mes-client/UAS_DeviceMonitor/Main.cs

using System;
using DevExpress.XtraBars;
using UAS_DeviceMonitor.DataOperate;
using System.Data;
using System.Text;
using UAS_DeviceMonitor.Entity;
using UAS_DeviceMonitor.PublicMethod;
using DevExpress.XtraGrid.Views.Grid;
using System.Collections.Generic;
using System.Drawing;
using DevExpress.XtraBars.Ribbon;
using System.Threading;

namespace UAS_DeviceMonitor
{
    public partial class Main : RibbonForm
    {

        StringBuilder sql = new StringBuilder();
        DataHelper dh;
        ModeBusTCPServer mbt = new ModeBusTCPServer();

        #region 初始化代码
        public Main()
        {
            dh = new DataHelper();
            SystemInf.dh = dh;
            InitializeComponent();
            dpc_enableCheckEdit.QueryCheckStateByValue += CheckedEdit_QueryCheckStateByValue;
            CommandSetRepositoryItemComboBox1.ParseEditValue += CommandSetRepositoryItemComboBox1_ParseEditValue;
            CheckEditCommandSet.QueryCheckStateByValue += CheckedEdit_QueryCheckStateByValue;
            PollSettingItemSearchLookUpEdit.ParseEditValue += PollSettingItemSearchLookUpEdit_ParseEditValue;
            GridViewPollSetting.RowCellStyle += GridViewPollSetting_RowCellStyle;
            #region 添加发送接收编码规则的静态值
            ComboBoxData cbd = new ComboBoxData();
            cbd.Text = "UTF-8";
            cbd.Value = "UTF-8";
            ComboBoxData cbd1 = new ComboBoxData();
            cbd1.Text = "Hexadecimal";
            cbd1.Value = "Hexadecimal";
            ComboBoxData cbd2 = new ComboBoxData();
            cbd2.Text = "ASCII";
            cbd2.Value = "ASCII";
            CommandSetRepositoryItemComboBox1.Items.Add(cbd);
            CommandSetRepositoryItemComboBox1.Items.Add(cbd1);
            CommandSetRepositoryItemComboBox1.Items.Add(cbd2);
            #endregion
        }

        private void CommandSetRepositoryItemComboBox1_ParseEditValue(object sender, DevExpress.XtraEditors.Controls.ConvertEditValueEventArgs e)
        {
            string val = "";
            if (e.Value != null)
            {
                val = e.Value.ToString();
            }
            else
            {
                val = "FALSE";//默认为不选   
            }
            e.Value = val;
            e.Handled = true;
        }

        private void PollSettingItemSearchLookUpEdit_ParseEditValue(object sender, DevExpress.XtraEditors.Controls.ConvertEditValueEventArgs e)
        {
            e.Handled = true;
        }

