fix(shop-order): 修复支付回调签名验证失败及状态更新问题
- 修正导入 Transaction 类为直连商户模式路径，解决签名验证失败 - 新增按 mchId 缓存 NotificationConfig，避免重复拉取平台证书和重复初始化 - 更新 ShopOrderMapper.xml，增加 update_time 和 expiration_time 字段更新 - 删除 ShopOrderServiceImpl.updateByOutTradeNo 中重置 expirationTime 的代码，确保回调传递值生效 - 补充日志，完善异步通知证书配置流程监控
This commit is contained in:
45
.workbuddy/memory/2026-04-16.md
Normal file
45
.workbuddy/memory/2026-04-16.md
Normal file
@@ -0,0 +1,45 @@
|
||||
# 2026-04-16 工作记录
|
||||
|
||||
## 支付回调状态不更新问题诊断与修复
|
||||
|
||||
**问题接口**: `POST /api/shop/shop-order/notify/{tenantId}`
|
||||
|
||||
### 发现的 Bug
|
||||
|
||||
1. **根因 Bug**：`ShopOrderServiceImpl.updateByOutTradeNo()` 第837行有 `order.setExpirationTime(null)`，强制覆盖了 Controller 中设置的 `expirationTime`（`LocalDateTime.now().plusYears(10)`），导致 XML 中 expirationTime 条件不生效。**已修复**：删除了该行。
|
||||
|
||||
2. **XML 缺少 `update_time`**：`ShopOrderMapper.xml` 的 `updateByOutTradeNo` SQL 的 `<set>` 块中没有 `update_time = NOW()` 和 `expiration_time` 字段。**已修复**：新增了这两个字段更新。
|
||||
|
||||
3. **回调地址路由问题**：Controller 路由为 `/notify/{tenantId}`，但测试访问的 `/notify`（无 tenantId）不存在，返回 fail。正确回调地址格式为 `https://glt-api.websoft.top/api/shop/shop-order/notify/{tenantId}`（需带租户ID）。**待检查**：数据库 Payment 表的 `notify_url` 字段是否正确配置了带 tenantId 的完整路径。
|
||||
|
||||
### 修复文件
|
||||
- `src/main/java/com/gxwebsoft/shop/service/impl/ShopOrderServiceImpl.java`
|
||||
- `src/main/java/com/gxwebsoft/shop/mapper/xml/ShopOrderMapper.xml`
|
||||
|
||||
---
|
||||
|
||||
## 支付回调签名验证失败：Transaction 类错误（00:29修复）
|
||||
|
||||
**错误日志关键信息**：
|
||||
```
|
||||
signature verification failed, signType[WECHATPAY2-SHA256-RSA2048]
|
||||
serial[test] message[test\ntest\n{"test":"test"}] sign[test]
|
||||
```
|
||||
|
||||
### 根本原因（最致命）
|
||||
|
||||
`ShopOrderController.java` 导入了 **服务商模式** 的 Transaction 类：
|
||||
```java
|
||||
// 错误（服务商模式）
|
||||
import com.wechat.pay.java.service.partnerpayments.jsapi.model.Transaction;
|
||||
```
|
||||
而 `ShopOrderServiceImpl.java` 下单时用的是**直连商户模式**：
|
||||
```java
|
||||
// 正确（直连商户模式）
|
||||
import com.wechat.pay.java.service.payments.model.Transaction;
|
||||
```
|
||||
两个 Transaction 包路径不同，字段结构有差异（服务商 Transaction 有 spAppid/spMchid 等字段），用错误的类解析回调会导致字段映射失败，交易状态无法正确读取。**已修复**：改为正确的直连商户模式 Transaction。
|
||||
|
||||
### 次要原因
|
||||
|
||||
`RSAAutoCertificateConfig` 每次回调都重新 `build()`，SDK 内部会发一次 `serial=test` 的探测验签，网络问题或并发场景下可能导致首次回调失败。**已优化**：添加 `notifyConfigCache`（ConcurrentHashMap）按 mchId 缓存 config，避免重复初始化。
|
||||
5
.workbuddy/settings.local.json
Normal file
5
.workbuddy/settings.local.json
Normal file
@@ -0,0 +1,5 @@
|
||||
{
|
||||
"enabledPlugins": {
|
||||
"modern-webapp@cb_teams_marketplace": true
|
||||
}
|
||||
}
|
||||
@@ -35,7 +35,7 @@ import com.wechat.pay.java.core.notification.NotificationConfig;
|
||||
import com.wechat.pay.java.core.notification.NotificationParser;
|
||||
import com.wechat.pay.java.core.notification.RequestParam;
|
||||
import com.wechat.pay.java.core.RSAAutoCertificateConfig;
|
||||
import com.wechat.pay.java.service.partnerpayments.jsapi.model.Transaction;
|
||||
import com.wechat.pay.java.service.payments.model.Transaction;
|
||||
import io.swagger.v3.oas.annotations.tags.Tag;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import io.swagger.v3.oas.annotations.Operation;
|
||||
@@ -53,6 +53,7 @@ import java.time.LocalDateTime;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Objects;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
|
||||
/**
|
||||
* 订单控制器
|
||||
@@ -65,6 +66,8 @@ import java.util.Objects;
|
||||
@RequestMapping("/api/shop/shop-order")
|
||||
public class ShopOrderController extends BaseController {
|
||||
private static final Logger logger = LoggerFactory.getLogger(ShopOrderController.class);
|
||||
/** 按商户号缓存 NotificationConfig，避免每次回调都重新拉取平台证书 */
|
||||
private final ConcurrentHashMap<String, NotificationConfig> notifyConfigCache = new ConcurrentHashMap<>();
|
||||
@Resource
|
||||
private ShopOrderService shopOrderService;
|
||||
@Resource
|
||||
@@ -791,90 +794,100 @@ public class ShopOrderController extends BaseController {
|
||||
.body(body)
|
||||
.build();
|
||||
|
||||
// 创建通知配置 - 使用与下单方法相同的证书配置逻辑
|
||||
// 创建通知配置 - 使用与下单方法相同的证书配置逻辑（按 mchId 缓存，避免重复拉取平台证书）
|
||||
NotificationConfig config;
|
||||
try {
|
||||
if (active.equals("dev")) {
|
||||
// 开发环境 - 构建包含租户号的私钥路径
|
||||
String tenantCertPath = "dev/wechat/" + tenantId;
|
||||
String privateKeyPath = tenantCertPath + "/" + certConfig.getWechatPay().getDev().getPrivateKeyFile();
|
||||
final String mchId = payment.getMchId();
|
||||
config = notifyConfigCache.get(mchId);
|
||||
if (config == null) {
|
||||
try {
|
||||
NotificationConfig newConfig;
|
||||
if (active.equals("dev")) {
|
||||
// 开发环境 - 构建包含租户号的私钥路径
|
||||
String tenantCertPath = "dev/wechat/" + tenantId;
|
||||
String privateKeyPath = tenantCertPath + "/" + certConfig.getWechatPay().getDev().getPrivateKeyFile();
|
||||
|
||||
logger.info("开发环境异步通知证书路径: {}", privateKeyPath);
|
||||
logger.info("租户ID: {}, 证书目录: {}", tenantId, tenantCertPath);
|
||||
logger.info("开发环境异步通知证书路径: {}", privateKeyPath);
|
||||
logger.info("租户ID: {}, 证书目录: {}", tenantId, tenantCertPath);
|
||||
|
||||
// 检查证书文件是否存在
|
||||
if (!certificateLoader.certificateExists(privateKeyPath)) {
|
||||
logger.error("证书文件不存在: {}", privateKeyPath);
|
||||
throw new RuntimeException("证书文件不存在: " + privateKeyPath);
|
||||
// 检查证书文件是否存在
|
||||
if (!certificateLoader.certificateExists(privateKeyPath)) {
|
||||
logger.error("证书文件不存在: {}", privateKeyPath);
|
||||
throw new RuntimeException("证书文件不存在: " + privateKeyPath);
|
||||
}
|
||||
|
||||
String privateKey = certificateLoader.loadCertificatePath(privateKeyPath);
|
||||
|
||||
// 使用验证器获取有效的 APIv3 密钥
|
||||
String apiV3Key = wechatPayConfigValidator.getValidApiV3Key(payment);
|
||||
|
||||
logger.info("私钥文件加载成功: {}", privateKey);
|
||||
logger.info("使用APIv3密钥来源: {}", payment.getApiKey() != null && !payment.getApiKey().trim().isEmpty() ? "数据库配置" : "配置文件默认");
|
||||
logger.info("APIv3密钥长度: {}", apiV3Key != null ? apiV3Key.length() : 0);
|
||||
logger.info("商户证书序列号: {}", payment.getMerchantSerialNumber());
|
||||
|
||||
// 使用自动证书配置
|
||||
newConfig = new RSAAutoCertificateConfig.Builder()
|
||||
.merchantId(mchId)
|
||||
.privateKeyFromPath(privateKey)
|
||||
.merchantSerialNumber(payment.getMerchantSerialNumber())
|
||||
.apiV3Key(apiV3Key)
|
||||
.build();
|
||||
|
||||
logger.info("✅ 开发环境使用自动证书配置创建通知解析器成功");
|
||||
} else {
|
||||
// 生产环境 - 使用自动证书配置
|
||||
final String certRootPath = certConfig.getCertRootPath();
|
||||
logger.info("生产环境证书根路径: {}", certRootPath);
|
||||
|
||||
String privateKeyRelativePath = payment.getApiclientKey();
|
||||
logger.info("数据库中的私钥相对路径: {}", privateKeyRelativePath);
|
||||
|
||||
// 生产环境已经没有/file目录，所有路径都直接拼接到根路径
|
||||
String privateKeyFullPath;
|
||||
// 处理数据库中可能存在的历史路径格式
|
||||
String cleanPath = privateKeyRelativePath;
|
||||
if (privateKeyRelativePath.startsWith("/file/")) {
|
||||
// 去掉历史的 /file/ 前缀
|
||||
cleanPath = privateKeyRelativePath.substring(6);
|
||||
} else if (privateKeyRelativePath.startsWith("file/")) {
|
||||
// 去掉历史的 file/ 前缀
|
||||
cleanPath = privateKeyRelativePath.substring(5);
|
||||
}
|
||||
// 确保路径以 / 开头
|
||||
if (!cleanPath.startsWith("/")) {
|
||||
cleanPath = "/" + cleanPath;
|
||||
}
|
||||
privateKeyFullPath = certRootPath + cleanPath;
|
||||
|
||||
logger.info("生产环境私钥完整路径: {}", privateKeyFullPath);
|
||||
String privateKey = certificateLoader.loadCertificatePath(privateKeyFullPath);
|
||||
String apiV3Key = payment.getApiKey();
|
||||
|
||||
// 使用自动证书配置
|
||||
newConfig = new RSAAutoCertificateConfig.Builder()
|
||||
.merchantId(mchId)
|
||||
.privateKeyFromPath(privateKey)
|
||||
.merchantSerialNumber(payment.getMerchantSerialNumber())
|
||||
.apiV3Key(apiV3Key)
|
||||
.build();
|
||||
|
||||
logger.info("✅ 生产环境使用自动证书配置创建通知解析器成功");
|
||||
}
|
||||
|
||||
String privateKey = certificateLoader.loadCertificatePath(privateKeyPath);
|
||||
|
||||
// 使用验证器获取有效的 APIv3 密钥
|
||||
String apiV3Key = wechatPayConfigValidator.getValidApiV3Key(payment);
|
||||
|
||||
logger.info("私钥文件加载成功: {}", privateKey);
|
||||
logger.info("使用APIv3密钥来源: {}", payment.getApiKey() != null && !payment.getApiKey().trim().isEmpty() ? "数据库配置" : "配置文件默认");
|
||||
logger.info("APIv3密钥长度: {}", apiV3Key != null ? apiV3Key.length() : 0);
|
||||
logger.info("商户证书序列号: {}", payment.getMerchantSerialNumber());
|
||||
|
||||
// 使用自动证书配置
|
||||
config = new RSAAutoCertificateConfig.Builder()
|
||||
.merchantId(payment.getMchId())
|
||||
.privateKeyFromPath(privateKey)
|
||||
.merchantSerialNumber(payment.getMerchantSerialNumber())
|
||||
.apiV3Key(apiV3Key)
|
||||
.build();
|
||||
|
||||
logger.info("✅ 开发环境使用自动证书配置创建通知解析器成功");
|
||||
} else {
|
||||
// 生产环境 - 使用自动证书配置
|
||||
final String certRootPath = certConfig.getCertRootPath();
|
||||
logger.info("生产环境证书根路径: {}", certRootPath);
|
||||
|
||||
String privateKeyRelativePath = payment.getApiclientKey();
|
||||
logger.info("数据库中的私钥相对路径: {}", privateKeyRelativePath);
|
||||
|
||||
// 生产环境已经没有/file目录，所有路径都直接拼接到根路径
|
||||
String privateKeyFullPath;
|
||||
// 处理数据库中可能存在的历史路径格式
|
||||
String cleanPath = privateKeyRelativePath;
|
||||
if (privateKeyRelativePath.startsWith("/file/")) {
|
||||
// 去掉历史的 /file/ 前缀
|
||||
cleanPath = privateKeyRelativePath.substring(6);
|
||||
} else if (privateKeyRelativePath.startsWith("file/")) {
|
||||
// 去掉历史的 file/ 前缀
|
||||
cleanPath = privateKeyRelativePath.substring(5);
|
||||
}
|
||||
// 确保路径以 / 开头
|
||||
if (!cleanPath.startsWith("/")) {
|
||||
cleanPath = "/" + cleanPath;
|
||||
}
|
||||
privateKeyFullPath = certRootPath + cleanPath;
|
||||
|
||||
logger.info("生产环境私钥完整路径: {}", privateKeyFullPath);
|
||||
String privateKey = certificateLoader.loadCertificatePath(privateKeyFullPath);
|
||||
String apiV3Key = payment.getApiKey();
|
||||
|
||||
// 使用自动证书配置
|
||||
config = new RSAAutoCertificateConfig.Builder()
|
||||
.merchantId(payment.getMchId())
|
||||
.privateKeyFromPath(privateKey)
|
||||
.merchantSerialNumber(payment.getMerchantSerialNumber())
|
||||
.apiV3Key(apiV3Key)
|
||||
.build();
|
||||
|
||||
logger.info("✅ 生产环境使用自动证书配置创建通知解析器成功");
|
||||
// 放入缓存
|
||||
notifyConfigCache.putIfAbsent(mchId, newConfig);
|
||||
config = notifyConfigCache.get(mchId);
|
||||
} catch (Exception e) {
|
||||
logger.error("❌ 创建通知配置失败 - 租户ID: {}, 商户号: {}", tenantId, mchId, e);
|
||||
logger.error("🔍 错误详情: {}", e.getMessage());
|
||||
logger.error("💡 请检查:");
|
||||
logger.error("1. 证书文件是否存在且路径正确");
|
||||
logger.error("2. APIv3密钥是否配置正确");
|
||||
logger.error("3. 商户证书序列号是否正确");
|
||||
logger.error("4. 网络连接是否正常");
|
||||
throw new RuntimeException("微信支付通知配置失败: " + e.getMessage(), e);
|
||||
}
|
||||
} catch (Exception e) {
|
||||
logger.error("❌ 创建通知配置失败 - 租户ID: {}, 商户号: {}", tenantId, payment.getMchId(), e);
|
||||
logger.error("🔍 错误详情: {}", e.getMessage());
|
||||
logger.error("💡 请检查:");
|
||||
logger.error("1. 证书文件是否存在且路径正确");
|
||||
logger.error("2. APIv3密钥是否配置正确");
|
||||
logger.error("3. 商户证书序列号是否正确");
|
||||
logger.error("4. 网络连接是否正常");
|
||||
throw new RuntimeException("微信支付通知配置失败: " + e.getMessage(), e);
|
||||
} else {
|
||||
logger.info("✅ 使用缓存的通知配置 - 商户号: {}", mchId);
|
||||
}
|
||||
|
||||
// 初始化 NotificationParser
|
||||
|
||||
@@ -329,6 +329,10 @@
|
||||
<update id="updateByOutTradeNo" parameterType="com.gxwebsoft.cms.entity.CmsWebsite">
|
||||
UPDATE shop_order
|
||||
<set>
|
||||
update_time = NOW(),
|
||||
<if test="param.expirationTime != null">
|
||||
expiration_time = #{param.expirationTime},
|
||||
</if>
|
||||
<if test="param.payType != null">
|
||||
pay_type = #{param.payType},
|
||||
</if>
|
||||
|
||||
@@ -834,7 +834,6 @@ public class ShopOrderServiceImpl extends ServiceImpl<ShopOrderMapper, ShopOrder
|
||||
|
||||
@Override
|
||||
public void updateByOutTradeNo(ShopOrder order) {
|
||||
order.setExpirationTime(null);
|
||||
baseMapper.updateByOutTradeNo(order);
|
||||
|
||||
// 处理支付成功后的业务逻辑
|
||||
|
||||
Reference in New Issue
Block a user