alsace/wu-lazy-cloud-network
1
0
Fork 0
mirror of https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git synced 2025-06-06 21:37:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

[fix] update visitorPort error

Browse Source
This commit is contained in:
wujiawei 2024-02-06 15:27:44 +08:00
parent cf8d761c50
commit 55191a03ec
2 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/entity/NettyServerVisitorDO.java
View File

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

2
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/infrastructure/persistence/NettyServerVisitorRepositoryImpl.java
View File

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