From edfbb3d9b6b38a4c9b47b037352bfc4a24a05310 Mon Sep 17 00:00:00 2001
From: fan.jiang <fan.jiang@mobvista.com>
Date: Fri, 2 Jul 2021 19:58:41 +0800
Subject: [PATCH] 热晕标签测试fix bug

---
 src/main/scala/mobvista/dmp/datasource/reyun/ReyunLabelTest.scala |  9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/main/scala/mobvista/dmp/datasource/reyun/ReyunLabelTest.scala b/src/main/scala/mobvista/dmp/datasource/reyun/ReyunLabelTest.scala
index 0e94df4..7887f80 100644
--- a/src/main/scala/mobvista/dmp/datasource/reyun/ReyunLabelTest.scala
+++ b/src/main/scala/mobvista/dmp/datasource/reyun/ReyunLabelTest.scala
@@ -54,10 +54,13 @@ class ReyunLabelTest  extends CommonSparkJob with Serializable{
     try {
       val sql1=
         s"""
-           |select  md5(dev_id)  from dwh.ods_dmp_user_info_daily
+           |select  md5(upper(dev_id))  from
+           |(select  dev_id  from dwh.ods_dmp_user_info_daily
            |where dt in ('${dt_today}','${one_day_ago}','${two_days_ago}')
-           |and platform='ios' and lower(country)='cn'
-           |and  (osversion like '14%' or osversion like '15%' or osversion like '16%')  limit 120000000
+           |and platform='ios'  and dev_type='idfa'  and lower(country)='cn'
+           |and  (osversion like '14%' or osversion like '15%' or osversion like '16%')
+           |group by dev_id ) t
+           |limit 120000000
         """.stripMargin
 
       println("sql=============="+sql1)
--
libgit2 0.27.1