# Copyright (C) 2012-2013 Zammad Foundation, http://zammad-foundation.org/ require 'time_calculation' require 'sla' class Ticket < ApplicationModel before_create :check_generate, :check_defaults before_update :check_defaults before_destroy :destroy_dependencies after_create :notify_clients_after_create after_update :notify_clients_after_update after_destroy :notify_clients_after_destroy belongs_to :group has_many :articles, :class_name => 'Ticket::Article', :after_add => :cache_update, :after_remove => :cache_update belongs_to :organization belongs_to :ticket_state, :class_name => 'Ticket::State' belongs_to :ticket_priority, :class_name => 'Ticket::Priority' belongs_to :owner, :class_name => 'User' belongs_to :customer, :class_name => 'User' belongs_to :created_by, :class_name => 'User' belongs_to :create_article_type, :class_name => 'Ticket::Article::Type' belongs_to :create_article_sender, :class_name => 'Ticket::Article::Sender' attr_accessor :callback_loop def agent_of_group Group.find( self.group_id ).users.where( :active => true ).joins(:roles).where( 'roles.name' => 'Agent', 'roles.active' => true ).uniq() end def self.agents User.where( :active => true ).joins(:roles).where( 'roles.name' => 'Agent', 'roles.active' => true ).uniq() end def self.attributes_to_change(params) if params[:ticket_id] params[:ticket] = self.find( params[:ticket_id] ) end if params[:article_id] params[:article] = self.find( params[:article_id] ) end # get ticket states ticket_state_ids = [] if params[:ticket] ticket_state_type = params[:ticket].ticket_state.state_type end ticket_state_types = ['open', 'closed', 'pending action', 'pending reminder'] if ticket_state_type && !ticket_state_types.include?(ticket_state_type.name) ticket_state_ids.push params[:ticket].ticket_state.id end ticket_state_types.each {|type| ticket_state_type = Ticket::StateType.where( :name => type ).first if ticket_state_type ticket_state_type.states.each {|ticket_state| ticket_state_ids.push ticket_state.id } end } # get owner owner_ids = [] if params[:ticket] params[:ticket].agent_of_group.each { |user| owner_ids.push user.id } end # get group group_ids = [] Group.where( :active => true ).each { |group| group_ids.push group.id } # get group / user relations agents = {} Ticket.agents.each { |user| agents[ user.id ] = 1 } groups_users = {} group_ids.each {|group_id| groups_users[ group_id ] = [] Group.find( group_id ).users.each {|user| next if !agents[ user.id ] groups_users[ group_id ].push user.id } } # get priorities ticket_priority_ids = [] Ticket::Priority.where( :active => true ).each { |priority| ticket_priority_ids.push priority.id } ticket_article_type_ids = [] if params[:ticket] ticket_article_types = ['note', 'phone'] if params[:ticket].group.email_address_id ticket_article_types.push 'email' end ticket_article_types.each {|ticket_article_type_name| ticket_article_type = Ticket::Article::Type.lookup( :name => ticket_article_type_name ) if ticket_article_type ticket_article_type_ids.push ticket_article_type.id end } end return { :ticket_article_type_id => ticket_article_type_ids, :ticket_state_id => ticket_state_ids, :ticket_priority_id => ticket_priority_ids, :owner_id => owner_ids, :group_id => group_ids, :group_id__owner_id => groups_users, } end def merge_to(data) # update articles Ticket::Article.where( :ticket_id => self.id ).update_all( ['ticket_id = ?', data[:ticket_id] ] ) # update history # create new merge article Ticket::Article.create( :ticket_id => self.id, :ticket_article_type_id => Ticket::Article::Type.lookup( :name => 'note' ).id, :ticket_article_sender_id => Ticket::Article::Sender.lookup( :name => 'Agent' ).id, :body => 'merged', :internal => false ) # add history to both # link tickets Link.add( :link_type => 'parent', :link_object_source => 'Ticket', :link_object_source_value => data[:ticket_id], :link_object_target => 'Ticket', :link_object_target_value => self.id ) # set state to 'merged' self.ticket_state_id = Ticket::State.lookup( :name => 'merged' ).id # rest owner self.owner_id = User.where( :login => '-' ).first.id # save ticket self.save end # def self.agent # Role.where( :name => ['Agent'], :active => true ).first.users.where( :active => true ).uniq() # end def subject_build (subject) # clena subject subject = self.subject_clean(subject) ticket_hook = Setting.get('ticket_hook') ticket_hook_divider = Setting.get('ticket_hook_divider') # none position if Setting.get('ticket_hook_position') == 'none' return subject end # right position if Setting.get('ticket_hook_position') == 'right' return subject + " [#{ticket_hook}#{ticket_hook_divider}#{self.number}] " end # left position return "[#{ticket_hook}#{ticket_hook_divider}#{self.number}] " + subject end def subject_clean (subject) ticket_hook = Setting.get('ticket_hook') ticket_hook_divider = Setting.get('ticket_hook_divider') ticket_subject_size = Setting.get('ticket_subject_size') # remove all possible ticket hook formats with [] subject = subject.gsub /\[#{ticket_hook}: #{self.number}\](\s+?|)/, '' subject = subject.gsub /\[#{ticket_hook}:#{self.number}\](\s+?|)/, '' subject = subject.gsub /\[#{ticket_hook}#{ticket_hook_divider}#{self.number}\](\s+?|)/, '' # remove all possible ticket hook formats without [] subject = subject.gsub /#{ticket_hook}: #{self.number}(\s+?|)/, '' subject = subject.gsub /#{ticket_hook}:#{self.number}(\s+?|)/, '' subject = subject.gsub /#{ticket_hook}#{ticket_hook_divider}#{self.number}(\s+?|)/, '' # remove leading "..:\s" and "..[\d+]:\s" e. g. "Re: " or "Re[5]: " subject = subject.gsub /^(..(\[\d+\])?:\s)+/, '' # resize subject based on config if subject.length > ticket_subject_size.to_i subject = subject[ 0, ticket_subject_size.to_i ] + '[...]' end return subject end # ticket.permission( # :current_user => 123 # ) def permission (data) # check customer if data[:current_user].is_role('Customer') # access ok if its own ticket return true if self.customer_id == data[:current_user].id # access ok if its organization ticket if data[:current_user].organization_id && self.organization_id return true if self.organization_id == data[:current_user].organization_id end # no access return false end # check agent # access if requestor is owner return true if self.owner_id == data[:current_user].id # access if requestor is in group data[:current_user].groups.each {|group| return true if self.group.id == group.id } return false end # Ticket.search( # :current_user => 123, # :query => 'search something', # :limit => 15, # ) def self.search (params) # get params query = params[:query] limit = params[:limit] || 12 current_user = params[:current_user] conditions = [] if current_user.is_role('Agent') group_ids = Group.select( 'groups.id' ).joins(:users). where( 'groups_users.user_id = ?', current_user.id ). where( 'groups.active = ?', true ). map( &:id ) conditions = [ 'group_id IN (?)', group_ids ] else if !current_user.organization || ( !current_user.organization.shared || current_user.organization.shared == false ) conditions = [ 'customer_id = ?', current_user.id ] else conditions = [ '( customer_id = ? OR organization_id = ? )', current_user.id, current_user.organization.id ] end end # do query tickets_all = Ticket.select('DISTINCT(tickets.id)'). where(conditions). where( '( `tickets`.`title` LIKE ? OR `tickets`.`number` LIKE ? OR `ticket_articles`.`body` LIKE ? OR `ticket_articles`.`from` LIKE ? OR `ticket_articles`.`to` LIKE ? OR `ticket_articles`.`subject` LIKE ?)', "%#{query}%", "%#{query}%", "%#{query}%", "%#{query}%", "%#{query}%", "%#{query}%" ). joins(:articles). limit(limit). order('`tickets`.`created_at` DESC') # build result list tickets = [] users = {} tickets_all.each do |ticket| ticket_tmp = Ticket.lookup( :id => ticket.id ) tickets.push ticket_tmp end return tickets end # Ticket.overview_list( # :current_user => 123, # ) def self.overview_list (data) # get customer overviews if data[:current_user].is_role('Customer') role = data[:current_user].is_role( 'Customer' ) if data[:current_user].organization_id && data[:current_user].organization.shared overviews = Overview.where( :role_id => role.id, :active => true ) else overviews = Overview.where( :role_id => role.id, :organization_shared => false, :active => true ) end return overviews end # get agent overviews role = data[:current_user].is_role( 'Agent' ) overviews = Overview.where( :role_id => role.id, :active => true ) return overviews end # Ticket.overview( # :view => 'some_view_url', # :current_user => OBJECT, # ) def self.overview (data) overviews = self.overview_list(data) # build up attributes hash overview_selected = nil overview_selected_raw = nil overviews.each { |overview| # remember selected view if data[:view] && data[:view] == overview.link overview_selected = overview overview_selected_raw = Marshal.load( Marshal.dump(overview.attributes) ) end # replace e.g. 'current_user.id' with current_user.id overview.condition.each { |item, value | if value && value.class.to_s == 'String' parts = value.split( '.', 2 ) if parts[0] && parts[1] && parts[0] == 'current_user' overview.condition[item] = data[:current_user][parts[1].to_sym] end end } } if data[:view] && !overview_selected return end # sortby # prio # state # group # customer # order # asc # desc # groupby # prio # state # group # customer # all = attributes[:myopenassigned] # all.merge( { :group_id => groups } ) # @tickets = Ticket.where(:group_id => groups, attributes[:myopenassigned] ).limit(params[:limit]) # get only tickets with permissions if data[:current_user].is_role('Customer') group_ids = Group.select( 'groups.id' ). where( 'groups.active = ?', true ). map( &:id ) else group_ids = Group.select( 'groups.id' ).joins(:users). where( 'groups_users.user_id = ?', [ data[:current_user].id ] ). where( 'groups.active = ?', true ). map( &:id ) end # overview meta for navbar if !overview_selected # loop each overview result = [] overviews.each { |overview| # get count count = Ticket.where( :group_id => group_ids ).where( self._condition( overview.condition ) ).count() # get meta info all = { :name => overview.name, :prio => overview.prio, :link => overview.link, } # push to result data result.push all.merge( { :count => count } ) } return result end # get result list if data[:array] order_by = overview_selected[:order][:by].to_s + ' ' + overview_selected[:order][:direction].to_s if overview_selected.group_by && !overview_selected.group_by.empty? order_by = overview_selected.group_by + '_id, ' + order_by end tickets = Ticket.select( 'id' ). where( :group_id => group_ids ). where( self._condition( overview_selected.condition ) ). order( order_by ). limit( 500 ) ticket_ids = [] tickets.each { |ticket| ticket_ids.push ticket.id } tickets_count = Ticket.where( :group_id => group_ids ). where( self._condition( overview_selected.condition ) ). count() return { :ticket_list => ticket_ids, :tickets_count => tickets_count, :overview => overview_selected_raw, } end # get tickets for overview data[:start_page] ||= 1 tickets = Ticket.where( :group_id => group_ids ). where( self._condition( overview_selected.condition ) ). order( overview_selected[:order][:by].to_s + ' ' + overview_selected[:order][:direction].to_s )#. # limit( overview_selected.view[ data[:view_mode].to_sym ][:per_page] ). # offset( overview_selected.view[ data[:view_mode].to_sym ][:per_page].to_i * ( data[:start_page].to_i - 1 ) ) tickets_count = Ticket.where( :group_id => group_ids ). where( self._condition( overview_selected.condition ) ). count() return { :tickets => tickets, :tickets_count => tickets_count, :overview => overview_selected_raw, } end def self._condition(condition) sql = '' bind = [nil] condition.each {|key, value| if sql != '' sql += ' AND ' end if value.class == Array sql += " #{key} IN (?)" bind.push value elsif value.class == Hash || value.class == ActiveSupport::HashWithIndifferentAccess time = Time.now if value['area'] == 'minute' if value['direction'] == 'last' time -= value['count'].to_i * 60 else time += value['count'].to_i * 60 end elsif value['area'] == 'hour' if value['direction'] == 'last' time -= value['count'].to_i * 60 * 60 else time += value['count'].to_i * 60 * 60 end elsif value['area'] == 'day' if value['direction'] == 'last' time -= value['count'].to_i * 60 * 60 * 24 else time += value['count'].to_i * 60 * 60 * 24 end elsif value['area'] == 'month' if value['direction'] == 'last' time -= value['count'].to_i * 60 * 60 * 24 * 31 else time += value['count'].to_i * 60 * 60 * 24 * 31 end elsif value['area'] == 'year' if value['direction'] == 'last' time -= value['count'].to_i * 60 * 60 * 24 * 365 else time += value['count'].to_i * 60 * 60 * 24 * 365 end end if value['direction'] == 'last' sql += " #{key} > ?" bind.push time else sql += " #{key} < ?" bind.push time end else sql += " #{key} = ?" bind.push value end } bind[0] = sql return bind end def self.escalation_calculation_rebuild ticket_state_list_open = Ticket::State.by_category( 'open' ) tickets = Ticket.where( :ticket_state_id => ticket_state_list_open ) tickets.each {|ticket| ticket.escalation_calculation } end def _escalation_calculation_get_sla sla_selected = nil sla_list = Cache.get( 'SLA::List::Active' ) if sla_list == nil sla_list = Sla.where( :active => true ).all Cache.write( 'SLA::List::Active', sla_list, { :expires_in => 1.hour } ) end sla_list.each {|sla| if !sla.condition || sla.condition.empty? sla_selected = sla elsif sla.condition hit = false map = [ [ 'tickets.ticket_priority_id', 'ticket_priority_id' ], [ 'tickets.group_id', 'group_id' ] ] map.each {|item| if sla.condition[ item[0] ] if sla.condition[ item[0] ].class == String sla.condition[ item[0] ] = [ sla.condition[ item[0] ] ] end if sla.condition[ item[0] ].include?( self[ item[1] ].to_s ) hit = true else hit = false end end } if hit sla_selected = sla end end } return sla_selected end def _escalation_calculation_higher_time(escalation_time, check_time, done_time) return escalation_time if done_time return check_time if !escalation_time return escalation_time if !check_time return check_time if escalation_time > check_time return escalation_time end def escalation_calculation # set escalation off if ticket is already closed ticket_state = Ticket::State.lookup( :id => self.ticket_state_id ) if ticket_state.ignore_escalation? self.escalation_time = nil # self.first_response_escal_date = nil # self.close_time_escal_date = nil self.callback_loop = true self.save return true end # get sla for ticket sla_selected = self._escalation_calculation_get_sla # reset escalation if no sla is set if !sla_selected self.escalation_time = nil # self.first_response_escal_date = nil # self.close_time_escal_date = nil self.callback_loop = true self.save return true end # puts sla_selected.inspect # puts days.inspect self.escalation_time = nil self.first_response_escal_date = nil self.update_time_escal_date = nil self.close_time_escal_date = nil # first response if sla_selected.first_response_time # get escalation date without pending time self.first_response_escal_date = TimeCalculation.dest_time( self.created_at, sla_selected.first_response_time, sla_selected.data, sla_selected.timezone ) # get pending time between created and first response escal. time time_in_pending = escalation_suspend( self.created_at, self.first_response_escal_date, 'relative', sla_selected, sla_selected.first_response_time ) # get new escalation time (original escal_date + time_in_pending) self.first_response_escal_date = TimeCalculation.dest_time( self.first_response_escal_date, time_in_pending.to_i, sla_selected.data, sla_selected.timezone ) # set ticket escalation self.escalation_time = self._escalation_calculation_higher_time( self.escalation_time, self.first_response_escal_date, self.first_response ) end if self.first_response# && !self.first_response_in_min # get response time in min between created and first response self.first_response_in_min = escalation_suspend( self.created_at, self.first_response, 'real', sla_selected ) end # set time to show if sla is raised ot in if sla_selected.first_response_time && self.first_response_in_min self.first_response_diff_in_min = sla_selected.first_response_time - self.first_response_in_min end # update time last_update = self.last_contact_agent if !last_update last_update = self.created_at end if sla_selected.update_time self.update_time_escal_date = TimeCalculation.dest_time( last_update, sla_selected.update_time, sla_selected.data, sla_selected.timezone ) # get pending time between created and update escal. time time_in_pending = escalation_suspend( last_update, self.update_time_escal_date, 'relative', sla_selected, sla_selected.update_time ) # get new escalation time (original escal_date + time_in_pending) self.update_time_escal_date = TimeCalculation.dest_time( self.update_time_escal_date, time_in_pending.to_i, sla_selected.data, sla_selected.timezone ) # set ticket escalation self.escalation_time = self._escalation_calculation_higher_time( self.escalation_time, self.update_time_escal_date, false ) end if self.last_contact_agent self.update_time_in_min = TimeCalculation.business_time_diff( self.created_at, self.last_contact_agent, sla_selected.data, sla_selected.timezone ) end # set sla time if sla_selected.update_time && self.update_time_in_min self.update_time_diff_in_min = sla_selected.update_time - self.update_time_in_min end # close time if sla_selected.close_time # get escalation date without pending time self.close_time_escal_date = TimeCalculation.dest_time( self.created_at, sla_selected.close_time, sla_selected.data, sla_selected.timezone ) # get pending time between created and close escal. time extended_escalation = escalation_suspend( self.created_at, self.close_time_escal_date, 'relative', sla_selected, sla_selected.close_time ) # get new escalation time (original escal_date + time_in_pending) self.close_time_escal_date = TimeCalculation.dest_time( self.close_time_escal_date, extended_escalation.to_i, sla_selected.data, sla_selected.timezone ) # set ticket escalation self.escalation_time = self._escalation_calculation_higher_time( self.escalation_time, self.close_time_escal_date, self.close_time ) end if self.close_time # && !self.close_time_in_min self.close_time_in_min = escalation_suspend( self.created_at, self.close_time, 'real', sla_selected ) end # set sla time if sla_selected.close_time && self.close_time_in_min self.close_time_diff_in_min = sla_selected.close_time - self.close_time_in_min end self.callback_loop = true self.save end =begin list tickets by customer groupd in state categroie open and closed result = Ticket.list_by_customer( :customer_id => 123, :limit => 15, # optional, default 15 ) returns result = { :open => tickets_open, :closed => tickets_closed, } =end def self.list_by_customer(data) # get closed/open states ticket_state_list_open = Ticket::State.by_category( 'open' ) ticket_state_list_closed = Ticket::State.by_category( 'closed' ) # get tickets tickets_open = Ticket.where( :customer_id => data[:customer_id], :ticket_state_id => ticket_state_list_open ).limit( data[:limit] || 15 ).order('created_at DESC') tickets_closed = Ticket.where( :customer_id => data[:customer_id], :ticket_state_id => ticket_state_list_closed ).limit( data[:limit] || 15 ).order('created_at DESC') return { :open => tickets_open, :closed => tickets_closed, } end private def check_generate return if self.number self.number = Ticket::Number.generate end def check_defaults if !self.owner_id self.owner_id = 1 end # if self.customer_id && ( !self.organization_id || self.organization_id.empty? ) if self.customer_id customer = User.find( self.customer_id ) if self.organization_id != customer.organization_id self.organization_id = customer.organization_id end end end def destroy_dependencies # delete history History.remove( 'Ticket', self.id ) # delete articles self.articles.destroy_all end #type could be: # real - time without supsend state # relative - only suspend time def escalation_suspend (start_time, end_time, type, sla_selected, sla_time = 0) if type == 'relative' end_time += sla_time * 60 end total_time_without_pending = 0 total_time = 0 #get history for ticket history_list = History.list( 'Ticket', self.id ) #loop through hist. changes and get time last_state = nil last_state_change = nil last_state_is_pending = false history_list.each { |history_item| # ignore if it isn't a state change next if !history_item.history_attribute_id history_attribute = History::Attribute.lookup( :id => history_item.history_attribute_id ); next if history_attribute.name != 'ticket_state' # ignore all newer state before start_time next if history_item.created_at < start_time # ignore all older state changes after end_time next if last_state_change && last_state_change > end_time # if created_at is later then end_time, use end_time as last time if history_item.created_at > end_time history_item.created_at = end_time end # get initial state and time if !last_state last_state = history_item.value_from last_state_change = start_time end # check if time need to be counted counted = true if history_item.value_from == 'pending' counted = false elsif history_item.value_from == 'close' counted = false end diff = escalation_time_diff( last_state_change, history_item.created_at, sla_selected ) if counted puts "Diff count #{history_item.value_from} -> #{history_item.value_to} / #{last_state_change} -> #{history_item.created_at}" total_time_without_pending = total_time_without_pending + diff else puts "Diff not count #{history_item.value_from} -> #{history_item.value_to} / #{last_state_change} -> #{history_item.created_at}" end total_time = total_time + diff if history_item.value_to == 'pending' last_state_is_pending = true else last_state_is_pending = false end # remember for next loop last state last_state = history_item.value_to last_state_change = history_item.created_at } # if last state isnt pending, count rest if !last_state_is_pending && last_state_change && last_state_change < end_time diff = escalation_time_diff( last_state_change, end_time, sla_selected ) puts "Diff count last state was not pending #{diff.to_s} - #{last_state_change} - #{end_time}" total_time_without_pending = total_time_without_pending + diff total_time = total_time + diff end # if we have not had any state change if !last_state_change diff = escalation_time_diff( start_time, end_time, sla_selected ) puts 'Diff state has not changed ' + diff.to_s total_time_without_pending = total_time_without_pending + diff total_time = total_time + diff end #return sum if type == 'real' return total_time_without_pending elsif type == 'relative' relative = total_time - total_time_without_pending return relative else raise "ERROR: Unknown type #{type}" end end def escalation_time_diff( start_time, end_time, sla_selected ) if sla_selected diff = TimeCalculation.business_time_diff( start_time, end_time, sla_selected.data, sla_selected.timezone) else diff = TimeCalculation.business_time_diff( start_time, end_time ) end diff end end