core

type ApiResponse[TData any] struct {
	// 操作是否成功
	Status bool
	// 返回状态代码
	StatusCode int
	// 返回消息内容
	StatusMessage string
	// 接口返回时间
	ServerAt dateTime.DateTime
	// 耗时
	ElapsedMilliseconds int64
	// 链路追踪ID
	TraceId string
	// 不同接口返回的值
	Data TData
}

type ApiResponseInt ApiResponse[int]

type ApiResponseLong ApiResponse[int64]

type ApiResponseString ApiResponse[string]

type ConsumerFunc func(message any, ea EventArgs)

type EventArgs struct {
	// 唯一标识
	Id string
	// 事件的发布时间
	CreateAt int64
	// 消息内容
	Message any
	// 执行失败次数
	ErrorCount int
	// 事件名称
	EventName string
}

type IEvent interface {
	// Publish 发布消息
	Publish(message any) error
	// PublishAsync 异步发布消息
	PublishAsync(message any)
}

type IHealthCheck interface {
	// Check 检查
	Check() (string, error)
}

type ILock interface {
	// TryLock 尝试加锁
	TryLock() bool
	// GetLock 获取锁，直到获取成功
	GetLock()
	// ReleaseLock 释放锁
	ReleaseLock()
	// TryLockRun 尝试加锁，执行完后，自动释放锁（未获取到时直接退出）
	TryLockRun(fn func()) bool
	// GetLockRun 获取锁，直到获取成功，执行完后，自动释放锁
	GetLockRun(fn func())
}

type ILog interface {
	Trace(contents ...any)                                                         // Trace Trace日志
	Tracef(format string, a ...any)                                                // Tracef Trace日志
	Debug(contents ...any)                                                         // Debug Debug日志
	Debugf(format string, a ...any)                                                // Debugf Debug日志
	Info(contents ...any)                                                          // Info Info日志
	Infof(format string, a ...any)                                                 // Infof Info日志
	Warning(content ...any)                                                        // Warning Warning日志
	Warningf(format string, a ...any)                                              // Warningf Warning日志
	Error(contents ...any) error                                                   // Error Error日志
	Errorf(format string, a ...any) error                                          // Errorf Error日志
	Critical(contents ...any)                                                      // Critical Critical日志
	Criticalf(format string, a ...any)                                             // Criticalf Critical日志
	Log(logLevel eumLogLevel.Enum, content string, component string, newLine bool) // 通用的日志记录
}

type IMapperInit interface {
	// MapperInit 在Mapper转换的时候初始化
	MapperInit()
}

type ITransaction interface {
	// Begin 开始
	// isolationLevels：事务等级
	Begin(isolationLevels ...sql.IsolationLevel) error
	// Commit 提交
	Commit()
	// Rollback 回滚
	Rollback()
	// Transaction 使用事务
	Transaction(executeFn func(), isolationLevels ...sql.IsolationLevel)
}