apps/gb28181
1
0
Fork 0
mirror of https://github.com/gowvp/gb28181.git synced 2025-09-26 19:41:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

设备状态变化

Browse Source
This commit is contained in:
xugo
2025-03-09 16:58:54 +08:00
parent f6cc59b8e6
commit 7bd5a119dd
3 changed files with 5 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/gbs/keepalive.go
View File

@@ -23,19 +23,6 @@ func (g *GB28181API) sipMessageKeepalive(ctx *sip.Context) {
return
}
// device, ok := _activeDevices.Get(ctx.DeviceID)
// if !ok {
// device = Devices{DeviceID: ctx.DeviceID}
// if err := db.Get(db.DBClient, &device); err != nil {
// logrus.Warnln("Device Keepalive not found ", u.DeviceID, err)
// }
// }
ipc, ok := g.svr.memoryStorer.Load(ctx.DeviceID)
if ok {
g.svr.memoryStorer.Store(ctx.DeviceID, ipc)
}
if err := g.svr.memoryStorer.Change(ctx.DeviceID, func(d *gb28181.Device) {
d.KeepaliveAt = orm.Now()
d.IsOnline = msg.Status == "OK" || msg.Status == "ON"

1
pkg/gbs/register.go
View File

@@ -157,6 +157,7 @@ func (g GB28181API) login(ctx *sip.Context, expire string) {
g.svr.memoryStorer.Change(ctx.DeviceID, func(d *gb28181.Device) {
d.IsOnline = true
d.RegisteredAt = orm.Now()
d.KeepaliveAt = orm.Now()
d.Expires, _ = strconv.Atoi(expire)
}, func(d *Device) {
d.conn = ctx.Request.GetConnection()

5
pkg/gbs/server.go
View File

@@ -93,7 +93,10 @@ func (s *Server) startTickerCheck() {
return true
}
if now.Sub(value.LastKeepaliveAt) >= 3*60*time.Second || value.conn == nil {
if sub := now.Sub(value.LastKeepaliveAt); sub >= 3*60*time.Second || value.conn == nil {
fmt.Println(now)
fmt.Println(sub)
fmt.Println(value.LastKeepaliveAt)
s.gb.logout(key, func(d *gb28181.Device) {
d.IsOnline = false
})