From c84171a757c5f45921a20a27ab0ede9fc3e529d9 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期二, 24 九月 2024 14:45:50 +0800
Subject: [PATCH] 钢化对接：避免同一炉玻璃反复向plc发送
---
hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/TemperingTask.java | 35 +++++++++--------------------------
1 files changed, 9 insertions(+), 26 deletions(-)
diff --git a/hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/TemperingTask.java b/hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/TemperingTask.java
index 86343e1..2ff37a9 100644
--- a/hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/TemperingTask.java
+++ b/hangzhoumesParent/moduleService/TemperingGlassModule/src/main/java/com/mes/job/TemperingTask.java
@@ -76,33 +76,16 @@
log.info("褰撳墠绯荤粺娌℃湁闇�瑕侀挗鍖栫殑鐜荤拑淇℃伅");
return;
}
- TemperingGlassInfo maxGlassInfo = temperingGlassInfoList.stream().max(Comparator.comparingLong(TemperingGlassInfo::getId)).get();
//鎷垮埌宸ョ▼id鍙婄倝鍙�
-// List<EngineerTemperingDTO> engineerTemperingList = temperingGlassInfoList.stream().map(e -> {
-// EngineerTemperingDTO engineerTemperingDTO = new EngineerTemperingDTO();
-// BeanUtils.copyProperties(e, engineerTemperingDTO);
-// return engineerTemperingDTO;
-// }).distinct().collect(Collectors.toList());
- //灏嗘鍦ㄩ挗鍖栫殑鐐夊彿杩囨护鎺夛紝浠呰幏鍙栧緟閽㈠寲鐨勭幓鐠�
-// List<TemperingRecord> temperingRecords = temperingRecordService.list(new LambdaQueryWrapper<TemperingRecord>().and(i -> i.isNull(TemperingRecord::getCoolEnergy).or().eq(TemperingRecord::getCoolEnergy, "")));
-// List<EngineerTemperingDTO> temperingList = new ArrayList<>();
-// if (CollectionUtils.isNotEmpty(temperingRecords)) {
-// temperingList = temperingRecords.stream().map(e -> {
-// EngineerTemperingDTO engineerTemperingDTO = new EngineerTemperingDTO();
-// BeanUtils.copyProperties(e, engineerTemperingDTO);
-// return engineerTemperingDTO;
-// }).collect(Collectors.toList());
-// }
-// engineerTemperingList.removeAll(temperingList);
-// if (CollectionUtils.isEmpty(engineerTemperingList)) {
-// log.info("娌℃湁寰呴挗鍖栫殑浠诲姟锛岀粨鏉�");
-// return;
-// }
-// if (engineerTemperingList.size() > 1) {
-// log.info("瀛樺湪澶氱倝寰呴挗鍖栫殑浠诲姟锛岃妫�鏌ョ幇鍦烘槸鍚︽湁寮傚父鏁版嵁鏈鐞�");
-// return;
-// }
-// EngineerTemperingDTO temperingDTO = engineerTemperingList.get(0);
+ TemperingGlassInfo maxGlassInfo = temperingGlassInfoList.stream().max(Comparator.comparingLong(TemperingGlassInfo::getId)).get();
+
+ //灏嗘鍦ㄩ挗鍖栫殑鐐夊彿杩囨护鎺夛紝浠呰幏鍙栧緟閽㈠寲鐨勭幓鐠�:鍒ゆ柇寰呴挗鐨勭幓鐠冩槸鍚﹀凡鍙戦�佸鎺ユ暟鎹�
+ List<TemperingRecord> temperingRecordList = temperingRecordService.list(new LambdaQueryWrapper<TemperingRecord>().eq(TemperingRecord::getEngineerId, maxGlassInfo.getEngineerId())
+ .eq(TemperingRecord::getTemperingLayoutId, maxGlassInfo.getTemperingLayoutId()));
+ if (CollectionUtils.isNotEmpty(temperingRecordList)) {
+ log.info("娌℃湁寰呴挗鍖栫殑浠诲姟锛岀粨鏉�");
+ return;
+ }
//鑾峰彇寰呴挗鍖栫殑鎵�鏈夌幓鐠冧俊鎭�
List<TemperingGlassInfo> temperingGlassList = temperingGlassInfoList.stream()
.filter(e -> e.getEngineerId().equals(maxGlassInfo.getEngineerId())
--
Gitblit v1.8.0