From 39b74c6fb4a50bed412bbebdd38440d384f47733 Mon Sep 17 00:00:00 2001
From: whycxzp <glperry@163.com>
Date: 星期日, 30 三月 2025 14:40:18 +0800
Subject: [PATCH] 完善温度告警
---
src/main/java/com/whyc/schedule/BattStationTempScheduleService.java | 22 +++++++++++++++++++---
1 files changed, 19 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/whyc/schedule/BattStationTempScheduleService.java b/src/main/java/com/whyc/schedule/BattStationTempScheduleService.java
index c7efb8b..49a82ca 100644
--- a/src/main/java/com/whyc/schedule/BattStationTempScheduleService.java
+++ b/src/main/java/com/whyc/schedule/BattStationTempScheduleService.java
@@ -7,18 +7,23 @@
import com.whyc.pojo.db_alarm.BattStationTempAlarm;
import com.whyc.pojo.db_batt.BattCamera;
import com.whyc.pojo.db_param.PageParam;
+import com.whyc.pojo.db_power_history.BattStationTempHistory;
import com.whyc.pojo.db_power_rt.BattStationTemp;
import com.whyc.service.BattStationTempAlarmService;
import com.whyc.service.BattStationTempHisService;
import com.whyc.service.BattStationTempService;
import com.whyc.service.PageParamService;
+import com.whyc.util.DateUtil;
import com.whyc.util.HikTempUtil;
+import com.whyc.util.ThreadLocalUtil;
import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.beanutils.BeanUtils;
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.lang.reflect.InvocationTargetException;
import java.util.Date;
import java.util.List;
import java.util.Map;
@@ -91,9 +96,20 @@
battStationTemp.setStationId(stationId);
service.addOrUpdate(battStationTemp);
- //娓╁害鍘嗗彶 - 鎸夌數姹犵粍id,鏈堝害琛�
-
-
+ String yearMonth = ThreadLocalUtil.format(date, 2);
+ //娓╁害鍘嗗彶 - 璁板綍鍒� 鎸夌數姹犵粍id,鏈堝害琛�
+ boolean exist = hisService.existTempHisTableByMonth(battGroupId,yearMonth);
+ //涓嶅瓨鍦ㄥ垯鍒涘缓.鎻掑叆璁板綍
+ if(!exist){
+ hisService.createTableByMonth(battGroupId,yearMonth);
+ }
+ BattStationTempHistory tempHistory = new BattStationTempHistory();
+ try {
+ BeanUtils.copyProperties(tempHistory,battStationTemp);
+ } catch (IllegalAccessException | InvocationTargetException e) {
+ throw new RuntimeException(e);
+ }
+ hisService.add(battGroupId,yearMonth,tempHistory);
//娓╁害鍛婅鍒ゆ柇
//鏌ヨ娓╁害鍛婅琛紝濡傛灉瀛樺湪
BattStationTempAlarm alarmInDB = alarmService.getByBattGroupId(battGroupId);
--
Gitblit v1.9.1