Implement CAIKnowledge and CDokumente junction functionality; add API routes, metadata, and localization files

custom/Espo/Custom/Api/JunctionData/GetDokumentes.php

@@ -0,0 +1,71 @@
+<?php
+
+namespace Espo\Custom\Api\JunctionData;
+
+use Espo\Core\Api\Action;
+use Espo\Core\Api\Request;
+use Espo\Core\Api\Response;
+use Espo\Core\Api\ResponseComposer;
+use Espo\Core\Exceptions\BadRequest;
+use Espo\Core\Exceptions\NotFound;
+use Espo\ORM\EntityManager;
+
+/**
+ * GET /api/v1/JunctionData/CAIKnowledge/:knowledgeId/dokumentes
+ * 
+ * Returns all documents linked to a knowledge entry with junction table data
+ */
+class GetDokumentes implements Action
+{
+    public function __construct(
+        private EntityManager $entityManager
+    ) {}
+    
+    public function process(Request $request): Response
+    {
+        $knowledgeId = $request->getRouteParam('knowledgeId');
+        
+        if (!$knowledgeId) {
+            throw new BadRequest('Knowledge ID is required');
+        }
+        
+        // Verify knowledge exists
+        $knowledge = $this->entityManager->getEntityById('CAIKnowledge', $knowledgeId);
+        if (!$knowledge) {
+            throw new NotFound('Knowledge entry not found');
+        }
+        
+        $pdo = $this->entityManager->getPDO();
+        
+        $sql = "
+            SELECT 
+                j.id as junctionId,
+                j.c_a_i_knowledge_id as cAIKnowledgeId,
+                j.c_dokumente_id as cDokumenteId,
+                j.ai_document_id as aiDocumentId,
+                j.syncstatus,
+                j.last_sync as lastSync,
+                d.id as documentId,
+                d.name as documentName,
+                d.blake3hash as blake3hash,
+                d.created_at as documentCreatedAt,
+                d.modified_at as documentModifiedAt
+            FROM c_a_i_knowledge_dokumente j
+            INNER JOIN c_dokumente d ON j.c_dokumente_id = d.id
+            WHERE j.c_a_i_knowledge_id = :knowledgeId
+              AND j.deleted = 0
+              AND d.deleted = 0
+            ORDER BY j.id DESC
+        ";
+        
+        $sth = $pdo->prepare($sql);
+        $sth->execute(['knowledgeId' => $knowledgeId]);
+        
+        $results = $sth->fetchAll(\PDO::FETCH_ASSOC);
+        
+        return ResponseComposer::json([
+            'total' => count($results),
+            'list' => $results
+        ]);
+    }
+}

custom/Espo/Custom/Api/JunctionData/LinkDokument.php

@@ -0,0 +1,178 @@
+<?php
+
+namespace Espo\Custom\Api\JunctionData;
+
+use Espo\Core\Api\Action;
+use Espo\Core\Api\Request;
+use Espo\Core\Api\Response;
+use Espo\Core\Api\ResponseComposer;
+use Espo\Core\Exceptions\BadRequest;
+use Espo\Core\Exceptions\NotFound;
+use Espo\Core\Exceptions\Conflict;
+use Espo\ORM\EntityManager;
+
+/**
+ * POST /api/v1/JunctionData/CAIKnowledge/:knowledgeId/dokumentes/:documentId
+ * 
+ * Creates or updates relationship with junction table data
+ * This endpoint links the entities AND sets junction columns in one call
+ */
+class LinkDokument implements Action
+{
+    public function __construct(
+        private EntityManager $entityManager
+    ) {}
+    
+    public function process(Request $request): Response
+    {
+        $knowledgeId = $request->getRouteParam('knowledgeId');
+        $documentId = $request->getRouteParam('documentId');
+        $data = $request->getParsedBody();
+        
+        if (!$knowledgeId || !$documentId) {
+            throw new BadRequest('Knowledge ID and Document ID are required');
+        }
+        
+        // Verify entities exist
+        $knowledge = $this->entityManager->getEntityById('CAIKnowledge', $knowledgeId);
+        if (!$knowledge) {
+            throw new NotFound('Knowledge entry not found');
+        }
+        
+        $document = $this->entityManager->getEntityById('CDokumente', $documentId);
+        if (!$document) {
+            throw new NotFound('Document not found');
+        }
+        
+        $pdo = $this->entityManager->getPDO();
+        
+        // Check if link already exists
+        $existing = $this->checkIfLinked($knowledgeId, $documentId);
+        
+        if ($existing) {
+            // Link exists - update junction columns
+            return $this->updateExisting($knowledgeId, $documentId, $data);
+        }
+        
+        // Create new link via ORM (triggers hooks like DokumenteSyncStatus)
+        $this->entityManager->getRDBRepository('CAIKnowledge')
+            ->getRelation($knowledge, 'dokumentes')
+            ->relate($document);
+        
+        // Now set junction columns if provided
+        if (!empty((array)$data)) {
+            return $this->updateExisting($knowledgeId, $documentId, $data);
+        }
+        
+        // Return created entry
+        $result = $this->getJunctionEntry($knowledgeId, $documentId);
+        
+        return ResponseComposer::json($result);
+    }
+    
+    private function checkIfLinked(string $knowledgeId, string $documentId): bool
+    {
+        $pdo = $this->entityManager->getPDO();
+        
+        $sql = "
+            SELECT COUNT(*) as count
+            FROM c_a_i_knowledge_dokumente
+            WHERE c_a_i_knowledge_id = :knowledgeId
+              AND c_dokumente_id = :documentId
+              AND deleted = 0
+        ";
+        
+        $sth = $pdo->prepare($sql);
+        $sth->execute([
+            'knowledgeId' => $knowledgeId,
+            'documentId' => $documentId
+        ]);
+        
+        $result = $sth->fetch(\PDO::FETCH_ASSOC);
+        return $result['count'] > 0;
+    }
+    
+    private function updateExisting(string $knowledgeId, string $documentId, \stdClass $data): Response
+    {
+        $pdo = $this->entityManager->getPDO();
+        
+        // Build dynamic UPDATE SET clause
+        $setClauses = [];
+        $params = [
+            'knowledgeId' => $knowledgeId,
+            'documentId' => $documentId
+        ];
+        
+        if (isset($data->aiDocumentId)) {
+            $setClauses[] = "ai_document_id = :aiDocumentId";
+            $params['aiDocumentId'] = $data->aiDocumentId;
+        }
+        
+        if (isset($data->syncstatus)) {
+            $allowedStatuses = ['new', 'unclean', 'synced', 'failed', 'unsupported'];
+            if (!in_array($data->syncstatus, $allowedStatuses)) {
+                throw new BadRequest('Invalid syncstatus value. Allowed: ' . implode(', ', $allowedStatuses));
+            }
+            $setClauses[] = "syncstatus = :syncstatus";
+            $params['syncstatus'] = $data->syncstatus;
+        }
+        
+        if (isset($data->lastSync)) {
+            $setClauses[] = "last_sync = :lastSync";
+            $params['lastSync'] = $data->lastSync;
+        } elseif (isset($data->updateLastSync) && $data->updateLastSync === true) {
+            $setClauses[] = "last_sync = NOW()";
+        }
+        
+        if (!empty($setClauses)) {
+            $sql = "
+                UPDATE c_a_i_knowledge_dokumente
+                SET " . implode(', ', $setClauses) . "
+                WHERE c_a_i_knowledge_id = :knowledgeId
+                  AND c_dokumente_id = :documentId
+                  AND deleted = 0
+            ";
+            
+            $sth = $pdo->prepare($sql);
+            $sth->execute($params);
+        }
+        
+        // Return updated data
+        $result = $this->getJunctionEntry($knowledgeId, $documentId);
+        
+        return ResponseComposer::json($result);
+    }
+    
+    private function getJunctionEntry(string $knowledgeId, string $documentId): array
+    {
+        $pdo = $this->entityManager->getPDO();
+        
+        $sql = "
+            SELECT 
+                id as junctionId,
+                c_a_i_knowledge_id as cAIKnowledgeId,
+                c_dokumente_id as cDokumenteId,
+                ai_document_id as aiDocumentId,
+                syncstatus,
+                last_sync as lastSync
+            FROM c_a_i_knowledge_dokumente
+            WHERE c_a_i_knowledge_id = :knowledgeId
+              AND c_dokumente_id = :documentId
+              AND deleted = 0
+        ";
+        
+        $sth = $pdo->prepare($sql);
+        $sth->execute([
+            'knowledgeId' => $knowledgeId,
+            'documentId' => $documentId
+        ]);
+        
+        $result = $sth->fetch(\PDO::FETCH_ASSOC);
+        
+        if (!$result) {
+            throw new NotFound('Junction entry not found');
+        }
+        
+        return $result;
+    }
+}

