package com.fzzy.push.gb2022;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.AuthToken;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.dto.ResponseDto;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.entity.ApiParent;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.utils.*;
import com.fzzy.api.view.repository.ApiLogRep;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
 * @author vince.xu
 * @Title: ApiService
 * @ProjectName igds-api
 * @Description: 上传数据服务类
 * @date 2022-9-216:27
 */
@Slf4j
@Data
@Service
public class GBApiRemoteService implements ApiRemoteService {


    @Autowired
    private RedisUtil redisUtil;

    @Autowired
    private ApiCommonService apiCommonService;

    @Autowired
    private ApiLogRep apiLogRep;


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

    @Override
    public ResponseDto pushData(ApiParam param, ApiConfs conf, Object data) {
        String inteId = param.getInteId();
        String kqdm = param.getKqdm();
        String bizId = param.getBizId();
        //添加LOGO
        ApiLog apiLog = new ApiLog();
        apiLog.setId(ContextUtil.getUUID());
        apiLog.setKqdm(kqdm);
        try {

            if (null == conf) {
                conf = apiCommonService.getConf(kqdm);
            }
            //获取TOKEN
            AuthToken token = getAuthToken(conf);

            if (!Constant.API_CODE_1109.equals(inteId)) {
                apiLog.setData(JSON.toJSONString(data));
            }
            apiLog.setInteId(inteId);

            if (conf == null) {
                ResponseDto responseDto = new ResponseDto(99, "没有获取到上传配置", bizId);
                apiLog.setStatus(99);
                apiLog.setResult("没有获取到上传配置");
                apiLogRep.save(apiLog);
                return responseDto;
            }
            if (null == token) {
                ResponseDto responseDto = new ResponseDto(99, "没有获取到TOKEN信息", bizId);
                apiLog.setStatus(99);
                apiLog.setResult("没有获取到TOKEN信息");
                apiLogRep.save(apiLog);
                return responseDto;
            }


            Map<String, Object> map = new HashMap<>();
            map.put("token", token.getToken());
            String jsondata = JSON.toJSONString(data);
            log.debug("-----------------数据报文----------------{}", jsondata);
            String d = SM2Utils.encrypt(conf.getPublicKey(), jsondata);
            log.info("json:" + jsondata);
            map.put("data", d);
            map.put("table", inteId);
            map.put("JSESSIONID", token.getJSESSIONID());
            ResponseDto responseDto = HttpClientUtil.postFormData(conf.getApiUrl() + inteId, map);
            responseDto.setBizId(bizId);
            apiLog.setStatus(responseDto.getSuccess());
            apiLog.setResult(responseDto.getMsg());
            apiLogRep.save(apiLog);

            updateAuthToken(responseDto, token);
            return responseDto;
        } catch (Exception e) {
            apiLog.setStatus(99);
            apiLog.setResult("失败：" + e.getMessage());
            apiLogRep.save(apiLog);
            log.error(e.getMessage(), e);
            return new ResponseDto(99, e.getMessage());
        }
    }

    @Override
    public ResponseDto pushData(ApiParam param, Object data) {
        return pushData(param, null, data);
    }


    /**
     * @Desc: 国标自定义方法
     * @author: Andy
     * @update-time: 2022/10/10
     */
    public ResponseDto pushData(String inteId, String kqdm, String bizId, Object data) {
        ApiConfs conf = apiCommonService.getConf(kqdm);

        ApiParam param = new ApiParam(conf);

        param.setInteId(inteId);
        param.setInteCategory(inteId.substring(0, 2));
        param.setBizId(bizId);

        return pushData(param, conf, data);
    }


    /**
     * 单条上传数据
     *
     * @param inteId
     * @param data
     * @return
     */
    public ResponseDto pushData(String inteId, ApiParent data) {
        try {
            //获取配置
            ApiConfs conf = apiCommonService.getConf(data.getKqdm());
            //获取TOKEN
            AuthToken token = getAuthToken(conf);

            //添加LOGO
            ApiLog apiLog = new ApiLog();
            apiLog.setId(ContextUtil.getUUID());
            if (!Constant.API_CODE_1109.equals(inteId)) {
                apiLog.setData(JSON.toJSONString(data));
            }
            apiLog.setInteId(inteId);
            apiLog.setKqdm(data.getKqdm());
            apiLog.setUploadTime(new Date());

            if (conf == null) {
                ResponseDto responseDto = new ResponseDto(99, "没有获取到上传配置", data.getBizId());
                apiLog.setStatus(99);
                apiLog.setResult("没有获取到上传配置");
                apiLogRep.save(apiLog);
                return responseDto;
            }
            if (null == token) {
                ResponseDto responseDto = new ResponseDto(99, "没有获取到TOKEN信息", data.getBizId());
                apiLog.setStatus(99);
                apiLog.setResult("没有获取到TOKEN信息");
                apiLogRep.save(apiLog);
                return responseDto;
            }

            Map<String, Object> map = new HashMap<>();
            map.put("token", token.getToken());
            String jsondata = JSON.toJSONString(data);
            String d = SM2Utils.encrypt(conf.getPublicKey(), jsondata);
            log.info("json:" + jsondata);
            map.put("data", d);
            map.put("table", inteId);
            map.put("JSESSIONID", token.getJSESSIONID());

            ResponseDto responseDto = HttpClientUtil.postFormData(conf.getApiUrl() + inteId, map);
            responseDto.setBizId(data.getBizId());
            apiLog.setStatus(responseDto.getSuccess());
            apiLog.setResult(responseDto.getMsg());

            apiLogRep.save(apiLog);

            updateAuthToken(responseDto, token);

            return responseDto;
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            return new ResponseDto(99, e.getMessage());
        }
    }

    /**
     * 代码调整
     *
     * @param conf
     * @return
     */
    public AuthToken getAuthToken(ApiConfs conf) {
        try {
            String key = RedisConst.buildKey(RedisConst.KYE_TOKEN, conf.getKqdm());

            AuthToken token = (AuthToken) redisUtil.get(key);
            if (null != token) return token;

            //从新获取TOKEN
            Map<String, Object> map = new HashMap<>();
            map.put("UserName", conf.getUserName());
            String password = SM2Utils.encrypt(conf.getPublicKey(), conf.getPassword());
            map.put("Password", password);
            ResponseDto responseDto = HttpClientUtil.postFormData(conf.getApiUrl() + "login", map);
            token = new AuthToken(conf.getKqdm(), responseDto.getToken(), responseDto.getJSESSIONID());

            updateAuthToken(null, token);

            return token;
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            return null;
        }
    }

    private void updateAuthToken(ResponseDto dto, AuthToken token) {
        String key = RedisConst.buildKey(RedisConst.KYE_TOKEN, token.getKqdm());

        if (null == dto) {
            redisUtil.set(key, token, 170);
            return;
        }

        if (dto.getSuccess() > 1) {
            return;
        } else if (dto.getSuccess() == 1) {
            redisUtil.del(key);
        } else {
            token.setToken(dto.getToken());
            token.setJSESSIONID(dto.getJSESSIONID());
            redisUtil.set(key, token, 170);
        }
    }


}