From 55191a03ec91ee51b93d2b9d9191073516ed5b7e Mon Sep 17 00:00:00 2001
From: wujiawei <12345678>
Date: Tue, 6 Feb 2024 15:27:44 +0800
Subject: [PATCH] [fix] update visitorPort error

---
 .../server/infrastructure/entity/NettyServerVisitorDO.java | 7 ++-----
 .../persistence/NettyServerVisitorRepositoryImpl.java      | 2 +-
 2 files changed, 3 insertions(+), 6 deletions(-)

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<NettyServerVisitor> story(NettyServerVisitor nettyServerVisitor) {
         NettyServerVisitorDO nettyServerVisitorDO = NettyServerVisitorConverter.INSTANCE.fromNettyServerVisitor(nettyServerVisitor);
-        lazyLambdaStream.upsert(nettyServerVisitorDO);
+        lazyLambdaStream.upsertRemoveNull(nettyServerVisitorDO);
         return ResultFactory.successOf();
     }