修改trigger 注入服务异常
	
		
			
	
		
	
	
		
			
				
	
				continuous-integration/drone/push Build is passing
				
					Details
				
			
		
	
				
					
				
			
				
	
				continuous-integration/drone/push Build is passing
				
					Details
				
			
		
	
							parent
							
								
									fc8aaea395
								
							
						
					
					
						commit
						6a8a005951
					
				| 
						 | 
					@ -1,6 +1,7 @@
 | 
				
			||||||
using EntityFrameworkCore.Triggered;
 | 
					using EntityFrameworkCore.Triggered;
 | 
				
			||||||
using IRaCIS.Core.Domain.Share;
 | 
					using IRaCIS.Core.Domain.Share;
 | 
				
			||||||
using IRaCIS.Core.Infrastructure;
 | 
					using IRaCIS.Core.Infrastructure;
 | 
				
			||||||
 | 
					using Microsoft.Extensions.Localization;
 | 
				
			||||||
using System;
 | 
					using System;
 | 
				
			||||||
using System.Collections.Generic;
 | 
					using System.Collections.Generic;
 | 
				
			||||||
using System.Linq;
 | 
					using System.Linq;
 | 
				
			||||||
| 
						 | 
					@ -11,18 +12,19 @@ namespace IRaCIS.Core.Application.Triggers
 | 
				
			||||||
{
 | 
					{
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    // 统一处理  外部用户、中心调研(先添加 再发送邮件)、参与医生加入到项目  ----废弃
 | 
					    // 统一处理  外部用户、中心调研(先添加 再发送邮件)、参与医生加入到项目  ----废弃
 | 
				
			||||||
    public class AddlTrialUserTrigger :BaseService, IBeforeSaveTrigger<TrialUser>
 | 
					    public class AddlTrialUserTrigger :IBeforeSaveTrigger<TrialUser>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    {
 | 
					    {
 | 
				
			||||||
 | 
					        public IStringLocalizer _localizer;
 | 
				
			||||||
        private readonly IRepository<Trial> _trialRepository;
 | 
					        private readonly IRepository<Trial> _trialRepository;
 | 
				
			||||||
        private readonly IRepository<User> _userRepository;
 | 
					        private readonly IRepository<User> _userRepository;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        public AddlTrialUserTrigger(IRepository<Trial> trialRepository, IRepository<User> userRepository)
 | 
					        public AddlTrialUserTrigger(IRepository<Trial> trialRepository, IRepository<User> userRepository, IStringLocalizer localizer)
 | 
				
			||||||
        {
 | 
					        {
 | 
				
			||||||
            _trialRepository = trialRepository;
 | 
					            _trialRepository = trialRepository;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
            _userRepository = userRepository;
 | 
					            _userRepository = userRepository;
 | 
				
			||||||
 | 
					            _localizer = localizer;
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
        public async Task BeforeSave(ITriggerContext<TrialUser> context, CancellationToken cancellationToken)
 | 
					        public async Task BeforeSave(ITriggerContext<TrialUser> context, CancellationToken cancellationToken)
 | 
				
			||||||
        {
 | 
					        {
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -1,20 +1,26 @@
 | 
				
			||||||
using AutoMapper;
 | 
					using AutoMapper;
 | 
				
			||||||
using EntityFrameworkCore.Triggered;
 | 
					using EntityFrameworkCore.Triggered;
 | 
				
			||||||
using IRaCIS.Core.Domain.Share;
 | 
					using IRaCIS.Core.Domain.Share;
 | 
				
			||||||
 | 
					using IRaCIS.Core.Infra.EFCore;
 | 
				
			||||||
using IRaCIS.Core.Infrastructure;
 | 
					using IRaCIS.Core.Infrastructure;
 | 
				
			||||||
using MassTransit;
 | 
					using MassTransit;
 | 
				
			||||||
 | 
					using Microsoft.Extensions.Localization;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
namespace IRaCIS.Core.Application.Triggers
 | 
					namespace IRaCIS.Core.Application.Triggers
 | 
				
			||||||
{
 | 
					{
 | 
				
			||||||
    /// <summary>
 | 
					    /// <summary>
 | 
				
			||||||
    /// 
 | 
					    /// 
 | 
				
			||||||
    /// </summary>
 | 
					    /// </summary>
 | 
				
			||||||
    public class SubjectStateTrigger :BaseService, IAfterSaveTrigger<Subject>
 | 
					    public class SubjectStateTrigger : IAfterSaveTrigger<Subject>
 | 
				
			||||||
    {
 | 
					    {
 | 
				
			||||||
 | 
					        public IStringLocalizer _localizer;
 | 
				
			||||||
 | 
					        private readonly IRepository _repository;
 | 
				
			||||||
        private readonly IRepository<SubjectVisit> _subjectVisitRepository;
 | 
					        private readonly IRepository<SubjectVisit> _subjectVisitRepository;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        public SubjectStateTrigger(IRepository<SubjectVisit> subjectVisitRepository)
 | 
					        public SubjectStateTrigger(IRepository<SubjectVisit> subjectVisitRepository, IStringLocalizer localizer, IRepository repository)
 | 
				
			||||||
        {
 | 
					        {
 | 
				
			||||||
 | 
					            _repository = repository;
 | 
				
			||||||
 | 
					            _localizer = localizer;
 | 
				
			||||||
            _subjectVisitRepository = subjectVisitRepository;
 | 
					            _subjectVisitRepository = subjectVisitRepository;
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -2,15 +2,17 @@
 | 
				
			||||||
using IRaCIS.Core.Application.Service;
 | 
					using IRaCIS.Core.Application.Service;
 | 
				
			||||||
using IRaCIS.Core.Application.ViewModel;
 | 
					using IRaCIS.Core.Application.ViewModel;
 | 
				
			||||||
using IRaCIS.Core.Domain.Share;
 | 
					using IRaCIS.Core.Domain.Share;
 | 
				
			||||||
 | 
					using IRaCIS.Core.Infra.EFCore;
 | 
				
			||||||
using IRaCIS.Core.Infrastructure;
 | 
					using IRaCIS.Core.Infrastructure;
 | 
				
			||||||
using MassTransit;
 | 
					using MassTransit;
 | 
				
			||||||
 | 
					using Microsoft.Extensions.Localization;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
namespace IRaCIS.Core.Application.Triggers
 | 
					namespace IRaCIS.Core.Application.Triggers
 | 
				
			||||||
{
 | 
					{
 | 
				
			||||||
    /// <summary>
 | 
					    /// <summary>
 | 
				
			||||||
    ///  处理  访视   末次评估  会影响Subject 状态
 | 
					    ///  处理  访视   末次评估  会影响Subject 状态
 | 
				
			||||||
    /// </summary>
 | 
					    /// </summary>
 | 
				
			||||||
    public class SubjectVisitFinalVisitTrigger :BaseService, IAfterSaveTrigger<SubjectVisit>
 | 
					    public class SubjectVisitFinalVisitTrigger :IAfterSaveTrigger<SubjectVisit>
 | 
				
			||||||
    {
 | 
					    {
 | 
				
			||||||
        private readonly IRepository<SubjectVisit> _subjectVisitRepository;
 | 
					        private readonly IRepository<SubjectVisit> _subjectVisitRepository;
 | 
				
			||||||
        private readonly IRepository<ReadingPeriodSet> _readingPeriodSetRepository;
 | 
					        private readonly IRepository<ReadingPeriodSet> _readingPeriodSetRepository;
 | 
				
			||||||
| 
						 | 
					@ -19,7 +21,8 @@ namespace IRaCIS.Core.Application.Triggers
 | 
				
			||||||
        private readonly IRepository<Subject> _subjectRepository;
 | 
					        private readonly IRepository<Subject> _subjectRepository;
 | 
				
			||||||
        private readonly IRepository<VisitTask> _visitTaskRepository;
 | 
					        private readonly IRepository<VisitTask> _visitTaskRepository;
 | 
				
			||||||
        private readonly IVisitTaskHelpeService _ivisitTaskHelpeService;
 | 
					        private readonly IVisitTaskHelpeService _ivisitTaskHelpeService;
 | 
				
			||||||
 | 
					        public IStringLocalizer _localizer;
 | 
				
			||||||
 | 
					        private readonly IRepository _repository;
 | 
				
			||||||
        public SubjectVisitFinalVisitTrigger(IRepository<SubjectVisit> subjectVisitRepository,
 | 
					        public SubjectVisitFinalVisitTrigger(IRepository<SubjectVisit> subjectVisitRepository,
 | 
				
			||||||
 | 
					
 | 
				
			||||||
            IRepository<ReadingPeriodSet> readingPeriodSetRepository,
 | 
					            IRepository<ReadingPeriodSet> readingPeriodSetRepository,
 | 
				
			||||||
| 
						 | 
					@ -27,7 +30,9 @@ namespace IRaCIS.Core.Application.Triggers
 | 
				
			||||||
                IRepository<VisitTask> visitTaskRepository,
 | 
					                IRepository<VisitTask> visitTaskRepository,
 | 
				
			||||||
                IVisitTaskHelpeService visitTaskHelpeService,
 | 
					                IVisitTaskHelpeService visitTaskHelpeService,
 | 
				
			||||||
                 IRepository<ReadModule> readModuleRepository,
 | 
					                 IRepository<ReadModule> readModuleRepository,
 | 
				
			||||||
            IRepository<Subject> subjectRepository)
 | 
					            IRepository<Subject> subjectRepository,
 | 
				
			||||||
 | 
					            IStringLocalizer localizer,
 | 
				
			||||||
 | 
					            IRepository repository)
 | 
				
			||||||
        {
 | 
					        {
 | 
				
			||||||
            _subjectVisitRepository = subjectVisitRepository;
 | 
					            _subjectVisitRepository = subjectVisitRepository;
 | 
				
			||||||
            this._readingPeriodSetRepository = readingPeriodSetRepository;
 | 
					            this._readingPeriodSetRepository = readingPeriodSetRepository;
 | 
				
			||||||
| 
						 | 
					@ -36,6 +41,8 @@ namespace IRaCIS.Core.Application.Triggers
 | 
				
			||||||
            this._readingPeriodPlanRepository = readingPeriodPlanRepository;
 | 
					            this._readingPeriodPlanRepository = readingPeriodPlanRepository;
 | 
				
			||||||
            this._readModuleRepository = readModuleRepository;
 | 
					            this._readModuleRepository = readModuleRepository;
 | 
				
			||||||
            _subjectRepository = subjectRepository;
 | 
					            _subjectRepository = subjectRepository;
 | 
				
			||||||
 | 
					            _repository = repository;
 | 
				
			||||||
 | 
					            _localizer = localizer;
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        public async Task AfterSave(ITriggerContext<SubjectVisit> context, CancellationToken cancellationToken)
 | 
					        public async Task AfterSave(ITriggerContext<SubjectVisit> context, CancellationToken cancellationToken)
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -587,12 +587,12 @@ namespace IRaCIS.Core.Infra.EFCore
 | 
				
			||||||
 | 
					
 | 
				
			||||||
                throw new DBSaveFailedException("SQL 事务失败,请检查环境。");
 | 
					                throw new DBSaveFailedException("SQL 事务失败,请检查环境。");
 | 
				
			||||||
            }
 | 
					            }
 | 
				
			||||||
            catch (Exception ex)
 | 
					            //catch (Exception ex)
 | 
				
			||||||
            {
 | 
					            //{
 | 
				
			||||||
                _logger.LogError(ex.InnerException is null ? ex.Message : ex.InnerException?.Message);
 | 
					            //    _logger.LogError(ex.InnerException is null ? ex.Message : ex.InnerException?.Message);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
                throw new DBSaveFailedException("数据保存异常。");
 | 
					            //    throw new DBSaveFailedException(ex.Message);
 | 
				
			||||||
            }
 | 
					            //}
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 
 | 
					 
 | 
				
			||||||
 | 
					
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue