smart_rank 相关的统计指标

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

@@ -622,8 +622,8 @@ object smart_rank_count {
            |on ov.cl_id = final_id.device_id
            |where ov.action = "page_view"
            |and ov.params['page_name']="welfare_detail"
-           |and ov.partition_date >='20181101'
-           |and ov.partition_date <'20181201'
+           |and ov.partition_date >='20181201'
+           |and ov.partition_date <='20181230'
            |and ov.city_id is not null
            |and final_id.device_id  is null
        """.stripMargin
@@ -636,9 +636,9 @@ object smart_rank_count {
            |from online.tl_meigou_service_view b
            |left join online.tl_hdfs_doctor_view c on b.doctor_id=c.id
            |left join online.tl_hdfs_hospital_view d on c.hospital_id=d.id
-           |where b.partition_date='20181227'
-           |and c.partition_date='20181227'
-           |and d.partition_date='20181227'
+           |where b.partition_date='20181228'
+           |and c.partition_date='20181228'
+           |and d.partition_date='20181228'
        """.stripMargin
       )
       meigou_city.createOrReplaceTempView("meigou_city")
@@ -656,7 +656,7 @@ object smart_rank_count {
 
       val meigou_pv_count = sc.sql(
         s"""
-           |select '2018-11' as stat_date,meigou_city,count(device_id) as meigou_pv,count(distinct(device_id)) as meigou_device_num
+           |select '2018-12' as stat_date,meigou_city,count(device_id) as meigou_pv,count(distinct(device_id)) as meigou_device_num
            |from meigou_pv_tongcheng
            |where device_city = meigou_city
            |group by meigou_city
@@ -671,8 +671,8 @@ object smart_rank_count {
            |select ov.cl_id as device_id,ov.city_id as device_city,ov.params['service_id'] as meigou_id
            |from online.tl_hdfs_maidian_view ov left join final_id
            |on ov.cl_id = final_id.device_id
-           |where ov.partition_date >= '20181101'
-           |and ov.partition_date <'20181201'
+           |where ov.partition_date >= '20181201'
+           |and ov.partition_date <='20181231'
            |and ov.action = 'welfare_detail_click_message'
            |and final_id.device_id is null
        """.stripMargin
@@ -691,7 +691,7 @@ object smart_rank_count {
 
       val zixun_pv_count = sc.sql(
         s"""
-           |select '2018-11' as stat_date,meigou_city,count(device_id) as meigou_zixun,count(distinct(device_id)) as meigou_zixun_device_num
+           |select '2018-12' as stat_date,meigou_city,count(device_id) as meigou_zixun,count(distinct(device_id)) as meigou_zixun_device_num
            |from zixun_meigou_tongcheng
            |where device_city=meigou_city
            |group by meigou_city
@@ -707,8 +707,8 @@ object smart_rank_count {
            |select first_city,count(distinct(device_id)) as new_device_month
            |from online.ml_device_day_active_status
            |where active_type != '4'
-           |and partition_date >='20181101'
-           |and partition_date <'20181121'
+           |and partition_date >='20181201'
+           |and partition_date <='20181230'
            |group by first_city
        """.stripMargin
       )