服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|JAVA教程|ASP教程|编程技术|

服务器之家 - 编程语言 - JAVA教程 - java微信扫码支付模式一线下支付功能实现

java微信扫码支付模式一线下支付功能实现

2020-07-02 11:25wangqiuyun JAVA教程

本篇文章主要介绍了JAVA微信扫码支付模式一线下支付功能实现,具有一定的参考价值,有需要的可以了解一下。

一、准备工作

无数人来追问模式一的开发,所以在这就贴出来,仅供参考。关于模式一和模式二的区别,我有解释过很多次,无非就是模式一的二维码是针对商品的,模式二的二维码是针对订单的,其他具体细节我就不费口舌了,各位可以自行去官方查看文档,然后是选模式一还是模式二就得看自己的业务了。

1.1、有关配置参数

还是之前那四样,APP_ID和APP_SECRET可以在公众平台找着,MCH_ID和API_KEY则在商户平台找到,特别是API_KEY要在商户平台设置好,这个东东关系到参数校验的正确与否,所以一定要设置正确。扫码支付模式一其实与扫码支付模式二类似,实际只会用到APP_ID、MCH_ID和API_KEY,其他的都不用。模式一的官方文档地址在这:https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=6_4

1.2、有关概念

在这里我想先修正一个概念,在之前模式二开发过程中我曾提到了一个“支付回调地址”这样的概念,其作用实际就是客户在扫描完成支付后,微信服务器要访问我们提供的这个地址,给我们发送支付结果,以便我们核实订单进行发货,这是其他支付工具比较普遍的概念和叫法。不过后来我翻了一下微信官网的文档,发现在模式一开发中,他们把这个叫做“异步通知url”而不是什么“支付回调地址”,但本质这指的是一个意思。可是为什么我要在这提到这个东东呢?这是因为在模式一中,实际上还有另外一个所谓的“支付回调”称之为“扫码支付回调URL”,这东东与上面的“异步通知url”可就不一样了,简单理解可以认为是咱们的服务器上一个用来辅助完成下单的接口。模式一的开发同时需要“扫码支付回调URL”与“异步通知url”两个接口配合才能完成,所以这里大家要辨别好了。

“异步通知url”在调用统一下单接口时进行设置,可以动态设置,只要这个接口按照有关规则接收参数响应参数即可。而“扫码支付回调URL”则较为固定,它在微信公众平台设置,设置后需要10分钟左右才能生效,大家登录微信公众平台后,选择微信支付,在开发配置选项卡下面就可以找着:

java微信扫码支付模式一线下支付功能实现

这里咱们要设置一个自己服务器的地址(再说一遍公网地址,就是让微信服务器能找着你)。

1.3、开发环境

我这里以最基本的Servlet 3.0作为示例环境。关于引用第三方的jar包,相比较于模式二开发,除了用到了xml操作的jdom,以外就一个Google ZXing的二维码包和log4j包。如下图:

java微信扫码支付模式一线下支付功能实现

为了方便调试,建议各位先在这个环境下调通了再移植到真实项目当中去。

二、开发实战

在动手之前,我建议大家先去官方文档那好好看看那个时序图,理解了那个时序图,写代码也就不是什么难事了,当然如果看图你没办法理解,也可以结合我下面的代码来试着理解。

2.1、二维码生成

首先是二维码,二维码中的内容为链接,形式为:

weixin://wxpay/bizpayurl?sign=XXXXX&appid=XXXXX&mch_id=XXXXX&product_id=XXXXXX&time_stamp=XXXXXX&nonce_str=XXXXX

具体可以参考官方文档模式一生成二维码规则。接下来我们需要将该链接生成二维码,我这里使用了Google ZXing来生成二维码。

?
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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
package com.wqy;
 
import java.io.IOException;
import java.io.OutputStream;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
import java.util.SortedMap;
import java.util.TreeMap;
 
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
import org.apache.log4j.Logger;
 
