Prechádzať zdrojové kódy

fix: 修复立案时间历史数据问题

许家凯 3 rokov pred
rodič
commit
380658adb7

+ 2 - 2
src/main/scala/com/winhc/bigdata/spark/ng/credit_punishment/udf/CreditPunishmentCaseAggUDF.scala

@@ -106,13 +106,13 @@ case class CreditPunishmentCaseAggUDF() extends UserDefinedAggregateFunction {
     buffer(2) = keyno +: buffer.getSeq[String](2)
     buffer(1) = card_num +: buffer.getSeq[String](1)
     buffer(15) = deleted +: buffer.getSeq[Long](15)
+    buffer(4) = getCaseCreateTime(buffer.getTimestamp(4), case_create_time)
+
     deleted match {
       //不计历史信息:
       case 0 => {
         buffer(0) = s"$tn$delimiter$rowkey" +: buffer.getSeq[String](0)
         buffer(3) = tn +: buffer.getSeq[String](3)
-        buffer(4) = getCaseCreateTime(buffer.getTimestamp(4), case_create_time)
-
 
         if (tn.equals("company_zxr")) {
           buffer(6) = buffer.getDouble(6) + getAmount(detail_data, "$.exec_money")