team/hm-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
liangzai
2025-11-19 19:50:16 +08:00
parent 35094559a0
commit 02c8ace29b
1 changed files with 2 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
app/main/api/internal/service/wechatpayService.go
View File

@@ -137,15 +137,10 @@ func newWechatPayServiceWithWxPayPubKey(c config.Config, userAuthModel model.Use
} }
// 初始化 notify.Handler // 初始化 notify.Handler
// 使用公钥方式时，certificateVisitor 可能为 nil，直接使用公钥验证器 // 使用微信支付公钥方式时，使用 NewSHA256WithRSAPubkeyVerifier
notifyHandler := notify.NewNotifyHandler( notifyHandler := notify.NewNotifyHandler(
mchAPIv3Key, mchAPIv3Key,
verifiers.NewSHA256WithRSACombinedVerifier(nil, mchPublicKeyID, *mchPublicKey)) verifiers.NewSHA256WithRSAPubkeyVerifier(mchPublicKeyID, *mchPublicKey))
if notifyHandler == nil {
logx.Errorf("创建 notifyHandler 失败")
panic("初始化失败，服务停止: notifyHandler 为 nil")
}
logx.Infof("微信支付客户端初始化成功(微信支付公钥方式)") logx.Infof("微信支付客户端初始化成功(微信支付公钥方式)")
return &WechatPayService{ return &WechatPayService{
@@ -299,9 +294,6 @@ func (w *WechatPayService) CreateWechatOrder(ctx context.Context, amount float64
// HandleWechatPayNotification 处理微信支付回调 // HandleWechatPayNotification 处理微信支付回调
func (w *WechatPayService) HandleWechatPayNotification(ctx context.Context, req *http.Request) (*payments.Transaction, error) { func (w *WechatPayService) HandleWechatPayNotification(ctx context.Context, req *http.Request) (*payments.Transaction, error) {
if w.notifyHandler == nil {
return nil, fmt.Errorf("微信支付通知处理器未初始化")
}
transaction := new(payments.Transaction) transaction := new(payments.Transaction)
_, err := w.notifyHandler.ParseNotifyRequest(ctx, req, transaction) _, err := w.notifyHandler.ParseNotifyRequest(ctx, req, transaction)
if err != nil { if err != nil {
@@ -313,9 +305,6 @@ func (w *WechatPayService) HandleWechatPayNotification(ctx context.Context, req
// HandleRefundNotification 处理微信退款回调 // HandleRefundNotification 处理微信退款回调
func (w *WechatPayService) HandleRefundNotification(ctx context.Context, req *http.Request) (*refunddomestic.Refund, error) { func (w *WechatPayService) HandleRefundNotification(ctx context.Context, req *http.Request) (*refunddomestic.Refund, error) {
if w.notifyHandler == nil {
return nil, fmt.Errorf("微信支付通知处理器未初始化")
}
refund := new(refunddomestic.Refund) refund := new(refunddomestic.Refund)
_, err := w.notifyHandler.ParseNotifyRequest(ctx, req, refund) _, err := w.notifyHandler.ParseNotifyRequest(ctx, req, refund)
if err != nil { if err != nil {