Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions Core/Kernel.php
Original file line number Diff line number Diff line change
Expand Up @@ -130,6 +130,7 @@ public static function init(): void
WorkQueue::addWorker('PurchaseDocumentWorker', 'Model.FacturaProveedor.Update');
WorkQueue::addWorker('PurchaseDocumentWorker', 'Model.PedidoProveedor.Update');
WorkQueue::addWorker('PurchaseDocumentWorker', 'Model.PresupuestoProveedor.Update');
WorkQueue::addWorker('FormaPagoWorker', 'Model.FormaPago.Update');

self::stopTimer('kernel::init');
}
Expand Down
59 changes: 59 additions & 0 deletions Core/Worker/FormaPagoWorker.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,59 @@
<?php
/**
* Worker to unlink clientes and proveedores when a payment method is deactivated.
*/

namespace FacturaScripts\Core\Worker;

use FacturaScripts\Core\Model\WorkEvent;
use FacturaScripts\Core\Template\WorkerClass;
use FacturaScripts\Core\Base\DataBase\DataBaseWhere;
use FacturaScripts\Core\Model\Cliente;
use FacturaScripts\Core\Model\Proveedor;
use FacturaScripts\Core\Model\FormaPago;

class FormaPagoWorker extends WorkerClass
{
public function run(WorkEvent $event): bool
{
$codpago = $event->value;
if (empty($codpago)) {
return $this->done();
}

$forma = new FormaPago();
if (false === $forma->load($codpago)) {
return $this->done();
}

// only act when the payment method is inactive
if ($forma->activa) {
return $this->done();
}

// prevent workers from creating new model events while we update rows
$this->preventNewEvents(['Model.Cliente.*', 'Model.Proveedor.*']);

$where = [new DataBaseWhere('codpago', $codpago)];

// unlink from clientes
foreach (Cliente::all($where, [], 0, 0) as $cliente) {
$cliente->codpago = null;
if (method_exists($cliente, 'disableAdditionalTest')) {
$cliente->disableAdditionalTest(true);
}
$cliente->save();
}

// unlink from proveedores
foreach (Proveedor::all($where, [], 0, 0) as $proveedor) {
$proveedor->codpago = null;
if (method_exists($proveedor, 'disableAdditionalTest')) {
$proveedor->disableAdditionalTest(true);
}
$proveedor->save();
}

return $this->done();
}
}