espocrm/custom/Espo/Custom/Hooks/CAkten/UpdateLastSyncFromDocuments.php

<?php
namespace Espo\Custom\Hooks\CAkten;

use Espo\ORM\Entity;
use Espo\ORM\Repository\Option\SaveOptions;
use Espo\Core\Hook\Hook\BeforeSave;

/**
 * Hook: Aktualisiert lastSync basierend auf dem neuesten lastSyncTimestamp
 * der verknüpften Dokumente
 */
class UpdateLastSyncFromDocuments 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 das neueste lastSyncTimestamp aller verknüpften Dokumente
            $query = $this->entityManager->getQueryBuilder()
                ->select([
                    'MAX:lastSyncTimestamp' => 'maxLastSync',
                    'COUNT:id' => 'dokumentCount'
                ])
                ->from('CDokumente')
                ->where([
                    'cAktenId' => $entity->getId(),
                    'deleted' => false,
                    'lastSyncTimestamp!=' => null
                ])
                ->build();
            
            $pdoStatement = $this->entityManager->getQueryExecutor()->execute($query);
            $result = $pdoStatement->fetch(\PDO::FETCH_ASSOC);
            
            if ($result && $result['maxLastSync']) {
                // Setze lastSync auf den neuesten Sync-Timestamp
                $entity->set('lastSync', $result['maxLastSync']);
            }
            
            // Berechne auch syncStatus basierend auf verknüpften Dokumenten
            $this->updateSyncStatus($entity);
            
        } catch (\Exception $e) {
            // Fehler loggen, aber nicht werfen (um Save nicht zu blockieren)
            $GLOBALS['log']->error('CAkten UpdateLastSyncFromDocuments Hook Error: ' . $e->getMessage());
        }
    }
    
    /**
     * Aktualisiert syncStatus basierend auf den Status der verknüpften Dokumente
     */
    private function updateSyncStatus(Entity $entity): void
    {
        $query = $this->entityManager->getQueryBuilder()
            ->select(['syncStatus'])
            ->from('CDokumente')
            ->where([
                'cAktenId' => $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;
        $hasFailed = false;
        
        foreach ($rows as $row) {
            $status = $row['syncStatus'] ?? null;
            
            if ($status === 'failed') {
                $hasFailed = true;
            }
            
            if ($status === 'new' || $status === 'unclean' || $status === null || $status === '') {
                $hasUnsynced = true;
            }
        }
        
        // Setze globalen Status
        if ($hasFailed) {
            $entity->set('syncStatus', 'failed');
        } elseif ($hasUnsynced) {
            $entity->set('syncStatus', 'unclean');
        } else {
            // Alle Dokumente sind "synced"
            $entity->set('syncStatus', 'synced');
        }
    }
}