【fix】

This commit is contained in:
wujiawei
2024-07-12 17:14:51 +08:00
parent 407382c26d
commit d0b9a76680
65 changed files with 1466 additions and 86 deletions

View File

@ -169,11 +169,11 @@
<!-->发布的地址<--> <!-->发布的地址<-->
<distributionManagement> <distributionManagement>
<snapshotRepository> <snapshotRepository>
<id>snapshots</id> <id>oss-snapshots</id>
<url>https://oss.sonatype.org/content/repositories/snapshots/</url> <url>https://oss.sonatype.org/content/repositories/snapshots/</url>
</snapshotRepository> </snapshotRepository>
<repository> <repository>
<id>snapshots</id> <id>oss-snapshots</id>
<url>https://oss.sonatype.org/service/local/staging/deploy/maven2/</url> <url>https://oss.sonatype.org/service/local/staging/deploy/maven2/</url>
</repository> </repository>
</distributionManagement> </distributionManagement>

View File

@ -13,7 +13,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
import org.framework.lazy.cloud.network.heartbeat.common.advanced.server.AbstractHandleClientConnectSuccessTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.common.advanced.server.AbstractHandleClientConnectSuccessTypeAdvanced;
import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist.LazyNettyClientBlacklist; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.List; import java.util.List;

View File

@ -2,11 +2,10 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientBlacklistDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientBlacklistDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;
import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist.LazyNettyClientBlacklist; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
import java.util.List; import java.util.List;

View File

@ -3,8 +3,7 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientState;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientState;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;
import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication;

View File

