微信小程序支付之V2支付

一、引入maven

<dependency><groupId>com.github.binarywang</groupId><artifactId>weixin-java-pay</artifactId><version>3.3.4.B</version><exclusions><exclusion><artifactId>qrcode-utils</artifactId><groupId>com.github.binarywang</groupId></exclusion></exclusions>
</dependency><!--微信支付依赖-->
<dependency><groupId>org.jdom</groupId><artifactId>jdom</artifactId><version>1.1</version><scope>compile</scope>
</dependency>

二、调用

package com.dcqq.wechat;import com.dcqq.common.core.controller.BaseController;
import com.dcqq.common.core.domain.R;
import com.dcqq.common.core.domain.entity.SysUser;
import com.dcqq.common.utils.ip.IpUtils;
import com.dcqq.common.utils.wx.HttpUtil;
import com.dcqq.common.utils.wx.PayCommonUtil;
import com.dcqq.common.utils.wx.WxPayConfig;
import com.dcqq.common.utils.wx.XMLUtil;
import com.dcqq.system.domain.TShopOrder;
import com.dcqq.system.domain.vo.PayVo;
import com.dcqq.system.service.ISysUserService;
import com.dcqq.system.service.ITShopOrderService;
import com.github.binarywang.wxpay.bean.notify.WxPayNotifyResponse;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.InputStreamReader;
import java.math.BigDecimal;
import java.util.*;/*** 微信支付管理Controller** @author dcqq* @date 2024-01-04*/
@RestController
@Api(tags = "微信支付管理")
@RequestMapping("/wechat/pay")
public class ApiPayController extends BaseController {@Autowiredprivate ITShopOrderService shopOrderService;@Autowiredprivate ISysUserService userService;/*** 调用统一下单接口,并组装生成支付所需参数对象.*/@PostMapping("/tradeOrder")@ApiOperation("支付接口")public R tradeOrder(@RequestBody PayVo payVo,HttpServletRequest request) {TShopOrder order = shopOrderService.getByOrderNo(payVo.getOrderNo());if (payVo.getPayWay()==2) {//小程序支付Map<String, Object> map = wxPay(order, request);return R.ok(map);}return null;}/*** @Description: 小程序支付* @param request*/private Map<String, Object> wxPay(TShopOrder order, HttpServletRequest request){SysUser user = userService.selectUserById(order.getSysUserId());String openid=user.getOpenId();Integer total=order.getOrderPrice().multiply(new BigDecimal("100")).intValue();try {request.setCharacterEncoding("UTF-8");//订单标题String title = "小程序微信支付";//时间戳String times = System.currentTimeMillis() + "";SortedMap<String, Object> packageParams = new TreeMap<String, Object>();packageParams.put("appid", WxPayConfig.appid);packageParams.put("mch_id", WxPayConfig.mch_id);packageParams.put("nonce_str", times);//时间戳packageParams.put("body", title);//支付主体packageParams.put("out_trade_no", order.getOrderNo());//订单编号packageParams.put("total_fee", total);//元转成分packageParams.put("attach","");packageParams.put("spbill_create_ip", IpUtils.getIpAddr(request));//这里之前加了ip,但是总是获取sign失败,原因不明,之后就注释掉了packageParams.put("notify_url", WxPayConfig.notify_url);//支付回调接口,用于支付成功后处理业务逻辑,小程序端支付success不能保证100%回调成功,建议采用后端异步回调处理方式,回调方法在最后packageParams.put("trade_type", WxPayConfig.tradeType);//这个api有,固定的packageParams.put("openid", openid);//openid//获取signString sign = PayCommonUtil.createSign("UTF-8", packageParams, WxPayConfig.apiKey);//最后这个是自己设置的32位密钥packageParams.put("sign", sign);//转成XMLString requestXML = PayCommonUtil.getRequestXml(packageParams);System.out.println(requestXML);//得到含有prepay_id的XMLString resXml = HttpUtil.postData(WxPayConfig.pay_url, requestXML);System.out.println(resXml);//解析XML存入MapMap map = XMLUtil.doXMLParse(resXml);System.out.println(map);// String return_code = (String) map.get("return_code");//得到prepay_idString prepay_id = (String) map.get("prepay_id");SortedMap<String, Object> packageP = new TreeMap<String, Object>();//以下map的key必须和微信参数一致,请勿修改packageP.put("appId", WxPayConfig.appid);//!!!注意,这里是appId,上面是appid,真怀疑写这个东西的人。。。packageP.put("nonceStr", times);//时间戳packageP.put("package", "prepay_id=" + prepay_id);//必须把package写成 "prepay_id="+prepay_id这种形式packageP.put("signType", WxPayConfig.signType);//paySign加密packageP.put("timeStamp", (System.currentTimeMillis() / 1000) + "");//得到paySignString paySign = PayCommonUtil.createSign("UTF-8", packageP, WxPayConfig.apiKey);packageP.put("paySign", paySign);return packageP;}catch(Exception e){e.printStackTrace();}return null;}/*** @Description:微信支付回调* @return* @throws Exception*/@RequestMapping(value="/wxNotify")public String wxNotify(HttpServletRequest request) {String result = "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>";try {DataInputStream in = new DataInputStream(request.getInputStream());byte[] bytes = new byte[request.getContentLength()];in.readFully(bytes);in.close();String xml = new String(bytes);Map<String, String> map = XMLUtil.doXMLParse(xml);if (map != null && !map.isEmpty()) {System.out.println(map);System.out.println(map.get("attach"));if (map.get("return_code").equals("SUCCESS")) {//String[] resultBody = map.get("attach").split(",");String orderSn=map.get("out_trade_no");/**更新订单信息*/shopOrderService.payCallback(orderSn);return WxPayNotifyResponse.success("处理成功!");}}return result.replace("SUCCESS", "FAIL").replace("OK", "返回数据错误");} catch (Exception e) {e.printStackTrace();return result.replace("SUCCESS", "FAIL").replace("OK", "本地服务器内部错误");}}
}

三、引入工具类,在公共文件下创建wx文件夹,把下面的代码全部放里面

package com.dcqq.common.utils.wx;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.URL;
import java.net.URLConnection;public class HttpUtil {//private static final Log logger = Logs.get();private final static int CONNECT_TIMEOUT = 5000; // in millisecondsprivate final static String DEFAULT_ENCODING = "UTF-8";public static String postData(String urlStr, String data){return postData(urlStr, data, null);}public static String postData(String urlStr, String data, String contentType){BufferedReader reader = null;try {URL url = new URL(urlStr);URLConnection conn = url.openConnection();conn.setDoOutput(true);conn.setConnectTimeout(CONNECT_TIMEOUT);conn.setReadTimeout(CONNECT_TIMEOUT);if(contentType != null)conn.setRequestProperty("content-type", contentType);OutputStreamWriter writer = new OutputStreamWriter(conn.getOutputStream(), DEFAULT_ENCODING);if(data == null)data = "";writer.write(data);writer.flush();writer.close();reader = new BufferedReader(new InputStreamReader(conn.getInputStream(), DEFAULT_ENCODING));StringBuilder sb = new StringBuilder();String line = null;while ((line = reader.readLine()) != null) {sb.append(line);sb.append("\r\n");}return sb.toString();} catch (IOException e) {//logger.error("Error connecting to " + urlStr + ": " + e.getMessage());} finally {try {if (reader != null)reader.close();} catch (IOException e) {}}return null;}
}
package com.dcqq.common.utils.wx;
import org.apache.commons.lang3.StringUtils;import javax.servlet.http.HttpServletRequest;/*** @Description:* @Date: 2018/7/17* @Author: wcf*/
public class IpUtils {/*** IpUtils工具类方法* 获取真实的ip地址* @param request* @return*/public static String getIpAddr(HttpServletRequest request) {String ip = request.getHeader("X-Forwarded-For");if(StringUtils.isNotEmpty(ip) && !"unKnown".equalsIgnoreCase(ip)){//多次反向代理后会有多个ip值,第一个ip才是真实ipint index = ip.indexOf(",");if(index != -1){return ip.substring(0,index);}else{return ip;}}ip = request.getHeader("X-Real-IP");if(StringUtils.isNotEmpty(ip) && !"unKnown".equalsIgnoreCase(ip)){return ip;}return request.getRemoteAddr();}
}
package com.dcqq.common.utils.wx;import java.security.MessageDigest;public class MD5 {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()));elseresultString = 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" };}
package com.dcqq.common.utils.wx;import java.text.SimpleDateFormat;
import java.util.*;public class PayCommonUtil {/*** 是否签名正确,规则是:按参数名称a-z排序,遇到空值的参数不参加签名。* @return boolean*/public static boolean isTenpaySign(String characterEncoding, SortedMap<Object, Object> packageParams, String API_KEY) {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(!"sign".equals(k) && null != v && !"".equals(v)) {sb.append(k + "=" + v + "&");}}sb.append("key=" + API_KEY);//算出摘要String mysign = MD5.MD5Encode(sb.toString(), characterEncoding).toLowerCase();String tenpaySign = ((String)packageParams.get("sign")).toLowerCase();//System.out.println(tenpaySign + "    " + mysign);return tenpaySign.equals(mysign);}/*** @author* @Description:sign签名  https://pay.weixin.qq.com/wiki/doc/api/wxa/wxa_api.php?chapter=7_7&index=3* @param characterEncoding*            编码格式* @param parameters*            请求参数* @return*/public static String createSign(String characterEncoding, SortedMap<String, Object> packageParams, String API_KEY) {StringBuffer sb = new StringBuffer();Set es = packageParams.entrySet();Iterator it = es.iterator();while (it.hasNext()) {Map.Entry entry = (Map.Entry) it.next();String k = entry.getKey().toString();String v = entry.getValue().toString();if (null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) {sb.append(k + "=" + v + "&");}}sb.append("key=" + API_KEY);System.out.println(sb.toString());String sign = MD5.MD5Encode(sb.toString(), characterEncoding).toUpperCase();return sign;}/*** @author* @Description:将请求参数转换为xml格式的string* @param parameters*            请求参数* @return*/public static String getRequestXml(SortedMap<String, Object> parameters) {StringBuffer sb = new StringBuffer();sb.append("<xml>");Set es = parameters.entrySet();Iterator it = es.iterator();while (it.hasNext()) {Map.Entry entry = (Map.Entry) it.next();String k = entry.getKey().toString();String v = entry.getValue().toString();if ("attach".equalsIgnoreCase(k) || "body".equalsIgnoreCase(k) || "sign".equalsIgnoreCase(k)) {sb.append("<" + k + ">" + "<![CDATA[" + v + "]]></" + k + ">");} else {sb.append("<" + k + ">" + v + "</" + k + ">");}}sb.append("</xml>");return sb.toString();}/*** 取出一个指定长度大小的随机正整数.** @param length*            int 设定所取出随机数的长度。length小于11* @return int 返回生成的随机数。*/public static int buildRandom(int length) {int num = 1;double random = Math.random();if (random < 0.1) {random = random + 0.1;}for (int i = 0; i < length; i++) {num = num * 10;}return (int) ((random * num));}/*** 获取当前时间 yyyyMMddHHmmss** @return String*/public static String getCurrTime() {Date now = new Date();SimpleDateFormat outFormat = new SimpleDateFormat("yyyyMMddHHmmss");String s = outFormat.format(now);return s;}
}
package com.dcqq.common.utils.wx;/*** @Description:* @Date: 2018/7/17* @Author: wcf*/
public class WxPayConfig {//小程序appidpublic static final String appid = "wxaf1111111111111111111";//微信支付的商户idpublic static final String mch_id = "55555555";//微信支付的商户密钥public static final String key = "A5223241994ASDr222222222";//支付成功后的服务器回调urlpublic static final String notify_url = "http://com.ss/wechat/pay/wxNotify";//签名方式public static final String signType = "MD5";//交易类型public static final String tradeType = "JSAPI";//api-keypublic static final String apiKey = "A5223241994ASDr222222222";//微信统一下单接口地址 https://api.mch.weixin.qq.com/pay/unifiedorderpublic static final String pay_url = "https://api.mch.weixin.qq.com/pay/unifiedorder";
}
package com.dcqq.common.utils.wx;import org.jdom.Document;
import org.jdom.Element;
import org.jdom.JDOMException;
import org.jdom.input.SAXBuilder;import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;public class XMLUtil {public static Map doXMLParse(String strxml) throws JDOMException, IOException {strxml = strxml.replaceFirst("encoding=\".*\"", "encoding=\"UTF-8\"");if(null == strxml || "".equals(strxml)) {return null;}Map m = new HashMap();InputStream in = new ByteArrayInputStream(strxml.getBytes("UTF-8"));SAXBuilder builder = new SAXBuilder();Document doc = builder.build(in);Element root = doc.getRootElement();List list = root.getChildren();Iterator it = list.iterator();while(it.hasNext()) {Element e = (Element) it.next();String k = e.getName();String v = "";List children = e.getChildren();if(children.isEmpty()) {v = e.getTextNormalize();} else {v = XMLUtil.getChildrenText(children);}m.put(k, v);}//关闭流in.close();return m;}/*** 获取子结点的xml* @param children* @return String*/public static String getChildrenText(List children) {StringBuffer sb = new StringBuffer();if(!children.isEmpty()) {Iterator it = children.iterator();while(it.hasNext()) {Element e = (Element) it.next();String name = e.getName();String value = e.getTextNormalize();List list = e.getChildren();sb.append("<" + name + ">");if(!list.isEmpty()) {sb.append(XMLUtil.getChildrenText(list));}sb.append(value);sb.append("</" + name + ">");}}return sb.toString();}
}