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

namespace FlexJobApi.UserServer.Application
{
    /// <summary>
    /// 同步电子签配置
    /// </summary>
    public class SyncElectronSignSettingsCommandHandler(
            IRepository<ElectronSignSetting> rep,
            IRepository<EnterpriseElectronSignSetting> repEnterpriseElectronSignSetting
        ) :
        IRequestHandler<SyncElectronSignSettingsCommand, bool>,
        IRequestHandler<CheckElectronSignAccessEnabledsCommand, bool>
    {
        private readonly IRepository<ElectronSignSetting> rep = rep;
        private readonly IRepository<EnterpriseElectronSignSetting> repEnterpriseElectronSignSetting = repEnterpriseElectronSignSetting;

        /// <summary>
        /// 同步电子签配置
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public async Task<bool> Handle(SyncElectronSignSettingsCommand request, CancellationToken cancellationToken)
        {
            var accesses = request.Items.DistinctSelect(it => it.Access);
            var entities = await rep.AsQueryable()
                .Where(it => accesses.Contains(it.Access))
                .ToListAsync();
            foreach (var item in request.Items)
            {
                var entity = entities.FirstOrDefault(it => it.Access == item.Access);
                if (entity == null)
                {
                    entity = new ElectronSignSetting();
                    item.Adapt(entity);
                    await rep.InsertAsync(entity);
                }
                else
                {
                    item.Adapt(entity);
                    await rep.UpdateAsync(entity);
                }
            }
            var disableds = entities.Where(it => it.IsDisabled).Select(it => it.Access).ToList();
            var settings = await repEnterpriseElectronSignSetting.AsQueryable()
                .Where(it => disableds.Contains(it.ElectronSignAccess))
                .ToListAsync();
            if (settings.IsNotNull())
            {
                await repEnterpriseElectronSignSetting.DeleteAsync(settings);
            }
            return true;
        }

        /// <summary>
        /// 校验电子签通道是否启用
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public async Task<bool> Handle(CheckElectronSignAccessEnabledsCommand request, CancellationToken cancellationToken)
        {
            var accesses = await rep.AsQueryable().AsNoTracking()
                .Where(it => !it.IsDisabled)
                .Select(it => it.Access)
                .ToListAsync(cancellationToken);
            var disabledAccesses = request.Accesses.Where(it => !accesses.Contains(it)).ToList();
            if (disabledAccesses.IsNotNull())
            {
                var model = await EnumUtils.GetModel<EnumElectronSignAccess>();
                var descriptions = model.Items.Where(it => disabledAccesses.Contains(it.Enum)).Select(it => it.Description).SplitJoin(",");
                throw Oops.Oh(EnumErrorCodeType.s400, $"未开通通道：{descriptions}");
            }
            return true;
        }
    }
}