@ -6,27 +6,28 @@ class ShixunsController < ApplicationController
before_action :require_login , :check_auth , except : [ :download_file , :index , :menus , :show , :show_right , :ranking_list ,
:discusses , :collaborators , :fork_list , :propaedeutics ]
before_action :check_account , only : [ :new , :create , :shixun_exec ]
before_action :check_account , only : [ :new , :create , :shixun_exec , :jupyter_exec ]
before_action :find_shixun , except : [ :index , :new , :create , :menus , :get_recommend_shixuns ,
:propaedeutics , :departments , :apply_shixun_mirror ,
:get_mirror_script , :download_file , :shixun_list , :batch_send_to_course ]
before_action :shixun_access_allowed , except : [ :index , :new , :create , :menus , :get_recommend_shixuns ,
:propaedeutics , :departments , :apply_shixun_mirror ,
:propaedeutics , :departments , :apply_shixun_mirror , :jupyter_exec ,
:get_mirror_script , :download_file , :shixun_list , :batch_send_to_course ]
before_action :find_repo_name , only : [ :repository , :commits , :file_content , :update_file , :shixun_exec , :copy , :add_file ]
before_action :find_repo_name , only : [ :repository , :commits , :file_content , :update_file , :shixun_exec , :copy ,
:add_file , :jupyter_exec ]
before_action :allowed , only : [ :update , :close , :update_propaedeutics , :settings , :publish ,
before_action :allowed , only : [ :update , :close , :update_propaedeutics , :settings , :publish , :apply_public ,
:shixun_members_added , :change_manager , :collaborators_delete ,
:cancel_ publish, :add_collaborators , :add_file ]
:cancel_ apply_public, :cancel_ publish, :add_collaborators , :add_file ]
before_action :portion_allowed , only : [ :copy ]
before_action :special_allowed , only : [ :send_to_course , :search_user_courses ]
## 获取课程列表
def index
@shixuns = current_laboratory . shixuns . unhidden
@shixuns = current_laboratory . shixuns . unhidden . publiced
## 方向
if params [ :tag_level ] . present? && params [ :tag_id ] . present?
@ -66,15 +67,11 @@ class ShixunsController < ApplicationController
## 排序参数
bsort = params [ :sort ] || 'desc'
case params [ :order_by ] || 'publish_time'
when 'new'
@shixuns = @shixuns . order ( " shixuns.status = 2 desc, shixuns.created_at #{ bsort } " )
case params [ :order_by ] || 'new'
when 'hot'
@shixuns = @shixuns . order ( " shixuns.status = 2 desc, shixuns.myshixuns_count #{ bsort } " )
when 'mine'
@shixuns = @shixuns . order ( " shixuns.created_at #{ bsort } " )
@shixuns = @shixuns . order ( " shixuns.public = 2 desc, shixuns.myshixuns_count #{ bsort } " )
else
@shixuns = @shixuns . order ( " shixuns. status = 2 desc, shixuns.publish_time #{ bsort } " )
@shixuns = @shixuns . order ( " shixuns.public = 2 desc, shixuns.publish_time #{ bsort } " )
end
# 用id计数会快10+MS左右,对于搜索的内容随着数据的增加，性能会提升一些。
@ -168,9 +165,10 @@ class ShixunsController < ApplicationController
def show_right
owner = @shixun . owner
#@fans_count = owner.fan_count
#@followed_count = owner.follow_count
@user_own_shixuns = owner . shixuns . published . count
@user_tags = @shixun . user_tags_name ( current_user )
@shixun_tags = @shixun . challenge_tags_name
@myshixun = @shixun . myshixuns . find_by ( user_id : current_user . id )
end
# 排行榜
@ -206,7 +204,7 @@ class ShixunsController < ApplicationController
@new_shixun = Shixun . new
@new_shixun . attributes = @shixun . attributes . dup . except ( " id " , " user_id " , " visits " , " gpid " , " status " , " identifier " , " averge_star " ,
" homepage_show " , " repo_name " , " myshixuns_count " , " challenges_count " ,
" can_copy " , " created_at " , " updated_at "
" can_copy " , " created_at " , " updated_at " , " public " )
@new_shixun . user_id = User . current . id
@new_shixun . averge_star = 5
@new_shixun . identifier = generate_identifier Shixun , 8
@ -264,7 +262,12 @@ class ShixunsController < ApplicationController
project_fork ( @new_shixun , @repo_path , current_user . login )
ShixunMember . create! ( :user_id = > User . current . id , :shixun_id = > @new_shixun . try ( :id ) , :role = > 1 )
# 如果是jupyter， ， ， ， ，
if @new_shixun . is_jupyter?
folder = EduSetting . get ( 'shixun_folder' )
path = " #{ folder } / #{ @new_shixun . identifier } "
FileUtils . mkdir_p ( path , :mode = > 0777 ) unless File . directory? ( path )
end
# 同步复制关卡
if @shixun . challenges . present?
@shixun . challenges . each do | challenge |
@ -343,7 +346,11 @@ class ShixunsController < ApplicationController
#合作者
def collaborators
@user = current_user
@members = @shixun . shixun_members . includes ( :user )
## 分页参数
page = params [ :page ] || 1
limit = params [ :limit ] || 10
@member_count = @shixun . shixun_members . count
@members = @shixun . shixun_members . includes ( :user ) . page ( page ) . per ( limit )
end
def fork_list
@ -364,73 +371,162 @@ class ShixunsController < ApplicationController
end
def create
# 评测脚本的一些操作
main_type , sub_type = params [ :main_type ] , params [ :small_type ]
mirror = MirrorScript . where ( :mirror_repository_id = > main_type )
identifier = generate_identifier Shixun , 8
@shixun = Shixun . new ( shixun_params )
@shixun . identifier = identifier
@shixun . user_id = current_user . id
@shixun . reset_time , @shixun . modify_time = Time . now , Time . now
if sub_type . blank?
shixun_script = mirror . first . try ( :script )
else
main_mirror = MirrorRepository . find ( main_type ) . type_name
sub_mirror = MirrorRepository . where ( id : sub_type ) . pluck ( :type_name )
if main_mirror == " Java " && sub_mirror . include? ( " Mysql " )
shixun_script = mirror . last . try ( :script )
else
shixun_script = mirror . first . try ( :script )
shixun_script = modify_shixun_script @shixun , shixun_script
@shixun = CreateShixunService . call ( current_user , shixun_params , params )
end
# 保存jupyter到版本库
def update_jupyter
jupyter_save_with_shixun ( @shixun , params [ :jupyter_port ] )
end
ActiveRecord :: Base . transaction do
def update
# 镜像方面
mirror_ids = MirrorRepository . where ( id : params [ :main_type ] )
. or ( MirrorRepository . where ( id : params [ :sub_type ] ) ) . pluck ( :id ) . uniq
old_mirror_ids = @shixun . shixun_mirror_repositories
. where ( mirror_repository_id : params [ :main_type ] )
. or ( @shixun . shixun_mirror_repositories . where ( mirror_repository_id : params [ :sub_type ] ) )
. pluck ( :mirror_repository_id ) . uniq
new_mirror_id = ( mirror_ids - old_mirror_ids ) . map { | id | { mirror_repository_id : id } } # 转换成数组hash方便操作
logger . info ( " # # # # # # # # # # new_mirror_id: #{ new_mirror_id } " )
logger . info ( " # # # # # # # # # # old_mirror_ids: #{ old_mirror_ids } " )
logger . info ( " # # # # # # # # # # mirror_ids: #{ mirror_ids } " )
# 服务配置方面
service_create_params = service_config_params [ :shixun_service_configs ]
. select { | config | ! old_mirror_ids . include? ( config [ :mirror_repository_id ] ) &&
MirrorRepository . find ( config [ :mirror_repository_id ] ) . name . present? }
service_update_params = service_config_params [ :shixun_service_configs ]
. select { | config | old_mirror_ids . include? ( config [ :mirror_repository_id ] ) }
logger . info ( " # # # # # # # # # service_create_params: #{ service_create_params } " )
logger . info ( " # # # # # # # # # service_update_params: #{ service_update_params } " )
begin
@shixun . save!
# shixun_info关联ß
ShixunInfo . create! ( shixun_id : @shixun . id , evaluate_script : shixun_script , description : params [ :description ] )
# 实训的公开范围
if params [ :scope_partment ] . present?
arr = [ ]
ids = School . where ( :name = > params [ :scope_partment ] ) . pluck ( :id ) . uniq
ids . each do | id |
arr << { :school_id = > id , :shixun_id = > @shixun . id }
ActiveRecord :: Base . transaction do
@shixun . update_attributes ( shixun_params )
@shixun . shixun_info . update_attributes ( shixun_info_params )
# 镜像变动
@shixun . shixun_mirror_repositories . where . not ( mirror_repository_id : old_mirror_ids ) . destroy_all
@shixun . shixun_mirror_repositories . create! ( new_mirror_id ) if new_mirror_id . present?
# 镜像变动要更换服务配置
@shixun . shixun_service_configs . where . not ( mirror_repository_id : old_mirror_ids ) . destroy_all
@shixun . shixun_service_configs . create! ( service_create_params ) if service_create_params . present?
service_update_params & . map do | service |
smr = @shixun . shixun_service_configs . find_by ( mirror_repository_id : service [ :mirror_repository_id ] )
logger . info ( " # # # # # # # # smr: #{ smr } " )
smr . update_attributes ( service ) if smr . present?
end
# 添加第二仓库（管理员权限）
if params [ :is_secret_repository ]
add_secret_repository if @shixun . shixun_secret_repository . blank?
else
# 如果有仓库，就要删
if @shixun . shixun_secret_repository & . repo_name
@shixun . shixun_secret_repository . lock!
GitService . delete_repository ( repo_path : @shixun . shixun_secret_repository . repo_path )
@shixun . shixun_secret_repository . destroy
end
end
end
rescue = > e
uid_logger_error ( e . message )
tip_exception ( " 基本信息更新失败: #{ e . message } " )
end
ShixunSchool . create! ( arr )
end
# 实训合作者
@shixun . shixun_members . create! ( user_id : current_user . id , role : 1 )
# 实训权限设置
def update_permission_setting
# 查找需要增删的高校id
school_id = School . where ( :name = > params [ :scope_partment ] ) . pluck ( :id )
old_school_ids = @shixun . shixun_schools . pluck ( :school_id )
school_params = ( school_id - old_school_ids ) . map { | id | { school_id : id } }
begin
ActiveRecord :: Base . transaction do
@shixun . update_attributes! ( shixun_params )
@shixun . shixun_schools . where . not ( school_id : school_id ) . destroy_all if school_id . present?
@shixun . shixun_schools . create! ( school_params )
end
rescue = > e
uid_logger_error ( " 实训权限设置失败-------- #{ e . message } " )
tip_exception ( " 实训权限设置失败 " )
end
end
# 镜像-实训关联表
ShixunMirrorRepository . create! ( :shixun_id = > @shixun . id , :mirror_repository_id = > main_type . to_i ) if main_type . present?
# 实训主镜像服务配置
ShixunServiceConfig . create! ( :shixun_id = > @shixun . id , :mirror_repository_id = > main_type . to_i )
if sub_type . present?
sub_type . each do | mirror |
ShixunMirrorRepository . create! ( :shixun_id = > @shixun . id , :mirror_repository_id = > mirror )
# 实训子镜像服务配置
name = MirrorRepository . find_by ( id : mirror ) . try ( :name ) #查看镜像是否有名称，如果没有名称就不用服务配置
ShixunServiceConfig . create! ( :shixun_id = > @shixun . id , :mirror_repository_id = > mirror ) if name . present?
# 实训学习页面设置
def update_learn_setting
begin
ActiveRecord :: Base . transaction do
@shixun . update_attributes! ( shixun_params )
end
rescue = > e
uid_logger_error ( " 实训学习页面设置失败-------- #{ e . message } " )
tip_exception ( " 实训学习页面设置失败 " )
end
end
# 创建版本库
repo_path = repo_namespace ( User . current . login , @shixun . identifier )
GitService . add_repository ( repo_path : repo_path )
# todo: 为什么保存的时候要去除后面的.git呢??
@shixun . update_column ( :repo_name , repo_path . split ( " . " ) [ 0 ] )
# Jupyter数据集
def get_data_sets
page = params [ :page ] || 1
limit = params [ :limit ] || 10
data_sets = @shixun . data_sets
@data_count = data_sets . count
@data_sets = data_sets . order ( " created_on desc " ) . page ( page ) . per ( limit )
@absolute_folder = edu_setting ( 'shixun_folder' )
end
# 将实训标志为该云上实验室建立
Laboratory . current . laboratory_shixuns . create! ( shixun : @shixun , ownership : true )
rescue Exception = > e
# 实训测试集附件
def upload_data_sets
begin
upload_file = params [ " file " ]
raise " 未上传文件 " unless upload_file
folder = edu_setting ( 'shixun_folder' )
raise " 存储目录未定义 " unless folder . present?
rep_name = @shixun . data_sets . pluck ( :filename ) . include? ( upload_file . original_filename )
raise " 文件名已经存在 \" #{ upload_file . original_filename } \" , 请删除后再上传 " if rep_name
tpm_folder = params [ :identifier ] # 这个是实训的identifier
save_path = File . join ( folder , tpm_folder )
ext = file_ext ( upload_file . original_filename )
local_path , digest = file_save_to_local ( save_path , upload_file . tempfile , ext )
content_type = upload_file . content_type . presence || 'application/octet-stream'
disk_filename = local_path [ save_path . size + 1 , local_path . size ]
@attachment = Attachment . where ( disk_filename : disk_filename ,
author_id : current_user . id ) . first
if @attachment . blank?
@attachment = Attachment . new
@attachment . filename = upload_file . original_filename
@attachment . disk_filename = local_path [ save_path . size + 1 , local_path . size ]
@attachment . filesize = upload_file . tempfile . size
@attachment . content_type = content_type
@attachment . digest = digest
@attachment . author_id = current_user . id
@attachment . disk_directory = tpm_folder
@attachment . container_id = @shixun . id
@attachment . container_type = @shixun . class . name
@attachment . attachtype = 2
@attachment . save!
else
logger . info " 文件已存在， #{ @attachment . id } , filename = #{ @attachment . filename } "
end
render_ok
rescue = > e
uid_logger_error ( e . message )
tip_exception ( " 实训创建失败 " )
raise ActiveRecord :: Rollback
tip_exception ( e . message )
end
end
# 多文件删除
def destroy_data_sets
files = Attachment . where ( id : params [ :id ] )
shixun_folder = edu_setting ( " shixun_folder " )
begin
files . each do | file |
file_path = " #{ shixun_folder } / #{ file . relative_path_filename } "
delete_file ( file_path )
end
files . destroy_all
render_ok
rescue = > e
uid_logger_error ( e . message )
tip_exception ( e . message )
end
end
@ -462,61 +558,6 @@ class ShixunsController < ApplicationController
tip_exception ( " 申请失败 " )
end
def update
ActiveRecord :: Base . transaction do
begin
@shixun . shixun_mirror_repositories . destroy_all
if params [ :main_type ] . present?
ShixunMirrorRepository . create ( :shixun_id = > @shixun . id , :mirror_repository_id = > params [ :main_type ] . to_i )
end
if params [ :small_type ] . present?
params [ :small_type ] . each do | mirror |
ShixunMirrorRepository . create ( :shixun_id = > @shixun . id , :mirror_repository_id = > mirror )
end
end
@shixun . update_attributes ( shixun_params )
@shixun . shixun_info . update_attributes ( shixun_info_params )
@shixun . shixun_schools . delete_all
# scope_partment: 高校的名称
if params [ :scope_partment ] . present?
arr = [ ]
ids = School . where ( :name = > params [ :scope_partment ] ) . pluck ( :id ) . uniq
ids . each do | id |
arr << { :school_id = > id , :shixun_id = > @shixun . id }
end
ShixunSchool . create! ( arr )
end
# 超级管理员和运营人员才能保存 中间层服务器pod信息的配置
# 如果镜像改动了，则也需要更改
mirror = @shixun . shixun_service_configs . map ( & :mirror_repository_id ) . sort
new_mirror = params [ :shixun_service_configs ] . map { | c | c [ :mirror_repository_id ] } . sort
if current_user . admin? || current_user . business? || ( mirror != new_mirror )
@shixun . shixun_service_configs . destroy_all
service_config_params [ :shixun_service_configs ] . each do | config |
name = MirrorRepository . find_by_id ( config [ :mirror_repository_id ] ) & . name
# 不保存没有镜像的配置
@shixun . shixun_service_configs . create! ( config ) if name . present?
end
end
# 添加第二仓库
if params [ :is_secret_repository ]
add_secret_repository if @shixun . shixun_secret_repository . blank?
else
# 如果有仓库，就要删
if @shixun . shixun_secret_repository & . repo_name
@shixun . shixun_secret_repository . lock!
GitService . delete_repository ( repo_path : @shixun . shixun_secret_repository . repo_path )
@shixun . shixun_secret_repository . destroy
end
end
rescue Exception = > e
uid_logger_error ( " 实训保存失败-------- #{ e . message } " )
tip_exception ( " 实训保存失败 " )
raise ActiveRecord :: Rollback
end
end
end
# 永久关闭实训
def close
@ -552,6 +593,8 @@ class ShixunsController < ApplicationController
# @evaluate_scirpt = @shixun.evaluate_script || "无"
end
# 获取脚本内容
def get_script_contents
mirrir_script = MirrorScript . find ( params [ :script_id ] )
@ -708,116 +751,45 @@ class ShixunsController < ApplicationController
end
end
# def shixun_exec
# if is_shixun_opening?
# tip_show_exception(-3, "#{@shixun.opening_time.strftime('%Y-%m-%d %H:%M:%S')}")
# end
# current_myshixun = @shixun.current_myshixun(current_user.id)
#
# min_challenges = @shixun.challenges.pluck(:id , :st)
# # 因为读写分离有延迟， ，
# if current_myshixun && params[:reset] != "1"
# games = current_myshixun.games
# # 如果TPM和TPI的管卡数不相等或者关卡顺序错了， ，
# if is_shixun_reset?(games, min_challenges, current_myshixun)
# # 这里页面弹框要收到 当前用户myshixun的identifier.
# tip_show_exception("/myshixuns/#{current_myshixun.try(:identifier)}/reset_my_game")
# end
#
#
# if current_myshixun.repo_name.nil?
# g = Gitlab.client
# repo_name = g.project(current_myshixun.gpid).try(:path_with_namespace)
# current_myshixun.update_column(:repo_name, repo_name)
# end
#
# # 如果存在实训，则直接进入实训
# # 如果实训允许跳关，
# @current_task =
# if params[:challenge_id]
# game = games.where(challenge_id: params[:challenge_id]).take
# if @shixun.task_pass || game.status != 3
# game
# else
# current_myshixun.current_task(games)
# end
# else
# current_myshixun.current_task(games)
# end
# else
# # 如果未创建关卡一定不能开启实训，
# if @shixun.challenges_count == 0
# tip_exception("开启实战前请先创建实训关卡")
# end
#
# # 判断实训是否全为选择题
# is_choice_type = (min_challenges.size == min_challenges.select{|challenge| challenge.last == 1}.count)
# if !is_choice_type
# commit = GitService.commits(repo_path: @repo_path).try(:first)
# uid_logger("First comit########{commit}")
# tip_exception("开启实战前请先在版本库中提交代码") if commit.blank?
# commit_id = commit["id"]
# end
#
# begin
# ActiveRecord::Base.transaction do
# begin
# myshixun_identifier = generate_identifier Myshixun, 10
# myshixun_params = {user_id: current_user.id, identifier: myshixun_identifier,
# modify_time: @shixun.modify_time, reset_time: @shixun.reset_time,
# onclick_time: Time.now, commit_id: commit_id}
# @myshixun = @shixun.myshixuns.create!(myshixun_params)
# # 其它创建关卡等操作
# challenges = @shixun.challenges
# # 之所以增加user_id是为了方便统计查询性能
# game_attrs = %i[challenge_id myshixun_id status user_id open_time identifier modify_time created_at updated_at]
# Game.bulk_insert(*game_attrs) do |worker|
# base_attr = {myshixun_id: @myshixun.id, user_id: @myshixun.user_id}
# challenges.each_with_index do |challenge, index|
# status = (index == 0 ? 0 : 3)
# game_identifier = generate_identifier(Game, 12)
# worker.add(base_attr.merge(challenge_id: challenge.id, status: status, open_time: Time.now,
# identifier: game_identifier, modify_time: challenge.modify_time))
# end
# end
# @current_task = @myshixun.current_task(@myshixun.games)
# rescue Exception => e
# logger.error("------ActiveRecord::RecordInvalid: #{e.message}")
# raise("ActiveRecord::RecordInvalid")
# end
# end
# # 如果实训是纯选择题，
# ActiveRecord::Base.transaction do
# unless is_choice_type
# # fork仓库
# cloud_bridge = edu_setting('cloud_bridge')
# project_fork(@myshixun, @repo_path, current_user.login)
# rep_url = Base64.urlsafe_encode64(repo_ip_url @repo_path)
# uid_logger("start openGameInstance")
# uri = "#{cloud_bridge}/bridge/game/openGameInstance"
# logger.info("end openGameInstance")
# params = {tpiID: "#{@myshixun.id}", tpmGitURL: rep_url, tpiRepoName: @myshixun.repo_name.split("/").last}
# uid_logger("openGameInstance params is #{params}")
# interface_post uri, params, 83, "实训云平台繁忙（ ： ）
# end
# end
# rescue Exception => e
# logger.info("shixun_exec error: #{e.message}")
# if e.message != "ActiveRecord::RecordInvalid"
# logger.error("##########project_fork error #{e.message}")
# @myshixun.destroy!
# end
# raise "实训云平台繁忙（ ： ）
# end
# end
# end
# gameID 及实训ID
# status: 0 , 1 申请过， 2， ，
# jupyter开启挑战
def jupyter_exec
begin
if is_shixun_opening?
tip_show_exception ( - 3 , " #{ @shixun . opening_time . strftime ( '%Y-%m-%d %H:%M:%S' ) } " )
end
current_myshixun = @shixun . current_myshixun ( current_user . id )
if current_myshixun
@myshixun = current_myshixun
else
commit = GitService . commits ( repo_path : @repo_path ) . try ( :first )
uid_logger ( " First comit # # # # # # # #{ commit } " )
tip_exception ( " 开启挑战前， " ) if commit . blank?
commit_id = commit [ " id " ]
cloud_bridge = edu_setting ( 'cloud_bridge' )
myshixun_identifier = generate_identifier Myshixun , 10
ActiveRecord :: Base . transaction do
@myshixun = @shixun . myshixuns . create! ( user_id : current_user . id , identifier : myshixun_identifier ,
modify_time : @shixun . modify_time , reset_time : @shixun . reset_time ,
onclick_time : Time . now , commit_id : commit_id )
# fork仓库
project_fork ( @myshixun , @repo_path , current_user . login )
rep_url = Base64 . urlsafe_encode64 ( repo_ip_url @repo_path )
uri = " #{ cloud_bridge } /bridge/game/openGameInstance "
params = { tpiID : " #{ @myshixun . id } " , tpmGitURL : rep_url , tpiRepoName : @myshixun . repo_name . split ( " / " ) . last }
interface_post uri , params , 83 , " 实训云平台繁忙（ ： ） "
end
end
rescue = > e
uid_logger_error ( e . message )
tip_exception ( " #{ e . message } " )
end
end
def publish
@status = 0
@position = [ ]
begin
unless @shixun . is_jupyter?
if @shixun . challenges . count == 0
@status = 4
else
@ -836,24 +808,27 @@ class ShixunsController < ApplicationController
end
end
end
end
if @status == 0
@shixun . update_attributes! ( :status = > 1 )
@shixun . update_attributes! ( :status = > 2 )
end
rescue Exception = > e
logger . error ( " pushlish game #{ e } " )
end
end
def apply_public
tip_exception ( - 1 , " 请先发布实训再申请公开 " ) if @shixun . status != 2
ActiveRecord :: Base . transaction do
@shixun . update_attributes! ( public : 1 )
apply = ApplyAction . where ( :container_type = > " ApplyShixun " , :container_id = > @shixun . id ) . order ( " created_at desc " ) . first
if apply && apply . status == 0
@status = 0
else
ApplyAction . create ( :container_type = > " ApplyShixun " , :container_id = > @shixun . id , :user_id = > current_user . id , :status = > 0 )
#begin
# status = Trustie::Sms.send(mobile: '18711011226', send_type:'publish_shixun' , name: '管理员')
#rescue => e
# Rails.logger.error "发送验证码出错: #{e}"
#end
@status = 1
end
end
rescue Exception = > e
logger . error ( " pushlish game #{ e } " )
end
normal_status ( 0 , " 申请成功 " )
end
# 设置私密版本库的在tpm中的目录
@ -993,14 +968,24 @@ class ShixunsController < ApplicationController
:disposition = > 'attachment' #inline can open in browser
end
# 撤销发布
def cancel_publish
tip_exception ( " 实训已经发布，无法撤销 " ) if @shixun . status == 2
# 撤销申请公开
def cancel_apply_public
tip_exception ( " 实训已经公开，无法撤销 " ) if @shixun . public == 2
ActiveRecord :: Base . transaction do
apply = ApplyAction . where ( :container_type = > " ApplyShixun " , :container_id = > @shixun . id ) . order ( " created_at desc " ) . first
if apply && apply . status == 0
apply . update_attribute ( :status , 3 )
apply . tidings . destroy_all
apply . update_attributes! ( status : 3 )
apply . tidings & . destroy_all
end
@shixun . update_column ( :public , 0 )
end
normal_status ( 0 , " 成功撤销申请 " )
end
# 撤销发布
def cancel_publish
tip_exception ( " 请先撤销申请公开，再撤销发布 " ) if @shixun . public == 1
tip_exception ( " 实训已经公开，无法撤销 " ) if @shixun . public == 2
@shixun . update_column ( :status , 0 )
end
@ -1021,10 +1006,9 @@ class ShixunsController < ApplicationController
private
def shixun_params
raise ( " 实训名称不能为空 " ) if params [ :shixun ] [ :name ] . blank?
params . require ( :shixun ) . permit ( :name , :trainee , :webssh , :can_copy , :use_scope , :vnc , :test_set_permission ,
:task_pass , :multi_webssh , :opening_time , :mirror_script_id , :code_hidden ,
:hide_code , :forbid_copy , :vnc_evaluate , :code_edit_permission
:hide_code , :forbid_copy , :vnc_evaluate , :code_edit_permission , :is_jupyter )
end
def validate_review_shixun_params
@ -1033,8 +1017,6 @@ private
end
def shixun_info_params
raise ( " 实训描述不能为空 " ) if params [ :shixun_info ] [ :description ] . blank?
raise ( " 评测脚本不能为空 " ) if params [ :shixun_info ] [ :evaluate_script ] . blank?
params . require ( :shixun_info ) . permit ( :description , :evaluate_script )
end
@ -1102,4 +1084,47 @@ private
ShixunSecretRepository . create! ( repo_name : repo_path . split ( " . " ) [ 0 ] , shixun_id : @shixun . id )
end
def file_save_to_local ( save_path , temp_file , ext )
unless Dir . exists? ( save_path )
FileUtils . mkdir_p ( save_path ) ##不成功这里会抛异常
end
digest = md5_file ( temp_file )
digest = " #{ digest } _ #{ ( Time . now . to_f * 1000 ) . to_i } "
local_file_path = File . join ( save_path , digest ) + ext
save_temp_file ( temp_file , local_file_path )
[ local_file_path , digest ]
end
def save_temp_file ( temp_file , save_file_path )
File . open ( save_file_path , 'wb' ) do | f |
temp_file . rewind
while ( buffer = temp_file . read ( 8192 ) )
f . write ( buffer )
end
end
end
def file_ext ( file_name )
ext = ''
exts = file_name . split ( " . " )
if exts . size > 1
ext = " . #{ exts . last } "
end
ext
end
def delete_file ( file_path )
File . delete ( file_path ) if File . exist? ( file_path )
end
def md5_file ( temp_file )
md5 = Digest :: MD5 . new
temp_file . rewind
while ( buffer = temp_file . read ( 8192 ) )
md5 . update ( buffer )
end
md5 . hexdigest
end
end
Jasder
5 years ago