From 320803b4b97cf0f911d06df0260ad781500b0b89 Mon Sep 17 00:00:00 2001 From: Manson Wang Date: Wed, 12 Feb 2014 12:08:37 +0800 Subject: [PATCH] Orbit Feed Module --- .gitignore | 6 + Gemfile | 17 ++ MIT-LICENSE | 20 +++ README.rdoc | 3 + Rakefile | 39 +++++ app/assets/images/feed/.gitkeep | 0 app/assets/javascripts/feed/.gitkeep | 0 .../javascripts/panel/feed/back_end/feeds.js | 2 + app/assets/stylesheets/gprs/.gitkeep | 0 app/assets/stylesheets/location/.gitkeep | 0 .../panel/gprs/back_end/locations.css | 4 + .../panel/location/back_end/locations.css | 4 + app/controllers/.gitkeep | 0 .../feed/back_end/feed_requests_controller.rb | 34 ++++ .../panel/feed/back_end/feeds_controller.rb | 147 ++++++++++++++++++ app/helpers/.gitkeep | 0 app/mailers/.gitkeep | 0 app/models/.gitkeep | 0 app/models/announcement_feed.rb | 13 ++ app/views/.gitkeep | 0 .../panel/feed/back_end/feeds/_form.html.erb | 28 ++++ .../panel/feed/back_end/feeds/edit.html.erb | 63 ++++++++ .../panel/feed/back_end/feeds/index.html.erb | 60 +++++++ .../panel/feed/back_end/feeds/new.html.erb | 31 ++++ config/locales/en.yml | 22 +++ config/locales/zh_tw.yml | 22 +++ config/routes.rb | 16 ++ feed.gemspec | 22 +++ lib/feed.rb | 30 ++++ lib/feed/version.rb | 3 + lib/rss_dynamic.rb | 114 ++++++++++++++ script/rails | 6 + 32 files changed, 706 insertions(+) create mode 100644 .gitignore create mode 100644 Gemfile create mode 100644 MIT-LICENSE create mode 100644 README.rdoc create mode 100644 Rakefile create mode 100644 app/assets/images/feed/.gitkeep create mode 100644 app/assets/javascripts/feed/.gitkeep create mode 100644 app/assets/javascripts/panel/feed/back_end/feeds.js create mode 100644 app/assets/stylesheets/gprs/.gitkeep create mode 100644 app/assets/stylesheets/location/.gitkeep create mode 100644 app/assets/stylesheets/panel/gprs/back_end/locations.css create mode 100644 app/assets/stylesheets/panel/location/back_end/locations.css create mode 100644 app/controllers/.gitkeep create mode 100644 app/controllers/panel/feed/back_end/feed_requests_controller.rb create mode 100644 app/controllers/panel/feed/back_end/feeds_controller.rb create mode 100644 app/helpers/.gitkeep create mode 100644 app/mailers/.gitkeep create mode 100644 app/models/.gitkeep create mode 100644 app/models/announcement_feed.rb create mode 100644 app/views/.gitkeep create mode 100644 app/views/panel/feed/back_end/feeds/_form.html.erb create mode 100644 app/views/panel/feed/back_end/feeds/edit.html.erb create mode 100644 app/views/panel/feed/back_end/feeds/index.html.erb create mode 100644 app/views/panel/feed/back_end/feeds/new.html.erb create mode 100644 config/locales/en.yml create mode 100644 config/locales/zh_tw.yml create mode 100644 config/routes.rb create mode 100644 feed.gemspec create mode 100644 lib/feed.rb create mode 100644 lib/feed/version.rb create mode 100644 lib/rss_dynamic.rb create mode 100755 script/rails diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..1463de6 --- /dev/null +++ b/.gitignore @@ -0,0 +1,6 @@ +.bundle/ +log/*.log +pkg/ +test/dummy/db/*.sqlite3 +test/dummy/log/*.log +test/dummy/tmp/ \ No newline at end of file diff --git a/Gemfile b/Gemfile new file mode 100644 index 0000000..a6e487f --- /dev/null +++ b/Gemfile @@ -0,0 +1,17 @@ +source "http://rubygems.org" + +# Declare your gem's dependencies in location.gemspec. +# Bundler will treat runtime dependencies like base dependencies, and +# development dependencies will be added by default to the :development group. +gemspec + +# jquery-rails is used by the dummy application +gem "jquery-rails" + +# Declare any dependencies that are still in development here instead of in +# your gemspec. These might include edge Rails or gems from your path or +# Git. Remember to move these dependencies to your gemspec before releasing +# your gem to rubygems.org. + +# To use debugger +# gem 'ruby-debug19', :require => 'ruby-debug' diff --git a/MIT-LICENSE b/MIT-LICENSE new file mode 100644 index 0000000..406f17b --- /dev/null +++ b/MIT-LICENSE @@ -0,0 +1,20 @@ +Copyright 2012 YOURNAME + +Permission is hereby granted, free of charge, to any person obtaining +a copy of this software and associated documentation files (the +"Software"), to deal in the Software without restriction, including +without limitation the rights to use, copy, modify, merge, publish, +distribute, sublicense, and/or sell copies of the Software, and to +permit persons to whom the Software is furnished to do so, subject to +the following conditions: + +The above copyright notice and this permission notice shall be +included in all copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, +EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF +MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND +NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE +LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION +OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION +WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. diff --git a/README.rdoc b/README.rdoc new file mode 100644 index 0000000..937b414 --- /dev/null +++ b/README.rdoc @@ -0,0 +1,3 @@ += Location + +This project rocks and uses MIT-LICENSE. diff --git a/Rakefile b/Rakefile new file mode 100644 index 0000000..6635337 --- /dev/null +++ b/Rakefile @@ -0,0 +1,39 @@ +#!/usr/bin/env rake +begin + require 'bundler/setup' +rescue LoadError + puts 'You must `gem install bundler` and `bundle install` to run rake tasks' +end +begin + require 'rdoc/task' +rescue LoadError + require 'rdoc/rdoc' + require 'rake/rdoctask' + RDoc::Task = Rake::RDocTask +end + +RDoc::Task.new(:rdoc) do |rdoc| + rdoc.rdoc_dir = 'rdoc' + rdoc.title = 'Location' + rdoc.options << '--line-numbers' + rdoc.rdoc_files.include('README.rdoc') + rdoc.rdoc_files.include('lib/**/*.rb') +end + +APP_RAKEFILE = File.expand_path("../test/dummy/Rakefile", __FILE__) +load 'rails/tasks/engine.rake' + + +Bundler::GemHelper.install_tasks + +require 'rake/testtask' + +Rake::TestTask.new(:test) do |t| + t.libs << 'lib' + t.libs << 'test' + t.pattern = 'test/**/*_test.rb' + t.verbose = false +end + + +task :default => :test diff --git a/app/assets/images/feed/.gitkeep b/app/assets/images/feed/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/app/assets/javascripts/feed/.gitkeep b/app/assets/javascripts/feed/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/app/assets/javascripts/panel/feed/back_end/feeds.js b/app/assets/javascripts/panel/feed/back_end/feeds.js new file mode 100644 index 0000000..89daa90 --- /dev/null +++ b/app/assets/javascripts/panel/feed/back_end/feeds.js @@ -0,0 +1,2 @@ +// Place all the behaviors and hooks related to the matching controller here. +// All this logic will automatically be available in application.js. \ No newline at end of file diff --git a/app/assets/stylesheets/gprs/.gitkeep b/app/assets/stylesheets/gprs/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/app/assets/stylesheets/location/.gitkeep b/app/assets/stylesheets/location/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/app/assets/stylesheets/panel/gprs/back_end/locations.css b/app/assets/stylesheets/panel/gprs/back_end/locations.css new file mode 100644 index 0000000..afad32d --- /dev/null +++ b/app/assets/stylesheets/panel/gprs/back_end/locations.css @@ -0,0 +1,4 @@ +/* + Place all the styles related to the matching controller here. + They will automatically be included in application.css. +*/ diff --git a/app/assets/stylesheets/panel/location/back_end/locations.css b/app/assets/stylesheets/panel/location/back_end/locations.css new file mode 100644 index 0000000..afad32d --- /dev/null +++ b/app/assets/stylesheets/panel/location/back_end/locations.css @@ -0,0 +1,4 @@ +/* + Place all the styles related to the matching controller here. + They will automatically be included in application.css. +*/ diff --git a/app/controllers/.gitkeep b/app/controllers/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/app/controllers/panel/feed/back_end/feed_requests_controller.rb b/app/controllers/panel/feed/back_end/feed_requests_controller.rb new file mode 100644 index 0000000..2bd3366 --- /dev/null +++ b/app/controllers/panel/feed/back_end/feed_requests_controller.rb @@ -0,0 +1,34 @@ +# encoding: utf-8 +class Panel::Feed::BackEnd::FeedRequestsController < OrbitBackendController + + skip_before_filter :verify_authenticity_token + open_for_visitor :only => [:transferred_request, :accepted_request] + + def transferred_request + if request.headers["HTTP_X_AUTH_TOKEN"] == '3kjlfksjDFJ' + permission_feed = AnnouncementFeed.new( + link: params['link'], + name: params['name'], + categories: params['categories'].split, + from_request: true, + from_request_link: request.host) + + permission_feed.save! + + render :nothing => true + else + render :status => 500 + end + end + + def accepted_request + if request.headers["HTTP_X_AUTH_TOKEN"] == '3kjlfksjDFJ' + accepted_feed = AnnouncementFeed.where({name: params['name'], link: params['link'], categories: params['categories'].split}).first + accepted_feed.update_attributes({accepted: true}) + + render :nothing => true + else + render :status => 500 + end + end +end \ No newline at end of file diff --git a/app/controllers/panel/feed/back_end/feeds_controller.rb b/app/controllers/panel/feed/back_end/feeds_controller.rb new file mode 100644 index 0000000..6c7a94a --- /dev/null +++ b/app/controllers/panel/feed/back_end/feeds_controller.rb @@ -0,0 +1,147 @@ +# encoding: utf-8 +class Panel::Feed::BackEnd::FeedsController < OrbitBackendController + before_filter :skip_current_site, only: [:new, :create] + + CATEGORIES = %w{全部 緊急 一般 研討會 演講 活動 徵才 招標 拖吊 校外 過期 H1N1 失物招領 近期} + + # Sites available for subscription + SITES = [ ["總務處 - 總務處", "www.ga.ntu.edu.tw", "0"], + ["總務處 - 總務長室暨總務處秘書室", "sec.ga.ntu.edu.tw", "1"], + ["總務處 - 文書組", "doc.ga.ntu.edu.tw", "2"], + ["總務處 - 事務組", "general.ga.ntu.edu.tw", "3"], + ["總務處 - 保管組", "property.ga.ntu.edu.tw", "4"], + ["總務處 - 營繕組", "construction.ga.ntu.edu.tw", "5"], + ["總務處 - 出納組", "cashier.ga.ntu.edu.tw", "6"], + ["總務處 - 採購組", "procurement.ga.ntu.edu.tw", "7"], + ["總務處 - 經營管理組", "fss.ga.ntu.edu.tw", "8"], + ["總務處 - 駐警隊", "police.ga.ntu.edu.tw", "9"], + ["社科院總務分處", "social.ga.ntu.edu.tw", "10"], + ["醫學院總務分處", "medicine.ga.ntu.edu.tw", "11"] ] + + def index + @feeds = AnnouncementFeed.where({from_request: false}) + @permission_feeds = AnnouncementFeed.where({from_request: true}) + + respond_to do |format| + format.html + end + end + + def new + @feed = AnnouncementFeed.new + @categories = CATEGORIES + @sites = @filtered_sites + end + + def edit + @feed = AnnouncementFeed.find(params[:id]) + @current_categories = @feed.categories + @categories = CATEGORIES + end + + def create + @feed = AnnouncementFeed.new(params[:announcement_feed]) + @feed.name = SITES[ params[:site].to_i ][0] + @feed.link = SITES[ params[:site].to_i ][1] + @categories = CATEGORIES + @sites = @filtered_sites + # if @feed.save + ## Testing(TO-DO) ## + if permission_request(@feed) + @feed.save + redirect_to panel_feed_back_end_feeds_url + else + flash.now[:notice] = t('feed.connection_fail') + render 'new' + end + end + + def update + @feed = AnnouncementFeed.find(params[:id]) + if @feed.update_attributes(params[:announcement_feed]) + redirect_to panel_feed_back_end_feeds_url + else + render 'edit' + end + end + + def destroy + @feed = AnnouncementFeed.find(params[:id]) + @feed.destroy + + redirect_to panel_feed_back_end_feeds_url + end + + def agree + require 'net/http' + require 'uri' + require 'json' + + @feed = AnnouncementFeed.find(params[:id], conditions: [ "from_request = ?", true]) + + uri_path = "/panel/feed/back_end/feed_requests/accepted_request" + http = Net::HTTP.new(@feed.from_request_link, 80) + request = Net::HTTP::Post.new(uri_path) + + categories = @feed.categories.join(' ') + body = { + 'link' => @feed.link, + 'name' => @feed.name, + 'categories' => categories + } + + 3.times do + request.set_form_data(body) + request.add_field 'X-Auth-Token', '3kjlfksjDFJ' + response = http.request(request) + + if response.code == "200" + @feed.destroy + break + end + end + + redirect_to panel_feed_back_end_feeds_url + end + + def permission_request(feed) + require 'net/http' + require 'uri' + require 'json' + + uri_path = "/panel/feed/back_end/feed_requests/transferred_request" + # http = Net::HTTP.new(feed.link, 80) + http = Net::HTTP.new(feed.link, 80) + request = Net::HTTP::Post.new(uri_path) + + categories = feed.categories.join(' ') unless feed.categories.blank? + + body = { + 'link' => feed.link, + 'name' => feed.name, + 'categories' => categories + } + + status = false + + 3.times do + request.set_form_data(body) + request.add_field 'X-Auth-Token', '3kjlfksjDFJ' + response = http.request(request) + + if response.code == "200" + status = true + break + end + end + + return status + end + + private + + def skip_current_site + @filtered_sites = SITES.collect {|site| site unless site[1] == request.host} + @filtered_sites.compact! + end +end \ No newline at end of file diff --git a/app/helpers/.gitkeep b/app/helpers/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/app/mailers/.gitkeep b/app/mailers/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/app/models/.gitkeep b/app/models/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/app/models/announcement_feed.rb b/app/models/announcement_feed.rb new file mode 100644 index 0000000..2a1c0e6 --- /dev/null +++ b/app/models/announcement_feed.rb @@ -0,0 +1,13 @@ +class AnnouncementFeed + include Mongoid::Document + include Mongoid::Timestamps + + field :link, type: String + field :name, type: String + field :categories, type: Array + field :accepted, type: Boolean, default: false + field :from_request, type: Boolean, default: false + field :from_request_link, type: String + + validates :categories, presence: true +end \ No newline at end of file diff --git a/app/views/.gitkeep b/app/views/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/app/views/panel/feed/back_end/feeds/_form.html.erb b/app/views/panel/feed/back_end/feeds/_form.html.erb new file mode 100644 index 0000000..584764c --- /dev/null +++ b/app/views/panel/feed/back_end/feeds/_form.html.erb @@ -0,0 +1,28 @@ +

