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.UserSyncDTO;
|
import com.ruoyi.system.mapper.UserSyncMapper;
|
import com.ruoyi.system.service.IUserSyncDataService;
|
|
import java.util.List;
|
|
/**
|
* SQL Server 用户数据查询服务实现
|
*
|
* 职责：专门负责从 SQL Server 查询用户数据
|
*
|
* 数据流向：SQL Server → 返回 DTO 列表
|
*
|
* @author ruoyi
|
* @date 2025-10-18
|
*/
|
@Service
|
@DataSource(DataSourceType.SQLSERVER)
|
public class UserSyncDataServiceImpl implements IUserSyncDataService
|
{
|
private static final Logger log = LoggerFactory.getLogger(UserSyncDataServiceImpl.class);
|
|
@Autowired
|
private UserSyncMapper userSyncMapper;
|
|
/**
|
* 从 SQL Server 查询 OA 用户数据
|
*
|
* 注意：UserSyncMapper 上有 @DataSource(DataSourceType.SQLSERVER) 注解
|
* 此方法会自动切换到 SQL Server 数据源执行查询
|
*
|
* @return OA 用户列表
|
*/
|
@Override
|
public List<UserSyncDTO> getOaUsers()
|
{
|
try
|
{
|
log.info("开始从 SQL Server 查询 OA 用户数据...");
|
|
// 调用 Mapper 查询 SQL Server 数据
|
// @DataSource 注解会自动切换数据源
|
List<UserSyncDTO> oaUsers = userSyncMapper.selectOaUsers();
|
|
if (oaUsers == null || oaUsers.isEmpty())
|
{
|
log.warn("未从 SQL Server 查询到 OA 用户数据");
|
return oaUsers;
|
}
|
|
log.info("从 SQL Server 查询到 {} 条 OA 用户数据", oaUsers.size());
|
return oaUsers;
|
}
|
catch (Exception e)
|
{
|
log.error("从 SQL Server 查询 OA 用户数据失败", e);
|
throw new RuntimeException("查询 SQL Server 用户数据失败: " + e.getMessage(), e);
|
}
|
}
|
}
|
