From 31c0c608f884ab548ba4c57ebcddef6f46da460e Mon Sep 17 00:00:00 2001 From: zhoushihao <zsh19950802@163.com> Date: 星期四, 09 五月 2024 13:15:06 +0800 Subject: [PATCH] 卧式理片笼进出片任务优化 --- hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java | 142 +++++++++++++++++++++++++++++------------------ 1 files changed, 87 insertions(+), 55 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java index d3d0768..322ea68 100644 --- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java +++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java @@ -1,10 +1,10 @@ package com.mes.edgstoragecage.service.impl; +import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.github.yulichang.base.MPJBaseServiceImpl; import com.github.yulichang.query.MPJLambdaQueryWrapper; -import com.github.yulichang.query.MPJQueryWrapper; import com.github.yulichang.toolkit.JoinWrappers; import com.github.yulichang.wrapper.MPJLambdaWrapper; import com.mes.edgstoragecage.entity.EdgStorageCage; @@ -16,13 +16,18 @@ import com.mes.pp.entity.OptimizeLayout; import com.mes.pp.mapper.OptimizeDetailMapper; import com.mes.taskcache.entity.TaskCache; +import com.mes.taskcache.service.TaskCacheService; import com.mes.uppattenusage.entity.UpPattenUsage; import com.mes.uppattenusage.mapper.UpPattenUsageMapper; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; + +import javax.annotation.Resource; import java.util.List; import java.util.Map; -import java.util.Objects; +import java.util.stream.Collectors; /** * <p> @@ -33,28 +38,36 @@ * @since 2024-04-07 */ @Service +@Slf4j public class EdgStorageCageDetailsServiceImpl extends MPJBaseServiceImpl<EdgStorageCageDetailsMapper, EdgStorageCageDetails> implements EdgStorageCageDetailsService { - @Autowired + @Resource UpPattenUsageMapper upPattenUsageMapper; + @Autowired OptimizeDetailMapper optimizeDetailMapper; - @Autowired + @Resource EdgStorageCageMapper edgStorageCageMapper; + + @Autowired + TaskCacheService taskCacheService; + /** * 璇嗗埆 鎷胯蛋:200/鐮存崯:201 + * * @param glassId * @param ControlsId * @return */ + @Override public boolean identWorn(String glassId, int ControlsId) { - List<EdgStorageCageDetails> edgStorageCageDetails = baseMapper.selectList(new MPJLambdaQueryWrapper<EdgStorageCageDetails>().selectAll(EdgStorageCageDetails.class).eq(EdgStorageCageDetails::getGlassId,glassId)); + List<EdgStorageCageDetails> edgStorageCageDetails = baseMapper.selectList(new MPJLambdaQueryWrapper<EdgStorageCageDetails>().selectAll(EdgStorageCageDetails.class).eq(EdgStorageCageDetails::getGlassId, glassId)); if (edgStorageCageDetails.size() == 1) { - EdgStorageCageDetails item=edgStorageCageDetails.get(0); + EdgStorageCageDetails item = edgStorageCageDetails.get(0); item.setState(ControlsId); - baseMapper.update(edgStorageCageDetails.get(0), new MPJLambdaWrapper<EdgStorageCageDetails>().selectAll(EdgStorageCageDetails.class).eq(EdgStorageCageDetails::getGlassId,glassId)); + baseMapper.update(edgStorageCageDetails.get(0), new MPJLambdaWrapper<EdgStorageCageDetails>().selectAll(EdgStorageCageDetails.class).eq(EdgStorageCageDetails::getGlassId, glassId)); return true; } // Sql鐗堟湰 @@ -70,25 +83,26 @@ /** * 鑾峰彇 鍒囧壊褰撳墠鐗堝浘 + * * @return */ @Override public List<Map<String, Object>> selectCutTerritory() { - List<UpPattenUsage> upPattenUsage=upPattenUsageMapper.selectList(new MPJLambdaWrapper<UpPattenUsage>() + List<UpPattenUsage> upPattenUsage = upPattenUsageMapper.selectList(new MPJLambdaWrapper<UpPattenUsage>() .selectAll(UpPattenUsage.class) .eq(UpPattenUsage::getState, 1)); - if(!upPattenUsage.isEmpty()){ - UpPattenUsage upPattenUsage1=upPattenUsage.get(0); + if (!upPattenUsage.isEmpty()) { + UpPattenUsage upPattenUsage1 = upPattenUsage.get(0); return optimizeDetailMapper.selectJoinMaps(JoinWrappers.lambda(OptimizeDetail.class) .selectAll(OptimizeDetail.class) - .selectAs(OptimizeLayout::getWidth,"olWidth") - .selectAs(OptimizeLayout::getWidth,"olHeight") - .leftJoin(OptimizeLayout.class,on->on - .eq(OptimizeLayout::getProjectNo,OptimizeDetail::getProjectNo) - .eq(OptimizeLayout::getStockId,OptimizeDetail::getStockId)) + .selectAs(OptimizeLayout::getWidth, "olWidth") + .selectAs(OptimizeLayout::getWidth, "olHeight") + .leftJoin(OptimizeLayout.class, on -> on + .eq(OptimizeLayout::getProjectNo, OptimizeDetail::getProjectNo) + .eq(OptimizeLayout::getStockId, OptimizeDetail::getStockId)) .eq(OptimizeDetail::getProjectNo, upPattenUsage1.getEngineeringId()) - .eq(OptimizeDetail::getStockId,upPattenUsage1.getLayoutSequence()) + .eq(OptimizeDetail::getStockId, upPattenUsage1.getLayoutSequence()) ); // Sql鐗堟湰 @@ -104,6 +118,7 @@ /** * 鑾峰彇 宸ョ▼涓嬬殑褰撳墠鐗堝浘 + * * @param current * @return */ @@ -112,11 +127,11 @@ return optimizeDetailMapper.selectJoinMaps(JoinWrappers.lambda(OptimizeDetail.class) .selectAll(OptimizeDetail.class) - .selectAs(OptimizeLayout::getWidth,"olWidth") - .selectAs(OptimizeLayout::getWidth,"olHeight") - .leftJoin(OptimizeLayout.class,on->on - .eq(OptimizeLayout::getProjectNo,OptimizeDetail::getProjectNo) - .eq(OptimizeLayout::getStockId,OptimizeDetail::getStockId)) + .selectAs(OptimizeLayout::getWidth, "olWidth") + .selectAs(OptimizeLayout::getWidth, "olHeight") + .leftJoin(OptimizeLayout.class, on -> on + .eq(OptimizeLayout::getProjectNo, OptimizeDetail::getProjectNo) + .eq(OptimizeLayout::getStockId, OptimizeDetail::getStockId)) .eq(OptimizeDetail::getProjectNo, current) ); //Sql鐗堟湰 @@ -129,54 +144,71 @@ /** * 鏌ヨ绗煎唴鐗堝浘宸�艰寖鍥村唴鐨� 姝ゅ昂瀵哥幓鐠� 濡傛棤鍒欐寜鐓� 閽㈠寲鐗堝浘搴忓彿 浠ュ強鐜荤拑搴忓彿 + * * @param glassId * @param poor * @return */ @Override - public EdgStorageCageDetails selectConformGlass(String glassId, int poor){ + public EdgStorageCageDetails selectConformGlass(String glassId, int poor) { //1.鍘荤鍐呮煡璇㈡灏哄鐨勭幓鐠� 鐩墠鐗堝浘宸�煎唴鐨勭幓鐠� 鏄惁鏈夊悓灏哄鐨� //1.1 鏈夊悓灏哄鐨� 鍒欑敓鎴愬悓灏哄鐨勪换鍔� //1.2 鏃犲悓灏哄鐨� 鍒欑敓鎴愮増鍥鹃『搴忔渶灏忕殑鍑虹墖 - EdgStorageCageDetails edgStorageCageDetails= baseMapper.selectOne(new MPJLambdaQueryWrapper<EdgStorageCageDetails>() - .selectAll(EdgStorageCageDetails.class) - .eq(EdgStorageCageDetails::getGlassId,glassId) - ); - List<EdgStorageCageDetails> listEdgStorageCageDetails= baseMapper.selectList(new LambdaQueryWrapper<EdgStorageCageDetails>() - .lt(EdgStorageCageDetails::getState,200) - .orderByAsc(EdgStorageCageDetails::getTemperingLayoutId,EdgStorageCageDetails::getTemperingFeedSequence) - ); - EdgStorageCageDetails minTemperingLayoutId=new EdgStorageCageDetails(); - if(!listEdgStorageCageDetails.isEmpty()){ - minTemperingLayoutId=listEdgStorageCageDetails.get(0); - } - EdgStorageCageDetails result=new EdgStorageCageDetails(); - if(edgStorageCageDetails!=null&&minTemperingLayoutId!=null){ - result=edgStorageCageMapper.selectJoinOne(EdgStorageCageDetails.class,new MPJLambdaWrapper<EdgStorageCage>() + log.info("鎸夌収鐜荤拑id锛歿}鑾峰彇鐜荤拑淇℃伅", glassId); + EdgStorageCageDetails oldEdgStorageCageDetails = null; + if (StringUtils.isNotEmpty(glassId)) { + oldEdgStorageCageDetails = baseMapper.selectOne(new MPJLambdaQueryWrapper<EdgStorageCageDetails>() .selectAll(EdgStorageCageDetails.class) - .leftJoin(EdgStorageCageDetails.class,on->on - .eq(EdgStorageCageDetails::getDeviceId,EdgStorageCage::getDeviceId) - .eq(EdgStorageCageDetails::getSlot,EdgStorageCage::getSlot)) - .isNotNull(EdgStorageCageDetails::getSlot) - .eq(EdgStorageCageDetails::getWidth,edgStorageCageDetails.getWidth()) - .eq(EdgStorageCageDetails::getHeight,edgStorageCageDetails.getHeight()) - .ge(EdgStorageCageDetails::getTemperingLayoutId,minTemperingLayoutId.getTemperingLayoutId()) - .le(EdgStorageCageDetails::getTemperingLayoutId,minTemperingLayoutId.getTemperingLayoutId()+poor) - .orderByAsc(EdgStorageCageDetails::getTemperingLayoutId,EdgStorageCageDetails::getTemperingFeedSequence) - ); + .eq(EdgStorageCageDetails::getGlassId, glassId)); } - if (result==null){ - result=edgStorageCageMapper.selectJoinOne(EdgStorageCageDetails.class,new MPJLambdaWrapper<EdgStorageCage>() + LambdaQueryWrapper<TaskCache> wrapper = new LambdaQueryWrapper<TaskCache>().select(TaskCache::getGlassId).eq(TaskCache::getTaskType, "2"); + List<TaskCache> taskCacheList = taskCacheService.list(wrapper); + List<String> glassIds = taskCacheList.stream().map(TaskCache::getGlassId).collect(Collectors.toList()); + log.info("鑾峰彇绗煎唴鎵�鏈夊凡鍑虹墖鐨勭幓鐠僫d淇℃伅:{}", glassIds); + + EdgStorageCageDetails minTemperingLayoutId = baseMapper.selectOne(new LambdaQueryWrapper<EdgStorageCageDetails>() + .eq(EdgStorageCageDetails::getState, 100) + .notIn(CollectionUtils.isNotEmpty(glassIds), EdgStorageCageDetails::getGlassId, glassIds) + .orderByAsc(EdgStorageCageDetails::getTemperingLayoutId, EdgStorageCageDetails::getTemperingFeedSequence) + .last("limit 1")); + Assert.isTrue(minTemperingLayoutId != null, "绗煎唴鏃犵鍚堣姹傜殑鐜荤拑"); + log.info("鑾峰彇绗煎唴鏈�灏忕増鍥緄d{}鍙婄増搴忎负{}鐨勭幓鐠冧俊鎭瘂}", minTemperingLayoutId.getTemperingLayoutId(), + minTemperingLayoutId.getTemperingFeedSequence(), minTemperingLayoutId); + + EdgStorageCageDetails outEdgStorageCageDetails = null; + if (oldEdgStorageCageDetails != null && minTemperingLayoutId != null) { + log.info("鎸夌収涓婁竴鐗囧凡鍑虹幓鐠冨搴}锛岄珮搴}锛屽強鐗堝浘id鍖洪棿{}鍒皗}鑾峰彇鍑虹墖浠诲姟鐜荤拑淇℃伅", oldEdgStorageCageDetails.getWidth() + , oldEdgStorageCageDetails.getHeight(), minTemperingLayoutId.getTemperingLayoutId(), minTemperingLayoutId.getTemperingLayoutId() + poor); + outEdgStorageCageDetails = edgStorageCageMapper.selectJoinOne(EdgStorageCageDetails.class, new MPJLambdaWrapper<EdgStorageCage>() .selectAll(EdgStorageCageDetails.class) - .leftJoin(EdgStorageCageDetails.class,on->on - .eq(EdgStorageCageDetails::getDeviceId,EdgStorageCage::getDeviceId) - .eq(EdgStorageCageDetails::getSlot,EdgStorageCage::getSlot)) + .leftJoin(EdgStorageCageDetails.class, on -> on + .eq(EdgStorageCageDetails::getDeviceId, EdgStorageCage::getDeviceId) + .eq(EdgStorageCageDetails::getSlot, EdgStorageCage::getSlot)) .isNotNull(EdgStorageCageDetails::getSlot) - .orderByAsc(EdgStorageCageDetails::getTemperingLayoutId,EdgStorageCageDetails::getTemperingFeedSequence) + .eq(EdgStorageCageDetails::getWidth, oldEdgStorageCageDetails.getWidth()) + .eq(EdgStorageCageDetails::getHeight, oldEdgStorageCageDetails.getHeight()) + .ge(EdgStorageCageDetails::getTemperingLayoutId, minTemperingLayoutId.getTemperingLayoutId()) + .le(EdgStorageCageDetails::getTemperingLayoutId, minTemperingLayoutId.getTemperingLayoutId() + poor) + .orderByAsc(EdgStorageCageDetails::getTemperingLayoutId, EdgStorageCageDetails::getTemperingFeedSequence) + .last("limit 1") ); + log.info("鍑虹墖浠诲姟鐨勭幓鐠冧俊鎭細{}", outEdgStorageCageDetails); } - return result; + + if (outEdgStorageCageDetails == null) { + outEdgStorageCageDetails = minTemperingLayoutId; +// outEdgStorageCageDetails = edgStorageCageMapper.selectJoinOne(EdgStorageCageDetails.class, new MPJLambdaWrapper<EdgStorageCage>() +// .selectAll(EdgStorageCageDetails.class) +// .leftJoin(EdgStorageCageDetails.class, on -> on +// .eq(EdgStorageCageDetails::getDeviceId, EdgStorageCage::getDeviceId) +// .eq(EdgStorageCageDetails::getSlot, EdgStorageCage::getSlot)) +// .isNotNull(EdgStorageCageDetails::getSlot) +// .orderByAsc(EdgStorageCageDetails::getTemperingLayoutId, EdgStorageCageDetails::getTemperingFeedSequence) +// .last("limit 1") +// ); + } + return outEdgStorageCageDetails; } } -- Gitblit v1.8.0