69 lines
1.8 KiB
Go
69 lines
1.8 KiB
Go
|
// Package repository 提供数据访问层
|
||
|
|
// 封装GORM的数据库操作, 供Service层调用
|
||
|
|
package repository
|
||
|
|
|
||
|
|
import (
|
||
|
|
"seeyon-filesystem/config"
|
||
|
|
"seeyon-filesystem/model"
|
||
|
|
)
|
||
|
|
|
||
|
|
// UserRepository 用户数据访问
|
||
|
|
type UserRepository struct{}
|
||
|
|
|
||
|
|
// NewUserRepository 创建用户Repository实例
|
||
|
|
func NewUserRepository() *UserRepository {
|
||
|
|
return &UserRepository{}
|
||
|
|
}
|
||
|
|
|
||
|
|
// Create 创建用户
|
||
|
|
func (r *UserRepository) Create(user *model.User) error {
|
||
|
|
return config.DB.Create(user).Error
|
||
|
|
}
|
||
|
|
|
||
|
|
// FindByID 根据ID查找用户
|
||
|
|
func (r *UserRepository) FindByID(id uint64) (*model.User, error) {
|
||
|
|
var user model.User
|
||
|
|
err := config.DB.First(&user, id).Error
|
||
|
|
if err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
return &user, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
// FindByUsername 根据用户名查找用户
|
||
|
|
func (r *UserRepository) FindByUsername(username string) (*model.User, error) {
|
||
|
|
var user model.User
|
||
|
|
err := config.DB.Where("username = ?", username).First(&user).Error
|
||
|
|
if err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
return &user, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
// Update 更新用户信息
|
||
|
|
func (r *UserRepository) Update(user *model.User) error {
|
||
|
|
return config.DB.Save(user).Error
|
||
|
|
}
|
||
|
|
|
||
|
|
// UpdateStorageUsed 更新用户已用存储空间
|
||
|
|
func (r *UserRepository) UpdateStorageUsed(userID uint64, delta int64) error {
|
||
|
|
return config.DB.Model(&model.User{}).
|
||
|
|
Where("id = ?", userID).
|
||
|
|
Update("used_storage", config.DB.Raw("used_storage + ?", delta)).Error
|
||
|
|
}
|
||
|
|
|
||
|
|
// List 分页查询用户列表
|
||
|
|
func (r *UserRepository) List(page, size int) ([]model.User, int64, error) {
|
||
|
|
var users []model.User
|
||
|
|
var total int64
|
||
|
|
|
||
|
|
config.DB.Model(&model.User{}).Count(&total)
|
||
|
|
err := config.DB.Offset((page - 1) * size).Limit(size).Order("id DESC").Find(&users).Error
|
||
|
|
return users, total, err
|
||
|
|
}
|
||
|
|
|
||
|
|
// Delete 删除用户(软删除)
|
||
|
|
func (r *UserRepository) Delete(id uint64) error {
|
||
|
|
return config.DB.Delete(&model.User{}, id).Error
|
||
|
|
}
|