From f68dd32cdd75924ebded3800cf37fa9110f9ec01 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期五, 07 六月 2024 10:31:33 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   38 ++++++++++++++++++++++----------------
 1 files changed, 22 insertions(+), 16 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 55ace44..0ae1e4f 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -357,6 +357,8 @@
                                 } else if (taskWrk.getIoType() == 2) {
                                     taskWrk.setWrkSts(14);
                                 }
+                                Date now = new Date();
+                                taskWrk.setCompleteTime(now);
                                 if (!taskWrkService.updateById(taskWrk)){
                                     log.error(taskWrk.getTaskNo()+ " 鍫嗗灈鏈轰换鍔″畬鎴愶紝鏀瑰彉浠诲姟鐘舵�佸け璐�");
                                 }
@@ -464,6 +466,7 @@
                 log.error("杩涘叆淇敼宸ヤ綔妗f祦绋�");
                 Date now = new Date();
                 taskWrk.setWrkSts(3);
+                taskWrk.setExecuteTime(now);
                 taskWrk.setModiTime(now);
                 if (taskWrkMapper.updateById(taskWrk) == 0) {
                     log.error("淇敼宸ヤ綔妗g姸鎬� 2.璁惧涓婅蛋 => 3.鍚婅溅鍏ュ簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", taskWrk.getWrkNo());
@@ -642,6 +645,7 @@
                             // 淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 12.鍚婅溅鍑哄簱涓�
                             Date now = new Date();
                             taskWrk.setWrkSts(12);
+                            taskWrk.setExecuteTime(now);
                             taskWrk.setModiTime(now);
                             if (taskWrkMapper.updateById(taskWrk) == 0) {
                                 log.error("淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 12.鍚婅溅鍑哄簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", taskWrk.getWrkNo());
@@ -833,6 +837,8 @@
                     } else if (taskWrk.getIoType() == 2) {
                         taskWrk.setWrkSts(14);
                     }
+                    Date now = new Date();
+                    taskWrk.setCompleteTime(now);
                     if (!taskWrkService.updateById(taskWrk)){
                         log.error(taskWrk.getTaskNo()+ " 鍫嗗灈鏈轰换鍔″畬鎴愶紝鏀瑰彉浠诲姟鐘舵�佸け璐�");
                     }
@@ -1028,24 +1034,24 @@
     public synchronized void autoCompleteTask() {
         List<TaskWrk> taskWrks = taskWrkMapper.selectWorkingTask();
         for (TaskWrk taskWrk : taskWrks) {
-            //鑾峰彇鍛戒护闆嗗悎
-            List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskWrk.getTaskNo());
-            if (taskWrk.getCommandStep() < commandInfos.size()) {
-                continue;//褰撳墠姝ュ簭娌℃湁鍒拌揪鏈�鍚庝竴鏉″懡浠�
-            }
-
-            //鍒ゆ柇鏈鍛戒护鏄惁鎵ц瀹屾垚
-            if (!commandInfos.isEmpty()){
-                CommandInfo commandInfo = commandInfos.get(commandInfos.size() - 1);
-                if (commandInfo.getCommandStatus() != CommandStatusType.COMPLETE.id) {
-                    continue;//鎸囦护鏈畬鎴�
-                }
-            }
+//            //鑾峰彇鍛戒护闆嗗悎
+//            List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskWrk.getTaskNo());
+//            if (taskWrk.getCommandStep() < commandInfos.size()) {
+//                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) {
+            if (taskWrk.getIoType() == 1 && taskWrk.getWrkSts() == 5) {
                 //鍏ュ簱浠诲姟
 //                taskWrk.setWrkSts(4);//3.鍚婅溅鍏ュ簱涓� => 4.鍏ュ簱瀹屾垚
                 taskWrk.setStatus(TaskStatusType.OVER.id);
@@ -1059,7 +1065,7 @@
                 locMast.setModiTime(now);
                 locMast.setModiUser(9999L);
                 locMastService.updateById(locMast);
-            } else if (taskWrk.getIoType() == 2) {
+            } else if (taskWrk.getIoType() == 2 && taskWrk.getWrkSts() == 15) {
                 //鍑哄簱浠诲姟
 //                taskWrk.setWrkSts(14);//12.鍚婅溅鍑哄簱涓� => 14.鍑哄簱瀹屾垚
                 taskWrk.setStatus(TaskStatusType.OVER.id);
@@ -1073,7 +1079,7 @@
                 locMast.setModiTime(now);
                 locMast.setModiUser(9999L);
                 locMastService.updateById(locMast);
-            } else if (taskWrk.getIoType() == 3) {
+            } else if (taskWrk.getIoType() == 3 && taskWrk.getWrkSts() == 5) {
 
                 //鏇存柊璧峰搴撲綅鐘舵��
                 LocMast locMastStart = locMastService.selectByLocNo(taskWrk.getStartPoint());

--
Gitblit v1.9.1