sync database currency rates

This commit is contained in:
Yurii
2026-03-10 11:33:49 +02:00
parent 48f71dfafe
commit b398004040
2 changed files with 6 additions and 0 deletions
@@ -32,6 +32,7 @@ namespace Espo\Classes\RecordHooks\CurrencyRecordRate;
use Espo\Core\Exceptions\Conflict; use Espo\Core\Exceptions\Conflict;
use Espo\Core\Record\DeleteParams; use Espo\Core\Record\DeleteParams;
use Espo\Core\Record\Hook\DeleteHook; use Espo\Core\Record\Hook\DeleteHook;
use Espo\Core\Utils\Currency\DatabasePopulator;
use Espo\Core\WebSocket\Submission; use Espo\Core\WebSocket\Submission;
use Espo\Entities\CurrencyRecordRate; use Espo\Entities\CurrencyRecordRate;
use Espo\ORM\Entity; use Espo\ORM\Entity;
@@ -46,6 +47,7 @@ class AfterDelete implements DeleteHook
public function __construct( public function __construct(
private SyncManager $syncManager, private SyncManager $syncManager,
private Submission $submission, private Submission $submission,
private DatabasePopulator $databasePopulator,
) {} ) {}
public function process(Entity $entity, DeleteParams $params): void public function process(Entity $entity, DeleteParams $params): void
@@ -58,6 +60,7 @@ class AfterDelete implements DeleteHook
throw new Conflict($e->getMessage(), previous: $e); throw new Conflict($e->getMessage(), previous: $e);
} }
$this->databasePopulator->process();
$this->submission->submit('appParamsUpdate'); $this->submission->submit('appParamsUpdate');
} }
} }
@@ -31,6 +31,7 @@ namespace Espo\Classes\RecordHooks\CurrencyRecordRate;
use Espo\Core\Exceptions\Conflict; use Espo\Core\Exceptions\Conflict;
use Espo\Core\Record\Hook\SaveHook; use Espo\Core\Record\Hook\SaveHook;
use Espo\Core\Utils\Currency\DatabasePopulator;
use Espo\Core\WebSocket\Submission; use Espo\Core\WebSocket\Submission;
use Espo\Entities\CurrencyRecordRate; use Espo\Entities\CurrencyRecordRate;
use Espo\ORM\Entity; use Espo\ORM\Entity;
@@ -45,6 +46,7 @@ class AfterSave implements SaveHook
public function __construct( public function __construct(
private SyncManager $syncManager, private SyncManager $syncManager,
private Submission $submission, private Submission $submission,
private DatabasePopulator $databasePopulator,
) {} ) {}
public function process(Entity $entity): void public function process(Entity $entity): void
@@ -57,6 +59,7 @@ class AfterSave implements SaveHook
throw new Conflict($e->getMessage(), previous: $e); throw new Conflict($e->getMessage(), previous: $e);
} }
$this->databasePopulator->process();
$this->submission->submit('appParamsUpdate'); $this->submission->submit('appParamsUpdate');
} }
} }