|
|
|
|
@ -172,13 +172,11 @@ public class BsTowerReportServiceImpl extends BaseServiceImpl<BsTowerReportMappe |
|
|
|
|
Date threeMinutesAgoDate = Date.from(threeMinutesAgo.atZone(ZoneId.systemDefault()).toInstant()); |
|
|
|
|
|
|
|
|
|
log.info("查询条件: startTime < {} 且 dealStatus = false", threeMinutesAgoDate); |
|
|
|
|
|
|
|
|
|
// 查询开始时间超过3分钟且未被处理(dealStatus='false')的报警记录
|
|
|
|
|
// 注意:DEAL_STATUS在数据库中是VARCHAR2类型,必须使用字符串比较
|
|
|
|
|
|
|
|
|
|
List<BsTowerReportEntity> unprocessedAlarms = list( |
|
|
|
|
Wrappers.lambdaQuery(BsTowerReportEntity.class) |
|
|
|
|
.lt(BsTowerReportEntity::getStartTime, threeMinutesAgoDate) |
|
|
|
|
.eq(BsTowerReportEntity::getDealStatus, "false") // 使用字符串而非布尔值
|
|
|
|
|
.eq(BsTowerReportEntity::getDealStatus, "false") |
|
|
|
|
.isNotNull(BsTowerReportEntity::getStartTime) |
|
|
|
|
); |
|
|
|
|
|
|
|
|
|
@ -190,7 +188,7 @@ public class BsTowerReportServiceImpl extends BaseServiceImpl<BsTowerReportMappe |
|
|
|
|
log.info("发现 {} 条超过3分钟未处理的酸雾塔报警", unprocessedAlarms.size()); |
|
|
|
|
|
|
|
|
|
// 获取环保技术员角色ID
|
|
|
|
|
Long environmentalTechnicianRoleId = 0L; |
|
|
|
|
Long environmentalTechnicianRoleId = 1123598816738675202L; |
|
|
|
|
String roleName = "环保技术员"; |
|
|
|
|
|
|
|
|
|
// 为每条未处理的报警记录发送提醒(只发送一次)
|
|
|
|
|
|