using Castle.Core.Internal;
using IRaCIS.Core.Application.Contracts;
using IRaCIS.Core.Application.Service.Inspection.DTO;
using IRaCIS.Core.Application.Service.Inspection.Interface;
using IRaCIS.Core.Domain.Share;
using Newtonsoft.Json;
using Panda.DynamicWebApi.Attributes;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace IRaCIS.Core.Application.Service.Inspection
{
    [NonDynamicWebApi]
    public class InspectionService : BaseService, IInspectionService
    {
        public InspectionService()
        { 
        
        }
        public async Task<PageOutput<GetDataInspectionOutDto>> GetInspectionData(GetDataInspectionDto dto)
        {
            //_repository.GetQueryable.GetQueryable < DataInspection >

            #region 逻辑代码
            var query = from data in _repository.GetQueryable<DataInspection>()
                        join trial in _repository.GetQueryable<Trial>() on data.TrialId equals trial.Id into trialtemp
                        from leftrial in trialtemp.DefaultIfEmpty()
                        join site in _repository.GetQueryable<Site>() on data.SiteId equals site.Id into sitetemp
                        from leftsite in sitetemp.DefaultIfEmpty()
                        join subject in _repository.GetQueryable<Subject>() on data.SubjectId equals subject.Id into subtemp
                        from leftsubject in subtemp.DefaultIfEmpty()
                        join subjectVisit in _repository.GetQueryable<SubjectVisit>() on data.SubjectVisitId equals subjectVisit.Id into subjectVisittemp
                        from leftsubjectVisit in subjectVisittemp.DefaultIfEmpty()
                        join parent in _repository.GetQueryable<DataInspection>() on data.ParentId equals parent.Id into parenttemp
                        from leftparent in parenttemp.DefaultIfEmpty()
                        join user in _repository.GetQueryable<User>() on data.CreateUserId equals user.Id into usertemp
                        from leftuser in usertemp.DefaultIfEmpty()

                        select new GetDataInspectionOutDto()
                        {
                            CreateTime = data.CreateTime,
                            CreateUserId = data.CreateUserId,
                            ModuleType = data.ModuleType,
                            BlindName = data.BlindName,
                            TrialId = data.TrialId,
                            SiteId = data.SiteId,
                            SubjectId = data.SubjectId,
                            SubjectVisitId = data.SubjectVisitId,
                            OptType = data.OptType,
                            IP = data.IP,
                            Reason = data.Reason,
                            IsSign = data.IsSign,
                            SignId = data.SignId,
                            ParentId = data.ParentId,
                            ChildrenType = data.ChildrenType,
                            JsonDetail = data.JsonDetail,
                            SiteName = data.SiteName,
                            ExperimentName = data.TrialName,
                            FirstName = leftsubject.FirstName,
                            LastName = leftsubject.LastName,
                            Id = data.Id,
                            ParentJson = leftparent.JsonDetail,
                            VisitName = data.SubjectVisitName,
                            CreateUser = leftuser.UserName,
                            UserFirstName = leftuser.FirstName,
                            UserLastName = leftuser.LastName,
                            //SubjectCode=leftsubject.Code,
                            SubjectCode =data.SubjectCode,
                            SubjectVisitName=data.SubjectVisitName,
                            CreateUserName = data.CreateUserName,
                            RoleName=data.RoleName,
                            TrialName=data.TrialName,
                        };

            query = query.WhereIf(!dto.BlindName.IsNullOrEmpty(), x => x.BlindName == dto.BlindName)
                .WhereIf(dto.IsSign != null, x => x.IsSign == dto.IsSign)
                .WhereIf(!dto.ChildrenType.IsNullOrEmpty(), x => x.ChildrenType == dto.ChildrenType)
                .WhereIf(!dto.ModuleType.IsNullOrEmpty(), x => x.ModuleType == dto.ModuleType)
                .WhereIf(!dto.OptType.IsNullOrEmpty(), x => x.OptType == dto.OptType)
                .WhereIf(!dto.Reason.IsNullOrEmpty(), x => x.Reason == dto.Reason)
                .WhereIf(dto.TrialId != null, x => x.TrialId == dto.TrialId)
                .WhereIf(dto.SubjectId != null, x => x.SubjectId == dto.SubjectId)
                .WhereIf(dto.SubjectVisitId != null, x => x.SubjectVisitId == dto.SubjectVisitId)
                .WhereIf(dto.SiteId != null, x => x.SiteId == dto.SiteId);
            #endregion

            #region 测试
            //var query = from data in _repository.GetQueryable<DataInspection>()

            //            join parent in _repository.GetQueryable<DataInspection>() on data.ParentId equals parent.Id into parenttemp
            //            from leftparent in parenttemp.DefaultIfEmpty()
            //            join subjectVisit in _repository.GetQueryable<SubjectVisit>() on data.SubjectVisitId equals subjectVisit.Id into subjectVisittemp

            //            from leftsubjectVisit in subjectVisittemp.DefaultIfEmpty()
            //            select new GetDataInspectionOutDto()
            //            {
            //                CreateTime = data.CreateTime,
            //                CreateUserId = data.CreateUserId,
            //                ModuleType = data.ModuleType,
            //                BlindName = data.BlindName,
            //                TrialId = data.TrialId,
            //                SiteId = data.SiteId,
            //                SubjectId = data.SubjectId,
            //                SubjectVisitId = data.SubjectVisitId,
            //                OptType = data.OptType,
            //                IP = data.IP,
            //                Reason = data.Reason,
            //                IsSign = data.IsSign,
            //                SignId = data.SignId,
            //                ParentId = data.ParentId,
            //                ChildrenType = data.ChildrenType,
            //                JsonDetail = data.JsonDetail,
            //                VisitName = leftsubjectVisit.VisitName,
            //                Id = data.Id,
            //                ParentJson = leftparent.JsonDetail,

            //            };
            #endregion


            dto.Asc = false;
            return await query.ToPagedListAsync(dto.PageIndex, dto.PageSize, "CreateTime", dto.Asc);
        }


        /// <summary>
        /// 通用逻辑封装
        /// </summary>
        /// <param name="OptCommand">方法参数</param>
        /// <param name="AuditInfo">添加稽查</param>
        /// <param name="SignInfo">用户签名</param>
        /// <param name="fun">委托</param>
        /// <param name="response">方法返回的结果</param>
        /// <param name="Statusdata">添加状态的对象</param>
        /// <returns></returns>
        public async Task<dynamic> Enforcement(dynamic OptCommand, DataInspectionAddDTO AuditInfo, SignDTO SignInfo, dynamic fun, IResponseOutput? response=null, object? Statusdata=null)
        {
            Guid? signId = null;
            MapData(OptCommand, AuditInfo);
            if (AuditInfo.IsSign)
            {
                // 验证用户签名信息
                var verifyResult = await VerifySignatureAsync(SignInfo);
                signId = await AddSignRecordAsync(SignInfo);
                if (verifyResult.IsSuccess == false)
                {
                    return verifyResult;
                }
                await AddSignRecordAsync(SignInfo);
            }

            IResponseOutput bResult;

            if (response != null)
            {
                bResult = response;
            }
            else
            {
                bResult = await fun(OptCommand);
            }

            // 用户 签名某个文档  
          

            if (bResult.IsSuccess == false)
            {
                return bResult;
            }

            // 判断是否需要前面

            await AddInspectionRecordAsync(AuditInfo, signId, Statusdata);

            if (bResult.IsSuccess == false)
            {
                return bResult;
            }
            return bResult;
        }


        /// <summary>
        ///  映射 SiteId  SubjectId  SubjectVisitId  TrialId  最开始没有  需要特殊处理
        /// </summary>
        /// <param name="data"></param>
        /// <param name="mapData"></param>
        public void MapData(dynamic data, dynamic mapData)
        {
            List<string> column = new List<string>() { "TrialId", "SiteId", "SubjectId", "SubjectVisitId" };
            foreach (var item in column)
            {
                try
                {
                    var value = data.GetType().GetProperty(item).GetValue(data);
                    mapData.GetType().GetProperty(item).SetValue(mapData, value);
                }
                catch (Exception)
                {
                    continue;

                }
            }
        }

        /// <summary> 验证用户签名信息 </summary> ///  
        public async Task<IResponseOutput> VerifySignatureAsync(SignDTO signDTO)
        {
            var user = await _repository.FirstOrDefaultAsync<User>(u => u.UserName == signDTO.UserName && u.Password == signDTO.PassWord);
            if (user == null)
            {
                return ResponseOutput.NotOk("password error");
            }
            else if (user.Status == UserStateEnum.Disable)
            {
                return ResponseOutput.NotOk("The user has been disabled!");
            }
            return ResponseOutput.Ok();

        }

        /// <summary> 添加签名记录 </summary> ///  
        public async Task<Guid> AddSignRecordAsync(SignDTO signDTO)
        {
            var add = await _repository.AddAsync(_mapper.Map<TrialSign>(signDTO));

            var success = await _repository.SaveChangesAsync();

            return add.Id;

        }

        /// <summary>
        /// 添加稽查记录
        /// </summary>
        /// <param name="addDto">添加对象</param>
        /// <param name="signId">签名Id</param>
        /// <param name="Statusdata">初始化状态对象</param>
        /// <returns></returns>
        public async Task<IResponseOutput> AddInspectionRecordAsync(DataInspectionAddDTO addDto, Guid? signId, object? Statusdata = null)
        {
            var add = _mapper.Map<DataInspection>(addDto);
            Guid? parentId = null;
            parentId = (await _repository.GetQueryable<DataInspection>().Where(x => x.TrialId == add.TrialId && x.SubjectVisitId == add.SubjectVisitId && x.SubjectId == add.SubjectId && x.SiteId == add.SiteId&&x.ModuleType==add.ModuleType&&x.ChildrenType==add.ChildrenType).OrderByDescending(x => x.CreateTime).FirstOrDefaultAsync())?.Id;
            add.ParentId = parentId;
            add.CreateTime = DateTime.Now;
            add.CreateUserId = _userInfo.Id;
            add.SignId = signId;
            add.IP = _userInfo.IP;
            await SetInspectionNameValue(add);
            await _repository.AddAsync(add);
            if (addDto.OptType.ToLower() == "Add".ToLower()&& Statusdata!=null)
            {
              

                DataInspection ststus = new DataInspection()
                {
                    SignId = signId,
                    SiteId = add.SiteId,
                    SubjectId = add.SubjectId,
                    SubjectVisitId = add.SubjectVisitId,
                    IsSign = add.IsSign,
                    BlindName = add.BlindName,
                    ChildrenType = "Status",
                    OptType = "Init",
                    CreateTime = add.CreateTime.AddMilliseconds(1),
                    CreateUserId = add.CreateUserId,
                    IP = add.IP,
                    ModuleType = add.ModuleType,
                    TrialId = add.TrialId,
                    JsonDetail = JsonConvert.SerializeObject(Statusdata),
                    TrialName=add.TrialName,
                    SiteName=add.SiteName,
                    SubjectCode = add.SubjectCode,
                    SubjectVisitName=add.SubjectVisitName,
                    CreateUserName=add.CreateUserName,
                    RoleName=add.RoleName,
                };

                await _repository.AddAsync(ststus);
            }

            var success = await _repository.SaveChangesAsync();
            return ResponseOutput.Ok(success);

        }

        /// <summary>
        /// 设置项目以及名称
        /// </summary>
        /// <param name="Data"></param>
        /// <returns></returns>
        public async Task SetInspectionNameValue(DataInspection Data)
        {
            #region 项目名称
            if (Data.TrialName.IsNullOrEmpty())
            {
                Data.TrialName = (await _repository.GetQueryable<Trial>().FirstOrDefaultAsync(x => x.Id == Data.TrialId))?.ExperimentName;
            }
            #endregion


            #region 测试中心名称
            if (Data.SiteName.IsNullOrEmpty())
            {
                Data.SiteName = (await _repository.GetQueryable<Site>().FirstOrDefaultAsync(x => x.Id == Data.SiteId))?.SiteName;
            }
            #endregion

            #region 受试者
            if (Data.SubjectCode.IsNullOrEmpty())
            {
                Data.SubjectCode = (await _repository.GetQueryable<Subject>().FirstOrDefaultAsync(x => x.Id == Data.SubjectId))?.Code;
            }
            #endregion

            #region 访视
            if (Data.SubjectVisitName.IsNullOrEmpty())
            {
                Data.SubjectVisitName = (await _repository.GetQueryable<SubjectVisit>().FirstOrDefaultAsync(x => x.Id == Data.SubjectVisitId))?.VisitName;
            }
            #endregion

            #region 创建者
            if (Data.CreateUserName.IsNullOrEmpty() || Data.RoleName.IsNullOrEmpty())
            {
                var userdata = await _repository.GetQueryable<User>().Where(x => x.Id == Data.CreateUserId).GroupJoin(_repository.GetQueryable<UserType>(), a => a.UserTypeId, b => b.Id, (a, b) => new
                {
                    UserName = a.FirstName + a.LastName,
                    Role = b
                }).SelectMany(a => a.Role, (m, n) => new
                {
                    UserName = m.UserName,
                    RoleName = n.UserTypeShortName
                }).FirstOrDefaultAsync();

                if (userdata != null)
                {
                    if (Data.CreateUserName.IsNullOrEmpty())
                    {
                        Data.CreateUserName = userdata?.UserName;
                    }


                    if (Data.RoleName.IsNullOrEmpty())
                    {
                        Data.RoleName = userdata?.RoleName;
                    }
                }
            }
            #endregion

        }
    }
}