From f939d20b9e587fa438a8b06848ab85e903ddbd46 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期二, 12 一月 2021 20:25:47 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/CrnController.java |  103 +++++++++++++++++++++++++++++----------------------
 1 files changed, 58 insertions(+), 45 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/CrnController.java b/src/main/java/com/zy/asrs/controller/CrnController.java
index af1991a..4b5edf5 100644
--- a/src/main/java/com/zy/asrs/controller/CrnController.java
+++ b/src/main/java/com/zy/asrs/controller/CrnController.java
@@ -14,11 +14,14 @@
 import com.zy.asrs.domain.vo.CrnStateTableVo;
 import com.zy.asrs.entity.BasCrnError;
 import com.zy.asrs.entity.BasCrnp;
+import com.zy.asrs.entity.LocMast;
 import com.zy.asrs.entity.WrkMast;
 import com.zy.asrs.mapper.BasCrnErrorMapper;
 import com.zy.asrs.service.BasCrnpService;
+import com.zy.asrs.service.LocMastService;
 import com.zy.asrs.service.WrkMastService;
 import com.zy.asrs.service.impl.MainServiceImpl;
+import com.zy.asrs.utils.VersionUtils;
 import com.zy.core.CrnThread;
 import com.zy.core.cache.MessageQueue;
 import com.zy.core.cache.OutputQueue;
@@ -61,6 +64,8 @@
     private BasCrnpService basCrnpService;
     @Autowired
     private MainServiceImpl mainService;
+    @Autowired
+    private LocMastService locMastService;
 
 
     @ManagerAuth(memo = "杩涜涓殑鍛戒护")
@@ -119,21 +124,32 @@
 //
 //            }
             vo.setStatusType(crnProtocol.modeType.desc);   //  妯″紡鐘舵��
-            vo.setStatus(crnProtocol.getStatusType().desc);     //  鐘舵��
+            if (crnProtocol.getTaskFinish() == 1) {
+                vo.setStatus("绛夊緟纭");
+            } else {
+                vo.setStatus(crnProtocol.getStatusType().desc);     //  鐘舵��
+            }
             vo.setLoading(crnProtocol.getLoaded()==1?"鏈夌墿":"鏃犵墿");  //  鏈夌墿
             vo.setBay(crnProtocol.getBay());    //  鍒�
             vo.setLev(crnProtocol.getLevel());  //  灞�
-            vo.setXOrigin(crnProtocol.getBay()==1?"鏄�":"鍚�");     //  璧拌鍘熺偣
-            vo.setYOrigin(crnProtocol.getLevel()==1?"鏄�":"鍚�");     // 鍗囬檷鍘熺偣
+            vo.setLiftPos(crnProtocol.getLiftPosType().desc);
+            if (crnProtocol.getPlatformHigh()) {
+                vo.setSitePos("绔欏彴楂樹綅");
+            }
+            if (crnProtocol.getPlatformLow()) {
+                vo.setSitePos("绔欏彴楂樹綅");
+            }
+//            vo.setXOrigin(crnProtocol.getBay()==1?"鏄�":"鍚�");     //  璧拌鍘熺偣
+//            vo.setYOrigin(crnProtocol.getLevel()==1?"鏄�":"鍚�");     // 鍗囬檷鍘熺偣
             vo.setForkOffset(crnProtocol.getForkPosType().desc);    // 璐у弶浣嶇疆
             vo.setXLocation(crnProtocol.getWalkPos() == 1?"鏄�":"鍚�");      // 璧拌瀹氫綅
             vo.setYLocation(crnProtocol.getLiftPosType().equals(CrnLiftPosType.NONE)?"鍚�":"鏄�");      // 鍗囬檷瀹氫綅
 //            vo.setStop(crnProtocol.getCrnError1().controlStop||crnProtocol.getCrnError1().mainStop||crnProtocol.getCrnError1().remoteStop?"鏄�":"鍚�");       //  鎬ュ仠
-            if (vo.getCrnNo() == 2) {
-                vo.setWarnCode(String.valueOf(crnProtocol.getAlarm1()-1000));  //  寮傚父鐮�
-            } else {
-                vo.setWarnCode(String.valueOf(crnProtocol.getAlarm1()));  //  寮傚父鐮�
-            }
+            vo.setAlarm1(String.valueOf(crnProtocol.getAlarm1()));
+            vo.setAlarm2(String.valueOf(crnProtocol.getAlarm2()));
+            vo.setAlarm3(String.valueOf(crnProtocol.getAlarm3()));
+            vo.setAlarm4(String.valueOf(crnProtocol.getAlarm4()));
+//            vo.setWarnCode(String.valueOf(crnProtocol.getAlarm1()));  //  寮傚父鐮�
 
         }
         return R.ok().add(list);
