diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java index 58748595..5b307b48 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java @@ -86,6 +86,15 @@ public class NifiClient { }); } + public T put(String path, Object requestBody, Class responseType) throws IOException { + String jsonBody = objectMapper.writeValueAsString(requestBody); + RequestBody body = RequestBody.create(jsonBody, MediaType.get("application/json; charset=utf-8")); + return executeRequestWithRetry(() -> { + Request request = new Request.Builder().url(config.getApiUrl() + path).put(body).header("Authorization", "Bearer " + accessToken.get()).build(); + return executeRequest(request, responseType); + }); + } + private T executeRequestWithRetry(IOExceptionRunnable runnable) throws IOException { int maxRetries = 2; for (int attempt = 0; attempt < maxRetries; attempt++) { diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/BindParameterContextsJoin11.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/BindParameterContextsJoin11.java new file mode 100644 index 00000000..df0ada05 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/BindParameterContextsJoin11.java @@ -0,0 +1,15 @@ +package com.hzya.frame.nifi.model.joinbindparametercontexts; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 11:1:46 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class BindParameterContextsJoin11 { + private Revision11 revision; + private Component11 component; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Component11.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Component11.java new file mode 100644 index 00000000..b539d353 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Component11.java @@ -0,0 +1,15 @@ +package com.hzya.frame.nifi.model.joinbindparametercontexts; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 11:1:46 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Component11 { + private String id; + private ParameterContext11 parameterContext; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/ParameterContext11.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/ParameterContext11.java new file mode 100644 index 00000000..8a697d39 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/ParameterContext11.java @@ -0,0 +1,8 @@ +package com.hzya.frame.nifi.model.joinbindparametercontexts; + +import lombok.Data; + +@Data +public class ParameterContext11 { + private String id; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Revision11.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Revision11.java new file mode 100644 index 00000000..8ee88871 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Revision11.java @@ -0,0 +1,17 @@ +/** + * Copyright 2025 bejson.com + */ +package com.hzya.frame.nifi.model.joinbindparametercontexts; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 11:1:46 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Revision11 { + private String version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Component7.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Component7.java new file mode 100644 index 00000000..9407181b --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Component7.java @@ -0,0 +1,11 @@ +package com.hzya.frame.nifi.model.joinprocessgroups; + +import com.hzya.frame.nifi.model.resultparametercontexts.Parameters; +import lombok.Data; + +import java.util.List; + +@Data +public class Component7 { + private String name; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupStatus.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupStatus.java new file mode 100644 index 00000000..a5879565 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupStatus.java @@ -0,0 +1,16 @@ +package com.hzya.frame.nifi.model.joinprocessgroups; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joinprocessgroups + * @Project：fw-nifi + * @name：ProcessGroupStatus + * @Date：2025/5/15 10:43 + * @Filename：ProcessGroupStatus + */ +@Data +public class ProcessGroupStatus { + private String name; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupsJoin.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupsJoin.java new file mode 100644 index 00000000..53859ac0 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupsJoin.java @@ -0,0 +1,18 @@ +package com.hzya.frame.nifi.model.joinprocessgroups; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joinprocessgroups + * @Project：fw-nifi + * @name：ProcessGroupsJoin + * @Date：2025/5/15 10:43 + * @Filename：ProcessGroupsJoin + */ +@Data +public class ProcessGroupsJoin { + private Revision5 revision; +// private ProcessGroupStatus status; + private Component7 component; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Revision5.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Revision5.java new file mode 100644 index 00000000..57282cde --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Revision5.java @@ -0,0 +1,8 @@ +package com.hzya.frame.nifi.model.joinprocessgroups; + +import lombok.Data; + +@Data +public class Revision5 { + private int version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/Revision10.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/Revision10.java new file mode 100644 index 00000000..3d20c070 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/Revision10.java @@ -0,0 +1,17 @@ +/** + * Copyright 2025 bejson.com + */ +package com.hzya.frame.nifi.model.joinstartorstopprocessgroup; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 10:47:3 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Revision10 { + private String version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/StartOrStopProcessGroupsInfoJoin10.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/StartOrStopProcessGroupsInfoJoin10.java new file mode 100644 index 00000000..cdeef740 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/StartOrStopProcessGroupsInfoJoin10.java @@ -0,0 +1,16 @@ +package com.hzya.frame.nifi.model.joinstartorstopprocessgroup; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 10:47:3 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class StartOrStopProcessGroupsInfoJoin10 { + private String id; + private String state; + private Revision10 revision; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Connections.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Connections.java index 455a6a43..719a6768 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Connections.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Connections.java @@ -6,7 +6,7 @@ import java.util.List; @Data public class Connections { - private Revision revision; + private Revision2 revision; private String id; private String uri; private Permissions permissions; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/InputPorts.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/InputPorts.java index b29862ef..5aa0208e 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/InputPorts.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/InputPorts.java @@ -6,7 +6,7 @@ import java.util.List; @Data public class InputPorts { - private Revision revision; + private Revision2 revision; private String id; private String uri; private Position position; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Labels.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Labels.java index 0de5546c..96c4fa7c 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Labels.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Labels.java @@ -4,7 +4,7 @@ import lombok.Data; @Data public class Labels { - private Revision revision; + private Revision2 revision; private String id; private String uri; private Position position; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputPorts.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputPorts.java index 9c8baab4..18a113bb 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputPorts.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputPorts.java @@ -6,7 +6,7 @@ import java.util.List; @Data public class OutputPorts { - private Revision revision; + private Revision2 revision; private String id; private String uri; private Position position; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Processors.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Processors.java index 2a8f9a1c..0f331fbd 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Processors.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Processors.java @@ -6,7 +6,7 @@ import java.util.List; @Data public class Processors { - private Revision revision; + private Revision2 revision; private String id; private String uri; private Position position; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision2.java similarity index 80% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision2.java index bff55741..f5002140 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision2.java @@ -3,6 +3,6 @@ package com.hzya.frame.nifi.model.processgroupid; import lombok.Data; @Data -public class Revision { +public class Revision2 { private int version; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java index fbebef08..dae13221 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java @@ -6,7 +6,7 @@ import java.util.List; @Data public class ProcessGroups { - private Revision revision; + private Revision3 revision; private String id; private String uri; private Position position; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision3.java similarity index 81% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision3.java index b152031a..03366b7f 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision3.java @@ -3,6 +3,6 @@ package com.hzya.frame.nifi.model.processgrouproot; import lombok.Data; @Data -public class Revision { +public class Revision3 { private String version; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java index 0f7ae0a1..c769bec7 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java @@ -4,7 +4,7 @@ import lombok.Data; @Data public class ParameterContextsResult { - private Revision revision; + private Revision4 revision; private String id; private String uri; private Permissions permissions; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision4.java similarity index 85% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision4.java index e8a518bf..955ec15a 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision4.java @@ -3,7 +3,7 @@ package com.hzya.frame.nifi.model.resultparametercontexts; import lombok.Data; @Data -public class Revision { +public class Revision4 { private int version; private String lastModifier; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroups/ProcessgroupsResult.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroups/ProcessgroupsResult.java new file mode 100644 index 00000000..82934f6b --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroups/ProcessgroupsResult.java @@ -0,0 +1,8 @@ +package com.hzya.frame.nifi.model.resultprocessgroups; + +import lombok.Data; + +@Data +public class ProcessgroupsResult { + private String id; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/AggregateSnapshot9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/AggregateSnapshot9.java new file mode 100644 index 00000000..d2b5381c --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/AggregateSnapshot9.java @@ -0,0 +1,43 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class AggregateSnapshot9 { + private String id; + private String name; + private String flowFilesIn; + private String bytesIn; + private String input; + private String flowFilesQueued; + private String bytesQueued; + private String queued; + private String queuedCount; + private String queuedSize; + private String bytesRead; + private String read; + private String bytesWritten; + private String written; + private String flowFilesOut; + private String bytesOut; + private String output; + private String flowFilesTransferred; + private String bytesTransferred; + private String transferred; + private String bytesReceived; + private String flowFilesReceived; + private String received; + private String bytesSent; + private String flowFilesSent; + private String sent; + private String activeThreadCount; + private String terminatedThreadCount; + private String processingNanos; + private ProcessingPerformanceStatus9 processingPerformanceStatus; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Component9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Component9.java new file mode 100644 index 00000000..9d77f58d --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Component9.java @@ -0,0 +1,41 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Component9 { + private String id; + private String parentGroupId; + private Position9 position; + private String name; + private String comments; + private Variables9 variables; + private String flowfileConcurrency; + private String flowfileOutboundPolicy; + private String defaultFlowFileExpiration; + private String defaultBackPressureObjectThreshold; + private String defaultBackPressureDataSizeThreshold; + private String runningCount; + private String stoppedCount; + private String invalidCount; + private String disabledCount; + private String activeRemotePortCount; + private String inactiveRemotePortCount; + private String upToDateCount; + private String locallyModifiedCount; + private String staleCount; + private String locallyModifiedAndStaleCount; + private String syncFailureCount; + private String localInputPortCount; + private String localOutputPortCount; + private String publicInputPortCount; + private String publicOutputPortCount; + private String inputPortCount; + private String outputPortCount; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Permissions9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Permissions9.java new file mode 100644 index 00000000..78ca1b5a --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Permissions9.java @@ -0,0 +1,15 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Permissions9 { + private String canRead; + private String canWrite; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Position9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Position9.java new file mode 100644 index 00000000..67d28144 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Position9.java @@ -0,0 +1,15 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Position9 { + private String x; + private String y; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessGroupsInfoResult9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessGroupsInfoResult9.java new file mode 100644 index 00000000..f0276e1d --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessGroupsInfoResult9.java @@ -0,0 +1,40 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +import java.util.List; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class ProcessGroupsInfoResult9 { + private Revision9 revision; + private String id; + private String uri; + private Position9 position; + private Permissions9 permissions; + private List bulletins; + private Component9 component; + private Status9 status; + private String runningCount; + private String stoppedCount; + private String invalidCount; + private String disabledCount; + private String activeRemotePortCount; + private String inactiveRemotePortCount; + private String upToDateCount; + private String locallyModifiedCount; + private String staleCount; + private String locallyModifiedAndStaleCount; + private String syncFailureCount; + private String localInputPortCount; + private String localOutputPortCount; + private String publicInputPortCount; + private String publicOutputPortCount; + private String inputPortCount; + private String outputPortCount; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessingPerformanceStatus9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessingPerformanceStatus9.java new file mode 100644 index 00000000..17ac6b85 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessingPerformanceStatus9.java @@ -0,0 +1,19 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class ProcessingPerformanceStatus9 { + private String identifier; + private String cpuDuration; + private String contentReadDuration; + private String contentWriteDuration; + private String sessionCommitDuration; + private String garbageCollectionDuration; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Revision9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Revision9.java new file mode 100644 index 00000000..714a89c3 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Revision9.java @@ -0,0 +1,14 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Revision9 { + private String version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Status9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Status9.java new file mode 100644 index 00000000..bb0de5c9 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Status9.java @@ -0,0 +1,20 @@ +/** + * Copyright 2025 bejson.com + */ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Status9 { + private String id; + private String name; + private String statsLastRefreshed; + private AggregateSnapshot9 aggregateSnapshot; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Variables9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Variables9.java new file mode 100644 index 00000000..c3268e00 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Variables9.java @@ -0,0 +1,14 @@ +/** + * Copyright 2025 bejson.com + */ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +public class Variables9 { + +} \ No newline at end of file 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 5241fd01..5ff590a4 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 @@ -2,10 +2,15 @@ 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.joinparametercontexts.ParameterContextsJoin; +import com.hzya.frame.nifi.model.joinprocessgroups.ProcessGroupsJoin; +import com.hzya.frame.nifi.model.joinstartorstopprocessgroup.StartOrStopProcessGroupsInfoJoin10; import com.hzya.frame.nifi.model.processgroupid.ProcessGroupsId; import com.hzya.frame.nifi.model.processgrouproot.ProcessGroupsRoot; import com.hzya.frame.nifi.model.resultparametercontexts.ParameterContextsResult; +import com.hzya.frame.nifi.model.resultprocessgroups.ProcessgroupsResult; +import com.hzya.frame.nifi.model.resultprocessgroupsinfo.ProcessGroupsInfoResult9; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -39,14 +44,17 @@ public class NifiApiService { } /** - * 查询全部流程组或指定流程组 + * 查询全部流程 */ - public Object queryFlowProcessGroupsRoot(String flowGroupId) throws Exception { - if (flowGroupId != null) { - return client.get(StrUtil.format("/flow/process-groups/{}", flowGroupId), ProcessGroupsId.class); - } else { - return client.get("/flow/process-groups/root", ProcessGroupsRoot.class); - } + public ProcessGroupsRoot queryFlowProcessGroupsRoot() throws Exception { + return client.get("/flow/process-groups/root", ProcessGroupsRoot.class); + } + + /** + * 查询指定流程 + */ + public ProcessGroupsId queryFlowProcessGroupsRoot(String flowGroupId) throws Exception { + return client.get(StrUtil.format("/flow/process-groups/{}", flowGroupId), ProcessGroupsId.class); } /** @@ -78,9 +86,45 @@ public class NifiApiService { } /** - * 删除参数上下文,待query参数 + * 删除参数上下文 */ public ParameterContextsResult deleteParameterContexts(String id, Map queryParams) throws Exception { return client.delete(StrUtil.format("/parameter-contexts/{}", id), queryParams, ParameterContextsResult.class); } + + /** + * 查询流程组详情 + */ + public ProcessGroupsInfoResult9 getProcessGroups(String processGroups) throws Exception { + return client.get(StrUtil.format("/process-groups/{}", processGroups), ProcessGroupsInfoResult9.class); + } + + /** + * 创建流程组 + */ + public ProcessgroupsResult createProcessGroups(String parentGroupId, ProcessGroupsJoin processGroupsJoin) throws Exception { + return client.post(StrUtil.format("/process-groups/{}/process-groups", parentGroupId), processGroupsJoin, ProcessgroupsResult.class); + } + + /** + * 删除流程组 + */ + public ProcessGroupsInfoResult9 deleteProcessGroups(String parentGroupId, Map queryParams) throws Exception { + return client.delete(StrUtil.format("/process-groups/{}", parentGroupId), queryParams, ProcessGroupsInfoResult9.class); + } + + /** + * 启动或停止流程组 + */ + public ProcessGroupsInfoResult9 startOrStopProcessGroups(StartOrStopProcessGroupsInfoJoin10 startOrStopProcessGroupsInfoJoin10) throws Exception { + return client.put(StrUtil.format("/flow/process-groups/{}", startOrStopProcessGroupsInfoJoin10.getId()), startOrStopProcessGroupsInfoJoin10, ProcessGroupsInfoResult9.class); + } + + /** + * 给流程组绑定参数上下文环境、或者给流程组更新上下文环境 + */ + public ProcessGroupsInfoResult9 bindParameterContexts(BindParameterContextsJoin11 bindParameterContextsJoin) throws Exception { + String id = bindParameterContextsJoin.getComponent().getId(); + return client.put(StrUtil.format("/process-groups/{}", id), bindParameterContextsJoin, ProcessGroupsInfoResult9.class); + } } \ No newline at end of file diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/client/NifiClient.class b/fw-nifi/target/classes/com/hzya/frame/nifi/client/NifiClient.class index 0030e6c2..a9679050 100644 Binary files a/fw-nifi/target/classes/com/hzya/frame/nifi/client/NifiClient.class and b/fw-nifi/target/classes/com/hzya/frame/nifi/client/NifiClient.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/ProcessorConfig.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/ProcessorConfig.class deleted file mode 100644 index 15d66f3c..00000000 Binary files a/fw-nifi/target/classes/com/hzya/frame/nifi/model/ProcessorConfig.class and /dev/null differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Component.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Component.class deleted file mode 100644 index cf93f7f1..00000000 Binary files a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Component.class and /dev/null differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.class index bcedd4cc..0d91656c 100644 Binary files a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.class and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Revision.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Revision.class deleted file mode 100644 index 4db82529..00000000 Binary files a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Revision.class and /dev/null differ 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 b5d5e42f..8b751ea7 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