XdCxRhDW/XdCxRhDW.App/UserControl/CtrlHome.cs

using DevExpress.Mvvm.DataAnnotations;
using DevExpress.Utils;
using DevExpress.Utils.Design;
using DevExpress.Utils.Drawing;
using DevExpress.Utils.Svg;
using DevExpress.XtraEditors;
using DevExpress.XtraEditors.ButtonsPanelControl;
using DevExpress.XtraEditors.Controls;
using DevExpress.XtraEditors.Repository;
using DevExpress.XtraGrid.Columns;
using DevExpress.XtraGrid.Views.Grid;
using DevExpress.XtraGrid.Views.Grid.ViewInfo;
using DxHelper;
using XdCxRhDW.App.EFContext;
using XdCxRhDW.App.Model;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using XdCxRhDW.App.EditForms;
using System.Data.Entity;
using DevExpress.XtraBars.Customization;
using System.Reflection;
using System.Net.Sockets;
using System.Net;
using DevExpress.XtraCharts.Native;
using System.Threading;
using XdCxRhDW.Dto;
using XdCxRhDW.App.Api;
using System.Windows.Controls;

namespace XdCxRhDW.App.UserControl
{
    public partial class CtrlHome : DevExpress.XtraEditors.XtraUserControl
    {
        List<TaskInfo> list = new List<TaskInfo>();


        public CtrlHome()
        {
            InitializeComponent();
            gridHomeTask.Init();
            gridHomePosRes.Init().UseMultiSelect().UseRowNumber();
            mapControl1.UseDefalutOptions()
                //.UseCluster()//定位点使用内置聚合
                .UseClearAll()
                .UseDistanceLine()
                .UseMarkDot()
                .UseExportImg()
                .UseExportXlsx()
                .UseExportCsv()
                .UseDrawRect(rect =>
                {
                    (double startLon, double startLat, double centerLon, double centerLat, double endLon, double endLat, double lonRange, double latRange) = rect;
                });

        }
        private async void GridView1_FocusedRowObjectChanged(object sender, DevExpress.XtraGrid.Views.Base.FocusedRowObjectChangedEventArgs e)
        {
            var tsk = (e.Row as TaskInfo);
            var btnEdit = (layoutControlGroup1.CustomHeaderButtons[1] as GroupBoxButton);
            var btnDel = (layoutControlGroup1.CustomHeaderButtons[2] as GroupBoxButton);
            btnDel.Enabled = btnEdit.Enabled = tsk.TaskState != EnumTaskState.Running;
            List<PosRes> listPos = new List<PosRes>();
            using (RHDWContext db = new RHDWContext())
            {
                var items = await db.PosRes.Where(p => p.TaskID == tsk.ID).OrderByDescending(p => p.SigTime).ToListAsync();
                listPos.AddRange(items);
            }
            this.gridHomePosRes.DataSource = listPos;
            mapControl1.SetPosDataSource(listPos.Where(p => p.PosLon <= 180));
        }
        private async void CtrlHome_Load(object sender, EventArgs e)
        {
            gridView1.FocusedRowObjectChanged += GridView1_FocusedRowObjectChanged;
            try
            {
                using (RHDWContext db = new RHDWContext())
                {
                    var qq = db.TaskInfos.OrderByDescending(p => p.CreateTime).ToList();
                    list.AddRange(qq);
                    var runningList = await db.TaskInfos.Where(p => p.TaskState == EnumTaskState.Running).ToListAsync();
                    foreach (var item in runningList)
                    {
                        item.TaskState = EnumTaskState.Stopped;
                    }
                    await db.SaveChangesAsync();
                }
            }
            catch (Exception ex)
            {
                Serilog.Log.Error("加载任务信息异常",ex);
                XtraMessageBox.Show("加载任务信息异常");
            }
            gridHomeTask.DataSource = list;
            gridView1.Columns["TaskName"].AppearanceCell.TextOptions.HAlignment = HorzAlignment.Near;
            this.svgImageCollection1.Add("Stopped", SvgHelper.CreateCycle("#1E8B58"));
            this.svgImageCollection1.Add("Running", SvgHelper.CreateCycle("#2E8B57"));



            gridView1.CustomDrawCell += GridView1_CustomDrawCell;
            DxHelper.WaitHelper.CloseForm();
        }

