From 52a57d1a6cd61009304656db35e50d4b9dbbda03 Mon Sep 17 00:00:00 2001
From: cpT <1@123>
Date: 星期二, 01 七月 2025 11:16:40 +0800
Subject: [PATCH] #改造

---
 src/main/java/com/zy/asrs/controller/CrnController.java |   67 +++++++++++++++++++++++++++------
 1 files changed, 54 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/CrnController.java b/src/main/java/com/zy/asrs/controller/CrnController.java
index 4a7dc85..688fed8 100644
--- a/src/main/java/com/zy/asrs/controller/CrnController.java
+++ b/src/main/java/com/zy/asrs/controller/CrnController.java
@@ -331,6 +331,7 @@
             }
             vo.setInEnable(basCrnp.getInEnable());
             vo.setOutEnable(basCrnp.getOutEnable());
+            vo.setTaskComplete(crnThread.getResetFlag()? "浠诲姟瀹屾垚涓嬪彂绛夊緟":"-");
         }
         return R.ok().add(list);
     }
@@ -549,19 +550,54 @@
 //        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
 //            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
 //        }
-        CrnCommand command = new CrnCommand();
-        command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
-        command.setTaskNo((short) 0); // 宸ヤ綔鍙�
-        command.setAckFinish((short) 1);  // 浠诲姟瀹屾垚纭浣�
-        command.setTaskMode(CrnTaskModeType.NONE); // 浠诲姟妯″紡
-        command.setSourcePosX((short) 0);     // 婧愬簱浣嶆帓
-        command.setSourcePosY((short) 0);     // 婧愬簱浣嶅垪
-        command.setSourcePosZ((short) 0);     // 婧愬簱浣嶅眰
-        command.setDestinationPosX((short) 0);     // 鐩爣搴撲綅鎺�
-        command.setDestinationPosY((short) 0);     // 鐩爣搴撲綅鍒�
-        command.setDestinationPosZ((short) 0);     // 鐩爣搴撲綅灞�
-        command.setCommand((short)0);
-        return crnControl(command)?R.ok():R.error();
+        if (Cools.isEmpty(param.getCrnNo()) || param.getCrnNo() == 0) {
+            return R.error("璇烽�夋嫨鍫嗗灈鏈�");
+        }
+        CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, param.getCrnNo());
+        crnThread.setResetFlag(true);
+        return R.ok();
+//        CrnCommand command = new CrnCommand();
+//        command.setCrnNo(); // 鍫嗗灈鏈虹紪鍙�
+//        command.setTaskNo((short) 0); // 宸ヤ綔鍙�
+//        command.setAckFinish((short) 1);  // 浠诲姟瀹屾垚纭浣�
+//        command.setTaskMode(CrnTaskModeType.NONE); // 浠诲姟妯″紡
+//        command.setSourcePosX((short) 0);     // 婧愬簱浣嶆帓
+//        command.setSourcePosY((short) 0);     // 婧愬簱浣嶅垪
+//        command.setSourcePosZ((short) 0);     // 婧愬簱浣嶅眰
+//        command.setDestinationPosX((short) 0);     // 鐩爣搴撲綅鎺�
+//        command.setDestinationPosY((short) 0);     // 鐩爣搴撲綅鍒�
+//        command.setDestinationPosZ((short) 0);     // 鐩爣搴撲綅灞�
+//        command.setCommand((short)0);
+//        return crnControl(command)?R.ok():R.error();
+    }
+
+    @ManagerAuth(memo = "浠诲姟瀹屾垚鎸囦护娓呴櫎")
+    @PostMapping("/crn/operator/taskCompleteClearCommand")
+    public R crnTaskCompleteClearCommand(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+        if (Cools.isEmpty(param.getCrnNo()) || param.getCrnNo() == 0) {
+            return R.error("璇烽�夋嫨鍫嗗灈鏈�");
+        }
+        CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, param.getCrnNo());
+        crnThread.setResetFlag(false);
+        return R.ok();
+//        CrnCommand command = new CrnCommand();
+//        command.setCrnNo(); // 鍫嗗灈鏈虹紪鍙�
+//        command.setTaskNo((short) 0); // 宸ヤ綔鍙�
+//        command.setAckFinish((short) 1);  // 浠诲姟瀹屾垚纭浣�
+//        command.setTaskMode(CrnTaskModeType.NONE); // 浠诲姟妯″紡
+//        command.setSourcePosX((short) 0);     // 婧愬簱浣嶆帓
+//        command.setSourcePosY((short) 0);     // 婧愬簱浣嶅垪
+//        command.setSourcePosZ((short) 0);     // 婧愬簱浣嶅眰
+//        command.setDestinationPosX((short) 0);     // 鐩爣搴撲綅鎺�
+//        command.setDestinationPosY((short) 0);     // 鐩爣搴撲綅鍒�
+//        command.setDestinationPosZ((short) 0);     // 鐩爣搴撲綅灞�
+//        command.setCommand((short)0);
+//        return crnControl(command)?R.ok():R.error();
     }
 
 //    @ManagerAuth(memo = "鏆傚仠")
@@ -624,6 +660,7 @@
                 }
                 CrnCommand crnCommand = new CrnCommand();
                 crnCommand.setCrnNo(crn.getId()); // 鍫嗗灈鏈虹紪鍙�
+                crnCommand.setLaneNo(crnProtocol.getLaneNo()); // 鍫嗗灈鏈哄贩閬撳彿
                 crnCommand.setTaskMode(CrnTaskModeType.CLEAR);
                 crnCommand.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
                 crnCommand.setCommand((short) 0);  // 浠诲姟瀹屾垚纭浣�
@@ -781,6 +818,8 @@
                 if (crnProtocol == null) {
                     throw new CoolException("鍫嗗灈鏈轰笉鍦ㄧ嚎");
                 }
+                command.setLaneNo(crnProtocol.getLaneNo()); // 鍫嗗灈鏈哄贩閬撳彿
+
                 // 绌洪棽鍒ゆ柇
 //                if (crnProtocol.getStatusType().equals(com.zy.core.enums.CrnStatusType.IDLE) && crnProtocol.getTaskNo() == 0) {
                 if (MessageQueue.offer(SlaveType.Crn, crn.getId(), new Task(4, command))) {
@@ -815,6 +854,8 @@
                 if (crnProtocol == null) {
                     throw new CoolException("鍫嗗灈鏈轰笉鍦ㄧ嚎");
                 }
+                command.setLaneNo(crnProtocol.getLaneNo()); // 鍫嗗灈鏈哄贩閬撳彿
+
                 // 绌洪棽鍒ゆ柇
 //                if (crnProtocol.getStatusType().equals(com.zy.core.enums.CrnStatusType.IDLE) && crnProtocol.getTaskNo() == 0) {
                 if (MessageQueue.offer(SlaveType.Crn, crn.getId(), new Task(2, command))) {

--
Gitblit v1.9.1