diff --git a/app/mix/service/xxljob_tasks.go b/app/mix/service/xxljob_tasks.go index 7883d569..d5aedafd 100644 --- a/app/mix/service/xxljob_tasks.go +++ b/app/mix/service/xxljob_tasks.go @@ -164,7 +164,7 @@ func (s *CronService) ImageAuditBatchHis(ctx context.Context, param *xxl.RunReq) logger.Info("task %v param: %v log_id: %v", param.ExecutorHandler, param.ExecutorParams, xxl.Int64ToStr(param.LogID)) handleMsg := &strings.Builder{} // 刷新批次号 - batchId := imageaudit.RefreshBatchId() + batchId := param.ExecutorParams // 执行图像审核 successNum, failNum, err := imageaudit.Run(batchId) if err != nil { @@ -210,7 +210,7 @@ func (s *CronService) TextAuditBatchHis(ctx context.Context, param *xxl.RunReq) handleMsg := &strings.Builder{} // 刷新批次号 - batchId := textaudit.RefreshBatchId() + batchId := param.ExecutorParams // 执行文字审核 successNum, failNum, err := textaudit.Run(batchId) if err != nil {