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 385d8f7..f817795 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
@@ -3,7 +3,6 @@ package com.lyms.platform.operate.web.inteceptor;
 
 import com.lyms.platform.biz.service.SyncDataService;
 import com.lyms.platform.common.utils.ExceptionUtils;
-import com.lyms.platform.operate.web.utils.SendMysqlSyncDatUtil;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang.StringUtils;
 import org.apache.ibatis.executor.Executor;
@@ -78,8 +77,9 @@ public class MysqlDataInterceptor implements Interceptor {
                     if (isSyncTable(sql))
                     {
                         System.out.println("==============delete or update sync sql = " + sql);
+                        //syncDataService.savePostMysql(sql,sqlId);
                         sql = null;
-                        syncDataService.savePostMysql(sql,sqlId);
+
                     }
                 }
                 else  if ("insert".equals(sqlCommandType.toLowerCase()) )
@@ -100,10 +100,9 @@ public class MysqlDataInterceptor implements Interceptor {
                     if (returnValue != null && returnValue instanceof ArrayList)
                     {
                         List<Integer> list = (ArrayList)returnValue;
-                        if (CollectionUtils.isNotEmpty(list))
-                        {
+                        if (CollectionUtils.isNotEmpty(list)) {
                             System.out.println("============add sync sql = " + sql);
-                            syncDataService.savePostMysql(sql,sqlId);
+//                          syncDataService.savePostMysql(sql,sqlId);
                             sql = null;
                         }
                     }
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 633abfd..635e684 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
@@ -14,7 +14,6 @@ import java.util.HashSet;
 import java.util.Set;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.TimeUnit;
 
 /**
  * Created by lqy
@@ -23,9 +22,8 @@ import java.util.concurrent.TimeUnit;
 @Component
 public class SendMysqlSyncDatUtil implements InitializingBean {
 
-    public static final String run_mode = PropertiesUtils.getPropertyValue("run.mode");
 
-    private static BlockingQueue<SqlRequest> syncSqlQueue = new LinkedBlockingQueue(500);
+    private static BlockingQueue<SqlRequest> syncSqlQueue = new LinkedBlockingQueue(200);
 
     //配置文件中配置的要同步的区域的url地址
     private static Set<String> urls = new HashSet<>();