package com.dy.pipIrrStatistics.statistics;
|
|
import com.dy.common.multiDataSource.DataSourceContext;
|
import com.dy.common.schedulerTask.TaskJob;
|
import com.dy.common.springUtil.SpringContextUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.quartz.JobDataMap;
|
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionException;
|
|
/**
|
* @Author: liurunyu
|
* @Date: 2024/12/27 8:43
|
* @Description 测试不同线程是否得到专属的orgTag
|
*/
|
@Slf4j
|
public class TestJob extends TaskJob {
|
|
private String orgTag ;
|
|
@Override
|
public void execute(JobExecutionContext ctx) throws JobExecutionException {
|
JobDataMap jobDataMap = ctx.getJobDetail().getJobDataMap() ;
|
if(jobDataMap != null){
|
orgTag = (String)jobDataMap.get(StatisticsListener.orgKey) ;
|
}
|
if(orgTag == null){
|
return ;
|
}
|
DataSourceContext.set(orgTag);//设置数据源
|
log.info("设置数据源：" + orgTag);
|
TestWorker worker = SpringContextUtil.getBean(TestWorker.class);
|
worker.doJob();
|
}
|
}
|
