CustomizationPlugin.cs

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Customization;
using PX.Data;
using PX.DbServices.Model.ImportExport;
using PX.Objects.CS;

namespace PX.Survey.Ext
{
    public class SurveyInitalizer : CustomizationPlugin
    {
        protected byte[] ReadFromFile(string fileName)
        {
            var context = File.ReadAllBytes(fileName);
            return context;
        }
        
        public void ImportFilesFromDirectory(string directory, string graphName)
        {
            var xmlFiles = Directory.GetFiles(directory).Where(p => p.EndsWith(".xml"));
            foreach (var xmlFile in xmlFiles)
            {
                ImportFilesAtName(xmlFile, graphName);
            }
        }
        public void ImportFilesAtName(string fileName, string graphName)
        {
            var content = ReadFromFile(fileName);
            Type type = ByName(graphName);
            var graph = PXGraph.CreateInstance(type);
            var item = graph.ImportEntitiesFromXml(content, RecordImportMode.Replace, out var dataUploader);
        }
        public List<Tuple<int, string, string>> TakeDictionaryGraphs(string currentDirectory)
        {
            var dictionary = new List<Tuple<int, string, string>>();
            var directories = Directory.GetDirectories(currentDirectory);
            foreach (var folder in directories)
            {
                dictionary.Add(Tuple.Create(Convert.ToInt32(folder.Split('\\').LastOrDefault().Split('-')[0]), folder.Split('-')[1], folder));
            }
           
            return dictionary;
        }
        private static IEnumerable<string> TryEnumerate(Func<IEnumerable<string>> action)
        {
            try
            {
                return action.Invoke();
            }
            catch
            {
                //TODO logging
                return Enumerable.Empty<string>();
            }
        }
        private static Type ByName(string name)
        {
            return
                AppDomain.CurrentDomain.GetAssemblies()
                    .Reverse()
                    .Select(assembly => assembly.GetType(name))
                    .FirstOrDefault(t => t != null)
                ??
                AppDomain.CurrentDomain.GetAssemblies()
                    .Reverse()
                    .SelectMany(assembly => assembly.GetTypes())
                    .FirstOrDefault(t => t.Name.Contains(name));
        }
        public override void UpdateDatabase()
        {
            this.WriteLog("Start of import");
            try
            {
                string folderName = $"{AppDomain.CurrentDomain.BaseDirectory.TrimEnd('\\')}\\SUContent\\";
                var nameOfGraphs = TakeDictionaryGraphs(folderName).OrderBy(p => p.Item1);
                
                foreach (var item in nameOfGraphs)
                {
                    ImportFilesFromDirectory(item.Item3, item.Item2);
                }
                
            }
            catch (Exception e)
            {
                this.WriteLog(e.Message);
            }
        }
    }
}