MARKUS

using log4net;

using Markus.Service.Convert.Plugin;

using Markus.Service.Extensions;

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Markus.Service.DataBase.Entities;

using Markus.Service.DataBase.Repositories;

using Markus.Service.DataBase;

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 DBTYPE_KEY = "DBTYPE";

        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)

                {

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

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

                    using (BaseRepository repository = new Markus.Service.DataBase.Repositories.BaseRepository(Encrypt.AESEncrypter.Decrypt(connectionString), dbtype))

                    {

                        string sql = @"SELECT  doc.* " +

                                      " 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 = repository.GetAsync<DOCUMENTITEM>(sql,null).GetAwaiter().GetResult();

                        if (docItems.Count() > 0)

                        {

                            foreach (var item in docItems)

                            {

                                string projctNo = item.PROJECT_NO;

                                string documentId = item.DOCUMENT_ID;

                                string originalUrl = item.ORIGINAL_FILE;

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

                                { 

                                    string convertId = GuidExtension.shortGuid();

                                    var param = new List<sqlParameter> {

                                        new sqlParameter("@ID",convertId,System.Data.DbType.String),

                                        new sqlParameter("@PROJECT_NO",projctNo,System.Data.DbType.String),

                                        new sqlParameter("@DOCUMENT_URL",originalUrl,System.Data.DbType.String),

                                        new sqlParameter( "@DOCUMENT_ID",documentId,System.Data.DbType.String)

                                    };

                                    repository.SetAsync("SELECT_CONVERT_INSERT", param).GetAwaiter().GetResult();

                                    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;

        }

    }

}