From b17e2a3f2bd85d18630cb447d65368e430c887f8 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <xltys1995>
Date: 星期四, 24 九月 2020 10:08:01 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/ConsoleController.java |   28 ++++++++++++++++++----------
 1 files changed, 18 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/ConsoleController.java b/src/main/java/com/zy/asrs/controller/ConsoleController.java
index ef9a2c0..e637dc3 100644
--- a/src/main/java/com/zy/asrs/controller/ConsoleController.java
+++ b/src/main/java/com/zy/asrs/controller/ConsoleController.java
@@ -73,7 +73,7 @@
                 return R.error("鍙d护閿欒");
             }
         }
-        Thread.sleep(2000L);
+        Thread.sleep(200L);
         SystemProperties.WCS_RUNNING_STATUS.set(param.getOperatorType()==1?Boolean.TRUE:Boolean.FALSE);
         return R.ok().add(Cools.add("status", SystemProperties.WCS_RUNNING_STATUS.get()));
     }
@@ -99,6 +99,7 @@
             vo.setSiteId(String.valueOf(entry.getKey())); // 绔欑偣缂栧彿
             vo.setWorkNo(staProtocol.getWorkNo()); // 宸ヤ綔鍙�
             vo.setSiteStatus(SiteStatusType.process(staProtocol));  // 鐘舵��
+            vo.setNearbySta(String.valueOf(staProtocol.getPosition())); // 鍙拌溅浣嶇疆
             vos.add(vo);
         }
         return R.ok().add(vos);
@@ -112,12 +113,10 @@
             // 鑾峰彇鍫嗗灈鏈轰俊鎭�
             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;
             }
             CrnLatestDataVo vo = new CrnLatestDataVo();
@@ -126,17 +125,23 @@
 //            Short totalBay = locMastMapper.selectTotalBay();
 
             vo.setOffset((double) new Random().nextInt(560));     //  鍫嗗灈鏈哄亸绉婚噺
-            vo.setBay(crnProtocol.getBay());    //  褰撳墠鍒�
+            vo.setBay((short) (crnProtocol.getBay() - crn.getOffset()));    //  褰撳墠鍒�
             /**
              * 鍫嗗灈鏈虹姸鎬佸垽鏂�
              */
-            if (crnProtocol.getTaskNo()>0) {
-                WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo());
-                if (wrkMast != null) {
-                    vo.setCrnStatus(CrnStatusType.process(wrkMast.getIoType()));
-                }
+            if (crnProtocol.getAlarm1() > 0) {
+                vo.setCrnStatus(CrnStatusType.MACHINE_ERROR);
             } else {
-                vo.setCrnStatus(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.MACHINE_AUTO: CrnStatusType.MACHINE_UN_AUTO);
+                if (crnProtocol.getTaskNo()>0) {
+                    WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo());
+                    if (wrkMast != null) {
+                        vo.setCrnStatus(CrnStatusType.process(wrkMast.getIoType()));
+                    } else {
+                        vo.setCrnStatus(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.MACHINE_AUTO: CrnStatusType.MACHINE_UN_AUTO);
+                    }
+                } else {
+                    vo.setCrnStatus(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.MACHINE_AUTO: CrnStatusType.MACHINE_UN_AUTO);
+                }
             }
             vos.add(vo);
 
@@ -150,6 +155,9 @@
         List<BarcodeDataVo> list = new ArrayList<>();
         for (Slave barcode : slaveProperties.getBarcode()) {
             BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, barcode.getId());
+            if (null == barcodeThread) {
+                continue;
+            }
             BarcodeDataVo vo = new BarcodeDataVo();
             vo.setBarcodeId(barcode.getId());
             vo.setCodeValue(barcodeThread.getBarcode());

--
Gitblit v1.9.1