diff --git a/.idea/.name b/.idea/.name
deleted file mode 100644
index 0080ff1..0000000
--- a/.idea/.name
+++ /dev/null
@@ -1 +0,0 @@
-cl_stream_30
\ No newline at end of file
diff --git a/.idea/compiler.xml b/.idea/compiler.xml
index 5bef374..88f2527 100644
--- a/.idea/compiler.xml
+++ b/.idea/compiler.xml
@@ -13,7 +13,7 @@
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_alibaba_fastjson_1_2_6.xml b/.idea/libraries/Maven__com_alibaba_fastjson_1_2_60.xml
similarity index 64%
rename from .idea/libraries/Maven__com_alibaba_fastjson_1_2_6.xml
rename to .idea/libraries/Maven__com_alibaba_fastjson_1_2_60.xml
index 0064979..567a643 100644
--- a/.idea/libraries/Maven__com_alibaba_fastjson_1_2_6.xml
+++ b/.idea/libraries/Maven__com_alibaba_fastjson_1_2_60.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_fasterxml_classmate_1_3_1.xml b/.idea/libraries/Maven__com_fasterxml_classmate_1_4_0.xml
similarity index 63%
rename from .idea/libraries/Maven__com_fasterxml_classmate_1_3_1.xml
rename to .idea/libraries/Maven__com_fasterxml_classmate_1_4_0.xml
index cfcab12..bbd3a88 100644
--- a/.idea/libraries/Maven__com_fasterxml_classmate_1_3_1.xml
+++ b/.idea/libraries/Maven__com_fasterxml_classmate_1_4_0.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_9_5.xml b/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_9_6.xml
similarity index 65%
rename from .idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_9_5.xml
rename to .idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_9_6.xml
index 467b779..51087da 100644
--- a/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_9_5.xml
+++ b/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_9_6.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_github_virtuald_curvesapi_1_04.xml b/.idea/libraries/Maven__com_github_virtuald_curvesapi_1_06.xml
similarity index 61%
rename from .idea/libraries/Maven__com_github_virtuald_curvesapi_1_04.xml
rename to .idea/libraries/Maven__com_github_virtuald_curvesapi_1_06.xml
index 2db7431..d156c18 100644
--- a/.idea/libraries/Maven__com_github_virtuald_curvesapi_1_04.xml
+++ b/.idea/libraries/Maven__com_github_virtuald_curvesapi_1_06.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_google_code_findbugs_jsr305_1_3_9.xml b/.idea/libraries/Maven__com_google_code_findbugs_jsr305_1_3_9.xml
new file mode 100644
index 0000000..0e66824
--- /dev/null
+++ b/.idea/libraries/Maven__com_google_code_findbugs_jsr305_1_3_9.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_google_errorprone_error_prone_annotations_2_1_3.xml b/.idea/libraries/Maven__com_google_errorprone_error_prone_annotations_2_1_3.xml
new file mode 100644
index 0000000..2343a7f
--- /dev/null
+++ b/.idea/libraries/Maven__com_google_errorprone_error_prone_annotations_2_1_3.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_google_guava_guava_25_0_jre.xml b/.idea/libraries/Maven__com_google_guava_guava_25_0_jre.xml
new file mode 100644
index 0000000..7de6f07
--- /dev/null
+++ b/.idea/libraries/Maven__com_google_guava_guava_25_0_jre.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_google_j2objc_j2objc_annotations_1_1.xml b/.idea/libraries/Maven__com_google_j2objc_j2objc_annotations_1_1.xml
new file mode 100644
index 0000000..c06f999
--- /dev/null
+++ b/.idea/libraries/Maven__com_google_j2objc_j2objc_annotations_1_1.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_ibm_icu_icu4j_4_6.xml b/.idea/libraries/Maven__com_ibm_icu_icu4j_4_6.xml
new file mode 100644
index 0000000..670405c
--- /dev/null
+++ b/.idea/libraries/Maven__com_ibm_icu_icu4j_4_6.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_monitorjbl_xlsx_streamer_2_1_0.xml b/.idea/libraries/Maven__com_monitorjbl_xlsx_streamer_2_1_0.xml
new file mode 100644
index 0000000..8797c89
--- /dev/null
+++ b/.idea/libraries/Maven__com_monitorjbl_xlsx_streamer_2_1_0.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_rackspace_apache_xerces2_xsd11_2_11_1.xml b/.idea/libraries/Maven__com_rackspace_apache_xerces2_xsd11_2_11_1.xml
new file mode 100644
index 0000000..50545e3
--- /dev/null
+++ b/.idea/libraries/Maven__com_rackspace_apache_xerces2_xsd11_2_11_1.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_rackspace_eclipse_webtools_sourceediting_org_eclipse_wst_xml_xpath2_processor_2_1_100.xml b/.idea/libraries/Maven__com_rackspace_eclipse_webtools_sourceediting_org_eclipse_wst_xml_xpath2_processor_2_1_100.xml
new file mode 100644
index 0000000..5624ade
--- /dev/null
+++ b/.idea/libraries/Maven__com_rackspace_eclipse_webtools_sourceediting_org_eclipse_wst_xml_xpath2_processor_2_1_100.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_squareup_okhttp3_okhttp_3_9_1.xml b/.idea/libraries/Maven__com_squareup_okhttp3_okhttp_3_6_0.xml
similarity index 62%
rename from .idea/libraries/Maven__com_squareup_okhttp3_okhttp_3_9_1.xml
rename to .idea/libraries/Maven__com_squareup_okhttp3_okhttp_3_6_0.xml
index ba9cb81..58edcd1 100644
--- a/.idea/libraries/Maven__com_squareup_okhttp3_okhttp_3_9_1.xml
+++ b/.idea/libraries/Maven__com_squareup_okhttp3_okhttp_3_6_0.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_squareup_okio_okio_1_13_0.xml b/.idea/libraries/Maven__com_squareup_okio_okio_1_11_0.xml
similarity index 65%
rename from .idea/libraries/Maven__com_squareup_okio_okio_1_13_0.xml
rename to .idea/libraries/Maven__com_squareup_okio_okio_1_11_0.xml
index cb99e2f..0ddf7cf 100644
--- a/.idea/libraries/Maven__com_squareup_okio_okio_1_13_0.xml
+++ b/.idea/libraries/Maven__com_squareup_okio_okio_1_11_0.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_sun_mail_javax_mail_1_6_2.xml b/.idea/libraries/Maven__com_sun_mail_javax_mail_1_6_2.xml
new file mode 100644
index 0000000..f5980e4
--- /dev/null
+++ b/.idea/libraries/Maven__com_sun_mail_javax_mail_1_6_2.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__com_swagger_ui_swagger_bootstrap_ui_1_8_8.xml b/.idea/libraries/Maven__com_swagger_ui_swagger_bootstrap_ui_1_8_8.xml
deleted file mode 100644
index b8ce1b6..0000000
--- a/.idea/libraries/Maven__com_swagger_ui_swagger_bootstrap_ui_1_8_8.xml
+++ /dev/null
@@ -1,13 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/.idea/libraries/Maven__commons_codec_commons_codec_1_10.xml b/.idea/libraries/Maven__commons_codec_commons_codec_1_12.xml
similarity index 61%
rename from .idea/libraries/Maven__commons_codec_commons_codec_1_10.xml
rename to .idea/libraries/Maven__commons_codec_commons_codec_1_12.xml
index 27424a1..0953394 100644
--- a/.idea/libraries/Maven__commons_codec_commons_codec_1_10.xml
+++ b/.idea/libraries/Maven__commons_codec_commons_codec_1_12.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__edu_princeton_cup_java_cup_10k.xml b/.idea/libraries/Maven__edu_princeton_cup_java_cup_10k.xml
new file mode 100644
index 0000000..12ad41d
--- /dev/null
+++ b/.idea/libraries/Maven__edu_princeton_cup_java_cup_10k.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__io_springfox_springfox_core_2_6_1.xml b/.idea/libraries/Maven__io_springfox_springfox_core_2_9_2.xml
similarity index 59%
rename from .idea/libraries/Maven__io_springfox_springfox_core_2_6_1.xml
rename to .idea/libraries/Maven__io_springfox_springfox_core_2_9_2.xml
index 6b4a6c2..03588dc 100644
--- a/.idea/libraries/Maven__io_springfox_springfox_core_2_6_1.xml
+++ b/.idea/libraries/Maven__io_springfox_springfox_core_2_9_2.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__io_springfox_springfox_schema_2_6_1.xml b/.idea/libraries/Maven__io_springfox_springfox_schema_2_9_2.xml
similarity index 58%
rename from .idea/libraries/Maven__io_springfox_springfox_schema_2_6_1.xml
rename to .idea/libraries/Maven__io_springfox_springfox_schema_2_9_2.xml
index 9e4a94d..4a47148 100644
--- a/.idea/libraries/Maven__io_springfox_springfox_schema_2_6_1.xml
+++ b/.idea/libraries/Maven__io_springfox_springfox_schema_2_9_2.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__io_springfox_springfox_spi_2_6_1.xml b/.idea/libraries/Maven__io_springfox_springfox_spi_2_9_2.xml
similarity index 60%
rename from .idea/libraries/Maven__io_springfox_springfox_spi_2_6_1.xml
rename to .idea/libraries/Maven__io_springfox_springfox_spi_2_9_2.xml
index 6458cbb..f934649 100644
--- a/.idea/libraries/Maven__io_springfox_springfox_spi_2_6_1.xml
+++ b/.idea/libraries/Maven__io_springfox_springfox_spi_2_9_2.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__io_springfox_springfox_spring_web_2_6_1.xml b/.idea/libraries/Maven__io_springfox_springfox_spring_web_2_9_2.xml
similarity index 55%
rename from .idea/libraries/Maven__io_springfox_springfox_spring_web_2_6_1.xml
rename to .idea/libraries/Maven__io_springfox_springfox_spring_web_2_9_2.xml
index 5c4d152..7898a19 100644
--- a/.idea/libraries/Maven__io_springfox_springfox_spring_web_2_6_1.xml
+++ b/.idea/libraries/Maven__io_springfox_springfox_spring_web_2_9_2.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__io_springfox_springfox_swagger2_2_6_1.xml b/.idea/libraries/Maven__io_springfox_springfox_swagger2_2_9_2.xml
similarity index 56%
rename from .idea/libraries/Maven__io_springfox_springfox_swagger2_2_6_1.xml
rename to .idea/libraries/Maven__io_springfox_springfox_swagger2_2_9_2.xml
index 3d5a04d..4ed7d0d 100644
--- a/.idea/libraries/Maven__io_springfox_springfox_swagger2_2_6_1.xml
+++ b/.idea/libraries/Maven__io_springfox_springfox_swagger2_2_9_2.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__io_springfox_springfox_swagger_common_2_6_1.xml b/.idea/libraries/Maven__io_springfox_springfox_swagger_common_2_9_2.xml
similarity index 65%
rename from .idea/libraries/Maven__io_springfox_springfox_swagger_common_2_6_1.xml
rename to .idea/libraries/Maven__io_springfox_springfox_swagger_common_2_9_2.xml
index a3eee0b..c40ef9f 100644
--- a/.idea/libraries/Maven__io_springfox_springfox_swagger_common_2_6_1.xml
+++ b/.idea/libraries/Maven__io_springfox_springfox_swagger_common_2_9_2.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__io_springfox_springfox_swagger_ui_2_9_2.xml b/.idea/libraries/Maven__io_springfox_springfox_swagger_ui_2_9_2.xml
new file mode 100644
index 0000000..0700f01
--- /dev/null
+++ b/.idea/libraries/Maven__io_springfox_springfox_swagger_ui_2_9_2.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__io_swagger_swagger_annotations_1_5_10.xml b/.idea/libraries/Maven__io_swagger_swagger_annotations_1_5_20.xml
similarity index 56%
rename from .idea/libraries/Maven__io_swagger_swagger_annotations_1_5_10.xml
rename to .idea/libraries/Maven__io_swagger_swagger_annotations_1_5_20.xml
index 0097e48..1c4a621 100644
--- a/.idea/libraries/Maven__io_swagger_swagger_annotations_1_5_10.xml
+++ b/.idea/libraries/Maven__io_swagger_swagger_annotations_1_5_20.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__io_swagger_swagger_models_1_5_10.xml b/.idea/libraries/Maven__io_swagger_swagger_models_1_5_20.xml
similarity index 60%
rename from .idea/libraries/Maven__io_swagger_swagger_models_1_5_10.xml
rename to .idea/libraries/Maven__io_swagger_swagger_models_1_5_20.xml
index cd838bb..395508f 100644
--- a/.idea/libraries/Maven__io_swagger_swagger_models_1_5_10.xml
+++ b/.idea/libraries/Maven__io_swagger_swagger_models_1_5_20.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__it_sauronsoftware_jave_1_0_2.xml b/.idea/libraries/Maven__it_sauronsoftware_jave_1_0_2.xml
new file mode 100644
index 0000000..85fabc6
--- /dev/null
+++ b/.idea/libraries/Maven__it_sauronsoftware_jave_1_0_2.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__javax_activation_activation_1_1.xml b/.idea/libraries/Maven__javax_activation_activation_1_1.xml
new file mode 100644
index 0000000..180d587
--- /dev/null
+++ b/.idea/libraries/Maven__javax_activation_activation_1_1.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__javax_mail_javax_mail_api_1_6_2.xml b/.idea/libraries/Maven__javax_mail_javax_mail_api_1_6_2.xml
new file mode 100644
index 0000000..b9b6e8f
--- /dev/null
+++ b/.idea/libraries/Maven__javax_mail_javax_mail_api_1_6_2.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_apache_commons_commons_collections4_4_1.xml b/.idea/libraries/Maven__org_apache_commons_commons_collections4_4_3.xml
similarity index 65%
rename from .idea/libraries/Maven__org_apache_commons_commons_collections4_4_1.xml
rename to .idea/libraries/Maven__org_apache_commons_commons_collections4_4_3.xml
index 1e0b53d..93ddf9a 100644
--- a/.idea/libraries/Maven__org_apache_commons_commons_collections4_4_1.xml
+++ b/.idea/libraries/Maven__org_apache_commons_commons_collections4_4_3.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_apache_commons_commons_compress_1_18.xml b/.idea/libraries/Maven__org_apache_commons_commons_compress_1_18.xml
new file mode 100644
index 0000000..cdc29f4
--- /dev/null
+++ b/.idea/libraries/Maven__org_apache_commons_commons_compress_1_18.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_apache_commons_commons_math3_3_6_1.xml b/.idea/libraries/Maven__org_apache_commons_commons_math3_3_6_1.xml
new file mode 100644
index 0000000..ebfe0a8
--- /dev/null
+++ b/.idea/libraries/Maven__org_apache_commons_commons_math3_3_6_1.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_apache_poi_poi_3_15.xml b/.idea/libraries/Maven__org_apache_poi_poi_3_15.xml
deleted file mode 100644
index 7c6539d..0000000
--- a/.idea/libraries/Maven__org_apache_poi_poi_3_15.xml
+++ /dev/null
@@ -1,13 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_apache_poi_poi_4_1_0.xml b/.idea/libraries/Maven__org_apache_poi_poi_4_1_0.xml
new file mode 100644
index 0000000..1a04a9b
--- /dev/null
+++ b/.idea/libraries/Maven__org_apache_poi_poi_4_1_0.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_apache_poi_poi_ooxml_3_15.xml b/.idea/libraries/Maven__org_apache_poi_poi_ooxml_4_1_0.xml
similarity index 63%
rename from .idea/libraries/Maven__org_apache_poi_poi_ooxml_3_15.xml
rename to .idea/libraries/Maven__org_apache_poi_poi_ooxml_4_1_0.xml
index ce194b5..b2b940d 100644
--- a/.idea/libraries/Maven__org_apache_poi_poi_ooxml_3_15.xml
+++ b/.idea/libraries/Maven__org_apache_poi_poi_ooxml_4_1_0.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_apache_poi_poi_ooxml_schemas_3_15.xml b/.idea/libraries/Maven__org_apache_poi_poi_ooxml_schemas_4_1_0.xml
similarity index 56%
rename from .idea/libraries/Maven__org_apache_poi_poi_ooxml_schemas_3_15.xml
rename to .idea/libraries/Maven__org_apache_poi_poi_ooxml_schemas_4_1_0.xml
index 374f748..674fc7f 100644
--- a/.idea/libraries/Maven__org_apache_poi_poi_ooxml_schemas_3_15.xml
+++ b/.idea/libraries/Maven__org_apache_poi_poi_ooxml_schemas_4_1_0.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_apache_xmlbeans_xmlbeans_2_6_0.xml b/.idea/libraries/Maven__org_apache_xmlbeans_xmlbeans_3_1_0.xml
similarity index 61%
rename from .idea/libraries/Maven__org_apache_xmlbeans_xmlbeans_2_6_0.xml
rename to .idea/libraries/Maven__org_apache_xmlbeans_xmlbeans_3_1_0.xml
index cb0f76d..0695d4b 100644
--- a/.idea/libraries/Maven__org_apache_xmlbeans_xmlbeans_2_6_0.xml
+++ b/.idea/libraries/Maven__org_apache_xmlbeans_xmlbeans_3_1_0.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_checkerframework_checker_compat_qual_2_0_0.xml b/.idea/libraries/Maven__org_checkerframework_checker_compat_qual_2_0_0.xml
new file mode 100644
index 0000000..29defe6
--- /dev/null
+++ b/.idea/libraries/Maven__org_checkerframework_checker_compat_qual_2_0_0.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_codehaus_mojo_animal_sniffer_annotations_1_14.xml b/.idea/libraries/Maven__org_codehaus_mojo_animal_sniffer_annotations_1_14.xml
new file mode 100644
index 0000000..1af11e4
--- /dev/null
+++ b/.idea/libraries/Maven__org_codehaus_mojo_animal_sniffer_annotations_1_14.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_mapstruct_mapstruct_1_0_0_Final.xml b/.idea/libraries/Maven__org_mapstruct_mapstruct_1_2_0_Final.xml
similarity index 58%
rename from .idea/libraries/Maven__org_mapstruct_mapstruct_1_0_0_Final.xml
rename to .idea/libraries/Maven__org_mapstruct_mapstruct_1_2_0_Final.xml
index 5599974..87cb599 100644
--- a/.idea/libraries/Maven__org_mapstruct_mapstruct_1_0_0_Final.xml
+++ b/.idea/libraries/Maven__org_mapstruct_mapstruct_1_2_0_Final.xml
@@ -1,13 +1,13 @@
-
+
-
+
-
+
-
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_12.xml b/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_12.xml
new file mode 100644
index 0000000..411efc6
--- /dev/null
+++ b/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_12.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__stax_stax_api_1_0_1.xml b/.idea/libraries/Maven__stax_stax_api_1_0_1.xml
deleted file mode 100644
index 0b13335..0000000
--- a/.idea/libraries/Maven__stax_stax_api_1_0_1.xml
+++ /dev/null
@@ -1,13 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/.idea/libraries/Maven__xml_apis_xml_apis_1_4_01.xml b/.idea/libraries/Maven__xml_apis_xml_apis_1_4_01.xml
new file mode 100644
index 0000000..9aadd29
--- /dev/null
+++ b/.idea/libraries/Maven__xml_apis_xml_apis_1_4_01.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/libraries/Maven__xml_resolver_xml_resolver_1_2.xml b/.idea/libraries/Maven__xml_resolver_xml_resolver_1_2.xml
new file mode 100644
index 0000000..3c94b04
--- /dev/null
+++ b/.idea/libraries/Maven__xml_resolver_xml_resolver_1_2.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/modules.xml b/.idea/modules.xml
index ae08aaa..d6ff43e 100644
--- a/.idea/modules.xml
+++ b/.idea/modules.xml
@@ -4,7 +4,7 @@
-
+
\ No newline at end of file
diff --git a/.idea/vcs.xml b/.idea/vcs.xml
index 70c1f8f..94a25f7 100644
--- a/.idea/vcs.xml
+++ b/.idea/vcs.xml
@@ -2,7 +2,5 @@
-
-
\ No newline at end of file
diff --git a/cl_query_data_job/cl_query_data_job.iml b/cl_query_data_job/cl_query_data_job.iml
index 683f253..2a965b9 100644
--- a/cl_query_data_job/cl_query_data_job.iml
+++ b/cl_query_data_job/cl_query_data_job.iml
@@ -79,7 +79,7 @@
-
+
@@ -128,11 +128,8 @@
-
-
-
@@ -157,5 +154,51 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/cl_query_data_job/pom.xml b/cl_query_data_job/pom.xml
index 98edc7b..07bfe79 100644
--- a/cl_query_data_job/pom.xml
+++ b/cl_query_data_job/pom.xml
@@ -4,9 +4,9 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
- cl_stream_3.0
+ cl_stream_4.0
com.bfd.mf
- 3.0-SNAPSHOT
+ 4.0-SNAPSHOT
cl_query_data_job
@@ -72,10 +72,15 @@
19.0
+
+
+
+
+
com.alibaba
fastjson
- 1.2.6
+ 1.2.60
@@ -100,13 +105,6 @@
6.0.0
-
-
- com.squareup.okhttp3
- okhttp
- 3.9.1
-
-
org.apache.kafka
kafka-clients
@@ -138,6 +136,66 @@
kafka
0.10
+
+ org.apache.poi
+ poi
+ 4.1.0
+
+
+ org.apache.poi
+ poi-ooxml
+ 4.1.0
+
+
+ com.monitorjbl
+ xlsx-streamer
+ 2.1.0
+
+
+ com.squareup.okhttp3
+ okhttp
+ 3.6.0
+
+
+
+ it.sauronsoftware
+ jave
+ 1.0.2
+
+
+ com.bfd.nlp
+ nlp_common_util
+ 1.1
+
+
+ httpclient
+ org.apache.httpcomponents
+
+
+
+
+
+
+ logback-classic
+ ch.qos.logback
+
+
+
+
+
+
+ javax.mail
+ javax.mail-api
+ 1.6.2
+
+
+
+ com.sun.mail
+ javax.mail
+ 1.6.2
+
+
+
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/Application.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/Application.java
index 14df1e0..a5df4ae 100644
--- a/cl_query_data_job/src/main/java/com/bfd/mf/job/Application.java
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/Application.java
@@ -23,6 +23,12 @@ public class Application {
private QueryProducer queryProducer;
@Autowired
private StatisticsProducer statisticsProducer;
+ @Autowired
+ private UpLoadProducer upLoadProducer;
+ @Autowired
+ private TaskCountProducer taskCountProducer;
+ @Autowired
+ private AlarmProducer alarmProducer;
public static void main(String[] args) {
ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);
@@ -42,7 +48,19 @@ public class Application {
}
if(config.getEnableBacktraceProducer()){
backtraceProducer.start();
- LOGGER.info("---- Statistics producer started successfully. ----");
+ LOGGER.info("---- Backtrace producer started successfully. ----");
+ }
+ if(config.getEnableUpLoadProducer()){
+ upLoadProducer.start();
+ LOGGER.info("---- Backtrace producer started successfully. ----");
+ }
+ if(config.getEnableTaskcountProducer()){
+ taskCountProducer.start();
+ LOGGER.info("---- TaskCount producer started successfully. ----");
+ }
+ if(config.getEnableAlarmProducer()){
+ alarmProducer.start();
+ LOGGER.info("---- Alarm producer started successfully. ----");
}
LOGGER.info("---- Application started successfully. ----");
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/config/AllKeys.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/config/AllKeys.java
new file mode 100644
index 0000000..1713b83
--- /dev/null
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/config/AllKeys.java
@@ -0,0 +1,162 @@
+package com.bfd.mf.job.config;
+
+import com.bfd.mf.job.util.DateUtil;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+public class AllKeys {
+ private static Map map = new HashMap();
+
+ public static Map getMap() {
+ return map;
+ }
+
+ public static void setMap(Map map) {
+ AllKeys.map = map;
+ }
+
+ static {
+ map.put("_id_","");
+ map.put("age","");
+ map.put("area","");
+ map.put("attitudesCount","");
+ map.put("attr","");
+ map.put("author","");
+ map.put("authorId","");
+ map.put("authorLevel","");
+ map.put("authornickname","");
+ map.put("availability",0);
+ map.put("avatar","");
+ map.put("brand","");
+ map.put("brandId","");
+ map.put("cate","");
+ map.put("channel","");
+ map.put("city","");
+ map.put("collectCount",0);
+ map.put("commentId","");
+ map.put("commentScore",0);
+ map.put("commentsCount",0);
+ map.put("commentUrl","");
+ map.put("content","");
+ map.put("contentLength",0);
+ map.put("contentSimHash","");
+ map.put("contentTag","");
+ map.put("country","");
+ map.put("crawlDataFlag","");
+ map.put("crawlDate",new Date ());
+ map.put("crawlDay",0L);
+ map.put("crawlTime",0L);
+ map.put("crawlTimeStr","");
+ map.put("createDate",new Date ());
+ map.put("createDay",0L);
+ map.put("createTime",0L);
+ map.put("createTimeStr","");
+ map.put("dataCount",0);
+ map.put("dataId","");
+ map.put("docId","");
+ map.put("docType","");
+ map.put("downCnt",0);
+ map.put("egc",0);
+ map.put("enSource","");
+ map.put("expression",new ArrayList<>());
+ map.put("extension","");
+ map.put("fansCount","");
+ map.put("favorCnt",0);
+ map.put("filePath",new ArrayList<>());
+ map.put("imagePath",new ArrayList<>());
+ map.put("videoPath",new ArrayList<>());
+ map.put("filePathSize",new ArrayList<>());
+ map.put("imagePathSize",new ArrayList<>());
+ map.put("videoPathSize",new ArrayList<>());
+ map.put("finalPhrase","");
+ map.put("firstListBrand","");
+ map.put("fiveListBrand","");
+ map.put("forumScore","");
+ map.put("forwardAttitudesCount",0);
+ map.put("forwardAuthor","");
+ map.put("forwardAvatar","");
+ map.put("forwardCommentsCount",0);
+ map.put("forwardContent","");
+ map.put("forwardImgs","");
+ map.put("forwardPostSource","");
+ map.put("forwardPubTime",0L);
+ map.put("forwardQuoteCount",0);
+ map.put("forwardUrl","");
+ map.put("forwardUserId","");
+ map.put("forwardUserType",0);
+ map.put("forwardUserUrl","");
+ map.put("fourListBrand","");
+ map.put("friendsCount","");
+ map.put("getSource","");
+ map.put("hashTag",new ArrayList<>());
+ map.put("hlKeywords",new ArrayList<>());
+ map.put("impression","");
+ map.put("isDownload",false);
+ map.put("isVip",0);
+ map.put("language","");
+ map.put("lastModifiedTime",0L);
+ map.put("listBrand","");
+ map.put("location","");
+ map.put("nomorprice",0);
+ map.put("opinions",new ArrayList<>());
+ map.put("originalPhrase","");
+ map.put("otherSourceJson","");
+ map.put("pageCommentCount",0);
+ map.put("pageTranspondCount",0);
+ map.put("pageType","");
+ map.put("pgc",0);
+ map.put("pictureList","");
+ map.put("places",new ArrayList<>());
+ map.put("postCount","");
+ map.put("postId","");
+ map.put("postSource","");
+ map.put("price",0);
+ map.put("primary",1);
+ map.put("productParameter","");
+ map.put("projectName","");
+ map.put("promotionInfo","");
+ map.put("province","");
+ map.put("pubDate",new Date());
+ map.put("pubDay", DateUtil.getcurr());
+ map.put("pubTime",DateUtil.getcurr());
+ map.put("pubTimeStr", DateUtil.getDateTime());
+ map.put("quoteCount",0);
+ map.put("readCount",0);
+ map.put("resolution","");
+ map.put("secondListBrand","");
+ map.put("sex","");
+ map.put("sign","");
+ map.put("siteId","");
+ map.put("skuProperties","");
+ map.put("smallImgs","");
+ map.put("source","");
+ map.put("sysAbstract","");
+ map.put("sysKeywords","");
+ map.put("sysSentiment",0.0);
+ map.put("threeListBrand","");
+ map.put("thumbnails","");
+ map.put("title","");
+ map.put("titleLength",0);
+ map.put("titleSimHash","");
+ map.put("translateContent","");
+ map.put("translateTitle","");
+ map.put("ugc",0);
+ map.put("url","");
+ map.put("urlHash","");
+ map.put("userType","");
+ map.put("userUrl","");
+ map.put("videoTime","");
+ map.put("videoUrl","");
+ map.put("avatarPath","");
+ map.put("viewCnt",0);
+ map.put("channelNum","");
+ map.put("crawlDataFlagType","");
+ map.put("primaryPost","");
+ map.put("dns","");
+ map.put("asrText","");
+ map.put("ocrText",new ArrayList<>());
+ }
+}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/config/AppConfig.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/config/AppConfig.java
index 7d50c21..1154b30 100644
--- a/cl_query_data_job/src/main/java/com/bfd/mf/job/config/AppConfig.java
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/config/AppConfig.java
@@ -1,8 +1,5 @@
package com.bfd.mf.job.config;
-import com.alibaba.fastjson.JSON;
-import org.apache.commons.lang3.builder.ToStringBuilder;
-import org.apache.commons.lang3.builder.ToStringStyle;
import org.joda.time.Instant;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
@@ -26,6 +23,7 @@ public class AppConfig {
public static final String SEPARATOR_UP = "丄";
public static final String SEPARATOR_DOWN = "丅";
public static final String CL_INDEX= "cl_index";
+ public static final String SEPARATOR = "_";
// 从配置文件中读的参数
private static final String CONFIG_ES_CLUSTER_NAME = "name";
@@ -41,19 +39,34 @@ public class AppConfig {
private Integer testThreadCount;
private Long testTaskId;
private String brokerList;
+ private String sendTopic;
private List analysisTopic;
private String analysisGroup;
- // private Boolean enableAnalysisProducer;
-// private Boolean enableAnalysisConsumer;
-// private Integer analysisProducerThreadCount;
-// private Integer analysisConsumerThreadCount;
private Boolean enableStatisticsProducer; // 离线查询统计服务的状态
private Boolean enableQueryProducer; // 离线查询数据服务的状态
private Boolean enableBacktraceProducer; // 离线拉取数据服务的状态(欧莱雅)
+ private Boolean enableUpLoadProducer;
+ private Boolean enableOutputProducer;
+ private Boolean enableTaskcountProducer;
+ private Boolean enableAlarmProducer;
private Integer statisticsProducerThreadCount; // 离线查询统计服务的线程数
private Integer queryProducerThreadCount;
private Integer backtraceProducerThreadCount;
- // private Boolean enableCompany;
+ private Integer upLoadProducerThreadCount;
+ private Integer outputProducerThreadCount;
+ private Integer taskcountProducerThreadCount;
+ private Integer alarmProducerThreadCount;
+ private String goFastPostUrl;
+ private String goFastDomain;
+ private String uploadOLYExcelPath;
+ private String uploadZipPath;
+ private String indexNamePre;
+
+ // private Boolean enableAnalysisProducer;
+// private Boolean enableAnalysisConsumer;
+// private Integer analysisProducerThreadCount;
+// private Integer analysisConsumerThreadCount;
+// private Boolean enableCompany;
// private Integer companyThreadCount;
// private Boolean enableCompanyProducer;
// private Boolean enableCompanyConsumer;
@@ -61,6 +74,8 @@ public class AppConfig {
// private Integer companyConsumerThreadCount;
// private Boolean enableZombie;
private Integer periodS;
+ private Long intervalTime;
+ private Long queryDataYearStarttime;
private String ruleRest;
private String commentRest;
private Integer ruleRestConcurrency;
@@ -68,8 +83,25 @@ public class AppConfig {
private Integer failureUpper;
private Map esNormal;
private Map esMini;
+ private Map esLogstash;
+ public Boolean getEnableAlarmProducer() {
+ return enableAlarmProducer;
+ }
+
+ public void setEnableAlarmProducer(Boolean enableAlarmProducer) {
+ this.enableAlarmProducer = enableAlarmProducer;
+ }
+
+ public Integer getAlarmProducerThreadCount() {
+ return alarmProducerThreadCount;
+ }
+
+ public void setAlarmProducerThreadCount(Integer alarmProducerThreadCount) {
+ this.alarmProducerThreadCount = alarmProducerThreadCount;
+ }
+
public Integer getPeriodS() {
return periodS;
}
@@ -78,6 +110,22 @@ public class AppConfig {
this.periodS = periodS;
}
+ public Long getIntervalTime() {
+ return intervalTime;
+ }
+
+ public void setIntervalTime(Long intervalTime) {
+ this.intervalTime = intervalTime;
+ }
+
+ public Long getQueryDataYearStarttime() {
+ return queryDataYearStarttime;
+ }
+
+ public void setQueryDataYearStarttime(Long queryDataYearStarttime) {
+ this.queryDataYearStarttime = queryDataYearStarttime;
+ }
+
public Integer getQueryProducerThreadCount() {
return queryProducerThreadCount;
}
@@ -118,6 +166,22 @@ public class AppConfig {
this.enableStatisticsProducer = enableStatisticsProducer;
}
+ public Boolean getEnableTaskcountProducer() {
+ return enableTaskcountProducer;
+ }
+
+ public void setEnableTaskcountProducer(Boolean enableTaskcountProducer) {
+ this.enableTaskcountProducer = enableTaskcountProducer;
+ }
+
+ public Integer getTaskcountProducerThreadCount() {
+ return taskcountProducerThreadCount;
+ }
+
+ public void setTaskcountProducerThreadCount(Integer taskcountProducerThreadCount) {
+ this.taskcountProducerThreadCount = taskcountProducerThreadCount;
+ }
+
public Integer getStatisticsProducerThreadCount() {
return statisticsProducerThreadCount;
}
@@ -126,6 +190,38 @@ public class AppConfig {
this.statisticsProducerThreadCount = statisticsProducerThreadCount;
}
+ public Boolean getEnableUpLoadProducer() {
+ return enableUpLoadProducer;
+ }
+
+ public void setEnableUpLoadProducer(Boolean enableUpLoadProducer) {
+ this.enableUpLoadProducer = enableUpLoadProducer;
+ }
+
+ public Integer getUpLoadProducerThreadCount() {
+ return upLoadProducerThreadCount;
+ }
+
+ public void setUpLoadProducerThreadCount(Integer upLoadProducerThreadCount) {
+ this.upLoadProducerThreadCount = upLoadProducerThreadCount;
+ }
+
+ public Boolean getEnableOutputProducer() {
+ return enableOutputProducer;
+ }
+
+ public void setEnableOutputProducer(Boolean enableOutputProducer) {
+ this.enableOutputProducer = enableOutputProducer;
+ }
+
+ public Integer getOutputProducerThreadCount() {
+ return outputProducerThreadCount;
+ }
+
+ public void setOutputProducerThreadCount(Integer outputProducerThreadCount) {
+ this.outputProducerThreadCount = outputProducerThreadCount;
+ }
+
public String getVersion() {
return version;
}
@@ -166,6 +262,14 @@ public class AppConfig {
this.brokerList = brokerList;
}
+ public String getSendTopic() {
+ return sendTopic;
+ }
+
+ public void setSendTopic(String sendTopic) {
+ this.sendTopic = sendTopic;
+ }
+
public List getAnalysisTopic() {
return analysisTopic;
}
@@ -182,7 +286,6 @@ public class AppConfig {
this.analysisGroup = analysisGroup;
}
-
public String getRuleRest() {
return ruleRest;
}
@@ -215,6 +318,31 @@ public class AppConfig {
this.failureUpper = failureUpper;
}
+ public Map getEsLogstash() {
+ return esLogstash;
+ }
+
+ public void setEsLogstash(Map esLogstash) {
+ this.esLogstash = esLogstash;
+ }
+
+ public String esLogstashClusterName() {
+ return (String) esLogstash.get(CONFIG_ES_CLUSTER_NAME);
+ }
+
+ public String[] esLogstashAddress() {
+ return ((String) esLogstash.get(CONFIG_ES_ADDRESS)).split(",");
+ }
+
+ public Long esLogstashUpper() {
+ String upper = (String) esLogstash.get(CONFIG_ES_SOURCE_UPPER);
+ return Instant.parse(upper).getMillis();
+ }
+
+ public String esLogstashStandby() {
+ return (String) esLogstash.get(CONFIG_ES_SOURCE_STANDBY);
+ }
+
public Map getEsNormal() {
return esNormal;
}
@@ -271,6 +399,55 @@ public class AppConfig {
return size;
}
+ public String getCommentRest() {
+ return commentRest;
+ }
+
+ public void setCommentRest(String commentRest) {
+ this.commentRest = commentRest;
+ }
+
+ public String getGoFastPostUrl() {
+ return goFastPostUrl;
+ }
+
+ public void setGoFastPostUrl(String goFastPostUrl) {
+ this.goFastPostUrl = goFastPostUrl;
+ }
+
+ public String getGoFastDomain() {
+ return goFastDomain;
+ }
+
+ public void setGoFastDomain(String goFastDomain) {
+ this.goFastDomain = goFastDomain;
+ }
+
+ public String getUploadOLYExcelPath() {
+ return uploadOLYExcelPath;
+ }
+
+ public void setUploadOLYExcelPath(String uploadOLYExcelPath) {
+ this.uploadOLYExcelPath = uploadOLYExcelPath;
+ }
+
+ public String getUploadZipPath() {
+ return uploadZipPath;
+ }
+
+ public void setUploadZipPath(String uploadZipPath) {
+ this.uploadZipPath = uploadZipPath;
+ }
+
+ public String getIndexNamePre() {
+ return indexNamePre;
+ }
+
+ public void setIndexNamePre(String indexNamePre) {
+ this.indexNamePre = indexNamePre;
+ }
+
+
public void verify() {
@@ -280,34 +457,24 @@ public class AppConfig {
Assert.isTrue(testTaskId > 0, "Config testTaskId must gt 0");
}
Assert.hasLength(brokerList, "Config brokerList must not be empty");
- if(enableStatisticsProducer){
+ if(enableStatisticsProducer){ // 统计
Assert.isTrue(statisticsProducerThreadCount > 0, "Config statisticsProducerThreadCount must gt 0");
}
- if(enableQueryProducer){
- Assert.isTrue(queryProducerThreadCount > 0, "Config statisticsProducerThreadCount must gt 0");
+ if(enableQueryProducer){ // 离线拉数
+ Assert.isTrue(queryProducerThreadCount > 0, "Config queryProducerThreadCount must gt 0");
+ }
+ if(enableBacktraceProducer){ // 欧莱雅离线拉数
+ Assert.isTrue(backtraceProducerThreadCount > 0, "Config backtraceProducerThreadCount must gt 0");
+ }
+ if(enableUpLoadProducer){ // 数据上传
+ Assert.isTrue(upLoadProducerThreadCount > 0, "Config upLoadProducerThreadCount must gt 0");
+ }
+ if(enableTaskcountProducer){ // 驾驶舱-每天的平均任务量统计
+ Assert.isTrue(taskcountProducerThreadCount > 0, "Config taskcountProducerThreadCount must gt 0");
}
- if(enableStatisticsProducer){
- Assert.isTrue(backtraceProducerThreadCount > 0, "Config statisticsProducerThreadCount must gt 0");
+ if(enableAlarmProducer){ // 驾驶舱-每天的平均任务量统计
+ Assert.isTrue(alarmProducerThreadCount > 0, "Config alarmProducerThreadCount must gt 0");
}
-// if (enableAnalysisProducer) {
-// Assert.isTrue(analysisProducerThreadCount > 0, "Config analysisProducerThreadCount must gt 0");
-// Assert.notEmpty(analysisTopic, "Config analysisTopic must not be empty.");
-// }
-// if (enableAnalysisConsumer) {
-// Assert.isTrue(analysisConsumerThreadCount > 0, "Config analysisConsumerThreadCount must gt 0");
-// Assert.hasLength(analysisGroup, "Config analysisGroup must not be empty.");
-// }
-// if (enableCompany) {
-// Assert.isTrue(companyThreadCount > 0, "Config companyThreadCount must gt 0");
-// }
-// if (enableCompanyProducer) {
-// Assert.isTrue(companyProducerThreadCount > 0, "Config companyProducerThreadCount must gt 0");
-//
-// }
-// if (enableCompanyConsumer) {
-// Assert.isTrue(companyConsumerThreadCount > 0, "Config companyConsumerThreadCount must gt 0");
-//
-// }
Assert.isTrue(periodS > 0, "Config periodS must gt 0");
Assert.hasLength(ruleRest, "Config ruleRest must not be empty");
Assert.isTrue(ruleRestConcurrency > 0, "Config ruleRestConcurrency must gt 0");
@@ -317,38 +484,7 @@ public class AppConfig {
Assert.notEmpty(esMini, "Config esTarget must not be empty");
}
- public String getCommentRest() {
- return commentRest;
- }
- public void setCommentRest(String commentRest) {
- this.commentRest = commentRest;
- }
-// public Map getRedis() {
-// return redis;
-// }
-// public void setRedis(Map redis) {
-// this.redis = redis;
-// }
-
-// public String redisModel() {
-// return (String) redis.get(REDIS_MODEL);
-// }
-// public String redisZkadress() {
-// return (String) redis.get(REDIS_ZKADRESS);
-// }
-// public String redisZksessiontimeoutms() {
-// return (String) redis.get(REDIS_ZKSESSIONTIMEOUTMS);
-// }
-// public String redisProxypath() {
-// return (String) redis.get(REDIS_PORT);
-// }
-// public String redisAddress() {
-// return (String) redis.get(REDIS_ADDRESS);
-// }
-// public String redisPort() {
-// return (String) redis.get(REDIS_PORT);
-// }
}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/config/BFDApiConfig.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/config/BFDApiConfig.java
deleted file mode 100644
index af24f24..0000000
--- a/cl_query_data_job/src/main/java/com/bfd/mf/job/config/BFDApiConfig.java
+++ /dev/null
@@ -1,1116 +0,0 @@
-package com.bfd.mf.job.config;
-
-import org.apache.commons.lang3.builder.ToStringBuilder;
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.validation.annotation.Validated;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Map;
-
-@Configuration
-@EnableConfigurationProperties
-@ConfigurationProperties(prefix = "bfd.api.mf")
-@Validated
-public class BFDApiConfig {
-
- private ThreadConfig threadConfig;
- private Download download;
- private ES es;
- private Data data;
- private Image image;
- private Email email;
- private Thrift thrift;
- private ManualImage manualImage;
- private ReportImage reportImage;
- private String restBaseUrl;
- private String webBaseUrl;
- private String metaSearchUrl;
- private String foreignMetaSearchUrl;
- private String restDataApi;
- private String similarityMonitorWarnNumber;
- private String similarityMonitorSplitNumber;
- private String mergeSegmentsIndexNumber;
- private String maxEsNumber;
- private String weiboChannelTimeUrl;
- private Screen screen;
- private int defaultCacheLimitDay;
- private Integer failedTaskRetryNum;
- private Integer dataCompareCount;
- private String weChatDomainName;
- private String textPostUrl;
- private String emotionPostUrl;
- private String wordCloudPostUrl;
- private Integer emotionPostType;
- private boolean codisCacheFlag = false;
- private ReportBehaviorInterface reportBehaviorInterface;
- /**
- * 访客 IP 白名单
- */
- private ArrayList accessWhiteList;
- /**
- * 请求 内网地址 白名单
- */
- private ArrayList accessRequestUrl;
- /**
- * 会话 session 过期时间 6小时 60*60*6
- */
- private int cacheTimeout = 21600;
- /**
- * 单次批量收藏最大数量
- */
- private int maxFavourNumber = 1000;
- /**
- * 微信简报对应渠道的查询数目
- */
- private int wechatNumber = 20;
- private Integer filterType;
- private Integer queryType;
- private Boolean bigram;
- /**
- * 数据监控页数据缓存时间: seconds
- */
- public Integer cacheAtDataMonitor;
-
- public Map esMini;
- public Map esNormal;
-
- public String esMiniName() {
- return (String) esMini.get("name");
- }
-
- public String[] esMiniAddress() {
- return ((String) esMini.get("address")).split(",");
- }
-
- public String esNormalName() {
- return (String) esNormal.get("name");
- }
-
- public String[] esNormalAddress() {
- return ((String) esNormal.get("address")).split(",");
- }
-
- public Map getEsMini() {
- return esMini;
- }
-
- public void setEsMini(Map esMini) {
- this.esMini = esMini;
- }
-
- public Map getEsNormal() {
- return esNormal;
- }
-
- public void setEsNormal(Map esNormal) {
- this.esNormal = esNormal;
- }
-
- public Integer getEmotionPostType() {
- return emotionPostType;
- }
-
- public void setEmotionPostType(Integer emotionPostType) {
- this.emotionPostType = emotionPostType;
- }
-
- public String getWordCloudPostUrl() {
- return wordCloudPostUrl;
- }
-
- public void setWordCloudPostUrl(String wordCloudPostUrl) {
- this.wordCloudPostUrl = wordCloudPostUrl;
- }
-
- public String getTextPostUrl() {
- return textPostUrl;
- }
-
- public void setTextPostUrl(String textPostUrl) {
- this.textPostUrl = textPostUrl;
- }
-
- public String getEmotionPostUrl() {
- return emotionPostUrl;
- }
-
- public void setEmotionPostUrl(String emotionPostUrl) {
- this.emotionPostUrl = emotionPostUrl;
- }
-
- public String getSimilarityMonitorWarnNumber() {
- return similarityMonitorWarnNumber;
- }
-
- public void setSimilarityMonitorWarnNumber(String similarityMonitorWarnNumber) {
- this.similarityMonitorWarnNumber = similarityMonitorWarnNumber;
- }
-
- public String getSimilarityMonitorSplitNumber() {
- return similarityMonitorSplitNumber;
- }
-
- public void setSimilarityMonitorSplitNumber(String similarityMonitorSplitNumber) {
- this.similarityMonitorSplitNumber = similarityMonitorSplitNumber;
- }
-
- public String getWeiboChannelTimeUrl() {
- return weiboChannelTimeUrl;
- }
-
- public void setWeiboChannelTimeUrl(String weiboChannelTimeUrl) {
- this.weiboChannelTimeUrl = weiboChannelTimeUrl;
- }
-
- public String getMaxEsNumber() {
- return maxEsNumber;
- }
-
- public void setMaxEsNumber(String maxEsNumber) {
- this.maxEsNumber = maxEsNumber;
- }
-
- public String getMergeSegmentsIndexNumber() {
- return mergeSegmentsIndexNumber;
- }
-
- public void setMergeSegmentsIndexNumber(String mergeSegmentsIndexNumber) {
- this.mergeSegmentsIndexNumber = mergeSegmentsIndexNumber;
- }
-
- public String getRestDataApi() {
- return restDataApi;
- }
-
- public void setRestDataApi(String restDataApi) {
- this.restDataApi = restDataApi;
- }
-
- public Integer getDataCompareCount() {
- return dataCompareCount;
- }
-
- public void setDataCompareCount(Integer dataCompareCount) {
- this.dataCompareCount = dataCompareCount;
- }
-
- public ReportBehaviorInterface getReportBehaviorInterface() {
- return reportBehaviorInterface;
- }
-
- public void setReportBehaviorInterface(ReportBehaviorInterface reportBehaviorInterface) {
- this.reportBehaviorInterface = reportBehaviorInterface;
- }
-
- public int getMaxFavourNumber() {
- return maxFavourNumber;
- }
-
- public void setMaxFavourNumber(int maxFavourNumber) {
- this.maxFavourNumber = maxFavourNumber;
- }
-
- public String getMetaSearchUrl() {
- return metaSearchUrl;
- }
-
- public void setMetaSearchUrl(String metaSearchUrl) {
- this.metaSearchUrl = metaSearchUrl;
- }
-
- public String getRestBaseUrl() {
- return restBaseUrl;
- }
-
- public void setRestBaseUrl(String restBaseUrl) {
- this.restBaseUrl = restBaseUrl;
- }
-
- public ManualImage getManualImage() {
- return manualImage;
- }
-
- public void setManualImage(ManualImage manualImage) {
- this.manualImage = manualImage;
- }
-
- public ES getEs() {
- return es;
- }
-
- public void setEs(ES es) {
- this.es = es;
- }
-
- public Download getDownload() {
- return download;
- }
-
- public void setDownload(Download download) {
- this.download = download;
- }
-
- public Data getData() {
- return data;
- }
-
- public void setData(Data data) {
- this.data = data;
- }
-
- public Email getEmail() {
- return email;
- }
-
- public void setEmail(Email email) {
- this.email = email;
- }
-
- public Thrift getThrift() {
- return thrift;
- }
-
- public void setThrift(Thrift thrift) {
- this.thrift = thrift;
- }
-
- public String getWebBaseUrl() {
- return webBaseUrl;
- }
-
- public void setWebBaseUrl(String webBaseUrl) {
- this.webBaseUrl = webBaseUrl;
- }
-
- public Screen getScreen() {
- return screen;
- }
-
- public void setScreen(Screen screen) {
- this.screen = screen;
- }
-
- public ArrayList getAccessWhiteList() {
- return accessWhiteList;
- }
-
- public void setAccessWhiteList(ArrayList accessWhiteList) {
- this.accessWhiteList = accessWhiteList;
- }
-
- public ArrayList getAccessRequestUrl() {
- return accessRequestUrl;
- }
-
- public void setAccessRequestUrl(ArrayList accessRequestUrl) {
- this.accessRequestUrl = accessRequestUrl;
- }
-
- public int getCacheTimeout() {
- return cacheTimeout;
- }
-
- public long getDefaultCacheLimitDay() {
- return defaultCacheLimitDay;
- }
-
- public void setDefaultCacheLimitDay(int defaultCacheLimitDay) {
- this.defaultCacheLimitDay = defaultCacheLimitDay;
- }
-
- public void setCacheTimeout(int cacheTimeout) {
- this.cacheTimeout = cacheTimeout;
- }
-
- public Integer getFailedTaskRetryNum() {
- return failedTaskRetryNum;
- }
-
- public void setFailedTaskRetryNum(Integer failedTaskRetryNum) {
- this.failedTaskRetryNum = failedTaskRetryNum;
- }
-
- public Integer getFilterType() {
- return filterType;
- }
-
- public void setFilterType(Integer filterType) {
- this.filterType = filterType;
- }
-
- public Integer getQueryType() {
- return queryType;
- }
-
- public void setQueryType(Integer queryType) {
- this.queryType = queryType;
- }
-
- public Boolean getBigram() {
- return bigram;
- }
-
- public void setBigram(Boolean bigram) {
- this.bigram = bigram;
- }
-
- public int getWechatNumber() {
- return wechatNumber;
- }
-
- public void setWechatNumber(int wechatNumber) {
- this.wechatNumber = wechatNumber;
- }
-
- public String getForeignMetaSearchUrl() {
- return foreignMetaSearchUrl;
- }
-
- public void setForeignMetaSearchUrl(String foreignMetaSearchUrl) {
- this.foreignMetaSearchUrl = foreignMetaSearchUrl;
- }
-
- public Integer getCacheAtDataMonitor() {
- return cacheAtDataMonitor;
- }
-
- public void setCacheAtDataMonitor(int cacheAtDataMonitor) {
- this.cacheAtDataMonitor = cacheAtDataMonitor;
- }
-
- public boolean isCodisCacheFlag() {
- return codisCacheFlag;
- }
-
- public void setCodisCacheFlag(boolean codisCacheFlag) {
- this.codisCacheFlag = codisCacheFlag;
- }
-
- public ThreadConfig getThreadConfig() {
- return threadConfig;
- }
-
- public void setThreadConfig(ThreadConfig threadConfig) {
- this.threadConfig = threadConfig;
- }
-
- public String getWeChatDomainName() {
- return weChatDomainName;
- }
-
- public void setWeChatDomainName(String weChatDomainName) {
- this.weChatDomainName = weChatDomainName;
- }
-
- public static class Download {
- private String codisTaskQueueKey;
- private String filePath;
- private int sleepSeconds;
- private int zombieSeconds;
- private Schedule schedule;
- private String active = "N";
- private String fileSecondPath;
-
- @Override
- public String toString() {
- return new ToStringBuilder(this)
- .append("active", active)
- .append("codisTaskQueueKey", codisTaskQueueKey)
- .append("filePath", filePath)
- .append("sleepSeconds", sleepSeconds)
- .append("schedule", schedule)
- .append("fileSecondPath", fileSecondPath)
- .toString();
- }
-
- public int getSleepSeconds() {
- return sleepSeconds;
- }
-
- public void setSleepSeconds(int sleepSeconds) {
- this.sleepSeconds = sleepSeconds;
- }
-
- public String getCodisTaskQueueKey() {
- return codisTaskQueueKey;
- }
-
- public void setCodisTaskQueueKey(String codisTaskQueueKey) {
- this.codisTaskQueueKey = codisTaskQueueKey;
- }
-
- public String getFilePath() {
- return filePath;
- }
-
- public void setFilePath(String filePath) {
- this.filePath = filePath;
- }
-
- public Schedule getSchedule() {
- return schedule;
- }
-
- public void setSchedule(Schedule schedule) {
- this.schedule = schedule;
- }
-
- public String getActive() {
- return active;
- }
-
- public void setActive(String active) {
- this.active = active;
- }
-
- public int getZombieSeconds() {
- return zombieSeconds;
- }
-
- public void setZombieSeconds(int zombieSeconds) {
- this.zombieSeconds = zombieSeconds;
- }
-
- public String getFileSecondPath() {
- return fileSecondPath;
- }
-
- public void setFileSecondPath(String fileSecondPath) {
- this.fileSecondPath = fileSecondPath;
- }
- }
-
- public static class ES {
- private String url, cluster, secondUrl, itemIndex, indexPrefix, primaryIndex;
- private Integer port;
- private Long dailyIndexCount;
- private Integer availableMiniClusterDays = 3;
- private Integer scrollSize ;
- private Integer sliceNumber;
- private Integer filterNumber;
- private Boolean indexDynamic;
- private String httpPort;
- private String httpNormalPort;
- private Integer secondPort;
-
- public String getPrimaryIndex() {
- return primaryIndex;
- }
-
- public void setPrimaryIndex(String primaryIndex) {
- this.primaryIndex = primaryIndex;
- }
-
- public Integer getScrollSize() {
- return scrollSize;
- }
-
- public void setScrollSize(Integer scrollSize) {
- this.scrollSize = scrollSize;
- }
-
- public Boolean getIndexDynamic() {
- return indexDynamic;
- }
-
- public void setIndexDynamic(Boolean indexDynamic) {
- this.indexDynamic = indexDynamic;
- }
-
- public Integer getSliceNumber() {
- return sliceNumber;
- }
-
- public void setSliceNumber(Integer sliceNumber) {
- this.sliceNumber = sliceNumber;
- }
-
- public Long getDailyIndexCount() {
- return dailyIndexCount;
- }
-
- public void setDailyIndexCount(Long dailyIndexCount) {
- this.dailyIndexCount = dailyIndexCount;
- }
-
- public String getHttpPort() {
- return httpPort;
- }
-
- public Integer getFilterNumber() {
- return filterNumber;
- }
-
- public void setFilterNumber(Integer filterNumber) {
- this.filterNumber = filterNumber;
- }
-
- public void setHttpPort(String httpPort) {
- this.httpPort = httpPort;
- }
-
- public String getHttpNormalPort() {
- return httpNormalPort;
- }
-
- public void setHttpNormalPort(String httpNormalPort) {
- this.httpNormalPort = httpNormalPort;
- }
-
- public Integer getSecondPort() {
- return secondPort;
- }
-
- public void setSecondPort(Integer secondPort) {
- this.secondPort = secondPort;
- }
-
- public String getUrl() {
- return url;
- }
-
- public void setUrl(String url) {
- this.url = url;
- }
-
- public String getCluster() {
- return cluster;
- }
-
- public void setCluster(String cluster) {
- this.cluster = cluster;
- }
-
- public Integer getPort() {
- return port;
- }
-
- public void setPort(Integer port) {
- this.port = port;
- }
-
- public String getSecondUrl() {
- return secondUrl;
- }
-
- public void setSecondUrl(String secondUrl) {
- this.secondUrl = secondUrl;
- }
-
- public String getItemIndex() {
- return itemIndex;
- }
-
- public void setItemIndex(String itemIndex) {
- this.itemIndex = itemIndex;
- }
-
- public String getDefaultIndexPre() {
- return indexPrefix + "_*";
- }
-
- @Override
- public String toString() {
- return new ToStringBuilder(this)
- .append("url", url)
- .append("port", port)
- .append("secondUrl", secondUrl)
- .append("secondPort", secondPort)
- .append("cluster", cluster)
- .append("itemIndex", itemIndex)
- .append("indexPrefix", indexPrefix)
- .append("dailyIndexCount", dailyIndexCount)
- .toString();
- }
-
- public String getIndexPrefix() {
- return indexPrefix;
- }
-
- public void setIndexPrefix(String indexPrefix) {
- this.indexPrefix = indexPrefix;
- }
-
- public Integer getAvailableMiniClusterDays() {
- return availableMiniClusterDays;
- }
-
- public void setAvailableMiniClusterDays(Integer availableMiniClusterDays) {
- this.availableMiniClusterDays = availableMiniClusterDays;
- }
- }
-
- public static class Schedule {
- private String jobPrefix, jobGroup, triggerPrefix, triggerGroup;
- private String cronTime;
- private int threadNumber = 10, delaySeconds = 30;
-
- public int getThreadNumber() {
- return threadNumber;
- }
-
- public void setThreadNumber(int threadNumber) {
- this.threadNumber = threadNumber;
- }
-
- public String getJobPrefix() {
- return jobPrefix;
- }
-
- public void setJobPrefix(String jobPrefix) {
- this.jobPrefix = jobPrefix;
- }
-
- public String getJobGroup() {
- return jobGroup;
- }
-
- public void setJobGroup(String jobGroup) {
- this.jobGroup = jobGroup;
- }
-
- public String getTriggerPrefix() {
- return triggerPrefix;
- }
-
- public void setTriggerPrefix(String triggerPrefix) {
- this.triggerPrefix = triggerPrefix;
- }
-
- public String getTriggerGroup() {
- return triggerGroup;
- }
-
- public void setTriggerGroup(String triggerGroup) {
- this.triggerGroup = triggerGroup;
- }
-
- public String getCronTime() {
- return cronTime;
- }
-
- public void setCronTime(String cronTime) {
- this.cronTime = cronTime;
- }
-
- public int getDelaySeconds() {
- return delaySeconds;
- }
-
- public void setDelaySeconds(int delaySeconds) {
- this.delaySeconds = delaySeconds;
- }
-
- @Override
- public String toString() {
- return new ToStringBuilder(this)
- .append("jobPrefix", jobPrefix)
- .append("jobGroup", jobGroup)
- .append("triggerPrefix", triggerPrefix)
- .append("triggerGroup", triggerGroup)
- .append("cronTime", cronTime)
- .append("threadNumber", threadNumber)
- .append("delaySeconds", delaySeconds)
- .toString();
- }
- }
-
- public static class Data {
- HashMap typeKv;
- String filePath;
-
- public HashMap getTypeKv() {
- return typeKv;
- }
-
- public void setTypeKv(HashMap typeKv) {
- this.typeKv = typeKv;
- }
-
- public String getFilePath() {
- return filePath;
- }
-
- public void setFilePath(String filePath) {
- this.filePath = filePath;
- }
-
- @Override
- public String toString() {
- return new ToStringBuilder(this)
- .append("typeKv", typeKv)
- .append("filePath", filePath)
- .toString();
- }
- }
-
- public Image getImage() {
- return image;
- }
-
- public void setImage(Image image) {
- this.image = image;
- }
-
- public static class Image {
- private String icon, dot, logo, footer, arr, articleSign, baseUrl, chartServerUrl, defaultChartUrl,
- pieChartUrl, lineChartUrl, baseNginxPath;
-
- public String getIcon() {
- return icon;
- }
-
- public void setIcon(String icon) {
- this.icon = icon;
- }
-
- public String getDot() {
- return dot;
- }
-
- public void setDot(String dot) {
- this.dot = dot;
- }
-
- public String getLogo() {
- return logo;
- }
-
- public void setLogo(String logo) {
- this.logo = logo;
- }
-
- public String getFooter() {
- return footer;
- }
-
- public void setFooter(String footer) {
- this.footer = footer;
- }
-
- public String getArr() {
- return arr;
- }
-
- public void setArr(String arr) {
- this.arr = arr;
- }
-
- public String getBaseUrl() {
- return baseUrl;
- }
-
- public void setBaseUrl(String baseUrl) {
- this.baseUrl = baseUrl;
- }
-
- public String getChartServerUrl() {
- return chartServerUrl;
- }
-
- public void setChartServerUrl(String chartServerUrl) {
- this.chartServerUrl = chartServerUrl;
- }
-
- public String getDefaultChartUrl() {
- return defaultChartUrl;
- }
-
- public void setDefaultChartUrl(String defaultChartUrl) {
- this.defaultChartUrl = defaultChartUrl;
- }
-
- public String getPieChartUrl() {
- return pieChartUrl;
- }
-
- public void setPieChartUrl(String pieChartUrl) {
- this.pieChartUrl = pieChartUrl;
- }
-
- public String getLineChartUrl() {
- return lineChartUrl;
- }
-
- public void setLineChartUrl(String lineChartUrl) {
- this.lineChartUrl = lineChartUrl;
- }
-
- public String getArticleSign() {
- return articleSign;
- }
-
- public void setArticleSign(String articleSign) {
- this.articleSign = articleSign;
- }
-
- public String getBaseNginxPath() {
- return baseNginxPath;
- }
-
- public void setBaseNginxPath(String baseNginxPath) {
- this.baseNginxPath = baseNginxPath;
- }
-
- @Override
- public String toString() {
- return new ToStringBuilder(this)
- .append("icon", icon)
- .append("dot", dot)
- .append("logo", logo)
- .append("footer", footer)
- .append("arr", arr)
- .append("articleSign", articleSign)
- .append("baseUrl", baseUrl)
- .append("chartServerUrl", chartServerUrl)
- .append("defaultChartUrl", defaultChartUrl)
- .append("pieChartUrl", pieChartUrl)
- .append("lineChartUrl", lineChartUrl)
- .append("baseNginxPath", baseNginxPath)
- .toString();
- }
- }
-
- public static class Email {
- private String sender;
- private String subject;
-
- public String getSender() {
- return sender;
- }
-
- public void setSender(String sender) {
- this.sender = sender;
- }
-
- public String getSubject() {
- return subject;
- }
-
- public void setSubject(String subject) {
- this.subject = subject;
- }
-
- @Override
- public String toString() {
- return new ToStringBuilder(this)
- .append("sender", sender)
- .append("subject", subject)
- .toString();
- }
- }
-
- public static class Thrift {
- private String ip;
- private Integer port;
-
- public String getIp() {
- return ip;
- }
-
- public void setIp(String ip) {
- this.ip = ip;
- }
-
- public Integer getPort() {
- return port;
- }
-
- public void setPort(Integer port) {
- this.port = port;
- }
-
- @Override
- public String toString() {
- return new ToStringBuilder(this)
- .append("ip", ip)
- .append("port", port)
- .toString();
- }
- }
-
- public static class ReportBehaviorInterface {
- private String reportInterface;
- private String manualReportInterface;
-
- public String getReportInterface() {
- return reportInterface;
- }
-
- public void setReportInterface(String reportInterface) {
- this.reportInterface = reportInterface;
- }
-
- public String getManualReportInterface() {
- return manualReportInterface;
- }
-
- public void setManualReportInterface(String manualReportInterface) {
- this.manualReportInterface = manualReportInterface;
- }
- }
-
- public static class ManualImage {
- private String path;
- private String userUploadPath;
- private String reportHeadPath;
- private String chartsPath;
-
- public String getPath() {
- return path;
- }
-
- public void setPath(String path) {
- this.path = path;
- }
-
- public String getUserUploadPath() {
- return userUploadPath;
- }
-
- public void setUserUploadPath(String userUploadPath) {
- this.userUploadPath = userUploadPath;
- }
-
- public String getReportHeadPath() {
- return reportHeadPath;
- }
-
- public void setReportHeadPath(String reportHeadPath) {
- this.reportHeadPath = reportHeadPath;
- }
-
- public String getChartsPath() {
- return chartsPath;
- }
-
- public void setChartsPath(String chartsPath) {
- this.chartsPath = chartsPath;
- }
-
- @Override
- public String toString() {
- return new ToStringBuilder(this)
- .append("path", path)
- .append("userUploadPath", userUploadPath)
- .append("reportHeadPath", reportHeadPath)
- .append("chartsPath", chartsPath)
- .toString();
- }
- }
-
- public ReportImage getReportImage() {
- return reportImage;
- }
-
- public void setReportImage(ReportImage reportImage) {
- this.reportImage = reportImage;
- }
-
- public static class ReportImage {
- private String chartsPath;
-
- public String getChartsPath() {
- return chartsPath;
- }
-
- public void setChartsPath(String chartsPath) {
- this.chartsPath = chartsPath;
- }
-
- @Override
- public String toString() {
- return new ToStringBuilder(this)
- .append("chartsPath", chartsPath)
- .toString();
- }
- }
-
- public static class Screen {
- private Integer limit;
-
- public Integer getLimit() {
- return limit;
- }
-
- public void setLimit(Integer limit) {
- this.limit = limit;
- }
-
- @Override
- public String toString() {
- return new ToStringBuilder(this)
- .append("limit", limit)
- .toString();
- }
- }
-
- public static class ThreadConfig {
- private int threadLimit = 1000;
-
- public long getAwaitTermination() {
- return awaitTermination;
- }
-
- public void setAwaitTermination(long awaitTermination) {
- this.awaitTermination = awaitTermination;
- }
-
- private long awaitTermination = 20L;
-
- public int getThreadLimit() {
- return threadLimit;
- }
-
- public void setThreadLimit(int threadLimit) {
- this.threadLimit = threadLimit;
- }
- }
-
- @Override
- public String toString() {
- return "BFDApiConfig{" +
- "threadConfig=" + threadConfig +
- ", download=" + download +
- ", es=" + es +
- ", data=" + data +
- ", image=" + image +
- ", email=" + email +
- ", thrift=" + thrift +
- ", manualImage=" + manualImage +
- ", reportImage=" + reportImage +
- ", restBaseUrl='" + restBaseUrl + '\'' +
- ", webBaseUrl='" + webBaseUrl + '\'' +
- ", metaSearchUrl='" + metaSearchUrl + '\'' +
- ", foreignMetaSearchUrl='" + foreignMetaSearchUrl + '\'' +
- ", restDataApi='" + restDataApi + '\'' +
- ", similarityMonitorWarnNumber='" + similarityMonitorWarnNumber + '\'' +
- ", similarityMonitorSplitNumber='" + similarityMonitorSplitNumber + '\'' +
- ", mergeSegmentsIndexNumber='" + mergeSegmentsIndexNumber + '\'' +
- ", maxEsNumber='" + maxEsNumber + '\'' +
- ", weiboChannelTimeUrl='" + weiboChannelTimeUrl + '\'' +
- ", screen=" + screen +
- ", defaultCacheLimitDay=" + defaultCacheLimitDay +
- ", failedTaskRetryNum=" + failedTaskRetryNum +
- ", dataCompareCount=" + dataCompareCount +
- ", weChatDomainName='" + weChatDomainName + '\'' +
- ", textPostUrl='" + textPostUrl + '\'' +
- ", emotionPostUrl='" + emotionPostUrl + '\'' +
- ", codisCacheFlag=" + codisCacheFlag +
- ", reportBehaviorInterface=" + reportBehaviorInterface +
- ", accessWhiteList=" + accessWhiteList +
- ", accessRequestUrl=" + accessRequestUrl +
- ", cacheTimeout=" + cacheTimeout +
- ", maxFavourNumber=" + maxFavourNumber +
- ", wechatNumber=" + wechatNumber +
- ", filterType=" + filterType +
- ", queryType=" + queryType +
- ", bigram=" + bigram +
- ", cacheAtDataMonitor=" + cacheAtDataMonitor +
- '}';
- }
-
-}
\ No newline at end of file
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/config/ESConstants.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/config/ESConstants.java
index 40bf76e..ea623fc 100644
--- a/cl_query_data_job/src/main/java/com/bfd/mf/job/config/ESConstants.java
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/config/ESConstants.java
@@ -6,6 +6,19 @@ import java.util.List;
import java.util.Map;
public class ESConstants {
+ //0:社交媒体1:新闻资讯2:博客智库3:论坛贴吧4:网络视频5:电商网站6:搜索引擎7:生活方式
+ public static final String DOCTYPESOCIAL = "0";
+ public static final String DOCTYPENEWS = "1";
+ public static final String DOCTYPEBLOG = "2";
+ public static final String DOCTYPEBBS = "3";
+ public static final String DOCTYPEVIDEO = "4";
+ public static final String DOCTYPEITEM = "5";
+ public static final String DOCTYPESEARDH = "6";
+ public static final String DOCTYPELIFE = "7";
+
+ public static final String LOGSTASH = "logstash-";
+
+
/**
* 是否是主贴
*/
@@ -465,9 +478,6 @@ public class ESConstants {
*/
public static final String DOC_TYPE_WEIXIN = "weixin";
-
-
-
public static final String MEDIA_AREA_KEY = "dict";
public static final float BOOST_WEIGHT = 10f;
@@ -495,7 +505,6 @@ public class ESConstants {
public static final String SUMMARY = "summary";
-
// public static final String FILEPATH = "filePath";
public static final String VIDEOURL = "videoUrl";
@@ -650,8 +659,8 @@ public class ESConstants {
/*
* docType(news\bbs...):int 类型常量
*/
- public static final int DOCTYPENEWS = 0;
- public static final int DOCTYPEBBS = 1;
+// public static final int DOCTYPENEWS = 0;
+// public static final int DOCTYPEBBS = 1;
/*
* 组合查询语句key值类型
*/
@@ -771,19 +780,33 @@ public class ESConstants {
*define es mapping fields
*/
public static String PUBTIME = "pubTime";
- public static String CHANNEL_HYLANDA = "hylanda";
+ public static String PUBTIMESTR = "pubTimeStr";
+ public static String PUBDAY = "pubDay";
+ public static String PUBDATE = "pubDate";
- public static String PUBTIME_STR = "pubTimeStr";
+ public static String CRAWLTIME = "crawlTime";
+ public static String CRAWLTIMESTR = "crawlTimeStr";
+ public static String CRAWLDAY = "crawlDay";
+ public static String CRAWLDATE = "crawlDate";
public static String CREATETIME = "createTime";
public static String CREATETIMESTR = "createTimeStr";
- public static String CREATETIMEDAY = "createDay";
+ public static String CREATEDAY = "createDay";
+ public static String CREATEDATE = "createDate";
+
+ public static String OCRTEXT = "ocrText";
+ public static String ASRTEXT = "asrText";
+
+
+
- public static String PUTTIME = "putTime";
- public static String CRAWLTIME = "crawlTime";
public static String ORIGINAL_SOURCE = "originalSource";
public static String CONTENT_SIMHASH = "contentSimHash";
public static String QUOTE_COUNT = "quoteCount";
+
+
+ public static String PUTTIME = "putTime";
+ public static String CHANNEL_HYLANDA = "hylanda";
/**
* 内容
*/
@@ -802,7 +825,13 @@ public class ESConstants {
public static final String TITLE = "title";
public static final String USER_LEVEL_NAME = "userLevelName";
public static String SOURCE = "source";
- public static String CRAWLDATAFLAG= "crawlDataFlag";
+ public static String TRANSLATETITLE = "translateTitle";
+ public static String TRANSLATECONTENT = "translateContent";
+ public static String AUTHORID = "authorId";
+ public static String PRICE = "price";
+ public static String PRODUCTPARAMETER = "productParameter";
+ public static String CRAWLDATAFLAG = "crawlDataFlag";
+ public static String CRAWLDATAFLAGTYPE = "crawlDataFlagType";
//微信专属字段,内容固定 value="微信"
public static String WEIXIN_SOURCE = "weixinSource";
@@ -821,7 +850,7 @@ public class ESConstants {
public static String KEYWORD = "keyword";
public static String ACCOUNT = "account";
- // public static String URL = "url";
+ // public static String URL = "url";
public static String SYS_ABSTRACT = "sysAbstract";
public static String SYS_KEYWORDS = "sysKeywords";
@@ -905,15 +934,13 @@ public class ESConstants {
public static final String APP = "app";
public static String WEIBO_DEFAULT_AVATOR = "http://tva1.sinaimg.cn/default/images/default_avatar_male_180.gif";
- public static final String BAIDUKOUBEI = "baidukoubei";
- public static final String DIANPING = "dianping";
- public static final String FANGTIANXIA = "fangtianxia";
- public static final String BAIDUTIEBA = "baidutieba";
- public static final String SOUHU = "souhu";
- public static final String XIECHENG = "xiecheng";
- public static final String AUTOHOME = "autohome";
public static final String TMALL = "tmall";
- public static final String YILONG = "yilong";
+ public static final String TAOBAO = "taobao";
+ public static final String EJINGDONG = "ejingdong";
+ public static final String SUNING = "suning";
+ public static final String WEIPINHUI = "weipinhui";
+ public static final String EJUMEI = "ejumei";
+ public static final String SEPHORA = "sephora";
// 电商
public static final String ITEM = "item";
public static final String ITEM_NAME = "itemName";
@@ -991,21 +1018,18 @@ public class ESConstants {
public static final String FORWARD_USER_TYPE = "forwardUserType";
public static final String FORWARD_PUBTIME = "forwardPubTime";
-
public static final String FORWARD_FLAG = "forwardFlag"; // 转发、回帖标志 1(转发、回帖) 0(原贴)
public static final int REGULAR_PUBTIME_QUERY = 0;
public static final int REGULAR_PUBTIME_AND_CREATETIME_QUERY = 1;
-
public static final List TYPE_LIST = new ArrayList<>();
public static final List BACKEND_ANALYSIS_LIST = new ArrayList<>();
public static final List BACKEND_AVAILABILITY_LIST = new ArrayList<>();
-
public static final List APP_TYPE_LIST = new ArrayList();
@@ -1035,15 +1059,22 @@ public class ESConstants {
public static final String IMAGEPATHSIZE = "imagePathSize";
public static final String FILEPATHSIZE = "filePathSize";
public static final String VIDEOPATHSIZE = "videoPathSize";
+ public static final String SRCIMAGEPATH = "srcimagePath";
+ public static final String SRCVIDEOPATH = "srcvideoPath";
+ public static final String SRCFILEPATH = "srcfilePath";
public static final String PGC = "pgc";
public static final String UGC = "ugc";
public static final String EGC = "egc";
-
public static final String URL = "url";
public static final String SIZE = "size";
public static final String RESOLUTION= "resolution";
public static final String VIDEOTIME = "videoTime";
+ public static final String GOFASTURL = "gofastUrl";
+ public static final String ORIGINALURL = "originalUrl";
+ public static final String PATHSIZELIST = "pathSizeList";
+ public static final String PATH = "path";
+
}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/EmailGroup.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/EmailGroup.java
new file mode 100644
index 0000000..80486b3
--- /dev/null
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/EmailGroup.java
@@ -0,0 +1,27 @@
+package com.bfd.mf.job.domain.entity;
+
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(name = "cl_email_group")
+public class EmailGroup extends AbstractEntity{
+ private String email;
+ private String groupName;
+
+ public String getEmail() {
+ return email;
+ }
+
+ public void setEmail(String email) {
+ this.email = email;
+ }
+
+ public String getGroupName() {
+ return groupName;
+ }
+
+ public void setGroupName(String groupName) {
+ this.groupName = groupName;
+ }
+}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/ServiceLoad.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/ServiceLoad.java
new file mode 100644
index 0000000..32a22a4
--- /dev/null
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/ServiceLoad.java
@@ -0,0 +1,101 @@
+package com.bfd.mf.job.domain.entity;
+
+import javax.persistence.Entity;
+import javax.persistence.Table;
+import java.util.Date;
+
+@Entity
+@Table(name = "cl_service_load")
+public class ServiceLoad extends AbstractEntity {
+
+ private String channelId;
+ private String clientId;
+ private Integer status;
+ private String serviceUrl;
+ private String serviceNames;
+ private String token;
+ private String serviceCluster;
+ private Float serviceStatus;
+ private Date updateTime;
+ private String updateUser;
+
+ public String getChannelId() {
+ return channelId;
+ }
+
+ public void setChannelId(String channelId) {
+ this.channelId = channelId;
+ }
+
+ public String getClientId() {
+ return clientId;
+ }
+
+ public void setClientId(String clientId) {
+ this.clientId = clientId;
+ }
+
+ public Integer getStatus() {
+ return status;
+ }
+
+ public void setStatus(Integer status) {
+ this.status = status;
+ }
+
+ public String getServiceUrl() {
+ return serviceUrl;
+ }
+
+ public void setServiceUrl(String serviceUrl) {
+ this.serviceUrl = serviceUrl;
+ }
+
+ public String getServiceNames() {
+ return serviceNames;
+ }
+
+ public void setServiceNames(String serviceNames) {
+ this.serviceNames = serviceNames;
+ }
+
+ public String getToken() {
+ return token;
+ }
+
+ public void setToken(String token) {
+ this.token = token;
+ }
+
+ public String getServiceCluster() {
+ return serviceCluster;
+ }
+
+ public void setServiceCluster(String serviceCluster) {
+ this.serviceCluster = serviceCluster;
+ }
+
+ public Float getServiceStatus() {
+ return serviceStatus;
+ }
+
+ public void setServiceStatus(Float serviceStatus) {
+ this.serviceStatus = serviceStatus;
+ }
+
+ public Date getUpdateTime() {
+ return updateTime;
+ }
+
+ public void setUpdateTime(Date updateTime) {
+ this.updateTime = updateTime;
+ }
+
+ public String getUpdateUser() {
+ return updateUser;
+ }
+
+ public void setUpdateUser(String updateUser) {
+ this.updateUser = updateUser;
+ }
+}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/Subject.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/Subject.java
index a2e0782..e43695f 100644
--- a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/Subject.java
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/Subject.java
@@ -11,7 +11,7 @@ public class Subject extends AbstractEntity {
private Integer top; //0:未置顶1:置顶
private String name; // 专题名称
private String description; // 话题描述
- private Integer status; //专题状态 0使用中 1已暂停
+ // private Integer status; //专题状态 0使用中 1已暂停
private Integer subjectType; //话题类型:1:分类,2:话题,3:帖子
private Integer keywordsType; //关键词类型:1:简单型,2:关联型,3:专家型
private String simpleContent; // 简单型原始内容,逗号分割
@@ -68,14 +68,14 @@ public class Subject extends AbstractEntity {
public void setDescription(String description) {
this.description = description;
}
-
- public Integer getStatus() {
- return status;
- }
-
- public void setStatus(Integer status) {
- this.status = status;
- }
+//
+// public Integer getStatus() {
+// return status;
+// }
+//
+// public void setStatus(Integer status) {
+// this.status = status;
+// }
public Integer getSubjectType() {
return subjectType;
@@ -339,7 +339,7 @@ public class Subject extends AbstractEntity {
"top=" + top +
", name='" + name + '\'' +
", description='" + description + '\'' +
- ", status=" + status +
+ // ", status=" + status +
", subjectType=" + subjectType +
", keywordsType=" + keywordsType +
", simpleContent='" + simpleContent + '\'' +
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/SubjectCount.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/SubjectCount.java
index 05cd1ef..4feceb9 100644
--- a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/SubjectCount.java
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/SubjectCount.java
@@ -10,6 +10,7 @@ import java.util.Date;
public class SubjectCount extends AbstractEntity {
private BigInteger subjectId;
private Date createTime;
+ private Date updateTime;
private BigInteger totalCount;
private BigInteger todayTotalCount;
private BigInteger socialTotalCount;
@@ -51,6 +52,14 @@ public class SubjectCount extends AbstractEntity {
this.createTime = createTime;
}
+ public Date getUpdateTime() {
+ return updateTime;
+ }
+
+ public void setUpdateTime(Date updateTime) {
+ this.updateTime = updateTime;
+ }
+
public BigInteger getTotalCount() {
return totalCount;
}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/Task.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/Task.java
index 5f4eab9..fd120ba 100644
--- a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/Task.java
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/Task.java
@@ -2,53 +2,49 @@ package com.bfd.mf.job.domain.entity;
import javax.persistence.*;
import java.math.BigInteger;
+import java.sql.Timestamp;
import java.util.Date;
@Entity
@Table(name = "cl_task")
public class Task extends AbstractEntity {
- // @Id
-// @GeneratedValue(strategy = GenerationType.IDENTITY)
-// private BigInteger id;
- // private Integer top;
+//id,subject_id,external_id,site_type, task_type,cid,crawl_status,crawl_start_time,crawl_end_time,crawl_data_flag,data_total,today_data_total,cache_num,update_time,del,file_name,file_remark
+
+ // private long top;
private BigInteger subjectId;
+ // private String appId;
private String externalId;
- // private Integer crawlId;
+ // private long crawlId;
private Integer siteType;
- private Integer taskType;
- //private Integer siteId;
+ private Integer taskType; // u
+ // private long siteId;
private String cid;
- // private String attachTag;
- // private Integer crawlStatus;
- // private String crawlKeyword;
- // private String crawlPageTypes;
- // private String crawlContentKey;
- // private Integer crawlMode;
- // private Integer crawlCyclicityTime;
- //private Integer crawlPeriodHour;
- // private BigInteger maxPageNum;
- // private BigInteger secondaryDataMaxPage;
+ // private String attachTag;
+ private Integer crawlStatus; // u
+ // private String crawlKeyword;
+// private String crawlPageTypes;
+ private String crawlContentKey;
+ // private long crawlMode;
+// private int crawlCyclicityTime; //crawl_cyclicity_time
+// private long crawlPeriodHour;
+// private long maxPageNum;
+// private long secondaryDataMaxPage;
private BigInteger crawlStartTime;
private BigInteger crawlEndTime;
private String crawlDataFlag;
private BigInteger dataTotal;
private BigInteger todayDataTotal;
private Integer cacheNum;
- // private Date createTime;
- //private String createUser;
- // private String createUserId;
- private Date updateTime;
- // private String updateUser;
- // private String updateUserId;
- // private Integer del;
-
-// public BigInteger getId() {
-// return id;
-// }
-//
-// public void setId(BigInteger id) {
-// this.id = id;
-// }
+ // private java.sql.Timestamp createTime;
+// private String createUser;
+// private String createUserId;
+ private java.sql.Timestamp updateTime;
+ // private String updateUser;
+// private String updateUserId;
+ private Integer del;
+// private String fileName;
+// private String fileRemark;
+
public BigInteger getSubjectId() {
return subjectId;
@@ -66,14 +62,6 @@ public class Task extends AbstractEntity {
this.externalId = externalId;
}
- public Integer getTaskType() {
- return taskType;
- }
-
- public void setTaskType(Integer taskType) {
- this.taskType = taskType;
- }
-
public Integer getSiteType() {
return siteType;
}
@@ -81,13 +69,14 @@ public class Task extends AbstractEntity {
public void setSiteType(Integer siteType) {
this.siteType = siteType;
}
-// public Integer getSiteId() {
-// return siteId;
-// }
-//
-// public void setSiteId(Integer siteId) {
-// this.siteId = siteId;
-// }
+
+ public Integer getTaskType() {
+ return taskType;
+ }
+
+ public void setTaskType(Integer taskType) {
+ this.taskType = taskType;
+ }
public String getCid() {
return cid;
@@ -97,6 +86,22 @@ public class Task extends AbstractEntity {
this.cid = cid;
}
+ public Integer getCrawlStatus() {
+ return crawlStatus;
+ }
+
+ public String getCrawlContentKey() {
+ return crawlContentKey;
+ }
+
+ public void setCrawlContentKey(String crawlContentKey) {
+ this.crawlContentKey = crawlContentKey;
+ }
+
+ public void setCrawlStatus(Integer crawlStatus) {
+ this.crawlStatus = crawlStatus;
+ }
+
public BigInteger getCrawlStartTime() {
return crawlStartTime;
}
@@ -145,11 +150,19 @@ public class Task extends AbstractEntity {
this.cacheNum = cacheNum;
}
- public Date getUpdateTime() {
+ public Timestamp getUpdateTime() {
return updateTime;
}
- public void setUpdateTime(Date updateTime) {
+ public void setUpdateTime(Timestamp updateTime) {
this.updateTime = updateTime;
}
+
+ public Integer getDel() {
+ return del;
+ }
+
+ public void setDel(Integer del) {
+ this.del = del;
+ }
}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/TaskCount.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/TaskCount.java
new file mode 100644
index 0000000..f48faff
--- /dev/null
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/TaskCount.java
@@ -0,0 +1,36 @@
+package com.bfd.mf.job.domain.entity;
+
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(name = "cl_task_count")
+public class TaskCount extends AbstractEntity {
+ private String countDate;
+ private float avgCount;
+ private float avgSpeed;
+
+ public String getCountDate() {
+ return countDate;
+ }
+
+ public void setCountDate(String countDate) {
+ this.countDate = countDate;
+ }
+
+ public float getAvgCount() {
+ return avgCount;
+ }
+
+ public void setAvgCount(float avgCount) {
+ this.avgCount = avgCount;
+ }
+
+ public float getAvgSpeed() {
+ return avgSpeed;
+ }
+
+ public void setAvgSpeed(float avgSpeed) {
+ this.avgSpeed = avgSpeed;
+ }
+}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/UploadTask.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/UploadTask.java
new file mode 100644
index 0000000..9e44397
--- /dev/null
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/entity/UploadTask.java
@@ -0,0 +1,90 @@
+package com.bfd.mf.job.domain.entity;
+
+import javax.persistence.*;
+import java.math.BigInteger;
+
+@Entity
+@Table(name = "cl_task")
+public class UploadTask extends AbstractEntity {
+
+ // private long top;
+ private BigInteger subjectId;
+ private Integer taskType; // u
+ private Integer crawlStatus; // u
+ private String fileName;
+ private String crawlDataFlag;
+
+ public String getCrawlDataFlag() {
+ return crawlDataFlag;
+ }
+
+ public void setCrawlDataFlag(String crawlDataFlag) {
+ this.crawlDataFlag = crawlDataFlag;
+ }
+
+ public BigInteger getSubjectId() {
+ return subjectId;
+ }
+
+ public void setSubjectId(BigInteger subjectId) {
+ this.subjectId = subjectId;
+ }
+
+ public int getTaskType() {
+ return taskType;
+ }
+
+ public void setTaskType(int taskType) {
+ this.taskType = taskType;
+ }
+
+ public int getCrawlStatus() {
+ return crawlStatus;
+ }
+
+ public void setCrawlStatus(int crawlStatus) {
+ this.crawlStatus = crawlStatus;
+ }
+
+ public String getFileName() {
+ return fileName;
+ }
+
+ public void setFileName(String fileName) {
+ this.fileName = fileName;
+ }
+
+ // private int del;
+// private String fileRemark;
+ // private String appId;
+// private String externalId;
+ // private long crawlId;
+// private int siteType;
+
+ // private long siteId;
+ // private String cid;
+ // private String attachTag;
+
+ // private String crawlKeyword;
+// private String crawlPageTypes;
+// private String crawlContentKey;
+// private long crawlMode;
+// private int crawlCyclicityTime; //crawl_cyclicity_time
+// private long crawlPeriodHour;
+// private long maxPageNum;
+// private long secondaryDataMaxPage;
+// private BigInteger crawlStartTime;
+// private BigInteger crawlEndTime;
+// private String crawlDataFlag;
+// private BigInteger dataTotal;
+// private BigInteger todayDataTotal;
+// private Integer cacheNum;
+ // private java.sql.Timestamp createTime;
+// private String createUser;
+// private String createUserId;
+// private Timestamp updateTime;
+ // private String updateUser;
+// private String updateUserId;
+
+
+}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/EmailGroupRepository.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/EmailGroupRepository.java
new file mode 100644
index 0000000..1db188d
--- /dev/null
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/EmailGroupRepository.java
@@ -0,0 +1,14 @@
+package com.bfd.mf.job.domain.repository;
+
+import com.bfd.mf.job.domain.entity.EmailGroup;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.CrudRepository;
+
+import java.util.List;
+
+public interface EmailGroupRepository extends CrudRepository {
+
+ @Query(value = "SELECT * FROM cl_email_group WHERE id IN (SELECT email_group_id from cl_site_email_res WHERE site_id = (SELECT id FROM `cl_site` WHERE is_usable = 0 AND cid = ?1));", nativeQuery = true)
+ List getEmailGroupsByCid(String cid);
+
+}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/ResultDetailRepository.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/ResultDetailRepository.java
index bf7ea8d..717d959 100644
--- a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/ResultDetailRepository.java
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/ResultDetailRepository.java
@@ -1,7 +1,6 @@
package com.bfd.mf.job.domain.repository;
import com.bfd.mf.job.domain.entity.ResultDetail;
-import com.bfd.mf.job.domain.entity.Task;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.CrudRepository;
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/ServiceLoadRepository.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/ServiceLoadRepository.java
new file mode 100644
index 0000000..4fb22ab
--- /dev/null
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/ServiceLoadRepository.java
@@ -0,0 +1,17 @@
+package com.bfd.mf.job.domain.repository;
+
+import com.bfd.mf.job.domain.entity.ServiceLoad;
+import com.bfd.mf.job.domain.entity.TaskCount;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.CrudRepository;
+import org.springframework.transaction.annotation.Transactional;
+
+public interface ServiceLoadRepository extends CrudRepository {
+
+ @Modifying
+ @Transactional(rollbackFor = Exception.class)
+ @Query(value = "update cl_service_load set service_status =?2 ,update_time = now() where id =?1 ", nativeQuery = true)
+ void updateTaskCount(Integer id, Float serviceStatus);
+
+}
diff --git a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/SubjectCountRepository.java b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/SubjectCountRepository.java
index 8678bba..9194515 100644
--- a/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/SubjectCountRepository.java
+++ b/cl_query_data_job/src/main/java/com/bfd/mf/job/domain/repository/SubjectCountRepository.java
@@ -7,7 +7,7 @@ import org.springframework.data.repository.CrudRepository;
import org.springframework.transaction.annotation.Transactional;
import java.math.BigInteger;
-import java.util.List;
+import java.util.Date;
public interface SubjectCountRepository extends CrudRepository {
@@ -20,8 +20,8 @@ public interface SubjectCountRepository extends CrudRepository findAllSubject();
+// @Query(value = "SELECT ct.id,ct.subject_id,ct.cache_num,ct.cid,ct.external_id,ct.crawl_data_flag,ct.crawl_start_time,ct.crawl_end_time,cs.kafka_switch,cs.kafka_addr,cs.kafka_topic,cs.go_fast_addr,cs.`status`,ct.del as delt,cs.del as dels FROM cl_task ct JOIN cl_subject cs ON (ct.subject_id = cs.id) WHERE cs.status = 0 AND ct.del = 0 AND cs.del = 0",nativeQuery = true)
+// List