using Apache.NMS.ActiveMQ.Commands;
|
using Microsoft.AspNetCore.Mvc;
|
using Rhea.Common;
|
using System;
|
using System.Collections.Generic;
|
using System.Threading.Tasks;
|
using Tiger.IBusiness;
|
using Tiger.Model.Entitys.MES;
|
using Tiger.Model.Entitys.WMS.DTOS;
|
|
namespace Tiger.Api.Controllers.WMS
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public partial class WMSController : ControllerBase
|
{
|
private static readonly object _locker = new object();
|
private static readonly object _locker1 = new object();
|
|
/// <summary>
|
/// 存储T100推送过来的其他出库单信息
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/OthOutInfo/SaveData")]
|
public IActionResult OthOutInfo([FromBody] List<otherOutInfoDTO> input)
|
{
|
ApiAction response = new();
|
try
|
{
|
response = response.GetResponse(_otherBus.SaveOthOutInfo(input));
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
|
/// <summary>
|
/// 存储T100传递过来的调拨单信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/TrasferInfo/SaveData")]
|
public IActionResult TrasferInfo([FromBody] List<TrasferInfoDTO> input)
|
{
|
ApiAction response = new();
|
try
|
{
|
response = response.GetResponse(_trasferBus.SaveTrasferInfo(input));
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
|
/// <summary>
|
/// 从T100获取物料库存信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/StockInfo/GetData")]
|
public IActionResult SaleOutInfo([FromBody] StockInputDTO input)
|
{
|
ApiAction response = new();
|
try
|
{
|
response = response.GetResponse(_stockBus.GetStockInfo(input));
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
|
/// <summary>
|
/// SMT退料——对接MES
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/Product/SMTReturnFormMES")]
|
public IActionResult SMTReturnFormMES([FromBody] SMTReturnDTO input)
|
{
|
ApiAction response = new();
|
try
|
{
|
response = response.GetResponse(_inputBus.SMTReturnFormMES(input));
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
|
/// <summary>
|
/// 成品入库——对接T100过账接口
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/ProductInput/PostingToT100")]
|
public IActionResult ProductInputPostingToT100([FromBody] ProductInputDTO input)
|
{
|
ApiAction response = new();
|
try
|
{
|
response = response.GetResponse(_inputBus.GetProductInputPostingToT100(input));
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
|
/// <summary>
|
/// 成品入库——对接T100，存储T100推送过来的表头表身数据
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/ProductInput/SaveDataFormT100")]
|
public IActionResult ProductInputSaveDataFormT100([FromBody] ProduceInputDataDTO input)
|
{
|
ApiAction response = new();
|
try
|
{
|
response = response.GetResponse(_inputBus.GetProductInputInfoFromT100(input));
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
|
/// <summary>
|
/// 成品入库
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/ProductInput/Save")]
|
public IActionResult ProductInputSaveData([FromBody] ProductInputDTO input)
|
{
|
ApiAction response = new();
|
try
|
{
|
lock (_locker)
|
{
|
response = response.GetResponse(_inputBus.GetProductInputInfo(input));
|
}
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
|
/// <summary>
|
/// 成品入库结果查询
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/ProductInput/GetProdctResult")]
|
public Task<List<C_Stock_Pallet_T>> ProductInputResultData([FromBody] ProductInputResultDTO input)
|
{
|
return _inputBus.GetProductInputResultInfoAsync(input);
|
}
|
|
/// <summary>
|
/// 成品入库状态复原
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/ProductInput/StatusRestored")]
|
public IActionResult ProductInputStatusRestored([FromBody] ProductInputResultDTO input)
|
{
|
ApiAction response = new();
|
try
|
{
|
response = response.GetResponse(_inputBus.ProductInputStatusRestoredAsync(input));
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
|
/// <summary>
|
/// 成品出库
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/ProductOutput/Save")]
|
public IActionResult ProductOutputSaveData([FromBody] ProductOutputDTO input)
|
{
|
ApiAction response = new();
|
try
|
{
|
response = response.GetResponse(_outputBus.GetProductOutputInfo(input));
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
|
/// <summary>
|
/// 成品分合箱
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/SplitBox/Save")]
|
public IActionResult SplitBoxSaveData([FromBody] SplitBoxDTO input)
|
{
|
ApiAction response = new();
|
try
|
{
|
response = response.GetResponse(_boxBus.SaveSplitBoxData(input));
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
|
/// <summary>
|
/// 成品门重工
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("api/[controller]/Rework/ReworkData")]
|
public IActionResult ReworkData([FromBody] List<string> input)
|
{
|
ApiAction response = new();
|
try
|
{
|
lock (_locker1)
|
{
|
response = response.GetResponse(_reworkBux.ReworkData(input));
|
}
|
}
|
catch (Exception ex)
|
{
|
response = response.GetResponse().CatchExceptionWithLog(ex);
|
}
|
return Ok(response);
|
}
|
}
|
}
|
