user

package
v1.0.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 24, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

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

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

func (uc *UserUsecase) BatchDeleteUser(ctx context.Context, userIDs []int) (int64, error)

BatchDeleteUser 批量删除用户

func (*UserUsecase) CreateUser

func (uc *UserUsecase) CreateUser(ctx context.Context, req *v1.CreateUserRequest) (int64, error)

CreateUser 创建用户

func (*UserUsecase) CurrentUser

func (uc *UserUsecase) CurrentUser(ctx context.Context, userID int) (*ent.ProxyUser, error)

CurrentUser 获取当前用户

func (*UserUsecase) DeleteUser

func (uc *UserUsecase) DeleteUser(ctx context.Context, userID int) error

DeleteUser 删除用户

func (*UserUsecase) GetUserDetail

func (uc *UserUsecase) GetUserDetail(ctx context.Context, userID int) (*ent.ProxyUser, error)

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 更新用户通知设置

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL