DataManager/UICompany.cs

using Mysqlx.Crud;
using MySqlX.Serialization;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Data.SqlClient;
using System.Drawing;
using System.Linq;
using System.Reflection;
using System.Runtime.InteropServices.ComTypes;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Text.Json;
using System.IO;
using System.Diagnostics;


namespace DataManager
{
    public partial class UICompany : Form
    {

        private string companyId;
        private int userId;

        private DataTable companyInfo;
        private DataTable fundList;
        private DataTable contactList;
        private List<DataRowView> old_selected_contactor = new List<DataRowView>();
        private List<DataRowView> old_selected_collector = new List<DataRowView>();
        private string saveFilePath;


        public UICompany(string companyId, int userId)
        {
            this.companyId = companyId.Trim().ToUpper();
            this.userId = userId;
            this.saveFilePath = ".\\Contracts\\" + companyId + "\\";

            InitializeComponent();

            InitializedData();

        }


        public string CompanyId { get { return companyId; } }
        public int UserId { get { return userId; } }

        private void InitializedData()
        {
            #region Basic Info Tab

            companyInfo = DataAccess.Get_dm_company_information(CompanyId);

            if(companyInfo == null || companyInfo.Rows.Count == 0 ) { return; }


            txtCompanyName.Text = companyInfo.Rows[0]["company_name"].ToString();
            txtRegisterCode.Text = companyInfo.Rows[0]["register_number"].ToString();
            txtCompanyId.Text = companyInfo.Rows[0]["company_id"].ToString();

            txtIncoporationDate.Text = DateTime.Parse(companyInfo.Rows[0]["establish_date"].ToString()).ToShortDateString();
            txtRegisterAddress.Text = companyInfo.Rows[0]["register_number_address"].ToString();
            txtOrgCode.Text = companyInfo.Rows[0]["credit_code"].ToString();
            
            txtBusinessAddress.Text = companyInfo.Rows[0]["company_address"].ToString();

            if (companyInfo.Rows[0]["nature_business_type"].ToString() != "")
                txtOrgType.Text = UIConstants.CompanyOwnerType[int.Parse(companyInfo.Rows[0]["nature_business_type"].ToString())];
            else
                txtOrgType.Text = "未知";
            if (companyInfo.Rows[0]["company_type"].ToString() != "")
                txtCompanyType.Text = UIConstants.CompanyType[int.Parse(companyInfo.Rows[0]["company_type"].ToString())];
            else
                txtCompanyType.Text = "未知";

            txtBusinessType.Text = companyInfo.Rows[0]["business_type"].ToString();

            if (companyInfo.Rows[0]["company_asset_size"].ToString() != "")
                txtAssetSize.Text = UIConstants.CompanyAssetSize[int.Parse(companyInfo.Rows[0]["company_asset_size"].ToString())];
            else
                txtAssetSize.Text = "未知";
            
            txtIsQualifiedAdvisor.Text = companyInfo.Rows[0]["has_consulting_qualification"].ToString() == "1" ? "是" : "否";
            //txtOwner.Text = companyInfo.Rows[0]["establish_date"].ToString();
            //txtAmacUpdateDate.Text = companyInfo.Rows[0]["zjx_last_info_update_time"].ToString();
            //lklAmacURL.Links.Add(Link )companyInfo.Rows[0]["amac_link"].ToString();
            txtCompanyShortName.Text = companyInfo.Rows[0]["company_short_name"].ToString();

            #endregion

            LoadContactsGrid();

            #region Fund List Tab

            Dictionary<int, string> d = new Dictionary<int, string>(UIConstants.HedgeFundStrategy);
            d.Add(DataAccess.DM_NULL, "全部");
            BindingSource bs = new BindingSource();
            bs.DataSource = d;
            cmbStrategy.DataSource = bs;
            cmbStrategy.DisplayMember = "Value";
            cmbStrategy.ValueMember = "Key";
            cmbStrategy.SelectedValue = (int)DataAccess.DM_NULL;
            
            LoadFundGrid();

            #endregion

            #region Contracts Tab

            sbyte jobType = Convert.ToSByte(UIConstants.JobType.Contact);
            DataTable dt_dm_user_1 = DataAccess.Get_dm_user(null, jobType);
            clbContactor.DataSource = dt_dm_user_1;
            clbContactor.DisplayMember = "username";
            clbContactor.ValueMember = "userid";

            // 给覆盖此公司的user打上勾
            DataTable dt_company_cover_1 = DataAccess.Get_dm_company_cover(CompanyId, jobType, null);
            for(int i = 0; i < clbContactor.Items.Count; i++)
            {
                string itemUserId = ((DataRowView)clbContactor.Items[i]).Row["userid"].ToString();
                
                if (dt_company_cover_1.Select("userid = " + itemUserId).Length > 0)
                    clbContactor.SetItemChecked(i, true);
            }
            // 记录一下初始的勾选
            foreach(DataRowView item in clbContactor.CheckedItems)
            {
                old_selected_contactor.Add(item);
            }

            jobType = Convert.ToSByte(UIConstants.JobType.Collection);
            DataTable dt_dm_user_2 = DataAccess.Get_dm_user(null, jobType);
            clbCollector.DataSource = dt_dm_user_2;
            clbCollector.DisplayMember = "username";
            clbCollector.ValueMember = "userid";

            // 给覆盖此公司的user打上勾
            DataTable dt_company_cover_2 = DataAccess.Get_dm_company_cover(CompanyId, jobType, null);
            for (int i = 0; i < clbCollector.Items.Count; i++)
            {
                string itemUserId = ((DataRowView)clbCollector.Items[i]).Row["userid"].ToString();

                if (dt_company_cover_2.Select("userid = " + itemUserId).Length > 0)
                    clbCollector.SetItemChecked(i, true);
            }
            // 记录一下初始的勾选
            foreach(DataRowView item in clbCollector.CheckedItems)
            {
                old_selected_collector.Add(item);
            }

            LoadContractFiles();

            #endregion


        }

