From eb852430ce781189ca5f9f6abcf3da539464c79e Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期五, 01 十一月 2024 14:57:24 +0800 Subject: [PATCH] 修改大理片为按工程数分前后两块进片 --- hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java | 137 ++++++++++++++++++++++++++++++++++++--------- 1 files changed, 109 insertions(+), 28 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 f30b7d0..b80f6d4 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 @@ -127,21 +127,38 @@ } //鎸夌収绾胯矾鍙婄幓鐠僫d鑾峰彇鐩搁偦涓ゅ潡鐜荤拑 鍗ц浆绔嬩笂鐨勭幓鐠�: 鐘舵�佷负0涓嶆搷浣滐紙D01閫佺墖锛�0涓嶆搷浣滐紝1鍏佽閫佺墖锛夛紝璇锋眰瀛椾负1锛� 锛�02鐜荤拑id涓虹┖鎴栬�呭崸杞珛鏈惎鍔級 if (!REQUEST_WORD.equals(mesD01Value) && REQUEST_WORD.equals(d01ToMES) && (StringUtils.isBlank(d02State) || !REQUEST_WORD.equals(d03State))) { - if (!d01GlassId.equals(d01Id)) { - judgeGlassTypeStatus(d01Id, Const.A09_OUT_TARGET_POSITION, mesD01Address); - edgGlassTaskInfoService.update(new LambdaUpdateWrapper<EdgGlassTaskInfo>() - .set(EdgGlassTaskInfo::getStatus, Const.EDG_GLASS_SUCCESS).eq(EdgGlassTaskInfo::getGlassId, d01Id)); + List<BigStorageCageFeedTask> bigStorageCageFeedTasks=bigStorageCageFeedTaskService.list( + new LambdaQueryWrapper<BigStorageCageFeedTask>() + .gt(BigStorageCageFeedTask::getTargetSlot,0) + .eq(BigStorageCageFeedTask::getLine,Const.A09_OUT_TARGET_POSITION) + .eq(BigStorageCageFeedTask::getTaskState,Const.BIG_STORAGE_IN_UP) + ); + if(CollectionUtils.isEmpty(bigStorageCageFeedTasks)){ + if (!d01GlassId.equals(d01Id)) { + 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; + } } } // 鐘舵�佷负0涓嶆搷浣滐紙D01閫佺墖锛�0涓嶆搷浣滐紝1鍏佽閫佺墖锛夛紝璇锋眰瀛椾负1锛� 鍗ц浆绔嬫湭鍚姩 if (!REQUEST_WORD.equals(mesD04Value) && REQUEST_WORD.equals(d04ToMES) && !REQUEST_WORD.equals(d05State)) { - if (!d04GlassId.equals(d04Id)) { - judgeGlassTypeStatus(d04Id, Const.A10_OUT_TARGET_POSITION, mesD04Address); - edgGlassTaskInfoService.update(new LambdaUpdateWrapper<EdgGlassTaskInfo>() - .set(EdgGlassTaskInfo::getStatus, Const.EDG_GLASS_SUCCESS).eq(EdgGlassTaskInfo::getGlassId, d04Id)); + List<BigStorageCageFeedTask> bigStorageCageFeedTasks=bigStorageCageFeedTaskService.list( + new LambdaQueryWrapper<BigStorageCageFeedTask>() + .gt(BigStorageCageFeedTask::getTargetSlot,0) + .eq(BigStorageCageFeedTask::getLine,Const.A10_OUT_TARGET_POSITION) + .eq(BigStorageCageFeedTask::getTaskState,Const.BIG_STORAGE_IN_UP) + ); + if(CollectionUtils.isEmpty(bigStorageCageFeedTasks)){ + if (!d04GlassId.equals(d04Id)) { + 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; + } } + } Date endDate = new Date(); log.info("澶х悊鐗囩鎵爜浠诲姟缁撴潫鏃堕棿锛歿}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime()); @@ -180,13 +197,26 @@ } if (!REQUEST_WORD.equals(d03ToMES) && !REQUEST_WORD.equals(d05ToMES)) { Date endDate = new Date(); - log.info("鍗ц浆绔嬫病鏈夐�佺墖璇锋眰锛岀粨鏉熼�佺墖浠诲姟锛屼换鍔$粨鏉熸椂闂达細{}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime()); + log.info("鍗ц浆绔嬬涓�娆℃病鏈夐�佺墖璇锋眰锛岀粨鏉熼�佺墖浠诲姟锛屼换鍔$粨鏉熸椂闂达細{}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime()); return; } + if (!REQUEST_WORD.equals(d03ToMES) && !REQUEST_WORD.equals(d05ToMES)) { + Date endDate = new Date(); + log.info("鍗ц浆绔嬬浜屾娌℃湁閫佺墖璇锋眰锛岀粨鏉熼�佺墖浠诲姟锛屼换鍔$粨鏉熸椂闂达細{}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime()); + return; + } +// List<Integer> lines=new ArrayList<>(); +// if(REQUEST_WORD.equals(d03ToMES)){ +// lines.add(Const.A09_OUT_TARGET_POSITION); +// } +// if(REQUEST_WORD.equals(d05ToMES)){ +// lines.add(Const.A10_OUT_TARGET_POSITION); +// } LambdaQueryWrapper<BigStorageCageFeedTask> wrapper = new LambdaQueryWrapper<BigStorageCageFeedTask>() .eq(BigStorageCageFeedTask::getTaskType, Const.BIG_STORAGE_IN_RUN) .and(e -> e.isNull(BigStorageCageFeedTask::getTargetSlot).or().eq(BigStorageCageFeedTask::getTargetSlot, Const.OUT_TARGET_POSITION_ZERO)) .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP); +// .in(BigStorageCageFeedTask::getLine,lines); //鑾峰彇鍙互鍚姩鍗ц浆绔嬬殑浠诲姟绾胯矾 List<BigStorageCageFeedTask> feedTaskList = bigStorageCageFeedTaskService.list(wrapper); if (CollectionUtils.isNotEmpty(feedTaskList)) { @@ -224,6 +254,8 @@ //鑾峰彇鍗ц浆绔嬪墿浣欏搴� if (computeIsRun(lineFirst, lineGlassId)) { computeTargetByLine(lineFirst); + }else{ + log.info("褰撳墠绾胯矾锛歿}锛屾湁鎵爜鐜荤拑锛歿}",lineFirst,lineGlassId); } } Date endDate = new Date(); @@ -581,20 +613,26 @@ 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 d03ToMES = plcParameterObject.getPlcParameter("D03ToMES").getValue(); +// String d05ToMES = plcParameterObject.getPlcParameter("D05ToMES").getValue(); + String d03ToMES = plcParameterObject.getPlcParameter("D03Request").getValue(); + String d05ToMES = plcParameterObject.getPlcParameter("D05Request").getValue(); String mesD03Address = plcParameterObject.getPlcParameter("MESToD03").getAddress(); String mesD05Address = plcParameterObject.getPlcParameter("MESToD05").getAddress(); if (!REQUEST_WORD.equals(d01ToMES)) { + log.info("鍦板潃锛歿}鍐欏叆0",mesD01Address); S7object.getinstance().plccontrol.writeWord(mesD01Address, 0); } if (!REQUEST_WORD.equals(d04ToMES)) { + log.info("鍦板潃锛歿}鍐欏叆0",mesD04Address); S7object.getinstance().plccontrol.writeWord(mesD04Address, 0); } if (!REQUEST_WORD.equals(d03ToMES)) { + log.info("鍦板潃锛歿}鍐欏叆0",mesD03Address); S7object.getinstance().plccontrol.writeWord(mesD03Address, 0); } if (!REQUEST_WORD.equals(d05ToMES)) { + log.info("鍦板潃锛歿}鍐欏叆0",mesD05Address); S7object.getinstance().plccontrol.writeWord(mesD05Address, 0); } } @@ -605,6 +643,8 @@ @Scheduled(fixedDelay = 300) public void feedStatusUpdate() { PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; + String mesD03Address = plcParameterObject.getPlcParameter("MESToD03").getAddress(); + String mesD05Address = plcParameterObject.getPlcParameter("MESToD05").getAddress(); List<String> glassIds1 = new ArrayList<>(); List<String> glassIds2 = new ArrayList<>(); for (int i = 1; i <= 6; i++) { @@ -633,12 +673,15 @@ .filter(glassIds1::contains) .distinct() .collect(Collectors.toList()); - bigStorageCageFeedTaskService.update( - new LambdaUpdateWrapper<BigStorageCageFeedTask>() - .in(BigStorageCageFeedTask::getGlassId, matchingIds1) - .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT) - .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP) - ); + log.info("D3id{},鍖归厤id:{}",glassIds1,matchingIds1); + if(CollectionUtils.isNotEmpty(matchingIds1)){ + bigStorageCageFeedTaskService.update( + new LambdaUpdateWrapper<BigStorageCageFeedTask>() + .in(BigStorageCageFeedTask::getGlassId, matchingIds1) + .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT) + .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP) + ); + } } if (CollectionUtils.isNotEmpty(bigStorageCageFeedTasks2) && CollectionUtils.isNotEmpty(glassIds2)) { List<String> matchingIds2 = bigStorageCageFeedTasks2.stream() @@ -646,14 +689,19 @@ .filter(glassIds2::contains) .distinct() .collect(Collectors.toList()); - bigStorageCageFeedTaskService.update( - new LambdaUpdateWrapper<BigStorageCageFeedTask>() - .in(BigStorageCageFeedTask::getGlassId, matchingIds2) - .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT) - .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP) - ); + log.info("D5id{},鍖归厤id:{}",glassIds2,matchingIds2); + if(CollectionUtils.isNotEmpty(matchingIds2)){ + bigStorageCageFeedTaskService.update( + new LambdaUpdateWrapper<BigStorageCageFeedTask>() + .in(BigStorageCageFeedTask::getGlassId, matchingIds2) + .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT) + .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP) + ); + } } if (CollectionUtils.isEmpty(glassIds1)) { + S7object.getinstance().plccontrol.writeWord(mesD03Address, 0); + log.info("{}绾夸慨鏀圭幓鐠冪姸鎬佷负3",Const.A09_OUT_TARGET_POSITION); bigStorageCageFeedTaskService.update( new LambdaUpdateWrapper<BigStorageCageFeedTask>() .eq(BigStorageCageFeedTask::getLine, Const.A09_OUT_TARGET_POSITION) @@ -664,6 +712,8 @@ ); } if (CollectionUtils.isEmpty(glassIds2)) { + S7object.getinstance().plccontrol.writeWord(mesD05Address, 0); + log.info("{}绾夸慨鏀圭幓鐠冪姸鎬佷负3",Const.A10_OUT_TARGET_POSITION); bigStorageCageFeedTaskService.update( new LambdaUpdateWrapper<BigStorageCageFeedTask>() .eq(BigStorageCageFeedTask::getLine, Const.A10_OUT_TARGET_POSITION) @@ -903,23 +953,54 @@ String mesD03Address = plcMesObject.getPlcParameter("MESToD03").getAddress(); String mesD05Address = plcMesObject.getPlcParameter("MESToD05").getAddress(); String outLine = line.equals(Const.A09_OUT_TARGET_POSITION) ? mesD03Address : mesD05Address; + List<String> returnData = new ArrayList<>(); + for (int i = 1; i <= taskList.size(); i++) { s7control.writeWord(plcMesObject.getPlcParameter("StartAddToImport" + i).getAddress(), taskList.get(i - 1).getLine()); s7control.writeWord(plcMesObject.getPlcParameter("TargetAddToImport" + i).getAddress(), taskList.get(i - 1).getTargetSlot()); + returnData.add(taskList.get(i - 1).getGlassId()); log.info("鍚憄lc鍙戦�佺{}鐗囩幓鐠冨凡瀹屾垚,璧峰浣嶇疆鏄瘂}锛岀洰鏍囦綅缃槸", i, taskList.get(i - 1).getLine(), taskList.get(i - 1).getTargetSlot()); } - int returnData = 1; +// int returnData = 1; int count = 1; - while (returnData != 0) { + + + while (CollectionUtils.isNotEmpty(returnData)) { + List<String> glassIds1 = new ArrayList<>(); + List<String> glassIds2 = new ArrayList<>(); s7control.writeWord(outLine, 2); + for (int i = 1; i <= 6; i++) { + String line1GlassId = plcMesObject.getPlcParameter("D03ID" + i).getValue(); + if (StringUtils.isNotEmpty(line1GlassId)) { + glassIds1.add(line1GlassId); + } + String line2GlassId = plcMesObject.getPlcParameter("D05ID" + i).getValue(); + if (StringUtils.isNotEmpty(line2GlassId)) { + glassIds2.add(line2GlassId); + } + } if (line.equals(Const.A09_OUT_TARGET_POSITION)) { - returnData = Integer.parseInt(plcMesObject.getPlcParameter("D03ToMES").getValue()); +// returnData = Integer.parseInt(plcMesObject.getPlcParameter("D03ToMES").getValue()); + returnData = glassIds1; } else { - returnData = Integer.parseInt(plcMesObject.getPlcParameter("D05ToMES").getValue()); +// returnData = Integer.parseInt(plcMesObject.getPlcParameter("D05ToMES").getValue()); + returnData = glassIds2; } // returnData = s7control.readWord(outLine, 1).get(0); - log.info("宸插悜plc绗瑊}娆″彂閫佽繘鐗囦换鍔$‘璁わ紝鍦板潃涓猴細{},鍐欏叆鐨勫唴瀹逛负{}", count++, outLine, 2); + log.info("宸插悜plc绗瑊}娆″彂閫佽繘鐗囦换鍔$‘璁わ紝鍦板潃涓猴細{},鍐欏叆鐨勫唴瀹逛负{},璇诲埌鐨勮姹備负{}", count++, outLine, 2,returnData); } +// while (returnData != 0) { +// s7control.writeWord(outLine, 2); +// if (line.equals(Const.A09_OUT_TARGET_POSITION)) { +//// returnData = Integer.parseInt(plcMesObject.getPlcParameter("D03ToMES").getValue()); +// returnData = s7control.readWord(plcMesObject.getPlcParameter("D03Request").getAddress(), 1).get(0); +// } else { +//// returnData = Integer.parseInt(plcMesObject.getPlcParameter("D05ToMES").getValue()); +// returnData = s7control.readWord(plcMesObject.getPlcParameter("D05Request").getAddress(), 1).get(0); +// } +//// returnData = s7control.readWord(outLine, 1).get(0); +// log.info("宸插悜plc绗瑊}娆″彂閫佽繘鐗囦换鍔$‘璁わ紝鍦板潃涓猴細{},鍐欏叆鐨勫唴瀹逛负{},璇诲埌鐨勮姹備负{}", count++, outLine, 2,returnData); +// } } /** -- Gitblit v1.8.0