瀏覽代碼

bizdate格式化

xufei 4 年之前
父節點
當前提交
87c1379e96
共有 1 個文件被更改,包括 7 次插入1 次删除
  1. 7 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/CompanyDynamicHandle.scala

+ 7 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/CompanyDynamicHandle.scala

@@ -245,7 +245,13 @@ trait CompanyDynamicHandle {
    * @param new_map
    * @return
    */
-  protected def get_change_time(bizDate: String, new_map: Map[String, String]): String = bizDate
+  protected def get_change_time(bizDate: String, new_map: Map[String, String]): String = {
+    var res = bizDate
+    if(bizDate.length == 10){
+      res = res.concat(" 00:00:00")
+    }
+    res
+  }
 
   /**
    * 业务id