MARKUS

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Markus.Service.DataBase.Repositories;

using RestSharp;

namespace ConvertResultBSENG

{

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

    {

        public string Name => nameof(ConvertResultBSENG);

        public string Exception { get; set; }

        private const string UPLOAD_API_KEY = "UPLOAD_API";

        private const string MARKUS_ConnectionString_KEY = "MARKUS_ConnectionString";

        private const string DBTYPE_KEY = "DBTYPE";

        private string connectioString;

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

        {

            bool result = false;

            Exception = "";

            try

            {

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

                {

                    Parameters.TryGetValue(DBTYPE_KEY, out object dbtypeStr);

                    Markus.Service.DataBase.DBMSType dbtype = (Markus.Service.DataBase.DBMSType)Enum.Parse(typeof(Markus.Service.DataBase.DBMSType), dbtypeStr.ToString());

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

                    string uploadUrl = Parameters[UPLOAD_API_KEY].ToString();

                    using (ConvertDocRepository database = new ConvertDocRepository(connectioString, dbtype))

                    {

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

                        if (convertItem != null)

                        {

                            using (DOCUMENTITEMRepository repository = new DOCUMENTITEMRepository(connectioString, dbtype))

                            {

                                var docitem = repository.GetFirstAsync(convertItem.PROJECT_NO,convertItem.DOCUMENT_ID).GetAwaiter().GetResult();

                                string uri = null;

                                if (docitem != null)

                                {

                                    //http://210.94.128.124/markus/markusRes.do?prj_No={prj_No}&document_Id={document_Id}&document_No={document_No}&document_Name=(document_Name)&group_No={group_No}&rev_No={rev_No}

                                    uri = $"http://{uploadUrl}/markus/markusRes.do?"

                                                 + $"prj_No={docitem.PROJECT_NO}&document_Id={docitem.ID}&document_No={docitem.DOCUMENT_NO}"

                                                 + $"&document_Name={docitem.DOCUMENT_NAME}&group_No={docitem.GROUP_NO}&rev_No={docitem.REVISION}";

                                    var value = SendData(uri);

                                    if (string.IsNullOrEmpty(value) || Convert.ToBoolean(value))

                                    {

                                        result = true;

                                    }

                                    else

                                    {

                                        this.Exception = uri;

                                        result = false;

                                    }

                                }

                                else

                                {

                                    this.Exception = "document Item Not Found " + uri;

                                }

                            }

                        }

                        else

                        {

                            this.Exception = "Convert_Doc Not Found";

                        }

                    }

                }

            }

            catch (Exception ex)

            {

                this.Exception = this.Exception +  ex.ToString() + ex.InnerException?.ToString();

                result = false;

            }

            return result;

        }

        private string SendData(string uri)

        {

            var client = new RestClient(uri);

            client.Timeout = -1;

            var request = new RestRequest(Method.GET);

            var result =  client.Get<string>(request);

            return result.Content;

        }

    }

}