更新

server/app/Console/Commands/LeyanJobCommand.php

@@ -63,6 +63,9 @@ class LeyanJobCommand extends Command
                 case 'batchUpdateProduct' :
                     $service->batchUpdateProducts($params);
                     break;
+                case 'updateProductEveryDay' :
+                    $service->updateProductsByEveryDay();
+                    break;
                 case 'updateProductByCas' :
                 default:
                     $service->updateProductByCas($params);

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

@@ -53,8 +53,23 @@ class LeyanApiService extends PlatformAbstractService
         }
     }
 
-    public function pushBatchUpdateProduct($token){
+    public function pushBatchUpdateProduct($token)
+    {
+        try{
+            if($this->checkPlatformStatus()){
+                $params = [];
 
+                $uri = $this->platformInfo['platform_url'].'/ProductDate/findProductDataPool';
+                $response = $this->getPostClient($uri,$params,null,[
+                    'token' => $token,
+                ],false);
+
+                return $this->apiResponse($response);
+            }
+        }catch(\exception $exception){
+            SimpleLogs::writeLog($exception->getMessage(), __CLASS__.':pushBatchUpdateProduct error', 'error');
+            return false;
+        }
     }
 
     public function getToken(){

server/app/Services/ThirdPlatform/LeyanService.php

@@ -25,6 +25,19 @@ class LeyanService
         $this->apiService = (new LeyanApiService(app(ThirdApiPlatformRepository::class)));
     }
 
+    public function updateProductsByEveryDay()
+    {
+        $result = $this->apiService->pushBatchUpdateProduct($this->getToken());
+        if(!$result){
+            return null;
+        }
+        try{
+            $result = $this->storeLeyanProducts($result);
+        }catch(\Exception $exception){
+            SimpleLogs::writeLog($exception->getMessage(),__CLASS__.':updateProductsByEveryDay', 'error');
+        }
+    }
+
     public function batchUpdateProducts($params = null)
     {
         ini_set('memory_limit','3072M');