From 1e18d2f1734062a38176e22113f2b65ad8aa2024 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期四, 19 十月 2023 10:11:37 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/asrs/controller/CrnController.java b/src/main/java/com/zy/asrs/controller/CrnController.java
index 1dbe9c2..b8e24d5 100644
--- a/src/main/java/com/zy/asrs/controller/CrnController.java
+++ b/src/main/java/com/zy/asrs/controller/CrnController.java
@@ -11,6 +11,7 @@
 import com.zy.asrs.domain.param.CrnDemoParam;
 import com.zy.asrs.domain.param.CrnOperatorParam;
 import com.zy.asrs.domain.vo.CommandLogVo;
+import com.zy.asrs.domain.vo.CrnListVo;
 import com.zy.asrs.domain.vo.CrnMsgTableVo;
 import com.zy.asrs.domain.vo.CrnStateTableVo;
 import com.zy.asrs.entity.*;
@@ -207,6 +208,107 @@
         return R.ok().add(list);
     }
 
+    @PostMapping("/crn/table/crn/{id}/msg")
+    @ManagerAuth(memo = "鍫嗗灈鏈烘暟鎹〃")
+    public R crnMsgTable(@PathVariable("id") Integer id){
+        BasCrnp basCrnp = basCrnpService.selectOne(new EntityWrapper<BasCrnp>().eq("crn_no", id).orderBy("crn_no"));
+        // 琛ㄦ牸琛�
+        CrnMsgTableVo vo = new CrnMsgTableVo();
+        vo.setCrnNo(basCrnp.getCrnNo());   //  鍫嗗灈鏈哄彿
+        // 鑾峰彇鍫嗗灈鏈轰俊鎭�
+        CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, basCrnp.getCrnNo());
+        if (crnThread == null) {
+            return R.error();
+        }
+        CrnProtocol crnProtocol = crnThread.getCrnProtocol();
+        if (crnProtocol == null) {
+            return R.error();
+        }
+
+        vo.setWorkNo(crnProtocol.getTaskNo());  //  浠诲姟鍙�
+        if (crnProtocol.getTaskNo()>0) {
+            WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo());
+            if (wrkMast != null) {
+                vo.setStatus(CrnStatusType.process(wrkMast.getIoType()).getDesc());   //  妯″紡鐘舵��
+                vo.setSourceStaNo(wrkMast.getSourceStaNo$());    //  婧愮珯
+                vo.setStaNo(wrkMast.getStaNo$());   //  鐩爣绔�
+                vo.setSourceLocNo(wrkMast.getSourceLocNo());    //  婧愬簱浣�
+                vo.setLocNo(wrkMast.getLocNo());    //  鐩爣搴撲綅
+            }
+        } else {
+            vo.setStatus(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.MACHINE_AUTO.getDesc(): CrnStatusType.MACHINE_UN_AUTO.getDesc());   //  妯″紡鐘舵��
+        }
+        vo.setXspeed(crnProtocol.getXSpeed());  //  璧拌閫熷害锛坢/min)
+        vo.setYspeed(crnProtocol.getYSpeed());  //  鍗囬檷閫熷害锛坢/min)
+        vo.setZspeed(crnProtocol.getZSpeed());  //  鍙夌墮閫熷害锛坢/min)
+        vo.setXdistance(crnProtocol.getXDistance());  //  璧拌璺濈(Km)
+        vo.setYdistance(crnProtocol.getYDistance());  //  鍗囬檷璺濈(Km)
+        vo.setXduration(crnProtocol.getXDuration());    //  璧拌鏃堕暱(H)
+        vo.setYduration(crnProtocol.getYDuration());    //  鍗囬檷鏃堕暱(H)
+        return R.ok().add(vo);
+    }
+
+    @GetMapping("/crn/list/auth")
+    @ManagerAuth(memo = "鍫嗗灈鏈烘暟鎹〃")
+    public R crnList(){
+        List<CrnListVo> list = new ArrayList<>();
+        List<BasCrnp> crnps = basCrnpService.selectList(new EntityWrapper<BasCrnp>().orderBy("crn_no"));
+        for (BasCrnp basCrnp : crnps) {
+            // 琛ㄦ牸琛�
+            CrnListVo vo = new CrnListVo();
+            vo.setCrnNo(basCrnp.getCrnNo());   //  鍫嗗灈鏈哄彿
+            list.add(vo);
+            // 鑾峰彇鍫嗗灈鏈轰俊鎭�
+            CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, basCrnp.getCrnNo());
+            if (crnThread == null) {
+                continue;
+            }
+            CrnProtocol crnProtocol = crnThread.getCrnProtocol();
+            if (crnProtocol == null) {
+                continue;
+            }
+
+            vo.setWorkNo(crnProtocol.getTaskNo());  //  浠诲姟鍙�
+            if (crnProtocol.getTaskNo()>0) {
+                WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo());
+                if (wrkMast != null) {
+                    vo.setDeviceStatus(CrnStatusType.process(wrkMast.getIoType()).getDesc());   //  妯″紡鐘舵��
+                    vo.setSourceStaNo(wrkMast.getSourceStaNo$());    //  婧愮珯
+                    vo.setStaNo(wrkMast.getStaNo$());   //  鐩爣绔�
+                    vo.setSourceLocNo(wrkMast.getSourceLocNo());    //  婧愬簱浣�
+                    vo.setLocNo(wrkMast.getLocNo());    //  鐩爣搴撲綅
+                }
+            } 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)
+            vo.setZspeed(crnProtocol.getZSpeed());  //  鍙夌墮閫熷害锛坢/min)
+            vo.setXdistance(crnProtocol.getXDistance());  //  璧拌璺濈(Km)
+            vo.setYdistance(crnProtocol.getYDistance());  //  鍗囬檷璺濈(Km)
+            vo.setXduration(crnProtocol.getXDuration());    //  璧拌鏃堕暱(H)
+            vo.setYduration(crnProtocol.getYDuration());    //  鍗囬檷鏃堕暱(H)
+
+            vo.setStatusType(crnProtocol.modeType.desc);   //  妯″紡鐘舵��
+            vo.setWrkStatus(crnProtocol.getStatusType().id);     //  浠诲姟鐘舵��
+            vo.setLoading((crnProtocol.getLoaded() != null && crnProtocol.getLoaded() == 1) ? "鏈夌墿" : "鏃犵墿");  //  鏈夌墿
+            vo.setBay(crnProtocol.getBay());    //  鍒�
+            vo.setLev(crnProtocol.getLevel());  //  灞�
+
+            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.setAlarm(crnError==null?"鏈煡寮傚父":crnError.getErrName());
+            }
+            vo.setInEnable(basCrnp.getInEnable());
+            vo.setOutEnable(basCrnp.getOutEnable());
+        }
+        return R.ok().add(list);
+    }
+
     @PostMapping("/crn/output/site")
     @ManagerAuth(memo = "鍫嗗灈鏈烘姤鏂囨棩蹇楄緭鍑�")
     public R crnOutput(){

--
Gitblit v1.9.1