import com.google.zxing.BarcodeFormat;
import com.google.zxing.EncodeHintType;
import com.google.zxing.MultiFormatWriter;
import com.google.zxing.WriterException;
import com.google.zxing.client.j2se.MatrixToImageWriter;
import com.google.zxing.common.BitMatrix;
import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
import com.wqy.util.PayCommonUtil;
import com.wqy.util.PayConfigUtil;
 
/**
 * Servlet implementation class Pay1
 */
@WebServlet("/Pay1")
public class Pay1 extends HttpServlet {
 private static final long serialVersionUID = 1L;
 private static Logger logger = Logger.getLogger(Pay1.class);
 
 public static int defaultWidthAndHeight=200;
 
 /**
 * @see HttpServlet#HttpServlet()
 */
 public Pay1() {
 super();
 // TODO Auto-generated constructor stub
 }
 
 /**
 * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse
 * response)
 */
 protected void doGet(HttpServletRequest request, HttpServletResponse response)
  throws ServletException, IOException {
  
 // TODO Auto-generated method stub
 String nonce_str = PayCommonUtil.getNonce_str();
 long time_stamp = System.currentTimeMillis() / 1000;
 String product_id = "hd_goodsssss_10";
 String key = PayConfigUtil.API_KEY; // key
  
 SortedMap<Object, Object> packageParams = new TreeMap<Object, Object>();
 packageParams.put("appid", PayConfigUtil.APP_ID);
 packageParams.put("mch_id", PayConfigUtil.MCH_ID);
 packageParams.put("time_stamp", String.valueOf(time_stamp));
 packageParams.put("nonce_str", nonce_str);
 packageParams.put("product_id", product_id);
 String sign = PayCommonUtil.createSign("UTF-8", packageParams,key);//MD5哈希
 packageParams.put("sign", sign);
  
 //生成参数
 String str = ToUrlParams(packageParams);
 String payurl = "weixin://wxpay/bizpayurl?" + str;
 logger.info("payurl:"+payurl);
  
  
 //生成二维码
 Map<EncodeHintType, Object> hints=new HashMap<EncodeHintType, Object>();
 // 指定纠错等级
 hints.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.L);
 // 指定编码格式
 hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");
 hints.put(EncodeHintType.MARGIN, 1);
 try {
  BitMatrix bitMatrix = new MultiFormatWriter().encode(payurl,BarcodeFormat.QR_CODE, defaultWidthAndHeight, defaultWidthAndHeight, hints);
  OutputStream out = response.getOutputStream();
  MatrixToImageWriter.writeToStream(bitMatrix, "png", out);//输出二维码
  out.flush();
  out.close();
  
 } catch (WriterException e) {
  // TODO Auto-generated catch block
  e.printStackTrace();
 }
 }
 
 public String ToUrlParams(SortedMap<Object, Object> packageParams){
 //实际可以不排序
 StringBuffer sb = new StringBuffer();
 Set es = packageParams.entrySet();
 Iterator it = es.iterator();
 while (it.hasNext()) {
  Map.Entry entry = (Map.Entry) it.next();
  String k = (String) entry.getKey();
  String v = (String) entry.getValue();
  if (null != v && !"".equals(v)) {
  sb.append(k + "=" + v + "&");
  }
 }
  
 sb.deleteCharAt(sb.length()-1);//删掉最后一个&
 return sb.toString();
 }
 
 /**
 * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse
 * response)
 */
 protected void doPost(HttpServletRequest request, HttpServletResponse response)
  throws ServletException, IOException {
 // TODO Auto-generated method stub
 doGet(request, response);
 }
 
}

2.2、扫描支付回调url接口

当客户用微信扫了上面的二位码之后,微信服务器就会访问此接口,在这里我们要完成统一下单获取交易会话标识,处理的主要流程如下:

1)、接收微信服务器发送过来的参数,对参数进行签名校验;

2)、取出参数product_id,这是二维码上唯一能够透传过来的参数,其他参数可参照官方文档模式一3.1 输入参数;

