pmb

type ActionPostArgs[T, F any] struct {
	Rows     []T              `json:"rows"`
	FormData F                `json:"form_data"`
	User     *SimpleUserModel `json:"user"`
	Model    IModelItem       `json:"model"`
}

type ActionPostPart[F any] struct {
	Name     string   `json:"name"`                // action名称
	Rows     []string `json:"rows,omitempty"`      // 选中的行id
	FormData F        `json:"form_data,omitempty"` // 表单填写的值
}

type Backend struct {
	Prefix string
	// contains filtered or unexported fields
}

type ContextValueInject struct {
	FromKey    string `json:"from_key,omitempty"`
	ToKey      string `json:"to_key,omitempty"`
	AllowEmpty bool   `json:"allow_empty,omitempty"`
}

type DynamicCall func(fieldId string, model IModelItem, user *SimpleUserModel, row map[string]any) (*DynamicResult, error)

type DynamicField struct {
	Id      string `json:"id"`      // 字段唯一id
	Name    string `json:"name"`    // 字段名
	Trigger string `json:"trigger"` // 触发方式 默认interval
	// contains filtered or unexported fields
}

type DynamicReq struct {
	RowUid string `json:"row_uid"` // 行id
	Id     string `json:"id"`      // 动态字段id
}

type DynamicResult struct {
	ShowType string `json:"show_type"`
	Data     any    `json:"data"`
}

type EmailPasswordLoginReq struct {
	Email    string `json:"email,omitempty" comment:"邮箱号码" validate:"required,email"`
	Password string `json:"password,omitempty" comment:"密码" validate:"required,min=6,max=36"`
	Force    bool   `json:"force,omitempty" comment:"强制"`
}

type IModelItem interface {
	GetBase() SchemaBase
	SetRaw(raw any)
	AddAction(action ISchemaAction)
	GetAction(name string) (ISchemaAction, bool)
	AddQueryFilterInject(fl *ut.Kov)
	ParseInject(ctx iris.Context) ([]*ut.Kov, error)
	GetCollection() *qmgo.Collection
	GetDb() *qmgo.Database
	GetTableName() string
	GetHandler(ctx iris.Context, queryParams pipe.QueryParseConfig, getParams pipe.ModelGetData, uid string) error
	PostHandler(ctx iris.Context, params pipe.ModelCtxMapperPack) error
	PutHandler(ctx iris.Context, params pipe.ModelPutConfig) error
	DelHandler(ctx iris.Context, params pipe.ModelDelConfig) error
	ActionEntry(ctx iris.Context)
	DynamicFieldsEntry(ctx iris.Context)
	Registry(part iris.Party)
	RegistryConfigAction(p iris.Party)
	RegistryCrud(p iris.Party)
	AddQueryContextInject(q ContextValueInject)
	GetContextUser(ctx iris.Context) *SimpleUserModel
	GetAllAction() []ISchemaAction
	SetPathId(newId string)
	GetRoles() *SchemaRole
	HaveUserKey(schema *jsonschema.Schema) bool
	GetSchema(mode ISchemaMode) *jsonschema.Schema
	SetSchemaRaw(mode ISchemaMode, raw any)
	SetSchema(mode ISchemaMode, schema *jsonschema.Schema)
	AddDynamicField(f *DynamicField)
	AddDF(id, name string, call DynamicCall)
	DfIdFind(id string) *DynamicField
}

type ISchemaAction interface {
	Execute(ctx iris.Context, args any) (responseInfo any, err error)
	GetBase() *SchemaActionBase
	SetCall(func(ctx iris.Context, args any) (responseInfo any, err error))
}

type ISchemaMode int

type ManySchema struct {
	Table  *jsonschema.Schema `json:"table"`
	Edit   *jsonschema.Schema `json:"edit"`
	Add    *jsonschema.Schema `json:"add"`
	Delete *jsonschema.Schema `json:"delete"`
}

type Message struct {
	UID       string          `json:"-"`
	Content   string          `json:"content,omitempty"`
	CreatedAt time.Time       `json:"created_at,omitempty"`
	Sequence  int             `json:"sequence,omitempty"`
	UA        map[string]bool `json:"-"`
}

type MessageQueue struct {
	// contains filtered or unexported fields
}

type OperationLog struct {
	pipe.ModelBase `bson:",inline"`

	Method   string   `json:"method,omitempty" bson:"method,omitempty" comment:"操作方法"`
	UserId   string   `json:"user_id,omitempty" bson:"user_id,omitempty" comment:"操作用户ID"`
	UserName string   `json:"user_name,omitempty" bson:"user_name,omitempty" comment:"操作用户名"`
	ToSheet  string   `json:"to_sheet,omitempty" bson:"to_sheet,omitempty" comment:"操作的表名"`
	ToRowId  string   `json:"to_row_id,omitempty" bson:"to_row_id,omitempty" comment:"行ID"`
	ToFields []ut.Kov `json:"to_fields,omitempty" bson:"to_fields,omitempty" comment:"字段内容"`
	Msg      string   `json:"msg,omitempty" bson:"msg,omitempty" comment:"消息"`
}

type Platform struct {
	Name      string `json:"name,omitempty" bson:"name,omitempty" comment:"平台名称"`
	Id        string `json:"id,omitempty" bson:"id,omitempty" comment:"平台唯一ID"`
	NickName  string `json:"nick_name,omitempty" bson:"nick_name,omitempty" comment:"平台昵称"`
	AvatarUrl string `json:"avatar_url,omitempty" bson:"avatar_url,omitempty" comment:"平台头像"`
	Data      string `json:"data,omitempty" bson:"data,omitempty" comment:"平台数据"`
}

