MARKUS

using MarkusDataModel.Common;

using MarkusDataModel.DataModel;

using Microsoft.AspNet.SignalR.Client;

using ServiceInterface;

using System;

using System.Collections;

using System.Collections.Generic;

using System.Data;

using System.Diagnostics;

using System.Linq;

using System.Reflection;

using System.Text;

using System.Threading.Tasks;

using TableDependency;

using TableDependency.EventArgs;

using TableDependency.SqlClient;

using static MarkusConsoleApplication.HubConfiguration;

namespace MarkusConsoleApplication

{

    class Program

    {

        private static SqlTableDependency<CONVERTER_DOC> _convertTableDependency;

        private static SqlTableDependency<FINAL_PDF> _finalTableDependency;

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

        private static ServiceEventLogger _serviceEventLogger = new ServiceEventLogger();

        private static string hubBaseURL = "http://cloud.devdoftech.co.kr:5100";

        private static string hubName = "MarkusHub";

        private static ConvertSetting convSetting = new ConvertSetting();

        private static FinalSetting finalSetting = new FinalSetting();

        private static DetectedType detectedType = new DetectedType();

        static void Main(string[] args)

        {

            #region 메인

            // convert

            try

            {

                // 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 

                _convertTableDependency.OnError += SqlTableDependency_OnError;

                _convertTableDependency.OnChanged += Convert_SqlTableDependency_Changed;

                _convertTableDependency.Start();

                // log 

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

            }

            catch (Exception ex)

            {

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

                throw;

            }

            // final

            try

            {

                var finalMapper = new ModelToTableMapper<FINAL_PDF>();

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

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

                _finalTableDependency.OnError += SqlTableDependency_OnError;

                _finalTableDependency.OnChanged += Final_SqlTableDependency_Changed;

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

                _finalTableDependency.Start();

            }

            catch (Exception ex)

            {

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

                throw;

            }

            Console.ReadKey();

            #endregion

        }

        /// <summary>

        /// SQL Dependency Error code 

        /// </summary>

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

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

        public static void SqlTableDependency_OnError(object sender, ErrorEventArgs e)

        {

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

            throw e.Error;

        }

        /// <summary>

        /// Converter Sql Dependency Changed

        /// </summary>

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

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

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

        {

            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;

            }

        }

        /// <summary>

        /// Final Sql Dependency Changed 

        /// </summary>

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

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

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

        {

            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;

            }

        }

        /// <summary>

        /// Convert Hub Send

        /// </summary>

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

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

        public static void DetectedMakrusConvertTable(string type, CONVERTER_DOC data)

        {

            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);

                }

            }

        }

        /// <summary>

        /// Final Hub Send

        /// </summary>

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

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

        public static void DetectedMakrusFinalTable(string type, FINAL_PDF data)

        {

            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);

                }

            }

        }

    }

}