From b6c839c638842915beda22486097294f5f368634 Mon Sep 17 00:00:00 2001
From: 55007 <55007@maojian>
Date: Tue, 7 Jan 2025 16:03:27 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9C=89=E7=9F=A5=E6=95=B0=E6=8D=AE=E6=B5=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.classpath | 40 +
.gitignore | 3 +
.project | 23 +
.settings/org.eclipse.core.resources.prefs | 5 +
.settings/org.eclipse.jdt.core.prefs | 9 +
.settings/org.eclipse.m2e.core.prefs | 4 +
README.md | 1 +
pom.xml | 269 ++++++
src/main/java/com/bfd/analyze/Application.java | 29 +
.../java/com/bfd/analyze/cache/ConfigCache.java | 49 ++
.../java/com/bfd/analyze/config/BillingConfig.java | 42 +
.../java/com/bfd/analyze/config/KafkaConfig.java | 20 +
.../com/bfd/analyze/config/ThreadPoolConfig.java | 43 +
.../com/bfd/analyze/config/ZookeeperConfig.java | 25 +
.../controller/ProcessTriggerController.java | 115 +++
.../java/com/bfd/analyze/entity/AnalystData.java | 41 +
.../java/com/bfd/analyze/entity/Constants.java | 149 ++++
.../com/bfd/analyze/handler/DataExecHandler.java | 314 +++++++
.../java/com/bfd/analyze/mapper/AppsMapper.java | 71 ++
.../com/bfd/analyze/mapper/BlueprintMapper.java | 51 ++
.../java/com/bfd/analyze/mapper/ModulesMapper.java | 42 +
.../com/bfd/analyze/mapper/RelationsMapper.java | 37 +
.../java/com/bfd/analyze/mapper/ScenesMapper.java | 47 ++
.../java/com/bfd/analyze/model/AppsEntity.java | 56 ++
.../com/bfd/analyze/model/BlueprintEntity.java | 44 +
.../java/com/bfd/analyze/model/ModulesEntity.java | 53 ++
.../com/bfd/analyze/model/RelationsEntity.java | 42 +
.../java/com/bfd/analyze/model/ScenesEntity.java | 59 ++
.../bfd/analyze/monitor/ZookeeperNodeMonitor.java | 50 ++
.../com/bfd/analyze/process/ErrorTaskProcess.java | 75 ++
.../bfd/analyze/process/ResultParseProcess.java | 365 +++++++++
.../com/bfd/analyze/process/ResultSendQueue.java | 48 ++
.../com/bfd/analyze/process/SaveDataProcess.java | 57 ++
.../bfd/analyze/process/TaskdispatchProcess.java | 248 ++++++
.../java/com/bfd/analyze/service/DataService.java | 18 +
.../analyze/service/DistributedLockService.java | 23 +
.../bfd/analyze/service/ProcessTriggerService.java | 59 ++
.../bfd/analyze/service/impl/DataServiceImpl.java | 240 ++++++
.../service/impl/DistributedLockServiceImpl.java | 40 +
.../service/impl/ProcessTriggerServiceImpl.java | 637 ++++++++++++++
.../bfd/analyze/test/CreateElasticsearchIndex.java | 79 ++
.../bfd/analyze/test/DeleteElasticsearchIndex.java | 58 ++
.../bfd/analyze/test/HttpClientDeleteExample.java | 59 ++
.../bfd/analyze/test/IndexDataWithHttpClient.java | 81 ++
src/main/java/com/bfd/analyze/utils/DateUtil.java | 177 ++++
.../java/com/bfd/analyze/utils/DownLoadUtil.java | 912 +++++++++++++++++++++
.../com/bfd/analyze/utils/ElasticsearchUtil.java | 408 +++++++++
.../java/com/bfd/analyze/utils/EncryptionUtil.java | 27 +
src/main/java/com/bfd/analyze/utils/FileUtil.java | 30 +
src/main/java/com/bfd/analyze/utils/JsonUtil.java | 39 +
.../java/com/bfd/analyze/utils/OtherUtils.java | 32 +
src/main/java/com/bfd/analyze/utils/PauseTool.java | 69 ++
src/main/java/com/bfd/analyze/utils/QueueUtil.java | 107 +++
.../com/bfd/analyze/utils/SpringBootKafka.java | 48 ++
.../bfd/analyze/utils/SqlStatementInterceptor.java | 226 +++++
.../com/bfd/analyze/utils/ThrowMessageUtil.java | 23 +
src/main/resources/application.yml | 136 +++
src/main/resources/logback-spring.xml | 36 +
src/test/java/com/bfd/AppTest.java | 20 +
59 files changed, 6110 insertions(+)
create mode 100644 .classpath
create mode 100644 .gitignore
create mode 100644 .project
create mode 100644 .settings/org.eclipse.core.resources.prefs
create mode 100644 .settings/org.eclipse.jdt.core.prefs
create mode 100644 .settings/org.eclipse.m2e.core.prefs
create mode 100644 README.md
create mode 100644 pom.xml
create mode 100644 src/main/java/com/bfd/analyze/Application.java
create mode 100644 src/main/java/com/bfd/analyze/cache/ConfigCache.java
create mode 100644 src/main/java/com/bfd/analyze/config/BillingConfig.java
create mode 100644 src/main/java/com/bfd/analyze/config/KafkaConfig.java
create mode 100644 src/main/java/com/bfd/analyze/config/ThreadPoolConfig.java
create mode 100644 src/main/java/com/bfd/analyze/config/ZookeeperConfig.java
create mode 100644 src/main/java/com/bfd/analyze/controller/ProcessTriggerController.java
create mode 100644 src/main/java/com/bfd/analyze/entity/AnalystData.java
create mode 100644 src/main/java/com/bfd/analyze/entity/Constants.java
create mode 100644 src/main/java/com/bfd/analyze/handler/DataExecHandler.java
create mode 100644 src/main/java/com/bfd/analyze/mapper/AppsMapper.java
create mode 100644 src/main/java/com/bfd/analyze/mapper/BlueprintMapper.java
create mode 100644 src/main/java/com/bfd/analyze/mapper/ModulesMapper.java
create mode 100644 src/main/java/com/bfd/analyze/mapper/RelationsMapper.java
create mode 100644 src/main/java/com/bfd/analyze/mapper/ScenesMapper.java
create mode 100644 src/main/java/com/bfd/analyze/model/AppsEntity.java
create mode 100644 src/main/java/com/bfd/analyze/model/BlueprintEntity.java
create mode 100644 src/main/java/com/bfd/analyze/model/ModulesEntity.java
create mode 100644 src/main/java/com/bfd/analyze/model/RelationsEntity.java
create mode 100644 src/main/java/com/bfd/analyze/model/ScenesEntity.java
create mode 100644 src/main/java/com/bfd/analyze/monitor/ZookeeperNodeMonitor.java
create mode 100644 src/main/java/com/bfd/analyze/process/ErrorTaskProcess.java
create mode 100644 src/main/java/com/bfd/analyze/process/ResultParseProcess.java
create mode 100644 src/main/java/com/bfd/analyze/process/ResultSendQueue.java
create mode 100644 src/main/java/com/bfd/analyze/process/SaveDataProcess.java
create mode 100644 src/main/java/com/bfd/analyze/process/TaskdispatchProcess.java
create mode 100644 src/main/java/com/bfd/analyze/service/DataService.java
create mode 100644 src/main/java/com/bfd/analyze/service/DistributedLockService.java
create mode 100644 src/main/java/com/bfd/analyze/service/ProcessTriggerService.java
create mode 100644 src/main/java/com/bfd/analyze/service/impl/DataServiceImpl.java
create mode 100644 src/main/java/com/bfd/analyze/service/impl/DistributedLockServiceImpl.java
create mode 100644 src/main/java/com/bfd/analyze/service/impl/ProcessTriggerServiceImpl.java
create mode 100644 src/main/java/com/bfd/analyze/test/CreateElasticsearchIndex.java
create mode 100644 src/main/java/com/bfd/analyze/test/DeleteElasticsearchIndex.java
create mode 100644 src/main/java/com/bfd/analyze/test/HttpClientDeleteExample.java
create mode 100644 src/main/java/com/bfd/analyze/test/IndexDataWithHttpClient.java
create mode 100644 src/main/java/com/bfd/analyze/utils/DateUtil.java
create mode 100644 src/main/java/com/bfd/analyze/utils/DownLoadUtil.java
create mode 100644 src/main/java/com/bfd/analyze/utils/ElasticsearchUtil.java
create mode 100644 src/main/java/com/bfd/analyze/utils/EncryptionUtil.java
create mode 100644 src/main/java/com/bfd/analyze/utils/FileUtil.java
create mode 100644 src/main/java/com/bfd/analyze/utils/JsonUtil.java
create mode 100644 src/main/java/com/bfd/analyze/utils/OtherUtils.java
create mode 100644 src/main/java/com/bfd/analyze/utils/PauseTool.java
create mode 100644 src/main/java/com/bfd/analyze/utils/QueueUtil.java
create mode 100644 src/main/java/com/bfd/analyze/utils/SpringBootKafka.java
create mode 100644 src/main/java/com/bfd/analyze/utils/SqlStatementInterceptor.java
create mode 100644 src/main/java/com/bfd/analyze/utils/ThrowMessageUtil.java
create mode 100644 src/main/resources/application.yml
create mode 100644 src/main/resources/logback-spring.xml
create mode 100644 src/test/java/com/bfd/AppTest.java
diff --git a/.classpath b/.classpath
new file mode 100644
index 0000000..deb4b51
--- /dev/null
+++ b/.classpath
@@ -0,0 +1,40 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..aa25188
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,3 @@
+/target/
+/logs/
+/.idea/
\ No newline at end of file
diff --git a/.project b/.project
new file mode 100644
index 0000000..7dca559
--- /dev/null
+++ b/.project
@@ -0,0 +1,23 @@
+
+
+ analyst_assistant_schedule
+
+
+
+
+
+ org.eclipse.jdt.core.javabuilder
+
+
+
+
+ org.eclipse.m2e.core.maven2Builder
+
+
+
+
+
+ org.eclipse.jdt.core.javanature
+ org.eclipse.m2e.core.maven2Nature
+
+
diff --git a/.settings/org.eclipse.core.resources.prefs b/.settings/org.eclipse.core.resources.prefs
new file mode 100644
index 0000000..365bbd6
--- /dev/null
+++ b/.settings/org.eclipse.core.resources.prefs
@@ -0,0 +1,5 @@
+eclipse.preferences.version=1
+encoding//src/main/java=UTF-8
+encoding//src/main/resources=UTF-8
+encoding//src/test/java=UTF-8
+encoding/=UTF-8
diff --git a/.settings/org.eclipse.jdt.core.prefs b/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 0000000..0ada971
--- /dev/null
+++ b/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,9 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.methodParameters=generate
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=1.8
diff --git a/.settings/org.eclipse.m2e.core.prefs b/.settings/org.eclipse.m2e.core.prefs
new file mode 100644
index 0000000..14b697b
--- /dev/null
+++ b/.settings/org.eclipse.m2e.core.prefs
@@ -0,0 +1,4 @@
+activeProfiles=
+eclipse.preferences.version=1
+resolveWorkspaceProjects=true
+version=1
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..7c67fd0
--- /dev/null
+++ b/README.md
@@ -0,0 +1 @@
+分析助手应用调度
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..2034791
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,269 @@
+
+
+
+ 4.0.0
+
+
+ org.springframework.boot
+ spring-boot-starter-parent
+ 2.2.4.RELEASE
+
+ com.bfd.analyze
+ analyst_assistant_schedule
+ 0.0.1-SNAPSHOT
+
+ analyst_assistant_schedule
+
+ http://www.example.com
+
+
+ UTF-8
+ 1.8
+ 1.8
+
+
+
+
+ junit
+ junit
+ 4.11
+ test
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+ de.codecentric
+ spring-boot-admin-starter-client
+ 2.2.4
+
+
+ com.google.code.gson
+ gson
+ 2.8.8
+
+
+ org.mybatis.spring.boot
+ mybatis-spring-boot-starter
+ 2.0.0
+
+
+ org.springframework.boot
+ spring-boot-test
+
+
+
+ org.springframework
+ spring-test
+ 5.0.10.RELEASE
+ test
+
+
+ commons-io
+ commons-io
+ 1.4
+
+
+ com.alibaba
+ fastjson
+ 2.0.17
+
+
+
+ com.mchange
+ c3p0
+ 0.9.5.5
+
+
+ mysql
+ mysql-connector-java
+ 8.0.29
+
+
+
+ com.squareup.okhttp3
+ okhttp
+ 4.9.3
+
+
+ org.apache.httpcomponents
+ httpclient
+ 4.5.3
+
+
+ commons-lang
+ commons-lang
+ 2.6
+
+
+
+ org.jetbrains.kotlin
+ kotlin-reflect
+ 1.6.21
+ runtime
+
+
+
+ redis.clients
+ jedis
+ 3.3.0
+
+
+
+ org.jsoup
+ jsoup
+ 1.8.1
+
+
+
+ org.projectlombok
+ lombok
+
+
+
+
+
+
+
+ org.springframework.kafka
+ spring-kafka
+
+
+ cn.hutool
+ hutool-all
+ 5.8.5
+
+
+ junit
+ junit
+
+
+
+ p6spy
+ p6spy
+ 3.9.0
+
+
+
+ commons-collections
+ commons-collections
+ 3.2.2
+
+
+
+
+
+ org.redisson
+ redisson-spring-boot-starter
+ 3.13.6
+
+
+ org.springframework.boot
+ spring-boot-starter-data-redis
+
+
+ org.apache.curator
+ curator-framework
+ 5.2.0
+
+
+ org.apache.curator
+ curator-recipes
+ 5.2.0
+
+
+
+
+
+
+
+
+
+ maven-clean-plugin
+ 3.1.0
+
+
+
+ maven-resources-plugin
+ 3.0.2
+
+
+ maven-compiler-plugin
+ 3.8.0
+
+
+ maven-surefire-plugin
+ 2.22.1
+
+
+ maven-jar-plugin
+ 3.0.2
+
+
+ maven-install-plugin
+ 2.5.2
+
+
+ maven-deploy-plugin
+ 2.8.2
+
+
+
+ maven-site-plugin
+ 3.7.1
+
+
+ maven-project-info-reports-plugin
+ 3.0.0
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+ com.bfd.analyze.Application
+ ZIP
+
+
+ ${project.groupId}
+ ${project.artifactId}
+
+
+
+
+
+
+ repackage
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-dependency-plugin
+ 3.1.1
+
+
+ copy
+ package
+
+ copy-dependencies
+
+
+ jar
+ jar
+ runtime
+ ${project.build.directory}/libs
+
+
+
+
+
+
+
+
diff --git a/src/main/java/com/bfd/analyze/Application.java b/src/main/java/com/bfd/analyze/Application.java
new file mode 100644
index 0000000..9efb4ec
--- /dev/null
+++ b/src/main/java/com/bfd/analyze/Application.java
@@ -0,0 +1,29 @@
+package com.bfd.analyze;
+
+
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.kafka.annotation.EnableKafka;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+/**
+ * 主入口
+ *
+ * @author jian.mao
+ * @date 2023年7月4日
+ * @description
+ */
+@SpringBootApplication
+@MapperScan("com.bfd.analyze.mapper")
+@EnableScheduling
+@EnableKafka
+public class Application {
+
+ public static void main(String[] args) {
+ SpringApplication.run(Application.class, args);
+ }
+
+
+}
diff --git a/src/main/java/com/bfd/analyze/cache/ConfigCache.java b/src/main/java/com/bfd/analyze/cache/ConfigCache.java
new file mode 100644
index 0000000..3a64191
--- /dev/null
+++ b/src/main/java/com/bfd/analyze/cache/ConfigCache.java
@@ -0,0 +1,49 @@
+package com.bfd.analyze.cache;
+
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.Map;
+import java.util.concurrent.LinkedBlockingDeque;
+
+/**
+ * @author jian.mao
+ * @date 2022年11月11日
+ * @description 静态变量类
+ */
+@Slf4j
+public class ConfigCache {
+
+ /**启动条件**/
+ public static boolean isStart = true;
+ /*****任务队列*****/
+ public static LinkedBlockingDeque