MARKUS

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using System.Runtime.Remoting.Channels.Tcp;

using System.Runtime.Remoting.Channels;

using System.Runtime.Remoting;

using IConverterPDF;

using DeepViewDataModel.DataModel;

using System.Threading;

using System.IO;

using DZConverterLib.Auth;

using System.Threading.Tasks;

using System.Net.Cache;

using System.Net;

using DeepViewDataModel.Common;

namespace RemotingTest

{

    public partial class Form1 : Form, InterfaceConverterPDF

    {

        public Form1()

        {

            InitializeComponent();

        }

        TcpChannel channel = null;

        List<ConverterPDF> _thread = new List<ConverterPDF>();

        private Thread _ConverterPdfThread = null;

        private Queue<ConverterPDF> _WorkItems = new Queue<ConverterPDF>();

        private void Form1_Load(object sender, EventArgs e)

        {

        }

        public ConverterPDFResult Notify(string ProjectNo, Guid ConverterID)

        {

            _WorkItems.Enqueue(new ConverterPDF { ID = Guid.NewGuid() });

            if (_ConverterPdfThread == null)

            {

                _ConverterPdfThread = new Thread(new ThreadStart(ConverterPDFProcess));

                _ConverterPdfThread.SetApartmentState(ApartmentState.MTA);

                _ConverterPdfThread.Start();

            }

            return new ConverterPDFResult();

        }

        public void ConverterPDFProcess()

        {

            while (_WorkItems.Count() > 0)

            {

                if (_thread.Count() > 10)

                {

                }

                else

                {

                }

            }

        }

        public int MultiProcessCount()

        {

            return Properties.Settings.Default.MultipleConverterCount;

        }

        public Guid[] RunningProcessID()

        {

            return _WorkItems.Select(t=>t.ID).ToArray();

        }

        private void button1_Click(object sender, EventArgs e)

        {

            Client();

            var _id = remObj[0].RunningProcessID();

            _id.ToList().ForEach(f=> System.Diagnostics.Debug.WriteLine(f.ToString()));

            var _info = remObj[0].ServiceInfomation();

            if (_info.Exception == null)

            {

                var _space = (_info.StorageInfo.First().FreeSpace / 1024f) / 1024f / 1024f;

                MessageBox.Show("여유공간 : " + _space + "GB");

            }

            else

            {

                System.Diagnostics.Debug.WriteLine(_info.Exception);

            }

            //Thread _send = new Thread(new ThreadStart(SendTest));

            //_send.SetApartmentState(ApartmentState.MTA);

            //_send.Start();

        }

        private void SendTest()

        {

            while (true)

            {

                for (int i = 0; i < remObj.Count; i++)

                {

                    var _id = remObj[i].RunningProcessID();

                    System.Diagnostics.Debug.WriteLine(_id.First());

                    Thread.Sleep(10);    

                }

            }

        }

        List<RemConverterPDFObject> remObj = null;

        public void Client()

        {

            try

            {

                //for (int i = 0; i < 10; i++)

                //{

                    System.Runtime.Remoting.Channels.IChannel _ch = ChannelServices.GetChannel("tcp");

                    if (_ch == null)

                    {

                        TcpChannel chan = new TcpChannel();

                        ChannelServices.RegisterChannel(chan, false);

                    }

                    // Create an instance of the remote object

                    RemConverterPDFObject rem2 = (RemConverterPDFObject)Activator.GetObject(typeof(RemConverterPDFObject),

                                                                    "tcp://172.20.120.180:8090/remConverterPDF");

                    if (remObj == null)

                        remObj = new List<RemConverterPDFObject>();

                    else

                        remObj.Clear();

                    remObj.Add(rem2);

                //}

            }

            catch (Exception ex)

            {

            }

        }

        public void Client1()

        {

            try

            {

                //for (int i = 0; i < 10; i++)

                //{

                System.Runtime.Remoting.Channels.IChannel _ch = ChannelServices.GetChannel("tcp");

                if (_ch == null)

                {

                    TcpChannel chan = new TcpChannel();

                    ChannelServices.RegisterChannel(chan, false);

                }

                // Create an instance of the remote object

                RemConverterPDFObject rem = (RemConverterPDFObject)Activator.GetObject(typeof(RemConverterPDFObject),

                                                            "tcp://172.20.100.72:8090/remConverterPDF");

                if (remObj == null)

                    remObj = new List<RemConverterPDFObject>();

                else

                    remObj.Clear();

                remObj.Add(rem);

                //}

            }

            catch (Exception ex)

            {

            }

        }