<%= t('feed.channel') %>

 +
+ +
+ +
+ <%= select_tag(:site, options_for_select(@sites)) %> +
+
+ +
+ +
+ <% @categories.each_with_index do |category, i| %> + <%= content_tag :label, :class => "checkbox inline" do -%> + <%= check_box("announcement_feed", "categories", {:multiple => true, :id => i}, category, nil) %> + + <% end -%> + <% end %> +
+
+ +
+
+ <%= f.submit t("submit"), :class => "btn btn-primary" %> +
+
+
\ No newline at end of file diff --git a/app/views/panel/feed/back_end/feeds/edit.html.erb b/app/views/panel/feed/back_end/feeds/edit.html.erb new file mode 100644 index 0000000..8a95444 --- /dev/null +++ b/app/views/panel/feed/back_end/feeds/edit.html.erb @@ -0,0 +1,63 @@ +<%= form_for @feed, :url => panel_feed_back_end_feed_path, :method => :put, :html => {:class => "form-horizontal"} do |f| %> + +

<%= t('feed.channel') %>

 +
+ +
+ +
+

<%= @feed.name %>

+
+
+ +
+ +
+ <% @categories.each_with_index do |category, i| %> + <%= content_tag :label, :class => "checkbox inline" do -%> + <%= check_box("announcement_feed", "categories", {:multiple => true, :id => i}, category, nil) %> + + <% end -%> + <% end %> +
+
+ +
+
+ <%= f.submit t("submit"), :class => "btn btn-primary" %> +
+
+ +
+<% end %> + + + \ No newline at end of file diff --git a/app/views/panel/feed/back_end/feeds/index.html.erb b/app/views/panel/feed/back_end/feeds/index.html.erb new file mode 100644 index 0000000..33f7b5f --- /dev/null +++ b/app/views/panel/feed/back_end/feeds/index.html.erb @@ -0,0 +1,60 @@ + + + + + + <%if is_manager? %> + + + + <% end %> + + + + <% @feeds.each do |feed| %> + + + <%if is_manager? %> + + + + <% end %> + + <% end %> + +

