物聯網測驗總結
功能說明：
1、可以同時實作兩個ESP32的ADC資料的讀取和顯示，并且可以將采集的資料發送到所連接資料庫和所系結的Onenet云平臺設備上，
2、可以pc同時與實作兩個ESP32進行TCP通行，并且可以將采集的資料發送到所連接資料庫和所系結的Onenet云平臺設備上，可查詢云端資料，
class1.cs 程式
class db 資料庫的類撰寫
class db //database資料庫的類，用于后面進行實體化，
{
static SqlConnection conn; //創建一個用于連接打開資料庫的靜態變數--conn
public static Boolean Is_OK; //創建一個布爾型別的公共靜態變數--Is_OK
public static void Open_db() //在資料庫類--db 中類中創建一個名為公共靜態型別的方法--Open_db
{
//嘗試連接到資料庫
try
{
//server=.\SQLEXPRESS;
string ConStr = "server=.;database=test;uid=sa;pwd=`sql2012"; //定義資料庫的，名，登錄用戶名，密碼
conn = new SqlConnection(ConStr);//連接到資料庫
conn.Open();//打開資料庫的連接
}
嘗試連接到資料庫失敗，彈出 "連接資料庫失敗" 視窗，
catch
{
MessageBox.Show("連接資料庫失敗");
}
}
//上傳資料到資料庫
//下面這個程式我改了，多加了幾個變數，更加的好用了
//定義添加資料到資料庫的方法--Insert_data( id 為資料的名稱如:ADC1， val 為ADC對應的數值，dt 為對應的發送時間，dbname 為對應的資料庫名如歷史資料表， xuhao 為資料表里的序號變數，
// value 為資料表里的當前值變數， date 為資料表里的時間變數 )
public static void Insert_data(int id, double val, DateTime dt, string dbname, string xuhao, string value, string date)
{
if (conn.State == ConnectionState.Open)//檢測資料庫當前狀態是否打開
{
SqlCommand cmd = new SqlCommand();//初始化一個client（用戶）型別的資料庫變數
cmd.Connection = conn;//
//string table = "[歷史資料表" + dt.ToString("yyMMdd") + "]";
string table = dbname;//吧資料庫的表名賦值給 table
string strSQL = "INSERT INTO " + table + "(" + xuhao + "," + value + "," + date + ")"
+ "VALUES (" + id + ", " + val
+ ", '" + dt.ToString() + "')";//把所有的需要傳給資料庫的資料整合為一個長的字串賦值給strSQL
cmd.CommandText = strSQL; //插入資料SQL陳述句
cmd.CommandType = CommandType.Text;//指定如何解釋字串
cmd.ExecuteNonQuery();//回傳受影響的行數
//int i = Convert.ToInt32(cmd.ExecuteScalar());
}
}
internal static void Insert_data_2(int newid, double v, DateTime time)
{
throw new NotImplementedException();
}
}
TCP類的撰寫
什么是套接字呢？點擊這里查看！！！
class myTcp//創建TCP的所用的類
{
public string strOut = "";//宣告一個字串型別的公共變數--strOut
public string strIP = "127.0.0.1";//
//初始化要連接的ip和埠號
//public IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(strIP), 9050);
//創建套接字
public Socket server = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);//實體化套接字
public void Tcp_Send(string str)//定義tcp發送資料的方法
{
if (server.Connected)//判斷是否連接到服務端
{
byte[] data = Encoding.UTF8.GetBytes(str);//將字串編碼為UTF8格式
server.Send(data);//將資料發送到服務端
}
}
public void Start()//打開tcp執行緒
{
//3.receive data
//new Thread(Thread_Connect) { IsBackground = true }.Start();
//當初始化一個執行緒，把Thread.IsBackground = true的時候，指示該執行緒為后臺執行緒，后臺執行緒將會隨著主執行緒的退出而退出，
new Thread(Thread_Receive) { IsBackground = true }.Start();//上面的注釋很清楚了
}
void Thread_Receive()//獲取執行緒的回傳值
{
int recv = 0;//
byte[] data = new byte[1024];//
while (true)
{
if (server.Connected)//是否連接到server端
{
try { recv = server.Receive(data); }//嘗試接收到緩沖區的資料
catch { }
strOut = Encoding.ASCII.GetString(data, 0, recv); //獲取回傳值
}
Thread.Sleep(10);//延時10ms
}
}
}
至此 class1.cs的主要兩個類程式寫完了，
Program.cs 程式
class DataPointTest //創建用于連接Onenet的類
public class DataPointTest//創建用于連接Onenet的類
{
private const string url = "api.heclouds.com";//onenet的連接地址
//public string appkey = "DXfTvFsU5RXxygkwddwvqFXhD3s=";//您在OneNET平臺的APIKey
public string appkey = "5TK53JepiCvPJ4k79XrBti4YEtI=";//你的設備APIKey
public string strOut = "";//
public void TestAddNewDataPoint(int 設備號, string 資料流, string strVal)//創建傳輸到Onenet資料的方法
{
var client = new DefaultOneNETClient(url, appkey, "");//實體化OneNETClient(客戶端)
var streams = new List<DataStreamSimple> //創建資料流變數
{
new DataStreamSimple
{
ID = 資料流 ,
Datapoints = new List<DataPointSimple>{
new DataPointSimple
{
Value = strVal //賦值資料
}
}
}
};
var data = new NewDataPointData { DataStreams = streams };//資料流賦值給data用于傳輸
var req = new NewDataPointRequest { DeviceID = 設備號, Data = data };//發送資料請求
var rsp = client.Execute(req);//發送資料并獲取回傳值
Assert.IsFalse(rsp.IsError);//測驗Onenet回傳值是否正常
}
public void TestSearchDataPointWithCondition(string appkey1, string strDeviceID, string sensorName)//創建Onenet資料查詢的方法 變數分別為 APIKey ，設備號， 傳感器名
{
var client = new DefaultOneNETClient(url, appkey1, "");//實體化OneNETClient(客戶端)
//測驗帶參查詢
var req1 = new SearchDataPointRequest { DeviceID = strDeviceID, Protocol = Scheme.HTTP };
req1.DataStreamId = "loc," + sensorName;
var rsp1 = client.Execute(req1);
Assert.IsFalse(rsp1.IsError);
Assert.AreEqual(0, rsp1.Errno);
Assert.AreEqual("succ", rsp1.Error);
Assert.IsNotNull(rsp1.Data);
//Assert.IsTrue(rsp1.Data.Count > 0);
if (rsp1.Data.Count > 0) {
var val = rsp1.Data.Datastreams[0].Datapoints[0].GetValue();
Console.WriteLine("帶參查詢結果：" + rsp1.Body);
strOut = rsp1.Body;
}
else
{
strOut = "";
}
}
}
Form1.cs 的程式
實作的效果
class Form1 : Form //創建Form1的類
public partial class Form1 : Form //創建Form1的類
{
//FormList fLst = new FormList();
//chart chart1 = new chart();
SerialPort sp1 = new SerialPort();
//SerialPort sp2 = new SerialPort();
string dbname = "[歷史資料表一]";
string xuhao = "系統序號01";
string value = "當前值01";
string date = "時間01";
string strComm = "";
public Form1()//Form1初始化
{
InitializeComponent();
}
private void btnSwitchSP_Click_1(object sender, EventArgs e)//打開/關閉串口按鈕的程式
{
if (btnSwitchSP.Text == "打開串口")
{
sp1.Close();
sp1.PortName = textBox1.Text;
sp1.BaudRate = 115200;
try
{
sp1.Open();//打開串口
this.Text = "埠號：" + sp1.PortName + " 丨";
this.Text += "波特率：" + sp1.BaudRate + " 丨";
}
catch (Exception ex)
{
MessageBox.Show("錯誤：" + ex.Message, "C#串口通信");
}
btnSwitchSP.Text = "關閉串口";
}
else
{
sp1.Close();//關閉串口
btnSwitchSP.Text = "打開串口";
}
}
private void Form1_Load(object sender, EventArgs e)//加載Form1視窗
{
btnSwitchSP_Click_1(sender, e);
}
private void timer2_Tick(object sender, EventArgs e)//視窗的定時器函式，定時發送資料
{
if (sp1.IsOpen)
{
if (strComm.Length >= 15) //保證接收位元組大于一定數目后再處理
{
string str = strComm; 將輸入緩沖區中可用的位元組賦值給str 用于字串的分割和發送 // sp.ReadExisting();
txtRTC.Text = str;
textBox2.Text = str;
if (str != "")
{
string[] strArray = str.Split(new char[] { ',' });
if (listBox1.Items.Count > 0) listBox1.Items.Clear();
for (int i = 0; i < strArray.Length; i++)
{
if (strArray[i] != "")
listBox1.Items.Add(strArray[i]);
}
string KEY;
KEY = "\r\nADC:";
if (str.IndexOf(KEY) >= 0)
{
Find_KEY_01(str, KEY); //查找關鍵字，并將A發送
}
else
{
KEY = "KEY:";
Find_KEY_01(str, KEY); //查找關鍵字，并
}
}
}
strComm = ""; //清空已發送的字串流
}
}
void sp1_ReadData()//用串口給esp32發送命令的方法
{
Thread.Sleep(10);
string t = "from machine import Pin,ADC,RTC,Timer\r\n"
+ "rtc = RTC()\r\n"
+ "adc1 = ADC(Pin(33))\r\n"
+ "adc2 = ADC(Pin(34))\r\n"
+ "adc3 = ADC(Pin(35))\r\n";
sp1.Write(t);
Thread.Sleep(100);
while (true)
{
try//防止程式崩潰的嘗試代碼
{
if (sp1.IsOpen)
{
t = "d = rtc.datetime()\r\nprint(str('ADC:1,%.3f,'%(adc1.read()/4095))+str('TIME:%04d-%02d-%02d %02d:%02d:%02d.%03d'%(d[0],d[1],d[2],d[4],d[5],d[6],int(d[7]/1000))))\r\n,";
sp1.Write(t);//發生上述命令到ESP32
Thread.Sleep(100);
if (sp1.BytesToRead >= 10)
{
strComm = sp1.ReadExisting(); //從輸入緩沖區中取用立即可用的位元組
}
t = "d = rtc.datetime()\r\nprint(str('ADC:2,%.3f,'%(adc2.read()/4095))+str('TIME:%04d-%02d-%02d %02d:%02d:%02d.%03d'%(d[0],d[1],d[2],d[4],d[5],d[6],int(d[7]/1000))))\r\n,";
sp1.Write(t);//發生上述命令到ESP32
Thread.Sleep(100);
if (sp1.BytesToRead >= 10)
strComm = sp1.ReadExisting();
t = "d = rtc.datetime()\r\nprint(str('ADC:3,%.3f,'%(adc3.read()/4095))+str('TIME:%04d-%02d-%02d %02d:%02d:%02d.%03d'%(d[0],d[1],d[2],d[4],d[5],d[6],int(d[7]/1000))))\r\n,";
sp1.Write(t);//發生上述命令到ESP32
Thread.Sleep(100);
if (sp1.BytesToRead >= 10)
strComm = sp1.ReadExisting();//從串口的緩沖區里讀取ESP32回傳的數值
}
}
catch
{
if (!sp1.IsOpen)
{
break;
}
}
Thread.Sleep(1); //防止串口沒有打開時，執行緒死鎖
}
}
private void BtnClear_Click(object sender, EventArgs e)
{
axTChart1.Series(0).Clear();
axTChart1.Series(1).Clear();
axTChart1.Series(2).Clear();
}
public void AddToChart(int id, double v, DateTime time)//將接受到的ESP32的ADC數值添加到圖表中
{
if (id >= 0 && id <= 2) {
axTChart1.Series(id).Add(v, time.ToString("HH:mm:ss"), 1);//共三條
}
}
void Find_KEY_01(string str, string KEY1)//找到關鍵字
{
//string KEY1 = "KEY:";
int index1 = str.IndexOf(KEY1); //在字串 str 中索引關鍵字 KEY1 并將此字串所在位作為 索引 0 **IndexOf（索引的物件，開始的索引號）；**
string KEY2 = ",TIME:"; //定義關鍵字 KEY2 為 ",TIME:"
int index2 = str.IndexOf(KEY2); //在字串 str 中索引關鍵字 ",TIME:" 并將此字串所在位作為 索引 0
if (index1 >= 0 && index2 >= 0) //索引到關鍵字
{
int pos0 = str.IndexOf(",", index1 + KEY1.Length);//取接收到的字串的第一個逗號為索引
if (pos0 >= 0)
label2.Text = str.Substring(index1 + KEY1.Length, pos0 - (index1 + KEY1.Length)); //取出 KEY1 打頭 ，結尾的一段字串
int pos1 = str.IndexOf(",", pos0 + 1);
if (pos1 >= 0)
label3.Text = str.Substring(pos0 + 1, pos1 - (pos0 + 1)); //取出 0號逗號和1號 之間的 字串
int pos2 = str.IndexOf(",", index2 + KEY2.Length);
if (pos2 >= 0)
{
label4.Text = str.Substring(index2 + KEY2.Length, 23); // pos2 - (index2 + KEY2.Length)-2); //取出 KEY1 打頭 ，結尾的一段字串
if (KEY1 == "\r\nADC:")
{
int id = Convert.ToInt32(label2.Text); //將label2.Text字串型別值轉換為32位整型賦給id
double v = Convert.ToDouble(label3.Text); //將label3.Text字串型別值轉換為雙精度型賦給v
DateTime time = Convert.ToDateTime(label4.Text); //將label4.Text字串型別值轉換為時間型別賦給time
if (label2.Text == "1")
{
}
db.Insert_data(id, v, time, dbname, xuhao, value, date); //上傳資料到資料庫 1
//db.Insert_data(id, v, time,dbname); //上傳資料庫 1
AddToChart(id,v, time);
DataPointTest dp = new DataPointTest();
dp.appkey = "5TK53JepiCvPJ4k79XrBti4YEtI=";//APIKEY
int devid = 561695299; //設備號
dp.TestAddNewDataPoint(devid, "ADC" + id, v.ToString()); //***發送ADC資料到onenet云平臺***
//資料串列
//fLst.AddToListView(label2.Text, label3.Text, label4.Text);
//fLst.Show();
}
}
}
}
private void button2_Click(object sender, EventArgs e) //初始化ESP32_01按鈕程式
{
Thread thread_sp1 = new Thread(new ThreadStart(sp1_ReadData));
thread_sp1.Start();
}
private void button3_Click(object sender, EventArgs e)//FormDB_01按鈕
{
FormDB_01 f = new FormDB_01();
f.Show();
}
private void button4_Click(object sender, EventArgs e)//查詢按鈕未使用
{
}
private void btn_添加_Click(object sender, EventArgs e)// btn_添加_Click按鈕程式
{
DataPointTest dp = new DataPointTest();
dp.appkey = "3=Uaw=REPGSubU=rwVj8x=Hbb58=";
dp.TestAddNewDataPoint(Convert.ToInt32(txt設備號.Text), txt傳感器名.Text, txt數值.Text);
}
}
FromTCP.cs的程式
實作效果
class FormTCP : Form //創建TCP的類
public partial class FormTCP : Form //創建TCP的類
{
myTcp tcp1 = new myTcp();
public int Station_Number = 0;
public FormTCP()
{
InitializeComponent();
}
private void btn_Connect_Click(object sender, EventArgs e)//連接按鈕程式
{
//if (tcp1.server.Connected)
this.Text = "連接關閉！";
tcp1.server.Close();
Thread.Sleep(100);
tcp1.server = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);
IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(txtIP.Text), Convert.ToInt16(txtPort.Text));//TCP終端初始化
try//嘗試連接
{
if (!tcp1.server.Connected)
tcp1.server.Connect(ipep);
Thread.Sleep(10);
if (tcp1.server.Connected)
this.Text = "連接成功！";
}
catch (SocketException e2) //連接例外處理
{
//this.Text = e2
tcp1.server.Close();
}
}
private void button1_Click(object sender, EventArgs e)//關閉連接 按鈕程式
{
try{
tcp1.server.Close();
}
catch (SocketException e2) //連接例外處理
{
}
this.Text = "連接關閉！";
}
private void label7_Click(object sender, EventArgs e)//TCP發送的label 程式
{
tcp1.Tcp_Send(textBox2.Text);//發送textBox里的資料到Server端
}
private void timer2_Tick(object sender, EventArgs e)//Tcp的定時器2的程式用于查找分割好的字串并發送資料到Onenet云平臺
{
if (tcp1.strOut != "")
{
string str = tcp1.strOut;
textBox4.Text = str;
if (str != "")
{
string[] strArray = str.Split(new char[] { ',' });
string KEY;
KEY = "ADC:";
if (str.IndexOf(KEY) >= 0)
{
Find_KEY(str, KEY);
}
else
{
KEY = "KEY:";
Find_KEY(str, KEY);
}
}
tcp1.strOut = "";
}
}
void Find_KEY(string str, string KEY1)//用于分割接收到的字串
{
//string KEY1 = "KEY:";
int index1 = str.IndexOf(KEY1);
string KEY2 = ",TIME:";
int index2 = str.IndexOf(KEY2);
string label2_Text="", label3_Text="",label4_Text="";
if (index1 >= 0 && index2 >= 0)
{
int pos = str.IndexOf(",", index1 + KEY1.Length);
if (pos >= 0)
label2_Text = str.Substring(index1 + KEY1.Length, pos - (index1 + KEY1.Length));
int pos1 = str.IndexOf(",", pos + 1);
if (pos1 >= 0)
label3_Text = str.Substring(pos + 1, pos1 - (pos + 1));
int pos2 = str.IndexOf(",", index2 + KEY2.Length);
if (pos2 >= 0)
{
label4_Text = str.Substring(index2 + KEY2.Length, 23); // pos2 - (index2 + KEY2.Length)-2);
if (KEY1 == "ADC:")
{
int id = Convert.ToInt32(label2_Text);
double v = Convert.ToDouble(label3_Text);
DateTime time = Convert.ToDateTime(label4_Text);
DataPointTest dp = new DataPointTest();
dp.appkey = "5TK53JepiCvPJ4k79XrBti4YEtI=";
int devid = 561695299; //設備號
dp.TestAddNewDataPoint(devid, "ADC" + id, v.ToString()); //***發送ADC資料到onenet云平臺***
MainForm.Add_To_ListView_Form(Station_Number, id, v, time);//將資料添加到ListView_Form視窗
}
}
}
}
private void FormTCP_Load(object sender, EventArgs e)//打開TCP視窗時加載
{
tcp1.Start();
}
private void timer1_Tick(object sender, EventArgs e)//tcp定時器1的程式
{
if (checkBox回圈發送.Checked) //回圈發送ADC1,ADC2,ADC3
{
for (int i = 1; i <= 3; i++)
{
textBox2.Text = "ADC" + i;
Thread.Sleep(200);
tcp1.Tcp_Send(textBox2.Text);
}
}
}
}
MainForm.cs 程式
實作效果
class MainForm : Form
public partial class MainForm : Form
{
protected Boolean stop = false;
protected Boolean conState = false;
private StreamReader sRead;
//Form1 f1 = new Form1();
//Form1 f2 = new Form1();
//Form1 f3 = new Form1();
//FormList fLst = new FormList();
string strRecieve;
bool bAccept = false;
SerialPort sp = new SerialPort();
public static string strPortName = "";
public static string strBaudRate = "";
public static string strDataBits = "";
public static string strStopBits = "";
public static Form_ListView listViewForm; // = new Form_ListView();
public static FormTCP frmtcp1 = new FormTCP();
public static FormTCP frmtcp2 = new FormTCP();
public static chart frmChart1 = new chart();
public static chart frmChart2 = new chart();
public static void Add_To_ListView_Form(int Station_Number, int id, double v, DateTime time)
{
//if (gl_全域變數.Is_System_Exit) return;
if (listViewForm == null) listViewForm = new Form_ListView();
if (!listViewForm.Visible) listViewForm.Show();
string t;
//string str_MAC = ParseUtil.ToHexMAC(buf, 14, 6);
string str_MAC = Station_Number + "_" + id;
string str_KEY = "K" + str_MAC;
string str_Time = time.ToString("HH:mm:ss.fff");
if (listViewForm == null)
listViewForm = new Form_ListView();
int newid = Convert.ToInt32(Station_Number + "0" + id);
string dbname = "[歷史資料表一]";
string xuhao = "系統序號01";
string value = "當前值01";
string date = "時間01";
db.Insert_data(newid, v, time, dbname, xuhao, value, date); //上傳資料庫 1
if (Station_Number == 1)
{
frmChart1.AddToChart(id, v, time);
if (!frmChart1.Visible) frmChart1.Show();
}
if (Station_Number == 2)
{
frmChart2.AddToChart(id, v, time);
if (!frmChart2.Visible) frmChart2.Show();
}
//OneNet 使用新的傳感器序號 newid 101 、201
//DataPointTest dp = new DataPointTest();
//dp.appkey = "zsa=LDvUNxe6TUZq8M0V3HrA54k=";
//int devid = 578091985;
//dp.TestAddNewDataPoint(devid, "ADC" + newid, v.ToString());
ListViewItem item = null;
//if (listViewForm.listView1.Items.Count == 0){
item = listViewForm.listView1.Items.Add("", listViewForm.listView1.Items.Count.ToString(), 0);
t = str_Time; //SubItems[1]
item.SubItems.Add(t);
t = str_MAC; // ParseUtil.ToHexMAC(buf, 15, 6); //MAC SubItems[2]
item.SubItems.Add(t);
t = v.ToString();
item.SubItems.Add(t);
t = ""; //Header4 - 11
item.SubItems.Add(t);
item.SubItems.Add(t);
item.SubItems.Add(t);
item.SubItems.Add(t);
item.SubItems.Add(t);
item.SubItems.Add(t);
item.SubItems.Add(t);
item.SubItems.Add(t);
}
public MainForm()
{
InitializeComponent();
}
private void btnSetSP_Click(object sender, EventArgs e)//串口設定
{
timer1.Enabled = false;
sp.Close();
}
private void btnSwitchSP_Click(object sender, EventArgs e)//打開串口
{
if (btnSwitchSP.Text == "打開串口")
{
if (strPortName != "" && strBaudRate != "" && strDataBits != "" && strStopBits != "")
{
try
{
if (sp.IsOpen)
{
sp.Close();
sp.Open(); //打開串口
}
else
{
sp.Open();//打開串口
}
btnReceiveData_Click(sender,e);
btnSwitchSP.Text = "關閉串口";
groupBox1.Enabled = true;
groupBox2.Enabled = true;
this.toolStripStatusLabel1.Text = "埠號：" + sp.PortName + " 丨";
this.toolStripStatusLabel2.Text = "波特率：" + sp.BaudRate + " 丨";
this.toolStripStatusLabel3.Text = "資料位：" + sp.DataBits + " 丨";
this.toolStripStatusLabel4.Text = "停止位：" + sp.StopBits + " 丨";
this.toolStripStatusLabel5.Text = "";
}
catch (Exception ex)
{
MessageBox.Show("錯誤：" + ex.Message,"C#串口通信");
}
}
else
{
MessageBox.Show("請先設定串口！","RS232串口通信");
}
}
else
{
timer1.Enabled = false;
btnSwitchSP.Text = "打開串口";
sp.Close();
groupBox1.Enabled = false;
groupBox2.Enabled = false;
this.toolStripStatusLabel1.Text = "埠號：埠未打開丨";
this.toolStripStatusLabel2.Text = "波特率：埠未打開丨";
this.toolStripStatusLabel3.Text = "資料位：埠未打開丨";
this.toolStripStatusLabel4.Text = "停止位：埠未打開丨";
this.toolStripStatusLabel5.Text = "";
}
}
private void btnSendData_Click(object sender, EventArgs e)//資料發送
{
if (sp.IsOpen)
{
try
{
sp.Encoding = System.Text.Encoding.GetEncoding("GB2312");//GB2312即資訊交換用漢字編碼字符集
sp.Write(txtSend.Text);
}
catch (Exception ex)//若應用程式出現除錯問題
{
MessageBox.Show("錯誤：" + ex.Message);
}
}
else
{
MessageBox.Show("請先打開串口！");
}
}
delegate void DelegateAcceptData();
void fun()
{
while (bAccept )
{ AcceptData(); }
}
delegate void reaction();
void AcceptData()
{
if (textBox2.InvokeRequired)
{
try
{
DelegateAcceptData ddd = new DelegateAcceptData(AcceptData);
this.Invoke(ddd, new object[] { });
}
catch { }
}
else
{
try
{
strRecieve = sp.ReadExisting();
textBox2.Text += strRecieve;
}
catch (Exception e) { }
}
}
private void btnReceiveData_Click(object sender, EventArgs e)//接受資訊
{
if (sp.IsOpen)
{
sp.Encoding = System.Text.Encoding.GetEncoding("GB2312");//GB2312即資訊交換用漢字編碼字符集
timer2.Enabled = true;
}
else
{
MessageBox.Show("請先打開串口！");
}
}
private void timer1_Tick(object sender, EventArgs e)
{
string str1;
str1 = sRead.ReadLine();
if (str1 == null)
{
timer1.Stop();
sRead.Close();
MessageBox.Show("檔案發送成功！","C#串口通信");
this.toolStripStatusLabel5.Text = "";
return;
}
byte[] data = Encoding.Default.GetBytes(str1);
sp.Write(data, 0, data.Length);
this.toolStripStatusLabel5.Text = " 檔案發送中...";
}
private void btnOutputInfo_Click(object sender, EventArgs e) //匯出資訊到檔案
{
try
{
string path = @"D:\output.txt";
string content = this.textBox2.Text;
FileStream fs = new FileStream(path, FileMode.OpenOrCreate, FileAccess.Write);
StreamWriter write = new StreamWriter(fs);
write.Write(content);
write.Flush();
write.Close();
fs.Close();
MessageBox.Show("接收資訊匯出在" + path);
}
catch (Exception exp)
{
MessageBox.Show(exp.ToString());
}
}
private void btnClearInfo_Click(object sender, EventArgs e)//清空接受區
{
this.textBox2.Text = "";
}
private void btnQueryFile_Click(object sender, EventArgs e)//設定檔案路徑
{
String filename;
OpenFileDialog Open1 = new OpenFileDialog();
Open1.FileName = "";
Open1.ShowDialog();
filename = Open1.FileName;
if (filename == "")
{
MessageBox.Show("請選擇要發送的檔案！", "Error");
return;
}
textBox1.Text = filename;
if (filename != null)
{
StreamReader sRead = new StreamReader(filename);
}
btnReceiveData.Enabled = true;
}
private void btnSendFile_Click(object sender, EventArgs e)//檔案發送
{
string fileName = textBox1.Text;
if (fileName == "")
{
MessageBox.Show("請選擇要發送的檔案！", "Error");
return;
}
else
{
sRead = new StreamReader(fileName);
}
timer1.Start();
}
private void timer2_Tick(object sender, EventArgs e)
{
if (sp.IsOpen)
{
string str = sp.ReadExisting();
string str4 = str.Replace("\r", "\r\n");
textBox2.AppendText(str4);
textBox2.ScrollToCaret();
}
}
private void MainForm_Load(object sender, EventArgs e)
{
groupBox1.Enabled = false;
groupBox2.Enabled = false;
this.toolStripStatusLabel1.Text = "埠號：埠未打開丨";
this.toolStripStatusLabel2.Text = "波特率：埠未打開丨";
this.toolStripStatusLabel3.Text = "資料位：埠未打開丨";
this.toolStripStatusLabel4.Text = "停止位：埠未打開丨";
this.toolStripStatusLabel5.Text = "";
}
private void btn_Form1_Click(object sender, EventArgs e)
{
Form1 f1 = new Form1();
f1.Show();
//f1.Left = this.Left-500;
//f1.Top = this.Top + 100;
f1.Text = "COM1";
//f1.textBox1.Text = "COM1";
//f1.textBox1.Text = "COM1";
}
private void button3_Click_1(object sender, EventArgs e)
{
Form2 f2 = new Form2();
f2.Show();
//f2.Left = this.Left - 500;
//f2.Top = this.Top + 100;
f2.Text = "COM2";
}
private void btn_FormList_Click(object sender, EventArgs e)
{
//fLst.Show();
}
private void button1_Click(object sender, EventArgs e)
{
FormDB_01 f = new FormDB_01();
f.Show();
}
private void button2_Click(object sender, EventArgs e)
{
FormTCP frmtcp1 = new FormTCP();
frmtcp1.txtIP.Text = "10.1.1.64";
frmtcp1.txtPort.Text = "10000";
frmtcp1.Station_Number = 1;
frmtcp1.Text = "TCP" + frmtcp1.Station_Number;
frmtcp1.Show();
frmtcp1.Left = this.Left + this.Width;
//f1.Top = this.Top + 500;
FormTCP frmtcp2 = new FormTCP();
frmtcp2.txtIP.Text = "10.1.1.52";
frmtcp2.txtPort.Text = "10000";
frmtcp2.Station_Number = 2;
frmtcp2.Text = "TCP" + frmtcp2.Station_Number;
frmtcp2.Show();
frmtcp2.Left = frmtcp2.Left;
//frmtcp2.Top = frmtcp2.Top + 500;
}
private void btn打開Tcp_Server_Click(object sender, EventArgs e)
{
FormTcpServer f1 = new FormTcpServer();
f1.txtIP.Text = "127.0.0.1";
f1.txtPort.Text = "9050";
f1.Show();
f1.Left = this.Left + this.Width;
//f1.Top = this.Top + 500;
}
}
FromDB.cs 程式
實作效果
class FormDB_01 : Form 實作代碼
public partial class FormDB_01 : Form
{
public FormDB_01()
{
InitializeComponent();
}
private void FormDB_01_Load(object sender, EventArgs e)
{
// TODO: 這行代碼將資料加載到表“testDataSet.歷史資料表一”中，您可以根據需要移動或洗掉它，
this.歷史資料表一TableAdapter.Fill(this.testDataSet.歷史資料表一);
}
private void button1_Click(object sender, EventArgs e)
{
DataPointTest dp = new DataPointTest();
dp.TestSearchDataPointWithCondition(txt_APIKEY.Text, txt設備號.Text, comboBox1.Text); //查詢 發送到onenet云平臺的資料
textBox2.Text = dp.strOut;
textBox2.Text = dp.strOut;
}
}
by iNBC form SDUT（2020.11.11 pm11:00）
轉載請註明出處，本文鏈接：https://www.uj5u.com/qianduan/211920.html
標籤：其他
上一篇：【Microstation】三維建模基礎及軟體入門到精通實驗教程目錄
下一篇：人人都是好朋友