代码更新

wangxinhui

昨天 011ca316e6ec2ed93e31c45a9ebd9d3c66664871

 ÏîÄ¿´úÂë/WCS/WCSServices/WIDESEAWCS_Tasks/³ÉÆ·²Ö/ConveyorLineJob_CPH.cs

@@ -89,133 +89,158 @@
                            List<Dt_StationManger> stationMangers = _stationMangerRepository.QueryData(x => x.StationDeviceCode == device.DeviceCode);
                            Task.Run(() =>
                            {
                                try
                                bool shouldRestart = true;

                                while (shouldRestart)
                                {
                                    Dt_StationManger? RequestIn = stationMangers.FirstOrDefault(x => x.StationDeviceCode == device.DeviceCode && x.StationType == StationTypeEnum.StationType_OnlyInbound.ObjToInt());
                                    while (true)
                                    try
                                    {
                                        if (RequestIn != null)
                                        shouldRestart = false;
                                        Dt_StationManger? RequestIn = stationMangers.FirstOrDefault(x => x.StationDeviceCode == device.DeviceCode && x.StationType == StationTypeEnum.StationType_OnlyInbound.ObjToInt());
                                        WriteInfo($"线程 {Thread.CurrentThread.ManagedThreadId}分垛口","开始执行");
                                        while (true)
                                        {
                                            DeviceProDTO? deviceProRead = device.DeviceProDTOs.Where(x => x.DeviceChildCode == RequestIn.StationCode && x.DeviceProParamType == nameof(R_CLineCPHDB)).OrderBy(x => x.DeviceProOffset).FirstOrDefault();
                                            DeviceProDTO? deviceProWrite = device.DeviceProDTOs.Where(x => x.DeviceChildCode == RequestIn.StationCode && x.DeviceProParamType == nameof(W_CLineCPHDB)).OrderBy(x => x.DeviceProOffset).FirstOrDefault();
                                            if (deviceProRead != null && deviceProWrite != null)
                                            //WriteInfo($"分垛口运行时间" , $"开始时间:" + DateTime.Now.ToString("HH:mm:ss.fff"));
                                            if (RequestIn != null)
                                            {
                                                R_CLineCPHInfo conveyorLineInfoRead = device.Communicator.ReadCustomer<R_CLineCPHInfo>(deviceProRead.DeviceProAddress);
                                                //码垛环线请求任务 
                                                if (conveyorLineInfoRead != null && (conveyorLineInfoRead.R_State == 2 || conveyorLineInfoRead.R_State == 3) && conveyorLineInfoRead.R_TaskNo <= 0 && !string.IsNullOrEmpty(conveyorLineInfoRead.R_BoxCode) && conveyorLineInfoRead.R_Request == 1)
                                                DeviceProDTO? deviceProRead = device.DeviceProDTOs.Where(x => x.DeviceChildCode == RequestIn.StationCode && x.DeviceProParamType == nameof(R_CLineCPHDB)).OrderBy(x => x.DeviceProOffset).FirstOrDefault();
                                                DeviceProDTO? deviceProWrite = device.DeviceProDTOs.Where(x => x.DeviceChildCode == RequestIn.StationCode && x.DeviceProParamType == nameof(W_CLineCPHDB)).OrderBy(x => x.DeviceProOffset).FirstOrDefault();
                                                if (deviceProRead != null && deviceProWrite != null)
                                                {
                                                    //判断是否任务已经存在
                                                    Dt_PackaxisTask packaxisTask = _packaxisTaskRepository.QueryFirst(x => x.BarCode == conveyorLineInfoRead.R_BoxCode.Trim() && x.TaskState == TaskStatusEnum.Line_Executing.ObjToInt());
                                                    if (packaxisTask != null)
                                                    R_CLineCPHInfo conveyorLineInfoRead = device.Communicator.ReadCustomer<R_CLineCPHInfo>(deviceProRead.DeviceProAddress);
                                                    //码垛环线请求任务 
                                                    if (conveyorLineInfoRead != null && (conveyorLineInfoRead.R_State == 2 || conveyorLineInfoRead.R_State == 3) && conveyorLineInfoRead.R_TaskNo <= 0 && !string.IsNullOrEmpty(conveyorLineInfoRead.R_BoxCode) && conveyorLineInfoRead.R_Request == 1)
                                                    {
                                                        //写入执行数据
                                                        device.SetValue(W_CLineCPHDB.W_TaskNo, packaxisTask.PackTaskNum, RequestIn.StationCode);
                                                        device.SetValue(W_CLineCPHDB.W_Channel, packaxisTask.NextAddress, RequestIn.StationCode);
                                                        device.SetValue(W_CLineCPHDB.W_Long, packaxisTask.PackLength, RequestIn.StationCode);
                                                        device.SetValue(W_CLineCPHDB.W_Wide, packaxisTask.PackWidth, RequestIn.StationCode);
                                                        device.SetValue(W_CLineCPHDB.W_High, packaxisTask.PackHeight, RequestIn.StationCode);
                                                        device.SetValue(W_CLineCPHDB.W_TMID, packaxisTask.BarCode, RequestIn.StationCode);
                                                        device.SetValue(W_CLineCPHDB.W_Request, 1, RequestIn.StationCode);
                                                    }
                                                    else
                                                    {
                                                        #region
                                                        WebResponseContent webResponse = _packaxisTaskService.ReqPackTask(conveyorLineInfoRead.R_BoxCode.Trim(), RequestIn.StationDeviceCode);
                                                        if (webResponse.Status)
                                                        //WriteInfo($"分垛口运行时间", $"{conveyorLineInfoRead.R_BoxCode}请求" + DateTime.Now.ToString("HH:mm:ss.fff"));
                                                        //判断是否任务已经存在
                                                        Dt_PackaxisTask packaxisTask = _packaxisTaskRepository.Db.Queryable<Dt_PackaxisTask>().Where(x => x.BarCode == conveyorLineInfoRead.R_BoxCode.Trim() && x.TaskState == TaskStatusEnum.Line_Executing.ObjToInt()).First();
                                                        if (packaxisTask != null)
                                                        {
                                                            Dt_PackaxisTask _PackaxisTask = webResponse.Data as Dt_PackaxisTask;
                                                            //写入执行数据
                                                            device.SetValue(W_CLineCPHDB.W_TaskNo, _PackaxisTask.PackTaskNum, RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_Channel, _PackaxisTask.NextAddress.ObjToInt(), RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_Long, _PackaxisTask.PackLength, RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_Wide, _PackaxisTask.PackWidth, RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_High, _PackaxisTask.PackHeight, RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_TMID, _PackaxisTask.BarCode, RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_TaskNo, packaxisTask.PackTaskNum, RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_Channel, packaxisTask.NextAddress, RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_Long, packaxisTask.PackLength, RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_Wide, packaxisTask.PackWidth, RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_High, packaxisTask.PackHeight, RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_TMID, conveyorLineInfoRead.R_BoxCode.Trim(), RequestIn.StationCode);
                                                            device.SetValue(W_CLineCPHDB.W_Request, 1, RequestIn.StationCode);
                                                            WebResponseContent content = _taskService.MESBoxCodeNotice(conveyorLineInfoRead.R_BoxCode.Trim());
                                                            if (content.Status)
                                                            {
                                                                WriteInfo(RequestIn.StationName, content.Message);
                                                            }
                                                            else
                                                            {
                                                                WriteError(RequestIn.StationName, content.Message);
                                                            }
                                                            //WriteInfo($"分垛口运行时间", $"{conveyorLineInfoRead.R_BoxCode}请求完成" + DateTime.Now.ToString("HH:mm:ss.fff"));
                                                        }
                                                        else
                                                        {
                                                            WriteError(RequestIn.StationName, webResponse.Message);
                                                            #region
                                                            WebResponseContent webResponse = _packaxisTaskService.ReqPackTask(conveyorLineInfoRead.R_BoxCode.Trim(), RequestIn.StationDeviceCode);
                                                            if (webResponse.Status)
                                                            {
                                                                Dt_PackaxisTask _PackaxisTask = webResponse.Data as Dt_PackaxisTask;
                                                                //写入执行数据
                                                                device.SetValue(W_CLineCPHDB.W_TaskNo, _PackaxisTask.PackTaskNum, RequestIn.StationCode);
                                                                device.SetValue(W_CLineCPHDB.W_Channel, _PackaxisTask.NextAddress.ObjToInt(), RequestIn.StationCode);
                                                                device.SetValue(W_CLineCPHDB.W_Long, _PackaxisTask.PackLength, RequestIn.StationCode);
                                                                device.SetValue(W_CLineCPHDB.W_Wide, _PackaxisTask.PackWidth, RequestIn.StationCode);
                                                                device.SetValue(W_CLineCPHDB.W_High, _PackaxisTask.PackHeight, RequestIn.StationCode);
                                                                device.SetValue(W_CLineCPHDB.W_TMID, conveyorLineInfoRead.R_BoxCode.Trim(), RequestIn.StationCode);
                                                                device.SetValue(W_CLineCPHDB.W_Request, 1, RequestIn.StationCode);
                                                                //WriteInfo($"分垛口运行时间", $"{conveyorLineInfoRead.R_BoxCode}请求完成" + DateTime.Now.ToString("HH:mm:ss.fff"));
                                                                WebResponseContent content = _taskService.MESBoxCodeNotice(conveyorLineInfoRead.R_BoxCode.Trim());
                                                                if (content.Status)
                                                                {
                                                                    WriteInfo(RequestIn.StationName, content.Message);
                                                                }
                                                                else
                                                                {
                                                                    WriteError(RequestIn.StationName, content.Message);
                                                                }
                                                            }
                                                            else
                                                            {
                                                                WriteError(RequestIn.StationName, webResponse.Message);
                                                            }
                                                            #endregion
                                                        }
                                                        #endregion
                                                        Thread.Sleep(200);
                                                    }
                                                }
                                                else
                                                {
                                                    WriteError(RequestIn.StationName, $"未找到设备子编号{RequestIn.StationCode}的协议信息");
                                                }
                                            }
                                            //WriteInfo($"分垛口运行时间", $"结束时间:" + DateTime.Now.ToString("HH:mm:ss.fff"));
                                        }
                                    }
                                    catch (Exception ex)
                                    {
                                        WriteInfo($"线程 {Thread.CurrentThread.ManagedThreadId}分垛口", $"异常:{ex.Message}");
                                        Thread.Sleep(3000);
                                        shouldRestart = true;
                                    }
                                }
                            });
                            Task.Run(() =>
                            {
                                bool shouldRestart = true;

                                while (shouldRestart)
                                {
                                    try
                                    {
                                        shouldRestart = false;
                                        //获取所有码垛口
                                        List<Dt_StationManger> stationMangersMD = stationMangers.Where(x => x.StationDeviceCode == device.DeviceCode && x.StationType == StationTypeEnum.StationType_OnlyOutbound.ObjToInt()).ToList();
                                        WriteInfo($"线程 {Thread.CurrentThread.ManagedThreadId}码垛口", "开始执行");
                                        while (true)
                                        {
                                            if (stationMangersMD.Count > 0)
                                            {
                                                foreach (var item in stationMangersMD)
                                                {
                                                    DeviceProDTO? deviceProRead = device.DeviceProDTOs.Where(x => x.DeviceChildCode == item.StationCode && x.DeviceProParamType == nameof(R_CLineCPHDB)).OrderBy(x => x.DeviceProOffset).FirstOrDefault();
                                                    if (deviceProRead != null)
                                                    {
                                                        R_CLineCPHChannelInfo conveyorLineInfoRead = device.Communicator.ReadCustomer<R_CLineCPHChannelInfo>(deviceProRead.DeviceProAddress);
                                                        //获取码垛口任务更新任务状态
                                                        if (conveyorLineInfoRead != null && conveyorLineInfoRead.R_State == 5 && conveyorLineInfoRead.R_TaskNo > 0)
                                                        {
                                                            Dt_PackaxisTask packaxisTask = _packaxisTaskRepository.QueryFirst(x => x.PackTaskNum == conveyorLineInfoRead.R_TaskNo && x.NextAddress == item.StationCode && x.TaskState == TaskStatusEnum.Line_Executing.ObjToInt() && x.DeviceCode == item.StationDeviceCode);
                                                            if (packaxisTask != null)
                                                            {
                                                                Dt_PackaxisTask packaxisTaskOld = _packaxisTaskRepository.QueryFirst(x => x.TaskState == TaskStatusEnum.MD_Executing.ObjToInt() && x.DeviceCode == item.StackerCraneCode);
                                                                if (packaxisTaskOld != null)
                                                                {
                                                                    WriteError(item.StationName, $"码垛{item.StackerCraneCode}正执行任务{packaxisTaskOld.PackTaskNum},无法继续下发");
                                                                }
                                                                else
                                                                {
                                                                    packaxisTask.CurrentAddress = item.StationCode;
                                                                    packaxisTask.NextAddress = packaxisTask.TargetAddress;
                                                                    packaxisTask.DeviceCode = item.StackerCraneCode;
                                                                    packaxisTask.TaskState = TaskStatusEnum.MD_Executing.ObjToInt();
                                                                    _packaxisTaskRepository.UpdateData(packaxisTask);
                                                                    device.SetValue(W_CLineCPHDB.W_Request, 1, item.StationCode);
                                                                }
                                                            }
                                                            else
                                                            {
                                                                WriteError(item.StationName, $"未找到任务{conveyorLineInfoRead.R_TaskNo}信息");
                                                            }
                                                            Thread.Sleep(2000);
                                                        }
                                                    }
                                                }
                                            }
                                            else
                                            {
                                                WriteError(RequestIn.StationName, $"未找到设备子编号{RequestIn.StationCode}的协议信息");
                                                WriteError(nameof(ConveyorLineJob_CPH), $"错误信息：未找到码垛口信息");
                                            }
                                        }
                                    }
                                }
                                catch (Exception ex)
                                {
                                    Thread.Sleep(1000);
                                }
                            });
                            Task.Run(() =>
                            {
                                try
                                {
                                    //获取所有码垛口
                                    List<Dt_StationManger> stationMangersMD = stationMangers.Where(x => x.StationDeviceCode == device.DeviceCode && x.StationType == StationTypeEnum.StationType_OnlyOutbound.ObjToInt()).ToList();
                                    while (true)
                                    catch (Exception ex)
                                    {
                                        if (stationMangersMD.Count > 0)
                                        {
                                            foreach (var item in stationMangersMD)
                                            {
                                                DeviceProDTO? deviceProRead = device.DeviceProDTOs.Where(x => x.DeviceChildCode == item.StationCode && x.DeviceProParamType == nameof(R_CLineCPHDB)).OrderBy(x => x.DeviceProOffset).FirstOrDefault();
                                                if (deviceProRead != null)
                                                {
                                                    R_CLineCPHChannelInfo conveyorLineInfoRead = device.Communicator.ReadCustomer<R_CLineCPHChannelInfo>(deviceProRead.DeviceProAddress);
                                                    //获取码垛口任务更新任务状态
                                                    if (conveyorLineInfoRead != null && conveyorLineInfoRead.R_State == 5 && conveyorLineInfoRead.R_TaskNo > 0)
                                                    {
                                                        Dt_PackaxisTask packaxisTask = _packaxisTaskRepository.QueryFirst(x => x.PackTaskNum == conveyorLineInfoRead.R_TaskNo && x.NextAddress == item.StationCode && x.TaskState == TaskStatusEnum.Line_Executing.ObjToInt() && x.DeviceCode == item.StationDeviceCode);
                                                        if (packaxisTask != null)
                                                        {
                                                            Dt_PackaxisTask packaxisTaskOld = _packaxisTaskRepository.QueryFirst(x => x.TaskState == TaskStatusEnum.MD_Executing.ObjToInt() && x.DeviceCode == item.StackerCraneCode);
                                                            if (packaxisTaskOld != null)
                                                            {
                                                                WriteError(item.StationName, $"码垛{item.StackerCraneCode}正执行任务{packaxisTaskOld.PackTaskNum},无法继续下发");
                                                            }
                                                            else
                                                            {
                                                                packaxisTask.CurrentAddress = item.StationCode;
                                                                packaxisTask.NextAddress = packaxisTask.TargetAddress;
                                                                packaxisTask.DeviceCode = item.StackerCraneCode;
                                                                packaxisTask.TaskState = TaskStatusEnum.MD_Executing.ObjToInt();
                                                                _packaxisTaskRepository.UpdateData(packaxisTask);
                                                            }
                                                        }
                                                        else
                                                        {
                                                            WriteError(item.StationName, $"未找到任务{conveyorLineInfoRead.R_TaskNo}信息");
                                                        }
                                                        Thread.Sleep(2000);
                                                    }
                                                }
                                            }
                                        }
                                        else
                                        {
                                            WriteError(nameof(ConveyorLineJob_CPH), $"错误信息：未找到码垛口信息");
                                        }
                                        WriteInfo($"线程 {Thread.CurrentThread.ManagedThreadId}码垛口", $"异常:{ex.Message}");
                                        Thread.Sleep(3000);
                                        shouldRestart = true;
                                    }
                                }
                                catch (Exception ex)
                                {
                                    Thread.Sleep(1000);
                                }
                            });