USB

using System;
using System.Collections.Generic;
using System.Text;
using System.Collections;
using System.ComponentModel;
using System.IO.Ports;
using SerialProtReader;
using System.Data;
using System.Threading;
namespace SerialProtReader{
    public class PortReader{
        private bool end = false;
        private BackgroundWorker bw;
        private int OldValue;
        private double timein;
        private int colports;
        private ArrayList TimesOpen = new ArrayList();
        private ArrayList TimesClose = new ArrayList();
        
        public PortReader(){
            this.OldValue = 0;
            this.timein = 0;
            this.colports = 8;
            for (int i = 0; i < colports; i++){
                TimesOpen.Add(DateTime.Now.TimeOfDay);
                TimesClose.Add(DateTime.Now.TimeOfDay);
            }
        }
 
        public void OnStart(string[] args)
        {
            bw = new BackgroundWorker();
            SerialPort sp = new SerialPort();
            sp.PortName = string.Format("COM{0}", 3);
            sp.BaudRate = 9600;
            sp.DataBits = 8;
            sp.StopBits = StopBits.One;
            foreach (string param in args){
                try{
                    switch (String.Format("{0}{1}{2}", param.ToLower()[0],  
                             param.ToLower()[1], param.ToLower()[2]))
                    {
                        case "/p:":
                            sp.PortName = 
                                    string.Format("COM{0}", param.Remove(0, 3));
                            break;
                        case "/b:":
                            sp.BaudRate = int.Parse(param.Remove(0, 3));
                            break;
                        case "/d:":
                            sp.DataBits = int.Parse(param.Remove(0, 3));
                            break;
                        case "/s:":
                            switch (param.Remove(0, 3))
                            {
                                case "0":
                                    sp.StopBits = StopBits.None;
                                    break;
                                case "1":
                                    sp.StopBits = StopBits.One;
                                    break;
                                case "1.5":
                                    sp.StopBits = StopBits.OnePointFive;
                                    break;
                                case "2":
                                    sp.StopBits = StopBits.Two;
                                    break;
                                default:
                                    break;
                            }
                            break;
                        case "/t:":
                            timein = double.Parse(param.Remove(0, 3));
                            break;
                        case "/c:":
                            colports = int.Parse(param.Remove(0, 3));
                            break;
                        default:
                            break;
                    }
                }
catch (Exception){
string message = string.Empty;
message += "Вы можите использовать следующие ключи:\n";
message += "/p:N где N – номер COM порта, к которому подключино устройство;\n";
message += "/b:N где N – BaudRate, устройства;\n";
message += "/d:N где N – DataBits, устройства;\n";
message += "/s:N где N – StopBits, устройства;\n";
message += "/t:N где N – время срабатывания устройства в секундах;\n";
message += "/c:N где N – количество портов на устройстве;\n";
message += "Параметры могут передаваться через пробел.;\n";
      message += "Пример: /p:4 /b:9600 /d:8 /s:1 /t:60 /c:8;\n";
      message += "После ввода таких параметров, программа будет настроена на:\n";
message += "Чтение из COM4, BaudRate:9600, DataBits:8, StopBits:1,\n";
      message += "время срабатывания = 1 минуте, на устройстве 8 портов.";
      throw new NotImplementedException(message);
  }
}
            
  bw.WorkerReportsProgress = true;
  bw.DoWork += new DoWorkEventHandler(bw_DoWork);
  bw.ProgressChanged += new ProgressChangedEventHandler(bw_ProgressChanged);
  try{
bw.RunWorkerAsync(sp);
  }
  catch (Exception ex) {
     throw new NotImplementedException(ex.Message);
  }
}
 
        public void OnStop()
        {
            end = true;
            bw.Dispose();
        }
 
private ArrayList IntToAL(int input_val){
 ArrayList al = new ArrayList();
 Queue q = new Queue();
 do{
   if (input_val % 2 == 0){
     q.Enqueue(0);
    }
    else{
     q.Enqueue(1);
    }
    input_val = Convert.ToInt32(input_val / 2);
  }
  while (input_val >= 1);
  int col = q.Count;
  int add = colports – col;
  for (int i = 0; i < col; i++){
    al.Add(q.Dequeue());
  }
  for (int i = 0; i < add; i++){
    al.Add(0);
  }
  return al;
}
 
private void bw_ProgressChanged(object sender, ProgressChangedEventArgs e){
 int newvalue = e.ProgressPercentage;
 if (OldValue != newvalue){
   ArrayList BitOldValue = IntToAL(OldValue);
   ArrayList BitNewValue = IntToAL(newvalue);
   for (int i = 0; i < BitOldValue.Count; i++){
     if (BitNewValue[i].ToString() != BitOldValue[i].ToString()){
       if ((int)(BitNewValue[i]) == 0){
         TimesClose[i] = DateTime.Now.TimeOfDay;
         TimeSpan rt = (TimeSpan)TimesClose[i] – (TimeSpan)TimesOpen[i];
           if (rt.TotalSeconds > timein){
            MySQLDataSet.portDataTable ports = new MySQLDataSet.portDataTable();
            MySQLDataSetTableAdapters.portTableAdapter portsTA = new MySQLDataSetTableAdapters.portTableAdapter();
            portsTA.ClearBeforeFill = true;
            portsTA.FilIDByPort(ports, UInt32.Parse(Math.Pow(2, i).ToString()));
            MySQLDataSet.worktableDataTable WorkTable = new MySQLDataSet.worktableDataTable();
            MySQLDataSetTableAdapters.worktableTableAdapter WorkTableTA = new MySQLDataSetTableAdapters.worktableTableAdapter();
            DataRow dr = WorkTable.NewRow();
            DateTime open = DateTime.Today.Add((TimeSpan)TimesOpen[i]);
            DateTime close = DateTime.Today.Add((TimeSpan)TimesClose[i]);
                                dr[WorkTable.IDColumn] = 1;
                                dr[WorkTable.OpenDTColumn] = open.ToString();
                                dr[WorkTable.CloseDTColumn] = close.ToString();
                                dr[WorkTable.Port_IDColumn] = ports[0].ID;
                                WorkTable.Rows.Add(dr);
                                WorkTableTA.Update(WorkTable);
            }
        }
        else{
           TimesOpen[i] = DateTime.Now.TimeOfDay;
        }
    }
  }
  
 
OldValue = newvalue;
 }
}
 
 
 
private void bw_DoWork(object sender, DoWorkEventArgs e)
{
  SerialPort sp = (SerialPort)e.Argument;
  sp.Open();
  e.Result = ReadData(sp);
  sp.Close();
  sp.Dispose();
}
 
 
private bool ReadData(SerialPort sp)
{
 try
  {
    while (!end)
    {
      int data = sp.ReadByte();
      bw.ReportProgress(data);
      sp.DiscardInBuffer();
      Thread.Sleep(1 * 5 * 1000);
    }
 }
 catch
 {
   return false;
 }
 return true;
  } 
 } 
}