using FlexJobApi.Core;
using Furion.DatabaseAccessor;
using Furion.FriendlyException;
using MediatR;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FlexJobApi.FlexJobServer.Application
{
    /// <summary>
    /// 任务验收命令处理器
    /// </summary>
    public class TaskCheckReceiveCommandHandler(
            IRepository<TaskInfo> repTaskInfo,
            IRepository<TaskInfoUser> repTaskInfoUser,
            IRepository<TaskInfoUserSubmit> repTaskInfoUserSubmit
        ) :
        IRequestHandler<SubmitCheckReceiveTaskCommand, Guid>,
        IRequestHandler<CheckReceiveTaskCommand, Guid>
    {
        private readonly IRepository<TaskInfo> repTaskInfo = repTaskInfo;
        private readonly IRepository<TaskInfoUser> repTaskInfoUser = repTaskInfoUser;
        private readonly IRepository<TaskInfoUserSubmit> repTaskInfoUserSubmit = repTaskInfoUserSubmit;

        /// <summary>
        /// 任务提交验收
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        [UnitOfWork]
        public async Task<Guid> Handle(SubmitCheckReceiveTaskCommand request, CancellationToken cancellationToken)
        {
            var now = DateTime.Now;
            var logier = JwtUtils.GetCurrentLogier();
            var task = await repTaskInfo.AsQueryable()
                .FirstOrDefaultAsync(it => it.Id == request.TaskInfoId, cancellationToken);
            if (task == null) throw Oops.Oh(EnumErrorCodeType.s404, "该任务");
            if (task.Status == EnumTaskStatus.Wait) throw Oops.Oh(EnumErrorCodeType.s510, "该任务暂未安排人员");
            if (task.ReleaseStatus == EnumTaskReleaseStatus.Stopped) throw Oops.Oh(EnumErrorCodeType.s510, "该任务已结束");
            if (!(task.BeginTime <= now && now <= task.EndTime)) throw Oops.Oh(EnumErrorCodeType.s510, "该任务已结束");
            var taskUser = await repTaskInfoUser.AsQueryable()
                .FirstOrDefaultAsync(it => it.TaskInfoId == task.Id && it.EnterpriseEmployee.UserId == logier.Id, cancellationToken);
            if (taskUser == null) throw Oops.Oh(EnumErrorCodeType.s404, "该报名信息");
            if (taskUser.ArrangeStatus == EnumTaskUserArrangeStatus.Wait) throw Oops.Oh(EnumErrorCodeType.s510, "暂未安排该任务");
            task.LastSubmitTime = now;
            taskUser.LastSubmitTime = now;
            var submit = await repTaskInfoUserSubmit.AsQueryable()
                .Include(it => it.Files)
                .FirstOrDefaultAsync(it => it.TaskInfoUserId == taskUser.Id && it.Date == now.Date);
            if (submit == null)
            {
                submit = new TaskInfoUserSubmit
                {
                    TaskInfoUserId = taskUser.Id,
                    Date = now.Date,
                    Files = request.Files.Select(it => new TaskInfoUserSubmitFile
                    {
                        File = it
                    }).ToList(),
                    CreatedTime = now,
                    CheckReceiveStatus = EnumTaskUserSubmitCheckReceiveStatus.WaitCheckReceive,
                };
                await repTaskInfoUserSubmit.InsertAsync(submit);
                return submit.Id;
            }
            else if (submit.CheckReceiveStatus == EnumTaskUserSubmitCheckReceiveStatus.Success)
            {
                throw Oops.Oh(EnumErrorCodeType.s510, "验收已完成，无法修改");
            }
            else
            {
                submit.Files = request.Files.Select(it => new TaskInfoUserSubmitFile
                {
                    File = it
                }).ToList();
                submit.CheckReceiveStatus = EnumTaskUserSubmitCheckReceiveStatus.WaitCheckReceive;
                submit.CreatedTime = now;
                await repTaskInfoUserSubmit.UpdateAsync(submit);
                return submit.Id;
            }
        }

        /// <summary>
        /// 任务验收
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        [UnitOfWork]
        public async Task<Guid> Handle(CheckReceiveTaskCommand request, CancellationToken cancellationToken)
        {
            var now = DateTime.Now;
            var logier = JwtUtils.GetCurrentLogier();
            var submit = await repTaskInfoUserSubmit.AsQueryable()
                .Include(it => it.Files)
                .FirstOrDefaultAsync(it => it.Id == request.Id);
            if (submit == null) throw Oops.Oh(EnumErrorCodeType.s404, "该提交信息");
            var taskUser = await repTaskInfoUser.AsQueryable()
                .FirstOrDefaultAsync(it => it.Id == submit.TaskInfoUserId, cancellationToken);
            if (taskUser == null) throw Oops.Oh(EnumErrorCodeType.s404, "该灵工信息");
            if (taskUser.ArrangeStatus == EnumTaskUserArrangeStatus.Wait) throw Oops.Oh(EnumErrorCodeType.s510, "未安排该灵工");
            var task = await repTaskInfo.AsQueryable()
                .FirstOrDefaultAsync(it => it.Id == taskUser.TaskInfoId && it.EnterpriseId == logier.EnterpriseId, cancellationToken);
            if (task == null) throw Oops.Oh(EnumErrorCodeType.s404, "该任务");
            if (task.Status == EnumTaskStatus.Wait) throw Oops.Oh(EnumErrorCodeType.s510, "该任务暂未安排人员");
            if (task.ReleaseStatus == EnumTaskReleaseStatus.Stopped) throw Oops.Oh(EnumErrorCodeType.s510, "该任务已结束");
            if (!(task.BeginTime <= now && now <= task.EndTime)) throw Oops.Oh(EnumErrorCodeType.s510, "该任务已结束");
            if (request.CheckReceiveStatus != EnumTaskUserSubmitCheckReceiveStatus.Success
                && request.CheckReceiveStatus != EnumTaskUserSubmitCheckReceiveStatus.Fail)
                throw Oops.Oh(EnumErrorCodeType.s400, "请选择正确的验收状态");
            submit.CheckReceiveStatus = request.CheckReceiveStatus;
            submit.CheckReceiveTime = now;
            taskUser.LastCheckReceiveTime = now;
            task.LastCheckReceiveTime = now;

            var dates = new List<DateTime>();
            for (DateTime i = task.BeginTime.Date; i <= task.EndTime.Date; i = i.AddDays(1))
            {
                dates.Add(i);
            }
            var taskUserSubmitDates = await repTaskInfoUserSubmit.AsQueryable().AsNoTracking()
                .Where(it =>
                    it.TaskInfoUserId == taskUser.Id
                    && it.Id != submit.Id
                    && (it.CheckReceiveStatus == EnumTaskUserSubmitCheckReceiveStatus.Success
                    || it.CheckReceiveStatus == EnumTaskUserSubmitCheckReceiveStatus.Fail))
                .Select(it => it.Date)
                .ToListAsync();
            taskUserSubmitDates.Add(now.Date);
            if (dates.All(taskUserSubmitDates.Contains))
            {
                taskUser.CheckReceiveStatus = EnumTaskCheckReceiveStatus.Completed;
            }

            var taskUserCheckReceiveStatuses = await repTaskInfoUser.AsQueryable().AsNoTracking()
                .Where(it =>
                    it.TaskInfoId == task.Id
                    && it.Id != taskUser.Id)
                .Select(it => it.CheckReceiveStatus)
                .ToListAsync();
            taskUserCheckReceiveStatuses.Add(EnumTaskCheckReceiveStatus.Completed);
            if (taskUserCheckReceiveStatuses.All(it => it == EnumTaskCheckReceiveStatus.Completed))
            {
                task.CheckReceiveStatus = EnumTaskCheckReceiveStatus.Completed;
            }

            await repTaskInfoUserSubmit.UpdateAsync(submit);
            return submit.Id;
        }
    }
}