diff --git a/doc/PROMTS/prompt-create_model_de.md b/doc/PROMTS/prompt-create_model_de.md new file mode 100644 index 0000000..dd2acf5 --- /dev/null +++ b/doc/PROMTS/prompt-create_model_de.md @@ -0,0 +1,53 @@ +Du bist Geschäftsprozess Architekt und Modellier. Deine Aufgabe ist es Prozessmodelle zu erstellen. + +Unsere Software basiert auf BPMN 2.0. Wir modellieren Geschäftsprozesse nach folgemden Prinzip: + +**Process** - der Workflow wird jeweils in einem eigenen BPMN Pool abgebildet. Der Prozessname (Name des Pools) bezeichnet den Workflow. + +**Tasks** - bilden die Zustaände in einem Prozess ab die üblicherweise von einem Mitarbeiter im Unternehmen verantwortet werden. Z.b. 'Rechnung erstellen', 'Rechnung prüfen', 'Zahlungseingang buchen'. +Tasks werden innerhalb der Sofware als individuelle Aufgaben für den User in einer Taskliste angezeigt. Jeder Task hat eine eindeutige ID. + +**Events** - werden bei uns genutzt um den Übergang von einem Task in einen anderen zu beschreiben. Ein Event ist damit die Aktion die der Mitarbeiter ausführt. Z.b. 'Rechnung weiterleiten', 'Prüfung ablehnen', 'Buchung abschließen'. +Jedes Event das einem Task zugeordnet ist hat innerhalb dieses Tasks eine eindeutige ID. + +Wir stellen den Prozessablauf textuell stark vereinfacht dar. Diese Darstellung dient dem BPMN Modellierer einen Prozess in unserem Tool zu erstellen. + + + +Beispiel: + +Business Process: Product + +START + | + |- [Task: 1000] Imported + | |-- [Event: 10] Update --> [Task: 1000] Imported + | |-- [Event: 50] (RAG) --> [Task: 1200] In Stock + | + |- [Task: 1200] In Stock + | |-- [Event: 10] Update --> [Task: 1200] In Stock + | |-- [Event: 105] Reindex --> [Task: 1000] Imported + | |-- [Event: 20] Ordered --> [Task: 1400] Ordered + | |-- [Event: 30] Not in Stock --> [Task: 1500] Not in Stock + | |-- [Event: 990] [CSV Import] --> [Task: 1000] Imported + | + |- [Task: 1400] Ordered + | |-- [Event: 10] Update --> [Task: 1400] Ordered + | |-- [Event: 20] Delievered --> [Task: 1000] Imported + | |-- [Event: 99] [Wiedervorlage] --> [Task: 1400] Ordered + | + |- [Task: 1500] Not in Stock + | |-- [Event: 10] Update --> [Task: 1500] Not in Stock + | |-- [Event: 20] Delievered --> [Task: 1000] Imported + | |-- [Event: 30] Delete --> [Task: 1990] Deleted + | + END + | + |- [Task: 1990] Deleted + | + + + +Erstelle einen neuen Prozess für eine "Supplier Compliance Prüfung" innerhalb eines Lieferkettenprozesses für ein großes Export Unternehmen. +Erstelle eine formatierte Text Datei für den Ablauf + diff --git a/doc/PROMTS/result-chatgpt.txt b/doc/PROMTS/result-chatgpt.txt new file mode 100644 index 0000000..8de3c3e --- /dev/null +++ b/doc/PROMTS/result-chatgpt.txt @@ -0,0 +1,50 @@ +START + | + |- [Task: 1000] Supplier angelegt + | |-- [Event: 10] Stammdaten aktualisieren --> [Task: 1000] Supplier angelegt + | |-- [Event: 20] Compliance-Prüfung starten --> [Task: 1100] Compliance-Prüfung in Vorbereitung + | + |- [Task: 1100] Compliance-Prüfung in Vorbereitung + | |-- [Event: 10] Prüfumfang anpassen --> [Task: 1100] Compliance-Prüfung in Vorbereitung + | |-- [Event: 30] Dokumente anfordern --> [Task: 1200] Dokumente angefordert + | |-- [Event: 40] Prüfung abbrechen --> [Task: 1900] Prüfung abgebrochen + | + |- [Task: 1200] Dokumente angefordert + | |-- [Event: 10] Erinnerung senden --> [Task: 1200] Dokumente angefordert + | |-- [Event: 20] Dokumente erhalten --> [Task: 1300] Dokumente eingegangen + | |-- [Event: 99] [Wiedervorlage] --> [Task: 1200] Dokumente angefordert + | + |- [Task: 1300] Dokumente eingegangen + | |-- [Event: 10] Dokumente aktualisieren --> [Task: 1300] Dokumente eingegangen + | |-- [Event: 30] Formale Prüfung durchführen --> [Task: 1400] Formale Prüfung + | + |- [Task: 1400] Formale Prüfung + | |-- [Event: 10] Prüfung wiederholen --> [Task: 1400] Formale Prüfung + | |-- [Event: 20] Formal unvollständig --> [Task: 1250] Nachforderung Dokumente + | |-- [Event: 30] Formal korrekt --> [Task: 1500] Inhaltliche Compliance-Prüfung + | + |- [Task: 1250] Nachforderung Dokumente + | |-- [Event: 10] Nachforderung senden --> [Task: 1200] Dokumente angefordert + | + |- [Task: 1500] Inhaltliche Compliance-Prüfung + | |-- [Event: 10] Prüfung vertiefen --> [Task: 1500] Inhaltliche Compliance-Prüfung + | |-- [Event: 20] Compliance erfüllt --> [Task: 1600] Supplier freigegeben + | |-- [Event: 30] Abweichungen festgestellt --> [Task: 1700] Abweichungen klären + | |-- [Event: 40] Kritischer Verstoß --> [Task: 1800] Supplier gesperrt + | + |- [Task: 1700] Abweichungen klären + | |-- [Event: 10] Maßnahmen anfordern --> [Task: 1700] Abweichungen klären + | |-- [Event: 20] Maßnahmen akzeptiert --> [Task: 1600] Supplier freigegeben + | |-- [Event: 30] Maßnahmen abgelehnt --> [Task: 1800] Supplier gesperrt + | + |- [Task: 1600] Supplier freigegeben + | |-- [Event: 10] Freigabe aktualisieren --> [Task: 1600] Supplier freigegeben + | |-- [Event: 90] Re-Compliance-Prüfung starten --> [Task: 1100] Compliance-Prüfung in Vorbereitung + | + |- [Task: 1800] Supplier gesperrt + | |-- [Event: 10] Sperrung prüfen --> [Task: 1800] Supplier gesperrt + | |-- [Event: 20] Sperrung aufheben --> [Task: 1100] Compliance-Prüfung in Vorbereitung + | + END + | + |- [Task: 1900] Prüfung abgebrochen diff --git a/doc/PROMTS/result-claude.txt b/doc/PROMTS/result-claude.txt new file mode 100644 index 0000000..adb9bc5 --- /dev/null +++ b/doc/PROMTS/result-claude.txt @@ -0,0 +1,178 @@ +================================================================================ +BUSINESS PROCESS: Supplier Compliance Prüfung +================================================================================ +Beschreibung: Workflow zur Prüfung und Freigabe von Lieferanten gemäß + Export-Compliance-Anforderungen (Sanktionslisten, Zertifikate, + Dual-Use-Prüfung, Qualitätsstandards) +================================================================================ + +START + | + |- [Task: 1000] Lieferant erfasst + | |-- [Event: 10] Update --> [Task: 1000] Lieferant erfasst + | |-- [Event: 20] Zur Vorprüfung --> [Task: 1100] Vorprüfung + | |-- [Event: 30] Direktablehnung --> [Task: 9000] Abgelehnt + | |-- [Event: 990] [CSV Import] --> [Task: 1000] Lieferant erfasst + | + |- [Task: 1100] Vorprüfung + | |-- [Event: 10] Update --> [Task: 1100] Vorprüfung + | |-- [Event: 20] Stammdaten vollständig --> [Task: 1200] Sanktionsprüfung + | |-- [Event: 30] Daten unvollständig --> [Task: 1050] Datenanforderung + | |-- [Event: 40] Abbrechen --> [Task: 9000] Abgelehnt + | + |- [Task: 1050] Datenanforderung + | |-- [Event: 10] Update --> [Task: 1050] Datenanforderung + | |-- [Event: 20] Daten erhalten --> [Task: 1100] Vorprüfung + | |-- [Event: 30] Keine Rückmeldung --> [Task: 9000] Abgelehnt + | |-- [Event: 99] [Wiedervorlage] --> [Task: 1050] Datenanforderung + | + |- [Task: 1200] Sanktionsprüfung + | |-- [Event: 10] Update --> [Task: 1200] Sanktionsprüfung + | |-- [Event: 20] Keine Treffer --> [Task: 1300] Export-Kontrollprüfung + | |-- [Event: 30] Treffer gefunden --> [Task: 1250] Sanktionstreffer Klärung + | |-- [Event: 40] (API Sanktionsliste) --> [Task: 1200] Sanktionsprüfung + | + |- [Task: 1250] Sanktionstreffer Klärung + | |-- [Event: 10] Update --> [Task: 1250] Sanktionstreffer Klärung + | |-- [Event: 20] False Positive bestätigt --> [Task: 1300] Export-Kontrollprüfung + | |-- [Event: 30] Treffer bestätigt --> [Task: 9100] Gesperrt + | |-- [Event: 40] Eskalation --> [Task: 1260] Compliance Officer Review + | + |- [Task: 1260] Compliance Officer Review + | |-- [Event: 10] Update --> [Task: 1260] Compliance Officer Review + | |-- [Event: 20] Freigabe erteilt --> [Task: 1300] Export-Kontrollprüfung + | |-- [Event: 30] Sperrung angeordnet --> [Task: 9100] Gesperrt + | + |- [Task: 1300] Export-Kontrollprüfung + | |-- [Event: 10] Update --> [Task: 1300] Export-Kontrollprüfung + | |-- [Event: 20] Keine Einschränkungen --> [Task: 1400] Dokumentenprüfung + | |-- [Event: 30] Dual-Use relevant --> [Task: 1350] Dual-Use Bewertung + | |-- [Event: 40] Embargo betroffen --> [Task: 9100] Gesperrt + | + |- [Task: 1350] Dual-Use Bewertung + | |-- [Event: 10] Update --> [Task: 1350] Dual-Use Bewertung + | |-- [Event: 20] Genehmigung vorhanden --> [Task: 1400] Dokumentenprüfung + | |-- [Event: 30] Genehmigung erforderlich --> [Task: 1360] Genehmigungsantrag + | |-- [Event: 40] Nicht genehmigungsfähig --> [Task: 9000] Abgelehnt + | + |- [Task: 1360] Genehmigungsantrag + | |-- [Event: 10] Update --> [Task: 1360] Genehmigungsantrag + | |-- [Event: 20] Genehmigung erteilt --> [Task: 1400] Dokumentenprüfung + | |-- [Event: 30] Genehmigung abgelehnt --> [Task: 9000] Abgelehnt + | |-- [Event: 99] [Wiedervorlage] --> [Task: 1360] Genehmigungsantrag + | + |- [Task: 1400] Dokumentenprüfung + | |-- [Event: 10] Update --> [Task: 1400] Dokumentenprüfung + | |-- [Event: 20] Dokumente vollständig --> [Task: 1500] Qualitätsprüfung + | |-- [Event: 30] Dokumente fehlen --> [Task: 1450] Dokumentenanforderung + | |-- [Event: 40] Dokumente ungültig --> [Task: 1450] Dokumentenanforderung + | + |- [Task: 1450] Dokumentenanforderung + | |-- [Event: 10] Update --> [Task: 1450] Dokumentenanforderung + | |-- [Event: 20] Dokumente erhalten --> [Task: 1400] Dokumentenprüfung + | |-- [Event: 30] Frist abgelaufen --> [Task: 9000] Abgelehnt + | |-- [Event: 99] [Wiedervorlage] --> [Task: 1450] Dokumentenanforderung + | + |- [Task: 1500] Qualitätsprüfung + | |-- [Event: 10] Update --> [Task: 1500] Qualitätsprüfung + | |-- [Event: 20] Qualität bestätigt --> [Task: 1600] Freigabeentscheidung + | |-- [Event: 30] Audit erforderlich --> [Task: 1550] Lieferanten-Audit + | |-- [Event: 40] Qualität unzureichend --> [Task: 9000] Abgelehnt + | + |- [Task: 1550] Lieferanten-Audit + | |-- [Event: 10] Update --> [Task: 1550] Lieferanten-Audit + | |-- [Event: 20] Audit bestanden --> [Task: 1600] Freigabeentscheidung + | |-- [Event: 30] Audit nicht bestanden --> [Task: 1560] Maßnahmenplan + | |-- [Event: 40] Audit abgebrochen --> [Task: 9000] Abgelehnt + | |-- [Event: 99] [Wiedervorlage] --> [Task: 1550] Lieferanten-Audit + | + |- [Task: 1560] Maßnahmenplan + | |-- [Event: 10] Update --> [Task: 1560] Maßnahmenplan + | |-- [Event: 20] Maßnahmen umgesetzt --> [Task: 1550] Lieferanten-Audit + | |-- [Event: 30] Maßnahmen abgelehnt --> [Task: 9000] Abgelehnt + | |-- [Event: 99] [Wiedervorlage] --> [Task: 1560] Maßnahmenplan + | + |- [Task: 1600] Freigabeentscheidung + | |-- [Event: 10] Update --> [Task: 1600] Freigabeentscheidung + | |-- [Event: 20] Vollfreigabe --> [Task: 2000] Aktiver Lieferant + | |-- [Event: 30] Bedingte Freigabe --> [Task: 2100] Bedingt freigegeben + | |-- [Event: 40] Ablehnung --> [Task: 9000] Abgelehnt + | + |- [Task: 2000] Aktiver Lieferant + | |-- [Event: 10] Update --> [Task: 2000] Aktiver Lieferant + | |-- [Event: 20] Re-Validierung fällig --> [Task: 3000] Re-Validierung + | |-- [Event: 30] Compliance-Vorfall --> [Task: 3500] Vorfallprüfung + | |-- [Event: 40] Lieferant deaktivieren --> [Task: 9200] Inaktiv + | |-- [Event: 99] [Wiedervorlage] --> [Task: 2000] Aktiver Lieferant + | + |- [Task: 2100] Bedingt freigegeben + | |-- [Event: 10] Update --> [Task: 2100] Bedingt freigegeben + | |-- [Event: 20] Bedingungen erfüllt --> [Task: 2000] Aktiver Lieferant + | |-- [Event: 30] Bedingungen nicht erfüllt --> [Task: 9000] Abgelehnt + | |-- [Event: 40] Re-Validierung fällig --> [Task: 3000] Re-Validierung + | |-- [Event: 99] [Wiedervorlage] --> [Task: 2100] Bedingt freigegeben + | + |- [Task: 3000] Re-Validierung + | |-- [Event: 10] Update --> [Task: 3000] Re-Validierung + | |-- [Event: 20] Validierung bestanden --> [Task: 2000] Aktiver Lieferant + | |-- [Event: 30] Sanktionsprüfung erforderlich --> [Task: 1200] Sanktionsprüfung + | |-- [Event: 40] Dokumentenprüfung erforderlich --> [Task: 1400] Dokumentenprüfung + | |-- [Event: 50] Validierung nicht bestanden --> [Task: 9100] Gesperrt + | + |- [Task: 3500] Vorfallprüfung + | |-- [Event: 10] Update --> [Task: 3500] Vorfallprüfung + | |-- [Event: 20] Vorfall unbegründet --> [Task: 2000] Aktiver Lieferant + | |-- [Event: 30] Vorfall bestätigt --> [Task: 3600] Maßnahmenfestlegung + | |-- [Event: 40] Sofortige Sperrung --> [Task: 9100] Gesperrt + | + |- [Task: 3600] Maßnahmenfestlegung + | |-- [Event: 10] Update --> [Task: 3600] Maßnahmenfestlegung + | |-- [Event: 20] Maßnahmen akzeptiert --> [Task: 2100] Bedingt freigegeben + | |-- [Event: 30] Zusammenarbeit beenden --> [Task: 9100] Gesperrt + | + END + | + |- [Task: 9000] Abgelehnt + | |-- [Event: 10] Update --> [Task: 9000] Abgelehnt + | |-- [Event: 20] Reaktivieren --> [Task: 1000] Lieferant erfasst + | + |- [Task: 9100] Gesperrt + | |-- [Event: 10] Update --> [Task: 9100] Gesperrt + | |-- [Event: 20] Sperrung aufheben --> [Task: 1200] Sanktionsprüfung + | |-- [Event: 30] Endgültig sperren --> [Task: 9900] Blacklist + | + |- [Task: 9200] Inaktiv + | |-- [Event: 10] Update --> [Task: 9200] Inaktiv + | |-- [Event: 20] Reaktivieren --> [Task: 3000] Re-Validierung + | |-- [Event: 30] Archivieren --> [Task: 9990] Archiviert + | + |- [Task: 9900] Blacklist + | + |- [Task: 9990] Archiviert + | + +================================================================================ +LEGENDE +================================================================================ +[Task: XXXX] = Prozessschritt / Zustand mit eindeutiger ID +[Event: XX] = Aktion / Übergang mit eindeutiger ID innerhalb des Tasks +--> = Ziel-Task nach Ausführung des Events +(API ...) = Automatisierter Event (Systemintegration) +[CSV Import] = Massenimport-Event +[Wiedervorlage] = Zeitgesteuertes Erinnerungs-Event + +================================================================================ +TASK-ÜBERSICHT +================================================================================ +1000-1099 Erfassung & Vorprüfung +1100-1199 Vorprüfung +1200-1299 Sanktionsprüfung +1300-1399 Export-Kontrollprüfung +1400-1499 Dokumentenprüfung +1500-1599 Qualitätsprüfung +1600-1699 Freigabeentscheidung +2000-2999 Aktive Lieferanten +3000-3999 Re-Validierung & Vorfallmanagement +9000-9999 Endstatus (Abgelehnt, Gesperrt, Archiviert) + +================================================================================ \ No newline at end of file diff --git a/doc/PROMTS/result-gemini.txt b/doc/PROMTS/result-gemini.txt new file mode 100644 index 0000000..d76ffac --- /dev/null +++ b/doc/PROMTS/result-gemini.txt @@ -0,0 +1,71 @@ +# Business Process: Supplier Compliance Prüfung + +## Pool: Supplier Compliance Prüfung (Workflow-Name) + +### Task: 50 | Prüfung beauftragt (Initialer Zustand) +* **Beschreibung:** Der Prozess ist gestartet und die Compliance-Prüfung wurde initialisiert. +* **Events (Aktionen des Users/Systems):** + * [Event: 10] Aktualisieren --> [Task: 50] Prüfung beauftragt + * [Event: 20] Zuordnung Compliance Manager --> [Task: 100] Compliance Prüfung in Bearbeitung + * [Event: 90] Prozess abbrechen --> [Task: 990] Abgeschlossen - Abgebrochen + +--- + +### Task: 100 | Compliance Prüfung in Bearbeitung (Hauptbearbeitung) +* **Beschreibung:** Der zugewiesene Compliance Manager arbeitet aktiv an der Prüfung, sammelt und bewertet Unterlagen. +* **Events (Aktionen des Users/Systems):** + * [Event: 10] Aktualisieren --> [Task: 100] Compliance Prüfung in Bearbeitung + * [Event: 20] Unterlagen fehlen - Nachforderung --> [Task: 200] Warten auf Unterlagen Lieferant + * [Event: 30] Compliance positiv - Freigeben --> [Task: 500] Compliance Positiv + * [Event: 40] Compliance negativ - Sperren --> [Task: 550] Compliance Negativ - Gesperrt + * [Event: 50] (RAG) Prüfung zur Freigabe --> [Task: 300] Prüfung zur Freigabe Compliance Management + +--- + +### Task: 200 | Warten auf Unterlagen Lieferant (Blockierender Zustand) +* **Beschreibung:** Der Prozess ist blockiert und wartet auf die vom Lieferanten nachzufordernden Dokumente. +* **Events (Aktionen des Users/Systems):** + * [Event: 10] Aktualisieren --> [Task: 200] Warten auf Unterlagen Lieferant + * [Event: 20] Unterlagen erhalten - Fortsetzen --> [Task: 100] Compliance Prüfung in Bearbeitung + * [Event: 30] Eskalation (Fristüberschreitung) --> [Task: 250] Eskalation (Fristüberschreitung) + * [Event: 40] Lieferant nicht kooperativ - Sperren --> [Task: 550] Compliance Negativ - Gesperrt + +--- + +### Task: 250 | Eskalation (Fristüberschreitung) (Entscheidungsbedarf) +* **Beschreibung:** Eine Frist wurde überschritten; eine Führungskraft oder der Einkauf muss eine Entscheidung über das weitere Vorgehen treffen. +* **Events (Aktionen des Users/Systems):** + * [Event: 10] Aktualisieren --> [Task: 250] Eskalation (Fristüberschreitung) + * [Event: 20] Prüfprozess fortsetzen --> [Task: 100] Compliance Prüfung in Bearbeitung + * [Event: 30] Lieferant sofort sperren --> [Task: 550] Compliance Negativ - Gesperrt + +--- + +### Task: 300 | Prüfung zur Freigabe Compliance Management (Vier-Augen-Prinzip) +* **Beschreibung:** Die finale Entscheidung zur Freigabe muss von einer übergeordneten Stelle überprüft und genehmigt werden. +* **Events (Aktionen des Users/Systems):** + * [Event: 10] Aktualisieren --> [Task: 300] Prüfung zur Freigabe Compliance Management + * [Event: 20] Freigabe genehmigen --> [Task: 500] Compliance Positiv + * [Event: 30] Prüfung ablehnen - Zurück zur Bearbeitung --> [Task: 100] Compliance Prüfung in Bearbeitung + +--- + +### Task: 500 | Compliance Positiv (Endzustand - Positiv) +* **Beschreibung:** Die Prüfung ist erfolgreich abgeschlossen, der Lieferant ist freigegeben. +* **Events (Aktionen des Users/Systems):** + * [Event: 10] Abschließen (Archivieren) --> [Task: 900] Abgeschlossen - Positiv + * [Event: 20] Sperre initiieren (Bei neuer Info) --> [Task: 550] Compliance Negativ - Gesperrt + +--- + +### Task: 550 | Compliance Negativ - Gesperrt (Endzustand - Negativ) +* **Beschreibung:** Die Prüfung ist abgeschlossen, der Lieferant ist nicht konform und wurde gesperrt. +* **Events (Aktionen des Users/Systems):** + * [Event: 10] Abschließen (Archivieren) --> [Task: 950] Abgeschlossen - Negativ + * [Event: 20] Re-Evaluierung beauftragen --> [Task: 50] Prüfung beauftragt + +--- + +### Task: 900 | Abgeschlossen - Positiv +### Task: 950 | Abgeschlossen - Negativ +### Task: 990 | Abgeschlossen - Abgebrochen \ No newline at end of file diff --git a/dynamixs-ai-app/src/main/java/ai/dynamixs/ChronicleTextBuilder.java b/dynamixs-ai-app/src/main/java/ai/dynamixs/ChronicleTextBuilder.java new file mode 100644 index 0000000..3b56cf5 --- /dev/null +++ b/dynamixs-ai-app/src/main/java/ai/dynamixs/ChronicleTextBuilder.java @@ -0,0 +1,475 @@ +package ai.dynamixs; + +/******************************************************************************* + * Imixs Workflow Technology + * Copyright (C) 2003, 2008 Imixs Software Solutions GmbH, + * http://www.imixs.com + * + * This program is free software; you can redistribute it and/or + * modify it under the terms of the GNU General Public License + * as published by the Free Software Foundation; either version 2 + * of the License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * General Public License for more details. + * + * You can receive a copy of the GNU General Public + * License at http://www.gnu.org/licenses/gpl.html + * + * Contributors: + * Imixs Software Solutions GmbH - initial API and implementation + * Ralph Soika + * + *******************************************************************************/ + +import java.io.Serializable; +import java.time.LocalDate; +import java.time.LocalDateTime; +import java.time.ZoneId; +import java.time.format.DateTimeFormatter; +import java.time.temporal.ChronoUnit; +import java.util.ArrayList; +import java.util.Collections; +import java.util.Comparator; +import java.util.Date; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Locale; +import java.util.Map; +import java.util.Set; +import java.util.logging.Logger; + +import org.imixs.workflow.FileData; +import org.imixs.workflow.ItemCollection; +import org.imixs.workflow.WorkflowKernel; +import org.imixs.workflow.engine.DocumentService; +import org.imixs.workflow.engine.plugins.HistoryPlugin; +import org.imixs.workflow.office.forms.WorkitemService; + +import jakarta.inject.Inject; + +/** + * The ChronicleTextBuilder creates a text representation of all chronicle data + * for a given workitem. + * + *

