using System.Text;
using Aop.Api.Domain;
using JNPF.Common.Enums;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.FriendlyException;
using JNPF.Systems.Entitys.System;
using JNPF.Systems.Interfaces.System;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Components.Forms;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using NPOI.SS.Formula.Functions;
using SqlSugar;
using Tnb.BasicData.Entities;
using Tnb.ProductionMgr.Entities.Entity;
using Tnb.WarehouseMgr.Entities;
using Tnb.WarehouseMgr.Entities.Consts;
using Tnb.WarehouseMgr.Entities.Dto.ErpInputs;
using Tnb.WarehouseMgr.Entities.Dto.Outputs;
using Tnb.WarehouseMgr.Entities.Entity;
using Top.Api;

namespace Tnb.WarehouseMgr
{
    /// <summary>
    /// erp接口模块
    /// </summary>
    [ApiDescriptionSettings(Tag = ModuleConsts.Tag, Area = ModuleConsts.Area, Order = 800)]
    public class ErpToWmsService : IDynamicApiController, ITransient
    {
        private readonly ISqlSugarRepository<WmsPurchaseH> _repository;
        private readonly IBillRullService _billRuleService;
        public ErpToWmsService(ISqlSugarRepository<WmsPurchaseH> repository, IBillRullService billRuleService)
        {
            _repository = repository;
            _billRuleService = billRuleService;
        }
        /// <summary>
        /// 采购到货单
        /// </summary>
        public async Task PurchaseArrive(PurchaseArriveInput input)
        {
            //主表 create_time 采购收货单号 bill_code 单据类型 bill_type 单据状态 status 业务类型 biz_type 入库仓库ID warehouse_id 供应商ID supplier_id 供应商名称supplier_name 生成类型 generate_type
            //子表 主表id bill_id 执行状态line_status  单位id unit_id  物料id material_id
            var db = _repository.AsSugarClient();
            WmsPurchaseH wmsPurchaseH = new WmsPurchaseH();
            string Code = await _billRuleService.GetBillNumber("WmsPurchase");
            wmsPurchaseH.bill_code = Code;
            wmsPurchaseH.bill_type = "25103333373205";//收料通知单(到货单)
            wmsPurchaseH.biz_type = "26191496816421";//一般入库
            wmsPurchaseH.status = "25065138925589";//新增
            wmsPurchaseH.generate_type = "1";//0人工 1自动
            wmsPurchaseH.create_time = DateTime.Now;
            wmsPurchaseH.source_id = input.source_id;
            wmsPurchaseH.source_code = input.source_code;
            wmsPurchaseH.delivery_date = input.delivery_date;
            wmsPurchaseH.shipping_method = input.shipping_method;
            var warehouse = await db.Queryable<BasWarehouse>().Where(p => p.whcode == input.warehouse).FirstAsync();
            if (warehouse != null)
                wmsPurchaseH.warehouse_id = warehouse.id;
            wmsPurchaseH.supplier_code = input.supplier_code;
            var supplier = await db.Queryable<BasSupplier>().Where(p => p.supplier_code == input.supplier_code).FirstAsync();
            if (supplier != null)
            {
                wmsPurchaseH.supplier_id = supplier.id;
                wmsPurchaseH.supplier_name = supplier.supplier_name;
            }
            List<WmsPurchaseD> WmsPurchaseDs = new List<WmsPurchaseD>();
            foreach (var detail in input.details)
            {
                WmsPurchaseD wmsPurchased = new WmsPurchaseD();
                wmsPurchased.bill_id = wmsPurchaseH.id;
                wmsPurchased.line_status = "25065138925589";//新增
                wmsPurchased.purchase_qty = detail.purchase_qty;
                wmsPurchased.purchase_prqty = detail.purchase_prqty;
                wmsPurchased.code_batch = detail.code_batch;
                wmsPurchased.purchase_arriveqty = detail.purchase_arriveqty;
                wmsPurchased.container_no = detail.container_no;
                wmsPurchased.material_code = detail.material_code;
                var material = await db.Queryable<BasMaterial>().Where(p => p.code == detail.material_code).FirstAsync();
                if (material != null)
                {
                    wmsPurchased.material_id = material.id;
                    //    wmsPurchased.material_name = material.name;
                    wmsPurchased.unit_id = material.unit_id;
                }
                WmsPurchaseDs.Add(wmsPurchased);
            }
            await db.Insertable(wmsPurchaseH).ExecuteCommandAsync();
            await db.Insertable(WmsPurchaseDs).ExecuteCommandAsync();

        }
        /// <summary>
        /// 采购退货单
        /// </summary>
        public async Task PurchaseReturn(PurchaseReturnInput input)
        {
            //主表 create_time 采购收货单号 bill_code 单据类型 bill_type 单据状态 status 业务类型 biz_type 入库仓库ID warehouse_id 供应商ID supplier_id 供应商名称supplier_name 生成类型 generate_type
            //子表 主表id bill_id 执行状态line_status  单位id unit_id  物料id material_id
            var db = _repository.AsSugarClient();
            WmsPurchaseH wmsPurchaseH = new WmsPurchaseH();
            string Code = await _billRuleService.GetBillNumber("WmsPurchase");
            wmsPurchaseH.bill_code = Code;
            wmsPurchaseH.bill_type = "25103345478421";//采购退料单
            wmsPurchaseH.biz_type = "26191522660645";//一般出库
            wmsPurchaseH.status = "25065138925589";//新增
            wmsPurchaseH.generate_type = "1";//0人工 1自动
            wmsPurchaseH.create_time = DateTime.Now;
            wmsPurchaseH.source_id = input.source_id;
            wmsPurchaseH.source_code = input.source_code;
            wmsPurchaseH.delivery_date = input.delivery_date;
            wmsPurchaseH.shipping_method = input.shipping_method;
            var warehouse = await db.Queryable<BasWarehouse>().Where(p => p.whcode == input.warehouse).FirstAsync();
            if (warehouse != null)
                wmsPurchaseH.warehouse_id = warehouse.id;
            wmsPurchaseH.supplier_code = input.supplier_code;
            var supplier = await db.Queryable<BasSupplier>().Where(p => p.supplier_code == input.supplier_code).FirstAsync();
            if (supplier != null)
            {
                wmsPurchaseH.supplier_id = supplier.id;

                wmsPurchaseH.supplier_name = supplier.supplier_name;
            }
            List<WmsPurchaseD> WmsPurchaseDs = new List<WmsPurchaseD>();
            foreach (var detail in input.details)
            {
                WmsPurchaseD wmsPurchased = new WmsPurchaseD();
                wmsPurchased.bill_id = wmsPurchaseH.id;
                wmsPurchased.line_status = "25065138925589";//新增
                wmsPurchased.purchase_qty = detail.purchase_qty;
                wmsPurchased.purchase_prqty = detail.purchase_prqty;
                wmsPurchased.code_batch = detail.code_batch;
                wmsPurchased.purchase_arriveqty = detail.purchase_arriveqty;
                wmsPurchased.container_no = detail.container_no;
                wmsPurchased.material_code = detail.material_code;
                var material = await db.Queryable<BasMaterial>().Where(p => p.code == detail.material_code).FirstAsync();
                if (material != null)
                {
                    wmsPurchased.material_id = material.id;
                    //    wmsPurchased.material_name = material.name;
                    wmsPurchased.unit_id = material.unit_id;
                }
                WmsPurchaseDs.Add(wmsPurchased);
            }
            await db.Insertable(wmsPurchaseH).ExecuteCommandAsync();
            await db.Insertable(WmsPurchaseDs).ExecuteCommandAsync();

        }
        /// <summary>
        /// 仓库调拨
        /// </summary>
        public async Task Allot(AllotInput input)
        {
            var db = _repository.AsSugarClient();
            WmsAllot wmsAllot = new WmsAllot();
            string Code = await _billRuleService.GetBillNumber("WmsTransfer");
            wmsAllot.bill_code = Code;
            wmsAllot.biz_type = "25044010525205";//仓库调拨
            wmsAllot.status = "25065138925589";//新增
            var warehouse = await db.Queryable<BasWarehouse>().Where(p => p.whcode == input.warehouse).FirstAsync();
            if (warehouse != null)
                wmsAllot.warehouse_id = warehouse.id;
            var startloc = await db.Queryable<BasLocation>().Where(p => p.location_code == input.startlocation).FirstAsync();
            if (startloc != null)
                wmsAllot.startlocation_id = startloc.id;
            var endloc = await db.Queryable<BasLocation>().Where(p => p.location_code == input.endlocation).FirstAsync();
            if (endloc != null)
                wmsAllot.endlocation_id = endloc.id;
            wmsAllot.create_time = DateTime.Now;
            await db.Insertable(wmsAllot).ExecuteCommandAsync();
        }
        /// <summary>
        /// 销售出库单
        /// </summary>
        public async Task SaleOut(SaleOutInput input)
        {
            var db = _repository.AsSugarClient();
            WmsSaleH WmsSaleH = new WmsSaleH();
            string Code = await _billRuleService.GetBillNumber("WmsSale");
            WmsSaleH.bill_code = Code;
            WmsSaleH.bill_type = "25103439022357";//销售出库单
            WmsSaleH.biz_type = "26191522660645";//一般出库
            WmsSaleH.status = "25065138925589";//新增
            WmsSaleH.generate_type = "1";//0人工 1自动
            WmsSaleH.create_time = DateTime.Now;
            WmsSaleH.source_id = input.source_id;
            WmsSaleH.source_code = input.source_code;
            WmsSaleH.ship_date = input.ship_date;
            WmsSaleH.shipping_method = input.shipping_method;
            var warehouse = await db.Queryable<BasWarehouse>().Where(p => p.whcode == input.warehouse).FirstAsync();
            if (warehouse != null)
                WmsSaleH.warehouse_id = warehouse.id;
            WmsSaleH.customer_code = input.customer_code;
            var customer = await db.Queryable<BasCustomer>().Where(p => p.customer_code == input.customer_code).FirstAsync();
            if (customer != null)
            {
                WmsSaleH.customer_id = customer.id;
                WmsSaleH.customer_name = customer.customer_name;
            }
            List<WmsSaleD> WmsSaleDs = new List<WmsSaleD>();
            foreach (var detail in input.details)
            {
                WmsSaleD WmsSaleD = new WmsSaleD();
                WmsSaleD.bill_id = WmsSaleH.id;
                WmsSaleD.line_status = "25065138925589";//新增
                WmsSaleD.purchase_qty = detail.purchase_qty;
                WmsSaleD.purchase_prqty = detail.purchase_prqty;
                WmsSaleD.code_batch = detail.code_batch;
                WmsSaleD.purchase_arriveqty = detail.purchase_arriveqty;
                WmsSaleD.container_no = detail.container_no;
                WmsSaleD.material_code = detail.material_code;
                var material = await db.Queryable<BasMaterial>().Where(p => p.code == detail.material_code).FirstAsync();
                if (material != null)
                {
                    WmsSaleD.material_id = material.id;
                    //    WmsSaleD.material_name = material.name;
                    WmsSaleD.unit_id = material.unit_id;
                }
                WmsSaleDs.Add(WmsSaleD);
            }
            await db.Insertable(WmsSaleH).ExecuteCommandAsync();
            await db.Insertable(WmsSaleDs).ExecuteCommandAsync();
        }
        /// <summary>
        /// 销售退货单
        /// </summary>
        public async Task SaleReturn(SaleReturnInput input)
        {
            var db = _repository.AsSugarClient();
            WmsInstockH WmsInstockH = new WmsInstockH();
            string Code = await _billRuleService.GetBillNumber("WmsInStock");
            WmsInstockH.bill_code = Code;
            WmsInstockH.bill_date = DateTime.Now;
            WmsInstockH.bill_type = "25103434001429";//销售退货单
            WmsInstockH.biz_type = "26191496816421";//一般入库
            WmsInstockH.status = "25065138925589";//新增
            WmsInstockH.generate_type = "1";//0人工 1自动
            WmsInstockH.create_time = DateTime.Now;
            WmsInstockH.source_id = input.source_id;
            WmsInstockH.source_code = input.source_code;
            WmsInstockH.source_line = input.source_line;
            WmsInstockH.source_detail_id = input.source_detail_id;
            WmsInstockH.is_check = 1;
            WmsInstockH.purchase_code = input.purchase_code;
            WmsInstockH.sync_status = "26191359047461";//无需同步
            WmsInstockH.print_status = "26191366982437";//未打印
            WmsInstockH.create_id = "";
            WmsInstockH.create_time = DateTime.Now;
            var location = await db.Queryable<BasLocation>().Where(p => p.location_code == input.location).FirstAsync();
            if (location != null)
                WmsInstockH.location_id = location.id;
            var warehouse = await db.Queryable<BasWarehouse>().Where(p => p.whcode == input.warehouse).FirstAsync();
            if (warehouse != null)
                WmsInstockH.warehouse_id = warehouse.id;
            WmsInstockH.supplier_code = input.supplier_code;
            var supplier = await db.Queryable<BasSupplier>().Where(p => p.supplier_code == input.supplier_code).FirstAsync();
            if (supplier != null)
            {
                WmsInstockH.supplier_id = supplier.id;
                WmsInstockH.supplier_name = supplier.supplier_name;
            }
            List<WmsInstockD> WmsInstockDs = new List<WmsInstockD>();
            foreach (var detail in input.details)
            {
                WmsInstockD WmsInstockD = new WmsInstockD();
                WmsInstockD.bill_id = WmsInstockH.id;
                WmsInstockD.line_status = "25065138925589";//新增
                WmsInstockD.pr_qty = detail.pr_qty;
                WmsInstockD.qty = detail.qty;
                WmsInstockD.reason = detail.reason;
                WmsInstockD.price = detail.price;
                WmsInstockD.tax_price = detail.tax_price;
                WmsInstockD.amount = detail.amount;
                WmsInstockD.all_amount = detail.all_amount;
                WmsInstockD.print_qty = 0;
                WmsInstockD.scan_qty = 0;
                WmsInstockD.code_batch = detail.code_batch;
                WmsInstockD.container_no = detail.container_no;
                var detailwarehouse = await db.Queryable<BasWarehouse>().Where(p => p.whcode == input.warehouse).FirstAsync();
                if (detailwarehouse != null)
                    WmsInstockD.warehouse_id = detailwarehouse.id;
                var material = await db.Queryable<BasMaterial>().Where(p => p.code == detail.material_code).FirstAsync();
                if (material != null)
                {
                    WmsInstockD.material_id = material.id;
                    WmsInstockD.unit_id = material.unit_id;

                }
                WmsInstockDs.Add(WmsInstockD);
            }
            await db.Insertable(WmsInstockH).ExecuteCommandAsync();
            await db.Insertable(WmsInstockDs).ExecuteCommandAsync();
        }


