fix: 股权冻结fix bugs

src/main/scala/com/winhc/bigdata/spark/jobs/company_judicial_assistance.scala

@@ -491,13 +491,14 @@ case class company_judicial_assistance(s: SparkSession,
            |WHERE   ds = '$inc_ods_last_ds'
            |""".stripMargin)
         .save2HBase("COMPANY_JUDICIAL_ASSISTANCE", "rowkey", ads_cols.diff(Seq("ds", "id")))
+
       sql(
         s"""
            |SELECT  *
            |FROM    $inc_ads_list_tab
            |WHERE   ds = '$inc_ods_last_ds'
            |""".stripMargin)
-        .select(ads_cols.diff(Seq("ds")).map(column => col(column).cast("string")): _*)
+        .select(getColumns(inc_ads_list_tab).diff(Seq("ds")).map(column => col(column).cast("string")): _*)
         .write
         .mode("append")
         .jdbc(PhoenixConfig.getPhoenixJDBCUrl, "COMPANY_JUDICIAL_ASSISTANCE_LIST", PhoenixConfig.getPhoenixProperties)