        #region Basic Info

        private void btnSaveBasicInfo_Click(object sender, EventArgs e)
        {
            MessageBox.Show("暂时不支持存数据");
        }

        #endregion

        #region Contact List
        private void LoadContactsGrid()
        {
            contactList = DataAccess.Get_dm_contacts(CompanyId);

            grdContacts.DataSource = contactList;

            grdContacts.AutoSizeColumnsMode = DataGridViewAutoSizeColumnsMode.Fill;

            grdContacts.Columns["id"].Visible = false;
            grdContacts.Columns["company_id"].Visible = false;
            grdContacts.Columns["name"].HeaderText = "姓名";
            grdContacts.Columns["role"].HeaderText = "职务";
            grdContacts.Columns["phone"].HeaderText = "电话";
            grdContacts.Columns["wechat"].HeaderText = "微信";
            grdContacts.Columns["email"].HeaderText = "邮箱";
            grdContacts.Columns["isvalid"].Visible = false;
            grdContacts.Columns["creatorid"].Visible = false;
            grdContacts.Columns["createtime"].Visible = false;
            grdContacts.Columns["updaterid"].Visible = false;
            grdContacts.Columns["updatetime"].Visible = false;

            lblContactsCount.Text = contactList.Rows.Count.ToString();
        }


        private void btnSaveContact_Click(object sender, EventArgs e)
        {
            if(contactList == null ) return;

            int updatedCnt = DataAccess.Set_dm_contacts(contactList, CompanyId, UserId);

            contactList.AcceptChanges();

            MessageBox.Show("成功更新了" + updatedCnt.ToString() + "个联系人");
            
        }

        #endregion

        #region Fund List

