mirror of
https://github.com/silenceper/wechat.git
synced 2026-02-04 12:52:27 +08:00
adf142dac2
* [feature] Format the code and improve Mini Program authorization to obtain openid（miniprogram/auth/auth.go Code2Session） * [feature] CheckEncryptedData (https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/user-info/auth.checkEncryptedData.html) * upgrade json error * upgrade json error * [feature] Wallet Transfer returns the pointer object * feat:Adaptation of new go-redis components * improve code * feat:upgrade golangci-lint-action version * fix * test ci * fix * test ci * fix * test * improve code * feat:GetPhoneNumber return ptr * fix: ptr Elem() error * improve code * improve code * improve code * improve code * upgrade go version v1.15 * improve .golangci.yml * feat:modify redis version v8.11.5 Co-authored-by: houseme <houseme@outlook.com>
77 lines
2.1 KiB
Go
77 lines
2.1 KiB
Go
package notify
|
|
|
|
import (
|
|
"crypto/md5"
|
|
"encoding/base64"
|
|
"encoding/hex"
|
|
"encoding/xml"
|
|
"errors"
|
|
|
|
"github.com/silenceper/wechat/v2/util"
|
|
)
|
|
|
|
// reference: https://pay.weixin.qq.com/wiki/doc/api/jsapi.php?chapter=9_16&index=10
|
|
|
|
// RefundedResult 退款回调
|
|
type RefundedResult struct {
|
|
ReturnCode *string `xml:"return_code"`
|
|
ReturnMsg *string `xml:"return_msg"`
|
|
|
|
AppID *string `xml:"appid"`
|
|
MchID *string `xml:"mch_id"`
|
|
NonceStr *string `xml:"nonce_str"`
|
|
ReqInfo *string `xml:"req_info"`
|
|
}
|
|
|
|
// RefundedReqInfo 退款结果（明文）
|
|
type RefundedReqInfo struct {
|
|
TransactionID *string `xml:"transaction_id"`
|
|
OutTradeNO *string `xml:"out_trade_no"`
|
|
RefundID *string `xml:"refund_id"`
|
|
OutRefundNO *string `xml:"out_refund_no"`
|
|
TotalFee *int `xml:"total_fee"`
|
|
SettlementTotalFee *int `xml:"settlement_total_fee"`
|
|
RefundFee *int `xml:"refund_fee"`
|
|
SettlementRefundFee *int `xml:"settlement_refund_fee"`
|
|
RefundStatus *string `xml:"refund_status"`
|
|
SuccessTime *string `xml:"success_time"`
|
|
RefundRecvAccount *string `xml:"refund_recv_accout"`
|
|
RefundAccount *string `xml:"refund_account"`
|
|
RefundRequestSource *string `xml:"refund_request_source"`
|
|
}
|
|
|
|
// RefundedResp 消息通知返回
|
|
type RefundedResp struct {
|
|
ReturnCode string `xml:"return_code"`
|
|
ReturnMsg string `xml:"return_msg"`
|
|
}
|
|
|
|
// DecryptReqInfo 对退款结果进行解密
|
|
func (notify *Notify) DecryptReqInfo(result *RefundedResult) (*RefundedReqInfo, error) {
|
|
if result == nil || result.ReqInfo == nil {
|
|
return nil, errors.New("empty refunded_result or req_info")
|
|
}
|
|
|
|
base64Decode, err := base64.StdEncoding.DecodeString(*result.ReqInfo)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
hash := md5.New()
|
|
if _, err = hash.Write([]byte(notify.Key)); err != nil {
|
|
return nil, err
|
|
}
|
|
md5APIKey := hex.EncodeToString(hash.Sum(nil))
|
|
|
|
data, err := util.AesECBDecrypt(base64Decode, []byte(md5APIKey))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
res := &RefundedReqInfo{}
|
|
if err = xml.Unmarshal(data, res); err != nil {
|
|
return nil, err
|
|
}
|
|
return res, nil
|
|
}
|