diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/entity/NettyServerVisitorDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/entity/NettyServerVisitorDO.java index ab6a819..12df722 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/entity/NettyServerVisitorDO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/entity/NettyServerVisitorDO.java @@ -1,9 +1,6 @@ package wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity; -import com.wu.framework.inner.lazy.stereotype.LazyFieldStrategy; -import com.wu.framework.inner.lazy.stereotype.LazyTable; -import com.wu.framework.inner.lazy.stereotype.LazyTableField; -import com.wu.framework.inner.lazy.stereotype.LazyTableFieldId; +import com.wu.framework.inner.lazy.stereotype.*; import io.swagger.v3.oas.annotations.media.Schema; import lombok.Data; import lombok.experimental.Accessors; @@ -63,7 +60,7 @@ public class NettyServerVisitorDO { * 访客端口 */ @Schema(description = "访客端口", name = "visitorPort", example = "") - @LazyTableField(name = "visitor_port", comment = "访客端口", columnType = "int") + @LazyTableFieldUnique(name = "visitor_port", comment = "访客端口", columnType = "int") private Integer visitorPort; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/persistence/NettyServerVisitorRepositoryImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/persistence/NettyServerVisitorRepositoryImpl.java index 22ec8eb..05a861b 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/persistence/NettyServerVisitorRepositoryImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/persistence/NettyServerVisitorRepositoryImpl.java @@ -40,7 +40,7 @@ public class NettyServerVisitorRepositoryImpl implements NettyServerVisitorRepos @Override public Result story(NettyServerVisitor nettyServerVisitor) { NettyServerVisitorDO nettyServerVisitorDO = NettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(nettyServerVisitor); - lazyLambdaStream.upsert(nettyServerVisitorDO); + lazyLambdaStream.upsertRemoveNull(nettyServerVisitorDO); return ResultFactory.successOf(); }