duanju_crontab_script/app/Jobs/Callback/RechargeReport.php

<?php

namespace App\Jobs\OrangeSite;

use App\Modules\Callback\Models\ChannelCallbackConfig;
use App\Modules\Callback\Services\CallbackBaseService;
use App\Modules\OrangeSite\Services\CheckReport\EnableReportCheck;
use App\Modules\OrangeSite\Services\CheckReport\OrderAlreadyReportCheck;
use App\Modules\OrangeSite\Services\CheckReport\PromotionProtectCheck;
use App\Modules\OrangeSite\Services\CheckReport\RechargeAmountCheck;
use App\Modules\OrangeSite\Services\CheckReport\ReportRateCheck;
use App\Modules\OrangeSite\Services\CheckReport\ReportRechargeTypeCheck;
use App\Modules\OrangeSite\Services\OrangeSitePromotionService;
use App\Modules\OrangeSite\Services\OrangeSiteRechargeReportCheckContext;
use App\Modules\OrangeSite\Services\OrangeSiteReportRateService;
use App\Modules\Order\Models\ReportUserChargeRecord;
use App\Modules\Trace\TraceContext;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Pipeline\Pipeline;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\DB;

class RechargeReport implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public const QUEUE = '{orangeSite}.report.recharge';
    public const CONNECTION = 'redis_queue';

    public const PLATFORM = 'orange';
    /**
     * @var array
     * <pre>
     * [
     *      'channelId' => 'xxx, // 站点id
     *      'orderId' => 'xxx', // 订单id
     *      'uid' => 'xxx', // 充值用户uid
     * ]
     * </pre>
     */
    private $reportInfo;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct(array $reportInfo)
    {
        $this->reportInfo = $reportInfo;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $traceContext = new TraceContext();
        \Log::info('[orangeSiteRechargeReport]开始回传', [
            'reportInfo' => $this->reportInfo,
            'traceInfo' => $traceContext->getTraceInfo()
        ]);
        $user = DB::table('users')->find(($this->reportInfo['uid'] ?? -1));
        $order = DB::table('orders')->where([
            ['id', '=', ($this->reportInfo['orderId'] ?? -1)],
            ['status', '=', 'PAID']
        ])->first();
        $channelCallbackConfig = ChannelCallbackConfig::where('channel_id', ($this->reportInfo['channelId'] ?? -1))
            ->where('platform', self::PLATFORM)->first();

        $channelSettingRate = OrangeSiteReportRateService::getChannelSettingReportRate($user->distribution_channel_id);
        $reportCheckContext = new OrangeSiteRechargeReportCheckContext($user, $order, $channelCallbackConfig,
            $traceContext, $channelSettingRate);

        try {
            $reportCheckContext->checkNecessaryInfo();
        } catch (\Exception $exception) {
            \Log::error('[orangeSiteRechargeReport]回传基础信息有误', [
                'message' => $exception->getMessage(),
                'traceInfo' => $traceContext->getTraceInfo()
            ]);
            dingTalkAlert(config('common.orangeSite.dingTalkUrl'), "[orangeSite]订单回传基础信息有误报警:\r\n" .
                \json_encode([
                    'reportInfo' => $this->reportInfo,
                    'message' => $exception->getMessage(),
                    'traceInfo' => $traceContext->getTraceInfo()
                ], JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT));
            return;
        }


        $pipes = [
            EnableReportCheck::class,
            OrderAlreadyReportCheck::class,
            ReportRechargeTypeCheck::class,
            RechargeAmountCheck::class,
            PromotionProtectCheck::class,
            ReportRateCheck::class
        ];

        $content = app(Pipeline::class)
            ->send($reportCheckContext)
            ->through($pipes)
            ->then(function ($content) {
                return $content;
            });
        $result = $content->result;
        \Log::info('[orangeSiteRechargeReport]回传判定结果', [
            'result' => $result,
            'traceInfo' => $traceContext->getTraceInfo()]);
        if ($result['needRecord'] ?? true) {
            $this->saveReportUserChargeReportInfo($reportCheckContext, $result);
        }
        if ($result['result']) {
            $this->reportRecharge($reportCheckContext, $result);
        }
    }

    private function reportRecharge(OrangeSiteRechargeReportCheckContext $reportCheckContext, array $checkResult)
    {
        $params = [
            'uid' => $reportCheckContext->user->id,
            'source' => 'zsy',
            'amount' => $reportCheckContext->order->price ?? 0,
            'link_source' => 'tiktok_event',
        ];


        $result = $this->reprotResultDeal(CallbackBaseService::directlyCharge($params));

        $resultContent = \json_decode(($result['content'] ?? '[]'), true);

        $updateInfo = [
            'status' => $result['status'] ?? 0,
            'request_param' => $result['request_param'] ?? '',
            'updated_at' => date('Y-m-d H:i:s'),
            'content' => \json_encode(array_merge($resultContent,
                ['log_content' => ($reportCheckContext->result['content'] ?? '')]))
        ];

        \Log::info('[orangeSiteRechargeReport]请求回传接口结果:' . ($updateInfo['status'] ? '成功' : '失败'), [
            'status' => $updateInfo['status'],
            'traceInfo' => $reportCheckContext->traceContext->getTraceInfo()]);

        DB::transaction(function () use ($reportCheckContext, $updateInfo, $checkResult, $result) {
            DB::table('report_user_charge_records')->where([
                'order_no' => $reportCheckContext->order->trade_no,
                'uid' => $reportCheckContext->order->uid,
                'link_source' => $reportCheckContext->platform,
            ])->update($updateInfo);

            if (1 == $result['status']) {
                /**
                 * 如果是计划保护回传成功的,只增加 orange_site_recharge_report_protect_records.current_protect_num,
                 * 而不增加 orange_site_recharge_report_records.rate_total_num 和 orange_site_recharge_report_records.rate_success_num
                 */
                if ('promotionProtect' == ($checkResult['result_ok_reason'] ?? '')) {
                    \Log::debug('[orangeSiteRechargeReport]回传成功,增加对应计划的成功数', [
                        'traceInfo' => $reportCheckContext->traceContext->getTraceInfo(),
                        'promotionId' => $reportCheckContext->reportInfo['promotionId']]);

                    OrangeSitePromotionService::setCurrentPromotionProtectNum($reportCheckContext->user->distribution_channel_id,
                        $reportCheckContext->reportInfo['promotionId'],
                        $reportCheckContext->channelCallbackConfig->eligible_count ?: 0);
                } else {
                    OrangeSiteReportRateService::increaseSuccessNum($reportCheckContext->user->distribution_channel_id,
                        $reportCheckContext->reportInfo['configRate']);
                }

            } else {
                if ('promotionProtect' != ($checkResult['result_ok_reason'] ?? '')) {
                    \Log::error('[orangeSiteRechargeReport]订单回传失败', [
                        'traceInfo' => $reportCheckContext->traceContext->getTraceInfo()]);
                    OrangeSiteReportRateService::increaseFailNum($reportCheckContext->user->distribution_channel_id,
                        $reportCheckContext->reportInfo['configRate']);
                } else {
                    \Log::error('[orangeSiteRechargeReport]计划保护订单回传失败', [
                        'traceInfo' => $reportCheckContext->traceContext->getTraceInfo()]);
                }
            }
        });
    }


    /**
     * [调用tiktok 接口回传后，数据处理逻辑]
     * @return [type]          [description]
     */
    public function reprotResultDeal($result)
    {
        $status = 0;
        $content = '';
        $result_data = isset($result['data']) ? $result['data'] : [];
        if (!empty($result_data['content'])) {
            $content = $result_data['content'];
            $con_arr = json_decode($content, true);
            $content = json_encode($con_arr);
            if (isset($con_arr['code']) && 0 == $con_arr['code']) {
                //tiktok_event
                $status = 1;
            }
        }
        //处理请求参数
        $request_param = '';
        if (isset($result_data['query_params'])) {
            if (is_string($result_data['query_params'])) {
                $request_param = $result_data['query_params'];
            }
            if (is_array($result_data['query_params'])) {
                $request_param = json_encode($result_data['query_params']);
            }
        }
        $data = [
            'status' => $status,
            'request_param' => $request_param,
        ];
        if ($content) {
            $data['content'] = $content;
        }
        return $data;
    }

    private function saveReportUserChargeReportInfo(OrangeSiteRechargeReportCheckContext $reportCheckContext, array $result)
    {
        $data = [
            'uid' => $this->reportInfo['uid'],
            'config_percent' => round($reportCheckContext->reportInfo['configRate'] / 100, 4),
            'report_percent' => round($reportCheckContext->reportInfo['reportRate'] / 100, 4),
            'order_no' => $reportCheckContext->order->trade_no,
            'timestamp' => time(),
            'status' => 0,
            'type' => $result['type'] ?? '',
            'content' => $result['content'] ?? '',
            'channel_id' => $reportCheckContext->user->distribution_channel_id,
            'request_param' => '',
            'link_source' => $reportCheckContext->platform,
        ];
        ReportUserChargeRecord::updateOrCreate([
            'order_no' => $data['order_no'],
            'uid' => $data['uid'],
            'link_source' => $data['link_source'],
        ], $data);
    }
}