MARKUS

using Markus.EntityModel;

using Markus.Service;

using Markus.Service.Extensions;

using Markus.Service.Helper;

using Microsoft.Win32;

using Newtonsoft.Json;

using Newtonsoft.Json.Linq;

using System;

using System.Collections.Generic;

using System.Diagnostics;

using System.IO;

using System.Linq;

using System.Net;

using System.Net.Http;

using System.ServiceModel;

using System.Text;

using System.Threading.Tasks;

using System.Web;

using System.Web.Script.Serialization;

using System.Windows;

using System.Windows.Data;

using System.Windows.Forms;

using static Markus.Service.Extensions.Encrypt;

namespace ServiceTestApp

{

    /// <summary>

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

    /// </summary>

    public partial class MainWindow : Window

    {

        public MainWindow()

        {

            InitializeComponent();

            var config = Markus.Service.Helper.ConfigHelper.AppConfig("ServiceStation.ini");

            MarkusDBConnectionString = AESEncrypter.Decrypt(config.GetValue(CONFIG_DEFINE.SERVICE, CONFIG_DEFINE.MARKUS_CONNECTION_STRING));

            datagrid.ItemsSource = convertItems;

            timer.Interval = new TimeSpan(0, 0, 0, 0, 700);

            timer.Tick += Timer_Tick;

            //timer.Start();

        }

        System.Windows.Threading.DispatcherTimer timer = new System.Windows.Threading.DispatcherTimer();

        private string MarkusDBConnectionString;

        private void Timer_0_Tick(object sender, EventArgs e)

        {

            BasicHttpBinding myBinding = new BasicHttpBinding();

            EndpointAddress myEndpoint = new EndpointAddress(UriHelper.UriCreate("http://localhost:9101/StationService"));

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

            var result =  client.AliveConvertList();

            datagrid.ItemsSource = result;

            if(result.Count() < 2)

            {

                foreach (var filename in Directory.EnumerateFiles("D:\\Case"))

                {

                    var additem = client.ConvertMenualAdd("111111",  filename, "test");

                    if (!string.IsNullOrWhiteSpace(additem))

                    {

                        Log.Text += $"Wcf Station Service call{filename} {result}\n";

                    }

                    else

                    {

                        Log.Text += $"Call Error {filename} {result}\n";

                    }

                }

            }

        }

        private void Timer_Tick(object sender, EventArgs e)

        {

            timer.Stop();

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

            {

                var data = database.GetConvertItems(Markus.Message.StatusCodeType.Saving);

                foreach (var item in data)

                {

                    var getitem = convertItems.Where(f => f.ConvertID == item.ConvertID);

                    if (getitem.Count() == 0)

                    {

                        convertItems.Add(item);

                    }

                    else

                    {

                        var binditem = getitem.First();

                        binditem.ConvertState = item.ConvertState;

                        binditem.CurrentPageNo = item.CurrentPageNo;

                        binditem.TotalPage = item.TotalPage;

                    }

                }

                var _removeitems = convertItems.Select(f => f.ConvertID).Except(data.Select(x => x.ConvertID)).ToList();

                foreach (var item in _removeitems)

                {

                    var items = convertItems.Where(x => x.ConvertID == item);

                    if (items.Count() > 0)

                    {

                        Markus.Service.Interface.ConvertItem convertItem = items.First();

                        convertItems.Remove(convertItem);

                    }

                }

            }

            var process = Process.GetProcessesByName("Markus.Service.ConvertProcess");

            this.Dispatcher.Invoke(() =>

            {

                CollectionViewSource.GetDefaultView(datagrid.ItemsSource).Refresh();

                if (process.Count() > 0)

                {

                    if (Log.Text.Length > int.MaxValue)

                    {

                        Log.Text = "";

                    }

                    Log.Text += "-------------------------------------\n";

                    Log.Text += $"  Physical memory usage     : {process.Sum(f => f.WorkingSet64)}" + "\n";

                    Log.Text += $"  Base priority             : {process.Sum(f => f.BasePriority)}" + "\n";

                    //Log.Text += $"  Priority class            : {process[0].PriorityClass}" + "\n";

                    //Log.Text += $"  User processor time       : {process[0].UserProcessorTime}" + "\n";

                    //Log.Text += $"  Privileged processor time : {process[0].PrivilegedProcessorTime}" + "\n";

                    //Log.Text += $"  Total processor time      : {process[0].TotalProcessorTime}" + "\n";

                    Log.Text += $"  Paged system memory size  : {process.Sum(f => f.PagedSystemMemorySize64)}" + "\n";

                    Log.Text += $"  Paged memory size         : {process.Sum(f => f.PagedMemorySize64)}" + "\n";

                }

            });

            //if (process.Count() < 3)

            //{

            //    BasicHttpBinding myBinding = new BasicHttpBinding();

            //    EndpointAddress myEndpoint = new EndpointAddress(UriHelper.UriCreate("http://localhost:9101/StationService"));

            //    StationService.StationServiceClient client = new StationService.StationServiceClient(myBinding, myEndpoint);

            //    foreach (var filename in Directory.EnumerateFiles("D:\\Case"))

            //    {

            //        var _id = new Guid().CreateUniqueGuid().ToString();

            //        var result = client.ConvertMenualAdd("111111", _id, filename, "test");

            //        if (result)

            //        {

            //            Log.Text += $"Wcf Station Service call{filename} {result}\n";

            //        }

            //        else

            //        {

            //            Log.Text += $"Call Error {filename} {result}\n";

            //        }

            //    }

            //}

            timer.Start();

        }

