添加环保处罚企业动态

src/main/scala/com/winhc/bigdata/spark/jobs/chance/ChangeExtract.scala

@@ -204,6 +204,7 @@ object ChangeExtract {
           |winhc_eci_dev company_bid_list rowkey 20200717 title
           |winhc_eci_dev company_land_transfer rowkey 20200717 num,location
           |winhc_eci_dev company_employment rowkey 20200717 source
+          |winhc_eci_dev company_env_punishment rowkey 20200717 punish_number
           |""".stripMargin.replace("20200717", ds)
       for (r <- rows.split("\r\n")) {
         if (StringUtils.isNotEmpty(r)) {

src/main/scala/com/winhc/bigdata/spark/jobs/chance/CompanyChangeHandle.scala

@@ -198,4 +198,14 @@ case class company_land_transfer(equCols: Seq[String]) extends CompanyChangeHand
   override def getLabel(oldMap: Map[String, String], newMap: Map[String, String]): String = ChangeExtractUtils.getTags(newMap, "土地转让", Array("merchandise_time", "user_pre", "user_now", "location", "area", "merchandise_price", "aministrative_area"))
 
   override def getBizTime(newMap: Map[String, String]): String = newMap("merchandise_time")
-}
+}
+//环保处罚
+case class company_env_punishment(equCols:Seq[String])extends CompanyChangeHandle {
+  override def getUpdateTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("punish_number"), s"${newMap("title")}环保处罚信息发生变更")
+
+  override def getInsertTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("punish_number"), s"新增${newMap("punish_number")}环保处罚信息")
+
+  override def getLabel(oldMap: Map[String, String], newMap: Map[String, String]): String = ChangeExtractUtils.getTags(newMap, "环保处罚", Array("name", "department", "punish_number", "punish_basis", "law_break", "reason", "content", "deleted"))
+
+  override def getBizTime(newMap: Map[String, String]): String = newMap("publish_time")
+}