86 lines
4.2 KiB
C#
86 lines
4.2 KiB
C#
using Longbow.Cache;
|
|
using Longbow.Data;
|
|
using Longbow.Logging;
|
|
using Longbow.Web.WebSockets;
|
|
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Collections.Specialized;
|
|
using System.Data;
|
|
using System.Data.Common;
|
|
using System.Text;
|
|
|
|
namespace Bootstrap.DataAccess
|
|
{
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
public static class ExceptionHelper
|
|
{
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
public static readonly string RetrieveExceptionsDataKey = "ExceptionHelper-RetrieveExceptions";
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="ex"></param>
|
|
/// <param name="additionalInfo"></param>
|
|
/// <returns></returns>
|
|
public static void Log(Exception ex, NameValueCollection additionalInfo)
|
|
{
|
|
var sql = "insert into Exceptions (AppDomainName, ErrorPage, UserID, UserIp, ExceptionType, Message, StackTrace, LogTime) values (@AppDomainName, @ErrorPage, @UserID, @UserIp, @ExceptionType, @Message, @StackTrace, GetDate())";
|
|
using (DbCommand cmd = DBAccessManager.SqlDBAccess.CreateCommand(CommandType.Text, sql))
|
|
{
|
|
cmd.Parameters.Add(DBAccessManager.SqlDBAccess.CreateParameter("@AppDomainName", AppDomain.CurrentDomain.FriendlyName));
|
|
cmd.Parameters.Add(DBAccessManager.SqlDBAccess.CreateParameter("@ErrorPage", DBAccessFactory.ToDBValue(additionalInfo["ErrorPage"])));
|
|
cmd.Parameters.Add(DBAccessManager.SqlDBAccess.CreateParameter("@UserID", DBAccessFactory.ToDBValue(additionalInfo["UserId"])));
|
|
cmd.Parameters.Add(DBAccessManager.SqlDBAccess.CreateParameter("@UserIp", DBAccessFactory.ToDBValue(additionalInfo["UserIp"])));
|
|
cmd.Parameters.Add(DBAccessManager.SqlDBAccess.CreateParameter("@ExceptionType", ex.GetType().FullName));
|
|
cmd.Parameters.Add(DBAccessManager.SqlDBAccess.CreateParameter("@Message", ex.Message));
|
|
cmd.Parameters.Add(DBAccessManager.SqlDBAccess.CreateParameter("@StackTrace", DBAccessFactory.ToDBValue(ex.StackTrace)));
|
|
DBAccessManager.SqlDBAccess.ExecuteNonQuery(cmd);
|
|
CacheManager.Clear(RetrieveExceptionsDataKey);
|
|
if (ex.GetType().IsSubclassOf(typeof(DbException)))
|
|
WebSocketServerManager.SendAsync(new ArraySegment<byte>(Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(new List<object> { new { Category = "Notification", ex.Message } }))));
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 查询所有异常
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public static IEnumerable<Exceptions> RetrieveExceptions()
|
|
{
|
|
return CacheManager.GetOrAdd(RetrieveExceptionsDataKey, key =>
|
|
{
|
|
string sql = "select top 1000 * from Exceptions order by LogTime desc";
|
|
List<Exceptions> exceptions = new List<Exceptions>();
|
|
DbCommand cmd = DBAccessManager.SqlDBAccess.CreateCommand(CommandType.Text, sql);
|
|
try
|
|
{
|
|
using (DbDataReader reader = DBAccessManager.SqlDBAccess.ExecuteReader(cmd))
|
|
{
|
|
while (reader.Read())
|
|
{
|
|
exceptions.Add(new Exceptions()
|
|
{
|
|
Id = (int)reader[0],
|
|
AppDomainName = (string)reader[1],
|
|
ErrorPage = (string)reader[2],
|
|
UserId = reader.IsDBNull(3) ? string.Empty : (string)reader[3],
|
|
UserIp = reader.IsDBNull(4) ? string.Empty : (string)reader[4],
|
|
ExceptionType = (string)reader[5],
|
|
Message = (string)reader[6],
|
|
StackTrace = (string)reader[7],
|
|
LogTime = (DateTime)reader[8],
|
|
});
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex) { ExceptionManager.Publish(ex); }
|
|
return exceptions;
|
|
});
|
|
}
|
|
}
|
|
}
|