file

Documentation

Index

• type Directory
• type File
• type GetDirectoryByAppRequest
• type GetFileRequest
• type GetFileResponse
• type PageFileRequest
• type PrepareUploadFileReply
• type PrepareUploadFileRequest
• type Repo
• type UploadFileReply
• type UploadFileRequest
• type UseCase
  • func NewUseCase(config *config.Config, repo Repo) *UseCase
  • func (u *UseCase) AddDirectory(ctx kratosx.Context, in *Directory) (uint32, error)
  • func (u *UseCase) AllDirectoryByParentID(ctx kratosx.Context, pid uint32, app string) ([]*Directory, error)
  • func (u *UseCase) DeleteDirectory(ctx kratosx.Context, id uint32, app string) error
  • func (u *UseCase) DeleteFiles(ctx kratosx.Context, pid uint32, ids []uint32) error
  • func (u *UseCase) GetFile(ctx kratosx.Context, in *GetFileRequest) (*GetFileResponse, error)
  • func (u *UseCase) GetFileBySha(ctx kratosx.Context, sha string) (*File, error)
  • func (u *UseCase) PageFile(ctx kratosx.Context, in *PageFileRequest) ([]*File, uint32, error)
  • func (u *UseCase) PrepareUploadFile(ctx kratosx.Context, in *PrepareUploadFileRequest) (*PrepareUploadFileReply, error)
  • func (u *UseCase) UpdateDirectory(ctx kratosx.Context, in *Directory) error
  • func (u *UseCase) UpdateFile(ctx kratosx.Context, file *File) error
  • func (u *UseCase) UploadFile(ctx kratosx.Context, in *UploadFileRequest) (*UploadFileReply, error)

Types

type Directory

type Directory struct {
	types.BaseModel
	ParentID uint32 `json:"parent_id" gorm:"uniqueIndex:pna;not null;comment:父id"`
	Name     string `json:"name" gorm:"uniqueIndex:pna;not null;size:128;comment:目录名称"`
	App      string `json:"app" gorm:"uniqueIndex:pna;not null;size:32;comment:所属应用"`
}

type File

type File struct {
	types.BaseModel
	DirectoryID uint32     `json:"directory_id" gorm:"uniqueIndex:dir_name;uniqueIndex:dir_sha;not null;comment:目录id"`
	Name        string     `json:"name" gorm:"uniqueIndex:dir_name;not null;size:128;comment:文件名称"`
	Type        string     `json:"type" gorm:"not null;size:32;comment:文件类型"`
	Size        uint32     `json:"size" gorm:"not null;comment:文件大小"`
	Sha         string     `json:"sha" gorm:"uniqueIndex:dir_sha;not null;size:128;comment:文件sha"`
	Src         string     `json:"src" gorm:"size:256;comment:文件真实路径"`
	UploadID    *string    `json:"upload_id" gorm:"uniqueIndex;size:128;comment:上传id"`
	ChunkCount  uint32     `json:"chunk_count" gorm:"default:1;comment:切片数量"`
	Storage     string     `json:"storage" gorm:"not null;size:32;comment:存储引擎"`
	Status      string     `json:"status" gorm:"default:PROGRESS;size:32;comment:上传状态"`
	Directory   *Directory `json:"directory" gorm:"constraint:onDelete:cascade"`
}

type GetDirectoryByAppRequest

type GetDirectoryByAppRequest struct {
	App      string `json:"app"`
	ParentID uint32 `json:"parent_id"`
}

type GetFileRequest

type GetFileRequest struct {
	Src    string `json:"src"`
	Width  int    `json:"width"`
	Height int    `json:"height"`
	Mode   string `json:"mode"`
}

type GetFileResponse

type GetFileResponse struct {
	Data []byte `json:"data"`
	Mime string `json:"mime"`
}

type PageFileRequest

type PageFileRequest struct {
	Page        uint32 `json:"page"`
	PageSize    uint32 `json:"page_size"`
	Name        string `json:"name"`
	DirectoryId uint32 `json:"directory_id"`
}

type PrepareUploadFileReply

type PrepareUploadFileReply struct {
	Uploaded     *bool   `json:"uploaded"`
	Src          *string `json:"src"`
	ChunkSize    *uint32 `json:"chunk_size"`
	ChunkCount   *uint32 `json:"chunk_count"`
	UploadId     *string `json:"upload_id"`
	UploadChunks []int   `json:"upload_chunks"`
	Sha          *string `json:"sha"`
}