        private void button2_Click(object sender, EventArgs e)

        {

            try

            {

                int _RemotingPort = Properties.Settings.Default.RemotingPort;

                channel = new TcpChannel(_RemotingPort);

                ChannelServices.RegisterChannel(channel, false);

                RemotingConfiguration.RegisterWellKnownServiceType(typeof(RemConverterPDFObject),

                                                                    "remConverterPDF", WellKnownObjectMode.Singleton);

                if(channel.ChannelData != null)

                    if (channel.ChannelData.GetType() == typeof(ChannelDataStore))

                    {

                        var _url = (channel.ChannelData as ChannelDataStore).ChannelUris;

                        foreach (var item in _url)

                        {

                            UriBuilder bl = new UriBuilder(item);

                            if (bl.Scheme == Uri.UriSchemeNetTcp)

                            {

                                System.Diagnostics.Debug.WriteLine("uri Scheme : " + Uri.UriSchemeNetTcp);

                            }

                            string _Host = bl.Host;

                            System.Diagnostics.Debug.WriteLine(_Host);

                        }

                    }

            }

            catch (Exception ex)

            {

            }

            IConverterPDF.Cache.Attach(this);

        }

        private void button3_Click(object sender, EventArgs e)

        {

        }

        int InterfaceConverterPDF.MultiProcessCount

        {

            get

            {

                throw new NotImplementedException();

            }

            set

            {

                throw new NotImplementedException();

            }

        }

        public ServiceInfo ServiceInfomation()

        {

            throw new NotImplementedException();

        }

        public TileSorceStorageInfo[] TileSorceStorageInfomation()

        {

            throw new NotImplementedException();

        }

        object _lock = new object();

        void DeteteDirectory(string Path)

        {

            Thread _stathread = new Thread(new ParameterizedThreadStart(DeteteWork));

            _stathread.SetApartmentState(ApartmentState.MTA);

            _stathread.Start(Path);

        }

        void DeteteWork(object Path)

        {

            DirectoryInfo _dir = new DirectoryInfo(Path.ToString());

            _dir.EnumerateDirectories().AsParallel().ForAll(d =>

            {

                d.Delete(true);

            });

            _dir.Delete(true);

        }

        private void button4_Click(object sender, EventArgs e)

        {

            string DocUri = @"http://portal.daelimplant.com/100481_app/Lists/VPLIST/Attachments/115047/VP-100481-29-001-PK8001-3700_0.pdf";

            string ItemPath = @"\\172.20.100.71\TileSource\000000_Tile\1050\115047_";

            string _delPath = ItemPath;

            //lock (_lock)

            //{

                try

                {

                    DirectoryInfo _dir = new DirectoryInfo(ItemPath);

                    if (_dir.Exists)

                    {

                        for (int i = 0; i < 100; i++)

                        {

                            _delPath = ItemPath + "_" + i.ToString();

                            if (!Directory.Exists(ItemPath + "_" + i.ToString()))

                            {

                                _dir.MoveTo(_delPath);

                                DeteteDirectory(_delPath);

                                break;

                            }

                        }

                    }

                    //DZConverter.DeleteDirectoryDirs(revPath);

                    Directory.CreateDirectory(ItemPath); 

                }

                catch (Exception ex)

                {

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

                }

                try

                {

                    Filefactory _fileFactory = new Filefactory();

                    HttpRequestCachePolicy policy = new HttpRequestCachePolicy(HttpRequestCacheLevel.NoCacheNoStore);

                    _fileFactory.CachePolicy = policy;

                    var _auth = AuthUser(DocUri);

                    if (_auth != null)

                    {

                        _fileFactory.DownloadFile(new Uri(DocUri), ItemPath + "\\VP-100481-29-001-PK8001-3700_0.pdf");

                    }

                    else

                    {

                    } 

                }

                catch (Exception ex)

                {

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

                }

            //}

        }

        private System.Net.ICredentials AuthUser(string PDFurl)

        {

            System.Net.NetworkCredential credentials = null;

            try

            {

                var _url = new UriBuilder(new Uri(PDFurl).AbsoluteUri.Replace(new Uri(PDFurl).PathAndQuery, "/"));

                var _dns = _url.Host.Split('.');

                if(_dns.Count() == 3)

                    if (_dns[0].ToLower() != "www")

                    {

                        _dns[0] = "www";

                        _url.Host = _dns[0] + "." + _dns[1] + "." + _dns[2];

                    }

                System.Net.HttpWebRequest request = (System.Net.HttpWebRequest)System.Net.WebRequest.Create(_url.ToString());

                credentials = Crediential.GetAdminCrediential(_url.ToString());

                request.Credentials = credentials;

                System.Net.HttpWebResponse response = (System.Net.HttpWebResponse)request.GetResponse();

                response.Close();

            }

            catch (Exception ex)

            {

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

                return credentials;

            }

            return credentials;

        }

