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

timeSliceQueryPush

This commit is contained in:
ziming 2025-06-12 09:37:25 +08:00
parent 343df76e71
commit d348f247fe
3 changed files with 15 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -17,11 +17,11 @@ func (v *Query) execute(ctx context.Context, req *timeslice.Manager) error {
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)
} }
fmt.Printf("%s到%s,总任务数:%d\n", managerStartStr, managerEndStr, taskCount) fmt.Printf("%s到%s,微信券查询处理,总任务数:%d\n", managerStartStr, managerEndStr, taskCount)
log.Warnf("%s到%s,总任务数:%d", managerStartStr, managerEndStr, taskCount) log.Warnf("%s到%s,微信券查询处理,总任务数:%d", managerStartStr, managerEndStr, taskCount)
return nil return nil
} }
@ -61,10 +61,10 @@ func (v *Query) callbackFunc(ctx context.Context, req *timeslice.Task) error {
"open_id": order.Account, "open_id": order.Account,
"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)
} }
} }
@ -81,7 +81,7 @@ func (v *Query) callbackFunc(ctx context.Context, req *timeslice.Task) error {
"notifyNum": notifyNum, "notifyNum": notifyNum,
"duration": end.Sub(start).String(), "duration": 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
} }

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

@ -81,7 +81,7 @@ func (v *Query) getManager(msg string) (*timeslice.Manager, error) {
return nil, err return nil, err
} }
m := &timeslice.Manager{ manager := &timeslice.Manager{
StartTime: start, StartTime: start,
EndTime: end, EndTime: end,
ProductNo: req.ProductNo, ProductNo: req.ProductNo,
@ -90,14 +90,14 @@ func (v *Query) getManager(msg string) (*timeslice.Manager, error) {
} }
if req.GoNum > 0 { if req.GoNum > 0 {
m.GoNum = req.GoNum manager.GoNum = req.GoNum
} }
if req.TimeSliceHours > 0 { if req.TimeSliceHours > 0 {
m.TimeSliceHours = req.TimeSliceHours manager.TimeSliceHours = req.TimeSliceHours
} }
return m, nil return manager, nil
} }
func (v *Query) Consumer(ctx context.Context, msg string) error { func (v *Query) Consumer(ctx context.Context, msg string) error {
@ -114,8 +114,8 @@ func (v *Query) Consumer(ctx context.Context, msg string) error {
executeStart := time.Now() executeStart := time.Now()
executeStartStr := executeStart.Format(time.DateTime) executeStartStr := executeStart.Format(time.DateTime)
log.Warnf("微信券查询处理开始:%s,manager:%s", executeStartStr, reqStr) log.Warnf("微信券查询处理开始:%s,msg:%s,manager%s", executeStartStr, msg, reqStr)
fmt.Printf("微信券查询处理开始:%s,manager:%s", executeStartStr, reqStr) fmt.Printf("微信券查询处理开始:%s,msg:%s,manager%s", executeStartStr, msg, reqStr)
if err = v.execute(ctx, req); err != nil { if err = v.execute(ctx, req); err != nil {
log.Errorf("微信券查询处理失败:%s,msg:%s,err:%v", executeStartStr, msg, err) log.Errorf("微信券查询处理失败:%s,msg:%s,err:%v", executeStartStr, msg, err)
@ -123,8 +123,8 @@ func (v *Query) Consumer(ctx context.Context, msg string) error {
} }
executeEnd := time.Now() executeEnd := time.Now()
log.Warnf("微信券查询处理耗时:%s,结束时间%s,manager:%s", executeEnd.Sub(executeStart).String(), executeEnd.String(), reqStr) log.Warnf("微信券查询处理耗时:%s,结束时间%s,manager%s", executeEnd.Sub(executeStart).String(), executeEnd.String(), reqStr)
fmt.Printf("微信券查询处理耗时:%s,结束时间%s,manager:%s", executeEnd.Sub(executeStart).String(), executeEnd.String(), reqStr) fmt.Printf("微信券查询处理耗时:%s,结束时间%s,manager%s", executeEnd.Sub(executeStart).String(), executeEnd.String(), reqStr)
return nil return nil
} }

3
internal/pkg/script/script_test.go
View File

@ -14,7 +14,7 @@ func Test_script(t *testing.T) {
return return
} }
endTime, err := time.Parse(time.DateTime, "2025-05-01 10:00:00") endTime, err := time.Parse(time.DateTime, "2025-05-01 5:00:00")
if err != nil { if err != nil {
t.Error(err) t.Error(err)
return return
@ -26,7 +26,6 @@ func Test_script(t *testing.T) {
requestBody := map[string]any{ requestBody := map[string]any{
"go_num": 2, // 并发数量 "go_num": 2, // 并发数量
"time_slice_hours": 2, // 时间间隔 "time_slice_hours": 2, // 时间间隔
"order_no": "",
"product_no": "", "product_no": "",
"start_time": startTime.Format(time.DateTime), "start_time": startTime.Format(time.DateTime),
"end_time": endTime.Format(time.DateTime), "end_time": endTime.Format(time.DateTime),