custom/Espo/Custom/Api/JunctionData/UpdateJunction.php

@@ -0,0 +1,123 @@
+<?php
+
+namespace Espo\Custom\Api\JunctionData;
+
+use Espo\Core\Api\Action;
+use Espo\Core\Api\Request;
+use Espo\Core\Api\Response;
+use Espo\Core\Api\ResponseComposer;
+use Espo\Core\Exceptions\BadRequest;
+use Espo\Core\Exceptions\NotFound;
+use Espo\ORM\EntityManager;
+
+/**
+ * PUT /api/v1/JunctionData/CAIKnowledge/:knowledgeId/dokumentes/:documentId
+ * 
+ * Updates junction table columns for an existing relationship
+ */
+class UpdateJunction implements Action
+{
+    public function __construct(
+        private EntityManager $entityManager
+    ) {}
+    
+    public function process(Request $request): Response
+    {
+        $knowledgeId = $request->getRouteParam('knowledgeId');
+        $documentId = $request->getRouteParam('documentId');
+        $data = $request->getParsedBody();
+        
+        if (!$knowledgeId || !$documentId) {
+            throw new BadRequest('Knowledge ID and Document ID are required');
+        }
+        
+        $pdo = $this->entityManager->getPDO();
+        
+        // Build dynamic UPDATE SET clause
+        $setClauses = [];
+        $params = [
+            'knowledgeId' => $knowledgeId,
+            'documentId' => $documentId
+        ];
+        
+        if (isset($data->aiDocumentId)) {
+            $setClauses[] = "ai_document_id = :aiDocumentId";
+            $params['aiDocumentId'] = $data->aiDocumentId;
+        }
+        
+        if (isset($data->syncstatus)) {
+            $allowedStatuses = ['new', 'unclean', 'synced', 'failed', 'unsupported'];
+            if (!in_array($data->syncstatus, $allowedStatuses)) {
+                throw new BadRequest('Invalid syncstatus value. Allowed: ' . implode(', ', $allowedStatuses));
+            }
+            $setClauses[] = "syncstatus = :syncstatus";
+            $params['syncstatus'] = $data->syncstatus;
+        }
+        
+        if (isset($data->lastSync)) {
+            $setClauses[] = "last_sync = :lastSync";
+            $params['lastSync'] = $data->lastSync;
+        } elseif (isset($data->updateLastSync) && $data->updateLastSync === true) {
+            $setClauses[] = "last_sync = NOW()";
+        }
+        
+        if (empty($setClauses)) {
+            throw new BadRequest('No fields to update. Provide at least one of: aiDocumentId, syncstatus, lastSync');
+        }
+        
+        $sql = "
+            UPDATE c_a_i_knowledge_dokumente
+            SET " . implode(', ', $setClauses) . "
+            WHERE c_a_i_knowledge_id = :knowledgeId
+              AND c_dokumente_id = :documentId
+              AND deleted = 0
+        ";
+        
+        $sth = $pdo->prepare($sql);
+        $sth->execute($params);
+        
+        $affectedRows = $sth->rowCount();
+        
+        if ($affectedRows === 0) {
+            throw new NotFound('Junction entry not found or no changes made');
+        }
+        
+        // Return updated data
+        $result = $this->getJunctionEntry($knowledgeId, $documentId);
+        
+        return ResponseComposer::json($result);
+    }
+    
+    private function getJunctionEntry(string $knowledgeId, string $documentId): array
+    {
+        $pdo = $this->entityManager->getPDO();
+        
+        $sql = "
+            SELECT 
+                id as junctionId,
+                c_a_i_knowledge_id as cAIKnowledgeId,
+                c_dokumente_id as cDokumenteId,
+                ai_document_id as aiDocumentId,
+                syncstatus,
+                last_sync as lastSync
+            FROM c_a_i_knowledge_dokumente
+            WHERE c_a_i_knowledge_id = :knowledgeId
+              AND c_dokumente_id = :documentId
+              AND deleted = 0
+        ";
+        
+        $sth = $pdo->prepare($sql);
+        $sth->execute([
+            'knowledgeId' => $knowledgeId,
+            'documentId' => $documentId
+        ]);
+        
+        $result = $sth->fetch(\PDO::FETCH_ASSOC);
+        
+        if (!$result) {
+            throw new NotFound('Junction entry not found');
+        }
+        
+        return $result;
+    }
+}

