增加diff校验

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

@@ -44,7 +44,7 @@ object diff_data_20250319 {
       val logKey = (apptype, mid, cid, ts, headvideoid).productIterator.mkString(",")
       val allfeaturemap: JSONObject = if (record.isNull("allfeaturemap")) new JSONObject() else
         JSON.parseObject(record.getString("allfeaturemap"))
-      allfeaturemap.put("logkey", Base64.getEncoder.encodeToString(logKey.getBytes("UTF-8")))
+      allfeaturemap.put("logkey", logKey)
       allfeaturemap
     })
 
@@ -155,6 +155,14 @@ object diff_data_20250319 {
             case e: Exception =>
               println(s"转换过程中出现错误: ${e.getMessage}")
           }
+        case num: java.lang.Number =>
+          // 数字类型转换为字符串
+          val str = num.toString
+          featureMap.put(name, str)
+        case num: java.lang.Number =>
+          // 数字类型转换为字符串
+          val str = num.toString
+          featureMap.put(name, str)
         case _ =>
           featureMap.put(name, record.get(name))
       }