springboot+微信小程序实现微信支付统一下单
Posted TiAmo_K
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了springboot+微信小程序实现微信支付统一下单相关的知识，希望对你有一定的参考价值。
说明：
1）微信支付必须有营业执照才可以申请
2）微信支付官方api是全套的，我这是抽取其中的统一下单api，做了一个简单的封装
首先看看微信支付
商户系统和微信支付系统主要交互：
1、小程序内调用登录接口，获取到用户的openid,api参见公共api【小程序登录API】
2、商户server调用支付统一下单，api参见公共api【统一下单API】
3、商户server调用再次签名，api参见公共api【再次签名】
4、商户server接收支付通知，api参见公共api【支付结果通知API】
5、商户server查询支付结果，api参见公共api【查询订单API】
注意上面有两次签名
1.配置文件类
1 2 3 public final class WxConfig { 4 public final static String appId="wxe86f60xxxxxxx"; // 小程序appid 5 public final static String mchId="15365xxxxx";// 商户ID 6 public final static String key="Ucsdfl782167bjslNCJD129863skkqoo"; // 跟微信支付约定的密钥 7 public final static String notifyPath="/admin/wxnotify"; // 回调地址 8 public final static String payUrl="https://api.mch.weixin.qq.com/pay/unifiedorder"; // 统一下单地址 9 public final static String tradeType="JSAPI"; // 支付方式 10 11 }
2.微信工具类，统一下单，签名，生成随机字符串。。
4 import lombok.extern.slf4j.Slf4j; 5 import org.apache.http.HttpEntity; 6 import org.apache.http.HttpResponse; 7 import org.apache.http.client.HttpClient; 8 import org.apache.http.client.config.RequestConfig; 9 import org.apache.http.client.methods.HttpPost; 10 import org.apache.http.config.RegistryBuilder; 11 import org.apache.http.conn.socket.ConnectionSocketFactory; 12 import org.apache.http.conn.socket.PlainConnectionSocketFactory; 13 import org.apache.http.conn.ssl.SSLConnectionSocketFactory; 14 import org.apache.http.entity.StringEntity; 15 import org.apache.http.impl.client.HttpClientBuilder; 16 import org.apache.http.impl.conn.BasicHttpClientConnectionManager; 17 import org.apache.http.util.EntityUtils; 18 import org.slf4j.Logger; 19 import org.slf4j.LoggerFactory; 20 import org.w3c.dom.Document; 21 import org.w3c.dom.Element; 22 import org.w3c.dom.Node; 23 import org.w3c.dom.NodeList; 24 25 import javax.crypto.Mac; 26 import javax.crypto.spec.SecretKeySpec; 27 import javax.xml.XMLConstants; 28 import javax.xml.parsers.DocumentBuilder; 29 import javax.xml.parsers.DocumentBuilderFactory; 30 import javax.xml.parsers.ParserConfigurationException; 31 import javax.xml.transform.OutputKeys; 32 import javax.xml.transform.Transformer; 33 import javax.xml.transform.TransformerFactory; 34 import javax.xml.transform.dom.DOMSource; 35 import javax.xml.transform.stream.StreamResult; 36 import java.io.ByteArrayInputStream; 37 import java.io.InputStream; 38 import java.io.StringWriter; 39 import java.security.MessageDigest; 40 import java.security.SecureRandom; 41 import java.time.Instant; 42 import java.util.*; 43 44 @Slf4j 45 public class WxUtil { 46 private static final String WXPAYSDK_VERSION = "WXPaySDK/3.0.9"; 47 private static final String USER_AGENT = WXPAYSDK_VERSION + 48 " (" + System.getProperty("os.arch") + " " + System.getProperty("os.name") + " " + System.getProperty("os.version") + 49 ") Java/" + System.getProperty("java.version") + " HttpClient/" + HttpClient.class.getPackage().getImplementationVersion(); 50 51 private static final String SYMBOLS = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"; 52 private static final Random RANDOM = new SecureRandom(); 53 // 统一下单接口 54 public static Map<String, String> unifiedOrder(Map<String, String> reqData) throws Exception { 55 // map格式转xml 方法在下面 56 String reqBody = mapToXml(reqData); 57 // 发起一次统一下单的请求 方法内容在下面 58 String responseBody = requestOnce(WxConfig.payUrl, reqBody); 59 // 将得到的结果由xml格式转为map格式 方法内容在下面 60 Map<String,String> response= processResponseXml(responseBody); 61 // 得到prepayId 62 String prepayId = response.get("prepay_id"); 63 // 组装参数package_str 为什么这样？ 因为二次签名微信规定这样的格式 64 String package_str = "prepay_id="+prepayId; 65 Map<String,String> payParameters = new HashMap<>(); 66 long epochSecond = Instant.now().getEpochSecond(); 67 payParameters.put("appId",WxConfig.appId); 68 payParameters.put("nonceStr", WxUtil.generateNonceStr()); 69 payParameters.put("package", package_str); 70 payParameters.put("signType", SignType.MD5.name()); 71 payParameters.put("timeStamp", String.valueOf(epochSecond)); 72 // 二次签名 73 payParameters.put("paySign", WxUtil.generateSignature(payParameters, WxConfig.key, SignType.MD5)); 74 // 返回签名后的map 75 return payParameters; 76 } 77 78 79 /** 80 * 生成签名. 注意，若含有sign_type字段，必须和signType参数保持一致。 81 * 82 * @param data 待签名数据 83 * @param key API密钥 84 * @param signType 签名方式 85 * @return 签名 86 */ 87 public static String generateSignature(final Map<String, String> data, String key, SignType signType) throws Exception { 88 Set<String> keySet = data.keySet(); 89 String[] keyArray = keySet.toArray(new String[keySet.size()]); 90 Arrays.sort(keyArray); 91 StringBuilder sb = new StringBuilder(); 92 for (String k : keyArray) { 93 if (k.equals("sign")) { 94 continue; 95 } 96 if (data.get(k).trim().length() > 0) // 参数值为空，则不参与签名 97 sb.append(k).append("=").append(data.get(k).trim()).append("&"); 98 } 99 sb.append("key=").append(key); 100 if (SignType.MD5.equals(signType)) { 101 return MD5(sb.toString()).toUpperCase(); 102 } 103 else if (SignType.HMACSHA256.equals(signType)) { 104 return HMACSHA256(sb.toString(), key); 105 } 106 else { 107 throw new Exception(String.format("Invalid sign_type: %s", signType)); 108 } 109 } 110 111 /** 112 * 生成 MD5 113 * 114 * @param data 待处理数据 115 * @return MD5结果 116 */ 117 private static String MD5(String data) throws Exception { 118 MessageDigest md = MessageDigest.getInstance("MD5"); 119 byte[] array = md.digest(data.getBytes("UTF-8")); 120 StringBuilder sb = new StringBuilder(); 121 for (byte item : array) { 122 sb.append(Integer.toHexString((item & 0xFF) | 0x100).substring(1, 3)); 123 } 124 return sb.toString().toUpperCase(); 125 } 126 127 public static String generateNonceStr() { 128 char[] nonceChars = new char[32]; 129 for (int index = 0; index < nonceChars.length; ++index) { 130 nonceChars[index] = SYMBOLS.charAt(RANDOM.nextInt(SYMBOLS.length())); 131 } 132 return new String(nonceChars); 133 } 134 135 public static String mapToXml(Map<String, String> data) throws Exception { 136 Document document = newDocument(); 137 Element root = document.createElement("xml"); 138 document.appendChild(root); 139 for (String key: data.keySet()) { 140 String value = data.get(key); 141 if (value == null) { 142 value = ""; 143 } 144 value = value.trim(); 145 Element filed = document.createElement(key); 146 filed.appendChild(document.createTextNode(value)); 147 root.appendChild(filed); 148 } 149 TransformerFactory tf = TransformerFactory.newInstance(); 150 Transformer transformer = tf.newTransformer(); 151 DOMSource source = new DOMSource(document); 152 transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8"); 153 transformer.setOutputProperty(OutputKeys.INDENT, "yes"); 154 StringWriter writer = new StringWriter(); 155 StreamResult result = new StreamResult(writer); 156 transformer.transform(source, result); 157 String output = writer.getBuffer().toString(); //.replaceAll("\\n|\\r", ""); 158 try { 159 writer.close(); 160 } 161 catch (Exception ex) { 162 } 163 return output; 164 } 165 166 // 判断签名是否有效 167 private static Map<String, String> processResponseXml(String xmlStr) throws Exception { 168 String RETURN_CODE = "return_code"; 169 String return_code; 170 Map<String, String> respData = xmlToMap(xmlStr); 171 if (respData.containsKey(RETURN_CODE)) { 172 return_code = respData.get(RETURN_CODE); 173 } 174 175 else { 176 throw new Exception(String.format("No `return_code` in XML: %s", xmlStr)); 177 } 178 179 if (return_code.equals("FAIL")) { 180 return respData; 181 } 182 else if (return_code.equals("SUCCESS")) { 183 if (isResponseSignatureValid(respData)) { 184 return respData; 185 } 186 else { 187 throw new Exception(String.format("Invalid sign value in XML: %s", xmlStr)); 188 } 189 } 190 else { 191 throw new Exception(String.format("return_code value %s is invalid in XML: %s", return_code, xmlStr)); 192 } 193 } 194 // 判断签名 195 private static boolean isResponseSignatureValid(Map<String, String> data) throws Exception { 196 String signKeyword = "sign"; 197 if (!data.containsKey(signKeyword) ) { 198 return false; 199 } 200 String sign = data.get(signKeyword); 201 return generateSignature(data, WxConfig.key, SignType.MD5).equals(sign); 202 } 203 204 // 发起一次请求 205 private static String requestOnce(String payUrl, String data) throws Exception { 206 BasicHttpClientConnectionManager connManager; 207 connManager = new BasicHttpClientConnectionManager( 208 RegistryBuilder.<ConnectionSocketFactory>create() 209 .register("http", PlainConnectionSocketFactory.getSocketFactory()) 210 .register("https", SSLConnectionSocketFactory.getSocketFactory()) 211 .build(), 212 null, 213 null, 214 null 215 ); 216 217 HttpClient httpClient = HttpClientBuilder.create() 218 .setConnectionManager(connManager) 219 .build(); 220 HttpPost httpPost = new HttpPost(payUrl); 221 222 RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(8000).setConnectTimeout(6000).build(); 223 httpPost.setConfig(requestConfig); 224 225 StringEntity postEntity = new StringEntity(data, "UTF-8"); 226 httpPost.addHeader("Content-Type", "text/xml"); 227 httpPost.addHeader("User-Agent", USER_AGENT + " " + WxConfig.mchId); 228 httpPost.setEntity(postEntity); 229 230 HttpResponse httpResponse = httpClient.execute(httpPost); 231 HttpEntity httpEntity = httpResponse.getEntity(); 232 return EntityUtils.toString(httpEntity, "UTF-8"); 233 234 } 235 236 237 238 private static String HMACSHA256(String data, String key) throws Exception { 239 Mac sha256_HMAC = Mac.getInstance("HmacSHA256"); 240 SecretKeySpec secret_key = new SecretKeySpec(key.getBytes("UTF-8"), "HmacSHA256"); 241 sha256_HMAC.init(secret_key); 242 byte[] array = sha256_HMAC.doFinal(data.getBytes("UTF-8")); 243 StringBuilder sb = new StringBuilder(); 244 for (byte item : array) { 245 sb.append(Integer.toHexString((item & 0xFF) | 0x100).substring(1, 3)); 246 } 247 return sb.toString().toUpperCase(); 248 } 249 250 private static DocumentBuilder newDocumentBuilder() throws ParserConfigurationException { 251 DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance(); 252 documentBuilderFactory.setFeature("http://apache.org/xml/features/disallow-doctype-decl", true); 253 documentBuilderFactory.setFeature("http://xml.org/sax/features/external-general-entities", false); 254 documentBuilderFactory.setFeature("http://xml.org/sax/features/external-parameter-entities", false); 255 documentBuilderFactory.setFeature("http://apache.org/xml/features/nonvalidating/load-external-dtd", false); 256 documentBuilderFactory.setFeature(XMLConstants.FEATURE_SECURE_PROCESSING, true); 257 documentBuilderFactory.setXIncludeAware(false); 258 documentBuilderFactory.setExpandEntityReferences(false); 259 260 return documentBuilderFactory.newDocumentBuilder(); 261 } 262 263 private static Document newDocument() throws ParserConfigurationException { 264 return newDocumentBuilder().newDocument(); 265 } 266 267 268 public static Map<String, String> xmlToMap(String strXML) throws Exception { 269 try { 270 Map<String, String> data = new HashMap<String, String>(); 271 DocumentBuilder documentBuilder = newDocumentBuilder(); 272 InputStream stream = new ByteArrayInputStream(strXML.getBytes("UTF-8")); 273 org.w3c.dom.Document doc = documentBuilder.parse(stream); 274 doc.getDocumentElement().normalize(); 275 NodeList nodeList = doc.getDocumentElement().getChildNodes(); 276 for (int idx = 0; idx < nodeList.getLength(); ++idx) { 277 Node node = nodeList.item(idx); 278 if (node.getNodeType() == Node.ELEMENT_NODE) { 279 org.w3c.dom.Element element = (org.w3c.dom.Element) node; 280 data.put(element.getNodeName(), element.getTextContent()); 281 } 282 } 283 try { 284 stream.close(); 285 } catch (Exception ex) { 286 // do nothing 287 } 288 return data; 289 } catch (Exception ex) { 290 getLogger().warn("Invalid XML, can not convert to map. Error message: {}. XML content: {}", ex.getMessage(), strXML); 291 throw ex; 292 } 293 294 } 295 /** 296 * 日志 297 * @return 298 */ 299 private static Logger getLogger() { 300 Logger logger = LoggerFactory.getLogger("wxpay java sdk"); 301 return logger; 302 } 303 304 305 306 /** 307 * 判断签名是否正确 308 * 309 * @param xmlStr XML格式数据 310 * @param key API密钥 311 * @return 签名是否正确 312 * @throws Exception 313 */ 314 public static boolean isSignatureValid(String xmlStr, String key) throws Exception { 315 Map<String, String> data = xmlToMap(xmlStr); 316 if (!data.containsKey("sign") ) { 317 return false; 318 } 319 String sign = data.get("sign"); 320 return generateSignature(data, key,SignType.MD5).equals(sign); 321 } 322 323 324 325 326 327 }
3.小程序发起请求 组装发起统一下单所需要的参数
1 @PostMapping("/recharge/wx") 2 public Map recharge(HttpServletRequest request, @RequestParam(value = "vipType",required = true) VipType vipType) throws Exception { 3 // 本案例是充值会员 用的时候根据实际情况改成自己的需求 4 Integer loginDealerId = MySecurityUtil.getLoginDealerId(); 5 // 获取ip地址 发起统一下单必要的参数 6 String ipAddress = HttpUtil.getIpAddress(request); 7 // 生成预付订单 存入数据库 回调成功在对订单状态进行修改 8 PrepaidOrder prepaidOrder = payService.recharge(loginDealerId, vipType, ipAddress); 9 // 组装统一下单需要的数据map 10 Map<String, String> stringStringMap = prepaidOrder.toWxPayParameters(); 11 // 调起统一支付 12 Map<String, String> payParameters =WxUtil.unifiedOrder(stringStringMap); 13 return payParameters; 14 }
生成预付订单代码（根据实际需求生成，此处只是我这的需求，仅供参考）
27 @Service("WXPayService") 28 @Slf4j 29 public class PayServiceImpl implements PayService { 30 33 @Resource 34 PrepaidOrderDao prepaidOrderDao; 35 36 @Resource 37 VipDao vipDao; 38 39 @Resource 40 DealerDao dealerDao; 41 42 @Resource 43 ApplicationContext applicationContext; 44 @Override 45 @Transactional 46 public PrepaidOrder recharge(Integer dealerId, VipType vipType, String userIp) { 47 Dealer dealer = dealerDao.getDealerById(dealerId); 48 SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss"); 49 String newDate = sdf.format(new Date()); 50 Random random = new Random(); 51 String orderNumber = newDate + random.nextInt(1000000); 52 BigDecimal amount = null; 53 // 如果不是生产环境 付一分钱 54 if (!applicationContext.getEnvironment().getActiveProfiles()[0].contains("prod")){ 55 amount = BigDecimal.valueOf(0.01); 56 }else if (vipType.equals(VipType.YEAR)){ 微信小程序支付及退款流程详解