Quatre fichiers EDI pour une seule ligne de commande

apiVersion: connectors.lumnik.io/v1kind: Connectormetadata:  name: scenario-cycle-cc-b  connector_type: csv-file  scopes: [logistics-b]spec:  transport:    kind: local    path: /tmp/lumnik-scenario/edi-order-cycle/b/ZINT_CC_*.txt   # order lines, ERP → partner  parser:    lines: true  after_process: none  mapping:    dataset:      - filter-where: { column: line, regex: ".{27}EC.*" }   # the header carries no customer code      - enrich-context: { stage: ORDERED }    cell:      - regex-extract:          column: line          required: true          pattern: "^(.{17})(.{10})(.{10})(.{40})(.{50})(.{8})(.{3})(.{12})(.{12})(.{40})(.{10})(.{4})(.*)$"          groups: { 4: customer_name, 8: order_no, 9: article, 10: label, 11: ordered_qty, 12: unit, 13: line_id }      - clean: { columns: [customer_name, order_no, article, label, ordered_qty, unit, line_id], strip: true }      - parse-number: { column: ordered_qty, decimal-separator: "." }

apiVersion: connectors.lumnik.io/v1kind: Connectormetadata:  name: scenario-cycle-ca-b  connector_type: csv-file  scopes: [logistics-b]spec:  transport:    kind: local    path: /tmp/lumnik-scenario/edi-order-cycle/b/ZINT_CA_*.txt   # acknowledgements, partner → ERP  parser:    lines: true  after_process: none  mapping:    cell:      - regex-extract:                 # the purchase order and the order it acknowledges, glued          column: line          required: true          pattern: "^(\\d{10})(\\d{8})$"          groups: { 1: po, 2: order_no }

apiVersion: connectors.lumnik.io/v1kind: Connectormetadata:  name: scenario-cycle-c1-b  connector_type: csv-file  scopes: [logistics-b]spec:  transport:    kind: local    path: /tmp/lumnik-scenario/edi-order-cycle/b/ZINT_C1_*.txt   # confirmed dates, partner → ERP  parser:    lines: true  after_process: none  mapping:    dataset:      - filter-where: { column: line, regex: "\\d.*" }        # data lines start with the purchase order      - enrich-context: { stage: CONFIRMED }    cell:      - regex-extract:          column: line          required: true          pattern: "^(.{12})(.{17})(.{18})(.{8})$"          groups: { 1: po, 2: line_id, 3: article, 4: confirmed_date }      - clean: { columns: [po, line_id, article], strip: true }      - parse-date: { column: confirmed_date, formats: ["yyyyMMdd"] }

apiVersion: connectors.lumnik.io/v1kind: Connectormetadata:  name: scenario-cycle-bl-b  connector_type: csv-file  scopes: [logistics-b]spec:  transport:    kind: local    path: /tmp/lumnik-scenario/edi-order-cycle/b/ZINT_BL_*.txt   # delivery notes, partner → ERP  parser:    lines: true  after_process: none  mapping:    dataset:      - filter-where: { column: line, regex: "\\d.*" }      - enrich-context: { stage: DELIVERED }    cell:      - regex-extract:          column: line          required: true          pattern: "^(.{16})(.{10})(.{18})(.{10})(.*)$"          groups: { 1: bl_no, 2: po, 3: article, 4: delivered_qty, 5: line_id }      - clean: { columns: [bl_no, po, article, delivered_qty, line_id], strip: true }      - parse-number: { column: delivered_qty, decimal-separator: "." }

kind: Entityname: order_line_cycle_blabel: Cycle d'une ligne de commandedescription: "One order line across the four flows: ordered, acknowledged, confirmed, delivered — the stage is the most advanced flow that names the line."match: [line_id]scopes: [logistics-b]columns:  line_id: { label: "Ligne" }  order_no: { label: "Commande" }  customer_name: { label: "Client" }  article: { label: "Article", prefer: t_scenario_cycle_cc_b }  ordered_qty: { label: "Commandé" }  confirmed_date: { label: "Livraison confirmée" }  delivered_qty: { label: "Livré" }  bl_no: { label: "Bon de livraison" }  stage: { label: "Étape", conflicts: false }   # the flows progress, they do not disagreesources:                                 # the order is the priority: the furthest flow names the stage  - table: t_scenario_cycle_bl_b    map: { line_id: line_id, article: article, delivered_qty: delivered_qty, bl_no: bl_no, stage: stage }  - table: t_scenario_cycle_c1_b    map: { line_id: line_id, article: article, confirmed_date: confirmed_date, stage: stage }  - table: t_scenario_cycle_cc_b    map: { line_id: line_id, order_no: order_no, customer_name: customer_name, article: article,           ordered_qty: ordered_qty, stage: stage }joins:  - table: t_scenario_cycle_ca_b           # the acknowledgement is per order, not per line    from: order_no    to: order_no    map: { po: acknowledged_po }

apiVersion: apps.lumnik.io/v1kind: Workflowmetadata:  name: order-line-cycle-bspec:  scope: logistics-b  provenance: declared  on:    table: connector.v_order_line_cycle_b   # the fused view: the stage only exists there    column: stage    key: line_id                            # one document per order line  states:    - { code: ORDERED, label: "Commandée", initial: true }    - { code: CONFIRMED, label: "Date confirmée" }    - { code: DELIVERED, label: "Livrée", terminal: true }  due:                                      # the deadline is a date the data carries, not a first sighting    column: confirmed_date    states: [CONFIRMED]    zone: Europe/Paris                      # a date-only column: due at the end of that day in Paris    message: "Ligne {doc_key}: livraison confirmée pour le {due}, toujours pas livrée"