file-service update StoreNodeMapper#findByNodeAddrAndHttpPort method

file/file-service/src/main/java/cn/reghao/tnb/file/app/service/StoreNodeService.java

@@ -49,7 +49,8 @@ public class StoreNodeService {
 
     public void addOrUpdate(StoreNodeDto storeNodeDto) {
         String nodeAddr = storeNodeDto.getNodeAddr();
-        StoreNode storeNode = storeNodeMapper.findByNodeAddr(nodeAddr);
+        int httpPort = storeNodeDto.getHttpPort();
+        StoreNode storeNode = storeNodeMapper.findByNodeAddrAndHttpPort(nodeAddr, httpPort);
         if (storeNode == null) {
             storeRepository.saveStoreNode(storeNodeDto);
 

file/file-service/src/main/java/cn/reghao/tnb/file/app/zoss/db/mapper/StoreNodeMapper.java

@@ -3,6 +3,7 @@ package cn.reghao.tnb.file.app.zoss.db.mapper;
 import cn.reghao.jutil.jdk.web.db.BaseMapper;
 import cn.reghao.tnb.file.app.zoss.model.po.StoreNode;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * @author reghao
@@ -10,7 +11,7 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface StoreNodeMapper extends BaseMapper<StoreNode> {
-    StoreNode findByNodeAddr(String nodeAddr);
+    StoreNode findByNodeAddrAndHttpPort(@Param("httpPort") String nodeAddr, @Param("httpPort") int httpPort);
     StoreNode findById(int id);
     StoreNode findFirstStore();
 }

file/file-service/src/main/resources/mapper/oss/StoreNodeMapper.xml

@@ -17,7 +17,7 @@
     <select id="findByNodeAddr" resultType="cn.reghao.tnb.file.app.zoss.model.po.StoreNode">
         select *
         from file_store_node
-        where node_addr=#{nodeAddr}
+        where node_addr=#{nodeAddr} and http_port=#{httpPort}
     </select>
     <select id="findById" resultType="cn.reghao.tnb.file.app.zoss.model.po.StoreNode">
         select *