From 32ff45fcd71057c6d137102545e7627a0cf994f0 Mon Sep 17 00:00:00 2001 From: jasder duan Date: Wed, 6 Dec 2023 18:52:16 +0800 Subject: [PATCH] =?UTF-8?q?ADD=20=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=EF=BC=9A=E6=AF=8F=E6=99=9A=E6=9B=B4=E6=96=B0=E8=AF=BE=E5=A0=82?= =?UTF-8?q?=E7=9A=84=E8=AF=95=E5=8D=B7=E6=95=B0=E9=87=8F(courses=E8=A1=A8?= =?UTF-8?q?=E4=B8=AD=E7=9A=84exercises=5Fcount=E5=AD=97=E6=AE=B5)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../daily_update_counter_cache_data.rake | 23 +++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 lib/tasks/daily_update_counter_cache_data.rake diff --git a/lib/tasks/daily_update_counter_cache_data.rake b/lib/tasks/daily_update_counter_cache_data.rake new file mode 100644 index 00000000..f08b1596 --- /dev/null +++ b/lib/tasks/daily_update_counter_cache_data.rake @@ -0,0 +1,23 @@ +#coding=utf-8 +# 通过配置服务器的crontab每天定时头歌平台中之前设置的counter_cache数 +# 取消model层面设置的counter_cache回调，解决并发场景下锁表锁行的问题 +namespace :daily_update_counter_cache_data do + desc "update counter_cache every day " + task :execute => :environment do + # 更课堂中exercises_count字段 + courses = Course.joins(:exercises).select("courses.id, COUNT(exercises.id) AS query_exercises_count").group("courses.id").order("query_exercises_count DESC") + courses = courses.where(id: ENV['update_id']) if ENV['update_id'].present? + + courses.find_in_batches(batch_size: 10000) do |group| + update_sql = "UPDATE courses SET exercises_count = CASE id " + Parallel.each(group, in_threads: 6) do |course| + update_sql += " WHEN #{course.id} THEN #{course.query_myshixuns_count&.to_i} " + end + + update_sql += " ELSE exercises_count END WHERE id IN (#{group.map(&:id).join(',')})" + Rails.logger.info "########## #{Time.now} 更新课堂exercises_count的SQL语句: #{update_sql}" + ActiveRecord::Base.connection.execute(update_sql) if group.present? + end + + end +end