diff --git a/app/Console/Commands/DesignUpdate.php b/app/Console/Commands/DesignUpdate.php index 4a93cb51d03d..317e2e4d8729 100644 --- a/app/Console/Commands/DesignUpdate.php +++ b/app/Console/Commands/DesignUpdate.php @@ -11,6 +11,7 @@ namespace App\Console\Commands; +use App\Libraries\MultiDB; use App\Models\Design; use Illuminate\Console\Command; use stdClass; @@ -47,6 +48,23 @@ class DesignUpdate extends Command * @return mixed */ public function handle() + { + + + if (! config('ninja.db.multi_db_enabled')) { + $this->processReminders(); + } else { + //multiDB environment, need to + foreach (MultiDB::$dbs as $db) { + MultiDB::setDB($db); + + $this->processReminders($db); + } + } + + } + + private function handleOnDb() { foreach (Design::whereIsCustom(false)->get() as $design) { $invoice_design = new \App\Services\PdfMaker\Design(strtolower($design->name)); diff --git a/app/Console/Commands/SendRemindersCron.php b/app/Console/Commands/SendRemindersCron.php index 65271cbf1f8c..a41a7e9b25f1 100644 --- a/app/Console/Commands/SendRemindersCron.php +++ b/app/Console/Commands/SendRemindersCron.php @@ -13,6 +13,7 @@ namespace App\Console\Commands; use App\Jobs\Ninja\SendReminders; use App\Jobs\Util\WebHookHandler; +use App\Libraries\MultiDB; use App\Models\Invoice; use App\Models\Quote; use App\Models\Webhook; @@ -58,6 +59,24 @@ class SendRemindersCron extends Command } private function webHookOverdueInvoices() + { + + + if (! config('ninja.db.multi_db_enabled')) { + $this->executeWebhooks(); + } else { + //multiDB environment, need to + foreach (MultiDB::$dbs as $db) { + MultiDB::setDB($db); + + $this->executeWebhooks(); + } + } + + } + + + private function executeWebhooks() { $invoices = Invoice::where('is_deleted', 0) ->whereIn('status_id', [Invoice::STATUS_SENT, Invoice::STATUS_PARTIAL]) @@ -68,10 +87,7 @@ class SendRemindersCron extends Command $invoices->each(function ($invoice) { WebHookHandler::dispatch(Webhook::EVENT_LATE_INVOICE, $invoice, $invoice->company); }); - } - private function webHookExpiredQuotes() - { $quotes = Quote::where('is_deleted', 0) ->where('status_id', Quote::STATUS_SENT) ->whereDate('due_date', '<=', now()->subDays(1)->startOfDay()) @@ -81,4 +97,6 @@ class SendRemindersCron extends Command WebHookHandler::dispatch(Webhook::EVENT_EXPIRED_QUOTE, $quote, $quote->company); }); } + + }