1. <?php
  3. /**
  4. * Merges datasets of queues for staging environments with error handling.
  5. *
  6. * @param array $stagingQueues An array of staging queue datasets. Each element should be an associative array with a 'data' key containing the queue data.
  7. * @param string $outputFile The path to the output file where the merged data will be written.
  8. * @return bool True on success, false on failure.
  9. */
  10. function mergeStagingQueues(array $stagingQueues, string $outputFile): bool
  11. {
  12. if (empty($stagingQueues)) {
  13. error_log("Error: No staging queues provided.");
  14. return false;
  15. }
  17. $mergedData = [];
  18. foreach ($stagingQueues as $queue) {
  19. if (!isset($queue['data']) || !is_array($queue['data'])) {
  20. error_log("Error: Invalid queue data format. Skipping.");
  21. continue; // Skip to the next queue
  22. }
  23. $mergedData = array_merge($mergedData, $queue['data']);
  24. }
  26. if (empty($mergedData)) {
  27. error_log("Error: No data found in staging queues.");
  28. return false;
  29. }
  31. try {
  32. file_put_contents($outputFile, json_encode($mergedData));
  33. return true;
  34. } catch (Exception $e) {
  35. error_log("Error writing to file: " . $e->getMessage());
  36. return false;
  37. }
  38. }
  40. // Example Usage (replace with your actual data and file path)
  41. /*
  42. $stagingQueues = [
  43. [
  44. 'data' => [
  45. ['id' => 1, 'name' => 'Queue A'],
  46. ['id' => 2, 'name' => 'Queue B'],
  47. ],
  48. ],
  49. [
  50. 'data' => [
  51. ['id' => 3, 'name' => 'Queue C'],
  52. ['id' => 4, 'name' => 'Queue D'],
  53. ],
  54. ],
  55. ];
  57. $outputFile = 'merged_queues.json';
  59. if (mergeStagingQueues($stagingQueues, $outputFile)) {
  60. echo "Staging queues merged successfully to " . $outputFile . "\n";
  61. } else {
  62. echo "Staging queues merge failed.\n";
  63. }
  64. */
  66. ?>

Add your comment