From 7a7c50a1ecf82fe070cf4dd86b73ba7386b33da6 Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期四, 24 四月 2025 17:28:28 +0800
Subject: [PATCH] *

---
 src/main/java/com/zy/asrs/controller/CrnController.java |  135 +++++++++++++++++++++++++++++++++++++-------
 1 files changed, 113 insertions(+), 22 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/CrnController.java b/src/main/java/com/zy/asrs/controller/CrnController.java
index fe5a746..3046c66 100644
--- a/src/main/java/com/zy/asrs/controller/CrnController.java
+++ b/src/main/java/com/zy/asrs/controller/CrnController.java
@@ -130,9 +130,9 @@
             vo.setForkOffset(crnProtocol.getForkPosType().desc);    // 璐у弶浣嶇疆
             vo.setLiftPos(crnProtocol.getLiftPosType().desc);
             vo.setWalkPos(crnProtocol.getWalkPos()==1?"涓嶅湪瀹氫綅":"鍦ㄥ畾浣�");
-            vo.setWarnCode(String.valueOf(crnProtocol.getAlarm1()));
-            if (crnProtocol.getAlarm1() > 0) {
-                BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm1());
+            vo.setWarnCode(String.valueOf(crnProtocol.getAlarm()));
+            if (crnProtocol.getAlarm() > 0) {
+                BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm());
                 vo.setAlarm(crnError==null?"鏈煡寮傚父":crnError.getErrName());
             }
         }
@@ -165,9 +165,9 @@
         vo.setForkOffset(crnProtocol.getForkPosType().desc);    // 璐у弶浣嶇疆
         vo.setLiftPos(crnProtocol.getLiftPosType().desc);
         vo.setWalkPos(crnProtocol.getWalkPos()==1?"涓嶅湪瀹氫綅":"鍦ㄥ畾浣�");
-        vo.setWarnCode(String.valueOf(crnProtocol.getAlarm1()));
-        if (crnProtocol.getAlarm1() > 0) {
-            BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm1());
+        vo.setWarnCode(String.valueOf(crnProtocol.getAlarm()));
+        if (crnProtocol.getAlarm() > 0) {
+            BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm());
             vo.setAlarm(crnError==null?"鏈煡寮傚父":crnError.getErrName());
         }
         return R.ok().add(vo);
@@ -288,7 +288,11 @@
                     vo.setLocNo(wrkMast.getLocNo());    //  鐩爣搴撲綅
                 }
             } else {
-                vo.setDeviceStatus(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.MACHINE_AUTO.getDesc(): CrnStatusType.MACHINE_UN_AUTO.getDesc());   //  妯″紡鐘舵��
+                if (Cools.isEmpty(crnProtocol.modeType)){
+                    vo.setDeviceStatus(CrnStatusType.MACHINE_UN_AUTO.getDesc());   //  妯″紡鐘舵��
+                } else {
+                    vo.setDeviceStatus(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.MACHINE_AUTO.getDesc(): CrnStatusType.MACHINE_UN_AUTO.getDesc());   //  妯″紡鐘舵��
+                }
             }
             vo.setXspeed(crnProtocol.getXSpeed());  //  璧拌閫熷害锛坢/min)
             vo.setYspeed(crnProtocol.getYSpeed());  //  鍗囬檷閫熷害锛坢/min)
@@ -297,8 +301,11 @@
             vo.setYdistance(crnProtocol.getYDistance());  //  鍗囬檷璺濈(Km)
             vo.setXduration(crnProtocol.getXDuration());    //  璧拌鏃堕暱(H)
             vo.setYduration(crnProtocol.getYDuration());    //  鍗囬檷鏃堕暱(H)
-
-            vo.setStatusType(crnProtocol.modeType.desc);   //  妯″紡鐘舵��
+            if (Cools.isEmpty(crnProtocol.modeType)){
+                vo.setStatusType(CrnStatusType.MACHINE_UN_AUTO.getDesc());   //  妯″紡鐘舵��
+            } else {
+                vo.setStatusType(crnProtocol.modeType.desc);   //  妯″紡鐘舵��
+            }
             vo.setWrkStatus(crnProtocol.getStatusType().id);     //  浠诲姟鐘舵��
             vo.setLoading((crnProtocol.getLoaded() != null && crnProtocol.getLoaded() == 1) ? "鏈夌墿" : "鏃犵墿");  //  鏈夌墿
             vo.setBay(crnProtocol.getBay());    //  鍒�
@@ -307,9 +314,9 @@
             vo.setForkOffset(crnProtocol.getForkPosType().desc);    // 璐у弶浣嶇疆
             vo.setLiftPos(crnProtocol.getLiftPosType().desc);
             vo.setWalkPos(crnProtocol.getWalkPos()==1?"涓嶅湪瀹氫綅":"鍦ㄥ畾浣�");
