feat(nifi): 添加创建连接关系功能

- 新增 CreateConnection18、Component18、Revision18 等相关模型类- 在 NifiApiService 中添加 createProcessorConnections 方法用于建立连接关系
- 新增对应的请求和响应模型类，以支持创建连接关系的 API 调用

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Component18.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifi.model.joincreateconnection;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnection
+ * @Project：fw-nifi
+ * @name：Component18
+ * @Date：2025/5/19 15:39
+ * @Filename：Component18
+ */
+@Data
+public class Component18 {
+    private String id;
+    private String parentGroupId;
+    private String backPressureObjectThreshold;
+    private String backPressureDataSizeThreshold;
+    private String flowFileExpiration;
+}

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/CreateConnection18.java

@@ -0,0 +1,23 @@
+package com.hzya.frame.nifi.model.joincreateconnection;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnection
+ * @Project：fw-nifi
+ * @name：CreateConnection
+ * @Date：2025/5/19 15:35
+ * @Filename：CreateConnection
+ */
+@Data
+public class CreateConnection18 {
+    private String id;
+    private String sourceId;
+    private String sourceGroupId;
+    private String sourceType;
+    private String destinationId;
+    private String destinationGroupId;
+    private String destinationType;
+    private Revision18 revision;
+}

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Revision18.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifi.model.joincreateconnection;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnection
+ * @Project：fw-nifi
+ * @name：Revision18
+ * @Date：2025/5/19 15:36
+ * @Filename：Revision18
+ */
+@Data
+public class Revision18 {
+    private String version;
+}

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Component18.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifi.model.joincreateconnections;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：Component17
+ * @Date：2025/5/19 11:58
+ * @Filename：Component17
+ */
+@Data
+public class Component18 {
+    private SourceOrDestination18 source;
+    private SourceOrDestination18 destination;
+    private List<String> selectedRelationships;
+}

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/CreateConnections18.java

@@ -0,0 +1,17 @@
+package com.hzya.frame.nifi.model.joincreateconnections;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：CreateConnections
+ * @Date：2025/5/19 11:56
+ * @Filename：CreateConnections
+ */
+@Data
+public class CreateConnections18 {
+    private Revision18 revision;
+    private Component18 component;
+}

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Revision18.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifi.model.joincreateconnections;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：Revision17
+ * @Date：2025/5/19 11:56
+ * @Filename：Revision17
+ */
+@Data
+public class Revision18 {
+    private String version;
+}

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/SourceOrDestination18.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifi.model.joincreateconnections;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：SourceOrDestination
+ * @Date：2025/5/19 13:39
+ * @Filename：SourceOrDestination
+ */
+@Data
+public class SourceOrDestination18 {
+    private String id;
+    private String groupId;
+    private String type;
+}

fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java

@@ -4,6 +4,8 @@ import cn.hutool.core.util.StrUtil;
 import com.hzya.frame.nifi.client.NifiClient;
 import com.hzya.frame.nifi.model.joinbindparametercontexts.BindParameterContextsJoin11;
 import com.hzya.frame.nifi.model.joincontrollerenabled.EnOrDiControllerServices12;
+import com.hzya.frame.nifi.model.joincreateconnection.CreateConnection18;
+import com.hzya.frame.nifi.model.joincreateconnections.CreateConnections18;
 import com.hzya.frame.nifi.model.joincreatetemp.CreateTemplateJoin;
 import com.hzya.frame.nifi.model.joingetcontroller.ControllerService12;
 import com.hzya.frame.nifi.model.joinparametercontexts.ParameterContextsJoin;
@@ -242,4 +244,11 @@ public class NifiApiService {
     public ProcessorsInfo16 deleteProcessor(String processId, Map<String, String> queryParams) throws Exception {
         return client.delete(StrUtil.format("/processors/{}", processId), queryParams, ProcessorsInfo16.class);
     }
+
+    /**
+     * 建立连接关系
+     */
+    public CreateConnection18 createProcessorConnections(String processGroupsId, CreateConnections18 createConnections17) throws Exception {
+        return client.post(StrUtil.format("/process-groups/{}/connections", processGroupsId), createConnections17, CreateConnection18.class);
+    }
 }