feat(nifi): 添加 NiFi API 客户端相关功能

- 实现了 NiFiClient 类，提供与 NiFi API 交互的功能
- 添加了必要的配置类和模型类
- 实现了基本的 HTTP 请求方法（GET、POST、DELETE、PUT）
-集成了 Jackson 和 OkHttpClient

base-service/src/main/java/com/hzya/frame/nifiapi/NifiApplication.java

@@ -0,0 +1,11 @@
+package com.hzya.frame.nifiapi;//package com.hzya.frame.nifi;
+//
+//import org.springframework.boot.SpringApplication;
+//import org.springframework.boot.autoconfigure.SpringBootApplication;
+//
+//@SpringBootApplication(scanBasePackages = "com.hzya.frame.nifi")
+//public class NifiApplication {
+//    public static void main(String[] args) {
+//        SpringApplication.run(NifiApplication.class, args);
+//    }
+//}

base-service/src/main/java/com/hzya/frame/nifiapi/client/NifiClient.java

@@ -0,0 +1,238 @@
+package com.hzya.frame.nifiapi.client;
+
+import cn.hutool.core.util.StrUtil;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.hzya.frame.nifiapi.config.NifiServiceConfig;
+import okhttp3.*;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.charset.StandardCharsets;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicReference;
+
+/**
+ * nifi客户端请求处理
+ *
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.client
+ * @Project：fw-nifi
+ * @name：NifiClient
+ * @Date：2025/5/14 10:00
+ * @Filename：NifiClient
+ */
+@Component
+public class NifiClient {
+
+    private final NifiServiceConfig config;
+    private final OkHttpClient httpClient;
+    private final ObjectMapper objectMapper;
+    private final AtomicReference<String> accessToken = new AtomicReference<>();
+    private volatile long tokenIssueTime; // Token 发行时间（毫秒）
+    private volatile long tokenExpiration; // Token 过期时间（毫秒）
+    Logger logger = LoggerFactory.getLogger(NifiClient.class);
+
+    @Autowired
+    public NifiClient(NifiServiceConfig config, OkHttpClient httpClient, ObjectMapper objectMapper) {
+        this.config = config;
+        this.httpClient = httpClient;
+        this.objectMapper = objectMapper;
+        initializeToken();
+    }
+
+    private void initializeToken() {
+        try {
+            accessToken.set(getAccessToken());
+            tokenIssueTime = System.currentTimeMillis();
+            tokenExpiration = tokenIssueTime + (12 * 60 * 60 * 1000); // 默认 12 小时
+            logger.info("令牌已初始化，过期时间：" + new java.util.Date(tokenExpiration));
+        } catch (Exception e) {
+            throw new RuntimeException("初始化NiFi访问令牌失败： " + e.getMessage());
+        }
+    }
+
+    public <T> T get(String path, Class<T> responseType) throws IOException {
+        return executeRequestWithRetry(() -> {
+            Request request = new Request.Builder().url(config.getApiUrl() + path).get().header("Authorization", "Bearer " + accessToken.get()).build();
+            return executeRequest(request, responseType);
+        });
+    }
+
+    /**
+     * 获取原始JSON响应字符串，不进行反序列化
+     */
+    public String getRaw(String path) throws IOException {
+        return executeRequestWithRetry(() -> {
+            Request request = new Request.Builder().url(config.getApiUrl() + path).get().header("Authorization", "Bearer " + accessToken.get()).build();
+            try (Response response = httpClient.newCall(request).execute()) {
+                if (!response.isSuccessful()) {
+                    throw new IOException("意外的响应码: " + response.code());
+                }
+                return response.body().string();
+            }
+        });
+    }
+
+    /**
+     * 执行GET请求并返回文件流，供调用者处理（如保存到文件或浏览器下载）
+     */
+    public InputStream getAsStream(String path) throws IOException {
+        return executeRequestWithRetry(() -> {
+            Request request = new Request.Builder().url(config.getApiUrl() + path).get().header("Authorization", "Bearer " + accessToken.get()).build();
+            return executeStreamRequest(request);
+        });
+    }
+
+    public <T> T post(String path, Object requestBody, Class<T> 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).post(body).header("Authorization", "Bearer " + accessToken.get()).build();
+            return executeRequest(request, responseType);
+        });
+    }
+
+    public <T> T delete(String path, Class<T> responseType) throws IOException {
+        return executeRequestWithRetry(() -> {
+            Request request = new Request.Builder().url(config.getApiUrl() + path).delete().header("Authorization", "Bearer " + accessToken.get()).build();
+            return executeRequest(request, responseType);
+        });
+    }
+
+    public <T> T delete(String path, Map<String, String> queryParams, Class<T> responseType) throws IOException {
+        // 构建 URL 并添加查询参数
+        HttpUrl.Builder urlBuilder = HttpUrl.parse(config.getApiUrl() + path).newBuilder();
+        if (queryParams != null) {
+            queryParams.forEach(urlBuilder::addQueryParameter);
+        }
+        String url = urlBuilder.build().toString();
+
+        return executeRequestWithRetry(() -> {
+            Request request = new Request.Builder().url(url).delete().header("Authorization", "Bearer " + accessToken.get()).build();
+            return executeRequest(request, responseType);
+        });
+    }
+
+    public <T> T put(String path, Object requestBody, Class<T> 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> T executeRequestWithRetry(IOExceptionRunnable<T> runnable) throws IOException {
+        int maxRetries = 2;
+        for (int attempt = 0; attempt < maxRetries; attempt++) {
+            try {
+                checkAndRefreshToken();
+                return runnable.run();
+            } catch (IOException e) {
+                if (attempt == maxRetries - 1 || !isTokenExpiredError(e)) {
+                    throw e;
+                }
+                logger.info("令牌可能已过期，请刷新并重试...");
+                try {
+                    accessToken.set(getAccessToken());
+                    tokenIssueTime = System.currentTimeMillis();
+                    tokenExpiration = tokenIssueTime + (12 * 60 * 60 * 1000); // 默认 12 小时
+                } catch (Exception ex) {
+                    throw new IOException("刷新令牌失败： " + ex.getMessage(), e);
+                }
+            }
+        }
+        throw new IOException("已达到最大重试次数");
+    }
+
+    private void checkAndRefreshToken() throws IOException {
+        long currentTime = System.currentTimeMillis();
+        if (currentTime > tokenExpiration - 300000) { // 提前 5 分钟刷新
+            try {
+                accessToken.set(getAccessToken());
+                tokenIssueTime = System.currentTimeMillis();
+                tokenExpiration = tokenIssueTime + (12 * 60 * 60 * 1000); // 默认 12 小时
+                logger.info("令牌已刷新，到期时间： " + new java.util.Date(tokenExpiration));
+            } catch (Exception e) {
+                throw new IOException("刷新令牌失败： " + e.getMessage());
+            }
+        }
+    }
+
+    private boolean isTokenExpiredError(IOException e) {
+        // 判断是否为 401 错误（Token 过期）
+        return e.getMessage().contains("401") || e.getMessage().contains("Unauthorized");
+    }
+
+    private <T> T executeRequest(Request request, Class<T> responseType) throws IOException {
+        try (Response response = httpClient.newCall(request).execute()) {
+            String responseBody = response.body().string();
+            logger.info("响应体：" + responseBody);
+            if (!response.isSuccessful()) {
+                throw new IOException(StrUtil.format("意外的响应码: {}", responseBody));
+            }
+            return objectMapper.readValue(responseBody, responseType);
+        }
+    }
+
+    public synchronized String getAccessToken() throws Exception {
+        // 创建信任所有证书的 OkHttpClient
+//        OkHttpClient client = httpClient.newBuilder().sslSocketFactory(createTrustAllSslSocketFactory(), createTrustAllTrustManager()).hostnameVerifier((hostname, session) -> true).build();
+
+        MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded");
+        RequestBody body = RequestBody.create(mediaType, "username=" + config.getUsername() + "&password=" + config.getPassword());
+        Request request = new Request.Builder().url(config.getApiUrl() + "/access/token").post(body).addHeader("Content-Type", "application/x-www-form-urlencoded").addHeader("Accept", "*/*").addHeader("User-Agent", "fw-nifi-client/1.0").addHeader("Connection", "keep-alive").build();
+
+        try (Response response = httpClient.newCall(request).execute()) {
+            if (!response.isSuccessful()) {
+                throw new IOException("获取访问令牌失败，响应码: " + response.code() + " - " + response.message());
+            }
+            byte[] bytes = response.body().bytes();
+            String newToken = new String(bytes, StandardCharsets.UTF_8);
+            return newToken;
+        }
+    }
+
+//    private SSLSocketFactory createTrustAllSslSocketFactory() throws Exception {
+//        SSLContext sslContext = SSLContext.getInstance("SSL");
+//        sslContext.init(null, new TrustManager[]{createTrustAllTrustManager()}, new SecureRandom());
+//        return sslContext.getSocketFactory();
+//    }
+
+//    private X509TrustManager createTrustAllTrustManager() {
+//        return new X509TrustManager() {
+//            @Override
+//            public void checkClientTrusted(X509Certificate[] chain, String authType) {
+//            }
+//
+//            @Override
+//            public void checkServerTrusted(X509Certificate[] chain, String authType) {
+//            }
+//
+//            @Override
+//            public X509Certificate[] getAcceptedIssuers() {
+//                return new X509Certificate[0];
+//            }
+//        };
+//    }
+
+    private InputStream executeStreamRequest(Request request) throws IOException {
+        Response response = httpClient.newCall(request).execute();
+        if (!response.isSuccessful()) {
+            String responseBody = response.body().string();
+            response.close();
+            throw new IOException("意外的响应码: " + responseBody);
+        }
+        return response.body().byteStream();
+    }
+
+    // 功能接口，用于重试逻辑
+    @FunctionalInterface
+    private interface IOExceptionRunnable<T> {
+        T run() throws IOException;
+    }
+}

