From f481c5fe4fc2aa80c77a760f4161e4ab3912cb45 Mon Sep 17 00:00:00 2001 From: zhoushihao <zsh19950802@163.com> Date: 星期六, 06 七月 2024 15:07:01 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java | 87 +++++++++++++++++++++++++------------------ 1 files changed, 50 insertions(+), 37 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java index f4f42f3..2f2dacc 100644 --- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java +++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java @@ -26,6 +26,7 @@ import javax.annotation.Resource; import java.util.ArrayList; +import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.stream.Collectors; @@ -66,43 +67,55 @@ */ @Override public List<BigStorageCageDetails> selectTask(int taskType) { - return null; -// if (taskType == 1) { -// //杩涚墖浠诲姟鏁版嵁 -// LambdaQueryWrapper<BigStorageCageDetails> feedWrapper = new LambdaQueryWrapper<>(); -// feedWrapper.eq(BigStorageCageDetails::getState, Const.BIG_STORAGE_IN); -// List<BigStorageCageDetails> bigStorageCageDetailsList = baseMapper.selectList(feedWrapper); -// -// LambdaQueryWrapper<BigStorageCageFeedTask> feedTaskWrapper = new LambdaQueryWrapper<>(); -// feedTaskWrapper.lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT); -// List<BigStorageCageFeedTask> bigStorageCageFeedTaskList = bigStorageCageFeedTaskMapper.selectList(feedTaskWrapper); -// -// Map<String, BigStorageCageFeedTask> listMap = bigStorageCageFeedTaskList.stream() -// .collect(Collectors.toMap(BigStorageCageFeedTask::getGlassId, task -> task)); -// -// for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList) { -// BigStorageCageFeedTask bigStorageCageFeedTask = listMap.get(bigStorageCageDetails.getGlassId()); -// bigStorageCageDetails.setBigStorageCageFeedTask(bigStorageCageFeedTask); -// } -// return bigStorageCageDetailsList; -// } else { -// //鍑虹墖浠诲姟鏁版嵁 -// LambdaQueryWrapper<BigStorageCageDetails> outWrapper = new LambdaQueryWrapper<>(); -// outWrapper.eq(BigStorageCageDetails::getState, Const.BIG_STORAGE_OUT); -// List<BigStorageCageDetails> bigStorageCageDetailsList = baseMapper.selectList(outWrapper); -// -// LambdaQueryWrapper<BigStorageCageOutTask> outTaskWrapper = new LambdaQueryWrapper<>(); -// outTaskWrapper.lt(BigStorageCageOutTask::getTaskState, Const.BIG_STORAGE_OUT_SUCCESS); -// List<BigStorageCageOutTask> bigStorageCageOutTaskList = bigStorageCageOutTaskMapper.selectList(outTaskWrapper); -// -// Map<String, BigStorageCageOutTask> listMap = bigStorageCageOutTaskList.stream() -// .collect(Collectors.toMap(BigStorageCageOutTask::getGlassId, task -> task)); -// for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList) { -// BigStorageCageOutTask bigStorageCageOutTask = listMap.get(bigStorageCageDetails.getGlassId()); -// bigStorageCageDetails.setBigStorageCageOutTask(bigStorageCageOutTask); -// } -// return bigStorageCageDetailsList; -// } + if (taskType == 1) { + //杩涚墖浠诲姟鏁版嵁 + LambdaQueryWrapper<BigStorageCageDetails> feedWrapper = new LambdaQueryWrapper<>(); + feedWrapper.eq(BigStorageCageDetails::getState, Const.GLASS_STATE_IN); + List<BigStorageCageDetails> bigStorageCageDetailsList = baseMapper.selectList(feedWrapper); + + LambdaQueryWrapper<BigStorageCageFeedTask> feedTaskWrapper = new LambdaQueryWrapper<>(); + feedTaskWrapper.lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT); + List<BigStorageCageFeedTask> bigStorageCageFeedTaskList = bigStorageCageFeedTaskMapper.selectList(feedTaskWrapper); + + Map<String, BigStorageCageFeedTask> listMap = bigStorageCageFeedTaskList.stream() + .collect(Collectors.toMap(BigStorageCageFeedTask::getGlassId, task -> task)); + Iterator<BigStorageCageDetails> iterator = bigStorageCageDetailsList.iterator(); + while (iterator.hasNext()) { + BigStorageCageDetails bigStorageCageDetails = iterator.next(); + BigStorageCageFeedTask bigStorageCageFeedTask = listMap.get(bigStorageCageDetails.getGlassId()); + bigStorageCageDetails.setBigStorageCageFeedTask(bigStorageCageFeedTask); + if (bigStorageCageDetails.getBigStorageCageFeedTask() == null) { + iterator.remove(); + } + } + return bigStorageCageDetailsList; + } else { + //鍑虹墖浠诲姟鏁版嵁 + LambdaQueryWrapper<BigStorageCageDetails> outWrapper = new LambdaQueryWrapper<>(); + outWrapper.eq(BigStorageCageDetails::getState, Const.GLASS_STATE_IN); + List<BigStorageCageDetails> bigStorageCageDetailsList = baseMapper.selectList(outWrapper); + + LambdaQueryWrapper<BigStorageCageOutTask> outTaskWrapper = new LambdaQueryWrapper<>(); + outTaskWrapper.lt(BigStorageCageOutTask::getTaskState, Const.BIG_STORAGE_OUT_SUCCESS); + List<BigStorageCageOutTask> bigStorageCageOutTaskList = bigStorageCageOutTaskMapper.selectList(outTaskWrapper); + + Map<String, BigStorageCageOutTask> listMap = bigStorageCageOutTaskList.stream() + .collect(Collectors.toMap(BigStorageCageOutTask::getGlassId, task -> task)); + for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList) { + BigStorageCageOutTask bigStorageCageOutTask = listMap.get(bigStorageCageDetails.getGlassId()); + bigStorageCageDetails.setBigStorageCageOutTask(bigStorageCageOutTask); + } + Iterator<BigStorageCageDetails> iterator = bigStorageCageDetailsList.iterator(); + while (iterator.hasNext()) { + BigStorageCageDetails bigStorageCageDetails = iterator.next(); + BigStorageCageOutTask bigStorageCageOutTask = listMap.get(bigStorageCageDetails.getGlassId()); + bigStorageCageDetails.setBigStorageCageOutTask(bigStorageCageOutTask); + if (bigStorageCageDetails.getBigStorageCageOutTask() == null) { + iterator.remove(); + } + } + return bigStorageCageDetailsList; + } } /** -- Gitblit v1.8.0