88 lines
2.3 KiB
Ruby
88 lines
2.3 KiB
Ruby
|
# Copyright (C) 2012-2014 Zammad Foundation, http://zammad-foundation.org/
|
||
|
|
|
||
|
|
class Job < ApplicationModel
|
||
|
|
store :timeplan
|
||
|
|
store :condition
|
||
|
|
store :execute
|
||
|
|
validates :name, :presence => true
|
||
|
|
|
||
|
|
before_create :updated_matching
|
||
|
|
before_update :updated_matching
|
||
|
|
|
||
|
|
after_create :notify_clients_after_create
|
||
|
|
after_update :notify_clients_after_update
|
||
|
|
after_destroy :notify_clients_after_destroy
|
||
|
|
|
||
|
|
def self.run
|
||
|
|
time = Time.new
|
||
|
|
day_map = {
|
||
|
|
0 => 'sun',
|
||
|
|
1 => 'mon',
|
||
|
|
2 => 'tue',
|
||
|
|
3 => 'wed',
|
||
|
|
4 => 'thu',
|
||
|
|
5 => 'fri',
|
||
|
|
6 => 'sat',
|
||
|
|
}
|
||
|
|
jobs = Job.where( :active => true )
|
||
|
|
jobs.each do |job|
|
||
|
|
|
||
|
|
# only execute jobs, older then 2 min, to give admin posibility to change
|
||
|
|
next if job.updated_at > Time.now - 2.minutes
|
||
|
|
|
||
|
|
# check if jobs need to be executed
|
||
|
|
# ignore if job was running within last 10 min.
|
||
|
|
next if job.last_run_at > Time.now - 10.minutes
|
||
|
|
|
||
|
|
# check day
|
||
|
|
next if !job.timeplan['days'].include?( day_map[time.wday] )
|
||
|
|
|
||
|
|
# check hour
|
||
|
|
next if !job.timeplan['hours'].include?( time.hour.to_s )
|
||
|
|
|
||
|
|
# check min
|
||
|
|
next if !job.timeplan['minutes'].include?( match_minutes(time.min.to_s) )
|
||
|
|
|
||
|
|
# find tickets to change
|
||
|
|
tickets = Ticket.where( job.condition.permit! ).
|
||
|
|
order( '`tickets`.`created_at` DESC' ).
|
||
|
|
limit( 1_000 )
|
||
|
|
job.processed = tickets.count
|
||
|
|
tickets.each do |ticket|
|
||
|
|
#puts "CHANGE #{job.execute.inspect}"
|
||
|
|
changed = false
|
||
|
|
job.execute.each do |key, value|
|
||
|
|
changed = true
|
||
|
|
attribute = key.split('.', 2).last
|
||
|
|
#puts "-- #{Ticket.columns_hash[ attribute ].type.to_s}"
|
||
|
|
#value = 4
|
||
|
|
#if Ticket.columns_hash[ attribute ].type == :integer
|
||
|
|
# puts "to i #{attribute}/#{value.inspect}/#{value.to_i.inspect}"
|
||
|
|
# #value = value.to_i
|
||
|
|
#end
|
||
|
|
ticket[attribute] = value
|
||
|
|
#puts "set #{attribute} = #{value.inspect}"
|
||
|
|
end
|
||
|
|
next if !changed
|
||
|
|
ticket.updated_by_id = 1
|
||
|
|
ticket.save
|
||
|
|
end
|
||
|
|
|
||
|
|
job.last_run_at = Time.now
|
||
|
|
job.save
|
||
|
|
end
|
||
|
|
true
|
||
|
|
end
|
||
|
|
|
||
|
|
private
|
||
|
|
|
||
|
|
def updated_matching
|
||
|
|
count = Ticket.where( self.condition.permit! ).count
|
||
|
|
self.matching = count
|
||
|
|
end
|
||
|
|
|
||
|
|
def self.match_minutes(minutes)
|
||
|
|
minutes.gsub!(/(\d)\d/, "\\1")
|
||
|
|
minutes.to_s + '0'
|
||
|
|
end
|
||
|
|
end
|