custom/Espo/Custom/Hooks/CDokumente/CDokumente.php

@@ -35,22 +35,24 @@ class CDokumente extends \Espo\Core\Hooks\Base
             return;
         }
 
-        // Berechne neue Hashes
-        $newMd5 = hash_file('md5', $filePath);
-        $newSha256 = hash_file('sha256', $filePath);
+        // Berechne Blake3 Hash
+        $fileContent = file_get_contents($filePath);
+        if ($fileContent === false) {
+            return;
+        }
         
-        // Setze Hashes
-        $entity->set('md5sum', $newMd5);
-        $entity->set('sha256', $newSha256);
+        $newBlake3 = \blake3($fileContent);
+
+        // Setze Hash
+        $entity->set('blake3hash', $newBlake3);
 
         // Bestimme Status
         if ($entity->isNew()) {
             $entity->set('fileStatus', 'new');
         } else {
-            $oldMd5 = $entity->getFetched('md5sum');
-            $oldSha256 = $entity->getFetched('sha256');
+            $oldBlake3 = $entity->getFetched('blake3hash');
 
-            if ($oldMd5 !== $newMd5 || $oldSha256 !== $newSha256) {
+            if ($oldBlake3 !== $newBlake3) {
                 $entity->set('fileStatus', 'changed');
             } else {
                 $entity->set('fileStatus', 'synced');

custom/Espo/Custom/Resources/i18n/de_DE/CAICollectionCDokumente.json

@@ -1,31 +0,0 @@
-{
-    "labels": {
-        "Create CAICollectionCDokumente": "AI-Collection-Dokument-Verknüpfung erstellen",
-        "CAICollectionCDokumente": "AI-Collection-Dokument-Verknüpfungen"
-    },
-    "fields": {
-        "cAICollection": "AI-Collection",
-        "cAICollectionId": "AI-Collection ID",
-        "cDokumente": "Dokument",
-        "cDokumenteId": "Dokument ID",
-        "xaifileid": "XAI File ID",
-        "syncStatus": "Sync-Status",
-        "deleted": "Gelöscht"
-    },
-    "links": {
-        "cAICollection": "AI-Collection",
-        "cDokumente": "Dokument"
-    },
-    "options": {
-        "syncStatus": {
-            "new": "Neu",
-            "changed": "Geändert",
-            "synced": "Synchronisiert",
-            "deleted": "Gelöscht"
-        }
-    },
-    "tooltips": {
-        "xaifileid": "Externe XAI File ID für dieses Dokument",
-        "syncStatus": "Synchronisierungsstatus mit XAI"
-    }
-}

custom/Espo/Custom/Resources/i18n/de_DE/CAIKnowledgeDokumente.json

@@ -1,31 +1,30 @@
 {
-    "labels": {
-        "Create CAIKnowledgeCDokumente": "AI Knowledge-Dokument Verknüpfung erstellen",
-        "CAIKnowledgeCDokumente": "AI Knowledge-Dokument Verknüpfung"
-    },
     "fields": {
         "cAIKnowledge": "AI Knowledge",
-        "cAIKnowledgeId": "AI Knowledge ID",
         "cDokumente": "Dokument",
-        "cDokumenteId": "Dokument ID",
         "aiDocumentId": "AI Dokument-ID",
         "syncstatus": "Sync-Status",
         "lastSync": "Letzte Synchronisation",
         "syncedHash": "Sync-Hash"
     },
+    "links": {
+        "cAIKnowledge": "AI Knowledge",
+        "cDokumente": "Dokument"
+    },
+    "labels": {
+        "Create CAIKnowledgeCDokumente": "Verknüpfung erstellen"
+    },
     "options": {
         "syncstatus": {
             "new": "Neu",
-            "unclean": "Unklar",
+            "unclean": "Geändert",
             "synced": "Synchronisiert",
-            "failed": "Fehlgeschlagen",
+            "failed": "Fehler",
             "unsupported": "Nicht unterstützt"
         }
     },
     "tooltips": {
         "aiDocumentId": "Externe AI-Dokument-Referenz-ID",
-        "syncstatus": "Status der Synchronisation mit externem AI-System",
-        "lastSync": "Zeitpunkt der letzten erfolgreichen Synchronisation",
-        "syncedHash": "Hash-Wert des zuletzt synchronisierten Dokument-Zustands (zur Änderungserkennung)"
+        "syncedHash": "Hash-Wert des zuletzt synchronisierten Dokument-Zustands"
     }
 }

custom/Espo/Custom/Resources/i18n/de_DE/CDokumente.json

@@ -2,10 +2,7 @@
     "fields": {
         "dokument": "Download",
         "preview": "Vorschau",
-        "ydocumentuuid": "Y-Document-UUID",
-        "md5sum": "MD5-Prüfsumme",
-        "sha256": "SHA256-Prüfsumme",
-        "fileStatus": "Datei-Status",
+        "blake3hash": "Blake3-Hash",
         "contactsvmhdokumente": "Freigegebene Nutzer",
         "vmhMietverhltnisesDokumente": "Mietverhältnisse",
         "vmhErstgespraechsdokumente": "Erstgespräche",
@@ -41,13 +38,6 @@
         "Create CDokumente": "Dokument erstellen"
     },
     "tooltips": {
-        "fileStatus": "Status der Datei: new = neu hochgeladen, changed = geändert, synced = synchronisiert"
-    },
-    "options": {
-        "fileStatus": {
-            "new": "Neu",
-            "changed": "Geändert",
-            "synced": "Synchronisiert"
-        }
+        "blake3hash": "Kryptografischer Blake3-Hash der Datei (schneller und sicherer als MD5/SHA256)"
     }
 }

custom/Espo/Custom/Resources/i18n/en_US/CAICollectionCDokumente.json

@@ -1,31 +0,0 @@
-{
-    "labels": {
-        "Create CAICollectionCDokumente": "Create AI Collection Document Link",
-        "CAICollectionCDokumente": "AI Collection Document Links"
-    },
-    "fields": {
-        "cAICollection": "AI Collection",
-        "cAICollectionId": "AI Collection ID",
-        "cDokumente": "Document",
-        "cDokumenteId": "Document ID",
-        "xaifileid": "XAI File ID",
-        "syncStatus": "Sync Status",
-        "deleted": "Deleted"
-    },
-    "links": {
-        "cAICollection": "AI Collection",
-        "cDokumente": "Document"
-    },
-    "options": {
-        "syncStatus": {
-            "new": "New",
-            "changed": "Changed",
-            "synced": "Synced",
-            "deleted": "Deleted"
-        }
-    },
-    "tooltips": {
-        "xaifileid": "External XAI file ID for this document",
-        "syncStatus": "Synchronization status with XAI"
-    }
-}

custom/Espo/Custom/Resources/i18n/en_US/CAIKnowledgeCDokumente.json

@@ -1,31 +0,0 @@
-{
-    "labels": {
-        "Create CAIKnowledgeCDokumente": "Create AI Knowledge-Document Link",
-        "CAIKnowledgeCDokumente": "AI Knowledge-Document Link"
-    },
-    "fields": {
-        "cAIKnowledge": "AI Knowledge",
-        "cAIKnowledgeId": "AI Knowledge ID",
-        "cDokumente": "Document",
-        "cDokumenteId": "Document ID",
-        "aiDocumentId": "AI Document ID",
-        "syncstatus": "Sync Status",
-        "lastSync": "Last Synchronization",
-        "syncedHash": "Sync Hash"
-    },
-    "options": {
-        "syncstatus": {
-            "new": "New",
-            "unclean": "Unclean",
-            "synced": "Synced",
-            "failed": "Failed",
-            "unsupported": "Unsupported"
-        }
-    },
-    "tooltips": {
-        "aiDocumentId": "External AI document reference ID",
-        "syncstatus": "Synchronization status with external AI system",
-        "lastSync": "Timestamp of the last successful synchronization",
-        "syncedHash": "Hash value of the last synchronized document state (for change detection)"
-    }
-}

custom/Espo/Custom/Resources/i18n/en_US/CAIKnowledgeDokumente.json

@@ -0,0 +1,30 @@
+{
+    "fields": {
+        "cAIKnowledge": "AI Knowledge",
+        "cDokumente": "Document",
+        "aiDocumentId": "AI Document ID",
+        "syncstatus": "Sync Status",
+        "lastSync": "Last Sync",
+        "syncedHash": "Synced Hash"
+    },
+    "links": {
+        "cAIKnowledge": "AI Knowledge",
+        "cDokumente": "Document"
+    },
+    "labels": {
+        "Create CAIKnowledgeCDokumente": "Create Link"
+    },
+    "options": {
+        "syncstatus": {
+            "new": "New",
+            "unclean": "Changed",
+            "synced": "Synced",
+            "failed": "Failed",
+            "unsupported": "Unsupported"
+        }
+    },
+    "tooltips": {
+        "aiDocumentId": "External AI document reference ID",
+        "syncedHash": "Hash value of last synced document state"
+    }
+}

custom/Espo/Custom/Resources/i18n/en_US/CDokumente.json

@@ -1,21 +1,17 @@
 {
     "fields": {
         "dokument": "Download",
-        "ydocumentuuid": "Y-Document-UUID",
         "preview": "Preview",
         "contactsvmhdokumente": "Portal Users",
         "vmhMietverhltnisesDokumente": "Tenancies",
         "vmhErstgespraechsdokumente": "Initial Consultations",
         "vmhRumungsklagesdokumente": "Eviction Lawsuits",
         "kuendigungDokumente": "Terminations",
-        "md5sum": "MD5 Checksum",
-        "sha256": "SHA256 Checksum",
+        "blake3hash": "Blake3 Hash",
         "beteiligte2dokumente": "Parties",
         "mietobjekt2dokumente": "Properties",
         "mietinkassosdokumente": "Rent Collection",
         "kndigungensdokumente": "Terminations",
-        "fileStatus": "File Status",
-        "advowareAktens": "Advoware Akten",
         "advowareAktens": "Advoware Akten",
         "aIKnowledges": "AI Knowledge",
         "advowareAktenHnr": "Advoware HNR",
@@ -47,13 +43,6 @@
         "listForAIKnowledge": "List for AI Knowledge"
     },
     "tooltips": {
-        "fileStatus": "File status: new = newly uploaded, changed = modified, synced = synchronized"
-    },
-    "options": {
-        "fileStatus": {
-            "new": "New",
-            "changed": "Changed",
-            "synced": "Synchronized"
-        }
+        "blake3hash": "Cryptographic Blake3 hash of the file (faster and more secure than MD5/SHA256)"
     }
 }

custom/Espo/Custom/Resources/layouts/CAIKnowledge/detail.json

@@ -10,6 +10,9 @@
                 }
             ],
             [
+                {
+                    "name": "aktivierungsstatus"
+                },
                 {
                     "name": "syncStatus"
                 },

custom/Espo/Custom/Resources/layouts/CDokumente/detail.json

@@ -40,9 +40,8 @@
         "rows": [
             [
                 {
-                    "name": "ydocumentuuid"
-                },
-                {}
+                    "name": "blake3hash"
+                }
             ]
         ],
         "dynamicLogicVisible": null,
