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 9b2f9027..c441151f 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 @@ -54,11 +54,7 @@ public class NifiClient { public T get(String path, Class responseType) throws IOException { return executeRequestWithRetry(() -> { - Request request = new Request.Builder() - .url(config.getApiUrl() + path) - .get() - .header("Authorization", "Bearer " + accessToken.get()). - build(); + Request request = new Request.Builder().url(config.getApiUrl() + path).get().header("Authorization", "Bearer " + accessToken.get()).build(); return executeRequest(request, responseType); }); } @@ -116,10 +112,10 @@ public class NifiClient { private T executeRequest(Request request, Class responseType) throws IOException { try (Response response = httpClient.newCall(request).execute()) { - if (!response.isSuccessful()) { - throw new IOException("意外的响应码: " + response); - } String responseBody = response.body().string(); + if (!response.isSuccessful()) { + throw new IOException("意外的响应码: " + responseBody); + } return objectMapper.readValue(responseBody, responseType); } } diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/ProcessorConfig.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/ProcessorConfig.java deleted file mode 100644 index dfe2b68d..00000000 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/ProcessorConfig.java +++ /dev/null @@ -1,27 +0,0 @@ -package com.hzya.frame.nifi.model; - -import com.fasterxml.jackson.annotation.JsonProperty; -import lombok.Data; - -/** - * @Author:liuyang - * @Package:com.hzya.frame.nifi.model - * @Project:fw-nifi - * @name:ProcessorConfig - * @Date:2025/5/14 10:01 - * @Filename:ProcessorConfig - */ -@Data -public class ProcessorConfig { - @JsonProperty("name") - private String name; - - @JsonProperty("type") - private String type; - - @JsonProperty("id") - private String id; - - @JsonProperty("state") - private String state; -} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Component.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Component.java new file mode 100644 index 00000000..c88f7cd2 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Component.java @@ -0,0 +1,17 @@ +package com.hzya.frame.nifi.model.joinparametercontexts; + +import lombok.Data; + +import java.util.List; + +/** + * Auto-generated: 2025-05-14 18:33:21 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Component { + private String name; + private List parameters; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameter.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameter.java new file mode 100644 index 00000000..3af1acf3 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameter.java @@ -0,0 +1,11 @@ +package com.hzya.frame.nifi.model.joinparametercontexts; + +import lombok.Data; + +@Data +public class Parameter { + private String name; + private String value; + private boolean sensitive; + private String description; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/ParameterContextsJoin.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/ParameterContextsJoin.java new file mode 100644 index 00000000..1516477d --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/ParameterContextsJoin.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.joinparametercontexts; + +import lombok.Data; + +@Data +public class ParameterContextsJoin { + private Revision revision; + private Component component; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameters.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameters.java new file mode 100644 index 00000000..024b66e1 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameters.java @@ -0,0 +1,11 @@ +/** + * Copyright 2025 bejson.com + */ +package com.hzya.frame.nifi.model.joinparametercontexts; + +import lombok.Data; + +@Data +public class Parameters { + private Parameter parameter; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Revision.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Revision.java new file mode 100644 index 00000000..37c1c14e --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Revision.java @@ -0,0 +1,8 @@ +package com.hzya.frame.nifi.model.joinparametercontexts; + +import lombok.Data; + +@Data +public class Revision { + private int version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Component.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Component.java new file mode 100644 index 00000000..7bd81976 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Component.java @@ -0,0 +1,14 @@ +package com.hzya.frame.nifi.model.resultparametercontexts; + +import lombok.Data; + +import java.util.List; + +@Data +public class Component { + private String name; + private List parameters; + private List boundProcessGroups; + private List inheritedParameterContexts; + private String id; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Parameter.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Parameter.java new file mode 100644 index 00000000..c2c4e4e7 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Parameter.java @@ -0,0 +1,22 @@ +package com.hzya.frame.nifi.model.resultparametercontexts; + +import lombok.Data; + +import java.util.List; + +/** + * Auto-generated: 2025-05-14 18:44:23 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Parameter { + private String name; + private String description; + private String sensitive; + private String value; + private String provided; + private List referencingComponents; + private ParameterContext parameterContext; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContext.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContext.java new file mode 100644 index 00000000..7b745bbf --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContext.java @@ -0,0 +1,10 @@ +package com.hzya.frame.nifi.model.resultparametercontexts; + +import lombok.Data; + +@Data +public class ParameterContext { + private String id; + private Permissions permissions; + private Component component; +} \ 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 new file mode 100644 index 00000000..2611c045 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java @@ -0,0 +1,12 @@ +package com.hzya.frame.nifi.model.resultparametercontexts; + +import lombok.Data; + +@Data +public class ParameterContextsResult { + private Revision revision; + private String id; + private String uri; + private Permissions permissions; + private Component component; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Parameters.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Parameters.java new file mode 100644 index 00000000..9c85a6b9 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Parameters.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.resultparametercontexts; + +import lombok.Data; + +@Data +public class Parameters { + private boolean canWrite; + private Parameter parameter; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Permissions.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Permissions.java new file mode 100644 index 00000000..500ed66d --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Permissions.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.resultparametercontexts; + +import lombok.Data; + +@Data +public class Permissions { + private boolean canRead; + private boolean canWrite; +} \ No newline at end of file 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/Revision.java new file mode 100644 index 00000000..e8a518bf --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.resultparametercontexts; + +import lombok.Data; + +@Data +public class Revision { + private int version; + private String lastModifier; +} \ 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 baa4f7c6..1e98eb96 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,12 +2,16 @@ 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.joinparametercontexts.ParameterContextsJoin; 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 org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; /** + * nifi api 服务类 + * * @Author:liuyang * @Package:com.hzya.frame.nifi.service * @Project:fw-nifi @@ -42,4 +46,30 @@ public class NifiApiService { return client.get("/flow/process-groups/root", ProcessGroupsRoot.class); } } + + /** + * 创建参数上下文 + */ + public ParameterContextsResult createParameterContexts(ParameterContextsJoin parameterContextsJoin) throws Exception { + return client.post("/parameter-contexts", parameterContextsJoin, ParameterContextsResult.class); + } + + /** + * 更新参数上下文 + */ + public ParameterContextsResult updateParameterContexts(ParameterContextsResult parameterContextsJoin) throws Exception { + return client.post(StrUtil.format("/parameter-contexts/{contextId}/update-requests", parameterContextsJoin.getId()), parameterContextsJoin, ParameterContextsResult.class); + } + + /** + * 删除参数上下文 + */ + + /** + * 查询参数上下文 + */ + public ParameterContextsResult getParameterContexts(String paramContextsId) throws Exception { + return client.get(StrUtil.format("/parameter-contexts/{}", paramContextsId), ParameterContextsResult.class); + } + } \ No newline at end of file