MARKUS

using System;

using System.Collections.Generic;

using System.Diagnostics;

using System.Linq;

using System.ServiceModel;

using System.ServiceProcess;

using System.Text;

using System.Threading.Tasks;

using System.Timers;

using System.Windows;

using System.Windows.Controls;

using System.Windows.Data;

using System.Windows.Documents;

using System.Windows.Input;

using System.Windows.Media;

using System.Windows.Media.Imaging;

using System.Windows.Navigation;

using System.Windows.Shapes;

using System.Windows.Threading;

using Markus.Service;

using Markus.Service.Extensions;

using Markus.Service.Helper;

namespace MonitorTest

{

    /// <summary>

    /// MainWindow.xaml에 대한 상호 작용 논리

    /// </summary>

    public partial class MainWindow : Window

    {

        public MainWindow()

        {

            InitializeComponent();

        }

        //Markus.Service.WorkMonitor.ServiceMonitor monitor = new Markus.Service.WorkMonitor.ServiceMonitor();

        private void Button_Click(object sender, RoutedEventArgs e)

        {

           // monitor.AddCallback(test.processTest, $"test{monitor.timers.Count}", new TimeSpan(0, 0, 1), new TimeSpan(0, 0, 10));

        }

        private void btProcessAguemnt_Click(object sender, RoutedEventArgs e)

        {

            var process = Process.GetProcessesByName(txtProcessName.Text);

            if (process.Count() > 0)

            {

                foreach (var item in process)

                {

                    System.Diagnostics.Debug.WriteLine(string.Join("",item.Arguments().CommandLine));

                }

            }

        }

        private void btProcessWorking_Click(object sender, RoutedEventArgs e)

        {

            var process = Process.GetProcessesByName("PerfWatson2");

            if (process.Count() > 0)

            {

                System.Diagnostics.Debug.WriteLine(process.First().StartInfo.WorkingDirectory);

            }

        }

        private void btTimerTest_Click(object sender, RoutedEventArgs e)

        {

            timer = new System.Timers.Timer(new TimeSpan(0, 0, 0, 1).TotalMilliseconds);

            timer.Elapsed += OnTimedEvent;

            timer.AutoReset = true;

            timer.Start();

        }

        private enum SimpleServiceCustomCommands { StopWorker = 128, RestartWorker, CheckWorker };

        private const string StationProcessName = "Markus.Service.Station";

        private const string StationServiceName = "ServiceStation";

        ServiceController serviceController;

        StationService.StationServiceClient stationServiceClient;

        System.Timers.Timer timer;

        private void ServiceInitialize()

        {

            if (serviceController == null)

            {

                serviceController = new ServiceController(StationServiceName);

            }

            #region 컨버터 서비스 연결

        }

        private void WcfClientInitialize()

        { 

            var process = Process.GetProcessesByName(StationProcessName);

            if (process.Count() > 0)

            {

                if (stationServiceClient == null)

                {

                    string serviceWorkDir = process.First().Arguments().WorkingDirectory;

                    var config = ConfigHelper.AppConfig(System.IO.Path.Combine(serviceWorkDir, $"{StationServiceName}.ini" ));

                    var endpointName = config.GetValue(CONFIG_DEFINE.WCF_ENDPOINT, CONFIG_DEFINE.STATION_SERVICE_NAME);

                    var port = config.GetValue(CONFIG_DEFINE.WCF_ENDPOINT, CONFIG_DEFINE.STATION_PORT);

                    if (!string.IsNullOrWhiteSpace(endpointName) && port.IsNumber())

                    {

                        var serviceUri = UriHelper.UriCreate($"http://localhost:{port}/{endpointName}");

                        BasicHttpBinding myBinding = new BasicHttpBinding();

                        EndpointAddress myEndpoint = new EndpointAddress(serviceUri);

                        stationServiceClient = new StationService.StationServiceClient(myBinding, myEndpoint);

                    }

                }

            }

            #endregion

        }

        private void OnTimedEvent(object sender, ElapsedEventArgs e)

        {

            timer.Enabled = false;

            try

            {

                if (serviceController == null)

                {

                    serviceController = null;

                    ServiceInitialize();

                }

                else

                {

                    serviceController.Refresh();

                    System.Diagnostics.Debug.WriteLine(" serviceController.Status : " + serviceController.Status);

                    if (serviceController.Status != ServiceControllerStatus.Running && serviceController.Status != ServiceControllerStatus.StartPending)

                    {

                        serviceController.Start();

                    }

                    else

                    {

                        if (stationServiceClient == null)

                        {

                            WcfClientInitialize();

                        }

                        else

                        {

                            System.Diagnostics.Debug.WriteLine(" stationServiceClient.State : " + stationServiceClient.State);

                            var result = stationServiceClient.AliveConvertList();

                        }

                    }

                }

            }

            catch (Exception ex)

            {

               // serviceController.ExecuteCommand((int)SimpleServiceCustomCommands.RestartWorker);

            }

            finally

            {

                timer.Enabled = true;

            }

        }

    }

    public class test

    {

        public static void processTest(object state )

        {

            System.Diagnostics.Debug.WriteLine($"{state}");

        }

    }

}