GUI fix

Proftaak Remote Healthcare/FietsClientV2/AppGlobal.cs

@@ -0,0 +1,98 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Fietsclient
+{
+    public class AppGlobal
+    {
+        private static AppGlobal _instance;
+
+        public int[] StatusItemsChecked;
+
+        Thread workerThread;
+        public static AppGlobal Instance
+        {
+            get { return _instance ?? (_instance = new AppGlobal()); }
+        }
+
+        
+
+        private KettlerBikeComm _bikeComm;
+
+
+        private AppGlobal()
+        {
+            _bikeComm = new KettlerBikeComm();
+            KettlerBikeComm.IncomingDataEvent += HandleBikeData; //initialize event
+        }
+
+        public void setTimeMode(string time)
+        {
+            _bikeComm.sendData("CU");
+            _bikeComm.sendData("PT " + time);
+        }
+
+        public void setPower(string power)
+        {
+            _bikeComm.sendData("CU");
+            _bikeComm.sendData("PW " + power);
+        }
+
+        public void setDistanceMode(string distance)
+        {
+            _bikeComm.sendData("CU");
+            _bikeComm.sendData("PD " + distance);
+        }
+
+        public void reset()
+        {
+            _bikeComm.sendData("RS");
+        }
+
+        public void startComPort()
+        {
+            startComPort("COM4");
+        }
+
+        public void startComPort(string portname)
+        {
+            _bikeComm.initComm(portname);
+        }
+
+        public void startAskingData()
+        {
+            workerThread = new Thread(() => workerThreadLoop());
+            workerThread.Start();
+        }
+
+        private void workerThreadLoop()
+        {
+            while(true)
+            {
+                Thread.Sleep(1000);
+                _bikeComm.sendData(KettlerBikeComm.STATUS);
+            }
+        }
+
+        //event handler
+        private void HandleBikeData(string[] data) 
+        {
+            //doe iets ermee...
+        }
+
+        public void closeComPort()
+        {
+            if (workerThread != null)
+                workerThread.Suspend();
+            _bikeComm.closeComm();
+        }
+
+
+
+
+    }
+}

Proftaak Remote Healthcare/FietsClientV2/DataHandler.cs

@@ -0,0 +1,203 @@
+using System;
+using System.Collections.Generic;
+using System.IO.Ports;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace FietsClientV2
+{
+
+    //alle data die ontvagen wordt van de fiets gaat als eerst door de DataHandler klasse heen voordat hij verwerkt wordt door de model klasse.
+    // TLDR: ontvangt fiets data 
+
+    class DataHandler
+    {
+        // vaste waarden
+        public static readonly string COMMAND = "CU";
+        public static readonly string CMD_TIME = "PT";
+        public static readonly string CMD_DISTANCE = "PD";
+        public static readonly string CMD_POWER = "PW";
+        public static readonly string CMD_ENERGY = "PE";
+        public static readonly string RESET = "RS";
+        public static readonly string STATUS = "ST";
+
+        // private fields
+        private string portname;
+        private int baudrate = 9600;
+        private string bufferOut;
+        private string[] bufferIn;
+
+        // public fields
+        public enum State { notConnected, connected, reset, command }
+        public enum ReturnData { ERROR, ACK, RUN, STATUS }
+
+        public State state = State.notConnected;
+        public ReturnData returnData;
+
+        private SerialPort ComPort;
+
+        // custom events
+        public delegate void DataDelegate(string[] data);
+        public static event DataDelegate IncomingDataEvent;
+
+        public delegate void DebugDelegate(string debugData);
+        public static event DebugDelegate IncomingDebugLineEvent;
+
+        public DataHandler()
+        {
+
+        }
+
+        private static void OnIncomingDataEvent(string[] data)
+        {
+            DataDelegate handler = IncomingDataEvent;
+            if (handler != null) handler(data);
+        }
+
+        public static void OnIncomingDebugLineEvent(string debugData)
+        {
+            DebugDelegate handler = IncomingDebugLineEvent;
+            if (handler != null) handler(debugData);
+        }
+
+        public void initComm(string portname)
+        {
+            if (ComPort != null)
+            {
+                ComPort.Close();
+            }
+            this.portname = portname;
+            try
+            {
+                ComPort = new SerialPort(this.portname, this.baudrate);
+                ComPort.Open();
+                ComPort.WriteLine(RESET);
+                ComPort.DataReceived += new SerialDataReceivedEventHandler(ComPort_DataReceived);
+            }
+            catch (UnauthorizedAccessException)
+            {
+                OnIncomingDebugLineEvent("ERROR: UnauthorizedAccessException throwed");
+                try { ComPort.Close(); } catch (Exception) { } // probeer om de ComPort wel te sluiten.
+            }
+            catch (InvalidOperationException)
+            {
+                OnIncomingDebugLineEvent("ERROR: InvalidOperationException throwed");
+                try { ComPort.Close(); } catch (Exception) { } // probeer om de ComPort wel te sluiten.
+            }
+
+        }
+
+        public void closeComm()
+        {
+            ComPort.Close();
+        }
+
+        public void sendData(string data)
+        {
+            bufferOut = data;
+            ComPort.WriteLine(data);
+        }
+
+        private void ComPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
+        {
+            string buffer = ComPort.ReadLine();
+            switch (buffer) //kijk wat er binnenkomt
+            {
+                case "ERROR": //wanneer "Error"
+                    returnData = ReturnData.ERROR;
+                    handleError();
+                    break;
+                case "ACK": // ACK betekent acknowledged.
+                    returnData = ReturnData.ACK;
+                    break;
+                case "RUN":
+                    returnData = ReturnData.RUN;
+                    break;
+                default:    // alle andere waarden.
+                    returnData = ReturnData.STATUS;
+                    handleBikeValues(buffer);
+                    break;
+            }
+        }
+
+        int trycount = 0;
+        private void handleError()
+        {
+            if (bufferOut == "RS" && trycount < 3)
+            {
+                sendData("RS");  //gewoon nog een keer proberen tot 3 keer toe, net zolang totdat hij werkt.
+                trycount++;
+            }
+        }
+
+        private void handleBikeValues(string buffer)
+        {
+            buffer = buffer.TrimEnd('\r');
+            Console.WriteLine(buffer);
+            bufferIn = buffer.Split('\t');
+            OnIncomingDataEvent(bufferIn);
+        }
+
+        private bool checkBikeState()
+        {
+            bool success = false;
+            switch (state)
+            {
+                case State.reset:
+                    setCommandMode();
+
+                    if (returnData != ReturnData.ERROR)
+                    {
+                        success = true;
+                    }
+                    break;
+                case State.connected:
+                    setCommandMode();
+                    success = true;
+                    break;
+                case State.command:
+                    success = true;
+                    break;
+                case State.notConnected:
+                    Console.WriteLine("ERROR: not connected to bike.");
+                    success = false;
+                    break;
+            }
+            return success;
+        }
+
+        public void setCommandMode()
+        {
+            sendData(COMMAND);
+        }
+
+        public void setTime()
+        {
+            if (!checkBikeState())
+                return;
+            sendData(CMD_TIME);
+        }
+
+        public void setDistance()
+        {
+            if (!checkBikeState())
+                return;
+            sendData(CMD_DISTANCE);
+        }
+
+        public void setPower()
+        {
+            if (!checkBikeState())
+                return;
+            sendData(CMD_POWER);
+        }
+
+        public void setEnergy()
+        {
+            if (!checkBikeState())
+                return;
+            sendData(CMD_ENERGY);
+        }
+    }
+}

Proftaak Remote Healthcare/FietsClientV2/FietsClientV2.csproj

@@ -47,6 +47,9 @@
     <Reference Include="System.Xml" />
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="AppGlobal.cs" />
+    <Compile Include="DataHandler.cs" />
+    <Compile Include="KettlerBikeComm.cs" />
     <Compile Include="Login.cs">
       <SubType>Form</SubType>
     </Compile>

Proftaak Remote Healthcare/FietsClientV2/KettlerBikeComm.cs

