353 lines
14 KiB
Ruby
353 lines
14 KiB
Ruby
#coding=utf-8
|
||
# 数据库字段中带有m前缀和is_readed是二次开发添加，之前的字段基本复用
|
||
# 注意reply_id 是提到人的id，不是留言id, Base中叫做 at_user
|
||
class JournalsForMessage < ActiveRecord::Base
|
||
require 'net/http'
|
||
require 'json'
|
||
include Redmine::SafeAttributes
|
||
include UserScoreHelper
|
||
include ApplicationHelper
|
||
has_many_kindeditor_assets :assets, :dependent => :destroy
|
||
safe_attributes "jour_type", # 留言所属类型
|
||
"jour_id", # 留言所属类型的id
|
||
"notes", # 留言内容
|
||
"reply_id", # 留言被回复留言者的用户id(用户a回复了用户b，这是b的id，用以查询谁给b留言了)
|
||
"status", # 留言是否被查看(弃用)
|
||
"user_id", # 留言者的id
|
||
"m_parent_id", # 留言信息的父留言id
|
||
"is_readed", # 留言是否已读
|
||
"m_reply_count", # 留言的回复数量
|
||
"m_reply_id" , # 回复某留言的留言id(a留言回复了b留言，这是b留言的id)
|
||
"is_comprehensive_evaluation", # 1 教师评论、2 匿评、3 留言
|
||
"private",
|
||
"root_id"
|
||
acts_as_tree :foreign_key => 'm_parent_id', :counter_cache => :m_reply_count, :order => "#{JournalsForMessage.table_name}.created_on ASC"
|
||
after_destroy :delete_kindeditor_assets
|
||
belongs_to :project,
|
||
:foreign_key => 'jour_id',
|
||
:conditions => "#{self.table_name}.jour_type = 'Project' ",:touch => true
|
||
|
||
belongs_to :course,
|
||
:foreign_key => 'jour_id',:touch=>true
|
||
|
||
|
||
belongs_to :jour, :polymorphic => true
|
||
belongs_to :user
|
||
belongs_to :homework_attach
|
||
belongs_to :student_works_score
|
||
belongs_to :at_user, :class_name => "User", :foreign_key => 'reply_id'
|
||
|
||
acts_as_event :title => Proc.new {|o| "#{l(:label_my_message)}"},
|
||
:datetime => Proc.new {|o| o.updated_on },
|
||
:author => Proc.new {|o| o.user },
|
||
:description => Proc.new{|o| o.notes },
|
||
:type => Proc.new {|o| o.jour_type },
|
||
:url => Proc.new {|o|
|
||
if o.jour.kind_of? Project
|
||
{:controller => 'projects', :action => 'feedback', :id => o.jour, :r => o.id, :anchor => "word_li_#{o.id}"}
|
||
elsif o.jour.kind_of? Course
|
||
{:controller => 'courses', :action => 'feedback', :id => o.jour, :r => o.id, :anchor => "word_li_#{o.id}"}
|
||
end
|
||
}
|
||
acts_as_activity_provider :author_key => :user_id,
|
||
:timestamp => "#{self.table_name}.updated_on",
|
||
:find_options => {:include => :project }
|
||
|
||
acts_as_activity_provider :type => 'course_journals_for_messages',
|
||
:author_key => :user_id,
|
||
:permission => :view_course_journals_for_messages,
|
||
:timestamp => "#{self.table_name}.updated_on",
|
||
:find_options => {:include => :course }
|
||
acts_as_attachable
|
||
|
||
has_many :acts, :class_name => 'Activity', :as => :act, :dependent => :destroy
|
||
has_many :principal_acts, :class_name => 'PrincipalActivity',:as =>:principal_act ,:dependent => :destroy
|
||
# 课程动态
|
||
has_many :course_acts, :class_name => 'CourseActivity',:as =>:course_act ,:dependent => :destroy
|
||
# 消息关联
|
||
has_many :course_messages, :class_name => 'CourseMessage',:as =>:course_message ,:dependent => :destroy
|
||
has_many :user_feedback_messages, :class_name => 'UserFeedbackMessage', :as =>:journals_for_message, :dependent => :destroy
|
||
|
||
has_many :at_messages, as: :at_message, dependent: :destroy
|
||
has_many :praise_tread, as: :praise_tread_object, dependent: :destroy
|
||
has_one :praise_tread_cache, as: :object, dependent: :destroy
|
||
|
||
validates :notes, presence: true, if: :is_homework_jour?
|
||
after_create :act_as_activity, :act_as_course_activity, :act_as_course_message,
|
||
act_as_at_message(:notes, :user_id), :act_as_user_feedback_message,
|
||
:act_as_principal_activity, :act_as_student_score
|
||
after_create :reset_counters!
|
||
#after_update :update_activity
|
||
# after_destroy :reset_counters!
|
||
after_save :be_user_score
|
||
after_destroy :down_user_score, :down_course_score
|
||
|
||
# default_scope { where('m_parent_id IS NULL') }
|
||
|
||
#动态的更新
|
||
def update_activity
|
||
update_course_activity(self.class, self.id)
|
||
update_user_activity(self.class, self.id)
|
||
update_forge_activity(self.class, self.id)
|
||
update_org_activity(self.class, self.id)
|
||
update_principal_activity(self.class, self.id)
|
||
end
|
||
def self.create_by_user? user
|
||
if user.anonymous?
|
||
return false
|
||
else
|
||
return true
|
||
end
|
||
end
|
||
|
||
|
||
def self.remove_by_user? user
|
||
if( self.user == user ||
|
||
( self.jour.kind_of?(User) && self.jour== user )
|
||
)
|
||
true
|
||
else
|
||
false
|
||
end
|
||
end
|
||
|
||
def self.delete_message(message_id)
|
||
self.find(message_id).destroy
|
||
# self.destroy_all "id = #{message_id}"
|
||
end
|
||
|
||
def is_homework_jour?
|
||
self.jour_type != "HomeworkAttach"
|
||
end
|
||
|
||
def reference_user
|
||
User.find(reply_id)
|
||
end
|
||
|
||
def delete_by_user?user
|
||
# 用户可删除自己的留言
|
||
if self.user.id == user.id || user.admin?
|
||
return true
|
||
else
|
||
return false
|
||
end
|
||
end
|
||
|
||
def self.reference_message(user_id)
|
||
@user = User.find(user_id)
|
||
message = JournalsForMessage.find_by_sql("select * from journals_for_messages where reply_id = #{@user.id}
|
||
or (jour_type = 'Bid' and jour_id in (select id from bids where author_id = #{@user.id}))")
|
||
message
|
||
end
|
||
|
||
def act_as_activity
|
||
if self.jour_type == 'Principal'
|
||
unless self.user_id == self.jour.id && self.user_id != self.reply_id && self.reply_id != 0
|
||
# self.acts << Activity.new(:user_id => self.user_id)
|
||
self.acts << Activity.new(:user_id => self.jour_id)
|
||
end
|
||
elsif self.jour_type == 'Project'
|
||
self.acts << Activity.new(:user_id => self.reply_id)
|
||
elsif self.jour_type == 'Course'
|
||
self.acts << Activity.new(:user_id => self.reply_id)
|
||
else
|
||
end
|
||
end
|
||
|
||
#用户动态公共表记录
|
||
def act_as_principal_activity
|
||
if self.jour_type == 'Principal' && self.m_parent_id.nil?
|
||
self.principal_acts << PrincipalActivity.new(:user_id => self.user_id, :principal_id => self.jour_id)
|
||
end
|
||
end
|
||
|
||
def reset_counters!
|
||
# self.class.reset_counters!(self)
|
||
end
|
||
def self.reset_counters! journals_for_messages
|
||
# jfm_id = journals_for_messages.id.to_i
|
||
count = find_all_by_m_parent_id(journals_for_messages.m_parent_id).count #(SELECT COUNT(*) FROM #{JournalsForMessage.table_name} WHERE m_parent_id = #{jfm_id} )
|
||
update_all("m_reply_count = #{count.to_i}", ["id = ?", journals_for_messages.m_parent_id])
|
||
end
|
||
|
||
#如果是在项目中留言则返回该项目否则返回nil - zjc
|
||
def project
|
||
if self.jour_type == 'Project'
|
||
Project.find(self.jour_id)
|
||
else
|
||
nil
|
||
end
|
||
end
|
||
|
||
# 更新用户分数 -by zjc
|
||
def be_user_score
|
||
#新建了留言回复
|
||
if self.reply_id != 0
|
||
#协同得分加分
|
||
UserScore.joint(:reply_message, self.user,User.find(self.reply_id),self, { journals_for_messages_id: self.id })
|
||
update_replay_for_message(self.user,1)
|
||
if self.jour_type == "Project"
|
||
update_replay_for_message(self.user,2,self.jour)
|
||
end
|
||
end
|
||
end
|
||
|
||
# 更新用户分数 -by zjc
|
||
def down_user_score
|
||
#删除了留言回复
|
||
if self.reply_id != 0
|
||
#协同得分减分
|
||
UserScore.joint(:reply_message_delete, self.user,User.find(self.reply_id), { journals_for_messages_id: self.id })
|
||
update_replay_for_message(self.user,1)
|
||
if self.jour_type == "Project"
|
||
update_replay_for_message(self.user,2,self.jour)
|
||
end
|
||
end
|
||
end
|
||
|
||
# Time 2015-04-01 14:15:06
|
||
# Author lizanle
|
||
# Description 删除对应课程留言的图片资源
|
||
def delete_kindeditor_assets
|
||
delete_kindeditor_assets_from_disk self.id,7
|
||
end
|
||
|
||
#课程动态公共表记录
|
||
def act_as_course_activity
|
||
if self.jour_type == 'Course' && self.m_parent_id.nil?
|
||
self.course_acts << CourseActivity.new(:user_id => self.user_id,:course_id => self.jour_id)
|
||
end
|
||
end
|
||
|
||
# 课程/作品回复 留言消息通知
|
||
def act_as_course_message
|
||
if self.jour_type == 'StudentWorksScore'
|
||
if self.user_id != self.jour.user_id
|
||
self.course_messages << CourseMessage.new(:user_id => self.jour.user_id,:course_id => self.jour.student_work.homework_common.course.id, :viewed => false)
|
||
end
|
||
end
|
||
# 课程留言
|
||
if self.jour_type == 'Course'
|
||
receivers = []
|
||
teachers = []
|
||
# 获取课程的老师
|
||
self.jour.members.each do |m|
|
||
if m.user.allowed_to?(:as_teacher, self.jour)
|
||
teachers << m
|
||
end
|
||
end
|
||
if self.reply_id == 0 # 主留言，即不是回复某条留言
|
||
teachers.each do |teacher|
|
||
if teacher.user_id != self.user_id
|
||
receivers << teacher.user_id
|
||
end
|
||
end
|
||
else # 留言回复
|
||
reply_to = User.find(self.reply_id)
|
||
if self.user_id != self.reply_id # 添加我回复的那个人
|
||
receivers << reply_to.id
|
||
end
|
||
# 给老师发送。 过滤条件：老师自己给自己发；回复对象为老师则排除改老师
|
||
teachers.each do |teacher|
|
||
if teacher.user_id != self.user_id && self.reply_id != teacher.user_id
|
||
receivers << teacher.user_id
|
||
end
|
||
end
|
||
end
|
||
receivers.each do |r|
|
||
self.course_messages << CourseMessage.new(:user_id => r, :course_id => self.jour.id, :viewed => false)
|
||
end
|
||
end
|
||
if self.jour_type == 'HomeworkCommon'
|
||
if self.m_parent_id.nil?
|
||
if self.user_id != self.jour.user_id
|
||
self.course_messages << CourseMessage.new(:user_id => self.jour.user_id,:course_id => self.jour.course.id, :viewed => false)
|
||
# count = ShieldWechatMessage.where("container_type='User' and container_id=#{self.jour.user_id} and shield_type='Course' and shield_id=#{self.jour.course_id}").count
|
||
# if count == 0
|
||
# ws = WechatService.new
|
||
# #content = truncate(strip_tags(self.notes.to_s), length: 200)
|
||
# content = strip_html self.notes.html_safe, 200
|
||
# ws.comment_template self.jour.user_id, "homework", self.jour_id, "#{l(:label_homework_comment_template)}", self.user.try(:realname), format_time(self.created_on), content
|
||
# end
|
||
end
|
||
else
|
||
if self.user_id != self.parent.user_id
|
||
self.course_messages << CourseMessage.new(:user_id => self.parent.user_id,:course_id => self.jour.course.id, :viewed => false)
|
||
# count = ShieldWechatMessage.where("container_type='User' and container_id=#{self.parent.user_id} and shield_type='Course' and shield_id=#{self.jour.course_id}").count
|
||
# if count == 0
|
||
# ws = WechatService.new
|
||
# #content = truncate(strip_tags(self.notes.to_s), length: 200)
|
||
# content = strip_html self.notes.html_safe, 200
|
||
# ws.comment_template self.parent.user_id, "homework", self.jour_id, "#{l(:label_new_second_comment_template)}", self.user.try(:realname), format_time(self.created_on), content
|
||
# end
|
||
end
|
||
end
|
||
end
|
||
end
|
||
|
||
|
||
# 用户留言消息通知
|
||
def act_as_user_feedback_message
|
||
# 主留言
|
||
ws = WechatService.new
|
||
if self.jour_type == 'Principal'
|
||
receivers = []
|
||
if self.reply_id == 0
|
||
if self.user_id != self.jour_id # 过滤自己给自己的留言消息
|
||
receivers << self.jour
|
||
content = strip_html self.notes, 200
|
||
ws.journal_notice self.jour_id, "journal_for_message", self.id, "#{l(:label_new_journals_template)}", self.user.show_name, format_time(self.created_on),content
|
||
end
|
||
else # 留言回复
|
||
reply_to = User.find(self.reply_id)
|
||
if self.user_id != self.reply_id # 添加我回复的那个人
|
||
receivers << reply_to
|
||
end
|
||
if self.user_id != self.parent.jour_id && self.reply_id != self.parent.jour_id # 给东家发信息，如果回复的对象是东家则不发
|
||
receivers << self.parent.jour
|
||
end
|
||
#content = strip_html self.notes, 200
|
||
#ws.comment_template self.reply_id, "journal_for_message", self.parent.id, "#{l(:label_journals_comment_template)}", self.user.try(:realname), format_time(self.created_on), content
|
||
end
|
||
receivers.each do |r|
|
||
self.user_feedback_messages << UserFeedbackMessage.new(:user_id => r.id, :journals_for_message_id => self.id, :journals_for_message_type => "Principal", :viewed => false)
|
||
end
|
||
end
|
||
end
|
||
|
||
# 课程成员得分（活跃度）
|
||
def act_as_student_score
|
||
if self.jour_type == "Course"
|
||
course_member_score(self.jour_id, self.user_id, "Course")
|
||
elsif self.jour_type == "HomeworkCommon"
|
||
course_member_score(self.jour.course_id, self.user_id, "HomeworkCommon")
|
||
end
|
||
end
|
||
|
||
# 删除操作的时候相应扣掉回复数
|
||
def down_course_score
|
||
if self.jour_type == "Course"
|
||
down_course_score_num(self.jour_id, self.user_id, "Course")
|
||
elsif self.jour_type == "HomeworkCommon"
|
||
down_course_score_num(self.jour.course_id, self.user_id, "HomeworkCommon")
|
||
end
|
||
end
|
||
|
||
def creator_user
|
||
self.user
|
||
end
|
||
|
||
def created_time
|
||
self.created_on
|
||
end
|
||
|
||
def content_detail
|
||
self.notes
|
||
end
|
||
|
||
def set_children_readed_delay
|
||
# fetch_user_leaveWord_reply(self).update_all(:is_readed => true, :status => false)
|
||
end
|
||
|
||
end
|