feat: 企业动态

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

@@ -0,0 +1,24 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_abnormal_info() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    null
+  }
+
+  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))
+
+  }
+}
+

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

@@ -0,0 +1,36 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+
+import scala.collection.mutable
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_court_announcement() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    null
+  }
+
+  override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
+    try {
+      var list: mutable.Seq[AssociationEntityInfo] = mutable.Seq.empty
+      val defendant_info = new_data.getOrEmptyStr("litigant_info")
+      list = list ++ getEntity(defendant_info, "litigant_id", "name", NgCompanyRiskLevelType.Caution, "做为被告/被上诉人")
+
+      val plaintiff_info = new_data.getOrEmptyStr("plaintiff_info")
+      list = list ++ getEntity(plaintiff_info, "litigant_id", "name", NgCompanyRiskLevelType.Prompt, "做为原告/上诉人")
+      list
+    } catch {
+      case e: Exception => {
+        logError(e.getMessage, e)
+        Seq.empty
+      }
+    }
+  }
+}
+

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

@@ -0,0 +1,36 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+
+import scala.collection.mutable
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_court_open_announcement() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    null
+  }
+
+  override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
+    try {
+      var list: mutable.Seq[AssociationEntityInfo] = mutable.Seq.empty
+      val defendant_info = new_data.getOrEmptyStr("defendant_info")
+      list = list ++ getEntity(defendant_info, "litigant_id", "name", NgCompanyRiskLevelType.Caution, "做为被告/被上诉人")
+
+      val plaintiff_info = new_data.getOrEmptyStr("plaintiff_info")
+      list = list ++ getEntity(plaintiff_info, "litigant_id", "name", NgCompanyRiskLevelType.Prompt, "做为原告/上诉人")
+      list
+    } catch {
+      case e: Exception => {
+        logError(e.getMessage, e)
+        Seq.empty
+      }
+    }
+  }
+}
+

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

@@ -0,0 +1,36 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+
+import scala.collection.mutable
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_court_register() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    null
+  }
+
+  override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
+    try {
+      var list: mutable.Seq[AssociationEntityInfo] = mutable.Seq.empty
+      val defendant_info = new_data.getOrEmptyStr("defendant_info")
+      list = list ++ getEntity(defendant_info, "litigant_id", "name", NgCompanyRiskLevelType.Caution, "做为被告/被上诉人")
+
+      val plaintiff_info = new_data.getOrEmptyStr("plaintiff_info")
+      list = list ++ getEntity(plaintiff_info, "litigant_id", "name", NgCompanyRiskLevelType.Prompt, "做为原告/上诉人")
+      list
+    } catch {
+      case e: Exception => {
+        logError(e.getMessage, e)
+        Seq.empty
+      }
+    }
+  }
+}
+

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

@@ -0,0 +1,24 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_env_punishment() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    null
+  }
+
+  override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
+    val keyno = new_data.getOrEmptyStr("company_id")
+    val name = new_data.getOrEmptyStr("name")
+    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.Caution, null))
+
+  }
+}
+

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

@@ -0,0 +1,24 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_illegal_info() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    null
+  }
+
+  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))
+
+  }
+}
+

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

@@ -0,0 +1,24 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_own_tax() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    null
+  }
+
+  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))
+
+  }
+}
+

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

@@ -0,0 +1,24 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_punishment_info() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    null
+  }
+
+  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))
+
+  }
+}
+

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

@@ -0,0 +1,24 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_punishment_info_creditchina() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    null
+  }
+
+  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))
+
+  }
+}
+

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

@@ -0,0 +1,42 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+import scala.collection.mutable
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_send_announcement() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    Map(
+      "code" -> "301701"
+      , "description" -> "新增送达公告"
+    )
+  }
+
+  override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
+    try {
+      var list: mutable.Seq[AssociationEntityInfo] = mutable.Seq.empty
+      val defendant_info = new_data.getOrEmptyStr("defendant_info")
+      list = list ++ getEntity(defendant_info, "litigant_id", "name", NgCompanyRiskLevelType.Caution, "做为被告/被上诉人")
+
+      val plaintiff_info = new_data.getOrEmptyStr("plaintiff_info")
+      list = list ++ getEntity(plaintiff_info, "litigant_id", "name", NgCompanyRiskLevelType.Prompt, "做为原告/上诉人")
+      list
+    } catch {
+      case e: Exception => {
+        logError(e.getMessage, e)
+        Seq.empty
+      }
+    }
+  }
+
+
+}
+

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

@@ -0,0 +1,27 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class company_tax_contravention() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    Map(
+      "code" -> "301801"
+      , "description" -> "新增询价评估"
+    )
+  }
+
+  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))
+  }
+}
+

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

@@ -0,0 +1,27 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.ng.dynamic.utils.DailyAggHandle
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/6/29 15:07
+ */
+case class zxr_evaluate_results() extends DailyAggHandle {
+  override def getDynamicInfo(): Map[String, String] = {
+    Map(
+      "code" -> "301901"
+      , "description" -> "新增询价评估"
+    )
+  }
+
+  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))
+  }
+}
+