wangdu_public_api/app/Jobs/AsyncOrderStats.php

<?php

/**
 * Created by PhpStorm.
 * User: z-yang
 * Date: 2020/5/5
 * Time: 11:29
 */

namespace App\Jobs;

use App\Modules\Channel\Services\ReportToChannelUserAndOrderService;
use App\Modules\Subscribe\Services\OrderService;
use GuzzleHttp\Client;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Redis;
use DB;

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

    const SUCCESS = 'success';

    private $orderId;
    private $order_info = null;

    private $uid = 0;

    public function __construct(int $order_id)
    {
        $this->orderId = $order_id;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $this->init();
        //activity 活动统计
        $this->activityStats();
        //$this->saveActivityOrder();
        //图书充值统计
        $this->bookChargeStats();
        //订单上报给渠道
        $this->reportToChannel();

        $this->fireOrderReport();
    }

    private function init()
    {
        $this->order_info = OrderService::getById($this->orderId);
        $this->uid = $this->order_info->uid;
    }


    private function activityStats()
    {
        $item = $this->order_info;
        if ($item->status != 'PAID') return;
        if (!$item->activity_id) return;
        $day = date('Y-m-d', strtotime($item->created_at));
        $exist = DB::table('activity_statistic_all')
            ->where('activity_id', $item->activity_id)
            ->where('day', $day)
            ->select('id', 'amount')
            ->where('distribution_channel_id', $item->distribution_channel_id)->first();
        if ($exist) {
            DB::table('activity_statistic_all')->where('id', $exist->id)->update(
                [
                    'amount' => $exist->amount + $item->price * 100,
                    'updated_at' => date('Y-m-d H:i:s')
                ]
            );
            return;
        }
        $pv = 0;
        $uv = 0;
        DB::table('activity_statistic_all')->insert([
            'activity_id' => $item->activity_id, 'day' => $day, 'distribution_channel_id' => $item->distribution_channel_id,
            'amount' => $item->price * 100, 'pv' => $pv, 'uv' => $uv, 'created_at' => date('Y-m-d H:i:s'), 'updated_at' => date('Y-m-d H:i:s')
        ]);
    }


    private function bookChargeStats(){
        $bid = $this->order_info->from_bid;
        if(!$bid) return ;
        $day = date('Y-m-d', strtotime($this->order_info->created_at));
        $price = $this->order_info->price * 100;
        Redis::hincrby('book:charge:stats:'.$day, $bid, $price);
    }

   private function reportToChannel(){
       $link = ReportToChannelUserAndOrderService::getReportUrl($this->order_info->distribution_channel_id,ReportToChannelUserAndOrderService::$order_type);
       if(!$link) return ;
       $uid = $this->uid;
       $distribution_channel_id = $this->order_info->distribution_channel_id;
       $price = $this->order_info->price;
       $order_created_at = $this->order_info->created_at->format('Y-m-d H:i:s');
       $client = new Client(['timeout'=>3.0]);
       try{
           $result = $client->request('post',$link,['form_params'=>[
               'uid'=>$uid,
               'distribution_channel_id'=>$distribution_channel_id,
               'price'=>$price,
               'order_created_at'=>$order_created_at,
               'event'=>'order',
               'source'=>'wangduyun'
           ]])->getBody()->getContents();
           if($result && str_contains(strtolower($result),self::SUCCESS)){
               return ;
           }
           $error = 'result error ,'.$result;
       }catch (\Exception $e){
           $error = 'exception,'.$e->getMessage();
       }
       DB::table('report_to_channel_orders')->insert([
           'uid'=>$uid,
           'distribution_channel_id'=>$distribution_channel_id,
           'price'=>$price,
           'order_created_at'=>$order_created_at,
           'report_status'=>0,
           'error_msg'=>$error,
           'created_at'=>date('Y-m-d H:i:s'),
           'updated_at'=>date('Y-m-d H:i:s'),
       ]);
   }


    private function fireOrderReport(){
        if ($this->order_info->status != 'PAID') return;
        $client = new Client();
        $reportData = [
            'platform' => 'wangduyun',
            'order'     => [
                'uid'        => getProp($this->order_info, 'uid'),
                'order_no'   => getProp($this->order_info, 'trade_no'),
                'price'      => getProp($this->order_info, 'price'),
                'channel_id' => getProp($this->order_info, 'distribution_channel_id'),
                'pay_time'   => getProp($this->order_info, 'pay_end_at'),
                'order_created_at'   => $this->order_info->created_at->format('Y-m-d H:i:s'),
                'order_type'=>  getProp($this->order_info, 'order_type'),
                'from_bid'=>    getProp($this->order_info, 'from_bid'),
                'pay_type'=>	getProp($this->order_info, 'pay_type')
            ]
        ];
        $record = [
            'uid'=>$reportData['order']['uid'],
            'trade_no'=>$reportData['order']['order_no'],
            'price'=>$reportData['order']['price'],
            'distribution_channel_id'=>$reportData['order']['channel_id'],
            'pay_time'=>$reportData['order']['pay_time'],
            'msg'=>'',
            'status'=>0,
            'created_at'=>date('Y-m-d H:i:s'),
            'updated_at'=>date('Y-m-d H:i:s'),
        ];
        $host = 'https://firetrack.wd.amanbook.com';
        try{
            // 执行上报
            $result = $client->post($host . '/api/reportOrder', [
                'headers' => [
                    'x-code' => 'Mvnx1Yr3O8i!TS5u'
                ],
                'json'    => $reportData
            ]);
            $record['msg'] = $result->getBody()->getContents();
            $record['status'] = 1;
        }catch (\Exception $e){
            $record['status'] = 2;
            $record['msg'] = '';
            \Log::error($e);
        }
        try{
            DB::table('fire_order_report_record')->insert($record);
        }catch (\Exception $e){

        }
    }

}