mirror of
https://github.com/invoiceninja/invoiceninja.git
synced 2024-11-11 05:32:39 +01:00
253 lines
9.2 KiB
PHP
253 lines
9.2 KiB
PHP
<?php
|
|
/**
|
|
* Invoice Ninja (https://invoiceninja.com).
|
|
*
|
|
* @link https://github.com/invoiceninja/invoiceninja source repository
|
|
*
|
|
* @copyright Copyright (c) 2021. Invoice Ninja LLC (https://invoiceninja.com)
|
|
*
|
|
* @license https://opensource.org/licenses/AAL
|
|
*/
|
|
|
|
namespace App\Services\Subscription;
|
|
|
|
use App\DataMapper\InvoiceItem;
|
|
use App\Factory\InvoiceFactory;
|
|
use App\Factory\InvoiceToRecurringInvoiceFactory;
|
|
use App\Factory\RecurringInvoiceFactory;
|
|
use App\Jobs\Util\SystemLogger;
|
|
use App\Models\ClientContact;
|
|
use App\Models\ClientSubscription;
|
|
use App\Models\Invoice;
|
|
use App\Models\PaymentHash;
|
|
use App\Models\Product;
|
|
use App\Models\RecurringInvoice;
|
|
use App\Models\Subscription;
|
|
use App\Models\SystemLog;
|
|
use App\Repositories\InvoiceRepository;
|
|
use App\Repositories\RecurringInvoiceRepository;
|
|
use App\Repositories\SubscriptionRepository;
|
|
use App\Utils\Traits\CleanLineItems;
|
|
use App\Utils\Traits\MakesHash;
|
|
use GuzzleHttp\RequestOptions;
|
|
|
|
class SubscriptionService
|
|
{
|
|
use MakesHash;
|
|
use CleanLineItems;
|
|
|
|
/** @var subscription */
|
|
private $subscription;
|
|
|
|
/** @var client_subscription */
|
|
// private $client_subscription;
|
|
|
|
public function __construct(Subscription $subscription)
|
|
{
|
|
$this->subscription = $subscription;
|
|
}
|
|
|
|
public function completePurchase(PaymentHash $payment_hash)
|
|
{
|
|
|
|
if (!property_exists($payment_hash->data, 'billing_context')) {
|
|
throw new \Exception("Illegal entrypoint into method, payload must contain billing context");
|
|
}
|
|
|
|
// if we have a recurring product - then generate a recurring invoice
|
|
if(strlen($this->subscription->recurring_product_ids) >=1){
|
|
|
|
$recurring_invoice = $this->convertInvoiceToRecurring($payment_hash->payment->client_id);
|
|
$recurring_invoice_repo = new RecurringInvoiceRepository();
|
|
|
|
$recurring_invoice->next_send_date = now();
|
|
$recurring_invoice = $recurring_invoice_repo->save([], $recurring_invoice);
|
|
$recurring_invoice->next_send_date = $recurring_invoice->nextSendDate();
|
|
|
|
/* Start the recurring service */
|
|
$recurring_invoice->service()
|
|
->start()
|
|
->save();
|
|
|
|
//execute any webhooks
|
|
$this->triggerWebhook();
|
|
|
|
if(array_key_exists('post_purchase_url', $this->subscription->webhook_configuration) && strlen($this->subscription->webhook_configuration['post_purchase_url']) >=1)
|
|
return redirect($this->subscription->webhook_configuration['post_purchase_url']);
|
|
|
|
return redirect('/client/recurring_invoices/'.$recurring_invoice->hashed_id);
|
|
}
|
|
else
|
|
{
|
|
|
|
//execute any webhooks
|
|
$this->triggerWebhook();
|
|
|
|
if(array_key_exists('post_purchase_url', $this->subscription->webhook_configuration) && strlen($this->subscription->webhook_configuration['post_purchase_url']) >=1)
|
|
return redirect($this->subscription->webhook_configuration['post_purchase_url']);
|
|
|
|
return redirect('/client/invoices/'.$this->encodePrimaryKey($payment_hash->fee_invoice_id));
|
|
|
|
}
|
|
}
|
|
|
|
/**
|
|
'email' => $this->email ?? $this->contact->email,
|
|
'quantity' => $this->quantity,
|
|
'contact_id' => $this->contact->id,
|
|
*/
|
|
public function startTrial(array $data)
|
|
{
|
|
// Redirects from here work just fine. Livewire will respect it.
|
|
$client_contact = ClientContact::find($data['contact_id']);
|
|
|
|
if(!$this->subscription->trial_enabled)
|
|
return new \Exception("Trials are disabled for this product");
|
|
|
|
//create recurring invoice with start date = trial_duration + 1 day
|
|
$recurring_invoice_repo = new RecurringInvoiceRepository();
|
|
|
|
$recurring_invoice = $this->convertInvoiceToRecurring($client_contact->client_id);
|
|
$recurring_invoice->next_send_date = now()->addSeconds($this->subscription->trial_duration);
|
|
$recurring_invoice->backup = 'is_trial';
|
|
|
|
if(array_key_exists('coupon', $data) && ($data['coupon'] == $this->subscription->promo_code) && $this->subscription->promo_discount > 0)
|
|
{
|
|
$recurring_invoice->discount = $this->subscription->promo_discount;
|
|
$recurring_invoice->is_amount_discount = $this->subscription->is_amount_discount;
|
|
}
|
|
|
|
$recurring_invoice = $recurring_invoice_repo->save($data, $recurring_invoice);
|
|
|
|
/* Start the recurring service */
|
|
$recurring_invoice->service()
|
|
->start()
|
|
->save();
|
|
|
|
//execute any webhooks
|
|
$this->triggerWebhook();
|
|
|
|
if(array_key_exists('post_purchase_url', $this->subscription->webhook_configuration) && strlen($this->subscription->webhook_configuration['post_purchase_url']) >=1)
|
|
return redirect($this->subscription->webhook_configuration['post_purchase_url']);
|
|
|
|
return redirect('/client/recurring_invoices/'.$recurring_invoice->hashed_id);
|
|
}
|
|
|
|
|
|
public function createInvoice($data): ?\App\Models\Invoice
|
|
{
|
|
|
|
$invoice_repo = new InvoiceRepository();
|
|
$subscription_repo = new SubscriptionRepository();
|
|
|
|
$invoice = InvoiceFactory::create($this->subscription->company_id, $this->subscription->user_id);
|
|
$invoice->line_items = $subscription_repo->generateLineItems($this->subscription);
|
|
$invoice->subscription_id = $this->subscription->id;
|
|
|
|
if(strlen($data['coupon']) >=1 && ($data['coupon'] == $this->subscription->promo_code) && $this->subscription->promo_discount > 0)
|
|
{
|
|
$invoice->discount = $this->subscription->promo_discount;
|
|
$invoice->is_amount_discount = $this->subscription->is_amount_discount;
|
|
}
|
|
|
|
return $invoice_repo->save($data, $invoice);
|
|
|
|
}
|
|
|
|
|
|
private function convertInvoiceToRecurring($client_id)
|
|
{
|
|
|
|
$subscription_repo = new SubscriptionRepository();
|
|
|
|
$recurring_invoice = RecurringInvoiceFactory::create($this->subscription->company_id, $this->subscription->user_id);
|
|
$recurring_invoice->client_id = $client_id;
|
|
$recurring_invoice->line_items = $subscription_repo->generateLineItems($this->subscription, true);
|
|
$recurring_invoice->subscription_id = $this->subscription->id;
|
|
$recurring_invoice->frequency_id = $this->subscription->frequency_id ?: RecurringInvoice::FREQUENCY_MONTHLY;
|
|
$recurring_invoice->date = now();
|
|
$recurring_invoice->remaining_cycles = -1;
|
|
|
|
return $recurring_invoice;
|
|
}
|
|
|
|
// @deprecated due to change in architecture
|
|
|
|
// public function createClientSubscription($payment_hash)
|
|
// {
|
|
|
|
// //is this a recurring or one off subscription.
|
|
|
|
// $cs = new ClientSubscription();
|
|
// $cs->subscription_id = $this->subscription->id;
|
|
// $cs->company_id = $this->subscription->company_id;
|
|
|
|
// $cs->invoice_id = $payment_hash->billing_context->invoice_id;
|
|
// $cs->client_id = $payment_hash->billing_context->client_id;
|
|
// $cs->quantity = $payment_hash->billing_context->quantity;
|
|
|
|
// //if is_recurring
|
|
// //create recurring invoice from invoice
|
|
// if($this->subscription->is_recurring)
|
|
// {
|
|
// $recurring_invoice = $this->convertInvoiceToRecurring($payment_hash);
|
|
// $recurring_invoice->frequency_id = $this->subscription->frequency_id;
|
|
// $recurring_invoice->next_send_date = $recurring_invoice->nextDateByFrequency(now()->format('Y-m-d'));
|
|
// $recurring_invoice->save();
|
|
// $cs->recurring_invoice_id = $recurring_invoice->id;
|
|
|
|
// //?set the recurring invoice as active - set the date here also based on the frequency?
|
|
// $recurring_invoice->service()->start();
|
|
// }
|
|
|
|
|
|
// $cs->save();
|
|
|
|
// $this->client_subscription = $cs;
|
|
|
|
// }
|
|
|
|
//@todo - need refactor
|
|
public function triggerWebhook()
|
|
{
|
|
//hit the webhook to after a successful onboarding
|
|
|
|
// $body = [
|
|
// 'subscription' => $this->subscription,
|
|
// 'client_subscription' => $this->client_subscription,
|
|
// 'client' => $this->client_subscription->client->toArray(),
|
|
// ];
|
|
|
|
|
|
// $client = new \GuzzleHttp\Client(['headers' => $this->subscription->webhook_configuration->post_purchase_headers]);
|
|
|
|
// $response = $client->{$this->subscription->webhook_configuration->post_purchase_rest_method}($this->subscription->post_purchase_url,[
|
|
// RequestOptions::JSON => ['body' => $body]
|
|
// ]);
|
|
|
|
// SystemLogger::dispatch(
|
|
// $body,
|
|
// SystemLog::CATEGORY_WEBHOOK,
|
|
// SystemLog::EVENT_WEBHOOK_RESPONSE,
|
|
// SystemLog::TYPE_WEBHOOK_RESPONSE,
|
|
// $this->client_subscription->client,
|
|
// );
|
|
|
|
}
|
|
|
|
public function fireNotifications()
|
|
{
|
|
//scan for any notification we are required to send
|
|
}
|
|
|
|
public function products()
|
|
{
|
|
return Product::whereIn('id', $this->transformKeys(explode(",", $this->subscription->product_ids)))->get();
|
|
}
|
|
|
|
public function recurring_products()
|
|
{
|
|
return Product::whereIn('id', $this->transformKeys(explode(",", $this->subscription->recurring_product_ids)))->get();
|
|
}
|
|
}
|