package com.fzzy.api.view.pr;

import lombok.extern.slf4j.Slf4j;

import com.bstek.dorado.annotation.Expose;
import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.service.*;
import com.fzzy.api.utils.ContextUtil;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 手动同步数据业务入口
 *
 * @author Andy
 */
@Slf4j
@Component
public class SyncServicePR {

    @Autowired
    private ApiCommonService apiCommonService;
    @Autowired
    private ApiSyncManager apiSyncManager;


    /**
     * syncServicePR#syncData
     * 手动调用数据同步，根据接口分类编码
     *
     * @param param
     * @return
     */
    @Expose
    public String syncData(ApiParam param) {


        ApiConfs apiConfs = apiCommonService.getConf(param.getKqdm());

        if (null == apiConfs) {
            return "执行失败：没有获取到当前库区的配置信息";
        }

        //调整开始时间和截止时间
        param.setSyncProtocol(apiConfs.getSyncProtocol());
        param.setDeptId(apiConfs.getDeptId());
        param.setStart(ContextUtil.getCurZero(param.getStart()));
        param.setEnd(ContextUtil.getNextZero(param.getEnd()));

        log.info("-----手动同步数据 -----{}", param.getInteId());


        if (Constant.API_CATEGORY_11.equals(param.getInteId())) {
            SyncService11 syncService11 = apiSyncManager.getSyncService11(param.getSyncProtocol());
            syncService11.syncData(param);
        }

        if (Constant.API_CATEGORY_12.equals(param.getInteId())) {
            SyncService12 syncService12 = apiSyncManager.getSyncService12(param.getSyncProtocol());
            syncService12.syncData(param);
        }

        if (Constant.API_CATEGORY_13.equals(param.getInteId())) {
            SyncService13 syncService13 = apiSyncManager.getSyncService13(param.getSyncProtocol());
            syncService13.syncData(param);
        }

        if (Constant.API_CATEGORY_14.equals(param.getInteId())) {
            SyncService14 syncService14 = apiSyncManager.getSyncService14(param.getSyncProtocol());
            syncService14.syncData(param);
        }

        return "同步命令发送完成，请稍等刷新数据查看";
    }


}