335 lines
15 KiB
C#
335 lines
15 KiB
C#
using APT.BaseData.Domain.Entities;
|
||
using APT.BaseData.Domain.Enums;
|
||
using APT.Infrastructure.Core;
|
||
using APT.BaseData.Domain.Entities.FM;
|
||
using APT.BaseData.Domain.IServices.FM;
|
||
using System;
|
||
using System.Linq;
|
||
using System.Net;
|
||
using APT.Infrastructure.Api;
|
||
namespace APT.BaseData.Services.Services.FM
|
||
{
|
||
public class PFSysLogService : CommonService, IPFSysLogService
|
||
{
|
||
public PFSysLogService(IRepository repository)
|
||
: base(repository)
|
||
{
|
||
}
|
||
|
||
/// <summary>
|
||
/// 添加登入系统日志
|
||
/// </summary>
|
||
/// <param name="userId"></param>
|
||
/// <param name="platformType">平台类型 PFPlatTypeEnum</param>
|
||
public void AddLoginLog(Guid userId, int platformType)
|
||
{
|
||
var user = this.GetEntity<T_FM_USER>(userId.ToString());
|
||
if (user != null)
|
||
AddLog(user.ORG_ID.Value, userId, PFSysLogTypeEnum.登入,
|
||
string.Format("用户【{0}】登入{1}系统", user.NAME, ((PFPlatTypeEnum)platformType).ToString()),
|
||
string.Format("用户ID：{0}", userId.ToString()));
|
||
}
|
||
public void AddLoginLogByApp(Guid userId, int platformType,KeywordFilter filter)
|
||
{
|
||
var user = this.GetEntity<T_FM_USER>(x=>x.ID== userId, filter);
|
||
if (user != null)
|
||
AddLog(user.ORG_ID.Value, userId, PFSysLogTypeEnum.登入,
|
||
string.Format("用户【{0}】登入{1}系统", user.NAME, ((PFPlatTypeEnum)platformType).ToString()),
|
||
string.Format("用户ID：{0}", userId.ToString()),filter);
|
||
}
|
||
/// <summary>
|
||
/// 添加登出系统日志
|
||
/// </summary>
|
||
/// <param name="userId"></param>
|
||
/// <param name="platformType">平台类型 PFPlatTypeEnum</param>
|
||
public void AddLoginOut(Guid userId, int platformType)
|
||
{
|
||
var user = this.GetEntity<T_FM_USER>(userId.ToString());
|
||
if (user != null)
|
||
AddLog(user.ORG_ID.Value, userId, PFSysLogTypeEnum.登出,
|
||
string.Format("用户【{0}】退出{1}系统", user.NAME, ((PFPlatTypeEnum)platformType).ToString()),
|
||
string.Format("用户ID：{0}", userId.ToString()));
|
||
}
|
||
|
||
/// <summary>
|
||
/// 添加新增日志
|
||
/// </summary>
|
||
/// <param name="userId"></param>
|
||
/// <param name="formCode"></param>
|
||
/// <param name="ids">实体ID列表 多个逗号隔开</param>
|
||
/// <param name="codes">实体编号 多个逗号隔开</param>
|
||
/// <param name="extData">额外数据</param>
|
||
public void AddAddLog(Guid userId, string formCode, string ids, string codes, string extData)
|
||
{
|
||
var user = this.GetEntity<T_FM_USER>(userId.ToString());
|
||
if (user != null)
|
||
{
|
||
T_PF_FORM form = null;
|
||
if (!string.IsNullOrEmpty(formCode))
|
||
form = this.GetEntity<T_PF_FORM>(t => t.CODE == formCode, new BaseFilter(user.ORG_ID));
|
||
AddLog(user.ORG_ID.Value, userId, PFSysLogTypeEnum.新增, formCode,
|
||
string.Format("用户【{0}】:新增{1}{2}", user.NAME, (form == null ? string.Empty : ("表单:" + form.NAME)), (string.IsNullOrEmpty(codes) ? string.Empty : (",编号:" + codes))),
|
||
string.Format("ID：{0}", ids), extData);
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 添加编辑日志
|
||
/// </summary>
|
||
/// <param name="userId"></param>
|
||
/// <param name="formCode"></param>
|
||
/// <param name="ids">实体ID列表 多个逗号隔开</param>
|
||
/// <param name="codes">实体编号 多个逗号隔开</param>
|
||
/// <param name="extData">额外数据</param>
|
||
public void AddEditLog(Guid userId, string formCode, string ids, string codes, string extData)
|
||
{
|
||
var user = this.GetEntity<T_FM_USER>(userId.ToString());
|
||
if (user != null)
|
||
{
|
||
T_PF_FORM form = null;
|
||
if (!string.IsNullOrEmpty(formCode))
|
||
form = this.GetEntity<T_PF_FORM>(t => t.CODE == formCode, new BaseFilter(user.ORG_ID));
|
||
AddLog(user.ORG_ID.Value, userId, PFSysLogTypeEnum.编辑, formCode,
|
||
string.Format("用户【{0}】:编辑{1}{2}", user.NAME, (form == null ? string.Empty : ("表单:" + form.NAME)), (string.IsNullOrEmpty(codes) ? string.Empty : (",编号:" + codes))),
|
||
string.Format("ID：{0}", ids), extData);
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 添加删除日志
|
||
/// </summary>
|
||
/// <param name="userId"></param>
|
||
/// <param name="formCode"></param>
|
||
/// <param name="ids">实体ID列表 多个逗号隔开</param>
|
||
/// <param name="tableName">实体名称</param>
|
||
/// <param name="extData">额外数据</param>
|
||
public void AddDeleteLog(Guid userId, string formCode, string ids, string tableName,string extData)
|
||
{
|
||
var user = this.GetEntity<T_FM_USER>(userId.ToString());
|
||
if (user != null)
|
||
{
|
||
T_PF_FORM form = null;
|
||
if (!string.IsNullOrEmpty(formCode))
|
||
form = this.GetEntity<T_PF_FORM>(t => t.CODE == formCode, new BaseFilter(user.ORG_ID));
|
||
AddLog(user.ORG_ID.Value, userId, PFSysLogTypeEnum.删除, formCode,
|
||
string.Format("用户【{0}】删除{1}", user.NAME, (form == null ? string.Empty : ("表单:" + form.NAME))),
|
||
string.Format("ID：{0},{1}", ids, (string.IsNullOrEmpty(tableName) ? string.Empty : ("表名:" + tableName))),
|
||
extData);
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 添加其他日志
|
||
/// </summary>
|
||
/// <param name="userId"></param>
|
||
/// <param name="formCode"></param>
|
||
/// <param name="title">标题</param>
|
||
/// <param name="data">数据</param>
|
||
/// <param name="extData">额外数据</param>
|
||
public void AddOtherLog(Guid userId, string formCode, string title, string data, string extData)
|
||
{
|
||
var user = this.GetEntity<T_FM_USER>(userId.ToString());
|
||
if (user != null)
|
||
{
|
||
AddLog(user.ORG_ID.Value, userId, PFSysLogTypeEnum.其他, formCode,
|
||
title, data, extData);
|
||
}
|
||
}
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 添加系统日志
|
||
/// </summary>
|
||
/// <param name="orgId">组织</param>
|
||
/// <param name="userId">用户</param>
|
||
/// <param name="type">类型</param>
|
||
/// <param name="title">标题</param>
|
||
/// <param name="data">数据</param>
|
||
public void AddLog(Guid orgId, Guid userId, PFSysLogTypeEnum type, string title, string data)
|
||
{
|
||
this.AddLog(orgId, userId, type, string.Empty, title, data, string.Empty);
|
||
}
|
||
public void AddLog(Guid orgId, Guid userId, PFSysLogTypeEnum type, string title, string data, KeywordFilter filter)
|
||
{
|
||
this.AddLog(orgId, userId, type, string.Empty, title, data, string.Empty, filter);
|
||
}
|
||
/// <summary>
|
||
/// 添加系统日志
|
||
/// </summary>
|
||
/// <param name="orgId">组织</param>
|
||
/// <param name="userId">用户</param>
|
||
/// <param name="title">标题</param>
|
||
/// <param name="data">数据</param>
|
||
public void AddLog(Guid orgId, Guid userId, string title, string data)
|
||
{
|
||
this.AddLog(orgId, userId, title, data, string.Empty);
|
||
}
|
||
/// <summary>
|
||
/// 添加系统日志
|
||
/// </summary>
|
||
/// <param name="orgId">组织</param>
|
||
/// <param name="userId">用户</param>
|
||
/// <param name="title">标题</param>
|
||
/// <param name="data">数据</param>
|
||
/// <param name="extData">额外数据</param>
|
||
public void AddLog(Guid orgId, Guid userId, string title, string data, string extData)
|
||
{
|
||
this.AddLog(orgId, userId, null, title, data, extData);
|
||
}
|
||
/// <summary>
|
||
/// 添加系统日志
|
||
/// </summary>
|
||
/// <param name="orgId">组织</param>
|
||
/// <param name="userId">用户</param>
|
||
/// <param name="formCode">表单</param>
|
||
/// <param name="title">标题</param>
|
||
/// <param name="data">数据</param>
|
||
/// <param name="extData">额外数据</param>
|
||
public void AddLog(Guid orgId, Guid userId, string formCode, string title, string data, string extData)
|
||
{
|
||
this.AddLog(orgId, userId, PFSysLogTypeEnum.其他, formCode, title, data, extData);
|
||
}
|
||
/// <summary>
|
||
/// 添加系统日志
|
||
/// </summary>
|
||
/// <param name="orgId">组织</param>
|
||
/// <param name="userId">用户</param>
|
||
/// <param name="type">类型</param>
|
||
/// <param name="formCode">表单编号</param>
|
||
/// <param name="title">标题</param>
|
||
/// <param name="data">数据</param>
|
||
/// <param name="extData">额外数据</param>
|
||
public void AddLog(Guid orgId, Guid userId, PFSysLogTypeEnum type, string formCode, string title, string data, string extData)
|
||
{
|
||
var sysLog = this.DoAddLog(orgId, userId, type, formCode, title, data, extData);
|
||
this.AddEntity(sysLog);
|
||
}
|
||
public void AddLog(Guid orgId, Guid userId, PFSysLogTypeEnum type, string formCode, string title, string data,
|
||
string extData, KeywordFilter filter)
|
||
{
|
||
var sysLog = this.DoAddLog(orgId, userId, type, formCode, title, data, extData, filter);
|
||
this.AddEntityByConn(sysLog,filter.SpecifyDbConn);
|
||
}
|
||
private T_PF_SYS_LOG DoAddLog(Guid orgId, Guid userId, PFSysLogTypeEnum type, string formCode, string title, string data, string extData)
|
||
{
|
||
var httpRequest = HttpContext.Current.Request;
|
||
string ip = string.Empty;
|
||
string ipv4 = string.Empty;
|
||
string hostName = string.Empty;
|
||
string browser = string.Empty;
|
||
if (httpRequest.HttpContext.Connection.RemoteIpAddress != null)
|
||
ip = httpRequest.HttpContext.Request.Headers["X-Forwarded-For"];
|
||
if (string.IsNullOrEmpty(ip))
|
||
ip = httpRequest.Host.Host;
|
||
try
|
||
{
|
||
foreach (IPAddress ipAddr in Dns.GetHostEntry(ip).AddressList)
|
||
{
|
||
if (ipAddr.AddressFamily.ToString() == "InterNetwork")
|
||
{
|
||
ipv4 = ipAddr.ToString();
|
||
}
|
||
}
|
||
}
|
||
catch { }
|
||
try
|
||
{
|
||
hostName = Dns.GetHostEntry(ip).HostName;
|
||
}
|
||
catch { }
|
||
if (string.IsNullOrEmpty(hostName) && string.Compare(ip, httpRequest.HttpContext.Request.Host.Value, true) != 0)
|
||
hostName = httpRequest.HttpContext.Request.Host.Value;
|
||
if (httpRequest.HttpContext.Request.Headers["User-Agent"].Count >= 0)
|
||
browser = httpRequest.HttpContext.Request.Headers["User-Agent"].FirstOrDefault();
|
||
|
||
T_PF_SYS_LOG sysLog = new T_PF_SYS_LOG();
|
||
sysLog.ID = Guid.NewGuid();
|
||
sysLog.ORG_ID = orgId;
|
||
sysLog.LOG_TYPE = (int)type;
|
||
sysLog.USER_ID = userId;
|
||
sysLog.LOG_TIME = DateTime.Now;
|
||
sysLog.LOG_TITLE = title;
|
||
sysLog.LOG_DATA = data;
|
||
sysLog.EXT_DATA = extData;
|
||
sysLog.HOST_NAME = (string.IsNullOrEmpty(hostName) ? string.Empty : string.Format("主机名:{0},", hostName))
|
||
+ (string.IsNullOrEmpty(ipv4) ? string.Empty : string.Format("IP:{0}", ipv4));
|
||
sysLog.BROWSER_NAME = browser;
|
||
if (!string.IsNullOrEmpty(formCode))
|
||
{
|
||
var form = this.GetEntity<T_PF_FORM>(t => t.CODE == formCode, new BaseFilter(orgId));
|
||
if (form != null)
|
||
sysLog.LOG_FORM_ID = form.ID;
|
||
}
|
||
return sysLog;
|
||
}
|
||
/// <summary>
|
||
/// APP登录 多库
|
||
/// </summary>
|
||
/// <param name="orgId"></param>
|
||
/// <param name="userId"></param>
|
||
/// <param name="type"></param>
|
||
/// <param name="formCode"></param>
|
||
/// <param name="title"></param>
|
||
/// <param name="data"></param>
|
||
/// <param name="extData"></param>
|
||
/// <returns></returns>
|
||
private T_PF_SYS_LOG DoAddLog(Guid orgId, Guid userId, PFSysLogTypeEnum type, string formCode,
|
||
string title, string data, string extData, KeywordFilter filter)
|
||
{
|
||
var httpRequest = HttpContext.Current.Request;
|
||
string ip = string.Empty;
|
||
string ipv4 = string.Empty;
|
||
string hostName = string.Empty;
|
||
string browser = string.Empty;
|
||
if (httpRequest.HttpContext.Connection.RemoteIpAddress != null)
|
||
ip = httpRequest.HttpContext.Request.Headers["X-Forwarded-For"];
|
||
if (string.IsNullOrEmpty(ip))
|
||
ip = httpRequest.Host.Host;
|
||
try
|
||
{
|
||
foreach (IPAddress ipAddr in Dns.GetHostEntry(ip).AddressList)
|
||
{
|
||
if (ipAddr.AddressFamily.ToString() == "InterNetwork")
|
||
{
|
||
ipv4 = ipAddr.ToString();
|
||
}
|
||
}
|
||
}
|
||
catch { }
|
||
try
|
||
{
|
||
hostName = Dns.GetHostEntry(ip).HostName;
|
||
}
|
||
catch { }
|
||
if (string.IsNullOrEmpty(hostName) && string.Compare(ip, httpRequest.HttpContext.Request.Host.Value, true) != 0)
|
||
hostName = httpRequest.HttpContext.Request.Host.Value;
|
||
if (httpRequest.HttpContext.Request.Headers["User-Agent"].Count >= 0)
|
||
browser = httpRequest.HttpContext.Request.Headers["User-Agent"].FirstOrDefault();
|
||
|
||
T_PF_SYS_LOG sysLog = new T_PF_SYS_LOG();
|
||
sysLog.ID = Guid.NewGuid();
|
||
sysLog.ORG_ID = orgId;
|
||
sysLog.LOG_TYPE = (int)type;
|
||
sysLog.USER_ID = userId;
|
||
sysLog.LOG_TIME = DateTime.Now;
|
||
sysLog.LOG_TITLE = title;
|
||
sysLog.LOG_DATA = data;
|
||
sysLog.EXT_DATA = extData;
|
||
sysLog.HOST_NAME = (string.IsNullOrEmpty(hostName) ? string.Empty : string.Format("主机名:{0},", hostName))
|
||
+ (string.IsNullOrEmpty(ipv4) ? string.Empty : string.Format("IP:{0}", ipv4));
|
||
sysLog.BROWSER_NAME = browser;
|
||
if (!string.IsNullOrEmpty(formCode))
|
||
{
|
||
var form = this.GetEntity<T_PF_FORM>(t => t.CODE == formCode, filter);
|
||
if (form != null)
|
||
sysLog.LOG_FORM_ID = form.ID;
|
||
}
|
||
return sysLog;
|
||
}
|
||
}
|
||
}
|