        /// <summary>
        /// 采购订单
        /// </summary>
        [HttpPost, NonUnify, AllowAnonymous]
        public async Task<Entities.Dto.Outputs.Result> PurchaseOrder(PurchaseOrderInput input)
        {
            LoggerErp2Mes.LogInformation($"【PurchaseOrderInput】ERP传入数据:{JsonConvert.SerializeObject(input)}");
            var db = _repository.AsSugarClient();

            if (string.IsNullOrEmpty(input.erp_pk))
            {
                _LoggerErp2Mes.LogWarning($"【PurchaseOrderInput】主表主键不能为空！");
                return await ToApiResult(HttpStatusCode.InternalServerError, $"主表主键不能为空！");
            }

            int count_erp_line_pk = input.details.Where(r => string.IsNullOrEmpty(r.erp_line_pk)).Count();
            if (count_erp_line_pk > 0)
            {
                _LoggerErp2Mes.LogWarning($@"【PurchaseOrderInput】子表主键不能为空！");
                throw new AppFriendlyException($@"子表主键不能为空！", 500);
            }

            var wmsPurchaseOrdersDistinct = input.details.Select(r => new
            {
                material_id = r.material_code,
                code_batch = r.code_batch,
            }).Distinct();
            if (wmsPurchaseOrdersDistinct.Count() < input.details.Count)
            {
                _LoggerErp2Mes.LogWarning($@"【PurchaseOrderInput】表体存在物料和批号重复的明细！");
                throw new AppFriendlyException($@"表体存在物料和批号重复的明细！", 500);
            }

            try
            {
                await db.Ado.BeginTranAsync();
                WmsPurchaseOrderH wmsPurchaseOrderH = new WmsPurchaseOrderH();
                string Code = await _billRuleService.GetBillNumber("Purchase");

                wmsPurchaseOrderH.purchase_order = Code;
                wmsPurchaseOrderH.erp_bill_code = input.purchase_order;
                wmsPurchaseOrderH.contact_person = input.contact_person;
                wmsPurchaseOrderH.tel = input.tel;
                wmsPurchaseOrderH.supplier_code = input.supplier_code;
                wmsPurchaseOrderH.certificate_date = input.certificate_date.Value.ToString("yyyy-MM-dd HH:mm:ss");
                wmsPurchaseOrderH.ship_date = input.ship_date;
                wmsPurchaseOrderH.erp_pk = input.erp_pk;
                wmsPurchaseOrderH.create_id = WmsWareHouseConst.ErpUserId;
                wmsPurchaseOrderH.create_time = DateTime.Now;
                var supplier = await db.Queryable<BasSupplier>().Where(p => p.supplier_code == input.supplier_code).FirstAsync();
                if (supplier != null)
                {
                    wmsPurchaseOrderH.supplier_id = supplier.id;
                    wmsPurchaseOrderH.supplier_name = supplier.supplier_name;
                }

                await db.Insertable(wmsPurchaseOrderH).ExecuteCommandAsync();


                List<WmsPurchaseOrderD> wmsPurchaseOrderDs = new List<WmsPurchaseOrderD>();
                foreach (var detail in input.details)
                {
                    WmsPurchaseOrderD wmsPurchaseOrderD = new WmsPurchaseOrderD();

                    wmsPurchaseOrderD.fk_wms_purchase_order_id = wmsPurchaseOrderH.id;
                    wmsPurchaseOrderD.matcode = detail.material_code;
                    wmsPurchaseOrderD.unit = detail.unit_code;
                    wmsPurchaseOrderD.purchase_quantity = detail.purchase_quantity.ToString();
                    wmsPurchaseOrderD.stock_location = detail.stock_location;
                    wmsPurchaseOrderD.code_batch = detail.code_batch;
                    wmsPurchaseOrderD.delivery_date = detail.delivery_date.Value.ToString("yyyy-MM-dd HH:mm:ss");
                    wmsPurchaseOrderD.erp_line_pk = detail.erp_line_pk;
                    wmsPurchaseOrderD.create_id = WmsWareHouseConst.ErpUserId;
                    wmsPurchaseOrderD.create_time = DateTime.Now;
                    wmsPurchaseOrderD.actual_quantity = "0";

                    var material = await db.Queryable<BasMaterial>().Where(p => p.code == detail.material_code).FirstAsync();
                    if (material != null)
                    {
                        wmsPurchaseOrderD.matcode_id = material.id;
                        wmsPurchaseOrderD.matspecification = material.material_specification;
                    }

                    wmsPurchaseOrderDs.Add(wmsPurchaseOrderD);
                }

                await db.Insertable(wmsPurchaseOrderDs).ExecuteCommandAsync();

                await db.Ado.CommitTranAsync();

                LoggerErp2Mes.LogInformation($"【PurchaseOrderInput】成功生成单据:{Code}");
                return await ToApiResult(HttpStatusCode.OK, "成功");
            }
            catch (Exception ex)
            {
                LoggerErp2Mes.LogError($"【PurchaseOrderInput】{ex.Message}");
                LoggerErp2Mes.LogError($"【PurchaseOrderInput】{ex.StackTrace}");
                await db.Ado.RollbackTranAsync();
                return await ToApiResult(HttpStatusCode.InternalServerError, ex.Message);
            }
            finally
            {

            }
        }

