wulin/wl_management
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

提交修改

Browse Source
This commit is contained in:
quyixiao 2022-06-13 13:59:57 +08:00
parent 73619c25c1
commit 577a885323
1 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java
View File

@ -870,21 +870,20 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
log.info("开始批量初始化流程，任务数量{}", resultStarts.size()); log.info("开始批量初始化流程，任务数量{}", resultStarts.size());
String oldNo = Logger.inheritableThreadLocalNo.get(); String oldNo = Logger.inheritableThreadLocalNo.get();
for (StartStartDto startStartDto : resultStarts) { for (StartStartDto startStartDto : resultStarts) {
try {
oldNo = Logger.inheritableThreadLocalNo.get();
String newNo = oldNo + "_initFlowRecord_" + startStartDto.getResultRecordList().get(0).getStartId();
Logger.threadLocalNo.set(newNo);
log.info("初始化任务中绩效数量{}", startStartDto.getResultRecordList().size()); log.info("初始化任务中绩效数量{}", startStartDto.getResultRecordList().size());
for (ResultRecord resultRecord : startStartDto.getResultRecordList()) { for (ResultRecord resultRecord : startStartDto.getResultRecordList()) {
try {
String newNo = oldNo + "_initFlowRecord_" + resultRecord.getStartId();
Logger.threadLocalNo.set(newNo);
log.info("初始化绩效{}", resultRecord); log.info("初始化绩效{}", resultRecord);
resultRecordService.initFlowRecord(resultRecord, startStartDto.getFlows(), startStartDto.getFlowApprovalRoles()); resultRecordService.initFlowRecord(resultRecord, startStartDto.getFlows(), startStartDto.getFlowApprovalRoles());
}
} catch (Exception e) { } catch (Exception e) {
log.error("发出异常", e); log.error("发出异常", e);
} finally { } finally {
Logger.threadLocalNo.set(oldNo); Logger.threadLocalNo.set(oldNo);
} }
} }
}
Logger.threadLocalNo.set(oldNo); Logger.threadLocalNo.set(oldNo);
dingtalkBusiness.sendWorkMSGWithAsyn(noticeStaff, WorkMsgTypeEnum.START_WORK.getType()); dingtalkBusiness.sendWorkMSGWithAsyn(noticeStaff, WorkMsgTypeEnum.START_WORK.getType());
} catch (Exception e) { } catch (Exception e) {