MARKUS

using Markus.EntityModel;

using Markus.Message;

using Markus.Service.Extensions;

using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using static Markus.Service.DataBase.ConvertDatabase;

using System.Windows;

using System.Linq.Expressions;

using Markus.Service.Interface;

using Markus.Service.DataBase.Data;

using Markus.Service.DataBase.Extensions;

namespace Markus.Service.DataBase

{

    public class ConvertDatabase : IDisposable

    {

        #region Constructor

        /// <summary>

        ///해당 프로젝트의 데이터베이스 연결

        /// </summary>

        Markus.EntityModel.MarkusModel entities;

        public ConvertDatabase(string ConnectionString)

        {

            try

            {

                entities = new Markus.EntityModel.MarkusModel(ConnectionString);

            }

            catch (Exception ex)

            {

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

                throw ex;

            }

        }

        public void Dispose()

        {

            entities.Dispose();

        }

        #endregion

        #region DataBaseItemsModel Function

        #region Get WaitConvertItems

        /// <summary>

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

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

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

        /// 

        /// </summary>

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

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

        /// <returns></returns>

        public IEnumerable<CONVERTER_DOC> GetWaitConvertItems(List<string> projectList, int TakeCount)

        {

            var convertWaitingItems = entities.CONVERTER_DOC.OrderBy(x => x.CREATE_DATETIME).Where(

                                        x =>

                                        //projectList.Contains(x.PROJECT_NO) && x.RECONVERTER < 2 &&

                                         x.RECONVERTER < 2 &&

                                        (x.STATUS == (int)StatusCodeType.None || x.STATUS == (int)StatusCodeType.FileError || x.STATUS == (int)StatusCodeType.Error))

                                    .GroupBy(x => x.DOCUMENT_ID).Select(x => x.FirstOrDefault())

                                    .Take(TakeCount);

            return convertWaitingItems;

        }

        #endregion

        #region Get FilterConvertItems

        /// <summary>

        /// 상단 그리드 선택된 Status에 따라 DB에서 값 가져온다.

        /// </summary>

        public IEnumerable<Interface.ConvertItem> GetConvertProjects(int status)

        {

            List<Interface.ConvertItem> convertItems = new List<Interface.ConvertItem>();

            var query = from items in entities.CONVERTER_DOC

                        join documents in entities.DOCUMENT_ITEM on items.DOCUMENT_ID equals documents.DOCUMENT_ID into GroupItems

                        from subpet in GroupItems.DefaultIfEmpty()

                        where items.STATUS == status

                        orderby items.CREATE_DATETIME descending

                        select new

                        {

                            ID = items.ID,

                            DOCUMENT_URL = items.DOCUMENT_URL,

                            RECONVERTER = items.RECONVERTER,

                            SERVICE_ID = items.SERVICE_ID,

                            STATUS = items.STATUS,

                            CREATE_DATETIME = items.CREATE_DATETIME,

                            TOTAL_PAGE = items.TOTAL_PAGE,

                            CURRENT_PAGE = items.CURRENT_PAGE,

                            EXCEPTION = items.EXCEPTION,

                            PROJECT_NO = items.PROJECT_NO,

                            DOCUMENT_ID = items.DOCUMENT_ID,

                            REVISION = subpet.REVISION,

                            DOCUMENT_NO = subpet.DOCUMENT_NO,

                            DOCUMENT_NAME = subpet.DOCUMENT_NAME,

                            GROUP_NO = subpet.GROUP_NO

                            //REVISION = documents.REVISION,

                            //DOCUMENT_NO = documents.DOCUMENT_NO,

                            //DOCUMENT_NAME = documents.DOCUMENT_NAME,

                            //GROUP_NO = documents.GROUP_NO

                        };

            if (query.Count() > 0)//세미

            {

                foreach (var item in query)

                {

                    Interface.ConvertItem convertitem = new Interface.ConvertItem(item.DOCUMENT_ID, item.PROJECT_NO, item.ID, item.DOCUMENT_URL)

                    {

                        ReConverter = item.RECONVERTER,

                        ServiceID = item.SERVICE_ID,

                        ConvertState = (StatusCodeType)item.STATUS,

                        CreateTime = item.CREATE_DATETIME,

                        TotalPage = item.TOTAL_PAGE,

                        CurrentPageNo = item.CURRENT_PAGE,

                        Exception = item.EXCEPTION,

                        Revision = item.REVISION,

                        DocumnetNo = item.DOCUMENT_NO,

                        DocumnetName = item.DOCUMENT_NAME,

                        GroupNo = item.GROUP_NO,

                        DocumentID = item.DOCUMENT_ID,

                        MarkusLink = Markus.Service.DataBase.Extensions.MarkusAPI.CreateMarkusParam(item.PROJECT_NO, item.DOCUMENT_ID, "doftech")

                    };

                    convertItems.Add(convertitem);

                }

            }

            return convertItems;

        }