3)、根据product_id处理自己的业务,比如计算支付金额,生成订单号等;

4)、调用统一下单接口获取交易会话标识prepay_id;

   4.1)、准备好相关参数(如appid、mch_id、支付金额、订单号、商品描述等),调用微信统一下单接口(与模式二调用统一下单接口类似),留意一下这里要加上上面提到的“异步通知url”,也就是后面会说道的异步通知url接口,具体参数参考官方文档统一下单请求参数;

   4.2)、接收统一下单接口返回的参数,对参数进行验签;  

   4.3)、取出参数prepay_id,这是交易会话标识,极其重要,其他参数可参考官方文档统一下单返回结果;

5)、准备好相关参数(如appid、mch_id、return_code、prepay_id等),响应最开始的支付回调(如果上面步骤如果错误,如验签失败则可以返回错误参数给微信服务器),具体参数可参照官方文档模式一3.2 输出参数。

?
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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
package com.wqy;
 
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.SortedMap;
import java.util.TreeMap;
 
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
import org.apache.log4j.Logger;
 
import com.wqy.util.HttpUtil;
import com.wqy.util.PayCommonUtil;
import com.wqy.util.PayConfigUtil;
 
/**
 * Servlet implementation class Notify1
 */
@WebServlet("/Notify1")
public class Notify1 extends HttpServlet {
 private static final long serialVersionUID = 1L;
 private static Logger logger = Logger.getLogger(Notify1.class);
 
 /**
 * @see HttpServlet#HttpServlet()
 */
 public Notify1() {
 super();
 // TODO Auto-generated constructor stub
 }
 
