package com.hfln.device.application.task;

import com.hfln.device.domain.entity.Device;
import com.hfln.device.domain.service.DeviceManagerService;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
import java.util.*;
import static org.mockito.Mockito.*;

class DeviceStatusCheckTaskTest {
    @Mock
    DeviceManagerService deviceManagerService;
    @InjectMocks
    DeviceStatusCheckTask deviceStatusCheckTask;
    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
    }
    @Test
    void testCheckDeviceKeepAlive() {
        Device device = new Device("dev001");
        device.setKeepaliveTime(System.currentTimeMillis() - 100000);
        when(deviceManagerService.getAllDevicesFromCache()).thenReturn(Collections.singletonList(device));
        deviceStatusCheckTask.checkDeviceKeepAlive();
        // 可根据业务补充verify
    }
    @Test
    void testCheckAllDeviceAlarmPlan() {
        Device device = new Device("dev001");
        when(deviceManagerService.getAllDevicesFromCache()).thenReturn(Collections.singletonList(device));
        deviceStatusCheckTask.checkAllDeviceAlarmPlan();
        // 可根据业务补充verify
    }
}