diff --git a/internal/biz/timeslicequery/retry_query_notice.go b/internal/biz/timeslicequery/retry_query_notice.go index 8646391..63d8ff2 100644 --- a/internal/biz/timeslicequery/retry_query_notice.go +++ b/internal/biz/timeslicequery/retry_query_notice.go @@ -94,13 +94,11 @@ func (v *Query) RetryQueryNoticeOrder(ctx context.Context, req *do.RetryQueryNot return fmt.Errorf("微信券查询order,任务执行失败: %v", err) } - end := time.Now() - logFields := map[string]any{ "num": num, "sucNum": sucNum, "errNum": errNum, - "elapsed": end.Sub(start).String(), + "elapsed": time.Now().Sub(start).String(), } log.Warnf("微信券查询order,处理完毕:%+v", logFields) @@ -131,6 +129,8 @@ func (v *Query) retryQueryNoticeOrder(ctx context.Context, order *bo.OrderBo) er return v.querySuccess(ctx, order) } else if status.IsExpired() { return v.queryExpired(ctx, order) + } else { + log.Warnf("微信券查询order,未知状态orderNo:%s,status:%d", order.OrderNo, status) } return nil @@ -203,13 +203,11 @@ func (v *Query) RetryQueryNoticeOrderBak(ctx context.Context, req *do.RetryQuery return fmt.Errorf("微信券查询orderBak,任务执行失败: %v", err2) } - end := time.Now() - logFields := map[string]any{ "num": num, "sucNum": sucNum, "errNum": errNum, - "elapsed": end.Sub(start).String(), + "elapsed": time.Now().Sub(start).String(), } log.Warnf("微信券查询orderBak,处理完毕:%+v", logFields) @@ -240,6 +238,8 @@ func (v *Query) retryQueryNoticeOrderBal(ctx context.Context, order *bo.OrderBo) return v.querySuccessBak(ctx, order) } else if status.IsExpired() { return v.queryExpiredBak(ctx, order) + } else { + log.Warnf("微信券查询orderBak,未知状态orderNo:%s,status:%d", order.OrderNo, status) } return nil