新裁判文书

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

@@ -417,6 +417,17 @@ object args_company_job {
       , rowkey_udf = "company_id"
       , is_super_filter = false
     )
+
+    , args_company_job("wenshu_detail_v2", Seq("case_no", "title")
+      , rowkey_udf = "md5(cleanup(concat_ws('', case_no, title)))"
+      , is_super_filter = false
+      , where = " is_json_str(defendant_info) and is_json_str(plaintiff_info)"
+      , explode_args = Seq(
+        explode_args("plaintiff_info", "$.litigant_id", "plaintiff_info_id_explode")
+        , explode_args("defendant_info", "$.litigant_id", "defendant_info_id_explode")
+      )
+    )
+
   )
 
   def get_args_company_job(tn: String): args_company_job = {

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

@@ -442,6 +442,27 @@ object CompanySummaryNg_new {
         , ("0", s"finance_info_v3_dis_0")
       ))
     )
+
+    , SummaryArgs(table_name = "wenshu_detail_v2_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 "
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"wenshu_detail_v2_del_0_plaintiff")
+        , ("1", s"wenshu_detail_v2_del_1_plaintiff")
+      ))
+    )
+
+    , SummaryArgs(table_name = "wenshu_detail_v2_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 "
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"wenshu_detail_v2_del_0_defendant")
+        , ("1", s"wenshu_detail_v2_del_1_defendant")
+      ))
+    )
+
   )
 
 

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

@@ -302,6 +302,15 @@ object export_company_index_2_es {
       , "rowkey,company_id,company_name,license_number,business_scope,is_available,create_time,update_time,deleted".split(","))
     , export_2_es_args("company_change"
       , "rowkey,company_id,company_name,category,change_item,content_before,content_after,change_time,create_time,update_time,deleted".split(","))
+    , export_2_es_args("company_change"
+      , "rowkey,company_id,company_name,category,change_item,content_before,content_after,change_time,create_time,update_time,deleted".split(","))
+//    , export_2_es_args("wenshu_detail_v2"
+//      , ("rowkey,case_id,doc_id,case_type,case_no,doc_type,case_reason_level1,case_reason_level2,case_reason_level3,case_reason_level4,case_reason,case_reason_levelnum," +
+//        "case_stage,new_case_stage,case_amt,judge_amt,accept_amt,province_court_name,city_court_name,court_name,court_province_code,court_city_code,court_level,party_info," +
+//        "people_info,yg_info,yg_type,plaintiff_info,yg_wtdlr,yg_faren,yg_lawyer,bg_info,bg_type,defendant_info,bg_wtdlr,bg_faren,bg_lawyer,third_party,danbao,fact,court_view," +
+//        "judge,judge_name,clerk,clerk_name,judge_date_cn,judge_date,judge_year,judge_result,is_success,url,title,addenda,keywords,public_date,update_date,sample_type,judge_main," +
+//        "all_connect_case_no,connect_case_no,litigant_info,party_title,first_case_yg,first_case_bg,all_lawyer,trial_verify,debate_focus,judge_result_point,associate_party,argue_info," +
+//        "lawsuit_point,plead_point,quote_legislation,deleted").split(","))
   )