using Admin.NET.Application.Entity;
using Admin.NET.Application.Service.ReportCenter.WmsOtherReport.Dto;

namespace Admin.NET.Application;
/// <summary>
/// 收货完成统计 服务
/// </summary>
[ApiDescriptionSettings(ApplicationConst.ReportCenterGroupName, Order = 100)]
public class WmsTakeGoodStatsService : IDynamicApiController, ITransient
{
    private readonly SqlSugarRepository<WmsOrderAsnDetails> _rep;

    private readonly SqlSugarRepository<WmsRecordReceivingDelivery> _wmsRecordReceivingDeliveryRep;

    public WmsTakeGoodStatsService(
        SqlSugarRepository<WmsRecordReceivingDelivery> wmsRecordReceivingDeliveryRep,
        SqlSugarRepository<WmsOrderAsnDetails> rep)

    {
        _wmsRecordReceivingDeliveryRep = wmsRecordReceivingDeliveryRep;
        _rep = rep;
    }

    /// <summary>
    /// 收货完成情况
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "Page")]
    [Description("WmsTakeGoodStats/Page")]
    public async Task<SqlSugarPagedList<WmsTakeGoodStatsOutput>> Page([FromQuery] WmsTakeGoodStatsInput input)
    {


        var today = DateTime.Today; // 获取当前日期

        // 查询当天的 ASN 单明细表，按照 ASN 单号、物料号、供应商名称进行分组
        var result = await Task.Run(() =>
        {
            var query = _rep.AsQueryable()
               .Where(a => a.CreateTime >= today) // 过滤条件，只取当天的记录
                .Select<WmsOrderAsnDetails>()
                .ToList();

            return query;
        });

        //查找今天收获的所有记录
        var records = await _wmsRecordReceivingDeliveryRep.AsQueryable().Where(x => x.CreateTime >= today).ToListAsync();

        var returnQuery = new SqlSugarPagedList<WmsTakeGoodStatsOutput>();
        var wmsTakeGoodStatsOutputList = new List<WmsTakeGoodStatsOutput>();
        foreach (var item in result)
        {
            var newWmsTakeGoodStatsOutput = new WmsTakeGoodStatsOutput();

            if (item.AsnStatus == OrderStatusEnum.新建)
            {
                newWmsTakeGoodStatsOutput.AsnNo = item.AsnNo;
                newWmsTakeGoodStatsOutput.MaterialCode = item.MaterialCode;
                newWmsTakeGoodStatsOutput.SupplierName = item.SupplierName;
                newWmsTakeGoodStatsOutput.ProjectNo = item.ProjectNo;
                // newWmsTakeGoodStatsOutput.ASNBeginTime = item.PlannedStartTime;
                //newWmsTakeGoodStatsOutput.ASNEndTime = item.PlannedEndTime;
                newWmsTakeGoodStatsOutput.ASNStatus = ReceiptStatusEnum.待收货;
                newWmsTakeGoodStatsOutput.ASNNumber = item.GoodsQuantity;
                newWmsTakeGoodStatsOutput.AllQty = item.Quantity;
                wmsTakeGoodStatsOutputList.Add(newWmsTakeGoodStatsOutput);
            }
            else if (item.AsnStatus == OrderStatusEnum.处理中)
            {
                newWmsTakeGoodStatsOutput.AsnNo = item.AsnNo;
                newWmsTakeGoodStatsOutput.MaterialCode = item.MaterialCode;
                newWmsTakeGoodStatsOutput.SupplierName = item.SupplierName;
                newWmsTakeGoodStatsOutput.ProjectNo = item.ProjectNo;
                newWmsTakeGoodStatsOutput.ASNBeginTime = item.PlannedStartTime;
                newWmsTakeGoodStatsOutput.ASNEndTime = item.PlannedEndTime;
                newWmsTakeGoodStatsOutput.ASNNumber = item.GoodsQuantity;
                newWmsTakeGoodStatsOutput.AllQty = item.Quantity;

                if (today < item.PlannedEndTime)
                {
                    newWmsTakeGoodStatsOutput.ASNStatus = ReceiptStatusEnum.收货中;
                    wmsTakeGoodStatsOutputList.Add(newWmsTakeGoodStatsOutput);
                }
                else if (today > item.PlannedEndTime)
                {
                    newWmsTakeGoodStatsOutput.ASNStatus = ReceiptStatusEnum.延迟未收货;
                    wmsTakeGoodStatsOutputList.Add(newWmsTakeGoodStatsOutput);
                }
            }
            else if (item.AsnStatus == OrderStatusEnum.已完成 || item.AsnStatus == OrderStatusEnum.已关闭)
            {
                if (item.AsnStatus == OrderStatusEnum.已完成)
                {
                    newWmsTakeGoodStatsOutput.AsnNo = item.AsnNo;
                    newWmsTakeGoodStatsOutput.MaterialCode = item.MaterialCode;
                    newWmsTakeGoodStatsOutput.SupplierName = item.SupplierName;
                    newWmsTakeGoodStatsOutput.ProjectNo = item.ProjectNo;
                    // 找到所有相同 ASN 单号的记录
                    var completedItems = result.Where(r => r.AsnNo == item.AsnNo).ToList();
                    newWmsTakeGoodStatsOutput.ASNNumber = item.GoodsQuantity;

                    // 找到最小和最大的 PlannedStartTime
                    var minStartTime = completedItems.Min(r => r.PlannedStartTime);
                    var maxEndTime = completedItems.Max(r => r.PlannedEndTime);

                    // 设置 ASNBeginTime 和 ASNEndTime
                    newWmsTakeGoodStatsOutput.ASNBeginTime = minStartTime;
                    newWmsTakeGoodStatsOutput.ASNEndTime = maxEndTime;
                    newWmsTakeGoodStatsOutput.ASNStatus = ReceiptStatusEnum.收货完成;
                    newWmsTakeGoodStatsOutput.AllQty = item.Quantity;
                    wmsTakeGoodStatsOutputList.Add(newWmsTakeGoodStatsOutput);
                }
                else
                {
                    newWmsTakeGoodStatsOutput.AsnNo = item.AsnNo;
                    newWmsTakeGoodStatsOutput.MaterialCode = item.MaterialCode;
                    newWmsTakeGoodStatsOutput.SupplierName = item.SupplierName;
                    newWmsTakeGoodStatsOutput.ProjectNo = item.ProjectNo;
                    newWmsTakeGoodStatsOutput.ASNBeginTime = item.PlannedStartTime;
                    newWmsTakeGoodStatsOutput.ASNEndTime = item.PlannedEndTime;
                    newWmsTakeGoodStatsOutput.ASNStatus = ReceiptStatusEnum.已关闭;
                    newWmsTakeGoodStatsOutput.ASNNumber = item.GoodsQuantity;
                    newWmsTakeGoodStatsOutput.AllQty = item.Quantity;
                    wmsTakeGoodStatsOutputList.Add(newWmsTakeGoodStatsOutput);
                }

            }
            else if (item.AsnStatus == OrderStatusEnum.已取消)
            {
                newWmsTakeGoodStatsOutput.AsnNo = item.AsnNo;
                newWmsTakeGoodStatsOutput.MaterialCode = item.MaterialCode;
                newWmsTakeGoodStatsOutput.SupplierName = item.SupplierName;
                newWmsTakeGoodStatsOutput.ProjectNo = item.ProjectNo;
                newWmsTakeGoodStatsOutput.ASNBeginTime = item.PlannedStartTime;
                newWmsTakeGoodStatsOutput.ASNEndTime = item.PlannedEndTime;
                newWmsTakeGoodStatsOutput.ASNStatus = ReceiptStatusEnum.已取消;
                newWmsTakeGoodStatsOutput.ASNNumber = item.GoodsQuantity;
                newWmsTakeGoodStatsOutput.AllQty = item.Quantity;
                wmsTakeGoodStatsOutputList.Add(newWmsTakeGoodStatsOutput);
            }
        }
        // 使用 LINQ 对 wmsTakeGoodStatsOutputList 进行分组
        var groupedResults = wmsTakeGoodStatsOutputList
            .GroupBy(x => new { x.AsnNo, x.MaterialCode, x.SupplierName })
            .Select(group => new WmsTakeGoodStatsOutput()
            {
                SupplierName = group.Key.SupplierName,
                AsnNo = group.Key.AsnNo,
                MaterialCode = group.Key.MaterialCode,
                //ASNStatus = group.Max(x => x.ASNStatus),
                ProjectNo = group.Min(x => x.ProjectNo),
                PlanBeginTime = group.Min(x => x.PlanBeginTime),
                AllQty = group.Sum(x => x.AllQty),
                ASNNumber = group.Sum(x => x.ASNNumber),
                //ASNBeginTime = group.Min(x => x.ASNBeginTime),
                //ASNEndTime = group.Max(x => x.ASNEndTime),
                IsCancel = group.Count(x => x.ASNStatus == ReceiptStatusEnum.已取消) == group.Count() ? true : false,
                IsClose = group.Count(x => x.ASNStatus == ReceiptStatusEnum.已关闭) == group.Count() ? true : false,
            }); ;

        input.Page = 1;
        input.PageSize = 10000;
        var ls = groupedResults.ToPagedList(input.Page, input.PageSize);
        foreach (var item in ls.Items)
        {
            //计算 开始收获时间+结束收获时间
            var myrecords = records.Where(x => x.OrderNo == item.AsnNo && x.MaterialCode == item.MaterialCode && x.SupplierName == item.SupplierName).OrderBy(x => x.Id).ToList();
            if (myrecords.Count > 0)
            {
                item.ASNBeginTime = myrecords.Select(x => x.CreateTime).Min();
                //判断他的状态
                if (item.AllQty == item.ASNNumber)
                {
                    item.ASNStatus = ReceiptStatusEnum.收货完成;
                    item.ASNEndTime = myrecords.Select(x => x.CreateTime).Max();
                }
                else if (item.AllQty > item.ASNNumber)
                {
                    if (item.ASNNumber > 0)
                    {
                        item.ASNStatus = ReceiptStatusEnum.收货中;
                    }
                    else
                    {
                        item.ASNBeginTime = null;
                        item.ASNStatus = ReceiptStatusEnum.待收货;
                        //判断是不是延迟未收货
                        if (item.PlanBeginTime < DateTime.Now)
                        {
                            item.ASNStatus = ReceiptStatusEnum.延迟未收货;
                        }
                    }
                }
            }
            else
            {
                item.ASNBeginTime = null;
                item.ASNStatus = ReceiptStatusEnum.待收货;
                //判断是不是延迟未收货
                if (item.PlanBeginTime < DateTime.Now)
                {
                    item.ASNStatus = ReceiptStatusEnum.延迟未收货;
                }
            }

            //判断是否取消或关闭
            if (item.IsCancel)
            {
                item.ASNStatus = ReceiptStatusEnum.已取消;
            }
            if (item.IsClose)
            {
                item.ASNStatus = ReceiptStatusEnum.已关闭;
            }

        }


        return ls;
    }


}