Merge branch 'dev' of http://git.legu.cc/liwei_3d/go_dreamfactory into dev
This commit is contained in:
commit
0af3ef8c60
@ -1,5 +1,7 @@
|
|||||||
## install tool
|
## install tool
|
||||||
|
|
||||||
|
<!-- https://sourceforge.net/projects/mingw/files/Installer/mingw-get-setup.exe/download -->
|
||||||
|
|
||||||
go install fyne.io/fyne/v2/cmd/fyne@latest
|
go install fyne.io/fyne/v2/cmd/fyne@latest
|
||||||
|
|
||||||
## install font
|
## install font
|
||||||
|
@ -36,7 +36,6 @@ func newAgent(gateway IGateway, conn *websocket.Conn) *Agent {
|
|||||||
closeSignal: make(chan bool),
|
closeSignal: make(chan bool),
|
||||||
state: 1,
|
state: 1,
|
||||||
}
|
}
|
||||||
conn.SetReadDeadline(time.Now().Add(time.Minute)) //一分钟内不登录 自动断开连接
|
|
||||||
agent.wg.Add(2)
|
agent.wg.Add(2)
|
||||||
go agent.readLoop()
|
go agent.readLoop()
|
||||||
go agent.writeLoop()
|
go agent.writeLoop()
|
||||||
@ -70,7 +69,6 @@ locp:
|
|||||||
go this.Close()
|
go this.Close()
|
||||||
break locp
|
break locp
|
||||||
}
|
}
|
||||||
|
|
||||||
if err = proto.Unmarshal(data, msg); err != nil {
|
if err = proto.Unmarshal(data, msg); err != nil {
|
||||||
this.gateway.Errorf("agent:%s uId:%s Unmarshal err:%v", this.sessionId, this.uId, err)
|
this.gateway.Errorf("agent:%s uId:%s Unmarshal err:%v", this.sessionId, this.uId, err)
|
||||||
go this.Close()
|
go this.Close()
|
||||||
|
@ -80,7 +80,7 @@ func (this *apiComp) Login(session comm.IUserSession, req *pb.UserLoginReq) (cod
|
|||||||
}
|
}
|
||||||
|
|
||||||
//缓存user session
|
//缓存user session
|
||||||
err = this.module.modelSession.ChangeList("online", user.Uid, map[string]interface{}{
|
err = this.module.modelSession.AddList("online", user.Uid, map[string]interface{}{
|
||||||
"uid": user.Uid,
|
"uid": user.Uid,
|
||||||
"sessionId": session.GetSessionId(),
|
"sessionId": session.GetSessionId(),
|
||||||
"serviceTag": session.GetServiecTag(),
|
"serviceTag": session.GetServiecTag(),
|
||||||
|
Loading…
Reference in New Issue
Block a user