CNAS/CNAS_RunSync/ucSyncShow.cs

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Drawing;
using System.Data;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using Newtonsoft.Json;
using CnasSynchronusClient;
using CNAS_DBSync;
using System.Configuration;
using CnasSynchrousModel;
using CnasSynchronousCommon;

namespace CNAS_RunSync
{
    public partial class ucSyncShow : UserControl
    {
        private string delayDays= FileOperation.GetSystemFormatConfigData().ShowDelayDays;
        private SyncInstrumentItemInfo syncInstrumentItem = new SyncInstrumentItemInfo();
        //private Dictionary<string, DataTable> dictSourceTables = new Dictionary<string, DataTable>();
        private DataTable dtSource = new DataTable();       //当前显示数据源
        private Dictionary<string, DataRow> dictSource = new Dictionary<string, DataRow>();
        private Dictionary<string, Type> DictComboBox = new Dictionary<string, Type>();   //ComboBox数据源
        private List<string> lstIntOrDouble = new List<string>() {"等于","不等于","大于","小于","不大于","不小于" };
        private List<string> lstText = new List<string>() { "等于", "不等于", "包含", "不包含"};
        private Color FinedBackColor = Color.LightCyan;   //查询后选中项
        Dictionary<string, string> DictField = new Dictionary<string, string>();

        //需要存在一个仪器才能正常显示数据
        public ucSyncShow(SyncInstrumentItemInfo syncInstrumentItem)
        {
            InitializeComponent();

            dgvSyncData.AutoGenerateColumns = false;
            dgvSyncData.RowHeadersVisible = false;

            this.syncInstrumentItem = syncInstrumentItem;
        }

        private void ucSyncShow_Load(object sender, EventArgs e)
        {
            BindData();
        }

        /// <summary>
        /// 绑定数据
        /// </summary>
        private void BindData()
        {
            if (this.syncInstrumentItem == null) return;

            this.lblTitle.Text = string.Format("当前仪器：【{0}】", syncInstrumentItem.Code);

            if (syncInstrumentItem.LstSyncPramas == null) return;
            if (syncInstrumentItem.SyncInstrumentDSInfo == null) return;
            //if (syncInstrumentItem.SyncInstrumentDSInfo.Path == null) return;
            if (syncInstrumentItem.SyncInstrumentDSInfo.InstrumentDataSourceType == DataSourceType.None) return;

            //清空现有绑定
            DictComboBox.Clear();
            dictSource.Clear();

            //加载相关数据
            //1.1根据仪器类型加载本地存储的中英文字段说明映射
            if (syncInstrumentItem.LstSyncPramas.Count > 0)
            {
                InstrumentDescribeZH describeZH = new InstrumentDescribeZH(syncInstrumentItem.InstruType, syncInstrumentItem.LstSyncPramas[0].SourceTable);
                describeZH.GetFieldDescribe();
                DictField = describeZH.DictField;
            }

            //2.datagridview中绑定数据（绑定的是从数据源中读取的数据）
            //2.1 根据映射表，创建datagridviewcolumn/和绑定数据列
            if (syncInstrumentItem.LstSyncPramas.Count <= 0) return;
            foreach (var item in syncInstrumentItem.LstSyncPramas)
            {
                string strColumnName = item.SourceField;
                if (DictField.ContainsKey(strColumnName))
                    strColumnName = DictField[strColumnName];
                AddDatagridColumn(dgvSyncData, item.SourceField, strColumnName, 100);
            }
            AddDatagridColumn(dgvSyncData, "GridGuid", "GridGuid", 100, false);

            //2.2 获取数据源数据，构建datagridviewcell
            //2.2.1 获取数据源数据
            var query = syncInstrumentItem.LstSyncPramas.Where(s => s.IfDateField == true).ToList<SyncParamasInfo>();
            if (query.Count == 1)
            {
                object[] obj = new object[]
                    {
                        syncInstrumentItem.LstSyncPramas[0].SourceTable,
                        query[0].SourceField,
                        DateTime.Now.AddDays(Convert.ToInt32(delayDays)).ToString("yyyy-MM-dd HH:mm:ss")
            };
                InstrumentData instrumentData = InstrumentDataFact.CreateInstrumentDataSource(syncInstrumentItem.SyncInstrumentDSInfo, obj);
                dtSource = instrumentData.GetInstrumentDataByDate();
            }

            //2.2.2 构建datagridviewcell
            foreach (DataRow dr in dtSource.Rows)
            {
                DataGridViewRow dataGridViewRow = new DataGridViewRow();
                foreach (DataGridViewColumn dataGridViewColumn in dgvSyncData.Columns)
                {
                    if (dtSource.Columns.Contains(dataGridViewColumn.Name))
                        AddDataTextCell(dataGridViewRow, dataGridViewColumn, dr);
                }
                //添加GUID值
                string strGuid = Guid.NewGuid().ToString();
                DataGridViewTextBoxCell txtCell = new DataGridViewTextBoxCell
                {
                    Value = strGuid
                };
                dataGridViewRow.Cells.Add(txtCell);

                dgvSyncData.Rows.Add(dataGridViewRow);

                dictSource.Add(strGuid, dr);
            }

            //3.初始化查询相关内容
            //3.1 绑定Combobox数据源        
            foreach (DataColumn dc in dtSource.Columns)
            {
                if (syncInstrumentItem.LstSyncPramas.Where(s => s.SourceField == dc.ColumnName.ToUpper()).LongCount<SyncParamasInfo>() > 0)
                {
                    string strColumnName = dc.ColumnName.ToUpper();
                    if (DictField.ContainsKey(strColumnName))
                        strColumnName = DictField[strColumnName];
                    DictComboBox.Add(strColumnName, dc.DataType);
                }
            }
            if (DictComboBox.Count > 0)
            {
                BindingSource bsComboBox = new BindingSource
                {
                    DataSource = DictComboBox
                };
                cmbColumns.DataSource = bsComboBox;
                cmbColumns.ValueMember = "Key";
                cmbColumns.DisplayMember = "Key";
            }
        }

