package com.dy.pmsOther.task;
|
|
import com.dy.common.schedulerTask.TaskJob;
|
import com.dy.common.springUtil.SpringContextUtil;
|
import com.dy.pmsGlobal.daoOth.OthStatisticDeviceMapper;
|
import com.dy.pmsGlobal.daoOth.OthStatisticWorkloadMapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionException;
|
import org.springframework.transaction.annotation.Transactional;
|
|
@Slf4j
|
public class DeviceCountTask extends TaskJob {
|
|
@Override
|
@Transactional
|
public void execute(JobExecutionContext ctx) throws JobExecutionException {
|
log.info("启动统计每日设备生产数任务");
|
OthStatisticWorkloadMapper workloadMapper = SpringContextUtil.getBean(OthStatisticWorkloadMapper.class);
|
OthStatisticDeviceMapper statisticDeviceMapper = SpringContextUtil.getBean(OthStatisticDeviceMapper.class);
|
//找到最大一条日期加1天防止重复统计
|
String maxDate = statisticDeviceMapper.selectMaxDate();
|
statisticDeviceMapper.insertBatch(maxDate);
|
log.info("统计每日设备生产数任务结束");
|
}
|
}
|
