diff --git a/internal/biz/timeslicequery/execute.go b/internal/biz/timeslicequery/execute.go
index 5f6e11d..fd00569 100644
--- a/internal/biz/timeslicequery/execute.go
+++ b/internal/biz/timeslicequery/execute.go
@@ -12,16 +12,23 @@ import (
 
 func (v *Query) execute(ctx context.Context, req *timeslice.Manager) error {
 
+	start := time.Now()
+
 	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)
+
 	taskCount, err := timeslice.NewManager(v.callbackFunc).Run(ctx, req)
 	if err != nil {
 		log.Errorf("微信券查询处理,%s到%s,失败:%v", managerStartStr, managerEndStr, err)
 	}
 
-	fmt.Printf("微信券查询处理,%s到%s,总任务数:%d\n", managerStartStr, managerEndStr, taskCount)
-	log.Warnf("微信券查询处理,%s到%s,总任务数:%d", managerStartStr, managerEndStr, taskCount)
+	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)
 
 	return nil
 }
@@ -76,7 +83,7 @@ func (v *Query) callbackFunc(ctx context.Context, req *timeslice.Task) error {
 
 	end := time.Now()
 
-	logFields := map[string]interface{}{
+	logFields := map[string]any{
 		"searchTime": currentStartTimeStr + "到" + currentEndTimeStr,
 		"num":        num,
 		"notifyNum":  notifyNum,
diff --git a/internal/biz/timeslicequery/mq.go b/internal/biz/timeslicequery/mq.go
index 18f250d..9db519b 100644
--- a/internal/biz/timeslicequery/mq.go
+++ b/internal/biz/timeslicequery/mq.go
@@ -106,24 +106,13 @@ func (v *Query) Consumer(ctx context.Context, msg string) error {
 
 	req, err := v.getManager(msg)
 	if err != nil {
-		return err
+		log.Errorf("微信券查询处理,前置参数处理失败,msg:%s,err:%v", msg, err)
+		return nil
 	}
 
-	reqStr := req.String()
-
-	executeStart := time.Now()
-	executeStartStr := executeStart.Format(time.DateTime)
-
-	log.Warnf("微信券查询处理,开始:%s,msg:%s,manager:%s", executeStartStr, msg, reqStr)
-	fmt.Printf("微信券查询处理,开始:%s,msg:%s,manager:%s", executeStartStr, msg, reqStr)
-
 	if err = v.execute(ctx, req); err != nil {
-		log.Errorf("微信券查询处理,失败:%s,msg:%s,err:%v", executeStartStr, msg, err)
+		log.Errorf("微信券查询处理,失败,msg:%s,err:%v", msg, err)
 	}
 
-	executeEnd := time.Now()
-	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)
-
 	return nil
 }