feat:add identifier to plugin. (#4289)

* feat:add identifier to plugin.

Signed-off-by: leozhang2018 <[email protected]>

* fix:fix handler.

Signed-off-by: leozhang2018 <[email protected]>

* fix:fix filter not update.

Signed-off-by: leozhang2018 <[email protected]>

---------

Signed-off-by: leozhang2018 <[email protected]>

Author: leozhang2018

pkg/microservice/aslan/core/common/repository/models/plugin.go

@@ -21,6 +21,7 @@ import "go.mongodb.org/mongo-driver/bson/primitive"
 type Plugin struct {
 	ID          primitive.ObjectID `bson:"_id,omitempty"  json:"id,omitempty"`
 	Name        string             `bson:"name"           json:"name"`
+	Identifier  string             `bson:"identifier"     json:"identifier"`
 	Index       int                `bson:"index"          json:"index"`
 	Type        string             `bson:"type"           json:"type"` // page or tab
 	Description string             `bson:"description"    json:"description"`

pkg/microservice/aslan/core/common/repository/mongodb/plugin.go

@@ -94,6 +94,7 @@ func (c *PluginColl) Update(id string, m *models.Plugin) error {
 	}
 	change := bson.M{"$set": bson.M{
 		"name":        m.Name,
+		"identifier":  m.Identifier,
 		"index":       m.Index,
 		"type":        m.Type,
 		"description": m.Description,

pkg/microservice/aslan/core/system/handler/plugin.go

@@ -68,6 +68,7 @@ func CreatePlugin(c *gin.Context) {
 		ctx.RespErr = e.ErrInvalidParam.AddDesc("name is required")
 		return
 	}
+	args.Identifier = c.PostForm("identifier")
 	if idxStr := c.PostForm("index"); idxStr != "" {
 		if parsed, err := strconv.Atoi(idxStr); err == nil {
 			args.Index = parsed
@@ -78,6 +79,16 @@ func CreatePlugin(c *gin.Context) {
 	args.Route = c.PostForm("route")
 	args.Enabled = c.PostForm("enabled") == "true"
 
+	// parse filters if provided
+	if filtersStr := c.PostForm("filters"); filtersStr != "" {
+		var filters []*commonmodels.PluginFilter
+		if err := json.Unmarshal([]byte(filtersStr), &filters); err != nil {
+			ctx.RespErr = e.ErrInvalidParam.AddDesc("invalid filters format, should be JSON array")
+			return
+		}
+		args.Filters = filters
+	}
+
 	file, header, err := c.Request.FormFile("file")
 	if err != nil {
 		ctx.RespErr = e.ErrInvalidParam.AddDesc("file is required")
@@ -119,6 +130,7 @@ func UpdatePlugin(c *gin.Context) {
 		}
 		args := new(commonmodels.Plugin)
 		args.Name = c.PostForm("name")
+		args.Identifier = c.PostForm("identifier")
 		if idxStr := c.PostForm("index"); idxStr != "" {
 			if parsed, err := strconv.Atoi(idxStr); err == nil {
 				args.Index = parsed
@@ -129,6 +141,16 @@ func UpdatePlugin(c *gin.Context) {
 		args.Route = c.PostForm("route")
 		args.Enabled = c.PostForm("enabled") == "true"
 
+		// parse filters if provided
+		if filtersStr := c.PostForm("filters"); filtersStr != "" {
+			var filters []*commonmodels.PluginFilter
+			if err := json.Unmarshal([]byte(filtersStr), &filters); err != nil {
+				ctx.RespErr = e.ErrInvalidParam.AddDesc("invalid filters format, should be JSON array")
+				return
+			}
+			args.Filters = filters
+		}
+
 		// try file
 		file, header, err := c.Request.FormFile("file")
 		if err == nil {