Browse Source

4个维度动态列表内容格式调整

晏永年 4 years ago
parent
commit
3156021fad

+ 7 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_env_punishment.scala

@@ -16,7 +16,13 @@ case class company_env_punishment()extends CompanyDynamicHandle {
    * @param new_map
    * @return
    */
-  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = new_map("punish_number")
+  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = {
+    s"""决定文书号:${new_map("punish_number")}
+       |处罚单位:${new_map("department")}
+       |处罚时间:${new_map("publish_time")}
+       |违反法律:${new_map("law_break")}
+       |执行情况:${new_map("execution")}""".stripMargin
+  }
 
   /**
    * 变更内容

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

@@ -16,7 +16,11 @@ case class company_land_announcement() extends CompanyDynamicHandle {
    * @param new_map
    * @return
    */
-  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = new_map("project_name")
+  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = {
+    s"""项目名称:${new_map("project_name")}
+       |项目位置:${new_map("project_loc")}
+       |合同签订日期:${new_map("contract_date")}""".stripMargin
+  }
 
   /**
    * 变更内容

+ 7 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_land_publicity.scala

@@ -16,7 +16,13 @@ case class company_land_publicity() extends CompanyDynamicHandle {
    * @param new_map
    * @return
    */
-  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = new_map("title")
+  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = {
+    s"""标题:${new_map("title")}
+       |项目名称:${new_map("project_name")}
+       |地块位置:${new_map("location")}
+       |公布日期:${new_map("publication_date")}""".stripMargin
+
+  }
 
   /**
    * 变更内容

+ 5 - 2
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_liquidating_info.scala

@@ -16,7 +16,10 @@ case class company_liquidating_info() extends CompanyDynamicHandle {
    * @param new_map
    * @return
    */
-  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = "清算信息"
+  override def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = {
+    s"""清算组负责人:${new_map("manager")}
+       |清算成员:${new_map("member")}""".stripMargin
+  }
 
   /**
    * 变更内容
@@ -26,7 +29,7 @@ case class company_liquidating_info() extends CompanyDynamicHandle {
    * @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")}"
+    s"清算信息"
   }
 
   /**