Commit ce4575ba by fan.jiang

dsp_req分区adx dealid入库需求

parent 69acc18a
...@@ -373,6 +373,34 @@ class DspOrgEtlDailys extends CommonSparkJob with Serializable { ...@@ -373,6 +373,34 @@ class DspOrgEtlDailys extends CommonSparkJob with Serializable {
value.packageName = "com.ucmobile_oppo" value.packageName = "com.ucmobile_oppo"
arrayBuffer = addDatasV2(arrayBuffer, deviceId, gaidmd5, imei, imeimd5, oaid, oaidmd5, androidId, idfv, deviceType, platform, value) arrayBuffer = addDatasV2(arrayBuffer, deviceId, gaidmd5, imei, imeimd5, oaid, oaidmd5, androidId, idfv, deviceType, platform, value)
} }
if (dealeridArray.contains("4059")) {
value.packageName = "com.ss.android.ugc.aweme"
arrayBuffer = addDatasV2(arrayBuffer, deviceId, gaidmd5, imei, imeimd5, oaid, oaidmd5, androidId, idfv, deviceType, platform, value)
value.packageName = "com.ss.android.ugc.aweme_oppoziyou"
arrayBuffer = addDatasV2(arrayBuffer, deviceId, gaidmd5, imei, imeimd5, oaid, oaidmd5, androidId, idfv, deviceType, platform, value)
}
if (dealeridArray.contains("4060")) {
value.packageName = "com.ss.android.ugc.aweme_oppoziyou_notinstall"
arrayBuffer = addDatasV2(arrayBuffer, deviceId, gaidmd5, imei, imeimd5, oaid, oaidmd5, androidId, idfv, deviceType, platform, value)
}
if (dealeridArray.contains("4061")) {
value.packageName = "com.ss.android.ugc.aweme_oppoziyou_hist_notinstall"
arrayBuffer = addDatasV2(arrayBuffer, deviceId, gaidmd5, imei, imeimd5, oaid, oaidmd5, androidId, idfv, deviceType, platform, value)
}
if (dealeridArray.contains("4053")) {
value.packageName = "com.ss.android.ugc.aweme"
arrayBuffer = addDatasV2(arrayBuffer, deviceId, gaidmd5, imei, imeimd5, oaid, oaidmd5, androidId, idfv, deviceType, platform, value)
value.packageName = "com.ss.android.ugc.aweme_oppolianmeng"
arrayBuffer = addDatasV2(arrayBuffer, deviceId, gaidmd5, imei, imeimd5, oaid, oaidmd5, androidId, idfv, deviceType, platform, value)
}
if (dealeridArray.contains("4054")) {
value.packageName = "com.ss.android.ugc.aweme_oppolianmeng_hist1year_notinstall"
arrayBuffer = addDatasV2(arrayBuffer, deviceId, gaidmd5, imei, imeimd5, oaid, oaidmd5, androidId, idfv, deviceType, platform, value)
}
if (dealeridArray.contains("4055")) {
value.packageName = "com.ss.android.ugc.aweme_oppolianmeng_histhalfyear_notinstall"
arrayBuffer = addDatasV2(arrayBuffer, deviceId, gaidmd5, imei, imeimd5, oaid, oaidmd5, androidId, idfv, deviceType, platform, value)
}
// 添加 oppo 在请求中开始传支付宝,京东,爱奇艺这几个包名的安装信息,并入库。 (2020-10-28 17:17 补充说明: com.eg.android.AlipayGphone_oppo伪包名大写,但已经入库,修改困难。以后入库伪包名统一定为小写,类似上面的 com.ucmobile_oppo) // 添加 oppo 在请求中开始传支付宝,京东,爱奇艺这几个包名的安装信息,并入库。 (2020-10-28 17:17 补充说明: com.eg.android.AlipayGphone_oppo伪包名大写,但已经入库,修改困难。以后入库伪包名统一定为小写,类似上面的 com.ucmobile_oppo)
// 2020.11.11 添加 2783对应的咸鱼的 com.taobao.idlefish 和 com.taobao.idlefish_oppo 入库 // 2020.11.11 添加 2783对应的咸鱼的 com.taobao.idlefish 和 com.taobao.idlefish_oppo 入库
// 2020.11.26 添加 2840对应的 com.youku.phone_notinstall 和 com.youku.phone_notinstall_oppo 入库 // 2020.11.26 添加 2840对应的 com.youku.phone_notinstall 和 com.youku.phone_notinstall_oppo 入库
...@@ -443,7 +471,8 @@ class DspOrgEtlDailys extends CommonSparkJob with Serializable { ...@@ -443,7 +471,8 @@ class DspOrgEtlDailys extends CommonSparkJob with Serializable {
100196 -> "com.smile.gifmaker", 100196 -> "com.smile.gifmaker",
100197 -> "id387682726", 100197 -> "id387682726",
100188 -> "com.tencent.news", 100188 -> "com.tencent.news",
100310 -> "com.taobao.litetao") 100310 -> "com.taobao.litetao",
100203 -> "com.ss.android.ugc.aweme")
if ("bes".equals(exchanges)) { if ("bes".equals(exchanges)) {
for (item <- mapData_bes) { for (item <- mapData_bes) {
if (dealeridArray.contains(item._1.toString)) { if (dealeridArray.contains(item._1.toString)) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment