若依分离版整合IJpay实现第三方支付-(微信支付篇_v2)
侯博易
若依分离版整合IJpay实现第三方支付-(微信支付篇_v2)
IJpay官网
https://javen205.gitee.io/ijpay/
简介
本文中暂时不对与支付流程做具体详细讲解,具体流程麻烦去看官方文档,看不懂就百度,想想办法…这是老版本, 新版本可能会有变动,需要自行校对官网文档和代码
首先添加依赖
这里仅添加了对应微信支付部分的依赖,如果不怕项目过重可以添加全部…可以但是不建议
ruoyi\pom.xml父级添加依赖因为使用了
再ruoyi的parent项目中的pom.xml文件中添加依赖dependencyManagement使用简介
Maven中的dependencyManagement元素提供了一种管理依赖版本号的方式。在dependencyManagement元素中声明所依赖的jar包的版本号等信息，那么所有子项目再次引入此依赖jar包时则无需显式的列出版本号。Maven会沿着父子层级向上寻找拥有dependencyManagement 元素的项目，然后使用它指定的版本号。
<dependency>
<groupId>com.github.javen205</groupId>
<artifactId>IJPay-WxPay</artifactId>
<!-- 如果这里添加了版本统一管理请酌情处理为 ${ijapy.version} -->
<version>2.7.4</version>
</dependency>
- 接下来在相应的支付模块的pom.xml中添加依赖,这里暂时直接使用admin的moudel做讲解,具体需求和项目结构酌情处理
<dependency>
<groupId>com.github.javen205</groupId>
<artifactId>IJPay-WxPay</artifactId>
</dependency>
接下来导入对应代码
具体位置我就不做表述了只需要注意下方代码的package位置就可以大致确定防止位置(!!!注意前言,根据具体需求决定位置这里只是用admin模块做演示)
接下来每个文件名我都使用了三级标签,可以方便根据目录查询
添加WxPayController
这里的代码跟官方给的Demo有些许的不同因为我们这里使用的工具类集成了hutool的依赖所以原本代码的一些
// 原本代码中引入的类是这个 import com.jfinal.kit.StrKit; // 但是下方使用的是hutool import cn.hutool.core.util.StrUtil; //所以下方所有的StrKit都变成了StrUtil
package com.ruoyi.web.controller.pay;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON;
import com.google.zxing.BarcodeFormat;
import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
import com.ijpay.core.enums.SignType;
import com.ijpay.core.enums.TradeType;
import com.ijpay.core.kit.HttpKit;
import com.ijpay.core.kit.IpKit;
import com.ijpay.core.kit.QrCodeKit;
import com.ijpay.core.kit.RsaKit;
import com.ijpay.core.kit.WxPayKit;
import com.ijpay.wxpay.WxPayApi;
import com.ijpay.wxpay.WxPayApiConfig;
import com.ijpay.wxpay.WxPayApiConfigKit;
import com.ijpay.wxpay.model.GetTransferInfoModel;
import com.ijpay.wxpay.model.MicroPayModel;
import com.ijpay.wxpay.model.OrderQueryModel;
import com.ijpay.wxpay.model.ProfitSharingModel;
import com.ijpay.wxpay.model.ReceiverModel;
import com.ijpay.wxpay.model.RefundModel;
import com.ijpay.wxpay.model.RefundQueryModel;
import com.ijpay.wxpay.model.SendRedPackModel;
import com.ijpay.wxpay.model.TransferModel;
import com.ijpay.wxpay.model.UnifiedOrderModel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.util.ResourceUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* <p>IJPay 让支付触手可及，封装了微信支付、支付宝支付、银联支付常用的支付方式以及各种常用的接口。</p>
*
* <p>不依赖任何第三方 mvc 框架，仅仅作为工具使用简单快速完成支付模块的开发，可轻松嵌入到任何系统里。 </p>
*
* <p>IJPay 交流群: 723992875</p>
*
* <p>Node.js 版: https://gitee.com/javen205/TNWX</p>
*
* <p>微信支付 Demo</p>
*
* @author Javen
*/
@Controller
@RequestMapping("/wxPay")
public class WxPayController extends AbstractWxPayApiController {
private final Logger log = LoggerFactory.getLogger(this.getClass());
@Autowired
WxPayBean wxPayBean;
private String notifyUrl;
private String refundNotifyUrl;
private static final String USER_PAYING = "USERPAYING";
@Override
public WxPayApiConfig getApiConfig() {
WxPayApiConfig apiConfig;
try {
apiConfig = WxPayApiConfigKit.getApiConfig(wxPayBean.getAppId());
} catch (Exception e) {
apiConfig = WxPayApiConfig.builder()
.appId(wxPayBean.getAppId())
.mchId(wxPayBean.getMchId())
.partnerKey(wxPayBean.getPartnerKey())
.certPath(wxPayBean.getCertPath())
.domain(wxPayBean.getDomain())
.build();
}
// 微信支付回调地址
notifyUrl = apiConfig.getDomain().concat("/wxPay/payNotify");
// 微信退款回调地址
refundNotifyUrl = apiConfig.getDomain().concat("/wxPay/refundNotify");
return apiConfig;
}
/**
* 测试接口
*/
@GetMapping("/test")
@ResponseBody
public WxPayBean test() {
return wxPayBean;
}
@GetMapping("/getKey")
@ResponseBody
public String getKey() {
return WxPayApi.getSignKey(wxPayBean.getMchId(), wxPayBean.getPartnerKey(), SignType.MD5);
}
/**
* 微信H5 支付
* 注意：必须再web页面中发起支付且域名已添加到开发配置中
*/
@RequestMapping(value = "/wapPay", method = {RequestMethod.POST, RequestMethod.GET})
public void wapPay(HttpServletRequest request, HttpServletResponse response) throws IOException {
String ip = IpKit.getRealIp(request);
if (StrUtil.isBlank(ip)) {
ip = "127.0.0.1";
}
H5SceneInfo sceneInfo = new H5SceneInfo();
H5SceneInfo.H5 h5_info = new H5SceneInfo.H5();
h5_info.setType("Wap");
//此域名必须在商户平台--"产品中心"--"开发配置"中添加
h5_info.setWap_url("https://gitee.com/javen205/IJPay");
h5_info.setWap_name("IJPay VIP 充值");
sceneInfo.setH5Info(h5_info);
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = UnifiedOrderModel
.builder()
.appid(wxPayApiConfig.getAppId())
.mch_id(wxPayApiConfig.getMchId())
.nonce_str(WxPayKit.generateStr())
.body("IJPay 让支付触手可及-H5支付")
.attach("Node.js 版:https://gitee.com/javen205/TNWX")
.out_trade_no(WxPayKit.generateStr())
.total_fee("1000")
.spbill_create_ip(ip)
.notify_url(notifyUrl)
.trade_type(TradeType.MWEB.getTradeType())
.scene_info(JSON.toJSONString(sceneInfo))
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
String xmlResult = WxPayApi.pushOrder(false, params);
log.info(xmlResult);
Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
String return_code = result.get("return_code");
String return_msg = result.get("return_msg");
if (!WxPayKit.codeIsOk(return_code)) {
throw new RuntimeException(return_msg);
}
String result_code = result.get("result_code");
if (!WxPayKit.codeIsOk(result_code)) {
throw new RuntimeException(return_msg);
}
// 以下字段在return_code 和result_code都为SUCCESS的时候有返回
String prepayId = result.get("prepay_id");
String webUrl = result.get("mweb_url");
log.info("prepay_id:" + prepayId + " mweb_url:" + webUrl);
response.sendRedirect(webUrl);
}
/**
* 公众号支付
*/
@RequestMapping(value = "/webPay", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public AjaxResult webPay(HttpServletRequest request, @RequestParam("total_fee") String totalFee) {
// openId，采用 网页授权获取 access_token API：SnsAccessTokenApi获取
String openId = (String) request.getSession().getAttribute("openId");
if (openId == null) {
openId = "11111111";
}
if (StrUtil.isEmpty(openId)) {
return AjaxResult.error("openId is null");
}
if (StrUtil.isEmpty(totalFee)) {
return AjaxResult.error("请输入数字金额");
}
String ip = IpKit.getRealIp(request);
if (StrUtil.isEmpty(ip)) {
ip = "127.0.0.1";
}
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = UnifiedOrderModel
.builder()
.appid(wxPayApiConfig.getAppId())
.mch_id(wxPayApiConfig.getMchId())
.nonce_str(WxPayKit.generateStr())
.body("IJPay 让支付触手可及-公众号支付")
.attach("Node.js 版:https://gitee.com/javen205/TNWX")
.out_trade_no(WxPayKit.generateStr())
.total_fee("1000")
.spbill_create_ip(ip)
.notify_url(notifyUrl)
.trade_type(TradeType.JSAPI.getTradeType())
.openid(openId)
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
String xmlResult = WxPayApi.pushOrder(false, params);
log.info(xmlResult);
Map<String, String> resultMap = WxPayKit.xmlToMap(xmlResult);
String returnCode = resultMap.get("return_code");
String returnMsg = resultMap.get("return_msg");
if (!WxPayKit.codeIsOk(returnCode)) {
return AjaxResult.error(returnMsg);
}
String resultCode = resultMap.get("result_code");
if (!WxPayKit.codeIsOk(resultCode)) {
return AjaxResult.error(returnMsg);
}
// 以下字段在 return_code 和 result_code 都为 SUCCESS 的时候有返回
String prepayId = resultMap.get("prepay_id");
Map<String, String> packageParams = WxPayKit.prepayIdCreateSign(prepayId, wxPayApiConfig.getAppId(),
wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
String jsonStr = JSON.toJSONString(packageParams);
return AjaxResult.success(jsonStr);
}
/**
* 扫码模式一
*/
@RequestMapping(value = "/scanCode1", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public AjaxResult scanCode1(HttpServletRequest request, HttpServletResponse response,
@RequestParam("productId") String productId) {
try {
if (StrUtil.isBlank(productId)) {
return AjaxResult.error("productId is null");
}
WxPayApiConfig config = getWxPayApiConfig();
//获取扫码支付（模式一）url
String qrCodeUrl = WxPayKit.bizPayUrl(config.getPartnerKey(), config.getAppId(), config.getMchId(), productId);
log.info(qrCodeUrl);
//生成二维码保存的路径
String name = "payQRCode1.png";
log.info(ResourceUtils.getURL("classpath:").getPath());
boolean encode = QrCodeKit.encode(qrCodeUrl, BarcodeFormat.QR_CODE, 3, ErrorCorrectionLevel.H,
"png", 200, 200,
ResourceUtils.getURL("classpath:").getPath().concat("static").concat(File.separator).concat(name));
if (encode) {
//在页面上显示
return AjaxResult.success(name);
}
} catch (Exception e) {
e.printStackTrace();
return AjaxResult.error("系统异常：" + e.getMessage());
}
return null;
}
/**
* 扫码支付模式一回调
*/
@RequestMapping(value = "/scanCodeNotify", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String scanCodeNotify(HttpServletRequest request, HttpServletResponse response) {
try {
String result = HttpKit.readData(request);
log.info("scanCodeNotify>>>" + result);
/**
* 获取返回的信息内容中各个参数的值
*/
Map<String, String> map = WxPayKit.xmlToMap(result);
for (String key : map.keySet()) {
log.info("key= " + key + " and value= " + map.get(key));
}
String appId = map.get("appid");
String openId = map.get("openid");
String mchId = map.get("mch_id");
String isSubscribe = map.get("is_subscribe");
String nonceStr = map.get("nonce_str");
String productId = map.get("product_id");
String sign = map.get("sign");
Map<String, String> packageParams = new HashMap<String, String>(6);
packageParams.put("appid", appId);
packageParams.put("openid", openId);
packageParams.put("mch_id", mchId);
packageParams.put("is_subscribe", isSubscribe);
packageParams.put("nonce_str", nonceStr);
packageParams.put("product_id", productId);
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
String packageSign = WxPayKit.createSign(packageParams, wxPayApiConfig.getPartnerKey(), SignType.MD5);
String ip = IpKit.getRealIp(request);
if (StrUtil.isBlank(ip)) {
ip = "127.0.0.1";
}
Map<String, String> params = UnifiedOrderModel
.builder()
.appid(wxPayApiConfig.getAppId())
.mch_id(wxPayApiConfig.getMchId())
.nonce_str(WxPayKit.generateStr())
.body("IJPay 让支付触手可及-扫码支付模式一")
.attach("Node.js 版:https://gitee.com/javen205/TNWX")
.out_trade_no(WxPayKit.generateStr())
.total_fee("1")
.spbill_create_ip(ip)
.notify_url(notifyUrl)
.trade_type(TradeType.NATIVE.getTradeType())
.openid(openId)
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
String xmlResult = WxPayApi.pushOrder(false, params);
log.info("统一下单:" + xmlResult);
/**
* 发送信息给微信服务器
*/
Map<String, String> payResult = WxPayKit.xmlToMap(xmlResult);
String returnCode = payResult.get("return_code");
String resultCode = payResult.get("result_code");
if (WxPayKit.codeIsOk(returnCode) && WxPayKit.codeIsOk(resultCode)) {
// 以下字段在 return_code 和 result_code 都为 SUCCESS 的时候有返回
String prepayId = payResult.get("prepay_id");
Map<String, String> prepayParams = new HashMap<String, String>(10);
prepayParams.put("return_code", "SUCCESS");
prepayParams.put("appid", appId);
prepayParams.put("mch_id", mchId);
prepayParams.put("nonce_str", System.currentTimeMillis() + "");
prepayParams.put("prepay_id", prepayId);
String prepaySign;
if (sign.equals(packageSign)) {
prepayParams.put("result_code", "SUCCESS");
} else {
prepayParams.put("result_code", "FAIL");
//result_code为FAIL时，添加该键值对，value值是微信告诉客户的信息
prepayParams.put("err_code_des", "订单失效");
}
prepaySign = WxPayKit.createSign(prepayParams, wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
prepayParams.put("sign", prepaySign);
String xml = WxPayKit.toXml(prepayParams);
log.error(xml);
return xml;
}
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 扫码支付模式二
*/
@RequestMapping(value = "/scanCode2", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public AjaxResult scanCode2(HttpServletRequest request, HttpServletResponse response,
@RequestParam("total_fee") String totalFee) {
if (StrUtil.isBlank(totalFee)) {
return AjaxResult.error("支付金额不能为空");
}
String ip = IpKit.getRealIp(request);
if (StrUtil.isBlank(ip)) {
ip = "127.0.0.1";
}
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = UnifiedOrderModel
.builder()
.appid(wxPayApiConfig.getAppId())
.mch_id(wxPayApiConfig.getMchId())
.nonce_str(WxPayKit.generateStr())
.body("IJPay 让支付触手可及-扫码支付模式二")
.attach("Node.js 版:https://gitee.com/javen205/TNWXX")
.out_trade_no(WxPayKit.generateStr())
.total_fee("1")
.spbill_create_ip(ip)
.notify_url(notifyUrl)
.trade_type(TradeType.NATIVE.getTradeType())
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
String xmlResult = WxPayApi.pushOrder(false, params);
log.info("统一下单:" + xmlResult);
Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
String returnCode = result.get("return_code");
String returnMsg = result.get("return_msg");
System.out.println(returnMsg);
if (!WxPayKit.codeIsOk(returnCode)) {
return AjaxResult.error("error:" + returnMsg);
}
String resultCode = result.get("result_code");
if (!WxPayKit.codeIsOk(resultCode)) {
return AjaxResult.error("error:" + returnMsg);
}
//生成预付订单success
String qrCodeUrl = result.get("code_url");
String name = "payQRCode2.png";
boolean encode = QrCodeKit.encode(qrCodeUrl, BarcodeFormat.QR_CODE, 3, ErrorCorrectionLevel.H, "png", 200, 200,
request.getSession().getServletContext().getRealPath("/") + File.separator + name);
if (encode) {
//在页面上显示
return AjaxResult.success(name);
}
return null;
}
/**
* 刷卡支付
*/
@RequestMapping(value = "/micropay", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public AjaxResult microPay(HttpServletRequest request, HttpServletResponse response) {
String authCode = request.getParameter("auth_code");
String totalFee = request.getParameter("total_fee");
if (StrUtil.isBlank(totalFee)) {
return AjaxResult.error("支付金额不能为空");
}
if (StrUtil.isBlank(authCode)) {
return AjaxResult.error("auth_code参数错误");
}
String ip = IpKit.getRealIp(request);
if (StrUtil.isBlank(ip)) {
ip = "127.0.0.1";
}
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = MicroPayModel.builder()
.appid(wxPayApiConfig.getAppId())
.mch_id(wxPayApiConfig.getMchId())
.nonce_str(WxPayKit.generateStr())
.body("IJPay 让支付触手可及-刷卡支付")
.attach("Node.js 版:https://gitee.com/javen205/TNWXX")
.out_trade_no(WxPayKit.generateStr())
.total_fee("1")
.spbill_create_ip(ip)
.auth_code(authCode)
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
String xmlResult = WxPayApi.microPay(false, params);
//同步返回结果
log.info("xmlResult:" + xmlResult);
Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
String returnCode = result.get("return_code");
String returnMsg = result.get("return_msg");
if (!WxPayKit.codeIsOk(returnCode)) {
//通讯失败
String errCode = result.get("err_code");
if (StrUtil.notBlank(errCode)) {
//用户支付中，需要输入密码
if (USER_PAYING.equals(errCode)) {
//等待5秒后调用【查询订单API】
}
}
log.info("提交刷卡支付失败>>" + xmlResult);
return AjaxResult.error(returnMsg);
}
String resultCode = result.get("result_code");
if (!WxPayKit.codeIsOk(resultCode)) {
log.info("支付失败>>" + xmlResult);
String errCodeDes = result.get("err_code_des");
return AjaxResult.error(errCodeDes);
}
//支付成功
return AjaxResult.success(xmlResult);
}
/**
* 微信APP支付
*/
@RequestMapping(value = "/appPay", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public AjaxResult appPay(HttpServletRequest request) {
String ip = IpKit.getRealIp(request);
if (StrUtil.isBlank(ip)) {
ip = "127.0.0.1";
}
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = UnifiedOrderModel
.builder()
.appid(wxPayApiConfig.getAppId())
.mch_id(wxPayApiConfig.getMchId())
.nonce_str(WxPayKit.generateStr())
.body("IJPay 让支付触手可及-App支付")
.attach("Node.js 版:https://gitee.com/javen205/TNWXX")
.out_trade_no(WxPayKit.generateStr())
.total_fee("1000")
.spbill_create_ip(ip)
.notify_url(notifyUrl)
.trade_type(TradeType.APP.getTradeType())
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
String xmlResult = WxPayApi.pushOrder(false, params);
log.info(xmlResult);
Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
String returnCode = result.get("return_code");
String returnMsg = result.get("return_msg");
if (!WxPayKit.codeIsOk(returnCode)) {
return AjaxResult.error(returnMsg);
}
String resultCode = result.get("result_code");
if (!WxPayKit.codeIsOk(resultCode)) {
return AjaxResult.error(returnMsg);
}
// 以下字段在 return_code 和 result_code 都为 SUCCESS 的时候有返回
String prepayId = result.get("prepay_id");
Map<String, String> packageParams = WxPayKit.appPrepayIdCreateSign(wxPayApiConfig.getAppId(), wxPayApiConfig.getMchId(), prepayId,
wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
String jsonStr = JSON.toJSONString(packageParams);
log.info("返回apk的参数:" + jsonStr);
return AjaxResult.success(jsonStr);
}
/**
* 微信小程序支付
*/
@RequestMapping(value = "/miniAppPay", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public AjaxResult miniAppPay(HttpServletRequest request) {
//需要通过授权来获取openId
String openId = (String) request.getSession().getAttribute("openId");
String ip = IpKit.getRealIp(request);
if (StrUtil.isBlank(ip)) {
ip = "127.0.0.1";
}
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = UnifiedOrderModel
.builder()
.appid(wxPayApiConfig.getAppId())
.mch_id(wxPayApiConfig.getMchId())
.nonce_str(WxPayKit.generateStr())
.body("IJPay 让支付触手可及-小程序支付")
.attach("Node.js 版:https://gitee.com/javen205/TNWXX")
.out_trade_no(WxPayKit.generateStr())
.total_fee("1000")
.spbill_create_ip(ip)
.notify_url(notifyUrl)
.trade_type(TradeType.JSAPI.getTradeType())
.openid(openId)
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
String xmlResult = WxPayApi.pushOrder(false, params);
log.info(xmlResult);
Map<String, String> result = WxPayKit.xmlToMap(xmlResult);
String returnCode = result.get("return_code");
String returnMsg = result.get("return_msg");
if (!WxPayKit.codeIsOk(returnCode)) {
return AjaxResult.error(returnMsg);
}
String resultCode = result.get("result_code");
if (!WxPayKit.codeIsOk(resultCode)) {
return AjaxResult.error(returnMsg);
}
// 以下字段在 return_code 和 result_code 都为 SUCCESS 的时候有返回
String prepayId = result.get("prepay_id");
Map<String, String> packageParams = WxPayKit.miniAppPrepayIdCreateSign(wxPayApiConfig.getAppId(), prepayId,
wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256);
String jsonStr = JSON.toJSONString(packageParams);
log.info("小程序支付的参数:" + jsonStr);
return AjaxResult.success(jsonStr);
}
@RequestMapping(value = "/queryOrder", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String queryOrder(@RequestParam(value = "transactionId", required = false) String transactionId, @RequestParam(value = "outTradeNo", required = false) String outTradeNo) {
try {
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = OrderQueryModel.builder()
.appid(wxPayApiConfig.getAppId())
.mch_id(wxPayApiConfig.getMchId())
.transaction_id(transactionId)
.out_trade_no(outTradeNo)
.nonce_str(WxPayKit.generateStr())
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);
log.info("请求参数：{}", WxPayKit.toXml(params));
String query = WxPayApi.orderQuery(params);
log.info("查询结果: {}", query);
return query;
} catch (Exception e) {
e.printStackTrace();
return "系统错误";
}
}
/**
* 企业付款到零钱
*/
@RequestMapping(value = "/transfer", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String transfer(HttpServletRequest request, @RequestParam("openId") String openId) {
String ip = IpKit.getRealIp(request);
if (StrUtil.isBlank(ip)) {
ip = "127.0.0.1";
}
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = TransferModel.builder()
.mch_appid(wxPayApiConfig.getAppId())
.mchid(wxPayApiConfig.getMchId())
.nonce_str(WxPayKit.generateStr())
.partner_trade_no(WxPayKit.generateStr())
.openid(openId)
.check_name("NO_CHECK")
.amount("100")
.desc("IJPay 让支付触手可及-企业付款")
.spbill_create_ip(ip)
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5, false);
// 提现
String transfers = WxPayApi.transfers(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
log.info("提现结果:" + transfers);
Map<String, String> map = WxPayKit.xmlToMap(transfers);
String returnCode = map.get("return_code");
String resultCode = map.get("result_code");
if (WxPayKit.codeIsOk(returnCode) && WxPayKit.codeIsOk(resultCode)) {
// 提现成功
} else {
// 提现失败
}
return transfers;
}
/**
* 查询企业付款到零钱
*/
@RequestMapping(value = "/transferInfo", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String transferInfo(@RequestParam("partner_trade_no") String partnerTradeNo) {
try {
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = GetTransferInfoModel.builder()
.nonce_str(WxPayKit.generateStr())
.partner_trade_no(partnerTradeNo)
.mch_id(wxPayApiConfig.getMchId())
.appid(wxPayApiConfig.getAppId())
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5, false);
return WxPayApi.getTransferInfo(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 获取RSA加密公钥
*/
@RequestMapping(value = "/getPublicKey", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String getPublicKey() {
try {
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = new HashMap<String, String>(4);
params.put("mch_id", wxPayApiConfig.getMchId());
params.put("nonce_str", String.valueOf(System.currentTimeMillis()));
params.put("sign_type", "MD5");
String createSign = WxPayKit.createSign(params, wxPayApiConfig.getPartnerKey(), SignType.MD5);
params.put("sign", createSign);
return WxPayApi.getPublicKey(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 企业付款到银行卡
*/
@RequestMapping(value = "/payBank", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String payBank() {
try {
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
//通过WxPayApi.getPublicKey接口获取RSA加密公钥
//假设获取到的RSA加密公钥为PUBLIC_KEY(PKCS#8格式)
final String PUBLIC_KEY = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA6Bl76IwSvBTiibZ+CNRUA6BfahMshZ0WJpHD1GpmvcQjeN6Yrv6c9eIl6gB4nU3isN7bn+LmoVTpH1gHViaV2YyG/zXj4z4h7r+V+ezesMqqorEg38BCNUHNmhnw4/C0I4gBAQ4x0SJOGnfKGZKR9yzvbkJtvEn732JcEZCbdTZmaxkwlenXvM+mStcJaxBCB/h5xJ5VOF5nDbTPzLphIpzddr3zx/Jxjna9QB1v/YSKYXn+iuwruNUXGCvvxBWaBGKrjOdRTRy9adWOgNmtuYDQJ2YOfG8PtPe06ELKjmr2CfaAGrKKUroyaGvy3qxAV0PlT+UQ4ADSXWt/zl0o5wIDAQAB";
Map<String, String> params = new HashMap<String, String>(10);
params.put("mch_id", wxPayApiConfig.getMchId());
params.put("partner_trade_no", System.currentTimeMillis() + "");
params.put("nonce_str", System.currentTimeMillis() + "");
//收款方银行卡号
params.put("enc_bank_no", RsaKit.encryptByPublicKeyByWx("银行卡号", PUBLIC_KEY));
//收款方用户名
params.put("enc_true_name", RsaKit.encryptByPublicKeyByWx("银行卡持有人姓名", PUBLIC_KEY));
//收款方开户行
params.put("bank_code", "1001");
params.put("amount", "1");
params.put("desc", "IJPay 让支付触手可及-付款到银行卡");
params.put("sign", WxPayKit.createSign(params, wxPayApiConfig.getPartnerKey(), SignType.HMACSHA256));
return WxPayApi.payBank(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 查询企业付款到银行
*/
@RequestMapping(value = "/queryBank", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String queryBank(@RequestParam("partner_trade_no") String partnerTradeNo) {
try {
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = new HashMap<String, String>(4);
params.put("mch_id", wxPayApiConfig.getMchId());
params.put("partner_trade_no", partnerTradeNo);
params.put("nonce_str", System.currentTimeMillis() + "");
params.put("sign", WxPayKit.createSign(params, wxPayApiConfig.getPartnerKey(), SignType.MD5));
return WxPayApi.queryBank(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 添加分账接收方
*/
@RequestMapping(value = "/profitSharingAddReceiver", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String profitSharingAddReceiver() {
try {
ReceiverModel receiver = ReceiverModel.builder()
.type("PERSONAL_OPENID")
.account("openid")
.relation_type("PARTNER")
.build();
Map<String, String> params = ProfitSharingModel.builder()
.mch_id(wxPayBean.getMchId())
.appid(wxPayBean.getAppId())
.nonce_str(WxPayKit.generateStr())
.receiver(JSON.toJSONString(receiver))
.build()
.createSign(wxPayBean.getPartnerKey(), SignType.HMACSHA256);
log.info("请求参数:{}", WxPayKit.toXml(params));
String result = WxPayApi.profitSharingAddReceiver(params);
log.info("请求结果:{}", result);
return JSON.toJSONString(WxPayKit.xmlToMap(result));
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 请求单次分账
*/
@RequestMapping(value = "/profitSharing", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String profitSharing(@RequestParam(value = "transactionId") String transactionId) {
List<ReceiverModel> list = new ArrayList<>();
list.add(ReceiverModel.builder()
.type("PERSONAL_OPENID")
.account("openid")
.amount(66)
.description("IJPay 分账")
.build());
Map<String, String> params = ProfitSharingModel.builder()
.mch_id(wxPayBean.getMchId())
.appid(wxPayBean.getAppId())
.nonce_str(WxPayKit.generateStr())
.transaction_id(transactionId)
.out_order_no(WxPayKit.generateStr())
.receivers(JSON.toJSONString(list))
.build()
.createSign(wxPayBean.getPartnerKey(), SignType.HMACSHA256);
log.info("请求参数:{}", WxPayKit.toXml(params));
String result = WxPayApi.profitSharing(params, wxPayBean.getCertPath(), wxPayBean.getMchId());
log.info("请求结果:{}", result);
return JSON.toJSONString(WxPayKit.xmlToMap(result));
}
/**
* 微信退款
*/
@RequestMapping(value = "/refund", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String refund(@RequestParam(value = "transactionId", required = false) String transactionId,
@RequestParam(value = "outTradeNo", required = false) String outTradeNo) {
try {
log.info("transactionId: {} outTradeNo:{}", transactionId, outTradeNo);
if (StrUtil.isBlank(outTradeNo) && StrUtil.isBlank(transactionId)) {
return "transactionId、out_trade_no二选一";
}
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = RefundModel.builder()
.appid(wxPayApiConfig.getAppId())
.mch_id(wxPayApiConfig.getMchId())
.nonce_str(WxPayKit.generateStr())
.transaction_id(transactionId)
.out_trade_no(outTradeNo)
.out_refund_no(WxPayKit.generateStr())
.total_fee("1")
.refund_fee("1")
.notify_url(refundNotifyUrl)
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);
String refundStr = WxPayApi.orderRefund(false, params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
log.info("refundStr: {}", refundStr);
return refundStr;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 微信退款查询
*/
@RequestMapping(value = "/refundQuery", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String refundQuery(@RequestParam("transactionId") String transactionId,
@RequestParam("out_trade_no") String outTradeNo,
@RequestParam("out_refund_no") String outRefundNo,
@RequestParam("refund_id") String refundId) {
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = RefundQueryModel.builder()
.appid(wxPayApiConfig.getAppId())
.mch_id(wxPayApiConfig.getMchId())
.nonce_str(WxPayKit.generateStr())
.transaction_id(transactionId)
.out_trade_no(outTradeNo)
.out_refund_no(outRefundNo)
.refund_id(refundId)
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);
return WxPayApi.orderRefundQuery(false, params);
}
/**
* 退款通知
*/
@RequestMapping(value = "/refundNotify", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String refundNotify(HttpServletRequest request) {
String xmlMsg = HttpKit.readData(request);
log.info("退款通知=" + xmlMsg);
Map<String, String> params = WxPayKit.xmlToMap(xmlMsg);
String returnCode = params.get("return_code");
// 注意重复通知的情况，同一订单号可能收到多次通知，请注意一定先判断订单状态
if (WxPayKit.codeIsOk(returnCode)) {
String reqInfo = params.get("req_info");
String decryptData = WxPayKit.decryptData(reqInfo, WxPayApiConfigKit.getWxPayApiConfig().getPartnerKey());
log.info("退款通知解密后的数据=" + decryptData);
// 更新订单信息
// 发送通知等
Map<String, String> xml = new HashMap<String, String>(2);
xml.put("return_code", "SUCCESS");
xml.put("return_msg", "OK");
return WxPayKit.toXml(xml);
}
return null;
}
@RequestMapping(value = "/sendRedPack", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String sendRedPack(HttpServletRequest request, @RequestParam("openId") String openId) {
try {
String ip = IpKit.getRealIp(request);
if (StrUtil.isBlank(ip)) {
ip = "127.0.0.1";
}
WxPayApiConfig wxPayApiConfig = getWxPayApiConfig();
Map<String, String> params = SendRedPackModel.builder()
.nonce_str(WxPayKit.generateStr())
.mch_billno(WxPayKit.generateStr())
.mch_id(wxPayApiConfig.getMchId())
.wxappid(wxPayApiConfig.getAppId())
.send_name("IJPay 红包测试")
.re_openid(openId)
.total_amount("1000")
.total_num("1")
.wishing("感谢您使用 IJPay")
.client_ip(ip)
.act_name("感恩回馈活动")
.remark("点 start 送红包，快来抢!")
.build()
.createSign(wxPayApiConfig.getPartnerKey(), SignType.MD5);
String result = WxPayApi.sendRedPack(params, wxPayApiConfig.getCertPath(), wxPayApiConfig.getMchId());
System.out.println("发送红包结果:" + result);
Map<String, String> map = WxPayKit.xmlToMap(result);
return JSON.toJSONString(map);
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 异步通知
* 这里面可以写判断支付成功之后的及具体业务需求
*/
@RequestMapping(value = "/payNotify", method = {RequestMethod.POST, RequestMethod.GET})
@ResponseBody
public String payNotify(HttpServletRequest request) {
String xmlMsg = HttpKit.readData(request);
log.info("支付通知=" + xmlMsg);
Map<String, String> params = WxPayKit.xmlToMap(xmlMsg);
String returnCode = params.get("return_code");
// 注意重复通知的情况，同一订单号可能收到多次通知，请注意一定先判断订单状态
// 注意此处签名方式需与统一下单的签名类型一致
if (WxPayKit.verifyNotify(params, getWxPayApiConfig().getPartnerKey(), SignType.HMACSHA256)) {
if (WxPayKit.codeIsOk(returnCode)) {
// 更新订单信息
// 发送通知等
Map<String, String> xml = new HashMap<String, String>(2);
xml.put("return_code", "SUCCESS");
xml.put("return_msg", "OK");
return WxPayKit.toXml(xml);
}
}
return null;
}
}
这里的上方代码中有很多个支付方式, 根据具体需要的支付进行选择性添加接口, 这里仅仅是全部展示出来了…建议不要太多冗余接口
如果需要多种支付同时走一个接口的情况(PS这里不建议但是会遇见这种不可避免的问题就是模块没有分清的情况下)
添加AbstractWxPayApiController
package com.ruoyi.web.controller.pay;
import com.ijpay.wxpay.WxPayApiConfig;
/**
* @author Javen
*/
public abstract class AbstractWxPayApiController {
/**
* 获取微信支付配置
*
* @return {@link WxPayApiConfig} 微信支付配置
*/
public abstract WxPayApiConfig getApiConfig();
}
添加WxPayBean
package com.ruoyi.web.common.pay;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.PropertySource;
import org.springframework.stereotype.Component;
/**
* <p>IJPay 让支付触手可及，封装了微信支付、支付宝支付、银联支付常用的支付方式以及各种常用的接口。</p>
*
* <p>不依赖任何第三方 mvc 框架，仅仅作为工具使用简单快速完成支付模块的开发，可轻松嵌入到任何系统里。 </p>
*
* <p>IJPay 交流群: 723992875</p>
*
* <p>Node.js 版: https://gitee.com/javen205/TNWX</p>
*
* <p>微信配置 Bean</p>
*
* @author Javen
*/
@Component
@PropertySource("classpath:/wxpay.properties")
@ConfigurationProperties(prefix = "wxpay")
public class WxPayBean {
private String appId;
private String appSecret;
private String mchId;
private String partnerKey;
private String certPath;
private String domain;
public String getAppId() {
return appId;
}
public void setAppId(String appId) {
this.appId = appId;
}
public String getAppSecret() {
return appSecret;
}
public void setAppSecret(String appSecret) {
this.appSecret = appSecret;
}
public String getMchId() {
return mchId;
}
public void setMchId(String mchId) {
this.mchId = mchId;
}
public String getPartnerKey() {
return partnerKey;
}
public void setPartnerKey(String partnerKey) {
this.partnerKey = partnerKey;
}
public String getCertPath() {
return certPath;
}
public void setCertPath(String certPath) {
this.certPath = certPath;
}
public String getDomain() {
return domain;
}
public void setDomain(String domain) {
this.domain = domain;
}
@Override
public String toString() {
return "WxPayBean [appId=" + appId + ", appSecret=" + appSecret + ", mchId=" + mchId + ", partnerKey="
+ partnerKey + ", certPath=" + certPath + ", domain=" + domain + "]";
}
}
在resources中添加production文件夹中添加文件名为wxpay.properties下方是内容
wxpay.appId=应用编号
wxpay.appSecret=appSecret 是 appId 对应的接口密码，微信公众号授权获取用户 openId 时使用
wxpay.mchId=微信支付商户号
wxpay.partnerKey=API 密钥
wxpay.certPath=apiclient_cert.p1 证书路径，在微信商户后台下载
wxpay.domain=外网访问项目的域名，支付通知中会使用
添加下方是是微信H5才需要的对应代码(下面简介文字)
下方的代码块内容仅仅对于WxPayController的下面的方法, 如果不需要下面方法的的方式支付则不需要添加下方代码,当然记得把对应WxPayController中代码删除
/**
* 微信H5 支付
* 注意：必须再web页面中发起支付且域名已添加到开发配置中
*/
@RequestMapping(value = “/wapPay”, method = {RequestMethod.POST, RequestMethod.GET})
public void wapPay(HttpServletRequest request, HttpServletResponse response) throws IOException {
package com.ijpay.demo.entity;
import com.alibaba.fastjson.JSON;
/**
* @author Javen
*/
public class H5SceneInfo {
private H5 h5_info;
public H5 getH5Info() {
return h5_info;
}
public void setH5Info(H5 h5_info) {
this.h5_info = h5_info;
}
@Override
public String toString() {
return JSON.toJSONString(this);
}
public static class H5 {
private String type;
private String app_name;
private String bundle_id;
private String package_name;
private String wap_url;
private String wap_name;
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
public String getApp_name() {
return app_name;
}
public void setApp_name(String app_name) {
this.app_name = app_name;
}
public String getBundle_id() {
return bundle_id;
}
public void setBundle_id(String bundle_id) {
this.bundle_id = bundle_id;
}
public String getPackage_name() {
return package_name;
}
public void setPackage_name(String package_name) {
this.package_name = package_name;
}
public String getWap_url() {
return wap_url;
}
public void setWap_url(String wap_url) {
this.wap_url = wap_url;
}
public String getWap_name() {
return wap_name;
}
public void setWap_name(String wap_name) {
this.wap_name = wap_name;
}
}
}
类似资料：