module EricWeixin::Pay
  def self.generate_prepay_id options
    required_field = %i(appid mch_id openid attach body out_trade_no total_fee spbill_create_ip notify_url trade_type)
    query_options = {}
    required_field.each do |p|
      query_options[p] = options[p]
    end
    query_options[:nonce_str] = SecureRandom.uuid.tr('-', '')
    public_account = ::EricWeixin::PublicAccount.find_by_weixin_app_id(options[:appid])

    sign = generate_sign query_options, public_account.mch_key
    last_query_options = query_options
    last_query_options[:sign] = sign
    pay_load = "<xml>#{last_query_options.map { |k, v| "<#{k.to_s}>#{v.to_s}</#{k.to_s}>" }.join}</xml>"
    require 'rest-client'

    response = RestClient.post 'https://api.mch.weixin.qq.com/pay/unifiedorder', pay_load
    pp "**********************下单结果 *********************************"
    pp response.force_encoding("UTF-8")
    result = Hash.from_xml(response.force_encoding("UTF-8"))
    return result['xml']['prepay_id'] if result['xml']['return_code'] == 'SUCCESS'
    nil
  end

  def self.generate_sign options, api_key
    pp "**************** 签名参数 *********************"
    pp options
    pp "**************** api_key *********************"
    pp api_key
    query = options.sort.map do |k,v|
      "#{k.to_s}=#{v.to_s}"
    end.join('&')
    Digest::MD5.hexdigest("#{query}&key=#{api_key}").upcase
  end

  # 参数
  # wxappid
  # re_openid
  # total_amount
  # wishing
  # client_ip
  # act_name
  # remark
  # mch_id
  # send_name
  # total_num
  # mch_key
  def self.sendredpack options
    required_field = %i(wxappid re_openid total_amount wishing client_ip act_name remark mch_id send_name total_num mch_key)
    required_field.each do |p|
      BusinessException.raise "缺少参数:#{p.to_s},且值不可以为空白字符串。" if options[p.to_sym].blank?
    end

    options[:nonce_str] = SecureRandom.uuid.tr('-', '')
    options[:mch_billno] = options[:mch_id] + Time.now.strftime("%Y%m%d") + Time.now.strftime("%H%M%S") + EricTools.generate_random_string(4,1).to_s
    # 生成签名
    api_key = options[:mch_key]
    options.delete(:mch_key)
    sign = generate_sign options, api_key
    options[:sign] = sign
    # 生成xml数据包
    pay_load = "<xml>#{options.map { |k, v| "<#{k.to_s}>#{v.to_s}</#{k.to_s}>" }.join}</xml>"
    require 'rest-client'
    ca_path = Rails.root.join("ca/").to_s
    Dir.mkdir ca_path unless Dir.exist? ca_path
    BusinessException.raise '请下载证书' unless File.exist?(ca_path+"apiclient_cert.pem") && File.exist?(ca_path+"apiclient_key.pem")
    response = RestClient::Request.execute(method: :post, url: 'https://api.mch.weixin.qq.com/mmpaymkttransfers/sendredpack',
                                ssl_client_cert: OpenSSL::X509::Certificate.new(File.read(ca_path+"apiclient_cert.pem")),
                                ssl_client_key:  OpenSSL::PKey::RSA.new(File.read(ca_path+"apiclient_key.pem"), "passphrase, if any"),
                                ssl_ciphers: 'AESGCM:!aNULL',
                                payload: pay_load)

    # 分析请求结果
    pp "********************** 发红包 请求结果 ******************************"
    pp response.force_encoding("UTF-8")
    result = Hash.from_xml(response.force_encoding("UTF-8"))
    result['xml']
  end

  # mch_billno
  # mch_id
  # appid
  # mch_key
  def self.gethbinfo options
    BusinessException.raise '请提供商户订单号。' if options[:mch_billno].blank?
    BusinessException.raise '请提供商户号。' if options[:mch_id].blank?
    BusinessException.raise '请提供公众账号ID。' if options[:appid].blank?
    BusinessException.raise '请提供mch_key。' if options[:mch_key].blank?
    options[:nonce_str] = SecureRandom.uuid.tr('-', '')
    options[:bill_type] = 'MCHT'

    api_key = options[:mch_key]
    options.delete(:mch_key)
    sign = generate_sign options, api_key
    # sign = generate_sign options, options[:mch_key]
    options[:sign] = sign

    pay_load = "<xml>#{options.map { |k, v| "<#{k.to_s}>#{v.to_s}</#{k.to_s}>" }.join}</xml>"
    require 'rest-client'
    ca_path = Rails.root.join("ca/").to_s
    Dir.mkdir ca_path unless Dir.exist? ca_path
    BusinessException.raise '请下载证书' unless File.exist?(ca_path+"apiclient_cert.pem") && File.exist?(ca_path+"apiclient_key.pem")
    response = RestClient::Request.execute(method: :post, url: 'https://api.mch.weixin.qq.com/mmpaymkttransfers/gethbinfo',
                                           ssl_client_cert: OpenSSL::X509::Certificate.new(File.read(ca_path+"apiclient_cert.pem")),
                                           ssl_client_key:  OpenSSL::PKey::RSA.new(File.read(ca_path+"apiclient_key.pem"), "passphrase, if any"),
                                           ssl_ciphers: 'AESGCM:!aNULL',
                                           payload: pay_load)
    # 分析查询红包结果
    pp "********************** 红包查询 结果 ******************************"
    pp response.force_encoding("UTF-8")
    result = Hash.from_xml(response.force_encoding("UTF-8"))
    result['xml']
  end

end