Tenlion/wlcb-common-population
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改

Browse Source
This commit is contained in:
wans 2022-01-26 16:30:27 +08:00
parent 9f22f9c095
commit 527aa9ed9b
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/cn/com/tenlion/commonpopulation/service/basepopulationinfo/impl/BasePopulationInfoServiceImpl.java
View File

@ -591,6 +591,7 @@ public class BasePopulationInfoServiceImpl extends DefaultBaseService implements
jObj.put("tableNumber", tableNumber); jObj.put("tableNumber", tableNumber);
jObj.put("action", "save"); jObj.put("action", "save");
List<BasePopulationInfoDTO> fullList = basePopulationInfoDao.listBasePopulationInfo(null); List<BasePopulationInfoDTO> fullList = basePopulationInfoDao.listBasePopulationInfo(null);
int forIndex = 0;
for(BasePopulationInfoDTO item : fullList){ for(BasePopulationInfoDTO item : fullList){
jObj.put("uid", item.getBasePopulationInfoId()); jObj.put("uid", item.getBasePopulationInfoId());
PopulationInfo info = new PopulationInfo(); PopulationInfo info = new PopulationInfo();
@ -646,6 +647,10 @@ public class BasePopulationInfoServiceImpl extends DefaultBaseService implements
info.setgrid_name(item.getGridName() == null ? "" : item.getGridName()); info.setgrid_name(item.getGridName() == null ? "" : item.getGridName());
jObj.put("data", info.saveCheckToJson()); jObj.put("data", info.saveCheckToJson());
kafkaTemplate.send("tableSync", jObj.toJSONString()); kafkaTemplate.send("tableSync", jObj.toJSONString());
if(forIndex % 10000 == 0){
System.out.println("================= PULL_COUNT_" + forIndex + " =================");
}
forIndex++;
} }
} }