脚本

internal/biz/timeslicequery/execute.go

@@ -47,6 +47,7 @@ func (v *Query) callbackFunc(ctx context.Context, req *timeslice.Task) error {
 		StartTime: currentStartTimeStr,
 		EndTime:   currentEndTimeStr,
 		ProductNo: req.Process.Manager.ProductNo,
+		BatchNo:   req.Process.Manager.BatchNo,
 	}
 
 	num := 0

internal/biz/timeslicequery/mq.go

@@ -85,6 +85,7 @@ func (v *Query) getManager(msg string) (*timeslice.Manager, error) {
 		StartTime:      start,
 		EndTime:        end,
 		ProductNo:      req.ProductNo,
+		BatchNo:        req.BatchNo,
 		GoNum:          timeslice.DefaultGoNum,          // 协程数量
 		TimeSliceHours: timeslice.DefaultTimeSliceHours, // 时间间隔
 	}

internal/pkg/timeslice/model.go

@@ -9,6 +9,7 @@ type Manager struct {
 	StartTime      time.Time // 开始时间
 	EndTime        time.Time // 结束时间
 	ProductNo      string    // 产品编号
+	BatchNo        string    // 微信批次号
 	GoNum          int       // 并发数
 	TimeSliceHours int64     // 时间片"小时"
 }