424 lines
16 KiB
C#
424 lines
16 KiB
C#
using JiangsuEarthquake.Common;
|
||
using JiangsuEarthquake.DataAccess;
|
||
using JiangsuEarthquake.Models;
|
||
using JiangsuEarthquake.Views.UserControls;
|
||
using MySql.Data.MySqlClient;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Collections.ObjectModel;
|
||
using System.Linq;
|
||
using System.Net;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
using System.Windows;
|
||
using System.Windows.Media;
|
||
using System.Windows.Threading;
|
||
|
||
namespace JiangsuEarthquake.ViewModels
|
||
{
|
||
public class SystemStateDataViewModel : NotifyBase
|
||
{
|
||
|
||
#region Search Data
|
||
private DateTime _startDateTime;
|
||
|
||
public DateTime StartDateTime
|
||
{
|
||
get { return _startDateTime; }
|
||
set { Set(ref _startDateTime, value); }
|
||
}
|
||
|
||
private DateTime _endDateTime;
|
||
|
||
public DateTime EndDateTime
|
||
{
|
||
get { return _endDateTime; }
|
||
set { Set(ref _endDateTime, value); }
|
||
}
|
||
|
||
int PageIndex = 0;
|
||
|
||
private int recordCount;
|
||
|
||
public int RecordCount
|
||
{
|
||
get { return recordCount; }
|
||
set { recordCount = value; this.DoNotify(); }
|
||
}
|
||
|
||
private int totalPage;
|
||
|
||
public int TotalPage
|
||
{
|
||
get { return totalPage; }
|
||
set { totalPage = value; this.DoNotify(); }
|
||
}
|
||
|
||
private string systemStateMsg;
|
||
|
||
public string SystemStateMsg
|
||
{
|
||
get { return systemStateMsg; }
|
||
set { systemStateMsg = value; this.DoNotify(); }
|
||
}
|
||
|
||
private ObservableCollection<BaseStationStatusModel> systemStateDataList = new ObservableCollection<BaseStationStatusModel>();
|
||
|
||
public ObservableCollection<BaseStationStatusModel> SystemStateDataList
|
||
{
|
||
get { return systemStateDataList; }
|
||
set { systemStateDataList = value; this.DoNotify(); }
|
||
}
|
||
|
||
private ObservableCollection<BaseStationStatusModel> totalSystemStateDataList = new ObservableCollection<BaseStationStatusModel>();
|
||
|
||
public ObservableCollection<BaseStationStatusModel> TotalSystemStateDataList
|
||
{
|
||
get { return totalSystemStateDataList; }
|
||
set { totalSystemStateDataList = value; this.DoNotify(); }
|
||
}
|
||
#endregion
|
||
|
||
|
||
#region Command Define
|
||
public CommandBase ForwordSystemStateCommand { get; set; }
|
||
|
||
public CommandBase NextSystemStateCommand { get; set; }
|
||
|
||
public CommandBase AskDataBtnCommand { get; set; }
|
||
|
||
public CommandBase RefreshDataCommand { get; set; }
|
||
|
||
public CommandBase DownloadDataCommand { get; set; }
|
||
#endregion
|
||
|
||
|
||
int station_id = 1;
|
||
|
||
public DispatcherTimer timerDownloadDataMsgHidden = new DispatcherTimer();
|
||
|
||
|
||
#region Data Filtering
|
||
string timeSearch = "";
|
||
|
||
public static DialogViewModel vm;
|
||
|
||
private bool _isChecked;
|
||
|
||
public bool IsChecked
|
||
{
|
||
get { return _isChecked; }
|
||
set
|
||
{
|
||
_isChecked = value;
|
||
this.DoNotify();
|
||
|
||
if (IsChecked)
|
||
{
|
||
if (string.IsNullOrEmpty(EndDateTime.ToString()) || string.IsNullOrEmpty(StartDateTime.ToString()))
|
||
{
|
||
IsChecked = false;
|
||
return;
|
||
}
|
||
|
||
if (EndDateTime < StartDateTime)
|
||
{
|
||
HandyControl.Controls.Dialog.Show(new TextDialog("起始时间大于结束时间，\n请重新输入！"));
|
||
IsChecked = false;
|
||
//this.EndDateTime = DateTime.Now;
|
||
//this.StartDateTime = DateTime.Now.AddDays(-1);
|
||
return;
|
||
}
|
||
|
||
timeSearch = " and DataTime BETWEEN '" + StartDateTime + "' and '" + EndDateTime + "' ";
|
||
}
|
||
else
|
||
{
|
||
timeSearch = "";
|
||
}
|
||
|
||
//设置当前页为1
|
||
PageIndex = 1;
|
||
|
||
TotalSystemStateDataList.Clear();
|
||
SystemStateDataList.Clear();
|
||
|
||
string sql = String.Format("select * from conboxenvpara where StationID = {0} {1} ORDER by id desc limit 100", station_id, timeSearch);
|
||
MySqlDataReader dataReader = DBHelper.ExecuteReader(sql, 1);
|
||
int index = 1;
|
||
while (dataReader.Read())
|
||
{
|
||
BaseStationStatusModel baseStationStatusModel = new BaseStationStatusModel();
|
||
baseStationStatusModel.Index = index++;
|
||
baseStationStatusModel.DataTime = Convert.ToDateTime(dataReader["DataTime"]);
|
||
baseStationStatusModel.In_Vol = Convert.ToSingle(string.IsNullOrEmpty(dataReader["In_Vol"].ToString()) ? "0" : dataReader["In_Vol"]);
|
||
baseStationStatusModel.In_Cur = Convert.ToSingle(string.IsNullOrEmpty(dataReader["In_Cur"].ToString()) ? "0" : dataReader["In_Cur"]);
|
||
baseStationStatusModel.JBH_Tem = Convert.ToSingle(string.IsNullOrEmpty(dataReader["JBH_Tem"].ToString()) ? "0" : dataReader["JBH_Tem"]);
|
||
baseStationStatusModel.JBH_Hum = Convert.ToSingle(string.IsNullOrEmpty(dataReader["JBH_Hum"].ToString()) ? "0" : dataReader["JBH_Hum"]);
|
||
int leakState = Convert.ToInt32(string.IsNullOrEmpty(dataReader["JBH_Leak"].ToString()) ? "1" : dataReader["JBH_Leak"]);
|
||
if (leakState == 1)
|
||
{
|
||
baseStationStatusModel.JBH_Leak = (ImageSource)Application.Current.FindResource("CycleRed");
|
||
}
|
||
else
|
||
{
|
||
baseStationStatusModel.JBH_Leak = (ImageSource)Application.Current.FindResource("CycleGreen");
|
||
}
|
||
baseStationStatusModel.JBH_Attitude_x = Convert.ToSingle(string.IsNullOrEmpty(dataReader["JBH_Attitude_x"].ToString()) ? "0" : dataReader["JBH_Attitude_x"]);
|
||
baseStationStatusModel.JBH_Attitude_y = Convert.ToSingle(string.IsNullOrEmpty(dataReader["JBH_Attitude_y"].ToString()) ? "0" : dataReader["JBH_Attitude_y"]);
|
||
baseStationStatusModel.JBH_Attitude_z = Convert.ToSingle(string.IsNullOrEmpty(dataReader["JBH_Attitude_z"].ToString()) ? "0" : dataReader["JBH_Attitude_z"]);
|
||
TotalSystemStateDataList.Add(baseStationStatusModel);
|
||
}
|
||
dataReader.Dispose();
|
||
|
||
RecordCount = index - 1;
|
||
if (RecordCount <= 10)
|
||
{
|
||
TotalPage = 1;
|
||
|
||
SystemStateDataList = TotalSystemStateDataList;
|
||
}
|
||
else
|
||
{
|
||
TotalPage = (int)Math.Ceiling((double)RecordCount / 10);
|
||
|
||
for (int i = 0; i < 10; i++)
|
||
{
|
||
SystemStateDataList.Add(TotalSystemStateDataList[i]);
|
||
}
|
||
}
|
||
|
||
SystemStateMsg = string.Format("共计{0}页，当前第{1}页", TotalPage, PageIndex);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
|
||
public SystemStateDataViewModel(int id)
|
||
{
|
||
// 默认查询1天内的日志
|
||
this.EndDateTime = DateTime.Now;
|
||
this.StartDateTime = DateTime.Now.AddDays(-1);
|
||
|
||
PageIndex = 1;
|
||
station_id = id;
|
||
|
||
vm = new DialogViewModel
|
||
{
|
||
Content = ""
|
||
};
|
||
|
||
|
||
#region Command Set
|
||
this.ForwordSystemStateCommand = new CommandBase();
|
||
this.ForwordSystemStateCommand.DoExcute = new Action<object>(ForwordSystemState);
|
||
this.ForwordSystemStateCommand.DoCanExcute = new Func<object, bool>((o) => true);
|
||
|
||
this.NextSystemStateCommand = new CommandBase();
|
||
this.NextSystemStateCommand.DoExcute = new Action<object>(NextSystemState);
|
||
this.NextSystemStateCommand.DoCanExcute = new Func<object, bool>((o) => true);
|
||
|
||
this.AskDataBtnCommand = new CommandBase();
|
||
this.AskDataBtnCommand.DoExcute = new Action<object>(AskData);
|
||
this.AskDataBtnCommand.DoCanExcute = new Func<object, bool>((o) => true);
|
||
|
||
this.RefreshDataCommand = new CommandBase();
|
||
this.RefreshDataCommand.DoExcute = new Action<object>(RefreshData);
|
||
this.RefreshDataCommand.DoCanExcute = new Func<object, bool>((o) => true);
|
||
|
||
this.DownloadDataCommand = new CommandBase();
|
||
this.DownloadDataCommand.DoExcute = new Action<object>(DownloadData);
|
||
this.DownloadDataCommand.DoCanExcute = new Func<object, bool>((o) => true);
|
||
#endregion
|
||
|
||
|
||
timerDownloadDataMsgHidden.Interval = TimeSpan.FromSeconds(2);
|
||
timerDownloadDataMsgHidden.Tick += TimerDownloadDataMsgHidden_Tick;
|
||
}
|
||
|
||
|
||
#region Ask Data
|
||
public void AskData(object o)
|
||
{
|
||
if (station_id == 1)
|
||
{
|
||
if (MainWindow.mainViewModel.serverModel1.IsOpened)
|
||
MainWindow.mainViewModel.serverModel1.SendMess(new byte[4] { 0x00, 0x01, 0x02, 0x04 });
|
||
}
|
||
else
|
||
{
|
||
if (MainWindow.mainViewModel.serverModel2.IsOpened)
|
||
MainWindow.mainViewModel.serverModel2.SendMess(new byte[4] { 0x00, 0x01, 0x02, 0x03 });
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
|
||
#region Page Switching
|
||
public void ForwordSystemState(object o)
|
||
{
|
||
if (PageIndex == 1)
|
||
return;
|
||
PageIndex -= 1;
|
||
|
||
SystemStateDataList.Clear();
|
||
for (int i = 0; i < 10; i++)
|
||
{
|
||
SystemStateDataList.Add(TotalSystemStateDataList[i + (PageIndex - 1) * 10]);
|
||
}
|
||
SystemStateMsg = string.Format("共计{0}页，当前第{1}页", TotalPage, PageIndex);
|
||
}
|
||
|
||
public void NextSystemState(object o)
|
||
{
|
||
if (PageIndex == TotalPage)
|
||
return;
|
||
PageIndex += 1;
|
||
|
||
SystemStateDataList.Clear();
|
||
for (int i = 0; i < (PageIndex == TotalPage ? (RecordCount - (PageIndex - 1) * 10) : 10); i++)
|
||
{
|
||
SystemStateDataList.Add(TotalSystemStateDataList[i + (PageIndex - 1) * 10]);
|
||
}
|
||
SystemStateMsg = string.Format("共计{0}页，当前第{1}页", TotalPage, PageIndex);
|
||
}
|
||
#endregion
|
||
|
||
|
||
#region RefreshData
|
||
public void RefreshData(object o)
|
||
{
|
||
if (IsChecked)
|
||
{
|
||
timeSearch = " and DataTime BETWEEN '" + StartDateTime + "' and '" + EndDateTime + "' ";
|
||
}
|
||
else
|
||
{
|
||
timeSearch = "";
|
||
}
|
||
|
||
//设置当前页为1
|
||
PageIndex = 1;
|
||
|
||
TotalSystemStateDataList.Clear();
|
||
SystemStateDataList.Clear();
|
||
|
||
string sql = String.Format("select * from conboxenvpara where StationID = {0} {1} ORDER by id desc limit 100", station_id, timeSearch);
|
||
MySqlDataReader dataReader = DBHelper.ExecuteReader(sql, 1);
|
||
int index = 1;
|
||
while (dataReader.Read())
|
||
{
|
||
BaseStationStatusModel baseStationStatusModel = new BaseStationStatusModel();
|
||
baseStationStatusModel.Index = index++;
|
||
baseStationStatusModel.DataTime = Convert.ToDateTime(dataReader["DataTime"]);
|
||
baseStationStatusModel.In_Vol = Convert.ToSingle(string.IsNullOrEmpty(dataReader["In_Vol"].ToString()) ? "0" : dataReader["In_Vol"]);
|
||
baseStationStatusModel.In_Cur = Convert.ToSingle(string.IsNullOrEmpty(dataReader["In_Cur"].ToString()) ? "0" : dataReader["In_Cur"]);
|
||
baseStationStatusModel.JBH_Tem = Convert.ToSingle(string.IsNullOrEmpty(dataReader["JBH_Tem"].ToString()) ? "0" : dataReader["JBH_Tem"]);
|
||
baseStationStatusModel.JBH_Hum = Convert.ToSingle(string.IsNullOrEmpty(dataReader["JBH_Hum"].ToString()) ? "0" : dataReader["JBH_Hum"]);
|
||
int leakState = Convert.ToInt32(string.IsNullOrEmpty(dataReader["JBH_Leak"].ToString()) ? "1" : dataReader["JBH_Leak"]);
|
||
if (leakState == 1)
|
||
{
|
||
baseStationStatusModel.JBH_Leak = (ImageSource)Application.Current.FindResource("CycleRed");
|
||
}
|
||
else
|
||
{
|
||
baseStationStatusModel.JBH_Leak = (ImageSource)Application.Current.FindResource("CycleGreen");
|
||
}
|
||
baseStationStatusModel.JBH_Attitude_x = Convert.ToSingle(string.IsNullOrEmpty(dataReader["JBH_Attitude_x"].ToString()) ? "0" : dataReader["JBH_Attitude_x"]);
|
||
baseStationStatusModel.JBH_Attitude_y = Convert.ToSingle(string.IsNullOrEmpty(dataReader["JBH_Attitude_y"].ToString()) ? "0" : dataReader["JBH_Attitude_y"]);
|
||
baseStationStatusModel.JBH_Attitude_z = Convert.ToSingle(string.IsNullOrEmpty(dataReader["JBH_Attitude_z"].ToString()) ? "0" : dataReader["JBH_Attitude_z"]);
|
||
TotalSystemStateDataList.Add(baseStationStatusModel);
|
||
}
|
||
dataReader.Dispose();
|
||
|
||
RecordCount = index - 1;
|
||
if (RecordCount <= 10)
|
||
{
|
||
TotalPage = 1;
|
||
|
||
SystemStateDataList = TotalSystemStateDataList;
|
||
}
|
||
else
|
||
{
|
||
TotalPage = (int)Math.Ceiling((double)RecordCount / 10);
|
||
|
||
for (int i = 0; i < 10; i++)
|
||
{
|
||
SystemStateDataList.Add(TotalSystemStateDataList[i]);
|
||
}
|
||
}
|
||
|
||
SystemStateMsg = string.Format("共计{0}页，当前第{1}页", TotalPage, PageIndex);
|
||
}
|
||
#endregion
|
||
|
||
|
||
#region DownloadData
|
||
private void TimerDownloadDataMsgHidden_Tick(object sender, EventArgs e)
|
||
{
|
||
DownloadDataMsgVisibility = Visibility.Hidden;
|
||
|
||
// 停止定时器
|
||
(sender as DispatcherTimer).Stop();
|
||
}
|
||
|
||
private string downloadDataMsg;
|
||
|
||
public string DownloadDataMsg
|
||
{
|
||
get { return downloadDataMsg; }
|
||
set { downloadDataMsg = value; this.DoNotify(); }
|
||
}
|
||
|
||
private Brush downloadDataMsgForeground;
|
||
|
||
public Brush DownloadDataMsgForeground
|
||
{
|
||
get { return downloadDataMsgForeground; }
|
||
set { downloadDataMsgForeground = value; this.DoNotify(); }
|
||
}
|
||
|
||
private bool downloadDataBtnIsEnabled = true;
|
||
|
||
public bool DownloadDataBtnIsEnabled
|
||
{
|
||
get { return downloadDataBtnIsEnabled; }
|
||
set { downloadDataBtnIsEnabled = value; this.DoNotify(); }
|
||
}
|
||
|
||
private Visibility downloadDataMsgVisibility = Visibility.Visible;
|
||
|
||
public Visibility DownloadDataMsgVisibility
|
||
{
|
||
get { return downloadDataMsgVisibility; }
|
||
set { downloadDataMsgVisibility = value; this.DoNotify(); }
|
||
}
|
||
|
||
public void DownloadData(object o)
|
||
{
|
||
DownloadDataBtnIsEnabled = false;
|
||
DownloadDataMsgVisibility = Visibility.Visible;
|
||
|
||
string baseStationFolder = Tools.GetAppSetting("BaseStationFolder");
|
||
string savePath = CSVDownload.CreateFile(baseStationFolder, "SystemStateData_" + DateTime.Now.ToString("yyyyMMddhhMMss"), "csv");
|
||
|
||
bool result = CSVDownload.SaveBaseStationDataToCSVFile(TotalSystemStateDataList, savePath);
|
||
if (result)
|
||
{
|
||
DownloadDataMsg = "下载数据成功！";
|
||
DownloadDataMsgForeground = new SolidColorBrush(Colors.Green);
|
||
}
|
||
else
|
||
{
|
||
DownloadDataMsg = "下载数据失败！";
|
||
DownloadDataMsgForeground = new SolidColorBrush(Colors.Red);
|
||
}
|
||
|
||
timerDownloadDataMsgHidden.Start();
|
||
DownloadDataBtnIsEnabled = true;
|
||
}
|
||
#endregion
|
||
|
||
}
|
||
}
|