diff --git a/internal/biz/timeslicequery/execute.go b/internal/biz/timeslicequery/execute.go
index 389ca47..55e5acd 100644
--- a/internal/biz/timeslicequery/execute.go
+++ b/internal/biz/timeslicequery/execute.go
@@ -17,18 +17,18 @@ func (v *Query) execute(ctx context.Context, req *timeslice.Manager) error {
 	managerStartStr := req.StartTime.Format(time.DateTime)
 	managerEndStr := req.EndTime.Format(time.DateTime)
 
-	log.Warnf("微信券查询处理,%s到%s,开始", managerStartStr, managerEndStr)
-	fmt.Printf("微信券查询处理,%s到%s,开始\n", managerStartStr, managerEndStr)
+	log.Warnf("微信券查询,%s到%s,开始", managerStartStr, managerEndStr)
+	fmt.Printf("微信券查询,%s到%s,开始\n", managerStartStr, managerEndStr)
 
 	taskCount, err := timeslice.NewManager(v.callbackFunc).Run(ctx, req)
 	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()
 
-	log.Warnf("微信券查询处理,%s到%s,总任务数:%d,总耗时:%s", managerStartStr, managerEndStr, taskCount, elapsed)
-	fmt.Printf("微信券查询处理,%s到%s,总任务数:%d,总耗时:%s\n", 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)
 
 	return nil
 }
@@ -69,10 +69,10 @@ func (v *Query) callbackFunc(ctx context.Context, req *timeslice.Task) error {
 					"stock_id":  order.BatchNo,
 					"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 {
-					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,
 		"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
 }
diff --git a/internal/biz/timeslicequery/mq.go b/internal/biz/timeslicequery/mq.go
index 9db519b..65d8462 100644
--- a/internal/biz/timeslicequery/mq.go
+++ b/internal/biz/timeslicequery/mq.go
@@ -106,12 +106,12 @@ func (v *Query) Consumer(ctx context.Context, msg string) error {
 
 	req, err := v.getManager(msg)
 	if err != nil {
-		log.Errorf("微信券查询处理,前置参数处理失败,msg:%s,err:%v", msg, err)
+		log.Errorf("微信券查询,前置参数处理失败,msg:%s,err:%v", msg, err)
 		return 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