From 45a87642e46c746802af13bf47bcd70e3b69277a Mon Sep 17 00:00:00 2001 From: zjj <3272660260@qq.com> Date: 星期四, 14 十二月 2023 16:49:38 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 39 ++++++++++++++++++++++++++------------- 1 files changed, 26 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java index 529e10a..4347bc1 100644 --- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java @@ -53,7 +53,8 @@ @Value("${wms.url}") private String wmsUrl; public ArrayList<String> wharfCode1 = new ArrayList<String>(){{ - add("J-1101"); add("J-1103"); add("J-1105"); add("J-1107"); add("J-1109"); add("J-1111"); + add("J-1101"); add("J-1103"); add("J-1105"); add("J-1107"); add("J-1109"); add("J-1111");add("H-1101"); + add("G-1101"); }}; @@ -91,6 +92,12 @@ taskWrk.setOriginStartPoint(param.getStartPoint()); } taskWrk.setTargetPoint(param.getTargetPoint()); + }else if (param.getIoType() == 3){ + taskWrk.setWrkSts(11); + if (!Cools.isEmpty(param.getStartPoint())) { + taskWrk.setStartPoint(Utils.getWcsLocNo(param.getStartPoint()));//璧风偣 + taskWrk.setOriginStartPoint(param.getStartPoint()); + } } @@ -175,8 +182,8 @@ .eq("type_no",1) .ge("crn_stn",200)); } - //map1.put("taskTunnel", staDesc.getStnDesc()); - map1.put("taskTunnel", "J-1104"); + map1.put("taskTunnel", staDesc.getStnDesc()); + //map1.put("taskTunnel", "J-1104"); return R.ok(map1); } return R.error((String) jsonObject.get("msg")); @@ -200,14 +207,22 @@ staProtocol = staProtocol.clone(); } Short workNo = staProtocol.getWorkNo(); - for (DevpSlave.Sta inSta : devp.getInSta()) { - if (inSta.getBackSta().equals(staDesc.getStnNo())){ - if (wharfCode1.contains(param.getWharfCode())){ - if (!staProtocol.isLoading() && !staProtocol.isCar()){ - //AGV鍑哄簱瀹屾垚浠ュ悗 - } + if (wharfCode1.contains(param.getWharfCode())){ + if (!staProtocol.isLoading() && !staProtocol.isCar() && staProtocol.getWorkNo() >0){ + //AGV鍑哄簱瀹屾垚浠ュ悗 + staProtocol.setWorkNo((short) 0); + staProtocol.setStaNo((short)0); + boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol)); + if (result) { - }else { + } else { + throw new RuntimeException("agv杩斿洖瀹屾垚鍚庯紝鍛戒护涓嬪彂澶辫触"); + } + } + }else { + for (DevpSlave.Sta inSta : devp.getInSta()) { + if (inSta.getBackSta().equals(staDesc.getStnNo())){ + if (staProtocol.isLoading() && !staProtocol.isCar() && workNo == 0){ //AGV鍏ュ簱瀹屾垚浠ュ悗 staProtocol.setWorkNo((short) 9999); @@ -219,12 +234,10 @@ throw new RuntimeException("agv杩斿洖瀹屾垚鍚庯紝鍛戒护涓嬪彂澶辫触"); } } + } } } - - - } } -- Gitblit v1.9.1