|
@@ -8,7 +8,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
|
|
|
* @Description TODO
|
|
|
*/
|
|
|
//环保处罚
|
|
|
-case class company_env_punishment(equCols:Seq[String])extends CompanyDynamicHandle {
|
|
|
+case class company_env_punishment()extends CompanyDynamicHandle {
|
|
|
/**
|
|
|
* 信息描述
|
|
|
*
|
|
@@ -16,7 +16,7 @@ case class company_env_punishment(equCols:Seq[String])extends CompanyDynamicHand
|
|
|
* @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 = new_map("punish_number")
|
|
|
|
|
|
/**
|
|
|
* 变更内容
|
|
@@ -25,7 +25,7 @@ case class company_env_punishment(equCols:Seq[String])extends CompanyDynamicHand
|
|
|
* @param new_map
|
|
|
* @return
|
|
|
*/
|
|
|
- override def get_change_content(old_map: Map[String, String], new_map: Map[String, String]): String = new_map("label")
|
|
|
+ override def get_change_content(old_map: Map[String, String], new_map: Map[String, String]): String = new_map("content")
|
|
|
|
|
|
/**
|
|
|
* 变更时间
|