Browse Source

准备添加tag

yjp 1 year ago
parent
commit
71f5666bf1

+ 47 - 0
convenient/data_containers/auth/permission.yaml

@@ -0,0 +1,47 @@
+kind: DataContainer
+spec:
+  namespace: # 替换
+  data_source: # 替换
+  name: # 替换.permissions
+  spec:
+    table_name: # 替换.permissions
+    columns:
+      - name: id
+        type: "varchar(32)"
+        comment: id
+        primary_key: true
+      - name: name
+        type: "varchar(256)"
+        comment: 权限名称
+        not_null: true
+        index: true
+      - name: description
+        type: "text"
+        comment: 权限描述
+        not_null: true
+      - name: resource
+        type: "text"
+        comment: resource
+        not_null: true
+        index: true
+      - name: action
+        type: "varchar(128)"
+        comment: action
+        not_null: true
+        index: true
+      - name: create_user_id
+        type: "varchar(32)"
+        comment: 创建用户ID
+        not_null: true
+      - name: last_update_user_id
+        type: "varchar(32)"
+        comment: 最近更新用户ID
+        not_null: true
+      - name: created_time
+        type: "timestamp with time zone"
+        comment: 创建时间
+        not_null: true
+      - name: last_updated_time
+        type: "timestamp with time zone"
+        comment: 最近更新时间
+        not_null: true

+ 37 - 0
convenient/data_containers/auth/permission_group.yaml

@@ -0,0 +1,37 @@
+kind: DataContainer
+spec:
+  namespace: # 替换
+  data_source: # 替换
+  name: # 替换.permission_groups
+  spec:
+    table_name: # 替换.permission_groups
+    columns:
+      - name: id
+        type: "varchar(32)"
+        comment: id
+        primary_key: true
+      - name: name
+        type: "varchar(256)"
+        comment: 权限名称
+        not_null: true
+        index: true
+      - name: description
+        type: "text"
+        comment: 权限描述
+        not_null: true
+      - name: create_user_id
+        type: "varchar(32)"
+        comment: 创建用户ID
+        not_null: true
+      - name: last_update_user_id
+        type: "varchar(32)"
+        comment: 最近更新用户ID
+        not_null: true
+      - name: created_time
+        type: "timestamp with time zone"
+        comment: 创建时间
+        not_null: true
+      - name: last_updated_time
+        type: "timestamp with time zone"
+        comment: 最近更新时间
+        not_null: true

+ 37 - 0
convenient/data_containers/auth/role.yaml

@@ -0,0 +1,37 @@
+kind: DataContainer
+spec:
+  namespace: # 替换
+  data_source: # 替换
+  name: # 替换.roles
+  spec:
+    table_name: # 替换.roles
+    columns:
+      - name: id
+        type: "varchar(32)"
+        comment: id
+        primary_key: true
+      - name: name
+        type: "varchar(256)"
+        comment: 权限名称
+        not_null: true
+        index: true
+      - name: description
+        type: "text"
+        comment: 权限描述
+        not_null: true
+      - name: create_user_id
+        type: "varchar(32)"
+        comment: 创建用户ID
+        not_null: true
+      - name: last_update_user_id
+        type: "varchar(32)"
+        comment: 最近更新用户ID
+        not_null: true
+      - name: created_time
+        type: "timestamp with time zone"
+        comment: 创建时间
+        not_null: true
+      - name: last_updated_time
+        type: "timestamp with time zone"
+        comment: 最近更新时间
+        not_null: true

+ 34 - 0
convenient/data_containers/auth/user.yaml

@@ -0,0 +1,34 @@
+kind: DataContainer
+spec:
+  namespace: # 替换
+  data_source: # 替换
+  name: # 替换.users
+  spec:
+    table_name: # 替换.users
+    columns:
+      - name: id
+        type: "varchar(32)"
+        comment: id
+        primary_key: true
+      - name: user_name
+        type: "varchar(256)"
+        comment: 用户名
+        not_null: true
+        index: true
+        unique: true
+      - name: password
+        type: "varchar(512)"
+        comment: 密码
+        not_null: true
+      - name: last_login_time
+        type: "timestamp with time zone"
+        comment: 最近登录时间
+        not_null: true
+      - name: created_time
+        type: "timestamp with time zone"
+        comment: 创建时间
+        not_null: true
+      - name: last_updated_time
+        type: "timestamp with time zone"
+        comment: 最近更新时间
+        not_null: true

