首页 友情链接

集成JPay的微信支付

时间 2021/3/19 14:02:13 加载中...

前言

项目用到微信支付，参照了 JPay 的 Spring Boot Demo 程序。
项目地址：https://gitee.com/javen205/IJPay/tree/master/IJPay-Demo-SpringBoot
但最好还是理解下微信支付的流程。
可以看一下官方的扫码支付：https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=6_5&index=3
然后在看 Demo 程序中是如何实现扫码程序的。

我们将 Demo 程序中的部分代码移植到自己的程序中。

自己项目为非前后台，技术栈 Spring Boot + thymeleaf。

移植步骤

pom.xml 文件添加依赖

添加了 微信支付 和 支付宝支付 两种。

  1.     <properties>
  2.         <ijapy.version>2.7.3</ijapy.version>
  3.     </properties>
  5.     <dependencies>
  6.         <dependency>
  7.             <groupId>com.github.javen205</groupId>
  8.             <artifactId>IJPay-WxPay</artifactId>
  9.             <version>${ijapy.version}</version>
  10.         </dependency>
  12.         <dependency>
  13.             <groupId>com.github.javen205</groupId>
  14.             <artifactId>IJPay-AliPay</artifactId>
  15.             <version>${ijapy.version}</version>
  16.         </dependency>
  17.     </dependencies>

添加配置

在 application.yml 中添加支付相关的配置

  1. pay:
  2.   weixin:
  3.     appId: 应用编号
  4.     appSecret: appSecret 是 appId 对应的接口密码，微信公众号授权获取用户 openId 时使用
  5.     mchId: 微信支付商户号
  6.     partnerKey: API 密钥
  7.     certPath: apiclient_cert.p1 证书路径，在微信商户后台下载
  8.     domain: 外网访问项目的域名，支付通知中会使用
  9.   ali:
  10.     appId: 应用编号
  11.     privateKey: 应用私钥
  12.     publicKey: 支付宝公钥，通过应用公钥上传到支付宝开放平台换取支付宝公钥(如果是证书模式，公钥与私钥在CSR目录)。
  13.     appCertPath: 应用公钥证书
  14.     aliPayCertPath: 支付宝公钥证书
  15.     aliPayRootCertPath: 支付宝根证书
  16.     serverUrl: 支付宝支付网关，沙箱环境时设置为 http://openapi.ev.com/gateway.do 使用正式环境时设置为 http://openapi.com/gateway.do
  17.     domain: 外网访问项目的域名，支付通知中会使用

在配置包下（我的是 config）新增一个包专门放置和支付相关的配置，比如包名为 pay
新增微信配置类和支付宝配置类。

  1. @Configuration
  2. @ConfigurationProperties(prefix = "pay.ali")
  3. public class AliConfig {
  5.     private String appId;
  6.     private String privateKey;
  7.     private String publicKey;
  8.     private String appCertPath;
  9.     private String aliPayCertPath;
  10.     private String aliPayRootCertPath;
  11.     private String serverUrl;
  12.     private String domain;
  14.     //getter setter 略
  15. }
  17. @Configuration
  18. @ConfigurationProperties(prefix = "pay.weixin")
  19. public class WxConfig {
  20.     private String appId;
  21.     private String appSecret;
  22.     private String mchId;
  23.     private String partnerKey;
  24.     private String certPath;
  25.     private String domain;
  27.     //getter setter 略
  28. }

添加接口

编写微信的控制器

此控制器包含一个【花钱购买角色】的业务逻辑。
前端调用 /wxPay/setRole 的接口，后台会创建一个订单记录（自己系统记录的订单），同时根据角色价格生成一个二维码，二维码会以 BASE64 的形式返回给前端。用户扫码支付后，微信后台就会调用回调接口（生成二维码的时候指定的），我们在回调接口中补充上自己的业务逻辑也就是赋值角色即可。

