[fix] 表名称调整

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.<LazyInternalNetworkServerPermeateClientMappingDO>lambdaWrapper().notNull(LazyInternalNetworkServerPermeateClientMappingDO::getId));
+        if (serverPermeateClientCount == 0) {
+            // 同步数据
+            List<LazyInternalNetworkServerPermeateClientMappingDO> list = lazyLambdaStream.selectList(LazyWrappers.<LazyInternalNetworkPenetrationMappingDO>lambdaWrapper().notNull(LazyInternalNetworkPenetrationMappingDO::getId), LazyInternalNetworkServerPermeateClientMappingDO.class);
+            lazyLambdaStream.insert(list);
+        }
+
+        // 服务端渗透服务端 统计数
+        Long serverPermeateServerCount = lazyLambdaStream.count(LazyWrappers.<LazyInternalNetworkServerPermeateServerMappingDO>lambdaWrapper().notNull(LazyInternalNetworkServerPermeateServerMappingDO::getId));
+        if (serverPermeateServerCount == 0) {
+            // 同步数据
+            List<LazyInternalNetworkServerPermeateServerMappingDO> list = lazyLambdaStream.selectList(LazyWrappers.<LazyInternalNetworkServerPermeateMappingDO>lambdaWrapper().notNull(LazyInternalNetworkServerPermeateMappingDO::getId), LazyInternalNetworkServerPermeateServerMappingDO.class);
+            lazyLambdaStream.insert(list);
+        }
+
+        // 服务端渗透服务端 统计数
+        Long lazyNettyServerPermeatePortPoolCount = lazyLambdaStream.count(LazyWrappers.<LazyNettyServerPermeatePortPoolDO>lambdaWrapper().notNull(LazyNettyServerPermeatePortPoolDO::getId));
+        if (lazyNettyServerPermeatePortPoolCount == 0) {
+            // 同步数据
+            List<LazyNettyServerPermeatePortPoolDO> list = lazyLambdaStream.selectList(LazyWrappers.<LazyNettyServerVisitorDO>lambdaWrapper().notNull(LazyNettyServerVisitorDO::getId), LazyNettyServerPermeatePortPoolDO.class);
+            lazyLambdaStream.insert(list);
+        }
+
+    }
+}

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);
 }

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;
+}

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 = "内网穿透映射")
+@LazyTable(tableName = "lazy_netty_server_permeate_client_mapping", comment = "服务端渗透客户端")
-@Schema(title = "lazy_internal_network_penetration_mapping", description = "内网穿透映射")
+@Schema(title = "lazy_netty_server_permeate_client_mapping", description = "服务端渗透客户端")
 public class LazyInternalNetworkServerPermeateClientMappingDO {
 
 

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;
+
+}

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 = "服务端网络渗透映射")
+@LazyTable(tableName = "lazy_netty_server_permeate_server_mapping",comment = "服务端渗透服务端")
-@Schema(title = "lazy_internal_network_server_permeate_mapping",description = "服务端网络渗透映射")
+@Schema(title = "lazy_netty_server_permeate_server_mapping",description = "服务端渗透服务端")
 public class LazyInternalNetworkServerPermeateServerMappingDO {
 
 

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.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity;
-import org.wu.framework.core.stereotype.LayerField;
-import org.wu.framework.core.stereotype.LayerField.LayerFieldType;
-import org.wu.framework.lazy.orm.core.stereotype.LazyTable;
-import org.wu.framework.lazy.orm.core.stereotype.LazyTableField;
 import org.wu.framework.lazy.orm.core.stereotype.*;
-import io.swagger.v3.oas.annotations.media.Schema;
+
-import io.swagger.v3.oas.annotations.media.Schema;
-import java.lang.String;
 import java.time.LocalDateTime;
-import org.wu.framework.lazy.orm.core.stereotype.LazyTableFieldId;
+
-import java.lang.Long;
-import java.lang.Boolean;
-import java.lang.Integer;
 /**
- * describe 服务端内网渗透端口池 
+ * describe 服务端提前开放出来的端口
  *
  * @author Jia wei Wu
- * @date 2024/09/17 01:26 夜间
+ * @date 2024/01/16 02:21 下午
- * @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity 
+ * @see DefaultDDDLazyInfrastructureEntity
  **/
 @Data
 @Accessors(chain = true)
-@LazyTable(tableName = "lazy_netty_server_permeate_port_pool",comment = "服务端内网渗透端口池")
+@LazyTable(tableName = "lazy_netty_server_permeate_port_pool", comment = "服务端提前开放出来的端口")
-@Schema(title = "lazy_netty_server_permeate_port_pool",description = "服务端内网渗透端口池")
+@Schema(title = "lazy_netty_server_permeate_port_pool", description = "服务端提前开放出来的端口")
 public class LazyNettyServerPermeatePortPoolDO {
 
+
     /**
-     * 
      * 创建时间
      */
-    @Schema(description ="创建时间",name ="createTime",example = "")
+    @Schema(description = "创建时间", name = "createTime", example = "")
-    @LazyTableField(name="create_time",comment="创建时间",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra=" on update CURRENT_TIMESTAMP")
+    @LazyTableField(name = "create_time", comment = "创建时间", defaultValue = "CURRENT_TIMESTAMP", upsertStrategy = LazyFieldStrategy.NEVER, extra = " on update CURRENT_TIMESTAMP")
     private LocalDateTime createTime;
 
     /**
-     * 
      * 描述
      */
-    @Schema(description ="描述",name ="describe",example = "")
+    @Schema(description = "描述", name = "describe", example = "")
-    @LazyTableField(name="describe",comment="描述",columnType="varchar(255)")
+    @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 = "")
+    @Schema(description = "是否删除", name = "isDeleted", example = "")
-    @LazyTableField(name="is_deleted",comment="是否删除",columnType="tinyint(1)")
+    @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 = "")
+    @Schema(description = "更新时间", name = "updateTime", example = "")
-    @LazyTableField(name="update_time",comment="更新时间",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra=" on update CURRENT_TIMESTAMP")
+    @LazyTableField(name = "update_time", comment = "更新时间", defaultValue = "CURRENT_TIMESTAMP", upsertStrategy = LazyFieldStrategy.NEVER, extra = " on update CURRENT_TIMESTAMP")
     private LocalDateTime updateTime;
 
     /**
-     * 
      * 访客端口
      */
