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

WechatQuery

This commit is contained in:
ziming 2025-06-06 15:56:27 +08:00
parent 9325bde2a3
commit 7cb8ee4202
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/biz/wechat_query.go
View File

@ -37,16 +37,16 @@ func (v *VoucherBiz) PushWechatQuery(ctx context.Context, req *do.WechatQuery) e
func (v *VoucherBiz) WechatQuery(ctx context.Context, msg string) error { func (v *VoucherBiz) WechatQuery(ctx context.Context, msg string) error {
start := time.Now()
log.Warnf("微信券查询处理开始:%s,msg:%s", start.String(), msg)
fmt.Printf("微信券查询处理开始:%s,msg:%s", start.String(), msg)
var req *do.WechatQuery var req *do.WechatQuery
if err := json.Unmarshal([]byte(msg), &req); err != nil { if err := json.Unmarshal([]byte(msg), &req); err != nil {
return err return err
} }
start := time.Now()
log.Warnf("微信券查询处理开始:%s,msg:%s", start.String(), msg)
fmt.Printf("微信券查询处理开始:%s,msg:%s", start.String(), msg)
num := 0 num := 0
err := v.OrderRepo.FinSucByStockIdInBatches(ctx, req, func(ctx context.Context, rows []*bo.OrderBo) error { err := v.OrderRepo.FinSucByStockIdInBatches(ctx, req, func(ctx context.Context, rows []*bo.OrderBo) error {