java实现微信企业付款到个人功能
更新时间：2018年09月29日 09:23:23 作者：蓝色格子ren
这篇文章主要为大家详细介绍了java实现微信企业付款到个人功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
微信官方提供了微信企业账户付款到微信个人零钱接口，提供企业向用户付款的功能，支持企业通过API接口付款，或通过微信支付商户平台网页功能操作付款。该接口并不是直接所有的商户都拥有，企业要开启必须满足以下两个条件：
1、商户号已入驻90日
2、商户号有30天连续正常交易
满足以上条件就可登录微信支付商户平台-产品中心，开通企业付款。
调用的链接地址：接口链接：https://api.mch.weixin.qq.com/mmpaymkttransfers/promotion/transfers
微信官方接口文档提供的调用微信企业付款的参数：
参数中最重要是获取用户openid和调用接口ip，获取openid可以通过公众号获取，app端可以直接获取。具体的代码实现如下：
封装请求微信企业付款的实体类Transfers:
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;
}
}
接口部分代码：
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;
}
产生随机串部分代码：
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();
}
}
生成签名：
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部分代码:
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：
/**
* 构造企业付款xml参数
* @param xml
* @return
*/
public static String transferXml(Transfers transfers){
xStream.autodetectAnnotations(true);
xStream.alias("xml", Transfers.class);
return xStream.toXML(transfers);
}
向微信发送xml请求（验证证书）部分代码：
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单独防止只要地址配置正确即可。）
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;
}
}
加载配置文件部分代码：
@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：
/**
* 解析申请退款之后微信返回的值并进行存库操作
* @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”时，一定要使用原单号重试，否则可能造成重复支付等资金风险。
微信官方文档提供有相关的参数错误码
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
本文主要介绍了SpringBoot实现RabbitMQ监听消息的四种方式,包括@RabbitListener,MessageListener接口,MessageListenerAdapter适配器,@RabbitHandler这几种,感兴趣的可以了解一下2024-05-05
SpringBoot核心@SpringBootApplication使用介绍
这篇文章主要介绍了SpringBoot核心@SpringBootApplication的使用，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-03-03
spring boot项目同时传递参数和文件的多种方式代码演示
这篇文章主要介绍了spring boot项目同时传递参数和文件的多种方式,在开发接口中，遇到了需要同时接收参数和文件的情况，可以有多种方式实现文件+参数的接收，这里基于spring boot 3 + vue 3 + axios，做一个简单的代码演示，需要的朋友可以参考下2023-06-06
最近使用new date（）获取的时间会和真实的本地时间相差8小时。本文就详细的来介绍一下解决java获取时间相差8小时的问题，感兴趣的可以了解一下2021-09-09
IntelliJ IDEA 2024.2 发布新功能介绍Spring Data JPA即时查询、自动补全cro
在2024.2 Ultimate版本中,对 Spring Data JPA 的支持做了增强,新功能允许您在不运行应用程序和分析日志文件的情况下查看方法将生成的查询,下面就来一起看看这个版本中推出的几个强大新特性2024-08-08
这篇文章主要介绍了Java简单实现农夫过河问题,简单描述了农夫过河问题的概念、原理并结合简单实例形式分析了java解决农夫过河问题的相关操作技巧,需要的朋友可以参考下2017-12-12
这篇文章主要介绍了java进行文件读写操作详解的相关资料,需要的朋友可以参考下2014-10-10
Java hashCode原理以及与equals()区别联系详解
在 Java 应用程序执行期间，在同一对象上多次调用 hashCode 方法时，必须一致地返回相同的整数，前提是对象上 equals 比较中所用的信息没有被修改。从某一应用程序的一次执行到同一应用程序的另一次执行，该整数无需保持一致2022-11-11
这篇文章主要给大家分享的是ava线程的三种创建方式，Thread、Runnable和Thread、Runnable和Thread，想了解具体方式的小伙伴可以参考下面文章内容，希望对你有所帮助2021-11-11
这篇文章主要介绍了Java 信号量Semaphore的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-09-09
最新评论