From df97e66f99cf081abf212a8d97fc32afe9c6e7a7 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期五, 17 一月 2025 13:46:32 +0800
Subject: [PATCH] 更新配置文件PDA版本

---
 代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/AGV/AGV_CSJExtend.cs |   25 ++++++++++++++++++++++++-
 1 files changed, 24 insertions(+), 1 deletions(-)

diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/AGV/AGV_CSJExtend.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/AGV/AGV_CSJExtend.cs"
index f26d272..c3ae198 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/AGV/AGV_CSJExtend.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/AGV/AGV_CSJExtend.cs"
@@ -11,6 +11,7 @@
 using WIDESEAWCS_Model.Models;
 using static Dm.net.buffer.ByteArrayBuffer;
 using WIDESEAWCS_QuartzJob;
+using WIDESEAWCS_DTO.Agv;
 
 namespace WIDESEAWCS_Tasks
 {
@@ -53,6 +54,7 @@
                         {
                             agvTask.TaskState = TaskStatusEnum.AGV_Executing.ObjToInt();
                             //agvTask.Remark = content.Data.ObjToString();
+                            _taskService.UpdateTask(agvTask, TaskStatusEnum.AGV_Executing);
                         }
                         else
                         {
@@ -70,6 +72,24 @@
                     }
                 }
                 _taskService.UpdateData(newTasks);
+                //鍑哄簱缁戝畾鏌ヨ
+                Dt_Task outBound = _taskService.Db.Queryable<Dt_Task>().Where(x => x.TaskState == TaskStatusEnum.Exception.ObjToInt() && nameof(AGV_CSJJob).Contains(x.DeviceCode) && x.TaskType==TaskTypeEnum.Outbound.ObjToInt()).ToList().OrderBy(x => x.Grade).ThenBy(x=>x.CreateDate).First();
+                if (outBound != null)
+                {
+                    AgvPodBerthAndMatDTO andMatDTO = new AgvPodBerthAndMatDTO()
+                    {
+                        ReqCode = Guid.NewGuid().ToString().Replace("-", ""),
+                        PositionCode=outBound.TargetAddress
+                    };
+                    WebResponseContent content = _taskService.AgvPodBerthAndMat(andMatDTO);
+                    if (content.Status)
+                    {
+                        outBound.TaskState = TaskStatusEnum.AGV_Execute.ObjToInt();
+                        outBound.ExceptionMessage = "";
+                        //agvTask.Remark = content.Data.ObjToString();
+                        _taskService.UpdateTask(outBound, TaskStatusEnum.AGV_Execute);
+                    }
+                }
             }
             catch (Exception ex)
             {
@@ -88,7 +108,7 @@
                 {
                     if (WaitToTask.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)
                     {
-                        if (WaitToTasks.FirstOrDefault(x=>x.TaskState==TaskStatusEnum.AGV_Puting.ObjToInt())!=null)
+                        if (WaitToTasks.FirstOrDefault(x=>x.TaskState==TaskStatusEnum.AGV_Puting.ObjToInt() || x.TaskState == TaskStatusEnum.Finish.ObjToInt()) !=null)
                         {
                             continue;
                         }
@@ -150,16 +170,19 @@
                     if (content.Status && WaitToTask.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)
                     {
                         WaitToTask.TaskState = TaskStatusEnum.AGV_Puting.ObjToInt();
+                        _taskService.UpdateTask(WaitToTask, TaskStatusEnum.AGV_Puting);
                         break;
                     }
                     else if (content.Status && WaitToTask.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
                     {
                         WaitToTask.TaskState = TaskStatusEnum.AGV_Executing.ObjToInt();
+                        _taskService.UpdateTask(WaitToTask, TaskStatusEnum.AGV_Executing);
                     }
                     else
                     {
                         WaitToTask.TaskState = TaskStatusEnum.Exception.ObjToInt();
                         WaitToTask.ExceptionMessage = content.Message;
+                        _taskService.UpdateTask(WaitToTask, TaskStatusEnum.Exception);
                     }
                 }
                 _taskService.UpdateData(WaitToTasks);

--
Gitblit v1.9.3