MARKUS

using Markus.Message;

using Markus.Service.Extensions;

using Markus.Service.Interface;

using Markus.Service.IWcfService;

using System;

using System.Collections.Generic;

using System.Diagnostics;

using System.Linq;

using System.ServiceModel;

using System.ServiceModel.Activation;

using System.ServiceModel.Web;

using System.Text;

using System.Threading.Tasks;

namespace Markus.Service

{

    /// <summary>

    /// web service 목록

    /// </summary>

    [AspNetCompatibilityRequirements(RequirementsMode = AspNetCompatibilityRequirementsMode.Allowed)]

    //[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall, IncludeExceptionDetailInFaults = true)]

    public partial class ServiceStation : IStationService

    {

        /// <summary>

        /// DB에 Convrert Item을 추가 하고 호출 

        /// CovnertWebService에서 호출시 사용

        /// </summary>

        /// <param name="ProjectNo"></param>

        /// <param name="ConvertID"></param>

        /// <returns></returns>

        public string ConvertAdd(string ProjectNo, string ConvertID)

        {

            string result = false.ToString();

            try

            {

                result = ConvertProcessAdd(ProjectNo, ConvertID);

                logger.Info($"ConvertAdd Call Item ProjectNo : {ProjectNo}  ConvertID : {ConvertID}  result : {result}");

            }

            catch (Exception ex)

            {

                result = $"ConvertAdd Error {ConvertID}";

                logger.Error($"ConvertAdd Error- {ConvertID}", ex);

            }

            return result;

        }

        /// <summary>

        /// Main Station에서 전달받은 convert item

        /// </summary>

        /// <param name="ProjectNo"></param>

        /// <param name="ConvertID"></param>

        /// <returns></returns>

        public string PassConvert(string ProjectNo, string ConvertID)

        {

            string result = false.ToString();

            try

            {

                using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))

                {

                    var convertItem = database.GetConvertItem(ProjectNo, ConvertID);

                    /// 순서별 Convert Item 처리 

                    if (convertItem != null)

                    {

                        if (AliveConvertQueue.Count(c => c.UniqueKey == convertItem.UniqueKey) == 0)

                        {

                            result = ConvertProcessAdd(ProjectNo, ConvertID);

                            logger.Info($"PassConvert Item ProjectNo : {ProjectNo}  ConvertID : {ConvertID}  result : {result}");

                        }

                        else

                        {

                        }

                    }

                }

            }

            catch (Exception ex)

            {

                result = $"PassConvert Error {ConvertID}";

                logger.Error($"PassConvert Error- {ConvertID}", ex);

            }

