diff --git a/Controllers/DeviceController.cs b/Controllers/DeviceController.cs index a14ebfd..7bddfbc 100644 --- a/Controllers/DeviceController.cs +++ b/Controllers/DeviceController.cs @@ -42,6 +42,16 @@ namespace LY.App.Controllers return Ok(result); } /// + /// 协议列表 + /// + /// + [HttpGet("protocollist")] + public async Task ProtocolTypeList() + { + var result = await _deviceService.ProtocolTypeList(); + return Ok(result); + } + /// ///更新 /// /// diff --git a/Device/DeviceManager.cs b/Device/DeviceManager.cs index ce75e19..f8e71d4 100644 --- a/Device/DeviceManager.cs +++ b/Device/DeviceManager.cs @@ -333,7 +333,7 @@ namespace LY.App.Device { int retryDelay = 1000; // 初始重连间隔(1秒) int maxDelay = 30000; // 最大重连间隔(30秒) - await _log.AddLog(new AddLog { Message = $"设备 {device.Id} 掉线,重新连接中...", Parameters = "", StackTrace = "", url = "" }); + await _log?.AddLog(new AddLog { Message = $"设备 {device.Id} 掉线,重新连接中...", Parameters = "", StackTrace = "", url = "" }); while (!device.IsConnected) { try diff --git a/Model/Alarm.cs b/Model/Alarm.cs index 258881d..9506a5e 100644 --- a/Model/Alarm.cs +++ b/Model/Alarm.cs @@ -57,11 +57,6 @@ namespace LY.App.Model /// [SugarColumn(ColumnName = "rssi", ColumnDescription = "信号增益")] public double RSSI { get; set; } - - /// - /// 无人机型号 - /// - /// /// 位置id /// diff --git a/Program.cs b/Program.cs index 6228714..92f86cb 100644 --- a/Program.cs +++ b/Program.cs @@ -43,7 +43,7 @@ string redisConnection = builder.Configuration.GetValue("Redis:Connectio // ע RedisService builder.Services.AddSingleton(new RedisService(redisConnection)); -//builder.Services.AddTransient(); +builder.Services.AddTransient(); ////עSignalR builder.Services.AddSignalR(); builder.Services.AddHttpClient(); @@ -117,7 +117,7 @@ app.UseCors("CorsPolicy"); //쳣м app.UseMiddleware(); //token֤м -app.UseMiddleware(); +//app.UseMiddleware(); //ִƥĶ˵ app.UseEndpoints(endpoints => { diff --git a/Service/AlarmService.cs b/Service/AlarmService.cs index dcd8b2a..9f4cf1b 100644 --- a/Service/AlarmService.cs +++ b/Service/AlarmService.cs @@ -259,7 +259,7 @@ namespace LY.App.Service .WhereIF(input.strartDate.HasValue, st => st.CreateTime >= input.strartDate.Value) .WhereIF(input.endDate.HasValue, st => st.CreateTime <= input.endDate.Value.AddDays(1)) .OrderBy(s => s.BatchId, OrderByType.Desc) - .GroupBy(s => new { s.BatchId, s.serial_number, s.device_type, s.positionId, s.PostionName }) + .GroupBy(s => new { s.BatchId, s.serial_number, s.device_type, s.positionId, s.PostionName ,s.freq}) .Select(st => new AlarmRepDto { batchId = st.BatchId.ToString(), @@ -285,6 +285,7 @@ namespace LY.App.Service start = start.HasValue ? start.Value : DateTime.Now.AddMonths(-1); end = end.HasValue ? end.Value.AddDays(1) : DateTime.Now.Date.AddDays(1); var query = await _db.Queryable().SplitTable() + .Where(s => s.alarmLevel > 0) .WhereIF(start.HasValue, st => st.CreateTime >= start.Value) .WhereIF(end.HasValue, st => st.CreateTime <= end.Value.AddDays(1)) .GroupBy(s => new { s.BatchId, s.serial_number, s.device_type, s.positionId, s.PostionName, s.DeviceId, s.DeviceName }) @@ -324,15 +325,24 @@ namespace LY.App.Service s.Key.positionName, count = s.Count() }), - hotmap = await GenerateHotMap(query.Select(s => s.batchId).ToList()), - device = query.GroupBy(s => new { s.deviceName }) - .Select(s => new - { - s.Key.deviceName, - count = s.Count() - }), + time = query.GroupBy(s => s.startTime.ToString("HH")) + .Select(it => new + { + it.Key, + count = it.Count() + }), date = query.GroupBy(s => s.startTime.ToString("yyyy-MM-dd")) - .Select(it => new { it.Key, count = it.Count() }) + .Select(it => new + { + it.Key, + count = it.Count() + }), + device = query.GroupBy(s => new { s.deviceName }) + .Select(b => new + { + b.Key.deviceName, + count = b.Count() + }) } }; } diff --git a/Service/DeviceService.cs b/Service/DeviceService.cs index 1f63cff..18736da 100644 --- a/Service/DeviceService.cs +++ b/Service/DeviceService.cs @@ -69,6 +69,22 @@ namespace LY.App.Service }; } /// + /// 获取协议列表 + /// + /// + public Task ProtocolTypeList() + { + var dict = new Dictionary(); + foreach (ProtocolType protocol in Enum.GetValues(typeof(ProtocolType))) + { + dict.Add((int)protocol, protocol.ToString()); + } + return Task.FromResult(new ApiResult() + { + data = dict + }); + } + /// /// 更新设备信息 /// /// diff --git a/Service/LogService.cs b/Service/LogService.cs index 66b2ab4..04a2281 100644 --- a/Service/LogService.cs +++ b/Service/LogService.cs @@ -20,7 +20,7 @@ namespace LY.App.Service public async Task AddLog(AddLog input) { var entity = input.Adapt(); - await _db.Insertable(entity).ExecuteReturnSnowflakeIdAsync(); + await _db?.Insertable(entity).ExecuteReturnSnowflakeIdAsync(); } /// /// 分页查询