using System.Linq.Expressions;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Localization;
using SJZY.Expand.ABP.Core.Localization;
using SJZY.Expand.ABP.Core.PublicMethords;
using SJZY.Track.Application.Contract.Dtos.TrackPull;
using SJZY.Track.Application.Contract.Services;
using SJZY.Track.Application.Localization;
using SJZY.Track.Domain.Aggregates.TrackPullAggregate;
using SJZY.Track.Domain.Dtos.Common;
using SJZY.Track.Domain.Dtos.TrackPull;
using SqlSugar;

namespace SJZY.Track.Application.Services.TrackPull;

/// <summary>
/// 轨迹拉取
/// </summary>
[ApiExplorerSettings(GroupName = "轨迹拉取")]
[Route("/Track/PullConfig")]
public class TrackPullService : ApplicationService
{
    private readonly IStringLocalizer<TrackLocalizationResource> _stringLocalizer;
    private readonly ITrackPullCacheService _trackPullCacheService;
    private readonly ITrackPullConfigRepository _trackPullConfigRepository;

    public TrackPullService(
        IStringLocalizer<TrackLocalizationResource> stringLocalizer,
        ITrackPullConfigRepository trackPullConfigRepository,
        ITrackPullCacheService trackPullCacheService)
    {
        _stringLocalizer = stringLocalizer;
        _trackPullConfigRepository = trackPullConfigRepository;
        _trackPullCacheService = trackPullCacheService;
    }

    /// <summary>
    /// 轨迹拉取配置列表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost("GetPage")]
    public async Task<UnifyPageResultDto<GetTrackPullConfigPageOutputVO>> GetPageAsync([FromBody] KeywordsInputVO input)
    {
        return await _trackPullConfigRepository.GetPageAsync(input);
    }

    /// <summary>
    /// 轨迹拉取配置内容列表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost("GetContentPage")]
    public async Task<UnifyPageResultDto<GetTrackPullContentPageOutputVO>> GetContentPageAsync(
        [FromBody] GetTrackPullContentPageInputVO input)
    {
        return await _trackPullConfigRepository.GetContentPageAsync(input);
    }