        private void LoadFundGrid()
        {
            fundList = DataAccess.Get_dm_fund_information(null, CompanyId);

            BindingSource bs = new BindingSource();
            bs.DataSource = fundList;
            grdFund.DataSource = bs;

            grdFund.AutoSizeColumnsMode = DataGridViewAutoSizeColumnsMode.Fill;

            grdFund.Columns["fund_id"].Visible = false;
            grdFund.Columns["raise_type"].Visible = false;
            grdFund.Columns["fund_name"].Visible = false;
            grdFund.Columns["fund_short_name"].HeaderText = "基金简称";
            grdFund.Columns["fund_structure"].Visible = false;
            grdFund.Columns["fund_type"].Visible = false;
            grdFund.Columns["strategy"].Visible = false;
            grdFund.Columns["substrategy"].Visible = false;
            grdFund.Columns["fund_status"].Visible = false;
            grdFund.Columns["base_currency"].Visible = false;
            grdFund.Columns["inception_date"].HeaderText = "成立日";
            grdFund.Columns["initial_unit_value"].Visible = false;
            grdFund.Columns["p_fund_id"].Visible = false;
            grdFund.Columns["p_fund_name"].Visible = false;
            grdFund.Columns["advisor_id"].Visible = false;
            grdFund.Columns["company_name"].Visible = false;
            grdFund.Columns["custodian_id"].Visible = false;
            grdFund.Columns["custodian_name"].HeaderText = "托管";
            grdFund.Columns["trust_id"].Visible = false;
            grdFund.Columns["nav_frequency"].HeaderText = "净值频率";
            grdFund.Columns["manager_type"].Visible = false;
            grdFund.Columns["zjx_last_info_update_time"].Visible = false;
            grdFund.Columns["amac_url"].Visible = false;
            grdFund.Columns["register_number"].HeaderText = "备案编码";
            grdFund.Columns["register_date"].Visible = false;
            grdFund.Columns["main_code"].Visible = false;
            grdFund.Columns["isVisible"].Visible = false;
            grdFund.Columns["is_ranking"].HeaderText = "是否排名";
            grdFund.Columns["is_rating"].HeaderText = "是否评级";
            grdFund.Columns["is_authorized"].HeaderText = "是否授权";
            grdFund.Columns["trust_register_number"].Visible = false;
            grdFund.Columns["isvalid"].Visible = false;
            grdFund.Columns["creatorid"].Visible = false;
            grdFund.Columns["createtime"].Visible = false;
            grdFund.Columns["updaterid"].Visible = false;
            grdFund.Columns["updatetime"].Visible = false;

            grdFund.Columns["fund_short_name"].AutoSizeMode = DataGridViewAutoSizeColumnMode.AllCells;

            SetStatusStrip(fundList.Rows.Count);
        }

        private void grdFund_CellContentClick(object sender, DataGridViewCellEventArgs e)
        {

            int rowIndex = e.RowIndex;
            int columnIndex = e.ColumnIndex;

            if (columnIndex < 0 || rowIndex < 0) return;

            DataGridViewRow row = grdFund.Rows[rowIndex];
            string fundId = row.Cells["fund_id"].Value.ToString();
            
            UIFund frm = new UIFund(fundId);
            frm.ShowDialog();
        }

        private void cmbStrategy_SelectedIndexChanged(object sender, EventArgs e)
        {
            FilterFund();
        }

        private void dtpInceptionDate_ValueChanged(object sender, EventArgs e)
        {
            FilterFund();
        }

        private void FilterFund()
        {
            string strategy = cmbStrategy.SelectedValue.ToString();
            string inception = dtpInceptionDate.Value.ToString();
            string filter = null;
            int cnt = 0;

            if (strategy == DataAccess.DM_NULL.ToString())
                filter = string.Format("inception_date <= #{0}#", inception);
            else
                filter = string.Format("strategy = {0} and inception_date <= #{1}#", strategy, inception);

            if (fundList != null && fundList.Rows.Count > 0)
            {
                BindingSource bs = (BindingSource)grdFund.DataSource;
                bs.Filter = filter;

                cnt = bs.Count;
            }

            SetStatusStrip(cnt);
        }

        private void SetStatusStrip(int cnt)
        {
            ToolStripStatusLabel label = new ToolStripStatusLabel();
            label.Text = "记录条数：" + cnt.ToString();
            sstCompany.Items.Clear();
            sstCompany.Items.Add(label);
        }

        #endregion


