From 9efe3f1d2ccb7375e5d81df7b5c29723dd99cc89 Mon Sep 17 00:00:00 2001 From: dubin <dubin@163.com> Date: 星期一, 19 五月 2025 17:10:14 +0800 Subject: [PATCH] 代码优化 --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 44 +++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 43 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java index 68bbb31..a6f9389 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -306,6 +306,8 @@ } Short workNo = staProtocol.getWorkNo(); Short stano = staProtocol.getStaNo(); + //led + LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed()); // 灏哄妫�娴嬪紓甯� boolean back = false; @@ -364,6 +366,11 @@ if (back) { storageEscalationParam.setWCSStatus(1); storageEscalationParam.setWCSErrorMessage(storageEscalationParam.getWCSErrorMessage() + errMsg); + // led 寮傚父鏄剧ず + if (ledThread != null) { + String errorMsg = errMsg; + MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg)); + } } } @@ -436,6 +443,11 @@ } } } else { + // led 寮傚父鏄剧ず + if (ledThread != null) { + String errorMsg = "宸叉湁鍏ュ簱浠诲姟锛侊紒锛�"; + MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg)); + } staProtocol.setWorkNo((short) 9991); staProtocol.setStaNo(inSta.getBackSta().shortValue()); devpThread.setPakMk(staProtocol.getSiteId(), false); @@ -443,6 +455,13 @@ } } else { + + // led 寮傚父鏄剧ず + if (ledThread != null) { + String errorMsg = jsonObject.getString("ErrorMessage"); + MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg)); + } + staProtocol.setWorkNo((short) 9991); staProtocol.setStaNo(inSta.getBackSta().shortValue()); devpThread.setPakMk(staProtocol.getSiteId(), false); @@ -502,6 +521,9 @@ staProtocol = staProtocol.clone(); } Short workNo = staProtocol.getWorkNo(); + //led + LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed()); + // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢 if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() @@ -590,6 +612,11 @@ } } } else { + // led 寮傚父鏄剧ず + if (ledThread != null) { + String errorMsg = "浠诲姟宸插瓨鍦紒锛侊紒锛�"; + MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg)); + } staProtocol.setWorkNo((short) 9991); staProtocol.setStaNo(inSta.getBackSta().shortValue()); devpThread.setPakMk(staProtocol.getSiteId(), false); @@ -597,6 +624,11 @@ } } else { + // led 寮傚父鏄剧ず + if (ledThread != null) { + String errorMsg = jsonObject.getString("ErrorMessage"); + MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg)); + } staProtocol.setWorkNo((short) 9991); staProtocol.setStaNo(inSta.getBackSta().shortValue()); devpThread.setPakMk(staProtocol.getSiteId(), false); @@ -1129,7 +1161,7 @@ LocMast locMast = locMastService.selectByLocNo(taskWrk.getStartPoint()); //鍒ゆ柇鍏跺簱浣嶆槸鍚︿负娣卞簱浣嶏紝濡傛灉涓烘繁搴撲綅鎵惧叾娴呭簱浣嶆槸閮芥湁璐� - if (locMast.getRow1() == 8 || locMast.getRow1() == 5) { + if (locMast.getRow1() == 5) { LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>() .eq("row1", (locMast.getRow1() + 1)) .eq("bay1", locMast.getBay1()) @@ -1139,6 +1171,16 @@ continue; } } + if (locMast.getRow1() == 8) { + LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>() + .eq("row1", (locMast.getRow1() - 1 )) + .eq("bay1", locMast.getBay1()) + .eq("lev1", locMast.getLev1()).eq("loc_sts", "F")); + if (!Cools.isEmpty(locMast1)) { + log.info(locMast.getLocNo() + "鍑烘繁搴撲綅锛屾祬搴撲綅鏈夎揣"); + continue; + } + } // 鑾峰彇鍫嗗灈鏈哄嚭搴撶珯淇℃伅 SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, crnStn.getDevpPlcId()); -- Gitblit v1.9.1