diff --git a/pom.xml b/pom.xml index f354a1ec..9871ef4f 100644 --- a/pom.xml +++ b/pom.xml @@ -169,11 +169,11 @@ 发布的地址<--> - snapshots + oss-snapshots https://oss.sonatype.org/content/repositories/snapshots/ - snapshots + oss-snapshots https://oss.sonatype.org/service/local/staging/deploy/maven2/ diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleClientConnectSuccessTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleClientConnectSuccessTypeAdvanced.java index becc839d..4dfef04b 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleClientConnectSuccessTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleClientConnectSuccessTypeAdvanced.java @@ -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.advanced.server.AbstractHandleClientConnectSuccessTypeAdvanced; 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.util.List; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientBlacklistApplication.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientBlacklistApplication.java index beca57b5..6f46c062 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientBlacklistApplication.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientBlacklistApplication.java @@ -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.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.web.response.Result; 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; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientStateApplication.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientStateApplication.java index cb3c8216..0fa2a1f3 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientStateApplication.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientStateApplication.java @@ -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.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.netty.client.state.LazyNettyClientState; +import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientState; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.web.response.Result; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientStateRecordApplication.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientStateRecordApplication.java new file mode 100644 index 00000000..a61cd4cc --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyClientStateRecordApplication.java @@ -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} 客户端状态变更记录新增后领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result story(LazyNettyClientStateRecordStoryCommand lazyNettyClientStateRecordStoryCommand); + + /** + * describe 批量新增客户端状态变更记录 + * + * @param lazyNettyClientStateRecordStoryCommandList 批量新增客户端状态变更记录 + * @return {@link Result>} 客户端状态变更记录新增后领域对象集合 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result> batchStory(List lazyNettyClientStateRecordStoryCommandList); + + /** + * describe 更新客户端状态变更记录 + * + * @param lazyNettyClientStateRecordUpdateCommand 更新客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result updateOne(LazyNettyClientStateRecordUpdateCommand lazyNettyClientStateRecordUpdateCommand); + + /** + * describe 查询单个客户端状态变更记录 + * + * @param lazyNettyClientStateRecordQueryOneCommand 查询单个客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result findOne(LazyNettyClientStateRecordQueryOneCommand lazyNettyClientStateRecordQueryOneCommand); + + /** + * describe 查询多个客户端状态变更记录 + * + * @param lazyNettyClientStateRecordQueryListCommand 查询多个客户端状态变更记录 + * @return {@link Result >} 客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result > findList(LazyNettyClientStateRecordQueryListCommand lazyNettyClientStateRecordQueryListCommand); + + /** + * describe 分页查询多个客户端状态变更记录 + * + * @param lazyNettyClientStateRecordQueryListCommand 分页查询多个客户端状态变更记录 + * @return {@link Result >} 分页客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result > findPage(int size,int current,LazyNettyClientStateRecordQueryListCommand lazyNettyClientStateRecordQueryListCommand); + + /** + * describe 删除客户端状态变更记录 + * + * @param lazyNettyClientStateRecordRemoveCommand 删除客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result remove(LazyNettyClientStateRecordRemoveCommand lazyNettyClientStateRecordRemoveCommand); + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyServerVisitorApplication.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyServerVisitorApplication.java index 5d774eb7..1f1b7faf 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyServerVisitorApplication.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyNettyServerVisitorApplication.java @@ -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.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; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyVisitorPortFlowApplication.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyVisitorPortFlowApplication.java index a313b54c..24bc1644 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyVisitorPortFlowApplication.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyVisitorPortFlowApplication.java @@ -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.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; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyVisitorPortPerDayFlowApplication.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyVisitorPortPerDayFlowApplication.java index 269e1e11..8cae7f8a 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyVisitorPortPerDayFlowApplication.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/LazyVisitorPortPerDayFlowApplication.java @@ -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.LazyVisitorPortPerDayFlowDTO; 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.LazyVisitorPortPerDayFlowStoryCommand; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowUpdateCommand; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/LazyNettyClientStateRecordDTOAssembler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/LazyNettyClientStateRecordDTOAssembler.java new file mode 100644 index 00000000..dad119cc --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/LazyNettyClientStateRecordDTOAssembler.java @@ -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); +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyClientBlacklistDTOAssembler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyClientBlacklistDTOAssembler.java index 05fa8a04..a39669d8 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyClientBlacklistDTOAssembler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyClientBlacklistDTOAssembler.java @@ -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.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.application.command.netty.client.blacklist.*; +import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist; import org.mapstruct.Mapper; import org.mapstruct.factory.Mappers; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyClientStateDTOAssembler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyClientStateDTOAssembler.java index 8de0082f..1154eca0 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyClientStateDTOAssembler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyClientStateDTOAssembler.java @@ -1,9 +1,8 @@ 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.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.command.netty.client.state.*; import org.mapstruct.Mapper; import org.mapstruct.factory.Mappers; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyServerVisitorDTOAssembler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyServerVisitorDTOAssembler.java index a21a496c..6d76ed7e 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyServerVisitorDTOAssembler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/NettyServerVisitorDTOAssembler.java @@ -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.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.mapstruct.Mapper; import org.mapstruct.factory.Mappers; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/VisitorPortFlowDTOAssembler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/VisitorPortFlowDTOAssembler.java index f3eecf96..6466ee3a 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/VisitorPortFlowDTOAssembler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/VisitorPortFlowDTOAssembler.java @@ -1,7 +1,7 @@ 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.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.dto.LazyVisitorPortFlowDTO; import org.mapstruct.Mapper; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/VisitorPortPerDayFlowDTOAssembler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/VisitorPortPerDayFlowDTOAssembler.java index 678b80f6..0d89157d 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/VisitorPortPerDayFlowDTOAssembler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/assembler/VisitorPortPerDayFlowDTOAssembler.java @@ -1,6 +1,6 @@ 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.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRemoveCommand; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowStoryCommand; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordQueryListCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordQueryListCommand.java new file mode 100644 index 00000000..e138e5ca --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordQueryListCommand.java @@ -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; + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordQueryOneCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordQueryOneCommand.java new file mode 100644 index 00000000..ca9c6931 --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordQueryOneCommand.java @@ -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; + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordRemoveCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordRemoveCommand.java new file mode 100644 index 00000000..787d0360 --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordRemoveCommand.java @@ -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; + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordStoryCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordStoryCommand.java new file mode 100644 index 00000000..f68747cc --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordStoryCommand.java @@ -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; + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordUpdateCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordUpdateCommand.java new file mode 100644 index 00000000..1b719948 --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/state/record/LazyNettyClientStateRecordUpdateCommand.java @@ -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; + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyNettyClientStateRecordDTO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyNettyClientStateRecordDTO.java new file mode 100644 index 00000000..ca5265fe --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyNettyClientStateRecordDTO.java @@ -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; + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java index f01bd10e..670e6081 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java @@ -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.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.netty.client.state.LazyNettyClientStateRepository; +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.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 lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.constant.ClientConfigKeyUtils; import org.framework.lazy.cloud.network.heartbeat.common.enums.NettyClientStatus; +import java.time.LocalDateTime; + @Slf4j @LazyApplication @@ -17,15 +21,26 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan private final LazyNettyClientStateRepository lazyNettyClientStateRepository; private final ServerNodeProperties serverNodeProperties; + + private final LazyNettyClientStateRecordRepository lazyNettyClientStateRecordRepository; public LazyClientStatsChangeApplicationImpl(LazyNettyClientStateRepository lazyNettyClientStateRepository, - ServerNodeProperties serverNodeProperties) { + ServerNodeProperties serverNodeProperties, LazyNettyClientStateRecordRepository lazyNettyClientStateRecordRepository) { this.lazyNettyClientStateRepository = lazyNettyClientStateRepository; 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(); lazyNettyClientState.setServerId(serverId); lazyNettyClientStateRepository.updateOnLIneState(lazyNettyClientState); + // 创建变更记录 + // // 触发暂存扫描 // ClientOnLineState clientOnLineState = new ClientOnLineState(); // clientOnLineState.setClientId(clientId); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientBlacklistApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientBlacklistApplicationImpl.java index 91b2c7cd..1a3a7444 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientBlacklistApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientBlacklistApplicationImpl.java @@ -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.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.domain.model.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.application.command.netty.client.blacklist.*; +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.lazy.netty.client.blacklist.LazyNettyClientBlacklistRepository; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.web.response.Result; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java index 7b4c26c6..47049a6c 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java @@ -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.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.domain.model.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.LazyNettyClientState; +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.command.netty.client.state.*; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.web.response.Result; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateRecordApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateRecordApplicationImpl.java new file mode 100644 index 00000000..e7419bee --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateRecordApplicationImpl.java @@ -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} 客户端状态变更记录新增后领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result story(LazyNettyClientStateRecordStoryCommand lazyNettyClientStateRecordStoryCommand) { + LazyNettyClientStateRecord lazyNettyClientStateRecord = LazyNettyClientStateRecordDTOAssembler.INSTANCE.toLazyNettyClientStateRecord(lazyNettyClientStateRecordStoryCommand); + return lazyNettyClientStateRecordRepository.story(lazyNettyClientStateRecord); + } + /** + * describe 批量新增客户端状态变更记录 + * + * @param lazyNettyClientStateRecordStoryCommandList 批量新增客户端状态变更记录 + * @return {@link Result>} 客户端状态变更记录新增后领域对象集合 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result> batchStory(List lazyNettyClientStateRecordStoryCommandList) { + List lazyNettyClientStateRecordList = lazyNettyClientStateRecordStoryCommandList.stream().map( LazyNettyClientStateRecordDTOAssembler.INSTANCE::toLazyNettyClientStateRecord).collect(Collectors.toList()); + return lazyNettyClientStateRecordRepository.batchStory(lazyNettyClientStateRecordList); + } + /** + * describe 更新客户端状态变更记录 + * + * @param lazyNettyClientStateRecordUpdateCommand 更新客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result updateOne(LazyNettyClientStateRecordUpdateCommand lazyNettyClientStateRecordUpdateCommand) { + LazyNettyClientStateRecord lazyNettyClientStateRecord = LazyNettyClientStateRecordDTOAssembler.INSTANCE.toLazyNettyClientStateRecord(lazyNettyClientStateRecordUpdateCommand); + return lazyNettyClientStateRecordRepository.story(lazyNettyClientStateRecord); + } + + /** + * describe 查询单个客户端状态变更记录 + * + * @param lazyNettyClientStateRecordQueryOneCommand 查询单个客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result findOne(LazyNettyClientStateRecordQueryOneCommand lazyNettyClientStateRecordQueryOneCommand) { + LazyNettyClientStateRecord lazyNettyClientStateRecord = LazyNettyClientStateRecordDTOAssembler.INSTANCE.toLazyNettyClientStateRecord(lazyNettyClientStateRecordQueryOneCommand); + return lazyNettyClientStateRecordRepository.findOne(lazyNettyClientStateRecord).convert(LazyNettyClientStateRecordDTOAssembler.INSTANCE::fromLazyNettyClientStateRecord); + } + + /** + * describe 查询多个客户端状态变更记录 + * + * @param lazyNettyClientStateRecordQueryListCommand 查询多个客户端状态变更记录 + * @return {@link Result>} 客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result> 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>} 分页客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result> 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} 客户端状态变更记录 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result remove(LazyNettyClientStateRecordRemoveCommand lazyNettyClientStateRecordRemoveCommand) { + LazyNettyClientStateRecord lazyNettyClientStateRecord = LazyNettyClientStateRecordDTOAssembler.INSTANCE.toLazyNettyClientStateRecord(lazyNettyClientStateRecordRemoveCommand); + return lazyNettyClientStateRecordRepository.remove(lazyNettyClientStateRecord); + } + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyServerVisitorApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyServerVisitorApplicationImpl.java index 00f6f57b..202e8403 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyServerVisitorApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyServerVisitorApplicationImpl.java @@ -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.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.domain.model.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.application.command.netty.server.visitor.*; +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.lazy.netty.server.visitor.LazyNettyServerVisitorRepository; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.web.response.Result; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyVisitorPortFlowApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyVisitorPortFlowApplicationImpl.java index 757342a3..2ddc7eed 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyVisitorPortFlowApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyVisitorPortFlowApplicationImpl.java @@ -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.dto.LazyVisitorFlowDTO; 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.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.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRepository; +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.lazy.visitor.flow.LazyVisitorPortFlowRepository; +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.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.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyVisitorPortPerDayFlowApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyVisitorPortPerDayFlowApplicationImpl.java index 01224332..cd82a47c 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyVisitorPortPerDayFlowApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyVisitorPortPerDayFlowApplicationImpl.java @@ -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.LazyClientPortFlowPerDayEchartsDTO; 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.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.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRepository; +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.lazy.netty.client.state.LazyNettyClientStateRepository; +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.lazy.visitor.port.per.day.flow.LazyVisitorPortPerDayFlowRepository; import org.wu.framework.core.utils.ObjectUtils; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientBlacklistProvider.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientBlacklistProvider.java index a7445021..590e868d 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientBlacklistProvider.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientBlacklistProvider.java @@ -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.dto.LazyNettyClientBlacklistDTO; 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.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.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; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientStateProvider.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientStateProvider.java index e6d79a16..9ade977c 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientStateProvider.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientStateProvider.java @@ -1,10 +1,9 @@ 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.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.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.web.response.Result; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientStateRecordProvider.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientStateRecordProvider.java new file mode 100644 index 00000000..726f96cb --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyClientStateRecordProvider.java @@ -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} 客户端状态变更记录新增后领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Operation(summary = "新增客户端状态变更记录") + @PostMapping("/story") + public Result story(@RequestBody LazyNettyClientStateRecordStoryCommand lazyNettyClientStateRecordStoryCommand){ + return lazyNettyClientStateRecordApplication.story(lazyNettyClientStateRecordStoryCommand); + } + /** + * describe 批量新增客户端状态变更记录 + * + * @param lazyNettyClientStateRecordStoryCommandList 批量新增客户端状态变更记录 + * @return {@link Result>} 客户端状态变更记录新增后领域对象集合 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Operation(summary = "批量新增客户端状态变更记录") + @PostMapping("/batchStory") + public Result> batchStory(@RequestBody List lazyNettyClientStateRecordStoryCommandList){ + return lazyNettyClientStateRecordApplication.batchStory(lazyNettyClientStateRecordStoryCommandList); + } + /** + * describe 更新客户端状态变更记录 + * + * @param lazyNettyClientStateRecordUpdateCommand 更新客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Operation(summary = "更新客户端状态变更记录") + @PutMapping("/updateOne") + public Result updateOne(@RequestBody LazyNettyClientStateRecordUpdateCommand lazyNettyClientStateRecordUpdateCommand){ + return lazyNettyClientStateRecordApplication.updateOne(lazyNettyClientStateRecordUpdateCommand); + } + /** + * describe 查询单个客户端状态变更记录 + * + * @param lazyNettyClientStateRecordQueryOneCommand 查询单个客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Operation(summary = "查询单个客户端状态变更记录") + @GetMapping("/findOne") + public Result findOne(@ModelAttribute LazyNettyClientStateRecordQueryOneCommand lazyNettyClientStateRecordQueryOneCommand){ + return lazyNettyClientStateRecordApplication.findOne(lazyNettyClientStateRecordQueryOneCommand); + } + /** + * describe 查询多个客户端状态变更记录 + * + * @param lazyNettyClientStateRecordQueryListCommand 查询多个客户端状态变更记录 + * @return {@link Result>} 客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Operation(summary = "查询多个客户端状态变更记录") + @GetMapping("/findList") + public Result> findList(@ModelAttribute LazyNettyClientStateRecordQueryListCommand lazyNettyClientStateRecordQueryListCommand){ + return lazyNettyClientStateRecordApplication.findList(lazyNettyClientStateRecordQueryListCommand); + } + /** + * describe 分页查询多个客户端状态变更记录 + * + * @param lazyNettyClientStateRecordQueryListCommand 分页查询多个客户端状态变更记录 + * @return {@link Result>} 分页客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Operation(summary = "分页查询多个客户端状态变更记录") + @GetMapping("/findPage") + public Result> 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} 客户端状态变更记录 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Operation(summary = "删除客户端状态变更记录") + @DeleteMapping("/remove") + public Result remove(@ModelAttribute LazyNettyClientStateRecordRemoveCommand lazyNettyClientStateRecordRemoveCommand){ + return lazyNettyClientStateRecordApplication.remove(lazyNettyClientStateRecordRemoveCommand); + } +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyServerVisitorProvider.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyServerVisitorProvider.java index 5bb912df..fc660fe4 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyServerVisitorProvider.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyNettyServerVisitorProvider.java @@ -13,7 +13,7 @@ import org.springframework.web.bind.annotation.*; 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.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; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyVisitorPortFlowProvider.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyVisitorPortFlowProvider.java index cb089e49..00e6ca5a 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyVisitorPortFlowProvider.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyVisitorPortFlowProvider.java @@ -14,7 +14,7 @@ import org.springframework.web.bind.annotation.*; 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.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; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/blacklist/LazyNettyClientBlacklist.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/blacklist/LazyNettyClientBlacklist.java similarity index 96% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/blacklist/LazyNettyClientBlacklist.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/blacklist/LazyNettyClientBlacklist.java index 405029a9..6a0b9c3e 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/blacklist/LazyNettyClientBlacklist.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/blacklist/LazyNettyClientBlacklist.java @@ -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 lombok.Data; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/blacklist/LazyNettyClientBlacklistRepository.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/blacklist/LazyNettyClientBlacklistRepository.java similarity index 98% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/blacklist/LazyNettyClientBlacklistRepository.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/blacklist/LazyNettyClientBlacklistRepository.java index 7128d058..c8dbf7f9 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/blacklist/LazyNettyClientBlacklistRepository.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/blacklist/LazyNettyClientBlacklistRepository.java @@ -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.web.response.Result; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/state/LazyNettyClientState.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/LazyNettyClientState.java similarity index 97% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/state/LazyNettyClientState.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/LazyNettyClientState.java index 3ab5e8b4..3ea21ae2 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/state/LazyNettyClientState.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/LazyNettyClientState.java @@ -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 lombok.Data; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/state/LazyNettyClientStateRepository.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/LazyNettyClientStateRepository.java similarity index 98% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/state/LazyNettyClientStateRepository.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/LazyNettyClientStateRepository.java index 86618d4e..3beff72d 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/client/state/LazyNettyClientStateRepository.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/LazyNettyClientStateRepository.java @@ -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.web.response.Result; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/record/LazyNettyClientStateRecord.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/record/LazyNettyClientStateRecord.java new file mode 100644 index 00000000..d951ce6e --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/record/LazyNettyClientStateRecord.java @@ -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; + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/record/LazyNettyClientStateRecordRepository.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/record/LazyNettyClientStateRecordRepository.java new file mode 100644 index 00000000..a4e81209 --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/state/record/LazyNettyClientStateRecordRepository.java @@ -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} 客户端状态变更记录新增后领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result story(LazyNettyClientStateRecord lazyNettyClientStateRecord); + + /** + * describe 批量新增客户端状态变更记录 + * + * @param lazyNettyClientStateRecordList 批量新增客户端状态变更记录 + * @return {@link Result>} 客户端状态变更记录新增后领域对象集合 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result> batchStory(List lazyNettyClientStateRecordList); + + /** + * describe 查询单个客户端状态变更记录 + * + * @param lazyNettyClientStateRecord 查询单个客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result findOne(LazyNettyClientStateRecord lazyNettyClientStateRecord); + + /** + * describe 查询多个客户端状态变更记录 + * + * @param lazyNettyClientStateRecord 查询多个客户端状态变更记录 + * @return {@link Result>} 客户端状态变更记录DTO对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result> findList(LazyNettyClientStateRecord lazyNettyClientStateRecord); + + /** + * describe 分页查询多个客户端状态变更记录 + * + * @param size 当前页数 + * @param current 当前页 + * @param lazyNettyClientStateRecord 分页查询多个客户端状态变更记录 + * @return {@link Result>} 分页客户端状态变更记录领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result> findPage(int size,int current,LazyNettyClientStateRecord lazyNettyClientStateRecord); + + /** + * describe 删除客户端状态变更记录 + * + * @param lazyNettyClientStateRecord 删除客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result remove(LazyNettyClientStateRecord lazyNettyClientStateRecord); + + /** + * describe 是否存在客户端状态变更记录 + * + * @param lazyNettyClientStateRecord 是否存在客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录是否存在 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + Result exists(LazyNettyClientStateRecord lazyNettyClientStateRecord); + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/server/visitor/LazyNettyServerVisitor.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/server/visitor/LazyNettyServerVisitor.java similarity index 97% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/server/visitor/LazyNettyServerVisitor.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/server/visitor/LazyNettyServerVisitor.java index cd3e79b5..3c1d445f 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/server/visitor/LazyNettyServerVisitor.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/server/visitor/LazyNettyServerVisitor.java @@ -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 lombok.Data; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/server/visitor/LazyNettyServerVisitorRepository.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/server/visitor/LazyNettyServerVisitorRepository.java similarity index 98% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/server/visitor/LazyNettyServerVisitorRepository.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/server/visitor/LazyNettyServerVisitorRepository.java index 4766c04c..f1b6db57 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/netty/server/visitor/LazyNettyServerVisitorRepository.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/server/visitor/LazyNettyServerVisitorRepository.java @@ -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.web.response.Result; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/LazyClientPerDayFlow.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/LazyClientPerDayFlow.java similarity index 98% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/LazyClientPerDayFlow.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/LazyClientPerDayFlow.java index e681efa9..867ef529 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/LazyClientPerDayFlow.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/LazyClientPerDayFlow.java @@ -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 lombok.Data; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/flow/LazyVisitorPortFlow.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/flow/LazyVisitorPortFlow.java similarity index 98% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/flow/LazyVisitorPortFlow.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/flow/LazyVisitorPortFlow.java index e18e5458..dfa80ec4 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/flow/LazyVisitorPortFlow.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/flow/LazyVisitorPortFlow.java @@ -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 lombok.Data; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/flow/LazyVisitorPortFlowRepository.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/flow/LazyVisitorPortFlowRepository.java similarity index 99% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/flow/LazyVisitorPortFlowRepository.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/flow/LazyVisitorPortFlowRepository.java index 60c5713e..ed5fe1fe 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/flow/LazyVisitorPortFlowRepository.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/flow/LazyVisitorPortFlowRepository.java @@ -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.web.response.Result; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/port/per/day/flow/LazyVisitorPortPerDayFlow.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/port/per/day/flow/LazyVisitorPortPerDayFlow.java similarity index 97% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/port/per/day/flow/LazyVisitorPortPerDayFlow.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/port/per/day/flow/LazyVisitorPortPerDayFlow.java index 833e4d40..67aabeae 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/port/per/day/flow/LazyVisitorPortPerDayFlow.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/port/per/day/flow/LazyVisitorPortPerDayFlow.java @@ -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.experimental.Accessors; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/port/per/day/flow/LazyVisitorPortPerDayFlowRepository.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/port/per/day/flow/LazyVisitorPortPerDayFlowRepository.java similarity index 97% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/port/per/day/flow/LazyVisitorPortPerDayFlowRepository.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/port/per/day/flow/LazyVisitorPortPerDayFlowRepository.java index 78c28717..0ea9be58 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/visitor/port/per/day/flow/LazyVisitorPortPerDayFlowRepository.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/visitor/port/per/day/flow/LazyVisitorPortPerDayFlowRepository.java @@ -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 java.util.List; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientBlacklistConverter.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientBlacklistConverter.java index f423781c..288aedfe 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientBlacklistConverter.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientBlacklistConverter.java @@ -1,7 +1,7 @@ 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.mapstruct.Mapper; import org.mapstruct.factory.Mappers; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientStateConverter.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientStateConverter.java index d5a57ec5..b9996dbf 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientStateConverter.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientStateConverter.java @@ -1,6 +1,6 @@ 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.mapstruct.Mapper; import org.mapstruct.factory.Mappers; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientStateRecordConverter.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientStateRecordConverter.java new file mode 100644 index 00000000..c5adaced --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyClientStateRecordConverter.java @@ -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); +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyServerVisitorConverter.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyServerVisitorConverter.java index a85c8f66..7ce438d1 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyServerVisitorConverter.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyServerVisitorConverter.java @@ -1,6 +1,6 @@ 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.mapstruct.Mapper; import org.mapstruct.factory.Mappers; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyVisitorPortFlowConverter.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyVisitorPortFlowConverter.java index f34293e5..a53bebca 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyVisitorPortFlowConverter.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyVisitorPortFlowConverter.java @@ -1,6 +1,6 @@ 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.mapstruct.Mapper; import org.mapstruct.factory.Mappers; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyVisitorPortPerDayFlowConverter.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyVisitorPortPerDayFlowConverter.java index 470a0303..bd07e6e9 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyVisitorPortPerDayFlowConverter.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyVisitorPortPerDayFlowConverter.java @@ -1,6 +1,6 @@ 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.mapstruct.factory.Mappers; import org.mapstruct.Mapper; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyClientStateRecordDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyClientStateRecordDO.java new file mode 100644 index 00000000..ff61742b --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyClientStateRecordDO.java @@ -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; + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/jpa/lazy/LazyNettyClientStateRecordLazyJpaRepository.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/jpa/lazy/LazyNettyClientStateRecordLazyJpaRepository.java new file mode 100644 index 00000000..f4c6ee3b --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/jpa/lazy/LazyNettyClientStateRecordLazyJpaRepository.java @@ -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 { + + + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/mapper/LazyNettyClientStateRecordMapper.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/mapper/LazyNettyClientStateRecordMapper.java new file mode 100644 index 00000000..5c4f427a --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/mapper/LazyNettyClientStateRecordMapper.java @@ -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 { + + + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientBlacklistRepositoryImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientBlacklistRepositoryImpl.java index 8b58801b..6502f6af 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientBlacklistRepositoryImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientBlacklistRepositoryImpl.java @@ -1,7 +1,7 @@ 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.netty.client.blacklist.LazyNettyClientBlacklistRepository; +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.lazy.netty.client.blacklist.LazyNettyClientBlacklistRepository; 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.stream.lambda.LazyLambdaStream; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientStateRecordRepositoryImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientStateRecordRepositoryImpl.java new file mode 100644 index 00000000..5f4af8fc --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientStateRecordRepositoryImpl.java @@ -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} 客户端状态变更记录新增后领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result story(LazyNettyClientStateRecord lazyNettyClientStateRecord) { + LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord); + lazyLambdaStream.upsert(lazyNettyClientStateRecordDO); + return ResultFactory.successOf(); + } + + /** + * describe 批量新增客户端状态变更记录 + * + * @param lazyNettyClientStateRecordList 批量新增客户端状态变更记录 + * @return {@link Result>} 客户端状态变更记录新增后领域对象集合 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result> batchStory(List lazyNettyClientStateRecordList) { + List lazyNettyClientStateRecordDOList = lazyNettyClientStateRecordList.stream().map(LazyNettyClientStateRecordConverter.INSTANCE::fromLazyNettyClientStateRecord).collect(Collectors.toList()); + lazyLambdaStream.upsert(lazyNettyClientStateRecordDOList); + return ResultFactory.successOf(); + } + + /** + * describe 查询单个客户端状态变更记录 + * + * @param lazyNettyClientStateRecord 查询单个客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result 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>} 客户端状态变更记录领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result> findList(LazyNettyClientStateRecord lazyNettyClientStateRecord) { + LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord); + List lazyNettyClientStateRecordList = lazyLambdaStream.selectList(LazyWrappers.lambdaWrapperBean(lazyNettyClientStateRecordDO), LazyNettyClientStateRecord.class); + return ResultFactory.successOf(lazyNettyClientStateRecordList); + } + + /** + * describe 分页查询多个客户端状态变更记录 + * + * @param size 当前页数 + * @param current 当前页 + * @param lazyNettyClientStateRecord 分页查询多个客户端状态变更记录 + * @return {@link Result>} 分页客户端状态变更记录领域对象 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result> findPage(int size,int current,LazyNettyClientStateRecord lazyNettyClientStateRecord) { + LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord); + LazyPage lazyPage = new LazyPage<>(current,size); + LazyPage lazyNettyClientStateRecordLazyPage = lazyLambdaStream.selectPage(LazyWrappers.lambdaWrapperBean(lazyNettyClientStateRecordDO),lazyPage, LazyNettyClientStateRecord.class); + return ResultFactory.successOf(lazyNettyClientStateRecordLazyPage); + } + + /** + * describe 删除客户端状态变更记录 + * + * @param lazyNettyClientStateRecord 删除客户端状态变更记录 + * @return {@link Result} 客户端状态变更记录 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result remove(LazyNettyClientStateRecord lazyNettyClientStateRecord) { + LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord); + // lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(lazyNettyClientStateRecordDO)); + return ResultFactory.successOf(); + } + + /** + * describe 是否存在客户端状态变更记录 + * + * @param lazyNettyClientStateRecord 客户端状态变更记录领域对象 + * @return {@link Result} 是否存在 true 存在，false 不存在 + + * @author Jia wei Wu + * @date 2024/07/12 04:29 下午 + **/ + + @Override + public Result exists(LazyNettyClientStateRecord lazyNettyClientStateRecord) { + LazyNettyClientStateRecordDO lazyNettyClientStateRecordDO = LazyNettyClientStateRecordConverter.INSTANCE.fromLazyNettyClientStateRecord(lazyNettyClientStateRecord); + Boolean exists=lazyLambdaStream.exists(LazyWrappers.lambdaWrapperBean(lazyNettyClientStateRecordDO)); + return ResultFactory.successOf(exists); + } + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientStateRepositoryImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientStateRepositoryImpl.java index dd69f11b..3fb5c464 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientStateRepositoryImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyClientStateRepositoryImpl.java @@ -1,8 +1,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.persistence; 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.netty.client.state.LazyNettyClientStateRepository; +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.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.converter.LazyNettyClientStateConverter; import org.springframework.stereotype.Repository; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyServerVisitorRepositoryImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyServerVisitorRepositoryImpl.java index fba385c2..5d5916f6 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyServerVisitorRepositoryImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyServerVisitorRepositoryImpl.java @@ -1,7 +1,7 @@ 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.netty.server.visitor.LazyNettyServerVisitorRepository; +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.lazy.netty.server.visitor.LazyNettyServerVisitorRepository; 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.stream.lambda.LazyLambdaStream; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyVisitorPortFlowRepositoryImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyVisitorPortFlowRepositoryImpl.java index aaa96f51..753da409 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyVisitorPortFlowRepositoryImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyVisitorPortFlowRepositoryImpl.java @@ -1,8 +1,8 @@ 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.visitor.flow.LazyVisitorPortFlowRepository; +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.lazy.visitor.flow.LazyVisitorPortFlowRepository; 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.stream.lambda.LazyLambdaStream; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyVisitorPortPerDayFlowRepositoryImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyVisitorPortPerDayFlowRepositoryImpl.java index ccaa0ffe..71dca102 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyVisitorPortPerDayFlowRepositoryImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyVisitorPortPerDayFlowRepositoryImpl.java @@ -1,8 +1,8 @@ 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.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.LazyClientPerDayFlow; +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.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.converter.LazyVisitorPortPerDayFlowConverter; import org.springframework.stereotype.Repository; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/xml/LazyNettyClientStateRecordMapper.xml b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/xml/LazyNettyClientStateRecordMapper.xml new file mode 100644 index 00000000..1a1b6b5f --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/xml/LazyNettyClientStateRecordMapper.xml @@ -0,0 +1,14 @@ + + + + + + + + + + + + + + \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/test/java/org/framework/lazy/cloud/network/heartbeat/server/domain/model/visitor/flow/VisitorPortFlowTest.java b/wu-lazy-cloud-heartbeat-server/src/test/java/org/framework/lazy/cloud/network/heartbeat/server/domain/model/visitor/flow/VisitorPortFlowTest.java index 6e0533a9..bc81faff 100644 --- a/wu-lazy-cloud-heartbeat-server/src/test/java/org/framework/lazy/cloud/network/heartbeat/server/domain/model/visitor/flow/VisitorPortFlowTest.java +++ b/wu-lazy-cloud-heartbeat-server/src/test/java/org/framework/lazy/cloud/network/heartbeat/server/domain/model/visitor/flow/VisitorPortFlowTest.java @@ -1,6 +1,6 @@ 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.wu.framework.core.ReflexUtils; import org.wu.framework.core.utils.DataTransformUntil; diff --git a/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-client-start/src/main/resources/application-dev.yml b/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-client-start/src/main/resources/application-dev.yml index 65a3a7cf..a9259848 100644 --- a/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-client-start/src/main/resources/application-dev.yml +++ b/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-client-start/src/main/resources/application-dev.yml @@ -5,10 +5,11 @@ spring: inet-host: 127.0.0.1 inet-port: 7001 inet-path: wu-lazy-cloud-heartbeat-server + client-id: wujiawei # 客户端ID # inet-host: 124.222.48.62 # 服务端地址 # inet-port: 30676 #服务端端口 - # inet-path: wu-lazy-cloud-heartbeat-server - client-id: wujiawei # 客户端ID +# # inet-path: wu-lazy-cloud-heartbeat-server +# client-id: shuhan # 客户端ID # client-id: temp_id # 客户端ID data: redis: diff --git a/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-server-start/pom.xml b/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-server-start/pom.xml index 32bb6995..66b9c231 100644 --- a/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-server-start/pom.xml +++ b/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-server-start/pom.xml @@ -23,6 +23,10 @@ top.wu2020 wu-lazy-cloud-heartbeat-server + + top.wu2020 + wu-smart-acw-client + diff --git a/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-server-start/src/main/resources/application-dev.yml b/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-server-start/src/main/resources/application-dev.yml index 20bf61d3..23756a57 100644 --- a/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-server-start/src/main/resources/application-dev.yml +++ b/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-server-start/src/main/resources/application-dev.yml @@ -1,11 +1,11 @@ --- ## h2 配置 -spring: - 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 - username: sa - driver-class-name: org.h2.Driver +#spring: +# 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 +# username: sa +# driver-class-name: org.h2.Driver --- # h2 web spring: @@ -16,9 +16,9 @@ spring: settings: web-allow-others: true --- -#spring: -# 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 -# username: root -# password: wujiawei -# driver-class-name: com.mysql.cj.jdbc.Driver \ No newline at end of file +spring: + 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 + username: root + password: wujiawei + driver-class-name: com.mysql.cj.jdbc.Driver \ No newline at end of file