announcement-test/app/models/bulletin_feed.rb

179 lines
6.5 KiB
Ruby
Raw Normal View History

2015-07-08 10:11:25 +00:00
class BulletinFeed
include Mongoid::Document
include Mongoid::Timestamps
include Slug
2021-09-16 09:15:44 +00:00
field :title, as: :slug_title, type: String, localize: true
field :tag_ids, type: Array, default: []
field :category_ids, type: Array, default: []
2022-05-09 12:13:29 +00:00
field :remote_urls, type: Array, default: []
2020-07-22 03:11:58 +00:00
before_save do
2021-08-13 04:42:14 +00:00
BulletinFeedCache.where(uid: self.uid).each do |cache|
cache.regenerate
end
end
2022-04-18 15:32:19 +00:00
def annc_depts_translations
if defined?(OrbitHelper::SharedHash) && OrbitHelper::SharedHash
OrbitHelper::SharedHash['announcement'][:annc_depts_translations] rescue AnnouncementSetting.first.annc_depts_translations
else
AnnouncementSetting.first.annc_depts_translations rescue {}
end
end
def enable_annc_dept
if defined?(OrbitHelper::SharedHash) && OrbitHelper::SharedHash
OrbitHelper::SharedHash['announcement'][:enable_annc_dept] rescue AnnouncementSetting.first.enable_annc_dept
else
AnnouncementSetting.first.enable_annc_dept rescue false
end
end
2021-08-13 04:42:14 +00:00
def self.create_feed_cache(bulletin=nil,bulletin_feed=nil)
Thread.new do
if !bulletin.nil?
BulletinFeed.where(:tag_ids.in => Array(bulletin.tag_ids).collect{|v| v.to_s}).each do |bulletin_feed|
uid = bulletin_feed.uid
BulletinFeedCache.where(:uid => uid).each do |cache|
cache.regenerate
end
end
elsif !bulletin_feed.nil?
uid = bulletin_feed.uid
BulletinFeedCache.where(:uid => uid).each do |cache|
cache.regenerate
end
end
end
end
def generate_one_cache_timeout(startdt: nil,enddt: nil,dt: nil, base_url: nil, timeout: nil)
begin
2021-11-18 02:30:25 +00:00
if timeout.nil?
2022-02-23 05:57:42 +00:00
feed_cache_content = self.generate_one_cache(startdt: startdt,enddt: enddt,dt: dt,base_url: base_url)
2021-11-18 02:30:25 +00:00
else
2021-12-06 04:24:55 +00:00
Timeout::timeout(timeout) do
2022-02-23 05:57:42 +00:00
feed_cache_content = nil
2022-02-23 05:43:17 +00:00
thread = Thread.new do
2022-02-23 05:57:42 +00:00
feed_cache_content = self.generate_one_cache(startdt: startdt,enddt: enddt,dt: dt,base_url: base_url)
2021-11-18 02:30:25 +00:00
end
(1..(timeout.to_i+1)).each do
sleep(1)
2022-02-23 05:57:42 +00:00
break if !feed_cache_content.nil? && !thread.alive?
2021-11-18 02:30:25 +00:00
end
2022-02-23 05:57:42 +00:00
feed_cache_content
2021-12-06 04:24:55 +00:00
end
2021-11-18 02:30:25 +00:00
end
2021-08-13 04:42:14 +00:00
rescue=> e
puts [e,e.backtrace]
2022-03-29 08:49:13 +00:00
nil
2021-08-13 04:42:14 +00:00
end
end
def generate_one_cache(startdt: nil,enddt: nil,dt: nil, base_url: nil)
base_url = Site.first.root_url if base_url.nil?
uid = self.uid
bf = self
2022-04-18 15:32:19 +00:00
annc_depts = []
tmp_enable_annc_dept = (enable_annc_dept rescue false)
if tmp_enable_annc_dept
annc_depts = annc_depts_translations[I18n.default_locale.to_s] rescue []
end
2023-04-08 15:39:54 +00:00
tags = bf.tag_ids
categories = bf.category_ids
if !(categories.empty? && tags.empty?)
anns_before_filter = Bulletin.is_approved_and_show
can_display_and_sorted_flag = false
if !dt.nil?
dt = DateTime.parse(dt)
dtt = dt + 1.day
anns_before_filter = anns_before_filter.where(:postdate.gt => dt, :postdate.lt => dtt)
elsif !startdt.blank? && enddt.blank?
startdt = DateTime.parse(startdt)
enddt = DateTime.now
anns_before_filter = anns_before_filter.where(:postdate.gt => startdt, :postdate.lt => enddt)
elsif !startdt.blank? && !enddt.blank?
startdt = DateTime.parse(startdt)
enddt = DateTime.parse(enddt) + 1.day
anns_before_filter = anns_before_filter.where(:postdate.gt => startdt, :postdate.lt => enddt)
else
can_display_and_sorted_flag = true
end
2021-11-18 07:07:34 +00:00
2023-04-08 15:39:54 +00:00
if !tags.empty?
anns_before_filter = anns_before_filter.filter_by_tags(tags)
end
if !categories.empty?
anns_before_filter = anns_before_filter.filter_by_categories(categories,paginate=false)
end
anns_before_filter.selector = {"$and"=>[anns_before_filter.selector,{"$or"=>(I18n.available_locales.map{|v| {"title.#{v}"=>{"$nin"=>["", nil]}}})}]}
if can_display_and_sorted_flag
announcements = anns_before_filter.valid_time_range.to_a
2021-08-13 04:42:14 +00:00
else
2023-04-08 15:39:54 +00:00
announcements = anns_before_filter.to_a
2021-08-13 04:42:14 +00:00
end
2023-04-08 15:39:54 +00:00
else
anns_before_filter = Bulletin.can_display_and_sorted
announcements = anns_before_filter.to_a
2021-08-13 04:42:14 +00:00
end
all_anns = []
tag_ids = []
category_ids = []
first_postdate = anns_before_filter.open_in_future.limit(1).pluck(:postdate)[0]
first_deadline = nil
2021-12-30 08:12:12 +00:00
cat_ids = announcements.collect{|a| a.category_id.blank? ? nil : a.category_id.to_s}.compact.uniq
tag_ids = announcements.collect{|a| a.tag_ids.collect{|v| v.blank? ? nil : v.to_s}}.flatten.compact.uniq
2022-05-09 12:13:29 +00:00
tag_names = tag_ids.map{|tag_id| Tag.find(tag_id).name_translations rescue nil}.compact
category_titles = cat_ids.map{|cat_id| Category.find(cat_id).title_translations rescue nil}.compact
2021-12-30 08:12:12 +00:00
basic_query = {:module => 'announcement',:enabled_for=>I18n.locale}
if !cat_ids.blank?
query = basic_query.merge({:categories.all => cat_ids})
else
query = basic_query.clone
end
if !tag_ids.blank?
query = query.merge({:tags.all => tag_ids})
end
page = Page.where(query).first || Page.where(basic_query).first
2022-02-23 08:02:21 +00:00
more_url = page ? page.get_url : nil
2021-12-30 08:12:12 +00:00
2021-12-06 04:24:55 +00:00
announcements.each_with_index do |anns,i|
2021-08-13 04:42:14 +00:00
deadline = anns.deadline
if !deadline.blank?
if first_deadline.nil? || first_deadline>deadline
first_deadline = deadline
end
end
2022-05-09 12:13:29 +00:00
a = anns.get_data(annc_depts, tmp_enable_annc_dept, more_url, base_url, cat_ids, tag_ids)
2021-08-13 04:42:14 +00:00
all_anns << a
end
invalid_date = [first_postdate,first_deadline].compact.sort[0]
anns = {
"announcements" => all_anns,
"tags" => tag_names,
"categories" => category_titles
}.to_json
2021-12-28 08:32:20 +00:00
BulletinFeedCache.where(uid: uid,start: startdt,end: enddt,date: dt).destroy
2021-08-13 04:42:14 +00:00
feed_cache = BulletinFeedCache.create(uid: uid,content: anns,start: startdt,end: enddt,date: dt,invalid_date: invalid_date)
2022-03-29 08:51:09 +00:00
anns
2021-08-13 04:42:14 +00:00
end
def self.smart_convertor(text,url)
2021-12-06 04:24:55 +00:00
doc = Nokogiri.HTML(text)
doc.search('a[href]').each do |link|
if link['href'].nil?
link.delete 'href'
elsif link['href'].start_with?('/')
link['href'] = url + link['href']
elsif link['href'].start_with?('../')
link['href'] = url + link['href'][3..-1]
end
end
doc.search('img[src]').each do |link|
if link['src'].nil?
link.delete 'src'
elsif link['src'].start_with?('/')
link['src'] = url + link['src']
elsif link['src'].start_with?('../')
link['src'] = url + link['src'][3..-1]
end
end
return doc.css('body').inner_html
2020-07-22 03:11:58 +00:00
end
2015-07-08 10:11:25 +00:00
end