1

huangxiaoqiang

2025-10-21 6c663b92b0078aa89657df22ec188dff65599f04

 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/StackerCraneJob/CommonStackerCraneJob.cs

@@ -2,15 +2,19 @@
using Mapster;
using Microsoft.AspNetCore.Components.Routing;
using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
using Quartz;
using System.Diagnostics.CodeAnalysis;
using System.Text;
using WIDESEAWCS_BasicInfoRepository;
using WIDESEAWCS_Common;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.Caches;
using WIDESEAWCS_Core.Helper;
using WIDESEAWCS_Core.HttpContextUser;
using WIDESEAWCS_DTO.TaskInfo;
using WIDESEAWCS_DTO.WMS;
using WIDESEAWCS_IBasicInfoRepository;
using WIDESEAWCS_ISystemServices;
using WIDESEAWCS_ITaskInfoRepository;
@@ -323,6 +327,47 @@
                }
                else
                {
                    string[] sourceCodes = task.SourceAddress.Split("-");
                    if (sourceCodes[0].Contains("3"))
                    {
                        var taskDto = new RequestTaskDto()
                        {
                            Position = task.SourceAddress,
                            PalletCode = task.PalletCode,
                            TaskNum = task.TaskNum
                        };

                        // èŽ·å–WMSip地址
                        var configz = _sys_ConfigService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
                        var wmsBasez = configz.Where(x => x.ConfigKey == SysConfigKeyConst.WMSIP_BASE).FirstOrDefault()?.ConfigValue;
                        var requestLocation = configz.Where(x => x.ConfigKey == SysConfigKeyConst.StackerIsNeedRelocation).FirstOrDefault()?.ConfigValue;
                        if (wmsBasez == null || requestLocation == null)
                        {
                            throw new InvalidOperationException("WMS IP æœªé…ç½®");
                        }
                        var wmsIpAddrss = wmsBasez + requestLocation;

                        var result = HttpHelper.PostAsync(wmsIpAddrss, taskDto.ToJsonString()).Result;

                        WebResponseContent content = JsonConvert.DeserializeObject<WebResponseContent>(result);

                        if (!content.Status)
                        {
                            task.ExceptionMessage = content.Message;
                            _taskRepository.UpdateData(task);
                            return null;
                        }

                        // ååºåˆ—化任务数据
                        var taskDTO = JsonConvert.DeserializeObject<WMSTaskDTO>(content.Data.ToString());

                        if (taskDTO.TaskNum != task.TaskNum)
                        {
                            _taskService.ReceiveWMSTask(new List<WMSTaskDTO> { taskDTO });
                            return _taskRepository.QueryFirst(x => x.TaskNum == taskDTO.TaskNum);
                        }
                    }

                    CommonConveyorLine? conveyorLine = Storage.Devices.FirstOrDefault(x=>x.DeviceCode =="1001") as CommonConveyorLine;
                    if (conveyorLine != null)
                    {