using Microsoft.AspNetCore.Mvc;
|
using System;
|
using System.Security.Claims;
|
using Microsoft.Extensions.Options;
|
using Model;
|
using Model.ModelVm;
|
using Newtonsoft.Json;
|
using Utility.Tools;
|
using WMS.IBLL.IBllSoServer;
|
using Wms.Tools;
|
using Model.InterFaceModel;
|
using WMS.IBLL.IBllAsnServer;
|
using WMS.IBLL.IBllCheckServer;
|
using Model.ModelVm.BllCheckVm;
|
using Microsoft.Extensions.Logging;
|
using WMS.IBLL.IPdaServer;
|
using WMS.IBLL.IDataServer;
|
using Model.ModelDto.DataDto;
|
using System.Collections.Generic;
|
using Model.ModelDto.LogDto;
|
|
namespace Wms.Controllers
|
{
|
/// <summary>
|
/// 上游系统交互
|
/// </summary>
|
[Route("api/[controller]/[action]")]
|
[ApiController]
|
public class UpApiController : ControllerBase
|
{
|
#region 依赖注入
|
private readonly ApiUrlConfig _config; //接口交互路径
|
private readonly IExportNoticeServer _exNoticeSvc;//出库单Svc
|
private readonly IArrivalNoticeServer _arrivalNoticeSvc;
|
private readonly IStockCheckServer _stockCheckSvc;//盘点单Svc
|
private readonly IPdaCrServer _daCrSvc;//PDA
|
private readonly IStockServer _stock; //库存
|
public UpApiController(IOptions<ApiUrlConfig> setting, IExportNoticeServer exNoticeSvc, IArrivalNoticeServer arrivalNoticeServer, IStockCheckServer stockCheckSvc, IPdaCrServer daCrSvc, IStockServer stock)
|
{
|
_config = setting.Value;
|
_exNoticeSvc = exNoticeSvc;
|
_arrivalNoticeSvc = arrivalNoticeServer;
|
_stockCheckSvc = stockCheckSvc;
|
_daCrSvc = daCrSvc;
|
_stock = stock;
|
}
|
#endregion
|
|
#region 调用上游系统接口
|
/// <summary>
|
/// 入库单关闭
|
/// </summary>
|
/// <param name="model">入库单号</param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult CloseAsn(IdVm model)
|
{
|
try
|
{
|
//获取当前登录的用户ID
|
var claimsIdentity = this.User.Identity as ClaimsIdentity;
|
if (claimsIdentity == null)
|
{
|
return Ok(new { code = 1, msg = "未获取到当前操作人信息" });
|
}
|
var userId = claimsIdentity.FindFirst(ClaimTypes.Name)?.Value;
|
if (string.IsNullOrWhiteSpace(userId))
|
{
|
return Ok(new { code = 1, msg = "未获取到当前操作人信息" });
|
}
|
_arrivalNoticeSvc.CloseArrivalNotice(model.Id, int.Parse(userId));
|
|
return Ok(new { code = 0, count = 0, msg = "入库单关单成功" });
|
}
|
catch (Exception e)
|
{
|
return Ok(new { code = 1, msg = e.Message });
|
}
|
}
|
/// <summary>
|
/// 入库单复核并回传
|
/// </summary>
|
/// <param name="model">入库单号</param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult FinishAsn(FinshVm model)
|
{
|
try
|
{
|
//获取当前登录的用户ID
|
var claimsIdentity = this.User.Identity as ClaimsIdentity;
|
if (claimsIdentity == null)
|
{
|
return Ok(new { code = 1, msg = "未获取到当前操作人信息" });
|
}
|
var userId = claimsIdentity.FindFirst(ClaimTypes.Name)?.Value;
|
if (string.IsNullOrWhiteSpace(userId))
|
{
|
return Ok(new { code = 1, msg = "未获取到当前操作人信息" });
|
}
|
_arrivalNoticeSvc.FinishAsn(model.Id, _config.ErpHost + _config.AsnFinishUrl, _config.MesHost + _config.MesAsnFinishUrl, _config.MesHost + _config.MesGetTokenUrl, model.UserNo, model.Password, int.Parse(userId));
|
|
return Ok(new { code = 0, count = 0, msg = "入库单复核并上传成功" });
|
}
|
catch (Exception e)
|
{
|
return Ok(new { code = 1, msg = e.Message });
|
}
|
}
|
|
/// <summary>
|
/// 完成/关闭出库单据
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult CloseExportNotice(IdVm model)
|
{
|
try
|
{
|
//获取当前登录的用户ID
|
var claimsIdentity = this.User.Identity as ClaimsIdentity;
|
if (claimsIdentity == null)
|
{
|
return Ok(new { code = 1, msg = "未获取到当前操作人信息" });
|
}
|
var userId = claimsIdentity.FindFirst(ClaimTypes.Name)?.Value;
|
if (string.IsNullOrWhiteSpace(userId))
|
{
|
return Ok(new { code = 1, msg = "未获取到当前操作人信息" });
|
}
|
_exNoticeSvc.CloseExportNotice(model.Id, int.Parse(userId));
|
|
return Ok(new { code = 0, count = 0, msg = "出库单关单成功" });
|
}
|
catch (Exception e)
|
{
|
return Ok(new { code = 1, msg = e.Message });
|
}
|
}
|
/// <summary>
|
/// //出库单复核并上传
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult FinishExportNotice(FinshVm model)
|
{
|
try
|
{
|
//获取当前登录的用户ID
|
var claimsIdentity = this.User.Identity as ClaimsIdentity;
|
if (claimsIdentity == null)
|
{
|
return Ok(new { code = 1, msg = "未获取到当前操作人信息" });
|
}
|
var userId = claimsIdentity.FindFirst(ClaimTypes.Name)?.Value;
|
if (string.IsNullOrWhiteSpace(userId))
|
{
|
return Ok(new { code = 1, msg = "未获取到当前操作人信息" });
|
}
|
_exNoticeSvc.FinishSo(model.Id, _config.ErpHost + _config.SoFinishUrl, model.UserNo, model.Password, int.Parse(userId));
|
return Ok(new { code = 0, count = 0, msg = "出库单复核并上传成功" });
|
}
|
catch (Exception e)
|
{
|
return Ok(new { code = 1, msg = e.Message });
|
}
|
}
|
|
/// <summary>
|
/// 完成盘库单据 //盘库单调整库存反馈
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult FinishCr(AdjustStockCheckVm model)
|
{
|
try
|
{
|
//获取当前登录的用户ID
|
var claimsIdentity = this.User.Identity as ClaimsIdentity;
|
if (claimsIdentity == null)
|
{
|
return Ok(new { code = 1, msg = "未获取到当前操作人信息" });
|
}
|
var userId = claimsIdentity.FindFirst(ClaimTypes.Name)?.Value;
|
if (string.IsNullOrWhiteSpace(userId))
|
{
|
return Ok(new { code = 1, msg = "未获取到当前操作人信息" });
|
}
|
bool bolls = false;
|
if (model.Origin == "0")
|
{
|
bolls = _stockCheckSvc.StockAdjust(model.Id, int.Parse(userId));
|
}
|
else
|
{
|
bolls = _stockCheckSvc.StockAdjustAuto(model.Id, int.Parse(userId));
|
}
|
if (bolls)
|
{
|
//系统对接后放开
|
//var bl =_stockCheckSvc.FinishCr(model.Id,_config.ErpHost + _config.DataChangeUrl, int.Parse(userId));
|
//if (bl)
|
//{
|
return Ok(new { code = 0, count = 0, msg = "盘点单调整上传成功" });
|
//}
|
//return Ok(new { code = 1, count = 0, msg = "出库单关单成功但上传失败" });
|
}
|
|
return Ok(new { code = 1, msg = "盘点单调整失败" });
|
|
}
|
catch (Exception e)
|
{
|
return Ok(new { code = 1, msg = e.Message });
|
}
|
}
|
|
//箱码信息 手持组托用 (扫箱码向追溯要信息)
|
//
|
|
|
/// <summary>
|
/// 下发AGV调度任务
|
/// </summary>
|
/// <param name="type"></param>
|
/// <param name="taskno"></param>
|
/// <param name="positionStart"></param>
|
/// <param name="positionEnd"></param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult AGVTask(string type, string taskno, string positionStart, string positionEnd)
|
{
|
try
|
{
|
|
OutCommanAgvDto agvRequest = _daCrSvc.AGVTask(type, taskno, positionStart, positionEnd, _config.AgvHost + _config.GenAgvSchedulingTask);
|
if (agvRequest.Code != "0")
|
{
|
return Ok(new { code = 1, msg = "小车任务执行失败" });
|
}
|
|
return Ok(new { code = 1, msg = "AGV任务下发成功" });
|
|
}
|
catch (Exception e)
|
{
|
return Ok(new { code = 1, msg = e.Message });
|
}
|
}
|
|
/// <summary>
|
/// 下发AGV取消任务
|
/// </summary>
|
/// <param name="taskno"></param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult cancelTask(string taskno)
|
{
|
try
|
{
|
|
_daCrSvc.cancelTask(taskno, _config.AgvHost + _config.CancelTask);
|
return Ok(new { code = 1, msg = "AGV任务取消成功" });
|
|
}
|
catch (Exception e)
|
{
|
return Ok(new { code = 1, msg = e.Message });
|
}
|
}
|
|
#endregion
|
|
#region 被调上游调用接口
|
|
/// <summary>
|
/// 入库单据下发
|
/// </summary>
|
/// <param name="model">入库单信息</param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult CreateAsn(AsnInfo model)
|
{
|
// liudl Test
|
var result = new HttpReturnModel { Success = "-1", Message = "" };
|
var logStr = "";
|
if (model.Origin == "MES")
|
{
|
logStr = $@".\log\MES\入库单下发" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
|
}
|
else if (model.Origin == "ERP")
|
{
|
logStr = $@".\log\ERP\入库单下发" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
|
}
|
|
try
|
{
|
//log日志记录
|
if (logStr != "")
|
{
|
var jsonData = JsonConvert.SerializeObject(model);
|
LogFile.SaveLogToFile($"入库单下发：( {jsonData} ),", logStr);
|
}
|
|
result = _arrivalNoticeSvc.HttpCreateAsn(model, _config.WcsHost + _config.AddOrderTaskUrl);
|
if (logStr != "")
|
{
|
var jsonData = JsonConvert.SerializeObject(result);
|
LogFile.SaveLogToFile($"入库单下发返回参数：( {jsonData} ),", logStr);
|
}
|
return Ok(result);
|
}
|
catch (Exception e)
|
{
|
result.Message = e.Message;
|
if (logStr != "")
|
{
|
var jsonData = JsonConvert.SerializeObject(result);
|
LogFile.SaveLogToFile($"入库单下发返回参数：( {jsonData} ),", logStr);
|
}
|
return Ok(result);
|
}
|
}
|
|
/// <summary>
|
/// 出库单下发接口
|
/// </summary>
|
/// <param name="model">入库单信息</param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult CreateSo(SoInfo model)
|
{
|
var logStr = "";
|
if (model.Origin == "MES")
|
{
|
logStr = $@".\log\MES\出库单下发" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
|
}
|
else if (model.Origin == "ERP")
|
{
|
logStr = $@".\log\ERP\出库单下发" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
|
}
|
|
try
|
{
|
//log日志记录
|
if (logStr != "")
|
{
|
var jsonData = JsonConvert.SerializeObject(model);
|
LogFile.SaveLogToFile($"出库单下发：( {jsonData} ),", logStr);
|
}
|
|
_exNoticeSvc.HttpAddExportNotice(model);
|
|
var data = new HttpReturnModel { Success = "0", Message = "成功" };
|
|
if (logStr != "")
|
{
|
var jsonData = JsonConvert.SerializeObject(data);
|
LogFile.SaveLogToFile($"出库单下发返回参数：( {jsonData} ),", logStr);
|
}
|
|
return Ok(data);
|
|
|
}
|
catch (Exception e)
|
{
|
var data = new HttpReturnModel { Success = "-1", Message = "失败" + e.Message };
|
if (logStr != "")
|
{
|
var jsonData = JsonConvert.SerializeObject(data);
|
LogFile.SaveLogToFile($"出库单下发返回参数：( {jsonData} ),", logStr);
|
}
|
return Ok(data);
|
}
|
}
|
|
/// <summary>
|
/// 释放备料区储位状态JC24
|
/// </summary>
|
/// <param name="model">状态信息</param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult UpLocate(UpLocateModel model)
|
{
|
//记录log
|
var logStr = "";
|
if (model.Origin == "MES")
|
{
|
logStr = $@".\log\MES\释放备料区储位状态" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
|
}
|
try
|
{
|
if (logStr != "")
|
{
|
var jsonData = JsonConvert.SerializeObject(model);
|
LogFile.SaveLogToFile($"释放备料区储位状态：( {jsonData} ),", logStr);
|
}
|
_arrivalNoticeSvc.UpLocate(model.WareHouseNo, model.LocatNo);
|
|
var data = new HttpReturnModel { Success = "0", Message = "成功" };
|
|
if (logStr != "")
|
{
|
var jsonData = JsonConvert.SerializeObject(data);
|
LogFile.SaveLogToFile($"释放备料区储位状态返回参数：( {jsonData} ),", logStr);
|
}
|
return Ok(data);
|
|
}
|
catch (Exception e)
|
{
|
var data = new HttpReturnModel { Success = "0", Message = "失败：" + e.Message };
|
if (logStr != "")
|
{
|
var jsonData = JsonConvert.SerializeObject(data);
|
LogFile.SaveLogToFile($"释放备料区储位状态返回参数：( {jsonData} ),", logStr);
|
}
|
return Ok(data);
|
}
|
}
|
|
|
//质检结果下发接口
|
|
//物料信息接口
|
|
//客户信息接口
|
|
//单位信息接口
|
|
//包装信息接口
|
|
|
/// <summary>
|
/// 数字孪生系统库存质量状态反馈
|
/// </summary>
|
/// <param name="model">来源信息</param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult ReLocateData(DigitalTwinModel model)
|
{
|
//记录log
|
var logStr = "";
|
logStr = $@".\log\数字孪生\库位信息及质量状态反馈" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
|
var jsonData = JsonConvert.SerializeObject(model);
|
LogFile.SaveLogToFile($"库位信息及质量状态反馈：( {jsonData} ),", logStr);
|
|
//获取库存信息
|
List<ReLocateDataModel> stocks = _stock.GetLocateList();
|
|
if (stocks.Count == 0)
|
{
|
var data = new HttpReturnModel { Success = "0", Message = "当前无库存" };
|
return Ok(data);
|
}
|
return Ok(stocks);
|
}
|
|
/// <summary>
|
/// 数字孪生系统库存质量状态反馈
|
/// </summary>
|
/// <param name="model">来源信息</param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult ReLogData(DigitalTwinModel model)
|
{
|
|
//记录log
|
var logStr = "";
|
logStr = $@".\log\数字孪生\操作日志信息反馈" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
|
var jsonData = JsonConvert.SerializeObject(model);
|
LogFile.SaveLogToFile($"操作日志信息反馈：( {jsonData} ),", logStr);
|
try
|
{
|
//获取库存信息
|
List<OperationDto> stocks = _stock.ReLogData();
|
|
if (stocks.Count == 0)
|
{
|
var data = new HttpReturnModel { Success = "0", Message = "当前无操作信息" };
|
return Ok(data);
|
}
|
return Ok(stocks);
|
|
}
|
catch (Exception e)
|
{
|
var data = new HttpReturnModel { Success = "0", Message = "失败：" + e.Message };
|
if (logStr != "")
|
{
|
jsonData = JsonConvert.SerializeObject(data);
|
LogFile.SaveLogToFile($"操作日志信息反馈，返回参数：( {jsonData} ),", logStr);
|
}
|
return Ok(data);
|
}
|
|
}
|
|
#endregion
|
|
}
|
}
|
