Browse Source

fix(ng.dynamic): 询价评估结果金额解析为json

JimZhang 3 years ago
parent
commit
0420225e38

+ 2 - 2
src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/zxr_evaluate_results.scala

@@ -3,14 +3,14 @@
 package com.winhc.bigdata.spark.ng.dynamic.handle
 
 import com.winhc.bigdata.spark.implicits.MapHelper._
-import com.winhc.bigdata.spark.ng.dynamic.utils.{DailyAggHandle, SimpleDailyDynamic}
+import com.winhc.bigdata.spark.ng.dynamic.utils.{ComplexDailyDynamic, DailyAggHandle, SimpleDailyDynamic}
 import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
 
 /**
  * @author: XuJiakai
  * @date: 2021/6/29 15:07
  */
-case class zxr_evaluate_results(is_inc:Boolean) extends DailyAggHandle   with SimpleDailyDynamic{
+case class zxr_evaluate_results(is_inc:Boolean) extends DailyAggHandle   with ComplexDailyDynamic{
   override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
     val keyno = new_data.getOrEmptyStr("keyno")
     val name = new_data.getOrEmptyStr("name")

+ 2 - 2
src/main/scala/com/winhc/bigdata/spark/ng/dynamic/utils/DynamicDimConfiguration.scala

@@ -90,7 +90,7 @@ object DynamicDimConfiguration {
       "sample" -> true,
       "name" -> "行政处罚",
       "list_field" -> Map(
-        "punish_number" -> Map(),
+        "" -> Map(),
         "content" -> Map(),
         "department_name" -> Map(),
         "decision_date" -> Map()
@@ -269,7 +269,7 @@ object DynamicDimConfiguration {
       "list_field" -> Map(
         "keyno" -> Map()
         , "name" -> Map()
-        , "money" -> Map()
+        , "money" -> Map("type" -> "json")
         , "asset_type" -> Map()
         , "reference_price" -> Map()
         , "case_no" -> Map()