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.Reflection;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Media;
using System.Windows.Threading;
using Brush = System.Windows.Media.Brush;

namespace JiangsuEarthquake.ViewModels
{
    public class SeismometerStateDataViewModel : 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 seismometerStateMsg;

        public string SeismometerStateMsg
        {
            get { return seismometerStateMsg; }
            set { seismometerStateMsg = value; this.DoNotify(); }
        }

        private ObservableCollection<EarthquakeSensorModel> seismometerStateDataList = new ObservableCollection<EarthquakeSensorModel>();

        public ObservableCollection<EarthquakeSensorModel> SeismometerStateDataList
        {
            get { return seismometerStateDataList; }
            set { seismometerStateDataList = value; this.DoNotify(); }
        }

        private ObservableCollection<EarthquakeSensorModel> totalSeismometerStateDataList = new ObservableCollection<EarthquakeSensorModel>();

        public ObservableCollection<EarthquakeSensorModel> TotalSeismometerStateDataList
        {
            get { return totalSeismometerStateDataList; }
            set { totalSeismometerStateDataList = 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


        #region Timer Define
        public DispatcherTimer timerDownloadDataMsgHidden = new DispatcherTimer();

        public DispatcherTimer timerAskData = new DispatcherTimer();

        public DispatcherTimer timerAskDataMsgHidden = new DispatcherTimer();

        public DispatcherTimer timerCycleAskData1 = new DispatcherTimer();

        public DispatcherTimer timerCycleAskData2 = new DispatcherTimer();
        #endregion


        int station_id = 1;


        #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;

                TotalSeismometerStateDataList.Clear();
                SeismometerStateDataList.Clear();

                string sql = String.Format("select * from seismograph_state 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())
                {
                    EarthquakeSensorModel earthquakeSensorModel = new EarthquakeSensorModel();
                    earthquakeSensorModel.Index = index++;
                    earthquakeSensorModel.RecordTime = Convert.ToDateTime(dataReader["RecordTime"]);
                    earthquakeSensorModel.Out_Vol = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Out_Vol"].ToString()) ? "0" : dataReader["Out_Vol"]);
                    earthquakeSensorModel.Backup_Vol = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Backup_Vol"].ToString()) ? "0" : dataReader["Backup_Vol"]);
                    earthquakeSensorModel.Pre = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Pre"].ToString()) ? "0" : dataReader["Pre"]);
                    earthquakeSensorModel.Tem = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Tem"].ToString()) ? "0" : dataReader["Tem"]);
                    earthquakeSensorModel.Sei_Tilt_Angle = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Sei_Tilt_Angle"].ToString()) ? "0" : dataReader["Sei_Tilt_Angle"]);
                    earthquakeSensorModel.OBS_Tilt_Angle = Convert.ToSingle(string.IsNullOrEmpty(dataReader["OBS_Tilt_Angle"].ToString()) ? "0" : dataReader["OBS_Tilt_Angle"]);
                    earthquakeSensorModel.Species_Dif = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Species_Dif"].ToString()) ? "0" : dataReader["Species_Dif"]);
                    earthquakeSensorModel.Frequency_Dif = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Frequency_Dif"].ToString()) ? "0" : dataReader["Frequency_Dif"]);
                    earthquakeSensorModel.CF_Total_Cap = Convert.ToSingle(string.IsNullOrEmpty(dataReader["CF_Total_Cap"].ToString()) ? "0" : dataReader["CF_Total_Cap"]);
                    earthquakeSensorModel.CF_Usable_Cap = Convert.ToSingle(string.IsNullOrEmpty(dataReader["CF_Usable_Cap"].ToString()) ? "0" : dataReader["CF_Usable_Cap"]);
                    earthquakeSensorModel.SD_Total_Cap1 = Convert.ToSingle(string.IsNullOrEmpty(dataReader["SD_Total_Cap1"].ToString()) ? "0" : dataReader["SD_Total_Cap1"]);
                    earthquakeSensorModel.SD_Usable_Cap1 = Convert.ToSingle(string.IsNullOrEmpty(dataReader["SD_Usable_Cap1"].ToString()) ? "0" : dataReader["SD_Usable_Cap1"]);
                    earthquakeSensorModel.SD_Total_Cap2 = Convert.ToSingle(string.IsNullOrEmpty(dataReader["SD_Total_Cap2"].ToString()) ? "0" : dataReader["SD_Total_Cap2"]);
                    earthquakeSensorModel.SD_Usable_Cap2 = Convert.ToSingle(string.IsNullOrEmpty(dataReader["SD_Usable_Cap2"].ToString()) ? "0" : dataReader["SD_Usable_Cap2"]);
                    earthquakeSensorModel.Sei_U_Point = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Sei_U_Point"].ToString()) ? "0" : dataReader["Sei_U_Point"]);
                    earthquakeSensorModel.Sei_V_Point = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Sei_V_Point"].ToString()) ? "0" : dataReader["Sei_V_Point"]);
                    earthquakeSensorModel.Sei_W_Point = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Sei_W_Point"].ToString()) ? "0" : dataReader["Sei_W_Point"]);
                    earthquakeSensorModel.North_Angle = Convert.ToSingle(string.IsNullOrEmpty(dataReader["North_Angle"].ToString()) ? "0" : dataReader["North_Angle"]);
                    TotalSeismometerStateDataList.Add(earthquakeSensorModel);
                }
                dataReader.Dispose();
                RecordCount = index - 1;
                if (RecordCount <= 10)
                {
                    TotalPage = 1;

                    SeismometerStateDataList = TotalSeismometerStateDataList;
                }
                else
                {
                    TotalPage = (int)Math.Ceiling((double)RecordCount / 10);

                    for (int i = 0; i < 10; i++)
                    {
                        SeismometerStateDataList.Add(TotalSeismometerStateDataList[i]);
                    }
                }

                SeismometerStateMsg = string.Format("共计{0}页，当前第{1}页", TotalPage, PageIndex);

                string record = "查询地震仪状态数据历史数据，查询时间范围为：" + StartDateTime + "至" + EndDateTime + "，共查询到" + RecordCount + "条历史数据";

                sql = $"insert into log_record(StationID,RecordTime,Device_Name,Operation_Type,Record) values('{station_id}','{DateTime.Now}','海底地震监测基站-地震仪','数据查询','{record}');";
                DBHelper.ExecuteNonQuery(sql, 1);
            }
        }
        #endregion


        public SeismometerStateDataViewModel(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


            #region Timer Set
            timerDownloadDataMsgHidden.Interval = TimeSpan.FromSeconds(2);
            timerDownloadDataMsgHidden.Tick += TimerDownloadDataMsgHidden_Tick;

            timerAskData.Interval = TimeSpan.FromSeconds(20);
            timerAskData.Tick += TimerAskData_Tick;

            timerAskDataMsgHidden.Interval = TimeSpan.FromSeconds(2);
            timerAskDataMsgHidden.Tick += TimerAskDataMsgHidden_Tick;
            #endregion

        }


        #region Ask Data
        private void TimerAskData_Tick(object sender, EventArgs e)
        {
            if (!AskDataBtnIsReceived)
            {
                AskDataMsgVisibility = Visibility.Visible;
                AskDataMsg = "请求数据发送成功，但未接收到数据！";
                timerAskDataMsgHidden.Start();
                AskDataMsgForeground = new SolidColorBrush(Colors.Red);
                AskDataBtnIsEnabled = true;
            }

            // 停止定时器
            (sender as DispatcherTimer).Stop();
        }

        private void TimerAskDataMsgHidden_Tick(object sender, EventArgs e)
        {
            AskDataMsgVisibility = Visibility.Hidden;

            // 停止定时器
            (sender as DispatcherTimer).Stop();
        }

        //点击周期获取时，选中的是主地震仪还是备地震仪
        private bool CheckIsMainSeis1 = false;

        private bool CheckIsMainSeis2 = false;

        private bool cycleRequestIsChecked;

        public bool CycleRequestIsChecked
        {
            get { return cycleRequestIsChecked; }
            set
            {
                cycleRequestIsChecked = value;
                this.DoNotify();

                if (CycleRequestIsChecked)
                {
                    if (string.IsNullOrEmpty(CycleRequestCycle))
                    {
                        CycleRequestIsChecked = false;
                        return;

                        //可改为自动设定周期
                    }

                    //周期获取数据
                    if (station_id == 1)
                    {
                        CheckIsMainSeis1 = MainSeisIsChecked;
                        timerCycleAskData1.Interval = TimeSpan.FromSeconds(int.Parse(CycleRequestCycle));
                        timerCycleAskData1.Tick += TimerCycleAskData1_Tick;
                        timerCycleAskData1.Start();
                    }
                    else
                    {
                        CheckIsMainSeis2 = MainSeisIsChecked;
                        timerCycleAskData2.Interval = TimeSpan.FromSeconds(int.Parse(CycleRequestCycle));
                        timerCycleAskData2.Tick += TimerCycleAskData2_Tick;
                        timerCycleAskData2.Start();
                    }

                    string record = "周期请求地震仪状态数据已开启，请求周期为：" + CycleRequestCycle;
                    string seisDevice = MainSeisIsChecked == true ? "海底地震监测基站-主地震仪" : "海底地震监测基站-备地震仪";

                    string sql = $"insert into log_record(StationID,RecordTime,Device_Name,Operation_Type,Record) values('{station_id}','{DateTime.Now}','{seisDevice}','数据请求','{record}');";
                    DBHelper.ExecuteNonQuery(sql, 1);
                }
                else
                {
                    //停止定时器
                    if (station_id == 1)
                    {
                        timerCycleAskData1.Stop();
                    }
                    else
                    {
                        timerCycleAskData2.Stop();
                    }

                    string seisDevice = MainSeisIsChecked == true ? "海底地震监测基站-主地震仪" : "海底地震监测基站-备地震仪";

                    string sql = $"insert into log_record(StationID,RecordTime,Device_Name,Operation_Type,Record) values('{station_id}','{DateTime.Now}','{seisDevice}','数据请求','周期请求地震仪状态数据已关闭');";
                    DBHelper.ExecuteNonQuery(sql, 1);
                }
            }
        }

        private void TimerCycleAskData1_Tick(object sender, EventArgs e)
        {
            AskSeisData(1, CheckIsMainSeis1);
        }

        private void TimerCycleAskData2_Tick(object sender, EventArgs e)
        {
            AskSeisData(2, CheckIsMainSeis2);
        }

        private string cycleRequestCycle;

        public string CycleRequestCycle
        {
            get { return cycleRequestCycle; }
            set { cycleRequestCycle = value; this.DoNotify(); }
        }

        private string askDataMsg;

        public string AskDataMsg
        {
            get { return askDataMsg; }
            set { askDataMsg = value; this.DoNotify(); }
        }

        private Brush askDataMsgForeground;

        public Brush AskDataMsgForeground
        {
            get { return askDataMsgForeground; }
            set { askDataMsgForeground = value; this.DoNotify(); }
        }

        private bool askDataBtnIsEnabled = true;

        public bool AskDataBtnIsEnabled
        {
            get { return askDataBtnIsEnabled; }
            set { askDataBtnIsEnabled = value; this.DoNotify(); }
        }

        private bool askDataBtnIsReceived = false;

        public bool AskDataBtnIsReceived
        {
            get { return askDataBtnIsReceived; }
            set { askDataBtnIsReceived = value; this.DoNotify(); }
        }

        private Visibility askDataMsgVisibility = Visibility.Visible;

        public Visibility AskDataMsgVisibility
        {
            get { return askDataMsgVisibility; }
            set { askDataMsgVisibility = value; this.DoNotify(); }
        }

        private bool mainSeisIsChecked = true;

        public bool MainSeisIsChecked
        {
            get { return mainSeisIsChecked; }
            set { mainSeisIsChecked = value; this.DoNotify(); }
        }

        private bool backupSeisIsChecked = false;

        public bool BackupSeisIsChecked
        {
            get { return backupSeisIsChecked; }
            set { backupSeisIsChecked = value; this.DoNotify(); }
        }

        List<byte> sendDataSeis = new List<byte>();

        private byte[] checkCode { get; set; } = new byte[2];       //从CMD到DATA结束的CRC16校验和

        private List<byte> checkByte { get; set; } = new List<byte>();            //校验码Byte

        public void AskData(object o)
        {
            AskSeisData(station_id, MainSeisIsChecked);
        }


        public void AskSeisData(int id, bool IsMainSeis)
        {
            AskDataBtnIsEnabled = false;
            AskDataBtnIsReceived = false;

            sendDataSeis.Clear();
            sendDataSeis.AddRange(new byte[] { 0xBF, 0x13, 0x97, 0x74 });   //SYNC
            sendDataSeis.AddRange(new byte[] { 0xA0, 0x50 });       //CMD
            sendDataSeis.AddRange(new byte[] { 0x00, 0x04 });       //LENGTH

            //地震计号
            byte[] numDZJ = new byte[2];
            if (id == 1)
            {
                if (IsMainSeis)
                    numDZJ = BitConverter.GetBytes(short.Parse(Tools.GetAppSetting("MainSeisNum1")));
                else
                    numDZJ = BitConverter.GetBytes(short.Parse(Tools.GetAppSetting("BackupSeisNum1")));
            }
            else
            {
                if (IsMainSeis)
                    numDZJ = BitConverter.GetBytes(short.Parse(Tools.GetAppSetting("MainSeisNum2")));
                else
                    numDZJ = BitConverter.GetBytes(short.Parse(Tools.GetAppSetting("BackupSeisNum2")));
            }
            numDZJ = Tools.PadArrayWithZeros(numDZJ, 2);

            sendDataSeis.AddRange(numDZJ);       //DATA
            checkByte.Clear();
            checkByte.AddRange(new byte[] { 0xA0, 0x50 });       //CMD
            checkByte.AddRange(new byte[] { 0x00, 0x04 });       //LENGTH
            checkByte.AddRange(numDZJ);       //DATA
            checkCode = Tools.ComputeChecksum(checkByte.ToArray());      //CHK_SUM
            sendDataSeis.AddRange(checkCode);

            bool result = false;
            if (id == 1)
            {
                if (IsMainSeis)  //主地震仪
                {
                    if (MainWindow.mainViewModel.clientModelMainSeis1.IsConnected && MainWindow.mainViewModel.IsMainSeis1CertSucs)
                    {
                        result = MainWindow.mainViewModel.clientModelMainSeis1.SendMessage(sendDataSeis.ToArray());
                    }
                    else
                    {
                        AskDataMsgVisibility = Visibility.Visible;
                        AskDataMsg = "通信未连接！";
                        timerAskDataMsgHidden.Start();
                        AskDataMsgForeground = new SolidColorBrush(Colors.Red);
                        AskDataBtnIsEnabled = true;
                        return;
                    }
                }
                else
                {
                    if (MainWindow.mainViewModel.clientModelBackupSeis1.IsConnected && MainWindow.mainViewModel.IsBackupSeis1CertSucs)
                    {
                        result = MainWindow.mainViewModel.clientModelBackupSeis1.SendMessage(sendDataSeis.ToArray());
                    }
                    else
                    {
                        AskDataMsgVisibility = Visibility.Visible;
                        AskDataMsg = "通信未连接！";
                        timerAskDataMsgHidden.Start();
                        AskDataMsgForeground = new SolidColorBrush(Colors.Red);
                        AskDataBtnIsEnabled = true;
                        return;
                    }
                }
            }
            else
            {
                if (IsMainSeis)  //主地震仪
                {
                    if (MainWindow.mainViewModel.clientModelMainSeis2.IsConnected && MainWindow.mainViewModel.IsMainSeis2CertSucs)
                    {
                        result = MainWindow.mainViewModel.clientModelMainSeis2.SendMessage(sendDataSeis.ToArray());
                    }
                    else
                    {
                        AskDataMsgVisibility = Visibility.Visible;
                        AskDataMsg = "通信未连接！";
                        timerAskDataMsgHidden.Start();
                        AskDataMsgForeground = new SolidColorBrush(Colors.Red);
                        AskDataBtnIsEnabled = true;
                        return;
                    }
                }
                else
                {
                    if (MainWindow.mainViewModel.clientModelBackupSeis2.IsConnected && MainWindow.mainViewModel.IsBackupSeis2CertSucs)
                    {
                        result = MainWindow.mainViewModel.clientModelBackupSeis2.SendMessage(sendDataSeis.ToArray());
                    }
                    else
                    {
                        AskDataMsgVisibility = Visibility.Visible;
                        AskDataMsg = "通信未连接！";
                        timerAskDataMsgHidden.Start();
                        AskDataMsgForeground = new SolidColorBrush(Colors.Red);
                        AskDataBtnIsEnabled = true;
                        return;
                    }
                }
            }

            if (result)
            {
                AskDataMsgVisibility = Visibility.Visible;
                AskDataMsg = "请求地震仪状态数据发送成功！";
                timerAskDataMsgHidden.Start();
                AskDataMsgForeground = new SolidColorBrush(Colors.Green);
                timerAskData.Start();
            }
            else
            {
                AskDataMsgVisibility = Visibility.Visible;
                AskDataMsg = "请求地震仪状态数据发送失败！";
                timerAskDataMsgHidden.Start();
                AskDataMsgForeground = new SolidColorBrush(Colors.Red);
                AskDataBtnIsEnabled = true;
            }

            string seisDevice = IsMainSeis == true ? "海底地震监测基站-主地震仪" : "海底地震监测基站-备地震仪";

            string sql = $"insert into log_record(StationID,RecordTime,Device_Name,Operation_Type,Record) values('{id}','{DateTime.Now}','{seisDevice}','数据请求','{AskDataMsg}');";
            DBHelper.ExecuteNonQuery(sql, 1);
        }
        #endregion


        #region Page Switching
        public void ForwordSystemState(object o)
        {
            if (PageIndex == 1)
                return;
            PageIndex -= 1;

            SeismometerStateDataList.Clear();
            for (int i = 0; i < 10; i++)
            {
                SeismometerStateDataList.Add(TotalSeismometerStateDataList[i + (PageIndex - 1) * 10]);
            }
            SeismometerStateMsg = string.Format("共计{0}页，当前第{1}页", TotalPage, PageIndex);
        }

        public void NextSystemState(object o)
        {
            if (PageIndex == TotalPage)
                return;
            PageIndex += 1;

            SeismometerStateDataList.Clear();
            for (int i = 0; i < (PageIndex == TotalPage ? (RecordCount - (PageIndex - 1) * 10) : 10); i++)
            {
                SeismometerStateDataList.Add(TotalSeismometerStateDataList[i + (PageIndex - 1) * 10]);
            }
            SeismometerStateMsg = 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;

            TotalSeismometerStateDataList.Clear();
            SeismometerStateDataList.Clear();

            string sql = String.Format("select * from seismograph_state 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())
            {
                EarthquakeSensorModel earthquakeSensorModel = new EarthquakeSensorModel();
                earthquakeSensorModel.Index = index++;
                earthquakeSensorModel.RecordTime = Convert.ToDateTime(dataReader["RecordTime"]);
                earthquakeSensorModel.Out_Vol = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Out_Vol"].ToString()) ? "0" : dataReader["Out_Vol"]);
                earthquakeSensorModel.Backup_Vol = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Backup_Vol"].ToString()) ? "0" : dataReader["Backup_Vol"]);
                earthquakeSensorModel.Pre = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Pre"].ToString()) ? "0" : dataReader["Pre"]);
                earthquakeSensorModel.Tem = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Tem"].ToString()) ? "0" : dataReader["Tem"]);
                earthquakeSensorModel.Sei_Tilt_Angle = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Sei_Tilt_Angle"].ToString()) ? "0" : dataReader["Sei_Tilt_Angle"]);
                earthquakeSensorModel.OBS_Tilt_Angle = Convert.ToSingle(string.IsNullOrEmpty(dataReader["OBS_Tilt_Angle"].ToString()) ? "0" : dataReader["OBS_Tilt_Angle"]);
                earthquakeSensorModel.Species_Dif = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Species_Dif"].ToString()) ? "0" : dataReader["Species_Dif"]);
                earthquakeSensorModel.Frequency_Dif = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Frequency_Dif"].ToString()) ? "0" : dataReader["Frequency_Dif"]);
                earthquakeSensorModel.CF_Total_Cap = Convert.ToSingle(string.IsNullOrEmpty(dataReader["CF_Total_Cap"].ToString()) ? "0" : dataReader["CF_Total_Cap"]);
                earthquakeSensorModel.CF_Usable_Cap = Convert.ToSingle(string.IsNullOrEmpty(dataReader["CF_Usable_Cap"].ToString()) ? "0" : dataReader["CF_Usable_Cap"]);
                earthquakeSensorModel.SD_Total_Cap1 = Convert.ToSingle(string.IsNullOrEmpty(dataReader["SD_Total_Cap1"].ToString()) ? "0" : dataReader["SD_Total_Cap1"]);
                earthquakeSensorModel.SD_Usable_Cap1 = Convert.ToSingle(string.IsNullOrEmpty(dataReader["SD_Usable_Cap1"].ToString()) ? "0" : dataReader["SD_Usable_Cap1"]);
                earthquakeSensorModel.SD_Total_Cap2 = Convert.ToSingle(string.IsNullOrEmpty(dataReader["SD_Total_Cap2"].ToString()) ? "0" : dataReader["SD_Total_Cap2"]);
                earthquakeSensorModel.SD_Usable_Cap2 = Convert.ToSingle(string.IsNullOrEmpty(dataReader["SD_Usable_Cap2"].ToString()) ? "0" : dataReader["SD_Usable_Cap2"]);
                earthquakeSensorModel.Sei_U_Point = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Sei_U_Point"].ToString()) ? "0" : dataReader["Sei_U_Point"]);
                earthquakeSensorModel.Sei_V_Point = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Sei_V_Point"].ToString()) ? "0" : dataReader["Sei_V_Point"]);
                earthquakeSensorModel.Sei_W_Point = Convert.ToSingle(string.IsNullOrEmpty(dataReader["Sei_W_Point"].ToString()) ? "0" : dataReader["Sei_W_Point"]);
                earthquakeSensorModel.North_Angle = Convert.ToSingle(string.IsNullOrEmpty(dataReader["North_Angle"].ToString()) ? "0" : dataReader["North_Angle"]);
                TotalSeismometerStateDataList.Add(earthquakeSensorModel);
            }
            dataReader.Dispose();
            RecordCount = index - 1;
            if (RecordCount <= 10)
            {
                TotalPage = 1;

                SeismometerStateDataList = TotalSeismometerStateDataList;
            }
            else
            {
                TotalPage = (int)Math.Ceiling((double)RecordCount / 10);

                for (int i = 0; i < 10; i++)
                {
                    SeismometerStateDataList.Add(TotalSeismometerStateDataList[i]);
                }
            }

            SeismometerStateMsg = string.Format("共计{0}页，当前第{1}页", TotalPage, PageIndex);

            sql = $"insert into log_record(StationID,RecordTime,Device_Name,Operation_Type,Record) values('{station_id}','{DateTime.Now}','海底地震监测基站-地震仪','数据刷新','刷新地震仪状态数据');";
            DBHelper.ExecuteNonQuery(sql, 1);
        }
        #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;

            string seismometerStateFolder = Tools.GetAppSetting("SeismometerStateFolder");
            string savePath = CSVDownload.CreateFile(seismometerStateFolder, "SeismometerStateData_" + DateTime.Now.ToString("yyyyMMddhhMMss"), "csv");

            bool result = CSVDownload.SaveSeismometerStateDataToCSVFile(TotalSeismometerStateDataList, savePath);
            if (result)
            {
                DownloadDataMsg = "下载数据成功！";
                DownloadDataMsgVisibility = Visibility.Visible;
                DownloadDataMsgForeground = new SolidColorBrush(Colors.Green);
            }
            else
            {
                DownloadDataMsg = "下载数据失败！";
                DownloadDataMsgVisibility = Visibility.Visible;
                DownloadDataMsgForeground = new SolidColorBrush(Colors.Red);
            }

            timerDownloadDataMsgHidden.Start();
            DownloadDataBtnIsEnabled = true;

            string record = "下载地震仪状态数据，" + DownloadDataMsg;

            string sql = $"insert into log_record(StationID,RecordTime,Device_Name,Operation_Type,Record) values('{station_id}','{DateTime.Now}','海底地震监测基站-地震仪','数据下载','{record}');";
            DBHelper.ExecuteNonQuery(sql, 1);
        }
        #endregion

    }
}