MARKUS

using IIpc;

using System;

using System.Collections.Generic;

using System.Diagnostics;

using System.IO;

using System.Linq;

using System.ServiceModel;

using System.Text;

using System.Threading.Tasks;

namespace DownloadManagerTest

{

    class Program

    {

       static  MarkusService.ServiceDeepViewClient Client;

        static void Main(string[] args)

        {

            string downloadmanagerPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory,"Plugin","DownloadManager.exe");

            if (!File.Exists(downloadmanagerPath))

            {

                Console.WriteLine("DownloadManager.exe Not Found");

            }

            else

            {

               var sBaseServiceURL = CommonLib.Common.GetConfigString("BaseClientAddress", "URL", "", false);

                var _EndPoint = new EndpointAddress(string.Format("{0}/ServiceDeepView.svc", sBaseServiceURL));

                Client = new MarkusService.ServiceDeepViewClient(GetBinding(), _EndPoint);

                Console.WriteLine("Connection Service :" + _EndPoint.Uri);

                string _projectNo = null;

                string _documentId = null;

                int _testLoop = 1;

                projectIn:

                Console.Write("Input Project No : ");

                _projectNo = Console.ReadLine();

                if(string.IsNullOrWhiteSpace(_projectNo))

                {

                    goto projectIn;

                }

                DocumentIDIn:

                Console.Write("Input Document Id : ");

                _documentId = Console.ReadLine();

                if (string.IsNullOrWhiteSpace(_documentId))

                {

                    goto DocumentIDIn;

                }

                Console.Write("Test Loop Count(default 1) : ");

                var strLoop = Console.ReadLine();

                int.TryParse(strLoop, out _testLoop);

                var items = Client.GetDocInfo(new MarkusService.KCOM_BasicParam { projectNo = _projectNo, documentID = _documentId });

                if (items != null)

                {

                    #region Page Storage Test 

                    string tempStoragePath = System.IO.Path.Combine(System.IO.Path.GetTempPath(), "MARKUS", System.IO.Path.GetRandomFileName());

                    Directory.CreateDirectory(tempStoragePath);

                    OpenFolder(tempStoragePath);

                    string sFolder = _documentId.All(char.IsDigit) ? (Convert.ToUInt32(_documentId) / 100).ToString() : (_documentId.Length >= 5 ? _documentId.Substring(0, 5) : _documentId);

                    var MainUrl = string.Format(CommonLib.Common.GetConfigString("mainServerImageWebPath", "URL", "", false).Replace("png", "jpg"), _projectNo, sFolder, _documentId, "{PageNo}");

                    KCOM.PageManager.PageStorage PageStorage = new KCOM.PageManager.PageStorage(MainUrl.Replace("jpg", "png"), tempStoragePath, "png", items.PAGE_COUNT);

                    Random rd = new Random();

                    for (int j = 0; j < _testLoop; j++)

                    {

                        List<int> getPageList = Enumerable.Range(1, items.PAGE_COUNT).ToList<int>();

                        for (int i = 0; i < items.PAGE_COUNT; i++)

                        {

                            int rdIndex = rd.Next(0, getPageList.Count);

                            var pageNo = getPageList[rdIndex];

                            var getPage = PageStorage.GetPageUriAsync(null, pageNo).ConfigureAwait(false);

                            getPageList.RemoveAt(rdIndex);

                            Console.WriteLine(getPage.GetAwaiter().GetResult());

                        }

                    }

                    Console.WriteLine("Page Storage Test OK.");

                    #endregion

                    #region DownloadManager Test

                    string endpoint = KCOM.Common.Commons.shortGuid() + "Thumbnail";

                    IIpc.WcfServer wcfServer = new IIpc.WcfServer(endpoint);

                    wcfServer.IpcThumbnailReceived += WcfServer_IpcThumbnailReceived;

                    wcfServer.Start();

                    KCOM.DownloadProcess.ThumbnailDownloader(endpoint,true, MainUrl, tempStoragePath, "jpg", items.PAGE_COUNT);

                    #endregion

                }

                else

                {

                    Console.WriteLine("Item null");

                }

            }

            Console.ReadKey();

        }

        private static void WcfServer_IpcThumbnailReceived(object sender, IpcThumbnailEventArgs e)

        {

            Console.WriteLine("Thumbnail : " +  new Uri(e.Path, UriKind.Absolute).ToString());

        }

        private static void OpenFolder(string folder)

        {

            Process.Start("explorer.exe", folder);

        }

        private static BasicHttpBinding GetBinding()

        {

            var _binding = new BasicHttpBinding(BasicHttpSecurityMode.TransportCredentialOnly);

            _binding.MaxBufferSize = 2147483647;

            _binding.MaxReceivedMessageSize = 2147483647;

            _binding.OpenTimeout = new TimeSpan(0, 1, 0);

            _binding.ReceiveTimeout = new TimeSpan(0, 10, 0);

            _binding.CloseTimeout = new TimeSpan(0, 5, 0);

            _binding.SendTimeout = new TimeSpan(0, 5, 0);

            _binding.TextEncoding = System.Text.Encoding.UTF8;

            _binding.TransferMode = TransferMode.Buffered;

            return _binding;

        }

    }

}