<?php
namespace app\service;
use app\model\BpsAdInsight;
//use think\facade\Db as ThinkDb;
class AdsDashboardService
{
public function getAdCycleCard($customerIds, $cycle, $startDate = null, $endDate = null)
{
// 将 Y-m-d 格式的日期转换为纯数字格式
$startDateNumeric = $startDate ? str_replace('-', '', $startDate) : null;
$endDateNumeric = $endDate ? str_replace('-', '', $endDate) : null;
// 获取当前周期的数据
$currentData = $this->getAdcycleInsight($customerIds, $cycle, $startDateNumeric, $endDateNumeric);
return $currentData;
// 计算前一天的日期
// $previousStartDate = $startDate ?
// (new DateTime($startDate))->modify('-1 day')->format('Ymd') :
// null;
//
// $previousEndDate = $endDate ?
// (new DateTime($endDate))->modify('-1 day')->format('Ymd') :
// null;
// 获取前一天周期的数据
// $lastData = $this->getAdcycleInsight($customerIds, $cycle, $previousStartDate, $previousEndDate);
}
public function getAdcycleInsight($customerIds, $cycle, $startDate = null, $endDate = null)
{
// 1. 查询全部数据集
$adcycleDataQuery = BpsAdInsight::alias('d');
$adRevenueQuery = BpsAdInsight::alias('d')
->where('d.platform', 3); // 过滤 platform=3
//dump($customerIds);
// 2. 客户 ID 过滤（如果提供了）
if (!empty($customerIds)) {
$adcycleDataQuery->whereIn('d.account_id', $customerIds);
$adRevenueQuery->whereIn('d.account_id', $customerIds);
} else {
return [
'data' => [
'meta' => [
'meta_ads' => '-',
'roas' => '-',
'cpc' => '-',
'cpm' => '-',
'meta_purchases' => '-',
'web_purchases' => '-',
'purchases' => '-',
'meta_conversion_value' => '-',
'web_conversion_value' => '-',
'conversion_value' => '-',
'cpoc' => '-',
'ctr' => '-',
'revenue_per_link_click' => '-',
'cpa' => '-',
],
'google' => [
'google_ads' => '-',
'conversion_value' => '-',
'roas' => '-',
'conversions' => '-',
'ctr' => '-',
'cpa' => '-',
'cpm' => '-',
'clicks' => '-',
'impressions' => '-',
'all_conversions_value' => '-',
'all_roas' => '-',
'all_conversions' => '-',
'all_cpa' => '-',
],
'tiktok' => [
'tiktok_ads' => '-',
'roas' => '-',
'impressions' => '-',
'cpm' => '-',
'cpc' => '-',
'ctr' => '-',
'cpa' => '-',
'tiktok_shop_conversions' => '-',
'tiktok_shop_conversion_value' => '-',
'conversion_value' => '-',
'web_conversion_value' => '-',
'purchases' => '-',
'web_purchases' => '-',
'tiktok_gmv_max_ads' => '-',
]
]
];
}
// 3. 时间范围筛选
if ($startDate && $endDate) {
$adcycleDataQuery->whereBetween('d.date', [$startDate, $endDate]);
$adRevenueQuery->whereBetween('d.date', [$startDate, $endDate]);
}
// 4. 获取数据并按平台和日期聚合
$adcycleData = $adcycleDataQuery->field(
'd.platform,
COALESCE(SUM(d.assisted_purchases), 0) as assisted_purchases,
COALESCE(SUM(d.last_clicked_purchases), 0) as last_clicked_purchases,
COALESCE(SUM(d.clicks), 0) as clicks,
COALESCE(SUM(d.outbound_clicks), 0) as outbound_clicks,
COALESCE(SUM(d.spend) / 1000000, 0) as spend,
COALESCE(SUM(d.impressions), 0) as impressions,
COALESCE(SUM(d.adds_to_cart), 0) as adds_to_cart,
COALESCE(SUM(d.purchases), 0) as purchases,
COALESCE(SUM(d.onsite_purchase), 0) as onsite_purchase,
COALESCE(SUM(d.offsite_purchase), 0) as offsite_purchase,
COALESCE(SUM(d.purchases_all), 0) as purchases_all,
COALESCE(SUM(d.tiktok_shop_conversion), 0) as tiktok_shop_conversion,
COALESCE(SUM(d.platform_purchase), 0) as platform_purchase,
COALESCE(SUM(d.purchases_value) / 1000000, 0) as purchases_value,
COALESCE(SUM(d.onsite_purchases_value) / 1000000, 0) as onsite_purchases_value,
COALESCE(SUM(d.offsite_purchases_value) / 1000000, 0) as offsite_purchases_value,
COALESCE(SUM(d.platform_purchase_value) / 1000000, 0) as platform_purchase_value,
COALESCE(SUM(d.tiktok_shop_conversion_value) / 1000000, 0) as tiktok_shop_conversion_value,
COALESCE(SUM(d.revenue) / 1000000, 0) as revenue,
COALESCE(SUM(d.total_cost) / 1000000, 0) as total_cost'
)
->group('d.platform') // 按平台和日期进行分组
->select();
// dump(ThinkDb::getLastSql());
// 4. 获取tiktok数据并按 ad_id 分组，计算 revenue 的总和
$adRevenueData = $adRevenueQuery->field(
'd.ad_id, COALESCE(SUM(d.revenue) / 1000000, 0) as total_revenue' // 计算 revenue 的总和
)
->group('d.ad_id') // 按 ad_id 分组
->select();
// dump(ThinkDb::getLastSql());
// 定义字段映射关系
$fieldMapping = [
'meta' => [
'meta_ads' => 'spend', // 示例映射
'roas' => 'meta_roas',
'cpc' => 'cpc',
'cpm' => 'cpm',
'meta_purchases' => 'onsite_purchase',
'web_purchases' => 'offsite_purchase',
'purchases' => 'platform_purchase',
'meta_conversion_value' => 'meta_conversion_value',
'web_conversion_value' => 'web_conversion_value',
'conversion_value' => 'platform_purchase_value',
'cpoc' => 'cpoc',
'ctr' => 'ctr',
'revenue_per_link_click' => 'revenue_per_link_click',
'cpa' => 'cpa',
],
'google' => [
'google_ads' => 'spend', // 示例映射
'conversion_value' => 'platform_purchase_value',
'roas' => 'google_roas',
'conversions' => 'purchases',
'ctr' => 'ctr',
'cpa' => 'google_cpa',
'cpm' => 'cpm',
'clicks' => 'clicks',
'impressions' => 'impressions',
'all_conversions_value' => 'revenue',
'all_roas' => 'roas',
'all_conversions' => 'purchases',
'all_cpa' => 'cpa',
],
'tiktok' => [
'tiktok_ads' => 'spend', // 示例映射
'roas' => 'roas',
'impressions' => 'impressions',
'cpm' => 'cpm',
'cpc' => 'cpc',
'ctr' => 'ctr',
'cpa' => 'cpa',
'tiktok_shop_conversions' => 'tiktok_shop_conversion',
'tiktok_shop_conversion_value' => 'tiktok_shop_conversion_value',
'conversion_value' => 'platform_purchase_value',
'web_conversion_value' => 'revenue',
'purchases' => 'platform_purchase',
'web_purchases' => 'purchases',
'tiktok_gmv_max_ads' => 'max_ad_revenue',
],
];
// 初始化结果数组
$result = [
'data' => [
'meta' => array_fill_keys(array_keys($fieldMapping['meta']), '-'),
'google' => array_fill_keys(array_keys($fieldMapping['google']), '-'),
'tiktok' => array_fill_keys(array_keys($fieldMapping['tiktok']), '-'),
],
];
// 5. 计算最大的 total_revenue
$maxAdRevenue = 0;
foreach ($adRevenueData as $data) {
if ($data['total_revenue'] > $maxAdRevenue) {
$maxAdRevenue = $data['total_revenue'];
}
}
// 在 PHP 中计算指标
foreach ($adcycleData as $data) {
$platform = $data['platform']; // 获取平台类型
$spend = (float)$data['spend'];
$revenue = (float)$data['revenue'];
$totalCost = (float)$data['total_cost'];
$impressions = (int)$data['impressions'];
$clicks = (int)$data['clicks'];
$outbound_clicks = (int)$data['outbound_clicks'];
$purchases = (int)$data['purchases'];
$purchases_all = (int)$data['purchases_all'];
$tiktok_shop_conversion = (int)$data['tiktok_shop_conversion'];
$platform_purchase = (int)$data['platform_purchase'];
$onsite_purchase = (int)$data['onsite_purchase'];
$offsite_purchase = (int)$data['offsite_purchase'];
$purchases_value = (float)$data['purchases_value'];
$platform_purchase_value = (float)$data['platform_purchase_value'];
$conversion_value = $platform_purchase_value; //meta的$conversion_value=$platform_purchase_value
$tiktok_shop_conversion_value = (float)$data['tiktok_shop_conversion_value'];
$web_conversion_value = (float)$data['onsite_purchases_value'];
$meta_conversion_value = (float)$data['offsite_purchases_value'];
// 计算指标
$roas = ($spend == 0) ? 0 : $revenue / $spend;
$meta_roas = ($spend == 0) ? 0 : $conversion_value / $spend;
$google_roas = ($spend == 0) ? 0 : $purchases_value / $spend;
$ctr = ($impressions == 0) ? 0 : $clicks / $impressions;
$cpoc = ($outbound_clicks == 0) ? 0 : $spend / $outbound_clicks;
$cpa = ($platform_purchase == 0) ? 0 : $spend / $platform_purchase;
$google_cpa = ($platform_purchase == 0) ? 0 : $spend / $platform_purchase;
$cpm = ($impressions == 0) ? 0 : ($spend * 1000) / $impressions;
$cpc = ($clicks == 0) ? 0 : $spend / $clicks;
$conversionRate = ($clicks == 0) ? 0 : $purchases / $clicks;
$revenuePerLinkClick = ($outbound_clicks == 0) ? 0 : $conversion_value / $outbound_clicks;
// 根据平台类型映射数据
$platformKey = match ($platform) {
1 => 'meta',
2 => 'google',
3 => 'tiktok',
default => null,
};
if ($platformKey) {
foreach ($fieldMapping[$platformKey] as $targetField => $sourceField) {
$value = '-';
switch ($sourceField) {
case 'spend':
$value = '$' . number_format($spend, 2);
break;
case 'revenue':
$value = '$' . number_format($revenue, 2);
break;
case 'total_cost':
$value = '$' . number_format($totalCost, 2);
break;
case 'purchases_value':
$value = '$' . number_format($purchases_value, 2);
break;
case 'platform_purchase_value':
$value = '$' . number_format($platform_purchase_value, 2);
break;
case 'roas':
$value = round($roas, 2) . 'x';
break;
case 'meta_roas':
$value = round($meta_roas, 2) . 'x';
break;
case 'google_roas':
$value = round($google_roas, 2) . 'x';
break;
case 'cpoc':
$value = '$' . number_format($cpoc, 2);
break;
case 'ctr':
$value = number_format($ctr * 100, 2) . '%';
break;
case 'cpa':
$value = '$' . number_format($cpa, 2);
break;
case 'google_cpa':
$value = '$' . number_format($google_cpa, 2);
break;
case 'cpm':
$value = '$' . number_format($cpm, 2);
break;
case 'cpc':
$value = '$' . number_format($cpc, 2);
break;
case 'meta_conversion_value':
$value = '$' . number_format($meta_conversion_value, 2);
break;
case 'web_conversion_value':
$value = '$' . number_format($web_conversion_value, 2);
break;
case 'conversion_value':
$value = '$' . number_format($conversion_value, 2);
break;
case 'conversion_rate':
$value = $conversionRate;
break;
case 'tiktok_shop_conversion':
$value = number_format($tiktok_shop_conversion);
break;
case 'tiktok_shop_conversion_value':
$value = '$' . number_format($tiktok_shop_conversion_value, 2);
break;
case 'max_ad_revenue':
$value = '$' . number_format($maxAdRevenue, 2);
break;
case 'revenue_per_link_click':
$value = '$' . number_format($revenuePerLinkClick, 2);
break;
case 'purchases':
$value = number_format($purchases);
break;
case 'purchases_all':
$value = number_format($purchases_all);
break;
case 'platform_purchase':
$value = number_format($platform_purchase);
break;
case 'onsite_purchase':
$value = number_format($onsite_purchase);
break;
case 'offsite_purchase':
$value = number_format($offsite_purchase);
break;
case 'clicks':
$value = number_format($clicks);
break;
case 'impressions':
$value = number_format($impressions);
break;
default:
$value = '-';
break;
}
$result['data'][$platformKey][$targetField] = $value;
}
}
}
return $result;
// dump(ThinkDb::getLastSql());
// 5. 处理数据，按照周期进行分组
// $processedData = $this->processDataByCycle($adcycleData->toArray(), $cycle);
// 6. 返回处理后的数据
// return $adcycleData;
}
}