feat:第二批变更参数

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

@@ -42,5 +42,20 @@ object NgChangeExtractArgs {
     , "company_license_creditchina"
     , "company_license_entpub"
 
+
+
+    , "bankruptcy_open_case"
+    , "company_brief_cancel_announcement"
+    , "company_dishonest_info"
+    , "company_public_announcement"
+    , "company_zxr"
+    , "company_zxr_final_case"
+    , "company_zxr_restrict"
+    , "restrictions_on_exit"
+
+    , "company_land_announcement"
+    , "company_land_publicity"
+    , "company_land_transfer"
+
   ).map(r => NgChangeExtractArgs(tableName = r))
 }

src/main/scala/com/winhc/bigdata/spark/ng/change/table/bankruptcy_open_case.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class bankruptcy_open_case(equCols: Seq[String],is_inc:Boolean) extends NgCompanyChangeHandle {
+
+
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc?DateUtils.getBizDate(newMap("update_time"))|DateUtils.getBizDate(newMap("public_date"))
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/change/table/company_brief_cancel_announcement.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class company_brief_cancel_announcement(equCols: Seq[String], is_inc: Boolean) extends NgCompanyChangeHandle {
+
+  //todo
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc ? DateUtils.getBizDate(newMap("update_time")) | DateUtils.getBizDate(newMap("publish_date"))
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/change/table/company_dishonest_info.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class company_dishonest_info(equCols: Seq[String],is_inc:Boolean) extends NgCompanyChangeHandle {
+
+
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc?DateUtils.getBizDate(newMap("update_time"))|DateUtils.getBizDate(newMap("pub_date"))
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/change/table/company_land_announcement.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class company_land_announcement(equCols: Seq[String],is_inc:Boolean) extends NgCompanyChangeHandle {
+
+
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc?DateUtils.getBizDate(newMap("update_time"))|DateUtils.getBizDate(newMap("contract_date"))
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/change/table/company_land_publicity.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class company_land_publicity(equCols: Seq[String], is_inc: Boolean) extends NgCompanyChangeHandle {
+
+
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc ? DateUtils.getBizDate(newMap("update_time")) | DateUtils.getBizDate(newMap("publication_date"), newMap("publication_start_date"))
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/change/table/company_land_transfer.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class company_land_transfer(equCols: Seq[String],is_inc:Boolean) extends NgCompanyChangeHandle {
+
+
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc?DateUtils.getBizDate(newMap("update_time"))|DateUtils.getBizDate(newMap("merchandise_time"))
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/change/table/company_public_announcement.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class company_public_announcement(equCols: Seq[String],is_inc:Boolean) extends NgCompanyChangeHandle {
+
+
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc?DateUtils.getBizDate(newMap("update_time"))|DateUtils.getBizDate(newMap("publish_date"))
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/change/table/company_zxr.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class company_zxr(equCols: Seq[String],is_inc:Boolean) extends NgCompanyChangeHandle {
+
+
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc?DateUtils.getBizDate(newMap("update_time"))|DateUtils.getBizDate(newMap("case_create_time"))
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/change/table/company_zxr_final_case.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class company_zxr_final_case(equCols: Seq[String],is_inc:Boolean) extends NgCompanyChangeHandle {
+
+
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc?DateUtils.getBizDate(newMap("update_time"))|DateUtils.getBizDate(newMap("case_final_time"))
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/change/table/company_zxr_restrict.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class company_zxr_restrict(equCols: Seq[String],is_inc:Boolean) extends NgCompanyChangeHandle {
+
+
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc?DateUtils.getBizDate(newMap("update_time"))|DateUtils.getBizDate(newMap("case_create_time"))
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/change/table/restrictions_on_exit.scala

@@ -0,0 +1,14 @@
+
+
+package com.winhc.bigdata.spark.ng.change.table
+
+import com.winhc.bigdata.spark.ng.change.NgCompanyChangeHandle
+import com.winhc.bigdata.spark.utils.DateUtils
+import com.winhc.bigdata.spark.implicits.Bool._
+
+case class restrictions_on_exit(equCols: Seq[String],is_inc:Boolean) extends NgCompanyChangeHandle {
+
+
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc?DateUtils.getBizDate(newMap("update_time"))|DateUtils.getBizDate(newMap("publish_time"))
+}
+