百步立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
刘磊
2024-12-17 58a5a9af83492c5bbb4fba88b4443f08fa4becfc 
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/CommonConveyorLine_GWJob.cs


@@ -1,4 +1,5 @@


#region MyRegion




#region << 版 本 注 释 >>




/*----------------------------------------------------------------


@@ -20,32 +21,24 @@




using AutoMapper;


using HslCommunication;


using Microsoft.AspNetCore.Server.HttpSys;


using Newtonsoft.Json;


using Quartz;


using SqlSugar;


using System.Diagnostics.CodeAnalysis;


using System.Net;


using System.Reflection;


using System.Threading.Tasks;


using WIDESEAWCS_BasicInfoRepository;


using WIDESEAWCS_BasicInfoService;


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.MOM;


using WIDESEAWCS_DTO.TaskInfo;


using WIDESEAWCS_IProcessRepository;


using WIDESEAWCS_ISystemRepository;


using WIDESEAWCS_ISystemServices;


using WIDESEAWCS_ITaskInfoRepository;


using WIDESEAWCS_ITaskInfoService;


using WIDESEAWCS_Model.Models;


using WIDESEAWCS_QuartzJob;


using WIDESEAWCS_QuartzJob.DeviceBase;


using WIDESEAWCS_QuartzJob.DTO;


using WIDESEAWCS_QuartzJob.Service;


using WIDESEAWCS_SignalR;


@@ -90,6 +83,7 @@


                if (conveyorLine != null)


                {


                    #region 站台方式




                    //List<Dt_StationManager> stationManagers = _stationManagerService.GetAllStationByDeviceCode(conveyorLine.DeviceCode);




                    //foreach (var station in stationManagers)


@@ -105,10 +99,12 @@


                    //            method.Invoke(this, new object[] { conveyorLine, command, station });


                    //        }


                    //    }


                    //} 


                    #endregion


                    //}




                    #endregion 站台方式




                    #region 路由方式




                    List<string> childDeviceCodes = _routerService.QueryAllPositions(conveyorLine.DeviceCode);


                    foreach (string childDeviceCode in childDeviceCodes)


                    {


@@ -163,15 +159,14 @@


                        _noticeService.StackerData(userIds?.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, data = obj });




                        #endregion 调用事件总线通知前端




                    }


                    #endregion




                    #endregion 路由方式


                }


            }


            catch (Exception ex)


            {


                Console.Out.WriteLine(nameof(CommonConveyorLine_AfterJob) + ":" + ex.ToString());


                Console.Out.WriteLine(nameof(CommonConveyorLine_GWJob) + ":" + ex.ToString());


            }


            finally


            {


@@ -180,7 +175,6 @@


            }


            return Task.CompletedTask;


        }






        /// <summary>


        /// 输送线请求入库


@@ -226,6 +220,12 @@


            Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.ConveyorLineTaskNum, childDeviceCode);


            if (task != null)


            {


                if (command.ConveyorLineBarcode != task.PalletCode)


                {


                    conveyorLine.SetValue(ConveyorLineDBName_After.ResponState, 2, childDeviceCode);


                    return;


                }




                Dt_Task? newTask = _taskService.UpdatePosition(task.TaskNum, task.CurrentAddress);


                if (newTask != null)


                {


@@ -250,7 +250,7 @@


        /// <param name="ProtocalDetailValue">线体当前bool读取偏移地址</param>


        public void ConveyorLineInFinish(CommonConveyorLine_GW conveyorLine, ConveyorLineTaskCommand_After command, string childDeviceCode)


        {


            var task = _taskService.QueryExecutingConveyorLineTask(command.ConveyorLineTaskNum, childDeviceCode);


            var task = _taskService.QueryExecutingTaskByBarcode(command.ConveyorLineBarcode, childDeviceCode);


            if (task != null && task.TaskState != (int)TaskInStatusEnum.Line_InFinish)


            {


                //ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);


@@ -313,7 +313,7 @@


                TrayCellsStatusDto trayCells = new TrayCellsStatusDto()


                {


                    Software = "WMS",


                    TrayBarcode = task.PalletCode,


                    TrayBarcode = command.ConveyorLineBarcode,


                    EquipmentCode = stationManager.stationEquipMOM,


                    SessionId = Guid.NewGuid().ToString(),


                    EmployeeNo = "MITest",


@@ -346,6 +346,7 @@


                    conveyorLine.SetValue(ConveyorLineDBName_After.ResponState, 1, childDeviceCode);


                    _taskService.UpdateTaskStatusToNext(task);


                }




            }


        }




@@ -442,7 +443,6 @@


                }


                var wmsIpAddress = wmsBase + requestTrayOutTask;






                var result = await HttpHelper.PostAsync(wmsIpAddress, new { position = childDeviceCode, tag = (int)taskType, areaCdoe = roadWay, roadways = roadways }.ToJsonString());


                //var result = await HttpHelper.PostAsync("http://localhost:5000/api/Task/RequestTrayOutTaskAsync", dynamic.ToJsonString());




@@ -454,7 +454,7 @@




                taskDTO = JsonConvert.DeserializeObject<WMSTaskDTO>(content.Data.ToString());




                #endregion


                #endregion 调用WMS获取出库任务




                CreateAndSendTask(taskDTO);


            }


@@ -472,10 +472,7 @@


            }


            return content;


        }










    }


}




#endregion