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


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


#region MyRegion




#region << 版 本 注 释 >>




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


@@ -20,37 +21,31 @@




using AutoMapper;


using HslCommunication;


using Microsoft.AspNetCore.Server.HttpSys;


using Microsoft.CodeAnalysis;


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;


using WIDESEAWCS_Tasks.ConveyorLineJob;


using ICacheService = WIDESEAWCS_Core.Caches.ICacheService;


using Platform = WIDESEAWCS_Model.Models.Platform;




namespace WIDESEAWCS_Tasks


{


@@ -90,6 +85,7 @@


                if (conveyorLine != null)


                {


                    #region 站台方式




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




                    //foreach (var station in stationManagers)


@@ -105,10 +101,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 +161,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 +177,6 @@


            }


            return Task.CompletedTask;


        }






        /// <summary>


        /// 输送线请求入库


@@ -226,6 +222,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 +252,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 +315,7 @@


                TrayCellsStatusDto trayCells = new TrayCellsStatusDto()


                {


                    Software = "WMS",


                    TrayBarcode = task.PalletCode,


                    TrayBarcode = command.ConveyorLineBarcode,


                    EquipmentCode = stationManager.stationEquipMOM,


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


                    EmployeeNo = "MITest",


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


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


                    _taskService.UpdateTaskStatusToNext(task);


                }




            }


        }




@@ -404,7 +407,7 @@


        /// <param name="command">读取的请求信息</param>


        /// <param name="childDeviceCode">子设备编号</param>


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


        public async void EmptyTrayReturn(CommonConveyorLine_GW conveyorLine, ConveyorLineTaskCommand_After command, string childDeviceCode, int index, Platform platform)


        public async void EmptyTrayReturn(CommonConveyorLine_GW conveyorLine, ConveyorLineTaskCommand_After command, string childDeviceCode, int index, WIDESEAWCS_Model.Models.Platform platform)


        {


            try


            {


@@ -413,7 +416,7 @@


                    taskOutboundTypeEnum = TaskOutboundTypeEnum.OutTray;


                else


                    taskOutboundTypeEnum = TaskOutboundTypeEnum.Outbound;


                await CheckAndCreateTask(taskOutboundTypeEnum, childDeviceCode, index, platform.Stacker);


                await CheckAndCreateTask(taskOutboundTypeEnum, childDeviceCode, index, platform.Stacker, platform);


            }


            catch (Exception)


            {


@@ -423,7 +426,7 @@


        /// <summary>


        /// 检查任务并创建新任务


        /// </summary>


        private async Task CheckAndCreateTask(TaskOutboundTypeEnum taskType, string childDeviceCode, int index, string roadWay, List<string> roadways = null)


        private async Task CheckAndCreateTask(TaskOutboundTypeEnum taskType, string childDeviceCode, int index, string roadWay, Platform platform)


        {


            var tasks = _taskRepository.QueryData(x => x.TaskType == (int)taskType && x.TargetAddress == childDeviceCode);


            if (tasks.Count < index)


@@ -443,7 +446,9 @@


                var wmsIpAddress = wmsBase + requestTrayOutTask;






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


                List<string> strings = platform.Location.Split(',').ToList();




                var result = await HttpHelper.PostAsync(wmsIpAddress, new { Position = childDeviceCode, Tag = (int)taskType, AreaCdoe = roadWay, AreaCdoes = strings, platform.ProductionLine }.ToJsonString());


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




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


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




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




                #endregion


                #endregion 调用WMS获取出库任务




                CreateAndSendTask(taskDTO);


            }


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


            }


            return content;


        }










    }


}




#endregion