change sql

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

@@ -53,13 +53,13 @@ object testt {
         println(strategy)
         val get_data_dura = sc.sql(
           s"""
-             |select partition_date, sum(params['duration']) as total_dur,count(distinct(cl_id)) as num
-             |from online.tl_hdfs_maidian_view
-             |where action="on_app_session_over"
-             |and cl_id regexp '${strategy}'
-             |and params['duration']>=0 and params['duration']<86400
-             |and partition_date >='20180801'
-             |group by partition_date order by partition_date desc
+             |select count(cid_id) as get_clk_count_newUser
+             |from data_feed_click jd inner join device_id_newUser
+             |on jd.device_id = device_id_newUser.decive_id
+             |where  (jd.cid_type = 'diary' or jd.cid_type = 'diary_video')
+             |and jd.device_id regexp'${strategy}'
+             |and jd.device_id not in (select device_id from bl_device_list)
+             |and jd.device_id not in (select device_id from blacklist)
          """.stripMargin
         )
         get_data_dura.show()