优化用户不回复功能

internal/mqs/amq/handler/amq/wxhook/send_wx.go

@@ -115,6 +115,7 @@ func (l *SendWxHandler) ProcessTask(ctx context.Context, t *asynq.Task) error {
 				// 处理错误
 			}
 		}
+		time.Sleep(time.Duration(60/p.Number) * time.Second)
 	}
 
 	finishTime := time.Now()

internal/mqs/amq/handler/amq/wxhook/send_wx_on_timeout.go

@@ -68,15 +68,12 @@ func (l *SendWxOnTimeoutHandler) ProcessTask(ctx context.Context, t *asynq.Task)
 			),
 		)).
 		All(ctx)
-	fmt.Printf("---------------nodes----------------: %+v\n\n", nodes)
 	// 遍历 nodes，将其各记录 parent_id 的值存入一个新的数组 parent_nodes 中
 	//parentNodes := make([]uint64, 0)
 	//stages := make([]uint64, 0)
 	for _, node := range nodes {
-		lowerBound := startTime.Add(-time.Minute * time.Duration(node.NoReplyCondition+5))
+		lowerBound := startTime.Add(-time.Minute * time.Duration(node.NoReplyCondition+2))
 		upperBound := startTime.Add(-time.Minute * time.Duration(node.NoReplyCondition))
-		fmt.Printf("---------------lowerBound----------------: %+v\n\n", lowerBound)
-		fmt.Printf("---------------upperBound----------------: %+v\n\n", upperBound)
 		if node.ParentID == 0 {
 			messagesStage, _ := l.svcCtx.WX_DB.MessageRecords.Query().
 				Where(messagerecords.StatusEQ(3)).
@@ -86,7 +83,6 @@ func (l *SendWxOnTimeoutHandler) ProcessTask(ctx context.Context, t *asynq.Task)
 				Where(messagerecords.SendTimeGTE(lowerBound)).
 				Where(messagerecords.SendTimeLTE(upperBound)).
 				All(ctx)
-			fmt.Printf("---------------messagesStage----------------: %+v\n\n", messagesStage)
 			for _, s := range messagesStage {
 				// 创建 MessageRecords 记录
 				for i1, c1 := range node.ActionMessage {