2012-04-10 14:06:46 +00:00
|
|
|
class History < ActiveRecord::Base
|
|
|
|
self.table_name = 'histories'
|
|
|
|
belongs_to :history_type, :class_name => 'History::Type'
|
|
|
|
belongs_to :history_object, :class_name => 'History::Object'
|
|
|
|
belongs_to :history_attribute, :class_name => 'History::Attribute'
|
|
|
|
# before_validation :check_type, :check_object
|
|
|
|
# attr_writer :history_type, :history_object
|
|
|
|
|
2012-07-10 08:09:58 +00:00
|
|
|
def self.history_create(data)
|
|
|
|
|
|
|
|
# lookups
|
|
|
|
history_type = History::Type.where( :name => data[:history_type] ).first
|
|
|
|
if !history_type || !history_type.id
|
|
|
|
history_type = History::Type.create(
|
|
|
|
:name => data[:history_type]
|
|
|
|
)
|
|
|
|
end
|
|
|
|
history_object = History::Object.where( :name => data[:history_object] ).first
|
|
|
|
if !history_object || !history_object.id
|
|
|
|
history_object = History::Object.create(
|
|
|
|
:name => data[:history_object]
|
|
|
|
)
|
|
|
|
end
|
|
|
|
related_history_object_id = nil
|
|
|
|
if data[:related_history_object]
|
|
|
|
related_history_object = History::Object.where( :name => data[:related_history_object] ).first
|
|
|
|
if !related_history_object || !related_history_object.id
|
|
|
|
related_history_object = History::Object.create(
|
|
|
|
:name => data[:related_history_object]
|
|
|
|
)
|
|
|
|
end
|
|
|
|
related_history_object_id = related_history_object.id
|
|
|
|
end
|
|
|
|
history_attribute_id = nil
|
|
|
|
if data[:history_attribute]
|
|
|
|
history_attribute = History::Attribute.where( :name => data[:history_attribute] ).first
|
|
|
|
if !history_attribute || !history_attribute.object_id
|
|
|
|
history_attribute = History::Attribute.create(
|
|
|
|
:name => data[:history_attribute]
|
|
|
|
)
|
|
|
|
end
|
|
|
|
history_attribute_id = history_attribute.id
|
|
|
|
end
|
|
|
|
|
|
|
|
# create history
|
|
|
|
History.create(
|
|
|
|
:o_id => data[:o_id],
|
|
|
|
:history_type_id => history_type.id,
|
|
|
|
:history_object_id => history_object.id,
|
|
|
|
:history_attribute_id => history_attribute_id,
|
|
|
|
:related_history_object_id => related_history_object_id,
|
|
|
|
:related_o_id => data[:related_o_id],
|
|
|
|
:value_from => data[:value_from],
|
|
|
|
:value_to => data[:value_to],
|
|
|
|
:id_from => data[:id_from],
|
|
|
|
:id_to => data[:id_to],
|
|
|
|
:created_by_id => data[:created_by_id]
|
|
|
|
)
|
|
|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
def self.history_destroy(requested_object, requested_object_id)
|
|
|
|
History.where( :history_object_id => History::Object.where( :name => requested_object ) ).
|
2012-04-10 14:06:46 +00:00
|
|
|
where( :o_id => requested_object_id ).
|
2012-07-10 08:09:58 +00:00
|
|
|
destroy_all
|
|
|
|
end
|
|
|
|
|
|
|
|
def self.history_list(requested_object, requested_object_id, related_history_object = nil)
|
|
|
|
if !related_history_object
|
|
|
|
history = History.where( :history_object_id => History::Object.where( :name => requested_object ) ).
|
|
|
|
where( :o_id => requested_object_id ).
|
2012-08-10 07:42:16 +00:00
|
|
|
where( :history_type_id => History::Type.where( :name => ['created', 'updated', 'notification', 'email'] ) ).
|
2012-07-10 08:09:58 +00:00
|
|
|
order('created_at ASC, id ASC')
|
|
|
|
else
|
|
|
|
history = History.where(
|
|
|
|
'((history_object_id = ? AND o_id = ?) OR (history_object_id = ? AND related_o_id = ? )) AND history_type_id IN (?)',
|
|
|
|
History::Object.where( :name => requested_object ).first.id,
|
|
|
|
requested_object_id,
|
|
|
|
History::Object.where( :name => related_history_object ).first.id,
|
|
|
|
requested_object_id,
|
2012-08-10 07:42:16 +00:00
|
|
|
History::Type.where( :name => ['created', 'updated', 'notification', 'email'] )
|
2012-07-10 08:09:58 +00:00
|
|
|
).
|
|
|
|
order('created_at ASC, id ASC')
|
|
|
|
end
|
|
|
|
|
|
|
|
list = []
|
|
|
|
history.each { |item|
|
|
|
|
item_tmp = item.attributes
|
|
|
|
item_tmp['history_type'] = item.history_type.name
|
|
|
|
item_tmp['history_object'] = item.history_object.name
|
|
|
|
if item.history_attribute
|
|
|
|
item_tmp['history_attribute'] = item.history_attribute.name
|
|
|
|
end
|
|
|
|
item_tmp.delete( 'history_attribute_id' )
|
|
|
|
item_tmp.delete( 'history_object_id' )
|
|
|
|
item_tmp.delete( 'history_type_id' )
|
|
|
|
item_tmp.delete( 'o_id' )
|
|
|
|
item_tmp.delete( 'updated_at' )
|
|
|
|
if item_tmp['id_to'] == nil && item_tmp['id_from'] == nil
|
|
|
|
item_tmp.delete( 'id_to' )
|
|
|
|
item_tmp.delete( 'id_from' )
|
|
|
|
end
|
|
|
|
if item_tmp['value_to'] == nil && item_tmp['value_from'] == nil
|
|
|
|
item_tmp.delete( 'value_to' )
|
|
|
|
item_tmp.delete( 'value_from' )
|
|
|
|
end
|
|
|
|
if item_tmp['related_history_object_id'] == nil
|
|
|
|
item_tmp.delete( 'related_history_object_id' )
|
|
|
|
end
|
|
|
|
if item_tmp['related_o_id'] == nil
|
|
|
|
item_tmp.delete( 'related_o_id' )
|
|
|
|
end
|
|
|
|
list.push item_tmp
|
|
|
|
}
|
|
|
|
return list
|
2012-04-10 14:06:46 +00:00
|
|
|
end
|
|
|
|
|
2012-10-18 19:29:56 +00:00
|
|
|
def self.activity_stream( user, limit = 10 )
|
2012-04-10 14:06:46 +00:00
|
|
|
# g = Group.where( :active => true ).joins(:users).where( 'users.id' => user.id )
|
|
|
|
# stream = History.select("distinct(histories.o_id), created_by_id, history_attribute_id, history_type_id, history_object_id, value_from, value_to").
|
2012-04-29 21:37:49 +00:00
|
|
|
# where( :history_type_id => History::Type.where( :name => ['created', 'updated']) ).
|
2012-04-10 14:06:46 +00:00
|
|
|
stream = History.select("distinct(histories.o_id), created_by_id, history_type_id, history_object_id").
|
2012-07-10 08:09:58 +00:00
|
|
|
where( :history_object_id => History::Object.where( :name => [ 'Ticket', 'Ticket::Article' ] ) ).
|
|
|
|
where( :history_type_id => History::Type.where( :name => [ 'created', 'updated' ]) ).
|
2012-04-10 14:06:46 +00:00
|
|
|
order('created_at DESC, id DESC').
|
2012-04-29 21:37:49 +00:00
|
|
|
limit(limit)
|
2012-04-20 12:25:13 +00:00
|
|
|
datas = []
|
2012-04-10 14:06:46 +00:00
|
|
|
stream.each do |item|
|
2012-04-20 12:25:13 +00:00
|
|
|
data = item.attributes
|
2012-07-10 08:09:58 +00:00
|
|
|
data['history_object'] = item.history_object.name
|
|
|
|
data['history_type'] = item.history_type.name
|
|
|
|
data.delete('history_object_id')
|
|
|
|
data.delete('history_type_id')
|
2012-04-20 12:25:13 +00:00
|
|
|
datas.push data
|
2012-04-10 14:06:46 +00:00
|
|
|
# item['history_attribute'] = item.history_attribute
|
|
|
|
end
|
2012-04-20 12:25:13 +00:00
|
|
|
return datas
|
2012-04-10 14:06:46 +00:00
|
|
|
end
|
2012-10-18 19:29:56 +00:00
|
|
|
def self.activity_stream_fulldata( user, limit = 10 )
|
2012-07-23 22:22:23 +00:00
|
|
|
activity_stream = History.activity_stream( user, limit )
|
|
|
|
|
|
|
|
# get related users
|
|
|
|
users = {}
|
|
|
|
tickets = []
|
|
|
|
articles = []
|
|
|
|
activity_stream.each {|item|
|
|
|
|
|
|
|
|
# load article ids
|
|
|
|
if item['history_object'] == 'Ticket'
|
|
|
|
ticket = Ticket.find( item['o_id'] ).attributes
|
|
|
|
tickets.push ticket
|
|
|
|
|
|
|
|
# load users
|
|
|
|
if !users[ ticket['owner_id'] ]
|
|
|
|
users[ ticket['owner_id'] ] = User.user_data_full( ticket['owner_id'] )
|
|
|
|
end
|
|
|
|
if !users[ ticket['customer_id'] ]
|
|
|
|
users[ ticket['customer_id'] ] = User.user_data_full( ticket['customer_id'] )
|
|
|
|
end
|
|
|
|
end
|
|
|
|
if item['history_object'] == 'Ticket::Article'
|
|
|
|
article = Ticket::Article.find( item['o_id'] ).attributes
|
|
|
|
if !article['subject'] || article['subject'] == ''
|
|
|
|
article['subject'] = Ticket.find( article['ticket_id'] ).title
|
|
|
|
end
|
|
|
|
articles.push article
|
|
|
|
|
|
|
|
# load users
|
|
|
|
if !users[ article['created_by_id'] ]
|
|
|
|
users[ article['created_by_id'] ] = User.user_data_full( article['created_by_id'] )
|
|
|
|
end
|
|
|
|
end
|
|
|
|
if item['history_object'] == 'User'
|
|
|
|
users[ item['o_id'] ] = User.user_data_full( item['o_id'] )
|
|
|
|
end
|
|
|
|
|
|
|
|
# load users
|
|
|
|
if !users[ item['created_by_id'] ]
|
|
|
|
users[ item['created_by_id'] ] = User.user_data_full( item['created_by_id'] )
|
|
|
|
end
|
|
|
|
}
|
|
|
|
|
|
|
|
return {
|
|
|
|
:activity_stream => activity_stream,
|
|
|
|
:tickets => tickets,
|
|
|
|
:articles => articles,
|
|
|
|
:users => users,
|
|
|
|
}
|
|
|
|
end
|
2012-04-10 14:06:46 +00:00
|
|
|
|
2012-10-18 19:23:05 +00:00
|
|
|
def self.recent_viewed( user, limit = 10 )
|
2012-04-10 14:06:46 +00:00
|
|
|
# g = Group.where( :active => true ).joins(:users).where( 'users.id' => user.id )
|
2012-07-23 22:22:23 +00:00
|
|
|
stream = History.select("distinct(o_id), created_by_id, history_type_id, history_object_id, created_at").
|
2012-04-10 14:06:46 +00:00
|
|
|
where( :history_object_id => History::Object.where( :name => 'Ticket').first.id ).
|
2012-07-23 22:22:23 +00:00
|
|
|
where( :history_type_id => History::Type.where( :name => ['viewed'] ) ).
|
2012-05-02 11:57:23 +00:00
|
|
|
where( :created_by_id => user.id ).
|
2012-07-23 22:22:23 +00:00
|
|
|
order('created_at DESC, id ASC').
|
2012-10-18 19:23:05 +00:00
|
|
|
limit(limit)
|
2012-04-20 12:25:13 +00:00
|
|
|
datas = []
|
2012-04-10 14:06:46 +00:00
|
|
|
stream.each do |item|
|
2012-04-20 12:25:13 +00:00
|
|
|
data = item.attributes
|
|
|
|
data['history_object'] = item.history_object
|
|
|
|
data['history_type'] = item.history_type
|
|
|
|
datas.push data
|
2012-04-10 14:06:46 +00:00
|
|
|
# item['history_attribute'] = item.history_attribute
|
|
|
|
end
|
2012-07-23 22:22:23 +00:00
|
|
|
# puts 'pppppppppp'
|
|
|
|
# puts datas.inspect
|
2012-04-20 12:25:13 +00:00
|
|
|
return datas
|
2012-04-10 14:06:46 +00:00
|
|
|
end
|
|
|
|
|
2012-10-18 19:29:56 +00:00
|
|
|
def self.recent_viewed_fulldata( user, limit = 10 )
|
2012-10-18 19:23:05 +00:00
|
|
|
recent_viewed = History.recent_viewed( user, limit )
|
2012-07-23 22:22:23 +00:00
|
|
|
|
|
|
|
# get related users
|
|
|
|
users = {}
|
|
|
|
tickets = []
|
|
|
|
recent_viewed.each {|item|
|
|
|
|
|
|
|
|
# load article ids
|
|
|
|
# if item.history_object == 'Ticket'
|
|
|
|
ticket = Ticket.find( item['o_id'] ).attributes
|
|
|
|
tickets.push ticket
|
|
|
|
# end
|
|
|
|
# if item.history_object 'Ticket::Article'
|
|
|
|
# tickets.push Ticket::Article.find(item.o_id)
|
|
|
|
# end
|
|
|
|
# if item.history_object 'User'
|
|
|
|
# tickets.push User.find(item.o_id)
|
|
|
|
# end
|
|
|
|
|
|
|
|
# load users
|
|
|
|
if !users[ ticket['owner_id'] ]
|
|
|
|
users[ ticket['owner_id'] ] = User.user_data_full( ticket['owner_id'] )
|
|
|
|
end
|
|
|
|
if !users[ ticket['created_by_id'] ]
|
|
|
|
users[ ticket['created_by_id'] ] = User.user_data_full( ticket['created_by_id'] )
|
|
|
|
end
|
|
|
|
if !users[ item['created_by_id'] ]
|
|
|
|
users[ item['created_by_id'] ] = User.user_data_full( item['created_by_id'] )
|
|
|
|
end
|
|
|
|
}
|
|
|
|
return {
|
|
|
|
:recent_viewed => recent_viewed,
|
|
|
|
:tickets => tickets,
|
|
|
|
:users => users,
|
|
|
|
}
|
|
|
|
end
|
|
|
|
|
2012-04-10 14:06:46 +00:00
|
|
|
private
|
|
|
|
def check_type
|
|
|
|
puts '--------------'
|
|
|
|
puts self.inspect
|
|
|
|
history_type = History::Type.where( :name => self.history_type ).first
|
|
|
|
if !history_type || !history_type.id
|
|
|
|
history_type = History::Type.create(
|
|
|
|
:name => self.history_type,
|
|
|
|
:active => true
|
|
|
|
)
|
|
|
|
end
|
|
|
|
self.history_type_id = history_type.id
|
|
|
|
end
|
|
|
|
def check_object
|
|
|
|
history_object = History::Object.where( :name => self.history_object ).first
|
|
|
|
if !history_object || !history_object.id
|
|
|
|
history_object = History::Object.create(
|
|
|
|
:name => self.history_object,
|
|
|
|
:active => true
|
|
|
|
)
|
|
|
|
end
|
|
|
|
self.history_object_id = history_object.id
|
|
|
|
end
|
|
|
|
|
|
|
|
class Object < ActiveRecord::Base
|
|
|
|
end
|
|
|
|
|
|
|
|
class Type < ActiveRecord::Base
|
|
|
|
end
|
|
|
|
|
|
|
|
class Attribute < ActiveRecord::Base
|
|
|
|
end
|
|
|
|
|
|
|
|
end
|