diff --git a/RELEASENOTES.md b/RELEASENOTES.md index 106420e..c3e0a3b 100644 --- a/RELEASENOTES.md +++ b/RELEASENOTES.md @@ -5,6 +5,11 @@ - Finalizierung Business Partner Interface - Zoho Schnittstelle +**Migration** + +- Encoding für CSV Impoort aus cargosoft muss auf `encoding=UTF-8` stehen! +- Neues Businesspartner BPMN Modell einspielen + ### 1.3.3 - Imixs-Archive 3.1.1. Compactor Sevrvice diff --git a/doc/BUSINESSPARTNER.md b/doc/BUSINESSPARTNER.md index b6c7613..dff4b38 100644 --- a/doc/BUSINESSPARTNER.md +++ b/doc/BUSINESSPARTNER.md @@ -9,12 +9,7 @@ In Imixs ist es dann aber möglich zusätzliche Attribute zu einem Businesspartn - Bankverbindungen - Emailadressen für Mahnwesen -Die Businessparnter werden zentral nur in dem Hauptsystem in Bremen importiert und verwaltet. Damit ein AGL System auf die BusinessPartner zugreifen kann wird eine Rest API Schnittstelle verwendet. Diese kann über Environmentvariablen aktiviert werden: - - # Rest Service BusinessPartner API - WORKFLOW_SERVICE_ENDPOINT: "http://app:8080/api" - WORKFLOW_SERVICE_USER: "admin" - WORKFLOW_SERVICE_PASSWORD: "xxxxxxxx" +Die Businessparnter werden für jedes System separat importiert und verwaltet. ## BusinessPartner Suche @@ -28,7 +23,7 @@ Z.b. kann das als Custom Part in eine Form eingebunden werden: ``` -Das widget legt dann automatisch die felder `bpid` und `bpidname` an. +Das widget legt dann automatisch die Items `bpid` und `bpidname` an. Alternativ kann im Backend über die EJB BusinessPartnerService nach bpid gesucht werden: @@ -40,10 +35,20 @@ Alternativ kann im Backend über die EJB BusinessPartnerService nach bpid gesuch # Daten Migration +Der `BusinessPartnerImportService` hängt sich über ein CDI Observer Pattern an den standard CSVImport Service +der die Cargosoft Stammdaten aktualisiert. Der BusinessPartnerImportService +prüft ob der Workflow schon existiert oder ggf. aktualisiert werden muss. + +Der Service migriert auch die alten zusätzlichen IBAN/BIC felder wenn der Business partner erstmals neu angelegt wird. Falls bei der ersten Migration erkannt wird, dass die IBAN Nummern nicht eindeutig sind wir der BusinessParter mit dem Event 300 angelegt. + +- + \_vendor_zip_code \_vendor_fax (type:cargosoftkreditor) AND ($modified:[20010101 TO 20250215]) -Wir müssen gundsätzlich erstmal über all $nosnapshot = true eintragen! +## Anmerkungen zu seltsamen Daten + +BP4641 existier jetzt 3 mal mit der Debitoren nummer D14641 diff --git a/office-alexander-logistics-app/src/main/java/com/alexanderlogistics/api/CargosoftMigrationRestService.java b/office-alexander-logistics-app/src/main/java/com/alexanderlogistics/api/CargosoftMigrationRestService.java index 0ab451d..29b6f7b 100644 --- a/office-alexander-logistics-app/src/main/java/com/alexanderlogistics/api/CargosoftMigrationRestService.java +++ b/office-alexander-logistics-app/src/main/java/com/alexanderlogistics/api/CargosoftMigrationRestService.java @@ -53,6 +53,7 @@ import org.imixs.workflow.FileData; import org.imixs.workflow.ItemCollection; import org.imixs.workflow.engine.DocumentService; import org.imixs.workflow.engine.WorkflowService; +import org.imixs.workflow.engine.index.UpdateService; import org.imixs.workflow.exceptions.AccessDeniedException; import org.imixs.workflow.exceptions.ModelException; import org.imixs.workflow.exceptions.PluginException; @@ -113,6 +114,9 @@ public class CargosoftMigrationRestService implements Serializable { @Inject MahnlaufService mahnlaufService; + @Inject + UpdateService updateService; + @Inject TeamService teamService; @@ -692,6 +696,9 @@ public class CargosoftMigrationRestService implements Serializable { totalObjects++; if (syncBusinessPartner(cargosoftItemCol)) { syncs++; + // Explicit flush the lucene search event log + updateService.updateIndex(); + } if (syncs >= maxcount) break; @@ -808,7 +815,7 @@ public class CargosoftMigrationRestService implements Serializable { } /** - * Hilfsmethode speichert eine cargoosft kreditor object... + * Hilfsmethode - löscht ein cargoosoft object... * * @param bpID * @param messageBuffer diff --git a/office-alexander-logistics-app/src/main/java/com/alexanderlogistics/xml/BusinessPartnerImportService.java b/office-alexander-logistics-app/src/main/java/com/alexanderlogistics/xml/BusinessPartnerImportService.java index a1538f1..422742f 100644 --- a/office-alexander-logistics-app/src/main/java/com/alexanderlogistics/xml/BusinessPartnerImportService.java +++ b/office-alexander-logistics-app/src/main/java/com/alexanderlogistics/xml/BusinessPartnerImportService.java @@ -65,12 +65,15 @@ import jakarta.enterprise.event.Observes; * "ON_DOCUMENT_SAVE" reagiert. Hier hängt sich der BusinessPartnerImportService * ein und prüft ob der Workflow schon existiert oder ggf. aktualisiert werden * muss. - * + *

