package com.dy.pipIrrModel.timingTask; 
 | 
  
 | 
import com.dy.common.multiDataSource.DataSourceContext; 
 | 
import com.dy.common.schedulerTask.TaskJob; 
 | 
import com.dy.common.springUtil.SpringContextUtil; 
 | 
import com.dy.pipIrrModel.modelCalculate.ModelCalculator; 
 | 
import org.apache.logging.log4j.LogManager; 
 | 
import org.apache.logging.log4j.Logger; 
 | 
import org.quartz.JobDataMap; 
 | 
import org.quartz.JobExecutionContext; 
 | 
import org.quartz.JobExecutionException; 
 | 
  
 | 
/** 
 | 
 * @Author: liurunyu 
 | 
 * @Date: 2025/8/6 9:32 
 | 
 * @Description 
 | 
 */ 
 | 
public class CalculateJob extends TaskJob { 
 | 
  
 | 
    private static Logger log = LogManager.getLogger(CalculateJob.class.getName()) ; 
 | 
  
 | 
    private String orgTag ; 
 | 
  
 | 
    @Override 
 | 
    public void execute(JobExecutionContext ctx) throws JobExecutionException { 
 | 
        JobDataMap jobDataMap = ctx.getJobDetail().getJobDataMap() ; 
 | 
        if(jobDataMap != null){ 
 | 
            orgTag = (String)jobDataMap.get(ModelListener.orgKey) ; 
 | 
        } 
 | 
        if(orgTag == null){ 
 | 
            return ; 
 | 
        } 
 | 
        DataSourceContext.set(orgTag);//设置数据源 
 | 
        ModelCalculator bean = (ModelCalculator)SpringContextUtil.getBean(ModelCalculator.selfBeanName); 
 | 
        if(bean != null){ 
 | 
            bean.execute(); 
 | 
        } 
 | 
    } 
 | 
} 
 |