mirror of
https://github.com/LaCasemate/fab-manager.git
synced 2024-12-01 12:24:28 +01:00
162 lines
6.2 KiB
Ruby
162 lines
6.2 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require 'payment/service'
|
|
require 'pay_zen/charge'
|
|
require 'pay_zen/order'
|
|
require 'pay_zen/item'
|
|
|
|
# PayZen payement gateway
|
|
module PayZen; end
|
|
|
|
## create remote objects on PayZen
|
|
class PayZen::Service < Payment::Service
|
|
def create_subscription(payment_schedule, order_id, *_args)
|
|
first_item = payment_schedule.ordered_items.first
|
|
|
|
order = PayZen::Order.new.get(order_id, operation_type: 'VERIFICATION')
|
|
client = PayZen::Charge.new
|
|
token_id = order['answer']['transactions'].first['paymentMethodToken']
|
|
|
|
params = {
|
|
amount: payzen_amount(first_item.details['recurring'].to_i),
|
|
effect_date: first_item.due_date.iso8601,
|
|
payment_method_token: token_id,
|
|
rrule: rrule(payment_schedule),
|
|
order_id: order_id
|
|
}
|
|
if first_item.details['adjustment']&.zero? && first_item.details['other_items']&.zero?
|
|
initial_amount = first_item.amount
|
|
initial_amount -= payment_schedule.wallet_amount if payment_schedule.wallet_amount
|
|
if initial_amount.zero?
|
|
params[:effect_date] = (first_item.due_date + 1.month).iso8601
|
|
params[:rrule] = rrule(payment_schedule, -1)
|
|
else
|
|
params[:initial_amount] = payzen_amount(initial_amount)
|
|
params[:initial_amount_number] = 1
|
|
end
|
|
end
|
|
pz_subscription = client.create_subscription(**params)
|
|
|
|
# save payment token
|
|
pgo_tok = PaymentGatewayObject.new(
|
|
gateway_object_id: token_id,
|
|
gateway_object_type: 'PayZen::Token',
|
|
item: payment_schedule
|
|
)
|
|
pgo_tok.save!
|
|
|
|
# save payzen subscription
|
|
pgo_sub = PaymentGatewayObject.new(
|
|
gateway_object_id: pz_subscription['answer']['subscriptionId'],
|
|
gateway_object_type: 'PayZen::Subscription',
|
|
item: payment_schedule,
|
|
payment_gateway_object_id: pgo_tok.id
|
|
)
|
|
pgo_sub.save!
|
|
end
|
|
|
|
def cancel_subscription(payment_schedule)
|
|
pz_subscription = payment_schedule.gateway_subscription.retrieve
|
|
|
|
order_client = PayZen::Order.new
|
|
tr_client = PayZen::Transaction.new
|
|
|
|
# first, we cancel all running transactions
|
|
begin
|
|
order = order_client.get(pz_subscription['answer']['orderId'])
|
|
order['answer']['transactions'].select { |t| t['status'] == 'RUNNING' }.each do |t|
|
|
tr_res = tr_client.cancel_or_refund(t['uuid'], amount: t['amount'], currency: t['currency'], resolution_mode: 'CANCELLATION_ONLY')
|
|
raise "Cannot cancel transaction #{t['uuid']}" unless tr_res['answer']['detailedStatus'] == 'CANCELLED'
|
|
end
|
|
rescue PayzenError => e
|
|
raise e unless e.details['errorCode'] == 'PSP_010' # ignore if no order
|
|
end
|
|
|
|
# then, we cancel the subscription
|
|
begin
|
|
sub_client = PayZen::Subscription.new
|
|
res = sub_client.cancel(pz_subscription['answer']['subscriptionId'], pz_subscription['answer']['paymentMethodToken'])
|
|
rescue PayzenError => e
|
|
return true if e.details['errorCode'] == 'PSP_033' # recurring payment already canceled
|
|
|
|
raise e
|
|
end
|
|
res['answer']['responseCode'].zero?
|
|
end
|
|
|
|
def process_payment_schedule_item(payment_schedule_item)
|
|
pz_subscription = payment_schedule_item.payment_schedule.gateway_subscription.retrieve
|
|
if pz_subscription['answer']['cancelDate'] && Time.zone.parse(pz_subscription['answer']['cancelDate']) <= Time.current &&
|
|
pz_subscription['answer']['pastPaymentsNumber'] != pz_subscription['answer']['totalPaymentsNumber']
|
|
# the subscription was canceled by the gateway => notify & update the status
|
|
notify_payment_schedule_gateway_canceled(payment_schedule_item)
|
|
payment_schedule_item.update(state: 'gateway_canceled')
|
|
return
|
|
end
|
|
pz_order = payment_schedule_item.payment_schedule.gateway_order.retrieve
|
|
transaction = pz_order['answer']['transactions'].last
|
|
return unless transaction_matches?(transaction, payment_schedule_item)
|
|
|
|
case transaction['status']
|
|
when 'PAID'
|
|
PaymentScheduleService.new.generate_invoice(payment_schedule_item,
|
|
payment_method: 'card',
|
|
payment_id: transaction['uuid'],
|
|
payment_type: 'PayZen::Transaction')
|
|
payment_schedule_item.update(state: 'paid', payment_method: 'card')
|
|
pgo = PaymentGatewayObject.find_or_initialize_by(item: payment_schedule_item)
|
|
pgo.gateway_object = PayZen::Item.new('PayZen::Transaction', transaction['uuid'])
|
|
pgo.save!
|
|
when 'RUNNING'
|
|
notify_payment_schedule_item_failed(payment_schedule_item)
|
|
payment_schedule_item.update(state: transaction['detailedStatus'])
|
|
pgo = PaymentGatewayObject.find_or_initialize_by(item: payment_schedule_item)
|
|
pgo.gateway_object = PayZen::Item.new('PayZen::Transaction', transaction['uuid'])
|
|
pgo.save!
|
|
else
|
|
notify_payment_schedule_item_error(payment_schedule_item)
|
|
payment_schedule_item.update(state: 'error')
|
|
end
|
|
end
|
|
|
|
def payzen_amount(amount)
|
|
currency = Setting.get('payzen_currency')
|
|
raise ConfigurationError, 'PayZen currency is not configured. Unable to process online payments.' if currency.nil?
|
|
|
|
return amount / 100 if zero_decimal_currencies.any? { |s| s.casecmp(currency).zero? }
|
|
return amount * 10 if three_decimal_currencies.any? { |s| s.casecmp(currency).zero? }
|
|
|
|
amount
|
|
end
|
|
|
|
private
|
|
|
|
def rrule(payment_schedule, offset = 0)
|
|
count = payment_schedule.payment_schedule_items.count
|
|
"RRULE:FREQ=MONTHLY;COUNT=#{count + offset}"
|
|
end
|
|
|
|
# check if the given transaction matches the given PaymentScheduleItem
|
|
def transaction_matches?(transaction, payment_schedule_item)
|
|
transaction_date = Time.zone.parse(transaction['creationDate']).to_date
|
|
|
|
amount = payment_schedule_item.amount
|
|
if payment_schedule_item.details['adjustment']&.zero? && payment_schedule_item.payment_schedule.wallet_amount
|
|
amount -= payment_schedule_item.payment_schedule.wallet_amount
|
|
end
|
|
|
|
transaction['amount'] == amount &&
|
|
transaction_date >= payment_schedule_item.due_date.to_date &&
|
|
transaction_date <= payment_schedule_item.due_date.to_date + 7.days
|
|
end
|
|
|
|
# @see https://payzen.io/en-EN/payment-file/ips/list-of-supported-currencies.html
|
|
def zero_decimal_currencies
|
|
%w[KHR JPY KRW XOF XPF]
|
|
end
|
|
|
|
def three_decimal_currencies
|
|
%w[KWD TND]
|
|
end
|
|
end
|