| | |
|---|
| | | { |
|---|
| | | 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鎼繍浠诲姟 |
|---|
| | |
|---|
| | | 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); |
|---|
| | | } |
|---|
| | | } |
|---|
