Do not allow multiple sources update the order at the same time

src/Dynamicweb.Ecommerce.DynamicwebLiveIntegration/Connectors/Connector.cs

@@ -85,6 +85,11 @@ public static XmlDocument CalculateOrder(Settings settings, string orderXml, Ord
 
             try
             {
+                if (createOrder)
+                {
+                    OrderHandler.SetCurrentlyProcessingOrder(order);
+                }
+
                 Diagnostics.ExecutionTable.Current.Add("DynamicwebLiveIntegration.Connector.CalculateOrder START");
                 // only retry if is not create order, for create order schedule task will send later
                 document = Communicate(settings, orderXml, $"CalculateOrder (ID: {order.Id}, CreateOrder: {createOrder})", logger, submitType, !createOrder, true, order);
@@ -96,6 +101,13 @@ public static XmlDocument CalculateOrder(Settings settings, string orderXml, Ord
                     $"Error CalculateOrder Order Id:'{order.Id}' CreateOrder:'{createOrder}' Message:'{ex.Message}'.");
                 error = ex;
             }
+            finally
+            {
+                if (createOrder)
+                {
+                    OrderHandler.RemoveCurrentlyProcessingOrder(order);
+                }
+            }
 
             if (EnableThrowExceptions && error != null)
             {

src/Dynamicweb.Ecommerce.DynamicwebLiveIntegration/Dynamicweb.Ecommerce.DynamicwebLiveIntegration.csproj

@@ -1,6 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk">
 	<PropertyGroup>
-		<Version>10.4.29</Version>		
+		<Version>10.4.30</Version>		
 		<AssemblyVersion>1.0.0.0</AssemblyVersion>
 		<Title>Live Integration</Title>
 		<Description>Live Integration</Description>

src/Dynamicweb.Ecommerce.DynamicwebLiveIntegration/OrderHandler.cs

@@ -1,4 +1,5 @@
-using Dynamicweb.Core;
+using Dynamicweb.Caching;
+using Dynamicweb.Core;
 using Dynamicweb.Ecommerce.DynamicwebLiveIntegration.Cache;
 using Dynamicweb.Ecommerce.DynamicwebLiveIntegration.Configuration;
 using Dynamicweb.Ecommerce.DynamicwebLiveIntegration.Connectors;
@@ -1374,5 +1375,24 @@ private static void SaveOrderHash(Settings settings, string hashValue)
         }
 
         #endregion Hash helper methods
+
+        private static string OrderCacheKey(Order order) => $"OrderHandlerSentOrder{order.Id}";
+
+        internal static void SetCurrentlyProcessingOrder(Order order)
+        {
+            string key = OrderCacheKey(order);
+            if (!Caching.Cache.Current.Contains(key))
+            {
+                Caching.Cache.Current.Set(key, key, new CacheItemPolicy() { SlidingExpiration = TimeSpan.FromMinutes(30) });
+            }
+        }
+
+        internal static bool IsOrderCurrentlyProcessing(Order order) => Caching.Cache.Current.Contains(OrderCacheKey(order));
+
+        internal static void RemoveCurrentlyProcessingOrder(Order order)
+        {
+            string key = $"OrderHandlerSentOrder{order.Id}";
+            Caching.Cache.Current.Remove(key);
+        }
     }
 }

src/Dynamicweb.Ecommerce.DynamicwebLiveIntegration/ScheduledTasks/CaptureOrdersScheduledTask.cs

@@ -18,7 +18,7 @@
     [AddInDescription("Capture orders payments updated through Batch Integration and updating using Live Integration")]
     [AddInIgnore(false)]
     [AddInUseParameterGrouping(true)]
     public class CaptureOrdersScheduledTask : BatchIntegrationScheduledTaskAddinBase, IDropDownOptions
     {
         private readonly Dictionary<string, CheckoutHandler> _paymentHandlers = new Dictionary<string, CheckoutHandler>();
         private string _processError;
@@ -347,6 +347,12 @@
 
             foreach (var order in ordersToSync)
             {
+                if (OrderHandler.IsOrderCurrentlyProcessing(order))
+                {
+                    Logger.Log($"Skipping order: {order.Id} as it is currently processing");
+                    continue;
+                }
+
                 Settings orderSettings = shopSettings;
                 if (orderSettings == null)
                 {

src/Dynamicweb.Ecommerce.DynamicwebLiveIntegration/ScheduledTasks/QueuedOrdersSyncScheduledTask.cs

@@ -22,7 +22,7 @@
     [AddInDescription("Sync queued orders using Dynamicweb Live Integration")]
     [AddInIgnore(false)]
     [AddInUseParameterGrouping(true)]
     public class QueuedOrdersSyncScheduledTask : BatchIntegrationScheduledTaskAddin, IDropDownOptions
     {
         /// <summary>
         /// Initializes a new instance of the <see cref="QueuedOrdersSyncScheduledTask"/> class.
@@ -142,6 +142,11 @@
                     Settings shopSettings = SettingsManager.GetSettingsByShop(ShopId);
                     foreach (var order in ordersToSync.GetResultOrders())
                     {
+                        if (OrderHandler.IsOrderCurrentlyProcessing(order))
+                        {
+                            Logger.Log($"Skipping order: {order.Id} as it is currently processing");
+                            continue;
+                        }
                         Settings settings = shopSettings;
                         if (settings == null)
                         {

src/Dynamicweb.Ecommerce.DynamicwebLiveIntegration/ScheduledTasks/UpdateOrdersScheduledTask.cs

@@ -17,7 +17,7 @@
     [AddInDescription("Update orders based on custom fields to update order state and this will generate emails notifications.")]
     [AddInIgnore(false)]
     [AddInUseParameterGrouping(true)]
     public class UpdateOrdersScheduledTask : BatchIntegrationScheduledTaskAddinBase, IDropDownOptions
     {
         private string _processErrorForEmail;
 
@@ -277,6 +277,12 @@
 
             foreach (var order in ordersToSync)
             {
+                if (OrderHandler.IsOrderCurrentlyProcessing(order))
+                {
+                    Logger.Log($"Skipping order: {order.Id} as it is currently processing");
+                    continue;
+                }
+
                 var erpUpdated = SendToErp(order);
                 if (!SkipCustomFieldUpdateOnErpFailure || erpUpdated)
                     UpdateOrderCustomField(order);