分支自 SuZhouGuanHong/TaiYuanTaiZhong
blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
dengjunjie
2024-01-31 50fd5cc9cfad08714c4daa6d481c5293ff2ae6b1 
 ´úÂë¹ÜÀí/WMS/WMS_Server/WIDESEA_WMS/ToAGV/ToAGVServer.cs


@@ -1,18 +1,10 @@


using Newtonsoft.Json;


using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;


using System;


using System.Collections.Generic;


using System.Linq;


using System.Net;


using System.Security.Policy;


using System.Text;


using System.Threading.Tasks;


using System.Xml.Linq;


using WIDESEA_Comm.LogInfo;


using WIDESEA_Common;


using WIDESEA_Core.EFDbContext;


using WIDESEA_Entity.DomainModels;


using WIDESEA_Entity.ToAGV;


using WIDESEA_WMS.Common;


using WIDESEA_WMS.IRepositories;


using WIDESEA_WMS.Repositories;




@@ -36,6 +28,8 @@


                if (string.IsNullOrEmpty(json) || json == "null")


                    throw new Exception("未获取到请求参数数据");


                tasteInfo = JsonConvert.DeserializeObject<UpdateTasteInfo>(json);


                if (tasteInfo == null)


                    throw new Exception("请求参数格式不对！");


                if (string.IsNullOrEmpty(tasteInfo.TASK_NO))


                    throw new Exception("未获取到任务号!");


                var task = repository.FindFirst(x => x.agv_tasknum == tasteInfo.TASK_NO);


@@ -47,7 +41,8 @@


                if (task.agv_taskstate == StateName)


                {


                    respone.success = 2;


                    throw new Exception(tasteInfo.TASK_NO + "：重复调用，任务状态为：" + tasteInfo.TASK_State);


                    respone.Message = tasteInfo.TASK_NO + "：重复调用，任务状态为：" + tasteInfo.TASK_State;


                    return respone;


                }


                if (tasteInfo.TASK_State == (int)AGVTaskStateEnum.Executing)


                    task.agv_executingBeginTime = DateTime.Now;


@@ -61,9 +56,9 @@


                    throw new Exception("任务状态更新失败！任务ID：" + tasteInfo.TASK_NO + "；任务状态：" + tasteInfo.TASK_State);


                if (tasteInfo.TASK_State == (int)AGVTaskStateEnum.Complete1)


                {


                    Task.AddHtyTask(task);


                    Task.Updateinventory(task);


                    Task.AutoUpdateHCJState(task);


                    HandleTask.AddHtyTask(task);


                    HandleTask.Updateinventory(task);


                    HandleTask.AutoUpdateHCJState(task);


                }


            }


            catch (Exception ex)


@@ -76,44 +71,6 @@


                WriteWMSLog.LogAdd(tasteInfo.TASK_NO, respone.success == 1 ? "成功 " : "失败", "WMS", "AGV", json, JsonConvert.SerializeObject(respone), "AGV反馈任务状态", "UpdateTaskState", respone.Message);


            }


            return respone;


        }




        /// <summary>


        /// ä¸‹å‘AGV任务


        /// </summary>


        /// <param name="agvtask"></param>


        public static void SendAGVTask(dt_agvtask agvtask)


        {


            if (agvtask == null) return;


            VOLContext context = new VOLContext();


            Idt_agvtaskRepository repository = new dt_agvtaskRepository(context);


            AGVRespone respone = new AGVRespone();


            RequestTask requestTask = new RequestTask();


            string postJson = string.Empty;


            string report = string.Empty;


            string url = "http://127.0.0.1/api/TaskCreat/CreatTask";


            try


            {


                requestTask.TASK_NO = agvtask.agv_tasknum;


                requestTask.FROM_POSITION = agvtask.agv_fromaddress;


                requestTask.TO_POSITION = agvtask.agv_toaddress;


                requestTask.Material = agvtask.agv_materielid;


                requestTask.Priority = agvtask.agv_grade;


                requestTask.agv_qty = agvtask.agv_qty;


                postJson = JsonConvert.SerializeObject(requestTask);


                report = Request.RequestData(postJson, url);


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


                if (respone.success != 1)


                    throw new Exception(respone.Message);


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


                agvtask.agv_realesstime = DateTime.Now;


                repository.Update(agvtask, true);


            }


            catch (Exception ex)


            {


                respone.Message = ex.Message;


            }


            WriteWMSLog.LogAdd(requestTask.TASK_NO, respone.success == 1 ? "成功 " : "失败", "AGV", "WMS", postJson, report, "下发AGV任务", "SendAGVTask", respone.Message);


        }


    }


}