许家凯 преди 3 години
родител
ревизия
54f59992be
променени са 1 файла, в които са добавени 5 реда и са изтрити 6 реда
  1. 5 6
      src/main/scala/com/winhc/bigdata/spark/jobs/chance/table/company_bid_list.scala

+ 5 - 6
src/main/scala/com/winhc/bigdata/spark/jobs/chance/table/company_bid_list.scala

@@ -20,13 +20,12 @@ case class company_bid_list(equCols: Seq[String]) extends CompanyChangeHandle {
 
   override def getLabel(oldMap: Map[String, String], newMap: Map[String, String]): String = ChangeExtractUtils.getTags(newMap, "招投标", Array("publish_time", "title", "purchaser", "province", "abs"))
 
-  override def getBizTime(newMap: Map[String, String]): String = DateUtils.getNotNullStr(newMap("publish_time"),newMap("update_time"))
+  override def getBizTime(newMap: Map[String, String]): String = DateUtils.getNotNullStr(newMap("publish_time"), newMap("update_time"))
 
-  override def handle(rowkey: String, oldMap: Map[String, String], newMap: Map[String, String]): (String, String, String, Map[String, String], String, String, String, String, Map[String, String]) =
-  {
-    super.handle(rowkey, oldMap, newMap.map(m=>{
-      if(m._1=="title" && m._2.contains(",")){
-        m._1->m._2.replace(",","、")
+  override def handle(rowkey: String, oldMap: Map[String, String], newMap: Map[String, String]): (String, String, String, Map[String, String], String, String, String, String, Map[String, String]) = {
+    super.handle(rowkey, oldMap, newMap.map(m => {
+      if ("title".equals(m._1) && m._2.contains(",")) {
+        m._1 -> m._2.replace(",", "、")
       }
       else {
         m