Przeglądaj źródła

fix: 过滤银行和保险机构

许家凯 4 lat temu
rodzic
commit
4455c0a22b

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/chance/eci_good_news.scala

@@ -70,7 +70,7 @@ object eci_good_news {
            |              AND     months_between('$now_time',to_date(biz_date)) < 3
            |          ) AS t2
            |ON      t1.rel_bg_cid = t2.detail_cid
-           |WHERE t1.bg_name not like concat('%','银行','%') AND t1.bg_name not like concat('%','保险','%')
+           |WHERE t1.rel_bg_name not like concat('%','银行','%') AND t1.rel_bg_name not like concat('%','保险','%')
            |""".stripMargin)
       df
         .cache()