地块公示,购地信息修改

src/main/scala/com/winhc/bigdata/spark/const/CaseChanceConst.scala

@@ -25,12 +25,15 @@ object CaseChanceConst {
     /*"" -> "3-1" //企业增资
     , "" -> "3-2" //企业新增对外投资
     , "" -> "3-3" //新增招投标
-    , */ "company_employment" -> "3-4" //新增招聘
-    /* , "" -> "3-5" //地块公示
-     , "" -> "3-6" //购地信息
-     , "" -> "3-7" //土地转让
-    */
-    , "company_tm" -> "3-8" //知识产权-商标
+    , "" -> "3-4" //新增招聘
+    , "" -> "3-5" //地块公示
+    , "" -> "3-6" //购地信息
+    , "" -> "3-7" //土地转让
+    ,*/
+     "company_employment" -> "3-4" //新增招聘
+    ,"company_land_publicity" -> "3-5" //地块公示
+    ,"company_land_announcement" -> "3-6" //购地信息
+    ,"company_tm" -> "3-8" //知识产权-商标
     , "company_patent_list" -> "3-9" //专利
     , "company_certificate" -> "3-10" //资质证书   X
     , "company_copyright_works_list" -> "3-11" //作品著作权

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

@@ -164,6 +164,10 @@ object ChangeExtract {
   // winhc_eci_dev company_copyright_reg_list rowkey 20200715 version
   // winhc_eci_dev company_employment rowkey 20200630 source
 
+  // winhc_eci_dev company_land_publicity rowkey 20200630 title,location,use_for
+  // winhc_eci_dev company_land_announcement rowkey 20200715 e_number,project_name
+
+
 
   // winhc_eci_dev company cid 20200630 legal_entity_id,reg_location,business_scope,reg_status,reg_capital,emails,phones
   def main(args: Array[String]): Unit = {

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

@@ -81,11 +81,11 @@ case class company_land_publicity(equCols: Seq[String]) extends CompanyChangeHan
     str
   }
 
-  override def getBizTime(newMap: Map[String, String]): String = "业务时间"
+  override def getBizTime(newMap: Map[String, String]): String = newMap("publication_start_date")
 
-  override def getUpdateTitle(newMap: Map[String, String]): String = "更新某地块公示"
+  override def getUpdateTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("project_name"), s"${newMap("project_name")}地块公示发生变更")
 
-  override def getInsertTitle(newMap: Map[String, String]): String = "新增某地块公示"
+  override def getInsertTitle(newMap: Map[String, String]): String = getValueOrNull(newMap("project_name"), s"新增${newMap("project_name")}地块公示")
 }