1

我有一个 Orchard CMS 模块，它加载了一些提供服务功能的代码。服务代码被编写为与主机无关，并且之前已与 ASP.NET 和 WCF 一起使用。服务代码使用 MEF 加载插件。一个这样的插件用于审计。

为了允许访问 Orchard 数据库进行审计，我修改了服务代码以允许主机传入审计实现实例。因此，我的 Orchard 模块可以在服务启动时传入一个实例，目的是该实例将审计数据作为记录写入 Orchard DB。

我为我的数据库创建了一个迁移：

    public int UpdateFrom5()
    {
        SchemaBuilder.CreateTable("AuditRecord",
            table => table
                .Column<int>("Id", c => c.PrimaryKey().Identity())
                .Column<int>("AuditPoint")
                .Column<DateTime>("EventTime")
                .Column("CampaignId", DbType.Guid)
                .Column("CallId", DbType.Guid)
                .Column<String>("Data")
                );
        return 6;
    }

我在 Models 中创建了 AuditRecord 模型：

namespace MyModule.Models
{
    public class AuditRecord
    {
        public virtual int Id { get; set; }
        public virtual int AuditPoint { get; set; }
        public virtual DateTime EventTime { get; set; }
        public virtual Guid CampaignId { get; set; }
        public virtual Guid CallId { get; set; }
        public virtual String Data { get; set; }
    }
}

我添加了一个从 IDependency 派生的 IAudiWriter 接口，以便我可以在我的模块启动时注入一个新实例。

public interface IAuditWriter : IDependency
{
    void WriteAuditRecord(AuditRecord data);
}

为了让我的审计编写器实例与现有服务代码一起工作，它必须派生自服务库中定义的抽象类 FlowSinkAudit。抽象类定义了 Audit 方法。当服务需要编写审计时，它会在从 FlowAuditSink 抽象类派生的所有实例上调用审计方法，这些实例已通过 MEF 或通过在启动时传入实例进行实例化。

public class AuditWriter : FlowAuditSink, IAuditWriter
{
    private readonly IComponentContext ctx;
    private readonly IRepository<AuditRecord> repo;
    public AuditWriter(IComponentContext ctx, IRepository<AuditRecord> repo)
    {
        this.ctx = ctx;
        this.repo = repo;
    }

    public void WriteAuditRecord(AuditRecord data)
    {
        // Get an audit repo
        //IRepository<AuditRecord> repo = (IRepository<AuditRecord>)ctx.Resolve(typeof(IRepository<AuditRecord>));
        using (System.Transactions.TransactionScope t = new System.Transactions.TransactionScope(System.Transactions.TransactionScopeOption.Suppress))
        {
            this.repo.Create(data);
        }
    }

    public override void Audit(DateTime eventTime, AuditPoint auditPoint, Guid campaignId, Guid callId, IDictionary<String, Object> auditPointData)
    {
        // Add code here to write audit into the Orchard DB.
        AuditRecord ar = new AuditRecord();
        ar.AuditPoint = (int)auditPoint;
        ar.EventTime = eventTime;
        ar.CampaignId = campaignId;
        ar.CallId = callId;
        ar.Data = auditPointData.AsString();
        WriteAuditRecord(ar);
    }
}

我的服务代码是从实现 IOrchardShellEvents 的模块级类开始的

public class Module : IOrchardShellEvents
{
    private readonly IAuditWriter audit;
    private readonly IRepository<ServiceSettingsPartRecord> settingsRepository;
    private readonly IScheduledTaskManager taskManager;
    private static readonly Object syncObject = new object();

    public ILogger logger { get; set; }

    public Module(IScheduledTaskManager taskManager, IRepository<ServiceSettingsPartRecord> settingsRepository, IAuditWriter audit)
    {
        this.audit = audit;
        this.settingsRepository = settingsRepository;
        this.taskManager = taskManager;
        logger = NullLogger.Instance;
    }
...

在“已激活”事件期间启动服务时，我传递this.Audit给服务实例。

