/ConvertService/ServiceBase/Markus.Service.Station/StationService/ServiceStationWCF.cs - 이력해설 - MARKUS - 일정관리

markus / ConvertService / ServiceBase / Markus.Service.Station / StationService / ServiceStationWCF.cs @ 1c7f408a

-c9637d
+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
+{
-            a53dfe45
+    /// <summary>
     /// web service 목록
     /// </summary>
-c9637d
+    [AspNetCompatibilityRequirements(RequirementsMode = AspNetCompatibilityRequirementsMode.Allowed)]
-ae729e4
+    //[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall, IncludeExceptionDetailInFaults = true)]
-c9637d
+    public partial class ServiceStation : IStationService
+    {
-            a53dfe45
+        /// <summary>
         /// DB에 Convrert Item을 추가 하고 호출
         /// CovnertWebService에서 호출시 사용
         /// </summary>
         /// <param name="ProjectNo"></param>
         /// <param name="ConvertID"></param>
         /// <returns></returns>
-c9637d
+        public string ConvertAdd(string ProjectNo, string ConvertID)
+        {
             string result = false.ToString();
             try
+            {
-f13e11
+                result = ConvertProcessAdd(ProjectNo, ConvertID);
-d5058
+            taeseongkim
                 logger.Info($"ConvertAdd Call Item ProjectNo : {ProjectNo}  ConvertID : {ConvertID}  result : {result}");
-c9637d
+            taeseongkim
             catch (Exception ex)
+            {
                 result = $"ConvertAdd Error {ConvertID}";
                 logger.Error($"ConvertAdd Error- {ConvertID}", ex);
+            }
             return result;
+        }
-            a53dfe45
+        /// <summary>
         /// 별도의 호출 사용
         /// </summary>
         /// <param name="ProjectNo"></param>
         /// <param name="originfilePath"></param>
         /// <param name="DocumentID"></param>
         /// <returns></returns>
-c9637d
+        public string ConvertMenualAdd(string ProjectNo, string originfilePath, string DocumentID)
+        {
             string result = false.ToString();
-f13e11
+            string convertID = new Guid().CreateUniqueGuid().ToString().Replace("-", "");
-c9637d
+            taeseongkim
             try
+            {
                 using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))
+                {
                     if (!database.SetConvertDoc(ProjectNo, convertID, originfilePath, DocumentID))
+                    {
                         logger.Error($"Set Convert Document Error - ProjectNo:{ProjectNo} UniqueID:{convertID} originfilePath:{originfilePath} DocumentID:{DocumentID}");
+                    }
                     else
+                    {
-f13e11
+                        result = ConvertProcessAdd(ProjectNo, convertID);
-c9637d
+            taeseongkim
+                }
+            }
             catch (Exception ex)
+            {
                 result = "DataBase SetConvert Error";
                 logger.Error($"ConvertMenualAdd Error-  database.SetConvertDoc ProjectNo:{ProjectNo} UniqueID:{convertID} originfilePath:{originfilePath} DocumentID:{DocumentID}", ex);
+            }
-f13e11
+            taeseongkim
-c9637d
+            return result;
+        }
-            a53dfe45
+        /// <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,
                             ProjectNo = item.ProjectNumber,
                             TotalPage = item.TotalPage,
                             CurrentPageNo = item.CurrentPageNo,
                             PdfPath = item.OriginfilePath,
                             ConvertPath = item.ConvertPath
                         };
-c9637d
+            taeseongkim
-            a53dfe45
+            taeseongkim
+                }
+            }
             catch (Exception ex)
+            {
                 throw new FaultException("Get ConvertItem Error");
+            }
-c9637d
+            taeseongkim
-            a53dfe45
+            return result;
+        }
         /// <summary>
         /// Convert Item을 DB에 추가 하고 프로세스 실행시 호출
         /// </summary>
         /// <param name="ProjectNo"></param>
         /// <param name="convertID"></param>
         /// <returns></returns>
-c9637d
+        private string ConvertProcessAdd(string ProjectNo, string convertID)
+        {
             string result = false.ToString();
             using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))
