erp/app/Services/Business/BusinessClient.php

<?php

namespace App\Services\Business;

use App\Models\Log;
use App\Models\Shop;
use GuzzleHttp\Client;

abstract class BusinessClient
{
    protected $redirectUri = 'http://erp.chutang66.com/callback';
    protected $code;
    protected $shop;
    protected $skuId = 0;

    abstract public function auth();

    abstract public function downloadGoodsList();

    abstract public function downloadGoods($skuId);

    abstract public function bindGoods($goods);

    abstract public function incrQuantity($skuId);

    abstract public function downloadOrders($beginTime, $endTime, $activityNo = '', $downloadType = 'default');

    abstract public function saveOrders($orders);

    public function authCallback($code, $shopId)
    {
        $this->setCode($code);
        $this->setShop($shopId);
        $this->auth();

        return $this;
    }

    public function setShopWithId($shopId)
    {
        $this->shop = Shop::query()->find($shopId);

        return $this;
    }

    public function setShop(Shop $shop)
    {
        $this->shop = $shop;

        return $this;
    }

    public function getShop()
    {
        return $this->shop;
    }

    public function setCode($code)
    {
        $this->code = $code;

        return $this;
    }

    public function getCode()
    {
        return $this->code;
    }

    public function setSkuId($skuId)
    {
        $this->skuId = $skuId;

        return $this;
    }

    public function getSkuId()
    {
        return $this->skuId;
    }

    public function formDataPostRequest($url, $params)
    {
        $headers = [
            'headers' => ['Content-type' => 'application/x-www-form-urlencoded;charset=UTF-8'],
            'form_params' => $params
        ];
        $res = (new Client())->request('POST', $url, $headers);
        $res = json_decode($res->getBody()->getContents(), true);
        $disableLogType = [
            'pdd.ktt.goods.query.list',
            'pdd.ktt.order.list',
            'pdd.ktt.increment.order.query'
        ];
        $log = new Log();
        $log->module = 'plat';
        $log->action = 'POST';
        $log->target_type = $this->shop->plat_id;
        $log->target_id = $this->skuId;
        $log->target_field = $params['type'];
        $log->user_id = 1;
        if (!in_array($params['type'], $disableLogType, true)) {
            $log->message = json_encode($res, 256);
        }
        $log->save();

        if (isset($res['error_response'])) {
            throw new \Exception($res['error_response']['error_msg'], $res['error_response']['error_code']);
        }

        return $res;
    }
}