运单预警

performance-web/src/main/java/com/clx/performance/controller/temp/TempTraceController.java

 package com.clx.performance.controller.temp;
 
 import com.clx.performance.dto.gd.GdRouteDTO;
+import com.clx.performance.param.mq.trace.TruckTraceSyncMqParam;
 import com.clx.performance.param.temp.DriverTraceAddParam;
 import com.clx.performance.param.temp.TruckTraceAddParam;
+import com.clx.performance.service.trace.TruckTraceMqHandlerService;
 import com.clx.performance.service.trace.TruckTraceService;
 import com.clx.performance.utils.gd.GdService;
 import com.clx.performance.vo.pc.trace.DriverTraceVO;
@@ -37,6 +39,21 @@ public class TempTraceController {
     @Autowired
     private GdService gdService;
 
+    @Autowired
+    private TruckTraceMqHandlerService truckTraceMqHandlerService;
+
+    @ApiOperation(value = "test", notes = "<br>By:艾庆国")
+    @PostMapping("/test")
+    public Result test(String truckNo, String beginTime, String endTime) {
+        TruckTraceSyncMqParam mq = new TruckTraceSyncMqParam();
+        mq.setTruckNo(truckNo);
+        mq.setBeginTime(beginTime);
+        mq.setEndTime(endTime);
+
+        truckTraceMqHandlerService.truckTracSync(mq);
+
+        return Result.ok();
+    }
     @ApiOperation(value = "车辆轨迹同步", notes = "<br>By:艾庆国")
     @PostMapping("/truckTraceSync")
     public Result truckTraceSync(@RequestBody TruckTraceAddParam param) {

performance-web/src/main/java/com/clx/performance/service/impl/trace/TruckTraceMqHandlerServiceImpl.java

@@ -63,13 +63,14 @@ public class TruckTraceMqHandlerServiceImpl implements TruckTraceMqHandlerServic
         List<TruckTraceESPlus> esList = new ArrayList<>();
         for (TruckTraceDTO item : list) {
             TruckTraceESPlus es = new TruckTraceESPlus();
-            es.setTruckNo(item.getTruckNo());
+            es.setTruckNo(mq.getTruckNo());
             es.setAngle(item.getAngle());
             es.setHeight(item.getHeight());
             es.setLocation(new BigDecimal[]{item.getLocation()[0], item.getLocation()[1]});
             es.setGpsTime(item.getGpsTime());
             es.setMileage(item.getMileage());
             es.setSpeed(item.getSpeed());
+            es.setCreateTime(LocalDateTimeUtils.formatTime());
 
             esList.add(es);
         }