using Newtonsoft.Json;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Security.Policy;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_Comm.LogInfo;
|
using WIDESEA_Common;
|
using WIDESEA_Core.EFDbContext;
|
using WIDESEA_Core.FreeDB;
|
using WIDESEA_Entity.DomainModels;
|
using WIDESEA_Entity.ToAGV;
|
using WIDESEA_WMS.IRepositories;
|
using WIDESEA_WMS.Repositories;
|
|
namespace WIDESEA_WMS.Common
|
{
|
public partial class AGVServer
|
{
|
|
/// <summary>
|
/// 任务下发
|
/// </summary>
|
public static void SendAgvTask()
|
{
|
Respone respone = new Respone();
|
RequestTask requestTask = new RequestTask();
|
string postJson = string.Empty;
|
string report = string.Empty;
|
try
|
{
|
VOLContext Context = new VOLContext();
|
Idt_agvtaskRepository agvtaskRepository = new dt_agvtaskRepository(Context);
|
var agv_tasks = agvtaskRepository.Find(x => x.agv_taskstate == "Create" && string.IsNullOrEmpty(x.agv_remark)).OrderByDescending(x => x.agv_grade)
|
.ThenBy(x => x.agv_createtime).ToList();
|
if (agv_tasks.Count < 1)
|
agv_tasks = agvtaskRepository.Find(x => x.agv_taskstate == "Create" && !string.IsNullOrEmpty(x.agv_remark)).OrderByDescending(x => x.agv_grade)
|
.ThenBy(x => x.agv_createtime).ToList();
|
if (agv_tasks.Count > 0)
|
{
|
foreach (var agv_task in agv_tasks)
|
{
|
var Materiel = QueryData.QueryMateriel(agv_task.agv_materielid);//查找车轮数据
|
var Materiel1 = QueryData.QueryMateriel1(agv_task.agv_materielid);//查找车轮数据
|
if (Materiel == null && Materiel1 == null && !agv_task.agv_tasktype.Contains("TaskType_EmptyPallet"))
|
{
|
agv_task.agv_remark = "未获取到当前任务的车轮数据";
|
agvtaskRepository.Update(agv_task, true);
|
throw new Exception("未查询到当前任务的车轮类型数据，任务ID：" + agv_task.agv_tasknum);
|
}
|
requestTask.TASK_NO = agv_task.agv_tasknum;
|
requestTask.FROM_POSITION = agv_task.agv_fromaddress;
|
requestTask.TO_POSITION = agv_task.agv_toaddress;
|
requestTask.Material = agv_task.agv_materielid;
|
requestTask.Grade = agv_task.agv_grade;
|
requestTask.Quantity = agv_task.agv_qty;
|
requestTask.TrayType = agv_task.agv_Traytype.Contains("Small") ? 1 : 2;//
|
requestTask.TaskType = agv_task.agv_tasktype.Contains("TaskType_EmptyPallet") ? 2 : 1;//
|
#region 组/拆空盘任务需处理
|
requestTask.StarQuantity = agv_task.StarQuantity;
|
requestTask.EndQuantity = agv_task.EndQuantity;
|
#endregion
|
if (Materiel != null)
|
{
|
requestTask.A = Materiel == null ? Materiel1.a : Materiel.a;
|
requestTask.B = Materiel == null ? Materiel1.b : Materiel.b;
|
requestTask.C = Materiel == null ? Materiel1.c : Materiel.c;
|
requestTask.D = Materiel == null ? Materiel1.d : Materiel.d;
|
requestTask.E = Materiel == null ? Materiel1.e : Materiel.e;
|
requestTask.F = Materiel == null ? Materiel1.f : Materiel.f;
|
requestTask.G = Materiel == null ? Materiel1.g : Materiel.g;
|
requestTask.H = Materiel == null ? Materiel1.h : Materiel.h;
|
}
|
postJson = JsonConvert.SerializeObject(requestTask);
|
report = Request.RequestData(postJson, "http://192.168.12.204:5000/api/TaskCreat/CreatTask");
|
respone = JsonConvert.DeserializeObject<Respone>(report);
|
if (respone.Success)
|
{
|
agv_task.agv_taskstate = AGVTaskStateEnum.SendOut.ToString();
|
agv_task.agv_realesstime = DateTime.Now;
|
agvtaskRepository.Update(agv_task, true);
|
WriteWMSLog.LogAdd(requestTask.TASK_NO, "成功 ", "AGV", "WMS", postJson, report, "下发AGV任务", "SendAGVTask", respone.Msg);
|
}
|
else
|
{
|
agv_task.agv_remark = respone.Msg;
|
var task = agvtaskRepository.Find(x => x.agv_tasknum == agv_task.agv_tasknum && x.agv_remark == agv_task.agv_remark).FirstOrDefault();//.Exists
|
if (task == null)
|
agvtaskRepository.Update(agv_task, true);
|
WriteWMSLog.LogAdd(requestTask.TASK_NO, "失败 ", "AGV", "WMS", postJson, report, "下发AGV任务", "SendAGVTask", respone.Msg);
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
respone.Success = false;
|
respone.Msg = ex.Message;
|
WriteWMSLog.LogAdd(requestTask.TASK_NO, "失败", "AGV", "WMS", postJson, report, "下发AGV任务", "SendAGVTask", respone.Msg);
|
}
|
}
|
}
|
}
|
