using AutoMapper;
using EasyCaching.Core;
using EntityFrameworkCore.Triggered;
using IRaCIS.Core.Application.ViewModel;
using IRaCIS.Core.Domain.Share;
using IRaCIS.Core.Infrastructure;

namespace IRaCIS.Core.Application.Triggers
{
    /// <summary>
    ///  处理  访视   末次评估  会影响Subject 状态
    /// </summary>
    public class SubjectVisitCheckPassedTrigger : IAfterSaveTrigger<SubjectVisit>
    {
        private readonly IRepository<SubjectVisit> _subjectVisitRepository;
        private readonly IRepository<VisitTask> _visitTaskRepository;

        private readonly IRepository<Trial> _trialRepository;
        private readonly IRepository<TaskAllocationRule> _taskAllocationRuleRepository;

        private readonly IEasyCachingProvider _provider;

        private readonly IMapper _mapper;

        public SubjectVisitCheckPassedTrigger(IRepository<SubjectVisit> subjectVisitRepository, IRepository<VisitTask> visitTaskRepository,
            IRepository<Trial> trialRepository,
            IRepository<TaskAllocationRule> taskAllocationRuleRepository,
            IEasyCachingProvider provider,
            IMapper mapper)
        {
            _subjectVisitRepository = subjectVisitRepository;
            _visitTaskRepository = visitTaskRepository;
            _provider = provider;
            _mapper = mapper;
            _taskAllocationRuleRepository = taskAllocationRuleRepository;
            _trialRepository = trialRepository;
        }

