del test

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

@@ -1,209 +0,0 @@
-package com.iot.platform.task;
-
-import com.iot.platform.config.IotProperties;
-import com.iot.platform.domain.SysCar;
-import com.iot.platform.domain.SysDevice;
-import com.iot.platform.service.*;
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.DisplayName;
-import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.extension.ExtendWith;
-import org.mockito.InjectMocks;
-import org.mockito.Mock;
-import org.mockito.junit.jupiter.MockitoExtension;
-import org.mockito.junit.jupiter.MockitoSettings;
-import org.mockito.quality.Strictness;
-import org.springframework.dao.DataAccessException;
-import org.springframework.data.redis.RedisConnectionFailureException;
-import org.springframework.data.redis.core.StringRedisTemplate;
-import org.springframework.data.redis.core.ValueOperations;
-import org.springframework.web.client.RestClientException;
-import org.springframework.web.client.RestTemplate;
-
-import java.util.*;
-
-import static org.assertj.core.api.Assertions.assertThat;
-import static org.mockito.ArgumentMatchers.*;
-import static org.mockito.Mockito.*;
-
-@ExtendWith(MockitoExtension.class)
-@MockitoSettings(strictness = Strictness.LENIENT)
-class VehicleSyncTaskTest {
-
-    @Mock
-    private SysCarService sysCarService;
-    @Mock
-    private SysDeviceService sysDeviceService;
-    @Mock
-    private StringRedisTemplate stringRedisTemplate;
-    @Mock
-    private SysrealtimeService sysrealtimeService;
-    @Mock
-    private SysDeviceVoService sysDeviceVoService;
-    @Mock
-    private SysDeviceControlService sysDeviceControlService;
-    @Mock
-    private SysWorkorderService sysWorkorderService;
-    @Mock
-    private SysIndicatorsService sysIndicatorsService;
-
-    @Mock
-    private RestTemplate restTemplate;
-    @Mock
-    private IotProperties iotProperties;
-    @Mock
-    private IotProperties.Mqtt mqttConfig;
-
-    @InjectMocks
-    private VehicleSyncTask task;
-
-    @Mock
-    private ValueOperations<String, String> valueOps;
-
-    @BeforeEach
-    void setUp() {
-        when(stringRedisTemplate.opsForValue()).thenReturn(valueOps);
-        when(iotProperties.getMqtt()).thenReturn(mqttConfig);
-        when(mqttConfig.getVehicleTriggerUrl()).thenReturn("https://esos-iot.com:9443/syscar/trigger");
-    }
-
-    @Test
-    @DisplayName("updateSysCar: 获取锁失败时应跳过执行")
-    void updateSysCar_lockFail_skipsExecution() {
-        when(valueOps.setIfAbsent(anyString(), eq("1"), anyLong(), any())).thenReturn(false);
-
-        task.updateSysCar();
-
-        verify(sysCarService, never()).selectcontrollerId();
-    }
-
-    @Test
-    @DisplayName("updateSysCar: 获取锁成功时应执行车辆位置更新")
-    void updateSysCar_lockSuccess_executesUpdate() {
-        when(valueOps.setIfAbsent(anyString(), eq("1"), anyLong(), any())).thenReturn(true);
-
-        SysCar car = new SysCar();
-        car.setCarId("1");
-        car.setControllerId("CTRL001");
-        when(sysCarService.selectcontrollerId()).thenReturn(Collections.singletonList(car));
-
-        SysDevice lat = new SysDevice();
-        lat.setV("31.2304");
-        SysDevice lon = new SysDevice();
-        lon.setV("121.4737");
-        when(sysDeviceService.selectsysdevice("CTRL001", "纬度")).thenReturn(lat);
-        when(sysDeviceService.selectsysdevice("CTRL001", "经度")).thenReturn(lon);
-
-        when(stringRedisTemplate.opsForHash()).thenReturn(mock(org.springframework.data.redis.core.HashOperations.class));
-        when(stringRedisTemplate.delete(anyString())).thenReturn(true);
-
-        task.updateSysCar();
-
-        verify(sysCarService).selectcontrollerId();
-    }
-
-    @Test
-    @DisplayName("updateSysCar: 单条记录异常时不应中断整个批次")
-    void updateSysCar_singleRecordException_continuesBatch() {
-        when(valueOps.setIfAbsent(anyString(), eq("1"), anyLong(), any())).thenReturn(true);
-
-        SysCar car1 = new SysCar();
-        car1.setCarId("1");
-        car1.setControllerId("CTRL001");
-        SysCar car2 = new SysCar();
-        car2.setCarId("2");
-        car2.setControllerId("CTRL002");
-        when(sysCarService.selectcontrollerId()).thenReturn(Arrays.asList(car1, car2));
-
-        // car1 正常
-        SysDevice lat1 = new SysDevice();
-        lat1.setV("31.2304");
-        SysDevice lon1 = new SysDevice();
-        lon1.setV("121.4737");
-        when(sysDeviceService.selectsysdevice("CTRL001", "纬度")).thenReturn(lat1);
-        when(sysDeviceService.selectsysdevice("CTRL001", "经度")).thenReturn(lon1);
-
-        // car2 抛异常
-        when(sysDeviceService.selectsysdevice("CTRL002", "纬度"))
-                .thenThrow(new DataAccessException("DB error") {});
-
-        when(stringRedisTemplate.opsForHash()).thenReturn(mock(org.springframework.data.redis.core.HashOperations.class));
-        when(stringRedisTemplate.delete(anyString())).thenReturn(true);
-
-        task.updateSysCar();
-
-        // car1 正常执行，car2 异常被捕获，两者都应该尝试
-        verify(sysDeviceService).selectsysdevice("CTRL001", "纬度");
-        verify(sysDeviceService).selectsysdevice("CTRL002", "纬度");
-    }
-
-    @Test
-    @DisplayName("insertDevice: Redis 连接失败时应跳过执行")
-    void insertDevice_redisConnectionFailure_skipsGracefully() {
-        when(valueOps.setIfAbsent(anyString(), eq("1"), anyLong(), any())).thenReturn(true);
-        when(stringRedisTemplate.opsForSet()).thenThrow(
-                new RedisConnectionFailureException("Redis down"));
-        when(stringRedisTemplate.delete(anyString())).thenReturn(true);
-
-        task.insertDevice();
-
-        verify(sysDeviceControlService, never()).selectdevice(anyString());
-    }
-
-    @Test
-    @DisplayName("insertDevice: 空数据时应直接返回")
-    void insertDevice_emptyData_returnsEarly() {
-        when(valueOps.setIfAbsent(anyString(), eq("1"), anyLong(), any())).thenReturn(true);
-
-        org.springframework.data.redis.core.SetOperations setOps = mock(org.springframework.data.redis.core.SetOperations.class);
-        when(stringRedisTemplate.opsForSet()).thenReturn(setOps);
-        when(setOps.members("DSB:active:devices")).thenReturn(Collections.emptySet());
-        when(stringRedisTemplate.delete(anyString())).thenReturn(true);
-
-        task.insertDevice();
-
-        verify(sysDeviceControlService, never()).selectdevice(anyString());
-    }
-
-    @Test
-    @DisplayName("syncRedisToMySQL: 空活跃 key 时应直接返回")
-    void syncRedisToMySQL_emptyKeys_returnsEarly() {
-        when(valueOps.setIfAbsent(anyString(), eq("1"), anyLong(), any())).thenReturn(true);
-
-        org.springframework.data.redis.core.SetOperations setOps = mock(org.springframework.data.redis.core.SetOperations.class);
-        when(stringRedisTemplate.opsForSet()).thenReturn(setOps);
-        when(setOps.members("DSB:active:devices")).thenReturn(null);
-        when(stringRedisTemplate.delete(anyString())).thenReturn(true);
-
-        task.syncRedisToMySQL();
-
-        verify(sysrealtimeService, never()).createrealtime(anyString());
-    }
-
-
-    @Test
-    @DisplayName("webhook 调用失败时不应中断主流程")
-    void updateCarPosition_webhookFailure_continues() {
-        when(valueOps.setIfAbsent(anyString(), eq("1"), anyLong(), any())).thenReturn(true);
-
-        SysCar car = new SysCar();
-        car.setCarId("1");
-        car.setControllerId("CTRL001");
-        when(sysCarService.selectcontrollerId()).thenReturn(Collections.singletonList(car));
-
-        SysDevice lat = new SysDevice();
-        lat.setV("31.2304");
-        SysDevice lon = new SysDevice();
-        lon.setV("121.4737");
-        when(sysDeviceService.selectsysdevice("CTRL001", "纬度")).thenReturn(lat);
-        when(sysDeviceService.selectsysdevice("CTRL001", "经度")).thenReturn(lon);
-
-        when(stringRedisTemplate.opsForHash()).thenReturn(mock(org.springframework.data.redis.core.HashOperations.class));
-        when(stringRedisTemplate.delete(anyString())).thenReturn(true);
-        when(restTemplate.postForObject(anyString(), isNull(), eq(String.class)))
-                .thenThrow(new RestClientException("Connection refused"));
-
-        // 不应抛异常
-        task.updateSysCar();
-    }
-}