dw_fact_log_session_path中user_id类型改为int

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

@@ -54,7 +54,7 @@ object MyConfigSession {
     //从dw_fact_log_session表中筛选数据
     final val SOURCE_SQL_PATH: String =
         s"""
-          |select session_id,user_id,action_type,user_token,menu_code,action_code,position,label_value,
+          |select session_id,cast(user_id as int) user_id,action_type,user_token,menu_code,action_code,position,label_value,
           |app_version,device_type,created_time,date_time from ${MyConfigSession.HIVE_TABLE1}
           | where created_day=DATE_SUB(current_date(),1) and app_version >= '3.1.7'
           | AND ((action_type ='ACTION_CLICK') OR (action_type ='ACTION_VIEW' and menu_code != '0' and menu_code !='null' and menu_code !=''))

src/main/scala/com/session/SessionProcessPath.scala

@@ -55,13 +55,13 @@ object SessionProcessPath {
 
             //注册日期在流量统计日期之前的用户
             val doctorDF: DataFrame = sparkSession.sql(
-                "select cast(id as string) id from pica_ds.pica_doctor where to_date(creat_time) <=DATE_SUB(current_date(),1)")
+                "select  id from pica_ds.pica_doctor where to_date(creat_time) <=DATE_SUB(current_date(),1)")
 
             sourceDF.join(doctorDF, sourceDF("user_id") === doctorDF("id"), "left")
                     .createOrReplaceTempView("tmp_table")
 
             //将id为null的记录设置为0
-            val reSql: String = "select session_id,case when id is null then '0' else user_id END as user_id,action_type," +
+            val reSql: String = "select session_id,case when id is null then 0 else user_id END as user_id,action_type," +
                     "user_token,menu_code,action_code,position,label_value,app_version,device_type,created_time,date_time from tmp_table"
             val selectDF: DataFrame = sparkSession.sql(reSql)
 

src/main/scala/com/session/SessionProcessPathArgs.scala

@@ -53,7 +53,7 @@ object SessionProcessPathArgs {
             //筛选源数据
             val sourceSql =
                 s"""
-                   |select session_id,user_id,action_type,user_token,menu_code,action_code,position,label_value,
+                   |select session_id,cast(user_id as int) user_id,action_type,user_token,menu_code,action_code,position,label_value,
                    |app_version,device_type,created_time,date_time from ${MyConfigSession.HIVE_TABLE1}
                    | where created_day='${args(0)}' and app_version >= '3.1.7' and menu_code !='null' and menu_code !=''
                    | and ((action_type ='ACTION_VIEW' and menu_code != '0') or (action_type ='ACTION_CLICK' and action_code !=''))
@@ -62,13 +62,13 @@ object SessionProcessPathArgs {
 
             //注册日期在流量统计日期之前的用户
             val doctorDF: DataFrame = sparkSession.sql(
-                "select cast(id as string) id from pica_ds.pica_doctor where to_date(creat_time) <=DATE_SUB(current_date(),1)")
+                "select  id from pica_ds.pica_doctor where to_date(creat_time) <=DATE_SUB(current_date(),1)")
 
             sourceDF.join(doctorDF, sourceDF("user_id") === doctorDF("id"), "left")
                     .createOrReplaceTempView("tmp_table")
 
             //将id为null的记录设置为0
-            val reSql: String = "select session_id,case when id is null then '0' else user_id END as user_id,action_type," +
+            val reSql: String = "select session_id,case when id is null then 0 else user_id END as user_id,action_type," +
                     "user_token,menu_code,action_code,position,label_value,app_version,device_type,created_time,date_time from tmp_table"
             val selectDF: DataFrame = sparkSession.sql(reSql)