@@ -52,77 +51,6 @@
         "hidden": false,
         "noteText": null,
         "noteStyle": "info",
-        "customLabel": "Externe Identifikatoren"
-    },
-    {
-        "rows": [
-            [
-                {
-                    "name": "fileStatus"
-                },
-                {
-                    "name": "md5sum"
-                }
-            ],
-            [
-                {
-                    "name": "sha256"
-                }
-            ]
-        ],
-        "dynamicLogicVisible": null,
-        "style": "default",
-        "tabBreak": false,
-        "tabLabel": null,
-        "hidden": false,
-        "noteText": null,
-        "noteStyle": "info",
         "customLabel": "Technische Daten"
-    },
-    {
-        "rows": [
-            [
-                {
-                    "name": "aktennr"
-                },
-                {
-                    "name": "syncStatus"
-                },
-                {
-                    "name": "advowareLastSync"
-                }
-            ]
-        ],
-        "dynamicLogicVisible": null,
-        "style": "default",
-        "tabBreak": false,
-        "tabLabel": null,
-        "hidden": false,
-        "noteText": null,
-        "noteStyle": "info",
-        "customLabel": "Advoware Sync"
-    },
-    {
-        "rows": [
-            [
-                {
-                    "name": "xaiId"
-                },
-                {
-                    "name": "xaiCollections"
-                },
-                {
-                    "name": "xaiSyncStatus"
-                }
-            ]
-        ],
-        "dynamicLogicVisible": null,
-        "style": "default",
-        "tabBreak": false,
-        "tabLabel": null,
-        "hidden": false,
-        "noteText": null,
-        "noteStyle": "info",
-        "customLabel": "x.AI Sync"
     }
 ]

