DaoMqPump2/DaoMqPump2/RemoteControl.cs

using System;
using System.Collections.Generic;
using System.Text;

namespace DaoMqPump2
{
    public class RemoteControl : IRemoteControl
    {
        

        public string[] GetTransports()
        {
            TransportController controller = TransportController.getInstance();
            return controller.getTransportNames();
        }

        public StatusData GetTransportStatus(string transport)
        {
            
            TransportController controller = TransportController.getInstance();
            Transport t = controller.getTransport(transport);

            StatusData data = t.TransportStatusData;
            return data;
        }

        public void SetTransportEnabled(string transport, bool enabled)
        {
            TransportController controller = TransportController.getInstance();
            Transport t = controller.getTransport(transport);
            t.Enabled = enabled;
        }

        /*
        public bool GetTransportEnabled(string transport)
        {
            TransportController controller = TransportController.getInstance();
            Transport t = controller.getTransport(transport);
            return t.Enabled;
        }


        public bool GetTransportLastrunOk(string transport)
        {
            TransportController controller = TransportController.getInstance();
            Transport t = controller.getTransport(transport);
            return t.lastrunOk;
        }

        public string GetTransportLastErrorMessage(string transport)
        {
            TransportController controller = TransportController.getInstance();
            Transport t = controller.getTransport(transport);
            return t.lastErrorMessage;
        }


        public string GetTransportLastOkTime(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.lastOkTime;
        }

        public string GetTransportLastErrorTime(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.lastErrorTime;
        }

        public string GetTransportLastTransferTime(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.lastTransferTime;
        }

        public int GetTransportCounter(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.counter;
        }*/

        
        public string[] GetTransportLog(string transport) 
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.logfile.getLog();

        }


        public string GetTransportDirection(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.direction;
        }


        public string GetTransportQueueName(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.queueName;
        }


        public string GetTransportInsertQuery(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.mq2sqlInsertQuery;
        }


        public string GetTransportReadQuery(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.sql2mqReadQuery;
        }


        public string GetTransportUpdateQuery(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.sql2mqUpdateQuery;
        }


    }
}
1	using System;
2	using System.Collections.Generic;
3	using System.Text;
4
5	namespace DaoMqPump2
6	{
7	public class RemoteControl : IRemoteControl
8	{
9
10
11	public string[] GetTransports()
12	{
13	TransportController controller = TransportController.getInstance();
14	return controller.getTransportNames();
15	}
16
17	public StatusData GetTransportStatus(string transport)
18	{
19
20	TransportController controller = TransportController.getInstance();
21	Transport t = controller.getTransport(transport);
22
23	StatusData data = t.TransportStatusData;
24	return data;
25	}
26
27	public void SetTransportEnabled(string transport, bool enabled)
28	{
29	TransportController controller = TransportController.getInstance();
30	Transport t = controller.getTransport(transport);
31	t.Enabled = enabled;
32	}
33
34	/*
35	public bool GetTransportEnabled(string transport)
36	{
37	TransportController controller = TransportController.getInstance();
38	Transport t = controller.getTransport(transport);
39	return t.Enabled;
40	}
41
42
43
44
45
46	public bool GetTransportLastrunOk(string transport)
47	{
48	TransportController controller = TransportController.getInstance();
49	Transport t = controller.getTransport(transport);
50	return t.lastrunOk;
51	}
52
53	public string GetTransportLastErrorMessage(string transport)
54	{
55	TransportController controller = TransportController.getInstance();
56	Transport t = controller.getTransport(transport);
57	return t.lastErrorMessage;
58	}
59
60
61	public string GetTransportLastOkTime(string transport)
62	{
63	Transport t = TransportController.getInstance().getTransport(transport);
64	return t.lastOkTime;
65	}
66
67	public string GetTransportLastErrorTime(string transport)
68	{
69	Transport t = TransportController.getInstance().getTransport(transport);
70	return t.lastErrorTime;
71	}
72
73	public string GetTransportLastTransferTime(string transport)
74	{
75	Transport t = TransportController.getInstance().getTransport(transport);
76	return t.lastTransferTime;
77	}
78
79	public int GetTransportCounter(string transport)
80	{
81	Transport t = TransportController.getInstance().getTransport(transport);
82	return t.counter;
83	}*/
84
85
86	public string[] GetTransportLog(string transport)
87	{
88	Transport t = TransportController.getInstance().getTransport(transport);
89	return t.logfile.getLog();
90
91	}
92
93
94	public string GetTransportDirection(string transport)
95	{
96	Transport t = TransportController.getInstance().getTransport(transport);
97	return t.direction;
98	}
99
100
101	public string GetTransportQueueName(string transport)
102	{
103	Transport t = TransportController.getInstance().getTransport(transport);
104	return t.queueName;
105	}
106
107
108	public string GetTransportInsertQuery(string transport)
109	{
110	Transport t = TransportController.getInstance().getTransport(transport);
111	return t.mq2sqlInsertQuery;
112	}
113
114
115	public string GetTransportReadQuery(string transport)
116	{
117	Transport t = TransportController.getInstance().getTransport(transport);
118	return t.sql2mqReadQuery;
119	}
120
121
122	public string GetTransportUpdateQuery(string transport)
123	{
124	Transport t = TransportController.getInstance().getTransport(transport);
125	return t.sql2mqUpdateQuery;
126	}
127
128
129	}
130	}