Victor_Jay
ff9886f08b
- Service 层：energy_service → energize/operations/admin/query 四文件 - Service 层：post_service → helpers/audit + 核心 CRUD 保留 - Service 层：favorite_service → items + 核心文件夹操作保留 - Service 层：auth_service → password + 核心注册/登录保留 - Service 层：notification_service → notify + 核心列表/已读保留 - Service 层：audit_service → review + 核心列表/详情保留 - Controller 层：studio_controller → page/write/api/post_api/action 五文件 - Controller 层：post_controller → page/api/upload 三文件 - Controller 层：comment_controller → list/write/action/upload 四文件 - 清理未使用导入（notification_service.go 移除 fmt）
86 lines
2.3 KiB
Go
86 lines
2.3 KiB
Go
package service
|
|
|
|
import (
|
|
"time"
|
|
|
|
"metazone.cc/metalab/internal/common"
|
|
"metazone.cc/metalab/internal/model"
|
|
)
|
|
|
|
// GetEnergyInfo 获取用户域能余额和每日赋能经验状态
|
|
func (s *EnergyService) GetEnergyInfo(userID uint) (*EnergyInfo, error) {
|
|
user, err := s.repo.FindUserByID(userID)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
loc, _ := time.LoadLocation("Asia/Shanghai")
|
|
now := time.Now().In(loc)
|
|
today := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, loc)
|
|
|
|
dailyExp := 0
|
|
summary, err := s.repo.GetDailyEnergizeExp(userID, today)
|
|
if err == nil && summary != nil {
|
|
dailyExp = summary.ExpEarned
|
|
}
|
|
|
|
return &EnergyInfo{
|
|
Energy: user.Energy,
|
|
DailyEnergizeExp: dailyExp,
|
|
DailyExpCap: DailyEnergizeExpCap,
|
|
DailyExpCapReached: dailyExp >= DailyEnergizeExpCap,
|
|
}, nil
|
|
}
|
|
|
|
// GetEnergyLogs 分页查询用户域能流水（近 N 天）
|
|
func (s *EnergyService) GetEnergyLogs(userID uint, days, page, pageSize int) ([]model.EnergyLog, int64, error) {
|
|
p := common.Pagination{Page: page, PageSize: pageSize}
|
|
p.DefaultPagination()
|
|
|
|
total, err := s.repo.CountEnergyLogsByUser(userID, days)
|
|
if err != nil {
|
|
return nil, 0, err
|
|
}
|
|
|
|
logs, err := s.repo.ListEnergyLogsByUser(userID, days, p.Offset(), p.PageSize)
|
|
if err != nil {
|
|
return nil, 0, err
|
|
}
|
|
if logs == nil {
|
|
logs = []model.EnergyLog{}
|
|
}
|
|
return logs, total, nil
|
|
}
|
|
|
|
// GetAdminEnergyLogs 后台查询全部域能流水
|
|
func (s *EnergyService) GetAdminEnergyLogs(energyType string, page, pageSize int) ([]model.EnergyLog, int64, error) {
|
|
p := common.Pagination{Page: page, PageSize: pageSize}
|
|
p.DefaultPagination()
|
|
return s.repo.ListAllEnergyLogs(energyType, p.Offset(), p.PageSize)
|
|
}
|
|
|
|
// GetFundBalance 获取公户余额
|
|
func (s *EnergyService) GetFundBalance() (int, error) {
|
|
if s.fundRepo == nil {
|
|
return 0, nil
|
|
}
|
|
return s.fundRepo.GetBalance()
|
|
}
|
|
|
|
// GetFundLogs 分页查询公户流水
|
|
func (s *EnergyService) GetFundLogs(logType string, page, pageSize int) ([]model.FundLog, int64, error) {
|
|
p := common.Pagination{Page: page, PageSize: pageSize}
|
|
p.DefaultPagination()
|
|
if s.fundRepo == nil {
|
|
return []model.FundLog{}, 0, nil
|
|
}
|
|
logs, total, err := s.fundRepo.ListLogs(logType, p.Offset(), p.PageSize)
|
|
if err != nil {
|
|
return nil, 0, err
|
|
}
|
|
if logs == nil {
|
|
logs = []model.FundLog{}
|
|
}
|
|
return logs, total, nil
|
|
}
|