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; using XdCxRhDW.App.WebAPI; using Microsoft.Owin.Hosting; using XdCxRhDW.App.App.Properties; using System.Web.Http; namespace XdCxRhDW.App.UserControl { public partial class CtrlHome : DevExpress.XtraEditors.XtraUserControl { List list = new List(); public CtrlHome() { InitializeComponent(); gridHomeTask.Init(); gridHomePosRes.Init().UseMultiSelect().UseRowNumber(); var mapService = string.Empty;//http://ows.mundialis.de/services/service using (RHDWContext db = new RHDWContext()) { mapService = db.SysSetings.FirstOrDefault().MapService; } mapControl1.UseDefalutOptions() //.UseCluster()//定位点使用内置聚合 .UseClearAll() .UseDistanceLine() .UseMarkDot() .UseExportImg() .UseExportXlsx() .UseExportCsv() .SetMapLayerType(mapService) //.SetMapLayerType("") .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 listPos = new List(); 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), false); } private async void CtrlHome_Load(object sender, EventArgs e) { gridView1.FocusedRowObjectChanged += GridView1_FocusedRowObjectChanged; try { List satList = new List(); List txList = new List(); 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(); var satres = db.SatInfos.OrderBy(p => p.SatName).OrderBy(p => p.SatName); satList.AddRange(await satres.ToListAsync()); var txres = await db.TxInfos.ToListAsync(); txList.AddRange(txres); } foreach (var sat in satList) { if (!sat.SatLon.HasValue) continue; mapControl1.Invoke(new Action(() => { mapControl1.DrawFixedImg("sat", 10, sat.SatLon.Value, DxHelper.SvgHelper.CreateSat(), new Size(32, 32), $"{sat.Sat}\r\n"); })); } foreach (var txitem in txList) { if ((txitem.Lon >= 180 || txitem.Lon <= 180) && txitem.Lat >= -90 || txitem.Lat <= 90)//画天线 { mapControl1.Invoke(new Action(() => { switch (txitem.TxType) { #warning 天线图片需要邹大哥给 case EnumTxType.MainSat: mapControl1.DrawFixedImg("MainSatTx", txitem.Lat, txitem.Lon, DxHelper.SvgHelper.CreatePentagram(), new Size(32, 32), $"[{txitem.Name}]\r\n主星天线经度:{txitem.Lon}°\r\n主星天线纬度:{txitem.Lat}°\r\n"); break; case EnumTxType.AdjaSat: mapControl1.DrawFixedImg("AdjaSatTx", txitem.Lat, txitem.Lon, DxHelper.SvgHelper.CreatePentagram(), new Size(32, 32), $"[{txitem.Name}]\r\n邻星天线经度:{txitem.Lon}°\r\n邻星天线纬度:{txitem.Lat}°\r\n"); break; case EnumTxType.Cdb: mapControl1.DrawFixedImg("CdbStation", txitem.Lat, txitem.Lon, DxHelper.SvgHelper.CreatePentagram(), new Size(32, 32), $"[{txitem.Name}]\r\n超短站经度:{txitem.Lon}°\r\n超短站纬度:{txitem.Lat}°\r\n"); break; case EnumTxType.Cx: mapControl1.DrawFixedImg("CxStation", txitem.Lat, txitem.Lon, DxHelper.SvgHelper.CreatePentagram(), new Size(32, 32), $"[{txitem.Name}]\r\n测向站经度:{txitem.Lon}°\r\n测向站纬度:{txitem.Lat}°\r\n"); break; case EnumTxType.Ref: mapControl1.DrawFixedImg("RefStation", txitem.Lat, txitem.Lon, DxHelper.SvgHelper.CreatePentagram(), new Size(32, 32), $"参考站经度:{txitem.Lon}°\r\n参考站纬度:{txitem.Lat}°\r\n"); break; default: break; } })); } } } catch (Exception ex) { Serilog.Log.Error(ex, "加载任务信息异常"); DxHelper.MsgBoxHelper.ShowError("加载任务信息异常"); } 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; using (RHDWContext db = new RHDWContext()) { var settings = await db.SysSetings.FirstOrDefaultAsync(); if (settings == null) { DxHelper.MsgBoxHelper.ShowWarning($"请在系统设置中配置IP端口信息"); return; } try { StartOptions options = new StartOptions(); options.Urls.Add($"http://+:{settings.HttpPort}"); httpServer = WebApp.Start(options); } catch (Exception ex) { httpServer = null; Serilog.Log.Error(ex, "启动Http定位接口服务失败!"); DxHelper.MsgBoxHelper.ShowWarning($"启动Http定位接口服务失败!"); } } 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)) { DxHelper.MsgBoxHelper.ShowWarning("任务名称重复"); return; } db.TaskInfos.Add(addItem); await db.SaveChangesAsync(); } list.Insert(0, addItem); gridView1.RefreshData(); gridView1.FocusedRowHandle = 0; } catch (Exception ex) { Serilog.Log.Error(ex, "保存任务异常"); DxHelper.MsgBoxHelper.ShowError("保存任务异常"); } } 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)) { DxHelper.MsgBoxHelper.ShowWarning("任务名称重复"); 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, "保存任务异常"); DxHelper.MsgBoxHelper.ShowError("保存任务异常"); } } else { try { var tsk = gridView1.GetFocusedRow() as TaskInfo; if (tsk == null) return; if (!DxHelper.MsgBoxHelper.ShowConfirm($"删除任务[{tsk.TaskName}]?")) 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, "删除任务异常"); DxHelper.MsgBoxHelper.ShowError("删除任务异常"); } } } IDisposable httpServer; 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)); DxHelper.MsgBoxHelper.ShowWarning($"已经有一个[{field.GetCustomAttribute().Name}]任务正在执行,请先停止!"); return; } var settings = await db.SysSetings.FirstOrDefaultAsync(); if (settings == null) { DxHelper.MsgBoxHelper.ShowWarning($"请在系统设置中配置IP端口信息"); return; } if (server == null) { server = new TcpServer(); server.OnDataReceived += this.Server_OnDataReceived; server.Start(settings.Port); } if (httpServer == null) { try { StartOptions options = new StartOptions(); options.Urls.Add($"http://+:{settings.HttpPort}"); httpServer = WebApp.Start(options); } catch (Exception ex) { Serilog.Log.Error(ex, "启动任务异常,Http定位接口服务启动失败"); DxHelper.MsgBoxHelper.ShowError($"启动任务异常,Http定位接口服务启动失败"); } } 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, "启动任务异常"); DxHelper.MsgBoxHelper.ShowError($"启动任务异常.{ex.Message}"); } } 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, "停止任务异常"); DxHelper.MsgBoxHelper.ShowError($"停止任务异常.{ex.Message}"); } } 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(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; 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; 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; 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(item); } } await db.SaveChangesAsync(); } gridView2.DeleteSelectedRows(); } catch (Exception ex) { Serilog.Log.Error(ex, "删除定位结果异常"); DxHelper.MsgBoxHelper.ShowError("删除定位结果异常"); } } private void gridView2_RowClick(object sender, RowClickEventArgs e) { var p = gridView2.GetFocusedRow() as PosRes; p.Selected = true; mapControl1.UpdatePosItem(p); } } }