package com.allinpay.syb.lib;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.allinpay.syb.model.PayOrderNotifyParam;
import com.allinpay.syb.model.PayOrderRefundResponse;
import com.allinpay.syb.model.PayPublicModel;
import com.doumee.core.utils.HttpsUtil;
import com.doumee.dao.business.model.Orders;
import com.doumee.dao.business.model.Refund;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;

import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.net.URLEncoder;
import java.util.Date;
import java.util.Map;
import java.util.TreeMap;

@Slf4j
@Data
public class DoumeeTLUtil {
    public static final String SUCCESS_CODE = "SUCCESS";
    public static final String FAIL_CODE = "FAIL";
    private PayPublicModel publicModel;
    private String appkey;
    private String pubKey;
    public DoumeeTLUtil(PayPublicModel model){
        this.publicModel = model;
    }
    public  static  String REFUND_SN_PREFIX = "refund_";
    public PayOrderRefundResponse sendRefundOrder(String reqsn, String oldReqsn, String money, String remark)    {
            TreeMap<String, String> params = new TreeMap<String, String>();
            params.put("cusid", publicModel.getCusid());
            params.put("appid", publicModel.getAppid());
            params.put("version", publicModel.getVersion());
            params.put("trxid", "");
            params.put("randomstr", SybUtil.getValidatecode(8));
            params.put("signtype", publicModel.getSigntype());
            params.put("notify_url",publicModel.getNotifyUrl());
            params.remove("sign");
            params.put("reqsn",REFUND_SN_PREFIX+reqsn);
            params.put("oldreqsn",oldReqsn);
            params.put("trxamt",money);
            params.put("remark",remark);
            return  sendRequest(params,publicModel.getUrl()+"/tranx/refund",publicModel.getAppkey(),publicModel.getAppPubkey(),new TypeReference<PayOrderRefundResponse>(){});
    }
    public  PayOrderNotifyParam   sendQueryOrder(String reqsn  )  {
            TreeMap<String, String> params = new TreeMap<String, String>();
            params.put("cusid", publicModel.getCusid());
            params.put("appid", publicModel.getAppid());
            params.put("version", publicModel.getVersion());
            params.put("trxid", "");
            params.put("randomstr", SybUtil.getValidatecode(8));
            params.put("signtype", publicModel.getSigntype());
            params.remove("sign");
            params.put("reqsn",reqsn);
           return  sendRequest(params,publicModel.getUrl()+"/tranx/query",publicModel.getAppkey(),publicModel.getAppPubkey(),new TypeReference<PayOrderNotifyParam>(){});
    }
    public static <T> T sendRequest(TreeMap<String,String> params, String url, String appkey, String pubKey, TypeReference<T> typeReference )  {
        try {
            params.put("sign", SybUtil.unionSign(params,appkey,params.get("signtype")));
            String data =getHttpParamsStr(params);
            log.error("订单交易数据请求================{}",data);
            String result =  HttpsUtil.post(url,data,"application/x-www-form-urlencoded",true);
            log.error("订单查交据返回================{}",result);
            T map = handleResult(result,pubKey,params.get("signtype"),typeReference);
            return map;
        }catch (Exception e){
            log.error("通联订单查询异常================{}",e);
        }
        return  null;
    }
    public static String getHttpParamsStr(Map<String, String> params ) throws IOException {
        StringBuilder outBuf = new StringBuilder();
        boolean isNotFirst = false;
        for (Map.Entry<String, String> entry: params.entrySet()){
            if (isNotFirst)
                outBuf.append('&');
            isNotFirst = true;
            outBuf
                    .append(entry.getKey())
                    .append('=')
                    .append(URLEncoder.encode(StringUtils.defaultString(entry.getValue(),""), "UTF-8"));
        }
        System.out.println("参数:"+outBuf.toString());
        return outBuf.toString();
    }

    public static <T> T  handleResult(String result,String pubKey,String signType, TypeReference<T> typeReference ) throws Exception{
        log.error("返回数据返回================{}",result);
        Map map = SybUtil.json2ObjMap(result);
        if(map == null){
            log.error("返回数据返回错误================{}",result);
            throw new Exception("返回数据错误");
        }
        if("SUCCESS".equals(map.get("retcode"))){
            TreeMap tmap = new TreeMap();
            tmap.putAll(map);
            if(SybUtil.validSign(tmap, pubKey, signType)){
                T param = JSONObject.parseObject(result,typeReference.getType());
                return param;
            }
        }
        return null;
    }
    public static  TreeMap<String, String> getParams(HttpServletRequest request){
        TreeMap<String, String> map = new TreeMap<String, String>();
        Map reqMap = request.getParameterMap();
        for(Object key:reqMap.keySet()){
            String value = ((String[])reqMap.get(key))[0];
            System.out.println(key+";"+value);
            map.put(key.toString(),value);
        }
        return map;
    }

}