feat: add rivers overview component and sync lake volume data across the dataset

2026-06-08 19:36:54 +02:00
parent ec540e056d
commit 62c861e610
71 changed files with 139421 additions and 29818 deletions
@@ -0,0 +1,79 @@
+import fs from 'fs';
+import path from 'path';
+
+function fixExistingData() {
+  const dataDir = path.resolve('public/data');
+  if (!fs.existsSync(dataDir)) {
+    console.error('Data directory does not exist!');
+    return;
+  }
+
+  const files = fs.readdirSync(dataDir).filter(f => f.endsWith('.json'));
+  console.log(`Found ${files.length} data files to clean up...`);
+
+  files.forEach(file => {
+    const filePath = path.join(dataDir, file);
+    try {
+      const content = fs.readFileSync(filePath, 'utf-8');
+      const data = JSON.parse(content);
+
+      if (!Array.isArray(data)) return;
+
+      let lastKnownInflow: number | null = null;
+      let lastKnownVolume: number | null = null;
+      let fixCountInflow = 0;
+      let fixCountVolume = 0;
+
+      // First pass (oldest to newest): find and propagate values forward
+      data.forEach(record => {
+        // Handle inflow
+        if (record.inflow !== undefined && record.inflow !== null && record.inflow !== 0) {
+          lastKnownInflow = record.inflow;
+        } else if ((record.inflow === undefined || record.inflow === null || record.inflow === 0) && lastKnownInflow !== null) {
+          record.inflow = lastKnownInflow;
+          fixCountInflow++;
+        }
+
+        // Handle volume
+        if (record.volume !== undefined && record.volume !== null && record.volume !== 0) {
+          lastKnownVolume = record.volume;
+        } else if ((record.volume === undefined || record.volume === null || record.volume === 0) && lastKnownVolume !== null) {
+          record.volume = lastKnownVolume;
+          fixCountVolume++;
+        }
+      });
+
+      // Second pass (newest to oldest): if there were zeros at the very beginning of the file
+      // before any non-zero value was found, propagate backwards.
+      let nextKnownInflow: number | null = null;
+      let nextKnownVolume: number | null = null;
+      for (let i = data.length - 1; i >= 0; i--) {
+        const record = data[i];
+        if (record.inflow !== undefined && record.inflow !== null && record.inflow !== 0) {
+          nextKnownInflow = record.inflow;
+        } else if ((record.inflow === undefined || record.inflow === null || record.inflow === 0) && nextKnownInflow !== null) {
+          record.inflow = nextKnownInflow;
+          fixCountInflow++;
+        }
+
+        if (record.volume !== undefined && record.volume !== null && record.volume !== 0) {
+          nextKnownVolume = record.volume;
+        } else if ((record.volume === undefined || record.volume === null || record.volume === 0) && nextKnownVolume !== null) {
+          record.volume = nextKnownVolume;
+          fixCountVolume++;
+        }
+      }
+
+      if (fixCountInflow > 0 || fixCountVolume > 0) {
+        fs.writeFileSync(filePath, JSON.stringify(data, null, 2), 'utf-8');
+        console.log(`[${file}] Cleaned up ${fixCountInflow} inflows and ${fixCountVolume} volumes.`);
+      }
+    } catch (e: any) {
+      console.error(`Error processing file ${file}:`, e.message);
+    }
+  });
+
+  console.log('Cleanup finished.');
+}
+
+fixExistingData();