alsace/wu-lazy-cloud-network
1
0
Fork 0
mirror of https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git synced 2026-02-04 15:05:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

[fix] 支持页面话操作网络代理

Browse Source
This commit is contained in:
wujiawei
2024-01-16 15:07:03 +08:00
parent a3a16394ef
commit 6980426dc0
106 changed files with 1754 additions and 16664 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
wu-lazy-cloud-heartbeat-server/pom.xml
View File

@@ -25,7 +25,7 @@
</dependency>
<!-- 通用心跳包 -->
<dependency>
<groupId>top.wu2020</groupId>
<groupId>top.wu2020</groupId>
<artifactId>wu-lazy-cloud-heartbeat-common</artifactId>
<version>1.2.2-JDK17-SNAPSHOT</version>
</dependency>
@@ -43,9 +43,15 @@
<groupId>top.wu2020</groupId>
<artifactId>wu-database-lazy-plus-starter</artifactId>
</dependency>
<!-- 授权平台 -->
<dependency>
<groupId>top.wu2020</groupId>
<artifactId>wu-authorization-server-starter</artifactId>
<artifactId>wu-authorization-server-platform-starter</artifactId>
</dependency>
<!-- jvm -->
<dependency>
<groupId>top.wu2020</groupId>
<artifactId>wu-jvm-server-platform-starter</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>

109
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/NettyServerVisitorApplication.java Normal file
View File

