From 4457030b0d7b8166074b380405951fa7e5175c5f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B5=B5=E5=95=B8=E9=9D=9E?= <13281114856@qq.com> Date: Sun, 19 Feb 2023 16:23:05 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=9D=90=E6=96=99=E6=95=B0?= =?UTF-8?q?=E9=87=8F=E7=BB=9F=E8=AE=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xhx/daemon/task/SyncSiteMatterTaskImpl.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) 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 dd3c031..4e77a7d 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 @@ -46,7 +46,8 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService { if (siteRest.getCode() == YesNoEnum.YES.getValue()) { log.info("鎬绘暟閲忥細{}",siteRest.getData().size()); siteRest.getData().forEach(site -> { - int page=100; + sheetMatterService.getDao().delete(new SheetMatterQuery().siteId(site.getId())); + int page=100; int pageNum=100; for(int i=1;i<=page;i++){ SiteMatterPdu siteMatterPdu = new SiteMatterPdu(); @@ -76,12 +77,12 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService { }).collect(Collectors.toList()); if (!ObjectUtils.isEmpty(sheetMatterEntities)) { - sheetMatterService.getDao().delete(new SheetMatterQuery().siteId(site.getId())); + // sheetMatterService.getDao().delete(new SheetMatterQuery().siteId(site.getId())); log.info("鏂板鏁伴噺锛歿}",sheetMatterEntities.size()); - List<List<SheetMatterEntity>> partition = ListUtil.partition(sheetMatterEntities, 500); + sheetMatterService.save(sheetMatterEntities); + /* List<List<SheetMatterEntity>> partition = ListUtil.partition(sheetMatterEntities, 500); for (List<SheetMatterEntity> matterEntities : partition) { - sheetMatterService.save(matterEntities); - } + }*/ } }else{ -- 2.24.3