Commit da1246f6 authored by 王志伟's avatar 王志伟

repair bug

parent ff60c768
...@@ -56,7 +56,7 @@ object strategy_other { ...@@ -56,7 +56,7 @@ object strategy_other {
//val stat_date = GmeiConfig.getMinusNDate(1) //val stat_date = GmeiConfig.getMinusNDate(1)
//println(param.date) //println(param.date)
val partition_date = param.date.replace("-","") val partition_date = param.date.replace("-","")
val decive_id_oldUser = sc.sql( val devicee_id_oldUser = sc.sql(
s""" s"""
|select distinct(device_id) as device_id |select distinct(device_id) as device_id
|from online.ml_device_day_active_status |from online.ml_device_day_active_status
...@@ -71,7 +71,7 @@ object strategy_other { ...@@ -71,7 +71,7 @@ object strategy_other {
|and partition_date ='${partition_date}' |and partition_date ='${partition_date}'
""".stripMargin """.stripMargin
) )
decive_id_oldUser.createOrReplaceTempView("device_id_old") devicee_id_oldUser.createOrReplaceTempView("device_id_old")
//device_id尾号1有点击用户日记本点击数 //device_id尾号1有点击用户日记本点击数
val clk_active_1 = sc.sql( val clk_active_1 = sc.sql(
...@@ -92,7 +92,7 @@ object strategy_other { ...@@ -92,7 +92,7 @@ object strategy_other {
s""" s"""
|select '${param.date}' as stat_date, count(cid_id) as imp_active_1 |select '${param.date}' as stat_date, count(cid_id) as imp_active_1
|from data_feed_exposure je inner join device_id_old |from data_feed_exposure je inner join device_id_old
|on je.device_id = device_id_old.decive_id |on je.device_id = device_id_old.device_id
|where je.cid_type = 'diary' |where je.cid_type = 'diary'
|and je.device_id regexp'1$$' |and je.device_id regexp'1$$'
|and je.device_id in (select distinct(device_id) from data_feed_click where device_id regexp '1$$' and stat_date = '${param.date}') |and je.device_id in (select distinct(device_id) from data_feed_click where device_id regexp '1$$' and stat_date = '${param.date}')
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment