From 49827e84663179b2af3f245eab5f91d29d3bda71 Mon Sep 17 00:00:00 2001 From: wangfei <3597712270@qq.com> Date: 星期四, 22 八月 2024 11:00:05 +0800 Subject: [PATCH] 提交前端代码 --- hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgglasstask/service/impl/EdgGlassTaskInfoServiceImpl.java | 58 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 57 insertions(+), 1 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgglasstask/service/impl/EdgGlassTaskInfoServiceImpl.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgglasstask/service/impl/EdgGlassTaskInfoServiceImpl.java index 34a06f4..0934ab6 100644 --- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgglasstask/service/impl/EdgGlassTaskInfoServiceImpl.java +++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgglasstask/service/impl/EdgGlassTaskInfoServiceImpl.java @@ -1,14 +1,23 @@ package com.mes.edgglasstask.service.impl; +import cn.smallbun.screw.core.util.CollectionUtils; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.mes.common.utils.RedisUtil; import com.mes.edgglasstask.entity.EdgGlassTaskInfo; +import com.mes.edgglasstask.entity.request.EdgGlassInfoRequest; import com.mes.edgglasstask.mapper.EdgGlassTaskInfoMapper; import com.mes.edgglasstask.service.EdgGlassTaskInfoService; +import com.mes.tools.DateUtil; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; + +import java.util.List; /** * <p> - * 鏈嶅姟瀹炵幇绫� + * 鏈嶅姟瀹炵幇绫� * </p> * * @author wu @@ -17,4 +26,51 @@ @Service public class EdgGlassTaskInfoServiceImpl extends ServiceImpl<EdgGlassTaskInfoMapper, EdgGlassTaskInfo> implements EdgGlassTaskInfoService { + @Autowired + RedisUtil redisUtil; + + @Override + public List<EdgGlassTaskInfo> selectEdgInfo() { + EdgGlassInfoRequest request = redisUtil.getCacheObject("edgGlassRequest"); + + if (null == request) { + request = new EdgGlassInfoRequest(); + } + if (null == request.getBeginDate()) { + request.setBeginDate(DateUtil.getBeginDate()); + request.setEndDate(DateUtil.getEndDate()); + } + LambdaQueryWrapper<EdgGlassTaskInfo> edgGlassWrapper = new LambdaQueryWrapper<EdgGlassTaskInfo>() + .in(CollectionUtils.isNotEmpty(request.getCellList()), EdgGlassTaskInfo::getLine, request.getCellList()) + .in(CollectionUtils.isNotEmpty(request.getStateList()), EdgGlassTaskInfo::getStatus, request.getStateList()) + .between(null != request.getBeginDate(), EdgGlassTaskInfo::getTime, request.getBeginDate(), request.getEndDate()) + .orderByDesc(EdgGlassTaskInfo::getTime); + return this.list(edgGlassWrapper); + } + + @Override + public String setEdgGlassInfoRequest(EdgGlassInfoRequest request) { + if (request == null) { + redisUtil.deleteObject("edgGlassRequest"); + } else { + redisUtil.setCacheObject("edgGlassRequest", request); + } + return "success"; + } + + /** + * 鏌ヨ鍒ゆ柇纾ㄨ竟绾挎槸鍚︽湁鐜荤拑杩愯 + * + * @param + * @return + */ + @Override + public List<EdgGlassTaskInfo> selectTaskCacheIsRun() { + QueryWrapper<EdgGlassTaskInfo> wrapper = new QueryWrapper<EdgGlassTaskInfo>() + .select("line") + .eq("status", 1) + .groupBy("line"); + + return this.list(wrapper); + } } -- Gitblit v1.8.0