111

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/impl/PreDealServiceImpl.java

@@ -11,10 +11,13 @@ import com.gic.haoban.manage.api.enums.PreDealTypeEnum;
 import com.gic.haoban.manage.service.dao.mapper.PreDealLogMapper;
 import com.gic.haoban.manage.service.entity.TabHaobanPreDealLog;
 import com.gic.haoban.manage.service.service.PreDealService;
+import com.gic.haoban.manage.service.task.QywxGroupSyncOperation;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 
 import org.apache.commons.collections.CollectionUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -31,13 +34,26 @@ public class PreDealServiceImpl implements PreDealService {
 
     @Autowired
     private PreDealLogMapper preDealLogMapper;
+    private static final Logger logger = LoggerFactory.getLogger(PreDealServiceImpl.class);
+    private static final int pageSize = 500;
 
     @Override
     public boolean insert(List<TabHaobanPreDealLog> list) {
         if (CollectionUtils.isEmpty(list)) {
             return true;
         }
-        preDealLogMapper.insertSelectiveBatch(list);
+    	//插入不存在的我们pre表的企业微信数据
+    	int count = list.size();
+    	int pre = count/pageSize+1;
+    	int  i= 0;
+    	while(i<pre){
+            logger.info("这是第{}次，进入",i);
+    		i++;
+	    	int fromIndex = (i-1)*pageSize;
+	    	int toIndex = (count-fromIndex) > pageSize ? (fromIndex+pageSize):count;
+    		List<TabHaobanPreDealLog>subList = list.subList(fromIndex, toIndex);
+    		preDealLogMapper.insertSelectiveBatch(subList);
+    	}
         return true;
     }
 

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/QywxGroupSyncOperation.java

@@ -224,17 +224,7 @@ public class QywxGroupSyncOperation implements BaseSyncOperation {
                     return dealLog;
                 }).collect(Collectors.toList());
             	//插入不存在的我们pre表的企业微信数据
-    	    	int count = preDealLogList.size();
-    	    	int pre = count/pageSize+1;
-    	    	int  i= 0;
-    	    	while(i<pre){
-    	            logger.info("这是第{}次，进入",i);
-    	    		i++;
-    		    	int fromIndex = (i-1)*pageSize;
-    		    	int toIndex = (count-fromIndex) > pageSize ? (fromIndex+pageSize):count;
-    	    		List<TabHaobanPreDealLog>subList = preDealLogList.subList(fromIndex, toIndex);
-    	            preDealService.insert(subList);
-    	    	}
+	            preDealService.insert(preDealLogList);
             }
         }