【程序源代码】微信商户收款功能完整技术实现

参数名称

获取位置

用途说明

小程序AppID

微信公众平台-小程序-开发管理-开发设置

小程序唯一标识，支付接口必填

商户号（mch_id）

微信支付商户平台-账户信息

微信支付商户唯一标识

支付V3密钥（api_v3_key）

商户平台-账户中心-API安全-设置V3密钥

支付签名、数据加密核心密钥，严格保密

商户证书序列号

商户平台-API安全-证书管理

V3接口签名校验

商户API证书（pem）

商户平台-API安全-证书下载

退款、敏感接口调用，基础收款暂可备用

xml                  org.springframework.bootspring-boot-starter-webcom.github.wechatpay-apiv3wechatpay-apache-httpclient0.4.6com.alibabafastjson22.0.32org.springframework.bootspring-boot-configuration-processortrue

yaml                  server:                  port: 8080                  servlet:                  context-path: /api                  # 微信支付V3配置                  wechat:                  pay:                  app-id: 小程序AppID                  mch-id: 微信支付商户号                  api-v3-key: 微信支付V3密钥                  serial-no: 商户证书序列号                  private-key-path: classpath:cert/apiclient_key.pem                  notify-url: https://你的公网HTTPS域名/api/pay/notify# 支付结果异步通知地址