        private System.Collections.ObjectModel.ObservableCollection<Markus.Service.Interface.ConvertItem> convertItems = new System.Collections.ObjectModel.ObservableCollection<Markus.Service.Interface.ConvertItem>();

        private Object stationObj;

        Markus.Service.ServiceStation station = new Markus.Service.ServiceStation();

        private void Button_Click(object sender, RoutedEventArgs e)

        {

            station.StartService();

            // if (station == null)

            // {

            //     station = new PrivateObject(typeof(Markus.Service.StationService.ServiceStation));

            // }

            Log.Text += "Wcf Service start\n";

        }

        private async void ServiceCall_Click(object sender, RoutedEventArgs e)

        {

            ConvertService.ConvertServiceClient client = new ConvertService.ConvertServiceClient();

            var result = await client.ConvertAddAsync(1);

            Log.Text += $"Wcf Convert Service call{result}\n";

        }

        private async void StationServiceCall_Click(object sender, RoutedEventArgs e)

        {

            StationService.StationServiceClient client = new StationService.StationServiceClient();

            var result = await client.ConvertAddAsync("test", "11");

            Log.Text += $"Wcf Station Service call{result}\n";

        }

        private async void ItemAdd_Click(object sender, RoutedEventArgs e)

        {

            string ProjectNo = "111111";

            BasicHttpBinding myBinding = new BasicHttpBinding();

            EndpointAddress myEndpoint = new EndpointAddress(UriHelper.UriCreate("http://localhost:9101/StationService"));

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

            foreach (var filename in GetFileList())

            {

                var result = await client.ConvertMenualAddAsync("111111", filename, "test");

                if (!string.IsNullOrWhiteSpace(result))

                {

                    Log.Text += $"Wcf Station Service call{filename} convert ID : {result}\n";

                }

                else

                {

                    Log.Text += $"Call Error {filename}\n";

                }

            }

            #region 데이터베이스 테스트 

            /*

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

            {

                foreach (var filename in GetFileList())

                {

                    var _id = new Guid().CreateUniqueGuid().ToString();

                    if (!database.SetConvertDoc(ProjectNo, _id, filename,_id))

                    {

                        System.Windows.MessageBox.Show("저장에 실패!");

                        break;

                    }

                }

            }

            */

            #endregion

        }

        private IEnumerable<string> GetFileList()

        {

            IEnumerable<string> result = new string[] { };

            using (FolderBrowserDialog dialog = new FolderBrowserDialog())

            {

                dialog.Description = "PDF가 있는 폴더를 선택하세요.";

                dialog.ShowNewFolderButton = false;

                dialog.RootFolder = Environment.SpecialFolder.MyComputer;

                if (dialog.ShowDialog() == System.Windows.Forms.DialogResult.OK)

                {

                    result = Directory.EnumerateFiles(dialog.SelectedPath, "*.pdf", SearchOption.AllDirectories);

                }

            }

            return result;

        }

        private void ServiceInstall_Click(object sender, RoutedEventArgs e)