base-service/src/main/java/com/hzya/frame/nifiapi/config/HttpClientConfig.java

@@ -0,0 +1,60 @@
+package com.hzya.frame.nifiapi.config;
+
+import okhttp3.OkHttpClient;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.SSLSocketFactory;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.X509TrustManager;
+import java.security.SecureRandom;
+import java.security.cert.X509Certificate;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * OkHttpClient配置类
+ *
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.config
+ * @Project：fw-nifi
+ * @name：HttpClientConfig
+ * @Date：2025/5/14 11:45
+ * @Filename：HttpClientConfig
+ */
+@Configuration
+public class HttpClientConfig {
+
+    @Bean
+    public OkHttpClient okHttpClient() throws Exception {
+
+        //调用nifi接口正常情况不会超过60秒的，目前遇到的接口1秒以内调用完毕
+        return new OkHttpClient.Builder().sslSocketFactory(createTrustAllSslSocketFactory(), createTrustAllTrustManager()).hostnameVerifier((hostname, session) -> true).connectTimeout(60, TimeUnit.SECONDS) // 连接超时时间
+                .readTimeout(60, TimeUnit.SECONDS)   // 读取超时时间
+                .writeTimeout(60, TimeUnit.SECONDS)  // 写入超时时间
+                .build();
+    }
+
+    private SSLSocketFactory createTrustAllSslSocketFactory() throws Exception {
+        SSLContext sslContext = SSLContext.getInstance("SSL");
+        sslContext.init(null, new TrustManager[]{createTrustAllTrustManager()}, new SecureRandom());
+        return sslContext.getSocketFactory();
+    }
+
+    private X509TrustManager createTrustAllTrustManager() {
+        return new X509TrustManager() {
+            @Override
+            public void checkClientTrusted(X509Certificate[] chain, String authType) {
+            }
+
+            @Override
+            public void checkServerTrusted(X509Certificate[] chain, String authType) {
+            }
+
+            @Override
+            public X509Certificate[] getAcceptedIssuers() {
+                return new X509Certificate[0];
+            }
+        };
+    }
+}

