From d1ef22f59d032a28d26a740432aa0581d04c249e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E2=80=9Clyd=E2=80=9D?= <“lyd@datametatech.com”>
Date: Thu, 20 Mar 2025 18:11:13 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E6=B0=B4=E5=BA=93=E6=80=BB=E8=A7=88bug?=
 =?UTF-8?q?=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/kms/yg/cz/service/MonitorService.java | 20 +++++++++++++------
 1 file changed, 14 insertions(+), 6 deletions(-)

diff --git a/shuili-system/src/main/java/com/kms/yg/cz/service/MonitorService.java b/shuili-system/src/main/java/com/kms/yg/cz/service/MonitorService.java
index ce00c16b..b4e9318a 100644
--- a/shuili-system/src/main/java/com/kms/yg/cz/service/MonitorService.java
+++ b/shuili-system/src/main/java/com/kms/yg/cz/service/MonitorService.java
@@ -324,16 +324,24 @@ public class MonitorService {
         }
         sp.setResCode(resCode);
         // 代表站
-        SkRelStRes relStResJsonMode =  queryDataOne(MonitorSourceEnum.DWS_REL_ST_RES, sp);
-        if (Objects.isNull(relStResJsonMode)) {
+        List<SkRelStRes> relStResJsonModeList =  queryDataList(MonitorSourceEnum.DWS_REL_ST_RES, sp);
+        if (CollectionUtils.isEmpty(relStResJsonModeList)) {
             return attResTaskViewDto;
         }
-        attResTaskViewDto.setStationName(relStResJsonMode.getStName());
-        attResTaskViewDto.setStationCode(relStResJsonMode.getStCode());
-
+        SkRelStRes skRelStRes = relStResJsonModeList.stream()
+                .filter(e -> !StringUtils.isNotEmpty(e.getFlag()))
+                .filter(e -> Objects.equals(e.getFlag(), "1"))
+                .findFirst()
+                .orElse(null);
+        log.info("获取SkRelStRes返回数据:{}",JSON.toJSONString(skRelStRes));
+        if (Objects.isNull(skRelStRes)) {
+            return attResTaskViewDto;
+        }
+        attResTaskViewDto.setStationName(skRelStRes.getStName());
+        attResTaskViewDto.setStationCode(skRelStRes.getStCode());
 
         // 当前水位
-        sp.setStcd(relStResJsonMode.getStCode());
+        sp.setStcd(skRelStRes.getStCode());
         sp.setStartTime(BsSgcSkStatisticsService.getStartOfDay());
         sp.setEndTime(BsSgcSkStatisticsService.getStartOfNextDay());
         List<MsHdmRsvr> msHdmRsvrFutureList = queryDataList(MonitorSourceEnum.MS_HDM_RSVR, sp);