分支自 SuZhouGuanHong/TaiYuanTaiZhong

dengjunjie
2024-05-23 cbd78ef6650440fcaa2f9eb8b47d16ad76cb4d77
´úÂë¹ÜÀí/WMS/WMS_Server/WIDESEA_WMS/ToAGV/ToAGVServer.cs
@@ -5,6 +5,7 @@
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;
@@ -23,6 +24,7 @@
            Idt_agvtaskRepository repository = new dt_agvtaskRepository(context);
            AGVRespone respone = new AGVRespone();
            UpdateTasteInfo tasteInfo = new();
            string remark = "AGV反馈任务状态:";
            try
            {
                if (string.IsNullOrEmpty(json) || json == "null")
@@ -38,34 +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;
                    respone.Message = tasteInfo.TASK_NO + ":重复调用,任务状态为:" + tasteInfo.TASK_State;
                    return respone;
                }
                #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
                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;
                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)
                {
                    HandleTask.AddHtyTask(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)
            {
@@ -74,7 +99,7 @@
            }
            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;
        }