fix招投标动态

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

@@ -27,12 +27,12 @@ case class company_bid_list() extends CompanyDynamicHandle{
   override def get_change_content(old_map: Map[String, String], new_map: Map[String, String]): String = new_map("abs")
 
   /**
-   * 变更时间
+   * 业务id
    *
-   * @param new_map
+   * @param rowkey
    * @return
    */
-  //  override def get_change_time(new_map: Map[String, String]): String = new_map("biz_date")
+  override def get_biz_id(rowkey: String): String = rowkey.split("_")(1)
 
   /**
    * 风险等级
@@ -59,13 +59,13 @@ case class company_bid_list() extends CompanyDynamicHandle{
    *         info_risk_level
    *         winhc_suggest
    */
-  override def handle(rowkey: String, bizDate: String, cid: String, change_fields: Seq[String], old_map: Map[String, String], new_map: Map[String, String], cname: String): Seq[(String, String, String, String, String, String, String, String)] = {
-    val proxyName=new_map.get("proxy")
-    if (proxyName.equals(cname)){
+  override def handle(rowkey: String, bizDate: String, cid: String, change_fields: Seq[String], old_map: Map[String, String], new_map: Map[String, String], cname: String, suggestion: String = null): Seq[(String, String, String, String, String, String, String, String)] = {
+    val proxyName=new_map("proxy")
+    if (proxyName!=null && !proxyName.isEmpty && proxyName.equals(cname)){
       return null
     }
     else{
-      super.handle(rowkey, bizDate, cid, change_fields, old_map, new_map)
+      super.handle(rowkey, bizDate, cid, change_fields, old_map, new_map,cname,"该企业发布或参与招投标行为")
     }
   }
 }