StartServerWPF/StartServerWPF.Modules.Main/ViewModels/MainViewModel.cs

using Prism.Commands;
using Prism.Mvvm;
using Prism.Services.Dialogs;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Net;
using System.Runtime.InteropServices;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Controls;
using System.Windows;
using System.Collections.ObjectModel;
using StartServerWPF.Modules.Main.Model;

namespace StartServerWPF.Modules.Main.ViewModels
{
    public class MainViewModel : BindableBase
    {
        public MainViewModel(IDialogService dialogService)
        {
            Message = "View A from your Prism Module";
            Console.WriteLine(System.Environment.CurrentDirectory + "\\" + systemConfigPath);
            sc = JsonParser.ReadSystemJsonFile(systemConfigPath);
            int moniTimeInd = sc.proMonitor.ProParams.IndexOf("-btime");
            string moniTimeStr = sc.proMonitor.ProParams.Substring(moniTimeInd + 7);
            int moniTimeIndEnd = moniTimeStr.IndexOf(">");
            moniTimeStr = moniTimeStr.Substring(0, moniTimeIndEnd - 1);
            MoniStartTime = DateTime.Parse(moniTimeStr);
            InitializeParams();
            JsonParser.UpdateApmsJson(sc.proApms.ProPath + "apms.json", sc.vpnInfo.DataSavePath);
            JsonParser.UpdateRecvJson(sc.proRecv.ProPath + "gw.recvftp.json", sc.vpnInfo.DataSavePath);
            sc.proMonitor.ProParams = JsonParser.CreateMonitorStartParam(sc.vpnInfo.DataSavePath, MoniStartTime);
            StartTime = DateTime.Now;
            // labelStartTime.Text = "启动时间：" + StartTime.ToString();

            remDb = new MySqlHelper(sc.remoteDb);
            Console.WriteLine(System.Environment.CurrentDirectory);
            Console.WriteLine(sc.remoteDb.ServerAddress + "\t" + sc.remoteDb.ServerPort
                + "\t" + sc.remoteDb.UserName + "\t" + sc.remoteDb.Password);
            this._dialogService = dialogService;
        }


        #region  属性
        private string _message;
        public string Message
        {
            get { return _message; }
            set { SetProperty(ref _message, value); }
        }
        private DateTime startTime;
        private DateTime moniStartTime;
        public DateTime StartTime { get => startTime; set => startTime = value; }
        public DateTime MoniStartTime { get => moniStartTime; set => moniStartTime = value; }
        private string runTime;

        public string RunTime
        {
            get { return runTime; }
            set { runTime = value; }
        }
        private string vPNStatus;

        public string VPNStatus
        {
            get { return vPNStatus; }
            set { vPNStatus = value; }
        }
        private string vpnIP;

        public string VpnIP
        {
            get { return vpnIP; }
            set { vpnIP = value; }
        }


        private ObservableCollection<string> reciveDataSource=new ObservableCollection<string>();

        public ObservableCollection<string> ReciveDataSource
        {
            get { return reciveDataSource; }
            set { reciveDataSource = value; }
        }
        private ObservableCollection<int> intervalTimesSource=new ObservableCollection<int>();

        public ObservableCollection<int> IntervalTimesSource
        {
            get { return intervalTimesSource; }
            set { intervalTimesSource = value; }
        }

        private int selectedIndex;

        public int SelectedIndex
        {
            get { return selectedIndex; }
            set { selectedIndex = value; }
        }

        private bool isEnabledStart;

        public bool IsEnabledStart
        {
            get { return isEnabledStart; }
            set { isEnabledStart = value; }
        }

        private int proMonInterval = 10;
        public int ProMonInterval { get => proMonInterval;
            set => proMonInterval = value; 
        }

        #endregion

        #region 事件
        public DelegateCommand LoadedCommand => new(Loaded);
        public DelegateCommand UnloadedCommand => new(Unloaded);