-            vo.setWarnCode(String.valueOf(crnProtocol.getAlarm1()));
-            if (crnProtocol.getAlarm1() > 0) {
-                BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm1());
+            vo.setWarnCode(String.valueOf(crnProtocol.getAlarm()));
+            if (crnProtocol.getAlarm() > 0) {
+                BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm());
                 vo.setAlarm(crnError==null?"鏈煡寮傚父":crnError.getErrName());
             }
             vo.setInEnable(basCrnp.getInEnable());
@@ -376,6 +383,10 @@
     @ManagerAuth(memo = "鍏ュ簱")
     @PostMapping("/crn/operator/put")
     public R crnPut(CrnOperatorParam param){
+//        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
         command.setTaskNo((short) 0); // 宸ヤ綔鍙�
@@ -387,40 +398,51 @@
         command.setDestinationPosX(param.getRow());     // 鐩爣搴撲綅鎺�
         command.setDestinationPosY(param.getBay());     // 鐩爣搴撲綅鍒�
         command.setDestinationPosZ(param.getLev());     // 鐩爣搴撲綅灞�
+        command.setCommand((short)1);
         return crnControl(command)?R.ok():R.error();
     }
 
     @ManagerAuth(memo = "鍑哄簱")
     @PostMapping("/crn/operator/take")
     public R crnTake(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        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) 0);  // 浠诲姟瀹屾垚纭浣�
-        command.setTaskMode(CrnTaskModeType.PAKOUT); // 浠诲姟妯″紡
+        command.setTaskMode(CrnTaskModeType.PAKIN); // 浠诲姟妯″紡
         command.setSourcePosX(param.getSourceRow());     // 婧愬簱浣嶆帓
         command.setSourcePosY(param.getSourceBay());     // 婧愬簱浣嶅垪
         command.setSourcePosZ(param.getSourceLev());     // 婧愬簱浣嶅眰
         command.setDestinationPosX(param.getRow());     // 鐩爣搴撲綅鎺�
         command.setDestinationPosY(param.getBay());     // 鐩爣搴撲綅鍒�
         command.setDestinationPosZ(param.getLev());     // 鐩爣搴撲綅灞�
+        command.setCommand((short)1);
         return crnControl(command)?R.ok():R.error();
     }
 
     @ManagerAuth(memo = "搴撲綅杞Щ")
     @PostMapping("/crn/operator/stockMove")
     public R crnStockMove(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        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) 0);  // 浠诲姟瀹屾垚纭浣�
         command.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡
