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

namespace MES.Service.service.BasicData;

public class MesItemsManager : Repository<MesItems>
{
    public bool Save(ErpItems item)
    {
        var entity = GetMesItems(item);

        return UseTransaction(db =>
        {
            switch (item.Type)
            {
                case "3":
                    if (DeleteItem(db, entity))
                        return 1;
                    break;
                case "2":
                case "4":
                case "5":
                    if (InsertOrUpdate(db, entity))
                        return 1;
                    break;
                default:
                    throw new ArgumentNullException(
                        $"type没有{item.Type}这个类型的参数");
            }

            throw new NotImplementedException("操作失败");
        }) > 0;
    }

    public bool SaveList(List<ErpItems> items)
    {
        var result = items.Select(Save).ToList();
        return result.All(b => b);
    }

    private bool DeleteItem(SqlSugarScope db, List<MesItems> listItem)
    {
        // 提取所有需要的 MesId 组合 
        var ids = listItem.Select(customer => customer.Id.ToString())
            .ToList();

        // 使用这些 MesId 去查询 MesLinkU9 表，找到对应的 U9Id
        var u9Ids = Db.Queryable<MesLinkU9>()
            .Where(u =>
                ids.Contains(u.MesId) && u.TableType == "MES_ITEMS")
            .Select(u => u.U9Id)
            .Distinct() // 应用 Distinct 去重
            .ToList();

        // 根据 U9Id 找到所有对应的 MesId，进行删除
        // 注意：这里假设您确实想要删除这些记录。如果不确定，请先查询以验证结果。
        var idsToDelete = Db.Queryable<MesLinkU9>()
            .Where(u => u9Ids.Contains(u.U9Id) && u.TableType == "MES_ITEMS")
            .Select(u => u.MesId)
            .Distinct() // 应用 Distinct 去重
            .ToList();

        var deleteByIds = Db.Deleteable<MesItems>().In(idsToDelete)
            .ExecuteCommand();
        // if (deleteByIds > 0)
        //     return true;
        return true;
        //throw new NotImplementedException("删除失败");
    }

    private List<MesItems> GetMesItems(ErpItems item)
    {
        List<MesItems> list = new();

        foreach (var erpDetail in item.FUseOrgId)
        {
            var exists = Db.Queryable<MesLinkU9>().Any(u =>
                u.U9Id == item.Id && u.OrgId == erpDetail.FUseOrgId &&
                u.TableType == "MES_ITEMS");

            decimal mesId = 0;
            if (exists)
            {
                //获取mesid
                mesId = Convert.ToDecimal(Db.Queryable<MesLinkU9>()
                    .Where(u =>
                        u.U9Id == item.Id && u.OrgId == erpDetail.FUseOrgId &&
                        u.TableType == "MES_ITEMS")
                    .Select(u => u.MesId) // 选择 MesId 字段
                    .First());
            }
            else
            {
                mesId = GetSeqUtil.GetSeq("SEQ_ITEMS_ID");
                var entity = new MesLinkU9
                {
                    CreateDate = DateTime.Now,
                    MesId = mesId.ToString(),
                    U9Id = item.Id,
                    OrgId = erpDetail.FUseOrgId,
                    TableType = "MES_ITEMS"
                };
                Db.Insertable(entity).ExecuteCommand();
            }

            var items = new MesItems
            {
                Id = mesId,
                ItemId = mesId,

                Fmaterialgroup = item.FMaterialGroup,
                ItemNo = item.FNumber,
                OldItemNo = item.FOldNumber,
                ItemName = item.FName,
                CatalogNo = item.CatalogNo,
                ItemModel = item.FSpecification,
                SafeStock = item.FSafeStock,
                Lowlimit = item.FMinStock,
                Highlimit = item.FMaxStock,
                DepotCode = item.FStockId,
                Fisbatchmanage = item.FIsBatchManage,
                MaterialProperti = item.FErpClsID,
                Storeunit = item.FStoreUnitID,
                ItemUnit = item.FBaseUnitId,
                Fpurchaseunitid = item.FPurchaseUnitId,
                Saleunit = item.FSaleUnitId,
                ProduceUnit = item.FPRODUCEUNITID,
                MaterialOutUomid = item.MaterialOutUomid,
                CreateBy = item.CreateBy,
                PubDescSeg38 = item.PubDescSeg38,
                Description = item.Description,
                PrivateDescSeg4 = item.PrivateDescSeg4,
                PrivateDescSeg9 = item.PrivateDescSeg9,
                IsDualQuantity = item.IsDualQuantity,
                IsDualUom = item.IsDualUom,
                IsMultyUom = item.IsMultyUom,
                IsVarRatio = item.IsVarRatio,
                ConverRatioRule = item.ConverRatioRule,
                PrivateDescSeg11 = item.PrivateDescSeg11,
                PrivateDescSeg7 = item.PrivateDescSeg7,
                PrivateDescSeg2 = item.PrivateDescSeg2,
                DocumentStatus = item.FDocumentStatus,
                ForbidStatus = item.FForbidStatus,
                UseOrg = erpDetail.FUseOrgId,
                CreateDate = DateTime.Now,
                Company = "1000",
                Factory = "1000",
                WarehouseKeeper = item.WarehouseKeeper,
                Merchandiser = item.Merchandiser
            };
            list.Add(items);
        }

        return list;
    }

    private bool InsertOrUpdate(SqlSugarScope db, List<MesItems> listItem)
    {
        DeleteItem(db, listItem);

        var insert = db.Insertable(listItem).PageSize(1).IgnoreColumnsNull()
            .ExecuteCommand();
        return insert > 0;
    }
}