28 lines
876 B
Ruby
28 lines
876 B
Ruby
# frozen_string_literal: true
|
|
|
|
module Jobs
|
|
class SyncTopicUserBookmarked < ::Jobs::Base
|
|
def execute(args = {})
|
|
topic_id = args[:topic_id]
|
|
|
|
DB.exec(<<~SQL, topic_id: topic_id)
|
|
UPDATE topic_users SET bookmarked = true
|
|
FROM bookmarks AS b
|
|
WHERE NOT topic_users.bookmarked AND
|
|
topic_users.topic_id = b.topic_id AND
|
|
topic_users.user_id = b.user_id #{topic_id.present? ? "AND topic_users.topic_id = :topic_id" : ""}
|
|
SQL
|
|
|
|
DB.exec(<<~SQL, topic_id: topic_id)
|
|
UPDATE topic_users SET bookmarked = false
|
|
WHERE topic_users.bookmarked AND
|
|
(
|
|
SELECT COUNT(*) FROM bookmarks
|
|
WHERE topic_id = topic_users.topic_id
|
|
AND user_id = topic_users.user_id
|
|
) = 0 #{topic_id.present? ? "AND topic_users.topic_id = :topic_id" : ""}
|
|
SQL
|
|
end
|
|
end
|
|
end
|