        /// <summary>
        /// 添加datagridview的列
        /// </summary>
        /// <param name="dgvShow"></param>
        /// <param name="strColumnName"></param>
        /// <param name="strColumnHeaderText"></param>
        /// <param name="Width"></param>
        /// <param name="bVisible"></param>
        private void AddDatagridColumn(DataGridView dgvShow,string strColumnName,string strColumnHeaderText,int Width,bool bVisible=true)
        {
            DataGridViewColumn Column = new DataGridViewColumn()
            {
                Name = strColumnName,
                HeaderText = strColumnHeaderText,
                Width = Width,
                Visible = bVisible,
                CellTemplate = new DataGridViewTextBoxCell()
             };
            //设置文本对齐方式
            Column.DefaultCellStyle.Alignment = DataGridViewContentAlignment.MiddleCenter;
            //设置该列背景颜色
            dgvShow.Columns.Add(Column);
        }

        /// <summary>
        /// 添加datagridview的单元格
        /// </summary>
        /// <param name="dataGridViewRow"></param>
        /// <param name="dataGridViewColumn"></param>
        /// <param name="dr"></param>
        private void AddDataTextCell(DataGridViewRow dataGridViewRow, DataGridViewColumn dataGridViewColumn,DataRow dr)
        {
            DataGridViewTextBoxCell txtCell = new DataGridViewTextBoxCell();
            txtCell.Value = Convert.ToString(dr[dataGridViewColumn.Name]);
            dataGridViewRow.Cells.Add(txtCell);
        }

        private void btnRunData_Click(object sender, EventArgs e)
        {
            //组织上传数据
            if (dgvSyncData.Columns.Count <= 0) return;

            DataTable dtReadySource = dtSource.Clone();
            GetUpLoadData(ref dtReadySource);
            if (dtReadySource.Rows.Count <= 0)
                MessageBox.Show("未能获得上传数据，请查询筛选后重试！");

            //执行上传
            RunUpLoad(dtReadySource);
        }

