package com.gyee.generation.task;


import com.gyee.generation.service.*;
import com.gyee.generation.service.realtimelibrary.*;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.Date;

/**
 * @ClassName : SaticScheduleTask
 * @Description : 调度
 */


@Component
public class SaticScheduleCALTask {

    private static Logger logger = LoggerFactory.getLogger(SaticScheduleCALTask.class);

    @Resource
    private AccessStatusService accessStatusService;
    @Resource
    private CalculationService calculationService;
    @Resource
    private CycleCalculationService cycleCalculationService;
    @Resource
    private ElectricityMeteringService electricityMeteringService;
    @Resource
    private RealtimeService realtimeService;
    @Resource
    private StatusService statusService;
    @Resource
    private TheoreticalPowerService theoreticalPowerService;
    @Resource
    private RegionCalreService regionCalreService;
    @Resource
    private RegionCalService regionCalService;

    /**
     * 全场状态，接入状态，总预测功率
     * 每秒执行一次
     */
    @XxlJob("accessStatus_CAL")
    public void accessStatus_CAL()  {


        XxlJobHelper.log("全场状态调度程序执行开始!........");
        try {
            //场站接入状态，总预测功率
            accessStatusService.accessStatus();
            //全场状态
            accessStatusService.fullFieldState();
        } catch (Exception e) {
            e.printStackTrace();
        }
        XxlJobHelper.log("全场状态调度任务处理完成!........");
    }

    /**
     * 后新增计算指标  节约煤，水，二氧化碳，二氧化硫，月利用小时，年利用小时，设备可利用率，等效可用系数，风能利用率
     * 每15分钟执行一次
     */
    @XxlJob("calculation_CAL")
    public void calculation_CAL()  {

        XxlJobHelper.log("计算指标调度程序执行开始!........");
        try {
            calculationService.calWp();
        } catch (Exception e) {
            e.printStackTrace();
        }
        XxlJobHelper.log("计算指标调度任务处理完成!........");
    }

    /**
     * 日，月，年，15分钟计算指标
     * 每15分钟执行一次
     */
    @XxlJob("cycleCalculation_CAL")
    public void cycleCalculation_CAL()  {

        XxlJobHelper.log("日月年计算指标调度程序执行开始!........");
        try {
            cycleCalculationService.saveCyle();
        } catch (Exception e) {
            e.printStackTrace();
        }
        XxlJobHelper.log("日月年计算指标调度任务处理完成!........");
    }

    /**
     * 电计量计算指标
     * 每15分钟执行一次
     */
    @XxlJob("electricityMetering_CAL")
    public void electricityMetering_CAL()  {

        XxlJobHelper.log("电计量指标调度程序执行开始!........");
        try {
            electricityMeteringService.saveGenerationDatas();
        } catch (Exception e) {
            e.printStackTrace();
        }
        XxlJobHelper.log("电计量计算指标调度任务处理完成!........");
    }


    /**
     * 实时计算指标
     * 每秒执行一次
     */
    @XxlJob("realtime_CAL")
    public void realtime_CAL()  {

        XxlJobHelper.log("实时指标调度程序执行开始!........");
        try {
            realtimeService.savaRealtimeTarget();
        } catch (Exception e) {
            e.printStackTrace();
        }
        XxlJobHelper.log("实时指标调度任务处理完成!........");
    }

    /**
     * 状态计算
     * 每秒执行一次
     */
    @XxlJob("status_CAL")
    public void status_CAL()  {

        XxlJobHelper.log("状态调度程序执行开始!........");
        try {
            statusService.powerRationing();
            statusService.statusReal();
            statusService.calculateStatusNumber();
        } catch (Exception e) {
            e.printStackTrace();
        }
        XxlJobHelper.log("状态调度任务处理完成!........");
    }


    /**
     * 自算功率，最优功率更新缓存
     * 每月执行一次
     */
    @XxlJob("theoreticalPower_CAL")
    public void theoreticalPower_CAL()  {

        XxlJobHelper.log("自算功率更新程序执行开始!........");
        try {
            theoreticalPowerService.updateCachePower();
        } catch (Exception e) {
            e.printStackTrace();
        }
        XxlJobHelper.log("自算功率更新调度任务处理完成!........");
    }

    /**
     * 区域公司实时指标
     * 每秒执行一次
     */
    @XxlJob("regionCalre_CAL")
    public void regionCalre_CAL()  {

        XxlJobHelper.log("区域公司实时程序执行开始!........");
        try {
            regionCalreService.companyCal();
            regionCalreService.RegionCal();
        } catch (Exception e) {
            e.printStackTrace();
        }
        XxlJobHelper.log("区域公司实时程序处理完成!........");
    }

    /**
     * 区域公司历史指标
     * 每秒执行一次
     */
    @XxlJob("regionCal_CAL")
    public void regionCal_CAL()  {

        XxlJobHelper.log("区域公司历史程序执行开始!........");
        try {
            regionCalService.companyCal();
            regionCalService.RegionCal();
        } catch (Exception e) {
            e.printStackTrace();
        }
        XxlJobHelper.log("区域公司历史程序处理完成!........");
    }







}