From d5d652d23a0bdf64ce527a6b592713a849abac7d Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期四, 17 十月 2024 15:22:37 +0800 Subject: [PATCH] Merge branch 'master' of http://bore.pub:10439/r/HangZhouMes --- hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java | 222 +++++++++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 182 insertions(+), 40 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 2e6b87a..61a0a3c 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 @@ -131,7 +131,7 @@ judgeGlassTypeStatus(d01Id, Const.A09_OUT_TARGET_POSITION, mesD01Address); edgGlassTaskInfoService.update(new LambdaUpdateWrapper<EdgGlassTaskInfo>() .set(EdgGlassTaskInfo::getStatus, Const.EDG_GLASS_SUCCESS).eq(EdgGlassTaskInfo::getGlassId, d01Id)); - d01GlassId = d01Id; +// d01GlassId = d01Id; } } // 鐘舵�佷负0涓嶆搷浣滐紙D01閫佺墖锛�0涓嶆搷浣滐紝1鍏佽閫佺墖锛夛紝璇锋眰瀛椾负1锛� 鍗ц浆绔嬫湭鍚姩 @@ -140,7 +140,7 @@ judgeGlassTypeStatus(d04Id, Const.A10_OUT_TARGET_POSITION, mesD04Address); edgGlassTaskInfoService.update(new LambdaUpdateWrapper<EdgGlassTaskInfo>() .set(EdgGlassTaskInfo::getStatus, Const.EDG_GLASS_SUCCESS).eq(EdgGlassTaskInfo::getGlassId, d04Id)); - d04GlassId = d04Id; +// d04GlassId = d04Id; } } Date endDate = new Date(); @@ -317,21 +317,23 @@ //鐜荤拑鍒伴綈鍖呮嫭宸插嚭鐗囩殑 //鍒伴綈锛屽皢鐜荤拑灏忕墖鏁版嵁瀛樺叆閽㈠寲灏忕墖琛紝閫昏緫鐢熸垚鍑虹墖浠诲姟 缁撴潫 for (TemperingLayoutDTO item : temperingLayoutDTOList) { - List<TemperingGlassInfo> temperingGlassInfos = glassInfoService.selectJoinList(TemperingGlassInfo.class, JoinWrappers.lambda(GlassInfo.class) - .selectAll(GlassInfo.class) - .select("-1 as state") - .selectAs(BigStorageCageDetails::getSlot, TemperingGlassInfo::getSlot) - .innerJoin(BigStorageCageDetails.class, BigStorageCageDetails::getGlassId, GlassInfo::getGlassId) - .eq(BigStorageCageDetails::getState, Const.GLASS_STATE_IN) - .eq(GlassInfo::getTemperingLayoutId, item.getTemperingLayoutId()) - .eq(GlassInfo::getEngineerId, item.getEngineerId()) - .orderBy(Boolean.TRUE, sequenceOrder, GlassInfo::getTemperingFeedSequence)); - if (CollectionUtils.isNotEmpty(temperingGlassInfos)) { - temperingGlassInfoService.saveBatch(temperingGlassInfos); - computeOutMoreGlassInfo(temperingGlassInfoList, Boolean.TRUE, mesToPLCAddress); - Date endDate = new Date(); - log.info("澶х悊鐗囩鍑虹墖浠诲姟缁撴潫鏃堕棿锛歿}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime()); - return; + if (redisUtil.getCacheObject("temperingengineerId").equals(item.getEngineerId())) { + List<TemperingGlassInfo> temperingGlassInfos = glassInfoService.selectJoinList(TemperingGlassInfo.class, JoinWrappers.lambda(GlassInfo.class) + .selectAll(GlassInfo.class) + .select("-1 as state") + .selectAs(BigStorageCageDetails::getSlot, TemperingGlassInfo::getSlot) + .innerJoin(BigStorageCageDetails.class, BigStorageCageDetails::getGlassId, GlassInfo::getGlassId) + .eq(BigStorageCageDetails::getState, Const.GLASS_STATE_IN) + .eq(GlassInfo::getTemperingLayoutId, item.getTemperingLayoutId()) + .eq(GlassInfo::getEngineerId, item.getEngineerId()) + .orderBy(Boolean.TRUE, sequenceOrder, GlassInfo::getTemperingFeedSequence)); + if (CollectionUtils.isNotEmpty(temperingGlassInfos)) { + temperingGlassInfoService.saveBatch(temperingGlassInfos); + computeOutMoreGlassInfo(temperingGlassInfoList, Boolean.TRUE, mesToPLCAddress); + Date endDate = new Date(); + log.info("澶х悊鐗囩鍑虹墖浠诲姟缁撴潫鏃堕棿锛歿}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime()); + return; + } } } } @@ -356,7 +358,7 @@ int serialNumber = 1; for (BigStorageCageDetails item : list) { outTasks.add(new BigStorageCageOutTask(item.getGlassId(), first.getSlot(), second.getSlot(), - item.getWidth() * 10, item.getHeight() * 10, 1, serialNumber++, Const.BIG_STORAGE_OUT_NEW)); + item.getWidth() * 10, item.getHeight() * 10, 1, serialNumber++, Const.BIG_STORAGE_OUT_NEW, new Date())); } //鏂板璋冨害浠诲姟 bigStorageCageOutTaskService.saveBatch(outTasks); @@ -435,6 +437,16 @@ List<BigStorageCageOutTask> outSuccessGlass = bigStorageCageOutTaskService.list(new LambdaQueryWrapper<BigStorageCageOutTask>() .in(BigStorageCageOutTask::getGlassId, glassIds).in(BigStorageCageOutTask::getTaskState, Const.BIG_STORAGE_OUT_ALL)); if (CollectionUtils.isNotEmpty(outSuccessGlass)) { + for (BigStorageCageOutTask bigStorageCageOutTask : outSuccessGlass + ) { + if (bigStorageCageOutTask.getEndSlot().equals(Const.ARTIFICIAL_OUT_TARGET_POSITION)) { + temperingGlassInfoService.update( + new LambdaUpdateWrapper<TemperingGlassInfo>() + .set(TemperingGlassInfo::getState, Const.TEMPERING_END) + .eq(TemperingGlassInfo::getGlassId, bigStorageCageOutTask.getGlassId()) + ); + } + } log.info("3銆佽幏鍙栧嚭鐗囧凡瀹屾垚鐨勭幓鐠冧俊鎭痠d:{}", outSuccessGlass); List<UpdateBigStorageCageDTO> storageCageDTOList = outSuccessGlass.stream().map(e -> { UpdateBigStorageCageDTO storageCageDTO = new UpdateBigStorageCageDTO(); @@ -515,9 +527,9 @@ Damage damage = new Damage(); damage.setGlassId(bigStorageCageFeedTask.getGlassId()); damage.setLine(bigStorageCageFeedTask.getLine()); - damage.setWorkingProcedure("鍐峰姞宸�"); + damage.setWorkingProcedure("纾ㄨ竟"); damage.setRemark("杩涚鍓嶅崸杞珛"); - damage.setStatus(0); + damage.setStatus(1); damage.setType(bigStorageCageFeedTask.getTaskState()); damageService.insertDamage(damage); slotList.add(bigStorageCageFeedTask.getTargetSlot()); @@ -543,9 +555,9 @@ Damage damage = new Damage(); damage.setGlassId(bigStorageCageOutTask.getGlassId()); damage.setLine(bigStorageCageOutTask.getEndSlot()); - damage.setWorkingProcedure("鍐峰姞宸�"); + damage.setWorkingProcedure("閽㈠寲"); damage.setRemark("鍑虹墖鍚庡崸杞珛"); - damage.setStatus(0); + damage.setStatus(1); damage.setType(bigStorageCageOutTask.getTaskState()); damageService.insertDamage(damage); slotList.add(bigStorageCageOutTask.getStartSlot()); @@ -560,6 +572,104 @@ } /** + * 纭瀛楁竻绌� + */ +// @Scheduled(fixedDelay = 300) + public void confirmClear() { + PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; + String d01ToMES = plcParameterObject.getPlcParameter("D01ToMES").getValue(); + String d04ToMES = plcParameterObject.getPlcParameter("D04ToMES").getValue(); + String mesD01Address = plcParameterObject.getPlcParameter("MESToD01").getAddress(); + String mesD04Address = plcParameterObject.getPlcParameter("MESToD04").getAddress(); + String d03ToMES = plcParameterObject.getPlcParameter("D03ToMES").getValue(); + String d05ToMES = plcParameterObject.getPlcParameter("D05ToMES").getValue(); + String mesD03Address = plcParameterObject.getPlcParameter("MESToD03").getAddress(); + String mesD05Address = plcParameterObject.getPlcParameter("MESToD05").getAddress(); + if (!REQUEST_WORD.equals(d01ToMES)) { + S7object.getinstance().plccontrol.writeWord(mesD01Address, 0); + } + if (!REQUEST_WORD.equals(d04ToMES)) { + S7object.getinstance().plccontrol.writeWord(mesD04Address, 0); + } + if (!REQUEST_WORD.equals(d03ToMES)) { + S7object.getinstance().plccontrol.writeWord(mesD03Address, 0); + } + if (!REQUEST_WORD.equals(d05ToMES)) { + S7object.getinstance().plccontrol.writeWord(mesD05Address, 0); + } + } + + /** + * 杩涚墖鐘舵�佷慨鏀� + */ +// @Scheduled(fixedDelay = 300) + public void feedStatusUpdate() { + PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; + List<String> glassIds1 = null; + List<String> glassIds2 = null; + for (int i = 1; i <= 2; i++) { + String line1GlassId = plcParameterObject.getPlcParameter("D03ID" + i).getAddress(); + if (StringUtils.isEmpty(line1GlassId)) { + glassIds1.add(line1GlassId); + } + String line2GlassId = plcParameterObject.getPlcParameter("D05ID" + i).getAddress(); + if (StringUtils.isEmpty(line2GlassId)) { + glassIds1.add(line2GlassId); + } + } + List<BigStorageCageFeedTask> bigStorageCageFeedTasks1 = bigStorageCageFeedTaskService.list( + new LambdaQueryWrapper<BigStorageCageFeedTask>() + .eq(BigStorageCageFeedTask::getTaskState, 1) + .eq(BigStorageCageFeedTask::getLine, Const.A09_OUT_TARGET_POSITION) + ); + List<BigStorageCageFeedTask> bigStorageCageFeedTasks2 = bigStorageCageFeedTaskService.list( + new LambdaQueryWrapper<BigStorageCageFeedTask>() + .eq(BigStorageCageFeedTask::getTaskState, 1) + .eq(BigStorageCageFeedTask::getLine, Const.A10_OUT_TARGET_POSITION) + ); + if (CollectionUtils.isNotEmpty(bigStorageCageFeedTasks1)) { + List<String> matchingIds1 = bigStorageCageFeedTasks1.stream() + .map(BigStorageCageFeedTask::getGlassId) + .filter(glassIds1::contains) + .distinct() + .collect(Collectors.toList()); + } + if (CollectionUtils.isNotEmpty(bigStorageCageFeedTasks2)) { + List<String> matchingIds2 = bigStorageCageFeedTasks2.stream() + .map(BigStorageCageFeedTask::getGlassId) + .filter(glassIds2::contains) + .distinct() + .collect(Collectors.toList()); + } + bigStorageCageFeedTaskService.update( + new LambdaUpdateWrapper<BigStorageCageFeedTask>() + .in(BigStorageCageFeedTask::getGlassId, glassIds1, glassIds2) + .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT) + .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP) + ); + if (glassIds1 == null) { + bigStorageCageFeedTaskService.update( + new LambdaUpdateWrapper<BigStorageCageFeedTask>() + .eq(BigStorageCageFeedTask::getLine,Const.A09_OUT_TARGET_POSITION) + .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP) + .gt(BigStorageCageFeedTask::getTargetSlot, 0) + .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT) + .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_CAR) + ); + } + if (glassIds1 == null) { + bigStorageCageFeedTaskService.update( + new LambdaUpdateWrapper<BigStorageCageFeedTask>() + .eq(BigStorageCageFeedTask::getLine,Const.A10_OUT_TARGET_POSITION) + .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP) + .gt(BigStorageCageFeedTask::getTargetSlot, 0) + .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT) + .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_CAR) + ); + } + } + + /** * 鎸夌収鐜荤拑id鍒ゆ柇鐜荤拑鐘舵�佸強鍗ц浆绔嬫槸鍚﹀彲鐩存帴鍚姩 */ public Boolean judgeGlassTypeStatus(String glassId, Integer line, String mesAddress) { @@ -569,14 +679,24 @@ .eq(EdgGlassTaskInfo::getLine, line) .apply("time >= (select time from edg_glass_task_info where line='" + line + "' and glass_id = '" + glassId + "' and deleted = 0)") .orderByAsc(EdgGlassTaskInfo::getTime)); - if (edgGlassTaskInfoList == null) { - log.info("绾胯矾锛歿}璇嗗埆鐜荤拑淇℃伅鏈嚭鐜板湪灏哄琛ㄤ腑,鑾峰彇鐩搁偦涓ゅ潡鐜荤拑澶辫触", line); - } else { + if (edgGlassTaskInfoList.size() == 0) { edgGlassTaskInfoList = edgGlassTaskInfoService.list(new QueryWrapper<EdgGlassTaskInfo>() .select("Top 1 *") .eq("glass_id", glassId) ); log.info("鍦ㄥ昂瀵歌〃涓幏鍙栫幓鐠冧俊鎭瘂}", edgGlassTaskInfoList); + if (edgGlassTaskInfoList.size() == 0) { + GlassInfo glassInfo = glassInfoService.getOne( + new LambdaQueryWrapper<GlassInfo>() + .eq(GlassInfo::getGlassId, glassId) + ); + EdgGlassTaskInfo edgGlassTaskInfo = new EdgGlassTaskInfo(); + BeanUtils.copyProperties(glassInfo, edgGlassTaskInfo); + edgGlassTaskInfo.setWidth((int) glassInfo.getWidth()); + edgGlassTaskInfo.setHeight((int) glassInfo.getHeight()); + edgGlassTaskInfoList.add(edgGlassTaskInfo); + log.info("鍦ㄧ幓鐠冧俊鎭〃涓幏鍙栫幓鐠冧俊鎭瘂}", edgGlassTaskInfoList); + } } Assert.isFalse(CollectionUtils.isEmpty(edgGlassTaskInfoList), "璇嗗埆鐜荤拑淇℃伅鏈嚭鐜板湪灏哄琛ㄤ腑,鑾峰彇鐩搁偦涓ゅ潡鐜荤拑澶辫触"); //2銆佽幏鍙栧崸杞珛鍓╀綑瀹藉害 @@ -639,11 +759,16 @@ //鍚憄lc鍐欏叆纭瀛� int returnData = 0; int count = 1; - while (returnData == 0) { + while (returnData != 0) { S7object.getinstance().plccontrol.writeWord(mesAddress, 1); - returnData = S7object.getinstance().plccontrol.readWord(mesAddress, 1).get(0); - log.info("杩涘崸杞珛绗瑊}娆″彂閫佺‘璁ゅ瓧瀹屾垚锛屽湴鍧�涓猴細{},鍐欏叆鐨勫唴瀹逛负{}", count++, mesAddress, returnData); - + PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; + if (Const.A10_OUT_TARGET_POSITION.equals(line)) { + returnData = Integer.parseInt(plcParameterObject.getPlcParameter("D04ToMES").getValue()); + } else { + returnData = Integer.parseInt(plcParameterObject.getPlcParameter("D01ToMES").getValue()); + } +// returnData = S7object.getinstance().plccontrol.readWord(mesAddress, 1).get(0); + log.info("杩涘崸杞珛绗瑊}娆″彂閫佺‘璁ゅ瓧瀹屾垚锛屽湴鍧�涓猴細{},鍐欏叆鐨勫唴瀹逛负{}", count++, mesAddress, 1); } } //璁板綍鏃犳硶鏀句笅鐜荤拑锛屽悗缁垽鏂惎鍔� @@ -664,6 +789,13 @@ bigStorageCageFeedTask.setCreateTime(new Date()); //鍒犻櫎鐞嗙墖绗艰〃鎷胯蛋/鐮存崯鏁版嵁鏁版嵁 damageService.deleteByGlassId(glassId); + Damage damage = new Damage(); + damage.setGlassId(glassId); + damage.setWorkingProcedure("纾ㄨ竟"); + damage.setLine(line); + damage.setType(1); + damage.setRemark("杩涘ぇ鐞嗙墖"); + damageService.insertDamage(damage); return bigStorageCageFeedTaskService.save(bigStorageCageFeedTask); } @@ -756,10 +888,15 @@ } int returnData = 0; int count = 1; - while (returnData == 0) { + while (returnData != 0) { s7control.writeWord(outLine, 2); - returnData = s7control.readWord(outLine, 1).get(0); - log.info("宸插悜plc绗瑊}娆″彂閫佽繘鐗囦换鍔$‘璁わ紝鍦板潃涓猴細{},鍐欏叆鐨勫唴瀹逛负{}", count++, outLine, returnData); + if (line.equals(Const.A09_OUT_TARGET_POSITION)) { + returnData = Integer.parseInt(plcMesObject.getPlcParameter("MESToD03").getValue()); + } else { + returnData = Integer.parseInt(plcMesObject.getPlcParameter("MESToD05").getValue()); + } +// returnData = s7control.readWord(outLine, 1).get(0); + log.info("宸插悜plc绗瑊}娆″彂閫佽繘鐗囦换鍔$‘璁わ紝鍦板潃涓猴細{},鍐欏叆鐨勫唴瀹逛负{}", count++, outLine, 2); } } @@ -787,7 +924,7 @@ int minLength = Math.min((int) e.getWidth(), (int) e.getHeight()); if (maxX + minLength <= xMaxSize) { bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.TEMPERING_OUT_TARGET_POSITION, - e.getWidth() * 10, e.getHeight() * 10, 0, 0, 1)); + e.getWidth() * 10, e.getHeight() * 10, 0, 0, 1, new Date())); maxX = Math.max(maxX, e.getXCoordinate()); } else { break; @@ -795,7 +932,7 @@ } else { bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.ARTIFICIAL_OUT_TARGET_POSITION, - e.getWidth() * 10, e.getHeight(), 0, 0, 1)); + e.getWidth() * 10, e.getHeight(), 0, 0, 1, new Date())); } } Assert.isFalse(CollectionUtils.isEmpty(bigStorageCageOutTaskList), "鏈幏鍙栧嚭鐗囨暟鎹紝缁撴潫鍑虹墖浠诲姟"); @@ -825,7 +962,7 @@ * @param <T> * @return */ - private <T extends BigStorageCageBaseInfo> Boolean computeOutMoreGlassInfo(List<T> list, Boolean isTempering, String mesToPLCAddress) { + public <T extends BigStorageCageBaseInfo> Boolean computeOutMoreGlassInfo(List<T> list, Boolean isTempering, String mesToPLCAddress) { //浠诲姟鏁版嵁 鑾峰彇杞﹀瓙瀛樻斁鐜荤拑鏈�澶ф暟閲� 鐜荤拑闂撮殧 List<BigStorageCageOutTask> bigStorageCageOutTaskList = new ArrayList<>(); //鎵撹溅鍓╀綑灏哄 @@ -846,7 +983,7 @@ int minLength = Math.min((int) e.getWidth(), (int) e.getHeight()); if (maxX + minLength <= xMaxSize) { bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.TEMPERING_OUT_TARGET_POSITION, - e.getWidth() * 10, e.getHeight() * 10, trainNumber, serialNumber++, 1)); + e.getWidth() * 10, e.getHeight() * 10, trainNumber, serialNumber++, 1, new Date())); maxX = Math.max(maxX, e.getXCoordinate()); } else { remainWidth = carWidth - maxLength - glassGap; @@ -854,21 +991,26 @@ serialNumber = 1; maxX = e.getXCoordinate(); bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.TEMPERING_OUT_TARGET_POSITION, - e.getWidth() * 10, e.getHeight(), trainNumber, serialNumber++, 1)); + e.getWidth() * 10, e.getHeight(), trainNumber, serialNumber++, 1, new Date())); } } else { bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.ARTIFICIAL_OUT_TARGET_POSITION, - e.getWidth() * 10, e.getHeight(), trainNumber, serialNumber++, 1)); + e.getWidth() * 10, e.getHeight(), trainNumber, serialNumber++, 1, new Date())); } } Assert.isFalse(CollectionUtils.isEmpty(bigStorageCageOutTaskList), "鏈幏鍙栧嚭鐗囨暟鎹紝缁撴潫鍑虹墖浠诲姟"); log.info("鑾峰彇鍑虹墖浠诲姟鏁版嵁{}鏉★紝鎵ц淇濆瓨", bigStorageCageOutTaskList.size()); - bigStorageCageOutTaskService.saveBatch(bigStorageCageOutTaskList); + for (BigStorageCageOutTask bigStorageCageOutTask : bigStorageCageOutTaskList + ) { + bigStorageCageOutTaskService.save(bigStorageCageOutTask); + } +// bigStorageCageOutTaskService.saveBatch(bigStorageCageOutTaskList); List<String> glassIds = bigStorageCageOutTaskList.stream().map(BigStorageCageOutTask::getGlassId).collect(Collectors.toList()); log.info("灏嗗嚭鐗囩幓鐠儃}鐜荤拑鐘舵�佹敼涓哄凡鍑虹墖", glassIds); bigStorageCageDetailsService.update(new LambdaUpdateWrapper<BigStorageCageDetails>() .set(BigStorageCageDetails::getState, Const.GLASS_STATE_OUT_ING) - .in(BigStorageCageDetails::getGlassId, glassIds)); + .in(BigStorageCageDetails::getGlassId, glassIds) + .ne(BigStorageCageDetails::getState, Const.GLASS_STATE_OUT)); // int returnData = 0; // int count = 1; // while (returnData == 0) { -- Gitblit v1.8.0