forked from jasder/forgeplus
221 lines
7.2 KiB
Ruby
221 lines
7.2 KiB
Ruby
|
class HackUserLastestCodesController < ApplicationController
|
|||
|
|
before_action :require_login, except: [:listen_result]
|
|||
|
|
before_action :find_my_hack, only: [:show, :code_debug, :code_submit, :update_code, :sync_code, :add_notes,
|
|||
|
|
:listen_result, :result, :submit_records, :restore_initial_code]
|
|||
|
|
before_action :update_user_hack_status, only: [:code_debug, :code_submit]
|
|||
|
|
before_action :require_auth_identity, only: [:add_notes]
|
|||
|
|
before_action :require_manager_identity, only: [:show, :update_code, :restore_initial_code, :sync_code]
|
|||
|
|
skip_before_action :check_sign, only: [:listen_result]
|
|||
|
|
|
|||
|
|
def show
|
|||
|
|
@my_hack.update_attribute(:submit_status, 0) if @my_hack.submit_status == 1
|
|||
|
|
@modify = @my_hack.modify_time.to_i < @hack.hack_codes.first.modify_time.to_i
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
def update_code
|
|||
|
|
@my_hack.update_attribute(:code, params[:code])
|
|||
|
|
render_ok
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 恢复初始代码
|
|||
|
|
def restore_initial_code
|
|||
|
|
@my_hack.update_attribute(:code, @hack.code)
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 同步代码
|
|||
|
|
def sync_code
|
|||
|
|
@my_hack.update_attributes(code: @hack.code, modify_time: Time.now)
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 调试代码
|
|||
|
|
def code_debug
|
|||
|
|
exec_mode = "debug"
|
|||
|
|
error_status = 501
|
|||
|
|
error_msg = "debug_error"
|
|||
|
|
oj_evaluate exec_mode, error_status, error_msg
|
|||
|
|
render_ok
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 提交
|
|||
|
|
def code_submit
|
|||
|
|
exec_mode = "submit"
|
|||
|
|
error_status = 502
|
|||
|
|
error_msg = "submit_error"
|
|||
|
|
oj_evaluate exec_mode, error_status, error_msg
|
|||
|
|
render_ok
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 提交结果显示
|
|||
|
|
def result
|
|||
|
|
if @my_hack.submit_status == 1
|
|||
|
|
render json: {status: 1, message: "正在评测中"}
|
|||
|
|
else
|
|||
|
|
@mode = params[:mode]
|
|||
|
|
@result =
|
|||
|
|
if @mode == "submit"
|
|||
|
|
@my_hack.hack_user_codes.last
|
|||
|
|
elsif @mode == "debug"
|
|||
|
|
@my_hack.hack_user_debug
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 提交记录
|
|||
|
|
def submit_records
|
|||
|
|
records = @my_hack.hack_user_codes
|
|||
|
|
@records_count = records.count
|
|||
|
|
@records = paginate records.created_order
|
|||
|
|
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 提交记录详情
|
|||
|
|
def record_detail
|
|||
|
|
@hack_user = HackUserCode.find params[:id]
|
|||
|
|
set = HackSet.find_by(id: @hack_user.error_test_set_id)
|
|||
|
|
@pass_set_count = set ? set.position - 1 : 0
|
|||
|
|
@set_count = @hack_user.hack.hack_sets.count
|
|||
|
|
@my_hack = @hack_user.hack_user_lastest_code
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 接收中间件返回结果接口
|
|||
|
|
# 调试模式： status： 0 表示评测无错误，其他 表示错误（如编译出错，执行出错，超时等）
|
|||
|
|
def listen_result
|
|||
|
|
logger.info("###########listen_result：#{params}")
|
|||
|
|
begin
|
|||
|
|
ojEvaResult = JSON.parse(params[:ojEvaResult])
|
|||
|
|
testCase = ojEvaResult['testCase']
|
|||
|
|
# 只有编译出错时，才正则匹配错误行数
|
|||
|
|
error_line=
|
|||
|
|
if ojEvaResult['status'] == "4" || ojEvaResult['status'] == "5"
|
|||
|
|
regular_match_error_line ojEvaResult['outPut'], @my_hack.hack.language
|
|||
|
|
end
|
|||
|
|
# debug 与submit 公用的参数
|
|||
|
|
|
|||
|
|
ds_params = {input: testCase['input'], output: testCase['output'], hack_id: @hack.id,
|
|||
|
|
code: ojEvaResult['codeFileContent'], user_id: @my_hack.user_id, error_line: error_line,
|
|||
|
|
status: ojEvaResult['status'], error_msg: ojEvaResult['outPut'],
|
|||
|
|
execute_time: ojEvaResult['executeTime'], execute_memory: ojEvaResult['executeMem']}
|
|||
|
|
ActiveRecord::Base.transaction do
|
|||
|
|
# debug模式与submit模式
|
|||
|
|
if ojEvaResult['execMode'] == "debug"
|
|||
|
|
save_debug_data ds_params
|
|||
|
|
elsif ojEvaResult['execMode'] == "submit"
|
|||
|
|
save_submit_data ds_params.merge(expected_output: testCase['expectedOutput'],
|
|||
|
|
error_test_set_id: ojEvaResult['failCaseNum'])
|
|||
|
|
end
|
|||
|
|
# 评测完成后，还原评测中的状态
|
|||
|
|
@my_hack.update_attribute(:submit_status, 0)
|
|||
|
|
end
|
|||
|
|
render_ok
|
|||
|
|
rescue Exception => e
|
|||
|
|
logger.error("#########listen_result: #{e.message}")
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
def add_notes
|
|||
|
|
@my_hack.update_attribute(:notes, params[:notes])
|
|||
|
|
render_ok
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
private
|
|||
|
|
def find_my_hack
|
|||
|
|
@my_hack = HackUserLastestCode.find_by(identifier: params[:identifier])
|
|||
|
|
@hack = @my_hack.hack
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
def oj_evaluate exec_mode, error_status, error_msg
|
|||
|
|
request_url = "#{edu_setting('cloud_bridge')}/bridge/ojs/evaluate"
|
|||
|
|
test_sets =
|
|||
|
|
if exec_mode == "submit"
|
|||
|
|
@hack.hack_sets.map{|set| {input: set.input, output: set.output, caseId: set.id}}
|
|||
|
|
else
|
|||
|
|
[{input: params[:input]}]
|
|||
|
|
end
|
|||
|
|
testCases = Base64.encode64(test_sets.to_json)
|
|||
|
|
#codeFileContent = Base64.urlsafe_encode64(@my_hack.code)
|
|||
|
|
debug_params = {execMode: exec_mode,
|
|||
|
|
tpiID: @my_hack.identifier,
|
|||
|
|
testCases: testCases,
|
|||
|
|
platform: @my_hack.language,
|
|||
|
|
codeFileContent: @my_hack.code,
|
|||
|
|
timeLimit: @hack.time_limit,
|
|||
|
|
sec_key: Time.now.to_i}
|
|||
|
|
interface_json_post request_url, debug_params, error_status, error_msg
|
|||
|
|
# 每次评测提交数增加
|
|||
|
|
@hack.increment!(:submit_num)
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 正则错误行数
|
|||
|
|
def regular_match_error_line content, language
|
|||
|
|
content = Base64.decode64(content).force_encoding("utf-8")
|
|||
|
|
logger.info("######content: #{content}")
|
|||
|
|
case language
|
|||
|
|
when 'Java'
|
|||
|
|
content.scan(/.java.\d+/).map{|s| s.match(/\d+/)[0].to_i}.min
|
|||
|
|
when 'C', 'C++'
|
|||
|
|
content.scan(/\d:\d+:/).map{|s| s.match(/\d+/)[0].to_i}.min
|
|||
|
|
when 'Python'
|
|||
|
|
content.scan(/line \d+/).map{|s| s.match(/\d+/)[0].to_i}.min
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 存储debug数据
|
|||
|
|
def save_debug_data debug_params
|
|||
|
|
if @my_hack.hack_user_debug.present?
|
|||
|
|
@my_hack.hack_user_debug.update_attributes!(debug_params)
|
|||
|
|
else
|
|||
|
|
debug = HackUserDebug.new(debug_params)
|
|||
|
|
debug.hack_user_lastest_code_id = @my_hack.id
|
|||
|
|
debug.save!
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 存储submit数据
|
|||
|
|
def save_submit_data submit_params
|
|||
|
|
# 通关
|
|||
|
|
if submit_params[:status] == "0"
|
|||
|
|
# 编程题已经发布，且之前未通关奖励积分
|
|||
|
|
@hack.increment!(:pass_num)
|
|||
|
|
if @hack.status == 1 && !@my_hack.passed?
|
|||
|
|
reward_attrs = { container_id: @hack.id, container_type: 'Hack', score: @hack.score }
|
|||
|
|
RewardGradeService.call(@my_hack.user, reward_attrs)
|
|||
|
|
RewardExperienceService.call(@my_hack.user, reward_attrs)
|
|||
|
|
# 评测完成更新通过数
|
|||
|
|
@my_hack.update_attributes(passed: true, passed_time: Time.now)
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
# 创建用户评测记录
|
|||
|
|
logger.info("###########submit_params:#{submit_params}")
|
|||
|
|
query_index = @my_hack.hack_user_codes.count +1
|
|||
|
|
@my_hack.hack_user_codes.create!(submit_params.merge(query_index: query_index))
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 调试或提交改变状态
|
|||
|
|
def update_user_hack_status
|
|||
|
|
@my_hack.update_attribute(:submit_status, 1)
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 只有自己才能改动代码
|
|||
|
|
def require_identity
|
|||
|
|
if @my_hack.user_id != current_user.id
|
|||
|
|
tip_exception(403, "..")
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 老师、自己、管理可以查看他人的编程题
|
|||
|
|
def require_manager_identity
|
|||
|
|
unless current_user.certification_teacher? || admin_or_business? || @my_hack.user_id == current_user.id
|
|||
|
|
tip_exception(403, "..")
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
# 只有自己才能评测
|
|||
|
|
def require_auth_identity
|
|||
|
|
unless @my_hack.user_id == current_user.id
|
|||
|
|
tip_exception(403, "..")
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
end
|