fix bug

pkg/ruleEngine/nodes/dingtalk_robot_node.go

@@ -25,6 +25,7 @@ type DingTalkRobotNodeConfig struct {
 }
 
 func (d *DingTalkRobotNode) Init(ctx ruleEngine.Context, config string) error {
+	fmt.Printf("初始化钉钉机器人节点---------------\n")
 	d.pool = grpool.New(10)
 	if config == "" {
 		d.config = &DingTalkRobotNodeConfig{
@@ -45,6 +46,7 @@ func (d *DingTalkRobotNode) Init(ctx ruleEngine.Context, config string) error {
 }
 
 func (d *DingTalkRobotNode) OnMessage(ctx ruleEngine.Context, message *protocol.Message) error {
+	fmt.Printf("执行钉钉机器人节点--------------\n")
 	body, err := d.newBody(message)
 	if body == nil {
 		return nil

pkg/ruleEngine/nodes/temp_alarm_node.go

@@ -49,8 +49,8 @@ func (t *TempAlarmNode) OnMessage(ctx ruleEngine.Context, message *protocol.Mess
 		if err != nil {
 			return err
 		}
+		fmt.Printf("消息组合成功，传递下一节点-----------\n")
 		ctx.TellNext(message, protocol.True)
-		return nil
 	} else {
 		ctx.TellNext(message, protocol.False)
 	}