 /**
 * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse
 * response)
 */
 protected void doGet(HttpServletRequest request, HttpServletResponse response)
  throws ServletException, IOException {
 // TODO Auto-generated method stub
 
 // 读取xml
 InputStream inputStream;
 StringBuffer sb = new StringBuffer();
 inputStream = request.getInputStream();
 String s;
 BufferedReader in = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
 while ((s = in.readLine()) != null) {
  sb.append(s);
 }
 in.close();
 inputStream.close();
  
 SortedMap<Object, Object> packageParams = PayCommonUtil.xmlConvertToMap(sb.toString());
 logger.info(packageParams);
  
 // 账号信息
 String key = PayConfigUtil.API_KEY; // key
  
 String resXml="";//反馈给微信服务器
 // 验签
 if (PayCommonUtil.isTenpaySign("UTF-8", packageParams, key)) {
  //appid openid mch_id is_subscribe nonce_str product_id sign
  
  //统一下单
  String openid = (String)packageParams.get("openid");
  String product_id = (String)packageParams.get("product_id");
  //解析product_id,计算价格等
  
  String out_trade_no = String.valueOf(System.currentTimeMillis()); // 订单号
  String order_price = "1"; // 价格 注意:价格的单位是分
  String body = product_id; // 商品名称 这里设置为product_id
  String attach = "XXX店"; //附加数据
  
  String nonce_str0 = PayCommonUtil.getNonce_str();
  
  // 获取发起电脑 ip
  String spbill_create_ip = PayConfigUtil.CREATE_IP;
  String trade_type = "NATIVE";
  
  
  SortedMap<Object,Object> unifiedParams = new TreeMap<Object,Object>();
  unifiedParams.put("appid", PayConfigUtil.APP_ID); // 必须
  unifiedParams.put("mch_id", PayConfigUtil.MCH_ID); // 必须
  unifiedParams.put("out_trade_no", out_trade_no); // 必须
  unifiedParams.put("product_id", product_id);
  unifiedParams.put("body", body); // 必须
  unifiedParams.put("attach", attach);
  unifiedParams.put("total_fee", order_price); // 必须
  unifiedParams.put("nonce_str", nonce_str0); // 必须
  unifiedParams.put("spbill_create_ip", spbill_create_ip); // 必须
  unifiedParams.put("trade_type", trade_type); // 必须
  unifiedParams.put("openid", openid);
  unifiedParams.put("notify_url", PayConfigUtil.NOTIFY_URL);//异步通知url
  
  String sign0 = PayCommonUtil.createSign("UTF-8", unifiedParams,key);
  unifiedParams.put("sign", sign0); //签名
  
  String requestXML = PayCommonUtil.getRequestXml(unifiedParams);
  logger.info(requestXML);
  //统一下单接口
  String rXml = HttpUtil.postData(PayConfigUtil.UFDODER_URL, requestXML);
  
  //统一下单响应
  SortedMap<Object, Object> reParams = PayCommonUtil.xmlConvertToMap(rXml);
  logger.info(reParams);
  
  //验签
  if (PayCommonUtil.isTenpaySign("UTF-8", reParams, key)) {
  // 统一下单返回的参数
  String prepay_id = (String)reParams.get("prepay_id");//交易会话标识 2小时内有效
   
  String nonce_str1 = PayCommonUtil.getNonce_str();
   
  SortedMap<Object,Object> resParams = new TreeMap<Object,Object>();
  resParams.put("return_code", "SUCCESS"); // 必须
  resParams.put("return_msg", "OK");
  resParams.put("appid", PayConfigUtil.APP_ID); // 必须
  resParams.put("mch_id", PayConfigUtil.MCH_ID);
  resParams.put("nonce_str", nonce_str1); // 必须
  resParams.put("prepay_id", prepay_id); // 必须
  resParams.put("result_code", "SUCCESS"); // 必须
  resParams.put("err_code_des", "OK");
   
  String sign1 = PayCommonUtil.createSign("UTF-8", resParams,key);
  resParams.put("sign", sign1); //签名
   
  resXml = PayCommonUtil.getRequestXml(resParams);
  logger.info(resXml);
   
  }else{
  logger.info("签名验证错误");
  resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>"
   + "<return_msg><![CDATA[签名验证错误]]></return_msg>" + "</xml> ";
  }
  
 }else{
  logger.info("签名验证错误");
  resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>"
   + "<return_msg><![CDATA[签名验证错误]]></return_msg>" + "</xml> ";
 }
 
 //------------------------------
 //处理业务完毕
 //------------------------------
 BufferedOutputStream out = new BufferedOutputStream(
  response.getOutputStream());
 out.write(resXml.getBytes());
 out.flush();
 out.close();
  
 }
 
 /**
 * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse
 * response)
 */
 protected void doPost(HttpServletRequest request, HttpServletResponse response)
  throws ServletException, IOException {
 // TODO Auto-generated method stub
 doGet(request, response);
 }
 
}

至此,用户的微信单就会显示出要支付的金额及商品描述等,接下来就是等待客户完成支付。

2.3、异步通知url接口

当用户在微信上完成支付操作后,微信服务器就会异步通知这个接口,给我们发送最终的支付结果,以便我们核实订单进行发货等操作,注意这个接口和模式二的开发是一模一样的。大概流程如下:

1)、接收微信服务器发送过来的参数,对参数进行签名校验;

2)、取出参数result_code、订单号out_trade_no、订单金额total_fee及其他业务相关的参数,具体参数可参照官方文档支付结果通用通知的通知参数;

3)、处理业务,如校验订单号及订单金额、修改订单状态等;

4)、准备好相关参数(return_code和return_msg),应答微信服务器。

注意,如果微信收到商户的应答不是成功或超时,微信认为通知失败,微信会通过一定的策略定期重新发起通知,尽可能提高通知的成功率,但微信不保证通知最终能成功。 (通知频率为15/15/30/180/1800/1800/1800/1800/3600,单位:秒)

?
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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
package com.wqy;
 
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.SortedMap;
 
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
import org.apache.log4j.Logger;
 
import com.wqy.util.PayCommonUtil;
import com.wqy.util.PayConfigUtil;
 
