| | |
|---|
| | | if (item.StationType == StationTypeEnum.StationType_InStartAndOutEnd.ObjToInt() && deviceProRead != null) |
|---|
| | | { |
|---|
| | | R_ConveyorLineCPInfo conveyorLineInfoRead = device.Communicator.ReadCustomer<R_ConveyorLineCPInfo>(deviceProRead.DeviceProAddress); |
|---|
| | | //鐮佸灈婊＄洏鐢熸垚RGV鎼繍浠诲姟 |
|---|
| | | if (conveyorLineInfoRead != null && conveyorLineInfoRead.StatusPV == 2 && conveyorLineInfoRead.Command == 11) |
|---|
| | | { |
|---|
| | | Dt_Task task = _taskRepository.QueryFirst(x => x.SourceAddress == item.StationCode && _taskService.TaskInboundTypes.Contains(x.TaskType) && (x.TaskState == TaskStatusEnum.RGV_Execute.ObjToInt() || x.TaskState == TaskStatusEnum.RGV_Executing.ObjToInt() || x.TaskState == TaskStatusEnum.New.ObjToInt())); |
|---|
| | | if (task == null) |
|---|
| | | { |
|---|
| | | //鑾峰彇绔欏彴鐢熸垚浠诲姟 |
|---|
| | | WebResponseContent content = _taskService.RequestWMSTaskSimple("", item.StationCode); |
|---|
| | | WebResponseContent content = _taskService.RequestWMSTaskSimple("", item.StationCode,taskType:TaskTypeEnum.InProduct.ObjToInt()); |
|---|
| | | if (content.Status) |
|---|
| | | { |
|---|
| | | Dt_Task taskNew = _taskRepository.QueryFirst(x => x.SourceAddress == item.StationCode && _taskService.TaskInboundTypes.Contains(x.TaskType) && (x.TaskState == TaskStatusEnum.New.ObjToInt())); |
|---|
| | |
|---|
| | | Thread.Sleep(1000); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (conveyorLineInfoRead != null && conveyorLineInfoRead.StatusPV == 2 && conveyorLineInfoRead.Command == 10) |
|---|
| | | { |
|---|
| | | item.IsOccupied = 0; |
|---|
| | | } |
|---|
| | | else |
|---|
| | | { |
|---|
| | | item.IsOccupied = 1; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | _stationMangerRepository.UpdateData(stationMangers); |
|---|
| | | } |
|---|
| | | return Task.CompletedTask; |
|---|
| | | } |
|---|
