types

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

type BulkOperateObjectRequest[TObjectKey ObjectKeyType] struct {
	Keys []TObjectKey `json:"keys"`
}

type CreateObjectResponse[TObjectId ObjectKeyType] struct {
	Id TObjectId `json:"id"`
}

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

type DbBulkRetrieve[TObjectKey ObjectKeyType, 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 ObjectKeyType] interface {
	Delete(key TObjectKey) error // 删除对象
}

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

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

type DbRetrieve[TObjectKey ObjectKeyType, 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 ObjectKeyType] struct {
	Key     TObjectKey `json:"key"`
	ItemKey TObjectKey `json:"item_key"`
}

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

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

type HookFunction func() error

type ObjectKeyType interface {
	int64 | int32 | int | string
}

type OperateObjectRequest[TObjectKey ObjectKeyType] struct {
	Key TObjectKey `json:"key"`
}

type QueryObjectRequest struct {
	Filters map[string]string   `json:"filters,omitempty"`
	List    *protobuf.ListParam `json:"list,omitempty"`
}

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

type QueryRefObjectRequest[TObjectKey ObjectKeyType] 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 RefDbBulkRetrieve[TObjectKey ObjectKeyType, TRefModelObject any] interface {
	BulkGet(key TObjectKey, refKeys []TObjectKey) (map[TObjectKey]TRefModelObject, error) // 批量获取对象
}

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

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

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

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

type RefDbRetrieve[TObjectKey ObjectKeyType, 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 RepoBulkCreate[TModelObject any] interface {
	BulkCreate(ctx context.Context, items []TModelObject) ([]TModelObject, error)
}

type RepoBulkGet[TObjectKey ObjectKeyType, TModelObject any] interface {
	BulkGet(ctx context.Context, ids []TObjectKey) (map[TObjectKey]TModelObject, error)
}

type RepoCRUD[TObjectKey ObjectKeyType, TBizObject any, TModelObject any] interface {
	RepoCreate[TBizObject, TModelObject]
	RepoRetrieve[TObjectKey, TModelObject]
	RepoEdit[TBizObject, TModelObject]
	RepoDelete[TObjectKey]
}

type RepoCRUDFull[TObjectKey ObjectKeyType, TBizObject any, TModelObject any] interface {
	RepoCreate[TBizObject, TModelObject]
	RepoRetrieve[TObjectKey, TModelObject]
	RepoBulkGet[TObjectKey, TModelObject]
	RepoEdit[TBizObject, TModelObject]
	RepoDelete[TObjectKey]
}

type RepoCRUDWithBulk[TObjectKey ObjectKeyType, TBizObject any, TModelObject any] interface {
	RepoCRUD[TObjectKey, TBizObject, TModelObject]
	RepoBulkGet[TObjectKey, TModelObject]
}

type RepoCreate[TBizObject any, TModelObject any] interface {
	Create(ctx context.Context, bizObj TBizObject) (TModelObject, error)
}

type RepoDelete[TObjectKey ObjectKeyType] interface {
	Delete(ctx context.Context, key TObjectKey) error
}

type RepoEdit[TBizObject any, TModelObject any] interface {
	Edit(ctx context.Context, bizObj TBizObject) (TModelObject, error)
}

type RepoRetrieve[TObjectKey ObjectKeyType, TModelObject any] interface {
	Get(ctx context.Context, key TObjectKey) (TModelObject, error)
	Count(ctx context.Context, filters map[string]string) (int64, error)
	List(ctx context.Context, filters map[string]string, list ...*protobuf.ListParam) ([]TModelObject, error)
}

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

type RepoUpsert[TBizObject any, TModelObject any] interface {
	Upsert(ctx context.Context, bizObj TBizObject) (TModelObject, error)
}

type ServiceBulkCreate[TModelObject any] interface {
	BulkCreate(ctx context.Context, items []TModelObject) ([]TModelObject, error)
}

type ServiceBulkGet[TObjectKey ObjectKeyType, TModelObject any] interface {
	BulkGet(ctx context.Context, ids []TObjectKey) (map[TObjectKey]TModelObject, error)
}

type ServiceCreate[TBizObject any] interface {
	Create(ctx context.Context, object TBizObject) (int64, error) // 创建业务对象
}

type ServiceDelete[TObjectKey ObjectKeyType] interface {
	Delete(ctx context.Context, key TObjectKey) error // 删除业务对象
}

type ServiceEdit[TBizObject any] interface {
	Edit(ctx context.Context, bizObject TBizObject) error // 编辑业务对象
}

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

type ServiceOperation[TObjectKey ObjectKeyType, TBizObject any] interface {
	ServiceCreate[TBizObject]
	ServiceRetrieve[TObjectKey, TBizObject]
	ServiceEdit[TBizObject]
	ServiceDelete[TObjectKey]
}

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

type ServiceRetrieve[TObjectKey ObjectKeyType, TBizObject any] interface {
	ServiceGet[TObjectKey, TBizObject]
	ServiceQuery[TBizObject]
}

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