微信商家转账常见的一些问题汇总(附Java调用示例)

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;

/**
 * 发起转账
 */
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: 请准备商户开发必要参数，参考：https://pay.weixin.qq.com/doc/v3/merchant/4013070756
        transfertouser client = new transfertouser(
                "12321321",                    // 商户号，是由微信支付系统生成并分配给每个商户的唯一标识符，商户号获取方式参考 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 = "佣金提现到账";
        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 = "劳务报酬";
        request.transferscenereportinfos = list;

        try {
            transfertouserresponse response = client.run(request);
            // todo: 请求成功，继续业务逻辑
            system.out.println(response);
        } catch (exception e) {
            // todo: 请求失败，根据状态码执行不同的逻辑
            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();

        // 发送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 成功，验证应答签名
//                wxpayutility.validateresponse(this.wechatpaypublickeyid, this.wechatpaypublickey,
//                        httpresponse.headers(), respbody);

                // 从http应答报文构建返回数据
                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
    }

}