Browse Source

fix: 查失信限高修复限高bug

许家凯 3 years ago
parent
commit
63ff152ebb

+ 2 - 0
src/main/scala/com/winhc/bigdata/spark/ng/credit_punishment/CreditPunishment.scala

@@ -19,6 +19,8 @@ object CreditPunishment {
   //---跑增量重写数据
   """
     |
+    |ALTER TABLE winhc_ng.bds_credit_punishment_data_extraction RENAME TO bds_credit_punishment_data_extraction_bak_20210906;
+    |
     |ALTER TABLE winhc_ng.bds_credit_punishment_case_info RENAME TO bds_credit_punishment_case_info_bak_20210906;
     |ALTER TABLE winhc_ng.bds_credit_punishment_entity_info RENAME TO bds_credit_punishment_entity_info_bak_20210906;
     |ALTER TABLE winhc_ng.bds_credit_punishment_entity_info_remove RENAME TO bds_credit_punishment_entity_info_remove_bak_20210906;

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/ng/credit_punishment/CreditPunishmentDataExtraction.scala

@@ -215,7 +215,7 @@ case class CreditPunishmentDataExtraction(s: SparkSession
          |       ,'company_zxr_restrict' as tn
          |       ,company_id as xjk_keyno
          |       ,company_name as xjk_name
-         |       ,coalesce(card_num,identity_num) as xjk_card_num
+         |       ,null as xjk_card_num
          |       ,court_name as xjk_court_name
          |       ,case_no as xjk_case_no
          |       ,case_create_time as xjk_case_create_time