        #endregion

        #region Update RealDataSelect 

        /// <summary>

        /// 상단 그리드에서 선택된 RealDataSelect

        /// 용도: 중앙그리드 Items Update

        /// </summary>

        public IEnumerable<Interface.ConvertItem> GetConvertProjects(System.Collections.ObjectModel.ObservableCollection<Interface.ConvertItem> selectedConvert)

        {

            List<Interface.ConvertItem> StatusKeep = new List<Interface.ConvertItem>();

            List<Interface.ConvertItem> convertItems = new List<Interface.ConvertItem>();

            foreach (var selectedConvertItem in selectedConvert)

            {

                var query = from items in entities.CONVERTER_DOC //세미

                            join documents in entities.DOCUMENT_ITEM on items.DOCUMENT_ID equals documents.DOCUMENT_ID into GroupItems

                            from subpet in GroupItems.DefaultIfEmpty()

                            where items.PROJECT_NO == selectedConvertItem.ProjectNumber && items.ID == selectedConvertItem.ConvertID

                            select new

                            {

                                ID = items.ID,

                                DOCUMENT_URL = items.DOCUMENT_URL,

                                RECONVERTER = items.RECONVERTER,

                                SERVICE_ID = items.SERVICE_ID,

                                STATUS = items.STATUS,

                                CREATE_DATETIME = items.CREATE_DATETIME,

                                TOTAL_PAGE = items.TOTAL_PAGE,

                                CURRENT_PAGE = items.CURRENT_PAGE,

                                EXCEPTION = items.EXCEPTION,

                                PROJECT_NO = items.PROJECT_NO,

                                DOCUMENT_ID = items.DOCUMENT_ID,

                                REVISION = subpet.REVISION,

                                DOCUMENT_NO = subpet.DOCUMENT_NO,

                                DOCUMENT_NAME = subpet.DOCUMENT_NAME,

                                GROUP_NO = subpet.GROUP_NO

                            };

                if (query.Count() > 0)//세미

                {

                    foreach (var item in query)

                    {

                        Interface.ConvertItem convertitem = new Interface.ConvertItem(item.DOCUMENT_ID, item.PROJECT_NO, item.ID, item.DOCUMENT_URL)

                        {

                            ReConverter = item.RECONVERTER,

                            ServiceID = item.SERVICE_ID,

                            ConvertState = (StatusCodeType)item.STATUS,

                            CreateTime = item.CREATE_DATETIME,

                            TotalPage = item.TOTAL_PAGE,

                            CurrentPageNo = item.CURRENT_PAGE,

                            Exception = item.EXCEPTION,

                            ConvertPath = GetConvertPath(item.PROJECT_NO, item.DOCUMENT_ID),

                            Revision = item.REVISION,

                            DocumnetNo = item.DOCUMENT_NO,

                            DocumnetName = item.DOCUMENT_NAME,

                            GroupNo = item.GROUP_NO,

                            MarkusLink = MarkusAPI.CreateMarkusParam(item.PROJECT_NO, item.DOCUMENT_ID, "doftech")

                        };

                        StatusKeep.Add(convertitem);

                    }

                }

            }

            return StatusKeep;

        }

        #endregion

        #region Data Convert

        /// <summary>

        /// 상단 그리드에서 선택된 Convert 버튼 

        /// 용도: 중앙 그리드로 Convert된 row 값 저장 하기 위해서 입니다.

        /// </summary>

        public IEnumerable<Interface.ConvertItem> GetConvertProjects(Markus.Service.Interface.ConvertItem selectedConvert)

