From 9887fc7be1578f465eee608e55b65097fa417d4c Mon Sep 17 00:00:00 2001 From: wangfei <3597712270@qq.com> Date: 星期二, 06 八月 2024 14:38:10 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes --- hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downglassinfo/service/impl/DownGlassInfoServiceImpl.java | 30 ++++++++++++++++++++++++++---- 1 files changed, 26 insertions(+), 4 deletions(-) diff --git a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downglassinfo/service/impl/DownGlassInfoServiceImpl.java b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downglassinfo/service/impl/DownGlassInfoServiceImpl.java index 64317a2..06ea03a 100644 --- a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downglassinfo/service/impl/DownGlassInfoServiceImpl.java +++ b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downglassinfo/service/impl/DownGlassInfoServiceImpl.java @@ -5,7 +5,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.mes.common.config.Const; +import com.mes.common.utils.RedisUtil; import com.mes.downglassinfo.entity.DownGlassInfo; +import com.mes.downglassinfo.entity.request.DownGlassInfoRequest; import com.mes.downglassinfo.mapper.DownGlassInfoMapper; import com.mes.downglassinfo.service.DownGlassInfoService; import com.mes.downstorage.entity.DownStorageCageDetails; @@ -28,6 +30,9 @@ @Autowired DownStorageCageDetailsService downStorageCageDetailsService; + @Autowired + RedisUtil redisUtil; + /** * 鏍规嵁娴佺▼鍗″彿鏌ヨ鏈�澶у簭鍙� */ @@ -35,7 +40,7 @@ public Integer getMaxSequenceByFlowCardId(String flowCardId, int layer) { LambdaQueryWrapper<DownGlassInfo> lambdaQueryWrapper = Wrappers.lambdaQuery(); lambdaQueryWrapper.eq(DownGlassInfo::getFlowCardId, flowCardId) - .eq(DownGlassInfo::getLayer, flowCardId) + .eq(DownGlassInfo::getLayer, layer) .select(DownGlassInfo::getSequence) .orderByDesc(DownGlassInfo::getSequence) .last("LIMIT 1"); @@ -60,8 +65,15 @@ } @Override - public List<DownGlassInfoDTO> queryWorkStationIsIn(Boolean isDownload) { - return baseMapper.queryWorkStationIsIn(isDownload); + public List<DownGlassInfoDTO> queryWorkStationIsIn(List<Integer> workList, Boolean isDownload) { + //鎸夌収瑕佹眰鑾峰彇宸茶惤鏋�/鏈惤鏋剁殑鐜荤拑淇℃伅 + return baseMapper.queryWorkStationIsIn(workList, isDownload); + } + + @Override + public List<DownGlassInfoDTO> queryWorkStationFlowCard(List<Integer> workList) { + //鑾峰彇宸茬粦瀹氭祦绋嬪崱鐨勬灦瀛愭湭钀界幓鐠冪殑鏁版嵁淇℃伅 + return baseMapper.queryWorkStationFlowCard(workList); } @Override @@ -80,6 +92,16 @@ //鐢熸垚浠诲姟淇℃伅 骞跺悜plc鍙戦�佸嚭鐗囦换鍔� GlassInfo glassInfo = new GlassInfo(); BeanUtils.copyProperties(details, glassInfo); - return downLoadCacheGlassTask.initDownGlassTask(glassInfo, details.getSlot(), 3001, 2); + return downLoadCacheGlassTask.initDownGlassTask(glassInfo, details.getSlot(), Const.G13_WORK_STATION, 2); + } + + @Override + public String setDownGlassInfoRequest(DownGlassInfoRequest request) { + if (request == null) { + redisUtil.deleteObject("downGlassRequest"); + } else { + redisUtil.setCacheObject("downGlassRequest", request); + } + return "success"; } } -- Gitblit v1.8.0