Quellcode durchsuchen

fix(ng.dynamic): 修复风险等级错误

JimZhang vor 3 Jahren
Ursprung
Commit
b86ff07e58

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/bankruptcy_open_case.scala

@@ -14,7 +14,7 @@ case class bankruptcy_open_case(is_inc: Boolean) extends DailyAggHandle with Com
 
 
   override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
-    getEntity(new_data("respondent_info"), id_key = "litigant_id", name_key = "name", NgCompanyRiskLevelType.Caution, null)
+    getEntity(new_data("respondent_info"), id_key = "litigant_id", name_key = "name", NgCompanyRiskLevelType.HighRisk, null)
   }
 }
 

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_brief_cancel_announcement.scala

@@ -17,7 +17,7 @@ case class company_brief_cancel_announcement(is_inc:Boolean) extends DailyAggHan
   override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
     val keyno = new_data.getOrEmptyStr("company_id")
     val name = new_data.getOrEmptyStr("company_name")
-    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.Caution, null))
+    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.HighRisk, null))
 
   }
 }

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_dishonest_info.scala

@@ -17,7 +17,7 @@ case class company_dishonest_info(is_inc:Boolean) extends DailyAggHandle with Si
   override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
     val keyno = new_data.getOrEmptyStr("keyno")
     val name = new_data.getOrEmptyStr("name")
-    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.Caution, null))
+    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.HighRisk, null))
 
   }
 }

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_illegal_info.scala

@@ -15,7 +15,7 @@ case class company_illegal_info(is_inc:Boolean) extends DailyAggHandle  with Sim
   override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
     val keyno = new_data.getOrEmptyStr("company_id")
     val name = new_data.getOrEmptyStr("company_name")
-    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.Caution, null))
+    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.HighRisk, null))
 
   }
 }

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_own_tax.scala

@@ -15,7 +15,7 @@ case class company_own_tax(is_inc:Boolean) extends DailyAggHandle  with SimpleDa
   override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
     val keyno = new_data.getOrEmptyStr("company_id")
     val name = new_data.getOrEmptyStr("company_name")
-    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.Caution, null))
+    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.HighRisk, null))
 
   }
 }

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_zxr.scala

@@ -17,7 +17,7 @@ case class company_zxr(is_inc:Boolean) extends DailyAggHandle  with SimpleDailyD
   override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
     val keyno = new_data.getOrEmptyStr("keyno")
     val name = new_data.getOrEmptyStr("name")
-    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.Caution, null))
+    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.HighRisk, null))
 
   }
 }

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_zxr_final_case.scala

@@ -17,7 +17,7 @@ case class company_zxr_final_case(is_inc:Boolean) extends DailyAggHandle  with S
   override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
     val keyno = new_data.getOrEmptyStr("keyno")
     val name = new_data.getOrEmptyStr("name")
-    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.Caution, null))
+    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.HighRisk, null))
 
   }
 }

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

@@ -19,10 +19,10 @@ case class company_zxr_restrict(is_inc:Boolean) extends DailyAggHandle with Simp
     Seq(
       AssociationEntityInfo(keyno = new_data.getOrEmptyStr("company_id")
         , name = new_data.getOrEmptyStr("company_name")
-        , risk_level = NgCompanyRiskLevelType.Caution, null)
+        , risk_level = NgCompanyRiskLevelType.HighRisk, null)
       ,AssociationEntityInfo(keyno = new_data.getOrEmptyStr("pid")
         , name = new_data.getOrEmptyStr("person_name")
-        , risk_level = NgCompanyRiskLevelType.Caution, null)
+        , risk_level = NgCompanyRiskLevelType.HighRisk, null)
     )
 
   }

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

@@ -19,10 +19,10 @@ case class restrictions_on_exit(is_inc:Boolean) extends DailyAggHandle  with Sim
     Seq(
       AssociationEntityInfo(keyno = new_data.getOrEmptyStr("limited_person_pid")
         , name = new_data.getOrEmptyStr("limited_person")
-        , risk_level = NgCompanyRiskLevelType.Caution, null)
+        , risk_level = NgCompanyRiskLevelType.HighRisk, null)
       ,AssociationEntityInfo(keyno = new_data.getOrEmptyStr("executed_person_keyno")
         , name = new_data.getOrEmptyStr("executed_person_name")
-        , risk_level = NgCompanyRiskLevelType.Caution, null)
+        , risk_level = NgCompanyRiskLevelType.HighRisk, null)
     )
 
   }