From 2757de0f03c3e7eb597c2341ffa53b0ed460d63f Mon Sep 17 00:00:00 2001 From: jjxu <428192774@qq.com> Date: Thu, 19 Jun 2025 11:12:15 +0800 Subject: [PATCH] fix: update --- pkg/service/asChat/robot/robot.go | 6 ++++-- pkg/service/asChat/robot/rulerList.go | 14 ++++++++++++++ .../asChat/robot/ruler_ReplyWhenWaiterNoAction.go | 10 ---------- 3 files changed, 18 insertions(+), 12 deletions(-) diff --git a/pkg/service/asChat/robot/robot.go b/pkg/service/asChat/robot/robot.go index eb08f77..f093a92 100644 --- a/pkg/service/asChat/robot/robot.go +++ b/pkg/service/asChat/robot/robot.go @@ -168,8 +168,8 @@ func (r *Robot) Run() { hit := false for _, rule := range r.joinSessionRules { hit = rule.Hit(event, r.Info) + fmt.Printf("规则【%s】校验结果:%v\n", rule.GetTitle(), hit) if hit { - fmt.Println("命中规则:", rule.GetTitle()) if rule.RunTime().IsZero() { err := rule.Run(r.cache) if err != nil { @@ -183,6 +183,7 @@ func (r *Robot) Run() { if !hit { for _, rule := range r.keywordsRules { hit = rule.Hit(event, r.Info) + fmt.Printf("规则【%s】校验结果:%v\n", rule.GetTitle(), hit) if hit { fmt.Println("命中规则:", rule.GetTitle()) if rule.RunTime().IsZero() { @@ -198,7 +199,8 @@ func (r *Robot) Run() { } if !hit { for _, rule := range r.noReplyAfterRules { - hit := rule.Hit(event, r.Info) + hit = rule.Hit(event, r.Info) + fmt.Printf("规则【%s】校验结果:%v\n", rule.GetTitle(), hit) if hit { fmt.Println("命中规则:", rule.GetTitle()) if rule.RunTime().IsZero() { diff --git a/pkg/service/asChat/robot/rulerList.go b/pkg/service/asChat/robot/rulerList.go index 2417b28..0bfa9ea 100644 --- a/pkg/service/asChat/robot/rulerList.go +++ b/pkg/service/asChat/robot/rulerList.go @@ -8,10 +8,24 @@ package robot import ( "fmt" + "fonchain-fiee/api/accountFiee" + "fonchain-fiee/pkg/common/ws" + "fonchain-fiee/pkg/service/asChat/chatCache" "fonchain-fiee/pkg/service/asChat/dto" "strings" + "time" ) +type IRobotTask interface { + Hit(event ws.ListenEventData, sender *accountFiee.ChatUserData) (hit bool) + Run(cache *chatCache.ChatCache) error + RunTime() time.Time + SetResponse(response string) + GetResponse() string + SetTitle(title string) + GetTitle() string +} + // 自动回复规则结构转换 func ParseReplyRule(data []*dto.ChatAutoReplyData) (joinSessionRules, keywordsRules, noReplyAfterRules []IRobotTask) { for _, responseRules := range data { diff --git a/pkg/service/asChat/robot/ruler_ReplyWhenWaiterNoAction.go b/pkg/service/asChat/robot/ruler_ReplyWhenWaiterNoAction.go index cbae6f5..6fe204b 100644 --- a/pkg/service/asChat/robot/ruler_ReplyWhenWaiterNoAction.go +++ b/pkg/service/asChat/robot/ruler_ReplyWhenWaiterNoAction.go @@ -18,16 +18,6 @@ import ( "time" ) -type IRobotTask interface { - Hit(event ws.ListenEventData, sender *accountFiee.ChatUserData) (hit bool) - Run(cache *chatCache.ChatCache) error - RunTime() time.Time - SetResponse(response string) - GetResponse() string - SetTitle(title string) - GetTitle() string -} - // 客服指定时间不回复则自动回复 func NewReplyWhenWaiterNoAction(title string, delaySecond time.Duration) IRobotTask { return &RobotTaskReplyWhenWaiterNoAction{