using AutoMapper; using Newtonsoft.Json; using Newtonsoft.Json.Serialization; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using WIDESEA_Common; using WIDESEA_Core; using WIDESEA_Core.BaseServices; using WIDESEA_Core.Enums; using WIDESEA_Core.Helper; using WIDESEA_Core.Utilities; using WIDESEA_DTO.Inbound; using WIDESEA_DTO.Outbound; using WIDESEA_DTO.Stock; using WIDESEA_IBasicService; using WIDESEA_IOutboundRepository; using WIDESEA_IOutboundService; using WIDESEA_IStockService; //using WIDESEA_ITaskInfoRepository; //using WIDESEA_ITaskInfoService; using WIDESEA_Model.Models; namespace WIDESEA_OutboundService { public partial class OutboundOrderService : ServiceBase, IOutboundOrderService { private readonly IMapper _mapper; private readonly IMaterielInfoService _materielInfoService; private readonly IStockInfoService _stockService; private readonly IStockInfoDetailService _stockDetailService; private readonly IOutboundOrder_HtyService _outboundOrder_HtyService; private readonly IOutboundOrderDetail_HtyService _outboundOrderDetail_HtyService; private readonly IOutboundOrderDetailService _outboundOrderDetailService; //private readonly ITaskService _taskService; public IOutboundOrderRepository Repository => BaseDal; public OutboundOrderService(IOutboundOrderRepository BaseDal, IMapper mapper, IMaterielInfoService materielInfoService, IOutboundOrderDetailService outboundOrderDetailService, IOutboundOrder_HtyService outboundOrder_HtyService, IOutboundOrderDetail_HtyService outboundOrderDetail_HtyService, IStockInfoDetailService stockDetailService, IStockInfoService stockInfoService) : base(BaseDal) { _mapper = mapper; _materielInfoService = materielInfoService; _stockDetailService = stockDetailService; _stockService = stockInfoService; _outboundOrder_HtyService = outboundOrder_HtyService; _outboundOrderDetail_HtyService = outboundOrderDetail_HtyService; _outboundOrderDetailService = outboundOrderDetailService; //_taskService = taskService; } public override WebResponseContent AddData(SaveModel saveModel) { OutboundOrderAddDTO outboundOrder = saveModel.MainData.DicToModel(); List orderDetailAddDTOs = saveModel.DetailData.DicToIEnumerable(); outboundOrder.Details = orderDetailAddDTOs.GroupBy(x => x.MaterielCode).Select(x => new OutboundOrderDetailAddDTO { BatchNo = x.FirstOrDefault()?.BatchNo ?? "", MaterielCode = x.Key, OrderQuantity = x.Sum(x => x.OrderQuantity), Remark = x.FirstOrDefault(v => !string.IsNullOrEmpty(v.Remark))?.Remark ?? "" }).ToList(); return AddOutboundOrder(outboundOrder); } public override WebResponseContent UpdateData(SaveModel saveModel) { List outboundOrderDetails = saveModel.DetailData.DicToIEnumerable(); if (outboundOrderDetails.GroupBy(x => x.MaterielCode).Select(x => x.Count()).Any(x => x > 1)) { return WebResponseContent.Instance.Error("物料重复"); } outboundOrderDetails = outboundOrderDetails.Where(x => (x.Id > 0 && x.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt()) || x.Id == 0).ToList(); List> dics = new List>(); JsonSerializerSettings settings = new JsonSerializerSettings(); settings.ContractResolver = new CamelCasePropertyNamesContractResolver(); foreach (var item in outboundOrderDetails) { string str = JsonConvert.SerializeObject(item, settings); Dictionary? dic = JsonConvert.DeserializeObject>(str); if (dic != null) dics.Add(dic); } saveModel.DetailData = dics; return base.UpdateData(saveModel); } public WebResponseContent AddOutboundOrder(OutboundOrderAddDTO orderAddDTO) { WebResponseContent content = new(); try { #region 验证数据 (bool, string, object?) result = CheckOutboundOrderAddData(orderAddDTO); if (!result.Item1) return content = WebResponseContent.Instance.Error(result.Item2); #endregion Dt_OutboundOrder outboundOrder = _mapper.Map(orderAddDTO); outboundOrder.OrderStatus = InboundStatusEnum.未开始.ObjToInt(); bool a = BaseDal.Db.InsertNav(outboundOrder).Include(x => x.Details).ExecuteCommand(); content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } finally { } return content; } //public WebResponseContent AddOutboundOrders(Houseounbound orderAddDTO) //{ // WebResponseContent content = new(); // try // { // OutboundOrderAddDTO orderAddDTO1 = new OutboundOrderAddDTO(); // orderAddDTO1.OrderNo = orderAddDTO.No; // orderAddDTO1.UpperOrderNo = orderAddDTO.No; // orderAddDTO1.OutWareHouse = orderAddDTO.OutWareHouse; // orderAddDTO1.TransactionCode = orderAddDTO.TransactionCode; // orderAddDTO1.OrderType = orderAddDTO.InoutType.ObjToInt(); // orderAddDTO1.Details = orderAddDTO.DetailList.DicToIEnumerable(); // #region 验证数据 // (bool, string, object?) result = CheckOutboundOrderAddData(orderAddDTO1); // if (!result.Item1) return content = WebResponseContent.Instance.Error(result.Item2); // #endregion // Dt_OutboundOrder 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 CancelOut(HouseCancelOut houseCancelOut) { WebResponseContent content = new(); try { OutboundOrderAddDTO orderAddDTO1 = new OutboundOrderAddDTO(); orderAddDTO1.OrderNo = houseCancelOut.No; orderAddDTO1.Details = houseCancelOut.DetailList.DicToIEnumerable(); Dt_OutboundOrder oldOutboundOrder = BaseDal.Db.Queryable().Where(x => x.OrderNo == orderAddDTO1.OrderNo).Includes(x => x.Details).First(); Dt_OutboundOrderDetail OutboundOrderDetail = BaseDal.Db.Queryable().Where(x => x.OrderId == oldOutboundOrder.Id).First(); if (oldOutboundOrder == null) { return WebResponseContent.Instance.Error("未找到此出库单据"); } if (oldOutboundOrder.OrderStatus != InboundStatusEnum.未开始.ObjToInt()) { return WebResponseContent.Instance.Error("该入库单任务已开始执行,不可取消"); } oldOutboundOrder.OrderStatus = InboundStatusEnum.取消.ObjToInt(); BaseDal.UpdateData(oldOutboundOrder); Dt_OutboundOrder_Hty inboundOrder_Hty = new Dt_OutboundOrder_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, }; _outboundOrder_HtyService.AddData(inboundOrder_Hty); foreach (var item in oldOutboundOrder.Details) { Dt_OutboundOrderDetail_Hty dt_InboundOrderDetail_Hty = new Dt_OutboundOrderDetail_Hty { OrderId = OutboundOrderDetail.OrderId, MaterielCode = OutboundOrderDetail.MaterielCode, MaterielName = OutboundOrderDetail.MaterielName, BatchNo = OutboundOrderDetail.BatchNo, OrderQuantity = OutboundOrderDetail.OrderQuantity, OrderDetailStatus = OutboundOrderDetail.OrderDetailStatus, Creater = "WMS", CreateDate = DateTime.Now, }; _outboundOrderDetail_HtyService.AddData(dt_InboundOrderDetail_Hty); _outboundOrderDetailService.DeleteData(item); } BaseDal.DeleteData(oldOutboundOrder); content = WebResponseContent.Instance.OK(); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } finally { } return content; } private (bool, string, object?) CheckOutboundOrderAddData(OutboundOrderAddDTO outboundOrderAddDTO) { (bool, string, object?) result1 = ModelValidate.ValidateModelData(outboundOrderAddDTO); if (!result1.Item1) return result1; (bool, string, object?) result2 = ModelValidate.ValidateModelData(outboundOrderAddDTO.Details); if (!result2.Item1) return result2; IEnumerable inOrderTypes = Enum.GetValues().Cast(); if (!inOrderTypes.Contains(outboundOrderAddDTO.OrderType)) { return (false, "未找到该单据类型", outboundOrderAddDTO); } List materielCodes = outboundOrderAddDTO.Details.Select(x => x.MaterielCode).ToList(); if (!_materielInfoService.ExsitMateriels(materielCodes)) { return (false, "有物料信息未录入,请录入物料信息", outboundOrderAddDTO); } if (BaseDal.QueryFirst(x => x.UpperOrderNo == outboundOrderAddDTO.UpperOrderNo && !string.IsNullOrEmpty(x.UpperOrderNo)) != null) { return (false, "单据已存在", outboundOrderAddDTO); } return (true, "成功", outboundOrderAddDTO); } public WebResponseContent ReleaseOutOrder(int orderId) { WebResponseContent content = new WebResponseContent(); try { } catch (Exception ex) { } return content; } } }