diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MybatisSqlInterceptor.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MybatisSqlInterceptor.java index d62c223..7cfc96d 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MybatisSqlInterceptor.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MybatisSqlInterceptor.java @@ -111,7 +111,6 @@ public class MybatisSqlInterceptor implements Interceptor { if (CollectionUtils.isNotEmpty(list)) { sql = sql.replaceFirst("\\(", "(ID,"); sql = sql.substring(0, sql.lastIndexOf("(") + 1) + list.get(0) + "," + sql.substring(sql.lastIndexOf("(") + 1, sql.length()); - System.out.println("add sync sql = " + sql); //发送要同步的sql SendMysqlSyncDatUtil.addSqlToQueue(sql, sqlId); sql = null; diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java index dfd3f46..d13b9d7 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java @@ -67,7 +67,6 @@ public class MysqlDataInterceptor implements Interceptor { sql = getSql(configuration, boundSql, sqlId); if (isSyncTable(sql)) { - System.out.println("delete or update sync sql = " + sql); SendMysqlSyncDatUtil.addSqlToQueue1(sql,sqlId); } } @@ -76,7 +75,6 @@ public class MysqlDataInterceptor implements Interceptor { sql = getSql(configuration, boundSql, sqlId); if (isSyncTable(sql)) { - System.out.println("add sync sql = " + sql); SendMysqlSyncDatUtil.addSqlToQueue1(sql,sqlId); } } diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java index aec9e4f..f3a6518 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java @@ -60,7 +60,6 @@ public class SendMysqlSyncDatUtil implements InitializingBean { request.setSql(Base64.encodeBase64String(sql.getBytes("utf-8"))); request.setSqlId(sqlId); syncSqlQueue.add(request); - System.out.println("syncSqlQueue size = " + syncSqlQueue.size()); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } @@ -74,7 +73,6 @@ public class SendMysqlSyncDatUtil implements InitializingBean { request.setSql(sql); request.setSqlId(sqlId); syncSqlQueue1.add(request); - System.out.println("syncSqlQueue1 size = " + syncSqlQueue.size()); } /** @@ -84,7 +82,6 @@ public class SendMysqlSyncDatUtil implements InitializingBean { */ @Override public void afterPropertiesSet() throws Exception { - System.out.println("init sync sql thread........."); Thread thread = new HandleThread(); Thread thread1 = new HandleThread1(); thread.setName("syncMysqlThread"); @@ -107,7 +104,6 @@ public class SendMysqlSyncDatUtil implements InitializingBean { try { Thread.sleep(3000); request = syncSqlQueue.take(); - System.out.println(request); String json = JsonUtil.obj2Str(request); if (CollectionUtils.isNotEmpty(urls)) { @@ -116,7 +112,6 @@ public class SendMysqlSyncDatUtil implements InitializingBean { for (int i = 0 ; i < 3 ; i++) { String result = HttpClientUtil.doPostSSL(url,json,"3d19960bf3e81e7d816c4f26051c49ba"); - System.out.println("sync mysql result = " + result+";url="+url); if (result == null) { continue;