#encoding: utf-8 class OauthController < ApplicationController include ApplicationHelper before_filter :user_setup before_filter :require_login, only: [:authorize] skip_before_filter :verify_authenticity_token, only: [:token] def index render 'oauth/index', layout: false end # 客户端申请认证的URI,包含以下参数: # # response_type:表示授权类型,必选项,此处的值固定为”code” # client_id:表示客户端的ID,必选项 # redirect_uri:表示重定向URI,可选项 # scope:表示申请的权限范围,可选项 # state:表示客户端的当前状态,可以指定任意值(最好是随机字符串),认证服务器会原封不动地返回这个值,可防止CSRF攻击 # # 这个页显示授权页,如果授权成功,返回redirect_uri+code # # # 服务器回应客户端的URI,包含以下参数: # # code:表示授权码,必选项。该码的有效期应该很短,通常设为10分钟,客户端只能使用该码一次, 否则会被授权服务器拒绝。该码与客户端ID和重定向URI,是一一对应关系。 # state:如果客户端的请求中包含这个参数,认证服务器的回应也必须一模一样包含这个参数。 def authorize begin #参数检查 raise "response_type只能为code" unless params["response_type"] == "code" raise "client_id为必传项" unless params["client_id"].present? raise "redirect_uri为必传项" unless params["redirect_uri"].present? config = OauthConfig.where(client_id: params["client_id"], redirect_uri: params["redirect_uri"]).first raise "client_id或redirect_uri不正确" unless config @data = params if params[:gen_code] ## 检查通过,生成code oauth = Oauth.create!(client_id: config.client_id, client_secret: config.client_secret, redirect_uri: config.redirect_uri, user_id: User.current.id ) code = oauth.gen_code redirect_to params["redirect_uri"] + "?code=#{code}&state=#{params[:state]}" else render 'oauth/authorize', :layout => 'forge' end rescue => e logger.error e render :text => e.message end end def test_callback # 申请 token # client_id = "88d893c5a345313e7b8c6fcf23d3d024ee08d5e41ce120c3448b6eea77d8de30" client_secret = "e9240cc5fc913741db5aea93f2986a8ea0631bb67f7c00e41e491b95d9619e64" redirect_uri = "http://localhost:3000/oauth/cb" url = "http://127.0.0.1:3000/oauth/token?grant_type=authorization_code&code=#{params['code']}&redirect_uri=#{redirect_uri}&client_id=#{client_id}&client_secret=#{client_secret}" render text: url end # 客户端向认证服务器申请令牌的HTTP请求,包含以下参数: # # grant_type:表示使用的授权模式,必选项,此处的值固定为”authorization_code”。 # code:表示上一步获得的授权码,必选项。 # redirect_uri:表示重定向URI,必选项,且必须与A步骤中的该参数值保持一致。 # client_id:表示客户端ID,必选项。 # client_secret: 表示客户端密钥,必选项。 # # # 认证服务器核对了授权码和”重定向URI”,确认无误后,向客户端发送访问令牌(access token)和更新令牌(refresh token)。 # # 认证服务器发送的HTTP回复,包含以下内容: # # access_token:表示访问令牌,必选项。 # token_type:表示令牌类型,该值大小写不敏感,必选项,可以是bearer类型或mac类型。 # expires_in:表示过期时间,单位为秒。如果省略该参数,必须其他方式设置过期时间。 # refresh_token:表示更新令牌,用来获取下一次的访问令牌,可选项。 # scope:表示权限范围,如果与客户端申请的范围一致,此项可省略。 def token begin res = {} if params[:grant_type] == 'authorization_code' raise "code必传" unless params["code"] raise "client_id必传" unless params["client_id"] raise "client_secret必传" unless params["client_secret"] raise "code错误或已超时" unless Oauth.code_valid?(params["code"]) oauth = Oauth.auth_code(params["code"], params["client_id"], params["client_secret"]) raise "认证不通过" unless oauth ## 生成 token # oauth.gen_token oauth.reload res = { access_token: oauth.access_token, token_type: 'bearer', expires_in: oauth.token_expires_in, refresh_token: oauth.refresh_token } end render json: res.to_json rescue => e logger.error e render text: e.message end end def get_userinfo user = Oauth.auth(params["access_token"]) user_info = {} if user user_info = { token: user.id, login: user.login, avatar_url: "https://openi.org.cn/images/" + url_to_avatar(user), name: user.show_name, email: user.mail, allow: (user.login == "guange"||user.phone=='15607313899') ? 1 : 0 } end render json: user_info.to_json end ####--Start-- 获取Openi的授权码,access_token,以及用户信息。为在openi登录的用户创建相关的educoder用户 #### IDENTITY_SITE = Redmine::Configuration['openi_domain'] ROOT_URL = Redmine::Configuration['educoder_domain'] DEFAULT_PASSWORD = 'a12345678'.freeze TOKEN_CALL_BACK = '/oauth/get_token_callback'.freeze USER_INFO = '/oauth/userinfo'.freeze def get_code # 从OpenI发过来的回调中获取授权码 code = params[:code] # 利用授权码从OpenI这里获取access_token client = get_client(IDENTITY_SITE) redirect_uri = "#{ROOT_URL}#{TOKEN_CALL_BACK}" access_token_hash = client.auth_code.get_token(code, redirect_uri: redirect_uri).to_hash # 利用access_token获取OpenI的用户信息 access_token = access_token_hash[:access_token] get_info_url = "#{IDENTITY_SITE}#{USER_INFO}?access_token=#{access_token}" response = HTTParty.get(get_info_url) body_json = JSON.parse response.body openi_user_id = body_json['token'] avatar_url = body_json['avatar_url'] login = body_json['login'] name = body_json['name'] email = body_json['email'] # 根据获取的用户信息来查询数据库,如已经存在对应的Educoder用户,则直接访问用户要访问的实训页面,否则为其创建用户后再访问实训页面 openi = Openi.find_by_login(login) unless openi ActiveRecord::Base.transaction do # 如果Educoder中已存在与该OpenI用户的邮箱相同的用户,则会直接跳转到登录educoder的登录页面 existing_user = User.find_by_mail(email) break if existing_user.present? user = User.new(lastname: name, mail: email, mail_notification: email) user.login = custom_openi_login(login) user.password = DEFAULT_PASSWORD user.save! UserExtensions.create!(user_id: user.id, school_id: School.first.id, identity: 4, gender: 0) UserDayCertification.create!(user_id: user.id, status: 1) openi = Openi.create!(user_id: user.id, openi_user_id: openi_user_id, avatar_url: avatar_url, login: login, name: name, email: email) end end self.logged_user = openi.user if openi.present? && openi.user.present? original_url = params[:original_url] redirect_to original_url end def get_token_callback end ####--End-- 获取Openi的授权码,access_token,以及用户信息。为在openi登录的用户创建相关的educoder用户 #### private # 为了保证新创建的用户用户名不与系统中已存在的用户冲突,加上 _openi 后缀 def custom_openi_login(login) login + '_openi' end def require_login require "base64" if !User.current.logged? redirect_to '/login?back_url64=' + Base64.urlsafe_encode64(request.original_url) end end include Trustie::Http end