fix bug

pkg/ruleEngine/nodes/dingtalk_robot_node.go

@@ -2,7 +2,6 @@ package nodes
 
 import (
 	"encoding/json"
-	"fmt"
 	"github.com/gogf/gf/encoding/gjson"
 	"github.com/gogf/gf/os/grpool"
 	"net/http"
@@ -25,7 +24,6 @@ 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{
@@ -46,14 +44,12 @@ 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
 	} else if err != nil {
 		return err
 	}
-	fmt.Printf("webhook:-----------%s\n", d.config.WebHook)
 	req, err := d.client.Post(d.config.WebHook, "application/json", gjson.New(body))
 
 	return d.pool.Add(func() {
@@ -78,6 +74,5 @@ 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/reg_types_test.go

@@ -2,10 +2,7 @@ package nodes
 
 import (
 	"encoding/json"
-	"github.com/gogf/gf/encoding/gjson"
 	"sparrow/pkg/ruleEngine"
-	"sparrow/pkg/server"
-	"sparrow/pkg/utils"
 	"strings"
 	"testing"
 	"text/template"
@@ -40,19 +37,3 @@ func TestMQTTBrokerNode_OnMessage(t *testing.T) {
 	}
 	t.Log(stringBuf.String())
 }
-
-func TestMQTTBrokerNode_OnMessage2(t *testing.T) {
-	msg := map[string]interface{}{
-		"content": "测试",
-	}
-	body := map[string]interface{}{
-		"msgtype": "text",
-		"text":    msg,
-	}
-	j := gjson.New(body)
-	client := utils.NewHttpClient()
-	_, err := client.Post("https://oapi.dingtalk.com/robot/send?access_token=0aad9626a5e0c7eb37aa8acf77cb2303201a2bff716fb8e0ed2fe6a55a290729", "application/json", j)
-	if err != nil {
-		server.Log.Error(err)
-	}
-}