63 lines
1.9 KiB
Go
63 lines
1.9 KiB
Go
package user_core_client
|
||
|
||
import "time"
|
||
|
||
type TokenClaims struct {
|
||
UserID string `json:"userId"`
|
||
PlatformCode string `json:"platformCode"`
|
||
}
|
||
|
||
// Event 接口定义了所有事件应具备的基本元数据
|
||
type Event interface {
|
||
GetEventID() string // 获取事件唯一ID
|
||
GetEventType() string // 获取事件类型
|
||
GetTimestamp() time.Time // 获取事件发生时间
|
||
}
|
||
|
||
// User 用户数据模型
|
||
type User struct {
|
||
ID int64 `json:"id" ` // 主键ID
|
||
CreatedAt time.Time `json:"created_at"` // 创建时间
|
||
UpdatedAt time.Time `json:"updated_at"` // 更新时间
|
||
DeletedAt uint `json:"deleted_at"` // 软删除时间 毫秒 0 表示未删除
|
||
|
||
EncryptedPhone string `json:"encrypted_phone" ` // 加密后的手机号
|
||
PhoneMask string `json:"phone_mask" ` // 手机号掩码（前三后四位）
|
||
|
||
Username string `json:"username" ` // 用户名（可重复）
|
||
LoginName string `json:"login_name" ` // 登录名
|
||
|
||
Gender string `json:"gender" ` // 性别 (male 男性, female 女性, unknown 未知)
|
||
Status string `json:"status" ` // 用户状态，enabled/disabled
|
||
}
|
||
|
||
type BaseEvent struct {
|
||
EventID string `json:"event_id"` // 事件ID
|
||
EventType string `json:"event_type"` // 事件类型
|
||
Timestamp time.Time `json:"timestamp"` // 事件时间戳
|
||
}
|
||
|
||
func (b *BaseEvent) GetEventID() string {
|
||
return b.EventID
|
||
}
|
||
|
||
func (b *BaseEvent) GetEventType() string {
|
||
return b.EventType
|
||
}
|
||
|
||
func (b *BaseEvent) GetTimestamp() time.Time {
|
||
return b.Timestamp
|
||
}
|
||
|
||
// UserEvent 用户事件结构
|
||
// 用于在Kafka消息中传输用户相关事件
|
||
type UserEvent struct {
|
||
BaseEvent
|
||
|
||
PlatformCode string `json:"platform_code"` // 平台代码
|
||
|
||
UserID int64 `json:"user_id"` // 用户ID
|
||
Username string `json:"username"` // 用户名
|
||
UserData *User `json:"user_data,omitempty"` // 用户数据，改为具体类型
|
||
}
|