alsace/wu-lazy-cloud-network
1
0
Fork 0
mirror of https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git synced 2025-06-06 13:27:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

【fix】 add client state record

Browse Source
This commit is contained in:
wujiawei 2024-07-12 23:29:52 +08:00
parent 7c256efb17
commit ddf848dba0
2 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyNettyClientStateRecordDTO.java
View File

@ -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;
@ -27,9 +28,11 @@ public class LazyNettyClientStateRecordDTO {
private String clientId;
/**
*
*
*
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
@Schema(description ="",name ="createTime",example = "")
private LocalDateTime createTime;

12
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java
View File

@ -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");
}
}