    /// <summary>
    /// 轨迹拉取配置详情
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpGet("GetDetail")]
    public async Task<GetTrackPullConfigDetailOutputVO> GetDetailAsync(int id)
    {
        return await _trackPullConfigRepository.GetDetailAsync(id);
    }

    /// <summary>
    /// 轨迹拉取配置内容详情
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpGet("GetContentDetail")]
    public async Task<GetTrackPullContentDetailOutputVO> GetContentDetailAsync(int id)
    {
        return await _trackPullConfigRepository.GetContentDetailAsync(id);
    }

    /// <summary>
    /// 轨迹拉取配置编辑
    /// </summary>
    /// <param name="input"></param>
    /// <param name="configuration"></param>
    /// <returns></returns>
    [HttpPost("Edit")]
    public async Task<bool> EditAsync([FromBody] EditTrackPullConfigInput input,
        [FromServices] IConfiguration configuration)
    {
        if (input.PullInterval < 60) input.PullInterval = 60;

        if (input.Options != OptionTypeNoNull.删除)
        {
            Expression<Func<TrackPullConfigEntity, bool>> isAnyExp = x =>
                x.SubSystemId == input.SubSystemId && x.ServiceProviderId == input.ServiceProviderId;
            if (input.Options == OptionTypeNoNull.修改) isAnyExp = isAnyExp.And(x => x.Id != input.Id);

            if (await _trackPullConfigRepository.IsAnyAsync(isAnyExp))
                throw new BusinessException(message: _stringLocalizer["IsTrackPullConfigAny"]);
        }

        switch (input.Options)
        {
            case OptionTypeNoNull.新增:
                {
                    var trackPullEntity = ObjectMapper.Map<EditTrackPullConfigInput, TrackPullConfigEntity>(input);

                    if (input.ParseMethod == (int) ParseMethod.InterfaceRelay)
                    {
                        var paramsConfig = configuration.GetSection("InterfaceRelayParamsConfig")
                            .Get<Dictionary<string, string>>();
                        if (paramsConfig == null)
                        {
                            throw new BusinessException(message: "未找到接口通参数配置，联系管理员添加");
                        }

                        trackPullEntity.OrderPath = paramsConfig[nameof(trackPullEntity.OrderPath)];
                        trackPullEntity.OrderNoName = paramsConfig[nameof(trackPullEntity.OrderNoName)];
                        trackPullEntity.TrackDetailsPath = paramsConfig[nameof(trackPullEntity.TrackDetailsPath)];
                        trackPullEntity.TrackContentCodeName =
                            paramsConfig[nameof(trackPullEntity.TrackContentCodeName)];
                        trackPullEntity.TrackStatusName = paramsConfig[nameof(trackPullEntity.TrackStatusName)];
                        trackPullEntity.TrackContentName = paramsConfig[nameof(trackPullEntity.TrackContentName)];
                        trackPullEntity.TrackPlaceName = paramsConfig[nameof(trackPullEntity.TrackPlaceName)];
                        trackPullEntity.TrackTimeName = paramsConfig[nameof(trackPullEntity.TrackTimeName)];
                        trackPullEntity.TrackTimeZoneName = paramsConfig[nameof(trackPullEntity.TrackTimeZoneName)];
                    }

                    var id = await _trackPullConfigRepository.InsertReturnIdentityAsync(trackPullEntity);

                    await _trackPullCacheService.SetPullConfigAsync(id);
                }
                break;

            case OptionTypeNoNull.修改:
                {
                    var oldTrackPullEntity = await _trackPullConfigRepository.GetFirstAsync(x => x.Id == input.Id) ??
                                             throw new BusinessException(message: _stringLocalizer["NotFindData"]);

                    ObjectMapper.Map(input, oldTrackPullEntity);

                    await _trackPullConfigRepository.UpdateAsync(oldTrackPullEntity);

                    await _trackPullCacheService.SetPullConfigAsync(input.Id);
                }
                break;

            case OptionTypeNoNull.删除:
                using (var ts = TransactionScopeHelper.Create())
                {
                    await _trackPullConfigRepository.SoftDeleteAsync(x => x.Id == input.Id);

                    await _trackPullConfigRepository.SoftDeleteContentAsync(x => x.TrackPullConfigId == input.Id);

                    await _trackPullCacheService.SetPullConfigAsync(input.Id);
                    ts.Complete();
                }

                break;

            default:
                throw new BusinessException(message: _stringLocalizer[SjzyBasicLocalization.Validation_IsInEnum,
                    nameof(EditTrackPullConfigInput.Options)]);
        }

        return true;
    }

    /// <summary>
    /// 轨迹拉取配置内容编辑
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost("EditContent")]
    public async Task<bool> EditContentAsync([FromBody] EditTrackPullContentInput input)
    {
        if (input.Options != OptionTypeNoNull.删除)
        {
            Expression<Func<TrackPullContentConfigEntity, bool>> isContentAnyExp = x =>
                x.TrackPullConfigId == input.TrackPullConfigId;

            if (input.Options == OptionTypeNoNull.修改)
            {
                isContentAnyExp = isContentAnyExp.And(x => x.Id != input.Id);
            }

            if (await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(x =>
                    x.TrackContentId == input.TrackContentId)))
                throw new BusinessException(message: _stringLocalizer["IsTrackPullContentAny"]);

            if (!input.TrackStatusValues.IsNullOrEmpty())
            {
                Expression<Func<TrackPullContentConfigEntity, bool>> trackStatusValuesExp = _ => false;
                input.TrackStatusValues!.ForEach(item =>
                {
                    trackStatusValuesExp = trackStatusValuesExp.Or(x => SqlFunc.SplitIn(x.TrackKeyword, item));
                });

                if (await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(trackStatusValuesExp)))
                    throw new BusinessException(message: _stringLocalizer["IsTrackPullContentStatusValueAny"]);
            }

            if (!input.TrackKeywords.IsNullOrEmpty())
            {
                Expression<Func<TrackPullContentConfigEntity, bool>> trackKeywordExp = _ => false;
                input.TrackKeywords!.ForEach(item =>
                {
                    trackKeywordExp = trackKeywordExp.Or(x => SqlFunc.SplitIn(x.TrackKeyword, item));
                });

                if (await _trackPullConfigRepository.IsContentAnyAsync(isContentAnyExp.And(trackKeywordExp)))
                    throw new BusinessException(message: _stringLocalizer["IsTrackPullContentKeywordsAny"]);
            }
        }

        switch (input.Options)
        {
            case OptionTypeNoNull.新增:
                {
                    var entity = ObjectMapper.Map<EditTrackPullContentInput, TrackPullContentConfigEntity>(input);

                    await _trackPullConfigRepository.InsertContentAsync(entity);
                    await _trackPullCacheService.SetPullConfigAsync(input.TrackPullConfigId);

                    break;
                }

            case OptionTypeNoNull.修改:
                {
                    var oldTrackPullContentEntity =
                        await _trackPullConfigRepository.GetContentByIdAsync(input.Id!.Value) ??
                        throw new BusinessException(message: _stringLocalizer["NotFindData"]);

                    ObjectMapper.Map(input, oldTrackPullContentEntity);

                    await _trackPullConfigRepository.UpdateContentAsync(oldTrackPullContentEntity);
                    await _trackPullCacheService.SetPullConfigAsync(oldTrackPullContentEntity.TrackPullConfigId);

                    break;
                }

            case OptionTypeNoNull.删除:
                {
                    var oldTrackPullContentEntity =
                        await _trackPullConfigRepository.GetContentByIdAsync(input.Id!.Value) ??
                        throw new BusinessException(message: _stringLocalizer["NotFindData"]);

                    await _trackPullConfigRepository.SoftDeleteContentAsync(x => x.Id == input.Id);
                    await _trackPullCacheService.SetPullConfigAsync(oldTrackPullContentEntity.TrackPullConfigId);

                    break;
                }

            default:
                throw new BusinessException(message: _stringLocalizer[SjzyBasicLocalization.Validation_IsInEnum,
                    nameof(EditTrackPullContentInput.Options)]);
        }

        return true;
    }
}