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

namespace MES.Service.service.BasicData;

public class MesRohInManager : Repository<MesRohIn>
{
    private readonly MesRohInDataManager rohInDataManager = new();

    // Save 方法用于保存单个 RohIn 记录，根据类型执行不同的操作
    public bool Save(RohIn rohIn)
    {
        var rohInErpRohIn = rohIn.ErpRohIn;
        var mesRohIn = GetMesRohIn(rohInErpRohIn);
        var mesRohInDatas =
            GetMesRohInDatas(rohIn.ErpRohinDatas, rohInErpRohIn.Type);

        return UseTransaction(db =>
        {
            switch (rohInErpRohIn.Type)
            {
                // case "2":
                //     return InsertData(db, mesRohIn, mesRohInDatas,
                //         rohInErpRohIn.FBILLTYPE)
                //         ? 1
                //         : 0;
                case "3":
                    return UpdateData(db, mesRohIn, mesRohInDatas) ? 1 : 0;
                case "2":
                case "4":
                    return SaveOrUpdateData(db, mesRohIn, mesRohInDatas)
                        ? 1
                        : 0;
                default:
                    throw new NotImplementedException(
                        $"type没有{rohInErpRohIn.Type}这个类型");
            }
        }) > 0;
    }

    // 插入数据的方法
    private bool InsertData(SqlSugarScope db, MesRohIn mesRohIn,
        List<MesRohInData> mesRohInDatas, string FBILLTYPE)
    {
        switch (FBILLTYPE)
        {
            case "A":
            {
                var decimals = mesRohInDatas.Select(s => s.Id).ToArray();

                if (mesRohIn.Id != null) base.DeleteById(mesRohIn.Id);

                if (decimals.Length > 0)
                    db.Deleteable<MesRohInData>().In(decimals).ExecuteCommand();

                var insert = base.Insert(mesRohIn);
                var insertRange =
                    rohInDataManager.InsertRange(mesRohInDatas);

                if (insert && insertRange) return true;
                throw new NotImplementedException("插入失败");
            }
            case "B":
            {
                var decimals = mesRohInDatas.Select(s => s.Id).ToArray();
                if (base.DeleteById(mesRohIn.Id) && db
                        .Deleteable<MesRohInData>().In(decimals)
                        .ExecuteCommand() > 0)
                {
                    var insert = base.Insert(mesRohIn);
                    var insertRange =
                        rohInDataManager.InsertRange(mesRohInDatas);

                    if (insert && insertRange) return true;
                    throw new NotImplementedException("插入失败");
                }

                break;
            }
        }

        throw new NotImplementedException("采购订单类型错误");
    }

    // 更新数据的方法
    private bool UpdateData(SqlSugarScope db, MesRohIn mesRohIn,
        List<MesRohInData> mesRohInDatas)
    {

        //根据单别和单号进行删除
        var update = db.Deleteable<MesRohIn>()    
        .Where(it => it.BillNo == mesRohIn.BillNo &&
                     it.DocumentType == mesRohIn.DocumentType)
        .ExecuteCommand() > 0;


        var mesRohInData = mesRohInDatas.Select(s => new { billno = s.BillNo, billnotype = s.Billnotype, seqno = s.OrderLineId }).ToList();



       
        var insertOrUpdate = db.Deleteable<MesRohInData>().Where(it => mesRohInData.Any(p => p.billno == it.BillNo && p.billnotype == it.Billnotype && p.seqno == it.OrderLineId)).ExecuteCommand() > 0;

        if (update && insertOrUpdate) return true;
        throw new NotImplementedException("更新失败");

    }

    // 插入或更新数据的方法
    private bool SaveOrUpdateData(SqlSugarScope db, MesRohIn mesRohIn,
        List<MesRohInData> mesRohInDatas)
    {
        if (mesRohIn.BillNo != null && mesRohIn.DocumentType != null)
        {

         db.Deleteable<MesRohIn>()
        .Where(it => it.BillNo == mesRohIn.BillNo &&
                     it.DocumentType == mesRohIn.DocumentType)
        .ExecuteCommand();

        };
    

        if (mesRohInDatas.Count > 0)
        {

            var mesRohInData = mesRohInDatas.Select(s => new { billno = s.BillNo, billnotype = s.Billnotype, seqno = s.OrderLineId }).ToList();

            db.Deleteable<MesRohInData>()
              .Where(it => mesRohInData.Any(p => p.billno == it.BillNo 
              && p.billnotype == it.Billnotype 
              && p.seqno == it.OrderLineId))
              .ExecuteCommand();

        };
           

        var orUpdate = base.Insert(mesRohIn);
        var baOrUpdate = rohInDataManager.InsertRange(mesRohInDatas);
        if (orUpdate && baOrUpdate) return true;
        throw new NotImplementedException("插入或更新失败");
    }

