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 2e4558c..05ca121 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
@@ -45,6 +45,7 @@ public class MybatisSqlInterceptor implements Interceptor {
Object[] args = invocation.getArgs();
Object returnValue = null;
+ System.out.println("args===="+args);
if (args != null && args.length == 2)
{
MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0];
@@ -61,6 +62,20 @@ public class MybatisSqlInterceptor implements Interceptor {
sql = getSql(configuration, boundSql, sqlId);
System.out.println("sqlCommandType = "+sqlCommandType+":mysql sql =" + sql);
returnValue = invocation.proceed();
+
+
+ //排除lis表
+ if (sql == null || sql.toUpperCase().contains("LIS_REPORT_TBL") || sql.toUpperCase().contains("RIS_REPORT_TBL"))
+ {
+ return returnValue;
+ }
+ if ("UPDATE".equals(sqlCommandType.toLowerCase()) || "DELETE".equals(sqlCommandType.toLowerCase()))
+ {
+ System.out.println("delete and update sync sql = "+sql);
+ //发送要同步的sql
+ SendMysqlSyncDatUtil.sendSql(sql, sqlId);
+ }
+
}
else
{
@@ -74,18 +89,20 @@ public class MybatisSqlInterceptor implements Interceptor {
{
sql = sql.replaceFirst("\\(","(ID,");
sql = sql.substring(0,sql.lastIndexOf("(")+1)+list.get(0)+","+sql.substring(sql.lastIndexOf("(")+1,sql.length());
+
+
+ //排除lis表
+ if (sql == null || sql.toUpperCase().contains("LIS_REPORT_TBL") || sql.toUpperCase().contains("RIS_REPORT_TBL"))
+ {
+ return returnValue;
+ }
+ System.out.println("add sync sql = "+sql);
+ //发送要同步的sql
+ SendMysqlSyncDatUtil.sendSql(sql, sqlId);
}
}
}
- //排除lis表
- if (sql == null || sql.toUpperCase().contains("LIS_REPORT_TBL") || sql.toUpperCase().contains("RIS_REPORT_TBL"))
- {
- return returnValue;
- }
- System.out.println("sync sql = "+sql);
- //发送要同步的sql
- SendMysqlSyncDatUtil.sendSql(sql, sqlId);
}
return returnValue;
diff --git a/platform-operate-api/src/main/resources/mybatis.xml b/platform-operate-api/src/main/resources/mybatis.xml
index befdd96..21e1189 100644
--- a/platform-operate-api/src/main/resources/mybatis.xml
+++ b/platform-operate-api/src/main/resources/mybatis.xml
@@ -13,10 +13,10 @@
-
-
-
-
+
\ No newline at end of file