        {

            List<Interface.ConvertItem> StatusKeep = new List<Interface.ConvertItem>();

            System.Diagnostics.Stopwatch stopwatch = new System.Diagnostics.Stopwatch();

            stopwatch.Start();

            List<Interface.ConvertItem> convertItems = new List<Interface.ConvertItem>();//디비 다 조인 후 조건 비교 후 그리드 출력

            var query = from items in entities.CONVERTER_DOC //세미

                        join documents in entities.DOCUMENT_ITEM on items.DOCUMENT_ID equals documents.DOCUMENT_ID into GroupItems

                        from subpet in GroupItems.DefaultIfEmpty()

                        where items.PROJECT_NO == selectedConvert.ProjectNumber && items.DOCUMENT_ID == selectedConvert.DocumentID

                        orderby items.CREATE_DATETIME descending

                        select new

                        {

                            ID = items.ID,

                            DOCUMENT_URL = items.DOCUMENT_URL,

                            RECONVERTER = items.RECONVERTER,

                            SERVICE_ID = items.SERVICE_ID,

                            STATUS = items.STATUS,

                            CREATE_DATETIME = items.CREATE_DATETIME,

                            TOTAL_PAGE = items.TOTAL_PAGE,

                            CURRENT_PAGE = items.CURRENT_PAGE,

                            EXCEPTION = items.EXCEPTION,

                            PROJECT_NO = items.PROJECT_NO,

                            DOCUMENT_ID = items.DOCUMENT_ID,

                            REVISION = subpet.REVISION,

                            DOCUMENT_NO = subpet.DOCUMENT_NO,

                            DOCUMENT_NAME = subpet.DOCUMENT_NAME,

                            GROUP_NO = subpet.GROUP_NO

                        };

            if (query.Count() > 0)//세미

            {

                foreach (var item in query)

                {

                    Interface.ConvertItem convertitem = new Interface.ConvertItem(item.DOCUMENT_ID, item.PROJECT_NO, item.ID, item.DOCUMENT_URL)

                    {

                        ReConverter = item.RECONVERTER,

                        ServiceID = item.SERVICE_ID,

                        ConvertState = (StatusCodeType)item.STATUS,

                        CreateTime = item.CREATE_DATETIME,

                        TotalPage = item.TOTAL_PAGE,

                        CurrentPageNo = item.CURRENT_PAGE,

                        Exception = item.EXCEPTION,

                        ConvertPath = GetConvertPath(item.PROJECT_NO, item.DOCUMENT_ID),

                        Revision = item.REVISION,

                        DocumnetNo = item.DOCUMENT_NO,

                        DocumnetName = item.DOCUMENT_NAME,

                        GroupNo = item.GROUP_NO,

                        MarkusLink = Markus.Service.DataBase.Extensions.MarkusAPI.CreateMarkusParam(item.PROJECT_NO, item.DOCUMENT_ID, "doftech")

                    };

                    StatusKeep.Add(convertitem);

                }

            }

            System.Diagnostics.Debug.WriteLine(new TimeSpan(stopwatch.ElapsedTicks).ToString());

            return StatusKeep;

        }

        #endregion

        #region SetCleanUpItem

        /// <summary>

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

        /// </summary>

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

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

        /// <returns></returns>

        /// 

        public int SetCleanUpItem(ConvertItem _ConvertItem)

        {

            int result = 0;

            var items = entities.CONVERTER_DOC.Where(x => x.ID == _ConvertItem.ConvertID);

            result = items.Count();

            if (items.Count() > 0)

            {

                var item = items.First();

                item.RECONVERTER = item.RECONVERTER - _ConvertItem.ReConverter;

                item.CREATE_DATETIME = DateTime.Now;

                item.STATUS = (int)StatusCodeType.None;

                item.END_DATETIME = null;

                result = entities.SaveChanges();

            }

            return result;

        }

        public int SetCleanUpItem(string convertID, int ReConvert)

        {

            int result = 0;

            var items = entities.CONVERTER_DOC.Where(x => x.ID == convertID);

            result = items.Count();

            if (items.Count() > 0)

            {

                var item = items.First();

                item.RECONVERTER = item.RECONVERTER + ReConvert;

                item.CREATE_DATETIME = DateTime.Now;

                //item.START_DATETIME = null;

                item.END_DATETIME = null;

                item.STATUS = (int)StatusCodeType.None;

                result = entities.SaveChanges();

            }

            return result;

        }

        #endregion

        #region Convert Path

        private string GetConvertPath(string ProjectNo, string DocumentID)

