From aa94ef4e1f060b184e6ea9fb37254b376a1eb60e Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期二, 14 十一月 2023 10:49:06 +0800
Subject: [PATCH] 1. 新增风险值的自动运行逻辑;

---
 src/main/java/com/flightfeather/monitor/analysis/dust/RiskAnalysisController.kt |    8 ++++----
 1 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/flightfeather/monitor/analysis/dust/RiskAnalysisController.kt b/src/main/java/com/flightfeather/monitor/analysis/dust/RiskAnalysisController.kt
index afc6bc1..fb01c98 100644
--- a/src/main/java/com/flightfeather/monitor/analysis/dust/RiskAnalysisController.kt
+++ b/src/main/java/com/flightfeather/monitor/analysis/dust/RiskAnalysisController.kt
@@ -22,8 +22,8 @@
     private val dustStatisticValueRep: DustStatisticsValueRep,
 ) {
 
-    private var running1 = false
-    private var running2 = false
+    var running1 = false
+    var running2 = false
 
     private var taskDaily: DustRiskAnalysis? = null
     private var taskMonthly: DustRiskMonthAnalysis? = null
@@ -75,7 +75,7 @@
         // 鑾峰彇鎵�鏈夊綋鍓嶄笂绾垮拰鍋滆繍鐨勮澶�
         dustSiteStatusRep.select(listOf(DeviceStatus.ONLINE, DeviceStatus.STOP)).forEach { s ->
             s?.let {
-                taskDaily?.roundInit()
+                taskDaily?.roundInit(s.mnCode, date)
                 val dustSiteDataList = dustSiteDataRep.select(s.mnCode, date)
                 val dustExceptionDataList = dustExceptionDataRep.select(s.mnCode, date)
                 val dustStatisticValueList = dustStatisticValueRep.select(s.mnCode, date)
@@ -95,7 +95,7 @@
         taskMonthly?.init()
         dustSiteStatusRep.select(listOf(DeviceStatus.ONLINE, DeviceStatus.STOP)).forEach { s ->
             s?.let {
-                taskMonthly?.roundInit()
+                taskMonthly?.roundInit(s.mnCode, date)
                 val riskValueList = riskValueRep.select(s.mnCode, date)
                 taskMonthly?.roundCal(riskValueList)
             }

--
Gitblit v1.9.3