using Admin.NET.Core.Service;
using Admin.NET.Application.Entity;
using Microsoft.AspNetCore.Http;
using StackExchange.Redis;
using Admin.NET.Application;
using MimeKit;
using static SKIT.FlurlHttpClient.Wechat.Api.Models.ProductOrderGetResponse.Types.Order.Types;
using System.Linq.Dynamic.Core;
using Admin.NET.Core;
using AngleSharp.Dom;
using Admin.NET.Core.Helper.ExcelHelper;
using System.Web;
using System.Data;
using System.Text;
using Newtonsoft.Json;

namespace Admin.NET.Application;
/// <summary>
/// 采购订单服务
/// </summary>
[ApiDescriptionSettings(ApplicationConst.WmsOrderGroupName, Order = 100)]
public class WmsOrderPurchaseService : IDynamicApiController, ITransient
{
    private readonly SqlSugarRepository<WmsOrderPurchase> _rep;
    private readonly SqlSugarRepository<WmsOrderPurchaseDetails> _purchaseOrderDetailsRep;
    private readonly SqlSugarRepository<WmsBaseCustomer> _BaseCustomerRep;
    private readonly SqlSugarRepository<WmsBaseMaterial> _wmsMaterialRep;
    private readonly SqlSugarRepository<v_ware_PurchaseOrderDetailsForPDA> _v_ware_PurchaseOrderDetailsForPDARep;
    private readonly SqlSugarRepository<WmsBaseBusinessType> _WmsBaseBusinessTypeRep;
    private readonly SqlSugarRepository<WmsConfigNoRule> _WmsNoCreateRuleRep;
    private readonly SqlSugarRepository<WmsConfigSerialSN> _repSNRep;
    private readonly SqlSugarRepository<WmsAdapterManagement> _repAdapterManagement;
    private readonly SqlSugarRepository<WmsAdapterCategories> _repAdapterCategories;
    private readonly SqlSugarRepository<WmsAdapterRecord> _repRecordAdapter;
    private readonly SqlSugarRepository<WmsOrderAsnDetails> _wmsOrderAsnDetailsRep;

    public WmsOrderPurchaseService(
        SqlSugarRepository<WmsOrderPurchase> rep
        , SqlSugarRepository<WmsOrderPurchaseDetails> purchaseOrderDetailsRep
        , SqlSugarRepository<WmsBaseCustomer> BaseCustomerRep
        , SqlSugarRepository<WmsBaseMaterial> wmsMaterialRep
        , SqlSugarRepository<v_ware_PurchaseOrderDetailsForPDA> v_ware_PurchaseOrderDetailsForPDARep,
        SqlSugarRepository<WmsBaseBusinessType> WmsBaseBusinessTypeRep
,
        SqlSugarRepository<WmsConfigNoRule> wmsNoCreateRuleRep,
        SqlSugarRepository<WmsAdapterRecord> repRecordAdapter,
        SqlSugarRepository<WmsAdapterManagement> repAdapterManagement,
        SqlSugarRepository<WmsAdapterCategories> repAdapterCategories,
        SqlSugarRepository<WmsOrderAsnDetails> wmsOrderAsnDetailsRep
        )
    {
        _rep = rep;
        _purchaseOrderDetailsRep = purchaseOrderDetailsRep;
        _BaseCustomerRep = BaseCustomerRep;
        _wmsMaterialRep = wmsMaterialRep;
        _v_ware_PurchaseOrderDetailsForPDARep = v_ware_PurchaseOrderDetailsForPDARep;
        _WmsBaseBusinessTypeRep = WmsBaseBusinessTypeRep;
        _WmsNoCreateRuleRep = wmsNoCreateRuleRep;
        _repAdapterManagement = repAdapterManagement;
        _repAdapterCategories = repAdapterCategories;
        _repRecordAdapter = repRecordAdapter;
        _wmsOrderAsnDetailsRep = wmsOrderAsnDetailsRep;
    }

    /// <summary>
    /// 分页查询采购订单
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Page")]
    [Description("WmsOrderPurchase/Page")]
    public async Task<SqlSugarPagedList<WmsOrderPurchaseOutput>> Page(WmsOrderPurchaseInput input)
    {
        List<WmsOrderPurchaseOutput> list1 = new List<WmsOrderPurchaseOutput>();

        var query = CommonPageFilter(input);

        //var query2 = CommonPageFilter(input).Select<WmsOrderPurchaseOutput>().ToList();
        //foreach (var item in query2)
        //{
        //    item.CreateASNQuantity = 1;
        //}
        //return await query2.Where(v => v.IsDelete == false).OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);

        return await query.OrderBy(x => x.PoStatus).OrderByDescending(x => x.CreateTime)
            //.OrderBuilder(input)
            .ToPagedListAsync(input.Page, input.PageSize);
    }

