using System;

using System.Collections.Generic;

using System.IO;

using System.IO.Ports;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using System.Windows;

using System.Windows.Controls;

using System.Windows.Data;

using System.Windows.Documents;

using System.Windows.Input;

using System.Windows.Media;

using System.Windows.Media.Imaging;

using System.Windows.Navigation;

using System.Windows.Shapes;

​

namespace VZprog

{

    /// <summary>

    /// Logika interakcji dla klasy MainWindow.xaml

    /// </summary>

    public partial class MainWindow : Window

    {

        AldlFrame msg = new AldlFrame();

        SerialPort Port = new SerialPort("COM1", 8192, Parity.None, 8, StopBits.One);

​

        public MainWindow()

        {

            InitializeComponent();

        }

​

        private void SerialPortList_SelectionChanged(object sender, SelectionChangedEventArgs e)

        {

            ConnectButton.IsEnabled = true;

        }

​

        private void SerialPortList_DropDownOpened(object sender, EventArgs e)

        {

            string[] ports = SerialPort.GetPortNames();

            SerialPortList.Items.Clear();

            foreach (string port in ports)

            {

                SerialPortList.Items.Add(port);

            }

        }

​

        private void ConnectButton_Click(object sender, RoutedEventArgs e)

        {

            if((string)ConnectButton.Content == "Connect")

            {

                if(SerialPortList.Text != "")

                {

                    SerialPortList.IsEnabled = false;

                    ConnectButton.Content = "Disconnect";

                    Port.PortName = SerialPortList.Text;

                    try

                    {

                        Port.DataReceived += new SerialDataReceivedEventHandler(DataReceivedHandler);

                        msg.FlushFrame();

                        Port.Open();

                        Port.DiscardInBuffer();

                    }

                    catch { Exception ex; }

                }

            }

            else

            {

                SerialPortList.IsEnabled = true;

                ConnectButton.Content = "Connect";

                try

                {

                    Port.Close();

                }

                catch { Exception ex; }

            }

        }

​

        private void DataReceivedHandler(object sender, SerialDataReceivedEventArgs e)

        {

            SerialPort Port = (SerialPort)sender;

            for (int i = Port.BytesToRead; i > 0; i--)

            {

                msg.AppendByte((byte)Port.ReadByte());

            }

            string s = msg.GetFrame();

            if (s != "")

            Application.Current.Dispatcher.Invoke(new Action(() => { RxTextBox.AppendText("Rx: " + s + "\n"); }));

        }

​

        private void CrearTextBoxButton_Click(object sender, RoutedEventArgs e)

        {

            RxTextBox.Clear();

        }

    }

​

​

    public class AldlFrame

    {

        private static byte ByteCount = 0;

        private static byte FramePayload = 0;

        private static bool FrameValid = false;

​

        private static Queue<byte[]> frames = new Queue<byte[]>();

​

        public void AppendByte(byte data)

        {

            if (ByteCount < 169)

            {

                GetRawData[ByteCount++] = data;

                if (ByteCount > 3) ProcessFrame();

            }

            else

                FlushFrame();

        }

​

        private void ProcessFrame()

        {

            if(GetRawData[1] > 0x55)

            {

                //Correct frame length

                FramePayload = (byte)(GetRawData[1] - 0x55);

                if(ByteCount == FramePayload + 3) // 2 byte header + 1 byte checksum

                {

                    byte sum = 0;

                    byte[] frame_buffer = new byte[FramePayload + 2];

                    //received whole message

                    for (byte b = 0; b < FramePayload + 2; b++)

                    {

                        sum += GetRawData[b];

                        frame_buffer[b] = GetRawData[b];

                    }

                    sum += GetRawData[FramePayload + 2];

                    if (sum == 0)

                    {

                        //checksum correct

                        frames.Enqueue(frame_buffer);

                    }

                    else FlushFrame();

                }

            }

            else FlushFrame();

        }

​

        public void FlushFrame()

        {

            ByteCount = 0;

            FramePayload = 0;

            FrameValid = false;

        }

​

        public static byte[] GetRawData { get; } = new byte[170];

​

        public string GetFrame()

        {

            string message = "";

            if (frames.Count > 0)

            {

                byte[] frame = frames.Dequeue();

                for (byte b = 0; b < frame.Length; b++)

                {

                    message += frame[b].ToString("X2");

                    message += " ";

                }

            }

            return message;

        }

    }

}

​