using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Mvc;
|
using System;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using WIDESEA_Core.Utilities;
|
using WIDESEA_Entity.DomainModels;
|
using WIDESEA_WCS;
|
|
namespace WIDESEA_WCSServer.Controllers.ToWMS
|
{
|
[Route("api/ToWMS")]
|
[ApiController]
|
public class ToWMSController : ControllerBase
|
{
|
/// <summary>
|
/// 添加agv任务
|
/// </summary>
|
/// <param name="taskinfo"></param>
|
/// <returns></returns>
|
//[HttpPost, Route("AddAgvTask"), AllowAnonymous]
|
//public WebResponseContent AddAgvTask([FromBody] dt_agvtask task)
|
//{
|
// return new WCSHelpServer().AddAgvTask(task);
|
//}
|
|
/// <summary>
|
/// WMS修改设备状态调用接口同步WCS设备状态并暂停调度
|
/// </summary>
|
/// <param name="saveModel"></param>
|
/// <returns></returns>
|
[HttpPost, HttpGet, Route("UpdateEquipState"), AllowAnonymous]
|
public async Task<WebResponseContent> UpdateEquipState([FromBody] SaveModel saveModel)
|
{
|
return await Task.Run(() =>
|
{
|
return WCSService.PauseOrResumeJob(saveModel);
|
});
|
}
|
|
[HttpPost, Route("WriteOrReadPLCData"), AllowAnonymous]
|
public object WriteOrReadPLCData([FromBody] PLCInfo info)
|
{
|
try
|
{
|
var client = WIDESEA_WCS.WCSService.Clients?.FirstOrDefault(t => t.PLCName == info.plcName);
|
if (client == null)
|
{
|
throw new Exception("plcName不存在或未连接！");
|
}
|
if (info.type == "r")
|
{
|
if (client.PLCType == "SiemensPLC")
|
{
|
if (info.dataType == "int")
|
{
|
info.value = client.SiemensPLCClient.Read<ushort>(info.address);
|
}
|
else if (info.dataType == "string")
|
{
|
info.value = client.SiemensPLCClient.Read<string>(info.address, info.len);
|
}
|
else if (info.dataType == "bool")
|
{
|
info.value = client.SiemensPLCClient.Read<bool>(info.address);
|
}
|
else if (info.dataType == "byte[]")
|
{
|
info.value = string.Join(',', client.SiemensPLCClient.Read<byte[]>(info.address, info.len).ToArray());
|
}
|
else
|
{
|
throw new Exception($"数据类型{info.dataType},未定义");
|
}
|
}
|
else if (client.PLCType == "OmronPLC")
|
{
|
if (info.dataType == "int")
|
{
|
info.value = client.SiemensPLCClient.Read<ushort>(info.address);
|
}
|
else if (info.dataType == "string")
|
{
|
info.value = client.SiemensPLCClient.Read<string>(info.address, info.len);
|
}
|
else if (info.dataType == "bool")
|
{
|
info.value = client.SiemensPLCClient.Read<bool>(info.address);
|
}
|
else if (info.dataType == "byte[]")
|
{
|
info.value = string.Join(',', client.SiemensPLCClient.Read<byte[]>(info.address, info.len).ToArray());
|
}
|
else
|
{
|
throw new Exception($"操作类型{info.dataType},未定义");
|
}
|
}
|
else
|
{
|
throw new Exception($"PLC类型{client.PLCType},未定义");
|
}
|
}
|
else if (info.type == "w")
|
{
|
throw new Exception("为安全起见，不能进行写操作！");
|
}
|
else
|
{
|
throw new Exception("操作类型不存在！");
|
}
|
}
|
catch (Exception ex)
|
{
|
return info.Error(ex.Message);
|
}
|
return info.Success();
|
}
|
|
|
/// <summary>
|
/// 获取AGV状态
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost, Route("GetAgvStatusData"), AllowAnonymous]
|
public WebResponseContent GetAgvStatusData([FromBody] SaveModel model)
|
{
|
return AGVData.GetAgvStatusData(model);
|
}
|
private static object gvTaskInfozz = new object();
|
/// <summary>
|
/// 树形任务完成量组装
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost, Route("GetAgvTaskInfozz"), AllowAnonymous]
|
public WebResponseContent GetAgvTaskInfozz([FromBody] SaveModel model)
|
{
|
lock (gvTaskInfozz)
|
{
|
return AGVData.GetAgvTaskInfozz(model);
|
}
|
|
}
|
private static object gvTaskInfozj = new object();
|
/// <summary>
|
/// 树形任务完成量组装
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost, Route("GetAgvTaskInfozj"), AllowAnonymous]
|
public WebResponseContent GetAgvTaskInfozj([FromBody] SaveModel model)
|
{
|
lock (gvTaskInfozj)
|
{
|
return AGVData.GetAgvTaskInfozj(model);
|
}
|
|
}
|
private static object gvTaskInfofj = new object();
|
/// <summary>
|
/// 树形任务完成量组装
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost, Route("GetAgvTaskInfofj"), AllowAnonymous]
|
public WebResponseContent GetAgvTaskInfofj([FromBody] SaveModel model)
|
{
|
lock (gvTaskInfofj)
|
{
|
return AGVData.GetAgvTaskInfofj(model);
|
}
|
|
}
|
/// <summary>
|
/// 获取空货位或者有货货位
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost, Route("GetLocationEmptyOrStored"), AllowAnonymous]
|
public WebResponseContent GetLocationEmptyOrStored([FromBody] SaveModel model)
|
{
|
return AGVData.GetLocationEmptyOrStored(model);
|
}
|
|
/// <summary>
|
/// 获取区域货位数据
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost, Route("GetLocationData"), AllowAnonymous]
|
public WebResponseContent GetLocationData([FromBody] SaveModel model)
|
{
|
return AGVData.GetLocationData(model);
|
}
|
|
/// <summary>
|
/// 获取AGV任务
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost, Route("GetAGVTaskData"), AllowAnonymous]
|
public WebResponseContent GetAGVTaskData([FromBody] SaveModel model)
|
{
|
return AGVData.GetAGVTaskData(model);
|
}
|
|
/// <summary>
|
/// 获取提升机信息
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost, Route("GetTSJInfo"), AllowAnonymous]
|
public WebResponseContent GetTSJInfo([FromBody] SaveModel model)
|
{
|
return AGVData.GetTSJInfo(model);
|
}
|
|
/// <summary>
|
/// 获取多个提升机信息
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
//[HttpPost, Route("GetTSJInfos"), AllowAnonymous]
|
//public WebResponseContent GetTSJInfos([FromBody] SaveModel model)
|
//{
|
// return AGVData.GetTSJInfos(model);
|
//}
|
}
|
|
public class PLCInfo
|
{
|
/// <summary>
|
/// 读取r，写入w
|
/// </summary>
|
public string type { get; set; } = "r";
|
|
/// <summary>
|
/// 指令
|
/// </summary>
|
public string address { get; set; }
|
|
public int len { get; set; }
|
|
/// <summary>
|
/// PLC名称
|
/// </summary>
|
public string plcName { get; set; }
|
|
public string dataType { get; set; }
|
|
|
|
|
/// <summary>
|
/// 读取或写入的值
|
/// </summary>
|
public object value { get; set; }
|
|
|
/// <summary>
|
/// 操作结果，和错误信息
|
/// </summary>
|
public string msg { get; set; }
|
|
public PLCInfo Error(string msg)
|
{
|
this.msg = "操作失败，" + msg;
|
return this;
|
}
|
|
public PLCInfo Success(string msg = null)
|
{
|
if (msg != null)
|
this.msg = msg;
|
return this;
|
}
|
}
|
}
|
