customer-server/controller/account_websocket_controller.go

// Package controller - WebSocket控制器
// 功能：WebSocket连接管理、实时消息推送
package controller

import (
	"context"
	"customer-server/model/dto"
	"customer-server/service"

	"gitea.redpowerfuture.com/red-future/common/beans"
	"github.com/gogf/gf/v2/frame/g"
)

var AccountWebsocket = new(accountWebSocket)

type accountWebSocket struct{}

// Connect WebSocket连接
// 参数: req - WebSocket连接请求，包含用户ID和平台信息
// 返回: res - 连接结果（实际通过WebSocket协议通信）
// 功能: 升级HTTP连接为WebSocket，建立实时通信通道
func (c *accountWebSocket) Connect(ctx context.Context, req *dto.AccountWebSocketConnectReq) (res *beans.ResponseEmpty, err error) {
	r := g.RequestFromCtx(ctx)
	err = service.AccountWebSocket.Connect(ctx, r, req)
	return
}