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

Remove CAIKnowledge related hooks, controllers, localization files, and metadata definitions; update microtime values in config and state files

Browse Source
This commit is contained in:
bsiggel
2026-03-26 15:41:56 +01:00
parent 260186d148
commit 297d2765bd
17 changed files with 3 additions and 719 deletions
Download Patch File Download Diff File Expand all files Collapse all files

75
custom/Espo/Custom/Hooks/CAIKnowledge/CheckGlobalSyncStatus.php
View File

@@ -1,75 +0,0 @@
<?php
namespace Espo\Custom\Hooks\CAIKnowledge;
use Espo\ORM\Entity;
use Espo\ORM\Repository\Option\SaveOptions;
use Espo\Core\Hook\Hook\BeforeSave;
/**
* Hook: Prüft Junction-Table und aktualisiert globalen syncStatus
* basierend auf den syncstatus-Werten der verknüpften Dokumente
*/
class CheckGlobalSyncStatus implements BeforeSave
{
public function __construct(
private \Espo\ORM\EntityManager $entityManager
) {}
public function beforeSave(Entity $entity, SaveOptions $options): void
{
// Überspringe, wenn skipHooks gesetzt ist (verhindert Loops)
if ($options->get('skipHooks')) {
return;
}
// Nur wenn Entity bereits existiert (nicht bei Create)
if ($entity->isNew()) {
return;
}
try {
// Hole alle verknüpften Dokumente mit ihren syncstatus-Werten aus der Junction-Tabelle
$query = $this->entityManager->getQueryBuilder()
->select(['syncstatus'])
->from('CAIKnowledgeDokumente')
->where([
'cAIKnowledgeId' => $entity->getId(),
'deleted' => false
])
->build();
$pdoStatement = $this->entityManager->getQueryExecutor()->execute($query);
$rows = $pdoStatement->fetchAll(\PDO::FETCH_ASSOC);
// Wenn keine Dokumente verknüpft, setze auf "unclean"
if (empty($rows)) {
$entity->set('syncStatus', 'unclean');
return;
}
// Prüfe, ob irgendein Dokument "new" oder "unclean" ist
$hasUnsynced = false;
foreach ($rows as $row) {
$status = $row['syncstatus'] ?? null;
if ($status === 'new' || $status === 'unclean' || $status === null || $status === '') {
$hasUnsynced = true;
break;
}
}
// Setze globalen Status
if ($hasUnsynced) {
$entity->set('syncStatus', 'unclean');
} else {
// Alle Dokumente sind "synced"
$entity->set('syncStatus', 'synced');
$entity->set('lastSync', date('Y-m-d H:i:s'));
}
} catch (\Exception $e) {
// Bei Fehler loggen und Status auf "unclean" setzen
$GLOBALS['log']->error('CAIKnowledge CheckGlobalSyncStatus Hook Error: ' . $e->getMessage());
$entity->set('syncStatus', 'unclean');
}
}
}

47
custom/Espo/Custom/Hooks/CAIKnowledge/DokumenteSyncStatus.php
View File

@@ -1,47 +0,0 @@
<?php
namespace Espo\Custom\Hooks\CAIKnowledge;
use Espo\ORM\Entity;
use Espo\Core\Hook\Hook\AfterRelate;
/**
* Hook: Setzt Dokument-Sync-Status auf "new" beim Verknüpfen und
* globalen syncStatus auf "unclean"
*/
class DokumenteSyncStatus implements AfterRelate
{
public function __construct(
private \Espo\ORM\EntityManager $entityManager
) {}
public function afterRelate(
Entity $entity,
string $relationName,
Entity $foreignEntity,
array $columnData,
\Espo\ORM\Repository\Option\RelateOptions $options
): void {
// Nur für dokumentes-Beziehung
if ($relationName !== 'dokumentes') {
return;
}
// Setze Sync-Status des Dokuments in der Junction-Tabelle auf "new"
$repository = $this->entityManager->getRDBRepository('CAIKnowledge');
try {
$repository->getRelation($entity, 'dokumentes')->updateColumns(
$foreignEntity,
['syncstatus' => 'new']
);
// Setze globalen syncStatus auf "unclean"
$entity->set('syncStatus', 'unclean');
$this->entityManager->saveEntity($entity, ['silent' => true, 'skipHooks' => true]);
} catch (\Exception $e) {
// Fehler loggen, aber nicht werfen (um Verknüpfung nicht zu blockieren)
$GLOBALS['log']->error('CAIKnowledge DokumenteSyncStatus Hook Error: ' . $e->getMessage());
}
}
}

182
custom/Espo/Custom/Hooks/CAIKnowledge/PropagateDocumentsUp.php
View File

