From dbbf0c051ef05480a0becee07974b80e32b1cb8f Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期二, 20 五月 2025 11:38:31 +0800 Subject: [PATCH] 提交阿尔及及利亚项目改动 --- hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java | 70 +++++++++++++++++++++++++---------- 1 files changed, 50 insertions(+), 20 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 353c9d1..b0aa717 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 @@ -15,25 +15,28 @@ import com.mes.bigstorage.mapper.BigStorageCageDetailsMapper; import com.mes.bigstorage.service.BigStorageCageDetailsService; import com.mes.bigstorage.service.BigStorageCageService; +import com.mes.bigstoragecagetask.entity.BigStorageCageHistoryTask; +import com.mes.bigstoragecagetask.service.BigStorageCageHistoryTaskService; import com.mes.bigstoragetask.entity.BigStorageCageFeedTask; import com.mes.bigstoragetask.entity.BigStorageCageOutTask; import com.mes.bigstoragetask.entity.UpdateBigStorageCageDTO; import com.mes.bigstoragetask.mapper.BigStorageCageFeedTaskMapper; import com.mes.bigstoragetask.mapper.BigStorageCageOutTaskMapper; import com.mes.common.config.Const; +import com.mes.common.config.ConstSysConfig; import com.mes.damage.entity.Damage; import com.mes.damage.service.DamageService; import com.mes.glassinfo.entity.GlassInfo; import com.mes.glassinfo.mapper.GlassInfoMapper; import com.mes.glassinfo.service.GlassInfoService; -import com.mes.job.PlcStorageCageTask; +import com.mes.sysconfig.entity.SysConfig; +import com.mes.sysconfig.service.SysConfigService; import com.mes.temperingglass.entity.TemperingGlassInfo; import com.mes.temperingglass.mapper.TemperingGlassInfoMapper; import com.mes.temperingglass.service.TemperingGlassInfoService; import com.mes.utils.RedisUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; -import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import javax.annotation.Resource; @@ -71,26 +74,31 @@ @Resource private TemperingGlassInfoService temperingGlassInfoService; - @Resource - private PlcStorageCageTask plcStorageCageTask; + private SysConfigService sysConfigService; + +// @Resource +// private PlcStorageCageTask plcStorageCageTask; @Resource private DamageService damageService; @Resource private RedisUtil redisUtil; - @Value("${mes.minCount}") - private int minCount; - - @Value("${mes.slotWidth}") - private Integer slotWidth; - - @Value("${mes.glassGap}") - private Integer glassGap; - - @Value("${mes.sequence.order}") - private boolean sequenceOrder; + @Resource + BigStorageCageHistoryTaskService bigStorageCageHistoryTaskService; +// +// @Value("${mes.minCount}") +// private int minCount; +// +// @Value("${mes.slotWidth}") +// private Integer slotWidth; +// +// @Value("${mes.glassGap}") +// private Integer glassGap; +// +// @Value("${mes.sequence.order}") +// private boolean sequenceOrder; @Override @@ -166,7 +174,7 @@ for (BigStorageCageDetails bigStorageCageDetails : bigStorageCageDetailsList ) { if (bigStorageCageDetails.getBigStorageCageFeedTask().getTaskState() == 0) { - carWidth = carWidth - bigStorageCageDetails.getWidth() - glassGap; + carWidth = carWidth - bigStorageCageDetails.getWidth() - 250; } } return carWidth; @@ -232,7 +240,7 @@ if (glassInfo != null) { BeanUtils.copyProperties(glassInfo, bigStorageCageDetails); bigStorageCageDetails.setState(1); - bigStorageCageDetails.setGap(glassGap); + bigStorageCageDetails.setGap(250); bigStorageCageDetailsList = new ArrayList<>(); bigStorageCageDetailsList.add(bigStorageCageDetails); } @@ -270,6 +278,7 @@ @Override public BigStorageDTO queryTargetSlotByTempering(GlassInfo glassInfo) { BigStorageDTO bigStorageDTO = null; + int slotWidth = sysConfigService.queryConfigValue(ConstSysConfig.VERTICAL_SLOT_WIDTH); MPJLambdaWrapper<BigStorageCage> wrapper = new MPJLambdaWrapper<>(BigStorageCage.class) .selectAll(BigStorageCage.class) .leftJoin(BigStorageCageDetails.class, BigStorageCageDetails::getSlot, BigStorageCage::getSlot) @@ -381,7 +390,7 @@ @Override public List<TemperingLayoutDTO> queryTemperingOccupySlot() { - return baseMapper.queryTemperingOccupySlot(minCount); + return baseMapper.queryTemperingOccupySlot(10); } @Override @@ -392,6 +401,8 @@ @Override public boolean temperingGlass(String temperingLayoutId, String engineerId, String temperingFeedSequence) { LambdaQueryWrapper<TemperingGlassInfo> temperingGlassInfoLambdaQueryWrapper = new LambdaQueryWrapper<>(); + SysConfig sysConfig = sysConfigService.queryConfigById(ConstSysConfig.CACHE_SEQUENCE_ORDER_TRUE); + boolean sequenceOrder = Boolean.parseBoolean(sysConfig.getConfigValue()); temperingGlassInfoLambdaQueryWrapper .eq(TemperingGlassInfo::getState, Const.TEMPERING_NEW); List<TemperingGlassInfo> temperingGlassInfoList = temperingGlassInfoMapper.selectList(temperingGlassInfoLambdaQueryWrapper); @@ -409,7 +420,7 @@ if (CollectionUtils.isNotEmpty(temperingGlassInfos)) { if ("0".equals(temperingFeedSequence)) { if (CollectionUtils.isNotEmpty(temperingGlassInfos)) { - plcStorageCageTask.computeOutMoreGlassInfo(temperingGlassInfos, Boolean.FALSE, ""); +// plcStorageCageTask.computeOutMoreGlassInfo(temperingGlassInfos, Boolean.FALSE, ""); } } else { temperingGlassInfoService.saveBatch(temperingGlassInfos); @@ -458,7 +469,26 @@ @Override public boolean cancelTemperingTask() { - return false; + //褰撳墠姝e湪鎵ц鐨勫嚭鐗囦换鍔� + List<BigStorageCageHistoryTask> historyTaskList = bigStorageCageHistoryTaskService.list(new LambdaQueryWrapper<BigStorageCageHistoryTask>() + .eq(BigStorageCageHistoryTask::getTaskState, Const.GLASS_STATE_NEW) + .eq(BigStorageCageHistoryTask::getTargetSlot, Const.TEMPERING_OUT_TARGET_POSITION)); + //涓嶅瓨鍦ㄥ嚭鐗囦换鍔★紝鐩存帴鍒犻櫎閽㈠寲灏忕墖琛ㄦ湭鍑虹墖鐨勪换鍔� + if (CollectionUtils.isEmpty(historyTaskList)) { + temperingGlassInfoMapper.delete(new LambdaQueryWrapper<TemperingGlassInfo>().eq(TemperingGlassInfo::getState, Const.TEMPERING_NEW)); + return Boolean.TRUE; + } + //瀛樺湪鍑虹墖浠诲姟锛屽垹闄ら挗鍖栧皬鐗囪〃 + List<String> glassIdList = historyTaskList.stream().map(BigStorageCageHistoryTask::getGlassId).collect(Collectors.toList()); + GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().in(GlassInfo::getGlassId, glassIdList) + .orderByDesc(GlassInfo::getTemperingFeedSequence).last("limit 1")); + temperingGlassInfoMapper.delete(new LambdaQueryWrapper<TemperingGlassInfo>() + .eq(TemperingGlassInfo::getEngineerId, glassInfo.getEngineerId()) + .eq(TemperingGlassInfo::getState, Const.TEMPERING_NEW) + .ge(TemperingGlassInfo::getTemperingLayoutId, glassInfo.getTemperingLayoutId()) + .gt(TemperingGlassInfo::getTemperingFeedSequence, glassInfo.getTemperingFeedSequence()) + ); + return Boolean.TRUE; } @Override -- Gitblit v1.8.0