fix: 企业动态

- 招聘风险等级
- 企业动态聚合后biz_id异常

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

@@ -93,7 +93,7 @@ case class CompanyDynamicForDayCount(s: SparkSession,
       val cname = r.getAs[String]("cname")
       val new_map = Map("cnt" -> (cnt + ""))
 
-      val result = handle.handle(cid + biz_date, biz_date, cid, null, null, new_map, cname)
+      val result = handle.handle(cid , biz_date, cid, null, null, new_map, cname)
       if (result == null) {
         None
       }

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

@@ -1,6 +1,5 @@
 package com.winhc.bigdata.spark.jobs.dynamic.tables
 
-import com.winhc.bigdata.spark.implicits.MapHelper._
 import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 
 /**
@@ -25,7 +24,7 @@ case class company_employment() extends CompanyDynamicHandle {
     * @param new_map
     * @return
     */
-  override protected def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = "提示"
+  override protected def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = "2"
 
   /**
     * 变更内容