        /// <summary>
        /// 转库单
        /// </summary>
        [HttpPost, NonUnify, AllowAnonymous]
        public async Task<Entities.Dto.Outputs.Result> MaterialTransfer(MaterialTransferInput input)
        {
            LoggerErp2Mes.LogInformation($"【MaterialTransfer】ERP传入数据:{JsonConvert.SerializeObject(input)}");
            var db = _repository.AsSugarClient();

            BasWarehouse warehouse_outstock = await db.Queryable<BasWarehouse>().Where(r => r.whcode == input.warehouse_outstock).FirstAsync();
            BasWarehouse warehouse_instock = await db.Queryable<BasWarehouse>().Where(r => r.whcode == input.warehouse_instock).FirstAsync();
            if (warehouse_outstock == null)
            {
                _LoggerErp2Mes.LogWarning($"【MaterialTransfer】无法查询到出库仓库{input.warehouse_outstock}的档案记录！");
                return await ToApiResult(HttpStatusCode.InternalServerError, $"无法查询到出库仓库{input.warehouse_outstock}的档案记录！");
            }
            if (warehouse_instock == null)
            {
                _LoggerErp2Mes.LogWarning($"【MaterialTransfer】无法查询到入库仓库{input.warehouse_instock}的档案记录！");
                return await ToApiResult(HttpStatusCode.InternalServerError, $"无法查询到入库仓库{input.warehouse_instock}的档案记录！");
            }

            if (string.IsNullOrEmpty(input.erp_pk))
            {
                _LoggerErp2Mes.LogWarning($"【MaterialTransfer】主表主键不能为空！");
                return await ToApiResult(HttpStatusCode.InternalServerError, $"主表主键不能为空！");
            }

            int count_erp_line_pk = input.details.Where(r => string.IsNullOrEmpty(r.erp_line_pk)).Count();
            if (count_erp_line_pk > 0)
            {
                _LoggerErp2Mes.LogWarning($@"【MaterialTransfer】子表主键不能为空！");
                throw new AppFriendlyException($@"子表主键不能为空！", 500);
            }

            string transfer_type = "";
            // 中储仓到暂存仓
            if (warehouse_outstock.id == WmsWareHouseConst.WAREHOUSE_ZC_ID && warehouse_instock.id == WmsWareHouseConst.WAREHOUSE_ZCC_ID)
            {
                int count = input.details.Where(r => string.IsNullOrEmpty(r.station_code)).Count();
                if (count > 0)
                {
                    _LoggerErp2Mes.LogWarning($@"【MaterialTransfer】表体存在未填写工位的明细！");
                    throw new AppFriendlyException($@"表体存在未填写工位的明细！", 500);
                }

                transfer_type = WmsWareHouseConst.MATERIALTRANSFER_CGCK_CODE;
            }
            else if (warehouse_outstock.id == WmsWareHouseConst.WAREHOUSE_CPCRK_ID && warehouse_instock.id == WmsWareHouseConst.WAREHOUSE_CP_ID)
            {
                transfer_type = WmsWareHouseConst.MATERIALTRANSFER_WXDBRK_CODE;
            }
            else if (warehouse_outstock.id == WmsWareHouseConst.WAREHOUSE_YCL_ID && warehouse_instock.id == WmsWareHouseConst.WAREHOUSE_JZGL_ID)
            {
                transfer_type = WmsWareHouseConst.MATERIALTRANSFER_JZGLRK_CODE;
            }
            // 暂时其他情况都算齐套出入库类型(未定)
            else
            {
                int count = input.details.Where(r => string.IsNullOrEmpty(r.station_code)).Count();
                if (count > 0)
                {
                    _LoggerErp2Mes.LogWarning($@"【MaterialTransfer】表体存在未填写工位的明细！");
                    throw new AppFriendlyException($@"表体存在未填写工位的明细！", 500);
                }

                transfer_type = WmsWareHouseConst.MATERIALTRANSFER_QTCRK_CODE;
            }


            var wmsMaterialTransferdsDistinct = input.details.Select(r => new
            {
                material_id = r.material_code,
                code_batch = r.code_batch,
            }).Distinct();
            if (wmsMaterialTransferdsDistinct.Count() < input.details.Count)
            {
                _LoggerErp2Mes.LogWarning($@"【MaterialTransfer】表体存在物料和批号重复的明细！");
                throw new AppFriendlyException($@"表体存在物料和批号重复的明细！", 500);
            }

            try
            {
                await db.Ado.BeginTranAsync();
                WmsMaterialTransfer wmsMaterialTransfer = new WmsMaterialTransfer();
                string Code = await _billRuleService.GetBillNumber("MaterialTransfer");
                wmsMaterialTransfer.bill_code = Code;
                wmsMaterialTransfer.status = WmsWareHouseConst.BILLSTATUS_ADD_ID;
                wmsMaterialTransfer.bill_date = DateTime.Now;
                wmsMaterialTransfer.warehouse_outstock = warehouse_outstock.id;
                wmsMaterialTransfer.warehouse_instock = warehouse_instock.id;
                wmsMaterialTransfer.biller_out = input.biller_out;
                wmsMaterialTransfer.depart_out = input.depart_out;
                wmsMaterialTransfer.biller_in = input.biller_in;
                wmsMaterialTransfer.depart_in = input.depart_in;
                wmsMaterialTransfer.deliver_date = input.deliver_date;
                wmsMaterialTransfer.arrival_date = input.arrival_date;
                wmsMaterialTransfer.create_id = WmsWareHouseConst.ErpUserId;
                wmsMaterialTransfer.create_time = DateTime.Now;
                wmsMaterialTransfer.org_id = WmsWareHouseConst.AdministratorOrgId;
                wmsMaterialTransfer.erp_bill_code = input.bill_code;
                wmsMaterialTransfer.transfer_type = transfer_type;
                wmsMaterialTransfer.erp_pk = input.erp_pk;

                await db.Insertable(wmsMaterialTransfer).ExecuteCommandAsync();

                List<WmsMaterialTransferD> wmsMaterialTransferDs = new List<WmsMaterialTransferD>();
                foreach (var detail in input.details)
                {
                    WmsMaterialTransferD wmsMaterialTransferD = new WmsMaterialTransferD();
                    wmsMaterialTransferD.lineno = detail.lineno;
                    wmsMaterialTransferD.material_code = detail.material_code;
                    wmsMaterialTransferD.code_batch = detail.code_batch;
                    wmsMaterialTransferD.station_code = detail.station_code;
                    wmsMaterialTransferD.qty = detail.qty;
                    wmsMaterialTransferD.bill_id = wmsMaterialTransfer.id;

                    wmsMaterialTransferD.yxfqty = 0;
                    wmsMaterialTransferD.yzqty = 0;
                    wmsMaterialTransferD.erp_line_pk = detail.erp_line_pk;

                    var material = await db.Queryable<BasMaterial>().Where(p => p.code == detail.material_code).FirstAsync();
                    if (material != null)
                    {
                        wmsMaterialTransferD.material_id = material.id;
                        wmsMaterialTransferD.material_specification = material.material_specification;
                    }

                    var erpExtendField = await db.Queryable<ErpExtendField>().InnerJoin<DictionaryDataEntity>((a, b) => a.table_id == b.Id).Where((a, b) => a.cunitid == detail.unit_code).Select((a, b) => b).FirstAsync();
                    if (erpExtendField != null)
                    {
                        wmsMaterialTransferD.unit_id = erpExtendField.Id;
                        wmsMaterialTransferD.unit_code = erpExtendField.EnCode;
                    }
                    else
                    {
                        _LoggerErp2Mes.LogWarning($@"【MaterialTransfer】表体明细中单位{detail.unit_code}在wms系统中未找到！");
                        throw new AppFriendlyException($@"表体明细中单位{detail.unit_code}在wms系统中未找到！", 500);
                    }

                    wmsMaterialTransferDs.Add(wmsMaterialTransferD);
                }

                await db.Insertable(wmsMaterialTransferDs).ExecuteCommandAsync();

                await db.Ado.CommitTranAsync();

                LoggerErp2Mes.LogInformation($"【MaterialTransfer】成功生成单据:{Code}");
                return await ToApiResult(HttpStatusCode.OK, "成功");
            }
            catch (Exception ex)
            {
                LoggerErp2Mes.LogError($"【MaterialTransfer】{ex.Message}");
                LoggerErp2Mes.LogError($"【MaterialTransfer】{ex.StackTrace}");
                await db.Ado.RollbackTranAsync();
                return await ToApiResult(HttpStatusCode.InternalServerError, ex.Message);
            }
            finally
            {

            }
        }

