Browse Source

feat: 裁判文书企业摘要和人的摘要

许家凯 3 years ago
parent
commit
d79b6c9066

+ 24 - 0
src/main/scala/com/winhc/bigdata/spark/ng/utils/CompanySummaryNg_new.scala

@@ -415,6 +415,28 @@ object CompanySummaryNg_new {
       ))
     )
 
+
+    , company_summary_args(table_name = "company_lawsuit_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"company_lawsuit_del_0_plaintiff")
+        , ("1", s"company_lawsuit_del_1_plaintiff")
+      ))
+    )
+    , company_summary_args(table_name = "company_lawsuit_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"company_lawsuit_del_0_defendant")
+        , ("1", s"company_lawsuit_del_1_defendant")
+      ))
+    )
+
+
+
     , company_summary_args(table_name = "company_court_announcement_explode"
       , companyIdField = "plaintiff_info_id_explode"
       , distinctField = "rowkey,plaintiff_info_id_explode"
@@ -502,6 +524,8 @@ object CompanySummaryNg_new {
     )
 
 
+
+
     //====================================================
 
     , get_default_summary_args("zxr_evaluate", "keyno")

+ 21 - 0
src/main/scala/com/winhc/bigdata/spark/ng/utils/PersonSummaryNg_new.scala

@@ -282,6 +282,27 @@ object PersonSummaryNg_new {
     )
 
 
+    , company_summary_args(table_name = "company_lawsuit_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) = 33 "
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_lawsuit_del_0_plaintiff")
+        , ("1", s"company_lawsuit_del_1_plaintiff")
+      ))
+    )
+    , company_summary_args(table_name = "company_lawsuit_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) = 33 "
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_lawsuit_del_0_defendant")
+        , ("1", s"company_lawsuit_del_1_defendant")
+      ))
+    )
+
+
+
     , company_summary_args(table_name = "company_court_announcement_explode"
       , companyIdField = "plaintiff_info_id_explode"
       , distinctField = "rowkey,plaintiff_info_id_explode"