base-service/src/main/java/com/hzya/frame/nifiapi/config/JacksonConfig.java

@@ -0,0 +1,29 @@
+package com.hzya.frame.nifiapi.config;
+
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * jackson配置类
+ *
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.config
+ * @Project：fw-nifi
+ * @name：JacksonConfig
+ * @Date：2025/5/14 11:54
+ * @Filename：JacksonConfig
+ */
+@Configuration
+public class JacksonConfig {
+    @Bean
+    public ObjectMapper objectMapper() {
+        ObjectMapper objectMapper = new ObjectMapper();
+        // 自动注册模块
+        objectMapper.findAndRegisterModules();
+        // 忽略 JSON 中存在但实体类中缺少的字段
+        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+        return objectMapper;
+    }
+}

base-service/src/main/java/com/hzya/frame/nifiapi/config/NifiServiceConfig.java

@@ -0,0 +1,38 @@
+package com.hzya.frame.nifiapi.config;
+
+import lombok.Data;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * nifi service配置类
+ *
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.config
+ * @Project：fw-nifi
+ * @name：NifiConfig
+ * @Date：2025/5/14 09:59
+ * @Filename：NifiConfig
+ */
+@Configuration
+@Data
+public class NifiServiceConfig {
+
+    @Value("${nifi.api.url:https://192.168.2.233:8443/nifi-api}")
+    private String apiUrl;
+
+    @Value("${nifi.api.username:hzya}")
+    private String username;
+
+    @Value("${nifi.api.password:hzya1314*nifi}")
+    private String password;
+
+    @Value("${nifi.api.controllerModifymark:接口修改标记}")
+    private String controllerModifyMark;
+
+    @Value("${nifi.api.relationshipMark:接口关系标记}")
+    private String relationshipMark;
+
+    @Value("${nifi.api.relationshipMark:接口状态清理标记}")
+    private String stateClearMark;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/basemodel/JoinBashModel.java

@@ -0,0 +1,30 @@
+package com.hzya.frame.nifiapi.model.basemodel;
+
+import com.hzya.frame.nifiapi.model.joincreparamcontext.CreateParamContextJoin;
+import com.hzya.frame.nifiapi.model.joinfindneedmodifycontroller.FindNeedModifyController;
+import lombok.Data;
+
+/**
+ * 基类封转创建应用操作公共的字段
+ *
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifiapi.model.joincreateoracleapp
+ * @Project：fw-nifi
+ * @name：CreateOracleApp
+ * @Date：2025/5/21 17:44
+ * @Filename：CreateOracleApp
+ */
+@Data
+public class JoinBashModel {
+    //实例化
+    private String appProcessGroupId;
+    private String parentProcessGroupId;
+    private String copyTargetProcessGroupId;
+//    private String copyTargetParentProcessGroupId;
+
+    //上下文
+    private CreateParamContextJoin createParamContextJoin;
+
+    //控制器
+    private FindNeedModifyController findNeedModifyController;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinbindparametercontexts/BindParameterContextsJoin11.java

@@ -0,0 +1,15 @@
+package com.hzya.frame.nifiapi.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;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinbindparametercontexts/Component11.java

@@ -0,0 +1,15 @@
+package com.hzya.frame.nifiapi.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;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinbindparametercontexts/ParameterContext11.java

@@ -0,0 +1,8 @@
+package com.hzya.frame.nifiapi.model.joinbindparametercontexts;
+
+import lombok.Data;
+
+@Data
+public class ParameterContext11 {
+    private String id;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinbindparametercontexts/Revision11.java

@@ -0,0 +1,17 @@
+/**
+ * Copyright 2025 bejson.com
+ */
+package com.hzya.frame.nifiapi.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;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincontrollerenabled/EnOrDiControllerServices12.java

@@ -0,0 +1,17 @@
+package com.hzya.frame.nifiapi.model.joincontrollerenabled;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincontrollerenabled
+ * @Project：fw-nifi
+ * @name：EnOrDiControllerServices
+ * @Date：2025/5/16 16:54
+ * @Filename：EnOrDiControllerServices
+ */
+@Data
+public class EnOrDiControllerServices12 {
+    private String state;
+    private Revision13 revision;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincontrollerenabled/Revision13.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.model.joincontrollerenabled;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincontrollerenabled
+ * @Project：fw-nifi
+ * @name：ControllerServiceStatus
+ * @Date：2025/5/16 16:54
+ * @Filename：ControllerServiceStatus
+ */
+@Data
+public class Revision13 {
+    private String version;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreateconnection/Component18.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifiapi.model.joincreateconnection;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnection
+ * @Project：fw-nifi
+ * @name：Component18
+ * @Date：2025/5/19 15:39
+ * @Filename：Component18
+ */
+@Data
+public class Component18 {
+    private String id;
+    private String parentGroupId;
+    private String backPressureObjectThreshold;
+    private String backPressureDataSizeThreshold;
+    private String flowFileExpiration;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreateconnection/CreateConnection18.java

@@ -0,0 +1,23 @@
+package com.hzya.frame.nifiapi.model.joincreateconnection;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnection
+ * @Project：fw-nifi
+ * @name：CreateConnection
+ * @Date：2025/5/19 15:35
+ * @Filename：CreateConnection
+ */
+@Data
+public class CreateConnection18 {
+    private String id;
+    private String sourceId;
+    private String sourceGroupId;
+    private String sourceType;
+    private String destinationId;
+    private String destinationGroupId;
+    private String destinationType;
+    private Revision18 revision;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreateconnection/Revision18.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.model.joincreateconnection;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnection
+ * @Project：fw-nifi
+ * @name：Revision18
+ * @Date：2025/5/19 15:36
+ * @Filename：Revision18
+ */
+@Data
+public class Revision18 {
+    private String version;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreateconnections/Component18.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifiapi.model.joincreateconnections;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：Component17
+ * @Date：2025/5/19 11:58
+ * @Filename：Component17
+ */
+@Data
+public class Component18 {
+    private SourceOrDestination18 source;
+    private SourceOrDestination18 destination;
+    private List<String> selectedRelationships;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreateconnections/CreateConnections18.java

@@ -0,0 +1,17 @@
+package com.hzya.frame.nifiapi.model.joincreateconnections;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：CreateConnections
+ * @Date：2025/5/19 11:56
+ * @Filename：CreateConnections
+ */
+@Data
+public class CreateConnections18 {
+    private Revision18 revision;
+    private Component18 component;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreateconnections/Revision18.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.model.joincreateconnections;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：Revision17
+ * @Date：2025/5/19 11:56
+ * @Filename：Revision17
+ */
+@Data
+public class Revision18 {
+    private String version;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreateconnections/SourceOrDestination18.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifiapi.model.joincreateconnections;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreateconnections
+ * @Project：fw-nifi
+ * @name：SourceOrDestination
+ * @Date：2025/5/19 13:39
+ * @Filename：SourceOrDestination
+ */
+@Data
+public class SourceOrDestination18 {
+    private String id;
+    private String groupId;
+    private String type;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreatemysqlapp/CreateMysqlApp.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.model.joincreatemysqlapp;
+
+import com.hzya.frame.nifiapi.model.basemodel.JoinBashModel;
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifiapi.model.joincreateoracleapp
+ * @Project：fw-nifi
+ * @name：CreateOracleApp
+ * @Date：2025/5/21 17:44
+ * @Filename：CreateOracleApp
+ */
+@Data
+public class CreateMysqlApp extends JoinBashModel {
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreateoracleapp/CreateAppInstanceJoin.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.model.joincreateoracleapp;
+
+import com.hzya.frame.nifiapi.model.basemodel.JoinBashModel;
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifiapi.model.joincreateoracleapp
+ * @Project：fw-nifi
+ * @name：CreateOracleApp
+ * @Date：2025/5/21 17:44
+ * @Filename：CreateOracleApp
+ */
+@Data
+public class CreateAppInstanceJoin extends JoinBashModel {
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreateprocessconnection/CreateProcessorConnections.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifiapi.model.joincreateprocessconnection;
+
+import com.hzya.frame.nifiapi.model.joincreateconnections.CreateConnections18;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifiapi.model.joincreateprocessconnection
+ * @Project：fw-nifi
+ * @name：CreateProcessorConnections
+ * @Date：2025/5/22 14:06
+ * @Filename：CreateProcessorConnections
+ */
+@Data
+public class CreateProcessorConnections {
+    private String processGroupsId;
+    private List<CreateConnections18> createConnections18;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreateprocessorandupdateparam/CreateProcessorAndUpdateParamJoin.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifiapi.model.joincreateprocessorandupdateparam;
+
+import com.hzya.frame.nifiapi.model.resultprocessorsinfo.Component16;
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifiapi.model.joincerateprocessorandupdateparam
+ * @Project：fw-nifi
+ * @name：CreateProcessorAndUpdateParam
+ * @Date：2025/5/26 15:59
+ * @Filename：CreateProcessorAndUpdateParam
+ */
+@Data
+public class CreateProcessorAndUpdateParamJoin {
+    private String targetProcessorId;
+    private String parentProcessGroupId;
+    private String copyTargetProcessGroupId;
+    private Component16 component;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreatetemp/CreateTemplateJoin.java

@@ -0,0 +1,19 @@
+package com.hzya.frame.nifiapi.model.joincreatetemp;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joincreatetemp
+ * @Project：fw-nifi
+ * @name：CreateTemplateJoin
+ * @Date：2025/5/17 10:52
+ * @Filename：CreateTemplateJoin
+ */
+@Data
+public class CreateTemplateJoin {
+    private String name;
+    private String description;
+    private String snippetId;
+    private String disconnectedNodeAcknowledged;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joincreparamcontext/CreateParamContextJoin.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifiapi.model.joincreparamcontext;
+
+import com.hzya.frame.nifiapi.model.joinparametercontexts.ParameterContextsJoin;
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifiapi.model.joincreparamcontext
+ * @Project：fw-nifi
+ * @name：CreateParamContextJoin
+ * @Date：2025/5/22 08:58
+ * @Filename：CreateParamContextJoin
+ */
+@Data
+public class CreateParamContextJoin {
+    private ParameterContextsJoin parameterContextsJoin;
+    private String processGroupsId;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinfindneedmodifycontroller/FindNeedModifyController.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifiapi.model.joinfindneedmodifycontroller;
+
+import com.hzya.frame.nifiapi.model.joingetcontroller.ControllerService12;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifiapi.model.joinfindneedmodifycontroller
+ * @Project：fw-nifi
+ * @name：FindNeedModifyController
+ * @Date：2025/5/22 11:03
+ * @Filename：FindNeedModifyController
+ */
+@Data
+public class FindNeedModifyController {
+    private String processGroupId;
+    private List<ControllerService12> needModifyController;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joingetallcontrollerservice/Component19.java

@@ -0,0 +1,31 @@
+package com.hzya.frame.nifiapi.model.joingetallcontrollerservice;
+
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifiapi.model.joingetallcontrollerservice
+ * @Project：fw-nifi
+ * @name：Component19
+ * @Date：2025/5/22 10:28
+ * @Filename：Component19
+ */
+@Data
+public class Component19 {
+    private String id;
+    private String name;
+    private String type;
+    private String state;
+    private String validationStatus;
+    private String bulletinLevel;
+    private String extensionMissing;
+    private String comments;
+    private Map<String, String> properties;
+    private String persistsState;
+    private String restricted;
+    private String deprecated;
+    private String multipleVersionsAvailable;
+    private String supportsSensitiveDynamicProperties;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joingetallcontrollerservice/ControllerServices19.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifiapi.model.joingetallcontrollerservice;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifiapi.model.joingetallcontrollerservice
+ * @Project：fw-nifi
+ * @name：ControllerServices19
+ * @Date：2025/5/22 10:15
+ * @Filename：ControllerServices19
+ */
+@Data
+public class ControllerServices19 {
+    private String id;
+    private String uri;
+    private Component19 component;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joingetallcontrollerservice/GetAllController19.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifiapi.model.joingetallcontrollerservice;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Author ：liuyang
+ * @Package ：com.hzya.frame.nifiapi.model.joingetallcontrollerservice
+ * @Project ：fw-nifi
+ * @name ：GetAllController
+ * @Date ：2025/5/22 10:13
+ * @Filename ：GetAllController
+ */
+@Data
+public class GetAllController19 {
+    private List<ControllerServices19> controllerServices;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joingetcontroller/Component12.java

@@ -0,0 +1,27 @@
+package com.hzya.frame.nifiapi.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;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joingetcontroller/ControllerService12.java

@@ -0,0 +1,21 @@
+package com.hzya.frame.nifiapi.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 {
+    //控制器服务id
+    private String id;
+    private Revision12 revision;
+    private Component12 component;
+    //修改标记id
+    private String modifyMarkId;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joingetcontroller/Properties12.java

@@ -0,0 +1,24 @@
+package com.hzya.frame.nifiapi.model.joingetcontroller;//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;
+//}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joingetcontroller/Revision12.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.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;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinparametercontexts/Component3.java

@@ -0,0 +1,17 @@
+package com.hzya.frame.nifiapi.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 Component3 {
+    private String name;
+    private List<Parameters2> parameters;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinparametercontexts/Parameter2.java

@@ -0,0 +1,11 @@
+package com.hzya.frame.nifiapi.model.joinparametercontexts;
+
+import lombok.Data;
+
+@Data
+public class Parameter2 {
+    private String name;
+    private String value;
+    private boolean sensitive;
+    private String description;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinparametercontexts/ParameterContextsJoin.java

@@ -0,0 +1,9 @@
+package com.hzya.frame.nifiapi.model.joinparametercontexts;
+
+import lombok.Data;
+
+@Data
+public class ParameterContextsJoin {
+    private Revision revision;
+    private Component3 component;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinparametercontexts/Parameters2.java

@@ -0,0 +1,11 @@
+/**
+ * Copyright 2025 bejson.com
+ */
+package com.hzya.frame.nifiapi.model.joinparametercontexts;
+
+import lombok.Data;
+
+@Data
+public class Parameters2 {
+    private Parameter2 parameter;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinparametercontexts/Revision.java

@@ -0,0 +1,8 @@
+package com.hzya.frame.nifiapi.model.joinparametercontexts;
+
+import lombok.Data;
+
+@Data
+public class Revision {
+    private int version;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinprocessgroups/Component7.java

@@ -0,0 +1,9 @@
+package com.hzya.frame.nifiapi.model.joinprocessgroups;
+
+import lombok.Data;
+
+@Data
+public class Component7 {
+    private String name;
+    private Position7 position;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinprocessgroups/Position7.java

@@ -0,0 +1,25 @@
+package com.hzya.frame.nifiapi.model.joinprocessgroups;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifiapi.model.joinprocessgroups
+ * @Project：fw-nifi
+ * @name：Position7
+ * @Date：2025/5/21 14:57
+ * @Filename：Position7
+ */
+@Data
+public class Position7 {
+    private String x;
+    private String y;
+
+    public Position7() {
+    }
+
+    public Position7(String x, String y) {
+        this.x = x;
+        this.y = y;
+    }
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinprocessgroups/ProcessGroupStatus.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.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;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinprocessgroups/ProcessGroupsJoin.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifiapi.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;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinprocessgroups/Revision5.java

@@ -0,0 +1,8 @@
+package com.hzya.frame.nifiapi.model.joinprocessgroups;
+
+import lombok.Data;
+
+@Data
+public class Revision5 {
+    private int version;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinsnippetinstance/SnippetInstanceJoin.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifiapi.model.joinsnippetinstance;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joinsnippetinstance
+ * @Project：fw-nifi
+ * @name：SnippetInstanceJoin
+ * @Date：2025/5/17 14:21
+ * @Filename：SnippetInstanceJoin
+ */
+@Data
+public class SnippetInstanceJoin {
+    private String snippetId;
+    private String originX;
+    private String originY;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinsnippets/Snippet.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifiapi.model.joinsnippets;
+
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joinsnippets
+ * @Project：fw-nifi
+ * @name：Snippet
+ * @Date：2025/5/17 11:01
+ * @Filename：Snippet
+ */
+@Data
+public class Snippet {
+    private String parentGroupId;
+    private Map<String, Map<String, String>> processGroups;
+    private Map<String, Map<String, String>> processors;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinsnippets/SnippetsJoin.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.model.joinsnippets;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joinsnippets
+ * @Project：fw-nifi
+ * @name：SnippetsJoin
+ * @Date：2025/5/17 11:00
+ * @Filename：SnippetsJoin
+ */
+@Data
+public class SnippetsJoin {
+    private Snippet snippet;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinstartorstopprocessgroup/Revision10.java

@@ -0,0 +1,17 @@
+/**
+ * Copyright 2025 bejson.com
+ */
+package com.hzya.frame.nifiapi.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;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinstartorstopprocessgroup/StartOrStopProcessGroupsInfoJoin10.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.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;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinupdateprocessor/Revision17.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.model.joinupdateprocessor;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joinupdateprocessor
+ * @Project：fw-nifi
+ * @name：Revision17
+ * @Date：2025/5/19 11:26
+ * @Filename：Revision17
+ */
+@Data
+public class Revision17 {
+    private String version;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/joinupdateprocessor/RunStatusOrStop17.java

@@ -0,0 +1,17 @@
+package com.hzya.frame.nifiapi.model.joinupdateprocessor;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.joinupdateprocessor
+ * @Project：fw-nifi
+ * @name：RunStatusOrStop
+ * @Date：2025/5/19 11:25
+ * @Filename：RunStatusOrStop
+ */
+@Data
+public class RunStatusOrStop17 {
+    private String state;
+    private Revision17 revision;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/nifitemplates/NifiTemplates.java

@@ -0,0 +1,11 @@
+package com.hzya.frame.nifiapi.model.nifitemplates;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class NifiTemplates {
+    private List<Templates> templates;
+    private String generated;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/nifitemplates/Permissions.java

@@ -0,0 +1,9 @@
+package com.hzya.frame.nifiapi.model.nifitemplates;
+
+import lombok.Data;
+
+@Data
+public class Permissions {
+    private String canRead;
+    private String canWrite;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/nifitemplates/Template.java

@@ -0,0 +1,16 @@
+package com.hzya.frame.nifiapi.model.nifitemplates;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
+public class Template {
+    private String uri;
+    private String id;
+    private String groupId;
+    private String name;
+    private String description;
+    private String timestamp;
+    @JsonProperty("encoding-version")
+    private String encodingVersion;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/nifitemplates/Templates.java

@@ -0,0 +1,10 @@
+package com.hzya.frame.nifiapi.model.nifitemplates;
+
+import lombok.Data;
+
+@Data
+public class Templates {
+    private String id;
+    private Permissions permissions;
+    private Template template;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/AggregateSnapshot.java

@@ -0,0 +1,30 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class AggregateSnapshot {
+    private String id;
+    private String groupId;
+    private String name;
+    private String type;
+    private String runStatus;
+    private String executionNode;
+    private String bytesRead;
+    private String bytesWritten;
+    private String read;
+    private String written;
+    private String flowFilesIn;
+    private String bytesIn;
+    private String input;
+    private String flowFilesOut;
+    private String bytesOut;
+    private String output;
+    private String taskCount;
+    private String tasksDurationNanos;
+    private String tasks;
+    private String tasksDuration;
+    private String activeThreadCount;
+    private String terminatedThreadCount;
+    private ProcessingPerformanceStatus processingPerformanceStatus;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/AllowableValue.java

@@ -0,0 +1,10 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class AllowableValue {
+    private String displayName;
+    private String value;
+    private String description;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/AllowableValues.java

@@ -0,0 +1,9 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class AllowableValues {
+    private AllowableValue allowableValue;
+    private String canRead;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/AttributesToIgnore.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class AttributesToIgnore {
+    private String name;
+    private String displayName;
+    private String description;
+    private String required;
+    private String sensitive;
+    private String dynamic;
+    private String supportsEl;
+    private String expressionLanguageScope;
+    private List<String> dependencies;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/AttributesToIgnoreRegex.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class AttributesToIgnoreRegex {
+    private String name;
+    private String displayName;
+    private String description;
+    private String required;
+    private String sensitive;
+    private String dynamic;
+    private String supportsEl;
+    private String expressionLanguageScope;
+    private List<String> dependencies;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/AttributesToLog.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class AttributesToLog {
+    private String name;
+    private String displayName;
+    private String description;
+    private String required;
+    private String sensitive;
+    private String dynamic;
+    private String supportsEl;
+    private String expressionLanguageScope;
+    private List<String> dependencies;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/AttributesToLogRegex.java

@@ -0,0 +1,19 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class AttributesToLogRegex {
+    private String name;
+    private String displayName;
+    private String description;
+    private String defaultValue;
+    private String required;
+    private String sensitive;
+    private String dynamic;
+    private String supportsEl;
+    private String expressionLanguageScope;
+    private List<String> dependencies;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Breadcrumb.java

@@ -0,0 +1,9 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Breadcrumb {
+    private String id;
+    private String name;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Breadcrumb2.java

@@ -0,0 +1,11 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Breadcrumb2 {
+    private String id;
+    private Permissions2 permissions;
+    private Breadcrumb3 breadcrumb;
+    private ParentBreadcrumb2 parentBreadcrumb;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Breadcrumb3.java

@@ -0,0 +1,17 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.processgroupid
+ * @Project：fw-nifi
+ * @name：Breadcrumb3
+ * @Date：2025/5/14 17:57
+ * @Filename：Breadcrumb3
+ */
+@Data
+public class Breadcrumb3 {
+    private String id;
+    private String name;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Bulletin.java

@@ -0,0 +1,15 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Bulletin {
+    private String id;
+    private String category;
+    private String groupId;
+    private String sourceId;
+    private String sourceName;
+    private String level;
+    private String message;
+    private String timestamp;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Bulletins.java

@@ -0,0 +1,13 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Bulletins {
+    private String id;
+    private String groupId;
+    private String sourceId;
+    private String timestamp;
+    private String canRead;
+    private Bulletin bulletin;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Bundle.java

@@ -0,0 +1,10 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Bundle {
+    private String group;
+    private String artifact;
+    private String version;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/CharacterSet.java

@@ -0,0 +1,19 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class CharacterSet {
+    private String name;
+    private String displayName;
+    private String description;
+    private String defaultValue;
+    private String required;
+    private String sensitive;
+    private String dynamic;
+    private String supportsEl;
+    private String expressionLanguageScope;
+    private List<String> dependencies;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Component.java

@@ -0,0 +1,13 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Component {
+    private String id;
+    private String name;
+    private String comments;
+    private String state;
+    private String type;
+    private String concurrentlySchedulableTaskCount;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Component2.java

@@ -0,0 +1,32 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class Component2 {
+    private String id;
+    private String name;
+    private String versionedComponentId;
+    private String parentGroupId;
+    private Position position;
+    private String type;
+    private Bundle bundle;
+    private String state;
+    private Object style;
+    private List<Relationships> relationships;
+    private String supportsParallelProcessing;
+    private String supportsEventDriven;
+    private String supportsBatching;
+    private String supportsSensitiveDynamicProperties;
+    private String persistsState;
+    private String restricted;
+    private String deprecated;
+    private String executionNodeRestricted;
+    private String multipleVersionsAvailable;
+    private String inputRequirement;
+    private String validationStatus;
+    private String extensionMissing;
+    private Config config;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Config.java

@@ -0,0 +1,27 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class Config {
+    private Properties properties;
+    private Descriptors descriptors;
+    private String schedulingPeriod;
+    private String schedulingStrategy;
+    private String executionNode;
+    private String penaltyDuration;
+    private String yieldDuration;
+    private String bulletinLevel;
+    private String runDurationMillis;
+    private String concurrentlySchedulableTaskCount;
+    private String comments;
+    private String lossTolerant;
+    private DefaultConcurrentTasks defaultConcurrentTasks;
+    private DefaultSchedulingPeriod defaultSchedulingPeriod;
+    private String retryCount;
+    private List<String> retriedRelationships;
+    private String backoffMechanism;
+    private String maxBackoffPeriod;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Connections.java

@@ -0,0 +1,22 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Connections {
+    private Revision2 revision;
+    private String id;
+    private String uri;
+    private Permissions permissions;
+    private Component component;
+    private Status status;
+//    private List<String> bends;
+    private String labelIndex;
+    private String zIndex;
+    private String sourceId;
+    private String sourceGroupId;
+    private String sourceType;
+    private String destinationId;
+    private String destinationGroupId;
+    private String destinationType;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/DefaultConcurrentTasks.java

@@ -0,0 +1,14 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
+public class DefaultConcurrentTasks {
+    @JsonProperty("TIMER_DRIVEN")
+    private String tIMERDRIVEN;
+    @JsonProperty("EVENT_DRIVEN")
+    private String eVENTDRIVEN;
+    @JsonProperty("CRON_DRIVEN")
+    private String cRONDRIVEN;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/DefaultSchedulingPeriod.java

@@ -0,0 +1,12 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
+public class DefaultSchedulingPeriod {
+    @JsonProperty("TIMER_DRIVEN")
+    private String tIMERDRIVEN;
+    @JsonProperty("CRON_DRIVEN")
+    private String cRONDRIVEN;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Descriptors.java

@@ -0,0 +1,37 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
+public class Descriptors {
+    @JsonProperty("Log Level")
+    private LogLevel logLevel;
+
+    @JsonProperty("Log Payload")
+    private LogPayload logPayload;
+
+    @JsonProperty("Attributes to Log")
+    private AttributesToLog attributesToLog;
+
+    @JsonProperty("attributes-to-log-regex")
+    private AttributesToLogRegex attributesToLogRegex;
+
+    @JsonProperty("Attributes to Ignore")
+    private AttributesToIgnore attributesToIgnore;
+
+    @JsonProperty("attributes-to-ignore-regex")
+    private AttributesToIgnoreRegex attributesToIgnoreRegex;
+
+    @JsonProperty("Log FlowFile Properties")
+    private LogFlowFileProperties logFlowFileProperties;
+
+    @JsonProperty("Output Format")
+    private OutputFormat outputFormat;
+
+    @JsonProperty("Log prefix")
+    private LogPrefix logprefix;
+
+    @JsonProperty("character-set")
+    private CharacterSet characterSet;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Destination.java

@@ -0,0 +1,14 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Destination {
+    private String id;
+    private String versionedComponentId;
+    private String type;
+    private String groupId;
+    private String name;
+    private String running;
+    private String comments;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Dimensions.java

@@ -0,0 +1,9 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Dimensions {
+    private String width;
+    private String height;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Flow.java

@@ -0,0 +1,17 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class Flow {
+    private List<String> processGroups;
+    private List<String> remoteProcessGroups;
+    private List<Processors> processors;
+    private List<InputPorts> inputPorts;
+    private List<OutputPorts> outputPorts;
+    private List<Connections> connections;
+    private List<Labels> labels;
+    private List<String> funnels;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/InputPorts.java

@@ -0,0 +1,19 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class InputPorts {
+    private Revision2 revision;
+    private String id;
+    private String uri;
+    private Position position;
+    private Permissions permissions;
+    private List<String> bulletins;
+    private Component component;
+    private Status status;
+    private String portType;
+    private OperatePermissions operatePermissions;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Labels.java

@@ -0,0 +1,15 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Labels {
+    private Revision2 revision;
+    private String id;
+    private String uri;
+    private Position position;
+    private Permissions permissions;
+    private Dimensions dimensions;
+    private String zIndex;
+    private Component component;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/LogFlowFileProperties.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class LogFlowFileProperties {
+    private String name;
+    private String displayName;
+    private String description;
+    private String defaultValue;
+    private List<AllowableValues> allowableValues;
+    private String required;
+    private String sensitive;
+    private String dynamic;
+    private String supportsEl;
+    private String expressionLanguageScope;
+    private List<String> dependencies;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/LogLevel.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class LogLevel {
+    private String name;
+    private String displayName;
+    private String description;
+    private String defaultValue;
+    private List<AllowableValues> allowableValues;
+    private String required;
+    private String sensitive;
+    private String dynamic;
+    private String supportsEl;
+    private String expressionLanguageScope;
+    private List<String> dependencies;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/LogPayload.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class LogPayload {
+    private String name;
+    private String displayName;
+    private String description;
+    private String defaultValue;
+    private List<AllowableValues> allowableValues;
+    private String required;
+    private String sensitive;
+    private String dynamic;
+    private String supportsEl;
+    private String expressionLanguageScope;
+    private List<String> dependencies;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/LogPrefix.java

@@ -0,0 +1,18 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class LogPrefix {
+    private String name;
+    private String displayName;
+    private String description;
+    private String required;
+    private String sensitive;
+    private String dynamic;
+    private String supportsEl;
+    private String expressionLanguageScope;
+    private List<String> dependencies;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/OperatePermissions.java

@@ -0,0 +1,9 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class OperatePermissions {
+    private String canRead;
+    private String canWrite;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/OutputFormat.java

@@ -0,0 +1,20 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class OutputFormat {
+    private String name;
+    private String displayName;
+    private String description;
+    private String defaultValue;
+    private List<AllowableValues> allowableValues;
+    private String required;
+    private String sensitive;
+    private String dynamic;
+    private String supportsEl;
+    private String expressionLanguageScope;
+    private List<String> dependencies;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/OutputPorts.java

@@ -0,0 +1,19 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class OutputPorts {
+    private Revision2 revision;
+    private String id;
+    private String uri;
+    private Position position;
+    private Permissions permissions;
+    private List<String> bulletins;
+    private Component component;
+    private Status status;
+    private String portType;
+    private OperatePermissions operatePermissions;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/ParameterContext.java

@@ -0,0 +1,10 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class ParameterContext {
+    private String id;
+    private Permissions permissions;
+    private Component component;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/ParentBreadcrumb.java

@@ -0,0 +1,10 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class ParentBreadcrumb {
+    private String id;
+    private Permissions permissions;
+    private Breadcrumb breadcrumb;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/ParentBreadcrumb2.java

@@ -0,0 +1,19 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.processgroupid
+ * @Project：fw-nifi
+ * @name：ParentBreadcrumb2
+ * @Date：2025/5/14 17:58
+ * @Filename：ParentBreadcrumb2
+ */
+@Data
+public class ParentBreadcrumb2 {
+    private String id;
+    private Permissions2 permissions;
+    private Breadcrumb3 breadcrumb;
+    private ParentBreadcrumb2 parentBreadcrumb;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Permissions.java

@@ -0,0 +1,9 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Permissions {
+    private String canRead;
+    private String canWrite;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Permissions2.java

@@ -0,0 +1,17 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+/**
+ * @Author：liuyang
+ * @Package：com.hzya.frame.nifi.model.processgroupid
+ * @Project：fw-nifi
+ * @name：Permissions2
+ * @Date：2025/5/14 17:57
+ * @Filename：Permissions2
+ */
+@Data
+public class Permissions2 {
+    private String canRead;
+    private String canWrite;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Position.java

@@ -0,0 +1,9 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Position {
+    private String x;
+    private String y;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/ProcessGroupFlow.java

@@ -0,0 +1,14 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class ProcessGroupFlow {
+    private String id;
+    private String uri;
+    private String parentGroupId;
+    private ParameterContext parameterContext;
+    private Breadcrumb2 breadcrumb;
+    private Flow flow;
+    private String lastRefreshed;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/ProcessGroupsId.java

@@ -0,0 +1,9 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class ProcessGroupsId {
+    private Permissions permissions;
+    private ProcessGroupFlow processGroupFlow;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/ProcessingPerformanceStatus.java

@@ -0,0 +1,13 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class ProcessingPerformanceStatus {
+    private String identifier;
+    private String cpuDuration;
+    private String contentReadDuration;
+    private String contentWriteDuration;
+    private String sessionCommitDuration;
+    private String garbageCollectionDuration;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Processors.java

@@ -0,0 +1,19 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class Processors {
+    private Revision2 revision;
+    private String id;
+    private String uri;
+    private Position position;
+    private Permissions permissions;
+    private List<Bulletins> bulletins;
+    private Component2 component;
+    private String inputRequirement;
+    private Status status;
+    private OperatePermissions operatePermissions;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Properties.java

@@ -0,0 +1,47 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * Auto-generated: 2025-05-14 16:51:34
+ *
+ * @author lzltool.com
+ * @website https://www.lzltool.com/JsonToJava
+ */
+@Data
+public class Properties {
+
+    @JsonProperty("Log Level")
+    private String logLevel;
+
+    @JsonProperty("Log Payload")
+    private String logPayload;
+
+    @JsonProperty("Attributes to Log")
+    private String attributesToLog;
+
+    @JsonProperty("attributes-to-log-regex")
+    private String attributesToLogRegex;
+
+    @JsonProperty("Attributes to Ignore")
+    private String attributesToIgnore;
+
+    @JsonProperty("attributes-to-ignore-regex")
+    private String attributesToIgnoreRegex;
+
+    @JsonProperty("Log FlowFile Properties")
+    private String logFlowFileProperties;
+
+    @JsonProperty("Output Format")
+    private String outputFormat;
+
+    @JsonProperty("Log prefix")
+    private String logPrefix;
+
+    @JsonProperty("character-set")
+    private String characterSet;
+
+    @JsonProperty("Database Connection Pooling Service")
+    private String databaseConnectionPoolingService;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Relationships.java

@@ -0,0 +1,11 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Relationships {
+    private String name;
+    private String description;
+    private String autoTerminate;
+    private String retry;
+}

base-service/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Revision2.java

@@ -0,0 +1,8 @@
+package com.hzya.frame.nifiapi.model.processgroupid;
+
+import lombok.Data;
+
+@Data
+public class Revision2 {
+    private int version;
+}