From 577a885323474e8731551e4ad36fac17042d4fc5 Mon Sep 17 00:00:00 2001
From: quyixiao <2621048238@qq.com>
Date: Mon, 13 Jun 2022 13:59:57 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/FlowStartServiceImpl.java    | 19 +++++++++----------
 1 file changed, 9 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java b/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java
index 8e30c851..e29f3bd5 100644
--- a/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java
+++ b/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java
@@ -870,19 +870,18 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
                 log.info("开始批量初始化流程，任务数量{}", resultStarts.size());
                 String oldNo = Logger.inheritableThreadLocalNo.get();
                 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());
-                        for (ResultRecord resultRecord : startStartDto.getResultRecordList()) {
+                    log.info("初始化任务中绩效数量{}", startStartDto.getResultRecordList().size());
+                    for (ResultRecord resultRecord : startStartDto.getResultRecordList()) {
+                        try {
+                            String newNo = oldNo + "_initFlowRecord_" + resultRecord.getStartId();
+                            Logger.threadLocalNo.set(newNo);
                             log.info("初始化绩效{}", resultRecord);
                             resultRecordService.initFlowRecord(resultRecord, startStartDto.getFlows(), startStartDto.getFlowApprovalRoles());
+                        } catch (Exception e) {
+                            log.error("发出异常", e);
+                        } finally {
+                            Logger.threadLocalNo.set(oldNo);
                         }
-                    } catch (Exception e) {
-                        log.error("发出异常", e);
-                    } finally {
-                        Logger.threadLocalNo.set(oldNo);
                     }
                 }
                 Logger.threadLocalNo.set(oldNo);