custom/Espo/Custom/Resources/metadata/app/api.json

@@ -9,6 +9,21 @@
       "route": "/CPuls/:id/abschliessen-fuer-team",
       "method": "post",
       "actionClassName": "Espo\\Custom\\Api\\CPuls\\AbschliessenFuerTeam"
+    },
+    {
+      "route": "/JunctionData/CAIKnowledge/:knowledgeId/dokumentes",
+      "method": "get",
+      "actionClassName": "Espo\\Custom\\Api\\JunctionData\\GetDokumentes"
+    },
+    {
+      "route": "/JunctionData/CAIKnowledge/:knowledgeId/dokumentes/:documentId",
+      "method": "put",
+      "actionClassName": "Espo\\Custom\\Api\\JunctionData\\UpdateJunction"
+    },
+    {
+      "route": "/JunctionData/CAIKnowledge/:knowledgeId/dokumentes/:documentId",
+      "method": "post",
+      "actionClassName": "Espo\\Custom\\Api\\JunctionData\\LinkDokument"
     }
   ]
 }

custom/Espo/Custom/Resources/metadata/entityDefs/CAICollectionCDokumente.json

@@ -1,87 +0,0 @@
-{
-    "fields": {
-        "id": {
-            "type": "id",
-            "dbType": "bigint",
-            "autoincrement": true
-        },
-        "cAICollection": {
-            "type": "link"
-        },
-        "cAICollectionId": {
-            "type": "varchar",
-            "len": 17,
-            "index": true
-        },
-        "cDokumente": {
-            "type": "link"
-        },
-        "cDokumenteId": {
-            "type": "varchar",
-            "len": 17,
-            "index": true
-        },
-        "xaifileid": {
-            "type": "varchar",
-            "len": 255,
-            "isCustom": true,
-            "tooltip": true,
-            "copyToClipboard": true
-        },
-        "syncStatus": {
-            "type": "enum",
-            "required": false,
-            "options": [
-                "new",
-                "changed",
-                "synced",
-                "deleted"
-            ],
-            "style": {
-                "new": "info",
-                "changed": "warning",
-                "synced": "success",
-                "deleted": "danger"
-            },
-            "default": "new",
-            "isCustom": true,
-            "tooltip": true
-        },
-        "deleted": {
-            "type": "bool",
-            "default": false
-        }
-    },
-    "links": {
-        "cAICollection": {
-            "type": "belongsTo",
-            "entity": "CAICollection"
-        },
-        "cDokumente": {
-            "type": "belongsTo",
-            "entity": "CDokumente"
-        }
-    },
-    "collection": {
-        "orderBy": "id",
-        "order": "desc"
-    },
-    "indexes": {
-        "cAICollectionId": {
-            "columns": ["cAICollectionId"]
-        },
-        "cDokumenteId": {
-            "columns": ["cDokumenteId"]
-        },
-        "xaifileid": {
-            "columns": ["xaifileid"]
-        },
-        "syncStatus": {
-            "columns": ["syncStatus"]
-        },
-        "uniqueRelation": {
-            "type": "unique",
-            "columns": ["cAICollectionId", "cDokumenteId", "deleted"]
-        }
-    }
-}

custom/Espo/Custom/Resources/metadata/entityDefs/CAIKnowledgeDokumente.json

