From 8076a2a7abb05b4f49544bd95a6083bae0048023 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期三, 13 一月 2021 15:19:38 +0800
Subject: [PATCH] #test

---
 src/main/java/com/zy/asrs/controller/CrnController.java |   62 ++++++++++++++++++++++++++----
 1 files changed, 53 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/CrnController.java b/src/main/java/com/zy/asrs/controller/CrnController.java
index 03eb364..50e1a5c 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 = "杩涜涓殑鍛戒护")
@@ -119,17 +127,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?"鏄�":"鍚�");       //  鎬ュ仠
-            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);
@@ -196,6 +219,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 {
@@ -209,9 +246,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();
     }
+
 
 
     /****************************************************************/
@@ -232,7 +275,6 @@
         command.setDestinationPosX(param.getRow());     // 鐩爣搴撲綅鎺�
         command.setDestinationPosY(param.getBay());     // 鐩爣搴撲綅鍒�
         command.setDestinationPosZ(param.getLev());     // 鐩爣搴撲綅灞�
-        staNoProcess(param, command);
         return crnControl(command)?R.ok():R.error();
     }
 
@@ -250,7 +292,6 @@
         command.setDestinationPosX(param.getRow());     // 鐩爣搴撲綅鎺�
         command.setDestinationPosY(param.getBay());     // 鐩爣搴撲綅鍒�
         command.setDestinationPosZ(param.getLev());     // 鐩爣搴撲綅灞�
-        staNoProcess(param, command);
         return crnControl(command)?R.ok():R.error();
     }
 
@@ -268,7 +309,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();
     }
 
@@ -286,7 +331,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