* Der Service migriert auch die alten zusätzlichen IBAN/BIC felder wenn der * Business partner erstmals neu angelegt wird. - * - * The service set also the flag NOSNAPSHOT=true for the crgosoftcreditor - * document type. + *

+ * Falls bei der ersten Migration erkannt wird, dass die IBAN Nummern nicht + * eindeutig sind wir der BusinessParter mit dem Event 300 angelegt. + *

+ * Im Cargosoft Entity wird zusätzlich das flag NOSNAPSHOT=true gesetzt. Dies + * ist nur eine Performance Optimierung. * * @author rsoika * @@ -110,90 +113,90 @@ public class BusinessPartnerImportService { if (event == null || event.getDocument() == null) { return; } - // check if source is already completed - if (event.getEventType() == DocumentEvent.ON_DOCUMENT_SAVE) { - // check type! - if ("cargosoftkreditor".equals(event.getDocument().getType())) { - // set NOSNAPSHOT=true - event.getDocument().setItemValue(SnapshotService.NOSNAPSHOT, true); + // check source + if (event.getEventType() == DocumentEvent.ON_DOCUMENT_SAVE + && "cargosoftkreditor".equals(event.getDocument().getType())) { - // run only if we have the model 'businesspartner-*'; - if (modelService.findVersionsByRegEx("(businesspartner*)").size() == 0) { - // no business partner workflow found - return; + // set NOSNAPSHOT=true fro cargosoft item (migration) + event.getDocument().setItemValue(SnapshotService.NOSNAPSHOT, true); + + // run only if we have the model 'businesspartner-*'; + if (modelService.findVersionsByRegEx("(businesspartner*)").size() == 0) { + // no business partner workflow found + return; + } + + logger.fine("Verify business partner object...."); + ItemCollection importDoc = event.getDocument(); + + String name = event.getDocument().getItemValueString("name"); + boolean isCreditor = name.toUpperCase().startsWith("K"); + String partnerID = InvoiceUtil.buildBPID(name); + + // Prüfen ob es diesen partner schon gibt? + ItemCollection businesspartner = lookupBusinessPartner(partnerID); + if (businesspartner == null) { + businesspartner = createBusinessPartner(partnerID); + } + ItemCollection oldBussinessPartnerItemColl = (ItemCollection) businesspartner.clone(); + + // Update Fields... + businesspartner.setItemValue("name", partnerID); + businesspartner.setItemValue("partner.id", partnerID); + if (isCreditor) { + businesspartner.setItemValue("cdtr.number", name); + if (businesspartner.isItemEmpty("cdtr.mail")) { + businesspartner.setItemValue("cdtr.mail", importDoc.getItemValueString("_vendor_email")); } - - logger.fine("Verify business partner object...."); - ItemCollection importDoc = event.getDocument(); - - String name = event.getDocument().getItemValueString("name"); - boolean isCreditor = name.toUpperCase().startsWith("K"); - String partnerID = InvoiceUtil.buildBPID(name); - - // Prüfen ob es diesen partner schon gibt? - ItemCollection businesspartner = lookupBusinessPartner(partnerID); - if (businesspartner == null) { - businesspartner = createBusinessPartner(partnerID); - } - ItemCollection oldBussinessPartnerItemColl = (ItemCollection) businesspartner.clone(); - - // Update Fields... - businesspartner.setItemValue("name", partnerID); - businesspartner.setItemValue("partner.id", partnerID); - if (isCreditor) { - businesspartner.setItemValue("cdtr.number", name); - if (businesspartner.isItemEmpty("cdtr.mail")) { - businesspartner.setItemValue("cdtr.mail", importDoc.getItemValueString("_vendor_email")); - } - } else { - businesspartner.setItemValue("dbtr.number", name); - if (businesspartner.isItemEmpty("dbtr.mail")) { - businesspartner.setItemValue("dbtr.mail", importDoc.getItemValueString("_vendor_email")); - } - } - businesspartner.setItemValue("partner.country", importDoc.getItemValueString("_vendor_country")); - businesspartner.setItemValue("partner.name", importDoc.getItemValueString("_vendor_name")); - businesspartner.setItemValue("partner.phone", importDoc.getItemValueString("_vendor_phone")); - businesspartner.setItemValue("partner.address", importDoc.getItemValueString("_vendor_str")); - businesspartner.setItemValue("partner.zip", importDoc.getItemValueString("_vendor_zip_code")); - businesspartner.setItemValue("partner.city", importDoc.getItemValueString("_vendor_city")); - - // hat sich das Objekt verändert? - if (!businesspartner.equals(oldBussinessPartnerItemColl)) { - - // Prüfe IBAN auf plausibilität - List bankList = BusinessPartnerService.getBanks(businesspartner); - boolean ibanDublette = false; - List dublettenIban = new ArrayList<>(); - for (ItemCollection bank : bankList) { - String iban = bank.getItemValueString("iban"); - // erkenne fehlerhaften kontonummern - if (dublettenIban.contains(iban)) { - // ACHTUNG - uneindeutige Bankverbindung - ibanDublette = true; - } else { - dublettenIban.add(iban); - } - } - - int eventID = 200; // default - // event errechnen - if (!businesspartner.hasItem(WorkflowKernel.LASTEVENT)) { - // create new! - if (ibanDublette) { - eventID = 300; // Exception - } else { - eventID = 100; // update/create - } - } - businesspartner.setEventID(eventID); - try { - workflowService.processWorkItemByNewTransaction(businesspartner); - } catch (AccessDeniedException | ProcessingErrorException | PluginException | ModelException e) { - logger.warning("Failed to update Business Partner Object " + name + " - " + e.getMessage()); - } + } else { + businesspartner.setItemValue("dbtr.number", name); + if (businesspartner.isItemEmpty("dbtr.mail")) { + businesspartner.setItemValue("dbtr.mail", importDoc.getItemValueString("_vendor_email")); } } + businesspartner.setItemValue("partner.country", importDoc.getItemValueString("_vendor_country")); + businesspartner.setItemValue("partner.name", importDoc.getItemValueString("_vendor_name")); + businesspartner.setItemValue("partner.phone", importDoc.getItemValueString("_vendor_phone")); + businesspartner.setItemValue("partner.address", importDoc.getItemValueString("_vendor_str")); + businesspartner.setItemValue("partner.zip", importDoc.getItemValueString("_vendor_zip_code")); + businesspartner.setItemValue("partner.city", importDoc.getItemValueString("_vendor_city")); + + // hat sich das Objekt verändert? + if (!businesspartner.equals(oldBussinessPartnerItemColl)) { + + // Prüfe IBAN auf plausibilität + List bankList = BusinessPartnerService.getBanks(businesspartner); + boolean ibanDublette = false; + List dublettenIban = new ArrayList<>(); + for (ItemCollection bank : bankList) { + String iban = bank.getItemValueString("iban"); + // erkenne fehlerhaften kontonummern + if (dublettenIban.contains(iban)) { + // ACHTUNG - uneindeutige Bankverbindung + ibanDublette = true; + } else { + dublettenIban.add(iban); + } + } + + int eventID = 200; // default + // event errechnen + if (!businesspartner.hasItem(WorkflowKernel.LASTEVENT)) { + // create new! + if (ibanDublette) { + eventID = 300; // Exception + } else { + eventID = 100; // update/create + } + } + businesspartner.setEventID(eventID); + try { + workflowService.processWorkItemByNewTransaction(businesspartner); + } catch (AccessDeniedException | ProcessingErrorException | PluginException | ModelException e) { + logger.warning("Failed to update Business Partner Object " + name + " - " + e.getMessage()); + } + } + } } diff --git a/workflow/businesspartner-de-1.0.0.bpmn b/workflow/businesspartner-de-1.0.0.bpmn index 98ebdd1..6412d90 100644 --- a/workflow/businesspartner-de-1.0.0.bpmn +++ b/workflow/businesspartner-de-1.0.0.bpmn @@ -634,9 +634,9 @@ - + - + @@ -646,7 +646,7 @@ - + @@ -703,8 +703,8 @@ - - + + @@ -754,8 +754,8 @@ - - + + @@ -769,7 +769,7 @@ - + @@ -782,7 +782,7 @@ - + diff --git a/workflow/businesspartner-en-1.0.0.bpmn b/workflow/businesspartner-en-1.0.0.bpmn index bd0967a..2f16649 100644 --- a/workflow/businesspartner-en-1.0.0.bpmn +++ b/workflow/businesspartner-en-1.0.0.bpmn @@ -644,13 +644,13 @@ - + - + - + @@ -754,8 +754,8 @@ - - + + @@ -827,7 +827,7 @@ - + @@ -862,15 +862,15 @@ - + - + - +