XCKJ
/
irc-netcore-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改

Temp_Event_IRC_Met8
he 2025-04-22 09:29:32 +08:00
parent fc81d6da22
commit 3abc8787c6
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
IRaCIS.Core.Application/MassTransit/Recurring/SystemDocumentConsumer.cs
View File

@ -21,7 +21,7 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
{
/// <summary>
/// 定时提醒
/// 定时过期提醒
/// </summary>
public class SystemDocumentErverDayEventConsumer(
IRepository<ReadingQuestionCriterionTrial> _trialReadingCriterionRepository,
@ -41,8 +41,7 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
{
DateTime now = DateTime.Now;
if (now.Hour == 9)
{
var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
var systemDocQuery =
from sysDoc in _systemDocumentRepository.AsQueryable(false)
@ -67,11 +66,11 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
UserName = identityUser.UserName,
IsNeedSendEmial = identityUser.IsZhiZhun || (!identityUser.IsZhiZhun && sysDoc.DocUserSignType == DocUserSignType.InnerAndOuter),
FullFilePath = sysDoc.Path
};
var datalist = await systemDocQuery.IgnoreQueryFilters().Where(t => !(t.IsDeleted == true && t.ConfirmTime == null))
.Where(x => x.ConfirmTime != null).ToListAsync();
.Where(x => x.IsNeedSendEmial).Where(x => x.ConfirmTime != null).ToListAsync();
datalist = datalist.Where(x => x.SuggestFinishTime != null && x.SuggestFinishTime.Value.Date == DateTime.Now.Date).ToList();
var confirmUserIdList = datalist.Select(t => t.ConfirmUserId).Distinct().ToList();
var userinfoList = await _identityUserRepository.Where(x => confirmUserIdList.Contains(x.Id)).ToListAsync();
@ -106,7 +105,7 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
await SendEmailHelper.SendEmailAsync(messageToSend, _systemEmailConfig);
}
}
}
}