types

type AppServer interface {
	Start() error                               // 开始
	Stop(forced ...bool) error                  // 默认为优雅关闭, 如果forced为true, 则强制关闭
	HookPreStart(fns ...HookFunction) AppServer // 添加启动前的钩子函数
	HookPreStop(fns ...HookFunction) AppServer  // 添加停止前的钩子函数
}

type CreateRefObjectRequest[TObjectKey KeyType, TBizObject any] struct {
	Key  TObjectKey `json:"key"`
	Item TBizObject `json:"item"`
}

type CreateRequest[TCreateModel any] struct {
	Item TCreateModel `json:"item"`
}

type DbBulkRetrieve[TObjectKey KeyType, ModelObject any] interface {
	BulkGet(ids []TObjectKey) (map[TObjectKey]ModelObject, error) // 批量获取对象
}

type DbCreate[BizObject any, ModelObject any] interface {
	Create(bizObj BizObject) (ModelObject, error) // 创建对象
}

type DbDelete[TObjectKey KeyType] interface {
	Delete(key TObjectKey) error // 删除对象
}

type DbEdit[TBizObject any] interface {
	Edit(bizObj TBizObject) error // 编辑对象
}

type DbOperation[TObjectKey KeyType, TBizObject any, TModelObject any, TCondition any] interface {
	DbCreate[TBizObject, TModelObject]
	DbRetrieve[TObjectKey, TModelObject, TCondition]
	DbUpdate[TModelObject]
	DbDelete[TObjectKey]
}

type DbRetrieve[TObjectKey KeyType, TModelObject any, TCondition any] interface {
	Get(key TObjectKey) (TModelObject, error)                                            // 获取对象
	Count(filters map[string]string) (int64, error)                                      // 统计对象
	List(filters map[string]string, list ...*protobuf.ListParam) ([]TModelObject, error) // 列出对象, list不传的时候获取所有对象
	GetQueryConditions(filters map[string]string) []TCondition                           // 获取查询条件
}

type DbUpdate[TModelObject any] interface {
	Update(modelObj TModelObject) error // 更新某个字段
}

type DeleteRefObjectRequest[TObjectKey KeyType] struct {
	Key     TObjectKey `json:"key"`
	ItemKey TObjectKey `json:"item_key"`
}

type DeleteRequest[TKey KeyType] struct {
	Keys []TKey `json:"keys"`
}

type EditRefObjectRequest[TObjectKey KeyType, TBizObject any] struct {
	Key  TObjectKey `json:"key"`
	Item TBizObject `json:"item"`
}

type GetRefObjectRequest[TObjectKey KeyType] struct {
	Key     TObjectKey `json:"key"`
	ItemKey TObjectKey `json:"item_key"`
}

type GetRequest[TKey KeyType] struct {
	Key TKey `json:"key"`
}

type HookFunction func() error

type KeyType interface {
	~int64 | ~int32 | ~int | ~string
}

type QueryRefObjectRequest[TObjectKey KeyType] struct {
	Key     TObjectKey          `json:"key"`
	Filters map[string]string   `json:"filters,omitempty"`
	List    *protobuf.ListParam `json:"list,omitempty"`
}

type QueryRefObjectResponse[TBizObject any] struct {
	Total int64        `json:"total"`
	Items []TBizObject `json:"items"`
}

type QueryRequest[TFilter any] struct {
	Filters TFilter             `json:"filters,omitempty"`
	List    *protobuf.ListParam `json:"list,omitempty"`
}

type QueryResponse[TResult any] struct {
	Total int64     `json:"total"`
	Items []TResult `json:"items"`
}

type RefDbBulkRetrieve[TObjectKey KeyType, TRefModelObject any] interface {
	BulkGet(key TObjectKey, refKeys []TObjectKey) (map[TObjectKey]TRefModelObject, error) // 批量获取对象
}

type RefDbCreate[TObjectKey KeyType, TRefBizObject any, TRefModelObject any] interface {
	Create(key TObjectKey, refBizObj TRefBizObject) (TRefModelObject, error) // 创建关联对象DAO
}

type RefDbDelete[TObjectKey KeyType] interface {
	Delete(key, refKey TObjectKey) error // 删除关联对象DAO
}

type RefDbEdit[TObjectKey KeyType, TRefBizObject any] interface {
	Edit(key TObjectKey, refBizObj TRefBizObject) error // 编辑数据库关联对象DAO
}

type RefDbOperation[TObjectKey KeyType, TRefBizObject any, TRefModelObject any, TCondition any] interface {
	RefDbCreate[TObjectKey, TRefBizObject, TRefModelObject]
	RefDbRetrieve[TObjectKey, TRefModelObject, TCondition]
	RefDbUpdate[TRefModelObject]
	RefDbDelete[TObjectKey]
}