@@ -0,0 +1,109 @@
package wu.framework.lazy.cloud.heartbeat.server.application;
import com.wu.framework.response.Result;
import com.wu.framework.response.ResultFactory;
import wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor.NettyServerVisitor;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorRemoveCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorStoryCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorUpdateCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorQueryListCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorQueryOneCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyServerVisitorDTO;
import java.util.List;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication
**/
public interface NettyServerVisitorApplication {
/**
* describe 新增服务端提前开放出来的端口
*
* @param nettyServerVisitorStoryCommand 新增服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口新增后领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<NettyServerVisitor> story(NettyServerVisitorStoryCommand nettyServerVisitorStoryCommand);
/**
* describe 批量新增服务端提前开放出来的端口
*
* @param nettyServerVisitorStoryCommandList 批量新增服务端提前开放出来的端口
* @return {@link Result<List<NettyServerVisitor>>} 服务端提前开放出来的端口新增后领域对象集合
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<List<NettyServerVisitor>> batchStory(List<NettyServerVisitorStoryCommand> nettyServerVisitorStoryCommandList);
/**
* describe 更新服务端提前开放出来的端口
*
* @param nettyServerVisitorUpdateCommand 更新服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<NettyServerVisitor> updateOne(NettyServerVisitorUpdateCommand nettyServerVisitorUpdateCommand);
/**
* describe 查询单个服务端提前开放出来的端口
*
* @param nettyServerVisitorQueryOneCommand 查询单个服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitorDTO>} 服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<NettyServerVisitorDTO> findOne(NettyServerVisitorQueryOneCommand nettyServerVisitorQueryOneCommand);
/**
* describe 查询多个服务端提前开放出来的端口
*
* @param nettyServerVisitorQueryListCommand 查询多个服务端提前开放出来的端口
* @return {@link Result <List<NettyServerVisitorDTO>>} 服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result <List<NettyServerVisitorDTO>> findList(NettyServerVisitorQueryListCommand nettyServerVisitorQueryListCommand);
/**
* describe 分页查询多个服务端提前开放出来的端口
*
* @param nettyServerVisitorQueryListCommand 分页查询多个服务端提前开放出来的端口
* @return {@link Result <LazyPage<NettyServerVisitorDTO>>} 分页服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result <LazyPage<NettyServerVisitorDTO>> findPage(int size,int current,NettyServerVisitorQueryListCommand nettyServerVisitorQueryListCommand);
/**
* describe 删除服务端提前开放出来的端口
*
* @param nettyServerVisitorRemoveCommand 删除服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<NettyServerVisitor> remove(NettyServerVisitorRemoveCommand nettyServerVisitorRemoveCommand);
}

93
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/assembler/NettyServerVisitorDTOAssembler.java Normal file
View File

@@ -0,0 +1,93 @@
package wu.framework.lazy.cloud.heartbeat.server.application.assembler;
import wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor.NettyServerVisitor;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorRemoveCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorStoryCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorUpdateCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorQueryListCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorQueryOneCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyServerVisitorDTO;
import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler
**/
@Mapper
public interface NettyServerVisitorDTOAssembler {
/**
* describe MapStruct 创建的代理对象
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
NettyServerVisitorDTOAssembler INSTANCE = Mappers.getMapper(NettyServerVisitorDTOAssembler.class);
/**
* describe 应用层存储入参转换成 领域对象
*
* @param nettyServerVisitorStoryCommand 保存服务端提前开放出来的端口对象
* @return {@link NettyServerVisitor} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
NettyServerVisitor toNettyServerVisitor(NettyServerVisitorStoryCommand nettyServerVisitorStoryCommand);
/**
* describe 应用层更新入参转换成 领域对象
*
* @param nettyServerVisitorUpdateCommand 更新服务端提前开放出来的端口对象
* @return {@link NettyServerVisitor} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
NettyServerVisitor toNettyServerVisitor(NettyServerVisitorUpdateCommand nettyServerVisitorUpdateCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param nettyServerVisitorQueryOneCommand 查询单个服务端提前开放出来的端口对象参数
* @return {@link NettyServerVisitor} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
NettyServerVisitor toNettyServerVisitor(NettyServerVisitorQueryOneCommand nettyServerVisitorQueryOneCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param nettyServerVisitorQueryListCommand 查询集合服务端提前开放出来的端口对象参数
* @return {@link NettyServerVisitor} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
NettyServerVisitor toNettyServerVisitor(NettyServerVisitorQueryListCommand nettyServerVisitorQueryListCommand);
/**
* describe 应用层删除入参转换成 领域对象
*
* @param nettyServerVisitorRemoveCommand 删除服务端提前开放出来的端口对象参数
* @return {@link NettyServerVisitor} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
NettyServerVisitor toNettyServerVisitor(NettyServerVisitorRemoveCommand nettyServerVisitorRemoveCommand);
/**
* describe 持久层领域对象转换成DTO对象
*
* @param nettyServerVisitor 服务端提前开放出来的端口领域对象
* @return {@link NettyServerVisitorDTO} 服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
NettyServerVisitorDTO fromNettyServerVisitor(NettyServerVisitor nettyServerVisitor);
}

6
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/command/netty/client/state/NettyClientStateQueryListCommand.java
View File

@@ -67,5 +67,11 @@ public class NettyClientStateQueryListCommand {
*/
@Schema(description ="修改时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
}

6
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/command/netty/client/state/NettyClientStateQueryOneCommand.java
View File

@@ -68,4 +68,10 @@ public class NettyClientStateQueryOneCommand {
@Schema(description ="修改时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
}

6
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/command/netty/client/state/NettyClientStateStoryCommand.java
View File

@@ -67,5 +67,11 @@ public class NettyClientStateStoryCommand {
*/
@Schema(description ="修改时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
}

6
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/command/netty/client/state/NettyClientStateUpdateCommand.java
View File

@@ -67,5 +67,11 @@ public class NettyClientStateUpdateCommand {
*/
@Schema(description ="修改时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
}

66
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/command/netty/server/visitor/NettyServerVisitorQueryListCommand.java Normal file
View File

@@ -0,0 +1,66 @@
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.time.LocalDateTime;
import java.lang.String;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyQueryListCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "netty_server_visitor_query_List_command",description = "服务端提前开放出来的端口")
public class NettyServerVisitorQueryListCommand {
/**
*
* 创建时间
*/
@Schema(description ="创建时间",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
/**
*
* 用户ID
*/
@Schema(description ="用户ID",name ="id",example = "")
private Long id;
/**
*
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted;
/**
*
* 更新时间
*/
@Schema(description ="更新时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 访客端口
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
private Integer visitorPort;
}

66
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/command/netty/server/visitor/NettyServerVisitorQueryOneCommand.java Normal file
View File

@@ -0,0 +1,66 @@
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.time.LocalDateTime;
import java.lang.String;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyQueryOneCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "netty_server_visitor_query_one_command",description = "服务端提前开放出来的端口")
public class NettyServerVisitorQueryOneCommand {
/**
*
* 创建时间
*/
@Schema(description ="创建时间",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
/**
*
* 用户ID
*/
@Schema(description ="用户ID",name ="id",example = "")
private Long id;
/**
*
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted;
/**
*
* 更新时间
*/
@Schema(description ="更新时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 访客端口
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
private Integer visitorPort;
}

66
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/command/netty/server/visitor/NettyServerVisitorRemoveCommand.java Normal file
View File

@@ -0,0 +1,66 @@
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.time.LocalDateTime;
import java.lang.String;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyRemoveCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "netty_server_visitor_remove_command",description = "服务端提前开放出来的端口")
public class NettyServerVisitorRemoveCommand {
/**
*
* 创建时间
*/
@Schema(description ="创建时间",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
/**
*
* 用户ID
*/
@Schema(description ="用户ID",name ="id",example = "")
private Long id;
/**
*
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted;
/**
*
* 更新时间
*/
@Schema(description ="更新时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 访客端口
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
private Integer visitorPort;
}

66
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/command/netty/server/visitor/NettyServerVisitorStoryCommand.java Normal file
View File

@@ -0,0 +1,66 @@
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.time.LocalDateTime;
import java.lang.String;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyStoryCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "netty_server_visitor_story_command",description = "服务端提前开放出来的端口")
public class NettyServerVisitorStoryCommand {
/**
*
* 创建时间
*/
@Schema(description ="创建时间",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
/**
*
* 用户ID
*/
@Schema(description ="用户ID",name ="id",example = "")
private Long id;
/**
*
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted;
/**
*
* 更新时间
*/
@Schema(description ="更新时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 访客端口
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
private Integer visitorPort;
}

66
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/command/netty/server/visitor/NettyServerVisitorUpdateCommand.java Normal file
View File

@@ -0,0 +1,66 @@
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.time.LocalDateTime;
import java.lang.String;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyUpdateCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "netty_server_visitor_update_command",description = "服务端提前开放出来的端口")
public class NettyServerVisitorUpdateCommand {
/**
*
* 创建时间
*/
@Schema(description ="创建时间",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
/**
*
* 用户ID
*/
@Schema(description ="用户ID",name ="id",example = "")
private Long id;
/**
*
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted;
/**
*
* 更新时间
*/
@Schema(description ="更新时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 访客端口
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
private Integer visitorPort;
}

3
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/dto/InternalNetworkPenetrationMappingDTO.java
View File

@@ -1,5 +1,6 @@
package wu.framework.lazy.cloud.heartbeat.server.application.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import lombok.experimental.Accessors;
@@ -43,6 +44,7 @@ public class InternalNetworkPenetrationMappingDTO {
*
* 创建时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
@Schema(description ="创建时间",name ="createTime",example = "")
private LocalDateTime createTime;
@@ -64,6 +66,7 @@ public class InternalNetworkPenetrationMappingDTO {
*
* 修改时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
@Schema(description ="修改时间",name ="updateTime",example = "")
private LocalDateTime updateTime;

7
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/dto/NettyClientStateDTO.java
View File

@@ -68,4 +68,11 @@ public class NettyClientStateDTO {
@Schema(description ="修改时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
}

66
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/dto/NettyServerVisitorDTO.java Normal file
View File

@@ -0,0 +1,66 @@
package wu.framework.lazy.cloud.heartbeat.server.application.dto;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.time.LocalDateTime;
import java.lang.String;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyDTO
**/
@Data
@Accessors(chain = true)
@Schema(title = "netty_server_visitor_command_dto",description = "服务端提前开放出来的端口")
public class NettyServerVisitorDTO {
/**
*
* 创建时间
*/
@Schema(description ="创建时间",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
/**
*
* 用户ID
*/
@Schema(description ="用户ID",name ="id",example = "")
private Long id;
/**
*
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted;
/**
*
* 更新时间
*/
@Schema(description ="更新时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 访客端口
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
private Integer visitorPort;
}

8
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/impl/NettyClientStateApplicationImpl.java
View File

@@ -2,6 +2,8 @@ package wu.framework.lazy.cloud.heartbeat.server.application.impl;
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
import wu.framework.lazy.cloud.heartbeat.common.NettyVisitorContext;
import wu.framework.lazy.cloud.heartbeat.server.application.NettyClientStateApplication;
import wu.framework.lazy.cloud.heartbeat.server.application.assembler.NettyClientStateDTOAssembler;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state.NettyClientStateStoryCommand;
@@ -135,7 +137,11 @@ public class NettyClientStateApplicationImpl implements NettyClientStateApplicat
@Override
public Result<NettyClientState> remove(NettyClientStateRemoveCommand nettyClientStateRemoveCommand) {
NettyClientState nettyClientState = NettyClientStateDTOAssembler.INSTANCE.toNettyClientState(nettyClientStateRemoveCommand);
return nettyClientStateRepository.remove(nettyClientState);
// 获取当前客户端通道 而后关闭
String clientId = nettyClientStateRemoveCommand.getClientId();
// 心跳关闭
ChannelContext.clear(clientId);
return nettyClientStateRepository.remove(nettyClientState);
}
}

144
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/application/impl/NettyServerVisitorApplicationImpl.java Normal file
View File

@@ -0,0 +1,144 @@
package wu.framework.lazy.cloud.heartbeat.server.application.impl;
import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
import wu.framework.lazy.cloud.heartbeat.server.application.NettyServerVisitorApplication;
import org.springframework.web.bind.annotation.*;
import com.wu.framework.response.Result;
import com.wu.framework.response.ResultFactory;
import org.springframework.beans.factory.annotation.Autowired;
import wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor.NettyServerVisitor;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorRemoveCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorStoryCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorUpdateCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorQueryListCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorQueryOneCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.assembler.NettyServerVisitorDTOAssembler;
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyServerVisitorDTO;
import java.util.stream.Collectors;
import jakarta.annotation.Resource;
import wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor.NettyServerVisitorRepository;
import java.util.List;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyApplicationImpl
**/
@LazyApplication
public class NettyServerVisitorApplicationImpl implements NettyServerVisitorApplication {
@Resource
NettyServerVisitorRepository nettyServerVisitorRepository;
/**
* describe 新增服务端提前开放出来的端口
*
* @param nettyServerVisitorStoryCommand 新增服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口新增后领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<NettyServerVisitor> story(NettyServerVisitorStoryCommand nettyServerVisitorStoryCommand) {
NettyServerVisitor nettyServerVisitor = NettyServerVisitorDTOAssembler.INSTANCE.toNettyServerVisitor(nettyServerVisitorStoryCommand);
return nettyServerVisitorRepository.story(nettyServerVisitor);
}
/**
* describe 批量新增服务端提前开放出来的端口
*
* @param nettyServerVisitorStoryCommandList 批量新增服务端提前开放出来的端口
* @return {@link Result<List<NettyServerVisitor>>} 服务端提前开放出来的端口新增后领域对象集合
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<List<NettyServerVisitor>> batchStory(List<NettyServerVisitorStoryCommand> nettyServerVisitorStoryCommandList) {
List<NettyServerVisitor> nettyServerVisitorList = nettyServerVisitorStoryCommandList.stream().map( NettyServerVisitorDTOAssembler.INSTANCE::toNettyServerVisitor).collect(Collectors.toList());
return nettyServerVisitorRepository.batchStory(nettyServerVisitorList);
}
/**
* describe 更新服务端提前开放出来的端口
*
* @param nettyServerVisitorUpdateCommand 更新服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<NettyServerVisitor> updateOne(NettyServerVisitorUpdateCommand nettyServerVisitorUpdateCommand) {
NettyServerVisitor nettyServerVisitor = NettyServerVisitorDTOAssembler.INSTANCE.toNettyServerVisitor(nettyServerVisitorUpdateCommand);
return nettyServerVisitorRepository.story(nettyServerVisitor);
}
/**
* describe 查询单个服务端提前开放出来的端口
*
* @param nettyServerVisitorQueryOneCommand 查询单个服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitorDTO>} 服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<NettyServerVisitorDTO> findOne(NettyServerVisitorQueryOneCommand nettyServerVisitorQueryOneCommand) {
NettyServerVisitor nettyServerVisitor = NettyServerVisitorDTOAssembler.INSTANCE.toNettyServerVisitor(nettyServerVisitorQueryOneCommand);
return nettyServerVisitorRepository.findOne(nettyServerVisitor).convert(NettyServerVisitorDTOAssembler.INSTANCE::fromNettyServerVisitor);
}
/**
* describe 查询多个服务端提前开放出来的端口
*
* @param nettyServerVisitorQueryListCommand 查询多个服务端提前开放出来的端口
* @return {@link Result<List<NettyServerVisitorDTO>>} 服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<List<NettyServerVisitorDTO>> findList(NettyServerVisitorQueryListCommand nettyServerVisitorQueryListCommand) {
NettyServerVisitor nettyServerVisitor = NettyServerVisitorDTOAssembler.INSTANCE.toNettyServerVisitor(nettyServerVisitorQueryListCommand);
return nettyServerVisitorRepository.findList(nettyServerVisitor) .convert(nettyServerVisitors -> nettyServerVisitors.stream().map(NettyServerVisitorDTOAssembler.INSTANCE::fromNettyServerVisitor).collect(Collectors.toList())) ;
}
/**
* describe 分页查询多个服务端提前开放出来的端口
*
* @param nettyServerVisitorQueryListCommand 分页查询多个服务端提前开放出来的端口
* @return {@link Result<LazyPage<NettyServerVisitorDTO>>} 分页服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<LazyPage<NettyServerVisitorDTO>> findPage(int size,int current,NettyServerVisitorQueryListCommand nettyServerVisitorQueryListCommand) {
NettyServerVisitor nettyServerVisitor = NettyServerVisitorDTOAssembler.INSTANCE.toNettyServerVisitor(nettyServerVisitorQueryListCommand);
return nettyServerVisitorRepository.findPage(size,current,nettyServerVisitor) .convert(page -> page.convert(NettyServerVisitorDTOAssembler.INSTANCE::fromNettyServerVisitor)) ;
}
/**
* describe 删除服务端提前开放出来的端口
*
* @param nettyServerVisitorRemoveCommand 删除服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<NettyServerVisitor> remove(NettyServerVisitorRemoveCommand nettyServerVisitorRemoveCommand) {
NettyServerVisitor nettyServerVisitor = NettyServerVisitorDTOAssembler.INSTANCE.toNettyServerVisitor(nettyServerVisitorRemoveCommand);
return nettyServerVisitorRepository.remove(nettyServerVisitor);
}
}

142
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/controller/NettyServerVisitorProvider.java Normal file
View File

@@ -0,0 +1,142 @@
package wu.framework.lazy.cloud.heartbeat.server.controller;
import io.swagger.v3.oas.annotations.tags.Tag;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import com.wu.framework.inner.layer.web.EasyController;
import org.springframework.web.bind.annotation.*;
import com.wu.framework.response.Result;
import com.wu.framework.response.ResultFactory;
import org.springframework.beans.factory.annotation.Autowired;
import jakarta.annotation.Resource;
import wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor.NettyServerVisitor;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorRemoveCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorStoryCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorUpdateCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorQueryListCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.server.visitor.NettyServerVisitorQueryOneCommand;
import wu.framework.lazy.cloud.heartbeat.server.application.NettyServerVisitorApplication;
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyServerVisitorDTO;
import java.util.List;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyController
**/
@Tag(name = "服务端提前开放出来的端口提供者")
@EasyController("/netty/server/visitor")
public class NettyServerVisitorProvider {
@Resource
private NettyServerVisitorApplication nettyServerVisitorApplication;
/**
* describe 新增服务端提前开放出来的端口
*
* @param nettyServerVisitorStoryCommand 新增服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口新增后领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Operation(summary = "新增服务端提前开放出来的端口")
@PostMapping("/story")
public Result<NettyServerVisitor> story(@RequestBody NettyServerVisitorStoryCommand nettyServerVisitorStoryCommand){
return nettyServerVisitorApplication.story(nettyServerVisitorStoryCommand);
}
/**
* describe 批量新增服务端提前开放出来的端口
*
* @param nettyServerVisitorStoryCommandList 批量新增服务端提前开放出来的端口
* @return {@link Result<List<NettyServerVisitor>>} 服务端提前开放出来的端口新增后领域对象集合
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Operation(summary = "批量新增服务端提前开放出来的端口")
@PostMapping("/batchStory")
public Result<List<NettyServerVisitor>> batchStory(@RequestBody List<NettyServerVisitorStoryCommand> nettyServerVisitorStoryCommandList){
return nettyServerVisitorApplication.batchStory(nettyServerVisitorStoryCommandList);
}
/**
* describe 更新服务端提前开放出来的端口
*
* @param nettyServerVisitorUpdateCommand 更新服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Operation(summary = "更新服务端提前开放出来的端口")
@PutMapping("/updateOne")
public Result<NettyServerVisitor> updateOne(@RequestBody NettyServerVisitorUpdateCommand nettyServerVisitorUpdateCommand){
return nettyServerVisitorApplication.updateOne(nettyServerVisitorUpdateCommand);
}
/**
* describe 查询单个服务端提前开放出来的端口
*
* @param nettyServerVisitorQueryOneCommand 查询单个服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitorDTO>} 服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Operation(summary = "查询单个服务端提前开放出来的端口")
@GetMapping("/findOne")
public Result<NettyServerVisitorDTO> findOne(@ModelAttribute NettyServerVisitorQueryOneCommand nettyServerVisitorQueryOneCommand){
return nettyServerVisitorApplication.findOne(nettyServerVisitorQueryOneCommand);
}
/**
* describe 查询多个服务端提前开放出来的端口
*
* @param nettyServerVisitorQueryListCommand 查询多个服务端提前开放出来的端口
* @return {@link Result<List<NettyServerVisitorDTO>>} 服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Operation(summary = "查询多个服务端提前开放出来的端口")
@GetMapping("/findList")
public Result<List<NettyServerVisitorDTO>> findList(@ModelAttribute NettyServerVisitorQueryListCommand nettyServerVisitorQueryListCommand){
return nettyServerVisitorApplication.findList(nettyServerVisitorQueryListCommand);
}
/**
* describe 分页查询多个服务端提前开放出来的端口
*
* @param nettyServerVisitorQueryListCommand 分页查询多个服务端提前开放出来的端口
* @return {@link Result<LazyPage<NettyServerVisitorDTO>>} 分页服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Operation(summary = "分页查询多个服务端提前开放出来的端口")
@GetMapping("/findPage")
public Result<LazyPage<NettyServerVisitorDTO>> findPage(@Parameter(description ="分页大小") @RequestParam(defaultValue = "10", value = "size") int size,
@Parameter(description ="当前页数") @RequestParam(defaultValue = "1", value = "current") int current,@ModelAttribute NettyServerVisitorQueryListCommand nettyServerVisitorQueryListCommand){
return nettyServerVisitorApplication.findPage(size,current,nettyServerVisitorQueryListCommand);
}
/**
* describe 删除服务端提前开放出来的端口
*
* @param nettyServerVisitorRemoveCommand 删除服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Operation(summary = "删除服务端提前开放出来的端口")
@DeleteMapping("/remove")
public Result<NettyServerVisitor> remove(@ModelAttribute NettyServerVisitorRemoveCommand nettyServerVisitorRemoveCommand){
return nettyServerVisitorApplication.remove(nettyServerVisitorRemoveCommand);
}
}

66
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/domain/model/netty/server/visitor/NettyServerVisitor.java Normal file
View File

@@ -0,0 +1,66 @@
package wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor;
import lombok.Data;
import lombok.experimental.Accessors;
import io.swagger.v3.oas.annotations.media.Schema;
import java.time.LocalDateTime;
import java.lang.String;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyDomain
**/
@Data
@Accessors(chain = true)
@Schema(title = "netty_server_visitor",description = "服务端提前开放出来的端口")
public class NettyServerVisitor {
/**
*
* 创建时间
*/
@Schema(description ="创建时间",name ="createTime",example = "")
private LocalDateTime createTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
/**
*
* 用户ID
*/
@Schema(description ="用户ID",name ="id",example = "")
private Long id;
/**
*
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted;
/**
*
* 更新时间
*/
@Schema(description ="更新时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 访客端口
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
private Integer visitorPort;
}

106
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/domain/model/netty/server/visitor/NettyServerVisitorRepository.java Normal file
View File

@@ -0,0 +1,106 @@
package wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor;
import com.wu.framework.response.Result;
import com.wu.framework.response.ResultFactory;
import org.springframework.beans.factory.annotation.Autowired;
import wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor.NettyServerVisitor;
import java.util.List;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyDomainRepository
**/
public interface NettyServerVisitorRepository {
/**
* describe 新增服务端提前开放出来的端口
*
* @param nettyServerVisitor 新增服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口新增后领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<NettyServerVisitor> story(NettyServerVisitor nettyServerVisitor);
/**
* describe 批量新增服务端提前开放出来的端口
*
* @param nettyServerVisitorList 批量新增服务端提前开放出来的端口
* @return {@link Result<List<NettyServerVisitor>>} 服务端提前开放出来的端口新增后领域对象集合
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<List<NettyServerVisitor>> batchStory(List<NettyServerVisitor> nettyServerVisitorList);
/**
* describe 查询单个服务端提前开放出来的端口
*
* @param nettyServerVisitor 查询单个服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<NettyServerVisitor> findOne(NettyServerVisitor nettyServerVisitor);
/**
* describe 查询多个服务端提前开放出来的端口
*
* @param nettyServerVisitor 查询多个服务端提前开放出来的端口
* @return {@link Result<List<NettyServerVisitor>>} 服务端提前开放出来的端口DTO对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<List<NettyServerVisitor>> findList(NettyServerVisitor nettyServerVisitor);
/**
* describe 分页查询多个服务端提前开放出来的端口
*
* @param size 当前页数
* @param current 当前页
* @param nettyServerVisitor 分页查询多个服务端提前开放出来的端口
* @return {@link Result<LazyPage<NettyServerVisitor>>} 分页服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<LazyPage<NettyServerVisitor>> findPage(int size,int current,NettyServerVisitor nettyServerVisitor);
/**
* describe 删除服务端提前开放出来的端口
*
* @param nettyServerVisitor 删除服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<NettyServerVisitor> remove(NettyServerVisitor nettyServerVisitor);
/**
* describe 是否存在服务端提前开放出来的端口
*
* @param nettyServerVisitor 是否存在服务端提前开放出来的端口
* @return {@link Result<Boolean>} 服务端提前开放出来的端口是否存在
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
Result<Boolean> exists(NettyServerVisitor nettyServerVisitor);
}

48
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/converter/NettyServerVisitorConverter.java Normal file
View File

@@ -0,0 +1,48 @@
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.converter;
import wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor.NettyServerVisitor;
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity.NettyServerVisitorDO;
import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureConverter
**/
@Mapper
public interface NettyServerVisitorConverter {
/**
* describe MapStruct 创建的代理对象
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
NettyServerVisitorConverter INSTANCE = Mappers.getMapper(NettyServerVisitorConverter.class);
/**
* describe 实体对象 转换成领域对象
*
* @param nettyServerVisitorDO 服务端提前开放出来的端口实体对象
* @return {@link NettyServerVisitor} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
NettyServerVisitor toNettyServerVisitor(NettyServerVisitorDO nettyServerVisitorDO);
/**
* describe 领域对象 转换成实体对象
*
* @param nettyServerVisitor 服务端提前开放出来的端口领域对象
* @return {@link NettyServerVisitorDO} 服务端提前开放出来的端口实体对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
NettyServerVisitorDO fromNettyServerVisitor(NettyServerVisitor nettyServerVisitor);
}

10
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/entity/NettyClientStateDO.java
View File

@@ -61,7 +61,7 @@ public class NettyClientStateDO {
* 暂存状态（开启、关闭）
*/
@Schema(description = "暂存状态（开启、关闭）", name = "staging", example = "")
@LazyTableField(name = "staging", comment = "暂存状态（开启、关闭）", columnType = "varchar(255)")
@LazyTableField(name = "staging_state", comment = "暂存状态（开启、关闭）", columnType = "varchar(255)")
private String stagingState;
/**
@@ -71,4 +71,12 @@ public class NettyClientStateDO {
@LazyTableFieldUpdateTime
private LocalDateTime updateTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
@LazyTableField(comment = "描述")
private String describe;
}

81
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/entity/NettyServerVisitorDO.java Normal file
View File

@@ -0,0 +1,81 @@
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity;
import lombok.Data;
import lombok.experimental.Accessors;
import com.wu.framework.inner.lazy.stereotype.LazyTableIndex;
import com.wu.framework.inner.layer.stereotype.LayerField;
import com.wu.framework.inner.layer.stereotype.LayerField.LayerFieldType;
import com.wu.framework.inner.lazy.stereotype.LazyTable;
import com.wu.framework.inner.lazy.stereotype.LazyTableField;
import com.wu.framework.inner.lazy.stereotype.*;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.media.Schema;
import java.time.LocalDateTime;
import java.lang.String;
import com.wu.framework.inner.lazy.stereotype.LazyTableFieldId;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity
**/
@Data
@Accessors(chain = true)
@LazyTable(tableName = "netty_server_visitor",schema = "lazy_cloud_netty_server",comment = "服务端提前开放出来的端口")
@Schema(title = "netty_server_visitor",description = "服务端提前开放出来的端口")
public class NettyServerVisitorDO {
/**
*
* 创建时间
*/
@Schema(description ="创建时间",name ="createTime",example = "")
@LazyTableField(name="create_time",comment="创建时间",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra=" on update CURRENT_TIMESTAMP")
private LocalDateTime createTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
@LazyTableField(name="describe",comment="描述",columnType="varchar(255)")
private String describe;
/**
*
* 用户ID
*/
@Schema(description ="用户ID",name ="id",example = "")
@LazyTableFieldId(name = "id", comment = "用户ID")
private Long id;
/**
*
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
@LazyTableField(name="is_deleted",comment="是否删除",columnType="tinyint(1)")
private Boolean isDeleted;
/**
*
* 更新时间
*/
@Schema(description ="更新时间",name ="updateTime",example = "")
@LazyTableField(name="update_time",comment="更新时间",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra=" on update CURRENT_TIMESTAMP")
private LocalDateTime updateTime;
/**
*
* 访客端口
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
@LazyTableField(name="visitor_port",comment="访客端口",columnType="int")
private Integer visitorPort;
}

15
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/mapper/NettyServerVisitorMapper.java Normal file
View File

@@ -0,0 +1,15 @@
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.mapper;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureMapper
**/
public interface NettyServerVisitorMapper {
}

15
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/mapper/NettyServerVisitorPortMapper.java Normal file
View File

@@ -0,0 +1,15 @@
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.mapper;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:13 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureMapper
**/
public interface NettyServerVisitorPortMapper {
}

56
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/persistence/InternalNetworkPenetrationMappingRepositoryImpl.java
View File

@@ -14,15 +14,16 @@ import org.springframework.stereotype.Repository;
import java.util.List;
import java.util.stream.Collectors;
/**
* describe 内网穿透映射
* describe 内网穿透映射
*
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructurePersistence
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructurePersistence
**/
@Repository
public class InternalNetworkPenetrationMappingRepositoryImpl implements InternalNetworkPenetrationMappingRepository {
public class InternalNetworkPenetrationMappingRepositoryImpl implements InternalNetworkPenetrationMappingRepository {
@Resource
LazyLambdaStream lazyLambdaStream;
@@ -30,9 +31,8 @@ public class InternalNetworkPenetrationMappingRepositoryImpl implements Intern
/**
* describe 新增内网穿透映射
*
* @param internalNetworkPenetrationMapping 新增内网穿透映射
* @return {@link Result<InternalNetworkPenetrationMapping>} 内网穿透映射新增后领域对象
* @param internalNetworkPenetrationMapping 新增内网穿透映射
* @return {@link Result<InternalNetworkPenetrationMapping>} 内网穿透映射新增后领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
@@ -47,9 +47,8 @@ public class InternalNetworkPenetrationMappingRepositoryImpl implements Intern
/**
* describe 批量新增内网穿透映射
*
* @param internalNetworkPenetrationMappingList 批量新增内网穿透映射
* @return {@link Result<List<InternalNetworkPenetrationMapping>>} 内网穿透映射新增后领域对象集合
* @param internalNetworkPenetrationMappingList 批量新增内网穿透映射
* @return {@link Result<List<InternalNetworkPenetrationMapping>>} 内网穿透映射新增后领域对象集合
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
@@ -64,9 +63,8 @@ public class InternalNetworkPenetrationMappingRepositoryImpl implements Intern
/**
* describe 查询单个内网穿透映射
*
* @param internalNetworkPenetrationMapping 查询单个内网穿透映射
* @return {@link Result<InternalNetworkPenetrationMapping>} 内网穿透映射领域对象
* @param internalNetworkPenetrationMapping 查询单个内网穿透映射
* @return {@link Result<InternalNetworkPenetrationMapping>} 内网穿透映射领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
@@ -81,9 +79,8 @@ public class InternalNetworkPenetrationMappingRepositoryImpl implements Intern
/**
* describe 查询多个内网穿透映射
*
* @param internalNetworkPenetrationMapping 查询多个内网穿透映射
* @return {@link Result<List<InternalNetworkPenetrationMapping>>} 内网穿透映射领域对象
* @param internalNetworkPenetrationMapping 查询多个内网穿透映射
* @return {@link Result<List<InternalNetworkPenetrationMapping>>} 内网穿透映射领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
@@ -98,29 +95,27 @@ public class InternalNetworkPenetrationMappingRepositoryImpl implements Intern
/**
* describe 分页查询多个内网穿透映射
*
* @param size 当前页数
* @param current 当前页
* @param internalNetworkPenetrationMapping 分页查询多个内网穿透映射
* @return {@link Result<LazyPage<InternalNetworkPenetrationMapping>>} 分页内网穿透映射领域对象
* @param size 当前页数
* @param current 当前页
* @param internalNetworkPenetrationMapping 分页查询多个内网穿透映射
* @return {@link Result<LazyPage<InternalNetworkPenetrationMapping>>} 分页内网穿透映射领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
@Override
public Result<LazyPage<InternalNetworkPenetrationMapping>> findPage(int size,int current,InternalNetworkPenetrationMapping internalNetworkPenetrationMapping) {
public Result<LazyPage<InternalNetworkPenetrationMapping>> findPage(int size, int current, InternalNetworkPenetrationMapping internalNetworkPenetrationMapping) {
InternalNetworkPenetrationMappingDO internalNetworkPenetrationMappingDO = InternalNetworkPenetrationMappingConverter.INSTANCE.fromInternalNetworkPenetrationMapping(internalNetworkPenetrationMapping);
LazyPage<InternalNetworkPenetrationMapping> lazyPage = new LazyPage<>(current,size);
LazyPage<InternalNetworkPenetrationMapping> internalNetworkPenetrationMappingLazyPage = lazyLambdaStream.selectPage(LazyWrappers.lambdaWrapperBean(internalNetworkPenetrationMappingDO),lazyPage, InternalNetworkPenetrationMapping.class);
LazyPage<InternalNetworkPenetrationMapping> lazyPage = new LazyPage<>(current, size);
LazyPage<InternalNetworkPenetrationMapping> internalNetworkPenetrationMappingLazyPage = lazyLambdaStream.selectPage(LazyWrappers.lambdaWrapperBean(internalNetworkPenetrationMappingDO), lazyPage, InternalNetworkPenetrationMapping.class);
return ResultFactory.successOf(internalNetworkPenetrationMappingLazyPage);
}
/**
* describe 删除内网穿透映射
*
* @param internalNetworkPenetrationMapping 删除内网穿透映射
* @return {@link Result<InternalNetworkPenetrationMapping>} 内网穿透映射
* @param internalNetworkPenetrationMapping 删除内网穿透映射
* @return {@link Result<InternalNetworkPenetrationMapping>} 内网穿透映射
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
@@ -128,16 +123,15 @@ public class InternalNetworkPenetrationMappingRepositoryImpl implements Intern
@Override
public Result<InternalNetworkPenetrationMapping> remove(InternalNetworkPenetrationMapping internalNetworkPenetrationMapping) {
InternalNetworkPenetrationMappingDO internalNetworkPenetrationMappingDO = InternalNetworkPenetrationMappingConverter.INSTANCE.fromInternalNetworkPenetrationMapping(internalNetworkPenetrationMapping);
// lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(internalNetworkPenetrationMappingDO));
lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(internalNetworkPenetrationMappingDO));
return ResultFactory.successOf();
}
/**
* describe 是否存在内网穿透映射
*
* @param internalNetworkPenetrationMapping 内网穿透映射领域对象
* @return {@link Result<Boolean>} 是否存在 true 存在，false 不存在
* @param internalNetworkPenetrationMapping 内网穿透映射领域对象
* @return {@link Result<Boolean>} 是否存在 true 存在，false 不存在
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
@@ -145,7 +139,7 @@ public class InternalNetworkPenetrationMappingRepositoryImpl implements Intern
@Override
public Result<Boolean> exists(InternalNetworkPenetrationMapping internalNetworkPenetrationMapping) {
InternalNetworkPenetrationMappingDO internalNetworkPenetrationMappingDO = InternalNetworkPenetrationMappingConverter.INSTANCE.fromInternalNetworkPenetrationMapping(internalNetworkPenetrationMapping);
Boolean exists=lazyLambdaStream.exists(LazyWrappers.lambdaWrapperBean(internalNetworkPenetrationMappingDO));
Boolean exists = lazyLambdaStream.exists(LazyWrappers.lambdaWrapperBean(internalNetworkPenetrationMappingDO));
return ResultFactory.successOf(exists);
}

2
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/persistence/NettyClientStateRepositoryImpl.java
View File

@@ -124,7 +124,7 @@ public class NettyClientStateRepositoryImpl implements NettyClientStateRepositor
@Override
public Result<NettyClientState> remove(NettyClientState nettyClientState) {
NettyClientStateDO nettyClientStateDO = NettyClientStateConverter.INSTANCE.fromNettyClientState(nettyClientState);
// lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(nettyClientStateDO));
lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(nettyClientStateDO));
return ResultFactory.successOf();
}

150
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/persistence/NettyServerVisitorRepositoryImpl.java Normal file
View File

@@ -0,0 +1,150 @@
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.persistence;
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity.NettyServerVisitorDO;
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.converter.NettyServerVisitorConverter;
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.mapper.NettyServerVisitorMapper;
import wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor.NettyServerVisitorRepository;
import org.springframework.stereotype.Repository;
import java.util.stream.Collectors;
import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.wrapper.LazyWrappers;
import com.wu.framework.response.Result;
import com.wu.framework.response.ResultFactory;
import jakarta.annotation.Resource;
import wu.framework.lazy.cloud.heartbeat.server.domain.model.netty.server.visitor.NettyServerVisitor;
import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.lambda.LazyLambdaStream;
import java.util.List;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
/**
* describe 服务端提前开放出来的端口
*
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
* @see com.wu.framework.inner.lazy.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructurePersistence
**/
@Repository
public class NettyServerVisitorRepositoryImpl implements NettyServerVisitorRepository {
@Resource
LazyLambdaStream lazyLambdaStream;
/**
* describe 新增服务端提前开放出来的端口
*
* @param nettyServerVisitor 新增服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口新增后领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<NettyServerVisitor> story(NettyServerVisitor nettyServerVisitor) {
NettyServerVisitorDO nettyServerVisitorDO = NettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(nettyServerVisitor);
lazyLambdaStream.upsert(nettyServerVisitorDO);
return ResultFactory.successOf();
}
/**
* describe 批量新增服务端提前开放出来的端口
*
* @param nettyServerVisitorList 批量新增服务端提前开放出来的端口
* @return {@link Result<List<NettyServerVisitor>>} 服务端提前开放出来的端口新增后领域对象集合
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<List<NettyServerVisitor>> batchStory(List<NettyServerVisitor> nettyServerVisitorList) {
List<NettyServerVisitorDO> nettyServerVisitorDOList = nettyServerVisitorList.stream().map(NettyServerVisitorConverter.INSTANCE::fromNettyServerVisitor).collect(Collectors.toList());
lazyLambdaStream.upsert(nettyServerVisitorDOList);
return ResultFactory.successOf();
}
/**
* describe 查询单个服务端提前开放出来的端口
*
* @param nettyServerVisitor 查询单个服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<NettyServerVisitor> findOne(NettyServerVisitor nettyServerVisitor) {
NettyServerVisitorDO nettyServerVisitorDO = NettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(nettyServerVisitor);
NettyServerVisitor nettyServerVisitorOne = lazyLambdaStream.selectOne(LazyWrappers.lambdaWrapperBean(nettyServerVisitorDO), NettyServerVisitor.class);
return ResultFactory.successOf(nettyServerVisitorOne);
}
/**
* describe 查询多个服务端提前开放出来的端口
*
* @param nettyServerVisitor 查询多个服务端提前开放出来的端口
* @return {@link Result<List<NettyServerVisitor>>} 服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<List<NettyServerVisitor>> findList(NettyServerVisitor nettyServerVisitor) {
NettyServerVisitorDO nettyServerVisitorDO = NettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(nettyServerVisitor);
List<NettyServerVisitor> nettyServerVisitorList = lazyLambdaStream.selectList(LazyWrappers.lambdaWrapperBean(nettyServerVisitorDO), NettyServerVisitor.class);
return ResultFactory.successOf(nettyServerVisitorList);
}
/**
* describe 分页查询多个服务端提前开放出来的端口
*
* @param size 当前页数
* @param current 当前页
* @param nettyServerVisitor 分页查询多个服务端提前开放出来的端口
* @return {@link Result<LazyPage<NettyServerVisitor>>} 分页服务端提前开放出来的端口领域对象
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<LazyPage<NettyServerVisitor>> findPage(int size, int current, NettyServerVisitor nettyServerVisitor) {
NettyServerVisitorDO nettyServerVisitorDO = NettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(nettyServerVisitor);
LazyPage<NettyServerVisitor> lazyPage = new LazyPage<>(current, size);
LazyPage<NettyServerVisitor> nettyServerVisitorLazyPage = lazyLambdaStream.selectPage(LazyWrappers.lambdaWrapperBean(nettyServerVisitorDO), lazyPage, NettyServerVisitor.class);
return ResultFactory.successOf(nettyServerVisitorLazyPage);
}
/**
* describe 删除服务端提前开放出来的端口
*
* @param nettyServerVisitor 删除服务端提前开放出来的端口
* @return {@link Result<NettyServerVisitor>} 服务端提前开放出来的端口
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<NettyServerVisitor> remove(NettyServerVisitor nettyServerVisitor) {
NettyServerVisitorDO nettyServerVisitorDO = NettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(nettyServerVisitor);
lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(nettyServerVisitorDO));
return ResultFactory.successOf();
}
/**
* describe 是否存在服务端提前开放出来的端口
*
* @param nettyServerVisitor 服务端提前开放出来的端口领域对象
* @return {@link Result<Boolean>} 是否存在 true 存在，false 不存在
* @author Jia wei Wu
* @date 2024/01/16 02:21 下午
**/
@Override
public Result<Boolean> exists(NettyServerVisitor nettyServerVisitor) {
NettyServerVisitorDO nettyServerVisitorDO = NettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(nettyServerVisitor);
Boolean exists = lazyLambdaStream.exists(LazyWrappers.lambdaWrapperBean(nettyServerVisitorDO));
return ResultFactory.successOf(exists);
}
}

7
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/model/netty/client/state/NettyClientState.java
View File

@@ -1,5 +1,6 @@
package wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state;
import com.wu.framework.inner.lazy.stereotype.LazyTableField;
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@@ -67,5 +68,11 @@ public class NettyClientState {
*/
@Schema(description ="修改时间",name ="updateTime",example = "")
private LocalDateTime updateTime;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
}