@@ -103,6 +103,7 @@ func DealEdbInspectionMessage(adminId int) {
err, isClose := WriteWebSocketMessageAsync(ctx, adminId, resp)
if err != nil {
utils.FileLog.Error("巡检信息发送失败,err:%s, adminId:%d", err.Error(), adminId)
+ cancel()
continue
}
if isClose {
