fix: 企业动态.司法拍卖

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

@@ -9,6 +9,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
  */
 case class company_judicial_sale_combine_list() extends CompanyDynamicHandle {
 
+  val fmt = new java.text.DecimalFormat("0.00")
 
   /**
    * 来源表的变更类型，insert or update
@@ -25,9 +26,9 @@ case class company_judicial_sale_combine_list() extends CompanyDynamicHandle {
    * @return
    */
   override protected def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = {
-
+    val b = new_map("initial_price").toDouble
     s"""标题：${new_map("title")}
-       |起拍价：${new_map("initial_price")}
+       |起拍价：${fmt.format(b)}
        |拍卖时间：${new_map("start_time")}""".stripMargin
   }
 
@@ -38,9 +39,9 @@ case class company_judicial_sale_combine_list() extends CompanyDynamicHandle {
    * @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(
-//    "source_id->address"
-//  ))
+  //  override protected def get_change_content(old_map: Map[String, String], new_map: Map[String, String], cname: String): String = new_map.toJson(Seq(
+  //    "source_id->address"
+  //  ))
 
   override protected def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = {
     "4"