cf_cloud/erp
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feat: #10000 批量同步修改

Browse Source
This commit is contained in:
赵世界 2022-11-08 10:26:16 +08:00
parent 9e4023afad
commit c7b595598f
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
app/Imports/InventoryImport.php
View File

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

11
app/Services/Business/BusinessClient.php
View File

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