Commit 67e115d8 authored by 赵啸非's avatar 赵啸非

添加材料数量统计

parent d0e6b6a7
...@@ -44,6 +44,7 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService { ...@@ -44,6 +44,7 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService {
sitePdu.setId(1L); sitePdu.setId(1L);
Rest<List<SitePdu>> siteRest = siteFeign.getFlatSitesBySiteId(sitePdu); Rest<List<SitePdu>> siteRest = siteFeign.getFlatSitesBySiteId(sitePdu);
if (siteRest.getCode() == YesNoEnum.YES.getValue()) { if (siteRest.getCode() == YesNoEnum.YES.getValue()) {
log.info("总数量:{}",siteRest.getData().size());
siteRest.getData().forEach(site -> { siteRest.getData().forEach(site -> {
SiteMatterPdu siteMatterPdu = new SiteMatterPdu(); SiteMatterPdu siteMatterPdu = new SiteMatterPdu();
siteMatterPdu.setPage(1); siteMatterPdu.setPage(1);
...@@ -67,6 +68,7 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService { ...@@ -67,6 +68,7 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService {
if (!ObjectUtils.isEmpty(sheetMatterEntities)) { 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); List<List<SheetMatterEntity>> partition = ListUtil.partition(sheetMatterEntities, 500);
for (List<SheetMatterEntity> matterEntities : partition) { for (List<SheetMatterEntity> matterEntities : partition) {
sheetMatterService.save(matterEntities); sheetMatterService.save(matterEntities);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment