统计复购用户日记本

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

@@ -794,10 +794,12 @@ object bug_again_count {
 
       val meigou_id_order = sc.sql(
         s"""
-           |select user_id,order_id
+           |select user_id,count(order_id) as order_num
            |from online.ml_meigou_order_detail
            |where status="2"
            |and partition_date='${partition_date}'
+           |group by user_id
+           |order by order_num
        """.stripMargin
       )
       meigou_id_order.createOrReplaceTempView("meigou_id_order")