From a37f6ab340e2a61f8ea3f086e71fbf33d0c378a7 Mon Sep 17 00:00:00 2001
From: liuy <37787198+LiuyCodes@users.noreply.github.com>
Date: Fri, 16 May 2025 16:45:17 +0800
Subject: [PATCH] =?UTF-8?q?feat(nifi):=20=E6=B7=BB=E5=8A=A0=E6=8E=A7?=
 =?UTF-8?q?=E5=88=B6=E5=99=A8=E6=9C=8D=E5=8A=A1=E7=9B=B8=E5=85=B3=E5=8A=9F?=
 =?UTF-8?q?=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 新增 ControllerService12、Component12、Revision12 类用于处理控制器服务相关数据
- 在 NifiApiService 中添加获取控制器服务详情和创建流程组级别的控制器服务的方法
---
 .../model/joingetcontroller/Component12.java  |  27 ++++++++++++++++++
 .../ControllerService12.java                  |  18 ++++++++++++
 .../model/joingetcontroller/Properties12.java |  24 ++++++++++++++++
 .../model/joingetcontroller/Revision12.java   |  16 +++++++++++
 .../frame/nifi/service/NifiApiService.java    |  18 ++++++++++++
 .../frame/nifi/service/NifiApiService.class   | Bin 6299 -> 7087 bytes
 6 files changed, 103 insertions(+)
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Component12.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/ControllerService12.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Properties12.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joingetcontroller/Revision12.java

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<String, String> 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 8b751ea721b8d6d147084fe6ae53077c92fbad95..bb656d207ebb4dc53c45a65d0f13d02c826a0ee6 100644
GIT binary patch
literal 7087
zcmb_gX;&Oo8h#20-E`W3odgItj4>{R#gaI#iHV3N5?LZ7#Hi5}O#u~}s<x^+31%|t
ztd2A4jJu!a>wKI!N0~XEqsPzwD38y*Rb5@(b?GJHaHy_(>)!Wy-{)QK^3%`X{Q%%M
z_&S3$%q|RJHG?&*r(vaVRlIJbQAlAk0~<~X#WdbZ!4)68H2e&*D5Y^tw6BZDjWo7W
zcsq@oDf~8rTPTU%-(~O)-p$}WG5Gf>{2`4$rtl{Xo%w=g+P;Q|X7bLazW(->p|85e
zrm5T3s-*{C^*O#z$$`f?<%DHh{z(lZ!%faPx}>3F%2_crbkA6}Iak_THr?~aa)CX$
z87FTPmJHVt?Xa`MU$;CBV@d$ebgx-?Q))F?v=)OVHS3u*{dH&MoFNSGO_vf5EtG8E
z+BBCe&!YHA+je}zw;Y?_o}6*qHQg(^mc1rzzV5gi`m$-*p1x}2eaGF>jc9^CS@NCh
zmTRsMY2TXZPv-Nc=bd*pOk2Z&;iEHGjcbNpFzhvb(HAl~F7v{TyjhfZDg0T(z*{BL
z-8x-xuAg%qG5w6|l#1Sh<In}qQijS2n`Ew_7lR3FVuH)@dO`y6=7y76G%M6vsTMgc
z4Bfj*U8R!KE5cU_8~gIEY4~Qu`jlh)<_(_&f2IzQz@Dp)Wf#ky%7=6Ggp{)!cD$Ym
zuIZHueiM=w<UrbVFdAG|Re)$XQ-}RlwAIj8Dz2z0`Klfzt(vmCw7gWu{8lw%LNG%T
z&eZT`ivij?aJTes*|Q>Q`<Ol~2MTQts<dITvK9S7=$Cw}pwAk`T@J}Mi+b*r#X+jc
z<ms*f)X-a9DYuH{YWZ08&=bilP4=8*B6KZUYqsH+T$W+xY9hC9OYH6jWseA>c&XHI
zMWJaEpt17lS@x<^Q|#Ci6o{ut%w1uz4XU$-{b7l#R^$tXB6V^|mXNp>)fzNg=u{Hq
zqTmJkOZ5$xi+WVH@2)Z@D0ZjrP*ai;rd2g5j*1i+S*@f_+{i}G`n(}xlL@iQLDcX0
zhU?F}i@sB=3E_X&TLna%$f=I&acby0>0)jy)FP)DzQV5)k2F)5T4DFTovf%pYIwCl
zFx`PUT&|ZbyRxS%7j_N*YDA)#Cl>>;7mRio&#9zI?k0AdyF*INgZz8B0cEW#Po`Kb
z1wXD+D41@zFXmEmL6IT#f?Y%)MG49RQF=n^#4*;H1C<eFFtOhD2h}n$hnn0*$!x61
zZkVz^VamjWhRFs_YOEWN0E<q^&6}q!aoE`}PEwUK%fq5DY8X}?L_9{V>G)jc_3{xX
zi^KR!7Qe>5DZHP>D8_ig(Zv?Md^{KrmI7Uz5Hy^)ljB4df5ivfJt^hiyv5^IWy3JP
zeAUeRDf}&qzvDw5t(pT)9yv&n9_8$~a7u8LnBG}ni(AAjKElTu9#p{SH*e{|&VAf9
zxf%0(FN=Q&l6%#ov-l@I5RXrIHmY@jpy+HvwVSTR8V)BBYI+#4EdiEyAo2Y}3ZG{2
z89q+o^DMr=mnnQDf}oNg<6dy!_DGk8Q#%7TRYs&I0usuxOD`zUc;BFc3YDq33}6^l
zf-^dUYiJ)9cM%V$1SPIIIGXvb;R!|cjO~@D3Wn!#<*48V$-w$Jn78$H-WoUs8swU~
z+yU`!-~ta3yhmAe+)aZ3r{Vxp>jo<~gU`;J$6rfIjRQs33>`(sqoC=ypzvc-Lae8b
z?t5svDCV8PE>FYh9fe05yXGXnqGG>tCvf|F1v;!)A`SEP0a{*JHDpP~l(SiMY<X8U
zRrjJsguNOg5-~Bs=xC5R4MlJ*7~-8Fz}h301itm~{V?uBJC3k*8g2XoG9&+kHZuAx
z+WyN{8}8?GAIE@i9e4m;c#uz^HyF*<Lu_%Ll*;9a?|U>hfTR5HB*+MVHL?D1ihw%C
zmd4-o$Tw))M*DyG9sr5a;5Y%04aS53<Lv2R&%^xJ@kl7?DJmvrbPGwjj@+JYbpD7v
zwE`cF3G7x1oCsN%qr!rP0Vy!m@jcR)+D8}vkFH!s%Ffivemcg+K*YuXjeL}<Rn!i7
zIY!|cZ*U(A0iUN;0<cE{?j6l#w{h2x$kxJ4#$b9Pm>xWiCsZ(xOPD7i2ojVpgmw){
zn0=vL+vpai?Fjl}40I?09U|z{JA)p_2_>05aWZLTr^3ql7+{>tXVhdqBdt7%Qz78F
z(8_*kWi8;{7b_8+k)$u74;N#Q{gI9RXaM;v{U(UrAf!l+!35-(aAhtuvR&p;5Z;$1
z;=RGN2yqaT(nyNJbC{xj&r@uW1fu5!_EbkxR~x5*pG5MC3_3%nyohNf`}^bUACT-H
zsEx6e7!`5$&#Ku!OHd6jVI~B;R7J(X7~oj0S4MSjE#k%wRLn+H%wb+-_$;yKB>p+P
ztaL@(;ISMnrYoeyaaXtv@tbyq(5T{y1v0aU^C2_U*;lSA+vp3jkIMCj%EimzR?Hpo
z?7M&^RrXzwbX>$MA*dO;<H+bX4sBy#Rz_$@%h(RcL0-JemEye^HAkW-J%USkmFQ_k
zsfgFwm}KR@B=vX=uPftlFcucMdt@BmQyUfU#|)3h;bnCkUY3Aw;7w&5{wfAICJ<R&
i6NsP0j2(=Oji=-l7zty;1iV80HZ03$K3eovfL{RgyWd{`

