Browse Source

fix: 兼容老的司法案件

许家凯 3 years ago
parent
commit
35536ebc5c

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/judicial/JudicialCaseRelation_CaseAgg.scala

@@ -568,7 +568,7 @@ case class JudicialCaseRelation_CaseAgg(s: SparkSession,
       val current_court_name = getVal(m1, "court_name")
       val current_court_name = getVal(m1, "court_name")
       val connect_court_name = getVal(m2, "court_name")
       val connect_court_name = getVal(m2, "court_name")
 
 
-      case_connect_utils.isConnect(current_case_party_list_org, connect_case_party_list_org, current_case_no, connect_case_no, current_court_name, connect_court_name)
+      case_connect_utils.isConnect(current_case_party_list_org, connect_case_party_list_org, current_case_no, connect_case_no, current_court_name, connect_court_name,tn1,tn2)
     } catch {
     } catch {
       case ex: Exception => {
       case ex: Exception => {
         logError(ex.getMessage)
         logError(ex.getMessage)