log

package
v1.0.11 Latest Latest
Warning

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

 Go to latest Published: Jun 28, 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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.