新增动态

src/main/scala/com/winhc/bigdata/spark/jobs/CalcIncrTotal.scala

@@ -42,6 +42,12 @@ object CalcIncrTotal {
   //  winhc_eci_dev company_double_random_check_result_info main_id,check_item,new_cid cid
 
   //  winhc_eci_dev company_judicial_sale_combine main_id,new_cid cids
+  //  winhc_eci_dev company_zxr_final_case new_cid,case_no cid
+
+  //  winhc_eci_dev company_license new_cid,license_number cid
+  //  winhc_eci_dev company_license_creditchina new_cid,licence_number cid
+  //  winhc_eci_dev company_license_entpub new_cid,license_number cid
+
 
   def main(args: Array[String]): Unit = {
 

src/main/scala/com/winhc/bigdata/spark/jobs/CompanyForCid.scala

@@ -24,6 +24,11 @@ object CompanyForCid {
 //  winhc_eci_dev company_tax_contravention taxpayer_number,case_info,new_cid
 //  winhc_eci_dev company_double_random_check_info check_task_num,new_cid
 //  winhc_eci_dev company_double_random_check_result_info main_id,check_item,new_cid
+//  winhc_eci_dev company_zxr_final_case case_no,new_cid
+
+//  winhc_eci_dev company_license license_number,new_cid
+//  winhc_eci_dev company_license_creditchina licence_number,new_cid
+//  winhc_eci_dev company_license_entpub license_number,new_cid
 
   def main(args: Array[String]): Unit = {
     val Array(space, sourceTable, cols) = args

src/main/scala/com/winhc/bigdata/spark/jobs/CompanyIncrForCid.scala

@@ -16,6 +16,10 @@ object CompanyIncrForCid {
   //winhc_eci_dev company_app_info icon_oss_path,brief,name,new_cid
   //winhc_eci_dev ads_company_tm app_date,tm_name,reg_no,new_cid
   //winhc_eci_dev company_wechat title,public_num,new_cid
+
+  //  winhc_eci_dev company_license license_number,new_cid
+  //  winhc_eci_dev company_license_creditchina licence_number,new_cid
+  //  winhc_eci_dev company_license_entpub license_number,new_cid
   def main(args: Array[String]): Unit = {
     val Array(project, tableName, dupliCols) = args
     println(

src/main/scala/com/winhc/bigdata/spark/jobs/chance/ChangeExtract.scala

@@ -310,6 +310,10 @@ object ChangeExtract {
     , Args(tableName = "company_judicial_sale_combine_list", primaryFields = "title")//司法拍卖
     , Args(tableName = "company_tax_contravention", primaryFields = "case_type")//税收违法
     , Args(tableName = "company_send_announcement_list", primaryFields = "title")//送达公告
+    , Args(tableName = "company_zxr_final_case", primaryFields = "identity_num")//终本案件
+    , Args(tableName = "company_license_creditchina", primaryFields = "licence_content")//行政许可-信用中国
+    , Args(tableName = "company_license_entpub", primaryFields = "license_name")//行政许可-企业公示
+    , Args(tableName = "company_license", primaryFields = "license_name")//行政许可
 
     , Args(tableName = "company_certificate", primaryFields = "type")
     , Args(tableName = "company_abnormal_info", primaryFields = "remove_reason")

src/main/scala/com/winhc/bigdata/spark/jobs/chance/table/company_license.scala

@@ -0,0 +1,28 @@
+
+package com.winhc.bigdata.spark.jobs.chance.table
+
+import com.winhc.bigdata.spark.jobs.chance.CompanyChangeHandle
+import com.winhc.bigdata.spark.utils.ChangeExtractUtils
+import org.apache.commons.lang3.StringUtils
+
+/**
+ * @Author: π
+ * @Date: 2020/8/11
+ * @Description:行政许可
+ */
+
+case class company_license(equCols: Seq[String]) extends CompanyChangeHandle with Serializable  {
+  override def getUpdateTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("license_name"), s"行政许可发生变更")
+
+  override def getInsertTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("license_name"), s"新增行政许可")
+
+  override def getLabel(oldMap: Map[String, String], newMap: Map[String, String]): String = ChangeExtractUtils.getTags(newMap, "行政许可", Array("license_name","start_date"))
+
+  override def getBizTime(newMap: Map[String, String]): String = {
+    if(StringUtils.isBlank(newMap("start_date"))){
+      newMap("update_time")
+    }else{
+      newMap("start_date").replaceAll("年","-").replaceAll("月","-").replaceAll("日","-")
+    }
+  }
+}

src/main/scala/com/winhc/bigdata/spark/jobs/chance/table/company_license_creditchina.scala

@@ -0,0 +1,28 @@
+
+package com.winhc.bigdata.spark.jobs.chance.table
+
+import com.winhc.bigdata.spark.jobs.chance.CompanyChangeHandle
+import com.winhc.bigdata.spark.utils.ChangeExtractUtils
+import org.apache.commons.lang3.StringUtils
+
+/**
+ * @Author: π
+ * @Date: 2020/8/11
+ * @Description:行政许可-信用中国
+ */
+
+case class company_license_creditchina(equCols: Seq[String]) extends CompanyChangeHandle with Serializable  {
+  override def getUpdateTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("licence_number"), s"行政许可-信用中国发生变更")
+
+  override def getInsertTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("licence_number"), s"新增行政许可-信用中国")
+
+  override def getLabel(oldMap: Map[String, String], newMap: Map[String, String]): String = ChangeExtractUtils.getTags(newMap, "行政许可-信用中国", Array("licence_content","decision_date"))
+
+  override def getBizTime(newMap: Map[String, String]): String = {
+    if(StringUtils.isBlank(newMap("decision_date"))){
+      newMap("update_time")
+    }else{
+      newMap("decision_date")
+    }
+  }
+}

src/main/scala/com/winhc/bigdata/spark/jobs/chance/table/company_license_entpub.scala

@@ -0,0 +1,28 @@
+
+package com.winhc.bigdata.spark.jobs.chance.table
+
+import com.winhc.bigdata.spark.jobs.chance.CompanyChangeHandle
+import com.winhc.bigdata.spark.utils.ChangeExtractUtils
+import org.apache.commons.lang3.StringUtils
+
+/**
+ * @Author: π
+ * @Date: 2020/8/11
+ * @Description:行政许可-企业公示
+ */
+
+case class company_license_entpub(equCols: Seq[String]) extends CompanyChangeHandle with Serializable  {
+  override def getUpdateTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("license_name"), s"行政许可-企业公示发生变更")
+
+  override def getInsertTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("license_name"), s"新增行政许可-企业公示")
+
+  override def getLabel(oldMap: Map[String, String], newMap: Map[String, String]): String = ChangeExtractUtils.getTags(newMap, "行政许可-企业公示", Array("license_name","start_date"))
+
+  override def getBizTime(newMap: Map[String, String]): String = {
+    if(StringUtils.isBlank(newMap("start_date"))){
+      newMap("update_time")
+    }else{
+      newMap("start_date").replaceAll("年","-").replaceAll("月","-").replaceAll("日","-")
+    }
+  }
+}

src/main/scala/com/winhc/bigdata/spark/jobs/chance/table/company_zxr_final_case.scala

@@ -0,0 +1,28 @@
+
+package com.winhc.bigdata.spark.jobs.chance.table
+
+import com.winhc.bigdata.spark.jobs.chance.CompanyChangeHandle
+import com.winhc.bigdata.spark.utils.ChangeExtractUtils
+import org.apache.commons.lang3.StringUtils
+
+/**
+ * @Author: π
+ * @Date: 2020/8/11
+ * @Description:终本案件
+ */
+
+case class company_zxr_final_case(equCols: Seq[String]) extends CompanyChangeHandle with Serializable  {
+  override def getUpdateTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("name"), s"终本案件发生变更")
+
+  override def getInsertTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("name"), s"新增终本案件")
+
+  override def getLabel(oldMap: Map[String, String], newMap: Map[String, String]): String = ChangeExtractUtils.getTags(newMap, "终本案件", Array("identity_num","case_create_time"))
+
+  override def getBizTime(newMap: Map[String, String]): String = {
+    if(StringUtils.isBlank(newMap("case_create_time"))){
+      newMap("update_time")
+    }else{
+      newMap("case_create_time")
+    }
+  }
+}

src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/CompanyDynamic.scala

@@ -198,6 +198,17 @@ object CompanyDynamic {
     , Args(tableName = "company_finance", bName = 1)
     , Args(tableName = "company_dishonest_info", bName = 1)
     , Args(tableName = "company_send_announcement_list", bName = 1)
+    , Args(tableName = "company_zxr_final_case", bName = 1)//终本案件
+    , Args(tableName = "company_license_creditchina", bName = 1)//行政许可-信用中国
+    , Args(tableName = "company_license_entpub", bName = 1)//行政许可-企业公示
+    , Args(tableName = "company_license", bName = 1)//行政许可
+    , Args(tableName = "company_check_info", bName = 1)//抽查检查
+    , Args(tableName = "company_court_announcement_list", bName = 1)//法院公告
+    , Args(tableName = "company_court_open_announcement_list", bName = 1)//开庭公告
+    , Args(tableName = "company_court_register_list", bName = 1)//立案信息
+    , Args(tableName = "company_double_random_check_info", bName = 1)//双随机抽查
+    , Args(tableName = "company_judicial_sale_combine_list", bName = 1)//司法拍卖
+    , Args(tableName = "company_tax_contravention", bName = 1)//税收违法
   )
 
   private case class Args(project: String = "winhc_eci_dev"

src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/CompanyDynamicHandle.scala

@@ -51,6 +51,10 @@ trait CompanyDynamicHandle {
     , "company_check_info" -> "spot_check" //抽查检查
     , "company_double_random_check_info" -> "company_double_random_check_info" //双随机抽查
     , "company_court_register" -> "company_court_register" //立案信息
+    , "company_zxr_final_case" -> "company_zxr_final_case" //终本案件
+    , "company_license_creditchina" -> "company_license_creditchina" //行政许可-信用中国
+    , "company_license_entpub" -> "company_license_entpub" //行政许可-企业公示
+    , "company_license" -> "company_license" //行政许可
   )
 
   private val table_2_info_type = Map(
@@ -92,13 +96,16 @@ trait CompanyDynamicHandle {
     , "company_finance" -> "31" // 融资动态
     , "company_stock_announcement" -> "32" // 企业公告
     , "company_check_info" -> "33" // 抽查检查
-    , "" -> "34" // 行政许可
+    , "company_license" -> "34-1" // 行政许可
+    , "company_license_creditchina" -> "34-2" // 行政许可-信用中国
+    , "company_license_entpub" -> "34-3" // 行政许可-企业公示
     , "company_double_random_check_info" -> "35" // 双随机抽查
     , "" -> "36" // 限制高消费
     , "" -> "37" // 被执行人
     , "company_send_announcement_list" -> "38" // 送达报告
     , "bankruptcy_open_case" -> "39" // 破产重整
     , "company_court_register" -> "40" // 立案信息
+    , "company_zxr_final_case" -> "41" // 终本案件
   )
 
 

src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_license.scala

@@ -0,0 +1,48 @@
+package com.winhc.bigdata.spark.jobs.dynamic.tables
+
+import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
+
+/**
+ * @Author: π
+ * @Date: 2020/8/11 17:39
+ * @Description: 行政许可
+ */
+case class company_license() extends CompanyDynamicHandle {
+
+
+  /**
+   * 来源表的变更类型，insert or update
+   *
+   * @return
+   */
+  override def org_type(): Seq[String] = Seq("insert")
+
+  /**
+   * 信息描述
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = {
+
+    s"""
+       |许可证编号：${new_map("license_number")}\n
+       |有效期自：${new_map("start_date")}\n
+       |有效期至：${new_map("end_date")}\n
+       |许可机关：${new_map("department")}\n
+       |许可内容：${new_map("scope")}
+       |""".stripMargin
+  }
+
+  /**
+   * 变更内容
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_change_content(old_map: Map[String, String], new_map: Map[String, String], cname: String): String = ""
+
+  override protected def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = "提示信息"
+}

src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_license_creditchina.scala

@@ -0,0 +1,49 @@
+package com.winhc.bigdata.spark.jobs.dynamic.tables
+
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
+
+/**
+ * @Author: π
+ * @Date: 2020/8/11 17:39
+ * @Description: 行政许可-信用中国
+ */
+case class company_license_creditchina() extends CompanyDynamicHandle {
+
+
+  /**
+   * 来源表的变更类型，insert or update
+   *
+   * @return
+   */
+  override def org_type(): Seq[String] = Seq("insert")
+
+  /**
+   * 信息描述
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = {
+
+    s"""
+       |许可证编号：${new_map("licence_number")}\n
+       |有效期自：${new_map("decision_date")}\n
+       |有效期至：${new_map("end_date")}\n
+       |许可机关：${new_map("department")}\n
+       |许可内容：${new_map("resume")}
+       |""".stripMargin
+  }
+
+  /**
+   * 变更内容
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_change_content(old_map: Map[String, String], new_map: Map[String, String], cname: String): String = ""
+
+  override protected def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = "提示信息"
+}

src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_license_entpub.scala

@@ -0,0 +1,48 @@
+package com.winhc.bigdata.spark.jobs.dynamic.tables
+
+import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
+
+/**
+ * @Author: π
+ * @Date: 2020/8/11 17:39
+ * @Description: 行政许可-企业公示
+ */
+case class company_license_entpub() extends CompanyDynamicHandle {
+
+
+  /**
+   * 来源表的变更类型，insert or update
+   *
+   * @return
+   */
+  override def org_type(): Seq[String] = Seq("insert")
+
+  /**
+   * 信息描述
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = {
+
+    s"""
+       |许可证编号：${new_map("license_number")}\n
+       |有效期自：${new_map("start_date")}\n
+       |有效期至：${new_map("end_date")}\n
+       |许可机关：${new_map("department")}\n
+       |许可内容：${new_map("scope")}
+       |""".stripMargin
+  }
+
+  /**
+   * 变更内容
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_change_content(old_map: Map[String, String], new_map: Map[String, String], cname: String): String = ""
+
+  override protected def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = "提示信息"
+}

src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_zxr_final_case.scala

@@ -0,0 +1,58 @@
+package com.winhc.bigdata.spark.jobs.dynamic.tables
+
+import com.winhc.bigdata.spark.implicits.MapHelper._
+import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
+
+/**
+ * @Author: π
+ * @Date: 2020/8/11 17:39
+ * @Description: 终本案件
+ */
+case class company_zxr_final_case() extends CompanyDynamicHandle {
+
+
+  /**
+   * 来源表的变更类型，insert or update
+   *
+   * @return
+   */
+  override def org_type(): Seq[String] = Seq("insert")
+
+  /**
+   * 信息描述
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_rta_desc(old_map: Map[String, String], new_map: Map[String, String]): String = {
+
+    s"""
+       |案号：${new_map("case_no")}\n
+       |执行法院：${new_map("court_name")}\n
+       |立案日期：${new_map("case_create_time")}\n
+       |终本日期：${new_map("case_final_time")}
+       |""".stripMargin
+  }
+
+  /**
+   * 变更内容
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override protected def get_change_content(old_map: Map[String, String], new_map: Map[String, String], cname: String): String = new_map.toJson(Seq(
+    "name->被执行人姓名"
+    ,"identity_num->身份证号码/组织机构代码"
+    ,"sex->性别"
+    ,"case_no->案号"
+    ,"court_name->执行法院"
+    ,"case_create_time->立案时间"
+    ,"case_final_time->终本日期"
+    ,"exec_amount->执行标的（元）"
+    ,"no_exec_amount->未履行金额"
+  ))
+
+  override protected def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = "风险信息"
+}