Prechádzať zdrojové kódy

fix: 调整人摘要字段名

许家凯 4 rokov pred
rodič
commit
b8519eda09

+ 12 - 1
src/main/scala/com/winhc/bigdata/spark/ng/utils/PersonSummaryNg_new.scala

@@ -256,12 +256,23 @@ object PersonSummaryNg_new {
     get_default_summary_args("company_zxr", "keyno")
     , get_default_summary_args("company_dishonest_info", "keyno")
     , get_default_summary_args("company_zxr_restrict", "pid")
-    , get_default_summary_args("company_judicial_assistance", "executed_person_id")
+//    , get_default_summary_args("company_judicial_assistance", "executed_person_id")
     , get_default_summary_args("restrictions_on_exit", "limited_person_pid")
     , get_default_summary_args("company_zxr_final_case", "keyno")
     , get_default_summary_args("zxr_evaluate_results", "keyno")
 
 
+
+    , company_summary_args(table_name = "company_judicial_assistance"
+      , companyIdField = "executed_person_id"
+      , where = "executed_person_id is not null and length(executed_person_id) = 33 "
+      , groupByInfo = GroupByInfoNg(field = "deleted", value_alias = Seq(
+        ("0", s"company_judicial_assistance_del_0_executed_person")
+        , ("1", s"company_judicial_assistance_del_1_executed_person")
+      ))
+    )
+
+
     , company_summary_args(table_name = "company_court_open_announcement_explode"
       , companyIdField = "plaintiff_info_id_explode"
       , distinctField = "rowkey,plaintiff_info_id_explode"