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

稽查访视修改

Uat_Study
hang 2022-05-06 13:28:21 +08:00
parent a89b69e1f8
commit 9ed7320c10
1 changed files with 22 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
IRaCIS.Core.Application/Service/Visit/SubjectVisitService.cs
View File

@ -7,10 +7,7 @@ using Microsoft.AspNetCore.Authorization;
using IRaCIS.Core.Domain.Share;
using IRaCIS.Core.Application.Contracts;
using IRaCIS.Core.Application.Interfaces;
using IRaCIS.Core.Application.Service.Inspection.Interface;
using Newtonsoft.Json;
using IRaCIS.Core.Infrastructure;
using IRaCIS.Core.Domain.Common;
namespace IRaCIS.Core.Application.Services
{
@ -18,13 +15,11 @@ namespace IRaCIS.Core.Application.Services
public class SubjectVisitService : BaseService, ISubjectVisitService
{
private readonly IRepository<SubjectVisit> _subjectVisitRepository;
private readonly IInspectionService _inspectionService;
private readonly IRepository<Subject> _subjectRepository;
public SubjectVisitService(IRepository<SubjectVisit> subjectVisitRepository, IInspectionService inspectionService,IRepository<Subject> subjectRepository)
public SubjectVisitService(IRepository<SubjectVisit> subjectVisitRepository, IRepository<Subject> subjectRepository)
{
_subjectVisitRepository = subjectVisitRepository;
this._inspectionService = inspectionService;
_subjectRepository = subjectRepository;
}
@ -33,7 +28,7 @@ namespace IRaCIS.Core.Application.Services
[UnitOfWork]
public async Task<IResponseOutput<string>> AddOrUpdateSV(SubjectVisitCommand svCommand)
{
var verifyExp1 = new EntityVerifyExp<SubjectVisit>()
{
VerifyExp = t => t.VisitNum == svCommand.VisitNum && t.SubjectId == svCommand.SubjectId,
@ -44,7 +39,7 @@ namespace IRaCIS.Core.Application.Services
{
VerifyExp = t => t.SubjectId == svCommand.SubjectId && t.IsFinalVisit,
VerifyMsg = "该受试者已经有访视设置为末次访视，不允许将该访视设置为末次访视",
IsVerify=svCommand.IsFinalVisit
IsVerify = svCommand.IsFinalVisit
};
@ -62,16 +57,16 @@ namespace IRaCIS.Core.Application.Services
{
if (await _subjectVisitRepository.AnyAsync(t => t.SubjectId == svCommand.SubjectId && t.IsFinalVisit))
{
throw new BusinessValidationFailedException("设置末次评估后，不允许添加计划外访视");
throw new BusinessValidationFailedException("设置末次评估后，不允许添加计划外访视");
}
}
dbBeforeEntity = await _subjectVisitRepository.InsertFromDTOAsync(svCommand, false, verifyExp1, verifyExp2);
dbBeforeEntity = await _subjectVisitRepository.InsertFromDTOAsync(svCommand, false, verifyExp1, verifyExp2);
}
else
{
dbBeforeEntity = await _subjectVisitRepository.UpdateFromDTOAsync(svCommand, false,false, verifyExp1, verifyExp2);
dbBeforeEntity = await _subjectVisitRepository.UpdateFromDTOAsync(svCommand, false, false, verifyExp1, verifyExp2);
if (svCommand.PDState != dbBeforeEntity.PDState && dbBeforeEntity.SubmitState == SubmitStateEnum.Submitted)
{
@ -83,7 +78,7 @@ namespace IRaCIS.Core.Application.Services
throw new BusinessValidationFailedException("回退的访视，不允许修改PD确认状态");
}
if (svCommand.IsLostVisit )
if (svCommand.IsLostVisit)
{
if (await _subjectVisitRepository.AnyAsync(t => t.Id == svCommand.Id && t.SubmitState == SubmitStateEnum.ToSubmit))
{
@ -93,27 +88,19 @@ namespace IRaCIS.Core.Application.Services
}
//更新受试者 首次给药日期 是否入组确认
if (svCommand.SubjectFirstGiveMedicineTime != null && svCommand.IsBaseLine)
{
//await _subjectRepository.UpdatePartialSearchFirstAsync(svCommand.SubjectId,
// u => new Subject() { FirstGiveMedicineTime = svCommand.SubjectFirstGiveMedicineTime });
var subject = (await _subjectRepository.FirstOrDefaultAsync(t => t.Id == svCommand.SubjectId)).IfNullThrowException();
// 更新受试者
subject.FirstGiveMedicineTime = svCommand.SubjectFirstGiveMedicineTime;
await _subjectRepository.UpdatePartialFromQueryAsync(svCommand.SubjectId, t => new Subject()
{
FirstGiveMedicineTime = svCommand.SubjectFirstGiveMedicineTime
});
}
await _repository.SaveChangesAsync();
await _subjectVisitRepository.SaveChangesAsync();
return ResponseOutput.Ok(dbBeforeEntity.Id.ToString());
@ -126,7 +113,7 @@ namespace IRaCIS.Core.Application.Services
[HttpPut("{trialId:guid}/{subjectVisitId:guid}/{isUrgent:bool}")]
public async Task<IResponseOutput> SetSubjectVisitUrgent(Guid subjectVisitId, bool isUrgent)
{
await _subjectVisitRepository.BatchUpdateNoTrackingAsync(t => t.Id == subjectVisitId, u => new SubjectVisit() { IsUrgent = isUrgent });
await _subjectVisitRepository.UpdatePartialFromQueryAsync(subjectVisitId, u => new SubjectVisit() { IsUrgent = isUrgent },true);
return ResponseOutput.Ok();
}
@ -145,11 +132,13 @@ namespace IRaCIS.Core.Application.Services
{
return ResponseOutput.NotOk("This visit is InPlan and couldn't be deleted.");
}
if (await _subjectVisitRepository.AnyAsync(t => t.OutPlanPreviousVisitId == id ))
if (await _subjectVisitRepository.AnyAsync(t => t.OutPlanPreviousVisitId == id))
{
return ResponseOutput.NotOk("This visit is OutPlanPreviousVisitId and couldn't be deleted.");
}
return ResponseOutput.Result(await _repository.BatchDeleteAsync<SubjectVisit>(s => s.Id == id));
await _subjectVisitRepository.SoftDeleteFromQueryAsync(s => s.Id == id);
return ResponseOutput.Ok();
}
/// <summary>
@ -157,12 +146,13 @@ namespace IRaCIS.Core.Application.Services
/// </summary>
/// <param name="subjectVisitId"></param>
/// <returns></returns>
[HttpPost("{subjectVisitId:guid}/{trialId:guid}")]
[HttpPut("{trialId:guid}/{subjectVisitId:guid}")]
[TrialAudit(AuditType.SubjectAudit, AuditOptType.SetSVExecuted)]
[TypeFilter(typeof(TrialResourceFilter))]
public async Task<IResponseOutput> SetSVExecuted(Guid subjectVisitId)
{
return ResponseOutput.Result(await _subjectVisitRepository.BatchUpdateNoTrackingAsync(s => s.Id == subjectVisitId, u => new SubjectVisit() { VisitExecuted = VisitExecutedEnum.Executed }));
await _subjectVisitRepository.UpdatePartialFromQueryAsync(subjectVisitId, u => new SubjectVisit() { VisitExecuted = VisitExecutedEnum.Executed }, true);
return ResponseOutput.Ok();
}
@ -216,6 +206,6 @@ namespace IRaCIS.Core.Application.Services
}
}