@@ -1,182 +0,0 @@
<?php
namespace Espo\Custom\Hooks\CAIKnowledge;
use Espo\ORM\Entity;
use Espo\Core\Hook\Hook\AfterRelate;
use Espo\Core\Hook\Hook\AfterUnrelate;
/**
* Hook: Propagiert Dokumenten-Verknüpfungen von AIKnowledge nach oben zu Räumungsklage/Mietinkasso
*
* Wenn Dokument mit AIKnowledge verknüpft wird:
* → verknüpfe mit verbundener Räumungsklage/Mietinkasso
* → von dort propagiert es automatisch zu AdvowareAkten (via deren Hooks)
*
* Wenn Dokument von AIKnowledge entknüpft wird:
* → entknüpfe von verbundener Räumungsklage/Mietinkasso
* → von dort propagiert es automatisch von AdvowareAkten (via deren Hooks)
*/
class PropagateDocumentsUp implements AfterRelate, AfterUnrelate
{
private static array $processing = [];
public function __construct(
private \Espo\ORM\EntityManager $entityManager
) {}
public function afterRelate(
Entity $entity,
string $relationName,
Entity $foreignEntity,
array $columnData,
\Espo\ORM\Repository\Option\RelateOptions $options
): void {
// Nur für dokumentes-Beziehung
if ($relationName !== 'dokumentes') {
return;
}
// Vermeide Loops
$key = $entity->getId() . '-' . $foreignEntity->getId() . '-relate';
if (isset(self::$processing[$key])) {
return;
}
self::$processing[$key] = true;
try {
// Prüfe ob Räumungsklage verknüpft ist
$raumungsklage = $this->entityManager
->getRDBRepository('CAIKnowledge')
->getRelation($entity, 'vmhRumungsklage')
->findOne();
if ($raumungsklage) {
$this->relateDocument($raumungsklage, 'dokumentesvmhraumungsklage', $foreignEntity);
// Also link to AdvowareAkte if Räumungsklage has one
$advowareAkte = $this->entityManager
->getRDBRepository('CVmhRumungsklage')
->getRelation($raumungsklage, 'advowareAkten')
->findOne();
if ($advowareAkte && !$foreignEntity->get('cAktenId')) {
$foreignEntity->set('cAktenId', $advowareAkte->getId());
$foreignEntity->set('syncStatus', 'new');
$this->entityManager->saveEntity($foreignEntity, ['silent' => true, 'skipHooks' => true]);
}
}
// Prüfe ob Mietinkasso verknüpft ist
$mietinkasso = $this->entityManager
->getRDBRepository('CAIKnowledge')
->getRelation($entity, 'mietinkasso')
->findOne();
if ($mietinkasso) {
$this->relateDocument($mietinkasso, 'dokumentesmietinkasso', $foreignEntity);
// Also link to AdvowareAkte if Mietinkasso has one
$advowareAkte = $this->entityManager
->getRDBRepository('CMietinkasso')
->getRelation($mietinkasso, 'advowareAkten')
->findOne();
if ($advowareAkte && !$foreignEntity->get('cAktenId')) {
$foreignEntity->set('cAktenId', $advowareAkte->getId());
$foreignEntity->set('syncStatus', 'new');
$this->entityManager->saveEntity($foreignEntity, ['silent' => true, 'skipHooks' => true]);
}
}
} catch (\Exception $e) {
$GLOBALS['log']->error('CAIKnowledge PropagateDocumentsUp (relate) Error: ' . $e->getMessage());
} finally {
unset(self::$processing[$key]);
}
}
public function afterUnrelate(
Entity $entity,
string $relationName,
Entity $foreignEntity,
\Espo\ORM\Repository\Option\UnrelateOptions $options
): void {
// Nur für dokumentes-Beziehung
if ($relationName !== 'dokumentes') {
return;
}
// Vermeide Loops
$key = $entity->getId() . '-' . $foreignEntity->getId() . '-unrelate';
if (isset(self::$processing[$key])) {
return;
}
self::$processing[$key] = true;
try {
// Prüfe ob Räumungsklage verknüpft ist
$raumungsklage = $this->entityManager
->getRDBRepository('CAIKnowledge')
->getRelation($entity, 'vmhRumungsklage')
->findOne();
if ($raumungsklage) {
$this->unrelateDocument($raumungsklage, 'dokumentesvmhraumungsklage', $foreignEntity);
}
// Prüfe ob Mietinkasso verknüpft ist
$mietinkasso = $this->entityManager
->getRDBRepository('CAIKnowledge')
->getRelation($entity, 'mietinkasso')
->findOne();
if ($mietinkasso) {
$this->unrelateDocument($mietinkasso, 'dokumentesmietinkasso', $foreignEntity);
}
// Note: We don't remove cAktenId on unrelate from AIKnowledge
// because the document might still be linked to Räumungsklage/Mietinkasso
} catch (\Exception $e) {
$GLOBALS['log']->error('CAIKnowledge PropagateDocumentsUp (unrelate) Error: ' . $e->getMessage());
} finally {
unset(self::$processing[$key]);
}
}
/**
* Hilfsfunktion: Verknüpfe Dokument (nur wenn nicht bereits verknüpft)
*/
private function relateDocument(Entity $parentEntity, string $relationName, Entity $document): void
{
$repository = $this->entityManager->getRDBRepository($parentEntity->getEntityType());
$relation = $repository->getRelation($parentEntity, $relationName);
// Prüfe ob bereits verknüpft
$isRelated = $relation
->where(['id' => $document->getId()])
->findOne();
if (!$isRelated) {
$relation->relate($document);
}
}
/**
* Hilfsfunktion: Entknüpfe Dokument
*/
private function unrelateDocument(Entity $parentEntity, string $relationName, Entity $document): void
{
$repository = $this->entityManager->getRDBRepository($parentEntity->getEntityType());
$relation = $repository->getRelation($parentEntity, $relationName);
// Prüfe ob verknüpft
$isRelated = $relation
->where(['id' => $document->getId()])
->findOne();
if ($isRelated) {
$relation->unrelate($document);
}
}
}