MARKUS

using IKCOM;

using MarkusDataModel.Common;

using MarkusDataModel.DataModel;

using Microsoft.AspNet.SignalR.Client;

using ServiceInterface;

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Diagnostics;

using System.Linq;

using System.Reflection;

using System.ServiceProcess;

using System.Text;

using System.Threading.Tasks;

using TableDependency;

using TableDependency.EventArgs;

using TableDependency.SqlClient;

using static LogviewSqlDependency.HubConfiguration;

namespace LogviewSqlDependency

{

    partial class LogviewSqlDependency : ServiceBase

    {

        private static SqlTableDependency<CONVERTER_DOC> _convertTableDependency;

        private static SqlTableDependency<FINAL_PDF> _finalTableDependency;

        private static string entityConnString = ConnectStringBuilder.MarkusEntitiesConnectionString().ProviderConnectionString.ToString();

        private static ServiceEventLogger_db _serviceEventLogger = new ServiceEventLogger_db();

        private static string hubBaseURL = LogviewHubBaseURI.Url + LogviewHubBaseURI.Port + LogviewHubBaseURI.SignalrPath;

        private static string hubName = "MarkusHub";

        private static ConvertSetting convSetting = new ConvertSetting();

        private static FinalSetting finalSetting = new FinalSetting();

        private static DetectedType detectedType = new DetectedType();

        private static ServiceController _service = new ServiceController("logviewDep_watcher");

        public LogviewSqlDependency()

        {

            InitializeComponent();

        }

        protected override void OnStart(string[] args)

        {

            // TODO: 여기에 서비스를 시작하는 코드를 추가합니다.

            #region sql dependency config 

            // convert

            try

            {

                // sql dependency config

                var convertMapper = new ModelToTableMapper<CONVERTER_DOC>();

                convertMapper.AddMapping(s => s.CURRENT_PAGE, "CURRENT_PAGE");

                _convertTableDependency = new SqlTableDependency<CONVERTER_DOC>(entityConnString, "CONVERTER_DOC", convertMapper);

                // add event ( mapping )  

                _convertTableDependency.OnError += SqlTableDependency_OnError;

                _convertTableDependency.OnChanged += Convert_SqlTableDependency_Changed;

                _convertTableDependency.Start();

                // event log 

                _serviceEventLogger.WriteEventEntry("Convert Table dependency" + MethodBase.GetCurrentMethod().Name, EventLogEntryType.SuccessAudit);

            }

            catch (Exception ex)

            {

                _serviceEventLogger.WriteEventEntry("Convert Table dependency ERROR " + MethodBase.GetCurrentMethod().Name + " : " + ex.Message, EventLogEntryType.Error);

                throw;

            }

            // final

            try

            {

                // sql dependency config 

                var finalMapper = new ModelToTableMapper<FINAL_PDF>();

                finalMapper.AddMapping(s => s.CURRENT_PAGE, "CURRENT_PAGE");

                _finalTableDependency = new SqlTableDependency<FINAL_PDF>(entityConnString, "FINAL_PDF", finalMapper);

                // add event ( mapping ) 

                _finalTableDependency.OnError += SqlTableDependency_OnError;

                _finalTableDependency.OnChanged += Final_SqlTableDependency_Changed;

                _finalTableDependency.Start();

                // event log 

                _serviceEventLogger.WriteEventEntry("final Table dependency" + MethodBase.GetCurrentMethod().Name, EventLogEntryType.SuccessAudit);

            }

            catch (Exception ex)

            {

                _serviceEventLogger.WriteEventEntry("final Table dependency ERROR " + MethodBase.GetCurrentMethod().Name + " : " + ex.Message, EventLogEntryType.Error);

                throw;

            }

            #endregion

        }

        protected override void OnStop()

        {

            // TODO: 서비스를 중지하는 데 필요한 작업을 수행하는 코드를 여기에 추가합니다.

        }

        /// <summary>

        /// sql dependency 에러 

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        public static void SqlTableDependency_OnError(object sender, ErrorEventArgs e)

