// Admin.NET 项目的版æƒã€å•†æ ‡ã€ä¸“利和其他相关æƒåˆ©å‡å—ç›¸åº”æ³•å¾‹æ³•è§„çš„ä¿æŠ¤ã€‚ä½¿ç”¨æœ¬é¡¹ç›®åº”éµå®ˆç›¸å…³æ³•律法规和许å¯è¯çš„è¦æ±‚。 // // 本项目主è¦éµå¾ª MIT 许å¯è¯å’Œ Apache 许å¯è¯ï¼ˆç‰ˆæœ¬ 2.0)进行分å‘和使用。许å¯è¯ä½äºŽæºä»£ç æ ‘æ ¹ç›®å½•ä¸çš„ LICENSE-MIT å’Œ LICENSE-APACHE 文件。 // // ä¸å¾—利用本项目从事å±å®³å›½å®¶å®‰å…¨ã€æ‰°ä¹±ç¤¾ä¼šç§©åºã€ä¾µçŠ¯ä»–äººåˆæ³•æƒç›Šç‰æ³•å¾‹æ³•è§„ç¦æ¢çš„æ´»åЍï¼ä»»ä½•基于本项目二次开å‘è€Œäº§ç”Ÿçš„ä¸€åˆ‡æ³•å¾‹çº çº·å’Œè´£ä»»ï¼Œæˆ‘ä»¬ä¸æ‰¿æ‹…ä»»ä½•è´£ä»»ï¼ using Elastic.Clients.Elasticsearch; namespace Admin.NET.Core; /// <summary> /// ES日志写入器 /// </summary> public class ElasticSearchLoggingWriter : IDatabaseLoggingWriter, IDisposable { private readonly IServiceScope _serviceScope; private readonly ElasticsearchClient _esClient; private readonly SysConfigService _sysConfigService; public ElasticSearchLoggingWriter(IServiceScopeFactory scopeFactory) { _serviceScope = scopeFactory.CreateScope(); _esClient = _serviceScope.ServiceProvider.GetRequiredService<ElasticsearchClient>(); _sysConfigService = _serviceScope.ServiceProvider.GetRequiredService<SysConfigService>(); } public async Task WriteAsync(LogMessage logMsg, bool flush) { // 是å¦å¯ç”¨æ“作日志 var sysOpLogEnabled = await _sysConfigService.GetConfigValue<bool>(ConfigConst.SysOpLog); if (!sysOpLogEnabled) return; var jsonStr = logMsg.Context?.Get("loggingMonitor")?.ToString(); if (string.IsNullOrWhiteSpace(jsonStr)) return; var loggingMonitor = JSON.Deserialize<dynamic>(jsonStr); // ä¸è®°å½•登录退出日志 if (loggingMonitor.actionName == "userInfo" || loggingMonitor.actionName == "logout") return; // 获å–当剿“作者 string account = "", realName = "", userId = "", tenantId = ""; if (loggingMonitor.authorizationClaims != null) { foreach (var item in loggingMonitor.authorizationClaims) { if (item.type == ClaimConst.Account) account = item.value; if (item.type == ClaimConst.RealName) realName = item.value; if (item.type == ClaimConst.TenantId) tenantId = item.value; if (item.type == ClaimConst.UserId) userId = item.value; } } string remoteIPv4 = loggingMonitor.remoteIPv4; (string ipLocation, double? longitude, double? latitude) = CommonUtil.GetIpAddress(remoteIPv4); var sysLogOp = new SysLogOp { Id = DateTime.Now.Ticks, ControllerName = loggingMonitor.controllerName, ActionName = loggingMonitor.actionTypeName, DisplayTitle = loggingMonitor.displayTitle, Status = loggingMonitor.returnInformation.httpStatusCode, RemoteIp = remoteIPv4, Location = ipLocation, Longitude = longitude, Latitude = latitude, Browser = loggingMonitor.userAgent, Os = loggingMonitor.osDescription + " " + loggingMonitor.osArchitecture, Elapsed = loggingMonitor.timeOperationElapsedMilliseconds, LogDateTime = logMsg.LogDateTime, Account = account, RealName = realName, HttpMethod = loggingMonitor.httpMethod, RequestUrl = loggingMonitor.requestUrl, RequestParam = (loggingMonitor.parameters == null || loggingMonitor.parameters.Count == 0) ? null : JSON.Serialize(loggingMonitor.parameters[0].value), ReturnResult = JSON.Serialize(loggingMonitor.returnInformation), EventId = logMsg.EventId.Id, ThreadId = logMsg.ThreadId, TraceId = logMsg.TraceId, Exception = (loggingMonitor.exception == null) ? null : JSON.Serialize(loggingMonitor.exception), Message = logMsg.Message, CreateUserId = string.IsNullOrWhiteSpace(userId) ? 0 : long.Parse(userId), TenantId = string.IsNullOrWhiteSpace(tenantId) ? 0 : long.Parse(tenantId) }; await _esClient.IndexAsync(sysLogOp); } /// <summary> /// 释放æœåŠ¡ä½œç”¨åŸŸ /// </summary> public void Dispose() { _serviceScope.Dispose(); } }