# encoding=utf-8 class GamesService include ApplicationHelper include GamesHelper CODES = %W(1 2 3 4 5 6 7 8 9 A B C D E F G H J K L N M O P Q R S T U V W X Y Z) # 关卡详情 def show_game params, current_user game = Game.min.find_by_identifier(params[:identifier]) Rails.logger.info("game id is #{game.try(:id)}, current_user id is #{current_user.try(:id)}") if game.blank? || current_user.blank? return{:status => 404} end # 防止评测中途ajax被取消;3改成0是为了处理首次进入下一关的问题 game.update_attribute(:status, 0) if game.status == 1 game.update_attributes(:status => 0, :open_time => Time.now) if game.status == 3 # Redo:后续可以去掉,只是为了兼顾其它模块的耗时统计 myshixun = Myshixun.min.find(game.myshixun_id) shixun = Shixun.min.find(myshixun.shixun_id) unless (myshixun.user_id == current_user.id || current_user.admin? || current_user.id == shixun.try(:user_id) || current_user.is_certification_teacher) return{:status => 403} end game_challenge = Challenge.min.find(game.challenge_id) has_answer = game_challenge.answer.blank? ? false : true game_challenge.answer = nil if game_challenge.st == 1 game_challenge.score = game_challenge.choose_score.to_i end # st:判断是选择类型还是实训类型 st = game_challenge.st game_count = myshixun.games.count discusses_count = shixun.discusses.count mirror_name = myshixun.mirror_name user = myshixun.owner username = user.show_name image_url = url_to_avatar(user) user_url = "/users/#{user.login}" is_teacher = (user.user_extensions.identity == 0) tpm_identifier = shixun.try(:identifier) # 实训超时设置 time_limit = shixun.exec_time # 高性能取上一关、下一关 prev_game = Game.prev_identifier(shixun.id, game.myshixun_id, game_challenge.position) next_game = if current_user.is_certification_teacher || shixun_manager(shixun, current_user) || game.status || shixun.task_pass Game.next_game(shixun.id, game.myshixun_id, game_challenge.position).try(:identifier) end # 该参数是为了判断是否需要加载loading @is_subject = params[:is_subject] # 关卡点赞数, praise_or_tread = 1则表示赞过 praise_count = PraiseTread.where(:praise_tread_object_id => game_challenge.id, :praise_tread_object_type => "Challenge", :praise_or_tread => 1).count user_praise = PraiseTread.where(:praise_tread_object_id => game_challenge.id, :praise_tread_object_type => "Challenge", :user_id => current_user.id, :praise_or_tread => 1).present? ? true : false # 实训的最大评测次数,这个值是为了优化查询,每次只取最新的最新一次评测的结果集 max_query_index = game.query_index - 1 # 判断实训是否全部通关 had_done = game.had_done # 统计时间 record = EvaluateRecord.where(:game_id => game.id).first.try(:consume_time) # 实训制作者当前拥有的金币 grade = myshixun.owner.try(:grade) # power判断用户是否有权限查看隐藏测试集(TPM管理员;平台认证的老师;花费金币查看者) -1 表示不能解锁 0 表示需要付费解锁 1表示可以看 # myshixun_manager myshixun_manager = shixun_manager(shixun, current_user) || (current_user.is_certification_teacher) power = (myshixun_manager || game.test_sets_view ) ? 1 : (shixun.test_set_permission ? 0 : -1) # 选择题和编程题公共部分 container = {:st => st, :discusses_count => discusses_count, :game_count => game_count, :myshixun => myshixun.try(:attributes), :challenge => game_challenge.try(:attributes), :game => game.try(:attributes), :shixun => shixun.try(:attributes), :record => record, :grade => grade, :prev_game => prev_game, :next_game => next_game, :username => username, :image_url => image_url, :user_url => user_url, :praise_count => praise_count, :user_praise => user_praise, :time_limit => time_limit, :tomcat_url => Redmine::Configuration['tomcat_php'], :is_teacher => is_teacher, :power => power, :myshixun_manager => myshixun_manager, :local_exam => LocalSetting.first.try(:exam)} # 区分选择题和编程题,st:0编程题; if st == 0 gitUrl = gitlab_url myshixun gitUrl = Base64.urlsafe_encode64(gitUrl) shixun_tomcat = Redmine::Configuration['shixun_tomcat'] params = {:tpiID => "#{myshixun.id}", :tpiGitURL => "#{gitUrl}"} # 判断tpm是否修改了 tpm_modified = repository_is_modified(myshixun, shixun.try(:gpid)) # 判断TPM和TPI的版本库是否被改了 tpm_cases_modified = (game_challenge.modify_time != game.modify_time ? true : false) # modify_time 决定TPM测试集是否有更新 # tpm_script_modified = (shixun.reset_time > myshixun.reset_time ? true : false) # 新结构脚本是实时传送的,所以不会影响 # 区分评测过未评测过,未评测过按需求取数据 sql = if max_query_index > 0 "SELECT b.actual_output, b.out_put, b.result, b.compile_success, a.is_public, a.input, a.output FROM (SELECT position, input, output, challenge_id, is_public FROM test_sets where challenge_id=#{game_challenge.id}) a LEFT JOIN (SELECT result, test_set_position, g.challenge_id, o.actual_output, o.out_put, o.compile_success FROM outputs o left join games g on g.id=o.game_id WHERE game_id=#{game.id} and query_index = #{max_query_index} ) b ON b.challenge_id = a.challenge_id and b.test_set_position = a.position" else # 这个地方如果加字段的话一定注意test_set_static_data方法,因为这个地方的字段数在下面有判断 "SELECT t.is_public, t.input, t.output, t.position FROM games g ,challenges c,test_sets t WHERE g.id=#{game.id} and c.id= g.challenge_id and t.challenge_id = c.id" end qurey_test_sets = TestSet.find_by_sql(sql) # 测试集统计及处理 unless qurey_test_sets.blank? check_power = (power == 1 || game.test_sets_view) test_sets = test_set_static_data(qurey_test_sets, check_power) end test_sets_count = qurey_test_sets.size had_test = Output.where(:game_id => game.id, :query_index => max_query_index) had_test_count = had_test.count had_passed_testsests_error_count = had_test.blank? ? 0 : had_test.select{|had_test| had_test.result == false}.count had_passed_testsests_error_count = had_test_count - had_passed_testsests_error_count error_position = had_test.blank? ? nil : had_test.select{|had_test| had_test.result == false}.last Rails.logger.info("latest output id is #{error_position.id unless error_position.blank?}") latest_output = error_position.try(:out_put).gsub(/\n/, '
').gsub(/\t/, " \; \; \; \; \; \; \; \;") unless error_position.try(:out_put).blank? Rails.logger.warn(latest_output) output_hash = {:test_sets => test_sets}.merge(:had_test_count => had_test_count, :test_sets_count => test_sets_count, :had_passed_testsests_error_count => had_passed_testsests_error_count) multi_webssh = shixun.webssh == 2 && shixun.multi_webssh result = {:tpm_modified => tpm_modified, :tpm_cases_modified => tpm_cases_modified, :hide_code => shixun.hide_code, :forbid_copy => true, :output_sets => output_hash, :latest_output => latest_output, :mirror_name => mirror_name, :multi_webssh => multi_webssh, :has_answer => has_answer}.merge(container) else # 选择题类型的 # 该方法多个地方调用,比如show、评测 # 最后一个字段true表示只显示数据,false表示可能有添加数据 result_container = choose_container(game_challenge, game, max_query_index, true) return result_container.merge(container) end end # output为testset的实际输出 # out_put为顶端结果显示输出 power 查看测试集的权限 def test_set_static_data test_sets, power test_result = [] unless test_sets.blank? test_sets.each do |test_set| # 第一次刷新或者没有评测的的时候test_set只需取四个字段,所以取了count actual_output = test_set.attributes.count > 4 ? test_set.try(:actual_output) : nil result = test_set.attributes.count > 4 ? test_set.try(:result) : nil compile_success = test_set.attributes.count > 4 ? test_set.try(:compile_success) : nil #actual_output = Base64.encode64(actual_output) actual_output = (compile_success.to_s == "0" ? "编译失败,请在测试结果中查看具体的错误信息" : actual_output) public_result = {:is_public => (test_set.is_public ? 1 : 0), :result => result, :actual_output => actual_output, :compile_success => compile_success} # 测试集公开的话才返回input结果 (test_set.is_public || power) && public_result.merge!({:input => test_set.input, :output => test_set.output}) Rails.logger.info("#######################test_set: #{public_result}") test_result << public_result.to_json end end test_result = test_result.blank? ? test_result : test_result.join(",") return test_result.gsub(/<\/script>/, '') end # 获取TPI关卡内容 def challenges params result = [] myshixun = Myshixun.find(Game.where(:identifier => params[:identifier]).pluck(:myshixun_id).first) shixun = Shixun.select([:id, :status]).find(myshixun.shixun_id) games = myshixun.games.includes(:challenge).reorder("challenges.position") games.each do |game| game_status = game.try(:status) challenge = game.challenge if challenge.st == 0 # 实战类型 if game_status == 2 # 通关了则取实际得分,没通关则取总分 gold = (shixun.status <= 1) ? 0 : game.final_score.to_i # 只要过关了,查看了答案经验值就是0,金币是负数 experience = (shixun.status <= 1 || game.final_score.to_i < 0) ? 0 : challenge.score.to_i challenge_tags_count = (shixun.status <= 1) ? 0 : challenge.challenge_tags.count else gold = challenge.score.to_i experience = gold challenge_tags_count = challenge.challenge_tags.count end else if game_status == 2 gold = (shixun.status <= 1) ? 0 : game.final_score.to_i experience = (shixun.status <= 1 || game.final_score.to_i < 0) ? 0 : challenge.choose_score.to_i challenge_tags_count = (shixun.status <= 1 || game.final_score.to_i <= 0) ? 0 : challenge.choose_tags_num else # 选择题只有在全对的时候才会获取final score总分,错任何一个题final_score就为0 gold = challenge.choose_score.to_i experience = challenge.choose_score.to_i challenge_tags_count = challenge.choose_tags_num end end result << {:position => challenge.position, :subject => challenge.subject, :tag_count => challenge_tags_count, :gold => gold, :experience => experience, :status => game.status, :star => game.star, :identifier => game.identifier} end result end # 评论打星星 def star params, current_user game = Game.find_by_identifier(params[:identifier]) shixun = Shixun.select([:id, :status]).find(params[:shixun_id]) # 如果已经评星,则不能重复评 grade = Grade.where(:user_id => current_user.id, :container_id => game.id, :container_type => 'Star').first if grade.present? return{:reward_code => -1} else game.update_column(:star, params[:star].to_i) # 随机生成10-100金币 code = rand(10..100) # 积分消耗情况记录;加积分之针对已发布的实训 if shixun.status >= 2 reward_grade(current_user, game.id, 'Star', code) return{:reward_code => code} else return{:reward_code => 0} end end end # TPI版本库文件目录结构 def entries params g = Gitlab.client gpid = params[:gpid] path = params[:path].try(:strip) rev = params[:rev] ? params[:rev] : "master" result = [] trees = g.trees(gpid, path: path, rev: rev) trees.each do |tree| # 去掉第一行的"/" new_path = File.join(path,tree.name).reverse.chomp("/").reverse result << {:name => tree.name, :path => new_path, :kind => tree.type == 'tree' ? 'dir' : 'file'} end return result end def answer params, current_user game_base params[:identifier] challenge = Challenge.select([:answer, :id, :score, :st]).find(@game.challenge_id) is_teacher = (current_user.user_extensions.identity == 0) is_certification_teacher = current_user.is_certification_teacher # 这几种情况可以直接查看答案的:实训未发布;当前用户为实训管理员;已经查看过答案;平台认证的老师; if (@shixun.status < 2 || shixun_manager(@shixun, current_user) || @game.answer_open || is_certification_teacher) Rails.logger.info("answer#{params[:identifier]}#### user is #{current_user.id}, status is #{@shixun.status}, manager is #{shixun_manager(@shixun, current_user)}, open #{@game.answer_open}, cer #{is_certification_teacher}") if challenge.st == 0 result = challenge.try(:answer) else result = [] challenge.challenge_chooses.each do |choose| result << {:position => choose.position, :answer => (choose.answer.blank? ? choose.standard_answer : choose.answer)} end end return {:view_answer => true, :answer => result} else return {:is_teacher => is_teacher, :view_answer => false} # view_answer = false end end # 查看答案需要扣取金币 # 必须保证用户的金币数大于关卡的金币数 def answer_grade params, current_user game_base params[:identifier] challenge = Challenge.select([:answer, :id, :score, :st]).find(@game.challenge_id) challenge_score = challenge.try(:score) final_score = @game.final_score if current_user.grade.to_i - challenge_score > 0 if !@game.answer_open # 如果这是第一次查看答案 if challenge.st == 0 final_score = final_score - challenge_score # 积分消耗情况记录 reward_grade(current_user, @game.id, 'Answer', -challenge_score) else final_score = final_score - challenge.choose_score.to_i # 之所以不用final_score是因为过关后查看答案的final_score为0,但是记录需要记录扣除的分数 reward_grade(current_user, @game.id, 'Answer', -challenge.choose_score.to_i) end @game.update_attributes!(:answer_open => true, :final_score => final_score) end else # 金币不足 raise("0") end if challenge.st == 0 answer = challenge.try(:answer) else answer = [] challenge.challenge_chooses.each do |choose| answer << {:position => choose.position, :answer => (choose.answer.blank? ? choose.standard_answer : choose.answer)} end end return {:answer => answer, :final_score => final_score, :grade => @myshixun.owner.try(:grade)} end # 查看隐藏测试集 def check_test_sets params, current_user game = Game.select([:id, :challenge_id, :test_sets_view]).find_by_identifier(params[:identifier]) if game.test_sets_view == true return {:status => -1, :message => "已解锁,请误重复操作!"} end challenge = Challenge.select([:id, :score]).find(game.challenge_id) user_grade = current_user.grade minus_grade = challenge.score * 5 max_query_index = game.query_index - 1 # 区分评测过未评测过,未评测过按需求取数据 if max_query_index > 0 qurey_test_sets = TestSet.find_by_sql("SELECT o.actual_output, o.out_put, o.result, o.compile_success, o.test_set_position, o.query_index,t.is_public,t.input, t.output, g.id as game_id, c.id as challenge_id FROM outputs o,games g ,challenges c,test_sets t where g.id=#{game.id} and o.query_index=#{max_query_index} and g.id = o.game_id and c.id= g.challenge_id and t.challenge_id = c.id and t.position =o.test_set_position order by o.query_index ") else qurey_test_sets = TestSet.find_by_sql("SELECT t.is_public,t.input, t.output,t.position FROM games g ,challenges c,test_sets t where g.id=#{game.id} and c.id= g.challenge_id and t.challenge_id = c.id ") end test_sets = test_set_static_data(qurey_test_sets, true) if user_grade >= minus_grade current_user.update_attribute(:grade, user_grade - minus_grade) game.update_attribute(:test_sets_view, true) # 扣分记录 gardes = Grade.create(:user_id => current_user.id, :container_id => game.id, :score => -minus_grade, :container_type => "testSet") gardes.attributes.merge!({test_sets: test_sets}) else return {:status => -1, :message => "本操作需要扣除#{ minus_grade }金币,您的金币不够了"} end end # 文件更新;数据评测记录 # 生成重新评测认证码 # content_modified:0 表示文件没有更新;content_modified:1 表示文件有更新 def file_update params, current_user game_base params[:identifier] path = params[:path].strip unless params[:path].blank? rev = params[:rev] ? params[:rev] : "master" content_modified = 0 ActiveRecord::Base.transaction do # params[:evaluate] 实训评测时更新必须给的参数,需要依据该参数做性能统计,其它类型的更新可以跳过 # 自动保存的时候evaluate为0;点评测的时候为1 if params[:evaluate] == 1 record = EvaluateRecord.create!(:user_id => current_user.id, :shixun_id => @myshixun.shixun.id, :game_id => @game.id) Rails.logger.warn("##game is is #{@game.id}, record id is #{record.id}, time is**** #{Time.now.strftime("%Y-%m-%d %H:%M:%S.%L")}") # @myshixun.student_works.update_all(:update_time => Time.now) if !@myshixun.student_works.blank? student_work_time = format("%.3f", (Time.now.to_f - record.created_at.to_f)).to_f record.update_attributes!(:student_work => student_work_time) end @g = Gitlab.client last_content = @g.files(@myshixun.gpid, path, "master").try(:content) last_content = tran_base64_decode64(last_content) content = if @myshixun.mirror_name.select{|a| a.include?("MachineLearning") || a.include?("Python")}.present? && params[:content].present? params[:content].gsub(/\t/, ' ') else params[:content] end if content != last_content content_modified = 1 code_file = @g.edit_file(@myshixun.gpid, current_user.login, :content => content, :file_path => path, :branch_name => "master", :commit_message => "auto commit") end # REDO:是否有读写分离的问题 if record.present? consume_time = format("%.3f", (Time.now.to_f - record.created_at.to_f)).to_f record.update_attributes!(:file_update => consume_time) end # status为2说明是重新评测 if @game.status == 2 code = CODES.sample(8).join resubmit = "#{code}_#{@myshixun.id}" end if content != last_content && code_file.blank? raise("update file failed") else return {:success => "success", :resubmit => resubmit ,:content_modified => content_modified} end end rescue Exception => e Rails.logger.error("file update failed #{e.message}") return {:status => -1, :success => "fail", :message => "实训云平台繁忙(繁忙等级:81),请稍后刷新并重试", :position => @game.challenge.position, :had_done => @game.had_done} end # 恢复初始代码 # 注意path为当前打开文件的path def reset_original_code params, current_user g = Gitlab.client path = params[:path] begin file_base params[:identifier] shixun = Shixun.select(:gpid).find(@myshixun.shixun_id) content = g.files(shixun.gpid, path, "master").try(:content) content = tran_base64_decode64(content) g.edit_file(@myshixun.gpid, current_user.login, :content => content, :file_path => path, :branch_name => "master", :commit_message => "reset_original_code") if content.nil? raise("初始代码为空,代码重置失败") end return content rescue Exception => e raise("#{e.message}") end end def reset_passed_code params, current_user g = Gitlab.client path = params[:path] game= Game.select([:id, :myshixun_id]).where(:identifier => params[:identifier]).first myshixun = Myshixun.find(game.myshixun_id) game_code = GameCode.where(:game_id => game.try(:id), :path => path).first if game_code.present? content = game_code.try(:new_code) content = if myshixun.mirror_name.select{|a| a.include?("MachineLearning") || a.include?("Python")}.present? && content.present? content.gsub(/\t/, ' ') else content end g.edit_file(myshixun.try(:gpid), current_user.login, :content => content, :file_path => path, :branch_name => "master", :commit_message => "game passed reset") return content else return {:status => -1, :message => "重置失败,代码为空"} end end # 获取版本库文件内容 # 通过版本库的默认分支可以判断版本库是否正常 # 注:如果本身path传错,内容肯定也为空;fork成功后,可能短时间内也获取不到版本库内容 # status =0 表示获取默认打开的内容,1表示右侧目录结构中获取的内容 def rep_content params, current_user file_base params[:identifier] # current_user: fork不应该是用当前用户去fork current_user = @myshixun.owner g = Gitlab.client gpid = @myshixun.try(:gpid) path = @game.challenge.try(:path).split(";")[0].strip() path = params[:path] ? params[:path] : path shixun_gpid = params[:shixun_gpid] status = params[:status] path = path.try(:strip) rev = params[:rev] ? params[:rev] : "master" Rails.logger.warn("path is #{path}") content = g.files(gpid, path, rev).try(:content) if content.blank? # 监测版本库HEAD是否存在,不存在则取最新的HEAD gitUrl = gitlab_url @myshixun gitUrl = Base64.urlsafe_encode64(gitUrl) shixun_tomcat = Redmine::Configuration['shixun_tomcat'] rep_params = {:tpiID => "#{@myshixun.id}", :tpiGitURL => "#{gitUrl}"} # 监测版本库HEAD是否存在,不存在则取最新的HEAD uri = "#{shixun_tomcat}/bridge/game/check" res = uri_exec uri, rep_params # res值:0 表示正常;-1表示有错误;-2表示代码版本库没了 if (status == 0 && res && res['code'] == -2 && params[:retry].to_i == 1) # 没有版本库则删除现有的版本库关联,重新fork一个版本库 g = Gitlab.client if current_user.gid.nil? s = Trustie::Gitlab::Sync.new s.sync_user(current_user) end gpid = sync_gitlab_rep @myshixun, shixun_gpid, current_user.try(:gid) content = g.files(gpid, path, rev).content else if (res && res['code'] != 0) Rails.logger.error("get rep_content failed: bridge return !0") # raise(status) return nil end end # gitlab缺陷:forked完成,短暂时间内取不了内容的,所以做一个小轮询,间隔0.2秒 # 超过3秒则失败,需通过页面刷新 # for i in 0..15 do # sleep(0.2) # content = g.files(gpid, path, rev).content # break if content.present? # end end content = tran_base64_decode64(content) if content.present? return content end # 编程题评测 def game_build params # 三类实训只取基础部分数据 game = Game.select([:myshixun_id, :status, :challenge_id, :id, :evaluate_count]).find_by_identifier(params[:identifier]) myshixun = Myshixun.select([:updated_at, :gpid, :id, :shixun_id]).find(game.myshixun_id) shixun = Shixun.select([:id, :evaluate_script, :webssh, :exec_time, :sigle_training, :identifier, :status]).find(myshixun.shixun_id) game_challenge = Challenge.select([:id, :position, :picture_path]).find(game.challenge_id) # 更新评测次数 game.update_column(:evaluate_count, (game.evaluate_count.to_i + 1)) # 清空代码评测信息 # msg = game.run_code_message # msg.update_attributes(:status => 0, :message => nil) if msg.present? # 更新时间是为了TPM端显示的更新,退出实训及访问实训的时候会更新 myshixun.update_column(:updated_at, Time.now) gitUrl = gitlab_url myshixun gitUrl = Base64.urlsafe_encode64(gitUrl) taskId = game.id shixun_tomcat = Redmine::Configuration['shixun_tomcat'] step = game_challenge.try(:position) mirror_repository_limit = shixun.mirror_repositories.where(:main_type => 1).select(:resource_limit).try(:first).try(:resource_limit) # mirror表中很很大的脚本字段,所以单独查询一个字段效果更好 resource_limit = "echo 'ulimit -f #{mirror_repository_limit}' >> /root/.bashrc ; source /root/.bashrc\n" tpmScript = shixun.evaluate_script.nil? ? "" : Base64.urlsafe_encode64((resource_limit + shixun.evaluate_script).gsub("\r\n", "\n")) # status为2已经通过关,是重新评测 if game.status == 2 resubmit = params[:resubmit] else # 重新评测不影响已通关的实训状态;first为第一次评测,通过前端JS轮询获取 game.update_attributes!(:status => 1) if params[:first].to_i == 1 end testSet = [] game_challenge.test_sets.each do |test_set| input = test_set.input.nil? ? "" : test_set.input.gsub("\r\n", "\n") output = test_set.output.nil? ? "" : test_set.output.gsub("\r\n", "\n") test_cases = {:input => input, :output => output} testSet << test_cases end testCases = Base64.urlsafe_encode64(testSet.to_json) unless testSet.blank? # 注意:这个地方的参数写的时候不能换行 content_modified = params[:content_modified] # 决定文件内容是否有修改,有修改如果中间成pull没有更新,则轮询等待更新 params = {:tpiID => "#{myshixun.id}", :tpiGitURL => "#{gitUrl}", :buildID => "#{taskId}",:instanceChallenge => "#{step}", :testCases => "#{testCases}", :resubmit => "#{resubmit}", :times => params[:first].to_i, :podType => shixun.webssh, :containers => "#{Base64.urlsafe_encode64(container_limit(shixun.mirror_repositories))}", :tpmScript => "#{tpmScript}", :timeLimit => "#{shixun.exec_time}", :content_modified => content_modified, :persistenceName => shixun.identifier, :isPublished => (shixun.status < 2 ? 0 : 1)} # 评测有文件输出的需要特殊传字段 path:表示文件存储的位置 params['file'] = Base64.urlsafe_encode64({:path => "#{game_challenge.picture_path}"}.to_json) if game_challenge.picture_path.present? # needPortMapping: web类型需要pod端口映射 params[:needPortMapping] = 8080 if myshixun.mirror_name.include?("Web") # 中间层交互 if shixun.sigle_training uri = "#{shixun_tomcat}/bridge/game/persistence/gameEvaluate" else uri = "#{shixun_tomcat}/bridge/game/gameEvaluate" end res = interface_post uri, params, 502 # 单评测类型(比较快的类型,实时返回结果,即不用中间层再回调trainint_task_status) if res['syncResult'].present? sigle_trainint_data res, myshixun, game end # ----单测模式end return {:result => "success", :resubmit => resubmit, :ableToCreate => res['ableToCreate'], :waitNum => res['waitNum'], :waitingTime => res['waitingTime'], :position => game_challenge.position, :port => res['port'], :had_done => game.had_done } rescue Exception => e Rails.logger.error("评测出错,详情:" + e.message) return {:result => 'fail', :contents =>"实训云平台繁忙(繁忙等级:502),请稍后刷新并重试", :position => game_challenge.position, :had_done => game.had_done} end # 单评测类型(比较快的类型,实时返回结果,即不用中间层再回调trainint_task_status) def sigle_trainint_data res, myshixun, game begin t1 = Time.now jsonTestDetails = JSON.parse(res['syncResult']['jsonTestDetails']) Rails.logger.info("res is #{res} ### jsonTestDetails is #{jsonTestDetails}") timeCost = JSON.parse(res['syncResult']['timeCost']) brige_end_time = Time.parse(timeCost['evaluateEnd']) if timeCost['evaluateEnd'].present? return_back_time = format("%.3f", ( t1.to_f - brige_end_time.to_f)).to_f status = jsonTestDetails['status'] game_id = jsonTestDetails['buildID'] Rails.logger.info("sigle training_task_status start#1**#{game_id}**** #{Time.now.strftime("%Y-%m-%d %H:%M:%S.%L")}") resubmit = jsonTestDetails['resubmit'] outPut = tran_base64_decode64(jsonTestDetails['outPut']) jenkins_testsets = jsonTestDetails['msg'] compile_success = jsonTestDetails['compileSuccess'] Rails.logger.info(outPut) challenge = game.challenge if challenge.picture_path.present? pics = res[:tpiRepoPath] game.update_column(:picture_path, pics) end Rails.logger.info("training_task_status start#2**#{game_id}**** #{Time.now.strftime("%Y-%m-%d %H:%M:%S.%L")}") unless jenkins_testsets.blank? jenkins_testsets.each do |j_test_set| Rails.logger.info("j_test_set: ############## #{j_test_set}") actual_output = tran_base64_decode64(j_test_set['output']) Rails.logger.info "actual_output:################################################# #{actual_output}" Output.create!(:code => status, :game_id => game_id, :out_put => outPut, :test_set_position => j_test_set['caseId'], :actual_output => actual_output, :result => j_test_set['passed'].to_i, :query_index => game.query_index, :compile_success => compile_success.to_i) end end Rails.logger.info("#############status: #{status}") record = EvaluateRecord.where(:game_id => game_id).first Rails.logger.info("training_task_status start#3**#{game_id}**** #{Time.now.strftime("%Y-%m-%d %H:%M:%S.%L")}") # status:0表示评测成功 if status == "0" if !resubmit.blank? game.update_attributes!(:retry_status => 2, :resubmit_identifier => resubmit) #if game.had_done == 1 challenge.path.split(";").each do |path| game_passed_code(game.id, path.try(:strip), myshixun.try(:gpid), 1) end #end else game.update_attributes!(:status => 2, :end_time => Time.now, :accuracy => format("%.4f", 1.0 / game.query_index)) myshixun.update_attributes!(:status => 1) if game.had_done == 1 challenge.path.split(";").each do |path| game_passed_code(game.id, path, myshixun.try(:gpid), 1) end if !game.answer_open && (challenge.shixun.try(:status) > 1) # 如果没有查看答案,则获得该关卡得分 reward_grade(game.user, game.id, 'Game', challenge.score) reward_experience(game.user, game.id, 'Game', challenge.score) game.update_attributes!(:final_score => challenge.score) end # 更新实训关联的作品分数 update_myshixun_work_score myshixun end # 如果过关了,下一关的状态是3(为开启),则需要把状态改成1(已开启) # next_game = game.next_game next_game = Game.next_game(myshixun.shixun_id, game.myshixun_id, challenge.position) next_game.update_column(:status, 0) if next_game.present? && next_game.status == 3 else # status == "-1" 表示返回结果错误 if !resubmit.blank? game.update_attributes!(:retry_status => 1, :resubmit_identifier => resubmit) else game.update_attributes!(:status => 0) end end test_cases_time = format("%.3f", (Time.now.to_f - t1.to_f)).to_f if record.present? consume_time = format("%.3f", (Time.now - record.created_at)).to_f record.update_attributes!(:consume_time => consume_time, :git_pull => timeCost['pull'] , :create_pod => timeCost['createPod'], :pod_execute => timeCost['execute'], :test_cases => test_cases_time, :brige => timeCost['evaluateAllTime'], :return_back => return_back_time) end end end # 选择题评测 def choose_build params # 三类实训只取基础部分数据 game = Game.select([:myshixun_id, :status, :challenge_id, :id, :answer_open, :final_score, :identifier, :evaluate_count]).find_by_identifier(params[:identifier]) # 更新评测次数 game.update_column(:evaluate_count, (game.evaluate_count.to_i + 1)) # 选择题如果通关了,则不让再评测 if game.status == 2 return {:message => "您已通过该关卡"} end myshixun = Myshixun.select([:updated_at, :gpid, :id, :shixun_id, :status, :user_id]).find(game.myshixun_id) shixun = Shixun.select([:id, :evaluate_script, :webssh, :status]).find(myshixun.shixun_id) game_challenge = Challenge.select([:id, :position]).find(game.challenge_id) user_answer = params[:answer] challenge_chooses_count = user_answer.length choose_correct_num = 0 score = 0 total_score = 0 had_passed = true test_sets = [] str = "" game_challenge.challenge_chooses.includes(:challenge_tags).each_with_index do |choose, index| user_answer_tran = user_answer[index].size > 1 ? user_answer[index].split("").sort.join("") : user_answer[index] standard_answer_tran = choose.standard_answer.size > 1 ? choose.standard_answer.split("").sort.join("") : choose.standard_answer correct = (user_answer_tran == standard_answer_tran) ? true : false if str.present? str += "," end str += "('#{game.id}', '#{choose.position}', '#{user_answer_tran}', '#{correct ? 1 : 0}', '#{game.query_index}', '#{Time.now.strftime('%Y-%m-%d %H:%M:%S')}', '#{Time.now.strftime('%Y-%m-%d %H:%M:%S')}')" # Output.create(:game_id => @game.id, :test_set_position => choose.position, :actual_output => params[:answer][index], :result => correct, :query_index => @game.query_index) # 只要有一题错误就不能通关 had_passed = false if !correct choose_correct_num += 1 if correct # 全部通关的时候,需要对所得的总分记录 # 总分的记录应该是根据每一题累加,如果该题正确,则加分 score += choose.score if correct standard_answer = correct ? standard_answer_tran : -1 sin_test_set = {:result => correct, :actual_output => user_answer_tran, :standard_answer => standard_answer, :position => choose.position} test_sets << sin_test_set end # 批量插入评测结果 Rails.logger.warn("sql str is #{str}") sql = "INSERT INTO outputs (game_id, test_set_position, actual_output, result, query_index, created_at, updated_at) VALUES" + str ActiveRecord::Base.connection.execute sql # 没通关或者查看了答案通关的时候经验为0 # 通关但是查看了答案,评测的时候金币显示0(避免用户以为重复扣除),但是在关卡列表中金币显示负数 experience = 0 final_score = 0 # 如果本次答题全部正确,并且之前没有通关,则进行相应的奖励,每关只要有错题,则不进行任何奖励 # 注:扣除分数是在查看答案的时候扣除的 if had_passed && !game.had_passed? game.update_attributes(:status => 2, :end_time => Time.now) # TPM实训已发布并且没有查看答案 if shixun.is_published? && !game.answer_open # 查看答案的时候处理final_scor和扣分记录 experience = score reward_grade(myshixun.owner, game.id, 'Game', score) game.update_attribute(:final_score, score) final_score = score reward_experience(myshixun.owner, game.id, 'Game', score) end end had_done = game.had_done myshixun.update_attribute(:status, 1) if had_done == 1 grade = myshixun.owner.try(:grade) # 更新实训关联的作品分数 update_myshixun_work_score myshixun # 高性能取上一关、下一关 prev_game = Game.prev_identifier(shixun.id, game.myshixun_id, game_challenge.position) next_game = Game.next_game(shixun.id, game.myshixun_id, game_challenge.position) # 如果过关了,下一关的状态是3(为开启),则需要把状态改成1(已开启) next_game.update_column(:status, 0) if next_game.present? && next_game.status == 3 return {:grade => grade, :gold => final_score, :experience => experience, :had_submmit => true, :challenge_chooses_count => challenge_chooses_count, :choose_correct_num => choose_correct_num, :test_sets => test_sets, :prev_game => prev_game, :next_game => next_game.try(:identifier)} end # 实训选择题需要局部刷新或者显示的部分 def choose_container game_challenge, game, max_query_index, just_show # category 1: 单选题,其它的多选题(目前只有两种) challenge_chooses = game_challenge.challenge_chooses.includes(:challenge_questions) test_sets = [] choose_test_cases = [] chooses = [] # 选择题测试集统计 challenge_chooses_count = challenge_chooses.count choose_correct_num = game.choose_correct_num game_outputs = game.outputs.where(:query_index => max_query_index) # 判断用户是否有提交 had_submmit = game_outputs.blank? ? false : true # 判断选择题是否写了标准答案 has_answer = [] challenge_chooses.each do |choose| challenge_question = [] output = game_outputs.select{|game_output| game_output.test_set_position == choose.position}[0] unless game_outputs.blank? category = choose.category subject = choose.subject choose.challenge_questions.each do |question| position = question.position option_name = question.option_name challenge_question << {:positon => position, :option_name => option_name} end # actual_output为空表示暂时没有评测答题,不云讯查看 actual_output = output.try(:actual_output).try(:strip) has_answer << choose.answer if choose.answer.present? # 标准答案处理,错误的不让用户查看,用-1替代 standard_answer = (actual_output.blank? || !output.try(:result)) ? -1 : choose.standard_answer result = output.try(:result) sin_test_set = {:result => result, :actual_output => actual_output, :standard_answer => standard_answer, :position => choose.position} sin_choose = {:category => category, :subject => subject, :challenge_question => challenge_question} chooses << sin_choose test_sets << sin_test_set end has_answer = has_answer.present? choose_test_cases = {:had_submmit => had_submmit, :challenge_chooses_count => challenge_chooses_count, :choose_correct_num => choose_correct_num, :test_sets => test_sets} return {:choose => chooses, :choose_test_cases => choose_test_cases, :has_answer => has_answer} end # 轮询获取状态 # resubmit是在file_update中生成的,从game_build中传入的 def game_status params, current_user game = Game.find_by_identifier(params[:identifier]) resubmit_identifier = game.resubmit_identifier # 如果没有超时并且正在评测中 # 判断评测中的状态有两种:1、如果之前没有通关的,只需判断status为1即可;如果通过关,则判断game的resubmit_identifier是否更新 if (params[:time_out] == "false") && ((params[:resubmit].blank? && game.status==1) || (params[:resubmit].present? && (params[:resubmit] != resubmit_identifier))) # 代码评测的信息 #running_code_status = game.run_code_message.try(:status) #running_code_message = game.run_code_message.try(:message) return #{:running_code_status => running_code_status, :running_code_message => running_code_message} end Rails.logger.info("##### resubmit_identifier is #{resubmit_identifier}") port = params[:port] score = 0 experience = 0 game_status = game.status had_done = game.had_done game_challenge = Challenge.select([:id, :score, :position, :shixun_id, :web_route]).find(game.challenge_id) shixun = Shixun.select([:id, :status, :user_id, :test_set_permission]).find(game_challenge.shixun_id) if params[:resubmit].blank? # 非重新评测 if game_status == 2 # 通关 if shixun.status > 1 score = game.final_score # 查看答案的时候有对最终获得金币进行处理 experience = game.answer_open ? 0 : game_challenge.score.to_i else score = 0 experience = 0 end end else # 重新评测 # 如果满足前面的条件,进入此处只可能是结果已返回并存入了数据库 if params[:resubmit] == resubmit_identifier # 本次重新评测结果已经返回并存入数据库 game_status = (game.retry_status == 2 ? 2 : 0) # retry_status是判断重新评测的通关情况。2表示通关 end end # 实训的最大评测次数,这个值是为了优化查询,每次只取最新的最新一次评测的结果集 max_query_index = game.query_index - 1 # 区分评测过未评测过,未评测过按需求取数据 if max_query_index > 0 qurey_test_sets = TestSet.find_by_sql("SELECT o.actual_output,o.result, o.compile_success, o.test_set_position, o.query_index,t.is_public,t.input, t.output, g.id as game_id, c.id as challenge_id FROM outputs o,games g ,challenges c,test_sets t where g.id=#{game.id} and o.query_index=#{max_query_index} and g.id = o.game_id and c.id= g.challenge_id and t.challenge_id = c.id and t.position =o.test_set_position order by o.query_index ") else qurey_test_sets = TestSet.find_by_sql("SELECT t.is_public,t.input, t.output,t.position FROM games g ,challenges c,test_sets t where g.id=#{game.id} and c.id= g.challenge_id and t.challenge_id = c.id ") end # 能进入到此处,肯定是已经返回了结果,也就是说outputs中肯定有了数据 test_sets_count = qurey_test_sets.size # had_test = Output.where(:game_id => game.id, :query_index => max_query_index) # had_test_count = had_test.count had_passed_testsests_error_count = max_query_index > 0 ? qurey_test_sets.select{|qurey_test_set| qurey_test_set.result == false}.count : 0 had_passed_testsests_error_count = test_sets_count - had_passed_testsests_error_count had_test = Output.where(:game_id => game.id, :query_index => max_query_index) error_position = had_test.blank? ? nil : had_test.select{|had_test| had_test.result == false}.last Rails.logger.info("latest output id is #{error_position.id unless error_position.blank?}") latest_output = error_position.try(:out_put).gsub(/\n/, '
').gsub(/\t/, " \; \; \; \; \; \; \; \;") if error_position.try(:out_put).present? Rails.logger.warn("last_output is #{latest_output}") # power判断用户是否有权限查看隐藏测试集(TPM管理员;平台认证的老师;花费金币查看者) power = (shixun_manager(shixun, current_user) || (current_user.is_certification_teacher)) ? 1 : (shixun.test_set_permission ? 0 : -1) # 测试集统计及处理 unless qurey_test_sets.blank? check_power = (power == 1 || game.test_sets_view) test_sets = test_set_static_data(qurey_test_sets, check_power) end # 处理生成图片类型文件 picture = (game.picture_path.nil? ? 0 : game.id) # 针对web类型的实训 web_route = game_challenge.try(:web_route) mirror_name = shixun.mirror_name # 轮询结束,更新评测耗时 e_record = EvaluateRecord.where(:game_id => game.id).first if game_status == 0 || game_status == 2 if e_record front_js = format("%.3f", (Time.now.to_f - e_record.try(:updated_at).to_f)).to_f consume_time = format("%.3f", (Time.now - e_record.created_at)).to_f e_record.update_attributes(:consume_time => consume_time, :front_js => front_js) end end Rails.logger.warn("##game is is #{game.id}, record id is #{e_record.id}, time is**** #{Time.now.strftime("%Y-%m-%d %H:%M:%S.%L")}") # 记录前端总耗时 record = e_record.try(:consume_time) # 实训制作者当前拥有的金币 grade = User.where(:id => game.user_id).pluck(:grade).first # 高性能取上一关、下一关 prev_game = Game.prev_identifier(shixun.id, game.myshixun_id, game_challenge.position) next_game = Game.next_game(shixun.id, game.myshixun_id, game_challenge.position).try(:identifier) output_hash = {:test_sets => test_sets, :had_test_count => test_sets_count, :test_sets_count => test_sets_count, :had_passed_testsests_error_count => had_passed_testsests_error_count} return {:grade => grade, :gold => score, :experience => experience, :status => game_status, :had_done => had_done, :position => game_challenge.position, :port => port, :power => power, :record => record, :mirror_name => mirror_name, :picture => picture, :web_route => web_route, :latest_output => latest_output, :star => game.star, :next_game => next_game, :prev_game => prev_game}.merge(output_hash) end # 记录实训花费的时间,前端是通过ent_time - open_time,所以最终只更新open_time即可 # 总花费的时间是花费的总时间加上开启的时间(open_time) # 注意:endtime和当前时间没关系,非时间差值,必须和opentime结合使用才有意义 def cost_time params game = Game.select([:id, :cost_time, :identifier]).find_by_identifier(params[:identifier]) cost_time = params[:time].to_i game.update_attribute(:cost_time, cost_time) return{ :game => game} end def sync_modify_time params game = Game.select([:id, :modify_time, :challenge_id]).find_by_identifier(params[:identifier]) modify_time = Challenge.where(:id => game.challenge_id).pluck(:modify_time).first game.update_column(:modify_time, modify_time) return {:status => 1, :message => "success"} end # tpi弹框状态更新;true则不再显示;false每次刷新显示 def system_update params myshixun = Myshixun.find(params[:myshixun_id]) myshixun.update_attribute(:system_tip, true) return {:status => 1, :message => "success"} end # For admin # 强制重置实训 def reset_my_game params, current_user unless current_user.admin? return {:status => 403, :message => "unauthorized"} end myshixun = Myshixun.find(Game.where(:identifier => params[:identifier]).pluck(:myshixun_id).first) shixun = myshixun.shixun ActiveRecord::Base.transaction do begin g = Gitlab.client shixun_tomcat = Redmine::Configuration['shixun_tomcat'] challenges = shixun.challenges # 删除选择题用户记录 unless challenges.blank? challenges.each do |challenge| if challenge.st != 0 challenge.challenge_chooses.each do |choose| user_output = choose.choose_outputs unless user_output.blank? user_output.delete end end end end end #end myshixun_job = Base64.urlsafe_encode64("myshixun_#{myshixun.id}") StudentWork.where(:myshixun_id => myshixun.id).update_all(:myshixun_id => 0, :work_status => 0, :work_score => nil, :final_score => nil, :cost_time => 0, :update_time => nil, :compelete_status => 0, :commit_time => nil) # myshixun.destroy myshixun.delete # 主从复制出现脏读的情况 if myshixun.gpid g.delete_project(myshixun.gpid) end rescue Exception => e Rails.logger.error("myshixun reset failed #{e}") raise ActiveRecord::Rollback end end # 主从复制出现脏读的情况 sleep(1) return {:status => 1, :message => "sucess", :url => "/shixuns/#{shixun.identifier}"} end def close_webssh params, current_user myshixun_id = Game.where(:identifier => params[:identifier]).pluck(:myshixun_id).first digest = params[:identifier]+Redmine::Configuration['bridge_secret_key'] digest_key = Digest::SHA1.hexdigest("#{digest}") begin shixun_tomcat = Redmine::Configuration['shixun_tomcat'] uri = "#{shixun_tomcat}/bridge/webssh/delete" Rails.logger.info("#{current_user} => cloese_webssh digest is #{digest}") params = {:tpiID => myshixun_id, :digestKey => digest_key, :identifier => params[:identifier]} res = uri_exec uri, params if res && res['code'].to_i != 0 raise("实训云平台繁忙(繁忙等级:110)") end return {:status => 1, :message => "webssh closed"} rescue Exception => e Rails.logger.error(e) return {:status => 0, :message => "authentication failed"} end end # return: 头像,姓名,用户主页链接,学校, 点赞数, 等级(通关数) def get_passed_user params page = params[:page].to_i offset = page * 15 file_base params[:identifier] games = @game.challenge.games.where(:status => 2).includes(user: [:myshixuns, user_extensions: :school]).order("cost_time desc").offset(offset).limit(15) users = format_answer_list games {user_answer_list: users} end def get_passed_code params file_base params[:identifier] codes = @game.game_codes.select([:new_code, :path]).where("new_code is not null") code_list = [] codes.each do |code| code_list << {path: code.path, code: code.new_code} end {code_list: code_list} end def shixun_manager shixun, user_current member = shixun.shixun_members.where(:role => [1,2], :user_id => user_current.id) (!member.blank? || user_current.admin?) ? true : false end # 实训一些基础查询 def game_base identifier @game = Game.select([:myshixun_id, :status, :final_score, :answer_open, :challenge_id, :id]).find_by_identifier(identifier) @myshixun = Myshixun.select([:id, :shixun_id, :gpid, :user_id]).find(@game.myshixun_id) @shixun = Shixun.select([:status, :id]).find(@myshixun.shixun_id) end # 与文件代码相关的一些通用查询 def file_base identifier @game = Game.select([:myshixun_id, :challenge_id, :id]).find_by_identifier(identifier) @myshixun = Myshixun.select([:shixun_id, :gpid, :id, :user_id]).find(@game.myshixun_id) end private def format_answer_list games user_info = [] games.each do |game| user = game.user votes = game.game_codes.first.votes passed_count = user.myshixuns.where(:status => 1).count user_info << { user_id: user.id, name: user.show_name, game_id: game.id, image_url: url_to_avatar(user), school_name: user.school_name, votes: votes, passed_count: passed_count } end user_info end end