Skip to content

S
sample-form-platform
Commit 303ac98c authored by 赵啸非's avatar 赵啸非
Browse files
Options

添加材料数量统计

parent e6d7b8ac
Hide whitespace changes
Inline Side-by-side
Showing with 40 additions and 31 deletions
sample-form-manager/src/main/java/com/mortals/xhx/daemon/task/SyncSiteMatterTaskImpl.java
View file @ 303ac98c
......@@ -46,39 +46,48 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService {
if (siteRest.getCode() == YesNoEnum.YES.getValue()) {
log.info("总数量：{}",siteRest.getData().size());
siteRest.getData().forEach(site -> {
SiteMatterPdu siteMatterPdu = new SiteMatterPdu();
siteMatterPdu.setPage(1);
siteMatterPdu.setSize(-1);
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();
sheetMatterEntity.setId(siteMatter.getMatterId());
sheetMatterEntity.setSiteId(siteMatter.getSiteId());
sheetMatterEntity.setMatterName(siteMatter.getMatterName());
sheetMatterEntity.setMatterNo(siteMatter.getMatterCode());
sheetMatterEntity.setDeptCode(siteMatter.getDeptCode());
sheetMatterEntity.setDeptName(siteMatter.getDeptName());
sheetMatterEntity.setAreaCode(siteMatter.getAreaCode());
sheetMatterEntity.setSource(siteMatter.getSource());
return sheetMatterEntity;
}).collect(Collectors.toList());
int page=20;
int pageNum=500;
for(int i=1;i<=page;i++){
SiteMatterPdu siteMatterPdu = new SiteMatterPdu();
siteMatterPdu.setPage(i);
siteMatterPdu.setSize(pageNum);
Rest<RespData<List<SiteMatterPdu>>> siteMatterRest = siteMatterFeign.list(siteMatterPdu);
if (siteMatterRest.getCode() == YesNoEnum.YES.getValue()) {
if(siteMatterRest.getData().getData().size()==0){
log.info("数据没有！跳出循环");
break;
}
//删除后新增
log.info("事项总数量：{}",siteMatterRest.getData().getData().size());
List<SheetMatterEntity> sheetMatterEntities = siteMatterRest.getData().getData().stream().map(siteMatter -> {
SheetMatterEntity sheetMatterEntity = new SheetMatterEntity();
sheetMatterEntity.initAttrValue();
sheetMatterEntity.setId(siteMatter.getMatterId());
sheetMatterEntity.setSiteId(siteMatter.getSiteId());
sheetMatterEntity.setMatterName(siteMatter.getMatterName());
sheetMatterEntity.setMatterNo(siteMatter.getMatterCode());
sheetMatterEntity.setDeptCode(siteMatter.getDeptCode());
sheetMatterEntity.setDeptName(siteMatter.getDeptName());
sheetMatterEntity.setAreaCode(siteMatter.getAreaCode());
sheetMatterEntity.setSource(siteMatter.getSource());
return sheetMatterEntity;
}).collect(Collectors.toList());
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);
}
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("请求错误，code:{}",siteMatterRest.getCode());
}
}
}
}else{
log.info("请求错误，code:{}",siteMatterRest.getCode());
}
});
}
}
......
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