        {

            //Markus.Service.ProjectInstaller projectInstaller = new Markus.Service.ProjectInstaller();

            //Hashtable savedState = new Hashtable();

            //projectInstaller.serviceProcessInstaller.Install(savedState);

            //projectInstaller.serviceProcessInstaller.Uninstall(savedState);

            IntegratedServiceInstaller integrated = new IntegratedServiceInstaller();

            integrated.Install("ServiceStation", "ServiceStation", "test", System.ServiceProcess.ServiceAccount.LocalService, System.ServiceProcess.ServiceStartMode.Automatic);

        }

        private void LibInstall_Click(object sender, RoutedEventArgs e)

        {

            Markus.Library.Installer.Install();

        }

        private async void ItemAddFile_Click(object sender, RoutedEventArgs e)

        {

            System.Windows.Forms.OpenFileDialog dialog = new System.Windows.Forms.OpenFileDialog();

            if (dialog.ShowDialog() == System.Windows.Forms.DialogResult.OK)

            {

                BasicHttpBinding myBinding = new BasicHttpBinding();

                EndpointAddress myEndpoint = new EndpointAddress(UriHelper.UriCreate("http://localhost:9101/StationService"));

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

                var result = await client.ConvertMenualAddAsync("111111", dialog.FileName, "test");

                Log.Text += $"Wcf Station Service call{dialog.FileName} {result}\n";

            }

        }

        private async void AliveList_Click(object sender, RoutedEventArgs e)

        {

            await AliveItemAsync();

        }

        private async Task AliveItemAsync()

        {

            BasicHttpBinding myBinding = new BasicHttpBinding();

            EndpointAddress myEndpoint = new EndpointAddress(UriHelper.UriCreate("http://localhost:9101/StationService"));

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

            var _id = new Guid().CreateUniqueGuid().ToString();

            var result = await client.AliveConvertListAsync();

            datagrid.ItemsSource = result;

        }

        private async void WaitList_Click(object sender, RoutedEventArgs e)

        {

            BasicHttpBinding myBinding = new BasicHttpBinding();

            EndpointAddress myEndpoint = new EndpointAddress(UriHelper.UriCreate("http://localhost:9101/StationService"));

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

            var _id = new Guid().CreateUniqueGuid().ToString();

            var result = await client.WaitConvertListAsync();

            datagrid.ItemsSource = result;

        }

        private void ProcessKill_Click(object sender, RoutedEventArgs e)

        {

            station.Stopprocess();

        }

        private void DeadLockProcessList_Click(object sender, RoutedEventArgs e)

        {

            station.DeadLockProcessKill();

        }

        private async void Button_Click_1(object sender, RoutedEventArgs e)

        {

            int count = 0;

            if(int.TryParse(txtProcessCount.Text,out count))

            {

            BasicHttpBinding myBinding = new BasicHttpBinding();

            EndpointAddress myEndpoint = new EndpointAddress(UriHelper.UriCreate("http://localhost:9101/StationService"));

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

            var result = await client.SettingMultiProcessAsync(count);

            }

        }

        private async void RemoteFileList_Click(object sender, RoutedEventArgs e)

        {

            var uriList = new[]

            {

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000053/250page.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000038/250page.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000027/BigSize.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000032/BigSize.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000087/1-5110-ZJ-492-005_C.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000070/VP-TEST-MARKUS-040.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000051/250page.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000039/250page.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000022/BigSize.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000023/BigSize.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000049/250page.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000050/250page.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000050/250page.pdf",

                "http://www.devdoftech.co.kr:5100/Doc_Manager/000000_app/VPCS_DOCLIB/40000036/250page.pdf"

            };

            BasicHttpBinding myBinding = new BasicHttpBinding();

            EndpointAddress myEndpoint = new EndpointAddress(UriHelper.UriCreate("http://localhost:9101/StationService"));

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

            foreach (var item in uriList)

            {

                var result = await client.ConvertMenualAddAsync("111111", item, "test");

                Log.Text += $"Wcf Station Service call{item} {result}\n";

            }

        }

        private void Button_Click_2(object sender, RoutedEventArgs e)