        private void GridView1_CustomDrawCell(object sender, DevExpress.XtraGrid.Views.Base.RowCellCustomDrawEventArgs e)
        {
            if (e.Column.FieldName == "TaskName" && (EnumTaskState)gridView1.GetRowCellValue(e.RowHandle, "TaskState") == EnumTaskState.Running)
            {
                var palette = SvgPaletteHelper.GetSvgPalette(this.LookAndFeel, ObjectState.Normal);
                e.Cache.DrawSvgImage(svgImageCollection1[1], new Rectangle(new Point(e.Bounds.X + 4, e.Bounds.Y + (e.Bounds.Height - 16) / 2), new Size(16, 16)), palette);

                Rectangle txtBounds = e.Bounds;
                txtBounds.Width -= 24;
                txtBounds.X += 24;
                e.Appearance.DrawString(e.Cache, e.DisplayText, txtBounds);
                e.Handled = true;
            }
        }

        //public void SetEnumColumnImage(GridView gv, string columnFieldName, object imageCollection)
        //{
        //    var repositoryItemImageComboBoxStatus = new RepositoryItemImageEdit();
        //    var col = gv.Columns[columnFieldName];
        //    col.MaxWidth = 40;
        //    repositoryItemImageComboBoxStatus.Images = imageCollection;
        //    col.ColumnEdit = repositoryItemImageComboBoxStatus;
        //}

        private void toolTipController1_GetActiveObjectInfo(object sender, DevExpress.Utils.ToolTipControllerGetActiveObjectInfoEventArgs e)
        {
            GridHitInfo hitInfo = gridView1.CalcHitInfo(e.ControlMousePosition);

            if (hitInfo.RowHandle < 0 || hitInfo.Column == null || hitInfo.HitTest != GridHitTest.RowCell)
            {
                toolTipController1.HideHint();
                return;
            }
            if (hitInfo.Column.FieldName == "TaskName")
            {
                var state = (EnumTaskState)gridView1.GetRowCellValue(hitInfo.RowHandle, "TaskState");
                if (state == EnumTaskState.Running)
                    e.Info = new ToolTipControlInfo(hitInfo.RowHandle, "执行中");
            }
        }

