From e651a844f515db8be6360406ecc1f2f9cbdb5091 Mon Sep 17 00:00:00 2001 From: junleea <354425203@qq.com> Date: Wed, 6 Nov 2024 12:04:51 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=A4=9A=E8=BF=9E=E6=8E=A5?= =?UTF-8?q?=E6=9F=A5=E7=9C=8B=E5=AE=9E=E6=97=B6=E8=A7=86=E9=A2=91=E4=B8=8D?= =?UTF-8?q?=E6=AD=A3=E5=B8=B8=E5=85=B3=E9=97=AD=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- handler/device.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/handler/device.go b/handler/device.go index 9918ace..565ca06 100644 --- a/handler/device.go +++ b/handler/device.go @@ -274,7 +274,7 @@ func subscribeAndHandleMessages(ws *websocket.Conn, device_id int) { } } //查看是否还有其他连接,没有则设置is_play为0 - if worker.GetRedisSetMembers(online_conn_key) == nil { + if worker.IsContainKey(online_conn_key) == false { worker.SetRedisWithExpire(strconv.Itoa(device_id)+"_is_play", "0", time.Minute*5) fmt.Println("device_id:", device_id, " has set is_play to 0") }