From d6ff18e0ff89d36e80195da43ca40bf3a8f42b2c Mon Sep 17 00:00:00 2001
From: Administrator <pjb>
Date: 星期日, 15 六月 2025 09:38:14 +0800
Subject: [PATCH] wms分配库位异常

---
 src/main/java/com/zy/asrs/task/TaskLogScheduler.java |   31 ++++++++++++++++++-------------
 1 files changed, 18 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/TaskLogScheduler.java b/src/main/java/com/zy/asrs/task/TaskLogScheduler.java
index cf1083a..71ad90a 100644
--- a/src/main/java/com/zy/asrs/task/TaskLogScheduler.java
+++ b/src/main/java/com/zy/asrs/task/TaskLogScheduler.java
@@ -12,6 +12,7 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.io.IOException;
 
@@ -42,20 +43,24 @@
                 case 5:
                     break;
             }
-            TaskWrkReport taskWrkReport = new TaskWrkReport();
-            TaskWrkLog taskWrkLog = new TaskWrkLog();
-            Synchro.Copy(taskWrk, taskWrkReport);
-            Synchro.Copy(taskWrk, taskWrkLog);
-            if (!taskWrkReportService.insert(taskWrkReport)) {
-                throw new CoolException("杞Щ鑷充笂鎶ヨ〃" + taskWrk);
-            }
-            if (!wrkLogService.insert(taskWrkLog)) {
-                throw new CoolException("杞巻鍙叉。澶辫触" + taskWrk);
-            }
-            if (!taskWrkService.deleteById(taskWrk)) {
-                throw new CoolException("浠诲姟妗e垹闄ゅけ璐�" + taskWrk);
-            }
+            exe(taskWrk);
         }
     }
 
+    @Transactional
+    public void exe(TaskWrk taskWrk) {
+        TaskWrkReport taskWrkReport = new TaskWrkReport();
+        TaskWrkLog taskWrkLog = new TaskWrkLog();
+        Synchro.Copy(taskWrk, taskWrkReport);
+        Synchro.Copy(taskWrk, taskWrkLog);
+        if (!wrkLogService.insert(taskWrkLog)) {
+            throw new CoolException("杞巻鍙叉。澶辫触" + taskWrk);
+        }
+        if (!taskWrkService.deleteById(taskWrk)) {
+            throw new CoolException("浠诲姟妗e垹闄ゅけ璐�" + taskWrk);
+        }
+        if (!taskWrkReportService.insert(taskWrkReport)) {
+            throw new CoolException("杞Щ鑷充笂鎶ヨ〃" + taskWrk);
+        }
+    }
 }

--
Gitblit v1.9.1