|
|
@@ -53,7 +53,6 @@ func (s *Device) Process() {
|
|
|
}
|
|
|
switch data[16:18] {
|
|
|
case "61":
|
|
|
- logger.Logger.Debug("登录")
|
|
|
// fe5c4b89 2a000000 62 00000000 17000000 31 23 32303233(年) 3035(月) 3135(日) 3031(星期) 3038(时) 3334(分) 3135(秒) 23 303630(心跳包时间) 23 ffff
|
|
|
buffer := protocol.AuthDataPack{}.AuthLogin()
|
|
|
// 通过sn 查设备是否存在 不存在return 存在就保存con 和 info
|
|
|
@@ -77,8 +76,8 @@ func (s *Device) Process() {
|
|
|
s.info = screens
|
|
|
devices[s.info.Sn] = *s
|
|
|
s.conn.Write(buffer.Bytes())
|
|
|
+ logger.Logger.Debugf("设备 [%v] 登录", s.info.ScreensName)
|
|
|
case "91":
|
|
|
- logger.Logger.Debug("心跳")
|
|
|
//判断内存devices中是否存储了设备(连接)信息
|
|
|
if _, exists := devices[data[34:50]]; !exists {
|
|
|
//不存在
|
|
|
@@ -100,6 +99,7 @@ func (s *Device) Process() {
|
|
|
})
|
|
|
}
|
|
|
}
|
|
|
+ logger.Logger.Debugf("设备 [%v] 心跳", s.info.ScreensName)
|
|
|
if data[34:50] != s.info.Sn {
|
|
|
continue
|
|
|
}
|
|
|
@@ -112,7 +112,7 @@ func (s *Device) Process() {
|
|
|
|
|
|
func (s *Device) Handle() {
|
|
|
defer s.conn.Close()
|
|
|
- t2 := time.NewTicker(3 * time.Minute) //在线监测
|
|
|
+ t2 := time.NewTicker(6 * time.Minute) //在线监测
|
|
|
defer t2.Stop()
|
|
|
|
|
|
for {
|
|
|
@@ -124,7 +124,7 @@ func (s *Device) Handle() {
|
|
|
DisplayStatus: s.info.DisplayStatus,
|
|
|
SourceStatus: s.info.SourceStatus,
|
|
|
}
|
|
|
- if time.Now().Add(-2*time.Minute).After(s.lastTime) || s.lastTime.IsZero() {
|
|
|
+ if time.Now().Add(-5*time.Minute).After(s.lastTime) || s.lastTime.IsZero() {
|
|
|
//离线
|
|
|
state.Status = 0
|
|
|
err := Dev.UpdateScreensStatusAndOffline(s.info.ScreensCode, state)
|