    /// <summary>
    /// 不分页查询采购订单
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "List")]
    [Description("WmsOrderPurchase/List")]
    public async Task<List<WmsOrderPurchaseOutput>> List([FromQuery] WmsOrderPurchaseInput input)
    {
        var query = CommonPageFilter(input);
        return await query.OrderBuilder(input).Select<WmsOrderPurchaseOutput>().ToListAsync();
    }

    /// <summary>
    /// 增加采购订单
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Add")]
    [Description("WmsOrderPurchase/Add")]
    public async Task<long> Add(DiyAddWmsOrderPurchaseInput input)
    {
        if (input.purchaseOrderDetails is null || input.purchaseOrderDetails.Count == 0)
        {
            throw Oops.Oh("明细不能为空");
        }
        var hearId = await AddOrderEFsql(input);
        return hearId;
    }

    private async Task<long> AddOrderEFsql(DiyAddWmsOrderPurchaseInput input)
    {

        var hearId = Yitter.IdGenerator.YitIdHelper.NextId();
        //新增表头
        var warehousOrder = input.Adapt<WmsOrderPurchase>();
        warehousOrder.Id = hearId;
        warehousOrder.OrderType = OrderTypeEnum.PO单;
        warehousOrder.OrderTypeName = OrderTypeEnum.PO单.GetDescription();
        warehousOrder.BusinessType = input.BusinessType;
        var entity = await _WmsBaseBusinessTypeRep.GetFirstAsync(u => u.BusinessTypeValue == input.BusinessType);
        if (entity == null)
        {
            throw Oops.Oh("业务类型名称获取失败");
        }
        warehousOrder.BusinessTypeName = entity.BusinessTypeName;
        // 获取当前时间
        DateTime currentTime = DateTime.Now;

        // 格式化为年月日字符串
        string formattedDate = currentTime.ToString("yyyyMMdd");

        //按照单号规则生成单号 - 查找最新的创建的一条单据记录
        var newestOrder = await _rep.AsQueryable().Where(p => p.OrderType == OrderTypeEnum.PO单).Where(p => p.PurchaseNo.Contains(formattedDate)).OrderBy(it => it.CreateTime, OrderByType.Desc)
                             .FirstAsync();

        //按照单号规则生成单号
        warehousOrder.PurchaseNo = await SerialUtilOrder.GetSerialOrder(OrderTypeEnum.PO单, _WmsNoCreateRuleRep, _repSNRep, warehousOrder.BusinessType, newestOrder == null ? null : newestOrder.PurchaseNo);
        if (warehousOrder.PurchaseNo == null || warehousOrder.PurchaseNo == "")
        {
            warehousOrder.PurchaseNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString();
        }

        warehousOrder.OrderTypeName = ((int)input.OrderType).ToString();

        warehousOrder.OrderSocure = GetEnumDescriptionUtil.GetEnumDescription(SourceByEnum.自建);
        warehousOrder.PoStatus = OrderStatusEnum.新建;
        warehousOrder.PoStatusName = GetEnumDescriptionUtil.GetEnumDescription(warehousOrder.PoStatus);
        warehousOrder.Quantity = (decimal)input.purchaseOrderDetails.Sum(x => x.Quantity);
        warehousOrder.GoodsQuantity = (decimal)input.purchaseOrderDetails.Sum(x => x.GoodsQuantity);
        var Info_BaseCustomer = await _BaseCustomerRep.GetFirstAsync(u => u.CustCode == input.SupplierCode);
        if (Info_BaseCustomer != null)
        {
            warehousOrder.SupplierName = Info_BaseCustomer.CustChinaName;
        }
        else
        {
            throw Oops.Oh($"请选择供应商编号！");
        }
        warehousOrder.Dock = input.Dock;
        warehousOrder.ErpOrderNo = input.ErpOrderNo;
        warehousOrder.ProjectNo = input.ProjectNo;
        warehousOrder.FactoryId = 1; //??
        //新增明细
        var warehousOrderDetails1 = input.purchaseOrderDetails.Adapt<List<WmsOrderPurchaseDetails>>();
        // PurchaseOrderHelper.CalcPurchaseOrderDeliveryQuantity(warehousOrder, warehousOrderDetails1);
        foreach (var w in warehousOrderDetails1)
        {
            if (w.Quantity == 0)
            {
                throw Oops.Oh("创建失败：数量需要大于0");
            }
            var materials = await _wmsMaterialRep.GetFirstAsync(u => u.MaterialCode == w.MaterialCode && u.IsDisabled == false);
            if (materials == null)
            {
                throw Oops.Oh("物料：" + w.MaterialCode + "不可用");
            }
            if (String.IsNullOrEmpty(w.ErpCode))
            {
                throw Oops.Oh("物料：" + w.MaterialCode + "ERP库存地必填");
            }
            w.Id = Yitter.IdGenerator.YitIdHelper.NextId();
            w.PoId = hearId;
            w.PoNo = warehousOrder.PurchaseNo;
            w.PoLineNumber = w.PoLineNumber;
            w.MaterialCode = w.MaterialCode;
            w.MaterialName = w.MaterialName;
            w.Quantity = w.Quantity;
            w.PoDetailStatus = OrderStatusEnum.新建;
            w.PoDetailStatusName = GetEnumDescriptionUtil.GetEnumDescription(OrderStatusEnum.新建);
            w.PlannedStartTime = w.PlannedStartTime;
            w.PlannedEndTime = w.PlannedEndTime;
            w.SupplierCode = warehousOrder.SupplierCode.ToString();
            w.SupplierName = warehousOrder.SupplierName.ToString();
            w.SupplierBatch = w.SupplierBatch;
            w.ErpCode = w.ErpCode;
            w.Unit = w.Unit;
            w.ProjectNo = input.ProjectNo;
            w.Dock = input.Dock;
            w.ErpOrderNo = warehousOrder.ErpOrderNo;
        }

        try
        {
            await _rep.AsTenant().BeginTranAsync();

            //插入主表
            await _rep.InsertAsync(warehousOrder);
            //插入明细表
            await _purchaseOrderDetailsRep.InsertRangeAsync(warehousOrderDetails1);

            await _rep.AsTenant().CommitTranAsync();
        }
        catch
        {
            await _rep.AsTenant().RollbackTranAsync();
            throw;
        }

        return hearId;
    }


    /// <summary>
    /// 增加适配器记录CC
    /// </summary>
    /// <param name="wcsInput"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "CCAddAdapterLogs")]
    [Description("WmsOrderPurchase/CCAddAdapterLogs")]
    [AllowAnonymous]
    public async Task CCAddAdapterLogs(WCSWriteAdapterLogsInput wcsInput)
    {


        var getAdapterModel = await _repAdapterManagement.AsQueryable().FirstAsync(p => p.AdapterMethodName.Contains("PO单接收"));
        string OrderADapter = JsonConvert.SerializeObject(wcsInput.OPOrderAdapterAdd);
        string Message = JsonConvert.SerializeObject(wcsInput.AdapterReturnMassageObject);
        //插入一条记录，初始化记录的时候一定要先将记录变成未处理
        if (getAdapterModel == null) throw Oops.Oh("当前接口地址不正确，未找到相应适配器");
        var newRecordAdapter = new WmsAdapterRecord()
        {
            AdapterCategoryId = getAdapterModel.AdapterCategoryId,
            AdapterName = getAdapterModel.AdapterName,
            CategoryName = getAdapterModel.CategoryName,
            AdapterId = getAdapterModel.Id,
            AdapterMethodName = getAdapterModel.AdapterMethodName,
            RequestSoure = "CC",
            AdapterSID = wcsInput.SID,
            BeginTime = DateTime.Now,
            DealWithStatus = AdapterLogDealWithEnum.未处理,
            ErrMessage = wcsInput.AdapterReturnMassageObject.Message,
            // ErrMessage = wcsInput.ErrMessage == null ? "" : wcsInput.ErrMessage,
            AdapterInput = OrderADapter,
            AdapterReturnMassage = Message,
            OrderNo = wcsInput.AdapterReturnMassageObject.Result.ToString()
        };
        await _repRecordAdapter.InsertAsync(newRecordAdapter);
    }

    /// <summary>
    /// 增加采购订单CC
    /// </summary>
    /// <param name="AddPoOrderData"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "CCAddPoOrder")]
    [Description("WmsOrderPurchase/CCAddPoOrder")]
    [AllowAnonymous]
    public async Task<string> CCAddPoOrder([FromBody] string AddPoOrderData)
    {
        var input = JsonConvert.DeserializeObject<DiyAddWmsOrderPurchaseInput>(AddPoOrderData);

        if (input.purchaseOrderDetails is null || input.purchaseOrderDetails.Count == 0)
        {
            throw Oops.Oh("明细不能为空");
        }
        var PoOrderNo = await CCAddOrderEFsql(input);
        return PoOrderNo;
    }
    /// <summary>
    /// 增加收货适配器记录
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "ReceivingAdapterLogs")]
    [Description("WmsOrderPurchase/ReceivingAdapterLogs")]
    [AllowAnonymous]
    public async Task ReceivingAdapterLogs(ReceivingAdapterLogsInput input)
    {
        var getAdapterModel = await _repAdapterManagement.AsQueryable().FirstAsync(p => p.AdapterMethodName.Contains("PO单收货"));
        string OrderADapter = JsonConvert.SerializeObject(input);
        //string Message = JsonConvert.SerializeObject(input.AdapterReturnMassageObject);
        var PoOrderNoList = new List<string>();
        foreach (var item in input.OPOrderReceivingAdapterAdd)
        {
            var POOrderNo = await _wmsOrderAsnDetailsRep.AsQueryable().FirstAsync(p => p.Id == item.OrderAsnDetailsId);
            PoOrderNoList.Add(POOrderNo.PoNo ?? "0");
        }
        var OrderNO = "";
        int index = 1;
        foreach (var item in PoOrderNoList)
        {
            if (index < PoOrderNoList.Count()) { OrderNO += item + ","; } else { OrderNO += item; }
            index++;
        }
        //插入一条记录，初始化记录的时候一定要先将记录变成未处理
        if (getAdapterModel == null) throw Oops.Oh("当前接口地址不正确，未找到相应适配器");
        var newRecordAdapter = new WmsAdapterRecord()
        {
            AdapterCategoryId = getAdapterModel.AdapterCategoryId,
            AdapterName = getAdapterModel.AdapterName,
            CategoryName = getAdapterModel.CategoryName,
            AdapterId = getAdapterModel.Id,
            AdapterMethodName = getAdapterModel.AdapterMethodName,
            RequestSoure = "PDA收货",
            // AdapterSID = input.SID,
            BeginTime = DateTime.Now,
            DealWithStatus = AdapterLogDealWithEnum.未处理,
            ErrMessage = "",
            // ErrMessage = wcsInput.ErrMessage == null ? "" : wcsInput.ErrMessage,
            AdapterInput = OrderADapter,
            AdapterReturnMassage = "",
            OrderNo = OrderNO,
            PushCount = 1,
            AdapterSID = "0",
            KeyCode = input.KeyCode.ToString()

        };
        await _repRecordAdapter.InsertAsync(newRecordAdapter);
    }


    private async Task<string> CCAddOrderEFsql(DiyAddWmsOrderPurchaseInput input)
    {

        var hearId = Yitter.IdGenerator.YitIdHelper.NextId();
        //新增表头
        var warehousOrder = input.Adapt<WmsOrderPurchase>();
        warehousOrder.Id = hearId;
        warehousOrder.OrderType = OrderTypeEnum.PO单;
        warehousOrder.OrderTypeName = OrderTypeEnum.PO单.GetDescription();
        warehousOrder.BusinessType = input.BusinessType;
        var entity = await _WmsBaseBusinessTypeRep.GetFirstAsync(u => u.BusinessTypeValue == input.BusinessType);
        if (entity == null)
        {
            throw Oops.Oh("业务类型名称获取失败");
        }
        warehousOrder.BusinessTypeName = entity.BusinessTypeName;
        // 获取当前时间
        DateTime currentTime = DateTime.Now;

        // 格式化为年月日字符串
        string formattedDate = currentTime.ToString("yyyyMMdd");

        //按照单号规则生成单号 - 查找最新的创建的一条单据记录
        var newestOrder = await _rep.AsQueryable().Where(p => p.OrderType == OrderTypeEnum.PO单).Where(p => p.PurchaseNo.Contains(formattedDate)).OrderBy(it => it.CreateTime, OrderByType.Desc)
                             .FirstAsync();

        //按照单号规则生成单号
        warehousOrder.PurchaseNo = await SerialUtilOrder.GetSerialOrder(OrderTypeEnum.PO单, _WmsNoCreateRuleRep, _repSNRep, warehousOrder.BusinessType, newestOrder == null ? null : newestOrder.PurchaseNo);
        if (warehousOrder.PurchaseNo == null || warehousOrder.PurchaseNo == "")
        {
            warehousOrder.PurchaseNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString();
        }

        warehousOrder.OrderTypeName = ((int)input.OrderType).ToString();

        warehousOrder.OrderSocure = GetEnumDescriptionUtil.GetEnumDescription(SourceByEnum.自建);
        warehousOrder.PoStatus = OrderStatusEnum.新建;
        warehousOrder.PoStatusName = GetEnumDescriptionUtil.GetEnumDescription(warehousOrder.PoStatus);
        warehousOrder.Quantity = (decimal)input.purchaseOrderDetails.Sum(x => x.Quantity);
        warehousOrder.GoodsQuantity = (decimal)input.purchaseOrderDetails.Sum(x => x.GoodsQuantity);
        var Info_BaseCustomer = await _BaseCustomerRep.GetFirstAsync(u => u.CustCode == input.SupplierCode);
        if (Info_BaseCustomer != null)
        {
            warehousOrder.SupplierName = Info_BaseCustomer.CustChinaName;
        }
        else
        {
            throw Oops.Oh($"请选择供应商编号！");
        }
        warehousOrder.Dock = input.Dock;
        warehousOrder.ErpOrderNo = input.ErpOrderNo;
        warehousOrder.ProjectNo = input.ProjectNo;
        warehousOrder.FactoryId = 1; //??
        //新增明细
        var warehousOrderDetails1 = input.purchaseOrderDetails.Adapt<List<WmsOrderPurchaseDetails>>();
        // PurchaseOrderHelper.CalcPurchaseOrderDeliveryQuantity(warehousOrder, warehousOrderDetails1);
        foreach (var w in warehousOrderDetails1)
        {
            if (w.Quantity == 0)
            {
                throw Oops.Oh("创建失败：数量需要大于0");
            }
            var materials = await _wmsMaterialRep.GetFirstAsync(u => u.MaterialCode == w.MaterialCode && u.IsDisabled == false);
            if (materials == null)
            {
                throw Oops.Oh("物料：" + w.MaterialCode + "不可用");
            }
            w.Id = Yitter.IdGenerator.YitIdHelper.NextId();
            w.PoId = hearId;
            w.PoNo = warehousOrder.PurchaseNo;
            w.PoLineNumber = w.PoLineNumber;
            w.MaterialCode = w.MaterialCode;
            w.MaterialName = w.MaterialName;
            w.Quantity = w.Quantity;
            w.PoDetailStatus = OrderStatusEnum.新建;
            w.PoDetailStatusName = GetEnumDescriptionUtil.GetEnumDescription(OrderStatusEnum.新建);
            w.PlannedStartTime = w.PlannedStartTime;
            w.PlannedEndTime = w.PlannedEndTime;
            w.SupplierCode = warehousOrder.SupplierCode.ToString();
            w.SupplierName = warehousOrder.SupplierName.ToString();
            w.SupplierBatch = w.SupplierBatch;
            w.ErpCode = w.ErpCode;
            w.Unit = w.Unit;
            w.ProjectNo = input.ProjectNo;
            w.Dock = input.Dock;
            w.ErpOrderNo = warehousOrder.ErpOrderNo;
        }

        try
        {
            await _rep.AsTenant().BeginTranAsync();

            //插入主表
            await _rep.InsertAsync(warehousOrder);
            //插入明细表
            await _purchaseOrderDetailsRep.InsertRangeAsync(warehousOrderDetails1);

            await _rep.AsTenant().CommitTranAsync();
        }
        catch
        {
            await _rep.AsTenant().RollbackTranAsync();
            throw;
        }

        return warehousOrder.PurchaseNo;
    }





    /// <summary>
    /// ly-取消采购订单
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Delete")]
    [Description("WmsOrderPurchase/Delete")]
    public async Task Delete(DeleteWmsOrderPurchaseInput input)
    {

        var entity = await _rep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
        entity.PoStatus = OrderStatusEnum.已取消;
        entity.PoStatusName = GetEnumDescriptionUtil.GetEnumDescription(OrderStatusEnum.已取消);
        var purchaseOrderDetails = await _purchaseOrderDetailsRep.AsQueryable()
                               .Where(x => x.PoId == entity.Id)
                               .Where(u => u.IsDelete == false)
                               .Select<WmsOrderPurchaseDetails>()
                               .ToListAsync();
        //删明细
        List<WmsOrderPurchaseDetails> deleteWarePurchaseOrderDetails = new List<WmsOrderPurchaseDetails>();
        var deleteList = purchaseOrderDetails.Where(x => x.IsDelete == false).ToList();
        foreach (var item in deleteList)
        {
            if (item.PoDetailStatus != OrderStatusEnum.新建)
            {
                throw Oops.Oh($"物料{item.MaterialCode}的状态{item.PoDetailStatus}，不允许取消");
            }
            if (item.GoodsQuantity > 0)
            {
                throw Oops.Oh($"物料{item.MaterialCode}的已收数量{item.GoodsQuantity}大于0，不允许取消");
            }
            item.PoDetailStatus = OrderStatusEnum.已取消;
            item.PoDetailStatusName = GetEnumDescriptionUtil.GetEnumDescription(OrderStatusEnum.已取消);
            deleteWarePurchaseOrderDetails.Add(item);
        }
        try
        {
            await _rep.AsTenant().BeginTranAsync();
            await _rep.UpdateAsync(entity);   //更新状态
            await _purchaseOrderDetailsRep.UpdateRangeAsync(deleteWarePurchaseOrderDetails); //更新状态
            await _rep.AsTenant().CommitTranAsync();
        }
        catch
        {
            await _rep.AsTenant().RollbackTranAsync();
            throw;
        }
    }

    /// <summary>
    /// 更新采购订单
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Update")]
    [Description("WmsOrderPurchase/Update")]
    public async Task Update(DiyAddWmsOrderPurchaseInput input)
    {
        if (input.purchaseOrderDetails is null || input.purchaseOrderDetails.Count == 0)
        {
            throw Oops.Oh("明细不能为空");
        }
        //  CheckWarePurchaseOrderDetails(input.purchaseOrderDetails);
        var dbOrder = await _rep.GetFirstAsync(w => w.PurchaseNo == input.PurchaseNo);
        if (dbOrder == null)
        {
            throw Oops.Oh($"订单{input.PurchaseNo}不存在");
        }
        dbOrder.SupplierCode = input.SupplierCode;
        dbOrder.SupplierName = input.SupplierName;
        dbOrder.Dock = input.Dock;
        dbOrder.ErpOrderNo = input.ErpOrderNo;
        dbOrder.Remark = input.Remark;
        dbOrder.ProjectNo = input.ProjectNo;
        dbOrder.FactoryId = 1; //???
        var purchaseOrderDetails = await _purchaseOrderDetailsRep.AsQueryable()
                                  .Where(x => x.PoId == dbOrder.Id)
                                  .Where(u => u.IsDelete == false)
                                  .Select<WmsOrderPurchaseDetails>()
                                  .ToListAsync();
        //验证数量是否正确
        foreach (var item in input.purchaseOrderDetails)
        {
            if (item.Quantity < item.GoodsQuantity)
            {
                throw Oops.Oh($"物料{item.MaterialCode}的采购数量{item.Quantity}不能小于已收数量{item.GoodsQuantity}");
            }
        }

        List<WmsOrderPurchaseDetails> addWarePurchaseOrderDetails = new List<WmsOrderPurchaseDetails>();
        List<WmsOrderPurchaseDetails> updateWarePurchaseOrderDetails = new List<WmsOrderPurchaseDetails>();
        List<WmsOrderPurchaseDetails> deleteWarePurchaseOrderDetails = new List<WmsOrderPurchaseDetails>();

        //寻找更新的
        var updateList = purchaseOrderDetails.Where(x => input.purchaseOrderDetails.Any(p => p.PoLineNumber == x.PoLineNumber && p.MaterialCode == x.MaterialCode)).ToList();
        foreach (var item in updateList)
        {
            var orderDetails = input.purchaseOrderDetails.FirstOrDefault(x => x.MaterialCode == item.MaterialCode && x.Id == item.Id);
            if (orderDetails == null)
            {
                continue;
            }
            else
            {

                if (String.IsNullOrEmpty(orderDetails.ErpCode))
                {
                    throw Oops.Oh("物料：" + item.MaterialCode + "ERP库存地必填");
                }

                item.Quantity = (decimal)orderDetails.Quantity;
                item.PoLineNumber = orderDetails.PoLineNumber;
                item.PlannedStartTime = orderDetails.PlannedStartTime;
                item.PlannedEndTime = orderDetails.PlannedEndTime;
                item.SupplierCode = input.SupplierCode;
                item.SupplierName = input.SupplierName;
                item.SupplierBatch = orderDetails.SupplierBatch;
                item.ErpCode = orderDetails.ErpCode;
                item.Unit = orderDetails.Unit;//update by liuwq 20240613
                item.ProjectNo = input.ProjectNo;
                item.Dock = input.Dock;
                item.ErpOrderNo = dbOrder.ErpOrderNo;
            }

            //item.DeliveryQuantity = input.purchaseOrderDetails.Where(x => x.WarematerialCode == item.WarematerialCode && x.Id == item.Id).First().DeliveryQuantity;
            if (item.Quantity < item.GoodsQuantity)
            {
                throw Oops.Oh($"物料{item.MaterialCode}的采购数量{item.Quantity}不能小于已收数量{item.GoodsQuantity}");
            }

            //变更明细的状态
            //   PurchaseOrderHelper.SetSignstatusForPurchaseOrder(item, dbOrder.PurchaseNo, _purchaseOrderRep, _purchaseOrderDetailsRep);
            updateWarePurchaseOrderDetails.Add(item);
        }

        //寻找删除的
        var deleteList = purchaseOrderDetails.Where(x => !input.purchaseOrderDetails.Any(p => p.PoLineNumber == x.PoLineNumber && p.MaterialCode == x.MaterialCode)).ToList();
        foreach (var item in deleteList)
        {
            if (item.GoodsQuantity > 0)
            {
                throw Oops.Oh($"物料{item.MaterialCode}的已收数量{item.GoodsQuantity}大于0，不允许删除");
            }
            deleteWarePurchaseOrderDetails.Add(item);
        }

        //寻找新增的
        var addList = input.purchaseOrderDetails.Where(x => !purchaseOrderDetails.Any(p => p.PoLineNumber == x.PoLineNumber && p.MaterialCode == x.MaterialCode)).ToList();
        foreach (var w in addList)
        {
            //TODO 要改成 在循环外查询数据库 update by  liuwq 20240613
            var materials = await _wmsMaterialRep.GetFirstAsync(u => u.MaterialCode == w.MaterialCode && u.IsDisabled == false);
            if (materials == null)
            {
                throw Oops.Oh("物料：" + w.MaterialCode + "不可用");
            }
            if (String.IsNullOrEmpty(w.ErpCode))
            {
                throw Oops.Oh("物料：" + w.MaterialCode + "ERP库存地必填");
            }
            WmsOrderPurchaseDetails warePurchaseOrderDetails = new WmsOrderPurchaseDetails()
            {
                Id = Yitter.IdGenerator.YitIdHelper.NextId(),
                PoId = dbOrder.Id,
                PoNo = dbOrder.PurchaseNo,
                PoLineNumber = w.PoLineNumber,
                MaterialCode = w.MaterialCode,
                MaterialName = w.MaterialName,
                Quantity = (decimal)w.Quantity,
                PoDetailStatus = OrderStatusEnum.新建,
                PoDetailStatusName = OrderStatusEnum.新建.GetDescription(),
                PlannedStartTime = w.PlannedStartTime,
                PlannedEndTime = w.PlannedEndTime,
                SupplierCode = input.SupplierCode,
                SupplierName = input.SupplierName,
                SupplierBatch = w.SupplierBatch,
                Unit = w.Unit,//update by liuwq 20240613
                ErpCode = w.ErpCode,
                ErpOrderNo = dbOrder.ErpOrderNo
            };
            addWarePurchaseOrderDetails.Add(warePurchaseOrderDetails);

        }

        try
        {
            await _rep.AsTenant().BeginTranAsync();

            if (addWarePurchaseOrderDetails.Count > 0)
            {
                await _purchaseOrderDetailsRep.InsertRangeAsync(addWarePurchaseOrderDetails);
            }
            if (updateWarePurchaseOrderDetails.Count > 0)
            {
                await _purchaseOrderDetailsRep.UpdateRangeAsync(updateWarePurchaseOrderDetails);
            }
            if (deleteWarePurchaseOrderDetails.Count > 0)
            {
                await _purchaseOrderDetailsRep.DeleteAsync(deleteWarePurchaseOrderDetails);
            }

            CalcPurchaseOrderDeliveryQuantity(dbOrder, input.purchaseOrderDetails);//计算并赋值 主订单的需求数
            await _rep.UpdateAsync(dbOrder);

            await _rep.AsTenant().CommitTranAsync();
        }
        catch
        {
            await _rep.AsTenant().RollbackTranAsync();
            throw;
        }




    }
    public static void CalcPurchaseOrderDeliveryQuantity(WmsOrderPurchase order, List<WmsOrderPurchaseDetailsInput> details)
    {
        order.Quantity = (decimal)details.Sum(x => x.Quantity);
    }

    /// <summary>
    /// 设置采购订单的状态
    /// </summary>
    /// <param name="purchaseOrderDetail"></param>
    /// <param name="purchaseOrderNo"></param>
    public static void SetSignstatusForPurchaseOrder(WmsOrderPurchaseDetails purchaseOrderDetail, string purchaseOrderNo,
       SqlSugarRepository<WmsOrderPurchase> _rep, SqlSugarRepository<WmsOrderPurchaseDetails> _purchaseOrderDetailsRep
        )
    {
        if (purchaseOrderDetail.GoodsQuantity == 0)
        {
            //   purchaseOrderDetail.PoDetailStatus = OrderStatusEnum.待收货;
        }
        else if (purchaseOrderDetail.GoodsQuantity < 0)
        {
            throw Oops.Oh($"采购单号{purchaseOrderNo},行号{purchaseOrderDetail.PoLineNumber},物料号{purchaseOrderDetail.MaterialCode}收货数量{purchaseOrderDetail.GoodsQuantity}不能小于0");
        }
        else
        {
            if (purchaseOrderDetail.GoodsQuantity == purchaseOrderDetail.Quantity)
            {
                // purchaseOrderDetail.SignStatus = EnumSignStatus.收货完成;
            }
            else if (purchaseOrderDetail.GoodsQuantity < purchaseOrderDetail.Quantity)
            {
                // purchaseOrderDetail.SignStatus = EnumSignStatus.收货中;
            }
            else
            {
                throw Oops.Oh($"采购单号{purchaseOrderNo},行号{purchaseOrderDetail.PoLineNumber},物料号{purchaseOrderDetail.MaterialCode}" +
                    $"收货数量{purchaseOrderDetail.GoodsQuantity}不能大于总数量{purchaseOrderDetail.Quantity}");
            }
        }

        //更新主表的状态 数量更新后，更新 状态
        var do_order = _rep.GetFirstAsync(x => x.PurchaseNo == purchaseOrderNo && x.IsDelete == false);
        var do_orderDetails = _purchaseOrderDetailsRep.AsQueryable().Where(x => x.PoId == do_order.Id && x.IsDelete == false).ToListAsync();


        //   var do_orderDetails = orderDetails.Where(x => x.PurchaseOrderId == order.Id && x.IsDeleted == false).ToList();

        //计算总量
        //var all_qty = do_orderDetails.Sum(x => x.DeliveryQuantity);
        // order.SignStatus = OrderCommonHelper.UpdateSignStatus(all_qty, do_orderDetails.Sum(x => x.GoodsQuantity));
        //  do_order.GoodsQuantity = do_orderDetails.Sum(x => x.GoodsQuantity);

        // UpdatePurchaseOrderStatus(do_order, do_orderDetails);


    }



    /// <summary>
    /// 获取采购订单
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "Detail")]
    [Description("WmsOrderPurchase/Detail")]
    public async Task<WmsOrderPurchase> Detail([FromQuery] QueryByIdWmsOrderPurchaseInput input)
    {
        return await _rep.GetFirstAsync(u => u.Id == input.Id);
    }

    /// <summary>
    /// po单主表明细导出
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "POOrderExcelOutting")]
    [Description("WmsOrderPurchase/POOrderExcelOutting")]
    [AllowAnonymous]
    public async Task<IActionResult> POOrderExcelOutting([FromQuery] WmsOrderPurchaseInput input)
    {


        var vs = (from p in _purchaseOrderDetailsRep.AsQueryable().ToList()
                  join m in _rep.AsQueryable()
                  .WhereIF(!string.IsNullOrWhiteSpace(input.PurchaseNo), u => u.PurchaseNo.Contains(input.PurchaseNo.Trim()))
            .WhereIF(input.OrderType.HasValue, u => u.OrderType == input.OrderType)
            .WhereIF(!string.IsNullOrWhiteSpace(input.OrderTypeName), u => u.OrderTypeName.Contains(input.OrderTypeName.Trim()))
            .WhereIF(input.BusinessType.HasValue, u => u.BusinessType == input.BusinessType)
            .WhereIF(!string.IsNullOrWhiteSpace(input.BusinessTypeName), u => u.BusinessTypeName.Contains(input.BusinessTypeName.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.OrderSocure), u => u.OrderSocure.Contains(input.OrderSocure.Trim()))
            .WhereIF(input.PoStatus.HasValue, u => u.PoStatus == input.PoStatus)
            .WhereIF(!string.IsNullOrWhiteSpace(input.PoStatusName), u => u.PoStatusName.Contains(input.PoStatusName.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.SupplierCode), u => u.SupplierCode.Contains(input.SupplierCode.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.SupplierName), u => u.SupplierName.Contains(input.SupplierName.Trim()))
            // .WhereIF(!string.IsNullOrWhiteSpace(input.Dock), u => u.Dock.Contains(input.Dock.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.ErpOrderNo), u => u.ErpOrderNo.Contains(input.ErpOrderNo.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.ProjectNo), u => u.ProjectNo.Contains(input.ProjectNo.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Remark), u => u.Remark.Contains(input.Remark.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Erp_CreatedUserName), u => u.Erp_CreatedUserName.Contains(input.Erp_CreatedUserName.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Erp_UpdatedUserName), u => u.Erp_UpdatedUserName.Contains(input.Erp_UpdatedUserName.Trim())).ToList() on p.PoId equals m.Id
                  select new WmsOrderPurchaseExcelOutput
                  {
                      //Id = m.Id,
                      PurchaseNo = m.PurchaseNo,
                      //OrderTypeName = m.OrderTypeName,
                      BusinessTypeName = m.BusinessTypeName,
                      OrderSocure = m.OrderSocure,
                      PoStatusName = m.PoStatusName,
                      SupplierCode = m.SupplierCode,
                      SupplierName = m.SupplierName,
                      ErpOrderNo = m.ErpOrderNo,
                      ProjectNo = m.ProjectNo,
                      CreateTime = m.CreateTime,
                      UpdateTime = m.UpdateTime,
                      CreateUserName = m.CreateUserName,
                      UpdateUserName = m.UpdateUserName,
                      MaterialName = p.MaterialName,
                      MaterialCode = p.MaterialCode,
                      PoLineNumber = p.PoLineNumber,
                      Unit = p.Unit,
                      Quantity = p.Quantity,
                      GoodsQuantity = p.GoodsQuantity,
                      PoDetailStatusName = p.PoDetailStatusName,
                      SupplierBatch = p.SupplierBatch,
                      ErpCode = p.ErpCode,
                      PlannedEndTime = p.PlannedEndTime,
                      PlannedStartTime = p.PlannedStartTime,
                      //Batch = p.Batch,
                      //Dock = p.Dock
                  }).ToList();
        var fileName = "PO单详情";
        var excelBaseResult = new Excel2003Result<WmsOrderPurchaseExcelOutput>(vs, fileName, false, "PO单导出详情");
        return new FileStreamResult(excelBaseResult.GetExcelStream(), "application/vnd.ms-excel");
    }


    #region 私有方法

    /// <summary>
    /// 公共查询采购订单条件
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    private ISugarQueryable<WmsOrderPurchaseOutput> CommonPageFilter(WmsOrderPurchaseInput input)
    {
        List<WmsOrderPurchaseOutput> list1 = new List<WmsOrderPurchaseOutput>();
        var query = _rep.AsQueryable()
            .WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u =>
                u.PurchaseNo.Contains(input.SearchKey.Trim())
                || u.SupplierCode.Contains(input.SearchKey.Trim())
                || u.SupplierName.Contains(input.SearchKey.Trim())
                || u.ErpOrderNo.Contains(input.SearchKey.Trim())
                || u.ProjectNo.Contains(input.SearchKey.Trim())
            )
            .WhereIF(!string.IsNullOrWhiteSpace(input.PurchaseNo), u => u.PurchaseNo.Contains(input.PurchaseNo.Trim()))
            .WhereIF(input.OrderType.HasValue, u => u.OrderType == input.OrderType)
            .WhereIF(!string.IsNullOrWhiteSpace(input.OrderTypeName), u => u.OrderTypeName.Contains(input.OrderTypeName.Trim()))
            .WhereIF(input.BusinessType.HasValue, u => u.BusinessType == input.BusinessType)
            .WhereIF(!string.IsNullOrWhiteSpace(input.BusinessTypeName), u => u.BusinessTypeName.Contains(input.BusinessTypeName.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.OrderSocure), u => u.OrderSocure.Contains(input.OrderSocure.Trim()))
            .WhereIF(input.PoStatus.HasValue, u => u.PoStatus == input.PoStatus)
            .WhereIF(!string.IsNullOrWhiteSpace(input.PoStatusName), u => u.PoStatusName.Contains(input.PoStatusName.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.SupplierCode), u => u.SupplierCode.Contains(input.SupplierCode.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.SupplierName), u => u.SupplierName.Contains(input.SupplierName.Trim()))
            // .WhereIF(!string.IsNullOrWhiteSpace(input.Dock), u => u.Dock.Contains(input.Dock.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.ErpOrderNo), u => u.ErpOrderNo.Contains(input.ErpOrderNo.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.ProjectNo), u => u.ProjectNo.Contains(input.ProjectNo.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Remark), u => u.Remark.Contains(input.Remark.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Erp_CreatedUserName), u => u.Erp_CreatedUserName.Contains(input.Erp_CreatedUserName.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Erp_UpdatedUserName), u => u.Erp_UpdatedUserName.Contains(input.Erp_UpdatedUserName.Trim()))
            .Select<WmsOrderPurchaseOutput>();

        return query;
    }

    /// <summary>
    /// 重复性验证
    /// </summary>
    /// <param name="input">验证对象</param>
    /// <param name="isEdit">是否是编辑</param>
    /// <returns></returns>
    private async Task CheckExist(WmsOrderPurchase input, bool isEdit = false)
    {



        //没有配置组合校验，不需要验重


        //没有配置单独校验，不需要验重
    }
    #endregion


    /// <summary>
    /// PDA收货
    /// 根据AsN单号和物料编码获取采购明细
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>

    [HttpGet]
    [ApiDescriptionSettings(Name = "QueryDetailsPda")]
    [Description("WmsOrderPurchase/QueryDetailsPda")]
    public async Task<SqlSugarPagedList<PurchaseOrderDetailsForPDAOutput>> QueryDetailsPda([FromQuery] QueryPurchaseOrderDetailsInput input)
    {

        var query = _v_ware_PurchaseOrderDetailsForPDARep.AsQueryable()
                     .WhereIF(!string.IsNullOrWhiteSpace(input.MaterialCode), u => u.MaterialCode == input.MaterialCode)
                     .WhereIF(!string.IsNullOrWhiteSpace(input.AsnNo), u => u.AsnNo == input.AsnNo)
                     .WhereIF(!string.IsNullOrWhiteSpace(input.SN_1d), u => u.SN_1d == input.SN_1d)
                     .WhereIF(!string.IsNullOrWhiteSpace(input.SN_2d), u => u.SN_2d == input.SN_2d)
                     .Where(u => u.IsFreeze != true || u.IsFreeze == null)
                     .Where(u => u.AsnStatus != OrderStatusEnum.已关闭) //ly-关闭的不可再收货
                     .Select<PurchaseOrderDetailsForPDAOutput>();

        return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);


    }






    #region 导入

    /// <summary>
    /// Excel模板导入PO单功能-ly 
    /// </summary>
    /// <param name="file">Excel模板文件</param>
    /// <returns>导入的记录数</returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "ImportExcel")]
    [Description("WmsOrderPurchase/ImportExcel")]
    public async Task<int> ImportExcelAsync(IFormFile file)
    {
        int _HeadStartLine = 2;//第1行是说明,第2行是列名
        int _DataStartLine = 3;//第3行开始是数据
        DataTable importDataTable = ExcelUtil.ImportExcelToDataTable(file, _HeadStartLine, _DataStartLine);
        var addListAll = await CommonImport(importDataTable, _DataStartLine);

        // 获取当前时间
        DateTime currentTime = DateTime.Now;

        // 格式化为年月日字符串
        string formattedDate = currentTime.ToString("yyyyMMdd");

        //按照单号规则生成单号 - 查找最新的创建的一条单据记录
        var newestOrder = await _rep.AsQueryable().Where(p => p.OrderType == OrderTypeEnum.PO单).Where(p => p.PurchaseNo.Contains(formattedDate)).OrderBy(it => it.CreateTime, OrderByType.Desc)
                             .FirstAsync();
        //按照单号规则生成单号-ly
        var PoNo = await SerialUtilOrder.GetSerialOrder(OrderTypeEnum.PO单, _WmsNoCreateRuleRep, _repSNRep, (int)BusinessTypeEnum.客户发运, newestOrder == null ? null : newestOrder.PurchaseNo);
        if (PoNo == null || PoNo == "")
        {
            PoNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString();
        }

        var DoId = Yitter.IdGenerator.YitIdHelper.NextId();
        //主表
        addListAll.OrderDeliver.PurchaseNo = Convert.ToString(PoNo);
        addListAll.OrderDeliver.Id = DoId;
        addListAll.OrderDeliver.OrderType = OrderTypeEnum.PO单;
        addListAll.OrderDeliver.OrderTypeName = GetEnumDescriptionUtil.GetEnumDescription(OrderTypeEnum.PO单);
        addListAll.OrderDeliver.BusinessType = (int)BusinessTypeEnum.采购收货;
        addListAll.OrderDeliver.BusinessTypeName = GetEnumDescriptionUtil.GetEnumDescription(BusinessTypeEnum.采购收货);
        addListAll.OrderDeliver.OrderSocure = "导入"; //(string)SourceByEnum.导入
        addListAll.OrderDeliver.PoStatus = OrderStatusEnum.新建;
        addListAll.OrderDeliver.PoStatusName = GetEnumDescriptionUtil.GetEnumDescription(OrderStatusEnum.新建);
        var Info_BaseCustomer = await _BaseCustomerRep.GetFirstAsync(u => u.CustCode == addListAll.OrderDeliver.SupplierCode);
        if (Info_BaseCustomer == null)
        {
            throw Oops.Oh("客户编号不存在！");
        }
        addListAll.OrderDeliver.SupplierName = Info_BaseCustomer.CustChinaName;

        //检验物料不存在
        List<string> queryCodeList = addListAll.OrderDeliverDetails.Select(v => v.MaterialCode).Distinct().ToList();
        var handleList = await _wmsMaterialRep.GetListAsync(u => queryCodeList.Contains(u.MaterialCode) && u.IsDelete == false);
        if (handleList == null || handleList.Count <= 0)
        {
            throw Oops.Oh($"物料不存在！");
        }
        //明细表
        foreach (var item in addListAll.OrderDeliverDetails)
        {
            var materials = handleList.Where(u => u.MaterialCode == item.MaterialCode).FirstOrDefault();
            if (materials == null)
            {
                throw Oops.Oh("物料：" + item.MaterialCode + "不存在");
            }
            item.PoNo = Convert.ToString(PoNo);
            item.PoId = DoId;
            item.PoDetailStatus = OrderStatusEnum.新建;
            item.PoDetailStatusName = GetEnumDescriptionUtil.GetEnumDescription(OrderStatusEnum.新建);
            item.MaterialName = materials.MaterialName;
            item.Quantity = 0;
            item.CreateASNQuantity = 0;
            //item.SNP = materials.SNP;
            item.SupplierCode = addListAll.OrderDeliver.SupplierCode;
            item.SupplierName = Info_BaseCustomer.CustChinaName;
        }
        try
        {
            await _rep.AsTenant().BeginTranAsync();
            await _rep.InsertAsync(addListAll.OrderDeliver); //插入主表
            await _purchaseOrderDetailsRep.InsertRangeAsync(addListAll.OrderDeliverDetails); //插入明细表
            await _rep.AsTenant().CommitTranAsync();
        }
        catch
        {
            await _rep.AsTenant().RollbackTranAsync();
            throw;
        }
        return 200;
    }

    /// <summary>
    ///  DataTable转换实体对象列表
    /// </summary>
    /// <param name="dataTable"></param>
    /// <param name="dataStartLine">模版列名开始行</param>
    /// <returns></returns>
    private async Task<WmsOrderPurchaseExportOutput> CommonImport(DataTable dataTable, int dataStartLine)
    {
        var detailsAll = new WmsOrderPurchaseExportOutput();

        var addItem = new WmsOrderPurchase();

        var detailsMaterial = new List<WmsOrderPurchaseDetails>();

        int index = dataStartLine;//模版列名开始行
        foreach (System.Data.DataRow row in dataTable.Rows)
        {
            index++;
            //导入模版定制化代码（替换模版使用）
            var addItemMaterial = new WmsOrderPurchaseDetails();
            #region 定义变量
            var _DeliverNo = "";//PO单号
            var _CustCode = "";//客户编号
            var MaterialCode = "";//物料编号
            var DoLineNumber = "";//行号
            var Quantity = "";//需求数
            var _ErpOrderNo = "";//ERP单号
            var _Remark = "";//备注
            #endregion
            #region 取值
            MaterialCode = row["物料编号"]?.ToString();
            DoLineNumber = row["行号"]?.ToString();
            Quantity = row["需求数"]?.ToString();
            _CustCode = row["供应商编号"]?.ToString();
            _ErpOrderNo = row["ERP单号"]?.ToString();
            _Remark = row["备注"]?.ToString();
            #endregion
            #region 验证

            //if (string.IsNullOrEmpty(_DeliverNo))
            //{
            //  throw Oops.Oh($"第{index}行[DO单号]{_DeliverNo}不能为空！");
            //}

            //if(!string.IsNullOrEmpty(_DeliverNo))
            //{
            //      addItem.DeliverNo = (string)(_DeliverNo.Trim());
            // }

            if (string.IsNullOrEmpty(MaterialCode))
            {
                throw Oops.Oh($"第{index}行[物料编号]{MaterialCode}不能为空！");
            }

            if (!string.IsNullOrEmpty(MaterialCode))
            {
                addItemMaterial.MaterialCode = (string)(MaterialCode.Trim());
            }


            if (string.IsNullOrEmpty(DoLineNumber))
            {
                throw Oops.Oh($"第{index}行[行号]{DoLineNumber}不能为空！");
            }

            if (!string.IsNullOrEmpty(DoLineNumber))
            {
                addItemMaterial.PoLineNumber = (string)(DoLineNumber.Trim());
            }


            if (string.IsNullOrEmpty(Quantity))
            {
                throw Oops.Oh($"第{index}行[需求数]{Quantity}不能为空！");
            }

            decimal qty = Convert.ToDecimal(Quantity.Trim());
            if (qty <= 0)
            {
                throw Oops.Oh($"第{index}行[需求数]{Quantity}不能小于0！");
            }
            addItemMaterial.Quantity = qty;

            //if (string.IsNullOrEmpty(_CustCode))
            //{
            //    throw Oops.Oh($"第{index}行[客户编号]{_CustCode}不能为空！");
            //}


            if (index == 4)
            {
                if (string.IsNullOrEmpty(_CustCode))
                {
                    throw Oops.Oh($"第{index}行[客户编号]{_CustCode}不能为空！");
                }

                if (!string.IsNullOrEmpty(_CustCode))
                {
                    addItem.SupplierCode = (string)(_CustCode.Trim());
                }

                if (!string.IsNullOrEmpty(_Remark))
                {
                    addItem.Remark = (string)(_Remark.Trim());
                }

                if (!string.IsNullOrEmpty(_ErpOrderNo))
                {
                    addItem.ErpOrderNo = (string)(_ErpOrderNo.Trim());
                }
            }


            #endregion


            detailsMaterial.Add(addItemMaterial);
        }

        //验重
        //await CheckExisitForImport(details);
        //  await CheckExisitForImport(detailsMaterial);

        detailsAll.OrderDeliver = addItem;
        detailsAll.OrderDeliverDetails = detailsMaterial;

        return detailsAll;
    }

    /// <summary>
    /// 根据版本下载PO单的Excel导入模板
    /// </summary>
    /// <returns>下载的模板文件</returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "DownloadExcelTemplate")]
    [Description("WmsOrderPurchase/DownloadExcelTemplate")]
    public IActionResult DownloadExcelTemplate()
    {
        string _path = TemplateConst.EXCEL_TEMPLATEFILE_导入模版路径 + $"\\PO单{TemplateConst.EXCEL_TEMPLATEFILE_导入模版名称后缀}.xlsx";
        var fileName = HttpUtility.UrlEncode($"导入模板(PO单).xlsx", Encoding.GetEncoding("UTF-8"));
        return new FileStreamResult(new FileStream(_path, FileMode.Open), "application/octet-stream") { FileDownloadName = fileName };
    }

    #endregion




}