package com.ruoyi.system.service.impl;

import com.ruoyi.common.annotation.DataSource;
import com.ruoyi.common.enums.DataSourceType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.ruoyi.system.domain.VehicleSyncDTO;
import com.ruoyi.system.mapper.VehicleSyncMapper;
import com.ruoyi.system.service.IVehicleSyncDataService;

import java.util.List;

/**
 * SQL Server 车辆数据查询服务实现
 * 
 * 职责：专门负责从 SQL Server 查询车辆数据
 * 
 * 数据流向：SQL Server → 返回 DTO 列表
 * 
 * @author ruoyi
 * @date 2025-10-20
 */
@Service
@DataSource(DataSourceType.SQLSERVER)
public class VehicleSyncDataServiceImpl implements IVehicleSyncDataService
{
    private static final Logger log = LoggerFactory.getLogger(VehicleSyncDataServiceImpl.class);

    @Autowired
    private VehicleSyncMapper vehicleSyncMapper;

    /**
     * 从 SQL Server 查询所有正常状态的车辆数据
     * 
     * 注意：VehicleSyncMapper 上有 @DataSource(DataSourceType.SQLSERVER) 注解
     * 此方法会自动切换到 SQL Server 数据源执行查询
     * 
     * @return 车辆列表
     */
    @Override
    public List<VehicleSyncDTO> getVehiclesFromSqlServer()
    {
        try
        {
            log.info("开始从 SQL Server 查询车辆数据...");
            
            // 调用 Mapper 查询 SQL Server 数据
            // @DataSource 注解会自动切换数据源
            List<VehicleSyncDTO> vehicles = vehicleSyncMapper.selectVehiclesFromSqlServer();
            
            if (vehicles == null || vehicles.isEmpty())
            {
                log.warn("未从 SQL Server 查询到车辆数据");
                return vehicles;
            }
            
            log.info("从 SQL Server 查询到 {} 条车辆数据", vehicles.size());
            return vehicles;
        }
        catch (Exception e)
        {
            log.error("从 SQL Server 查询车辆数据失败", e);
            throw new RuntimeException("查询 SQL Server 车辆数据失败: " + e.getMessage(), e);
        }
    }
}