diff --git a/Form1.Designer.cs b/Form1.Designer.cs
index 1a1e333..ca1d4c3 100644
--- a/Form1.Designer.cs
+++ b/Form1.Designer.cs
@@ -22,333 +22,273 @@ partial class Form1
#region Windows Form Designer generated code
+ private System.Windows.Forms.GroupBox groupBoxGPS;
+ private System.Windows.Forms.ComboBox comboBoxGPSPort;
+ private System.Windows.Forms.Label labelGPSPort;
+ private System.Windows.Forms.GroupBox groupBoxSpectrometer;
+ private System.Windows.Forms.NumericUpDown numericUpDownRefreshInterval;
+ private System.Windows.Forms.Label labelRefreshInterval;
+ private System.Windows.Forms.ComboBox comboBoxSpectrometerPort;
+ private System.Windows.Forms.Label labelSpectrometerPort;
+ private System.Windows.Forms.GroupBox groupBoxMQTT;
+ private System.Windows.Forms.TextBox textBoxDeviceSecret;
+ private System.Windows.Forms.Label labelDeviceSecret;
+ private System.Windows.Forms.TextBox textBoxDeviceName;
+ private System.Windows.Forms.Label labelDeviceName;
+ private System.Windows.Forms.TextBox textBoxTopicRoot;
+ private System.Windows.Forms.Label labelTopicRoot;
+ private System.Windows.Forms.TextBox textBoxProductKey;
+ private System.Windows.Forms.Label labelProductKey;
+ private System.Windows.Forms.Button buttonStartStop;
+ private System.Windows.Forms.TextBox textBoxLog;
+ private System.Windows.Forms.Label labelLog;
+
///
/// Required method for Designer support - do not modify
/// the contents of this method with the code editor.
///
private void InitializeComponent()
{
- this.groupBox1 = new System.Windows.Forms.GroupBox();
- this.cmbPort1 = new System.Windows.Forms.ComboBox();
- this.cmbBaud1 = new System.Windows.Forms.ComboBox();
- this.btnConnect1 = new System.Windows.Forms.Button();
- this.lblPort1 = new System.Windows.Forms.Label();
- this.lblBaud1 = new System.Windows.Forms.Label();
- this.groupBox2 = new System.Windows.Forms.GroupBox();
- this.cmbPort2 = new System.Windows.Forms.ComboBox();
- this.cmbBaud2 = new System.Windows.Forms.ComboBox();
- this.btnConnect2 = new System.Windows.Forms.Button();
- this.lblPort2 = new System.Windows.Forms.Label();
- this.lblBaud2 = new System.Windows.Forms.Label();
- this.groupBox3 = new System.Windows.Forms.GroupBox();
- this.txtUrl = new System.Windows.Forms.TextBox();
- this.lblUrl = new System.Windows.Forms.Label();
- this.btnStartUpload = new System.Windows.Forms.Button();
- this.btnStopUpload = new System.Windows.Forms.Button();
- this.groupBox4 = new System.Windows.Forms.GroupBox();
- this.txtLog = new System.Windows.Forms.TextBox();
- this.btnClearLog = new System.Windows.Forms.Button();
- this.btnSaveLog = new System.Windows.Forms.Button();
- this.statusStrip1 = new System.Windows.Forms.StatusStrip();
- this.toolStripStatusLabel1 = new System.Windows.Forms.ToolStripStatusLabel();
- this.groupBox1.SuspendLayout();
- this.groupBox2.SuspendLayout();
- this.groupBox3.SuspendLayout();
- this.groupBox4.SuspendLayout();
- this.statusStrip1.SuspendLayout();
+ this.groupBoxGPS = new System.Windows.Forms.GroupBox();
+ this.comboBoxGPSPort = new System.Windows.Forms.ComboBox();
+ this.labelGPSPort = new System.Windows.Forms.Label();
+ this.groupBoxSpectrometer = new System.Windows.Forms.GroupBox();
+ this.numericUpDownRefreshInterval = new System.Windows.Forms.NumericUpDown();
+ this.labelRefreshInterval = new System.Windows.Forms.Label();
+ this.comboBoxSpectrometerPort = new System.Windows.Forms.ComboBox();
+ this.labelSpectrometerPort = new System.Windows.Forms.Label();
+ this.groupBoxMQTT = new System.Windows.Forms.GroupBox();
+ this.textBoxDeviceSecret = new System.Windows.Forms.TextBox();
+ this.labelDeviceSecret = new System.Windows.Forms.Label();
+ this.textBoxDeviceName = new System.Windows.Forms.TextBox();
+ this.labelDeviceName = new System.Windows.Forms.Label();
+ this.textBoxTopicRoot = new System.Windows.Forms.TextBox();
+ this.labelTopicRoot = new System.Windows.Forms.Label();
+ this.textBoxProductKey = new System.Windows.Forms.TextBox();
+ this.labelProductKey = new System.Windows.Forms.Label();
+ this.buttonStartStop = new System.Windows.Forms.Button();
+ this.textBoxLog = new System.Windows.Forms.TextBox();
+ this.labelLog = new System.Windows.Forms.Label();
+ this.groupBoxGPS.SuspendLayout();
+ this.groupBoxSpectrometer.SuspendLayout();
+ ((System.ComponentModel.ISupportInitialize)(this.numericUpDownRefreshInterval)).BeginInit();
+ this.groupBoxMQTT.SuspendLayout();
this.SuspendLayout();
//
- // groupBox1
+ // groupBoxGPS
//
- this.groupBox1.Controls.Add(this.lblBaud1);
- this.groupBox1.Controls.Add(this.lblPort1);
- this.groupBox1.Controls.Add(this.btnConnect1);
- this.groupBox1.Controls.Add(this.cmbBaud1);
- this.groupBox1.Controls.Add(this.cmbPort1);
- this.groupBox1.Location = new System.Drawing.Point(12, 12);
- this.groupBox1.Name = "groupBox1";
- this.groupBox1.Size = new System.Drawing.Size(200, 120);
- this.groupBox1.TabIndex = 0;
- this.groupBox1.TabStop = false;
- this.groupBox1.Text = "串口1";
+ this.groupBoxGPS.Controls.Add(this.comboBoxGPSPort);
+ this.groupBoxGPS.Controls.Add(this.labelGPSPort);
+ this.groupBoxGPS.Location = new System.Drawing.Point(12, 12);
+ this.groupBoxGPS.Name = "groupBoxGPS";
+ this.groupBoxGPS.Size = new System.Drawing.Size(200, 80);
+ this.groupBoxGPS.TabIndex = 0;
+ this.groupBoxGPS.TabStop = false;
+ this.groupBoxGPS.Text = "GPS设置";
//
- // cmbPort1
+ // comboBoxGPSPort
//
- this.cmbPort1.DropDownStyle = System.Windows.Forms.ComboBoxStyle.DropDownList;
- this.cmbPort1.FormattingEnabled = true;
- this.cmbPort1.Location = new System.Drawing.Point(60, 25);
- this.cmbPort1.Name = "cmbPort1";
- this.cmbPort1.Size = new System.Drawing.Size(121, 23);
- this.cmbPort1.TabIndex = 0;
+ this.comboBoxGPSPort.FormattingEnabled = true;
+ this.comboBoxGPSPort.Location = new System.Drawing.Point(70, 30);
+ this.comboBoxGPSPort.Name = "comboBoxGPSPort";
+ this.comboBoxGPSPort.Size = new System.Drawing.Size(121, 28);
+ this.comboBoxGPSPort.TabIndex = 1;
//
- // cmbBaud1
+ // labelGPSPort
//
- this.cmbBaud1.DropDownStyle = System.Windows.Forms.ComboBoxStyle.DropDownList;
- this.cmbBaud1.FormattingEnabled = true;
- this.cmbBaud1.Items.AddRange(new object[] {
- "9600",
- "19200",
- "38400",
- "57600",
- "115200"});
- this.cmbBaud1.Location = new System.Drawing.Point(60, 54);
- this.cmbBaud1.Name = "cmbBaud1";
- this.cmbBaud1.Size = new System.Drawing.Size(121, 23);
- this.cmbBaud1.TabIndex = 1;
+ this.labelGPSPort.AutoSize = true;
+ this.labelGPSPort.Location = new System.Drawing.Point(6, 33);
+ this.labelGPSPort.Name = "labelGPSPort";
+ this.labelGPSPort.Size = new System.Drawing.Size(54, 20);
+ this.labelGPSPort.TabIndex = 0;
+ this.labelGPSPort.Text = "串口：";
//
- // btnConnect1
+ // groupBoxSpectrometer
//
- this.btnConnect1.Location = new System.Drawing.Point(60, 83);
- this.btnConnect1.Name = "btnConnect1";
- this.btnConnect1.Size = new System.Drawing.Size(75, 23);
- this.btnConnect1.TabIndex = 2;
- this.btnConnect1.Text = "连接";
- this.btnConnect1.UseVisualStyleBackColor = true;
- this.btnConnect1.Click += new System.EventHandler(this.btnConnect1_Click);
+ this.groupBoxSpectrometer.Controls.Add(this.numericUpDownRefreshInterval);
+ this.groupBoxSpectrometer.Controls.Add(this.labelRefreshInterval);
+ this.groupBoxSpectrometer.Controls.Add(this.comboBoxSpectrometerPort);
+ this.groupBoxSpectrometer.Controls.Add(this.labelSpectrometerPort);
+ this.groupBoxSpectrometer.Location = new System.Drawing.Point(230, 12);
+ this.groupBoxSpectrometer.Name = "groupBoxSpectrometer";
+ this.groupBoxSpectrometer.Size = new System.Drawing.Size(250, 80);
+ this.groupBoxSpectrometer.TabIndex = 1;
+ this.groupBoxSpectrometer.TabStop = false;
+ this.groupBoxSpectrometer.Text = "谱仪设置";
//
- // lblPort1
+ // numericUpDownRefreshInterval
//
- this.lblPort1.AutoSize = true;
- this.lblPort1.Location = new System.Drawing.Point(15, 28);
- this.lblPort1.Name = "lblPort1";
- this.lblPort1.Size = new System.Drawing.Size(32, 15);
- this.lblPort1.TabIndex = 3;
- this.lblPort1.Text = "端口";
+ this.numericUpDownRefreshInterval.Location = new System.Drawing.Point(190, 50);
+ this.numericUpDownRefreshInterval.Maximum = new decimal(new int[] { 60, 0, 0, 0 });
+ this.numericUpDownRefreshInterval.Minimum = new decimal(new int[] { 1, 0, 0, 0 });
+ this.numericUpDownRefreshInterval.Name = "numericUpDownRefreshInterval";
+ this.numericUpDownRefreshInterval.Size = new System.Drawing.Size(50, 27);
+ this.numericUpDownRefreshInterval.TabIndex = 3;
+ this.numericUpDownRefreshInterval.Value = new decimal(new int[] { 1, 0, 0, 0 });
//
- // lblBaud1
+ // labelRefreshInterval
//
- this.lblBaud1.AutoSize = true;
- this.lblBaud1.Location = new System.Drawing.Point(15, 57);
- this.lblBaud1.Name = "lblBaud1";
- this.lblBaud1.Size = new System.Drawing.Size(44, 15);
- this.lblBaud1.TabIndex = 4;
- this.lblBaud1.Text = "波特率";
+ this.labelRefreshInterval.AutoSize = true;
+ this.labelRefreshInterval.Location = new System.Drawing.Point(6, 52);
+ this.labelRefreshInterval.Name = "labelRefreshInterval";
+ this.labelRefreshInterval.Size = new System.Drawing.Size(178, 20);
+ this.labelRefreshInterval.TabIndex = 2;
+ this.labelRefreshInterval.Text = "刷新间隔(秒)：";
//
- // groupBox2
+ // comboBoxSpectrometerPort
//
- this.groupBox2.Controls.Add(this.lblBaud2);
- this.groupBox2.Controls.Add(this.lblPort2);
- this.groupBox2.Controls.Add(this.btnConnect2);
- this.groupBox2.Controls.Add(this.cmbBaud2);
- this.groupBox2.Controls.Add(this.cmbPort2);
- this.groupBox2.Location = new System.Drawing.Point(230, 12);
- this.groupBox2.Name = "groupBox2";
- this.groupBox2.Size = new System.Drawing.Size(200, 120);
- this.groupBox2.TabIndex = 1;
- this.groupBox2.TabStop = false;
- this.groupBox2.Text = "串口2";
+ this.comboBoxSpectrometerPort.FormattingEnabled = true;
+ this.comboBoxSpectrometerPort.Location = new System.Drawing.Point(70, 20);
+ this.comboBoxSpectrometerPort.Name = "comboBoxSpectrometerPort";
+ this.comboBoxSpectrometerPort.Size = new System.Drawing.Size(121, 28);
+ this.comboBoxSpectrometerPort.TabIndex = 1;
//
- // cmbPort2
+ // labelSpectrometerPort
//
- this.cmbPort2.DropDownStyle = System.Windows.Forms.ComboBoxStyle.DropDownList;
- this.cmbPort2.FormattingEnabled = true;
- this.cmbPort2.Location = new System.Drawing.Point(60, 25);
- this.cmbPort2.Name = "cmbPort2";
- this.cmbPort2.Size = new System.Drawing.Size(121, 23);
- this.cmbPort2.TabIndex = 0;
+ this.labelSpectrometerPort.AutoSize = true;
+ this.labelSpectrometerPort.Location = new System.Drawing.Point(6, 23);
+ this.labelSpectrometerPort.Name = "labelSpectrometerPort";
+ this.labelSpectrometerPort.Size = new System.Drawing.Size(54, 20);
+ this.labelSpectrometerPort.TabIndex = 0;
+ this.labelSpectrometerPort.Text = "串口：";
//
- // cmbBaud2
+ // groupBoxMQTT
//
- this.cmbBaud2.DropDownStyle = System.Windows.Forms.ComboBoxStyle.DropDownList;
- this.cmbBaud2.FormattingEnabled = true;
- this.cmbBaud2.Items.AddRange(new object[] {
- "9600",
- "19200",
- "38400",
- "57600",
- "115200"});
- this.cmbBaud2.Location = new System.Drawing.Point(60, 54);
- this.cmbBaud2.Name = "cmbBaud2";
- this.cmbBaud2.Size = new System.Drawing.Size(121, 23);
- this.cmbBaud2.TabIndex = 1;
+ this.groupBoxMQTT.Controls.Add(this.textBoxDeviceSecret);
+ this.groupBoxMQTT.Controls.Add(this.labelDeviceSecret);
+ this.groupBoxMQTT.Controls.Add(this.textBoxDeviceName);
+ this.groupBoxMQTT.Controls.Add(this.labelDeviceName);
+ this.groupBoxMQTT.Controls.Add(this.textBoxTopicRoot);
+ this.groupBoxMQTT.Controls.Add(this.labelTopicRoot);
+ this.groupBoxMQTT.Controls.Add(this.textBoxProductKey);
+ this.groupBoxMQTT.Controls.Add(this.labelProductKey);
+ this.groupBoxMQTT.Location = new System.Drawing.Point(500, 12);
+ this.groupBoxMQTT.Name = "groupBoxMQTT";
+ this.groupBoxMQTT.Size = new System.Drawing.Size(300, 150);
+ this.groupBoxMQTT.TabIndex = 2;
+ this.groupBoxMQTT.TabStop = false;
+ this.groupBoxMQTT.Text = "MQTT设置";
//
- // btnConnect2
+ // textBoxDeviceSecret
//
- this.btnConnect2.Location = new System.Drawing.Point(60, 83);
- this.btnConnect2.Name = "btnConnect2";
- this.btnConnect2.Size = new System.Drawing.Size(75, 23);
- this.btnConnect2.TabIndex = 2;
- this.btnConnect2.Text = "连接";
- this.btnConnect2.UseVisualStyleBackColor = true;
- this.btnConnect2.Click += new System.EventHandler(this.btnConnect2_Click);
+ this.textBoxDeviceSecret.Location = new System.Drawing.Point(100, 115);
+ this.textBoxDeviceSecret.Name = "textBoxDeviceSecret";
+ this.textBoxDeviceSecret.Size = new System.Drawing.Size(190, 27);
+ this.textBoxDeviceSecret.TabIndex = 7;
+ this.textBoxDeviceSecret.Text = "1031a49a4f61c29a086f79b41ed971c7";
//
- // lblPort2
+ // labelDeviceSecret
//
- this.lblPort2.AutoSize = true;
- this.lblPort2.Location = new System.Drawing.Point(15, 28);
- this.lblPort2.Name = "lblPort2";
- this.lblPort2.Size = new System.Drawing.Size(32, 15);
- this.lblPort2.TabIndex = 3;
- this.lblPort2.Text = "端口";
+ this.labelDeviceSecret.AutoSize = true;
+ this.labelDeviceSecret.Location = new System.Drawing.Point(6, 118);
+ this.labelDeviceSecret.Name = "labelDeviceSecret";
+ this.labelDeviceSecret.Size = new System.Drawing.Size(88, 20);
+ this.labelDeviceSecret.TabIndex = 6;
+ this.labelDeviceSecret.Text = "设备密钥：";
//
- // lblBaud2
+ // textBoxDeviceName
//
- this.lblBaud2.AutoSize = true;
- this.lblBaud2.Location = new System.Drawing.Point(15, 57);
- this.lblBaud2.Name = "lblBaud2";
- this.lblBaud2.Size = new System.Drawing.Size(44, 15);
- this.lblBaud2.TabIndex = 4;
- this.lblBaud2.Text = "波特率";
+ this.textBoxDeviceName.Location = new System.Drawing.Point(100, 85);
+ this.textBoxDeviceName.Name = "textBoxDeviceName";
+ this.textBoxDeviceName.Size = new System.Drawing.Size(190, 27);
+ this.textBoxDeviceName.TabIndex = 5;
+ this.textBoxDeviceName.Text = "PubDevice";
//
- // groupBox3
+ // labelDeviceName
//
- this.groupBox3.Controls.Add(this.btnStopUpload);
- this.groupBox3.Controls.Add(this.btnStartUpload);
- this.groupBox3.Controls.Add(this.lblUrl);
- this.groupBox3.Controls.Add(this.txtUrl);
- this.groupBox3.Location = new System.Drawing.Point(450, 12);
- this.groupBox3.Name = "groupBox3";
- this.groupBox3.Size = new System.Drawing.Size(320, 120);
- this.groupBox3.TabIndex = 2;
- this.groupBox3.TabStop = false;
- this.groupBox3.Text = "数据上传";
+ this.labelDeviceName.AutoSize = true;
+ this.labelDeviceName.Location = new System.Drawing.Point(6, 88);
+ this.labelDeviceName.Name = "labelDeviceName";
+ this.labelDeviceName.Size = new System.Drawing.Size(88, 20);
+ this.labelDeviceName.TabIndex = 4;
+ this.labelDeviceName.Text = "设备名称：";
//
- // txtUrl
+ // textBoxTopicRoot
//
- this.txtUrl.Location = new System.Drawing.Point(15, 40);
- this.txtUrl.Name = "txtUrl";
- this.txtUrl.Size = new System.Drawing.Size(290, 23);
- this.txtUrl.TabIndex = 0;
- this.txtUrl.Text = "http://localhost:8080/api/data";
+ this.textBoxTopicRoot.Location = new System.Drawing.Point(100, 55);
+ this.textBoxTopicRoot.Name = "textBoxTopicRoot";
+ this.textBoxTopicRoot.Size = new System.Drawing.Size(190, 27);
+ this.textBoxTopicRoot.TabIndex = 3;
+ this.textBoxTopicRoot.Text = "a10inDdCRS6";
//
- // lblUrl
+ // labelTopicRoot
//
- this.lblUrl.AutoSize = true;
- this.lblUrl.Location = new System.Drawing.Point(15, 22);
- this.lblUrl.Name = "lblUrl";
- this.lblUrl.Size = new System.Drawing.Size(56, 15);
- this.lblUrl.TabIndex = 1;
- this.lblUrl.Text = "上传地址";
+ this.labelTopicRoot.AutoSize = true;
+ this.labelTopicRoot.Location = new System.Drawing.Point(6, 58);
+ this.labelTopicRoot.Name = "labelTopicRoot";
+ this.labelTopicRoot.Size = new System.Drawing.Size(88, 20);
+ this.labelTopicRoot.TabIndex = 2;
+ this.labelTopicRoot.Text = "主题根路径：";
//
- // btnStartUpload
+ // textBoxProductKey
//
- this.btnStartUpload.Location = new System.Drawing.Point(15, 80);
- this.btnStartUpload.Name = "btnStartUpload";
- this.btnStartUpload.Size = new System.Drawing.Size(75, 23);
- this.btnStartUpload.TabIndex = 2;
- this.btnStartUpload.Text = "开始上传";
- this.btnStartUpload.UseVisualStyleBackColor = true;
- this.btnStartUpload.Click += new System.EventHandler(this.btnStartUpload_Click);
+ this.textBoxProductKey.Location = new System.Drawing.Point(100, 25);
+ this.textBoxProductKey.Name = "textBoxProductKey";
+ this.textBoxProductKey.Size = new System.Drawing.Size(190, 27);
+ this.textBoxProductKey.TabIndex = 1;
+ this.textBoxProductKey.Text = "gfcq950RDqt";
//
- // btnStopUpload
+ // labelProductKey
//
- this.btnStopUpload.Location = new System.Drawing.Point(110, 80);
- this.btnStopUpload.Name = "btnStopUpload";
- this.btnStopUpload.Size = new System.Drawing.Size(75, 23);
- this.btnStopUpload.TabIndex = 3;
- this.btnStopUpload.Text = "停止上传";
- this.btnStopUpload.UseVisualStyleBackColor = true;
- this.btnStopUpload.Click += new System.EventHandler(this.btnStopUpload_Click);
+ this.labelProductKey.AutoSize = true;
+ this.labelProductKey.Location = new System.Drawing.Point(6, 28);
+ this.labelProductKey.Name = "labelProductKey";
+ this.labelProductKey.Size = new System.Drawing.Size(88, 20);
+ this.labelProductKey.TabIndex = 0;
+ this.labelProductKey.Text = "产品密钥：";
//
- // groupBox4
+ // buttonStartStop
//
- this.groupBox4.Controls.Add(this.btnSaveLog);
- this.groupBox4.Controls.Add(this.btnClearLog);
- this.groupBox4.Controls.Add(this.txtLog);
- this.groupBox4.Location = new System.Drawing.Point(12, 150);
- this.groupBox4.Name = "groupBox4";
- this.groupBox4.Size = new System.Drawing.Size(758, 270);
- this.groupBox4.TabIndex = 3;
- this.groupBox4.TabStop = false;
- this.groupBox4.Text = "数据日志";
+ this.buttonStartStop.Font = new System.Drawing.Font("Microsoft YaHei UI", 12F, System.Drawing.FontStyle.Bold, System.Drawing.GraphicsUnit.Point);
+ this.buttonStartStop.Location = new System.Drawing.Point(12, 110);
+ this.buttonStartStop.Name = "buttonStartStop";
+ this.buttonStartStop.Size = new System.Drawing.Size(120, 50);
+ this.buttonStartStop.TabIndex = 3;
+ this.buttonStartStop.Text = "开始";
+ this.buttonStartStop.UseVisualStyleBackColor = true;
+ this.buttonStartStop.Click += new System.EventHandler(this.buttonStartStop_Click);
//
- // txtLog
+ // textBoxLog
//
- this.txtLog.Location = new System.Drawing.Point(15, 22);
- this.txtLog.Multiline = true;
- this.txtLog.Name = "txtLog";
- this.txtLog.ReadOnly = true;
- this.txtLog.ScrollBars = System.Windows.Forms.ScrollBars.Vertical;
- this.txtLog.Size = new System.Drawing.Size(728, 210);
- this.txtLog.TabIndex = 0;
+ this.textBoxLog.Location = new System.Drawing.Point(12, 200);
+ this.textBoxLog.Multiline = true;
+ this.textBoxLog.Name = "textBoxLog";
+ this.textBoxLog.ReadOnly = true;
+ this.textBoxLog.ScrollBars = System.Windows.Forms.ScrollBars.Vertical;
+ this.textBoxLog.Size = new System.Drawing.Size(788, 250);
+ this.textBoxLog.TabIndex = 4;
//
- // btnClearLog
+ // labelLog
//
- this.btnClearLog.Location = new System.Drawing.Point(15, 238);
- this.btnClearLog.Name = "btnClearLog";
- this.btnClearLog.Size = new System.Drawing.Size(75, 23);
- this.btnClearLog.TabIndex = 1;
- this.btnClearLog.Text = "清空日志";
- this.btnClearLog.UseVisualStyleBackColor = true;
- this.btnClearLog.Click += new System.EventHandler(this.btnClearLog_Click);
- //
- // btnSaveLog
- //
- this.btnSaveLog.Location = new System.Drawing.Point(110, 238);
- this.btnSaveLog.Name = "btnSaveLog";
- this.btnSaveLog.Size = new System.Drawing.Size(75, 23);
- this.btnSaveLog.TabIndex = 2;
- this.btnSaveLog.Text = "保存日志";
- this.btnSaveLog.UseVisualStyleBackColor = true;
- this.btnSaveLog.Click += new System.EventHandler(this.btnSaveLog_Click);
- //
- // statusStrip1
- //
- this.statusStrip1.Items.AddRange(new System.Windows.Forms.ToolStripItem[] {
- this.toolStripStatusLabel1});
- this.statusStrip1.Location = new System.Drawing.Point(0, 428);
- this.statusStrip1.Name = "statusStrip1";
- this.statusStrip1.Size = new System.Drawing.Size(784, 22);
- this.statusStrip1.TabIndex = 4;
- this.statusStrip1.Text = "statusStrip1";
- //
- // toolStripStatusLabel1
- //
- this.toolStripStatusLabel1.Name = "toolStripStatusLabel1";
- this.toolStripStatusLabel1.Size = new System.Drawing.Size(32, 17);
- this.toolStripStatusLabel1.Text = "就绪";
+ this.labelLog.AutoSize = true;
+ this.labelLog.Location = new System.Drawing.Point(12, 177);
+ this.labelLog.Name = "labelLog";
+ this.labelLog.Size = new System.Drawing.Size(69, 20);
+ this.labelLog.TabIndex = 5;
+ this.labelLog.Text = "数据日志";
//
// Form1
//
- this.AutoScaleDimensions = new System.Drawing.SizeF(7F, 15F);
+ this.AutoScaleDimensions = new System.Drawing.SizeF(8F, 20F);
this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
- this.ClientSize = new System.Drawing.Size(784, 450);
- this.Controls.Add(this.statusStrip1);
- this.Controls.Add(this.groupBox4);
- this.Controls.Add(this.groupBox3);
- this.Controls.Add(this.groupBox2);
- this.Controls.Add(this.groupBox1);
- this.Name = "Form1";
- this.Text = "串口数据采集与上传系统";
- this.FormClosing += new System.Windows.Forms.FormClosingEventHandler(this.Form1_FormClosing);
- this.Load += new System.EventHandler(this.Form1_Load);
- this.groupBox1.ResumeLayout(false);
- this.groupBox1.PerformLayout();
- this.groupBox2.ResumeLayout(false);
- this.groupBox2.PerformLayout();
- this.groupBox3.ResumeLayout(false);
- this.groupBox3.PerformLayout();
- this.groupBox4.ResumeLayout(false);
- this.groupBox4.PerformLayout();
- this.statusStrip1.ResumeLayout(false);
- this.statusStrip1.PerformLayout();
+ this.ClientSize = new System.Drawing.Size(820, 470);
+ this.Controls.Add(this.labelLog);
+ this.Controls.Add(this.textBoxLog);
+ this.Controls.Add(this.buttonStartStop);
+ this.Controls.Add(this.groupBoxMQTT);
+ this.Controls.Add(this.groupBoxSpectrometer);
+ this.Controls.Add(this.groupBoxGPS);
+ this.Text = "串口数据采集与MQTT发送";
+ this.groupBoxGPS.ResumeLayout(false);
+ this.groupBoxGPS.PerformLayout();
+ this.groupBoxSpectrometer.ResumeLayout(false);
+ this.groupBoxSpectrometer.PerformLayout();
+ ((System.ComponentModel.ISupportInitialize)(this.numericUpDownRefreshInterval)).EndInit();
+ this.groupBoxMQTT.ResumeLayout(false);
+ this.groupBoxMQTT.PerformLayout();
this.ResumeLayout(false);
this.PerformLayout();
}
#endregion
-
- private System.Windows.Forms.GroupBox groupBox1;
- private System.Windows.Forms.ComboBox cmbPort1;
- private System.Windows.Forms.ComboBox cmbBaud1;
- private System.Windows.Forms.Button btnConnect1;
- private System.Windows.Forms.Label lblPort1;
- private System.Windows.Forms.Label lblBaud1;
- private System.Windows.Forms.GroupBox groupBox2;
- private System.Windows.Forms.ComboBox cmbPort2;
- private System.Windows.Forms.ComboBox cmbBaud2;
- private System.Windows.Forms.Button btnConnect2;
- private System.Windows.Forms.Label lblPort2;
- private System.Windows.Forms.Label lblBaud2;
- private System.Windows.Forms.GroupBox groupBox3;
- private System.Windows.Forms.TextBox txtUrl;
- private System.Windows.Forms.Label lblUrl;
- private System.Windows.Forms.Button btnStartUpload;
- private System.Windows.Forms.Button btnStopUpload;
- private System.Windows.Forms.GroupBox groupBox4;
- private System.Windows.Forms.TextBox txtLog;
- private System.Windows.Forms.Button btnClearLog;
- private System.Windows.Forms.Button btnSaveLog;
- private System.Windows.Forms.StatusStrip statusStrip1;
- private System.Windows.Forms.ToolStripStatusLabel toolStripStatusLabel1;
}
diff --git a/Form1.cs b/Form1.cs
index b147745..fcf7531 100644
--- a/Form1.cs
+++ b/Form1.cs
@@ -1,461 +1,592 @@
-using System.Collections.Concurrent;
-using System.IO.Ports;
-using System.Text;
-using System.Text.Json;
-using System.Text.RegularExpressions;
-
-namespace sscom_sender
-{
- public partial class Form1 : Form
- {
- // 串口对象
- private SerialPort? serialPort1;
- private SerialPort? serialPort2;
-
- // 数据缓冲区
- private StringBuilder buffer1 = new StringBuilder();
- private StringBuilder buffer2 = new StringBuilder();
-
- // 数据队列
- private ConcurrentQueue dataQueue = new ConcurrentQueue();
-
- // 线程控制
- private CancellationTokenSource? uploadCancellationTokenSource;
- private CancellationTokenSource? logCancellationTokenSource;
- private Task? uploadTask;
- private Task? logTask;
-
- // HTTP客户端
- private readonly HttpClient httpClient = new HttpClient();
-
- // 日志文件路径
- private readonly string logFilePath = Path.Combine(Application.StartupPath, "data_log.txt");
-
- // 线程安全的日志队列
- private ConcurrentQueue logQueue = new ConcurrentQueue();
-
- public Form1()
- {
- InitializeComponent();
- }
-
- private void Form1_Load(object sender, EventArgs e)
- {
- // 初始化串口列表
- RefreshPortList();
-
- // 设置默认波特率
- cmbBaud1.SelectedIndex = 4; // 115200
- cmbBaud2.SelectedIndex = 4; // 115200
-
- // 启动日志线程
- StartLogThread();
-
- UpdateStatus("系统已启动");
- }
-
- private void RefreshPortList()
- {
- string[] ports = SerialPort.GetPortNames();
-
- cmbPort1.Items.Clear();
- cmbPort2.Items.Clear();
-
- foreach (string port in ports)
- {
- cmbPort1.Items.Add(port);
- cmbPort2.Items.Add(port);
- }
-
- if (ports.Length > 0)
- {
- cmbPort1.SelectedIndex = 0;
- if (ports.Length > 1)
- cmbPort2.SelectedIndex = 1;
- else
- cmbPort2.SelectedIndex = 0;
- }
- }
-
- private void btnConnect1_Click(object sender, EventArgs e)
- {
- if (serialPort1?.IsOpen == true)
- {
- // 断开连接
- serialPort1.Close();
- btnConnect1.Text = "连接";
- UpdateStatus("串口1已断开");
- }
- else
- {
- // 建立连接
- try
- {
- serialPort1 = new SerialPort(
- cmbPort1.Text,
- int.Parse(cmbBaud1.Text),
- Parity.None,
- 8,
- StopBits.One);
-
- serialPort1.DataReceived += SerialPort1_DataReceived;
- serialPort1.Open();
-
- btnConnect1.Text = "断开";
- UpdateStatus($"串口1已连接: {cmbPort1.Text}");
- }
- catch (Exception ex)
- {
- MessageBox.Show($"串口1连接失败: {ex.Message}", "错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
- }
- }
- }
-
- private void btnConnect2_Click(object sender, EventArgs e)
- {
- if (serialPort2?.IsOpen == true)
- {
- // 断开连接
- serialPort2.Close();
- btnConnect2.Text = "连接";
- UpdateStatus("串口2已断开");
- }
- else
- {
- // 建立连接
- try
- {
- serialPort2 = new SerialPort(
- cmbPort2.Text,
- int.Parse(cmbBaud2.Text),
- Parity.None,
- 8,
- StopBits.One);
-
- serialPort2.DataReceived += SerialPort2_DataReceived;
- serialPort2.Open();
-
- btnConnect2.Text = "断开";
- UpdateStatus($"串口2已连接: {cmbPort2.Text}");
- }
- catch (Exception ex)
- {
- MessageBox.Show($"串口2连接失败: {ex.Message}", "错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
- }
- }
- }
-
- private void SerialPort1_DataReceived(object sender, SerialDataReceivedEventArgs e)
- {
- if (serialPort1?.IsOpen == true)
- {
- string data = serialPort1.ReadExisting();
- ProcessSerialData(data, 1, buffer1);
- }
- }
-
- private void SerialPort2_DataReceived(object sender, SerialDataReceivedEventArgs e)
- {
- if (serialPort2?.IsOpen == true)
- {
- string data = serialPort2.ReadExisting();
- ProcessSerialData(data, 2, buffer2);
- }
- }
-
- private void ProcessSerialData(string data, int portNumber, StringBuilder buffer)
- {
- // 将数据添加到缓冲区
- buffer.Append(data);
-
- // 查找完整的数据包（以换行符结束）
- string bufferContent = buffer.ToString();
- string[] lines = bufferContent.Split(new[] { '\r', '\n' }, StringSplitOptions.RemoveEmptyEntries);
-
- if (lines.Length > 0)
- {
- // 处理完整的行
- for (int i = 0; i < lines.Length - 1; i++)
- {
- ProcessCompleteDataLine(lines[i], portNumber);
- }
-
- // 检查最后一行是否完整
- if (bufferContent.EndsWith("\r") || bufferContent.EndsWith("\n"))
- {
- ProcessCompleteDataLine(lines[lines.Length - 1], portNumber);
- buffer.Clear();
- }
- else
- {
- // 保留不完整的最后一行
- buffer.Clear();
- buffer.Append(lines[lines.Length - 1]);
- }
- }
- }
-
- private void ProcessCompleteDataLine(string line, int portNumber)
- {
- if (string.IsNullOrWhiteSpace(line)) return;
-
- var dataPacket = new DataPacket
- {
- PortNumber = portNumber,
- RawData = line,
- Timestamp = DateTime.Now
- };
-
- // 如果是串口1且数据格式匹配BESTPOS，提取经纬度
- if (portNumber == 1 && line.Contains("BESTPOSA"))
- {
- var coordinates = ExtractCoordinates(line);
- if (coordinates != null)
- {
- dataPacket.Latitude = coordinates.Value.Latitude;
- dataPacket.Longitude = coordinates.Value.Longitude;
- }
- }
-
- // 添加到队列
- dataQueue.Enqueue(dataPacket);
-
- // 添加到日志显示
- string logMessage = $"[{dataPacket.Timestamp:yyyy-MM-dd HH:mm:ss}] 串口{portNumber}: {line}";
- if (dataPacket.Latitude.HasValue && dataPacket.Longitude.HasValue)
- {
- logMessage += $" [经度: {dataPacket.Longitude:F8}, 纬度: {dataPacket.Latitude:F8}]";
- }
-
- AddLogMessage(logMessage);
- }
-
- private (double Latitude, double Longitude)? ExtractCoordinates(string data)
- {
- try
- {
- // BESTPOS数据格式解析
- // #BESTPOSA,COM1,14394,98.0,UNKNOWN,1,1699.000,1700908,2,18;INSUFFICIENT_OBS,NONE,纬度,经度,高度,undulation,datum,lat_std,lon_std,hgt_std,stn_id,diff_age,sol_age,#obs,#L1,#L2,reserved,ext_sol_stat,galileo_beidou_sig_mask,gps_glonass_sig_mask*checksum
- string[] parts = data.Split(',');
- if (parts.Length >= 14)
- {
- if (double.TryParse(parts[11], out double latitude) &&
- double.TryParse(parts[12], out double longitude))
- {
- return (latitude, longitude);
- }
- }
- }
- catch (Exception ex)
- {
- AddLogMessage($"坐标解析错误: {ex.Message}");
- }
- return null;
- }
-
- private void btnStartUpload_Click(object sender, EventArgs e)
- {
- if (string.IsNullOrWhiteSpace(txtUrl.Text))
- {
- MessageBox.Show("请输入上传地址", "提示", MessageBoxButtons.OK, MessageBoxIcon.Warning);
- return;
- }
-
- uploadCancellationTokenSource = new CancellationTokenSource();
- uploadTask = Task.Run(() => UploadWorker(uploadCancellationTokenSource.Token));
-
- btnStartUpload.Enabled = false;
- btnStopUpload.Enabled = true;
- UpdateStatus("数据上传已启动");
- }
-
- private void btnStopUpload_Click(object sender, EventArgs e)
- {
- uploadCancellationTokenSource?.Cancel();
- btnStartUpload.Enabled = true;
- btnStopUpload.Enabled = false;
- UpdateStatus("数据上传已停止");
- }
-
- private async Task UploadWorker(CancellationToken cancellationToken)
- {
- while (!cancellationToken.IsCancellationRequested)
- {
- try
- {
- if (dataQueue.TryDequeue(out DataPacket? packet))
- {
- await UploadData(packet);
- }
- else
- {
- await Task.Delay(100, cancellationToken); // 等待100ms
- }
- }
- catch (OperationCanceledException)
- {
- break;
- }
- catch (Exception ex)
- {
- Invoke(() => AddLogMessage($"上传错误: {ex.Message}"));
- await Task.Delay(5000, cancellationToken); // 错误后等待5秒
- }
- }
- }
-
- private async Task UploadData(DataPacket packet)
- {
- try
- {
- var jsonData = JsonSerializer.Serialize(packet);
- var content = new StringContent(jsonData, Encoding.UTF8, "application/json");
-
- var response = await httpClient.PostAsync(txtUrl.Text, content);
-
- if (response.IsSuccessStatusCode)
- {
- Invoke(() => AddLogMessage($"数据上传成功: 串口{packet.PortNumber}"));
- }
- else
- {
- Invoke(() => AddLogMessage($"数据上传失败: {response.StatusCode} - 串口{packet.PortNumber}"));
- }
- }
- catch (Exception ex)
- {
- Invoke(() => AddLogMessage($"上传异常: {ex.Message}"));
- }
- }
-
- private void StartLogThread()
- {
- logCancellationTokenSource = new CancellationTokenSource();
- logTask = Task.Run(() => LogWorker(logCancellationTokenSource.Token));
- }
-
- private async Task LogWorker(CancellationToken cancellationToken)
- {
- while (!cancellationToken.IsCancellationRequested)
- {
- try
- {
- var logsToWrite = new List();
-
- // 批量获取日志
- while (logQueue.TryDequeue(out string? logMessage))
- {
- logsToWrite.Add(logMessage);
- if (logsToWrite.Count >= 10) break; // 批量写入，最多10条
- }
-
- if (logsToWrite.Count > 0)
- {
- await File.AppendAllLinesAsync(logFilePath, logsToWrite, cancellationToken);
- }
- else
- {
- await Task.Delay(1000, cancellationToken); // 等待1秒
- }
- }
- catch (OperationCanceledException)
- {
- break;
- }
- catch (Exception ex)
- {
- // 日志写入错误，避免无限循环
- Console.WriteLine($"日志写入错误: {ex.Message}");
- await Task.Delay(5000, cancellationToken);
- }
- }
- }
-
- private void AddLogMessage(string message)
- {
- // 添加到界面显示
- if (InvokeRequired)
- {
- Invoke(() => AddLogMessage(message));
- return;
- }
-
- txtLog.AppendText(message + Environment.NewLine);
- txtLog.SelectionStart = txtLog.Text.Length;
- txtLog.ScrollToCaret();
-
- // 添加到日志文件队列
- logQueue.Enqueue(message);
-
- // 限制界面显示的行数
- if (txtLog.Lines.Length > 1000)
- {
- var lines = txtLog.Lines.Skip(500).ToArray();
- txtLog.Text = string.Join(Environment.NewLine, lines);
- }
- }
-
- private void UpdateStatus(string message)
- {
- if (InvokeRequired)
- {
- Invoke(() => UpdateStatus(message));
- return;
- }
-
- toolStripStatusLabel1.Text = message;
- AddLogMessage($"[系统] {message}");
- }
-
- private void btnClearLog_Click(object sender, EventArgs e)
- {
- txtLog.Clear();
- }
-
- private void btnSaveLog_Click(object sender, EventArgs e)
- {
- try
- {
- using (var saveDialog = new SaveFileDialog())
- {
- saveDialog.Filter = "文本文件|*.txt|所有文件|*.*";
- saveDialog.FileName = $"log_{DateTime.Now:yyyyMMdd_HHmmss}.txt";
-
- if (saveDialog.ShowDialog() == DialogResult.OK)
- {
- File.WriteAllText(saveDialog.FileName, txtLog.Text);
- MessageBox.Show("日志保存成功", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
- }
- }
- }
- catch (Exception ex)
- {
- MessageBox.Show($"保存失败: {ex.Message}", "错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
- }
- }
-
- private void Form1_FormClosing(object sender, FormClosingEventArgs e)
- {
- // 停止所有线程
- uploadCancellationTokenSource?.Cancel();
- logCancellationTokenSource?.Cancel();
-
- // 关闭串口
- serialPort1?.Close();
- serialPort2?.Close();
-
- // 释放资源
- httpClient.Dispose();
- }
- }
-
- // 数据包类
- public class DataPacket
- {
- public int PortNumber { get; set; }
- public string RawData { get; set; } = string.Empty;
- public DateTime Timestamp { get; set; }
- public double? Latitude { get; set; }
- public double? Longitude { get; set; }
- }
-}
+using System;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.ComponentModel;
+using System.Data;
+using System.Drawing;
+using System.IO;
+using System.IO.Ports;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using System.Windows.Forms;
+using uPLibrary.Networking.M2Mqtt;
+using uPLibrary.Networking.M2Mqtt.Messages;
+using Newtonsoft.Json;
+using aiot_paho_csharp;
+
+namespace sscom_sender
+{
+ public partial class Form1 : Form
+ {
+ private SerialPort gpsPort;
+ private SerialPort spectrometerPort;
+ private MqttClient mqttClient;
+ private bool isRunning = false;
+ private string logFileName;
+
+ // 数据队列
+ private ConcurrentQueue gpsDataQueue = new ConcurrentQueue();
+ private ConcurrentQueue spectrometerDataQueue = new ConcurrentQueue();
+ private ConcurrentQueue logQueue = new ConcurrentQueue();
+
+ // 线程控制
+ private CancellationTokenSource cancellationTokenSource;
+ private Task gpsTask;
+ private Task spectrometerTask;
+ private Task mqttTask;
+ private Task logTask;
+
+ // 数据缓冲区
+ private StringBuilder gpsBuffer = new StringBuilder();
+ private StringBuilder spectrometerBuffer = new StringBuilder();
+
+ public Form1()
+ {
+ InitializeComponent();
+ InitializeForm();
+ }
+
+ private void InitializeForm()
+ {
+ // 初始化串口列表
+ RefreshSerialPorts();
+
+ // 创建日志文件名
+ logFileName = Path.Combine(Application.StartupPath, "logs", $"log_{DateTime.Now:yyyyMMdd_HHmmss}.txt");
+ Directory.CreateDirectory(Path.GetDirectoryName(logFileName));
+ }
+
+ private void RefreshSerialPorts()
+ {
+ string[] ports = SerialPort.GetPortNames();
+ comboBoxGPSPort.Items.Clear();
+ comboBoxSpectrometerPort.Items.Clear();
+
+ foreach (string port in ports)
+ {
+ comboBoxGPSPort.Items.Add(port);
+ comboBoxSpectrometerPort.Items.Add(port);
+ }
+
+ if (ports.Length > 0)
+ {
+ comboBoxGPSPort.SelectedIndex = 0;
+ if (ports.Length > 1)
+ comboBoxSpectrometerPort.SelectedIndex = 1;
+ else
+ comboBoxSpectrometerPort.SelectedIndex = 0;
+ }
+ }
+
+ private void buttonStartStop_Click(object sender, EventArgs e)
+ {
+ if (!isRunning)
+ {
+ StartDataCollection();
+ }
+ else
+ {
+ StopDataCollection();
+ }
+ }
+
+ private void StartDataCollection()
+ {
+ try
+ {
+ // 初始化串口
+ InitializeSerialPorts();
+
+ // 启动线程
+ cancellationTokenSource = new CancellationTokenSource();
+ var token = cancellationTokenSource.Token;
+
+ gpsTask = Task.Run(() => GPSDataReader(token), token);
+ spectrometerTask = Task.Run(() => SpectrometerDataReader(token), token);
+ mqttTask = Task.Run(() => MQTTDataSender(token), token);
+ logTask = Task.Run(() => LogWriter(token), token);
+
+ isRunning = true;
+ buttonStartStop.Text = "停止";
+ buttonStartStop.BackColor = Color.Red;
+
+ LogMessage("数据采集已启动");
+ }
+ catch (Exception ex)
+ {
+ MessageBox.Show($"启动失败: {ex.Message}", "错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
+ }
+ }
+
+ private void StopDataCollection()
+ {
+ try
+ {
+ isRunning = false;
+ cancellationTokenSource?.Cancel();
+
+ // 立即更新UI状态
+ buttonStartStop.Text = "开始";
+ buttonStartStop.BackColor = SystemColors.Control;
+ LogMessage("正在停止数据采集...");
+
+ // 异步等待任务完成，避免阻塞UI线程
+ Task.Run(() =>
+ {
+ try
+ {
+ // 给任务一些时间优雅退出
+ var tasks = new[] { gpsTask, spectrometerTask, mqttTask, logTask }.Where(t => t != null).ToArray();
+ if (tasks.Length > 0)
+ {
+ Task.WaitAll(tasks, 2000); // 减少等待时间到2秒
+ }
+
+ // 关闭串口
+ try { gpsPort?.Close(); } catch { }
+ try { spectrometerPort?.Close(); } catch { }
+
+ // 断开MQTT
+ try { mqttClient?.Disconnect(); } catch { }
+
+ // 在UI线程上更新状态
+ this.Invoke(new Action(() =>
+ {
+ LogMessage("数据采集已停止");
+ }));
+ }
+ catch (Exception ex)
+ {
+ this.Invoke(new Action(() =>
+ {
+ LogMessage($"停止时发生错误: {ex.Message}");
+ }));
+ }
+ });
+ }
+ catch (Exception ex)
+ {
+ LogMessage($"停止时发生错误: {ex.Message}");
+ }
+ }
+
+ private void InitializeSerialPorts()
+ {
+ // GPS串口
+ if (comboBoxGPSPort.SelectedItem != null)
+ {
+ gpsPort = new SerialPort(comboBoxGPSPort.SelectedItem.ToString(), 115200, Parity.None, 8, StopBits.One);
+ gpsPort.DataReceived += GPSPort_DataReceived;
+ gpsPort.Open();
+
+ // 发送GPS初始化命令
+ gpsPort.WriteLine("bestposa com1 1");
+ }
+
+ // 谱仪串口
+ if (comboBoxSpectrometerPort.SelectedItem != null)
+ {
+
+ spectrometerPort = new SerialPort(comboBoxSpectrometerPort.SelectedItem.ToString(), 115200, Parity.None, 8, StopBits.One);
+ spectrometerPort.DataReceived += SpectrometerPort_DataReceived;
+ spectrometerPort.Open();
+ if (!spectrometerPort.IsOpen) {
+ LogMessage("谱仪端口打开失败");
+ return;
+ }
+ LogMessage("谱仪端口已打开");
+ // 发送谱仪开始命令
+ spectrometerPort.DiscardInBuffer();
+ spectrometerPort.Write("$start\r\n");
+ spectrometerPort.ReadTimeout = 1500;
+ }
+ }
+
+ private void InitializeMQTT()
+ {
+ try
+ {
+ string productKey = textBoxProductKey.Text;
+ string topicRoot = textBoxTopicRoot.Text;
+ string deviceName = textBoxDeviceName.Text;
+ string deviceSecret = textBoxDeviceSecret.Text;
+
+ MqttSign sign = new MqttSign();
+ sign.calculate(productKey, deviceName, deviceSecret);
+
+ string broker = productKey + ".iot-as-mqtt.cn-shanghai.aliyuncs.com";
+ mqttClient = new MqttClient(broker, 1883, true, null, null, MqttSslProtocols.TLSv1_2);
+ mqttClient.Connect(sign.getClientid(), sign.getUsername(), sign.getPassword());
+
+ LogMessage($"MQTT已连接到: {broker}");
+ }
+ catch (Exception ex)
+ {
+ LogMessage($"MQTT连接失败: {ex.Message}，将继续进行数据采集和日志记录");
+ mqttClient = null; // 确保mqttClient为null，避免后续使用
+ }
+ }
+
+ private void GPSPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
+ {
+ try
+ {
+ string data = gpsPort.ReadExisting();
+ gpsBuffer.Append(data);
+
+ // 处理完整的行
+ string bufferContent = gpsBuffer.ToString();
+ string[] lines = bufferContent.Split(new[] { '\r', '\n' }, StringSplitOptions.RemoveEmptyEntries);
+
+ if (bufferContent.EndsWith("\r") || bufferContent.EndsWith("\n"))
+ {
+ gpsBuffer.Clear();
+ foreach (string line in lines)
+ {
+ ProcessGPSData(line);
+ }
+ }
+ else
+ {
+ gpsBuffer.Clear();
+ for (int i = 0; i < lines.Length - 1; i++)
+ {
+ ProcessGPSData(lines[i]);
+ }
+ gpsBuffer.Append(lines[lines.Length - 1]);
+ }
+ }
+ catch (Exception ex)
+ {
+ LogMessage($"GPS数据接收错误: {ex.Message}");
+ }
+ }
+
+ private void SpectrometerPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
+ {
+ try
+ {
+ string data = spectrometerPort.ReadExisting();
+ // LogMessage($"谱仪原始数据: {data}");
+ spectrometerBuffer.Append(data);
+
+ // 处理完整的行
+ string bufferContent = spectrometerBuffer.ToString();
+ string[] lines = bufferContent.Split(new[] { '\r', '\n' }, StringSplitOptions.RemoveEmptyEntries);
+
+ if (bufferContent.EndsWith("\r") || bufferContent.EndsWith("\n"))
+ {
+ spectrometerBuffer.Clear();
+ foreach (string line in lines)
+ {
+ ProcessSpectrometerData(line);
+ }
+ }
+ else
+ {
+ spectrometerBuffer.Clear();
+ for (int i = 0; i < lines.Length - 1; i++)
+ {
+ ProcessSpectrometerData(lines[i]);
+ }
+ spectrometerBuffer.Append(lines[lines.Length - 1]);
+ }
+ }
+ catch (Exception ex)
+ {
+ LogMessage($"谱仪数据接收错误: {ex.Message}");
+ }
+ }
+
+ private void ProcessGPSData(string data)
+ {
+ LogMessage($"GPS原始数据: {data}");
+ if (data.StartsWith("#BESTPOSA"))
+ {
+ try
+ {
+ string[] parts = data.Split(',');
+ // 查找WGS84标识的位置
+ // LogMessage($"GPS数据部分数量: {parts.Length}");
+ int wgs84Index = -1;
+ for (int i = 0; i < parts.Length; i++)
+ {
+ // LogMessage($"GPS数据部分: {parts[i]}");
+ if (parts[i].Contains("WGS84"))
+ {
+ wgs84Index = i;
+ break;
+ }
+ }
+ // LogMessage($"WGS84索引: {wgs84Index}");
+
+ // WGS84后面的两个字段是经纬度
+ if (wgs84Index >= 0 && parts.Length > wgs84Index + 2)
+ {
+ double lat = double.Parse(parts[wgs84Index + 1]);
+ double lng = double.Parse(parts[wgs84Index + 2]);
+
+ GPSData gpsData = new GPSData
+ {
+ Latitude = lat,
+ Longitude = lng,
+ Timestamp = DateTime.Now
+ };
+
+ gpsDataQueue.Enqueue(gpsData);
+ LogMessage($"GPS数据: 纬度={lat:F8}, 经度={lng:F8}");
+
+ }
+ }
+ catch (Exception ex)
+ {
+ LogMessage($"GPS数据解析错误: {ex.Message}");
+ }
+ }
+ }
+
+ private void ProcessSpectrometerData(string data)
+ {
+ LogMessage($"谱仪原始数据: {data}");
+ if (data.Equals("ok")) {
+ LogMessage("谱仪已准备好");
+ return;
+ }
+ try
+ {
+ string[] parts = data.Split(' ');
+ // 检查是否为完整的反馈格式：16个字段（日期 时间 + 14个数值）
+ if (parts.Length == 16)
+ {
+ // 验证日期格式 xxxx.xx.xx
+ if (!System.Text.RegularExpressions.Regex.IsMatch(parts[0], @"^\d{4}\.\d{2}\.\d{2}$"))
+ return;
+
+ // 验证时间格式 xx:xx:xx
+ if (!System.Text.RegularExpressions.Regex.IsMatch(parts[1], @"^\d{2}:\d{2}:\d{2}$"))
+ return;
+
+ // 解析时间戳 (xxxx.xx.xx xx:xx:xx)
+ string dateStr = parts[0];
+ string timeStr = parts[1];
+
+ SpectrometerData spectData = new SpectrometerData
+ {
+ Timestamp = DateTime.Now, // 使用当前时间，也可以解析返回的时间
+ RealTime = double.Parse(parts[2]), // aaaaaaa.aa 实时间
+ DeadTime = double.Parse(parts[3]), // bbbbbbb.bb 死时间
+ DoseRate = double.Parse(parts[14]), // JJJJJJ.JJ 环境总辐射剂量率值（第15个字段）
+ TotalCountRate = double.Parse(parts[15]) // cccccccccc.cc γ谱的全谱计数率（第16个字段）
+ };
+
+ spectrometerDataQueue.Enqueue(spectData);
+ LogMessage($"谱仪数据: 时间={dateStr} {timeStr}, 剂量率={spectData.DoseRate:F2} nSv/h, 全谱计数率={spectData.TotalCountRate:F2} cps");
+ }
+ }
+ catch (Exception ex)
+ {
+ LogMessage($"谱仪数据解析错误: {ex.Message}, 数据: {data}");
+ }
+
+ }
+
+ private async void GPSDataReader(CancellationToken token)
+ {
+ while (!token.IsCancellationRequested && isRunning)
+ {
+ await Task.Delay(1000, token);
+ }
+ }
+
+ private async void SpectrometerDataReader(CancellationToken token)
+ {
+ while (!token.IsCancellationRequested && isRunning)
+ {
+ try
+ {
+ LogMessage("尝试读取谱仪数据");
+ if (spectrometerPort != null && spectrometerPort.IsOpen)
+ {
+ // spectrometerPort.DiscardInBuffer();
+ // spectrometerPort.Write("$start\r\n");
+ // await Task.Delay(50, token); // 等待刷新完成
+ // // spectrometerPort.ReadTimeout = 1500;
+ // // string response = spectrometerPort.ReadLine();
+ // // LogMessage($"谱仪原始数据: {response}");
+ // spectrometerPort.DiscardInBuffer();
+ // spectrometerPort.Write("$start\r");
+ // await Task.Delay(50, token); // 等待刷新完成
+ // spectrometerPort.ReadTimeout = 1500;
+ // response = spectrometerPort.ReadLine();
+ // LogMessage($"谱仪原始数据: {response}");
+
+ // response = spectrometerPort.ReadLine();
+ // LogMessage($"谱仪原始数据: {response}");
+ // spectrometerPort.DiscardInBuffer();
+ // spectrometerPort.Write("$start\r\n\r\n");
+ // spectrometerPort.ReadTimeout = 1500;
+ // response = spectrometerPort.ReadLine();
+ // LogMessage($"谱仪原始数据: {response}");
+ // await Task.Delay(50, token); // 等待刷新完成
+ LogMessage("谱仪端口已打开");
+ // 先发送刷新指令
+ spectrometerPort.Write("$refresh\r\n");
+ await Task.Delay(500, token); // 等待刷新完成
+
+ // 再发送获取结果指令
+ spectrometerPort.Write("$getSperesult\r\n");
+ }
+
+ int interval = (int)(numericUpDownRefreshInterval.Value * 1000);
+ await Task.Delay(interval, token);
+ }
+ catch (Exception ex)
+ {
+ LogMessage($"谱仪数据读取错误: {ex.Message}");
+ await Task.Delay(5000, token);
+ }
+ }
+ }
+
+ private async void MQTTDataSender(CancellationToken token)
+ {
+ // 在数据发送线程中初始化MQTT连接
+ InitializeMQTT();
+
+ while (!token.IsCancellationRequested && isRunning)
+ {
+ try
+ {
+ if (spectrometerDataQueue.TryDequeue(out SpectrometerData spectData))
+ {
+ // 查找最近的GPS数据
+ GPSData nearestGPS = FindNearestGPSData(spectData.Timestamp);
+
+ if (nearestGPS != null)
+ {
+ var mqttData = new
+ {
+ OptTime = spectData.Timestamp.ToString("yyyy-MM-dd HH:mm:ss.fff"),
+ PointLat = nearestGPS.Latitude.ToString("F8"),
+ PointLng = nearestGPS.Longitude.ToString("F8"),
+ Value = spectData.DoseRate / 1000000000.0 // 转换为合适的单位
+ };
+
+ string json = JsonConvert.SerializeObject(mqttData);
+ string topic = $"/{textBoxTopicRoot.Text}/{textBoxDeviceName.Text}/user/update";
+
+ if (mqttClient != null && mqttClient.IsConnected)
+ {
+ mqttClient.Publish(topic, Encoding.UTF8.GetBytes(json));
+ LogMessage($"MQTT发送: {json}");
+ }
+ else
+ {
+ LogMessage($"MQTT未连接，数据记录: {json}");
+ }
+ }
+ }
+
+ await Task.Delay(100, token);
+ }
+ catch (Exception ex)
+ {
+ LogMessage($"MQTT发送错误: {ex.Message}");
+ await Task.Delay(5000, token);
+ }
+ }
+ }
+
+ private GPSData FindNearestGPSData(DateTime targetTime)
+ {
+ GPSData nearest = null;
+ TimeSpan minDiff = TimeSpan.MaxValue;
+
+ var gpsDataList = gpsDataQueue.ToArray();
+ foreach (var gpsData in gpsDataList)
+ {
+ TimeSpan diff = Math.Abs((gpsData.Timestamp - targetTime).Ticks) == (gpsData.Timestamp - targetTime).Ticks ?
+ gpsData.Timestamp - targetTime : targetTime - gpsData.Timestamp;
+
+ if (diff < minDiff)
+ {
+ minDiff = diff;
+ nearest = gpsData;
+ }
+ }
+
+ return nearest;
+ }
+
+ private async void LogWriter(CancellationToken token)
+ {
+ while (!token.IsCancellationRequested)
+ {
+ try
+ {
+ if (logQueue.TryDequeue(out string logMessage))
+ {
+ await File.AppendAllTextAsync(logFileName, logMessage + Environment.NewLine, token);
+ }
+
+ await Task.Delay(100, token);
+ }
+ catch (Exception ex)
+ {
+ // 避免日志写入错误导致的无限循环
+ Console.WriteLine($"日志写入错误: {ex.Message}");
+ await Task.Delay(1000, token);
+ }
+ }
+ }
+
+ private void LogMessage(string message)
+ {
+ string logEntry = $"[{DateTime.Now:yyyy-MM-dd HH:mm:ss.fff}] {message}";
+
+ // 添加到日志队列
+ logQueue.Enqueue(logEntry);
+
+ // 更新UI
+ if (textBoxLog.InvokeRequired)
+ {
+ textBoxLog.Invoke(new Action(() => {
+ textBoxLog.AppendText(logEntry + Environment.NewLine);
+ textBoxLog.ScrollToCaret();
+ }));
+ }
+ else
+ {
+ textBoxLog.AppendText(logEntry + Environment.NewLine);
+ textBoxLog.ScrollToCaret();
+ }
+ }
+
+ protected override void OnFormClosing(FormClosingEventArgs e)
+ {
+ if (isRunning)
+ {
+ StopDataCollection();
+ }
+ base.OnFormClosing(e);
+ }
+ }
+
+ public class GPSData
+ {
+ public double Latitude { get; set; }
+ public double Longitude { get; set; }
+ public DateTime Timestamp { get; set; }
+ }
+
+ public class SpectrometerData
+ {
+ public DateTime Timestamp { get; set; }
+ public double RealTime { get; set; }
+ public double DeadTime { get; set; }
+ public double DoseRate { get; set; }
+ public double TotalCountRate { get; set; }
+ }
+}
diff --git a/MqttSign.cs b/MqttSign.cs
new file mode 100644
index 0000000..e6b812d
--- /dev/null
+++ b/MqttSign.cs
@@ -0,0 +1,56 @@
+using System;
+using System.Security.Cryptography;
+
+namespace aiot_paho_csharp
+{
+ class CryptoUtil
+ {
+ public static String hmacSha256(String plainText, String key)
+ {
+ var encoding = new System.Text.UTF8Encoding();
+ byte[] plainTextBytes = encoding.GetBytes(plainText);
+ byte[] keyBytes = encoding.GetBytes(key);
+
+ HMACSHA256 hmac = new HMACSHA256(keyBytes);
+ byte[] sign = hmac.ComputeHash(plainTextBytes);
+ return BitConverter.ToString(sign).Replace("-", string.Empty);
+ }
+ }
+ public class MqttSign
+ {
+ private String username = "";
+
+ private String password = "";
+
+ private String clientid = "";
+
+ public String getUsername() { return this.username; }
+
+ public String getPassword() { return this.password; }
+
+ public String getClientid() { return this.clientid; }
+
+ public bool calculate(String productKey, String deviceName, String deviceSecret)
+ {
+ if (productKey == null || deviceName == null || deviceSecret == null)
+ {
+ return false;
+ }
+
+ //MQTT用户名
+ this.username = deviceName + "&" + productKey;
+
+ //MQTT密码
+ String timestamp = Convert.ToInt64((DateTime.UtcNow - new DateTime(1970, 1, 1)).TotalMilliseconds).ToString();
+ String plainPasswd = "clientId" + productKey + "." + deviceName + "deviceName" +
+ deviceName + "productKey" + productKey + "timestamp" + timestamp;
+ this.password = CryptoUtil.hmacSha256(plainPasswd, deviceSecret);
+
+ //MQTT ClientId
+ this.clientid = productKey + "." + deviceName + "|" + "timestamp=" + timestamp +
+ ",_v=paho-c#-1.0.0,securemode=2,signmethod=hmacsha256|";
+
+ return true;
+ }
+ }
+}
\ No newline at end of file
diff --git a/readme.txt b/readme.txt
new file mode 100644
index 0000000..3b681e2
--- /dev/null
+++ b/readme.txt
@@ -0,0 +1,94 @@
+我希望用C#写一个GUI应用，能够打开2个串口，然后读取数据，然后能够整理数据，把数据发送到配置好的网址上，并且能够在界面上看到数据记录，然后也能把数据写到一个log文件中。
+一个串口是GPS的，数据格式是这样的。要提取WGS84后面的经纬度信息。这个串口打开，发送bestposa com1 1 \r\n后就有数据传输进来：
+#BESTPOSA,COM1,14394,98.0,UNKNOWN,1,1699.000,1700908,2,18;INSUFFICIENT_OBS,NONE,0.00000000000,0.00000000000,0.0000,0.0000,WGS84,0.0000,0.0000,0.0000,"",0.000,0.000,0,0,0,0,0,00,00,00*fcf220b4
+另一个串口是谱仪数据,文档如下：
+航空γ谱仪通信协议
+通信方式
+采用RS232串口通信，115200，n，8，1。
+操作指令
+开始测量指令
+指令格式：$start[回车][换行]
+反馈格式：ok[回车][换行]
+谱数据刷新指令（刷新的回复要忽略）
+指令格式：$refresh[回车][换行]
+反馈格式：0 0 0 0 0 0 0 0 0 0 0 0 0 (很长的一个序列)[回车][换行]
+清空测量指令
+指令格式：$clear[回车][换行]
+反馈格式：ok[回车][换行]
+谱分析指令
+指令格式：$getSperesult[回车][换行]
+反馈格式：xxxx.xx.xx xx:xx:xx aaaaaaa.aa bbbbbbb.bb 1111111.11 2222222.12 3333333.33 4444444.44 5555555.55 6666666.66 7777777.77 8888888.88 9999999.99 0000000.00 JJJJJJ.JJ cccccccccc.cc [回车][换行]
+“aaaaaaa.aa bbbbbbb.bb”表示实时间和死时间，单位：s（秒）；
+“1111111.11 … …0000000.00”表示十种核素计数率，单位：cps；
+“JJJJJJ.JJ”表示环境总辐射剂量率值，单位：nSv/h；
+“cccccccccc.cc”表示γ谱的全谱计数率cps；
+“xxxx.xx.xx xx:xx:xx”表示返回该帧时间；
+1111111.11 (核素40K，单位cps)
+2222222.22 (核素208Tl，单位cps)
+3333333.33 (核素214Bi，单位cps)
+4444444.44 (核素214Pb，单位cps)
+5555555.55 (核素226Ra，单位cps)
+6666666.66 (核素232Th，单位cps)
+7777777.77 (核素60Co，单位cps)
+8888888.88 (核素131I，单位cps)
+9999999.99 (核素137Cs，单位cps)
+0000000.00 (核素192Ir，单位cps)
+
+这个需要打开串口的时候先开始，然后就进入一个循环，刷新一次，解析一次，得到数据，这样反复。我希望能选择刷新的频率。
+
+两个串口的数据分别放到两个队列里，每次要从谱仪队列里读取数据，然后从GPS队列里读取时间最近的数据，两个合并起来，组成这样的格式：{"OptTime":"2020-11-30 13:16:24.178","PointLat":"23.10606","PointLng":"113.213425","Value":1.9334545697802241E-07}。
+
+然后通过mqtt发送出去。
+
+这是大致的发布代码：
+ String productKey = "gfcq950RDqt";
+ String topicRoot = "a10inDdCRS6";
+ String deviceName = "PubDevice";
+ String deviceSecret = "1031a49a4f61c29a086f79b41ed971c7";
+
+ //计算Mqtt建联参数
+ MqttSign sign = new MqttSign();
+ sign.calculate(productKey, deviceName, deviceSecret);
+
+ Console.WriteLine("username: " + sign.getUsername());
+ Console.WriteLine("password: " + sign.getPassword());
+ Console.WriteLine("clientid: " + sign.getClientid());
+
+ //使用Paho链接阿里云物联网平台
+ int port = 443;
+ String broker = productKey + ".iot-as-mqtt.cn-shanghai.aliyuncs.com";
+
+ MqttClient mqttClient = new MqttClient(broker, port, true, MqttSslProtocols.TLSv1_2, null, null);
+ mqttClient.Connect(sign.getClientid(), sign.getUsername(), sign.getPassword());
+
+ Console.WriteLine("broker: " + broker + " Connected");
+
+ // //Paho Mqtt 消息订阅
+ // String topicReply = "/" + topicRoot + "/" + deviceName + "/user/get";
+
+ // mqttClient.MqttMsgPublishReceived += MqttPostProperty_MqttMsgPublishReceived;
+ // mqttClient.Subscribe(new string[] { topicReply }, new byte[] { MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE });
+ // Console.WriteLine("subscribe: " + topicReply);
+
+ //Paho Mqtt 消息发布
+ String topic = "/" + topicRoot + "/" + deviceName + "/user/update";
+ String message = "{\"id\":\"1\",\"version\":\"1.0\",\"params\":{\"LightSwitch\":0}}";
+ mqttClient.Publish(topic, Encoding.UTF8.GetBytes(message));
+ Console.WriteLine("publish: " + message);
+
+ while(true) {
+ Thread.Sleep(2000);
+ }
+
+ //Paho Mqtt 断开连接
+ mqttClient.Disconnect();
+
+另外，我希望是2个串口接收数据分别分配一个线程，上传分配一个线程。数据读取后放到一个队列里，上传线程去读取队列数据。
+还要有一个日志线程，把数据写入到日志里。
+软件要有个简单的文本框来展示串口收到的数据
+日志要自动创建文件，每次打开的时候，日志的名字应该是当前的时间。
+
+要有个按钮可以一键开始和结束。
+
+另外，接收数据的时候很可能每次收到的是不完整的数据。
+我已经创建好了模板程序。
\ No newline at end of file
diff --git a/sscom-sender.csproj b/sscom-sender.csproj
index 1b91352..a04e4de 100644
--- a/sscom-sender.csproj
+++ b/sscom-sender.csproj
@@ -1,4 +1,4 @@
-
+
WinExe
@@ -10,7 +10,9 @@
+
+
\ No newline at end of file
diff --git a/sscom-sender.sln b/sscom-sender.sln
deleted file mode 100644
index 90e7ab7..0000000
--- a/sscom-sender.sln
+++ /dev/null
@@ -1,24 +0,0 @@
-Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio Version 17
-VisualStudioVersion = 17.5.2.0
-MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "sscom-sender", "sscom-sender.csproj", "{F03C6C53-8989-99E6-D747-EC03449AD20F}"
-EndProject
-Global
- GlobalSection(SolutionConfigurationPlatforms) = preSolution
- Debug|Any CPU = Debug|Any CPU
- Release|Any CPU = Release|Any CPU
- EndGlobalSection
- GlobalSection(ProjectConfigurationPlatforms) = postSolution
- {F03C6C53-8989-99E6-D747-EC03449AD20F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {F03C6C53-8989-99E6-D747-EC03449AD20F}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {F03C6C53-8989-99E6-D747-EC03449AD20F}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {F03C6C53-8989-99E6-D747-EC03449AD20F}.Release|Any CPU.Build.0 = Release|Any CPU
- EndGlobalSection
- GlobalSection(SolutionProperties) = preSolution
- HideSolutionNode = FALSE
- EndGlobalSection
- GlobalSection(ExtensibilityGlobals) = postSolution
- SolutionGuid = {707867E8-3EF5-4E83-A851-9053BE677857}
- EndGlobalSection
-EndGlobal