@@ -1,4 +1,5 @@
 {
+    "table": "c_a_i_knowledge_dokumente",
     "fields": {
         "id": {
             "type": "id",
@@ -6,58 +7,58 @@
             "autoincrement": true
         },
         "cAIKnowledge": {
-            "type": "link"
+            "type": "link",
+            "entity": "CAIKnowledge"
         },
         "cAIKnowledgeId": {
             "type": "varchar",
             "len": 17,
             "index": true
         },
+        "cAIKnowledgeName": {
+            "type": "varchar",
+            "notStorable": true,
+            "relation": "cAIKnowledge",
+            "foreign": "name"
+        },
         "cDokumente": {
-            "type": "link"
+            "type": "link",
+            "entity": "CDokumente"
         },
         "cDokumenteId": {
             "type": "varchar",
             "len": 17,
             "index": true
         },
+        "cDokumenteName": {
+            "type": "varchar",
+            "notStorable": true,
+            "relation": "cDokumente",
+            "foreign": "name"
+        },
         "aiDocumentId": {
             "type": "varchar",
             "len": 255,
-            "isCustom": true,
             "tooltip": true
         },
         "syncstatus": {
             "type": "enum",
-            "required": false,
-            "options": [
-                "new",
-                "unclean",
-                "synced",
-                "failed",
-                "unsupported"
-            ],
+            "options": ["new", "unclean", "synced", "failed", "unsupported"],
+            "default": "new",
             "style": {
-                "new": "info",
+                "new": "primary",
                 "unclean": "warning",
                 "synced": "success",
                 "failed": "danger",
                 "unsupported": "default"
-            },
-            "default": "new",
-            "isCustom": true,
-            "tooltip": true
+            }
         },
         "lastSync": {
-            "type": "datetime",
-            "required": false,
-            "isCustom": true,
-            "tooltip": true
+            "type": "datetime"
         },
         "syncedHash": {
             "type": "varchar",
             "len": 64,
-            "isCustom": true,
             "tooltip": true
         },
         "deleted": {
@@ -68,30 +69,17 @@
     "links": {
         "cAIKnowledge": {
             "type": "belongsTo",
-            "entity": "CAIKnowledge"
+            "entity": "CAIKnowledge",
+            "foreign": "dokumentes"
         },
         "cDokumente": {
             "type": "belongsTo",
-            "entity": "CDokumente"
+            "entity": "CDokumente",
+            "foreign": "aIKnowledges"
         }
     },
     "collection": {
         "orderBy": "id",
-        "order": "desc"
-    },
-    "indexes": {
-        "cAIKnowledgeId": {
-            "columns": ["cAIKnowledgeId"]
-        },
-        "cDokumenteId": {
-            "columns": ["cDokumenteId"]
-        },
-        "syncstatus": {
-            "columns": ["syncstatus"]
-        },
-        "uniqueRelation": {
-            "type": "unique",
-            "columns": ["cAIKnowledgeId", "cDokumenteId", "deleted"]
-        }
+        "order": "asc"
     }
 }

custom/Espo/Custom/Resources/metadata/entityDefs/CDokumente.json

@@ -45,13 +45,6 @@
             "isCustom": true,
             "audited": true
         },
-        "ydocumentuuid": {
-            "type": "varchar",
-            "maxLength": 100,
-            "readOnlyAfterCreate": true,
-            "options": [],
-            "isCustom": true
-        },
         "preview": {
             "type": "image",
             "previewSize": "medium",
@@ -59,80 +52,67 @@
             "readOnlyAfterCreate": false,
             "isCustom": true
         },
-        "md5sum": {
-            "type": "varchar",
-            "maxLength": 32,
-            "copyToClipboard": true,
-            "readOnlyAfterCreate": true,
-            "options": [],
-            "isCustom": true
-        },
-        "sha256": {
+        "blake3hash": {
             "type": "varchar",
             "maxLength": 64,
-            "readOnlyAfterCreate": true,
+            "copyToClipboard": true,
+            "readOnlyAfterCreate": false,
             "options": [],
             "isCustom": true,
-            "copyToClipboard": true
+            "tooltip": true
         },
         "puls": {
             "type": "link",
             "entity": "CPuls",
             "isCustom": true
         },
-        "fileStatus": {
-            "type": "enum",
-            "required": false,
-            "options": [
-                "new",
-                "changed",
-                "synced"
-            ],
-            "style": {
-                "new": "info",
-                "changed": "warning",
-                "synced": "success"
-            },
-            "default": "new",
-            "readOnly": false,
-            "tooltip": true,
-            "isCustom": true
-        },
         "advowareAktenHnr": {
             "type": "int",
             "notStorable": true,
             "utility": true,
-            "layoutAvailabilityList": ["listForAdvowareAkten"]
+            "layoutAvailabilityList": [
+                "listForAdvowareAkten"
+            ]
         },
         "advowareAktenSyncstatus": {
             "type": "varchar",
             "notStorable": true,
             "utility": true,
-            "layoutAvailabilityList": ["listForAdvowareAkten"]
+            "layoutAvailabilityList": [
+                "listForAdvowareAkten"
+            ]
         },
         "advowareAktenLastSync": {
             "type": "datetime",
             "notStorable": true,
             "utility": true,
-            "layoutAvailabilityList": ["listForAdvowareAkten"]
+            "layoutAvailabilityList": [
+                "listForAdvowareAkten"
+            ]
         },
         "aiKnowledgeAiDocumentId": {
             "type": "varchar",
             "notStorable": true,
             "utility": true,
-            "layoutAvailabilityList": ["listForAIKnowledge"]
+            "layoutAvailabilityList": [
+                "listForAIKnowledge"
+            ]
         },
         "aiKnowledgeSyncstatus": {
             "type": "varchar",
             "notStorable": true,
             "utility": true,
-            "layoutAvailabilityList": ["listForAIKnowledge"]
+            "layoutAvailabilityList": [
+                "listForAIKnowledge"
+            ]
         },
         "aiKnowledgeLastSync": {
             "type": "datetime",
             "notStorable": true,
             "utility": true,
-            "layoutAvailabilityList": ["listForAIKnowledge"]
+            "layoutAvailabilityList": [
+                "listForAIKnowledge"
+            ]
         }
     },
     "links": {
@@ -298,14 +278,9 @@
                 "id"
             ]
         },
-        "md5sum": {
+        "blake3hash": {
             "columns": [
-                "md5sum"
-            ]
-        },
-        "sha256": {
-            "columns": [
-                "sha256"
+                "blake3hash"
             ]
         }
     },

custom/Espo/Custom/Resources/metadata/formula/CDokumente.json

