diff --git a/IRaCIS.Core.Application/MassTransit/Recurring/TrialDocumentConsumer.cs b/IRaCIS.Core.Application/MassTransit/Recurring/TrialDocumentConsumer.cs
index 40d5661bb..06a7a2cfc 100644
--- a/IRaCIS.Core.Application/MassTransit/Recurring/TrialDocumentConsumer.cs
+++ b/IRaCIS.Core.Application/MassTransit/Recurring/TrialDocumentConsumer.cs
@@ -55,7 +55,7 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
             var trialDocQuery =
              from trialDoc in _trialDocumentRepository.AsQueryable(true)
  
-             join trialIdentityUser in _trialIdentityUserRepository.AsQueryable() on trialDoc.TrialId equals trialIdentityUser.TrialId
+             join trialIdentityUser in _trialIdentityUserRepository.Where(x => x.IsDeleted == false) on trialDoc.TrialId equals trialIdentityUser.TrialId
              from identityUser in _identityUserRepository.AsQueryable(false)
              .Where(t => t.Status == UserStateEnum.Enable &&
                     t.Id == trialIdentityUser.IdentityUserId &&
@@ -187,7 +187,7 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
                 // 只查询新增角色的用户
                 systemDocQuery =
                 from trialDoc in _trialDocumentRepository.AsQueryable(false).Where(x => context.Message.Ids.Contains(x.Id))
-                join trialIdentityUser in _trialIdentityUserRepository.AsQueryable() on trialDoc.TrialId equals trialIdentityUser.TrialId
+                join trialIdentityUser in _trialIdentityUserRepository.Where(x=>x.IsDeleted==false) on trialDoc.TrialId equals trialIdentityUser.TrialId
                 from identityUser in _identityUserRepository.AsQueryable(false)
                 .Where(t => t.Status == UserStateEnum.Enable &&
                         t.Id == trialIdentityUser.IdentityUserId &&
@@ -217,7 +217,7 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
                 // 查询所有相关角色的用户
                 systemDocQuery =
                 from trialDoc in _trialDocumentRepository.AsQueryable(false).Where(x => context.Message.Ids.Contains(x.Id))
-                join trialIdentityUser in _trialIdentityUserRepository.AsQueryable() on trialDoc.TrialId equals trialIdentityUser.TrialId
+                join trialIdentityUser in _trialIdentityUserRepository.Where(x => x.IsDeleted == false) on trialDoc.TrialId equals trialIdentityUser.TrialId
                 from identityUser in _identityUserRepository.AsQueryable(false)
                 .Where(t => t.Status == UserStateEnum.Enable &&
                        t.Id== trialIdentityUser.IdentityUserId&&