diff --git a/sample-form-manager/src/main/java/com/mortals/xhx/daemon/task/SyncSiteMatterTaskImpl.java b/sample-form-manager/src/main/java/com/mortals/xhx/daemon/task/SyncSiteMatterTaskImpl.java index fcd6fcd7542756cbe03d6dbd89e24942825044c3..824d3d82781d5934e12521b6b6f0a0cac001bfe1 100644 --- a/sample-form-manager/src/main/java/com/mortals/xhx/daemon/task/SyncSiteMatterTaskImpl.java +++ b/sample-form-manager/src/main/java/com/mortals/xhx/daemon/task/SyncSiteMatterTaskImpl.java @@ -44,6 +44,7 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService { sitePdu.setId(1L); Rest<List<SitePdu>> siteRest = siteFeign.getFlatSitesBySiteId(sitePdu); if (siteRest.getCode() == YesNoEnum.YES.getValue()) { + log.info("鎬绘暟閲忥細{}",siteRest.getData().size()); siteRest.getData().forEach(site -> { SiteMatterPdu siteMatterPdu = new SiteMatterPdu(); siteMatterPdu.setPage(1); @@ -51,6 +52,7 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService { Rest<RespData<List<SiteMatterPdu>>> siteMatterRest = siteMatterFeign.list(siteMatterPdu); if (siteMatterRest.getCode() == YesNoEnum.YES.getValue()) { //鍒犻櫎鍚庢柊澧� + log.info("浜嬮」鎬绘暟閲忥細{}",siteMatterRest.getData().getData().size()); List<SheetMatterEntity> sheetMatterEntities = siteMatterRest.getData().getData().stream().map(siteMatter -> { SheetMatterEntity sheetMatterEntity = new SheetMatterEntity(); sheetMatterEntity.initAttrValue(); @@ -67,12 +69,15 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService { if (!ObjectUtils.isEmpty(sheetMatterEntities)) { sheetMatterService.getDao().delete(new SheetMatterQuery().siteId(site.getId())); + log.info("鏂板鏁伴噺锛歿}",sheetMatterEntities.size()); List<List<SheetMatterEntity>> partition = ListUtil.partition(sheetMatterEntities, 500); for (List<SheetMatterEntity> matterEntities : partition) { sheetMatterService.save(matterEntities); } } + }else{ + log.info("璇锋眰閿欒锛宑ode:{}",siteMatterRest.getCode()); } }); }