diff --git a/alarm/src/main/java/com/yingji/quartz/AlarmQuartz.java b/alarm/src/main/java/com/yingji/quartz/AlarmQuartz.java index 7ea393e..0ef0068 100644 --- a/alarm/src/main/java/com/yingji/quartz/AlarmQuartz.java +++ b/alarm/src/main/java/com/yingji/quartz/AlarmQuartz.java @@ -2,6 +2,8 @@ package com.yingji.quartz; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.StrUtil; +import cn.hutool.http.HttpRequest; +import cn.hutool.json.JSONUtil; import com.yingji.entity.Alarm; import com.yingji.entity.dto.request.AlarmRequest; import com.yingji.service.AlarmService; @@ -16,7 +18,9 @@ import javax.annotation.Resource; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.ArrayList; +import java.util.HashMap; import java.util.List; +import java.util.Map; import java.util.Random; /** @@ -46,6 +50,39 @@ public class AlarmQuartz { String token = alarmService.getToken(); // 查询所有id List idList = findId(token); + // 根据id查询数据保存 + addList(idList, token); + } + + /** + * 110算法接口 + */ + @Async + @Scheduled(cron = "0 */5 * * * ? ") + public void emergencyAlgorithm() { + log.info("============110算法接口开始" + LocalDateTime.now() + "============="); + // 获取当前的时间 + LocalDateTime endTime = LocalDateTime.now(); + // 获取五分钟前时间 + LocalDateTime startTime = endTime.minusMinutes(5); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"); + String endTimeStr = endTime.format(formatter) + ":00"; + String startTimeStr = startTime.format(formatter) + ":00"; + Map map = new HashMap<>(); + map.put("startTime", startTimeStr); + map.put("endTime", endTimeStr); + String body = JSONUtil.toJsonStr(map); + HttpRequest.post("http://localhost:9002/emergency_algorithm").body(body).execute().body(); + log.info("============110算法接口结束" + LocalDateTime.now() + "============="); + } + + /** + * 根据id查询数据保存 + * + * @param idList 数据id + * @param token token + */ + private void addList(List idList, String token) { // 查询数据条件 AlarmRequest alarmRequest = new AlarmRequest(); alarmRequest.setType("getValue"); @@ -59,6 +96,7 @@ public class AlarmQuartz { try { for (String x : idList) { alarmRequest.setValue(x); + // 查询数据 Alarm alarm = alarmService.findDataList(alarmRequest, token); if (alarm != null) { alarm.setSourceId(x); diff --git a/page/src/main/resources/mapper/yingji/AlarmMapper.xml b/page/src/main/resources/mapper/yingji/AlarmMapper.xml index 7224616..8b29db9 100644 --- a/page/src/main/resources/mapper/yingji/AlarmMapper.xml +++ b/page/src/main/resources/mapper/yingji/AlarmMapper.xml @@ -7,41 +7,40 @@ diff --git a/rescue/src/main/java/com/yingji/service/impl/AccidentServiceImpl.java b/rescue/src/main/java/com/yingji/service/impl/AccidentServiceImpl.java index 07c6b9e..13644d9 100644 --- a/rescue/src/main/java/com/yingji/service/impl/AccidentServiceImpl.java +++ b/rescue/src/main/java/com/yingji/service/impl/AccidentServiceImpl.java @@ -215,14 +215,14 @@ public class AccidentServiceImpl implements AccidentService { Task one = taskService.getOne(wrapper); if (BeanUtil.isEmpty(one)) { taskService.save(task); + Amb amb = taskInfo.getAmb(); + if (BeanUtil.isNotEmpty(amb)) { + amb.setTaskId(task.getTaskId()); + ambService.save(amb); + } } else { taskService.updateById(task); } - Amb amb = taskInfo.getAmb(); - if (BeanUtil.isNotEmpty(amb)) { - amb.setTaskId(task.getTaskId()); - ambService.save(amb); - } } } }