feat: 主要成员企业动态

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

@@ -178,6 +178,7 @@ object CompanyDynamic {
   private val startArgs = Seq(
     Args(tableName = "company_abnormal_info", bName = 0)
     , Args(tableName = "company_equity_info")
+    , Args(tableName = "company_staff", bName = 0)
   )
 
   private case class Args(project: String = "winhc_eci_dev"

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

@@ -42,6 +42,8 @@ trait CompanyDynamicHandle {
     , "" -> "investor_equity_change" //大股东变更
     , "" -> "actual_controller_change" //实际控制人变更
     , "" -> "court_notice" //开庭公告
+
+    , "company_staff" -> "company_staff" //主要成员
   )
 
   private val table_2_info_type = Map(
@@ -79,7 +81,7 @@ trait CompanyDynamicHandle {
     , "" -> "27" // 新闻信息
     , "" -> "28" // 股东信息
     , "" -> "29" // 最终受益人
-    , "" -> "30" // 主要成员
+    , "company_staff" -> "30" // 主要成员
     , "" -> "31" // 融资动态
     , "" -> "32" // 企业公告
     , "" -> "33" // 抽查检查

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

@@ -0,0 +1,38 @@
+package com.winhc.bigdata.spark.jobs.dynamic.tables
+
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
+
+/**
+ * @Author: XuJiakai
+ * @Date: 2020/8/5 19:26
+ * @Description: 主要成员
+ */
+case class company_staff() extends CompanyDynamicHandle {
+  /**
+   * 信息描述
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = "新增一位主要成员"
+
+  /**
+   * 变更内容
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_change_content(old_map: Map[String, String], new_map: Map[String, String], cname: String): String = new_map.toJson(Seq("hid","staff_type->职位"))
+
+  /**
+   * 风险等级
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = "1"
+}