1
0
mirror of https://github.com/invoiceninja/invoiceninja.git synced 2024-09-22 01:11:34 +02:00
invoiceninja/app/Jobs/Ledger/UpdateLedger.php
2023-11-07 17:39:56 +11:00

74 lines
2.0 KiB
PHP

<?php
/**
* Invoice Ninja (https://invoiceninja.com).
*
* @link https://github.com/invoiceninja/invoiceninja source repository
*
* @copyright Copyright (c) 2023. Invoice Ninja LLC (https://invoiceninja.com)
*
* @license https://www.elastic.co/licensing/elastic-license
*/
namespace App\Jobs\Ledger;
use App\Libraries\MultiDB;
use App\Models\CompanyLedger;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\Middleware\WithoutOverlapping;
class UpdateLedger implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public $tries = 1;
public $deleteWhenMissingModels = true;
public function __construct(private int $company_ledger_id, private float $start_amount, private string $company_key, private string $db)
{
}
/**
* Execute the job.
*
*
* @return void
*/
public function handle() :void
{
// nlog("Updating company ledger for client ". $this->company_ledger_id);
MultiDB::setDb($this->db);
$cl = CompanyLedger::find($this->company_ledger_id);
if(!$cl)
return;
$entity = $cl->company_ledgerable;
$balance = $entity->calc()->getBalance();
$cl->adjustment = $balance - $this->start_amount;
$parent_ledger = CompanyLedger::query()
->where('id', '<', $cl->id)
->where('company_id', $cl->company_id)
->where('client_id', $cl->client_id)
->where('balance', '!=', 0)
->orderBy('id', 'DESC')
->first();
$cl->balance = ($parent_ledger ? $parent_ledger->balance : 0) + $cl->adjustment;
$cl->save();
}
public function middleware()
{
return [new WithoutOverlapping($this->company_key)];
}
}