标签页角标数字（Accounts、Campaigns、Ad Sets 、Ads、Creatives）更新3 +导出广告系列列表到 Excel 更新1

app/controller/BpsAdController.php

@@ -53,6 +53,34 @@ class BpsAdController
      */
     private $bpsAdAccountService;
 
+    /*
+     * 返回标签页角标数字接口
+     *
+     */
+    public function listAdBadges(Request $request)
+    {
+        $options              = $request->all();
+        $options['jwtClaims'] = $request->jwtClaims;
+
+        // 获取请求参数
+//        $startDate         = $options['conditions']['startDate'] ?? null;  // 开始日期
+//        $endDate           = $options['conditions']['endDate'] ?? null;  // 结束日期
+        $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]);
+        if (empty($accounts)) {
+            return $this->successResponse(['data' => []], $request);
+        }
+        $accountIds        = array_unique(array_column($accounts, 'account_id'));
+        $endDateLastWeek   = (int)date('Ymd');
+        $startDateLastWeek = (int)date('Ymd', strtotime('-6 days'));
+//        dump($startDateLastWeek, $endDateLastWeek);
+//        if ($startDateLastWeek === $startDate && $endDateLastWeek === $endDate) {
+        $ad_data_count = $this->adsInsightService::getAdCountData($accountIds, $startDateLastWeek, $endDateLastWeek);
+//        } else {
+//            $ad_data_count = [];
+//        }
+ // 返回结果
+        return $this->successResponse($ad_data_count, $request);
+    }
 
     public function listThirdUsers(Request $request)
     {
@@ -97,14 +125,6 @@ class BpsAdController
         // 获取客户ID数组
         $accountIds = array_unique(array_column($accounts, 'account_id'));
 
-        $endDateLastWeek   = (int)date('Ymd');
-        $startDateLastWeek = (int)date('Ymd', strtotime('-6 days'));
-//        dump($startDateLastWeek, $endDateLastWeek);
-        if ($startDateLastWeek === $startDate && $endDateLastWeek === $endDate) {
-            $ad_data_count = $this->adsInsightService::getAdCountData($accountIds,$startDate, $endDate);
-        } else {
-            $ad_data_count = [];
-        }
 
         // 调用 Service 层查询广告列表
         $result = $this->adsInsightService::getAccountList(
@@ -117,7 +137,6 @@ class BpsAdController
             $endDate,          // 结束日期
         );
 
-        $result['ad_data_count'] = $ad_data_count;
 
         // 返回结果
         return $this->successResponse($result, $request);
@@ -291,6 +310,60 @@ class BpsAdController
 //        return $this->errorResponse(300,'授权失败');
     }
 
+    public function exportCampaignsToExcel(Request $request)
+    {
+        $options              = $request->all();
+        $options['jwtClaims'] = $request->jwtClaims;
+
+        // 获取请求参数
+        $page         = $options['pageNo'] ?? 1;  // 页码
+        $pageSize     = $options['pageSize'] ?? 1000;  // 每页数量
+        $keyword      = $options['conditions']['keyword'] ?? '';  // 关键字搜索
+        $platformType = $options['conditions']['platformType'] ?? 0;  // 关键字搜索
+        $status       = $options['conditions']['status'] ?? 0;  // 平台类型
+        $startDate    = $options['conditions']['startDate'] ?? null;  // 开始日期
+        $endDate      = $options['conditions']['endDate'] ?? null;  // 结束日期
+//        $dateRange    = 'Last Week';  // 默认日期范围
+        // 根据 platformType 获取广告账户
+        if ($platformType === 1) {
+            if (!$request->refresh_token_facebook) {
+                return $this->successResponse(['data' => []], $request);
+            }
+            $accounts = $this->bpsAdAccountService->getMetaAdAccounts(['refresh_token' => $request->refresh_token_facebook]);
+        } elseif ($platformType === 2) {
+            if (!$request->refresh_token_google) {
+                return $this->successResponse(['data' => []], $request);
+            }
+            $accounts = $this->bpsAdAccountService->getGoogleAdAccounts(['refresh_token' => $request->refresh_token_google]);
+        } elseif ($platformType === 3) {
+            if (!$request->refresh_token_tiktok) {
+                return $this->successResponse(['data' => []], $request);
+            }
+            $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]);
+        } else {
+            // TODO: 匹配jwt的商户id还是登录用户id
+            $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]);
+        }
+
+        if (empty($accounts)) {
+            return $this->successResponse(['data' => []], $request);
+        }
+
+        // 获取客户ID数组
+        $accountIds = array_column($accounts, 'account_id');
+        // 调用 Service 层查询
+        return $this->adsInsightService::exportCampaignsToExcel(
+            $platformType,
+            $accountIds,   // 客户 ID 数组
+            $page,          // 页码
+            $pageSize,      // 每页数量
+            $keyword,       // 关键字
+            $startDate,     // 开始日期
+            $endDate,        // 结束日期
+            $status
+        );
+    }
+
     public function listAdsets(Request $request)
     {
         $options              = $request->all();

app/service/AdsInsightService.php

@@ -174,9 +174,7 @@ class AdsInsightService
         // 动态构建日期条件
         $dateCondition = '';
         if ($startDate && $endDate) {
-            $query->leftJoin('bps.bps_ads_insights d', "c.campaign_id = d.ad_campaign_id AND c.platform_type = d.platform AND {$dateCondition}");
             $dateCondition = "d.date BETWEEN '{$startDate}' AND '{$endDate}'";
-        } else {
         }
         $query->leftJoin('bps.bps_ads_insights d', "c.campaign_id = d.ad_campaign_id AND c.platform_type = d.platform AND {$dateCondition}")
             ->field('c.campaign_id, c.status as status, c.name, c.account_id,c.platform_type,
@@ -305,6 +303,81 @@ class AdsInsightService
         ];
     }
 
