添加user_id_int

src/main/scala/com/session/SessionProcessArgs.scala

@@ -126,8 +126,10 @@ class SessionProcessArgs extends java.io.Serializable {
                     }
                 }
             }
-            //匹配menu_code:如果上述截取出来的menu_code为'',null或者action is ACTION_VIEW
-            if (menu_code.equals("")|| menu_code.equals("null") || action_type.equals("ACTION_VIEW")) {
+            //匹配menu_code:如果上述截取出来的menu_code为(''||null||0||length(menu_code)>3 ) and action is ACTION_VIEW
+            if ((menu_code.equals("")|| menu_code.equals("null") || menu_code.equals("0") || menu_code.length> 3 )
+              && action_type.equals("ACTION_VIEW")) {
+                menu_code = "0" //关联不上的显示为0
                 import scala.util.control.Breaks._
                 breakable {
                     //利用menu_code映射表匹配
@@ -385,7 +387,9 @@ object SessionProcessArgs {
         val deviceToken: Dataset[Row] = deviceTokenDF.where("user_id !='0'")
         val rightUserId: Dataset[Row] = DF.where("user_id !='' and user_id != '0' and LENGTH(user_id) !=24")
         val dwFactLogSession: Dataset[Row] = rightUserId.union(deviceToken).union(mobilePhoneDF)
-        dwFactLogSession
+        dwFactLogSession.createOrReplaceTempView(MyConfigSession.VIEW_MOBILE_PHONE)
+        val userIdDF: DataFrame = sparkSQLSession.sql(MyConfigSession.USER_ID_INT_SQL)
+        userIdDF
     }
 
 }