1. <?php
  3. /**
  4. * Aggregates form submissions for data migration.
  5. *
  6. * This script reads data from a specified file (e.g., CSV, JSON)
  7. * and aggregates values based on a key. It's designed for minimal
  8. * configuration.
  9. *
  10. * Usage:
  11. * php aggregate_data.php <input_file> <output_file> <aggregation_key>
  12. *
  13. * <input_file>: Path to the file containing form submissions.
  14. * <output_file>: Path to the file where aggregated data will be saved (CSV).
  15. * <aggregation_key>: The key to group data by.
  16. */
  18. // --- Configuration ---
  19. $inputFile = $argv[1]; // Input file path
  20. $outputFile = $argv[2]; // Output file path
  21. $aggregationKey = $argv[3]; // Key to aggregate by
  23. // --- Data Loading & Aggregation ---
  24. try {
  25. // Attempt to load data from CSV. Adapt for other formats (JSON, XML)
  26. $data = [];
  27. if (substr($inputFile, -3) === 'csv') {
  28. $handle = fopen($inputFile, 'r');
  29. if ($handle) {
  30. $header = fgetcsv($handle);
  31. while (($row = fgetcsv($handle)) !== FALSE) {
  32. $data[$row[$aggregationKey]] = $row[0]; // Aggregate value (assuming first column)
  33. }
  34. fclose($handle);
  35. } else {
  36. throw new Exception("Failed to open input file.");
  37. }
  38. } else {
  39. throw new Exception("Unsupported input file format. Only CSV supported.");
  40. }
  42. // --- Output to CSV ---
  43. $output = fopen($outputFile, 'w');
  44. if ($output) {
  45. fputcsv($output, ['Aggregation Key', 'Aggregated Value']);
  46. foreach ($data as $key => $value) {
  47. fputcsv($output, [$key, $value]);
  48. }
  49. fclose($output);
  50. } else {
  51. throw new Exception("Failed to open output file.");
  52. }
  54. echo "Data aggregated and saved to: " . $outputFile . "\n";
  56. } catch (Exception $e) {
  57. echo "Error: " . $e->getMessage() . "\n";
  58. exit(1);
  59. }
  61. ?>

Add your comment