feat:第二批动态

src/main/scala/com/winhc/bigdata/spark/ng/change/table/company_brief_cancel_announcement.scala

@@ -11,7 +11,7 @@ import scala.util.matching.Regex
 
 case class company_brief_cancel_announcement(equCols: Seq[String], is_inc: Boolean) extends NgCompanyChangeHandle {
 
-  override protected def getBizDate(newMap: Map[String, String]): String = is_inc ? DateUtils.getBizDate(newMap("update_time")) | DateUtils.getBizDate(get_announcement_start_date(newMap("publish_date")).orNull, newMap("update_time"))
+  override protected def getBizDate(newMap: Map[String, String]): String = is_inc ? DateUtils.getBizDate(newMap("update_time")) | DateUtils.getBizDate(get_announcement_start_date(newMap("announcement_term")).orNull, newMap("update_time"))
 
   private val p = "(?<start>[1-2]\\d{3}年[0-1][1-9]月[0-3]\\d日) - (?<end>[1-2]\\d{3}年[0-1][1-9]月[0-3]\\d日)".r
 

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/NgCompanyRiskLevelType.scala

@@ -11,4 +11,5 @@ object NgCompanyRiskLevelType extends Enum[String] {
   val Positive: NgCompanyRiskLevelType = "0" //利好信息
   val Prompt: NgCompanyRiskLevelType = "1" //提示信息
   val Caution: NgCompanyRiskLevelType = "2" //警示信息
+  val HighRisk: NgCompanyRiskLevelType = "3" //高风险
 }

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

@@ -0,0 +1,20 @@
+
+
+package com.winhc.bigdata.spark.ng.dynamic.handle
+
+import com.winhc.bigdata.spark.ng.dynamic.utils.{DailyAggHandle, SimpleDailyDynamic}
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/7/13 15:07
+ *        破产信息
+ */
+case class bankruptcy_open_case() extends DailyAggHandle with SimpleDailyDynamic {
+
+
+  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)
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_brief_cancel_announcement.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.utils.{DailyAggHandle, SimpleDailyDynamic}
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/7/13 15:07
+ *        简易注销
+ */
+case class company_brief_cancel_announcement() 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.Caution, null))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_dishonest_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.utils.{DailyAggHandle, SimpleDailyDynamic}
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/7/13 15:07
+ *        失信
+ */
+case class company_dishonest_info() extends DailyAggHandle with SimpleDailyDynamic {
+
+
+  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))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_land_announcement.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.utils.{DailyAggHandle, SimpleDailyDynamic}
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/7/13 15:07
+ *        购地信息
+ */
+case class company_land_announcement() 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("application_name")
+    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.Caution, null))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_land_publicity.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.utils.{DailyAggHandle, SimpleDailyDynamic}
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/7/13 15:07
+ *        地块公示
+ */
+case class company_land_publicity() 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("application_name")
+    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.Positive, null))
+
+  }
+}
+

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

@@ -0,0 +1,29 @@
+
+
+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/7/13 15:07
+ *        土地转让
+ */
+case class company_land_transfer() extends DailyAggHandle with SimpleDailyDynamic {
+
+
+  override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
+    Seq(
+      AssociationEntityInfo(keyno = new_data.getOrEmptyStr("pre_keyno")
+        , name = new_data.getOrEmptyStr("user_pre")
+        , risk_level = NgCompanyRiskLevelType.Prompt, "原土地使用权人")
+      , AssociationEntityInfo(keyno = new_data.getOrEmptyStr("now_keyno")
+        , name = new_data.getOrEmptyStr("user_now")
+        , risk_level = NgCompanyRiskLevelType.Positive, "现土地使用权人")
+    )
+
+  }
+}
+

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

@@ -10,14 +10,13 @@ import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskL
  * @author: XuJiakai
  * @date: 2021/6/29 15:07
  */
