zhangsiye/server/app/Jobs/KuaishouSettlementJob.php

<?php

namespace App\Jobs;

use App\Helper\ByteDance;
use App\Helper\Kuaishou;
use App\Helper\UniPlatform\Bytedance\ByteDanceAPI;
use App\Helper\UniPlatform\Kuaishou\KuaishouAPI;
use App\Models\Pay;
use App\Models\PayConfig;
use Carbon\Carbon;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Psy\Util\Json;

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

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct()
    {
        //
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $app = $this->getKuishouFactory();

        $orders = Pay::with(['user.info'])->whereHas('user.info', function ($query){
            $query->where('platform', 2);
        })->where('status', 1)
            ->where('created_at', '<=',Carbon::now()->subDays(7)->toDateString().' 00:00:00')
            ->where('is_settle', 0)
            ->get()
            ->chunk(30);
        foreach ($orders as $arr){
            /* @var Pay $order*/
            foreach ($arr as $order){
                try {
                    $res = $app->settle($order->pay_id, $order->order_fee * 100);
                    $order->is_settle = 1;
                    $order->settle_no = $res['settle_no'];
                    $order->save();
                    \Log::info("快手结算--> 支付订单号：{$order->pay_id}\t结算单号：{$res['settle_no']}");
                }catch (\Exception $e) {
                    \Log::info("快手结算错误--> 支付订单号：{$order->pay_id}\n错误信息：{$e->getMessage()}");
                }
            }
            // 30QPS
            sleep(1);
        }

    }

    protected function getKuishouFactory(): Kuaishou
    {
        $setting = PayConfig::first();
        return (new Kuaishou(app(KuaishouAPI::class)))->factory([
            'app_id'     => $setting->kuaishou_app_id,
            'app_secret' => $setting->kuaishou_app_secret,
        ]);
    }
}