# 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) 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: 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 } unless first_item.details['adjustment']&.zero? && first_item.details['other_items']&.zero? params[:initial_amount] = first_item.amount params[:initial_amount_number] = 1 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 process_payment_schedule_item(payment_schedule_item) pz_order = payment_schedule_item.payment_schedule.gateway_order.retrieve transaction = pz_order['answer']['transactions'].last return unless transaction_matches?(transaction, payment_schedule_item) if transaction['status'] == 'PAID' PaymentScheduleService.new.generate_invoice(payment_schedule_item, payment_method: 'card', payment_id: transaction['uuid'], payment_type: 'PayZen::Transaction') payment_schedule_item.update_attributes(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! elsif transaction['status'] == 'RUNNING' if payment_schedule_item.state == 'new' # notify only for new deadlines, to prevent spamming NotificationCenter.call type: 'notify_admin_payment_schedule_failed', receiver: User.admins_and_managers, attached_object: payment_schedule_item NotificationCenter.call type: 'notify_member_payment_schedule_failed', receiver: payment_schedule_item.payment_schedule.user, attached_object: payment_schedule_item end payment_schedule_item.update_attributes(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 payment_schedule_item.update_attributes(state: 'error') end end private def rrule(payment_schedule) count = payment_schedule.payment_schedule_items.count "RRULE:FREQ=MONTHLY;COUNT=#{count}" end # check if the given transaction matches the given PaymentScheduleItem def transaction_matches?(transaction, payment_schedule_item) transaction_date = DateTime.parse(transaction['creationDate']).to_date transaction['amount'] == payment_schedule_item.amount && transaction_date >= payment_schedule_item.due_date.to_date && transaction_date <= payment_schedule_item.due_date.to_date + 7.days end end