add

src/main/java/com/zfire/jiasm/syncdata/service/impl/GLPPGFWebsitWorkerServiceImpl.java

@@ -285,19 +285,19 @@ public class GLPPGFWebsitWorkerServiceImpl implements GLPPGFWebsitWorkerService
                 }
             }
             // 修改品牌商网点师傅数据
-            if (upWorkerBrandAccounts.size()>3000){
+            if (upWorkerBrandAccounts.size()>1000){
                 workerBrandAccountService.updateBatchById(upWorkerBrandAccounts);
                 upWorkerBrandAccounts.clear();
             }
 
             // 新增品牌师傅网点信息
-            if (addwbas.size()>3000){
+            if (addwbas.size()>1000){
                 workerBrandAccountService.saveBatch(addwbas);
                 addwbas.clear();
             }
 
             // 新增师傅所在平台网点信息
-            if (websitWorkeradd.size()>3000){
+            if (websitWorkeradd.size()>1000){
                 websitWorkerService.saveBatch(websitWorkeradd);
                 websitWorkeradd.clear();
             }
@@ -611,7 +611,7 @@ public class GLPPGFWebsitWorkerServiceImpl implements GLPPGFWebsitWorkerService
             getWorker(addWorkerRec, sfzens, m, workerIdcardMap);
 
             // 新增的插入到表
-            if (addWorkerRec.size()>=3000){
+            if (addWorkerRec.size()>=1000){
                 workerService.saveOrUpdateBatch(addWorkerRec);
                 log.info("本地网点维修工人员信息表新增插入了{}条数据", addWorkerRec.size());
                 addWorkerRec.clear();
@@ -699,7 +699,7 @@ public class GLPPGFWebsitWorkerServiceImpl implements GLPPGFWebsitWorkerService
                 ItfTblWangdianWxgDownload old = oldRecMap.get(item.getWxgid()).get(0);
                 MyBeanUtils.copyProperties(item,old);
                 update.add(old);
-                if (update.size()>3000){
+                if (update.size()>1000){
                     itfTblWangdianWxgDownloadService.updateBatchById(update);
                     log.info("网点维修工基础资料信息同步更新修改了{}条数据", update.size());
                     update.clear();
@@ -713,7 +713,7 @@ public class GLPPGFWebsitWorkerServiceImpl implements GLPPGFWebsitWorkerService
                 item.setSynTimes(0);
                 add.add(item);
 
-                if (add.size()>3000){
+                if (add.size()>1000){
                     itfTblWangdianWxgDownloadService.saveBatch(add);
                     log.info("网点维修工基础资料信息同步新增插入了{}条数据", add.size());
                     add.clear();

src/main/java/com/zfire/jiasm/syncdata/service/impl/GLPPLeiBieServiceImpl.java

@@ -226,7 +226,7 @@ public class GLPPLeiBieServiceImpl implements GLPPLeiBieService {
                 }
 
                 addProduct.add(v);
-                if (addProduct.size()>=3000){
+                if (addProduct.size()>=1000){
                     productService.saveBatch(addProduct);
                     log.info("本地机型信息表新增插入了{}条数据",addProduct.size());
                     addProduct.clear();
@@ -961,7 +961,7 @@ public class GLPPLeiBieServiceImpl implements GLPPLeiBieService {
                 oldRecId.add(item.getId());
                 addRec.add(item);
 
-                if (addRec.size()>=3000){
+                if (addRec.size()>=1000){
                     itfTblSplbJixinDownloadService.saveBatch(addRec);
                     log.info("格力品牌机型基础资料信息同步新增插入了{}条数据", addRec.size());
                     addAllRec.addAll(addRec);

src/main/java/com/zfire/jiasm/syncdata/service/impl/GLPPWXGQueryAddServiceImpl.java

@@ -492,7 +492,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
         ItfTblWangdianPositionDownload item = new ItfTblWangdianPositionDownload();
         BeanUtils.copyProperties(wvos,item);
         wdwxgadd.add(item);
-        if (wdwxgadd.size()>3000){
+        if (wdwxgadd.size()>1000){
             itfTblWangdianPositionDownloadService.saveBatch(wdwxgadd);
             wdwxgadd.clear();
         }

src/main/java/com/zfire/jiasm/syncdata/service/impl/MasterDownloadServiceImpl.java

@@ -1149,7 +1149,7 @@ public class MasterDownloadServiceImpl implements MasterDownloadService {
 			item.setSynTimes(0);
 			addRec.add(item);
 
-			if (addRec.size()>2000){
+			if (addRec.size()>1000){
 				itfTblWxCpgzDownloadService.saveBatch(addRec);
 				log.info("产品故障基表信息同步新增插入了{}条数据", addRec.size());
 				addRec.clear();
@@ -1180,7 +1180,7 @@ public class MasterDownloadServiceImpl implements MasterDownloadService {
 			item.setSynTimes(0);
 			addRec.add(item);
 
-			if (addRec.size()>2000){
+			if (addRec.size()>1000){
 				itfJhAzdCauseSortNewDownloadService.saveBatch(addRec);
 				log.info("晶弘冰箱故障代码信息同步新增插入了{}条数据", addRec.size());
 				addRec.clear();
@@ -1206,7 +1206,7 @@ public class MasterDownloadServiceImpl implements MasterDownloadService {
 			item.setSynTimes(0);
 			addRec.add(item);
 
-			if (addRec.size()>2000){
+			if (addRec.size()>1000){
 				itfTblWxCpgzXjdDownloadService.saveBatch(addRec);
 				log.info("生活电话故障代码信息同步新增插入了{}条数据", addRec.size());
 				addRec.clear();
@@ -1246,7 +1246,7 @@ public class MasterDownloadServiceImpl implements MasterDownloadService {
 			item.setSynTimes(0);
 			addRec.add(item);
 
-			if (addRec.size()>2000){
+			if (addRec.size()>1000){
 				itfTblWxGzdmWxxmjcDownloadService.saveBatch(addRec);
 				log.info("故障代码与维修项目基表信息同步新增插入了{}条数据", addRec.size());
 				addRec.clear();
@@ -1303,7 +1303,7 @@ public class MasterDownloadServiceImpl implements MasterDownloadService {
 			item.setSynTimes(0);
 			addRec.add(item);
 
-			if (addRec.size()>2000){
+			if (addRec.size()>1000){
 				itfTblWxWxxmjcDownloadService.saveBatch(addRec);
 				log.info("维修项目基表信息同步新增插入了{}条数据", addRec.size());
 				addRec.clear();
@@ -1337,7 +1337,7 @@ public class MasterDownloadServiceImpl implements MasterDownloadService {
 			item.setSynTimes(0);
 			addRec.add(item);
 
-			if (addRec.size()>2000){
+			if (addRec.size()>1000){
 				itfJhAzdCauseAtterDownloadService.saveBatch(addRec);
 				log.info("晶弘冰箱维修项目基表信息同步新增插入了{}条数据", addRec.size());
 				addRec.clear();
@@ -1372,7 +1372,7 @@ public class MasterDownloadServiceImpl implements MasterDownloadService {
 			item.setSynTimes(0);
 			addRec.add(item);
 
-			if (addRec.size()>2000){
+			if (addRec.size()>1000){
 				itfTblWxWxxmXjdDownloadService.saveBatch(addRec);
 				log.info("晶弘冰箱维修项目基表信息同步新增插入了{}条数据", addRec.size());
 				addRec.clear();

src/main/java/com/zfire/jiasm/syncdata/service/impl/ProvinceCityAreaTownServiceImpl.java

@@ -198,7 +198,7 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
                 }
 
                 // 新增的插入到表
-                if (addStreet.size()>2000){
+                if (addStreet.size()>1000){
                     streetService.saveBatch(addStreet);
                     log.info("本地乡镇信息表新增插入了{}条数据",addStreet.size());
                     addStreet.clear();
@@ -254,7 +254,7 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
                 }
 
                 // 更新
-                if (updateStreet.size()>2000){
+                if (updateStreet.size()>1000){
                     streetService.updateBatchById(updateStreet);
                     log.info("本地乡镇信息表更新修改了{}条数据", updateStreet.size());
                     updateStreet.clear();
@@ -345,7 +345,7 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
                 addRec.add(item);
             }
 
-            if (addRec.size()>=2000){
+            if (addRec.size()>=1000){
                 // 插入到表
                 itfTblCityJdxzDownloadService.saveBatch(addRec);
                 log.info("乡镇信息同步新增插入了{}条数据", addRec.size());
@@ -353,7 +353,7 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
                 addRec.clear();
             }
 
-            if (updateRecn.size()>=2000){
+            if (updateRecn.size()>=1000){
                 // 插入到表
                 itfTblCityJdxzDownloadService.saveBatch(updateRecn);
                 log.info("乡镇信息同步更新修改了{}条数据", updateRecn.size());
@@ -517,7 +517,7 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
                 }
 
                 // 新增的插入到表
-                if (addCity.size()>2000){
+                if (addCity.size()>1000){
                     cityService.saveBatch(addCity);
                     log.info("本地市信息表新增插入了{}条数据",addCity.size());
                     addCity.clear();
@@ -545,7 +545,7 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
                 }
 
                 // 更新
-                if (updateCity.size()>2000){
+                if (updateCity.size()>1000){
                     cityService.updateBatchById(updateCity);
                     log.info("本地市信息表更新修改了{}条数据", updateCity.size());
                     updateCity.clear();
@@ -569,13 +569,13 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
 
     private void extractedLocalCityAddOrUpdata(List<ItfTblCityDownload> addRec, List<ItfTblCityDownload> updateRec) {
         // 新增的插入到表
-        if (addRec.size()>2000){
+        if (addRec.size()>1000){
             itfTblCityDownloadService.saveBatch(addRec);
             log.info("市信息同步新增插入了{}条数据", addRec.size());
             addRec.clear();
         }
         // 更新
-        if (updateRec.size()>2000){
+        if (updateRec.size()>1000){
             itfTblCityDownloadService.updateBatchById(updateRec);
             log.info("市信息同步更新修改了{}条数据", updateRec.size());
             updateRec.clear();
@@ -685,13 +685,13 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
             }
 
             // 新增的插入到表
-            if (addRecn.size()>2000){
+            if (addRecn.size()>1000){
                 itfTblCountyDownloadService.saveBatch(addRecn);
                 log.info("区信息同步新增插入了{}条数据", addRecn.size());
                 addRecn.clear();
             }
             // 更新
-            if (updateRecn.size()>2000){
+            if (updateRecn.size()>1000){
                 itfTblCountyDownloadService.updateBatchById(updateRecn);
                 log.info("区信息同步更新修改了{}条数据", updateRecn.size());
                 updateRecn.clear();
@@ -781,7 +781,7 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
                 }
 
                 // 更新
-                if (updateArea.size()>2000){
+                if (updateArea.size()>1000){
                     areaService.updateBatchById(updateArea);
                     updateArea.clear();
                     log.info("本地区信息表更新修改了{}条数据", updateArea.size());
@@ -826,7 +826,7 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
                     addArea.add(v);
 
                     // 新增的插入到表
-                    if (addArea.size()>2000){
+                    if (addArea.size()>1000){
                         areaService.saveBatch(addArea);
                         addArea.clear();
                         log.info("本地区信息表新增插入了{}条数据",addArea.size());