add try lock

Author: rez1dent3

src/Commands/BulkWrite.php

@@ -5,6 +5,8 @@
 use Bavix\Entry\Services\BulkService;
 use Bavix\Entry\Jobs\BulkWriter;
 use Illuminate\Console\Command;
+use Illuminate\Contracts\Cache\LockTimeoutException;
+use Illuminate\Support\Facades\Cache;
 
 class BulkWrite extends Command
 {
@@ -29,23 +31,32 @@ class BulkWrite extends Command
      */
     public function handle(): void
     {
-        $batchSize = \config('entry.batchSize', 10000);
-        $keys = app(BulkService::class)->keys();
-        foreach ($keys as $key) {
-            [$bulkName, $class] = \explode(':', $key, 2);
-            $chunkIterator = app(BulkService::class)
-                ->chunkIterator($batchSize, $key);
-
-            foreach ($chunkIterator as $bulkData) {
-                foreach ($bulkData as $itemKey => $itemValue) {
-                    $bulkData[$itemKey] = \json_decode($itemValue, true);
+        $lock = Cache::lock(__CLASS__, 120);
+        try {
+            $lock->block(1);
+            // Lock acquired after waiting maximum of second...
+            $batchSize = \config('entry.batchSize', 10000);
+            $keys = app(BulkService::class)->keys();
+            foreach ($keys as $key) {
+                [$bulkName, $class] = \explode(':', $key, 2);
+                $chunkIterator = app(BulkService::class)
+                    ->chunkIterator($batchSize, $key);
+
+                foreach ($chunkIterator as $bulkData) {
+                    foreach ($bulkData as $itemKey => $itemValue) {
+                        $bulkData[$itemKey] = \json_decode($itemValue, true);
+                    }
+
+                    $queueName = \config('entry.queueName', 'default');
+                    $job = new BulkWriter(new $class, $bulkData);
+                    $job->onQueue($queueName);
+                    \dispatch($job);
                 }
-
-                $queueName = \config('entry.queueName', 'default');
-                $job = new BulkWriter(new $class, $bulkData);
-                $job->onQueue($queueName);
-                \dispatch($job);
             }
+        } catch (LockTimeoutException $timeoutException) {
+            // Unable to acquire lock...
+        } finally {
+            optional($lock)->release();
         }
     }