fix

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

@@ -12,7 +12,6 @@ import org.apache.spark.sql.{Row, SparkSession}
 
 import scala.annotation.meta.getter
 import scala.collection.mutable
-import org.apache.spark.ui.graphx.GraphXTab._
 
 case class GraphX4Judicase(s: SparkSession,
                            project: String, //表所在工程名
@@ -99,7 +98,7 @@ object GraphX4Judicase {
       "spark.hadoop.odps.spark.local.partition.amt" -> "2000"
     )
     val spark: SparkSession = SparkUtils.InitEnv(this.getClass.getSimpleName, config)
-    spark.sparkContext.setLogLevel("All")
+    spark.sparkContext.setLogLevel("Warn")
     GraphX4Judicase(spark, "winhc_eci_dev", "xjk_ads_judicial_case_relation1", "id_2", "id_1").calc()
   }
 }

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

@@ -22,4 +22,12 @@ case class bankruptcy_open_case() extends CompanyDynamicHandle {
        |申请人：${new_map("applicant")}
        |公开日期：${new_map("public_date")}""".stripMargin
   }
+  /**
+   * 风险等级
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = "4"
 }

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

@@ -26,4 +26,12 @@ case class company_annual_report_out_guarantee() extends CompanyDynamicHandle {
    * @return
    */
   override def get_change_content(old_map: Map[String, String], new_map: Map[String, String], cname: String = null): String = new_map("credito_term") + new_map("guarantee_way")
+  /**
+   * 风险等级
+   *
+   * @param old_map
+   * @param new_map
+   * @return
+   */
+  override def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = "2"
 }

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

@@ -46,7 +46,7 @@ case class company_send_announcement_list()extends CompanyDynamicHandle {
    * @return
    */
   override def get_info_risk_level(old_map: Map[String, String], new_map: Map[String, String]): String = {
-    if(new_map("defendant_cids").contains("cid"))//原告
+    if(new_map("defendant_cids").contains("cid"))//被告
       {
         "3"
       }