Release 1.2.45+1

SCPN1-9296-1.2

See merge request r-d-technique/tiers/reflex-wms-connector!132

README.md

@@ -1,10 +1,20 @@
 # Reflex Platform Core FTLs
 
+## Overview
 
+The **Reflex WMS Connector** is a set of **FreeMarker templates (FTL)** designed to transform **outgoing JSON flows from Reflex WMS** into **flows compatible with Reflex Platform**.
 
-These FTL core files aim to translate data flow from Reflex WMS into Reflex platform API.
+This connector does not contain any standalone executable code: it is intended to be used by **Reflex integration engines** or **data exchange pipelines**, where it applies the mapping rules defined in the `.ftl` files.
 
+## Role of the FTL Files
 
+- Each `.ftl` file corresponds to a **flow type** (order, stock, receipt, shipment, etc.).
+- These templates use the **FreeMarker** syntax to:
+  - Extract the required fields from the WMS source flow.
+  - Apply transformation rules (mapping, conversions, enrichments).
+  - Generate a **final structured JSON** for Reflex Platform.
 
-You can find more info about those files in the Reflex platform documentation center : https://docs.viz.reflex-platform.com/connectivity/partnerapp/reflex-wms-connector/
+## Useful Resources
 
+- [FreeMarker Documentation](https://freemarker.apache.org/docs/index.html)
+- [Reflex Platform](https://auth.reflex-platform.com/)

RFXtoRP_HliPrepaL.ftl

@@ -0,0 +1,31 @@
+<#-- **** input parameters  ***** -->
+<#-- input        : message RFX  -->
+<#-- project      : projectId in ReflexPlatform  -->
+<#-- organisation : organisationtId in ReflexPlatform  -->
+<#include "ReflexUtils.ftl">
+<#assign cloudEventMsg = JsonUtil.jsonToMap(input)>
+<#assign projectRP = project>
+<#assign organisationRP = organisation>
+<#include "RFX_PartnerAPP_Settings.ftl">
+
+<#assign aDateTime = .now>
+
+<#switch cloudEventMsg.action>
+<#case "C">
+<#--<#case "U">
+    <#-- *********************************************** Action = CREATE or UPDATE ******************** -->
+    <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
+    <#assign preparationOrderLines = JsonUtil.jsonToMap(dataRfx)>
+    <#stop "no generic FTL file available yet for preparationOrderLines">
+    <#break>
+<#case "D">
+    <#-- *********************************************** Action = DELETE ******************** -->
+    <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
+    <#assign preparationOrderLines = JsonUtil.jsonToMap(dataRfx)>
+    <#stop "no generic FTL file available yet for preparationOrderLines">
+    <#break>
+<#break>
+
+<#default>
+<#stop>
+</#switch>

RFXtoRP_HliReceiptLr.ftl

@@ -0,0 +1,34 @@
+<#-- **** input parameters  ***** -->
+<#-- input        : message RFX  -->
+<#-- project      : projectId in ReflexPlatform  -->
+<#-- organisation : organisationtId in ReflexPlatform  -->
+
+<#assign cloudEventMsg = JsonUtil.jsonToMap(input)>
+<#assign projectRP = project>
+<#assign organisationRP = organisation>
+
+<#assign aDateTime = .now>
+
+<#switch cloudEventMsg.action>
+    <#case "C">
+    <#case "U">
+        <#-- *********************************************** Action = CREATE ******************** -->
+
+        <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
+        <#assign receiptLines = JsonUtil.jsonToMap(dataRfx)>
+
+        <#stop "no generic FTL file available yet for receiptLines">
+        <#break>
+
+      <#case "D">
+      <#-- *********************************************** Action = DELETE ******************** -->
+        <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
+        <#assign receiptLines = JsonUtil.jsonToMap(dataRfx)>
+
+        <#stop "no generic FTL file available yet for receiptLines">
+        <#break>
+
+    <#default>
+          <#stop >
+</#switch>
+

RFXtoRP_HlrProL.ftl

@@ -0,0 +1,32 @@
+<#-- **** input parameters  ***** -->
+<#-- input        : message RFX  -->
+<#-- project      : projectId in ReflexPlatform  -->
+<#-- organisation : organisationtId in ReflexPlatform  -->
+
+<#assign cloudEventMsg = JsonUtil.jsonToMap(input)>
+<#assign projectRP = project>
+<#assign organisationRP = organisation>
+
+<#assign aDateTime = .now>
+
+<#switch cloudEventMsg.action>
+  <#case "C">
+  <#case "U">
+      <#-- *********************************************** Action = CREATE or UPDATE ******************** -->
+      <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
+      <#assign preparationOrderLines = JsonUtil.jsonToMap(dataRfx)>
+
+      <#stop "no generic FTL file available yet for preparationOrderLines">
+      <#break>
+
+    <#case "D">
+      <#-- *********************************************** Action = DELETE ******************** -->
+      <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
+      <#assign preparationOrderLines = JsonUtil.jsonToMap(dataRfx)>
+
+      <#stop "no generic FTL file available yet for preparationOrderLines">
+      <#break>
+    <#default>
+          <#stop >
+</#switch>
+

RFXtoRP_HsaDispute.ftl

@@ -36,7 +36,8 @@
                 <#stop>
               </#if>
             <#else>
-              <#stop "Reference is empty">
+              <#--  "Reference is empty"-->
+              <#stop>
             </#if>
           </#if>
        ]

RFXtoRP_HsaDispute_ClaimMetadata.ftl

@@ -0,0 +1,4 @@
+<#-- use protobuf of class HsaDispute to find Reflex Wms fields names  -->
+
+
+"MetaData": [        ]

RFXtoRP_HsaDispute_Created.ftl

@@ -39,6 +39,8 @@
                 </#if>
                 "Value": "${dispute.dispute_amount}"
              },
+            <#-- Claim metadata inclusion  -->
+            <#include "RFXtoRP_HsaDispute_ClaimMetadata.ftl">,
             <#-- To configure -->
             <#include "RFXtoRP_HsaDispute_TableReasonCodeToClaimTypeID.ftl">
             <#if dispute.dispute_type_code=="050" >

RFXtoRP_HsaIpgMove.ftl

@@ -57,8 +57,8 @@
                         }
                         ]
                       <#else>
-                        <#-- Case of IPG move type volontarilly ignored-->
+                        <#-- Case of IPG move type volontarilly ignored, Reference receipt is empty-->
-                        <#stop " Reference receipt is empty">
+                        <#stop >
                      </#if>
                <#else>
                   <#stop>

RFXtoRP_HsaIpgMove_GoodsReceived.ftl

@@ -29,14 +29,30 @@
          <#-- Goods received Segmentation Keys inclusion  -->
          <#include "RFXtoRP_HsaIpgMove_GoodsReceived_SegmentationKeys.ftl">
          },
-        <#if reflexMvtStockInterface.receipt_reference!="">
+        <#if reflexMvtStockInterface.ipg_move_type?? & reflexMvtStockInterface.ipg_move_type=="120"> <#-- if it is a transfer-type movement -->
-          "ExecutionflowID": "${reflexMvtStockInterface.receipt_reference?trim?json_string}",
+          <#if reflexMvtStockInterface.origin_order_line_reference?? && reflexMvtStockInterface.origin_order_line_reference!="">
-          "OrderID": "${reflexMvtStockInterface.receipt_reference?trim?json_string}",
+            "ExecutionflowID": "${reflexMvtStockInterface.origin_order_line_reference?trim?json_string}",
+            "OrderID": "${reflexMvtStockInterface.origin_order_line_reference?trim?json_string}",
+          <#else>
+            <#if reflexMvtStockInterface.receipt_reference?? && reflexMvtStockInterface.receipt_reference!="">
+              "ExecutionflowID": "${reflexMvtStockInterface.receipt_reference?trim?json_string}",
+              "OrderID": "${reflexMvtStockInterface.receipt_reference?trim?json_string}",
+            </#if>
+          </#if>
         <#else>
-          "ExecutionflowID": "${reflexMvtStockInterface.physical_depot_code}${reflexMvtStockInterface.activity_code}${reflexMvtStockInterface.ipg_move_year_number}${reflexMvtStockInterface.extended_ipg_move_number}",
+          <#if reflexMvtStockInterface.receipt_reference?? && reflexMvtStockInterface.receipt_reference!="">
-          "OrderID": "${reflexMvtStockInterface.physical_depot_code}${reflexMvtStockInterface.activity_code}${reflexMvtStockInterface.ipg_move_year_number}${reflexMvtStockInterface.extended_ipg_move_number}",
+            "ExecutionflowID": "${reflexMvtStockInterface.receipt_reference?trim?json_string}",
+            "OrderID": "${reflexMvtStockInterface.receipt_reference?trim?json_string}",
+          <#else>
+            "ExecutionflowID": "${reflexMvtStockInterface.physical_depot_code}${reflexMvtStockInterface.activity_code}${reflexMvtStockInterface.ipg_move_year_number}${reflexMvtStockInterface.extended_ipg_move_number}",
+            "OrderID": "${reflexMvtStockInterface.physical_depot_code}${reflexMvtStockInterface.activity_code}${reflexMvtStockInterface.ipg_move_year_number}${reflexMvtStockInterface.extended_ipg_move_number}",
+          </#if>
+        </#if>
+        <#if reflexMvtStockInterface.origin_order_line_number_reference?? && reflexMvtStockInterface.origin_order_line_number_reference!=0>
+          "LineID": "${reflexMvtStockInterface.origin_order_line_number_reference}",
+        <#else>
+          "LineID": "${reflexMvtStockInterface.receipt_line_number}",
         </#if>
