package cn.gistack.job.executor.jobhandler;
|
|
import cn.gistack.sm.sjztmd.feign.IAttResManagePersonClient;
|
import cn.gistack.system.user.feign.IUserClient;
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.xxl.job.core.log.XxlJobLogger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* @PROJECT_NAME: skjcmanager
|
* @DESCRIPTION: 用户调度器
|
* @USER: aix
|
* @DATE: 2023/6/17 10:24
|
*/
|
@Component
|
public class UserXxlJob {
|
|
@Autowired
|
private IAttResManagePersonClient attResManagePersonClient;
|
|
@Autowired
|
private IUserClient userClient;
|
|
/**
|
* 用户同步调度器
|
* @return
|
*/
|
@XxlJob("synchronizationUserJobHandler")
|
public ReturnT<String> execute(String param) {
|
XxlJobLogger.log("开始用户同步任务...");
|
int retAddInt = attResManagePersonClient.syncharonization_add_user();
|
XxlJobLogger.log("新增用户：<span style='color:red'>" + retAddInt + "</span>");
|
int retupInt = attResManagePersonClient.syncharonization_update_user();
|
XxlJobLogger.log("修改用户：<span style='color:red'>" + retupInt + "</span>");
|
XxlJobLogger.log("结束用户同步任务...");
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 用户同步调度器
|
* @return
|
*/
|
@XxlJob("encryptUserJobHandler")
|
public ReturnT<String> encryptUser(String param) {
|
XxlJobLogger.log("开始更新用户数据");
|
|
String message = userClient.encryptUser();
|
XxlJobLogger.log(message);
|
XxlJobLogger.log("结束更新用户数据");
|
return ReturnT.SUCCESS;
|
}
|
|
}
|