        public async Task AfterSave(ITriggerContext<SubjectVisit> context, CancellationToken cancellationToken)
        {

            var subjectVisit = context.Entity;


            if (context.ChangeType == ChangeType.Modified)
            {

                // 一致性核查通过  生成读片任务
                if (context.UnmodifiedEntity?.CheckState != subjectVisit.CheckState && subjectVisit.CheckState == CheckStateEnum.CVPassed)
                {

                    if (_taskAllocationRuleRepository.Where(t => t.TrialId == subjectVisit.TrialId && t.IsEnable).Count() < 2)
                    {
                        throw new BusinessValidationFailedException("能参与读片的医生数量必须大于2,自动分配任务中止");
                    }

                    var dbMaxCode = _visitTaskRepository.Where(t => t.TrialId == subjectVisit.TrialId).Select(t => t.Code).DefaultIfEmpty().Max();

                    var cacheMaxCodeInt = _provider.Get<int>($"{subjectVisit.TrialId }_{ StaticData.CacheKey.TaskMaxCode}").Value;

                    int currentMaxCodeInt = cacheMaxCodeInt > dbMaxCode ? cacheMaxCodeInt : dbMaxCode;

                    _provider.Set<int>($"{subjectVisit.TrialId }_{ StaticData.CacheKey.TaskMaxCode}", currentMaxCodeInt + 2, TimeSpan.FromMinutes(30));

                    var trialConfig = (await _trialRepository.Where(t => t.Id == subjectVisit.TrialId).Select(t => new { TrialId = t.Id, t.ReadingType, t.TaskAllocateDefaultState, t.TaskAllocateObjEnum }).FirstOrDefaultAsync()).IfNullThrowException();

                    //统计当前医生分配信息  有效医生数量必须大于2 已做验证
                    var allocateStat = _taskAllocationRuleRepository.Where(t => t.TrialId == subjectVisit.TrialId && t.IsEnable).ProjectTo<AllocateInfo>(_mapper.ConfigurationProvider).ToList();

                    if (trialConfig.ReadingType == ReadingMethod.Double)
                    {

                        //每个访视 根据项目配置生成任务  双审生成两个 
                        var task1 = await _visitTaskRepository.AddAsync(new VisitTask()
                        {
                            TrialId = subjectVisit.TrialId,
                            SubjectId = subjectVisit.SubjectId,
                            IsUrgent = subjectVisit.IsUrgent,
                            TaskBlindName = subjectVisit.BlindName,
                            TaskName = subjectVisit.VisitName,
                            CheckPassedTime = subjectVisit.CheckPassedTime,
                            ArmEnum = 1,//特殊
                            Code = currentMaxCodeInt + 1,
                            TaskCode = AppSettings.GetCodeStr(currentMaxCodeInt + 1, nameof(VisitTask)),
                            ReadingCategory = ReadingCategory.Visit
                        });

                        var task2 = await _visitTaskRepository.AddAsync(new VisitTask()
                        {
                            TrialId = subjectVisit.TrialId,
                            SubjectId = subjectVisit.SubjectId,
                            IsUrgent = subjectVisit.IsUrgent,
                            TaskBlindName = subjectVisit.BlindName,
                            TaskName = subjectVisit.VisitName,
                            CheckPassedTime = subjectVisit.CheckPassedTime,
                            ArmEnum = 2,//特殊
                            Code = currentMaxCodeInt + 2,
                            TaskCode = AppSettings.GetCodeStr(currentMaxCodeInt + 2, nameof(VisitTask)),
                            ReadingCategory = ReadingCategory.Visit
                        });


                        if (trialConfig.TaskAllocateDefaultState == TaskAllocateDefaultState.Allocated)
                        {
                            task1.TaskState =TaskState.Allocated;
                            task2.TaskState = TaskState.Allocated;
                        }
                        else if (trialConfig.TaskAllocateDefaultState == TaskAllocateDefaultState.InitAllocated)
                        {
                            task1.TaskState = TaskState.InitAllocated;
                            task2.TaskState = TaskState.InitAllocated;
                        }

                        if (trialConfig.TaskAllocateObjEnum == TaskAllocateObj.Subject)
                        {

                            //该Subject 之前是否有已分配的   如果改变配置  可能会出现  一个Subject 分配的同一个医生 有的在Arm1 有的在Arm2
                            var allocateSubjectArmList = _visitTaskRepository.Where(t => t.SubjectId == subjectVisit.SubjectId && t.TrialId == subjectVisit.TrialId && t.DoctorUserId != null).Select(t => new { t.DoctorUserId, t.ArmEnum }).Distinct().ToList();

                            //初次自动分配
                            if (allocateSubjectArmList.Count == 0)
                            {
                                //排除已经入选其他Arm的阅片人

                                //是否有做过Arm1的医生  有新的医生未分配 按照最优法找
                                if (allocateStat.Any(t => t.ArmList.Any(t => t == 1)) && !allocateStat.Any(t=>t.ArmList.Count==0))
                                {

                                    task1.DoctorUserId = allocateStat.Where(t => t.ArmList.Any(t => t == 1)).OrderByDescending(t => t.TotalTaskCount * t.PlanReadingRatio * 0.01 - t.SelfTaskCount).ThenByDescending(t => t.PlanReadingRatio).FirstOrDefault().DoctorUserId;

                                }
                                else
                                {
                                    //找到最优的需要分配任务的医生
                                    task1.DoctorUserId = allocateStat.OrderByDescending(t => t.TotalTaskCount * t.PlanReadingRatio * 0.01 - t.SelfTaskCount).ThenByDescending(t => t.PlanReadingRatio).FirstOrDefault().DoctorUserId;

                                    allocateStat.FirstOrDefault(t => t.DoctorUserId == task1.DoctorUserId).ArmList.Add(1);
                                }

                                //是否有做过Arm2的医生   有新的医生未分配 按照最优法找
                                if (allocateStat.Any(t => t.ArmList.Any(t => t == 2)) && !allocateStat.Any(t => t.ArmList.Count == 0))
                                {
                                    
                                    task2.DoctorUserId = allocateStat.Where(t => t.ArmList.Any(t => t == 2)).OrderByDescending(t => t.TotalTaskCount * t.PlanReadingRatio * 0.01 - t.SelfTaskCount).ThenByDescending(t => t.PlanReadingRatio).FirstOrDefault().DoctorUserId;
                                }
                                else
                                {
                                    //找到最优的需要分配任务的医生
                                    task2.DoctorUserId = allocateStat.OrderByDescending(t => t.TotalTaskCount * t.PlanReadingRatio * 0.01 - t.SelfTaskCount).ThenByDescending(t => t.PlanReadingRatio).Skip(1).FirstOrDefault().DoctorUserId;
                                }
                               
                            }
                            else
                            {
                                if (allocateSubjectArmList.GroupBy(t => t.DoctorUserId).Any(g => g.Count() == 2))
                                {
                                    throw new BusinessValidationFailedException("请确认是否改了配置，导致同一受试者 分配给同一个医生 在不同的Arm,无法完成自动分配");
                                }

                                //手动分配的时候  如果只分配了Arm1  没有分配Arm2 就会有问题
                                if (!(allocateSubjectArmList.Any(t => t.ArmEnum == 1) && allocateSubjectArmList.Any(t => t.ArmEnum == 2)))
                                {
                                    throw new BusinessValidationFailedException("请确认是否改了配置，或者手动分配时，只分配了一个Arm ");
                                }

                                //分配给对应Arm的人
                                task1.DoctorUserId = allocateSubjectArmList.FirstOrDefault(t => t.ArmEnum == 1).DoctorUserId;
                                task2.DoctorUserId = allocateSubjectArmList.FirstOrDefault(t => t.ArmEnum == 2).DoctorUserId;
                            }

                            task1.AllocateTime = DateTime.Now;
                            task2.AllocateTime = DateTime.Now;
                        }

                    }
                    else if (trialConfig.ReadingType == ReadingMethod.Single)
                    {
                        await _visitTaskRepository.AddAsync(new VisitTask()
                        {
                            TrialId = subjectVisit.TrialId,
                            SubjectId = subjectVisit.SubjectId,
                            IsUrgent = subjectVisit.IsUrgent,
                            TaskBlindName = subjectVisit.BlindName,
                            TaskName = subjectVisit.VisitName,
                            CheckPassedTime = subjectVisit.CheckPassedTime,
                            ArmEnum = 0, //特殊
                            Code = currentMaxCodeInt + 1,
                            TaskCode = AppSettings.GetCodeStr(currentMaxCodeInt + 1, nameof(VisitTask)),
                            ReadingCategory = ReadingCategory.Visit
                        });

                    }


                    await _visitTaskRepository.SaveChangesAsync();
                }

            }

        }





    }
}