区别新老客户

eda/feededa/src/main/scala/com/gmei/testt.scala

@@ -126,7 +126,7 @@ object testt {
 //新用户到美购详情页的转化
       val diary_meigou_newUser = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date, count(device_id) as diary_meigou_newUser
+           |select '${stat_date}' as stat_date, count(dd.device_id) as diary_meigou_newUser
            |from diary_meigou_device dd left join device_id_new
            |on dd.device_id = device_id_new.device_id
            |where device_id_new.device_id is not null
@@ -135,7 +135,7 @@ object testt {
       //老用户到美购详情页的转化
       val diary_meigou_oldUser = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date, count(device_id) as diary_meigou_oldUser
+           |select '${stat_date}' as stat_date, count(dd.device_id) as diary_meigou_oldUser
            |from diary_meigou_device dd left join device_id_old
            |on dd.device_id = device_id_old.device_id
            |where device_id_old.device_id is not null
@@ -174,7 +174,7 @@ object testt {
       //新用户日记本点击
       val diary_clk_newUser = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date, count(device_id) as diary_clk_newUser
+           |select '${stat_date}' as stat_date, count(dd.device_id) as diary_clk_newUser
            |from diary_clk_device dd left join device_id_new
            |on dd.device_id = device_id_new.device_id
            |where device_id_new.device_id is not null
@@ -183,7 +183,7 @@ object testt {
       //老用户日记本点击
       val diary_clk_oldUser = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date, count(device_id) as diary_clk_oldUser
+           |select '${stat_date}' as stat_date, count(dd.device_id) as diary_clk_oldUser
            |from diary_clk_device dd left join device_id_old
            |on dd.device_id = device_id_old.device_id
            |where device_id_old.device_id is not null
@@ -220,7 +220,7 @@ object testt {
       //新用户日记本曝光
       val diary_exp_newUser = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date, count(device_id) as diary_exp_newUser
+           |select '${stat_date}' as stat_date, count(dd.device_id) as diary_exp_newUser
            |from diary_expoure_device dd left join device_id_new
            |on dd.device_id = device_id_new.device_id
            |where device_id_new.device_id is not null
@@ -229,7 +229,7 @@ object testt {
       //老用户日记本曝光
       val diary_exp_oldUser = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date, count(device_id) as diary_exp_oldUser
+           |select '${stat_date}' as stat_date, count(dd.device_id) as diary_exp_oldUser
            |from diary_expoure_device dd left join device_id_old
            |on dd.device_id = device_id_old.device_id
            |where device_id_old.device_id is not null
@@ -266,7 +266,7 @@ object testt {
       //新用户搜索次数
       val search_newUser = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date, count(device_id) as search_newUser
+           |select '${stat_date}' as stat_date, count(sd.device_id) as search_newUser
            |from search_device sd left join device_id_new
            |on sd.device_id = device_id_new.device_id
            |where device_id_new.device_id is not null
@@ -275,7 +275,7 @@ object testt {
       //老用户日搜索次数
       val search_oldUser = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date, count(device_id) as search_oldUser
+           |select '${stat_date}' as stat_date, count(sd.device_id) as search_oldUser
            |from search_device sd left join device_id_old
            |on sd.device_id = device_id_old.device_id
            |where device_id_old.device_id is not null
@@ -298,7 +298,7 @@ object testt {
       //新用户登录人数
       val log_newUser = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date, count(distinct(device_id)) as log_newUser
+           |select '${stat_date}' as stat_date, count(distinct(ld.device_id)) as log_newUser
            |from log_device ld left join device_id_new
            |on ld.device_id = device_id_new.device_id
            |where device_id_new.device_id is not null
@@ -307,7 +307,7 @@ object testt {
       //老用户登录人数
       val log_oldUser = sc.sql(
         s"""
-           |select '${stat_date}' as stat_date, count(distinct(device_id)) as log_oldUser
+           |select '${stat_date}' as stat_date, count(distinct(ld.device_id)) as log_oldUser
            |from log_device ld left join device_id_old
            |on ld.device_id = device_id_old.device_id
            |where device_id_old.device_id is not null