using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEAWCS_Core;
|
using WIDESEAWCS_Core.Helper;
|
using WIDESEAWCS_DTO.WMSInfo;
|
using WIDESEAWCS_Model.Models;
|
using WIDESEAWCS_QuartzJob;
|
using WIDESEAWCS_QuartzJob.DTO;
|
using WIDESEAWCS_QuartzJob.Models;
|
using WIDESEAWCS_Tasks.ProductionLineJob;
|
|
namespace WIDESEAWCS_Tasks
|
{
|
public partial class CommonProductionLineJob
|
{
|
/// <summary>
|
/// 入库产线
|
/// </summary>
|
/// <param name="conveyorLine"></param>
|
/// <returns></returns>
|
public void ProductionLineIn(OtherDevice ProductionLine)
|
{
|
foreach (var item in ProductionLine.DeviceProDTOs.GroupBy(x => x.DeviceChildCode))
|
{
|
var request = ProductionLine.GetValue<ProductionLineDBName, short>(ProductionLineDBName.request, item.Key);
|
if (request == 1)
|
{
|
var traytype = ProductionLine.GetValue<ProductionLineDBName, short>(ProductionLineDBName.trayType, item.Key);
|
var content = Request(ProductionLine, traytype, item.Key);
|
|
if (content.Status) ProductionLine.SetValue(ProductionLineDBName.Wrequest, 1, item.Key);
|
}
|
}
|
}
|
/// <summary>
|
/// 出库产线
|
/// </summary>
|
/// <param name="ProductionLine"></param>
|
public void ProductionLineOut(OtherDevice ProductionLine)
|
{
|
foreach (var item in ProductionLine.DeviceProDTOs.GroupBy(x => x.DeviceChildCode))
|
{
|
var request = ProductionLine.GetValue<ProductionLineDBName, short>(ProductionLineDBName.request, item.Key);
|
if (request == 1)
|
{
|
bool ok = false;
|
var traytype = ProductionLine.GetValue<ProductionLineDBName, short>(ProductionLineDBName.trayType, item.Key);
|
if (traytype == 2 || traytype == 4 || traytype == 6)
|
ok = Request(ProductionLine, traytype, item.Key).Status;
|
else
|
{
|
var task = _taskService.QuertOutProductionLineTask(true);
|
if (task != null)
|
{
|
//if (task.Remark.ObjToInt() == traytype)
|
if (!string.IsNullOrEmpty(task.Remark) && traytype == 5)
|
{
|
task.TargetAddress = item.Key;
|
task.NextAddress = item.Key;
|
ok = _taskService.UpdateData(task).Status;
|
}
|
}
|
}
|
if (ok) ProductionLine.SetValue(ProductionLineDBName.Wrequest, 1, item.Key);
|
}
|
}
|
}
|
/// <summary>
|
/// 申请
|
/// </summary>
|
/// <param name="ProductionLine">产线</param>
|
/// <param name="traytype">托盘类型</param>
|
/// <param name="station">站台号</param>
|
/// <returns></returns>
|
public WebResponseContent Request(OtherDevice ProductionLine, short traytype, string station)
|
{
|
WebResponseContent response = new WebResponseContent();
|
ProductionLineDTO MaterielGroupDTO = new ProductionLineDTO();
|
try
|
{
|
switch (traytype)
|
{
|
case 1://放空托
|
case 3://放空盒
|
//case 5://放满盒
|
{
|
MaterielGroupDTO.stationCode = station;
|
MaterielGroupDTO.traytype = traytype;
|
}
|
break;
|
case 2://取空托
|
case 4://取满盒
|
case 6://取空盒
|
{
|
MaterielGroupDTO.Barcode = ProductionLine.GetValue<ProductionLineDBName, string>(ProductionLineDBName.trayBarcode, station);
|
MaterielGroupDTO.stationCode = station;
|
MaterielGroupDTO.traytype = traytype;
|
if (traytype == 4)
|
{
|
#region 读取数量
|
//var productQtyadd = ProductionLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceProParamName == ProductionLineDBName.productQty.ToString() && x.DeviceChildCode == station);
|
//var productQty = ProductionLine.Communicator.Read<short>(productQtyadd.DeviceProAddress, (ushort)productQtyadd.DeviceProDataLength);
|
//#endregion
|
|
//#region 写入数量
|
//var WproductQtyadd = ProductionLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceProParamName == ProductionLineDBName.WproductQty.ToString() && x.DeviceChildCode == station);
|
//ProductionLine.Communicator.Write(WproductQtyadd.DeviceProAddress, productQty);
|
#endregion
|
|
MaterielGroupDTO.batchNo = ProductionLine.GetValue<ProductionLineDBName, string>(ProductionLineDBName.batchNo, station);
|
//MaterielGroupDTO.productQty = string.Join(",", productQty);
|
}
|
}
|
break;
|
#region MyRegion
|
//case 3://放空盒
|
// {
|
// MaterielGroupDTO.stationCode = station;
|
// MaterielGroupDTO.traytype = traytype;
|
// }
|
// break;
|
//case 4://取满盒
|
// {
|
// //var productQty = ProductionLine.GetValue<ProductionLineDBName, short>(ProductionLineDBName.productQty, station);
|
// #region 读取数量
|
// var productQtyadd = ProductionLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceProParamName == ProductionLineDBName.productQty.ToString() && x.DeviceChildCode == station);
|
// var productQty = ProductionLine.Communicator.Read<short>(productQtyadd.DeviceProAddress, (ushort)productQtyadd.DeviceProDataLength);
|
// #endregion
|
|
// #region 写入数量
|
// var WproductQtyadd = ProductionLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceProParamName == ProductionLineDBName.WproductQty.ToString() && x.DeviceChildCode == station);
|
// ProductionLine.Communicator.Write(WproductQtyadd.DeviceProAddress, productQty);
|
// #endregion
|
|
// var batchNo = ProductionLine.GetValue<ProductionLineDBName, string>(ProductionLineDBName.batchNo, station);
|
// var trayBarcode = ProductionLine.GetValue<ProductionLineDBName, string>(ProductionLineDBName.trayBarcode, station);
|
|
// MaterielGroupDTO.batchNo = batchNo;
|
// MaterielGroupDTO.Barcode = trayBarcode;
|
// MaterielGroupDTO.stationCode = station;
|
// MaterielGroupDTO.traytype = traytype;
|
// MaterielGroupDTO.productQty = string.Join(",", productQty);
|
// }
|
// break;
|
//case 5://放满盒
|
// {
|
// MaterielGroupDTO.stationCode = station;
|
// MaterielGroupDTO.traytype = traytype;
|
// }
|
// break;
|
//case 6://取空盒
|
// {
|
|
// }
|
// break;
|
#endregion
|
default:
|
throw new Exception("未定义托盘类型");
|
}
|
|
response = ProductionLineToWMSRequest(MaterielGroupDTO);
|
}
|
catch (Exception ex)
|
{
|
response.Error(ex.Message);
|
}
|
return response;
|
}
|
|
public WebResponseContent ProductionLineToWMSRequest(ProductionLineDTO MaterielGroupDTO)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
var ResultData = HttpHelper.PostAsync(WMSInterfaceAddress.ProductionlineRequest, MaterielGroupDTO.ToJson(), headers: new Dictionary<string, string>());
|
if (ResultData.Result == null) throw new Exception($"产线向WMS请求超时");
|
|
content = JsonConvert.DeserializeObject<WebResponseContent>(ResultData.Result);
|
|
#region 产线申请入库任务
|
if (content != null && content.Status)//任务转换
|
{
|
var task = JsonConvert.DeserializeObject<Dt_Task>(content.Data.ToJson());
|
if (task != null)
|
{
|
List<int> TaskNums = new List<int>();
|
List<Dt_Router> routers = _routerService.QueryNextRoutes(task.CurrentAddress, task.TargetAddress);
|
if (routers.Count > 0)
|
{
|
task.NextAddress = routers.FirstOrDefault().ChildPosi;
|
}
|
task.WMSId = task.TaskId;
|
task.Creater = "WMS";
|
task.Dispatchertime = null;
|
task.CreateDate = DateTime.Now;
|
content = _taskService.AddData(task);
|
TaskNums.Add(task.TaskNum);
|
_taskExecuteDetailService.AddTaskExecuteDetail(TaskNums, "接收WMS任务");
|
}
|
}
|
#endregion
|
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
}
|
}
|
