Bladeren bron

fix: company_zxr_restrict、company_dishonest_info

许家凯 4 jaren geleden
bovenliggende
commit
a2f2196692
1 gewijzigde bestanden met toevoegingen van 2 en 2 verwijderingen
  1. 2 2
      src/main/scala/com/winhc/bigdata/spark/ng/jobs/args_company_job.scala

+ 2 - 2
src/main/scala/com/winhc/bigdata/spark/ng/jobs/args_company_job.scala

@@ -35,12 +35,12 @@ object args_company_job {
       )
     )
     , args_company_job("company_dishonest_info", Seq("case_no", "name")
-      , rowkey_udf = "md5(cleanup(concat_ws('',case_no_trim(case_no),get_fixed_val(keyno,name) )))"
+      , rowkey_udf = "md5(cleanup(concat_ws('',case_no,get_fixed_val(keyno,name) )))"
       , is_super_filter = false
       , where = "case_no_trim(case_no) is not null and get_fixed_val(keyno,name) is not null"
     )
     , args_company_job("company_zxr_restrict", Seq("case_no", "person_name")
-      , rowkey_udf = "md5(cleanup(concat_ws('',case_no_trim(case_no),person_name )))"
+      , rowkey_udf = "md5(cleanup(concat_ws('',case_no,person_name )))"
       , is_super_filter = false
       , verify_company_id = false
       , where = "case_no_trim(case_no) is not null and person_name is not null and length(trim(person_name))>=2 "