package com.ld.igds.timer;

import com.ld.igds.constant.Constant;
import com.ld.igds.grain.view.SysGrainManager;
import com.ld.igds.models.Depot;
import com.ld.igds.models.TimingDepot;
import com.ld.igds.timer.service.ITimerService;
import com.ld.igds.view.service.HDepotService;

import lombok.extern.slf4j.Slf4j;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 粮情定时检测执行
 */
@Slf4j
@Service(Constant.JOB_BEAN_GRAIN)
public class JobGrainService implements Job {

    @Autowired
    private ITimerService timerService;
    @Autowired
    private HDepotService depotService;
    @Autowired
    private SysGrainManager sysGrainManager;

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        log.info("=======================开始执行定时粮情检测=============================");

        // 获取JOB的ID
        String key = context.getTrigger().getKey().getName();
        String jobId = key.substring(7);

        //根据当前JOB获取设备列表
        List<TimingDepot> list = timerService.getDepotByTimerId(jobId);
        if (null == list || list.isEmpty()) {
            log.info(context.getJobDetail().getDescription() + "该方案下没有配置需要执行的仓库，定时检测失败……");
            return;
        }

        // 获取到需要操作的仓库列表
        List<Depot> depots = depotService.getDepotByTimer(list);
        if (null == depots || depots.isEmpty()) {
            log.info(context.getJobDetail().getDescription() + "该方案下没有获取到仓库信息，定时检测失败……");
            return;
        }

        String msg  = sysGrainManager.batchCheck(depots);

        log.info("=======================定时检测结束，结果============================{}",msg);
    }

}