Scheduler Props

Author: pierophp

README.md

@@ -75,7 +75,7 @@ To the job work correctly, it is necessary generate a row in the queue_config ta
 | class_name      | The full path with namespace of your job class (\App\Jobs\TestJob)                                                                        |
 | active          | If the job is active or not                                                                                                               |
 | schedulable     | If the job is schedulable or not                                                                                                          |
-| schedule_config | A JSON config of the schedule. {"method" : "The schedule methods from laravel", "params": "The params to the schedule method (optional)"} |
+| schedule_config | A JSON config of the schedule. {"method" : "The schedule methods from laravel", "params": "The params to the schedule method (optional)", "props": [ { "my_job_prop": 1 }, { "my_job_prop": 2 } ]} |
 | max_attemps     | The max attempts of the queue                                                                                                             |
 | max_instances   | The max parallel instances of the queue                                                                                                   |
 | timeout         | The timeout of the queue                                                                                                                  |

src/AbstractJob.php

@@ -17,9 +17,17 @@ abstract class AbstractJob implements ShouldQueue
 
     private $connectionName;
 
+    protected $name;
+
     abstract function execute();
 
-    abstract function getName();
+    public function setName($name) {
+        $this->name = $name;
+    }
+
+    public function getName() {
+        return $this->name;
+    }
 
     private function preventKillProcess()
     {
@@ -66,6 +74,9 @@ final public function dispatch()
     final public function setProps($props)
     {
         foreach ($props as $key => $value) {
+            if ($value instanceof \stdClass) {
+                $value = json_encode($value);
+            }
             $this->$key = $value;
         }
     }

src/Core/Scheduler.php

@@ -28,13 +28,20 @@ public static function schedule(Schedule $schedule)
                 $params = $scheduleConfig->params;
             }
 
-            $schedule->call(function () use ($schedulableQueue) {
-
+            $schedule->call(function () use ($schedulableQueue, $scheduleConfig) {
                 $className = $schedulableQueue->class_name;
-
-                $job = (new $className());
-                $job->dispatch();
-
+                if ($scheduleConfig->props && is_array($scheduleConfig->props)) {
+                    foreach($scheduleConfig->props as $prop) {
+                        $job = (new $className());    
+                        $job->setName($schedulableQueue->name);
+                        $job->setProps($prop);
+                        $job->dispatch();
+                    }
+                } else {
+                    $job = (new $className());    
+                    $job->setName($schedulableQueue->name);
+                    $job->dispatch();
+                }
             })->$method($params);
         }
     }