Skip to content

O
openApi
Commit 202c3685 authored by hangjun83's avatar hangjun83
Browse files
Options

药明康德更新

parent 4e3fd923
Hide whitespace changes
Inline Side-by-side
Showing with 19 additions and 18 deletions
server/app/Services/ThirdPlatform/WuxiLabService.php
View file @ 202c3685
...@@ -353,27 +353,28 @@ class WuxiLabService ...@@ -353,27 +353,28 @@ class WuxiLabService
//处理更新不成功的商品 //处理更新不成功的商品
if(isset($result['errorProduct']) && !empty($result['errorProduct'])){ if(isset($result['errorProduct']) && !empty($result['errorProduct'])){
$storeEntries = $this->apiService->getPlatformDataEntries('wuxiLab_not_exist_products','data_values'); $storeEntries = $this->apiService->getPlatformDataEntries('wuxiLab_not_exist_products','data_values');
if(!is_null($storeEntries) && count($storeEntries['products']) >= $this->apiService->getPlatformInfo('platform_params')['excelCreateLimit']){ if(isset($storeEntries) && !empty($storeEntries)){
/*$this->apiService->pushQueue([ if(count($storeEntries['products']) >= $this->apiService->getPlatformInfo('platform_params')['excelCreateLimit']){
'params' => ['products' => $storeEntries['products'],'type' => 'product'], /*$this->apiService->pushQueue([
'consumer' => __CLASS__,
'method' => 'processProductsUpdateThroughtExcel'
],'wuxilab_product');*/
$this->apiService->pushQueue([
'params' => ['products' => $storeEntries['products'],'type' => 'package'],
'consumer' => __CLASS__,
'method' => 'processProductsUpdateThroughtExcel'
],'wuxilab_package');
$this->apiService->removePlatformDataEntries('wuxiLab_not_exist_products');
/*SimpleKafka::produerSend(
[
'params' => ['products' => $storeEntries['products'],'type' => 'product'], 'params' => ['products' => $storeEntries['products'],'type' => 'product'],
'consumer' => __CLASS__, 'consumer' => __CLASS__,
'method' => 'processProductsUpdateThroughtExcel' 'method' => 'processProductsUpdateThroughtExcel'
] ],'wuxilab_product');*/
);*/ $this->apiService->pushQueue([
$this->apiService->removePlatformDataEntries('wuxiLab_not_exist_products'); 'params' => ['products' => $storeEntries['products'],'type' => 'package'],
$storeEntries = []; 'consumer' => __CLASS__,
'method' => 'processProductsUpdateThroughtExcel'
],'wuxilab_package');
$this->apiService->removePlatformDataEntries('wuxiLab_not_exist_products');
/*SimpleKafka::produerSend(
[
'params' => ['products' => $storeEntries['products'],'type' => 'product'],
'consumer' => __CLASS__,
'method' => 'processProductsUpdateThroughtExcel'
]
);*/
$storeEntries = [];
}
} }
foreach($result['errorProduct'] as $errorProduct){ foreach($result['errorProduct'] as $errorProduct){
if($errorProduct['reason'] == 'PRODUCT_NOT_EXIST'){ if($errorProduct['reason'] == 'PRODUCT_NOT_EXIST'){
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment