1
0
mirror of https://github.com/invoiceninja/invoiceninja.git synced 2024-11-13 22:54:25 +01:00
invoiceninja/app/Ninja/Repositories/InvoiceRepository.php
2019-01-30 22:25:37 +11:00

1390 lines
56 KiB
PHP

<?php
namespace App\Ninja\Repositories;
use App\Events\QuoteItemsWereCreated;
use App\Events\QuoteItemsWereUpdated;
use App\Events\InvoiceItemsWereCreated;
use App\Events\InvoiceItemsWereUpdated;
use App\Jobs\SendInvoiceEmail;
use App\Models\Account;
use App\Models\Client;
use App\Models\Document;
use App\Models\Expense;
use App\Models\Invitation;
use App\Models\Invoice;
use App\Models\InvoiceItem;
use App\Models\Product;
use App\Models\Task;
use App\Models\GatewayType;
use App\Services\PaymentService;
use Auth;
use DB;
use Utils;
class InvoiceRepository extends BaseRepository
{
protected $documentRepo;
public function getClassName()
{
return 'App\Models\Invoice';
}
public function __construct(PaymentService $paymentService, DocumentRepository $documentRepo, PaymentRepository $paymentRepo)
{
$this->documentRepo = $documentRepo;
$this->paymentService = $paymentService;
$this->paymentRepo = $paymentRepo;
}
public function all()
{
return Invoice::scope()
->invoiceType(INVOICE_TYPE_STANDARD)
->with('user', 'client.contacts', 'invoice_status')
->withTrashed()
->where('is_recurring', '=', false)
->get();
}
public function getInvoices($accountId, $clientPublicId = false, $entityType = ENTITY_INVOICE, $filter = false)
{
$query = DB::table('invoices')
->join('accounts', 'accounts.id', '=', 'invoices.account_id')
->join('clients', 'clients.id', '=', 'invoices.client_id')
->join('invoice_statuses', 'invoice_statuses.id', '=', 'invoices.invoice_status_id')
->join('contacts', 'contacts.client_id', '=', 'clients.id')
->where('invoices.account_id', '=', $accountId)
->where('contacts.deleted_at', '=', null)
->where('invoices.is_recurring', '=', false)
->where('contacts.is_primary', '=', true)
//->whereRaw('(clients.name != "" or contacts.first_name != "" or contacts.last_name != "" or contacts.email != "")') // filter out buy now invoices
->select(
DB::raw('COALESCE(clients.currency_id, accounts.currency_id) currency_id'),
DB::raw('COALESCE(clients.country_id, accounts.country_id) country_id'),
'clients.public_id as client_public_id',
'clients.user_id as client_user_id',
'invoice_number',
'invoice_number as quote_number',
'invoice_status_id',
DB::raw("COALESCE(NULLIF(clients.name,''), NULLIF(CONCAT(contacts.first_name, ' ', contacts.last_name),''), NULLIF(contacts.email,'')) client_name"),
'invoices.public_id',
'invoices.amount',
'invoices.balance',
'invoices.invoice_date',
'invoices.due_date as due_date_sql',
'invoices.partial_due_date',
DB::raw("CONCAT(invoices.invoice_date, invoices.created_at) as date"),
DB::raw("CONCAT(COALESCE(invoices.partial_due_date, invoices.due_date), invoices.created_at) as due_date"),
DB::raw("CONCAT(COALESCE(invoices.partial_due_date, invoices.due_date), invoices.created_at) as valid_until"),
'invoice_statuses.name as status',
'invoice_statuses.name as invoice_status_name',
'contacts.first_name',
'contacts.last_name',
'contacts.email',
'invoices.quote_id',
'invoices.quote_invoice_id',
'invoices.deleted_at',
'invoices.is_deleted',
'invoices.partial',
'invoices.user_id',
'invoices.is_public',
'invoices.is_recurring',
'invoices.private_notes'
);
$this->applyFilters($query, $entityType, ENTITY_INVOICE);
if ($statuses = session('entity_status_filter:' . $entityType)) {
$statuses = explode(',', $statuses);
$query->where(function ($query) use ($statuses) {
foreach ($statuses as $status) {
if (in_array($status, \App\Models\EntityModel::$statuses)) {
continue;
}
$query->orWhere('invoice_status_id', '=', $status);
}
if (in_array(INVOICE_STATUS_UNPAID, $statuses)) {
$query->orWhere(function ($query) use ($statuses) {
$query->where('invoices.balance', '>', 0)
->where('invoices.is_public', '=', true);
});
}
if (in_array(INVOICE_STATUS_OVERDUE, $statuses)) {
$query->orWhere(function ($query) use ($statuses) {
$query->where('invoices.balance', '>', 0)
->where('invoices.due_date', '<', date('Y-m-d'))
->where('invoices.is_public', '=', true);
});
}
});
}
if ($clientPublicId) {
$query->where('clients.public_id', '=', $clientPublicId);
} else {
$query->whereNull('clients.deleted_at');
}
if ($filter) {
$query->where(function ($query) use ($filter) {
$query->where('clients.name', 'like', '%'.$filter.'%')
->orWhere('invoices.invoice_number', 'like', '%'.$filter.'%')
->orWhere('contacts.first_name', 'like', '%'.$filter.'%')
->orWhere('contacts.last_name', 'like', '%'.$filter.'%')
->orWhere('contacts.email', 'like', '%'.$filter.'%');
});
}
return $query;
}
public function getRecurringInvoices($accountId, $clientPublicId = false, $filter = false)
{
$query = DB::table('invoices')
->join('accounts', 'accounts.id', '=', 'invoices.account_id')
->join('clients', 'clients.id', '=', 'invoices.client_id')
->join('invoice_statuses', 'invoice_statuses.id', '=', 'invoices.invoice_status_id')
->leftJoin('frequencies', 'frequencies.id', '=', 'invoices.frequency_id')
->join('contacts', 'contacts.client_id', '=', 'clients.id')
->where('invoices.account_id', '=', $accountId)
->where('invoices.invoice_type_id', '=', INVOICE_TYPE_STANDARD)
->where('contacts.deleted_at', '=', null)
->where('invoices.is_recurring', '=', true)
->where('contacts.is_primary', '=', true)
->select(
DB::raw('COALESCE(clients.currency_id, accounts.currency_id) currency_id'),
DB::raw('COALESCE(clients.country_id, accounts.country_id) country_id'),
'clients.public_id as client_public_id',
DB::raw("COALESCE(NULLIF(clients.name,''), NULLIF(CONCAT(contacts.first_name, ' ', contacts.last_name),''), NULLIF(contacts.email,'')) client_name"),
'invoices.public_id',
'invoices.amount',
'frequencies.name as frequency',
'invoices.start_date as start_date_sql',
'invoices.end_date as end_date_sql',
'invoices.last_sent_date as last_sent_date_sql',
DB::raw("CONCAT(invoices.start_date, invoices.created_at) as start_date"),
DB::raw("CONCAT(invoices.end_date, invoices.created_at) as end_date"),
DB::raw("CONCAT(invoices.last_sent_date, invoices.created_at) as last_sent"),
'contacts.first_name',
'contacts.last_name',
'contacts.email',
'invoices.deleted_at',
'invoices.is_deleted',
'invoices.user_id',
'invoice_statuses.name as invoice_status_name',
'invoice_statuses.name as status',
'invoices.invoice_status_id',
'invoices.balance',
'invoices.due_date',
'invoices.due_date as due_date_sql',
'invoices.is_recurring',
'invoices.quote_invoice_id',
'invoices.private_notes'
);
if ($clientPublicId) {
$query->where('clients.public_id', '=', $clientPublicId);
} else {
$query->whereNull('clients.deleted_at');
}
$this->applyFilters($query, ENTITY_RECURRING_INVOICE, ENTITY_INVOICE);
if ($filter) {
$query->where(function ($query) use ($filter) {
$query->where('clients.name', 'like', '%'.$filter.'%')
->orWhere('invoices.invoice_number', 'like', '%'.$filter.'%')
->orWhere('contacts.first_name', 'like', '%'.$filter.'%')
->orWhere('contacts.last_name', 'like', '%'.$filter.'%')
->orWhere('contacts.email', 'like', '%'.$filter.'%');
});
}
return $query;
}
public function getClientRecurringDatatable($contactId)
{
$query = DB::table('invitations')
->join('accounts', 'accounts.id', '=', 'invitations.account_id')
->join('invoices', 'invoices.id', '=', 'invitations.invoice_id')
->join('clients', 'clients.id', '=', 'invoices.client_id')
->join('frequencies', 'frequencies.id', '=', 'invoices.frequency_id')
->where('invitations.contact_id', '=', $contactId)
->where('invitations.deleted_at', '=', null)
->where('invoices.invoice_type_id', '=', INVOICE_TYPE_STANDARD)
->where('invoices.is_deleted', '=', false)
->where('clients.deleted_at', '=', null)
->where('invoices.is_recurring', '=', true)
->where('invoices.is_public', '=', true)
->where('invoices.deleted_at', '=', null)
//->where('invoices.start_date', '>=', date('Y-m-d H:i:s'))
->select(
DB::raw('COALESCE(clients.currency_id, accounts.currency_id) currency_id'),
DB::raw('COALESCE(clients.country_id, accounts.country_id) country_id'),
'invitations.invitation_key',
'invoices.invoice_number',
'invoices.due_date',
'clients.public_id as client_public_id',
'clients.name as client_name',
'invoices.public_id',
'invoices.amount',
'invoices.start_date',
'invoices.end_date',
'invoices.auto_bill',
'invoices.client_enable_auto_bill',
'frequencies.name as frequency'
);
$table = \Datatable::query($query)
->addColumn('frequency', function ($model) {
$frequency = strtolower($model->frequency);
$frequency = preg_replace('/\s/', '_', $frequency);
return trans('texts.freq_' . $frequency);
})
->addColumn('start_date', function ($model) {
return Utils::fromSqlDate($model->start_date);
})
->addColumn('end_date', function ($model) {
return Utils::fromSqlDate($model->end_date);
})
->addColumn('amount', function ($model) {
return Utils::formatMoney($model->amount, $model->currency_id, $model->country_id);
})
->addColumn('client_enable_auto_bill', function ($model) {
if ($model->auto_bill == AUTO_BILL_OFF) {
return trans('texts.disabled');
} elseif ($model->auto_bill == AUTO_BILL_ALWAYS) {
return trans('texts.enabled');
} elseif ($model->client_enable_auto_bill) {
return trans('texts.enabled') . ' - <a href="javascript:setAutoBill('.$model->public_id.',false)">'.trans('texts.disable').'</a>';
} else {
return trans('texts.disabled') . ' - <a href="javascript:setAutoBill('.$model->public_id.',true)">'.trans('texts.enable').'</a>';
}
});
return $table->make();
}
public function getClientDatatable($contactId, $entityType, $search)
{
$query = DB::table('invitations')
->join('accounts', 'accounts.id', '=', 'invitations.account_id')
->join('invoices', 'invoices.id', '=', 'invitations.invoice_id')
->join('clients', 'clients.id', '=', 'invoices.client_id')
->join('contacts', 'contacts.client_id', '=', 'clients.id')
->where('invitations.contact_id', '=', $contactId)
->where('invitations.deleted_at', '=', null)
->where('invoices.invoice_type_id', '=', $entityType == ENTITY_QUOTE ? INVOICE_TYPE_QUOTE : INVOICE_TYPE_STANDARD)
->where('invoices.is_deleted', '=', false)
->where('clients.deleted_at', '=', null)
->where('contacts.deleted_at', '=', null)
->where('contacts.is_primary', '=', true)
->where('invoices.is_recurring', '=', false)
->where('invoices.is_public', '=', true)
// Only show paid invoices for ninja accounts
->whereRaw(sprintf("((accounts.account_key != '%s' and accounts.account_key not like '%s%%') or invoices.invoice_status_id = %d)", env('NINJA_LICENSE_ACCOUNT_KEY'), substr(NINJA_ACCOUNT_KEY, 0, 30), INVOICE_STATUS_PAID))
->select(
DB::raw('COALESCE(clients.currency_id, accounts.currency_id) currency_id'),
DB::raw('COALESCE(clients.country_id, accounts.country_id) country_id'),
'invitations.invitation_key',
'invoices.invoice_number',
'invoices.invoice_date',
'invoices.balance as balance',
'invoices.due_date',
'invoices.invoice_status_id',
'invoices.due_date',
'invoices.quote_invoice_id',
'clients.public_id as client_public_id',
DB::raw("COALESCE(NULLIF(clients.name,''), NULLIF(CONCAT(contacts.first_name, ' ', contacts.last_name),''), NULLIF(contacts.email,'')) client_name"),
'invoices.public_id',
'invoices.amount',
'invoices.start_date',
'invoices.end_date',
'invoices.partial'
);
$table = \Datatable::query($query)
->addColumn('invoice_number', function ($model) use ($entityType) {
return link_to('/view/'.$model->invitation_key, $model->invoice_number)->toHtml();
})
->addColumn('invoice_date', function ($model) {
return Utils::fromSqlDate($model->invoice_date);
})
->addColumn('amount', function ($model) {
return Utils::formatMoney($model->amount, $model->currency_id, $model->country_id);
});
if ($entityType == ENTITY_INVOICE) {
$table->addColumn('balance', function ($model) {
return $model->partial > 0 ?
trans('texts.partial_remaining', [
'partial' => Utils::formatMoney($model->partial, $model->currency_id, $model->country_id),
'balance' => Utils::formatMoney($model->balance, $model->currency_id, $model->country_id),
]) :
Utils::formatMoney($model->balance, $model->currency_id, $model->country_id);
});
}
return $table->addColumn('due_date', function ($model) {
return Utils::fromSqlDate($model->due_date);
})
->addColumn('invoice_status_id', function ($model) use ($entityType) {
if ($model->invoice_status_id == INVOICE_STATUS_PAID) {
$label = trans('texts.status_paid');
$class = 'success';
} elseif ($model->invoice_status_id == INVOICE_STATUS_PARTIAL) {
$label = trans('texts.status_partial');
$class = 'info';
} elseif ($entityType == ENTITY_QUOTE && ($model->invoice_status_id >= INVOICE_STATUS_APPROVED || $model->quote_invoice_id)) {
$label = trans('texts.status_approved');
$class = 'success';
} elseif (Invoice::calcIsOverdue($model->balance, $model->due_date)) {
$class = 'danger';
if ($entityType == ENTITY_INVOICE) {
$label = trans('texts.past_due');
} else {
$label = trans('texts.expired');
}
} else {
$class = 'default';
if ($entityType == ENTITY_INVOICE) {
$label = trans('texts.unpaid');
} else {
$label = trans('texts.pending');
}
}
return "<h4><div class=\"label label-{$class}\">$label</div></h4>";
})
->make();
}
/**
* @param array $data
* @param Invoice|null $invoice
*
* @return Invoice|mixed
*/
public function save(array $data, Invoice $invoice = null)
{
/** @var Account $account */
$account = $invoice ? $invoice->account : \Auth::user()->account;
$publicId = isset($data['public_id']) ? $data['public_id'] : false;
if (Utils::isNinjaProd() && ! Utils::isReseller()) {
$copy = json_decode( json_encode($data), true);
$copy['data'] = false;
$logMessage = date('r') . ' account_id: ' . $account->id . ' ' . json_encode($copy) . "\n\n";
@file_put_contents(storage_path('logs/invoice-repo.log'), $logMessage, FILE_APPEND);
}
$isNew = ! $publicId || intval($publicId) < 0;
if ($invoice) {
// do nothing
$entityType = $invoice->getEntityType();
} elseif ($isNew) {
$entityType = ENTITY_INVOICE;
if (isset($data['is_recurring']) && filter_var($data['is_recurring'], FILTER_VALIDATE_BOOLEAN)) {
$entityType = ENTITY_RECURRING_INVOICE;
} elseif (isset($data['is_quote']) && filter_var($data['is_quote'], FILTER_VALIDATE_BOOLEAN)) {
$entityType = ENTITY_QUOTE;
}
$invoice = $account->createInvoice($entityType, $data['client_id']);
$invoice->invoice_date = date_create()->format('Y-m-d');
$invoice->custom_taxes1 = $account->custom_invoice_taxes1 ?: false;
$invoice->custom_taxes2 = $account->custom_invoice_taxes2 ?: false;
// set the default due date
if ($entityType == ENTITY_INVOICE && empty($data['partial_due_date'])) {
$client = Client::scope()->whereId($data['client_id'])->first();
$invoice->due_date = $account->defaultDueDate($client);
}
} else {
$invoice = Invoice::scope($publicId)->firstOrFail();
if (Utils::isNinjaDev()) {
\Log::warning('Entity not set in invoice repo save');
}
}
if ($invoice->is_deleted) {
return $invoice;
} elseif ($invoice->isLocked()) {
return $invoice;
}
if (isset($data['has_tasks']) && filter_var($data['has_tasks'], FILTER_VALIDATE_BOOLEAN)) {
$invoice->has_tasks = true;
}
if (isset($data['has_expenses']) && filter_var($data['has_expenses'], FILTER_VALIDATE_BOOLEAN)) {
$invoice->has_expenses = true;
}
if (isset($data['is_public']) && filter_var($data['is_public'], FILTER_VALIDATE_BOOLEAN)) {
$invoice->is_public = true;
if (! $invoice->isSent()) {
$invoice->invoice_status_id = INVOICE_STATUS_SENT;
}
}
if (isset($data['invoice_design_id']) && ! $data['invoice_design_id']) {
$data['invoice_design_id'] = 1;
}
$invoice->fill($data);
if ((isset($data['set_default_terms']) && $data['set_default_terms'])
|| (isset($data['set_default_footer']) && $data['set_default_footer'])) {
if (isset($data['set_default_terms']) && $data['set_default_terms']) {
$account->{"{$invoice->getEntityType()}_terms"} = trim($data['terms']);
}
if (isset($data['set_default_footer']) && $data['set_default_footer']) {
$account->invoice_footer = trim($data['invoice_footer']);
}
$account->save();
}
if (! empty($data['invoice_number']) && ! $invoice->is_recurring) {
$invoice->invoice_number = trim($data['invoice_number']);
}
if (isset($data['discount'])) {
$invoice->discount = round(Utils::parseFloat($data['discount']), 2);
}
if (isset($data['is_amount_discount'])) {
$invoice->is_amount_discount = $data['is_amount_discount'] ? true : false;
}
if (isset($data['invoice_date_sql'])) {
$invoice->invoice_date = $data['invoice_date_sql'];
} elseif (isset($data['invoice_date'])) {
$invoice->invoice_date = Utils::toSqlDate($data['invoice_date']);
}
/*
if (isset($data['invoice_status_id'])) {
if ($data['invoice_status_id'] == 0) {
$data['invoice_status_id'] = INVOICE_STATUS_DRAFT;
}
$invoice->invoice_status_id = $data['invoice_status_id'];
}
*/
if ($invoice->is_recurring) {
if (! $isNew && isset($data['start_date']) && $invoice->start_date && $invoice->start_date != Utils::toSqlDate($data['start_date'])) {
$invoice->last_sent_date = null;
}
$invoice->frequency_id = array_get($data, 'frequency_id', FREQUENCY_MONTHLY);
$invoice->start_date = Utils::toSqlDate(array_get($data, 'start_date'));
$invoice->end_date = Utils::toSqlDate(array_get($data, 'end_date'));
$invoice->client_enable_auto_bill = isset($data['client_enable_auto_bill']) && $data['client_enable_auto_bill'] ? true : false;
$invoice->auto_bill = array_get($data, 'auto_bill_id') ?: array_get($data, 'auto_bill', AUTO_BILL_OFF);
if ($invoice->auto_bill < AUTO_BILL_OFF || $invoice->auto_bill > AUTO_BILL_ALWAYS) {
$invoice->auto_bill = AUTO_BILL_OFF;
}
if (isset($data['recurring_due_date'])) {
$invoice->due_date = $data['recurring_due_date'];
} elseif (isset($data['due_date'])) {
$invoice->due_date = $data['due_date'];
}
} else {
if ($isNew && empty($data['due_date']) && empty($data['due_date_sql'])) {
// do nothing
} elseif (isset($data['due_date']) || isset($data['due_date_sql'])) {
$invoice->due_date = isset($data['due_date_sql']) ? $data['due_date_sql'] : Utils::toSqlDate($data['due_date']);
}
$invoice->frequency_id = 0;
$invoice->start_date = null;
$invoice->end_date = null;
}
if (isset($data['terms']) && trim($data['terms'])) {
$invoice->terms = trim($data['terms']);
} elseif ($isNew && ! $invoice->is_recurring && $account->{"{$entityType}_terms"}) {
$invoice->terms = $account->{"{$entityType}_terms"};
} else {
$invoice->terms = '';
}
if (isset($data['invoice_footer']) && trim($data['invoice_footer'])) {
$invoice->invoice_footer = trim($data['invoice_footer']);
} elseif ($isNew && ! $invoice->is_recurring && $account->invoice_footer) {
$invoice->invoice_footer = $account->invoice_footer;
} else {
$invoice->invoice_footer = '';
}
$invoice->public_notes = isset($data['public_notes']) ? trim($data['public_notes']) : '';
// process date variables if not recurring
if (! $invoice->is_recurring) {
$invoice->terms = Utils::processVariables($invoice->terms);
$invoice->invoice_footer = Utils::processVariables($invoice->invoice_footer);
$invoice->public_notes = Utils::processVariables($invoice->public_notes);
}
if (isset($data['po_number'])) {
$invoice->po_number = trim($data['po_number']);
}
// provide backwards compatibility
if (isset($data['tax_name']) && isset($data['tax_rate'])) {
$data['tax_name1'] = $data['tax_name'];
$data['tax_rate1'] = $data['tax_rate'];
}
$total = 0;
$itemTax = 0;
foreach ($data['invoice_items'] as $item) {
$item = (array) $item;
if (! $item['cost'] && ! $item['product_key'] && ! $item['notes']) {
continue;
}
$invoiceItemCost = Utils::roundSignificant(Utils::parseFloat($item['cost']));
$invoiceItemQty = Utils::roundSignificant(Utils::parseFloat($item['qty']));
$discount = empty($item['discount']) ? 0 : round(Utils::parseFloat($item['discount']), 2);
$lineTotal = $invoiceItemCost * $invoiceItemQty;
if ($discount) {
if ($invoice->is_amount_discount) {
$lineTotal -= $discount;
} else {
$lineTotal -= round($lineTotal * $discount / 100, 4);
}
}
$total += round($lineTotal, 2);
}
foreach ($data['invoice_items'] as $item) {
$item = (array) $item;
$invoiceItemCost = Utils::roundSignificant(Utils::parseFloat($item['cost']));
$invoiceItemQty = Utils::roundSignificant(Utils::parseFloat($item['qty']));
$discount = empty($item['discount']) ? 0 : round(Utils::parseFloat($item['discount']), 2);
$lineTotal = $invoiceItemCost * $invoiceItemQty;
if ($discount) {
if ($invoice->is_amount_discount) {
$lineTotal -= $discount;
} else {
$lineTotal -= round($lineTotal * $discount / 100, 4);
}
}
if ($invoice->discount > 0) {
if ($invoice->is_amount_discount) {
if ($total != 0) {
$lineTotal -= round(($lineTotal / $total) * $invoice->discount, 4);
}
} else {
$lineTotal -= round($lineTotal * ($invoice->discount / 100), 4);
}
}
if (isset($item['tax_rate1'])) {
$taxRate1 = Utils::parseFloat($item['tax_rate1']);
if ($taxRate1 != 0) {
$itemTax += round($lineTotal * $taxRate1 / 100, 2);
}
}
if (isset($item['tax_rate2'])) {
$taxRate2 = Utils::parseFloat($item['tax_rate2']);
if ($taxRate2 != 0) {
$itemTax += round($lineTotal * $taxRate2 / 100, 2);
}
}
}
if ($invoice->discount != 0) {
if ($invoice->is_amount_discount) {
$total -= $invoice->discount;
} else {
$discount = round($total * ($invoice->discount / 100), 2);
$total -= $discount;
}
}
if (isset($data['custom_value1'])) {
$invoice->custom_value1 = round($data['custom_value1'], 2);
}
if (isset($data['custom_value2'])) {
$invoice->custom_value2 = round($data['custom_value2'], 2);
}
if (isset($data['custom_text_value1'])) {
$invoice->custom_text_value1 = trim($data['custom_text_value1']);
}
if (isset($data['custom_text_value2'])) {
$invoice->custom_text_value2 = trim($data['custom_text_value2']);
}
// custom fields charged taxes
if ($invoice->custom_value1 && $invoice->custom_taxes1) {
$total += $invoice->custom_value1;
}
if ($invoice->custom_value2 && $invoice->custom_taxes2) {
$total += $invoice->custom_value2;
}
if (! $account->inclusive_taxes) {
$taxAmount1 = round($total * ($invoice->tax_rate1 ? $invoice->tax_rate1 : 0) / 100, 2);
$taxAmount2 = round($total * ($invoice->tax_rate2 ? $invoice->tax_rate2 : 0) / 100, 2);
$total = round($total + $taxAmount1 + $taxAmount2, 2);
$total += $itemTax;
}
// custom fields not charged taxes
if ($invoice->custom_value1 && ! $invoice->custom_taxes1) {
$total += $invoice->custom_value1;
}
if ($invoice->custom_value2 && ! $invoice->custom_taxes2) {
$total += $invoice->custom_value2;
}
if ($publicId) {
$invoice->balance = round($total - ($invoice->amount - $invoice->balance), 2);
} else {
$invoice->balance = $total;
}
if (isset($data['partial'])) {
$invoice->partial = max(0, min(round(Utils::parseFloat($data['partial']), 2), $invoice->balance));
}
if ($invoice->partial) {
if (isset($data['partial_due_date'])) {
$invoice->partial_due_date = Utils::toSqlDate($data['partial_due_date']);
}
} else {
$invoice->partial_due_date = null;
}
$invoice->amount = $total;
$invoice->save();
if ($publicId) {
$invoice->invoice_items()->forceDelete();
}
if (! empty($data['document_ids'])) {
$document_ids = array_map('intval', $data['document_ids']);
foreach ($document_ids as $document_id) {
$document = Document::scope($document_id)->first();
if ($document && Auth::user()->can('edit', $document)) {
if ($document->invoice_id && $document->invoice_id != $invoice->id) {
// From a clone
$document = $document->cloneDocument();
$document_ids[] = $document->public_id; // Don't remove this document
}
$document->invoice_id = $invoice->id;
$document->expense_id = null;
$document->save();
}
}
if (! $invoice->wasRecentlyCreated) {
foreach ($invoice->documents as $document) {
if (! in_array($document->public_id, $document_ids)) {
// Removed
// Not checking permissions; deleting a document is just editing the invoice
if ($document->invoice_id == $invoice->id) {
// Make sure the document isn't on a clone
$document->delete();
}
}
}
}
}
foreach ($data['invoice_items'] as $item) {
$item = (array) $item;
if (empty($item['cost']) && empty($item['product_key']) && empty($item['notes']) && empty($item['custom_value1']) && empty($item['custom_value2'])) {
continue;
}
$task = false;
if (isset($item['task_public_id']) && $item['task_public_id']) {
$task = Task::scope($item['task_public_id'])->where('invoice_id', '=', null)->firstOrFail();
if (Auth::user()->can('edit', $task)) {
$task->invoice_id = $invoice->id;
$task->client_id = $invoice->client_id;
$task->save();
}
}
$expense = false;
if (isset($item['expense_public_id']) && $item['expense_public_id']) {
$expense = Expense::scope($item['expense_public_id'])->where('invoice_id', '=', null)->firstOrFail();
if (Auth::user()->can('edit', $expense)) {
$expense->invoice_id = $invoice->id;
$expense->client_id = $invoice->client_id;
$expense->save();
}
}
if (Auth::check()) {
if ($productKey = trim($item['product_key'])) {
if ($account->update_products
&& ! $invoice->has_tasks
&& ! $invoice->has_expenses
&& ! in_array($productKey, Utils::trans(['surcharge', 'discount', 'fee', 'gateway_fee_item']))
) {
$product = Product::findProductByKey($productKey);
if (! $product) {
if (Auth::user()->can('create', ENTITY_PRODUCT)) {
$product = Product::createNew();
$product->product_key = trim($item['product_key']);
} else {
$product = null;
}
}
if ($product && (Auth::user()->can('edit', $product))) {
$product->notes = ($task || $expense) ? '' : $item['notes'];
if (! $account->convert_products) {
$product->cost = $expense ? 0 : Utils::parseFloat($item['cost']);
}
$product->tax_name1 = isset($item['tax_name1']) ? $item['tax_name1'] : null;
$product->tax_rate1 = isset($item['tax_rate1']) ? $item['tax_rate1'] : 0;
$product->tax_name2 = isset($item['tax_name2']) ? $item['tax_name2'] : null;
$product->tax_rate2 = isset($item['tax_rate2']) ? $item['tax_rate2'] : 0;
$product->custom_value1 = isset($item['custom_value1']) ? $item['custom_value1'] : null;
$product->custom_value2 = isset($item['custom_value2']) ? $item['custom_value2'] : null;
$product->save();
}
}
}
}
$invoiceItem = InvoiceItem::createNew($invoice);
$invoiceItem->fill($item);
$invoiceItem->product_id = isset($product) ? $product->id : null;
$invoiceItem->product_key = isset($item['product_key']) ? (trim($invoice->is_recurring ? $item['product_key'] : Utils::processVariables($item['product_key']))) : '';
$invoiceItem->notes = trim($invoice->is_recurring ? $item['notes'] : Utils::processVariables($item['notes']));
$invoiceItem->cost = Utils::parseFloat($item['cost']);
$invoiceItem->qty = Utils::parseFloat($item['qty']);
if (isset($item['custom_value1'])) {
$invoiceItem->custom_value1 = $item['custom_value1'];
}
if (isset($item['custom_value2'])) {
$invoiceItem->custom_value2 = $item['custom_value2'];
}
// provide backwards compatability
if (isset($item['tax_name']) && isset($item['tax_rate'])) {
$item['tax_name1'] = $item['tax_name'];
$item['tax_rate1'] = $item['tax_rate'];
}
// provide backwards compatability
if (! isset($item['invoice_item_type_id']) && in_array($invoiceItem->notes, [trans('texts.online_payment_surcharge'), trans('texts.online_payment_discount')])) {
$invoiceItem->invoice_item_type_id = $invoice->balance > 0 ? INVOICE_ITEM_TYPE_PENDING_GATEWAY_FEE : INVOICE_ITEM_TYPE_PAID_GATEWAY_FEE;
}
$invoiceItem->fill($item);
$invoice->invoice_items()->save($invoiceItem);
}
$invoice->load('invoice_items');
if (Auth::check()) {
$invoice = $this->saveInvitations($invoice);
}
$this->dispatchEvents($invoice);
return $invoice;
}
private function saveInvitations($invoice)
{
$client = $invoice->client;
$client->load('contacts');
$sendInvoiceIds = [];
if (! $client->contacts->count()) {
return $invoice;
}
foreach ($client->contacts as $contact) {
if ($contact->send_invoice) {
$sendInvoiceIds[] = $contact->id;
}
}
// if no contacts are selected auto-select the first to ensure there's an invitation
if (! count($sendInvoiceIds)) {
$sendInvoiceIds[] = $client->contacts[0]->id;
}
foreach ($client->contacts as $contact) {
$invitations = Invitation::scope()->whereContactId($contact->id)->whereInvoiceId($invoice->id)->orderBy('id')->get();
if ($invitations->count() == 0) {
if (in_array($contact->id, $sendInvoiceIds)) {
$invitation = Invitation::createNew($invoice);
$invitation->invoice_id = $invoice->id;
$invitation->contact_id = $contact->id;
$invitation->invitation_key = strtolower(str_random(RANDOM_KEY_LENGTH));
$invitation->save();
}
} else {
$isFirst = true;
foreach ($invitations as $invitation) {
if (! in_array($contact->id, $sendInvoiceIds) || !$isFirst) {
$invitation->delete();
}
$isFirst = false;
}
}
}
if ($invoice->is_public && ! $invoice->areInvitationsSent()) {
$invoice->markInvitationsSent();
}
return $invoice;
}
private function dispatchEvents($invoice)
{
if ($invoice->isType(INVOICE_TYPE_QUOTE)) {
if ($invoice->wasRecentlyCreated) {
event(new QuoteItemsWereCreated($invoice));
} else {
event(new QuoteItemsWereUpdated($invoice));
}
} else {
if ($invoice->wasRecentlyCreated) {
event(new InvoiceItemsWereCreated($invoice));
} else {
event(new InvoiceItemsWereUpdated($invoice));
}
}
}
/**
* @param Invoice $invoice
* @param null $quoteId
*
* @return mixed
*/
public function cloneInvoice(Invoice $invoice, $quoteId = null)
{
$invoice->load('invitations', 'invoice_items');
$account = $invoice->account;
$clone = Invoice::createNew($invoice);
$clone->balance = $invoice->amount;
// if the invoice prefix is diff than quote prefix, use the same number for the invoice (if it's available)
$invoiceNumber = false;
if ($account->hasInvoicePrefix() && $account->share_counter) {
$invoiceNumber = $invoice->invoice_number;
if ($account->quote_number_prefix && strpos($invoiceNumber, $account->quote_number_prefix) === 0) {
$invoiceNumber = substr($invoiceNumber, strlen($account->quote_number_prefix));
}
$invoiceNumber = $account->invoice_number_prefix.$invoiceNumber;
if (Invoice::scope(false, $account->id)
->withTrashed()
->whereInvoiceNumber($invoiceNumber)
->first()) {
$invoiceNumber = false;
} else {
// since we aren't using the counter we need to offset it by one
$account->invoice_number_counter -= 1;
$account->save();
}
}
foreach ([
'client_id',
'discount',
'is_amount_discount',
'po_number',
'is_recurring',
'frequency_id',
'start_date',
'end_date',
'terms',
'invoice_footer',
'public_notes',
'invoice_design_id',
'tax_name1',
'tax_rate1',
'tax_name2',
'tax_rate2',
'amount',
'invoice_type_id',
'custom_value1',
'custom_value2',
'custom_taxes1',
'custom_taxes2',
'partial',
'custom_text_value1',
'custom_text_value2',
] as $field) {
$clone->$field = $invoice->$field;
}
if ($quoteId) {
$clone->invoice_type_id = INVOICE_TYPE_STANDARD;
$clone->invoice_design_id = $account->invoice_design_id;
$clone->quote_id = $quoteId;
if ($account->invoice_terms) {
$clone->terms = $account->invoice_terms;
}
if (! auth()->check()) {
$clone->is_public = true;
$clone->invoice_status_id = INVOICE_STATUS_SENT;
}
}
$clone->invoice_number = $invoiceNumber ?: $account->getNextNumber($clone);
$clone->invoice_date = date_create()->format('Y-m-d');
$clone->due_date = $account->defaultDueDate($invoice->client);
$clone->save();
if ($quoteId) {
$invoice->quote_invoice_id = $clone->public_id;
$invoice->save();
}
foreach ($invoice->invoice_items as $item) {
$cloneItem = InvoiceItem::createNew($invoice);
foreach ([
'product_id',
'product_key',
'notes',
'cost',
'qty',
'tax_name1',
'tax_rate1',
'tax_name2',
'tax_rate2',
'custom_value1',
'custom_value2',
'discount',
] as $field) {
$cloneItem->$field = $item->$field;
}
$clone->invoice_items()->save($cloneItem);
}
foreach ($invoice->documents as $document) {
$cloneDocument = $document->cloneDocument();
$clone->documents()->save($cloneDocument);
}
foreach ($invoice->invitations as $invitation) {
$cloneInvitation = Invitation::createNew($invoice);
$cloneInvitation->contact_id = $invitation->contact_id;
$cloneInvitation->invitation_key = strtolower(str_random(RANDOM_KEY_LENGTH));
$clone->invitations()->save($cloneInvitation);
}
$this->dispatchEvents($clone);
return $clone;
}
/**
* @param Invoice $invoice
*/
public function emailInvoice(Invoice $invoice)
{
// TODO remove this with Laravel 5.3 (https://github.com/invoiceninja/invoiceninja/issues/1303)
if (config('queue.default') === 'sync') {
app('App\Ninja\Mailers\ContactMailer')->sendInvoice($invoice);
} else {
dispatch(new SendInvoiceEmail($invoice));
}
}
/**
* @param Invoice $invoice
*/
public function markSent(Invoice $invoice)
{
$invoice->markSent();
}
/**
* @param Invoice $invoice
*/
public function markPaid(Invoice $invoice)
{
if (! $invoice->canBePaid()) {
return;
}
$invoice->markSentIfUnsent();
$data = [
'client_id' => $invoice->client_id,
'invoice_id' => $invoice->id,
'amount' => $invoice->balance,
];
return $this->paymentRepo->save($data);
}
/**
* @param $invitationKey
*
* @return Invitation|bool
*/
public function findInvoiceByInvitation($invitationKey)
{
// check for extra params at end of value (from website feature)
list($invitationKey) = explode('&', $invitationKey);
$invitationKey = substr($invitationKey, 0, RANDOM_KEY_LENGTH);
/** @var \App\Models\Invitation $invitation */
$invitation = Invitation::where('invitation_key', '=', $invitationKey)->first();
if (! $invitation) {
return false;
}
$invoice = $invitation->invoice;
if (! $invoice || $invoice->is_deleted) {
return false;
}
$invoice->load('user', 'invoice_items', 'documents', 'invoice_design', 'account.country', 'client.contacts', 'client.country');
$client = $invoice->client;
if (! $client || $client->is_deleted) {
return false;
}
return $invitation;
}
/**
* @param $clientId
* @param mixed $entityType
*
* @return mixed
*/
public function findOpenInvoices($clientId)
{
$query = Invoice::scope()
->invoiceType(INVOICE_TYPE_STANDARD)
->whereClientId($clientId)
->whereIsRecurring(false)
->whereDeletedAt(null)
->where('balance', '>', 0);
return $query->where('invoice_status_id', '<', INVOICE_STATUS_PAID)
->select(['public_id', 'invoice_number'])
->get();
}
/**
* @param Invoice $recurInvoice
*
* @return mixed
*/
public function createRecurringInvoice(Invoice $recurInvoice)
{
$recurInvoice->load('account.timezone', 'invoice_items', 'client', 'user');
$client = $recurInvoice->client;
if ($client->deleted_at) {
return false;
}
if (! $recurInvoice->user->confirmed) {
return false;
}
if (! $recurInvoice->shouldSendToday()) {
return false;
}
$invoice = Invoice::createNew($recurInvoice);
$invoice->is_public = true;
$invoice->invoice_type_id = INVOICE_TYPE_STANDARD;
$invoice->client_id = $recurInvoice->client_id;
$invoice->recurring_invoice_id = $recurInvoice->id;
$invoice->invoice_number = $recurInvoice->account->getNextNumber($invoice);
$invoice->amount = $recurInvoice->amount;
$invoice->balance = $recurInvoice->amount;
$invoice->invoice_date = date_create()->format('Y-m-d');
$invoice->discount = $recurInvoice->discount;
$invoice->po_number = $recurInvoice->po_number;
$invoice->public_notes = Utils::processVariables($recurInvoice->public_notes, $client);
$invoice->terms = Utils::processVariables($recurInvoice->terms ?: $recurInvoice->account->invoice_terms, $client);
$invoice->invoice_footer = Utils::processVariables($recurInvoice->invoice_footer ?: $recurInvoice->account->invoice_footer, $client);
$invoice->tax_name1 = $recurInvoice->tax_name1;
$invoice->tax_rate1 = $recurInvoice->tax_rate1;
$invoice->tax_name2 = $recurInvoice->tax_name2;
$invoice->tax_rate2 = $recurInvoice->tax_rate2;
$invoice->invoice_design_id = $recurInvoice->invoice_design_id;
$invoice->custom_value1 = $recurInvoice->custom_value1 ?: 0;
$invoice->custom_value2 = $recurInvoice->custom_value2 ?: 0;
$invoice->custom_taxes1 = $recurInvoice->custom_taxes1 ?: 0;
$invoice->custom_taxes2 = $recurInvoice->custom_taxes2 ?: 0;
$invoice->custom_text_value1 = Utils::processVariables($recurInvoice->custom_text_value1, $client);
$invoice->custom_text_value2 = Utils::processVariables($recurInvoice->custom_text_value2, $client);
$invoice->is_amount_discount = $recurInvoice->is_amount_discount;
$invoice->due_date = $recurInvoice->getDueDate();
$invoice->save();
foreach ($recurInvoice->invoice_items as $recurItem) {
$item = InvoiceItem::createNew($recurItem);
$item->product_id = $recurItem->product_id;
$item->qty = $recurItem->qty;
$item->cost = $recurItem->cost;
$item->notes = Utils::processVariables($recurItem->notes, $client);
$item->product_key = Utils::processVariables($recurItem->product_key, $client);
$item->tax_name1 = $recurItem->tax_name1;
$item->tax_rate1 = $recurItem->tax_rate1;
$item->tax_name2 = $recurItem->tax_name2;
$item->tax_rate2 = $recurItem->tax_rate2;
$item->custom_value1 = Utils::processVariables($recurItem->custom_value1, $client);
$item->custom_value2 = Utils::processVariables($recurItem->custom_value2, $client);
$item->discount = $recurItem->discount;
$invoice->invoice_items()->save($item);
}
foreach ($recurInvoice->documents as $recurDocument) {
$document = $recurDocument->cloneDocument();
$invoice->documents()->save($document);
}
foreach ($recurInvoice->invitations as $recurInvitation) {
$invitation = Invitation::createNew($recurInvitation);
$invitation->contact_id = $recurInvitation->contact_id;
$invitation->invitation_key = strtolower(str_random(RANDOM_KEY_LENGTH));
$invoice->invitations()->save($invitation);
}
$recurInvoice->last_sent_date = date('Y-m-d');
$recurInvoice->save();
if ($recurInvoice->getAutoBillEnabled() && ! $recurInvoice->account->auto_bill_on_due_date) {
// autoBillInvoice will check for ACH, so we're not checking here
if ($this->paymentService->autoBillInvoice($invoice)) {
// update the invoice reference to match its actual state
// this is to ensure a 'payment received' email is sent
$invoice->invoice_status_id = INVOICE_STATUS_PAID;
}
}
$this->dispatchEvents($invoice);
return $invoice;
}
/**
* @param Account $account
*
* @return mixed
*/
public function findNeedingReminding(Account $account, $filterEnabled = true)
{
$dates = [];
for ($i = 1; $i <= 3; $i++) {
if ($date = $account->getReminderDate($i, $filterEnabled)) {
if ($account->{"field_reminder{$i}"} == REMINDER_FIELD_DUE_DATE) {
$dates[] = "(due_date = '$date' OR partial_due_date = '$date')";
} else {
$dates[] = "invoice_date = '$date'";
}
}
}
if (! count($dates)) {
return collect();
}
$sql = implode(' OR ', $dates);
$invoices = Invoice::invoiceType(INVOICE_TYPE_STANDARD)
->with('client', 'invoice_items')
->whereHas('client', function ($query) {
$query->whereSendReminders(true);
})
->whereAccountId($account->id)
->where('balance', '>', 0)
->where('is_recurring', '=', false)
->whereIsPublic(true)
->whereRaw('('.$sql.')')
->get();
return $invoices;
}
public function findNeedingEndlessReminding(Account $account)
{
$settings = $account->account_email_settings;
$frequencyId = $settings->frequency_id_reminder4;
if (! $frequencyId || ! $account->enable_reminder4) {
return collect();
}
$frequency = Utils::getFromCache($frequencyId, 'frequencies');
$lastSentDate = date_create();
$lastSentDate->sub(date_interval_create_from_date_string($frequency->date_interval));
$invoices = Invoice::invoiceType(INVOICE_TYPE_STANDARD)
->with('client', 'invoice_items')
->whereHas('client', function ($query) {
$query->whereSendReminders(true);
})
->whereAccountId($account->id)
->where('balance', '>', 0)
->where('is_recurring', '=', false)
->whereIsPublic(true)
->where('last_sent_date', '<', $lastSentDate);
for ($i=1; $i<=3; $i++) {
if (!$account->{"enable_reminder{$i}"}) {
continue;
}
$field = $account->{"field_reminder{$i}"} == REMINDER_FIELD_DUE_DATE ? 'due_date' : 'invoice_date';
$date = date_create();
if ($account->{"direction_reminder{$i}"} == REMINDER_DIRECTION_AFTER) {
$date->sub(date_interval_create_from_date_string($account->{"num_days_reminder{$i}"} . ' days'));
}
$invoices->where($field, '<', $date);
}
return $invoices->get();
}
public function clearGatewayFee($invoice)
{
$account = $invoice->account;
if (! $invoice->relationLoaded('invoice_items')) {
$invoice->load('invoice_items');
}
$data = $invoice->toArray();
foreach ($data['invoice_items'] as $key => $item) {
if ($item['invoice_item_type_id'] == INVOICE_ITEM_TYPE_PENDING_GATEWAY_FEE) {
unset($data['invoice_items'][$key]);
$this->save($data, $invoice);
break;
}
}
}
public function setLateFee($invoice, $amount, $percent)
{
if ($amount <= 0 && $percent <= 0) {
return false;
}
$account = $invoice->account;
$data = $invoice->toArray();
$fee = $amount;
if ($invoice->getRequestedAmount() > 0) {
$fee += round($invoice->getRequestedAmount() * $percent / 100, 2);
}
$item = [];
$item['product_key'] = trans('texts.fee');
$item['notes'] = trans('texts.late_fee_added', ['date' => $account->formatDate('now')]);
$item['qty'] = 1;
$item['cost'] = $fee;
$item['invoice_item_type_id'] = INVOICE_ITEM_TYPE_LATE_FEE;
$data['invoice_items'][] = $item;
$this->save($data, $invoice);
}
public function setGatewayFee($invoice, $gatewayTypeId)
{
$account = $invoice->account;
if (! $account->gateway_fee_enabled) {
return;
}
$settings = $account->getGatewaySettings($gatewayTypeId);
$this->clearGatewayFee($invoice);
if (! $settings) {
return;
}
$data = $invoice->toArray();
$fee = $invoice->calcGatewayFee($gatewayTypeId);
if ($fee == 0) {
return;
}
$date = $account->getDateTime()->format($account->getCustomDateFormat());
$feeItemLabel = $account->getLabel('gateway_fee_item') ?: ($fee >= 0 ? trans('texts.surcharge') : trans('texts.discount'));
if ($feeDescriptionLabel = $account->getLabel('gateway_fee_description')) {
if (strpos($feeDescriptionLabel, '$date') !== false) {
$feeDescriptionLabel = str_replace('$date', $date, $feeDescriptionLabel);
} else {
$feeDescriptionLabel .= ' • ' . $date;
}
} else {
$feeDescriptionLabel = $fee >= 0 ? trans('texts.online_payment_surcharge') : trans('texts.online_payment_discount');
$feeDescriptionLabel .= ' • ' . $date;
}
$item = [];
$item['product_key'] = $feeItemLabel;
$item['notes'] = $feeDescriptionLabel;
$item['qty'] = 1;
$item['cost'] = $fee;
$item['tax_rate1'] = $settings->fee_tax_rate1;
$item['tax_name1'] = $settings->fee_tax_name1;
$item['tax_rate2'] = $settings->fee_tax_rate2;
$item['tax_name2'] = $settings->fee_tax_name2;
$item['invoice_item_type_id'] = INVOICE_ITEM_TYPE_PENDING_GATEWAY_FEE;
$data['invoice_items'][] = $item;
$this->save($data, $invoice);
}
public function findPhonetically($invoiceNumber)
{
$map = [];
$max = SIMILAR_MIN_THRESHOLD;
$invoiceId = 0;
$invoices = Invoice::scope()->get(['id', 'invoice_number', 'public_id']);
foreach ($invoices as $invoice) {
$map[$invoice->id] = $invoice;
$similar = similar_text($invoiceNumber, $invoice->invoice_number, $percent);
var_dump($similar);
if ($percent > $max) {
$invoiceId = $invoice->id;
$max = $percent;
}
}
return ($invoiceId && isset($map[$invoiceId])) ? $map[$invoiceId] : null;
}
}