mirror of
https://github.com/invoiceninja/invoiceninja.git
synced 2025-06-03 08:14:35 -04:00
Improve bulk email performance
This commit is contained in:
parent
7e85c19705
commit
bdf95fcf70
@ -27,6 +27,7 @@ use App\Http\Requests\Invoice\StoreInvoiceRequest;
|
|||||||
use App\Http\Requests\Invoice\UpdateInvoiceRequest;
|
use App\Http\Requests\Invoice\UpdateInvoiceRequest;
|
||||||
use App\Http\Requests\Invoice\UploadInvoiceRequest;
|
use App\Http\Requests\Invoice\UploadInvoiceRequest;
|
||||||
use App\Jobs\Entity\EmailEntity;
|
use App\Jobs\Entity\EmailEntity;
|
||||||
|
use App\Jobs\Invoice\BulkInvoiceJob;
|
||||||
use App\Jobs\Invoice\StoreInvoice;
|
use App\Jobs\Invoice\StoreInvoice;
|
||||||
use App\Jobs\Invoice\ZipInvoices;
|
use App\Jobs\Invoice\ZipInvoices;
|
||||||
use App\Jobs\Ninja\TransactionLog;
|
use App\Jobs\Ninja\TransactionLog;
|
||||||
@ -747,23 +748,14 @@ class InvoiceController extends BaseController
|
|||||||
case 'email':
|
case 'email':
|
||||||
//check query parameter for email_type and set the template else use calculateTemplate
|
//check query parameter for email_type and set the template else use calculateTemplate
|
||||||
|
|
||||||
|
|
||||||
if (request()->has('email_type') && property_exists($invoice->company->settings, request()->input('email_type'))) {
|
if (request()->has('email_type') && property_exists($invoice->company->settings, request()->input('email_type'))) {
|
||||||
$this->reminder_template = $invoice->client->getSetting(request()->input('email_type'));
|
$this->reminder_template = $invoice->client->getSetting(request()->input('email_type'));
|
||||||
} else {
|
} else {
|
||||||
$this->reminder_template = $invoice->calculateTemplate('invoice');
|
$this->reminder_template = $invoice->calculateTemplate('invoice');
|
||||||
}
|
}
|
||||||
|
|
||||||
//touch reminder1,2,3_sent + last_sent here if the email is a reminder.
|
BulkInvoiceJob::dispatch($invoice, $this->reminder_template);
|
||||||
//$invoice->service()->touchReminder($this->reminder_template)->deletePdf()->save();
|
|
||||||
$invoice->service()->touchReminder($this->reminder_template)->markSent()->save();
|
|
||||||
|
|
||||||
$invoice->invitations->load('contact.client.country', 'invoice.client.country', 'invoice.company')->each(function ($invitation) use ($invoice) {
|
|
||||||
EmailEntity::dispatch($invitation, $invoice->company, $this->reminder_template)->delay(now()->addSeconds(30));
|
|
||||||
});
|
|
||||||
|
|
||||||
if ($invoice->invitations->count() >= 1) {
|
|
||||||
$invoice->entityEmailEvent($invoice->invitations->first(), 'invoice', $this->reminder_template);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (! $bulk) {
|
if (! $bulk) {
|
||||||
return response()->json(['message' => 'email sent'], 200);
|
return response()->json(['message' => 'email sent'], 200);
|
||||||
|
71
app/Jobs/Invoice/BulkInvoiceJob.php
Normal file
71
app/Jobs/Invoice/BulkInvoiceJob.php
Normal file
@ -0,0 +1,71 @@
|
|||||||
|
<?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://www.elastic.co/licensing/elastic-license
|
||||||
|
*/
|
||||||
|
|
||||||
|
namespace App\Jobs\Invoice;
|
||||||
|
|
||||||
|
use App\Jobs\Entity\EmailEntity;
|
||||||
|
use App\Models\Invoice;
|
||||||
|
use CleverIt\UBL\Invoice\Address;
|
||||||
|
use CleverIt\UBL\Invoice\Contact;
|
||||||
|
use CleverIt\UBL\Invoice\Country;
|
||||||
|
use CleverIt\UBL\Invoice\Generator;
|
||||||
|
use CleverIt\UBL\Invoice\Invoice as UBLInvoice;
|
||||||
|
use CleverIt\UBL\Invoice\InvoiceLine;
|
||||||
|
use CleverIt\UBL\Invoice\Item;
|
||||||
|
use CleverIt\UBL\Invoice\LegalMonetaryTotal;
|
||||||
|
use CleverIt\UBL\Invoice\Party;
|
||||||
|
use CleverIt\UBL\Invoice\TaxCategory;
|
||||||
|
use CleverIt\UBL\Invoice\TaxScheme;
|
||||||
|
use CleverIt\UBL\Invoice\TaxSubTotal;
|
||||||
|
use CleverIt\UBL\Invoice\TaxTotal;
|
||||||
|
use Exception;
|
||||||
|
use Illuminate\Bus\Queueable;
|
||||||
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
||||||
|
use Illuminate\Foundation\Bus\Dispatchable;
|
||||||
|
use Illuminate\Queue\InteractsWithQueue;
|
||||||
|
use Illuminate\Queue\SerializesModels;
|
||||||
|
|
||||||
|
class BulkInvoiceJob implements ShouldQueue
|
||||||
|
{
|
||||||
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
||||||
|
|
||||||
|
public $invoice;
|
||||||
|
|
||||||
|
public $reminder_template;
|
||||||
|
|
||||||
|
public function __construct(Invoice $invoice, string $reminder_template)
|
||||||
|
{
|
||||||
|
$this->invoice = $invoice;
|
||||||
|
$this->reminder_template = $reminder_template;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Execute the job.
|
||||||
|
*
|
||||||
|
*
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
public function handle()
|
||||||
|
{
|
||||||
|
|
||||||
|
$this->invoice->service()->touchReminder($this->reminder_template)->markSent()->save();
|
||||||
|
|
||||||
|
$this->invoice->invitations->load('contact.client.country', 'invoice.client.country', 'invoice.company')->each(function ($invitation) {
|
||||||
|
EmailEntity::dispatch($invitation, $this->invoice->company, $this->reminder_template)->delay(now()->addSeconds(5));
|
||||||
|
});
|
||||||
|
|
||||||
|
if ($this->invoice->invitations->count() >= 1) {
|
||||||
|
$this->invoice->entityEmailEvent($this->invoice->invitations->first(), 'invoice', $this->reminder_template);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
@ -238,6 +238,7 @@ class GoCardlessPaymentDriver extends BaseDriver
|
|||||||
if(!is_array($request->events) || !is_object($request->events)){
|
if(!is_array($request->events) || !is_object($request->events)){
|
||||||
|
|
||||||
nlog("No GoCardless events to process in response?");
|
nlog("No GoCardless events to process in response?");
|
||||||
|
nlog($request);
|
||||||
return response()->json([], 200);
|
return response()->json([], 200);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user