kwaiAD/app/Http/Controllers/Web/AdPlacementC...

<?php

namespace App\Http\Controllers\Web;

use App\Http\Controllers\Controller;
use App\Models\JxAdPlacementLog;
use App\Support\EmailQueue;
use App\Support\Log;
use App\Support\RedisModel;
use Illuminate\Http\Request;
use App\Services\AdPlacementService;

class AdPlacementController extends Controller
{
    public function handleCallback(Request $request)
    {
        try {
//            Log::info('快手监测链接回调数据记录', [
//                'data' => $request->all()
//            ], 'adPlacementLog');

            $data = AdPlacementService::processRequestData($request);

            RedisModel::lPush('adPlacementLog', json_encode($data, 1));

            return [
                'code' => 0,
                'message' => 'success',
                'data' => []
            ];

        } catch (\Exception $e) {
            $errorContext = [
                'request_data' => $request->all(),
                'file' => $e->getFile(),
                'line' => $e->getLine(),
                'message' => $e->getMessage(),
                'trace' => $e->getTraceAsString()
            ];

            Log::error('快手监测链接回调数据异常', $errorContext, 'adPlacementLog');

            // 发送邮件
            EmailQueue::rPush(
                '快手监测链接回调数据异常',
                json_encode($errorContext),
                ['song.shen@kuxuan-inc.com'],
                '聚星'
            );

            return [
                'code' => 500,
                'message' => 'Internal Server Error',
                'data' => []
            ];
        }
    }

    public function orderCallback(Request $request) {
        try{
           Log::info('大航海订单回调数据记录', [$request->all()], 'adPlacementLog');
//            EmailQueue::rPush(
//                '大航海订单回调数据记录',
//                json_encode($request->all()),
//                ['song.shen@kuxuan-inc.com'],
//                '聚星'
//            );

            # 解析数据
            $logId = $request->input('log_id');
            $transformType = $request->input('transformType');

            AdPlacementService::handleTransformData($logId, $transformType);

            return json_encode([
                "code" => 0, //0=成功，1=内部错误
                "message" => "success",
                "data" => []
            ]);
        } catch (\Exception $e) {
            $errorContext = [
                'request_data' => $request->all(),
                'file' => $e->getFile(),
                'line' => $e->getLine(),
                'message' => $e->getMessage(),
                'trace' => $e->getTraceAsString()
            ];

            Log::error('大航海订单回调数据记录异常', $errorContext, 'adPlacementLog');

            // 发送邮件
            EmailQueue::rPush(
                '大航海订单回调数据记录异常',
                json_encode($errorContext),
                ['song.shen@kuxuan-inc.com'],
                '聚星'
            );

            return [
                'code' => 1,
                'message' => 'Internal Server Error',
                'data' => []
            ];
        }

    }
}