From 6b7f4fc2d528f0a0d9818800a07166ba2c3da821 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 09:12:18 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E6=B0=B4=E5=BA=93=E6=80=BB=E8=A7=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/kms/yg/cz/service/MonitorService.java   | 8 ++++----
 1 file changed, 4 insertions(+), 4 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 d48363cd..104ced11 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
@@ -375,7 +375,7 @@ public class MonitorService {
         // 近一个小时
         sp.setStartTime(BsSgcSkStatisticsService.getTimeBeforeHours(1));
         sp.setEndTime(BsSgcSkStatisticsService.getCurrentTime());
-        CompletableFuture<List<MsHdmObp>> msHdmObpOneListFuture = CompletableFuture.supplyAsync(() -> queryDataList(MS_HDM_OBP, sp));
+        CompletableFuture<List<MsHdmObp>> msHdmObpOneListFuture = CompletableFuture.supplyAsync(() -> queryDataList(MonitorSourceEnum.MS_HDM_OBP, sp));
         List<MsHdmObp> msHdmObpOneList = msHdmObpOneListFuture.join();
         if (!CollectionUtils.isEmpty(msHdmObpOneList)) {
             // 近一个小时
@@ -385,7 +385,7 @@ public class MonitorService {
         // 近6个小时
         sp.setStartTime(BsSgcSkStatisticsService.getTimeBeforeHours(6));
         sp.setEndTime(BsSgcSkStatisticsService.getCurrentTime());
-        CompletableFuture<List<MsHdmObp>> msHdmObpSixListFuture = CompletableFuture.supplyAsync(() -> queryDataList(MS_HDM_OBP, sp));
+        CompletableFuture<List<MsHdmObp>> msHdmObpSixListFuture = CompletableFuture.supplyAsync(() -> queryDataList(MonitorSourceEnum.MS_HDM_OBP, sp));
         List<MsHdmObp> msHdmObpSixList = msHdmObpSixListFuture.join();
         if (!CollectionUtils.isEmpty(msHdmObpSixList)) {
             // 近6个小时
@@ -395,7 +395,7 @@ public class MonitorService {
         // 近9个小时
         sp.setStartTime(BsSgcSkStatisticsService.getTimeBeforeHours(9));
         sp.setEndTime(BsSgcSkStatisticsService.getCurrentTime());
-        CompletableFuture<List<MsHdmObp>> msHdmObpNineListFuture = CompletableFuture.supplyAsync(() -> queryDataList(MS_HDM_OBP, sp));
+        CompletableFuture<List<MsHdmObp>> msHdmObpNineListFuture = CompletableFuture.supplyAsync(() -> queryDataList(MonitorSourceEnum.MS_HDM_OBP, sp));
         List<MsHdmObp> msHdmObpNineList = msHdmObpNineListFuture.join();
         if (!CollectionUtils.isEmpty(msHdmObpNineList)) {
             // 近9个小时
@@ -405,7 +405,7 @@ public class MonitorService {
         // 近12个小时
         sp.setStartTime(BsSgcSkStatisticsService.getTimeBeforeHours(12));
         sp.setEndTime(BsSgcSkStatisticsService.getCurrentTime());
-        CompletableFuture<List<MsHdmObp>> msHdmObpTwelveListFuture = CompletableFuture.supplyAsync(() -> queryDataList(MS_HDM_OBP, sp));
+        CompletableFuture<List<MsHdmObp>> msHdmObpTwelveListFuture = CompletableFuture.supplyAsync(() -> queryDataList(MonitorSourceEnum.MS_HDM_OBP, sp));
         List<MsHdmObp> msHdmObpTwelveList = msHdmObpTwelveListFuture.join();
         if (!CollectionUtils.isEmpty(msHdmObpTwelveList)) {
             // 近12个小时