        public DelegateCommand ConnectVPNCommand => new(ConnectVPN);
        public DelegateCommand DisConnectVPNCommand => new(DisConnectVPN);
        public DelegateCommand GetVPNStatusCommand => new(GetVPNStatus);     
        public DelegateCommand SetVPNParaCommand => new(SetVPNPara);
        public DelegateCommand DisplayLogCommand => new(DisplayLog);
        public DelegateCommand OneKeyStartCommand => new(OneKeyStart);
        public DelegateCommand OneKeyStopCommand => new(OneKeyStop);
        public DelegateCommand DisplayRealWavesCommand => new(DisplayRealWaves);
        public DelegateCommand QueryDataCommand => new(QueryData);
        public DelegateCommand InsertDataCommand => new(InsertData);
        private void Loaded()
        {
            IntilVPN();
            SetControlstatus();
        }
        
        private void Unloaded()
        {
            KillProcess(sc.proServer);
            KillProcess(sc.proRecv);
            KillProcess(sc.proApms);
            KillProcess(sc.proMonitor);
            string logStr = DateTime.Now.ToString("s") + "\t程序关闭";
            WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);
            //switch (kserindex)
            //{
            //    case -1:
            //        Console.WriteLine(serProcInfo.ProName + "结束失败");
            //        break;
            //    case 0:
            //        Console.WriteLine(serProcInfo.ProName + "结束成功");
            //        break;
            //    case 1:
            //        Console.WriteLine(serProcInfo.ProName + "程序未启动");
            //        break;
            //}

            //int krecindex = KillProcess(recvProcInfo);
            //switch (krecindex)
            //{
            //    case -1:
            //        Console.WriteLine(recvProcInfo.ProName + "结束失败");
            //        break;
            //    case 0:
            //        Console.WriteLine(recvProcInfo.ProName + "结束成功");
            //        break;
            //    case 1:
            //        Console.WriteLine(recvProcInfo.ProName + "程序未启动");
            //        break;
            //}
        }
       