        private void Main_Load(object sender, EventArgs e)
        {
            //设备列表
            GridDeviceList.GetDataSQL = "select de_id,de_code,de_name,de_spec,de_indate,de_runstatus,de_address,de_wccode,de_vendcode,de_vendname from device".ToUpper();
            ToolPageControlDeviceList.Gridcontrol = GridDeviceList;
            //轮询业务
            //GridPolling.GetDataSQL = "select 0 CHECKEDCOLUMN,pl_id,pl_code,pl_name,pl_type,pl_dccode,pl_remark from polling".ToUpper();
            //GridPolling.ID = "pl_id";
            //GridPolling.TableName = "polling";
            //GridPolling.InsertSQL = "insert into polling(pl_id,pl_code,pl_name,pl_type,pl_dccode,pl_remark) values(polling_seq.nextval,:pl_code,:pl_name,:pl_type,:pl_dccode,:pl_remark)";
            //ButtonDeletePolling.Grid = GridPolling;
            //ButtonSavePolling.Grid = GridPolling;
            //ButtonAddPolling.Grid = GridPolling;
            //轮询配置界面
            GridPollingSetting.GetDataSQL = "SELECT '' POLLSETTINGSTATUSCOLUMN,0 CHECKEDCOLUMN,DPC_ID,DPC_DECODE ,DPC_INTERVAL ,DPC_DCCODE ,DPC_FUNCTION , nvl(DPC_ENABLE,0)DPC_ENABLE,DPC_STATUS ,DPC_REMARK FROM DEVICEPOLLINGCONFIG ORDER BY DPC_ID";
            GridPollingSetting.ID = "DPC_ID";
            GridPollingSetting.TableName = "DEVICEPOLLINGCONFIG";
            GridPollingSetting.InsertSQL = "insert into DEVICEPOLLINGCONFIG(DPC_ID,DPC_DECODE ,DPC_INTERVAL ,DPC_DCCODE ,DPC_FUNCTION , DPC_ENABLE,DPC_STATUS ,DPC_REMARK) values(DEVICEPOLLINGCONFIG_seq.nextval,:DPC_DECODE  ,:DPC_INTERVAL ,:DPC_DCCODE ,:DPC_FUNCTION , :DPC_ENABLE,:DPC_STATUS ,:DPC_REMARK)";

            ButtonSaveCommandSet.Grid = GridPollingSetting;
            ButtonNewCommandSet.Grid = GridPollingSetting;
            ButtonDeleteCommandSet.Grid = GridPollingSetting;

            //指令设置界面
            GridCommandSetting.GetDataSQL = "select 0 CHECKEDCOLUMN,dc_id,dc_code,dc_name,dc_value,dc_sendcoding,dc_receivecoding from devicecommand ".ToUpper();
            GridCommandSetting.TableName = "devicecommand";
            GridCommandSetting.ID = "dc_id";
            GridCommandSetting.InsertSQL = "insert into devicecommand(dc_id,dc_code,dc_name,dc_value,dc_debrand,dc_sendcoding,dc_receivecoding) values(devicecommand_seq.nextval,:dc_code,:dc_name,:dc_value,'" + BaseUtil.GetComboxEditValue(Brand) + "',:dc_sendcoding,:dc_receivecoding)";
            ButtonSaveCommand.Grid = GridCommandSetting;
            ButtonDeleteCommand.Grid = GridCommandSetting;
            ButtonNewCommand.Grid = GridCommandSetting;

            //设备联网配置界面
            GridDeviceNetSetting.GetDataSQL = "SELECT 0 CHECKEDCOLUMN,DNC_ID,DNC_DECODE,DNC_GATEWAY,DNC_UPPERIP,DNC_PORT,DNC_MAC,DNC_IP,DNC_TYPE FROM DEVICENETCONFIG order by DNC_ID";
            GridDeviceNetSetting.ID = "dnc_id";
            GridDeviceNetSetting.TableName = "DEVICENETCONFIG";
            GridDeviceNetSetting.InsertSQL = "insert into DEVICENETCONFIG(DNC_ID,DNC_DECODE,DNC_GATEWAY,DNC_UPPERIP,DNC_PORT,DNC_MAC,DNC_IP,DNC_TYPE) values(DEVICENETCONFIG_SEQ.NEXTVAL,:DNC_DECODE,:DNC_GATEWAY,:DNC_UPPERIP,:DNC_PORT,:DNC_MAC,:DNC_IP,:DNC_TYPE)";
            ButtonDeleteNetConfig.Grid = GridDeviceNetSetting;
            ButtonAddNetConfig.Grid = GridDeviceNetSetting;
            ButtonSaveNetConfig.Grid = GridDeviceNetSetting;

            Ptime = new Dictionary<int, PollingTimer>();
        }
        #endregion

        #region 界面通用事件
        /// <summary>
        /// 选项卡切换不同XPage
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void ButtonItem_ItemClick(object sender, ItemClickEventArgs e)
        {
            HideXPage(e.Item.Tag.ToString());
        }

        /// <summary>
        /// 根据点击按钮的Tag显示对应的XPage
        /// </summary>
        /// <param name="PageName"></param>
        private void HideXPage(string PageName)
        {
            for (int i = 0; i < MainTabControl.TabPages.Count; i++)
            {
                if (MainTabControl.TabPages[i].Name == PageName)
                    MainTabControl.TabPages[i].PageVisible = true;
                else
                    MainTabControl.TabPages[i].PageVisible = false;
            }
        }

        /// <summary>
        /// 勾选Grid的CheckBox
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void CheckedEdit_QueryCheckStateByValue(object sender, DevExpress.XtraEditors.Controls.QueryCheckStateByValueEventArgs e)
        {
            string val = "";
            if (e.Value != null)
            {
                val = e.Value.ToString();
            }
            else
            {
                val = "FALSE";//默认为不选   
            }
            switch (val.ToUpper())
            {
                case "TRUE":
                case "YES":
                case "1":
                    e.CheckState = System.Windows.Forms.CheckState.Checked;
                    break;
                case "FALSE":
                case "NO":
                case "0":
                    e.CheckState = System.Windows.Forms.CheckState.Unchecked;
                    break;
                default:
                    e.CheckState = System.Windows.Forms.CheckState.Checked;
                    break;
            }
            e.Handled = true;
        }
        #endregion

