Browse Source

fix: 破产公告

许家凯 4 years ago
parent
commit
23c1caf68d

+ 2 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/CompanyDynamicHandle.scala

@@ -117,7 +117,8 @@ trait CompanyDynamicHandle {
 
   //风险等级映射
   private val info_risk_level_map = Map(
-    "company_dishonest_info" -> "4" //企业失信被执情况
+    "bankruptcy_open_case" -> "4" //破产公告
+    , "company_dishonest_info" -> "4" //企业失信被执情况
     , "" -> "4" //股东失信被执情况
     , "" -> "4" //股权冻结
     , "" -> "4" //司法拍卖

+ 5 - 31
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/bankruptcy_open_case.scala

@@ -16,36 +16,10 @@ case class bankruptcy_open_case() extends CompanyDynamicHandle {
    * @param new_map
    * @return
    */
-  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = new_map("case_no")
-
-  /**
-   * 变更内容
-   *
-   * @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("case_no")}\n
-       |被申请人:${new_map("respondent")}\n
-       |申请人:${new_map("applicant")}\n
-       |公开日期:${new_map("public_date")}\n""".stripMargin
+  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = {
+    s"""案号:${new_map("case_no")}
+       |被申请人:${new_map("respondent")}
+       |申请人:${new_map("applicant")}
+       |公开日期:${new_map("public_date")}""".stripMargin
   }
-
-  /**
-   * 变更时间
-   *
-   * @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 = "高风险"
 }