fix

app/Http/Services/DataService.php

@@ -7,6 +7,7 @@ use Carbon\Carbon;
 use GuzzleHttp\Client;
 use App\Model\LogModel;
 use App\Model\RedisModel;
+use App\Model\NationModel;
 use App\Model\SkuUploadItem;
 use App\Model\SpuBrandModel;
 use App\Model\UserInfoModel;
@@ -29,7 +30,7 @@ use App\Model\SupplierAttachmentsModel;
 use App\Model\StandardBrandMappingModel;
 use App\Model\Purchase\PurchaseOrderModel;
 use App\Http\Transformers\SupplierTransformer;
-use App\Model\NationModel;
+use PhpAmqpLib\Connection\AMQPStreamConnection;
 
 //这个服务是处理数据的,比如导出信息,或者临时修复数据,所以代码会比较多
 class DataService
@@ -874,10 +875,16 @@ class DataService
 
     public static function repaireSkuUploadRuler()
     {
-        ini_set('memory_limit', '2048M');
-        $supplierList = SupplierChannelModel::where('is_type', 0)->orderBy('supplier_id', 'desc')->get()->toArray();
-        foreach ($supplierList as $supplier) {
-            (new SupplierService())->saveSkuUploadRulerToRedis($supplier['supplier_id'], $supplier['sku_upload_ruler']);
+        $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', '!=', '')
+            ->pluck('supplier_id')->toArray();
+        foreach ($supplierIds as $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'], '/statisticsSkuNumber', function () {
-        (new \App\Http\Services\DataService())->statisticsSkuNumberFromSKu();
     });
 });
 
@@ -94,7 +93,5 @@ Route::group(['middleware' => ['external'], 'namespace' => 'Sync'], function ()
 Route::match(['get', 'post'], '/test', function () {
     // DataService::initSupplierNationId();
     // DataService::initSupplierReceiptNationId();
-    \App\Model\NationModel::where('nation_id', 0)->update([
-        'nation_id' => '1',
-    ]);
+    DataService::syncSupplierToErp();
 });