统计搜索ctr,保存数据表

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

@@ -434,7 +434,6 @@ object GetHiveSearchData {
       var (searchHospitalExposureVal,searchHospitalClickNum,searchHospitalExposureMapCount,searchHospitalExposureFilterCount) = GetSearchResultData(sc,strSearchHospitalExposureAction,strSearchHospitalClickAction)
 
 
-
       val diary_clickSql = sc.sql(
         s"""
            |select
@@ -470,9 +469,18 @@ object GetHiveSearchData {
       println("searchDoctorExposureVal:" + searchDoctorExposureVal + "\tsearchDoctorClickNum:" + searchDoctorClickNum + "\tclickRate:" + (searchDoctorClickNum.floatValue()/searchDoctorExposureVal.floatValue()).formatted("%.2f"))
       println("searchHospitalExposureVal:" + searchHospitalExposureVal + "\tsearchHospitalClickNum:" + searchHospitalClickNum + "\tclickRate:" + (searchHospitalClickNum.floatValue()/searchHospitalExposureVal.floatValue()).formatted("%.2f"))
 
+
+
+      val result=List((stat_date,diaryExposureVal,diary_click_num,meigouExposureVal,meigouClickNum,searchResultExposureVal,(searchResultClickNum+content_diary_click_num),searchDoctorExposureVal,searchDoctorClickNum,searchHospitalExposureVal,searchHospitalClickNum))
+      val df_result = sc.createDataFrame(result).withColumnRenamed("_1,_2,_3,_4,_5,_6,_7,_8,_9,_10,_11","stat_date,diaryExposureVal,diary_click_num,meigouExposureVal,meigouClickNum,searchResultExposureVal,searchResultClickNum,searchDoctorExposureVal,searchDoctorClickNum,searchHospitalExposureVal,searchHospitalClickNum")
+
+      GmeiConfig.writeToJDBCTable(df_result, table = "Repeated_content_recommendation_moreday", SaveMode.Append)
+
     }
 
 
+
+
     def GetSearchResultData(spark: SparkSession, strExposureAction:String, strClickAction:String) = {
 
       val stat_date = "2019-01-16"