using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Mvc;
|
using WIDESEAWCS_Common.TaskEnum;
|
using WIDESEAWCS_Core;
|
using WIDESEAWCS_ITaskInfoRepository;
|
using WIDESEAWCS_ITaskInfoService;
|
using WIDESEAWCS_QuartzJob;
|
using WIDESEAWCS_TaskInfoRepository;
|
using WIDESEAWCS_TaskInfoService;
|
using WIDESEAWCS_Tasks.ElevatorJob;
|
|
namespace WIDESEAWCS_Server.Controllers.Task
|
{
|
[Route("/api/Elevator")]
|
[ApiController]
|
public class ElevatorController : ControllerBase
|
{
|
private readonly ITaskService _taskService;
|
private readonly ITaskRepository _taskRepository;
|
|
public ElevatorController(ITaskService taskService, ITaskRepository taskRepository)
|
{
|
_taskService = taskService;
|
_taskRepository = taskRepository;
|
}
|
|
/// <summary>
|
/// 停止
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost, HttpGet, Route("stopElevator"), AllowAnonymous]
|
public WebResponseContent StopElevator()
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
CommonElevator? commonElevator = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "TSJ1") as CommonElevator;
|
if (commonElevator != null)
|
{
|
commonElevator.SetValue<ElevatorDBName, short>(ElevatorDBName.StopElevator, 1);
|
Thread.Sleep(1000);
|
commonElevator.SetValue<ElevatorDBName, short>(ElevatorDBName.StopElevator, 0);
|
return content.OK("提升机停止成功");
|
}
|
return content.Error("失败");
|
}
|
catch (Exception ex)
|
{
|
return content.Error(ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 初始化提升机
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost, HttpGet, Route("initialization"), AllowAnonymous]
|
public WebResponseContent initialzationElevator()
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
CommonElevator? elevator = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "TSJ1") as CommonElevator;
|
if (elevator != null)
|
{
|
elevator.SetValue<ElevatorDBName, short>(ElevatorDBName.StopElevator, 1);
|
Thread.Sleep(1000);
|
elevator.SetValue<ElevatorDBName, short>(ElevatorDBName.StopElevator, 0);
|
Thread.Sleep(1000);
|
//获取提升机状态的显示 =0无状态；=1运行中；=2待机；=3报警
|
if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.ElevatorStatus) == 2)
|
{
|
//获取提升机手动/自动切换开关状态
|
if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.ManualAutoSwitch) == 1)
|
{
|
//获取提升机是否能允许初始化
|
if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.AllowInitialization) == 1)
|
{
|
if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.InitializationFlag) == 0)
|
{
|
if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.InitializationFlag) == 0)
|
{
|
elevator.SetValue<ElevatorDBName, short>(ElevatorDBName.InitializationTrigger, 1);
|
Thread.Sleep(1000);
|
elevator.SetValue<ElevatorDBName, short>(ElevatorDBName.InitializationTrigger, 0);
|
}
|
}
|
Thread.Sleep(1000);
|
if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.InitializationFlag) == 1)
|
{
|
Thread.Sleep(5000);
|
if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.InitializationFlag) == 0)
|
{
|
|
var TaskDouble = _taskRepository.QueryData(x => x.TaskState > (int)TaskAcrossFloorStatusEnum.CarryNew && x.TaskState < (int)TaskAcrossFloorStatusEnum.EndAddressExecuting && x.DoubleTray == 1);
|
var task = _taskRepository.QueryFirst(x => x.TaskState > (int)TaskAcrossFloorStatusEnum.CarryNew && x.TaskState < (int)TaskAcrossFloorStatusEnum.EndAddressExecuting);
|
if (TaskDouble.Count() > 0)
|
{
|
if (TaskDouble.First().Floor == "2F")
|
{
|
elevator.SetValue(ElevatorDBName.TaskNum, Convert.ToInt16(TaskDouble.First().TaskNum));
|
elevator.SetValue(ElevatorDBName.FlagBit, Convert.ToInt16(2));
|
elevator.SetValue(ElevatorDBName.StartFloor, Convert.ToInt16(1));
|
elevator.SetValue(ElevatorDBName.EdnFloor, Convert.ToInt16(2));
|
Thread.Sleep(1000);
|
elevator.SetValue(ElevatorDBName.StartCommand, Convert.ToInt16(1));
|
|
_taskService.SendAgvTask("AAA", TaskDouble.First().TaskNum);
|
_taskService.UpdateTaskStatusToNext(TaskDouble.First().TaskNum);
|
}
|
else
|
{
|
elevator.SetValue(ElevatorDBName.TaskNum, Convert.ToInt16(TaskDouble.First().TaskNum));
|
elevator.SetValue(ElevatorDBName.FlagBit, Convert.ToInt16(2));
|
elevator.SetValue(ElevatorDBName.StartFloor, Convert.ToInt16(2));
|
elevator.SetValue(ElevatorDBName.EdnFloor, Convert.ToInt16(1));
|
Thread.Sleep(1000);
|
elevator.SetValue(ElevatorDBName.StartCommand, Convert.ToInt16(1));
|
|
_taskService.SendAgvTask("DDD", TaskDouble.First().TaskNum);
|
_taskService.UpdateTaskStatusToNext(TaskDouble.First().TaskNum);
|
}
|
}
|
if (task != null)
|
{
|
if (task.Floor == "2F")
|
{
|
elevator.SetValue(ElevatorDBName.TaskNum, Convert.ToInt16(task.TaskNum));
|
elevator.SetValue(ElevatorDBName.FlagBit, Convert.ToInt16(2));
|
elevator.SetValue(ElevatorDBName.StartFloor, Convert.ToInt16(1));
|
elevator.SetValue(ElevatorDBName.EdnFloor, Convert.ToInt16(2));
|
Thread.Sleep(1000);
|
elevator.SetValue(ElevatorDBName.StartCommand, Convert.ToInt16(1));
|
|
_taskService.SendAgvTask("AAA", task.TaskNum);
|
_taskService.UpdateTaskStatusToNext(task.TaskNum);
|
}
|
else
|
{
|
elevator.SetValue(ElevatorDBName.TaskNum, Convert.ToInt16(task.TaskNum));
|
elevator.SetValue(ElevatorDBName.FlagBit, Convert.ToInt16(2));
|
elevator.SetValue(ElevatorDBName.StartFloor, Convert.ToInt16(2));
|
elevator.SetValue(ElevatorDBName.EdnFloor, Convert.ToInt16(1));
|
Thread.Sleep(1000);
|
elevator.SetValue(ElevatorDBName.StartCommand, Convert.ToInt16(1));
|
|
_taskService.SendAgvTask("DDD", task.TaskNum);
|
_taskService.UpdateTaskStatusToNext(task.TaskNum);
|
}
|
}
|
if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.InitializationFlag) == 0)
|
{
|
elevator.SetValue<ElevatorDBName, short>(ElevatorDBName.StartElevator, 1);
|
Thread.Sleep(2000);
|
elevator.SetValue<ElevatorDBName, short>(ElevatorDBName.StartElevator, 0);
|
|
}
|
}
|
}
|
|
}
|
}
|
}
|
return content.OK("提升机初始化成功");
|
|
}
|
return content.Error("失败");
|
}
|
catch (Exception ex)
|
{
|
return content.Error(ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 启动
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost, HttpGet, Route("startElevator"), AllowAnonymous]
|
public WebResponseContent StartElevator()
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
CommonElevator? commonElevator = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "TSJ1") as CommonElevator;
|
if (commonElevator != null)
|
{
|
if(commonElevator.GetValue<ElevatorDBName, short>(ElevatorDBName.AllowDeviceStartup) == 1)
|
{
|
commonElevator.SetValue<ElevatorDBName, short>(ElevatorDBName.StartElevator, 1);
|
Thread.Sleep(1000);
|
commonElevator.SetValue<ElevatorDBName, short>(ElevatorDBName.StartElevator, 0);
|
return content.OK("提升机启动成功");
|
}
|
else
|
{
|
return content.Error("提升机当前状态不允许启动");
|
}
|
|
}
|
return content.Error("失败");
|
}
|
catch (Exception ex)
|
{
|
return content.Error(ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 复位
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost, HttpGet, Route("resetElevator"), AllowAnonymous]
|
public WebResponseContent ResetElevator()
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
CommonElevator? commonElevator = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "TSJ1") as CommonElevator;
|
if (commonElevator != null)
|
{
|
commonElevator.SetValue<ElevatorDBName, short>(ElevatorDBName.ResetElevator, 1);
|
Thread.Sleep(1000);
|
commonElevator.SetValue<ElevatorDBName, short>(ElevatorDBName.ResetElevator, 0);
|
return content.OK("提升机启动成功");
|
}
|
return content.Error("失败");
|
}
|
catch (Exception ex)
|
{
|
return content.Error(ex.Message);
|
}
|
}
|
}
|
}
|
