From f6e955d57bf5e885afde54a8c6eefe80bc1bec26 Mon Sep 17 00:00:00 2001 From: zjj <3272660260@qq.com> Date: 星期四, 30 十一月 2023 17:00:06 +0800 Subject: [PATCH] #出入库任务下发 --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 284 +++++++++++++++++++++++++++++++++++++++++--------------- 1 files changed, 207 insertions(+), 77 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 a52189a..c66b089 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -4,7 +4,10 @@ import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; +import com.core.common.R; import com.core.exception.CoolException; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.zy.asrs.domain.enums.TaskStatusType; import com.zy.asrs.entity.*; import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam; import com.zy.asrs.mapper.*; @@ -22,6 +25,7 @@ import com.zy.core.model.CrnSlave; import com.zy.core.model.DevpSlave; import com.zy.core.model.Task; +import com.zy.core.model.command.CommandPackage; import com.zy.core.model.command.CrnCommand; import com.zy.core.model.protocol.CrnProtocol; import com.zy.core.model.protocol.StaProtocol; @@ -38,8 +42,11 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import java.io.IOException; import java.util.Date; +import java.util.HashMap; import java.util.List; +import java.util.Map; /** * 绔嬩綋浠撳簱WCS绯荤粺涓绘祦绋嬩笟鍔� @@ -74,6 +81,11 @@ private ConfigService configService; @Autowired private StaDescMapper staDescMapper; + @Autowired + private CommandInfoService commandInfoService; + + @Autowired + private OpenServiceImpl openServiceImpl; @Value("${wms.url}") private String wmsUrl; @@ -143,6 +155,7 @@ TaskWrk taskWrk = taskWrkMapper.selectByWrkNo(Integer.valueOf(workNo)); if (taskWrk != null) { taskWrk.setMemo(errMsg);//灏嗛敊璇爜瀛樺叆澶囨敞瀛楁杩涜灞曠ず + taskWrkMapper.updateById(taskWrk); } continue; } @@ -153,7 +166,29 @@ } String barcode = barcodeThread.getBarcode(); if(!Cools.isEmpty(barcode)) { - +// ToWmsDTO toWmsDTO = new ToWmsDTO(); +// Map<String, Object> map = new HashMap<>(); +// map.put("x-api-key","7a15b5db-29b6-552c-8cff-0cfec3756da2"); +// List<Integer> list = openServiceImpl.getInEnableRoadway(); +// +// //TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo()); +// toWmsDTO.setWarehouseId("1688469798893297665"); +// toWmsDTO.setContainerCode(param.getContainerCode()); +// toWmsDTO.setApplyType("TUNNEL"); +// toWmsDTO.setWharfSource(null); +// toWmsDTO.setCanInboundTunnels(list); +// String response = null; +// try { +// response = new HttpHandler.Builder() +// .setHeaders(map) +// .setUri(wmsUrl) +// .setPath("wcsManager/wcsInterface/inboundTaskApply") +// .setJson(JSON.toJSONString(toWmsDTO)) +// .build() +// .doPost(); +// }catch (Exception e){ +// +// } } } @@ -202,31 +237,26 @@ && crnProtocol.forkPosType == CrnForkPosType.HOME) { // 鍛戒护涓嬪彂鍖� -------------------------------------------------------------------------- - // 涓嬪彂绔欑偣淇℃伅 - staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue()); - String targetPoint = taskWrk.getTargetPoint(); - int i = Integer.parseInt(targetPoint); - staProtocol.setStaNo((short)i); - if (!CommandUtils.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol))) { - continue; + //鍙栧嚭杈撻�佺嚎鍛戒护 + List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskWrk.getTaskNo()); + if (commandInfos.isEmpty()) { + continue;//鍛戒护绌� } - // 鏇存柊宸ヤ綔妗g姸鎬佷负14 - taskWrk.setWrkSts(14); - if (taskWrkMapper.updateById(taskWrk) != 0) { - // 澶嶄綅鍫嗗灈鏈� - crnThread.setResetFlag(true); - - //鏇存柊搴撲綅鐘舵�� - LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint()); - locMast.setLocSts("O");//O.绌哄簱浣� - locMast.setBarcode("");//鎵樼洏鐮� - locMast.setModiTime(new Date()); - locMast.setModiUser(9999L); - locMastService.updateById(locMast); - } else { - log.error("鏇存柊宸ヤ綔妗g殑宸ヤ綔鐘舵�佷负14澶辫触锛侊紒锛� [宸ヤ綔鍙�:{}]", taskWrk.getWrkNo()); +// CommandPackage commandPackage = JSON.parseObject(commandInfo.getCommand(), CommandPackage.class);//鍙栧嚭鍛戒护鎶ユ枃 +// CrnCommand crnCommand = JSON.parseObject(commandPackage.getCommand().toString(), CrnCommand.class); + Integer commandStep = taskWrk.getCommandStep(); + CommandInfo commandInfo = commandInfos.get(commandStep); + CommandPackage commandPackage = JSON.parseObject(commandInfo.getCommand(), CommandPackage.class);//鍙栧嚭鍛戒护鎶ユ枃 + //StaProtocol staProtocol1 = JSON.parseObject(commandInfo.getCommand(), StaProtocol.class); + StaProtocol staProtocol1 = JSON.parseObject(commandPackage.getCommand().toString(), StaProtocol.class); + if (!MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol1))) { + log.error("杈撻�佺嚎鍛戒护涓嬫柟澶辫触锛侊紒锛� [宸ヤ綔鍙�:{}]", taskWrk.getWrkNo()); + continue;//鍛戒护涓嬪彂澶辫触 } + + // 澶嶄綅鍫嗗灈鏈� + crnThread.setResetFlag(true); } } @@ -240,7 +270,7 @@ /** * 鍏ュ嚭搴� ===>> 鍫嗗灈鏈哄叆鍑哄簱浣滀笟涓嬪彂 */ - public synchronized void crnIoExecute(){ + public synchronized void crnIoExecute() throws IOException { for (CrnSlave crn : slaveProperties.getCrn()) { // 鑾峰彇鍫嗗灈鏈轰俊鎭� CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId()); @@ -285,7 +315,7 @@ /** * 鍏ュ簱 ===>> 鍫嗗灈鏈虹珯鍒板簱浣� */ - public void crnStnToLoc(CrnSlave slave, CrnProtocol crnProtocol){ + public void crnStnToLoc(CrnSlave slave, CrnProtocol crnProtocol) throws IOException { for (CrnSlave.CrnStn crnStn : slave.getCrnInStn()) { List<StaDesc> staDescs = staDescMapper.selectList(new EntityWrapper<StaDesc>().eq("crn_no", slave.getId()).eq("crn_stn", crnStn.getStaNo())); for (StaDesc staDesc : staDescs) { @@ -327,20 +357,17 @@ continue; } - // 鍛戒护涓嬪彂鍖� -------------------------------------------------------------------------- - CrnCommand crnCommand = new CrnCommand(); - crnCommand.setCrnNo(slave.getId()); // 鍫嗗灈鏈虹紪鍙� - crnCommand.setTaskNo(taskWrk.getWrkNo().shortValue()); // 宸ヤ綔鍙� - crnCommand.setAckFinish((short) 0); // 浠诲姟瀹屾垚纭浣� - crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡: 搴撲綅绉昏浆 - crnCommand.setSourcePosX(crnStn.getBay().shortValue()); // 婧愬簱浣嶅垪 - crnCommand.setSourcePosY(crnStn.getLev().shortValue()); // 婧愬簱浣嶅眰 - crnCommand.setSourcePosZ(crnStn.getRow().shortValue()); // 婧愬簱浣嶆帓 - crnCommand.setDestinationPosX(Utils.getBayShort(taskWrk.getTargetPoint())); // 鐩爣搴撲綅鍒� - crnCommand.setDestinationPosY(Utils.getLevShort(taskWrk.getTargetPoint())); // 鐩爣搴撲綅灞� - crnCommand.setDestinationPosZ(Utils.getRowShort(taskWrk.getTargetPoint())); // 鐩爣搴撲綅鎺� - crnCommand.setCommand((short)1); - if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) { + //鍙栧嚭鍛戒护 + List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskWrk.getTaskNo()); + Integer commandStep = taskWrk.getCommandStep(); + if (commandInfos.isEmpty()) { + continue;//鍛戒护绌� + } + CommandInfo commandInfo = commandInfos.get(commandStep); + CommandPackage commandPackage = JSON.parseObject(commandInfo.getCommand(), CommandPackage.class);//鍙栧嚭鍛戒护鎶ユ枃 + CrnCommand crnCommand = JSON.parseObject(commandPackage.getCommand().toString(), CrnCommand.class); + + if (!MessageQueue.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) { log.error("鍫嗗灈鏈哄懡浠や笅鍙戝け璐ワ紝鍫嗗灈鏈哄彿={}锛屼换鍔℃暟鎹�={}", taskWrk.getCrnNo(), JSON.toJSON(crnCommand)); } else { // 淇敼宸ヤ綔妗g姸鎬� 2.璁惧涓婅蛋 => 3.鍚婅溅鍏ュ簱涓� @@ -351,6 +378,31 @@ log.error("淇敼宸ヤ綔妗g姸鎬� 2.璁惧涓婅蛋 => 3.鍚婅溅鍏ュ簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", taskWrk.getWrkNo()); } } + +// // 鍛戒护涓嬪彂鍖� -------------------------------------------------------------------------- +// CrnCommand crnCommand = new CrnCommand(); +// crnCommand.setCrnNo(slave.getId()); // 鍫嗗灈鏈虹紪鍙� +// crnCommand.setTaskNo(taskWrk.getWrkNo().shortValue()); // 宸ヤ綔鍙� +// crnCommand.setAckFinish((short) 0); // 浠诲姟瀹屾垚纭浣� +// crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡: 搴撲綅绉昏浆 +// crnCommand.setSourcePosX(crnStn.getBay().shortValue()); // 婧愬簱浣嶅垪 +// crnCommand.setSourcePosY(crnStn.getLev().shortValue()); // 婧愬簱浣嶅眰 +// crnCommand.setSourcePosZ(crnStn.getRow().shortValue()); // 婧愬簱浣嶆帓 +// crnCommand.setDestinationPosX(Utils.getBayShort(taskWrk.getTargetPoint())); // 鐩爣搴撲綅鍒� +// crnCommand.setDestinationPosY(Utils.getLevShort(taskWrk.getTargetPoint())); // 鐩爣搴撲綅灞� +// crnCommand.setDestinationPosZ(Utils.getRowShort(taskWrk.getTargetPoint())); // 鐩爣搴撲綅鎺� +// crnCommand.setCommand((short)1); +// if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) { +// log.error("鍫嗗灈鏈哄懡浠や笅鍙戝け璐ワ紝鍫嗗灈鏈哄彿={}锛屼换鍔℃暟鎹�={}", taskWrk.getCrnNo(), JSON.toJSON(crnCommand)); +// } else { +// // 淇敼宸ヤ綔妗g姸鎬� 2.璁惧涓婅蛋 => 3.鍚婅溅鍏ュ簱涓� +// Date now = new Date(); +// taskWrk.setWrkSts(3); +// taskWrk.setModiTime(now); +// if (taskWrkMapper.updateById(taskWrk) == 0) { +// log.error("淇敼宸ヤ綔妗g姸鎬� 2.璁惧涓婅蛋 => 3.鍚婅溅鍏ュ簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", taskWrk.getWrkNo()); +// } +// } } return; @@ -446,20 +498,17 @@ } } - // 1.鍫嗗灈鏈哄紑濮嬬Щ鍔� - CrnCommand crnCommand = new CrnCommand(); - crnCommand.setCrnNo(slave.getId()); // 鍫嗗灈鏈虹紪鍙� - crnCommand.setTaskNo(taskWrk.getWrkNo().shortValue()); // 宸ヤ綔鍙� - crnCommand.setAckFinish((short) 0); // 浠诲姟瀹屾垚纭浣� - crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡: 搴撲綅绉昏浆 - crnCommand.setSourcePosX(Utils.getBayShort(taskWrk.getStartPoint())); // 婧愬簱浣嶆帓 - crnCommand.setSourcePosY(Utils.getLevShort(taskWrk.getStartPoint())); // 婧愬簱浣嶅垪 - crnCommand.setSourcePosZ(Utils.getRowShort(taskWrk.getStartPoint())); // 婧愬簱浣嶅眰 - crnCommand.setDestinationPosX(crnStn.getBay().shortValue()); // 鐩爣搴撲綅鎺� - crnCommand.setDestinationPosY(crnStn.getLev().shortValue()); // 鐩爣搴撲綅鍒� - crnCommand.setDestinationPosZ(crnStn.getRow().shortValue()); // 鐩爣搴撲綅灞� - crnCommand.setCommand((short)1); - if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) { + //鍙栧嚭鍛戒护 + List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskWrk.getTaskNo()); + Integer commandStep = taskWrk.getCommandStep(); + if (commandInfos.isEmpty()) { + continue;//鍛戒护绌� + } + CommandInfo commandInfo = commandInfos.get(commandStep); + CommandPackage commandPackage = JSON.parseObject(commandInfo.getCommand(), CommandPackage.class);//鍙栧嚭鍛戒护鎶ユ枃 + CrnCommand crnCommand = JSON.parseObject(commandPackage.getCommand().toString(), CrnCommand.class); + + if (!MessageQueue.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) { log.error("鍫嗗灈鏈哄懡浠や笅鍙戝け璐ワ紝鍫嗗灈鏈哄彿={}锛屼换鍔℃暟鎹�={}", taskWrk.getCrnNo(), JSON.toJSON(crnCommand)); } else { // 淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 12.鍚婅溅鍑哄簱涓� @@ -549,37 +598,68 @@ if (crnProtocol == null) { continue; } // 鐘舵�侊細绛夊緟纭 骞朵笖 浠诲姟瀹屾垚浣� = 1 if (crnProtocol.getTaskFinish() == 0 && crnProtocol.statusType == CrnStatusType.HANDLING_COMPLETED && crnProtocol.getTaskNo() != 0) { - // 鑾峰彇鍏ュ簱寰呯‘璁ゅ伐浣滄。 - TaskWrk taskWrk = taskWrkMapper.selectCrnNoWorking(crn.getId(),crnProtocol.getTaskNo().intValue()); - if (Cools.isEmpty(taskWrk)) { - log.error("鍫嗗灈鏈哄浜庣瓑寰呯‘璁や笖浠诲姟瀹屾垚鐘舵�侊紝浣嗘湭鎵惧埌宸ヤ綔妗c�傚爢鍨涙満鍙�={}锛屽伐浣滃彿={}", crn.getId(), crnProtocol.getTaskNo()); + + //鑾峰彇鎸囦护ID + Integer commandId = crnProtocol.getCommandId(); + CommandInfo commandInfo = commandInfoService.selectById(commandId); + if (commandInfo == null) { + //鎸囦护涓嶅瓨鍦� continue; } - // 鍏ュ簱 + 搴撲綅杞Щ ==> 4.鍏ュ簱瀹屾垚 - if ((taskWrk.getWrkSts() == 3 && taskWrk.getIoType() == 1) || (taskWrk.getWrkSts() == 12 && taskWrk.getIoType() == 3)) { - taskWrk.setWrkSts(4); - } else { - continue; - } - Date now = new Date(); - taskWrk.setModiTime(now); - Integer integerTaskWrk = taskWrkMapper.updateById(taskWrk); - // 淇敼鎴愬姛鍚庡浣嶅爢鍨涙満 - if (integerTaskWrk > 0) { + + commandInfo.setCommandStatus(CommandStatusType.COMPLETE.id);//鎸囦护瀹屾垚 + commandInfo.setCompleteTime(new Date());//鎸囦护瀹屾垚鏃堕棿 + if (commandInfoService.updateById(commandInfo)) {//淇敼鎴愬姛鍚庡浣嶅爢鍨涙満 // 鍫嗗灈鏈哄浣� crnThread.setResetFlag(true); - - //鏇存柊搴撲綅鐘舵�� - LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint()); - locMast.setLocSts("F");//F.鍦ㄥ簱 - locMast.setBarcode(taskWrk.getBarcode());//鎵樼洏鐮� - locMast.setModiTime(now); - locMast.setModiUser(9999L); - locMastService.updateById(locMast); } } } } + +// /** +// * 鎵ц瀵瑰伐浣滄。鐨勫畬鎴愭搷浣� +// */ +// @Async +// public void storeFinished() { +// for (CrnSlave crn : slaveProperties.getCrn()) { +// // 鑾峰彇鍫嗗灈鏈轰俊鎭� +// CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId()); +// CrnProtocol crnProtocol = crnThread.getCrnProtocol(); +// if (crnProtocol == null) { continue; } +// // 鐘舵�侊細绛夊緟纭 骞朵笖 浠诲姟瀹屾垚浣� = 1 +// if (crnProtocol.getTaskFinish() == 0 && crnProtocol.statusType == CrnStatusType.HANDLING_COMPLETED && crnProtocol.getTaskNo() != 0) { +// // 鑾峰彇鍏ュ簱寰呯‘璁ゅ伐浣滄。 +// TaskWrk taskWrk = taskWrkMapper.selectCrnNoWorking(crn.getId(),crnProtocol.getTaskNo().intValue()); +// if (Cools.isEmpty(taskWrk)) { +// log.error("鍫嗗灈鏈哄浜庣瓑寰呯‘璁や笖浠诲姟瀹屾垚鐘舵�侊紝浣嗘湭鎵惧埌宸ヤ綔妗c�傚爢鍨涙満鍙�={}锛屽伐浣滃彿={}", crn.getId(), crnProtocol.getTaskNo()); +// continue; +// } +// // 鍏ュ簱 + 搴撲綅杞Щ ==> 4.鍏ュ簱瀹屾垚 +// if ((taskWrk.getWrkSts() == 3 && taskWrk.getIoType() == 1) || (taskWrk.getWrkSts() == 12 && taskWrk.getIoType() == 3)) { +// taskWrk.setWrkSts(4); +// } else { +// continue; +// } +// Date now = new Date(); +// taskWrk.setModiTime(now); +// Integer integerTaskWrk = taskWrkMapper.updateById(taskWrk); +// // 淇敼鎴愬姛鍚庡浣嶅爢鍨涙満 +// if (integerTaskWrk > 0) { +// // 鍫嗗灈鏈哄浣� +// crnThread.setResetFlag(true); +// +// //鏇存柊搴撲綅鐘舵�� +// LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint()); +// locMast.setLocSts("F");//F.鍦ㄥ簱 +// locMast.setBarcode(taskWrk.getBarcode());//鎵樼洏鐮� +// locMast.setModiTime(now); +// locMast.setModiUser(9999L); +// locMastService.updateById(locMast); +// } +// } +// } +// } /** * 鍫嗗灈鏈哄紓甯镐俊鎭褰� @@ -715,7 +795,57 @@ try { taskWrkService.distribute(taskWrk.getTaskNo(), 9527L); } catch (CoolException e) { - e.printStackTrace(); + log.info(e.getMessage()); + } + } + } + + //鑷姩瀹屾垚浠诲姟 + public synchronized void autoCompleteTask() { + List<TaskWrk> taskWrks = taskWrkMapper.selectWorkingTask(); + for (TaskWrk taskWrk : taskWrks) { + //鑾峰彇鍛戒护闆嗗悎 + List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskWrk.getTaskNo()); + if (taskWrk.getCommandStep() != commandInfos.size()) { + continue;//褰撳墠姝ュ簭娌℃湁鍒拌揪鏈�鍚庝竴鏉″懡浠� + } + + //鍒ゆ柇鏈鍛戒护鏄惁鎵ц瀹屾垚 + CommandInfo commandInfo = commandInfos.get(commandInfos.size() - 1); + if (commandInfo.getCommandStatus() != CommandStatusType.COMPLETE.id) { + continue;//鎸囦护鏈畬鎴� + } + + Date now = new Date(); + //鎸囦护宸插畬鎴愶紝鏇存柊浠诲姟 + if (taskWrk.getIoType() == 1) { + //鍏ュ簱浠诲姟 + taskWrk.setWrkSts(4);//3.鍚婅溅鍏ュ簱涓� => 4.鍏ュ簱瀹屾垚 + taskWrk.setStatus(TaskStatusType.COMPLETE.id); + taskWrk.setModiTime(now); + taskWrkService.updateById(taskWrk); + + //鏇存柊搴撲綅鐘舵�� + LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint()); + locMast.setLocSts("F");//F.鍦ㄥ簱 + locMast.setBarcode(taskWrk.getBarcode());//鎵樼洏鐮� + locMast.setModiTime(now); + locMast.setModiUser(9999L); + locMastService.updateById(locMast); + } else if (taskWrk.getIoType() == 2) { + //鍑哄簱浠诲姟 + taskWrk.setWrkSts(14);//12.鍚婅溅鍑哄簱涓� => 14.鍑哄簱瀹屾垚 + taskWrk.setStatus(TaskStatusType.COMPLETE.id); + taskWrk.setModiTime(now); + taskWrkService.updateById(taskWrk); + + //鏇存柊搴撲綅鐘舵�� + LocMast locMast = locMastService.selectByLocNo(taskWrk.getStartPoint()); + locMast.setLocSts("O");//O.绌哄簱浣� + locMast.setBarcode("");//鎵樼洏鐮� + locMast.setModiTime(now); + locMast.setModiUser(9999L); + locMastService.updateById(locMast); } } } -- Gitblit v1.9.1