using DevExpress.XtraEditors;
|
using DevExpress.XtraEditors.Controls;
|
using DevExpress.XtraGrid;
|
using DevExpress.XtraGrid.Columns;
|
using DevExpress.XtraGrid.Views.Base;
|
using DevExpress.XtraGrid.Views.Grid;
|
using DevExpress.XtraWaitForm;
|
using Gs.DevApp.ToolBox;
|
using Microsoft.Win32;
|
using NModbus;
|
using NModbus.Device;
|
using NModbus.Serial;
|
using System;
|
using System.Collections.Generic;
|
using System.ComponentModel;
|
using System.Configuration;
|
using System.Data;
|
using System.Drawing;
|
using System.IO.Ports;
|
using System.Linq;
|
using System.Windows.Forms;
|
using static DevExpress.Data.Filtering.Helpers.SubExprHelper.ThreadHoppingFiltering;
|
using DateTime = System.DateTime;
|
|
namespace Gs.DevApp
|
{
|
public partial class XtraForm2 : DevExpress.XtraEditors.XtraForm
|
{
|
public delegate void HandleInterfaceUpdataDelegate(string text);
|
public SerialPort Sp = new SerialPort();
|
private XtraForm2.HandleInterfaceUpdataDelegate interfaceUpdataHandle;
|
public XtraForm2()
|
{
|
InitializeComponent();
|
this.cmbBaudRate.EditValue = (object)"9600";
|
this.GetComList();
|
}
|
|
private void GetComList()
|
{
|
this.cmbSerialPortNum.Properties.Items.Clear();
|
|
this.cmbBaudRate.Properties.Items.AddRange(new ImageComboBoxItem[5]
|
{
|
new ImageComboBoxItem("14400", (object) "14400", -1),
|
new ImageComboBoxItem("9600", (object) "9600", -1),
|
new ImageComboBoxItem("4800", (object) "4800", -1),
|
new ImageComboBoxItem("2400", (object) "2400", -1),
|
new ImageComboBoxItem("1200", (object) "1200", -1)
|
});
|
|
|
RegistryKey registryKey = Registry.LocalMachine.OpenSubKey("Hardware\\DeviceMap\\SerialComm");
|
if (registryKey == null)
|
return;
|
foreach (string valueName in registryKey.GetValueNames())
|
{
|
string description = (string)registryKey.GetValue(valueName);
|
this.cmbSerialPortNum.Properties.Items.Add(new ImageComboBoxItem(description, (object)description));
|
}
|
if (this.cmbSerialPortNum.Properties.Items.Count > 0)
|
this.cmbSerialPortNum.SelectedIndex = 0;
|
}
|
|
public void GetWeight()
|
{
|
ModbusFactory factory = new ModbusFactory();
|
LogHelper.Debug(this.ToString(), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":创建modbus对象...");
|
IModbusMaster rtuMaster = (IModbusMaster)factory.CreateRtuMaster(this.Sp);
|
bool flag = true;
|
while (true)
|
{
|
try
|
{
|
if (!this.Sp.IsOpen)
|
{
|
LogHelper.Debug(this.ToString(), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":重新打开串口连接...");
|
this.Sp.Open();
|
rtuMaster = (IModbusMaster)factory.CreateRtuMaster(this.Sp);
|
}
|
if (rtuMaster == null)
|
{
|
LogHelper.Debug(this.ToString(), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":重新创建modbus对象...");
|
rtuMaster = (IModbusMaster)factory.CreateRtuMaster(this.Sp);
|
}
|
// DataTable dataTable = this._sqlHelper.ExecuteDataTable("\r\nselect top 1 * from WOMZLA(nolock) \r\nwhere ZLA004=convert(varchar(10),getdate(),120) and ZLA003='IQC' and ZLA008='N'\r\norder by ZLA005");
|
//if (dataTable != null && dataTable.Rows.Count > 0)
|
//{
|
// // LoggerHelper.WriteInfoLog($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}:发送上下限数据：{dataTable.Rows[0]["ZLA006"]}|{dataTable.Rows[0]["ZLA007"]}");
|
// byte slaveAddress1 = byte.Parse("1");
|
// ushort startAddress1 = ushort.Parse("0104");
|
// ushort[] ushort2_1 = this.stringToUshort2(dataTable.Rows[0]["ZLA006"].ToString());
|
// rtuMaster.WriteMultipleRegisters(slaveAddress1, startAddress1, ushort2_1);
|
// byte slaveAddress2 = byte.Parse("1");
|
// ushort startAddress2 = ushort.Parse("0102");
|
// ushort[] ushort2_2 = this.stringToUshort2(dataTable.Rows[0]["ZLA007"].ToString());
|
// rtuMaster.WriteMultipleRegisters(slaveAddress2, startAddress2, ushort2_2);
|
// this._sqlHelper.ExecuteNonQuery($"update WOMZLA set ZLA008='Y',ZLA009=convert(varchar(20),getdate(),120) where ZLA001='{dataTable.Rows[0]["ZLA001"]}'");
|
//}
|
//else
|
{
|
byte slaveAddress3 = byte.Parse("1");
|
ushort startAddress3 = ushort.Parse("0002");
|
ushort numberOfPoints1 = ushort.Parse("2");
|
ushort[] numArray = rtuMaster.ReadHoldingRegisters(slaveAddress3, startAddress3, numberOfPoints1);
|
float single = BitConverter.ToSingle(this.CombomBinaryArray(BitConverter.GetBytes(numArray[1]), BitConverter.GetBytes(numArray[0])), 0);
|
this.Invoke((Delegate)this.interfaceUpdataHandle, (object)single.ToString());
|
byte slaveAddress4 = byte.Parse("1");
|
ushort startAddress4 = ushort.Parse("0001");
|
ushort numberOfPoints2 = ushort.Parse("1");
|
int int32 = Convert.ToInt32(rtuMaster.ReadHoldingRegisters(slaveAddress4, startAddress4, numberOfPoints2)[0].ToString());
|
string str = Convert.ToString(int32, 2).PadLeft(16 /*0x10*/, '0');
|
char ch1 = str[1];
|
char ch2 = str[6];
|
if (ch1 == '0' && ch2 == '0')
|
{
|
// this._sqlHelper.ExecuteNonQuery($"\r\nif not exists(select 1 from WOMZLB(nolock) where ZLB001='IQC' and ZLB002='{single.ToString()}' and ZLB003='{int32.ToString()}')\r\nbegin\r\n if exists(select 1 from WOMZLB(nolock) where ZLB001='IQC')\r\n begin\r\n\t update WOMZLB set ZLB002='{single.ToString()}',ZLB003='{int32.ToString()}' where ZLB001='IQC'\r\n end\r\n else\r\n begin\r\n\t insert into WOMZLB(ZLB001,ZLB002,ZLB003)\r\n\t select 'IQC','{single.ToString()}','{int32.ToString()}'\r\n end\r\nend\r\n");
|
flag = true;
|
}
|
else if (flag)
|
{
|
// this._sqlHelper.ExecuteNonQuery($"\r\nif not exists(select 1 from WOMZLB(nolock) where ZLB001='IQC' and ZLB002='{single.ToString()}' and ZLB003='{int32.ToString()}')\r\nbegin\r\n if exists(select 1 from WOMZLB(nolock) where ZLB001='IQC')\r\n begin\r\n\t update WOMZLB set ZLB002='0',ZLB003='{int32.ToString()}' where ZLB001='IQC'\r\n end\r\n else\r\n begin\r\n\t insert into WOMZLB(ZLB001,ZLB002,ZLB003)\r\n\t select 'IQC','0','{int32.ToString()}'\r\n end\r\nend\r\n");
|
flag = false;
|
}
|
MessageBox.Show(single.ToString() + ":" + int32.ToString());
|
LogHelper.Debug(this.ToString(), "single:" + single.ToString());
|
LogHelper.Debug(this.ToString(), "int32:" + int32.ToString());
|
}
|
// Thread.Sleep(2000);
|
}
|
catch (Exception ex)
|
{
|
// Thread.Sleep(2000);
|
MessageBox.Show(ex.Message);
|
LogHelper.Debug(this.ToString(), "single:" + ex.Message);
|
}
|
}
|
}
|
private byte[] CombomBinaryArray(byte[] srcArray1, byte[] srcArray2)
|
{
|
byte[] destinationArray = new byte[srcArray1.Length + srcArray2.Length];
|
Array.Copy((Array)srcArray1, 0, (Array)destinationArray, 0, srcArray1.Length);
|
Array.Copy((Array)srcArray2, 0, (Array)destinationArray, srcArray1.Length, srcArray2.Length);
|
return destinationArray;
|
}
|
private void simpleButton1_Click(object sender, EventArgs e)
|
{
|
try
|
{
|
DateTime now = DateTime.Now;
|
// LoggerHelper.WriteInfoLog(now.ToString("yyyy-MM-dd HH:mm:ss") + ":开始采集");
|
if (this.cmbBaudRate.Text.Trim() != "" && this.cmbSerialPortNum.Text != "")
|
{
|
now = DateTime.Now;
|
// LoggerHelper.WriteInfoLog(now.ToString("yyyy-MM-dd HH:mm:ss") + ":配置串口通信");
|
// this.interfaceUpdataHandle = new MainForm.HandleInterfaceUpdataDelegate(this.UpdateTextBox);
|
this.Sp.PortName = this.cmbSerialPortNum.Text.Trim();
|
this.Sp.BaudRate = Convert.ToInt32(this.cmbBaudRate.Text.Trim());
|
this.Sp.Parity = Parity.None;
|
this.Sp.StopBits = StopBits.One;
|
now = DateTime.Now;
|
// LoggerHelper.WriteInfoLog(now.ToString("yyyy-MM-dd HH:mm:ss") + ":打开串口同通信");
|
this.Sp.Open();
|
MessageBox.Show("打开成功Sp:" + Sp.IsOpen.ToString());
|
//this.button1.Enabled = false;
|
//this.button2.Enabled = true;
|
//this.timer1.Enabled = false;
|
//now = DateTime.Now;
|
//LoggerHelper.WriteInfoLog(now.ToString("yyyy-MM-dd HH:mm:ss") + ":启动刷新数据定时器");
|
//this.timer1.Start();
|
}
|
else
|
{
|
now = DateTime.Now;
|
// LoggerHelper.WriteErrorLog(now.ToString("yyyy-MM-dd HH:mm:ss") + ":请输入正确的端口号和波特率");
|
int num = (int)MessageBox.Show("请输入正确的端口号和波特率！");
|
this.cmbSerialPortNum.Focus();
|
}
|
}
|
catch (Exception ex)
|
{
|
// LoggerHelper.WriteErrorLog($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}:{ex.Message}");
|
int num = (int)MessageBox.Show($"端口{this.cmbSerialPortNum.Text.Trim()}打开失败！{ex.Message}");
|
}
|
}
|
|
private void simpleButton2_Click(object sender, EventArgs e)
|
{
|
GetWeight();
|
}
|
|
public void ReadWeight222()
|
{
|
ModbusFactory factory = new ModbusFactory();
|
try
|
{
|
// 1. 配置串口参数（需与电子秤一致）
|
string portName = "COM1"; // 串口号
|
int baudRate = 9600; // 波特率
|
Parity parity = Parity.None; // 校验位
|
int dataBits = 8; // 数据位
|
StopBits stopBits = StopBits.One; // 停止位
|
|
// 2. 创建串口连接
|
SerialPort serialPort = new SerialPort(portName, baudRate, parity, dataBits, stopBits);
|
serialPort.Open();
|
|
// 3. 创建Modbus RTU主站
|
IModbusMaster master = (IModbusMaster)factory.CreateRtuMaster(serialPort);
|
// 4. 配置读取参数
|
//byte slaveId = 1; // 从站地址（电子秤的Modbus地址）
|
//ushort startAddress = 0; // 寄存器起始地址（40001对应地址0）
|
//ushort numRegisters = 2; // 读取2个寄存器（32位数据）
|
|
|
byte slaveAddress3 = byte.Parse("1");
|
ushort startAddress3 = ushort.Parse("0");
|
ushort numberOfPoints1 = ushort.Parse("2");
|
// 5. 读取保持寄存器
|
ushort[] registers = master.ReadHoldingRegisters(slaveAddress3, startAddress3, numberOfPoints1);
|
|
// 6. 处理返回数据（假设数据为32位浮点数，大端格式）
|
byte[] bytes = new byte[4];
|
Buffer.BlockCopy(registers, 0, bytes, 0, 4);
|
|
// 处理字节序（根据设备要求可能需要调整）
|
if (BitConverter.IsLittleEndian)
|
{
|
Array.Reverse(bytes); // 如果设备是大端模式，需要反转字节
|
}
|
|
// 转换为浮点数
|
float weight = BitConverter.ToSingle(bytes, 0);
|
|
MessageBox.Show(weight.ToString());
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"读取失败: {ex.Message}");
|
MessageBox.Show("err:" + ex.Message.ToString());
|
}
|
}
|
|
private void simpleButton3_Click(object sender, EventArgs e)
|
{
|
ModbusFactory factory = new ModbusFactory();
|
// 1. 配置串口参数
|
SerialPort serialPort = new SerialPort("COM1", 9600, Parity.None, 8, StopBits.One);
|
serialPort.Open();
|
|
|
// 构造自定义功能码请求帧（示例：功能码 0x31）
|
byte[] request = new byte[] { 0x01, 0x31, 0x00, 0x01, 0x00, 0x02, 0x00, 0x00 };
|
serialPort.Write(request, 0, request.Length);
|
|
// 读取响应
|
byte[] buffer = new byte[256];
|
int bytesRead = serialPort.Read(buffer, 0, buffer.Length);
|
MessageBox.Show($"响应数据: {BitConverter.ToString(buffer, 0, bytesRead)}");
|
|
//serialPort.Close();
|
|
// 2. 创建Modbus RTU主站
|
IModbusMaster modbusMaster = (IModbusMaster)factory.CreateRtuMaster(serialPort);
|
try
|
{
|
while (true)
|
{
|
// 3. 读取保持寄存器（从站地址1，起始地址0x0001，读取2个寄存器）
|
ushort[] registers = modbusMaster.ReadHoldingRegisters(1, 0x0001, 2);
|
MessageBox.Show("d");
|
// 4. 解析数据（假设寄存器存储的是重量值，单位为克）
|
int weight = (registers[0] << 16) + registers[1];
|
Console.WriteLine($"重量值: {weight} g");
|
MessageBox.Show($"重量值: {weight} g");
|
System.Threading.Thread.Sleep(1000); // 每秒读取一次
|
}
|
}
|
catch (Exception ex)
|
{
|
MessageBox.Show(ex.Message);
|
Console.WriteLine($"错误: {ex.Message}");
|
}
|
finally
|
{
|
serialPort.Close();
|
}
|
|
}
|
}
|
}
|
