From 5d5cd3ad979a0b85ab8c7034dcad1663fdcf71be Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Fri, 01 Dec 2023 14:18:53 +0800
Subject: [PATCH] 文章通过范围查询

---
 src/main/java/org/springblade/modules/task/service/impl/TaskReportForRepairsServiceImpl.java |   22 +++++++++++++++++-----
 1 files changed, 17 insertions(+), 5 deletions(-)

diff --git a/src/main/java/org/springblade/modules/task/service/impl/TaskReportForRepairsServiceImpl.java b/src/main/java/org/springblade/modules/task/service/impl/TaskReportForRepairsServiceImpl.java
index 0185983..c030351 100644
--- a/src/main/java/org/springblade/modules/task/service/impl/TaskReportForRepairsServiceImpl.java
+++ b/src/main/java/org/springblade/modules/task/service/impl/TaskReportForRepairsServiceImpl.java
@@ -16,10 +16,13 @@
  */
 package org.springblade.modules.task.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import org.springblade.core.mp.base.BaseServiceImpl;
 import org.springblade.core.secure.utils.AuthUtil;
+import org.springblade.modules.grid.entity.GridmanEntity;
 import org.springblade.modules.grid.service.IGridService;
+import org.springblade.modules.sse.server.SSEServer;
 import org.springblade.modules.task.entity.TaskEntity;
 import org.springblade.modules.task.entity.TaskReportForRepairsEntity;
 import org.springblade.modules.task.mapper.TaskReportForRepairsMapper;
@@ -66,11 +69,7 @@
 				list = gridService.getAddressCodeListByUserId(AuthUtil.getUserId());
 			}
 		}
-		// 没有范围,不查询数据
-		if (list.size() > 0) {
-			return page.setRecords(baseMapper.selectTaskReportForRepairsPage(page, taskReportForRepairs, list));
-		}
-		return page.setRecords(new ArrayList<>());
+		return page.setRecords(baseMapper.selectTaskReportForRepairsPage(page, taskReportForRepairs,list));
 	}
 
 	/**
@@ -105,6 +104,8 @@
 			taskReportForRepairs.setTaskId(taskEntity.getId());
 			taskReportForRepairs.setConfirmFlag(1);
 			flag = save(taskReportForRepairs);
+			// 同时向web 端推送消息
+			SSEServer.sendMessage("web:1","1");
 		}
 		return flag;
 	}
@@ -153,4 +154,15 @@
 	public Integer getStatistics(Long userId) {
 		return baseMapper.getStatistics(userId);
 	}
+
+	/**
+	 * 更新状态--临时接口
+	 * @param gridman
+	 * @return
+	 */
+	@Override
+	public boolean updateView(GridmanEntity gridman) {
+		baseMapper.updateView(gridman);
+		return true;
+	}
 }

--
Gitblit v1.9.3