        private void button5_Click(object sender, EventArgs e)

        {

            try

            {

                for (int i = 0; i < Enum.GetValues(typeof(HttpRequestCacheLevel)).Length; i++)

                {

                    var _value = Enum.Parse(typeof(HttpRequestCacheLevel), i.ToString(),true);

                    System.Diagnostics.Stopwatch _watch = new System.Diagnostics.Stopwatch();

                    _watch.Start();

                    string DocUri = @"http://portal.daelimplant.com/100481_app/Lists/VPLIST/Attachments/115372/VP-100481-16-117-PK6101-621_5.pdf";

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

                    HttpRequestCachePolicy policy = new HttpRequestCachePolicy((HttpRequestCacheLevel)_value);

                    _fileFactory.CachePolicy = policy;

                    var _auth = AuthUser(DocUri);

                    if (_auth !=null)

                    {

                        _fileFactory.Credentials = _auth;

                        _fileFactory.DownloadFile(new Uri(DocUri), Application.StartupPath+"\\VP-100481-29-001-PK8001-3700_0.pdf");

                    }

                    _watch.Stop();

                    System.Diagnostics.Debug.WriteLine(_value.ToString() +  " 완료시간: " + _watch.ElapsedMilliseconds);

                    }

                GC.Collect(1);

                GC.Collect(1);

            }

            catch (Exception ex)

            {

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

            }

        }

        private void button6_Click(object sender, EventArgs e)

        {

            var _name = System.Security.Principal.WindowsIdentity.GetCurrent().Name.ToString();

            System.Diagnostics.Debug.WriteLine(_name);

            int _RemotingPort = 8090;

            channel = new TcpChannel(_RemotingPort);

            ChannelServices.RegisterChannel(channel, false);

            RemotingConfiguration.RegisterWellKnownServiceType(typeof(IntPtr),

                                                                "test", WellKnownObjectMode.Singleton);

        }

        protected override void AdjustFormScrollbars(bool displayScrollbars)

        {

            base.AdjustFormScrollbars(displayScrollbars);

        }

        private void button7_Click(object sender, EventArgs e)

        {

            using (DeepViewEntities _deepview = new DeepViewEntities(ConnectStringBuilder.DeepViewConnectionString().ToString()))

            {

                Guid id =  Guid.Parse("707139a8-da38-4ca8-89bb-886da27f5f92");

                var _converterItems = _deepview.ConverterPDF.Where(c => c.SubPassID == id

                                                            && c.Status != 4 && c.ReConverter == false);

                foreach (var item in _converterItems)

                {

                    item.Status = 0;

                    item.ReConverter = true;

                    item.SubPassID = null;

                }

                if (_converterItems.Count() > 0)

                    _deepview.SaveChanges();

            }

        }

        Uri ServiceUri()

        {

            Uri _result = null;

            try

            {

                if (channel.ChannelData != null)

                    if (channel.ChannelData.GetType() == typeof(ChannelDataStore))

                    {

                        var _uris = (channel.ChannelData as ChannelDataStore).ChannelUris;

                        if (_uris.Count() > 0)

                            _result = new Uri(_uris[0]);

                    }

            }

            catch (Exception)

            {

                new Exception("service Uri Eorror");

            }

            return _result;

        }

        public bool ServiceOn(Guid ServiceID)

        {

            throw new NotImplementedException();

        }

        private void button8_Click(object sender, EventArgs e)

        {

            Client1();

            var _id = remObj[0].RunningProcessID();

            _id.ToList().ForEach(f => System.Diagnostics.Debug.WriteLine(f.ToString()));

            var _info = remObj[0].ServiceInfomation();

            if (_info.Exception == null)

            {

                var _space = (_info.StorageInfo.First().FreeSpace / 1024f) / 1024f / 1024f;

                MessageBox.Show("여유공간 : " + _space + "GB");

            }

            else

            {

                System.Diagnostics.Debug.WriteLine(_info.Exception);

            }

        }

        private void button9_Click(object sender, EventArgs e)

        {

           MessageBox.Show(System.Environment.MachineName);

        }

    }

}