整合目前新的详情接口

server/websocket/internal/handler/routes.go

@@ -27,6 +27,11 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
 				Path:    "/api/websocket/common_notify",
 				Handler: CommonNotifyHandler(serverCtx),
 			},
+			{
+				Method:  http.MethodPost,
+				Path:    "/api/websocket/close_websocket",
+				Handler: CloseWebsocketHandler(serverCtx),
+			},
 		},
 	)
 }

server/websocket/internal/types/types.go

@@ -25,6 +25,10 @@ type CommonNotifyReq struct {
 	Data    map[string]interface{} `json:"data"`              //后端与前端约定好的数据
 }
 
+type CloseWebsocketReq struct {
+	Wid string `json:"wid"`
+}
+
 type Request struct {
 }
 

server_api/websocket.api

@@ -18,6 +18,9 @@ service websocket {
 	//通用回调接口
 	@handler CommonNotifyHandler
 	post /api/websocket/common_notify(CommonNotifyReq) returns (response);
+	//关闭某个连接
+	@handler CloseWebsocketHandler
+	post /api/websocket/close_websocket(CloseWebsocketReq) returns (response);
 }
 
 //websocket数据交互[
@@ -39,4 +42,8 @@ type CommonNotifyReq {
 	UserId  int64                  `json:"user_id,optional"`  //用户id
 	GuestId int64                  `json:"guest_id,optional"` //游客id
 	Data    map[string]interface{} `json:"data"`              //后端与前端约定好的数据
+}
+//关闭连接
+type CloseWebsocketReq {
+	Wid string `json:"wid"`
 }