增加质检出入库逻辑

dengjunjie

2025-07-09 7ca9651f81d7b84f054194d3d46fdbd1d9c8b922

 项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/AGV/AGVJob.cs

@@ -18,6 +18,7 @@
using WIDESEAWCS_QuartzJob;
using WIDESEAWCS_QuartzJob.Models;
using WIDESEAWCS_QuartzJob.Service;
using WIDESEAWCS_TaskInfoService;

namespace WIDESEAWCS_Tasks
{
@@ -40,6 +41,21 @@
        {
            try
            {
                #region 浠诲姟鍙栨秷
                var CancelTasks = _taskService.Db.Queryable<Dt_Task>().Where(x => x.TaskState == TaskInStatusEnum.InCancel.ObjToInt() || x.TaskState == TaskOutStatusEnum.OutCancel.ObjToInt()).ToList();
                foreach (var CancelTask in CancelTasks)
                {
                    var difference = DateTime.Now.AddMinutes(-5);
                    if (difference > CancelTask.ModifyDate)
                    {
                        //todo 鍚屾鍒癢MS
                        WMSTaskDTO WMStask = _mapper.Map<WMSTaskDTO>(CancelTask);
                        HttpHelper.PostAsync(WMSInterfaceAddress.CancelTask, WMStask.ToJson(), headers: new Dictionary<string, string>());
                        _taskService.AddTask_Hty(CancelTask, TaskOperateTypeEnum.AGVDeletion);
                    }
                }
                #endregion

                #region 浠诲姟鏇存柊
                var Tasks = _taskService.Db.Queryable<Dt_Task>().Where(x =>
                x.TaskState > (int)TaskInStatusEnum.InNew &&
@@ -85,13 +101,18 @@
                                    }
                                    break;
                                case "09":
                                    {
                                        Task.TaskState = _taskService.TaskInboundTypes.Contains(Task.TaskType) ? (int)TaskInStatusEnum.InCancel : TaskOutStatusEnum.OutCancel.ObjToInt();
                                        Task.ModifyDate = DateTime.Now;
                                        Task.Modifier = "AGV";
                                    }
                                    break;
                                default:
                                    break;
                            }
                        }
                    }
                    Thread.Sleep(1000);
                    Thread.Sleep(5000);
                }
                _taskService.Db.Updateable(Tasks).ExecuteCommand();
                #endregion
@@ -107,6 +128,7 @@
                    if (content.code == "20000")
                    {
                        var task = newTasks.Where(x => x.TaskNum == agvTaskDTO.outID.ObjToInt()).First();
                        task.Dispatchertime = DateTime.Now;
                        task.TaskState = _taskService.TaskInboundTypes.Contains(task.TaskType) ? TaskInStatusEnum.AGV_InSend.ObjToInt() : TaskOutStatusEnum.AGV_OutSend.ObjToInt();
                        UpnewTasks.Add(task);
                    }
@@ -150,7 +172,7 @@
                point point2 = new point()
                {
                    sn = "02",
                    pointCode = task.NextAddress,
                    pointCode = task.NextAddress == "1001" ? "2001" : task.NextAddress,
                    pointType = "04",
                    matCode = task.PalletCode
                };