@ -0,0 +1,109 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application;
import org.wu.framework.web.response.Result;
import org.wu.framework.web.response.ResultFactory;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecord;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateRecordDTO;
import java.util.List;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication
**/
public interface LazyNettyClientStateRecordApplication {
/**
* describe 新增客户端状态变更记录
*
* @param lazyNettyClientStateRecordStoryCommand 新增客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录新增后领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<LazyNettyClientStateRecord> story(LazyNettyClientStateRecordStoryCommand lazyNettyClientStateRecordStoryCommand);
/**
* describe 批量新增客户端状态变更记录
*
* @param lazyNettyClientStateRecordStoryCommandList 批量新增客户端状态变更记录
* @return {@link Result<List<LazyNettyClientStateRecord>>} 客户端状态变更记录新增后领域对象集合
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<List<LazyNettyClientStateRecord>> batchStory(List<LazyNettyClientStateRecordStoryCommand> lazyNettyClientStateRecordStoryCommandList);
/**
* describe 更新客户端状态变更记录
*
* @param lazyNettyClientStateRecordUpdateCommand 更新客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<LazyNettyClientStateRecord> updateOne(LazyNettyClientStateRecordUpdateCommand lazyNettyClientStateRecordUpdateCommand);
/**
* describe 查询单个客户端状态变更记录
*
* @param lazyNettyClientStateRecordQueryOneCommand 查询单个客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecordDTO>} 客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<LazyNettyClientStateRecordDTO> findOne(LazyNettyClientStateRecordQueryOneCommand lazyNettyClientStateRecordQueryOneCommand);
/**
* describe 查询多个客户端状态变更记录
*
* @param lazyNettyClientStateRecordQueryListCommand 查询多个客户端状态变更记录
* @return {@link Result <List<LazyNettyClientStateRecordDTO>>} 客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result <List<LazyNettyClientStateRecordDTO>> findList(LazyNettyClientStateRecordQueryListCommand lazyNettyClientStateRecordQueryListCommand);
/**
* describe 分页查询多个客户端状态变更记录
*
* @param lazyNettyClientStateRecordQueryListCommand 分页查询多个客户端状态变更记录
* @return {@link Result <LazyPage<LazyNettyClientStateRecordDTO>>} 分页客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result <LazyPage<LazyNettyClientStateRecordDTO>> findPage(int size,int current,LazyNettyClientStateRecordQueryListCommand lazyNettyClientStateRecordQueryListCommand);
/**
* describe 删除客户端状态变更记录
*
* @param lazyNettyClientStateRecordRemoveCommand 删除客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<LazyNettyClientStateRecord> remove(LazyNettyClientStateRecordRemoveCommand lazyNettyClientStateRecordRemoveCommand);
}

View File

@ -7,7 +7,7 @@ import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;
import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.server.visitor.LazyNettyServerVisitor; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor.LazyNettyServerVisitor;
import java.util.List; import java.util.List;

View File

@ -8,7 +8,7 @@ import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;
import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow.LazyVisitorPortFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow.LazyVisitorPortFlow;
import java.util.List; import java.util.List;

View File

@ -4,7 +4,7 @@ import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyClientPortFlowPerDayEchartsDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyClientPortFlowPerDayEchartsDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorPortPerDayFlowDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorPortPerDayFlowDTO;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRemoveCommand; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowStoryCommand; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowUpdateCommand; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowUpdateCommand;

View File

@ -0,0 +1,93 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecord;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateRecordDTO;
import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler
**/
@Mapper
public interface LazyNettyClientStateRecordDTOAssembler {
/**
* describe MapStruct 创建的代理对象
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
LazyNettyClientStateRecordDTOAssembler INSTANCE = Mappers.getMapper(LazyNettyClientStateRecordDTOAssembler.class);
/**
* describe 应用层存储入参转换成 领域对象
*
* @param lazyNettyClientStateRecordStoryCommand 保存客户端状态变更记录对象
* @return {@link LazyNettyClientStateRecord} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
LazyNettyClientStateRecord toLazyNettyClientStateRecord(LazyNettyClientStateRecordStoryCommand lazyNettyClientStateRecordStoryCommand);
/**
* describe 应用层更新入参转换成 领域对象
*
* @param lazyNettyClientStateRecordUpdateCommand 更新客户端状态变更记录对象
* @return {@link LazyNettyClientStateRecord} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
LazyNettyClientStateRecord toLazyNettyClientStateRecord(LazyNettyClientStateRecordUpdateCommand lazyNettyClientStateRecordUpdateCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyNettyClientStateRecordQueryOneCommand 查询单个客户端状态变更记录对象参数
* @return {@link LazyNettyClientStateRecord} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
LazyNettyClientStateRecord toLazyNettyClientStateRecord(LazyNettyClientStateRecordQueryOneCommand lazyNettyClientStateRecordQueryOneCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyNettyClientStateRecordQueryListCommand 查询集合客户端状态变更记录对象参数
* @return {@link LazyNettyClientStateRecord} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
LazyNettyClientStateRecord toLazyNettyClientStateRecord(LazyNettyClientStateRecordQueryListCommand lazyNettyClientStateRecordQueryListCommand);
/**
* describe 应用层删除入参转换成 领域对象
*
* @param lazyNettyClientStateRecordRemoveCommand 删除客户端状态变更记录对象参数
* @return {@link LazyNettyClientStateRecord} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
LazyNettyClientStateRecord toLazyNettyClientStateRecord(LazyNettyClientStateRecordRemoveCommand lazyNettyClientStateRecordRemoveCommand);
/**
* describe 持久层领域对象转换成DTO对象
*
* @param lazyNettyClientStateRecord 客户端状态变更记录领域对象
* @return {@link LazyNettyClientStateRecordDTO} 客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
LazyNettyClientStateRecordDTO fromLazyNettyClientStateRecord(LazyNettyClientStateRecord lazyNettyClientStateRecord);
}

View File

@ -2,8 +2,7 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientBlacklistDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientBlacklistDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist.LazyNettyClientBlacklist; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler;

View File

@ -1,9 +1,8 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler; package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientState; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientState;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler;

View File

@ -2,7 +2,7 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.server.visitor.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.server.visitor.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerVisitorDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerVisitorDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.server.visitor.LazyNettyServerVisitor; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor.LazyNettyServerVisitor;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.server.visitor.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.server.visitor.*;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;

View File

@ -1,7 +1,7 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler; package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.flow.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.flow.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow.LazyVisitorPortFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow.LazyVisitorPortFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.flow.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.flow.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorPortFlowDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorPortFlowDTO;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;

View File

@ -1,6 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler; package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorPortPerDayFlowDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorPortPerDayFlowDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRemoveCommand; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowStoryCommand; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowStoryCommand;

View File

@ -0,0 +1,64 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.lang.String;
import java.time.LocalDateTime;
import java.lang.Long;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyQueryListCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_client_state_record_query_List_command",description = "客户端状态变更记录")
public class LazyNettyClientStateRecordQueryListCommand {
/**
*
* 客户端ID
*/
@Schema(description ="客户端ID",name ="clientId",example = "")
private String clientId;
/**
*
*
*/
@Schema(description ="",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 主键
*/
@Schema(description ="主键",name ="id",example = "")
private Long id;
/**
*
* 在线状态true在线false离线
*/
@Schema(description ="在线状态true在线false离线",name ="onLineState",example = "")
private String onLineState;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
private String serverId;
/**
*
* 暂存状态(开启、关闭)
*/
@Schema(description ="暂存状态(开启、关闭)",name ="stagingState",example = "")
private String stagingState;
}

View File

@ -0,0 +1,64 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.lang.String;
import java.time.LocalDateTime;
import java.lang.Long;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyQueryOneCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_client_state_record_query_one_command",description = "客户端状态变更记录")
public class LazyNettyClientStateRecordQueryOneCommand {
/**
*
* 客户端ID
*/
@Schema(description ="客户端ID",name ="clientId",example = "")
private String clientId;
/**
*
*
*/
@Schema(description ="",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 主键
*/
@Schema(description ="主键",name ="id",example = "")
private Long id;
/**
*
* 在线状态true在线false离线
*/
@Schema(description ="在线状态true在线false离线",name ="onLineState",example = "")
private String onLineState;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
private String serverId;
/**
*
* 暂存状态(开启、关闭)
*/
@Schema(description ="暂存状态(开启、关闭)",name ="stagingState",example = "")
private String stagingState;
}

View File

@ -0,0 +1,64 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.lang.String;
import java.time.LocalDateTime;
import java.lang.Long;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyRemoveCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_client_state_record_remove_command",description = "客户端状态变更记录")
public class LazyNettyClientStateRecordRemoveCommand {
/**
*
* 客户端ID
*/
@Schema(description ="客户端ID",name ="clientId",example = "")
private String clientId;
/**
*
*
*/
@Schema(description ="",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 主键
*/
@Schema(description ="主键",name ="id",example = "")
private Long id;
/**
*
* 在线状态true在线false离线
*/
@Schema(description ="在线状态true在线false离线",name ="onLineState",example = "")
private String onLineState;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
private String serverId;
/**
*
* 暂存状态(开启、关闭)
*/
@Schema(description ="暂存状态(开启、关闭)",name ="stagingState",example = "")
private String stagingState;
}

View File

@ -0,0 +1,64 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.lang.String;
import java.time.LocalDateTime;
import java.lang.Long;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyStoryCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_client_state_record_story_command",description = "客户端状态变更记录")
public class LazyNettyClientStateRecordStoryCommand {
/**
*
* 客户端ID
*/
@Schema(description ="客户端ID",name ="clientId",example = "")
private String clientId;
/**
*
*
*/
@Schema(description ="",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 主键
*/
@Schema(description ="主键",name ="id",example = "")
private Long id;
/**
*
* 在线状态true在线false离线
*/
@Schema(description ="在线状态true在线false离线",name ="onLineState",example = "")
private String onLineState;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
private String serverId;
/**
*
* 暂存状态(开启、关闭)
*/
@Schema(description ="暂存状态(开启、关闭)",name ="stagingState",example = "")
private String stagingState;
}

View File

@ -0,0 +1,64 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.lang.String;
import java.time.LocalDateTime;
import java.lang.Long;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyUpdateCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_client_state_record_update_command",description = "客户端状态变更记录")
public class LazyNettyClientStateRecordUpdateCommand {
/**
*
* 客户端ID
*/
@Schema(description ="客户端ID",name ="clientId",example = "")
private String clientId;
/**
*
*
*/
@Schema(description ="",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 主键
*/
@Schema(description ="主键",name ="id",example = "")
private Long id;
/**
*
* 在线状态true在线false离线
*/
@Schema(description ="在线状态true在线false离线",name ="onLineState",example = "")
private String onLineState;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
private String serverId;
/**
*
* 暂存状态(开启、关闭)
*/
@Schema(description ="暂存状态(开启、关闭)",name ="stagingState",example = "")
private String stagingState;
}

View File

@ -0,0 +1,64 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.lang.String;
import java.time.LocalDateTime;
import java.lang.Long;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyDTO
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_client_state_record_command_dto",description = "客户端状态变更记录")
public class LazyNettyClientStateRecordDTO {
/**
*
* 客户端ID
*/
@Schema(description ="客户端ID",name ="clientId",example = "")
private String clientId;
/**
*
*
*/
@Schema(description ="",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 主键
*/
@Schema(description ="主键",name ="id",example = "")
private Long id;
/**
*
* 在线状态true在线false离线
*/
@Schema(description ="在线状态true在线false离线",name ="onLineState",example = "")
private String onLineState;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
private String serverId;
/**
*
* 暂存状态(开启、关闭)
*/
@Schema(description ="暂存状态(开启、关闭)",name ="stagingState",example = "")
private String stagingState;
}

View File

@ -3,13 +3,17 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties; import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyClientStatsChangeApplication; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyClientStatsChangeApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientState; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientState;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientStateRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecord;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecordRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientStateRepository;
import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.framework.lazy.cloud.network.heartbeat.common.constant.ClientConfigKeyUtils; import org.framework.lazy.cloud.network.heartbeat.common.constant.ClientConfigKeyUtils;
import org.framework.lazy.cloud.network.heartbeat.common.enums.NettyClientStatus; import org.framework.lazy.cloud.network.heartbeat.common.enums.NettyClientStatus;
import java.time.LocalDateTime;
@Slf4j @Slf4j
@LazyApplication @LazyApplication
@ -17,15 +21,26 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan
private final LazyNettyClientStateRepository lazyNettyClientStateRepository; private final LazyNettyClientStateRepository lazyNettyClientStateRepository;
private final ServerNodeProperties serverNodeProperties; private final ServerNodeProperties serverNodeProperties;
private final LazyNettyClientStateRecordRepository lazyNettyClientStateRecordRepository;
public LazyClientStatsChangeApplicationImpl(LazyNettyClientStateRepository lazyNettyClientStateRepository, public LazyClientStatsChangeApplicationImpl(LazyNettyClientStateRepository lazyNettyClientStateRepository,
ServerNodeProperties serverNodeProperties) { ServerNodeProperties serverNodeProperties, LazyNettyClientStateRecordRepository lazyNettyClientStateRecordRepository) {
this.lazyNettyClientStateRepository = lazyNettyClientStateRepository; this.lazyNettyClientStateRepository = lazyNettyClientStateRepository;
this.serverNodeProperties = serverNodeProperties; this.serverNodeProperties = serverNodeProperties;
this.lazyNettyClientStateRecordRepository = lazyNettyClientStateRecordRepository;
} }
private void storyClientStateRecord(String clientId){
LazyNettyClientStateRecord lazyNettyClientStateRecord = new LazyNettyClientStateRecord();
lazyNettyClientStateRecord.setClientId(clientId);
lazyNettyClientStateRecord.setCreateTime(LocalDateTime.now());
lazyNettyClientStateRecordRepository.story(lazyNettyClientStateRecord);
}
/** /**
* 客户端在线 * 客户端在线
@ -68,6 +83,8 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan
String serverId = serverNodeProperties.getNodeId(); String serverId = serverNodeProperties.getNodeId();
lazyNettyClientState.setServerId(serverId); lazyNettyClientState.setServerId(serverId);
lazyNettyClientStateRepository.updateOnLIneState(lazyNettyClientState); lazyNettyClientStateRepository.updateOnLIneState(lazyNettyClientState);
// 创建变更记录
// // 触发暂存扫描 // // 触发暂存扫描
// ClientOnLineState clientOnLineState = new ClientOnLineState(); // ClientOnLineState clientOnLineState = new ClientOnLineState();
// clientOnLineState.setClientId(clientId); // clientOnLineState.setClientId(clientId);

View File

@ -5,9 +5,8 @@ import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler.NettyClientBlacklistDTOAssembler; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler.NettyClientBlacklistDTOAssembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientBlacklistDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientBlacklistDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist.LazyNettyClientBlacklist; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist.LazyNettyClientBlacklistRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklistRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*;
import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;

View File

@ -6,10 +6,9 @@ import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodePr
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyNettyClientStateApplication; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyNettyClientStateApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler.NettyClientStateDTOAssembler; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler.NettyClientStateDTOAssembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientState; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientState;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientStateRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientStateRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*;
import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;

View File

@ -0,0 +1,144 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.impl;
import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyNettyClientStateRecordApplication;
import org.springframework.web.bind.annotation.*;
import org.wu.framework.web.response.Result;
import org.wu.framework.web.response.ResultFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecord;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler.LazyNettyClientStateRecordDTOAssembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateRecordDTO;
import java.util.stream.Collectors;
import jakarta.annotation.Resource;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecordRepository;
import java.util.List;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplicationImpl
**/
@LazyApplication
public class LazyNettyClientStateRecordApplicationImpl implements LazyNettyClientStateRecordApplication {
@Resource
LazyNettyClientStateRecordRepository lazyNettyClientStateRecordRepository;
/**
* describe 新增客户端状态变更记录
*
* @param lazyNettyClientStateRecordStoryCommand 新增客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录新增后领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<LazyNettyClientStateRecord> story(LazyNettyClientStateRecordStoryCommand lazyNettyClientStateRecordStoryCommand) {
LazyNettyClientStateRecord lazyNettyClientStateRecord = LazyNettyClientStateRecordDTOAssembler.INSTANCE.toLazyNettyClientStateRecord(lazyNettyClientStateRecordStoryCommand);
return lazyNettyClientStateRecordRepository.story(lazyNettyClientStateRecord);
}
/**
* describe 批量新增客户端状态变更记录
*
* @param lazyNettyClientStateRecordStoryCommandList 批量新增客户端状态变更记录
* @return {@link Result<List<LazyNettyClientStateRecord>>} 客户端状态变更记录新增后领域对象集合
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<List<LazyNettyClientStateRecord>> batchStory(List<LazyNettyClientStateRecordStoryCommand> lazyNettyClientStateRecordStoryCommandList) {
List<LazyNettyClientStateRecord> lazyNettyClientStateRecordList = lazyNettyClientStateRecordStoryCommandList.stream().map( LazyNettyClientStateRecordDTOAssembler.INSTANCE::toLazyNettyClientStateRecord).collect(Collectors.toList());
return lazyNettyClientStateRecordRepository.batchStory(lazyNettyClientStateRecordList);
}
/**
* describe 更新客户端状态变更记录
*
* @param lazyNettyClientStateRecordUpdateCommand 更新客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<LazyNettyClientStateRecord> updateOne(LazyNettyClientStateRecordUpdateCommand lazyNettyClientStateRecordUpdateCommand) {
LazyNettyClientStateRecord lazyNettyClientStateRecord = LazyNettyClientStateRecordDTOAssembler.INSTANCE.toLazyNettyClientStateRecord(lazyNettyClientStateRecordUpdateCommand);
return lazyNettyClientStateRecordRepository.story(lazyNettyClientStateRecord);
}
/**
* describe 查询单个客户端状态变更记录
*
* @param lazyNettyClientStateRecordQueryOneCommand 查询单个客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecordDTO>} 客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<LazyNettyClientStateRecordDTO> findOne(LazyNettyClientStateRecordQueryOneCommand lazyNettyClientStateRecordQueryOneCommand) {
LazyNettyClientStateRecord lazyNettyClientStateRecord = LazyNettyClientStateRecordDTOAssembler.INSTANCE.toLazyNettyClientStateRecord(lazyNettyClientStateRecordQueryOneCommand);
return lazyNettyClientStateRecordRepository.findOne(lazyNettyClientStateRecord).convert(LazyNettyClientStateRecordDTOAssembler.INSTANCE::fromLazyNettyClientStateRecord);
}
/**
* describe 查询多个客户端状态变更记录
*
* @param lazyNettyClientStateRecordQueryListCommand 查询多个客户端状态变更记录
* @return {@link Result<List<LazyNettyClientStateRecordDTO>>} 客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<List<LazyNettyClientStateRecordDTO>> findList(LazyNettyClientStateRecordQueryListCommand lazyNettyClientStateRecordQueryListCommand) {
LazyNettyClientStateRecord lazyNettyClientStateRecord = LazyNettyClientStateRecordDTOAssembler.INSTANCE.toLazyNettyClientStateRecord(lazyNettyClientStateRecordQueryListCommand);
return lazyNettyClientStateRecordRepository.findList(lazyNettyClientStateRecord) .convert(lazyNettyClientStateRecords -> lazyNettyClientStateRecords.stream().map(LazyNettyClientStateRecordDTOAssembler.INSTANCE::fromLazyNettyClientStateRecord).collect(Collectors.toList())) ;
}
/**
* describe 分页查询多个客户端状态变更记录
*
* @param lazyNettyClientStateRecordQueryListCommand 分页查询多个客户端状态变更记录
* @return {@link Result<LazyPage<LazyNettyClientStateRecordDTO>>} 分页客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<LazyPage<LazyNettyClientStateRecordDTO>> findPage(int size,int current,LazyNettyClientStateRecordQueryListCommand lazyNettyClientStateRecordQueryListCommand) {
LazyNettyClientStateRecord lazyNettyClientStateRecord = LazyNettyClientStateRecordDTOAssembler.INSTANCE.toLazyNettyClientStateRecord(lazyNettyClientStateRecordQueryListCommand);
return lazyNettyClientStateRecordRepository.findPage(size,current,lazyNettyClientStateRecord) .convert(page -> page.convert(LazyNettyClientStateRecordDTOAssembler.INSTANCE::fromLazyNettyClientStateRecord)) ;
}
/**
* describe 删除客户端状态变更记录
*
* @param lazyNettyClientStateRecordRemoveCommand 删除客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<LazyNettyClientStateRecord> remove(LazyNettyClientStateRecordRemoveCommand lazyNettyClientStateRecordRemoveCommand) {
LazyNettyClientStateRecord lazyNettyClientStateRecord = LazyNettyClientStateRecordDTOAssembler.INSTANCE.toLazyNettyClientStateRecord(lazyNettyClientStateRecordRemoveCommand);
return lazyNettyClientStateRecordRepository.remove(lazyNettyClientStateRecord);
}
}

View File

@ -5,9 +5,8 @@ import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler.NettyServerVisitorDTOAssembler; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler.NettyServerVisitorDTOAssembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.server.visitor.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.server.visitor.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerVisitorDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerVisitorDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.server.visitor.LazyNettyServerVisitor; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor.LazyNettyServerVisitor;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.server.visitor.LazyNettyServerVisitorRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor.LazyNettyServerVisitorRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.server.visitor.*;
import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;

View File

@ -9,12 +9,11 @@ import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowStoryCommand; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorFlowDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorFlowDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorPortFlowDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorPortFlowDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow.LazyVisitorPortFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow.LazyVisitorPortFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow.LazyVisitorPortFlowRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow.LazyVisitorPortFlowRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.flow.*;
import org.wu.framework.core.utils.ObjectUtils; import org.wu.framework.core.utils.ObjectUtils;
import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;

View File

@ -8,10 +8,10 @@ import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyClientFlowPerDayEchartsDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyClientFlowPerDayEchartsDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyClientPortFlowPerDayEchartsDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyClientPortFlowPerDayEchartsDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorPortPerDayFlowDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorPortPerDayFlowDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientState; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientState;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientStateRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientStateRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRepository;
import org.wu.framework.core.utils.ObjectUtils; import org.wu.framework.core.utils.ObjectUtils;
import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;

View File

@ -2,7 +2,6 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.controller;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientBlacklistDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientBlacklistDTO;
import org.wu.framework.web.spring.EasyController; import org.wu.framework.web.spring.EasyController;
@ -17,7 +16,7 @@ import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyController; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyController;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyNettyClientBlacklistApplication; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyNettyClientBlacklistApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist.LazyNettyClientBlacklist; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
import java.util.List; import java.util.List;

View File

@ -1,10 +1,9 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.controller; package org.framework.lazy.cloud.network.heartbeat.server.standalone.controller;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientState; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientState;
import org.wu.framework.web.spring.EasyController; import org.wu.framework.web.spring.EasyController;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;

View File

@ -0,0 +1,142 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.controller;
import io.swagger.v3.oas.annotations.tags.Tag;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import org.wu.framework.web.spring.EasyController;
import org.springframework.web.bind.annotation.*;
import org.wu.framework.web.response.Result;
import org.wu.framework.web.response.ResultFactory;
import org.springframework.beans.factory.annotation.Autowired;
import jakarta.annotation.Resource;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecord;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.record.LazyNettyClientStateRecordQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyNettyClientStateRecordApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateRecordDTO;
import java.util.List;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyController
**/
@Tag(name = "客户端状态变更记录提供者")
@EasyController("/lazy/netty/client/state/record")
public class LazyNettyClientStateRecordProvider {
@Resource
private LazyNettyClientStateRecordApplication lazyNettyClientStateRecordApplication;
/**
* describe 新增客户端状态变更记录
*
* @param lazyNettyClientStateRecordStoryCommand 新增客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录新增后领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Operation(summary = "新增客户端状态变更记录")
@PostMapping("/story")
public Result<LazyNettyClientStateRecord> story(@RequestBody LazyNettyClientStateRecordStoryCommand lazyNettyClientStateRecordStoryCommand){
return lazyNettyClientStateRecordApplication.story(lazyNettyClientStateRecordStoryCommand);
}
/**
* describe 批量新增客户端状态变更记录
*
* @param lazyNettyClientStateRecordStoryCommandList 批量新增客户端状态变更记录
* @return {@link Result<List<LazyNettyClientStateRecord>>} 客户端状态变更记录新增后领域对象集合
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Operation(summary = "批量新增客户端状态变更记录")
@PostMapping("/batchStory")
public Result<List<LazyNettyClientStateRecord>> batchStory(@RequestBody List<LazyNettyClientStateRecordStoryCommand> lazyNettyClientStateRecordStoryCommandList){
return lazyNettyClientStateRecordApplication.batchStory(lazyNettyClientStateRecordStoryCommandList);
}
/**
* describe 更新客户端状态变更记录
*
* @param lazyNettyClientStateRecordUpdateCommand 更新客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Operation(summary = "更新客户端状态变更记录")
@PutMapping("/updateOne")
public Result<LazyNettyClientStateRecord> updateOne(@RequestBody LazyNettyClientStateRecordUpdateCommand lazyNettyClientStateRecordUpdateCommand){
return lazyNettyClientStateRecordApplication.updateOne(lazyNettyClientStateRecordUpdateCommand);
}
/**
* describe 查询单个客户端状态变更记录
*
* @param lazyNettyClientStateRecordQueryOneCommand 查询单个客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecordDTO>} 客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Operation(summary = "查询单个客户端状态变更记录")
@GetMapping("/findOne")
public Result<LazyNettyClientStateRecordDTO> findOne(@ModelAttribute LazyNettyClientStateRecordQueryOneCommand lazyNettyClientStateRecordQueryOneCommand){
return lazyNettyClientStateRecordApplication.findOne(lazyNettyClientStateRecordQueryOneCommand);
}
/**
* describe 查询多个客户端状态变更记录
*
* @param lazyNettyClientStateRecordQueryListCommand 查询多个客户端状态变更记录
* @return {@link Result<List<LazyNettyClientStateRecordDTO>>} 客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Operation(summary = "查询多个客户端状态变更记录")
@GetMapping("/findList")
public Result<List<LazyNettyClientStateRecordDTO>> findList(@ModelAttribute LazyNettyClientStateRecordQueryListCommand lazyNettyClientStateRecordQueryListCommand){
return lazyNettyClientStateRecordApplication.findList(lazyNettyClientStateRecordQueryListCommand);
}
/**
* describe 分页查询多个客户端状态变更记录
*
* @param lazyNettyClientStateRecordQueryListCommand 分页查询多个客户端状态变更记录
* @return {@link Result<LazyPage<LazyNettyClientStateRecordDTO>>} 分页客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Operation(summary = "分页查询多个客户端状态变更记录")
@GetMapping("/findPage")
public Result<LazyPage<LazyNettyClientStateRecordDTO>> findPage(@Parameter(description ="分页大小") @RequestParam(defaultValue = "10", value = "size") int size,
@Parameter(description ="当前页数") @RequestParam(defaultValue = "1", value = "current") int current,@ModelAttribute LazyNettyClientStateRecordQueryListCommand lazyNettyClientStateRecordQueryListCommand){
return lazyNettyClientStateRecordApplication.findPage(size,current,lazyNettyClientStateRecordQueryListCommand);
}
/**
* describe 删除客户端状态变更记录
*
* @param lazyNettyClientStateRecordRemoveCommand 删除客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Operation(summary = "删除客户端状态变更记录")
@DeleteMapping("/remove")
public Result<LazyNettyClientStateRecord> remove(@ModelAttribute LazyNettyClientStateRecordRemoveCommand lazyNettyClientStateRecordRemoveCommand){
return lazyNettyClientStateRecordApplication.remove(lazyNettyClientStateRecordRemoveCommand);
}
}

View File

@ -13,7 +13,7 @@ import org.springframework.web.bind.annotation.*;
import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyController; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyController;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyNettyServerVisitorApplication; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyNettyServerVisitorApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerVisitorDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerVisitorDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.server.visitor.LazyNettyServerVisitor; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor.LazyNettyServerVisitor;
import java.util.List; import java.util.List;

View File

@ -14,7 +14,7 @@ import org.springframework.web.bind.annotation.*;
import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyController; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyController;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyVisitorPortFlowApplication; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyVisitorPortFlowApplication;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorFlowDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyVisitorFlowDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow.LazyVisitorPortFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow.LazyVisitorPortFlow;
import java.util.List; import java.util.List;

View File

@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;

View File

@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;

View File

@ -0,0 +1,64 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.lang.String;
import java.time.LocalDateTime;
import java.lang.Long;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyDomain
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_client_state_record",description = "客户端状态变更记录")
public class LazyNettyClientStateRecord {
/**
*
* 客户端ID
*/
@Schema(description ="客户端ID",name ="clientId",example = "")
private String clientId;
/**
*
*
*/
@Schema(description ="",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 主键
*/
@Schema(description ="主键",name ="id",example = "")
private Long id;
/**
*
* 在线状态true在线false离线
*/
@Schema(description ="在线状态true在线false离线",name ="onLineState",example = "")
private String onLineState;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
private String serverId;
/**
*
* 暂存状态(开启、关闭)
*/
@Schema(description ="暂存状态(开启、关闭)",name ="stagingState",example = "")
private String stagingState;
}

View File

@ -0,0 +1,106 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record;
import org.wu.framework.web.response.Result;
import org.wu.framework.web.response.ResultFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecord;
import java.util.List;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyDomainRepository
**/
public interface LazyNettyClientStateRecordRepository {
/**
* describe 新增客户端状态变更记录
*
* @param lazyNettyClientStateRecord 新增客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录新增后领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<LazyNettyClientStateRecord> story(LazyNettyClientStateRecord lazyNettyClientStateRecord);
/**
* describe 批量新增客户端状态变更记录
*
* @param lazyNettyClientStateRecordList 批量新增客户端状态变更记录
* @return {@link Result<List<LazyNettyClientStateRecord>>} 客户端状态变更记录新增后领域对象集合
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<List<LazyNettyClientStateRecord>> batchStory(List<LazyNettyClientStateRecord> lazyNettyClientStateRecordList);
/**
* describe 查询单个客户端状态变更记录
*
* @param lazyNettyClientStateRecord 查询单个客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<LazyNettyClientStateRecord> findOne(LazyNettyClientStateRecord lazyNettyClientStateRecord);
/**
* describe 查询多个客户端状态变更记录
*
* @param lazyNettyClientStateRecord 查询多个客户端状态变更记录
* @return {@link Result<List<LazyNettyClientStateRecord>>} 客户端状态变更记录DTO对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<List<LazyNettyClientStateRecord>> findList(LazyNettyClientStateRecord lazyNettyClientStateRecord);
/**
* describe 分页查询多个客户端状态变更记录
*
* @param size 当前页数
* @param current 当前页
* @param lazyNettyClientStateRecord 分页查询多个客户端状态变更记录
* @return {@link Result<LazyPage<LazyNettyClientStateRecord>>} 分页客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<LazyPage<LazyNettyClientStateRecord>> findPage(int size,int current,LazyNettyClientStateRecord lazyNettyClientStateRecord);
/**
* describe 删除客户端状态变更记录
*
* @param lazyNettyClientStateRecord 删除客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<LazyNettyClientStateRecord> remove(LazyNettyClientStateRecord lazyNettyClientStateRecord);
/**
* describe 是否存在客户端状态变更记录
*
* @param lazyNettyClientStateRecord 是否存在客户端状态变更记录
* @return {@link Result<Boolean>} 客户端状态变更记录是否存在
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
Result<Boolean> exists(LazyNettyClientStateRecord lazyNettyClientStateRecord);
}

View File

@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.server.visitor; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.server.visitor; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;

View File

@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;

View File

@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow;
import lombok.Data; import lombok.Data;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;

View File

@ -1,6 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow; package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.LazyClientPerDayFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.LazyClientPerDayFlow;
import org.wu.framework.web.response.Result; import org.wu.framework.web.response.Result;
import java.util.List; import java.util.List;

View File

@ -1,7 +1,7 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter; package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist.LazyNettyClientBlacklist; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientBlacklistDO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientBlacklistDO;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;

View File

@ -1,6 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter; package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientState; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientState;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientStateDO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientStateDO;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;

View File

@ -0,0 +1,48 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecord;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientStateRecordDO;
import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureConverter
**/
@Mapper
public interface LazyNettyClientStateRecordConverter {
/**
* describe MapStruct 创建的代理对象
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
LazyNettyClientStateRecordConverter INSTANCE = Mappers.getMapper(LazyNettyClientStateRecordConverter.class);
/**
* describe 实体对象 转换成领域对象
*
* @param lazyNettyClientStateRecordDO 客户端状态变更记录实体对象
* @return {@link LazyNettyClientStateRecord} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
LazyNettyClientStateRecord toLazyNettyClientStateRecord(LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO);
/**
* describe 领域对象 转换成实体对象
*
* @param lazyNettyClientStateRecord 客户端状态变更记录领域对象
* @return {@link LazyNettyClientStateRecordDO} 客户端状态变更记录实体对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
LazyNettyClientStateRecordDO fromLazyNettyClientStateRecord(LazyNettyClientStateRecord lazyNettyClientStateRecord);
}

View File

@ -1,6 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter; package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.server.visitor.LazyNettyServerVisitor; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor.LazyNettyServerVisitor;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyServerVisitorDO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyServerVisitorDO;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;

View File

@ -1,6 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter; package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow.LazyVisitorPortFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow.LazyVisitorPortFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyVisitorPortFlowDO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyVisitorPortFlowDO;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;

View File

@ -1,6 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter; package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyVisitorPortPerDayFlowDO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyVisitorPortPerDayFlowDO;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;

View File

@ -0,0 +1,79 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity;
import lombok.Data;
import lombok.experimental.Accessors;
import org.wu.framework.lazy.orm.core.stereotype.LazyTableIndex;
import org.wu.framework.core.stereotype.LayerField;
import org.wu.framework.core.stereotype.LayerField.LayerFieldType;
import org.wu.framework.lazy.orm.core.stereotype.LazyTable;
import org.wu.framework.lazy.orm.core.stereotype.LazyTableField;
import org.wu.framework.lazy.orm.core.stereotype.*;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.media.Schema;
import java.lang.String;
import java.time.LocalDateTime;
import org.wu.framework.lazy.orm.core.stereotype.LazyTableFieldId;
import java.lang.Long;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity
**/
@Data
@Accessors(chain = true)
@LazyTable(tableName = "lazy_netty_client_state_record",schema = "wu_lazy_cloud_netty_server",comment = "客户端状态变更记录")
@Schema(title = "lazy_netty_client_state_record",description = "客户端状态变更记录")
public class LazyNettyClientStateRecordDO {
/**
*
* 客户端ID
*/
@Schema(description ="客户端ID",name ="clientId",example = "")
@LazyTableField(name="client_id",comment="客户端ID",notNull=true,columnType="varchar(255)")
private String clientId;
/**
*
*
*/
@Schema(description ="",name ="createTime",example = "")
@LazyTableField(name="create_time",comment="",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra="")
private LocalDateTime createTime;
/**
*
* 主键
*/
@Schema(description ="主键",name ="id",example = "")
@LazyTableFieldId(name = "id", comment = "主键")
private Long id;
/**
*
* 在线状态true在线false离线
*/
@Schema(description ="在线状态true在线false离线",name ="onLineState",example = "")
@LazyTableField(name="on_line_state",comment="在线状态true在线false离线",columnType="varchar(255)")
private String onLineState;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
@LazyTableField(name="server_id",comment="服务端ID",notNull=true,columnType="varchar(255)")
private String serverId;
/**
*
* 暂存状态(开启、关闭)
*/
@Schema(description ="暂存状态(开启、关闭)",name ="stagingState",example = "")
@LazyTableField(name="staging_state",comment="暂存状态(开启、关闭)",columnType="varchar(255)")
private String stagingState;
}

View File

@ -0,0 +1,18 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.jpa.lazy;
import org.wu.framework.lazy.orm.database.jpa.repository.LazyJpaRepository;
import org.wu.framework.lazy.orm.database.jpa.repository.annotation.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientStateRecordDO;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureLazyJpa
**/
@LazyRepository
public interface LazyNettyClientStateRecordLazyJpaRepository extends LazyJpaRepository<LazyNettyClientStateRecordDO,Long> {
}

View File

@ -0,0 +1,15 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.mapper;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureMapper
**/
public interface LazyNettyClientStateRecordMapper {
}

View File

@ -1,7 +1,7 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence; package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist.LazyNettyClientBlacklist; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.blacklist.LazyNettyClientBlacklistRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklistRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientBlacklistDO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientBlacklistDO;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.lazy.orm.database.lambda.stream.lambda.LazyLambdaStream; import org.wu.framework.lazy.orm.database.lambda.stream.lambda.LazyLambdaStream;

View File

@ -0,0 +1,152 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientStateRecordDO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter.LazyNettyClientStateRecordConverter;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.mapper.LazyNettyClientStateRecordMapper;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecordRepository;
import org.springframework.stereotype.Repository;
import java.util.stream.Collectors;
import org.wu.framework.lazy.orm.database.lambda.stream.wrapper.LazyWrappers;
import org.wu.framework.web.response.Result;
import org.wu.framework.web.response.ResultFactory;
import jakarta.annotation.Resource;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.record.LazyNettyClientStateRecord;
import org.wu.framework.lazy.orm.database.lambda.stream.lambda.LazyLambdaStream;
import java.util.List;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
/**
* describe 客户端状态变更记录
*
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructurePersistence
**/
@Repository
public class LazyNettyClientStateRecordRepositoryImpl implements LazyNettyClientStateRecordRepository {
@Resource
LazyLambdaStream lazyLambdaStream;
/**
* describe 新增客户端状态变更记录
*
* @param lazyNettyClientStateRecord 新增客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录新增后领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<LazyNettyClientStateRecord> story(LazyNettyClientStateRecord lazyNettyClientStateRecord) {
LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord);
lazyLambdaStream.upsert(lazyNettyClientStateRecordDO);
return ResultFactory.successOf();
}
/**
* describe 批量新增客户端状态变更记录
*
* @param lazyNettyClientStateRecordList 批量新增客户端状态变更记录
* @return {@link Result<List<LazyNettyClientStateRecord>>} 客户端状态变更记录新增后领域对象集合
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<List<LazyNettyClientStateRecord>> batchStory(List<LazyNettyClientStateRecord> lazyNettyClientStateRecordList) {
List<LazyNettyClientStateRecordDO> lazyNettyClientStateRecordDOList = lazyNettyClientStateRecordList.stream().map(LazyNettyClientStateRecordConverter.INSTANCE::fromLazyNettyClientStateRecord).collect(Collectors.toList());
lazyLambdaStream.upsert(lazyNettyClientStateRecordDOList);
return ResultFactory.successOf();
}
/**
* describe 查询单个客户端状态变更记录
*
* @param lazyNettyClientStateRecord 查询单个客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<LazyNettyClientStateRecord> findOne(LazyNettyClientStateRecord lazyNettyClientStateRecord) {
LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord);
LazyNettyClientStateRecord lazyNettyClientStateRecordOne = lazyLambdaStream.selectOne(LazyWrappers.lambdaWrapperBean(lazyNettyClientStateRecordDO), LazyNettyClientStateRecord.class);
return ResultFactory.successOf(lazyNettyClientStateRecordOne);
}
/**
* describe 查询多个客户端状态变更记录
*
* @param lazyNettyClientStateRecord 查询多个客户端状态变更记录
* @return {@link Result<List<LazyNettyClientStateRecord>>} 客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<List<LazyNettyClientStateRecord>> findList(LazyNettyClientStateRecord lazyNettyClientStateRecord) {
LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord);
List<LazyNettyClientStateRecord> lazyNettyClientStateRecordList = lazyLambdaStream.selectList(LazyWrappers.lambdaWrapperBean(lazyNettyClientStateRecordDO), LazyNettyClientStateRecord.class);
return ResultFactory.successOf(lazyNettyClientStateRecordList);
}
/**
* describe 分页查询多个客户端状态变更记录
*
* @param size 当前页数
* @param current 当前页
* @param lazyNettyClientStateRecord 分页查询多个客户端状态变更记录
* @return {@link Result<LazyPage<LazyNettyClientStateRecord>>} 分页客户端状态变更记录领域对象
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<LazyPage<LazyNettyClientStateRecord>> findPage(int size,int current,LazyNettyClientStateRecord lazyNettyClientStateRecord) {
LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord);
LazyPage<LazyNettyClientStateRecord> lazyPage = new LazyPage<>(current,size);
LazyPage<LazyNettyClientStateRecord> lazyNettyClientStateRecordLazyPage = lazyLambdaStream.selectPage(LazyWrappers.lambdaWrapperBean(lazyNettyClientStateRecordDO),lazyPage, LazyNettyClientStateRecord.class);
return ResultFactory.successOf(lazyNettyClientStateRecordLazyPage);
}
/**
* describe 删除客户端状态变更记录
*
* @param lazyNettyClientStateRecord 删除客户端状态变更记录
* @return {@link Result<LazyNettyClientStateRecord>} 客户端状态变更记录
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<LazyNettyClientStateRecord> remove(LazyNettyClientStateRecord lazyNettyClientStateRecord) {
LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord);
// lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(lazyNettyClientStateRecordDO));
return ResultFactory.successOf();
}
/**
* describe 是否存在客户端状态变更记录
*
* @param lazyNettyClientStateRecord 客户端状态变更记录领域对象
* @return {@link Result<Boolean>} 是否存在 true 存在false 不存在
* @author Jia wei Wu
* @date 2024/07/12 04:29 下午
**/
@Override
public Result<Boolean> exists(LazyNettyClientStateRecord lazyNettyClientStateRecord) {
LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord);
Boolean exists=lazyLambdaStream.exists(LazyWrappers.lambdaWrapperBean(lazyNettyClientStateRecordDO));
return ResultFactory.successOf(exists);
}
}

View File

@ -1,8 +1,8 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence; package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientState; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientState;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.client.state.LazyNettyClientStateRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientStateRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientStateDO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientStateDO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter.LazyNettyClientStateConverter; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter.LazyNettyClientStateConverter;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;

View File

@ -1,7 +1,7 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence; package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.server.visitor.LazyNettyServerVisitor; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor.LazyNettyServerVisitor;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.netty.server.visitor.LazyNettyServerVisitorRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor.LazyNettyServerVisitorRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyServerVisitorDO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyServerVisitorDO;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.lazy.orm.database.lambda.stream.lambda.LazyLambdaStream; import org.wu.framework.lazy.orm.database.lambda.stream.lambda.LazyLambdaStream;

View File

@ -1,8 +1,8 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence; package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow.LazyVisitorPortFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow.LazyVisitorPortFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow.LazyVisitorPortFlowRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow.LazyVisitorPortFlowRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyVisitorPortFlowDO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyVisitorPortFlowDO;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.lazy.orm.database.lambda.stream.lambda.LazyLambdaStream; import org.wu.framework.lazy.orm.database.lambda.stream.lambda.LazyLambdaStream;

View File

@ -1,8 +1,8 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence; package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.LazyClientPerDayFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.LazyClientPerDayFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow.LazyVisitorPortPerDayFlow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRepository; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRepository;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyVisitorPortPerDayFlowDO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyVisitorPortPerDayFlowDO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter.LazyVisitorPortPerDayFlowConverter; import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter.LazyVisitorPortPerDayFlowConverter;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;

View File

@ -0,0 +1,14 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.mapper.LazyNettyClientStateRecordMapper">
<resultMap id="BaseResultMap" type="org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientStateRecordDO">
<result column="client_id" property="clientId" />
<result column="create_time" property="createTime" />
<id column="id" property="id" />
<result column="on_line_state" property="onLineState" />
<result column="server_id" property="serverId" />
<result column="staging_state" property="stagingState" />
</resultMap>
</mapper>

View File

@ -1,6 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.server.domain.model.visitor.flow; package org.framework.lazy.cloud.network.heartbeat.server.domain.model.visitor.flow;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.visitor.flow.LazyVisitorPortFlow; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.visitor.flow.LazyVisitorPortFlow;
import org.springframework.util.StopWatch; import org.springframework.util.StopWatch;
import org.wu.framework.core.ReflexUtils; import org.wu.framework.core.ReflexUtils;
import org.wu.framework.core.utils.DataTransformUntil; import org.wu.framework.core.utils.DataTransformUntil;

View File

@ -5,10 +5,11 @@ spring:
inet-host: 127.0.0.1 inet-host: 127.0.0.1
inet-port: 7001 inet-port: 7001
inet-path: wu-lazy-cloud-heartbeat-server inet-path: wu-lazy-cloud-heartbeat-server
client-id: wujiawei # 客户端ID
# inet-host: 124.222.48.62 # 服务端地址 # inet-host: 124.222.48.62 # 服务端地址
# inet-port: 30676 #服务端端口 # inet-port: 30676 #服务端端口
# inet-path: wu-lazy-cloud-heartbeat-server # # inet-path: wu-lazy-cloud-heartbeat-server
client-id: wujiawei # 客户端ID # client-id: shuhan # 客户端ID
# client-id: temp_id # 客户端ID # client-id: temp_id # 客户端ID
data: data:
redis: redis:

View File

@ -23,6 +23,10 @@
<groupId>top.wu2020</groupId> <groupId>top.wu2020</groupId>
<artifactId>wu-lazy-cloud-heartbeat-server</artifactId> <artifactId>wu-lazy-cloud-heartbeat-server</artifactId>
</dependency> </dependency>
<dependency>
<groupId>top.wu2020</groupId>
<artifactId>wu-smart-acw-client</artifactId>
</dependency>
</dependencies> </dependencies>

View File

@ -1,11 +1,11 @@
--- ---
## h2 配置 ## h2 配置
spring: #spring:
datasource: # datasource:
url: jdbc:h2:./wu_lazy_cloud_netty_server:wu_lazy_cloud_netty_server;LOCK_TIMEOUT=10000;DB_CLOSE_ON_EXIT=FALSE;DATABASE_TO_UPPER=true;MODE=MySQL;CASE_INSENSITIVE_IDENTIFIERS=TRUE # url: jdbc:h2:./wu_lazy_cloud_netty_server:wu_lazy_cloud_netty_server;LOCK_TIMEOUT=10000;DB_CLOSE_ON_EXIT=FALSE;DATABASE_TO_UPPER=true;MODE=MySQL;CASE_INSENSITIVE_IDENTIFIERS=TRUE
username: sa # username: sa
driver-class-name: org.h2.Driver # driver-class-name: org.h2.Driver
--- ---
# h2 web # h2 web
spring: spring:
@ -16,9 +16,9 @@ spring:
settings: settings:
web-allow-others: true web-allow-others: true
--- ---
#spring: spring:
# datasource: datasource:
# url: jdbc:mysql://127.0.0.1:3306/wu_lazy_cloud_netty_server?allowMultiQueries=true&useUnicode=true&autoReconnect=true&useAffectedRows=true&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&databaseTerm=SCHEMA url: jdbc:mysql://127.0.0.1:3306/wu_lazy_cloud_netty_server?allowMultiQueries=true&useUnicode=true&autoReconnect=true&useAffectedRows=true&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&databaseTerm=SCHEMA
# username: root username: root
# password: wujiawei password: wujiawei
# driver-class-name: com.mysql.cj.jdbc.Driver driver-class-name: com.mysql.cj.jdbc.Driver