fix

app/Console/Commands/SyncAllSupplierToErp.php

@@ -37,21 +37,35 @@ class SyncAllSupplierToErp extends Command
     public function handle()
     public function handle()
     {
     {
         ini_set('memory_limit', -1);
         ini_set('memory_limit', -1);
-        $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();
-        $conn = new AMQPStreamConnection(config('database.connections.rabbitmq.host'),
+        $conn = new AMQPStreamConnection(
+            config('database.connections.rabbitmq.host'),
             config('database.connections.rabbitmq.port'),
             config('database.connections.rabbitmq.port'),
             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();
+            $hasDataFollower = SupplierContactModel::where('supplier_id', $supplierId)
+                ->where('channel_user_type', SupplierContactModel::CHANNEL_USER_TYPE_INVENTORY)->exists();
             if (!$hasDataFollower) {
             if (!$hasDataFollower) {
                 continue;
                 continue;
             }
             }
-            usleep(100000);
+            // usleep(100000);
             dump($supplierId);
             dump($supplierId);
-            (new SyncSupplierService())->syncSupplierToErp($supplierId, $conn);
+            //找出所有的联系人对应的采购id,更新主表
+            $canCheckUids = SupplierContactModel::where('supplier_id', $supplierId)->pluck('can_check_uids');
+            if (!empty($canCheckUids)) {
+                $canCheckUids = array_unique($canCheckUids->toArray());
+                $canCheckUids = implode(',', $canCheckUids);
+            } else {
+                $canCheckUids = '';
+            }
+
+            SupplierChannelModel::where('supplier_id', $supplierId)->update([
+                'channel_uid' => $canCheckUids,
+            ]);
+            // (new SyncSupplierService())->syncSupplierToErp($supplierId, $conn);
         }
         }
     }
     }
 }
 }