using AutoMapper; using MailKit.Search; using SqlSugar; using System; using System.Collections.Generic; using System.Linq; using System.Reflection.Metadata; using System.Text; using System.Threading.Tasks; using WIDESEA_Common; using WIDESEA_Core; using WIDESEA_Core.BaseRepository; using WIDESEA_Core.BaseServices; using WIDESEA_Core.Enums; using WIDESEA_Core.Helper; using WIDESEA_Core.Utilities; using WIDESEA_DTO; using WIDESEA_DTO.Inbound; using WIDESEA_DTO.Outbound; using WIDESEA_IBasicService; using WIDESEA_IInboundRepository; using WIDESEA_IInboundService; using WIDESEA_IStockService; using WIDESEA_ITaskInfoRepository; using WIDESEA_Model.Models; using static WIDESEA_Common.HouseInventoryIn; namespace WIDESEA_InboundService { public partial class InboundOrderService : ServiceBase, IInboundOrderService { private readonly IMapper _mapper; private readonly IUnitOfWorkManage _unitOfWorkManage; private readonly ITaskRepository _taskRepository; private IBasicService _basicService; private IStockService _stockService; private IInboundOrderDetailService _inboundOrderDetailService; private IInboundOrder_HtyService _inboundOrderHtyService; private IInboundOrderDetail_HtyService _inboundOrderDetail_HtyService; public IInboundOrderRepository Repository => BaseDal; public InboundOrderService(IInboundOrderRepository BaseDal, IMapper mapper, IUnitOfWorkManage unitOfWorkManage, ITaskRepository taskRepository, IBasicService basicService, IStockService stockService, IInboundOrderDetailService inboundOrderDetailService, IInboundOrder_HtyService inboundOrderHtyService, IInboundOrderDetail_HtyService inboundOrderDetail_HtyService) : base(BaseDal) { _mapper = mapper; _unitOfWorkManage = unitOfWorkManage; _taskRepository = taskRepository; _basicService = basicService; _stockService = stockService; _inboundOrderDetailService = inboundOrderDetailService; _inboundOrderHtyService = inboundOrderHtyService; _inboundOrderDetail_HtyService = inboundOrderDetail_HtyService; } /// /// 添加单据 /// /// /// public override WebResponseContent AddData(SaveModel saveModel) { InboundOrderAddDTO orderAddDTO = saveModel.MainData.DicToModel(); orderAddDTO.Details = saveModel.DetailData.DicToIEnumerable(); return AddInboundOrder(orderAddDTO); } /// /// 添加单据 /// /// 单据添加DTO /// public WebResponseContent AddInboundOrder(InboundOrderAddDTO orderAddDTO) { WebResponseContent content = new(); try { #region 验证数据 (bool, string, object?) result = CheckInboundOrderAddData(orderAddDTO); if (!result.Item1) return content = WebResponseContent.Instance.Error(result.Item2); #endregion Dt_InboundOrder inboundOrder = _mapper.Map(orderAddDTO); inboundOrder.OrderStatus = InboundStatusEnum.未开始.ObjToInt(); bool a = BaseDal.Db.InsertNav(inboundOrder).Include(x => x.Details).ExecuteCommand(); content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } finally { } return content; } /// /// 入库单据下发 /// /// /// public WebResponseContent AddInboundOrders(HouseInbound orderAddDTO) { WebResponseContent content = new(); try { InboundOrderAddDTO orderAddDTO1 = new InboundOrderAddDTO(); orderAddDTO1.OrderNo = orderAddDTO.AsnNo; orderAddDTO1.UpperOrderNo = orderAddDTO.AsnNo; orderAddDTO1.OutWareHouse = orderAddDTO.InWarehouse; orderAddDTO1.TransactionCode = orderAddDTO.TransactionCode; orderAddDTO1.InoutType = orderAddDTO.OrderType; orderAddDTO1.OrderType = orderAddDTO.InoutType.ObjToInt(); orderAddDTO1.Details = orderAddDTO.DetailList.DicToIEnumerable(); #region 验证数据 (bool, string, object?) result = CheckInboundOrderAddData(orderAddDTO1); if (!result.Item1) return content = WebResponseContent.Instance.Error(result.Item2); #endregion Dt_InboundOrder inboundOrder = _mapper.Map(orderAddDTO1); inboundOrder.OrderStatus = InboundStatusEnum.未开始.ObjToInt(); inboundOrder.Creater = "WMS"; inboundOrder.CreateDate = DateTime.Now; bool a = BaseDal.Db.InsertNav(inboundOrder).Include(x => x.Details).ExecuteCommand(); content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } finally { } return content; } /// /// 盘点入库 /// /// public WebResponseContent InventoryIn(string name) { WebResponseContent content = new(); try { //Dt_StockInfoDetail stockInfoDetail = _stockService.StockInfoDetailService.Repository.QueryFirst(x => x.OrderNo == name); ////Dt_OutboundOrderDetail outboundOrderDetail= //HouseInventoryIn houseInventoryIn1 = new HouseInventoryIn(); //houseInventoryIn1.No = name; //InventoryIn inventoryIn = new InventoryIn(); //inventoryIn.LinId = stockInfoDetail.LinId; ////inventoryIn.LPN_No =stockInfoDetail. //inventoryIn.MaterielCode = stockInfoDetail.MaterielCode; //inventoryIn.OrderQuantity = stockInfoDetail.StockQuantity; //inventoryIn.BatchNo = stockInfoDetail.BatchNo; //inventoryIn.FinishQty = stockInfoDetail.FinishQty; //inventoryIn.WarehouseCode = // inventoryIn.StorageAreaCode = // inventoryIn.StorageLocationCode = // #region 验证数据 //(bool, string, object ?) result = CheckInboundOrderAddData(orderAddDTO1); // if (!result.Item1) return content = WebResponseContent.Instance.Error(result.Item2); // #endregion // Dt_OutboundOrder inboundOrder = _mapper.Map(orderAddDTO1); // inboundOrder.OrderStatus = InboundStatusEnum.未开始.ObjToInt(); // inboundOrder.OrderType = OutOrderTypeEnum.OutInventory.ObjToInt(); // inboundOrder.Creater = "WMS"; // inboundOrder.CreateDate = DateTime.Now; // bool a = BaseDal.Db.InsertNav(inboundOrder).Include(x => x.Details).ExecuteCommand(); content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } finally { } return content; } /// /// 入库取消 /// /// /// public WebResponseContent CancelIn(HouseCancelIn houseCancelIn) { WebResponseContent content = new(); try { InboundOrderAddDTO orderAddDTO1 = new InboundOrderAddDTO(); orderAddDTO1.OrderNo = houseCancelIn.AsnNo; orderAddDTO1.Details = houseCancelIn.DetailList.DicToIEnumerable(); Dt_InboundOrder oldOutboundOrder = BaseDal.Db.Queryable().Where(x => x.OrderNo == orderAddDTO1.OrderNo).Includes(x => x.Details).First(); Dt_InboundOrderDetail dt_InboundOrderDetail = BaseDal.Db.Queryable().Where(x => x.OrderId == oldOutboundOrder.Id).First(); if (oldOutboundOrder.OrderStatus != InboundStatusEnum.未开始.ObjToInt()) { return WebResponseContent.Instance.Error("该入库单任务已开始执行,不可取消"); } oldOutboundOrder.OrderStatus = InboundStatusEnum.取消.ObjToInt(); BaseDal.UpdateData(oldOutboundOrder); Dt_InboundOrder_Hty inboundOrder_Hty = new Dt_InboundOrder_Hty { OrderStatus = oldOutboundOrder.OrderStatus, CreateType = oldOutboundOrder.CreateType, //SourceId = oldOutboundOrder.SourceId, UpperOrderNo = oldOutboundOrder.UpperOrderNo, OrderNo = oldOutboundOrder.OrderNo, OutWareHouse = oldOutboundOrder.OutWareHouse, TransactionCode = oldOutboundOrder.TransactionCode, InoutType = oldOutboundOrder.InoutType, OrderType = oldOutboundOrder.OrderType, Creater = "WMS", CreateDate = DateTime.Now, }; _inboundOrderHtyService.AddData(inboundOrder_Hty); foreach (var item in oldOutboundOrder.Details) { Dt_InboundOrderDetail_Hty dt_InboundOrderDetail_Hty = new Dt_InboundOrderDetail_Hty { OrderId = dt_InboundOrderDetail.OrderId, MaterielCode = dt_InboundOrderDetail.MaterielCode, MaterielName = dt_InboundOrderDetail.MaterielName, BatchNo = dt_InboundOrderDetail.BatchNo, OrderQuantity = dt_InboundOrderDetail.OrderQuantity, ReceiptQuantity = dt_InboundOrderDetail.ReceiptQuantity, OverInQuantity = dt_InboundOrderDetail.OverInQuantity, OrderDetailStatus = dt_InboundOrderDetail.OrderDetailStatus, Creater = "WMS", CreateDate = DateTime.Now, }; _inboundOrderDetail_HtyService.AddData(dt_InboundOrderDetail_Hty); _inboundOrderDetailService.DeleteData(item); } BaseDal.DeleteData(oldOutboundOrder); //inboundOrder_Hty.Details = oldOutboundOrder.Details; //#region 验证数据 //(bool, string, object?) result = CheckInboundOrderAddData(orderAddDTO1); //#endregion //Dt_InboundOrder inboundOrder = _mapper.Map(orderAddDTO1); //inboundOrder.OrderStatus = InboundStatusEnum.未开始.ObjToInt(); //inboundOrder.OrderType = OutOrderTypeEnum.OutInventory.ObjToInt(); //inboundOrder.Creater = "WMS"; //inboundOrder.CreateDate = DateTime.Now; //bool a = BaseDal.Db.InsertNav(inboundOrder).Include(x => x.Details).ExecuteCommand(); content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } finally { } return content; } /// /// 验证单据添加DTO对象 /// /// 单据添加DTO /// private (bool, string, object?) CheckInboundOrderAddData(InboundOrderAddDTO inboundOrderAddDTO) { (bool, string, object?) result1 = ModelValidate.ValidateModelData(inboundOrderAddDTO); if (!result1.Item1) return result1; (bool, string, object?) result2 = ModelValidate.ValidateModelData(inboundOrderAddDTO.Details); if (!result2.Item1) return result2; IEnumerable inOrderTypes = Enum.GetValues().Cast(); if (!inOrderTypes.Contains(inboundOrderAddDTO.OrderType)) { return (false, "未找到该单据类型", inboundOrderAddDTO); } List materielCodes = inboundOrderAddDTO.Details.Select(x => x.MaterielCode).ToList(); if (!_basicService.MaterielInfoService.ExsitMateriels(materielCodes)) { return (false, "有物料信息未录入,请录入物料信息", inboundOrderAddDTO); } if (BaseDal.QueryFirst(x => x.OrderName == inboundOrderAddDTO.orderName && !string.IsNullOrEmpty(x.OrderName)) != null) { return (false, "单据已存在", inboundOrderAddDTO); } return (true, "成功", inboundOrderAddDTO); } } }