更新提交

server/app/Services/ThirdPlatform/WuxiLabNewService.php

@@ -66,6 +66,11 @@ class WuxiLabNewService
                         'consumer' => __CLASS__,
                         'method' => 'queueBatchUpdatePackagesToApi'
                     ];break;
+                    case 'init_package': $queueParams = [
+                        'params' => ['packageList' => $newPackages],
+                        'consumer' => __CLASS__,
+                        'method' => 'initQueueBatchUpdatePackagesToApi'
+                    ];break;
                     default:
                         $queueParams = [
                             'params' => ['rawList' => $rawList,'packageList' => $newPackages],
@@ -147,8 +152,8 @@ class WuxiLabNewService
                     $tempData = [];
                     $tempData['product_division'] = 'CHEMICAL';
                     list($pCode, $packCode) = explode('-', $product->p_code);
-                    $tempData['productId'] = 'R003250';//$pCode;
-                    $tempData['packageUnitDescription'] = 'R003250-1ml';//$product->p_code;
+                    $tempData['productId'] = $pCode;
+                    $tempData['packageUnitDescription'] = $product->p_code;
                     $tempData['packageStockQuantity'] = $product->p_stock;
                     $tempData['packageStockLocation'] = 'CN-SH';
                     $tempData['stockStatus'] = $product->p_status == '1' ? 'ACTIVE' : 'INACTIVE';;
@@ -162,6 +167,64 @@ class WuxiLabNewService
         }
     }
 
+    public function initQueueBatchUpdatePackagesToApi($updateData)
+    {
+        if(empty($updateData['packageList'])){
+            return false;
+        }
+        try{
+            $packageList = [];
+            foreach($updateData['packageList'] as $packageCode => $data){
+                $tempData = [];
+                $tempData['product_division'] = 'CHEMICAL';
+                $tempData['productId'] = $data['r_code'];
+                $tempData['status'] = $data['p_status'] == '1' ? 'ACTIVE' : 'INACTIVE';
+                $tempData['packageUnitDescription'] = $packageCode;
+                $packageList[] = $tempData;
+            }
+
+            $result = $this->apiService->pushBatchUpdatePackages($packageList, $this->getToken());
+            $this->processApiResponse($result);
+
+            $updateProductStock = [];
+            foreach($updateData['packageList'] as $product){
+                $tempData = [];
+                $tempData['product_division'] = 'CHEMICAL';
+                list($pCode, $packCode) = explode('-', $product->p_code);
+                $tempData['productId'] = $pCode;
+                $tempData['packageUnitDescription'] = $product->p_code;
+                $tempData['packageStockQuantity'] = $product->p_stock;
+                $tempData['packageStockLocation'] = 'CN-SH';
+                $tempData['stockStatus'] = $product->p_status == '1' ? 'ACTIVE' : 'INACTIVE';;
+                $updateProductStock[] = $tempData;
+                break;
+            }
+            $result = $this->apiService->pushBatchUpdateStock($updateProductStock, $this->getToken());
+            $this->processApiResponse($result);
+
+            $updateProductPrice = [];
+            foreach($updateData['packageList'] as $product){
+                $tempData = [];
+                $tempData['product_division'] = 'CHEMICAL';
+                list($pCode, $packCode) = explode('-', $product->p_code);
+                $tempData['productId'] = $pCode;
+                $tempData['packageUnitDescription'] = $product->p_code;
+                $tempData['minPackageUnitDescription'] = '';
+                $tempData['price'] = bcmul($product->p_price, 0.5, 2);
+                $tempData['discount'] = '0.5';
+                $tempData['inCostCurrency'] = 'RMB';
+                $tempData['status'] = $product->p_status == '1' ? 'ACTIVE' : 'INACTIVE';;
+                $updateProductPrice[] = $tempData;
+            }
+            $result = $this->apiService->pushBatchUpdatePrice($updateProductPrice, $this->getToken());
+            $this->processApiResponse($result);
+
+        }catch(\Throwable $exception){
+            SimpleLogs::writeLog($exception->getMessage(), __CLASS__.':batchUpdateToWuxiLab', 'error');
+            var_dump($exception->getMessage());
+        }
+    }
+
     public function queueBatchUpdatePackagesToApi($updateData)
     {
         if(empty($updateData['packageList'])){