From 7a23bac143166768c577411d68b256fdf85c8bb5 Mon Sep 17 00:00:00 2001 From: zhoushihao <zsh19950802@163.com> Date: 星期一, 27 五月 2024 14:43:33 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/service/impl/TaskCacheServiceImpl.java | 87 ++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 85 insertions(+), 2 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 87ba952..2398039 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,14 +1,17 @@ package com.mes.taskcache.service.impl; -import com.mes.taskcache.entity.TaskCache; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.github.yulichang.wrapper.MPJLambdaWrapper; +import com.mes.taskcache.entity.TaskCache; import com.mes.taskcache.mapper.TaskCacheMapper; import com.mes.taskcache.service.TaskCacheService; import org.springframework.stereotype.Service; +import java.util.List; + /** * <p> - * 鏈嶅姟瀹炵幇绫� + * 鏈嶅姟瀹炵幇绫� * </p> * * @author zhoush @@ -17,4 +20,84 @@ @Service public class TaskCacheServiceImpl extends ServiceImpl<TaskCacheMapper, TaskCache> implements TaskCacheService { + /** + * 鏌ヨ纾ㄨ竟浠诲姟 + * + * @param line + * @return + */ + @Override + public List<TaskCache> selectEdgInfo(String line) { + return baseMapper.selectList(new MPJLambdaWrapper<TaskCache>().selectAll(TaskCache.class).eq(TaskCache::getEndCell, line)); +// return baseMapper.selectList(new QueryWrapper<TaskCache>().eq("end_cell",line)); + } + + /** + * 鏌ヨ寰呯悊鐗囧伐浣滅殑浠诲姟 + * + * @return + */ + @Override + 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 + public List<TaskCache> selectAll() { + return baseMapper.selectList(null); + } + + /** + * 鏌ヨ寰呰繘鐗囦换鍔� + * + * @return + */ + @Override + 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)); +// 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)); +// 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)); + } + + } -- Gitblit v1.8.0