From d85033771c1dcdd07eacf6c1dcd2c9feceba7798 Mon Sep 17 00:00:00 2001
From: wangfei <3597712270@qq.com>
Date: 星期四, 19 九月 2024 15:08:25 +0800
Subject: [PATCH] 查询使用websockect实时推送数据
---
hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/rawglasstask/service/impl/RawGlassRawGlassStorageTaskServiceImpl.java | 57 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 57 insertions(+), 0 deletions(-)
diff --git a/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/rawglasstask/service/impl/RawGlassRawGlassStorageTaskServiceImpl.java b/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/rawglasstask/service/impl/RawGlassRawGlassStorageTaskServiceImpl.java
index 6afab45..ff99076 100644
--- a/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/rawglasstask/service/impl/RawGlassRawGlassStorageTaskServiceImpl.java
+++ b/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/rawglasstask/service/impl/RawGlassRawGlassStorageTaskServiceImpl.java
@@ -4,13 +4,20 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.mes.common.utils.RedisUtil;
import com.mes.pp.entity.request.Reportingdamage;
import com.mes.rawglasstask.entity.RawGlassStorageTask;
+import com.mes.rawglasstask.entity.request.RawGlassTaskRequest;
import com.mes.rawglasstask.mapper.RawGlassStorageTaskMapper;
import com.mes.rawglasstask.service.RawGlassStorageTaskService;
import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
import java.util.List;
import java.util.Map;
@@ -21,6 +28,56 @@
@Service
@Slf4j
public class RawGlassRawGlassStorageTaskServiceImpl extends ServiceImpl<RawGlassStorageTaskMapper, RawGlassStorageTask> implements RawGlassStorageTaskService {
+
+
+ @Autowired
+ RedisUtil redisUtil;
+
+ @Override
+ public List<RawGlassStorageTask> findAll() {
+ RawGlassTaskRequest request = redisUtil.getCacheObject("rawGlassTaskRequest");
+ if (null == request) {
+ request = new RawGlassTaskRequest();
+ //璁剧疆榛樿鏃堕棿 startDate锛氬紑濮嬫椂闂� endDate锛氱粨鏉熸椂闂�
+ DateFormat df = new SimpleDateFormat("yyyy-MM-dd");
+ Date startDate=null;
+ Date endDate=null;
+ try {
+ startDate= df.parse("2022-01-01");
+ endDate= df.parse("2025-01-01");
+ }catch (ParseException e){
+ e.printStackTrace();
+ }
+ request.setCreateTime(startDate);//
+ request.setPatternQuantity(endDate);
+ //return null;
+ }
+
+ QueryWrapper<RawGlassStorageTask> queryWrapper = new QueryWrapper<>();
+ //涓嬮潰杩欎釜鍒楁槸鏌ヨ瀛楁锛屼笉瑕佸彲浠ュ垹鎺夐粯璁ゆ煡璇㈠叏閮�
+ queryWrapper.ge("create_time", request.getCreateTime())//澶т簬鏃堕棿
+ .le("create_time",request.getPatternQuantity());//灏忎簬鏃堕棿
+// .orderByDesc("enable_id");//鎺掑簭瀛楁
+ if(!request.getEnableType().isEmpty()&&request.getEnableType().size()>0){
+ queryWrapper.eq("enable_type", request.getEnableType().get(0));
+ }if(!request.getEnableState().isEmpty()&&request.getEnableState().size()>0){
+ queryWrapper.eq("enable_state", request.getEnableState().get(0));
+ }
+
+ return baseMapper.selectList(queryWrapper);
+ }
+
+ @Override
+ public String setRawGlassTaskRequest(RawGlassTaskRequest request) {
+ if (request == null) {
+ redisUtil.deleteObject("rawGlassTaskRequest");
+ } else {
+ redisUtil.setCacheObject("rawGlassTaskRequest", request);
+ }
+ log.info("鍓嶇浼犲叆鍙傛暟锛歿}",request);
+ return "success";
+ }
+
@Override
public List<RawGlassStorageTask> selectTask() {
return list();
--
Gitblit v1.8.0