Refactor alternateSave() in BaseRepo

This commit is contained in:
David Bomba 2021-01-15 11:59:23 +11:00
parent 6857393ff6
commit 12c4cdb4ed

View File

@ -130,13 +130,12 @@ class BaseRepository
return count($entities); return count($entities);
} }
/* Returns an invoice if defined as a key in the $resource array*/
public function getInvitation($invitation, $resource) public function getInvitation($invitation, $resource)
{ {
if (is_array($invitation) && ! array_key_exists('key', $invitation)) { if (is_array($invitation) && ! array_key_exists('key', $invitation))
return false; return false;
}
$invitation_class = sprintf('App\\Models\\%sInvitation', $resource); $invitation_class = sprintf('App\\Models\\%sInvitation', $resource);
$invitation = $invitation_class::whereRaw('BINARY `key`= ?', [$invitation['key']])->first(); $invitation = $invitation_class::whereRaw('BINARY `key`= ?', [$invitation['key']])->first();
@ -144,8 +143,24 @@ class BaseRepository
return $invitation; return $invitation;
} }
/* Clean return of a key rather than butchering the model*/
private function resolveEntityKey($model)
{
switch ($model) {
case ($model instanceof RecurringInvoice):
return 'recurring_invoice_id';
case ($model instanceof Invoice):
return 'invoice_id';
case ($model instanceof Quote):
return 'quote_id';
case ($model instanceof Credit):
return 'credit_id';
}
}
/** /**
* Alternative save used for Invoices, Quotes & Credits. * Alternative save used for Invoices, Recurring Invoices, Quotes & Credits.
*
* @param $data * @param $data
* @param $model * @param $model
* @return mixed * @return mixed
@ -153,20 +168,17 @@ class BaseRepository
*/ */
protected function alternativeSave($data, $model) protected function alternativeSave($data, $model)
{ {
$class = new ReflectionClass($model);
if (array_key_exists('client_id', $data)) { if (array_key_exists('client_id', $data)) //forces the client_id if it doesn't exist
$client = Client::where('id', $data['client_id'])->withTrashed()->first(); $model->client_id = $data['client_id'];
} else {
$client = Client::where('id', $model->client_id)->withTrashed()->first(); $client = Client::where('id', $model->client_id)->withTrashed()->first();
}
$state = []; $state = [];
$resource = explode('\\', $class->name)[2]; /** This will extract 'Invoice' from App\Models\Invoice */
$lcfirst_resource_id = lcfirst($resource).'_id'; //doesn't work for recurring.
if($class->name == RecurringInvoice::class) $resource = class_basename($model); //ie Invoice
$lcfirst_resource_id = 'recurring_invoice_id';
$lcfirst_resource_id = $this->resolveEntityKey($model); //ie invoice_id
$state['starting_amount'] = $model->amount; $state['starting_amount'] = $model->amount;
@ -176,26 +188,24 @@ class BaseRepository
$data = array_merge($company_defaults, $data); $data = array_merge($company_defaults, $data);
} }
$tmp_data = $data; $tmp_data = $data; //preserves the $data arrayss
/* We need to unset some variable as we sometimes unguard the model */ /* We need to unset some variable as we sometimes unguard the model */
if (isset($tmp_data['invitations'])) { if (isset($tmp_data['invitations']))
unset($tmp_data['invitations']); unset($tmp_data['invitations']);
}
if (isset($tmp_data['client_contacts']))
if (isset($tmp_data['client_contacts'])) {
unset($tmp_data['client_contacts']); unset($tmp_data['client_contacts']);
}
$model->fill($tmp_data); $model->fill($tmp_data);
$model->save(); $model->save();
if (array_key_exists('documents', $data)) { /* Model now persisted, now lets do some child tasks */
if (array_key_exists('documents', $data))
$this->saveDocuments($data['documents'], $model); $this->saveDocuments($data['documents'], $model);
}
$invitation_factory_class = sprintf('App\\Factory\\%sInvitationFactory', $resource);
/* Marks whether the client contact should receive emails based on the send_email property */
if (isset($data['client_contacts'])) { if (isset($data['client_contacts'])) {
foreach ($data['client_contacts'] as $contact) { foreach ($data['client_contacts'] as $contact) {
if ($contact['send_email'] == 1 && is_string($contact['id'])) { if ($contact['send_email'] == 1 && is_string($contact['id'])) {
@ -206,6 +216,7 @@ class BaseRepository
} }
} }
/* If invitations are present we need to filter existing invitations with the new ones */
if (isset($data['invitations'])) { if (isset($data['invitations'])) {
$invitations = collect($data['invitations']); $invitations = collect($data['invitations']);
@ -214,23 +225,24 @@ class BaseRepository
$invitation_class = sprintf('App\\Models\\%sInvitation', $resource); $invitation_class = sprintf('App\\Models\\%sInvitation', $resource);
$invitation = $invitation_class::whereRaw('BINARY `key`= ?', [$invitation])->first(); $invitation = $invitation_class::whereRaw('BINARY `key`= ?', [$invitation])->first();
if ($invitation) { if ($invitation)
$invitation->delete(); $invitation->delete();
}
}); });
foreach ($data['invitations'] as $invitation) { foreach ($data['invitations'] as $invitation) {
//if no invitations are present - create one. //if no invitations are present - create one.
if (! $this->getInvitation($invitation, $resource)) { if (! $this->getInvitation($invitation, $resource)) {
if (isset($invitation['id'])) {
if (isset($invitation['id']))
unset($invitation['id']); unset($invitation['id']);
}
//make sure we are creating an invite for a contact who belongs to the client only! //make sure we are creating an invite for a contact who belongs to the client only!
$contact = ClientContact::find($invitation['client_contact_id']); $contact = ClientContact::find($invitation['client_contact_id']);
if ($contact && $model->client_id == $contact->client_id) { if ($contact && $model->client_id == $contact->client_id) {
$invitation_class = sprintf('App\\Models\\%sInvitation', $resource); $invitation_class = sprintf('App\\Models\\%sInvitation', $resource);
$new_invitation = $invitation_class::withTrashed() $new_invitation = $invitation_class::withTrashed()
@ -239,12 +251,17 @@ class BaseRepository
->first(); ->first();
if ($new_invitation && $new_invitation->trashed()) { if ($new_invitation && $new_invitation->trashed()) {
$new_invitation->restore(); $new_invitation->restore();
} else { } else {
$invitation_factory_class = sprintf('App\\Factory\\%sInvitationFactory', $resource);
$new_invitation = $invitation_factory_class::create($model->company_id, $model->user_id); $new_invitation = $invitation_factory_class::create($model->company_id, $model->user_id);
$new_invitation->{$lcfirst_resource_id} = $model->id; $new_invitation->{$lcfirst_resource_id} = $model->id;
$new_invitation->client_contact_id = $contact->id; $new_invitation->client_contact_id = $contact->id;
$new_invitation->save(); $new_invitation->save();
} }
} }
} }
@ -254,50 +271,61 @@ class BaseRepository
$model->load('invitations'); $model->load('invitations');
/* If no invitations have been created, this is our fail safe to maintain state*/ /* If no invitations have been created, this is our fail safe to maintain state*/
if ($model->invitations->count() == 0) { if ($model->invitations->count() == 0)
$model->service()->createInvitations(); $model->service()->createInvitations();
}
/* Recalculate invoice amounts */
$model = $model->calc()->getInvoice(); $model = $model->calc()->getInvoice();
/* We use this to compare to our starting amount */
$state['finished_amount'] = $model->amount; $state['finished_amount'] = $model->amount;
/* Apply entity number */
$model = $model->service()->applyNumber()->save(); $model = $model->service()->applyNumber()->save();
if ($model->company->update_products !== false) { /* Update product details if necessary */
if ($model->company->update_products !== false)
UpdateOrCreateProduct::dispatch($model->line_items, $model, $model->company); UpdateOrCreateProduct::dispatch($model->line_items, $model, $model->company);
}
if ($class->name == Invoice::class) { /* Perform model specific tasks */
if ($model instanceof Invoice) {
if (($state['finished_amount'] != $state['starting_amount']) && ($model->status_id != Invoice::STATUS_DRAFT)) { if (($state['finished_amount'] != $state['starting_amount']) && ($model->status_id != Invoice::STATUS_DRAFT)) {
$model->ledger()->updateInvoiceBalance(($state['finished_amount'] - $state['starting_amount'])); $model->ledger()->updateInvoiceBalance(($state['finished_amount'] - $state['starting_amount']));
$model->client->service()->updateBalance(($state['finished_amount'] - $state['starting_amount']))->save(); $model->client->service()->updateBalance(($state['finished_amount'] - $state['starting_amount']))->save();
} }
if (! $model->design_id) { if (! $model->design_id)
$model->design_id = $this->decodePrimaryKey($client->getSetting('invoice_design_id')); $model->design_id = $this->decodePrimaryKey($client->getSetting('invoice_design_id'));
}
//links tasks and expenses back to the invoice. //links tasks and expenses back to the invoice.
$model->service()->linkEntities()->save(); $model->service()->linkEntities()->save();
} }
if ($class->name == Credit::class) { if ($model instanceof Credit) {
$model = $model->calc()->getCredit(); $model = $model->calc()->getCredit();
$model->ledger()->updateCreditBalance(($state['finished_amount'] - $state['starting_amount'])); $model->ledger()->updateCreditBalance(($state['finished_amount'] - $state['starting_amount']));
if (! $model->design_id) { if (! $model->design_id)
$model->design_id = $this->decodePrimaryKey($client->getSetting('credit_design_id')); $model->design_id = $this->decodePrimaryKey($client->getSetting('credit_design_id'));
}
} }
if ($class->name == Quote::class) { if ($model instanceof Quote) {
$model = $model->calc()->getQuote(); $model = $model->calc()->getQuote();
} }
if($class->name == RecurringInvoice::class) { if ($model instanceof RecurringInvoice) {
$model = $model->calc()->getRecurringInvoice(); $model = $model->calc()->getRecurringInvoice();
} }
$model->save(); $model->save();