        #region Contract
        private void btnSaveContactor_Click(object sender, EventArgs e)
        {
            List<CompanyCoverUser> coverage = new List<CompanyCoverUser>();

            List<DataRowView> new_selected_contactor = new List<DataRowView>();
            foreach(DataRowView item in clbContactor.CheckedItems)
                new_selected_contactor.Add(item);

            CompanyCoverUser cov1 = CompareCoverage(CompanyId, 1, old_selected_contactor, new_selected_contactor);
            if(cov1 != null )
                coverage.Add(cov1);

            List<DataRowView> new_selected_collector = new List<DataRowView>();
            foreach (DataRowView item in clbCollector.CheckedItems)
                new_selected_collector.Add(item);

            CompanyCoverUser cov2 = CompareCoverage(CompanyId, 2, old_selected_collector, new_selected_collector);
            if(cov2 != null )
                coverage.Add(cov2);
            
            string query = JsonSerializer.Serialize(coverage);
            
            int ret = DataAccess.Set_dm_company_cover(query, UserId);

            string message = ret < 0 ? "Oops... 变更存数据库时出了错" : "人员覆盖变更已经成功存盘~";
            MessageBox.Show(message);

        }
        /// <summary>
        /// 前后人员覆盖对比
        /// </summary>
        /// <param name="companyId"></param>
        /// <param name="coverType"></param>
        /// <param name="oldList"></param>
        /// <param name="newList"></param>
        /// <returns></returns>
        private CompanyCoverUser CompareCoverage(string companyId, sbyte coverType, List<DataRowView> oldList, List<DataRowView> newList)
        {
            CompanyCoverUser companyCoverUser = new CompanyCoverUser();
            companyCoverUser.CompanyId = companyId;
            companyCoverUser.CoverType = coverType;

            if (oldList == null || newList == null) return companyCoverUser;

            // 在旧名单里，但不在新名单里的要删掉
            List<DataRowView> itemDeleted = oldList.Except(newList).ToList();
            // 在新名单里，但不在旧名单里的要增加
            List<DataRowView> itemAdded = newList.Except(oldList).ToList();

            int i = 0;
            CompanyCoverUser.Coverage[] covers = null;
            if (itemDeleted.Count > 0 || itemAdded.Count > 0)
                covers = new CompanyCoverUser.Coverage[itemDeleted.Count+itemAdded.Count];

            foreach (DataRowView item in itemDeleted)
            {
                CompanyCoverUser.Coverage cov = new CompanyCoverUser.Coverage();
                
                cov.IsValid = 0;
                cov.UserId = int.Parse(item.Row["userid"].ToString());
                covers[i] = cov;
                i++;
            }

            foreach (DataRowView item in itemAdded)
            {
                CompanyCoverUser.Coverage cov = new CompanyCoverUser.Coverage();

                cov.IsValid = 1;
                cov.UserId = int.Parse(item.Row["userid"].ToString());
                covers[i] = cov;
                i++;
            }
            companyCoverUser.Coverages = covers;

            //ret = JsonSerializer.Serialize(companyCoverUser);
            
            return companyCoverUser;
        }

        /// <summary>
        /// 上传文件  TODO: 文件先写到本地
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnUploadFile_Click(object sender, EventArgs e)
        {

            ofdUploadFile.Title = "文件上传 ... 还没做完呢";
            //ofdUploadFile.DefaultExt = "doc";
            
            //ofdUploadFile.Filter = "所有Word文件(*.doc)|所有pdf文件(*.pdf)|所有文件(*.*)|*.*";

            if(ofdUploadFile.ShowDialog() == DialogResult.OK)
            {
                // TODO: upload files to server. let's fake it for now
                string filePath = ofdUploadFile.FileName;
                string fileName = Path.GetFileName(filePath);

                string saveFileName = this.saveFilePath + fileName;
                try
                {
                    if (!Directory.Exists(saveFilePath)) { Directory.CreateDirectory(saveFilePath); }


                    File.Copy(filePath, saveFileName, true);

                    CreateFileButton(Path.GetFileName(saveFileName));
                }
                catch (Exception ex)
                {
                    MessageBox.Show("文件上传失败：" + ex.Message);
                }

            }
        }

        /// <summary>
        /// 显示已上传文件，每个文件一个按钮
        /// </summary>
        private void LoadContractFiles()
        {
            if (Directory.Exists(this.saveFilePath))
            {
                string[] fileNames = Directory.GetFiles(saveFilePath);
                

                if(fileNames.Length > 0)
                {
                    foreach (string fileName in fileNames)
                    {
                        CreateFileButton(Path.GetFileName(fileName));
                    }
                }
            }
        }