+    /**
+     * 导出广告系列列表到 Excel
+     *
+     * @param int $platformType 平台类型
+     * @param array $customerIds 客户ID列表
+     * @param int $page 当前页码
+     * @param int $pageSize 每页条数
+     * @param string $keyword 关键字
+     * @param string|null $startDate 开始日期
+     * @param string|null $endDate 结束日期
+     * @param int $status 广告系列状态
+     */
+    public static function exportCampaignsToExcel($platformType, $customerIds, $page, $pageSize, $keyword, $startDate = null, $endDate = null, $status = 0)
+    {
+        $campaignsStatus = [
+            0 => 'UNSPECIFIED',  // UNSPECIFIED
+            1 => 'UNKNOWN',  // UNKNOWN
+            2 => 'ENABLED',  // ENABLED
+            3 => 'PAUSED',  // PAUSED
+            4 => 'REMOVED',  // REMOVED
+        ];
+
+        // 调用 getCampaignList 获取广告系列数据
+        $campaignList = self::getCampaignList($platformType, $customerIds, $page, $pageSize, $keyword, $startDate, $endDate, $status, false);
+
+        if (empty($campaignList['data'])) {
+            return ['message' => 'No campaign data available for export.'];
+        }
+
+        // 创建 Spreadsheet 对象
+        $spreadsheet = new Spreadsheet();
+        $sheet       = $spreadsheet->getActiveSheet();
+
+        // 设置表头
+        $headers = [
+            'A1' => 'Campaign ID', 'B1' => 'Status', 'C1' => 'Name',
+            'D1' => 'Platform', 'E1' => 'Clicks', 'F1' => 'Spend',
+            'G1' => 'Impressions', 'H1' => 'Revenue', 'I1' => 'Purchases'
+        ];
+        foreach ($headers as $cell => $header) {
+            $sheet->setCellValue($cell, $header);
+        }
+
+        // 填充数据
+        $row = 2;
+        foreach ($campaignList['data'] as $campaign) {
+//            $sheet->setCellValueExplicit('A' . $row, (string)$campaign['campaign_id'], \PhpOffice\PhpSpreadsheet\Cell\DataType::TYPE_STRING);
+            $sheet->setCellValue('A' . $row, $campaign['id']);
+            $sheet->setCellValue('B' . $row, $campaignsStatus[$campaign['status']]);
+            $sheet->setCellValue('C' . $row, $campaign['name']);
+            $sheet->setCellValue('D' . $row, $campaign['platform_type']);
+            $sheet->setCellValue('E' . $row, $campaign['clicks']);
+            $sheet->setCellValue('F' . $row, $campaign['spend']);
+            $sheet->setCellValue('G' . $row, $campaign['impressions']);
+            $sheet->setCellValue('H' . $row, $campaign['revenue']);
+            $sheet->setCellValue('I' . $row, $campaign['purchases']);
+            $row++;
+        }
+
+
+        // 文件名与路径
+        $fileName = 'Exported_Campaigns_' . date('Y-m-d_H-i-s') . '.xlsx';
+        $filePath = public_path() . '/' . $fileName;
+
+        // 保存 Excel 文件
+        $writer = new Xlsx($spreadsheet);
+        try {
+            $writer->save($filePath);
+            return response()->download($filePath, $fileName);
+        } catch (\Exception $e) {
+            return ['success' => false, 'message' => $e->getMessage()];
+        }
+    }
+
+
     /**
      * 获取广告组列表
      */