delta 1508
zcma)6NmCO+6#jaG%w%dzA_XBNG6q4E1dJ@o=7Jk2C@Qjuf`B0^`xXU74C02%!KyiO
z@dsF?7M2GO9xcoApnt)OC;x)w>n2WGD;6HQ=k@En@4fGPFa5H5r9AQJ=ezd+s_;~Y
zh6_#v(4(Ul7d7;$=;!8uhD$1<ItCF_aaqF^6<7JikcMF$21YcD^79zq#x+c+nA9+(
zVp_)xMz}Yw;~K8(n8k>SIfl&W=um7t&R#DMGInG22kY0ZZyQ@ZCT<$ojC>XI26mvt
zYH;;BZehWC?us~X8%SW0p~m{E`mKawS|0bH;|`XrS$DYjE=m}@k;#GSfw5RTHeD8-
z7>~#1;xm!?1q1gWw)@sc_vh>f1|DKb#j=4%c&y?HLx?c5tt#eS?b`HR2?R(CfFX+)
zLzatd6I<Xw(CW?(BnpJjL3<%GPy{EoVJn@yP-xf5TSQ-O@pwkJzy?MKpqN%Bxwg}n
zagG!cB)fu6jJ{gv4V1TVydqlxPsD!>ghc{F*a0n>Aw(A$<O<U&MHz>(Tsgt=R9J-+
z=1v>6Q?TmG2{)#qY9%&)n~fh4?4nGmtVv!GDubb%IB<c!<P=Cy4HA^chVr12hAs_M
zrGVOvJp!uQ8<C)zBq-B{G6|~s-%vHE6;Lm{GQm~}N+wvBo?xA*svdg<RDNzrGuKKN
z-R?jxIwd%tU6~K-!0n^v1+8bfrDCAg`rIR+f|LmKXZ$@#0qhr*ao+(nP~wAhpPUBr
z93s!3ZE-3T0=fbY(^7DRG&+h#&VbIXG**08{e0ZAta_hc5;`i;k=1ERuTB%;FdV~i
zq0Wl0v^_OR!~dYuY}0AMiFCy`6KIP7K1s!LodS8XPE+dw|F=#&RZ6E*#N{;3Bz0;_
z>SV6z^dZlbbefZNk_WO4XVVR2o1oK<4xv-XU)7(Qq6ED-ixQ<myY+=MU0npHQS12-
V{M~4JS2_t;!8x&a+b_&{;1|x@jbZ=*