using MES.Service.DB;
using MES.Service.Dto.service;
using MES.Service.Dto.webApi;
using MES.Service.Modes;
using SqlSugar;

namespace MES.Service.service.Warehouse;

/// <summary>
///     销售托盘管理服务
/// </summary>
public class SalesPalletManager : Repository<SalesPallet>
{
    /// <summary>
    /// 获取销售托盘分页数据
    /// </summary>
    /// <param name="request">查询请求参数</param>
    /// <returns></returns>
    public (List<SalesPalletQueryDto> item, int TotalCount)
        GetSalesPalletPage(SalesPalletSearchDto request)
    {
        var query = Db.Queryable<SalesPallet>()
            .LeftJoin<SalesDeliveryNotice>((z, a) => a.BillNo == z.BillNo)
            .LeftJoin<SalesDeliveryNoticeDetail>((z, a, b) =>
                a.ErpId == b.ErpHeadId && z.ItemId.ToString() == b.MaterialId)
            .LeftJoin<MesItems>((z, a, b, s) => s.Id.ToString() == b.MaterialId)
            .LeftJoin<MesUnit>((z, a, b, s, u) =>
                u.Id.ToString() == b.SalesUnitId)
            .LeftJoin<SysUser>((z, a, b, s, u, su) => su.Fcode == z.CheckUser)
            .LeftJoin<MesDepots>((z, a, b, s, u, su, d) =>
                d.DepotId.ToString() == b.Warehouse)
            .Where((z, a, b, s, u, su, d)=>z.SalesQuantity > 0)
            .WhereIF(!string.IsNullOrEmpty(request.BillNo),
                (z, a, b, s, u, su, d) => z.BillNo.Contains(request.BillNo))
            .WhereIF(!string.IsNullOrEmpty(request.ItemNo),
                (z, a, b, s, u, su, d) => s.ItemNo.Contains(request.ItemNo))
            .WhereIF(!string.IsNullOrEmpty(request.ItemName),
                (z, a, b, s, u, su, d) => s.ItemName.Contains(request.ItemName))
            .WhereIF(request.Status.HasValue,
                (z, a, b, s, u, su, d) => z.Status == request.Status)
            .Select((z, a, b, s, u, su, d) => new SalesPalletQueryDto
            {
                Id = z.Id,
                Status = z.Status,
                CheckDate = z.CheckDate,
                CheckUser = su.Fname,
                BillNo = z.BillNo,
                ItemNo = s.ItemNo,
                ItemName = s.ItemName,
                ItemModel = s.ItemModel,
                UnitName = u.Fname,
                Xsdd = b.SalesQuantity,
                Yb = z.SalesQuantity,
                Wyj = a.BillNo + s.Id.ToString()
            });

        var totalCount = 0;
        var items = query.ToPageList(request.PageIndex, request.Limit,
            ref totalCount);

        return (items, totalCount);
    }

    public List<SalesPalletDetailQueryDto>
        GetSalesPalletDetail(SalesPalletDetailQueryDto request)
    {
        var subQuery = Db.Queryable<MesPalletBinding1>()
            .LeftJoin<Womdaa>((a, b) => a.TicketNo == b.Daa001)
            .LeftJoin<MesItems>((a, b, it) => it.Id.ToString() == b.Daa002)
            .GroupBy((a, b, it) => new { a.Stackcode, it.Id })
            .Select((a, b, it) => new
            {
                StackCode = a.Stackcode,
                ItemId = it.Id,
                ItemNo = SqlFunc.AggregateMax(it.ItemNo),
                ItemName = SqlFunc.AggregateMax(it.ItemName),
                ItemModel = SqlFunc.AggregateMax(it.ItemModel)
            });

        var query = Db.Queryable<SalesPalletDetail>()
            .LeftJoin(subQuery, (b, o) => b.Stackcode == o.StackCode)
            .Where((b, o) => b.Mid == request.Mid)
            .Select((b, o) => new SalesPalletDetailQueryDto
            {
                Id = b.Id,
                Mid = b.Mid,
                BillNo = b.BillNo,
                Stackcode = b.Stackcode,
                Qty = b.Qty,
                ItemNo = o.ItemNo,
                ItemName = o.ItemName,
                ItemModel = o.ItemModel
            });

        return query.ToList();
    }

    /// <summary>
    /// 创建销售订单发货
    /// </summary>
    /// <param name="request">发货请求参数</param>
    /// <returns></returns>
    public int CreateSalesOrderShipping(CreateSalesOrderShippingRequestDto request)
    {
        //验证request.PalletIds是否为空
        if (request.PalletIds == null || !request.PalletIds.Any())
        {
            throw new Exception("销售托盘ID列表不能为空");
        }

        //调用GetSalesPalletDetail方法拿到返回值
        var allDetails = new List<SalesPalletDetailQueryDto>();
        foreach (var palletId in request.PalletIds)
        {
            var detailQuery = new SalesPalletDetailQueryDto { Mid = palletId };
            var details = GetSalesPalletDetail(detailQuery);
            allDetails.AddRange(details);
        }

        if (!allDetails.Any())
        {
            throw new Exception("未找到销售托盘明细数据");
        }

        //提取出结果集的Stackcode并去重
        var stackCodes = allDetails
            .Where(d => !string.IsNullOrEmpty(d.Stackcode))
            .Select(d => d.Stackcode)
            .Distinct()
            .ToList();

        if (!stackCodes.Any())
        {
            throw new Exception("未找到有效的栈板码");
        }

        //select * from MES_INV_ITEM_STOCKS where STACKCODE in (Stackcode去重后的结果);
        var stockItems = Db.Queryable<MesInvItemStocks>()
            .Where(s => stackCodes.Contains(s.StackCode) && s.Quantity > 0)
            .ToList();

        if (!stockItems.Any())
        {
            throw new Exception("未找到对应的库存数据");
        }

        //调用MesInvItemStocksManager.CreateReturnMaterialRequest方法
        var stockManager = new MesInvItemStocksManager();
        var itemStockQuery = new ItemStockQueryDto
        {
            UserCode = request.UserCode,
            Station = request.Station,
            ItemBarcodes = stackCodes
        };

        stockManager.CreateReturnMaterialRequest(itemStockQuery);

        return stackCodes.Count;
    }
}