-    @Schema(description ="访客端口",name ="visitorPort",example = "")
+    @Schema(description = "访客端口", name = "visitorPort", example = "")
-    @LazyTableField(name="visitor_port",comment="访客端口",columnType="int")
+    @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;
+
+
 }

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 下午
+ * @date 2024/09/17 01:26 夜间
- * @see DefaultDDDLazyInfrastructureEntity
+ * @see org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyInfrastructureEntity
+ *
  **/
+@Deprecated
 @Data
 @Accessors(chain = true)
-@LazyTable(tableName = "lazy_netty_server_visitor", comment = "服务端提前开放出来的端口")
+@LazyTable(tableName = "lazy_netty_server_visitor",comment = "服务端内网渗透端口池")
-@Schema(title = "lazy_netty_server_visitor", description = "服务端提前开放出来的端口")
+@Schema(title = "lazy_netty_server_visitor",description = "服务端内网渗透端口池")
 public class LazyNettyServerVisitorDO {
 
-
     /**
+     *
      * 创建时间
      */
-    @Schema(description = "创建时间", name = "createTime", example = "")
+    @Schema(description ="创建时间",name ="createTime",example = "")
-    @LazyTableField(name = "create_time", comment = "创建时间", defaultValue = "CURRENT_TIMESTAMP", upsertStrategy = LazyFieldStrategy.NEVER, extra = " on update CURRENT_TIMESTAMP")
+    @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 = "")
+    @Schema(description ="描述",name ="describe",example = "")
-    @LazyTableField(name = "describe", comment = "描述", columnType = "varchar(255)")
+    @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 = "")
+    @Schema(description ="是否删除",name ="isDeleted",example = "")
-    @LazyTableField(name = "is_deleted", comment = "是否删除")
+    @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 = "")
+    @Schema(description ="更新时间",name ="updateTime",example = "")
-    @LazyTableField(name = "update_time", comment = "更新时间", defaultValue = "CURRENT_TIMESTAMP", upsertStrategy = LazyFieldStrategy.NEVER, extra = " on update CURRENT_TIMESTAMP")
+    @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 = "")
+    @Schema(description ="访客端口",name ="visitorPort",example = "")
-    @LazyTableFieldUnique(name = "visitor_port", comment = "访客端口", columnType = "int")
+    @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;
-
-
 }

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 服务端内网渗透端口池 
  *

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<LazyNettyServerVisitor> story(LazyNettyServerVisitor lazyNettyServerVisitor) {
-        LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
+        LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
-        lazyLambdaStream.upsertRemoveNull(lazyNettyServerVisitorDO);
+        lazyLambdaStream.upsertRemoveNull(lazyNettyServerPermeatePortPoolDO);
         return ResultFactory.successOf();
     }
 
