From 66a674aae32196080e0f22ef0811b69437774dbd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E4=B9=BE=E7=BF=94?= <z982093659@qq.com>
Date: Mon, 27 Apr 2026 19:45:53 +0800
Subject: [PATCH] =?UTF-8?q?=E7=8E=AF=E4=BF=9D=E6=8A=80=E6=9C=AF=E5=91=98?=
 =?UTF-8?q?=E8=A7=92=E8=89=B2ID?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../desk/energy/pojo/entity/BsTowerReportEntity.java  |  3 ++-
 .../energy/service/impl/BsTowerReportServiceImpl.java | 11 +++++++----
 2 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/energy/pojo/entity/BsTowerReportEntity.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/energy/pojo/entity/BsTowerReportEntity.java
index b45fe700..2bae6395 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/energy/pojo/entity/BsTowerReportEntity.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/energy/pojo/entity/BsTowerReportEntity.java
@@ -103,5 +103,6 @@ public class BsTowerReportEntity extends BaseEntity {
 	 */
 	@Schema(description = "持续时间")
 	private Double consLong;
-
+	@Schema(description = "是否推送系统待办提醒 0否 1是")
+	private Integer reminder;
 }
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/energy/service/impl/BsTowerReportServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/energy/service/impl/BsTowerReportServiceImpl.java
index 4f61c2b3..01f02fed 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/energy/service/impl/BsTowerReportServiceImpl.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/energy/service/impl/BsTowerReportServiceImpl.java
@@ -176,8 +176,10 @@ public class BsTowerReportServiceImpl extends BaseServiceImpl<BsTowerReportMappe
 			List<BsTowerReportEntity> unprocessedAlarms = list(
 				Wrappers.lambdaQuery(BsTowerReportEntity.class)
 					.lt(BsTowerReportEntity::getStartTime, threeMinutesAgoDate)
-					.eq(BsTowerReportEntity::getDealStatus, "false")
+					.eq(BsTowerReportEntity::getDealStatus, false)
+					.eq(BsTowerReportEntity::getReminder, 0)
 					.isNotNull(BsTowerReportEntity::getStartTime)
+
 			);
 			
 			if (unprocessedAlarms == null || unprocessedAlarms.isEmpty()) {
@@ -226,10 +228,11 @@ public class BsTowerReportServiceImpl extends BaseServiceImpl<BsTowerReportMappe
 					if (result != null && result.isSuccess()) {
 						log.info("D，报警ID: {}, 编码: {}", alarm.getId(), alarm.getBtCode());
 					} else {
-						log.error("发送酸雾塔报警提醒失败，报警ID: {}, 错误信息: {}", 
-							alarm.getId(), result != null ? result.getMsg() : "返回结果为空");
+						throw new RuntimeException("发送酸雾塔报警提醒失败: " + (result != null ? result.getMsg() : "返回结果为空"));
 					}
-					
+					alarm.setReminder(1);
+					updateById(alarm);
+
 				} catch (Exception e) {
 					log.error("处理酸雾塔报警提醒时发生异常，报警ID: {}", alarm.getId(), e);
 				}