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();
    }
}