using AutoMapper;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_BasicRepository;
|
using WIDESEA_Common.MaterielEnum;
|
using WIDESEA_Common.OrderEnum;
|
using WIDESEA_Common.WareHouseEnum;
|
using WIDESEA_Core;
|
using WIDESEA_Core.BaseRepository;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_Core.Enums;
|
using WIDESEA_Core.Helper;
|
using WIDESEA_DTO;
|
using WIDESEA_DTO.ERP;
|
using WIDESEA_IBasicRepository;
|
using WIDESEA_IInboundRepository;
|
using WIDESEA_IInboundService;
|
using WIDESEA_InboundRepository;
|
using WIDESEA_Model.Models;
|
|
namespace WIDESEA_InboundService
|
{
|
public class PurchaseBSTOrderService : ServiceBase<Dt_PurchaseBSTOrder, IPurchaseBSTOrderRepository>, IPurchaseBSTOrderService
|
{
|
private readonly IUnitOfWorkManage _unitOfWorkManage;
|
public IPurchaseBSTOrderRepository Repository => BaseDal;
|
public IPurchaseBSTOrderDetailRepository _purchaseBSTOrderDetailRepository;
|
private readonly IBasicRepository _basicRepository;
|
private readonly ISupplierInfoRepository _supplierInfoRepository;
|
private readonly IMaterielInfoRepository _materielInfoRepository;
|
private readonly IMapper _mapper;
|
|
public PurchaseBSTOrderService(IPurchaseBSTOrderRepository BaseDal, IUnitOfWorkManage unitOfWorkManage, IBasicRepository basicRepository, ISupplierInfoRepository supplierInfoRepository, IMaterielInfoRepository materielInfoRepository, IPurchaseBSTOrderDetailRepository purchaseBSTOrderDetailRepository,IMapper mapper) : base(BaseDal)
|
{
|
_unitOfWorkManage = unitOfWorkManage;
|
_basicRepository = basicRepository;
|
_supplierInfoRepository = supplierInfoRepository;
|
_materielInfoRepository = materielInfoRepository;
|
_purchaseBSTOrderDetailRepository = purchaseBSTOrderDetailRepository;
|
_mapper = mapper;
|
}
|
/// <summary>
|
/// 添加老厂采购单信息
|
/// </summary>
|
/// <returns></returns>
|
public WebResponseContent AddPurchaseBSTOrder(List<BSTPurchaseOrderDTO> bSTPurchaseOrderDTOs)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
List<Dt_PurchaseBSTOrder> OldpurchaseBSTOrders = BaseDal.Db.Queryable<Dt_PurchaseBSTOrder>().Includes(x=>x.Details).ToList();
|
//新增
|
List<BSTPurchaseOrderDTO> bSTPurchaseOrderDTOsAdd = bSTPurchaseOrderDTOs.Where(x => x.Way == 1).ToList();
|
//修改
|
List<BSTPurchaseOrderDTO> bSTPurchaseOrderDTOsUpdate = bSTPurchaseOrderDTOs.Where(x => x.Way == 2).ToList();
|
//删除
|
List<BSTPurchaseOrderDTO> bSTPurchaseOrderDTOsDel = bSTPurchaseOrderDTOs.Where(x => x.Way == 3).ToList();
|
//获取所有物料
|
List<Dt_MaterielInfo> materielInfos = _basicRepository.MaterielInfoRepository.QueryData(x => x.WarehouseId == WarehouseEnum.LLDYL.ObjToInt() && x.MaterielInvOrgId == MaterielInvOrgEnum.老厂.ObjToInt() && x.MaterialSourceId != 0);
|
//获取所有供应商
|
List<Dt_SupplierInfo> supplierInfos = _basicRepository.SupplierInfoRepository.QueryData(x => x.InvOrgId == MaterielInvOrgEnum.老厂.ObjToInt());
|
|
List<Dt_PurchaseBSTOrder> purchaseAddBSTOrders = new List<Dt_PurchaseBSTOrder>();
|
List<Dt_PurchaseBSTOrder> purchaseUpdateBSTOrders = new List<Dt_PurchaseBSTOrder>();
|
List<Dt_PurchaseBSTOrder> purchaseDeleteBSTOrders = new List<Dt_PurchaseBSTOrder>();
|
List<Dt_PurchaseBSTOrderDetail> purchaseBSTOrderDetailsDel = new List<Dt_PurchaseBSTOrderDetail>();
|
//新增
|
if (bSTPurchaseOrderDTOsAdd.Count>0)
|
{
|
//判断供应商
|
BSTPurchaseOrderDTO? bSTPurchaseOrderDTO = bSTPurchaseOrderDTOsAdd.FirstOrDefault(x => !supplierInfos.Select(x=>x.SupplierCode).Contains(x.VendNo));
|
if (bSTPurchaseOrderDTO != null)
|
{
|
return content.Error($"采购{nameof(BSTPurchaseOrderDTO.PaperReceiptNo)}:{bSTPurchaseOrderDTO.PaperReceiptNo}供应商:{bSTPurchaseOrderDTO.VendNo}不存在");
|
}
|
//判断单据
|
Dt_PurchaseBSTOrder? ExistAddPurchase = OldpurchaseBSTOrders.FirstOrDefault(x => bSTPurchaseOrderDTOsAdd.Select(x => x.PaperReceiptId).Contains(x.PaperReceiptId));
|
if (ExistAddPurchase != null)
|
{
|
return content.Error($"采购收货Id{nameof(BSTPurchaseOrderDTO.PaperReceiptId)}:{ExistAddPurchase.PaperReceiptId}已存在");
|
}
|
//验证条码重复
|
List<Dt_PurchaseBSTOrderDetail> purchaseBSTOrderDetails = OldpurchaseBSTOrders.SelectMany(x => x.Details).ToList();
|
List<PaperReceiptDetailsItem> paperReceiptDetailsItemsAdd = bSTPurchaseOrderDTOsAdd.SelectMany(x => x.PaperReceiptDetails).ToList();
|
var ExistDetail = purchaseBSTOrderDetails.FirstOrDefault(x => paperReceiptDetailsItemsAdd.Select(x => x.Barcode).Contains(x.Barcode));
|
if (ExistDetail!=null)
|
{
|
return content.Error($"采购条码{nameof(ExistDetail.Barcode)}:{ExistDetail.Barcode}已存在");
|
}
|
//判断是否存在物料
|
PaperReceiptDetailsItem? paperReceiptDetailsItem = paperReceiptDetailsItemsAdd.FirstOrDefault(x => !materielInfos.Select(x => x.MaterialSourceId).Contains(x.MaterialId));
|
if (paperReceiptDetailsItem!=null)
|
{
|
return content.Error($"采购条码{nameof(paperReceiptDetailsItem.Barcode)}:{paperReceiptDetailsItem.Barcode}物料Id:{paperReceiptDetailsItem.MaterialId}不存在");
|
}
|
foreach (var item in bSTPurchaseOrderDTOsAdd)
|
{
|
if (bSTPurchaseOrderDTOsUpdate.FirstOrDefault(x=>x.PaperReceiptId== item.PaperReceiptId)!=null)
|
{
|
continue;
|
}
|
List<Dt_PurchaseBSTOrderDetail> bSTOrderDetails = item.PaperReceiptDetails.Select(x=>_mapper.Map<Dt_PurchaseBSTOrderDetail>(x)).ToList();
|
Dt_PurchaseBSTOrder purchaseBSTOrder = _mapper.Map<Dt_PurchaseBSTOrder>(item);
|
purchaseBSTOrder.Details = bSTOrderDetails;
|
purchaseAddBSTOrders.Add(purchaseBSTOrder);
|
}
|
}
|
//更新
|
if (bSTPurchaseOrderDTOsUpdate.Count > 0)
|
{
|
//存在的采购单
|
List<Dt_PurchaseBSTOrder>? ExistpurchaseBSTOrders = OldpurchaseBSTOrders.Where(x => bSTPurchaseOrderDTOsUpdate.Select(x => x.PaperReceiptId).Contains(x.PaperReceiptId)).Distinct().ToList();
|
|
foreach (var item in bSTPurchaseOrderDTOsUpdate)
|
{
|
Dt_PurchaseBSTOrder? purchaseBSTOrderUpdate = ExistpurchaseBSTOrders.FirstOrDefault(x => x.PaperReceiptId == item.PaperReceiptId);
|
//如果订单已存在则进行更改
|
if (purchaseBSTOrderUpdate != null)
|
{
|
if (purchaseBSTOrderUpdate.PurchaseOrderStatus!=InOrderStatusEnum.未开始.ObjToInt())
|
{
|
return content.Error($"采购{nameof(purchaseBSTOrderUpdate.PaperReceiptId)}:{purchaseBSTOrderUpdate.PaperReceiptId}订单入库中，不可更改");
|
}
|
purchaseBSTOrderDetailsDel.AddRange(purchaseBSTOrderUpdate.Details);
|
|
//更新
|
List<Dt_PurchaseBSTOrderDetail> bSTOrderDetails = item.PaperReceiptDetails.Select(x => _mapper.Map<Dt_PurchaseBSTOrderDetail>(x)).ToList();
|
bSTOrderDetails.ForEach(x =>
|
{
|
x.PurchaseBSTOrderId = purchaseBSTOrderUpdate.Id;
|
});
|
purchaseBSTOrderUpdate.Details = bSTOrderDetails;
|
purchaseBSTOrderUpdate.PaperReceiptId = item.PaperReceiptId;
|
purchaseBSTOrderUpdate.PaperReceiptNo = item.PaperReceiptNo;
|
purchaseBSTOrderUpdate.VendNo = item.VendNo;
|
purchaseBSTOrderUpdate.ReceiptDate = DateTimeOffset.FromUnixTimeMilliseconds(item.ReceiptDate).DateTime;
|
purchaseBSTOrderUpdate.TotalProcurementLength = item.TotalProcurementLength;
|
purchaseUpdateBSTOrders.Add(purchaseBSTOrderUpdate);
|
}
|
else //如果不存在则进行新增
|
{
|
List<Dt_PurchaseBSTOrderDetail> bSTOrderDetails = item.PaperReceiptDetails.Select(x => _mapper.Map<Dt_PurchaseBSTOrderDetail>(x)).ToList();
|
Dt_PurchaseBSTOrder purchaseBSTOrder = _mapper.Map<Dt_PurchaseBSTOrder>(item);
|
purchaseBSTOrder.Details = bSTOrderDetails;
|
purchaseAddBSTOrders.Add(purchaseBSTOrder);
|
}
|
}
|
|
}
|
//删除
|
if (bSTPurchaseOrderDTOsDel.Count>0)
|
{
|
List<Dt_PurchaseBSTOrder>? ExistDelPurchase = OldpurchaseBSTOrders.Where(x => bSTPurchaseOrderDTOsDel.Select(x => x.PaperReceiptId).Contains(x.PaperReceiptId)).ToList();
|
//更新的单据是否存在
|
if (ExistDelPurchase.Count == bSTPurchaseOrderDTOsDel.Count)
|
{
|
|
}
|
else
|
{
|
BSTPurchaseOrderDTO? bSTPurchaseOrderDTO = bSTPurchaseOrderDTOsDel.FirstOrDefault(x => !ExistDelPurchase.Select(x => x.PaperReceiptId).Contains(x.PaperReceiptId));
|
return content.Error($"未找到指定采购收货单{nameof(BSTPurchaseOrderDTO.PaperReceiptId)}:{bSTPurchaseOrderDTO?.PaperReceiptId}");
|
}
|
}
|
//更新数据
|
_unitOfWorkManage.BeginTran();
|
BaseDal.Db.InsertNav(purchaseAddBSTOrders).Include(x => x.Details).ExecuteCommand();
|
_purchaseBSTOrderDetailRepository.DeleteData(purchaseBSTOrderDetailsDel);
|
BaseDal.Db.UpdateNav(purchaseUpdateBSTOrders).Include(x => x.Details).ExecuteCommand();
|
_unitOfWorkManage.CommitTran();
|
content.OK("接收成功");
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
}
|
}
|
