1 Star 0 Fork 725

五六色/dgiot_dtu

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
MainForm.cs 32.72 KB
一键复制 编辑 原始数据 按行查看 历史
lsxredrain 提交于 2021-12-03 15:03 . add opcda getitems
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927
// <copyright file="MainForm.cs" company="PlaceholderCompany">
// Copyright (c) PlaceholderCompany. All rights reserved.
// </copyright>
namespace Dgiot_dtu
{
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Diagnostics;
using System.Text.RegularExpressions;
using System.Windows.Forms;
public partial class MainForm : Form
{
private delegate void LogHandler(string text);
private LogHelper log = LogHelper.GetInstance();
private MqttClientHelper mqtt = MqttClientHelper.GetInstance();
private TcpClientHelper tcpclient = TcpClientHelper.GetInstance();
private UDPClientHelper udplient = UDPClientHelper.GetInstance();
private SerialPortHelper serialport = SerialPortHelper.GetInstance();
private TcpServerHelper tcpserver = TcpServerHelper.GetInstance();
private PLCHelper plc = PLCHelper.GetInstance();
private OPCDAHelper opcda = OPCDAHelper.GetInstance();
private OPCUAHelper opcua = OPCUAHelper.GetInstance();
private BACnetHelper bacnet = BACnetHelper.GetInstance();
private AccessHelper access = AccessHelper.GetInstance();
private SqlServerHelper sqlserver = SqlServerHelper.GetInstance();
private static string clientid = Guid.NewGuid().ToString().Substring(0, 10);
private static string productid = Guid.NewGuid().ToString().Substring(0, 10);
private static string devaddr = Guid.NewGuid().ToString().Substring(0, 10);
private bool bAutoReconnect = false;
private bool bIsRunning = false;
private readonly string[] bridges = new string[]
{
"SerialPort",
"TcpServer",
"BACnet",
"OPCDA_SCAN",
"OPCDA_READ",
"OPCDA_WRITE",
"OPCUA",
"MqttClient",
"MqttServer",
"TcpClient",
"TcpServer",
"UdpClient",
"UdpServer",
"PLC",
"Control",
"Access",
"SqlServer",
};
private Configuration config;
public MainForm()
{
InitializeComponent();
config = ConfigurationManager.OpenExeConfiguration(ConfigurationUserLevel.None);
LogHelper.Init(this);
SetComboBox();
Text += " v" + System.Reflection.Assembly.GetEntryAssembly().GetName().Version;
try
{
RestoreConfigs(config);
SaveAppConfig();
}
catch (Exception ex)
{
Log("read config exception: " + ex.Message);
}
}
public void Log(string text)
{
if (InvokeRequired)
{
Invoke(new LogHandler(Log), new object[] { text });
return;
}
// Truncate
if (textBoxLog.Text.Length > 4096)
{
textBoxLog.Text = textBoxLog.Text.Substring(textBoxLog.Text.Length - 4096);
}
textBoxLog.Text += text + "\r\n";
textBoxLog.SelectionStart = textBoxLog.Text.Length - 1;
textBoxLog.ScrollToCaret();
}
private void ToStop()
{
try
{
buttonStartStop.Text = @"Start";
bIsRunning = false;
MqttClientHelper.Stop();
MqttServerHelper.Stop();
SerialPortHelper.Stop();
TcpClientHelper.Stop();
TcpServerHelper.Stop();
UDPClientHelper.Stop();
UDPServerHelper.Stop();
BACnetHelper.Stop();
}
catch (Exception e)
{
Log("stop server exception:" + e.Message);
return;
}
}
private void ButtonStartStopClick(object sender, EventArgs e)
{
if (!bIsRunning)
{
bIsRunning = true;
try
{
MqttServerHelper.Start(config.AppSettings.Settings);
MqttClientHelper.Start(config.AppSettings.Settings, bAutoReconnect);
TcpServerHelper.Start(config.AppSettings.Settings);
TcpClientHelper.Start(config.AppSettings.Settings, bAutoReconnect);
UDPServerHelper.Start(config.AppSettings.Settings);
UDPClientHelper.Start(config.AppSettings.Settings, bAutoReconnect);
OPCDAHelper.Start(config.AppSettings.Settings);
BACnetHelper.Start(config.AppSettings.Settings);
}
catch (Exception error)
{
Log("star error " + error.ToString());
return;
}
buttonStartStop.Text = @"Stop";
DgiotHelper.GetIps();
SaveAppConfig();
}
else
{
ToStop();
}
}
private void SetComboBox()
{
var arrPorts = SerialPortHelper.GetPorts();
comboBoxSerialPort.Items.Clear();
foreach (var port in arrPorts)
{
comboBoxSerialPort.Items.Add(port);
}
if (arrPorts.Length > 0)
{
comboBoxSerialPort.SelectedIndex = 0;
}
comboBoxBaudRate.SelectedIndex = 7;
comboBoxDataBits.SelectedIndex = 0;
comboBoxStopBits.SelectedIndex = 0;
comboBoxParity.SelectedIndex = 0;
comboBoxCmdProdxy.SelectedIndex = 0;
comboBoxBridge.Items.Clear();
foreach (var bridge in bridges)
{
comboBoxBridge.Items.Add(bridge);
}
if (bridges.Length > 0)
{
comboBoxBridge.SelectedIndex = 0;
}
bAutoReconnect = checkBoxReconnect.Checked;
comboBoxDevAddr.Items.Clear();
List<string> macAddrs = DgiotHelper.GetMacByWmi();
foreach (var mac in macAddrs)
{
devaddr = Regex.Replace(mac, @":", "");
comboBoxDevAddr.Items.Add(devaddr);
}
comboBoxDevAddr.SelectedIndex = 0;
List<string> opcservers = OPCDAHelper.GetServer();
foreach (var opcserver in opcservers)
{
comboBoxOpcServer.Items.Add(opcserver);
}
if (opcservers.Count > 0)
{
comboBoxOpcServer.SelectedIndex = 0;
}
List<string> loglevels = LogHelper.Levels();
foreach (var level in loglevels)
{
comboBoxLogLevel.Items.Add(level);
}
if (loglevels.Count > 0)
{
comboBoxLogLevel.SelectedIndex = (int)LogHelper.Level.DEBUG;
}
comboBoxLan.Items.Add("简体中文");
comboBoxLan.Items.Add("English");
comboBoxLan.SelectedIndex = 0;
OpcHost();
}
private void OpcHost()
{
DgiotHelper.GetIps().ForEach((ip) =>
{
comboBoxOpcHost.Items.Add(ip);
});
if (comboBoxOpcHost.Items.Count > 0)
{
comboBoxOpcHost.SelectedIndex = 0;
}
SetConfig("OpcHost", comboBoxOpcHost.Text);
}
private void OpcServer()
{
comboBoxOpcServer.Items.Clear();
OPCDAHelper.GetServer().ForEach((server) =>
{
comboBoxOpcServer.Items.Add(server);
});
if (comboBoxOpcServer.Items.Count > 0)
{
comboBoxOpcServer.SelectedIndex = 0;
}
SetConfig("OpcServer", comboBoxOpcServer.Text);
OpcGroup();
}
private void OpcGroup()
{
comboBoxOpcGroup.Items.Clear();
OPCDAHelper.GetGroup().ForEach((group) =>
{
comboBoxOpcGroup.Items.Add(group);
});
if (comboBoxOpcGroup.Items.Count > 0)
{
comboBoxOpcGroup.SelectedIndex = 0;
}
SetConfig("OpcGroup", comboBoxOpcGroup.Text);
OpcItems();
}
private void OpcItems()
{
comboBoxOpcGroup.Items.Clear();
OPCDAHelper.GetItems().ForEach((item) =>
{
comboBoxOpcItem.Items.Add(item);
});
if (comboBoxOpcItem.Items.Count > 0)
{
comboBoxOpcItem.SelectedIndex = 0;
}
SetConfig("OpcItems", comboBoxOpcItem.Text);
}
private void RestoreConfigs(Configuration config)
{
if (config.AppSettings.Settings["portName"] != null)
{
var tmp = config.AppSettings.Settings["portName"].Value;
comboBoxSerialPort.SelectedIndex = comboBoxSerialPort.Items.IndexOf(tmp);
}
if (config.AppSettings.Settings["BaudRate"] != null)
{
var tmp = config.AppSettings.Settings["BaudRate"].Value;
comboBoxBaudRate.SelectedIndex = comboBoxBaudRate.Items.IndexOf(tmp);
}
if (config.AppSettings.Settings["DataBits"] != null)
{
var tmp = config.AppSettings.Settings["DataBits"].Value;
comboBoxDataBits.SelectedIndex = comboBoxDataBits.Items.IndexOf(tmp);
}
if (config.AppSettings.Settings["Parity"] != null)
{
var tmp = config.AppSettings.Settings["Parity"].Value;
comboBoxParity.SelectedIndex = comboBoxParity.Items.IndexOf(tmp);
}
if (config.AppSettings.Settings["StopBits"] != null)
{
var tmp = config.AppSettings.Settings["StopBits"].Value;
comboBoxStopBits.SelectedIndex = comboBoxStopBits.Items.IndexOf(tmp);
}
if (config.AppSettings.Settings["serialPortIsCheck"] != null)
{
comboBoxSerialPort.Text = config.AppSettings.Settings["serialPortIsCheck"].Value;
}
if (config.AppSettings.Settings["cmdProdxy"] != null)
{
comboBoxCmdProdxy.Text = config.AppSettings.Settings["cmdProdxy"].Value;
}
if (config.AppSettings.Settings["toPayload"] != null)
{
this.textToPayload.Text = config.AppSettings.Settings["toPayload"].Value;
}
if (config.AppSettings.Settings["mqttServer"] != null)
{
textBoxMqttSever.Text = config.AppSettings.Settings["mqttServer"].Value;
}
if (config.AppSettings.Settings["mqttPort"] != null)
{
textBoxMqttPort.Text = config.AppSettings.Settings["mqttPort"].Value;
}
if (config.AppSettings.Settings["mqttUserName"] != null)
{
textBoxMqttUserName.Text = config.AppSettings.Settings["mqttUserName"].Value;
}
if (config.AppSettings.Settings["devAddr"] != null)
{
var tmp = config.AppSettings.Settings["devAddr"].Value;
comboBoxDevAddr.SelectedIndex = comboBoxDevAddr.Items.IndexOf(tmp);
}
if (config.AppSettings.Settings["mqttPassword"] != null)
{
textBoxMqttPassword.Text = config.AppSettings.Settings["mqttPassword"].Value;
}
if (config.AppSettings.Settings["mqttPubTopic"] != null)
{
textBoxMqttPubTopic.Text = config.AppSettings.Settings["mqttPubTopic"].Value;
}
if (config.AppSettings.Settings["tcpClientServer"] != null)
{
textBoxTcpClientServer.Text = config.AppSettings.Settings["tcpClientServer"].Value;
}
if (config.AppSettings.Settings["tcpClientPort"] != null)
{
textBoxTcpClientPort.Text = config.AppSettings.Settings["tcpClientPort"].Value;
}
if (config.AppSettings.Settings["tcpClientLogin"] != null)
{
textBoxTcpClientLogin.Text = config.AppSettings.Settings["tcpClientLogin"].Value;
}
if (config.AppSettings.Settings["UDPClientServer"] != null)
{
textBoxUDPClientServer.Text = config.AppSettings.Settings["UDPClientServer"].Value;
}
if (config.AppSettings.Settings["UDPClientPort"] != null)
{
textBoxUDPCLientPort.Text = config.AppSettings.Settings["UDPClientPort"].Value;
}
if (config.AppSettings.Settings["tcpServerPort"] != null)
{
textBoxTcpServerPort.Text = config.AppSettings.Settings["tcpServerPort"].Value;
}
if (config.AppSettings.Settings["tcpServerIsCheck"] != null)
{
checkBoxTcpBridge.Checked = DgiotHelper.StrTobool(config.AppSettings.Settings["tcpServerIsCheck"].Value);
}
if (config.AppSettings.Settings["LogLevel"] != null)
{
var tmp = config.AppSettings.Settings["LogLevel"].Value;
comboBoxLogLevel.SelectedIndex = comboBoxLogLevel.Items.IndexOf(tmp);
}
Resh_Topic();
Resh_Config();
}
private void SetConfig(string key, string value)
{
if (config.AppSettings.Settings[key] == null)
{
config.AppSettings.Settings.Add(key, value);
}
else
{
config.AppSettings.Settings[key].Value = value;
}
Resh_Config();
Resh_Topic();
}
private void Resh_Config()
{
MqttClientHelper.Config(config.AppSettings.Settings);
MqttServerHelper.Config(config.AppSettings.Settings);
TcpClientHelper.Config(config.AppSettings.Settings);
TcpServerHelper.Config(config.AppSettings.Settings);
UDPClientHelper.Config(config.AppSettings.Settings);
UDPServerHelper.Config(config.AppSettings.Settings);
SerialPortHelper.Config(config.AppSettings.Settings);
PLCHelper.Config(config.AppSettings.Settings);
OPCDAHelper.Config(config.AppSettings.Settings);
OPCUAHelper.Config(config.AppSettings.Settings);
AccessHelper.Config(config.AppSettings.Settings);
SqlServerHelper.Config(config.AppSettings.Settings);
}
private void Resh_Topic()
{
devaddr = comboBoxDevAddr.Text;
productid = textBoxMqttUserName.Text;
clientid = DgiotHelper.Md5("Device" + this.textBoxMqttUserName.Text + devaddr).Substring(0, 10);
textBoxMqttClientId.Text = clientid;
textBoxMqttSubTopic.Text = "/" + productid + "/" + devaddr;
textBoxMqttPubTopic.Text = "/" + productid + "/" + devaddr + "/properties/read/reply";
textBoxAccessTopic.Text = "/" + productid + "/" + devaddr + "/child/mdb";
// textBoxOPCDATopic.Text = "/" + productid + "/" + devaddr + "/child/opcda";
textBoxOPCUATopic.Text = "/" + productid + "/" + devaddr + "/child/opcua";
textBoxPLCTopic.Text = "/" + productid + "/" + devaddr + "/child/plc";
textBoxBACnetTopic.Text = "/" + productid + "/" + devaddr + "/child/bacnet";
textBoxControlTopic.Text = "/" + productid + "/" + devaddr + "/child/control";
textBoxSqlServerTopic.Text = "/" + productid + "/" + devaddr + "/child/sqlserver";
}
private void LinkLabel1LinkClicked(object sender, LinkLabelLinkClickedEventArgs e)
{
Process.Start("https://github.com/dgiot/dgiot_dtu");
}
private void ButtonClearClick(object sender, EventArgs e)
{
textBoxLog.Text = "";
}
private void LinkLabel2_LinkClicked(object sender, LinkLabelLinkClickedEventArgs e)
{
Process.Start("https://github.com/dgiot/dgiot_dtu");
}
private void SaveAppConfig()
{
SetConfig("tcpServerIsCheck", DgiotHelper.BoolTostr(checkBoxTcpBridge.Checked));
SetConfig("PLCTopic", textBoxPLCTopic.Text);
SetConfig("OpcHost", textBoxOpcIp.Text);
SetConfig("OpcServer", comboBoxOpcServer.Text);
SetConfig("OpcGroup", comboBoxOpcServer.Text);
SetConfig("OpcItems", comboBoxOpcItem.Text);
SetConfig("OPCUATopic", textBoxOPCUATopic.Text);
SetConfig("BACnetTopic", textBoxBACnetTopic.Text);
SetConfig("ControlTopic", textBoxControlTopic.Text);
SetConfig("AccessTopic", textBoxAccessTopic.Text);
SetConfig("SqlServerTopic", textBoxSqlServerTopic.Text);
SetConfig("mqttIsCheck", DgiotHelper.BoolTostr(radioButtonMqttClient.Checked));
SetConfig("tcpClientIsCheck", DgiotHelper.BoolTostr(radioButtonTcpClient.Checked));
SetConfig("UDPClientIsCheck", DgiotHelper.BoolTostr(radioButtonTcpClient.Checked));
SetConfig("toPayload", textToPayload.Text);
SetConfig("mqttServer", textBoxMqttSever.Text);
SetConfig("mqttPort", textBoxMqttPort.Text);
SetConfig("mqttClientId", textBoxMqttClientId.Text);
SetConfig("devAddr", comboBoxDevAddr.Text);
SetConfig("mqttUserName", textBoxMqttUserName.Text);
SetConfig("mqttPassword", textBoxMqttPassword.Text);
SetConfig("mqttSubTopic", textBoxMqttSubTopic.Text);
SetConfig("mqttPubTopic", textBoxMqttPubTopic.Text);
SetConfig("tcpClientServer", textBoxTcpClientServer.Text);
SetConfig("tcpClientPort", textBoxTcpClientPort.Text);
SetConfig("tcpClientLogin", textBoxTcpClientLogin.Text);
SetConfig("UDPClientServer", textBoxUDPClientServer.Text);
SetConfig("UDPClientPort", textBoxUDPCLientPort.Text);
SetConfig("UDPClientLogin", textBoxUDPClientLogin.Text);
SetConfig("tcpServerPort", textBoxTcpServerPort.Text);
SetConfig("LogLevel", comboBoxLogLevel.Text);
config.Save(ConfigurationSaveMode.Full);
ConfigurationManager.RefreshSection("appSettings");
}
private void CheckBoxReconnectCheckedChanged(object sender, EventArgs e)
{
bAutoReconnect = checkBoxReconnect.Checked;
}
private void CheckBoxDisplayHexCheckedChanged(object sender, EventArgs e)
{
SetConfig("DisplayHex", DgiotHelper.BoolTostr(checkBoxDisplayHex.Checked));
}
private void CheckBoxMqttBridge_CheckedChanged(object sender, EventArgs e)
{
SetConfig("mqttbridgeIsCheck", DgiotHelper.BoolTostr(checkBoxMqttBridge.Checked));
}
private void CheckBoxTcpBridge_CheckedChanged(object sender, EventArgs e)
{
SetConfig("tcpBridgeIsCheck", DgiotHelper.BoolTostr(checkBoxTcpBridge.Checked));
}
private void CheckBoxUdpBridge_CheckedChanged(object sender, EventArgs e)
{
SetConfig("udpBridgeIsCheck", DgiotHelper.BoolTostr(checkBoxUdpBridge.Checked));
}
private void RadioButtonMqttClient_CheckedChanged(object sender, EventArgs e)
{
SetConfig("mqttIsCheck", DgiotHelper.BoolTostr(radioButtonMqttClient.Checked));
}
private void RadioButtonTcpClient_CheckedChanged(object sender, EventArgs e)
{
SetConfig("tcpClientIsCheck", DgiotHelper.BoolTostr(radioButtonTcpClient.Checked));
}
private void TextToPayload_TextChanged(object sender, EventArgs e)
{
SetConfig("toPayload", textToPayload.Text);
}
private void TextBoxMqttSever_TextChanged(object sender, EventArgs e)
{
SetConfig("mqttServer", textBoxMqttSever.Text);
}
private void TextBoxMqttPort_TextChanged(object sender, EventArgs e)
{
SetConfig("mqttPort", textBoxMqttPort.Text);
}
private void TextBoxMqttClientId_TextChanged(object sender, EventArgs e)
{
SetConfig("mqttClientId", textBoxMqttClientId.Text);
}
private void TextBoxMqttUserName_TextChanged(object sender, EventArgs e)
{
SetConfig("mqttUserName", textBoxMqttUserName.Text);
}
private void TextBoxMqttPassword_TextChanged(object sender, EventArgs e)
{
SetConfig("mqttPassword", textBoxMqttPassword.Text);
}
private void TextBoxMqttSubTopic_TextChanged(object sender, EventArgs e)
{
SetConfig("mqttSubTopic", textBoxMqttSubTopic.Text);
}
private void TextBoxMqttPubTopic_TextChanged(object sender, EventArgs e)
{
SetConfig("mqttPubTopic", textBoxMqttPubTopic.Text);
}
private void TextBoxMqttServerPort_TextChanged(object sender, EventArgs e)
{
SetConfig("mqttServerPort", textBoxTcpClientLogin.Text);
}
private void TextBoxTcpClientServer_TextChanged(object sender, EventArgs e)
{
SetConfig("tcpClientServer", textBoxTcpClientServer.Text);
}
private void TextBoxTcpClientPort_TextChanged(object sender, EventArgs e)
{
SetConfig("tcpClientPort", textBoxTcpClientPort.Text);
}
private void TextBoxTcpClientLogin_TextChanged(object sender, EventArgs e)
{
SetConfig("tcpClientLogin", textBoxTcpClientLogin.Text);
}
private void TextBoxTcpServerPort_TextChanged(object sender, EventArgs e)
{
SetConfig("tcpServerPort", textBoxTcpServerPort.Text);
}
private void TextBoxUDPClientServer_TextChanged(object sender, EventArgs e)
{
SetConfig("UDPClientServer", textBoxUDPClientServer.Text);
}
private void TextBoxUDPCLientPort_TextChanged(object sender, EventArgs e)
{
SetConfig("UDPClientPort", textBoxUDPCLientPort.Text);
}
private void TextBoxUDPClientLogin_TextChanged(object sender, EventArgs e)
{
SetConfig("UDPClientLogin", textBoxUDPClientLogin.Text);
}
private void TextBoxUdpServerPort_TextChanged(object sender, EventArgs e)
{
SetConfig("udpServerPort", textBoxUdpServerPort.Text);
}
private void ComboBoxCmdProdxy_SelectedIndexChanged(object sender, EventArgs e)
{
}
private void ComboBoxStopBits_SelectedIndexChanged(object sender, EventArgs e)
{
}
private void ComboBoxParity_SelectedIndexChanged(object sender, EventArgs e)
{
}
private void ComboBoxDataBits_SelectedIndexChanged(object sender, EventArgs e)
{
}
private void ComboBoxDevAddr_SelectedIndexChanged(object sender, EventArgs e)
{
SetConfig("devAddr", comboBoxDevAddr.Text);
}
private void TextBoxPLCTopic_TextChanged(object sender, EventArgs e)
{
SetConfig("PLCTopic", textBoxPLCTopic.Text);
}
private void TextBoxOPCUATopic_TextChanged(object sender, EventArgs e)
{
SetConfig("OPCUATopic", textBoxOPCUATopic.Text);
}
private void TextBoxBACnetTopic_TextChanged(object sender, EventArgs e)
{
SetConfig("BACnetTopic", textBoxBACnetTopic.Text);
}
private void TextBoxControlTopic_TextChanged(object sender, EventArgs e)
{
SetConfig("ControlTopic", textBoxControlTopic.Text);
}
private void TextBoxAccessTopic_TextChanged(object sender, EventArgs e)
{
SetConfig("AccessTopic", textBoxAccessTopic.Text);
}
private void TextBoxSqlServerTopic_TextChanged(object sender, EventArgs e)
{
SetConfig("SqlServerTopic", textBoxSqlServerTopic.Text);
}
private void ComboBoxOpcHost_SelectedIndexChanged(object sender, EventArgs e)
{
SetConfig("OpcHost", comboBoxOpcHost.Text);
OpcServer();
}
private void ComboBoxOpcServer_SelectedIndexChanged(object sender, EventArgs e)
{
SetConfig("OpcServer", comboBoxOpcServer.Text);
OpcGroup();
}
private void ComboBoxOpcGroup_SelectedIndexChanged(object sender, EventArgs e)
{
SetConfig("OpcGroup", comboBoxOpcGroup.Text);
OpcItems();
}
private void ComboBoxOpcItem_SelectedIndexChanged(object sender, EventArgs e)
{
SetConfig("OpcItems", comboBoxOpcItem.Text);
}
private void ComboBoxLogLevel_SelectedIndexChanged(object sender, EventArgs e)
{
SetConfig("LogLevel", comboBoxLogLevel.Text);
LogHelper.SetLevel(comboBoxLogLevel.SelectedIndex);
}
private void ComboBoxBridge_SelectedIndexChanged(object sender, EventArgs e)
{
SetConfig("Bridge", comboBoxBridge.Text);
}
private void SendBridge_Click(object sender, EventArgs e)
{
byte[] payload = LogHelper.Payload(config.AppSettings.Settings["toPayload"].Value.ToCharArray());
LogHelper.Log(bridges[comboBoxBridge.SelectedIndex] + " send [" + LogHelper.Logdata(payload, 0, payload.Length) + "]");
if (bridges[comboBoxBridge.SelectedIndex] == "SerialPort")
{
}
else if (bridges[comboBoxBridge.SelectedIndex] == "TcpServer")
{
TcpServerHelper.Write(payload, 0, payload.Length);
}
else if (bridges[comboBoxBridge.SelectedIndex] == "PLC")
{
}
else if (bridges[comboBoxBridge.SelectedIndex] == "OPCDA_SCAN")
{
OPCDAHelper.Scan();
}
else if (bridges[comboBoxBridge.SelectedIndex] == "OPCDA_READ")
{
}
else if (bridges[comboBoxBridge.SelectedIndex] == "OPCDA_WRITE")
{
OPCDAHelper.Write();
}
else if (bridges[comboBoxBridge.SelectedIndex] == "OPCUA")
{
}
else if (bridges[comboBoxBridge.SelectedIndex] == "BACnet")
{
BACnetHelper.Write(payload, 0, payload.Length);
}
else if (bridges[comboBoxBridge.SelectedIndex] == "Control")
{
}
else if (bridges[comboBoxBridge.SelectedIndex] == "Access")
{
}
else if (bridges[comboBoxBridge.SelectedIndex] == "SqlServer")
{
}
else if (bridges[comboBoxBridge.SelectedIndex] == "MqttClient")
{
MqttClientHelper.Write(payload, 0, payload.Length);
}
else if (bridges[comboBoxBridge.SelectedIndex] == "MqttServer")
{
MqttServerHelper.Write(payload, 0, payload.Length);
}
else if (bridges[comboBoxBridge.SelectedIndex] == "TcpClient")
{
TcpClientHelper.Write(payload, 0, payload.Length);
}
else if (bridges[comboBoxBridge.SelectedIndex] == "UdpClient")
{
}
else
{
}
}
private void ComboBoxLan_SelectedIndexChanged(object sender, EventArgs e)
{
Language(comboBoxLan.SelectedItem.ToString());
}
private void Language(String lan)
{
if (lan == "English")
{
En();
}
else
{
Zh();
}
}
private void Zh()
{
sendBridge.Text = "发送";
buttonClear.Text = "清除";
buttonStartStop.Text = "开始";
checkBoxReconnect.Text = "自动重连";
label3.Text = "作者:";
label33.Text = "语言";
label32.Text = "日志级别";
label7.Text = "发至";
label2.Text = "发至";
label19.Text = "发至";
label23.Text = "发至";
label8.Text = "发至";
label6.Text = "发至";
label14.Text = "发至";
groupBoxSerialPort.Text = "串口捕获";
groupBox12.Text = "PLC 捕获";
groupBox4.Text = "OPC_DA 捕获";
groupBox5.Text = "OPC_UA 捕获";
groupBox6.Text = "BACnet 捕获";
groupBox7.Text = "控制捕获";
groupBox8.Text = "访问捕获";
groupBox9.Text = "Sql Server 捕获";
labelSerialPort.Text = "端口";
label1.Text = "波特率";
label4.Text = "数据位";
label13.Text = "校验位";
label5.Text = "停止位";
label31.Text = "扫描";
label25.Text = "服务";
groupBox3.Text = "Mqtt 客户端通道";
label22.Text = "服务";
label21.Text = "端口";
label9.Text = "用户名";
label10.Text = "密码";
label30.Text = "开发地址";
label20.Text = "客户编号";
label11.Text = "订阅主题";
label12.Text = "发布主题";
label29.Text = "命令行代理";
label27.Text = "桥接";
groupBox2.Text = "TCP 客户端通道";
label18.Text = "服务";
label17.Text = "端口";
label16.Text = "登录";
labelTargetPort.Text = "桥接";
groupBox10.Text = "UDP 客户端通道";
label26.Text = "服务";
label24.Text = "端口";
label15.Text = "登录";
label28.Text = "桥接";
}
private void En()
{
sendBridge.Text = "Send";
buttonClear.Text = "Clear";
buttonStartStop.Text = "Start";
label32.Text = "Level";
checkBoxReconnect.Text = "Auto Reconnect";
label3.Text = "Author:";
label33.Text = "Language";
label7.Text = "To";
label2.Text = "To";
label19.Text = "To";
label23.Text = "To";
label8.Text = "To";
label6.Text = "To";
label14.Text = "To";
groupBoxSerialPort.Text = "Serial Port Capture";
groupBox12.Text = "PLC Capture";
groupBox4.Text = "OPC_DA Capture";
groupBox5.Text = "OPC_UA Capture";
groupBox6.Text = "BACnet Capture";
groupBox7.Text = "Control Capture";
groupBox8.Text = "Access Capture";
groupBox9.Text = "Sql Server Capture";
labelSerialPort.Text = "Port";
label1.Text = "Baud Rate";
label4.Text = "dataBits";
label13.Text = "Parity";
label5.Text = "stopBits";
label31.Text = "Scan";
label25.Text = "Server";
groupBox3.Text = "Mqtt Client Channel";
label22.Text = "Server";
label21.Text = "Port";
label9.Text = "UserName";
label10.Text = "PassWord";
label30.Text = "DevAddr";
label20.Text = "Clientid";
label11.Text = "SubTopic";
label12.Text = "PubTopic";
label29.Text = "cmd proxy";
label27.Text = "bridge";
groupBox2.Text = "TCP Client Channel";
label18.Text = "Server";
label17.Text = "Port";
label16.Text = "login";
labelTargetPort.Text = "bridge";
groupBox10.Text = "UDP Client Channel";
label26.Text = "Server";
label24.Text = "Port";
label15.Text = "login";
label28.Text = "bridge";
}
}
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
C#
1
https://gitee.com/tmhx90775614/dgiot_dtu.git
git@gitee.com:tmhx90775614/dgiot_dtu.git
tmhx90775614
dgiot_dtu
dgiot_dtu
master

搜索帮助