123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125 |
- package cygx
- import (
- "context"
- "fmt"
- "github.com/wechatpay-apiv3/wechatpay-go/core"
- "github.com/wechatpay-apiv3/wechatpay-go/core/option"
- "github.com/wechatpay-apiv3/wechatpay-go/services/refunddomestic"
- payUtils "github.com/wechatpay-apiv3/wechatpay-go/utils"
- "hongze/hz_crm_api/models/cygx"
- "hongze/hz_crm_api/services/alarm_msg"
- "hongze/hz_crm_api/utils"
- )
- const (
-
-
- MchPKFileName = "/home/code/wechat_cert/cygx/apiclient_key.pem"
- Mchid = "1624495680"
- MchCertificateSerialNumber = "5ED2719CFAE5205763034AD80BF4B8A33533C418"
- MchAPIv3Key = "W1tbnzQrzQ7yRRNuQCIHjis8dgdasKVX"
- )
- var WechatCertClient *core.Client
- func init() {
- if !utils.FileIsExist(MchPKFileName) {
-
- go alarm_msg.SendAlarmMsg("微信商户链接失败 商户私钥文件不存在", 2)
- return
- }
-
- mchPrivateKey, err := payUtils.LoadPrivateKeyWithPath(MchPKFileName)
- if err != nil {
- fmt.Println(err)
- go alarm_msg.SendAlarmMsg("微信商户链接失败 LoadPrivateKeyWithPath"+err.Error(), 2)
- }
- ctx := context.Background()
-
- opts := []core.ClientOption{
- option.WithWechatPayAutoAuthCipher(Mchid, MchCertificateSerialNumber, mchPrivateKey, MchAPIv3Key),
- }
- client, err := core.NewClient(ctx, opts...)
- if err != nil {
- fmt.Println(err)
- go alarm_msg.SendAlarmMsg("微信商户链接失败 NewClient"+err.Error(), 2)
- }
- WechatCertClient = client
- return
- }
- func RefundsApiService(orderDetail *cygx.CygxOrderResp) (statusCode int, err error) {
- defer func() {
- if err != nil {
- fmt.Println(err)
- go alarm_msg.SendAlarmMsg(fmt.Sprint("微信商户退款失败 RefundsApiService, err:", err.Error()), 2)
- }
- }()
-
-
-
-
-
- ctx := context.Background()
- svc := refunddomestic.RefundsApiService{Client: WechatCertClient}
- resp, result, err := svc.Create(ctx,
- refunddomestic.CreateRequest{
-
- TransactionId: core.String(orderDetail.OutTradeCode),
- OutTradeNo: core.String(orderDetail.OutTradeNo),
- OutRefundNo: core.String("RE" + orderDetail.OrderCode),
- Reason: core.String("退款"),
- NotifyUrl: core.String(utils.Wx_MFYX_Refund_NotifyUrl),
- FundsAccount: refunddomestic.REQFUNDSACCOUNT_AVAILABLE.Ptr(),
- Amount: &refunddomestic.AmountReq{
- Currency: core.String("CNY"),
-
-
-
-
- Refund: core.Int64(int64(orderDetail.PayMoney * 100)),
- Total: core.Int64(int64(orderDetail.PayMoney * 100)),
- },
- },
- )
- if err != nil {
- return
- } else {
- utils.FileLogCygx.Info("status=%d resp=%s", result.Response.StatusCode, resp)
- }
- statusCode = result.Response.StatusCode
- return
- }
|