package com.zy.kingdee.utils;

import cn.hutool.http.HttpRequest;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.core.common.Cools;

import com.smecloud.apigw.client.ApigwClient;
import com.smecloud.apigw.codec.GwURLEncoder;
import com.smecloud.apigw.constant.HttpMethod;
import com.smecloud.apigw.exception.ApiException;
import com.smecloud.apigw.model.ApiRequest;
import com.smecloud.apigw.model.ApigwConfig;
import com.smecloud.apigw.util.CommontUtil;
import com.smecloud.apigw.util.SHAUtil;
import com.zy.kingdee.entity.*;
import lombok.SneakyThrows;

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.security.SecureRandom;
import java.util.*;
import java.util.stream.Collectors;

public class K3ApiUtil {
    private static final String clientId = "320285";
    private static final String clientSecret = "bd29825057688ef40b1154057961a13b";
    private static final String HOST = "api.kingdee.com";
    private static final String instanceId = "436582290097836032";
    private static final String appKey = "KidEvrK8";
    private static final String[] DEFAULT_SIGNHEADERS = new String[]{"X-Api-Nonce", "X-Api-TimeStamp"};

    public static ResParam TokenRes = null;
    public static ResParam userRes = null;
    public static String authCode = null;
    public static String sessionId = null;
    public static AcctDto acctDto = null;
    public static GatewayDto gatewayDto = null;


    /**
     * 获取Nonce
     *
     * @param len
     * @return
     */
    public static String getNonce(int len) {
        StringBuilder rs = new StringBuilder();
        for (int i = 0; i < len; ++i) {
            rs.append(new SecureRandom().nextInt(10));
        }
        return rs.toString();
    }

    /**
     * 获取url转码格式
     *
     * @param path
     * @return
     */
    private static String getPathEncode(String path) {
        try {
            return GwURLEncoder.encode(path, StandardCharsets.UTF_8.toString());
        } catch (Exception var3) {
            Exception e = var3;
            throw new ApiException(e);
        }
    }

    /**
     * 获取拼接参数转码格式
     *
     * @param querys
     * @return
     */
    private static String getQueryEncode(Map<String, String> querys) {
        try {
            if (CommontUtil.isEmpty(querys)) {
                return "";
            } else {
                List<String> list = new ArrayList(querys.size());
                Iterator var3 = querys.entrySet().iterator();

                while (var3.hasNext()) {
                    Map.Entry<String, String> entry = (Map.Entry) var3.next();
                    String key = GwURLEncoder.encode((String) entry.getKey(), StandardCharsets.UTF_8.toString());
                    String value = URLEncoder.encode((String) entry.getValue(), StandardCharsets.UTF_8.toString());
                    list.add(key + "=" + value);
                }

                Collections.sort(list);
                String rawQueryString = String.join("&", list);
                String[] queryStrings = rawQueryString.split("&");
                list.clear();
                String[] var16 = queryStrings;
                int var17 = queryStrings.length;

                for (int var7 = 0; var7 < var17; ++var7) {
                    String param = var16[var7];
                    int index = param.indexOf("=");
                    if (index >= 1) {
                        String key = GwURLEncoder.encode(param.substring(0, index), StandardCharsets.UTF_8.toString());
                        String value = GwURLEncoder.encode(param.substring(index + 1), StandardCharsets.UTF_8.toString());
                        list.add(key + "=" + value);
                    }
                }

                return String.join("&", list);
            }
        } catch (Exception var12) {
            Exception e = var12;
            throw new ApiException(e);
        }
    }

    /**
     * 获取加密签名
     *
     * @param method
     * @param path
     * @param query
     * @param signatureHeaders
     * @param headers
     * @return
     */
    private static String getSign(String method, String path, String query, String[] signatureHeaders, Map<String, String> headers) {
        StringBuilder b = new StringBuilder();
        b.append(method);
        b.append("\n");
        b.append(path);
        b.append("\n");
        b.append(query);
        b.append("\n");
        String[] var7 = signatureHeaders;
        int var8 = signatureHeaders.length;

        for (int var9 = 0; var9 < var8; ++var9) {
            String x = var7[var9];
            b.append(x.toLowerCase());
            b.append(":");
            b.append((String) headers.get(x));
            b.append("\n");
        }

        String s = SHAUtil.SHA256HMAC(b.toString(), clientSecret);
        return s != null ? Base64.getEncoder().encodeToString(s.getBytes()) : "";
    }

