fiee/fonchain-fiee
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: debug2

Browse Source
This commit is contained in:
徐俊杰 2025-06-19 09:23:08 +08:00
parent 03adb50fee
commit eaf04ae02d
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/service/asChat/robot/robot.go
View File

@ -163,6 +163,7 @@ func (r *Robot) Run() {
return return
case event := <-r.EventListener.Chan: case event := <-r.EventListener.Chan:
fmt.Printf("robot listen event:%#v\n", event) fmt.Printf("robot listen event:%#v\n", event)
r.mu.Lock()
for _, ruleResponse := range r.Rules { for _, ruleResponse := range r.Rules {
hit, task := ruleResponse.Hit(event, r.Info) hit, task := ruleResponse.Hit(event, r.Info)
if hit { if hit {
@ -176,13 +177,12 @@ func (r *Robot) Run() {
} else { } else {
ruleResponse := ruleResponse ruleResponse := ruleResponse
task.SetResponse(ruleResponse.Response) task.SetResponse(ruleResponse.Response)
r.mu.Lock()
r.RegisterDelayTask(task) r.RegisterDelayTask(task)
r.mu.Unlock()
} }
break break
} }
} }
r.mu.Unlock()
} }
} }
} }
@ -196,8 +196,6 @@ func (r *Robot) Stop() {
r.mu.Unlock() r.mu.Unlock()
} }
func (r *Robot) RegisterDelayTask(task IRobotTask) { func (r *Robot) RegisterDelayTask(task IRobotTask) {
r.mu.Lock()
defer r.mu.Unlock()
if task.Run == nil { if task.Run == nil {
return return
} }