liucaijun
/
voucher
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

cmb

This commit is contained in:
李子铭 2025-03-10 10:24:32 +08:00
parent 90a398800b
commit 6c1dde9834
2 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/biz/wechat_notify_consume.go
View File

@ -21,9 +21,9 @@ func (j *VoucherBiz) WechatNotifyConsumer(ctx context.Context, tag string, req *
return nil return nil
} }
req.PlainText.StockCreatorMchid = "1676203838" //req.PlainText.StockCreatorMchid = "1676203838"
req.PlainText.StockID = "20215869" //req.PlainText.StockID = "20215869"
req.PlainText.CouponID = "96059179220" //req.PlainText.CouponID = "96059179220"
orderWechat, err := j.OrderWechatRepo.GetByMSCId(ctx, req.PlainText.StockCreatorMchid, req.PlainText.StockID, req.PlainText.CouponID) orderWechat, err := j.OrderWechatRepo.GetByMSCId(ctx, req.PlainText.StockCreatorMchid, req.PlainText.StockID, req.PlainText.CouponID)
if err != nil { if err != nil {

12
internal/data/mixrepoimpl/cmb.go
View File

@ -5,12 +5,14 @@ import (
"encoding/json" "encoding/json"
"errors" "errors"
"fmt" "fmt"
"github.com/go-kratos/kratos/v2/log"
"net/http" "net/http"
"net/url" "net/url"
"time" "time"
v1 "voucher/api/v1" v1 "voucher/api/v1"
"voucher/internal/biz/bo" "voucher/internal/biz/bo"
"voucher/internal/biz/mixrepos" "voucher/internal/biz/mixrepos"
"voucher/internal/biz/vo"
"voucher/internal/conf" "voucher/internal/conf"
"voucher/internal/pkg/cmb" "voucher/internal/pkg/cmb"
"voucher/internal/pkg/helper" "voucher/internal/pkg/helper"
@ -213,8 +215,11 @@ func (s *CmbMixRepoImpl) Request(ctx context.Context, req *v1.CmbRequest, uri st
"Content-Type": []string{"application/x-www-form-urlencoded"}, "Content-Type": []string{"application/x-www-form-urlencoded"},
} }
_, bodyBytes, err := request.Post(ctx, uri+"?"+uv.Encode(), nil, request.WithHeaders(h)) r := uri + "?" + uv.Encode()
_, bodyBytes, err := request.Post(ctx, r, nil, request.WithHeaders(h))
if err != nil { if err != nil {
log.Errorf("请求掌上生活报错,url=%s,err=%v", r, err)
return nil, err return nil, err
} }
@ -223,6 +228,11 @@ func (s *CmbMixRepoImpl) Request(ctx context.Context, req *v1.CmbRequest, uri st
return nil, err return nil, err
} }
if response.RespCode != vo.CmbResponseStatusSuccess.GetValue() {
log.Errorf("请求掌上生活返回报错,url=%s,err=%s", r, response.RespMsg)
return nil, fmt.Errorf(response.RespMsg)
}
return response, nil return response, nil
} }