95 lines
2.9 KiB
Go
95 lines
2.9 KiB
Go
|
package service
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"strings"
|
|||
|
|
|
|||
|
|
"gorm.io/gorm"
|
|||
|
|
|
|||
|
|
"nl-pms-api/internal/commonservice"
|
|||
|
|
"nl-pms-api/internal/model"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
// SettingsService 用户设置与全局资源（fest_img:* / file_storage）。
|
|||
|
|
type SettingsService struct {
|
|||
|
|
DB *gorm.DB
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func isGlobalSetting(name string) bool {
|
|||
|
|
return name == "file_storage" || strings.HasPrefix(name, "fest_img:")
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func settingOwner(userID int64, name string) int64 {
|
|||
|
|
if isGlobalSetting(name) {
|
|||
|
|
return commonservice.AdminUserID
|
|||
|
|
}
|
|||
|
|
return userID
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// GetSetting 读取单条设置；全局键从管理员账号读。
|
|||
|
|
func (s *SettingsService) GetSetting(userID int64, name string) (*model.SyncSetting, error) {
|
|||
|
|
name = strings.TrimSpace(name)
|
|||
|
|
if name == "" {
|
|||
|
|
return nil, commonservice.BadRequest("SETTING_NAME_REQUIRED")
|
|||
|
|
}
|
|||
|
|
owner := settingOwner(userID, name)
|
|||
|
|
var row model.SyncSetting
|
|||
|
|
if err := s.DB.Where("user_id = ? AND name = ?", owner, name).First(&row).Error; err != nil {
|
|||
|
|
if err == gorm.ErrRecordNotFound {
|
|||
|
|
return nil, commonservice.NotFound("NOT_FOUND")
|
|||
|
|
}
|
|||
|
|
return nil, commonservice.Internal("QUERY_FAILED")
|
|||
|
|
}
|
|||
|
|
return &row, nil
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// ListByPrefix 按前缀批量拉取（如 fest_img:），全局前缀从管理员账号读。
|
|||
|
|
func (s *SettingsService) ListByPrefix(userID int64, prefix string) ([]model.SyncSetting, error) {
|
|||
|
|
prefix = strings.TrimSpace(prefix)
|
|||
|
|
if prefix == "" {
|
|||
|
|
return nil, commonservice.BadRequest("SETTING_PREFIX_REQUIRED")
|
|||
|
|
}
|
|||
|
|
owner := userID
|
|||
|
|
if strings.HasPrefix(prefix, "fest_img:") || prefix == "fest_img:" {
|
|||
|
|
owner = commonservice.AdminUserID
|
|||
|
|
}
|
|||
|
|
var rows []model.SyncSetting
|
|||
|
|
if err := s.DB.Where("user_id = ? AND name LIKE ?", owner, prefix+"%").
|
|||
|
|
Order("name").Find(&rows).Error; err != nil {
|
|||
|
|
return nil, commonservice.Internal("QUERY_FAILED")
|
|||
|
|
}
|
|||
|
|
if rows == nil {
|
|||
|
|
rows = []model.SyncSetting{}
|
|||
|
|
}
|
|||
|
|
return rows, nil
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// GetGlobal 读取挂在管理员名下的全局设置。
|
|||
|
|
func (s *SettingsService) GetGlobal(name string) (*model.SyncSetting, error) {
|
|||
|
|
return s.GetSetting(commonservice.AdminUserID, name)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// PutSetting LWW 写入；全局键仅管理员可写，且落在 user_id=1。
|
|||
|
|
func (s *SettingsService) PutSetting(userID int64, name, value, updatedAt string) error {
|
|||
|
|
name = strings.TrimSpace(name)
|
|||
|
|
if name == "" {
|
|||
|
|
return commonservice.BadRequest("SETTING_NAME_REQUIRED")
|
|||
|
|
}
|
|||
|
|
if updatedAt == "" {
|
|||
|
|
updatedAt = commonservice.NowRFC()
|
|||
|
|
}
|
|||
|
|
owner := userID
|
|||
|
|
if isGlobalSetting(name) {
|
|||
|
|
if userID != commonservice.AdminUserID {
|
|||
|
|
return commonservice.Forbidden("FORBIDDEN")
|
|||
|
|
}
|
|||
|
|
owner = commonservice.AdminUserID
|
|||
|
|
}
|
|||
|
|
q := `INSERT INTO sync_settings(user_id,name,value,updated_at) VALUES(?,?,?,?)
|
|||
|
|
ON DUPLICATE KEY UPDATE value=IF(VALUES(updated_at)>updated_at,VALUES(value),value),
|
|||
|
|
updated_at=IF(VALUES(updated_at)>updated_at,VALUES(updated_at),updated_at)`
|
|||
|
|
if err := s.DB.Exec(q, owner, name, value, updatedAt).Error; err != nil {
|
|||
|
|
return commonservice.Internal("SAVE_FAILED")
|
|||
|
|
}
|
|||
|
|
return nil
|
|||
|
|
}
|