refactor(P1): 字段注入→构造函数注入，扩展配置校验

- VehicleSyncTask: 10个@Autowired字段改为final+构造函数注入
- MqttGenericConsumer: 3个@Autowired字段改为构造函数参数
- IotProperties: validate()新增brokerUrl和url空值校验
- MqttGenericConsumerTest: 更新匹配4参数构造函数

iot-platform/src/main/java/com/iot/platform/config/IotProperties.java

@@ -20,8 +20,10 @@ public class IotProperties {
     @PostConstruct
     public void validate() {
         List<String> errors = new ArrayList<>();
+        if (isBlank(mqtt.getBrokerUrl())) errors.add("iot.mqtt.broker-url 不能为空");
         if (isBlank(mqtt.getUsername())) errors.add("iot.mqtt.username 不能为空");
         if (isBlank(mqtt.getPassword())) errors.add("iot.mqtt.password 不能为空");
+        if (isBlank(tdengine.getUrl())) errors.add("iot.tdengine.url 不能为空");
         if (isBlank(tdengine.getUsername())) errors.add("iot.tdengine.username 不能为空");
         if (isBlank(tdengine.getPassword())) errors.add("iot.tdengine.password 不能为空");
         if (!errors.isEmpty()) {

iot-platform/src/main/java/com/iot/platform/mqtt/MqttGenericConsumer.java

@@ -21,18 +21,21 @@ import java.util.concurrent.ExecutorService;
 @Component
 public class MqttGenericConsumer extends AbstractMqttConsumer {
 
-    @Autowired
-    private StringRedisTemplate stringRedisTemplate;
-    @Autowired
-    public SysControllerService sysControllerService;
-    @Autowired
-    public MqttDynamicConsumer messageListenerService2;
+    private final StringRedisTemplate stringRedisTemplate;
+    private final SysControllerService sysControllerService;
+    private final MqttDynamicConsumer messageListenerService2;
 
     private final ObjectMapper objectMapper = new ObjectMapper();
 
     @Autowired
-    public MqttGenericConsumer(@Qualifier("abstractConsumerExecutor") ExecutorService executorService) {
+    public MqttGenericConsumer(@Qualifier("abstractConsumerExecutor") ExecutorService executorService,
+                               StringRedisTemplate stringRedisTemplate,
+                               SysControllerService sysControllerService,
+                               MqttDynamicConsumer messageListenerService2) {
         super(executorService);
+        this.stringRedisTemplate = stringRedisTemplate;
+        this.sysControllerService = sysControllerService;
+        this.messageListenerService2 = messageListenerService2;
     }
 
     @Override

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

@@ -28,26 +28,39 @@ public class VehicleSyncTask {
 
     private static final Logger log = LoggerFactory.getLogger(VehicleSyncTask.class);
 
+    private final SysCarService sysCarService;
+    private final SysDeviceService sysDeviceService;
+    private final StringRedisTemplate stringRedisTemplate;
+    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;
+
     @Autowired
-    public SysCarService sysCarService;
-    @Autowired
-    public SysDeviceService sysDeviceService;
-    @Autowired
-    private StringRedisTemplate stringRedisTemplate;
-    @Autowired
-    private SysrealtimeService sysrealtimeService;
-    @Autowired
-    public SysDeviceVoService sysDeviceVoService;
-    @Autowired
-    public SysDeviceControlService sysDeviceControlService;
-    @Autowired
-    public SysWorkorderService sysWorkorderService;
-    @Autowired
-    public SysIndicatorsService sysIndicatorsService;
-    @Autowired
-    public SysCompanyService sysCompanyService;
-    @Autowired
-    private RestTemplate restTemplate;
+    public VehicleSyncTask(SysCarService sysCarService,
+                           SysDeviceService sysDeviceService,
+                           StringRedisTemplate stringRedisTemplate,
+                           SysrealtimeService sysrealtimeService,
+                           SysDeviceVoService sysDeviceVoService,
+                           SysDeviceControlService sysDeviceControlService,
+                           SysWorkorderService sysWorkorderService,
+                           SysIndicatorsService sysIndicatorsService,
+                           SysCompanyService sysCompanyService,
+                           RestTemplate restTemplate) {
+        this.sysCarService = sysCarService;
+        this.sysDeviceService = sysDeviceService;
+        this.stringRedisTemplate = stringRedisTemplate;
+        this.sysrealtimeService = sysrealtimeService;
+        this.sysDeviceVoService = sysDeviceVoService;
+        this.sysDeviceControlService = sysDeviceControlService;
+        this.sysWorkorderService = sysWorkorderService;
+        this.sysIndicatorsService = sysIndicatorsService;
+        this.sysCompanyService = sysCompanyService;
+        this.restTemplate = restTemplate;
+    }
 
     private boolean tryLock(String lockKey, long expireSeconds) {
         Boolean acquired = stringRedisTemplate.opsForValue().setIfAbsent(lockKey, "1", expireSeconds, TimeUnit.SECONDS);

iot-platform/src/test/java/com/iot/platform/mqtt/MqttGenericConsumerTest.java

@@ -1,28 +1,38 @@
 package com.iot.platform.mqtt;
 
+import com.iot.platform.service.SysControllerService;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
+import org.springframework.data.redis.core.StringRedisTemplate;
 
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.mockito.Mockito.mock;
 
 class MqttGenericConsumerTest {
 
     private final ExecutorService executorService = Executors.newSingleThreadExecutor();
+    private final StringRedisTemplate stringRedisTemplate = mock(StringRedisTemplate.class);
+    private final SysControllerService sysControllerService = mock(SysControllerService.class);
+    private final MqttDynamicConsumer mqttDynamicConsumer = mock(MqttDynamicConsumer.class);
+
+    private MqttGenericConsumer createConsumer() {
+        return new MqttGenericConsumer(executorService, stringRedisTemplate, sysControllerService, mqttDynamicConsumer);
+    }
 
     @Test
     @DisplayName("getSubscribeTopic 应返回 +/generics")
     void getSubscribeTopic_returnsCorrectValue() {
-        MqttGenericConsumer consumer = new MqttGenericConsumer(executorService);
+        MqttGenericConsumer consumer = createConsumer();
         assertThat(consumer.getSubscribeTopic()).isEqualTo("+/generics");
     }
 
     @Test
     @DisplayName("generateClientId 应包含 mqttx 前缀")
     void generateClientId_containsPrefix() {
-        MqttGenericConsumer consumer = new MqttGenericConsumer(executorService);
+        MqttGenericConsumer consumer = createConsumer();
         String clientId = consumer.generateClientId();
         assertThat(clientId).startsWith("mqttx_e216fbf16");
     }