MARKUS

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Markus.Service.Convert.Plugin;

using Markus.Service.DataBase.Entities;

using Markus.Service.DataBase.Repositories;

using Markus.Service.Extensions;

namespace TestDocumentInfo

{

    public class DocumentInfoProcess : Markus.Service.Convert.Plugin.IPlugin

    {

        public string Name => "TestDocumentInfo";

        public string Exception { get; set; }

        public string gConvertID;

        private const string MARKUS_ConnectionString_KEY = "MARKUS_ConnectionString";

        bool IPlugin.Do(string ConvertID, Dictionary<string, object> Parameters)

        {

            bool result = false;

            gConvertID = ConvertID;

            try

            {

                if (Parameters.Keys.Count(x => x == MARKUS_ConnectionString_KEY) > 0)

                {

                    string connectionString = Markus.Service.Extensions.Encrypt.AESEncrypter.Decrypt(Parameters[MARKUS_ConnectionString_KEY].ToString());

                    using (ConvertDocRepository database = new ConvertDocRepository(connectionString))

                    {

                        var convertItem = database.GetConvertDocSingleAsync(ConvertID: ConvertID).GetAwaiter().GetResult();

                        if (convertItem != null)

                        {

                            string projectNo = convertItem.PROJECT_NO;

                            string documentId = convertItem.DOCUMENT_ID;

                            using (DOCUMENTITEMRepository repository = new DOCUMENTITEMRepository(connectionString))

                            {

                                DOCUMENTITEM documentItem = repository.GetFirstAsync(projectNo, documentId).GetAwaiter().GetResult();

                                if (documentItem != null)

                                {

                                    documentItem.DOCUMENT_NAME = documentItem.DOCUMENT_NAME;

                                    documentItem.REVISION = documentItem.REVISION;

                                    documentItem.DOCUMENT_NO = documentItem.DOCUMENT_NO;

                                    documentItem.ORIGINAL_FILE = convertItem.DOCUMENT_URL;

                                }

                                else

                                {

                                    string docNo = "";

                                    var filename = convertItem.DOCUMENT_URL.Split('/').LastOrDefault();

                                    if (filename.Contains('.'))

                                    {

                                        docNo = filename.Split('.').First();

                                    }

                                    documentItem = new DOCUMENTITEM

                                    { 

                                        ID = new Guid().CreateUniqueGuid().ToString(),

                                        DOCUMENT_NO = docNo,

                                        REVISION = "A",

                                        DOCUMENT_NAME = docNo,

                                        GROUP_NO = "11",

                                        ORIGINAL_FILE = convertItem.DOCUMENT_URL,

                                        DOCUMENT_ID = documentId,

                                        PROJECT_NO = projectNo,

                                        Link = convertItem.DOCUMENT_URL

                                    };

                                }

                                var id =  repository.CreateOrUPdateAsync(documentItem).GetAwaiter().GetResult();

                                if(id != null)

                                {

                                    result = true;

                                }

                            }

                        }

                    }

                }

                else

                {

                    this.Exception = "MARKUS_ConnectionString SECTION Not Found";

                }

            }

            catch (Exception ex)

            {

                this.Exception = ex.ToString();

                result = false;

            }

            return result;

        }

    }

}