package com.dy.pipIrrSell.autoTask;
|
|
import com.dy.common.multiDataSource.DataSourceContext;
|
import com.dy.common.schedulerTask.TaskJob;
|
import com.dy.common.springUtil.SpringContextUtil;
|
import com.dy.common.util.DateTime;
|
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/9/23 14:21
|
* @Description
|
*/
|
public class StatisticsJob extends TaskJob {
|
|
private static Logger log = LogManager.getLogger(StatisticsJob.class.getName()) ;
|
|
private String orgTag ;
|
|
private StAccount stAccount;
|
|
private String yesterday;
|
|
@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);//设置数据源
|
stAccount = SpringContextUtil.getBean(StAccount.class);
|
if(stAccount != null){
|
yesterday = DateTime.lastXDay_yyyy_MM_dd(1) ;//得到昨天，零晨时刻统计，统计昨天的数
|
//统计日的量
|
doStatisticsDay() ;
|
}else{
|
log.error("未能从Spring容器中得到统计bean");
|
}
|
}
|
|
/**
|
* 统计
|
*/
|
private void doStatisticsDay(){
|
stAccount.statistics4Day(yesterday) ;
|
}
|
}
|