<%= t('feed.channel') %>

<%= t('RSS') %><%= t('feed.edit') %><%= t('feed.delete') %><%= t('feed.status.status') %>
<%= feed.name %><%= link_to t('feed.edit'), edit_panel_feed_back_end_feed_path(feed) %><%= link_to t('feed.cancel'), panel_feed_back_end_feed_path(feed), method: :delete, confirm: t(:sure?) %> + <%- if feed.accepted? %> + <%= t('feed.status.accepted') %> + <% else %> + <%= t('feed.status.unaccepted') %> + <% end -%> +
+ +<%if is_manager? %> +
+ <%= link_to t('feed.new'), new_panel_feed_back_end_feed_path, :class => "btn btn-primary pull-right", :id => "create_event_btn", :ref => "add-btn" %> +<% end %> + + + + + + + <%if is_manager? %> + + <% end %> + + + + <% @permission_feeds.each do |feed| %> + + + <%if is_manager? %> + + <% end %> + + <% end %> + +

<%= t('feed.status.permission') %>

<%= t('URL') %><%= t('feed.permit') %>
<%= feed.from_request_link %><%= link_to t('feed.agree'), agree_panel_feed_back_end_feeds_path(feed), method: :post, class: "btn btn-primary" %>
+ + diff --git a/app/views/panel/feed/back_end/feeds/new.html.erb b/app/views/panel/feed/back_end/feeds/new.html.erb new file mode 100644 index 0000000..c481da1 --- /dev/null +++ b/app/views/panel/feed/back_end/feeds/new.html.erb @@ -0,0 +1,31 @@ +<%= form_for @feed, :url => panel_feed_back_end_feeds_path, :html => { :class=>"form-horizontal"} do |f| %> + <%= render :partial => 'form', :locals => {:f => f} %> +<% end %> + + diff --git a/config/locales/en.yml b/config/locales/en.yml new file mode 100644 index 0000000..c9647f7 --- /dev/null +++ b/config/locales/en.yml @@ -0,0 +1,22 @@ +en: + feed: + all: All + choose: Choose a Category + choose_rss: Choose a RSS site + current_rss: Current RSS site + feed: RSS + channel: Announcement RSS + status: + status: Status + accepted: Accepted + unaccepted: Unaccepted + permission: Announcement RSS Waiting for Permission + new: New + edit: Edit + delete: Delete + cancel: Cancel RSS + enter: Enter + name: Name + permit: Permit + agree: Agree + connection_fail: Connection Fail \ No newline at end of file diff --git a/config/locales/zh_tw.yml b/config/locales/zh_tw.yml new file mode 100644 index 0000000..9835ac4 --- /dev/null +++ b/config/locales/zh_tw.yml @@ -0,0 +1,22 @@ +zh_tw: + feed: + all: 全部 + choose: 選擇訂閱類別 + choose_rss: 選擇訂閱RSS站 + current_rss: 訂閱的RSS站 + feed: RSS + channel: 公告RSS訂閱 + status: + status: 狀態 + accepted: 已授權 + unaccepted: 未授權 + permission: 待授權公告RSS訂閱 + new: 新增 + edit: 編輯 + delete: 刪除 + cancel: 取消訂閱 + enter: 輸入 + name: 名稱 + permit: 授權 + agree: 同意 + connection_fail: 無法取得與對方的連線！ \ No newline at end of file diff --git a/config/routes.rb b/config/routes.rb new file mode 100644 index 0000000..50870cd --- /dev/null +++ b/config/routes.rb @@ -0,0 +1,16 @@ +Rails.application.routes.draw do + namespace :panel do + namespace :feed do + namespace :back_end do + resources :feeds do + collection do + post "/:id/agree" => "feeds#agree", :as => 'agree' + end + end + + post "feed_requests/transferred_request" => "feed_requests#transferred_request", :as => 'transferred_request' + post "feed_requests/accepted_request" => "feed_requests#accepted_request", :as => 'accepted_request' + end + end + end +end diff --git a/feed.gemspec b/feed.gemspec new file mode 100644 index 0000000..5c988e3 --- /dev/null +++ b/feed.gemspec @@ -0,0 +1,22 @@ +$:.push File.expand_path("../lib", __FILE__) + +# Maintain your gem's version: +require "feed/version" + +# Describe your gem and declare its dependencies: +Gem::Specification.new do |s| + s.name = "feed" + s.version = Feed::VERSION + s.authors = ["RulingDigital"] + s.email = ["service@rulingcom.com"] + s.description = "Orbit Announcement module" + s.summary = "" + s.homepage = "http://www.rulingcom.com" + s.license = "RulingDigital" + + s.files = Dir["{app,config,db,lib}/**/*"] + ["MIT-LICENSE", "Rakefile", "README.rdoc"] + s.test_files = Dir["test/**/*"] + + s.add_development_dependency "bundler", "~> 1.3" + s.add_development_dependency "rake" +end diff --git a/lib/feed.rb b/lib/feed.rb new file mode 100644 index 0000000..b9d7ffa --- /dev/null +++ b/lib/feed.rb @@ -0,0 +1,30 @@ +module Feed + class Engine < Rails::Engine + initializer "feed" do + OrbitApp.registration "Feed",:type=> 'ModuleApp' do + module_label 'feed.feed' + base_url File.expand_path File.dirname(__FILE__) + # personal_plugin :enable => true,:path=>"panel/location/plugin/profile",:i18n=>'admin.location' + + version "0.1" + organization "Rulingcom" + author "RulingDigital" + intro "Orbit Feed Module" + update_info 'some update_info' + #enable_frontend true + + categorizable + authorizable + + side_bar do + head_label_i18n 'feed.channel', :icon_class=>"icon-plus" + available_for [:admin, :guest, :manager, :sub_manager] + active_for_controllers( {:private => ['feeds']} ) + + head_link_path "panel_feed_back_end_feeds_path" + + end + end + end + end +end \ No newline at end of file diff --git a/lib/feed/version.rb b/lib/feed/version.rb new file mode 100644 index 0000000..ceeb708 --- /dev/null +++ b/lib/feed/version.rb @@ -0,0 +1,3 @@ +module Feed + VERSION = "0.0.1" +end diff --git a/lib/rss_dynamic.rb b/lib/rss_dynamic.rb new file mode 100644 index 0000000..d7126a1 --- /dev/null +++ b/lib/rss_dynamic.rb @@ -0,0 +1,114 @@ +# encoding: utf-8 +require 'rss' +require 'mongo' +require 'mongoid' + +# Change this according to local DB +DB_NAME = "orbit_site_new" + +Mongoid.configure do |config| + config.master = Mongo::Connection.new("localhost", 27017).db("#{DB_NAME}") +end + +class Bulletin + include Mongoid::Document + include Mongoid::Timestamps + include Mongoid::MultiParameterAttributes +end + +class BufferCategory + include Mongoid::Document + include Mongoid::Timestamps +end + +# Create a hash rss site list from mongodb +db = Mongo::Connection.new("localhost", 27017).db("#{DB_NAME}") +SITES = Hash[ db["announcement_feeds"].find(accepted: true).entries.collect {|f| [ f["name"], f["link"] ]} ] +CATEGORIES = Array( db["announcement_feeds"].find().entries.collect {|f| f["categories"]} ) + +yesterday = Time.now - 86400 +two_weeks_ago = Time.new - 60 * 60 * 24 * 14 + +recent_feed = {} + +SITES.each_with_index do |(name, url), i| + open("http://#{url}/panel/announcement/front_end/bulletins.rss?inner=true") do |rss| + # Giving 'false' parameter is for skipping irregular format of the RSS + feed = RSS::Parser.parse(rss, false) + + feed.items.each do |item| + category = item.category.to_s.gsub(/\<(\/)*category\>/, '') + + if ( item.pubDate > yesterday ) && ( CATEGORIES[i][0] == "全部" || CATEGORIES[i].include?(category) ) + recent_feed[item.title.strip] = { date: item.pubDate, description: item.description.gsub("\r\n", '
').strip, + link: item.link, category: category, source: name } + end + end + end +end + +def get_category_id(category, categories, coll_cat) + db = Mongo::Connection.new("localhost", 27017).db("#{DB_NAME}") + if categories.keys.include? "rss_#{category}" + [categories["rss_#{category}"], categories] + else + cat = { + _type: "Category", + key: "rss_#{category}", + disable: false, + title: {:zh_tw => "rss_#{category}"}, + created_at: Time.now, + updated_at: Time.now, + module_app_id: db["module_apps"].find({:key=>"announcement"}).first['_id'] + } + categories["rss_#{category}"] = result = coll_cat.save(cat) + [result, categories] + end +end + +def get_mongo_and_categories + db = Mongo::Connection.new("localhost", 27017).db("#{DB_NAME}") + coll_bulletin = db["bulletins"] + coll_cat = db["categories"] + + categories = coll_cat.find().to_a.inject({}) do |categories, category| + categories[category['key']] = category['_id'] + categories + end + + [categories, coll_bulletin, coll_cat] +end + +recent_feed.each do |title, bulletin| + + categories, coll_bulletin, coll_cat = get_mongo_and_categories + category_id, categories = get_category_id(bulletin[:category], categories, coll_cat) + + unless coll_bulletin.find_one(rss_link: bulletin[:link]) + bulletin = { _type: "Bulletin", + postdate: bulletin[:date], + created_at: bulletin[:date], + updated_at: bulletin[:date], + category_id: category_id, + title: {:zh_tw => title, :en => ""}, + text: {:zh_tw => bulletin[:description], :en => ""}, + available_for_zh_tw: true, + available_for_en: false, + rss_link: bulletin[:link], + rss_source: bulletin[:source], + is_top: false, + is_hot: false, + is_hidden: false } + + # coll_bulletin.save(bulletin) + bulletin = Bulletin.new(bulletin) + bulletin.save! + + category = { _type: "BufferCategory", + category_id: category_id, + categorizable_type: "Bulletin", + categorizable_id: bulletin.id } + buffer_category = BufferCategory.new(category) + buffer_category.save! + end +end \ No newline at end of file diff --git a/script/rails b/script/rails new file mode 100755 index 0000000..e323e44 --- /dev/null +++ b/script/rails @@ -0,0 +1,6 @@ +#!/usr/bin/env ruby +#!/usr/bin/env ruby +# This command will automatically be run when you run "rails" with Rails 3 gems installed from the root of your application. + +ENGINE_PATH = File.expand_path('../..', __FILE__) +load File.expand_path('../../test/dummy/script/rails', __FILE__)