工单处理

huanghongfeng

2024-07-15 a765da90e5ee63e04d2d8460a5ad1ebd0e8eb4db

 ´úÂë¹ÜÀí/WMS/WMS_Server/WIDESEA_WMS/Common/AGVTask/AGVServer.cs

@@ -6,6 +6,7 @@
using System.Security.Policy;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Comm;
using WIDESEA_Comm.LogInfo;
using WIDESEA_Common;
using WIDESEA_Core.EFDbContext;
@@ -29,22 +30,23 @@
            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)
            {
                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)
                        .OrderBy(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)
                        .OrderBy(x => x.agv_createtime).ToList();
                if (agv_tasks.Count > 0)
                foreach (var agv_task in agv_tasks)
                {
                    foreach (var agv_task in agv_tasks)
                    try
                    {
                        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"))
                        if (Materiel == null && Materiel1 == null && !agv_task.agv_tasktype.Contains(AGVTaskTypeEnum.TaskType_EmptyPallet.ToString()))
                        {
                            agv_task.agv_remark = "未获取到当前任务的车轮数据";
                            agvtaskRepository.Update(agv_task, true);
@@ -56,8 +58,8 @@
                        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;//
                        requestTask.TrayType = agv_task.agv_Traytype.Contains(TrayTypeEnum.SmallTray.ToString()) ? 1 : 2;//
                        requestTask.TaskType = agv_task.agv_tasktype.Contains(AGVTaskTypeEnum.TaskType_EmptyPallet.ToString()) ? 2 : 1;//
                        #region ç»„/拆空盘任务需处理
                        requestTask.StarQuantity = agv_task.StarQuantity;
                        requestTask.EndQuantity = agv_task.EndQuantity;
@@ -74,32 +76,34 @@
                            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);
                        }
                        //report = Request.RequestData(postJson, AGVAPIAddress.IPAddress_AGVTask);//"http://192.168.12.204:5000/api/TaskCreat/CreatTask"
                        RequestAGV(agvtaskRepository, agv_task, postJson, AGVAPIAddress.IPAddress_AGVTask);
                        //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);
                    }
                }
            }
            catch (Exception ex)
            {
                respone.Success = false;
                respone.Msg = ex.Message;
                WriteWMSLog.LogAdd(requestTask.TASK_NO, "失败", "AGV", "WMS", postJson, report, "下发AGV任务", "SendAGVTask", respone.Msg);
            }

        }
    }
}