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 8c2564e..c93567f 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 @@ -142,11 +142,13 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan @Override public void stagingOpened(LazyNettyClientLoginCommand lazyNettyClientLoginCommand) { String clientId = lazyNettyClientLoginCommand.getClientId(); + String originalIp = lazyNettyClientLoginCommand.getOriginalIp(); LazyNettyClientState lazyNettyClientState = new LazyNettyClientState(); lazyNettyClientState.setClientId(clientId); lazyNettyClientState.setStagingState("OPENED"); String serverId = serverNodeProperties.getNodeId(); lazyNettyClientState.setServerId(serverId); + lazyNettyClientState.setOriginalIp(originalIp); lazyNettyClientStateRepository.updateStagingState(lazyNettyClientState); lazyNettyClientLoginCommand.setStagingState("OPENED"); lazyNettyClientLoginCommand.setOnLineState(NettyClientStatus.OFF_LINE);