乐妍

server/app/Console/Commands/LeyanJobCommand.php

@@ -60,6 +60,9 @@ class LeyanJobCommand extends Command
 
             $service = app(LeyanService::class);
             switch($action_type){
+                case 'batchUpdateProduct' :
+                    $service->batchUpdateProducts($params);
+                    break;
                 case 'updateProductByCas' :
                 default:
                     $service->updateProductByCas($params);

server/app/Rhawn/Services/BhuaProductService.php

@@ -45,6 +45,6 @@ class BhuaProductService
 
     public function getProductCasByBidToGroupByCas($bId)
     {
-        $this->productRepository->getProductCasByBidToGroupByCas($bId);
+        return $this->productRepository->getProductCasByBidToGroupByCas($bId);
     }
 }

server/app/Services/ThirdPlatform/Api/LeyanApiService.php

@@ -33,12 +33,12 @@ class LeyanApiService extends PlatformAbstractService
      * @param $product
      * @return bool
      */
-    public function pushUpdateProductByCas($product,$token)
+    public function pushUpdateProductByCas($cas,$token)
     {
         try{
             if($this->checkPlatformStatus()){
                 $params = [];
-                $params['casNo'] = $this->mergeApiMetaData($product);
+                $params['casNo'] = $cas;
 
                 $uri = $this->platformInfo['platform_url'].'/ProductDate/findProductDataPoolByCatalogNoOrCas';
                 $response = $this->getPostClient($uri,$params,null,[

server/app/Services/ThirdPlatform/LeyanService.php

@@ -27,11 +27,22 @@ class LeyanService
 
     public function batchUpdateProducts($params = null)
     {
-        app(BhuaProductService::class)->getProductCasByBidToGroupByCas(108);
+        ini_set('memory_limit','3072M');
+        $casList = app(BhuaProductService::class)->getProductCasByBidToGroupByCas($params);
+        if($casList){
+            foreach($casList as $cas){
+                $this->apiService->pushQueue([
+                    'params' => ['cas' => $cas],
+                    'consumer' => __CLASS__,
+                    'method' => 'updateProductByCas'
+                ],'leyan');
+            }
+        }
     }
 
     public function updateProductByCas($params)
     {
+        if(!$params['cas']) return null;
         $result = $this->apiService->pushUpdateProductByCas($params,$this->getToken());
         if(!$result){
             return null;