From 4c72c2172ac6573e0ce9fcc3a6402e1518723833 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期六, 15 八月 2020 16:13:57 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/asrs/controller/CrnController.java b/src/main/java/com/zy/asrs/controller/CrnController.java
index da1edef..bacf4b6 100644
--- a/src/main/java/com/zy/asrs/controller/CrnController.java
+++ b/src/main/java/com/zy/asrs/controller/CrnController.java
@@ -79,10 +79,10 @@
             if (crnProtocol.getTaskNo()>0) {
                 WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo());
                 if (wrkMast != null) {
-                    vo.setStatusType(CrnStatusType.process(wrkMast.getIoType()));   //  妯″紡鐘舵��
+                    vo.setStatusType(CrnStatusType.process(wrkMast.getIoType()).getDesc());   //  妯″紡鐘舵��
                 }
             } else {
-                vo.setStatusType(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.AUTO: CrnStatusType.UN_AUTO);   //  妯″紡鐘舵��
+                vo.setStatusType(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.AUTO.getDesc(): CrnStatusType.UN_AUTO.getDesc());   //  妯″紡鐘舵��
             }
             vo.setStatus(crnProtocol.getStatusType().desc);     //  鐘舵��
             vo.setWarn(""); //  鎶ヨ todo
@@ -100,25 +100,37 @@
     @ManagerAuth(memo = "鍫嗗灈鏈烘暟鎹〃")
     public R crnMsgTable(){
         List<CrnMsgTableVo> list = new ArrayList<>();
-        for (int i=1;i<=4;i++){
+        for (CrnSlave crn : slaveProperties.getCrn()) {
+            // 鑾峰彇鍫嗗灈鏈轰俊鎭�
+            CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId());
+            if (crnThread == null) {
+                log.error("{}鍙峰爢鍨涙満杩炴帴澶辫触", crn.getId());
+                continue;
+            }
+            CrnProtocol crnProtocol = crnThread.getCrnProtocol();
+            if (crnProtocol == null) {
+                log.error("{}鍙峰爢鍨涙満杩炴帴澶辫触", crn.getId());
+                continue;
+            }
+            // 琛ㄦ牸琛�
             CrnMsgTableVo vo = new CrnMsgTableVo();
-            vo.setCrnNo(String.valueOf(i));
-            vo.setCommand("28283E23132D23");
-            vo.setError("");
-            vo.setLocNo("0601812");
-            vo.setOrigin("0");
-            vo.setSourceLocNo("");
-            vo.setSourceStaNo("0");
-            vo.setStaNo("2112");
-            vo.setStatus("绌洪棽");
-            if (integer.get()%5 == 0) {
-                vo.setWorkNo("0000");
+            vo.setCrnNo(crn.getId());   //  鍫嗗灈鏈哄彿
+            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.setWorkNo("9998");
+                vo.setStatus(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.AUTO.getDesc(): CrnStatusType.UN_AUTO.getDesc());   //  妯″紡鐘舵��
             }
             list.add(vo);
+
         }
-        integer.getAndIncrement();
         return R.ok().add(list);
     }
 

--
Gitblit v1.9.1