pkg/service/asChat/robot/robot.go

@@ -173,12 +173,10 @@ func (r *Robot) Run() {
 				if hit {
 					hasHit = true
 					if rule.RunTime().IsZero() {
-						go func() {
-							err := rule.Run(r.cache)
-							if err != nil {
-								log.Printf("robot 执行任务失败：%v\n", err)
-							}
-						}()
+						err := rule.Run(r.cache)
+						if err != nil {
+							log.Printf("robot 执行任务失败：%v\n", err)
+						}
 					} else {
 						r.RegisterDelayTask(rule)
 					}
@@ -193,12 +191,10 @@ func (r *Robot) Run() {
 						hasHit = true
 						fmt.Println("命中规则:", rule.GetTitle())
 						if rule.RunTime().IsZero() {
-							go func() {
-								err := rule.Run(r.cache)
-								if err != nil {
-									log.Printf("robot 执行任务失败：%v\n", err)
-								}
-							}()
+							err := rule.Run(r.cache)
+							if err != nil {
+								log.Printf("robot 执行任务失败：%v\n", err)
+							}
 						} else {
 							r.RegisterDelayTask(rule)
 						}
@@ -214,12 +210,10 @@ func (r *Robot) Run() {
 						hasHit = true
 						fmt.Println("命中规则:", rule.GetTitle())
 						if rule.RunTime().IsZero() {
-							go func() {
-								err := rule.Run(r.cache)
-								if err != nil {
-									log.Printf("robot 执行任务失败：%v\n", err)
-								}
-							}()
+							err := rule.Run(r.cache)
+							if err != nil {
+								log.Printf("robot 执行任务失败：%v\n", err)
+							}
 						} else {
 							r.RegisterDelayTask(rule)
 						}