From 4da282d3a87fb648ae6865929f5862b27d05a562 Mon Sep 17 00:00:00 2001
From: cpT <1@123>
Date: 星期四, 03 七月 2025 15:07:25 +0800
Subject: [PATCH] #改造

---
 src/main/java/com/zy/asrs/controller/CrnController.java |   78 ++++++++++++++++++++++++++++++---------
 1 files changed, 60 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/CrnController.java b/src/main/java/com/zy/asrs/controller/CrnController.java
index cd1ae7f..573b31f 100644
--- a/src/main/java/com/zy/asrs/controller/CrnController.java
+++ b/src/main/java/com/zy/asrs/controller/CrnController.java
@@ -303,6 +303,7 @@
                 }
             }
             vo.setLaneNo(crnProtocol.getLaneNo());  //
+            vo.setErrorCrn(crnProtocol.getErrCrn());  //
             vo.setXspeed(crnProtocol.getXSpeed());  //  璧拌閫熷害锛坢/min)
             vo.setYspeed(crnProtocol.getYSpeed());  //  鍗囬檷閫熷害锛坢/min)
             vo.setZspeed(crnProtocol.getZSpeed());  //  鍙夌墮閫熷害锛坢/min)
@@ -330,6 +331,7 @@
             }
             vo.setInEnable(basCrnp.getInEnable());
             vo.setOutEnable(basCrnp.getOutEnable());
+            vo.setTaskComplete(crnThread.getResetFlag()? "浠诲姟瀹屾垚涓嬪彂绛夊緟":"-");
         }
         return R.ok().add(list);
     }
@@ -452,11 +454,11 @@
         command.setDestinationPosX(param.getBay());     // 鐩爣搴撲綅鍒�
         command.setDestinationPosY(param.getLev());     // 鐩爣搴撲綅灞�
         command.setCommand((short)1);
-        LocMast sourceLoc = locMastService.selectOne(new EntityWrapper<LocMast>().eq("row1", command.getSourcePosX())
-                .eq("bay1", command.getSourcePosY()).eq("lev1", command.getSourcePosZ()));
-        LocMast loc = locMastService.selectOne(new EntityWrapper<LocMast>().eq("row1", command.getDestinationPosX())
-                .eq("bay1", command.getDestinationPosY()).eq("lev1", command.getDestinationPosZ()));
-        VersionUtils.locMoveCheckLocType(sourceLoc, loc);
+//        LocMast sourceLoc = locMastService.selectOne(new EntityWrapper<LocMast>().eq("row1", command.getSourcePosX())
+//                .eq("bay1", command.getSourcePosY()).eq("lev1", command.getSourcePosZ()));
+//        LocMast loc = locMastService.selectOne(new EntityWrapper<LocMast>().eq("row1", command.getDestinationPosX())
+//                .eq("bay1", command.getDestinationPosY()).eq("lev1", command.getDestinationPosZ()));
+//        VersionUtils.locMoveCheckLocType(sourceLoc, loc);
         return crnControl(command)?R.ok():R.error();
     }
 
@@ -548,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 = "鏆傚仠")
@@ -623,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);  // 浠诲姟瀹屾垚纭浣�
@@ -780,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))) {
@@ -814,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