-        "LineID": "${reflexMvtStockInterface.receipt_line_number}",
         "ActorID": "${RFXtoRPprefixDepot(reflexMvtStockInterface.physical_depot_code?trim?json_string)}",
         "Quantity": {
             "LVID": "${quantity_in_base_lv_RP_Cst}",

RFXtoRP_HsaItmLv_LogisticVariantUpdated.ftl

@@ -12,7 +12,7 @@
            {
           "LVID": "${lv.logistical_variant_code?json_string}",
           "Name" : "${lv.lv_type_code?json_string}",
-          <#if lv.id_list??>
+          <#if lv.id_list??  && (lv.id_list?size == lv.id_list?filter(l ->l??)?size)>
           "Codes": [
                    <#list lv.id_list as id>
                    {

RFXtoRP_HsaItm_ItemCreated.ftl

@@ -37,7 +37,7 @@
             "LVID": "${logistical_variant.logistical_variant_code?json_string}",
             "Name" : "${logistical_variant.lv_type_code?json_string}",
 
-              <#if logistical_variant.id_list??>
+              <#if logistical_variant.id_list?? && (logistical_variant.id_list?size == logistical_variant.id_list?filter(l ->l??)?size)>
             "Codes": [
                        <#list logistical_variant.id_list as id>
                        {

RFXtoRP_HsaProStatus.ftl

@@ -17,56 +17,57 @@
       <#assign preparationStatusInterface = JsonUtil.jsonToMap(dataRfx) />
       [
          <#--**Pick batch runned (200) **-->
-         <#if  preparationStatusInterface.preparation_order_originator_reference?? && preparationStatusInterface.preparation_order_originator_reference!="">
+      <#if  preparationStatusInterface.preparation_order_originator_reference?? && preparationStatusInterface.preparation_order_originator_reference!="">
-            <#if preparationStatusInterface.preparation_status_type == "100" && preparationStatusInterface.preparation_status_code == "200" >
+         <#if preparationStatusInterface.preparation_status_type == "100" && preparationStatusInterface.preparation_status_code == "200" >
+            {
+            <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowPreparationExpected>
+            "apiReflexPlatformID" :  "${apiReflexPlatformID}",
+            "datas" :
+            <#include "RFXtoRP_HsaProStatus_PreparationExpected.ftl">
+            }
+         <#else>
+            <#-- ** Collection started (300) and Preparation in progress (400)** -->
+            <#if preparationStatusInterface.preparation_status_type == "100" && (preparationStatusInterface.preparation_status_code == "300" || preparationStatusInterface.preparation_status_code == "400") >
                {
-               <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowPreparationExpected>
+               <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowPreparationStarted>
                "apiReflexPlatformID" :  "${apiReflexPlatformID}",
                "datas" :
-               <#include "RFXtoRP_HsaProStatus_PreparationExpected.ftl">
+                  <#include "RFXtoRP_HsaProStatus_PreparationStarted.ftl">
                }
             <#else>
-               <#-- ** Collection started (300) and Preparation in progress (400)** -->
+                  <#-- ****Preparation dispatched (600)** -->
-               <#if preparationStatusInterface.preparation_status_type == "100" && (preparationStatusInterface.preparation_status_code == "300" || preparationStatusInterface.preparation_status_code == "400") >
+               <#if preparationStatusInterface.preparation_status_type == "100" && preparationStatusInterface.preparation_status_code == "600" >
-                  {
+                     {
-                  <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowPreparationStarted>
+                     <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowPreparationCompleted>
-                  "apiReflexPlatformID" :  "${apiReflexPlatformID}",
+                     "apiReflexPlatformID" :  "${apiReflexPlatformID}",
-                  "datas" :
+                     "datas" :
-                     <#include "RFXtoRP_HsaProStatus_PreparationStarted.ftl">
+                        <#include "RFXtoRP_HsaProStatus_PreparationCompleted.ftl">
-                  }
+                     },
-               <#else>
+                     {
-                     <#-- ****Preparation dispatched (600)** -->
+                        <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowTransportStarted>
-                  <#if preparationStatusInterface.preparation_status_type == "100" && preparationStatusInterface.preparation_status_code == "600" >
-                        {
-                        <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowPreparationCompleted>
                         "apiReflexPlatformID" :  "${apiReflexPlatformID}",
                         "datas" :
-                           <#include "RFXtoRP_HsaProStatus_PreparationCompleted.ftl">
+                           <#include "RFXtoRP_HsaProStatus_TransportStarted.ftl">
-                        },
+                     }
+               <#else>
+                     <#-- ****Preparation cancelled (650)**** -->
+                  <#if preparationStatusInterface.preparation_status_type == "100" && preparationStatusInterface.preparation_status_code == "650" >
                         {
-                           <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowTransportStarted>
+                        <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowCancelled>
-                           "apiReflexPlatformID" :  "${apiReflexPlatformID}",
+                        "apiReflexPlatformID" :  "${apiReflexPlatformID}",
-                           "datas" :
+                        "datas" :
-                              <#include "RFXtoRP_HsaProStatus_TransportStarted.ftl">
+                           <#include "RFXtoRP_HsaProStatus_ExecutionflowCancelled.ftl">
                         }
                   <#else>
-                        <#-- ****Preparation cancelled (650)**** -->
+                        <#stop>
-                     <#if preparationStatusInterface.preparation_status_type == "100" && preparationStatusInterface.preparation_status_code == "650" >
-                           {
-                           <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowCancelled>
-                           "apiReflexPlatformID" :  "${apiReflexPlatformID}",
-                           "datas" :
-                              <#include "RFXtoRP_HsaProStatus_ExecutionflowCancelled.ftl">
-                           }
-                     <#else>
-                           <#stop>
-                     </#if>
                   </#if>
                </#if>
             </#if>
-         <#else>
-            <#stop "PRO reference is empty">
          </#if>
+      <#else>
+         <#--PRO reference is empty-->
+         <#stop >
+      </#if>
       ]
       <#break>
 

RFXtoRP_HsaProStatus_ExecutionflowCancelled.ftl

@@ -8,7 +8,7 @@
       "ProjectID": "${projectRP}"
     },
     "ID": {
-      "RefID": "${preparationStatusInterface.preparation_order_originator_reference?trim?json_string}",
+    "RefID": "${preparationStatusInterface.preparation_order_originator_reference?trim?json_string}",
     "RefDate": {
       "DateTime": "${preparation_status_datetime}",
       "AuthorTimeZone": "${time_zone_rfx}"

RFXtoRP_HsaProStatus_PreparationCompleted.ftl

@@ -7,7 +7,7 @@
       "ProjectID": "${projectRP}"
     },
     "ID": {
-         "RefID": "${preparationStatusInterface.preparation_order_originator_reference?trim?json_string}",
+       "RefID": "${preparationStatusInterface.preparation_order_originator_reference?trim?json_string}",
        "RefDate": {
         "DateTime": "${preparation_status_datetime}",
         "AuthorTimeZone": "${time_zone_rfx}"

RFXtoRP_HsaProStatus_PreparationExpected.ftl

@@ -7,10 +7,10 @@
       "ProjectID": "${projectRP}"
     },
     "ID": {
-         "RefID": "${preparationStatusInterface.preparation_order_originator_reference?trim?json_string}",
+        "RefID": "${preparationStatusInterface.preparation_order_originator_reference?trim?json_string}",
-       "RefDate": {
+        "RefDate": {
-        "DateTime": "${preparation_status_datetime}",
+          "DateTime": "${preparation_status_datetime}",
-        "AuthorTimeZone": "${time_zone_rfx}"
+          "AuthorTimeZone": "${time_zone_rfx}"
       }
     },
 

RFXtoRP_HsaProStatus_PreparationStarted.ftl

@@ -7,10 +7,10 @@
       "ProjectID": "${projectRP}"
     },
     "ID": {
-         "RefID": "${preparationStatusInterface.preparation_order_originator_reference?trim?json_string}",
+        "RefID": "${preparationStatusInterface.preparation_order_originator_reference?trim?json_string}",
-       "RefDate": {
+        "RefDate": {
-        "DateTime": "${preparation_status_datetime}",
+          "DateTime": "${preparation_status_datetime}",
-        "AuthorTimeZone": "${time_zone_rfx}"
+          "AuthorTimeZone": "${time_zone_rfx}"
       }
     },
 

RFXtoRP_HsaProStatus_TransportStarted.ftl

@@ -7,10 +7,10 @@
       "ProjectID": "${projectRP}"
     },
     "ID": {
-         "RefID": "${preparationStatusInterface.preparation_order_originator_reference?trim?json_string}",
+        "RefID": "${preparationStatusInterface.preparation_order_originator_reference?trim?json_string}",
        "RefDate": {
-        "DateTime": "${preparation_status_datetime}",
+          "DateTime": "${preparation_status_datetime}",
-        "AuthorTimeZone": "${time_zone_rfx}"
+          "AuthorTimeZone": "${time_zone_rfx}"
       }
     },
 

RFXtoRP_HsrPackBranch.ftl

@@ -0,0 +1,32 @@
+<#-- **** input parameters  ***** -->
+<#-- input        : message RFX  -->
+<#-- project      : projectId in ReflexPlatform  -->
+<#-- organisation : organisationtId in ReflexPlatform  -->
+
+<#assign cloudEventMsg = JsonUtil.jsonToMap(input)>
+<#assign projectRP = project>
+<#assign organisationRP = organisation>
+
+<#assign aDateTime = .now>
+
+<#switch cloudEventMsg.action>
+  <#case "C">
+  <#case "U">
+      <#-- *********************************************** Action = CREATE or UPDATE ******************** -->
+      <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
+      <#assign packBranch = JsonUtil.jsonToMap(dataRfx)>
+
+      <#stop "no generic FTL file available yet for Pack Branch">
+      <#break>
+
+    <#case "D">
+      <#-- *********************************************** Action = DELETE ******************** -->
+      <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
+      <#assign packBranch = JsonUtil.jsonToMap(dataRfx)>
+
+      <#stop "no generic FTL file available yet for  Pack Branch">
+      <#break>
+    <#default>
+          <#stop >
+</#switch>
+

RFXtoRP_HsrPackOrder.ftl

@@ -0,0 +1,32 @@
+<#-- **** input parameters  ***** -->
+<#-- input        : message RFX  -->
+<#-- project      : projectId in ReflexPlatform  -->
+<#-- organisation : organisationtId in ReflexPlatform  -->
+
+<#assign cloudEventMsg = JsonUtil.jsonToMap(input)>
+<#assign projectRP = project>
+<#assign organisationRP = organisation>
+
+<#assign aDateTime = .now>
+
+<#switch cloudEventMsg.action>
+  <#case "C">
+  <#case "U">
+      <#-- *********************************************** Action = CREATE or UPDATE ******************** -->
+      <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
+      <#assign packOrder = JsonUtil.jsonToMap(dataRfx)>
+
+      <#stop "no generic FTL file available yet for Pack Order">
+      <#break>
+
+    <#case "D">
+      <#-- *********************************************** Action = DELETE ******************** -->
+      <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
+      <#assign packOrder = JsonUtil.jsonToMap(dataRfx)>
+
+      <#stop "no generic FTL file available yet for Pack Order">
+      <#break>
+    <#default>
+          <#stop >
+</#switch>
+

RFXtoRP_HsrPrepa.ftl

@@ -18,6 +18,7 @@
 <#assign preparationOrder = JsonUtil.jsonToMap(dataRfx)>
 
    <#if	preparationOrder.total_lv_validated !=0>
+      <#if preparationOrder.preparation_line_lst??>
          [
             {
             <#assign apiReflexPlatformID = ApiReflexPlatformID.HandlingunitGoodsPrepared>
@@ -95,8 +96,13 @@
             </#list>
             <#assign refIDHmap ={}>
          ]
+      <#else>
+         <#--   No line-->
+         <#stop >
+      </#if>
    <#else>
-      <#stop "no confirmed quantity for the preparation - preparation closed">
+      <#--   no confirmed quantity for the preparation - preparation closed-->
+      <#stop >
    </#if>
 
 

RFXtoRP_HsrPrepa_CarrierUpdated.ftl

@@ -4,30 +4,30 @@
 [
   <#assign refIDHmap_local ={}>
    <#list preparationOrder.preparation_line_lst?filter(l ->l.preparation_order_originator_reference!="") as preparation_line>
-  <#assign OrderOriginReference = preparation_line.preparation_order_originator_reference?trim?json_string>
+    <#assign OrderOriginReference = preparation_line.preparation_order_originator_reference?trim?json_string>
-    <#if !refIDHmap_local[OrderOriginReference]?? >
+   <#if !refIDHmap_local[OrderOriginReference]?? >
-        <#if refIDHmap_local?size != 0 >
+      <#if refIDHmap_local?size != 0 >
-        ,
+      ,
-        </#if>
+      </#if>
       <#assign refIDHmap_local +={OrderOriginReference,OrderOriginReference}>
-    {
+      {
       "Header": {
       "ProjectID": "${projectRP}"
       },
       "ID":{
       "RefID": "${OrderOriginReference}"
       },
-    "Payload":{
+      "Payload":{
-      "Carrier": {
+        "Carrier": {
-        "ActorID": "${RFXtoRPprefixCarrier(preparationOrder.load_data.carrier_code?trim?json_string)}"
+          "ActorID": "${RFXtoRPprefixCarrier(preparationOrder.load_data.carrier_code?trim?json_string)}"
+        }
+        <#-- Add transport grade code
+        <#if preparationOrder.transport_grade_code!="">
+        ,
+        "CarrierService":"${preparationOrder.transport_grade_code?trim?json_string}"
+        </#if> -->
       }
-      <#-- Add transport grade code
+     }
-      <#if preparationOrder.transport_grade_code!="">
-      ,
-      "CarrierService":"${preparationOrder.transport_grade_code?trim?json_string}"
-      </#if> -->
-    }
-    }
     </#if>
   </#list>
   <#assign refIDHmap_local ={}>

RFXtoRP_HsrPrepa_HandlingunitGoodsPrepared.ftl

@@ -111,9 +111,9 @@
 
        <#-- Segmentation Keys inclusion -->
        <#include "RFXtoRP_HsrPrepa_GoodsPrepared_SegmentationKeys.ftl">
-         },
+        },
-         "OrderID": "${preparation_line.preparation_order_originator_reference?trim?json_string}",
+        "OrderID": "${preparation_line.preparation_order_originator_reference?trim?json_string}",
-       "ExecutionflowID": "${preparation_line.preparation_order_originator_reference?trim?json_string}",
+        "ExecutionflowID": "${preparation_line.preparation_order_originator_reference?trim?json_string}",
         <#if (preparation_line.pro_originator_reference_line_number!0) != 0>
           "LineID": "${preparation_line.pro_originator_reference_line_number}",
         <#else>

RFXtoRP_HsrPrepa_OrderCarrierUpdated.ftl

@@ -5,25 +5,25 @@
   <#assign refIDHmap_local ={}>
   <#list preparationOrder.preparation_line_lst?filter(l ->l.preparation_order_originator_reference!="") as preparation_line>
   <#assign OrderOriginReference = preparation_line.preparation_order_originator_reference?trim?json_string>
-  <#if !refIDHmap_local[OrderOriginReference]?? >
+    <#if !refIDHmap_local[OrderOriginReference]?? >
       <#if refIDHmap_local?size != 0 >
-    ,
+      ,
-    </#if>
+      </#if>
-    <#assign refIDHmap_local +={OrderOriginReference,OrderOriginReference}>
+      <#assign refIDHmap_local +={OrderOriginReference,OrderOriginReference}>
-    {
+      {
-      "Header": {
+        "Header": {
-      "ProjectID": "${projectRP}"
+        "ProjectID": "${projectRP}"
-      },
+        },
-      "ID":{
+        "ID":{
-      "RefID": "${OrderOriginReference}"
+        "RefID": "${OrderOriginReference}"
-      },
+        },
-    "Payload":{
+      "Payload":{
-      "Carrier": {
+        "Carrier": {
-        "ActorID": "${RFXtoRPprefixCarrier(preparationOrder.load_data.carrier_code?trim?json_string)}"
+          "ActorID": "${RFXtoRPprefixCarrier(preparationOrder.load_data.carrier_code?trim?json_string)}"
+        }
       }
-    }
+      }
-    }
+    </#if>
-  </#if>
   </#list>
   <#assign refIDHmap_local ={}>
 ]

RFXtoRP_HsrPro.ftl

@@ -16,29 +16,27 @@
       <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign preparation_order = JsonUtil.jsonToMap(dataRfx)>
        [
-
         <#if  preparation_order.originator_reference?? && preparation_order.originator_reference!="">
           <#-- check preparation type code (internal order and reservation are ignored)  -->
-          <#if preparation_order.preparation_type_code == "010" || preparation_order.preparation_type_code == "030">
+          <#if preparation_order.preparation_type_code?? && (preparation_order.preparation_type_code == "010" || preparation_order.preparation_type_code == "030")>
-            <#-- Only if preparation order not confirmed  -->
+            <#if preparation_order.line_list??>
-            <#if preparation_order.preparation_order_confirmed == "false" >
+              {
-            {
+                <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowDetected>
-              <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowDetected>
+                "apiReflexPlatformID" :  "${apiReflexPlatformID}",
-              "apiReflexPlatformID" :  "${apiReflexPlatformID}",
+                "datas" :
-              "datas" :
+                <#include "RFXtoRP_HsrPro_ExecutionflowDetected.ftl">
-              <#include "RFXtoRP_HsrPro_ExecutionflowDetected.ftl">
+              }
-            }
+            <#else>
-           <#else>
+              <#-- No line -->
-           <#-- preparation order already confirmed -->
+              <#stop>
-            <#stop>
+            </#if>
-           </#if>
-
           <#else>
           <#-- preparation order type not supported -->
-          <#stop>
+            <#stop>
           </#if>
         <#else>
-          <#stop "PRO reference is empty">
+          <#-- PRO reference is empty -->
+          <#stop>
         </#if>
        ]
   <#break>
@@ -49,14 +47,20 @@
       <#assign preparation_order = JsonUtil.jsonToMap(dataRfx)>
        [
         <#if  preparation_order.originator_reference?? && preparation_order.originator_reference!="">
-        {
+          <#if preparation_order.line_list??>
-          <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowCancelled>
+            {
-          "apiReflexPlatformID" :  "${apiReflexPlatformID}",
+              <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowCancelled>
-          "datas" :
+              "apiReflexPlatformID" :  "${apiReflexPlatformID}",
-          <#include "RFXtoRP_HsrPro_ExecutionflowCancelled.ftl">
+              "datas" :
-        }
+              <#include "RFXtoRP_HsrPro_ExecutionflowCancelled.ftl">
+            }
+          <#else>
+            <#-- No line -->
+            <#stop>
+          </#if>
         <#else>
-          <#stop "PRO reference is empty">
+          <#-- PRO reference is empty -->
+          <#stop>
         </#if>
        ]
          <#break>

RFXtoRP_HsrPro_ExecutionflowDetected.ftl

@@ -9,7 +9,7 @@
       "ProjectID": "${projectRP}"
     },
     "ID": {
-      "RefID": "${preparation_order.originator_reference?trim?json_string}",
+    "RefID": "${preparation_order.originator_reference?trim?json_string}",
     "RefDate": {
             "DateTime": "${pro_creation_datetime}",
            "AuthorTimeZone": "${time_zone_rfx}"
@@ -78,7 +78,7 @@
                 }
           </#if>
          },
-
+        "OrderID": "${preparation_order.originator_reference?trim?json_string}",
        <#if preparation_order.line_list??>
        "Lines" : [
            <#list preparation_order.line_list as preparation_order_line >

RFXtoRP_HsrReceiptList.ftl

@@ -17,8 +17,9 @@
       <#assign receipt = JsonUtil.jsonToMap(dataRfx)>
       <#if receipt.receipt_reference ?? && receipt.receipt_reference!="">
         <#if receipt.receipt_type == "030">
-        <#stop "ignored message because receipt type = transfert">
+          <#stop "ignored message because receipt type = transfert">
         <#else>
+          <#if receipt.line_list ??>
           [
           {
             <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowDetected>
@@ -35,10 +36,15 @@
 
           }
           ]
-        </#if>
+          <#else>
-      <#else>
+            <#--  No line-->
-        <#stop "Receipt reference is empty">
+            <#stop>
+          </#if>
       </#if>
+    <#else>
+      <#--  "Receipt reference is empty"-->
+      <#stop>
+    </#if>
       <#break>
     <#case "U">
        <#-- *********************************************** Action = UPDATE ******************** -->
@@ -65,23 +71,29 @@
               <#if receipt.receipt_type == "030">
                 <#stop "ignored message because receipt type = transfert">
               <#else>
-                {
+                <#if receipt.line_list ??>
-                  <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowDetected>
+                  {
+                    <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowDetected>
+                    "apiReflexPlatformID" :  "${apiReflexPlatformID}",
+                    "datas" :
+                    <#include "RFXtoRP_HsrReceiptList_ExecutionflowDetected.ftl">
+                  },
+                  {
+                  <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowReceiptExpected>
                   "apiReflexPlatformID" :  "${apiReflexPlatformID}",
                   "datas" :
-                  <#include "RFXtoRP_HsrReceiptList_ExecutionflowDetected.ftl">
+                  <#include "RFXtoRP_HsrReceiptList_ReceiptExpected.ftl">
-                },
+                  }
-                {
+                <#else>
-                <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowReceiptExpected>
+                  <#--  No line-->
-                "apiReflexPlatformID" :  "${apiReflexPlatformID}",
+                  <#stop>
-                "datas" :
+                </#if>
-                <#include "RFXtoRP_HsrReceiptList_ReceiptExpected.ftl">
-                }
               </#if>
             </#if>
           </#if>
         <#else>
-          <#stop "Receipt reference is empty">
+          <#-- Receipt reference is empty-->
+          <#stop >
         </#if>
        ]
       <#break>
@@ -92,15 +104,21 @@
       <#assign receipt = JsonUtil.jsonToMap(dataRfx)>
        [
         <#if receipt.receipt_reference?? && receipt.receipt_reference!="">
-          {
+          <#if receipt.line_list ??>
+            {
 
-            <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowCancelled>
+              <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowCancelled>
-            "apiReflexPlatformID" :  "${apiReflexPlatformID}",
+              "apiReflexPlatformID" :  "${apiReflexPlatformID}",
-            "datas" :
+              "datas" :
-            <#include "RFXtoRP_HsrReceiptList_ExecutionflowCancelled.ftl">
+              <#include "RFXtoRP_HsrReceiptList_ExecutionflowCancelled.ftl">
-          }
+            }
+            <#else>
+              <#--  No line-->
+              <#stop>
+            </#if>
         <#else>
-          <#stop "Receipt reference is empty">
+           <#-- Receipt reference is empty-->
+          <#stop >
         </#if>
        ]
          <#break>

RFXtoRP_HsrReceiptList_ExecutionflowCancelled.ftl

@@ -1,20 +1,46 @@
 <#include "HfRpConfig.ftl">
 <#include "ReflexUtils.ftl">
 <#assign receipt_status_datetime = RfxDateTimetoUTCWithTimezone(receipt.modification_datetime,time_zone_rfx) />
-
+<#assign refIDHmap_local ={}>
 [
-  {
+  <#if receipt.line_list??>
-    "Header": {
+    <#list receipt.line_list as receipt_line >
-      "ProjectID": "${projectRP}"
+      <#if receipt_line.origin_order_line_reference?? && receipt_line.origin_order_line_reference!="">
-    },
+        <#if !refIDHmap_local[receipt_line.origin_order_line_reference]?? >
-    "ID": {
+          <#if refIDHmap_local?size != 0 >
-      "RefID": "${receipt.receipt_reference?trim?json_string}",
+          ,
-      "RefDate": {
+          </#if>
-        "DateTime": "${receipt_status_datetime}",
+          <#assign refIDHmap_local +={receipt_line.origin_order_line_reference,receipt_line.origin_order_line_reference}>
-        "AuthorTimeZone": "${time_zone_rfx}"
+          {
-      }
+            "Header": {"ProjectID": "${projectRP}"},
-    },
+            "ID": {
-    "Payload": {
+                "RefID": "${receipt_line.receipt_reference?trim?json_string}",
-    }
+              "RefDate": {
-  }
+              "DateTime": "${receipt_status_datetime}",
+              "AuthorTimeZone": "${time_zone_rfx}"
+              }
+          },
+            "Payload": {
+            }
+          }
+        </#if>
+      <#else>
+        <#if receipt.receipt_reference?? && receipt.receipt_reference!="">
+        {
+          "Header": {"ProjectID": "${projectRP}"},
+          "ID": {
+              "RefID": "${receipt.receipt_reference?trim?json_string}",
+            "RefDate": {
+              "DateTime": "${receipt_status_datetime}",
+              "AuthorTimeZone": "${time_zone_rfx}"
+            }
+          },
+          "Payload": {
+          }
+        }
+        <#break>
+        </#if>
+      </#if>
+    </#list>
+  </#if>
 ]

RFXtoRP_HsrReceiptList_ExecutionflowDetected.ftl

@@ -26,7 +26,11 @@
 
       "ShipFrom":
       {
+        <#if receipt.receipt_type == '020'>
+          "ActorID": "${RFXtoRPprefixConsignee(receipt.original_code?trim?json_string)}"
+        <#else>
         "ActorID": "${RFXtoRPprefixSupplier(receipt.original_code?trim?json_string)}"
+        </#if>
       },
         "ShipTo"  :
       {
@@ -40,7 +44,7 @@
           "ActorID":"${RFXtoRPprefixCarrier(receipt.carrier_informations.carrier_code?trim?json_string)}"
         },
       </#if>
-
+      "OrderID": "${receipt.receipt_reference?trim?json_string}",
       <#if receipt.line_list??>
        "Lines" : [
           <#list receipt.line_list as line>

RFXtoRP_HsrReceiptList_ExecutionflowReceiptCompleted.ftl

@@ -1,19 +1,46 @@
 <#include "HfRpConfig.ftl">
 <#include "ReflexUtils.ftl">
-<#assign receipt_status_datetime = RfxDateTimetoUTCWithTimezone(receipt.confirmation_datetime,time_zone_rfx) />
+<#assign receipt_status_datetime = RfxDateTimetoUTCWithTimezone(receipt.modification_datetime,time_zone_rfx) />
+<#assign refIDHmap_local ={}>
 [
-  {
+  <#if receipt.line_list??>
-     "Header": {
+    <#list receipt.line_list as receipt_line >
-      "ProjectID": "${projectRP}"
+      <#if receipt_line.origin_order_line_reference?? && receipt_line.origin_order_line_reference!="">
-    },
+        <#if !refIDHmap_local[receipt_line.origin_order_line_reference]?? >
-    "ID": {
+          <#if refIDHmap_local?size != 0 >
-      "RefID": "${receipt.receipt_reference?trim?json_string}",
+          ,
-      "RefDate": {
+          </#if>
-        "DateTime": "${receipt_status_datetime}",
+          <#assign refIDHmap_local +={receipt_line.origin_order_line_reference,receipt_line.origin_order_line_reference}>
-        "AuthorTimeZone": "${time_zone_rfx}"
+          {
-      }
+            "Header": {"ProjectID": "${projectRP}"},
-    },
+            "ID": {
-    "Payload": {
+                "RefID": "${receipt_line.receipt_reference?trim?json_string}",
-    }
+              "RefDate": {
-  }
+              "DateTime": "${receipt_status_datetime}",
+              "AuthorTimeZone": "${time_zone_rfx}"
+              }
+          },
+            "Payload": {
+            }
+          }
+        </#if>
+      <#else>
+        <#if receipt.receipt_reference?? && receipt.receipt_reference!="">
+        {
+          "Header": {"ProjectID": "${projectRP}"},
+          "ID": {
+              "RefID": "${receipt.receipt_reference?trim?json_string}",
+            "RefDate": {
+              "DateTime": "${receipt_status_datetime}",
+              "AuthorTimeZone": "${time_zone_rfx}"
+            }
+          },
+          "Payload": {
+          }
+        }
+        <#break>
+        </#if>
+      </#if>
+    </#list>
+  </#if>
 ]

RFXtoRP_HsrReceiptList_ReceiptExpected.ftl

@@ -1,21 +1,46 @@
 <#include "HfRpConfig.ftl">
 <#include "ReflexUtils.ftl">
-<#assign receipt_status_datetime = RfxDateTimetoUTCWithTimezone(receipt.creation_datetime,time_zone_rfx) />
+<#assign receipt_status_datetime = RfxDateTimetoUTCWithTimezone(receipt.modification_datetime,time_zone_rfx) />
-
+<#assign refIDHmap_local ={}>
 [
-  {
+  <#if receipt.line_list??>
-    "Header": {
+    <#list receipt.line_list as receipt_line >
-      "ProjectID": "${projectRP}"
+      <#if receipt_line.origin_order_line_reference?? && receipt_line.origin_order_line_reference!="">
-    },
+        <#if !refIDHmap_local[receipt_line.origin_order_line_reference]?? >
-    "ID": {
+          <#if refIDHmap_local?size != 0 >
-         "RefID": "${receipt.receipt_reference?trim?json_string}",
+          ,
-       "RefDate": {
+          </#if>
-        "DateTime": "${receipt_status_datetime}",
+          <#assign refIDHmap_local +={receipt_line.origin_order_line_reference,receipt_line.origin_order_line_reference}>
-        "AuthorTimeZone": "${time_zone_rfx}"
+          {
-      }
+            "Header": {"ProjectID": "${projectRP}"},
-    },
+            "ID": {
-
+                "RefID": "${receipt_line.receipt_reference?trim?json_string}",
-    "Payload": {}
+              "RefDate": {
-
+              "DateTime": "${receipt_status_datetime}",
-  }
+              "AuthorTimeZone": "${time_zone_rfx}"
+              }
+          },
+            "Payload": {
+            }
+          }
+        </#if>
+      <#else>
+        <#if receipt.receipt_reference?? && receipt.receipt_reference!="">
+        {
+          "Header": {"ProjectID": "${projectRP}"},
+          "ID": {
+              "RefID": "${receipt.receipt_reference?trim?json_string}",
+            "RefDate": {
+              "DateTime": "${receipt_status_datetime}",
+              "AuthorTimeZone": "${time_zone_rfx}"
+            }
+          },
+          "Payload": {
+          }
+        }
+        <#break>
+        </#if>
+      </#if>
+    </#list>
+  </#if>
 ]

RPtoRFX_ExecutionflowEvent.ftl

@@ -17,6 +17,7 @@
 
 <#switch eventRP.event>
 	  <#case "Created">
+	  <#case "Renotified">
 			 <#-- *********************************************** Action = CREATE or UPDATE ******************** -->
 			<#assign executionflow = eventRP.data />
 

RPtoRFX_PrepOrder.ftl

@@ -44,6 +44,7 @@
         "automatic_generation": "${automatic_generation_flag}",
 		"deactivate": "false",
 		"optional_attributes": {
+			<#include "RPtoRFX_PrepOrder_OptionalAttributes.ftl">
 			"apt_with_end_consignee": "${apt_with_end_consignee_flag}",
 			"apt_with_intermediate": "false",
 			"load_grouping": "${load_grouping}"
@@ -83,9 +84,13 @@
 				<#-- ******* line  MetaData and Segmentationkeys to maps ******** -->
 				<#if line.MetaData??>
 				<#assign Line_MetaData_Map = JsonUtil.sequenceToMap(line.MetaData, "Key", "Value") />
+				<#else>
+				<#assign Line_MetaData_Map = {} />
 				</#if>
 				<#if line.RequestedContent.Goods.SegmentationKeys??>
 				<#assign SegmentationKeys_Map = JsonUtil.sequenceToMap(line.RequestedContent.Goods.SegmentationKeys, "Key", "Value") />
+				<#else>
+				<#assign SegmentationKeys_Map = {} />
 				</#if>
 				<#include "RPtoRFX_PrepOrder_DefaultLineData.ftl">
 				{
@@ -100,13 +105,6 @@
 				"batch_1": "${batch_1?json_string}",
 				"base_lv_quantity": "true",
 				"any_lv": "false"
-				<#--
-				"stock_reservation": "false",
-				"forced_priority_date_min_lead_time": "false",
-				"temp_substitution_possible": "false",
-				"substitution_possible": "false"
-				-->
-
 				}
 			<#sep>,</#sep>
 			</#list>

RPtoRFX_PrepOrder_OptionalAttributes.ftl

@@ -0,0 +1,8 @@
+<#-- Here are the fields that can be added
+"end_consignee_apt_start_datetime": "0000-00-00T00:00:00",
+"end_consignee_apt_end_datetime": "0000-00-00T00:00:00",
+"reason_code": "str",
+"planned_preparation_date": "0000-00-00",
+"despatch_grouping": "string",
+"reservation_end_datetime": "0000-00-00T00:00:00",
+-->

RPtoRFX_Receipt.ftl

@@ -38,9 +38,13 @@
 			<#-- ******* line  MetaData and Segmentationkeys to maps ******** -->
 				<#if line.MetaData??>
 				<#assign Line_MetaData_Map = JsonUtil.sequenceToMap(line.MetaData, "Key", "Value") />
+				<#else>
+				<#assign Line_MetaData_Map = {} />
 				</#if>
 				<#if line.RequestedContent.Goods.SegmentationKeys??>
 				<#assign SegmentationKeys_Map = JsonUtil.sequenceToMap(line.RequestedContent.Goods.SegmentationKeys, "Key", "Value") />
+				<#else>
+				<#assign SegmentationKeys_Map = {} />
 				</#if>
 			<#include "RPtoRFX_Receipt_DefaultLineData.ftl">
 			{
@@ -53,15 +57,9 @@
 				"grade_code": "${grade_code}",
 				"batch_1": "${batch_1?json_string!""}",
 				"optional_attributes": {
-			   		<#--"held_for_check": "false",
+				<#include "RPtoRFX_Receipt_OptionalAttributes.ftl">
-			   		"hold_code": "false", -->
+				"hold_for_specific_code": "false"
-					"hold_for_specific_code": "false"
 		 		}
-		  		<#--"quality_control_attributes": {
-	        		"qcf_to_create_for_receipt_line": "false",
-	         		"exclude_item_from_inspection": "false"
-  				} -->
-
 			}<#sep>,</#sep>
 		</#list>
 		]

RPtoRFX_Receipt_OptionalAttributes.ftl

@@ -0,0 +1,16 @@
+<#-- Here are the fields that can be added
+"batch_2": "string",
+"batch_3": "string",
+"anticipated_receipt_line_activity_code": "str",
+"anticipated_receipt_line_physical_depot_code": "str",
+"anticipated_receipt_line_originator_code": "string",
+"anticipated_receipt_reference": "string",
+"anticipated_receipt_planned_date": "0000-00-00",
+"anticipated_receipt_reference_line_no": 999999,
+"reservation_consignee_code": "string",
+"reservation_consignee_group_code": "string",
+"pro_reservation_reference": "string",
+"held_for_check": "false",
+"held_for_repacking": "false",
+"hold_code": "str"
+-->

VERSION

@@ -1 +1 @@
-1.2.39+2
+1.2.45+1