如果有新的逻辑，修改 setRole 方法，和 UpdateOrder 方法即可。

  1. package com.sqber.personMgr.ui.controller.pay;
  3. import com.google.zxing.BarcodeFormat;
  4. import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
  5. import com.ijpay.core.enums.SignType;
  6. import com.ijpay.core.enums.TradeType;
  7. import com.ijpay.core.kit.HttpKit;
  8. import com.ijpay.core.kit.IpKit;
  9. import com.ijpay.core.kit.QrCodeKit;
  10. import com.ijpay.core.kit.WxPayKit;
  11. import com.ijpay.wxpay.WxPayApi;
  12. import com.ijpay.wxpay.WxPayApiConfigKit;
  13. import com.ijpay.wxpay.model.OrderQueryModel;
  14. import com.ijpay.wxpay.model.UnifiedOrderModel;
  15. import com.sqber.personMgr.base.BaseResponse;
  16. import com.sqber.personMgr.base.SessionHelper;
  17. import com.sqber.personMgr.bll.IPayOrderService;
  18. import com.sqber.personMgr.entity.PayOrder;
  19. import com.sqber.personMgr.ui.config.pay.WxConfig;
  20. import org.slf4j.Logger;
  21. import org.slf4j.LoggerFactory;
  22. import org.springframework.beans.factory.annotation.Autowired;
  23. import org.springframework.util.StringUtils;
  24. import org.springframework.web.bind.annotation.*;
  26. import com.ijpay.wxpay.WxPayApiConfig;
  28. import javax.servlet.http.HttpServletRequest;
  29. import javax.servlet.http.HttpServletResponse;
  30. import java.io.ByteArrayOutputStream;
  31. import java.io.IOException;
  32. import java.util.Base64;
  33. import java.util.HashMap;
  34. import java.util.Map;
  37. @RestController
  38. @RequestMapping("/wxPay")
  39. public class WxController {
  40.     private final Logger log = LoggerFactory.getLogger(this.getClass());
  42.     @Autowired
  43.     WxConfig wxConfig;
  45.     @Autowired
  46.     IPayOrderService payOrderService;
  48.     public void getApiConfig() {
  49.         WxPayApiConfig apiConfig;
  51.         try {
  52.             apiConfig = WxPayApiConfigKit.getApiConfig(wxConfig.getAppId());
  53.         } catch (Exception e) {
  54.             apiConfig = WxPayApiConfig.builder()
  55.                     .appId(wxConfig.getAppId())
  56.                     .mchId(wxConfig.getMchId())
  57.                     .partnerKey(wxConfig.getPartnerKey())
  58.                     .certPath(wxConfig.getCertPath())
  59.                     .domain(wxConfig.getDomain())
  60.                     .build();
  61.             WxPayApiConfigKit.setThreadLocalWxPayApiConfig(apiConfig);
  62.         }
  63.     }
  67.     @GetMapping("/test")
  68.     public String test(){
  69.         return "test";
  70.     }
  72.     /**
  73.      * 扫码支付模式二
  74.      */
  75.     @PostMapping("/scanCode2")
  76.     public BaseResponse scanCode2(HttpServletRequest request, HttpServletResponse response, String totalFee) {
  78.         if (StringUtils.isEmpty(totalFee)) {
  79.             return BaseResponse.fail("支付金额不能为空");
  80.         }
  82.         String ip = IpKit.getRealIp(request);
  83.         if (StringUtils.isEmpty(ip)) {
  84.             ip = "127.0.0.1";
  85.         }
  87.         return createCode(WxPayKit.generateStr(), ip,"","","", 1);
  89.     }
  91.     private BaseResponse createCode(String orderNo, String ip, String body, String detail, String attach, int totalFee){
  93.         getApiConfig();
  94.         WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();
  96.         String notifyUrl = wxPayApiConfig.getDomain().concat("/wxPay/payNotify");
  98.         Map<String, String> params = UnifiedOrderModel
  99.                 .builder()
  100.                 .appid(wxPayApiConfig.getAppId())
  101.                 .mch_id(wxPayApiConfig.getMchId())
  102.                 .nonce_str(WxPayKit.generateStr())
  103.                 .body(body)
  104.                 .attach(attach)
  105.                 .detail(detail)
  106.                 .out_trade_no(orderNo)
  107.                 .total_fee(String.valueOf(totalFee))
  108.                 .spbill_create_ip(ip)
  109.                 .notify_url(notifyUrl)
  110.                 .trade_type(TradeType.NATIVE.getTradeType())
  111.                 .build()
  112.                 .createSign(wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
  114.         log.info("parmas:" + params);
  115.         log.info("notifyUrl:" + notifyUrl);
  116.         String xmlResult = WxPayApi.pushOrder(false, params);
  117.         log.info("统一下单:" + xmlResult);
  119.         Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
  121.         String returnCode = result.get("return_code");
  122.         String returnMsg = result.get("return_msg");
  123.         System.out.println(returnMsg);
  124.         if (!WxPayKit.codeIsOk(returnCode)) {
  125.             return BaseResponse.fail("error:" + returnMsg);
  126.         }
  127.         String resultCode = result.get("result_code");
  128.         if (!WxPayKit.codeIsOk(resultCode)) {
  129.             return BaseResponse.fail("error:" + returnMsg);
  130.         }
  131.         //生成预付订单success
  133.         String qrCodeUrl = result.get("code_url");
  135.         // 生成二维码，并返回 BASE64 格式的图片
  136.         try {
  137.             ByteArrayOutputStream output = new ByteArrayOutputStream();
  138.             QrCodeKit.encodeOutPutSteam(output, qrCodeUrl, BarcodeFormat.QR_CODE, 3, ErrorCorrectionLevel.H, "png", 200, 200);
  139.             byte[] byteArr = output.toByteArray();
  140.             String str = Base64.getEncoder().encodeToString(byteArr);
  141.             String imgStr = new StringBuilder().append("data:image/png;base64,").append(str).toString();
  143.             BaseResponse baseResponse = new BaseResponse();
  144.             baseResponse.setData(imgStr);
  145.             return baseResponse;
  147.         } catch (IOException e) {
  148.             log.error("error:{}", e);
  149.             e.printStackTrace();
  150.             return BaseResponse.fail("服务器错误");
  151.         }
  152.     }
  154.     @GetMapping("/setRole")
  155.     // 创建业务订单
  156.     private BaseResponse createOrder(HttpServletRequest request, HttpServletResponse response){
  158.         // 从数据库中获取角色的价格
  160.         PayOrder payOrder = new PayOrder();
  161.         payOrder.setOrderNo(WxPayKit.generateStr());
  162.         payOrder.setAmount(1); // 1分 1元 = 10角 = 100分
  163.         payOrder.setUserId(SessionHelper.GetLoginUserID());
  164.         payOrder.setOrderState(PayOrder.NOT_PAYED);
  165.         payOrder.setProduct("获取管理员角色");
  166.         payOrder.setContent("获取管理员角色");
  168.         payOrderService.insert(payOrder);
  170.         String ip = IpKit.getRealIp(request);
  171.         if (StringUtils.isEmpty(ip)) {
  172.             ip = "127.0.0.1";
  173.         }
  175.         return createCode(payOrder.getOrderNo(),ip, payOrder.getContent(), "详情", "附加", payOrder.getAmount());
  176.     }
  178.     /**
  179.      * 异步通知
  180.      */
  181.     @RequestMapping(value = "/payNotify", method = {RequestMethod.POST, RequestMethod.GET})
  182.     @ResponseBody
  183.     public String payNotify(HttpServletRequest request) {
  184.         log.info("异步通知来了");
  185.         String xmlMsg = HttpKit.readData(request);
  186.         log.info("支付通知=" + xmlMsg);
  187.         Map<String, String> params = WxPayKit.xmlToMap(xmlMsg);
  189.         String returnCode = params.get("return_code");
  190.         String resultCode = params.get("result_code");
  191.         String transactionId = params.get("transaction_id"); // 微信订单号
  192.         String out_trade_no = params.get("out_trade_no"); // 商户订单号
  193.         String attach = params.get("attach"); // 附加数据
  195.         log.info("微信订单号（交易单号）：" + transactionId);
  196.         log.info("订单号（商户单号）：" + out_trade_no);
  198.         // 注意重复通知的情况，同一订单号可能收到多次通知，请注意一定先判断订单状态
  199.         // 注意此处签名方式需与统一下单的签名类型一致
  200.         getApiConfig();
  201.         if (WxPayKit.verifyNotify(params, WxPayApiConfigKit.getWxPayApiConfig().getPartnerKey(), SignType.HMACSHA256)) {
  202.             if (WxPayKit.codeIsOk(returnCode) && WxPayKit.codeIsOk(resultCode)) {
  203.                 // 更新订单信息
  204.                 // 发送通知等
  206.                 updateOrder(out_trade_no);
  208.                 Map<String, String> xml = new HashMap<String, String>(2);
  209.                 xml.put("return_code", "SUCCESS");
  210.                 xml.put("return_msg", "OK");
  211.                 return WxPayKit.toXml(xml);
  212.             }
  213.         }
  214.         return null;
  215.     }
  217.     // 更新订单 && 发送商品
  218.     private void updateOrder(String orderNo){
  219.         payOrderService.completeOrder(orderNo);
  220.         PayOrder payOrder = payOrderService.getByOrderNo(orderNo);
  223.         log.info("设置指定角色");
  224.         // 赋予用户特定角色
  225.         // userRole.updateRole(userId,payOrder.getProduct());
  226.     }
  229.     /**
  230.      * 查询订单
  231.      *
  232.      * @param transactionId
  233.      * @param outTradeNo
  234.      * @return
  235.      */
  236.     @RequestMapping(value = "/queryOrder", method = {RequestMethod.POST, RequestMethod.GET})
  237.     @ResponseBody
  238.     public String queryOrder(@RequestParam(value = "transactionId", required = false) String transactionId, @RequestParam(value = "outTradeNo", required = false) String outTradeNo) {
  239.         try {
  240.             getApiConfig();
  241.             WxPayApiConfig wxPayApiConfig = WxPayApiConfigKit.getWxPayApiConfig();
  243.             Map<String, String> params = OrderQueryModel.builder()
  244.                     .appid(wxPayApiConfig.getAppId())
  245.                     .mch_id(wxPayApiConfig.getMchId())
  246.                     .transaction_id(transactionId)
  247.                     .out_trade_no(outTradeNo)
  248.                     .nonce_str(WxPayKit.generateStr())
  249.                     .build()
  250.                     .createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);
  251.             log.info("请求参数：{}", WxPayKit.toXml(params));
  252.             String query = WxPayApi.orderQuery(params);
  253.             log.info("查询结果: {}", query);
  255. //            if(成功了){
  256. //                updateOrder();
  257. //            }
  259.             return query;
  260.         } catch (Exception e) {
  261.             e.printStackTrace();
  262.             return "系统错误";
  263.         }
  264.     }
  266. }

