log

package
v1.0.10 Latest Latest
Warning

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

Go to latest
Published: Jun 26, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	LogTypeEmail            int8 = 10 // Email Message
	LogTypeMobile           int8 = 11 // Mobile Message
	LogTypeSubscribe        int8 = 20 // Subscribe
	LogTypeSubscribeTraffic int8 = 21 // Subscribe Traffic
	LogTypeServerTraffic    int8 = 22 // Server Traffic
	LogTypeResetSubscribe   int8 = 23 // Reset Subscribe
	LogTypeLogin            int8 = 30 // Login
	LogTypeRegister         int8 = 31 // Register
	LogTypeBalance          int8 = 32 // Balance
	LogTypeCommission       int8 = 33 // Commission
	LogTypeGift             int8 = 34 // Gift
)

日志类型常量(对应 proxy_system_log 表的 type 字段) 这些值必须与原项目保持一致,以便能正确查询已有的日志数据

Variables

This section is empty.

Functions

This section is empty.

Types

type FilterParams

type FilterParams struct {
	Page     int32
	Size     int32
	Type     int8   // 日志类型
	Date     string // 日期过滤
	ObjectID *int64 // 对象ID(用户ID、服务器ID等)
	Search   string // 搜索关键词(在content中搜索)
}

FilterParams 过滤参数

type LogSettingRepo

type LogSettingRepo interface {
	// GetLogSetting 获取日志设置
	GetLogSetting(ctx context.Context) (*v1.LogSetting, error)

	// UpdateLogSetting 更新日志设置
	UpdateLogSetting(ctx context.Context, setting *v1.LogSetting) error
}

LogSettingRepo 日志设置仓库接口

type LogSettingUsecase

type LogSettingUsecase struct {
	// contains filtered or unexported fields
}

LogSettingUsecase 日志设置用例

func NewLogSettingUsecase

func NewLogSettingUsecase(repo LogSettingRepo, logger log.Logger) *LogSettingUsecase

NewLogSettingUsecase 创建日志设置用例

func (*LogSettingUsecase) GetLogSetting

func (uc *LogSettingUsecase) GetLogSetting(ctx context.Context) (*v1.LogSetting, error)

GetLogSetting 获取日志设置

func (*LogSettingUsecase) UpdateLogSetting

func (uc *LogSettingUsecase) UpdateLogSetting(ctx context.Context, setting *v1.LogSetting) error

UpdateLogSetting 更新日志设置

type SystemLogRepo

type SystemLogRepo interface {
	// FilterSystemLog 过滤系统日志(通用方法)
	FilterSystemLog(ctx context.Context, params *FilterParams) ([]*ent.ProxySystemLog, int32, error)
}

SystemLogRepo 系统日志仓库接口

type SystemLogUsecase

type SystemLogUsecase struct {
	// contains filtered or unexported fields
}

SystemLogUsecase 系统日志用例

func NewSystemLogUsecase

func NewSystemLogUsecase(repo SystemLogRepo, logger log.Logger) *SystemLogUsecase

NewSystemLogUsecase 创建系统日志用例

func (*SystemLogUsecase) FilterBalanceLog

func (uc *SystemLogUsecase) FilterBalanceLog(ctx context.Context, page, size int32, date string, userID *int64) ([]*ent.ProxySystemLog, int32, error)

FilterBalanceLog 过滤余额日志

func (*SystemLogUsecase) FilterCommissionLog

func (uc *SystemLogUsecase) FilterCommissionLog(ctx context.Context, page, size int32, date string, userID *int64) ([]*ent.ProxySystemLog, int32, error)

FilterCommissionLog 过滤佣金日志

func (*SystemLogUsecase) FilterEmailLog

func (uc *SystemLogUsecase) FilterEmailLog(ctx context.Context, page, size int32, date, search string) ([]*ent.ProxySystemLog, int32, error)

FilterEmailLog 过滤邮件日志

func (*SystemLogUsecase) FilterGiftLog

func (uc *SystemLogUsecase) FilterGiftLog(ctx context.Context, page, size int32, date string, userID *int64, search string) ([]*ent.ProxySystemLog, int32, error)

