lib/alipay/service.rb in alipay-0.6.0.beta1 vs lib/alipay/service.rb in alipay-0.6.0.beta2
- old
+ new
@@ -1,188 +1,192 @@
-require 'cgi'
-
module Alipay
module Service
GATEWAY_URL = 'https://mapi.alipay.com/gateway.do'
- CREATE_PARTNER_TRADE_BY_BUYER_REQUIRED_OPTIONS = %w( service partner _input_charset out_trade_no subject payment_type logistics_type logistics_fee logistics_payment seller_email price quantity )
+ CREATE_PARTNER_TRADE_BY_BUYER_REQUIRED_PARAMS = %w( out_trade_no subject logistics_type logistics_fee logistics_payment price quantity )
# alipayescow
- def self.create_partner_trade_by_buyer_url(options)
- options = {
+ def self.create_partner_trade_by_buyer_url(params, options = {})
+ params = Utils.stringify_keys(params)
+ check_required_params(params, CREATE_PARTNER_TRADE_BY_BUYER_REQUIRED_PARAMS)
+
+ params = {
'service' => 'create_partner_trade_by_buyer',
'_input_charset' => 'utf-8',
- 'partner' => Alipay.pid,
- 'seller_email' => Alipay.seller_email,
+ 'partner' => options[:pid] || Alipay.pid,
+ 'seller_email' => options[:seller_email] || Alipay.seller_email,
'payment_type' => '1'
- }.merge(Utils.stringify_keys(options))
+ }.merge(params)
- check_required_options(options, CREATE_PARTNER_TRADE_BY_BUYER_REQUIRED_OPTIONS)
-
- request_uri(options).to_s
+ request_uri(params, options).to_s
end
- TRADE_CREATE_BY_BUYER_REQUIRED_OPTIONS = %w( service partner _input_charset out_trade_no subject payment_type logistics_type logistics_fee logistics_payment seller_email price quantity )
+ TRADE_CREATE_BY_BUYER_REQUIRED_PARAMS = %w( out_trade_no subject logistics_type logistics_fee logistics_payment price quantity )
# alipaydualfun
- def self.trade_create_by_buyer_url(options = {})
- options = {
+ def self.trade_create_by_buyer_url(params, options = {})
+ params = Utils.stringify_keys(params)
+ check_required_params(params, TRADE_CREATE_BY_BUYER_REQUIRED_PARAMS)
+
+ params = {
'service' => 'trade_create_by_buyer',
'_input_charset' => 'utf-8',
- 'partner' => Alipay.pid,
- 'seller_email' => Alipay.seller_email,
+ 'partner' => options[:pid] || Alipay.pid,
+ 'seller_email' => options[:seller_email] || Alipay.seller_email,
'payment_type' => '1'
- }.merge(Utils.stringify_keys(options))
+ }.merge(params)
- check_required_options(options, TRADE_CREATE_BY_BUYER_REQUIRED_OPTIONS)
-
- request_uri(options).to_s
+ request_uri(params, options).to_s
end
- CREATE_DIRECT_PAY_BY_USER_REQUIRED_OPTIONS = %w( service partner _input_charset out_trade_no subject payment_type seller_email )
+ CREATE_DIRECT_PAY_BY_USER_REQUIRED_PARAMS = %w( out_trade_no subject )
# direct
- def self.create_direct_pay_by_user_url(options)
- options = {
- 'service' => 'create_direct_pay_by_user',
- '_input_charset' => 'utf-8',
- 'partner' => Alipay.pid,
- 'seller_email' => Alipay.seller_email,
- 'payment_type' => '1'
- }.merge(Utils.stringify_keys(options))
+ def self.create_direct_pay_by_user_url(params, options = {})
+ params = Utils.stringify_keys(params)
+ check_required_params(params, CREATE_DIRECT_PAY_BY_USER_REQUIRED_PARAMS)
- check_required_options(options, CREATE_DIRECT_PAY_BY_USER_REQUIRED_OPTIONS)
-
- if options['total_fee'].nil? and (options['price'].nil? || options['quantity'].nil?)
+ if params['total_fee'].nil? and (params['price'].nil? || params['quantity'].nil?)
warn("Ailpay Warn: total_fee or (price && quantiry) must have one")
end
- request_uri(options).to_s
+ params = {
+ 'service' => 'create_direct_pay_by_user',
+ '_input_charset' => 'utf-8',
+ 'partner' => options[:pid] || Alipay.pid,
+ 'seller_email' => options[:seller_email] || Alipay.seller_email,
+ 'payment_type' => '1'
+ }.merge(params)
+
+ request_uri(params, options).to_s
end
- CREATE_REFUND_URL_REQUIRED_OPTIONS = %w( batch_no data notify_url )
+ CREATE_REFUND_URL_REQUIRED_PARAMS = %w( batch_no data notify_url )
# 支付宝即时到帐批量退款有密接口(此为异步接口，有密指通过此接口打开 url 后需要用户输入支付宝的支付密码进行退款)
- def self.create_refund_url(options)
- options = Utils.stringify_keys(options)
- check_required_options(options, CREATE_REFUND_URL_REQUIRED_OPTIONS)
+ def self.refund_fastpay_by_platform_pwd_url(params, options = {})
+ params = Utils.stringify_keys(params)
+ check_required_params(params, CREATE_REFUND_URL_REQUIRED_PARAMS)
- data = options.delete('data')
+ data = params.delete('data')
detail_data = data.map do|item|
item = Utils.stringify_keys(item)
"#{item['trade_no']}^#{item['amount']}^#{item['reason']}"
end.join('#')
- options = {
+ params = {
'service' => 'refund_fastpay_by_platform_pwd', # 接口名称
'_input_charset' => 'utf-8',
- 'partner' => Alipay.pid,
- 'seller_email' => Alipay.seller_email,
+ 'partner' => options[:pid] || Alipay.pid,
+ 'seller_email' => options[:seller_email] || Alipay.seller_email,
'refund_date' => Time.now.strftime('%Y-%m-%d %H:%M:%S'), # 申请退款时间
'batch_num' => data.size, # 总笔数
'detail_data' => detail_data # 转换后的单笔数据集字符串
- }.merge(options)
+ }.merge(params)
- request_uri(options).to_s
+ request_uri(params, options).to_s
end
- CREATE_FOREX_SINGLE_REFUND_URL_REQUIRED_OPTIONS = %w( out_return_no out_trade_no return_amount currency reason )
+ CREATE_FOREX_SINGLE_REFUND_URL_REQUIRED_PARAMS = %w( out_return_no out_trade_no return_amount currency reason )
# 支付宝境外收单单笔退款接口
# out_return_no 退款流水单号
# out_trade_no 交易创建时的订单号
# return_amount 退款金额
# currency 退款币种，与交易创建时的币种一致
- def self.create_forex_single_refund_url(options)
- options = {
+ def self.forex_refund_url(params, options = {})
+ params = Utils.stringify_keys(params)
+ check_required_params(params, CREATE_FOREX_SINGLE_REFUND_URL_REQUIRED_PARAMS)
+
+ params = {
'service' => 'forex_refund',
- 'partner' => Alipay.pid,
+ 'partner' => options[:pid] || Alipay.pid,
'_input_charset' => 'utf-8',
'gmt_return' => Time.now.strftime('%Y%m%d%H%M%S')
- }.merge(Utils.stringify_keys(options))
+ }.merge(params)
- check_required_options(options, CREATE_FOREX_SINGLE_REFUND_URL_REQUIRED_OPTIONS)
-
- request_uri(options).to_s
+ request_uri(params, options).to_s
end
- SEND_GOODS_CONFIRM_BY_PLATFORM_REQUIRED_OPTIONS = %w( service partner _input_charset trade_no logistics_name )
- def self.send_goods_confirm_by_platform(options)
- options = {
- 'service' => 'send_goods_confirm_by_platform',
- 'partner' => Alipay.pid,
- '_input_charset' => 'utf-8'
- }.merge(Utils.stringify_keys(options))
+ SEND_GOODS_CONFIRM_BY_PLATFORM_REQUIRED_PARAMS = %w( trade_no logistics_name )
+ def self.send_goods_confirm_by_platform(params, options = {})
+ params = Utils.stringify_keys(params)
+ check_required_params(params, SEND_GOODS_CONFIRM_BY_PLATFORM_REQUIRED_PARAMS)
- check_required_options(options, SEND_GOODS_CONFIRM_BY_PLATFORM_REQUIRED_OPTIONS)
-
- if options['transport_type'].nil? and options['create_transport_type'].nil?
+ if params['transport_type'].nil? and params['create_transport_type'].nil?
warn("Ailpay Warn: transport_type or create_transport_type must have one")
end
- Net::HTTP.get(request_uri(options))
+ params = {
+ 'service' => 'send_goods_confirm_by_platform',
+ 'partner' => options[:pid] || Alipay.pid,
+ '_input_charset' => 'utf-8'
+ }.merge(params)
+
+ Net::HTTP.get(request_uri(params, options))
end
- CREATE_FOREX_TRADE_REQUIRED_OPTIONS = %w(service partner _input_charset notify_url subject out_trade_no currency total_fee)
- def self.create_forex_trade(options)
- options = {
+ CREATE_FOREX_TRADE_REQUIRED_PARAMS = %w( notify_url subject out_trade_no currency total_fee)
+ def self.create_forex_trade_url(params, options = {})
+ params = Utils.stringify_keys(params)
+ check_required_params(params, CREATE_FOREX_TRADE_REQUIRED_PARAMS)
+
+ params = {
'service' => 'create_forex_trade',
'_input_charset' => 'utf-8',
- 'partner' => Alipay.pid,
- 'seller_email' => Alipay.seller_email
- }.merge(Utils.stringify_keys(options))
+ 'partner' => options[:pid] || Alipay.pid,
+ 'seller_email' => options[:seller_email] || Alipay.seller_email
+ }.merge(params)
- check_required_options(options, CREATE_FOREX_TRADE_REQUIRED_OPTIONS)
-
- request_uri(options).to_s
+ request_uri(params, options).to_s
end
- CLOSE_TRADE_REQUIRED_OPTIONS = %w( service partner _input_charset)
- CLOSE_TRADE_REQUIRED_OPTIONAL_OPTIONS = %w( trade_no out_order_no )
- def self.close_trade(options)
- options = {
+ CLOSE_TRADE_REQUIRED_OPTIONAL_PARAMS = %w( trade_no out_order_no )
+ def self.close_trade(params, options = {})
+ params = Utils.stringify_keys(params)
+ check_optional_params(params, CLOSE_TRADE_REQUIRED_OPTIONAL_PARAMS)
+
+ params = {
'service' => 'close_trade',
'_input_charset' => 'utf-8',
- 'partner' => Alipay.pid
- }.merge(Utils.stringify_keys(options))
+ 'partner' => options[:pid] || Alipay.pid
+ }.merge(params)
- check_required_options(options, CLOSE_TRADE_REQUIRED_OPTIONS)
- check_optional_options(options, CLOSE_TRADE_REQUIRED_OPTIONAL_OPTIONS)
-
- Net::HTTP.get(request_uri(options))
+ Net::HTTP.get(request_uri(params, options))
end
- SINGLE_TRADE_QUERY_OPTIONS = %w( service partner _input_charset)
- SINGLE_TRADE_QUERY_OPTIONAL_OPTIONS = %w( trade_no out_trade_no )
- def self.single_trade_query(options)
- options = {
+ SINGLE_TRADE_QUERY_OPTIONAL_PARAMS = %w( trade_no out_trade_no )
+ def self.single_trade_query(params, options = {})
+ params = Utils.stringify_keys(params)
+ check_optional_params(params, SINGLE_TRADE_QUERY_OPTIONAL_PARAMS)
+
+ params = {
"service" => 'single_trade_query',
"_input_charset" => "utf-8",
- "partner" => Alipay.pid,
- }.merge(Utils.stringify_keys(options))
+ "partner" => options[:pid] || Alipay.pid,
+ }.merge(params)
- check_required_options(options, SINGLE_TRADE_QUERY_OPTIONS)
- check_optional_options(options, SINGLE_TRADE_QUERY_OPTIONAL_OPTIONS)
-
- Net::HTTP.get(request_uri(options))
+ Net::HTTP.get(request_uri(params, options))
end
- def self.request_uri(options)
+ def self.request_uri(params, options = {})
uri = URI(GATEWAY_URL)
- uri.query = URI.encode_www_form(sign_params(options))
+ uri.query = URI.encode_www_form(sign_params(params, options))
uri
end
- def self.sign_params(params)
- params = params.merge('sign_type' => Alipay.sign_type) if params['sign_type'].nil?
- params.merge('sign' => Alipay::Sign.generate(params))
+ def self.sign_params(params, optinos = {})
+ params.merge(
+ 'sign_type' => (optinos[:sign_type] || Alipay.sign_type),
+ 'sign' => Alipay::Sign.generate(params, optinos)
+ )
end
- def self.check_required_options(options, names)
+ def self.check_required_params(params, names)
return if !Alipay.debug_mode?
names.each do |name|
- warn("Ailpay Warn: missing required option: #{name}") unless options.has_key?(name)
+ warn("Ailpay Warn: missing required option: #{name}") unless params.has_key?(name)
end
end
- def self.check_optional_options(options, names)
+ def self.check_optional_params(params, names)
return if !Alipay.debug_mode?
- warn("Ailpay Warn: must specify either #{names.join(' or ')}") if names.all? {|name| options[name].nil? }
+ warn("Ailpay Warn: must specify either #{names.join(' or ')}") if names.all? {|name| params[name].nil? }
end
end
end