Browse Source

fix: v8摘要缩减

许家凯 2 years ago
parent
commit
640b8ebf1d

+ 23 - 22
src/main/scala/com/winhc/bigdata/spark/ng/utils/CompanySummaryNg_new.scala

@@ -36,9 +36,9 @@ object CompanySummaryNg_new {
   }
 
   val start_args = Seq(
-    get_default_summary_args("company_holder")
-    , get_default_summary_args("company_staff")
-    , get_default_summary_args("company_icp")
+//    get_default_summary_args("company_holder")
+//    , get_default_summary_args("company_staff")
+     get_default_summary_args("company_icp")
     , get_default_summary_args("company_tm", company_id = "keyno")
     , get_default_summary_args("company_app_info")
     , get_default_summary_args("finance_info_v3", "company_id")
@@ -46,12 +46,12 @@ object CompanySummaryNg_new {
     , get_default_summary_args("company_finance", "company_id")
     , get_default_summary_args("company_equity_pledge", "company_id")
     , get_default_summary_args("company_env_punishment", "company_id")
-    , get_default_summary_args("company_liquidating_info", "company_id")
+//    , get_default_summary_args("company_liquidating_info", "company_id")
     , get_default_summary_args("company_certificate", "company_id")
     //    , get_default_summary_args("company_icp", "company_id")
     , get_default_summary_args("company_weibo", "company_id")
     , get_default_summary_args("company_customs_credit", "company_id")
-    , get_default_summary_args("company_license", "company_id")
+//    , get_default_summary_args("company_license", "company_id")
     , get_default_summary_args("company_license_creditchina", "company_id")
     , get_default_summary_args("company_license_entpub", "company_id")
     , get_default_summary_args("company_tax", "company_id")
@@ -59,7 +59,7 @@ object CompanySummaryNg_new {
     , get_default_summary_args("company_land_publicity", "company_id")
     , get_default_summary_args("company_bond", "company_id")
     , get_default_summary_args("company_tele_license", "company_id")
-    , get_default_summary_args("company_change", "company_id")
+//    , get_default_summary_args("company_change", "company_id")
     , get_default_summary_args("company_employment", "company_id")
     , get_default_summary_args("increase_registered_capital_info", "company_id")
     , get_default_summary_args("reduction_registered_capital_info", "company_id")
@@ -68,7 +68,7 @@ object CompanySummaryNg_new {
     , get_default_summary_args("construction_person", "company_id")
     , get_default_summary_args("construction_project", "company_id")
 
-    , SummaryArgs(table_name = "company_court_open_announcement_explode"
+   /* , SummaryArgs(table_name = "company_court_open_announcement_explode"
       , companyIdField = "plaintiff_info_id_explode"
       , distinctField = "rowkey,plaintiff_info_id_explode"
       , where = "plaintiff_info_id_explode is not null and length(plaintiff_info_id_explode) = 32 "
@@ -85,7 +85,7 @@ object CompanySummaryNg_new {
         ("0", s"company_court_open_announcement_del_0_defendant")
         , ("1", s"company_court_open_announcement_del_1_defendant")
       ))
-    )
+    )*/
 
     , SummaryArgs(table_name = "company_dishonest_info"
       , companyIdField = "keyno"
@@ -152,14 +152,14 @@ object CompanySummaryNg_new {
     )
 
 
-    , SummaryArgs(table_name = "company_judicial_assistance"
+  /*  , SummaryArgs(table_name = "company_judicial_assistance"
       , companyIdField = "company_id"
       , where = "company_id is not null and length(company_id) = 32 "
       , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
         ("0", s"company_judicial_assistance_del_0_related")
         , ("1", s"company_judicial_assistance_del_1_related")
       ))
-    )
+    )*/
 
     , SummaryArgs(table_name = "company_judicial_assistance"
       , companyIdField = "executed_person_id"
@@ -171,14 +171,14 @@ object CompanySummaryNg_new {
     )
 
 
-    , SummaryArgs(table_name = "company_equity_info"
+  /*  , SummaryArgs(table_name = "company_equity_info"
       , companyIdField = "related_company_id"
       , where = "related_company_id is not null and length(related_company_id) = 32 "
       , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
         ("0", s"company_equity_info_del_0_related")
         , ("1", s"company_equity_info_del_1_related")
       ))
-    )
+    )*/
 
 
     , SummaryArgs(table_name = "company_equity_info_explode"
@@ -221,7 +221,7 @@ object CompanySummaryNg_new {
     )
 
 
-    , SummaryArgs(table_name = "company_court_announcement_explode"
+   /* , SummaryArgs(table_name = "company_court_announcement_explode"
       , companyIdField = "plaintiff_info_id_explode"
       , distinctField = "rowkey,plaintiff_info_id_explode"
       , where = "plaintiff_info_id_explode is not null and length(plaintiff_info_id_explode) = 32 "
@@ -238,8 +238,8 @@ object CompanySummaryNg_new {
         ("0", s"company_court_announcement_del_0_litigant")
         , ("1", s"company_court_announcement_del_1_litigant")
       ))
-    )
-    , SummaryArgs(table_name = "company_send_announcement_explode"
+    )*/
+/*    , SummaryArgs(table_name = "company_send_announcement_explode"
       , companyIdField = "plaintiff_info_id_explode"
       , distinctField = "rowkey,plaintiff_info_id_explode"
       , where = "plaintiff_info_id_explode is not null and length(plaintiff_info_id_explode) = 32 "
@@ -256,7 +256,8 @@ object CompanySummaryNg_new {
         ("0", s"company_send_announcement_del_0_defendant")
         , ("1", s"company_send_announcement_del_1_defendant")
       ))
-    ), SummaryArgs(table_name = "company_zxr_final_case"
+    )*/
+    , SummaryArgs(table_name = "company_zxr_final_case"
       , companyIdField = "keyno"
       , where = "keyno is not null and length(keyno) = 32 "
       , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
@@ -265,7 +266,7 @@ object CompanySummaryNg_new {
       ))
     )
 
-    , SummaryArgs(table_name = "company_court_register_explode"
+   /* , SummaryArgs(table_name = "company_court_register_explode"
       , companyIdField = "plaintiff_info_id_explode"
       , distinctField = "rowkey,plaintiff_info_id_explode"
       , where = "plaintiff_info_id_explode is not null and length(plaintiff_info_id_explode) = 32 "
@@ -283,7 +284,7 @@ object CompanySummaryNg_new {
         ("0", s"company_court_register_del_0_defendant")
         , ("1", s"company_court_register_del_1_defendant")
       ))
-    )
+    )*/
 
 
     , SummaryArgs(table_name = "litigation_mediation_explode"
@@ -364,14 +365,14 @@ object CompanySummaryNg_new {
     , get_default_summary_args("zxr_evaluate_results", "keyno")
     , get_default_summary_args("restrictions_on_exit", "executed_person_keyno")
     , get_default_summary_args("company_zxr", "keyno")
-    , get_default_summary_args("company_punishment_info", "company_id")
+//    , get_default_summary_args("company_punishment_info", "company_id")
     , get_default_summary_args("company_tax_contravention", "company_id")
     , get_default_summary_args("company_own_tax", "company_id")
-    , get_default_summary_args("company_check_info", "company_id")
+//    , get_default_summary_args("company_check_info", "company_id")
     , get_default_summary_args("company_punishment_info_creditchina", "company_id")
     , get_default_summary_args("company_mortgage_info", "company_id")
-    , get_default_summary_args("company_brief_cancel_announcement", "company_id")
-    , get_default_summary_args("company_double_random_check_info", "company_id")
+//    , get_default_summary_args("company_brief_cancel_announcement", "company_id")
+//    , get_default_summary_args("company_double_random_check_info", "company_id")
     , get_default_summary_args("company_wechat", "company_id")
     , get_default_summary_args("company_annual_report", "company_id")