feat: 经营类企业动态

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_check_info.scala

@@ -0,0 +1,23 @@
+
+
+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.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_check_info() extends DailyAggHandle  with SimpleDailyDynamic{
+
+
+  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.Prompt, null))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_double_random_check_info.scala

@@ -0,0 +1,23 @@
+
+
+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.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_double_random_check_info() extends DailyAggHandle  with SimpleDailyDynamic{
+
+
+  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.Prompt, null))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_finance.scala

@@ -0,0 +1,23 @@
+
+
+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.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_finance() extends DailyAggHandle  with SimpleDailyDynamic{
+
+
+  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.Positive, null))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_license.scala

@@ -0,0 +1,23 @@
+
+
+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.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_license() extends DailyAggHandle  with SimpleDailyDynamic{
+
+
+  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.Prompt, null))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_license_creditchina.scala

@@ -0,0 +1,23 @@
+
+
+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.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_license_creditchina() extends DailyAggHandle  with SimpleDailyDynamic{
+
+
+  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.Prompt, null))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_license_entpub.scala

@@ -0,0 +1,23 @@
+
+
+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.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_license_entpub() extends DailyAggHandle  with SimpleDailyDynamic{
+
+
+  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.Prompt, null))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/utils/CollapseKeyArgs.scala

@@ -10,6 +10,7 @@ object CollapseKeyArgs {
 
   val map = Map(
     "company_punishment_info" -> Seq("company_punishment_info", "company_punishment_info_creditchina")
+    ,"company_license" -> Seq("company_license", "company_license_entpub", "company_license_creditchina")
   )
 
   private val m = map.flatMap(r => r._2.map((_ -> r._1))).filter(r => !r._2.equals(r._1))

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

@@ -43,7 +43,9 @@ object DynamicDimConfiguration {
       "list_field" -> Map(
         "start_date" -> Map(),
         "case_no" -> Map(),
-        "case_reason" -> Map()
+        "case_reason" -> Map(),
+        "defendant_info" -> Map(),
+        "plaintiff_info" -> Map()
       )
     ),
     "company_env_punishment" -> Map(
@@ -145,12 +147,11 @@ object DynamicDimConfiguration {
         ),
         "case_no" -> Map()
       )
-    ),
-    "company_punishment_info_creditchina" -> Map(
+    )
+    , "company_punishment_info_creditchina" -> Map(
       "code" -> Map(
         "insert" -> "302601"
       ),
-
       "name" -> "行政处罚信用中国",
       "list_field" -> Map(
         "punish_number" -> Map(),
@@ -159,6 +160,86 @@ object DynamicDimConfiguration {
         "decision_date" -> Map()
       )
     )
-  )
 
+    , "company_check_info" -> Map(
+      "code" -> Map(
+        "insert" -> "201101"
+      ),
+      "name" -> "抽查检查",
+      "list_field" -> Map(
+        "check_result" -> Map()
+        , "check_date" -> Map()
+      )
+    )
+
+    , "company_double_random_check_info" -> Map(
+      "code" -> Map(
+        "insert" -> "201201"
+      ),
+      "name" -> "双随机抽查",
+      "list_field" -> Map(
+        "check_task_num" -> Map()
+        , "check_task_name" -> Map()
+        , "check_department" -> Map()
+        , "check_date" -> Map()
+      )
+    )
+
+    , "company_finance" -> Map(
+      "code" -> Map(
+        "insert" -> "201301"
+      ),
+      "name" -> "融资信息",
+      "list_field" -> Map(
+        "inverstors" -> Map(),
+        "round" -> Map(),
+        "money" -> Map()
+      )
+    )
+
+
+    , "company_license" -> Map(
+      "code" -> Map(
+        "insert" -> "201401"
+      ),
+      "name" -> "行政许可",
+      "list_field" -> Map(
+        "license_number" -> Map(),
+        "start_date" -> Map(),
+        "end_date" -> Map(),
+        "department" -> Map(),
+        "scope" -> Map()
+      )
+    )
+
+    , "company_license_creditchina" -> Map(
+      "code" -> Map(
+        "insert" -> "201401"
+      ),
+      "name" -> "行政许可",
+      "list_field" -> Map(
+        "license_number" -> Map(),
+        "start_date" -> Map("from" -> "decision_date"),
+        "end_date" -> Map(),
+        "department" -> Map(),
+        "scope" -> Map("from" -> "licence_content")
+      )
+    )
+
+    , "company_license_entpub" -> Map(
+      "code" -> Map(
+        "insert" -> "201401"
+      ),
+      "name" -> "行政许可",
+      "list_field" -> Map(
+        "license_number" -> Map(),
+        "start_date" -> Map(),
+        "end_date" -> Map(),
+        "department" -> Map(),
+        "scope" -> Map()
+      )
+    )
+
+
+  )
 }