ws

services/percutaneous/internal/logic/addUserLogic.go

@@ -62,7 +62,6 @@ func (l *AddUserLogic) AddUser(in *percutaneous.AddUserRequest) (*percutaneous.R
 		}
 	}
 
-	// 取出等待中的ws会话
 	sess := l.svcCtx.SessionMgr.Pop(in.HostCode)
 	if sess == nil {
 		l.Logger.Error("no waiting ws session code is = ", in.HostCode)

services/percutaneous/internal/logic/wsAddUserStreamLogic.go

@@ -46,7 +46,6 @@ func NewWsAddUserStreamLogic(ctx context.Context, svcCtx *svc.ServiceContext) *W
 	}
 }
 
-// 添加用户
 func (l *WsAddUserStreamLogic) WsAddUserStream(stream percutaneous.Percutaneous_WsAddUserStreamServer) error {
 	ctx := stream.Context()
 	timeout := time.Duration(utils.GetConfigInt("ws.out_time")) * time.Second
@@ -55,7 +54,6 @@ func (l *WsAddUserStreamLogic) WsAddUserStream(stream percutaneous.Percutaneous_
 		cancel()
 	}()
 
-	// BFF自动发来第一条消息，读取host_code
 	recvFrame, err := stream.Recv()
 	if err != nil {
 		l.Logger.Errorf("recv host_code failed: %v", err)
@@ -64,7 +62,6 @@ func (l *WsAddUserStreamLogic) WsAddUserStream(stream percutaneous.Percutaneous_
 	var hostCode struct {
 		Code string `json:"host_code"`
 	}
-	// 保留你确认的 !err 判断
 	if ok := utils.JsonStringToStruct(string(recvFrame.RawBody), &hostCode); !ok {
 		return status.Errorf(codes.InvalidArgument, "device code parse error")
 	}
@@ -102,7 +99,6 @@ func (l *WsAddUserStreamLogic) getUserInfo(id int64) *userInfo {
 	if id == utils.NumberZero {
 		return nil
 	}
-	logx.Errorf("get user id: %v", id)
 	cli, err := svc.GetRpcClient(l.svcCtx.UserName)
 	if err != nil {
 		logx.Errorf("get user err: %v", err)