        /// <summary>
        /// 获取上传数据
        /// </summary>
        /// <param name="dtReadySource">准备上传的数据</param>
        private void GetUpLoadData(ref DataTable dtReadySource)
        {
            foreach (DataGridViewRow dgvRow in dgvSyncData.Rows)
            {
                if (dgvRow.DefaultCellStyle.BackColor == FinedBackColor)
                {
                    string strGuid = dgvRow.Cells["GridGuid"].Value.ToString();
                    if (!dictSource.ContainsKey(strGuid)) continue;
                    DataRow dr = dictSource[strGuid];

                    DataRow drReady = dtReadySource.NewRow();
                    foreach (DataColumn dc in dtReadySource.Columns)
                    {
                        if (dr.Table.Columns.Contains(dc.ColumnName))
                            drReady[dc.ColumnName] = dr[dc.ColumnName];
                    }
                    dtReadySource.Rows.Add(drReady);
                }
            }
        }

        private void RunUpLoad(DataTable dtReadySource)
        {
            //根据映射字段获取准备上传的所有数据
            if (dtReadySource == null || dtReadySource.Rows.Count <= 0) return;

            //构建准备插入的数据
            DataTable dtTarget = CnasDataOperationFact.CnasDataOperation().GetCNASTablesStruct(syncInstrumentItem.LstSyncPramas[0].TargetTable, syncInstrumentItem.SyncTargetDBInfo);
            if (dtTarget.Columns.Count <= 0)
            {
                MessageBox.Show("未能成功读取CNAS数据库列，请检查数据库配置。");
                return;
            }

            //创建插入操作类
            CnasInsertOperation insertOperation = new CnasInsertOperation{syncInstrumentItem = syncInstrumentItem};

            //逐行插入数据到内存表
            string strErrorMsg = insertOperation.CreateInputData(dtReadySource,ref dtTarget);
            if (strErrorMsg != "")
            {
                MessageBox.Show(strErrorMsg);
                return;
            }
            if (dtTarget.Rows.Count <= 0)
            {
                MessageBox.Show("未能获取到符合要求的数据，请检查配置或联系管理员。");
                return;
            } 

            //检查数据合法性
             insertOperation.CheckInsertDataFormat(dtTarget, ref strErrorMsg);
            if (strErrorMsg != "")
            {
                MessageBox.Show(strErrorMsg);
                return;
            }

            //逐行执行插入内存表数据到数据库中
            int ErrorCount = 0;
            int SuccessCount = 0;
            int OtherCount = 0;
            List<DataRow> lstError = new List<DataRow>();            
            foreach (DataRow dr in dtTarget.Rows)
            {
                dr.AcceptChanges();
                int iReturn = CnasDataOperationFact.CnasDataOperation().InsertDataToCNASTable(GlobalCommonOperation.ConvertDataRowToTable(dr), syncInstrumentItem.SyncTargetDBInfo,syncInstrumentItem.LstSyncPramas, syncInstrumentItem.CnasInstrumentColumn,syncInstrumentItem.lstFixedValue);
                if (iReturn <= 0)  //此时出现问题
                {
                    if (iReturn == -1)
                    {
                        AppLog.ServiceInfo("数据库连接中断，终止本次上传。");
                        break;   //此时数据库连接中断，直接跳出循环，结束本次数据同步传输
                    }
                    else if (iReturn == -2)  //等于-2表示插入准备更新时发现数据一致，不再执行
                    {
                        OtherCount++;
                    }
                    else
                    {
                        ErrorCount++;
                        /*需要转换一下，否则会将整个dt全部写入日志*/
                        lstError.Add(GlobalCommonOperation.ConvertDataRowToTable(dr).Rows[0]);
                    }
                }
                else
                {
                    SuccessCount++;
                }
            }

            ////判断返回结果
            //if (lstError.Count <= 0)
            //{
            //    MessageBox.Show("上传完成！");
            //}
            //else
            //{
            //    AppLog.Error($"未成功上传的数据如下：{TransConvert.ListToString(lstError)}");
            //    MessageBox.Show("上传过程中发生异常，存在部分数据未成功上传，请联系管理员！");
            //}
            MessageBox.Show( $"上传操作完成！其中成功{SuccessCount}条，失败{ErrorCount}条，其他{OtherCount}条。");
            if(lstError.Count> 0)
                AppLog.Error($"未成功上传的数据如下：{TransConvert.ListToString(lstError)}");
        }


