股东时间修复

src/main/scala/com/winhc/bigdata/spark/ng/change/NgChangeExtractAll.scala

@@ -25,7 +25,7 @@ case class NgChangeExtractAll(s: SparkSession,
                              ) extends LoggingUtils with Logging {
   @(transient@getter) val spark: SparkSession = s
 
-  val target_tab = "bds_change_extract_all"
+  val target_tab = "bds_change_extract_all_v2"
 
   init()
 
@@ -102,7 +102,7 @@ case class NgChangeExtractAll(s: SparkSession,
          |FROM
          |    tmp_change_extract_view_$tableName
          |WHERE
-         |    update_type = 'insert'
+         |--    update_type = 'insert'
          |""".stripMargin)
   }
 }

src/main/scala/com/winhc/bigdata/spark/ng/monitor/CompanyMonitorV2.scala

@@ -22,7 +22,7 @@ import scala.collection.mutable
  * @Description: 企业财产监控v8版本
  */
 object CompanyMonitorV2 {
-  val targetTab = "winhc_ng.ads_company_monitor_dev"
+  val targetTab = "winhc_ng.ads_company_monitor"
 
   case class CompanyMonitorUtil(s: SparkSession,
                                 project: String, //表所在工程名
@@ -169,7 +169,7 @@ object CompanyMonitorV2 {
     , Args(tableName = "zxr_evaluate")
     , Args(tableName = "zxr_evaluate_results")
     , Args(tableName = "company_license")
-    , Args(tableName = "company_judicial_assistance")
+    //, Args(tableName = "company_judicial_assistance")
 
   )
 

src/main/scala/com/winhc/bigdata/spark/ng/monitor/table/company_holder.scala

@@ -44,11 +44,11 @@ case class company_holder(is_inc: Boolean) extends AbstractDailyHandle {
       , dimension_type = args1.dimension_type
       , flow_type = args1.flow_type
       , rta_desc = ""
-      , change_time = biz_date
+      , change_time = CompanyMonitorUtils.formatDate(biz_date)
       , biz_id = rowkey
       , info_risk_level = args1.info_risk_level
       , `type` = `type1`
-      , create_time = update_time
+      , create_time = CompanyMonitorUtils.formatDate(update_time)
       , amt = get_money(new_data)
       , update_type = update_type
       , deleted = get_deleted(new_data)