haligit pu
This commit is contained in:
parent
1334347fe9
commit
103f53c0d5
@ -835,20 +835,12 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
|
|||||||
//String newNo = oldNo + "_initFlowRecord" ;//+ resultRecord.getStaffId() + "_" + resultRecord.getId();
|
//String newNo = oldNo + "_initFlowRecord" ;//+ resultRecord.getStaffId() + "_" + resultRecord.getId();
|
||||||
//ch.qos.logback.classic.Logger.threadLocalNo.set(newNo);
|
//ch.qos.logback.classic.Logger.threadLocalNo.set(newNo);
|
||||||
log.info("开始批量初始化流程,数量{}", resultRecords.size());
|
log.info("开始批量初始化流程,数量{}", resultRecords.size());
|
||||||
int i = 10;
|
|
||||||
while(i > 0){
|
|
||||||
for (ResultRecord resultRecord:resultRecords
|
for (ResultRecord resultRecord:resultRecords
|
||||||
) {
|
) {
|
||||||
resultRecordService.initFlowRecord(resultRecord.getId());
|
resultRecordService.initFlowRecord(resultRecord.getId());
|
||||||
}
|
}
|
||||||
log.info("批量{}", i);
|
|
||||||
try {
|
|
||||||
Thread.sleep(1000);
|
|
||||||
} catch (InterruptedException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
i--;
|
|
||||||
}
|
|
||||||
|
|
||||||
//ch.qos.logback.classic.Logger.threadLocalNo.set(oldNo);
|
//ch.qos.logback.classic.Logger.threadLocalNo.set(oldNo);
|
||||||
dingtalkBusiness.sendWorkMSGWithAsyn(noticeStaff, WorkMsgTypeEnum.START_WORK.getType());
|
dingtalkBusiness.sendWorkMSGWithAsyn(noticeStaff, WorkMsgTypeEnum.START_WORK.getType());
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user