add

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