package com.fzzy.igds.dzhwk.v1;

import com.alibaba.fastjson.JSON;
import com.fzzy.igds.dzhwk.domain.DicSysConf;
import com.fzzy.igds.dzhwk.v1.dto.ApiV1ReqDto;
import com.fzzy.igds.dzhwk.v1.dto.ApiV1RespDto;
import com.fzzy.igds.dzhwk.v1.util.ApiV1Utils;
import com.fzzy.igds.sys.SysConfService;
import com.fzzy.igds.util.ContextUtil;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.http.HttpUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.time.DateFormatUtils;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Date;

/**
 * @Description 魔墙数据接口服务
 * @Author CZT
 * @Date 2025/6/04 16:10
 */
@Slf4j
@Component
public class ApiV1Server {

    @Resource
    private SysConfService confService;
    @Resource
    private ApiV1Manager apiManager;

    /**
     * 拉取数据
     * @param interfaceId 接口编码
     * @param startTime   起始时间
     * @param endTime     截止时间
     * @return
     */
    public String pullData(String interfaceId, Date startTime, Date endTime) {

        if (StringUtils.isEmpty(interfaceId)) {
            log.error("接口编码为空，接口编码={}", interfaceId);
            return "接口编码为空！";
        }
        if (null == startTime || null == endTime) {
            log.error("请求时间段为空，startTime={}, endTime={}", startTime, endTime);
            return "请求时间段为空！";
        }
        DicSysConf sysConf = confService.getCacheSysConf(ContextUtil.getDefaultCompanyId());
        if (null == sysConf) {
            log.error("未配置系统配置信息");
            return "未配置系统配置信息！";
        }
        if (StringUtils.isEmpty(sysConf.getHwkApiPath())) {
            log.error("未配置接口请求地址，请求地址={}", sysConf.getHwkApiPath());
            return "未配置接口请求地址！";
        }

        //组装请求数据
        ApiV1ReqDto reqDto = new ApiV1ReqDto();
        reqDto.setInterfaceId(interfaceId);
        reqDto.setDeptId("");
        reqDto.setDeptId("");
        reqDto.setReqDate(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
        reqDto.setStartTime(DateFormatUtils.format(startTime, "yyyy-MM-dd HH:mm:ss"));
        reqDto.setEndTime(DateFormatUtils.format(endTime, "yyyy-MM-dd HH:mm:ss"));
        String jsonString = JSON.toJSONString(reqDto);

        //POST请求获取数据
        String result = HttpUtils.sendPost(sysConf.getHwkApiPath(), jsonString);

        log.info("请求接口，返回数据={}", result);
        if(StringUtils.isEmpty(result)){
            log.error("请求接口失败，返回数据={}", result);
            return "请求接口失败！";
        }
        //解析返回数据
        ApiV1RespDto respDto = JSON.parseObject(result, ApiV1RespDto.class);
        if (null == respDto) {
            log.error("请求接口失败，返回数据={}", respDto);
            return "请求接口失败！";
        }
        if(!"200".equals(respDto.getCode())){
            log.error("请求接口失败，返回数据={}", respDto.getMsg());
            return respDto.getMsg();
        }
        //解密报文
        String dataStr = ApiV1Utils.decrypt(respDto.getData(), null);
        log.info("请求接口，返回数据,解密后={}", dataStr);
        if (dataStr == null) {
            log.error("解密后数据为空，解密数据={}", dataStr);
            return "解密后数据为空！";
        }
        try {
            //异步解析数据
            apiManager.analysis(interfaceId, dataStr, reqDto);
            return null;
        } catch (Exception e) {
            log.error("魔墙数据接口服务异常", e);
            return "魔墙数据接口服务异常！";
        }
    }
}