From 6ca0cf26e5eeaaf8dd3761640dd88c558bf4efc7 Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期二, 15 十月 2024 14:35:48 +0800 Subject: [PATCH] * --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 32 ++++++++++++++++++++++++++++++-- 1 files changed, 30 insertions(+), 2 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 9306a2b..1a940ee 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -2319,6 +2319,7 @@ param.setIoType(10); param.setSourceStaNo(122); param.setLocType1((short)1); + param.setRgvNo(rgvProtocol.getRgvNo()); String response = new HttpHandler.Builder() .setUri(wmsUrl) .setPath("/rpc/pakin/empty/loc/v1") @@ -2364,7 +2365,8 @@ DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, led.getDevpPlcId()); // 鍛戒护闆嗗悎 List<LedCommand> commands = new ArrayList<>(); - // 宸ヤ綔妗i泦鍚� + String orderNo = null; + // 宸ヤ綔妗i泦鍚� List<WrkMast> wrkMasts = new ArrayList<>(); for (Integer staNo : led.getStaArr()) { // 鑾峰彇鍙夎溅绔欑偣 @@ -2424,7 +2426,13 @@ // ledCommand.setSourceStaNo(wrkMast.getSourceStaNo()); if (wrkMast.getIoType() != 110 && wrkMast.getIoType() != 10) { List<WrkDetl> wrkDetls = wrkDetlService.findByWorkNo(wrkMast.getWrkNo()); - wrkDetls.forEach(wrkDetl -> ledCommand.getMatDtos().add(new MatDto(wrkDetl))); + if (Cools.isEmpty(wrkDetls)){ + continue; + } + Integer count1 = wrkDetlService.count1(); + Integer count2 = wrkDetlService.count2(wrkDetls.get(0).getOrderNo()); + Integer count3 = wrkDetlService.count3(); + wrkDetls.forEach(wrkDetl -> ledCommand.getMatDtos().add(new MatDto(wrkDetl,count1,count2,count3))); } commands.add(ledCommand); } @@ -3379,6 +3387,26 @@ if (!staProtocol.isLoading()){ continue; } + StaProtocol staProtocol120 = devpThread.getStation().get(120); + if (staProtocol120 == null) { + continue; + } else { + staProtocol120 = staProtocol120.clone(); + } + + if (staProtocol120.isLoading()){ + continue; + } + StaProtocol staProtocol121 = devpThread.getStation().get(121); + if (staProtocol121 == null) { + continue; + } else { + staProtocol121 = staProtocol121.clone(); + } + + if (staProtocol121.isLoading()){ + continue; + } // if (!staProtocol.getWorkNo().equals(wrkMast131.getWrkNo())){ // log.info("绔欑偣宸ヤ綔鍙�={} 涓庤创鏍囧伐浣滃彿={} 涓嶄竴鑷达紝寮傚父锛�",staProtocol.getWorkNo(),wrkMast131.getWrkNo().shortValue()); // } -- Gitblit v1.9.1