package co.yixiang.modules.transferToUser.utils;

import com.google.gson.annotations.SerializedName;
import lombok.Data;
import okhttp3.*;

import java.io.IOException;
import java.io.UncheckedIOException;
import java.security.PrivateKey;
import java.util.ArrayList;
import java.util.List;

/**
 * 發(fā)起轉(zhuǎn)賬
 */
public class TransferToUser {
    private static String HOST = "https://api.mch.weixin.qq.com";
    private static String METHOD = "POST";
    private static String PATH = "/v3/fund-app/mch-transfer/transfer-bills";

    public static void main(String[] args) {
        // TODO: 請準(zhǔn)備商戶開發(fā)必要參數(shù)，參考：https://pay.weixin.qq.com/doc/v3/merchant/4013070756
        TransferToUser client = new TransferToUser(
                "12321321",                    // 商戶號，是由微信支付系統(tǒng)生成并分配給每個商戶的唯一標(biāo)識符，商戶號獲取方式參考 https://pay.weixin.qq.com/doc/v3/merchant/4013070756
                "12321321321321312",         // 商戶API證書序列號，如何獲取請參考 https://pay.weixin.qq.com/doc/v3/merchant/4013053053
                "E:\\Java_project_self\privateKey.pem"     // 商戶API證書私鑰文件路徑，本地文件路徑
        );

        TransferToUserRequest request = new TransferToUserRequest();
        request.appid = "wx213123213";
        request.outBillNo = "plfk212DS" + System.currentTimeMillis();
        request.transferSceneId = "1005";
        request.openid = "21321321321213";
        request.transferAmount = 10L;
        request.transferRemark = "傭金提現(xiàn)到賬";
        request.notifyUrl = "https://www.weixin.qq.com/wxpay/pay.php";

        List<TransferSceneReportInfo> list = new ArrayList<>();

        TransferSceneReportInfo info1 = new TransferSceneReportInfo();
        info1.infoType = "崗位類型";
        info1.infoContent = "分享有禮";
        list.add(info1);

        TransferSceneReportInfo info2 = new TransferSceneReportInfo();
        info2.infoType = "報酬說明";
        info2.infoContent = "用戶推廣獲得傭金";
        list.add(info2);

        request.userRecvPerception = "勞務(wù)報酬";
        request.transferSceneReportInfos = list;

        try {
            TransferToUserResponse response = client.run(request);
            // TODO: 請求成功，繼續(xù)業(yè)務(wù)邏輯
            System.out.println(response);
        } catch (Exception e) {
            // TODO: 請求失敗，根據(jù)狀態(tài)碼執(zhí)行不同的邏輯
            e.printStackTrace();
        }
    }

    public TransferToUserResponse run(TransferToUserRequest request) {
        String uri = PATH;
        String reqBody = WXPayUtility.toJson(request);

        Request.Builder reqBuilder = new Request.Builder().url(HOST + uri);
        reqBuilder.addHeader("Accept", "application/json");

        reqBuilder.addHeader("Authorization", WXPayUtility.buildAuthorization(mchid, certificateSerialNo, privateKey, METHOD, uri, reqBody));
        reqBuilder.addHeader("Content-Type", "application/json");
        RequestBody requestBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8"), reqBody);
        reqBuilder.method(METHOD, requestBody);
        Request httpRequest = reqBuilder.build();

        // 發(fā)送HTTP請求
        OkHttpClient client = new OkHttpClient.Builder().build();
        try (Response httpResponse = client.newCall(httpRequest).execute()) {
            String respBody = WXPayUtility.extractBody(httpResponse);
            if (httpResponse.code() >= 200 && httpResponse.code() < 300) {
                // 2XX 成功，驗(yàn)證應(yīng)答簽名
//                WXPayUtility.validateResponse(this.wechatPayPublicKeyId, this.wechatPayPublicKey,
//                        httpResponse.headers(), respBody);

                // 從HTTP應(yīng)答報文構(gòu)建返回數(shù)據(jù)
                return WXPayUtility.fromJson(respBody, TransferToUserResponse.class);
            } else {
                throw new WXPayUtility.ApiException(httpResponse.code(), respBody, httpResponse.headers());
            }
        } catch (IOException e) {
            throw new UncheckedIOException("Sending request to " + uri + " failed.", e);
        }
    }

    private final String mchid;
    private final String certificateSerialNo;
    private final PrivateKey privateKey;

    public TransferToUser(String mchid, String certificateSerialNo, String privateKeyFilePath) {
        this.mchid = mchid;
        this.certificateSerialNo = certificateSerialNo;
        this.privateKey = WXPayUtility.loadPrivateKeyFromPath(privateKeyFilePath);
    }

    @Data
    public static class TransferToUserRequest {
        @SerializedName("appid")
        public String appid;

        @SerializedName("out_bill_no")
        public String outBillNo;

        @SerializedName("transfer_scene_id")
        public String transferSceneId;

        @SerializedName("openid")
        public String openid;

        @SerializedName("user_name")
        public String userName;

        @SerializedName("transfer_amount")
        public Long transferAmount;

        @SerializedName("transfer_remark")
        public String transferRemark;

        @SerializedName("notify_url")
        public String notifyUrl;

        @SerializedName("user_recv_perception")
        public String userRecvPerception;

        @SerializedName("transfer_scene_report_infos")
        public List<TransferSceneReportInfo> transferSceneReportInfos = new ArrayList<TransferSceneReportInfo>();
    }

    @Data
    public static class TransferToUserResponse {
        @SerializedName("out_bill_no")
        public String outBillNo;

        @SerializedName("transfer_bill_no")
        public String transferBillNo;

        @SerializedName("create_time")
        public String createTime;

        @SerializedName("state")
        public TransferBillStatus state;

        @SerializedName("package_info")
        public String packageInfo;
    }

    @Data
    public static class TransferSceneReportInfo {
        @SerializedName("info_type")
        public String infoType;

        @SerializedName("info_content")
        public String infoContent;
    }

    public enum TransferBillStatus {
        @SerializedName("ACCEPTED")
        ACCEPTED,
        @SerializedName("PROCESSING")
        PROCESSING,
        @SerializedName("WAIT_USER_CONFIRM")
        WAIT_USER_CONFIRM,
        @SerializedName("TRANSFERING")
        TRANSFERING,
        @SerializedName("SUCCESS")
        SUCCESS,
        @SerializedName("FAIL")
        FAIL,
        @SerializedName("CANCELING")
        CANCELING,
        @SerializedName("CANCELLED")
        CANCELLED
    }

}