59 lines
2.3 KiB
Go
59 lines
2.3 KiB
Go
package dto
|
||
|
||
import (
|
||
"gitea.com/red-future/common/beans"
|
||
"github.com/gogf/gf/v2/frame/g"
|
||
)
|
||
|
||
// WebSocketConnectReq WebSocket 连接请求
|
||
type WebSocketConnectReq struct {
|
||
g.Meta `path:"/connect" method:"get" tags:"WebSocket" summary:"WebSocket连接" dc:"建立WebSocket连接，用于实时消息推送"`
|
||
UserId string `p:"user_id" v:"required#用户ID不能为空" dc:"用户ID"`
|
||
Platform string `p:"platform" d:"xiaohongshu" dc:"平台(xiaohongshu/douyin/kuaishou)"`
|
||
}
|
||
|
||
type WebSocketConnectRes = beans.ResponseEmpty
|
||
|
||
// WebSocketSendReq 发送消息请求
|
||
type WebSocketSendReq struct {
|
||
g.Meta `path:"/send" method:"post" tags:"WebSocket" summary:"发送消息" dc:"发送消息到Redis Stream，message服务会消费并处理"`
|
||
UserId string `json:"userId" v:"required#用户ID不能为空" dc:"用户ID"`
|
||
Content string `json:"content" v:"required#消息内容不能为空" dc:"消息内容"`
|
||
}
|
||
|
||
type WebSocketSendRes struct {
|
||
MessageId string `json:"messageId" dc:"消息ID"`
|
||
}
|
||
|
||
// WebSocketBroadcastReq 广播消息请求
|
||
type WebSocketBroadcastReq struct {
|
||
g.Meta `path:"/broadcast" method:"post" tags:"WebSocket" summary:"广播消息" dc:"向所有WebSocket连接广播消息（测试用）"`
|
||
Content string `json:"content" v:"required#消息内容不能为空" dc:"消息内容"`
|
||
}
|
||
|
||
type WebSocketBroadcastRes = beans.ResponseEmpty
|
||
|
||
// WebSocketOnlineReq 获取在线用户请求
|
||
type WebSocketOnlineReq struct {
|
||
g.Meta `path:"/online" method:"get" tags:"WebSocket" summary:"获取在线用户" dc:"获取当前所有WebSocket在线用户"`
|
||
}
|
||
|
||
type WebSocketOnlineRes struct {
|
||
Count int `json:"count" dc:"在线用户数"`
|
||
Users []WebSocketOnlineUserRes `json:"users" dc:"在线用户列表"`
|
||
}
|
||
|
||
type WebSocketOnlineUserRes struct {
|
||
UserId string `json:"userId" dc:"用户ID"`
|
||
Platform string `json:"platform" dc:"平台"`
|
||
CreatedAt int64 `json:"createdAt" dc:"连接时间戳"`
|
||
}
|
||
|
||
// WebSocketPushMsg WebSocket 推送消息结构
|
||
type WebSocketPushMsg struct {
|
||
Type string `json:"type"` // 消息类型: ack, error, broadcast, answer
|
||
MessageId string `json:"message_id,omitempty"` // 消息ID（ack 时返回）
|
||
Message string `json:"message,omitempty"` // 提示消息
|
||
Content string `json:"content,omitempty"` // 内容（broadcast/answer 时返回）
|
||
}
|