Update makedata_ad_33_bucketDataToHive_20250110: fix has_click

src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_33_bucketDataToHive_20250110.scala

@@ -84,14 +84,12 @@ object makedata_ad_33_bucketDataToHive_20250110 {
         }
         .map {
           case (logKey, labelKey, features) =>
-            val label = JSON.parseObject(labelKey).getOrDefault(whatLabel, "0").toString
+            val labelObject = JSON.parseObject(labelKey)
+            val label = labelObject.getOrDefault(whatLabel, "0").toString
             val bucketsMap = bucketsMap_br.value
             var resultMap = features.collect {
               case (name, score) if !filterNames.exists(name.contains) && score > 1E-8 =>
                 var key = name.replace("*", "_x_").replace("(view)", "_view")
-                if (key == "ad_is_click") {
-                  key = "has_click"
-                }
                 val value = if (bucketsMap.contains(name)) {
                   val (bucketsNum, buckets) = bucketsMap(name)
                   1.0 / bucketsNum * (ExtractorUtils.findInsertPosition(buckets, score).toDouble + 1.0)
@@ -100,7 +98,8 @@ object makedata_ad_33_bucketDataToHive_20250110 {
                 }
                 key -> value.toString
             }.toMap
-            resultMap += ("has_conversion" -> label)
+            resultMap += ("has_click" -> labelObject.getString("ad_is_click"))
+            resultMap += ("has_conversion" -> labelObject.getString("ad_is_conversion"))
             resultMap += ("logkey" -> logKey)
             (label.toInt, resultMap, Random.nextDouble())
         }.filter(r => r._3 < negSampleRate || r._1 > 0)