From c59bcfa4429a5d67842ebaa492db1fa11a3e97fc Mon Sep 17 00:00:00 2001 From: pang.jiabao <pang_jiabao@163.com> Date: 星期四, 10 七月 2025 09:21:25 +0800 Subject: [PATCH] 输送线异常提示 --- src/main/java/com/zy/asrs/controller/ConsoleController.java | 53 ++++++++++++++++++++++++++++++++--------------------- 1 files changed, 32 insertions(+), 21 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/ConsoleController.java b/src/main/java/com/zy/asrs/controller/ConsoleController.java index d7da4a6..b1a0503 100644 --- a/src/main/java/com/zy/asrs/controller/ConsoleController.java +++ b/src/main/java/com/zy/asrs/controller/ConsoleController.java @@ -17,6 +17,7 @@ import com.zy.asrs.mapper.BasCrnErrorMapper; import com.zy.asrs.mapper.LocMastMapper; import com.zy.asrs.mapper.ReportQueryMapper; +import com.zy.asrs.mapper.TaskWrkMapper; import com.zy.asrs.service.BasCrnpService; import com.zy.asrs.service.BasDevpService; import com.zy.asrs.service.DeviceErrorService; @@ -42,6 +43,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; +import javax.annotation.Resource; import java.text.SimpleDateFormat; import java.util.*; @@ -70,6 +72,9 @@ private DeviceErrorService deviceErrorService; @Autowired private BasCrnpService basCrnpService; + + @Resource + private TaskWrkMapper taskWrkMapper; @PostMapping("/system/running/status") @ManagerAuth(memo = "绯荤粺杩愯鐘舵��") @@ -116,7 +121,8 @@ StaProtocol staProtocol = entry.getValue(); vo.setSiteId(String.valueOf(entry.getKey())); // 绔欑偣缂栧彿 vo.setWorkNo(staProtocol.getWorkNo()); // 宸ヤ綔鍙� - vo.setSiteStatus(SiteStatusType.process(staProtocol)); // 鐘舵�� + String faultDescription = staProtocol.getFaultDescription(); + vo.setSiteStatus(Cools.isEmpty(faultDescription) ? SiteStatusType.process(staProtocol) : SiteStatusType.SITE_ERROR); // 鐘舵�� vo.setNearbySta(staProtocol.getNearbySta()); //RGV浣嶇疆 vos.add(vo); } @@ -143,7 +149,7 @@ // Short totalBay = locMastMapper.selectTotalBay(); vo.setOffset((double) new Random().nextInt(560)); // 鍫嗗灈鏈哄亸绉婚噺 - vo.setBay((short) (crnProtocol.getBay() - crn.getOffset())); // 褰撳墠鍒� + vo.setBay(crnProtocol.getBay()); // 褰撳墠鍒� /** * 鍫嗗灈鏈虹姸鎬佸垽鏂� */ @@ -151,9 +157,10 @@ vo.setCrnStatus(CrnStatusType.MACHINE_ERROR); } else { if (crnProtocol.getTaskNo() > 0) { - WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo()); - if (wrkMast != null) { - vo.setCrnStatus(CrnStatusType.process(wrkMast.getIoType())); +// WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo()); + TaskWrk taskWrk = taskWrkMapper.selectByWrkNo(Integer.valueOf(crnProtocol.getTaskNo())); + if (taskWrk != null) { + vo.setCrnStatus(CrnStatusType.process(taskWrk.getIoType())); } else { vo.setCrnStatus(crnProtocol.modeType.equals(CrnModeType.AUTO) ? CrnStatusType.MACHINE_AUTO : CrnStatusType.MACHINE_UN_AUTO); } @@ -279,14 +286,16 @@ vo.setWorkNo(staProtocol.getWorkNo()); // 宸ヤ綔鍙� if (staProtocol.getWorkNo() > 0) { - WrkMast wrkMast = wrkMastService.selectById(staProtocol.getWorkNo()); - if (wrkMast != null) { - vo.setWrkSts(wrkMast.getWrkSts$()); // 宸ヤ綔鐘舵�� - vo.setIoType(wrkMast.getIoType$()); // 鍏ュ嚭搴撶被鍨� - vo.setSourceStaNo(wrkMast.getSourceStaNo$()); - vo.setStaNo(wrkMast.getStaNo$()); - vo.setSourceLocNo(wrkMast.getSourceLocNo$()); - vo.setLocNo(wrkMast.getLocNo$()); +// WrkMast wrkMast = wrkMastService.selectById(staProtocol.getWorkNo()); + TaskWrk taskWrk = taskWrkMapper.selectByWrkNo(Integer.valueOf(staProtocol.getWorkNo())); + + if (taskWrk != null) { + vo.setWrkSts(taskWrk.getWrkSts$()); // 宸ヤ綔鐘舵�� + vo.setIoType(taskWrk.getIoType$()); // 鍏ュ嚭搴撶被鍨� + vo.setSourceStaNo(taskWrk.getStartPoint()); + vo.setStaNo(taskWrk.getTargetPoint()); + vo.setSourceLocNo(taskWrk.getStartPoint()); + vo.setLocNo(taskWrk.getTargetPoint()); } } @@ -295,6 +304,7 @@ vo.setCanining(basDevp.getCanining()); // 鑳藉叆 vo.setCanouting(basDevp.getCanouting()); // 鑳藉嚭 + vo.setError(staProtocol.getFaultDescription()); return R.ok().add(vo); } @@ -330,14 +340,15 @@ } if (crnProtocol.getTaskNo() > 0) { - WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo()); - if (wrkMast != null) { - vo.setSourceStaNo(wrkMast.getSourceStaNo$()); - vo.setStaNo(wrkMast.getStaNo$()); - vo.setWrkSts(wrkMast.getWrkSts$()); // 宸ヤ綔鐘舵�� - vo.setIoType(wrkMast.getIoType$()); // 鍏ュ嚭搴撶被鍨� - vo.setSourceLocNo(wrkMast.getSourceLocNo$()); - vo.setLocNo(wrkMast.getLocNo$()); + TaskWrk taskWrk = taskWrkMapper.selectByWrkNo(Integer.valueOf(crnProtocol.getTaskNo())); +// WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo()); + if (taskWrk != null) { + vo.setSourceStaNo(taskWrk.getStartPoint()); + vo.setStaNo(taskWrk.getTargetPoint()); + vo.setWrkSts(taskWrk.getWrkSts$()); // 宸ヤ綔鐘舵�� + vo.setIoType(taskWrk.getIoType$()); // 鍏ュ嚭搴撶被鍨� + vo.setSourceLocNo(taskWrk.getStartPoint()); + vo.setLocNo(taskWrk.getTargetPoint()); vo.setCrnStatus(crnProtocol.getStatusType().desc); vo.setError(""); // todo } -- Gitblit v1.9.1