236 lines
14 KiB
C#
236 lines
14 KiB
C#
using iTextSharp.text;
|
|
using Microsoft.Extensions.Configuration;
|
|
using Net.Business.Entities;
|
|
using Net.Business.Entities.ServicesLayer;
|
|
using Net.Business.Entities.ServicesLayer.Invoices;
|
|
using Net.Business.Entities.ServicesLayer.Items;
|
|
using Net.Business.Entities.ServicesLayer.PurchaseDeliveryNotes;
|
|
using Net.Business.Entities.ServicesLayer.StockTransfer;
|
|
using Net.Business.Entities.WMS.Transferencia;
|
|
using Net.Connection;
|
|
using Net.CrossCotting;
|
|
using Net.Data.HelperData.Invoices;
|
|
using Net.Data.HelperData.Stock;
|
|
using Net.Data.ServicesLayer;
|
|
using Net.Data.ServicesLayer.StockTransfer;
|
|
using Sap.Data.Hana;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Linq;
|
|
using System.Net.Http;
|
|
using System.Text.RegularExpressions;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace Net.Data.WMS.Transferencia
|
|
{
|
|
public class TransferenciaRepository : RepositoryBase<object>, ITransferenciaRepository
|
|
{
|
|
#region Variables Globales
|
|
private string _aplicacionName;
|
|
private string _metodoName;
|
|
private readonly Regex regex = new Regex(@"<(\w+)>.*");
|
|
|
|
private readonly IHttpClientFactory _clientFactory;
|
|
private readonly IConfiguration _configuration;
|
|
#endregion
|
|
|
|
public TransferenciaRepository(IConnectionSQL context, IHttpClientFactory clientFactory, IConfiguration configuration) : base(context)
|
|
{
|
|
_clientFactory = clientFactory;
|
|
_configuration = configuration;
|
|
_aplicacionName = GetType().Name;
|
|
}
|
|
|
|
public async Task<BE_ResultadoTransaccion<object>> Create(BE_TransferenciaRequest entidad)
|
|
{
|
|
_metodoName = regex.Match(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Name).Groups[1].Value.ToString();
|
|
|
|
ResultadoTransaccion<object> resultadoTransaccion = new ResultadoTransaccion<object>(_metodoName, _aplicacionName);
|
|
|
|
return await Task.Run(() =>
|
|
{
|
|
try
|
|
{
|
|
//=== CREA INSTANCIA PARA CONECTAR A SAP
|
|
StockTransferRepository stockTransferRepository = new StockTransferRepository(_clientFactory, _configuration);
|
|
|
|
BE_StockTransfer StockTransfer = new BE_StockTransfer
|
|
{
|
|
DocDate = entidad.FechaOrden,
|
|
DueDate = entidad.FechaOrden,
|
|
TaxDate = entidad.FechaOrden,
|
|
FromWarehouse = entidad.CodigoSubAlmacenOrigen,
|
|
ToWarehouse = entidad.CodigoSubAlmacenDestino,
|
|
Comments = "Transferencia Generado desde Cubico - SAP",
|
|
StockTransferLines = new List<BE_StockTransferLine>()
|
|
};
|
|
|
|
entidad.TransferenciaDetalles.ForEach(x =>
|
|
{
|
|
var Detalle = new BE_StockTransferLine
|
|
{
|
|
FromWarehouseCode = entidad.CodigoSubAlmacenOrigen,
|
|
WarehouseCode = entidad.CodigoSubAlmacenDestino,
|
|
ItemCode = x.CodigoArticulo,
|
|
Quantity = (double)x.CantidadPedida,
|
|
BaseLine = entidad.DocEntry == 0 ? null : (int?)x.Item,
|
|
BaseEntry = entidad.DocEntry == 0 ? null : (int?)entidad.DocEntry,
|
|
BaseType = entidad.DocEntry == 0 ? null : "InventoryTransferRequest",
|
|
LineNum = x.Item,
|
|
BatchNumbers = new List<BE_StockTransferLineBatchNumber>()
|
|
};
|
|
StockTransfer.StockTransferLines.Add(Detalle);
|
|
});
|
|
|
|
// == REALIZA DISTRIBUCION DE STOCK POR LOTE / ALMACEN
|
|
StockTransfer.StockTransferLines.ForEach(line =>
|
|
{
|
|
#region CONSULTA A HANA
|
|
|
|
List<BE_ItemStock> ListaStock = HelperStock.Get(line.ItemCode, line.FromWarehouseCode);
|
|
var CantidadPendiente = line.Quantity;
|
|
var ListOrdenadaFecha = ListaStock.OrderBy(x => x.ExpDate).ToList();
|
|
ListOrdenadaFecha.ForEach(Lote =>
|
|
{
|
|
if (CantidadPendiente > 0)
|
|
{
|
|
if (Lote.OnHandQty >= CantidadPendiente)
|
|
{
|
|
line.BatchNumbers.Add(new BE_StockTransferLineBatchNumber() { BatchNumber = Lote.DistNumber, Quantity = CantidadPendiente });
|
|
CantidadPendiente = 0;
|
|
}
|
|
else if (Lote.OnHandQty < CantidadPendiente)
|
|
{
|
|
line.BatchNumbers.Add(new BE_StockTransferLineBatchNumber() { BatchNumber = Lote.DistNumber, Quantity = Lote.OnHandQty });
|
|
CantidadPendiente -= Lote.OnHandQty;
|
|
}
|
|
}
|
|
});
|
|
|
|
#endregion
|
|
});
|
|
|
|
//=== SI EL ALMACEN ES ALM99 (almacen de costeo de importaciones), AMARRA CON LA ENTRADA DE MERCANCIA
|
|
// Proceso: factura de reserva -> WMS recibe por partes y crea una entrada por recepcion (todas a ALM99) -> costeo en SAP ->
|
|
// WMS notifica UNA transferencia por entrada, con numorden = DocNum de la factura de reserva y en el detalle los
|
|
// articulos/cantidades de esa entrada. Detalle completo y diagnostico en docs/TRANSFERENCIA_IMPORTACION.md.
|
|
// Casos: (1) DocEntryEM informado -> se usa esa entrada; (2) sin DocEntryEM -> se busca la entrada de la factura que
|
|
// coincida con el detalle y no tenga transferencia (EntradaImportacion.Elegir); (3) la factura no tiene entradas ->
|
|
// como antes, lotes del stock de HANA sin amarre.
|
|
if (entidad.CodigoSubAlmacenOrigen == "ALM99")
|
|
{
|
|
StockTransfer.U_SYP_MDMT = "21";
|
|
PurchaseDeliveryNotesRepository _purchaseDeliveryNotesRepository = new PurchaseDeliveryNotesRepository(_clientFactory, _configuration);
|
|
|
|
if (entidad.DocEntryEM > 0)
|
|
{
|
|
// WMS indica la entrada: se toman sus lotes y se amarra linea por linea (BaseLine del JSON == BaseLine de la entrada)
|
|
var pdn = _purchaseDeliveryNotesRepository.GetPurchaseDeliveryNotes(entidad.DocEntryEM).Result.ListData?.FirstOrDefault();
|
|
if (pdn == null)
|
|
{
|
|
return resultadoTransaccion.GetInformacionResultado($"SAP: La entrada de mercaderia {entidad.DocEntryEM} no se encuentra", entidad);
|
|
}
|
|
|
|
foreach (var line in StockTransfer.StockTransferLines)
|
|
{
|
|
var Lines = pdn.DocumentLines.FirstOrDefault(l => l.BaseLine == line.LineNum);
|
|
if (Lines == null)
|
|
{
|
|
return resultadoTransaccion.GetInformacionResultado($"SAP: La linea {line.LineNum} no existe en la entrada de mercaderia {entidad.DocEntryEM}", entidad);
|
|
}
|
|
line.BatchNumbers = (Lines.BatchNumbers ?? new List<BE_PurchaseDeliveryNotesBatchNumbers>())
|
|
.Select(lotes => new BE_StockTransferLineBatchNumber() { BatchNumber = lotes.BatchNumber, Quantity = lotes.Quantity }).ToList();
|
|
line.BaseLine = Lines.LineNum;
|
|
line.BaseType = "PurchaseDeliveryNotes";
|
|
line.BaseEntry = entidad.DocEntryEM;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
// WMS envia en NumOrden el DocNum de la Factura de Reserva y en el detalle los articulos/cantidades de UNA de sus
|
|
// entradas: se busca la entrada con ese mismo juego que aun no tenga transferencia y se transfiere esa.
|
|
var filas = HelperInvoice.GetEntradasPorFactura(entidad.NumOrden);
|
|
if (filas.Count > 0)
|
|
{
|
|
int docEntryEntrada = EntradaImportacion.Elegir(entidad.NumOrden, filas, entidad.TransferenciaDetalles, out string errorEntrada);
|
|
if (docEntryEntrada == 0)
|
|
{
|
|
return resultadoTransaccion.GetInformacionResultado(errorEntrada, entidad);
|
|
}
|
|
|
|
var pdn = _purchaseDeliveryNotesRepository.GetPurchaseDeliveryNotes(docEntryEntrada).Result.ListData?.FirstOrDefault();
|
|
if (pdn == null)
|
|
{
|
|
return resultadoTransaccion.GetInformacionResultado($"SAP: La entrada de mercaderia {docEntryEntrada} no se puede leer", entidad);
|
|
}
|
|
|
|
// Las lineas de la transferencia salen de la entrada (articulo, cantidad y lotes reales de cada linea)
|
|
StockTransfer.StockTransferLines = new List<BE_StockTransferLine>();
|
|
foreach (var l in pdn.DocumentLines)
|
|
{
|
|
var lotes = (l.BatchNumbers ?? new List<BE_PurchaseDeliveryNotesBatchNumbers>())
|
|
.Select(b => new BE_StockTransferLineBatchNumber() { BatchNumber = b.BatchNumber, Quantity = b.Quantity }).ToList();
|
|
if (lotes.Count > 0 && Math.Abs(lotes.Sum(b => b.Quantity) - l.Quantity) > 0.0001)
|
|
{
|
|
return resultadoTransaccion.GetInformacionResultado($"SAP: Los lotes de la linea {l.LineNum} ({l.ItemCode}) de la entrada {docEntryEntrada} no cubren la cantidad {l.Quantity}", entidad);
|
|
}
|
|
StockTransfer.StockTransferLines.Add(new BE_StockTransferLine
|
|
{
|
|
FromWarehouseCode = entidad.CodigoSubAlmacenOrigen,
|
|
WarehouseCode = entidad.CodigoSubAlmacenDestino,
|
|
ItemCode = l.ItemCode,
|
|
Quantity = l.Quantity,
|
|
LineNum = l.LineNum,
|
|
BaseType = "PurchaseDeliveryNotes",
|
|
BaseEntry = docEntryEntrada,
|
|
BaseLine = l.LineNum,
|
|
BatchNumbers = lotes
|
|
});
|
|
}
|
|
}
|
|
// Si la factura no tiene entradas (o NumOrden no es una factura de reserva) se mantiene lo de antes:
|
|
// transferencia con los lotes del stock de HANA, sin amarre.
|
|
}
|
|
}
|
|
|
|
var ResultTransaction = stockTransferRepository.StockTransfer(StockTransfer).Result;
|
|
if (ResultTransaction.StatusCode == -1)
|
|
{
|
|
return resultadoTransaccion.GetInformacionResultado(ResultTransaction.Message.ToString(), entidad);
|
|
}
|
|
|
|
// === SOLO SE EJECUTA CUANDO TIENE UN DOCUMENTO BASE [SOLICITUD DE TRASLADO]
|
|
if (entidad.DocEntry != 0)
|
|
{
|
|
var Result_SolicitudTraslado = stockTransferRepository.GetInventoryTransferRequest(entidad.DocEntry).Result;
|
|
if (Result_SolicitudTraslado.DocEntry == -1)
|
|
{
|
|
return resultadoTransaccion.GetInformacionResultado("SAP: La solicitud no se encuentra", entidad);
|
|
}
|
|
var _SolicitudTraslado = Result_SolicitudTraslado.ListData.FirstOrDefault();
|
|
|
|
// === SOLO CIERRA CUANDO EL DOCUMENTO ESTA ABIERTO
|
|
if (_SolicitudTraslado.DocumentStatus == "bost_Open")
|
|
{
|
|
var Response_Close = stockTransferRepository.CloseInventoryTransferRequest(entidad.DocEntry).Result;
|
|
if (Response_Close.DocEntry == -1)
|
|
{
|
|
return resultadoTransaccion.GetInformacionResultado("SAP: La Solicitud no se puede cerrar en automatico", entidad);
|
|
}
|
|
}
|
|
}
|
|
|
|
return resultadoTransaccion.GetInformacionResultado((int)ResultTransaction.Data.DocEntry, ResultTransaction.Data.DocNum.ToString(), "Registrado Correctamente", entidad);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return resultadoTransaccion.GetInformacionResultado(ex.Message.ToString(), entidad);
|
|
}
|
|
});
|
|
}
|
|
|
|
|
|
}
|
|
}
|