type RoleUpLoginReq struct {
	Id     string `json:"id" comment:"id" validate:"required,max=50"`
	Secret string `json:"secret" comment:"秘钥" validate:"required,max=50"`
	Role   string `json:"role" comment:"权限" validate:"required,max=50"`
}

type SchemaActionBase struct {
	Name                        string             `json:"name,omitempty"`                   // 动作名称 需要唯一
	Prefix                      string             `json:"prefix,omitempty"`                 // 前缀标识 仅展示用
	Types                       []uint             `json:"types,omitempty"`                  // 0 表可用 1 行可用
	Form                        *jsonschema.Schema `json:"form,omitempty"`                   // 若form为nil 则不会弹出表单填写
	MustSelect                  bool               `json:"must_select,omitempty"`            // 必须有所选择表选择适用 行是必须选一行
	TableEmptySelectUseAllSheet bool               `json:"table_empty_select_use_all_sheet"` // 表模式未选中行则默认是整表
	Conditions                  []ut.Kov           `json:"conditions,omitempty"`             // 选中/执行的前置条件 判断数据为选中的每一行数据 常用场景为 限定只有字段a=b时才可用或a!=b时 挨个执行 任意一个不成功都返回
	FaWarning                   bool               `json:"fa_warning,omitempty"`             // 是否弹出二次确认操作
}

type SchemaBase struct {
	Group     string `json:"group,omitempty"`      // 组名
	Priority  int    `json:"priority,omitempty"`   // 在组下显示的优先级 越大越优先
	TableName string `json:"table_name,omitempty"` // 表名
	UniqueId  string `json:"unique_id,omitempty"`  // 唯一ID 默认生成sonyflakeId
	PathId    string `json:"path_id,omitempty"`    // 路径ID 默认取UniqueId 在加入backend时会自动修改
	RawName   string `json:"raw_name,omitempty"`   // 原始名称
	Alias     string `json:"alias,omitempty"`      // 别名 中文名
}

type SchemaGetResp struct {
	*ut.MongoFacetResult
	Page     int64          `json:"page,omitempty"`
	PageSize int64          `json:"page_size,omitempty"`
	Sorts    *ut.BaseSort   `json:"sorts,omitempty"`
	Filters  *ut.QueryParse `json:"filters,omitempty"`
}

type SchemaHooks[T any] struct {
	CustomAddHandler func(ctx iris.Context, params pipe.ModelCtxMapperPack, model *SchemaModel[T]) error
	OnAddBefore      func(ctx iris.Context, args *pipe.RunResp[any], model *SchemaModel[T]) error                                      // 在新增之前
	OnAddAfter       func(ctx iris.Context, args *pipe.RunResp[map[string]any], model *SchemaModel[T]) error                           // 在新增之后
	OnGetBefore      func(ctx iris.Context, args *pipe.RunResp[*ut.QueryFull], params *pipe.ModelGetData, model *SchemaModel[T]) error // 在获取之前
	OnGetAfter       func(ctx iris.Context, args *pipe.RunResp[*ut.MongoFacetResult], model *SchemaModel[T]) error                     // 在获取之后
	OnEditBefore     func(ctx iris.Context)                                                                                            // 在修改之前
	OnEditAfter      func(ctx iris.Context)                                                                                            // 在修改之后
	OnDelBefore      func(ctx iris.Context)                                                                                            // 在删除之前
	OnDelAfter       func(ctx iris.Context)                                                                                            // 在删除之后
}

type SchemaIframe struct {
	Url string `json:"url,omitempty"`
}

type SchemaModel[T any] struct {
	SchemaBase

	Roles         *SchemaRole         `json:"roles,omitempty"`
	Schemas       ManySchema          `json:"schemas"`
	Iframe        *SchemaIframe       `json:"iframe,omitempty"`
	TableDisable  *SchemaTableDisable `json:"table_disable,omitempty"`
	Actions       []ISchemaAction     `json:"actions,omitempty"`        // 各类操作
	DynamicFields []*DynamicField     `json:"dynamic_fields,omitempty"` // 动态字段

	WriteInsert  bool     `json:"write_insert,omitempty"`   // 是否把注入内容写入新增体
	PostMustKeys []string `json:"post_must_keys,omitempty"` // 新增时候必须存在的key

	Hooks SchemaHooks[T]
	// contains filtered or unexported fields
}

type SchemaModelAction[T, F any] struct {
	SchemaActionBase
	// contains filtered or unexported fields
}

type SchemaRole struct {
	RoleGroup []string `json:"role_group"` // staff root
	NameGroup []string `json:"name_group"` // 自定义名称组
}

type SchemaTableDisable struct {
	Read    bool `json:"read,omitempty"`
	Edit    bool `json:"edit,omitempty"`
	Del     bool `json:"del,omitempty"`
	Create  bool `json:"create,omitempty"`
	Actions bool `json:"actions,omitempty"`
}

type SimpleUserModel struct {
	pipe.GenericsAccount `bson:",inline"`
	// contains filtered or unexported fields
}

type UserModel interface {
	InjectDefault(mp map[string]any) error
	GetUid() string
}

type UserPasswordLoginReq struct {
	UserName string `json:"user_name,omitempty" comment:"用户名" validate:"required,min=3,max=24"`
	Password string `json:"password,omitempty" comment:"密码" validate:"required,min=6,max=36"`
	Force    bool   `json:"force,omitempty" comment:"强制"`
}