bsiggel/espocrm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Enhance document synchronization hooks to handle linking and unlinking; update sync status for related entities; modify state file for cache and microtime values

Browse Source
This commit is contained in:
bsiggel
2026-03-27 09:52:28 +01:00
parent bd29d6e9b4
commit 2a18e62528
4 changed files with 107 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

97
custom/Espo/Custom/Hooks/CDokumente/UpdateJunctionSyncStatus.php
View File

@@ -2,14 +2,22 @@
namespace Espo\Custom\Hooks\CDokumente;
use Espo\ORM\Entity;
use Espo\ORM\Repository\Option\RemoveOptions;
use Espo\ORM\Repository\Option\SaveOptions;
use Espo\Core\Hook\Hook\AfterRemove;
use Espo\Core\Hook\Hook\AfterSave;
/**
* Hook: Bei Änderung eines Dokuments syncStatus und aiSyncStatus auf "unclean" setzen
* und die verknüpfte CAkten-Entity aktualisieren.
* Hook: Bei Änderung, Verlinkung oder Löschung eines Dokuments syncStatus und
* aiSyncStatus auf "unclean" setzen und die verknüpfte CAkten-Entity aktualisieren.
*
* Auslöser:
* - afterSave: Feldänderungen (name, description, file, …)
* - afterSave: Neues Dokument mit cAktenId
* - afterSave: cAktenId-Änderung (Verlinkung / Entlinkung über CAkten-Panel)
* - afterRemove: Gelöschtes Dokument → verknüpfte Akte neu berechnen
*/
class UpdateJunctionSyncStatus implements AfterSave
class UpdateJunctionSyncStatus implements AfterSave, AfterRemove
{
public function __construct(
private \Espo\ORM\EntityManager $entityManager
@@ -17,30 +25,83 @@ class UpdateJunctionSyncStatus implements AfterSave
public function afterSave(Entity $entity, SaveOptions $options): void
{
if ($entity->isNew()) {
return;
}
if (!$this->hasRelevantChanges($entity)) {
return;
}
if (!$entity->get('cAktenId')) {
// Kein Re-Eintritt wenn dieser Hook selbst gespeichert hat
if ($options->get('skipHooks')) {
return;
}
try {
// Fall 1: Neues Dokument → verknüpfte Akte neu berechnen
if ($entity->isNew()) {
if ($entity->get('cAktenId')) {
$this->triggerAkteUpdate($entity->get('cAktenId'));
}
return;
}
// Fall 2: cAktenId geändert (Dokument verlinkt oder entlinkt)
if ($entity->isAttributeChanged('cAktenId')) {
$oldAktenId = $entity->getFetched('cAktenId');
$newAktenId = $entity->get('cAktenId');
// Dokument der neuen Akte zugewiesen → als unclean markieren
if ($newAktenId) {
$entity->set('syncStatus', 'unclean');
$entity->set('aiSyncStatus', 'unclean');
$this->entityManager->saveEntity($entity, ['silent' => true, 'skipHooks' => true]);
$this->triggerAkteUpdate($newAktenId);
}
// Alte Akte ebenfalls neu berechnen (Dokument entfernt)
if ($oldAktenId && $oldAktenId !== $newAktenId) {
$this->triggerAkteUpdate($oldAktenId);
}
return;
}
// Fall 3: Relevante Feldänderungen (Datei, Name, Beschreibung, …)
if (!$this->hasRelevantChanges($entity)) {
return;
}
if (!$entity->get('cAktenId')) {
return;
}
$entity->set('syncStatus', 'unclean');
$entity->set('aiSyncStatus', 'unclean');
$this->entityManager->saveEntity($entity, ['silent' => true, 'skipHooks' => true]);
$this->triggerAkteUpdate($entity->get('cAktenId'));
// Akte triggern → BeforeSave-Hook UpdateLastSyncFromDocuments aggregiert Status
$akte = $this->entityManager->getEntityById('CAkten', $entity->get('cAktenId'));
if ($akte) {
$this->entityManager->saveEntity($akte, ['silent' => true]);
}
} catch (\Exception $e) {
$GLOBALS['log']->error('CDokumente UpdateJunctionSyncStatus Hook Error: ' . $e->getMessage());
$GLOBALS['log']->error('CDokumente UpdateJunctionSyncStatus afterSave Error: ' . $e->getMessage());
}
}
public function afterRemove(Entity $entity, RemoveOptions $options): void
{
$akteId = $entity->get('cAktenId');
if (!$akteId) {
return;
}
try {
$this->triggerAkteUpdate($akteId);
} catch (\Exception $e) {
$GLOBALS['log']->error('CDokumente UpdateJunctionSyncStatus afterRemove Error: ' . $e->getMessage());
}
}
/**
* Speichert die CAkten-Entity neu, damit UpdateLastSyncFromDocuments
* den Sync-Status aller verknüpften Dokumente neu aggregiert.
*/
private function triggerAkteUpdate(string $akteId): void
{
$akte = $this->entityManager->getEntityById('CAkten', $akteId);
if ($akte) {
// silent=true → keine Audit-Einträge; kein skipHooks → UpdateLastSyncFromDocuments läuft
$this->entityManager->saveEntity($akte, ['silent' => true]);
}
}