微信官方提供了微信企业账户付款到微信个人零钱接口，提供企业向用户付款的功能，支持企业通过api接口付款，或通过微信支付商户平台网页功能操作付款。该接口并不是直接所有的商户都拥有，企业要开启必须满足以下两个条件：
1、商户号已入驻90日
2、商户号有30天连续正常交易
满足以上条件就可登录微信支付商户平台-产品中心，开通企业付款。
调用的链接地址：接口链接：https://api.mch.weixin.qq.com/mmpaymkttransfers/promotion/transfers
微信官方接口文档提供的调用微信企业付款的参数：
参数中最重要是获取用户openid和调用接口ip，获取openid可以通过公众号获取，app端可以直接获取。具体的代码实现如下：
封装请求微信企业付款的实体类transfers:
java" id="highlighter_548829">
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
public class transfers implements serializable{
private static final long serialversionuid = 1l;
/** 商户账号appid*/
public string mch_appid;
/** 微信支付商户号*/
public string mchid;
/** 随机串*/
public string nonce_str;
/** 签名*/
public string sign;
/** 商户订单号*/
public string partner_trade_no;
/** 用户id*/
public string openid;
/** 是否校验用户姓名 no_check：不校验真实姓名 force_check：强校验真实姓名*/
public string check_name;
/** 金额 单位：分*/
public integer amount;
/** 企业付款描述信息*/
public string desc;
/** ip地址*/
public string spbill_create_ip;
public string getmch_appid() {
return mch_appid;
}
public void setmch_appid(string mch_appid) {
this.mch_appid = mch_appid;
}
public string getmchid() {
return mchid;
}
public void setmchid(string mchid) {
this.mchid = mchid;
}
public string getnonce_str() {
return nonce_str;
}
public void setnonce_str(string nonce_str) {
this.nonce_str = nonce_str;
}
public string getsign() {
return sign;
}
public void setsign(string sign) {
this.sign = sign;
}
public string getpartner_trade_no() {
return partner_trade_no;
}
public void setpartner_trade_no(string partner_trade_no) {
this.partner_trade_no = partner_trade_no;
}
public string getopenid() {
return openid;
}
public void setopenid(string openid) {
this.openid = openid;
}
public string getcheck_name() {
return check_name;
}
public void setcheck_name(string check_name) {
this.check_name = check_name;
}
public integer getamount() {
return amount;
}
public void setamount(integer amount) {
this.amount = amount;
}
public string getdesc() {
return desc;
}
public void setdesc(string desc) {
this.desc = desc;
}
public string getspbill_create_ip() {
return spbill_create_ip;
}
public void setspbill_create_ip(string spbill_create_ip) {
this.spbill_create_ip = spbill_create_ip;
}
}
|
接口部分代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
private transfers transfers = new transfers();
// 构造签名的map
private sortedmap<object, object> parameters = new treemap<object, object>();
// 微信的参数
private weixinconfigutils config = new weixinconfigutils();
/**
* 微信提现（企业付款）
*/
@action("weixinwithdraw")
public string weixinwithdraw(){
string openid = request.getparameter("openid");
string ip = request.getparameter("ip");
string money = request.getparameter("money");
string doctorid = request.getparameter("doctorid");
if (stringutils.isnotblank(money) && stringutils.isnotblank(ip) && stringutils.isnotblank(openid) && stringutils.isnotblank(doctorid)) {
// 参数组
string appid = config.appid;
string mch_id = config.mch_id;
string nonce_str = randcharsutils.getrandomstring(16);
//是否校验用户姓名 no_check：不校验真实姓名 force_check：强校验真实姓名
string checkname ="no_check";
//等待确认转账金额,ip,openid的来源
integer amount = integer.valueof(money);
string spbill_create_ip = ip;
string partner_trade_no = uuidutils.getuuid();
//描述
string desc = "健康由我医师助手提现"+amount/100+"元";
// 参数：开始生成第一次签名
parameters.put("appid", appid);
parameters.put("mch_id", mch_id);
parameters.put("partner_trade_no", partner_trade_no);
parameters.put("nonce_str", nonce_str);
parameters.put("openid", openid);
parameters.put("checkname", checkname);
parameters.put("amount", amount);
parameters.put("spbill_create_ip", spbill_create_ip);
parameters.put("desc", desc);
string sign = wxsignutils.createsign("utf-8", parameters);
transfers.setamount(amount);
transfers.setcheck_name(checkname);
transfers.setdesc(desc);
transfers.setmch_appid(appid);
transfers.setmchid(mch_id);
transfers.setnonce_str(nonce_str);
transfers.setopenid(openid);
transfers.setpartner_trade_no(partner_trade_no);
transfers.setsign(sign);
transfers.setspbill_create_ip(spbill_create_ip);
string xmlinfo = httpxmlutils.transferxml(transfers);
try {
closeablehttpresponse response = httputil.post(weixinconstant.withdraw_url, xmlinfo, true);
string transfersxml = entityutils.tostring(response.getentity(), "utf-8");
map<string, string> transfermap = httpxmlutils.parserefundxml(transfersxml);
if (transfermap.size()>0) {
if (transfermap.get("result_code").equals("success") && transfermap.get("return_code").equals("success")) {
//成功需要进行的逻辑操作，
}
}
system.out.println("成功");
} catch (exception e) {
log.error(e.getmessage());
throw new basicruntimeexception(this, "企业付款异常" + e.getmessage());
}
}else {
system.out.println("失败");
}
return none;
}
|
产生随机串部分代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
public class randcharsutils {
private static simpledateformat df = new simpledateformat("yyyymmddhhmmss");
public static string getrandomstring(int length) { //length表示生成字符串的长度
string base = "abcdefghijklmnopqrstuvwxyz0123456789abcdefghijklmnopqrstuvwxyz";
random random = new random();
stringbuffer sb = new stringbuffer();
int number = 0;
for (int i = 0; i < length; i++) {
number = random.nextint(base.length());
sb.append(base.charat(number));
}
return sb.tostring();
}
}
|
生成签名：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
public class wxsignutils {
/**
* 微信支付签名算法sign
* @param characterencoding
* @param parameters
* @return
*/
@suppresswarnings("rawtypes")
public static string createsign(string characterencoding,sortedmap<object,object> parameters){
stringbuffer sb = new stringbuffer();
set es = parameters.entryset();//所有参与传参的参数按照accsii排序（升序）
iterator it = es.iterator();
while(it.hasnext()) {
map.entry entry = (map.entry)it.next();
string k = (string)entry.getkey();
object v = entry.getvalue();
if(null != v && !"".equals(v)
&& !"sign".equals(k) && !"key".equals(k)) {
sb.append(k + "=" + v + "&");
}
}
sb.append("key=" + weixinconstant.key);
string sign = md5util.md5encode(sb.tostring(), characterencoding).touppercase();
return sign;
}
}
|
md5部分代码:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
import java.security.messagedigest;
public class md5util {
private static string bytearraytohexstring(byte b[]) {
stringbuffer resultsb = new stringbuffer();
for (int i = 0; i < b.length; i++)
resultsb.append(bytetohexstring(b[i]));
return resultsb.tostring();
}
private static string bytetohexstring(byte b) {
int n = b;
if (n < 0)
n += 256;
int d1 = n / 16;
int d2 = n % 16;
return hexdigits[d1] + hexdigits[d2];
}
public static string md5encode(string origin, string charsetname) {
string resultstring = null;
try {
resultstring = new string(origin);
messagedigest md = messagedigest.getinstance("md5");
if (charsetname == null || "".equals(charsetname))
resultstring = bytearraytohexstring(md.digest(resultstring
.getbytes()));
else
resultstring = bytearraytohexstring(md.digest(resultstring
.getbytes(charsetname)));
} catch (exception exception) {
}
return resultstring;
}
private static final string hexdigits[] = { "0", "1", "2", "3", "4", "5",
"6", "7", "8", "9", "a", "b", "c", "d", "e", "f" };
}
|
构造xml：
|
1
2
3
4
5
6
7
8
9
10
|
/**
* 构造企业付款xml参数
* @param xml
* @return
*/
public static string transferxml(transfers transfers){
xstream.autodetectannotations(true);
xstream.alias("xml", transfers.class);
return xstream.toxml(transfers);
}
|
向微信发送xml请求（验证证书）部分代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
public class httputil {
/**
* 发送post请求
*
* @param url
* 请求地址
* @param outputentity
* 发送内容
* @param isloadcert
* 是否加载证书
*/
public static closeablehttpresponse post(string url, string outputentity, boolean isloadcert) throws exception {
httppost httppost = new httppost(url);
// 得指明使用utf-8编码，否则到api服务器xml的中文不能被成功识别
httppost.addheader("content-type", "text/xml");
httppost.setentity(new stringentity(outputentity, "utf-8"));
if (isloadcert) {
// 加载含有证书的http请求
return httpclients.custom().setsslsocketfactory(certutil.initcert()).build().execute(httppost);
} else {
return httpclients.custom().build().execute(httppost);
}
}
}
|
加载证书部分代码：（加载证书需要注意证书放置位置在项目下的webapp中建文件夹，linux单独防止只要地址配置正确即可。）
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
import java.io.file;
import java.io.fileinputstream;
import java.security.keystore;
import javax.net.ssl.sslcontext;
import org.apache.http.conn.ssl.sslconnectionsocketfactory;
import org.apache.http.ssl.sslcontexts;
/**
* 加载证书的类
* @author
* @since 2017/08/16
*/
@suppresswarnings("deprecation")
public class certutil {
private static weixinconfigutils config = new weixinconfigutils();
/**
* 加载证书
*/
public static sslconnectionsocketfactory initcert() throws exception {
fileinputstream instream = null;
keystore keystore = keystore.getinstance("pkcs12");
instream = new fileinputstream(new file(weixinconstant.path));
keystore.load(instream, config.mch_id.tochararray());
if (null != instream) {
instream.close();
}
sslcontext sslcontext = sslcontexts.custom().loadkeymaterial(keystore,config.mch_id.tochararray()).build();
sslconnectionsocketfactory sslsf = new sslconnectionsocketfactory(sslcontext, new string[]{"tlsv1"}, null, sslconnectionsocketfactory.browser_compatible_hostname_verifier);
return sslsf;
}
}
|
加载配置文件部分代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
@suppresswarnings("unused")
public class weixinconfigutils {
private static final log log = logfactory.getlog(weixinconfigutils.class);
public static string appid;
public static string mch_id;
public static string notify_url;
public static string order_notify_url;
public static string doctor_notify_url;
static {
try{
inputstream is = weixinconfigutils.class.getresourceasstream("/weixin.properties");
properties properties = new properties();
properties.load(is);
appid = properties.getproperty("weixin.appid");
mch_id = properties.getproperty("weixin.mch_id");
notify_url = properties.getproperty("weixin.notify_url");
order_notify_url = properties.getproperty("weixin.order_notify_url");
doctor_notify_url = properties.getproperty("weixin.doctor_notify_url");
}catch(exception ex){
log.debug("加载配置文件："+ex.getmessage());
}
}
}
|
获取返回的xml参数并解析为map：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
/**
* 解析申请退款之后微信返回的值并进行存库操作
* @throws ioexception
* @throws jdomexception
*/
public static map<string, string> parserefundxml(string refundxml) throws jdomexception, ioexception{
parsexmlutils.jdomparsexml(refundxml);
stringreader read = new stringreader(refundxml);
// 创建新的输入源sax 解析器将使用 inputsource 对象来确定如何读取 xml 输入
inputsource source = new inputsource(read);
// 创建一个新的saxbuilder
saxbuilder sb = new saxbuilder();
// 通过输入源构造一个document
org.jdom.document doc;
doc = (org.jdom.document) sb.build(source);
org.jdom.element root = doc.getrootelement();// 指向根节点
list<org.jdom.element> list = root.getchildren();
map<string, string> refundordermap = new hashmap<string, string>();
if(list!=null&&list.size()>0){
for (org.jdom.element element : list) {
refundordermap.put(element.getname(), element.gettext());
}
return refundordermap;
}
return null;
}
|
调用时候主要是获取openid和调起接口的ip（ip十分重要，微信在收到xml后会校验传过去的ip和微信获取的调起接口ip是否一致）
在调用时候当返回错误码为“systemerror”时，一定要使用原单号重试，否则可能造成重复支付等资金风险。
微信官方文档提供有相关的 参数错误码
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：https://blog.csdn.net/github_38924695/article/details/78850704