        #region PageCommandSet业务代码(指令设置)
        /// <summary>
        /// 判断指令编号不能重复
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void ButtonSaveCommand_Click(object sender, EventArgs e)
        {
            GridCommandSetting.InsertSQL = "insert into devicecommand(dc_id,dc_code,dc_name,dc_value,dc_debrand,dc_sendcoding,dc_receivecoding) values(devicecommand_seq.nextval,:dc_code,:dc_name,:dc_value,'" + BaseUtil.GetComboxEditValue(Brand) + "',:dc_sendcoding,:dc_receivecoding)";
            ButtonSaveCommand.DoSave();
        }

        /// <summary>
        /// 加载ComBox品牌数据
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void PageCommandSet_VisibleChanged(object sender, EventArgs e)
        {
            if (PageCommandSet.PageVisible)
            {
                DataTable dt = (DataTable)SystemInf.dh.ExecuteSql("select * from devicebrand", "select");
                BaseUtil.FillComBoxEditWidthDataTable(Brand, "db_name", "db_code", dt);
                GridCommandSetting.Condition = " where dc_debrand='" + BaseUtil.GetComboxEditValue(Brand) + "' order by dc_id";
            }
        }

        private void Brand_SelectedIndexChanged(object sender, EventArgs e)
        {
            GridCommandSetting.Condition = " where dc_debrand='" + BaseUtil.GetComboxEditValue(Brand) + "'";
            GridCommandSetting.RefreshData();
        }

        #endregion

        #region PagePollingSetting业务代码(轮询配置)

        PollingTask pt = new PollingTask();
        /// <summary>
        /// 绘制轮询配置状态栏
        /// </summary>
        List<int> PollSettingPaintRowIndex = new List<int>();

        private void ButtonStartPolling_Click(object sender, EventArgs e)
        {
            GridView grid = GridViewPollSetting;
            mbt.Open();
            for (int i = 0; i < GridPollingSetting.RowCount; i++)
            {
                Polling pl = new Polling();
                pl.Id = int.Parse(GridViewPollSetting.GetRowCellValue(i, "DPC_ID").ToString());
                pl.DeviceCode = GridViewPollSetting.GetRowCellValue(i, "DPC_DECODE").ToString();
                pl.CommandCode = GridViewPollSetting.GetRowCellValue(i, "DPC_DCCODE").ToString();
                pl.Interval = int.Parse(GridViewPollSetting.GetRowCellValue(i, "DPC_INTERVAL").ToString());
                pl.SendRadix = GridViewPollSetting.GetRowCellValue(i, "DPC_INTERVAL").ToString();
                pl.Enable = GridViewPollSetting.GetRowCellValue(i, "DPC_ENABLE").ToString() != "0";
                pl.Dh = new DataHelper();
                if (pl.Enable)
                {
                    pt.AddTask(RunTask, pl);
                    //添加到状态为运行的行
                    PollSettingPaintRowIndex.Add(i);
                    GridPollingSetting.Focus();
                }
            }
        }

        /// <summary>
        /// 绘制轮询状态
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void GridViewPollSetting_RowCellStyle(object sender, RowCellStyleEventArgs e)
        {
            if (e.Column.Name.ToUpper() == "POLLSETTINGSTATUSCOLUMN" && PollSettingPaintRowIndex.Contains(e.RowHandle))
            {
                e.Appearance.BackColor = Color.Green;
            }
        }

        Dictionary<int, PollingTimer> Ptime;

        private void RunTask(object i)
        {
            PollingTimer timer = new PollingTimer();
            Polling pl = (Polling)i;
            timer.Polling = i;
            timer.Interval = pl.Interval * 5000;
            timer.Elapsed += Timer_Tick;
            timer.Start();
            try
            {
                if (!Ptime.ContainsKey(pl.Id))
                    Ptime.Add(pl.Id, timer);
            }
            catch (Exception)
            {
                if (!Ptime.ContainsKey(pl.Id))
                    Ptime.Add(pl.Id, timer);
            }
        }

        /// <summary>
        /// 轮询执行的业务
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Timer_Tick(object sender, EventArgs e)
        {
            PollingTimer timer = (PollingTimer)sender;
            Polling pl = (Polling)timer.Polling;
            DataHelper dh = pl.Dh;
            string Decode = pl.DeviceCode;
            string Dccode = pl.CommandCode;
            DataTable dt = (DataTable)dh.ExecuteSql("select dnc_ip,dnc_port from DEVICENETCONFIG where dnc_decode='" + Decode + "'", "select");
            DataTable dt1 = (DataTable)dh.ExecuteSql("select dc_sendcoding,dc_value from devicecommand where dc_code='" + Dccode + "'", "select");
            if (dt.Rows.Count > 0)
            {
                string IP = dt.Rows[0]["dnc_ip"].ToString() + ":" + dt.Rows[0]["dnc_port"].ToString();
                string Coding = "";
                string Command = "";
                if (dt1.Rows.Count > 0)
                {
                    Coding = dt1.Rows[0]["dc_sendcoding"].ToString();
                    Command = dt1.Rows[0]["dc_value"].ToString();
                }
                mbt.Send(IP, Coding, Command);
                Thread.Sleep(5000);
                Console.WriteLine(IP);
                Console.WriteLine(mbt.Returnvalue);
            }
        }