+ * The output format is structured by year and month: + * + * 

+ * 2025
+ * 
+ * December
+ * 27. Dec 2025 (14:37) - Ralph Soika
+ * Offer sent
+ * Products are out of stock now!
+ * 
+ * 27. Dec 2025 (14:35) - imixs-workflow-service
+ * Retrieve Products
+ * Retrieve Address
+ *
+ * + *

+ * Usage example: + * + * 

+ * ChronicleTextBuilder builder = new ChronicleTextBuilder(workitem, locale);
+ * builder.setDmsController(dmsController);
+ * builder.setWorkitemLinkController(workitemLinkController);
+ * builder.setWorkitemService(workitemService);
+ * builder.setDocumentService(documentService);
+ * String chronicleText = builder.build();
+ *
+ * + *

+ * The builder supports filtering by entry type (history, comment, dms, + * reference, version, imixs-ai). + * + * @author rsoika + */ +public class ChronicleTextBuilder implements Serializable { + + private static final long serialVersionUID = 1L; + private static Logger logger = Logger.getLogger(ChronicleTextBuilder.class.getName()); + + private ItemCollection workitem; + private Locale locale; + private String filterType; + + @Inject + private WorkitemService workitemService; + + @Inject + private DocumentService documentService; + + // Internal data structures + private List chronicleEntries; + private Map> yearsMonths; + + // Date formatters + private DateTimeFormatter dayFormatter; + private DateTimeFormatter timeFormatter; + private DateTimeFormatter monthFormatter; + + /** + * Constructor with workitem and locale. + * + * @param workitem the workitem to build the chronicle for + * @param locale the locale for date formatting (e.g., Locale.ENGLISH, + * Locale.GERMAN) + */ + public ChronicleTextBuilder(ItemCollection workitem, Locale locale) { + this.workitem = workitem; + this.locale = locale != null ? locale : Locale.ENGLISH; + this.filterType = null; + this.chronicleEntries = new ArrayList<>(); + this.yearsMonths = new HashMap<>(); + + // Initialize date formatters + this.dayFormatter = DateTimeFormatter.ofPattern("d. MMM yyyy", this.locale); + this.timeFormatter = DateTimeFormatter.ofPattern("HH:mm", this.locale); + this.monthFormatter = DateTimeFormatter.ofPattern("MMMM", this.locale); + } + + /** + * Constructor with workitem only (uses English locale as default). + * + * @param workitem the workitem to build the chronicle for + */ + public ChronicleTextBuilder(ItemCollection workitem) { + this(workitem, Locale.ENGLISH); + } + + /** + * Sets a filter to include only entries of a specific type. Valid types: + * history, comment, dms, reference, version, imixs-ai + * + * @param filterType the type to filter by, or null to include all + * @return this builder for method chaining + */ + public ChronicleTextBuilder setFilter(String filterType) { + this.filterType = filterType; + return this; + } + + /** + * Builds and returns the text representation of the chronicle. + * + * @return formatted chronicle text + */ + public String build() { + long startTime = System.currentTimeMillis(); + + if (workitem == null) { + return ""; + } + + // Collect all chronicle data + collectHistoryEntries(); + collectCommentEntries(); + + collectDMSEntries(); + + collectVersionEntries(); + + // Sort entries by date (newest first) + Collections.sort(chronicleEntries, new ChronicleEntryComparator(false)); + + // Build the text output + String result = buildTextOutput(); + + logger.fine("ChronicleTextBuilder.build() completed in " + (System.currentTimeMillis() - startTime) + "ms"); + + return result; + } + + /** + * Collects workflow history entries from the workitem. + */ + @SuppressWarnings("unchecked") + private void collectHistoryEntries() { + List> history = null; + + // Check for deprecated field 'txtworkflowhistory' + if (!workitem.hasItem(HistoryPlugin.ITEM_HISTORY_LOG) + && workitem.hasItem("txtworkflowhistory")) { + history = workitem.getItemValue("txtworkflowhistory"); + // Sort old history entries chronologically + Collections.sort(history, new Comparator>() { + @Override + public int compare(List entry1, List entry2) { + Date date1 = (Date) entry1.get(0); + Date date2 = (Date) entry2.get(0); + return date1.compareTo(date2); + } + }); + } else { + history = workitem.getItemValue(HistoryPlugin.ITEM_HISTORY_LOG); + } + + // Reverse to get newest first + // Collections.reverse(history); + + if (history.size() > 0 && history.get(0) instanceof List) { + for (List entries : history) { + Date date = (Date) entries.get(0); + String message = (String) entries.get(1); + String user = (String) entries.get(2); + addEntry(date, user, message, "history"); + } + } + } + + /** + * Collects comment entries from the workitem. + */ + private void collectCommentEntries() { + List>> comments = workitem.getItemValue("txtCommentLog"); + for (Map> comment : comments) { + ItemCollection itemCol = new ItemCollection(comment); + Date date = itemCol.getItemValueDate("datcomment"); + String message = itemCol.getItemValueString("txtcomment"); + String user = itemCol.getItemValueString("nameditor"); + addEntry(date, user, message, "comment"); + } + } + + /** + * Collects DMS (attachment) entries if dmsController is available. + */ + private void collectDMSEntries() { + + List fileDataList = workitem.getFileData(); + for (FileData fileData : fileDataList) { + + ItemCollection fileAttributes = new ItemCollection(fileData.getAttributes()); + + String content = fileAttributes.getItemValueString("text"); + if (!content.isBlank()) { + String user = fileAttributes.getItemValueString("$creator"); + Date date = fileAttributes.getItemValueDate("$created"); + if (fileData.getAttribute("$modified") != null) { + date = fileAttributes.getItemValueDate("$modified"); + } + if (date == null) { + date = new Date(); + } + addEntry(date, user, "Attachment: " + fileData.getName() + "\n\n" + content + "\n\n", "dms"); + + } + + } + + } + + /** + * Collects version entries if workitemService and documentService are + * available. + */ + private void collectVersionEntries() { + if (workitemService == null || documentService == null) { + return; + } + + List versions = workitemService.findAllVersions(workitem); + for (ItemCollection version : versions) { + // Skip current workitem + if (workitem.getUniqueID().equals(version.getUniqueID())) { + continue; + } + + ItemCollection versionFull = documentService.load(version.getUniqueID()); + Date date = version.getItemValueDate(WorkflowKernel.CREATED); + String message = version.getItemValueString("$WorkflowSummary"); + String user = version.getItemValueString(WorkflowKernel.EDITOR); + + if (!versionFull.getItemValueString("$uniqueIdSource").isEmpty()) { + if (versionFull.hasItem(WorkflowKernel.CREATED + ".version")) { + date = versionFull.getItemValueDate(WorkflowKernel.CREATED + ".version"); + } + message = "Version (Branch): " + message; + } else { + message = "Version: " + message; + } + + addEntry(date, user, message, "version"); + } + } + + /** + * Adds a chronicle entry to the internal list. Applies filter if set and + * updates the year/month index. + */ + private void addEntry(Date date, String user, String message, String type) { + if (date == null) { + return; + } + + // Apply filter if set + if (filterType != null && !filterType.isEmpty() && !filterType.equals(type)) { + return; + } + + // Truncate to minutes + LocalDateTime localDateTime = date.toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime(); + localDateTime = localDateTime.truncatedTo(ChronoUnit.MINUTES); + + ChronicleEntry entry = new ChronicleEntry(localDateTime, user, message, type); + chronicleEntries.add(entry); + + // Update year/month index + LocalDate localDate = localDateTime.toLocalDate(); + int year = localDate.getYear(); + int month = localDate.getMonthValue(); + yearsMonths.computeIfAbsent(year, k -> new HashSet<>()).add(month); + } + + /** + * Builds the formatted text output from collected entries. + */ + private String buildTextOutput() { + StringBuilder sb = new StringBuilder(); + + // Add title + sb.append( + "# " + workitem.getWorkflowGroup() + " : " + workitem.getItemValueString(WorkflowKernel.WORKFLOWSTATUS)) + .append("\n\n"); + + // Get sorted years (descending) + List years = new ArrayList<>(yearsMonths.keySet()); + + for (int i = 0; i < years.size(); i++) { + int year = years.get(i); + + // Year header + // sb.append(year).append("\n\n"); + + // Get sorted months for this year (descending) + List months = new ArrayList<>(yearsMonths.get(year)); + + for (int j = 0; j < months.size(); j++) { + int month = months.get(j); + + // Get entries for this month + List monthEntries = getEntriesForMonth(year, month); + + if (monthEntries.isEmpty()) { + continue; + } + + // Month header + // String monthName = LocalDate.of(year, month, 1).format(monthFormatter); + // sb.append(monthName).append("\n\n"); + + // Group entries by user and timestamp + List groupedEntries = groupEntries(monthEntries); + + for (GroupedEntry grouped : groupedEntries) { + // Format: "27. Dec 2025 (14:37) - Ralph Soika" + String dayStr = grouped.dateTime.format(dayFormatter); + String timeStr = grouped.dateTime.format(timeFormatter); + sb.append("\n" + dayStr).append(" (").append(timeStr).append(") - ").append(grouped.user) + .append("\n"); + + // Add all messages for this group + for (String message : grouped.messages) { + sb.append(message).append("\n"); + } + } + + // Add spacing between months (but not after the last month of the last year) + if (j < months.size() - 1 || i < years.size() - 1) { + sb.append("\n"); + } + } + } + + return sb.toString().trim(); + } + + /** + * Returns all entries for a specific year and month. + */ + private List getEntriesForMonth(int year, int month) { + List result = new ArrayList<>(); + for (ChronicleEntry entry : chronicleEntries) { + if (entry.dateTime.getYear() == year && entry.dateTime.getMonthValue() == month) { + result.add(entry); + } + } + return result; + } + + /** + * Groups entries by user and timestamp (same minute). This consolidates + * multiple actions by the same user at the same time. + */ + private List groupEntries(List entries) { + List grouped = new ArrayList<>(); + GroupedEntry current = null; + + for (ChronicleEntry entry : entries) { + if (current == null || + !current.user.equals(entry.user) || + !current.dateTime.equals(entry.dateTime)) { + // Start a new group + current = new GroupedEntry(entry.dateTime, entry.user); + grouped.add(current); + } + current.messages.add(entry.message); + } + + return grouped; + } + + /** + * Internal class representing a single chronicle entry. + */ + private static class ChronicleEntry { + LocalDateTime dateTime; + String user; + String message; + String type; + + ChronicleEntry(LocalDateTime dateTime, String user, String message, String type) { + this.dateTime = dateTime; + this.user = user != null ? user : ""; + this.message = message != null ? message : ""; + this.type = type; + } + } + + /** + * Internal class for grouping entries by user and timestamp. + */ + private static class GroupedEntry { + LocalDateTime dateTime; + String user; + List messages; + + GroupedEntry(LocalDateTime dateTime, String user) { + this.dateTime = dateTime; + this.user = user; + this.messages = new ArrayList<>(); + } + } + + /** + * Comparator for sorting chronicle entries by date. + */ + private static class ChronicleEntryComparator implements Comparator { + private boolean descending; + + ChronicleEntryComparator(boolean descending) { + this.descending = descending; + } + + @Override + public int compare(ChronicleEntry e1, ChronicleEntry e2) { + int result = e1.dateTime.compareTo(e2.dateTime); + return descending ? -result : result; + } + } +} \ No newline at end of file diff --git a/dynamixs-ai-app/src/main/java/ai/dynamixs/RAGDefaultIndexPlugin.java b/dynamixs-ai-app/src/main/java/ai/dynamixs/RAGDefaultIndexPlugin.java new file mode 100644 index 0000000..4370d09 --- /dev/null +++ b/dynamixs-ai-app/src/main/java/ai/dynamixs/RAGDefaultIndexPlugin.java @@ -0,0 +1,124 @@ +/**************************************************************************** + * Copyright (c) 2022-2025 Imixs Software Solutions GmbH and others. + * + * This program and the accompanying materials are made available under the + * terms of the Eclipse Public License v. 2.0 which is available at + * https://www.eclipse.org/legal/epl-2.0 + * + * This Source Code may also be made available under the terms of the + * GNU General Public License, version 2 or later (GPL-2.0-or-later), + * which is available at https://www.gnu.org/licenses/old-licenses/gpl-2.0.html + * + * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0-or-later + ****************************************************************************/ + +package ai.dynamixs; + +import java.util.List; +import java.util.logging.Logger; + +import org.imixs.ai.rag.RAGService; +import org.imixs.workflow.ItemCollection; +import org.imixs.workflow.engine.WorkflowService; +import org.imixs.workflow.exceptions.AdapterException; +import org.imixs.workflow.exceptions.PluginException; + +import jakarta.inject.Inject; + +/** + * This RAGIndexPlugin extends the default imixs-ai RAGIndexPlugin. + * + * In the mode INDEX this plugins generates a default prompt template if no + * prompt definition was found. This is to simplify the models. + *

+ * + * 

+  {@code
+   
+      false  
+   
+    }
+ *
+ *

+ * The tag 'debug' is optional + * + * + * @author rsoika + * + */ +public class RAGDefaultIndexPlugin extends org.imixs.ai.rag.RAGIndexPlugin { + + private static final Logger logger = Logger.getLogger(RAGDefaultIndexPlugin.class.getName()); + + @Inject + private WorkflowService workflowService; + + @Inject + private RAGService ragService; + + @Override + public ItemCollection run(ItemCollection workitem, ItemCollection event) throws PluginException { + + // do not run on Snapshots! + if (workitem.getType().startsWith("snapshot-")) { + // no op! + return workitem; + } + + logger.info("├── running Dynamixs.AI RAGPlugin"); + + // read optional configuration form the model or imixs.properties.... + List ragIndexDefinitions = workflowService.evalWorkflowResultXML(event, "imixs-ai", + RAGService.RAG_INDEX, workitem, false); + + try { + // INDEX Mode? + if (ragIndexDefinitions != null && ragIndexDefinitions.size() > 0) { + + // do we have a prompt template? + ItemCollection indexDefinition = ragIndexDefinitions.get(0); + String promptTemplate = indexDefinition.getItemValueString("promptTemplate"); + if (promptTemplate.isBlank()) { + // generate default template + ChronicleTextBuilder chronicleTextBuilder = new ChronicleTextBuilder(workitem); + promptTemplate = chronicleTextBuilder.build(); + workitem.setItemValue("ai.chronicle.summary", promptTemplate); + indexDefinition.setItemValue("promptTemplate", embedTemplate(promptTemplate)); + ragService.createIndex(ragIndexDefinitions, workitem, event); + return workitem; + } + + } + + // default behavior + return super.run(workitem, event); + + } catch (AdapterException e) { + throw new PluginException(e); + } + + } + + /** + * Embedds a prompt into a imixs prompt template + * + * + * @param prompt + * @return + */ + private String embedTemplate(String prompt) { + + String template = "\n" + // + "\n" + // + " {}\n" + // + " \n" + // + "\n" + // + " "; + + return template; + } + +} diff --git a/workflow/en/offer-en-1.0.1.bpmn b/workflow/en/offer-en-1.0.1.bpmn index b19294e..b562eb6 100644 --- a/workflow/en/offer-en-1.0.1.bpmn +++ b/workflow/en/offer-en-1.0.1.bpmn @@ -20,7 +20,7 @@ - + @@ -88,6 +88,17 @@ ExclusiveGateway_2 TextAnnotation_4 dataObject_u4ZytA + event_oOnn8A + event_YGXi9A + task_qvmKNg + task_BRnorw + event_nzILHw + event_tm9U6A + dataObject_gVhkEg + event_20Geow + event_pxwPEw + dataObject_QIYhww + textAnnotation_ASEpEw @@ -222,6 +233,7 @@ Color: _color
$workflowgroup - $workflowstatus]]> SequenceFlow_42 + sequenceFlow_1TkjsQ sequenceFlow_HCxYvw sequenceFlow_RppP5Q sequenceFlow_ZtZaBQ @@ -272,6 +284,7 @@ Color: _color
SequenceFlow_40 SequenceFlow_19 SequenceFlow_25 + sequenceFlow_oWlcYg @@ -1115,7 +1128,7 @@ Color: _color
 - + @@ -1689,6 +1702,7 @@ Color: _color
sequenceFlow_WRPdIA sequenceFlow_hZg0iw sequenceFlow_kkTZbA + sequenceFlow_VQusBA @@ -1938,6 +1952,7 @@ Color: _color
sequenceFlow_BM0t3w + sequenceFlow_VQusBA sequenceFlow_hkBSvg @@ -1953,6 +1968,498 @@ Color: _color
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + ]]> + + + + + + + + + false + + + + sequenceFlow_1TkjsQ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + https://embeddings.llama.cpp.imixs.com/ + true + + +]]> + + + + + + + + + false + + + + sequenceFlow_oWlcYg + sequenceFlow_FFp2sQ + + + + + + + + Product: _name
+EAN: _ean
+Category: _category
+Brand: _brand
+

