| using AutoMapper; | 
| using HslCommunication.WebSocket; | 
| using Microsoft.AspNetCore.Mvc.RazorPages; | 
| using Newtonsoft.Json; | 
| using SqlSugar; | 
| using System; | 
| using System.Collections.Generic; | 
| using System.Linq; | 
| using System.Linq.Expressions; | 
| using System.Reflection.Metadata; | 
| using System.Text; | 
| using System.Threading.Tasks; | 
| using WIDESEA_Common.CommonEnum; | 
| using WIDESEA_Common.OrderEnum; | 
| using WIDESEA_Common.StockEnum; | 
| using WIDESEA_Common.WareHouseEnum; | 
| using WIDESEA_Core; | 
| using WIDESEA_Core.BaseRepository; | 
| using WIDESEA_Core.BaseServices; | 
| using WIDESEA_Core.CodeConfigEnum; | 
| using WIDESEA_Core.DB; | 
| using WIDESEA_Core.Enums; | 
| using WIDESEA_Core.Helper; | 
| using WIDESEA_Core.Seed; | 
| using WIDESEA_Core.Utilities; | 
| using WIDESEA_DTO; | 
| using WIDESEA_DTO.Basic; | 
| using WIDESEA_DTO.ERP; | 
| using WIDESEA_DTO.Inbound; | 
| using WIDESEA_DTO.MES; | 
| using WIDESEA_External.ERPService; | 
| using WIDESEA_External.Model; | 
| using WIDESEA_IBasicRepository; | 
| using WIDESEA_IBasicService; | 
| using WIDESEA_IInboundRepository; | 
| using WIDESEA_IInboundService; | 
| using WIDESEA_IRecordService; | 
| using WIDESEA_IStockRepository; | 
| using WIDESEA_IStockService; | 
| using WIDESEA_ITaskInfoRepository; | 
| using WIDESEA_ITaskInfoService; | 
| using WIDESEA_Model.Models; | 
| using WIDESEA_StockRepository; | 
|   | 
| namespace WIDESEA_InboundService | 
| { | 
|     public class InboundOrderService : ServiceBase<Dt_InboundOrder, IInboundOrderRepository>, IInboundOrderService | 
|     { | 
|         private readonly IMapper _mapper; | 
|         private readonly IUnitOfWorkManage _unitOfWorkManage; | 
|         private readonly IInboundRepository _inboundRepository; | 
|         private readonly IBasicRepository _basicRepository; | 
|         private readonly IStockRepository _stockRepository; | 
|         private readonly IRecordService _recordService; | 
|         private readonly IInvokeERPService _invokeERPService; | 
|         private readonly IWarehouseService _warehouseService; | 
|         private readonly IPalletTypeInfoRepository _palletTypeInfoRepository; | 
|   | 
|         public IInboundOrderRepository Repository => BaseDal; | 
|   | 
|         public InboundOrderService(IInboundOrderRepository BaseDal, IMapper mapper, IUnitOfWorkManage unitOfWorkManage, IInboundRepository inboundRepository, IBasicRepository basicRepository, IStockRepository stockRepository, IRecordService recordService, IInvokeERPService invokeERPService, IWarehouseService warehouseService, IPalletTypeInfoRepository palletTypeInfoRepository) : base(BaseDal) | 
|         { | 
|             _mapper = mapper; | 
|             _unitOfWorkManage = unitOfWorkManage; | 
|             _inboundRepository = inboundRepository; | 
|             _basicRepository = basicRepository; | 
|             _stockRepository = stockRepository; | 
|             _recordService = recordService; | 
|             _invokeERPService = invokeERPService; | 
|             _warehouseService = warehouseService; | 
|             _palletTypeInfoRepository = palletTypeInfoRepository; | 
|         } | 
|         /// <summary> | 
|         /// 其他入库单创建 | 
|         /// </summary> | 
|         /// <returns></returns> | 
|         public WebResponseContent ReceiveWarehousingOrder(ErpInOrderDTO erpInOrder) | 
|         { | 
|             WebResponseContent content = new WebResponseContent(); | 
|             try | 
|             { | 
|                 //获取仓库信息 | 
|                 Dt_Warehouse warehouse = _warehouseService.Repository.QueryFirst(x => x.WarehouseCode == erpInOrder.WaId); | 
|                 if (warehouse == null) | 
|                 { | 
|                     return content.Error("未找到仓库信息"); | 
|                 } | 
|                 //获取是否存在订单 | 
|                 Dt_InboundOrder inboundOrder = BaseDal.QueryFirst(x => x.InboundOrderNo == erpInOrder.OrderNo); | 
|                 if (erpInOrder.Way == 1) | 
|                 { | 
|                     if (inboundOrder != null) | 
|                     { | 
|   | 
|                     } | 
|                 } | 
|                 else if (erpInOrder.Way == 2) | 
|                 { | 
|   | 
|                 } | 
|                 else | 
|                 { | 
|   | 
|                 } | 
|                 return content.OK(); | 
|             } | 
|             catch (Exception ex) | 
|             { | 
|                 content.Error(ex.Message); | 
|             } | 
|             return content; | 
|         } | 
|         public WebResponseContent GetInboundOrders(SaveModel saveModel) | 
|         { | 
|             WebResponseContent content = new WebResponseContent(); | 
|             try | 
|             { | 
|                 int pageNo = saveModel.MainData["pageNo"].ObjToInt(); | 
|                 string? orderNo = saveModel.MainData["orderNo"].ToString(); | 
|                 int warehouseId = saveModel.MainData["warehouseId"].ObjToInt(); | 
|                 List<Dt_InboundOrder> dt_ReceiveOrders = new List<Dt_InboundOrder>(); | 
|                 if (string.IsNullOrEmpty(orderNo)) | 
|                 { | 
|                     dt_ReceiveOrders = Db.Queryable<Dt_InboundOrder>().Where(x => x.OrderStatus < InOrderStatusEnum.入库完成.ObjToInt() && x.WarehouseId == warehouseId).OrderByDescending(x => x.CreateDate).ToPageList(pageNo, 5); | 
|                 } | 
|                 else | 
|                 { | 
|                     dt_ReceiveOrders = Db.Queryable<Dt_InboundOrder>().Where(x => (x.InboundOrderNo.Contains(orderNo)) && x.OrderStatus < InOrderStatusEnum.入库完成.ObjToInt() && x.WarehouseId == warehouseId).OrderByDescending(x => x.CreateDate).ToPageList(pageNo, 5); | 
|                 } | 
|   | 
|                 content.OK(data: dt_ReceiveOrders); | 
|             } | 
|             catch (Exception ex) | 
|             { | 
|                 content.Error(ex.Message); | 
|             } | 
|             return content; | 
|         } | 
|         /// <summary> | 
|         /// 单个物料码组盘 适用测试架 | 
|         /// </summary> | 
|         /// <param name="inboundOrderId"></param> | 
|         /// <param name="palletCode"></param> | 
|         /// <param name="serNum"></param> | 
|         /// <returns></returns> | 
|         public WebResponseContent MaterielGroup(int inboundOrderId, string palletCode, string serNum) | 
|         { | 
|             try | 
|             { | 
|                 Dt_InboundOrder inboundOrder = BaseDal.Db.Queryable<Dt_InboundOrder>().Where(x => x.Id == inboundOrderId).Includes(x => x.Details).First(); | 
|                 if (inboundOrder == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到入库单信息"); | 
|                 } | 
|                 if (inboundOrder.OrderStatus >= InOrderStatusEnum.入库完成.ObjToInt()) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"入库单已结束"); | 
|                 } | 
|                 if (inboundOrder.Details.Count <= 0) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到入库单明细信息"); | 
|                 } | 
|                 MatSerNumAnalysisModel model = CodeAnalysisHelper.CodeAnalysis<MatSerNumAnalysisModel>(AnalysisCodeEnum.MatSerNumAnalysis, serNum); | 
|                 Dt_MaterielInfo materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterielCode == model.MaterielCode); | 
|                 if (materielInfo == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到该物料的信息"); | 
|                 } | 
|                 if (materielInfo.WarehouseId != inboundOrder.WarehouseId) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"该物料不属于本仓"); | 
|                 } | 
|                 Dt_ReceiveOrder receiveOrder = _inboundRepository.ReceiveOrderRepository.Db.Queryable<Dt_ReceiveOrder>().Where(x => x.ReceiveOrderNo == inboundOrder.UpperOrderNo).Includes(x => x.Details).First(); | 
|                 if (receiveOrder == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到对应的收货单"); | 
|                 } | 
|                 if (receiveOrder.Details.Count <= 0) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到对应的收货单明细"); | 
|                 } | 
|                 List<string> purchaseOrderNos = receiveOrder.Details.Select(x => x.PurchaseOrderNo).ToList(); | 
|                 if (!purchaseOrderNos.Contains(model.PurchaseOrderNo)) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到对应收货单明细中采购单"); | 
|                 } | 
|                 Dt_ReceiveOrderDetail? receiveOrderDetail = receiveOrder.Details.FirstOrDefault(x => x.MaterielCode == model.MaterielCode); | 
|                 if (receiveOrderDetail == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未在收货单明细中找到该物料信息"); | 
|                 } | 
|                 Dt_InboundOrderDetail? inboundOrderDetail = inboundOrder.Details.FirstOrDefault(x => x.MaterielCode == model.MaterielCode); | 
|                 if (inboundOrderDetail == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未在入库单明细中找到该物料信息"); | 
|                 } | 
|                 if (inboundOrderDetail.OrderDetailStatus > OrderDetailStatusEnum.GroupAndInbound.ObjToInt()) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"对应入库单明细已结束"); | 
|                 } | 
|                 float inboundDetailSum = inboundOrderDetail.OverInQuantity + inboundOrderDetail.ReceiptQuantity; | 
|                 if (inboundDetailSum == inboundOrderDetail.OrderQuantity) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"该物料入库单明细已全部组盘完成"); | 
|                 } | 
|                 if (model.Quantity > receiveOrderDetail.ReceivedQuantity || (inboundDetailSum + model.Quantity) > receiveOrderDetail.ReceivedQuantity) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"与该收货单明细收货数量不一致"); | 
|                 } | 
|                 Dt_StockInfo oldStockinfo = _stockRepository.StockInfoRepository.QueryFirst(x => x.PalletCode == palletCode); | 
|                 if (oldStockinfo != null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"托盘重复"); | 
|                 } | 
|                 Dt_StockInfoDetail stockInfoDetail = new Dt_StockInfoDetail() | 
|                 { | 
|                     BatchNo = model.LotNo, | 
|                     MaterielCode = materielInfo.MaterielCode, | 
|                     MaterielName = materielInfo.MaterielName, | 
|                     OrderNo = inboundOrder.InboundOrderNo, | 
|                     SerialNumber = model.SerialNumber, | 
|                     StockQuantity = model.Quantity, | 
|                     OutboundQuantity = 0, | 
|                     Unit = materielInfo.MaterielUnit, | 
|                     Status = StockStatusEmun.组盘暂存.ObjToInt(), | 
|                     ProductionDate = model.ProductionDate, | 
|                     EffectiveDate = model.EffectiveDate, | 
|                     InboundOrderRowNo = inboundOrderDetail.RowNo, | 
|                 }; | 
|   | 
|                 Dt_StockInfo stockInfo = new Dt_StockInfo() | 
|                 { | 
|                     PalletCode = palletCode, | 
|                     StockStatus = StockStatusEmun.组盘暂存.ObjToInt(), | 
|                     WarehouseId = inboundOrder.WarehouseId, | 
|                     Details = new List<Dt_StockInfoDetail> { stockInfoDetail } | 
|                 }; | 
|                 inboundOrderDetail.ReceiptQuantity += model.Quantity; | 
|                 _unitOfWorkManage.BeginTran(); | 
|                 if (inboundOrderDetail.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt()) | 
|                 { | 
|                     inboundOrderDetail.OrderDetailStatus = OrderDetailStatusEnum.GroupAndInbound.ObjToInt(); | 
|                 } | 
|                 _inboundRepository.InboundOrderDetailRepository.UpdateData(inboundOrderDetail); | 
|                 if (inboundOrder.OrderStatus == InOrderStatusEnum.未开始.ObjToInt()) | 
|                 { | 
|                     inboundOrder.OrderStatus = InOrderStatusEnum.入库中.ObjToInt(); | 
|                     BaseDal.UpdateData(inboundOrder); | 
|                 } | 
|                 _stockRepository.StockInfoRepository.Db.InsertNav(stockInfo).Include(x => x.Details).ExecuteCommand(); | 
|                 _unitOfWorkManage.CommitTran(); | 
|                 return WebResponseContent.Instance.OK(); | 
|             } | 
|             catch (Exception ex) | 
|             { | 
|                 _unitOfWorkManage.RollbackTran(); | 
|                 return WebResponseContent.Instance.Error(ex.Message); | 
|             } | 
|         } | 
|   | 
|   | 
|         /// <summary> | 
|         /// 入平库,直接添加库存 | 
|         /// </summary> | 
|         /// <param name="warehouseId"></param> | 
|         /// <param name="serNums"></param> | 
|         /// <returns></returns> | 
|         public WebResponseContent InPinKu(string inboundOrderId, int warehouseId, List<string> serNums) | 
|         { | 
|             WebResponseContent content = new WebResponseContent(); | 
|             try | 
|             { | 
|                 Dt_Warehouse warehouse = _warehouseService.Repository.QueryFirst(x => x.WarehouseId == warehouseId); | 
|                 if (warehouse == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到该仓库信息"); | 
|                 } | 
|                 Dt_InboundOrder inboundOrder = BaseDal.Db.Queryable<Dt_InboundOrder>().Where(x => x.InboundOrderNo == inboundOrderId && x.WarehouseId == warehouse.WarehouseId).Includes(x => x.Details).First(); | 
|                 if (inboundOrder == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到入库单信息"); | 
|                 } | 
|                 if (inboundOrder.Details == null || inboundOrder.Details.Count <= 0) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到入库单明细信息"); | 
|                 } | 
|   | 
|                 //入库明细原完成数量 | 
|                 int oldCount = inboundOrder.Details.Where(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()).ToList().Count; | 
|   | 
|                 Dt_ReceiveOrder receiveOrder = _inboundRepository.ReceiveOrderRepository.Db.Queryable<Dt_ReceiveOrder>().Where(x => x.ReceiveOrderNo == inboundOrder.UpperOrderNo).Includes(x => x.Details).First(); | 
|                 if (receiveOrder == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到对应的收货单"); | 
|                 } | 
|                 if (receiveOrder.Details == null || receiveOrder.Details.Count <= 0) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到对应的收货单明细"); | 
|                 } | 
|   | 
|                 List<string> purchaseOrderNos = receiveOrder.Details.Select(x => x.PurchaseOrderNo).ToList(); | 
|   | 
|                 List<MatSerNumAnalysisModel> models = CodeAnalysisHelper.CodeAnalysis<MatSerNumAnalysisModel>(AnalysisCodeEnum.MatSerNumAnalysis, serNums); | 
|   | 
|                 if (models.Select(x => x.MaterielCode).Distinct().Count() > 1) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"物料不可混放"); | 
|                 } | 
|   | 
|                 string materielCode = models.FirstOrDefault()?.MaterielCode ?? ""; | 
|                 Dt_MaterielInfo materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterielCode == materielCode); | 
|                 if (materielInfo == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到该物料的信息"); | 
|                 } | 
|   | 
|                 List<Dt_InboundOrderDetail> inboundOrderDetails = inboundOrder.Details.Where(x => x.MaterielCode == materielCode).ToList(); | 
|   | 
|                 if (inboundOrderDetails == null || inboundOrderDetails.Count <= 0) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未在入库单明细中找到该物料信息"); | 
|                 } | 
|                 foreach (var model in models) | 
|                 { | 
|                     if (!inboundOrderDetails.Any(x => x.BatchNo == model.LotNo)) | 
|                         return WebResponseContent.Instance.Error($"未在入库单明细中找到该物料批次【{model.LotNo}】"); | 
|                 } | 
|                 if (receiveOrder.Details.FirstOrDefault(x => x.MaterielCode == materielCode) == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未在收货单明细中找到该物料信息"); | 
|                 } | 
|                 float beforeQuantity = 0; | 
|                 Dt_StockInfo stockInfo = new Dt_StockInfo() | 
|                 { | 
|                     PalletCode = DateTime.Now.ToString("yyyyMMddHHmmss"), | 
|                     StockStatus = StockStatusEmun.入库完成.ObjToInt(), | 
|                     WarehouseId = inboundOrder.WarehouseId, | 
|                     PalletType = PalletTypeEnum.SmallPallet.ObjToInt(), | 
|                     LocationCode = "平库位", | 
|                     Details = new List<Dt_StockInfoDetail>() | 
|                 }; | 
|   | 
|                 List<Dt_StockInfoDetail> stockInfoDetails = new List<Dt_StockInfoDetail>(); | 
|                 List<int> detailKeys = new List<int>(); | 
|                 foreach (var model in models) | 
|                 { | 
|                     if (purchaseOrderNos.FirstOrDefault(x => x == model.PurchaseOrderNo) == null) | 
|                     { | 
|                         return WebResponseContent.Instance.Error($"未在收货单明细中找到该采购单"); | 
|                     } | 
|   | 
|                     Dt_InboundOrderDetail? notGroupDetail = inboundOrderDetails.Where(x => x.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt() && x.OrderQuantity == model.Quantity && !detailKeys.Contains(x.Id) && x.OrderQuantity > x.ReceiptQuantity).FirstOrDefault(); | 
|   | 
|                     if (notGroupDetail == null) | 
|                     { | 
|                         return WebResponseContent.Instance.Error($"该物料在该入库单中已全部组盘完成"); | 
|                     } | 
|                     detailKeys.Add(notGroupDetail.Id); | 
|   | 
|                     Dt_StockInfoDetail stockInfoDetail = new Dt_StockInfoDetail() | 
|                     { | 
|                         BatchNo = model.LotNo, | 
|                         MaterielCode = materielInfo.MaterielCode, | 
|                         MaterielName = materielInfo.MaterielName, | 
|                         OrderNo = inboundOrder.InboundOrderNo, | 
|                         SerialNumber = model.SerialNumber, | 
|                         StockQuantity = model.Quantity, | 
|                         OutboundQuantity = 0, | 
|                         Unit = materielInfo.MaterielUnit, | 
|                         Status = StockStatusEmun.入库完成.ObjToInt(), | 
|                         ProductionDate = model.ProductionDate, | 
|                         EffectiveDate = model.EffectiveDate, | 
|                         InboundOrderRowNo = notGroupDetail.RowNo, | 
|                     }; | 
|                     oldCount++; | 
|   | 
|                     if (stockInfo.Id > 0) | 
|                     { | 
|                         stockInfoDetail.StockId = stockInfo.Id; | 
|                     } | 
|                     stockInfo.Details.Add(stockInfoDetail); | 
|   | 
|                     stockInfoDetails.Add(stockInfoDetail); | 
|   | 
|                     notGroupDetail.ReceiptQuantity = model.Quantity; | 
|                     notGroupDetail.OverInQuantity = model.Quantity; | 
|                     notGroupDetail.OrderDetailStatus = OrderDetailStatusEnum.Over.ObjToInt(); | 
|                 } | 
|   | 
|                 //入库明细新增完成数量 | 
|                 if (inboundOrder.Details.Count == oldCount) | 
|                 { | 
|                     inboundOrder.OrderStatus = InOrderStatusEnum.入库完成.ObjToInt(); | 
|                 } | 
|                 else | 
|                     inboundOrder.OrderStatus = InOrderStatusEnum.入库中.ObjToInt(); | 
|                 float totalQuantity = stockInfo.Details.Sum(x => x.StockQuantity); | 
|   | 
|                 _unitOfWorkManage.BeginTran(); | 
|                 if (stockInfo.Id == 0) | 
|                 { | 
|                     _stockRepository.StockInfoRepository.Db.InsertNav(stockInfo).Include(x => x.Details).ExecuteCommand(); | 
|                 } | 
|                 else | 
|                 { | 
|                     _stockRepository.StockInfoRepository.Db.UpdateNav(stockInfo).Include(x => x.Details, new UpdateNavOptions() { OneToManyInsertOrUpdate = true }).ExecuteCommand(); | 
|                 } | 
|                 _inboundRepository.InboundOrderDetailRepository.UpdateData(inboundOrderDetails); | 
|                 _inboundRepository.InboundOrderRepository.UpdateData(inboundOrder); | 
|                 _recordService.StockQuantityChangeRecordService.AddStockChangeRecord(stockInfo, stockInfoDetails, beforeQuantity, totalQuantity, StockChangeTypeEnum.Inbound); | 
|                 _unitOfWorkManage.CommitTran(); | 
|   | 
|                 #region 入库完成上报ERP | 
|                 if (inboundOrder.OrderStatus == InOrderStatusEnum.入库完成.ObjToInt()) | 
|                     FeedbackInboundOrder(inboundOrder); | 
|                 #endregion | 
|                 content.OK(); | 
|             } | 
|             catch (Exception ex) | 
|             { | 
|                 _unitOfWorkManage.RollbackTran(); | 
|                 content.Error(ex.Message); | 
|             } | 
|             return content; | 
|         } | 
|         /// <summary> | 
|         /// WMS入平库不推单据 | 
|         /// </summary> | 
|         /// <param name="warehouseId"></param> | 
|         /// <param name="serNums"></param> | 
|         /// <returns></returns> | 
|         public WebResponseContent WMSInPinKu(int warehouseId, List<string> serNums) | 
|         { | 
|             WebResponseContent content = new WebResponseContent(); | 
|             try | 
|             { | 
|                 Dt_Warehouse warehouse = _warehouseService.Repository.QueryFirst(x => x.WarehouseId == warehouseId); | 
|                 if (warehouse == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到该仓库信息"); | 
|                 } | 
|                 List<MatSerNumAnalysisModel> models = CodeAnalysisHelper.CodeAnalysis<MatSerNumAnalysisModel>(AnalysisCodeEnum.MatSerNumAnalysis, serNums); | 
|                 if (models.Select(x => x.MaterielCode).Distinct().Count() > 1) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"物料不可混放"); | 
|                 } | 
|   | 
|                 string materielCode = models.FirstOrDefault()?.MaterielCode ?? ""; | 
|                 Dt_MaterielInfo materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterielCode == materielCode); | 
|                 if (materielInfo == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到该物料的信息"); | 
|                 } | 
|                 float beforeQuantity = 0; | 
|                 Dt_StockInfo stockInfo = new Dt_StockInfo() | 
|                 { | 
|                     PalletCode = DateTime.Now.ToString("yyyyMMddHHmmss"), | 
|                     StockStatus = StockStatusEmun.入库完成.ObjToInt(), | 
|                     WarehouseId = warehouse.WarehouseId, | 
|                     PalletType = PalletTypeEnum.SmallPallet.ObjToInt(), | 
|                     LocationCode = "平库位", | 
|                     Details = new List<Dt_StockInfoDetail>() | 
|                 }; | 
|                 List<Dt_StockInfoDetail> stockInfoDetails = new List<Dt_StockInfoDetail>(); | 
|                 foreach (var model in models) | 
|                 { | 
|                     Dt_StockInfoDetail stockInfoDetail = new Dt_StockInfoDetail() | 
|                     { | 
|                         BatchNo = model.LotNo, | 
|                         MaterielCode = materielInfo.MaterielCode, | 
|                         MaterielName = materielInfo.MaterielName, | 
|                         SerialNumber = model.SerialNumber, | 
|                         StockQuantity = model.Quantity, | 
|                         OutboundQuantity = 0, | 
|                         OrderNo = "", | 
|                         Unit = materielInfo.MaterielUnit, | 
|                         Status = StockStatusEmun.入库完成.ObjToInt(), | 
|                         ProductionDate = model.ProductionDate, | 
|                         EffectiveDate = model.EffectiveDate, | 
|                     }; | 
|   | 
|                     if (stockInfo.Id > 0) | 
|                     { | 
|                         stockInfoDetail.StockId = stockInfo.Id; | 
|                     } | 
|                     stockInfo.Details.Add(stockInfoDetail); | 
|   | 
|                     stockInfoDetails.Add(stockInfoDetail); | 
|   | 
|                 } | 
|                 float totalQuantity = stockInfo.Details.Sum(x => x.StockQuantity); | 
|                 _unitOfWorkManage.BeginTran(); | 
|                 if (stockInfo.Id == 0) | 
|                 { | 
|                     _stockRepository.StockInfoRepository.Db.InsertNav(stockInfo).Include(x => x.Details).ExecuteCommand(); | 
|                 } | 
|                 else | 
|                 { | 
|                     _stockRepository.StockInfoRepository.Db.UpdateNav(stockInfo).Include(x => x.Details, new UpdateNavOptions() { OneToManyInsertOrUpdate = true }).ExecuteCommand(); | 
|                 } | 
|                 _recordService.StockQuantityChangeRecordService.AddStockChangeRecord(stockInfo, stockInfoDetails, beforeQuantity, totalQuantity, StockChangeTypeEnum.Inbound); | 
|                 _unitOfWorkManage.CommitTran(); | 
|                 content.OK(); | 
|             } | 
|             catch (Exception ex) | 
|             { | 
|                 _unitOfWorkManage.RollbackTran(); | 
|                 content.Error(ex.Message); | 
|             } | 
|             return content; | 
|         } | 
|         /// <summary> | 
|         /// 组盘 | 
|         /// </summary> | 
|         /// <param name="saveModel"></param> | 
|         /// <returns></returns> | 
|         public WebResponseContent MaterielGroup(SaveModel saveModel) | 
|         { | 
|             WebResponseContent content = new WebResponseContent(); | 
|             try | 
|             { | 
|                 var orderNo = saveModel.MainData["orderNo"].ToString(); | 
|                 var palletCode = saveModel.MainData["palletCode"].ToString(); | 
|                 var warehouseId = saveModel.MainData["warehouseId"].ObjToInt(); | 
|                 var Initiallife = saveModel.MainData["initiallife"].ObjToInt(); | 
|                 var serNums = saveModel.DelKeys.Select(x => x.ToString()).ToList(); | 
|                 Dt_Warehouse warehouse = _warehouseService.Repository.QueryFirst(x => x.WarehouseId == warehouseId); | 
|                 if (warehouse == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到该仓库信息"); | 
|                 } | 
|   | 
|                 Dt_InboundOrder inboundOrder = BaseDal.Db.Queryable<Dt_InboundOrder>().Where(x => x.InboundOrderNo == orderNo && x.WarehouseId == warehouse.WarehouseId).Includes(x => x.Details).First(); | 
|                 if (inboundOrder == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到入库单信息"); | 
|                 } | 
|                 if (inboundOrder.Details == null || inboundOrder.Details.Count <= 0) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到入库单明细信息"); | 
|                 } | 
|   | 
|                 Dt_ReceiveOrder receiveOrder = _inboundRepository.ReceiveOrderRepository.Db.Queryable<Dt_ReceiveOrder>().Where(x => x.ReceiveOrderNo == inboundOrder.UpperOrderNo).Includes(x => x.Details).First(); | 
|                 if (receiveOrder == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到对应的收货单"); | 
|                 } | 
|                 if (receiveOrder.Details == null || receiveOrder.Details.Count <= 0) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到对应的收货单明细"); | 
|                 } | 
|   | 
|                 List<string> purchaseOrderNos = receiveOrder.Details.Select(x => x.PurchaseOrderNo).ToList(); | 
|   | 
|                 List<MatSerNumAnalysisModel> models = CodeAnalysisHelper.CodeAnalysis<MatSerNumAnalysisModel>(AnalysisCodeEnum.MatSerNumAnalysis, serNums); | 
|   | 
|                 if (models.Select(x => x.MaterielCode).Distinct().Count() > 1) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"物料不可混放"); | 
|                 } | 
|   | 
|                 string materielCode = models.FirstOrDefault()?.MaterielCode ?? ""; | 
|                 Dt_MaterielInfo materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterielCode == materielCode); | 
|                 if (materielInfo == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到该物料的信息"); | 
|                 } | 
|   | 
|                 List<Dt_InboundOrderDetail> inboundOrderDetails = inboundOrder.Details.Where(x => x.MaterielCode == materielCode && x.BatchNo == (models.FirstOrDefault()?.LotNo ?? "")).ToList(); | 
|   | 
|                 if (inboundOrderDetails == null || inboundOrderDetails.Count <= 0) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未在入库单明细中找到该物料信息"); | 
|                 } | 
|                 if (receiveOrder.Details.FirstOrDefault(x => x.MaterielCode == materielCode) == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未在收货单明细中找到该物料信息"); | 
|                 } | 
|   | 
|                 float beforeQuantity = 0; | 
|   | 
|                 Dt_StockInfo stockInfo = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.PalletCode == palletCode).Includes(x => x.Details).First(); | 
|                 if (stockInfo == null) | 
|                 { | 
|                     stockInfo = new Dt_StockInfo() | 
|                     { | 
|                         PalletCode = palletCode, | 
|                         StockStatus = StockStatusEmun.组盘暂存.ObjToInt(), | 
|                         WarehouseId = inboundOrder.WarehouseId, | 
|                         PalletType = GetPalletType(warehouse, palletCode), | 
|                         Details = new List<Dt_StockInfoDetail>() | 
|                     }; | 
|                 } | 
|                 else | 
|                 { | 
|                     if (stockInfo.StockStatus != StockStatusEmun.组盘暂存.ObjToInt()) | 
|                     { | 
|                         return WebResponseContent.Instance.Error($"托盘号重复"); | 
|                     } | 
|                     beforeQuantity = stockInfo.Details.Sum(x => x.StockQuantity); | 
|                 } | 
|   | 
|                 if (warehouse.WarehouseCode == WarehouseEnum.HA64.ToString()) | 
|                 { | 
|                     stockInfo.Remark = Initiallife.ToString(); | 
|                     string batchNo = models.FirstOrDefault()?.LotNo ?? ""; | 
|                     Dt_StockInfoDetail existDetail = _stockRepository.StockInfoDetailRepository.QueryFirst(x => x.BatchNo == batchNo); | 
|                     if (existDetail != null) | 
|                     { | 
|                         return WebResponseContent.Instance.Error($"{batchNo}测试架已存在"); | 
|                     } | 
|                     if (models.Count >= 2) | 
|                     { | 
|                         return WebResponseContent.Instance.Error($"组盘明细不唯一"); | 
|                     } | 
|                     if (palletCode.Substring(0, 1) == "6") | 
|                     { | 
|                         stockInfo.PalletType = PalletTypeEnum.MediumPallet.ObjToInt(); | 
|                     } | 
|                     else | 
|                     { | 
|                         stockInfo.PalletType = PalletTypeEnum.LargestPallet.ObjToInt(); | 
|                     } | 
|                 } | 
|   | 
|                 List<Dt_StockInfoDetail> stockInfoDetails = new List<Dt_StockInfoDetail>(); | 
|                 List<int> detailKeys = new List<int>(); | 
|                 foreach (var model in models) | 
|                 { | 
|                     if (purchaseOrderNos.FirstOrDefault(x => x == model.PurchaseOrderNo) == null) | 
|                     { | 
|                         return WebResponseContent.Instance.Error($"未在收货单明细中找到该采购单"); | 
|                     } | 
|   | 
|                     Dt_InboundOrderDetail? notGroupDetail = inboundOrderDetails.Where(x => x.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt() && x.OrderQuantity == model.Quantity && !detailKeys.Contains(x.Id) && x.OrderQuantity > x.ReceiptQuantity).FirstOrDefault(); | 
|   | 
|                     if (notGroupDetail == null) | 
|                     { | 
|                         return WebResponseContent.Instance.Error($"该物料在该入库单中已全部组盘完成"); | 
|                     } | 
|                     detailKeys.Add(notGroupDetail.Id); | 
|                     Dt_StockInfoDetail stockInfoDetail = new Dt_StockInfoDetail() | 
|                     { | 
|                         BatchNo = model.LotNo, | 
|                         MaterielCode = materielInfo.MaterielCode, | 
|                         MaterielName = materielInfo.MaterielName, | 
|                         OrderNo = inboundOrder.InboundOrderNo, | 
|                         SerialNumber = model.SerialNumber, | 
|                         StockQuantity = model.Quantity, | 
|                         OutboundQuantity = 0, | 
|                         Unit = materielInfo.MaterielUnit, | 
|                         Status = StockStatusEmun.组盘暂存.ObjToInt(), | 
|                         ProductionDate = model.ProductionDate, | 
|                         EffectiveDate = model.EffectiveDate, | 
|                         InboundOrderRowNo = notGroupDetail.RowNo, | 
|                     }; | 
|   | 
|                     if (stockInfo.Id > 0) | 
|                     { | 
|                         stockInfoDetail.StockId = stockInfo.Id; | 
|                     } | 
|                     stockInfo.Details.Add(stockInfoDetail); | 
|   | 
|                     stockInfoDetails.Add(stockInfoDetail); | 
|   | 
|                     notGroupDetail.ReceiptQuantity = model.Quantity; | 
|                     notGroupDetail.OrderDetailStatus = OrderDetailStatusEnum.GroupAndInbound.ObjToInt(); | 
|                 } | 
|   | 
|                 float totalQuantity = stockInfo.Details.Sum(x => x.StockQuantity); | 
|   | 
|                 inboundOrder.OrderStatus = InOrderStatusEnum.入库中.ObjToInt(); | 
|   | 
|                 _unitOfWorkManage.BeginTran(); | 
|                 if (stockInfo.Id == 0) | 
|                 { | 
|                     _stockRepository.StockInfoRepository.Db.InsertNav(stockInfo).Include(x => x.Details).ExecuteCommand(); | 
|                 } | 
|                 else | 
|                 { | 
|                     _stockRepository.StockInfoRepository.Db.UpdateNav(stockInfo).Include(x => x.Details, new UpdateNavOptions() { OneToManyInsertOrUpdate = true }).ExecuteCommand(); | 
|                 } | 
|                 _inboundRepository.InboundOrderDetailRepository.UpdateData(inboundOrderDetails); | 
|                 _inboundRepository.InboundOrderRepository.UpdateData(inboundOrder); | 
|                 _recordService.StockQuantityChangeRecordService.AddStockChangeRecord(stockInfo, stockInfoDetails, beforeQuantity, totalQuantity, StockChangeTypeEnum.MaterielGroup); | 
|                 _unitOfWorkManage.CommitTran(); | 
|                 content.OK(); | 
|             } | 
|             catch (Exception ex) | 
|             { | 
|                 _unitOfWorkManage.RollbackTran(); | 
|                 content.Error(ex.Message); | 
|             } | 
|             return content; | 
|         } | 
|   | 
|   | 
|         public WebResponseContent MaterielGroup(string palletCode, int Initiallife, int warehouseId, List<string> serNums) | 
|         { | 
|             WebResponseContent content = new WebResponseContent(); | 
|             try | 
|             { | 
|                 Dt_Warehouse warehouse = _warehouseService.Repository.QueryFirst(x => x.WarehouseId == warehouseId); | 
|                 if (warehouse == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到该仓库信息"); | 
|                 } | 
|   | 
|                 List<MatSerNumAnalysisModel> models = CodeAnalysisHelper.CodeAnalysis<MatSerNumAnalysisModel>(AnalysisCodeEnum.MatSerNumAnalysis, serNums); | 
|   | 
|                 if (models.Select(x => x.MaterielCode).Distinct().Count() > 1) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"物料不可混放"); | 
|                 } | 
|   | 
|                 string materielCode = models.FirstOrDefault()?.MaterielCode ?? ""; | 
|                 Dt_MaterielInfo materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterielCode == materielCode); | 
|                 if (materielInfo == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到该物料的信息"); | 
|                 } | 
|   | 
|                 float beforeQuantity = 0; | 
|   | 
|                 Dt_StockInfo stockInfo = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.PalletCode == palletCode).Includes(x => x.Details).First(); | 
|   | 
|                 if (stockInfo == null) | 
|                 { | 
|                     stockInfo = new Dt_StockInfo() | 
|                     { | 
|                         PalletCode = palletCode, | 
|                         StockStatus = StockStatusEmun.手动组盘暂存.ObjToInt(), | 
|                         WarehouseId = warehouse.WarehouseId, | 
|                         PalletType = GetPalletType(warehouse, palletCode), | 
|                         Details = new List<Dt_StockInfoDetail>() | 
|                     }; | 
|                 } | 
|                 else | 
|                 { | 
|                     if (stockInfo.StockStatus != StockStatusEmun.组盘暂存.ObjToInt() && stockInfo.StockStatus != StockStatusEmun.手动组盘暂存.ObjToInt()) | 
|                     { | 
|                         return WebResponseContent.Instance.Error($"托盘号重复"); | 
|                     } | 
|                     beforeQuantity = stockInfo.Details.Sum(x => x.StockQuantity); | 
|                 } | 
|   | 
|                 if (warehouse.WarehouseCode == WarehouseEnum.HA64.ToString()) | 
|                 { | 
|                     string batchNo = models.FirstOrDefault()?.LotNo ?? ""; | 
|                     Dt_StockInfoDetail existDetail = _stockRepository.StockInfoDetailRepository.QueryFirst(x => x.BatchNo == batchNo); | 
|                     if (existDetail != null) | 
|                     { | 
|                         return WebResponseContent.Instance.Error($"{batchNo}测试架已存在"); | 
|                     } | 
|                     if (models.Count >= 2) | 
|                     { | 
|                         return WebResponseContent.Instance.Error($"组盘明细不唯一"); | 
|                     } | 
|                     stockInfo.Remark = Initiallife.ToString(); | 
|                     if (palletCode.Substring(0, 1) == "6") | 
|                     { | 
|                         stockInfo.PalletType = PalletTypeEnum.MediumPallet.ObjToInt(); | 
|                     } | 
|                     else | 
|                     { | 
|                         stockInfo.PalletType = PalletTypeEnum.LargestPallet.ObjToInt(); | 
|                     } | 
|                 } | 
|   | 
|                 List<Dt_StockInfoDetail> stockInfoDetails = new List<Dt_StockInfoDetail>(); | 
|                 List<int> detailKeys = new List<int>(); | 
|                 foreach (var model in models) | 
|                 { | 
|                     Dt_StockInfoDetail stockInfoDetail = new Dt_StockInfoDetail() | 
|                     { | 
|                         BatchNo = model.LotNo, | 
|                         MaterielCode = materielInfo.MaterielCode, | 
|                         MaterielName = materielInfo.MaterielName, | 
|                         OrderNo = "", | 
|                         SerialNumber = model.SerialNumber, | 
|                         StockQuantity = model.Quantity, | 
|                         OutboundQuantity = 0, | 
|                         Unit = materielInfo.MaterielUnit, | 
|                         Status = StockStatusEmun.组盘暂存.ObjToInt(), | 
|                         ProductionDate = model.ProductionDate, | 
|                         EffectiveDate = model.EffectiveDate, | 
|                         InboundOrderRowNo = 0, | 
|                     }; | 
|   | 
|                     if (stockInfo.Id > 0) | 
|                     { | 
|                         stockInfoDetail.StockId = stockInfo.Id; | 
|                     } | 
|                     stockInfo.Details.Add(stockInfoDetail); | 
|   | 
|                     stockInfoDetails.Add(stockInfoDetail); | 
|                 } | 
|   | 
|                 float totalQuantity = stockInfo.Details.Sum(x => x.StockQuantity); | 
|   | 
|                 _unitOfWorkManage.BeginTran(); | 
|                 if (stockInfo.Id == 0) | 
|                 { | 
|                     _stockRepository.StockInfoRepository.Db.InsertNav(stockInfo).Include(x => x.Details).ExecuteCommand(); | 
|                 } | 
|                 else | 
|                 { | 
|                     _stockRepository.StockInfoRepository.Db.UpdateNav(stockInfo).Include(x => x.Details, new UpdateNavOptions() { OneToManyInsertOrUpdate = true }).ExecuteCommand(); | 
|                 } | 
|                 _recordService.StockQuantityChangeRecordService.AddStockChangeRecord(stockInfo, stockInfoDetails, beforeQuantity, totalQuantity, StockChangeTypeEnum.MaterielGroup); | 
|                 _unitOfWorkManage.CommitTran(); | 
|                 content.OK(); | 
|             } | 
|             catch (Exception ex) | 
|             { | 
|                 _unitOfWorkManage.RollbackTran(); | 
|                 content.Error(ex.Message); | 
|             } | 
|             return content; | 
|         } | 
|         /// <summary> | 
|         /// 入库完成上报ERP | 
|         /// </summary> | 
|         /// <returns></returns> | 
|         public WebResponseContent FeedbackInboundOrder(Dt_InboundOrder inboundOrder) | 
|         { | 
|             WebResponseContent content = new WebResponseContent(); | 
|             try | 
|             { | 
|                 if (inboundOrder.Details.Count == 0) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到入库单明细信息"); | 
|                 } | 
|   | 
|                 List<Dt_StockInfoDetail> stockInfoDetails = _stockRepository.StockInfoDetailRepository.QueryData(x => x.OrderNo == inboundOrder.InboundOrderNo); | 
|                 if (stockInfoDetails.Count == 0) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到库存明细信息"); | 
|                 } | 
|                 //获取该入库单所有库存 | 
|                 List<Dt_StockInfo> stockInfos = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => stockInfoDetails.GroupBy(x => x.StockId).Select(x => x.Key).Contains(x.Id)).Includes(x => x.Details).ToList(); | 
|                 Dt_Warehouse warehouse = _warehouseService.Repository.QueryFirst(x => x.WarehouseId == inboundOrder.WarehouseId); | 
|                 if (warehouse == null) | 
|                 { | 
|                     return WebResponseContent.Instance.Error($"未找到仓库信息"); | 
|                 } | 
|                 List<ERPInboundDetailModel>? detailModels = new List<ERPInboundDetailModel>(); | 
|                 foreach (var stockInfo in stockInfos) | 
|                 { | 
|                     foreach (var item in stockInfo.Details.GroupBy(x => x.InboundOrderRowNo).Select(x => x.Key)) | 
|                     { | 
|                         //区分不同批次 | 
|                         Dt_StockInfoDetail? dt_StockInfoDetail = stockInfo.Details.Where(x => x.InboundOrderRowNo == item).FirstOrDefault(); | 
|                         ERPInboundDetailModel detailModel = new ERPInboundDetailModel() | 
|                         { | 
|                             ExpiryDate = dt_StockInfoDetail?.EffectiveDate ?? "", | 
|                             LocationCode = warehouse.WarehouseCode, | 
|                             MaterialsCode = dt_StockInfoDetail.MaterielCode, | 
|                             MfgDate = dt_StockInfoDetail.ProductionDate ?? "", | 
|                             QtyCustoms = "0", | 
|                             Quantity = stockInfo.Details.Where(x => x.InboundOrderRowNo == item).Sum(x => x.StockQuantity).ToString(), | 
|                             Rack = stockInfo.LocationCode, | 
|                             ReceiptCode = inboundOrder.UpperOrderNo, | 
|                             ReceiptSerNo = item.ToString() | 
|                         }; | 
|                         detailModels.Add(detailModel); | 
|                     } | 
|                 } | 
|                 ERPInboundModel model = new ERPInboundModel() | 
|                 { | 
|                     Code = CreateCodeByRule(nameof(RuleCodeEnum.RLCodeRule)), | 
|                     CreatorCode = inboundOrder.Creater, | 
|                     EntDate = inboundOrder.CreateDate.ToString("yyyy-MM-dd HH:mm:ss"), | 
|                     StockDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), | 
|                     SuppliersId = inboundOrder.SupplierId, | 
|                     Type = "S", | 
|                     UniqueTag = inboundOrder.Id.ToString(), | 
|                     WarehouseCode = warehouse.WarehouseCode, | 
|                     Way = 1, | 
|                     Details = detailModels | 
|                 }; | 
|                 //推送ERP | 
|                 _invokeERPService.InvokeInboundOrderApi(model); | 
|                 return WebResponseContent.Instance.OK(); | 
|             } | 
|             catch (Exception ex) | 
|             { | 
|                 _unitOfWorkManage.RollbackTran(); | 
|                 content.Error(ex.Message); | 
|             } | 
|             return content; | 
|         } | 
|         static object lock_code = new object(); | 
|         public string CreateCodeByRule(string ruleCode) | 
|         { | 
|             lock (lock_code) | 
|             { | 
|   | 
|                 string code = string.Empty; | 
|                 DateTime dateTime = DateTime.Now; | 
|                 DateTime now = DateTime.Now; | 
|                 try | 
|                 { | 
|                     if (string.IsNullOrEmpty(ruleCode)) | 
|                         throw new ArgumentNullException(nameof(ruleCode)); | 
|                     SqlSugarClient sugarClient = new SqlSugarClient(new ConnectionConfig | 
|                     { | 
|                         IsAutoCloseConnection = true, | 
|                         DbType = DbType.SqlServer, | 
|                         ConnectionString = DBContext.ConnectionString | 
|                     }); | 
|                     Dt_CodeRuleConfig codeRuleConfig = sugarClient.Queryable<Dt_CodeRuleConfig>().Where(x => x.RuleCode == ruleCode).First(); | 
|                     if (codeRuleConfig == null) | 
|                         throw new ArgumentNullException(nameof(codeRuleConfig)); | 
|                     if (codeRuleConfig.ModifyDate != null) | 
|                     { | 
|                         dateTime = Convert.ToDateTime(codeRuleConfig.ModifyDate); | 
|                     } | 
|                     else | 
|                     { | 
|                         dateTime = Convert.ToDateTime(codeRuleConfig.CreateDate); | 
|                     } | 
|   | 
|                     if (now.Year == dateTime.Year && now.Month == dateTime.Month && now.Day == dateTime.Day) | 
|                     { | 
|                         now = dateTime; | 
|                         codeRuleConfig.CurrentVal = Convert.ToInt32(codeRuleConfig.CurrentVal) + 1; | 
|                     } | 
|                     else | 
|                     { | 
|                         codeRuleConfig.CurrentVal = 1; | 
|                     } | 
|                     codeRuleConfig.ModifyDate = DateTime.Now; | 
|                     code = codeRuleConfig.Format; | 
|                     code = code.Replace($"[{CodeFormatTypeEnum.YYYY}]", now.Year.ToString().PadLeft(4, '0')); | 
|                     code = code.Replace($"[{CodeFormatTypeEnum.MM}]", now.Month.ToString().PadLeft(2, '0')); | 
|                     code = code.Replace($"[{CodeFormatTypeEnum.DD}]", now.Day.ToString().PadLeft(2, '0')); | 
|                     code = code.Replace($"[{CodeFormatTypeEnum.ST}]", codeRuleConfig.StartStr?.ToString() ?? ""); | 
|                     code = code.Replace($"[{CodeFormatTypeEnum.NUM}]", codeRuleConfig.CurrentVal.ToString().PadLeft(codeRuleConfig.Length, '0')); | 
|                     Dictionary<string, object> keyValuePairs = new Dictionary<string, object>() { { nameof(codeRuleConfig.CurrentVal), codeRuleConfig.CurrentVal }, { nameof(codeRuleConfig.Id), codeRuleConfig.Id }, { nameof(codeRuleConfig.ModifyDate), DateTime.Now } }; | 
|                     sugarClient.Updateable(keyValuePairs).AS(MainDb.CodeRuleConfig).WhereColumns(nameof(codeRuleConfig.Id)).ExecuteCommand(); | 
|                     sugarClient.Updateable(codeRuleConfig); | 
|   | 
|                 } | 
|                 catch (Exception ex) | 
|                 { | 
|   | 
|                 } | 
|                 return code; | 
|             } | 
|         } | 
|   | 
|         /// <summary> | 
|         /// 入库完成回传到ERP | 
|         /// </summary> | 
|         /// <param name="id"></param> | 
|         /// <returns></returns> | 
|         //public WebResponseContent FeedbackInboundOrder(int id) | 
|         //{ | 
|         //    try | 
|         //    { | 
|         //        Dt_InboundOrder inboundOrder = Db.Queryable<Dt_InboundOrder>().Where(x => x.Id == id).Includes(x => x.Details).First(); | 
|         //        if (inboundOrder == null) | 
|         //        { | 
|         //            return WebResponseContent.Instance.Error($"未找到入库单信息"); | 
|         //        } | 
|         //        if (inboundOrder.Details == null || inboundOrder.Details.Count == 0) | 
|         //        { | 
|         //            return WebResponseContent.Instance.Error($"未找到入库单明细信息"); | 
|         //        } | 
|         //        if (inboundOrder.OrderStatus == InOrderStatusEnum.入库完成.ObjToInt()) | 
|         //        { | 
|         //            return WebResponseContent.Instance.Error($"入库单据已完成"); | 
|         //        } | 
|   | 
|         //        List<Dt_StockInfo> stockInfos = Db.Queryable<Dt_StockInfo>().Where(x => x.Details.Any(v => v.OrderNo == inboundOrder.InboundOrderNo)).Includes(x => x.Details).ToList(); | 
|         //        List<Dt_Warehouse> warehouses = Db.Queryable<Dt_Warehouse>().ToList(); | 
|   | 
|         //        List<ERPInboundDetailModel> detailModels = new List<ERPInboundDetailModel>(); | 
|         //        foreach (var item in inboundOrder.Details) | 
|         //        { | 
|         //            Dt_StockInfo? stockInfo = stockInfos.FirstOrDefault(x => x.Details.Any(v => v.InboundOrderRowNo == item.RowNo && v.MaterielCode == item.MaterielCode)); | 
|         //            if (stockInfo == null) | 
|         //            { | 
|         //                return WebResponseContent.Instance.Error($"未找到库存信息"); | 
|         //            } | 
|   | 
|         //            Dt_Warehouse? warehouse = warehouses.FirstOrDefault(x => x.WarehouseId == stockInfo.WarehouseId); | 
|         //            if (warehouse == null) | 
|         //            { | 
|         //                return WebResponseContent.Instance.Error($"未找到仓库信息"); | 
|         //            } | 
|   | 
|         //            ERPInboundDetailModel detailModel = new ERPInboundDetailModel() | 
|         //            { | 
|         //                ExpiryDate = stockInfo.Details.FirstOrDefault()?.EffectiveDate ?? "", | 
|         //                LocationCode = warehouse.WarehouseCode, | 
|         //                MaterialsCode = item.MaterielCode, | 
|         //                MfgDate = stockInfo.Details.FirstOrDefault()?.ProductionDate ?? "", | 
|         //                QtyCustoms = "0", | 
|         //                Quantity = stockInfo.Details.Sum(x => x.StockQuantity).ToString(), | 
|         //                Rack = stockInfo.LocationCode, | 
|         //                ReceiptCode = inboundOrder.UpperOrderNo, | 
|         //                ReceiptSerNo = item.RowNo.ToString() | 
|         //            }; | 
|         //            detailModels.Add(detailModel); | 
|         //        } | 
|         //        Dt_Warehouse? warehouse2 = warehouses.FirstOrDefault(x => x.WarehouseId == inboundOrder.WarehouseId); | 
|         //        if (warehouse2 == null) | 
|         //        { | 
|         //            return WebResponseContent.Instance.Error($"未找到仓库信息"); | 
|         //        } | 
|         //        ERPInboundModel model = new ERPInboundModel() | 
|         //        { | 
|         //            Code = inboundOrder.InboundOrderNo, | 
|         //            CreatorCode = inboundOrder.Creater,//测试 | 
|         //            EntDate = inboundOrder.CreateDate.ToString("yyyy-MM-dd HH:mm:ss"), | 
|         //            StockDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), | 
|         //            SuppliersId = inboundOrder.SupplierId, | 
|         //            Type = "S", | 
|         //            UniqueTag = inboundOrder.Id.ToString(), | 
|         //            WarehouseCode = warehouse2.WarehouseCode, | 
|         //            Way = 1, | 
|         //            Details = detailModels | 
|         //        }; | 
|         //        //测试注释 | 
|         //        _invokeERPService.InvokeInboundOrderApi(model); | 
|         //        return WebResponseContent.Instance.OK(); | 
|         //    } | 
|         //    catch (Exception ex) | 
|         //    { | 
|         //        return WebResponseContent.Instance.Error(ex.Message); | 
|         //    } | 
|         //} | 
|   | 
|         public int GetPalletType(Dt_Warehouse warehouse, string palletCode) | 
|         { | 
|             if (warehouse.WarehouseCode == WarehouseEnum.HA64.ToString()) | 
|             { | 
|                 if (palletCode.Substring(0, 1) == "6") | 
|                 { | 
|                     return PalletTypeEnum.MediumPallet.ObjToInt(); | 
|                 } | 
|                 else | 
|                 { | 
|                     return PalletTypeEnum.LargestPallet.ObjToInt(); | 
|                 } | 
|             } | 
|             else if (warehouse.WarehouseCode == WarehouseEnum.HA153.ObjToString()) | 
|             { | 
|                 Dt_PalletTypeInfo palletTypeInfo = _palletTypeInfoRepository.QueryFirst(x => x.CodeStartStr == palletCode.Substring(0, 1)); | 
|                 if (palletTypeInfo == null) | 
|                 { | 
|                     throw new Exception($"托盘号错误"); | 
|                 } | 
|                 return palletTypeInfo.PalletType; | 
|             } | 
|             else if (warehouse.WarehouseCode == WarehouseEnum.HA152.ObjToString()) | 
|             { | 
|                 Dt_PalletTypeInfo palletTypeInfo = _palletTypeInfoRepository.QueryFirst(x => x.CodeStartStr == palletCode.Substring(0, 2)); | 
|                 if (palletTypeInfo == null) | 
|                 { | 
|                     throw new Exception($"托盘号错误"); | 
|                 } | 
|                 return palletTypeInfo.PalletType; | 
|             } | 
|             else if (warehouse.WarehouseCode == WarehouseEnum.HA57.ObjToString()) | 
|             { | 
|                 Dt_PalletTypeInfo palletTypeInfo = _palletTypeInfoRepository.QueryFirst(x => x.CodeStartStr == palletCode.Substring(0, 3)); | 
|                 if (palletTypeInfo == null) | 
|                 { | 
|                     throw new Exception($"托盘号错误"); | 
|                 } | 
|                 return palletTypeInfo.PalletType; | 
|             } | 
|             return -1; | 
|         } | 
|     } | 
| } |