feat(api): статистика запросов на авторизацию не из КЭШа

2024-06-03 11:52:24 +10:00
parent f4ec3448ae
commit faab4a6664
4 changed files with 95 additions and 0 deletions
--- a/PARR.API/Controllers/V1/Statistics/StatAuthController.cs
+++ b/PARR.API/Controllers/V1/Statistics/StatAuthController.cs
@@ -0,0 +1,70 @@
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using PARR.API.Contracts.V1;
+using PARR.API.Contracts.V1.Requests.Queries;
+using PARR.API.Contracts.V1.Responses.Base;
+using PARR.API.Contracts.V1.Responses.Statistics;
+using PARR.API.Controllers.V1.Base;
+using PARR.Constants;
+using PARR.DAL.InfluxDbServices;
+using PARR.DAL.Settings;
+
+namespace PARR.API.Controllers.V1.Statistics
+{
+    /// <summary>
+    /// Статистика по авторизации
+    /// </summary>
+    [Authorize(Roles = ParrRoles.EsppRobot.RoleOrAdmin)]
+    public class StatAuthController : BaseApiController
+    {
+        private readonly IInfluxDbService influxDbService;
+        private readonly InfluxDbSettings influxDbSettings;
+
+        public StatAuthController(
+              IInfluxDbService influxDbService,
+              InfluxDbSettings influxDbSettings
+              )
+        {
+            this.influxDbService = influxDbService;
+            this.influxDbSettings = influxDbSettings;
+        }
+
+
+        /// <summary>
+        /// Кол-во запросов на авторизацию не из КЭШа
+        /// </summary>
+        /// <returns></returns>
+        [HttpGet(ApiRoutes.StatAuth.Get)]
+        public async Task<IActionResult> Get([FromQuery] StatAuthGetQuery query)
+        {
+            var startAt = string.IsNullOrEmpty(query.StartAt) ? "-2h" : query.StartAt;
+
+            var result = await influxDbService.QueryAsync(async handler =>
+            {
+                var query = $"from(bucket: \"{influxDbSettings.Logons!.Bucket}\")  " +
+                                $"|> range(start: {startAt})  " +
+                                $"|> filter(fn: (r) => r._measurement == \"logon\")  " +
+                                $"|> drop(columns: [\"HostId\", \"UserId\"])  " +
+                                $"|> aggregateWindow(every: 5m, fn: count)";
+
+                var tables = await handler.QueryAsync(query, influxDbSettings.Organization);
+
+                return tables.SelectMany(table =>
+
+                    table.Records.Select(record => new StatAuthResponse
+                    {
+                        Date = (DateTimeOffset)record.GetTimeInDateTime(),
+                        Count = int.Parse(record.GetValue()?.ToString() ?? "0")
+                    })
+                );
+            }, influxDbSettings.Logons!.Token);
+
+            if (result == null)
+                return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = $"Ошибка при получении статистики" } }));
+
+
+            return Ok(new Response<List<StatAuthResponse>>(result.ToList(), true));
+        }
+
+    }
+}