修改统计参数

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

@@ -319,8 +319,6 @@ object coincidence_xinyang {
       )
       all_id.createOrReplaceTempView("all_id")
 
-
-
       //* 所有获得用户列表的用户id
       //1.重合用户的美购数
       val meigou_coincidence_num = sc.sql(
@@ -379,7 +377,7 @@ object coincidence_xinyang {
       meigou_pay_device_all.show()
 
       //截止目前获得的与新氧重合的用户数咨询统计
-      val zixun_num_all = sc.sql(
+/*      val zixun_num_all = sc.sql(
         s"""
            |select count(ov.cl_id)  as zixun_num_all
            |from online.tl_hdfs_maidian_view ov left join coincidence_id
@@ -402,12 +400,12 @@ object coincidence_xinyang {
          """.stripMargin
       )
       zixun_device_all.show()
-
+*/
       val zixun_num_co = sc.sql(
         s"""
            |select count(ov.cl_id)  as zixun_num_all
            |from online.tl_hdfs_maidian_view ov left join all_id
-           |on ov.cl_id = coincidence_id.device_id
+           |on ov.cl_id = all_id.device_id
            |where partition_date >= '20180501'
            |and coincidence_id.device_id is not null
            |and action = 'welfare_detail_click_message'
@@ -419,7 +417,7 @@ object coincidence_xinyang {
         s"""
            |select count(distinct(ov.cl_id))  as zixun_num_all
            |from online.tl_hdfs_maidian_view ov left join all_id
-           |on ov.cl_id = coincidence_id.device_id
+           |on ov.cl_id = all_id.device_id
            |where partition_date >= '20180501'
            |and coincidence_id.device_id is not null
            |and action = 'welfare_detail_click_message'