/***********************************************************************
|
* Project: baifenBinfa.Net *
|
* Web: https://baifenBinfa.com *
|
* ProjectName: 百分兵法管理系统 *
|
* Author: *
|
* Email: *
|
* Versions: 1.0 *
|
* CreateTime: 2020-02-03 23:05:12
|
* FileName: LogLockHelper
|
* ClassDescription:
|
***********************************************************************/
|
|
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using CoreCms.Net.Model.ViewModels.LogInfo;
|
using CoreCms.Net.Utility.Extensions;
|
using Newtonsoft.Json;
|
|
namespace CoreCms.Net.Loging
|
{
|
/// <summary>
|
/// 日志锁
|
/// </summary>
|
public class LogLockHelper
|
{
|
|
static ReaderWriterLockSlim LogWriteLock = new ReaderWriterLockSlim();
|
static int WritedCount = 0;
|
static int FailedCount = 0;
|
static string _contentRoot = string.Empty;
|
|
public LogLockHelper(string contentPath)
|
{
|
_contentRoot = contentPath;
|
}
|
|
public static void OutSql2Log(string rootPath, string filename, string[] dataParas, bool IsHeader = true)
|
{
|
try
|
{
|
//设置读写锁为写入模式独占资源，其他写入请求需要等待本次写入结束之后才能继续写入
|
//注意：长时间持有读线程锁或写线程锁会使其他线程发生饥饿 (starve)。 为了得到最好的性能，需要考虑重新构造应用程序以将写访问的持续时间减少到最小。
|
// 从性能方面考虑，请求进入写入模式应该紧跟文件操作之前，在此处进入写入模式仅是为了降低代码复杂度
|
// 因进入与退出写入模式应在同一个try finally语句块内，所以在请求进入写入模式之前不能触发异常，否则释放次数大于请求次数将会触发异常
|
LogWriteLock.EnterWriteLock();
|
|
var path = Path.Combine(_contentRoot, "App_Data/" + rootPath);
|
if (!Directory.Exists(path))
|
{
|
Directory.CreateDirectory(path);
|
}
|
string logFilePath = Path.Combine(path, $@"{filename}.log");
|
|
var now = DateTime.Now;
|
string logContent = String.Join("\r\n", dataParas);
|
if (IsHeader)
|
{
|
logContent = (
|
"--------------------------------\r\n" +
|
DateTime.Now + "|\r\n" +
|
String.Join("\r\n", dataParas) + "\r\n"
|
);
|
}
|
|
File.AppendAllText(logFilePath, logContent);
|
WritedCount++;
|
}
|
catch (Exception e)
|
{
|
Console.Write(e.Message);
|
FailedCount++;
|
}
|
finally
|
{
|
//退出写入模式，释放资源占用
|
//注意：一次请求对应一次释放
|
// 若释放次数大于请求次数将会触发异常[写入锁定未经保持即被释放]
|
// 若请求处理完成后未释放将会触发异常[此模式不下允许以递归方式获取写入锁定]
|
LogWriteLock.ExitWriteLock();
|
}
|
}
|
|
public static string ReadLog(string Path, Encoding encode)
|
{
|
string s = "";
|
try
|
{
|
LogWriteLock.EnterReadLock();
|
|
if (!System.IO.File.Exists(Path))
|
{
|
s = null;
|
}
|
else
|
{
|
StreamReader f2 = new StreamReader(Path, encode);
|
s = f2.ReadToEnd();
|
f2.Close();
|
f2.Dispose();
|
}
|
}
|
catch (Exception)
|
{
|
FailedCount++;
|
}
|
finally
|
{
|
LogWriteLock.ExitReadLock();
|
}
|
return s;
|
}
|
|
|
public static List<LogInfo> GetLogData()
|
{
|
List<LogInfo> aopLogs = new List<LogInfo>();
|
List<LogInfo> excLogs = new List<LogInfo>();
|
List<LogInfo> sqlLogs = new List<LogInfo>();
|
List<LogInfo> reqresLogs = new List<LogInfo>();
|
|
try
|
{
|
var aoplogContent = ReadLog(Path.Combine(_contentRoot, "Logs", "AOPLog.log"), Encoding.UTF8);
|
|
if (!string.IsNullOrEmpty(aoplogContent))
|
{
|
aopLogs = aoplogContent.Split("--------------------------------")
|
.Where(d => !string.IsNullOrEmpty(d) && d != "\n" && d != "\r\n")
|
.Select(d => new LogInfo
|
{
|
Datetime = d.Split("|")[0].ObjectToDate(),
|
Content = d.Split("|")[1]?.Replace("\r\n", "<br>"),
|
LogColor = "AOP",
|
}).ToList();
|
}
|
}
|
catch (Exception) { }
|
|
try
|
{
|
var exclogContent = ReadLog(Path.Combine(_contentRoot, "Logs", $"GlobalExcepLogs_{DateTime.Now.ToString("yyyMMdd")}.log"), Encoding.UTF8);
|
|
if (!string.IsNullOrEmpty(exclogContent))
|
{
|
excLogs = exclogContent.Split("--------------------------------")
|
.Where(d => !string.IsNullOrEmpty(d) && d != "\n" && d != "\r\n")
|
.Select(d => new LogInfo
|
{
|
Datetime = (d.Split("|")[0]).Split(',')[0].ObjectToDate(),
|
Content = d.Split("|")[1]?.Replace("\r\n", "<br>"),
|
LogColor = "EXC",
|
Import = 9,
|
}).ToList();
|
}
|
}
|
catch (Exception) { }
|
|
try
|
{
|
var sqllogContent = ReadLog(Path.Combine(_contentRoot, "Logs", "SqlLog.log"), Encoding.UTF8);
|
|
if (!string.IsNullOrEmpty(sqllogContent))
|
{
|
sqlLogs = sqllogContent.Split("--------------------------------")
|
.Where(d => !string.IsNullOrEmpty(d) && d != "\n" && d != "\r\n")
|
.Select(d => new LogInfo
|
{
|
Datetime = d.Split("|")[0].ObjectToDate(),
|
Content = d.Split("|")[1]?.Replace("\r\n", "<br>"),
|
LogColor = "SQL",
|
}).ToList();
|
}
|
}
|
catch (Exception) { }
|
|
try
|
{
|
var Logs = JsonConvert.DeserializeObject<List<RequestInfo>>("[" + ReadLog(Path.Combine(_contentRoot, "Logs", "RequestIpInfoLog.log"), Encoding.UTF8) + "]");
|
|
Logs = Logs.Where(d => d.Datetime.ObjectToDate() >= DateTime.Today).ToList();
|
|
reqresLogs = Logs.Select(d => new LogInfo
|
{
|
Datetime = d.Datetime.ObjectToDate(),
|
Content = $"IP:{d.Ip}<br>{d.Url}",
|
LogColor = "ReqRes",
|
}).ToList();
|
}
|
catch (Exception)
|
{
|
}
|
|
if (excLogs != null)
|
{
|
aopLogs.AddRange(excLogs);
|
}
|
if (sqlLogs != null)
|
{
|
aopLogs.AddRange(sqlLogs);
|
}
|
if (reqresLogs != null)
|
{
|
aopLogs.AddRange(reqresLogs);
|
}
|
aopLogs = aopLogs.OrderByDescending(d => d.Import).ThenByDescending(d => d.Datetime).Take(100).ToList();
|
|
return aopLogs;
|
}
|
|
|
public static RequestApiWeekView RequestApiinfoByWeek()
|
{
|
List<RequestInfo> Logs = new List<RequestInfo>();
|
List<ApiWeek> apiWeeks = new List<ApiWeek>();
|
string apiWeeksJson = string.Empty;
|
List<string> columns = new List<string>();
|
columns.Add("日期");
|
|
|
try
|
{
|
Logs = JsonConvert.DeserializeObject<List<RequestInfo>>("[" + ReadLog(Path.Combine(_contentRoot, "Logs", "RequestIpInfoLog.log"), Encoding.UTF8) + "]");
|
|
var ddd = Logs.Where(d => d.Week == "周日").ToList();
|
|
apiWeeks = (from n in Logs
|
group n by new { n.Week, n.Url } into g
|
select new ApiWeek
|
{
|
week = g.Key.Week,
|
url = g.Key.Url,
|
count = g.Count(),
|
}).ToList();
|
|
//apiWeeks = apiWeeks.OrderByDescending(d => d.count).Take(8).ToList();
|
|
}
|
catch (Exception)
|
{
|
}
|
|
StringBuilder jsonBuilder = new StringBuilder();
|
jsonBuilder.Append("[");
|
|
var weeks = apiWeeks.GroupBy(x => new { x.week }).Select(s => s.First()).ToList();
|
foreach (var week in weeks)
|
{
|
var apiweeksCurrentWeek = apiWeeks.Where(d => d.week == week.week).OrderByDescending(d => d.count).Take(8).ToList();
|
jsonBuilder.Append("{");
|
|
jsonBuilder.Append("\"");
|
jsonBuilder.Append("日期");
|
jsonBuilder.Append("\":\"");
|
jsonBuilder.Append(week.week);
|
jsonBuilder.Append("\",");
|
|
foreach (var item in apiweeksCurrentWeek)
|
{
|
jsonBuilder.Append("\"");
|
jsonBuilder.Append(item.url);
|
jsonBuilder.Append("\":\"");
|
jsonBuilder.Append(item.count);
|
jsonBuilder.Append("\",");
|
}
|
jsonBuilder.Remove(jsonBuilder.Length - 1, 1);
|
jsonBuilder.Append("},");
|
}
|
|
jsonBuilder.Remove(jsonBuilder.Length - 1, 1);
|
jsonBuilder.Append("]");
|
|
columns.AddRange(apiWeeks.OrderByDescending(d => d.count).Take(8).Select(d => d.url).ToList());
|
|
return new RequestApiWeekView()
|
{
|
columns = columns,
|
rows = jsonBuilder.ToString(),
|
};
|
}
|
|
public static AccessApiDateView AccessApiByDate()
|
{
|
List<RequestInfo> Logs = new List<RequestInfo>();
|
List<ApiDate> apiDates = new List<ApiDate>();
|
try
|
{
|
Logs = JsonConvert.DeserializeObject<List<RequestInfo>>("[" + ReadLog(Path.Combine(_contentRoot, "Logs", "RequestIpInfoLog.log"), Encoding.UTF8) + "]");
|
|
apiDates = (from n in Logs
|
group n by new { n.Date } into g
|
select new ApiDate
|
{
|
date = g.Key.Date,
|
count = g.Count(),
|
}).ToList();
|
|
apiDates = apiDates.OrderByDescending(d => d.date).Take(7).ToList();
|
|
}
|
catch (Exception)
|
{
|
}
|
|
return new AccessApiDateView()
|
{
|
columns = new string[] { "date", "count" },
|
rows = apiDates.OrderBy(d => d.date).ToList(),
|
};
|
}
|
|
public static AccessApiDateView AccessApiByHour()
|
{
|
List<RequestInfo> Logs = new List<RequestInfo>();
|
List<ApiDate> apiDates = new List<ApiDate>();
|
try
|
{
|
Logs = JsonConvert.DeserializeObject<List<RequestInfo>>("[" + ReadLog(Path.Combine(_contentRoot, "Logs", "RequestIpInfoLog.log"), Encoding.UTF8) + "]");
|
|
apiDates = (from n in Logs
|
where n.Datetime.ObjectToDate() >= DateTime.Today
|
group n by new { hour = n.Datetime.ObjectToDate().Hour } into g
|
select new ApiDate
|
{
|
date = g.Key.hour.ToString("00"),
|
count = g.Count(),
|
}).ToList();
|
|
apiDates = apiDates.OrderBy(d => d.date).Take(24).ToList();
|
|
}
|
catch (Exception)
|
{
|
}
|
|
return new AccessApiDateView()
|
{
|
columns = new string[] { "date", "count" },
|
rows = apiDates,
|
};
|
}
|
}
|
|
}
|
