同步脚本

app/Console/Commands/SyncAllSupplierToErp.php

@@ -7,6 +7,7 @@ use App\Http\Services\StatisticsSkuUploadService;
 use App\Http\Services\SupplierService;
 use App\Http\Services\SupplierService;
 use App\Http\Services\SyncSupplierService;
 use App\Http\Services\SyncSupplierService;
 use App\Model\SupplierChannelModel;
 use App\Model\SupplierChannelModel;
+use App\Model\SupplierContactModel;
 use Illuminate\Console\Command;
 use Illuminate\Console\Command;
 use Illuminate\Foundation\Inspiring;
 use Illuminate\Foundation\Inspiring;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
@@ -43,6 +44,11 @@ class SyncAllSupplierToErp extends Command
             config('database.connections.rabbitmq.login'),
             config('database.connections.rabbitmq.login'),
             config('database.connections.rabbitmq.password'));
             config('database.connections.rabbitmq.password'));
         foreach ($supplierIds as $supplierId) {
         foreach ($supplierIds as $supplierId) {
+            $hasDataFollower = SupplierContactModel::where('supplier_id',$supplierId)
+            ->where('channel_user_type',SupplierContactModel::CHANNEL_USER_TYPE_INVENTORY)->exists();
+            if (!$hasDataFollower) {
+                continue;
+            }
             usleep(100000);
             usleep(100000);
             dump($supplierId);
             dump($supplierId);
             (new SyncSupplierService())->syncSupplierToErp($supplierId, $conn);
             (new SyncSupplierService())->syncSupplierToErp($supplierId, $conn);