    /**
     * 获取加密后结果
     *
     * @return
     */
    public static String getSecretStr(String key, String secret) {
        String s = SHAUtil.SHA256HMAC(key, secret);
        return s != null ? Base64.getEncoder().encodeToString(s.getBytes()) : "";
    }

    public static String getMapStr(Map<String, String> map) {
        if (map == null) {
            return "";
        }
        StringBuilder b = new StringBuilder("?");
        String str = map.keySet().stream().map(key ->
        {
            try {
                return GwURLEncoder.encode(key, StandardCharsets.UTF_8.toString()) + "=" + GwURLEncoder.encode(map.get(key), StandardCharsets.UTF_8.toString());
            } catch (UnsupportedEncodingException e) {
                throw new RuntimeException(e);
            }
        }).collect(Collectors.joining("&"));
        b.append(str);
        return b.toString();
    }

    /**
     * 初始化网关
     *
     * @return
     */
    private static ApigwConfig initConfig() {
        ApigwConfig config = new ApigwConfig();
        //设置client_id
        config.setClientID(clientId);
        //设置client_secret
        config.setClientSecret(clientSecret);
        ApigwClient apigwClient = ApigwClient.getInstance();
        //初始化API网关客户端
        apigwClient.init(config);
        return config;
    }

    /**
     * 获取签名
     *
     * @param method
     * @param url
     * @param querys
     * @return
     */
    public static ReqParam getSignature(HttpMethod method, String url, Map<String, String> querys) {
        //初始化API网关客户端
        ApigwConfig config = initConfig();

        ApiRequest request = new ApiRequest(method, HOST, url);
        request.setQuerys(querys);
        request.setBodyJson(JSONObject.toJSONString("").getBytes());
        //初始回参
        ReqParam res = ReqParam.init(Long.toString(System.currentTimeMillis()), getNonce(10));

        request.addHeader("X-Api-ClientID", config.getClientID());
        request.addHeader("X-Api-Auth-Version", "2.0");
        request.addHeader("X-Api-TimeStamp", res.getTimeStamp());
        request.addHeader("X-Api-Nonce", res.getNonce());
        request.addHeader("X-Api-SignHeaders", String.join(",", DEFAULT_SIGNHEADERS));
        String sign = getSign(request.getMethod().getValue(), getPathEncode(request.getPath()), getQueryEncode(request.getQuerys()), DEFAULT_SIGNHEADERS, request.getHeaders());
        request.setSignature(sign);
        request.addHeader("X-Api-Signature", sign);
        res.setSign(sign);


        return res;
    }


    /**
     * 获取验证
     *
     * @return
     */
    @SneakyThrows
    public static ResParam getAuthorize() {
        String url = "/jdyconnector/app_management/push_app_authorize";
        //URL ？拼接字段
        Map<String, String> map = new LinkedHashMap<>();
        map.put("outerInstanceId", instanceId);
        String pathParamStr = getMapStr(map);
        //获取接口参数
        ReqParam req = K3ApiUtil.getSignature(HttpMethod.POST_BODY, url, map);
        String resStr = HttpRequest.post(HOST + url + pathParamStr)
                .header("X-Api-ClientID", clientId)
                .header("X-Api-Auth-Version", "2.0")
                .header("X-Api-TimeStamp", req.getTimeStamp())
                .header("X-Api-Nonce", req.getNonce())
                .header("X-Api-SignHeaders", "X-Api-TimeStamp,X-Api-Nonce")
                .header("X-Api-Signature", req.getSign())
                .execute()
                .body();

        ResDto res = JSONObject.parseObject(resStr, ResDto.class);
        if (res.getCode() != 200) {
            throw new RuntimeException(res.getMsg());
        }
//        System.out.println("testGetAuth()：" + resStr);
        userRes = res.getData().get(0);
        return res.getData().get(0);

    }

