!133 批量同步修改

Merge pull request !133 from 赵世界/develop
This commit is contained in:
赵世界 2022-11-08 02:27:21 +00:00 committed by Gitee
commit 2982b7af61
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
2 changed files with 7 additions and 5 deletions

View File

@ -73,6 +73,7 @@ class InventoryImport implements ToCollection, SkipsEmptyRows
$goodsSku->stock = 0; $goodsSku->stock = 0;
$goodsSku->save(); $goodsSku->save();
} }
sleep(2);
event(new StockUpdateEvent($onSkuIds, 1)); event(new StockUpdateEvent($onSkuIds, 1));
} }
} }

View File

@ -12,6 +12,7 @@ use App\Models\Shop;
use GuzzleHttp\Client; use GuzzleHttp\Client;
use Illuminate\Support\Facades\Auth; use Illuminate\Support\Facades\Auth;
use GuzzleHttp\Promise; use GuzzleHttp\Promise;
use Illuminate\Support\Facades\Log as LogFile;
abstract class BusinessClient abstract class BusinessClient
{ {
@ -163,6 +164,7 @@ abstract class BusinessClient
public function batchAsyncPostRequest($url, $batchParams) public function batchAsyncPostRequest($url, $batchParams)
{ {
LogFile::info(json_encode($batchParams, 256));
$client = new Client(); $client = new Client();
$promises = []; $promises = [];
foreach ($batchParams as $param) { foreach ($batchParams as $param) {
@ -172,10 +174,9 @@ abstract class BusinessClient
]; ];
$promises[] = $client->postAsync($url, $options); $promises[] = $client->postAsync($url, $options);
} }
Promise\Utils::unwrap($promises); $res = Promise\Utils::unwrap($promises);
// $res = Promise\Utils::unwrap($promises); foreach ($res as $item) {
// foreach ($res as $item) { LogFile::info($item->getBody()->getContents());
// var_dump($item->getBody()->getContents()); }
// }
} }
} }