package com.iotechn.unimall.biz.service.freight;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.dobbinsoft.fw.core.enums.BaseEnums;
import com.dobbinsoft.fw.core.exception.ServiceException;
import com.dobbinsoft.fw.core.exception.ThirdPartServiceException;
import com.iotechn.unimall.data.dto.freight.ShipTraceDTO;
import com.iotechn.unimall.data.dto.freight.ShipTraceItemDTO;
import com.iotechn.unimall.data.enums.ShipCodeType;
import com.iotechn.unimall.data.exception.ExceptionDefinition;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.Base64Utils;
import org.springframework.util.CollectionUtils;

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.security.MessageDigest;
import java.util.LinkedList;
import java.util.List;


@Component
public class KdniaoTrackQueryAPI implements ShipTraceQuery {

    private static final Logger logger = LoggerFactory.getLogger(KdniaoTrackQueryAPI.class);

    @Value("${com.iotechn.ship.query.kdn.app-key}")
    private String businessID;

    @Value("${com.iotechn.ship.query.kdn.business-id}")
    private String appKey;

    private static final String REQ_URL = "http://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx";

    private OkHttpClient okHttpClient = new OkHttpClient();

    @Override
    public ShipTraceDTO query(String shipNo, String shipCode) throws ServiceException {
        String msg = "";
        try {
            String orderTracesByJson = getOrderTracesByJson(shipCode, shipNo);
            JSONObject jsonObject = JSONObject.parseObject(orderTracesByJson);
            ShipTraceDTO shipTraceDTO = new ShipTraceDTO();
            shipTraceDTO.setShipNo(shipNo);
            shipTraceDTO.setShipCode(shipCode);
            shipTraceDTO.setShipName(BaseEnums.getByCode(shipCode, ShipCodeType.class).getMsg());
            List<ShipTraceItemDTO> traces = new LinkedList<>();
            JSONArray tracesFromJson = jsonObject.getJSONArray("Traces");
            if (!CollectionUtils.isEmpty(tracesFromJson)) {
                for (int i = 0; i < tracesFromJson.size(); i++) {
                    ShipTraceItemDTO shipTraceItemDTO = new ShipTraceItemDTO();
                    shipTraceItemDTO.setStation(tracesFromJson.getJSONObject(i).getString("AcceptStation"));
                    shipTraceItemDTO.setTime(tracesFromJson.getJSONObject(i).getString("AcceptTime"));
                    traces.add(shipTraceItemDTO);
                }
            }
            shipTraceDTO.setTraces(traces);
            return shipTraceDTO;
        } catch (Exception e) {
            logger.error("[快递鸟 查询] 异常", e);
            throw new ThirdPartServiceException(msg, ExceptionDefinition.THIRD_PART_SERVICE_EXCEPTION.getCode());
        }
    }

    /**
     * Json方式 查询订单物流轨迹
     *
     * @throws Exception
     */
    private String getOrderTracesByJson(String shipCode, String shipNo) throws Exception {
        String requestData = "{\"OrderCode\":\"\",\"ShipperCode\":\"" + shipCode + "\",\"LogisticCode\":\"" + shipNo + "\"}";
        MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded");
        StringBuilder sb = new StringBuilder();
        sb.append("RequestData=");
        sb.append(URLEncoder.encode(requestData, "UTF-8"));
        sb.append("&EBusinessID=");
        sb.append(businessID);
        sb.append("&RequestType=1002");
        String dataSign = encrypt(requestData, appKey, "UTF-8");
        sb.append("&DataSign=");
        sb.append(dataSign);
        sb.append("&DataType=2");
        RequestBody body = RequestBody.create(mediaType, sb.toString());
        String result = okHttpClient.newCall(new Request.Builder().url(REQ_URL).post(body).build()).execute().body().string();
        return result;
    }

    /**
     * MD5加密
     *
     * @param str     内容
     * @param charset 编码方式
     * @throws Exception
     */
    private String MD5(String str, String charset) throws Exception {
        MessageDigest md = MessageDigest.getInstance("MD5");
        md.update(str.getBytes(charset));
        byte[] result = md.digest();
        StringBuffer sb = new StringBuffer(32);
        for (int i = 0; i < result.length; i++) {
            int val = result[i] & 0xff;
            if (val <= 0xf) {
                sb.append("0");
            }
            sb.append(Integer.toHexString(val));
        }
        return sb.toString().toLowerCase();
    }

    /**
     * base64编码
     *
     * @param str     内容
     * @param charset 编码方式
     * @throws UnsupportedEncodingException
     */
    private String base64(String str, String charset) throws UnsupportedEncodingException {
        return Base64Utils.encodeToString(str.getBytes(charset));
    }

    /**
     * 电商Sign签名生成
     *
     * @param content  内容
     * @param keyValue Appkey
     * @param charset  编码方式
     * @return DataSign签名
     * @throws UnsupportedEncodingException ,Exception
     */
    private String encrypt(String content, String keyValue, String charset) throws UnsupportedEncodingException, Exception {
        if (keyValue != null) {
            return base64(MD5(content + keyValue, charset), charset);
        }
        return base64(MD5(content, charset), charset);
    }



}