1. <?php
  3. /**
  4. * Filters JSON data with retry logic for data migration.
  5. *
  6. * @param string $jsonString The JSON string to parse and filter.
  7. * @param array $filters An array of filter criteria (e.g., ['field' => 'name', 'operator' => '=', 'value' => 'John']).
  8. * @param int $maxRetries The maximum number of retry attempts.
  9. * @param int $retryDelay The delay in seconds between retries.
  10. *
  11. * @return array|null An array of filtered JSON objects, or null on failure after all retries.
  12. */
  13. function filterJsonDataWithRetry(string $jsonString, array $filters, int $maxRetries = 3, int $retryDelay = 5): ?array
  14. {
  15. $filteredData = [];
  16. $retries = 0;
  18. while ($retries < $maxRetries) {
  19. $retries++;
  21. $data = json_decode($jsonString, true);
  23. if ($data === null) {
  24. // JSON decode failed.
  25. error_log("JSON decode failed. Attempt: " . $retries);
  26. if ($retries === $maxRetries) {
  27. return null; // Return null if all retries fail.
  28. }
  30. sleep($retryDelay);
  31. continue; // Retry
  32. }
  34. foreach ($data as $item) {
  35. $match = true;
  36. foreach ($filters as $filter) {
  37. $field = $filter['field'];
  38. $operator = $filter['operator'];
  39. $value = $filter['value'];
  41. if (!isset($item[$field])) {
  42. $match = false;
  43. break;
  44. }
  46. switch ($operator) {
  47. case '=':
  48. if ($item[$field] !== $value) {
  49. $match = false;
  50. break;
  51. }
  52. break;
  53. case '!=':
  54. if ($item[$field] === $value) {
  55. $match = false;
  56. break;
  57. }
  58. break;
  59. case '>':
  60. if ($item[$field] <= $value) {
  61. $match = false;
  62. break;
  63. }
  64. break;
  65. case '<':
  66. if ($item[$field] >= $value) {
  67. $match = false;
  68. break;
  69. }
  70. break;
  71. case 'in':
  72. if (!in_array($item[$field], [$value])) {
  73. $match = false;
  74. break;
  75. }
  76. break;
  77. default:
  78. error_log("Unsupported operator: " . $operator . ". Attempt: " . $retries);
  79. $match = false;
  80. break;
  81. }
  82. }
  84. if ($match) {
  85. $filteredData[] = $item;
  86. }
  87. }
  89. break; // Exit the retry loop if successful.
  90. }
  92. return $filteredData;
  93. }
  95. ?>

Add your comment