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 int getSelectedTransportIndex()
        {
            if (transports.SelectedIndices.Count == 0)
                return -1;
            else
                return transports.SelectedIndices[0];
        }

        public void loadTransports() 
        {

            int selected = getSelectedTransportIndex();
            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 = "";
                Color bgColor;
                if (enabled)
                {
                    bool lastOk = statusData.lastrunOk;                    
                    
                    if (lastOk)
                    {
                        status = "running";
                        bgColor = Color.Green;
                    }
                    else
                    {
                        status = "error";
                        bgColor = Color.Red;
                    }
                }
                else
                {
                    status = "stopped";
                    bgColor = Color.DarkOrange;                    
                }

                ListViewItem item = new ListViewItem(t + " - " + status);
                item.ForeColor = bgColor;
                transports.Items.Add(item);
            }


            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.SelectedIndices.Clear();
            if (selected != -1)
                transports.SelectedIndices.Add(selected);
            //transports.SelectedIndices[0] = 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 (getSelectedTransportIndex() == -1)
                return;

            string transportName = transportNameList[getSelectedTransportIndex() ];

            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;

            txtDiscarded.Text = "" + statusData.discardedCounter;

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

        }

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

            if (getSelectedTransportIndex() == -1)
                return;

            showData();
        }

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

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

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

        }

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

            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 (getSelectedTransportIndex() == -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	torben	2013	public int getSelectedTransportIndex()
68			{
69			if (transports.SelectedIndices.Count == 0)
70			return -1;
71			else
72			return transports.SelectedIndices[0];
73			}
74
75	torben	1986	public void loadTransports()
76			{
77	torben	2013
78			int selected = getSelectedTransportIndex();
79	torben	1986	if (selected == -1) //er der ikke valgt - vælger vi den første
80			selected = 0;
81
82			transports.Items.Clear();
83			transportNameList.Clear();
84
85			string[] transportNames = getSafeTransports();
86			foreach (string t in transportNames)
87			{
88			transportNameList.Add(t);
89	torben	2000	StatusData statusData = client.GetTransportStatus(t);
90			bool enabled = statusData.transportEnabled;
91	torben	1986	string status = "";
92	torben	2013	Color bgColor;
93	torben	1986	if (enabled)
94			{
95	torben	2000	bool lastOk = statusData.lastrunOk;
96	torben	1986
97			if (lastOk)
98			{
99	torben	2013	status = "running";
100			bgColor = Color.Green;
101	torben	1986	}
102			else
103			{
104			status = "error";
105	torben	2013	bgColor = Color.Red;
106	torben	1986	}
107			}
108			else
109			{
110			status = "stopped";
111	torben	2013	bgColor = Color.DarkOrange;
112	torben	1986	}
113
114	torben	2013	ListViewItem item = new ListViewItem(t + " - " + status);
115			item.ForeColor = bgColor;
116			transports.Items.Add(item);
117	torben	1986	}
118
119
120			if (selected >= transports.Items.Count) //hvis at der før var flere transports end nu - kan ikke ske pt.
121			{
122			if (transports.Items.Count > 0) //hvis vi har nogen vælger vi den første
123			selected = 0;
124			else
125			selected = -1;
126			}
127
128	torben	2013	transports.SelectedIndices.Clear();
129			if (selected != -1)
130			transports.SelectedIndices.Add(selected);
131			//transports.SelectedIndices[0] = selected;
132	torben	1986
133			}
134
135			private void stopAll_Click(object sender, EventArgs e)
136			{
137			string[] transportNames = getSafeTransports();
138			foreach (string t in transportNames)
139			{
140			client.SetTransportEnabled(t, false);
141			}
142
143			loadTransports();
144			}
145
146			private void startAll_Click(object sender, EventArgs e)
147			{
148			string[] transportNames = getSafeTransports();
149			foreach (string t in transportNames)
150			{
151			client.SetTransportEnabled(t, true);
152			}
153
154			loadTransports();
155			}
156
157			private void btnEnableOne_Click(object sender, EventArgs e)
158			{
159			string transportName = txtTransport.Text;
160			client.SetTransportEnabled(transportName, true);
161			loadTransports();
162			}
163
164			private void btnDisableOne_Click(object sender, EventArgs e)
165			{
166			string transportName = txtTransport.Text;
167			client.SetTransportEnabled(transportName, false);
168			loadTransports();
169			}
170
171			private void transports_SelectedIndexChanged(object sender, EventArgs e)
172			{
173	torben	2000	showData();
174	torben	1986	}
175
176	torben	2000	private void loadStatusData()
177	torben	1986	{
178	torben	2013	if (getSelectedTransportIndex() == -1)
179	torben	1986	return;
180
181	torben	2013	string transportName = transportNameList[getSelectedTransportIndex() ];
182	torben	1986
183	torben	2000	StatusData statusData = client.GetTransportStatus(transportName);
184	torben	1986
185	torben	2000	bool enabled = statusData.transportEnabled;
186	torben	1986
187			txtTransport.Text = transportName;
188			txtEnabled.Text = "" + enabled;
189	torben	2000	txtLastOK.Text = "" + statusData.lastrunOk;
190	torben	1986
191	torben	2000	txtOkTime.Text = statusData.lastOkTime;
192			txtErrorTime.Text = statusData.lastErrorTime;
193			txtTransferTime.Text = statusData.lastTransferTime;
194	torben	1986
195	torben	2000	txtErrorMsg.Text = statusData.lastErrorMessage;
196	torben	1986
197	torben	2000	txtCounter.Text = "" + statusData.counter;
198	torben	1986
199	torben	2058	txtDiscarded.Text = "" + statusData.discardedCounter;
200	torben	1986
201			btnDisableOne.Enabled = enabled;
202			btnEnableOne.Enabled = (!enabled);
203
204			}
205
206			private void refreshTimer_Tick(object sender, EventArgs e)
207			{
208	torben	2013	loadTransports();
209	torben	1986
210	torben	2013	if (getSelectedTransportIndex() == -1)
211	torben	1986	return;
212
213	torben	2000	showData();
214	torben	1986	}
215
216			private void loadLog()
217			{
218	torben	2013	if (getSelectedTransportIndex() == -1)
219	torben	1986	return;
220	torben	2013	string transportName = transportNameList[getSelectedTransportIndex()];
221	torben	1986
222			string[] logEntries = client.GetTransportLog(transportName);
223
224			string str = "";
225			foreach (string entry in logEntries)
226			{
227			str += entry + "\r\n";
228			}
229			txtLog.Text = str;
230
231			}
232
233			private void loadConfig()
234			{
235	torben	2013	if (getSelectedTransportIndex() == -1)
236	torben	1986	return;
237	torben	2013	string transportName = transportNameList[getSelectedTransportIndex()];
238	torben	1986
239			string direction = client.GetTransportDirection(transportName);
240			string queue = client.GetTransportQueueName(transportName);
241			string insert = client.GetTransportInsertQuery(transportName);
242			string read = client.GetTransportReadQuery(transportName);
243			string update = client.GetTransportUpdateQuery(transportName);
244
245			txtDirection.Text = direction;
246			txtQueueName.Text = queue;
247			txtInsertQuery.Text = insert;
248			txtReadQuery.Text = read;
249			txtUpdateQuery.Text = update;
250
251			}
252
253	torben	2000	private void showData()
254	torben	1986	{
255	torben	2013	if (getSelectedTransportIndex() == -1)
256	torben	1986	return;
257
258			switch (tabControl1.SelectedIndex)
259			{
260			case 0:
261	torben	2000	loadStatusData();
262	torben	1986	break;
263			case 1:
264			loadLog();
265			break;
266			case 2:
267			loadConfig();
268			break;
269			}
270			}
271
272	torben	2000	private void tabControl1_SelectedIndexChanged(object sender, EventArgs e)
273			{
274			showData();
275			}
276
277	torben	1992	private void lnkServer_LinkClicked(object sender, LinkLabelLinkClickedEventArgs e)
278			{
279			string tmp_hostname = Microsoft.VisualBasic.Interaction.InputBox("Indtast servernavn/ip", "MQ Gui", hostname);
280			if (tmp_hostname == null \|\| tmp_hostname.Trim().Length == 0)
281			return;
282
283			hostname = tmp_hostname.Trim();
284
285			RegistryKey key = Registry.LocalMachine.CreateSubKey("Software\\DAO\\DaoMqGui");
286			key.SetValue("Hostname", hostname, RegistryValueKind.String);
287			key.Close();
288
289			initClient();
290			loadTransports();
291			}
292
293	torben	1994	private void MainForm_Shown(object sender, EventArgs e)
294			{
295	torben	1995	lnkServer.Text = "Connecting ...";
296			this.Refresh(); //force a redraw now () before we do the heavy work
297
298	torben	1994	initClient();
299			loadTransports();
300			}
301
302	torben	1986	}
303			}