ServiceStack：在 InsertFilter 和 UpdateFilter 中访问会话

Question

我有一个 C#.net 应用程序，我在其中写入一个 sql server 数据库。 SQL Server 表都有公共记录管理列（DateCreated、DateLastUpdated、CreatedUserId 等...），我希望将这些字段的填充抽象为 InsertFilter 和 UpdateFilter。

这是 AppHost 的 Configure 方法的简化版本..

public override void Configure(Container container)
{
    ICacheClient CacheClient = new MemoryCacheClient();
    container.Register(CacheClient);

    var connectionString = ConfigurationManager.ConnectionStrings["mydb"].ConnectionString;

    container.Register<IDbConnectionFactory>(c => new OrmLiteConnectionFactory(connectionString, SqlServerDialect.Provider));

    container.Register<IUserAuthRepository>(c => new OrmLiteAuthRepository(c.Resolve<IDbConnectionFactory>()));
    var authRepo = (OrmLiteAuthRepository)container.Resolve<IUserAuthRepository>();


    OrmLiteConfig.InsertFilter = (dbCmd, row) =>
    {
        var userSession = SessionFeature.GetOrCreateSession<AuthUserSession>(CacheClient);
        var recordManagementRow = row as IRecordManagement;
        if (recordManagementRow != null)
        {
            recordManagementRow.DateCreated = recordManagementRow.DateLastUpdated = DateTime.UtcNow;
            if (userSession != null)
                recordManagementRow.CreatedUserId = recordManagementRow.LastUpdatedUserId = userSession.Id.ToInt();
        }
    };
}

执行时，OrmLiteConfig.InsertFilter 委托的第一行出现以下异常。有没有人对如何检索当前用户会话 ID 以插入数据库有更好的想法？

ServiceStack.dll 中出现“System.NotImplementedException”类型的异常，但未在用户代码中处理

补充信息：此 AppHost 不支持通过 Singleton 访问当前请求

Answer 1

User Session 只能在请求的上下文中访问，因为它依赖于当前请求的 Session Cookies。

只有 ASP.NET 主机可以访问 HttpContext.Current 单例来访问当前请求。在尝试访问 HTTP 侦听器自身主机中的用户会话而不注入当前 HTTP Request 时，您将收到此异常，例如：

var userSession = SessionFeature
    .GetOrCreateSession<AuthUserSession>(CacheClient, Request);

我建议不要尝试像这样访问用户会话，而是在 IRecordManagement 上创建一个扩展方法，以填充类似于您的 InsertFilter 正在执行的 POCO，例如：

db.Insert(new Record { ... }.WithAudit(Request));

//Extension Method Example:
public static class RecordManagementExtensions
{
    public static T WithAudit<T>(this T row, IRequest req) where T : IRecordManagement => 
        row.WithAudit(Request.GetSession().UserAuthId);

    public static T WithAudit<T>(this T row, string userId) where T : IRecordManagement
    {
        row.UserId = userId;
        row.DateCreated = DateTime.UtcNow;
        return row;
    }
}

虽然我不建议依赖 RequestContext 单例，但您可以在这种情况下使用它来为请求过滤器中的请求设置当前 UserId，例如：

GlobalRequestFilters.Add((req, res, requestDto) => {
    RequestContext.Instance.Items["userId"] = req.GetSession().UserAuthId;
});

然后您可以从过滤器中访问，例如：

OrmLiteConfig.InsertFilter = (dbCmd, row) => {
    ...
    recordMgt.CreatedUserId = RequestContext.Instance.Items["userId"];
}