parkMonitor_V2.0/PLCLinker/centralController/Monitor/Monitor.cs

using allInOneMachine;
using BroadcastModule;
using centralController.advert;
using centralController.WebServer;
using db;
using Monitor;
using MySql.Data.MySqlClient;
using NumMachine;
using parkMonitor.language;
using parkMonitor.LOG;
using parkMonitor.model;
using PLCS7;
using System;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using System.Management;
using System.Net;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace Monitor
{
    public class Monitor : IMonitor
    {
        /// <summary>
        /// 监控模块单例
        /// </summary>
        public static Monitor ins { get; set; }
        /// <summary>
        /// 中控系统总状态
        /// </summary>
        public static bool globalStatus = false;
        /// <summary>
        /// 初始化步骤
        /// </summary>
        public static int initializeState = 0;
        /// <summary>
        /// PLC对象句柄
        /// </summary>
        public static AbstractPLCLinker PLC = null;
        public static string plcIPAddr { get; set; }
        public static int plcRack { get; set; }
        public static int plcSlot { get; set; }
        public static string[] plcDatablockConfig { get; set; }
        public static int plcTerminalCount { get; set; }
        public static int plcParkingSpaceCount { get; set; }
        public static int plcRefreshInterval { get; set; }
        public static MainBlockStru mainBlockInfo { get; set; }
        public static List<ParkingSpaceStru> parkingSpaceInfo { get; set; }
        /// <summary>
        /// 远程数据库操作句柄
        /// </summary>
        public static DBOperation remoteDBOper;
        /// <summary>
        /// 本地数据库操作句柄
        /// </summary>
        public static DBOperation localDBOper;
        /// <summary>
        /// 显示板操作对象句柄
        /// </summary>
        public static BroadcastLinker allInOneMachine;
        public static string allInOneMachineIP { get; set; }
        public static int allInOneMachinePort { get; set; }
        /// <summary>
        /// 号牌机操作句柄
        /// </summary>
        public static NumMachineLinker numMachineLinker;
        public static IntPtr flpHandle;
        /// <summary>
        /// 本地web操作句柄
        /// </summary>
        public static IWebServer webServer;
        public static int webPort { get; set; }
        /// <summary>
        /// 广告路径
        /// </summary>
        public static string advertPath { get; set; }
        public static AdvertManager advertMgr;
        public static centralController.centralController mainWin { get; set; }
        public static string defaultLic{get;set;}
        /// <summary>
        /// 车库层数
        /// </summary>
        public static int floors { get; set; }
        /// <summary>
        /// 每层分块数
        /// </summary>
        public static int rows { get; set; }
        /// <summary>
        /// 每块车位数
        /// </summary>
        public static int spacesInRow { get; set; }

        /// <summary>
        /// 系统初始化器句柄
        /// </summary>
        internal static SystemInitializer sysInitializer;
        /// <summary>
        /// 系统关闭状态
        /// </summary>
        public static bool isClosing;
        /// <summary>
        /// 车库ID
        /// </summary>
        public static int garageID;
        /// <summary>
        /// PLC读取锁
        /// </summary>
        public static object PLCReadLock = new object();
        /// <summary>
        /// 是否初始化PLC数据更新次数的计数，重连PLC后初始化该值以刷新车位
        /// </summary>
        public static bool updateCount = false;
        /// <summary>
        /// 将显示在界面的提示字符串
        /// </summary>
        private static Queue<string> notificationQueue = new Queue<string>();
        private const int MAXLINES = 80;

        private void PLCUpdate()
        {
            int linkCount = 0;
            int count = 0;
            bool disconnected = false;
            while (!isClosing)
            {
                if (updateCount)
                {
                    count = 0;
                    updateCount = false;
                }
                if (count > 50)
                    count = 3;
                count++;
                if (PLC != null)
                {
                    if (PLC.isConnected)
                    {
                        if (disconnected) {disconnected = false; SetNotification("PLC已重新连接",TextColor.Info); }
                        linkCount = 0;
                        lock (PLCReadLock)
                        {
                            List<object> received = PLC.ReadFromPLC(PLCDataType.terminal, 0);
                            //首先获取所有终端信息
                            try
                            {
                                //终端总数相同
                                if (Terminal.Terminal.terminalInfo.Count == plcTerminalCount)
                                {
                                    for (int i = 0; i < plcTerminalCount; i++)
                                    {
                                        //一旦发现差异立刻更新
                                        if (!Terminal.Terminal.terminalInfo[i].Equals(received[i]))
                                        {
                                            Terminal.Terminal.terminalInfo[i] = (TerminalStru)received[i];
                                        }
                                    }
                                }
                                else
                                {
                                    //初始化终端信息列表
                                    Terminal.Terminal.terminalInfo.Clear();
                                    for (int i = 0; i < plcTerminalCount; i++)
                                    {
                                        Terminal.Terminal.terminalInfo.Add((TerminalStru)received[i]);
                                        if (!Terminal.Terminal.termCalcMap.ContainsKey(((TerminalStru)received[i]).terminalID))
                                            Terminal.Terminal.termCalcMap.Add(((TerminalStru)received[i]).terminalID, false);
                                        else
                                            Terminal.Terminal.termCalcMap[((TerminalStru)received[i]).terminalID] = false;
                                    }
                                }
                            }
                            catch (Exception ex) { Console.WriteLine("PLC监控终端数据," + ex.Message); }
                            //接下来获取中控监控信息
                            try
                            {
                                received = PLC.ReadFromPLC(PLCDataType.central, 0);
                                if (received.Count > 0 && !mainBlockInfo.Equals(received[0]))
                                {
                                    mainBlockInfo = (MainBlockStru)received[0];
                                }
                            }
                            catch (Exception ex) { Console.WriteLine("PLC监控中控数据," + ex.Message); }
                            //最后获得所有车位信息
                            if (count < 10 && count % 5 == 0)
                            {
                                try
                                {
                                    received = PLC.ReadFromPLC(PLCDataType.parkingSpace, 0);
                                    //Console.WriteLine(parkingSpaceInfo.Count+","+ plcParkingSpaceCount);
                                    //车位总数相同
                                    if (parkingSpaceInfo.Count == plcParkingSpaceCount)
                                    {
                                        for (int i = 0; i < plcParkingSpaceCount; i++)
                                        {
                                            //一旦发现差异立刻更新
                                            if (!parkingSpaceInfo[i].Equals(received[i]))
                                            {
                                                parkingSpaceInfo[i] = (ParkingSpaceStru)received[i];
                                            }
                                        }
                                    }
                                    else
                                    {
                                        parkingSpaceInfo.Clear();
                                        for (int i = 0; i < plcParkingSpaceCount; i++)
                                        {
                                            parkingSpaceInfo.Add((ParkingSpaceStru)received[i]);
                                        }
                                    }
                                }
                                catch (Exception ex) { Console.WriteLine("PLC监控车位数据," + ex.Message); }
                            }
                        }
                    }
                    else
                    {
                        linkCount += 1;
                        if (linkCount == 1)
                        {
                            disconnected = true;
                            SetNotification("PLC掉线，请检查连接",TextColor.Warning);
                        }else if (linkCount == 5)
                        {
                            Terminal.Terminal.terminalInfo.Clear();
                            parkingSpaceInfo.Clear();
                            mainBlockInfo = new MainBlockStru();
                        }
                    }
                }
                Thread.Sleep(300);
            }
        }

        /// <summary>
        /// CPU名
        /// </summary>
        /// <returns></returns>
        private static string getCPUName()
        {
            try
            {
                string str = string.Empty;
                ManagementClass mcCPU = new ManagementClass("Win32_Processor");
                ManagementObjectCollection mocCPU = mcCPU.GetInstances();
                foreach (ManagementObject m in mocCPU)
                {
                    string name = m["Name"].ToString();
                    return name;
                }
            }
            catch { }

            return "";
        }

        /// <summary>
        /// 操作系统版本
        /// </summary>
        private static string getOsVersion()
        {
            string str = "Windows 10";
            try
            {
                string hdId = string.Empty;
                ManagementClass hardDisk = new ManagementClass("Win32_OperatingSystem");
                ManagementObjectCollection hardDiskC = hardDisk.GetInstances();
                foreach (ManagementObject m in hardDiskC)
                {
                    str = m["Name"].ToString().Split('|')[0].Replace("Microsoft", "").Trim();
                    break;
                }
            }
            catch
            {

            }
            return str;
        }

        /// <summary>
        /// 显卡名
        /// </summary>
        private static string getGPUName()
        {
            string result = "";
            try
            {

                ManagementClass hardDisk = new ManagementClass("Win32_VideoController");
                ManagementObjectCollection hardDiskC = hardDisk.GetInstances();
                foreach (ManagementObject m in hardDiskC)
                {
                    result = m["VideoProcessor"].ToString();
                    break;
                }
            }
            catch
            {

            }
            return result;
        }

        /// <summary>
        /// 获取系统内存大小
        /// </summary>
        private static string getMenSize()
        {
            ManagementObjectSearcher searcher = new ManagementObjectSearcher();   //用于查询一些如系统信息的管理对象 
            searcher.Query = new SelectQuery("Win32_PhysicalMemory", "", new string[] { "Capacity" });//设置查询条件 
            ManagementObjectCollection collection = searcher.Get();   //获取内存容量 
            ManagementObjectCollection.ManagementObjectEnumerator em = collection.GetEnumerator();

            long capacity = 0;
            while (em.MoveNext())
            {
                ManagementBaseObject baseObj = em.Current;
                if (baseObj.Properties["Capacity"].Value != null)
                {
                    try
                    {
                        capacity += long.Parse(baseObj.Properties["Capacity"].Value.ToString());
                    }
                    catch
                    {
                        return "-GB";
                    }
                }
            }
            int gb = 1024 * 1024 * 1024;
            return ((double)capacity / gb).ToString("0.0") + "GB";
        }

        //************************************ 公有方法 **********************************
        public Monitor(centralController.centralController mainWin, IntPtr flpHandle)
        {
            Monitor.mainWin = mainWin;
            Monitor.flpHandle = flpHandle;
            parkingSpaceInfo = new List<ParkingSpaceStru>();
            mainBlockInfo = new MainBlockStru();
        }
        ///// <summary>
        ///// 获取提示信息
        ///// </summary>
        ///// <returns></returns>
        //public string GetNotification()
        //{
        //    StringBuilder notificationStr = new StringBuilder();
        //    lock (notificationQueue)
        //    {
        //        string[] strs = notificationQueue.ToArray();
        //        Array.Reverse(strs);
        //        for (int i = 0; i < strs.Length; i++)
        //        {
        //            notificationStr.Append(strs[i]);
        //        }
        //        //Queue<string>.Enumerator notiEnumer = notificationQueue.GetEnumerator();
        //        //while (notiEnumer.MoveNext())
        //        //{
        //        //    notificationStr.Append(notiEnumer.Current);
        //        //}
        //    }
        //    return notificationStr.ToString();
        //}
        /// <summary>
        /// 添加提示信息
        /// </summary>
        /// <param name="notification"></param>
        public static void SetNotification(string notification, TextColor textColor=TextColor.Log)
        {
            if (notification == "clear")
            {
                //lock (notificationQueue)
                //{
                //    notificationQueue.Clear();
                //}
                if (mainWin != null)
                {
                    mainWin.Invoke(new Action(() => {
                        mainWin.UpdateText(notification, textColor,MAXLINES);
                    }));
                }
                return;
            }
            else
            {
                string time = DateTime.Now + "\r\n";
                string notificationStr = time + notification + "\r\n";
                //lock (notificationQueue)
                //{
                //    int count = notificationQueue.Count;
                //    if (count >= MAXLINES)
                //    {
                //        notificationQueue.Dequeue();
                //    }
                //    notificationQueue.Enqueue(notificationStr);
                //}
                if (mainWin != null)
                {
                    mainWin.Invoke(new Action(() => {
                        mainWin.UpdateText(notificationStr, textColor, MAXLINES);
                    }));
                }
            }
            
        }
        /// <summary>
        /// 返回系统信息字符串
        /// </summary>
        /// <returns></returns>
        public static string GetSysInfo()
        {
            string info = "";
            Language lng = Language.ins;
            try
            {
                string endl = "\r\n";
                info += endl + lng.autoPackSys + " " + lng.centralPort + endl + endl;
                info += lng.version + "：" + SysConst.version() + endl + endl;

                info += lng.hostNmae + "：" + Dns.GetHostName() + endl + endl;
                info += lng.os + "：" + getOsVersion() + endl + endl;
                info += lng.cpu + "：" + getCPUName() + endl + endl;
                info += lng.mem + "：" + getMenSize() + endl + endl;
                info += lng.gpu + "：" + getGPUName() + endl + endl;
            }
            catch (Exception) { }
            return info;
        }
        /// <summary>
        /// 返回关于我们信息字符串
        /// </summary>
        /// <returns></returns>
        public static string GetAboutInfo()
        {
            return Language.ins.aboutWinText;
        }
        /// <summary>
        /// 返回停车记录信息
        /// </summary>
        /// <returns></returns>
        public static List<object[]> GetParkingRecords(string license = "", string startTime = "", string endTime = "")
        {
            DateTime now = DateTime.Now;
            List<object[]> result = new List<object[]>();
            string getParkingRecordsSql = "";
            if (startTime == "" || endTime == "")
            {
                DateTime yesterday = DateTime.Now - (new TimeSpan(1, 0, 0, 0));
                DateTime twoDaysAgo = DateTime.Now - (new TimeSpan(2, 0, 0, 0));
                getParkingRecordsSql = "select parkingRecordsID,userID,numberPlate,parkingSpaceID,realParkTime,realGetTime,receiptNum,parkingPrice,paymentStatus " +
                "from parkingrecords where numberPlate " + (license == "" ? "like '%" : "= '" + license) + "' and (realParkTime like '" + now.ToString("yyyy-MM-dd") + "%' or realParkTime like '" + yesterday.ToString("yyyy-MM-dd") + "%' or realParkTime like '" + twoDaysAgo.ToString("yyyy-MM-dd") + "%');";
            }
            else
            {
                getParkingRecordsSql = "select parkingRecordsID,userID,numberPlate,parkingSpaceID,realParkTime,realGetTime,receiptNum,parkingPrice,paymentStatus " +
                "from parkingrecords where numberPlate " + (license == "" ? "like '%" : "= '" + license) + "' and realParkTime >= '" + startTime + "' and realParkTime <= '" + endTime + "';";
            }
            if (localDBOper != null)
            {
                lock (localDBOper)
                {
                    MySqlDataReader reader = localDBOper.Query(getParkingRecordsSql);
                    try
                    {
                        while (reader != null && reader.Read())
                        {
                            if (reader.HasRows)
                            {
                                object[] temp = new object[reader.FieldCount];
                                reader.GetValues(temp);
                                result.Add(temp);
                            }
                        }
                    }
                    catch (Exception e) { Console.WriteLine(e.Message); }
                    try
                    {
                        if (reader != null)
                        {
                            reader.Close();
                            reader.Dispose();
                        }
                    }
                    catch (Exception e) { Console.WriteLine(e.Message); }
                }
            }
            result.Reverse();
            return result;
        }
        /// <summary>
        /// 返回预约记录信息
        /// </summary>
        /// <returns></returns>
        public static List<object[]> GetOrderRecords(bool localDB, string license="", string startTime = "", string endTime = "")
        {
            DateTime now = DateTime.Now;
            List<object[]> result = new List<object[]>();
            string getOrderRecordsSql = "";
            if (startTime == "" || endTime == "")
            {
                DateTime yesterday = DateTime.Now - (new TimeSpan(1, 0, 0, 0));
                DateTime twoDaysAgo = DateTime.Now - (new TimeSpan(2, 0, 0, 0));
                getOrderRecordsSql = "select orderRecordsID,userID,numberPlate,bookParkTime,cancelBookTime,bookFetchTime,bookHour,bookPrice,bookState " +
                "from orderrecords where numberPlate " + (license == "" ? "like '%" : "= '" + license) + "' and (bookParkTime like '" + now.ToString("yyyy-MM-dd") +
                "%' or bookParkTime like '" + yesterday.ToString("yyyy-MM-dd") + "%' or bookFetchTime like '" + now.ToString("yyyy-MM-dd") + "%' or bookFetchTime like '" + yesterday.ToString("yyyy-MM-dd") + "%');";
            }
            else
            {
                getOrderRecordsSql = "select orderRecordsID,userID,numberPlate,bookParkTime,cancelBookTime,bookFetchTime,bookHour,bookPrice,bookState " +
                "from orderrecords where numberPlate " + (license == "" ? "like '%" : "= '" + license) + "' and ((bookParkTime >= '" + startTime + "' and bookParkTime <= '" + endTime + "') or (bookFetchTime >= '" + startTime + "' and bookFetchTime <= '" + endTime + "'));";
            }
            if (localDBOper != null)
            {
                lock (localDBOper)
                {
                    MySqlDataReader reader;
                    if (localDB)
                        reader = localDBOper.Query(getOrderRecordsSql);
                    else
                        reader = remoteDBOper.Query(getOrderRecordsSql);
                    try
                    {
                        while (reader != null && reader.Read())
                        {
                            if (reader.HasRows)
                            {
                                object[] temp = new object[reader.FieldCount];
                                reader.GetValues(temp);
                                result.Add(temp);
                            }
                        }
                    }
                    catch (Exception e) { Console.WriteLine(e.Message); }
                    try
                    {
                        if (reader != null)
                        {
                            reader.Close();
                            reader.Dispose();
                        }
                    }
                    catch (Exception e) { Console.WriteLine(e.Message); }
                }
            }
            result.Reverse();
            return result;
        }
        /// <summary>
        /// 更新停车记录关于支付的信息
        /// </summary>
        /// <param name="license"></param>
        /// <param name="receiptNum"></param>
        /// <param name="parkingFee"></param>
        /// <param name="paymentStatus"></param>
        /// <returns></returns>
        public static bool UpdateParkingRecords(string license, string receiptNum, string parkingFee, string paymentStatus, bool local)
        {
            bool result = false;
            string updateRecordsSql = "update parkingrecords set parkingPrice = " + parkingFee + " ,paymentStatus = " + paymentStatus + " where numberPlate = '" + license + "' and receiptNum = " + receiptNum+";";
            List<string> updateList = new List<string>();
            updateList.Add(updateRecordsSql);
            if (local && localDBOper != null)
            {
                lock (localDBOper)
                {
                    try
                    {
                        result = localDBOper.UpdateTransaction(updateList);
                    }
                    catch { Log.WriteLog(LogType.database, "更新本地停车记录中支付信息出现异常。\n" + updateRecordsSql); return false; }
                }
            }else if(!local && remoteDBOper != null)
            {
                lock (remoteDBOper)
                {
                    try
                    {
                        result = remoteDBOper.UpdateTransaction(updateList);
                    }
                    catch { Log.WriteLog(LogType.database, "更新云端记录中支付信息出现异常。\n" + updateRecordsSql); return false; }
                }
            }
            return result;
        }
        /// <summary>
        /// 更新终端停车费用，便于车辆放行
        /// </summary>
        /// <returns></returns>
        public static bool UpdateTermFeeStatus(string receiptNum)
        {
            for (int i = 0; i < Terminal.Terminal.terminalInfo.Count; i++)
            {
                if(Terminal.Terminal.terminalInfo[i].receiptNum.ToString() == receiptNum)
                {
                    if(Terminal.Terminal.terminalInfo[i].terminalStatus==2 && Terminal.Terminal.terminalInfo[i].paymentStatus == 3)
                    {
                        TerminalStru tsFromCentral = new TerminalStru
                        {
                            terminalID = (short)Terminal.Terminal.terminalInfo[i].terminalID,
                            parkingFee = (short)-1,
                            receiptNum = -1,
                            paymentStatus = 3,
                        };
                        PLC.WriteToPLC(tsFromCentral, PLCDataType.central);
                        return true;
                    }
                    else
                    {
                        SetNotification((Terminal.Terminal.terminalInfo[i].terminalStatus == 1 ? "停车" : "非取车状态")+"终端，支付状态:"+ Terminal.Terminal.terminalInfo[i].paymentStatus+"，不进行修改",TextColor.Warning);
                        Log.WriteLog(LogType.process,LogFile.ERROR, (Terminal.Terminal.terminalInfo[i].terminalStatus == 1 ? "停车" : "非取车状态") + "终端，支付状态:" + Terminal.Terminal.terminalInfo[i].paymentStatus + "，不进行修改");
                        return false;
                    }
                }
            }
            SetNotification("未找到待修改终端", TextColor.Warning);
            Log.WriteLog(LogType.process, LogFile.ERROR, "未找到待修改终端");
            return false;
        }

        /// <summary>
        /// 返回空闲正常车位数
        /// </summary>
        /// <param name="state">状态：0.空闲与保留，1.空闲，2.保留，3.预约车位总数</param>
        /// <returns></returns>
        public int GetFreeSpaceCount(int state)
        {
            int freeSpaceCount = 0;
            int bookableSpaceCount = 0;
            int bookedSpaceCount = 0;
            if(state == 3)
            {
                return mainBlockInfo.reserveTotalSpace;
            }
            try
            {
                if (parkingSpaceInfo != null)
                {
                    foreach (ParkingSpaceStru psStru in parkingSpaceInfo)
                    {
                        if (psStru.spaceStatus == 3)
                            bookedSpaceCount++;
                        if (psStru.spaceStatus != 1 && psStru.spaceStatus != 3)
                        {
                            freeSpaceCount++;
                            if (psStru.spaceStatus == 2)
                                bookableSpaceCount++;
                        }
                    }
                }
            }
            catch { Console.WriteLine("空闲车位数，计数异常");return 0; }
            switch (state)
            {
                case 0:
                    return freeSpaceCount;//0+2
                case 1:
                    return freeSpaceCount - bookableSpaceCount;//0
                case 2:
                    return bookableSpaceCount;//2
                case 4:
                    return bookedSpaceCount + bookableSpaceCount;//2+3
                default:
                    return freeSpaceCount;
            }
        }
        /// <summary>
        /// 暂未使用，查询本地数据库返回可预约车位数
        /// </summary>
        /// <returns></returns>
        //public int GetBookableSpaceCount()
        //{
        //    int bookableSpaceCount = 0;
        //    string bookableSpaceSql = "select currentBookableSpace from garageproperties where garageID = " + garageID + ";";
        //    if (localDBOper != null)
        //    {
        //        MySqlDataReader reader = localDBOper.Query(bookableSpaceSql);
        //        if (reader != null)
        //        {
        //            try
        //            {
        //                if (reader.Read() && reader.HasRows)
        //                {
        //                    bookableSpaceCount = reader.GetInt32("currentBookableSpace");
        //                }
        //            }
        //            catch { }
        //            try
        //            {
        //                reader.Close();
        //                reader.Dispose();
        //            }
        //            catch { }
        //        }
        //    }
        //    return bookableSpaceCount;
        //}
        /// <summary>
        /// 系统初始化，启动plc监控
        /// </summary>
        public void Start()
        {
            if (flpHandle != IntPtr.Zero)
            {
                //初始化系统
                if (sysInitializer == null)
                {
                    sysInitializer = new SystemInitializer();
                }
                Task.Factory.StartNew(() =>
                {
                    sysInitializer.Init(flpHandle);
                });

                //更新PLC数据
                Thread PLCUpdateThread = new Thread(PLCUpdate);
                PLCUpdateThread.Start();
                //System.Windows.Forms.Timer PLCUpdateTimer = new System.Windows.Forms.Timer();
                //PLCUpdateTimer.Interval = 300;
                //PLCUpdateTimer.Tick += new EventHandler(PLCUpdate);
                //PLCUpdateTimer.Start();
            }
        }
        /// <summary>
        /// 系统停止
        /// </summary>
        public void Stop()
        {
            sysInitializer.Stop();
            System.Environment.Exit(0);
        }
    }

    //public class ParkingRecord
    //{
    //    int parkingRecordsID;
    //    int userID;
    //    string numberPlate;
    //    int parkingSpaceID;
    //}
}