From c9a3592c20b7913dd9949383721ae26c32563eb7 Mon Sep 17 00:00:00 2001 From: zjj <3272660260@qq.com> Date: 星期六, 02 十一月 2024 10:25:11 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 200 +++++++++++++++++++++++++++++++++++++++++-------- 1 files changed, 166 insertions(+), 34 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 08a9a18..f77025b 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -94,6 +94,8 @@ private WrkMastStaService wrkMastStaService; @Autowired private MatnrCodeService matnrCodeService; + @Autowired + private WaitPakinService waitPakinService; @Value("${wms.url}") private String wmsUrl; @@ -2065,10 +2067,14 @@ List<StaDesc> staDescs = staDescService.selectList(new EntityWrapper<StaDesc>().eq("type_no", 10).eq("stn_no", sta.getStaNo())); for (StaDesc staDesc:staDescs){ - BasDevp basDevp = basDevpService.selectOne(new EntityWrapper<BasDevp>().eq("dev_no", staDesc.getCrnStn())); + BasDevp basDevp = new BasDevp(); - WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("crn_no", staDesc.getCrnNo()).gt("io_type", 100)); - if (!Cools.isEmpty(wrkMast)){ + if (staDesc.getCrnNo() == 1){ + basDevp = basDevpService.selectOne(new EntityWrapper<BasDevp>().eq("dev_no", 1004)); + } else if (staDesc.getCrnNo() == 2) { + basDevp = basDevpService.selectOne(new EntityWrapper<BasDevp>().eq("dev_no", 1008)); + } + if (Cools.isEmpty(basDevp)){ continue; } @@ -2076,7 +2082,7 @@ && basDevp.getWrkNo() == 0 && basDevp.getCanining().equals("Y")){ // 鏇存柊绔欑偣淇℃伅 涓� 涓嬪彂plc鍛戒护 staProtocol.setWorkNo((short) 9997); - staProtocol.setStaNo(basDevp.getDevNo().shortValue()); + staProtocol.setStaNo((short) (basDevp.getDevNo()==1004?1003:1013)); // staProtocol.setStaNo((short) 1013); devpThread.setPakMk(staProtocol.getSiteId(), false); boolean result = MessageQueue.offer(SlaveType.Devp, devpThread.getSlave().getId(), new Task(2, staProtocol)); @@ -2146,11 +2152,19 @@ // && staProtocol.isEmptyMk() && staProtocol.getWorkNo() == 0 ) { - WrkMast pakoutEmpty = wrkMastMapper.selectPakoutEmpty(sta.getStaNo()); + Integer staNo = sta.getStaNo(); + switch (staProtocol.getSiteId()){ + case 4007: + staNo = 4002;break; + case 4016: + staNo = 4011;break; + } + WrkMast pakoutEmpty = wrkMastMapper.selectPakoutEmpty(staNo); if (null != pakoutEmpty) { return; } - List<StaDesc> staDescs = staDescService.selectList(new EntityWrapper<StaDesc>().eq("stn_no", sta.getStaNo())); + + List<StaDesc> staDescs = staDescService.selectList(new EntityWrapper<StaDesc>().eq("stn_no", staNo)); for (StaDesc staDesc: staDescs){ BasCrnp basCrnp = basCrnpService.selectOne(new EntityWrapper<BasCrnp>().eq("crn_no", staDesc.getCrnNo())); if (!basCrnp.getCrnSts().equals(3) || basCrnp.getCrnErr() != 0){ @@ -2159,6 +2173,7 @@ try { HashMap<String, Object> map = new HashMap<>(); map.put("crnNo", staDesc.getCrnNo());//鐩爣绔� + map.put("staNo",staDesc.getStnNo()); String response = new HttpHandler.Builder() .setUri(wmsUrl) .setParams(map) @@ -2265,7 +2280,7 @@ crnCommand.setSourcePosX(crnStn.getRow().shortValue()); // 婧愬簱浣嶆帓 crnCommand.setSourcePosY(crnStn.getBay().shortValue()); // 婧愬簱浣嶅垪 crnCommand.setSourcePosZ(crnStn.getLev().shortValue()); // 婧愬簱浣嶅眰 - crnCommand.setDestinationPosX(locMast.getRow1()==9?(short)4:(short)5); // 鐩爣搴撲綅鎺� + crnCommand.setDestinationPosX(locMast.getRow1().shortValue()); // 鐩爣搴撲綅鎺� crnCommand.setDestinationPosY(locMast.getBay1().shortValue()); // 鐩爣搴撲綅鍒� crnCommand.setDestinationPosZ(locMast.getLev1().shortValue()); // 鐩爣搴撲綅灞� crnCommand.setLocType1(locMast.getLocType1().shortValue()); // 璐х墿绫诲瀷 @@ -2410,7 +2425,7 @@ crnCommand.setTaskNo(wrkMast.getWrkNo().shortValue()); // 宸ヤ綔鍙� crnCommand.setAckFinish((short) 0); // 浠诲姟瀹屾垚纭浣� crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡: 搴撲綅绉昏浆 - crnCommand.setSourcePosX(locMast.getRow1()==9?(short)4:(short)5); // 婧愬簱浣嶆帓 + crnCommand.setSourcePosX(locMast.getRow1().shortValue()); // 婧愬簱浣嶆帓 crnCommand.setSourcePosY(locMast.getBay1().shortValue()); // 婧愬簱浣嶅垪 crnCommand.setSourcePosZ(locMast.getLev1().shortValue()); // 婧愬簱浣嶅眰 crnCommand.setDestinationPosX(crnStn.getRow().shortValue()); // 鐩爣搴撲綅鎺� @@ -2501,6 +2516,10 @@ }else { rgvProtocol = rgvProtocol.clone(); } + List<WrkMastSta> wrkMastStas = wrkMastStaService.selectRGVTask1(rgvSlave.getId()); + if (!Cools.isEmpty(wrkMastStas)){ + continue; + } if (rgvProtocol.getModeType() == RgvModeType.AUTO && rgvProtocol.getStatusType() == RgvStatusType.IDLE && rgvProtocol.getLoaded1() == 0){ boolean work1 = false; boolean work2 = false; @@ -2518,6 +2537,8 @@ short type2 = 0; short anfme = 0; short anfme2 = 0; + Double weight = 0d; + Double weight2 = 0d; //宸ヤ綅涓�浠诲姟 for (RgvSlave.Sta inStn : rgvSlave.getInStn()){ @@ -2527,12 +2548,12 @@ SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, inStn.getSourcePlcId()); StaProtocol staProtocol = devpThread.getStation().get(inStn.getSourceStaNo()); if (staProtocol == null) { - break; -// continue; +// break; + continue; } else { staProtocol = staProtocol.clone(); } - if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.isPakMk() && staProtocol.getWorkNo()>0){ + if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.isPakMk() && (staProtocol.getWorkNo()>0 && staProtocol.getWorkNo()<9900)){ WrkMast wrkMast = wrkMastService.selectByworkNo(staProtocol.getWorkNo()); if (Cools.isEmpty(wrkMast)){ @@ -2547,6 +2568,37 @@ break; + } else if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.isPakMk() && (staProtocol.getWorkNo()>=9900 || staProtocol.getWorkNo()==0)) { + if (rgvSlave.getId() != 2 ){ + continue; + } + workNo1 = workNo++; + souSta1 = Utils.getRgvStaNo(rgvSlave.getId(),inStn.getSourceStaNo()); + if (inStn.getSourceStaNo() == 4007 && staProtocol.getTongType() == 1){ + sta1 = Utils.getRgvStaNo(rgvSlave.getId(),2103); + } else if (inStn.getSourceStaNo() == 4007 && staProtocol.getTongType() == 2) { + sta1 = Utils.getRgvStaNo(rgvSlave.getId(),2002); + } else if (inStn.getSourceStaNo() == 2102 && staProtocol.isFullPlt()) { + sta1 = Utils.getRgvStaNo(rgvSlave.getId(),2301); + } else { + sta1 = Utils.getRgvStaNo(rgvSlave.getId(),inStn.getStaNo()); + } + + if (inStn.getSourceStaNo() == 2102 && staProtocol.isEmptyMk()){ //鍖哄垎绌烘澘 + type = 1; + } + if(inStn.getSourceStaNo() == 2102){ + weight = staProtocol.getWeight().doubleValue()/10; + } + + work1 = true; + if (inStn.getSourcePlcId() == 4 || inStn.getSourcePlcId() ==5){ //鐏岃绔欓渶瑕佽幏鍙栬緭閫佺嚎鐗╂枡浠g爜 + matnr = staProtocol.getMatnr(); + batch = staProtocol.getBatch(); + } + + devpThread.setPakMk(inStn.getSourceStaNo(),false); + break; } } @@ -2562,12 +2614,12 @@ SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, inStn.getSourcePlcId()); StaProtocol staProtocol = devpThread.getStation().get(inStn.getSourceStaNo()); if (staProtocol == null) { - break; -// continue; +// break; + continue; } else { staProtocol = staProtocol.clone(); } - if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable()&& staProtocol.isPakMk() && staProtocol.getWorkNo()>0){ + if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable()&& staProtocol.isPakMk() && (staProtocol.getWorkNo()>0 && staProtocol.getWorkNo()<9900)){ WrkMast wrkMast = wrkMastService.selectByworkNo(staProtocol.getWorkNo()); if (Cools.isEmpty(wrkMast)){ @@ -2580,7 +2632,38 @@ work2 = true; devpThread.setPakMk(inStn.getSourceStaNo(),false); break; + } else if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.isPakMk() && (staProtocol.getWorkNo()>=9900 || staProtocol.getWorkNo()==0)) { + if (rgvSlave.getId() != 2 ){ + continue; } + workNo2 = workNo++; + souSta2 = Utils.getRgvStaNo(rgvSlave.getId(),inStn.getSourceStaNo()); + if (inStn.getSourceStaNo() == 4007 && staProtocol.getTongType() == 1){ + sta2 = Utils.getRgvStaNo(rgvSlave.getId(),2103); + } else if (inStn.getSourceStaNo() == 4007 && staProtocol.getTongType() == 2) { + sta2 = Utils.getRgvStaNo(rgvSlave.getId(),2002); + }else if (inStn.getSourceStaNo() == 2102 && staProtocol.isFullPlt()) { + sta2 = Utils.getRgvStaNo(rgvSlave.getId(),2301); + } else { + sta2 = Utils.getRgvStaNo(rgvSlave.getId(),inStn.getStaNo()); + } + + if (inStn.getSourceStaNo() == 2102 && staProtocol.isEmptyMk()){ //鍖哄垎绌烘澘 + type2 = 1; + } + + if(inStn.getSourceStaNo() == 2102){ + weight2 = staProtocol.getWeight().doubleValue()/10; + } + + work2 = true; + if (inStn.getSourcePlcId() == 4){ + matnr2 = staProtocol.getMatnr(); + batch2 = staProtocol.getBatch(); + } + devpThread.setPakMk(inStn.getSourceStaNo(),false); + break; + } } @@ -2612,6 +2695,9 @@ command.setType(type); command.setType2(type2); + + command.setWeight(weight); + command.setWeight2(weight2); if (workNo1 == 0 && workNo2 !=0){ command.setTaskMode(RgvTaskModeType.FETCH_PUT2); // 浠诲姟妯″紡: 2鍙栨斁璐� @@ -2656,10 +2742,10 @@ log.info("{}鍙穜gv宸ヤ綅涓�宸ヤ綔瀹屾垚澶嶄綅,宸ヤ綔鍙�:{}",rgvSlave.getId(),rgvProtocol.getTaskNo1()); if (offer){ //瀹屾垚rgv浠诲姟 - Wrapper<WrkMastSta> wrkMastStaWrapper = new EntityWrapper<WrkMastSta>().eq("wrk_crn", rgvProtocol.getRgvNo()).eq("wrk_no", rgvProtocol.getTaskNo1()); + Wrapper<WrkMastSta> wrkMastStaWrapper = new EntityWrapper<WrkMastSta>().eq("wrk_crn", rgvSlave.getId()).eq("wrk_no", rgvProtocol.getTaskNo1()); WrkMastSta wrkMastSta1 = wrkMastStaService.selectOne(wrkMastStaWrapper); if (Cools.isEmpty(wrkMastSta1)){ - log.error("瀹屾垚{}鍙疯溅宸ヤ綅涓�浠诲姟鏈壘鍒板搴攔gv浠诲姟,{}",rgvProtocol.getRgvNo(),rgvProtocol.getTaskNo1()); + log.error("瀹屾垚{}鍙疯溅宸ヤ綅涓�浠诲姟鏈壘鍒板搴攔gv浠诲姟,{}",rgvSlave.getId(),rgvProtocol.getTaskNo1()); }else { if (wrkMastSta1.getWrkType() == 8 ){ wrkMastSta1.setWrkSts(3); @@ -2762,7 +2848,7 @@ WrkMastSta wrkMastSta = wrkMastStaService.selectByRgvNoandWrkNo(rgvSlave.getId(), rgvProtocol.getTaskNo1()); WrkMast wrkMast = wrkMastService.selectByworkNo(rgvProtocol.getTaskNo1()); if (Cools.isEmpty(wrkMastSta)){ - log.error("鏈煡璇㈠埌rgv宸ヤ綔浠诲姟锛宺gv缂栧彿{},宸ヤ綔鍙穥}",rgvProtocol.getRgvNo(),rgvProtocol.getTaskNo1()); + log.error("鏈煡璇㈠埌rgv宸ヤ綔浠诲姟锛宺gv缂栧彿{},宸ヤ綔鍙穥}",rgvSlave.getId(),rgvProtocol.getTaskNo1()); continue; } for (RgvSlave.Sta outStn :rgvSlave.getOutStn()){ @@ -2840,6 +2926,9 @@ continue; } for (RgvSlave.Sta outStn :rgvSlave.getOutStn()){ + if (!Objects.equals(Utils.getStaNo(rgvSlave.getId(), wrkMastSta.getWrkEnd()), outStn.getStaNo())){ + continue; + } SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, outStn.getStaPlcId()); StaProtocol staProtocol = devpThread.getStation().get(outStn.getStaNo()); if (staProtocol == null) { @@ -2875,6 +2964,9 @@ continue; } for (RgvSlave.Sta outStn :rgvSlave.getOutStn()){ + if (!Objects.equals(Utils.getStaNo(rgvSlave.getId(), wrkMastSta.getStaEnd()), outStn.getStaNo())){ + continue; + } SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, outStn.getStaPlcId()); StaProtocol staProtocol = devpThread.getStation().get(outStn.getStaNo()); if (staProtocol == null) { @@ -2967,7 +3059,7 @@ boolean offer = MessageQueue.offer(SlaveType.Rgv, rgvSlave.getId(), new Task(4, new RgvCommand())); log.info("{}鍙穜gv宸ヤ綅浜屽伐浣滃畬鎴愬浣�,宸ヤ綔鍙�:{}",rgvSlave.getId(),rgvProtocol.getTaskNo2()); if (offer){ - Wrapper<WrkMastSta> wrkMastStaWrapper = new EntityWrapper<WrkMastSta>().eq("wrk_crn", rgvProtocol.getRgvNo()).eq("wrk_no", rgvProtocol.getTaskNo2()); + Wrapper<WrkMastSta> wrkMastStaWrapper = new EntityWrapper<WrkMastSta>().eq("wrk_crn", rgvProtocol.getRgvNo()).eq("wrk_no2", rgvProtocol.getTaskNo2()); WrkMastSta wrkMastSta1 = wrkMastStaService.selectOne(wrkMastStaWrapper); if (Cools.isEmpty(wrkMastSta1)){ log.error("瀹屾垚{}鍙疯溅宸ヤ綅浜屼换鍔℃湭鎵惧埌瀵瑰簲宸ヤ綔浠诲姟,{}",rgvProtocol.getRgvNo(),rgvProtocol.getTaskNo2()); @@ -3011,10 +3103,26 @@ public boolean rgvTaskSave(RgvCommand command){ // Wrapper<WrkMastSta> wrkMastStaWrapper = new EntityWrapper<WrkMastSta>().eq("wrk_crn", command.getRgvNo()).eq("wrk_no", command.getTaskNo1()); - List<WrkMastSta> wrkMastSta1 = wrkMastStaService.selectBywrkNoHistoricalTasks(command.getRgvNo(),command.getTaskNo1(),command.getTaskNo2()); - if (!Cools.isEmpty(wrkMastSta1)){ - wrkMastStaService.deleteBatchIds(wrkMastSta1); + if (command.getTaskNo1() > 0){ + List<WrkMastSta> wrkMastSta1 = wrkMastStaService.selectBywrkNoHistoricalTasks(command.getRgvNo(),command.getTaskNo1()); + if (!Cools.isEmpty(wrkMastSta1)){ + for (WrkMastSta wrkMastSta :wrkMastSta1){ + wrkMastStaService.deleteById(wrkMastSta); + } + + } } + if (command.getTaskNo2() > 0){ + List<WrkMastSta> wrkMastSta1 = wrkMastStaService.selectBywrkNoHistoricalTasks2(command.getRgvNo(),command.getTaskNo2()); + if (!Cools.isEmpty(wrkMastSta1)){ + for (WrkMastSta wrkMastSta :wrkMastSta1){ + wrkMastStaService.deleteById(wrkMastSta); + } + + } + } + + WrkMastSta wrkMastSta = new WrkMastSta(); wrkMastSta.setWrkNo(Long.valueOf(command.getTaskNo1())); wrkMastSta.setWrkNo2(Long.valueOf(command.getTaskNo2())); @@ -3028,14 +3136,17 @@ wrkMastSta.setUpdateTime(now); wrkMastSta.setWrkCrn(command.getRgvNo()); wrkMastSta.setWrkType(command.getTaskMode().intValue()); - wrkMastSta.setMatnr1(command.getMatnr().intValue()); - wrkMastSta.setMatnr2(command.getMatnr2().intValue()); + wrkMastSta.setMatnr1(command.getMatnr()); + wrkMastSta.setMatnr2(command.getMatnr2()); wrkMastSta.setType(command.getType().intValue()); wrkMastSta.setType2(command.getType2().intValue()); wrkMastSta.setBatch(command.getBatch()); wrkMastSta.setBatch2(command.getBatch2()); wrkMastSta.setAnfme(command.getAnfme().intValue()); wrkMastSta.setAnfme2(command.getAnfme2().intValue()); + wrkMastSta.setWeight(command.getWeight()); + wrkMastSta.setWeight2(command.getWeight2()); + return wrkMastStaService.insert(wrkMastSta); } @@ -3105,14 +3216,26 @@ } } // 鑾峰彇鍏ュ簱閫氱煡妗� - List<WaitPakin> waitPakins = waitPakinMapper.selectList(new EntityWrapper<WaitPakin>().eq("zpallet", barcode).eq("io_status", "N")); - if (waitPakins.isEmpty()) { + WaitPakin waitPakin = waitPakinService.selectOne(new EntityWrapper<WaitPakin>().eq("zpallet", barcode).eq("io_status", "N")); + if (Cools.isEmpty(waitPakin)) { try { - CreateComb(barcode,staProtocol.getMatnr().intValue(),staProtocol.getWorkNo().intValue()); + CreateComb(barcode, staProtocol.getMatnr(),staProtocol.getWorkNo().intValue(),staProtocol.getBatch()); }catch (IOException e) { throw new CoolException(e); } - }else { + } else if (waitPakin.getWeight() == null) { + WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("wrk_no", staProtocol.getWorkNo().intValue())); + if (Cools.isEmpty(wrkMastSta)){ + wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("wrk_no2", staProtocol.getWorkNo().intValue())); + if (Cools.isEmpty(wrkMastSta)){ + throw new CoolException("鏈壘鍒板搴旂殑浠诲姟淇℃伅"); + } + waitPakin.setWeight(wrkMastSta.getWeight2()); + }else { + waitPakin.setWeight(wrkMastSta.getWeight()); + } + waitPakinService.update(waitPakin,new EntityWrapper<WaitPakin>().eq("zpallet", barcode).eq("io_status", "N")); + } else { try { LocTypeDto locTypeDto = new LocTypeDto(staProtocol); SearchLocParam param = new SearchLocParam(); @@ -3166,23 +3289,30 @@ } - public void CreateComb(String barcode,Integer code,Integer wrkNo) throws IOException { - String batch = ""; - Double anfme = 0D; + public void CreateComb(String barcode,Integer code,Integer wrkNo,String batch) throws IOException { + Double anfme = 0d; + Double weight = 0d; WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("wrk_no", wrkNo)); if (Cools.isEmpty(wrkMastSta)){ wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("wrk_no2", wrkNo)); if (Cools.isEmpty(wrkMastSta)){ - throw new CoolException("鏈壘鍒板搴旂殑浠诲姟淇℃伅"); + if (code >0 && !Cools.isEmpty(batch)){ + anfme = 1d; + }else { + throw new CoolException("鏈壘鍒板搴旂殑浠诲姟淇℃伅"); + } + }else { + batch = wrkMastSta.getBatch2(); + anfme = wrkMastSta.getAnfme2().doubleValue(); + code = wrkMastSta.getMatnr2(); + weight = wrkMastSta.getWeight2(); } - batch = wrkMastSta.getBatch2(); - anfme = wrkMastSta.getAnfme2().doubleValue(); - code = wrkMastSta.getMatnr2(); }else { batch = wrkMastSta.getBatch(); anfme = wrkMastSta.getAnfme().doubleValue(); code = wrkMastSta.getMatnr1(); + weight = wrkMastSta.getWeight(); } MatnrCode matnrCode = matnrCodeService.selectByCode(code); if (Cools.isEmpty(matnrCode)){ @@ -3208,6 +3338,8 @@ JSONObject jsonObject = JSON.parseObject(response); if (jsonObject.getInteger("code").equals(200)) { + }else { + log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + "/mobile/comb/auth", JSON.toJSONString(combParam), response); } } -- Gitblit v1.9.1