司法案件预处理 被执行人和终本修改

src/main/scala/com/winhc/bigdata/spark/jobs/judicial/JudicialCaseRelationPre10.scala

@@ -119,11 +119,11 @@ case class JudicialCaseRelationPre10(s: SparkSession, project: String
          |      ,exec_money as case_amt
          |      ,row_number() over(partition by rowkey order by update_time desc) num
          |      from (
-         |        select case_no,court,cname,case_create_time,rowkey,update_time,card
+         |        select case_no,court,cname,case_create_time,rowkey,update_time,card,exec_money
          |        from $project.ads_company_zxr_person
          |        where length(case_no) > 0 and ds>'0'
          |        union all
-         |        select case_no,court,cname,case_create_time,rowkey,update_time,card
+         |        select case_no,court,cname,case_create_time,rowkey,update_time,card,exec_money
          |        from $project.inc_ads_company_zxr_person
          |        where length(case_no) > 0 and ds>'0'
          |      ) A

src/main/scala/com/winhc/bigdata/spark/jobs/judicial/JudicialCaseRelationPre12.scala

@@ -119,11 +119,11 @@ case class JudicialCaseRelationPre12(s: SparkSession, project: String
          |      ,exec_amount as case_amt
          |      ,row_number() over(partition by rowkey order by update_time desc) num
          |      from (
-         |        select case_no,court_name,name,case_create_time,rowkey,update_time,identity_num
+         |        select case_no,court_name,name,case_create_time,rowkey,update_time,identity_num,exec_amount
          |        from $project.ads_company_zxr_final_case_person
          |        where length(case_no) > 0 and ds>'0'
          |        union all
-         |        select case_no,court_name,name,case_create_time,rowkey,update_time,identity_num
+         |        select case_no,court_name,name,case_create_time,rowkey,update_time,identity_num,exec_amount
          |        from $project.inc_ads_company_zxr_final_case_person
          |        where length(case_no) > 0 and ds>'0'
          |      ) A