修改流量dw层表处理逻辑

src/main/scala/com/config/MyConfigSession.scala

@@ -75,7 +75,7 @@ object MyConfigSession {
           |app_version,device_type,created_time,date_time,module_class1,module_class2 from ${MyConfigSession.HIVE_TABLE1}
           | where  app_version >= '3.1.7'
           | AND ((action_type ='ACTION_CLICK'  and action_code != 'null' ) OR  action_type ='ACTION_VIEW' )
-          | and (menu_code != '0' and menu_code !='null' and menu_code !='' and length(menu_code) <= 3 )
+          | and (menu_code != '0' and menu_code !='null' and menu_code !='' and (length(menu_code) <= 3 or length(menu_code)=7) )
         """.stripMargin
 
     //从dw_fact_log_session_TERM表中筛选数据
@@ -85,7 +85,7 @@ object MyConfigSession {
          |app_version,device_type,device_brand,device_model,net_type,created_time,date_time,module_class1,module_class2 from ${MyConfigSession.HIVE_TABLE4}
          | where  app_version >= '3.1.7'
          | AND ((action_type ='ACTION_CLICK'  and action_code != 'null' )   OR  action_type ='ACTION_VIEW'   )
-         | and (menu_code != '0' and menu_code !='null' and menu_code !='' and length(menu_code) <= 3 and cast(menu_code as int ) is not null)
+         | and (menu_code != '0' and menu_code !='null' and menu_code !='' and (length(menu_code) <= 3 or length(menu_code)=7) and cast(menu_code as int ) is not null)
           """.stripMargin
 
 

src/main/scala/com/session/SessionProcessTerm.scala

@@ -363,8 +363,8 @@ class SessionProcessTerm {
         if ("MenuCode_081".equals(menu_code_new)) {
           menu_code_new = "081" //针对异常menu_code值单独处理
         }
-        //匹配menu_code:如果上述截取出来的menu_code为(''||null||0||length(menu_code)>3 ) and action is ACTION_VIEW
-        if ((menu_code_new.equals("") || menu_code_new.equals("null") || menu_code_new.equals("0") || menu_code_new.length > 3)
+        //匹配menu_code:如果上述截取出来的menu_code为(''||null||0||length(menu_code)>3  && !component_tag.contains("#") ) and action is ACTION_VIEW
+        if ((menu_code_new.equals("") || menu_code_new.equals("null") || menu_code_new.equals("0") || (menu_code_new.length > 3  && !component_tag.contains("#")) )
           && action_type.equals("ACTION_VIEW")) {
           menu_code_new = "0" //关联不上的显示为0
           import scala.util.control.Breaks._