使用事件在NHibernate中进行数据审计

public class AuditEventListener : IPreUpdateEventListener, IPreInsertEventListener
{
    public bool OnPreUpdate(PreUpdateEvent @event)
    {
        // 在数据更新前进行审计操作
        return false;
    }

    public bool OnPreInsert(PreInsertEvent @event)
    {
        // 在数据插入前进行审计操作
        return false;
    }
}

public class AuditEventListener : IPreUpdateEventListener, IPreInsertEventListener
{
    public bool OnPreUpdate(PreUpdateEvent @event)
    {
        var entity = @event.Entity as MyEntity;
        if (entity != null)
        {
            // 进行数据审计操作
            Audit(entity, @event.State);
        }
        return false;
    }

    public bool OnPreInsert(PreInsertEvent @event)
    {
        var entity = @event.Entity as MyEntity;
        if (entity != null)
        {
            // 进行数据审计操作
            Audit(entity, @event.State);
        }
        return false;
    }

    private void Audit(MyEntity entity, object[] state)
    {
        // 记录日志或发送通知等审计操作
    }
}

public class AuditInterceptor : EmptyInterceptor
{
    private readonly AuditEventListener _listener = new AuditEventListener();

    public override bool OnFlushDirty(object entity, object id, object[] currentState, object[] previousState, string[] propertyNames, IType[] types)
    {
        if (_listener.OnPreUpdate(new PreUpdateEvent(entity, id, currentState, previousState, propertyNames, types)))
        {
            return false;
        }
        return base.OnFlushDirty(entity, id, currentState, previousState, propertyNames, types);
    }

    public override bool OnSave(object entity, object id, object[] state, string[] propertyNames, IType[] types)
    {
        if (_listener.OnPreInsert(new PreInsertEvent(entity, id, state, propertyNames, types)))
        {
            return false;
        }
        return base.OnSave(entity, id, state, propertyNames, types);
    }
}

var configuration = new Configuration();
configuration.Configure();
configuration.SetInterceptor(new AuditInterceptor());