if persistent data not exist on Read in DB -> create it

ix-ax · Sep 18, 2024 · 39dc647 · 39dc647
1 parent 23e6aa4
commit 39dc647
Showing 1 changed file with 13 additions and 6 deletions.
diff --git a/src/data/src/AXOpen.Data/DataPersistentExchange/AxoDataPersistentExchange.cs b/src/data/src/AXOpen.Data/DataPersistentExchange/AxoDataPersistentExchange.cs
@@ -141,7 +141,6 @@ private void AddTagsFromRecordToWrittenList(List<ITwinPrimitive> tagsToWrite, Pe
             }
         }
 
-
         /// <summary>
         /// Updates a persistent group of tags to the repository after reading from the PLC.
         /// </summary>
@@ -155,7 +154,6 @@ public async Task<bool> UpdatePersistentGroupFromPlcToRepository(string persiste
 
         private bool UpdateReadedTagsToRepository(string persistentGroupName)
         {
-
             var primitivesTagsInGroup = tagsInGroups[persistentGroupName];
 
             if (primitivesTagsInGroup == null)
@@ -223,7 +221,6 @@ private bool UpdateReadedTagsToRepository(string persistentGroupName)
             return true;
         }
 
-
         /// <summary>
         /// Updates a persistent group of tags to the repository after reading from the PLC.
         /// </summary>
@@ -241,7 +238,6 @@ public async Task<bool> UpdateAllPersistentGroupsToRepository()
             return true;
         }
 
-
         #endregion Main Handling Method - Read Write
 
         #region Data Exchange Implementation
@@ -292,6 +288,13 @@ private async Task Handle()
             switch (operation)
             {
                 case ePersistentOperation.Read:
+
+                    // if  not exist => create it
+                    if (!Repository.Exists(identifier))
+                    {
+                        await UpdatePersistentGroupFromPlcToRepository(identifier);
+                    }
+
                     await this.WritePersistentGroupFromRepository(identifier);
                     break;
 
@@ -301,9 +304,13 @@ private async Task Handle()
 
                 case ePersistentOperation.ReadAll:
 
-                    if (!Repository.Exists(DEFAULT_IDENTIFIER)) // repo is empty
+                    // if any group not exist => create it
+                    foreach (var persitGroupName in this.CollectedGroups)
                     {
-                        await this.UpdateAllPersistentGroupsToRepository(); // create records from online
+                        if (!Repository.Exists(persitGroupName))
+                        {
+                            await UpdatePersistentGroupFromPlcToRepository(persitGroupName);
+                        }
                     }
 
                     await this.WriteAllPersistentGroupsFromRepositoryToPlc();