MARKUS

using Dapper;

using NUnit.Framework;

using System;

using System.Collections.Generic;

namespace Markus.Service.DataBase.Test

{

    /// <summary>

    /// PostgreSQL

    /// </summary>

    public class DataBaseConvertDocPG : TestBasePG

    {

        public List<string> newConvertDocIDs = new List<string>();

        /// <summary>

        /// 완료

        /// </summary>

        [Test, Description("Craete Convert Doc Postgresql Test")]

        public void CreateConvertDocAsync()

        {

            using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype))

            {

                var newConvertDocID = repository.CreateAsync(ProjectNo, docUri, "111111").GetAwaiter().GetResult();

                newConvertDocIDs.Add(newConvertDocID);

                Console.WriteLine($"new id : {newConvertDocID}");

                Assert.Pass(newConvertDocID);

                var newConvertDocID2 = repository.CreateAsync(ProjectNo, docUri, "A1111111").GetAwaiter().GetResult();

                newConvertDocIDs.Add(newConvertDocID2);

                Console.WriteLine($"new id : {newConvertDocID2}");

                Assert.Pass(newConvertDocID2);

            }

        }

        /// <summary>

            /// 완료

        /// </summary>

        [Test, Description("Craete Convert Doc MSSQL Test")]

        public void CreateConvertDoc()

        {

            using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype))

            {

                var newConvertDocID = repository.Create(ProjectNo, docUri, "111111").GetAwaiter().GetResult();

                newConvertDocIDs.Add(newConvertDocID);

                Console.WriteLine($"new id : {newConvertDocID}");

                Assert.Pass(newConvertDocID);

                var newConvertDocID2 = repository.Create(ProjectNo, docUri, "A1111111").GetAwaiter().GetResult();

                newConvertDocIDs.Add(newConvertDocID2);

                Console.WriteLine($"new id : {newConvertDocID2}");

                Assert.Pass(newConvertDocID2);

            }

        }

        /// <summary>

        /// 완료

        /// </summary>

        [Test, Description("GetConvertDocSingle Test")]

        public void GetConvertDocSingle()

        {

            this.CreateConvertDoc();

            using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype))

            {

                foreach (var convertDocID in newConvertDocIDs)

                {

                    var convertDoc = repository.GetConvertDocSingleAsync(ProjectNo, ConvertID: convertDocID).GetAwaiter().GetResult();

                    Assert.Pass(convertDoc.ID);

                    Console.WriteLine($"ID : {convertDoc.ID} PROJECT_NO:{convertDoc.PROJECT_NO} DOCUMENT_URL:{convertDoc.DOCUMENT_URL} DOCUMENT_ID:{convertDoc.DOCUMENT_ID}  ConvertPath:{convertDoc.ConvertPath}  ");

                }

            }

        }

        /// <summary>

        /// 완료

        /// </summary>

        [Test, Description("Select waitOrError PostgreSQL Test")]

        public void SelectWaitOrError()

        {

            using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype))

            {

                var items = repository.GetWaitorErrorAsync(2).GetAwaiter().GetResult();

                foreach (var item in items)

                {

                    Assert.Pass(item.ID);

                }

            }

        }

        /// <summary>

        /// 완료

        /// </summary>

        [Test, Description("Select Top 10 Convert Doc PostgreSQL Test")]

        public void SelectTop10ConvertDoc()

        {

            using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype))

            {

                string sql = @"SELECT ID, PROJECT_NO, DOCUMENT_URL, DOCUMENT_ID, CREATE_DATETIME, STATUS, TOTAL_PAGE, CURRENT_PAGE, EXCEPTION, END_DATETIME, START_DATETIME, SERVICE_ID,"

                             + "RECONVERTER FROM CONVERTER_DOC where CREATE_DATETIME >= @CREATE_DATETIME order by CREATE_DATETIME desc limit 10";

                var parameter = new List<sqlParameter>();

                parameter.Add(new sqlParameter("@CREATE_DATETIME", DateTime.Now.AddDays(-2), System.Data.DbType.DateTime));

               var items = repository.GetAsync<Markus.Service.DataBase.Entities.ConvertDoc>(sql, parameter).GetAwaiter().GetResult();

                foreach(var item in items)

                {

                    Assert.Pass(item.ID);

                }

            }

        }

        /// <summary>

        /// 완료

        /// </summary>

        [Test, Description("CONVERT_SELECT_CONVERTINGITEMS")]

        public void CONVERT_SELECT_CONVERTINGITEMS()

        {

            int TakeCount = 5;

            using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype))

            {

                var items = repository.GetConvertingItemAsync(TakeCount).GetAwaiter().GetResult();

                foreach (var item in items)

                {

                    Assert.Pass(item.ID);

                }

            }

        }

        /// <summary>

        /// 완료.

        /// </summary>

        [Test, Description("SetCleanUpItem PostgreSQL Test")]

        public void SelectSetCleanUpItem()

        {

            this.CreateConvertDoc();

            foreach (var item in newConvertDocIDs)

            {

                using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype))

                {

                    var items = repository.SetCleanUpItemAsync(item,1).GetAwaiter().GetResult();

                    Assert.Pass(item);

                }

            }

        }

        /// <summary>

        /// 완료.

        /// </summary>

        [Test, Description("UpdateStatusAsync")]

        public void UpdateStatusAsync()

        {

            using (Markus.Service.DataBase.Repositories.ConvertDocRepository repository = new Repositories.ConvertDocRepository(ConnectionStr, dbtype))

            {

                var newConvertDocID = repository.CreateAsync(ProjectNo, docUri, "111111").GetAwaiter().GetResult();

                var convertDoc = repository.GetConvertDocSingleAsync(ProjectNo, ConvertID: newConvertDocID).GetAwaiter().GetResult();

                Console.WriteLine($"ID : {convertDoc.ID} PROJECT_NO:{convertDoc.PROJECT_NO} DOCUMENT_URL:{convertDoc.DOCUMENT_URL} DOCUMENT_ID:{convertDoc.DOCUMENT_ID}  ConvertPath:{convertDoc.ConvertPath}  ");

                var status = repository.UpdateStatusAsync("", convertDoc.ID, convertDoc.STATUS, convertDoc.TOTAL_PAGE, convertDoc.CURRENT_PAGE, "").GetAwaiter().GetResult();

                //Assert.That(status, Is.EqualTo(1));

            }

        }

    }

}