@@ -0,0 +1,206 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using System.IO.Ports;
+using System.Threading;
+
+namespace Fietsclient
+{
+    /// <summary>
+    /// Dit is de communicatieklasse met de simulator of de fiets.
+    /// </summary>
+    class KettlerBikeComm
+    {
+
+        // vaste waarden
+        public static readonly string COMMAND = "CU";
+        public static readonly string CMD_TIME = "PT";
+        public static readonly string CMD_DISTANCE = "PD";
+        public static readonly string CMD_POWER = "PW";
+        public static readonly string CMD_ENERGY = "PE";
+        public static readonly string RESET = "RS";
+        public static readonly string STATUS = "ST";
+
+        // private fields
+        private string _portname;
+        private int baudrate = 9600;
+        private string _bufferOut;
+        private string[] _bufferIn;
+
+        // public fields
+        public enum State { notConnected, connected, reset, command }
+        public enum ReturnData { ERROR, ACK, RUN, STATUS }
+
+        public State state = State.notConnected;
+        public ReturnData returnData;
+
+        private SerialPort ComPort;
+
+        // custom events
+        public delegate void DataDelegate(string[] data);
+        public static event DataDelegate IncomingDataEvent;
+
+        public delegate void DebugDelegate(string debugData);
+        public static event DebugDelegate IncomingDebugLineEvent;
+
+        public KettlerBikeComm()
+        {
+            
+        }
+
+        private static void OnIncomingDataEvent(string[] data)
+        {
+            DataDelegate handler = IncomingDataEvent;
+            if (handler != null) handler(data);
+        }
+
+        public static void OnIncomingDebugLineEvent(string debugData)
+        {
+            DebugDelegate handler = IncomingDebugLineEvent;
+            if (handler != null) handler(debugData);
+        }
+
+        public void initComm(string portname)
+        {
+            if (ComPort != null)
+            {
+                ComPort.Close();
+            }
+            _portname = portname;
+            try
+            {
+                ComPort = new SerialPort(_portname, this.baudrate);
+                ComPort.Open();
+                ComPort.WriteLine(RESET);
+                ComPort.DataReceived += new SerialDataReceivedEventHandler(ComPort_DataReceived);
+            }
+            catch (UnauthorizedAccessException)
+            {
+                OnIncomingDebugLineEvent("ERROR: UnauthorizedAccessException throwed");
+                try { ComPort.Close(); } catch (Exception) { } // probeer om de ComPort wel te sluiten.
+            }
+            catch (InvalidOperationException)
+            {
+                OnIncomingDebugLineEvent("ERROR: InvalidOperationException throwed");
+                try { ComPort.Close(); } catch (Exception) { } // probeer om de ComPort wel te sluiten.
+            }
+
+        }
+
+        public void closeComm()
+        {
+            ComPort.Close();
+        }
+
+        public void sendData(string data)
+        {
+            _bufferOut = data;
+            ComPort.WriteLine(data);
+        }
+
+        private void ComPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
+        {
+            string buffer = ComPort.ReadLine();
+            switch(buffer) //kijk wat er binnenkomt
+            {
+                case "ERROR": //wanneer "Error"
+                    returnData = ReturnData.ERROR;
+                    handleError();
+                    break;
+                case "ACK": // ACK betekent acknowledged.
+                    returnData = ReturnData.ACK;
+                    break;
+                case "RUN":
+                    returnData = ReturnData.RUN;
+                    break;
+                default:    // alle andere waarden.
+                    returnData = ReturnData.STATUS;
+                    handleBikeValues(buffer);
+                    break;
+            }
+        }
+
+        int trycount = 0;
+        private void handleError()
+        {
+            if (_bufferOut == "RS" && trycount < 3)
+            {
+                sendData("RS");  //gewoon nog een keer proberen tot 3 keer toe, net zolang totdat hij werkt.
+                trycount++;
+            }
+        }
+
+        private void handleBikeValues(string buffer)
+        {
+            buffer = buffer.TrimEnd('\r');
+            Console.WriteLine(buffer);
+            _bufferIn = buffer.Split('\t');
+            OnIncomingDataEvent(_bufferIn);
+        }
+
+        private bool checkBikeState()
+        {
+            bool success = false;
+            switch(state)
+            {
+                case State.reset:
+                    setCommandMode();
+                    
+                    if(returnData != ReturnData.ERROR)
+                    {
+                        success = true;
+                    }
+                    break;
+                case State.connected:
+                    setCommandMode();                   
+                    success = true;
+                    break;
+                case State.command:
+                    success = true;
+                    break;
+                case State.notConnected:
+                    Console.WriteLine("ERROR: not connected to bike.");
+                    success = false;
+                    break;
+            }
+            return success;
+        }
+
+        public void setCommandMode()
+        {
+            sendData(COMMAND);
+        }
+
+        public void setTime()
+        {
+            if (!checkBikeState())
+                return;
+            sendData(CMD_TIME);
+        }
+
+        public void setDistance()
+        {
+            if (!checkBikeState())
+                return;
+            sendData(CMD_DISTANCE);
+        }
+
+        public void setPower()
+        {
+            if (!checkBikeState())
+                return;
+            sendData(CMD_POWER);
+        }
+
+        public void setEnergy()
+        {
+            if (!checkBikeState())
+                return;
+            sendData(CMD_ENERGY);
+        }
+    }
+}
+
+