DaoMqPump2/DaoMqGUI/MainForm.cs

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;

using DaoMqGUI.ServiceReference1;
using System.ServiceModel;
using Microsoft.Win32;

namespace DaoMqGUI
{
    public partial class MainForm : Form
    {
        RemoteControlClient client = null;

        List<string> transportNameList = new List<string>();

        string hostname = "";

        public MainForm()
        {
            InitializeComponent();

            //initClient(); is now called on shown() event
            // loadTransports(); is now called on shown() event

        }

        private void initClient()
        {
            RegistryKey key = Registry.LocalMachine.CreateSubKey("Software\\DAO\\DaoMqGui");

            hostname = (string) key.GetValue("Hostname", "localhost");
            hostname = hostname.Trim();

            lnkServer.Text = hostname;

            //Step 1 - initialize client
            BasicHttpBinding binding = new BasicHttpBinding();
            EndpointAddress endpoint = new EndpointAddress(new Uri("http://" + hostname + ":8000/RemoteControl/RemoteControl"));
            client = new RemoteControlClient(binding, endpoint);
        }

        private string[] getSafeTransports()
        {
            string[] result = new string[] { };
            try
            {
                result = client.GetTransports();

                startAll.Enabled = true;
                stopAll.Enabled = true;
            }
            catch (Exception e)
            {
                MessageBox.Show(e.Message);
                startAll.Enabled = false;
                stopAll.Enabled = false;
            }

            return result;
        }

        public void loadTransports() 
        {
            int selected = transports.SelectedIndex;
            if (selected == -1) //er der ikke valgt - vælger vi den første
                selected = 0;

            transports.Items.Clear();
            transportNameList.Clear();

            string[] transportNames = getSafeTransports();
            foreach (string t in transportNames)
            {
                transportNameList.Add(t);
                StatusData statusData = client.GetTransportStatus(t);
                bool enabled = statusData.transportEnabled;
                string status = "";

                if (enabled)
                {
                    bool lastOk = statusData.lastrunOk;                    
                    
                    if (lastOk)
                    {
                        status = "running";                        
                    }
                    else
                    {
                        status = "error";
                    }
                }
                else
                {
                    status = "stopped";
                }

                transports.Items.Add(t + " - " + status);
            }


            if (selected >= transports.Items.Count) //hvis at der før var flere transports end nu - kan ikke ske pt.
            {
                if (transports.Items.Count > 0) //hvis vi har nogen vælger vi den første
                    selected = 0;
                else
                    selected = -1;
            }

            transports.SelectedIndex = selected;

        }

        private void stopAll_Click(object sender, EventArgs e)
        {
            string[] transportNames = getSafeTransports();
            foreach (string t in transportNames)
            {
                client.SetTransportEnabled(t, false);
            }

            loadTransports();
        }

        private void startAll_Click(object sender, EventArgs e)
        {
            string[] transportNames = getSafeTransports();
            foreach (string t in transportNames)
            {
                client.SetTransportEnabled(t, true);
            }

            loadTransports();
        }

        private void btnEnableOne_Click(object sender, EventArgs e)
        {
            string transportName = txtTransport.Text;
            client.SetTransportEnabled(transportName, true);
            loadTransports();
        }

        private void btnDisableOne_Click(object sender, EventArgs e)
        {
            string transportName = txtTransport.Text;
            client.SetTransportEnabled(transportName, false);
            loadTransports();
        }

        private void transports_SelectedIndexChanged(object sender, EventArgs e)
        {
            showData();
        }

        private void loadStatusData()
        {
            if (transports.SelectedIndex == -1)
                return;

            string transportName = transportNameList[transports.SelectedIndex];

            StatusData statusData = client.GetTransportStatus(transportName);

            bool enabled = statusData.transportEnabled;

            txtTransport.Text = transportName;
            txtEnabled.Text = "" + enabled;
            txtLastOK.Text = "" + statusData.lastrunOk;

            txtOkTime.Text = statusData.lastOkTime;
            txtErrorTime.Text = statusData.lastErrorTime;
            txtTransferTime.Text = statusData.lastTransferTime;

            txtErrorMsg.Text = statusData.lastErrorMessage;

            txtCounter.Text = "" + statusData.counter;


            btnDisableOne.Enabled = enabled;
            btnEnableOne.Enabled = (!enabled);            

        }

        private void refreshTimer_Tick(object sender, EventArgs e)
        {
            loadTransports(); 

            if (transports.SelectedIndex == -1)
                return;

            showData();
        }

        private void loadLog()
        {
            if (transports.SelectedIndex == -1)
                return;
            string transportName = transportNameList[transports.SelectedIndex];

            string[] logEntries = client.GetTransportLog(transportName);

            string str = "";
            foreach (string entry in logEntries)
            {
                str += entry + "\r\n";
            }
            txtLog.Text = str;

        }

