MARKUS



using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using System.Data.SqlClient;

using Markus.Message;

using Markus.Service.DataBase.Repositories;

namespace Markus.Service.DataBase.Dapper

{

    public class ConvertDatabase : IDisposable

    {

        #region Constructor

        public readonly string ConnectionString;

        public ConvertDatabase(string connectionString)

        {

            try

            {

                ConnectionString = connectionString;

            }

            catch (Exception ex)

            {

                System.Diagnostics.Debug.WriteLine(ex.ToString());

                throw ex;

            }

        }

        public void Dispose()

        {

        }

        #endregion

        /// <summary>

        /// service에서 대기중이거나 오류인 아이템을 가져가서 컨버터 프로세스를 호출한다.

        /// 컨버터 상태가 에러이거나 2보다 작은 경우 

        /// UniqueKey는 각 데이터베이스의 문서 정보에서 유일한 키이며 컨버터저장에서 같은 폴더로의 저장을 방지 한다.

        /// 

        /// </summary>

        /// <param name="aliveItems"></param>

        /// <param name="TakeCount"></param>

        /// <returns></returns>

        public async Task<IEnumerable<DataBase.Entities.ConvertDoc>> GetWaitConvertItemsAsync(int TakeCount)

        {

            IEnumerable<DataBase.Entities.ConvertDoc> result = null;

            using (ConvertDocRepository repository = new ConvertDocRepository(ConnectionString))

            {

                result = await repository.GetWaitorErrorAsync(TakeCount);

            }

            return result;

        }

        /// <summary>

        /// 오류나 wait으로 남아 있는 데이터베이스의 Item을 StatusCodeType.None으로 복구

        /// </summary>

        /// <param name="convertID">StatusCodeType을 변경하고자 하는 ConvertItem의 ID</param>

        /// <param name="ReConvert">ReConvert가 2이면 다시 Convert를 시도 안하기 때문에 기존 값으로 유지 하고 계속 시도 할수 있도록 0을 주는 경우가 있다.</param>

        /// <returns></returns>

        /// 

        public async Task<int> SetCleanUpItemAsync(string convertID, int ReConvert)

        {

            int result = -1;

            using (ConvertDocRepository repository = new ConvertDocRepository(ConnectionString))

            {

                result = await repository.SetCleanUpItemAsync(convertID, ReConvert);

            }

            return result;

        }

    }

}