using System;

using System.IO.Ports;

using System.Text;

using System.Threading;

namespace weight

{

///

/// 电子秤接口信息类，封装COM口数据

///

public class WeightInformation

{

string _wdata;

string _wunit;

string _qdata;

string _qunit;

string _percentage;

///

/// 获取或设置重量

///

public string WData { get { return this._wdata; } set { this._wdata = value; } }

///

/// 获取或设置重量单位

///

public string WUnit { get { return this._wunit; } set { this._wunit = value; } }

///

/// 获取或设置数量

///

public string QData { get { return this._qdata; } set { this._qdata = value; } }

///

/// 获取或设置数量单位

///

public string QUnit { get { return this._qunit; } set { this._qunit = value; } }

///

/// 获取或设置百分数

///

public string Percentage { get { return this._percentage; } set { this._percentage = value; } }

}

///

/// 电子称数据读取类

///

public class WeightReader : IDisposable

{

#region 字段、属性与构造函数

SerialPort sp;

int _speed = 300;

///

/// 获取或设置电脑取COM数据缓冲时间，单位毫秒

///

public int Speed

{

get

{

return this._speed;

}

set

{

if (value < 300)

throw new Exception("串口读取缓冲时间不能小于300毫秒!");

this._speed = value;

}

}

public bool InitCom(string PortName)

{

return this.InitCom(PortName, 4800, 300);

}

///

/// 初始化串口

///

/// 数据传输端口

/// 波特率

/// 串口读数缓冲时间

///

public bool InitCom(string PortName, int BaudRate,int Speed)

{

try

{

sp = new SerialPort(PortName, BaudRate, Parity.None, 8);

sp.ReceivedBytesThreshold = 10;

sp.Handshake = Handshake.RequestToSend;

sp.Parity = Parity.None;

sp.ReadTimeout = 600;

sp.WriteTimeout = 600;

this.Speed = Speed;

if (!sp.IsOpen)

{

sp.Open();

}

return true;

}

catch

{

throw new Exception(string.Format("无法初始化串口{0}!",PortName));

}

}

#endregion

#region 串口数据读取方法

public WeightInformation ReadInfo()

{

string src = this.ReadCom();

WeightInformation info = new WeightInformation();

info.WData = this.DecodeWeightData(src);

info.WUnit = this.DecodeWeightUnit(src);

info.Percentage = this.DecodePercentage(src);

info.QData = this.DecodeQualityData(src);

info.QUnit = this.DecodeQualityUnit(src);

return info;

}

///

/// 将COM口缓存数据全部读取

///

///

private string ReadCom()//返回信息

{

if (this.sp.IsOpen)

{

Thread.Sleep(this._speed);

string res = "";

//for (int i = 0; i < 5; i++)

//{

byte[] buffer = new byte[sp.BytesToRead];

sp.Read(buffer, 0, buffer.Length);

res = System.Text.Encoding.ASCII.GetString(buffer);

//if (res != "")

//    break;

//}

if (res == "")

{

throw new Exception("串口读取数据为空，参数设置是否正确!");

}

return res;

}

return "";

}

#endregion

#region  基本取数方法

///

/// 从字符串中取值

///

/// 起始字符串

/// 间隔位长度

/// 值长度

/// 源字符串

///

private string DecodeValue(string head, int intervalLen, int valueLen,string src)

{

int index = src.IndexOf(head);

return src.Substring(index + intervalLen, valueLen);

}

///

/// 取重量

///

/// 源字符串

///

private string DecodeWeightData(string srcString)

{

return this.DecodeValue("GS,", 3, 8,srcString);

}

///

/// 取重量单位

///

/// 源字符串

///

private string DecodeWeightUnit(string srcString)

{

return this.DecodeValue("GS,", 12, 2, srcString);

}

///

/// 取百分数

///

/// 源字符串

///

private string DecodePercentage(string srcString)

{

return this.DecodeValue("U.W.", 4, 14, srcString);

}

///

/// 取数量

///

/// 源字符串

///

private string DecodeQualityData(string srcString)

{

return this.DecodeValue("PCS", 3, 9, srcString);

}

///

/// 取数量单位

///

/// 源字符串

///

private string DecodeQualityUnit(string srcString)

{

return this.DecodeValue("PCS", 12, 3, srcString);

}

#endregion

#region 释放所有资源

public void Dispose()

{

if (sp != null && sp.IsOpen)

{

sp.Close();

}

}

#endregion

}

}

————————————————

版权声明：本文为CSDN博主「maomaoawen」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/maomaoawen/article/details/4284514