From 3adff2c549121bc166f49aa8de681265cd87b2d9 Mon Sep 17 00:00:00 2001 From: 野心家 <1051256694@qq.com> Date: 星期四, 19 六月 2025 09:49:09 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 321 +++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 274 insertions(+), 47 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 ac3afb1..a6f9389 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -29,6 +29,7 @@ import com.zy.core.enums.*; import com.zy.core.model.CrnSlave; import com.zy.core.model.DevpSlave; +import com.zy.core.model.LedSlave; import com.zy.core.model.Task; import com.zy.core.model.command.CommandPackage; import com.zy.core.model.command.CrnCommand; @@ -36,6 +37,7 @@ import com.zy.core.model.protocol.StaProtocol; import com.zy.core.properties.SlaveProperties; import com.zy.core.thread.BarcodeThread; +import com.zy.core.thread.LedThread; import com.zy.core.thread.SiemensDevpThread; import com.zy.system.entity.Config; import com.zy.system.service.ConfigService; @@ -113,13 +115,15 @@ private CrnController crnController; @Autowired private SiteController siteController; + @Autowired + private TaskWrkLogService taskWrkLogService; /** * 鍫嗗灈鏈烘紨绀� ===>> 搴撲綅绉昏浆 */ public synchronized void crnDemoOfLocMove1() { try { - List <BasCrnp> basCrnps =basCrnpService.selectList(new EntityWrapper<BasCrnp>()); + List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<BasCrnp>()); for (BasCrnp crn : basCrnps) { if (!crn.getEmpIn().equals("1")) { continue; @@ -131,7 +135,7 @@ if (crnProtocol == null) { continue; } - TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("crn_no",crn.getCrnNo()).eq("io_type",3)); + TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("crn_no", crn.getCrnNo()).eq("io_type", 3)); if (taskWrk1 != null) { continue; } @@ -141,7 +145,7 @@ LocMast sourceLoc = locMastService.queryDemoSourceLoc(crn.getCrnNo()); - LocMast loc = locMastService.queryDemoLoc(crn.getCrnNo(),sourceLoc.getLocType1()); + LocMast loc = locMastService.queryDemoLoc(crn.getCrnNo(), sourceLoc.getLocType1()); if (null == sourceLoc || null == loc) { continue; } @@ -152,7 +156,7 @@ // 淇濆瓨宸ヤ綔妗� TaskWrk taskWrk = new TaskWrk(); taskWrk.setWrkNo(workNo); - taskWrk.setTaskNo(workNo+"");//浠诲姟鍙� + taskWrk.setTaskNo(workNo + "");//浠诲姟鍙� taskWrk.setWrkSts(11); // 宸ヤ綔鐘舵�侊細11.鐢熸垚鍑哄簱ID taskWrk.setIoType(3); // 鍏ュ嚭搴撶姸鎬侊細 3.搴撴牸绉昏浇 taskWrk.setIoPri(13); @@ -164,7 +168,7 @@ int res = taskWrkMapper.insert(taskWrk); if (res == 0) { throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); - }else { + } else { loc.setCtnKind(1); locMastService.updateById(loc); } @@ -302,6 +306,8 @@ } Short workNo = staProtocol.getWorkNo(); Short stano = staProtocol.getStaNo(); + //led + LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed()); // 灏哄妫�娴嬪紓甯� boolean back = false; @@ -341,33 +347,41 @@ && staProtocol.isPakMk()) { // 鑾峰彇鏉$爜鎵弿浠俊鎭� BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, inSta.getBarcode()); - if (barcodeThread == null) { - continue; - } - String BoxNo = barcodeThread.getBarcode(); - TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("barcode", BoxNo)); - if (!Cools.isEmpty(taskWrk1)) { - log.info("鎵樼洏鐮侊細" + BoxNo + "浠诲姟妗e瓨鍦�"); - if (taskWrk1.getIoType() == 1 && taskWrk1.getStartPoint().equals(staProtocol.getSiteId().toString())) { - StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>() - .eq("crn_no", taskWrk1.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId())); - if (Cools.isEmpty(staDesc)) { - return; - } else { - continue; + String BoxNo = ""; + if (barcodeThread != null) { + BoxNo = barcodeThread.getBarcode(); + TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("barcode", BoxNo)); + if (!Cools.isEmpty(taskWrk1)) { + log.info("鎵樼洏鐮侊細" + BoxNo + "浠诲姟妗e瓨鍦�"); + if (taskWrk1.getIoType() == 1 && taskWrk1.getStartPoint().equals(staProtocol.getSiteId().toString())) { + StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>() + .eq("crn_no", taskWrk1.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId())); + if (Cools.isEmpty(staDesc)) { + return; + } else { + continue; + } + } + } + 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)); } } } - if (back) { - storageEscalationParam.setWCSStatus(1); - storageEscalationParam.setWCSErrorMessage(storageEscalationParam.getWCSErrorMessage() + errMsg); - } - log.info("缁勬墭鍏ュ簱={}", storageEscalationParam); + + storageEscalationParam.setBoxNo(BoxNo); //鏄惁婊℃澘 1婊℃澘 0绌烘澘 - storageEscalationParam.setStaType(staProtocol.isEmptyMk()? 0:1); + storageEscalationParam.setStaType(staProtocol.isEmptyMk() ? 0 : 1); //搴撲綅绫诲瀷 1楂樺簱浣� 0浣庡簱浣� - storageEscalationParam.setLocType(staProtocol.isHigh()? 1:0); + storageEscalationParam.setLocType(staProtocol.isHigh() ? 1 : 0); + storageEscalationParam.setTerminalNo(staProtocol.getSiteId()); + log.info("缁勬墭鍏ュ簱={}", storageEscalationParam); String response = ""; Boolean success = false; try { @@ -389,7 +403,7 @@ // 鍒涙柊涓�涓叆搴撳伐浣滄。 TaskWrk taskWrk = taskWrkService.selectByTaskNo(result.getTaskNo()); if (Cools.isEmpty(taskWrk)) { - taskWrk = createTask1(result, BoxNo); + taskWrk = createTask1(result, BoxNo,staProtocol.getSiteId()); if (Cools.isEmpty(taskWrk)) { log.error("搴撲綅寮傚父锛屽簱浣嶅彿锛�={}", taskWrk.getOriginTargetPoint()); } else { @@ -429,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); @@ -436,12 +455,186 @@ } } 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); MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); } } + } catch (Exception e) { + log.error("璇锋眰鍏ュ簱璋冪敤鎺ュ彛澶辫触"); + log.error("寮傚父淇℃伅鎵撳嵃锛�" + e); + try { + BasDevp basDevp = basDevpService.selectById(inSta.getStaNo()); + if (Cools.isEmpty(basDevp)) { + log.error("绔欑偣鍙峰紓甯�" + inSta.getStaNo()); + } else if (basDevp.getStaErr() != 0) { + basDevp.setStaErr(2); + basDevpService.updateById(basDevp); + } + } catch (Exception e1) { + // 閫�鍥� + log.error("鎵爜妫�娴嬬▼搴忓紓甯�" + inSta.getStaNo() + "寮傚父淇℃伅" + e1); + } + } finally { + apiLogService.save("wms璇锋眰鍏ュ簱璐т綅鎺ュ彛" + , wmsUrl + inboundTaskApplyPath + , null + , "127.0.0.1" + , JSON.toJSONString(storageEscalationParam) + , response + , success + ); + } + log.info("鍏ュ簱璇锋眰鍙傛暟=" + JSON.toJSONString(BoxNo)); + log.info("鍏ュ簱璇锋眰杩斿洖鍙傛暟=" + JSON.toJSONString(response)); + } + } + } + } catch (Exception e) { + log.error("generateStoreWrkFile e", e); + TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); + } + } + + //鎷f枡鍥炲簱 + public synchronized void PickingAndReturningToTheWarehouse() throws IOException, InterruptedException { + try { + // 鏍规嵁杈撻�佺嚎plc閬嶅巻 + for (DevpSlave devp : slaveProperties.getDevp()) { + // 閬嶅巻鍏ュ簱鍙� + for (DevpSlave.Sta inSta : devp.getPickSta()) { + StorageEscalationParam storageEscalationParam = new StorageEscalationParam(); + // 鑾峰彇鍏ュ簱绔欎俊鎭� + DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); + StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo()); + if (staProtocol == null) { + continue; + } else { + staProtocol = staProtocol.clone(); + } + Short workNo = staProtocol.getWorkNo(); + //led + LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed()); + + // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢 + if (staProtocol.isAutoing() && staProtocol.isLoading() + && staProtocol.isInEnable() + && staProtocol.isPakMk()) { + // 鑾峰彇鏉$爜鎵弿浠俊鎭� + String BoxNo = ""; + //绔欑偣鎷f枡鍥炲簱浠诲姟鏄細鏈変竴鏉� + TaskWrk taskWrkk =taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("start_point",staProtocol.getSiteId())); + if (!Cools.isEmpty(taskWrkk)) { + continue; + } + if(!staProtocol.isEmptyMk()&&staProtocol.getWorkNo()<9990){ + + TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("wrk_no", workNo)); + + if (!Cools.isEmpty(taskWrk1)) { + BoxNo = taskWrk1.getBarcode(); + } else { + TaskWrkLog taskWrkLog = taskWrkLogService.selectOne(new EntityWrapper<TaskWrkLog>().eq("wrk_no", workNo).orderBy("modi_time", false)); + if (taskWrkLog != null) { + BoxNo = taskWrkLog.getBarcode(); + } + } + } + log.info("缁勬墭鍏ュ簱={}", storageEscalationParam); + storageEscalationParam.setBoxNo(BoxNo); + //鏄惁婊℃澘 1婊℃澘 0绌烘澘 + storageEscalationParam.setStaType(staProtocol.isEmptyMk() ? 0 : 1); + //搴撲綅绫诲瀷 1楂樺簱浣� 0浣庡簱浣� + storageEscalationParam.setLocType(staProtocol.isHigh() ? 1 : 0); + storageEscalationParam.setTerminalNo(staProtocol.getSiteId()); + String response = ""; + Boolean success = false; + try { + response = new HttpHandler.Builder() + .setUri(wmsUrl) + .setPath(inboundTaskApplyPath) + .setJson(JSON.toJSONString(storageEscalationParam)) + .build() + .doPost(); + JSONObject jsonObject = JSON.parseObject(response); + + if (!Cools.isEmpty(response) && !Cools.isEmpty(jsonObject.get("ReturnStatus")) && jsonObject.get("ReturnStatus").equals(0) && !Cools.isEmpty(jsonObject.get("Result").toString())) { + Result result = JSON.parseObject(jsonObject.get("Result").toString(), Result.class); + + // 鍒涙柊涓�涓叆搴撳伐浣滄。 + TaskWrk taskWrk = taskWrkService.selectByTaskNo(result.getTaskNo()); + if (Cools.isEmpty(taskWrk)) { + taskWrk = createTask1(result, BoxNo,staProtocol.getSiteId()); + if (Cools.isEmpty(taskWrk)) { + log.error("搴撲綅寮傚父锛屽簱浣嶅彿锛�={}", taskWrk.getOriginTargetPoint()); + } else { + taskWrkService.insert(taskWrk); + StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>() + .eq("crn_no", taskWrk.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId())); + staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue()); + staProtocol.setStaNo(staDesc.getCrnStn().shortValue()); + MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); + HashMap<String, Object> hashMap = new HashMap<>(); + hashMap.put("TaskNo", taskWrk.getTaskNo()); + try { + //寮�濮嬩笂鎶�,浠诲姟寮�濮嬫椂锛學CS鍥炶皟WMS + response = new HttpHandler.Builder() + .setUri(wmsUrl) + .setPath(taskStatusFeedbackPath) + .setJson(JSON.toJSONString(hashMap)) + .build() + .doPost(); + JSONObject jsonObject1 = JSON.parseObject(response); + Boolean bool = false; + if (jsonObject1.get("ReturnStatus").equals(0)) { + taskWrk.setStatus(2);//娲惧彂浠诲姟 + bool = true; + taskWrkService.updateById(taskWrk); + } + apiLogService.save("wcs寮�濮嬪叆搴撲换鍔′笂鎶ms" + , wmsUrl + TaskExecCallback + , null + , "127.0.0.1" + , JSON.toJSONString(hashMap) + , response + , bool + ); + } catch (Exception e) { + + } + } + } 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); + MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); + } + + } 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); + MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); + } + } catch (Exception e) { log.error("璇锋眰鍏ュ簱璋冪敤鎺ュ彛澶辫触"); log.error("寮傚父淇℃伅鎵撳嵃锛�" + e); @@ -782,7 +975,7 @@ staProtocol.setStaNo(staDesc.getStnNo().shortValue()); boolean offer = false; try { - offer = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol)); + offer = MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol)); } catch (Exception e) { log.error("涓嬪彂杈撻�佺嚎浠诲姟澶辫触锛氬紓甯�:" + e); log.error("涓嬪彂杈撻�佺嚎浠诲姟澶辫触锛氬紓甯�:offer:" + offer); @@ -968,7 +1161,7 @@ LocMast locMast = locMastService.selectByLocNo(taskWrk.getStartPoint()); //鍒ゆ柇鍏跺簱浣嶆槸鍚︿负娣卞簱浣嶏紝濡傛灉涓烘繁搴撲綅鎵惧叾娴呭簱浣嶆槸閮芥湁璐� - if (locMast.getRow1() == 1 || locMast.getRow1() == 5) { + if (locMast.getRow1() == 5) { LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>() .eq("row1", (locMast.getRow1() + 1)) .eq("bay1", locMast.getBay1()) @@ -977,9 +1170,10 @@ log.info(locMast.getLocNo() + "鍑烘繁搴撲綅锛屾祬搴撲綅鏈夎揣"); continue; } - } else if (locMast.getRow1() == 4 || locMast.getRow1() == 8) { + } + if (locMast.getRow1() == 8) { 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)) { @@ -1013,11 +1207,11 @@ if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) { break; } - int storeCount = basDevpService.getStoreCount(); - if (storeCount >= maxCount) { - log.error("杈撻�佺嚎鏆傚瓨鏁拌揪鍒颁笂闄恵}", storeCount); - break; - } +// int storeCount = basDevpService.getStoreCount(); +// if (storeCount >= maxCount) { +// log.error("杈撻�佺嚎鏆傚瓨鏁拌揪鍒颁笂闄恵}", storeCount); +// break; +// } // 宸茬粡瀛樺湪鍚婅溅鎵ц浠诲姟鏃讹紝鍒欒繃婊� @@ -1627,9 +1821,8 @@ return response; } - private TaskWrk createTask1(Result result, String barcode) { + private TaskWrk createTask1(Result result, String barcode,Integer staNo) { String locNo = Utils.Fusion(result.getRow(), result.getFloor(), result.getColumn()); - Date now = new Date(); TaskWrk taskWrk = new TaskWrk(); @@ -1638,18 +1831,13 @@ taskWrk.setWrkNo(workNo1); taskWrk.setStatus(TaskStatusType.RECEIVE.id);//浠诲姟鐘舵�侊細鎺ユ敹 taskWrk.setCreateTime(now); - taskWrk.setIoType(1);//浠诲姟绫诲瀷 + taskWrk.setIoType(1);//浠诲姟绫诲瀷 鍏ュ簱 taskWrk.setIoPri(13);//浼樺厛绾� taskWrk.setBarcode(barcode);//鏉$爜 - LocMast locMast = locMastService.selectByLocNo(locNo); - taskWrk.setCrnNo(locMast.getCrnNo()); taskWrk.setTargetPoint(locNo); - taskWrk.setStartPoint("116"); - if (result.getAlley().equals("1")) { - taskWrk.setCrnNo(1); - } else { - taskWrk.setCrnNo(2); - } + taskWrk.setStartPoint(staNo+""); + taskWrk.setCrnNo(Integer.valueOf(result.getAlley()));//鍫嗗灈鏈哄彿 + if (taskWrk.getIoType() == 1) { taskWrk.setWrkSts(2); if (!Cools.isEmpty(taskWrk.getTargetPoint())) { @@ -1701,4 +1889,43 @@ return taskWrk; } + //----------------------------------------------------------鐢佃鏈烘樉绀哄鐞�---------------------------------------- + /** + * 鍏朵粬 ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅 + */ + public synchronized void ledReset(Integer mark) { + +// log.info(""+mark+" - 0"+" - 寮�濮嬫墽琛�:鍏朵粬 ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅"); + for (LedSlave led : slaveProperties.getLed()) { + + // 鑾峰彇杈撻�佺嚎plc绾跨▼ + DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, led.getDevpPlcId()); + // 鍛戒护闆嗗悎 + boolean reset = true; + for (Integer staNo : led.getStaArr()) { + // 鑾峰彇鍙夎溅绔欑偣 + StaProtocol staProtocol = devpThread.getStation().get(staNo); + if (staProtocol == null) { + continue; + } + if (staProtocol.getWorkNo() != 0 && staProtocol.isLoading()) { + reset = false; + break; + } + } + // 鑾峰彇led绾跨▼ + LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, led.getId()); + // led鏄剧ず榛樿鍐呭 + if (reset && !ledThread.isLedMk()) { + ledThread.setLedMk(true); + if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(4, new ArrayList<>()))) { + log.error(""+mark+" - 1"+" - {}鍙稬ED鍛戒护涓嬪彂澶辫触锛侊紒锛乕ip锛歿}] [port锛歿}]", led.getId(), led.getIp(), led.getPort()); + } else { + + } + } + } +// log.info(""+mark+" - 0"+" - 鎵ц瀹屾垚锛氬叾浠� ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅"); + } + } -- Gitblit v1.9.1