| | |
|---|
| | | ConveyorLineSignal conveyorLineSignalRead = conveyorLineInfoRead.Signal.ByteToBoolObject<ConveyorLineSignal>(); |
|---|
| | | |
|---|
| | | ConveyorLineSignal conveyorLineSignalWrite = conveyorLineInfoWrite.Signal.ByteToBoolObject<ConveyorLineSignal>(); |
|---|
| | | if (item.StationType == StationTypeEnum.StationType_OnlyInbound.ObjToInt()) |
|---|
| | | { |
|---|
| | | if (conveyorLineSignalRead.STB && conveyorLineStatus.Online && conveyorLineStatus.Goods && !conveyorLineStatus.Alarm && !conveyorLineSignalWrite.ACK) |
|---|
| | | { |
|---|
| | | if (!string.IsNullOrEmpty(conveyorLineInfoRead.Barcode)) |
|---|
| | | { |
|---|
| | | WebResponseContent content = _taskService.RequestWMSTask(conveyorLineInfoRead.Barcode, item.StationCode); |
|---|
| | | if (content.Status) |
|---|
| | | { |
|---|
| | | device.SetValue(W_ConveyorLineDB.ACK, true, item.StationCode); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | else if (!conveyorLineSignalRead.STB && conveyorLineStatus.Online && conveyorLineStatus.Goods && !conveyorLineStatus.Alarm && conveyorLineSignalWrite.ACK) |
|---|
| | | { |
|---|
| | | Dt_Task task = _taskRepository.QueryFirst(x => x.CurrentAddress == item.StationCode && x.PalletCode == conveyorLineInfoRead.Barcode && x.DeviceCode == item.StationDeviceCode && x.TaskState == TaskStatusEnum.New.ObjToInt()); |
|---|
| | | if (task != null) |
|---|
| | | { |
|---|
| | | _taskService.UpdateTask(task, TaskStatusEnum.SC_Execute, currentAddress: item.StackerCraneStationCode, deviceCode: task.Roadway, nextAddress: task.TargetAddress); |
|---|
| | | } |
|---|
| | | #region |
|---|
| | | //if (item.StationType == StationTypeEnum.StationType_OnlyInbound.ObjToInt()) |
|---|
| | | //{ |
|---|
| | | // if (conveyorLineSignalRead.STB && conveyorLineStatus.Online && conveyorLineStatus.Goods && !conveyorLineStatus.Alarm && !conveyorLineSignalWrite.ACK) |
|---|
| | | // { |
|---|
| | | // if (!string.IsNullOrEmpty(conveyorLineInfoRead.Barcode)) |
|---|
| | | // { |
|---|
| | | // WebResponseContent content = _taskService.RequestWMSTask(conveyorLineInfoRead.Barcode, item.StationCode); |
|---|
| | | // if (content.Status) |
|---|
| | | // { |
|---|
| | | // device.SetValue(W_ConveyorLineDB.ACK, true, item.StationCode); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // else if (!conveyorLineSignalRead.STB && conveyorLineStatus.Online && conveyorLineStatus.Goods && !conveyorLineStatus.Alarm && conveyorLineSignalWrite.ACK) |
|---|
| | | // { |
|---|
| | | // Dt_Task task = _taskRepository.QueryFirst(x => x.CurrentAddress == item.StationCode && x.PalletCode == conveyorLineInfoRead.Barcode && x.DeviceCode == item.StationDeviceCode && x.TaskState == TaskStatusEnum.New.ObjToInt()); |
|---|
| | | // if (task != null) |
|---|
| | | // { |
|---|
| | | // _taskService.UpdateTask(task, TaskStatusEnum.SC_Execute, currentAddress: item.StackerCraneStationCode, deviceCode: task.Roadway, nextAddress: task.TargetAddress); |
|---|
| | | // } |
|---|
| | | |
|---|
| | | device.SetValue(W_ConveyorLineDB.ACK, false, item.StationCode); |
|---|
| | | } |
|---|
| | | // device.SetValue(W_ConveyorLineDB.ACK, false, item.StationCode); |
|---|
| | | // } |
|---|
| | | |
|---|
| | | } |
|---|
| | | else if (item.StationType == StationTypeEnum.StationType_OnlyOutbound.ObjToInt()) |
|---|
| | | //} |
|---|
| | | #endregion |
|---|
| | | //2016鍑哄簱绔欏彴浠诲姟瀹屾垚 |
|---|
| | | if (item.StationType == StationTypeEnum.StationType_OnlyOutbound.ObjToInt()) |
|---|
| | | { |
|---|
| | | if (conveyorLineSignalRead.STB) |
|---|
| | | { |
|---|
| | | device.SetValue(W_ConveyorLineDB.ACK, true, item.StationCode); |
|---|
| | | |
|---|
| | | Thread.Sleep(500); |
|---|
| | | device.SetValue(W_ConveyorLineDB.ACK, false, item.StationCode); |
|---|
| | | _taskService.TaskCompleted(conveyorLineInfoRead.TaskNum); |
|---|
| | | } |
|---|
| | | Thread.Sleep(500); |
|---|
| | | device.SetValue(W_ConveyorLineDB.ACK, false, item.StationCode); |
|---|
| | | } |
|---|
| | | else if (item.StationType == StationTypeEnum.StationType_InboundAndOutbound.ObjToInt()) |
|---|
| | | { |
|---|
| | | if (!conveyorLineSignalRead.STB && !conveyorLineSignalRead.ACK && conveyorLineStatus.Online && !conveyorLineStatus.Goods && !conveyorLineStatus.Alarm && !conveyorLineSignalWrite.STB && !conveyorLineSignalWrite.ACK) |
|---|
| | | { |
|---|
| | | Dt_Task task = _taskRepository.QueryFirst(x => _taskService.TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == TaskStatusEnum.New.ObjToInt() && string.IsNullOrEmpty(x.TargetAddress) && !string.IsNullOrEmpty(x.NextAddress)); |
|---|
| | | Dt_Task task = _taskRepository.QueryFirst(x => _taskService.TaskOutboundTypes.Contains(x.TaskType) && x.DeviceCode == item.StackerCraneCode && x.TaskState == TaskStatusEnum.New.ObjToInt() && string.IsNullOrEmpty(x.TargetAddress) && !string.IsNullOrEmpty(x.NextAddress)); |
|---|
| | | if (task != null) |
|---|
| | | { |
|---|
| | | _taskService.UpdateTask(task, TaskStatusEnum.SC_Execute, nextAddress: item.StationCode, deviceCode: item.StackerCraneCode, targetAddress: item.StationCode); |
|---|
| | | _taskService.UpdateTask(task, TaskStatusEnum.SC_Execute, nextAddress: item.StackerCraneStationCode, deviceCode: item.StackerCraneCode, targetAddress: item.StationCode); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (conveyorLineSignalRead.STB && conveyorLineStatus.Online && conveyorLineStatus.Goods && !conveyorLineStatus.Alarm && !conveyorLineSignalWrite.ACK)//鍏ュ簱 |
|---|
| | | { |
|---|
| | | Dt_Task task = _taskRepository.QueryFirst(x => x.TaskNum == conveyorLineInfoRead.TaskNum && x.NextAddress == item.StationCode); |
|---|
| | | Dt_Task task = _taskRepository.QueryFirst(x => x.TaskNum == conveyorLineInfoRead.TaskNum && x.DeviceCode == item.StationDeviceCode && x.NextAddress == item.StationCode); |
|---|
| | | if (task != null && task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup) |
|---|
| | | { |
|---|
| | | Dt_StationManger? stationManger = stationMangers.FirstOrDefault(x => x.StationCode == item.StationCode); |
|---|
