字段变更

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

@@ -123,8 +123,8 @@ object args_company_job {
         , explode_args("defendant_info", "$.litigant_id", "defendant_info_id_explode")
       )
     )
-    , args_company_job("company_zxr_final_case", Seq("case_no")
-      , rowkey_udf = "md5(cleanup(concat_ws('',case_no )))"
+    , args_company_job("company_zxr_final_case", Seq("case_no,name")
+      , rowkey_udf = "md5(cleanup(concat_ws('',case_no,name )))"
       , is_super_filter = false
     )
     , args_company_job("company_tax_contravention", Seq("case_info", "company_id")

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

@@ -210,7 +210,7 @@ object export_company_index_2_es {
     , export_2_es_args("company_court_announcement"
       , "rowkey,announcement_type,case_no,court_name,plaintiff_info,litigant_info,publish_date,deleted".split(","))
     , export_2_es_args("company_send_announcement"
-      , "rowkey,defendant_info,plaintiff_info,court,start_date,title,deleted".split(","))
+      , "rowkey,defendant_info,plaintiff_info,court,start_date,title,case_no,deleted".split(","))
     , export_2_es_args("company_court_register"
       , "rowkey,case_no,case_reason,defendant_info,plaintiff_info,filing_date,deleted".split(","))