@@ -236,7 +252,6 @@
         command.setDestinationPosX(param.getRow());     // 鐩爣搴撲綅鎺�
         command.setDestinationPosY(param.getBay());     // 鐩爣搴撲綅鍒�
         command.setDestinationPosZ(param.getLev());     // 鐩爣搴撲綅灞�
-        staNoProcess(param, command);
         return crnControl(command)?R.ok():R.error();
     }
 
@@ -254,7 +269,6 @@
         command.setDestinationPosX(param.getRow());     // 鐩爣搴撲綅鎺�
         command.setDestinationPosY(param.getBay());     // 鐩爣搴撲綅鍒�
         command.setDestinationPosZ(param.getLev());     // 鐩爣搴撲綅灞�
-        staNoProcess(param, command);
         return crnControl(command)?R.ok():R.error();
     }
 
@@ -272,7 +286,11 @@
         command.setDestinationPosX(param.getRow());     // 鐩爣搴撲綅鎺�
         command.setDestinationPosY(param.getBay());     // 鐩爣搴撲綅鍒�
         command.setDestinationPosZ(param.getLev());     // 鐩爣搴撲綅灞�
-        staNoProcess(param, command);
+        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();
     }
 
@@ -290,7 +308,6 @@
         command.setDestinationPosX(param.getStaNo());     // 鐩爣搴撲綅鎺�
         command.setDestinationPosY((short) 0);     // 鐩爣搴撲綅鍒�
         command.setDestinationPosZ((short) 1);     // 鐩爣搴撲綅灞�
-        staNoProcess(param, command);
         return crnControl(command)?R.ok():R.error();
     }
 
@@ -328,23 +345,23 @@
         return crnControl(command)?R.ok():R.error();
     }
 
-    @ManagerAuth(memo = "鍧愭爣绉诲姩")
-    @PostMapping("/operator/coorMove")
-    public R crnCoorMove(CrnOperatorParam param){
-        CrnCommand command = new CrnCommand();
-        command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
-        command.setTaskNo((short) 0); // 宸ヤ綔鍙�
-        command.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
-        command.setTaskMode(CrnTaskModeType.OFFSET_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());     // 鐩爣搴撲綅灞�
-        staNoProcess(param, command);
-        return crnControl(command)?R.ok():R.error();
-    }
+//    @ManagerAuth(memo = "鍧愭爣绉诲姩")
+//    @PostMapping("/operator/coorMove")
+//    public R crnCoorMove(CrnOperatorParam param){
+//        CrnCommand command = new CrnCommand();
+//        command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
+//        command.setTaskNo((short) 0); // 宸ヤ綔鍙�
+//        command.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
+//        command.setTaskMode(CrnTaskModeType.OFFSET_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());     // 鐩爣搴撲綅灞�
+//        staNoProcess(param, command);
+//        return crnControl(command)?R.ok():R.error();
+//    }
 
     @ManagerAuth(memo = "浠诲姟瀹屾垚")
     @PostMapping("/operator/taskComplete")
@@ -403,23 +420,19 @@
                 if (crnProtocol == null) {
                     throw new CoolException("鍫嗗灈鏈轰笉鍦ㄧ嚎");
                 }
-                // 鍙湁鍑虹幇鎸囧畾寮傚父鎵嶈繘琛屽浣�
-                if (crnProtocol.getCrnError3().leftTakeNoneErr
-                        || crnProtocol.getCrnError3().rightTakeNoneErr
-                        || crnProtocol.getCrnError3().leftTakeThenLoadErr
-                        || crnProtocol.getCrnError3().rightTakeThenLoadErr) {
-                    CrnCommand command = new CrnCommand();
-                    command.setCrnNo(param.getCrnNo()); // 鍫嗗灈鏈虹紪鍙�
-                    command.setAckFinish((short) 1);  // 浠诲姟瀹屾垚纭浣�
-                    command.setTaskMode(CrnTaskModeType.NONE); // 浠诲姟妯″紡
-                    // 寤舵椂鍙戦��
-                    Thread.sleep(3000L);
-                    if (MessageQueue.offer(SlaveType.Crn, crn.getId(), new Task(2, command))) {
-                        return R.ok();
-                    } else {
-                        throw new CoolException("鍛戒护涓嬪彂澶辫触");
-                    }
+                CrnCommand crnCommand = new CrnCommand();
+                crnCommand.setCrnNo(crn.getId()); // 鍫嗗灈鏈虹紪鍙�
+                crnCommand.setTaskMode(CrnTaskModeType.CLEAR);
+                crnCommand.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
+                // 寤舵椂鍙戦��
+                Thread.sleep(1000L);
+                if (MessageQueue.offer(SlaveType.Crn, crn.getId(), new Task(2, crnCommand))) {
+                    return R.ok();
+                } else {
+                    throw new CoolException("鍛戒护涓嬪彂澶辫触");
                 }
+
+
             }
         }
 

--
Gitblit v1.9.1