add device_search_tag

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

@@ -548,16 +548,18 @@ object GetDevicePortrait {
 
       val device_search_tag = sc.sql(
         s"""
-           |select
-           |	a.cl_id as device_id,a.partition_date as stat_date,
-           |	COALESCE(a.params['diary_id'], a.params['business_id'], 0) as cid_id,
-           |	split(b.level1_ids,';')[0] as level1_id
-           |from online.tl_hdfs_maidian_view a
-           |left join diary_feat b
-           |on COALESCE(a.params['diary_id'], a.params['business_id'], 0) = b.diary_id
-           |where
-           |	a.partition_date = '20181224'
-           |	and (a.action = 'on_click_diary_card' or (a.action="full_stack_click_video_card_full_screen_play" and a.params["card_type"]="diary"))
+           |select c.device_id,c.stat_date,c.cid_id,count(c.level1_id) as level1_count
+           |from (select
+           |		a.cl_id as device_id,a.partition_date as stat_date,
+           |		COALESCE(a.params['diary_id'], a.params['business_id'], 0) as cid_id,
+           |		split(b.level1_ids,';')[0] as level1_id
+           |	from online.tl_hdfs_maidian_view a
+           |	left join diary_feat b
+           |	on COALESCE(a.params['diary_id'], a.params['business_id'], 0) = b.diary_id
+           |	where
+           |		a.partition_date = '20181224'
+           |		and (a.action = 'on_click_diary_card' or (a.action="full_stack_click_video_card_full_screen_play" and a.params["card_type"]="diary"))) c
+           |group by c.device_id,c.cid_id
          """.stripMargin
       )
       device_search_tag.show()