jiangjiazhi / regional-platform

Download as
Browse Code »

Commit 2229aae7559967170976bfc95c458b7fa7a21e74

Authored by liquanyu
1 parent aa4560f150
Exists in master and in 6 other branches autism, dev, fengning, fengning2023-06-06, longhua, luanping

update code

Showing 2 changed files with 5 additions and 7 deletions

platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MybatisSqlInterceptor.java View file @ 2229aae
... ... @@ -137,6 +137,7 @@
137 137 {
138 138 sql = sql.replaceFirst("\\(","(ID,");
139 139 sql = sql.substring(0,sql.lastIndexOf("(")+1)+list.get(0)+","+sql.substring(sql.lastIndexOf("(")+1,sql.length());
  140 + System.out.println("add sync sql = "+sql);
140 141 //发送要同步的sql
141 142 SendMysqlSyncDatUtil.addSqlToQueue(sql, sqlId);
142 143 sql = null;
platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java View file @ 2229aae
... ... @@ -63,13 +63,10 @@
63 63 */
64 64 @Override
65 65 public void afterPropertiesSet() throws Exception {
66   - if ("2".equals(run_mode))
67   - {
68   - System.out.println("init .........");
69   - Thread thread = new HandleThread();
70   - thread.setName("syncMysqlThread");
71   - thread.start();
72   - }
  66 + System.out.println("init .........");
  67 + Thread thread = new HandleThread();
  68 + thread.setName("syncMysqlThread");
  69 + thread.start();
73 70 }
74 71  
75 72