        private void cmbColumns_SelectedIndexChanged(object sender, EventArgs e)
        {
            if (cmbColumns.SelectedItem == null) return;
            KeyValuePair<string, Type> obj = (KeyValuePair<string, Type>)cmbColumns.SelectedItem;
            if (DictComboBox.ContainsKey(obj.Key))
            {
                Type selectType = DictComboBox[obj.Key];

                switch (selectType.ToString())
                { 
                    case "System.DateTime":
                        UseDateTimeControl();
                        break;
                    case "System.Double":
                    case "System.Int64":
                    case "System.Int32":
                        UseNormalControl();
                        //绑定条件ComboBox
                        combCondition.DataSource = lstIntOrDouble ;
                        break;
                    case "System.Byte[]":
                    case "System.String":
                    default:
                        UseNormalControl();
                        //绑定条件ComboBox
                        combCondition.DataSource = lstText;
                        break;
                }
            }
        }

        /// <summary>
        /// 使用时间类型专用的查询控件组
        /// </summary>
        private void UseDateTimeControl()
        {
            if (pnlCheck.Controls.Contains(pnlText))
                pnlCheck.Controls.Remove(pnlText);
            if (!pnlCheck.Controls.Contains(pnlDate))
            {
                pnlCheck.Controls.Add(pnlDate);
                pnlDate.Visible = true;
                pnlDate.Dock = DockStyle.Fill;
            }
        }

        /// <summary>
        /// 使用标准的查询控件组
        /// </summary>
        private void UseNormalControl()
        {
            if (pnlCheck.Controls.Contains(pnlDate))
                pnlCheck.Controls.Remove(pnlDate);
            if (!pnlCheck.Controls.Contains(pnlText))
            {
                pnlCheck.Controls.Add(pnlText);
                pnlText.Visible = true;
                pnlText.Dock = DockStyle.Fill;
            }
        }

        /// <summary>
        /// 查询满足满足条件的项
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnFind_Click(object sender, EventArgs e)
        {
            if (cmbColumns.SelectedValue == null) return;
            //1.合法性检测
            if (DictComboBox[cmbColumns.SelectedValue.ToString()].ToString().Equals("System.DateTime"))
            {
                if (dtpTarget.Value < dtpSource.Value)
                {
                    MessageBox.Show("查询时间需要一个有效的时间范围！");
                    return;
                }
            }
            else
            {
                if (this.txtFind.Text.Trim() == "")  //为空  认为是取消查询
                {
                    btnCancelFind_Click(sender, e);
                    return;
                }               
            }

            
            //2.将datagridview中满足条件的项修改背景色
            //2.1 判断当前显示的datagridview是否含有旧的查询数据
            //2.2 将满足条件的项背景色改为特殊颜色
            foreach (DataGridViewRow dgvrow in dgvSyncData.Rows)
            {
                dgvrow.DefaultCellStyle.BackColor = Color.White;

                //查询列的当前值
                string strGuid  = dgvrow.Cells["GridGuid"].Value.ToString();
                if (DictField.Count > 0)
                {
                    var query = DictField.Where(s => s.Value == cmbColumns.SelectedValue.ToString());
                    if (query.Count() == 1)
                    {
                        string strValue = dgvrow.Cells[query.ElementAtOrDefault(0).Key].Value.ToString();
                        //判断是否满足条件
                        if (CheckMatchCondition(strValue))
                        {
                            dgvrow.DefaultCellStyle.BackColor = FinedBackColor;
                        }
                    }
                }
                else
                {
                    string strValue = dgvrow.Cells[cmbColumns.SelectedValue.ToString()].Value.ToString();
                    //判断是否满足条件
                    if (CheckMatchCondition(strValue))
                    {
                        dgvrow.DefaultCellStyle.BackColor = FinedBackColor;
                    }
                }
            }
        }

