smart_rank 相关的统计指标

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

@@ -615,17 +615,52 @@ object smart_rank_count {
       final_id.createOrReplaceTempView("final_id")
 
 
-            val meigou_price = sc.sql(
-              s"""
-                 |select cl_id,city_id,params['business_id'] as meigou_id
-                 |from online.tl_hdfs_maidian_view
-                 |where action = "page_view"
-                 |and params['page_name']="welfare_detail"
-                 |and partition_date ='20181201'
-                 |LIMIT 10
-             """.stripMargin
-            )
-            meigou_price.show(80)
+      val meigou_pv = sc.sql(
+        s"""
+           |select *
+           |from online.tl_hdfs_maidian_view
+           |where action = "page_view"
+           |and params['page_name']="welfare_detail"
+           |and partition_date ='20181201'
+           |LIMIT 3
+       """.stripMargin
+      )
+       meigou_pv.show(80)
+
+//      val zixun_pv = sc.sql(
+//        s"""
+//           |select cl_id,city_id,params['service_id'] as meigou_id
+//           |from online.tl_hdfs_maidian_view
+//           |where partition_date > '20171118'
+//           |and action = 'welfare_detail_click_message'
+//       """.stripMargin
+//      )
+//      zixun_pv.show(80)
+
+
+
+//      val meigou_price = sc.sql(
+//        s"""
+//           |select  md.user_id,sum(md.gengmei_price) as pay_all
+//           |from online.ml_meigou_order_detail md
+//           |left join
+//           |(
+//           |        SELECT
+//           |        order_id
+//           |        FROM mining.ml_order_spam_recognize
+//           |        WHERE partition_date='20181223' AND
+//           |        self_support=0 AND dayBitsGetW1(predict_result,'20181223')=0
+//           |)spam
+//           |on md.order_id = spam.order_id
+//           |where md.status= 2
+//           |and  spam.order_id is null
+//           |and md.partition_date = '20181223'
+//           |and  md.pay_time  is  not  null
+//           |and  md.validate_time>'2017-01-01 00:00:00.0'
+//           |group by md.user_id
+//           |order by sum(md.gengmei_price)
+//       """.stripMargin
+//      )
 
       //      GmeiConfig.writeToJDBCTable(meigou_price, "meigou_price", SaveMode.Overwrite)