From be61c90200910a3e48c72596f3bbd459a2a73f25 Mon Sep 17 00:00:00 2001 From: pang.jiabao <pang_jiabao@163.com> Date: 星期日, 25 五月 2025 13:47:13 +0800 Subject: [PATCH] 取消写入后回答延时 --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 24 ++++++++++++++---------- 1 files changed, 14 insertions(+), 10 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 18c8b4b..1086ff1 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -184,16 +184,21 @@ continue; } if (back) { - log.info("鎵樼洏閫�鍥�==>{}锛寋}", BoxNo, errMsg); staProtocol.setStaNo(inSta.getBackSta().shortValue()); devpThread.setPakMk(staProtocol.getSiteId(), false); MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); + log.info("缁勬墭鍏ュ簱鎵樼洏閫�鍥炲懡浠ゆ帹閫佽緭閫佺嚎闃熷垪鎴愬姛==>{}锛寋}", BoxNo, errMsg); } else { StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>() .eq("crn_no", taskWrk.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId())); + if (staDesc == null) { + log.error("缁勬墭鍏ュ簱璺緞涓嶅瓨鍦紝wrkNo={},crn={},stn_no={}",taskWrk.getWrkNo(),taskWrk.getCrnNo(),staProtocol.getSiteId()); + continue; + } staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue()); staProtocol.setStaNo(staDesc.getCrnStn().shortValue()); MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); + log.info("缁勬墭鍏ュ簱鍛戒护鎺ㄩ�佽緭閫佺嚎闃熷垪鎴愬姛:{}",staProtocol); } } @@ -419,24 +424,24 @@ LocMast locMast = locMastService.selectByLocNo(taskWrk.getStartPoint()); //鍒ゆ柇鍏跺簱浣嶆槸鍚︿负娣卞簱浣嶏紝濡傛灉涓烘繁搴撲綅鎵惧叾娴呭簱浣嶆槸閮芥湁璐� - boolean flag = false; + int flag = 0; if (locMast.getRow1() == 1 || locMast.getRow1() == 5 || locMast.getRow1() == 9) { - flag = true; + flag = 1; } else if (locMast.getRow1() == 4 || locMast.getRow1() == 8 || locMast.getRow1() == 12) { - flag = true; + flag = 2; } - if (flag) { + if (flag == 1) { LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>() - .eq("row1", (locMast.getRow1() - 1)) + .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; } - } else { + } else if (flag == 2){ LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>() - .eq("row1", (locMast.getRow1() + 1)) + .eq("row1", (locMast.getRow1() - 1)) .eq("bay1", locMast.getBay1()) .eq("lev1", locMast.getLev1()).eq("loc_sts", "F")); if (!Cools.isEmpty(locMast1)) { @@ -614,7 +619,7 @@ CrnOperatorParam crnOperatorParam = new CrnOperatorParam(); crnOperatorParam.setCrnNo(crn.getId()); R r = crnController.crnTaskComplete(crnOperatorParam); - Thread.sleep(1000); +// Thread.sleep(1000); if (!r.get("code").equals(200)) { return; } @@ -625,7 +630,6 @@ //鏇存柊搴撲綅鐘舵�� LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint()); locMast.setLocSts("F");//F.鍦ㄥ簱 - locMast.setStatus("1"); locMast.setBarcode(taskWrk.getBarcode());//鎵樼洏鐮� locMast.setModiTime(new Date()); locMast.setModiUser(9999L); -- Gitblit v1.9.1