龙得利纸质行业立库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
wangxinhui
昨天 011ca316e6ec2ed93e31c45a9ebd9d3c66664871 
 ÏîÄ¿´úÂë/WCS/WCSServices/WIDESEAWCS_Tasks/³ÉÆ·²Ö/ConveyorLineJob_CPC.cs


@@ -65,6 +65,7 @@


            try


            {


                bool flag = context.JobDetail.JobDataMap.TryGetValue("JobParams", out object? value);


                bool isUpdate = false;


                if (flag && value != null)


                {


                    OtherDevice device = (OtherDevice)value;


@@ -74,7 +75,7 @@


                    {


                        DeviceProDTO? deviceProRead = device.DeviceProDTOs.Where(x => x.DeviceChildCode == item.StationCode && x.DeviceProParamType == nameof(R_ConveyorLineCPDB)).OrderBy(x => x.DeviceProOffset).FirstOrDefault();


                        DeviceProDTO? deviceProWrite = device.DeviceProDTOs.Where(x => x.DeviceChildCode == item.StationCode && x.DeviceProParamType == nameof(W_ConveyorLineCPDB)).OrderBy(x => x.DeviceProOffset).FirstOrDefault();


                        if (item.StationType == StationTypeEnum.StationType_InStartAndOutEnd.ObjToInt() && deviceProRead != null)


                        if (item.StationType == StationTypeEnum.StationType_InStartAndOutEnd.ObjToInt() && deviceProRead != null && deviceProWrite != null)


                        {


                            R_ConveyorLineCPInfo conveyorLineInfoRead = device.Communicator.ReadCustomer<R_ConveyorLineCPInfo>(deviceProRead.DeviceProAddress);


                            //码垛满盘生成RGV搬运任务


@@ -90,24 +91,32 @@


                                        Dt_Task taskNew = _taskRepository.QueryFirst(x => x.SourceAddress == item.StationCode && _taskService.TaskInboundTypes.Contains(x.TaskType) && (x.TaskState == TaskStatusEnum.New.ObjToInt()));


                                        if (taskNew != null)


                                        {


                                            device.SetValue(W_ConveyorLineCPDB.W_Command, 1, item.StationCode);


                                            _taskService.UpdateTask(taskNew, TaskStatusEnum.RGV_Execute);


                                        }


                                    }


                                    Thread.Sleep(1000);


                                }


                            }


                            if (conveyorLineInfoRead != null && conveyorLineInfoRead.StatusPV == 2 && conveyorLineInfoRead.Command == 10)


                            if (conveyorLineInfoRead != null && conveyorLineInfoRead.StatusPV == 2 && conveyorLineInfoRead.Command == 10 && item.IsOccupied == 1)


                            {


                                item.IsOccupied = 0;


                                isUpdate = true;


                                WriteInfo("码垛工位状态更新",$"{item.StationCode}{DateTime.Now}更新工位状态:{conveyorLineInfoRead.Command}");


                            }


                            else


                            else if ((conveyorLineInfoRead == null ||(conveyorLineInfoRead != null && conveyorLineInfoRead.Command != 10 && item.IsOccupied == 0)))


                            {


                                item.IsOccupied = 1;


                                isUpdate = true;


                                WriteInfo("码垛工位状态更新", $"{item.StationCode}{DateTime.Now}更新工位状态不可用");


                            }


                        }




                    }


                    _stationMangerRepository.UpdateData(stationMangers);


                    if (isUpdate)


                    {


                        _stationMangerRepository.UpdateData(stationMangers);


                    }


                }


            }


            catch (Exception ex)