big_collector adjust

发送walle服务端匹配

获取素材映射

失败

获取出价信息

是否获取到出价

获取出价失败

获取cpc出价

根据纬度匹配出价

根据DEFAULT、子渠道匹配

click

获取子渠道

获取出价是否成功

结束

优先根据 id 匹配，id不存在是根据name匹配

补齐出价：根据出价类型click：cpc: 同cpi

是

根据国家、子渠道匹配

根据出价类型补齐出价

cpi 补齐出价1、获取查询纬度    mintegral：offerId    tiktok：     offerId    applovin:   offerId    unityads:   offerId    其他：      campaignId

获取offer_id offer_name1、toutiao  offer_id =  campaignName 最后括号中的信息2、tiktok   offer_id = campaignName 最后一个&符号到最后3、mintegral   offer_id = campaignName4、applovin   offer_name = campaignName 开始到“(”5、快手   offer_id = trackerName 根据“::”分割，第三个数组6、unityads    offer_id =  campaignName 最后括号中的信息    如果offer_id 为空    offer_name = campaignName7、facebook    offer_id =  trackerName 根据“::”分割，第三个数组最后括号中的内容8、snapchat    offer_id =  trackerName 根据“::”分割，第三个数组最后括号中的内容9、iqiyi    offer_id =  trackerName 根据“::”分割，第三个数组根据“-”分割，获取第二个数组值10、gdt    offer_id =  trackerName 根据“::”分割，第三个数组最后括号中的内容

adjust 回传

获取出价

根据creative获取映射

处理event逻辑

补齐出价：根据出价类型install：   cpi:  见右下图   cpa: 同cpi   cpe: 同cpi   ocpm: 同cpi   ocpc: 同cpi   cpc:  见右下图   cpm: 同cpc

成功

根据平台、campaignid、creative_at 小于 事件时间

回传出价是否存在

记录到mong

根据offer获取映射

否

install

获取cpi出价

获取出价类型

获取creative_id、creative_name1、toutiao  creative_id = creativeName 最后括号中的信息2、tiktok  creative_id = creativeName 最后一个&符号到最后3、mintegral   creative_id = creativeName4、applovin  creative_name = creativeName5、kuaishou    creative_id = creativeName 最后括号中的信息6、unityads   creative_id = creativeName7、facebook   creative_id = creativeName 最后括号中的信息8、ironsource   creative_id =  creativeName 最后一个“_”到最后   creative_name = creativeName 开始到最后一个“_”9、iqiyi   creative_id = creativeName10、gdt   creative_id = creativeName 最后括号中的信息11、snapchat   creative_id = trackerName 以“::”分隔，第三个数组最后括号中的信息

落到大数据

是否存在出价

根据平台、campaignid

是否获取到素材映射

是否自然量

获取子渠道1、mintegral   子渠道：adGroup2、toutiao   子渠道：offerId3、tiktok   子渠道：offerId4、iqiyi   子渠道：offerId5、gdt   子渠道：offerId子渠道为空，默认 all

是否获取到映射

记录获取出价异常

根据adid+app_id判断是否重复回传

记录到mongo

查询结果

根据 all、all匹配

获取查询的campaignId

1、平台处理。    1.1 osNmae 包含“android” → platform=“android”    1.2 osNmae 包含“ios”       → platform=“ios”    1.3 stroe 包含 \"itunes\"       → platform=“ios”    1.4 stroe 包含 \"google\"       → platform=“android” 2、应用信息处理    2.1 adjust 回传packageName 为空是，使用 回传的app_id 作为包名    2.2 回传包名为ios应用市场id时，根据包名（id***）从alpha平台或者bundleId3、ad_network 逻辑    3.1 自然量。is_organic==1           fmt.Sprintf(\"%v(自然量)\

根据 all、子渠道匹配

impression

不存在

记录error表

根据国家、all匹配

补充createDate

落入大数据

是否渠道包

数据转换

记录为当前时间

存在

cpc 出价逻辑1、当前安装时间对应前第n个小时内总展示成本/总安装数