<#-- **** input parameters  ***** -->
<#-- input        : message HARDIS WMS  -->
<#-- project      : projectId in HARDIS SC NETWORK  -->
<#-- organisation : organisationtId in HARDIS SC NETWORK  -->

<#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 preparationStatusInterface = JsonUtil.jsonToMap(dataRfx) />
      [
         <#--**Pick batch runned (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.ExecutionflowPreparationStarted>
                  "apiReflexPlatformID" :  "${apiReflexPlatformID}",
                  "datas" :
                     <#include "RFXtoRP_HsaProStatus_PreparationStarted.ftl">
                  }
               <#else>
                     <#-- ****Preparation dispatched (600)** -->
                  <#if preparationStatusInterface.preparation_status_type == "100" && preparationStatusInterface.preparation_status_code == "600" >
                        {
                        <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowPreparationCompleted>
                        "apiReflexPlatformID" :  "${apiReflexPlatformID}",
                        "datas" :
                           <#include "RFXtoRP_HsaProStatus_PreparationCompleted.ftl">
                        },
                        {
                           <#assign apiReflexPlatformID = ApiReflexPlatformID.ExecutionflowTransportStarted>
                           "apiReflexPlatformID" :  "${apiReflexPlatformID}",
                           "datas" :
                              <#include "RFXtoRP_HsaProStatus_TransportStarted.ftl">
                        }
                  <#else>
                        <#-- ****Preparation cancelled (650)**** -->
                     <#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>
      ]
      <#break>

   <#case "D">
      <#-- *********************************************** Action = DELETE ******************** -->
      <#stop >
      <#break>

   <#default>
      <#stop >
</#switch>