串口通讯:化验数据采集[测硫仪]
using System;using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Text;
using System.Windows.Forms;
using System.IO.Ports;
using System.Threading;
using System.Text.RegularExpressions;
using DataParse;
//using System.Windows.Forms;
namespace SendData
{
/// <summary>
///
/// </summary>
public partial class uSerPort : Label
{
private SerialPort[] serPorts;
public delegate void GetComData(string sValue);
public GetComData getData;
private bool[] isOpens;
public static string _weightZL = "";
[DescriptionAttribute("通讯端口号")]
/// <summary>
/// 串口号
/// </summary>
public string[] Ports;
[DescriptionAttribute("通讯波特率")]
public int[] iBits;
[DescriptionAttribute("数据长度")]
public int[] iLengths;
[DescriptionAttribute("数据较验:0,1,2")]
//0为None，1为寄校验，2为偶较验
public int[] iParitys;
[DescriptionAttribute("数据停止位:0,1,2")]
public string[] iStops;
[DescriptionAttribute("过滤的字符")]
public string[] filters;
[DescriptionAttribute("是否连续发送")]
public string CanSpace;
[DescriptionAttribute("台称个数")]
public int iNum=1;
[DescriptionAttribute("数据解析方法")]
public string dataParse = "";
[DescriptionAttribute("设备ID")]
public string deviceId = "";
public uSerPort()
{
InitializeComponent();
//this.TextAlign = ContentAlignment.MiddleCenter;
//this.serPort.ReadBufferSize = 1024;
}
/// <summary>
/// 串口打开
/// </summary>
/// <returns></returns>
public bool[] OpenPort()
{
isOpens = new bool[iNum];
try
{
serPorts = new SerialPort[iNum];
for (int i = 0; i < iNum; i )
{
isOpens[i] = false;
serPorts[i] = new SerialPort();
serPorts[i].ReceivedBytesThreshold = 1;
serPorts[i].BaudRate = iBits[i];
serPorts[i].DataBits = iLengths[i];
serPorts[i].DtrEnable = true;
serPorts[i].PortName = Ports[i];
int iStop = 0;
if (iStops[i] == "1.5")
iStop = 15;
else
{
try
{
iStop = Convert.ToInt16(iStops[i]);
}
catch { }
}
switch (iParitys[i])
{
default:
case 0:
serPorts[i].Parity = Parity.None;
break;
case 1:
serPorts[i].Parity = Parity.Odd;
break;
case 2:
serPorts[i].Parity = Parity.Even;
break;
}
switch (iStop)
{
default:
serPorts[i].StopBits = StopBits.One;
break;
case 2:
serPorts[i].StopBits = StopBits.Two;
break;
case 15:
serPorts[i].StopBits = StopBits.OnePointFive;
break;
}
if (serPorts[i].IsOpen)
serPorts[i].Close();
serPorts[i].Open();
isOpens[i] = true;
if (i == 0)
{
serPorts[i].DataReceived = new SerialDataReceivedEventHandler(serPort_DataReceived);
}
else
{
serPorts[i].DataReceived = new SerialDataReceivedEventHandler(serPort_DataReceived2);
}
}
}
catch (Exception ex)
{
throw new Exception(ex.Message);
}
return isOpens;
}
/// <summary>
/// 串口关闭
/// </summary>
/// <returns></returns>
public bool ClosePort()
{
bool flag = false;
isOpens = new bool[iNum];
try
{
for (int i=0;i<iNum;i )
{
if (serPorts[i].IsOpen)
{
if(i==0)
serPorts[i].DataReceived -= new SerialDataReceivedEventHandler(serPort_DataReceived);
else
serPorts[i].DataReceived -= new SerialDataReceivedEventHandler(serPort_DataReceived2);
serPorts[i].Close();
//serPort.Dispose();
}
flag = true;
isOpens[i] = false;
}
}
catch (Exception ex)
{
flag = false;
throw new Exception(ex.Message);
}
return flag;
}
/// <summary>
/// 获取端口打开状态
/// </summary>
/// <returns></returns>
public bool[] GetPortState()
{
bool[] isOp = new bool[iNum];
for (int i = 0; i < iNum;i )
{
isOp[i] = serPorts[i].IsOpen;
}
return isOp;
}
private void serPort_DataReceived(object sender, System.IO.Ports.SerialDataReceivedEventArgs e)
{
SerialPort serPort = sender as SerialPort;
getWeight(serPort, filters[0]);
}
private void serPort_DataReceived2(object sender, System.IO.Ports.SerialDataReceivedEventArgs e)
{
SerialPort serPort = sender as SerialPort;
getWeight(serPort, filters[1]);
}
private void getWeight(SerialPort serPort, string Filter)
{
string str = TransWeight.getWeight(serPort, Filter);
getData(str);
//this.Dispatcher.Invoke(getData, new string[] { str });
//this.Invoke(getData, new string[] { str });
_weightZL = str;
//SerialPort serPort = sender as SerialPort;
//try
//{
// if (serPort.IsOpen)
// {
// string extStr = "";
// string str = "";
// if (Filter != "0")
// {
// System.Threading.Thread.Sleep(200);
// extStr = serPort.ReadExisting();
// loger.Info(string.Format("ReadExisting:{0}", extStr));
// if (extStr.IndexOf("\r") > 0)//带换行
// {
// str = extStr.Replace("\r", "");
// if (str.IndexOf("Net") >= 0)
// {
// str = str.Substring(str.IndexOf("Net") 3);
// }
// else if (str.IndexOf("Weight") >= 0)
// {
// str = str.Substring(str.IndexOf("Weight") 6);
// }
// else if (str.IndexOf("WT:") >= 0)
// {
// str = str.Substring(str.IndexOf("WT:") 3);
// }
// }
// else//不带换行
// {
// #region 不带回车符的连续发送
// if (extStr.Contains("ENTER."))
// {
// serPort.NewLine = "ENTER."; //空格代表换行
// str = serPort.ReadLine();
// }
// else
// {
// str = extStr;
// }
// #endregion
// }
// }
// else//数据不做任何处理,按键发送
// {
// str = extStr = serPort.ReadLine();
// loger.Info(string.Format("ReadExisting:{0}", str));
// }
// if (str.Length > 0)
// {
// if (Filter.Length > 0 && str.IndexOf(Filter) >= 0 && Filter != "0")
// {
// str = str.Substring(str.IndexOf(Filter) Filter.Length);
// }
// Regex reg = new Regex(@"-?[\d] .?[\d] ");
// str = reg.Match(str).Value;
// loger.Info(string.Format("MatchString:{0}", str));
// //if (this.IsHandleCreated && str.Length > 1) { this.Invoke(getData, new string[] { str }); }
// //try { }
// //catch { getData(str); }
// //getData(str);
// this.Dispatcher.Invoke(getData, new string[] { str });
// _weightZL = toDouble(str);
// }
// }
//}
//catch (Exception ex)
//{
// //MessageBox.Show(ex.Message);
//}
}
/// <summary>
/// 设置串口属性
/// </summary>
/// <param name="strPort">端口号</param>
/// <param name="Bit">波特率</param>
/// <param name="Length">数据位</param>
/// <param name="Parity">较验码</param>
/// <param name="Stop">停止位</param>
public void IniSerPort(string[] strPorts,int[] Bits,int[] Lengths,int[] Paritys,string[] Stops)
{
Ports = strPorts;
iBits = Bits;
iLengths = Lengths;
iParitys = Paritys;
iStops = Stops;
}
private double toDouble(object str)
{
double result = 0.0;
try { result=Convert.ToDouble(str); }
catch { }
return result;
}
/// <summary>
/// 返回计量仪表上的重量数据
/// </summary>
/// <returns></returns>
public static string GetjlybData()
{
return _weightZL;
}
}
}
.
├── DataParse
│ ├── DataParse.cs
│ ├── DataParse.csproj
│ ├── FileClass.cs
│ ├── Properties
│ │ └── AssemblyInfo.cs
│ ├── TransWeight.cs
│ ├── bin
│ │ ├── Debug
│ │ │ ├── DataParse.dll
│ │ │ ├── DataParse.pdb
│ │ │ ├── Model.dll
│ │ │ ├── Model.pdb
│ │ │ ├── Newtonsoft.Json.dll
│ │ │ ├── Service.dll
│ │ │ ├── Service.pdb
│ │ │ └── log4net.dll
│ │ └── Release
│ └── obj
│ └── Debug
│ ├── DataParse.csproj.AssemblyReference.cache
│ ├── DataParse.csproj.CopyComplete
│ ├── DataParse.csproj.CoreCompileInputs.cache
│ ├── DataParse.csproj.FileListAbsolute.txt
│ ├── DataParse.csprojResolveAssemblyReference.cache
│ ├── DataParse.dll
│ ├── DataParse.pdb
│ ├── DesignTimeResolveAssemblyReferencesInput.cache
│ └── TempPE
├── Lib
│ ├── 2_0
│ │ └── Newtonsoft.Json.dll
│ ├── Newtonsoft.Json.dll
│ └── log4net.dll
├── Model
│ ├── IfSampleCheckConnector.cs
│ ├── Model.csproj
│ ├── Param
│ │ ├── Base.cs
│ │ └── IfSampleCheckConnectorParam.cs
│ ├── Properties
│ │ └── AssemblyInfo.cs
│ ├── bin
│ │ ├── Debug
│ │ │ ├── Model.dll
│ │ │ └── Model.pdb
│ │ └── Release
│ └── obj
│ └── Debug
│ ├── DesignTimeResolveAssemblyReferencesInput.cache
│ ├── Model.csproj.AssemblyReference.cache
│ ├── Model.csproj.CoreCompileInputs.cache
│ ├── Model.csproj.FileListAbsolute.txt
│ ├── Model.dll
│ ├── Model.pdb
│ └── TempPE
├── SendData.sln
├── SendData.suo
├── SendMMS
│ ├── BalanceCommRead
│ │ ├── BalanceCon.cs
│ │ ├── clsRWIniFile.cs
│ │ ├── uSerPort.Designer.cs
│ │ ├── uSerPort.cs
│ │ └── uSerPort.resx
│ ├── CreateDelegateHelper.cs
│ ├── FileClass.cs
│ ├── Program.cs
│ ├── ProjectInstaller.Designer.cs
│ ├── ProjectInstaller.cs
│ ├── ProjectInstaller.resx
│ ├── Properties
│ │ └── AssemblyInfo.cs
│ ├── SendData.csproj
│ ├── SendData.csproj.user
│ ├── SendDataService.Designer.cs
│ ├── SendDataService.cs
│ ├── SendDataService.resx
│ ├── System.Ini
│ ├── app.config
│ ├── bin
│ │ ├── Debug
│ │ │ ├── DataParse.dll
│ │ │ ├── DataParse.pdb
│ │ │ ├── Log
│ │ │ │ ├── 20200929.log
│ │ │ │ ├── 20201007.log
│ │ │ │ └── 20201009.log
│ │ │ ├── Model.dll
│ │ │ ├── Model.pdb
│ │ │ ├── Newtonsoft.Json.dll
│ │ │ ├── SendData.exe
│ │ │ ├── SendData.exe.config
│ │ │ ├── SendData.pdb
│ │ │ ├── SendData.vshost.exe
│ │ │ ├── SendData.vshost.exe.config
│ │ │ ├── SendData.vshost.exe.manifest
│ │ │ ├── SendMMS.vshost.exe.manifest
│ │ │ ├── Service.dll
│ │ │ ├── Service.pdb
│ │ │ ├── System.Ini
│ │ │ ├── System.Net.Http.dll
│ │ │ ├── System1.Ini
│ │ │ ├── System2.Ini
│ │ │ └── log4net.dll
│ │ └── Release
│ └── obj
│ └── x86
│ └── Debug
│ ├── DesignTimeResolveAssemblyReferences.cache
│ ├── DesignTimeResolveAssemblyReferencesInput.cache
│ ├── SendData.SendDataService.resources
│ ├── SendData.csproj.AssemblyReference.cache
│ ├── SendData.csproj.CopyComplete
│ ├── SendData.csproj.CoreCompileInputs.cache
│ ├── SendData.csproj.FileListAbsolute.txt
│ ├── SendData.csproj.GenerateResource.Cache
│ ├── SendData.csprojResolveAssemblyReference.cache
│ ├── SendData.exe
│ ├── SendData.pdb
│ ├── SendData.uSerPort.resources
│ ├── SendMMS.ProjectInstaller.resources
│ ├── SendMMS.csproj.FileListAbsolute.txt
│ ├── SendMMS.csproj.GenerateResource.Cache
│ └── TempPE
├── SendMmsSetup
│ ├── Debug
│ │ ├── Debug.zip
│ │ ├── SendMmsSetup.msi
│ │ ├── WindowsInstaller3_1
│ │ │ └── WindowsInstaller-KB893803-v2-x86.exe
│ │ └── setup.exe
│ ├── Release
│ ├── SendMmsSetup.vdproj
│ └── 化验数据采集发送服务部署说明.docx
├── Service
│ ├── ApiWebClient.cs
│ ├── ApiWebClientInterface.cs
│ ├── FileClass.cs
│ ├── IfSampleCheckConnectorService.cs
│ ├── Properties
│ │ └── AssemblyInfo.cs
│ ├── Service.csproj
│ ├── Service.csproj.user
│ ├── ServiceProvider.cs
│ ├── WebClientPro.cs
│ ├── bin
│ │ ├── Debug
│ │ │ ├── Model.dll
│ │ │ ├── Model.pdb
│ │ │ ├── Newtonsoft.Json.dll
│ │ │ ├── Service.dll
│ │ │ └── Service.pdb
│ │ └── Release
│ └── obj
│ └── Debug
│ ├── DesignTimeResolveAssemblyReferences.cache
│ ├── DesignTimeResolveAssemblyReferencesInput.cache
│ ├── Service.csproj.AssemblyReference.cache
│ ├── Service.csproj.CopyComplete
│ ├── Service.csproj.CoreCompileInputs.cache
│ ├── Service.csproj.FileListAbsolute.txt
│ ├── Service.csprojResolveAssemblyReference.cache
│ ├── Service.dll
│ ├── Service.pdb
│ └── TempPE
├── UpgradeLog.htm
├── WfTest
│ ├── FileClass.cs
│ ├── Form1.Designer.cs
│ ├── Form1.cs
│ ├── Form1.resx
│ ├── Program.cs
│ ├── Properties
│ │ ├── AssemblyInfo.cs
│ │ ├── Resources.Designer.cs
│ │ ├── Resources.resx
│ │ ├── Settings.Designer.cs
│ │ └── Settings.settings
│ ├── WfTest.csproj
│ ├── bin
│ │ └── Debug
│ │ ├── System.Ini
│ │ ├── System.Net.Http.dll
│ │ ├── WfTest.exe
│ │ └── WfTest.pdb
│ └── obj
│ └── x86
│ └── Debug
│ ├── DesignTimeResolveAssemblyReferences.cache
│ ├── DesignTimeResolveAssemblyReferencesInput.cache
│ ├── TempPE
│ ├── WfTest.Form1.resources
│ ├── WfTest.Properties.Resources.resources
│ ├── WfTest.csproj.FileListAbsolute.txt
│ ├── WfTest.csproj.GenerateResource.Cache
│ ├── WfTest.csprojResolveAssemblyReference.cache
│ ├── WfTest.exe
│ └── WfTest.pdb
└── 找例子网_化验数据采集[测硫仪].zip
50 directories, 150 files
评论