ASP.NET Core后台服务LINQ查询无法稳定获取全部数据求助

问题描述 #

在基于ASP.NET Core 3.1/SQL Server/EF Core的宠物医疗提醒系统中，通过BackgroundService每日中午执行LINQ查询获取需通知宠物主人的定期医疗提醒数据，但查询有时无法返回全部符合条件的数据（例如4条符合条件的数据仅返回3条，且数据库中对应数据的ReminderSMSSent仍为false）。相关查询代码如下：

_context.Tests
.Where(t => t.Visit.User.SMSAccount != null
       && t.Visit.User.SMSAccount.AutoReminder
       && t.Visit.Customer.Consent
       && (t.Visit.Customer.ContactBy == "Mobile")
       && !string.IsNullOrEmpty(t.Visit.Customer.Mobile)
       && !t.Visit.Pet.PassedAway
       && t.Reminder.HasValue
       && !t.ReminderSMSSent
       && DateTime.Now.Date.AddDays(t.Visit.User.SMSAccount.DaysBefore.Value) == t.Reminder)
.Include(t => t.Visit.User.SMSAccount)
.Include(t => t.Visit.Customer)
.Include(t => t.Visit.Pet)
.AsNoTracking();

已知LinqPad模拟执行对应SQL可返回正确数据，且已发现t.Reminder未使用Value的潜在问题，但仍未解决数据不全的问题。

排查与解决步骤 #

• 修正Reminder取值逻辑
  t.Reminder是可空DateTime类型，直接与DateTime.Now.Date.AddDays(...)比较可能存在隐式转换的不确定性，显式调用Value更严谨（已通过t.Reminder.HasValue确保非空）：

  DateTime.Now.Date.AddDays(t.Visit.User.SMSAccount.DaysBefore.Value) == t.Reminder.Value
  

• 统一时间处理逻辑，避免时区/时间精度偏差
  服务器本地时间与数据库时间可能存在时区差异，或者Reminder字段包含时分秒信息，导致日期匹配失败。建议统一使用UTC时间，并仅比较日期部分：

  DateTime.UtcNow.Date.AddDays(t.Visit.User.SMSAccount.DaysBefore.Value) == t.Reminder.Value.Date
  

  同时确保数据库中Reminder字段的时间存储逻辑与代码一致，避免因时间精度（如毫秒级差异）导致的不匹配。

• 记录运行时生成的SQL语句
  LinqPad模拟的SQL可能与BackgroundService运行时EF Core生成的SQL存在差异，需捕获实际执行的SQL并验证：

  var query = _context.Tests
      .Where(...) // 原查询条件
      .Include(t => t.Visit.User.SMSAccount)
      .Include(t => t.Visit.Customer)
      .Include(t => t.Visit.Pet)
      .AsNoTracking();
  
  // 输出生成的SQL到日志
  var sql = query.ToQueryString();
  _logger.LogInformation("Reminder query SQL: {Sql}", sql);
  
  var results = query.ToList();
  

  将生成的SQL在SSMS中执行，对比返回结果与代码执行结果，定位是否为EF Core查询转换的问题。

• 处理并发数据修改问题
  若查询执行期间有其他进程修改符合条件的数据（如ReminderSMSSent被提前标记），会导致数据漏取：

  1. 使用快照隔离事务，确保查询获取一致的数据视图：

     using var transaction = _context.Database.BeginTransaction(System.Data.IsolationLevel.Snapshot);
     var results = _context.Tests.Where(...).ToList();
     transaction.Commit();
     

  2. 查询后立即标记ReminderSMSSent为true并保存，同时添加乐观锁（如RowVersion字段）防止并发冲突：

     foreach (var test in results)
     {
         test.ReminderSMSSent = true;
     }
     _context.SaveChanges();
     

• 验证BackgroundService执行时机
  记录查询执行时的服务器时间，确认BackgroundService确实在每日中午执行，避免因定时任务偏差导致日期匹配条件不满足。

• 排查EF Core上下文缓存问题
  即使使用了AsNoTracking()，复用DbContext实例仍可能存在缓存干扰。确保每次查询使用全新的DbContext实例，或在查询前清除跟踪状态：

  _context.ChangeTracker.Clear();
  

内容的提问来源于stack exchange，提问作者dpant