fix bug

pkg/ruleEngine/nodes/dingtalk_robot_node.go

@@ -2,6 +2,7 @@ package nodes
 
 import (
 	"encoding/json"
+	"fmt"
 	"github.com/gogf/gf/encoding/gjson"
 	"github.com/gogf/gf/os/grpool"
 	"net/http"
@@ -50,6 +51,7 @@ func (d *DingTalkRobotNode) OnMessage(ctx ruleEngine.Context, message *protocol.
 	} else if err != nil {
 		return err
 	}
+	fmt.Printf("webhook:-----------%s\n", d.config.WebHook)
 	req, err := utils.NewRequest("POST", d.config.WebHook, gjson.New(body))
 	if err != nil {
 		server.Log.Error(err)
@@ -79,5 +81,6 @@ func (d *DingTalkRobotNode) newBody(message *protocol.Message) (body map[string]
 		"msgtype": "text",
 		"text":    msg,
 	}
+	fmt.Printf("message222222:-----------%s\n", body)
 	return body, nil
 }

pkg/ruleEngine/nodes/temp_alarm_node.go

@@ -112,12 +112,13 @@ func (t *TempAlarmNode) newAlarmMessage(message *protocol.Message) error {
 		}
 		reqStr, err := req.String()
 		if err != nil {
-			fmt.Printf("str转换错误----------%s\n", err.Error())
+			return err
 		}
-		fmt.Printf("查询用户信息------------------：%s\r\n", reqStr)
 		j := gjson.New(reqStr)
+		if j.GetInt("code") == -1 {
+			return nil
+		}
 		dataMap = j.GetMap("data")
-		fmt.Printf("dataMap------------------：%v\r\n", dataMap)
 	} else {
 		j := gjson.New(message.Data)
 		dataMap = j.GetMap("status")
@@ -127,6 +128,7 @@ func (t *TempAlarmNode) newAlarmMessage(message *protocol.Message) error {
 	if err != nil {
 		return err
 	}
+	fmt.Printf("message:-----------%s\n", message.AlarmMessage)
 	return nil
 }