GitHub/015
1
0
Fork 0
mirror of https://github.com/keven1024/015.git synced 2026-06-08 05:14:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(backend): streamline Redis operations in file and share handling by utilizing handler functions for improved data management

Browse Source
This commit is contained in:
keven1024
2026-04-06 12:05:00 +08:00
parent 30de50e82a
commit c366dadc7b
4 changed files with 37 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
worker/internal/services/file.go
View File

@@ -7,8 +7,6 @@ import (
"pkg/services"
u "pkg/utils"
"time"
"github.com/spf13/cast"
)
type GenStandardFileReturn struct {
@@ -48,21 +46,20 @@ func GenStandardFile(filePath string, mimeType string) (GenStandardFileReturn, e
if err := os.Rename(filePath, newPath); err != nil {
return GenStandardFileReturn{}, err
}
expire := cast.ToInt64(u.GetEnvWithDefault("upload.remove_expire", "2")) * 3600
err = services.SetFileRemoveTask(fileId, time.Duration(expire)*time.Second)
if err != nil {
return GenStandardFileReturn{}, err
}
if err := models.SetRedisFileInfo(fileId, func(fileInfo *models.RedisFileInfo) *models.RedisFileInfo {
redisFileInfo, err := models.SetRedisFileInfo(fileId, func(fileInfo *models.RedisFileInfo) *models.RedisFileInfo {
fileInfo.FileInfo = models.FileInfo{
FileSize: fileSize,
FileHash: fileHash,
MimeType: mimeType,
},
FileType: models.FileTypeUpload,
CreatedAt: time.Now().Unix(),
Expire: expire,
}); err != nil {
}
fileInfo.FileType = models.FileTypeUpload
return fileInfo
})
if err != nil {
return GenStandardFileReturn{}, err
}
err = services.SetFileRemoveTask(fileId, time.Duration(redisFileInfo.Expire)*time.Second)
if err != nil {
return GenStandardFileReturn{}, err
}
return GenStandardFileReturn{