@@ -340,13 +413,13 @@ class AdsInsightService
         $dateCondition = '';
         if ($startDate && $endDate) {
             $dateCondition = "d.date BETWEEN '{$startDate}' AND '{$endDate}'";
-            $query->leftJoin('bps.bps_ads_insights d', "s.ad_set_id = d.ad_set_id AND s.platform_type = d.platform AND {$dateCondition}");
+
         }
 
         // 基础查询：广告组和日数据表联接
-
+        $query->leftJoin('bps.bps_ads_insights d', "s.ad_set_id = d.ad_set_id AND s.platform_type = d.platform AND {$dateCondition}")
-        $query->leftJoin('bps.bps_ads_campaign c', 's.campaign_id = c.campaign_id') // 联接广告系列表
+            ->leftJoin('bps.bps_ads_campaign c', 's.campaign_id = c.campaign_id') // 联接广告系列表
-        ->field('s.ad_set_id, s.status as status, s.name, s.account_id,s.platform_type,c.name as campaign_name,
+            ->field('s.ad_set_id, s.status as status, s.name, s.account_id,s.platform_type,c.name as campaign_name,
             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,
@@ -504,12 +577,13 @@ class AdsInsightService
         $dateCondition = '';
         if ($startDate && $endDate) {
             $dateCondition = "d.date BETWEEN '{$startDate}' AND '{$endDate}'";
-            $query->leftJoin('bps.bps_ads_insights d', "a.advertiser_id = d.account_id AND {$dateCondition}");
+
         }
 
         // 基础查询：广告和日数据表联接
         // 其他联表及字段计算
-        $query->leftJoin('bps.bps_third_user u', 'a.doc_ = u.id')
+        $query->leftJoin('bps.bps_ads_insights d', "a.advertiser_id = d.account_id AND {$dateCondition}")
+            ->leftJoin('bps.bps_third_user u', 'a.doc_ = u.id')
             ->field('a.advertiser_id, a.advertiser_name,u.third_type,
         COALESCE(SUM(d.assisted_purchases), 0) as assisted_purchases,
         COALESCE(SUM(d.last_clicked_purchases), 0) as last_clicked_purchases,
@@ -673,12 +747,13 @@ class AdsInsightService
         $dateCondition = '';
         if ($startDate && $endDate) {
             $dateCondition = "d.date BETWEEN '{$startDate}' AND '{$endDate}'";
-            $query->leftJoin('bps.bps_ads_insights d', "a.ad_id = d.ad_id AND a.platform_type = d.platform AND {$dateCondition}");
+
         }
 
         // 基础查询：广告和日数据表联接
-        $query->leftJoin('bps.bps_ads_set s', 'a.ad_set_id = s.ad_set_id')  // 联接广告组表，获取 ad_set_name
+        $query->leftJoin('bps.bps_ads_insights d', "a.ad_id = d.ad_id AND a.platform_type = d.platform AND {$dateCondition}")
-        ->field('a.ad_id, a.status as status, a.name, a.account_id,a.platform_type,s.name as ad_set_name,
+            ->leftJoin('bps.bps_ads_set s', 'a.ad_set_id = s.ad_set_id')  // 联接广告组表，获取 ad_set_name
+            ->field('a.ad_id, a.status as status, a.name, a.account_id,a.platform_type,s.name as ad_set_name,
         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,
@@ -1108,7 +1183,7 @@ class AdsInsightService
         if (!empty($customerIds)) {
             $creativeDataQuery->whereIn('i.account_id', $customerIds);
         } else {
-            return $countOnly ? 0 :[
+            return $countOnly ? 0 : [
                 'data' => [],
                 'total' => 0,
                 'statistics' => [],

config/route.php

@@ -48,7 +48,7 @@ Route::group('/marketing', function () {
 
         Route::group('/campaign', function () {
             Route::post('/list', [BpsAdController::class, 'listCampaigns']);
-//            Route::post('/export', [BpsAdController::class, 'exportCampaignsToExcel']);
+            Route::post('/export', [BpsAdController::class, 'exportCampaignsToExcel']);
 //            Route::group('/status', function () {
 //                Route::post('/update', [BpsAdController::class, 'updateCampaignStatus']);
 //                Route::post('/get', [BpsAdController::class, 'getCampaignStatus']);
@@ -74,6 +74,12 @@ Route::group('/marketing', function () {
             app\middleware\JwtLocal::class,
             app\middleware\OauthThirdCheck::class,
         ]);
+        Route::group('/badge', function () {
+            Route::post('/list', [BpsAdController::class, 'listAdBadges']);
+        })->middleware([
+            app\middleware\JwtLocal::class,
+            app\middleware\OauthThirdCheck::class,
+        ]);
         Route::group('/creative', function () {
             Route::post('/list', [BpsAdController::class, 'listCreatives']);
             Route::post('/chart', [BpsAdController::class, 'listCharts']);