From 7fc6af8642885c3881904b2decd5dfb7cb45a8f3 Mon Sep 17 00:00:00 2001
From: liquanyu <liquanyu@lymsh.com>
Date: Thu, 27 Apr 2017 19:39:32 +0800
Subject: [PATCH] update

---
 .../web/inteceptor/MybatisSqlInterceptor.java      | 33 ++++++++++++++++------
 .../src/main/resources/mybatis.xml                 | 10 +++----
 2 files changed, 30 insertions(+), 13 deletions(-)

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 @@
     <setting name="defaultStatementTimeout" value="25000" />
     <setting name="callSettersOnNulls" value="true"/>
 </settings>
-    <plugins>
-        <!-- mybatis写出sql记录控件(拦截器) -->
-        <plugin interceptor="com.lyms.platform.operate.web.inteceptor.MybatisSqlInterceptor">  <!-- 自己写的那个拦截器 -->
-            <property name="dialect" value="mysql"/> <!-- mysql的方言 -->
+    <!-- <plugins>
+        mybatis写出sql记录控件(拦截器)
+        <plugin interceptor="com.lyms.platform.operate.web.inteceptor.MybatisSqlInterceptor">
+            <property name="dialect" value="mysql"/>
         </plugin>
-    </plugins>
+    </plugins> -->
 </configuration>
\ No newline at end of file
-- 
1.8.3.1