package com.fzzy.api.timer;

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.service.*;
import com.fzzy.api.utils.ContextUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;

/**
 * @author: andy.jia
 * @description: 同步粮库信息系统数据入口
 * @version:
 */
@Slf4j
@Component(SyncDataScheduled.BEAN_ID)
public class SyncDataScheduled {

    public static final String BEAN_ID = "api.syncDataScheduled";

    @Autowired
    private ApiSyncManager apiSyncManager;

    @Autowired
    private ApiCommonService apiCommonService;


    /**
     * cron = "0 0,30 * * * ? "
     * <p>
     * 固定时间：0分钟和30分钟执行
     */
//    @Scheduled(cron = "0 0,30 * * * ? ")
    public void scheduled() {

        log.info("系统执行定时数据同步操作<<<<<<<<<<<<<--------");


        List<ApiConfs> list = apiCommonService.listCacheConf();

        if (null == list || list.isEmpty()) return;

        Date exeDate = new Date();

        for (ApiConfs conf : list) {

            exeByConf11(conf, exeDate);

            exeByConf99(conf, exeDate);
        }
    }

    /**
     * 同步义务数据
     *
     * @param conf
     * @param exeDate
     */
    private void exeByConf99(ApiConfs conf, Date exeDate) {
        if (null == conf.getSyncType99() || conf.getSyncType99().equals(ApiConfs.SYNC_PUSH_HAND)) {

            log.info("业务接口数据，系统配置为手动模式，取消自动执行<<<<<<<<<<<<<-------");
            return;
        }


        Date start = exeDate;

        //是否执行
        boolean isExecute = false;
        boolean isUpdateStart = false;
        //核对天是否匹配
        if (conf.getSyncDay99().equals(ApiConfs.TIME_ALL)) {
            isExecute = true;
        } else {
            int dayOfWeek = ContextUtil.getDayOfWeek(exeDate);
            if (String.valueOf(dayOfWeek).equals(conf.getSyncDay11())) {
                isExecute = true;

                //开始时间提前7天
                start = DateUtils.addDays(start, -7);
                isUpdateStart = true;
            } else {
                isExecute = false;
            }
        }

        if (!isExecute) {
            log.debug("业务数据同步---时间配置天不匹配<<<<<<<<<<<<<-------");
            return;
        }

        //核对时间是否匹配
        if (conf.getSyncHour99().equals(ApiConfs.TIME_ALL)) {
            isExecute = true;
        } else {
            int hourOfDay = ContextUtil.getHourOfDay(exeDate);
            if (String.valueOf(hourOfDay).equals(conf.getSyncHour11())) {
                isExecute = true;

                if (!isUpdateStart) {
                    start = DateUtils.addDays(start, -1);
                    isUpdateStart = true;
                }
            } else {
                isExecute = false;
            }
        }
        if (!isExecute) {
            log.debug("业务数据同步---时间配置小时不匹配<<<<<<<<<<<<<-------");
            return;
        }

        //核对时间分钟是否匹配
        int minute = ContextUtil.getMinuteOfHour(exeDate);
        if (String.valueOf(minute).equals(conf.getSyncMinute99())) {
            isExecute = true;
            if (!isUpdateStart) {
                start = DateUtils.addHours(start, -1);
            }
        } else {
            isExecute = false;
        }

        if (!isExecute) {
            log.debug("业务数据同步---时间配置分钟不匹配<<<<<<<<<<<<<-------");
            return;
        }

        ApiParam param = new ApiParam();
        param.setSyncProtocol(conf.getSyncProtocol());
        param.setPushProtocol(conf.getPushProtocol());
        param.setKqdm(conf.getKqdm());
        param.setStart(start);
        param.setEnd(exeDate);
        param.setDeptId(conf.getDeptId());


        SyncService12 syncService12 = apiSyncManager.getSyncService12(param.getSyncProtocol());
        syncService12.syncData(param);

        SyncService13 syncService13 = apiSyncManager.getSyncService13(param.getSyncProtocol());
        syncService13.syncData(param);

        SyncService14 syncService14 = apiSyncManager.getSyncService14(param.getSyncProtocol());
        syncService14.syncData(param);
    }

    /**
     * 同步基础信息
     *
     * @param conf
     * @param exeDate
     */
    private void exeByConf11(ApiConfs conf, Date exeDate) {

        if (null == conf.getSyncType11() || conf.getSyncType11().equals(ApiConfs.SYNC_PUSH_HAND)) {

            log.info("基础数据同步，系统配置为手动模式，取消自动执行<<<<<<<<<<<<<-------");
            return;
        }


        Date start = exeDate;

        //是否执行
        boolean isExecute = false;
        boolean isUpdateStart = false;
        //核对天是否匹配
        if (conf.getSyncDay11().equals(ApiConfs.TIME_ALL)) {
            isExecute = true;
        } else {
            int dayOfWeek = ContextUtil.getDayOfWeek(exeDate);
            if (String.valueOf(dayOfWeek).equals(conf.getSyncDay11())) {
                isExecute = true;

                //开始时间提前7天
                start = DateUtils.addDays(start, -7);
                isUpdateStart = true;
            } else {
                isExecute = false;
            }
        }

        if (!isExecute) {
            log.debug("基础数据同步---时间配置天不匹配<<<<<<<<<<<<<-------");
            return;
        }

        //核对时间是否匹配
        if (conf.getSyncHour11().equals(ApiConfs.TIME_ALL)) {
            isExecute = true;
        } else {
            int hourOfDay = ContextUtil.getHourOfDay(exeDate);
            if (String.valueOf(hourOfDay).equals(conf.getSyncHour11())) {
                isExecute = true;

                if (!isUpdateStart) {
                    start = DateUtils.addDays(start, -1);
                    isUpdateStart = true;
                }
            } else {
                isExecute = false;
            }
        }
        if (!isExecute) {
            log.debug("基础数据同步---时间配置小时不匹配<<<<<<<<<<<<<-------");
            return;
        }

        //核对时间分钟是否匹配
        int minute = ContextUtil.getMinuteOfHour(exeDate);
        if (String.valueOf(minute).equals(conf.getSyncMinute11())) {
            isExecute = true;
            if (!isUpdateStart) {
                start = DateUtils.addHours(start, -1);
            }
        } else {
            isExecute = false;
        }

        if (!isExecute) {
            log.debug("基础数据同步---时间配置分钟不匹配<<<<<<<<<<<<<-------");
            return;
        }

        ApiParam param = new ApiParam();
        param.setSyncProtocol(conf.getSyncProtocol());
        param.setKqdm(conf.getKqdm());
        param.setStart(start);
        param.setEnd(exeDate);
        param.setDeptId(conf.getDeptId());


        SyncService11 syncService11 = apiSyncManager.getSyncService11(param.getSyncProtocol());
        syncService11.syncData(param);
    }
}