diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Component12.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Component12.java new file mode 100644 index 00000000..8d43786a --- /dev/null +++ b/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 properties; + private String validationStatus; + private String bulletinLevel; + private String extensionMissing; + private String comments; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/ControllerService12.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/ControllerService12.java new file mode 100644 index 00000000..511ad7fb --- /dev/null +++ b/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; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Properties12.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Properties12.java new file mode 100644 index 00000000..a8315203 --- /dev/null +++ b/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; +//} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Revision12.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Revision12.java new file mode 100644 index 00000000..b6652b91 --- /dev/null +++ b/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; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java index 5ff590a4..f427c5b6 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java +++ b/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); + } } \ No newline at end of file diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/service/NifiApiService.class b/fw-nifi/target/classes/com/hzya/frame/nifi/service/NifiApiService.class index 8b751ea7..bb656d20 100644 Binary files a/fw-nifi/target/classes/com/hzya/frame/nifi/service/NifiApiService.class and b/fw-nifi/target/classes/com/hzya/frame/nifi/service/NifiApiService.class differ