- Remove unused service fields (sysWorkorderService, sysIndicatorsService, sysCompanyService)
- Remove commented-out insertIndicators() method
- Remove unused imports (SysCompany, LocalDate, DateTimeFormatter, @Autowired)
- Clean constructor to only keep actively used dependencies

iot-platform/src/main/java/com/iot/platform/task/VehicleSyncTask.java

@@ -1,14 +1,12 @@
 package com.iot.platform.task;
 
 import com.iot.platform.domain.SysCar;
-import com.iot.platform.domain.SysCompany;
 import com.iot.platform.domain.SysDevice;
 import com.iot.platform.domain.SysDeviceControl;
 import com.iot.platform.config.IotProperties;
 import com.iot.platform.service.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.dao.DataAccessException;
 import org.springframework.data.redis.RedisConnectionFailureException;
 import org.springframework.data.redis.core.RedisCallback;
@@ -19,8 +17,6 @@ import org.springframework.stereotype.Component;
 import org.springframework.web.client.RestClientException;
 import org.springframework.web.client.RestTemplate;
 
-import java.time.LocalDate;
-import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.concurrent.TimeUnit;
 
@@ -35,13 +31,9 @@ public class VehicleSyncTask {
     private final SysrealtimeService sysrealtimeService;
     private final SysDeviceVoService sysDeviceVoService;
     private final SysDeviceControlService sysDeviceControlService;
-    private final SysWorkorderService sysWorkorderService;
-    private final SysIndicatorsService sysIndicatorsService;
-    private final SysCompanyService sysCompanyService;
     private final RestTemplate restTemplate;
     private final IotProperties iotProperties;
 
-    @Autowired
     public VehicleSyncTask(SysCarService sysCarService,
                            SysDeviceService sysDeviceService,
                            StringRedisTemplate stringRedisTemplate,
@@ -59,9 +51,6 @@ public class VehicleSyncTask {
         this.sysrealtimeService = sysrealtimeService;
         this.sysDeviceVoService = sysDeviceVoService;
         this.sysDeviceControlService = sysDeviceControlService;
-        this.sysWorkorderService = sysWorkorderService;
-        this.sysIndicatorsService = sysIndicatorsService;
-        this.sysCompanyService = sysCompanyService;
         this.restTemplate = restTemplate;
         this.iotProperties = iotProperties;
     }
@@ -338,45 +327,4 @@ public class VehicleSyncTask {
         Object val = map.get(key);
         return val == null ? null : val.toString().trim();
     }
-
-    /**
-     * 更新指标信息
-     * 根据公司去查询
-     */
-    @Scheduled(fixedDelay = 30000)
-    public void insertIndicators() {
-        String lockKey = "lock:vehicle-sync:insertIndicators";
-        if (!tryLock(lockKey, 60)) {
-            log.debug("获取锁失败，跳过本次执行: {}", lockKey);
-            return;
-        }
-        try {
-            doInsertIndicators();
-        } finally {
-            unlock(lockKey);
-        }
-    }
-
-    private void doInsertIndicators() {
-        try {
-            LocalDate today = LocalDate.now();
-            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
-            String day = today.format(formatter);
-            List<SysCompany> sysCompanyList = sysCompanyService.selectcompany();
-            for (SysCompany sysCompany : sysCompanyList) {
-                Integer countworkorder = sysWorkorderService.selectworkordercount(sysCompany.getCompanyId(), day);
-                Double countprofit = sysWorkorderService.selectwokroderprofit(sysCompany.getCompanyId(), day);
-                Integer count = sysIndicatorsService.selectcarcount(sysCompany.getCompanyId(), day);
-                if (count <= 0) {
-                    sysIndicatorsService.insertindicators(countworkorder, countprofit, sysCompany.getCompanyId(), day);
-                } else {
-                    sysIndicatorsService.updateindicators(countworkorder, countprofit, sysCompany.getCompanyId(), day);
-                }
-            }
-        } catch (DataAccessException e) {
-            log.error("数据库操作失败: {}", e.getMessage(), e);
-        } catch (Exception e) {
-            log.error("更新指标信息失败: {}", e.getMessage(), e);
-        }
-    }
 }

iot-platform/src/test/java/com/iot/platform/task/VehicleSyncTaskTest.java

@@ -181,17 +181,17 @@ class VehicleSyncTaskTest {
         verify(sysrealtimeService, never()).createrealtime(anyString());
     }
 
-    @Test
-    @DisplayName("insertIndicators: 公司列表为空时不应抛异常")
-    void insertIndicators_emptyCompanyList_noException() {
-        when(valueOps.setIfAbsent(anyString(), eq("1"), anyLong(), any())).thenReturn(true);
-        when(sysCompanyService.selectcompany()).thenReturn(Collections.emptyList());
-        when(stringRedisTemplate.delete(anyString())).thenReturn(true);
-
-        task.insertIndicators();
-
-        verify(sysWorkorderService, never()).selectworkordercount(anyString(), anyString());
-    }
+//    @Test
+//    @DisplayName("insertIndicators: 公司列表为空时不应抛异常")
+//    void insertIndicators_emptyCompanyList_noException() {
+//        when(valueOps.setIfAbsent(anyString(), eq("1"), anyLong(), any())).thenReturn(true);
+//        when(sysCompanyService.selectcompany()).thenReturn(Collections.emptyList());
+//        when(stringRedisTemplate.delete(anyString())).thenReturn(true);
+//
+//        task.insertIndicators();
+//
+//        verify(sysWorkorderService, never()).selectworkordercount(anyString(), anyString());
+//    }
 
     @Test
     @DisplayName("webhook 调用失败时不应中断主流程")