@@ -1,3 +1,3 @@
 {
-    "beforeSaveScript": "// Automatische x.AI Sync-Status Verwaltung\n\n// Fall 1: xaiId wurde gelöscht (war vorher vorhanden, jetzt leer)\nif (\n    attribute\\fetched('xaiId') != null &&\n    xaiId == null\n) {\n    xaiSyncStatus = 'no_sync';\n}\n// Fall 2: xaiId wird neu gesetzt (war vorher leer, jetzt gefüllt)\nelse if (\n    attribute\\fetched('xaiId') == null &&\n    xaiId != null\n) {\n    xaiSyncStatus = 'pending_sync';\n}\n// Fall 3: Dokument hat xaiId und relevante Felder haben sich geändert\nelse if (\n    xaiId != null &&\n    xaiSyncStatus != 'no_sync' &&\n    (\n        attribute\\isChanged('name') ||\n        attribute\\isChanged('description') ||\n        attribute\\isChanged('dokumentId') ||\n        attribute\\isChanged('md5sum') ||\n        attribute\\isChanged('sha256')\n    )\n) {\n    xaiSyncStatus = 'unclean';\n}\n// Fall 4: Bei neuem Dokument MIT xaiId → pending_sync\nelse if (\n    entity\\isNew() &&\n    xaiId != null\n) {\n    xaiSyncStatus = 'pending_sync';\n}\n// Fall 5: Bei neuem Dokument OHNE xaiId → no_sync\nelse if (\n    entity\\isNew() &&\n    xaiId == null\n) {\n    xaiSyncStatus = 'no_sync';\n}\n\n// Automatische Advoware Sync-Status Verwaltung\n\n// Fall 1: aktennr wurde gelöscht (war vorher vorhanden, jetzt leer)\nif (\n    attribute\\fetched('aktennr') != null &&\n    aktennr == null\n) {\n    syncStatus = 'no_sync';\n}\n// Fall 2: aktennr wird neu gesetzt (war vorher leer, jetzt gefüllt)\nelse if (\n    attribute\\fetched('aktennr') == null &&\n    aktennr != null\n) {\n    syncStatus = 'pending_sync';\n}\n// Fall 3: Dokument hat aktennr und relevante Felder haben sich geändert\nelse if (\n    aktennr != null &&\n    syncStatus != 'no_sync' &&\n    (\n        attribute\\isChanged('name') ||\n        attribute\\isChanged('description') ||\n        attribute\\isChanged('dokumentId') ||\n        attribute\\isChanged('md5sum') ||\n        attribute\\isChanged('sha256')\n    )\n) {\n    syncStatus = 'unclean';\n}\n// Fall 4: Bei neuem Dokument MIT aktennr → pending_sync\nelse if (\n    entity\\isNew() &&\n    aktennr != null\n) {\n    syncStatus = 'pending_sync';\n}\n// Fall 5: Bei neuem Dokument OHNE aktennr → no_sync\nelse if (\n    entity\\isNew() &&\n    aktennr == null\n) {\n    syncStatus = 'no_sync';\n}"
+    "beforeSaveScript": "// Automatische x.AI Sync-Status Verwaltung\n\n// Fall 1: xaiId wurde gelöscht (war vorher vorhanden, jetzt leer)\nif (\n    attribute\\fetched('xaiId') != null &&\n    xaiId == null\n) {\n    xaiSyncStatus = 'no_sync';\n}\n// Fall 2: xaiId wird neu gesetzt (war vorher leer, jetzt gefüllt)\nelse if (\n    attribute\\fetched('xaiId') == null &&\n    xaiId != null\n) {\n    xaiSyncStatus = 'pending_sync';\n}\n// Fall 3: Dokument hat xaiId und relevante Felder haben sich geändert\nelse if (\n    xaiId != null &&\n    xaiSyncStatus != 'no_sync' &&\n    (\n        attribute\\isChanged('name') ||\n        attribute\\isChanged('description') ||\n        attribute\\isChanged('dokumentId') ||\n        attribute\\isChanged('blake3hash')\n    )\n) {\n    xaiSyncStatus = 'unclean';\n}\n// Fall 4: Bei neuem Dokument MIT xaiId → pending_sync\nelse if (\n    entity\\isNew() &&\n    xaiId != null\n) {\n    xaiSyncStatus = 'pending_sync';\n}\n// Fall 5: Bei neuem Dokument OHNE xaiId → no_sync\nelse if (\n    entity\\isNew() &&\n    xaiId == null\n) {\n    xaiSyncStatus = 'no_sync';\n}\n\n// Automatische Advoware Sync-Status Verwaltung\n\n// Fall 1: aktennr wurde gelöscht (war vorher vorhanden, jetzt leer)\nif (\n    attribute\\fetched('aktennr') != null &&\n    aktennr == null\n) {\n    syncStatus = 'no_sync';\n}\n// Fall 2: aktennr wird neu gesetzt (war vorher leer, jetzt gefüllt)\nelse if (\n    attribute\\fetched('aktennr') == null &&\n    aktennr != null\n) {\n    syncStatus = 'pending_sync';\n}\n// Fall 3: Dokument hat aktennr und relevante Felder haben sich geändert\nelse if (\n    aktennr != null &&\n    syncStatus != 'no_sync' &&\n    (\n        attribute\\isChanged('name') ||\n        attribute\\isChanged('description') ||\n        attribute\\isChanged('dokumentId') ||\n        attribute\\isChanged('blake3hash')\n    )\n) {\n    syncStatus = 'unclean';\n}\n// Fall 4: Bei neuem Dokument MIT aktennr → pending_sync\nelse if (\n    entity\\isNew() &&\n    aktennr != null\n) {\n    syncStatus = 'pending_sync';\n}\n// Fall 5: Bei neuem Dokument OHNE aktennr → no_sync\nelse if (\n    entity\\isNew() &&\n    aktennr == null\n) {\n    syncStatus = 'no_sync';\n}"
 }

custom/Espo/Custom/Resources/metadata/scopes/CAIKnowledgeCDokumente.json

@@ -1,10 +0,0 @@
-{
-    "entity": true,
-    "type": "Base",
-    "module": "Custom",
-    "object": true,
-    "isCustom": true,
-    "tab": false,
-    "acl": true,
-    "disabled": false
-}

custom/Espo/Custom/Resources/metadata/scopes/CAIKnowledgeDokumente.json

@@ -1,10 +1,11 @@
 {
     "entity": true,
-    "type": "Base",
-    "module": "Custom",
-    "object": true,
-    "isCustom": true,
+    "object": false,
+    "layouts": false,
     "tab": false,
     "acl": true,
-    "disabled": false
+    "customizable": false,
+    "type": "Base",
+    "module": "Custom",
+    "isCustom": true
 }

custom/Espo/Custom/Resources/metadata/scopes/CAdvowareAkten.json

