file.go
1.8 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
package domain
import (
"path/filepath"
"strings"
"time"
)
// File 文件
type File struct {
// 文件ID
FileId int `json:"fileId"`
// 文件类型
FileType string `json:"fileType"`
// 文件信息
FileInfo *FileInfo `json:"fileInfo"`
// 源文件Id(FileType为TemporaryFile或VerifiedFile时有值)
SourceFileId int `json:"sourceFileId"`
// 操作人
// Operator string `json:"operator"`
// 创建时间
CreatedAt time.Time `json:"createdAt"`
// 更新时间
UpdatedAt time.Time `json:"updatedAt"`
// 删除时间
DeletedAt time.Time `json:"deletedAt"`
// 版本
Version int `json:"version"`
// 扩展
Context *Context `json:"context"`
}
type FileRepository interface {
Save(file *File) (*File, error)
Remove(file *File) (*File, error)
FindOne(queryOptions map[string]interface{}) (*File, error)
Find(queryOptions map[string]interface{}) (int64, []*File, error)
}
func (file *File) Identify() interface{} {
if file.FileId == 0 {
return nil
}
return file.FileId
}
func (file *File) UpdateFileUrl(url string) {
if len(url) == 0 {
return
}
if url == file.FileInfo.Url {
return
}
file.FileInfo.Ext = filepath.Ext(url)
file.FileInfo.Url = url
}
func (file *File) Update(data map[string]interface{}) error {
return nil
}
func FileName(fileName string) string {
base := filepath.Base(fileName)
return strings.Split(base, ".")[0]
}
func (file *File) CopyTo(fileType FileType, ctx *Context) *File {
t := &File{
FileType: fileType.ToString(),
FileInfo: &FileInfo{
Name: file.FileInfo.Name,
FileSize: file.FileInfo.FileSize,
Url: file.FileInfo.Url,
Ext: file.FileInfo.Ext,
RowCount: file.FileInfo.RowCount,
},
CreatedAt: time.Now(),
UpdatedAt: time.Now(),
SourceFileId: file.FileId,
//Operator: file.Operator,
Context: ctx,
}
return t
}