fix: #20220916 同步优化
This commit is contained in:
parent
18837f25fd
commit
38abb92032
@ -35,7 +35,7 @@ class BusinessGoodsSkusController extends Controller
|
|||||||
return BusinessGoodsSkuResource::collection($businessGoodsSkus);
|
return BusinessGoodsSkuResource::collection($businessGoodsSkus);
|
||||||
}
|
}
|
||||||
|
|
||||||
public function update(Request $request, $id)
|
public function update($id, Request $request)
|
||||||
{
|
{
|
||||||
$validator = Validator::make($request->all(), [
|
$validator = Validator::make($request->all(), [
|
||||||
'is_sync' => ['required', Rule::in([0, 1])]
|
'is_sync' => ['required', Rule::in([0, 1])]
|
||||||
@ -55,7 +55,7 @@ class BusinessGoodsSkusController extends Controller
|
|||||||
return response($this->res, $this->res['httpCode']);
|
return response($this->res, $this->res['httpCode']);
|
||||||
}
|
}
|
||||||
|
|
||||||
public function destroy(Request $request, $id)
|
public function destroy($id, Request $request)
|
||||||
{
|
{
|
||||||
DB::beginTransaction();
|
DB::beginTransaction();
|
||||||
try {
|
try {
|
||||||
@ -75,7 +75,7 @@ class BusinessGoodsSkusController extends Controller
|
|||||||
return response($this->res, $this->res['httpCode']);
|
return response($this->res, $this->res['httpCode']);
|
||||||
}
|
}
|
||||||
|
|
||||||
public function syncStock(Request $request, $id)
|
public function syncStock($id, Request $request)
|
||||||
{
|
{
|
||||||
$businessGoodsSku = BusinessGoodsSku::find($id);
|
$businessGoodsSku = BusinessGoodsSku::find($id);
|
||||||
[$goodsCode, $skuCode] = explode('_', $businessGoodsSku->external_sku_id);
|
[$goodsCode, $skuCode] = explode('_', $businessGoodsSku->external_sku_id);
|
||||||
|
|||||||
@ -41,6 +41,8 @@ class Goods
|
|||||||
if (!empty($businessGoodSku->external_sku_id)) {
|
if (!empty($businessGoodSku->external_sku_id)) {
|
||||||
event(new BusinessOrdersUpdate($businessGoodSku, 0));
|
event(new BusinessOrdersUpdate($businessGoodSku, 0));
|
||||||
}
|
}
|
||||||
|
} else {
|
||||||
|
$businessGoodSku->update($data);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -5,8 +5,6 @@ namespace App\Services\Business\KuaiTuanTuan;
|
|||||||
use App\Models\BusinessGoodsSku;
|
use App\Models\BusinessGoodsSku;
|
||||||
use App\Models\GoodsSku;
|
use App\Models\GoodsSku;
|
||||||
use App\Services\Business\BusinessClient;
|
use App\Services\Business\BusinessClient;
|
||||||
use App\Models\Log;
|
|
||||||
use App\Utils\DateTimeUtils;
|
|
||||||
|
|
||||||
class KuaiTuanTuan extends BusinessClient
|
class KuaiTuanTuan extends BusinessClient
|
||||||
{
|
{
|
||||||
@ -42,18 +40,6 @@ class KuaiTuanTuan extends BusinessClient
|
|||||||
public function downloadGoodsListAndBind($page = 1)
|
public function downloadGoodsListAndBind($page = 1)
|
||||||
{
|
{
|
||||||
[$type, $appendParams] = Goods::downloadGoods($this->shop->owner_id, $page);
|
[$type, $appendParams] = Goods::downloadGoods($this->shop->owner_id, $page);
|
||||||
$log = Log::query()
|
|
||||||
->where('target_field', 'pdd.ktt.goods.query.list')
|
|
||||||
->where('target_id', $this->shop->id)
|
|
||||||
->orderBy('id', 'desc')
|
|
||||||
->first();
|
|
||||||
if ($log) {
|
|
||||||
$lastGetTime = DateTimeUtils::getMicroTime($log->created_at);
|
|
||||||
// 毫秒时间戳,往前算3分钟
|
|
||||||
$startTime = $lastGetTime - 30000;
|
|
||||||
$appendParams['update_time_start'] = $startTime;
|
|
||||||
$appendParams['update_time_end'] = DateTimeUtils::getMicroTime();
|
|
||||||
}
|
|
||||||
$res = $this->doRequest($type, $appendParams);
|
$res = $this->doRequest($type, $appendParams);
|
||||||
$goods = $res['ktt_goods_query_list_response']['goods_list'];
|
$goods = $res['ktt_goods_query_list_response']['goods_list'];
|
||||||
$this->bindGoods($goods);
|
$this->bindGoods($goods);
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user