新路径漏斗分析底表

src/main/scala/com/session/SessionPathConvert.scala

@@ -80,7 +80,7 @@ object SessionPathConvert {
                         "device_type","device_brand","device_model","net_type","created_time","date_time","module_class1","module_class2","refer_time_diff")
             println("referResDF.printSchema()")
             referResDF.printSchema()
-            println(s"referResDF.count=${referResDF.count()}")
+//            println(s"referResDF.count=${referResDF.count()}")
             println("------------------------------------单独计算label_value----------------------------------------------")
             //"menu_code = '930' and  action_code IN ( '930000', '930001', '930002' ) and action_type = 'ACTION_CLICK'
             println("-----------------------------------load data to pica_dw.dw_fact_log_session_path-----------------")
@@ -179,7 +179,7 @@ class SessionPathConvert {
                         referMap("referCreated") = preCreated
                         //menu_code改变,先查询栈顶记录,如果栈顶记录的pre记录与当前menu_code一致,则弹出栈顶元素,否则将上个menu_code的信息放入站中
                         //弹出栈顶记录后,下个栈顶记录数据中的refer信息作为该menu_code的refer(前提当前页面不是首页)
-                        if(!menuStack.isEmpty && menuStack.top.apply(1) == menu_code ){
+                        if(!menuStack.isEmpty && (menuStack.top.apply(1) == menu_code||menuStack.top.apply(1)=="499") ){
                             var preMenuInfo  = menuStack.pop()
                             if(!menuStack.isEmpty){
                                 referMap("referLogSessionId") = menuStack.top.apply(0)