Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/cartforge.co/app/code/StripeIntegration/Payments/Model/ |
<?php
namespace StripeIntegration\Payments\Model;
use Magento\Framework\Exception\LocalizedException;
use StripeIntegration\Payments\Exception\GenericException;
class Subscription extends \Magento\Framework\Model\AbstractModel
{
private $config;
private $quoteRepository;
private $stripeCustomer;
private $helper;
private $subscriptionsHelper;
private $subscriptionProductFactory;
private $stripeSubscriptionFactory;
private $stripeSubscriptionModel;
private $dataHelper;
private $subscriptionFactory;
private $session;
private $subscriptionReactivationFactory;
private $resourceModel;
private $quoteHelper;
private $orderHelper;
private $productHelper;
private $dateTimeHelper;
private $cartInfo;
public function __construct(
\StripeIntegration\Payments\Model\Config $config,
\Magento\Quote\Api\CartRepositoryInterface $quoteRepository,
\StripeIntegration\Payments\Helper\Generic $helper,
\StripeIntegration\Payments\Helper\Subscriptions $subscriptionsHelper,
\StripeIntegration\Payments\Helper\Quote $quoteHelper,
\StripeIntegration\Payments\Helper\Order $orderHelper,
\StripeIntegration\Payments\Helper\Product $productHelper,
\StripeIntegration\Payments\Helper\DateTime $dateTimeHelper,
\StripeIntegration\Payments\Helper\Data $dataHelper,
\StripeIntegration\Payments\Model\Cart\Info $cartInfo,
\StripeIntegration\Payments\Model\SubscriptionProductFactory $subscriptionProductFactory,
\StripeIntegration\Payments\Model\Stripe\SubscriptionFactory $stripeSubscriptionFactory,
\StripeIntegration\Payments\Model\SubscriptionFactory $subscriptionFactory,
\StripeIntegration\Payments\Model\SubscriptionReactivationFactory $subscriptionReactivationFactory,
\StripeIntegration\Payments\Model\ResourceModel\Subscription $resourceModel,
\Magento\Customer\Model\Session $session,
\Magento\Framework\Model\Context $context,
\Magento\Framework\Registry $registry,
\Magento\Framework\Model\ResourceModel\AbstractResource $resource = null,
\Magento\Framework\Data\Collection\AbstractDb $resourceCollection = null,
array $data = []
) {
$this->config = $config;
$this->quoteRepository = $quoteRepository;
parent::__construct($context, $registry, $resource, $resourceCollection, $data);
$this->helper = $helper;
$this->stripeCustomer = $helper->getCustomerModel();
$this->subscriptionsHelper = $subscriptionsHelper;
$this->subscriptionProductFactory = $subscriptionProductFactory;
$this->stripeSubscriptionFactory = $stripeSubscriptionFactory;
$this->dataHelper = $dataHelper;
$this->cartInfo = $cartInfo;
$this->subscriptionFactory = $subscriptionFactory;
$this->session = $session;
$this->subscriptionReactivationFactory = $subscriptionReactivationFactory;
$this->resourceModel = $resourceModel;
$this->quoteHelper = $quoteHelper;
$this->orderHelper = $orderHelper;
$this->productHelper = $productHelper;
$this->dateTimeHelper = $dateTimeHelper;
}
protected function _construct()
{
$this->_init('StripeIntegration\Payments\Model\ResourceModel\Subscription');
}
public function fromSubscriptionId($subscriptionId)
{
$this->resourceModel->load($this, $subscriptionId, "subscription_id");
if (empty($this->getId()) || empty($this->getOrderIncrementId()))
{
$this->stripeSubscriptionModel = $this->stripeSubscriptionFactory->create();
$this->stripeSubscriptionModel->setExpandParams(['plan.product']);
$this->stripeSubscriptionModel->fromSubscriptionId($subscriptionId);
$subscription = $this->stripeSubscriptionModel->getStripeObject();
$this->initFrom($subscription);
$this->resourceModel->save($this);
}
return $this;
}
protected function getStripeSubscriptionModel()
{
if (!$this->getSubscriptionId())
throw new GenericException(__("The subscription could not be loaded."));
if (!$this->stripeSubscriptionModel)
$this->stripeSubscriptionModel = $this->stripeSubscriptionFactory->create()->fromSubscriptionId($this->getSubscriptionId());
return $this->stripeSubscriptionModel;
}
public function initFrom($subscription, $order = null)
{
if (!$order && !empty($subscription->metadata->{'Order #'}))
{
$order = $this->orderHelper->loadOrderByIncrementId($subscription->metadata->{'Order #'});
}
$data = [
"created_at" => $subscription->created,
"livemode" => $subscription->livemode,
"subscription_id" => $subscription->id,
"stripe_customer_id" => $subscription->customer,
"payment_method_id" => $subscription->default_payment_method,
"quantity" => $subscription->quantity,
"currency" => $subscription->plan->currency ?? null, // Versions 2.x of the module may not have this set
"status" => $subscription->status,
"name" => $this->subscriptionsHelper->generateSubscriptionName($subscription),
"plan_amount" => $subscription->plan->amount ?? null,
"plan_interval" => $subscription->plan->interval ?? null,
"plan_interval_count" => $subscription->plan->interval_count ?? null,
];
$productIds = $this->subscriptionsHelper->getSubscriptionProductIDs($subscription);
if (!empty($productIds))
$data["product_id"] = array_shift($productIds);
if ($order)
{
$data["store_id"] = $order->getStoreId();
$data["order_increment_id"] = $order->getIncrementId();
$data["magento_customer_id"] = $order->getCustomerId();
$data["grand_total"] = $order->getGrandTotal();
}
// cartInfo is only populated during the initial order placement
if (!empty($subscription->trial_end))
{
$data["trial_end"] = $subscription->trial_end;
}
else if ($subscription->billing_cycle_anchor && $subscription->billing_cycle_anchor > $subscription->start_date)
{
$data["start_date"] = $subscription->billing_cycle_anchor;
}
$this->addData($data);
return $this;
}
public function cancel()
{
$subscription = $this->getStripeSubscriptionModel()->getStripeObject();
$subscriptionId = $subscription->id;
$this->config->getStripeClient()->subscriptions->cancel($subscriptionId, []);
$this->resourceModel->load($this, $subscriptionId, "subscription_id");
if ($this->getReorderFromQuoteId())
{
try
{
$quote = $this->quoteRepository->get($this->getReorderFromQuoteId());
$quote->setIsUsedForRecurringOrders(false);
$this->quoteRepository->save($quote);
}
catch (\Exception $e)
{
}
}
}
public function getStripeObject()
{
return $this->getStripeSubscriptionModel()->getStripeObject();
}
public function reactivate()
{
if (!$this->getId())
throw new GenericException(__("The subscription could not be loaded."));
$subscription = $this->getStripeSubscriptionModel()->getStripeObject();
$params['customer'] = $subscription->customer;
$params['items'] = [];
if (isset($subscription->items) && isset($subscription->items->data)) {
foreach ($subscription->items->data as $subItems) {
$subItemData = [];
$subItemData['price'] = $subItems->price->id;
$subItemData['quantity'] = $subItems->quantity;
$subItemData['metadata'] = json_decode(json_encode($subItems->metadata), true);
$params['items'][] = $subItemData;
}
}
$params['metadata'] = json_decode(json_encode($subscription->metadata), true);
$params['description'] = $subscription->description?: "Subscription";
$params['currency'] = $subscription->currency;
$params['collection_method'] = $subscription->collection_method;
// If the subscription had a trial, and is still within the trial period, set it on the reactivated subscription
if (is_numeric($subscription->trial_end) && $subscription->trial_end > time())
{
$params['trial_end'] = $subscription->trial_end;
}
// If the subscription had a billing anchor date which is still in the future, set it on the reactivated subscription
else if (is_numeric($subscription->billing_cycle_anchor) && $subscription->billing_cycle_anchor > time())
{
$params['billing_cycle_anchor'] = $subscription->billing_cycle_anchor;
$params['proration_behavior'] = 'none';
}
// If the subscription's current period invoice is paid, set the billing cycle anchor to the next billing date
else if ($this->isLatestInvoicePaid($subscription) && $subscription->current_period_end > time())
{
$params['billing_cycle_anchor'] = $subscription->current_period_end;
$params['proration_behavior'] = 'none';
}
if (isset($subscription->payment_settings) && isset($subscription->payment_settings->save_default_payment_method)) {
$params['payment_settings']['save_default_payment_method'] = $subscription->payment_settings->save_default_payment_method;
}
$reactivationModel = $this->subscriptionReactivationFactory->create();
$reactivationModel->load($this->getOrderIncrementId(), 'order_increment_id');
$reactivationModel->setOrderIncrementId($this->getOrderIncrementId());
$reactivationModel->setReactivatedAt(date('Y-m-d H:i:s'));
$reactivationModel->save();
if ($this->paymentMethodDeleted())
{
return $this->reactivateWithNewPaymentMethod($subscription, $params);
}
else
{
$params['default_payment_method'] = $this->getPaymentMethodId();
}
$reactivatedSubscription = $this->config->getStripeClient()->subscriptions->create($params);
$this->setStatus('reactivated');
$this->resourceModel->save($this);
$subscriptionData = [
'store_id' => ($this->getStoreId() ?? $this->helper->getStoreId()),
'livemode' => $reactivatedSubscription->livemode,
'subscription_id' => $reactivatedSubscription->id,
'order_increment_id' => ($this->getOrderIncrementId() ?? $reactivatedSubscription->metadata->{'Order #'}),
'magento_customer_id' => ($this->getMagentoCustomerId() ?? $this->session->getId()),
'stripe_customer_id' => ($this->getStripeCustomerId() ?? $reactivatedSubscription->customer),
'payment_method_id' => ($this->getPaymentMethodId() ?? $reactivatedSubscription->default_payment_method),
'quantity' => $reactivatedSubscription->quantity,
'currency' => $reactivatedSubscription->currency,
'status' => $reactivatedSubscription->status
];
$this->subscriptionFactory->create($subscriptionData)->save();
}
private function isLatestInvoicePaid($subscription)
{
$invoice = $subscription->latest_invoice;
if (!$invoice)
return false;
$invoice = $this->config->getStripeClient()->invoices->retrieve($invoice, []);
return $invoice->status == "paid";
}
protected function setSubscriptionReactivateDetails($subscription, $createSubParams)
{
$checkoutSession = $this->helper->getCheckoutSession();
$checkoutSession->setSubscriptionReactivateDetails([
"update_subscription_id" => $subscription->id,
"success_url" => $this->helper->getUrl("stripe/customer/subscriptions", ["updateSuccess" => 1]),
"subscription_data" => $createSubParams
]);
}
protected function reactivateWithNewPaymentMethod($subscription, $createSubParams)
{
try
{
$orderIncrementId = $this->subscriptionsHelper->getSubscriptionOrderID($subscription);
if (!$orderIncrementId)
throw new LocalizedException(__("This subscription is not associated with an order."));
$order = $this->orderHelper->loadOrderByIncrementId($orderIncrementId);
if (!$order)
throw new LocalizedException(__("Could not load order for this subscription."));
$quote = $this->quoteHelper->getQuote();
$quote->removeAllItems();
$quote->removeAllAddresses();
$extensionAttributes = $quote->getExtensionAttributes();
$extensionAttributes->setShippingAssignments([]);
$productIds = $this->subscriptionsHelper->getSubscriptionProductIDs($subscription);
$items = $order->getItemsCollection();
foreach ($items as $item)
{
$subscriptionProductModel = $this->subscriptionProductFactory->create()->fromOrderItem($item);
if ($subscriptionProductModel->isSubscriptionProduct() &&
$subscriptionProductModel->getIsSalable() &&
in_array($subscriptionProductModel->getProductId(), $productIds)
)
{
$product = $subscriptionProductModel->getProduct();
if ($item->getParentItem() && $item->getParentItem()->getProductType() == "configurable")
{
$item = $item->getParentItem();
try
{
$product = $this->productHelper->getProduct($item->getProductId());
if (!$product->getIsSalable())
continue;
}
catch (\Exception $e)
{
continue;
}
}
$request = $this->dataHelper->getBuyRequest($item);
$result = $quote->addProduct($product, $request);
if (is_string($result))
throw new LocalizedException(__($result));
}
}
if (!$quote->hasItems())
throw new LocalizedException(__("Sorry, this subscription product is currently unavailable."));
$this->setSubscriptionReactivateDetails($subscription, $createSubParams);
$quote->getShippingAddress()->setCollectShippingRates(false);
$quote->setTotalsCollectedFlag(false)->collectTotals();
$this->quoteHelper->saveQuote($quote);
try
{
if (!$order->getIsVirtual() && !$quote->getIsVirtual() && $order->getShippingMethod())
{
$shippingAddress = $quote->getShippingAddress();
$shippingAddress->addData($order->getShippingAddress()->getData());
$shippingAddress->setCollectShippingRates(true)
->collectShippingRates()
->setShippingMethod($order->getShippingMethod())
->save();
}
}
catch (\Exception $e)
{
// The shipping address or method may not be available, ignore in this case
}
return 'checkout';
}
catch (LocalizedException $e)
{
throw new LocalizedException(__("Sorry, unable to reactivate the subscription."));
}
catch (\Exception $e)
{
throw new GenericException(__("Sorry, the subscription could not be reactivated. Please contact us for more help."));
}
}
public function paymentMethodDeleted()
{
$savedPaymentMethods = $this->stripeCustomer->getSavedPaymentMethods(\StripeIntegration\Payments\Helper\PaymentMethod::SUPPORTS_SUBSCRIPTIONS, true);
$savedPaymentMethodsArray = [];
foreach ($savedPaymentMethods as $savedPaymentMethod)
{
$savedPaymentMethodsArray[$savedPaymentMethod['id']] = $savedPaymentMethod['id'];
}
return !in_array($this->getPaymentMethodId(), $savedPaymentMethodsArray);
}
public function isNewSubscription()
{
$subscription = $this->getStripeSubscriptionModel()->getStripeObject();
// Fetch the subscription's invoices
$invoices = $this->config->getStripeClient()->invoices->all([
'subscription' => $subscription->id,
'limit' => 3
]);
// If there are multiple invoices, its not a new subscription
if (count($invoices->data) > 1)
return false;
// Subscriptions with start dates will have no invoices
if (empty($invoices->data))
return true;
// If it has a single invoice, check if it was created within a minute of the subscription creation time.
$invoice = $invoices->data[0];
$subscriptionCreated = $subscription->created;
$invoiceCreated = $invoice->created;
return ($invoiceCreated - $subscriptionCreated) < 60;
}
}