add 电动车轨迹同步

ruoyi-admin/src/main/java/com/ruoyi/web/controller/task/ElectricCarTask.java

@@ -0,0 +1,27 @@
+package com.ruoyi.web.controller.task;
+
+import com.ruoyi.qdtl.service.ITlElectricDeviceLocationService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Description: 电瓶车定位相关任务
+ * @Author: huangcheng
+ * @Date: 2022/6/23
+ * @Version V1.0
+ */
+@Component("electricCarTask")
+@Slf4j
+public class ElectricCarTask {
+
+    @Autowired
+    private ITlElectricDeviceLocationService electricDeviceLocationService;
+
+    /**
+     * 同步电动车位置信息
+     */
+    public void syncLocation() {
+        electricDeviceLocationService.syncDeviceLocation();
+    }
+}

ruoyi-system/src/main/java/com/ruoyi/qdtl/service/impl/TlElectricDeviceLocationServiceImpl.java

@@ -1,5 +1,6 @@
 package com.ruoyi.qdtl.service.impl;
 
+import cn.hutool.core.util.StrUtil;
 import com.ruoyi.qdtl.domain.TlElectricDeviceLocation;
 import com.ruoyi.qdtl.mapper.TlElectricDeviceLocationMapper;
 import com.ruoyi.qdtl.service.IQdCommonService;
@@ -9,6 +10,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * 电动车定位设备轨迹Service业务层处理
@@ -82,7 +84,8 @@ public class TlElectricDeviceLocationServiceImpl implements ITlElectricDeviceLoc
     @Override
     public void syncDeviceLocation() {
         List<TlElectricDeviceLocation> electricCarsDeviceLocationList = qdCommonService.getElectricCarsDeviceLocationList();
-        if (electricCarsDeviceLocationList != null && electricCarsDeviceLocationList.size() > 0) {
+        electricCarsDeviceLocationList = electricCarsDeviceLocationList.stream().filter(a -> StrUtil.equals(a.getActivationFlag(), "1")).collect(Collectors.toList());
+        if (electricCarsDeviceLocationList.size() > 0) {
             tlElectricDeviceLocationMapper.saveBatch(electricCarsDeviceLocationList);
         }
         log.info("同步最新的定位数据量：{}条", electricCarsDeviceLocationList.size());