using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using WIDESEA_Common;
|
using WIDESEA_Common.TaskEnum;
|
using WIDESEA_Common.Tools;
|
using WIDESEA_Core.Utilities;
|
using WIDESEA_Entity.CustomModels.RGVModel;
|
using WIDESEA_Entity.DomainModels;
|
using WIDESEA_Services;
|
using WIDESEA_Services.IRepositories;
|
using WIDESEA_Services.Services.APIInvoke.RGV;
|
|
namespace WIDESEA_WCS
|
{
|
public partial class RgvDispatchJob
|
{
|
|
public static void SendRGVTaskAction(Dt_TaskRGVinfo rgvTask, Dt_TaskWCSinfo wcsInfo, IDt_TaskRGVinfoRepository taskRGVinfoRepository, IDt_TaskWCSinfoRepository taskWCSinfoRepository)
|
{
|
|
RgvSendTaskModel taskInfo = new RgvSendTaskModel();
|
int typeV = -1;
|
if (rgvTask.rgvtask_taskType == RGVTaskType.RgvTaskType_Inbound.ToString())
|
typeV = 1;
|
else if (rgvTask.rgvtask_taskType == RGVTaskType.RgvTaskType_Outbound.ToString())
|
typeV = 2;
|
else if (rgvTask.rgvtask_taskType == RGVTaskType.RgvTaskType_Move.ToString())
|
typeV = 3;
|
|
//组装RGV任务
|
List<RgvSendTaskModel> taskList = new List<RgvSendTaskModel>();
|
RgvSendTaskModel taskModel = new RgvSendTaskModel();
|
taskModel.taskId = rgvTask.rgvtask_taskId;
|
taskModel.taskType = typeV;
|
taskModel.containerNo = rgvTask.rgvtask_barCode;
|
string sourceNode = "";
|
|
if (rgvTask.rgvtask_startNode.Contains("-"))
|
sourceNode = rgvTask.rgvtask_startNode.Replace("-", "");
|
else//转换站台与货位
|
sourceNode = ConvertStationToLocationId.Convert_Station_To_LocationId(rgvTask.rgvtask_startNode);
|
taskModel.source = sourceNode;
|
|
string endNode = "";
|
if (rgvTask.rgvtask_endNode.Contains("-"))
|
endNode = rgvTask.rgvtask_endNode.Replace("-", "");
|
else//转换站台与货位
|
endNode = ConvertStationToLocationId.Convert_Station_To_LocationId(rgvTask.rgvtask_endNode);
|
taskModel.target = endNode;
|
taskModel.priority = int.Parse(rgvTask.rgvtask_priorityCode);
|
taskList.Add(taskModel);
|
|
//发送任务给RGV
|
WebResponseContent content = RGVAPIInvokeSendTask.SendTaskToRGV(taskList);
|
if (content.Status)
|
{
|
RgvReturnModel model = (RgvReturnModel)content.Data;
|
if (model.code == 0)
|
{
|
taskRGVinfoRepository.DbContextBeginTransaction(() =>
|
{
|
rgvTask.rgvtask_dispatchertime = DateTime.Now;
|
rgvTask.rgvtask_taskStatus = RGVTaskState.RgvTaskState_Had_Sended.ToString();
|
if (null != wcsInfo)
|
{
|
wcsInfo.wcstask_state = TaskState.TaskState_RGV_Received.ToString();
|
wcsInfo.wcstask_dispatcherTime = DateTime.Now;
|
taskWCSinfoRepository.Update(wcsInfo, true);
|
}
|
//在此处事务更新
|
taskRGVinfoRepository.Update(rgvTask, true);
|
//Wms更新
|
WMSApi.PostTaskStateToWMS(rgvTask.rgvtask_barCode, TaskState.TaskState_RGV_Received.ToString());
|
return content.OK();
|
});
|
|
}
|
}
|
|
}
|
}
|
}
|