-        command.setSourcePosX(param.getSourceRow());     // 婧愬簱浣嶆帓
-        command.setSourcePosY(param.getSourceBay());     // 婧愬簱浣嶅垪
-        command.setSourcePosZ(param.getSourceLev());     // 婧愬簱浣嶅眰
-        command.setDestinationPosX(param.getRow());     // 鐩爣搴撲綅鎺�
-        command.setDestinationPosY(param.getBay());     // 鐩爣搴撲綅鍒�
-        command.setDestinationPosZ(param.getLev());     // 鐩爣搴撲綅灞�
+        command.setSourcePosZ(param.getSourceRow());     // 婧愬簱浣嶆帓
+        command.setSourcePosX(param.getSourceBay());     // 婧愬簱浣嶅垪
+        command.setSourcePosY(param.getSourceLev());     // 婧愬簱浣嶅眰
+        command.setDestinationPosZ(param.getRow());     // 鐩爣搴撲綅鎺�
+        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())
@@ -432,6 +454,10 @@
     @ManagerAuth(memo = "绔欏埌绔�")
     @PostMapping("/crn/operator/siteMove")
     public R crnSiteMove(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
         command.setTaskNo((short) 0); // 宸ヤ綔鍙�
@@ -449,6 +475,10 @@
     @ManagerAuth(memo = "鍥炲師鐐�")
     @PostMapping("/crn/operator/bacOrigin")
     public R crnBacOrigin(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
         command.setTaskNo((short) 0); // 宸ヤ綔鍙�
@@ -466,6 +496,10 @@
     @ManagerAuth(memo = "鍙嶅師鐐�")
     @PostMapping("/crn/operator/reverseOrigin")
     public R reverseOrigin(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
         command.setTaskNo((short) 0); // 宸ヤ綔鍙�
@@ -475,8 +509,8 @@
         command.setSourcePosY((short) 0);     // 婧愬簱浣嶅垪
         command.setSourcePosZ((short) 0);     // 婧愬簱浣嶅眰
         command.setDestinationPosX((short) 0);     // 鐩爣搴撲綅鎺�
-        command.setDestinationPosY((short) 34);     // 鐩爣搴撲綅鍒�
-        command.setDestinationPosZ((short) 5);     // 鐩爣搴撲綅灞�
+        command.setDestinationPosY((short) 22);     // 鐩爣搴撲綅鍒�
+        command.setDestinationPosZ((short) 1);     // 鐩爣搴撲綅灞�
         return crnControl(command)?R.ok():R.error();
     }
 
@@ -501,6 +535,10 @@
     @ManagerAuth(memo = "浠诲姟瀹屾垚")
     @PostMapping("/crn/operator/taskComplete")
     public R crnTaskComplete(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
         command.setTaskNo((short) 0); // 宸ヤ綔鍙�
@@ -512,6 +550,7 @@
         command.setDestinationPosX((short) 0);     // 鐩爣搴撲綅鎺�
         command.setDestinationPosY((short) 0);     // 鐩爣搴撲綅鍒�
         command.setDestinationPosZ((short) 0);     // 鐩爣搴撲綅灞�
+        command.setCommand((short)0);
         return crnControl(command)?R.ok():R.error();
     }
 
@@ -530,6 +569,10 @@
     @ManagerAuth(memo = "娓呴櫎鍛戒护")
     @PostMapping("/crn/operator/clearCommand")
     public R crnClearCommand(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         if (param.getCrnNo() == null) {
             throw new CoolException("璇烽�夋嫨鍫嗗灈鏈�");
         }
@@ -550,6 +593,10 @@
     @ManagerAuth(memo = "鎵嬪姩澶嶄綅")
     @PostMapping("/crn/operator/handleReset")
     public R handleReset(CrnOperatorParam param) throws Exception {
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         if (param.getCrnNo() == null) {
             throw new CoolException("璇烽�夋嫨鍫嗗灈鏈�");
         }
@@ -572,7 +619,7 @@
                 crnCommand.setCommand((short) 0);  // 浠诲姟瀹屾垚纭浣�
                 // 寤舵椂鍙戦��
                 Thread.sleep(1000L);
-                if (CommandUtils.offer(SlaveType.Crn, crn.getId(), new Task(2, crnCommand), false)) {
+                if (CommandUtils.offer(SlaveType.Crn, crn.getId(), new Task(5, crnCommand), false)) {
                     return R.ok();
                 } else {
                     throw new CoolException("鍛戒护涓嬪彂澶辫触");
@@ -588,6 +635,10 @@
     @ManagerAuth(memo = "鍒囨崲鑱旀満妯″紡")
     @PostMapping("/crn/operator/auto")
     public R crnAuto(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         short[] array = new short[9];
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
@@ -599,6 +650,10 @@
     @ManagerAuth(memo = "鍒囨崲鍗婃墜鍔ㄦā寮�")
     @PostMapping("/crn/operator/semiAutomatic")
     public R crnsemiAutomatic(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         short[] array = new short[9];
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
@@ -610,6 +665,10 @@
     @ManagerAuth(memo = "鍒囨崲鎵嬪姩妯″紡")
     @PostMapping("/crn/operator/hand")
     public R onlineWrk1(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         short[] array = new short[9];
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
@@ -621,6 +680,10 @@
     @ManagerAuth(memo = "鐢宠瀹屾垚浠诲姟")
     @PostMapping("/crn/operator/onlineWrk1")
     public R onlineWrk2(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         short[] array = new short[9];
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
@@ -632,6 +695,10 @@
     @ManagerAuth(memo = "鐢宠鍙栨秷浠诲姟")
     @PostMapping("/crn/operator/onlineWrk2")
     public R onlineWrk3(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         short[] array = new short[9];
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
@@ -643,6 +710,10 @@
     @ManagerAuth(memo = "娓呴櫎鑱旀満浠诲姟")
     @PostMapping("/crn/operator/onlineWrk3")
     public R onlineWrk4(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         short[] array = new short[9];
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
@@ -654,6 +725,10 @@
     @ManagerAuth(memo = "鎭㈠鑱旀満浠诲姟")
     @PostMapping("/crn/operator/onlineWrk4")
     public R crnHand(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
         short[] array = new short[9];
         CrnCommand command = new CrnCommand();
         command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
@@ -663,6 +738,22 @@
         return crnControl2(command)?R.ok():R.error();
     }
 
+    @ManagerAuth(memo = "澶嶄綅")
+    @PostMapping("/crn/operator/reset")
+    public R crnReset(CrnOperatorParam param){
+        // 绯荤粺杩愯鐘舵�佸垽鏂�
+//        if (SystemProperties.WCS_RUNNING_STATUS.get()) {
+//            return R.error("wcs绯荤粺鐘舵�佷负寮�鍚�");
+//        }
+        short[] array = new short[9];
+        CrnCommand command = new CrnCommand();
+        command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
+        command.setTaskNo((short) 0); // 宸ヤ綔鍙�
+        command.setReset((short)1);
+
+        return crnControl2(command)?R.ok():R.error();
+    }
+
 
 
     private boolean crnControl2(CrnCommand command){

--
Gitblit v1.9.1