From 7fe1ea37e4044eb61374a51c5a2fe1ecf9e834be Mon Sep 17 00:00:00 2001
From: whycxzp <glperry@163.com>
Date: 星期一, 09 六月 2025 19:07:39 +0800
Subject: [PATCH] 杂项更新

---
 src/main/java/com/whyc/schedule/FireRobotSchedule.java |   74 +++++++++++++++++++++++++++++++++++++
 1 files changed, 74 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/whyc/schedule/FireRobotSchedule.java b/src/main/java/com/whyc/schedule/FireRobotSchedule.java
new file mode 100644
index 0000000..095c2fe
--- /dev/null
+++ b/src/main/java/com/whyc/schedule/FireRobotSchedule.java
@@ -0,0 +1,74 @@
+package com.whyc.schedule;
+
+import com.github.pagehelper.PageInfo;
+import com.whyc.dto.Response;
+import com.whyc.pojo.db_alarm.BattStationTempAlarm;
+import com.whyc.pojo.db_batt.BattMonsLocation;
+import com.whyc.pojo.db_param.BattAlarmParam;
+import com.whyc.pojo.db_real_batt.RtData;
+import com.whyc.service.BattAlarmParamService;
+import com.whyc.service.BattStationTempAlarmService;
+import com.whyc.service.BattStationTempService;
+import com.whyc.service.RtDataService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@EnableScheduling
+@Component
+@Slf4j
+public class FireRobotSchedule {
+
+    @Autowired
+    private BattStationTempAlarmService battStationTempAlarmService;
+
+    @Autowired
+    private RtDataService rtDataService;
+
+    @Autowired
+    private BattAlarmParamService battAlarmParamService;
+
+    //鏌ヨ鐢垫睜绔欑偣娓╁害鍛婅骞舵牎楠屾槸鍚﹀瓨鍦ㄧ數姹犲崟浣撴俯搴﹂珮. 瀛樺湪鐨勬儏鍐典笅,缁欑數姹犲崟浣撴俯搴﹂珮鐨勭數姹犲崟浣�.杩涜娑堥槻鏈哄櫒浜虹伃鐏鐞�
+    @Scheduled(fixedRate = 4000,initialDelay = 2000)
+    public void checkAndStopFire() {
+        //鏌ヨ姝e湪鍙戠敓涓�绾у憡璀︾殑鐢垫睜鍗曚綋鏈夊摢浜�
+        Response<PageInfo<BattStationTempAlarm>> page = battStationTempAlarmService.getPage(1, 10, 1);
+        PageInfo<BattStationTempAlarm> data = page.getData();
+        List<BattStationTempAlarm> alarmList = data.getList();
+
+        for (int i = 0; i < alarmList.size(); i++) {
+            //鏌ヨ娓╁害鍛婅鐨勯槇鍊�
+            BattAlarmParam param = battAlarmParamService.getTempAlarmParam();
+
+            BattStationTempAlarm tempAlarm = alarmList.get(i);
+            BattMonsLocation battMonsLocation = tempAlarm.getBattMonsLocation();
+            String battMons = battMonsLocation.getBattMons();
+            Integer battGroupId = battMonsLocation.getBattGroupId();
+            String[] battMonsArray = battMons.split(",");
+            //杞负int绫诲瀷鏁扮粍
+            Integer[] battMonsArrayInt = new Integer[battMonsArray.length];
+            for (int j = 0; j < battMonsArray.length; j++) {
+                battMonsArrayInt[j] = Integer.parseInt(battMonsArray[j]);
+            }
+            //鏌ヨ瀵瑰簲鐨勭數姹犵粍鍜岀數姹犲崟浣撶殑娓╁害鏁版嵁
+            List<RtData> rtDataList = rtDataService.getList(battGroupId, battMonsArrayInt);
+            for (int j = 0; j < rtDataList.size(); j++) {
+                RtData rtData = rtDataList.get(j);
+                //娓╁害鍩哄噯鍊煎浐瀹氫负25搴�
+                int tempBase = 25;
+                if (rtData.getMonTmp() > tempBase*param.getAlmHighCoe()) { //鍗曚綋娓╁害楂樹簬娓╁害闃堝��
+                    //TODO 鍗曚綋鐏伀鎸囦护娌$粰,鍦ㄧ數姹犵珯鐐规俯搴﹀憡璀﹁〃涓璁″鍔犲垪-鏄惁鍙戦�佷簡鐏伀鎸囦护,榛樿涓哄惁,鏆傛病杩藉姞!!!!!!!!!! 杩藉姞鍚�,涓婇潰鐨勮鏌ヨ骞跺垽鏂槸鍚﹀彂閫佷簡鐏伀鎸囦护,濡傛灉鍙戦�佷簡,鍒欎笉杩涜涓嬭堪鐨勭伃鐏祦绋�
+                    //缁欑數姹犲崟浣撴俯搴﹂珮鐨勭數姹犲崟浣�.杩涜娑堥槻鏈哄櫒浜虹伃鐏鐞�
+                    Integer monNum = rtData.getMonNum();
+                }
+            }
+        }
+
+
+    }
+
+}

--
Gitblit v1.9.1