[fix] flink cluster node update

Author: isacc

src/main/java/com/github/codingdebugallday/client/api/dto/NodeSettingInfo.java

@@ -22,4 +22,9 @@ public class NodeSettingInfo {
     private String host;
     private String username;
     private String password;
+    /**
+     * 是否需要修改该节点的密码
+     */
+    @Builder.Default
+    private Boolean changePassword = false;
 }

src/main/java/com/github/codingdebugallday/client/app/service/impl/ClusterServiceImpl.java

@@ -213,7 +213,11 @@ private List<Node> genNodeList(ClusterDTO clusterDTO) {
             nodeDTO.setClusterCode(clusterDTO.getClusterCode());
             nodeDTO.setTenantId(clusterDTO.getTenantId());
             NodeSettingInfo nodeSettingInfo = JSON.toObj(nodeDTO.getSettingInfo(), NodeSettingInfo.class);
-            nodeSettingInfo.setPassword(jasyptStringEncryptor.encrypt(nodeSettingInfo.getPassword()));
+            // 第一次新增时对密码进行加密 或者 该节点需要对密码进行更新
+            if (Objects.isNull(nodeDTO.getNodeId()) ||
+                    nodeSettingInfo.getChangePassword()) {
+                nodeSettingInfo.setPassword(jasyptStringEncryptor.encrypt(nodeSettingInfo.getPassword()));
+            }
             nodeDTO.setSettingInfo(JSON.toJson(nodeSettingInfo));
             return NodeConvertMapper.INSTANCE.dtoToEntity(nodeDTO);
         }).collect(Collectors.toList());