feat: 添加企业摘要参数

src/main/scala/com/winhc/bigdata/spark/ng/utils/CompanySummaryNg_new.scala

@@ -265,6 +265,18 @@ object CompanySummaryNg_new {
     )
   }
 
+  private def get_default_summary_args(tableName: String,company_id:String): company_summary_args = {
+    company_summary_args(
+      table_name = tableName
+      , companyIdField = company_id
+      , where = s"$company_id is not null and length($company_id) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"${tableName}_del_0")
+        , ("1", s"${tableName}_del_1")
+      ))
+    )
+  }
+
   private val start_args = Seq(
     get_default_summary_args("company_holder")
     , get_default_summary_args("company_staff")
@@ -274,21 +286,237 @@ object CompanySummaryNg_new {
 
     , company_summary_args(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 and deleted <> 9"
       , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
-        ("0", s"company_court_open_announcement_deleted_0_plaintiff")
-        , ("1", s"company_court_open_announcement_deleted_1_plaintiff")
+        ("0", s"company_court_open_announcement_del_0_plaintiff")
+        , ("1", s"company_court_open_announcement_del_1_plaintiff")
       ))
     )
     , company_summary_args(table_name = "company_court_open_announcement_explode"
       , companyIdField = "defendant_info_id_explode"
+      , distinctField = "rowkey,defendant_info_id_explode"
+      , where = "defendant_info_id_explode is not null and length(defendant_info_id_explode) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_court_open_announcement_del_0_defendant")
+        , ("1", s"company_court_open_announcement_del_1_defendant")
+      ))
+    )
+
+    , company_summary_args(table_name = "company_dishonest_info"
+      , companyIdField = "keyno"
+      , where = "keyno is not null and length(keyno) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_dishonest_info_del_0")
+        , ("1", s"company_dishonest_info_del_1")
+      ))
+    )
+    , company_summary_args(table_name = "company_zxr_restrict"
+      , companyIdField = "company_id"
+      , where = "company_id is not null and length(company_id) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_zxr_restrict_del_0")
+        , ("1", s"company_zxr_restrict_del_1")
+      ))
+    )
+
+    , company_summary_args(table_name = "company_abnormal_info"
+      , companyIdField = "company_id"
+      , where = "company_id is not null and length(company_id) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_abnormal_info_del_0")
+        , ("1", s"company_abnormal_info_del_1")
+      ))
+    )
+
+    //todo
+    , company_summary_args(table_name = "company_public_announcement"
+      , companyIdField = "company_id"
+      , where = "company_id is not null and length(company_id) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_public_announcement_del_0")
+        , ("1", s"company_public_announcement_del_1")
+      ))
+    )
+    , company_summary_args(table_name = "company_illegal_info"
+      , companyIdField = "company_id"
+      , where = "company_id is not null and length(company_id) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_illegal_info_del_0")
+        , ("1", s"company_illegal_info_del_1")
+      ))
+    )
+
+
+    , company_summary_args(table_name = "company_land_mortgage"
+      , companyIdField = "mortgagor_company_id"
+      , where = "mortgagor_company_id is not null and length(mortgagor_company_id) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_land_mortgage_del_0_mortgagor")
+        , ("1", s"company_land_mortgage_del_1_mortgagor")
+      ))
+    )
+
+
+    , company_summary_args(table_name = "company_land_mortgage"
+      , companyIdField = "mortgagee_company_id"
+      , where = "mortgagee_company_id is not null and length(mortgagee_company_id) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_land_mortgage_del_0_mortgagee")
+        , ("1", s"company_land_mortgage_del_1_mortgagee")
+      ))
+    )
+
+
+    , company_summary_args(table_name = "company_judicial_assistance"
+      , companyIdField = "company_id"
+      , where = "company_id is not null and length(company_id) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_judicial_assistance_del_0")
+        , ("1", s"company_judicial_assistance_del_1")
+      ))
+    )
+
+
+    , company_summary_args(table_name = "company_equity_info"
+      , companyIdField = "related_company_id"
+      , where = "related_company_id is not null and length(related_company_id) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_equity_info_del_0_related")
+        , ("1", s"company_equity_info_del_1_related")
+      ))
+    )
+    , company_summary_args(table_name = "company_equity_info_explode"
+      , companyIdField = "pledgor_keyno_explode"
+      , distinctField = "rowkey,pledgor_keyno_explode"
+      , where = "pledgor_keyno_explode is not null and length(pledgor_keyno_explode) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_equity_info_del_0_pledgor")
+        , ("1", s"company_equity_info_del_1_pledgor")
+      ))
+    )
+    , company_summary_args(table_name = "company_equity_info_explode"
+      , companyIdField = "pledgee_keyno_explode"
+      , distinctField = "rowkey,pledgee_keyno_explode"
+      , where = "pledgee_keyno_explode is not null and length(pledgee_keyno_explode) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_equity_info_del_0_pledgee")
+        , ("1", s"company_equity_info_del_1_pledgee")
+      ))
+    )
+
+    , company_summary_args(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 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_court_announcement_del_0_plaintiff")
+        , ("1", s"company_court_announcement_del_1_plaintiff")
+      ))
+    )
+    , company_summary_args(table_name = "company_court_announcement_explode"
+      , companyIdField = "litigant_info_id_explode"
+      , distinctField = "rowkey,litigant_info_id_explode"
+      , where = "litigant_info_id_explode is not null and length(litigant_info_id_explode) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_court_announcement_del_0_litigant")
+        , ("1", s"company_court_announcement_1_litigant")
+      ))
+    )
+    , company_summary_args(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 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_send_announcement_del_0_plaintiff")
+        , ("1", s"company_send_announcement_1_plaintiff")
+      ))
+    )
+    , company_summary_args(table_name = "company_send_announcement_explode"
+      , companyIdField = "defendant_info_id_explode"
+      , distinctField = "rowkey,defendant_info_id_explode"
+      , where = "defendant_info_id_explode is not null and length(defendant_info_id_explode) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_send_announcement_del_0_defendant")
+        , ("1", s"company_send_announcement_1_defendant")
+      ))
+    ), company_summary_args(table_name = "company_zxr_final_case"
+      , companyIdField = "keyno"
+      , where = "keyno is not null and length(keyno) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_send_announcement_del_0")
+        , ("1", s"company_send_announcement_del_1")
+      ))
+    )
+
+    , company_summary_args(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 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_court_register_del_0_plaintiff")
+        , ("1", s"company_court_register_del_1_plaintiff")
+      ))
+    )
+
+    , company_summary_args(table_name = "company_court_register_explode"
+      , companyIdField = "defendant_info_id_explode"
+      , distinctField = "rowkey,defendant_info_id_explode"
       , where = "defendant_info_id_explode is not null and length(defendant_info_id_explode) = 32 and deleted <> 9"
       , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
-        ("0", s"company_court_open_announcement_deleted_0_defendant")
-        , ("1", s"company_court_open_announcement_deleted_1_defendant")
+        ("0", s"company_court_register_del_0_defendant")
+        , ("1", s"company_court_register_del_1_defendant")
       ))
     )
 
