diff --git a/app/controller/BpsAdController.php b/app/controller/BpsAdController.php index 6384f6b..7126e5d 100644 --- a/app/controller/BpsAdController.php +++ b/app/controller/BpsAdController.php @@ -80,7 +80,7 @@ class BpsAdController // 获取请求参数 // $startDate = $options['conditions']['startDate'] ?? null; // 开始日期 // $endDate = $options['conditions']['endDate'] ?? null; // 结束日期 - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); if (empty($accounts)) { return $this->successResponse(['data' => []], $request); } @@ -130,7 +130,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -174,16 +174,16 @@ class BpsAdController // 根据 platformType 获取第三方用户数据 if ($platformType === 1) { // 获取 Facebook 第三方用户数据 - $users = $this->bpsAdAccountService->getMetaThirdUsers(['uid' => $options['jwtClaims']['uid']]); + $users = $this->bpsAdAccountService->getMetaThirdUsers(['merchant_id' => $options['jwtClaims']['merchant_id']]); } elseif ($platformType === 2) { // 获取 Google 第三方用户数据 - $users = $this->bpsAdAccountService->getGoogleThirdUsers(['uid' => $options['jwtClaims']['uid']]); + $users = $this->bpsAdAccountService->getGoogleThirdUsers(['merchant_id' => $options['jwtClaims']['merchant_id']]); } elseif ($platformType === 3) { // 获取 TikTok 第三方用户数据 - $users = $this->bpsAdAccountService->getTiktokThirdUsers(['uid' => $options['jwtClaims']['uid']]); + $users = $this->bpsAdAccountService->getTiktokThirdUsers(['merchant_id' => $options['jwtClaims']['merchant_id']]); } else { // 根据 JWT claims 获取所有平台的第三方用户 - $users = $this->bpsAdAccountService->getAllThirdUsers(['uid' => $options['jwtClaims']['uid']]); + $users = $this->bpsAdAccountService->getAllThirdUsers(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($users)) { @@ -243,7 +243,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -301,7 +301,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -357,7 +357,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -411,7 +411,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -464,7 +464,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -517,7 +517,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -571,7 +571,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -626,7 +626,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -684,7 +684,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -741,7 +741,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -796,7 +796,7 @@ class BpsAdController $accounts = $this->bpsAdAccountService->getTiktokAdAccounts(['refresh_token' => $request->refresh_token_tiktok]); } else { // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); } if (empty($accounts)) { @@ -832,7 +832,7 @@ class BpsAdController // $dateRange = 'Last Week'; // 默认日期范围 // TODO: 匹配jwt的商户id还是登录用户id - $accounts = $this->bpsAdAccountService->getAllAdAccounts(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllAdAccounts(['merchant_id' => $options['jwtClaims']['merchant_id']]); if (empty($accounts)) { @@ -858,25 +858,31 @@ class BpsAdController // 可以加入一些公共方法 protected function successResponse($data, Request $request): Response { - if ($request->jwtNewToken) { - return new Response(200, - [ - 'Content-Type' => 'application/json', - 'X-New-Token' => $request->jwtNewToken - ], - json_encode($data, JSON_UNESCAPED_UNICODE)); - } else { - return Json([ - 'code' => 0, - 'msg' => 'ok', - 'data' => $data, - ]); + $responseData = [ + 'code' => 0, + 'msg' => 'ok', + 'data' => $data, + ]; + + // 如果 data 是空数组,转换为空对象 + if (is_array($data) && empty($data)) { + $responseData['data'] = new \stdClass(); } + // 如果有新 token,添加到 header + if ($request->jwtNewToken) { + return new Response(200, [ + 'Content-Type' => 'application/json', + 'X-New-Token' => $request->jwtNewToken, + ], json_encode($responseData, JSON_UNESCAPED_UNICODE)); + } + return Json($responseData); } - protected function errorResponse($code, $message, $data = []): Response + + protected + function errorResponse($code, $message, $data = []): Response { return Json([ 'code' => $code, diff --git a/app/controller/CustomerController.php b/app/controller/CustomerController.php index 26e6fd5..e57a2e6 100644 --- a/app/controller/CustomerController.php +++ b/app/controller/CustomerController.php @@ -27,18 +27,6 @@ class CustomerController */ private $googleAdsAccountService; - //绑定某个广告账号 - public function bindAdvertiser(Request $request) - { - $customerId = $request->input('customer_id'); // 需要绑定的广告账号 ID - $thirdUserId = $request->input('third_user_id'); // bps_third_user的id - $googleOAuthService = new GoogleOAuthService(); - $hasThirdUser = $googleOAuthService->bindThirdUserAdvertiser($customerId, $thirdUserId); - if (!$hasThirdUser) { - return $this->errorResponse(300, 'Invalid state parameter'); - } - return $this->successResponse($hasThirdUser); - } public function getCustomerList(Request $request) { diff --git a/app/controller/OAuthController.php b/app/controller/OAuthController.php index aab1419..4c3a906 100644 --- a/app/controller/OAuthController.php +++ b/app/controller/OAuthController.php @@ -30,7 +30,7 @@ class OAuthController public function getAuthCode(Request $request) { - $state = $request->get('state') ?? $request->jwtClaims['uid']; + $state = $request->get('state') ?? $request->jwtClaims['merchant_id']; $authUrl = $this->googleOAuthService->getAuthUrl($state); return $this->successResponse([ 'url' => $authUrl, @@ -48,7 +48,8 @@ class OAuthController 'google' => ['status' => 0], 'tiktok' => ['status' => 0], ]; - $accounts = $this->bpsAdAccountService->getAllThirdUsers(['uid' => $options['jwtClaims']['uid']]); +// $accounts = $this->bpsAdAccountService->getAllThirdUsers(['uid' => $options['jwtClaims']['uid']]); + $accounts = $this->bpsAdAccountService->getAllThirdUsers(['merchant_id' => $options['jwtClaims']['merchant_id']]); foreach ($accounts as $account) { $authorizedThirdUsers[$account['third_type']] = [ @@ -64,7 +65,8 @@ class OAuthController public function handleCallback(Request $request) { - $state = $request->input('state') ?? $request->jwtClaims['uid']; +// $state = $request->input('state') ?? $request->jwtClaims['uid']; + $state = $request->input('state') ?? $request->jwtClaims['merchant_id']; $code = $request->input('code'); // 授权码 if (!$state) { @@ -123,10 +125,10 @@ class OAuthController // $customerId = isset($requestData['customer_id']) ? $requestData['customer_id'] : getenv('GOOGLE_ADS_CUSTOMER_ID'); // $customerId = getenv('GOOGLE_ADS_CUSTOMER_ID'); //临时指定 - $uid = $request->input('user_id') ?? $request->jwtClaims['uid']; + $merchant_id = $request->input('merchant_id') ?? $request->jwtClaims['merchant_id']; // 通过 advertiser_id 查询 ThirdUserAdvertiser,联表查询 ThirdUser 数据 - $thirdUser = ThirdUser::where('user_id', $uid)->where('third_type', 'google')->find(); // 获取第一个结果 + $thirdUser = ThirdUser::where('merchant_id', $merchant_id)->where('third_type', 'google')->find(); // 获取第一个结果 // dump($thirdUser); return ($uid); if (!$thirdUser) { return $this->errorResponse(300, '未授权'); diff --git a/app/event/GoogleAdsCustomers.php b/app/event/GoogleAdsCustomers.php index b0f65df..0f22c61 100644 --- a/app/event/GoogleAdsCustomers.php +++ b/app/event/GoogleAdsCustomers.php @@ -69,7 +69,7 @@ class GoogleAdsCustomers // $customerId = $account['customer_id']; // dump($customerId, $thirdUser->id, $rootAccountId, $account); // if($account['customer_id'] == 1509096882)continue; - $this->googleOAuthService->saveThirdUserAdvertiser($account['customer_id'], $thirdUser->id, $rootAccountId, $account); + $this->googleOAuthService->saveThirdUserAdvertiser($account['customer_id'], $thirdUser->id, $rootAccountId, $account,$thirdUser->merchant_id); } } $this->googleOAuthService->updateThirdUserDefault($thirdUser->id, 't'); @@ -103,7 +103,8 @@ class GoogleAdsCustomers $account['customer_id'], $thirdUser->id, $rootId, - $account + $account, + $thirdUser->merchant_id ); } } diff --git a/app/middleware/OauthCheck.php b/app/middleware/OauthCheck.php index e8e7b7f..001b121 100644 --- a/app/middleware/OauthCheck.php +++ b/app/middleware/OauthCheck.php @@ -16,9 +16,11 @@ class OauthCheck implements MiddlewareInterface $requestData = $request->all(); // 获取请求数据 // $customerId = isset($requestData['ad_customer_id']) ? $requestData['ad_customer_id'] : getenv('GOOGLE_ADS_CUSTOMER_ID'); - $uid = $request->jwtClaims['uid']; +// $uid = $request->jwtClaims['uid']; + $merchant_id = $request->jwtClaims['merchant_id']; // 查询指定 user_id 的 ThirdUser - $thirdUser = ThirdUser::where('user_id', $uid)->where('third_type', 'google')->find(); +// $thirdUser = ThirdUser::where('user_id', $uid)->where('third_type', 'google')->find(); + $thirdUser = ThirdUser::where('merchant_id', $merchant_id)->where('third_type', 'google')->find(); if ($thirdUser && $thirdUser->access_token) { // 获取 access_token diff --git a/app/middleware/OauthThirdCheck.php b/app/middleware/OauthThirdCheck.php index 72e081d..5f89815 100644 --- a/app/middleware/OauthThirdCheck.php +++ b/app/middleware/OauthThirdCheck.php @@ -16,9 +16,11 @@ class OauthThirdCheck implements MiddlewareInterface $requestData = $request->all(); // 获取请求数据 // $customerId = isset($requestData['ad_customer_id']) ? $requestData['ad_customer_id'] : getenv('GOOGLE_ADS_CUSTOMER_ID'); - $uid = $request->jwtClaims['uid']; +// $uid = $request->jwtClaims['uid']; + $merchant_id = $request->jwtClaims['merchant_id']; // 查询指定 user_id 的 ThirdUser - $thirdUserGoogle = ThirdUser::where('user_id', $uid)->where('third_type', 'google')->find(); +// $thirdUserGoogle = ThirdUser::where('user_id', $uid)->where('third_type', 'google')->find(); + $thirdUserGoogle = ThirdUser::where('merchant_id', $merchant_id)->where('third_type', 'google')->find(); if ($thirdUserGoogle && $thirdUserGoogle->access_token) { // 获取 access_token $request->refresh_token_google = $thirdUserGoogle->access_token; @@ -31,12 +33,14 @@ class OauthThirdCheck implements MiddlewareInterface // dump( $request->access_token,$request->login_customer_id); } } - $thirdUserFacebook = ThirdUser::where('user_id', $uid)->where('third_type', 'facebook')->find(); +// $thirdUserFacebook = ThirdUser::where('user_id', $uid)->where('third_type', 'facebook')->find(); + $thirdUserFacebook = ThirdUser::where('merchant_id', $merchant_id)->where('third_type', 'facebook')->find(); if ($thirdUserFacebook && $thirdUserFacebook->access_token) { // 获取 access_token $request->refresh_token_facebook = $thirdUserFacebook->access_token; } - $thirdUserTiktok = ThirdUser::where('user_id', $uid)->where('third_type', 'tiktok')->find(); +// $thirdUserTiktok = ThirdUser::where('user_id', $uid)->where('third_type', 'tiktok')->find(); + $thirdUserTiktok = ThirdUser::where('merchant_id', $merchant_id)->where('third_type', 'tiktok')->find(); if($thirdUserTiktok && $thirdUserTiktok->access_token){ $request->refresh_token_tiktok = $thirdUserTiktok->access_token; } diff --git a/app/service/BpsAdAccountService.php b/app/service/BpsAdAccountService.php index 543e97e..c48ed1f 100644 --- a/app/service/BpsAdAccountService.php +++ b/app/service/BpsAdAccountService.php @@ -142,7 +142,7 @@ class BpsAdAccountService // 获取符合条件的客户ID数组 $customers = ThirdUserAdvertiser::alias('tua') ->join('bps.bps_third_user tu', 'tua.doc_ = tu.id') // 连接 bps_third_user 表 - ->where('tu.user_id', $options['uid']) // 筛选 third_type 为 google 的记录 + ->where('tu.merchant_id', $options['merchant_id']) // 筛选 third_type 为 google 的记录 ->where('tu.access_token', '<>', '') // 筛选 access_token 不为空的记录 ->field('tua.advertiser_id as account_id, tu.access_token as refresh_token') // 获取 advertiser_id 字段 ->order('tu.third_type', 'asc') // 获取 advertiser_id 字段 @@ -163,14 +163,13 @@ class BpsAdAccountService // 获取 Facebook 第三方用户数据 public function getMetaThirdUsers($options = []) { - $uid = $options['uid'] ?? null; - - if ($uid) { + $merchant_id = $options['merchant_id'] ?? null; + if ($merchant_id) { // 根据 UID 获取符合条件的用户数据 $users = ThirdUserAdvertiser::alias('tua') ->join('bps.bps_third_user tu', 'tua.doc_ = tu.id') // 连接 bps_third_user 表 ->where('tu.third_type', 'facebook') // 筛选 third_type 为 facebook 的记录 - ->where('tu.user_id', $uid) // 筛选 user_id 的记录 + ->where('tu.merchant_id', $merchant_id) // 筛选 merchant_id 的记录 ->where('tu.access_token', '<>', '') // 筛选 access_token 不为空的记录 ->field('tu.id, tu.access_token as refresh_token') // 获取相关字段 ->select(); @@ -195,14 +194,14 @@ class BpsAdAccountService // 获取 Google 第三方用户数据 public function getGoogleThirdUsers($options = []) { - $uid = $options['uid'] ?? null; + $merchant_id = $options['merchant_id'] ?? null; - if ($uid) { + if ($merchant_id) { // 获取符合条件的用户数据 $users = ThirdUserAdvertiser::alias('tua') ->join('bps.bps_third_user tu', 'tua.doc_ = tu.id') // 连接 bps_third_user 表 ->where('tu.third_type', 'google') // 筛选 third_type 为 google 的记录 - ->where('tu.user_id', $uid) // 筛选 user_id 的记录 + ->where('tu.merchant_id', $merchant_id) // 筛选 merchant_id 的记录 ->where('tu.access_token', '<>', '') // 筛选 access_token 不为空的记录 ->field('tu.id, tu.access_token as refresh_token') // 获取相关字段 ->select(); @@ -226,15 +225,15 @@ class BpsAdAccountService // 获取 TikTok 第三方用户数据 public function getTiktokThirdUsers($options = []) { - $uid = $options['uid'] ?? null; + $merchant_id = $options['merchant_id'] ?? null; - if ($uid) { + if ($merchant_id) { // $refreshToken = $options['refresh_token']; // 获取符合条件的用户数据 $users = ThirdUserAdvertiser::alias('tua') ->join('bps.bps_third_user tu', 'tua.doc_ = tu.id') // 连接 bps_third_user 表 ->where('tu.third_type', 'tiktok') // 筛选 third_type 为 tiktok 的记录 - ->where('tu.user_id', $uid) // 筛选 user_id 的记录 + ->where('tu.merchant_id', $merchant_id) // 筛选 merchant_id 的记录 ->where('tu.access_token', '<>', '') // 筛选 access_token 不为空的记录 ->field('tu.id, tu.access_token as refresh_token') // 获取相关字段 ->select(); @@ -258,12 +257,13 @@ class BpsAdAccountService // 获取所有平台的第三方用户数据 public function getAllThirdUsers($options = []) { - $userId = $options['uid']; // 获取用户ID +// $userId = $options['uid']; // 获取用户ID + $merchantId = $options['merchant_id']; // 获取用户ID // 获取符合条件的用户数据 $users = ThirdUserAdvertiser::alias('tua') ->join('bps.bps_third_user tu', 'tua.doc_ = tu.id') // 连接 bps_third_user 表 - ->where('tu.user_id', $userId) // 筛选 user_id 的记录 + ->where('tu.merchant_id', $merchantId) // 筛选 merchant_id 的记录 ->where('tu.access_token', '<>', '') // 筛选 access_token 不为空的记录 ->field('tu.id, tu.third_type, tu.access_token as refresh_token') // 获取相关字段 ->select(); diff --git a/app/service/GoogleOAuthService.php b/app/service/GoogleOAuthService.php index 4fa7d18..456c1be 100644 --- a/app/service/GoogleOAuthService.php +++ b/app/service/GoogleOAuthService.php @@ -92,7 +92,7 @@ class GoogleOAuthService } //保存或更新某个主体部广告账号 - public function saveThirdUserAdvertiser($customer_id, $third_user_id, $login_customer_id, $customer) + public function saveThirdUserAdvertiser($customer_id, $third_user_id, $login_customer_id, $customer, $merchant_id) { // 确保 customer_id 和 third_user_id 是字符串 $customer_id = (string)$customer_id; @@ -103,6 +103,7 @@ class GoogleOAuthService 'advertiser_id' => $customer_id, 'advertiser_name' => $customer['descriptive_name'], 'google_login_customer_id' => $login_customer_id, + 'merchant_id' => $merchant_id, ]; if ($customer['manager'] === true) { $data['google_manager'] = 't'; @@ -117,35 +118,20 @@ class GoogleOAuthService // dump($data); $sql = " INSERT INTO {$tableName} - (advertiser_id,advertiser_name, doc_,google_login_customer_id,google_manager,google_test_account) - VALUES (:advertiser_id, :advertiser_name,:doc_,:google_login_customer_id,:google_manager,:google_test_account) + (advertiser_id,advertiser_name, doc_,google_login_customer_id,google_manager,google_test_account,merchant_id) + VALUES (:advertiser_id, :advertiser_name,:doc_,:google_login_customer_id,:google_manager,:google_test_account,:merchant_id) ON CONFLICT (advertiser_id,doc_) DO UPDATE SET advertiser_name = EXCLUDED.advertiser_name, google_login_customer_id = EXCLUDED.google_login_customer_id, google_manager = EXCLUDED.google_manager, - google_test_account = EXCLUDED.google_test_account + google_test_account = EXCLUDED.google_test_account, + merchant_id = EXCLUDED.merchant_id "; // dump($sql,$data); ThinkDb::execute($sql, $data); } - //绑定某个主体的广告账号 - public function bindThirdUserAdvertiser($customer_id, $third_user_id) - { - $tableName = 'bps_third_user'; - $tableName = getenv('DB_PG_SCHEMA') ? getenv('DB_PG_SCHEMA') . '.' . $tableName : 'bps' . $tableName; - $data = [ - 'id' => $third_user_id, - 'user_id' => $customer_id,]; - $sql = " - UPDATE {$tableName} - SET user_id = :user_id - WHERE id = :id - "; - ThinkDb::execute($sql, $data); - } - public function updateThirdUserDefault($third_user_id, $is_default = 't'): void { $tableName = 'bps_third_user'; @@ -181,7 +167,7 @@ class GoogleOAuthService $tableName = getenv('DB_PG_SCHEMA') ? getenv('DB_PG_SCHEMA') . '.' . $tableName : 'bps' . $tableName; if (!empty($state)) { - $thirdUser = ThirdUser::where('user_id', $state)->where('third_type', 'google')->find(); // 获取第一个结果 + $thirdUser = ThirdUser::where('merchant_id', $state)->where('third_type', 'google')->find(); // 获取第一个结果 // dump($thirdUser); return ($uid); if ($thirdUser) { $data['id'] = $thirdUser->id; @@ -194,11 +180,11 @@ class GoogleOAuthService WHERE id = :id "; } else { - $data['user_id'] = $state; + $data['merchant_id'] = $state; $sql = " INSERT INTO {$tableName} - (access_token, is_default, third_type, user_id) - VALUES (:access_token, :is_default, :third_type, :user_id) + (access_token, is_default, third_type, merchant_id) + VALUES (:access_token, :is_default, :third_type, :merchant_id) "; } } else { @@ -216,21 +202,6 @@ class GoogleOAuthService $this->queue($options); } - public function updateRefreshToken($refreshToken) - { - $customer_id = getenv('GOOGLE_ADS_CUSTOMER_ID'); - //暂时update进行绑定 - $tableName = "bps.bps_third_user"; -// $sql = "UPDATE {$tableName} SET access_token = :access_token WHERE random_code = :random_code"; - $sql = "UPDATE {$tableName} SET access_token = :access_token WHERE user_id = :user_id"; - $data = [ - 'access_token' => $refreshToken, // 这里的 $accessToken 是您想要匹配的值 - 'user_id' => $customer_id, // 这里的 $accessToken 是您想要匹配的值 - ]; - // 执行 SQL 语句 - $result = ThinkDb::execute($sql, $data); - } - public function revokeToken($accessToken, $third_user_id) { diff --git a/config/route.php b/config/route.php index d9267c2..61f3935 100644 --- a/config/route.php +++ b/config/route.php @@ -153,7 +153,6 @@ Route::group('/googleads', function () { ]); Route::group('/customer', function () { Route::post('/list', [CustomerController::class, 'getCustomerList']); - Route::post('/bind', [CustomerController::class, 'bindAdvertiser']); Route::post('/list_resource', [CustomerController::class, 'accessibleCustomers']); Route::post('/list_tree', [CustomerController::class, 'accountHierarchy']); Route::post('/access_role', [CustomerController::class, 'accountAccess']);