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("统计每日设备生产数任务结束");
    }
}