feat(nifi): 添加控制器服务相关功能

- 新增 ControllerService12、Component12、Revision12 类用于处理控制器服务相关数据
- 在 NifiApiService 中添加获取控制器服务详情和创建流程组级别的控制器服务的方法

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Component12.java

@@ -0,0 +1,27 @@
+package com.hzya.frame.nifi.model.joingetcontroller;
+
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joingetcontroller
+ * @Project：fw-nifi
+ * @name：Component11
+ * @Date：2025/5/16 13:59
+ * @Filename：Component11
+ */
+@Data
+public class Component12 {
+    private String id;
+    private String name;
+    private String type;
+    private String state;
+    //每个不同类型的控制器服务对应的属性都不一样，这里就很坑
+    private Map<String, String> properties;
+    private String validationStatus;
+    private String bulletinLevel;
+    private String extensionMissing;
+    private String comments;
+}

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/ControllerService12.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifi.model.joingetcontroller;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joingetcontroller
+ * @Project：fw-nifi
+ * @name：ControllerSerbices
+ * @Date：2025/5/16 13:57
+ * @Filename：ControllerSerbices
+ */
+@Data
+public class ControllerService12 {
+    private String id;
+    private Revision12 revision;
+    private Component12 component;
+}

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Properties12.java

@@ -0,0 +1,24 @@
+//package com.hzya.frame.nifi.model.joingetcontroller;
+//
+//import lombok.Data;
+//
+///**
+// * @Author：liuyang
+// * @Package：com.hzya.frame.nifi.model.joingetcontroller
+// * @Project：fw-nifi
+// * @name：Properties11
+// * @Date：2025/5/16 14:00
+// * @Filename：Properties11
+// */
+//@Data
+//public class Properties11 {
+//    private String databaseConnectionUrl;
+//    private String databaseDriverClassName;
+//    private String databaseDriverLocations;
+//    private String databaseUser;
+//    private String password;
+//    private String maxWaitTime;
+//    private String maxTotalConnections;
+//    private String validationQuery;
+//    private String dbcpMinIdleConns;
+//}

fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Revision12.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifi.model.joingetcontroller;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joingetcontroller
+ * @Project：fw-nifi
+ * @name：Revision11
+ * @Date：2025/5/16 13:58
+ * @Filename：Revision11
+ */
+@Data
+public class Revision12 {
+    private String version;
+}

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

@@ -3,6 +3,7 @@ package com.hzya.frame.nifi.service;
 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.joingetcontroller.ControllerService12;
 import com.hzya.frame.nifi.model.joinparametercontexts.ParameterContextsJoin;
 import com.hzya.frame.nifi.model.joinprocessgroups.ProcessGroupsJoin;
 import com.hzya.frame.nifi.model.joinstartorstopprocessgroup.StartOrStopProcessGroupsInfoJoin10;
@@ -127,4 +128,21 @@ public class NifiApiService {
         String id = bindParameterContextsJoin.getComponent().getId();
         return client.put(StrUtil.format("/process-groups/{}", id), bindParameterContextsJoin, ProcessGroupsInfoResult9.class);
     }
+
+    /**
+     * 查询控制器服务详情
+     */
+    public ControllerService12 getControllerServices(String controllerServicesId) throws Exception {
+        return client.get(StrUtil.format("/controller-services/{}", controllerServicesId), ControllerService12.class);
+    }
+
+    /**
+     * 创建流程组组级别的控制器服务,控制器服务分为流程组级别和全局级别，其中流程组级别只能在流程组内的处理器共享
+     *
+     * @param id                  对应的流程组id
+     * @param controllerService11 提交参数
+     */
+    public ControllerService12 createControllerServices(String id, ControllerService12 controllerService11) throws Exception {
+        return client.post(StrUtil.format("/process-groups/{}/controller-services", id), controllerService11, ControllerService12.class);
+    }
 }