java                  import com.wechat.pay.contrib.apache.httpclient.WechatPayHttpClientBuilder;                  import com.wechat.pay.contrib.apache.httpclient.auth.PrivateKeySigner;                  import com.wechat.pay.contrib.apache.httpclient.auth.Verifier;                  import com.wechat.pay.contrib.apache.httpclient.auth.WechatPay2Credentials;                  import com.wechat.pay.contrib.apache.httpclient.auth.WechatPay2Validator;                  import com.wechat.pay.contrib.apache.httpclient.util.PemUtil;                  import org.apache.http.impl.client.CloseableHttpClient;                  import org.springframework.beans.factory.annotation.Value;                  import org.springframework.context.annotation.Bean;                  import org.springframework.context.annotation.Configuration;                  import java.io.FileInputStream;                  import java.io.InputStream;                  import java.security.PrivateKey;                  @Configuration                  public class WechatPayConfig {                  @Value(“${wechat.pay.app-id}”)                  private String appId;                  @Value(“${wechat.pay.mch-id}”)                  private String mchId;                  @Value(“${wechat.pay.api-v3-key}”)                  private String apiV3Key;                  @Value(“${wechat.pay.serial-no}”)                  private String serialNo;                  @Value(“${wechat.pay.private-key-path}”)                  private String privateKeyPath;                  /**                  * 加载商户私钥                  */                  @Bean                  public PrivateKey getPrivateKey() throws Exception {                  InputStream inputStream = this.getClass().getResourceAsStream(privateKeyPath.replace(“classpath:”, “”));                  return PemUtil.loadPrivateKey(inputStream);                  }                  /**                  * 初始化微信支付V3 HTTP客户端                  */                  @Bean                  public CloseableHttpClient wechatPayHttpClient(PrivateKey privateKey) {                  WechatPayHttpClientBuilder builder = WechatPayHttpClientBuilder.create()                  .withCredentials(new WechatPay2Credentials(mchId, new PrivateKeySigner(serialNo, privateKey)))                  .withValidator(new WechatPay2Validator((Verifier) null));                  return builder.build();                  }                  // getter方法省略，直接注入对应参数即可                  }

java                  import com.alibaba.fastjson2.JSONObject;                  import org.apache.http.client.methods.CloseableHttpResponse;                  import org.apache.http.client.methods.HttpPost;                  import org.apache.http.entity.StringEntity;                  import org.apache.http.impl.client.CloseableHttpClient;                  import org.apache.http.util.EntityUtils;                  import org.springframework.beans.factory.annotation.Autowired;                  import org.springframework.beans.factory.annotation.Value;                  import org.springframework.web.bind.annotation.PostMapping;                  import org.springframework.web.bind.annotation.RequestBody;                  import org.springframework.web.bind.annotation.RequestMapping;                  import org.springframework.web.bind.annotation.RestController;                  import java.nio.charset.StandardCharsets;                  import java.util.HashMap;                  import java.util.Map;                  import java.util.UUID;                  @RestController                  @RequestMapping(“/pay”)                  public class WechatPayController {                  @Autowired                  private CloseableHttpClient wechatPayHttpClient;                  @Value(“${wechat.pay.app-id}”)                  private String appId;                  @Value(“${wechat.pay.mch-id}”)                  private String mchId;                  @Value(“${wechat.pay.notify-url}”)                  private String notifyUrl;                  @Value(“${wechat.pay.api-v3-key}”)                  private String apiV3Key;                  /**                  * 小程序支付统一下单接口                  * @param params 前端传入参数：openid, totalFee(金额分), body(商品描述)                  */                  @PostMapping(“/createOrder”)                  public MapcreateOrder(@RequestBody JSONObject params) {          MapresultMap = new HashMap<>();           try {           // 1. 获取前端参数并校验           String openid = params.getString(“openid”);           Integer totalFee = params.getInteger(“totalFee”);           String body = params.getString(“body”);           if (openid == null || totalFee == null || totalFee < 1 || body == null) {           resultMap.put(“code”, 400);           resultMap.put(“msg”, “参数缺失或金额不合法”);           return resultMap;           }           // 生成唯一商户订单号           String outTradeNo = “ORDER” + System.currentTimeMillis() + UUID.randomUUID().toString().replace(“-“, “”).substring(0, 8);           // 2. 此处添加本地订单入库逻辑（存入MySQL，状态默认为0：未支付）           // orderService.saveOrder(outTradeNo, totalFee, openid, body);           // 3. 组装微信统一下单请求参数           JSONObject requestParam = new JSONObject();           requestParam.put(“appid”, appId);           requestParam.put(“mchid”, mchId);           requestParam.put(“description”, body);           requestParam.put(“out_trade_no”, outTradeNo);           requestParam.put(“notify_url”, notifyUrl);           // 金额参数           JSONObject amountObj = new JSONObject();           amountObj.put(“total”, totalFee);           amountObj.put(“currency”, “CNY”);           requestParam.put(“amount”, amountObj);           // 用户openid           JSONObject payerObj = new JSONObject();           payerObj.put(“openid”, openid);           requestParam.put(“payer”, payerObj);           // 4. 调用微信支付V3统一下单接口           HttpPost httpPost = new HttpPost(“https://api.mch.weixin.qq.com/v3/pay/transactions/jsapi”);           httpPost.addHeader(“Content-Type”, “application/json”);           httpPost.addHeader(“Accept”, “application/json”);           httpPost.setEntity(new StringEntity(requestParam.toJSONString(), StandardCharsets.UTF_8));           CloseableHttpResponse response = wechatPayHttpClient.execute(httpPost);           String responseStr = EntityUtils.toString(response.getEntity(), StandardCharsets.UTF_8);           JSONObject responseObj = JSONObject.parseObject(responseStr);           // 5. 获取预支付ID，生成前端支付参数           String prepayId = responseObj.getString(“prepay_id”);           if (prepayId == null) {           resultMap.put(“code”, 500);           resultMap.put(“msg”, “微信下单失败：” + responseObj.getString(“message”));           return resultMap;           }           // 生成小程序拉起支付所需参数           MappayParams = buildPayParams(prepayId);            resultMap.put(“code”, 200);            resultMap.put(“msg”, “下单成功”);            resultMap.put(“data”, payParams);            } catch (Exception e) {            e.printStackTrace();            resultMap.put(“code”, 500);            resultMap.put(“msg”, “服务异常，下单失败”);            }            return resultMap;            }            /**            * 生成小程序前端支付参数（自动签名）            */            private MapbuildPayParams(String prepayId) throws Exception {             MappayParams = new HashMap<>();              long timeStamp = System.currentTimeMillis() / 1000;              String nonceStr = UUID.randomUUID().toString().replace(“-“, “”);              String packageStr = “prepay_id=” + prepayId;              // 小程序支付必填参数              payParams.put(“appId”, appId);              payParams.put(“timeStamp”, String.valueOf(timeStamp));              payParams.put(“nonceStr”, nonceStr);              payParams.put(“package”, packageStr);              payParams.put(“signType”, “RSA”);              // 生成签名（微信支付V3签名逻辑，此处省略具体签名实现，直接使用SDK自动处理）              return payParams;              }              }

java                  import com.alibaba.fastjson2.JSONObject;                  import com.wechat.pay.contrib.apache.httpclient.util.AesUtil;                  import org.springframework.beans.factory.annotation.Value;                  import org.springframework.web.bind.annotation.PostMapping;                  import org.springframework.web.bind.annotation.RequestBody;                  import org.springframework.web.bind.annotation.RequestMapping;                  import org.springframework.web.bind.annotation.RestController;                  import javax.servlet.http.HttpServletRequest;                  import java.nio.charset.StandardCharsets;                  import java.util.HashMap;                  import java.util.Map;                  @RestController                  @RequestMapping(“/pay”)                  public class WechatPayNotifyController {                  @Value(“${wechat.pay.api-v3-key}”)                  private String apiV3Key;                  /**                  * 微信支付异步通知接口                  */                  @PostMapping(“/notify”)                  public MappayNotify(HttpServletRequest request, @RequestBody String body) {          MapresultMap = new HashMap<>();           try {           // 1. 解析微信通知参数           JSONObject notifyObj = JSONObject.parseObject(body);           String resourceType = notifyObj.getString(“resource_type”);           JSONObject resource = notifyObj.getJSONObject(“resource”);           String ciphertext = resource.getString(“ciphertext”);           String nonce = resource.getString(“nonce”);           String associatedData = resource.getString(“associated_data”);           // 2. AES解密通知数据（V3密钥解密）           AesUtil aesUtil = new AesUtil(apiV3Key.getBytes(StandardCharsets.UTF_8));           String decryptStr = aesUtil.decryptToString(associatedData.getBytes(StandardCharsets.UTF_8),           nonce.getBytes(StandardCharsets.UTF_8), ciphertext);           JSONObject decryptObj = JSONObject.parseObject(decryptStr);           // 3. 获取订单核心信息           String outTradeNo = decryptObj.getString(“out_trade_no”);           String tradeState = decryptObj.getString(“trade_state”);           String transactionId = decryptObj.getString(“transaction_id”);           // 4. 支付成功处理           if (“SUCCESS”.equals(tradeState)) {           // 更新本地订单状态：改为1-已支付，记录微信订单号、支付时间           // orderService.updateOrderStatus(outTradeNo, 1, transactionId);           System.out.println(“订单” + outTradeNo + “支付成功，微信订单号：” + transactionId);           }           // 5. 返回成功响应给微信，停止重复通知           resultMap.put(“code”, “SUCCESS”);           resultMap.put(“message”, “成功”);           } catch (Exception e) {           e.printStackTrace();           // 处理失败，返回失败，微信会重新推送通知           resultMap.put(“code”, “FAIL”);           resultMap.put(“message”, “处理失败”);           }           return resultMap;           }           }

javascript                  // pages/pay/pay.js                  const app = getApp();                  Page({                  data: { totalFee: 100, orderBody: ‘小程序商品购买’ },                  // 发起支付                  toPay() {                  const openid = app.globalData.openid;                  if (!openid) { wx.showToast({ title: ‘请先授权登录’, icon: ‘none’ }); return; }                  wx.showLoading({ title: ‘下单中…’ });                  wx.request({                  url: ‘https://你的公网HTTPS域名/api/pay/createOrder’,                  method: ‘POST’,                  data: { openid: openid, totalFee: this.data.totalFee, body: this.data.orderBody },                  success: (res) => {                  wx.hideLoading();                  if (res.data.code === 200) {                  // 拉起微信支付                  wx.requestPayment({                  …res.data.data,                  success: () => wx.showToast({ title: ‘支付成功’ }),                  fail: () => wx.showToast({ title: ‘支付取消’, icon: ‘none’ })                  })                  } else { wx.showToast({ title: res.data.msg, icon: ‘none’ }) }                  },                  fail: () => { wx.hideLoading(); wx.showToast({ title: ‘网络异常’, icon: ‘none’ }) }                  })                  }                  })