package com.ruoyi.quartz.task;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import com.ruoyi.common.core.domain.AjaxResult;
|
import com.ruoyi.system.domain.UserSyncDTO;
|
import com.ruoyi.system.service.IUserSyncDataService;
|
import com.ruoyi.system.service.IUserSyncService;
|
import java.util.List;
|
|
/**
|
* 企业微信用户ID同步任务
|
*
|
* 定期同步OA系统中的企业微信用户ID到本地系统
|
*
|
* @author ruoyi
|
* @date 2025-12-11
|
*/
|
@Component("qyWechatUserSyncTask")
|
public class QyWechatUserSyncTask
|
{
|
private static final Logger log = LoggerFactory.getLogger(QyWechatUserSyncTask.class);
|
|
@Autowired
|
private IUserSyncDataService userSyncDataService;
|
|
@Autowired
|
private IUserSyncService userSyncService;
|
|
/**
|
* 同步企业微信用户ID
|
*
|
* 任务执行方法，由Quartz调度器调用
|
*
|
* @return 同步结果
|
*/
|
public AjaxResult syncQyWechatUserIds()
|
{
|
try
|
{
|
log.info("开始同步企业微信用户ID...");
|
|
// 1. 从SQL Server查询OA用户数据（包含企业微信用户ID）
|
List<UserSyncDTO> oaUsers = userSyncDataService.getOaUsers();
|
|
if (oaUsers == null || oaUsers.isEmpty())
|
{
|
log.warn("未查询到OA用户数据，跳过同步");
|
return AjaxResult.warn("未查询到OA用户数据");
|
}
|
|
log.info("从OA系统查询到 {} 条用户数据", oaUsers.size());
|
|
// 2. 同步到MySQL数据库
|
AjaxResult result = userSyncService.syncOaUsers(oaUsers);
|
|
log.info("企业微信用户ID同步完成: {}", result.get("msg"));
|
return result;
|
}
|
catch (Exception e)
|
{
|
log.error("同步企业微信用户ID失败", e);
|
return AjaxResult.error("同步失败: " + e.getMessage());
|
}
|
}
|
}
|
