using Gs.WeightIqc.ToolBox;
|
using Microsoft.Win32;
|
using Newtonsoft.Json;
|
using NModbus;
|
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.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using System.Windows.Forms;
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement;
|
|
namespace Gs.WeightLine
|
{
|
public partial class Form1 : DevExpress.XtraEditors.XtraForm
|
{
|
string _webServiceName = "WorkWeight/";
|
public System.IO.Ports.SerialPort Sp = new System.IO.Ports.SerialPort();
|
public delegate void HandleInterfaceUpdataDelegate(string text);
|
private Form1.HandleInterfaceUpdataDelegate interfaceUpdataHandle;
|
private Dictionary<string, Thread> dicThread = new Dictionary<string, Thread>();
|
private System.Windows.Forms.Timer timer1 = new System.Windows.Forms.Timer();
|
|
System.Timers.Timer timerGridview = new System.Timers.Timer(10000);
|
public Form1()
|
{
|
InitializeComponent();
|
GetComList();
|
comLine.getSuppler("");
|
#region MyRegion
|
int int32 = 10000;
|
string _vanishingSeconds = ConfigurationManager.AppSettings["TimingMailInterval"];
|
if (!string.IsNullOrEmpty(_vanishingSeconds))
|
int32 = int.Parse(_vanishingSeconds);
|
this.timer1.Interval = int32;
|
this.button1.Enabled = true;
|
this.button2.Enabled = false;
|
this.comLine.IsReadly = false;
|
this.cmbSerialPortNum.Enabled = true;
|
this.cmbBaudRate.Enabled = true;
|
this.cmbBaudRate.SelectedIndex = 1;
|
#endregion
|
this.timer1.Tick += (s, e) =>
|
{
|
if (this.dicThread.Keys.Contains<string>("GetWeight"))
|
return;
|
Thread thread1 = new Thread(new ThreadStart(this.GetWeight));
|
thread1.Start();
|
this.dicThread.Add("GetWeight", thread1);
|
};
|
this.button1.Click += (s, e) =>
|
{
|
string _comLine = comLine.GetId();
|
if (string.IsNullOrEmpty(_comLine))
|
{
|
MessageBox.Show("请选择线体");
|
this.comLine.Focus();
|
return;
|
}
|
try
|
{
|
LogHelper.Debug(this.ToString(), " 开始采集");
|
if (this.cmbBaudRate.Text.Trim() != "" && this.cmbSerialPortNum.Text != "")
|
{
|
LogHelper.Debug(this.ToString(), "配置串口通信");
|
this.interfaceUpdataHandle = new Form1.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;
|
LogHelper.Debug(this.ToString(), "打开串口同通信");
|
this.Sp.Open();
|
this.button1.Enabled = false;
|
this.button2.Enabled = true;
|
this.timer1.Enabled = false;
|
this.comLine.IsReadly = true;
|
this.cmbSerialPortNum.Enabled = false;
|
this.cmbBaudRate.Enabled = false;
|
LogHelper.Debug(this.ToString(), "启动刷新数据定时器");
|
this.timer1.Start();
|
}
|
else
|
{
|
LogHelper.Debug(this.ToString(), "请输入正确的串口号和波特率");
|
int num = (int)MessageBox.Show("请输入正确的串口号和波特率！");
|
this.cmbSerialPortNum.Focus();
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Debug(this.ToString(), ex.Message);
|
int num = (int)MessageBox.Show($"串口{this.cmbSerialPortNum.Text.Trim()}打开失败！{ex.Message}");
|
}
|
};
|
this.button2.Click += (s, e) =>
|
{
|
try
|
{
|
if (this.dicThread.Keys.Contains<string>("GetWeight"))
|
{
|
Thread thread = this.dicThread["GetWeight"];
|
if (thread.IsAlive)
|
thread.Abort();
|
this.dicThread.Remove("GetWeight");
|
}
|
this.button1.Enabled = true;
|
this.button2.Enabled = false;
|
this.comLine.IsReadly = false;
|
this.cmbSerialPortNum.Enabled = true;
|
this.cmbBaudRate.Enabled = true;
|
this.timer1.Stop();
|
this.Sp.Close();
|
}
|
catch (Exception ex)
|
{
|
//int num = (int)MessageBox.Show(ex.Message);
|
//Application.Exit();
|
MessageBox.Show(ex.Message);
|
LogHelper.Debug(this.ToString(), ex.Message);
|
}
|
};
|
this.FormClosing += (s, e) =>
|
{
|
if (Sp.IsOpen)
|
Sp.Close();
|
if (timer1 != null)
|
{
|
timer1.Stop();
|
timer1.Dispose();
|
}
|
if (timerGridview != null)
|
{
|
timerGridview.Stop();
|
timerGridview.Dispose();
|
}
|
try
|
{
|
if (this.dicThread.Keys.Contains<string>("GetWeight"))
|
{
|
Thread thread = this.dicThread["GetWeight"];
|
if (thread.IsAlive)
|
thread.Abort();
|
this.dicThread.Remove("GetWeight");
|
}
|
this.timer1.Stop();
|
this.Sp.Close();
|
}
|
catch (Exception ex)
|
{
|
//int num = (int)MessageBox.Show(ex.Message);
|
//Application.Exit();
|
MessageBox.Show(ex.Message);
|
}
|
};
|
#region gridview设置
|
timerGridview.Elapsed += (s, e) =>
|
{
|
string _lineId = comLine.GetId();
|
if (string.IsNullOrEmpty(_lineId))
|
return;
|
var _obj = new
|
{
|
lineId = _lineId,
|
};
|
try
|
{
|
var strReturn = UtilityHelper.HttpPost("", _webServiceName + "GetModelList", JsonConvert.SerializeObject(_obj), false);
|
var dd = UtilityHelper.ReturnToList(strReturn);
|
var dt = dd.rtnData;
|
BeginInvoke(new Action(() =>
|
{
|
gcMx1.BindingContext = new BindingContext();
|
gcMx1.DataSource = dt;
|
gcMx1.ForceInitialize();
|
gvMx1.BestFitColumns();
|
}));
|
BeginInvoke(new Action(() =>
|
{
|
this.txtMsg.Text = "最近刷新列表时间:" + DateTime.Now.ToString();
|
}));
|
}
|
catch (Exception ex)
|
{
|
MessageBox.Show("gvMx1:" + ex.Message);
|
}
|
};
|
timerGridview.AutoReset = true; // 设置为true表示重复执行，false表示执行一次后停止
|
timerGridview.Enabled = true; // 开始计时
|
gvMx1.OptionsFind.ShowSearchNavButtons = false;
|
gvMx1.OptionsView.ShowAutoFilterRow = false;
|
gvMx1.OptionsView.ShowGroupPanel = false;
|
gvMx1.RowStyle += (s, e) =>
|
{
|
//默认选中行不变色
|
gvMx1.OptionsSelection.EnableAppearanceFocusedRow = false;
|
//默认选中单元格不变色
|
gvMx1.OptionsSelection.EnableAppearanceFocusedCell = false;
|
if (e.RowHandle >= 0)
|
{
|
DataRow row = gvMx1.GetDataRow(e.RowHandle);
|
if (row == null)
|
return;
|
string colorString = row["bgColor"].ToString(); // 使用十六进制表示颜色的ARGB值
|
Color color = ColorTranslator.FromHtml(colorString);
|
e.Appearance.BackColor = color;
|
}
|
};
|
gvMx1.IndicatorWidth = 60;
|
gvMx1.CustomDrawRowIndicator += (s, e) =>
|
{
|
if (e.Info.IsRowIndicator && e.RowHandle >= 0)
|
e.Info.DisplayText = (e.RowHandle + 1).ToString();
|
};
|
#endregion
|
}
|
|
/// <summary>
|
/// 获取重量
|
/// </summary>
|
public void GetWeight()
|
{
|
ModbusFactory factory = new ModbusFactory();
|
LogHelper.Debug(this.ToString(), "GetWeight创建modbus对象");
|
IModbusMaster rtuMaster = (IModbusMaster)factory.CreateRtuMaster(this.Sp);
|
bool flag = true;
|
while (true)
|
{
|
//addModel("1", "2");
|
//ToolBox.LogHelper.Debug(this.ToString(), "GetWeight创建modbus对象");
|
try
|
{
|
if (!this.Sp.IsOpen)
|
{
|
LogHelper.Debug(this.ToString(), "GetWeight 重新打开串口连接");
|
this.Sp.Open();
|
rtuMaster = (IModbusMaster)factory.CreateRtuMaster(this.Sp);
|
}
|
if (rtuMaster == null)
|
{
|
LogHelper.Debug(this.ToString(), "GetWeight 重新创建modbus对象2");
|
rtuMaster = (IModbusMaster)factory.CreateRtuMaster(this.Sp);
|
}
|
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')
|
{
|
flag = true;
|
}
|
else if (flag)
|
{
|
flag = false;
|
}
|
addModel(single.ToString(), int32.ToString());
|
LogHelper.Debug(this.ToString(), "single:" + single.ToString() + ",flag:" + flag.ToString() + ",int32:" + int32.ToString());
|
Thread.Sleep(2000);
|
}
|
catch (Exception ex)
|
{
|
Thread.Sleep(2000);
|
}
|
}
|
}
|
/// <summary>
|
/// 上传称重数据
|
/// </summary>
|
/// <param name="_realWeight">截取后的数量</param>
|
/// <param name="_realWeightTxt">原子串</param>
|
private void addModel(string _realWeight, string _realWeightTxt)
|
{
|
string _lineId = comLine.GetId();
|
var _obj = new
|
{
|
lineId = _lineId,
|
realWeight = _realWeight.Trim(),
|
realWeightTxt = _realWeightTxt.Trim(),
|
};
|
try
|
{
|
string strJson = UtilityHelper.HttpPost("", "WorkWeight/EditModel", JsonConvert.SerializeObject(_obj));
|
ReturnModel<dynamic> _rtn = UtilityHelper.ReturnToDynamic(strJson);
|
if (_rtn.rtnCode <= 0)
|
{
|
LogHelper.Debug(this.ToString(), "WorkWeight/EditModel:" + strJson);
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Debug(this.ToString(), ex.Message);
|
}
|
}
|
|
|
/// <summary>
|
/// 更新UI
|
/// </summary>
|
/// <param name="text"></param>
|
|
private void UpdateTextBox(string text)
|
{
|
try
|
{
|
this.txtMsg.Text = "最近获取称重时间:" + DateTime.Now.ToString();
|
if (this.txtNum.Text == text)
|
return;
|
this.txtNum.Text = text;
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Debug(this.ToString(), ex.Message);
|
}
|
}
|
|
private void GetComList()
|
{
|
this.cmbSerialPortNum.Clear();
|
RegistryKey registryKey = Registry.LocalMachine.OpenSubKey("Hardware\\DeviceMap\\SerialComm");
|
if (registryKey == null)
|
return;
|
foreach (string valueName in registryKey.GetValueNames())
|
{
|
string description = (string)registryKey.GetValue(valueName);
|
cmbSerialPortNum.Properties.Items.Add(description);
|
}
|
if (this.cmbSerialPortNum.Properties.Items.Count > 0)
|
this.cmbSerialPortNum.SelectedIndex = 0;
|
}
|
|
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;
|
}
|
|
|
}
|
}
|
