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