type PrepareUploadFileRequest

type PrepareUploadFileRequest struct {
	DirectoryId   uint32 `json:"directory_id"`
	DirectoryPath string `json:"directory_path"`
	App           string `json:"app"`
	Name          string `json:"name"`
	Sha           string `json:"sha"`
	Size          uint32 `json:"size"`
}

type Repo

type Repo interface {
	AddDirectory(ctx kratosx.Context, in *Directory) (uint32, error)
	GetDirectoryByID(ctx kratosx.Context, id uint32) (*Directory, error)
	GetDirectoryByName(ctx kratosx.Context, id uint32, name string) (*Directory, error)
	GetDirectoryByPaths(ctx kratosx.Context, app string, paths []string) (*Directory, error)
	UpdateDirectory(ctx kratosx.Context, in *Directory) error
	DeleteDirectory(ctx kratosx.Context, id uint32) error
	AllDirectoryByParentID(ctx kratosx.Context, pid uint32, app string) ([]*Directory, error)
	DirectoryCountByParentID(ctx kratosx.Context, id uint32) (int64, error)

	CopyFile(ctx kratosx.Context, src *File, did uint32, name string) error
	FileCountByName(ctx kratosx.Context, did uint32, name string) (int64, error)
	FileCountByDirectoryID(ctx kratosx.Context, id uint32) (int64, error)
	GetFileByID(ctx kratosx.Context, id uint32) (*File, error)
	GetFileBySha(ctx kratosx.Context, keyword string) (*File, error)
	GetFileByUploadID(ctx kratosx.Context, uid string) (*File, error)
	PageFile(ctx kratosx.Context, req *PageFileRequest) ([]*File, uint32, error)
	AddFile(ctx kratosx.Context, c *File) error
	UpdateFile(ctx kratosx.Context, file *File) error
	UpdateFileSuccess(ctx kratosx.Context, id uint32) error

	DeleteFile(ctx kratosx.Context, id uint32) error
	DeleteFiles(ctx kratosx.Context, pid uint32, ids []uint32) error
}

type UploadFileReply

type UploadFileReply struct {
	Src string
	Sha string
}

type UploadFileRequest

type UploadFileRequest struct {
	Data     []byte `json:"data"`
	UploadId string `json:"upload_id"`
	Index    uint32 `json:"index"`
}

type UseCase

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

func NewUseCase

func NewUseCase(config *config.Config, repo Repo) *UseCase

func (*UseCase) AddDirectory

func (u *UseCase) AddDirectory(ctx kratosx.Context, in *Directory) (uint32, error)

func (*UseCase) AllDirectoryByParentID

func (u *UseCase) AllDirectoryByParentID(ctx kratosx.Context, pid uint32, app string) ([]*Directory, error)

func (*UseCase) DeleteDirectory

func (u *UseCase) DeleteDirectory(ctx kratosx.Context, id uint32, app string) error

func (*UseCase) DeleteFiles

func (u *UseCase) DeleteFiles(ctx kratosx.Context, pid uint32, ids []uint32) error

DeleteFiles 删除文件

func (*UseCase) GetFile

func (u *UseCase) GetFile(ctx kratosx.Context, in *GetFileRequest) (*GetFileResponse, error)

func (*UseCase) GetFileBySha

func (u *UseCase) GetFileBySha(ctx kratosx.Context, sha string) (*File, error)

func (*UseCase) PageFile

func (u *UseCase) PageFile(ctx kratosx.Context, in *PageFileRequest) ([]*File, uint32, error)

func (*UseCase) PrepareUploadFile

func (u *UseCase) PrepareUploadFile(ctx kratosx.Context, in *PrepareUploadFileRequest) (*PrepareUploadFileReply, error)

PrepareUploadFile 预上传文件

func (*UseCase) UpdateDirectory

func (u *UseCase) UpdateDirectory(ctx kratosx.Context, in *Directory) error

func (*UseCase) UpdateFile

func (u *UseCase) UpdateFile(ctx kratosx.Context, file *File) error

UpdateFile 修改文件名称

func (*UseCase) UploadFile

func (u *UseCase) UploadFile(ctx kratosx.Context, in *UploadFileRequest) (*UploadFileReply, error)