更新规则链管理接口

pkg/models/rulechain.go

@@ -44,8 +44,9 @@ type CellData struct {
 	ZIndex    string     `json:"ZIndex"`    // 序号
 	FuncBody  string     `json:"func_body"` // 代码
 	Label     string     `json:"label"`
-	Source    string     `json:"source"` // 源节点id
-	Target    string     `json:"target"` // 目标节点id
+	Source    string     `json:"source"`   // 源节点id
+	Target    string     `json:"target"`   // 目标节点id
+	MesType   []string   `json:"mes_type"` // 消息类型
 	Headers   []*Headers `json:"headers"`
 	Url       string     `json:"url"`
 	Method    string     `json:"method"`

services/knowoapi/services/rule_chain.go

@@ -90,19 +90,24 @@ func (a ruleChainService) create(ruleChain *models.RuleChain) error {
 				DebugModel:  true,
 				Intro:       v.Data.Desc,
 			}
-			if ruleNode.Type == "MsgTypeSwitchNode" {
+
+			switch ruleNode.Type {
+			case "MsgTypeSwitchNode":
 				ruleNode.Name = "消息类型路由器"
-			}
+			case "MsgTypeFilter":
+				conMap := map[string]interface{}{
+					"msg_type": v.Data.MesType,
+				}
+				marshal, _ := json.Marshal(conMap)
+				ruleNode.Configuration = fmt.Sprintf("%s", marshal)
 
-			if ruleNode.Type == "FilterJavascriptNode" {
+			case "FilterJavascriptNode":
 				conMap := map[string]string{
 					"func_body": v.Data.FuncBody,
 				}
 				marshal, _ := json.Marshal(conMap)
 				ruleNode.Configuration = fmt.Sprintf("%s", marshal)
-			}
-
-			if ruleNode.Type == "RestApiRequestNode" {
+			case "RestApiRequestNode":
 				configuration := models.NodeConfiguration{
 					Url:       v.Data.Url,
 					Method:    v.Data.Method,