        {

            #region dependency error 

            _serviceEventLogger.WriteEventEntry(" SQL Dependency ERROR " + MethodBase.GetCurrentMethod().Name + " :: " + e, EventLogEntryType.Error);

            try

            {

                Process[] dep = Process.GetProcessesByName("LoviewSqlDependency_Watcher");

                if (dep.Length > 0)

                {

                    dep[0].Kill();

                    //this.EventLog.WriteEntry("Dependency wather :: Dependency Service Kill");

                    _service.Refresh();

                    if (_service.Status == ServiceControllerStatus.Running || _service.Status == ServiceControllerStatus.StartPending)

                    {

                        _service.WaitForStatus(ServiceControllerStatus.Stopped);

                    }

                    _service.Start(new string[] { "Restart" });

                    _service.WaitForStatus(ServiceControllerStatus.Running);

                    //this.EventLog.WriteEntry("Dependency wather :: Dependency Service start");

                }

                else

                {

                    _service.Start();

                    _service.WaitForStatus(ServiceControllerStatus.Running);

                    //this.EventLog.WriteEntry("Dependency wather :: process not found");

                }

            }

            catch (Exception ex)

            {

                //this.EventLog.WriteEntry("Dependency wather :: Dependency service restart Error " + ex.ToString());

            }

            throw e.Error;

            #endregion

        }

        /// <summary>

        /// 변경사항 ( 추가, 삭제, 수정 ) 감지 

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        public static void Convert_SqlTableDependency_Changed(object sender, RecordChangedEventArgs<CONVERTER_DOC> e)

        {

            #region convert table dependency

            try

            {

                string changeType = e.ChangeType.ToString();

                DetectedMakrusConvertTable(e.ChangeType.ToString(), e.Entity);

                _serviceEventLogger.WriteEventEntry(MethodBase.GetCurrentMethod().Name + " changeType : " + changeType, EventLogEntryType.SuccessAudit);

            }

            catch (Exception ex)

            {

                _serviceEventLogger.WriteEventEntry("Convert_SqlTableDependency_Changed Error : " + ex, EventLogEntryType.Error);

                throw;

            }

            #endregion

        }

        /// <summary>

        /// 변경사항 ( 추가, 삭제, 수정 ) 감지 

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        public static void Final_SqlTableDependency_Changed(object sender, RecordChangedEventArgs<FINAL_PDF> e)

        {

            #region final table dependency

            try

            {

                string changeType = e.ChangeType.ToString();

                _serviceEventLogger.WriteEventEntry(MethodBase.GetCurrentMethod().Name + " changeType : " + changeType, EventLogEntryType.SuccessAudit);

                DetectedMakrusFinalTable(changeType, e.Entity);

            }

            catch (Exception ex)

            {

                _serviceEventLogger.WriteEventEntry("Final_SqlTableDependency_Changed Error : " + ex, EventLogEntryType.Error);

                throw;

            }

            #endregion

        }

        /// <summary>

        /// Convert 테이블 변경 시 signalR을 통해 클라이언트에게 전송 

        /// </summary>

        /// <param name="type"></param>

        /// <param name="data"></param>

        public static void DetectedMakrusConvertTable(string type, CONVERTER_DOC data)

        {

            #region Convert Table SignalR

            using (var hubConn = new HubConnection(hubBaseURL))

            {

                var hub = hubConn.CreateHubProxy(hubName);

                hubConn.Start().Wait();

                _serviceEventLogger.WriteEventEntry(MethodBase.GetCurrentMethod().Name, EventLogEntryType.SuccessAudit);

                if (type == detectedType.DataInsert)

                {

                    hub.Invoke(convSetting.InvokeInsert, data);

                }

                else if (type == detectedType.DataUpdate)

                {

                    hub.Invoke(convSetting.InvokeChange, data);

                }

                else if (type == detectedType.DataDelete)

                {

                    hub.Invoke(convSetting.InvokeDelete, data);

                }

            }

            #endregion

        }

        /// <summary>

        /// Final 테이블 변경 시 signalR을 통해 클라이언트에게 전송

        /// </summary>

        /// <param name="type"></param>

        /// <param name="data"></param>

        public static void DetectedMakrusFinalTable(string type, FINAL_PDF data)

        {

            #region Final Table SignalR

            using (var hubConn = new HubConnection(hubBaseURL))

            {

                var hub = hubConn.CreateHubProxy(hubName);

                hubConn.Start().Wait();

                _serviceEventLogger.WriteEventEntry(MethodBase.GetCurrentMethod().Name, EventLogEntryType.SuccessAudit);

                if (type == detectedType.DataInsert)

                {

                    hub.Invoke(finalSetting.InvokeInsert, data);

                }

                else if (type == detectedType.DataUpdate)

                {

                    hub.Invoke(finalSetting.InvokeChange, data);

                }

                else if (type == detectedType.DataDelete)

                {

                    hub.Invoke(finalSetting.InvokeDelete, data);

                }

            }

            #endregion

        }

    }

}