diff --git a/internal/biz/timeslicequery/mq.go b/internal/biz/timeslicequery/mq.go index d1388a8..feb4bf5 100644 --- a/internal/biz/timeslicequery/mq.go +++ b/internal/biz/timeslicequery/mq.go @@ -119,7 +119,6 @@ func (v *Query) Consumer(ctx context.Context, msg string) error { if err = v.execute(ctx, req); err != nil { log.Errorf("微信券查询处理,失败:%s,msg:%s,err:%v", executeStartStr, msg, err) - return fmt.Errorf("微信券查询处理,失败:%s,msg:%s,err:%v", executeStartStr, msg, err) } executeEnd := time.Now()