会话

services/llm/chat_service.go

@@ -148,7 +148,6 @@ func SaveChatRecordsToDB(chatId int) error {
 	holder, _ := uuid.NewRandom()
 	holderStr := fmt.Sprintf("sys_%s", holder.String())
 	defer func() {
-		fmt.Printf("系统释放锁:%s", key)
 		lock.ReleaseLock(key, holderStr)
 	}()
 	if lock.AcquireLock(key, 10, holderStr) {
@@ -169,7 +168,6 @@ func SaveChatRecordsToDB(chatId int) error {
 // SaveAllChatRecordsToDB 定时任务保存所有 Redis 中的聊天记录到数据库
 func SaveAllChatRecordsToDB() {
 	for {
-		fmt.Println("开始保存聊天记录到数据库...")
 		keys, err := utils.Rc.Keys(redisChatPrefix + "*")
 		if err != nil {
 			utils.FileLog.Error("获取 Redis 键失败: %v", err)
@@ -189,11 +187,9 @@ func SaveAllChatRecordsToDB() {
 				if err = SaveChatRecordsToDB(chatId); err != nil {
 					utils.FileLog.Error("解析聊天ID失败: %v", err)
 				}
-				fmt.Println("保存聊天记录到数据库完成")
 			}(key)
 		}
 		wg.Wait()
-		fmt.Printf("计划任务完成")
 		time.Sleep(10 * time.Second)
 	}
 }

utils/lock/distrubtLock.go

@@ -25,7 +25,6 @@ func AcquireLock(key string, expiration int, Holder string) bool {
 			else
 				return 0
 			end`)
-	fmt.Println("lockName:"+lockName+key, "Holder:"+Holder, "expiration:"+fmt.Sprintf("%d", expiration))
 	lockey := fmt.Sprintf("%s%s", lockName, key)
 	result, err := script.Run(ctx, utils.Rc.RedisClient(), []string{lockey}, Holder, expiration).Int()
 	if err != nil {
@@ -47,7 +46,6 @@ func ReleaseLock(key string, holder string) bool {
 	       return 0
 	   end
 	`)
-	fmt.Println("lockName:"+lockName+key, "Holder:"+holder)
 	lockey := fmt.Sprintf("%s%s", lockName, key)
 	result, err := script.Run(ctx, utils.Rc.RedisClient(), []string{lockey}, holder).Int()
 	if err != nil {

utils/ws/latency_measurer.go

@@ -2,7 +2,6 @@ package ws
 
 import (
 	"errors"
-	"fmt"
 	"github.com/gorilla/websocket"
 	"sync"
 	"time"
@@ -88,7 +87,6 @@ func SetupLatencyMeasurement(conn *websocket.Conn) *LatencyMeasurer {
 	lm := NewLatencyMeasurer(5) // 使用最近5次测量的滑动窗口
 	conn.SetPongHandler(func(appData string) error {
 		lm.CalculateLatency()
-		fmt.Printf("触发了pong的应答")
 		return nil
 	})
 	return lm

utils/ws/session_manager.go

@@ -60,6 +60,9 @@ func (manager *ConnectionManager) HandleMessage(userID int, sessionID string, me
 	if !exists {
 		return errors.New("session not found")
 	}
+	if string(message) == "pong" {
+		return nil
+	}
 	var userMessage Message
 	err := json.Unmarshal(message, &userMessage)
 	if err != nil {