rainbowfast/muscipro
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

vip

Browse Source
This commit is contained in:
menxipeng
2025-11-09 23:28:29 +08:00
parent 9f87272433
commit 0033f7875a
7 changed files with 241 additions and 74 deletions
Download Patch File Download Diff File Expand all files Collapse all files

63
ruoyi-system/src/main/java/com/ruoyi/system/util/AppleyPay.java
View File

@@ -82,8 +82,8 @@ public class AppleyPay {
* @param receipt 苹果传递前端给的值
* @param chooseEnv 是否时测试环境
*/
public ShopUser setIapCertificate(Long userId, String receipt, OrderInfo orderInfo,boolean chooseEnv) {
log.info("IOS端发送的购买凭证。数据有 userId = {},receipt = {},chooseEnv = {}",userId,receipt,chooseEnv);
public ShopUser setIapCertificate(Long userId, String receipt, OrderInfo orderInfo, boolean chooseEnv) {
log.info("IOS端发送的购买凭证。数据有 userId = {},receipt = {},chooseEnv = {}", userId, receipt, chooseEnv);
if (userId == null || StringUtils.isEmpty(receipt)) {
log.error("用户ID 或者 receipt为空");
return null;
@@ -92,7 +92,7 @@ public class AppleyPay {
url = chooseEnv == true ? certificateUrl : certificateUrlTest;
final String certificateCode = receipt;
if (StringUtils.isNotEmpty(certificateCode)) {
return sendHttpsCoon(url, certificateCode, userId,orderInfo);
return sendHttpsCoon(url, certificateCode, userId, orderInfo);
} else {
log.error("用户ID 或者 receipt为空");
return null;
@@ -101,15 +101,15 @@ public class AppleyPay {
/**
* 发送请求 向苹果发起验证支付请求是否有效：本方法有认证方法进行调用
*
* <p>
* 支持的订阅产品ID：
* - com.mingyue.product.month (月付)
* - com.mingyue.product.quarterly (季付)
* - com.mingyue.product.semiAnnual (半年付)
* - com.mingyue.product.annual (年付)
*
* @param url 支付的环境校验地址
* @param code 接口传递的 receipt
* @param url 支付的环境校验地址
* @param code 接口传递的 receipt
* @param userId 用户ID
* @return 结果
*/
@@ -177,14 +177,14 @@ public class AppleyPay {
// 处理 latest_receipt_info（可能是数组或单个对象）
InAppTransaction latestTransaction = null;
if (latestReceiptInfoObj instanceof JSONArray) {
// 如果是数组，取最后一个（最新的交易）
// 如果是数组，取第一个（最新的交易）
JSONArray receiptArray = (JSONArray) latestReceiptInfoObj;
if (receiptArray.isEmpty()) {
log.error("latest_receipt_info 数组为空");
return null;
}
// 获取最新的交易记录（数组最后一个元素）
Object lastReceipt = receiptArray.get(receiptArray.size() - 1);
Object lastReceipt = receiptArray.get(0);
latestTransaction = JSONUtil.toBean(lastReceipt.toString(), InAppTransaction.class);
} else {
// 如果是单个对象
@@ -200,11 +200,12 @@ public class AppleyPay {
String transactionId = latestTransaction.getTransactionId();
String productId = latestTransaction.getProductId();
// 获取过期时间（北京时间）
Long expiresDateMsInBeijing = latestTransaction.getExpiresDateMsInBeijing();
String expiresData = latestTransaction.getExpiresDate();
//long expiresDateMsInBeijing = StringUtils.convertToTimestampMillis(expiresData);
// 查询交易信息是否已经存在
OrderInfo selectOrderInfo = orderInfoMapper.selectByTradeNo(transactionId);
if (selectOrderInfo != null){
if (selectOrderInfo != null) {
log.warn("交易ID {} 已存在，可能重复处理。用户ID: {}", transactionId, userId);
// 交易信息已存在
return null;
@@ -230,15 +231,14 @@ public class AppleyPay {
}
}
// 验证订阅是否过期（对于订阅类型，使用北京时间）
if (expiresDateMsInBeijing != null) {
long currentTimestamp = System.currentTimeMillis();
if (expiresDateMsInBeijing < currentTimestamp) {
log.warn("订阅已过期。交易ID: {}, 过期时间(北京时间): {}, 当前时间: {}",
transactionId, new Date(expiresDateMsInBeijing), new Date(currentTimestamp));
return null;
}
}
// 验证订阅是否过期（对于订阅类型，使用北京时间）TODO：// 待修改
long currentTimestamp = System.currentTimeMillis();
// if (expiresDateMsInBeijing < currentTimestamp) {
// log.warn("订阅已过期。交易ID: {}, 过期时间(北京时间): {}, 当前时间: {}",
// transactionId, new Date(expiresDateMsInBeijing), new Date(currentTimestamp));
// return null;
// }
// 根据产品ID处理不同的订阅类型
String packageType = null;
@@ -251,7 +251,7 @@ public class AppleyPay {
// 创建或更新订单记录
OrderInfo orderInfo = null;
boolean isNewOrder = false; // 标记是否为新订单
// 如果 orderParam 为 null 或 orderId 为空，需要创建新订单
if (orderParam == null || orderParam.getOrderId() == null) {
// 创建新订单
@@ -286,7 +286,7 @@ public class AppleyPay {
orderInfo.setPayTime(DateUtils.getNowDate());
orderInfo.setStartTime(startTime);
orderInfo.setTradeNo(transactionId);
orderInfo.setCallbackContent(transactionId); // 保存交易ID
orderInfo.setCallbackContent(latestTransaction.getOriginalTransactionId()); // 保存交易ID
orderInfo.setCallTime(DateUtils.getNowDate());
orderInfo.setUpdateTime(DateUtils.getNowDate());
@@ -301,7 +301,7 @@ public class AppleyPay {
Date endTime = calculateEndTime(startTime, packageType);
orderInfo.setEndTime(endTime);
orderInfo.setPackageType(packageType);
} else if ("com.mingyue.product.quarterly".equals(productId)) {
} else if ("com.mingyue.item.quarterly".equals(productId)) {
// 季付
packageType = "2";
orderName = "VIP会员包季度";
@@ -312,7 +312,7 @@ public class AppleyPay {
orderInfo.setOrderName(orderName);
orderInfo.setEndTime(endTime);
orderInfo.setPackageType(packageType);
} else if ("com.mingyue.product.semiAnnual".equals(productId)) {
} else if ("com.mingyue.item.semiAnnual".equals(productId)) {
// 半年付
packageType = "3";
orderName = "VIP会员包半年";
@@ -323,7 +323,7 @@ public class AppleyPay {
orderInfo.setOrderName(orderName);
orderInfo.setEndTime(endTime);
orderInfo.setPackageType(packageType);
} else if ("com.mingyue.product.annual".equals(productId)) {
} else if ("com.mingyue.item.annual".equals(productId)) {
// 年付
packageType = "4";
orderName = "VIP会员包年";
@@ -338,14 +338,14 @@ public class AppleyPay {
log.error("用户ID：{}, 未知的产品ID: {}", userId, productId);
return null;
}
// 根据是否为新订单选择插入或更新
if (isNewOrder) {
orderInfoService.insertOrderInfo(orderInfo);
} else {
orderInfoService.updateOrderInfo(orderInfo);
}
// 更新用户VIP时间
return shopUserService.updateShopUserVipTime(userId, packageType);
} catch (Exception e) {
@@ -357,7 +357,7 @@ public class AppleyPay {
/**
* 根据套餐类型计算结束时间
*
* @param startTime 开始时间
* @param startTime 开始时间
* @param packageType 套餐类型：1-月付, 3-季付, 6-半年付, 12-年付
* @return 结束时间
*/
@@ -423,7 +423,6 @@ public class AppleyPay {
}
}
/**
* 注意：下面代码跟苹果支付业务无关。
* 这里的code 是前端请求苹果，苹果给前端的一个密钥（如果我们通过base64解密后，可获得signature、purchase-info、environment、pod、signing-status）这个密钥用于告诉Java服务器 想苹果服务器校验订单是否成功的参数
@@ -474,8 +473,12 @@ public class AppleyPay {
// 添加padding
switch (base64.length() % 4) {
case 2: base64 += "=="; break;
case 3: base64 += "="; break;
case 2:
base64 += "==";
break;
case 3:
base64 += "=";
break;
}
byte[] decodedBytes = Base64.decode(base64);

6
ruoyi-system/src/main/java/com/ruoyi/system/util/InAppTransaction.java
View File

@@ -1,5 +1,6 @@
package com.ruoyi.system.util;
import com.ruoyi.common.utils.StringUtils;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
@@ -129,6 +130,11 @@ public class InAppTransaction {
}
}
public static void main(String[] args) {
String expiresDateMs = "2025-11-06 13:54:04 Etc/GMT";
System.out.println(StringUtils.convertToTimestampMillis(expiresDateMs));
}
/**
* 获取购买日期时间戳（北京时间，毫秒）
* 将太平洋时间转换为北京时间

106
ruoyi-system/src/main/java/com/ruoyi/system/util/WeChatAppServiceExtensionExample.java Normal file
View File

@@ -0,0 +1,106 @@
package com.ruoyi.system.util;
import com.wechat.pay.java.core.Config;
import com.wechat.pay.java.core.RSAAutoCertificateConfig;
import com.wechat.pay.java.core.exception.HttpException;
import com.wechat.pay.java.core.exception.MalformedMessageException;
import com.wechat.pay.java.core.exception.ServiceException;
import com.wechat.pay.java.service.payments.app.AppServiceExtension;
import com.wechat.pay.java.service.payments.app.model.CloseOrderRequest;
import com.wechat.pay.java.service.payments.app.model.PrepayRequest;
import com.wechat.pay.java.service.payments.app.model.PrepayWithRequestPaymentResponse;
import com.wechat.pay.java.service.payments.app.model.QueryOrderByIdRequest;
import com.wechat.pay.java.service.payments.app.model.QueryOrderByOutTradeNoRequest;
import com.wechat.pay.java.service.payments.model.Transaction;
public class WeChatAppServiceExtensionExample {
/**
* 商户号
*/
public static String merchantId = "190000****";
/**
* 商户API私钥路径
*/
public static String privateKeyPath = "/Users/yourname/your/path/apiclient_key.pem";
/**
* 商户证书序列号
*/
public static String merchantSerialNumber = "5157F09EFDC096DE15EBE81A47057A72********";
/**
* 商户APIV3密钥
*/
public static String apiV3Key = "...";
public static AppServiceExtension service;
public static void main(String[] args) {
// 初始化商户配置
Config config =
new RSAAutoCertificateConfig.Builder()
.merchantId(merchantId)
// 使用 com.wechat.pay.java.core.util 中的函数从本地文件中加载商户私钥，商户私钥会用来生成请求的签名
.privateKeyFromPath(privateKeyPath)
.merchantSerialNumber(merchantSerialNumber)
.apiV3Key(apiV3Key)
.build();
// 初始化服务
service = new AppServiceExtension.Builder().config(config).build();
try {
// ... 调用接口
PrepayWithRequestPaymentResponse response = prepayWithRequestPayment();
System.out.println(response);
} catch (HttpException e) { // 发送HTTP请求失败
// 调用e.getHttpRequest()获取请求打印日志或上报监控，更多方法见HttpException定义
} catch (ServiceException e) { // 服务返回状态小于200或大于等于300，例如500
// 调用e.getResponseBody()获取返回体打印日志或上报监控，更多方法见ServiceException定义
} catch (MalformedMessageException e) { // 服务返回成功，返回体类型不合法，或者解析返回体失败
// 调用e.getMessage()获取信息打印日志或上报监控，更多方法见MalformedMessageException定义
}
}
/**
* 关闭订单
*/
public static void closeOrder() {
CloseOrderRequest request = new CloseOrderRequest();
// 调用request.setXxx(val)设置所需参数，具体参数可见Request定义
// 调用接口
service.closeOrder(request);
}
/**
* APP支付下单，并返回APP调起支付数据
*/
public static PrepayWithRequestPaymentResponse prepayWithRequestPayment() {
PrepayRequest request = new PrepayRequest();
// 调用request.setXxx(val)设置所需参数，具体参数可见Request定义
// 调用接口
return service.prepayWithRequestPayment(request);
}
/**
* 微信支付订单号查询订单
*/
public static Transaction queryOrderById() {
QueryOrderByIdRequest request = new QueryOrderByIdRequest();
// 调用request.setXxx(val)设置所需参数，具体参数可见Request定义
// 调用接口
return service.queryOrderById(request);
}
/**
* 商户订单号查询订单
*/
public static Transaction queryOrderByOutTradeNo() {
QueryOrderByOutTradeNoRequest request = new QueryOrderByOutTradeNoRequest();
// 调用request.setXxx(val)设置所需参数，具体参数可见Request定义
// 调用接口
return service.queryOrderByOutTradeNo(request);
}
}

2
ruoyi-system/src/main/resources/mapper/system/ShopUserMapper.xml
View File

@@ -69,6 +69,8 @@
<result property="updateTime" column="update_time" />
<result property="isDel" column="is_del" />
<result property="descinfo" column="descinfo" />
<result property="vipStartTime" column="vip_start_time" />
<result property="vipEndTime" column="vip_end_time" />
</resultMap>
<sql id="selectShopUserVo">