+            {
-f13e11
+                var convertItem = database.GetConvertItem(ProjectNo, convertID);
-c9637d
+            taeseongkim
                 /// 순서별 Convert Item 처리
                 if (convertItem != null)
+                {
                     try
+                    {
-            cdfb57ff
+                        if (AliveConvertQueue.Count(c => c.UniqueKey == convertItem.UniqueKey) == 0)
+                        {
-dc9
+                            if (ServiceStation.AliveConvertQueue.Count() < ServiceProperty.PROCESS_COUNT)
-            cdfb57ff
+            taeseongkim
-a89a17f
+                                convertItem.ServiceID = this.ServiceID;
-            cdfb57ff
+                                ConvertProcessStart(convertItem);
                                 result = true.ToString();
+                            }
-d5058
+                            else
+                            {
                                 logger.Info($"ConvertAdd  ConvertProcess Wait ProcessCount ProjectNo:{ProjectNo} convertID:{convertID} ");
                                 result = true.ToString();
+                            }
-            cdfb57ff
+            taeseongkim
                         else
-c9637d
+            taeseongkim
-a89a17f
+                            PassConvertItem(ProjectNo, convertID, convertItem.UniqueKey);
-c9637d
+                            result = true.ToString();
+                        }
+                    }
                     catch (Exception ex)
+                    {
                         result = "Convert Process Start Error";
-d5058
+                        logger.Error($"ConvertAdd  ConvertProcess call Error  ProjectNo:{ProjectNo} convertID:{convertID} ", ex);
-c9637d
+            taeseongkim
+                }
                 else
+                {
-d5058
+                    logger.Error($"ConvertAdd  ConvertProcess call Error  ProjectNo:{ProjectNo} convertID:{convertID} item Null ");
-c9637d
+                    result = "Get ConvertItem Error";
+                }
+            }
             return result;
+        }
-            a53dfe45
+        /// <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>
-f13e11
+        public bool ConvertProcessState(string ConvertID, int status, int CurrentPage, int TotalPage, string Error)
-c9637d
+            taeseongkim
-f13e11
+            var items = AliveConvertQueue.Where(x => x.ConvertID == ConvertID);
             if (items.Count() > 0)
-c9637d
+            taeseongkim
                 var item = items.First();
                 item.TotalPage = TotalPage;
                 item.CurrentPageNo = CurrentPage;
                 item.ConvertState = ((StatusCodeType)status).ToString();
+            }
             if (CurrentPage % SaveStatusInterval == 0 || !Error.IsNullOrEmpty())
+            {
                 using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))
+                {
-b158
+                    if (!database.SetConvertState(this.ServiceID, ConvertID, status, CurrentPage, TotalPage, Error))
-c9637d
+            taeseongkim
                         logger.Error($"DataBase Error database.SetConvertState({ConvertID}, {(int)status},{CurrentPage},{TotalPage}, {Error})");
+                    }
+                }
+            }
             return true;
+        }
-            a53dfe45
+        /// <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>
-f13e11
+        public bool ConvertFinish(string ConvertID, int status, int CurrentPage, int TotalPage, string Error)
-c9637d
+            taeseongkim
             using (Markus.Service.DataBase.ConvertDatabase database = new Markus.Service.DataBase.ConvertDatabase(MarkusDBConnectionString))
+            {
-b158
+                if (!database.SetConvertState(this.ServiceID, ConvertID, status, CurrentPage, TotalPage, Error))
-c9637d
+            taeseongkim
                     logger.Error($"DataBase Error database.SetConvertState({ConvertID}, {(int)status},{CurrentPage},{TotalPage}, {Error})");
+                }
+            }
             var _convertItem = ServiceStation.AliveConvertQueue.Where(f => f.ConvertID == ConvertID);
             if (_convertItem.Count() > 0)
-f13e11
+            taeseongkim
-c9637d
+                ConvertFinish(_convertItem.First());
-f13e11
+            taeseongkim
-c9637d
+            taeseongkim
             return true;
+        }
-            a53dfe45
+        /// <summary>
         /// 대기중인 Convert Item을 가져옴
         /// </summary>
         /// <returns></returns>
-c9637d
+        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;
+        }
-            a53dfe45
+        /// <summary>
         /// 현재 AliveConvertQueue에 있는 컨버터 리스트
         /// </summary>
         /// <returns></returns>
-c9637d
+        public List<ConvertItem> AliveConvertList()
+        {
-f13e11
+            return ServiceStation.AliveConvertQueue;
-c9637d
+            taeseongkim
-            a53dfe45
+        /// <summary>
         /// WCF 시작
         /// </summary>
         /// <returns></returns>
-c9637d
+        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;
+        }
-            a53dfe45
+        /// <summary>
         /// WCF 중단
         /// </summary>
         /// <returns></returns>
-c9637d
+        private bool StopWcfService()
+        {
             bool result = false;
             try
+            {
                 gWcfServiceHost.Abort();
                 result = true;
+            }
             catch (Exception ex)
+            {
                 logger.Error("Stop WCF Service Error ", ex);
+            }
             return result;
+        }
-f13e11
+        public bool ReleaseConvertItems()
+        {
             System.Diagnostics.Debug.WriteLine("Call ReleaseConvertItems");
-dc9
+            if (!IsReleaseItems)
+            {
                 ReleaseItems();
+            }
-f13e11
+            System.Diagnostics.Debug.WriteLine("end ReleaseConvertItems");
             return true;
+        }
-c9637d
+            taeseongkim
+}

프로젝트

일반

사용자정보

MARKUS

markus / ConvertService / ServiceBase / Markus.Service.Station / StationService / ServiceStationWCF.cs @ 1c7f408a