From 7a6d4580cb6b69614a1e628d960279c090bbc60a Mon Sep 17 00:00:00 2001 From: zhoushihao <zsh19950802@163.com> Date: 星期四, 04 七月 2024 16:59:30 +0800 Subject: [PATCH] 大理片协议读取更新 --- hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java | 147 +++++++++++++++++++++++++++++++++--------------- 1 files changed, 101 insertions(+), 46 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java index 28c7f1f..4d4ec63 100644 --- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java +++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java @@ -72,25 +72,34 @@ @Value("${mes.slotWidth}") private Integer slotWidth; - @Value("${mes.carMaxSize}") - private Integer carMaxSize; + @Value("${mes.inCarMaxSize}") + private Integer inCarMaxSize; + + @Value("${mes.outCarMaxSize}") + private Integer outCarMaxSize; @Value("${mes.galssGap}") private Integer galssGap; - // @Scheduled(fixedDelay = 5000) + @Scheduled(fixedDelay = 300) public void plcToHomeEdgScan() { PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; String d01Id = plcParameterObject.getPlcParameter("D01ID").getValue(); - String d02Id = plcParameterObject.getPlcParameter("D02ID").getValue(); + String d04Id = plcParameterObject.getPlcParameter("D04ID").getValue(); + //D02id鍒ゆ柇鏄惁涓虹┖ 纭鏄惁绌洪棽 鍏佽杩涚墖 + String d02State = plcParameterObject.getPlcParameter("D02ID").getValue(); String d03State = plcParameterObject.getPlcParameter("D03State").getValue(); String d05State = plcParameterObject.getPlcParameter("D05State").getValue(); - String mesD03Address = plcParameterObject.getPlcParameter("MESToD03").getAddress(); - String mesD05Address = plcParameterObject.getPlcParameter("MESToD05").getAddress(); + String mesD01Address = plcParameterObject.getPlcParameter("MESToD01").getAddress(); + String mesD04Address = plcParameterObject.getPlcParameter("MESToD04").getAddress(); + String d01ToMES = plcParameterObject.getPlcParameter("D01ToMES").getValue(); + if (!REQUEST_WORD.equals(d01ToMES)) { + log.info("璇锋眰瀛椾负{}锛岀粨鏉熸湰娆℃壂鎻忚繘鍗ц浆绔嬩换鍔�", d01ToMES); + return; + } - - log.info("1銆佽幏鍙杁01Id鎵弿ID涓猴細{};鑾峰彇d02Id鎵弿ID涓猴細{};", d01Id, d02Id); - if (StringUtils.isBlank(d01Id) && StringUtils.isBlank(d02Id)) { + log.info("1銆佽幏鍙杁01Id鎵弿ID涓猴細{};鑾峰彇d04Id鎵弿ID涓猴細{};", d01Id, d04Id); + if (StringUtils.isBlank(d01Id) && StringUtils.isBlank(d04Id)) { log.info("涓ゆ潯绾挎湭鏀跺埌杩涚墖浠诲姟锛岀粨鏉熸湰娆℃壂鎻忚繘鍗ц浆绔嬩换鍔�"); return; } @@ -101,11 +110,11 @@ // Boolean flag01 = Boolean.FALSE; // Boolean flag04 = Boolean.FALSE; //鎸夌収绾胯矾鍙婄幓鐠僫d鑾峰彇鐩搁偦涓ゅ潡鐜荤拑 鍗ц浆绔嬩笂鐨勭幓鐠� - if (StringUtils.isNotBlank(d01Id) && !REQUEST_WORD.equals(d03State)) { - judgeGlassTypeStatus(d01Id, Const.A09_OUT_TARGET_POSITION, mesD03Address); + if (StringUtils.isNotBlank(d01Id) && (StringUtils.isBlank(d02State) || !REQUEST_WORD.equals(d03State))) { + judgeGlassTypeStatus(d01Id, Const.A09_OUT_TARGET_POSITION, mesD01Address); } - if (StringUtils.isNotBlank(d02Id) && !REQUEST_WORD.equals(d05State)) { - judgeGlassTypeStatus(d02Id, Const.A10_OUT_TARGET_POSITION, mesD05Address); + if (StringUtils.isNotBlank(d04Id) && !REQUEST_WORD.equals(d05State)) { + judgeGlassTypeStatus(d04Id, Const.A10_OUT_TARGET_POSITION, mesD04Address); } log.info("缁撴潫鎵爜浠诲姟"); // if (flag01 && flag04) { @@ -122,17 +131,26 @@ // } } - @Scheduled(fixedDelay = 5000) + @Scheduled(fixedDelay = 300) public void plcToHomeEdgFreeCarTask() { PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; String e01Status = plcParameterObject.getPlcParameter("E01State").getValue(); + String d03ToMES = plcParameterObject.getPlcParameter("D03ToMES").getValue(); + String d05ToMES = plcParameterObject.getPlcParameter("D05ToMES").getValue(); + log.info("鎵ц绌鸿溅閫佺墖浠诲姟锛岃幏鍙栧埌鐨勫ぇ杞︾姸鎬佷负{}锛屽崸杞珛鐘舵�佸垎鍒负d03:{}锛宒05:{}", e01Status, d03ToMES, d05ToMES); if (REQUEST_WORD.equals(e01Status)) { - log.info("杩涚墖澶ц溅闈炵┖闂�"); + log.info("杩涚墖澶ц溅闈炵┖闂诧紝缁撴潫閫佺墖浠诲姟"); return; } - List<BigStorageCageFeedTask> feedTaskList = bigStorageCageFeedTaskService.list(new LambdaQueryWrapper<BigStorageCageFeedTask>() + if (!REQUEST_WORD.equals(d03ToMES) && !REQUEST_WORD.equals(d05ToMES)) { + log.info("鍗ц浆绔嬫病鏈夐�佺墖璇锋眰锛岀粨鏉熼�佺墖浠诲姟"); + return; + } + LambdaQueryWrapper<BigStorageCageFeedTask> wrapper = new LambdaQueryWrapper<BigStorageCageFeedTask>() .eq(BigStorageCageFeedTask::getTaskType, Const.BIG_STORAGE_IN_RUN) - .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP)); + .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP); + //鑾峰彇鍙互鍚姩鍗ц浆绔嬬殑浠诲姟绾胯矾 + List<BigStorageCageFeedTask> feedTaskList = bigStorageCageFeedTaskService.list(wrapper); if (CollectionUtils.isNotEmpty(feedTaskList)) { if (feedTaskList.size() == 1) { computeTargetByLine(feedTaskList.get(0).getLine()); @@ -146,13 +164,13 @@ } } String d01Id = plcParameterObject.getPlcParameter("D01ID").getValue(); - String d02Id = plcParameterObject.getPlcParameter("D02ID").getValue(); - log.info("1銆佽幏鍙杁01Id鎵弿ID涓猴細{};鑾峰彇d02Id鎵弿ID涓猴細{};", d01Id, d02Id); + String d04Id = plcParameterObject.getPlcParameter("D04ID").getValue(); + log.info("1銆佽幏鍙杁01Id鎵弿ID涓猴細{};鑾峰彇d04Id鎵弿ID涓猴細{};", d01Id, d04Id); //涓ゆ潯绾块兘鏈夎繘鍗ц浆绔嬩换鍔★紝鐩存帴缁撴潫 - if (StringUtils.isNotBlank(d01Id) && StringUtils.isNotBlank(d02Id)) { - log.info("涓ゆ潯绾块兘瀛樺湪杩涚墖浠诲姟锛岀粨鏉熶换鍔�"); - return; - } +// if (StringUtils.isNotBlank(d01Id) && StringUtils.isNotBlank(d04Id)) { +// log.info("涓ゆ潯绾块兘瀛樺湪杩涚墖浠诲姟锛岀粨鏉熶换鍔�"); +// return; +// } //鑾峰彇涓ゆ潯绾垮崸杞珛鏄惁鏈夌幓鐠冿紝涓斾换鍔$姸鎬侀兘涓�2 List<Integer> lineList = bigStorageCageFeedTaskService.querySitToUpGlass(); if (CollectionUtils.isEmpty(lineList)) { @@ -160,30 +178,53 @@ return; } Integer lineFirst = lineList.get(0); - String lineGlassId = lineFirst.equals(Const.A09_OUT_TARGET_POSITION) ? d01Id : d02Id; + String lineGlassId = lineFirst.equals(Const.A09_OUT_TARGET_POSITION) ? d01Id : d04Id; //浠呮湁涓�鏉″厛绗﹀悎鍚姩鍚姩鏉′欢 if (lineList.size() == 1) { //濡傛灉杩涚墖璇锋眰浣嗙幓鐠冧负绌猴紝璁$畻浠诲姟琛ㄨ繘鐗囨牸瀛� 鍙戦�佽繘鐗囦换鍔� if (StringUtils.isEmpty(lineGlassId)) { computeTargetByLine(lineFirst); + } else { + //todo:璁$畻鎵弿鍒扮殑鐜荤拑鏄惁鍙互瀛樿繘鍗ц浆绔� + //鑾峰彇鍗ц浆绔嬪墿浣欏搴� + if (computeIsRun(lineFirst, lineGlassId)) { + computeTargetByLine(lineFirst); + } } return; } //涓ゆ潯鍏堝潎鍙墽琛岃繘鐗囦换鍔★紝鍒ゆ柇涓ゆ潯绾挎槸鍚﹁繘鐗囪姹傛槸鍚﹂兘涓虹┖ - if (StringUtils.isBlank(d01Id) && StringUtils.isBlank(d02Id)) { + if (StringUtils.isBlank(d01Id) && StringUtils.isBlank(d04Id)) { //姣旇緝鏈�鏃╀竴鐗囦换鍔$殑鐗堝浘id鍙婄増搴� 姹傚嚭鍗ц浆绔嬬殑绾胯矾 Integer line = getStartLine(); //璁$畻浠诲姟琛ㄨ繘鐗囨牸瀛� 鍙戦�佽繘鐗囦换鍔� computeTargetByLine(line); return; + } else if (StringUtils.isNotBlank(d01Id) && StringUtils.isNotBlank(d04Id)) { +// todo:涓や釜閮芥湁杩涚墖鐜荤拑 + if (computeIsRun(Const.A09_OUT_TARGET_POSITION, d01Id) && computeIsRun(Const.A10_OUT_TARGET_POSITION, d04Id)) { + //姣旇緝鏈�鏃╀竴鐗囦换鍔$殑鐗堝浘id鍙婄増搴� 姹傚嚭鍗ц浆绔嬬殑绾胯矾 + Integer line = getStartLine(); + //璁$畻浠诲姟琛ㄨ繘鐗囨牸瀛� 鍙戦�佽繘鐗囦换鍔� + computeTargetByLine(line); + } else if (computeIsRun(Const.A09_OUT_TARGET_POSITION, d01Id)) { + computeTargetByLine(Const.A09_OUT_TARGET_POSITION); + } else if (computeIsRun(Const.A10_OUT_TARGET_POSITION, d04Id)) { + computeTargetByLine(Const.A10_OUT_TARGET_POSITION); + } else { + return; + } + } else { + //锛屾垨鑰呬粎鏈変竴鏉℃湁鐜荤拑 + //涓�鏉$嚎涓虹┖锛屼竴鏉$嚎鏈夎繘鐗囪姹傛湁鐜荤拑 + int outLine = StringUtils.isBlank(d01Id) ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION; + //鑾峰彇杩涚墖璇锋眰鐜荤拑涓虹┖鐨勶紝璁$畻浠诲姟琛ㄨ繘鐗囨牸瀛� 鍙戦�佽繘鐗囦换鍔� + computeTargetByLine(outLine); } - //涓�鏉$嚎涓虹┖锛屼竴鏉$嚎鏈夎繘鐗囪姹傛湁鐜荤拑 - int outLine = StringUtils.isBlank(d01Id) ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION; - //鑾峰彇杩涚墖璇锋眰鐜荤拑涓虹┖鐨勶紝璁$畻浠诲姟琛ㄨ繘鐗囨牸瀛� 鍙戦�佽繘鐗囦换鍔� - computeTargetByLine(outLine); + } - // @Scheduled(fixedDelay = 5000) + @Scheduled(fixedDelay = 300) public void plcToHomeEdgOutTask() { List<BigStorageCageOutTask> outingList = bigStorageCageOutTaskService.list(new LambdaQueryWrapper<BigStorageCageOutTask>().eq(BigStorageCageOutTask::getTaskState, Const.BIG_STORAGE_OUT_NEW)); @@ -198,14 +239,14 @@ .orderBy(Boolean.TRUE, sequenceOrder, TemperingGlassInfo::getTemperingFeedSequence)); if (CollectionUtils.isNotEmpty(temperingGlassInfoList)) { log.info("鏈夋鍦ㄥ嚭鐗囩殑閽㈠寲浠诲姟"); - computeOutGlassInfo(temperingGlassInfoList); + computeOutGlassInfo(temperingGlassInfoList, Boolean.TRUE); return; } //鏄惁鏈変汉宸ヤ笅鐗囦换鍔� 鏈夌洿鎺ュ嚭 List<BigStorageCageDetails> artificialList = bigStorageCageDetailsService.list(new LambdaQueryWrapper<BigStorageCageDetails>() .eq(BigStorageCageDetails::getState, Const.GLASS_STATE_ARTIFICIAL).orderByDesc(BigStorageCageDetails::getWidth)); if (CollectionUtils.isNotEmpty(artificialList)) { - computeOutGlassInfo(temperingGlassInfoList); + computeOutGlassInfo(temperingGlassInfoList, Boolean.FALSE); return; } //閽㈠寲浼樺厛锛氳幏鍙栫悊鐗囩 鐜荤拑灏忕墖 鐮存崯琛� 鏁伴噺 鍒ゆ柇绗煎唴鐗堝浘鏄惁鍒伴綈 @@ -222,7 +263,7 @@ .eq(GlassInfo::getTemperingLayoutId, temperingLayoutDTO.getTemperingLayoutId()) .eq(GlassInfo::getEngineerId, temperingLayoutDTO.getEngineerId())); temperingGlassInfoService.saveBatch(temperingGlassInfos); - computeOutGlassInfo(temperingGlassInfoList); + computeOutGlassInfo(temperingGlassInfoList, Boolean.TRUE); return; } //鏈埌榻� 鎵ц鍐呴儴璋冨害浠诲姟 @@ -286,7 +327,7 @@ Integer widthSecond = edgGlassTaskInfoList.get(1).getWidth(); if (remainWidth >= widthFirst) { if (remainWidth - widthFirst - galssGap >= widthSecond) { - if (glassCount <= carMaxSize - 1) { + if (glassCount <= inCarMaxSize - 1) { addFeedTask(glassId, line, Const.BIG_STORAGE_IN_WAIT, widthFirst); } else { addFeedTask(glassId, line, Const.BIG_STORAGE_IN_RUN, widthFirst); @@ -300,7 +341,7 @@ } //鍚憄lc鍙戦�佽繘鐗囩‘璁� if (flag) { - S7object.getinstance().plccontrol.writeWord(mesAddress, (short) 1); + S7object.getinstance().plccontrol.writeWord(mesAddress, 1); } //璁板綍鏃犳硶鏀句笅鐜荤拑锛屽悗缁垽鏂惎鍔� return flag; @@ -375,11 +416,11 @@ //2銆佽幏鍙栫洰鏍囨牸瀛愪俊鎭� BigStorageDTO bigStorageDTO = bigStorageCageDetailsService.queryTargetSlotByTempering(info); //3銆佹洿鏂板ぇ鐞嗙墖绗艰〃鍓╀綑瀹藉害 - bigStorageCageService.update(new LambdaUpdateWrapper<BigStorageCage>().set(BigStorageCage::getRemainWidth, bigStorageDTO.getWidth()) + bigStorageCageService.update(new LambdaUpdateWrapper<BigStorageCage>().set(BigStorageCage::getRemainWidth, bigStorageDTO.getWidth() - info.getWidth()) .eq(BigStorageCage::getSlot, bigStorageDTO.getSlot())); //4銆佹洿鏂拌繘鐗囦换鍔¤〃锛岀洰鏍囨牸瀛愬強鐘舵�侊紙鐘舵�佹敼涓�2 鐢垫皵鎵埌鑷澶勭悊锛� 閬囧埌闂锛氭棤娉曟壒閲忔洿鏂帮紝鎵归噺鏇存柊鏃犳硶璧版寚瀹氫粠搴� e.setTargetSlot(bigStorageDTO.getSlot()); - e.setTaskType(Const.BIG_STORAGE_IN_RUN); +// e.setTaskType(Const.BIG_STORAGE_IN_RUN); bigStorageCageFeedTaskService.updateById(e); //5銆佸皢杩涚墖淇℃伅瀛樺叆澶х悊鐗囩璇︽儏琛� @@ -398,24 +439,31 @@ String mesD05Address = plcMesObject.getPlcParameter("MESToD05").getAddress(); String outLine = line.equals(Const.A09_OUT_TARGET_POSITION) ? mesD03Address : mesD05Address; for (int i = 1; i <= taskList.size(); i++) { - s7control.writeWord(plcMesObject.getPlcParameter("StartAddToImport" + i).getAddress(), (short) taskList.get(i).getLine()); - s7control.writeWord(plcMesObject.getPlcParameter("TargetAddToImport1" + i).getAddress(), (short) taskList.get(i).getTargetSlot()); + s7control.writeWord(plcMesObject.getPlcParameter("StartAddToImport" + i).getAddress(), taskList.get(i - 1).getLine()); + s7control.writeWord(plcMesObject.getPlcParameter("TargetAddToImport" + i).getAddress(), taskList.get(i - 1).getTargetSlot()); } - s7control.writeWord(outLine, (short) 1); + s7control.writeWord(outLine, 2); + log.info("閫佺墖浠诲姟宸插彂閫佸畬鎴愶紝浠诲姟绾胯矾涓猴細{}锛屽惎鍔ㄥ湴鍧�涓簕}", line, outLine); } - private <T extends BigStorageCageBaseInfo> Boolean computeOutGlassInfo(List<T> list) { + private <T extends BigStorageCageBaseInfo> Boolean computeOutGlassInfo(List<T> list, Boolean isTempering) { //浠诲姟鏁版嵁 鑾峰彇杞﹀瓙瀛樻斁鐜荤拑鏈�澶ф暟閲� 鐜荤拑闂撮殧 List<BigStorageCageOutTask> bigStorageCageOutTaskList = new ArrayList<>(); //鎵撹溅鍓╀綑灏哄 Integer remainWidth = carWidth; for (T e : list) { - if (bigStorageCageOutTaskList.size() > carMaxSize || e.getWidth() > remainWidth) { + if (bigStorageCageOutTaskList.size() > outCarMaxSize || e.getWidth() > remainWidth) { break; } remainWidth = remainWidth - (int) e.getWidth() - galssGap; - bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.A09_OUT_TARGET_POSITION, - (int) e.getWidth(), 0, 0, 1)); + if (isTempering) { + bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.TEMPERING_OUT_TARGET_POSITION, + (int) e.getWidth() * 10, 0, 0, 1)); + } else { + bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.ARTIFICIAL_OUT_TARGET_POSITION, + (int) e.getWidth() * 10, 0, 0, 1)); + } + } Assert.isFalse(CollectionUtils.isEmpty(bigStorageCageOutTaskList), "鏈幏鍙栧嚭鐗囨暟鎹紝缁撴潫鍑虹墖浠诲姟"); log.info("鑾峰彇鍑虹墖浠诲姟鏁版嵁{}鏉★紝鎵ц淇濆瓨", bigStorageCageOutTaskList.size()); @@ -456,7 +504,14 @@ bigStorageCageService.update(new LambdaUpdateWrapper<BigStorageCage>().set(BigStorageCage::getRemainWidth, slotWidth) .in(BigStorageCage::getSlot, slotList)); } - - } + + public Boolean computeIsRun(int line, String glassId) { + //鑾峰彇鍗ц浆绔嬪墿浣欏搴� + BigStorageDTO sitToUpRemainWidth = bigStorageCageFeedTaskService.querySitToUpRemainWidth(line); + //鑾峰彇鐜荤拑淇℃伅 + GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId)); + return sitToUpRemainWidth.getWidth() < glassInfo.getWidth(); + } + } \ No newline at end of file -- Gitblit v1.8.0