From 6ff1b66c16a506d8f40b7284c1c3774faf1e6d2e Mon Sep 17 00:00:00 2001 From: wuyouming666 <2265557248@qq.com> Date: 星期五, 31 五月 2024 16:45:45 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes --- hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/service/impl/TaskCacheServiceImpl.java | 91 +++++++++++++++++++++++++++++++++++---------- 1 files changed, 71 insertions(+), 20 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/service/impl/TaskCacheServiceImpl.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/service/impl/TaskCacheServiceImpl.java index 2398039..3b56659 100644 --- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/service/impl/TaskCacheServiceImpl.java +++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/service/impl/TaskCacheServiceImpl.java @@ -1,17 +1,26 @@ package com.mes.taskcache.service.impl; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.github.yulichang.wrapper.MPJLambdaWrapper; +import com.mes.edgstoragecage.entity.EdgStorageCageDetails; +import com.mes.edgstoragecage.mapper.EdgStorageCageDetailsMapper; +import com.mes.glassinfo.entity.GlassInfo; +import com.mes.glassinfo.mapper.GlassInfoMapper; import com.mes.taskcache.entity.TaskCache; import com.mes.taskcache.mapper.TaskCacheMapper; import com.mes.taskcache.service.TaskCacheService; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.util.ArrayList; +import java.util.HashMap; import java.util.List; +import java.util.Map; /** * <p> - * 鏈嶅姟瀹炵幇绫� + * 鏈嶅姟瀹炵幇绫� * </p> * * @author zhoush @@ -20,32 +29,78 @@ @Service public class TaskCacheServiceImpl extends ServiceImpl<TaskCacheMapper, TaskCache> implements TaskCacheService { + @Autowired + EdgStorageCageDetailsMapper edgStorageCageDetailsMapper; + + @Autowired + GlassInfoMapper glassInfoMapper; + /** + * 娣诲姞鐞嗙墖绗间换鍔� + * @param taskCache + * @return + */ + @Override + public boolean insertTaskCache(TaskCache taskCache){ + baseMapper.insert(taskCache); + return true; + } + /** * 鏌ヨ纾ㄨ竟浠诲姟 - * * @param line * @return */ @Override - public List<TaskCache> selectEdgInfo(String line) { - return baseMapper.selectList(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getEndCell, line)); + public List<Map<String,Object>> selectEdgInfo(String line) { + List<TaskCache> taskCache=baseMapper.selectList(new MPJLambdaWrapper<TaskCache>() + .selectAll(TaskCache.class) + .eq(TaskCache::getEndCell, line) + .eq(TaskCache::getTaskStatus,1) + .orderByAsc(TaskCache::getCreateTime)); + List<Map<String,Object>> result=new ArrayList<>(); + int serialNumber=1; + for(TaskCache taskCache1:taskCache){ + Map<String,Object> map=new HashMap<>(); + GlassInfo glassInfo=glassInfoMapper.selectOne(new MPJLambdaWrapper<GlassInfo>() + .selectAll(GlassInfo.class) + .eq(GlassInfo::getGlassId,taskCache1.getGlassId())); + if(glassInfo!=null){ + map.put("Line",line);//绾胯矾 2001 1绾匡紝 2002 2绾� + map.put("Width",glassInfo.getWidth());//瀹� + map.put("Height",glassInfo.getHeight());//楂� + map.put("Thickness",glassInfo.getThickness());//鍘� + map.put("GlassId",glassInfo.getGlassId());//鐜荤拑ID + map.put("FlowCardId",glassInfo.getFlowCardId());//娴佺▼鍗″彿 + map.put("TemperingLayoutId",glassInfo.getTemperingLayoutId());// 鏆備笉鏄剧ず 閽㈠寲鐗堝浘ID + map.put("TemperingFeedSequence",glassInfo.getTemperingFeedSequence());// 鏆備笉鏄剧ず 閽㈠寲鐗堝浘ID鍐呯殑搴忓彿 + map.put("FilmsId",glassInfo.getFilmsid());//鑶滅郴 + map.put("SerialNumber",serialNumber);//鍑虹墖椤哄簭 + result.add(map); + } + serialNumber++; + } + + return result; // return baseMapper.selectList(new QueryWrapper<TaskCache>().eq("end_cell",line)); + } + + @Override + public TaskCache queryGlassByTaskCache(int line, List<Integer> taskTypes) { + return baseMapper.queryGlassByTaskCache(line, taskTypes); } /** * 鏌ヨ寰呯悊鐗囧伐浣滅殑浠诲姟 - * * @return */ @Override - public List<TaskCache> selectCacheInfo() { - return baseMapper.selectList(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getTaskStatus, 0)); + public List<TaskCache> selectCacheInfo(){ + return baseMapper.selectList(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getTaskStatus,0)); // return baseMapper.selectList(new QueryWrapper<TaskCache>().eq("task_status",0)); } /** * 鏌ヨ鍏ㄩ儴浠诲姟 - * * @return */ @Override @@ -55,48 +110,44 @@ /** * 鏌ヨ寰呰繘鐗囦换鍔� - * * @return */ @Override - public List<TaskCache> selectInputTaskCache() { - return baseMapper.selectList(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getTaskStatus, 0).eq(TaskCache::getTaskType, 1)); + public List<TaskCache> selectInputTaskCache(){ + return baseMapper.selectList(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getTaskStatus,0).eq(TaskCache::getTaskType,1)); // return baseMapper.selectList(new QueryWrapper<TaskCache>().eq("task_status",0).eq("task_type",1)); } /** * 鏌ヨ寰呭嚭鐗囦换鍔� - * * @return */ @Override - public List<TaskCache> selectOutTaskCache() { - return baseMapper.selectList(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getTaskStatus, 0).eq(TaskCache::getTaskType, 2)); + public List<TaskCache> selectOutTaskCache(){ + return baseMapper.selectList(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getTaskStatus,0).eq(TaskCache::getTaskType,2)); // return baseMapper.selectList(new QueryWrapper<TaskCache>().eq("task_status",0).eq("task_type",2)); } /** * 鏌ヨ A09 鎴� A10 鏈�鏂扮殑涓�鐗� 鍑虹墖浠诲姟 - * * @param line * @return */ @Override - public List<TaskCache> selectLastOutCacheInfos(int line) { - return baseMapper.selectList(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getEndCell, line).eq(TaskCache::getTaskStatus, 1).orderByDesc(TaskCache::getCreateTime)); + public List<TaskCache> selectLastOutCacheInfos(int line){ + return baseMapper.selectList(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getEndCell,line).eq(TaskCache::getTaskStatus,1).orderByDesc(TaskCache::getCreateTime)); // return baseMapper.selectList(new QueryWrapper<TaskCache>().eq("end_cell",line).eq("task_status",1).orderByDesc("ID")); } /** * 鏌ヨ A09 鎴� A10 鏈�鏂扮殑涓�鐗� 鍑虹墖浠诲姟 - * * @param line * @return */ @Override - public TaskCache selectLastOutCacheInfo(String line) { - return baseMapper.selectOne(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getEndCell, line).eq(TaskCache::getTaskStatus, 1).orderByDesc(TaskCache::getCreateTime)); + public TaskCache selectLastOutCacheInfo(int line){ + return baseMapper.selectOne(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getEndCell,line).eq(TaskCache::getTaskStatus,1).orderByDesc(TaskCache::getCreateTime)); } -- Gitblit v1.8.0