        {

            try

            {

                return Path.Combine(BaseStorage(ProjectNo), ProjectNo + "_Tile", (System.Convert.ToInt64(DocumentID) / 100).ToString(), DocumentID);

            }

            catch (Exception)

            {

                throw new Exception("GetConvertPath Error");

            }

        }

        private string BaseStorage(string ProjectNo)

        {

            string result = "";

            var properties = entities.PROPERTIES.Where(f => f.PROPERTY == ProjectNo && f.TYPE == PROPERTIES_DEFINE.TILE_SOURCE_STORAGE);

            if (properties.Count() > 0)

            {

                result = properties.First().VALUE;

            }

            else

            {

                throw new Exception($"Project {ProjectNo} BaseStorage Not Setting.");

            }

            return result;

        }

        #endregion

        #region Remove

        /// <summary>

        /// Item 삭제

        /// </summary>

        /// <returns></returns>

        public int RemoveItem(string convertID)

        {

            int result = 0;

            var items = entities.CONVERTER_DOC.Where(x => x.ID == convertID);

            if (items.Count() > 0)

            {

                CONVERTER_DOC item = items.First();

                entities.CONVERTER_DOC.Remove(item);

                result = entities.SaveChanges();

            }

            return result;

        }

        #endregion

        #region MarkusLink

        ////// userID는 관리자 계정인 doftech

        ////string markusLink = "kcom://" + MarkusAPI.CreateMarkusParam(projectNo, documentID, userID);

        //public static string CreateMarkusParam(string projectNo, string documentID, string userID)

        //{

        //    ViewInfo viewInfo = new ViewInfo();

        //    viewInfo.DocumentItemID = documentID;

        //    viewInfo.ProjectNO = projectNo;

        //    viewInfo.UserID = userID;

        //    return ParamEncoding(JsonConvert.SerializeObject(viewInfo));

        //}

        //public static string ParamEncoding(string EncodingText, System.Text.Encoding oEncoding = null)

        //{

        //    if (oEncoding == null)

        //        oEncoding = System.Text.Encoding.UTF8;

        //    return Convert.ToBase64String(oEncoding.GetBytes(EncodingText));

        //}

        #endregion

        #endregion

        #region DataBaseByStatusViewModel Function

        /// <summary>

        /// 전체 컨버터를 가져온다. 비동기로 변경하여야 한다.

        /// </summary>

        /// <returns></returns>

        public List<Interface.ConvertItem> GetConvertItems(StatusCodeType statusCodeType, Func<CONVERTER_DOC, bool> @where, int takeCount = 100)

        {

            List<Interface.ConvertItem> convertItems = new List<Interface.ConvertItem>();

            var items = entities.CONVERTER_DOC.Where(x => x.STATUS == (int)statusCodeType).Take(takeCount).ToList();

            if (items.Count() > 0)

            {

                foreach (var item in items)

                {

                    var convertitem = new Interface.ConvertItem(item.DOCUMENT_ID, item.PROJECT_NO, item.ID, item.DOCUMENT_URL)

                    {

                        ReConverter = item.RECONVERTER,

                        ServiceID = item.SERVICE_ID,

                        ConvertState = ((StatusCodeType)item.STATUS),

                        CreateTime = item.CREATE_DATETIME,

                        TotalPage = item.TOTAL_PAGE,

                        CurrentPageNo = item.CURRENT_PAGE,

                        ConvertPath = GetConvertPath(item.PROJECT_NO, item.DOCUMENT_ID)

                    };

                    convertItems.Add(convertitem);

                }

            }

            return convertItems;

        }

        #endregion

        #region No 참조 

        /// <summary>

        /// 컨버터서비스를 이용하는 문서 정보 저장

        /// UniqueID

        /// using Markus.Service.Extensions;  new Guid().CreateUniqueGuid().ToString();

        /// </summary>

        /// <param name="ProjectNo">프로젝트</param>

        /// <param name="UniqueID">컨버터 서비스의 아이템 ID</param>

        /// <param name="originfilePath"></param>

        /// <param name="DocumentID"></param>

        /// <returns></returns>

        public bool SetConvertDoc(string ProjectNo, string UniqueID, string originfilePath, string DocumentID)