    /**
     * 获取验证
     *
     * @return
     */
    @SneakyThrows
    public static ResParam getToken() {
        //获取授权
        ResParam authorizeRes = getAuthorize();

        String url = "/jdyconnector/app_management/kingdee_auth_token";
        //URL ？拼接字段
        Map<String, String> map = new LinkedHashMap<>();
        map.put("app_key", authorizeRes.getAppKey());
        String secretStr = getSecretStr(authorizeRes.getAppKey(), authorizeRes.getAppSecret());
        map.put("app_signature", secretStr);
        String pathParamStr = getMapStr(map);
        //获取接口参数
        ReqParam req = K3ApiUtil.getSignature(HttpMethod.GET, url, map);
        String resStr = HttpRequest.get(HOST + url + pathParamStr)
                .header("X-Api-ClientID", clientId)
                .header("X-Api-Auth-Version", "2.0")
                .header("X-Api-TimeStamp", req.getTimeStamp())
                .header("X-Api-Nonce", req.getNonce())
                .header("X-Api-SignHeaders", "X-Api-TimeStamp,X-Api-Nonce")
                .header("X-Api-Signature", req.getSign())
                .execute()
                .body();
        ResDto res = JSONObject.parseObject(resStr, ResDto.class);
        if (res.getErrcode() != 0) {
            throw new RuntimeException(res.getDescription());
        }
        ResParam resParam = res.getData().get(0);
        resParam.setDomain(authorizeRes.getDomain());
//        System.out.println("testGetToken()：" + resStr);
        TokenRes = resParam;
        return resParam;
    }

    @SneakyThrows
    public static String getAuthCode() {

        String url = "/koas/user/auth_code";
        //URL ？拼接字段
        Map<String, String> map = new LinkedHashMap<>();
        map.put("access_token", TokenRes.getAccessToken());
        String pathParamStr = getMapStr(map);
        //body

        //请求
        String resStr = HttpRequest.post(HOST + url + pathParamStr)
                .header("KIS-Timestamp", Long.toString(System.currentTimeMillis() / 1000L))
                .header("KIS-State", "vfun" + getNonce(12))
                .header("KIS-TraceID", "vfun10086")
                .header("KIS-Ver", "1.0")
                .contentType("application/json")
                .execute()
                .body();
        ResDto res = JSONObject.parseObject(resStr, ResDto.class);
        if (res.getErrcode() != 0) {
            throw new RuntimeException(res.getDescription());
        }
    //        System.out.println("testSendMsg()：" + resStr);
        authCode = res.getData().get(0).getAuthCode();
        return res.getData().get(0).getAuthCode();
    }

    @SneakyThrows
    public static String getSessionId() {

        String url = "/koas/user/auth_code_login_access_token";
        //URL ？拼接字段
        Map<String, String> map = new LinkedHashMap<>();
        map.put("client_id", clientId);
        map.put("client_secret",clientSecret);
        String pathParamStr = getMapStr(map);
        //body
        HashMap<String, Object> bodyMap = new HashMap<>();
        bodyMap.put("auth_code",authCode);
        //请求
        String resStr = HttpRequest.post(HOST + url + pathParamStr)
                .header("KIS-Timestamp", Long.toString(System.currentTimeMillis() / 1000L))
                .header("KIS-State", "WMS" + getNonce(12))
                .header("KIS-TraceID", "WMS")
                .header("KIS-Ver", "1.0")
                .contentType("application/json")
                .body(JSON.toJSONString(bodyMap))
                .execute()
                .body();
        ResDto res = JSONObject.parseObject(resStr, ResDto.class);
        if (res.getErrcode() != 0) {
            throw new RuntimeException(res.getDescription());
        }
        sessionId = res.getData().get(0).getSessionId();
        return res.getData().get(0).getSessionId();
    }
    @SneakyThrows
    public static AcctDto getAcctNumber() {

        String url = "/koas/user/account";
        //URL ？拼接字段
        Map<String, String> map = new LinkedHashMap<>();
        map.put("access_token", TokenRes.getAccessToken());
        String pathParamStr = getMapStr(map);
        //body
        HashMap<String, Object> bodyMap = new HashMap<>();
        bodyMap.put("session_id",sessionId);
        //请求
        String resStr = HttpRequest.post(HOST + url + pathParamStr)
                .header("KIS-Timestamp", Long.toString(System.currentTimeMillis() / 1000L))
                .header("KIS-State", "WMS" + getNonce(12))
                .header("KIS-TraceID", "WMS")
                .header("KIS-Ver", "1.0")
                .contentType("application/json")
                .body(JSON.toJSONString(bodyMap))
                .execute()
                .body();
        AcctDto res = JSONObject.parseObject(resStr, AcctDto.class);
        if (res.getErrcode() != 0) {
            throw new RuntimeException(res.getDescription());
        }
        acctDto = res;
        return res;
    }

