From 527aa9ed9b1be23b3b388e11072e1652c1a04f65 Mon Sep 17 00:00:00 2001 From: wans <747101512@qq.com> Date: Wed, 26 Jan 2022 16:30:27 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/BasePopulationInfoServiceImpl.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/main/java/cn/com/tenlion/commonpopulation/service/basepopulationinfo/impl/BasePopulationInfoServiceImpl.java b/src/main/java/cn/com/tenlion/commonpopulation/service/basepopulationinfo/impl/BasePopulationInfoServiceImpl.java index 415d91b..d917493 100644 --- a/src/main/java/cn/com/tenlion/commonpopulation/service/basepopulationinfo/impl/BasePopulationInfoServiceImpl.java +++ b/src/main/java/cn/com/tenlion/commonpopulation/service/basepopulationinfo/impl/BasePopulationInfoServiceImpl.java @@ -591,6 +591,7 @@ public class BasePopulationInfoServiceImpl extends DefaultBaseService implements jObj.put("tableNumber", tableNumber); jObj.put("action", "save"); List fullList = basePopulationInfoDao.listBasePopulationInfo(null); + int forIndex = 0; for(BasePopulationInfoDTO item : fullList){ jObj.put("uid", item.getBasePopulationInfoId()); PopulationInfo info = new PopulationInfo(); @@ -646,6 +647,10 @@ public class BasePopulationInfoServiceImpl extends DefaultBaseService implements info.setgrid_name(item.getGridName() == null ? "" : item.getGridName()); jObj.put("data", info.saveCheckToJson()); kafkaTemplate.send("tableSync", jObj.toJSONString()); + if(forIndex % 10000 == 0){ + System.out.println("================= PULL_COUNT_" + forIndex + " ================="); + } + forIndex++; } }