pkg/service/asChat/robot/replyAndRuler.go

@@ -8,7 +8,6 @@ package robot
 
 import (
 	"context"
-	"fmt"
 	"fonchain-fiee/api/accountFiee"
 	"fonchain-fiee/pkg/common/ws"
 	"fonchain-fiee/pkg/service"
@@ -21,7 +20,6 @@ import (
 
 // 回复规则
 type Reply struct {
-	Title    string
 	Response string
 	Rules    []IRule
 }
@@ -207,16 +205,10 @@ func (k *ReplyWhenWaiterNoAction) Hit(event ws.ListenEventData, sender *accountF
 	if event.ChatUser.Role != 1 {
 		return
 	}
-	hit = true // 立即保存SessionId的值
+	hit = true
-	clientSessionId := event.Client.SessionId
-
-	fmt.Printf("闭包前: clientSessionId=%s\n", clientSessionId)
 	task = RobotTask{
 		RunTime: time.Now().Add(k.DelaySecond * time.Second),
 		Run: func(content string, cache *chatCache.ChatCache, Sender *accountFiee.ChatUserData) error {
-			// 记录闭包执行时的Client状态
-			fmt.Printf("闭包执行: clientSessionId=%s\n", clientSessionId)
-
 			//如果客服已经回复则不发送消息
 			chatRecordListRes, err := service.AccountFieeProvider.GetChatRecordList(context.Background(), &accountFiee.GetChatRecordListRequest{
 				Query: &accountFiee.ChatRecordData{
@@ -247,10 +239,9 @@ func (k *ReplyWhenWaiterNoAction) Hit(event ws.ListenEventData, sender *accountF
 			//notice.BuildMessage(newRecord)
 			//_, err = consts.ChatRoom.SendSessionMessage(robotInfo, wsClient.SessionId, ws.NewChatMsgType, notice)
 			//return err
-			fmt.Println("延时回复 sessionID:", clientSessionId)
 			err = logic.NewMessage(context.Background(), cache, sender, dto.NewMessageRequest{
 				Waiter:    true,
-				SessionId: clientSessionId,
+				SessionId: event.Client.SessionId,
 				Message: dto.Message{
 					MsgType:    1,
 					Text:       content,

pkg/service/asChat/robot/robot.go

@@ -166,7 +166,6 @@ func (r *Robot) Run() {
 			for _, ruleResponse := range r.Rules {
 				hit, task := ruleResponse.Hit(event, r.Info)
 				if hit {
-					fmt.Println("命中规则:", ruleResponse.Title)
 					if task.RunTime.IsZero() {
 						err := task.Run(ruleResponse.Response, r.cache, r.Info)
 						if err != nil {

pkg/service/asChat/robot/rulerList.go

@@ -14,7 +14,6 @@ import (
 // 自动回复规则结构转换
 func ParseReplyRule(data *dto.ChatAutoReplyData) (r Reply) {
 	r.Response = data.Response
-	r.Title = data.Title
 	for ruleName, v := range data.Rules {
 		if !v.Enable {
 			continue