+    /**
+     * ====================================================
+     */
+    , company_summary_args(table_name = "bankruptcy_open_case_explode"
+      , companyIdField = "applicant_info_id_explode"
+      , distinctField = "rowkey,applicant_info_id_explode"
+      , where = "applicant_info_id_explode is not null and length(applicant_info_id_explode) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"bankruptcy_open_case_del_0_applicant")
+        , ("1", s"bankruptcy_open_case_del_1_applicant")
+      ))
+    )
+
+    , company_summary_args(table_name = "bankruptcy_open_case_explode"
+      , companyIdField = "respondent_info_id_explode"
+      , distinctField = "rowkey,respondent_info_id_explode"
+      , where = "respondent_info_id_explode is not null and length(respondent_info_id_explode) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"bankruptcy_open_case_del_0_respondent")
+        , ("1", s"bankruptcy_open_case_del_1_respondent")
+      ))
+    )
+
+    /**
+     * ====================================================
+     */
+
+    , 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_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")
+
+    , company_summary_args(table_name = "auction_tracking_explode"
+      , companyIdField = "company_info_id_explode"
+      , distinctField = "rowkey,company_info_id_explode"
+      , where = "company_info_id_explode is not null and length(company_info_id_explode) = 32 and deleted <> 9"
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"auction_tracking_del_0")
+        , ("1", s"auction_tracking_del_1")
+      ))
+    )
+
+
+
   )
 
   def main(args: Array[String]): Unit = {