tdx
807 lines
41 KiB
C#
807 lines
41 KiB
C#
using Newtonsoft.Json;
|
|
using Newtonsoft.Json.Linq;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel;
|
|
using System.Configuration;
|
|
using System.Data;
|
|
using System.Data.SqlClient;
|
|
using System.Drawing;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Reflection;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Windows.Forms;
|
|
|
|
namespace LadfDataApp
|
|
{
|
|
public partial class FrmMain : Form
|
|
{
|
|
private string sid = string.Empty;//认证码
|
|
private System.Timers.Timer timer = new System.Timers.Timer();//指定间隔循环
|
|
private int timeInterval = 0;
|
|
private DateTime startTime;
|
|
public FrmMain()
|
|
{
|
|
InitializeComponent();
|
|
this.Load += OnFrmMainLoad;
|
|
this.linkBtn.Click += OnLinkBtnClick;
|
|
this.startBtn.Click += OnStartBtnClick;
|
|
this.radioFix.CheckedChanged += OnCheckedChanged;
|
|
this.radioNext.CheckedChanged += OnCheckedChanged;
|
|
}
|
|
|
|
private void OnFrmMainLoad(object sender, EventArgs e)
|
|
{
|
|
startBtn.Enabled = false;
|
|
DateTime nowDateTime = DateTime.Now;
|
|
fixStartDate.Value = new DateTime(nowDateTime.Year, nowDateTime.Month, nowDateTime.Day, 0, 0, 0, 0);
|
|
fixEndDate.Value = new DateTime(nowDateTime.Year, nowDateTime.Month, nowDateTime.Day, 23, 59, 59, 999);
|
|
nextStartDate.Value = new DateTime(nowDateTime.Year, nowDateTime.Month, nowDateTime.Day, 0, 0, 0, 0);
|
|
this.loginNameBox.Text = ConfigurationManager.AppSettings["loginName"];
|
|
this.serverBox.Text = ConfigurationManager.AppSettings["server"];
|
|
this.dataBaseBox.Text = ConfigurationManager.AppSettings["database"];
|
|
this.timeIntervalBox.Text = ConfigurationManager.AppSettings["intervalTime"];
|
|
if (this.loginNameBox.Text.Equals("lserptest"))
|
|
{
|
|
this.loginPasswordBox.Text = "lserpAdmin";
|
|
}
|
|
}
|
|
|
|
private void OnCheckedChanged(object sender, EventArgs e)
|
|
{
|
|
if (sender == radioFix && radioFix.Checked)
|
|
{
|
|
radioNext.Checked = false;
|
|
panelNext.Enabled = false;
|
|
panelFix.Enabled = true;
|
|
}
|
|
if (sender == radioNext && radioNext.Checked)
|
|
{
|
|
radioFix.Checked = false;
|
|
panelFix.Enabled = false;
|
|
panelNext.Enabled = true;
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 加载项目下拉框数据源
|
|
/// </summary>
|
|
private void InitComboBox()
|
|
{
|
|
try
|
|
{
|
|
this.projectComboBox.Items.Clear();
|
|
string url = "https://api.123321yun.com/api/user/queryProjectList";
|
|
HttpUtil.setting("application/x-www-form-urlencoded", null, null);
|
|
Dictionary<string, string> pmsDic = new Dictionary<string, string>();
|
|
pmsDic.Add("isAll", "true");
|
|
pmsDic.Add("pageNum", "1");
|
|
pmsDic.Add("pageSize", "10");
|
|
Dictionary<string, string> headerDic = new Dictionary<string, string>();
|
|
headerDic.Add("__sid", sid);
|
|
HttpWebResponse webResponse = HttpUtil.Post(url, "", pmsDic, headerDic, HttpUtil.Method.POST);
|
|
string result = new StreamReader(webResponse.GetResponseStream(), Encoding.UTF8).ReadToEnd();
|
|
if (webResponse != null && !string.IsNullOrEmpty(result))
|
|
{
|
|
JObject resultJObject = (JObject)JsonConvert.DeserializeObject(result);
|
|
string code = resultJObject["code"] + "";
|
|
if (code.Equals("200"))
|
|
{
|
|
JArray projectArray = (JArray)resultJObject["data"];
|
|
foreach (JObject projectJObject in projectArray)
|
|
{
|
|
try
|
|
{
|
|
string projectName = projectJObject["name"] + "";
|
|
this.projectComboBox.Items.Add(projectName);
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
}
|
|
|
|
private void OnLinkBtnClick(object sender, EventArgs e)
|
|
{
|
|
ClearMsg();
|
|
bool isConnection = CreateConnection();
|
|
if (!isConnection)
|
|
{
|
|
startBtn.Enabled = false;
|
|
MessageBox.Show("网络连接失败", "提示");
|
|
return;
|
|
}
|
|
if (!Login())
|
|
{
|
|
startBtn.Enabled = false;
|
|
MessageBox.Show("物联网平台登录失败", "提示");
|
|
return;
|
|
}
|
|
string alterSql = $@"if not exists (select 1 from INFORMATION_SCHEMA.COLUMNS where TABLE_NAME = 'p_systemtab' and COLUMN_NAME = 'ProjectEndTime')
|
|
BEGIN ALTER TABLE p_systemtab ADD ProjectEndTime datetime END";
|
|
SqlHelper.ExecuteNonQuery(alterSql);
|
|
string selectSql = $"select ProjectEndTime from p_systemtab";
|
|
string endDateTime = SqlHelper.ExecuteScalar(selectSql) + "";
|
|
if (!string.IsNullOrEmpty(endDateTime))
|
|
{
|
|
this.nextStartDate.Value = Convert.ToDateTime(endDateTime);
|
|
}
|
|
else
|
|
{
|
|
SqlHelper.ExecuteNonQuery($"update p_systemtab set ProjectEndTime = '{this.nextStartDate.Value.ToString("yyyy-MM-dd HH:mm:ss.fff")}'");
|
|
}
|
|
InitComboBox();
|
|
UpdateMsg("连接成功\r\n");
|
|
startBtn.Enabled = true;
|
|
}
|
|
|
|
private void OnStartBtnClick(object sender, EventArgs e)
|
|
{
|
|
if (string.IsNullOrEmpty(this.loginNameBox.Text) || string.IsNullOrEmpty(this.loginPasswordBox.Text))
|
|
{
|
|
MessageBox.Show("用户名或密码不能为空", "提示");
|
|
return;
|
|
}
|
|
if (string.IsNullOrEmpty(this.serverBox.Text) || string.IsNullOrEmpty(this.dataBaseBox.Text))
|
|
{
|
|
MessageBox.Show("服务器或数据库不能为空", "提示");
|
|
return;
|
|
}
|
|
if (string.IsNullOrEmpty(this.projectComboBox.SelectedItem + ""))
|
|
{
|
|
MessageBox.Show("未选择项目", "提示");
|
|
return;
|
|
}
|
|
bool isConnection = CreateConnection();
|
|
if (isConnection)
|
|
{
|
|
if (radioFix.Checked)
|
|
{
|
|
GetDataOnlyOne();
|
|
}
|
|
else if (radioNext.Checked)
|
|
{
|
|
if (!int.TryParse(this.timeIntervalBox.Text, out timeInterval) && timeInterval <= 0)
|
|
{
|
|
MessageBox.Show("间隔时间必须大于0", "提示");
|
|
return;
|
|
}
|
|
timer.Elapsed += OnTimerElapsed;
|
|
timer.Interval = 100;
|
|
timer.Start();
|
|
}
|
|
}
|
|
else
|
|
{
|
|
MessageBox.Show("网络连接失败", "提示");
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 获取数据事件
|
|
/// </summary>
|
|
/// <param name="sender"></param>
|
|
/// <param name="e"></param>
|
|
private void GetDataOnlyOne()
|
|
{
|
|
try
|
|
{
|
|
this.Invoke(new Action(() =>
|
|
{
|
|
this.groupBox3.Enabled = false;
|
|
this.panelFix.Enabled = false;
|
|
this.linkBtn.Enabled = false;
|
|
this.startBtn.Enabled = false;
|
|
this.loginNameBox.Enabled = false;
|
|
this.loginPasswordBox.Enabled = false;
|
|
this.serverBox.Enabled = false;
|
|
this.dataBaseBox.Enabled = false;
|
|
this.timeIntervalBox.Enabled = false;
|
|
this.projectComboBox.Enabled = false;
|
|
}));
|
|
ClearMsg();
|
|
QueryProjectList();
|
|
UpdateMsg("同步完成，所有数据已成功写入\r\n");
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
finally
|
|
{
|
|
this.Invoke(new Action(() =>
|
|
{
|
|
this.groupBox3.Enabled = true;
|
|
this.panelFix.Enabled = true;
|
|
this.loginNameBox.Enabled = true;
|
|
this.loginPasswordBox.Enabled = true;
|
|
this.linkBtn.Enabled = true;
|
|
this.startBtn.Enabled = true;
|
|
this.serverBox.Enabled = true;
|
|
this.dataBaseBox.Enabled = true;
|
|
this.timeIntervalBox.Enabled = true;
|
|
this.projectComboBox.Enabled = true;
|
|
}));
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 获取数据事件
|
|
/// </summary>
|
|
/// <param name="sender"></param>
|
|
/// <param name="e"></param>
|
|
private void OnTimerElapsed(object sender, System.Timers.ElapsedEventArgs e)
|
|
{
|
|
timer.Enabled = false;
|
|
try
|
|
{
|
|
this.Invoke(new Action(() =>
|
|
{
|
|
this.groupBox2.Enabled = false;
|
|
this.panelNext.Enabled = false;
|
|
this.linkBtn.Enabled = false;
|
|
this.startBtn.Enabled = false;
|
|
this.loginNameBox.Enabled = false;
|
|
this.loginPasswordBox.Enabled = false;
|
|
this.serverBox.Enabled = false;
|
|
this.dataBaseBox.Enabled = false;
|
|
this.timeIntervalBox.Enabled = false;
|
|
this.projectComboBox.Enabled = false;
|
|
}));
|
|
if (timer.Interval == 100)
|
|
{
|
|
startTime = this.nextStartDate.Value;
|
|
SqlHelper.ExecuteNonQuery($"update p_systemtab set ProjectEndTime = '{this.nextStartDate.Value.ToString("yyyy-MM-dd HH:mm:ss.fff")}'");
|
|
}
|
|
else
|
|
{
|
|
string selectSql = $"select ProjectEndTime from p_systemtab";
|
|
string endDateTime = SqlHelper.ExecuteScalar(selectSql) + "";
|
|
startTime = this.nextStartDate.Value;
|
|
if (!string.IsNullOrEmpty(endDateTime))
|
|
{
|
|
startTime = Convert.ToDateTime(endDateTime);
|
|
}
|
|
}
|
|
if (timer.Interval == 100)
|
|
{
|
|
timer.Interval = timeInterval * 60 * 1000;
|
|
}
|
|
ClearMsg();
|
|
string nextTime = startTime.AddMinutes(timeInterval).ToString("yyyy-MM-dd HH:mm:ss.fff");
|
|
if (startTime.AddMinutes(timeInterval) <= DateTime.Now)
|
|
{
|
|
QueryProjectList();
|
|
UpdateMsg("同步完成，所有数据已成功写入\r\n");
|
|
SqlHelper.ExecuteNonQuery($"update p_systemtab set ProjectEndTime = '{startTime.AddMinutes(timeInterval).ToString("yyyy-MM-dd HH:mm:ss.fff")}'");
|
|
UpdateMsg($"下次同步时间：{DateTime.Now.AddMinutes(timeInterval).ToString("yyyy-MM-dd HH:mm:ss.fff")}\r\n");
|
|
}
|
|
else
|
|
{
|
|
UpdateMsg($"结束时间{nextTime}大于当前时间{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}\r\n");
|
|
UpdateMsg($"下次同步时间：{DateTime.Now.AddMinutes(timeInterval).ToString("yyyy-MM-dd HH:mm:ss.fff")}\r\n");
|
|
}
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
finally
|
|
{
|
|
}
|
|
timer.Enabled = true;
|
|
}
|
|
/// <summary>
|
|
/// 登录
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
private bool Login()
|
|
{
|
|
bool isLogin = false;
|
|
try
|
|
{
|
|
string url = "https://api.123321yun.com/api/user/login";
|
|
HttpUtil.setting("application/x-www-form-urlencoded", null, null);
|
|
Dictionary<string, string> pmsDic = new Dictionary<string, string>();
|
|
pmsDic.Add("username", this.loginNameBox.Text);
|
|
pmsDic.Add("password", this.loginPasswordBox.Text);
|
|
HttpWebResponse webResponse = HttpUtil.Post(url, "", pmsDic, null, HttpUtil.Method.POST);
|
|
string result = new StreamReader(webResponse.GetResponseStream(), Encoding.UTF8).ReadToEnd();
|
|
if (webResponse != null && !string.IsNullOrEmpty(result))
|
|
{
|
|
JObject resultJObject = (JObject)JsonConvert.DeserializeObject(result);
|
|
string code = resultJObject["code"] + "";
|
|
if (code.Equals("200"))
|
|
{
|
|
sid = resultJObject["data"] + "";
|
|
isLogin = true;
|
|
}
|
|
}
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
return isLogin;
|
|
}
|
|
/// <summary>
|
|
/// 查询项目列表
|
|
/// </summary>
|
|
private void QueryProjectList()
|
|
{
|
|
try
|
|
{
|
|
string url = "https://api.123321yun.com/api/user/queryProjectList";
|
|
HttpUtil.setting("application/x-www-form-urlencoded", null, null);
|
|
Dictionary<string, string> pmsDic = new Dictionary<string, string>();
|
|
pmsDic.Add("isAll", "true");
|
|
pmsDic.Add("pageNum", "1");
|
|
pmsDic.Add("pageSize", "10");
|
|
Dictionary<string, string> headerDic = new Dictionary<string, string>();
|
|
headerDic.Add("__sid", sid);
|
|
HttpWebResponse webResponse = HttpUtil.Post(url, "", pmsDic, headerDic, HttpUtil.Method.POST);
|
|
string result = new StreamReader(webResponse.GetResponseStream(), Encoding.UTF8).ReadToEnd();
|
|
if (webResponse != null && !string.IsNullOrEmpty(result))
|
|
{
|
|
JObject resultJObject = (JObject)JsonConvert.DeserializeObject(result);
|
|
string code = resultJObject["code"] + "";
|
|
if (code.Equals("200"))
|
|
{
|
|
string selectProjectName = "";
|
|
this.Invoke(new Action(() =>
|
|
{
|
|
selectProjectName = projectComboBox.SelectedItem + "";
|
|
}));
|
|
JArray projectArray = (JArray)resultJObject["data"];
|
|
foreach (JObject projectJObject in projectArray)
|
|
{
|
|
try
|
|
{
|
|
if (projectJObject.ContainsKey("name") && (projectJObject["name"] + "").Equals(selectProjectName))
|
|
{
|
|
try
|
|
{
|
|
UpdateMsg($"正在读取项目：{projectJObject["name"]}\r\n");
|
|
ProjectModel projectModel = new ProjectModel();
|
|
projectModel.projectId = projectJObject["id"] + "";
|
|
projectModel.name = projectJObject["name"] + "";
|
|
projectModel.delFlag = projectJObject["delFlag"] + "";
|
|
projectModel.province = projectJObject["province"] + "";
|
|
projectModel.city = projectJObject["city"] + "";
|
|
projectModel.county = projectJObject["county"] + "";
|
|
projectModel.address = projectJObject["address"] + "";
|
|
projectModel.propertyOwner = projectJObject["propertyOwner"] + "";
|
|
projectModel.constructionTime = projectJObject["constructionTime"] + "";
|
|
projectModel.acreage = projectJObject["acreage"] + "";
|
|
projectModel.typeId = projectJObject["typeId"] + "";
|
|
projectModel.state = projectJObject["state"] + "";
|
|
projectModel.enableTime = projectJObject["enableTime"] + "";
|
|
projectModel.energyConsumption = projectJObject["energyConsumption"] + "";
|
|
projectModel.imgUrl = projectJObject["imgUrl"] + "";
|
|
projectModel.remarks = projectJObject["remarks"] + "";
|
|
projectModel.contractor = projectJObject["contractor"] + "";
|
|
projectModel.propertyMgmt = projectJObject["propertyMgmt"] + "";
|
|
projectModel.projectTypeId = projectJObject["projectType"]["id"] + "";
|
|
projectModel.projectTypeName = projectJObject["projectType"]["name"] + "";
|
|
StringBuilder projectSqlStrBuilder = new StringBuilder();
|
|
StringBuilder projectInsertKeys = new StringBuilder();
|
|
StringBuilder projectInsertValues = new StringBuilder();
|
|
PropertyInfo[] devicePmsPropertyInfos = projectModel.GetType().GetProperties();
|
|
foreach (System.Reflection.PropertyInfo projectPropertyInfo in devicePmsPropertyInfos)
|
|
{
|
|
projectInsertKeys.Append($"{projectPropertyInfo.Name},");
|
|
projectInsertValues.Append($"'{(projectPropertyInfo.GetValue(projectModel, null) + "").Replace("'", "''")}',");
|
|
}
|
|
projectSqlStrBuilder.Append($"delete from LadfProjectTab where projectid = '{projectModel.projectId}';\r\n" +
|
|
$"insert into LadfProjectTab ({projectInsertKeys.ToString().TrimEnd(',')}) values ({projectInsertValues.ToString().TrimEnd(',')});\r\n");
|
|
if (!string.IsNullOrEmpty(projectSqlStrBuilder.ToString()))
|
|
{
|
|
SqlHelper.ExecuteNonQuery(projectSqlStrBuilder.ToString());
|
|
}
|
|
QueryDeviceByProject(projectModel);
|
|
UpdateMsg($"项目：{projectJObject["name"]}数据写入完成\r\n");
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
UpdateMsg($"项目：{projectJObject["name"]}数据写入失败，原因：{ex.Message}\r\n");
|
|
}
|
|
}
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
}
|
|
}
|
|
else if (code.Equals("4012"))
|
|
{
|
|
UpdateMsg($"登录失败\r\n");
|
|
Login();
|
|
QueryProjectList();
|
|
}
|
|
}
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 查询项目的设备列表
|
|
/// </summary>
|
|
private void QueryDeviceByProject(ProjectModel projectModel)
|
|
{
|
|
UpdateMsg($"正在读取项目：{projectModel.name}的设备\r\n");
|
|
try
|
|
{
|
|
string url = "https://api.123321yun.com/api/device/queryDeviceByProject";
|
|
HttpUtil.setting("application/x-www-form-urlencoded", null, null);
|
|
Dictionary<string, string> pmsDic = new Dictionary<string, string>();
|
|
pmsDic.Add("projId", projectModel.projectId);
|
|
Dictionary<string, string> headerDic = new Dictionary<string, string>();
|
|
headerDic.Add("__sid", sid);
|
|
HttpWebResponse webResponse = HttpUtil.Post(url, "", pmsDic, headerDic, HttpUtil.Method.POST);
|
|
string result = new StreamReader(webResponse.GetResponseStream(), Encoding.UTF8).ReadToEnd();
|
|
if (webResponse != null && !string.IsNullOrEmpty(result))
|
|
{
|
|
JObject resultJObject = (JObject)JsonConvert.DeserializeObject(result);
|
|
string code = resultJObject["code"] + "";
|
|
if (code.Equals("200"))
|
|
{
|
|
JArray deviceArray = (JArray)resultJObject["data"];
|
|
foreach (JObject deviceJObject in deviceArray)
|
|
{
|
|
try
|
|
{
|
|
StringBuilder projectSqlStrBuilder = new StringBuilder();
|
|
UpdateMsg($"正在读取设备：{deviceJObject["name"]}\r\n");
|
|
DeviceModel deviceModel = new DeviceModel();
|
|
deviceModel.deviceId = deviceJObject["id"] + "";
|
|
deviceModel.brand = deviceJObject["brand"] + "";
|
|
deviceModel.model = deviceJObject["model"] + "";
|
|
deviceModel.typeId = deviceJObject["typeId"] + "";
|
|
deviceModel.projectId = deviceJObject["projectId"] + "";
|
|
deviceModel.power = deviceJObject["power"] + "";
|
|
deviceModel.regionId = deviceJObject["regionId"] + "";
|
|
deviceModel.produceTime = deviceJObject["produceTime"] + "";
|
|
deviceModel.deviceTypeId = deviceJObject["deviceType"]["id"] + "";
|
|
deviceModel.deviceTypeName = deviceJObject["deviceType"]["name"] + "";
|
|
deviceModel.name = deviceJObject["name"] + "";
|
|
StringBuilder deviceInsertKeys = new StringBuilder();
|
|
StringBuilder deviceInsertValues = new StringBuilder();
|
|
PropertyInfo[] devicePropertyInfos = deviceModel.GetType().GetProperties();
|
|
foreach (System.Reflection.PropertyInfo devicePropertyInfo in devicePropertyInfos)
|
|
{
|
|
deviceInsertKeys.Append($"{devicePropertyInfo.Name},");
|
|
deviceInsertValues.Append($"'{(devicePropertyInfo.GetValue(deviceModel, null) + "").Replace("'", "''")}',");
|
|
}
|
|
projectSqlStrBuilder.Append($"delete from LadfDeviceTab where projectid = '{deviceModel.projectId}' and deviceId = '{deviceModel.deviceId}';\r\n");
|
|
projectSqlStrBuilder.Append($"insert into LadfDeviceTab ({deviceInsertKeys.ToString().TrimEnd(',')}) values ({deviceInsertValues.ToString().TrimEnd(',')});\r\n");
|
|
if (!string.IsNullOrEmpty(projectSqlStrBuilder.ToString()))
|
|
{
|
|
SqlHelper.ExecuteNonQuery(projectSqlStrBuilder.ToString());
|
|
}
|
|
QueryDeviceParamStatus(deviceModel);
|
|
if (checkHistory.Checked)
|
|
{
|
|
QueryDeviceParamStatusHistory(deviceModel);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
UpdateMsg($"读取设备{deviceJObject["name"]}失败，原因：{ex.Message}\r\n");
|
|
}
|
|
}
|
|
}
|
|
else if (code.Equals("4012"))
|
|
{
|
|
UpdateMsg($"登录失败\r\n");
|
|
Login();
|
|
QueryDeviceByProject(projectModel);
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
if (ex.Message.Contains("未将对象引用设置到"))
|
|
{
|
|
UpdateMsg($"读取项目：{projectModel.name}的设备失败，原因：未查询到数据\r\n");
|
|
}
|
|
else
|
|
{
|
|
UpdateMsg($"读取项目：{projectModel.name}的设备失败，原因：{ex.Message}\r\n");
|
|
}
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 查询单个设备的属性
|
|
/// </summary>
|
|
private void QueryDeviceParamStatus(DeviceModel deviceModel)
|
|
{
|
|
StringBuilder projectSqlStrBuilder = new StringBuilder();
|
|
UpdateMsg($"正在读取设备：{deviceModel.name}{deviceModel.deviceTypeName}的属性数据\r\n");
|
|
try
|
|
{
|
|
string url = "https://api.123321yun.com/api/device/queryDeviceParamStatus";
|
|
HttpUtil.setting("application/x-www-form-urlencoded", null, null);
|
|
Dictionary<string, string> pmsDic = new Dictionary<string, string>();
|
|
pmsDic.Add("id", deviceModel.deviceId);
|
|
Dictionary<string, string> headerDic = new Dictionary<string, string>();
|
|
headerDic.Add("__sid", sid);
|
|
HttpWebResponse webResponse = HttpUtil.Post(url, "", pmsDic, headerDic, HttpUtil.Method.POST);
|
|
string result = new StreamReader(webResponse.GetResponseStream(), Encoding.UTF8).ReadToEnd();
|
|
if (webResponse != null && !string.IsNullOrEmpty(result))
|
|
{
|
|
JObject resultJObject = (JObject)JsonConvert.DeserializeObject(result);
|
|
string code = resultJObject["code"] + "";
|
|
if (code.Equals("200"))
|
|
{
|
|
if (resultJObject.ContainsKey("data"))
|
|
{
|
|
JObject deviceParamJObject = (JObject)resultJObject["data"];
|
|
DeviceParamModel deviceParamModel = new DeviceParamModel();
|
|
deviceParamModel.deviceTypeId = deviceParamJObject["deviceType"]["id"] + "";
|
|
deviceParamModel.deviceTypeName = deviceParamJObject["deviceType"]["name"] + "";
|
|
deviceParamModel.deviceId = deviceParamJObject["deviceId"] + "";
|
|
deviceParamModel.deviceName = deviceParamJObject["deviceName"] + "";
|
|
deviceParamModel.workload = deviceParamJObject["workload"] + "";
|
|
deviceParamModel.elec = deviceParamJObject["elec"] + "";
|
|
deviceParamModel.errorParamNum = deviceParamJObject["errorParamNum"] + "";
|
|
deviceParamModel.warnParamNum = deviceParamJObject["warnParamNum"] + "";
|
|
deviceParamModel.errorTimeSum = deviceParamJObject["errorTimeSum"] + "";
|
|
deviceParamModel.runTimeSum = deviceParamJObject["runTimeSum"] + "";
|
|
deviceParamModel.warnEventSum = deviceParamJObject["warnEventSum"] + "";
|
|
deviceParamModel.errorEventSum = deviceParamJObject["errorEventSum"] + "";
|
|
deviceParamModel.projectId = deviceParamJObject["projectId"] + "";
|
|
deviceParamModel.status = deviceParamJObject["status"] + "";
|
|
deviceParamModel.timestamp = deviceParamJObject["timestamp"] + "";
|
|
StringBuilder deviceParamInsertKeys = new StringBuilder();
|
|
StringBuilder deviceParamInsertValues = new StringBuilder();
|
|
PropertyInfo[] deviceParamPropertyInfos = deviceParamModel.GetType().GetProperties();
|
|
foreach (System.Reflection.PropertyInfo deviceParamPropertyInfo in deviceParamPropertyInfos)
|
|
{
|
|
deviceParamInsertKeys.Append($"{deviceParamPropertyInfo.Name},");
|
|
deviceParamInsertValues.Append($"'{(deviceParamPropertyInfo.GetValue(deviceParamModel, null) + "").Replace("'", "''")}',");
|
|
}
|
|
projectSqlStrBuilder.Append($"delete from LadfDeviceParamTab where projectid = '{deviceModel.projectId}' and deviceId = '{deviceModel.deviceId}';\r\n");
|
|
projectSqlStrBuilder.Append($"insert into LadfDeviceParamTab ({deviceParamInsertKeys.ToString().TrimEnd(',')}) values ({deviceParamInsertValues.ToString().TrimEnd(',')});\r\n");
|
|
projectSqlStrBuilder.Append($"delete from LadfDeviceParamStatusTab where projectid = '{deviceModel.projectId}' and deviceId = '{deviceModel.deviceId}';\r\n");
|
|
JArray devicePmsArray = (JArray)deviceParamJObject["jsonParams"];
|
|
foreach (JObject devicePmsJObject in devicePmsArray)
|
|
{
|
|
try
|
|
{
|
|
DeviceParamStatusModel devicePmsModel = new DeviceParamStatusModel();
|
|
devicePmsModel.projectId = deviceModel.projectId;
|
|
devicePmsModel.deviceId = deviceModel.deviceId;
|
|
devicePmsModel.qs = devicePmsJObject["qs"] + "";
|
|
devicePmsModel.realValue = devicePmsJObject["realValue"] + "";
|
|
devicePmsModel.flag = devicePmsJObject["flag"] + "";
|
|
devicePmsModel.id = devicePmsJObject["id"] + "";
|
|
devicePmsModel.paramName = devicePmsJObject["paramName"] + "";
|
|
devicePmsModel.value = devicePmsJObject["value"] + "";
|
|
devicePmsModel.unitName = devicePmsJObject["unitName"] + "";
|
|
devicePmsModel.dataType = devicePmsJObject["dataType"] + "";
|
|
StringBuilder devicePmsInsertKeys = new StringBuilder();
|
|
StringBuilder devicePmsInsertValues = new StringBuilder();
|
|
PropertyInfo[] devicePmsPropertyInfos = devicePmsModel.GetType().GetProperties();
|
|
foreach (System.Reflection.PropertyInfo devicePmsPropertyInfo in devicePmsPropertyInfos)
|
|
{
|
|
devicePmsInsertKeys.Append($"{devicePmsPropertyInfo.Name},");
|
|
devicePmsInsertValues.Append($"'{(devicePmsPropertyInfo.GetValue(devicePmsModel, null) + "").Replace("'", "''")}',");
|
|
}
|
|
projectSqlStrBuilder.Append($"insert into LadfDeviceParamStatusTab ({devicePmsInsertKeys.ToString().TrimEnd(',')}) values ({devicePmsInsertValues.ToString().TrimEnd(',')});\r\n");
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
}
|
|
if (!string.IsNullOrEmpty(projectSqlStrBuilder.ToString()))
|
|
{
|
|
SqlHelper.ExecuteNonQuery(projectSqlStrBuilder.ToString());
|
|
}
|
|
UpdateMsg($"读取设备：{deviceModel.name}{deviceModel.deviceTypeName}的属性成功\r\n");
|
|
}
|
|
else
|
|
{
|
|
projectSqlStrBuilder.Append($"update LadfDeviceParamTab set status = '3' where projectid = '{deviceModel.projectId}' and deviceId = '{deviceModel.deviceId}';\r\n");
|
|
if (!string.IsNullOrEmpty(projectSqlStrBuilder.ToString()))
|
|
{
|
|
SqlHelper.ExecuteNonQuery(projectSqlStrBuilder.ToString());
|
|
}
|
|
UpdateMsg($"读取设备：{deviceModel.name}{deviceModel.deviceTypeName}的属性成功,但设备已离线\r\n");
|
|
}
|
|
}
|
|
else if (code.Equals("4012"))
|
|
{
|
|
UpdateMsg($"登录失败\r\n");
|
|
Login();
|
|
QueryDeviceParamStatus(deviceModel);
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
if (ex.Message.Contains("未将对象引用设置到"))
|
|
{
|
|
UpdateMsg($"读取设备：{deviceModel.name}{deviceModel.deviceTypeName}的属性成功，但未查询到数据\r\n");
|
|
}
|
|
else
|
|
{
|
|
UpdateMsg($"读取设备：{deviceModel.name}{deviceModel.deviceTypeName}的属性数据失败，原因：{ex.Message}\r\n");
|
|
}
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 查询历史数据
|
|
/// </summary>
|
|
private void QueryDeviceParamStatusHistory(DeviceModel deviceModel)
|
|
{
|
|
StringBuilder projectSqlStrBuilder = new StringBuilder();
|
|
UpdateMsg($"正在读取设备：{deviceModel.name}{deviceModel.deviceTypeName}的属性历史数据\r\n");
|
|
try
|
|
{
|
|
string url = "https://api.123321yun.com/api/device/queryDeviceParamHistoryData";
|
|
HttpUtil.setting("application/x-www-form-urlencoded", null, null);
|
|
Dictionary<string, string> pmsDic = new Dictionary<string, string>();
|
|
pmsDic.Add("deviceId", deviceModel.deviceId);
|
|
if (radioFix.Checked)
|
|
{
|
|
pmsDic.Add("start", GetStamp(fixStartDate.Value));
|
|
pmsDic.Add("end", GetStamp(fixEndDate.Value));
|
|
}
|
|
else
|
|
{
|
|
pmsDic.Add("start", GetStamp(startTime));
|
|
pmsDic.Add("end", GetStamp(startTime.AddMinutes(timeInterval)));
|
|
}
|
|
pmsDic.Add("type", "1");
|
|
Dictionary<string, string> headerDic = new Dictionary<string, string>();
|
|
headerDic.Add("__sid", sid);
|
|
HttpWebResponse webResponse = HttpUtil.Post(url, "", pmsDic, headerDic, HttpUtil.Method.POST);
|
|
string result = new StreamReader(webResponse.GetResponseStream(), Encoding.UTF8).ReadToEnd();
|
|
if (webResponse != null && !string.IsNullOrEmpty(result))
|
|
{
|
|
JObject resultJObject = (JObject)JsonConvert.DeserializeObject(result);
|
|
string code = resultJObject["code"] + "";
|
|
if (code.Equals("200"))
|
|
{
|
|
if (radioFix.Checked)
|
|
{
|
|
projectSqlStrBuilder.Append($"delete from LadfDeviceParamStatusHistoryTab where projectid = '{deviceModel.projectId}' and deviceId = '{deviceModel.deviceId}' and datetime >= {GetStamp(fixStartDate.Value)} and datetime <= {GetStamp(fixEndDate.Value)};\r\n");
|
|
}
|
|
else if (radioNext.Checked)
|
|
{
|
|
projectSqlStrBuilder.Append($"delete from LadfDeviceParamStatusHistoryTab where projectid = '{deviceModel.projectId}' and deviceId = '{deviceModel.deviceId}' and datetime >= {GetStamp(startTime)} and datetime <= {GetStamp(startTime.AddMinutes(timeInterval))};\r\n");
|
|
}
|
|
JArray deviceParamHistoryJArray = (JArray)resultJObject["data"];
|
|
foreach (JObject deviceParamHistoryJObject in deviceParamHistoryJArray)
|
|
{
|
|
int datetime;
|
|
if (!int.TryParse(deviceParamHistoryJObject["datetime"] + "", out datetime))
|
|
{
|
|
Console.WriteLine("时间转换失败");
|
|
}
|
|
IEnumerable<JProperty> properties = deviceParamHistoryJObject.Properties();
|
|
foreach (JProperty item in properties)
|
|
{
|
|
string flag = item.Name.ToString().Replace("'", "''");
|
|
string value = item.Value.ToString().Replace("'", "''");
|
|
projectSqlStrBuilder.Append($"insert into LadfDeviceParamStatusHistoryTab (projectId,deviceId,flag,value,datetime) values ('{deviceModel.projectId}','{deviceModel.deviceId}','{flag}','{value}',{datetime});\r\n");
|
|
}
|
|
}
|
|
if (!string.IsNullOrEmpty(projectSqlStrBuilder.ToString()))
|
|
{
|
|
SqlHelper.ExecuteNonQuery(projectSqlStrBuilder.ToString());
|
|
}
|
|
}
|
|
else if (code.Equals("4012"))
|
|
{
|
|
UpdateMsg($"登录失败\r\n");
|
|
Login();
|
|
QueryDeviceParamStatusHistory(deviceModel);
|
|
}
|
|
UpdateMsg($"读取设备：{deviceModel.name}{deviceModel.deviceTypeName}的属性历史数据成功\r\n");
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
if (ex.Message.Contains("未将对象引用设置到"))
|
|
{
|
|
UpdateMsg($"读取设备：{deviceModel.name}{deviceModel.deviceTypeName}的属性历史数据失败，原因：未查询到数据\r\n");
|
|
}
|
|
else
|
|
{
|
|
UpdateMsg($"读取设备：{deviceModel.name}{deviceModel.deviceTypeName}的属性历史数据失败，原因：{ex.Message}\r\n");
|
|
}
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 连接数据库
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
private bool CreateConnection()
|
|
{
|
|
string connStr = GetConnection();
|
|
if (SqlHelper._connection != null)
|
|
{
|
|
try
|
|
{
|
|
SqlHelper._connection.Close();
|
|
SqlHelper._connection.Dispose();
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
SqlHelper._connection = null;
|
|
}
|
|
try
|
|
{
|
|
SqlHelper._connection = new SqlConnection(connStr);
|
|
SqlHelper._connection.Open();
|
|
return true;
|
|
}
|
|
catch (Exception)
|
|
{
|
|
// LogHelper.Instance.WriteLog(ex.Message);
|
|
}
|
|
return false;
|
|
}
|
|
private void CloseConnection()
|
|
{
|
|
if (SqlHelper._connection != null)
|
|
{
|
|
try
|
|
{
|
|
SqlHelper._connection.Close();
|
|
SqlHelper._connection.Dispose();
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
SqlHelper._connection = null;
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 获取连接服务器的字符串
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string GetConnection()
|
|
{
|
|
return string.Format("Server={0};Database={1};Persist Security Info=True;User ID={2};Password={3};Connection Timeout=5;MultipleActiveResultSets=true", this.serverBox.Text, this.dataBaseBox.Text, "lserpAdmin", "lserp110");
|
|
}
|
|
/// <summary>
|
|
/// 获取当天零点的时间戳
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string GetNowTime0Stamp()
|
|
{
|
|
int year = DateTime.Now.Year;
|
|
int month = DateTime.Now.Month;
|
|
int day = DateTime.Now.Day;
|
|
DateTime dateTime = new DateTime(year, month, day, 0, 0, 0, 0);
|
|
TimeSpan tspan = dateTime.ToUniversalTime() - new DateTime(1970, 1, 1, 0, 0, 0, 0);
|
|
return Convert.ToInt64(tspan.TotalSeconds).ToString();
|
|
}
|
|
/// <summary>
|
|
/// 获取当天24点的时间戳
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string GetNowTime24Stamp()
|
|
{
|
|
int year = DateTime.Now.Year;
|
|
int month = DateTime.Now.Month;
|
|
int day = DateTime.Now.Day;
|
|
DateTime dateTime = new DateTime(year, month, day, 23, 59, 59, 999);
|
|
TimeSpan tspan = dateTime.ToUniversalTime() - new DateTime(1970, 1, 1, 0, 0, 0, 0);
|
|
return Convert.ToInt64(tspan.TotalSeconds).ToString();
|
|
}
|
|
/// <summary>
|
|
/// 获取指定时间的时间戳
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string GetStamp(DateTime dateTime)
|
|
{
|
|
TimeSpan tspan = dateTime.ToUniversalTime() - new DateTime(1970, 1, 1, 0, 0, 0, 0);
|
|
return Con |