using AutoMapper;
|
using LogLibrary.Log;
|
using Newtonsoft.Json;
|
using WIDESEAWCS_Common.TaskEnum;
|
using WIDESEAWCS_Core;
|
using WIDESEAWCS_DTO.AGV;
|
using WIDESEAWCS_DTO.TaskInfo;
|
using WIDESEAWCS_IBasicInfoRepository;
|
using WIDESEAWCS_ITaskInfoRepository;
|
using WIDESEAWCS_ITaskInfoService;
|
using WIDESEAWCS_Model.Models;
|
using WIDESEAWCS_QuartzJob;
|
using WIDESEAWCS_Tasks.ConveyorLineJob;
|
|
namespace WIDESEAWCS_Tasks.AGV
|
{
|
public class AGVSignal:IAGVSignal
|
{
|
private readonly ITaskRepository _taskRepository;
|
private readonly ITask_HtyRepository _taskhtyRepository;
|
private readonly ITaskService _taskService;
|
private readonly IDt_StationManagerRepository _stationManagerRepository;
|
private readonly IMapper _mapper;
|
|
public AGVSignal(ITaskRepository taskRepository, ITaskService taskService,IDt_StationManagerRepository stationManagerRepository,ITask_HtyRepository taskhtyRepository, IMapper mapper)
|
{
|
_taskRepository = taskRepository;
|
_taskService = taskService;
|
_stationManagerRepository = stationManagerRepository;
|
_taskhtyRepository = taskhtyRepository;
|
_mapper = mapper;
|
}
|
#region AGV与设备信号交互
|
|
/// <summary>
|
/// AGV--设备交互
|
/// </summary>
|
/// <returns></returns>
|
public WebResponseContent SignalInteraction(AGVReceiveDTO receiveDTO)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
LogFactory.WriteInfo($"AGV状态上报", $"参数【{JsonConvert.SerializeObject(receiveDTO)}】{Environment.NewLine}{Environment.NewLine}");
|
var task = _taskRepository.QueryFirst(t => t.TaskNum == Convert.ToInt32(receiveDTO.orderId));
|
if (task == null)
|
{
|
return content.Error("未找到任务");
|
}
|
|
CommonConveyorLine? commonConveyorLine = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "1001") as CommonConveyorLine;
|
CommonElevator? elevator = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "TSJ1") as CommonElevator;
|
switch (receiveDTO.status)
|
{
|
//case 20:
|
// content = RequestPickUp(task, commonConveyorLine, elevator);
|
// break;
|
//case 21:
|
// content = PickUpFinish(task, commonConveyorLine, elevator);
|
// break;
|
//case 22:
|
// content = RequestPut(task, commonConveyorLine, elevator);
|
// break;
|
//case 8:
|
// content = PutFinish(task, commonConveyorLine, elevator);
|
// break;
|
default:
|
content.Error("未知状态");
|
break;
|
}
|
LogFactory.WriteInfo($"AGV状态上报", $"返回参数【{JsonConvert.SerializeObject(content)}】{Environment.NewLine}{Environment.NewLine}");
|
return content;
|
}
|
catch (Exception ex)
|
{
|
return content.Error(ex.Message);
|
}
|
}
|
|
///// <summary>
|
///// 放货完成
|
///// </summary>
|
///// <param name="task"></param>
|
///// <returns></returns>
|
//public WebResponseContent PutFinish(Dt_Task task, CommonConveyorLine commonConveyorLine, CommonElevator elevator)
|
//{
|
// WebResponseContent content = new WebResponseContent();
|
// try
|
// {
|
|
// if (task.TaskState == (int)TaskAcrossFloorStatusEnum.FirstCarry)
|
// {
|
// if (task.Floor == "1F")
|
// {
|
// elevator.SetValue(ElevatorDBName.OneLayerPutFinish, 1);
|
// }
|
// else
|
// {
|
// elevator.SetValue(ElevatorDBName.TwoLayerPutFinish, 1);
|
// }
|
// _taskService.UpdateTaskStatusToNext(task.TaskNum);
|
// content.OK();
|
// }
|
// else if (task.TaskState == (int)TaskAcrossFloorStatusEnum.EndAddressExecuting)
|
// {
|
// _taskService.UpdateTaskStatusToNext(task.TaskNum);
|
// content.OK();
|
// }
|
// else if (task.TaskState.GetTaskStateGroup() == TaskStateGroup.CarryGroup)
|
// {
|
// _taskService.UpdateTaskStatusToNext(task.TaskNum);
|
// }
|
|
// if (task.TaskState.GetTaskStateGroup() == TaskStateGroup.RelocationGroup)
|
// {
|
// _taskService.UpdateTaskStatusToNext(task.TaskNum);
|
// }
|
// if (task.TaskState.GetTaskStateGroup() == TaskStateGroup.OutbondGroup)
|
// {
|
// if (task.TaskState == (int)TaskOutStatusEnum.AGV_OutExecuting)
|
// {
|
// _taskService.UpdateTaskStatusToNext(task.TaskNum);
|
// }
|
// }
|
// else if (task.TaskState.GetTaskStateGroup() == TaskStateGroup.InboundGroup)
|
// {
|
// commonConveyorLine.SetValue(ConveyorLineDBName.PutFinish, 1, "LK001");
|
|
// _taskService.UpdateTaskStatusToNext(task.TaskNum);
|
// content.OK();
|
// }
|
// }
|
// catch (Exception ex)
|
// {
|
// content.Error(ex.Message);
|
// }
|
// return content;
|
//}
|
|
///// <summary>
|
///// 取货完成
|
///// </summary>
|
///// <param name="task"></param>
|
///// <returns></returns>
|
//public WebResponseContent PickUpFinish(Dt_Task task, CommonConveyorLine commonConveyorLine, CommonElevator elevator)
|
//{
|
// WebResponseContent content = new WebResponseContent();
|
// try
|
// {
|
// if (task.TaskState == (int)TaskAcrossFloorStatusEnum.SecondCarry)
|
// {
|
// if (task.Floor == "1F")
|
// {
|
// elevator.SetValue(ElevatorDBName.OneLayerPickUpFinish, 1);
|
// }
|
// else
|
// {
|
// elevator.SetValue(ElevatorDBName.TwoLayerPickUpFinish, 1);
|
// }
|
|
// _taskService.UpdateTaskStatusToNext(task.TaskNum);
|
// content.OK();
|
// }
|
// if (task.TaskState.GetTaskStateGroup() == TaskStateGroup.OutbondGroup)
|
// {
|
// commonConveyorLine.SetValue(ConveyorLineDBName.PickUpFinish, 1, "LK001");
|
// _taskService.UpdateTaskStatusToNext(task.TaskNum);
|
// content.OK();
|
// }
|
// }
|
// catch (Exception ex)
|
// {
|
// content.Error(ex.Message);
|
// }
|
// return content;
|
//}
|
|
///// <summary>
|
///// 请求取货
|
///// </summary>
|
///// <param name="task"></param>
|
///// <returns></returns>
|
//public WebResponseContent RequestPickUp(Dt_Task task, CommonConveyorLine commonConveyorLine, CommonElevator elevator)
|
//{
|
// WebResponseContent content = new WebResponseContent();
|
// try
|
// {
|
|
// if (task.TaskState == (int)TaskAcrossFloorStatusEnum.SecondCarry)
|
// {
|
// if (task.Floor == "1F")
|
// {
|
// if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.OneLayerAllowPickUp) == 1)
|
// {
|
// _taskService.ContinueAgvTask(task.AGVTaskNum);
|
// content.OK();
|
// }
|
// else
|
// {
|
// task.AGVSign = "RequestPickUp";
|
// _taskRepository.UpdateData(task);
|
// content.Error("设备不允许取货");
|
// }
|
// }
|
// else
|
// {
|
// if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.TwoLayerAllowPickUp) == 1)
|
// {
|
// _taskService.ContinueAgvTask(task.AGVTaskNum);
|
// content.OK();
|
// }
|
// else
|
// {
|
// task.AGVSign = "RequestPickUp";
|
// _taskRepository.UpdateData(task);
|
// content.Error("设备不允许取货");
|
// }
|
// }
|
// }
|
// if (task.TaskState.GetTaskStateGroup() == TaskStateGroup.OutbondGroup)
|
// {
|
// if (commonConveyorLine.GetValue<ConveyorLineDBName, short>(ConveyorLineDBName.AllowPickUp, "LK001") == 1)
|
// {
|
// _taskService.ContinueAgvTask(task.AGVTaskNum);
|
// _taskService.UpdateTaskStatusToNext(task.TaskNum);
|
// content.OK();
|
// }
|
// else
|
// {
|
// task.AGVSign = "RequestPickUp";
|
// _taskRepository.UpdateData(task);
|
// content.Error("设备不允许取货");
|
// }
|
// }
|
// }
|
// catch (Exception ex)
|
// {
|
// task.AGVSign = "RequestPickUp";
|
// _taskRepository.UpdateData(task);
|
// content.Error(ex.Message);
|
// }
|
// return content;
|
//}
|
|
///// <summary>
|
///// 请求放货
|
///// </summary>
|
///// <param name="task"></param>
|
///// <returns></returns>
|
//public WebResponseContent RequestPut(Dt_Task task, CommonConveyorLine commonConveyorLine, CommonElevator elevator)
|
//{
|
// WebResponseContent content = new WebResponseContent();
|
// try
|
// {
|
|
// if (task.TaskState == (int)TaskAcrossFloorStatusEnum.FirstCarry)
|
// {
|
// if (task.Floor == "1F")
|
// {
|
// if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.OneLayerAllowPut) == 1)
|
// {
|
// _taskService.ContinueAgvTask(task.AGVTaskNum);
|
// content.OK();
|
// }
|
// else
|
// {
|
// task.AGVSign = "RequestPut";
|
// _taskRepository.UpdateData(task);
|
// content.Error("设备不允许放货");
|
// }
|
// }
|
// else
|
// {
|
// if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.TwoLayerAllowPut) == 1)
|
// {
|
// _taskService.ContinueAgvTask(task.AGVTaskNum);
|
// content.OK();
|
// }
|
// else
|
// {
|
// task.AGVSign = "RequestPut";
|
// _taskRepository.UpdateData(task);
|
// content.Error("设备不允许放货");
|
// }
|
// }
|
// }
|
// if (task.TaskState.GetTaskStateGroup() == TaskStateGroup.InboundGroup)
|
// {
|
// if (commonConveyorLine.GetValue<ConveyorLineDBName, short>(ConveyorLineDBName.AllowPut, "LK001") == 1)
|
// {
|
// _taskService.ContinueAgvTask(task.AGVTaskNum);
|
// content.OK();
|
// }
|
// else
|
// {
|
// task.AGVSign = "RequestPut";
|
// _taskRepository.UpdateData(task);
|
// content.Error("设备不允许取货");
|
// }
|
|
// }
|
|
// }
|
// catch (Exception ex)
|
// {
|
// task.AGVSign = "RequestPut";
|
// _taskRepository.UpdateData(task);
|
// content.Error(ex.Message);
|
// }
|
// return content;
|
//}
|
|
#endregion
|
|
}
|
}
|
