119 lines
3.3 KiB
Ruby
119 lines
3.3 KiB
Ruby
# Copyright (C) 2012-2021 Zammad Foundation, http://zammad-foundation.org/
|
|
|
|
class Karma::ActivityLog < ApplicationModel
|
|
belongs_to :object_lookup, optional: true
|
|
belongs_to :user, class_name: '::User'
|
|
|
|
self.table_name = 'karma_activity_logs'
|
|
|
|
=begin
|
|
|
|
add karma activity log of an object
|
|
|
|
Karma::ActivityLog.add('ticket create', User.find(1), 'Ticket', 123)
|
|
|
|
=end
|
|
|
|
def self.add(action, user, object, o_id, force = false)
|
|
activity = Karma::Activity.lookup(name: action)
|
|
|
|
if object
|
|
object_id = ObjectLookup.by_name(object)
|
|
end
|
|
|
|
# scheduler transactions causes a lot of calls
|
|
# so we try to cache the add process
|
|
# to skip the time loss of the transaction
|
|
# to increase performance
|
|
if !force
|
|
cache = Cache.read("Karma::ActivityLog.add::#{activity.once_ttl.seconds}::#{action}::#{user.id}::#{object}::#{o_id}")
|
|
return cache if cache
|
|
end
|
|
|
|
Karma::ActivityLog.transaction do
|
|
last_activity = Karma::ActivityLog.where(user_id: user.id).order(id: :desc).lock(true).first
|
|
latest_activity = Karma::ActivityLog.where(
|
|
user_id: user.id,
|
|
object_lookup_id: object_id,
|
|
o_id: o_id,
|
|
activity_id: activity.id,
|
|
).find_by('created_at >= ?', Time.zone.now - activity.once_ttl.seconds)
|
|
return false if !force && latest_activity
|
|
|
|
score_total = 0
|
|
if last_activity
|
|
score_total = last_activity.score_total
|
|
end
|
|
|
|
local_score_total = score_total + activity.score
|
|
if local_score_total.negative?
|
|
local_score_total = 0
|
|
end
|
|
|
|
Karma::ActivityLog.create(
|
|
object_lookup_id: object_id,
|
|
o_id: o_id,
|
|
user_id: user.id,
|
|
activity_id: activity.id,
|
|
score: activity.score,
|
|
score_total: local_score_total,
|
|
)
|
|
|
|
if !force
|
|
Cache.write("Karma::ActivityLog.add::#{activity.once_ttl.seconds}::#{action}::#{user.id}::#{object}::#{o_id}", true, expires_in: activity.once_ttl.seconds)
|
|
end
|
|
end
|
|
|
|
# set new karma level
|
|
Karma::User.sync(user)
|
|
|
|
true
|
|
end
|
|
|
|
=begin
|
|
|
|
remove whole karma activity log of an object
|
|
|
|
Karma::ActivityLog.remove('Ticket', 123)
|
|
|
|
=end
|
|
|
|
def self.remove(object_name, o_id)
|
|
object_id = ObjectLookup.by_name(object_name)
|
|
Karma::ActivityLog.where(
|
|
object_lookup_id: object_id,
|
|
o_id: o_id,
|
|
).destroy_all
|
|
end
|
|
|
|
def self.latest(user, limit = 12)
|
|
result = []
|
|
logs = Karma::ActivityLog.where(user_id: user.id).order(id: :desc).limit(limit)
|
|
logs.each do |log|
|
|
last = result.last
|
|
if last && last[:object_id] == log.object_id && last[:o_id] == log.o_id && last[:created_at] == log.created_at
|
|
comment = {
|
|
description: Karma::Activity.lookup(id: log.activity_id).description,
|
|
score: log.score,
|
|
}
|
|
last[:comments].push comment
|
|
last[:score_total] = score_total
|
|
next
|
|
end
|
|
comment = {
|
|
object_id: log.object_id,
|
|
o_id: log.o_id,
|
|
description: Karma::Activity.lookup(id: log.activity_id).description,
|
|
score: log.score,
|
|
}
|
|
data = {
|
|
comments: [comment],
|
|
score_total: log.score_total,
|
|
created_at: log.created_at,
|
|
}
|
|
result.push data
|
|
end
|
|
result
|
|
end
|
|
|
|
end
|