        {

            bool result = false;

            if (ProjectNo.IsNullOrEmpty())

            {

                throw new Exception("ProjectNo is Null");

            }

            if (UniqueID.IsNullOrEmpty())

            {

                throw new Exception("UniqueID is Null");

            }

            if (originfilePath.IsNullOrEmpty())

            {

                throw new Exception("originfilePath is Null");

            }

            if (DocumentID.IsNullOrEmpty())

            {

                throw new Exception("DocumentID is Null");

            }

            if (DocumentID.IsNullOrEmpty())

            {

                long _lastDocId = 0;

                if (entities.CONVERTER_DOC.Count() > 0)

                {

                    try

                    {

                        string qry = @"SELECT * FROM CONVERTER_DOC order by CAST(DOCUMENT_ID as int) desc";

                        var _item = entities.CONVERTER_DOC.SqlQuery(qry).FirstOrDefault();

                        if (_item != null)

                        {

                            _lastDocId = Convert.ToInt64(_item.DOCUMENT_ID) + 1;

                        }

                    }

                    catch (Exception)

                    {

                        throw;

                    }

                }

                DocumentID = _lastDocId.ToString();

            }

            CONVERTER_DOC convert_doc = new CONVERTER_DOC

            {

                ID = UniqueID,

                PROJECT_NO = ProjectNo,

                DOCUMENT_URL = originfilePath,

                DOCUMENT_ID = DocumentID,

                CREATE_DATETIME = DateTime.Now,

                STATUS = 0,

                TOTAL_PAGE = 0,

                CURRENT_PAGE = 0,

                RECONVERTER = 0

            };

            entities.CONVERTER_DOC.Add(convert_doc);

            if (entities.SaveChanges() == 1)

            {

                result = true;

            }

            return result;

        }

        /// <summary>

        /// 컨버터서비스를 이용하는 문서 정보 저장

        /// UniqueID

        /// using Markus.Service.Extensions;  new Guid().CreateUniqueGuid().ToString();

        /// </summary>

        /// <param name="ProjectNo">프로젝트</param>

        /// <param name="UniqueID">컨버터 서비스의 아이템 ID</param>

        /// <param name="originfilePath"></param>

        /// <param name="DocumentID"></param>

        /// <returns></returns>

        public bool SetDocumentInfo(string ConvertID, int totalPage, List<DOCPAGE> pageinfo)

        {

            bool result = false;

            var convertDocItems = entities.CONVERTER_DOC.Where(f => f.ID == ConvertID);

            if (convertDocItems.Count() > 0)

            {

                var convertDoc = convertDocItems.First();

                string docId = new Guid().CreateUniqueGuid().ToString();

                var docinfo = entities.DOCINFO.FirstOrDefault(x => x.PROJECT_NO == convertDoc.PROJECT_NO && x.DOCUMENT_ID == convertDoc.DOCUMENT_ID);

                if (docinfo != null)

                {

                    // 기존 Docpage 삭제.

                    entities.DOCPAGE.RemoveRange(docinfo.DOCPAGE);

                    // 기존 코멘트 유지를 위한 Docinfo update                    

                    docinfo.PROJECT_NO = convertDoc.PROJECT_NO;

                    docinfo.ORIGINAL_FILE = convertDoc.DOCUMENT_URL;

                    docinfo.PAGE_COUNT = totalPage;                    

                    docinfo.DOCPAGE = pageinfo;                    

                    entities.SaveChanges();

                    result = true;

                }

                else

                {

                    DOCINFO instace = new DOCINFO

                    {

                        ID = docId,

                        PROJECT_NO = convertDoc.PROJECT_NO,

                        ORIGINAL_FILE = convertDoc.DOCUMENT_URL,

                        DOCUMENT_ID = convertDoc.DOCUMENT_ID,

                        PAGE_COUNT = totalPage,

                        DOCPAGE = pageinfo

                    };

                    entities.DOCINFO.Add(instace);

                    var save = entities.SaveChanges();

                    if (save == pageinfo.Count() + 1)

                    {

                        result = true;

                    }

                }

            }

            return result;

        }

        public Interface.ConvertItem GetConvertItem(string ProjectNo, string UniqueID)

