分支自 SuZhouGuanHong/TaiYuanTaiZhong
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
dengjunjie
2024-04-27 0b5ccdca6263cf7a2cee460f30c76ef1efea2811 
 ´úÂë¹ÜÀí/WMS/WMS_Server/WIDESEA_WMS/ToAGV/ToAGVServer.cs


@@ -1,18 +1,11 @@


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.Common.AGVTask;


using WIDESEA_WMS.IRepositories;


using WIDESEA_WMS.Repositories;




@@ -31,11 +24,14 @@


            Idt_agvtaskRepository repository = new dt_agvtaskRepository(context);


            AGVRespone respone = new AGVRespone();


            UpdateTasteInfo tasteInfo = new();


            string remark = "AGV反馈任务状态：";


            try


            {


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


@@ -44,27 +40,57 @@


                if (tasteInfo.TASK_State < 1 || tasteInfo.TASK_State > 4)


                    throw new Exception("未定义的任务状态:" + tasteInfo.TASK_State);


                var StateName = Enum.GetName(typeof(AGVTaskStateEnum), tasteInfo.TASK_State);


                if (task.agv_taskstate == StateName)


                if (task.agv_taskstate == StateName && task.agv_taskstate != AGVTaskStateEnum.Complete1.ToString())


                {


                    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;


                else if (tasteInfo.TASK_State == (int)AGVTaskStateEnum.Complete)


                    task.agv_executingEndTime = DateTime.Now;


                else if (tasteInfo.TASK_State == (int)AGVTaskStateEnum.Executing1)


                    task.agv_completeBeginTime = DateTime.Now;




                #region åˆ¤æ–­ä»»åŠ¡çŠ¶æ€


                //List<string> list = new List<string>() { AGVTaskStateEnum.Executing.ToString(), AGVTaskStateEnum.Complete.ToString(), AGVTaskStateEnum.Executing1.ToString(), AGVTaskStateEnum.Complete1.ToString() };


                //var index = list.IndexOf(task.agv_taskstate) + 1;


                //if (tasteInfo.TASK_State < index)


                //    throw new Exception("任务状态更新异常！当前任务状态为：" + index + ";请求更新状态为：" + tasteInfo.TASK_State);


                #endregion




                task.agv_taskstate = StateName;


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


                {


                    remark = remark + "起点执行中";


                    task.agv_executingBeginTime = DateTime.Now;


                }


                else if (tasteInfo.TASK_State == (int)AGVTaskStateEnum.Complete)


                {


                    remark = remark + "起点已完成";


                    HandleTask.AutoUpdateHCJState(task);


                    task.agv_executingEndTime = DateTime.Now;


                }


                else if (tasteInfo.TASK_State == (int)AGVTaskStateEnum.Executing1)


                {


                    remark = remark + "终点执行中";


                    task.agv_completeBeginTime = DateTime.Now;


                }


                var count = repository.Update(task, true);


                if (count < 1)


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


                    remark = remark + "终点已完成";


                    task.agv_finishedtime = DateTime.Now;




                    #region åŒæ­¥MES出入库信息


                    var mes = HandleTask_Mes.UploadMESInfo(task);


                    if (mes.code != "200" && mes.Type != "success")


                        throw new Exception(mes.message);


                    #endregion




                    HandleTask.Updateinventory(task);


                    HandleTask.AutoUpdateHCJState(task);


                    HandleTask.AddHtyTask(task);


                }


                respone.success = 1;


                return respone;


            }


            catch (Exception ex)


            {


@@ -73,47 +99,9 @@


            }


            finally


            {


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


                WriteWMSLog.LogAdd(tasteInfo.TASK_NO, respone.success == 1 ? "成功 " : "失败", "WMS", "AGV", json, JsonConvert.SerializeObject(respone), remark, "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);


        }


    }


}