package com.fzzy.push.sx2023;

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.utils.RedisConst;
import com.fzzy.api.utils.RedisUtil;
import com.fzzy.order.ordersx2023.OrderSxService;
import com.fzzy.order.ordersx2023.data.OrderSxConstant;
import com.fzzy.order.ordersx2023.data.OrderSxReq;
import com.fzzy.push.impl.*;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.text.ParseException;

/**
 * @Description 陕西省平台2023版-指令解析
 * @Author CZT
 * @Date 2024/4/23 11:48
 */
@Slf4j
@Service
public class SX2023OrderServiceImpl implements OrderSxService {

    @Autowired
    private RedisUtil redisUtil;
    @Autowired
    private SX2023ApiRemoteService apiRemoteService;
    @Autowired
    private ComPushService11 pushService11;
    @Autowired
    private ComPushService12 pushService12;
    @Autowired
    private ComPushService13 pushService13;
    @Autowired
    private ComPushService14 pushService14;
    @Autowired
    private ComPushService15 pushService15;

    @Override
    public String getProtocol() {
        return PushProtocol.SB_SX_2023.getCode();
    }

    @Override
    public void execute(OrderSxReq req, ApiConfs apiConfs) throws ParseException {
        // 若指令类型不为1，则返回
        if (!OrderSxConstant.ORDER_SX_TYPE_1.equals(req.getType())) {
            log.error("陕西省平台：收到指令，指令类型不为1，不执行数据上报！，指令类型={}", req.getType());
            return;
        }
        String datas = req.getData();
        if (StringUtils.isEmpty(datas)) {
            log.error("陕西省平台：收到指令，指令内容为空，不执行数据上报！");
            return;
        }

        //指令存入缓存，时效24小时
        String key = RedisConst.buildKey(RedisConst.KYE_ORDER, apiConfs.getKqdm());
        redisUtil.set(key, req.getOrderid(), 59 * 60 * 24);

        ApiParam param = new ApiParam();
        param.setPushProtocol(apiConfs.getPushProtocol());
        param.setKqdm(apiConfs.getKqdm());
        param.setStart(DateUtils.parseDate(req.getStartTime(), new String[]{"yyyy-MM-dd HH:mm:ss"}));
        param.setEnd(DateUtils.parseDate(req.getEndTime(), new String[]{"yyyy-MM-dd HH:mm:ss"}));
        param.setDeptId(apiConfs.getDeptId());

        log.info("接收的指令中接口内容为={}", datas);
        String[] interfaces = datas.split(",");
        for (String inteId : interfaces) {
            log.info("执行接口={}的数据上报", inteId);
            getDataToPush(param, inteId);
        }
    }


    private void getDataToPush(ApiParam param, String inteId) {

        switch (inteId) {
            case "ODS_UP_DWXXJK":
                pushService11.pushData1101(apiRemoteService, param);
                break;
            case "ODS_UP_KQXXJK":
                pushService11.pushData1102(apiRemoteService, param);
                break;
            case "ODS_UP_CFXXJK":
                pushService11.pushData1103(apiRemoteService, param);
                break;
            case "ODS_UP_AJXXJK":
                pushService11.pushData1104(apiRemoteService, param);
                break;
            case "ODS_UP_HWXXJK":
                pushService11.pushData1105(apiRemoteService, param);
                break;
            case "ODS_UP_YGXXJK":
                pushService11.pushData1106(apiRemoteService, param);
                break;
            case "ODS_UP_SBXXJK":
                pushService11.pushData1107(apiRemoteService, param);
                break;
            case "ODS_UP_YJXXJK":
                pushService11.pushData1108(apiRemoteService, param);
                break;
            case "ODS_UP_WJXXJK":
                pushService12.pushData1109(apiRemoteService, param);
                break;
            case "ODS_UP_KQTCFDWBZSJXXJK":
                pushService11.pushData1110(apiRemoteService, param);
                break;
            case "ODS_UP_KQTSPJKSBDWBZSJXXJK":
                pushService11.pushData1111(apiRemoteService, param);
                break;
            case "ODS_UP_RYXXJK":
                pushService11.pushData1112(apiRemoteService, param);
                break;
            case "ODS_UP_CWBBXXJK":
                pushService15.pushData1500(apiRemoteService, param);
                break;
            case "ODS_UP_HTXXJK":
                pushService12.pushData1201(apiRemoteService, param);
                break;
            case "ODS_UP_LSRKXXJK":
                pushService12.pushData1202(apiRemoteService, param);
                break;
            case "ODS_UP_LSRKJYXXJK":
                pushService12.pushData1203(apiRemoteService, param);
                break;
            case "ODS_UP_LSRKJSXXJK":
                pushService12.pushData1204(apiRemoteService, param);
                break;
            case "ODS_UP_LSCKXXJK":
                pushService12.pushData1205(apiRemoteService, param);
                break;
            case "ODS_UP_LSCKJSXXJK":
                pushService12.pushData1206(apiRemoteService, param);
                break;
            case "ODS_UP_DCXXJK":
                pushService12.pushData1207(apiRemoteService, param);
                break;
            case "ODS_UP_LSKCXXJK":
                pushService12.pushData1208(apiRemoteService, param);
                break;
            case "ODS_UP_SYDXXJK":
                pushService12.pushData1209(apiRemoteService, param);
                break;
            case "ODS_UP_LSXZZBDXXJK":
                pushService12.pushData1210(apiRemoteService, param);
                break;
            case "ODS_UP_ZMKCXXJK":
                pushService12.pushData1211(apiRemoteService, param);
                break;
            case "ODS_UP_KHXXJK":
                pushService12.pushData1212(apiRemoteService, param);
                break;
            case "ODS_UP_AQGLXXJK":
                pushService13.pushData1301(apiRemoteService, param);
                break;
            case "ODS_UP_WSDJCXXJK":
                pushService13.pushData1302(apiRemoteService, param);
                break;
            case "ODS_UP_CHJCXXJK":
                pushService13.pushData1303(apiRemoteService, param);
                break;
            case "ODS_UP_QTJCXXJK":
                pushService13.pushData1304(apiRemoteService, param);
                break;
            case "ODS_UP_TFZYXXJK":
                pushService13.pushData1305(apiRemoteService, param);
                break;
            case "ODS_UP_XZZYXXJK":
                pushService13.pushData1306(apiRemoteService, param);
                break;
            case "ODS_UP_CNSPTXXXJK":
                pushService13.pushData1307(apiRemoteService, param);
                break;
            case "ODS_UP_SPJKYCSJGJJBXXJK":
                pushService13.pushData1308(apiRemoteService, param);
                break;
            case "ODS_UP_WGYJXXJK":
                pushService13.pushData1309(apiRemoteService, param);
                break;
            case "ODS_UP_ZJXXJK":
                pushService13.pushData1310(apiRemoteService, param);
                break;
            case "ODS_UP_CBGMXXJK":
                pushService14.pushData1401(apiRemoteService, param);
                break;
            case "ODS_UP_LHJHXXJK":
                pushService14.pushData1403(apiRemoteService, param);
                break;
            case "ODS_UP_LHJHMXXXJK":
                pushService14.pushData1404(apiRemoteService, param);
                break;
            default:
                log.error("-----陕西省平台：未匹配到接口编码，不推送-----");
                break;
        }

    }
}