using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using KonSoft.Admin.Dtos;
using KonSoft.Admin.Entities;
using KonSoft.Admin.IApplicationServices;
using KonSoft.Admin.IRepositories;
using Volo.Abp;
using Volo.Abp.Application.Dtos;
using Volo.Abp.Application.Services;
using Volo.Abp.Domain.Repositories;

namespace KonSoft.Admin.ApplicationServices;

public class ProductAppAppService(IProductRepository repository) : ApplicationService, IProductAppService
{
    private readonly IProductRepository repository = repository;

    /// <summary>
    ///     创建产品
    /// </summary>
    public async Task CreateAsync(CreateProductDto input)
    {
        var id = Guid.NewGuid();
        var product = new Product(id, input.Name, input.Code, input.Price, input.Description, input.Type,
            input.ParentId, input.Status, input.Order);
        await repository.InsertAsync(product);
    }

    /// <summary>
    ///     删除
    /// </summary>
    public async Task DeleteAsync(Guid id)
    {
        await repository.DeleteAsync(x => x.Id == id);
    }

    /// <summary>
    ///     查询
    /// </summary>
    public async Task<ProductDto> GetAsync(Guid id)
    {
        var product = await repository.GetAsync(x => x.Id == id);
        return ObjectMapper.Map<Product, ProductDto>(product);
    }

    /// <summary>
    ///     查询集合
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task<PagedResultDto<ProductDto>> GetListAsync(PagedResultRequestDto input)
    {
        var query = await repository.GetPageRootListAsync(input.SkipCount, input.MaxResultCount,
            x => x.ParentId == null);
        var all = await repository.GetListAsync(x => x.ParentId != null);
        foreach (var item in query)
        {
            BuildChildren(item, all);
        }

        var totalCount = await repository.CountAsync(x => x.ParentId == null);

        var productDtos = ObjectMapper.Map<List<Product>, List<ProductDto>>(query);

        return new PagedResultDto<ProductDto>(totalCount, productDtos);
    }

    /// <summary>
    ///     修改
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task UpdateAsync(UpdateProductDto input)
    {
        // 根据ID查询订单，如果不存在则抛出异常【修改前端必然看到了,数据若查不到提示自定义异常信息】
        var order = await repository.FindAsync(o => o.Id == input.Id) ??
                    throw new BusinessException("商品找不到").WithData("Id", input.Id);

        // 将输入的DTO字段映射到订单实体
        ObjectMapper.Map(input, order);

        // 更新订单
        await repository.UpdateAsync(order);
    }

    private static void BuildChildren(Product parent, List<Product> all)
    {
        var children = all
            .Where(x => x.ParentId == parent.Id)
            .OrderBy(x => x.Order)
            .ToList();

        parent.Children = children;

        foreach (var child in children)
        {
            BuildChildren(child, all); // 递归
        }
    }
}