using LB_SmartVisionCommon;
|
using LB_VisionProcesses.Communicators;
|
using LB_VisionProcesses.Communicators.SiemensS7;
|
using LB_VisionProcesses.Communicators.Tcom;
|
using Microsoft.VisualBasic;
|
using OpenVinoSharp.Extensions.model;
|
using ReaLTaiizor.Forms;
|
using RJCP.IO.Ports;
|
using S7.Net;
|
using System.Data;
|
using System.Diagnostics;
|
using System.Linq;
|
using System.Windows.Forms;
|
using YamlDotNet.Core.Tokens;
|
|
namespace LB_SmartVision.Forms.Pages.CommunicatorPage
|
{
|
public delegate void CommunicatorS7Change(BaseCommunicator communicator);
|
public partial class CommunicatorS7Form : Form
|
{
|
BaseCommunicator communicator { get; set; }
|
|
public event CommunicatorS7Change CommunicatorChanged;
|
|
private PlcConfig config;
|
private DataTable signalTable;
|
private BindingSource bindingSource;
|
private string Name;
|
|
private void communicatorChanged(BaseCommunicator communicator)
|
{
|
if (CommunicatorChanged != null)
|
{
|
CommunicatorChanged(communicator);
|
}
|
}
|
|
public CommunicatorS7Form()
|
{
|
InitializeComponent();
|
cmbType.Items.Clear();
|
if (communicator != null && !string.IsNullOrEmpty(communicator.CommunicatorConnections["型号"]?.ToString()))
|
{
|
cmbType.Items.Add(communicator.CommunicatorConnections["型号"]?.ToString());
|
}
|
}
|
|
public CommunicatorS7Form(BaseCommunicator communicator, string name)
|
{
|
InitializeComponent();
|
if (communicator == null)
|
{
|
return;
|
}
|
cmbIP.Enabled = false;
|
txtIP.Enabled = false;
|
txtPort.Enabled = false;
|
|
|
lblType.Visible = false;
|
cmbType.Visible = false;
|
|
Name = name;
|
this.Text = name;
|
if (communicator is SiemensLBS7)
|
{
|
txtIP.Text = communicator.CommunicatorConnections["地址"]?.ToString();
|
txtPort.Text = communicator.CommunicatorConnections["端口"]?.ToString();
|
cmbType.Items.Clear();
|
if (!string.IsNullOrEmpty(communicator.CommunicatorConnections["型号"]?.ToString()))
|
{
|
cmbType.Items.Add(communicator.CommunicatorConnections["型号"]?.ToString());
|
cmbType.Text = communicator.CommunicatorConnections["型号"]?.ToString();
|
}
|
txtIP.Visible = true;
|
cmbIP.Visible = false;
|
lblType.Visible = true;
|
cmbType.Visible = true;
|
|
lblIP.Text = "IP";
|
lblPort.Text = "槽";
|
}
|
|
this.communicator = communicator;
|
//加载回调函数
|
Subscribe();
|
LoadConfigAndSetupGrid();
|
}
|
|
private void CommunicatorForm_FormClosing(object sender, FormClosingEventArgs e) => Unsubscribe();
|
|
public void Unsubscribe()
|
{
|
try
|
{
|
if (communicator == null)
|
{
|
return;
|
}
|
//取消回调函数
|
communicator.MessageReceived -= ShowReceiveMsg;
|
if (communicator != null)
|
{
|
communicatorChanged(communicator);
|
if (GlobalVar.dicCommunicators != null && GlobalVar.dicCommunicators.Keys.Count > 0 && GlobalVar.dicCommunicators.Keys.Contains(communicator.CommunicatorName))
|
{
|
GlobalVar.dicCommunicators[communicator.CommunicatorName] = communicator;
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
// 记录错误信息
|
Debug.WriteLine($"错误: {ex.Message}");
|
}
|
|
}
|
|
public void Subscribe()
|
{
|
try
|
{
|
if (communicator == null)
|
{
|
return;
|
}
|
|
//取消回调函数
|
communicator.MessageReceived -= ShowReceiveMsg;
|
//加载回调函数
|
communicator.MessageReceived += ShowReceiveMsg;
|
}
|
catch (Exception ex)
|
{
|
// 记录错误信息
|
Debug.WriteLine($"错误: {ex.Message}");
|
}
|
}
|
|
/// <summary>
|
/// 通讯回调运行
|
/// </summary>
|
/// <param name="CCDName"></param>
|
/// <param name="image"></param>
|
private void ShowReceiveMsg(string strReceiveMsg)
|
{
|
// 如果当前不是 UI 线程，则通过 Invoke 将操作调度到 UI 线程
|
if (this.InvokeRequired)
|
{
|
this.Invoke(new Action<string>((msg) =>
|
{
|
// 更新 UI 控件，比如显示接收到的消息
|
this.txtReceiveMsg.AppendText(("[接收]" + DateTime.Now.ToString() + "：" + msg));
|
this.txtReceiveMsg.AppendText("\r\n");
|
this.txtReceiveMsg.SelectionStart = this.txtReceiveMsg.Text.Length;
|
this.txtReceiveMsg.ScrollToCaret();
|
}), strReceiveMsg);
|
}
|
else
|
{
|
// 如果已经在 UI 线程上，直接更新 UI
|
this.txtReceiveMsg.AppendText(("[接收]" + DateTime.Now.ToString() + "：" + strReceiveMsg));
|
this.txtReceiveMsg.AppendText("\r\n");
|
this.txtReceiveMsg.SelectionStart = this.txtReceiveMsg.Text.Length;
|
this.txtReceiveMsg.ScrollToCaret();
|
}
|
}
|
|
private void ShowSendMsg(string strSendMsg)
|
{
|
// 如果当前不是 UI 线程，则通过 Invoke 将操作调度到 UI 线程
|
if (this.InvokeRequired)
|
{
|
this.Invoke(new Action<string>((msg) =>
|
{
|
// 更新 UI 控件，比如显示接收到的消息
|
this.txtReceiveMsg.AppendText(("[发送]" + DateTime.Now.ToString() + "：" + msg));
|
this.txtReceiveMsg.AppendText("\r\n");
|
this.txtReceiveMsg.SelectionStart = this.txtReceiveMsg.Text.Length;
|
this.txtReceiveMsg.ScrollToCaret();
|
}), strSendMsg);
|
}
|
else
|
{
|
// 如果已经在 UI 线程上，直接更新 UI
|
this.txtReceiveMsg.AppendText(("[发送]" + DateTime.Now.ToString() + "：" + strSendMsg));
|
this.txtReceiveMsg.AppendText("\r\n");
|
this.txtReceiveMsg.SelectionStart = this.txtReceiveMsg.Text.Length;
|
this.txtReceiveMsg.ScrollToCaret();
|
}
|
}
|
|
private void ShowLogMsg(string msg)
|
{
|
// 如果当前不是 UI 线程，则通过 Invoke 将操作调度到 UI 线程
|
if (this.InvokeRequired)
|
{
|
this.Invoke(new Action<string>((message) =>
|
{
|
this.txtReceiveMsg.AppendText("[" + DateTime.Now.ToString("HH:mm:ss.fff") + "] " + message + "\r\n");
|
this.txtReceiveMsg.ScrollToCaret();
|
}), msg);
|
}
|
else
|
{
|
this.txtReceiveMsg.AppendText("[" + DateTime.Now.ToString("HH:mm:ss.fff") + "] " + msg + "\r\n");
|
this.txtReceiveMsg.ScrollToCaret();
|
}
|
}
|
|
// 批量读取所有信号
|
private void btnReadAll_Click(object sender, EventArgs e)
|
{
|
if (communicator == null || !communicator.bConnected)
|
{
|
MessageBox.Show("请先连接 PLC", "提示", MessageBoxButtons.OK, MessageBoxIcon.Warning);
|
return;
|
}
|
|
try
|
{
|
for (int i = 0; i < config.Signals.Count; i++)
|
{
|
var signal = config.Signals[i];
|
object value = ((SiemensLBS7)communicator).ReadSignal(signal);
|
config.Signals[i].Value= value?.ToString() ?? "";
|
signalTable.Rows[i]["Value"] = config.Signals[i].Value;
|
ShowLogMsg(signalTable.Rows[i]["Value"] + "：" + value?.ToString() ?? "");
|
}
|
}
|
catch (Exception ex)
|
{
|
MessageBox.Show($"批量读取失败: {ex.Message}", "错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
|
}
|
}
|
|
// 批量写入：将表格中修改过的值写入 PLC
|
private void btnWriteAll_Click(object sender, EventArgs e)
|
{
|
if (communicator == null || !communicator.bConnected)
|
{
|
MessageBox.Show("请先连接 PLC", "提示", MessageBoxButtons.OK, MessageBoxIcon.Warning);
|
return;
|
}
|
|
try
|
{
|
int successCount = 0;
|
for (int i = 0; i < config.Signals.Count; i++)
|
{
|
var signal = config.Signals[i];
|
string newValueStr = signalTable.Rows[i]["Value"]?.ToString();
|
if (!string.IsNullOrEmpty(newValueStr))
|
{
|
object convertedValue = ConvertValue(signal.DataType, newValueStr);
|
((SiemensLBS7)communicator).WriteSignal(signal, convertedValue);
|
successCount++;
|
}
|
ShowSendMsg(signalTable.Rows[i]["Value"] + "：" + newValueStr?.ToString() ?? "");
|
}
|
MessageBox.Show($"批量写入完成，成功写入 {successCount} 个信号。", "写入结果", MessageBoxButtons.OK, MessageBoxIcon.Information);
|
}
|
catch (Exception ex)
|
{
|
MessageBox.Show($"批量写入失败: {ex.Message}", "错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
|
}
|
}
|
|
private void btnConfig_Click(object sender, EventArgs e)
|
{
|
using (var configForm = new ConfigForm(config, GlobalVar.allPlcSettingPath + "\\" + this.Name + ".json"))
|
{
|
if (configForm.ShowDialog() == DialogResult.OK)
|
{
|
config = S7ConfigService.LoadConfig(GlobalVar.allPlcSettingPath);
|
LoadConfigAndSetupGrid();
|
UpdateConnectionStatus();
|
}
|
}
|
}
|
|
|
|
// 数据类型转换辅助方法
|
private object ConvertValue(string dataType, string valueStr)
|
{
|
switch (dataType)
|
{
|
case "Bool":
|
{
|
if (bool.TryParse(valueStr, out bool b)) return b;
|
if (valueStr == "1") return true;
|
if (valueStr == "0") return false;
|
throw new Exception("无效的布尔值");
|
}
|
case "Byte":
|
{
|
return byte.Parse(valueStr);
|
}
|
case "Int":
|
{
|
return short.Parse(valueStr);
|
}
|
case "DInt":
|
{
|
return int.Parse(valueStr);
|
}
|
case "Real":
|
{
|
return float.Parse(valueStr);
|
}
|
case "String":
|
{
|
return valueStr;
|
}
|
default:
|
{
|
throw new NotSupportedException($"不支持的类型: {dataType}");
|
}
|
}
|
}
|
private void LoadConfigAndSetupGrid()
|
{
|
config = S7ConfigService.LoadConfig(GlobalVar.allPlcSettingPath + "\\" + this.Name + ".json");
|
|
if (GlobalVar.allPlcSettings.Keys.Contains(Name))
|
{
|
GlobalVar.allPlcSettings[Name] = config;
|
}
|
else
|
{
|
GlobalVar.allPlcSettings.TryAdd(Name, config);
|
}
|
ConfigManager<Dictionary<string, PlcConfig>>.SaveConfig<Dictionary<string, PlcConfig>>(GlobalVar.allPlcSettings, GlobalVar.allPlcSettingsPath);
|
// 构建 DataTable 用于展示信号（支持编辑值列）
|
signalTable = new DataTable();
|
signalTable.Columns.Add("SignalName", typeof(string));
|
signalTable.Columns.Add("Address", typeof(string));
|
signalTable.Columns.Add("Value", typeof(string));
|
|
foreach (var signal in config.Signals)
|
{
|
string address = $"{signal.Area}";
|
if (signal.Area == "DB")
|
address += $"{signal.DbNumber}.DB";
|
address += $"{signal.ByteOffset}.{signal.BitOffset}";
|
|
signalTable.Rows.Add(signal.SignalName, address, "");
|
}
|
|
bindingSource = new BindingSource();
|
bindingSource.DataSource = signalTable;
|
dgvSignals.DataSource = bindingSource;
|
|
dgvSignals.Columns["SignalName"].HeaderText = "信号名称";
|
dgvSignals.Columns["SignalName"].ReadOnly = true;
|
dgvSignals.Columns["Address"].HeaderText = "PLC 地址";
|
dgvSignals.Columns["Address"].ReadOnly = true;
|
dgvSignals.Columns["Value"].HeaderText = "当前值";
|
dgvSignals.Columns["Value"].ReadOnly = false; // 允许用户编辑
|
|
UpdateConnectionStatus();
|
dgvSignals.AutoSizeColumnsMode = DataGridViewAutoSizeColumnsMode.Fill;
|
}
|
|
private void UpdateConnectionStatus()
|
{
|
if (communicator != null && communicator.bConnected)
|
{
|
lblStatus.Text = $"已连接: {config.PlcIpAddress}";
|
lblStatus.ForeColor = Color.Green;
|
}
|
else
|
{
|
lblStatus.Text = "未连接";
|
lblStatus.ForeColor = Color.Red;
|
}
|
}
|
|
// ========== 右键菜单：单信号操作 ==========
|
private SignalConfig GetSelectedSignal()
|
{
|
if (dgvSignals.CurrentRow == null) return null;
|
int index = dgvSignals.CurrentRow.Index;
|
if (index >= 0 && index < config.Signals.Count)
|
return config.Signals[index];
|
return null;
|
}
|
|
private void menuReadSignal_Click(object sender, EventArgs e)
|
{
|
var signal = GetSelectedSignal();
|
if (signal == null) return;
|
|
if (communicator != null && !communicator.bConnected)
|
{
|
MessageBox.Show("请先连接 PLC");
|
return;
|
}
|
|
try
|
{
|
object value = ((SiemensLBS7)communicator).ReadSignal(signal);
|
MessageBox.Show($"信号 [{signal.SignalName}] 当前值: {value}", "读取结果");
|
signalTable.Rows[dgvSignals.CurrentRow.Index]["Value"] = value?.ToString();
|
}
|
catch (Exception ex)
|
{
|
MessageBox.Show($"读取失败: {ex.Message}");
|
}
|
}
|
|
private void menuWriteSignal_Click(object sender, EventArgs e)
|
{
|
var signal = GetSelectedSignal();
|
if (signal == null) return;
|
|
if (communicator != null && !communicator.bConnected)
|
{
|
MessageBox.Show("请先连接 PLC");
|
return;
|
}
|
|
string input = Interaction.InputBox(
|
$"请输入要写入 {signal.SignalName} 的值 ({signal.DataType})",
|
"写入信号", "");
|
if (string.IsNullOrEmpty(input)) return;
|
|
try
|
{
|
object value = ConvertValue(signal.DataType, input);
|
((SiemensLBS7)communicator).WriteSignal(signal, value);
|
MessageBox.Show("写入成功");
|
}
|
catch (Exception ex)
|
{
|
MessageBox.Show($"写入失败: {ex.Message}");
|
}
|
}
|
}
|
}
|
