mirror of
https://gitee.com/hzchunfen/erp.git
synced 2025-11-30 22:20:45 +00:00
292 lines
11 KiB
PHP
292 lines
11 KiB
PHP
<?php
|
||
|
||
namespace App\Services\Business\KuaiTuanTuan;
|
||
|
||
use App\Models\BusinessGoodsSku;
|
||
use App\Models\GoodsSku;
|
||
use App\Models\GroupGoods;
|
||
use App\Models\Shop;
|
||
use App\Models\ShopShip;
|
||
use App\Services\Business\BusinessClient;
|
||
use App\Models\Groups as GroupsModel;
|
||
use Illuminate\Support\Facades\Log;
|
||
|
||
class KuaiTuanTuan extends BusinessClient
|
||
{
|
||
// 所有的请求和响应数据编码皆为utf-8格式，url里的所有参数值请做urlencode编码。
|
||
// 如果请求的content-type是 application/x-www-form-urlencoded，所有参数值也做urlencode编码；
|
||
// 如果是multipart/form-data格式，每个表单字段的参数值无需编码，但每个表单字段的charset需要指定为utf-8
|
||
// 如果指定接口返回数据格式为JSON，请指明header头content-type: application/json
|
||
protected $clientId = '8d7ca13bc27247b6a04e08404b51dfd8';
|
||
|
||
protected $clientSecret = '4478bc82dc1e1f68fe06c9f2bc683f1dcb3e6d83';
|
||
|
||
protected $publicParams = [
|
||
'type' => '',
|
||
'client_id' => '',
|
||
'access_token' => '', // 非必填,通过code获取的access_token
|
||
'timestamp' => '',
|
||
'data_type' => '', // 非必填,响应格式，即返回数据的格式，JSON或者XML（二选一），默认JSON，注意是大写
|
||
'version' => '', // 非必填, API协议版本号，默认为V1，可不填
|
||
'sign' => ''
|
||
];
|
||
|
||
public function auth($type = 'ktt')
|
||
{
|
||
$accessToken = $this->getAccessTokenWithCode();
|
||
$accessToken['scope'] = json_encode($accessToken['scope'], 256);
|
||
$accessToken['status'] = Shop::$STATUS_AUTHORIZED;
|
||
if ('ktt' === $type) {
|
||
$accessToken['pop_auth_token_create_response'] = json_encode($accessToken, 256);
|
||
$this->shop->update($accessToken);
|
||
}
|
||
if ('ship' === $type) {
|
||
unset($accessToken['r1_expires_at'], $accessToken['r1_expires_in'], $accessToken['r2_expires_at'], $accessToken['r2_expires_in'], $accessToken['w1_expires_at'], $accessToken['w1_expires_in'], $accessToken['w2_expires_at'], $accessToken['w2_expires_in'], $accessToken['request_id']);
|
||
ShopShip::query()->updateOrCreate(
|
||
['shop_id' => $this->shop->id],
|
||
$accessToken
|
||
);
|
||
}
|
||
|
||
return $this->shop;
|
||
}
|
||
|
||
public function downloadGoodsListAndBind($activityNo, $title = '', $page = 1)
|
||
{
|
||
[$type, $appendParams] = Goods::downloadGoods($activityNo, $page);
|
||
$res = $this->doRequest($type, $appendParams);
|
||
$goods = $res['ktt_goods_query_list_response']['goods_list'];
|
||
$this->bindGoods($goods, $title);
|
||
$pageNum = ceil($res['ktt_goods_query_list_response']['total'] / $appendParams['size']);
|
||
if ($pageNum > $page && 60 >= $page) {
|
||
$this->downloadGoodsListAndBind($activityNo, $title, $page + 1);
|
||
}
|
||
}
|
||
|
||
public function bindGoods($goods, $title = '')
|
||
{
|
||
Goods::bindGoods($goods, $this->shop->id, $title);
|
||
}
|
||
|
||
public function incrQuantity($businessGoodsSku, $num, $incremental)
|
||
{
|
||
[$type, $appendParams] = Goods::incrQuantity($businessGoodsSku['goods_id'], $businessGoodsSku['sku_id'], $num, $incremental ? 1 : 2);
|
||
$this->doRequest($type, $appendParams);
|
||
}
|
||
|
||
public function batchIncrQuantity($businessGoodsSkus, $num, $incremental)
|
||
{
|
||
$batchAppendParams = [];
|
||
$logData = [];
|
||
foreach ($businessGoodsSkus as $businessGoodsSku) {
|
||
[$type, $appendParams] = Goods::incrQuantity($businessGoodsSku['goods_id'], $businessGoodsSku['sku_id'], $num, $incremental ? 1 : 2);
|
||
$logData[] = $appendParams;
|
||
$appendParams['type'] = $type;
|
||
$appendParams['client_id'] = $this->clientId;
|
||
$appendParams['timestamp'] = time();
|
||
$appendParams['access_token'] = $this->getShop()->access_token;
|
||
$appendParams['sign'] = $this->getSign($appendParams);
|
||
$batchAppendParams[] = $appendParams;
|
||
}
|
||
$this->batchAsyncPostRequest('https://gw-api.pinduoduo.com/api/router', $batchAppendParams);
|
||
if ($logData) {
|
||
Log::info('本次批量同步: ' . json_encode($logData, 256));
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 下载订单
|
||
*
|
||
* @param $beginTime
|
||
* @param $endTime
|
||
* @param int $page
|
||
* @param string $downloadType
|
||
* @return void
|
||
*/
|
||
public function downloadOrdersAndSave($beginTime, $endTime, $downloadType = 'default', $page = 1)
|
||
{
|
||
if ('increment' === $downloadType) {
|
||
[$type, $appendParams] = Order::downloadIncrementOrders($beginTime, $endTime, $page);
|
||
$responseName = 'ktt_increment_order_query_response';
|
||
} else {
|
||
[$type, $appendParams] = Order::downloadOrders($beginTime, $endTime, $page);
|
||
$responseName = 'ktt_order_list_response';
|
||
}
|
||
$res = $this->doRequest($type, $appendParams);
|
||
if (!isset($res[$responseName])) {
|
||
return;
|
||
}
|
||
$this->saveOrders($res[$responseName]['order_list']);
|
||
$pageNum = ceil($res[$responseName]['total_count'] / $appendParams['page_size']);
|
||
if ($pageNum > $page && 30 >= $page) {
|
||
$this->downloadOrdersAndSave($beginTime, $endTime, $downloadType, $page + 1);
|
||
}
|
||
}
|
||
|
||
public function getOrderInfo($orderSn)
|
||
{
|
||
[$type, $appendParams] = Order::getOrderInfo($orderSn);
|
||
|
||
return $this->doRequest($type, $appendParams);
|
||
}
|
||
|
||
protected function getAccessTokenWithCode()
|
||
{
|
||
$type = 'pdd.pop.auth.token.create';
|
||
$res = $this->doRequest($type, ['code' => $this->code]);
|
||
|
||
return $res['pop_auth_token_create_response'];
|
||
}
|
||
|
||
protected function getSign($params)
|
||
{
|
||
ksort($params);
|
||
$str = '';
|
||
foreach ($params as $key => $val) {
|
||
$str .= $key . $val;
|
||
}
|
||
$str = $this->clientSecret . $str . $this->clientSecret;
|
||
|
||
return strtoupper(md5($str));
|
||
}
|
||
|
||
public function doRequest($type, $appendParams = [], $url = 'https://gw-api.pinduoduo.com/api/router')
|
||
{
|
||
$publicParams = [
|
||
'type' => $type,
|
||
'client_id' => $this->clientId,
|
||
'timestamp' => time()
|
||
];
|
||
if ('pdd.pop.auth.token.create' !== $type) {
|
||
$publicParams['access_token'] = $this->getShop()->access_token;
|
||
}
|
||
$publicParams = array_merge($publicParams, $appendParams);
|
||
$publicParams['sign'] = $this->getSign($publicParams);
|
||
$res = $this->formDataPostRequest($url, $publicParams);
|
||
if (isset($res['error_response'])) {
|
||
// "error_msg":"业务服务错误","sub_msg":"该店铺下不存在该商品","sub_code":"11","error_code":50001
|
||
// "error_msg":"业务服务错误","sub_msg":"该SKU在快团团中设置的库存为无限库存，不支持修改库存","sub_code":"13","error_code":50001
|
||
if (50001 == $res['error_response']['error_code'] && in_array($res['error_response']['sub_code'], ['13', '11'])) {
|
||
BusinessGoodsSku::query()->where('goods_id', $appendParams['goods_id'])->where('sku_id', $appendParams['sku_id'])->update(['is_sync' => 0]);
|
||
}
|
||
Log::error(json_encode($res, 256) . $type);
|
||
}
|
||
|
||
return $res;
|
||
}
|
||
|
||
public function downloadGoods($skuId)
|
||
{
|
||
$goodsSku = GoodsSku::query()
|
||
->with(['goods:id,goods_code'])
|
||
->find($skuId);
|
||
$code = $goodsSku->goods->goods_code . '_' . $goodsSku->sku_code;
|
||
$business = BusinessGoodsSku::query()->where('shop_id', $this->shop->id)->where('external_sku_id', $code)->first(['goods_id', 'sku_id']);
|
||
[$type, $appendParams] = Goods::downloadSingle($business->goods_id);
|
||
$res = $this->doRequest($type, $appendParams);
|
||
$goods = $res['response']['result'];
|
||
$this->bindGoods([$goods]);
|
||
}
|
||
|
||
public function getAuthUrl($shopId, $platId)
|
||
{
|
||
$state = $shopId . '_' . $platId;
|
||
|
||
return "https://oauth.pinduoduo.com/authorize/ktt?client_id={$this->clientId}&redirect_uri={$this->redirectUri}&state={$state}";
|
||
}
|
||
|
||
public function createSku()
|
||
{
|
||
[$type, $appendParams] = Goods::createSpec();
|
||
|
||
return $this->doRequest($type, $appendParams);
|
||
}
|
||
|
||
public function createGroup($localGroupId)
|
||
{
|
||
[$type, $appendParams] = Groups::createGroup($localGroupId, $this->shop);
|
||
$res = $this->doRequest($type, $appendParams);
|
||
if (isset($res['response']['success'])) {
|
||
$group = GroupsModel::query()->where('parent_id', $localGroupId)->where('shop_id', $this->shop->id)->first();
|
||
$group->activity_no = $res['response']['activity_no'];
|
||
$group->save();
|
||
}
|
||
|
||
return $res;
|
||
}
|
||
|
||
public function queryGroupStatus($localGroupId)
|
||
{
|
||
[$type, $appendParams] = Groups::queryGroupStatus($localGroupId, $this->shop->id);
|
||
$res = $this->doRequest($type, $appendParams);
|
||
if (isset($res['response'])) {
|
||
$group = GroupsModel::query()->where('parent_id', $localGroupId)->where('shop_id', $this->shop->id)->first();
|
||
$group->create_status = $res['response']['status'];
|
||
if (1 === $res['response']['status']) {
|
||
$group->qr_code_url = $res['response']['qr_code_url'];
|
||
// foreach ($res['response']['goods_list'] as $goods) {
|
||
// $groupGoods = GroupGoods::query()
|
||
// ->where('group_id', $localGroupId)
|
||
// ->where('external_sku_id', $goods['sku_list'][0]['external_sku_id'])
|
||
// ->first();
|
||
// $groupGoods->ktt_goods_id = $goods['goods_id'];
|
||
// $groupGoods->ktt_sku_id = $goods['sku_list'][0]['sku_id'];
|
||
// $groupGoods->save();
|
||
// }
|
||
}
|
||
if (2 === $res['response']['status']) {
|
||
$group->error_msg = $res['response']['error_msg'];
|
||
}
|
||
$group->save();
|
||
}
|
||
|
||
return $res;
|
||
}
|
||
|
||
public function queryGroup()
|
||
{
|
||
[$type, $appendParams] = Groups::queryGroup();
|
||
$res = $this->doRequest($type, $appendParams);
|
||
// if (isset($res['ktt_group_query_list_response'])) {
|
||
// foreach ($res['ktt_group_query_list_response']['activity_list'] as $activity) {
|
||
// $group = GroupsModel::query()->where('activity_no', $activity['activity_no'])->first();
|
||
// if ($group) {
|
||
// $group->is_help_sell = $activity[''];
|
||
// $group->status = $activity[''];
|
||
// $group->save();
|
||
// }
|
||
// }
|
||
// }
|
||
|
||
return $res;
|
||
}
|
||
|
||
public function uploadImage($url)
|
||
{
|
||
[$type, $appendParams] = Goods::uploadImage($url);
|
||
|
||
return $this->doRequest($type, $appendParams);
|
||
}
|
||
|
||
public function createLogistic($orderSn, $waybillNo)
|
||
{
|
||
[$type, $appendParams] = Order::createOrderLogistic($orderSn, $waybillNo);
|
||
|
||
return $this->doRequest($type, $appendParams);
|
||
}
|
||
|
||
public function cancelLogistic($orderSn, $waybillNo)
|
||
{
|
||
[$type, $appendParams] = Order::deleteOrderLogistic($orderSn, $waybillNo);
|
||
|
||
return $this->doRequest($type, $appendParams);
|
||
}
|
||
|
||
public function getLogisticsCompanies()
|
||
{
|
||
[$type, $appendParams] = Order::getLogisticsCompanies();
|
||
|
||
return $this->doRequest($type, $appendParams);
|
||
}
|
||
}
|