@@ -56,8 +56,8 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi
 
     @Override
     public Result<List<LazyNettyServerVisitor>> batchStory(List<LazyNettyServerVisitor> lazyNettyServerVisitorList) {
-        List<LazyNettyServerVisitorDO> lazyNettyServerVisitorDOList = lazyNettyServerVisitorList.stream().map(LazyNettyServerVisitorConverter.INSTANCE::fromNettyServerVisitor).collect(Collectors.toList());
+        List<LazyNettyServerPermeatePortPoolDO> lazyNettyServerPermeatePortPoolDOList = lazyNettyServerVisitorList.stream().map(LazyNettyServerVisitorConverter.INSTANCE::fromNettyServerVisitor).collect(Collectors.toList());
-        lazyLambdaStream.upsert(lazyNettyServerVisitorDOList);
+        lazyLambdaStream.upsert(lazyNettyServerPermeatePortPoolDOList);
         return ResultFactory.successOf();
     }
 
@@ -72,8 +72,8 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi
 
     @Override
     public Result<LazyNettyServerVisitor> findOne(LazyNettyServerVisitor lazyNettyServerVisitor) {
-        LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
+        LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
-        LazyNettyServerVisitor lazyNettyServerVisitorOne = lazyLambdaStream.selectOne(LazyWrappers.lambdaWrapperBean(lazyNettyServerVisitorDO), LazyNettyServerVisitor.class);
+        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<List<LazyNettyServerVisitor>> findList(LazyNettyServerVisitor lazyNettyServerVisitor) {
-        LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
+        LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
         List<LazyNettyServerVisitor> lazyNettyServerVisitorList = lazyLambdaStream
                 .selectList(
-                        LazyWrappers.lambdaWrapperBean(lazyNettyServerVisitorDO)
+                        LazyWrappers.lambdaWrapperBean(lazyNettyServerPermeatePortPoolDO)
-                                .orderByDesc(LazyNettyServerVisitorDO::getCreateTime)
+                                .orderByDesc(LazyNettyServerPermeatePortPoolDO::getCreateTime)
                         , LazyNettyServerVisitor.class);
         return ResultFactory.successOf(lazyNettyServerVisitorList);
     }
@@ -110,12 +110,12 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi
 
     @Override
     public Result<LazyPage<LazyNettyServerVisitor>> findPage(int size, int current, LazyNettyServerVisitor lazyNettyServerVisitor) {
-        LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
+        LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
         LazyPage<LazyNettyServerVisitor> lazyPage = new LazyPage<>(current, size);
         LazyPage<LazyNettyServerVisitor> nettyServerVisitorLazyPage = lazyLambdaStream
                 .selectPage(
-                        LazyWrappers.lambdaWrapperBean(lazyNettyServerVisitorDO)
+                        LazyWrappers.lambdaWrapperBean(lazyNettyServerPermeatePortPoolDO)
-                                .orderByDesc(LazyNettyServerVisitorDO::getCreateTime)
+                                .orderByDesc(LazyNettyServerPermeatePortPoolDO::getCreateTime)
                         , lazyPage, LazyNettyServerVisitor.class);
         return ResultFactory.successOf(nettyServerVisitorLazyPage);
     }
@@ -131,8 +131,8 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi
 
     @Override
     public Result<LazyNettyServerVisitor> remove(LazyNettyServerVisitor lazyNettyServerVisitor) {
-        LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
+        LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
-        lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(lazyNettyServerVisitorDO));
+        lazyLambdaStream.delete(LazyWrappers.lambdaWrapperBean(lazyNettyServerPermeatePortPoolDO));
         return ResultFactory.successOf();
     }
 
@@ -147,8 +147,8 @@ public class LazyNettyServerVisitorRepositoryImpl implements LazyNettyServerVisi
 
     @Override
     public Result<Boolean> exists(LazyNettyServerVisitor lazyNettyServerVisitor) {
-        LazyNettyServerVisitorDO lazyNettyServerVisitorDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
+        LazyNettyServerPermeatePortPoolDO lazyNettyServerPermeatePortPoolDO = LazyNettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(lazyNettyServerVisitor);
-        Boolean exists = lazyLambdaStream.exists(LazyWrappers.lambdaWrapperBean(lazyNettyServerVisitorDO));
+        Boolean exists = lazyLambdaStream.exists(LazyWrappers.lambdaWrapperBean(lazyNettyServerPermeatePortPoolDO));
         return ResultFactory.successOf(exists);
     }