using Dm.filter;
|
using DocumentFormat.OpenXml.Presentation;
|
using Elastic.Clients.Elasticsearch;
|
using Furion.Logging;
|
using Newtonsoft.Json;
|
using System;
|
using System.Diagnostics.CodeAnalysis;
|
using System.Linq;
|
using System.Text;
|
using WCS.Application.Entity;
|
|
namespace WCS.Application;
|
|
/// <summary>
|
/// 示例开放接口
|
/// </summary>
|
[ApiDescriptionSettings("开放接口", Name = "Demo", Order = 100)]
|
//[Authorize(AuthenticationSchemes = SignatureAuthenticationDefaults.AuthenticationScheme)]
|
[AllowAnonymous]
|
public class DemoOpenApi : IDynamicApiController
|
{
|
private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId);
|
|
private readonly UserManager _userManager;
|
|
public DemoOpenApi(UserManager userManager)
|
{
|
_userManager = userManager;
|
}
|
|
//[HttpGet("helloWord")]
|
//public Task<string> HelloWord()
|
//{
|
// return Task.FromResult($"Hello word. {_userManager.Account}");
|
//}
|
|
// <summary>
|
/// WCS接受WMS下发的任务(单条任务)
|
/// </summary>
|
/// <param name="models">任务信息</param>
|
/// <returns>反馈信息</returns>
|
[AllowAnonymous]
|
public ResponseModel AddWcsTasks(List<ResponseTasksModel> modelList)
|
{
|
ResponseModel result = new ResponseModel();
|
result.StatusCode = 0;
|
try
|
{
|
foreach (var models in modelList)
|
{
|
var res = AddWcsTask(models);
|
if (res.StatusCode == -1)
|
{
|
result.StatusCode = -1;
|
result.Msg = res.Msg;
|
}
|
else if (res.StatusCode == 0)
|
{
|
result.StatusCode = 0;
|
result.Msg = models.TaskNo + "任务" + res.Msg;
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
return new ResponseModel() { StatusCode = -1, Msg = ex.Message };
|
}
|
return result;
|
}
|
/// <summary>
|
/// WCS接受WMS下发的任务(单条任务)
|
/// </summary>
|
/// <param name="models">任务信息</param>
|
/// <returns>反馈信息</returns>
|
[AllowAnonymous]
|
public ResponseModel AddWcsTask(ResponseTasksModel models)
|
{
|
ResponseModel result = new ResponseModel();
|
try
|
{
|
// 验证任务是否已存在
|
var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskNo == models.TaskNo);
|
if (taskInfo != null)
|
{
|
result.StatusCode = -1;
|
result.Msg = "任务:" + models.TaskNo + ";已存在!";
|
return result;
|
}
|
if (models.TaskType == "0" && models.TaskType == "0")
|
{
|
models.Order = 1;
|
}
|
else
|
{
|
models.Order = 2;
|
}
|
Enum type;
|
var bale = "0";
|
if (models.TaskType == "0" )
|
{
|
type = TaskTypeEnum.In;
|
}
|
else if (models.TaskType == "1")
|
{
|
type = TaskTypeEnum.Out;
|
}
|
else if (models.TaskType == "3")
|
{
|
type = TaskTypeEnum.In;
|
bale = "1";//裹包
|
}
|
else
|
{
|
type = TaskTypeEnum.Move;
|
}
|
//新增任务
|
var taskAdd = new WcsTask()
|
{
|
TaskNo = models.TaskNo,
|
TaskType = (TaskTypeEnum?)type,
|
Status = TaskStatusEnum.Wait,
|
//IsSuccess =TaskSuccessEnum.Success,
|
Levels = 999,
|
Origin = "WMS",
|
StartRoadway= models.StartRoadway,
|
StartLocate = models.StartLocate,
|
EndLocate = models.EndLocate,
|
EndRoadway= models.EndRoadway,
|
PalletNo = models.PalletNo,
|
IsBale = bale,
|
|
|
//LotNo =models.LotNo,
|
//SkuNo=models.SkuNo,
|
//SkuName=models.SkuName,
|
//Qty=models.Qty
|
};
|
_db.Insertable(taskAdd).ExecuteCommand();
|
|
return new ResponseModel() { StatusCode = 0, Msg = "插入成功" };
|
}
|
catch (Exception ex)
|
{
|
return new ResponseModel() { StatusCode = -1, Msg = ex.Message };
|
}
|
}
|
|
/// <summary>
|
/// WCS接收WMS下发的出入库单任务
|
/// </summary>
|
/// <param name="models"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[AllowAnonymous]
|
public ResponseModel AddOrderTask(List<ResponseOrderTaskModel> models)
|
{
|
ResponseModel result = new ResponseModel();
|
try
|
{
|
foreach (var item in models)
|
{
|
string str = JsonConvert.SerializeObject(models);
|
Log.Information("接收WMS推送的箱码信息：" + str);
|
// 验证任务是否已存在
|
//var taskInfo = _db.Queryable<WcsOderTask>().First(w => w.OrderNo == item.OrderNo && w.SkuNo == item.SkuNo && w.LotNo == item.LotNo);
|
//if (taskInfo == null)
|
//{
|
//var taskid = _db.Queryable<WcsOderTask>().OrderByDescending(w=>w.CreateTime).First();
|
//int newid = (int)taskid.Id + 1;
|
var orderAdd = new WcsOderTask()
|
{
|
|
OrderNo = item.OrderNo,
|
TaskNo = "",
|
LotNo = item.LotNo,
|
SkuNo = item.SkuNo,
|
SkuName = item.SkuName,
|
BoxType = item.BoxType,
|
Qty = item.Qty,
|
TaskType = (TaskTypeEnum)item.TaskType,
|
CreateTime = DateTime.Now,
|
Status = TaskStatusEnum.Wait,
|
};
|
_db.Insertable(orderAdd).ExecuteCommand();
|
//}
|
}
|
return new ResponseModel() { StatusCode = 0, Msg = "插入成功" };
|
}
|
catch (Exception ex)
|
{
|
return new ResponseModel() { StatusCode = -1, Msg = ex.Message };
|
}
|
}
|
|
|
/// <summary>
|
/// WCS接受赋码系统推送的箱码信息
|
/// </summary>
|
/// <param name="models">箱码信息</param>
|
/// <returns>反馈信息</returns>
|
[HttpPost]
|
[AllowAnonymous]
|
public ResponseFuMaModel AddHttpBoxInfo(FumaBoxInfoInput models)
|
{
|
|
try
|
{
|
string str = JsonConvert.SerializeObject(models);
|
Log.Information("接收赋码推送的箱码信息："+str);
|
if (models.Origin != "赋码")
|
{
|
throw new Exception("来源未识别");
|
}
|
var num = _db.Queryable<WcsBoxInfo>().Where(m=>m.BoxNo == models.BoxNo && m.IsDelete == false).ToList();
|
var type = "add";
|
if (num.Count>0)
|
{
|
//WCS存在箱码信息，更新箱码信息(需判断箱码是否已组盘入库)
|
var num2 = num.Count(m => m.Status != "0" || !string.IsNullOrWhiteSpace(m.PalletNo));
|
if (num2 > 0)
|
{
|
throw new Exception("该箱已入盘入库，不可更新信息");
|
}
|
type = "edit";
|
}
|
|
if (models.DelistList.Count == 0)
|
{
|
throw new Exception("盒码集合不能为空");
|
}
|
|
var listBox = new List<WcsBoxInfo>();
|
foreach (var item in models.DelistList)
|
{
|
var level = "3";
|
if (string.IsNullOrWhiteSpace(item.BoxNo2))
|
{
|
level = "2";
|
}
|
if (item.DelistList2.Count == 0)
|
{
|
throw new Exception("支码集合不能为空");
|
}
|
//二级码
|
foreach (var item2 in item.DelistList2)
|
{
|
if (string.IsNullOrWhiteSpace(models.ProductionTime) || string.IsNullOrWhiteSpace(models.ExpirationTime))
|
{
|
throw new Exception("生产日期或失效日期不能为空");
|
}
|
DateTime proTime;
|
DateTime expTime;
|
var isValid = DateTime.TryParse(models.ProductionTime, out proTime);
|
var isValid2 = DateTime.TryParse(models.ExpirationTime, out expTime);
|
if (!isValid || !isValid2)
|
{
|
throw new Exception("生产日期或失效日期格式错误");
|
};
|
DateTime? stortime = null;
|
if (!string.IsNullOrWhiteSpace(models.StoreTime))
|
{
|
stortime = DateTime.Parse(models.StoreTime);
|
}
|
|
var boxAdd = new WcsBoxInfo()
|
{
|
BoxNo = models.BoxNo,
|
//OrderNo = models.OrderNo,
|
SkuNo = models.SkuNo,
|
SkuName = models.SkuName,
|
Standard = models.Standard,
|
LotNo = models.LotNo,
|
LineNo = models.LineNo, // 产线号或产线名称
|
Qty = item2.Qty,
|
FullQty = models.FullQty,
|
//SupplierLot = models.SupplierLot,
|
InsPectMark = models.InsPectMark,
|
BitBoxMark = models.BitBoxMark,
|
//InspectStatus = models.InspectStatus，
|
ProductionTime = proTime,
|
ExpirationTime = expTime,
|
StoreTime = stortime,
|
EndLotFlag = string.IsNullOrWhiteSpace(models.EndBatchMark) ? "0" : models.EndBatchMark,
|
|
BoxNo2 = item.BoxNo2,
|
BoxNo3 = item2.BoxNo3,
|
QtyCount = item2.QtyCount,
|
QtyOrd = item2.QtyOrd,
|
|
Status = "0",
|
Level = level,
|
|
IsDelete = false
|
};
|
listBox.Add(boxAdd);
|
}
|
|
}
|
_db.Insertable(listBox).ExecuteCommand();
|
if (type == "edit")
|
{
|
//gen
|
_db.Deleteable(num).ExecuteCommand();
|
return new ResponseFuMaModel() { Success = "0", Message = "更新成功" };
|
}
|
return new ResponseFuMaModel() { Success = "0", Message = "插入成功" };
|
}
|
catch (Exception ex)
|
{
|
return new ResponseFuMaModel() { Success = "-1", Message = ex.Message };
|
}
|
}
|
|
/// <summary>
|
/// WCS接受赋码系统推送的箱码移除
|
/// </summary>
|
/// <param name="models">箱码信息</param>
|
/// <returns>反馈信息</returns>
|
[HttpPost]
|
[AllowAnonymous]
|
public ResponseFuMaModel DelgatesHttpBoxInfo(FumaBoxInfoInput models)
|
{
|
|
try
|
{
|
string str = JsonConvert.SerializeObject(models);
|
Log.Information("接收赋码推送的箱码移除：" + str);
|
var num = _db.Queryable<WcsBoxInfo>().Where(m => m.BoxNo == models.BoxNo && m.IsDelete == false).ToList();
|
if (num.Count > 0)
|
{
|
//WCS存在箱码信息，更新箱码信息(需判断箱码是否已组盘入库)
|
var num2 = num.Count(m => m.Status != "0" || !string.IsNullOrWhiteSpace(m.PalletNo));
|
if (num2 > 0)
|
{
|
throw new Exception("该箱已盘入库，不可更新信息");
|
}
|
}
|
if (num.Count == 0)
|
{
|
throw new Exception("未找到该箱码，箱码移除失败！");
|
}
|
|
_db.Deleteable(num).ExecuteCommand();
|
return new ResponseFuMaModel() { Success = "0", Message = "移除箱码成功" };
|
}
|
catch (Exception ex)
|
{
|
return new ResponseFuMaModel() { Success = "-1", Message = ex.Message };
|
}
|
}
|
|
/// <summary>
|
/// WCS接受赋码系统推送的结批总数量
|
/// </summary>
|
/// <param name="models">结批数量信息</param>
|
/// <returns>反馈信息</returns>
|
[HttpPost]
|
[AllowAnonymous]
|
public ResponseFuMaModel HttpTotalNum(FumaJiepiModel models)
|
{
|
|
try
|
{
|
string str = JsonConvert.SerializeObject(models);
|
Log.Information("接收赋码推送的完工结批总数量：" + str);
|
//查看赋码下发的任务信息是否正在分拣
|
var num = _db.Queryable<WcsCheckTask>().Where(m => m.SkuNo == models.SkuNo &&m.LotNo == models.LotNo && m.Status == "1").ToList();
|
if (num.Count < 1)
|
{
|
return new ResponseFuMaModel() { Success = "-1", Message = "该批次未进行分拣或已结批" };
|
}
|
|
//获取包装数量
|
int Fqty = int.Parse(models.FinishQty);
|
var boxinfolog = _db.Queryable<WcsBoxInfoLog>().Where(m => m.SkuNo == models.SkuNo && m.LotNo == models.LotNo && m.BitBoxMark == "0").First();
|
if (boxinfolog == null)
|
{
|
var boxinfo = _db.Queryable<WcsBoxInfo>().Where(m => m.SkuNo == models.SkuNo && m.LotNo == models.LotNo && m.BitBoxMark == "0").First();
|
Fqty = (int)(Fqty /boxinfo.QtyCount);
|
}
|
else
|
{
|
Fqty = (int)(Fqty / boxinfolog.QtyCount);
|
}
|
|
//写入该任务完成数量
|
foreach (var item in num)
|
{
|
item.FinishQty = Fqty;
|
}
|
_db.Updateable(num).ExecuteCommand();
|
|
return new ResponseFuMaModel() { Success = "0", Message = "接受完工结批数量成功" };
|
}
|
catch (Exception ex)
|
{
|
return new ResponseFuMaModel() { Success = "-1", Message = ex.Message };
|
}
|
}
|
|
}
|
