From 79b09ecfea0ab4a736c0b6633653cdb780a7fabe Mon Sep 17 00:00:00 2001
From: wujiawei <12345678>
Date: Mon, 18 Nov 2024 20:41:02 +0800
Subject: [PATCH] =?UTF-8?q?[fix]=20=20=E4=BC=98=E5=8C=96=E8=B4=9F=E8=BD=BD?=
 =?UTF-8?q?=E8=8E=B7=E5=8F=96=E5=8F=AF=E4=BB=A5=E4=BD=BF=E7=94=A8=E7=9A=84?=
 =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../lazy/cloud/network/heartbeat/common/ChannelContext.java     | 2 ++
 .../application/impl/LazyClientStatsChangeApplicationImpl.java  | 1 +
 2 files changed, 3 insertions(+)

diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java
index ed9dd2a..21847bc 100644
--- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java
+++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java
@@ -11,6 +11,7 @@ import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
+import java.util.stream.Collectors;
 
 /**
  * 通道上下文
@@ -117,6 +118,7 @@ public class ChannelContext {
         if(ObjectUtils.isEmpty(channels)){
             return null;
         }
+        channels = channels.stream().filter(Channel::isActive).collect(Collectors.toList());
         return channels.get(0);
     }
 
diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java
index aca312a..8c2564e 100644
--- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java
+++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java
@@ -129,6 +129,7 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan
         lazyNettyClientState.setOriginalIp(lazyNettyClientLoginCommand.getOriginalIp());
         lazyNettyClientStateRepository.updateStagingState(lazyNettyClientState);
         lazyNettyClientLoginCommand.setStagingState("CLOSED");
+        lazyNettyClientLoginCommand.setOnLineState(NettyClientStatus.ON_LINE);
         lazyNettyClientLoginCommand.setServerId(serverId);
         storyClientStateRecord(lazyNettyClientLoginCommand);
     }