using System;
|
using System.Linq;
|
using System.Web.Http;
|
using HH.WCS.Mobox3.RiDong.apiMethod;
|
using HH.WCS.Mobox3.RiDong.dispatch;
|
using HH.WCS.Mobox3.RiDong.dto;
|
using HH.WCS.Mobox3.RiDong.generalMethod;
|
using HH.WCS.Mobox3.RiDong.models;
|
using HH.WCS.Mobox3.RiDong.util;
|
using HH.WCS.Mobox3.RiDong.wms;
|
|
namespace HH.WCS.Mobox3.RiDong.api;
|
|
/// <summary>
|
/// 综合性接口
|
/// </summary>
|
public class SynthesizeController : ApiController
|
{
|
/// <summary>
|
/// 创建作业
|
/// </summary>
|
/// <remarks>存在中转货位（入库、出库、盘点入、盘点出）</remarks>
|
/// <returns></returns>
|
[HttpPost]
|
public ApiModel.SimpleResult AddOperation(OperationDto input)
|
{
|
return SynthesizeService.AddOperation(input);
|
}
|
|
/// <summary>
|
/// 作业取消
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost]
|
public ApiModel.SimpleResult CancelOperation(ApiModel.MoboxTaskBase model)
|
{
|
var result = new ApiModel.SimpleResult();
|
|
var operation = AdoSqlMethod<Operation>.QueryFirst(p => p.S_CODE == model.TaskNo && p.N_B_STATE != 7);
|
|
if (operation == null)
|
{
|
result.resultCode = -1;
|
result.resultMsg = "当前任务号不存在或任务已取消";
|
return result;
|
}
|
|
var tasks = AdoSqlMethod<Task>.QueryList(p => p.S_OP_CODE == operation.S_CODE);
|
|
// 当前任务数量和当前未执行的任务数量一致的情况下，允许取消任务
|
if (tasks.Count == tasks.Count(p => p.S_OP_CODE == operation.S_CODE && p.N_B_STATE < 3))
|
{
|
// 允许取消任务
|
foreach (var task in tasks)
|
{
|
// 判断任务
|
if (task.N_SCHEDULE_TYPE == 2 && task.N_B_STATE > 0 && task.N_B_STATE < 3)
|
{
|
// 通知agv取消任务
|
NDCHelper.Cancel(task.S_CODE.Trim());
|
}
|
|
task.N_B_STATE = 5;
|
task.S_B_STATE = "取消";
|
task.T_MODIFY = DateTime.Now;
|
task.T_END_TIME = DateTime.Now;
|
}
|
|
AdoSqlMethod<Task>.UpdateList(tasks, p => new { p.N_B_STATE, p.S_B_STATE, p.T_MODIFY, p.T_END_TIME });
|
|
operation.N_B_STATE = 7;
|
operation.S_B_STATE = "取消";
|
operation.T_MODIFY = DateTime.Now;
|
operation.T_END_TIME = DateTime.Now;
|
|
AdoSqlMethod<Operation>.UpdateFirst(operation,
|
p => new { p.N_B_STATE, p.S_B_STATE, p.T_MODIFY, p.T_END_TIME });
|
|
var container = AdoSqlMethod<Container>.QueryFirst(p => p.S_CODE == operation.S_CNTR_CODE);
|
|
// 修改容器状态
|
container.T_MODIFY = DateTime.Now;
|
container.N_LOCK_STATE = 0;
|
|
string loc = "";
|
// 解锁
|
if (operation.N_TYPE == 1 || operation.N_TYPE == 3)
|
{
|
container.C_ENABLE = 'N';
|
loc = operation.S_END_LOC;
|
}
|
else if (operation.N_TYPE == 2 || operation.N_TYPE == 4 || operation.N_TYPE == 5 || operation.N_TYPE == 6 || operation.N_TYPE == 7)
|
{
|
container.C_ENABLE = 'Y';
|
loc = operation.S_START_LOC;
|
}
|
|
LocationHelper.UnLockLoc(loc);
|
|
AdoSqlMethod<Container>.UpdateFirst(container, p => new { p.C_ENABLE, p.T_MODIFY, p.N_LOCK_STATE });
|
|
result.resultCode = 0;
|
result.resultMsg = "任务取消成功";
|
return result;
|
}
|
|
result.resultCode = -1;
|
result.resultMsg = "作业正在执行中，不可取消";
|
return result;
|
}
|
|
/// <summary>
|
/// 任务优先级
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
public ApiModel.SimpleResult TaskPriority(ApiModel.MoboxTaskBase model)
|
{
|
|
var result = new ApiModel.SimpleResult();
|
|
var operation = AdoSqlMethod<Operation>.QueryFirst(p => p.S_CODE == model.TaskNo);
|
|
if (operation == null)
|
{
|
result.resultCode = -1;
|
result.resultMsg = $"作业不存在！，传递的任务号为{model.TaskNo}";
|
return result;
|
}
|
|
// 任务存在，判断任务类型
|
if (operation.N_TYPE is 1 or 3)
|
{
|
result.resultCode = -1;
|
result.resultMsg = "入库类型任务无法提升优先级";
|
return result;
|
}
|
|
var task = AdoSqlMethod<Task>.QueryFirst(p =>
|
p.S_OP_CODE == operation.S_CODE && p.N_B_STATE < 2 && p.N_SCHEDULE_TYPE == 2);
|
|
if (task == null)
|
{
|
result.resultCode = -1;
|
result.resultMsg = "当前任务已完结或出错，无法提升优先级";
|
return result;
|
}
|
|
// 未推送
|
if (task.N_B_STATE == 0)
|
{
|
task.N_PRIORITY = 99;
|
AdoSqlMethod<Task>.UpdateFirst(task, p => new { p.N_PRIORITY });
|
}
|
else
|
{
|
// 已推送，修改
|
// 让agv放货
|
NDCHelper.ChangePri(task.S_CODE, 99);
|
}
|
|
result.resultCode = 0;
|
result.resultMsg = "优先级修改成功";
|
return result;
|
}
|
|
/// <summary>
|
/// 测试接口
|
/// </summary>
|
/// <param name="type"></param>
|
/// <returns></returns>
|
public Location QueryStereoscopicStorehouseLocation(string type)
|
{
|
var location = LocationMethod.QueryStereoscopicStorehouseLocation(type);
|
|
// 加锁
|
LocationHelper.LockLoc(location.S_CODE, 1);
|
|
return location;
|
}
|
}
|