        {

            var pageinfoList = new Markus.Message.PageInfo[]

            {

                new Markus.Message.PageInfo

                {

                    Width = 111,

                    Height = 111,

                    PageNo = 1,

                },

                new Markus.Message.PageInfo

                {

                    Width = 111,

                    Height = 111,

                    PageNo = 2,

                }

            };

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

            {

                List<DOCPAGE> docPageList = new List<DOCPAGE>();

                docPageList = pageinfoList.Select(f => new DOCPAGE

                {

                    ID = GuidExtension.shortGuid(),

                    PAGE_WIDTH = f.Width.ToString(),

                    PAGE_HEIGHT = f.Height.ToString(),

                    PAGE_NUMBER = f.PageNo

                }).ToList();

                database.SetDocumentInfo("1df16d9a-1ea9-9a32-8a61-aad6ce4a2a49", 2, docPageList);

            }

        }

        private void wcfTest_Click(object sender, RoutedEventArgs e)

        {

            station.GetApplicationConfig();

            station.StartWcfService();

        }

        private static readonly HttpClient _Client = new HttpClient();

        private static JavaScriptSerializer _Serializer = new JavaScriptSerializer();

        private async void WebServiceTest_click(object sender, RoutedEventArgs e)

        {

            //string cookie = "";

            //var  uri = new Uri("http://localhost:9101/StationService/Rest/GetConvertItem"); // string 을 Uri 로 형변환

            //var wReq = (System.Net.HttpWebRequest)System.Net.WebRequest.Create(uri); // WebRequest 객체 형성 및 HttpWebRequest 로 형변환

            //wReq.Method = "POST"; // 전송 방법 "GET" or "POST"

            //wReq.ContentType = "application/x-www-form-urlencoded; charset=UTF-8";

            //wReq.Proxy = new System.Net.WebProxy("127.0.0.1", 8888);

            ////wReq.ServicePoint.Expect100Continue = false;

            ////wReq.CookieContainer = new System.Net.CookieContainer();

            ////wReq.CookieContainer.SetCookies(uri, cookie); // 넘겨줄 쿠키가 있을때 CookiContainer 에 저장

            ////POST 전송일 경우

            //string url = "http://localhost:9101/StationService/Rest/GetConvertItem";

            //var data = new SEND

            //{

            //    ProjectNo = "111111",

            //    DocumentID = "453"

            //};

            //var json = _Serializer.Serialize(data);

            //var response2 = await Request(HttpMethod.Post, url, json, new Dictionary<string, string>());

            //string responseText = await response2.Content.ReadAsStringAsync();

            //Console.WriteLine(responseText);

            using (var client = new System.Net.Http.HttpClient())

            {

                var uri2 = new Uri("http://localhost:9101/StationService/Rest/GetConvertItem");

                var data2 = new SEND

                {

                    ProjectNo = "111111",

                    DocumentID = "453"

                };

                var jsonRequest2 = JsonConvert.SerializeObject(data2);

                var stringContent = new System.Net.Http.StringContent(jsonRequest2, Encoding.UTF8, "application/json");

                var response = await client.PostAsync(uri2, stringContent);

                if (response.IsSuccessStatusCode)

                {

                    System.Diagnostics.Debug.WriteLine(response.Content.Headers.First());

                    System.Diagnostics.Debug.WriteLine(await response.Content.ReadAsStringAsync());

                }

            }

            //using (var client = new System.Net.Http.HttpClient())

            //{

            //    var uri2 = new Uri("http://localhost:13009/MarkusService.svc/Rest/GetCommantList");

            //    var data2 = new SEND

            //    {

            //        ProjectNo = "111111",

            //        DocumentID = "453"

            //    };

            //    var jsonRequest2 = JsonConvert.SerializeObject(data2);

            //    var stringContent = new System.Net.Http.StringContent(jsonRequest2, Encoding.UTF8, "application/json");

            //    var response = await client.PostAsync(uri2, stringContent);

            //    if (response.IsSuccessStatusCode)

            //    {

            //        System.Diagnostics.Debug.WriteLine(response.Content.Headers.First());

            //        System.Diagnostics.Debug.WriteLine(await response.Content.ReadAsStringAsync());

            //    }

            //}

            //var client2 = new System.Net.WebClient();

            //client2.Proxy = new System.Net.WebProxy("127.0.0.1", 8888);

            //var result = await client2.DownloadStringTaskAsync("http://localhost:9101/StationService/Rest/GetConvertItem?ProjectNo=111111&DocumentID=453");

            //System.Diagnostics.Debug.WriteLine(result);

        }

