educoder/lib/tasks/public_course.rake

#coding=utf-8
# 执行示例  bundle exec rake public_course:student args=149,2903
# args 第一个参数是subject_id，第二个参数是课程course_id
# 第一期时间：2018-12-16 至2019-03-31
# 第二期时间：2019-04-07 至2019-07-28
#
# 这次学习很有收获，感谢老师提供这么好的资源和细心的服务🎉🎉🎉
#

desc "同步精品课数据"
namespace :public_course do
  if ENV['args']
    subject_id = ENV['args'].split(",")[0] # 对应课程的id
    course_id = ENV['args'].split(",")[1] # 对应课堂的id
    status = ENV['args'].split(",")[2] # 表示相应的期数
    type = ENV['args'].split(",")[3] # 表示课程模块
  end


  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

  task :student => :environment do
    puts "subject_id is #{subject_id}"
    puts "course_id is #{course_id}"

    user_ids = Myshixun.find_by_sql("select distinct(user_id) from myshixuns where shixun_id in (select shixun_id from stage_shixuns
                                     where stage_id in (select id from stages where subject_id=#{subject_id}))").map(&:user_id)
    puts user_ids
    if user_ids.present?
      user_ids.each do |user_id|
        puts user_id
        begin
          CourseMember.create!(course_id: course_id, user_id: user_id, role: 4)
        rescue Exception => e
          Rails.logger(e.message)
        end
      end
    end
  end

  task :test_user => :environment do
    users = User.where(is_test: true)
    users.find_each do |user|
      puts user.id
      CourseMember.create!(course_id: course_id, user_id: user.id, role: 4)
    end
  end


  # 更新某个课程的某类时间
  # 执行示例  RAILS_ENV=production bundle exec rake public_course:time args=-1,2932,1,1
  task :time => :environment do
    # course_id = ENV['args'].split(",")[0] # 对应课堂的id
    # type = ENV['args'].split(",")[1]

    course = Course.find(course_id)

    case type.to_i
    when 1
      # 讨论区
      messages = Message.where(board_id: course.boards)
      messages.each do |message|
        created_on = random_time start_time, end_time
        puts created_on
        message.update_columns(created_on: created_on, updated_on: created_on)
        MessageDetail.where(message_id: message.id).each do |detail|
          rand_created_on = random_time start_time, end_time
          detail.update_columns(created_at: rand_created_on, updated_at: rand_created_on)
        end
      end
    when 2
      # 作业
      course.homework_commons.each do |homework|
        created_at = random_time(start_time, end_time)
        publish_time = random_larger_time created_at, start_time, end_time
        end_time = random_larger_time publish_time, start_time, end_time
        updated_at = end_time

        homework.update_columns(publish_time: publish_time, end_time: end_time, created_at: created_at, updated_at: updated_at)
        homework.homework_detail_manual.update_columns(comment_status: 6, created_at: created_at, updated_at: updated_at)

        homework.student_works.where("work_status !=0 and update_time > '#{end_time}'").update_all(update_time: end_time)
      end
    when 3
      # 试卷
      course.exercises.each do |exercise|
        created_at = random_time start_time, end_time
        publish_time = random_larger_time created_at, start_time, end_time
        end_time = random_larger_time publish_time, start_time, end_time
        updated_at = end_time

        exercise.update_columns(publish_time: publish_time, end_time: end_time, created_at: created_at, updated_at: updated_at, exercise_status: 3)
      end
    when 4
      # 资源
      course.attachments.each do |atta|
        created_on = random_time start_time, end_time

        atta.update_columns(is_publish: 1, created_on: created_on, publish_time: created_on)
      end
    end

  end

  task :create_homework_work => :environment do
    course = Course.find(course_id)
    course.practice_homeworks.each do |homework|
      if homework.student_works.count == 0
        str = ""
        CourseMember.students(course).each do |student|
          str += "," if str != ""
          str += "(#{homework.id},#{student.user_id}, '#{Time.now.strftime('%Y-%m-%d %H:%M:%S')}', '#{Time.now.strftime('%Y-%m-%d %H:%M:%S')}')"
        end
        if str != ""
          sql = "insert into student_works (homework_common_id, user_id, created_at, updated_at) values" + str
          ActiveRecord::Base.connection.execute sql
        end
      end
    end
  end

  def min_swith(time)
    puts time
    return time < 9 ? "0#{time}" : time
  end

  def random_time(start_time, end_time)
    hour = (6..23).to_a.sample(1).first
    min = rand(60)
    sec = rand(60)

    start_time = Date.parse(start_time)
    end_time = Date.parse(end_time)
    date = (start_time..end_time).to_a.sample(1).first

    time = "#{date} #{min_swith(hour)}:#{min_swith(min)}:#{min_swith(sec)}"

    puts time
    time
  end

  def random_larger_time(time, start_time, end_time)
    large_time = random_time(start_time, end_time)
    while large_time <= time
      large_time = random_time(start_time, end_time)
    end
    large_time
  end
end