Merge branch 'release/1.2' into 'main-1.2'

release/1.2 into main-1.2

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

ActorPrefix.ftl

@@ -37,7 +37,11 @@
   <#if uniqueness>
     <#local depot = actor>
   <#else>
+    <#if actor?length gt 4>
     <#local depot = actor[4..]>
+    <#else>
+        <#local depot = actor>
+    </#if>
   </#if>
 <#return (depot)>
 </#function>
@@ -78,7 +82,11 @@
   <#if uniqueness>
     <#local supplier = actor>
   <#else>
+    <#if actor?length gt 4>
     <#local supplier = actor[4..]>
+    <#else>
+        <#local supplier = actor>
+    </#if>
   </#if>
 <#return (supplier)>
 </#function>
@@ -117,7 +125,11 @@
   <#if uniqueness>
     <#local carrier = actor>
   <#else>
+    <#if actor?length gt 4>
     <#local carrier = actor[4..]>
+    <#else>
+        <#local carrier = actor>
+    </#if>
   </#if>
 <#return (carrier)>
 </#function>
@@ -156,7 +168,11 @@
   <#if uniqueness>
     <#local consignee = actor>
   <#else>
+    <#if actor?length gt 4>
     <#local consignee = actor[4..]>
+    <#else>
+        <#local consignee = actor>
+    </#if>
   </#if>
 <#return (consignee)>
 </#function>

RFXtoRP_HfGrade.ftl

@@ -9,7 +9,7 @@
 	<#case "C">
 	<#case "U">
 	<#case "D">
-		<#stop "no generic FTL file available yet for Grades">
+		<#stop>
 	<#break>
 
 

RFXtoRP_HfLvTypeList.ftl

@@ -9,9 +9,7 @@
 	<#case "C">
 	<#case "U">
 	<#case "D">
-
-		<#stop "no generic FTL file available yet for LV types">
-
+	<#stop>
 	<#break>
 
 

RFXtoRP_HfOwner.ftl

@@ -9,7 +9,7 @@
 	<#case "C">
 	<#case "U">
 	<#case "D">
-		<#stop "no generic FTL file available yet for Owners">
+	<#stop>
 	<#break>
 
 

RFXtoRP_HsaDesPatch.ftl

@@ -16,7 +16,7 @@
       <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign desPatch = JsonUtil.jsonToMap(dataRfx)>
 
-      <#stop "no generic FTL file available yet for desPatch">
+      <#stop>
       <#break>
 
     <#case "D">
@@ -24,7 +24,7 @@
       <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign desPatch = JsonUtil.jsonToMap(dataRfx)>
 
-      <#stop "no generic FTL file available yet for desPatch">
+      <#stop>
       <#break>
     <#default>
           <#stop >

RFXtoRP_HsaDespNt.ftl

@@ -16,7 +16,7 @@
       <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign despNt = JsonUtil.jsonToMap(dataRfx)>
 
-      <#stop "no generic FTL file available yet for despNt">
+      <#stop>
       <#break>
 
     <#case "D">
@@ -24,7 +24,7 @@
       <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign despNt = JsonUtil.jsonToMap(dataRfx)>
 
-      <#stop "no generic FTL file available yet for despNt">
+      <#stop>
       <#break>
     <#default>
           <#stop >

RFXtoRP_HsaIpgMove_StockMoved.ftl

@@ -60,7 +60,7 @@
         </#if>
         "ExternalInfo" : "${reflexMvtStockInterface.stock_move_reference?json_string}",
         <#if reflexMvtStockInterface.ipg_move_operation_year_number!= 0>
-          "OperationReference": "${reflexMvtStockInterface.ipg_move_operation_year_number} - ${reflexMvtStockInterface.ipg_move_operation_number}",
+          "OperationReference": "${reflexMvtStockInterface.physical_depot_code}${reflexMvtStockInterface.activity_code}-${reflexMvtStockInterface.ipg_move_operation_year_number}-${reflexMvtStockInterface.ipg_move_operation_number}",
         </#if>
 
         "Quantity":

RFXtoRP_HsaLstCarSta.ftl

@@ -1,5 +1,5 @@
 <#-- **** input parameters  ***** -->
-<#-- input        : message HARDIS WMS  -->
+<#-- input        : message RFX  -->
 <#-- project      : projectId in ReflexPlatform  -->
 <#-- organisation : organisationtId in ReflexPlatform  -->
 <#include "ActorPrefix.ftl">

RFXtoRP_HsaLstCarSta_CarrierExpected.ftl

@@ -1,5 +1,6 @@
 [
     <#assign ref_datetime = RfxDateTimetoUTCWithTimezone(carrier_apt_status.status.creation_datetime,time_zone_rfx) />
+    <#assign ref_datetime2 = AddSecondsToDatetime(ref_datetime?datetime.iso, 1)?iso_utc />
     {
         "Header": {
             "ProjectID": "${projectRP}"
@@ -19,7 +20,7 @@
                 </#if>
             </#if>
 			"RefDate": {
-               "DateTime": "${ref_datetime}",
+               "DateTime": "${ref_datetime2}",
                "AuthorTimeZone": "${time_zone_rfx}"
 			 }
         },

RFXtoRP_HsrCarrierApt.ftl

@@ -36,35 +36,7 @@
   <#break>
     <#case "U">
     <#--   *********************************************** Action = Update ********************-->
-    <#if carrier_apt.constant_appointment?? && carrier_apt.constant_appointment== "true">
-			<#if carrier_apt.appointment_reference?? && carrier_apt.appointment_reference!="">
-        <#assign ID = "${carrier_apt.appointment_reference?json_string}-${carrier_apt.year_number}-${carrier_apt.appointment_number}" />
-			<#else>
-				<#assign ID = "${carrier_apt.year_number}-${carrier_apt.appointment_number}" />
-			</#if>
-		<#else>
-			<#if carrier_apt.appointment_reference?? && carrier_apt.appointment_reference!="">
-        <#assign ID = "${carrier_apt.appointment_reference?json_string}" />
-			<#else>
-        <#assign ID = "${carrier_apt.year_number}-${carrier_apt.appointment_number}" />
-			</#if>
-		</#if>
-      <#assign payload = '{"Header": {"ProjectID": "${projectRP}:${RFXtoRPprefixDepot(carrier_apt.physical_depot?json_string)}"},"IDs": [{"RefID": "${ID}"}],"Options": {"Only": ["ID.RefID","Payload.WMSCreated"]}}'/>
-      <#assign queryApiReflexPlatformID = QueryApiReflexPlatformID.AppointmentGetByIds>
-      <#assign response = QueryApiReflexPlatformCall.call(queryApiReflexPlatformID,payload) />
-      <#assign appointmentRP = JsonUtil.jsonToMap(response)>
-
-      <#if !appointmentRP?? || !appointmentRP.Objects?? || !appointmentRP.Objects[0]?? || !appointmentRP.Objects[0].ID.RefID?? || !appointmentRP.Objects[0].Payload?? || !appointmentRP.Objects[0].Payload.WMSCreated?? || !appointmentRP.Objects[0].Payload.WMSCreated>
-      [
-        {
-          <#assign apiReflexPlatformID = ApiReflexPlatformID.BookingForceBookAppointment>
-          "apiReflexPlatformID" :  "${apiReflexPlatformID}",
-          "datas" :
-          <#include "RFXtoRP_HsrCarrierApt_BookingForceBookAppointment.ftl">
-        }
-      ]
-      <#else>
-      [
+        [
         {
         <#assign apiReflexPlatformID = ApiReflexPlatformID.AppointmentCustomFieldsUpdated>
         "apiReflexPlatformID" :  "${apiReflexPlatformID}",
@@ -76,10 +48,10 @@
       <#if carrier_apt.status?? && (carrier_apt.status.status_code=="999" || carrier_apt.status.status_code=="040" || carrier_apt.status.status_code=="030")>
       [
         {
-        <#assign apiReflexPlatformID = ApiReflexPlatformID.BookingCancelAppointment>
+        <#assign apiReflexPlatformID = ApiReflexPlatformID.BookingForceCancelAppointment>
         "apiReflexPlatformID" :  "${apiReflexPlatformID}",
         "datas" :
-        <#include "RFXtoRP_HsrCarrierApt_BookingCancelAppointment.ftl">
+        <#include "RFXtoRP_HsrCarrierApt_BookingForceCancelAppointment.ftl">
         }
       ]
       <#else>
@@ -159,17 +131,16 @@
         </#if>
       </#if>
       ]
-      </#if>
     <#break>
 <#case "D">
       <#-- *********************************************** Action = Delete ******************** -->
        [
        <#-- Ajout des lignes-->
         {
-          <#assign apiReflexPlatformID = ApiReflexPlatformID.BookingCancelAppointment>
+          <#assign apiReflexPlatformID = ApiReflexPlatformID.BookingForceCancelAppointment>
           "apiReflexPlatformID" :  "${apiReflexPlatformID}",
           "datas" :
-          <#include "RFXtoRP_HsrCarrierApt_BookingCancelAppointment.ftl">
+          <#include "RFXtoRP_HsrCarrierApt_BookingForceCancelAppointment.ftl">
         }
        ]
          <#break>

RFXtoRP_HsrCarrierApt_BookingForceBookAppointment.ftl

@@ -61,8 +61,12 @@
 				</#if>
 				<#assign appointmentType = AppointmentType.APPOINTMENT_TYPE_UNLOADING>
 				<#assign duration = DurationBetweenTwoDatetimeInSeconds(carrier_apt.planned_unloading_start_datetime?datetime.iso,carrier_apt.planned_unloading_end_datetime?datetime.iso) />
-				<#if (duration <= 0)>
+				<#if (duration < 0)>
 					<#stop "planned_unloading_start_datetime or planned_unloading_end_datetime field of appointmend are not valid" >
+				<#else>
+					<#if (duration == 0)>
+					   <#assign duration = 1 />
+					</#if>
 				</#if>
 			<#else>
 				<#if carrier_apt.unloading_appointment == "false" && carrier_apt.load_appointment == "true" >
@@ -71,8 +75,12 @@
 					</#if>
 					<#assign appointmentType = AppointmentType.APPOINTMENT_TYPE_LOADING>
 					<#assign duration = DurationBetweenTwoDatetimeInSeconds(carrier_apt.planned_load_start_datetime?datetime.iso,carrier_apt.planned_load_end_datetime?datetime.iso) />
-					<#if (duration <= 0)>
-						<#stop "planned_unloading_start_datetime or planned_unloading_end_datetime field of appointmend are not valid" >
+					<#if (duration < 0)>
+						<#stop "planned_load_start_datetime or planned_load_end_datetime field of appointmend are not valid" >
+					<#else>
+						<#if (duration == 0)>
+						<#assign duration = 1 />
+						</#if>
 					</#if>
 				<#else>
 					<#if carrier_apt.unloading_appointment == "true" && carrier_apt.load_appointment == "true">
@@ -81,8 +89,12 @@
 						</#if>
 						<#assign appointmentType = AppointmentType.APPOINTMENT_TYPE_UNLOADING>
 						<#assign duration = DurationBetweenTwoDatetimeInSeconds(carrier_apt.planned_unloading_start_datetime?datetime.iso,carrier_apt.planned_load_end_datetime?datetime.iso) />
-						<#if (duration <= 0)>
+						<#if (duration < 0)>
 							<#stop "planned_unloading_start_datetime or planned_load_end_datetime field of appointmend are not valid" >
+						<#else>
+							<#if (duration == 0)>
+							<#assign duration = 1 />
+							</#if>
 						</#if>
 					<#else>
 						<#stop "Appointment type not supported" >

RFXtoRP_HsrCarrierApt_CarrierExpected.ftl

@@ -1,6 +1,6 @@
 [
-    <#assign ref_datetime = RfxDateTimetoUTCWithTimezone(carrier_apt.metadata.creation_datetime,time_zone_rfx) />
-    <#assign ref_datetime2 = AddSecondsToDatetime(ref_datetime?datetime.iso, 60)?iso_utc />
+    <#assign ref_datetime = RfxDateTimetoUTCWithTimezone(carrier_apt.metadata.last_update_datetime,time_zone_rfx) />
+    <#assign ref_datetime2 = AddSecondsToDatetime(ref_datetime?datetime.iso, 1)?iso_utc />
     {
         "Header": {
             "ProjectID": "${projectRP}"

RFXtoRP_HsrLoadInfo.ftl

@@ -17,22 +17,14 @@
        <#-- *********************************************** Action = CREATE or UPDATE ******************** -->
       <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign depot = JsonUtil.jsonToMap(dataRfx)>
-       [
-          {
-
-          }
-       ]
+       <#stop>
       <#break>
 
     <#case "D">
       <#-- *********************************************** Action = DELETE *************************** -->
         <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign depot = JsonUtil.jsonToMap(dataRfx)>
-       [
-           {
-
-           }
-       ]
+       <#stop>
        <#break>
 
     <#default>

RFXtoRP_HsrPackBranch.ftl

@@ -16,7 +16,7 @@
       <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign packBranch = JsonUtil.jsonToMap(dataRfx)>
 
-      <#stop "no generic FTL file available yet for Pack Branch">
+      <#stop>
       <#break>
 
     <#case "D">
@@ -24,7 +24,7 @@
       <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign packBranch = JsonUtil.jsonToMap(dataRfx)>
 
-      <#stop "no generic FTL file available yet for  Pack Branch">
+      <#stop>
       <#break>
     <#default>
           <#stop >

RFXtoRP_HsrPackOrder.ftl

@@ -16,7 +16,7 @@
       <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign packOrder = JsonUtil.jsonToMap(dataRfx)>
 
-      <#stop "no generic FTL file available yet for Pack Order">
+      <#stop>
       <#break>
 
     <#case "D">
@@ -24,7 +24,7 @@
       <#assign dataRfx = JsonUtil.decodeBase64(cloudEventMsg.data) />
       <#assign packOrder = JsonUtil.jsonToMap(dataRfx)>
 
-      <#stop "no generic FTL file available yet for Pack Order">
+      <#stop>
       <#break>
     <#default>
           <#stop >

RFXtoRP_HsrPro.ftl

@@ -25,6 +25,12 @@
                 "apiReflexPlatformID" :  "${apiReflexPlatformID}",
                 "datas" :
                 <#include "RFXtoRP_HsrPro_ExecutionflowDetected.ftl">
+              },
+               {
+                <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowCustomFieldsUpdated>
+                "apiReflexPlatformID" :  "${apiReflexPlatformID}",
+                "datas" :
+                <#include "RFXtoRP_HsrPro_ExecutionflowCustomFieldsUpdated.ftl">
               }
             <#else>
               <#-- No line -->

RFXtoRP_HsrPro_ExecutionflowCustomFieldsUpdated.ftl

@@ -0,0 +1,40 @@
+<#include "HfRpConfig.ftl">
+<#include "ReflexUtils.ftl">
+<#include "ActorPrefix.ftl">
+[
+    {
+        "Header": {
+            "ProjectID": "${projectRP}"
+        },
+        "Payload" :{},
+        "ID":{
+            "CustomFields": [
+            {
+                "Key": "depot_code",
+                "Value": "${preparation_order.physical_depot_code?trim?json_string}"
+            },
+            {
+                "Key": "activity_code",
+                "Value": "${preparation_order.activity_code?trim?json_string}"
+            },
+            {
+                "Key": "originator_code",
+                "Value": "${preparation_order.originator_code?trim?json_string}"
+            },
+            {
+                "Key": "reference",
+                "Value": "${preparation_order.originator_reference?trim?json_string}"
+            },
+            {
+                "Key": "order_year",
+                "Value": "${preparation_order.preparation_order_year}"
+            },
+             {
+                "Key": "order_number",
+                "Value": "${preparation_order.preparation_order_number}"
+            }
+        ],
+        "RefID": "${preparation_order.originator_reference?trim?json_string}"
+        }
+    }
+]

RFXtoRP_HsrReceiptList.ftl

@@ -32,6 +32,12 @@
             "apiReflexPlatformID" :  "${apiReflexPlatformID}",
             "datas" :
             <#include "RFXtoRP_HsrReceiptList_ReceiptExpected.ftl">
+          },
+          {
+            <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowCustomFieldsUpdated>
+            "apiReflexPlatformID" :  "${apiReflexPlatformID}",
+            "datas" :
+            <#include "RFXtoRP_HsrReceiptList_CustomFieldsUpdated.ftl">
           }
           ]
           <#else>

RFXtoRP_HsrReceiptList_CustomFieldsUpdated.ftl

@@ -0,0 +1,44 @@
+<#include "HfRpConfig.ftl">
+<#include "ReflexUtils.ftl">
+<#include "ActorPrefix.ftl">
+[
+    {
+        "Header": {
+            "ProjectID": "${projectRP}"
+        },
+        "Payload" :{},
+        "ID":{
+            "CustomFields": [
+            {
+                "Key": "depot_code",
+                "Value": "${receipt.physical_depot_code?trim?json_string}"
+            },
+            {
+                "Key": "activity_code",
+                "Value": "${receipt.activity_code?trim?json_string}"
+            },
+            {
+                "Key": "originator_code",
+                "Value": "${receipt.originator_code?trim?json_string}"
+            },
+            {
+                "Key": "reference",
+                "Value": "${receipt.receipt_reference?trim?json_string}"
+            },
+            {
+                "Key": "order_year",
+                "Value": "${receipt.receipt_year}"
+            },
+             {
+                "Key": "order_number",
+                "Value": "${receipt.receipt_number}"
+            }
+        ],
+        <#if receipt.receipt_reference?? && receipt.receipt_reference!="">
+            "RefID": "${receipt.receipt_reference?trim?json_string}"
+        <#else>
+            "RefID": "${receipt.physical_depot_code?trim?json_string}${receipt.activity_code?trim?json_string}${receipt.originator_code?trim?json_string}${receipt.receipt_year}${receipt.receipt_number}"
+        </#if>
+        }
+    }
+]

RFXtoRP_PlatformLogCreate.ftl

@@ -23,16 +23,16 @@
 	    },
 	    "TechMessage": {
 	      "Code": "${restResponsetMsg.status!"no Code"}",
-	      "Label": ${strJsonBody}
+	      "Label": ${strJsonBody?truncate(32000,'...')}
 	      },
 	    "UserMessage": {
 	      "Code": "${restResponsetMsg.status!"no Code"}",
-	      "Label": ${strJsonBody},
+	      "Label": ${strJsonBody?truncate(32000,'...'),
 	      "Params": []
 	    },
 	    "DetailElements": [],
 	    "CorrelationID": "${id.correlationid!"no Correlationid"}",
-	    "ContextPayload": ${strJsonBody},
+	    "ContextPayload": ${strJsonBody?truncate(32000,'...')},
 	    "Type": "${event}",
 	    "Task": "${id.apiRestReflexID!"no Task"}",
 	    "OriginalID": "${id.refid!"no OriginalID"?trim?json_string}",

RPtoRFX_AppointmentEvent.ftl

@@ -28,10 +28,6 @@
 	    <#assign AddComma = false />
 		<#assign appointment = eventRP.data />
 	[
-<<<<<<< HEAD
-		<#if eventRP.commissionsUpdated>
-			<#if appointment.AppointmentType == "APPOINTMENT_TYPE_UNLOADING" && eventRP.addedCommissions?? && eventRP.addedCommissions !="">
-=======
 		<#if appointment?? && (!(appointment.WMSCreated??) ||  !appointment.WMSCreated) &&  appointment.Status?? && appointment.Status.Current?? && appointment.Status.Current.StatusCode?? && appointment.Status.Current.StatusCode == AppointmentStatusCode.APPOINTMENT_0150_ALLOCATION_ERROR>
 		{
 			<#assign apiRestReflexID = ApiRestReflexID.appointment_post_create>
@@ -42,7 +38,6 @@
 		<#else>
 			<#if eventRP.commissionsUpdated>
 				<#if appointment.AppointmentType == AppointmentType.APPOINTMENT_TYPE_UNLOADING && eventRP.addedUnloadCommissions?? && eventRP.addedUnloadCommissions != "">
->>>>>>> develop-1.2
 					<#if eventRP.appointmentCustomFields?has_content>
 					{
 						<#assign apiRestReflexID = ApiRestReflexID.appointment_post_physical_receipt_associations_by_number>
@@ -58,21 +53,12 @@
 						<#include "RPtoRFX_CarrierAppointmentPhysicalReceiptAssociationByRef.ftl">
 					}
 					</#if>
-<<<<<<< HEAD
-				<#assign AddComma = true />
-				</#if>
-			<#if appointment.AppointmentType == "APPOINTMENT_TYPE_UNLOADING" && eventRP.removedCommissions?? && eventRP.removedCommissions!="">
-				<#if AddComma == true>
-					   ,
-					</#if>	
-=======
 					<#assign AddComma = true />
 				</#if>
 				<#if appointment.AppointmentType == AppointmentType.APPOINTMENT_TYPE_UNLOADING && eventRP.removedUnloadCommissions?? && eventRP.removedUnloadCommissions!="">
 					<#if AddComma == true>
 						,
 					</#if>
->>>>>>> develop-1.2
 
 					<#if eventRP.appointmentCustomFields?has_content>
 					{

VERSION

@@ -1 +1 @@
-1.2.59+1
+1.2.60+5