支付宝接口控制器暂无。

业务订单表 SQL 语句

  1. CREATE TABLE `payOrder` (
  2.     `id` int unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  3.     `orderNo` varchar(100) NOT NULL DEFAULT '' COMMENT '订单号',
  4.     `amount` int NOT NULL DEFAULT 0 COMMENT '金额(单位:分)',
  5.     `userId` int NOT NULL DEFAULT 0 COMMENT '用户id', 
  6.     `orderState` int NOT NULL DEFAULT 0 COMMENT '订单状态：0-待支付 1-已支付 2-支付失败',
  7.     `product` VARCHAR(200) NOT NULL DEFAULT '' COMMENT '商品(比如按角色付费，则可以存角色id)',
  8.     `content` VARCHAR(200) NOT NULL DEFAULT '' COMMENT '商品描述',
  9.     `createUser` varchar(64) NULL DEFAULT '' COMMENT '创建人',
  10.     `createTime` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  11.     `modifyUser` varchar(64) NULL DEFAULT '' COMMENT '更新人',
  12.     `modifyTime` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
  13.     `status` tinyint DEFAULT '1' COMMENT '记录状态：0-删除 1-正常',
  14.   PRIMARY KEY (`id`)
  15. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='支付订单表';

Demo地址

https://github.com/shenqiangbin/personMgr

扫码分享
版权说明
作者：SQBER
文章来源：http://www.sqber.com/articles/the-pay-wx.html
本文版权归作者所有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。
sqber 2017-2021 冀ICP备17029815 站点地图