|
@@ -57,6 +57,8 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
|
|
|
// 省份数据同步到本地表
|
|
|
localextracted(addRec, updateRec);
|
|
|
+ addRec.clear();
|
|
|
+ updateRec.clear();
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -91,6 +93,8 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
|
|
|
// 市数据同步到本地表
|
|
|
extractedLoadlCityAddOrUpdate(addRec, updateRec);
|
|
|
+ addRec.clear();
|
|
|
+ updateRec.clear();
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -106,6 +110,8 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
|
|
|
// 区数据同步到本地表
|
|
|
extractedLoaclAreaAddOrUpdate(addRec, updateRec);
|
|
|
+ addRec.clear();
|
|
|
+ updateRec.clear();
|
|
|
}
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@@ -134,12 +140,17 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
if (addStreet.size()>0){
|
|
|
streetService.saveBatch(addStreet);
|
|
|
log.info("本地乡镇信息表新增插入了{}条数据",addStreet.size());
|
|
|
+ addStreet.clear();
|
|
|
}
|
|
|
// 更新
|
|
|
if (updateStreet.size()>0){
|
|
|
streetService.updateBatchById(updateStreet);
|
|
|
log.info("本地乡镇信息表更新修改了{}条数据", updateStreet.size());
|
|
|
+ updateStreet.clear();
|
|
|
}
|
|
|
+
|
|
|
+ addAllRec.clear();
|
|
|
+ updateRec.clear();
|
|
|
}
|
|
|
|
|
|
private void extractedStreetAdd(List<ItfTblCityJdxzDownload> addAllRec, List<String> areaRecName,
|
|
@@ -189,8 +200,8 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
// 新增的插入到表
|
|
|
if (addStreet.size()>2000){
|
|
|
streetService.saveBatch(addStreet);
|
|
|
- addStreet.clear();
|
|
|
log.info("本地乡镇信息表新增插入了{}条数据",addStreet.size());
|
|
|
+ addStreet.clear();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -410,11 +421,13 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
if (addProvince.size()>0){
|
|
|
provinceService.saveBatch(addProvince);
|
|
|
log.info("本地省份信息表新增插入了{}条数据",addProvince.size());
|
|
|
+ addProvince.clear();
|
|
|
}
|
|
|
// 更新
|
|
|
if (updateProvince.size()>0){
|
|
|
provinceService.updateBatchById(updateProvince);
|
|
|
log.info("本地省份信息表更新修改了{}条数据", updateProvince.size());
|
|
|
+ updateProvince.clear();
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -506,8 +519,8 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
// 新增的插入到表
|
|
|
if (addCity.size()>2000){
|
|
|
cityService.saveBatch(addCity);
|
|
|
- addCity.clear();
|
|
|
log.info("本地市信息表新增插入了{}条数据",addCity.size());
|
|
|
+ addCity.clear();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -534,8 +547,8 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
// 更新
|
|
|
if (updateCity.size()>2000){
|
|
|
cityService.updateBatchById(updateCity);
|
|
|
- updateCity.clear();
|
|
|
log.info("本地市信息表更新修改了{}条数据", updateCity.size());
|
|
|
+ updateCity.clear();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -544,11 +557,13 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
if (addCity.size()>0){
|
|
|
cityService.saveBatch(addCity);
|
|
|
log.info("本地市信息表新增插入了{}条数据",addCity.size());
|
|
|
+ addCity.clear();
|
|
|
}
|
|
|
// 更新
|
|
|
if (updateCity.size()>0){
|
|
|
cityService.updateBatchById(updateCity);
|
|
|
log.info("本地市信息表更新修改了{}条数据", updateCity.size());
|
|
|
+ updateCity.clear();
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -556,14 +571,14 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
// 新增的插入到表
|
|
|
if (addRec.size()>2000){
|
|
|
itfTblCityDownloadService.saveBatch(addRec);
|
|
|
- addRec.clear();
|
|
|
log.info("市信息同步新增插入了{}条数据", addRec.size());
|
|
|
+ addRec.clear();
|
|
|
}
|
|
|
// 更新
|
|
|
if (updateRec.size()>2000){
|
|
|
itfTblCityDownloadService.updateBatchById(updateRec);
|
|
|
- updateRec.clear();
|
|
|
log.info("市信息同步更新修改了{}条数据", updateRec.size());
|
|
|
+ updateRec.clear();
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -688,15 +703,15 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
// 新增的插入到表
|
|
|
if (addRecn.size()>0){
|
|
|
itfTblCountyDownloadService.saveBatch(addRecn);
|
|
|
- addRecn.clear();
|
|
|
log.info("区信息同步新增插入了{}条数据", addRecn.size());
|
|
|
+ addRecn.clear();
|
|
|
|
|
|
}
|
|
|
// 更新
|
|
|
if (updateRecn.size()>0){
|
|
|
itfTblCountyDownloadService.updateBatchById(updateRecn);
|
|
|
- updateRecn.clear();
|
|
|
log.info("区信息同步更新修改了{}条数据", updateRecn.size());
|
|
|
+ updateRecn.clear();
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -717,14 +732,14 @@ public class ProvinceCityAreaTownServiceImpl implements ProvinceCityAreaTownServ
|
|
|
// 新增的插入到表
|
|
|
if (addArea.size()>0){
|
|
|
areaService.saveBatch(addArea);
|
|
|
- addArea.clear();
|
|
|
log.info("本地区信息表新增插入了{}条数据",addArea.size());
|
|
|
+ addArea.clear();
|
|
|
}
|
|
|
// 更新
|
|
|
if (updateArea.size()>0){
|
|
|
areaService.updateBatchById(updateArea);
|
|
|
- updateArea.clear();
|
|
|
log.info("本地区信息表更新修改了{}条数据", updateArea.size());
|
|
|
+ updateArea.clear();
|
|
|
}
|
|
|
}
|
|
|
|