    // 批量保存记录的方法
    public bool SaveList(List<RohIn> rohIns)
    {
        var result = rohIns.Select(Save).ToList();
        return result.All(b => b);
    }

    // 将 ErpRohIn 对象转换为 MesRohIn 对象的方法
    public MesRohIn GetMesRohIn(ErpRohIn rohIn)
    {
        //var eid = Convert.ToDecimal(rohIn.id);
        var mesRohIn = new MesRohIn();

        mesRohIn.BillNo = rohIn.FBillNo;
        mesRohIn.DocumentStatus = rohIn.FDocumentStatus;
        mesRohIn.DocumentType = rohIn.FBillTypeID;
        mesRohIn.BusinessType = rohIn.FBusinessType;

        if (rohIn.FDate != null)
            mesRohIn.PurchaseDate = DateTime.ParseExact(rohIn.FDate,
                "yyyy-MM-dd HH:mm:ss", null);

        mesRohIn.Supplier = rohIn.FSupplierId;
        mesRohIn.CloseStatus = rohIn.FCloseStatus;
        mesRohIn.Purchaser = rohIn.FPurchaserId;
        mesRohIn.CancellationStatus = rohIn.FCancelStatus;
        mesRohIn.CancellationPerson = rohIn.FCancellerId;

        if (rohIn.FCancelDate != null)
            mesRohIn.CancellationDate =
                DateTime.ParseExact(rohIn.FCancelDate,
                    "yyyy-MM-dd HH:mm:ss", null);

        mesRohIn.CreateBy = rohIn.FCreatorId;

        if (rohIn.FCreateDate != null)
            mesRohIn.CreateDate = DateTime.ParseExact(rohIn.FCreateDate,
                "yyyy-MM-dd HH:mm:ss", null);


        mesRohIn.ErpCheckBy = rohIn.FApproverId;
        mesRohIn.ErpCheckDate = rohIn.FApproveDate;
        mesRohIn.Changereason = rohIn.FCHANGEREASON;

        return mesRohIn;
    }

    // 将 ErpRohinData 对象转换为 MesRohInData 对象的方法
    public List<MesRohInData> GetMesRohInDatas(
        List<ErpRohinData> erpRohinDatas, string type)
    {
        return erpRohinDatas.Select(s =>
        {




            var entity = new MesRohInData
            {

                Billnotype = s.FBillTypeID,  //采购单别
                BillNo = s.FBillNo,
                OrderLineId = s.FDEMANDBILLENTRYSEQ,
                SalesOrderId = s.F_UNW_Text_xsddh,
                ItemId = s.FMaterialId,
                PurchaseUnit = s.FUnitId,
                PurchaseQty = Convert.ToDecimal(s.FQty),
                InventoryUnit = s.FStockUnitID,
                DeliveryDate = DateTime.ParseExact(s.FDeliveryDate,"yyyy-MM-dd HH:mm:ss", null),
                BusinessClose = s.FMRPCloseStatus,
                TerminateTime = !string.IsNullOrEmpty(s.FTerminateDate) ? DateTime.ParseExact(s.FTerminateDate, "yyyy-MM-dd HH:mm:ss", null) : (DateTime?)null,
                SourceDocumentType = s.FSrcBillTypeId,
                Remarks = s.FEntryNote,
                SupplierItemCode = s.FSupMatId,
                SupplierItemName = s.FSupMatName,   
                TotalReceivedQty = Convert.ToDecimal(s.FReceiveQty),
                RemainingReceivedQty =
                    Convert.ToDecimal(s.FRemainReceiveQty),
                TotalStoredQty = Convert.ToDecimal(s.FStockInQty),
                RemainingStoredQty = Convert.ToDecimal(s.FRemainStockINQty),
                TotalReturnedQty = Convert.ToDecimal(s.FMrbQty),
                ReturnableReceivedQty = Convert.ToDecimal(s.FCHECKRETQTY),
                SourceDocumentId = s.FSrcBillNo,
                DemandTrackingId = s.FReqTraceNo,
                DepotCode = s.FDepotCode,
                DepotName = s.FDepotName
            };

          

            return entity;
        }).ToList();
    }




    public bool Delete(YFDelete data)
    {


        return UseTransaction(db =>
        {
            var update = db.Deleteable<MesRohIn>()
                   .Where(it => it.BillNo == data.FBillNo &&
                                it.DocumentType == data.FBillTypeID)
                   .ExecuteCommand() > 0;

            var insertOrUpdate = db.Deleteable<MesRohInData>()
                  .Where(it => it.BillNo == data.FBillNo &&
                               it.Billnotype == data.FBillTypeID)
                  .ExecuteCommand() > 0;



            if (update && insertOrUpdate) return 1;
            throw new NotImplementedException("删除失败");
        }) > 0;


    }


}