        private void gridView1_PopupMenuShowing(object sender, PopupMenuShowingEventArgs e)
        {
            if (gridView1.FocusedRowHandle < 0) return;
            var state = (EnumTaskState)gridView1.GetFocusedRowCellValue("TaskState");
            btnStart.Enabled = state == EnumTaskState.Stopped;
            btnStop.Enabled = state == EnumTaskState.Running;
            popupMenu1.ShowPopup(MousePosition);
        }
        private void gridView2_PopupMenuShowing(object sender, PopupMenuShowingEventArgs e)
        {
            if (gridView2.FocusedRowHandle < 0) return;
            if (!gridView2.GetSelectedRows().Any())
            {
                btnDelPos.Visibility = DevExpress.XtraBars.BarItemVisibility.Never;
            }
            else
            {
                btnDelPos.Visibility = DevExpress.XtraBars.BarItemVisibility.Always;
            }
            popupMenu2.ShowPopup(MousePosition);
        }
        private async void layoutControlGroup1_CustomButtonClick(object sender, DevExpress.XtraBars.Docking2010.BaseButtonEventArgs e)
        {
            var txt = (e.Button as GroupBoxButton).Caption;
            if (txt == "新建任务")
            {
                try
                {
                    TaskEditor frm = new TaskEditor();
                    if (frm.ShowDialog() != DialogResult.OK) return;
                    var addItem = frm.info;
                    using (RHDWContext db = new RHDWContext())
                    {
                        if (await db.TaskInfos.AnyAsync(p => p.TaskName == addItem.TaskName))
                        {
                            XtraMessageBox.Show("任务名称重复");
                            return;
                        }
                        db.TaskInfos.Add(addItem);
                        await db.SaveChangesAsync();
                    }
                    list.Insert(0, addItem);
                    gridView1.RefreshData();
                    gridView1.FocusedRowHandle = 0;
                }
                catch (Exception ex)
                {
                    Serilog.Log.Error("保存任务失败", ex);
                    XtraMessageBox.Show("保存任务失败!");
                }
            }
            else if (txt == "编辑任务")
            {
                try
                {
                    var editItem = gridView1.GetFocusedRow() as TaskInfo;
                    TaskEditor frm = new TaskEditor(editItem);
                    if (frm.ShowDialog() != DialogResult.OK) return;
                    editItem = frm.info;
                    using (RHDWContext db = new RHDWContext())
                    {
                        if (await db.TaskInfos.AnyAsync(p => p.ID != editItem.ID && p.TaskName == editItem.TaskName))
                        {
                            XtraMessageBox.Show("任务名称重复");
                            return;
                        }
                        var find = await db.TaskInfos.Where(p => p.ID == editItem.ID).FirstOrDefaultAsync();
                        find.TaskName = editItem.TaskName;
                        find.PosType = editItem.PosType;
                        await db.SaveChangesAsync();
                    }
                    gridView1.RefreshData();
                }
                catch (Exception ex)
                {
                    Serilog.Log.Error("保存任务失败", ex);
                    XtraMessageBox.Show("保存任务失败!");
                }
            }
            else
            {
                try
                {
                    var tsk = gridView1.GetFocusedRow() as TaskInfo;
                    if (tsk == null) return;
                    if (XtraMessageBox.Show($"删除任务[{tsk.TaskName}]?", "确认", MessageBoxButtons.YesNo) == DialogResult.No) return;
                    using (RHDWContext db = new RHDWContext())
                    {
                        var item = db.TaskInfos.FirstOrDefault(p => p.ID == tsk.ID);
                        db.TaskInfos.Remove(item);
                        db.SaveChanges();
                    }
                    gridView1.DeleteSelectedRows();

                }
                catch (Exception ex)
                {
                    Serilog.Log.Error("删除任务失败", ex);
                    XtraMessageBox.Show("删除任务失败!");
                }
            }
        }
        TcpServer server;
        private async void btn_ItemClick(object sender, DevExpress.XtraBars.ItemClickEventArgs e)
        {
            var tsk = gridView1.GetFocusedRow() as TaskInfo;
            if (e.Item.Caption == "启动任务")
            {
                try
                {
                    using (RHDWContext db = new RHDWContext())
                    {
                        var find = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskState == EnumTaskState.Running && p.PosType == tsk.PosType);
                        if (find != null)
                        {
                            var field = typeof(EnumPosType).GetField(Enum.GetName(typeof(EnumPosType), find.PosType));
                            XtraMessageBox.Show($"已经有一个[{field.GetCustomAttribute<DisplayAttribute>().Name}]任务正在执行,请先停止!");
                            return;
                        }

                        var settings = await db.SysSetings.FirstOrDefaultAsync();
                        if (settings == null)
                        {
                            XtraMessageBox.Show($"请在系统设置中配置IP端口信息");
                            return;
                        }
                        if (server == null)
                        {
                            server = new TcpServer();
                            server.OnDataReceived += this.Server_OnDataReceived;
                            server.Start(settings.Port);
                        }
                        var item = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == tsk.ID);
                        item.TaskState = EnumTaskState.Running;
                        await db.SaveChangesAsync();
                        tsk.TaskState = EnumTaskState.Running;
                        Serilog.Log.Information($"用户启动了任务,ID={tsk.ID}");
                    }
                }
                catch (Exception ex)
                {
                    Serilog.Log.Error("启动任务失败", ex);
                    XtraMessageBox.Show("启动任务失败");
                }
            }
            else
            {
                try
                {
                    using (RHDWContext db = new RHDWContext())
                    {
                        var item = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == tsk.ID);
                        item.TaskState = EnumTaskState.Stopped;
                        await db.SaveChangesAsync();
                        if (!db.TaskInfos.Any(p => p.TaskState == EnumTaskState.Running))
                        {
                            server?.StopListening();
                            server = null;
                        }
                    }
                    tsk.TaskState = EnumTaskState.Stopped;
                    Serilog.Log.Information($"用户停止了任务,ID={tsk.ID}");

                }
                catch (Exception ex)
                {
                    Serilog.Log.Error("停止任务失败", ex);
                    XtraMessageBox.Show("停止任务失败");
                }
            }
            gridView1.RefreshData();
            var btnEdit = (layoutControlGroup1.CustomHeaderButtons[1] as GroupBoxButton);
            var btnDel = (layoutControlGroup1.CustomHeaderButtons[2] as GroupBoxButton);
            btnDel.Enabled = btnEdit.Enabled = tsk.TaskState != EnumTaskState.Running;
        }

        private void gridView1_CustomDrawEmptyForeground(object sender, DevExpress.XtraGrid.Views.Base.CustomDrawEventArgs e)
        {
            if (gridView1.RowCount == 0)
            {
                string txt = "点击+创建任务";
                var s = e.Appearance.CalcTextSize(e.Cache, txt, e.Bounds.Width).ToSize();
                var x = (e.Bounds.Width - s.Width) / 2;
                var y = (e.Bounds.Height - s.Height) / 2;
                //e.Appearance.DrawString(e.Cache, txt, new Rectangle(x,y,s.Width,s.Height));
                e.DrawHtml(htmlTemplate1);
            }
        }
        readonly Random r = new Random();
        private async void Server_OnDataReceived(byte[] data)
        {
            try
            {
                var msg = Encoding.UTF8.GetString(data);
                var dto = Newtonsoft.Json.JsonConvert.DeserializeObject<SendDto>(msg);
                if (dto == null) return;
                var sigTime = DateTime.Now;
                using (RHDWContext db = new RHDWContext())
                {
                    var cgRes = db.CgRes.Add(new CgRes()
                    {
                        SigTime = sigTime,
                        DtoSx = dto.SxDto * 1e6,
                        DfoSx = 200 + r.Next(1, 5) + Math.Round(r.NextDouble(), 3),
                        SnrSx = r.Next(18, 24) + Math.Round(r.NextDouble(), 1),
                        DtoCdb = dto.XdDto * 1e6,
                        DfoCdb = 600 + r.Next(1, 5) + Math.Round(r.NextDouble(), 3),
                        SnrCdb = r.Next(22, 32) + Math.Round(r.NextDouble(), 1),
                        YbMain = dto.MainYbDto * 1e6,
                        YbAdja = dto.AdjaYbDto * 1e6,
                        MainX = dto.MainX,
                        MainY = dto.MainY,
                        MainZ = dto.MainZ,
                        AdjaX = dto.AdjaX,
                        AdjaY = dto.AdjaY,
                        AdjaZ = dto.AdjaZ,
                    });
                    var listTx = await db.TxInfos.ToListAsync();
                    var cxRes = db.CxRes.Add(new CxRes()
                    {
                        SigTime = sigTime,
                        Fx = dto.CxRes,
                    });
                    var tsk1X1D = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X1D1CX && p.TaskState == EnumTaskState.Running);
                    var tsk2X1D = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
                    var tskRh = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.RH && p.TaskState == EnumTaskState.Running);

                    if (tsk1X1D != null)
                    {
                        var res = PosApi.X1D1_POS(cgRes, listTx, cxRes);
                        PosRes posRes = new PosRes()
                        {
                            SigTime = sigTime,
                            TaskID = tsk1X1D.ID,
                            CxResID = cxRes.ID,
                            CgResID = cgRes.ID,
                            TarName = "未知目标",
                            TsName = "DAMA--56-115ms",
                            PosLon = res[0],
                            PosLat = res[1],
                            MirrLon = res[3],
                            MirrLat = res[4],
                        };
                        db.PosRes.Add(posRes);
                        var currentTask = gridView1.GetFocusedRow() as TaskInfo;
                        if (currentTask != null && currentTask.ID == tsk1X1D.ID)
                        {
                            var ds = this.gridHomePosRes.DataSource as List<PosRes>;
                            ds.Insert(0, posRes);
                            this.Invoke(new Action(() =>
                            {
                                gridView2.RefreshData();
                                mapControl1.AddPosItem(posRes);
                            }));

                        }
                    }
                    if (tsk2X1D != null)
                    {
                        var res = PosApi.X2D1_POS(cgRes, listTx);
                        PosRes posRes = new PosRes()
                        {
                            SigTime = sigTime,
                            TaskID = tsk2X1D.ID,
                            CxResID = cxRes.ID,
                            CgResID = cgRes.ID,
                            TarName = "未知目标",
                            TsName = "DAMA-225-173ms",
                            PosLon = res[0],
                            PosLat = res[1],
                            MirrLon = res[3],
                            MirrLat = res[4],
                        };
                        db.PosRes.Add(posRes);
                        var currentTask = gridView1.GetFocusedRow() as TaskInfo;
                        if (currentTask.ID == tsk2X1D.ID)
                        {
                            var ds = this.gridHomePosRes.DataSource as List<PosRes>;
                            ds.Insert(0, posRes);
                            this.Invoke(new Action(() =>
                            {
                                gridView2.RefreshData();
                                mapControl1.AddPosItem(posRes);
                            }));

                        }
                    }
                    if (tskRh != null)
                    {
                        var res = PosApi.RH_POS(cgRes, listTx, cxRes);
                        PosRes posRes = new PosRes()
                        {
                            SigTime = sigTime,
                            TaskID = tskRh.ID,
                            CxResID = cxRes.ID,
                            CgResID = cgRes.ID,
                            TarName = "未知目标",
                            TsName = "DAMA-738-109ms",
                            PosLon = res[0],
                            PosLat = res[1],
                            MirrLon = res[3],
                            MirrLat = res[4],
                        };
                        db.PosRes.Add(posRes);
                        var currentTask = gridView1.GetFocusedRow() as TaskInfo;
                        if (currentTask.ID == tskRh.ID)
                        {
                            var ds = this.gridHomePosRes.DataSource as List<PosRes>;
                            ds.Insert(0, posRes);
                            this.Invoke(new Action(() =>
                            {
                                gridView2.RefreshData();
                                mapControl1.AddPosItem(posRes);
                            }));
                        }
                    }
                    await db.SaveChangesAsync();
                }
            }
            catch (Exception ex)
            {
                Serilog.Log.Error("接收到推送消息后处理异常", ex);
            }
        }

        private async void btnDelPos_ItemClick(object sender, DevExpress.XtraBars.ItemClickEventArgs e)
        {
            try
            {
                var ids = gridView2.GetSelectedRows();
                using (RHDWContext db = new RHDWContext())
                {
                    foreach (var id in ids)
                    {
                        var item = gridView2.GetRow(id) as PosRes;
                        var delItem = await db.PosRes.Where(p => p.ID == item.ID).FirstOrDefaultAsync();
                        if (delItem != null)
                        {
                            db.PosRes.Remove(delItem);
                            mapControl1.DelPosItem<PosRes>(item);
                        }
                    }
                    await db.SaveChangesAsync();
                }
                gridView2.DeleteSelectedRows();

            }
            catch (Exception ex)
            {
                Serilog.Log.Error("删除定位结果失败", ex);
                XtraMessageBox.Show("删除定位结果失败");
            }
        }

        private void gridView2_RowClick(object sender, RowClickEventArgs e)
        {
            var p = gridView2.GetFocusedRow() as PosRes;
            p.Selected = true;
            mapControl1.UpdatePosItem(p);
        }
    }


}