From ee51a946795e372e5d7ed025a71dabd27048975c Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期五, 02 七月 2021 11:14:00 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/ConsoleController.java | 28 ++++++++++++++++++++++++---- 1 files changed, 24 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/ConsoleController.java b/src/main/java/com/zy/asrs/controller/ConsoleController.java index 5e79f59..b5792d8 100644 --- a/src/main/java/com/zy/asrs/controller/ConsoleController.java +++ b/src/main/java/com/zy/asrs/controller/ConsoleController.java @@ -1,6 +1,7 @@ package com.zy.asrs.controller; import com.core.annotations.ManagerAuth; +import com.core.common.Arith; import com.core.common.Cools; import com.core.common.R; import com.zy.asrs.domain.enums.CrnStatusType; @@ -13,6 +14,7 @@ import com.zy.asrs.service.BasDevpService; import com.zy.asrs.service.WrkMastService; import com.zy.common.CodeRes; +import com.zy.core.CrnThread; import com.zy.core.Slave; import com.zy.core.cache.SlaveConnection; import com.zy.core.enums.CrnModeType; @@ -24,8 +26,9 @@ import com.zy.core.properties.SlaveProperties; import com.zy.core.properties.SystemProperties; import com.zy.core.thread.BarcodeThread; -import com.zy.core.thread.CrnThread; -import com.zy.core.thread.DevpThread; +import com.zy.core.thread.ScaleThread; +import com.zy.core.thread.SiemensCrnThread; +import com.zy.core.DevpThread; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; @@ -128,7 +131,7 @@ /** * 鍫嗗灈鏈虹姸鎬佸垽鏂� */ - if (crnProtocol.getAlarm() > 0) { + if (crn.getId() == 1 && crnProtocol.getAlarm1() > 0) { vo.setCrnStatus(CrnStatusType.MACHINE_ERROR); } else { if (crnProtocol.getTaskNo()>0) { @@ -160,6 +163,23 @@ BarcodeDataVo vo = new BarcodeDataVo(); vo.setBarcodeId(barcode.getId()); vo.setCodeValue(barcodeThread.getBarcode()); + list.add(vo); + } + return R.ok().add(list); + } + + @PostMapping("/latest/data/scale") + @ManagerAuth(memo = "纾呯Г瀹炴椂鏁版嵁") + public R scaleLatestData(){ + List<ScaleDataVo> list = new ArrayList<>(); + for (Slave scale : slaveProperties.getScale()) { + ScaleThread scaleThread = (ScaleThread) SlaveConnection.get(SlaveType.Scale, scale.getId()); + if (null == scaleThread) { + continue; + } + ScaleDataVo vo = new ScaleDataVo(); + vo.setScaleId(scale.getId()); + vo.setValue(String.valueOf(Arith.multiplys(1, scaleThread.getScale(), 1))); list.add(vo); } return R.ok().add(list); @@ -223,7 +243,7 @@ CrnDetailVo vo = new CrnDetailVo(); for (CrnSlave crnSlave : slaveProperties.getCrn()) { if (crnSlave.getId().equals(crnNo)) { - CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crnSlave.getId()); + SiemensCrnThread crnThread = (SiemensCrnThread) SlaveConnection.get(SlaveType.Crn, crnSlave.getId()); CrnProtocol crnProtocol = crnThread.getCrnProtocol(); vo.setCrnNo(crnNo); vo.setWorkNo(crnProtocol.getTaskNo()); -- Gitblit v1.9.1