接口新增

Admin

2026-03-06 ec3daa05f122738f18d4474b9257e4cf794dc5cf

 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs

@@ -815,6 +815,11 @@
            return BaseDal.QueryFirst(x => x.PalletCode == barcode && x.NextAddress == nextAddress && (x.TaskState == (int)TaskInStatusEnum.Line_InExecuting || x.TaskState == (int)TaskOutStatusEnum.Line_OutExecuting), TaskOrderBy);
        }

        public Dt_Task QueryOutTaskByBarcode(string barcode)
        {
            return BaseDal.QueryFirst(x => x.PalletCode == barcode  && x.TaskState == (int)TaskOutStatusEnum.Line_OutExecuting, TaskOrderBy);
        }

        private string GetIpAddress(string baseIp, string name)
        {
            var configz = _sys_ConfigService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
@@ -939,7 +944,7 @@


        //读取申请，给agv下发任务
        public WebResponseContent GetAGVTaskdistribution(string TargetAddress)
        public WebResponseContent GetAGVTaskdistribution(string TargetAddress,string Number)
        {

            WebResponseContent content = new WebResponseContent();
@@ -952,16 +957,41 @@
                {
                    throw new InvalidOperationException("WMS IP æœªé…ç½®");
                }
                var wmsIpAddress = wmsBase + completeTask;
                var taskDto = new RequestTaskDto()
                IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "1000");
                CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                DeviceProDTO? deviceProDTOt = conveyorLine.DeviceProDTOs.Find(x => x.DeviceChildCode == TargetAddress && x.DeviceProParamName == "ConveyorLineSingal");
                if (conveyorLine.Communicator.Read<short>(deviceProDTOt.DeviceProAddress) == 1)
                {
                    RequestType = "999",
                    Position = TargetAddress,
                };


                var result = HttpHelper.PostAsync(wmsIpAddress, taskDto.ToJsonString()).Result;
                content = JsonConvert.DeserializeObject<WebResponseContent>(result);
                    var wmsIpAddress = wmsBase + completeTask;
                    var taskDto = new RequestTaskDto()
                    {
                        RequestType = "999",
                        Position = TargetAddress,
                    };


                    var result = HttpHelper.PostAsync(wmsIpAddress, taskDto.ToJsonString()).Result;
                    content = JsonConvert.DeserializeObject<WebResponseContent>(result);
                    if (content.Status)
                    {
                        List<Dt_Task> tasks = BaseDal.QueryData(x => x.axle_czh == Number);
                        if (tasks.Count > 0)
                        {
                            foreach (var task in tasks)
                            {
                                task.Towhereabouts = TargetAddress;
                            }
                            BaseDal.UpdateData(tasks);
                        }
                    }
                }
                else
                {
                    content.Error();
                }

                return content;
            }
            catch (Exception ex)