        {

            Interface.ConvertItem result = null;

            //var items = entities.CONVERTER_DOC.Where(f => f.PROJECT_NO == gProjectNo && f.ID == UniqueID);

            var items = entities.CONVERTER_DOC.Where(f => f.PROJECT_NO == ProjectNo && f.ID == UniqueID);

            if (items.Count() > 0)

            {

                var convertItem = items.First();

                string convertPath = Path.Combine(BaseStorage(convertItem.PROJECT_NO), convertItem.PROJECT_NO + "_Tile", (System.Convert.ToInt64(convertItem.DOCUMENT_ID) / 100).ToString(), convertItem.DOCUMENT_ID);

                result = new Interface.ConvertItem(convertItem.DOCUMENT_ID, convertItem.PROJECT_NO, convertItem.ID, convertItem.DOCUMENT_URL, convertPath);

            }

            return result;

        }

        public Interface.ConvertItem GetConvertItembyDocumentID(string ProjectNo, string DocumentID)

        {

            Interface.ConvertItem result = null;

            //var items = entities.CONVERTER_DOC.Where(f => f.PROJECT_NO == gProjectNo && f.ID == UniqueID);

            var items = entities.CONVERTER_DOC.Where(f => f.PROJECT_NO == ProjectNo && f.DOCUMENT_ID == DocumentID);

            if (items.Count() > 0)

            {

                var convertItem = items.First();

                string convertPath = Path.Combine(BaseStorage(convertItem.PROJECT_NO), convertItem.PROJECT_NO + "_Tile", (System.Convert.ToInt64(convertItem.DOCUMENT_ID) / 100).ToString(), convertItem.DOCUMENT_ID);

                if (convertItem.STATUS == (int)StatusCodeType.Completed)

                {

                    result = new Interface.ConvertItem(convertItem.DOCUMENT_ID, convertItem.PROJECT_NO, convertItem.ID, convertItem.DOCUMENT_URL, convertPath,

                                                        (StatusCodeType)convertItem.STATUS, convertItem.CURRENT_PAGE, convertItem.TOTAL_PAGE, convertItem.EXCEPTION);

                }

                else

                {

                    result = new Interface.ConvertItem(convertItem.DOCUMENT_ID, convertItem.PROJECT_NO, convertItem.ID, convertItem.DOCUMENT_URL, convertPath);

                }

            }

            return result;

        }

        public List<CONVERTER_DOC> GetConvertingItems(List<string> projectList)

        {

            var convertWaitingItems = entities.CONVERTER_DOC.OrderBy(x => x.CREATE_DATETIME).Where(

                                        x =>

                                        projectList.Contains(x.PROJECT_NO) &&

                                         (x.STATUS > (int)StatusCodeType.None && x.STATUS < (int)StatusCodeType.Completed) && x.RECONVERTER < 2);

            return convertWaitingItems.ToList();

        }

        /// <summary>

        /// 전체 컨버터를 가져온다. 비동기로 변경하여야 한다.

        /// </summary>

        /// <returns></returns>

        public List<Interface.ConvertItem> GetConvertItems(StatusCodeType statusCodeType)

        {

            List<Interface.ConvertItem> convertItems = new List<Interface.ConvertItem>();

            var items = entities.CONVERTER_DOC.Where(x => x.STATUS == (int)statusCodeType).ToList(); //.Where(x => x.PROJECT_NO == gProjectNo);

            if (items.Count() > 0)

            {

                foreach (var item in items)

                {

                    var convertitem = new Interface.ConvertItem(item.DOCUMENT_ID, item.PROJECT_NO, item.ID, item.DOCUMENT_URL)

                    {

                        ReConverter = item.RECONVERTER,

                        ServiceID = item.SERVICE_ID,

                        ConvertState = ((StatusCodeType)item.STATUS),

                        CreateTime = item.CREATE_DATETIME,

                        TotalPage = item.TOTAL_PAGE,

                        CurrentPageNo = item.CURRENT_PAGE,

                        ConvertPath = GetConvertPath(item.PROJECT_NO, item.DOCUMENT_ID)

                    };

                    convertItems.Add(convertitem);

                }

            }

            return convertItems;

        }

        public List<Interface.ConvertItem> GetConvertProjectsStatus(Func<CONVERTER_DOC, bool> @where)