        static async Task<System.Net.Http.HttpResponseMessage> Request(HttpMethod pMethod, string pUrl, string pJsonContent, Dictionary<string, string> pHeaders)

        {

            var httpRequestMessage = new HttpRequestMessage();

            httpRequestMessage.Method = pMethod;

            httpRequestMessage.RequestUri = new Uri(pUrl);

            foreach (var head in pHeaders)

            {

                httpRequestMessage.Headers.Add(head.Key, head.Value);

            }

            switch (pMethod.Method)

            {

                case "POST":

                    HttpContent httpContent = new StringContent(pJsonContent, Encoding.UTF8, "application/json");

                    httpRequestMessage.Content = httpContent;

                    break;

            }

            return await new HttpClient().SendAsync(httpRequestMessage);

        }

        private async void ConvertWebServiceTest_click(object sender, RoutedEventArgs e)

        {

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

            {

                var items = database.GetConvertItems(Markus.Message.StatusCodeType.Completed).Take(100).ToList();

                var service = new ConvertWebService.ConversionSoapClient();

                int count = 0;

                foreach (var item in items)

                {

                    count++;

                    byte[] bytes = Encoding.UTF8.GetBytes(item.OriginfilePath);

                    var url = Convert.ToBase64String(bytes);

                    var result = await service.ConvertRunAsync(count.ToString(), item.UniqueKey, item.UniqueKey + count.ToString(), count.ToString(), "111111", item.UniqueKey, url);

                    System.Diagnostics.Debug.WriteLine(item.ConvertID + " " + result.ToString());

                }

            }

        }

        private async void DownLoadTest_click(object sender, RoutedEventArgs e)

        {

            await DownloadFileAsync("http://172.20.110.75:8880/ifweb/external/DLMFileDownload.jsp?objectId=33808.61925.45058.48300&format=Original PDF&fileName=MARKUS_20190731_0001_A.pdf");

        }

        private async Task<bool> DownloadFileAsync(string FileaPath)

        {

            bool result = false;

            try

            {

                Uri pdfFileUri = null;

                //if (saveItem.PdfFilePath.Contains("VPCS_DOCLIB"))

                //{

                //    FileName = DocUri.Remove(0, DocUri.LastIndexOf("/") + 1);

                //    ProjectFolderPath = DownloadDir_PDF + "\\" + ConverterItem.PROJECT_NO + "_Tile"; //프로젝트 폴더

                //    ItemListPath = ProjectFolderPath + "\\" + (System.Convert.ToInt64(ConverterItem.DOCUMENT_ID) / 100).ToString();

                //    ItemPath = ItemListPath + "\\" + ConverterItem.DOCUMENT_ID;

                //    DownloadFilePath = ItemPath + "\\" + FileName;

                //}

                //else

                //{

                //    ProjectFolderPath = DownloadDir_PDF + "\\" + ConverterItem.PROJECT_NO + "_Tile"; //프로젝트 폴더

                //    ItemListPath = ProjectFolderPath + "\\" + (System.Convert.ToInt64(ConverterItem.DOCUMENT_ID) / 100).ToString();

                //    ItemPath = ItemListPath + "\\" + ConverterItem.DOCUMENT_ID;

                //    FileName = HttpUtility.ParseQueryString(new Uri(DocUri).Query).Get("fileName");

                //    DownloadFilePath = string.IsNullOrWhiteSpace(FileName) ? ItemPath + "\\" + FileName : ItemPath + "\\" + FileName;

                //}

                FileaPath = HttpUtility.UrlDecode(FileaPath); //PDF 전체 경로

                string FileName = DownloadUri.GetFileName(FileaPath);

                string downloadFilePath = System.IO.Path.Combine(@"c:\temp", FileName);

                // 드라이브 경로가 포함되었는지 판단.

                if (Path.IsPathRooted(FileaPath))

                {

                    if (File.Exists(FileaPath))

                    {

                        File.Copy(FileaPath, downloadFilePath, true);

                    }

                    else

                    {

                        throw new Exception("File Not Found. Please, check the file path.");

                    }

                }

                else if (Uri.TryCreate(FileaPath, UriKind.RelativeOrAbsolute, out pdfFileUri))

                {

                    try

                    {

                        using (System.Net.WebClient webClient = new System.Net.WebClient())

                        {

                            webClient.UseDefaultCredentials = true;//.Headers.Add("Authorization: BASIC SGVsbG8="); //가상의 인증

                            //if (!System.IO.Directory.Exists(ConvertProcessContext.TempDirectory))

                            //{

                            //    System.IO.Directory.CreateDirectory(ConvertProcessContext.TempDirectory);

                            //}

                            await webClient.DownloadFileTaskAsync(pdfFileUri, downloadFilePath);

                        }

                    }

                    catch (Exception)

                    {

                        throw new Exception("File Download Error. Please, check the file path.");

                    }

                }

                else

                {

                    throw new Exception("Please, check the file path.");

                }

                if (File.Exists(downloadFilePath))

                {

                    var file = File.Open(downloadFilePath, FileMode.Open);

                    if (file.Length == 0)

                    {

                        throw new Exception("File Size 0. Please, check the file path.");

                    }

                    file.Close();

                    file.Dispose();

                    FileaPath = downloadFilePath;

                    result = true;

                }

            }

            catch (Exception EX)

            {

                System.Diagnostics.Debug.WriteLine(EX.ToString());

                result = false;

            }

            return result;

        }