/**
 * Servlet implementation class Re_notify
 */
@WebServlet("/Re_notify")
public class Re_notify extends HttpServlet {
 private static final long serialVersionUID = 1L;
 private static Logger logger = Logger.getLogger(Re_notify.class);
 
 /**
 * @see HttpServlet#HttpServlet()
 */
 public Re_notify() {
 super();
 // TODO Auto-generated constructor stub
 }
 
 /**
 * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse
 * response)
 */
 protected void doGet(HttpServletRequest request, HttpServletResponse response)
  throws ServletException, IOException {
 // TODO Auto-generated method stub
 // 读取参数
 InputStream inputStream;
 StringBuffer sb = new StringBuffer();
 inputStream = request.getInputStream();
 String s;
 BufferedReader in = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
 while ((s = in.readLine()) != null) {
  sb.append(s);
 }
 in.close();
 inputStream.close();
 
 SortedMap<Object, Object> packageParams = PayCommonUtil.xmlConvertToMap(sb.toString());
 logger.info(packageParams);
 
 // 账号信息
 String key = PayConfigUtil.API_KEY; // key
 
 String resXml = ""; // 反馈给微信服务器
 // 判断签名是否正确
 if (PayCommonUtil.isTenpaySign("UTF-8", packageParams, key)) {
  // ------------------------------
  // 处理业务开始
  // ------------------------------
  if ("SUCCESS".equals((String) packageParams.get("result_code"))) {
  // 这里是支付成功
  ////////// 执行自己的业务逻辑////////////////
  String mch_id = (String) packageParams.get("mch_id");
  String openid = (String) packageParams.get("openid");
  String is_subscribe = (String) packageParams.get("is_subscribe");
  String out_trade_no = (String) packageParams.get("out_trade_no");
 
  String total_fee = (String) packageParams.get("total_fee");
 
  logger.info("mch_id:" + mch_id);
  logger.info("openid:" + openid);
  logger.info("is_subscribe:" + is_subscribe);
  logger.info("out_trade_no:" + out_trade_no);
  logger.info("total_fee:" + total_fee);
 
  ////////// 执行自己的业务逻辑////////////////
 
  logger.info("支付成功");
  // 通知微信.异步确认成功.必写.不然会一直通知后台.八次之后就认为交易失败了.
  resXml = "<xml>" + "<return_code><![CDATA[SUCCESS]]></return_code>"
   + "<return_msg><![CDATA[OK]]></return_msg>" + "</xml> ";
 
  } else {
  logger.info("支付失败,错误信息:" + packageParams.get("err_code"));
  resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>"
   + "<return_msg><![CDATA[报文为空]]></return_msg>" + "</xml> ";
  }
 
 } else {
  logger.info("签名验证错误");
  resXml = "<xml>" + "<return_code><![CDATA[FAIL]]></return_code>"
   + "<return_msg><![CDATA[签名验证错误]]></return_msg>" + "</xml> ";
 }
 
 // ------------------------------
 // 处理业务完毕
 // ------------------------------
 BufferedOutputStream out = new BufferedOutputStream(response.getOutputStream());
 out.write(resXml.getBytes());
 out.flush();
 out.close();
 }
 
 /**
 * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse
 * response)
 */
 protected void doPost(HttpServletRequest request, HttpServletResponse response)
  throws ServletException, IOException {
 // TODO Auto-generated method stub
 doGet(request, response);
 }
 
}

三、测试结果

3.1、生成的支付二维码链接

java微信扫码支付模式一线下支付功能实现

3.2、支付回调url接口接收到的参数

java微信扫码支付模式一线下支付功能实现

3.3、发起统一下单请求参数

java微信扫码支付模式一线下支付功能实现

3.4、统一下单返回参数

java微信扫码支付模式一线下支付功能实现

3.5、支付回调url接口最终的响应参数

java微信扫码支付模式一线下支付功能实现

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。

延伸 · 阅读

精彩推荐