From 433040dfff973bc8e502a00b2f1bee2e929fdf70 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期六, 16 一月 2021 16:01:10 +0800
Subject: [PATCH] #堆垛机异常

---
 src/main/java/com/zy/asrs/controller/CrnController.java |   74 ++++++++++++++++++++++++++++++------
 1 files changed, 61 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 0c202b1..d1f80c2 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;
@@ -35,12 +38,15 @@
 import com.zy.core.properties.SystemProperties;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 /**
  * 鍫嗗灈鏈烘帴鍙�
@@ -61,6 +67,8 @@
     private BasCrnpService basCrnpService;
     @Autowired
     private MainServiceImpl mainService;
+    @Autowired
+    private LocMastService locMastService;
 
 
     @ManagerAuth(memo = "杩涜涓殑鍛戒护")
@@ -127,13 +135,36 @@
             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.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?"鏄�":"鍚�");       //  鎬ュ仠
-            vo.setWarnCode(String.valueOf(crnProtocol.getAlarm1()));  //  寮傚父鐮�
+            if (crnProtocol.getAlarm1() > 0) {
+                BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm1());
+                vo.setAlarm1(crnError==null?"鏈煡寮傚父":crnError.getErrName());
+            }
+            if (crnProtocol.getAlarm2() > 0) {
+                BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm2());
+                vo.setAlarm2(crnError==null?"鏈煡寮傚父":crnError.getErrName());
+            }
+            if (crnProtocol.getAlarm3() > 0) {
+                BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm3());
+                vo.setAlarm3(crnError==null?"鏈煡寮傚父":crnError.getErrName());
+            }
+            if (crnProtocol.getAlarm4() > 0) {
+                BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm4());
+                vo.setAlarm4(crnError==null?"鏈煡寮傚父":crnError.getErrName());
+            }
+//            vo.setAlarm1(String.valueOf(crnProtocol.getAlarm1()));
+//            vo.setAlarm2(String.valueOf(crnProtocol.getAlarm2()));
+//            vo.setAlarm3(String.valueOf(crnProtocol.getAlarm3()));
+//            vo.setAlarm4(String.valueOf(crnProtocol.getAlarm4()));
 
         }
         return R.ok().add(list);
@@ -160,10 +191,6 @@
             }
 
             vo.setWorkNo(crnProtocol.getTaskNo());  //  浠诲姟鍙�
-            BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm1());
-            if (null != crnError) {
-                vo.setError(crnError.getErrName());
-            }
             if (crnProtocol.getTaskNo()>0) {
                 WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo());
                 if (wrkMast != null) {
@@ -200,6 +227,20 @@
         return R.ok().add(str.toString());
     }
 
+
+    @GetMapping("/demo/status")
+    public R demoStatus(){
+        List<Map<String, Object>> res = new ArrayList<>();
+        for (CrnSlave crnSlave : slaveProperties.getCrn()) {
+            Map<String, Object> map = new HashMap<>();
+            map.put("crnNo", crnSlave.getId());
+            map.put("demo", crnSlave.getDemo());
+            res.add(map);
+        }
+        return R.ok().add(res);
+    }
+
+
     @PostMapping("/demo/switch")
     @ManagerAuth(memo = "鍫嗗灈鏈烘紨绀�")
     public R crnDemo(CrnDemoParam param) throws InterruptedException {
@@ -213,9 +254,15 @@
             return R.error("鍙d护閿欒");
         }
         Thread.sleep(200L);
-        mainService.crnDemoOfLocMove(param.getCrnId());
+        for (CrnSlave crnSlave : slaveProperties.getCrn()) {
+            if (crnSlave.getId().equals(param.getCrnId())) {
+                crnSlave.setDemo(param.getOpt());
+            }
+        }
+//        mainService.crnDemoOfLocMove(param.getCrnId());
         return R.ok();
     }
+
 
 
     /****************************************************************/
@@ -236,7 +283,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 +300,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 +317,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 +339,6 @@
         command.setDestinationPosX(param.getStaNo());     // 鐩爣搴撲綅鎺�
         command.setDestinationPosY((short) 0);     // 鐩爣搴撲綅鍒�
         command.setDestinationPosZ((short) 1);     // 鐩爣搴撲綅灞�
-        staNoProcess(param, command);
         return crnControl(command)?R.ok():R.error();
     }
 

--
Gitblit v1.9.1