diff --git a/internal/biz/wechat_query.go b/internal/biz/wechat_query.go index 7ce7e5c..c3b027d 100644 --- a/internal/biz/wechat_query.go +++ b/internal/biz/wechat_query.go @@ -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 { - start := time.Now() - log.Warnf("微信券查询处理开始:%s,msg:%s", start.String(), msg) - fmt.Printf("微信券查询处理开始:%s,msg:%s", start.String(), msg) - var req *do.WechatQuery if err := json.Unmarshal([]byte(msg), &req); err != nil { return err } + start := time.Now() + log.Warnf("微信券查询处理开始:%s,msg:%s", start.String(), msg) + fmt.Printf("微信券查询处理开始:%s,msg:%s", start.String(), msg) + num := 0 err := v.OrderRepo.FinSucByStockIdInBatches(ctx, req, func(ctx context.Context, rows []*bo.OrderBo) error {