using Masuit.Tools;
using MES.Service.DB;
using MES.Service.Dto.service;
using MES.Service.Modes;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace MES.Service.service.Warehouse
{
    public class MesItemQtrkManager : Repository<MesItemQtrk>
    {
        public bool MiscellaneousReceipts(MesItemQtRKDto mesItemQtRKDto)
        {
            var itemQtRKFrom = mesItemQtRKDto.from;
            var itemQtRKLists = mesItemQtRKDto.items;

            // 根据AsnNo和MesNo对明细进行分组
            //var groupedItems = itemOutLists
            //    .GroupBy(item => new { item.AsnNo, item.MesNo, item.SqNo })
            //    .ToList();

            bool result = true;
            //foreach (var group in itemQtRKLists)
            //{
                //if (group.Key.AsnNo == null)
                //{
                //    throw new NotImplementedException("AsnNo不能为空");
                //}

                //if (group.Key.MesNo == null)
                //{
                //    throw new NotImplementedException("入库单单号不能为空");
                //}

                //if (group.Key.SqNo == null)
                //{
                //    throw new NotImplementedException("退货申请单行号不能为空");
                //}

                // 创建一个临时的itemOutFrom对象，使用分组的Key作为主要属性
                //var tempItemOutFrom = new ItemOutFrom
                //{
                //    AsnNo = group.Key.AsnNo,
                //    MesNo = group.Key.MesNo,
                //    SqNo = group.Key.SqNo,
                //    // 继承原始itemOutFrom的其他属性
                //    RtnNo = itemOutFrom.RtnNo,
                //    Type = itemOutFrom.Type,
                //    CreateBy = itemOutFrom.CreateBy,
                //    FMRMODE = itemOutFrom.FMRMODE,
                //    DepotId = itemOutFrom.DepotId,
                //    SupperId = itemOutFrom.SupperId
                //};

                // 根据Type执行不同的逻辑
                switch (itemQtRKFrom.Type)
                {
                    case "1":
                        {
                            var mesInvItemOuts = Db.Queryable<MesItemQtrk>()
                                .Where(s => s.Qtck == itemQtRKFrom.ApplyNumber

                                )
                                .Count();

                            if (mesInvItemOuts > 0)
                            {
                                throw new NotImplementedException(
                                    itemQtRKFrom.ApplyNumber +
                                    "的杂收申请单已经存在");
                            }

                            // 为当前分组保存数据
                            var groupResult = Save(itemQtRKFrom, itemQtRKLists);
                            if (!groupResult)
                            {
                                result = false;
                            }

                            break;
                        }
                    case "4":
                        var removeResult = Remove(itemQtRKFrom);
                        if (!removeResult)
                        {
                            result = false;
                        }

                        break;
                    default:
                        result = false;
                        break;
                }
            //}

            return result;
        }


        private bool Save(MesItemQtRKFrom from, List<MesItemQtRKList> items)
        {
            //var mesInvItemIns = Db.Queryable<MesInvItemIns>()
            //    .Where(s => s.BillTypeId == 100
            //                && s.TransctionNo == "101"
            //                && s.BillNo == from.MesNo
            //    ).First();

            //if (mesInvItemIns == null)
            //{
            //    throw new NotImplementedException("采购入库不存在");
            //}

           
            string SuppNo = "";
            if (from.SupplierCode!="" && from.SupplierCode!=null)
            {
                var mesLinkU9 = Db.Queryable<MesLinkU9>()
              .Where(s => s.TableType == "MES_SUPPLIER"
                          && s.U9Id == from.SupplierCode).First();

                if (mesLinkU9 == null)
                {
                    throw new NotImplementedException("供应商ID不存在或未同步于U9");
                }

                var mesSupplier = Db.Queryable<MesSupplier>()
                    .Where(s => s.Id == Decimal.Parse(mesLinkU9.MesId))
                    .First();
                if (mesSupplier == null)
                {
                    throw new NotImplementedException("[" + from.SupplierCode +
                                                      "]供应商不存在，请同步给MES");
                }
                SuppNo= mesSupplier.SuppNo;
            }
            var mesDepots = Db.Queryable<MesDepots>()
                .Where(s => s.DepotId == Decimal.Parse(from.FromWarehouse)).First();

            if (mesDepots == null)
            {
                throw new NotImplementedException("[" + from.FromWarehouse +
                                                  "]仓库不存在，请同步给MES");
            }

            var sysDepartment = Db.Queryable<SysDepartment>()
              .Where(s => s.Departmentid == Decimal.Parse(from.ApplyDept)).First();

            if (sysDepartment == null)
            {
                throw new NotImplementedException("[" + from.ApplyDept +
                                                  "]部门不存在，请同步给MES");
            }


            var nextSequenceValue =
                Db.Ado.SqlQuery<decimal>("SELECT SEQ_QTRK.NEXTVAL FROM DUAL")
                    .First();

            // var billCode =
            //     Db.Ado.SqlQuery<string>(
            //             "SELECT GETBILLCODE1('1000', '1000', 'TLSQ') FROM DUAL")
            //         .First();
            //var billCode = from.RtnNo;

            // 创建杂收申请单记录
            var MesItemQtrk = new MesItemQtrk
            {
                Id = nextSequenceValue,
                Qtck= from.ApplyNumber,
                Qt001= from.Equals(null) ? DateTime.Now : from.ApplyDate,
                Qt002= from.Equals(null) ? DateTime.Now : from.AuditDate,
                Qt003= from.DocumentType,
                Qt004= from.StockInType,
                Qt005= from.CreatedBy,
                Qt006= from.WorkOrder,
                Qt009= sysDepartment.Departmentname,
                Qt012 = sysDepartment.Departmentcode,
                Qt010 = from.Reason,
                Qt011= mesDepots.DepotCode,
                Qt008 = mesDepots.DepotName,
                 
                Qt015= 1,
                Qt016= from.Auditor,
                Qt017= from.TaskNumber,
                Qt018= SuppNo,
                Qt019= from.Direction,
                Qt020= from.OwnerType,
                CustomerCode= from.CustomerCode,
                Receiver= from.Receiver,
                Department = from.Department,
                StockKeeper=from.StockKeeper,
                SourceType = from.SourceType,
                SourceDocument = from.SourceDocument,
                ProductionRelated = from.ProductionRelated,
                ProductionLine = from.ProductionLine,
                ProductionActivity = from.ProductionActivity,
                FinishedGoods = from.FinishedGoods,
                ReversePosting = from.ReversePosting,
                AccountingPeriod= from.AccountingPeriod,
                Employee= from.Employee,
                FalseReturn = from.FalseReturn,
                ProjectCode = from.ProjectCode,
                TaskCode = from.TaskCode,
                Status=from.Status,
                OwnerOrganization= from.OwnerOrganization


            };

            // 创建杂收申请单行记录
            var mesItemQtrrDetail = new List<MesItemQtrrDetail>();

            foreach (var ItemQtRKList in items)
            {
                // 检查必要字段是否为空
                //if (string.IsNullOrEmpty(itemOutList.SrcDocNo))
                //{
                //    throw new NotImplementedException("采购订单号不能为空");
                //}

               

                //var mesRohInData = Db.Queryable<MesRohInData>()
                //    .Where(s => s.BillNo == itemOutList.SrcDocNo
                //                && s.OrderLineId == itemOutList.SrcDocLineNo)
                //    .First();

                //if (mesRohInData == null)
                //{
                //    throw new NotImplementedException("采购订单不存在");
                //}

                //var deliveryDetail = Db.Queryable<DeliveryDetail>()
                //    .Where(a => a.Zzasn == from.AsnNo
                //                && Int32.Parse(a.ZzitemId) ==
                //                Int32.Parse(itemOutList.AsnLineNo))
                //    .Count();

                //if (deliveryDetail <= 0)
                //{
                //    throw new NotImplementedException("[" + from.AsnNo + "]的明细行[" +
                //                                      itemOutList.AsnLineNo +
                //                                      "]不存在");
                //}

                var itemIdLinkU9 = Db.Queryable<MesLinkU9>()
                    .Where(s => s.TableType == "MES_ITEMS"
                                && s.U9Id == ItemQtRKList.ItemId).First();

                if (itemIdLinkU9 == null)
                {
                    throw new NotImplementedException("物料ID不存在或未同步于U9");
                }

                var mesItems = Db.Queryable<MesItems>()
                    .Where(s => s.Id == Decimal.Parse(itemIdLinkU9.MesId))
                    .First();

                if (mesItems == null)
                {
                    throw new NotImplementedException("[" + ItemQtRKList.ItemId +
                                                      "]物料不存在，请同步给MES");
                }
                var mesDepot = "";
                if (ItemQtRKList.StorageLocation != null && ItemQtRKList.StorageLocation!=null)
                {
                     mesDepots = Db.Queryable<MesDepots>()
                    .Where(s => s.DepotId == Decimal.Parse(ItemQtRKList.StorageLocation)).First();
                    if (mesDepots == null)
                    {
                        throw new NotImplementedException("[" + ItemQtRKList.StorageLocation +
                                                          "]仓库不存在，请同步给MES");
                    }
                    mesDepot = mesDepots.DepotCode;
                }
                string supplierCode = "";
                if (ItemQtRKList.SupplierCode!=null && ItemQtRKList.SupplierCode != "")
                {
                    var mesLinkU9 = Db.Queryable<MesLinkU9>()
   .Where(s => s.TableType == "MES_SUPPLIER"
               && s.U9Id == ItemQtRKList.SupplierCode).First();

                    var mesSupplier = Db.Queryable<MesSupplier>()
        .Where(s => s.Id == Decimal.Parse(mesLinkU9.MesId))
        .First();
                    if (mesSupplier == null)
                    {
                        throw new NotImplementedException("[" + ItemQtRKList.SupplierCode +
                                                          "]供应商不存在，请同步给MES");
                    }
                    supplierCode = mesSupplier.SuppNo;
                }
               

                //var mesInvItemInCItems = Db.Queryable<MesInvItemInCItems>()
                //    .Where(s => s.ItemInId == mesInvItemIns.Id
                //                && s.ItemNo == mesItems.ItemNo
                //                && s.Ebeln == itemOutList.SrcDocNo
                //                && s.EbelnLineNo ==
                //                Decimal.Parse(itemOutList.SrcDocLineNo)
                //                && s.SuppNo == mesSupplier.SuppNo
                //                && Convert.ToInt32(s.ZzitemId) ==
                //                Convert.ToInt32(itemOutList.AsnLineNo)).First();

                //if (mesInvItemInCItems == null)
                //{
                //    throw new NotImplementedException("没有对应的入库明细");
                //}


                // 确保CbillNo不为空
                if (ItemQtRKList.AppliedQuantity<=0 || ItemQtRKList.AppliedQuantity==null)
                {
                    throw new NotImplementedException("申请数量不能为0或NULL值！");
                }

                mesItemQtrrDetail.Add(new MesItemQtrrDetail
                {
                    Mid = nextSequenceValue,
                    Qd002= mesItems.ItemNo,
                    Qd003= mesItems.ItemName,
                    Qd004= mesItems.ItemModel,
                    Qd005= mesItems.ColorName,
                    Qd006= ItemQtRKList.PlannedQuantity,
                    Qd007= ItemQtRKList.AppliedQuantity,
                    Qd008=0, // 已入数量默认为0
                    Qd009= mesItems.ItemUnit,
                    Qd010= ItemQtRKList.Remark,
                    Qd012= mesItems.Id, // 物料内码
                    LineNumber= ItemQtRKList.LineNumber,
                    ProductionRelated= ItemQtRKList.ProductionRelated,
                    StorageType= ItemQtRKList.StorageType,
                    OwnerOrganization = ItemQtRKList.OwnerOrganization,
                    StorageLocation= mesDepot,
                    SupplierCode= supplierCode,
                    CustomerCode = ItemQtRKList.CustomerCode,
                    ProjectCode = ItemQtRKList.ProjectCode,
                    TaskCode = ItemQtRKList.TaskCode,
                    ProductionOrder = ItemQtRKList.ProductionOrder,
                    DailyPlan = ItemQtRKList.DailyPlan,
                    ProductionActivity = ItemQtRKList.ProductionActivity,
                    FinishedProduct = ItemQtRKList.FinishedProduct
                        
                });
            }

            var outItemCommand = Db.Insertable(mesItemQtrrDetail)
                .PageSize(1).IgnoreColumnsNull().ExecuteCommand();
            if (outItemCommand <= 0)
            {
                throw new Exception("创建杂收单子表失败");
            }

            // 插入采购退料单记录
            var insertResult = Db.Insertable(MesItemQtrk).IgnoreColumns(true)
                .ExecuteCommand();
            if (insertResult <= 0)
            {
                throw new Exception("创建杂收单失败");
            }

            return outItemCommand + insertResult >= 2;
        }

        private bool Remove(MesItemQtRKFrom from)
        {
            // 查找要删除的杂收单
            var mesItemQtrk = Db.Queryable<MesItemQtrk>()
                .Where(s => s.Qtck == from.ApplyNumber
                           ).ToList();

            if (mesItemQtrk == null || mesItemQtrk.Count == 0)
            {
                throw new NotImplementedException("找不到对应的杂收单: " + from.ApplyNumber);
            }

            // 检查是否有已审核的单据，如果存在已审核(Status=1)则不允许删除
            //if (mesInvItemOuts.Any(item => item.Status == 1))
            //{
            //    throw new NotImplementedException("存在已审核的采购退料单，不允许删除");
            //}

            // 删除所有相关单据
            foreach (var itemRK in mesItemQtrk)
            {
                // 查找要删除的杂收单明细
                var mesInvItemOutItems = Db.Queryable<MesItemQtrrDetail>()
                    .Where(s => s.Mid == itemRK.Id)
                    .ToList();

                if (mesInvItemOutItems == null || mesInvItemOutItems.Count == 0)
                {
                    throw new NotImplementedException(
                        $"找不到杂收单[{from.ApplyNumber}]对应的明细");
                }

                // 删除杂收单明细
                var deleteItemsResult = Db.Deleteable<MesItemQtrrDetail>()
                    .Where(s => s.Mid == itemRK.Id)
                    .ExecuteCommand();

                if (deleteItemsResult <= 0)
                {
                    throw new Exception($"找不到杂收单[ {from.ApplyNumber}]明细，删除失败");
                }

                // 删除杂收单
                var deleteResult = Db.Deleteable<MesItemQtrk>()
                    .Where(s => s.Id == itemRK.Id)
                    .ExecuteCommand();

                if (deleteResult <= 0)
                {
                    throw new Exception($"删除杂收单[{from.ApplyNumber}]失败");
                }
            }

            return true;
        }
    }
}