修改

app/Http/Services/DataService.php

@@ -7,6 +7,7 @@ use Carbon\Carbon;
 use GuzzleHttp\Client;
 use GuzzleHttp\Client;
 use App\Model\LogModel;
 use App\Model\LogModel;
 use App\Model\RedisModel;
 use App\Model\RedisModel;
+use App\Model\NationModel;
 use App\Model\SkuUploadItem;
 use App\Model\SkuUploadItem;
 use App\Model\SpuBrandModel;
 use App\Model\SpuBrandModel;
 use App\Model\UserInfoModel;
 use App\Model\UserInfoModel;
@@ -29,7 +30,7 @@ use App\Model\SupplierAttachmentsModel;
 use App\Model\StandardBrandMappingModel;
 use App\Model\StandardBrandMappingModel;
 use App\Model\Purchase\PurchaseOrderModel;
 use App\Model\Purchase\PurchaseOrderModel;
 use App\Http\Transformers\SupplierTransformer;
 use App\Http\Transformers\SupplierTransformer;
-use App\Model\NationModel;
+use PhpAmqpLib\Connection\AMQPStreamConnection;
 
 
 //这个服务是处理数据的,比如导出信息,或者临时修复数据,所以代码会比较多
 //这个服务是处理数据的,比如导出信息,或者临时修复数据,所以代码会比较多
 class DataService
 class DataService
@@ -875,10 +876,16 @@ class DataService
     //同步供应商到erp
     //同步供应商到erp
     public static function syncSupplierToErp()
     public static function syncSupplierToErp()
     {
     {
+        $conn = new AMQPStreamConnection(
+            config('database.connections.rabbitmq.host'),
+            config('database.connections.rabbitmq.port'),
+            config('database.connections.rabbitmq.login'),
+            config('database.connections.rabbitmq.password')
+        );
         $supplierIds = SupplierChannelModel::where('is_type', 0)->where('group_code', '!=', '')
         $supplierIds = SupplierChannelModel::where('is_type', 0)->where('group_code', '!=', '')
             ->pluck('supplier_id')->toArray();
             ->pluck('supplier_id')->toArray();
         foreach ($supplierIds as $supplierId) {
         foreach ($supplierIds as $supplierId) {
-            (new SyncSupplierService())->syncSupplierToErp($supplierId);
+            (new SyncSupplierService())->syncSupplierToErp($supplierId,$conn);
         }
         }
     }
     }
 }
 }

app/Http/routes.php

@@ -69,7 +69,6 @@ Route::group(['middleware' => ['web'], 'namespace' => 'Api'], function () {
     Route::match(['get', 'post'], '/api/supplier_contract/{key}', 'SupplierContractApiController@Entrance');
     Route::match(['get', 'post'], '/api/supplier_contract/{key}', 'SupplierContractApiController@Entrance');
     //单独的统计接口
     //单独的统计接口
     Route::match(['get', 'post'], '/statisticsSkuNumber', function () {
     Route::match(['get', 'post'], '/statisticsSkuNumber', function () {
-        (new \App\Http\Services\DataService())->statisticsSkuNumberFromSKu();
     });
     });
 });
 });
 
 
@@ -94,8 +93,5 @@ Route::group(['middleware' => ['external'], 'namespace' => 'Sync'], function ()
 Route::match(['get', 'post'], '/test', function () {
 Route::match(['get', 'post'], '/test', function () {
     // DataService::initSupplierNationId();
     // DataService::initSupplierNationId();
     // DataService::initSupplierReceiptNationId();
     // DataService::initSupplierReceiptNationId();
-    \App\Model\NationModel::where('nation_id', 0)->update([
-        'nation_id' => '1',
-    ]);
-    DataService::repairNationInternationalCode();
+    DataService::syncSupplierToErp();
 });
 });