From a9703f2322b8b2b83b5988d0183ad7a8c00cf403 Mon Sep 17 00:00:00 2001 From: yinq Date: Tue, 17 Jun 2025 10:09:51 +0800 Subject: [PATCH] =?UTF-8?q?change=20-=20=E8=B6=85=E8=BF=87=E7=94=B5?= =?UTF-8?q?=E9=98=88=E5=80=BC=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/EmsRecordAlarmDataServiceImpl.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java b/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java index 5d2962f..caf26ff 100644 --- a/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java @@ -1,6 +1,8 @@ package com.os.ems.record.service.impl; import java.math.BigDecimal; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.Date; import java.util.HashMap; import java.util.List; @@ -188,9 +190,18 @@ public class EmsRecordAlarmDataServiceImpl implements IEmsRecordAlarmDataService public void exceedDnbThresholdAlarmsTask() { EmsBaseMonitorThreshold monitorThreshold = new EmsBaseMonitorThreshold(); monitorThreshold.setMonitorType(2L); + String nowTime = DateUtils.getTime(); + String endTime = LocalDateTime + .parse(nowTime, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + .plusMinutes(1) // 加一分钟 + .format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); List thresholdList = emsBaseMonitorThresholdMapper.selectEmsBaseMonitorThresholdList(monitorThreshold); EmsRecordDnbInstant dnbInstant = new EmsRecordDnbInstant(); + HashMap selectMap = new HashMap<>(); + selectMap.put("beginRecordTime", nowTime); + selectMap.put("endRecordTime", endTime); + dnbInstant.setParams(selectMap); List dnbInstantList = emsRecordDnbInstantMapper.selectEmsRecordDnbInstantList(dnbInstant); Map thresholdMap = compareThresholdAndRecord(thresholdList, dnbInstantList); //防止多次存入异常数据