* [ * 'channelId' => 'xxx, // 站点id * 'orderId' => 'xxx', // 订单id * 'uid' => 'xxx', // 充值用户uid * ] * */ 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); } }