+Description:
+_description
+
+Price: _price _currency
+Stock: _stock
+Size: _size
+Color: _color
+]]> + + + + + + + + + request.subject]]> + + + true + + + + + + + + + + + + + + $workflowgroup - $workflowstatus]]> + SequenceFlow_40 + sequenceFlow_6AvkzQ + SequenceFlow_25 + sequenceFlow_FFp2sQ + sequenceFlow_C79hSw + + + + + + + + Product: _name
+EAN: _ean
+Category: _category
+Brand: _brand
+
+Description:
+_description
+
+Price: _price _currency
+Stock: _stock
+Size: _size
+Color: _color
+]]> + + + + + + + + + request.subject]]> + + + true + + + + + + + + + + + + + + $workflowgroup - $workflowstatus]]> + sequenceFlow_FFp2sQ + sequenceFlow_zyO0wQ + sequenceFlow_VtEF4g + sequenceFlow_11vZNA + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + llm.service.endpoint + ai.workflow.summary + true + +false +]]> + + + + + + + + + + + + false + + + + sequenceFlow_C79hSw + sequenceFlow_7s3Yfw + sequenceFlow_zyO0wQ + + sequenceFlow_InfPdQ + + + + + + + + + + sequenceFlow_7s3Yfw + + + + + + + + + + + + {"n_predict": 4096, "temperature": 0.0} + + + + ai.chronicle.summary ]]]]> + + + ]]> + + + + + + + + sequenceFlow_VtEF4g + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + ]]> + + + + + + + + + false + + + + + + + sequenceFlow_11vZNA + sequenceFlow_6AvkzQ + + + + + + + + + + + + + + + + + + + + + + + + + +]]> + + + + + + + + + @@ -2125,11 +2632,68 @@ Color: _color
- + - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + @@ -2182,10 +2746,8 @@ Color: _color
 - - - - + + @@ -2325,13 +2887,13 @@ Color: _color
- + - + - + @@ -2386,13 +2948,14 @@ Color: _color
 - - + + - - + + + @@ -2409,6 +2972,70 @@ Color: _color
 + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +