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

timeSliceQuery

This commit is contained in:
ziming 2025-06-13 18:12:42 +08:00
parent ba8d349273
commit cb1135e9c8
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
internal/biz/timeslicequery/execute.go
View File

@ -17,18 +17,18 @@ func (v *Query) execute(ctx context.Context, req *timeslice.Manager) error {
managerStartStr := req.StartTime.Format(time.DateTime) managerStartStr := req.StartTime.Format(time.DateTime)
managerEndStr := req.EndTime.Format(time.DateTime) managerEndStr := req.EndTime.Format(time.DateTime)
log.Warnf("微信券查询处理,%s到%s,开始", managerStartStr, managerEndStr) log.Warnf("微信券查询,%s到%s,开始", managerStartStr, managerEndStr)
fmt.Printf("微信券查询处理,%s到%s,开始\n", managerStartStr, managerEndStr) fmt.Printf("微信券查询,%s到%s,开始\n", managerStartStr, managerEndStr)
taskCount, err := timeslice.NewManager(v.callbackFunc).Run(ctx, req) taskCount, err := timeslice.NewManager(v.callbackFunc).Run(ctx, req)
if err != nil { if err != nil {
log.Errorf("微信券查询处理,%s到%s,失败:%v", managerStartStr, managerEndStr, err) log.Errorf("微信券查询,%s到%s,失败:%v", managerStartStr, managerEndStr, err)
} }
elapsed := time.Now().Sub(start).String() elapsed := time.Now().Sub(start).String()
log.Warnf("微信券查询处理,%s到%s,总任务数:%d,总耗时:%s", managerStartStr, managerEndStr, taskCount, elapsed) log.Warnf("微信券查询,%s到%s,总任务数:%d,总耗时:%s", managerStartStr, managerEndStr, taskCount, elapsed)
fmt.Printf("微信券查询处理,%s到%s,总任务数:%d,总耗时:%s\n", managerStartStr, managerEndStr, taskCount, elapsed) fmt.Printf("微信券查询,%s到%s,总任务数:%d,总耗时:%s\n", managerStartStr, managerEndStr, taskCount, elapsed)
return nil return nil
} }
@ -69,10 +69,10 @@ func (v *Query) callbackFunc(ctx context.Context, req *timeslice.Task) error {
"stock_id": order.BatchNo, "stock_id": order.BatchNo,
"err": err.Error(), "err": err.Error(),
} }
log.Errorf("微信券查询处理,%s到%s,taskId:%d,错误:%+v", startTimeStr, endTimeStr, req.TaskID, logFields) log.Errorf("微信券查询,%s到%s,taskId:%d,错误:%+v", startTimeStr, endTimeStr, req.TaskID, logFields)
if errNum > 20 { if errNum > 20 {
return fmt.Errorf("微信券查询处理,%s到%s,第%d个任务,已经连续发生20次错误%+v", startTimeStr, endTimeStr, req.TaskID, logFields) return fmt.Errorf("微信券查询,%s到%s,第%d个任务,已经连续发生20次错误%+v", startTimeStr, endTimeStr, req.TaskID, logFields)
} }
} }
@ -90,7 +90,7 @@ func (v *Query) callbackFunc(ctx context.Context, req *timeslice.Task) error {
"errNum": errNum, "errNum": errNum,
"elapsed": end.Sub(start).String(), "elapsed": end.Sub(start).String(),
} }
log.Warnf("微信券查询处理,%s到%s,taskId:%d,处理完毕:%+v", startTimeStr, endTimeStr, req.TaskID, logFields) log.Warnf("微信券查询,%s到%s,taskId:%d,处理完毕:%+v", startTimeStr, endTimeStr, req.TaskID, logFields)
return err return err
} }

4
internal/biz/timeslicequery/mq.go
View File

@ -106,12 +106,12 @@ func (v *Query) Consumer(ctx context.Context, msg string) error {
req, err := v.getManager(msg) req, err := v.getManager(msg)
if err != nil { if err != nil {
log.Errorf("微信券查询处理,前置参数处理失败,msg:%s,err:%v", msg, err) log.Errorf("微信券查询,前置参数处理失败,msg:%s,err:%v", msg, err)
return nil return nil
} }
if err = v.execute(ctx, req); err != nil { if err = v.execute(ctx, req); err != nil {
log.Errorf("微信券查询处理,失败,msg:%s,err:%v", msg, err) log.Errorf("微信券查询,失败,msg:%s,err:%v", msg, err)
} }
return nil return nil