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

MasstransitMeditor 不在efcore 同一个事务
continuous-integration/drone/push Build is passing Details

IRC_NewDev
hang 2024-09-28 21:21:52 +08:00
parent 1bacc222be
commit 7693c72802
7 changed files with 29 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
IRaCIS.Core.API/Progranm.cs
View File

@ -151,6 +151,7 @@ builder.Services.AddMediator(cfg =>
{
cfg.AddConsumer<ConsistencyCheckConsumer>();
cfg.AddConsumer<AddUserLogTriggerConsumer>();
cfg.AddConsumer<AddSubjectTriggerConsumer>();
});
// 添加 MassTransit 和 InMemory 传输

6
IRaCIS.Core.Application/IRaCIS.Core.Application.xml
View File

@ -12658,7 +12658,8 @@
</member>
<member name="T:IRaCIS.Core.Application.MassTransit.Consumer.AddSubjectTriggerConsumer">
<summary>
添加Subject 触发添加访视 不能代替 Trigger,稽查BatchId 不一致 暂时废弃
添加Subject 触发添加访视 不能代替 Trigger,稽查BatchId 不一致
因为消费者这里的数据库上下文 和消息发送者上下文不是同一个，相当于两个独立的事务
</summary>
<param name="_subjectVisitRepository"></param>
<param name="_visitStageRepository"></param>
@ -12667,7 +12668,8 @@
</member>
<member name="M:IRaCIS.Core.Application.MassTransit.Consumer.AddSubjectTriggerConsumer.#ctor(IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.SubjectVisit},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.VisitStage},IRaCIS.Core.Infra.EFCore.IRepository{IRaCIS.Core.Domain.Models.Trial},AutoMapper.IMapper)">
<summary>
添加Subject 触发添加访视 不能代替 Trigger,稽查BatchId 不一致 暂时废弃
添加Subject 触发添加访视 不能代替 Trigger,稽查BatchId 不一致
因为消费者这里的数据库上下文 和消息发送者上下文不是同一个，相当于两个独立的事务
</summary>
<param name="_subjectVisitRepository"></param>
<param name="_visitStageRepository"></param>

4
IRaCIS.Core.Application/MassTransit/Consumer/NeedVerify/AddSubjectTriggerConsumer.cs
View File

@ -7,7 +7,8 @@ using MassTransit;
namespace IRaCIS.Core.Application.MassTransit.Consumer;
/// <summary>
/// 添加Subject 触发添加访视 不能代替 Trigger,稽查BatchId 不一致 暂时废弃
/// 添加Subject 触发添加访视 不能代替 Trigger,稽查BatchId 不一致
/// 因为消费者这里的数据库上下文 和消息发送者上下文不是同一个，相当于两个独立的事务
/// </summary>
/// <param name="_subjectVisitRepository"></param>
/// <param name="_visitStageRepository"></param>
@ -41,6 +42,5 @@ public class AddSubjectTriggerConsumer(IRepository<SubjectVisit> _subjectVisitRe
});
await _subjectVisitRepository.AddRangeAsync(svList);
await _subjectVisitRepository.SaveChangesAsync();
}
}

13
IRaCIS.Core.Application/TestService.cs
View File

@ -4,11 +4,13 @@ using IRaCIS.Core.Application.BusinessFilter;
using IRaCIS.Core.Application.Contracts;
using IRaCIS.Core.Application.Helper;
using IRaCIS.Core.Application.ViewModel;
using IRaCIS.Core.Domain;
using IRaCIS.Core.Domain.Share;
using IRaCIS.Core.Infrastructure;
using IRaCIS.Core.Infrastructure.Encryption;
using IRaCIS.Core.Infrastructure.NewtonsoftJson;
using MassTransit;
using MassTransit.Mediator;
using Medallion.Threading;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Hosting;
@ -119,6 +121,17 @@ namespace IRaCIS.Core.Application.Service
}
public async Task<IResponseOutput> TestMasstransitMeditor([FromServices] IMediator _mediator, [FromServices] IRepository<TestLength> _testLengthRepository)
{
await _testLengthRepository.AddAsync(new TestLength() { Name = "zhouhang1" });
await _mediator.Send(new AddSubjectTriggerCommand { SubjectId = Guid.Empty });
await _testLengthRepository.SaveChangesAsync();
return ResponseOutput.Ok();
}
public async Task<IResponseOutput> TestJson()
{
var model1 = new TestModel() { TestId = NewId.NextSequentialGuid(), TestName = null };

1
IRaCIS.Core.Application/Triggers/SubjectTrigger.cs
View File

@ -117,7 +117,6 @@ namespace IRaCIS.Core.Application.Triggers
await _subjectVisitRepository.AddRangeAsync(svList);
//await _subjectVisitRepository.SaveChangesAsync();
}

5
IRaCIS.Core.Domain/BaseModel/IAuditAdd.cs
View File

@ -11,7 +11,4 @@ public interface IAuditAdd : IAuditAdd<Guid>
}
public interface IAuditAddWithUserName : IAuditAdd<Guid>
{
public string CreateUser { get; set; }
}

26
IRaCIS.Core.Infra.EFCore/Interceptor/AuditEntityInterceptor.cs
View File

@ -28,9 +28,9 @@ public class AuditEntityInterceptor(IUserInfo _userInfo,
public override ValueTask<InterceptionResult<int>> SavingChangesAsync(DbContextEventData eventData,
InterceptionResult<int> result, CancellationToken cancellationToken = default)
{
////领域命令 （同一个事务提交的一些逻辑，类似Trigger 保存事务之前执行的一些逻辑）
//////领域命令 （同一个事务提交的一些逻辑，类似Trigger 保存事务之前执行的一些逻辑）
//eventData.Context.AddDomainCommands();
//DispatchDomainCommands(eventData.Context).GetAwaiter().GetResult();
//await DispatchDomainCommands(eventData.Context);
//领域事件
eventData.Context.AddDomainEvents();
@ -41,6 +41,8 @@ public class AuditEntityInterceptor(IUserInfo _userInfo,
//IRC稽查 放在savechange 之前 不影响之前的逻辑
IRCDataInspection(eventData.Context);
//return result;
return base.SavingChangesAsync(eventData, result, cancellationToken);
}
public override InterceptionResult<int> SavingChanges(DbContextEventData eventData, InterceptionResult<int> result)
@ -55,6 +57,8 @@ public class AuditEntityInterceptor(IUserInfo _userInfo,
//IRC稽查 放在savechange 之前 不影响之前的逻辑
IRCDataInspection(eventData.Context);
//return result;
return base.SavingChanges(eventData, result);
}
public void AuditEntities(DbContext? context)
@ -122,22 +126,6 @@ public class AuditEntityInterceptor(IUserInfo _userInfo,
updateEntity.UpdateTime = DateTime.Now;
updateEntity.UpdateUserId = _userInfo.Id;
}
if (entry.Entity is IAuditAddWithUserName addEntity3)
{
if (addEntity3.CreateTime == default(DateTime))
{
addEntity3.CreateTime = DateTime.Now;
}
if (addEntity3.CreateUserId == default(Guid))
{
addEntity3.CreateUserId = _userInfo.Id;
addEntity3.CreateUser = _userInfo.RealName;
}
}
break;
}
}
@ -164,7 +152,6 @@ public class AuditEntityInterceptor(IUserInfo _userInfo,
#region 异常处理
#endregion
private void LoggerDBContextException(DbContextErrorEventData eventData)
{
@ -225,6 +212,7 @@ public class AuditEntityInterceptor(IUserInfo _userInfo,
base.SaveChangesFailed(eventData);
}
#endregion
#region 领域命令分发