16 Commits

Author SHA1 Message Date
wujiawei
9ae2f162e2 [fix] 仓库 2024-09-29 10:12:39 +08:00
wujiawei
c2a4926888 [fix] 2024-09-28 19:27:13 +08:00
wujiawei
a5176c3cf1 [fix] 2024-09-28 19:14:18 +08:00
wujiawei
600706ccc1 [fix] 2024-09-28 19:01:41 +08:00
wujiawei
fb086d6e95 [fix] 2024-09-28 18:21:29 +08:00
wujiawei
98811a18c3 [fix] 2024-09-28 18:12:08 +08:00
wujiawei
0493c1ce5e [fix] 2024-09-28 16:44:05 +08:00
wujiawei
dd6daa5421 [fix] 添加客户端令牌桶 2024-09-28 15:54:18 +08:00
wujiawei
6c7f6b807f [fix] 添加客户端令牌桶 2024-09-28 13:57:57 +08:00
wujiawei
97f50d1701 [fix] 添加文档 2024-09-28 12:13:43 +08:00
wujiawei
5e3216a2a4 [fix] update version to 1.2.8-JDK17-SNAPSHOT 2024-09-26 20:07:28 +08:00
wujiawei
68d9713cf9 [fix] update version to 1.2.8-JDK17-SNAPSHOT 2024-09-26 20:07:06 +08:00
wujiawei
2d15abcc9f [fix] update version to 1.2.8-JDK17-SNAPSHOT 2024-09-26 11:16:22 +08:00
wujiawei
ec4c1cd7e4 [fix] update version to 1.2.8-JDK17-SNAPSHOT 2024-09-25 14:52:14 +08:00
wujiawei
bab2ce0242 [fix] update version to 1.2.8-JDK17-SNAPSHOT 2024-09-25 14:48:29 +08:00
wujiawei
6408239029 [fix] update version to 1.2.8-JDK17-SNAPSHOT 2024-09-25 08:27:04 +08:00
357 changed files with 3427 additions and 2893 deletions

140
NetworkPermeate1.0.puml Normal file
View File

@@ -0,0 +1,140 @@
@startuml
title 服务端渗透客户端
actor 访客 as User
package "服务端(公网)"{
component [服务端开放端口]{
[默认UI页面端口:6001]
[默认tcp端口:7001] as tcp
[开放给客户端访问的端口:13306]
}
}
package "客户端(私有网络)"{
component [客户端端口]{
[默认UI页面端口:6004]
}
database "客户端所在网络中的mysql:3306" as target {
}
}
[User] ...right...> [开放给客户端访问的端口:13306]: 发送请求到 http://ip:13306
[开放给客户端访问的端口:13306] ...down...> [target]: 发送真实二进制请求到真实服务
note "无法直接访问" as N2
(User) .... N2
N2 ... (target)
@enduml
@startuml
title 服务端渗透服务端
actor 访客 as User
package "服务端(局域网)"{
component [服务端开放端口]{
[默认UI页面端口:6001]
[默认tcp端口:7001] as tcp
[开放给服务端访问的端口:13306]
}
database "服务端所在网络中的mysql:3306" as target {
}
}
[User] ...right...> [开放给服务端访问的端口:13306]: 发送请求到 http://ip:13306
[开放给服务端访问的端口:13306] ...down...> [target]: 发送真实二进制请求到真实服务
note "无法直接访问" as N2
(User) .. N2
N2 .. (target)
@enduml
@startuml
title 客户端渗透服务端
actor 访客 as User
package "服务端(公网)"{
component [服务端开放端口]{
[默认UI页面端口:6001]
[默认tcp端口:7001] as tcp
}
database "服务端所在网络中的mysql:3306" as target {
}
}
package "客户端(私有网络)"{
component [客户端端口]{
[默认UI页面端口:6004]
[客户端开放端口:13306]
}
}
[User] ...right...> [客户端开放端口:13306]: 发送请求到 http://ip:13306
[客户端开放端口:13306] ...up...> [target]: 发送真实二进制请求到真实服务
note "无法直接访问" as N2
(User) ...up... N2
N2 ...up.. (target)
@enduml
@startuml
title 客户端渗透客户端
actor 访客杭州 as User
package "服务端(公网)" as server{
component [服务端开放端口]{
[默认UI页面端口:6001]
[默认tcp端口:7001] as tcp
}
}
package "客户端(私有网络--杭州)" as client_hangzhou{
component [客户端端口]{
[默认UI页面端口:6004]
[客户端开放端口:13306]
}
}
package "客户端(私有网络--上海)" as client_shanghai{
component [上海客户端端口]{
[上海默认UI页面端口:6004]
}
database "服务端所在网络中的mysql:3306" as target {
}
}
server ...down...> client_hangzhou
server <...right... client_shanghai
[User] ...right...> [客户端开放端口:13306]: 发送请求到 http://ip:13306
[客户端开放端口:13306] ...up...> [target]: 发送真实二进制请求到真实服务
note "无法直接访问" as N2
(User) ...up... N2
N2 ...up.. (target)
@enduml

Binary file not shown.

After

Width:  |  Height:  |  Size: 60 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 50 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 48 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 41 KiB

View File

