fix(企标稽查计划): 80985
This commit is contained in:
+20
-8
@@ -168,14 +168,26 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
|
||||
}
|
||||
ProcessAll processAll = esInspectPlanFlowVO.getProcessAll();
|
||||
String projectId = processAll.getProjectId();
|
||||
processEsInspectPlanList.stream().map(v -> {
|
||||
if (StringUtils.isBlank(v.getId())){
|
||||
v.setId(String.valueOf(SnowflakeUtils.snowflake()));
|
||||
}
|
||||
v.setProjectId(projectId);
|
||||
return v;
|
||||
}).collect(Collectors.toList()).forEach(v -> log.info(v.toString()));
|
||||
processEsInspectPlanService.saveOrUpdateBatch(processEsInspectPlanList);
|
||||
|
||||
List<ProcessEsInspectPlan> updateProcessEsInspectPlanList = processEsInspectPlanList.stream()
|
||||
.filter(v -> StringUtils.isNotBlank(v.getId()))
|
||||
.map(v -> {
|
||||
v.setProjectId(projectId);
|
||||
return v;
|
||||
})
|
||||
.collect(Collectors.toList());
|
||||
processEsInspectPlanService.updateBatchById(updateProcessEsInspectPlanList);
|
||||
|
||||
List<ProcessEsInspectPlan> saveProcessEsInspectPlanList = processEsInspectPlanList.stream()
|
||||
.filter(v -> StringUtils.isBlank(v.getId()))
|
||||
.map(v -> {
|
||||
v.setId(String.valueOf(SnowflakeUtils.snowflake()));
|
||||
v.setProjectId(projectId);
|
||||
return v;
|
||||
})
|
||||
.collect(Collectors.toList());
|
||||
processEsInspectPlanService.saveBatch(saveProcessEsInspectPlanList);
|
||||
|
||||
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
||||
|
||||
// 处理意见
|
||||
|
||||
Reference in New Issue
Block a user