ExecuteDueTasks
in package
implements
ShouldQueue
uses
Dispatchable, InteractsWithQueue, Queueable, SerializesModels
Table of Contents
Interfaces
- ShouldQueue
Properties
Methods
- __construct() : mixed
- handle() : void
- Execute the job.
- executeReminder() : void
- Execute a reminder task
- executeReport() : void
- Execute a report task
- executeResearch() : void
- Execute a research task
- executeTask() : void
- Execute a single task Note: Task status is already set to 'running' in lockAndAcquireNextTask()
- getSmsService() : SmsService
- Get SmsService instance
- lockAndAcquireNextTask() : AiAssistantTask|null
- Lock and acquire the next due task atomically.
Properties
$rruleService
protected
RruleService
$rruleService
Methods
__construct()
public
__construct(RruleService $rruleService) : mixed
Parameters
- $rruleService : RruleService
handle()
Execute the job.
public
handle() : void
executeReminder()
Execute a reminder task
protected
executeReminder(AiAssistantTask $task) : void
Parameters
- $task : AiAssistantTask
executeReport()
Execute a report task
protected
executeReport(AiAssistantTask $task) : void
Parameters
- $task : AiAssistantTask
executeResearch()
Execute a research task
protected
executeResearch(AiAssistantTask $task) : void
Parameters
- $task : AiAssistantTask
executeTask()
Execute a single task Note: Task status is already set to 'running' in lockAndAcquireNextTask()
protected
executeTask(AiAssistantTask $task) : void
Parameters
- $task : AiAssistantTask
getSmsService()
Get SmsService instance
protected
getSmsService() : SmsService
Return values
SmsServicelockAndAcquireNextTask()
Lock and acquire the next due task atomically.
protected
lockAndAcquireNextTask() : AiAssistantTask|null
Uses lockForUpdate() to ensure only one worker can process each task.