        private void ConnectVPN()
        {
            vpn.CreateOrUpdateVPN(sc.vpnInfo.VpnName, sc.vpnInfo.VpnIP);
            vpn.ConnectVPN(sc.vpnInfo.VpnName, sc.vpnInfo.VpnUserName, sc.vpnInfo.VpnPsw);
            Thread.Sleep(1000);
            string logStr = DateTime.Now.ToString("s") + "\tVPN手动连接";
            WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);
            SetControlstatus();
        }
        
        private void DisConnectVPN()
        {
            if (MessageBox.Show("是否断开VPN连接？", "提示", MessageBoxButton.YesNo, MessageBoxImage.Warning) == MessageBoxResult.Yes)
            {
                vpn.DisConnectVPN(sc.vpnInfo.VpnName);
                Thread.Sleep(500);
                SetControlstatus();
                Thread.Sleep(100);
                string logStr = DateTime.Now.ToString("s") + "\tVPN手动断开";
                WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);
            }
        }
     
        private void GetVPNStatus()
        {
            if (vpn.CheckVpnStatus(sc.vpnInfo.VpnName))
            {
                MessageBox.Show("VPN已经连接!");
            }
            else
            {
                MessageBox.Show("VPN未连接!");
            }
        }

        private void SetVPNPara()
        {
            //FormSetParam fvi = new FormSetParam();
            //fvi.fm = this;
            //fvi.ShowDialog();

            DialogParameters param = new DialogParameters();
            param.Add("type", 1);// 编辑
            param.Add("model", sc.vpnInfo);
            param.Add("moniTime", MoniStartTime);

            _dialogService.ShowDialog(
                "SetParamDialog",
                param,
                new Action<IDialogResult>(result =>
                {
                    if (result != null && result.Result == ButtonResult.OK)
                    {
                        MessageBox.Show("数据已保存", "提示");
                    }
                }));
        }

        private void DisplayLog()
        {
            Process.Start("explorer.exe", sc.vpnInfo.SystemLogPath);
        }
       
        private void OneKeyStart()
        {
            StartTime = DateTime.Now;
            sc.proServer.Pid = StartProcess(sc.proServer);
            StartTime = DateTime.Now;
            if (sc.proServer.Pid < 32)
            {
                ReciveDataSource.Add("服务器程序启动失败：" + StartTime.ToString());
            }
            Thread.Sleep(10);
            sc.proRecv.Pid = StartProcess(sc.proRecv);
            if (sc.proRecv.Pid < 32)
            {
                ReciveDataSource.Add("接收数据程序启动失败：" + StartTime.ToString());
            }
            Thread.Sleep(10);
            sc.proApms.Pid = StartProcess(sc.proApms);
            if (sc.proApms.Pid < 32)
            {
                ReciveDataSource.Add("自动识别程序启动失败：" + StartTime.ToString());
            }
            Thread.Sleep(10);
            sc.proMonitor.Pid = StartProcess(sc.proMonitor);
            Console.WriteLine(sc.proMonitor.Pid);
            if (sc.proMonitor.Pid < 32)
            {
                ReciveDataSource.Add("网页服务程序启动失败：" + StartTime.ToString());
            }
            Thread.Sleep(10);
            // labelStartTime.Text = "启动时间：" + StartTime.ToString();
            RunTime = "运行时间：" + DateDiff(DateTime.Now, StartTime);
            string logStr = StartTime.ToString("s") + "\t服务器程序启动";
            WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);
            // progressBar1.Style = ProgressBarStyle.Marquee;

            IsEnabledStart = false;
            // btnSetParams.Enabled = false;
            timer1.Interval = ProMonInterval * 1000;
            timer1.Start();
            ReciveDataSource.Clear();
        }

        private void OneKeyStop()
        {
            int kserindex = KillProcess(sc.proServer);
            if (kserindex > -1)
            {
                ReciveDataSource.Add(sc.proServer.ProName + "结束成功");
            }
            else
            {
                ReciveDataSource.Add(sc.proServer.ProName + "结束失败");
            }
            int krecindex = KillProcess(sc.proRecv);
            if (kserindex > -1)
            {
                ReciveDataSource.Add(sc.proRecv.ProName + "结束成功");
            }
            else
            {
                ReciveDataSource.Add(sc.proRecv.ProName + "结束失败");
            }
            int kampsindex = KillProcess(sc.proApms);
            if (kampsindex > -1)
            {
                ReciveDataSource.Add(sc.proApms.ProName + "结束成功");
            }
            else
            {
                ReciveDataSource.Add(sc.proApms.ProName + "结束失败");
            }
            int kmonitorindex = KillProcess(sc.proMonitor);
            if (kmonitorindex > -1)
            {
                ReciveDataSource.Add(sc.proMonitor.ProName + "结束成功");
            }
            else
            {
                ReciveDataSource.Add(sc.proMonitor.ProName + "结束失败");
            }
            ReciveDataSource.Add("服务停止于：" + DateTime.Now.ToString());
            timer1.Stop();
           // progressBar1.Style = ProgressBarStyle.Continuous;
            string logStr = DateTime.Now.ToString("s") + "\t服务器程序关闭";
            WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);

            // labelStartTime.Text = "启动时间：";
            StartTime = new DateTime();
            RunTime = "运行时间：";
            isEnabledStart = true;
            //  buttonOneKeyStart.Enabled = true;
            // btnSetParams.Enabled = true;
        }

        private void DisplayRealWaves()
        {
            StartProcess(sc.proPlot);
        }

        private void QueryData()
        {
            string str = "2021-05-09T00:15:34.530406 -0.60000 -0.07969 0.6000 ML -3.05 14 13 0.048 ";
            MsEvent me = new MsEvent(str);
            // dataGridView1.DataSource = remDb.MySqlSelect("select ETime,X,Y,Z,ML,LocSta,MLSta,Rms from " + sc.remoteDb.TableName).Tables[sc.remoteDb.TableName];
        }

        private void InsertData()
        {
            string str = "2021-05-09T00:15:34.900406 -0.60000 -0.07969 0.6000 ML -3.05 14 13 0.048 ";
            MsEvent me = new MsEvent(str);
            bool insStat = remDb.InsertEvent(me);
            if (insStat)
            {
                Console.WriteLine("新增成功");
            }
            else
            {
                Console.WriteLine("已有该记录");
            }
            // dataGridView1.DataSource = remDb.MySqlSelect("select ETime,X,Y,Z,ML,LocSta,MLSta,Rms from " + sc.remoteDb.TableName).Tables[sc.remoteDb.TableName];
        }



        //private void button1_Click(object sender, EventArgs e)
        //{
        //    vpn.ConnectVPN(sc.vpnInfo.VpnName, sc.vpnInfo.VpnUserName, sc.vpnInfo.VpnPsw);
        //    Thread.Sleep(1000);
        //    string logStr = DateTime.Now.ToString("s") + "\tVPN手动连接";
        //    WriteSerLog(sc.SystemLogPath + systemLogFileName, logStr);
        //    SetControlstatus();
        //}

        //private void button1_Click_1(object sender, EventArgs e)
        //{
        //    JsonParser.WriteSystemConfigFile("SystemConfig.json", sc);

        //}

        //private void button2_Click(object sender, EventArgs e)
        //{
        //    ProcessStartInfo processStartInfo = new ProcessStartInfo(@"F:\Project\2021\河南理工\余吾预警项目\郑老师程序\v20210415\All\server.exe", "service.conf");
        //    processStartInfo.WindowStyle = ProcessWindowStyle.Normal;
        //    Process proc = Process.Start(processStartInfo);

        //    ProcessStartInfo processStartInfoRec = new ProcessStartInfo(@"F:\Project\2021\河南理工\余吾预警项目\郑老师程序\v20210415\All\gw.recvftp.exe", "-cfg gw.recvftp.json >outRecv.txt");
        //    processStartInfoRec.WindowStyle = ProcessWindowStyle.Normal;
        //    Process procRec = Process.Start(processStartInfoRec);
        //}

        #endregion
        private void ConnectVpn()
        {
            // 系统路径 C:\windows\system32\
            string WinDir = Environment.GetFolderPath(Environment.SpecialFolder.SystemX86) + @"";
            Console.WriteLine(WinDir);
            // rasdial.exe
            string RasDialFileName = "rasdial.exe";

            // VPN路径 C:\windows\system32\rasdial.exe
            string VPNPROCESS = WinDir + "\\" + RasDialFileName;
            // VPN地址
            //string IPToPing = "49.232.209.49";

            // VPN名称
            string VPNName = "余吾手动";

            // VPN用户名
            string UserName = "lzvpn";

            // VPN密码
            string PassWord = "Lz123456789";
            string args = string.Format("{0} {1} {2}", VPNName, UserName, PassWord);

            ProcessStartInfo myProcess = new ProcessStartInfo(VPNPROCESS, args);

            myProcess.CreateNoWindow = true;

            myProcess.UseShellExecute = false;

            Process.Start(myProcess);
        }
        private void IntilVPN()
        {
            vpn = new VPNHelper(sc.vpnInfo.VpnName, sc.vpnInfo.VpnIP, sc.vpnInfo.VpnUserName, sc.vpnInfo.VpnPsw);
        }


        [DllImport("shell32.dll")]
        public static extern int ShellExecute(IntPtr hwnd, StringBuilder lpszOp, StringBuilder lpszFile, StringBuilder lpszParams, StringBuilder lpszDir, int FsShowCmd);

        public string proPath;
        public string zyProPath = @"\serverprogram";

        public string systemConfigPath = "SystemConfig.json";
        public string systemLogFileName;

        public int showState = 0;
        public string serverVision = "20210629";

        public VPNHelper vpn;

        public bool vpnStatus = false;
        public SystemConfig sc;

        MySqlHelper remDb;

        private System.Timers.Timer  timer1=new System.Timers.Timer();
        private readonly IDialogService _dialogService;

        public void InitializeParams()
        {
            timer1.Interval = ProMonInterval * 1000;
            this.Message = "服务器版本：" + serverVision;
            IntervalTimesSource.Add(5);
            IntervalTimesSource.Add(10);
            IntervalTimesSource.Add(15);
            IntervalTimesSource.Add(20);
            IntervalTimesSource.Add(30);
            IntervalTimesSource.Add(60);
            SelectedIndex = 1;
            systemLogFileName = "SerLog_" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
            string logStr = DateTime.Now.ToString("s") + "\t程序启动";
            WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);
            //CheckIp();
        }
        #region 方法
        /// <summary>
        /// 启动进程
        /// </summary>
        /// <param name="proInfo"></param>
        /// <returns>进程启动返回值</returns>
        private int StartProcess(ProcessInfo proInfo)
        {
            int seInd = ShellExecute(IntPtr.Zero, new StringBuilder("open"), new StringBuilder(proInfo.ProName + ".exe")
                     , new StringBuilder(proInfo.ProParams), new StringBuilder(proInfo.ProPath), proInfo.ShowState);
            return seInd;
        }
        /// <summary>
        /// 结束进程
        /// </summary>
        /// <param name="processInfo"></param>
        /// <returns>0=成功;1=未找到进程;-1=失败</returns>
        private int KillProcess(ProcessInfo processInfo)
        {
            int ri = 0;
            if (processInfo != null)
            {
                if (processInfo.ProName != null)
                {
                    try
                    {

                        Process[] localByName = Process.GetProcessesByName(processInfo.ProName);
                        if (localByName.Length == 0)
                        {
                            ri = 1;
                            return ri;
                        }
                        foreach (var item in localByName)
                        {
                            Console.WriteLine(item.Id);
                            item.Kill();
                        }
                        return ri;
                    }
                    catch (Exception)
                    {
                        return -1;
                    }
                }
                else
                {
                    return 0;
                }
            }
            else
            {
                return 0;
            }
        }
        /// <summary>
        /// 查找进程
        /// </summary>
        /// <param name="processInfo"></param>
        /// <returns>0=正在运行;1=未运行;-1=系统错误</returns>
        private int FindProcess(ProcessInfo processInfo)
        {
            int ri = 0;
            try
            {
                Process[] localByName = Process.GetProcessesByName(processInfo.ProName);
                if (localByName.Length == 0)
                {
                    ri = 1;
                    return ri;
                }
                return ri;
            }
            catch (Exception)
            {
                return -1;
            }
        }
        private string DateDiff(DateTime DateTime1, DateTime DateTime2)
        {
            string dateDiff = null;
            TimeSpan ts1 = new TimeSpan(DateTime1.Ticks);
            TimeSpan ts2 = new
            TimeSpan(DateTime2.Ticks);
            TimeSpan ts = ts1.Subtract(ts2).Duration();
            if (ts.Days > 0)
            {
                dateDiff += ts.Days.ToString() + "天";
            }
            if (ts.Hours > 0)
            {
                dateDiff += ts.Hours.ToString() + "小时";
            }
            if (ts.Minutes > 0)
            {
                dateDiff += ts.Minutes.ToString() + "分钟";
            }

            dateDiff += ts.Seconds.ToString() + "秒";
            return dateDiff;
        }


        private void timer1_Tick(object sender, EventArgs e)
        {
            ReciveDataSource.Clear();
            ReciveDataSource.Add(DateTime.Now.ToString());
            int sfp = FindProcess(sc.proServer);
            if (sfp == 0)
            {
                ReciveDataSource.Add("服务器程序运行正常");
            }
            else
            {
                ReciveDataSource.Add("服务器程序未运行");
                Thread.Sleep(2);
                StartProcess(sc.proServer);
                Thread.Sleep(20);
                ReciveDataSource.Add("服务器程序重启成功");
                string logStr = DateTime.Now.ToString("s") + "\t服务器程序" + sc.proServer.ProName + "重启";
                WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);
            }
            sfp = FindProcess(sc.proRecv);
            if (sfp == 0)
            {
                ReciveDataSource.Add("接收数据程序运行正常");
            }
            else
            {
                ReciveDataSource.Add("接收数据程序未运行");
                Thread.Sleep(2);
                StartProcess(sc.proRecv);
                Thread.Sleep(20);
                ReciveDataSource.Add("接收数据程序重启成功");
                string logStr = DateTime.Now.ToString("s") + "\t接收数据程序" + sc.proRecv.ProName + "重启";
                WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);
            }
            sfp = FindProcess(sc.proApms);
            if (sfp == 0)
            {
                ReciveDataSource.Add("自动识别程序运行正常");
            }
            else
            {
                ReciveDataSource.Add("自动识别程序未运行");
                Thread.Sleep(2);
                StartProcess(sc.proApms);
                Thread.Sleep(20);
                ReciveDataSource.Add("自动识别程序重启成功");
                string logStr = DateTime.Now.ToString("s") + "\t自动识别程序" + sc.proApms.ProName + "重启";
                WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);
            }
            sfp = FindProcess(sc.proMonitor);
            if (sfp == 0)
            {
                ReciveDataSource.Add("网页服务程序运行正常");
            }
            else
            {
                ReciveDataSource.Add("网页服务程序未运行");
                Thread.Sleep(2);
                StartProcess(sc.proMonitor);
                Thread.Sleep(20);
                ReciveDataSource.Add("网页服务程序重启成功");
                string logStr = DateTime.Now.ToString("s") + "\t网页服务程序" + sc.proMonitor.ProName + "重启";
                WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);
            }
            RunTime = "运行时间：" + DateDiff(DateTime.Now, StartTime);
            vpnStatus = vpn.CheckVpnStatus(sc.vpnInfo.VpnName);
            if (!vpnStatus)
            {
                vpn.ConnectVPN(sc.vpnInfo.VpnName, sc.vpnInfo.VpnUserName, sc.vpnInfo.VpnPsw);
                Thread.Sleep(1000);
                string logStr = DateTime.Now.ToString("s") + "\tVPN断开，重连";
                WriteSerLog(sc.vpnInfo.SystemLogPath + systemLogFileName, logStr);
            }
        }
        public void GetLocalIp()
        {
            ///获取本地的IP地址
            string AddressIP = string.Empty;
            foreach (IPAddress _IPAddress in Dns.GetHostEntry(Dns.GetHostName()).AddressList)
            {
                if (_IPAddress.AddressFamily.ToString() == "InterNetwork")
                {
                    AddressIP = _IPAddress.ToString();
                    if (AddressIP.Contains("172.16"))
                    {
                        sc.vpnInfo.VpnIP = AddressIP;
                    }
                }
            }
            //return AddressIP;
        }

      
        public void SetControlstatus()
        {
            vpnStatus = vpn.CheckVpnStatus(sc.vpnInfo.VpnName);
            if (vpnStatus)
            {
                //gbServerControl.Enabled = true;
              //  buttonConnectVPN.Enabled = false;

               // buttonDisconnectVPN.Enabled = true;
              //  labelVPNstatus.ForeColor = Color.Blue;
                VPNStatus = "VPN已连接";
                VpnIP = "本机IP：" + vpn.GetLocalIp();
            }
            else
            {
             //   gbServerControl.Enabled = false;
             //   buttonConnectVPN.Enabled = true;

              //  buttonDisconnectVPN.Enabled = false;
               // labelVPNstatus.ForeColor = Color.Red;
                VPNStatus = "VPN未连接";
            }
        }

        public void WriteSerLog(string fn, string logstr)
        {            
           if(!File.Exists(fn))
            {
                Directory.CreateDirectory(Path.GetDirectoryName(fn));           
            }
            StreamWriter sw = new StreamWriter(fn, true, Encoding.Default);
            sw.WriteLine(logstr);
            sw.Close();
        }
        #endregion
    }



}