|
|
@@ -1,54 +1,63 @@
|
|
|
using System;
|
|
|
using System.IO;
|
|
|
+using Datory;
|
|
|
+using GxPress.Common.AppOptions;
|
|
|
+using GxPress.Common.Tools;
|
|
|
using GxPress.Entity;
|
|
|
using GxPress.Service.Interface;
|
|
|
using Microsoft.AspNetCore.Http;
|
|
|
using Microsoft.Extensions.Configuration;
|
|
|
-using SqlSugar;
|
|
|
+using Microsoft.Extensions.Options;
|
|
|
|
|
|
namespace GxPress.Service.Implement
|
|
|
{
|
|
|
public class ApiLogService : IApiLogService
|
|
|
{
|
|
|
private readonly IConfiguration _configuration;
|
|
|
- private readonly SqlSugarClient _dbContext;
|
|
|
|
|
|
- public ApiLogService(IConfiguration configuration, SqlSugarClient dbContext)
|
|
|
+ private readonly Repository<UserLogin> _repository;
|
|
|
+
|
|
|
+ public ApiLogService(IConfiguration configuration, IOptionsMonitor<DatabaseOptions> dbOptionsAccessor)
|
|
|
{
|
|
|
_configuration = configuration;
|
|
|
- _dbContext = dbContext;
|
|
|
+ var databaseType =
|
|
|
+ StringUtils.ToEnum<DatabaseType>(dbOptionsAccessor.CurrentValue.DatabaseType, DatabaseType.MySql);
|
|
|
+ //_connectionString = dbOptionsAccessor.CurrentValue.ConnectionString;
|
|
|
+ var database = new Database(databaseType, dbOptionsAccessor.CurrentValue.ConnectionString);
|
|
|
+ _repository = new Repository<UserLogin>(database);
|
|
|
}
|
|
|
|
|
|
- public void DataSave(HttpContext context, long responseTime,int userId)
|
|
|
+ public async void DataSave(HttpContext context, long responseTime, int userId)
|
|
|
{
|
|
|
var isLog = _configuration.GetValue<bool>("ApiLog:IsEnable");
|
|
|
- if (isLog)
|
|
|
+ // if (isLog)
|
|
|
+ // {
|
|
|
+ var requestMethod = context.Request.Method;
|
|
|
+ var requestURL = $"{context.Request.Scheme}://{context.Request.Host}{context.Request.Path}";
|
|
|
+ //var accessToken = context.GetTokenAsync("access_token").Result;//添加身份验证的项目可以使用此方法获取到access_toekn
|
|
|
+ var accessToken = string.Empty;
|
|
|
+ var requestBody = string.Empty;
|
|
|
+ if (requestMethod == "POST")
|
|
|
{
|
|
|
- var requestMethod = context.Request.Method;
|
|
|
- var requestURL = $"{context.Request.Scheme}://{context.Request.Host}{context.Request.Path}";
|
|
|
- //var accessToken = context.GetTokenAsync("access_token").Result;//添加身份验证的项目可以使用此方法获取到access_toekn
|
|
|
- var accessToken = string.Empty;
|
|
|
- var requestBody = string.Empty;
|
|
|
- if (requestMethod == "POST")
|
|
|
- {
|
|
|
- context.Request.Body.Seek(0, SeekOrigin.Begin);
|
|
|
- var _reader = new StreamReader(context.Request.Body);
|
|
|
- requestBody = _reader.ReadToEnd();
|
|
|
- }
|
|
|
- _dbContext.Insertable(new UserLogin
|
|
|
- {
|
|
|
- AccessToken = accessToken,
|
|
|
- AccessTime = DateTime.Now,
|
|
|
- AccessAction = requestMethod,
|
|
|
- AccessApiUrl = requestURL,
|
|
|
- QueryString = context.Request.QueryString.ToString(),
|
|
|
- Body = requestBody,
|
|
|
- HttpStatus = context.Response.StatusCode,
|
|
|
- ClientIP = context.Connection.RemoteIpAddress.ToString(),
|
|
|
- ResponseTime = responseTime,
|
|
|
- UserId=userId
|
|
|
- }).ExecuteCommand();
|
|
|
+ context.Request.Body.Seek(0, SeekOrigin.Begin);
|
|
|
+ var _reader = new StreamReader(context.Request.Body);
|
|
|
+ requestBody = _reader.ReadToEnd();
|
|
|
}
|
|
|
+ var model=new UserLogin
|
|
|
+ {
|
|
|
+ AccessToken = accessToken,
|
|
|
+ AccessTime = DateTime.Now,
|
|
|
+ AccessAction = requestMethod,
|
|
|
+ AccessApiUrl = requestURL,
|
|
|
+ QueryString = context.Request.QueryString.ToString(),
|
|
|
+ Body = requestBody,
|
|
|
+ HttpStatus = context.Response.StatusCode,
|
|
|
+ ClientIP = context.Connection.RemoteIpAddress.ToString(),
|
|
|
+ ResponseTime = responseTime,
|
|
|
+ UserId = userId
|
|
|
+ };
|
|
|
+ await _repository.InsertAsync(model);
|
|
|
+ //}
|
|
|
}
|
|
|
}
|
|
|
}
|
李昊