From 51a540d2a561a9b9985e68bc21b93e622224c4c1 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期五, 15 三月 2024 13:33:54 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   28 ++++++++++++++++++++++++----
 1 files changed, 24 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index d44b9c2..50b7e6c 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -323,9 +323,18 @@
                                     log.error("杈撻�佺嚎鍛戒护涓嬫柟澶辫触锛侊紒锛� [宸ヤ綔鍙�:{}]", taskWrk.getWrkNo());
                                     continue;//鍛戒护涓嬪彂澶辫触
                                 }
-
                                 // 澶嶄綅鍫嗗灈鏈�
                                 crnThread.setResetFlag(true);
+
+                                if (taskWrk.getIoType() == 1 || taskWrk.getIoType() == 3){
+                                    taskWrk.setWrkSts(4);
+                                } else if (taskWrk.getIoType() == 2) {
+                                    taskWrk.setWrkSts(14);
+                                }
+                                if (!taskWrkService.updateById(taskWrk)){
+                                    log.error(taskWrk.getTaskNo()+ " 鍫嗗灈鏈轰换鍔″畬鎴愶紝鏀瑰彉浠诲姟鐘舵�佸け璐�");
+                                }
+
 
                             }
                         }
@@ -793,6 +802,14 @@
                 if (commandInfoService.updateById(commandInfo)) {//淇敼鎴愬姛鍚庡浣嶅爢鍨涙満
                     // 鍫嗗灈鏈哄浣�
                     crnThread.setResetFlag(true);
+                    if (taskWrk.getIoType() == 1 || taskWrk.getIoType() == 3){
+                        taskWrk.setWrkSts(4);
+                    } else if (taskWrk.getIoType() == 2) {
+                        taskWrk.setWrkSts(14);
+                    }
+                    if (!taskWrkService.updateById(taskWrk)){
+                        log.error(taskWrk.getTaskNo()+ " 鍫嗗灈鏈轰换鍔″畬鎴愶紝鏀瑰彉浠诲姟鐘舵�佸け璐�");
+                    }
                 }
             }
         }
@@ -992,11 +1009,14 @@
             }
 
             //鍒ゆ柇鏈鍛戒护鏄惁鎵ц瀹屾垚
-            CommandInfo commandInfo = commandInfos.get(commandInfos.size() - 1);
-            if (commandInfo.getCommandStatus() != CommandStatusType.COMPLETE.id) {
-                continue;//鎸囦护鏈畬鎴�
+            if (!commandInfos.isEmpty()){
+                CommandInfo commandInfo = commandInfos.get(commandInfos.size() - 1);
+                if (commandInfo.getCommandStatus() != CommandStatusType.COMPLETE.id) {
+                    continue;//鎸囦护鏈畬鎴�
+                }
             }
 
+
             Date now = new Date();
             //鎸囦护宸插畬鎴愶紝鏇存柊浠诲姟
             if (taskWrk.getIoType() == 1) {

--
Gitblit v1.9.1