        private void loadConfig()
        {
            if (transports.SelectedIndex == -1)
                return;
            string transportName = transportNameList[transports.SelectedIndex];

            string direction = client.GetTransportDirection(transportName);
            string queue = client.GetTransportQueueName(transportName);
            string insert = client.GetTransportInsertQuery(transportName);
            string read = client.GetTransportReadQuery(transportName);
            string update = client.GetTransportUpdateQuery(transportName);

            txtDirection.Text = direction;
            txtQueueName.Text = queue;
            txtInsertQuery.Text = insert;
            txtReadQuery.Text = read;
            txtUpdateQuery.Text = update;

        }

        private void showData()
        {
            if (transports.SelectedIndex == -1)
                return;

            switch (tabControl1.SelectedIndex)
            {
                case 0:
                    loadStatusData();
                    break;
                case 1:
                    loadLog();
                    break;
                case 2:
                    loadConfig();
                    break;
            }
        }

        private void tabControl1_SelectedIndexChanged(object sender, EventArgs e)
        {
            showData();
        }

        private void lnkServer_LinkClicked(object sender, LinkLabelLinkClickedEventArgs e)
        {
            string tmp_hostname = Microsoft.VisualBasic.Interaction.InputBox("Indtast servernavn/ip", "MQ Gui", hostname);
            if (tmp_hostname == null || tmp_hostname.Trim().Length == 0)
                return;

            hostname = tmp_hostname.Trim();

            RegistryKey key = Registry.LocalMachine.CreateSubKey("Software\\DAO\\DaoMqGui");
            key.SetValue("Hostname", hostname, RegistryValueKind.String);
            key.Close();

            initClient();
            loadTransports();
        }