        /// <summary>
        /// 停止全部轮询
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void ButtonPausePolling_Click(object sender, EventArgs e)
        {
            foreach (var item in Ptime)
            {
                item.Value.Stop();
            }
            PollSettingPaintRowIndex.Clear();
            GridPollingSetting.Focus();
            Ptime.Clear();
        }

        private void GridViewPollSetting_CellValueChanging(object sender, DevExpress.XtraGrid.Views.Base.CellValueChangedEventArgs e)
        {
            GridViewPollSetting.SetRowCellValue(e.RowHandle, e.Column, e.Value);
            if (e.Column.Name.ToUpper() == "DPC_ENABLE")
            {
                if (GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ENABLE").ToString() == "0")
                {
                    int id = int.Parse(GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ID").ToString());
                    if (Ptime.ContainsKey(id))
                    {
                        Ptime[id].Stop();
                        Ptime.Remove(id);
                        PollSettingPaintRowIndex.Remove(e.RowHandle);
                    }
                }
                else
                {
                    Polling pl = new Polling();
                    pl.Id = int.Parse(GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ID").ToString());
                    pl.DeviceCode = GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_DECODE").ToString();
                    pl.Interval = int.Parse(GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_INTERVAL").ToString());
                    pl.Enable = GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ENABLE").ToString() != "0";
                    if (pl.Enable)
                        pt.AddTask(RunTask, pl);
                    PollSettingPaintRowIndex.Add(e.RowHandle);
                }
            }
            ////选择业务方案时带出指令编号
            //if (e.Column.FieldName == "DPC_PLCODE")
            //{
            //    string pqf01 = e.Value.ToString();
            //    DataTable dt = (DataTable)PollSettingItemSearchLookUpEdit.DataSource;
            //    DataRow[] rows = dt.Select(string.Format("PL_CODE='{0}'", pqf01));
            //    if (rows != null && rows.Length > 0)
            //    {
            //        DataRow row = rows[0];
            //        GridViewPollSetting.SetRowCellValue(e.RowHandle, "DPC_DCCODE", row["PL_DCCODE"].ToString());
            //        GridViewPollSetting.SetRowCellValue(e.RowHandle, "DPC_PLNAME", row["PL_NAME"].ToString());
            //    }
            //}
        }

        /// <summary>
        /// 设置GridView多选放大镜
        /// </summary>
        /// <param name="sender"></param> 
        /// <param name="e"></param>
        private void PagePollingSetting_VisibleChanged(object sender, EventArgs e)
        {
            if (PagePollingSetting.PageVisible)
            {
                DataTable dt = (DataTable)SystemInf.dh.ExecuteSql("SELECT DC_CODE,DC_NAME,DC_REMARK FROM DEVICECOMMAND", "select");
                PollSettingItemSearchLookUpEdit.DataSource = dt;
                PollSettingItemSearchLookUpEdit.DisplayMember = "DC_CODE";
                PollSettingItemSearchLookUpEdit.ValueMember = "DC_CODE";
            }
        }
        #endregion

        #region 设备查看界面
        private void PageDeviceStatus_VisibleChanged(object sender, EventArgs e)
        {
            if (PageDeviceStatus.PageVisible)
            {
                //清除之前添加的图像
                for (int i = 0; i < GalleryDeviceStatus.Gallery.Groups.Count; i++)
                {
                    GalleryDeviceStatus.Gallery.Groups[i].Items.Clear();
                }
                DataTable dt = (DataTable)dh.ExecuteSql("select * from device left join DEVICEPOLLINGCONFIG on dpc_decode=de_code ", "select");
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    GalleryItem gallery;
                    if (dt.Rows[i]["dpc_status"].ToString() == "")
                    {
                        gallery = new GalleryItem(Properties.Resources.devicecontrol, dt.Rows[i]["de_name"].ToString(), dt.Rows[i]["de_code"].ToString());
                    }
                    else
                    {
                        gallery = new GalleryItem(Properties.Resources.close_24px_1069872_easyicon_net, dt.Rows[i]["de_name"].ToString(), dt.Rows[i]["de_code"].ToString());
                    }
                    GalleryDeviceStatus.Gallery.Groups[0].Items.Add(gallery);
                }
            }
        }
        #endregion
    }
}