@@ -16,7 +16,7 @@
     "notifications": true,
     "stream": true,
     "disabled": false,
-    "type": "BasePlus",
+    "type": "Base",
     "module": "Custom",
     "object": true,
     "isCustom": true,

custom/Espo/Custom/Resources/routes.json

@@ -0,0 +1,17 @@
+[
+    {
+        "route": "/JunctionData/CAIKnowledge/:knowledgeId/dokumentes",
+        "method": "get",
+        "actionClassName": "Espo\\Custom\\Api\\JunctionData\\GetDokumentes"
+    },
+    {
+        "route": "/JunctionData/CAIKnowledge/:knowledgeId/dokumentes/:documentId",
+        "method": "put",
+        "actionClassName": "Espo\\Custom\\Api\\JunctionData\\UpdateJunction"
+    },
+    {
+        "route": "/JunctionData/CAIKnowledge/:knowledgeId/dokumentes/:documentId",
+        "method": "post",
+        "actionClassName": "Espo\\Custom\\Api\\JunctionData\\LinkDokument"
+    }
+]

custom/Espo/Custom/Services/CAICollectionCDokumente.php

@@ -1,14 +0,0 @@
-<?php
-namespace Espo\Custom\Services;
-
-use Espo\Services\Record;
-
-/**
- * Junction Service: CAICollection ↔ CDokumente
- * 
- * Handles business logic for the junction table.
- */
-class CAICollectionCDokumente extends Record
-{
-    // Standard CRUD logic inherited from Record service
-}

custom/Espo/Custom/Services/CAIKnowledgeCDokumente.php

@@ -1,14 +0,0 @@
-<?php
-namespace Espo\Custom\Services;
-
-use Espo\Services\Record;
-
-/**
- * Junction Service: CAIKnowledge ↔ CDokumente
- * 
- * Handles business logic for the junction table.
- */
-class CAIKnowledgeCDokumente extends Record
-{
-    // Standard CRUD logic inherited from Record service
-}

custom/scripts/install_blake3.sh

@@ -0,0 +1,87 @@
+#!/bin/bash
+# Blake3 PHP Extension Installation Script
+# Für EspoCRM Docker Container
+
+set -e  # Beende bei Fehler
+
+echo "========================================="
+echo "Blake3 PHP Extension Installation"
+echo "========================================="
+
+# Schritt 1: Build-Tools installieren
+echo ""
+echo "Schritt 1: Installiere Build-Tools..."
+apt-get update
+apt-get install -y \
+    git \
+    build-essential \
+    autoconf \
+    automake \
+    libtool \
+    pkg-config \
+    curl \
+    libcurl4-openssl-dev
+
+# PHP-Dev ist bereits im Image vorhanden
+echo "PHP Development headers: $(php-config --version)"
+
+# Schritt 2: Blake3 C-Bibliothek klonen
+echo ""
+echo "Schritt 2: Lade Blake3 C-Bibliothek..."
+cd /tmp
+rm -rf BLAKE3 php-blake3
+git clone https://github.com/BLAKE3-team/BLAKE3.git
+cd BLAKE3/c
+gcc -shared -O3 -o libblake3.so blake3.c blake3_dispatch.c blake3_portable.c blake3_sse2_x86-64_unix.S blake3_sse41_x86-64_unix.S blake3_avx2_x86-64_unix.S blake3_avx512_x86-64_unix.S -fPIC
+cp libblake3.so /usr/local/lib/
+ldconfig
+
+# Schritt 3: PHP Blake3 Extension klonen und kompilieren
+echo ""
+echo "Schritt 3: Kompiliere PHP Blake3 Extension..."
+cd /tmp
+git clone https://github.com/cypherbits/php-blake3.git
+cd php-blake3
+
+phpize
+./configure
+make
+make install
+
+# Schritt 4: Extension aktivieren
+echo ""
+echo "Schritt 4: Aktiviere Blake3 Extension..."
+PHP_INI_DIR=$(php -i | grep "Scan this dir for additional .ini files" | cut -d'>' -f2 | xargs)
+if [ -z "$PHP_INI_DIR" ]; then
+    PHP_INI_DIR="/usr/local/etc/php/conf.d"
+fi
+
+echo "extension=blake3.so" > ${PHP_INI_DIR}/99-blake3.ini
+
+# Schritt 5: Verifizierung
+echo ""
+echo "Schritt 5: Verifiziere Installation..."
+php -m | grep -i blake3
+if [ $? -eq 0 ]; then
+    echo "✅ Blake3 Extension erfolgreich installiert!"
+    php -r "echo 'Test Hash: ' . hash('blake3', 'test') . PHP_EOL;"
+else
+    echo "❌ Blake3 Extension nicht geladen!"
+    exit 1
+fi
+
+# Cleanup
+echo ""
+echo "Schritt 6: Aufräumen..."
+cd /
+rm -rf /tmp/BLAKE3 /tmp/php-blake3
+
+echo ""
+echo "========================================="
+echo "✅ Installation abgeschlossen!"
+echo "========================================="
+echo ""
+echo "Nächste Schritte:"
+echo "1. Starte PHP-FPM neu: service php8.4-fpm restart || pkill -USR2 php-fpm"
+echo "2. Überprüfe: php -m | grep blake3"
+echo "3. Teste: php -r \"echo hash('blake3', 'test');\""

data/config.php

@@ -360,7 +360,7 @@ return [
     0 => 'youtube.com',
     1 => 'google.com'
   ],
-  'microtime' => 1773262547.930204,
+  'microtime' => 1773351315.93688,
   'siteUrl' => 'https://crm.bitbylaw.com',
   'fullTextSearchMinLength' => 4,
   'webSocketUrl' => 'ws://api.bitbylaw.com:5000/espocrm/ws',

data/state.php

@@ -1,7 +1,7 @@
 <?php
 return [
-  'cacheTimestamp' => 1773262548,
-  'microtimeState' => 1773262548.062426,
+  'cacheTimestamp' => 1773351316,
+  'microtimeState' => 1773351316.064287,
   'currencyRates' => [
     'EUR' => 1.0
   ],