843 lines
35 KiB
C#
843 lines
35 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.ComponentModel;
|
||
using System.Data;
|
||
using System.Data.SqlClient;
|
||
using System.Drawing;
|
||
using System.IO;
|
||
using System.Text;
|
||
using System.Text.RegularExpressions;
|
||
using System.Threading;
|
||
using System.Windows.Forms;
|
||
using LitJson;
|
||
using MySql.Data.MySqlClient;
|
||
namespace SimpleServer
|
||
{
|
||
public partial class ServerForm : Form
|
||
{
|
||
//获取当前程序运行路径
|
||
private string Save_Path = System.AppDomain.CurrentDomain.SetupInformation.ApplicationBase + @"数据记录\";
|
||
|
||
int date_flag = DateTime.Now.DayOfYear;
|
||
static string COD;
|
||
static string ammnit;
|
||
static string tonitro;
|
||
static string tophosp;
|
||
static string ph;
|
||
static string oxyen;
|
||
static string Tem;
|
||
static string conductivity;
|
||
static string turbidity;
|
||
static string time;
|
||
public struct Model
|
||
{
|
||
public string Datetime { get; set; }
|
||
public string Measparam { get; set; }
|
||
public string Value { get; set; }
|
||
public string Unit { get; set; }
|
||
public string Type { get; set; }
|
||
public string dataflag { get; set; }
|
||
}
|
||
#region DataMember & Ctor
|
||
private Server server = new Server();
|
||
private Server_10 server_10 = new Server_10();
|
||
|
||
public ServerForm()
|
||
{
|
||
InitializeComponent();
|
||
ServerDlgSubscribe(true);
|
||
ServerDlgSubscribe_10(true);
|
||
}
|
||
#endregion
|
||
|
||
#region 界面事件处理
|
||
private void btnStart_Click(object sender, EventArgs e)
|
||
{
|
||
string ip = this.tbIP.Text.Trim();
|
||
string port = this.tbPort.Text.Trim();
|
||
if (server.Start(ip, int.Parse(port)))
|
||
{
|
||
ModifyShowsByServerState(true);
|
||
}
|
||
Thread acceptClientThread = new Thread(BeginAcceptClient);
|
||
acceptClientThread.IsBackground = true;
|
||
acceptClientThread.Start();
|
||
}
|
||
|
||
private void btnClose_Click(object sender, EventArgs e)
|
||
{
|
||
if (server.ServerClose())
|
||
{
|
||
ModifyShowsByServerState(false);
|
||
}
|
||
server.DisconnectClient();
|
||
}
|
||
|
||
private void btnClear_Click(object sender, EventArgs e)
|
||
{
|
||
this.txtRecv.Clear();
|
||
}
|
||
|
||
private void btnSend_Click(object sender, EventArgs e)
|
||
{
|
||
byte[] msg = new byte[10];
|
||
|
||
msg[0] = 0x01;
|
||
msg[1] = 0x02;
|
||
server.SendMsg(msg);
|
||
}
|
||
|
||
private void btnDisconnect_Click(object sender, EventArgs e)
|
||
{
|
||
server.DisconnectClient();
|
||
}
|
||
|
||
private void ServerForm_FormClosing(object sender, FormClosingEventArgs e)
|
||
{
|
||
ServerDlgSubscribe(false);
|
||
}
|
||
|
||
private void ServerForm_Load(object sender, EventArgs e)
|
||
{
|
||
ModifyShowsByServerState(false);
|
||
ModifyShowsByClientState(false);
|
||
}
|
||
#endregion
|
||
|
||
#region 界面逻辑函数
|
||
/// <summary>
|
||
/// 根据监听状态修改界面显示
|
||
/// ServerForm_Load,点击启用服务器，关闭服务器按钮后调用
|
||
/// </summary>
|
||
/// <param name="serverStart"></param>
|
||
private void ModifyShowsByServerState(bool serverStart)
|
||
{
|
||
this.btnStart.Enabled = !serverStart;
|
||
this.btnClose.Enabled = serverStart;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 根据监听状态修改界面显示 -端口号2010
|
||
/// ServerForm_Load,点击启用服务器，关闭服务器按钮后调用
|
||
/// </summary>
|
||
/// <param name="serverStart"></param>
|
||
private void ModifyShowsByServerState_10(bool serverStart)
|
||
{
|
||
this.btnStart_10.Enabled = !serverStart;
|
||
this.btnClose_10.Enabled = serverStart;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 根据连接状态修改界面显示
|
||
/// ServerForm_Load,Server_NewClientEvent，Server_RemoteDisconnectEvent，Server_LocalDisconnectEvent调用到
|
||
/// </summary>
|
||
/// <param name="clientConnect"></param>
|
||
private void ModifyShowsByClientState(bool clientConnect)
|
||
{
|
||
this.btnSend.Enabled = clientConnect;
|
||
this.btnDisconnect.Enabled = clientConnect;
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 根据连接状态修改界面显示
|
||
/// ServerForm_Load,Server_NewClientEvent，Server_RemoteDisconnectEvent，Server_LocalDisconnectEvent调用到
|
||
/// </summary>
|
||
/// <param name="clientConnect"></param>
|
||
private void ModifyShowsByClientState_10(bool clientConnect)
|
||
{
|
||
this.btnSend.Enabled = clientConnect;
|
||
this.btnDisconnect_10.Enabled = clientConnect;
|
||
}
|
||
|
||
|
||
private string splitSymbols = "\r\n\r\n";
|
||
/// <summary>
|
||
/// 日志记录
|
||
/// </summary>
|
||
/// <param name="content"></param>
|
||
private void LogRecord(string content)
|
||
{
|
||
this.txtLog.AppendText(content + splitSymbols);
|
||
}
|
||
public double ConvertDateTimeInt(System.DateTime time)//将时间格式的数据类型转换成浮点数类型
|
||
|
||
{
|
||
|
||
double intResult = 0;
|
||
|
||
System.DateTime startTime = TimeZone.CurrentTimeZone.ToLocalTime(new System.DateTime(1970,1,1));
|
||
|
||
intResult =(time - startTime).TotalSeconds;
|
||
|
||
return intResult;
|
||
|
||
}
|
||
public double ConvertByteDouble(byte [] d)
|
||
{
|
||
double result=0;
|
||
float q = BitConverter.ToSingle(d, 0);
|
||
result = (double)q;
|
||
return result;
|
||
}
|
||
public byte[] ConvertDoubleByte(double d)
|
||
{
|
||
byte[] result = new byte[4];
|
||
float f=(float)d;
|
||
result = BitConverter.GetBytes(f);
|
||
return result;
|
||
}
|
||
private static byte[] strToToHexByte(string hexString)
|
||
{
|
||
hexString = hexString.Replace(" ", "");
|
||
if ((hexString.Length % 2) != 0)
|
||
hexString += " ";
|
||
byte[] returnBytes = new byte[hexString.Length / 2];
|
||
for (int i = 0; i < returnBytes.Length; i++)
|
||
returnBytes[i] = Convert.ToByte(hexString.Substring(i * 2, 2), 16);
|
||
return returnBytes;
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 将收文或发文字符串处理后加入文本接收区 -2009
|
||
/// </summary>
|
||
/// <param name="param"></param>
|
||
/// --------------------------------------------------------------------------------------------
|
||
private void AppendText(byte[] param)
|
||
{
|
||
string strRcv = null;
|
||
//int decNum = 0;//存储十进制
|
||
for (int i = 0; i < param.Length; i++) //窗体显示
|
||
{
|
||
|
||
strRcv += param[i].ToString("X2"); //16进制显示
|
||
|
||
}
|
||
string strRcv_1 = strRcv.Substring(0,116);
|
||
|
||
Tools.AddLgoToTXT("端口号2009原始报文.txt", Save_Path + System.DateTime.Now.ToString("yyyy_MM_dd") + @"\", System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " ---- " + strRcv_1 + "\r\n");
|
||
|
||
string str;
|
||
int datenow = DateTime.Now.DayOfYear;
|
||
|
||
if (strRcv_1.Substring(10,2) == "02")
|
||
{ //实时数据功能码
|
||
if (strRcv_1.Substring(12, 2) == "09")
|
||
{//凯米斯大类
|
||
if (strRcv_1.Substring(14, 2) == "00")
|
||
{//数据类型hex
|
||
|
||
int data_tem = Convert.ToInt32(strRcv_1.Substring(16, 4), 16);//tem整数
|
||
//float f_tem = Convert.ToSingle(data_tem);//转float
|
||
int data_x = Convert.ToInt32(strRcv_1.Substring(20, 4),16);//小数
|
||
float t_tem=(float)Math.Pow(10,(double)data_x);//次方
|
||
float Tem = data_tem / t_tem;
|
||
|
||
int data_ph = Convert.ToInt32(strRcv_1.Substring(24, 4), 16);//PH整数
|
||
//float f_ph = Convert.ToSingle(data_ph);//转float
|
||
int data_x_ph = Convert.ToInt32(strRcv_1.Substring(28, 4), 16);//小数
|
||
float t_ph = (float)Math.Pow(10, (double)data_x_ph);//次方
|
||
//int data_ph = 1;
|
||
float COD = data_ph / t_ph;
|
||
|
||
|
||
int data_oxy = Convert.ToInt32(strRcv_1.Substring(32, 4), 16);//oxy整数
|
||
//float f_oxy = Convert.ToSingle(data_oxy);//转float
|
||
int data_x_oxy = Convert.ToInt32(strRcv_1.Substring(36, 4), 16);//小数
|
||
float t_oxy = (float)Math.Pow(10, (double)data_x_oxy);//次方
|
||
float turbid = data_oxy / t_oxy;
|
||
|
||
int data_conductivity = Convert.ToInt32(strRcv_1.Substring(40, 4), 16);//conductivity整数
|
||
//float f_conductivity = Convert.ToSingle(data_conductivity);//转float
|
||
int data_x_pconductivity = Convert.ToInt32(strRcv_1.Substring(44, 4), 16);//小数
|
||
float t_pconductivity = (float)Math.Pow(10, (double)data_x_pconductivity);//次方
|
||
float Conductivity = data_conductivity / t_pconductivity;
|
||
|
||
int data_turbity = Convert.ToInt32(strRcv_1.Substring(48, 4), 16);//turbity整数
|
||
//float f_turbity = Convert.ToSingle(data_turbity);//转float
|
||
int data_x_turbity = Convert.ToInt32(strRcv_1.Substring(52, 4), 16);//小数
|
||
float t_turbity = (float)Math.Pow(10, (double)data_x_turbity);//次方
|
||
float PH = data_turbity / t_turbity;
|
||
|
||
int data_ammnit = Convert.ToInt32(strRcv_1.Substring(56, 4), 16);//ammnit整数
|
||
//float f_ammnit = Convert.ToSingle(data_ammnit);//转float
|
||
int data_x_ammnit = Convert.ToInt32(strRcv_1.Substring(60, 4), 16);//小数
|
||
float t_ammnit = (float)Math.Pow(10, (double)data_x_ammnit);//次方
|
||
float ORP = data_ammnit / t_ammnit;
|
||
|
||
int data_orp = Convert.ToInt32(strRcv_1.Substring(64, 4), 16);//orp整数
|
||
// float f_orp = Convert.ToSingle(data_orp);//转float
|
||
int data_x_orp = Convert.ToInt32(strRcv_1.Substring(68, 4), 16);//小数
|
||
float t_orp = (float)Math.Pow(10, (double)data_x_orp);//次方
|
||
float OXY = data_orp / t_orp;
|
||
|
||
int data_cod = Convert.ToInt32(strRcv_1.Substring(72, 4), 16);//orp整数
|
||
//float f_cod = Convert.ToSingle(data_cod);//转float
|
||
int data_x_cod = Convert.ToInt32(strRcv_1.Substring(76, 4), 16);//小数
|
||
float t_cod = (float)Math.Pow(10, (double)data_x_cod);//次方
|
||
float NH4 = data_cod / t_cod;
|
||
|
||
int data_zhuodu = Convert.ToInt32(strRcv_1.Substring(80, 4), 16);//zhuodu
|
||
//float f_cod = Convert.ToSingle(data_cod);//转float
|
||
int data_x_zhuodu = Convert.ToInt32(strRcv_1.Substring(84, 4), 16);//小数
|
||
float t_zhuodu = (float)Math.Pow(10, (double)data_x_cod);//次方
|
||
float zhuodu = data_zhuodu / t_zhuodu;
|
||
|
||
|
||
int HUM = Convert.ToInt32(strRcv_1.Substring(100, 4), 16);//HUM
|
||
//float f_cod = Convert.ToSingle(data_cod);//转float
|
||
/*float HUM_1 = (HUM / 1000)*33;*/
|
||
float HUM_1 = 33;
|
||
DateTime time_2 = DateTime.Now;
|
||
string constr = "server=localhost;User Id=root;password=ztt12345!;Database=ningbo_wireless";
|
||
|
||
|
||
MySqlConnection mycon = new MySqlConnection(constr);
|
||
|
||
mycon.Open();
|
||
|
||
MySqlCommand mycmd = new MySqlCommand("insert into ningbo_wireless_data(id,data_time,Tem,PH,Turbidity,Ammnit,oxygen,COD,Water_level,Hum) values('0201','" + time_2 + "','" + Tem + "','" + PH + "','" + zhuodu + "','" + NH4 + "','" + OXY + "','" + COD + "','II','" + HUM_1 + "')", mycon);//数据库插入
|
||
|
||
Tools.AddLgoToTXT("端口号2009解析数据.txt", Save_Path + System.DateTime.Now.ToString("yyyy_MM_dd") + @"\", System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " ---- " + ",data_time:" + time_2 + ",Tem:" + Tem + ",PH:" + PH + ",zhuodu" + zhuodu + ",NH4:" + NH4 + ",OXY:" + OXY + ",COD:" + COD + "','II','" + HUM_1 + "\r\n");
|
||
//MySqlCommand mycmd_1 = new MySqlCommand("DELETE FROM kfq_node2_sensor WHERE id NOT IN (SELECT kfq_node2_sensor_copy.id FROM(SELECT MIN(id) AS id FROM kfq_node2_sensor GROUP BY data_time) kfq_node2_sensor_copy)", mycon_1);
|
||
//MySqlCommand mycmd_2 = new MySqlCommand("DELETE FROM kfq_node3_sensor WHERE id NOT IN (SELECT kfq_node3_sensor_copy.id FROM(SELECT MIN(id) AS id FROM kfq_node3_sensor GROUP BY data_time) kfq_node3_sensor_copy)", mycon_2);
|
||
//MySqlCommand mycmd_3 = new MySqlCommand("DELETE FROM kfq_node4_sensor WHERE id NOT IN (SELECT kfq_node4_sensor_copy.id FROM(SELECT MIN(id) AS id FROM kfq_node4_sensor GROUP BY data_time) kfq_node4_sensor_copy)", mycon_3);
|
||
try
|
||
{
|
||
if (mycmd.ExecuteNonQuery() > 0)
|
||
{
|
||
Console.WriteLine("数据插入成功！");
|
||
}
|
||
else
|
||
{
|
||
Console.WriteLine("数据插入wei成功！");
|
||
}
|
||
}
|
||
catch (System.Exception ex)
|
||
{
|
||
//MessageBox.Show(ex.Message, "cuowu");
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
|
||
}
|
||
//FEEF002601020900000000000000000000000000000000000000000000000000000000000100FC001C16
|
||
|
||
|
||
/*if (datenow != date_flag)
|
||
{
|
||
FileStream fs1 = new FileStream(str, FileMode.Create, FileAccess.Write);//创建写入文件
|
||
StreamWriter sw = new StreamWriter(fs1);//添加文本结束符等
|
||
// sw.WriteLine(data00.ToString() + ' ' + data11.ToString() + ' ' + data22.ToString() + ' ' + data33.ToString() + ' ' + data44.ToString() + ' ' + data55.ToString() + ' ' + data000.ToString() + ' ' + data111.ToString() + ' ' + data222.ToString() + ' ' + DateTime.Now.ToString());//开始写入值
|
||
sw.WriteLine(param);
|
||
sw.Close();
|
||
fs1.Close();
|
||
}
|
||
else
|
||
{
|
||
FileStream fs = new FileStream(str, FileMode.Append, FileAccess.Write);
|
||
StreamWriter sr = new StreamWriter(fs);
|
||
// sr.WriteLine(data00.ToString() + ' ' + data11.ToString() + ' ' + data22.ToString() + ' ' + data33.ToString() + ' ' + data44.ToString() + ' ' + data55.ToString() + ' ' + data000.ToString() + ' ' + data111.ToString() + ' ' + data222.ToString() + ' ' + DateTime.Now.ToString());//开始写入值
|
||
sr.WriteLine(param);
|
||
sr.Close();
|
||
fs.Close();
|
||
}*/
|
||
date_flag = DateTime.Now.DayOfYear;
|
||
|
||
int index1 = this.txtRecv.Text.Length;
|
||
int length1 = strRcv_1.IndexOf("\r\n");
|
||
int index2 = index1 + length1 + 2;
|
||
int length2 = param.Length - length1 - 2;
|
||
this.txtRecv.AppendText(strRcv_1);
|
||
this.txtRecv.Select(index1, length1);
|
||
this.txtRecv.SelectionColor = Color.Green;
|
||
this.txtRecv.Select(index2, length2);
|
||
this.txtRecv.SelectionColor = Color.Black;
|
||
this.txtRecv.Select(this.txtRecv.Text.Length, 0);
|
||
this.txtRecv.Focus();
|
||
}
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 将收文或发文字符串处理后加入文本接收区--2010
|
||
/// </summary>
|
||
/// <param name="param"></param>
|
||
/// --------------------------------------------------------------------------------------------
|
||
private void AppendText_10(byte[] param)
|
||
{
|
||
string strRcv = null;
|
||
//int decNum = 0;//存储十进制
|
||
for (int i = 0; i < param.Length; i++) //窗体显示
|
||
{
|
||
|
||
strRcv += param[i].ToString("X2"); //16进制显示
|
||
|
||
}
|
||
string strRcv_1 = strRcv.Substring(0, 116);
|
||
Tools.AddLgoToTXT("端口号2010原始报文.txt", Save_Path + System.DateTime.Now.ToString("yyyy_MM_dd") + @"\", System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " ---- " + strRcv_1 + "\r\n");
|
||
|
||
string str;
|
||
int datenow = DateTime.Now.DayOfYear;
|
||
|
||
if (strRcv_1.Substring(10, 2) == "02")
|
||
{ //实时数据功能码
|
||
if (strRcv_1.Substring(12, 2) == "09")
|
||
{//凯米斯大类
|
||
if (strRcv_1.Substring(14, 2) == "00")
|
||
{//数据类型hex
|
||
|
||
int data_tem = Convert.ToInt32(strRcv_1.Substring(16, 4), 16);//tem整数
|
||
//float f_tem = Convert.ToSingle(data_tem);//转float
|
||
int data_x = Convert.ToInt32(strRcv_1.Substring(20, 4), 16);//小数
|
||
float t_tem = (float)Math.Pow(10, (double)data_x);//次方
|
||
float Tem = data_tem / t_tem;
|
||
|
||
int data_ph = Convert.ToInt32(strRcv_1.Substring(24, 4), 16);//PH整数
|
||
//float f_ph = Convert.ToSingle(data_ph);//转float
|
||
int data_x_ph = Convert.ToInt32(strRcv_1.Substring(28, 4), 16);//小数
|
||
float t_ph = (float)Math.Pow(10, (double)data_x_ph);//次方
|
||
//int data_ph = 1;
|
||
float COD = data_ph / t_ph;
|
||
|
||
|
||
int data_oxy = Convert.ToInt32(strRcv_1.Substring(32, 4), 16);//oxy整数
|
||
//float f_oxy = Convert.ToSingle(data_oxy);//转float
|
||
int data_x_oxy = Convert.ToInt32(strRcv_1.Substring(36, 4), 16);//小数
|
||
float t_oxy = (float)Math.Pow(10, (double)data_x_oxy);//次方
|
||
float turbid = data_oxy / t_oxy;
|
||
|
||
int data_conductivity = Convert.ToInt32(strRcv_1.Substring(40, 4), 16);//conductivity整数
|
||
//float f_conductivity = Convert.ToSingle(data_conductivity);//转float
|
||
int data_x_pconductivity = Convert.ToInt32(strRcv_1.Substring(44, 4), 16);//小数
|
||
float t_pconductivity = (float)Math.Pow(10, (double)data_x_pconductivity);//次方
|
||
float Conductivity = data_conductivity / t_pconductivity;
|
||
|
||
int data_turbity = Convert.ToInt32(strRcv_1.Substring(48, 4), 16);//turbity整数
|
||
//float f_turbity = Convert.ToSingle(data_turbity);//转float
|
||
int data_x_turbity = Convert.ToInt32(strRcv_1.Substring(52, 4), 16);//小数
|
||
float t_turbity = (float)Math.Pow(10, (double)data_x_turbity);//次方
|
||
float PH = data_turbity / t_turbity;
|
||
|
||
int data_ammnit = Convert.ToInt32(strRcv_1.Substring(56, 4), 16);//ammnit整数
|
||
//float f_ammnit = Convert.ToSingle(data_ammnit);//转float
|
||
int data_x_ammnit = Convert.ToInt32(strRcv_1.Substring(60, 4), 16);//小数
|
||
float t_ammnit = (float)Math.Pow(10, (double)data_x_ammnit);//次方
|
||
float ORP = data_ammnit / t_ammnit;
|
||
|
||
int data_orp = Convert.ToInt32(strRcv_1.Substring(64, 4), 16);//orp整数
|
||
// float f_orp = Convert.ToSingle(data_orp);//转float
|
||
int data_x_orp = Convert.ToInt32(strRcv_1.Substring(68, 4), 16);//小数
|
||
float t_orp = (float)Math.Pow(10, (double)data_x_orp);//次方
|
||
float OXY = data_orp / t_orp;
|
||
|
||
int data_cod = Convert.ToInt32(strRcv_1.Substring(72, 4), 16);//orp整数
|
||
//float f_cod = Convert.ToSingle(data_cod);//转float
|
||
int data_x_cod = Convert.ToInt32(strRcv_1.Substring(76, 4), 16);//小数
|
||
float t_cod = (float)Math.Pow(10, (double)data_x_cod);//次方
|
||
float NH4 = data_cod / t_cod;
|
||
|
||
int data_zhuodu = Convert.ToInt32(strRcv_1.Substring(80, 4), 16);//zhuodu
|
||
//float f_cod = Convert.ToSingle(data_cod);//转float
|
||
int data_x_zhuodu = Convert.ToInt32(strRcv_1.Substring(84, 4), 16);//小数
|
||
float t_zhuodu = (float)Math.Pow(10, (double)data_x_cod);//次方
|
||
float zhuodu = data_zhuodu / t_zhuodu;
|
||
|
||
|
||
int HUM = Convert.ToInt32(strRcv_1.Substring(100, 4), 16);//HUM
|
||
//float f_cod = Convert.ToSingle(data_cod);//转float
|
||
float HUM_1 = (HUM / 1000) * 33;
|
||
|
||
int V0 = Convert.ToInt32(strRcv_1.Substring(108, 4), 16);//HUM
|
||
//float f_cod = Convert.ToSingle(data_cod);//转float
|
||
double V1 = (V0 / 1000.00) * 11.16;
|
||
|
||
DateTime time_2 = DateTime.Now;
|
||
string constr = "server=localhost;User Id=root;password=ztt12345!;Database=ningbo_wireless";
|
||
|
||
|
||
MySqlConnection mycon = new MySqlConnection(constr);
|
||
|
||
mycon.Open();
|
||
|
||
MySqlCommand mycmd = new MySqlCommand("insert into ningbo_wireless1_data(id,data_time,Tem,PH,Turbidity,Ammnit,oxygen,COD,Water_level,Hum,Vol) values('0201','" + time_2 + "','" + Tem + "','" + PH + "','" + zhuodu + "','" + NH4 + "','" + OXY + "','" + COD + "','II','" + HUM_1 + "','" + V1 + "')", mycon);//数据库插入
|
||
Tools.AddLgoToTXT("端口号2010解析数据.txt", Save_Path + System.DateTime.Now.ToString("yyyy_MM_dd") + @"\", System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " ---- " + ",data_time:" + time_2 + ",Tem:" + Tem + ",PH:" + PH + ",zhuodu" + zhuodu + ",NH4:" + NH4 + ",OXY:" + OXY + ",COD:" + COD + "','II','" + HUM_1 + "\r\n");
|
||
|
||
//MySqlCommand mycmd_1 = new MySqlCommand("DELETE FROM kfq_node2_sensor WHERE id NOT IN (SELECT kfq_node2_sensor_copy.id FROM(SELECT MIN(id) AS id FROM kfq_node2_sensor GROUP BY data_time) kfq_node2_sensor_copy)", mycon_1);
|
||
//MySqlCommand mycmd_2 = new MySqlCommand("DELETE FROM kfq_node3_sensor WHERE id NOT IN (SELECT kfq_node3_sensor_copy.id FROM(SELECT MIN(id) AS id FROM kfq_node3_sensor GROUP BY data_time) kfq_node3_sensor_copy)", mycon_2);
|
||
//MySqlCommand mycmd_3 = new MySqlCommand("DELETE FROM kfq_node4_sensor WHERE id NOT IN (SELECT kfq_node4_sensor_copy.id FROM(SELECT MIN(id) AS id FROM kfq_node4_sensor GROUP BY data_time) kfq_node4_sensor_copy)", mycon_3);
|
||
try
|
||
{
|
||
if (mycmd.ExecuteNonQuery() > 0)
|
||
{
|
||
Console.WriteLine("数据插入成功！");
|
||
}
|
||
else
|
||
{
|
||
Console.WriteLine("数据插入wei成功！");
|
||
}
|
||
}
|
||
catch (System.Exception ex)
|
||
{
|
||
//MessageBox.Show(ex.Message, "cuowu");
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
|
||
}
|
||
date_flag = DateTime.Now.DayOfYear;
|
||
|
||
int index1 = this.txtRecv.Text.Length;
|
||
int length1 = strRcv_1.IndexOf("\r\n");
|
||
int index2 = index1 + length1 + 2;
|
||
int length2 = param.Length - length1 - 2;
|
||
this.txtRecv.AppendText(strRcv_1);
|
||
this.txtRecv.Select(index1, length1);
|
||
this.txtRecv.SelectionColor = Color.Green;
|
||
this.txtRecv.Select(index2, length2);
|
||
this.txtRecv.SelectionColor = Color.Black;
|
||
this.txtRecv.Select(this.txtRecv.Text.Length, 0);
|
||
this.txtRecv.Focus();
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 业务逻辑处理
|
||
/// <summary>
|
||
/// 监听启动之后，线程中启动连接接收
|
||
/// </summary>
|
||
private void BeginAcceptClient()
|
||
{
|
||
server.BeginAcceptClient();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 监听启动之后，线程中启动连接接收-10
|
||
/// </summary>
|
||
private void BeginAcceptClient_10()
|
||
{
|
||
server_10.BeginAcceptClient();
|
||
}
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 在构造函数和ServerForm_FormClosing里调用
|
||
/// </summary>
|
||
/// <param name="add"></param>
|
||
private void ServerDlgSubscribe(bool add)
|
||
{
|
||
if (add)
|
||
{
|
||
server.ServerStartEvent += new DlgNoParam(Server_ServerStartEvent);
|
||
server.ServerCloseEvent += new DlgNoParam(Server_ServerCloseEvent);
|
||
server.NewClientEvent += new DlgOneParam<string>(Server_NewClientEvent);
|
||
server.RecvMsgEvent += new DlgOneParam<byte[]>(Server_RecvMsgEvent);
|
||
server.RemoteDisconnectEvent += new DlgOneParam<string>(Server_RemoteDisconnectEvent);
|
||
server.LocalDisconnectEvent += new DlgNoParam(Server_LocalDisconnectEvent);
|
||
}
|
||
else
|
||
{
|
||
server.ServerStartEvent -= new DlgNoParam(Server_ServerStartEvent);
|
||
server.ServerCloseEvent -= new DlgNoParam(Server_ServerCloseEvent);
|
||
server.NewClientEvent -= new DlgOneParam<string>(Server_NewClientEvent);
|
||
server.RecvMsgEvent -= new DlgOneParam<byte[]>(Server_RecvMsgEvent);
|
||
server.RemoteDisconnectEvent -= new DlgOneParam<string>(Server_RemoteDisconnectEvent);
|
||
server.LocalDisconnectEvent -= new DlgNoParam(Server_LocalDisconnectEvent);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 在构造函数和ServerForm_FormClosing里调用-2010
|
||
/// </summary>
|
||
/// <param name="add"></param>
|
||
private void ServerDlgSubscribe_10(bool add)
|
||
{
|
||
if (add)
|
||
{
|
||
server.ServerStartEvent += new DlgNoParam(Server_ServerStartEvent_10);
|
||
server.ServerCloseEvent += new DlgNoParam(Server_ServerCloseEvent_10);
|
||
server.NewClientEvent += new DlgOneParam<string>(Server_NewClientEvent_10);
|
||
server.RecvMsgEvent += new DlgOneParam<byte[]>(Server_RecvMsgEvent_10);//数据接收解析
|
||
server.RemoteDisconnectEvent += new DlgOneParam<string>(Server_RemoteDisconnectEvent_10);
|
||
server.LocalDisconnectEvent += new DlgNoParam(Server_LocalDisconnectEvent_10);
|
||
}
|
||
else
|
||
{
|
||
server.ServerStartEvent -= new DlgNoParam(Server_ServerStartEvent_10);
|
||
server.ServerCloseEvent -= new DlgNoParam(Server_ServerCloseEvent_10);
|
||
server.NewClientEvent -= new DlgOneParam<string>(Server_NewClientEvent_10);
|
||
server.RecvMsgEvent -= new DlgOneParam<byte[]>(Server_RecvMsgEvent_10);//数据接收解析
|
||
server.RemoteDisconnectEvent -= new DlgOneParam<string>(Server_RemoteDisconnectEvent_10);
|
||
server.LocalDisconnectEvent -= new DlgNoParam(Server_LocalDisconnectEvent_10);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
#region 下层事件处理-2009
|
||
public void Server_ServerStartEvent()
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
LogRecord("服务器(2009)已启动...");
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
LogRecord("服务器(端口号2009)已启动...");
|
||
}
|
||
}
|
||
|
||
public void Server_ServerCloseEvent()
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
LogRecord("服务器(端口号2009)已关闭...");
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
LogRecord("服务器(端口号2009)已关闭...");
|
||
}
|
||
}
|
||
|
||
public void Server_NewClientEvent(string param)
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
LogRecord("(端口号2009)接收到客户端连接： " + param + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
||
ModifyShowsByClientState(true);
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
LogRecord("(端口号2009)接收到客户端连接： " + param + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
||
ModifyShowsByClientState(true);
|
||
}
|
||
}
|
||
|
||
public void Server_RecvMsgEvent(byte[] param)
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
AppendText(param);
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
AppendText(param);
|
||
}
|
||
}
|
||
|
||
|
||
|
||
public void Server_RemoteDisconnectEvent(string param)
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
LogRecord("(端口号2009)远程客户端断开连接： " + param);
|
||
ModifyShowsByClientState(false);
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
LogRecord("(端口号2009)远程客户端断开连接： " + param);
|
||
ModifyShowsByClientState(false);
|
||
}
|
||
}
|
||
|
||
public void Server_LocalDisconnectEvent()
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
LogRecord("(端口号2009)本地客户端断开连接");
|
||
ModifyShowsByClientState(false);
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
LogRecord("(端口号2009)本地客户端断开连接");
|
||
ModifyShowsByClientState(false);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
|
||
#region 下层事件处理-2010
|
||
public void Server_ServerStartEvent_10()
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
LogRecord("服务器(端口号2010)已启动...");
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
LogRecord("服务器(端口号2010)已启动...");
|
||
}
|
||
}
|
||
|
||
public void Server_ServerCloseEvent_10()
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
LogRecord("服务器(端口号2010)已关闭...");
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
LogRecord("服务器(端口号2010)已关闭...");
|
||
}
|
||
}
|
||
|
||
public void Server_NewClientEvent_10(string param)
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
LogRecord("(端口号2010)接收到客户端连接： " + param + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
||
ModifyShowsByClientState_10(true);
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
LogRecord("(端口号2010)接收到客户端连接： " + param + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
||
ModifyShowsByClientState_10(true);
|
||
}
|
||
}
|
||
|
||
public void Server_RecvMsgEvent_10(byte[] param)
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
AppendText_10(param);
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
AppendText_10(param);
|
||
}
|
||
}
|
||
|
||
|
||
public void Server_RemoteDisconnectEvent_10(string param)
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
LogRecord("(端口号2010)远程客户端断开连接： " + param);
|
||
ModifyShowsByClientState_10(false);
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
LogRecord("(端口号2010)远程客户端断开连接： " + param);
|
||
ModifyShowsByClientState_10(false);
|
||
}
|
||
}
|
||
|
||
public void Server_LocalDisconnectEvent_10()
|
||
{
|
||
if (this.InvokeRequired)
|
||
{
|
||
this.BeginInvoke(new ThreadStart(delegate()
|
||
{
|
||
LogRecord("(端口号2010)本地客户端断开连接");
|
||
ModifyShowsByClientState_10(false);
|
||
}));
|
||
}
|
||
else
|
||
{
|
||
LogRecord("(端口号2010)本地客户端断开连接");
|
||
ModifyShowsByClientState_10(false);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
|
||
#region 端口号2010操作
|
||
|
||
/// <summary>
|
||
/// 开启端口号2010的监听
|
||
/// </summary>
|
||
/// <param name="sender"></param>
|
||
/// <param name="e"></param>
|
||
private void btnStart_10_Click(object sender, EventArgs e)
|
||
{
|
||
string ip_10 = this.tbIP_10.Text.Trim();
|
||
string port_10 = this.tbPort_10.Text.Trim();
|
||
if (server_10.Start(ip_10, int.Parse(port_10)))
|
||
{
|
||
ModifyShowsByServerState_10(true);
|
||
}
|
||
Thread acceptClientThread = new Thread(BeginAcceptClient_10);
|
||
acceptClientThread.IsBackground = true;
|
||
acceptClientThread.Start();
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 关闭端口号2010的监听
|
||
/// </summary>
|
||
/// <param name="sender"></param>
|
||
/// <param name="e"></param>
|
||
private void btnClose_10_Click(object sender, EventArgs e)
|
||
{
|
||
if (server_10.ServerClose())
|
||
{
|
||
ModifyShowsByServerState_10(false);
|
||
}
|
||
server.DisconnectClient();
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 关闭连接
|
||
/// </summary>
|
||
/// <param name="sender"></param>
|
||
/// <param name="e"></param>
|
||
private void btnDisconnect_10_Click(object sender, EventArgs e)
|
||
{
|
||
server.DisconnectClient();
|
||
}
|
||
|
||
#endregion
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
}
|
||
}
|