风险数据，被执行人，破产等

src/main/scala/com/winhc/bigdata/spark/ng/jobs/args_company_job.scala

@@ -162,6 +162,68 @@ object args_company_job {
       , rowkey_udf = "md5(cleanup(concat_ws('',main_id,check_item,check_result)))"
       , is_super_filter = false
     )
+
+
+    , args_company_job("company_zxr", Seq("name", "case_no")
+      , rowkey_udf = "md5(cleanup(concat_ws('',name,case_no)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("bankruptcy_open_case", Seq("applicant", "respondent", "public_date")
+      , rowkey_udf = "md5(cleanup(concat_ws('',applicant,respondent,split_date(cast(public_date as String)))))"
+      , is_super_filter = false
+      , where = "is_json_str(applicant_info) and is_json_str(respondent_info) "
+      , explode_args = Seq(
+        explode_args("applicant_info", "$.litigant_id", "applicant_info_id_explode")
+        , explode_args("respondent_info", "$.litigant_id", "respondent_info_id_explode")
+      )
+
+    )
+
+    , args_company_job("bankruptcy_open_announcement", Seq("title", "case_no")
+      , rowkey_udf = "md5(cleanup(concat_ws('',title,case_no)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("bankruptcy_judgment_document", Seq("title", "case_no")
+      , rowkey_udf = "md5(cleanup(concat_ws('',title,case_no)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("auction_tracking", Seq("auction_items_id")
+      , rowkey_udf = "md5(cleanup(concat_ws('',auction_items_id)))"
+      , is_super_filter = false
+      , where = "is_json_str(company_info) "
+      , explode_args = Seq(
+        explode_args("company_info", "$.litigant_id", "company_info_id_explode")
+
+      )
+    )
+
+    , args_company_job("company_punishment_info", Seq("punish_number")
+      , rowkey_udf = "md5(cleanup(concat_ws('',punish_number)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("company_punishment_info_creditchina", Seq("punish_number")
+      , rowkey_udf = "md5(cleanup(concat_ws('',punish_number)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("company_brief_cancel_announcement", Seq("company_id")
+      , rowkey_udf = "md5(cleanup(concat_ws('',company_id)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("company_brief_cancel_announcement_objection", Seq("main_id", "objection_date", "objection_content")
+      , rowkey_udf = "md5(cleanup(concat_ws('',main_id, split_date(cast(objection_date as String)), objection_content)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("company_brief_cancel_announcement_result", Seq("main_id", "announcement_apply_date", "brief_cancel_result")
+      , rowkey_udf = "md5(cleanup(concat_ws('',main_id, split_date(cast(announcement_apply_date as String)), brief_cancel_result)))"
+      , is_super_filter = false
+    )
   )
 
   def get_args_company_job(tn: String): args_company_job = {

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

@@ -495,7 +495,7 @@ object CompanySummaryNg_new {
     /**
      * ====================================================
      */
-
+    , get_default_summary_args("company_zxr")
     , 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")

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

@@ -187,6 +187,20 @@ object export_company_index_2_es {
       , "rowkey,company_id,company_name,reg_num,reg_date,publish_date,reg_department,type,deleted".split(","))
     , export_2_es_args("company_double_random_check_info"
       , "rowkey,company_id,company_name,check_plan_num,check_plan_name,check_task_num,check_task_name,check_type,check_department,check_date,deleted".split(","))
+
+
+    , export_2_es_args("company_zxr"
+      , "rowkey,name,keyno,card,court,case_create_time,case_no,exec_money,status,deleted".split(","))
+    , export_2_es_args("bankruptcy_open_case"
+      , "rowkey,case_no,case_type,agency_court,applicant,applicant_info,respondent,respondent_info,public_date,deleted".split(","))
+    , export_2_es_args("auction_tracking"
+      , "rowkey,auction_items_id,company_info,case_no,auction_title,initial_price,start_time,apply_count,url,deleted".split(","))
+    , export_2_es_args("company_punishment_info"
+      , "rowkey,company_id,company_name,person_name,pid,type,department_name,decision_date,publish_date,deleted".split(","))
+    , export_2_es_args("company_punishment_info_creditchina"
+      , "rowkey,company_id,company_name,punish_number,punish_name,person_name,pid,decision_date,status,deleted".split(","))
+    , export_2_es_args("company_brief_cancel_announcement"
+      , "rowkey,company_id,deleted".split(","))
   )