        {

            List<Interface.ConvertItem> convertItems = new List<Interface.ConvertItem>();

            //var items = entities.CONVERTER_DOC.Where(x => x.STATUS == (int)statusCodeType).Take(takeCount).ToList(); //.Where(x => x.PROJECT_NO == gProjectNo);

            var items = entities.CONVERTER_DOC.Where(x => x.STATUS <= 4);

            if (items.Count() > 0)

            {

                foreach (var item in items)

                {

                    var convertitem = new Interface.ConvertItem(item.DOCUMENT_ID, item.PROJECT_NO, item.ID, item.DOCUMENT_URL)

                    {

                        ReConverter = item.RECONVERTER,

                        ServiceID = item.SERVICE_ID,

                        //ConvertState = ((StatusCodeType)item.STATUS).ToString(),

                        //ConvertState = (item.STATUS).ToString(),

                        ConvertState = (StatusCodeType)item.STATUS,

                        CreateTime = item.CREATE_DATETIME,

                        TotalPage = item.TOTAL_PAGE,

                        CurrentPageNo = item.CURRENT_PAGE,

                        Exception = item.EXCEPTION,

                        ConvertPath = GetConvertPath(item.PROJECT_NO, item.DOCUMENT_ID)

                    };

                    convertItems.Add(convertitem);

                }

            }

            return convertItems;

        }

        public bool SetConvertState(string ServiceID, string UniqueID, int State, int CurrentPage, int TotalPage, string Error)

        {

            bool result = false;

            try

            {

                var items = entities.CONVERTER_DOC.SingleOrDefault(f => f.ID == UniqueID);

                //var items = entities.CONVERTER_DOC.SingleOrDefault(f => f.PROJECT_NO == gProjectNo && f.ID == UniqueID);

                if (items != null)

                {

                    items.SERVICE_ID = ServiceID;

                    items.STATUS = State;

                    items.CURRENT_PAGE = CurrentPage;

                    items.TOTAL_PAGE = TotalPage;

                    StatusCodeType statusCode = (StatusCodeType)State;

                    if (items.START_DATETIME == null)

                    {

                        items.START_DATETIME = DateTime.Now;

                    }

                    switch (statusCode)

                    {

                        case StatusCodeType.None:

                            break;

                        case StatusCodeType.Wait:

                            items.START_DATETIME = DateTime.Now;

                            break;

                        case StatusCodeType.PageLoading:

                            break;

                        case StatusCodeType.Saving:

                            break;

                        case StatusCodeType.Completed:

                            items.CURRENT_PAGE = items.TOTAL_PAGE;

                            items.END_DATETIME = DateTime.Now;

                            break;

                        case StatusCodeType.FileError:

                            Error = $" file Error :" + Error;

                            items.END_DATETIME = DateTime.Now;

                            break;

                        case StatusCodeType.PageError:

                            Error = $" Page No {CurrentPage} Error :" + Error;

                            break;

                        case StatusCodeType.NeedsPassword:

                            break;

                        case StatusCodeType.Error:

                            Error = $" Error :" + Error;

                            items.END_DATETIME = DateTime.Now;

                            break;

                        default:

                            break;

                    }

                    if (items.EXCEPTION == null)

                    {

                        items.EXCEPTION = "";

                    }

                    if (items.EXCEPTION.Length < 255)

                    {

                        items.EXCEPTION = items.EXCEPTION + Error;

                    }

                    entities.SaveChanges();

                    result = true;

                }

            }

            catch (Exception ex)

            {

                throw new Exception("SetConvertState", ex);

            }

            return result;

        }

        public SERVICE_PROPERTIES GetServiceProperties(string ServiceID)

        {

            SERVICE_PROPERTIES result = null;

            var items = entities.SERVICE_PROPERTIES.Where(x => x.ID == ServiceID);

            if (items.Count() > 0)

            {

                result = items.First();

            }

            return result;

        }

        /// <summary>

        /// 현재 서비스에서 컨버터중인 아이템.

        /// </summary>

        /// <returns></returns>

        public List<Interface.ConvertItem> GetServiceAliveItems(string ServiceID)

        {

            List<Interface.ConvertItem> convertItems = new List<Interface.ConvertItem>();

            var items = entities.CONVERTER_DOC.Where(x => x.SERVICE_ID == ServiceID && x.STATUS > (int)StatusCodeType.None && x.STATUS < (int)StatusCodeType.Completed).ToList(); //.Where(x => x.PROJECT_NO == gProjectNo);

            if (items.Count() > 0)

            {

                foreach (var item in items)

                {

                    var convertitem = new Interface.ConvertItem(item.DOCUMENT_ID, item.PROJECT_NO, item.ID, item.DOCUMENT_URL);

                    convertItems.Add(convertitem);

                }

            }

            return convertItems;

        }

        #endregion

    }

}