koderover
diff --git a/‎pkg/cli/initconfig/cmd/init.go‎
Lines changed: 82 additions & 0 deletions b/‎pkg/cli/initconfig/cmd/init.go‎
Lines changed: 82 additions & 0 deletions
diff --git a/‎pkg/microservice/aslan/config/consts.go‎
Lines changed: 68 additions & 0 deletions b/‎pkg/microservice/aslan/config/consts.go‎
Lines changed: 68 additions & 0 deletions
diff --git a/‎pkg/microservice/aslan/core/application/handler/application.go‎
Lines changed: 135 additions & 0 deletions b/‎pkg/microservice/aslan/core/application/handler/application.go‎
Lines changed: 135 additions & 0 deletions
@@ -42,6 +42,13 @@ import (
 	gormtool "github.com/koderover/zadig/v2/pkg/tool/gorm"
 	"github.com/koderover/zadig/v2/pkg/tool/log"
 	mongotool "github.com/koderover/zadig/v2/pkg/tool/mongo"
+
+	aslanconfig "github.com/koderover/zadig/v2/pkg/microservice/aslan/config"
+	commonmodels "github.com/koderover/zadig/v2/pkg/microservice/aslan/core/common/repository/models"
+
+	"errors"
+
+	"go.mongodb.org/mongo-driver/mongo"
 )
 
 func init() {
@@ -111,6 +118,8 @@ func createOrUpdateMongodbIndex(ctx context.Context) {
 	for _, r := range []indexer{
 		// aslan related db index
 		template.NewProductColl(),
+		commonrepo.NewApplicationColl(),
+		commonrepo.NewApplicationFieldDefinitionColl(),
 		commonrepo.NewBasicImageColl(),
 		commonrepo.NewBuildColl(),
 		commonrepo.NewCallbackRequestColl(),
@@ -252,6 +261,12 @@ func initSystemData() error {
 		return err
 	}
 
+	// Seed built-in application field definitions (idempotent)
+	if err := createBuiltinApplicationFieldDefinitions(); err != nil {
+		log.Errorf("failed to create builtin application field definitions: %s", err)
+		return err
+	}
+
 	if err := createLocalCluster(); err != nil {
 		log.Errorf("createLocalCluster err:%s", err)
 		return err
@@ -268,6 +283,73 @@ func initSystemData() error {
 	return nil
 }
 
+// createBuiltinApplicationFieldDefinitions creates built-in Application fields into the
+// application_field_definition collection.
+func createBuiltinApplicationFieldDefinitions() error {
+	coll := commonrepo.NewApplicationFieldDefinitionColl()
+	ctx := context.Background()
+
+	// Define built-in fields. Ignore _id and plugins; treat repository as a special type without inner-field visibility.
+	builtin := []commonmodels.ApplicationFieldDefinition{
+		{Key: "name", Name: "名称", Type: aslanconfig.ApplicationCustomFieldTypeText, Required: true, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "业务服务的名称"},
+		{Key: "key", Name: "标识", Type: aslanconfig.ApplicationCustomFieldTypeText, Required: true, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "业务服务的唯一标识符"},
+		{Key: "project", Name: "项目归属", Type: aslanconfig.ApplicationCustomFieldTypeProject, Required: true, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "业务服务所属的项目"},
+		{Key: "type", Name: "类型", Type: aslanconfig.ApplicationCustomFieldTypeSingleSelect, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "业务服务的类型", Options: []string{"服务", "组件", "应用"}},
+		{Key: "owner", Name: "负责人", Type: aslanconfig.ApplicationCustomFieldTypeUser, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "业务服务的负责人"},
+		{Key: "repository", Name: "代码库", Type: aslanconfig.ApplicationCustomFieldTypeRepository, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "代码仓库"},
+		{Key: "description", Name: "描述", Type: aslanconfig.ApplicationCustomFieldTypeText, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "业务服务的详细描述"},
+		{Key: "testing_service_name", Name: "测试配置", Type: aslanconfig.ApplicationCustomFieldTypeServiceConfig, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "测试环境的配置"},
+		{Key: "production_service_name", Name: "生产配置", Type: aslanconfig.ApplicationCustomFieldTypeServiceConfig, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "生产环境的配置"},
+		{Key: "create_time", Name: "创建时间", Type: aslanconfig.ApplicationCustomFieldTypeDatetime, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "业务服务的创建时间"},
+		{Key: "update_time", Name: "更新时间", Type: aslanconfig.ApplicationCustomFieldTypeDatetime, ShowInList: true, Source: aslanconfig.ApplicationFieldSourceBuiltin, Description: "业务服务的更新时间"},
+	}
+
+	// Upsert per key to be idempotent. Keep user-changed attributes for custom fields; for built-ins we only enforce Source="builtin" and Type.
+	for i := range builtin {
+		b := builtin[i]
+		existing, err := coll.GetByKey(ctx, b.Key)
+		if err != nil {
+			// if not found, create
+			if errors.Is(err, mongo.ErrNoDocuments) {
+				// set timestamps via Create
+				if _, cerr := coll.Create(ctx, &b); cerr != nil {
+					return cerr
+				}
+				continue
+			}
+			return err
+		}
+		// Already exists: only update Source, Type, Name, Description, Required if they differ; preserve other settings (e.g., ShowInList) to avoid surprising overrides.
+		needUpdate := false
+		if existing.Source != aslanconfig.ApplicationFieldSourceBuiltin {
+			existing.Source = aslanconfig.ApplicationFieldSourceBuiltin
+			needUpdate = true
+		}
+		if existing.Type != b.Type {
+			existing.Type = b.Type
+			needUpdate = true
+		}
+		if existing.Name != b.Name {
+			existing.Name = b.Name
+			needUpdate = true
+		}
+		if existing.Description != b.Description {
+			existing.Description = b.Description
+			needUpdate = true
+		}
+		if existing.Required != b.Required {
+			existing.Required = b.Required
+			needUpdate = true
+		}
+		if needUpdate {
+			if err := coll.UpdateByID(ctx, existing.ID.Hex(), existing); err != nil {
+				return err
+			}
+		}
+	}
+	return nil
+}
+
 func createLocalCluster() error {
 	cluster, err := aslan.New(config.AslanServiceAddress()).GetLocalCluster()
 	if err != nil {
 
@@ -766,3 +766,71 @@ const (
 	NavigationKeyDataInsight           NavigationItemKey = "dataInsight"
 	NavigationKeyCustomerDelivery      NavigationItemKey = "customerDelivery"
 )
+
+// Application custom field types
+type ApplicationCustomFieldType string
+
+const (
+	ApplicationCustomFieldTypeText        ApplicationCustomFieldType = "text"
+	ApplicationCustomFieldTypeNumber      ApplicationCustomFieldType = "number"
+	ApplicationCustomFieldTypeBool        ApplicationCustomFieldType = "bool"
+	ApplicationCustomFieldTypeDatetime    ApplicationCustomFieldType = "datetime"
+	ApplicationCustomFieldTypeMultiSelect ApplicationCustomFieldType = "multi_select"
+	// below is the custom field types that are only supported by the frontend, but has no real meaning in the backend
+	ApplicationCustomFieldTypeLink          ApplicationCustomFieldType = "link"
+	ApplicationCustomFieldTypeUser          ApplicationCustomFieldType = "user"
+	ApplicationCustomFieldTypeUserGroup     ApplicationCustomFieldType = "user_group"
+	ApplicationCustomFieldTypeRepository    ApplicationCustomFieldType = "repository"
+	ApplicationCustomFieldTypeProject       ApplicationCustomFieldType = "project"
+	ApplicationCustomFieldTypeSingleSelect  ApplicationCustomFieldType = "single_select"
+	ApplicationCustomFieldTypeServiceConfig ApplicationCustomFieldType = "service_config"
+)
+
+// Application field source types (definition origin)
+type ApplicationFieldSourceType string
+
+const (
+	ApplicationFieldSourceBuiltin ApplicationFieldSourceType = "builtin"
+	ApplicationFieldSourceCustom  ApplicationFieldSourceType = "custom"
+)
+
+// Application filter field categories used by search filtering
+type ApplicationFilterFieldType string
+
+const (
+	ApplicationFilterFieldTypeString ApplicationFilterFieldType = "string"
+	ApplicationFilterFieldTypeNumber ApplicationFilterFieldType = "number"
+	ApplicationFilterFieldTypeBool   ApplicationFilterFieldType = "bool"
+	ApplicationFilterFieldTypeArray  ApplicationFilterFieldType = "array"
+)
+
+// Application filter actions (verbs) supported by search filtering
+type ApplicationFilterAction string
+
+const (
+	// common
+	ApplicationFilterActionEq          ApplicationFilterAction = "="
+	ApplicationFilterActionNe          ApplicationFilterAction = "!="
+	ApplicationFilterActionHasAnyOf    ApplicationFilterAction = "has_any_of"
+	ApplicationFilterActionContains    ApplicationFilterAction = "contains"
+	ApplicationFilterActionNotContains ApplicationFilterAction = "not_contains"
+
+	// string-like
+	ApplicationFilterActionBeginsWith    ApplicationFilterAction = "begins_with"
+	ApplicationFilterActionNotBeginsWith ApplicationFilterAction = "not_begins_with"
+	ApplicationFilterActionEndsWith      ApplicationFilterAction = "ends_with"
+	ApplicationFilterActionNotEndsWith   ApplicationFilterAction = "not_ends_with"
+
+	// number
+	ApplicationFilterActionLt  ApplicationFilterAction = "<"
+	ApplicationFilterActionLte ApplicationFilterAction = "<="
+	ApplicationFilterActionGt  ApplicationFilterAction = ">"
+	ApplicationFilterActionGte ApplicationFilterAction = ">="
+
+	// bool
+	ApplicationFilterActionIs ApplicationFilterAction = "is"
+
+	// array
+	ApplicationFilterActionIsEmpty    ApplicationFilterAction = "is_empty"
+	ApplicationFilterActionIsNotEmpty ApplicationFilterAction = "is_not_empty"
+)
@@ -0,0 +1,135 @@
+/*
+Copyright 2025 The KodeRover Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package handler
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io"
+
+	"github.com/gin-gonic/gin"
+	"github.com/gin-gonic/gin/binding"
+
+	"github.com/koderover/zadig/v2/pkg/microservice/aslan/core/application/service"
+	commonmodels "github.com/koderover/zadig/v2/pkg/microservice/aslan/core/common/repository/models"
+	internalhandler "github.com/koderover/zadig/v2/pkg/shared/handler"
+	e "github.com/koderover/zadig/v2/pkg/tool/errors"
+)
+
+func CreateApplication(c *gin.Context) {
+	ctx, err := internalhandler.NewContextWithAuthorization(c)
+	defer func() { internalhandler.JSONResponse(c, ctx) }()
+	if err != nil {
+		ctx.RespErr = fmt.Errorf("authorization Info Generation failed: err %s", err)
+		ctx.UnAuthorized = true
+		return
+	}
+	args := new(commonmodels.Application)
+	data, _ := c.GetRawData()
+	c.Request.Body = io.NopCloser(bytes.NewBuffer(data))
+	if err := c.ShouldBindWith(&args, binding.JSON); err != nil {
+		ctx.RespErr = e.ErrInvalidParam.AddDesc("invalid application args")
+		return
+	}
+	ctx.Resp, ctx.RespErr = service.CreateApplication(args, ctx.Logger)
+}
+
+func BulkCreateApplications(c *gin.Context) {
+	ctx, err := internalhandler.NewContextWithAuthorization(c)
+	defer func() { internalhandler.JSONResponse(c, ctx) }()
+	if err != nil {
+		ctx.RespErr = fmt.Errorf("authorization Info Generation failed: err %s", err)
+		ctx.UnAuthorized = true
+		return
+	}
+
+	var args []*commonmodels.Application
+	data, _ := c.GetRawData()
+	c.Request.Body = io.NopCloser(bytes.NewBuffer(data))
+	if err := c.ShouldBindWith(&args, binding.JSON); err != nil {
+		ctx.RespErr = e.ErrInvalidParam.AddDesc("invalid application args")
+		return
+	}
+
+	err = service.BulkCreateApplications(args, ctx.Logger)
+	if err != nil {
+		ctx.RespErr = err
+		return
+	}
+}
+
+func GetApplication(c *gin.Context) {
+	ctx := internalhandler.NewContext(c)
+	defer func() { internalhandler.JSONResponse(c, ctx) }()
+	ctx.Resp, ctx.RespErr = service.GetApplication(c.Param("id"), ctx.Logger)
+}
+
+func UpdateApplication(c *gin.Context) {
+	ctx, err := internalhandler.NewContextWithAuthorization(c)
+	defer func() { internalhandler.JSONResponse(c, ctx) }()
+	if err != nil {
+		ctx.RespErr = fmt.Errorf("authorization Info Generation failed: err %s", err)
+		ctx.UnAuthorized = true
+		return
+	}
+	args := new(commonmodels.Application)
+	data, _ := c.GetRawData()
+	if err := json.Unmarshal(data, args); err != nil {
+		ctx.RespErr = e.ErrInvalidParam.AddDesc("invalid application args")
+		return
+	}
+	ctx.RespErr = service.UpdateApplication(c.Param("id"), args, ctx.Logger)
+}
+
+func DeleteApplication(c *gin.Context) {
+	ctx, err := internalhandler.NewContextWithAuthorization(c)
+	defer func() { internalhandler.JSONResponse(c, ctx) }()
+	if err != nil {
+		ctx.RespErr = fmt.Errorf("authorization Info Generation failed: err %s", err)
+		ctx.UnAuthorized = true
+		return
+	}
+	ctx.RespErr = service.DeleteApplication(c.Param("id"), ctx.Logger)
+}
+
+func SearchApplications(c *gin.Context) {
+	ctx := internalhandler.NewContext(c)
+	defer func() { internalhandler.JSONResponse(c, ctx) }()
+	var req service.SearchApplicationsRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		ctx.RespErr = e.ErrInvalidParam.AddErr(err)
+		return
+	}
+	items, total, err := service.SearchApplications(&req, ctx.Logger)
+	if err != nil {
+		ctx.RespErr = err
+		return
+	}
+	ctx.Resp = gin.H{"items": items, "page": req.Page, "page_size": req.PageSize, "total": total}
+}
+
+func ListApplicationEnvs(c *gin.Context) {
+	ctx := internalhandler.NewContext(c)
+	defer func() { internalhandler.JSONResponse(c, ctx) }()
+	resp, err := service.ListApplicationEnvs(c.Param("id"), ctx.Logger)
+	if err != nil {
+		ctx.RespErr = err
+		return
+	}
+	ctx.Resp = resp
+}