From a524e02e16c44465779ead49bb47d4d8ff016c7b Mon Sep 17 00:00:00 2001
From: yf001217 <834502597@qq.com>
Date: Mon, 15 Jun 2026 16:23:11 +0800
Subject: [PATCH] =?UTF-8?q?pqc=E5=B7=A5=E5=8D=95=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ...msIssueTicketProcessControllerService.java | 35 +++++++++++++++----
 1 file changed, 28 insertions(+), 7 deletions(-)

diff --git a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/QmsIssueTicketProcessControllerService.java b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/QmsIssueTicketProcessControllerService.java
index 0ae19518..a98ff508 100644
--- a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/QmsIssueTicketProcessControllerService.java
+++ b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/QmsIssueTicketProcessControllerService.java
@@ -15,6 +15,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
@@ -86,19 +87,39 @@ public class QmsIssueTicketProcessControllerService {
                         Collectors.mapping(QmsIssueTicketProcessAddQO.HandlerItem::getTaskResultId, Collectors.toList())
                 ));
 
+        List<Long> handlerUserIds = new ArrayList<>();
+
         // 为每个处理人创建处理记录
         for (Map.Entry<Long, List<Long>> entry : handlerToResultsMap.entrySet()) {
             doAdd(request.getIssueTicketId(), entry.getKey(), entry.getValue());
+            handlerUserIds.add(entry.getKey());
         }
 
-        if (Objects.equals(ticket.getSourceType(), (short) 3) && !Objects.equals(ticket.getStatus(), (short) 1)) {
-            issueTicketService.lambdaUpdate()
-                    .eq(QmsIssueTicket::getId, ticket.getId())
-                    .set(QmsIssueTicket::getStatus, (short) 1)
-                    .set(QmsIssueTicket::getUpdateUserId, currentUserId)
-                    .set(QmsIssueTicket::getUpdateUserName, currentUserName)
-                    .set(QmsIssueTicket::getUpdateTime, now)
+        if (Objects.equals(ticket.getSourceType(), (short) 3)) {
+            issueTicketToDoService.lambdaUpdate()
+                    .eq(QmsIssueTicketToDo::getTicketId, ticket.getId())
+                    .eq(QmsIssueTicketToDo::getHasProcessed, false)
+                    .set(QmsIssueTicketToDo::getHasProcessed, true)
                     .update();
+
+            for (Long handlerUserId : handlerUserIds) {
+                QmsIssueTicketToDo todoItem = new QmsIssueTicketToDo()
+                        .setTicketId(ticket.getId())
+                        .setHandlerUserId(handlerUserId)
+                        .setHasProcessed(false)
+                        .setIsRead(false);
+                issueTicketToDoService.save(todoItem);
+            }
+
+            if (!Objects.equals(ticket.getStatus(), (short) 1)) {
+                issueTicketService.lambdaUpdate()
+                        .eq(QmsIssueTicket::getId, ticket.getId())
+                        .set(QmsIssueTicket::getStatus, (short) 1)
+                        .set(QmsIssueTicket::getUpdateUserId, currentUserId)
+                        .set(QmsIssueTicket::getUpdateUserName, currentUserName)
+                        .set(QmsIssueTicket::getUpdateTime, now)
+                        .update();
+            }
         }
     }