-case class company_license_creditchina() extends DailyAggHandle  with SimpleDailyDynamic{
+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_public_announcement.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.utils.{DailyAggHandle, SimpleDailyDynamic}
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/7/13 15:07
+ *        公示催告
+ */
+case class company_public_announcement() 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("apply_name")
+    Seq(AssociationEntityInfo(keyno = keyno, name = name, risk_level = NgCompanyRiskLevelType.Prompt, null))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_zxr.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.utils.{DailyAggHandle, SimpleDailyDynamic}
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/7/13 15:07
+ *        被执
+ */
+case class company_zxr() extends DailyAggHandle  with SimpleDailyDynamic{
+
+
+  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))
+
+  }
+}
+

src/main/scala/com/winhc/bigdata/spark/ng/dynamic/handle/company_zxr_final_case.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.utils.{DailyAggHandle, SimpleDailyDynamic}
+import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
+
+/**
+ * @author: XuJiakai
+ * @date: 2021/7/13 15:07
+ *        终本
+ */
+case class company_zxr_final_case() extends DailyAggHandle  with SimpleDailyDynamic{
+
+
+  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))
+
+  }
+}
+

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

@@ -0,0 +1,30 @@
+
+
+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/7/13 15:07
+ *        限高
+ */
+case class company_zxr_restrict() extends DailyAggHandle with SimpleDailyDynamic {
+
+
+  override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
+
+    Seq(
+      AssociationEntityInfo(keyno = new_data.getOrEmptyStr("company_id")
+        , name = new_data.getOrEmptyStr("company_name")
+        , risk_level = NgCompanyRiskLevelType.Caution, null)
+      ,AssociationEntityInfo(keyno = new_data.getOrEmptyStr("pid")
+        , name = new_data.getOrEmptyStr("person_name")
+        , risk_level = NgCompanyRiskLevelType.Caution, null)
+    )
+
+  }
+}
+

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

@@ -0,0 +1,30 @@
+
+
+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/7/13 15:07
+ *        限制出镜
+ */
+case class restrictions_on_exit() extends DailyAggHandle  with SimpleDailyDynamic{
+
+
+  override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
+
+    Seq(
+      AssociationEntityInfo(keyno = new_data.getOrEmptyStr("limited_person_pid")
+        , name = new_data.getOrEmptyStr("limited_person")
+        , risk_level = NgCompanyRiskLevelType.Caution, null)
+      ,AssociationEntityInfo(keyno = new_data.getOrEmptyStr("executed_person_keyno")
+        , name = new_data.getOrEmptyStr("executed_person_name")
+        , risk_level = NgCompanyRiskLevelType.Caution, null)
+    )
+
+  }
+}
+

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

@@ -13,7 +13,7 @@ trait ComplexDailyDynamic extends Logging {
       createDynamicInfo(this.getClass.getSimpleName, new_data)
     }
     catch {
-      case e: Exception => logError(e.getMessage, e)
+      case e: Exception => logError("xjk:"+e.getMessage, e)
         (null, Map.empty)
     }
   }

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

@@ -247,5 +247,187 @@ object DynamicDimConfiguration {
     )
 
 