    public void Activated()
    {
        lock (syncObject)
        {
            var settings = settingsRepository.Fetch(f => f.StorageProvider != null).FirstOrDefault();
            InitialiseServer();
            // Auto start the server
            if (!StartServer(settings))
            {
                // Auto start failed, setup a scheduled task to retry
                var tasks = taskManager.GetTasks(ServerAutostartTask.TaskType);
                if (tasks == null || tasks.Count() == 0)
                    taskManager.CreateTask(ServerAutostartTask.TaskType, DateTime.Now + TimeSpan.FromSeconds(60), null);
            }
        }
    }
...
    private void InitialiseServer()
    {
        if (!Server.IsInitialized)
        {
            var systemFolder = @"C:\Scratch\Plugins";
            if (!Directory.Exists(systemFolder))
                Directory.CreateDirectory(systemFolder);

            var cacheFolder = System.Web.Hosting.HostingEnvironment.MapPath("~/App_Data/MyModule/Cache");
            if (!Directory.Exists(cacheFolder))
                Directory.CreateDirectory(cacheFolder);

            Server.Initialise(systemFolder, cacheFolder, null, (FlowAuditSink)audit);
        }
    }

所有这些都按预期工作，我的服务代码调用了审计接收器。

我的问题是，当调用审计接收器并且我尝试将审计写入数据库时this.repo.Create(data)​​没有写入任何内容。

我还尝试使用 IComponentContext 接口创建一个新的存储库对象，但是这个错误已经处理了对象。我认为这是因为审计接收器是一个长期存在的对象实例。

我已经尝试过暂停和不暂停当前事务，这不会影响结果。我认为这是因为调用不是通过 ASP.NET MVC 来的，而是来自服务代码创建的线程。

谁能告诉我如何让我的审计数据出现在 Orchard 数据库中？

谢谢

克里斯。

4

1 回答 1

2

好吧，我有一个解决方案，但由于我对 Orchards 架构不是很熟悉，所以它可能不是最好的方法。

在深入研究了 Orchard 的资料后，我发现这个问题的症结可以概括为

“如何从不使用 Http 请求管道的线程访问 Orchard autofac 注入机制”。

我认为这是计划任务必须执行的操作，因此我创建了计划任务并在 IScheduledTaskHandler.Process 中设置断点以了解任务的执行方式。查看 Orchard\Tasks\SweepGenerator.cs 为我指明了方向。

我因此修改了我的 AuditWriter：

public interface IAuditWriter : ISingletonDependency
{
}

public class AuditWriter : FlowAuditSink, IAuditWriter
{
    private readonly IWorkContextAccessor _workContextAccessor;

    public AuditWriter(IWorkContextAccessor workContextAccessor)
    {
        _workContextAccessor = workContextAccessor;
    }

    public override void Audit(DateTime eventTime, AuditPoint auditPoint, Guid campaignId, Guid callId, IDictionary<String, Object> auditPointData)
    {
        // Add code here to write audit into the Orchard DB.
        AuditRecord ar = new AuditRecord();
        ar.AuditPoint = (int)auditPoint;
        ar.EventTime = eventTime;
        ar.CampaignId = campaignId;
        ar.CallId = callId;
        ar.Data = auditPointData.AsString();

        using (var scope = _workContextAccessor.CreateWorkContextScope())
        {
            // resolve the manager and invoke it
            var repo = scope.Resolve<IRepository<AuditRecord>>();
            repo.Create(ar);
            repo.Flush();
        }
    }
}

scope.Resolve有效，我的数据已成功写入 Orchard DB。

目前，我认为我对 ISingletonDependency 的使用不能正常工作，因为我的构造函数仅在我的模块在其构造函数中注入 AuditWriter 实例并且它不止一次发生时才被调用。

无论如何，似乎要从非 Http 线程访问 Orchard autofac 解析机制，我们使用 IWorkContextAccessor

如果这不正确，请告诉我。

于 2013-11-06T14:08:52.717 回答