        protected Task<Entities.Dto.Outputs.Result> ToApiResult(HttpStatusCode statusCode, string msg)
        {
            Entities.Dto.Outputs.Result result = new()
            {
                code = statusCode,
                msg = msg
            };
            return Task.FromResult(result);
        }

        private static readonly Dictionary<LogLevel, string> s_logLevelMap = new()
        {
            [LogLevel.Debug] = "DBG",
            [LogLevel.Information] = "INF",
            [LogLevel.Warning] = "WRN",
            [LogLevel.Error] = "ERR",
        };

        protected string _LoggerErp2MesFileName = "";
        protected ILogger _LoggerErp2Mes;
        protected ILogger LoggerErp2Mes
        {
            get
            {
                string newFileName = $"{AppContext.BaseDirectory}/logs/Erp2Mes{DateTime.Now:yyyyMMdd}.log";
                if (_LoggerErp2MesFileName != newFileName)
                {
                    ILoggerFactory loggerFactory = LoggerFactory.Create(builder => builder.AddFile(newFileName, cfgOpts =>
                    {

                        //cfgOpts.DateFormat = "yyyy-MM-dd HH:mm:ss.fff";
                        cfgOpts.MessageFormat = (logMsg) =>
                        {
                            var logLevel = s_logLevelMap[logMsg.LogLevel];
                            var sb = new StringBuilder();
                            _ = sb.Append($"[{logLevel}] ");
                            _ = sb.Append($"{logMsg.LogName} ");
                            _ = sb.Append($"{DateTime.Now:yyyy-MM-dd HH:mm:ss.fff} ");
                            _ = sb.Append($"#{logMsg.EventId.Id} ");
                            _ = sb.Append(logMsg.Message + " ");
                            _ = sb.Append(logMsg.Exception?.ToString());
                            return sb.ToString();
                        };

                    }));
                    _LoggerErp2Mes = loggerFactory.CreateLogger(this.GetType());
                    _LoggerErp2MesFileName = newFileName;
                }
                return _LoggerErp2Mes;
            }
        }
    }
}