package com.aiotagro.cattletrade.test;

import com.aiotagro.cattletrade.business.service.IotDeviceLogSyncService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;

/**
 * 设备日志同步功能测试
 *
 * @author System
 * @date 2025-01-16
 */
@SpringBootTest
@SpringJUnitConfig
public class IotDeviceLogSyncTest {

    @Autowired
    private IotDeviceLogSyncService iotDeviceLogSyncService;

    /**
     * 测试设备日志同步功能
     */
    @Test
    public void testSyncDeviceDataToLogs() {
        try {
            System.out.println("=== 开始测试设备日志同步功能 ===");
            
            // 执行同步
            iotDeviceLogSyncService.syncDeviceDataToLogs();
            
            // 输出统计信息
            iotDeviceLogSyncService.logSyncStatistics();
            
            System.out.println("=== 设备日志同步功能测试完成 ===");
            
        } catch (Exception e) {
            System.err.println("设备日志同步功能测试失败: " + e.getMessage());
            e.printStackTrace();
        }
    }

    /**
     * 测试日志统计功能
     */
    @Test
    public void testLogSyncStatistics() {
        try {
            System.out.println("=== 开始测试日志统计功能 ===");
            
            iotDeviceLogSyncService.logSyncStatistics();
            
            System.out.println("=== 日志统计功能测试完成 ===");
            
        } catch (Exception e) {
            System.err.println("日志统计功能测试失败: " + e.getMessage());
            e.printStackTrace();
        }
    }
}
