分支自 SuZhouGuanHong/TaiYuanTaiZhong
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
dengjunjie
2024-05-23 cbd78ef6650440fcaa2f9eb8b47d16ad76cb4d77 
 ´úÂë¹ÜÀí/WMS/WMS_Server/WIDESEA_WMS/Common/AGVTask/AGVServer.cs


@@ -19,73 +19,91 @@


{


    public partial class AGVServer


    {


        static FreeDB freeDB = new FreeDB();


        static Respone respone = new Respone();


        static RequestTask requestTask = new RequestTask();


        static string postJson = string.Empty;


        static string report = string.Empty;




        /// <summary>


        /// ä»»åŠ¡ä¸‹å‘


        /// </summary>


        public static void SendAgvTask()


        {


            try


            WriteLog.Write_Log("自动下发任务", "SendAgvTask", "");


            Respone respone = new Respone();


            RequestTask requestTask = new RequestTask();


            string postJson = string.Empty;


            string report = string.Empty;




            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)


            {


                var agv_task = freeDB.Select<dt_agvtask>()


                        .Where(t => t.agv_taskstate == AGVTaskStateEnum.Create.ToString()


                               && (t.agv_tasktype == "TaskType_Outbound" || t.agv_tasktype == "TaskType_Inbound" || t.agv_tasktype == "TaskType_AOutbound")


                               && string.IsNullOrEmpty(t.agv_remark))


                        .OrderByDescending(t => t.agv_grade)


                        .OrderBy(t => t.agv_createtime)


                        .First();


                if (agv_task == null)


                    agv_task = freeDB.Select<dt_agvtask>()


                        .Where(t => t.agv_taskstate == AGVTaskStateEnum.Create.ToString()


                               && (t.agv_tasktype == "TaskType_Outbound" || t.agv_tasktype == "TaskType_Inbound" || t.agv_tasktype == "TaskType_AOutbound")


                               && !string.IsNullOrEmpty(t.agv_remark))


                        .OrderByDescending(t => t.agv_grade)


                        .OrderBy(t => t.agv_createtime)


                        .First();


                if (agv_task != null)


                foreach (var agv_task in agv_tasks)


                {


                    var Materiel = QueryData.QueryMateriel(agv_task.agv_materielid);//查找车轮数据


                    if (Materiel == null)


                    try


                    {


                        agv_task.agv_remark = "未获取到当前任务的车轮数据";


                        freeDB.Update(agv_task).UpdateColumns(t => new { t.agv_remark }).ExecuteAffrows();


                        throw new Exception("未查询到当前任务的车轮类型数据，任务ID：" + agv_task.agv_tasknum);


                        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, 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);


                        //}


                    }


                    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.A = Materiel.a;


                    requestTask.B = Materiel.b;


                    requestTask.C = Materiel.c;


                    requestTask.D = Materiel.d;


                    requestTask.E = Materiel.e;


                    requestTask.F = Materiel.f;


                    requestTask.G = Materiel.g;


                    requestTask.H = Materiel.h;


                    postJson = JsonConvert.SerializeObject(requestTask);


                    report = Request.RequestData(postJson, "http://192.168.12.250:5566/api/TaskCreat/CreatTask");


                    respone = JsonConvert.DeserializeObject<Respone>(report);


                    if (respone.Success)


                    catch (Exception ex)


                    {


                        agv_task.agv_taskstate = AGVTaskStateEnum.SendOut.ToString();


                        agv_task.agv_realesstime = DateTime.Now;


                        freeDB.Update(agv_task).UpdateColumns(t => new { t.agv_realesstime, t.agv_taskstate }).ExecuteAffrows();


                        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, respone.Success ? "成功 " : "失败", "AGV", "WMS", postJson, report, "下发AGV任务", "SendAGVTask", respone.Msg);




        }


    }


}