百步立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
huangxiaoqiang
2025-04-21 2a20cd300ab6d9233a708a0f4558ba3d92c9f0a2 
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/CommonConveyorLine_GWJob.cs


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


#region MyRegion




#region << 版 本 注 释 >>




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


@@ -20,37 +21,32 @@




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


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


{


@@ -67,8 +63,12 @@


        private readonly IDt_StationManagerRepository _stationManagerRepository;


        private readonly ICacheService _cacheService;


        private readonly INoticeService _noticeService;


        private readonly IDt_needBarcodeRepository _needBarcodeRepository;


        private readonly IDeviceInfoRepository _deviceInfoRepository;


        private static List<string>? userTokenIds;


        private static List<int>? userIds;




        public CommonConveyorLine_GWJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IPlatFormRepository platFormRepository, ISys_ConfigService sys_ConfigService, IDt_StationManagerRepository stationManagerRepository, ICacheService cacheService, INoticeService noticeService)


        public CommonConveyorLine_GWJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IPlatFormRepository platFormRepository, ISys_ConfigService sys_ConfigService, IDt_StationManagerRepository stationManagerRepository, ICacheService cacheService, INoticeService noticeService, IDt_needBarcodeRepository needBarcodeRepository, IDeviceInfoRepository deviceInfoRepository)


        {


            _taskService = taskService;


            _taskExecuteDetailService = taskExecuteDetailService;


@@ -80,6 +80,8 @@


            _stationManagerRepository = stationManagerRepository;


            _cacheService = cacheService;


            _noticeService = noticeService;


            _needBarcodeRepository = needBarcodeRepository;


            _deviceInfoRepository = deviceInfoRepository;


        }




        public Task Execute(IJobExecutionContext context)


@@ -90,6 +92,7 @@


                if (conveyorLine != null)


                {


                    #region 站台方式




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




                    //foreach (var station in stationManagers)


@@ -105,10 +108,12 @@


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


                    //        }


                    //    }


                    //} 


                    #endregion


                    //}




                    #endregion 站台方式




                    #region 路由方式




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


                    foreach (string childDeviceCode in childDeviceCodes)


                    {


@@ -127,9 +132,9 @@


                            }


                        }




                        if (childDeviceCode == "1670")


                        if (childDeviceCode == "1670"||childDeviceCode=="1666"||childDeviceCode=="1548"||childDeviceCode=="1448")


                        {


                            Platform platform = _platFormRepository.QueryFirst(x => x.PLCCode == conveyorLine.DeviceCode && x.PlatCode == childDeviceCode && x.Status == "Active");


                            Platform platform = _platFormRepository.QueryFirst(x => x.DeviceCode == conveyorLine.DeviceCode && x.PlatCode == childDeviceCode && x.Status == "Active");


                            if (platform != null)


                            {


                                if (command.HasPallet != 1)


@@ -137,7 +142,8 @@


                                    MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);


                                    if (method != null)


                                    {


                                        int count = string.IsNullOrEmpty(platform.Location) ? 0 + 1 : platform.Location.Split(',').Count() + 1;


                                        //var strings = platform.Location.Split(',').ToList();


                                        int count = 1;


                                        method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });


                                    }


                                }


@@ -160,18 +166,17 @@


                            childDeviceCode,


                            commandAfter = command,


                        };


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


                        _noticeService.LineData(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 +185,6 @@


            }


            return Task.CompletedTask;


        }






        /// <summary>


        /// 输送线请求入库


