From 4f5d1a4c178231bf0eb5db2f8e6f158fffbf5635 Mon Sep 17 00:00:00 2001 From: wangfei <3597712270@qq.com> Date: 星期一, 01 七月 2024 17:57:07 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes --- hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java | 118 ++++++++++++++++++++++++++++++++--------------------------- 1 files changed, 64 insertions(+), 54 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 13e1d47..27c9878 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 org.springframework.stereotype.Service; import javax.annotation.Resource; +import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.stream.Collectors; @@ -55,19 +56,33 @@ @Value("${mes.minCount}") private int minCount; + @Value("${mes.carWidth}") + private Integer carWidth; + + @Value("${mes.slotWidth}") + private Integer slotWidth; + + @Value("${mes.carMaxSize}") + private Integer carMaxSize; + + @Value("${mes.galssGap}") + private Integer galssGap; + /** * 鏌ヨ杩�/鍑虹墖浠诲姟 */ @Override public List<BigStorageCageDetails> selectTask(int taskType) { + if (taskType == 1) { //杩涚墖浠诲姟鏁版嵁 LambdaQueryWrapper<BigStorageCageDetails> feedWrapper = new LambdaQueryWrapper<>(); - feedWrapper.eq(BigStorageCageDetails::getState, 1) - .or() - .eq(BigStorageCageDetails::getState, 2); + feedWrapper.eq(BigStorageCageDetails::getState, Const.BIG_STORAGE_IN); List<BigStorageCageDetails> bigStorageCageDetailsList = baseMapper.selectList(feedWrapper); - List<BigStorageCageFeedTask> bigStorageCageFeedTaskList = bigStorageCageFeedTaskMapper.selectList(null); + + 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)); @@ -80,11 +95,12 @@ } else { //鍑虹墖浠诲姟鏁版嵁 LambdaQueryWrapper<BigStorageCageDetails> outWrapper = new LambdaQueryWrapper<>(); - outWrapper.eq(BigStorageCageDetails::getState, 3) - .or() - .eq(BigStorageCageDetails::getState, 4); + outWrapper.eq(BigStorageCageDetails::getState, Const.BIG_STORAGE_OUT); List<BigStorageCageDetails> bigStorageCageDetailsList = baseMapper.selectList(outWrapper); - List<BigStorageCageOutTask> bigStorageCageOutTaskList = bigStorageCageOutTaskMapper.selectList(null); + + 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)); @@ -94,7 +110,6 @@ } return bigStorageCageDetailsList; } - } /** @@ -122,7 +137,7 @@ for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList ) { if (bigStorageCageDetails.getBigStorageCageFeedTask().getTaskState() == 0) { - carWidth -= Integer.parseInt(bigStorageCageDetails.getWidth().toString()) + bigStorageCageDetails.getGap(); + carWidth = carWidth - bigStorageCageDetails.getWidth() - galssGap; } } return carWidth; @@ -139,7 +154,8 @@ //鐞嗙墖绗艰鎯呯牬鎹� @Override - public void damageBigStorageCageDetails(String glassId) { + public void damageBigStorageCageDetails(String glassId, int status) { + LambdaQueryWrapper<TemperingGlassInfo> temperingGlassInfoWrapper = new LambdaQueryWrapper<>(); temperingGlassInfoWrapper.eq(TemperingGlassInfo::getGlassId, glassId); TemperingGlassInfo temperingGlassInfo = temperingGlassInfoMapper.selectOne(temperingGlassInfoWrapper); @@ -148,13 +164,16 @@ bigStorageCageDetailsWrapper.eq(BigStorageCageDetails::getGlassId, glassId); BigStorageCageDetails bigStorageCageDetails = baseMapper.selectOne(bigStorageCageDetailsWrapper); - if (temperingGlassInfo.getState() == -2) { - temperingGlassInfoMapper.deleteById(temperingGlassInfo); - } else { - temperingGlassInfo.setState(5); + if (temperingGlassInfo != null) { + if (status == 0) { + temperingGlassInfo.setState(Const.TEMPERING_DAMAGE); + } else { + temperingGlassInfo.setState(Const.TEMPERING_TAKE); + } temperingGlassInfoMapper.updateById(temperingGlassInfo); } - baseMapper.deleteById(bigStorageCageDetails.getId()); + bigStorageCageDetails.setState(Const.BIG_STORAGE_OUTSIDE); + baseMapper.updateById(bigStorageCageDetails); bigStorageCageService.updateRemainWidth(bigStorageCageDetails.getSlot()); //todo:鎻掑叆鐮存崯鏁版嵁 @@ -162,15 +181,19 @@ //鏌ヨ鐜荤拑淇℃伅 @Override - public BigStorageCageDetails selectBigStorageCageDetails(String glassId) { + public List<BigStorageCageDetails> selectBigStorageCageDetails(String glassId) { LambdaQueryWrapper<GlassInfo> glassInfoWrapper = new LambdaQueryWrapper<>(); glassInfoWrapper.eq(GlassInfo::getGlassId, glassId); GlassInfo glassInfo = glassInfoMapper.selectOne(glassInfoWrapper); BigStorageCageDetails bigStorageCageDetails = new BigStorageCageDetails(); - BeanUtils.copyProperties(glassInfo, bigStorageCageDetails); - bigStorageCageDetails.setState(0); - bigStorageCageDetails.setGap(20); - return bigStorageCageDetails; + if (glassInfo != null) { + BeanUtils.copyProperties(glassInfo, bigStorageCageDetails); + bigStorageCageDetails.setState(0); + bigStorageCageDetails.setGap(galssGap); + } + List<BigStorageCageDetails> bigStorageCageDetailsList = new ArrayList<>(); + bigStorageCageDetailsList.add(bigStorageCageDetails); + return bigStorageCageDetailsList; } //鐞嗙墖绗艰鎯呮坊鍔� @@ -183,60 +206,48 @@ //鐞嗙墖绗艰鎯呭畬鎴� @Override public void finishBigStorageCageDetails(BigStorageCageDetails bigStorageCageDetails) { - if (bigStorageCageDetails.getState() == 1 || bigStorageCageDetails.getState() == 2) { - bigStorageCageDetails.setState(0); + if (bigStorageCageDetails.getBigStorageCageFeedTask() != null) { + bigStorageCageDetails.setState(Const.BIG_STORAGE_INSIDE); baseMapper.updateById(bigStorageCageDetails); - bigStorageCageFeedTaskMapper.deleteById(bigStorageCageDetails.getBigStorageCageFeedTask().getId()); } else { - baseMapper.deleteById(bigStorageCageDetails.getId()); - bigStorageCageOutTaskMapper.deleteById(bigStorageCageDetails.getBigStorageCageOutTask().getId()); + bigStorageCageDetails.setState(Const.BIG_STORAGE_OUTSIDE); + baseMapper.updateById(bigStorageCageDetails); + bigStorageCageService.updateRemainWidth(bigStorageCageDetails.getSlot()); } - } //鎵嬪姩鍑虹墖 @Override public void outBigStorageCageDetails(BigStorageCageDetails bigStorageCageDetails) { - LambdaQueryWrapper<TemperingGlassInfo> temperingGlassInfoWrapper = new LambdaQueryWrapper<>(); - temperingGlassInfoWrapper - .eq(TemperingGlassInfo::getGlassId, bigStorageCageDetails.getGlassId()); - TemperingGlassInfo temperingGlassInfo = temperingGlassInfoMapper.selectOne(temperingGlassInfoWrapper); - if (temperingGlassInfo.getGlassId() == null) { - LambdaQueryWrapper<GlassInfo> glassInfoWrapper = new LambdaQueryWrapper<>(); - glassInfoWrapper - .eq(GlassInfo::getGlassId, bigStorageCageDetails.getGlassId()); - GlassInfo glassInfo = glassInfoMapper.selectOne(glassInfoWrapper); - TemperingGlassInfo temperingGlassInfo1 = new TemperingGlassInfo(); - BeanUtils.copyProperties(glassInfo, temperingGlassInfo1); - - if (temperingGlassInfo.getTemperingLayoutId() != null) { - temperingGlassInfo1.setState(-1); - } else { - temperingGlassInfo1.setState(-2); - } - temperingGlassInfoMapper.insert(temperingGlassInfo1); - } + bigStorageCageDetails.setState(4); + baseMapper.updateById(bigStorageCageDetails); } @Override public BigStorageDTO queryTargetSlotByTempering(GlassInfo glassInfo) { BigStorageDTO bigStorageDTO = null; MPJLambdaWrapper<BigStorageCage> wrapper = new MPJLambdaWrapper<>(BigStorageCage.class) - .selectAsClass(BigStorageCage.class, BigStorageDTO.class) + .selectAll(BigStorageCage.class) .leftJoin(BigStorageCageDetails.class, BigStorageCageDetails::getSlot, BigStorageCage::getSlot) + .eq(BigStorageCage::getEnableState, Const.SLOT_ON) .eq(BigStorageCageDetails::getTemperingLayoutId, glassInfo.getTemperingLayoutId()) + .gt(BigStorageCage::getRemainWidth, glassInfo.getWidth()) .last("limit 1"); if (glassInfo.getTemperingLayoutId() == 0) { wrapper.eq(BigStorageCageDetails::getWidth, glassInfo.getWidth()).eq(BigStorageCageDetails::getHeight, glassInfo.getHeight()); } else { wrapper.eq(BigStorageCageDetails::getTemperingFeedSequence, glassInfo.getTemperingFeedSequence() + 1); } - bigStorageDTO = bigStorageCageService.selectJoinOne(BigStorageDTO.class, wrapper); - if (null != bigStorageDTO) { + BigStorageCage bigStorageCage = bigStorageCageService.selectJoinOne(BigStorageCage.class, wrapper); + if (null != bigStorageCage) { + bigStorageDTO = new BigStorageDTO(); + bigStorageDTO.setWidth(bigStorageCage.getRemainWidth()); + bigStorageDTO.setSlot(bigStorageCage.getSlot()); return bigStorageDTO; } - BigStorageCage bigStorageCage = bigStorageCageService.getOne(new LambdaQueryWrapper<BigStorageCage>() - .eq(BigStorageCage::getRemainWidth, Const.BIG_STORAGE_WIDTH) + bigStorageCage = bigStorageCageService.getOne(new LambdaQueryWrapper<BigStorageCage>() + .eq(BigStorageCage::getEnableState, Const.SLOT_ON) + .eq(BigStorageCage::getRemainWidth, slotWidth) .inSql(BigStorageCage::getDeviceId, "select distinct device_id from big_storage_cage_details where tempering_layout_id = " + glassInfo.getTemperingLayoutId()) .last("limit 1")); @@ -247,15 +258,14 @@ return bigStorageDTO; } bigStorageCage = bigStorageCageService.getOne(new LambdaQueryWrapper<BigStorageCage>() - .eq(BigStorageCage::getRemainWidth, Const.BIG_STORAGE_WIDTH) + .eq(BigStorageCage::getRemainWidth, slotWidth) + .eq(BigStorageCage::getEnableState, Const.SLOT_ON) .last("limit 1")); Assert.isTrue(null != bigStorageCage, "娌℃湁绌轰綑鐨勭瀛愬瓨鏀剧幓鐠�"); bigStorageDTO = new BigStorageDTO(); bigStorageDTO.setWidth(bigStorageCage.getRemainWidth()); bigStorageDTO.setSlot(bigStorageCage.getSlot()); return bigStorageDTO; - - } @Override -- Gitblit v1.8.0