123 lines
4.2 KiB
PHP
123 lines
4.2 KiB
PHP
<?php
|
|
namespace Espo\Custom\Hooks\CDokumente;
|
|
|
|
use Espo\ORM\Entity;
|
|
use Espo\ORM\Repository\Option\SaveOptions;
|
|
use Espo\Core\Hook\Hook\AfterSave;
|
|
|
|
/**
|
|
* Hook: Bei Änderung eines Dokuments wird syncStatus auf "unclean" gesetzt
|
|
* und alle verknüpften AIKnowledge Junction-Table-Einträge werden aktualisiert
|
|
*/
|
|
class UpdateJunctionSyncStatus implements AfterSave
|
|
{
|
|
public function __construct(
|
|
private \Espo\ORM\EntityManager $entityManager
|
|
) {}
|
|
|
|
public function afterSave(Entity $entity, SaveOptions $options): void
|
|
{
|
|
// Überspringe bei Create (nur bei Update)
|
|
if ($entity->isNew()) {
|
|
return;
|
|
}
|
|
|
|
// Überspringe, wenn keine relevanten Felder geändert wurden
|
|
if (!$this->hasRelevantChanges($entity)) {
|
|
return;
|
|
}
|
|
|
|
try {
|
|
// Set syncStatus = 'unclean' directly on CDokumente entity
|
|
// (only if it has an AdvowareAkte linked)
|
|
if ($entity->get('cAdvowareAktenId')) {
|
|
$entity->set('syncStatus', 'unclean');
|
|
$this->entityManager->saveEntity($entity, ['silent' => true, 'skipHooks' => true]);
|
|
|
|
// Trigger parent AdvowareAkte update (will update syncStatus and lastSync via its own hook)
|
|
$akte = $this->entityManager->getEntityById('CAdvowareAkten', $entity->get('cAdvowareAktenId'));
|
|
if ($akte) {
|
|
// Just touch the entity to trigger beforeSave hook
|
|
$this->entityManager->saveEntity($akte, ['silent' => true]);
|
|
}
|
|
}
|
|
|
|
// Update AIKnowledge Junction-Tables (unchanged)
|
|
$this->updateAIKnowledgeJunctions($entity);
|
|
|
|
} catch (\Exception $e) {
|
|
// Fehler loggen, aber nicht werfen (um Save nicht zu blockieren)
|
|
$GLOBALS['log']->error('CDokumente UpdateJunctionSyncStatus Hook Error: ' . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Prüft ob relevante Felder geändert wurden
|
|
*/
|
|
private function hasRelevantChanges(Entity $entity): bool
|
|
{
|
|
// Relevante Felder für Sync-Status
|
|
$relevantFields = [
|
|
'name',
|
|
'description',
|
|
'dokument',
|
|
'dokumentId',
|
|
'preview',
|
|
'previewId',
|
|
'fileStatus'
|
|
];
|
|
|
|
foreach ($relevantFields as $field) {
|
|
if ($entity->isAttributeChanged($field)) {
|
|
return true;
|
|
}
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Update AIKnowledge Junction-Tables
|
|
*/
|
|
private function updateAIKnowledgeJunctions(Entity $entity): void
|
|
{
|
|
$updateQuery = $this->entityManager->getQueryBuilder()
|
|
->update()
|
|
->in('CAIKnowledgeDokumente')
|
|
->set(['syncstatus' => 'unclean'])
|
|
->where([
|
|
'cDokumenteId' => $entity->getId(),
|
|
'deleted' => false
|
|
])
|
|
->build();
|
|
|
|
$this->entityManager->getQueryExecutor()->execute($updateQuery);
|
|
|
|
// Hole alle betroffenen AIKnowledge IDs
|
|
$selectQuery = $this->entityManager->getQueryBuilder()
|
|
->select(['cAIKnowledgeId'])
|
|
->from('CAIKnowledgeDokumente')
|
|
->where([
|
|
'cDokumenteId' => $entity->getId(),
|
|
'deleted' => false
|
|
])
|
|
->build();
|
|
|
|
$pdoStatement = $this->entityManager->getQueryExecutor()->execute($selectQuery);
|
|
$rows = $pdoStatement->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
// Trigger Update auf jeder AIKnowledge (um CheckGlobalSyncStatus Hook auszulösen)
|
|
foreach ($rows as $row) {
|
|
$knowledgeId = $row['cAIKnowledgeId'] ?? null;
|
|
if ($knowledgeId) {
|
|
$knowledge = $this->entityManager->getEntity('CAIKnowledge', $knowledgeId);
|
|
if ($knowledge) {
|
|
// Force Update ohne Hook-Loop
|
|
$knowledge->set('syncStatus', 'unclean');
|
|
$this->entityManager->saveEntity($knowledge, ['silent' => true, 'skipHooks' => true]);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|