MARKUS

using log4net;

using Markus.Service.Convert.Plugin;

using Markus.Service.Extensions;

using System;

using System.Collections.Generic;

using System.Data.Entity.Core.Objects;

using System.Data.Entity.Infrastructure;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

namespace DocItemCheck

{

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

    {

        public string Name => nameof(DocItemCheck);

        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 = true;

            log4net.Config.BasicConfigurator.Configure();

            log4net.ILog log = log4net.LogManager.GetLogger(typeof(DocumentItemCheck));

            try

            {

                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)))

                    {

                        string sql = @"SELECT " +

                                      " doc.PROJECT_NO as PROJECT_NO " +

				                      " ,doc.DOCUMENT_ID as DOCUMENT_ID " +

				                      " ,doc.ORIGINAL_FILE as ORIGINAL_FILE " +

                                      " FROM MarkusModel.DOCUMENT_ITEM as doc " +

                                      " LEFT OUTER JOIN MarkusModel.CONVERTER_DOC as con " +

				                      " ON doc.DOCUMENT_ID = con.DOCUMENT_ID and doc.PROJECT_NO = con.PROJECT_NO " +

				                      " where con.DOCUMENT_ID is null";

                        var docItems =  (entities as IObjectContextAdapter).ObjectContext.CreateQuery<System.Data.Common.DbDataRecord>(sql);

                        if (docItems.Count() > 0)

                        {

                            foreach (var dataRecord in docItems)

                            {

                                string projctNo = dataRecord["PROJECT_NO"]?.ToString().Trim();

                                string documentId = dataRecord["DOCUMENT_ID"]?.ToString().Trim();

                                string originalUrl = dataRecord["ORIGINAL_FILE"]?.ToString();

                                if (!string.IsNullOrWhiteSpace(projctNo) && !string.IsNullOrWhiteSpace(documentId) && !string.IsNullOrWhiteSpace(originalUrl))

                                { 

                                    string convertId = GuidExtension.shortGuid();

                                    var param = new [] {

                                        new System.Data.SqlClient.SqlParameter("ID",convertId),

                                        new System.Data.SqlClient.SqlParameter("PROJECT_NO",projctNo),

                                        new System.Data.SqlClient.SqlParameter("DOCUMENT_URL",originalUrl),

                                        new System.Data.SqlClient.SqlParameter( "DOCUMENT_ID",documentId)

                                    };

                                   (entities as IObjectContextAdapter).ObjectContext.ExecuteStoreQuery<object>("SELECT_CONVERT_INSERT @ID, @PROJECT_NO, @DOCUMENT_URL , @DOCUMENT_ID", param);

                                    log.Warn($"[Insert Convert_Doc] ID : {convertId} / PROJECT_NO : {projctNo} / DOCUMENT_URL : {originalUrl} / DOCUMENT_ID : {documentId} ");

                                }

                            }

                        }

                        else

                        {

                            log.Info($"Document Item Check - Null");

                        }

                    }

                }

                else

                {

                    this.Exception = "MARKUS_ConnectionString SECTION Not Found";

                }

            }

            catch (Exception ex)

            {

                log.Error(ex);

                this.Exception = ex.ToString();

                result = false;

            }

            return result;

        }

    }

}