113 lines
2.7 KiB
PHP
113 lines
2.7 KiB
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 downloadGoodsListAndBind();
|
|
|
|
abstract public function downloadGoods($skuId);
|
|
|
|
abstract public function bindGoods($goods);
|
|
|
|
abstract public function incrQuantity($skuId);
|
|
|
|
abstract public function downloadOrdersAndSave($beginTime, $endTime, $page = 1, $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);
|
|
$size = $res->getBody()->getSize();
|
|
$res = json_decode($res->getBody()->getContents(), true);
|
|
if ('pdd.ktt.increment.order.query' === $params['type']) {
|
|
$log = Log::query()->where('user_id', $this->shop->id)->where('target_field', $params['type'])->first();
|
|
} else {
|
|
$log = new Log();
|
|
}
|
|
$log->module = 'plat';
|
|
$log->action = 'POST';
|
|
$log->target_type = $this->shop->plat_id;
|
|
$log->target_id = $this->getSkuId();
|
|
$log->target_field = $params['type'];
|
|
$log->user_id = $this->shop->id;
|
|
if ($size < 64000) {
|
|
$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;
|
|
}
|
|
}
|