From d07f2ed521887c5839384a28aa4f85db8118dbb9 Mon Sep 17 00:00:00 2001 From: wu Date: Fri, 17 May 2024 17:04:20 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9110=E7=AE=97=E6=B3=95?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E4=B8=BA11=E8=8E=B7=E5=8F=96=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E5=90=8E=E6=89=A7=E8=A1=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- alarm/src/main/java/com/yingji/quartz/AlarmQuartz.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/alarm/src/main/java/com/yingji/quartz/AlarmQuartz.java b/alarm/src/main/java/com/yingji/quartz/AlarmQuartz.java index 0ef0068..494ff3e 100644 --- a/alarm/src/main/java/com/yingji/quartz/AlarmQuartz.java +++ b/alarm/src/main/java/com/yingji/quartz/AlarmQuartz.java @@ -1,6 +1,7 @@ package com.yingji.quartz; import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.http.HttpRequest; import cn.hutool.json.JSONUtil; @@ -52,19 +53,21 @@ public class AlarmQuartz { List idList = findId(token); // 根据id查询数据保存 addList(idList, token); + // 110算法接口 + if (CollectionUtil.isNotEmpty(idList)) { + emergencyAlgorithm(); + } } /** * 110算法接口 */ - @Async - @Scheduled(cron = "0 */5 * * * ? ") public void emergencyAlgorithm() { log.info("============110算法接口开始" + LocalDateTime.now() + "============="); // 获取当前的时间 LocalDateTime endTime = LocalDateTime.now(); // 获取五分钟前时间 - LocalDateTime startTime = endTime.minusMinutes(5); + LocalDateTime startTime = endTime.minusMinutes(1); DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"); String endTimeStr = endTime.format(formatter) + ":00"; String startTimeStr = startTime.format(formatter) + ":00";