        /// <summary>
        /// 为每个上传的文件产生一个按钮来显示
        /// </summary>
        /// <param name="fileName"></param>
        private void CreateFileButton(string fileName)
        {
            Panel panFile = new Panel();
            panFile.BorderStyle = BorderStyle.FixedSingle;
            panFile.Size = btnUploadFile.Size;
            panFile.Text = fileName;
            panFile.Font = new Font("微软雅黑", 10F, FontStyle.Regular, GraphicsUnit.Point, ((byte)(134)));
            panFile.Click += PanFile_Click;
            panFile.MouseEnter += PanFile_Enter;
            panFile.MouseLeave += PanFile_MouseLeave;

            Label lblFileName = new Label();
            lblFileName.Text = fileName;
            lblFileName.ForeColor = Color.Navy;
            lblFileName.Size = new Size(panFile.Width, panFile.Height/2);
            lblFileName.Location = new Point(panFile.Location.X, panFile.Location.Y + panFile.Size.Height/2);
            lblFileName.TextAlign = ContentAlignment.MiddleCenter;
            lblFileName.Click += LblFileName_Click;
            panFile.Controls.Add(lblFileName);

            CircleDeleteControl delIcon = new CircleDeleteControl();
            delIcon.Size = new Size(panFile.Width/8, panFile.Height/8);
            delIcon.Location = new Point(panFile.Width * 3/4, panFile.Width * 1/8);
            delIcon.Visible = true;
            delIcon.Click += DelIcon_Click;
            panFile.Controls.Add(delIcon);


            flowLayoutPanel1.Controls.Add(panFile);
        }


        private void LblFileName_Click(object sender, EventArgs e)
        {
            Control pan = ((Control)sender).Parent;
            PanFile_Click(pan, e);
        }

        private void PanFile_Click(object sender, EventArgs e)
        {
            OpenFile(saveFilePath + ((Panel)sender).Text);
        }

        private void PanFile_Enter(object sender, EventArgs e)
        {
            ((Control)sender).BackColor = Color.LightGray;
        }

        private void PanFile_MouseLeave(object sender, EventArgs e)
        {
            ((Control)sender).BackColor = Color.White;
        }

        private void DelIcon_Click(object sender, EventArgs e)
        {
            DialogResult result = MessageBox.Show("确认要删除此文件么？", "删除文件确认", MessageBoxButtons.YesNo, MessageBoxIcon.Question);

            if (result == DialogResult.Yes) 
            {
                Panel pan = (Panel)((Control)sender).Parent;

                File.Delete(saveFilePath + pan.Text);

                pan.Parent.Controls.Remove(pan);
            }
        }


        private void OpenFile(string fileName)
        {
            ProcessStartInfo startInfo = new ProcessStartInfo
            {
                FileName = fileName,
                UseShellExecute = true
            };

            Process.Start(startInfo);

        }

        #endregion
    }

    public class CompanyCoverUser
    {
        public string CompanyId { get; set; }

        public sbyte CoverType { get; set; }

        public Coverage[] Coverages { get; set; }

        public class Coverage
        {
            public sbyte IsValid { get; set; }

            public int UserId { get; set; }

        }
    }

    public class CircleDeleteControl : Control
    {
        protected override void OnPaint(PaintEventArgs e)
        {
            base.OnPaint(e);
            Graphics g = e.Graphics;
            g.SmoothingMode = System.Drawing.Drawing2D.SmoothingMode.AntiAlias;

            Point center = new Point(this.Width/2, this.Height/2);

            // 圆形删除符号的直径可以是控件的最小边长
            int diameter = Math.Min(this.Width, this.Height);

            // 圆形删除符号的内半径
            int innerRadius = diameter / 2;

            using (Pen deletePen = new Pen(Color.Red, 1))
            {
                // 绘制圆形删除符号的背景
                g.DrawEllipse(deletePen, center.X - innerRadius, center.Y - innerRadius, diameter, diameter);

                // 绘制两条相交的对角线
                g.DrawLine(deletePen, center.X - innerRadius, center.Y + innerRadius, center.X + innerRadius, center.Y - innerRadius);
                g.DrawLine(deletePen, center.X - innerRadius, center.Y - innerRadius, center.X + innerRadius, center.Y + innerRadius);
            }

        }

        protected override void OnMouseEnter(EventArgs e)
        {
            base.OnMouseEnter(e);
            this.Cursor = Cursors.Hand;
        }
        protected override void OnMouseLeave(EventArgs e)
        {
            base.OnMouseLeave(e);
            this.Cursor = Cursors.Arrow;
        }

    }
}