Documentation
¶
Index ¶
- type AuthMethodRepo
- type AuthMethodUsecase
- func (uc *AuthMethodUsecase) CreateUserAuthMethod(ctx context.Context, req *v1.CreateUserAuthMethodRequest) (int64, error)
- func (uc *AuthMethodUsecase) DeleteUserAuthMethod(ctx context.Context, userID int64, authType string) error
- func (uc *AuthMethodUsecase) GetUserAuthMethod(ctx context.Context, userID int64) ([]*ent.ProxyUserAuthMethod, error)
- func (uc *AuthMethodUsecase) UpdateUserAuthMethod(ctx context.Context, req *v1.UpdateUserAuthMethodRequest) error
- type DeviceRepo
- type DeviceUsecase
- type SubscribeRepo
- type SubscribeUsecase
- func (uc *SubscribeUsecase) CreateUserSubscribe(ctx context.Context, req *v1.CreateUserSubscribeRequest) (int64, error)
- func (uc *SubscribeUsecase) DeleteUserSubscribe(ctx context.Context, userSubscribeID int64) error
- func (uc *SubscribeUsecase) GetUserSubscribe(ctx context.Context, req *v1.GetUserSubscribeRequest) ([]*ent.ProxyUserSubscribe, int32, error)
- func (uc *SubscribeUsecase) GetUserSubscribeById(ctx context.Context, userSubscribeID int64) (*v1.UserSubscribeDetail, error)
- func (uc *SubscribeUsecase) GetUserSubscribeDevices(ctx context.Context, req *v1.GetUserSubscribeDevicesRequest) ([]*ent.ProxyUserDevice, int32, error)
- func (uc *SubscribeUsecase) GetUserSubscribeLogs(ctx context.Context, req *v1.GetUserSubscribeLogsRequest) ([]*ent.ProxySystemLog, int32, error)
- func (uc *SubscribeUsecase) GetUserSubscribeResetTrafficLogs(ctx context.Context, req *v1.GetUserSubscribeResetTrafficLogsRequest) ([]*ent.ProxySystemLog, int32, error)
- func (uc *SubscribeUsecase) GetUserSubscribeTrafficLogs(ctx context.Context, req *v1.GetUserSubscribeTrafficLogsRequest) ([]*ent.ProxyTrafficLog, int32, error)
- func (uc *SubscribeUsecase) ResetUserSubscribeToken(ctx context.Context, userSubscribeID int64) error
- func (uc *SubscribeUsecase) ResetUserSubscribeTraffic(ctx context.Context, userSubscribeID int64) error
- func (uc *SubscribeUsecase) ToggleUserSubscribeStatus(ctx context.Context, userSubscribeID int64) error
- func (uc *SubscribeUsecase) UpdateUserSubscribe(ctx context.Context, req *v1.UpdateUserSubscribeRequest) error
- type UserRepo
- type UserUsecase
- func (uc *UserUsecase) BatchDeleteUser(ctx context.Context, userIDs []int) (int64, error)
- func (uc *UserUsecase) CreateUser(ctx context.Context, req *v1.CreateUserRequest) (int64, error)
- func (uc *UserUsecase) CurrentUser(ctx context.Context, userID int) (*ent.ProxyUser, error)
- func (uc *UserUsecase) DeleteUser(ctx context.Context, userID int) error
- func (uc *UserUsecase) GetUserDetail(ctx context.Context, userID int) (*ent.ProxyUser, error)
- func (uc *UserUsecase) GetUserList(ctx context.Context, page, size int32, search string, ...) ([]*ent.ProxyUser, int32, error)
- func (uc *UserUsecase) GetUserLoginLogs(ctx context.Context, page, size int32, userID *int64, date string) ([]*ent.ProxySystemLog, int32, error)
- func (uc *UserUsecase) UpdateUserBasicInfo(ctx context.Context, req *v1.UpdateUserBasicInfoRequest) error
- func (uc *UserUsecase) UpdateUserNotifySettings(ctx context.Context, req *v1.UpdateUserNotifySettingsRequest) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthMethodRepo ¶
type AuthMethodRepo interface {
// CreateUserAuthMethod 创建用户认证方法(或更新已存在的)
CreateUserAuthMethod(ctx context.Context, req *v1.CreateUserAuthMethodRequest) (int64, error)
// GetUserAuthMethod 获取用户认证方法列表
GetUserAuthMethod(ctx context.Context, userID int64) ([]*ent.ProxyUserAuthMethod, error)
// UpdateUserAuthMethod 更新用户认证方法
UpdateUserAuthMethod(ctx context.Context, req *v1.UpdateUserAuthMethodRequest) error
// DeleteUserAuthMethod 删除用户认证方法
DeleteUserAuthMethod(ctx context.Context, userID int64, authType string) error
}
AuthMethodRepo 认证方法仓储接口
type AuthMethodUsecase ¶
type AuthMethodUsecase struct {
// contains filtered or unexported fields
}
AuthMethodUsecase 认证方法用例
func NewAuthMethodUsecase ¶
func NewAuthMethodUsecase(repo AuthMethodRepo, logger log.Logger) *AuthMethodUsecase
NewAuthMethodUsecase 创建认证方法用例
func (*AuthMethodUsecase) CreateUserAuthMethod ¶
func (uc *AuthMethodUsecase) CreateUserAuthMethod(ctx context.Context, req *v1.CreateUserAuthMethodRequest) (int64, error)
CreateUserAuthMethod 创建用户认证方法
func (*AuthMethodUsecase) DeleteUserAuthMethod ¶
func (uc *AuthMethodUsecase) DeleteUserAuthMethod(ctx context.Context, userID int64, authType string) error
DeleteUserAuthMethod 删除用户认证方法
func (*AuthMethodUsecase) GetUserAuthMethod ¶
func (uc *AuthMethodUsecase) GetUserAuthMethod(ctx context.Context, userID int64) ([]*ent.ProxyUserAuthMethod, error)
GetUserAuthMethod 获取用户认证方法
func (*AuthMethodUsecase) UpdateUserAuthMethod ¶
func (uc *AuthMethodUsecase) UpdateUserAuthMethod(ctx context.Context, req *v1.UpdateUserAuthMethodRequest) error
UpdateUserAuthMethod 更新用户认证方法
type DeviceRepo ¶
type DeviceRepo interface {
// UpdateUserDevice 更新用户设备
UpdateUserDevice(ctx context.Context, req *v1.UpdateUserDeviceRequest) error
// DeleteUserDevice 删除用户设备
DeleteUserDevice(ctx context.Context, deviceID int64) error
// KickOfflineByUserDevice 踢下线用户设备
KickOfflineByUserDevice(ctx context.Context, deviceID int64) error
}
DeviceRepo 设备仓储接口
type DeviceUsecase ¶
type DeviceUsecase struct {
// contains filtered or unexported fields
}
DeviceUsecase 设备用例
func NewDeviceUsecase ¶
func NewDeviceUsecase(repo DeviceRepo, logger log.Logger) *DeviceUsecase
NewDeviceUsecase 创建设备用例
func (*DeviceUsecase) DeleteUserDevice ¶
func (uc *DeviceUsecase) DeleteUserDevice(ctx context.Context, deviceID int64) error
DeleteUserDevice 删除用户设备
func (*DeviceUsecase) KickOfflineByUserDevice ¶
func (uc *DeviceUsecase) KickOfflineByUserDevice(ctx context.Context, deviceID int64) error
KickOfflineByUserDevice 踢下线用户设备
func (*DeviceUsecase) UpdateUserDevice ¶
func (uc *DeviceUsecase) UpdateUserDevice(ctx context.Context, req *v1.UpdateUserDeviceRequest) error
UpdateUserDevice 更新用户设备
type SubscribeRepo ¶
type SubscribeRepo interface {
// GetUserSubscribe 获取用户订阅列表
GetUserSubscribe(ctx context.Context, req *v1.GetUserSubscribeRequest) ([]*ent.ProxyUserSubscribe, int32, error)
// CreateUserSubscribe 创建用户订阅
CreateUserSubscribe(ctx context.Context, req *v1.CreateUserSubscribeRequest) (int64, error)
// UpdateUserSubscribe 更新用户订阅
UpdateUserSubscribe(ctx context.Context, req *v1.UpdateUserSubscribeRequest) error
// DeleteUserSubscribe 删除用户订阅
DeleteUserSubscribe(ctx context.Context, userSubscribeID int64) error
// GetUserSubscribeById 根据ID获取用户订阅详情(包含套餐信息)
GetUserSubscribeById(ctx context.Context, userSubscribeID int64) (*v1.UserSubscribeDetail, error)
// GetUserSubscribeDevices 获取用户订阅设备列表
GetUserSubscribeDevices(ctx context.Context, req *v1.GetUserSubscribeDevicesRequest) ([]*ent.ProxyUserDevice, int32, error)
// GetUserSubscribeLogs 获取用户订阅日志
GetUserSubscribeLogs(ctx context.Context, req *v1.GetUserSubscribeLogsRequest) ([]*ent.ProxySystemLog, int32, error)
// GetUserSubscribeResetTrafficLogs 获取用户订阅重置流量日志
GetUserSubscribeResetTrafficLogs(ctx context.Context, req *v1.GetUserSubscribeResetTrafficLogsRequest) ([]*ent.ProxySystemLog, int32, error)
// GetUserSubscribeTrafficLogs 获取用户订阅流量日志
GetUserSubscribeTrafficLogs(ctx context.Context, req *v1.GetUserSubscribeTrafficLogsRequest) ([]*ent.ProxyTrafficLog, int32, error)
// ResetUserSubscribeToken 重置用户订阅令牌
ResetUserSubscribeToken(ctx context.Context, userSubscribeID int64) error
// ToggleUserSubscribeStatus 切换用户订阅状态
ToggleUserSubscribeStatus(ctx context.Context, userSubscribeID int64) error
// ResetUserSubscribeTraffic 重置用户订阅流量
ResetUserSubscribeTraffic(ctx context.Context, userSubscribeID int64) error
}
SubscribeRepo 订阅仓储接口
type SubscribeUsecase ¶
type SubscribeUsecase struct {
// contains filtered or unexported fields
}
SubscribeUsecase 订阅用例
func NewSubscribeUsecase ¶
func NewSubscribeUsecase(repo SubscribeRepo, logger log.Logger) *SubscribeUsecase
NewSubscribeUsecase 创建订阅用例
func (*SubscribeUsecase) CreateUserSubscribe ¶
func (uc *SubscribeUsecase) CreateUserSubscribe(ctx context.Context, req *v1.CreateUserSubscribeRequest) (int64, error)
CreateUserSubscribe 创建用户订阅
func (*SubscribeUsecase) DeleteUserSubscribe ¶
func (uc *SubscribeUsecase) DeleteUserSubscribe(ctx context.Context, userSubscribeID int64) error
DeleteUserSubscribe 删除用户订阅
func (*SubscribeUsecase) GetUserSubscribe ¶
func (uc *SubscribeUsecase) GetUserSubscribe(ctx context.Context, req *v1.GetUserSubscribeRequest) ([]*ent.ProxyUserSubscribe, int32, error)
GetUserSubscribe 获取用户订阅列表
func (*SubscribeUsecase) GetUserSubscribeById ¶
func (uc *SubscribeUsecase) GetUserSubscribeById(ctx context.Context, userSubscribeID int64) (*v1.UserSubscribeDetail, error)
GetUserSubscribeById 根据ID获取用户订阅详情
func (*SubscribeUsecase) GetUserSubscribeDevices ¶
func (uc *SubscribeUsecase) GetUserSubscribeDevices(ctx context.Context, req *v1.GetUserSubscribeDevicesRequest) ([]*ent.ProxyUserDevice, int32, error)
GetUserSubscribeDevices 获取用户订阅设备列表
func (*SubscribeUsecase) GetUserSubscribeLogs ¶
func (uc *SubscribeUsecase) GetUserSubscribeLogs(ctx context.Context, req *v1.GetUserSubscribeLogsRequest) ([]*ent.ProxySystemLog, int32, error)
GetUserSubscribeLogs 获取用户订阅日志
func (*SubscribeUsecase) GetUserSubscribeResetTrafficLogs ¶
func (uc *SubscribeUsecase) GetUserSubscribeResetTrafficLogs(ctx context.Context, req *v1.GetUserSubscribeResetTrafficLogsRequest) ([]*ent.ProxySystemLog, int32, error)
GetUserSubscribeResetTrafficLogs 获取用户订阅重置流量日志
func (*SubscribeUsecase) GetUserSubscribeTrafficLogs ¶
func (uc *SubscribeUsecase) GetUserSubscribeTrafficLogs(ctx context.Context, req *v1.GetUserSubscribeTrafficLogsRequest) ([]*ent.ProxyTrafficLog, int32, error)
GetUserSubscribeTrafficLogs 获取用户订阅流量日志
func (*SubscribeUsecase) ResetUserSubscribeToken ¶
func (uc *SubscribeUsecase) ResetUserSubscribeToken(ctx context.Context, userSubscribeID int64) error
ResetUserSubscribeToken 重置用户订阅令牌
func (*SubscribeUsecase) ResetUserSubscribeTraffic ¶
func (uc *SubscribeUsecase) ResetUserSubscribeTraffic(ctx context.Context, userSubscribeID int64) error
ResetUserSubscribeTraffic 重置用户订阅流量
func (*SubscribeUsecase) ToggleUserSubscribeStatus ¶
func (uc *SubscribeUsecase) ToggleUserSubscribeStatus(ctx context.Context, userSubscribeID int64) error
ToggleUserSubscribeStatus 切换用户订阅状态
func (*SubscribeUsecase) UpdateUserSubscribe ¶
func (uc *SubscribeUsecase) UpdateUserSubscribe(ctx context.Context, req *v1.UpdateUserSubscribeRequest) error
UpdateUserSubscribe 更新用户订阅
type UserRepo ¶
type UserRepo interface {
// CreateUser 创建用户
CreateUser(ctx context.Context, req *v1.CreateUserRequest) (int64, error)
// DeleteUser 删除用户
DeleteUser(ctx context.Context, userID int) error
// BatchDeleteUser 批量删除用户
BatchDeleteUser(ctx context.Context, userIDs []int) (int64, error)
// GetUserByID 根据ID获取用户
GetUserByID(ctx context.Context, userID int) (*ent.ProxyUser, error)
// GetUserList 获取用户列表
GetUserList(ctx context.Context, page, size int32, search string, userID, subscribeID, userSubscribeID *int64, unscoped bool, shortCode string) ([]*ent.ProxyUser, int32, error)
// UpdateUserBasicInfo 更新用户基本信息
UpdateUserBasicInfo(ctx context.Context, req *v1.UpdateUserBasicInfoRequest) error
// UpdateUserNotifySettings 更新用户通知设置
UpdateUserNotifySettings(ctx context.Context, req *v1.UpdateUserNotifySettingsRequest) error
// GetUserLoginLogs 获取用户登录日志
GetUserLoginLogs(ctx context.Context, page, size int32, userID *int64, date string) ([]*ent.ProxySystemLog, int32, error)
}
UserRepo 用户仓库接口
type UserUsecase ¶
type UserUsecase struct {
// contains filtered or unexported fields
}
UserUsecase 用户用例
func NewUserUsecase ¶
func NewUserUsecase(repo UserRepo, logger log.Logger) *UserUsecase
NewUserUsecase 创建用户用例
func (*UserUsecase) BatchDeleteUser ¶
BatchDeleteUser 批量删除用户
func (*UserUsecase) CreateUser ¶
func (uc *UserUsecase) CreateUser(ctx context.Context, req *v1.CreateUserRequest) (int64, error)
CreateUser 创建用户
func (*UserUsecase) CurrentUser ¶
CurrentUser 获取当前用户
func (*UserUsecase) DeleteUser ¶
func (uc *UserUsecase) DeleteUser(ctx context.Context, userID int) error
DeleteUser 删除用户
func (*UserUsecase) GetUserDetail ¶
GetUserDetail 获取用户详情
func (*UserUsecase) GetUserList ¶
func (uc *UserUsecase) GetUserList(ctx context.Context, page, size int32, search string, userID, subscribeID, userSubscribeID *int64, unscoped bool, shortCode string) ([]*ent.ProxyUser, int32, error)
GetUserList 获取用户列表
func (*UserUsecase) GetUserLoginLogs ¶
func (uc *UserUsecase) GetUserLoginLogs(ctx context.Context, page, size int32, userID *int64, date string) ([]*ent.ProxySystemLog, int32, error)
GetUserLoginLogs 获取用户登录日志
func (*UserUsecase) UpdateUserBasicInfo ¶
func (uc *UserUsecase) UpdateUserBasicInfo(ctx context.Context, req *v1.UpdateUserBasicInfoRequest) error
UpdateUserBasicInfo 更新用户基本信息
func (*UserUsecase) UpdateUserNotifySettings ¶
func (uc *UserUsecase) UpdateUserNotifySettings(ctx context.Context, req *v1.UpdateUserNotifySettingsRequest) error
UpdateUserNotifySettings 更新用户通知设置