diff --git a/lib/tasks/public_message.rake b/lib/tasks/public_message.rake
index ca54fbd7b..5a2cd5e74 100644
--- a/lib/tasks/public_message.rake
+++ b/lib/tasks/public_message.rake
@@ -32,6 +32,41 @@ namespace :sync do
         MessageDetail.create!(message_id: new_message.id, content: discuss.try(:content))
       end
     end
+  end
+
+  task :sigle_message => :environment do
+    shixun_id = ENV['args'].split(",")[0] # 对应课程的id
+    board_id = ENV['args'].split(",")[1]
+    message_id = ENV['args'].split(",")[2]
+    status = ENV['args'].split(",")[3] # 表示相应的期数
+
+    if status.to_i == 1
+      start_time = '2018-12-16'
+      end_time = '2019-04-01'
+    elsif status.to_i == 2
+      start_time = '2019-04-07'
+      end_time = '2019-07-28'
+    else
+      # 这种情况是取所有的
+      start_time = '2015-01-01'
+      end_time = '2022-07-28'
+    end
+
+    discusses = Discuss.where(dis_id: shixun_ids).where("parent_id is null and created_at >? and created_at <?", start_time, end_time)
+    discusses.each do |discusse|
+      puts discusse.id
+      # 找到所有的子回复
+      replies = Discuss.where(parent_id: discusse.id)
 
+      # 如果有子回复，除了创建父回复外，还需要同步子回复
+      new_message = Message.create!(board_id: board_id.to_i, author_id: discuss.user_id, parent_id: message_id, root_id: message_id)
+      MessageDetail.create!(message_id: new_message.id, content: discuss.try(:content))
+      if replies.present?
+        replies.each do |reply|
+          reply_message = Message.create!(board_id: board_id.to_i, author_id: reply.user_id, parent_id: new_message.id, root_id: message_id)
+          MessageDetail.create!(message_id: reply_message.id, content: reply.try(:content))
+        end
+      end
+    end
   end
-end
\ No newline at end of file
+end