        private void ServiceCallTest_click(object sender, RoutedEventArgs e)

        {

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

            {

                var items = database.GetConvertItems(Markus.Message.StatusCodeType.Completed).Take(100).ToList();

                int count = 0;

                foreach (var item in items)

                {

                    database.SetCleanUpItem(item.ConvertID, 0);

                    System.Net.WebClient client = new System.Net.WebClient();

                    var convertResult = client.DownloadString($"http://192.168.0.129:9101/StationService/Rest/ConvertAdd?ProjectNo={item.ProjectNumber}&DocumentID={item.ConvertID}");

                    JObject jObject = JObject.Parse(convertResult, new JsonLoadSettings());

                    var result = jObject["ConvertAddResult"].ToString();

                    System.Diagnostics.Debug.WriteLine(item.ConvertID + " " + result.ToString());

                }

            }

        }

        private void ConfingSectionTest_click(object sender, RoutedEventArgs e)

        {

            var config = Markus.Service.Helper.ConfigHelper.AppConfig("Plugin.ini");

            Dictionary<string, object> parameters = new Dictionary<string, object>();

            var sections = config.Sections.Where(x => x.SectionName == "PemssDocumentInfo").FirstOrDefault();

            foreach (var item in sections.Keys)

            {

                parameters.Add(item.Name,item.Content);

            }

        }

        private void PemssPluginTest_click(object sender, RoutedEventArgs e)

        {

        }

        private void MonitorTest_Click(object sender, RoutedEventArgs e)

        {

            Markus.Service.MonitorService.ServiceMonitor service = new Markus.Service.MonitorService.ServiceMonitor();

            service.Start(null);

        }

        private async void FileDownloadTest_Click(object sender, RoutedEventArgs e)

        {

            try

            {

                if (!string.IsNullOrWhiteSpace(txtEncodeDownloadFile.Text))

                {

                    txtDecodeDownloadFile.Text = HttpUtility.UrlDecode(txtEncodeDownloadFile.Text,Encoding.UTF8);

                }

                if(!string.IsNullOrWhiteSpace(txtDecodeDownloadFile.Text))

                {

                    txtEncodeDownloadFile.Text = HttpUtility.UrlEncode(txtDecodeDownloadFile.Text,Encoding.UTF8);

                }

                string File = txtDecodeDownloadFile.Text;

                DownloadCurrent(File);

                string Savepath = txtSavePath.Text;

                //if (!System.IO.Directory.Exists(Savepath))

                //{

                //    System.IO.Directory.CreateDirectory(Savepath);

                //}

                //Markus.Service.Convert.ConvertService convertService = new Markus.Service.Convert.ConvertService();

                //var result = await convertService.DownloadFileAsync(new Markus.Message.SaveItem { PdfFilePath = File, SavePath = Savepath });

               // System.Windows.MessageBox.Show(result.ToString());

            }

            catch (Exception ex)

            {

                System.Windows.MessageBox.Show(ex.ToString());

            }

        }

        private  void DownloadCurrent(string fileUri)

