From ddf848dba039d553998eee584980d7012e3ace38 Mon Sep 17 00:00:00 2001
From: wujiawei <1207537021@qq.com>
Date: Fri, 12 Jul 2024 23:29:52 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=20add=20client=20state=20?=
 =?UTF-8?q?record?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dto/LazyNettyClientStateRecordDTO.java           |  5 ++++-
 .../impl/LazyClientStatsChangeApplicationImpl.java   | 12 ++++++++----
 2 files changed, 12 insertions(+), 5 deletions(-)

diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyNettyClientStateRecordDTO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyNettyClientStateRecordDTO.java
index ca5265f..0db01eb 100644
--- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyNettyClientStateRecordDTO.java
+++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyNettyClientStateRecordDTO.java
@@ -1,5 +1,6 @@
 package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto;
 
+import com.fasterxml.jackson.annotation.JsonFormat;
 import lombok.Data;
 import lombok.experimental.Accessors;
 import io.swagger.v3.oas.annotations.media.Schema;
@@ -28,8 +29,10 @@ public class LazyNettyClientStateRecordDTO {
 
     /**
      * 
-     * 
+     *
+     *
      */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
     @Schema(description ="",name ="createTime",example = "")
     private LocalDateTime createTime;
 
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 670e608..457355c 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
@@ -33,12 +33,13 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan
         this.lazyNettyClientStateRecordRepository = lazyNettyClientStateRecordRepository;
     }
 
-    private void storyClientStateRecord(String clientId){
+    private void storyClientStateRecord(String clientId,String serverId,String onLineState,String stagingState){
         LazyNettyClientStateRecord lazyNettyClientStateRecord = new LazyNettyClientStateRecord();
         lazyNettyClientStateRecord.setClientId(clientId);
         lazyNettyClientStateRecord.setCreateTime(LocalDateTime.now());
-
-
+        lazyNettyClientStateRecord.setServerId(serverId);
+        lazyNettyClientStateRecord.setOnLineState(onLineState);
+        lazyNettyClientStateRecord.setStagingState(stagingState);
         lazyNettyClientStateRecordRepository.story(lazyNettyClientStateRecord);
     }
 
@@ -58,6 +59,7 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan
         String serverId = serverNodeProperties.getNodeId();
         lazyNettyClientState.setServerId(serverId);
         lazyNettyClientStateRepository.updateOnLIneState(lazyNettyClientState);
+        storyClientStateRecord(clientId,serverId,NettyClientStatus.ON_LINE.name(),null);
         // 触发暂存扫描
 //        ClientOnLineState clientOnLineState = new ClientOnLineState();
 //        clientOnLineState.setClientId(clientId);
@@ -84,7 +86,7 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan
         lazyNettyClientState.setServerId(serverId);
         lazyNettyClientStateRepository.updateOnLIneState(lazyNettyClientState);
         // 创建变更记录
-
+        storyClientStateRecord(clientId,serverId,NettyClientStatus.OFF_LINE.name(),null);
 //        // 触发暂存扫描
 //        ClientOnLineState clientOnLineState = new ClientOnLineState();
 //        clientOnLineState.setClientId(clientId);
@@ -106,6 +108,7 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan
         String serverId = serverNodeProperties.getNodeId();
         lazyNettyClientState.setServerId(serverId);
         lazyNettyClientStateRepository.updateStagingState(lazyNettyClientState);
+        storyClientStateRecord(clientId,serverId,null,"CLOSE");
     }
 
     /**
@@ -121,5 +124,6 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan
         String serverId = serverNodeProperties.getNodeId();
         lazyNettyClientState.setServerId(serverId);
         lazyNettyClientStateRepository.updateStagingState(lazyNettyClientState);
+        storyClientStateRecord(clientId,serverId,null,"CLOSE");
     }
 }