diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/ChangeDataInit.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/ChangeDataInit.java new file mode 100644 index 0000000..8731b16 --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/ChangeDataInit.java @@ -0,0 +1,51 @@ +package org.framework.lazy.cloud.network.heartbeat.server.init; + + +import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.*; +import org.springframework.boot.CommandLineRunner; +import org.springframework.stereotype.Component; +import org.wu.framework.lazy.orm.database.lambda.stream.lambda.LazyLambdaStream; +import org.wu.framework.lazy.orm.database.lambda.stream.wrapper.LazyWrappers; + +import java.util.List; + +/** + * 数据修改 + */ +@Component +public class ChangeDataInit implements CommandLineRunner { + + private final LazyLambdaStream lazyLambdaStream; + + public ChangeDataInit(LazyLambdaStream lazyLambdaStream) { + this.lazyLambdaStream = lazyLambdaStream; + } + + @Override + public void run(String... args) throws Exception { + // 服务端渗透客户端 统计数 + Long serverPermeateClientCount = lazyLambdaStream.count(LazyWrappers.lambdaWrapper().notNull(LazyInternalNetworkServerPermeateClientMappingDO::getId)); + if (serverPermeateClientCount == 0) { + // 同步数据 + List list = lazyLambdaStream.selectList(LazyWrappers.lambdaWrapper().notNull(LazyInternalNetworkPenetrationMappingDO::getId), LazyInternalNetworkServerPermeateClientMappingDO.class); + lazyLambdaStream.insert(list); + } + + // 服务端渗透服务端 统计数 + Long serverPermeateServerCount = lazyLambdaStream.count(LazyWrappers.lambdaWrapper().notNull(LazyInternalNetworkServerPermeateServerMappingDO::getId)); + if (serverPermeateServerCount == 0) { + // 同步数据 + List list = lazyLambdaStream.selectList(LazyWrappers.lambdaWrapper().notNull(LazyInternalNetworkServerPermeateMappingDO::getId), LazyInternalNetworkServerPermeateServerMappingDO.class); + lazyLambdaStream.insert(list); + } + + // 服务端渗透服务端 统计数 + Long lazyNettyServerPermeatePortPoolCount = lazyLambdaStream.count(LazyWrappers.lambdaWrapper().notNull(LazyNettyServerPermeatePortPoolDO::getId)); + if (lazyNettyServerPermeatePortPoolCount == 0) { + // 同步数据 + List list = lazyLambdaStream.selectList(LazyWrappers.lambdaWrapper().notNull(LazyNettyServerVisitorDO::getId), LazyNettyServerPermeatePortPoolDO.class); + lazyLambdaStream.insert(list); + } + + } +} diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyServerVisitorConverter.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyServerVisitorConverter.java index 2b28ae0..14589a9 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyServerVisitorConverter.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/converter/LazyNettyServerVisitorConverter.java @@ -1,7 +1,7 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.converter; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.port.pool.LazyNettyServerVisitor; -import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyServerVisitorDO; +import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyServerPermeatePortPoolDO; import org.mapstruct.Mapper; import org.mapstruct.factory.Mappers; import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureConverter; @@ -28,20 +28,20 @@ public interface LazyNettyServerVisitorConverter { /** * describe 实体对象 转换成领域对象 * - * @param lazyNettyServerVisitorDO 服务端提前开放出来的端口实体对象 + * @param lazyNettyServerPermeatePortPoolDO 服务端提前开放出来的端口实体对象 * @return {@link LazyNettyServerVisitor} 服务端提前开放出来的端口领域对象 * @author Jia wei Wu * @date 2024/01/16 02:21 下午 **/ - LazyNettyServerVisitor toNettyServerVisitor(LazyNettyServerVisitorDO lazyNettyServerVisitorDO); + LazyNettyServerVisitor toNettyServerVisitor(LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO); /** * describe 领域对象 转换成实体对象 * * @param lazyNettyServerVisitor 服务端提前开放出来的端口领域对象 - * @return {@link LazyNettyServerVisitorDO} 服务端提前开放出来的端口实体对象 + * @return {@link LazyNettyServerPermeatePortPoolDO} 服务端提前开放出来的端口实体对象 * @author Jia wei Wu * @date 2024/01/16 02:21 下午 **/ - LazyNettyServerVisitorDO fromNettyServerVisitor(LazyNettyServerVisitor lazyNettyServerVisitor); + LazyNettyServerPermeatePortPoolDO fromNettyServerVisitor(LazyNettyServerVisitor lazyNettyServerVisitor); } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkPenetrationMappingDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkPenetrationMappingDO.java new file mode 100644 index 0000000..6afe3a9 --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkPenetrationMappingDO.java @@ -0,0 +1,101 @@ +package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity; + + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; +import lombok.experimental.Accessors; +import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity; +import org.wu.framework.lazy.orm.core.stereotype.*; + +import java.time.LocalDateTime; + +/** + * describe 内网穿透映射 + * + * @author Jia wei Wu + * @date 2023/12/29 05:21 下午 + * @see DefaultDDDLazyInfrastructureEntity + **/ +@Deprecated +@Data +@Accessors(chain = true) +@LazyTable(tableName = "lazy_internal_network_penetration_mapping", comment = "内网穿透映射") +@Schema(title = "lazy_internal_network_penetration_mapping", description = "内网穿透映射") +public class LazyInternalNetworkPenetrationMappingDO { + + + /** + * 客户端ID + */ + @Schema(description = "客户端ID", name = "clientId", example = "") + @LazyTableField(name = "client_id", comment = "客户端ID", columnType = "varchar(255)") + private String clientId; + + /** + * 客户端目标地址 + */ + @Schema(description = "客户端目标地址", name = "clientTargetIp", example = "") + @LazyTableField(name = "client_target_ip", comment = "客户端目标地址", columnType = "varchar(255)", defaultValue = "'0.0.0.0'") + private String clientTargetIp; + + /** + * 客户端目标端口 + */ + @Schema(description = "客户端目标端口", name = "clientTargetPort", example = "") + @LazyTableField(name = "client_target_port", comment = "客户端目标端口", columnType = "int", notNull = true) + private Integer clientTargetPort; + + /** + * 创建时间 + */ + @Schema(description = "创建时间", name = "createTime", example = "") + @LazyTableFieldCreateTime + private LocalDateTime createTime; + + /** + * 主键自增 + */ + @Schema(description = "主键自增", name = "id", example = "") + @LazyTableFieldId + private Long id; + + /** + * 是否删除 默认否 + */ + @Schema(description = "是否删除 默认否", name = "isDeleted", example = "") + @LazyTableField(name = "is_deleted", comment = "是否删除 默认否", columnType = "tinyint", defaultValue = "'0'") + private Boolean isDeleted; + + /** + * 修改时间 + */ + @Schema(description = "修改时间", name = "updateTime", example = "") + @LazyTableFieldUpdateTime + private LocalDateTime updateTime; + + /** + * 访问端口 + */ + @Schema(description = "访问端口", name = "visitorPort", example = "") + @LazyTableFieldUnique(comment = "访问端口", notNull = true) + private Integer visitorPort; + /** + * 描述 + */ + @Schema(description = "描述", name = "describe", example = "") + @LazyTableField(comment = "描述") + private String describe; + /** + * 服务端ID + */ + @LazyTableFieldUnique(name = "server_id", comment = "服务端ID") + @Schema(description = "服务端ID", name = "serverId", example = "") + private String serverId; + + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + @LazyTableField(name="is_ssl",comment="是否是ssl",defaultValue = "'0'") + private Boolean isSsl; +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateClientMappingDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateClientMappingDO.java index 5cd63ec..6216a21 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateClientMappingDO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateClientMappingDO.java @@ -10,16 +10,17 @@ import org.wu.framework.lazy.orm.core.stereotype.*; import java.time.LocalDateTime; /** - * describe 内网穿透映射 + * describe 服务端渗透客户端 * * @author Jia wei Wu * @date 2023/12/29 05:21 下午 * @see DefaultDDDLazyInfrastructureEntity + * @see LazyInternalNetworkPenetrationMappingDO **/ @Data @Accessors(chain = true) -@LazyTable(tableName = "lazy_internal_network_penetration_mapping", comment = "内网穿透映射") -@Schema(title = "lazy_internal_network_penetration_mapping", description = "内网穿透映射") +@LazyTable(tableName = "lazy_netty_server_permeate_client_mapping", comment = "服务端渗透客户端") +@Schema(title = "lazy_netty_server_permeate_client_mapping", description = "服务端渗透客户端") public class LazyInternalNetworkServerPermeateClientMappingDO { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateMappingDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateMappingDO.java new file mode 100644 index 0000000..965e7aa --- /dev/null +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateMappingDO.java @@ -0,0 +1,104 @@ +package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; +import lombok.experimental.Accessors; +import org.wu.framework.lazy.orm.core.stereotype.*; + +import java.time.LocalDateTime; + +/** + * describe 服务端网络渗透映射 + * + * @author Jia wei Wu + * @date 2024/09/17 01:35 下午 + * @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity + **/ +@Deprecated +@Data +@Accessors(chain = true) +@LazyTable(tableName = "lazy_internal_network_server_permeate_mapping",comment = "服务端网络渗透映射") +@Schema(title = "lazy_internal_network_server_permeate_mapping",description = "服务端网络渗透映射") +public class LazyInternalNetworkServerPermeateMappingDO { + + + /** + * + * + */ + @Schema(description ="",name ="createTime",example = "") + @LazyTableField(name="create_time",comment="",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra="") + private LocalDateTime createTime; + + /** + * + * 描述 + */ + @Schema(description ="描述",name ="describe",example = "") + @LazyTableField(name="describe",comment="描述",columnType="varchar(255)") + private String describe; + + /** + * + * + */ + @Schema(description ="",name ="id",example = "") + @LazyTableFieldId(name = "id", comment = "") + private Long id; + + /** + * + * 是否删除 默认否 + */ + @Schema(description ="是否删除 默认否",name ="isDeleted",example = "") + @LazyTableField(name="is_deleted",comment="是否删除 默认否",defaultValue="'0'",upsertStrategy = LazyFieldStrategy.NEVER,columnType="tinyint") + private Boolean isDeleted; + + /** + * + * 渗透目标地址 + */ + @Schema(description ="渗透目标地址",name ="permeateTargetIp",example = "") + @LazyTableFieldUnique(name="permeate_target_ip",comment="渗透目标地址",defaultValue="'0.0.0.0'",columnType="varchar(255)") + private String permeateTargetIp; + + /** + * + * 渗透目标端口 + */ + @Schema(description ="渗透目标端口",name ="permeateTargetPort",example = "") + @LazyTableFieldUnique(name="permeate_target_port",comment="渗透目标端口",notNull=true,columnType="int") + private Integer permeateTargetPort; + + /** + * + * 服务端ID + */ + @Schema(description ="服务端ID",name ="serverId",example = "") + @LazyTableField(name="server_id",comment="服务端ID",columnType="varchar(255)") + private String serverId; + + /** + * + * + */ + @Schema(description ="",name ="updateTime",example = "") + @LazyTableField(name="update_time",comment="",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra=" on update CURRENT_TIMESTAMP") + private LocalDateTime updateTime; + + /** + * + * 渗透端口 + */ + @Schema(description ="渗透端口",name ="visitorPort",example = "") + @LazyTableFieldUnique(name="visitor_port",comment="渗透端口",notNull=true,columnType="int") + private Integer visitorPort; + + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + @LazyTableField(name="is_ssl",comment="是否是ssl",defaultValue = "'0'") + private Boolean isSsl; + +} \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateServerMappingDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateServerMappingDO.java index 6484b6a..7d0b36e 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateServerMappingDO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateServerMappingDO.java @@ -22,8 +22,8 @@ import java.lang.Integer; **/ @Data @Accessors(chain = true) -@LazyTable(tableName = "lazy_internal_network_server_permeate_mapping",comment = "服务端网络渗透映射") -@Schema(title = "lazy_internal_network_server_permeate_mapping",description = "服务端网络渗透映射") +@LazyTable(tableName = "lazy_netty_server_permeate_server_mapping",comment = "服务端渗透服务端") +@Schema(title = "lazy_netty_server_permeate_server_mapping",description = "服务端渗透服务端") public class LazyInternalNetworkServerPermeateServerMappingDO { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyServerPermeatePortPoolDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyServerPermeatePortPoolDO.java index 04d298f..12ca7a1 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyServerPermeatePortPoolDO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyServerPermeatePortPoolDO.java @@ -1,104 +1,94 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity; + +import io.swagger.v3.oas.annotations.media.Schema; import lombok.Data; import lombok.experimental.Accessors; -import org.wu.framework.lazy.orm.core.stereotype.LazyTableIndex; -import org.wu.framework.core.stereotype.LayerField; -import org.wu.framework.core.stereotype.LayerField.LayerFieldType; -import org.wu.framework.lazy.orm.core.stereotype.LazyTable; -import org.wu.framework.lazy.orm.core.stereotype.LazyTableField; +import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity; import org.wu.framework.lazy.orm.core.stereotype.*; -import io.swagger.v3.oas.annotations.media.Schema; -import io.swagger.v3.oas.annotations.media.Schema; -import java.lang.String; + import java.time.LocalDateTime; -import org.wu.framework.lazy.orm.core.stereotype.LazyTableFieldId; -import java.lang.Long; -import java.lang.Boolean; -import java.lang.Integer; + /** - * describe 服务端内网渗透端口池 + * describe 服务端提前开放出来的端口 * * @author Jia wei Wu - * @date 2024/09/17 01:26 夜间 - * @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity + * @date 2024/01/16 02:21 下午 + * @see DefaultDDDLazyInfrastructureEntity **/ @Data @Accessors(chain = true) -@LazyTable(tableName = "lazy_netty_server_permeate_port_pool",comment = "服务端内网渗透端口池") -@Schema(title = "lazy_netty_server_permeate_port_pool",description = "服务端内网渗透端口池") +@LazyTable(tableName = "lazy_netty_server_permeate_port_pool", comment = "服务端提前开放出来的端口") +@Schema(title = "lazy_netty_server_permeate_port_pool", description = "服务端提前开放出来的端口") public class LazyNettyServerPermeatePortPoolDO { + /** - * * 创建时间 */ - @Schema(description ="创建时间",name ="createTime",example = "") - @LazyTableField(name="create_time",comment="创建时间",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra=" on update CURRENT_TIMESTAMP") + @Schema(description = "创建时间", name = "createTime", example = "") + @LazyTableField(name = "create_time", comment = "创建时间", defaultValue = "CURRENT_TIMESTAMP", upsertStrategy = LazyFieldStrategy.NEVER, extra = " on update CURRENT_TIMESTAMP") private LocalDateTime createTime; /** - * * 描述 */ - @Schema(description ="描述",name ="describe",example = "") - @LazyTableField(name="describe",comment="描述",columnType="varchar(255)") + @Schema(description = "描述", name = "describe", example = "") + @LazyTableField(name = "describe", comment = "描述", columnType = "varchar(255)") private String describe; /** - * * 主键ID */ - @Schema(description ="主键ID",name ="id",example = "") + @Schema(description = "主键ID", name = "id", example = "") @LazyTableFieldId(name = "id", comment = "主键ID") private Long id; /** - * * 是否删除 */ - @Schema(description ="是否删除",name ="isDeleted",example = "") - @LazyTableField(name="is_deleted",comment="是否删除",columnType="tinyint(1)") + @Schema(description = "是否删除", name = "isDeleted", example = "") + @LazyTableField(name = "is_deleted", comment = "是否删除") private Boolean isDeleted; /** - * - * 是否被占用 - */ - @Schema(description ="是否被占用",name ="isUsed",example = "") - @LazyTableField(name="is_used",comment="是否被占用",columnType="tinyint(1)") - private Boolean isUsed; - - /** - * - * 访客端口池大小 - */ - @Schema(description ="访客端口池大小",name ="poolSize",example = "") - @LazyTableField(name="pool_size",comment="访客端口池大小",defaultValue="'20'",upsertStrategy = LazyFieldStrategy.NEVER,columnType="int") - private Integer poolSize; - - /** - * - * 服务端ID - */ - @Schema(description ="服务端ID",name ="serverId",example = "") - @LazyTableField(name="server_id",comment="服务端ID",notNull=true,columnType="varchar(255)") - private String serverId; - - /** - * * 更新时间 */ - @Schema(description ="更新时间",name ="updateTime",example = "") - @LazyTableField(name="update_time",comment="更新时间",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra=" on update CURRENT_TIMESTAMP") + @Schema(description = "更新时间", name = "updateTime", example = "") + @LazyTableField(name = "update_time", comment = "更新时间", defaultValue = "CURRENT_TIMESTAMP", upsertStrategy = LazyFieldStrategy.NEVER, extra = " on update CURRENT_TIMESTAMP") private LocalDateTime updateTime; /** - * * 访客端口 */ - @Schema(description ="访客端口",name ="visitorPort",example = "") - @LazyTableField(name="visitor_port",comment="访客端口",columnType="int") + @Schema(description = "访客端口", name = "visitorPort", example = "") + @LazyTableFieldUnique(name = "visitor_port", comment = "访客端口", columnType = "int") private Integer visitorPort; + /** + * 访客端口池大小 + */ + @Schema(description = "访客端口池大小", name = "poolSize", example = "") + @LazyTableField(name = "pool_size", comment = "访客端口池大小", columnType = "int",defaultValue = "'20'") + private Integer poolSize; + /** + * 服务端ID + */ + @LazyTableFieldUnique(name = "server_id", comment = "服务端ID",notNull = true) + @Schema(description = "服务端ID", name = "serverId", example = "") + private String serverId; + + + /** + * 类型：服务端内网穿透、服务端内网渗透、客户端渗透服务端、客户端渗透客户端 + */ + + /** + * 是否被占用 + */ + @Schema(description = "是否被占用", name = "isUsed", example = "") + @LazyTableField(name = "is_used", comment = "是否被占用") + private Boolean isUsed; + + } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyServerVisitorDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyServerVisitorDO.java index 8491d12..f72085b 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyServerVisitorDO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyServerVisitorDO.java @@ -1,94 +1,103 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity; - -import io.swagger.v3.oas.annotations.media.Schema; import lombok.Data; import lombok.experimental.Accessors; -import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity; +import org.wu.framework.lazy.orm.core.stereotype.LazyTable; +import org.wu.framework.lazy.orm.core.stereotype.LazyTableField; import org.wu.framework.lazy.orm.core.stereotype.*; +import io.swagger.v3.oas.annotations.media.Schema; +import java.lang.String; import java.time.LocalDateTime; - +import org.wu.framework.lazy.orm.core.stereotype.LazyTableFieldId; +import java.lang.Long; +import java.lang.Boolean; +import java.lang.Integer; /** - * describe 服务端提前开放出来的端口 + * describe 服务端内网渗透端口池 * * @author Jia wei Wu - * @date 2024/01/16 02:21 下午 - * @see DefaultDDDLazyInfrastructureEntity + * @date 2024/09/17 01:26 夜间 + * @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity + * **/ +@Deprecated @Data @Accessors(chain = true) -@LazyTable(tableName = "lazy_netty_server_visitor", comment = "服务端提前开放出来的端口") -@Schema(title = "lazy_netty_server_visitor", description = "服务端提前开放出来的端口") +@LazyTable(tableName = "lazy_netty_server_visitor",comment = "服务端内网渗透端口池") +@Schema(title = "lazy_netty_server_visitor",description = "服务端内网渗透端口池") public class LazyNettyServerVisitorDO { - /** + * * 创建时间 */ - @Schema(description = "创建时间", name = "createTime", example = "") - @LazyTableField(name = "create_time", comment = "创建时间", defaultValue = "CURRENT_TIMESTAMP", upsertStrategy = LazyFieldStrategy.NEVER, extra = " on update CURRENT_TIMESTAMP") + @Schema(description ="创建时间",name ="createTime",example = "") + @LazyTableField(name="create_time",comment="创建时间",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra=" on update CURRENT_TIMESTAMP") private LocalDateTime createTime; /** + * * 描述 */ - @Schema(description = "描述", name = "describe", example = "") - @LazyTableField(name = "describe", comment = "描述", columnType = "varchar(255)") + @Schema(description ="描述",name ="describe",example = "") + @LazyTableField(name="describe",comment="描述",columnType="varchar(255)") private String describe; /** + * * 主键ID */ - @Schema(description = "主键ID", name = "id", example = "") + @Schema(description ="主键ID",name ="id",example = "") @LazyTableFieldId(name = "id", comment = "主键ID") private Long id; /** + * * 是否删除 */ - @Schema(description = "是否删除", name = "isDeleted", example = "") - @LazyTableField(name = "is_deleted", comment = "是否删除") + @Schema(description ="是否删除",name ="isDeleted",example = "") + @LazyTableField(name="is_deleted",comment="是否删除",columnType="tinyint(1)") private Boolean isDeleted; /** + * + * 是否被占用 + */ + @Schema(description ="是否被占用",name ="isUsed",example = "") + @LazyTableField(name="is_used",comment="是否被占用",columnType="tinyint(1)") + private Boolean isUsed; + + /** + * + * 访客端口池大小 + */ + @Schema(description ="访客端口池大小",name ="poolSize",example = "") + @LazyTableField(name="pool_size",comment="访客端口池大小",defaultValue="'20'",upsertStrategy = LazyFieldStrategy.NEVER,columnType="int") + private Integer poolSize; + + /** + * + * 服务端ID + */ + @Schema(description ="服务端ID",name ="serverId",example = "") + @LazyTableField(name="server_id",comment="服务端ID",notNull=true,columnType="varchar(255)") + private String serverId; + + /** + * * 更新时间 */ - @Schema(description = "更新时间", name = "updateTime", example = "") - @LazyTableField(name = "update_time", comment = "更新时间", defaultValue = "CURRENT_TIMESTAMP", upsertStrategy = LazyFieldStrategy.NEVER, extra = " on update CURRENT_TIMESTAMP") + @Schema(description ="更新时间",name ="updateTime",example = "") + @LazyTableField(name="update_time",comment="更新时间",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra=" on update CURRENT_TIMESTAMP") private LocalDateTime updateTime; /** + * * 访客端口 */ - @Schema(description = "访客端口", name = "visitorPort", example = "") - @LazyTableFieldUnique(name = "visitor_port", comment = "访客端口", columnType = "int") + @Schema(description ="访客端口",name ="visitorPort",example = "") + @LazyTableField(name="visitor_port",comment="访客端口",columnType="int") private Integer visitorPort; - /** - * 访客端口池大小 - */ - @Schema(description = "访客端口池大小", name = "poolSize", example = "") - @LazyTableField(name = "pool_size", comment = "访客端口池大小", columnType = "int",defaultValue = "'20'") - private Integer poolSize; - /** - * 服务端ID - */ - @LazyTableFieldUnique(name = "server_id", comment = "服务端ID",notNull = true) - @Schema(description = "服务端ID", name = "serverId", example = "") - private String serverId; - - - /** - * 类型：服务端内网穿透、服务端内网渗透、客户端渗透服务端、客户端渗透客户端 - */ - - /** - * 是否被占用 - */ - @Schema(description = "是否被占用", name = "isUsed", example = "") - @LazyTableField(name = "is_used", comment = "是否被占用") - private Boolean isUsed; - - } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/jpa/lazy/LazyNettyServerPermeatePortPoolLazyJpaRepository.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/jpa/lazy/LazyNettyServerPermeatePortPoolLazyJpaRepository.java index 931784d..d80464b 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/jpa/lazy/LazyNettyServerPermeatePortPoolLazyJpaRepository.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/jpa/lazy/LazyNettyServerPermeatePortPoolLazyJpaRepository.java @@ -1,8 +1,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.jpa.lazy; +import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyServerPermeatePortPoolDO; import org.wu.framework.lazy.orm.database.jpa.repository.LazyJpaRepository; import org.wu.framework.lazy.orm.database.jpa.repository.annotation.*; -import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyServerPermeatePortPoolDO; /** * describe 服务端内网渗透端口池 * diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyServerVisitorRepositoryImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyServerVisitorRepositoryImpl.java index 1e994ad..592467c 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyServerVisitorRepositoryImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/persistence/LazyNettyServerVisitorRepositoryImpl.java @@ -2,7 +2,7 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastruct import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.port.pool.LazyNettyServerVisitor; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.port.pool.LazyNettyServerVisitorRepository; -import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyServerVisitorDO; +import org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyServerPermeatePortPoolDO; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.lazy.orm.database.lambda.stream.lambda.LazyLambdaStream; import org.wu.framework.lazy.orm.database.lambda.stream.wrapper.LazyWrappers; @@ -40,8 +40,8 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi @Override public Result story(LazyNettyServerVisitor lazyNettyServerVisitor) { - LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); - lazyLambdaStream.upsertRemoveNull(lazyNettyServerVisitorDO); + LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); + lazyLambdaStream.upsertRemoveNull(lazyNettyServerPermeatePortPoolDO); return ResultFactory.successOf(); } @@ -56,8 +56,8 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi @Override public Result> batchStory(List lazyNettyServerVisitorList) { - List lazyNettyServerVisitorDOList = lazyNettyServerVisitorList.stream().map(LazyNettyServerVisitorConverter.INSTANCE::fromNettyServerVisitor).collect(Collectors.toList()); - lazyLambdaStream.upsert(lazyNettyServerVisitorDOList); + List lazyNettyServerPermeatePortPoolDOList = lazyNettyServerVisitorList.stream().map(LazyNettyServerVisitorConverter.INSTANCE::fromNettyServerVisitor).collect(Collectors.toList()); + lazyLambdaStream.upsert(lazyNettyServerPermeatePortPoolDOList); return ResultFactory.successOf(); } @@ -72,8 +72,8 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi @Override public Result findOne(LazyNettyServerVisitor lazyNettyServerVisitor) { - LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); - LazyNettyServerVisitor lazyNettyServerVisitorOne = lazyLambdaStream.selectOne(LazyWrappers.lambdaWrapperBean(lazyNettyServerVisitorDO), LazyNettyServerVisitor.class); + LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); + LazyNettyServerVisitor lazyNettyServerVisitorOne = lazyLambdaStream.selectOne(LazyWrappers.lambdaWrapperBean(lazyNettyServerPermeatePortPoolDO), LazyNettyServerVisitor.class); return ResultFactory.successOf(lazyNettyServerVisitorOne); } @@ -88,11 +88,11 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi @Override public Result> findList(LazyNettyServerVisitor lazyNettyServerVisitor) { - LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); + LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); List lazyNettyServerVisitorList = lazyLambdaStream .selectList( - LazyWrappers.lambdaWrapperBean(lazyNettyServerVisitorDO) - .orderByDesc(LazyNettyServerVisitorDO::getCreateTime) + LazyWrappers.lambdaWrapperBean(lazyNettyServerPermeatePortPoolDO) + .orderByDesc(LazyNettyServerPermeatePortPoolDO::getCreateTime) , LazyNettyServerVisitor.class); return ResultFactory.successOf(lazyNettyServerVisitorList); } @@ -110,12 +110,12 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi @Override public Result> findPage(int size, int current, LazyNettyServerVisitor lazyNettyServerVisitor) { - LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); + LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); LazyPage lazyPage = new LazyPage<>(current, size); LazyPage nettyServerVisitorLazyPage = lazyLambdaStream .selectPage( - LazyWrappers.lambdaWrapperBean(lazyNettyServerVisitorDO) - .orderByDesc(LazyNettyServerVisitorDO::getCreateTime) + LazyWrappers.lambdaWrapperBean(lazyNettyServerPermeatePortPoolDO) + .orderByDesc(LazyNettyServerPermeatePortPoolDO::getCreateTime) , lazyPage, LazyNettyServerVisitor.class); return ResultFactory.successOf(nettyServerVisitorLazyPage); } @@ -131,8 +131,8 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi @Override public Result remove(LazyNettyServerVisitor lazyNettyServerVisitor) { - LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); - lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(lazyNettyServerVisitorDO)); + LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); + lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(lazyNettyServerPermeatePortPoolDO)); return ResultFactory.successOf(); } @@ -147,8 +147,8 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi @Override public Result exists(LazyNettyServerVisitor lazyNettyServerVisitor) { - LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); - Boolean exists = lazyLambdaStream.exists(LazyWrappers.lambdaWrapperBean(lazyNettyServerVisitorDO)); + LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor); + Boolean exists = lazyLambdaStream.exists(LazyWrappers.lambdaWrapperBean(lazyNettyServerPermeatePortPoolDO)); return ResultFactory.successOf(exists); }