            return result;

        }

        /// <summary>

        /// 별도의 호출 사용 

        /// </summary>

        /// <param name="ProjectNo"></param>

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

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

        /// <returns></returns>

        public string ConvertMenualAdd(string ProjectNo, string originfilePath, string DocumentID)

        {

            string result = false.ToString();

            string convertID = new Guid().CreateUniqueGuid().ToString().Replace("-", "");

            try

            {

                using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))

                {

                    var convertItem = database.GetConvertItembyDocumentID(ProjectNo, DocumentID);

                    if(convertItem != null)

                    {

                        var aliveItems = AliveConvertQueue.Where(x => x.UniqueKey == convertItem.UniqueKey);

                    }

                    if (!database.SetConvertDoc(ProjectNo, convertID, originfilePath, DocumentID))

                    {

                        logger.Error($"Set Convert Document Error - ProjectNo:{ProjectNo} UniqueID:{convertID} originfilePath:{originfilePath} DocumentID:{DocumentID}");

                    }

                    else

                    {

                        result = ConvertProcessAdd(ProjectNo, convertID);

                    }

                }

            }

            catch (Exception ex)

            {

                result = "DataBase SetConvert Error";

                logger.Error($"ConvertMenualAdd Error-  database.SetConvertDoc ProjectNo:{ProjectNo} UniqueID:{convertID} originfilePath:{originfilePath} DocumentID:{DocumentID}", ex);

            }

            return result;

        }

        /// <summary>

        /// ConvertItem의 상태

        /// </summary>

        /// <param name="ProjectNo"></param>

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

        /// <returns></returns>

        public Item GetConvertItem(string ProjectNo, string DocumentID)

        {

            Item result = null;

            try

            {

                using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))

                {

                    var item = database.GetConvertItembyDocumentID(ProjectNo, DocumentID);

                    if (item != null)

                    {

                        result =

                        new Item

                        {

                            DocumentID = item.UniqueKey,

                            Status = item.ConvertState.ToString(),

                            ProjectNo = item.ProjectNumber,

                            TotalPage = item.TotalPage,

                            CurrentPageNo = item.CurrentPageNo,

                            PdfPath = item.OriginfilePath,

                            ConvertPath = item.ConvertPath

                        };

                    }

                }

            }

            catch (Exception ex)

            {

                throw new FaultException("Get ConvertItem Error");

            }

            return result;

        }

        /// <summary>

        /// Convert Item을 DB에 추가 하고 프로세스 실행시 호출

        /// </summary>

        /// <param name="ProjectNo"></param>

        /// <param name="convertID"></param>

        /// <returns></returns>

        private string ConvertProcessAdd(string ProjectNo, string convertID)

        {

            string result = false.ToString();

            logger.Warn($"WCF ConvertProcessAdd Call ProjectNo:{ProjectNo} convertID:{convertID} ");

            using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))

            {

                var convertItem = database.GetConvertItem(ProjectNo, convertID);

                /// 순서별 Convert Item 처리 

                if (convertItem != null)

                {

                    try

                    {

                        if (AliveConvertQueue.Find(c => c.UniqueKey == convertItem.UniqueKey) == null)

                        {

                            if (AliveConvertQueue.Count() < ServiceProperty.PROCESS_COUNT)

                            {

                                convertItem.ServiceID = this.ServiceID;

                                AliveConvertQueue.Add(convertItem);

                                var startResult = ConvertProcessStart(convertItem);

                                if(!startResult)

                                {

                                    AliveConvertQueue.Remove(convertItem);

                                }

                                result = true.ToString();

                            }

                            else

                            {

                                logger.Warn($"ConvertProcessAdd  PassConvertItem ProcessCount ProjectNo:{ProjectNo} convertID:{convertID} ");

                                /// sub service (다른ip의 서비스로 보낸다) 이중화

                                PassConvertItem(ProjectNo, convertID, convertItem.UniqueKey, true);

                                result = true.ToString();

                            }

                        }

                        else

                        {

                            result = true.ToString();

                        }

                    }

                    catch (Exception ex)

                    {

                        result = "Convert Process Start Error";

                        logger.Error($"ConvertAdd  ConvertProcess call Error  ProjectNo:{ProjectNo} convertID:{convertID} ", ex);

                    }

                }

                else

                {

                    logger.Error($"ConvertAdd  ConvertProcess call Error  ProjectNo:{ProjectNo} convertID:{convertID} item Null ");

                    result = "Get ConvertItem Error";

                }

            }

            return result;

        }

        /// <summary>

        /// 각 ConvertProcess의 상태값을 저장

        /// </summary>

        /// <param name="ConvertID"></param>

        /// <param name="status"></param>

        /// <param name="CurrentPage"></param>

        /// <param name="TotalPage"></param>

        /// <param name="Error"></param>

        /// <returns></returns>

        public bool ConvertProcessState(string ConvertID, int status, int CurrentPage, int TotalPage, string Error)

        {

            if (AliveConvertQueue.Count() > 0)

            {

                var items = AliveConvertQueue.Where(x => x.ConvertID == ConvertID);

                if (items.Count() > 0)

                {

                    var item = items.First();

                    item.TotalPage = TotalPage;

                    item.CurrentPageNo = CurrentPage;

                    item.ConvertState = (StatusCodeType)status;

                }

            }

            if (CurrentPage % SaveStatusInterval == 0 || !Error.IsNullOrEmpty())

            {

                using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))

                {

                    if (!database.SetConvertState(this.ServiceID, ConvertID, status, CurrentPage, TotalPage, Error))

                    {

                        logger.Error($"DataBase Error database.SetConvertState({ConvertID}, {(int)status},{CurrentPage},{TotalPage}, {Error})");

                    }

                }

            }

            return true;

        }

        /// <summary>

        /// Convert Process 완료시 호출

        /// </summary>

        /// <param name="ConvertID"></param>

        /// <param name="status"></param>

        /// <param name="CurrentPage"></param>

        /// <param name="TotalPage"></param>

        /// <param name="Error"></param>

        /// <returns></returns>

        public bool ConvertFinish(string ConvertID, int status, int CurrentPage, int TotalPage, string Error)

        {

            using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))

            {

                if (!database.SetConvertState(this.ServiceID, ConvertID, status, CurrentPage, TotalPage, Error))

                {

                    logger.Error($"DataBase Error database.SetConvertState({ConvertID}, {(int)status},{CurrentPage},{TotalPage}, {Error})");

                }

            }

            var _convertItem = AliveConvertQueue.Where(f => f.ConvertID == ConvertID);

            if (_convertItem.Count() > 0)

            {

                ConvertFinish(_convertItem.First());

            }

            return true;

        }

        /// <summary>

        /// 대기중인 Convert Item을 가져옴

        /// </summary>

        /// <returns></returns>

        public List<ConvertItem> WaitConvertList()

        {

            List<ConvertItem> result = new List<ConvertItem>();

            using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))

            {

                result = database.GetConvertItems(Message.StatusCodeType.Wait).ToList();

            }

            return result;

        }

        /// <summary>

        /// 현재 AliveConvertQueue에 있는 컨버터 리스트

        /// </summary>

        /// <returns></returns>

        public List<ConvertItem> AliveConvertList()

        {

            return ServiceStation.AliveConvertQueue;

        }

        /// <summary>

        /// WCF 시작

        /// </summary>

        /// <returns></returns>

        public CommunicationState StartWcfService()

        {

            CommunicationState result = CommunicationState.Faulted;

            try

            {

                if (gServiceHostAddress != null)

                {

                    gWcfServiceHost = gWcfServiceHost.WcfCreate(this, typeof(IWcfService.IStationService), gServiceHostAddress);

                }

                if (gWcfServiceHost?.State != CommunicationState.Faulted)

                {

                    result = gWcfServiceHost.State;

                }

            }

            catch (Exception ex)

            {

                logger.Error("Start WCF Service Error ", ex);

            }

            return result;

        }

        /// <summary>

        /// WCF 중단

        /// </summary>

        /// <returns></returns>

        private bool StopWcfService()

        {

            bool result = false;

            try

            {

                gWcfServiceHost.Abort();

                result = true;

            }

            catch (Exception ex)

            {

                logger.Error("Stop WCF Service Error ", ex);

            }

            return result;

        }

        public bool ReleaseConvertItems()

        {

            System.Diagnostics.Debug.WriteLine("Call ReleaseConvertItems");

            if (!IsReleaseItems)

            {

                ReleaseItems();

            }

            System.Diagnostics.Debug.WriteLine("end ReleaseConvertItems");

            return true;

        }

    }

}