增加新指标

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

@@ -49,6 +49,7 @@ object Recommendation_strategy_all {
       ti.tidbMapTable(dbName = "jerry_prod", tableName = "blacklist")
       ti.tidbMapTable(dbName = "jerry_test", tableName = "bl_device_list")
       ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure")
+      ti.tidbMapTable(dbName = "jerry_prod", tableName = "merge_queue_table")
 
 
       import sc.implicits._
@@ -123,9 +124,48 @@ object Recommendation_strategy_all {
          """.stripMargin
       )
 
+//获取策略命中用户device_id
+      val device_id_cover = sc.sql(
+        s"""
+           |select distinct(device_id) as device_id
+           |from merge_queue_table
+         """.stripMargin
+      )
+      device_id_cover.createOrReplaceTempView("device_id_cover_older")
+
+
+      val clk_count_oldUser_Cover = sc.sql(
+        s"""
+           |select '${param.date}' as stat_date, count(cid_id) as clk_count_oldUser_Cover
+           |from data_feed_click jd inner join device_id_cover_older
+           |on jd.device_id = device_id_cover_older.device_id
+           |where  (jd.cid_type = 'diary' or jd.cid_type = 'diary_video')
+           |and jd.device_id not in (select device_id from bl_device_list)
+           |and jd.device_id not in (select device_id from blacklist)
+           |and jd.stat_date ='${param.date}'
+         """.stripMargin
+      )
+
+      val imp_count_oldUser_Cover = sc.sql(
+        s"""
+           |select '${param.date}' as stat_date, count(cid_id) as imp_count_oldUser_Cover
+           |from data_feed_exposure je inner join device_id_cover_older
+           |on je.device_id = device_id_cover_older.device_id
+           |where je.cid_type = 'diary'
+           |and je.device_id not in (select device_id from bl_device_list)
+           |and je.device_id not in (select device_id from blacklist)
+           |and je.stat_date ='${param.date}'
+         """.stripMargin
+      )
+
+
+
+
       val result = clk_count_oldUser_Contrast.join(imp_count_oldUser_Contrast,"stat_date")
           .join(clk_count_oldUser_all,"stat_date")
           .join(imp_count_oldUser_all,"stat_date")
+          .join(clk_count_oldUser_Cover,"stat_date")
+          .join(imp_count_oldUser_Cover,"stat_date")
       result.show()