Преглед на файлове

fix: 企业动态的失信人信息

许家凯 преди 4 години
родител
ревизия
f1e60dcfec
променени са 1 файла, в които са добавени 5 реда и са изтрити 1 реда
  1. 5 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_dishonest_info.scala

+ 5 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_dishonest_info.scala

@@ -15,7 +15,11 @@ case class company_dishonest_info() extends CompanyDynamicHandle {
    * @param new_map
    * @return
    */
-  override protected def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = s"新增1条企业失信信息:${new_map.getOrElse("court", "")}"
+  override protected def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String =
+    s"""失信人名称:${new_map("name")}
+       |案号:${new_map("case_no")}
+       |发布时间:${new_map("pub_date")}
+       |履行情况:${new_map("performance")}""".stripMargin
 
   /*
    * 变更内容