+ 0 - 0
convenient/data_containers/configuration.yaml → convenient/data_containers/configuration/configuration.yaml


+ 0 - 0
convenient/data_containers/sql_executor.yaml → convenient/data_containers/sql_executor/sql_executor.yaml


+ 1 - 0
convenient/domain/auth/auth.go

@@ -0,0 +1 @@
+package auth

+ 1 - 0
convenient/domain/auth/middleware.go

@@ -0,0 +1 @@
+package auth

+ 1 - 0
convenient/domain/auth/permission/api.go

@@ -0,0 +1 @@
+package permission

+ 146 - 0
convenient/domain/auth/permission/entity.go

@@ -0,0 +1,146 @@
+package permission
+
+import (
+	"git.sxidc.com/go-framework/baize/framework/core/domain"
+	"git.sxidc.com/go-framework/baize/framework/core/domain/entity"
+	"git.sxidc.com/go-framework/baize/framework/core/tag/check"
+	"git.sxidc.com/go-tools/utils/strutils"
+	"github.com/pkg/errors"
+)
+
+const (
+	FieldName        = "Name"
+	FieldDescription = "Description"
+	FieldResource    = "Resource"
+	FieldAction      = "Action"
+)
+
+var (
+	ColumnName        = domain.ColumnName(FieldName)
+	ColumnDescription = domain.ColumnName(FieldDescription)
+	ColumnResource    = domain.ColumnName(FieldResource)
+	ColumnAction      = domain.ColumnName(FieldAction)
+)
+
+var fieldMap = map[string]string{
+	FieldName:        "权限名称",
+	FieldDescription: "权限描述",
+	FieldResource:    "resource",
+	FieldAction:      "action",
+}
+
+type Entity struct {
+	entity.Base
+	Name        string `sqlmapping:"column:name" sqlresult:"column:name" check:"required,lte=256"`
+	Description string `sqlmapping:"column:description;updateClear" sqlresult:"column:description"`
+	Resource    string `sqlmapping:"column:resource" sqlresult:"column:resource" check:"required"`
+	Action      string `sqlmapping:"column:action" sqlresult:"column:action" check:"required,lte=128"`
+
+	PermissionGroupIDs []string `sqlmapping:"-" sqlresult:"-"`
+	RoleIDs            []string `sqlmapping:"-" sqlresult:"-"`
+
+	entity.UserIDFields
+	entity.TimeFields
+}
+
+func (e *Entity) DomainCNName() string {
+	return "权限"
+}
+
+func (e *Entity) DomainCamelName() string {
+	return "Permission"
+}
+
+func (e *Entity) ForCreate() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	err = domain.CheckField(checkResult, e.DomainCNName(), FieldName)
+	if err != nil {
+		return err
+	}
+
+	err = domain.CheckField(checkResult, e.DomainCNName(), FieldResource)
+	if err != nil {
+		return err
+	}
+
+	err = domain.CheckField(checkResult, e.DomainCNName(), FieldAction)
+	if err != nil {
+		return err
+	}
+
+	err = entity.CheckFieldCreateUserIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	e.LastUpdateUserID = e.CreateUserID
+
+	return nil
+}
+
+func (e *Entity) ForDelete() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (e *Entity) ForUpdate() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	err = entity.CheckFieldLastUpdateUserIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	err = e.checkUpdateFields(checkResult)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (e *Entity) checkUpdateFields(checkResult check.Result) error {
+	if strutils.AllBlank(e.Name, e.Resource, e.Action) {
+		return errors.New(e.DomainCNName() + "没有传递需要更新的字段")
+	}
+
+	if strutils.IsStringNotEmpty(e.Name) {
+		err := domain.CheckField(checkResult, e.DomainCNName(), FieldName)
+		if err != nil {
+			return err
+		}
+	}
+
+	if strutils.IsStringNotEmpty(e.Resource) {
+		err := domain.CheckField(checkResult, e.DomainCNName(), FieldResource)
+		if err != nil {
+			return err
+		}
+	}
+
+	if strutils.IsStringNotEmpty(e.Action) {
+		err := domain.CheckField(checkResult, e.DomainCNName(), FieldAction)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}

+ 1 - 0
convenient/domain/auth/permission/request_params.go

@@ -0,0 +1 @@
+package permission

+ 1 - 0
convenient/domain/auth/permission_group/api.go

@@ -0,0 +1 @@
+package permission_group

+ 113 - 0
convenient/domain/auth/permission_group/entity.go

@@ -0,0 +1,113 @@
+package permission_group
+
+import (
+	"git.sxidc.com/go-framework/baize/framework/core/domain"
+	"git.sxidc.com/go-framework/baize/framework/core/domain/entity"
+	"git.sxidc.com/go-framework/baize/framework/core/tag/check"
+	"git.sxidc.com/go-tools/utils/strutils"
+	"github.com/pkg/errors"
+)
+
+const (
+	FieldName        = "Name"
+	FieldDescription = "Description"
+)
+
+var (
+	ColumnName        = domain.ColumnName(FieldName)
+	ColumnDescription = domain.ColumnName(FieldDescription)
+)
+
+var fieldMap = map[string]string{
+	FieldName:        "权限组名称",
+	FieldDescription: "权限组描述",
+}
+
+type Entity struct {
+	entity.Base
+	Name        string `sqlmapping:"column:name" sqlresult:"column:name" check:"required,lte=256"`
+	Description string `sqlmapping:"column:description;updateClear" sqlresult:"column:description"`
+
+	PermissionIDs []string `sqlmapping:"-" sqlresult:"-"`
+
+	entity.UserIDFields
+	entity.TimeFields
+}
+
+func (e *Entity) DomainCNName() string {
+	return "权限组"
+}
+
+func (e *Entity) DomainCamelName() string {
+	return "PermissionGroup"
+}
+
+func (e *Entity) ForCreate() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	err = domain.CheckField(checkResult, e.DomainCNName(), FieldName)
+	if err != nil {
+		return err
+	}
+
+	err = entity.CheckFieldCreateUserIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	e.LastUpdateUserID = e.CreateUserID
+
+	return nil
+}
+
+func (e *Entity) ForDelete() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (e *Entity) ForUpdate() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	err = entity.CheckFieldLastUpdateUserIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	err = e.checkUpdateFields(checkResult)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (e *Entity) checkUpdateFields(checkResult check.Result) error {
+	if strutils.AllBlank(e.Name) {
+		return errors.New(e.DomainCNName() + "没有传递需要更新的字段")
+	}
+
+	if strutils.IsStringNotEmpty(e.Name) {
+		err := domain.CheckField(checkResult, e.DomainCNName(), FieldName)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}

+ 1 - 0
convenient/domain/auth/permission_group/request_params.go

@@ -0,0 +1 @@
+package permission_group

+ 1 - 0
convenient/domain/auth/role/api.go

@@ -0,0 +1 @@
+package role

+ 114 - 0
convenient/domain/auth/role/entity.go

@@ -0,0 +1,114 @@
+package role
+
+import (
+	"git.sxidc.com/go-framework/baize/framework/core/domain"
+	"git.sxidc.com/go-framework/baize/framework/core/domain/entity"
+	"git.sxidc.com/go-framework/baize/framework/core/tag/check"
+	"git.sxidc.com/go-tools/utils/strutils"
+	"github.com/pkg/errors"
+)
+
+const (
+	FieldName        = "Name"
+	FieldDescription = "Description"
+)
+
+var (
+	ColumnName        = domain.ColumnName(FieldName)
+	ColumnDescription = domain.ColumnName(FieldDescription)
+)
+
+var fieldMap = map[string]string{
+	FieldName:        "角色名称",
+	FieldDescription: "角色描述",
+}
+
+type Entity struct {
+	entity.Base
+	Name        string `sqlmapping:"column:name" sqlresult:"column:name" check:"required,lte=256"`
+	Description string `sqlmapping:"column:description;updateClear" sqlresult:"column:description"`
+
+	UserIDs       []string `sqlmapping:"-" sqlresult:"-"`
+	PermissionIDs []string `sqlmapping:"-" sqlresult:"-"`
+
+	entity.UserIDFields
+	entity.TimeFields
+}
+
+func (e *Entity) DomainCNName() string {
+	return "角色"
+}
+
+func (e *Entity) DomainCamelName() string {
+	return "Role"
+}
+
+func (e *Entity) ForCreate() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	err = domain.CheckField(checkResult, e.DomainCNName(), FieldName)
+	if err != nil {
+		return err
+	}
+
+	err = entity.CheckFieldCreateUserIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	e.LastUpdateUserID = e.CreateUserID
+
+	return nil
+}
+
+func (e *Entity) ForDelete() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (e *Entity) ForUpdate() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	err = entity.CheckFieldLastUpdateUserIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	err = e.checkUpdateFields(checkResult)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (e *Entity) checkUpdateFields(checkResult check.Result) error {
+	if strutils.AllBlank(e.Name) {
+		return errors.New(e.DomainCNName() + "没有传递需要更新的字段")
+	}
+
+	if strutils.IsStringNotEmpty(e.Name) {
+		err := domain.CheckField(checkResult, e.DomainCNName(), FieldName)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}

+ 1 - 0
convenient/domain/auth/role/request_params.go

@@ -0,0 +1 @@
+package role

+ 1 - 0
convenient/domain/auth/user/api.go

@@ -0,0 +1 @@
+package user

+ 93 - 0
convenient/domain/auth/user/entity.go

@@ -0,0 +1,93 @@
+package user
+
+import (
+	"git.sxidc.com/go-framework/baize/framework/core/domain"
+	"git.sxidc.com/go-framework/baize/framework/core/domain/entity"
+	"git.sxidc.com/go-framework/baize/framework/core/tag/check"
+	"time"
+)
+
+const (
+	FieldUserName      = "UserName"
+	FieldPassword      = "Password"
+	FieldLastLoginTime = "LastLoginTime"
+)
+
+var (
+	ColumnUserName      = domain.ColumnName(FieldUserName)
+	ColumnPassword      = domain.ColumnName(FieldPassword)
+	ColumnLastLoginTime = domain.ColumnName(FieldLastLoginTime)
+)
+
+var fieldMap = map[string]string{
+	FieldUserName:      "用户名",
+	FieldPassword:      "密码",
+	FieldLastLoginTime: "最近登录时间",
+}
+
+type Entity struct {
+	entity.Base
+	UserName      string    `sqlmapping:"column:user_name;notUpdate" sqlresult:"column:user_name" check:"required,lte=256"`
+	Password      string    `sqlmapping:"column:password;aes:'@MKU^AAOP%H*K¥VJ<%G&j*o#$XZSWQ@L'" sqlresult:"column:password;aes:'@MKU^AAOP%H*K¥VJ<%G&j*o#$XZSWQ@L'" check:"required,lte=256"`
+	LastLoginTime time.Time `sqlmapping:"column:last_login_time;notUpdate" sqlresult:"column:last_login_time"`
+
+	RoleIDs []string
+
+	entity.TimeFields
+}
+
+func (e *Entity) DomainCNName() string {
+	return "用户"
+}
+
+func (e *Entity) DomainCamelName() string {
+	return "User"
+}
+
+func (e *Entity) ForCreate() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	err = domain.CheckField(checkResult, e.DomainCNName(), FieldUserName)
+	if err != nil {
+		return err
+	}
+
+	err = domain.CheckField(checkResult, e.DomainCNName(), FieldPassword)
+	if err != nil {
+		return err
+	}
+
+	err = domain.CheckField(checkResult, e.DomainCNName(), FieldLastLoginTime)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (e *Entity) ForDelete() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (e *Entity) ForUpdate() error {
+	checkResult := check.Struct(e, fieldMap)
+
+	err := entity.CheckFieldIDResult(checkResult)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}

+ 1 - 0
convenient/domain/auth/user/request_params.go

@@ -0,0 +1 @@
+package user