        private bool CheckMatchCondition(string strValue)
        {
            if (DictComboBox[cmbColumns.SelectedValue.ToString()].ToString().Equals("System.DateTime"))
            {
                DateTime dt= DateTime.Now;
                if (!DateTime.TryParse(strValue, out dt)) return false;

                DateTime dtSource = dtpSource.Value;
                DateTime dtTarget = dtpTarget.Value;
                DateTime dtValue = dt;
                if (dt >= dtSource && dt <= dtTarget)
                    return true;
                else
                    return false;
            }
            else
            {
                string strFindText = this.txtFind.Text.ToString();
                bool bReturn = false;
                try
                {
                    switch (combCondition.SelectedValue.ToString())
                    {
                        case "等于":
                            bReturn = strValue == strFindText ? true : false;
                            break;
                        case "不等于":
                            bReturn = strValue != strFindText ? true : false;
                            break;
                        case "包含":
                            bReturn = strValue.Contains(strFindText) ? true : false;
                            break;
                        case "不包含":
                            bReturn = !strValue.Contains(strFindText) ? true : false;
                            break;
                        case "大于":
                            bReturn = Convert.ToDouble(strValue) > Convert.ToDouble(strFindText) ? true : false;
                            break;
                        case "不小于":
                            bReturn = Convert.ToDouble(strValue) >= Convert.ToDouble(strFindText) ? true : false;
                            break;
                        case "小于":
                            bReturn = Convert.ToDouble(strValue) < Convert.ToDouble(strFindText) ? true : false;
                            break;
                        case "不大于":
                            bReturn = Convert.ToDouble(strValue) <= Convert.ToDouble(strFindText) ? true : false;
                            break;
                    }
                }
                catch (Exception ex)
                {
                    AppLog.Error(ex.Message);
                    bReturn = false;
                }
                return bReturn;
            }
        }


        /// <summary>
        /// 获得查询语句（非日期类型）
        /// </summary>
        /// <param name="strColumnName"></param>
        /// <param name="strColumnType"></param>
        /// <param name="strCondition"></param>
        /// <param name="strValue"></param>
        /// <returns></returns>
        private string GetSelectString(string strColumnName,string strCondition, string strValue)
        {
            string strCondi = "";
            switch (strCondition)
            {
                case "等于":
                    strCondi = "=";
                    break;
                case "不等于":
                    strCondi = "<>";
                    break;
                case "包含":
                    strCondi = "like";
                    break;
                case "不包含":
                    strCondi = "not like";
                    break;
                case "大于":
                    strCondi = ">";
                    break;
                case "不小于":
                    strCondi = ">=";
                    break;
                case "小于":
                    strCondi = "<";
                    break;
                case "不大于":
                    strCondi = "<=";
                    break;
            }
            if (strCondi == "like" || strCondi == "not like")
                return string.Format("{0} {1} '%{2}%'", strColumnName, strCondi, strValue);
            else
                return string.Format("{0} {1} '{2}'",strColumnName,strCondi,strValue);
        }
        private void btnConfig_Click(object sender, EventArgs e)
        {
            if (new frmOperationPwd().ShowDialog() == DialogResult.OK)
            {
                frmSyncParams frmSyncConfig = new frmSyncParams(syncInstrumentItem);
                frmSyncConfig.ParamsChangedDelegate = delegate (SyncInstrumentItemInfo instrumentItemInfo)
                  {
                      syncInstrumentItem = instrumentItemInfo;

                  //重新绑定数据
                  dgvSyncData.DataSource = null;
                      dgvSyncData.Rows.Clear();
                      dgvSyncData.Columns.Clear();
                      combCondition.DataSource = null;
                      cmbColumns.DataSource = null;

                      BindData();
                  };
                frmSyncConfig.ShowDialog();
            }
        }

        private void btnCancelFind_Click(object sender, EventArgs e)
        {
            foreach (DataGridViewRow dgvrow in dgvSyncData.Rows)
            {
                if (dgvrow.DefaultCellStyle.BackColor != Color.White)
                    dgvrow.DefaultCellStyle.BackColor = Color.White;
            }
        }

        private void btnAutoService_Click(object sender, EventArgs e)
        {
            if (new frmOperationPwd().ShowDialog() == DialogResult.OK)
            {
                frmServiceConfig frmServiceConfig = new frmServiceConfig();
                frmServiceConfig.ShowDialog();
            }
        }
    }
}