清算信息维度企业动态

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

@@ -313,6 +313,7 @@ object ChangeExtract {
     , Args(tableName = "company_annual_report_out_guarantee", primaryFields = "id")//年报-对外担保
     , Args(tableName = "company_zxr_restrict", primaryFields = "status")//限制消费令，发现最新状态
     , Args(tableName = "company_brief_cancel_announcement", primaryFields = "credit_code")//简易注销
+    , Args(tableName = "company_liquidating_info", primaryFields = "id")//清算信息
 
     , Args(tableName = "company_zxr_final_case", primaryFields = "identity_num")//终本案件
     , Args(tableName = "company_license_creditchina", primaryFields = "licence_content")//行政许可-信用中国

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

@@ -0,0 +1,24 @@
+
+package com.winhc.bigdata.spark.jobs.chance.table
+
+import com.winhc.bigdata.spark.jobs.chance.CompanyChangeHandle
+import com.winhc.bigdata.spark.utils.ChangeExtractUtils
+
+/**
+ * @Author: Yan Yongnian
+ * @Date: 2020/8/19
+ * @Description:
+ */
+
+
+//清算信息
+
+case class company_liquidating_info(equCols: Seq[String]) extends CompanyChangeHandle {
+  override def getUpdateTitle(newMap: Map[String, String]): String = "清算信息发生变更"
+
+  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("manager", "member"))
+
+  override def getBizTime(newMap: Map[String, String]): String = newMap("update_time")
+}

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

@@ -201,6 +201,7 @@ object CompanyDynamic {
     , Args(tableName = "company_annual_report_out_guarantee", bName = 1)
     , Args(tableName = "company_zxr_restrict", bName = 1)
     , Args(tableName = "company_brief_cancel_announcement", bName = 1)
+    , Args(tableName = "company_liquidating_info", bName = 1)
 
     , Args(tableName = "company_zxr_final_case", bName = 1)//终本案件
     , Args(tableName = "company_license_creditchina", bName = 1)//行政许可-信用中国

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

@@ -38,7 +38,7 @@ trait CompanyDynamicHandle {
     , "company_own_tax" -> "tax_owenotice" //欠税公告
     , "company_judicial_sale_combine_list" -> "judicial" //司法拍卖
     , "company_employment" -> "recruit" //招聘信息
-    , "" -> "liquidation_information" //清算信息
+    , "company_liquidating_info" -> "company_liquidating_info" //清算信息
     , "" -> "investor_equity_change" //大股东变更
     , "" -> "actual_controller_change" //实际控制人变更
     , "company_court_open_announcement_list" -> "court_notice" //开庭公告
@@ -87,7 +87,7 @@ trait CompanyDynamicHandle {
     , "company_own_tax" -> "20" // 欠税公告
     , "company_tax_contravention" -> "21" // 税收违法
     , "" -> "22" // 股权冻结
-    , "" -> "23" // 清算信息
+    , "company_liquidating_info" -> "23" // 清算信息
     , "" -> "24" // 大股东变更
     , "" -> "25" // 实际控制人变更
     , "company_court_open_announcement_list" -> "26" // 开庭公告
@@ -118,7 +118,7 @@ trait CompanyDynamicHandle {
     , "" -> "4" //股东失信被执情况
     , "" -> "4" //股权冻结
     , "" -> "4" //司法拍卖
-    , "" -> "4" //清算信息
+    , "company_liquidating_info" -> "4" //清算信息
     , "company_brief_cancel_announcement" -> "4" //简易注销
     , "" -> "4" //严重违法
     , "" -> "3" //裁判文书（被告）

src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_liquidating_info.scala

@@ -0,0 +1,48 @@
+package com.winhc.bigdata.spark.jobs.dynamic.tables
+
+import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
+
+/**
+ * @Author yyn
+ * @Date 2020/8/19
+ * @Description
+ */
+//清算信息
+case class company_liquidating_info() extends CompanyDynamicHandle {
+  /**
+   * 信息描述
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = "清算信息"
+
+  /**
+   * 变更内容
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override def get_change_content(old_map: Map[String, String], new_map: Map[String, String], cname: String = null): String = {
+    s"进行了清算，清算组负责人为${new_map("manager")},清算组成员为${new_map("member")}"
+  }
+
+  /**
+   * 变更时间
+   *
+   * @param new_map
+   * @return
+   */
+  //  override def get_change_time(new_map: Map[String, String]): String = new_map("biz_date")
+
+  /**
+   * 风险等级
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = "高风险信息"
+}