@@ -33,8 +33,17 @@
wu-lazy-cloud-network
是一款基于([wu-framework-parent](https://gitee.com/wujiawei1207537021/wu-framework-parent)孵化出的项目内部使用Lazy
ORM操作数据库主要功能是网络穿透对于没有公网IP的服务进行公网IP映射
使用环境JDK17 Spring Boot 3.0.2
ORM操作数据库使用环境JDK17 Spring Boot 3.0.2。
主要功能:
- 服务端渗透客户端网络穿透对于没有公网IP的服务进行公网IP映射
- ![NetworkPermeateServerPermeateClient.png](NetworkPermeateServerPermeateClient.png)
- 服务端渗透服务端----本地同局域网内端口映射
- ![NetworkPermeateServerPermeateServer.png](NetworkPermeateServerPermeateServer.png)
- 客户端渗透服务端----本地端口映射到另一个服务端中的局域网端口
- ![NetworkPermeateClientPermeateServer.png](NetworkPermeateClientPermeateServer.png)
- 客户端渗透客户端----本地端口映射到另一个局域网端口
- ![NetworkPermeateClientPermeateClient.png](NetworkPermeateClientPermeateClient.png)
[UI](https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network-server-ui)
@@ -249,24 +258,23 @@ public class NettyClientSocket {
### 项目结构
| 模块 | 版本 | 描述 |
|-----------------------------------------------------------------------------------------------------------------------------------------|----------------------|------------------------------|
| [wu-lazy-cloud-heartbeat-common](wu-lazy-cloud-heartbeat-common) | 1.2.7-JDK17-SNAPSHOT | 内网穿透公共模块(声明接口、枚举、常量、适配器、解析器) |
| [wu-lazy-cloud-heartbeat-client](wu-lazy-cloud-heartbeat-client) | 1.2.7-JDK17-SNAPSHOT | 客户端(支持二次开发) |
| [wu-lazy-cloud-heartbeat-server](wu-lazy-cloud-heartbeat-server) | 1.2.7-JDK17-SNAPSHOT | 服务端(支持二次开发) |
| [wu-lazy-cloud-network-ui](wu-lazy-cloud-heartbeat-server-ui) | 1.2.7-JDK17-SNAPSHOT | 服务端页面 |
| [wu-lazy-cloud-heartbeat-client-start](wu-lazy-cloud-heartbeat-sample/wu-lazy-cloud-heartbeat-client-sample) | 1.2.7-JDK17-SNAPSHOT | 客户端样例 |
| [wu-lazy-cloud-heartbeat-server-start](wu-lazy-cloud-heartbeat-sample/wu-lazy-cloud-heartbeat-server-sample) | 1.2.7-JDK17-SNAPSHOT | 服务端样例 |
| 模块 | 版本 | 描述 |
|------------------------------------------------------------------------------------------------------------|----------------------|------------------------------|
| [wu-lazy-cloud-heartbeat-common](wu-lazy-cloud-heartbeat-common) | 1.2.8-JDK17-SNAPSHOT | 内网穿透公共模块(声明接口、枚举、常量、适配器、解析器) |
| [wu-lazy-cloud-heartbeat-client](wu-lazy-cloud-heartbeat-client) | 1.2.8-JDK17-SNAPSHOT | 客户端(支持二次开发) |
| [wu-lazy-cloud-heartbeat-server](wu-lazy-cloud-heartbeat-server) | 1.2.8-JDK17-SNAPSHOT | 服务端(支持二次开发) |
| [wu-lazy-cloud-heartbeat-client-start](wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-server-start) | 1.2.8-JDK17-SNAPSHOT | 客户端样例 |
| [wu-lazy-cloud-heartbeat-server-start](wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-client-start) | 1.2.8-JDK17-SNAPSHOT | 服务端样例 |
### 使用技术
| 框架 | 版本 | 描述 |
|-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------|--------------|
| spring-boot | 3.0.7 | springboot框架 |
| [wu-framework-web](https://gitee.com/wujiawei1207537021/wu-framework-parent/tree/master/wu-framework-web) | 1.2.7-JDK17-SNAPSHOT | web容器 |
| [Lazy -ORM](https://gitee.com/wujiawei1207537021/wu-framework-parent/tree/master/wu-inner-intergration/wu-database-parent) | 1.2.7-JDK17-SNAPSHOT | ORM |
| [wu-framework-web](https://gitee.com/wujiawei1207537021/wu-framework-parent/tree/master/wu-framework-web) | 1.2.8-JDK17-SNAPSHOT | web容器 |
| [Lazy -ORM](https://gitee.com/wujiawei1207537021/wu-framework-parent/tree/master/wu-inner-intergration/wu-database-parent) | 1.2.8-JDK17-SNAPSHOT | ORM |
| mysql-connector-j | 8.0.33 | mysql驱动 |
| [wu-authorization-server-platform-starter](https://gitee.com/wujiawei1207537021/wu-framework-parent/tree/master/wu-smart-platform/wu-authorization-server-platform-starter) | 1.2.7-JDK17-SNAPSHOT | 用户授权体系 |
| [wu-authorization-server-platform-starter](https://gitee.com/wujiawei1207537021/wu-framework-parent/tree/master/wu-smart-platform/wu-authorization-server-platform-starter) | 1.2.8-JDK17-SNAPSHOT | 用户授权体系 |
### 使用环境
@@ -279,7 +287,7 @@ public class NettyClientSocket {
docker启动
docker run -d -it -p 18080:18080 --name wu-lazy-cloud-heartbeat-server registry.cn-hangzhou.aliyuncs.com/wu-lazy/wu-lazy-cloud-heartbeat-server:1.2.7-JDK17-SNAPSHOT
docker run -d -it -p 18080:18080 --name wu-lazy-cloud-heartbeat-server registry.cn-hangzhou.aliyuncs.com/wu-lazy/wu-lazy-cloud-heartbeat-server:1.2.8-JDK17-SNAPSHOT
http://127.0.0.1:18080/swagger-ui/index.html
@@ -288,15 +296,15 @@ public class NettyClientSocket {
#### 页面操作
启动项目后打开服务端界面
![img.png](url_info.png)
![url_info.png](url_info.png)
默认账号密码admin/admin
![img.png](login.png)
![login.png](login.png)
初始化项目
![img.png](init_menu.png)
![init_menu.png](init_menu.png)
添加角色
![img.png](init_role.png)
![init_role.png](init_role.png)
为用户授权
![img.png](authRoe2User.png)
@@ -306,12 +314,26 @@ public class NettyClientSocket {
客户端管理(客户端会自动注册)
![img.png](cloud_client.png)
网络映射管理(修改后者新增需要映射的客户端)
![img.png](mapping.png)
## 服务端渗透
- 服务端口池管理(服务器端需要开放的端口)
![server_permeate_port_pool.png](server_permeate_port_pool.png)
访客端口池管理(服务器端需要开放的端口
![img.png](visitor_port.png)
- 服务端渗透客户端(内网穿透)(修改后者新增需要映射的客户端
![server_permeate_client_mapping.png](server_permeate_client_mapping.png)
- 服务端渗透服务端
![server_permeate_server_mapping.png](server_permeate_server_mapping.png)
## 客户端渗透
- 客户端渗透端口池管理
![client_permeate_port_pool.png](client_permeate_port_pool.png)
- 客户端渗透客户端
![client_permeate_client_mapping.png](client_permeate_client_mapping.png)
- 客户端渗透服务端
![client_permeate_server_mapping.png](client_permeate_server_mapping.png)
## 报表
流量管理(每个客户端使用的流量)
![img.png](flow.png)

Binary file not shown.

After

Width:  |  Height:  |  Size: 115 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 90 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 110 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 113 KiB

After

Width:  |  Height:  |  Size: 86 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 124 KiB

After

Width:  |  Height:  |  Size: 100 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 148 KiB

13
pom.xml
View File

@@ -8,12 +8,12 @@
<parent>
<artifactId>wu-framework-parent</artifactId>
<groupId>top.wu2020</groupId>
<version>1.2.7-JDK17-SNAPSHOT</version>
<version>1.2.8-JDK17-SNAPSHOT</version>
</parent>
<artifactId>wu-lazy-cloud-network</artifactId>
<packaging>pom</packaging>
<version>1.2.7-JDK17-SNAPSHOT</version>
<version>1.2.8-JDK17-SNAPSHOT</version>
<description>云上云下</description>
@@ -70,19 +70,12 @@
<dependency>
<groupId>top.wu2020</groupId>
<artifactId>wu-framework-dependencies</artifactId>
<version>1.2.7-JDK17-SNAPSHOT</version>
<version>1.2.8-JDK17-SNAPSHOT</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<repositories>
<repository>
<id>maven_central</id>
<name>Maven Central</name>
<url>https://repo.maven.apache.org/maven2/</url>
</repository>
</repositories>
<profiles>

Binary file not shown.

After

Width:  |  Height:  |  Size: 120 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 95 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 104 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 428 KiB

After

Width:  |  Height:  |  Size: 398 KiB

View File

@@ -19,4 +19,10 @@
sudo sysctl -w net.core.wmem_default=4194304
sudo sysctl -w net.core.wmem_max=4194304
[fix] 修复下线客户端、删除映射无法刷新问题
#### 下一版本计划内网渗透
#### 1.2.8-JDK17-SNAPSHOT
[change] 原《内网穿透》更改为服务端渗透客户端
[change] 新增服务端渗透服务端----本地同局域网内端口映射
[change] 新增客户端渗透服务端----本地端口映射到另一个服务端中的局域网端口
[change] 新增客户端渗透客户端----本地端口映射到另一个局域网端口
#### 下一版本计划https

View File

@@ -5,7 +5,7 @@
<parent>
<groupId>top.wu2020</groupId>
<artifactId>wu-lazy-cloud-network</artifactId>
<version>1.2.7-JDK17-SNAPSHOT</version>
<version>1.2.8-JDK17-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

View File

@@ -1,5 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.client.config;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
@@ -29,6 +30,19 @@ public class NettyClientProperties {
*/
private String clientId;
/**
*
* 令牌key
*/
private String appKey;
/**
*
* 令牌密钥
*/
private String appSecret;
/**
* 是否开启 默认是
*/

View File

@@ -56,4 +56,9 @@ public class InternalNetworkClientPermeateClientVisitor implements InternalNetwo
* 访客ID
*/
private String visitorId;
/**
* 是否是ssl
*/
private boolean isSsl;
}

View File

@@ -38,4 +38,10 @@ public class InternalNetworkPermeateServerVisitor implements InternalNetworkPerm
*/
private List<HandleChannelTypeAdvanced> handleChannelTypeAdvancedList;
/**
* 是否是ssl
*/
private boolean isSsl;
}

View File

@@ -49,7 +49,7 @@ public class NettyClientPermeateServerVisitorHandler extends SimpleChannelInboun
// Channel transferChannel = nettyChannelPool.availableChannel(visitorId);
// 创建访客连接服务端通道
NettyClientPermeateServerVisitorTransferSocket.buildTransferServer(internalNetworkPermeateServerVisitor,visitorChannel);
log.info("客户端渗透服务端访客端口连接成功了,访客ID:{}", visitorId);
log.debug("客户端渗透服务端访客端口连接成功了,访客ID:{}", visitorId);
super.channelActive(ctx);
}
@@ -77,7 +77,7 @@ public class NettyClientPermeateServerVisitorHandler extends SimpleChannelInboun
nettyProxyMsg.setData(bytes);
nextChannel.writeAndFlush(nettyProxyMsg);
// 处理访客流量
log.info("【客户端渗透服务端】访客端口成功发送数据了 访客ID:{}", visitorId);
log.debug("【客户端渗透服务端】访客端口成功发送数据了 访客ID:{}", visitorId);
}
@Override
@@ -100,9 +100,9 @@ public class NettyClientPermeateServerVisitorHandler extends SimpleChannelInboun
nextChannel.writeAndFlush(myMsg);
//通信通道
nextChannel.close();
log.info("关闭访问通道、真实通道 with visitorId:{}", visitorId);
log.debug("关闭访问通道、真实通道 with visitorId:{}", visitorId);
}else {
log.info("channel inactive:{}", nextChannel);
log.debug("channel inactive:{}", nextChannel);
}
// 访客通道关闭
channel.close();

View File

@@ -61,7 +61,7 @@ public class NettyClientPermeateServerVisitorTransferSocket {
Integer visitorPort = internalNetworkPermeateServerVisitor.getVisitorPort();
// 客户端新建访客通道 连接服务端IP:{},连接服务端端口:{}
log.info("Client creates a new visitor channel to connect to server IP: {}, connecting to server port: {}", inetHost, inetPort);
log.debug("Client creates a new visitor channel to connect to server IP: {}, connecting to server port: {}", inetHost, inetPort);
ChannelFuture future = bootstrap.connect(inetHost, inetPort);
// 使用的客户端ID:{}
@@ -86,7 +86,7 @@ public class NettyClientPermeateServerVisitorTransferSocket {
transferChannel.writeAndFlush(myMsg);
} else {
log.info("客户端渗透服务端通信通道中断....");
log.warn("客户端渗透服务端通信通道中断....");
transferChannel.eventLoop().schedule(() -> {
try {
buildTransferServer(internalNetworkPermeateServerVisitor, visitorChannel);

View File

@@ -6,7 +6,7 @@
<parent>
<groupId>top.wu2020</groupId>
<artifactId>wu-lazy-cloud-network</artifactId>
<version>1.2.7-JDK17-SNAPSHOT</version>
<version>1.2.8-JDK17-SNAPSHOT</version>
</parent>
<artifactId>wu-lazy-cloud-heartbeat-common</artifactId>

View File

@@ -51,5 +51,17 @@ public interface InternalNetworkPermeate {
*/
void setVisitorPort(Integer visitorPort);
/**
* 是否是ssl
*
* @return
*/
boolean isSsl();
/**
* 设置ssl
*/
void setSsl(boolean ssl);
}

View File

@@ -13,7 +13,7 @@ import lombok.experimental.Accessors;
@Builder
@Data
@Accessors(chain = true)
public class InternalNetworkPermeateRealServer {
public class InternalNetworkServerPermeateServerRealServer {
@@ -32,4 +32,8 @@ public class InternalNetworkPermeateRealServer {
* 访问端口
*/
private Integer visitorPort;
/**
* 是否是ssl
*/
private Boolean isSsl;
}

View File

@@ -5,6 +5,7 @@ import lombok.Setter;
import java.util.Arrays;
@Deprecated
@Setter
@Getter
public class NettyMsg {

View File

@@ -14,7 +14,7 @@ import java.nio.charset.StandardCharsets;
@Getter
public class NettyProxyMsg {
// body 长度 type 1 clientId 4 clientTargetIp 4 clientTargetPort 4 visitorPort 4 visitorId 4 data 4
public static final int bodyLength = 1 + 4 + 4 + 4 + 4 + 4 + 4;
public static final int bodyLength = 1 + 1 + 4 + 4 + 4 + 4 + 4 + 4;
/**
@@ -25,6 +25,13 @@ public class NettyProxyMsg {
*/
private byte type;
/**
* 是否是ssl
* byte 长度 1
* 1 true
* 0 false
*/
private byte isSsl = 0;
/**
* 客户端ID
* byte[] 长度 4
@@ -110,4 +117,23 @@ public class NettyProxyMsg {
}
public Boolean isSsl() {
return isSsl == 1;
}
public void isSsl(Boolean isSsl) {
if (isSsl) {
this.isSsl = 1;
} else {
this.isSsl = 0;
}
}
public byte getIsSsl() {
return isSsl;
}
public void setIsSsl(byte isSsl) {
this.isSsl = isSsl;
}
}

View File

@@ -109,6 +109,8 @@ public class NettyProxyMsgDecoder extends LengthFieldBasedFrameDecoder {
int bodyLength = in.readInt();
byte type = in.readByte();
nettyProxyMsg.setType(type);
byte isSsl = in.readByte();
nettyProxyMsg.setIsSsl(isSsl);
int clientIdLength = in.readInt();
byte[] clientIdBytes = new byte[clientIdLength];

View File

@@ -23,6 +23,7 @@ public class NettyProxyMsgEncoder extends MessageToByteEncoder<NettyProxyMsg> {
// body 长度 type 1 clientId 4 clientTargetIp 4 clientTargetPort 4 visitorPort 4 visitorId 4 data 4
int bodyLength = NettyProxyMsg.bodyLength;
byte typeBytes = msg.getType();
byte isSsl = msg.getIsSsl();
byte[] clientIdBytes = msg.getClientId();
byte[] clientTargetIpBytes = msg.getClientTargetIp();
byte[] clientTargetPortBytes = msg.getClientTargetPort();
@@ -30,7 +31,6 @@ public class NettyProxyMsgEncoder extends MessageToByteEncoder<NettyProxyMsg> {
byte[] visitorIdBytes = msg.getVisitorId();
byte[] msgDataBytes = msg.getData();
if (clientIdBytes != null) {
bodyLength += clientIdBytes.length;
}
@@ -54,6 +54,7 @@ public class NettyProxyMsgEncoder extends MessageToByteEncoder<NettyProxyMsg> {
out.writeInt(bodyLength);
out.writeByte(typeBytes);
out.writeByte(isSsl);
// 防止数据读错位置 clientId
if (clientIdBytes != null) {

View File

@@ -5,7 +5,7 @@
<parent>
<groupId>top.wu2020</groupId>
<artifactId>wu-lazy-cloud-network</artifactId>
<version>1.2.7-JDK17-SNAPSHOT</version>
<version>1.2.8-JDK17-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

View File

@@ -5,7 +5,7 @@
<parent>
<groupId>top.wu2020</groupId>
<artifactId>wu-lazy-cloud-network</artifactId>
<version>1.2.7-JDK17-SNAPSHOT</version>
<version>1.2.8-JDK17-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

View File

@@ -39,12 +39,12 @@ public class HeartbeatServerConfiguration {
public ServerHandleClientConnectSuccessTypeAdvanced serverReportConnectSuccessTypeAdvanced(
LazyClientStatsChangeApplication lazyClientStatsChangeApplication,
LazyNettyClientBlacklistApplication lazyNettyClientBlacklistApplication,
LazyInternalNetworkPenetrationMappingApplication lazyInternalNetworkPenetrationMappingApplication,
LazyInternalNetworkServerPermeateClientMappingApplication lazyInternalNetworkServerPermeateClientMappingApplication,
LazyInternalNetworkClientPermeateServerMappingApplication lazyInternalNetworkClientPermeateServerMappingApplication,
LazyInternalNetworkClientPermeateClientMappingApplication lazyInternalNetworkClientPermeateClientMappingApplication) {
return new ServerHandleClientConnectSuccessTypeAdvanced(lazyClientStatsChangeApplication,
lazyNettyClientBlacklistApplication,
lazyInternalNetworkPenetrationMappingApplication,
lazyInternalNetworkServerPermeateClientMappingApplication,
lazyInternalNetworkClientPermeateServerMappingApplication,
lazyInternalNetworkClientPermeateClientMappingApplication);
}

View File

@@ -19,6 +19,10 @@ public class InitServerPermeateSocket implements CommandLineRunner {
@Override
public void run(String... args) throws Exception {
lazyInternalNetworkServerPermeateMappingApplication.initPermeateSocket();
try {
lazyInternalNetworkServerPermeateMappingApplication.initPermeateSocket();
} catch (Exception e) {
e.printStackTrace();
}
}
}

View File

@@ -0,0 +1,31 @@
package org.framework.lazy.cloud.network.heartbeat.server.netty;
import lombok.Data;
import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkPermeate;
@Data
public class InternalNetworkServerPermeateServerConf implements InternalNetworkPermeate {
/**
* 目标地址
*/
private String targetIp;
/**
* 目标端口
*/
private Integer targetPort;
/**
* 访问端口
*/
private Integer visitorPort;
/**
* 是否是ssl
*/
private boolean isSsl;
}

View File

@@ -10,8 +10,8 @@ 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.application.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateClientMappingDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateServerMappingDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
@@ -31,14 +31,14 @@ public class ServerHandleClientConnectSuccessTypeAdvanced extends AbstractHandle
private final LazyClientStatsChangeApplication lazyClientStatsChangeApplication;
private final LazyNettyClientBlacklistApplication lazyNettyClientBlacklistApplication;
private final LazyInternalNetworkPenetrationMappingApplication lazyInternalNetworkPenetrationMappingApplication;
private final LazyInternalNetworkServerPermeateClientMappingApplication lazyInternalNetworkServerPermeateClientMappingApplication;
private final LazyInternalNetworkClientPermeateServerMappingApplication lazyInternalNetworkClientPermeateServerMappingApplication;
private final LazyInternalNetworkClientPermeateClientMappingApplication lazyInternalNetworkClientPermeateClientMappingApplication;
public ServerHandleClientConnectSuccessTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication, LazyNettyClientBlacklistApplication lazyNettyClientBlacklistApplication, LazyInternalNetworkPenetrationMappingApplication lazyInternalNetworkPenetrationMappingApplication, LazyInternalNetworkClientPermeateServerMappingApplication lazyInternalNetworkClientPermeateServerMappingApplication, LazyInternalNetworkClientPermeateClientMappingApplication lazyInternalNetworkClientPermeateClientMappingApplication) {
public ServerHandleClientConnectSuccessTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication, LazyNettyClientBlacklistApplication lazyNettyClientBlacklistApplication, LazyInternalNetworkServerPermeateClientMappingApplication lazyInternalNetworkServerPermeateClientMappingApplication, LazyInternalNetworkClientPermeateServerMappingApplication lazyInternalNetworkClientPermeateServerMappingApplication, LazyInternalNetworkClientPermeateClientMappingApplication lazyInternalNetworkClientPermeateClientMappingApplication) {
this.lazyClientStatsChangeApplication = lazyClientStatsChangeApplication;
this.lazyNettyClientBlacklistApplication = lazyNettyClientBlacklistApplication;
this.lazyInternalNetworkPenetrationMappingApplication = lazyInternalNetworkPenetrationMappingApplication;
this.lazyInternalNetworkServerPermeateClientMappingApplication = lazyInternalNetworkServerPermeateClientMappingApplication;
this.lazyInternalNetworkClientPermeateServerMappingApplication = lazyInternalNetworkClientPermeateServerMappingApplication;
this.lazyInternalNetworkClientPermeateClientMappingApplication = lazyInternalNetworkClientPermeateClientMappingApplication;
}
@@ -91,7 +91,7 @@ public class ServerHandleClientConnectSuccessTypeAdvanced extends AbstractHandle
// 开始开启客户端:【{}】,端口映射
log.info("Start opening client: [{}], port mapping", clientId);
// 创建访问者(内网穿透连接创建)
lazyInternalNetworkPenetrationMappingApplication.createVisitor(clientId);
lazyInternalNetworkServerPermeateClientMappingApplication.createVisitor(clientId);
// 结束开启客户端:【{}】,端口映射
log.info("End opening client: [{}], port mapping", clientId);

View File

@@ -0,0 +1,58 @@
package org.framework.lazy.cloud.network.heartbeat.server.netty.filter;
import io.netty.channel.Channel;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.ssl.SslContext;
import io.netty.handler.ssl.SslContextBuilder;
import io.netty.handler.ssl.SslHandler;
import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
import lombok.extern.slf4j.Slf4j;
import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkServerPermeateServerRealServer;
import org.framework.lazy.cloud.network.heartbeat.common.decoder.TransferDecoder;
import org.framework.lazy.cloud.network.heartbeat.common.encoder.TransferEncoder;
import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer;
import org.framework.lazy.cloud.network.heartbeat.server.netty.handler.NettyServerPermeateServerRealHandler;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLEngine;
@Slf4j
public class NettyServerPermeateServerRealFilter extends DebugChannelInitializer<SocketChannel> {
private final InternalNetworkServerPermeateServerRealServer internalNetworkServerPermeateServerRealServer;
public NettyServerPermeateServerRealFilter(InternalNetworkServerPermeateServerRealServer internalNetworkServerPermeateServerRealServer) {
this.internalNetworkServerPermeateServerRealServer = internalNetworkServerPermeateServerRealServer;
}
/**
* This method will be called once the {@link Channel} was registered. After the method returns this instance
* will be removed from the {@link ChannelPipeline} of the {@link Channel}.
*
* @param ch the {@link Channel} which was registered.
*/
@Override
protected void initChannel0(SocketChannel ch) {
ChannelPipeline pipeline = ch.pipeline();
Boolean isSsl = internalNetworkServerPermeateServerRealServer.getIsSsl();
if(isSsl!=null && isSsl) {
log.info("init channel0 ssl");
String targetIp = internalNetworkServerPermeateServerRealServer.getClientTargetIp();
Integer targetPort = internalNetworkServerPermeateServerRealServer.getClientTargetPort();
// 适配https
try {
SslContext sslContext = SslContextBuilder.forClient()
.trustManager(InsecureTrustManagerFactory.INSTANCE).build();
pipeline.addLast(sslContext.newHandler(ch.alloc()));
} catch (Exception e) {
throw new RuntimeException(e);
}
}
// 解码、编码
pipeline.addLast(new TransferDecoder(Integer.MAX_VALUE, 1024 * 1024*10));
pipeline.addLast(new TransferEncoder());
pipeline.addLast(new NettyServerPermeateServerRealHandler());
}
}

View File

@@ -5,17 +5,17 @@ import io.netty.channel.ChannelDuplexHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkPermeateRealServer;
import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkServerPermeateServerRealServer;
import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelFlowAdapter;
import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer;
import org.framework.lazy.cloud.network.heartbeat.server.netty.handler.PermeateVisitorHandler;
import org.framework.lazy.cloud.network.heartbeat.server.netty.handler.NettyServerPermeateServerVisitorHandler;
public class PermeateVisitorFilter extends DebugChannelInitializer<SocketChannel> {
private final InternalNetworkPermeateRealServer internalNetworkPermeateRealServer;
public class NettyServerPermeateServerVisitorFilter extends DebugChannelInitializer<SocketChannel> {
private final InternalNetworkServerPermeateServerRealServer internalNetworkServerPermeateServerRealServer;
private final ChannelFlowAdapter channelFlowAdapter;
public PermeateVisitorFilter(InternalNetworkPermeateRealServer internalNetworkPermeateRealServer, ChannelFlowAdapter channelFlowAdapter) {
this.internalNetworkPermeateRealServer = internalNetworkPermeateRealServer;
public NettyServerPermeateServerVisitorFilter(InternalNetworkServerPermeateServerRealServer internalNetworkServerPermeateServerRealServer, ChannelFlowAdapter channelFlowAdapter) {
this.internalNetworkServerPermeateServerRealServer = internalNetworkServerPermeateServerRealServer;
this.channelFlowAdapter = channelFlowAdapter;
}
@@ -32,6 +32,6 @@ public class PermeateVisitorFilter extends DebugChannelInitializer<SocketChannel
protected void initChannel0(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
pipeline.addLast(new ChannelDuplexHandler());
pipeline.addLast(new PermeateVisitorHandler(internalNetworkPermeateRealServer, channelFlowAdapter));
pipeline.addLast(new NettyServerPermeateServerVisitorHandler(internalNetworkServerPermeateServerRealServer, channelFlowAdapter));
}
}

View File

@@ -1,26 +0,0 @@
package org.framework.lazy.cloud.network.heartbeat.server.netty.filter;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import org.framework.lazy.cloud.network.heartbeat.common.decoder.TransferDecoder;
import org.framework.lazy.cloud.network.heartbeat.common.encoder.TransferEncoder;
import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer;
import org.framework.lazy.cloud.network.heartbeat.server.netty.handler.PermeateClientRealHandler;
public class PermeateClientRealFilter extends DebugChannelInitializer<SocketChannel> {
/**
* This method will be called once the {@link Channel} was registered. After the method returns this instance
* will be removed from the {@link ChannelPipeline} of the {@link Channel}.
*
* @param ch the {@link Channel} which was registered.
*/
@Override
protected void initChannel0(SocketChannel ch) {
ChannelPipeline pipeline = ch.pipeline();
// 解码、编码
pipeline.addLast(new TransferDecoder(Integer.MAX_VALUE, 1024 * 1024*10));
pipeline.addLast(new TransferEncoder());
pipeline.addLast(new PermeateClientRealHandler());
}
}

View File

@@ -14,7 +14,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
* 来自客户端 真实服务器返回的数据请求
*/
@Slf4j
public class PermeateClientRealHandler extends SimpleChannelInboundHandler<NettyByteBuf> {
public class NettyServerPermeateServerRealHandler extends SimpleChannelInboundHandler<NettyByteBuf> {
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {

View File

@@ -7,23 +7,24 @@ import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelOption;
import io.netty.channel.SimpleChannelInboundHandler;
import lombok.extern.slf4j.Slf4j;
import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkPermeateRealServer;
import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkServerPermeateServerRealServer;
import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelFlowAdapter;
import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum;
import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
import org.framework.lazy.cloud.network.heartbeat.server.netty.InternalNetworkServerPermeateServerConf;
import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerChannelFlow;
import org.framework.lazy.cloud.network.heartbeat.server.netty.socket.NettyServerPermeateServerConnectRealSocket;
import java.util.UUID;
@Slf4j
public class PermeateVisitorHandler extends SimpleChannelInboundHandler<ByteBuf> {
private final InternalNetworkPermeateRealServer internalNetworkPermeateRealServer;
public class NettyServerPermeateServerVisitorHandler extends SimpleChannelInboundHandler<ByteBuf> {
private final InternalNetworkServerPermeateServerRealServer internalNetworkServerPermeateServerRealServer;
private final ChannelFlowAdapter channelFlowAdapter;// 流量适配器
// private final NettyChannelPool nettyChannelPool = new DefaultNettyChannelPool(10);
public PermeateVisitorHandler(InternalNetworkPermeateRealServer internalNetworkPermeateRealServer, ChannelFlowAdapter channelFlowAdapter) {
this.internalNetworkPermeateRealServer = internalNetworkPermeateRealServer;
public NettyServerPermeateServerVisitorHandler(InternalNetworkServerPermeateServerRealServer internalNetworkServerPermeateServerRealServer, ChannelFlowAdapter channelFlowAdapter) {
this.internalNetworkServerPermeateServerRealServer = internalNetworkServerPermeateServerRealServer;
this.channelFlowAdapter = channelFlowAdapter;
}
@@ -42,9 +43,10 @@ public class PermeateVisitorHandler extends SimpleChannelInboundHandler<ByteBuf>
// 判断是否有可用的通道 如果没有创建新的通道
log.info("开始准备绑定渗透真实通道: {}", internalNetworkPermeateRealServer.getVisitorPort());
log.info("开始准备绑定渗透真实通道: {}", internalNetworkServerPermeateServerRealServer.getVisitorPort());
// 创建这是客户端通道池
NettyServerPermeateServerConnectRealSocket.buildRealServer(internalNetworkPermeateRealServer, visitorChannel, visitorId);
NettyServerPermeateServerConnectRealSocket.buildRealServer(internalNetworkServerPermeateServerRealServer, visitorChannel, visitorId);
log.info("内网渗透 服务端访客端口连接成功了");
@@ -56,7 +58,7 @@ public class PermeateVisitorHandler extends SimpleChannelInboundHandler<ByteBuf>
// 访客通道
Channel visitorChannel = ctx.channel();
Integer visitorPort = internalNetworkPermeateRealServer.getVisitorPort();
Integer visitorPort = internalNetworkServerPermeateServerRealServer.getVisitorPort();
byte[] bytes = new byte[buf.readableBytes()];
buf.readBytes(bytes);
// 获取客户端通道而后进行数据下发

View File

@@ -6,9 +6,9 @@ import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import lombok.extern.slf4j.Slf4j;
import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkPermeateRealServer;
import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkServerPermeateServerRealServer;
import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
import org.framework.lazy.cloud.network.heartbeat.server.netty.filter.PermeateClientRealFilter;
import org.framework.lazy.cloud.network.heartbeat.server.netty.filter.NettyServerPermeateServerRealFilter;
import java.util.concurrent.TimeUnit;
@@ -22,23 +22,23 @@ public class NettyServerPermeateServerConnectRealSocket {
/**
* 连接真实服务
*
* @param internalNetworkPermeateRealServer 访客信息
* @param internalNetworkServerPermeateServerRealServer 访客信息
*/
public static void buildRealServer(InternalNetworkPermeateRealServer internalNetworkPermeateRealServer,Channel visitorChannel ,String visitorId) {
buildNewRealServer(internalNetworkPermeateRealServer,visitorChannel,visitorId);
public static void buildRealServer(InternalNetworkServerPermeateServerRealServer internalNetworkServerPermeateServerRealServer, Channel visitorChannel , String visitorId) {
buildNewRealServer(internalNetworkServerPermeateServerRealServer,visitorChannel,visitorId);
}
/**
* @param internalNetworkPermeateRealServer 访客信息
* @param internalNetworkServerPermeateServerRealServer 访客信息
* @param visitorChannel
* @param visitorId
*/
private static void buildNewRealServer(InternalNetworkPermeateRealServer internalNetworkPermeateRealServer,
private static void buildNewRealServer(InternalNetworkServerPermeateServerRealServer internalNetworkServerPermeateServerRealServer,
Channel visitorChannel, String visitorId) {
try {
String clientTargetIp = internalNetworkPermeateRealServer.getClientTargetIp();
Integer clientTargetPort = internalNetworkPermeateRealServer.getClientTargetPort();
Integer visitorPort = internalNetworkPermeateRealServer.getVisitorPort();
String clientTargetIp = internalNetworkServerPermeateServerRealServer.getClientTargetIp();
Integer clientTargetPort = internalNetworkServerPermeateServerRealServer.getClientTargetPort();
Integer visitorPort = internalNetworkServerPermeateServerRealServer.getVisitorPort();
Bootstrap bootstrap = new Bootstrap();
bootstrap.group(eventLoopGroup).channel(NioSocketChannel.class)
// 设置读缓冲区为2M
@@ -50,7 +50,7 @@ public class NettyServerPermeateServerConnectRealSocket {
// .option(ChannelOption.SO_BACKLOG, 128)//务端接受连接的队列长度 默认128
// .option(ChannelOption.RCVBUF_ALLOCATOR, new NettyRecvByteBufAllocator(1024 * 1024))//用于Channel分配接受Buffer的分配器 默认AdaptiveRecvByteBufAllocator.DEFAULT
.option(ChannelOption.WRITE_BUFFER_WATER_MARK, new WriteBufferWaterMark(1024 * 1024, 1024 * 1024 * 2))
.handler(new PermeateClientRealFilter())
.handler(new NettyServerPermeateServerRealFilter(internalNetworkServerPermeateServerRealServer))
;
@@ -77,7 +77,7 @@ public class NettyServerPermeateServerConnectRealSocket {
} else {
log.error("服务端内网渗透 无法连接当前网络内的目标IP【{}】,目标端口:【{}】", clientTargetIp, clientTargetPort);
channelFuture.channel().eventLoop().schedule(() -> {
buildNewRealServer(internalNetworkPermeateRealServer, visitorChannel, visitorId);
buildNewRealServer(internalNetworkServerPermeateServerRealServer, visitorChannel, visitorId);
}, 2, TimeUnit.SECONDS);
}
});

View File

@@ -7,11 +7,11 @@ import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkPermeateRealServer;
import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkServerPermeateServerRealServer;
import org.framework.lazy.cloud.network.heartbeat.common.NettyPermeateVisitorContext;
import org.framework.lazy.cloud.network.heartbeat.common.NettyVisitorPortContext;
import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelFlowAdapter;
import org.framework.lazy.cloud.network.heartbeat.server.netty.filter.PermeateVisitorFilter;
import org.framework.lazy.cloud.network.heartbeat.server.netty.filter.NettyServerPermeateServerVisitorFilter;
import java.io.IOException;
@@ -22,19 +22,16 @@ import java.io.IOException;
public class NettyServerPermeateServerConnectVisitorSocket {
private final EventLoopGroup bossGroup = new NioEventLoopGroup();
private final EventLoopGroup workerGroup = new NioEventLoopGroup();
private final PermeateVisitorFilter permeateVisitorFilter;
private final NettyServerPermeateServerVisitorFilter nettyServerPermeateServerVisitorFilter;
@Getter
private final int visitorPort;
private final InternalNetworkPermeateRealServer internalNetworkPermeateRealServer;
public NettyServerPermeateServerConnectVisitorSocket(PermeateVisitorFilter permeateVisitorFilter,
InternalNetworkPermeateRealServer internalNetworkPermeateRealServer,
public NettyServerPermeateServerConnectVisitorSocket(NettyServerPermeateServerVisitorFilter nettyServerPermeateServerVisitorFilter,
int visitorPort) {
this.permeateVisitorFilter = permeateVisitorFilter;
this.nettyServerPermeateServerVisitorFilter = nettyServerPermeateServerVisitorFilter;
this.visitorPort = visitorPort;
this.internalNetworkPermeateRealServer = internalNetworkPermeateRealServer;
}
@@ -66,7 +63,7 @@ public class NettyServerPermeateServerConnectVisitorSocket {
.childOption(ChannelOption.WRITE_BUFFER_WATER_MARK, new WriteBufferWaterMark(1024 * 1024, 1024 * 1024 * 2))
.childHandler(permeateVisitorFilter);
.childHandler(nettyServerPermeateServerVisitorFilter);
ChannelFuture sync = bootstrap.bind(visitorPort).sync();
sync.addListener((ChannelFutureListener) future -> {
if (future.isSuccess()) {
@@ -122,10 +119,11 @@ public class NettyServerPermeateServerConnectVisitorSocket {
* 访问端口
*/
private Integer permeateVisitorPort;
/**
* 访客ID
* 是否是ssl
*/
private String visitorId;
private Boolean isSsl;
/**
* 流量适配器
@@ -179,6 +177,16 @@ public class NettyServerPermeateServerConnectVisitorSocket {
this.channelFlowAdapter = channelFlowAdapter;
return this;
}
/**
* 是否是ssl
*
* @param isSsl 是否是ssl
* @return 当前对象
*/
public NettyPermeateVisitorSocketBuilder builderIsSsl(Boolean isSsl) {
this.isSsl = isSsl;
return this;
}
public NettyServerPermeateServerConnectVisitorSocket build() {
@@ -192,15 +200,16 @@ public class NettyServerPermeateServerConnectVisitorSocket {
if (permeateVisitorPort == null) {
throw new IllegalArgumentException("visitorPort must not null");
}
InternalNetworkPermeateRealServer internalNetworkPermeateRealServer = InternalNetworkPermeateRealServer
InternalNetworkServerPermeateServerRealServer internalNetworkServerPermeateServerRealServer = InternalNetworkServerPermeateServerRealServer
.builder()
.clientTargetIp(clientTargetIp)
.clientTargetPort(clientTargetPort)
.visitorPort(permeateVisitorPort)
.isSsl(isSsl)
.build();
PermeateVisitorFilter permeateVisitorFilter = new PermeateVisitorFilter(internalNetworkPermeateRealServer, channelFlowAdapter);
return new NettyServerPermeateServerConnectVisitorSocket(permeateVisitorFilter, internalNetworkPermeateRealServer, permeateVisitorPort);
NettyServerPermeateServerVisitorFilter nettyServerPermeateServerVisitorFilter = new NettyServerPermeateServerVisitorFilter(internalNetworkServerPermeateServerRealServer, channelFlowAdapter);
return new NettyServerPermeateServerConnectVisitorSocket(nettyServerPermeateServerVisitorFilter, permeateVisitorPort);
}

View File

@@ -1,13 +1,12 @@
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.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateClientMappingDTO;
import java.util.List;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;

View File

@@ -1,13 +1,12 @@
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.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateServerMappingDTO;
import java.util.List;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;

View File

@@ -1,108 +0,0 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.internal.network.penetration.mapping.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.internal.network.penetration.mapping.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkPenetrationMappingDTO;
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.internal.network.penetration.mapping.LazyInternalNetworkPenetrationMapping;
import java.util.List;
/**
* describe 内网穿透映射
*
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
* @see DefaultDDDLazyApplication
**/
public interface LazyInternalNetworkPenetrationMappingApplication {
/**
* describe 新增内网穿透映射
*
* @param lazyInternalNetworkPenetrationMappingStoryCommand 新增内网穿透映射
* @return {@link Result< LazyInternalNetworkPenetrationMapping >} 内网穿透映射新增后领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<LazyInternalNetworkPenetrationMapping> story(LazyInternalNetworkPenetrationMappingStoryCommand lazyInternalNetworkPenetrationMappingStoryCommand) ;
/**
* describe 批量新增内网穿透映射
*
* @param lazyInternalNetworkPenetrationMappingStoryCommandList 批量新增内网穿透映射
* @return {@link Result<List< LazyInternalNetworkPenetrationMapping >>} 内网穿透映射新增后领域对象集合
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<List<LazyInternalNetworkPenetrationMapping>> batchStory(List<LazyInternalNetworkPenetrationMappingStoryCommand> lazyInternalNetworkPenetrationMappingStoryCommandList);
/**
* describe 更新内网穿透映射
*
* @param lazyInternalNetworkPenetrationMappingUpdateCommand 更新内网穿透映射
* @return {@link Result< LazyInternalNetworkPenetrationMapping >} 内网穿透映射领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<LazyInternalNetworkPenetrationMapping> updateOne(LazyInternalNetworkPenetrationMappingUpdateCommand lazyInternalNetworkPenetrationMappingUpdateCommand) ;
/**
* describe 查询单个内网穿透映射
*
* @param lazyInternalNetworkPenetrationMappingQueryOneCommand 查询单个内网穿透映射
* @return {@link Result< LazyInternalNetworkPenetrationMappingDTO >} 内网穿透映射DTO对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<LazyInternalNetworkPenetrationMappingDTO> findOne(LazyInternalNetworkPenetrationMappingQueryOneCommand lazyInternalNetworkPenetrationMappingQueryOneCommand);
/**
* describe 查询多个内网穿透映射
*
* @param lazyInternalNetworkPenetrationMappingQueryListCommand 查询多个内网穿透映射
* @return {@link Result <List<LazyInternalNetworkPenetrationMappingDTO>>} 内网穿透映射DTO对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<List<LazyInternalNetworkPenetrationMappingDTO>> findList(LazyInternalNetworkPenetrationMappingQueryListCommand lazyInternalNetworkPenetrationMappingQueryListCommand);
/**
* describe 分页查询多个内网穿透映射
*
* @param lazyInternalNetworkPenetrationMappingQueryListCommand 分页查询多个内网穿透映射
* @return {@link Result <LazyPage<LazyInternalNetworkPenetrationMappingDTO>>} 分页内网穿透映射DTO对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<LazyPage<LazyInternalNetworkPenetrationMappingDTO>> findPage(int size, int current, LazyInternalNetworkPenetrationMappingQueryListCommand lazyInternalNetworkPenetrationMappingQueryListCommand);
/**
* describe 删除内网穿透映射
*
* @param lazyInternalNetworkPenetrationMappingRemoveCommand 删除内网穿透映射
* @return {@link Result< LazyInternalNetworkPenetrationMapping >} 内网穿透映射
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<LazyInternalNetworkPenetrationMapping> remove(LazyInternalNetworkPenetrationMappingRemoveCommand lazyInternalNetworkPenetrationMappingRemoveCommand);
/**
* 创建客户端的访问者
*
* @param clientId 客户端ID
*/
Result<Void> createVisitor(String clientId);
}

View File

@@ -0,0 +1,107 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.client.mapping.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkPenetrationMappingDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.client.mapping.LazyInternalNetworkServerPermeateClientMapping;
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 java.util.List;
/**
* describe 内网穿透映射
*
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
* @see DefaultDDDLazyApplication
**/
public interface LazyInternalNetworkServerPermeateClientMappingApplication {
/**
* describe 新增内网穿透映射
*
* @param lazyInternalNetworkServerPermeateClientMappingStoryCommand 新增内网穿透映射
* @return {@link Result< LazyInternalNetworkServerPermeateClientMapping >} 内网穿透映射新增后领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<LazyInternalNetworkServerPermeateClientMapping> story(LazyInternalNetworkServerPermeateClientMappingStoryCommand lazyInternalNetworkServerPermeateClientMappingStoryCommand) ;
/**
* describe 批量新增内网穿透映射
*
* @param lazyInternalNetworkServerPermeateClientMappingStoryCommandList 批量新增内网穿透映射
* @return {@link Result<List< LazyInternalNetworkServerPermeateClientMapping >>} 内网穿透映射新增后领域对象集合
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<List<LazyInternalNetworkServerPermeateClientMapping>> batchStory(List<LazyInternalNetworkServerPermeateClientMappingStoryCommand> lazyInternalNetworkServerPermeateClientMappingStoryCommandList);
/**
* describe 更新内网穿透映射
*
* @param lazyInternalNetworkServerPermeateClientMappingUpdateCommand 更新内网穿透映射
* @return {@link Result< LazyInternalNetworkServerPermeateClientMapping >} 内网穿透映射领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<LazyInternalNetworkServerPermeateClientMapping> updateOne(LazyInternalNetworkServerPermeateClientMappingUpdateCommand lazyInternalNetworkServerPermeateClientMappingUpdateCommand) ;
/**
* describe 查询单个内网穿透映射
*
* @param lazyInternalNetworkServerPermeateClientMappingQueryOneCommand 查询单个内网穿透映射
* @return {@link Result< LazyInternalNetworkPenetrationMappingDTO >} 内网穿透映射DTO对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<LazyInternalNetworkPenetrationMappingDTO> findOne(LazyInternalNetworkServerPermeateClientMappingQueryOneCommand lazyInternalNetworkServerPermeateClientMappingQueryOneCommand);
/**
* describe 查询多个内网穿透映射
*
* @param lazyInternalNetworkServerPermeateClientMappingQueryListCommand 查询多个内网穿透映射
* @return {@link Result <List<LazyInternalNetworkPenetrationMappingDTO>>} 内网穿透映射DTO对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<List<LazyInternalNetworkPenetrationMappingDTO>> findList(LazyInternalNetworkServerPermeateClientMappingQueryListCommand lazyInternalNetworkServerPermeateClientMappingQueryListCommand);
/**
* describe 分页查询多个内网穿透映射
*
* @param lazyInternalNetworkServerPermeateClientMappingQueryListCommand 分页查询多个内网穿透映射
* @return {@link Result <LazyPage<LazyInternalNetworkPenetrationMappingDTO>>} 分页内网穿透映射DTO对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<LazyPage<LazyInternalNetworkPenetrationMappingDTO>> findPage(int size, int current, LazyInternalNetworkServerPermeateClientMappingQueryListCommand lazyInternalNetworkServerPermeateClientMappingQueryListCommand);
/**
* describe 删除内网穿透映射
*
* @param lazyInternalNetworkServerPermeateClientMappingRemoveCommand 删除内网穿透映射
* @return {@link Result< LazyInternalNetworkServerPermeateClientMapping >} 内网穿透映射
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
Result<LazyInternalNetworkServerPermeateClientMapping> remove(LazyInternalNetworkServerPermeateClientMappingRemoveCommand lazyInternalNetworkServerPermeateClientMappingRemoveCommand);
/**
* 创建客户端的访问者
*
* @param clientId 客户端ID
*/
Result<Void> createVisitor(String clientId);
}

View File

@@ -1,13 +1,8 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.server.mapping.*;
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.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMappingRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMappingStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMappingUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMappingQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.server.mapping.LazyInternalNetworkServerPermeateServerMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkServerPermeateMappingDTO;
import java.util.List;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
@@ -25,86 +20,86 @@ public interface LazyInternalNetworkServerPermeateMappingApplication {
/**
* describe 新增服务端网络渗透映射
*
* @param lazyInternalNetworkServerPermeateMappingStoryCommand 新增服务端网络渗透映射
* @return {@link Result<LazyInternalNetworkServerPermeateMapping>} 服务端网络渗透映射新增后领域对象
* @param lazyInternalNetworkServerPermeateServerMappingStoryCommand 新增服务端网络渗透映射
* @return {@link Result< LazyInternalNetworkServerPermeateServerMapping >} 服务端网络渗透映射新增后领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
Result<LazyInternalNetworkServerPermeateMapping> story(LazyInternalNetworkServerPermeateMappingStoryCommand lazyInternalNetworkServerPermeateMappingStoryCommand);
Result<LazyInternalNetworkServerPermeateServerMapping> story(LazyInternalNetworkServerPermeateServerMappingStoryCommand lazyInternalNetworkServerPermeateServerMappingStoryCommand);
/**
* describe 批量新增服务端网络渗透映射
*
* @param lazyInternalNetworkServerPermeateMappingStoryCommandList 批量新增服务端网络渗透映射
* @return {@link Result<List<LazyInternalNetworkServerPermeateMapping>>} 服务端网络渗透映射新增后领域对象集合
* @param lazyInternalNetworkServerPermeateServerMappingStoryCommandList 批量新增服务端网络渗透映射
* @return {@link Result<List< LazyInternalNetworkServerPermeateServerMapping >>} 服务端网络渗透映射新增后领域对象集合
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
Result<List<LazyInternalNetworkServerPermeateMapping>> batchStory(List<LazyInternalNetworkServerPermeateMappingStoryCommand> lazyInternalNetworkServerPermeateMappingStoryCommandList);
Result<List<LazyInternalNetworkServerPermeateServerMapping>> batchStory(List<LazyInternalNetworkServerPermeateServerMappingStoryCommand> lazyInternalNetworkServerPermeateServerMappingStoryCommandList);
/**
* describe 更新服务端网络渗透映射
*
* @param lazyInternalNetworkServerPermeateMappingUpdateCommand 更新服务端网络渗透映射
* @return {@link Result<LazyInternalNetworkServerPermeateMapping>} 服务端网络渗透映射领域对象
* @param lazyInternalNetworkServerPermeateServerMappingUpdateCommand 更新服务端网络渗透映射
* @return {@link Result< LazyInternalNetworkServerPermeateServerMapping >} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
Result<LazyInternalNetworkServerPermeateMapping> updateOne(LazyInternalNetworkServerPermeateMappingUpdateCommand lazyInternalNetworkServerPermeateMappingUpdateCommand);
Result<LazyInternalNetworkServerPermeateServerMapping> updateOne(LazyInternalNetworkServerPermeateServerMappingUpdateCommand lazyInternalNetworkServerPermeateServerMappingUpdateCommand);
/**
* describe 查询单个服务端网络渗透映射
*
* @param lazyInternalNetworkServerPermeateMappingQueryOneCommand 查询单个服务端网络渗透映射
* @param lazyInternalNetworkServerPermeateServerMappingQueryOneCommand 查询单个服务端网络渗透映射
* @return {@link Result<LazyInternalNetworkServerPermeateMappingDTO>} 服务端网络渗透映射DTO对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
Result<LazyInternalNetworkServerPermeateMappingDTO> findOne(LazyInternalNetworkServerPermeateMappingQueryOneCommand lazyInternalNetworkServerPermeateMappingQueryOneCommand);
Result<LazyInternalNetworkServerPermeateMappingDTO> findOne(LazyInternalNetworkServerPermeateServerMappingQueryOneCommand lazyInternalNetworkServerPermeateServerMappingQueryOneCommand);
/**
* describe 查询多个服务端网络渗透映射
*
* @param lazyInternalNetworkServerPermeateMappingQueryListCommand 查询多个服务端网络渗透映射
* @param lazyInternalNetworkServerPermeateServerMappingQueryListCommand 查询多个服务端网络渗透映射
* @return {@link Result <List<LazyInternalNetworkServerPermeateMappingDTO>>} 服务端网络渗透映射DTO对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
Result <List<LazyInternalNetworkServerPermeateMappingDTO>> findList(LazyInternalNetworkServerPermeateMappingQueryListCommand lazyInternalNetworkServerPermeateMappingQueryListCommand);
Result <List<LazyInternalNetworkServerPermeateMappingDTO>> findList(LazyInternalNetworkServerPermeateServerMappingQueryListCommand lazyInternalNetworkServerPermeateServerMappingQueryListCommand);
/**
* describe 分页查询多个服务端网络渗透映射
*
* @param lazyInternalNetworkServerPermeateMappingQueryListCommand 分页查询多个服务端网络渗透映射
* @param lazyInternalNetworkServerPermeateServerMappingQueryListCommand 分页查询多个服务端网络渗透映射
* @return {@link Result <LazyPage<LazyInternalNetworkServerPermeateMappingDTO>>} 分页服务端网络渗透映射DTO对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
Result <LazyPage<LazyInternalNetworkServerPermeateMappingDTO>> findPage(int size,int current,LazyInternalNetworkServerPermeateMappingQueryListCommand lazyInternalNetworkServerPermeateMappingQueryListCommand);
Result <LazyPage<LazyInternalNetworkServerPermeateMappingDTO>> findPage(int size, int current, LazyInternalNetworkServerPermeateServerMappingQueryListCommand lazyInternalNetworkServerPermeateServerMappingQueryListCommand);
/**
* describe 删除服务端网络渗透映射
*
* @param lazyInternalNetworkServerPermeateMappingRemoveCommand 删除服务端网络渗透映射
* @return {@link Result<LazyInternalNetworkServerPermeateMapping>} 服务端网络渗透映射
* @param lazyInternalNetworkServerPermeateServerMappingRemoveCommand 删除服务端网络渗透映射
* @return {@link Result< LazyInternalNetworkServerPermeateServerMapping >} 服务端网络渗透映射
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
Result<LazyInternalNetworkServerPermeateMapping> remove(LazyInternalNetworkServerPermeateMappingRemoveCommand lazyInternalNetworkServerPermeateMappingRemoveCommand);
Result<LazyInternalNetworkServerPermeateServerMapping> remove(LazyInternalNetworkServerPermeateServerMappingRemoveCommand lazyInternalNetworkServerPermeateServerMappingRemoveCommand);
/**

View File

@@ -1,6 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.blacklist.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientBlacklistDTO;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
import org.wu.framework.web.response.Result;

View File

@@ -1,7 +1,7 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.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.lazy.netty.client.state.LazyNettyClientState;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;

View File

@@ -0,0 +1,109 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application;
import org.wu.framework.web.response.Result;
import org.wu.framework.web.response.ResultFactory;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.token.bucket.LazyNettyClientTokenBucket;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket.LazyNettyClientTokenBucketRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket.LazyNettyClientTokenBucketStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket.LazyNettyClientTokenBucketUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket.LazyNettyClientTokenBucketQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket.LazyNettyClientTokenBucketQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientTokenBucketDTO;
import java.util.List;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
/**
* describe 客户端令牌桶
*
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication
**/
public interface LazyNettyClientTokenBucketApplication {
/**
* describe 新增客户端令牌桶
*
* @param lazyNettyClientTokenBucketStoryCommand 新增客户端令牌桶
* @return {@link Result<LazyNettyClientTokenBucket>} 客户端令牌桶新增后领域对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
Result<LazyNettyClientTokenBucket> story(LazyNettyClientTokenBucketStoryCommand lazyNettyClientTokenBucketStoryCommand);
/**
* describe 批量新增客户端令牌桶
*
* @param lazyNettyClientTokenBucketStoryCommandList 批量新增客户端令牌桶
* @return {@link Result<List<LazyNettyClientTokenBucket>>} 客户端令牌桶新增后领域对象集合
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
Result<List<LazyNettyClientTokenBucket>> batchStory(List<LazyNettyClientTokenBucketStoryCommand> lazyNettyClientTokenBucketStoryCommandList);
/**
* describe 更新客户端令牌桶
*
* @param lazyNettyClientTokenBucketUpdateCommand 更新客户端令牌桶
* @return {@link Result<LazyNettyClientTokenBucket>} 客户端令牌桶领域对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
Result<LazyNettyClientTokenBucket> updateOne(LazyNettyClientTokenBucketUpdateCommand lazyNettyClientTokenBucketUpdateCommand);
/**
* describe 查询单个客户端令牌桶
*
* @param lazyNettyClientTokenBucketQueryOneCommand 查询单个客户端令牌桶
* @return {@link Result<LazyNettyClientTokenBucketDTO>} 客户端令牌桶DTO对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
Result<LazyNettyClientTokenBucketDTO> findOne(LazyNettyClientTokenBucketQueryOneCommand lazyNettyClientTokenBucketQueryOneCommand);
/**
* describe 查询多个客户端令牌桶
*
* @param lazyNettyClientTokenBucketQueryListCommand 查询多个客户端令牌桶
* @return {@link Result <List<LazyNettyClientTokenBucketDTO>>} 客户端令牌桶DTO对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
Result <List<LazyNettyClientTokenBucketDTO>> findList(LazyNettyClientTokenBucketQueryListCommand lazyNettyClientTokenBucketQueryListCommand);
/**
* describe 分页查询多个客户端令牌桶
*
* @param lazyNettyClientTokenBucketQueryListCommand 分页查询多个客户端令牌桶
* @return {@link Result <LazyPage<LazyNettyClientTokenBucketDTO>>} 分页客户端令牌桶DTO对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
Result <LazyPage<LazyNettyClientTokenBucketDTO>> findPage(int size,int current,LazyNettyClientTokenBucketQueryListCommand lazyNettyClientTokenBucketQueryListCommand);
/**
* describe 删除客户端令牌桶
*
* @param lazyNettyClientTokenBucketRemoveCommand 删除客户端令牌桶
* @return {@link Result<LazyNettyClientTokenBucket>} 客户端令牌桶
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
Result<LazyNettyClientTokenBucket> remove(LazyNettyClientTokenBucketRemoveCommand lazyNettyClientTokenBucketRemoveCommand);
}

View File

@@ -1,109 +0,0 @@
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.server.permeate.port.pool.LazyNettyServerPermeatePortPool;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPoolRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPoolStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPoolUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPoolQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPoolQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerPermeatePortPoolDTO;
import java.util.List;
import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage;
/**
* describe 服务端内网渗透端口池
*
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplication
**/
public interface LazyNettyServerPermeatePortPoolApplication {
/**
* describe 新增服务端内网渗透端口池
*
* @param lazyNettyServerPermeatePortPoolStoryCommand 新增服务端内网渗透端口池
* @return {@link Result<LazyNettyServerPermeatePortPool>} 服务端内网渗透端口池新增后领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
Result<LazyNettyServerPermeatePortPool> story(LazyNettyServerPermeatePortPoolStoryCommand lazyNettyServerPermeatePortPoolStoryCommand);
/**
* describe 批量新增服务端内网渗透端口池
*
* @param lazyNettyServerPermeatePortPoolStoryCommandList 批量新增服务端内网渗透端口池
* @return {@link Result<List<LazyNettyServerPermeatePortPool>>} 服务端内网渗透端口池新增后领域对象集合
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
Result<List<LazyNettyServerPermeatePortPool>> batchStory(List<LazyNettyServerPermeatePortPoolStoryCommand> lazyNettyServerPermeatePortPoolStoryCommandList);
/**
* describe 更新服务端内网渗透端口池
*
* @param lazyNettyServerPermeatePortPoolUpdateCommand 更新服务端内网渗透端口池
* @return {@link Result<LazyNettyServerPermeatePortPool>} 服务端内网渗透端口池领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
Result<LazyNettyServerPermeatePortPool> updateOne(LazyNettyServerPermeatePortPoolUpdateCommand lazyNettyServerPermeatePortPoolUpdateCommand);
/**
* describe 查询单个服务端内网渗透端口池
*
* @param lazyNettyServerPermeatePortPoolQueryOneCommand 查询单个服务端内网渗透端口池
* @return {@link Result<LazyNettyServerPermeatePortPoolDTO>} 服务端内网渗透端口池DTO对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
Result<LazyNettyServerPermeatePortPoolDTO> findOne(LazyNettyServerPermeatePortPoolQueryOneCommand lazyNettyServerPermeatePortPoolQueryOneCommand);
/**
* describe 查询多个服务端内网渗透端口池
*
* @param lazyNettyServerPermeatePortPoolQueryListCommand 查询多个服务端内网渗透端口池
* @return {@link Result <List<LazyNettyServerPermeatePortPoolDTO>>} 服务端内网渗透端口池DTO对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
Result <List<LazyNettyServerPermeatePortPoolDTO>> findList(LazyNettyServerPermeatePortPoolQueryListCommand lazyNettyServerPermeatePortPoolQueryListCommand);
/**
* describe 分页查询多个服务端内网渗透端口池
*
* @param lazyNettyServerPermeatePortPoolQueryListCommand 分页查询多个服务端内网渗透端口池
* @return {@link Result <LazyPage<LazyNettyServerPermeatePortPoolDTO>>} 分页服务端内网渗透端口池DTO对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
Result <LazyPage<LazyNettyServerPermeatePortPoolDTO>> findPage(int size,int current,LazyNettyServerPermeatePortPoolQueryListCommand lazyNettyServerPermeatePortPoolQueryListCommand);
/**
* describe 删除服务端内网渗透端口池
*
* @param lazyNettyServerPermeatePortPoolRemoveCommand 删除服务端内网渗透端口池
* @return {@link Result<LazyNettyServerPermeatePortPool>} 服务端内网渗透端口池
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
Result<LazyNettyServerPermeatePortPool> remove(LazyNettyServerPermeatePortPoolRemoveCommand lazyNettyServerPermeatePortPoolRemoveCommand);
}

View File

@@ -1,13 +1,12 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.server.visitor.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.server.visitor.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerVisitorDTO;
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.lazy.netty.server.visitor.LazyNettyServerVisitor;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.port.pool.LazyNettyServerVisitor;
import java.util.List;

View File

@@ -1,8 +1,7 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.internal.network.penetration.mapping.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.internal.network.penetration.mapping.LazyInternalNetworkPenetrationMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.internal.network.penetration.mapping.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.client.mapping.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.client.mapping.LazyInternalNetworkServerPermeateClientMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkPenetrationMappingDTO;
import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers;
@@ -30,60 +29,60 @@ public interface InternalNetworkPenetrationMappingDTOAssembler {
/**
* describe 应用层存储入参转换成 领域对象
*
* @param lazyInternalNetworkPenetrationMappingStoryCommand 保存内网穿透映射对象
* @return {@link LazyInternalNetworkPenetrationMapping} 内网穿透映射领域对象
* @param lazyInternalNetworkServerPermeateClientMappingStoryCommand 保存内网穿透映射对象
* @return {@link LazyInternalNetworkServerPermeateClientMapping} 内网穿透映射领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
LazyInternalNetworkPenetrationMapping toInternalNetworkPenetrationMapping(LazyInternalNetworkPenetrationMappingStoryCommand lazyInternalNetworkPenetrationMappingStoryCommand);
LazyInternalNetworkServerPermeateClientMapping toInternalNetworkPenetrationMapping(LazyInternalNetworkServerPermeateClientMappingStoryCommand lazyInternalNetworkServerPermeateClientMappingStoryCommand);
/**
* describe 应用层更新入参转换成 领域对象
*
* @param lazyInternalNetworkPenetrationMappingUpdateCommand 更新内网穿透映射对象
* @return {@link LazyInternalNetworkPenetrationMapping} 内网穿透映射领域对象
* @param lazyInternalNetworkServerPermeateClientMappingUpdateCommand 更新内网穿透映射对象
* @return {@link LazyInternalNetworkServerPermeateClientMapping} 内网穿透映射领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
LazyInternalNetworkPenetrationMapping toInternalNetworkPenetrationMapping(LazyInternalNetworkPenetrationMappingUpdateCommand lazyInternalNetworkPenetrationMappingUpdateCommand);
LazyInternalNetworkServerPermeateClientMapping toInternalNetworkPenetrationMapping(LazyInternalNetworkServerPermeateClientMappingUpdateCommand lazyInternalNetworkServerPermeateClientMappingUpdateCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyInternalNetworkPenetrationMappingQueryOneCommand 查询单个内网穿透映射对象参数
* @return {@link LazyInternalNetworkPenetrationMapping} 内网穿透映射领域对象
* @param lazyInternalNetworkServerPermeateClientMappingQueryOneCommand 查询单个内网穿透映射对象参数
* @return {@link LazyInternalNetworkServerPermeateClientMapping} 内网穿透映射领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
LazyInternalNetworkPenetrationMapping toInternalNetworkPenetrationMapping(LazyInternalNetworkPenetrationMappingQueryOneCommand lazyInternalNetworkPenetrationMappingQueryOneCommand);
LazyInternalNetworkServerPermeateClientMapping toInternalNetworkPenetrationMapping(LazyInternalNetworkServerPermeateClientMappingQueryOneCommand lazyInternalNetworkServerPermeateClientMappingQueryOneCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyInternalNetworkPenetrationMappingQueryListCommand 查询集合内网穿透映射对象参数
* @return {@link LazyInternalNetworkPenetrationMapping} 内网穿透映射领域对象
* @param lazyInternalNetworkServerPermeateClientMappingQueryListCommand 查询集合内网穿透映射对象参数
* @return {@link LazyInternalNetworkServerPermeateClientMapping} 内网穿透映射领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
LazyInternalNetworkPenetrationMapping toInternalNetworkPenetrationMapping(LazyInternalNetworkPenetrationMappingQueryListCommand lazyInternalNetworkPenetrationMappingQueryListCommand);
LazyInternalNetworkServerPermeateClientMapping toInternalNetworkPenetrationMapping(LazyInternalNetworkServerPermeateClientMappingQueryListCommand lazyInternalNetworkServerPermeateClientMappingQueryListCommand);
/**
* describe 应用层删除入参转换成 领域对象
*
* @param lazyInternalNetworkPenetrationMappingRemoveCommand 删除内网穿透映射对象参数
* @return {@link LazyInternalNetworkPenetrationMapping} 内网穿透映射领域对象
* @param lazyInternalNetworkServerPermeateClientMappingRemoveCommand 删除内网穿透映射对象参数
* @return {@link LazyInternalNetworkServerPermeateClientMapping} 内网穿透映射领域对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
LazyInternalNetworkPenetrationMapping toInternalNetworkPenetrationMapping(LazyInternalNetworkPenetrationMappingRemoveCommand lazyInternalNetworkPenetrationMappingRemoveCommand);
LazyInternalNetworkServerPermeateClientMapping toInternalNetworkPenetrationMapping(LazyInternalNetworkServerPermeateClientMappingRemoveCommand lazyInternalNetworkServerPermeateClientMappingRemoveCommand);
/**
* describe 持久层领域对象转换成DTO对象
*
* @param lazyInternalNetworkPenetrationMapping 内网穿透映射领域对象
* @param lazyInternalNetworkServerPermeateClientMapping 内网穿透映射领域对象
* @return {@link LazyInternalNetworkPenetrationMappingDTO} 内网穿透映射DTO对象
* @author Jia wei Wu
* @date 2023/12/29 05:21 下午
**/
LazyInternalNetworkPenetrationMappingDTO fromInternalNetworkPenetrationMapping(LazyInternalNetworkPenetrationMapping lazyInternalNetworkPenetrationMapping);
LazyInternalNetworkPenetrationMappingDTO fromInternalNetworkPenetrationMapping(LazyInternalNetworkServerPermeateClientMapping lazyInternalNetworkServerPermeateClientMapping);
}

View File

@@ -1,11 +1,11 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateClientMappingDTO;
import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper;

View File

@@ -1,11 +1,11 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateServerMappingDTO;
import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper;

View File

@@ -1,93 +0,0 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMappingRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMappingStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMappingUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMappingQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.server.permeate.mapping.LazyInternalNetworkServerPermeateMappingQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkServerPermeateMappingDTO;
import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper;
/**
* describe 服务端网络渗透映射
*
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler
**/
@Mapper
public interface LazyInternalNetworkServerPermeateMappingDTOAssembler {
/**
* describe MapStruct 创建的代理对象
*
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateMappingDTOAssembler INSTANCE = Mappers.getMapper(LazyInternalNetworkServerPermeateMappingDTOAssembler.class);
/**
* describe 应用层存储入参转换成 领域对象
*
* @param lazyInternalNetworkServerPermeateMappingStoryCommand 保存服务端网络渗透映射对象
* @return {@link LazyInternalNetworkServerPermeateMapping} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateMapping toLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateMappingStoryCommand lazyInternalNetworkServerPermeateMappingStoryCommand);
/**
* describe 应用层更新入参转换成 领域对象
*
* @param lazyInternalNetworkServerPermeateMappingUpdateCommand 更新服务端网络渗透映射对象
* @return {@link LazyInternalNetworkServerPermeateMapping} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateMapping toLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateMappingUpdateCommand lazyInternalNetworkServerPermeateMappingUpdateCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyInternalNetworkServerPermeateMappingQueryOneCommand 查询单个服务端网络渗透映射对象参数
* @return {@link LazyInternalNetworkServerPermeateMapping} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateMapping toLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateMappingQueryOneCommand lazyInternalNetworkServerPermeateMappingQueryOneCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyInternalNetworkServerPermeateMappingQueryListCommand 查询集合服务端网络渗透映射对象参数
* @return {@link LazyInternalNetworkServerPermeateMapping} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateMapping toLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateMappingQueryListCommand lazyInternalNetworkServerPermeateMappingQueryListCommand);
/**
* describe 应用层删除入参转换成 领域对象
*
* @param lazyInternalNetworkServerPermeateMappingRemoveCommand 删除服务端网络渗透映射对象参数
* @return {@link LazyInternalNetworkServerPermeateMapping} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateMapping toLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateMappingRemoveCommand lazyInternalNetworkServerPermeateMappingRemoveCommand);
/**
* describe 持久层领域对象转换成DTO对象
*
* @param lazyInternalNetworkServerPermeateMapping 服务端网络渗透映射领域对象
* @return {@link LazyInternalNetworkServerPermeateMappingDTO} 服务端网络渗透映射DTO对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateMappingDTO fromLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateMapping lazyInternalNetworkServerPermeateMapping);
}

View File

@@ -0,0 +1,89 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.server.mapping.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.server.mapping.LazyInternalNetworkServerPermeateServerMapping;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkServerPermeateMappingDTO;
import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper;
/**
* describe 服务端网络渗透映射
*
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler
**/
@Mapper
public interface LazyInternalNetworkServerPermeateServerMappingDTOAssembler {
/**
* describe MapStruct 创建的代理对象
*
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateServerMappingDTOAssembler INSTANCE = Mappers.getMapper(LazyInternalNetworkServerPermeateServerMappingDTOAssembler.class);
/**
* describe 应用层存储入参转换成 领域对象
*
* @param lazyInternalNetworkServerPermeateServerMappingStoryCommand 保存服务端网络渗透映射对象
* @return {@link LazyInternalNetworkServerPermeateServerMapping} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateServerMapping toLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateServerMappingStoryCommand lazyInternalNetworkServerPermeateServerMappingStoryCommand);
/**
* describe 应用层更新入参转换成 领域对象
*
* @param lazyInternalNetworkServerPermeateServerMappingUpdateCommand 更新服务端网络渗透映射对象
* @return {@link LazyInternalNetworkServerPermeateServerMapping} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateServerMapping toLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateServerMappingUpdateCommand lazyInternalNetworkServerPermeateServerMappingUpdateCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyInternalNetworkServerPermeateServerMappingQueryOneCommand 查询单个服务端网络渗透映射对象参数
* @return {@link LazyInternalNetworkServerPermeateServerMapping} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateServerMapping toLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateServerMappingQueryOneCommand lazyInternalNetworkServerPermeateServerMappingQueryOneCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyInternalNetworkServerPermeateServerMappingQueryListCommand 查询集合服务端网络渗透映射对象参数
* @return {@link LazyInternalNetworkServerPermeateServerMapping} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateServerMapping toLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateServerMappingQueryListCommand lazyInternalNetworkServerPermeateServerMappingQueryListCommand);
/**
* describe 应用层删除入参转换成 领域对象
*
* @param lazyInternalNetworkServerPermeateServerMappingRemoveCommand 删除服务端网络渗透映射对象参数
* @return {@link LazyInternalNetworkServerPermeateServerMapping} 服务端网络渗透映射领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateServerMapping toLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateServerMappingRemoveCommand lazyInternalNetworkServerPermeateServerMappingRemoveCommand);
/**
* describe 持久层领域对象转换成DTO对象
*
* @param lazyInternalNetworkServerPermeateServerMapping 服务端网络渗透映射领域对象
* @return {@link LazyInternalNetworkServerPermeateMappingDTO} 服务端网络渗透映射DTO对象
* @author Jia wei Wu
* @date 2024/09/17 01:35 下午
**/
LazyInternalNetworkServerPermeateMappingDTO fromLazyInternalNetworkServerPermeateMapping(LazyInternalNetworkServerPermeateServerMapping lazyInternalNetworkServerPermeateServerMapping);
}

View File

@@ -0,0 +1,93 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.token.bucket.LazyNettyClientTokenBucket;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket.LazyNettyClientTokenBucketRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket.LazyNettyClientTokenBucketStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket.LazyNettyClientTokenBucketUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket.LazyNettyClientTokenBucketQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket.LazyNettyClientTokenBucketQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientTokenBucketDTO;
import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper;
/**
* describe 客户端令牌桶
*
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler
**/
@Mapper
public interface LazyNettyClientTokenBucketDTOAssembler {
/**
* describe MapStruct 创建的代理对象
*
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
LazyNettyClientTokenBucketDTOAssembler INSTANCE = Mappers.getMapper(LazyNettyClientTokenBucketDTOAssembler.class);
/**
* describe 应用层存储入参转换成 领域对象
*
* @param lazyNettyClientTokenBucketStoryCommand 保存客户端令牌桶对象
* @return {@link LazyNettyClientTokenBucket} 客户端令牌桶领域对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
LazyNettyClientTokenBucket toLazyNettyClientTokenBucket(LazyNettyClientTokenBucketStoryCommand lazyNettyClientTokenBucketStoryCommand);
/**
* describe 应用层更新入参转换成 领域对象
*
* @param lazyNettyClientTokenBucketUpdateCommand 更新客户端令牌桶对象
* @return {@link LazyNettyClientTokenBucket} 客户端令牌桶领域对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
LazyNettyClientTokenBucket toLazyNettyClientTokenBucket(LazyNettyClientTokenBucketUpdateCommand lazyNettyClientTokenBucketUpdateCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyNettyClientTokenBucketQueryOneCommand 查询单个客户端令牌桶对象参数
* @return {@link LazyNettyClientTokenBucket} 客户端令牌桶领域对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
LazyNettyClientTokenBucket toLazyNettyClientTokenBucket(LazyNettyClientTokenBucketQueryOneCommand lazyNettyClientTokenBucketQueryOneCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyNettyClientTokenBucketQueryListCommand 查询集合客户端令牌桶对象参数
* @return {@link LazyNettyClientTokenBucket} 客户端令牌桶领域对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
LazyNettyClientTokenBucket toLazyNettyClientTokenBucket(LazyNettyClientTokenBucketQueryListCommand lazyNettyClientTokenBucketQueryListCommand);
/**
* describe 应用层删除入参转换成 领域对象
*
* @param lazyNettyClientTokenBucketRemoveCommand 删除客户端令牌桶对象参数
* @return {@link LazyNettyClientTokenBucket} 客户端令牌桶领域对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
LazyNettyClientTokenBucket toLazyNettyClientTokenBucket(LazyNettyClientTokenBucketRemoveCommand lazyNettyClientTokenBucketRemoveCommand);
/**
* describe 持久层领域对象转换成DTO对象
*
* @param lazyNettyClientTokenBucket 客户端令牌桶领域对象
* @return {@link LazyNettyClientTokenBucketDTO} 客户端令牌桶DTO对象
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
**/
LazyNettyClientTokenBucketDTO fromLazyNettyClientTokenBucket(LazyNettyClientTokenBucket lazyNettyClientTokenBucket);
}

View File

@@ -1,93 +0,0 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPool;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPoolRemoveCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPoolStoryCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPoolUpdateCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPoolQueryListCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.LazyNettyServerPermeatePortPoolQueryOneCommand;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerPermeatePortPoolDTO;
import org.mapstruct.factory.Mappers;
import org.mapstruct.Mapper;
/**
* describe 服务端内网渗透端口池
*
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler
**/
@Mapper
public interface LazyNettyServerPermeatePortPoolDTOAssembler {
/**
* describe MapStruct 创建的代理对象
*
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
LazyNettyServerPermeatePortPoolDTOAssembler INSTANCE = Mappers.getMapper(LazyNettyServerPermeatePortPoolDTOAssembler.class);
/**
* describe 应用层存储入参转换成 领域对象
*
* @param lazyNettyServerPermeatePortPoolStoryCommand 保存服务端内网渗透端口池对象
* @return {@link LazyNettyServerPermeatePortPool} 服务端内网渗透端口池领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
LazyNettyServerPermeatePortPool toLazyNettyServerPermeatePortPool(LazyNettyServerPermeatePortPoolStoryCommand lazyNettyServerPermeatePortPoolStoryCommand);
/**
* describe 应用层更新入参转换成 领域对象
*
* @param lazyNettyServerPermeatePortPoolUpdateCommand 更新服务端内网渗透端口池对象
* @return {@link LazyNettyServerPermeatePortPool} 服务端内网渗透端口池领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
LazyNettyServerPermeatePortPool toLazyNettyServerPermeatePortPool(LazyNettyServerPermeatePortPoolUpdateCommand lazyNettyServerPermeatePortPoolUpdateCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyNettyServerPermeatePortPoolQueryOneCommand 查询单个服务端内网渗透端口池对象参数
* @return {@link LazyNettyServerPermeatePortPool} 服务端内网渗透端口池领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
LazyNettyServerPermeatePortPool toLazyNettyServerPermeatePortPool(LazyNettyServerPermeatePortPoolQueryOneCommand lazyNettyServerPermeatePortPoolQueryOneCommand);
/**
* describe 应用层查询入参转换成 领域对象
*
* @param lazyNettyServerPermeatePortPoolQueryListCommand 查询集合服务端内网渗透端口池对象参数
* @return {@link LazyNettyServerPermeatePortPool} 服务端内网渗透端口池领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
LazyNettyServerPermeatePortPool toLazyNettyServerPermeatePortPool(LazyNettyServerPermeatePortPoolQueryListCommand lazyNettyServerPermeatePortPoolQueryListCommand);
/**
* describe 应用层删除入参转换成 领域对象
*
* @param lazyNettyServerPermeatePortPoolRemoveCommand 删除服务端内网渗透端口池对象参数
* @return {@link LazyNettyServerPermeatePortPool} 服务端内网渗透端口池领域对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
LazyNettyServerPermeatePortPool toLazyNettyServerPermeatePortPool(LazyNettyServerPermeatePortPoolRemoveCommand lazyNettyServerPermeatePortPoolRemoveCommand);
/**
* describe 持久层领域对象转换成DTO对象
*
* @param lazyNettyServerPermeatePortPool 服务端内网渗透端口池领域对象
* @return {@link LazyNettyServerPermeatePortPoolDTO} 服务端内网渗透端口池DTO对象
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
**/
LazyNettyServerPermeatePortPoolDTO fromLazyNettyServerPermeatePortPool(LazyNettyServerPermeatePortPool lazyNettyServerPermeatePortPool);
}

View File

@@ -1,6 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
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.lazy.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.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
import org.mapstruct.Mapper;

View File

@@ -1,6 +1,6 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.state.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.state.LazyNettyClientState;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyClientStateDTO;
import org.mapstruct.Mapper;

View File

@@ -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.server.visitor.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyNettyServerVisitorDTO;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.visitor.LazyNettyServerVisitor;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.server.visitor.*;
import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.port.pool.LazyNettyServerVisitor;
import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers;
import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyAssembler;

View File

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

View File

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

View File

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

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.netty.client.blacklist;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.blacklist;
import org.wu.framework.web.response.mark.ValidType;

View File

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

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping;
import lombok.Data;
import lombok.experimental.Accessors;

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping;
import lombok.Data;
import lombok.experimental.Accessors;

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping;
import lombok.Data;
import lombok.experimental.Accessors;

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping;
import lombok.Data;
import lombok.experimental.Accessors;
@@ -98,4 +98,11 @@ public class LazyInternalNetworkClientPermeateClientMappingStoryCommand {
@Schema(description ="渗透端口",name ="visitorPort",example = "")
private Integer visitorPort;
/**
* 是否是ssl
*/
@Schema(description ="是否是ssl",name ="is_ssl",example = "")
private Boolean isSsl;
}

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.client.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping;
import lombok.Data;
import lombok.experimental.Accessors;
@@ -98,4 +98,10 @@ public class LazyInternalNetworkClientPermeateClientMappingUpdateCommand {
@Schema(description ="渗透端口",name ="visitorPort",example = "")
private Integer visitorPort;
/**
* 是否是ssl
*/
@Schema(description ="是否是ssl",name ="is_ssl",example = "")
private Boolean isSsl;
}

View File

@@ -44,9 +44,9 @@ public class LazyNettyClientPermeatePortPoolQueryListCommand {
/**
*
* 用户ID
* 主键ID
*/
@Schema(description ="用户ID",name ="id",example = "")
@Schema(description ="主键ID",name ="id",example = "")
private Long id;
/**

View File

@@ -44,9 +44,9 @@ public class LazyNettyClientPermeatePortPoolQueryOneCommand {
/**
*
* 用户ID
* 主键ID
*/
@Schema(description ="用户ID",name ="id",example = "")
@Schema(description ="主键ID",name ="id",example = "")
private Long id;
/**

View File

@@ -44,9 +44,9 @@ public class LazyNettyClientPermeatePortPoolRemoveCommand {
/**
*
* 用户ID
* 主键ID
*/
@Schema(description ="用户ID",name ="id",example = "")
@Schema(description ="主键ID",name ="id",example = "")
private Long id;
/**

View File

@@ -44,9 +44,9 @@ public class LazyNettyClientPermeatePortPoolStoryCommand {
/**
*
* 用户ID
* 主键ID
*/
@Schema(description ="用户ID",name ="id",example = "")
@Schema(description ="主键ID",name ="id",example = "")
private Long id;
/**

View File

@@ -44,9 +44,9 @@ public class LazyNettyClientPermeatePortPoolUpdateCommand {
/**
*
* 用户ID
* 主键ID
*/
@Schema(description ="用户ID",name ="id",example = "")
@Schema(description ="主键ID",name ="id",example = "")
private Long id;
/**

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping;
import lombok.Data;
import lombok.experimental.Accessors;

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping;
import lombok.Data;
import lombok.experimental.Accessors;

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping;
import lombok.Data;
import lombok.experimental.Accessors;

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping;
import lombok.Data;
import lombok.experimental.Accessors;
@@ -91,4 +91,9 @@ public class LazyInternalNetworkClientPermeateServerMappingStoryCommand {
@Schema(description ="渗透端口",name ="visitorPort",example = "")
private Integer visitorPort;
/**
* 是否是ssl
*/
@Schema(description ="是否是ssl",name ="is_ssl",example = "")
private Boolean isSsl;
}

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.internal.network.client.permeate.server.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping;
import lombok.Data;
import lombok.experimental.Accessors;
@@ -91,4 +91,9 @@ public class LazyInternalNetworkClientPermeateServerMappingUpdateCommand {
@Schema(description ="渗透端口",name ="visitorPort",example = "")
private Integer visitorPort;
/**
* 是否是ssl
*/
@Schema(description ="是否是ssl",name ="is_ssl",example = "")
private Boolean isSsl;
}

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket;
import lombok.Data;
import lombok.experimental.Accessors;
@@ -7,18 +7,32 @@ import java.lang.String;
import java.time.LocalDateTime;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端内网渗透端口池
* describe 客户端令牌桶
*
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
* @date 2024/09/28 01:56 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyQueryListCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_server_permeate_port_pool_query_List_command",description = "服务端内网渗透端口池")
public class LazyNettyServerPermeatePortPoolQueryListCommand {
@Schema(title = "lazy_netty_client_token_bucket_query_List_command",description = "客户端令牌桶")
public class LazyNettyClientTokenBucketQueryListCommand {
/**
*
* 令牌key
*/
@Schema(description ="令牌key",name ="appKey",example = "")
private String appKey;
/**
*
* 令牌密钥
*/
@Schema(description ="令牌密钥",name ="appSecret",example = "")
private String appSecret;
/**
*
@@ -36,9 +50,16 @@ public class LazyNettyServerPermeatePortPoolQueryListCommand {
/**
*
* 用户ID
* 过期时间
*/
@Schema(description ="用户ID",name ="id",example = "")
@Schema(description ="过期时间",name ="expireInTime",example = "")
private LocalDateTime expireInTime;
/**
*
* 主键ID
*/
@Schema(description ="主键ID",name ="id",example = "")
private Long id;
/**
@@ -46,28 +67,7 @@ public class LazyNettyServerPermeatePortPoolQueryListCommand {
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted;
/**
*
* 是否被占用
*/
@Schema(description ="是否被占用",name ="isUsed",example = "")
private Boolean isUsed;
/**
*
* 访客端口池大小
*/
@Schema(description ="访客端口池大小",name ="poolSize",example = "")
private Integer poolSize;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
private String serverId;
private Boolean isDeleted=false;
/**
*
@@ -78,9 +78,9 @@ public class LazyNettyServerPermeatePortPoolQueryListCommand {
/**
*
* 访客端口
* 被使用的客户端ID
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
private Integer visitorPort;
@Schema(description ="被使用的客户端ID",name ="usedByClientId",example = "")
private String usedByClientId;
}

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket;
import lombok.Data;
import lombok.experimental.Accessors;
@@ -7,20 +7,33 @@ import java.lang.String;
import java.time.LocalDateTime;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端内网渗透端口池
* describe 客户端令牌桶
*
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
* @date 2024/09/28 01:56 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyQueryOneCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_server_permeate_port_pool_query_one_command",description = "服务端内网渗透端口池")
public class LazyNettyServerPermeatePortPoolQueryOneCommand {
@Schema(title = "lazy_netty_client_token_bucket_query_one_command",description = "客户端令牌桶")
public class LazyNettyClientTokenBucketQueryOneCommand {
/**
*
* 令牌key
*/
@Schema(description ="令牌key",name ="appKey",example = "")
private String appKey;
/**
*
* 令牌密钥
*/
@Schema(description ="令牌密钥",name ="appSecret",example = "")
private String appSecret;
/**
*
* 创建时间
@@ -37,9 +50,16 @@ public class LazyNettyServerPermeatePortPoolQueryOneCommand {
/**
*
* 用户ID
* 过期时间
*/
@Schema(description ="用户ID",name ="id",example = "")
@Schema(description ="过期时间",name ="expireInTime",example = "")
private LocalDateTime expireInTime;
/**
*
* 主键ID
*/
@Schema(description ="主键ID",name ="id",example = "")
private Long id;
/**
@@ -47,28 +67,7 @@ public class LazyNettyServerPermeatePortPoolQueryOneCommand {
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted;
/**
*
* 是否被占用
*/
@Schema(description ="是否被占用",name ="isUsed",example = "")
private Boolean isUsed;
/**
*
* 访客端口池大小
*/
@Schema(description ="访客端口池大小",name ="poolSize",example = "")
private Integer poolSize;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
private String serverId;
private Boolean isDeleted=false;
/**
*
@@ -79,9 +78,9 @@ public class LazyNettyServerPermeatePortPoolQueryOneCommand {
/**
*
* 访客端口
* 被使用的客户端ID
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
private Integer visitorPort;
@Schema(description ="被使用的客户端ID",name ="usedByClientId",example = "")
private String usedByClientId;
}

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.port.pool;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket;
import lombok.Data;
import lombok.experimental.Accessors;
@@ -7,20 +7,33 @@ import java.lang.String;
import java.time.LocalDateTime;
import java.lang.Long;
import java.lang.Boolean;
import java.lang.Integer;
/**
* describe 服务端内网渗透端口池
* describe 客户端令牌桶
*
* @author Jia wei Wu
* @date 2024/09/17 01:26 夜间
* @date 2024/09/28 01:56 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyRemoveCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_server_permeate_port_pool_remove_command",description = "服务端内网渗透端口池")
public class LazyNettyServerPermeatePortPoolRemoveCommand {
@Schema(title = "lazy_netty_client_token_bucket_remove_command",description = "客户端令牌桶")
public class LazyNettyClientTokenBucketRemoveCommand {
/**
*
* 令牌key
*/
@Schema(description ="令牌key",name ="appKey",example = "")
private String appKey;
/**
*
* 令牌密钥
*/
@Schema(description ="令牌密钥",name ="appSecret",example = "")
private String appSecret;
/**
*
* 创建时间
@@ -37,9 +50,16 @@ public class LazyNettyServerPermeatePortPoolRemoveCommand {
/**
*
* 用户ID
* 过期时间
*/
@Schema(description ="用户ID",name ="id",example = "")
@Schema(description ="过期时间",name ="expireInTime",example = "")
private LocalDateTime expireInTime;
/**
*
* 主键ID
*/
@Schema(description ="主键ID",name ="id",example = "")
private Long id;
/**
@@ -49,27 +69,6 @@ public class LazyNettyServerPermeatePortPoolRemoveCommand {
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted;
/**
*
* 是否被占用
*/
@Schema(description ="是否被占用",name ="isUsed",example = "")
private Boolean isUsed;
/**
*
* 访客端口池大小
*/
@Schema(description ="访客端口池大小",name ="poolSize",example = "")
private Integer poolSize;
/**
*
* 服务端ID
*/
@Schema(description ="服务端ID",name ="serverId",example = "")
private String serverId;
/**
*
* 更新时间
@@ -79,9 +78,9 @@ public class LazyNettyServerPermeatePortPoolRemoveCommand {
/**
*
* 访客端口
* 被使用的客户端ID
*/
@Schema(description ="访客端口",name ="visitorPort",example = "")
private Integer visitorPort;
@Schema(description ="被使用的客户端ID",name ="usedByClientId",example = "")
private String usedByClientId;
}

View File

@@ -0,0 +1,45 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket;
import com.fasterxml.jackson.annotation.JsonFormat;
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;
import java.lang.Boolean;
/**
* describe 客户端令牌桶
*
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyStoryCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_client_token_bucket_story_command",description = "客户端令牌桶")
public class LazyNettyClientTokenBucketStoryCommand {
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
/**
*
* 过期时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
@Schema(description ="过期时间",name ="expireInTime",example = "")
private LocalDateTime expireInTime;
/**
*
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted=false;
}

View File

@@ -0,0 +1,65 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.token.bucket;
import com.fasterxml.jackson.annotation.JsonFormat;
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;
import java.lang.Boolean;
/**
* describe 客户端令牌桶
*
* @author Jia wei Wu
* @date 2024/09/28 01:56 下午
* @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyUpdateCommand
**/
@Data
@Accessors(chain = true)
@Schema(title = "lazy_netty_client_token_bucket_update_command",description = "客户端令牌桶")
public class LazyNettyClientTokenBucketUpdateCommand {
/**
*
* 令牌key
*/
@Schema(description ="令牌key",name ="appKey",example = "")
private String appKey;
/**
*
* 令牌密钥
*/
@Schema(description ="令牌密钥",name ="appSecret",example = "")
private String appSecret;
/**
*
* 被使用的客户端ID
*/
@Schema(description ="被使用的客户端ID",name ="usedByClientId",example = "")
private String usedByClientId;
/**
*
* 描述
*/
@Schema(description ="描述",name ="describe",example = "")
private String describe;
/**
*
* 过期时间
*/
@Schema(description ="过期时间",name ="expireInTime",example = "")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private LocalDateTime expireInTime;
/**
*
* 是否删除
*/
@Schema(description ="是否删除",name ="isDeleted",example = "")
private Boolean isDeleted=false;
}

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.internal.network.penetration.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.client.mapping;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@@ -17,7 +17,7 @@ import java.time.LocalDateTime;
@Data
@Accessors(chain = true)
@Schema(title = "internal_network_penetration_mapping_query_List_command", description = "内网穿透映射")
public class LazyInternalNetworkPenetrationMappingQueryListCommand {
public class LazyInternalNetworkServerPermeateClientMappingQueryListCommand {
/**

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.internal.network.penetration.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.client.mapping;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@@ -17,7 +17,7 @@ import java.time.LocalDateTime;
@Data
@Accessors(chain = true)
@Schema(title = "lazy_internal_network_penetration_mapping_query_one_command", description = "内网穿透映射")
public class LazyInternalNetworkPenetrationMappingQueryOneCommand {
public class LazyInternalNetworkServerPermeateClientMappingQueryOneCommand {
/**

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.internal.network.penetration.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.client.mapping;
import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotNull;
@@ -17,7 +17,7 @@ import org.wu.framework.web.response.mark.ValidType;
@Data
@Accessors(chain = true)
@Schema(title = "internal_network_penetration_mapping_remove_command", description = "内网穿透映射")
public class LazyInternalNetworkPenetrationMappingRemoveCommand {
public class LazyInternalNetworkServerPermeateClientMappingRemoveCommand {
/**

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.internal.network.penetration.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.client.mapping;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@@ -15,7 +15,7 @@ import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLaz
@Data
@Accessors(chain = true)
@Schema(title = "internal_network_penetration_mapping_story_command", description = "内网穿透映射")
public class LazyInternalNetworkPenetrationMappingStoryCommand {
public class LazyInternalNetworkServerPermeateClientMappingStoryCommand {
/**
@@ -56,4 +56,10 @@ public class LazyInternalNetworkPenetrationMappingStoryCommand {
*/
@Schema(description = "服务端ID", name = "serverId", example = "")
private String serverId;
/**
* 是否是ssl
*/
@Schema(description ="是否是ssl",name ="is_ssl",example = "")
private Boolean isSsl;
}

View File

@@ -1,4 +1,4 @@
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.internal.network.penetration.mapping;
package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.client.mapping;
import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotNull;
@@ -17,7 +17,7 @@ import org.wu.framework.web.response.mark.ValidType;
@Data
@Accessors(chain = true)
@Schema(title = "internal_network_penetration_mapping_update_command", description = "内网穿透映射")
public class LazyInternalNetworkPenetrationMappingUpdateCommand {
public class LazyInternalNetworkServerPermeateClientMappingUpdateCommand {
/**
* 客户端ID
@@ -61,4 +61,10 @@ public class LazyInternalNetworkPenetrationMappingUpdateCommand {
*/
@Schema(description = "服务端ID", name = "serverId", example = "")
private String serverId;
/**
* 是否是ssl
*/
@Schema(description ="是否是ssl",name ="is_ssl",example = "")
private Boolean isSsl;
}

Some files were not shown because too many files have changed in this diff Show More