我正在编写像这样在 Schedule 模型中定义的任何时候的跑步者;
def self.scheduled_jobs
jobs = Schedule.where(execution_time <= Time.now )
if !jobs.nil?
jobs.each do |job|
task = Schedule.find(job)
MessageWorker.perform_async(task.message_id, task.lists, task.user_id)
task.destroy
end
end
end
这里的查询有问题;
jobs = Schedule.where(execution_time <= Time.now )
以及如何写好它的建议?
在控制台中的响应是;
NameError: undefined local variable or method
main:Object 的 execution_time'
总的来说,关于如何改进代码的任何建议?
每当 cron 工作在这里;
set :output, "/log/cron_log.log"
every 5.minute do
runner "Schedule.scheduled_jobs"
end