fix

src/main/scala/com/winhc/bigdata/spark/jobs/chance/ChangeExtract.scala

@@ -71,7 +71,7 @@ object ChangeExtract {
             s"""
                |SELECT  cid,current_cid as new_cid
                |FROM    ${project}.inc_ads_company
-               |WHERE   ds = $ds
+               |WHERE   ds = '${getLastPartitionsOrElse(s"$project.inc_ads_company", "0")}'
                |AND     cid IS NOT NULL
                |AND     current_cid IS NOT NULL
                |GROUP BY cid,current_cid
@@ -297,7 +297,7 @@ object ChangeExtract {
     , Args(tableName = "company_icp", primaryFields = "domain")
     , Args(tableName = "company_punishment_info", primaryFields = "punish_number")
     , Args(tableName = "company_punishment_info_creditchina", primaryFields = "punish_number")
-    , Args(tableName = "bankruptcy_open_case", primaryFields = "case_no") //破产重整
+    , Args(tableName = "bankruptcy_open_case", primaryFields = "case_no", isCopy=false) //破产重整
     , Args(tableName = "company_public_announcement2_list", primaryFields = "applicant_cid,owner_cid,drawer_cid,gather_name_cid,bill_num")//公示催告
 
     , Args(tableName = "company_certificate", primaryFields = "type")

src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/CompanyDynamic.scala

@@ -180,6 +180,7 @@ object CompanyDynamic {
     , Args(tableName = "company_equity_info")
     , Args(tableName = "company_staff", bName = 0)
     , Args(tableName = "company", bName = 0)
+    , Args(tableName = "bankruptcy_open_case", bName = 1)
   )
 
   private case class Args(project: String = "winhc_eci_dev"