文书动态biz_id修改

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

@@ -205,7 +205,7 @@ trait CompanyDynamicHandle {
       , rta_desc
       , get_change_content(old_map, new_map)
       , get_change_time(bizDate, new_map)
-      , get_biz_id(rowkey)
+      , get_biz_id(rowkey, new_map)
       , get_sub_info_type()
       , get_info_risk_level(old_map, new_map)
       , if (suggestion == null) null else suggestion
@@ -265,7 +265,7 @@ trait CompanyDynamicHandle {
    * @param rowkey
    * @return
    */
-  protected def get_biz_id(rowkey: String): String = rowkey
+  protected def get_biz_id(rowkey: String, new_map: Map[String, String]): String = rowkey
 
   /**
    * 子信息类型，小类

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

@@ -32,7 +32,7 @@ case class company_bid_list() extends CompanyDynamicHandle {
    * @param rowkey
    * @return
    */
-  override def get_biz_id(rowkey: String): String = rowkey.split("_")(1)
+  override def get_biz_id(rowkey: String, new_map: Map[String, String]): String = rowkey.split("_")(1)
 
   /**
    * 风险等级

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

@@ -47,7 +47,7 @@ case class company_equity_info() extends CompanyDynamicHandle {
           , get_rta_desc(old_map, new_map)
           , get_change_content(old_map, new_map, cname)
           , get_change_time(bizDate, new_map)
-          , get_biz_id(rowkey)
+          , get_biz_id(rowkey,new_map)
           , get_sub_info_type()
           , t._3
           , null

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

@@ -65,4 +65,7 @@ case class wenshu_detail_combine() extends CompanyDynamicHandle {
     t2
   }
 
+  override protected def get_biz_id(rowkey: String, new_map: Map[String, String]): String = {
+    new_map("case_id")
+  }
 }