type RefDbRetrieve[TObjectKey KeyType, TRefModelObject any, Condition any] interface {
	Get(key, refKey TObjectKey) (TRefModelObject, error)                                                          // 获取关联对象DAO
	Count(key TObjectKey, refObjFilters map[string]string) (int64, error)                                         // 统计关联对象DAO
	List(key TObjectKey, refObjFilters map[string]string, list ...*protobuf.ListParam) ([]TRefModelObject, error) // 列出关联对象DAO
	GetQueryConditions(key TObjectKey, refObjFilters map[string]string) []Condition                               // 获取关联对象DAO
}

type RefDbUpdate[TRefObjectModel any] interface {
	Update(refObjModel TRefObjectModel) error // 更新数据库关联对象
}

type RepoBulkGet[TKey KeyType, TModel any] interface {
	BulkGet(ctx context.Context, keys ...TKey) (map[TKey]TModel, error)
}

type RepoCount[TFilter any] interface {
	Count(ctx context.Context, filter TFilter) (int64, error)
}

type RepoCreate[TCreate any, TKey KeyType] interface {
	Create(ctx context.Context, model TCreate) (TKey, error)
}

type RepoDelete[TKey KeyType] interface {
	Delete(ctx context.Context, keys ...TKey) (int64, error)
}

type RepoGet[TKey KeyType, TModel any] interface {
	Get(ctx context.Context, key TKey) (TModel, error)
}

type RepoList[TFilter any, TModel any] interface {
	List(ctx context.Context, filter TFilter, list ...*protobuf.ListParam) ([]TModel, error)
}

type RepoOperation[TKey KeyType, TCreate, TUpdate, TFilter, TModel any] interface {
	RepoCreate[TCreate, TKey]
	RepoGet[TKey, TModel]
	RepoCount[TFilter]
	RepoList[TFilter, TModel]
	RepoUpdate[TUpdate]
	RepoDelete[TKey]
}

type RepoQuery[TFilter any, TModel any] interface {
	RepoCount[TFilter]
	RepoList[TFilter, TModel]
}

type RepoUpdate[TUpdate any] interface {
	Update(ctx context.Context, model TUpdate) error
}

type ScopedRepoCount[TScopeKey KeyType, TFilter any] interface {
	Count(ctx context.Context, scopeKey TScopeKey, filters TFilter) (int64, error)
}

type ScopedRepoCreate[TScopeKey, TKey KeyType, TCreate any] interface {
	Create(ctx context.Context, scopeKey TScopeKey, item TCreate) (TKey, error)
}

type ScopedRepoDelete[TScopeKey, TKey KeyType] interface {
	Delete(ctx context.Context, scopeKey TScopeKey, keys ...TKey) (int64, error)
}

type ScopedRepoList[TScopeKey KeyType, TFilter, TModel any] interface {
	List(ctx context.Context, scopeKey TScopeKey, filters TFilter, list ...*protobuf.ListParam) ([]TModel, error)
}

type ScopedRepoOperation[TScopeKey, TKey KeyType, TCreate, TUpdate, TFilter, TModel any] interface {
	RepoGet[TKey, TModel]
	ScopedRepoCreate[TScopeKey, TKey, TCreate]
	ScopedRepoUpdate[TScopeKey, TUpdate]
	ScopedRepoDelete[TScopeKey, TKey]
	ScopedRepoCount[TScopeKey, TFilter]
	ScopedRepoList[TScopeKey, TFilter, TModel]
}

type ScopedRepoUpdate[TScopeKey KeyType, TUpdate any] interface {
	Update(ctx context.Context, scopeKey TScopeKey, item TUpdate) error
}

type ServiceBulkGet[TKey KeyType, TResult any] interface {
	BulkGet(ctx context.Context, keys ...TKey) (map[TKey]TResult, error)
}

type ServiceCreate[TCreate any, TKey KeyType] interface {
	Create(ctx context.Context, model TCreate) (TKey, error) // 创建业务对象
}

type ServiceDelete[TKey KeyType] interface {
	Delete(ctx context.Context, keys ...TKey) error
}

type ServiceGet[TKey KeyType, TResult any] interface {
	Get(ctx context.Context, key TKey) (TResult, error) // 获取业务对象
}

type ServiceOperation[TKey KeyType, TCreate, TUpdate, TFilter, TResult any] interface {
	ServiceCreate[TCreate, TKey]
	ServiceGet[TKey, TResult]
	ServiceQuery[TFilter, TResult]
	ServiceUpdate[TUpdate]
	ServiceDelete[TKey]
}

type ServiceQuery[TFilter, TResult any] interface {
	Query(ctx context.Context, filters TFilter, list ...*protobuf.ListParam) (int64, []TResult, error) // 查询业务对象
}

type ServiceUpdate[TUpdate any] interface {
	Update(ctx context.Context, model TUpdate) error // 更新业务对象
}

type UpdateRequest[TUpdateModel any] struct {
	Item TUpdateModel `json:"item"`
}