        {

            HttpWebRequest webRequest = (HttpWebRequest)WebRequest.Create(fileUri);

            webRequest.Method = "GET";

            webRequest.Timeout = 3000;

            webRequest.Credentials = CredentialCache.DefaultCredentials;

            webRequest.BeginGetResponse(new AsyncCallback(PlayResponeAsync), webRequest);

        }

        private void PlayResponeAsync(IAsyncResult asyncResult)

        {

            long total = 0;

            long received = 0;

            HttpWebRequest webRequest = (HttpWebRequest)asyncResult.AsyncState;

            try

            {

                using (HttpWebResponse webResponse = (HttpWebResponse)webRequest.EndGetResponse(asyncResult))

                {

                    byte[] buffer = new byte[1024];

                    FileStream fileStream = File.OpenWrite(@"D:\Case\test.pdf");

                    using (Stream input = webResponse.GetResponseStream())

                    {

                        total = input.Length;

                        int size = input.Read(buffer, 0, buffer.Length);

                        while (size > 0)

                        {

                            fileStream.Write(buffer, 0, size);

                            received += size;

                            size = input.Read(buffer, 0, buffer.Length);

                        }

                    }

                    fileStream.Flush();

                    fileStream.Close();

                }

            }

            catch (Exception ex)

            {

            }

        }

        private  string ToHexString(char chr)

        {

            UTF8Encoding utf8 = new UTF8Encoding();

            byte[] encodedBytes = utf8.GetBytes(chr.ToString());

            StringBuilder builder = new StringBuilder();

            for (int index = 0; index < encodedBytes.Length; index++)

            {

                builder.AppendFormat("%{0}", Convert.ToString(encodedBytes[index], 16));

            }

            return builder.ToString();

        }

    }

    class IntegratedServiceInstaller

    {

        public void Install(String ServiceName, String DisplayName, String Description,

            System.ServiceProcess.ServiceAccount Account,

            System.ServiceProcess.ServiceStartMode StartMode)

        {

            System.ServiceProcess.ServiceProcessInstaller ProcessInstaller = new System.ServiceProcess.ServiceProcessInstaller();

            ProcessInstaller.Account = Account;

            System.ServiceProcess.ServiceInstaller SINST = new System.ServiceProcess.ServiceInstaller();

            System.Configuration.Install.InstallContext Context = new System.Configuration.Install.InstallContext();

            string processPath = Process.GetCurrentProcess().MainModule.FileName;

            if (processPath != null && processPath.Length > 0)

            {

                System.IO.FileInfo fi = new System.IO.FileInfo(processPath);

                //Context = new System.Configuration.Install.InstallContext();

                //Context.Parameters.Add("assemblyPath", fi.FullName);

                //Context.Parameters.Add("startParameters", "Test");

                String path = String.Format("/assemblypath={0}", fi.FullName);

                String[] cmdline = { path };

                Context = new System.Configuration.Install.InstallContext("", cmdline);

            }

            SINST.Context = Context;

            SINST.DisplayName = DisplayName;

            SINST.Description = Description;

            SINST.ServiceName = ServiceName;

            SINST.StartType = StartMode;

            SINST.Parent = ProcessInstaller;

            // http://bytes.com/forum/thread527221.html

            //            SINST.ServicesDependedOn = new String[] {};

            System.Collections.Specialized.ListDictionary state = new System.Collections.Specialized.ListDictionary();

            SINST.Install(state);

            // http://www.dotnet247.com/247reference/msgs/43/219565.aspx

            using (RegistryKey oKey = Registry.LocalMachine.OpenSubKey(String.Format(@"SYSTEM\CurrentControlSet\Services\{0}", SINST.ServiceName), true))

            {

                try

                {

                    Object sValue = oKey.GetValue("ImagePath");

                    oKey.SetValue("ImagePath", sValue);

                }

                catch (Exception Ex)

                {

                    //                    System.Console.WriteLine(Ex.Message);

                }

            }

        }

        public void Uninstall(String ServiceName)

        {

            System.ServiceProcess.ServiceInstaller SINST = new System.ServiceProcess.ServiceInstaller();

            System.Configuration.Install.InstallContext Context = new System.Configuration.Install.InstallContext("c:\\install.log", null);

            SINST.Context = Context;

            SINST.ServiceName = ServiceName;

            SINST.Uninstall(null);

        }

    }

    public class SEND

    {

        public string ProjectNo { get; set; }

        public string DocumentID{ get; set; }

}

}