回传日志

modules/Callback/Http/Controllers/CallbackLogController.php

@@ -0,0 +1,104 @@
+<?php
+
+namespace Modules\Callback\Http\Controllers;
+
+use Catch\Base\CatchController;
+use Illuminate\Foundation\Validation\ValidatesRequests;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\DB;
+use Modules\Callback\Services\TiktokEventReportService;
+use Modules\Common\Errors\Errors;
+use Modules\Common\Exceptions\CommonBusinessException;
+
+class CallbackLogController extends CatchController
+{
+    use ValidatesRequests;
+    public function list(Request $request) {
+        $advertiserId = $request->input('advertiser_id');
+        $uid = $request->input('uid');
+        $advPromotionId = $request->input('adv_promotion_id');
+        $userRanseStartAtBeginTime = $request->input('user_ranse_start_at_begin_time');
+        $userRanseStartAtEndTime = $request->input('user_ranse_start_at_end_time');
+        $orderCreatedAtBeginTime = $request->input('order_created_at_begin_time');
+        $orderCreatedAtEndTime = $request->input('order_created_at_end_time');
+        $isExport = $request->input('is_export', false);
+
+        $sql = DB::table('callback_report_charge_record')
+            ->where([
+                'optimizer_uid' => $this->getLoginUserId()
+            ])->when($advertiserId, function ($query, $advertiserId) {
+                return $query->where('advertiser_id', $advertiserId);
+            })->when($uid, function ($query, $uid) {
+                return $query->where('uid', $uid);
+            })->when($advPromotionId, function ($query, $advPromotionId){
+                return $query->where('adv_promotion_id', $advPromotionId);
+            })->when($userRanseStartAtBeginTime, function ($query, $userRanseStartAtBeginTime){
+                return $query->where('user_ranse_start_at', '>=', $userRanseStartAtBeginTime);
+            })->when($userRanseStartAtEndTime, function ($query, $userRanseStartAtEndTime){
+                return $query->where('user_ranse_start_at', '<=', $userRanseStartAtEndTime);
+            })->when($orderCreatedAtBeginTime, function ($query, $orderCreatedAtBeginTime){
+                return $query->where('order_created_at', '>=', $orderCreatedAtBeginTime);
+            })->when($orderCreatedAtEndTime, function ($query, $orderCreatedAtEndTime) {
+                return $query->where('order_created_at', '<=', $orderCreatedAtEndTime);
+            });
+        if($isExport) {
+            $result = $sql->get();
+        } else {
+            $result = $sql->paginate($request->integer('limit', 15));
+        }
+        $advertisers = DB::table('juliang_account_callback_config')
+            ->where('company_uid', $this->getLoginUserId())
+            ->select('adv_account_id', 'adv_account_name')
+            ->get()->keyBy('adv_account_id');
+        $reportSuccessStr = [
+            0 => '回传失败',
+            1 => '回传成功',
+            2 => '补传成功',
+        ];
+        foreach ($result as $item) {
+            $item->advertiser_name = $advertisers->get($item->advertiser_id ?? -1)->adv_account_name ?? '';
+            if('ok' == $item->filter_type ) {
+                $item->filter_reason .= '-'. $reportSuccessStr[$item->report_success] ?? '';
+            }
+        }
+
+        return $result;
+    }
+
+    public function callbackAgain(Request $request) {
+        $this->validate($request, ['log_id' => 'required']);
+        $logId = $request->integer('log_id');
+
+        $record = DB::table('callback_report_charge_record')
+            ->where('id', $logId)
+            ->select('report_param')
+            ->first();
+        if(!$record || !$record->report_param) {
+            CommonBusinessException::throwError(Errors::CALLBACK_RECORD_NOT_EXISTS);
+        }
+
+        $requestInfo = \json_decode($record->report_param);
+        if(!$requestInfo) {
+            CommonBusinessException::throwError(Errors::CALLBACK_RECORD_LOG_ERROR);
+        }
+
+        $reportService = new TiktokEventReportService();
+        $result = $reportService->reportCharge($requestInfo);
+        $reportSuccess = 0;
+        if($result['result']) {
+            $resultContent = \json_decode($result['content'], true);
+            if(0 == $resultContent['code']) {
+                $reportSuccess = 2;
+            }
+        }
+        DB::table('callback_report_charge_record')
+            ->where('id', $logId)
+            ->update([
+                'report_result' => \json_encode($result),
+                'report_success' => $reportSuccess,
+                'updated_at' => date('Y-m-d H:i:s')
+            ]);
+
+        return 2 == $reportSuccess ? '补传成功' : '补传失败';
+    }
+}

