司法拍卖,增资记录监控

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

@@ -371,6 +371,8 @@ object ChangeExtract {
     , Args(tableName = "company_holder", primaryFields = "amount")
     , Args(tableName = "company_holder_v2", primaryFields = "deleted")
     , Args(tableName = "company_annual_report_out_investment", primaryFields = "main_id")
+    , Args(tableName = "increase_registered_capital_info", primaryFields = "change_time")
+    , Args(tableName = "auction_tracking_list", primaryFields = "auction_items_id")
   )
 
 

src/main/scala/com/winhc/bigdata/spark/jobs/chance/table/auction_tracking_list.scala

@@ -0,0 +1,23 @@
+
+package com.winhc.bigdata.spark.jobs.chance.table
+
+import com.winhc.bigdata.spark.jobs.chance.CompanyChangeHandle
+import com.winhc.bigdata.spark.utils.{ChangeExtractUtils, DateUtils}
+
+/**
+ * @Author: π
+ * @Date: 2020/8/11
+ * @Description:司法拍卖
+ */
+
+case class auction_tracking_list(equCols: Seq[String]) extends CompanyChangeHandle with Serializable {
+  override def getUpdateTitle(newMap: Map[String, String]): String = s"司法拍卖发生变更"
+
+  override def getInsertTitle(newMap: Map[String, String]): String = s"新增司法拍卖"
+
+  override def getLabel(oldMap: Map[String, String], newMap: Map[String, String]): String = ChangeExtractUtils.getTags(newMap, "司法拍卖", Array("auction_items_id"))
+
+  override def getBizTime(newMap: Map[String, String]): String = {
+    DateUtils.getBizDate(newMap("end_time"), newMap("update_time"))
+  }
+}

src/main/scala/com/winhc/bigdata/spark/jobs/chance/table/increase_registered_capital_info.scala

@@ -0,0 +1,23 @@
+
+package com.winhc.bigdata.spark.jobs.chance.table
+
+import com.winhc.bigdata.spark.jobs.chance.CompanyChangeHandle
+import com.winhc.bigdata.spark.utils.{ChangeExtractUtils, DateUtils}
+
+/**
+ * @Author: π
+ * @Date: 2020/8/11
+ * @Description:增资记录
+ */
+
+case class increase_registered_capital_info(equCols: Seq[String]) extends CompanyChangeHandle with Serializable  {
+  override def getUpdateTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("change_item"), s"注册资本发生变更")
+
+  override def getInsertTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("change_item"), s"增资记录")
+
+  override def getLabel(oldMap: Map[String, String], newMap: Map[String, String]): String = ChangeExtractUtils.getTags(newMap, "增资记录", Array("change_item","change_time"))
+
+  override def getBizTime(newMap: Map[String, String]): String = {
+    DateUtils.getBizDate(newMap("change_time"), newMap("update_time"))
+  }
+}

src/main/scala/com/winhc/bigdata/spark/jobs/monitor/CompanyMonitor.scala

@@ -199,6 +199,7 @@ object CompanyMonitor {
     //, Args(tableName = "company", bName = 1)
     , Args(tableName = "company_land_mortgage_v2", bName = 1)
     , Args(tableName = "auction_tracking_list", bName = 1)
+    , Args(tableName = "increase_registered_capital_info", bName = 1)
 
   )
 

src/main/scala/com/winhc/bigdata/spark/jobs/monitor/CompanyMonitorHandle.scala

@@ -31,7 +31,7 @@ trait CompanyMonitorHandle extends Logging {
     , "company_copyright_works_list" -> "1" //作品著作权
     , "company_holder_add" -> "2" //股东新增
     , "company_holder_deleted" -> "1" //股东移除
-    , "company" -> "2" //工商信息
+    , "increase_registered_capital_info" -> "2" //增资记录
     , "auction_tracking_list" -> "3" //司法拍卖
   )
 
@@ -57,7 +57,7 @@ trait CompanyMonitorHandle extends Logging {
     , "company_copyright_works_list" -> "0" //作品著作权
     , "company_holder_add" -> "0" //股东新增
     , "company_holder_deleted" -> "1" //股东移除
-    , "company" -> "0" //工商信息
+    , "increase_registered_capital_info" -> "0" //增资记录
     , "auction_tracking_list" -> "0" //司法拍卖
   )
 
@@ -65,7 +65,7 @@ trait CompanyMonitorHandle extends Logging {
   //维度映射
   private val table_type_map = Map(
     "bankruptcy_open_case" -> "1" //BANKRUPTCY_OPEN_CASE//HBase
-    , "company" -> "2" //COMPANY//HBase
+    , "increase_registered_capital_info" -> "2" //INCREASE_REGISTERED_CAPITAL_INFO//HBase
     , "company_bid_list" -> "3" //COMPANY_BID_LIST//HBase
     , "company_copyright_reg_list" -> "4" //COMPANY_COPYRIGHT_REG_LIST//HBase
     , "company_copyright_works_list" -> "5" //COMPANY_COPYRIGHT_WORKS_LIST//HBase
@@ -90,7 +90,7 @@ trait CompanyMonitorHandle extends Logging {
   //类别
   private val type_map = Map(
     "bankruptcy_open_case" -> "1" //新增破产公告
-    , "company" -> "2" //注册资本上升
+    , "increase_registered_capital_info" -> "2" //注册资本上升
     , "company_bid_list" -> "3" //新增招标信息
     , "company_copyright_reg_list" -> "4" //软件著作权
     , "company_copyright_works_list" -> "5" //作品著作权

src/main/scala/com/winhc/bigdata/spark/jobs/monitor/tables/auction_tracking_list.scala

@@ -15,9 +15,11 @@ case class auction_tracking_list() extends CompanyMonitorHandle {
    * @return
    */
   override protected def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String =
-    s"""标题：${new_map("title")}
-       |起拍价：${new_map("applicant")}
-       |拍卖时间：${new_map("public_date")}""".stripMargin
+    s"""标题：${new_map("auction_title")}
+       |起拍价：${new_map("initial_price")}
+       |拍卖时间：${new_map("end_time")}""".stripMargin
 
 
+  //override def org_type(): Seq[String] = Seq("insert","update")
+
 }

src/main/scala/com/winhc/bigdata/spark/jobs/monitor/tables/increase_registered_capital_info.scala

@@ -0,0 +1,23 @@
+package com.winhc.bigdata.spark.jobs.monitor.tables
+
+import com.winhc.bigdata.spark.jobs.monitor.CompanyMonitorHandle
+
+/**
+ * @Date: 2020/12/14
+ * @Description: 增资记录
+ */
+case class increase_registered_capital_info() extends CompanyMonitorHandle {
+  /**
+   * 信息描述
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String =
+    s"""变更后资本：${new_map("content_after")}
+       |变更前资本：${new_map("content_before")}
+       |变更时间：${new_map("change_time")}""".stripMargin
+
+
+}