Cutlery/invoiceninja
1
0
Fork 0
mirror of https://github.com/invoiceninja/invoiceninja.git synced 2025-11-04 00:17:34 -05:00
Code Issues Packages Projects Releases Wiki Activity

Send mails after company import

Browse Source
This commit is contained in:
David Bomba 2021-06-29 10:04:09 +10:00
parent 80141b9ae9
commit 63a3e94308
1 changed files with 31 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
app/Jobs/Company/CompanyImport.php
View File

@ -20,6 +20,7 @@ use App\Libraries\MultiDB;
use App\Mail\DownloadBackup; use App\Mail\DownloadBackup;
use App\Mail\DownloadInvoices; use App\Mail\DownloadInvoices;
use App\Mail\Import\CompanyImportFailure; use App\Mail\Import\CompanyImportFailure;
use App\Mail\Import\ImportCompleted;
use App\Models\Activity; use App\Models\Activity;
use App\Models\Backup; use App\Models\Backup;
use App\Models\Client; use App\Models\Client;
@ -193,6 +194,17 @@ class CompanyImport implements ShouldQueue
->purgeCompanyData() ->purgeCompanyData()
->importData(); ->importData();
$data = [
'errors' => []
];
$nmo = new NinjaMailerObject;
$nmo->mailable = new ImportCompleted($this->company, $data);
$nmo->company = $this->company;
$nmo->settings = $this->company->settings;
$nmo->to_user = $this->company->owner();
NinjaMailerJob::dispatchNow($nmo);
} }
catch(\Exception $e){ catch(\Exception $e){
@ -324,14 +336,9 @@ class CompanyImport implements ShouldQueue
if($this->pre_flight_checks_pass === false) if($this->pre_flight_checks_pass === false)
{ {
$nmo = new NinjaMailerObject;
$nmo->mailable = new CompanyImportFailure($this->company, $this->message);
$nmo->company = $this->company;
$nmo->settings = $this->company->settings;
$nmo->to_user = $this->company->owner();
NinjaMailerJob::dispatchNow($nmo);
nlog($this->message); $this->sendImportMail($this->message);
throw new \Exception($this->message); throw new \Exception($this->message);
} }
@ -393,7 +400,7 @@ class CompanyImport implements ShouldQueue
} }
nlog("finished importing company data"); nlog("finished importing company data");
return $this; return $this;
@ -1271,6 +1278,8 @@ class CompanyImport implements ShouldQueue
if (! array_key_exists($resource, $this->ids)) { if (! array_key_exists($resource, $this->ids)) {
// nlog($this->ids); // nlog($this->ids);
$this->sendImportMail("The Import failed due to missing data in the import file. Resource {$resource} not available.");
throw new \Exception("Resource {$resource} not available."); throw new \Exception("Resource {$resource} not available.");
} }
@ -1283,6 +1292,8 @@ class CompanyImport implements ShouldQueue
if($resource == 'users') if($resource == 'users')
return $this->company_owner->id; return $this->company_owner->id;
$this->sendImportMail("The Import failed due to missing data in the import file. Resource {$resource} not available.");
throw new \Exception("Missing {$resource} key: {$old}"); throw new \Exception("Missing {$resource} key: {$old}");
} }
@ -1290,4 +1301,15 @@ class CompanyImport implements ShouldQueue
} }
private function sendImportMail($message){
$nmo = new NinjaMailerObject;
$nmo->mailable = new CompanyImportFailure($this->company, $message);
$nmo->company = $this->company;
$nmo->settings = $this->company->settings;
$nmo->to_user = $this->company->owner();
NinjaMailerJob::dispatchNow($nmo);
}
} }