pgfqe6ch8/app/controllers/ecloud_controller.rb

#encoding=utf-8
require 'net/http'
class EcloudController < ApplicationController
  skip_before_filter :verify_authenticity_token


  def index

    render file: 'public/react-oschina/build/index.html', :layout => false
  end

  def trustie_login
  end

  CLIENT_ID = 'e5da9855f89bc724a335d100cb63cf02a03a592bd3151bbc84acf7b2e222ddb8'
  CLIENT_SECRET = '4f2f291fac1d3dae338c18a3e3544814be5a1c4ade9e72d62f45ceab914c89f5'
  ROOT_URl = 'http://localhost:3000'

  def oschina_login
    # 根据session，看看有没有存access_token，去刷新下。
    # 1. 如果过期，则跳转
    # 2. 未过期，直接用

    redirect_to "https://gitee.com/oauth/authorize?client_id=#{CLIENT_ID}&redirect_uri=#{ROOT_URl}/oschina/login_cb&response_type=code"
  end

  # 企业开通
  def bs_new

  end

  # 企业更新
  def bs_update

  end

  # 用户业务开通接口
  def ps_new
    begin
      ecloud_user = EcloudUser.where(:custid => params['custid'], :user_id => params['users']['userid']).first
      if ecloud_user.present?
        render :json => {code: 501, msg: "你已开通过该业务"}
      else
        EcloudUser.create!(custid: params['custid'], opttype: params['users']['opttype'], userid: params['users']['userid'],
                           username: params['users']['username'], useralias: params['users']['useralias'],
                           mobile: params['users']['mobile'],  email: params['users']['email'],  begintime: params['users']['begintime'].to_s,
                           endtime: params['users']['endtime'].to_s)
        render :json => {success: true, errmsg: ""}
      end
    rescue Exception => e
      logger.error(e.message)
      render :json => {code: 500, msg: "#{e.message}"}
    end
  end

  # 用户业务变更、销毁接口
  def ps_update
    begin
      ecloud_user = EcloudUser.where(:custid => params['custid'], :user_id => params['users']['userid']).first
      if ecloud_user.present?
        ecloud_user.update_attributes(opttype: params['users']['opttype'])
        render :json => {code: 501, msg: "你已开通过该业务"}
      else
        render :json => {code: 404, errmsg: ""}
      end
    rescue Exception => e
      logger.error(e.message)
      render :json => {code: 500, msg: "#{e.message}"}
    end
  end

  def ecloud_login_callback
    #获取code
    #
    #
    logger.debug params
    url = "https://221.176.54.92:9081/restful/services/oauth2/authorization?grant_type=authorization_code" +
        "&client_id=#{CLIENT_ID}&scope=&redirect_uri=&code=#{params[:code]}"
    # url =  "https://gitee.com/oauth/token?grant_type=authorization_code"+
    #     "&code=#{params[:code]}&client_id=#{CLIENT_ID}&redirect_uri=#{ROOT_URl}/oschina/login_cb&client_secret=#{CLIENT_SECRET}"

    res = post(url)
    logger.debug res

    body = decode(res)
    #{"access_token":"21a80f20ff736b54aecd002b60210943","token_type":"bearer","expires_in":86400,"refresh_token":"be92e2c137a8c6dd22f0d8c4a622b3aeceb054087a95d293130f04ec60fd3e3f","scope":"user_info","created_at":1542684088}

    raise '登录失败' unless body["access_token"]

    #获取此用户信息

    # res = get("https://gitee.com/api/v5/user?access_token=#{body["access_token"]}")
    res = get("https://221.176.54.92:9081/restful/services/user/info?access_token=#{body["access_token"]}&userid=%7bUSERID%7d")
    logger.debug res

    info = decode(res)

    user =  User.find_by_oschina_user_id(info["id"])
    unless user
      user = User.create_with_oschina!(info)
    end

    @current_user = user

    render :index
  end


  private
  def get(url)
    uri = URI(url)
    res = Net::HTTP.start(uri.host, uri.port, use_ssl: url.start_with?('https')) do |http|
      req = Net::HTTP::Get.new(uri)
      #req['Content-Type'] = 'application/json'
      # The body needs to be a JSON string, use whatever you know to parse Hash to JSON
      #req.body = {a: 1}.to_json
      http.request(req)
    end

    res.body
  end

  def post(url)
    uri = URI(url)
    res = Net::HTTP.start(uri.host, uri.port, use_ssl: url.start_with?('https')) do |http|
      req = Net::HTTP::Post.new(uri)
      #req['Content-Type'] = 'application/json'
      # The body needs to be a JSON string, use whatever you know to parse Hash to JSON
      #req.body = {a: 1}.to_json
      http.request(req)
    end

    res.body
  end

  def decode(s)
    begin
      obj = ActiveSupport::JSON.decode(s)
    rescue ActiveSupport::JSON.parse_error
      logger.error("Attempted to decode invalid JSON: #{s}")
    end
  end

  private
  def ecloudeuser_params
    {}
  end
end