+
+
+
+    , "bankruptcy_open_case" -> Map(
+      "code" -> Map(
+        "insert" -> "303101"
+      ),
+      "sample" -> true,
+      "name" -> "破产信息",
+      "list_field" -> Map(
+        "case_no" -> Map(),
+        "respondent_info" -> Map(),
+        "applicant_info" -> Map(),
+        "public_date" -> Map()
+      )
+    )
+
+
+    , "company_brief_cancel_announcement" -> Map(
+      "code" -> Map(
+        "insert" -> "303201"
+      ),
+      "sample" -> true,
+      "name" -> "简易注销",
+      "list_field" -> Map(
+        "reg_authority" -> Map(),
+        "announcement_term" -> Map()
+      )
+    )
+
+
+    , "company_dishonest_info" -> Map(
+      "code" -> Map(
+        "insert" -> "303301"
+      ),
+      "sample" -> true,
+      "name" -> "失信被执行人",
+      "list_field" -> Map(
+        "case_no" -> Map(),
+        "performance" -> Map(),
+        "pub_date" -> Map()
+      )
+    )
+
+
+    , "company_public_announcement" -> Map(
+      "code" -> Map(
+        "insert" -> "303401"
+      ),
+      "sample" -> true,
+      "name" -> "公示催告",
+      "list_field" -> Map(
+        "bill_num" -> Map(),
+        "apply_name" -> Map(),
+        "company_id" -> Map(),
+        "bill_amt" -> Map(),
+        "publish_date" -> Map()
+      )
+    )
+
+
+    , "company_zxr" -> Map(
+      "code" -> Map(
+        "insert" -> "303501"
+      ),
+      "sample" -> true,
+      "name" -> "被执行人",
+      "list_field" -> Map(
+        "case_no" -> Map(),
+        "exec_money" -> Map(),
+        "case_create_time" -> Map()
+      )
+    )
+
+
+    , "company_zxr_final_case" -> Map(
+      "code" -> Map(
+        "insert" -> "303601"
+      ),
+      "sample" -> true,
+      "name" -> "终本案件",
+      "list_field" -> Map(
+        "case_no" -> Map(),
+        "court_name" -> Map(),
+        "case_create_time" -> Map(),
+        "case_final_time" -> Map()
+      )
+    )
+
+
+    , "company_zxr_restrict" -> Map(
+      "code" -> Map(
+        "insert" -> "303701"
+      ),
+      "sample" -> true,
+      "name" -> "限制高消费",
+      "list_field" -> Map(
+        "case_no" -> Map(),
+        "company_name" -> Map(),
+        "company_id" -> Map(),
+        "person_name" -> Map(),
+        "pid" -> Map(),
+        "case_create_time" -> Map()
+      )
+    )
+
+
+    , "restrictions_on_exit" -> Map(
+      "code" -> Map(
+        "insert" -> "303801"
+      ),
+      "sample" -> true,
+      "name" -> "限制出境",
+      "list_field" -> Map(
+        "case_no" -> Map(),
+        "limited_person" -> Map(),
+        "limited_person_pid" -> Map(),
+        "executed_person_name" -> Map(),
+        "executed_person_keyno" -> Map(),
+        "court" -> Map(),
+        "publish_time" -> Map()
+      )
+    )
+
+
+    , "company_land_announcement" -> Map(
+      "code" -> Map(
+        "insert" -> "201501"
+      ),
+      "sample" -> true,
+      "name" -> "购地信息",
+      "list_field" -> Map(
+        "project_loc" -> Map(),
+        "area" -> Map(),
+        "tran_price" -> Map(),
+        "use_type" -> Map(),
+        "application_name" -> Map(),
+        "company_id" -> Map(),
+        "contract_date" -> Map()
+      )
+    )
+
+
+    , "company_land_publicity" -> Map(
+      "code" -> Map(
+        "insert" -> "201601"
+      ),
+      "sample" -> true,
+      "name" -> "地块公示",
+      "list_field" -> Map(
+        "location" -> Map(),
+        "area" -> Map(),
+        "final_price" -> Map(),
+        "use_for" -> Map(),
+        "application_name" -> Map(),
+        "company_id" -> Map(),
+        "publication_date" -> Map()
+      )
+    )
+
+
+    , "company_land_transfer" -> Map(
+      "code" -> Map(
+        "insert" -> "201701"
+      ),
+      "sample" -> true,
+      "name" -> "土地转让",
+      "list_field" -> Map(
+        "location" -> Map(),
+        "area" -> Map(),
+        "merchandise_price" -> Map(),
+        "user_pre" -> Map(),
+        "pre_keyno" -> Map(),
+        "user_now" -> Map(),
+        "now_keyno" -> Map(),
+        "merchandise_time" -> Map()
+      )
+    )
+
+
+
+
   )
 }

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

@@ -12,7 +12,7 @@ trait SimpleDailyDynamic extends Logging {
     try {
       createSimpleDynamicInfo(this.getClass.getSimpleName, new_data)
     } catch {
-      case e: Exception => logError(e.getMessage, e)
+      case e: Exception => logError("xjk:"+e.getMessage, e)
       (null, Map.empty)
     }
   }