预警配置

performance-web/src/main/java/com/clx/performance/job/TruckTraceJob.java

@@ -102,28 +102,4 @@ public class TruckTraceJob {
         }
     }
 
-
-    /**
-     * 车辆轨迹同步
-     */
-    @XxlJob("truckTraceSync")
-    public void truckTraceSync() {
-        try {
-            List<String> truckNoList = new ArrayList<>();
-            log.info("车辆轨迹同步, size:{}", truckNoList.size());
-
-            for (String truckNo : truckNoList) {
-
-                LocalDateTime now = LocalDateTime.now();
-
-                // 发送mq (同步车辆轨迹)
-                truckTraceMqService.truckTracSync(truckNo, LocalDateTimeUtils.formatTime(now.minusSeconds(600)), LocalDateTimeUtils.formatTime(now));
-            }
-
-        } catch (Exception e) {
-            log.warn("车辆轨迹同步失败，异常原因:{}",e);
-            JobLog.error("车辆轨迹同步失败，异常原因=====================", e);
-        }
-    }
-
 }

performance-web/src/main/java/com/clx/performance/job/trace/VehicleTraceJob.java

+package com.clx.performance.job.trace;
+
+import com.clx.performance.dao.vehiclewarn.VehicleWarnChildDao;
+import com.clx.performance.model.vehiclewarn.VehicleWarnChild;
+import com.clx.performance.service.trace.TruckTraceMqService;
+import com.clx.performance.utils.LocalDateTimeUtils;
+import com.msl.common.job.JobLog;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.exception.ExceptionUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+@Slf4j
+@Component
+public class VehicleTraceJob {
+
+    @Autowired
+    private VehicleWarnChildDao vehicleWarnChildDao;
+    @Autowired
+    private TruckTraceMqService truckTraceMqService;
+
+
+    /**
+     * 车辆轨迹同步
+     */
+    @XxlJob("truckTraceSync")
+    public void truckTraceSync() {
+        try {
+
+            List<VehicleWarnChild> list = vehicleWarnChildDao.ListTruckNoOfTrace();
+            log.info("车辆轨迹同步, size:{}", list.size());
+
+            for (VehicleWarnChild item : list) {
+
+                LocalDateTime now = LocalDateTime.now();
+                LocalDateTime beginTime = now.minusSeconds(600);
+
+                // 发送mq (同步车辆轨迹)
+                truckTraceMqService.truckTracSync(item.getTruckNo(), item.getTruckNo(), LocalDateTimeUtils.formatTime(beginTime), LocalDateTimeUtils.formatTime(now));
+            }
+
+        } catch (Exception e) {
+            log.warn("车辆轨迹同步失败，异常原因:{}", ExceptionUtils.getStackTrace(e));
+            JobLog.error("车辆轨迹同步失败，异常原因=====================", e);
+        }
+    }
+
+}

performance-web/src/main/java/com/clx/performance/job/vehiclewarn/VehicleWarnJob.java

+package com.clx.performance.job.vehiclewarn;
+
+import com.clx.performance.dao.vehiclewarn.VehicleWarnChildDao;
+import com.clx.performance.model.vehiclewarn.VehicleWarnChild;
+import com.clx.performance.service.vehiclewarn.VehicleWarnMqService;
+import com.msl.common.job.JobLog;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.exception.ExceptionUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+@Slf4j
+@Component
+public class VehicleWarnJob {
+
+    @Autowired
+    private VehicleWarnChildDao vehicleWarnChildDao;
+    @Autowired
+    private VehicleWarnMqService vehicleWarnMqService;
+
+    /**
+     * 车辆预警
+     */
+    @XxlJob("truckWarn")
+    public void truckWarn() {
+
+        try {
+
+            List<VehicleWarnChild> list = vehicleWarnChildDao.ListTruckNoOfWarn();
+            log.info("车辆预警, size:{}", list.size());
+
+            for (VehicleWarnChild item : list) {
+
+                LocalDateTime now = LocalDateTime.now();
+                LocalDateTime beginTime = now.minusSeconds(600);
+
+                // 发送mq (车辆预警)
+                vehicleWarnMqService.truckWarn(item.getChildNo());
+            }
+
+        } catch (Exception e) {
+            log.warn("车辆轨迹同步失败，异常原因:{}", ExceptionUtils.getStackTrace(e));
+            JobLog.error("车辆轨迹同步失败，异常原因=====================", e);
+        }
+
+    }
+}