From 7cb8ee4202458d5026af7fb32c833f15bcc79f60 Mon Sep 17 00:00:00 2001 From: ziming Date: Fri, 6 Jun 2025 15:56:27 +0800 Subject: [PATCH] WechatQuery --- internal/biz/wechat_query.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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 {