@@ -196,13 +200,24 @@


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


                //HandleTaskOut(conveyorLine, command, childDeviceCode, task);


                // && command.ConveyorLineBarcode != "NoRead" && !command.ConveyorLineBarcode.IsNotEmptyOrNull()


                ConsoleHelper.WriteSuccessLine($"【{conveyorLine.DeviceName}】托盘号：【{command.ConveyorLineBarcode}】设备编码：【{childDeviceCode}】");


                var log = $"【{conveyorLine.DeviceName}】托盘号：【{command.ConveyorLineBarcode}】任务号：【{command.ConveyorLineTaskNum}】设备编码：【{childDeviceCode}】";


                ConsoleHelper.WriteSuccessLine(log);




                _noticeService.Logs(userTokenIds, new { conveyorLine.DeviceName, log = log, time = DateTime.Now.ToString("G"), color = "red" });


                WriteInfo(conveyorLine.DeviceName, log);




                if (task == null)


                {


                    HandleNewTask(conveyorLine, command, childDeviceCode);


                }


                else


                {


                    var GWTask = _taskRepository.QueryData(x => x.Roadway.Contains("GWSC2") && x.SourceAddress == "1039" && (x.TaskState == (int)TaskInStatusEnum.Line_InExecuting || x.TaskState == (int)TaskInStatusEnum.Line_InFinish)).ToList();


                    if (GWTask.Count >= 2 && childDeviceCode == "1039")


                    {


                        ConsoleHelper.WriteErrorLine($"托盘号：【{command.ConveyorLineBarcode}】高温二已存在【{GWTask.Count}】个任务大于2个任务不可下发");


                        return;


                    }


                    ConveyorLineTaskCommand_After taskCommand = _mapper.Map<ConveyorLineTaskCommand_After>(task);


                    conveyorLine.SendCommand(taskCommand, childDeviceCode);


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


@@ -223,7 +238,8 @@


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


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


        {


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


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


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


            if (task != null)


            {


                if (command.ConveyorLineBarcode != task.PalletCode)


@@ -235,14 +251,10 @@


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


                if (newTask != null)


                {




                    //conveyorLine.SetValue(ConveyorLineDBName_After.ConveyorLineTaskNum, newTask.TaskNum, childDeviceCode);


                    //conveyorLine.SetValue(ConveyorLineDBName_After.ConveyorLineTargetAddress, newTask.NextAddress, childDeviceCode);


                    //conveyorLine.SetValue(ConveyorLineDBName_After.ConveyorLineBarcode, command.ConveyorLineBarcode, childDeviceCode);


                    ConveyorLineTaskCommand_After taskCommand = _mapper.Map<ConveyorLineTaskCommand_After>(newTask);


                    //taskCommand.InteractiveSignal = command.InteractiveSignal;


                    conveyorLine.SendCommand(taskCommand, childDeviceCode);


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


                    _taskService.UpdateData(newTask);


                }


            }


        }


@@ -259,8 +271,6 @@


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


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


            {


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




                WebResponseContent content = _taskService.UpdateTaskStatusToNext(task);




                if (content.Status)


@@ -305,7 +315,8 @@


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


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


        {


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


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


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


            if (task != null)


            {


                var config = _sys_ConfigService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);


@@ -342,6 +353,7 @@


                        ConveyorLineTaskCommand_After taskCommand = _mapper.Map<ConveyorLineTaskCommand_After>(newTask);


                        conveyorLine.SendCommand(taskCommand, childDeviceCode);


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


                        _taskService.UpdateData(newTask);


                    }


                }


                else


@@ -363,21 +375,35 @@


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


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


        {


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


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


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


            if (task != null)


            {


                WebResponseContent content = new WebResponseContent();


                ConveyorLineTaskCommand_After taskCommand = _mapper.Map<ConveyorLineTaskCommand_After>(task);


                taskCommand.InteractiveSignal = command.InteractiveSignal;


                Dt_StationManager stationManager = _stationManagerRepository.QueryFirst(x => x.stationPLC == conveyorLine.DeviceCode && x.stationChildCode == childDeviceCode);


                if (task.PalletCode != command.ConveyorLineBarcode)


                {


                    var NGAddress = _platFormRepository.QueryFirst(x => x.PlatCode == task.TargetAddress).Capacity;


                    taskCommand.ConveyorLineTargetAddress = (short)NGAddress;


                    //var NGAddress = _platFormRepository.QueryFirst(x => x.PlatCode == task.TargetAddress).Capacity;


                    //taskCommand.ConveyorLineTargetAddress = (short)NGAddress;


                    taskCommand.ConveyorLineTargetAddress = Convert.ToInt16(stationManager.stationNGChildCode);


                }


                else


                {


                    Dt_StationManager stationManager = _stationManagerRepository.QueryFirst(x => x.stationPLC == conveyorLine.DeviceCode && x.stationChildCode == childDeviceCode);


                    //Dt_StationManager stationManager = _stationManagerRepository.QueryFirst(x => x.stationPLC == conveyorLine.DeviceCode && x.stationChildCode == childDeviceCode);


                    taskCommand.ConveyorLineTargetAddress = Convert.ToInt16(stationManager.stationLocation);


                }




                if (stationManager.stationPLC == "1018" && stationManager.stationArea == "Cache")  //更新在途数据


                {


                    dt_needBarcode needBarcode = _needBarcodeRepository.QueryFirst(x => x.productLine == stationManager.productLine && x.toArea == stationManager.stationChildCode);




                    if (needBarcode != null)


                    {


                        needBarcode.inLineNum--;


                        _needBarcodeRepository.UpdateData(needBarcode);


                    }


                }




                conveyorLine.SendCommand(taskCommand, childDeviceCode);


@@ -385,6 +411,24 @@


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


                content = _taskService.UpdateTaskStatusToNext(task);


            }


            //else


            //{


            //    Dt_StationManager stationManager = _stationManagerRepository.QueryFirst(x => x.stationPLC == conveyorLine.DeviceCode && x.stationChildCode == childDeviceCode && x.stationArea == "Cache");


            //    ////查询对应产线的在途数据


            //    //dt_needBarcode needBarcode = _needBarcodeRepository.QueryFirst(x => x.productLine == station.productLine);




            //    //needBarcode.inLineNum = _taskRepository.QueryData(x => x.TargetAddress == station.stationChildCode).Count();




            //    //若在途数量小于目标位置的缓存数量 则寻找对应常温库存中常温3工序的可出库数据 并建立出库任务


            //    //if (needBarcode.inLineNum <= needBarcode.cacheNum)


            //    //{


            //    //}


            //    //如果包装缓存站台存在 且有请求  则


            //    if (stationManager != null)


            //    {


            //        _taskService.RequestOutTaskToBZAsync(stationManager);


            //    }


            //}


        }




        /// <summary>


@@ -410,7 +454,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


            {


@@ -419,7 +463,7 @@


                    taskOutboundTypeEnum = TaskOutboundTypeEnum.OutTray;


                else


                    taskOutboundTypeEnum = TaskOutboundTypeEnum.Outbound;


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


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


            }


            catch (Exception)


            {


@@ -429,10 +473,10 @@


        /// <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, Platform platform)


        {


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


            if (tasks.Count < index)


            if (tasks.Count < platform.Capacity)


            {


                #region 调用WMS获取出库任务




@@ -448,8 +492,11 @@


                }


                var wmsIpAddress = wmsBase + requestTrayOutTask;




                //var device = _deviceInfoRepository.QueryData(x => x.DeviceStatus == "1" && x.DeviceRemark == platform.Id.ToString());


                //var deviceCode = device.Select(x => x.DeviceCode).ToList();


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




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


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


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




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


@@ -460,7 +507,7 @@




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




                #endregion


                #endregion 调用WMS获取出库任务




                CreateAndSendTask(taskDTO);


            }


@@ -478,10 +525,7 @@


            }


            return content;


        }










    }


}




#endregion