环保技术员角色ID

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;
 }

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);
 				}