FilterGiftLog 过滤赠送日志

func (*SystemLogUsecase) FilterLoginLog

func (uc *SystemLogUsecase) FilterLoginLog(ctx context.Context, page, size int32, date string, userID *int64, search string) ([]*ent.ProxySystemLog, int32, error)

FilterLoginLog 过滤登录日志

func (*SystemLogUsecase) FilterMobileLog

func (uc *SystemLogUsecase) FilterMobileLog(ctx context.Context, page, size int32, date, search string) ([]*ent.ProxySystemLog, int32, error)

FilterMobileLog 过滤手机日志

func (*SystemLogUsecase) FilterRegisterLog

func (uc *SystemLogUsecase) FilterRegisterLog(ctx context.Context, page, size int32, date string, userID *int64, search string) ([]*ent.ProxySystemLog, int32, error)

FilterRegisterLog 过滤注册日志

func (*SystemLogUsecase) FilterResetSubscribeLog

func (uc *SystemLogUsecase) FilterResetSubscribeLog(ctx context.Context, page, size int32, date string, userID *int64, search string) ([]*ent.ProxySystemLog, int32, error)

FilterResetSubscribeLog 过滤重置订阅日志

func (*SystemLogUsecase) FilterServerTrafficLog

func (uc *SystemLogUsecase) FilterServerTrafficLog(ctx context.Context, page, size int32, date string, serverID *int64) ([]*ent.ProxySystemLog, int32, error)

FilterServerTrafficLog 过滤服务器流量日志

func (*SystemLogUsecase) FilterSubscribeLog

func (uc *SystemLogUsecase) FilterSubscribeLog(ctx context.Context, page, size int32, date string, userID, userSubscribeID *int64) ([]*ent.ProxySystemLog, int32, error)

FilterSubscribeLog 过滤订阅日志

func (*SystemLogUsecase) FilterUserSubscribeTrafficLog

func (uc *SystemLogUsecase) FilterUserSubscribeTrafficLog(ctx context.Context, page, size int32, date string, userID, subscribeID *int64) ([]*ent.ProxySystemLog, int32, error)

FilterUserSubscribeTrafficLog 过滤用户订阅流量日志

func (*SystemLogUsecase) GetMessageLogList

func (uc *SystemLogUsecase) GetMessageLogList(ctx context.Context, page, size int32, logType int32, search string) ([]*ent.ProxySystemLog, int32, error)

GetMessageLogList 获取消息日志列表

type TrafficLogRepo

type TrafficLogRepo interface {
	// FilterTrafficLogDetails 过滤流量日志详情
	FilterTrafficLogDetails(ctx context.Context, page, size int32, date string, serverID, userID, subscribeID *int64) ([]*ent.ProxyTrafficLog, int32, error)
	QueryTrafficLogsByDate(ctx context.Context, date string, serverID, userID, subscribeID *int64) ([]*ent.ProxyTrafficLog, error)
}

TrafficLogRepo 流量日志仓库接口

type TrafficLogUsecase

type TrafficLogUsecase struct {
	// contains filtered or unexported fields
}

TrafficLogUsecase 流量日志用例

func NewTrafficLogUsecase

func NewTrafficLogUsecase(repo TrafficLogRepo, logger log.Logger) *TrafficLogUsecase

NewTrafficLogUsecase 创建流量日志用例

func (*TrafficLogUsecase) FilterTrafficLogDetails

func (uc *TrafficLogUsecase) FilterTrafficLogDetails(ctx context.Context, page, size int32, date string, serverID, userID, subscribeID *int64) ([]*ent.ProxyTrafficLog, int32, error)

FilterTrafficLogDetails 过滤流量日志详情

func (*TrafficLogUsecase) QueryTrafficLogsByDate

func (uc *TrafficLogUsecase) QueryTrafficLogsByDate(ctx context.Context, date string, serverID, userID, subscribeID *int64) ([]*ent.ProxyTrafficLog, error)

Jump to

Keyboard shortcuts

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