索引id修改

src/main/scala/com/winhc/bigdata/spark/jobs/judicial/JudicialCaseRelationPreNew.scala

@@ -511,7 +511,7 @@ case class JudicialCaseRelationPreNew(s: SparkSession, project: String, ds: Stri
       s"""
          |INSERT ${if (isWindows) "INTO" else "OVERWRITE"} TABLE winhc_eci.ads_judicial_case_relation_r1
          |SELECT
-         |    concat_ws('',x.judicase_id,${t1_ds.substring(2)}) judicase_id,
+         |    concat_ws('',x.judicase_id) judicase_id,
          |    title       ,
          |    case_type   ,
          |    case_reason ,
@@ -567,7 +567,7 @@ case class JudicialCaseRelationPreNew(s: SparkSession, project: String, ds: Stri
          |INSERT ${if (isWindows) "INTO" else "OVERWRITE"} TABLE winhc_eci.ads_judicial_case_relation_r2
          |SELECT
          |    id,
-         |    concat_ws('',x.judicase_id,${t1_ds.substring(2)}) judicase_id,
+         |    concat_ws('',x.judicase_id) judicase_id,
          |    title       ,
          |    case_type   ,
          |    case_reason ,
@@ -582,7 +582,7 @@ case class JudicialCaseRelationPreNew(s: SparkSession, project: String, ds: Stri
          |    0 deleted
          |FROM
          |(
-         |SELECT  md5(concat_ws('',concat_ws('',judicase_id,${t1_ds.substring(2)}),CLEANUP(case_no))) id
+         |SELECT  md5(concat_ws('',concat_ws('',judicase_id),CLEANUP(case_no))) id
          |        ,judicase_id
          |        ,max(first_title) title
          |        ,case_type(max(case_no)) as case_type