modules/Callback/Services/TiktokEventReportService.php

@@ -0,0 +1,152 @@
+<?php
+
+namespace Modules\Callback\Services;
+
+use Exception;
+use GuzzleHttp\Client;
+
+/**
+ * 抖音数据回调---新版---使用事件管理模式
+ * ios加桌和普通抖音事件管理是一个回传逻辑
+ * 开发文档：https://event-manager.oceanengine.com/docs/8650/h5_api_docs/
+ */
+class TiktokEventReportService
+{
+    /**
+     * 充值用户事件类型
+     */
+    protected $charge_event_type = 'active_pay';
+    /**
+     * 注册用户事件类型
+     */
+    protected $register_event_type = 'active_register';
+    /**
+     * 激活事件类型
+     */
+    protected $active_event_type = 'active';
+    /**
+     * 次留事件类型
+     */
+    protected $rentention_event_type = 'next_day_open';
+    /**
+     * 付费ROI事件类型
+     */
+    protected $purchase_roi_event_type = 'purchase_roi';
+
+
+    /**
+     * 充值用户数据上报地址
+     */
+    protected $report_url = 'https://analytics.oceanengine.com/api/v2/conversion';
+
+    private $user;
+
+    public function __construct()
+    {
+
+    }
+
+    /**
+     * 付费上报
+     */
+    public function reportCharge($user, $amount=0)
+    {
+        return $this->report($this->report_url, [
+            'event_type' => $this->charge_event_type,
+            'context' => [
+                'ad' => [
+                    'callback' => $user->callback
+                ]
+            ],
+            'timestamp' => time()
+        ]);
+    }
+
+    /**
+     * 注册上报
+     */
+    public function reportRegister(DouyinUser $user)
+    {
+        return $this->report($this->report_url, [
+            'event_type' => $this->register_event_type,
+            'context' => [
+                'ad' => [
+                    'callback' => $user->callback
+                ]
+            ],
+            'timestamp' => time()
+        ]);
+    }
+
+    /**
+     * 次日留存上报
+     */
+    public function reportRentention()
+    {
+        return $this->report($this->report_url, [
+            'event_type' => $this->rentention_event_type,
+            'context' => [
+                'ad' => [
+                    'callback' => $this->user->callback
+                ]
+            ],
+            'timestamp' => time()
+        ]);
+    }
+
+    public function reportAddDesktop()
+    {
+        return [];
+    }
+
+    /**
+     * 激活上报
+     */
+    public function reportActive($user)
+    {
+        return $this->report($this->report_url, [
+            'event_type' => $this->active_event_type,
+            'context' => [
+                'ad' => [
+                    'callback' => $user->callback
+                ]
+            ],
+            'timestamp' => time()
+        ]);
+    }
+
+    /**
+     * 数据上报
+     */
+    public function report(string $url, array $query_params)
+    {
+        $result = false;
+        $content = '';
+        try {
+            myLog('tiktok_event_report')->info('report_param_event_tiktok:' . json_encode($query_params));
+
+            $client = new Client(['timeout' => 4]);
+            $response = $client->request('post', $url, ['json' => $query_params]);
+
+            $content = $response->getBody()->getContents();
+            myLog('tiktok_event_report')->info('report_result_event_tiktok:' . json_encode($content, true));
+
+            $status_code = $response->getStatusCode();
+            if ($status_code == 200) {
+                $result = true;
+            } else {
+                $result = false;
+            }
+        } catch (Exception $e) {
+            myLog('tiktok_event_report')->error('event_tiktok_ept:' . json_encode($query_params) . ' ept:' . $e->getMessage());
+        } finally {
+            $query_params['report_url'] = $url;
+            return [
+                'result' => $result,
+                'content' => $content,
+                'query_params' => $query_params,
+            ];
+        }
+    }
+
+}

modules/Common/Errors/Errors.php

@@ -14,4 +14,6 @@ class Errors
     public const  UPLOAD_IMAGE_ERROR= [500006, '上传图片不成功'];
     public const  JULIANG_ACCOUNT_EXISTS= [500101, '巨量广告账户已经存在'];
     public const  CALLBACK_RATE_TIME_RANGE_ERROR= [500102, '回传比例时间区间不合法'];
+    public const  CALLBACK_RECORD_NOT_EXISTS= [500103, '回传日志不存在'];
+    public const  CALLBACK_RECORD_LOG_ERROR= [500104, '回传日志补传信息缺失'];
 }