    @SneakyThrows
    public static String getIcrmId() {

        String url = "/koas/user/account_applist";
        //URL ？拼接字段
        Map<String, String> map = new LinkedHashMap<>();
        map.put("access_token", TokenRes.getAccessToken());
        String pathParamStr = getMapStr(map);
        //body
        HashMap<String, Object> bodyMap = new HashMap<>();
        bodyMap.put("session_id",sessionId);
        bodyMap.put("client_id", clientId);
        bodyMap.put("acctnumber",acctDto.getData().getOrglist().get(0).getProdinstlist().get(0).getAccountlist().get(0).getAcctnumber());
        //请求
        String resStr = HttpRequest.post(HOST + url + pathParamStr)
                .header("KIS-Timestamp", Long.toString(System.currentTimeMillis() / 1000L))
                .header("KIS-State", "wmss" + getNonce(12))
                .header("KIS-TraceID", "wmss")
                .header("KIS-Ver", "1.0")
                .contentType("application/json")
                .body(JSON.toJSONString(bodyMap))
                .execute()
                .body();
        ResDto res = JSONObject.parseObject(resStr, ResDto.class);
        if (res.getErrcode() != 0) {
            throw new RuntimeException(res.getDescription());
        }

        return "";
    }

    @SneakyThrows
    public static String getServiceGateway() {

        String url = "/koas/user/get_service_gateway";
        //URL ？拼接字段
        Map<String, String> map = new LinkedHashMap<>();
        map.put("access_token", TokenRes.getAccessToken());
        String pathParamStr = getMapStr(map);
        //body
        HashMap<String, Object> bodyMap = new HashMap<>();
        bodyMap.put("session_id",sessionId);
        bodyMap.put("pid", acctDto.getData().getOrglist().get(0).getProdinstlist().get(0).getPid());
        bodyMap.put("acctnumber",acctDto.getData().getOrglist().get(0).getProdinstlist().get(0).getAccountlist().get(0).getAcctnumber());
        bodyMap.put("icrmid","2c9223b083cc0f130183e4c32be01544");
        //请求
        String resStr = HttpRequest.post(HOST + url + pathParamStr)
                .header("KIS-Timestamp", Long.toString(System.currentTimeMillis() / 1000L))
                .header("KIS-State", "wmss" + getNonce(12))
                .header("KIS-TraceID", "wmss")
                .header("KIS-Ver", "1.0")
                .contentType("application/json")
                .body(JSON.toJSONString(bodyMap))
                .execute()
                .body();
        GatewayDto res = JSONObject.parseObject(resStr, GatewayDto.class);
        if (res.getErrcode() != 0) {
            throw new RuntimeException(res.getDescription());
        }
        gatewayDto = res;
        return "SUCCESS";
    }

    public static void init(){
        getToken();
        getAuthCode();
        getSessionId();
        getAcctNumber();
        getServiceGateway();
    }

    public static void main(String[] args) {
        getToken();
        getAuthCode();
        getSessionId();
        getAcctNumber();
        getServiceGateway();
//        getIcrmId();
    }

    /**
     * 单据审核接口
     * @param FClassTypeID 外购入库(1001), 销售出库(1021),采购申请(1070) ,销售订单(1081),产品入库(1002),调拨单(1041) ,生产领料单（1024）,采购订单 (1071)
     * @param FInterID 单据ID
     * @return
     */
//    @SneakyThrows
//    @Deprecated
//    public static ResDto checkK3Vouch(Integer FClassTypeID, Integer FInterID) {
//        ResParam tokenRes = getToken();
//        String url = "/koas/APP007720/api/approve/submit";
//        //URL ？拼接字段
//        Map<String, String> map = new LinkedHashMap<>();
//        map.put("access_token", tokenRes.getAccessToken());
//        String pathParamStr = getMapStr(map);
//        //body
//        String bodyJson = VouchCheckDto.convertToQueryJson(FClassTypeID, FInterID);
//        //请求
//        String resStr = HttpRequest.post(HOST + url + pathParamStr)
//                .header("KIS-Timestamp", Long.toString(System.currentTimeMillis() / 1000L))
//                .header("KIS-State", "vfun" + getNonce(12))
//                .header("KIS-TraceID", "vfun10086")
//                .header("KIS-Ver", "1.0")
//                .header("KIS-AuthData", tokenRes.getAppToken())
//                .header("X-Api-SignHeaders", "X-Api-TimeStamp,X-Api-Nonce")
//                .header("X-GW-Router-Addr", tokenRes.getDomain())
//                .body(bodyJson)
//                .execute()
//                .body();
//        ResDto res = ObjUtil.parseObject(resStr, ResDto.class);
//        if (res.getErrcode() != 0) {
//            throw new RuntimeException(res.getDescription());
//        }
////        System.out.println("testSendMsg()：" + resStr);
//        return res;
//    }
}