        private void MainForm_Shown(object sender, EventArgs e)
        {
            lnkServer.Text = "Connecting ...";
            this.Refresh(); //force a redraw now () before we do the heavy work
            
            initClient();
            loadTransports();
        }

    }
}
1	torben	1986	using System;
2			using System.Collections.Generic;
3			using System.ComponentModel;
4			using System.Data;
5			using System.Drawing;
6			using System.Text;
7			using System.Windows.Forms;
8
9			using DaoMqGUI.ServiceReference1;
10	torben	1992	using System.ServiceModel;
11			using Microsoft.Win32;
12	torben	1986
13			namespace DaoMqGUI
14			{
15			public partial class MainForm : Form
16			{
17	torben	1992	RemoteControlClient client = null;
18	torben	1986
19			List<string> transportNameList = new List<string>();
20
21	torben	1992	string hostname = "";
22
23	torben	1986	public MainForm()
24			{
25			InitializeComponent();
26	torben	1992
27	torben	1994	//initClient(); is now called on shown() event
28			// loadTransports(); is now called on shown() event
29	torben	1992
30	torben	1986	}
31
32	torben	1992	private void initClient()
33			{
34			RegistryKey key = Registry.LocalMachine.CreateSubKey("Software\\DAO\\DaoMqGui");
35
36			hostname = (string) key.GetValue("Hostname", "localhost");
37			hostname = hostname.Trim();
38
39			lnkServer.Text = hostname;
40
41			//Step 1 - initialize client
42			BasicHttpBinding binding = new BasicHttpBinding();
43			EndpointAddress endpoint = new EndpointAddress(new Uri("http://" + hostname + ":8000/RemoteControl/RemoteControl"));
44			client = new RemoteControlClient(binding, endpoint);
45			}
46
47	torben	1986	private string[] getSafeTransports()
48			{
49			string[] result = new string[] { };
50			try
51			{
52			result = client.GetTransports();
53
54			startAll.Enabled = true;
55			stopAll.Enabled = true;
56			}
57			catch (Exception e)
58			{
59			MessageBox.Show(e.Message);
60			startAll.Enabled = false;
61			stopAll.Enabled = false;
62			}
63
64			return result;
65			}
66
67			public void loadTransports()
68			{
69			int selected = transports.SelectedIndex;
70			if (selected == -1) //er der ikke valgt - vælger vi den første
71			selected = 0;
72
73			transports.Items.Clear();
74			transportNameList.Clear();
75
76			string[] transportNames = getSafeTransports();
77			foreach (string t in transportNames)
78			{
79			transportNameList.Add(t);
80	torben	2000	StatusData statusData = client.GetTransportStatus(t);
81			bool enabled = statusData.transportEnabled;
82	torben	1986	string status = "";
83
84			if (enabled)
85			{
86	torben	2000	bool lastOk = statusData.lastrunOk;
87	torben	1986
88			if (lastOk)
89			{
90			status = "running";
91			}
92			else
93			{
94			status = "error";
95			}
96			}
97			else
98			{
99			status = "stopped";
100			}
101
102			transports.Items.Add(t + " - " + status);
103			}
104
105
106			if (selected >= transports.Items.Count) //hvis at der før var flere transports end nu - kan ikke ske pt.
107			{
108			if (transports.Items.Count > 0) //hvis vi har nogen vælger vi den første
109			selected = 0;
110			else
111			selected = -1;
112			}
113
114			transports.SelectedIndex = selected;
115
116			}
117
118			private void stopAll_Click(object sender, EventArgs e)
119			{
120			string[] transportNames = getSafeTransports();
121			foreach (string t in transportNames)
122			{
123			client.SetTransportEnabled(t, false);
124			}
125
126			loadTransports();
127			}
128
129			private void startAll_Click(object sender, EventArgs e)
130			{
131			string[] transportNames = getSafeTransports();
132			foreach (string t in transportNames)
133			{
134			client.SetTransportEnabled(t, true);
135			}
136
137			loadTransports();
138			}
139
140			private void btnEnableOne_Click(object sender, EventArgs e)
141			{
142			string transportName = txtTransport.Text;
143			client.SetTransportEnabled(transportName, true);
144			loadTransports();
145			}
146
147			private void btnDisableOne_Click(object sender, EventArgs e)
148			{
149			string transportName = txtTransport.Text;
150			client.SetTransportEnabled(transportName, false);
151			loadTransports();
152			}
153
154			private void transports_SelectedIndexChanged(object sender, EventArgs e)
155			{
156	torben	2000	showData();
157	torben	1986	}
158
159	torben	2000	private void loadStatusData()
160	torben	1986	{
161			if (transports.SelectedIndex == -1)
162			return;
163
164			string transportName = transportNameList[transports.SelectedIndex];
165
166	torben	2000	StatusData statusData = client.GetTransportStatus(transportName);
167	torben	1986
168	torben	2000	bool enabled = statusData.transportEnabled;
169	torben	1986
170			txtTransport.Text = transportName;
171			txtEnabled.Text = "" + enabled;
172	torben	2000	txtLastOK.Text = "" + statusData.lastrunOk;
173	torben	1986
174	torben	2000	txtOkTime.Text = statusData.lastOkTime;
175			txtErrorTime.Text = statusData.lastErrorTime;
176			txtTransferTime.Text = statusData.lastTransferTime;
177	torben	1986
178	torben	2000	txtErrorMsg.Text = statusData.lastErrorMessage;
179	torben	1986
180	torben	2000	txtCounter.Text = "" + statusData.counter;
181	torben	1986
182
183
184			btnDisableOne.Enabled = enabled;
185			btnEnableOne.Enabled = (!enabled);
186
187			}
188
189			private void refreshTimer_Tick(object sender, EventArgs e)
190			{
191			loadTransports();
192
193			if (transports.SelectedIndex == -1)
194			return;
195
196	torben	2000	showData();
197	torben	1986	}
198
199			private void loadLog()
200			{
201			if (transports.SelectedIndex == -1)
202			return;
203			string transportName = transportNameList[transports.SelectedIndex];
204
205			string[] logEntries = client.GetTransportLog(transportName);
206
207			string str = "";
208			foreach (string entry in logEntries)
209			{
210			str += entry + "\r\n";
211			}
212			txtLog.Text = str;
213
214			}
215
216			private void loadConfig()
217			{
218			if (transports.SelectedIndex == -1)
219			return;
220			string transportName = transportNameList[transports.SelectedIndex];
221
222			string direction = client.GetTransportDirection(transportName);
223			string queue = client.GetTransportQueueName(transportName);
224			string insert = client.GetTransportInsertQuery(transportName);
225			string read = client.GetTransportReadQuery(transportName);
226			string update = client.GetTransportUpdateQuery(transportName);
227
228			txtDirection.Text = direction;
229			txtQueueName.Text = queue;
230			txtInsertQuery.Text = insert;
231			txtReadQuery.Text = read;
232			txtUpdateQuery.Text = update;
233
234			}
235
236	torben	2000	private void showData()
237	torben	1986	{
238			if (transports.SelectedIndex == -1)
239			return;
240
241			switch (tabControl1.SelectedIndex)
242			{
243			case 0:
244	torben	2000	loadStatusData();
245	torben	1986	break;
246			case 1:
247			loadLog();
248			break;
249			case 2:
250			loadConfig();
251			break;
252			}
253			}
254
255	torben	2000	private void tabControl1_SelectedIndexChanged(object sender, EventArgs e)
256			{
257			showData();
258			}
259
260	torben	1992	private void lnkServer_LinkClicked(object sender, LinkLabelLinkClickedEventArgs e)
261			{
262			string tmp_hostname = Microsoft.VisualBasic.Interaction.InputBox("Indtast servernavn/ip", "MQ Gui", hostname);
263			if (tmp_hostname == null \|\| tmp_hostname.Trim().Length == 0)
264			return;
265
266			hostname = tmp_hostname.Trim();
267
268			RegistryKey key = Registry.LocalMachine.CreateSubKey("Software\\DAO\\DaoMqGui");
269			key.SetValue("Hostname", hostname, RegistryValueKind.String);
270			key.Close();
271
272			initClient();
273			loadTransports();
274			}
275
276	torben	1994	private void MainForm_Shown(object sender, EventArgs e)
277			{
278	torben	1995	lnkServer.Text = "Connecting ...";
279			this.Refresh(); //force a redraw now () before we do the heavy work
280
281	torben	1994	initClient();
282			loadTransports();
283			}
284
285	torben	1986	}
286			}