Merge remote-tracking branch 'origin/master'

src/main/scala/com/winhc/bigdata/spark/jobs/chance/table/company_bid_list.scala

@@ -21,4 +21,16 @@ 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 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._2.contains(",")){
+        m._1->m._2.replace(",","、")
+      }
+      else {
+        m
+      }
+    }))
+  }
 }

src/main/scala/com/winhc/bigdata/spark/jobs/judicial/JudicialCaseRelationPreNew.scala

@@ -153,7 +153,7 @@ case class JudicialCaseRelationPreNew(s: SparkSession, project: String, ds: Stri
          |        ,regexp_replace(bg_name,'\n',',') as bg_name
          |        ,judge_date as date
          |        ,case_id as detail_id
-         |        ,case_amt
+         |        ,case_amt*10000
          |FROM    (
          |            SELECT  rowkey,max(judicase_id) judicase_id
          |            FROM $project.ads_judicial_case_relation_graph WHERE flag = 'wenshu_detail'