From 03adb50feee42bc9886c7d5847c826e549694ab1 Mon Sep 17 00:00:00 2001
From: jjxu <428192774@qq.com>
Date: Thu, 19 Jun 2025 09:15:10 +0800
Subject: [PATCH] fix: debug

---
 pkg/service/asChat/robot/robot.go     | 2 ++
 pkg/service/asChat/robot/rulerList.go | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/pkg/service/asChat/robot/robot.go b/pkg/service/asChat/robot/robot.go
index 8cdbaf4..f218d6c 100644
--- a/pkg/service/asChat/robot/robot.go
+++ b/pkg/service/asChat/robot/robot.go
@@ -176,7 +176,9 @@ func (r *Robot) Run() {
 					} else {
 						ruleResponse := ruleResponse
 						task.SetResponse(ruleResponse.Response)
+						r.mu.Lock()
 						r.RegisterDelayTask(task)
+						r.mu.Unlock()
 					}
 					break
 				}
diff --git a/pkg/service/asChat/robot/rulerList.go b/pkg/service/asChat/robot/rulerList.go
index 2c62ff6..1e23495 100644
--- a/pkg/service/asChat/robot/rulerList.go
+++ b/pkg/service/asChat/robot/rulerList.go
@@ -7,6 +7,7 @@
 package robot
 
 import (
+	"fmt"
 	"fonchain-fiee/pkg/service/asChat/dto"
 	"strings"
 )
@@ -27,6 +28,7 @@ func ParseReplyRule(data *dto.ChatAutoReplyData) (r Reply) {
 			} else {
 				keywords = strings.Split(v.Content, ",")
 			}
+			fmt.Println("ParseReplyRule 解析keywords:", keywords)
 			r.Rules = append(r.Rules, NewReplyWhenHitKeywords(keywords))
 		case "joinSession": //加入聊天后回复
 			r.Rules = append(r.Rules, NewReplyWhenUserJoinSession())