MARKUS

using System;

using System.Collections.Generic;

using System.Linq;

using System.ServiceModel;

using System.Text;

using System.Threading.Tasks;

using Markus.Service.Convert.Plugin;

namespace PemssDocumentInfo

{

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

    {

        public string Name => "PemssDocumentInfo";

        public string Exception { get; set; }

        private const string PEMSS_SERVICE_KEY = "PEMSS_SERVICE";

        private const string MARKUS_ConnectionString_KEY = "MARKUS_ConnectionString";

        private string gConvertID;

        private string gPemssServiceUri;

        private PemssService.PemssServiceClient pemssServiceClient;

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

        {

            bool result = false;

            gConvertID = ConvertID;

            try

            {

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

                {

                    gPemssServiceUri = Parameters[PEMSS_SERVICE_KEY].ToString();

                    BasicHttpBinding myBinding = new BasicHttpBinding();

                    EndpointAddress myEndpoint = new EndpointAddress(gPemssServiceUri);

                    pemssServiceClient = new PemssService.PemssServiceClient(myBinding, myEndpoint);

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

                    {

                        string connectionString = Parameters[MARKUS_ConnectionString_KEY].ToString();

                        using (var entities = new Markus.EntityModel.MarkusModel(Markus.Service.Extensions.Encrypt.AESEncrypter.Decrypt(connectionString)))

                        {

                            var convertItems = entities.CONVERTER_DOC.Where(x => x.ID == ConvertID);

                            if (convertItems.Count() > 0)

                            {

                                var convertItem = convertItems.First();

                                string pID = convertItem.PROJECT_NO;

                                string dID = convertItem.DOCUMENT_ID;

                                var documentInfo = pemssServiceClient.GetDocumentInfo(pID,dID);

                                var docItems = entities.DOCUMENT_ITEM.Where(x => x.PROJECT_NO == pID && x.DOCUMENT_ID == dID);

                                if (docItems.Count() > 0)

                                {

                                    var docitem = docItems.First();

                                    docitem.DOCUMENT_NAME = documentInfo.docName;

                                    docitem.REVISION = documentInfo.revision;

                                    docitem.DOCUMENT_NO = documentInfo.slipNo;

                                    docitem.ORIGINAL_FILE = convertItem.DOCUMENT_URL;

                                }

                                else

                                {

                                    entities.DOCUMENT_ITEM.Add(new Markus.EntityModel.DOCUMENT_ITEM

                                    {

                                        DOCUMENT_NAME = documentInfo.docName,

                                        REVISION = documentInfo.revision,

                                        DOCUMENT_NO = documentInfo.slipNo,

                                        ORIGINAL_FILE = convertItem.DOCUMENT_URL

                                    });

                                }

                                entities.SaveChanges();

                            }

                            else

                            {

                                this.Exception = "ConvertItem Not Found";

                            }

                        }

                    }

                    else

                    {

                        this.Exception = "MARKUS_ConnectionString SECTION Not Found";

                    }

                }

                else

                {

                    this.Exception = "PEMSS_SERVICE SECTION Not Found";

                    return false;

                }

            }

            catch (Exception ex)

            {

                this.Exception = ex.ToString();

                result = false;

            }

            return result;

        }

    }

}