no message

partnerpay/Client.go

@@ -7,11 +7,16 @@ import (
 	"errors"
 	"fmt"
 	"github.com/wechatpay-apiv3/wechatpay-go/core"
+	"github.com/wechatpay-apiv3/wechatpay-go/core/auth/verifiers"
+	"github.com/wechatpay-apiv3/wechatpay-go/core/downloader"
+	"github.com/wechatpay-apiv3/wechatpay-go/core/notify"
 	"github.com/wechatpay-apiv3/wechatpay-go/core/option"
 	"github.com/wechatpay-apiv3/wechatpay-go/services/partnerpayments/jsapi"
+	"github.com/wechatpay-apiv3/wechatpay-go/services/payments"
 	"github.com/wechatpay-apiv3/wechatpay-go/utils"
 	"log"
 	"math/big"
+	"net/http"
 	"strings"
 	"time"
 )
@@ -88,6 +93,26 @@ func (s *WechatPartnerPayClient) getWxPayClient() *core.Client {
 	return wc
 }
 
+const (
+	TransactionSuccess = "TRANSACTION.SUCCESS"
+	RefundSuccess      = "REFUND.SUCCESS"
+)
+
+// AnalysisPayNotifyResult 解析支付通知结果
+func (s *WechatPartnerPayClient) AnalysisPayNotifyResult(request *http.Request) (*notify.Request, *payments.Transaction, error) {
+	certVisitor := downloader.MgrInstance().GetCertificateVisitor(*s.MchId)
+	handler, e := notify.NewRSANotifyHandler(*s.ApiKey, verifiers.NewSHA256WithRSAVerifier(certVisitor))
+	if e != nil {
+		return nil, nil, e
+	}
+	content := new(payments.Transaction)
+	notifyReq, err := handler.ParseNotifyRequest(context.Background(), request, content)
+	if err != nil {
+		return nil, nil, errors.New(getErrMessage(err.Error()))
+	}
+	return notifyReq, content, nil
+}
+
 const defaultExpireTime int64 = 30
 
 func getTimeExpire(expireTime *int64) time.Time {