|
@@ -45,7 +45,7 @@ namespace Test
|
|
|
string user_data_tebles_sp = "user";
|
|
|
string user_data_tebles_log = "log";
|
|
|
|
|
|
- string server_ip = "118.190.37.99";
|
|
|
+ string server_ip = "39.105.214.155";
|
|
|
string server_port = "3306";
|
|
|
string mysql_user = "root";
|
|
|
string mysql_pass = "";
|
|
@@ -276,15 +276,15 @@ namespace Test
|
|
|
Client_connect = true;
|
|
|
byte[] arrMsg = System.Text.Encoding.UTF8.GetBytes(strMsg); // 将要发送的字符串转换成Utf-8字节数组;
|
|
|
// SendMsgdata(strMsg);//源数据下发 给所有客户端
|
|
|
- foreach (Socket s in dict.Values) //开始群发信息 遍历字典里面的连接好的socket客户端
|
|
|
- {
|
|
|
- if (s != sokClient)//判断是否是当前发送数据上来的客户端 是的话就不发送
|
|
|
- {
|
|
|
- s.Send(arrMsg);
|
|
|
-
|
|
|
- }
|
|
|
- // s.Send(arrMsg);
|
|
|
- }
|
|
|
+ //foreach (Socket s in dict.Values) //开始群发信息 遍历字典里面的连接好的socket客户端
|
|
|
+ //{
|
|
|
+ // if (s != sokClient)//判断是否是当前发送数据上来的客户端 是的话就不发送
|
|
|
+ // {
|
|
|
+ // s.Send(arrMsg);
|
|
|
+
|
|
|
+ // }
|
|
|
+ // // s.Send(arrMsg);
|
|
|
+ //}
|
|
|
str_check(strMsg);
|
|
|
//ShowMsg("发送消息为:" + strMsg);
|
|
|
}
|
|
@@ -333,7 +333,7 @@ namespace Test
|
|
|
}
|
|
|
private void Form1_Load(object sender, EventArgs e)
|
|
|
{
|
|
|
- dataGridView1.RowHeadersVisible = false; //隐藏首列
|
|
|
+ // dataGridView1.RowHeadersVisible = false; //隐藏首列
|
|
|
//String sqlConn = "server="+ server_ip + ";port=3306;user=root;password=licoo1128;database=test;Charset=utf8;";//定义连接字符串,Charset=utf8使可以填充中文字符不出现乱码
|
|
|
String sqlConn = "server='" + server_ip + "';port='" + server_port + "';user='" +
|
|
|
mysql_user + "';password='" + mysql_pass + "'; database='" + mysql_dataname + "';" + "Charset=utf8;";
|
|
@@ -348,7 +348,13 @@ namespace Test
|
|
|
bindingSource1.DataSource = ds.Tables[0];//绑定数据
|
|
|
bindingNavigator1.BindingSource = bindingSource1;//为导航控件绑定数据
|
|
|
dataGridView1.DataSource = bindingSource1;//为DataGridView数据控件绑定数据
|
|
|
+
|
|
|
dataGridView1.Columns[0].ReadOnly = true;//设置第1列,即id列不可编辑
|
|
|
+
|
|
|
+ dataGridView1.Columns[0].Width = 80;//设置列宽度
|
|
|
+ dataGridView1.Columns[1].Width = 120;//设置列宽度
|
|
|
+ dataGridView1.Columns[2].Width = 120;//设置列宽度
|
|
|
+ dataGridView1.Columns[3].Width = 120;//设置列宽度
|
|
|
}
|
|
|
catch (MySqlException ex)
|
|
|
{
|
|
@@ -437,6 +443,10 @@ namespace Test
|
|
|
dataGridView1.DataSource = bindingSource1;//为DataGridView数据控件绑定数据
|
|
|
dataGridView1.Columns[0].ReadOnly = true;//设置第1列,即id列不可编辑
|
|
|
// Console.WriteLine(bindingSource1.DataSource.ToString());
|
|
|
+ dataGridView1.Columns[0].Width = 80;//设置列宽度
|
|
|
+ dataGridView1.Columns[1].Width = 120;//设置列宽度
|
|
|
+ dataGridView1.Columns[2].Width = 120;//设置列宽度
|
|
|
+ dataGridView1.Columns[3].Width = 120;//设置列宽度
|
|
|
}
|
|
|
|
|
|
private void btnBulkAdd_Click(object sender, EventArgs e)
|
|
@@ -490,11 +500,11 @@ namespace Test
|
|
|
else
|
|
|
MessageBox.Show("操作失败");
|
|
|
|
|
|
- cmd.CommandText = string.Format("delete from " + mysql_dataname + "." + user_data_tebles_log);
|
|
|
- if (cmd.ExecuteNonQuery() > 0)
|
|
|
- MessageBox.Show("清空数据库成功");
|
|
|
- else
|
|
|
- MessageBox.Show("操作失败");
|
|
|
+ //cmd.CommandText = string.Format("delete from " + mysql_dataname + "." + user_data_tebles_log);
|
|
|
+ //if (cmd.ExecuteNonQuery() > 0)
|
|
|
+ // MessageBox.Show("清空数据库成功");
|
|
|
+ //else
|
|
|
+ // MessageBox.Show("操作失败");
|
|
|
|
|
|
adapter = new MySqlDataAdapter("select * from " + user_data_tebles_sp, conn);
|
|
|
DataSet ds = new DataSet();
|
|
@@ -646,6 +656,7 @@ namespace Test
|
|
|
if(datstr!="")
|
|
|
{
|
|
|
insert_data(GetCurrentTime().ToString(), datstr);
|
|
|
+ SendMsgdata("server_send:Completion\r\n");//下发到下位机提示交易完成
|
|
|
}
|
|
|
|
|
|
}
|
|
@@ -806,8 +817,24 @@ namespace Test
|
|
|
|
|
|
dataGridView1.Columns[0].Width = 60;//设置列宽度
|
|
|
dataGridView1.Columns[1].Width = 180;//设置列宽度
|
|
|
+ // dataGridView1.Columns[3].Width = 80;//设置列宽度
|
|
|
+ dataGridView1.Columns[2].Width = 200;//设置列宽度
|
|
|
+ }
|
|
|
+
|
|
|
+ private void button1_Click_1(object sender, EventArgs e)
|
|
|
+ {
|
|
|
+ cmd.CommandText = string.Format("delete from " + mysql_dataname + "." + user_data_tebles_log);
|
|
|
+ if (cmd.ExecuteNonQuery() > 0)
|
|
|
+ MessageBox.Show("清空数据库成功");
|
|
|
+ else
|
|
|
+ MessageBox.Show("操作失败");
|
|
|
|
|
|
- dataGridView1.Columns[2].Width = 100;//设置列宽度
|
|
|
+ adapter = new MySqlDataAdapter("select * from " + user_data_tebles_log, conn);
|
|
|
+ DataSet ds = new DataSet();
|
|
|
+ adapter.Fill(ds);//填充数据至ds数据集
|
|
|
+ bindingSource1.DataSource = ds.Tables[0];//绑定数据
|
|
|
+ bindingNavigator1.BindingSource = bindingSource1;//为导航控件绑定数据
|
|
|
+ dataGridView1.DataSource = bindingSource1;//为DataGridView数据控件绑定数据
|
|
|
}
|
|
|
}
|
|
|
}
|