From 42bcc76b7e473a23ba8d59619945d4fcd3d6c787 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期一, 31 八月 2020 13:51:04 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/ConsoleController.java | 30 +++++++++++++++++++++++------- 1 files changed, 23 insertions(+), 7 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/ConsoleController.java b/src/main/java/com/zy/asrs/controller/ConsoleController.java index a0473e0..2c6af3f 100644 --- a/src/main/java/com/zy/asrs/controller/ConsoleController.java +++ b/src/main/java/com/zy/asrs/controller/ConsoleController.java @@ -9,6 +9,7 @@ import com.zy.asrs.domain.vo.*; import com.zy.asrs.entity.BasDevp; import com.zy.asrs.entity.WrkMast; +import com.zy.asrs.mapper.LocMastMapper; import com.zy.asrs.service.BasDevpService; import com.zy.asrs.service.WrkMastService; import com.zy.common.CodeRes; @@ -49,6 +50,8 @@ private WrkMastService wrkMastService; @Autowired private BasDevpService basDevpService; + @Autowired + private LocMastMapper locMastMapper; @PostMapping("/system/running/status") @ManagerAuth(memo = "绯荤粺杩愯鐘舵��") @@ -70,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())); } @@ -119,17 +122,27 @@ } CrnLatestDataVo vo = new CrnLatestDataVo(); vo.setCrnId(crn.getId()); // 鍫嗗灈鏈虹紪鍙� + +// Short totalBay = locMastMapper.selectTotalBay(); + vo.setOffset((double) new Random().nextInt(560)); // 鍫嗗灈鏈哄亸绉婚噺 + vo.setBay((short) (crnProtocol.getBay() - crn.getOffset())); // 褰撳墠鍒� /** * 鍫嗗灈鏈虹姸鎬佸垽鏂� */ - if (crnProtocol.getTaskNo()>0) { - WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo()); - if (wrkMast != null) { - vo.setCrnStatusType(CrnStatusType.process(wrkMast.getIoType())); - } + if (crnProtocol.getAlarm() > 0) { + vo.setCrnStatus(CrnStatusType.MACHINE_ERROR); } else { - vo.setCrnStatusType(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.AUTO: CrnStatusType.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); @@ -143,6 +156,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