Update: 2026-07-06 19:17:19

backend/pricing-engine/migrations/003_add_surge_zones.sql

@@ -0,0 +1,16 @@
+-- Migration: Create competitor_surge_zones table for heatmap integration
+-- Purpose: Bridge the geographic surge anomalies from Node.js pricing engine to PHP heatmap
+
+CREATE TABLE IF NOT EXISTS `competitor_surge_zones` (
+  `id` INT AUTO_INCREMENT PRIMARY KEY,
+  `competitor_name` VARCHAR(100) NOT NULL,
+  `country_code` VARCHAR(5) NOT NULL,
+  `zone_key` VARCHAR(50) NOT NULL,
+  `latitude` DECIMAL(10,6) NOT NULL,
+  `longitude` DECIMAL(10,6) NOT NULL,
+  `avg_ppk` DECIMAL(10,3) NOT NULL,
+  `sample_count` INT NOT NULL,
+  `surge_multiplier` DECIMAL(5,3) NOT NULL DEFAULT 1.000,
+  `detected_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+  UNIQUE KEY `unique_zone` (`competitor_name`, `country_code`, `zone_key`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

backend/pricing-engine/src/db/connection.ts

@@ -164,6 +164,43 @@ export async function saveSurgeInsights(
   await pool.execute(sql, flatParams);
 }
 
+export async function saveSurgeZones(
+  pool: mysql.Pool,
+  zones: Array<{
+    competitorName: string;
+    countryCode: string;
+    zoneKey: string;
+    latitude: number;
+    longitude: number;
+    avgPpk: number;
+    sampleCount: number;
+    surgeMultiplier: number;
+  }>
+): Promise<void> {
+  if (zones.length === 0) return;
+
+  const values = zones.map(() => `(?, ?, ?, ?, ?, ?, ?, ?, NOW())`).join(',');
+  const flatParams: (string | number)[] = [];
+
+  for (const z of zones) {
+    flatParams.push(
+      z.competitorName, z.countryCode, z.zoneKey,
+      z.latitude, z.longitude, z.avgPpk, z.sampleCount, z.surgeMultiplier
+    );
+  }
+
+  const sql = `INSERT INTO competitor_surge_zones 
+    (competitor_name, country_code, zone_key, latitude, longitude, avg_ppk, sample_count, surge_multiplier, detected_at)
+    VALUES ${values}
+    ON DUPLICATE KEY UPDATE
+    avg_ppk = VALUES(avg_ppk),
+    sample_count = VALUES(sample_count),
+    surge_multiplier = VALUES(surge_multiplier),
+    detected_at = NOW()`;
+
+  await pool.execute(sql, flatParams);
+}
+
 export async function closeConnections(): Promise<void> {
   if (mysqlPool) {
     await mysqlPool.end();

backend/pricing-engine/src/index.ts

@@ -10,7 +10,7 @@
  * Cron integration: see crontab examples in package.json scripts
  */
 
-import { getMySQL, fetchSamples, saveFormulas, saveSurgeInsights, closeConnections } from './db/connection';
+import { getMySQL, fetchSamples, saveFormulas, saveSurgeInsights, saveSurgeZones, closeConnections } from './db/connection';
 import { runAnalysis } from './analysis/engine';
 import { Pool, RowDataPacket } from 'mysql2/promise';
 
@@ -255,6 +255,31 @@ async function processCompetitor(
     await saveSurgeInsights(pool, surgeInsights);
     console.log(`   ✅ Saved surge insight: avg ${avgMultiplier.toFixed(3)}x, hours ${peakStart}:00-${peakEnd}:00`);
   }
+
+  // --- Save surge zones ---
+  if (opts.mode !== 'report' && report.zones.length > 0) {
+    // Find the standard tier formula to use as a baseline for calculating surge multipliers
+    const standardTier = formulas.find(f => f.tier === 'standard') || formulas[0];
+    const baselinePpk = standardTier ? standardTier.kmRate : 0.350;
+
+    const surgeZones = report.zones
+      .filter(z => z.avgPpk > baselinePpk * 1.1) // Only keep zones with > 10% surge
+      .map(z => ({
+        competitorName: comp.competitor_name,
+        countryCode: comp.country_code,
+        zoneKey: z.zoneKey,
+        latitude: z.centerLat,
+        longitude: z.centerLng,
+        avgPpk: z.avgPpk,
+        sampleCount: z.samples.length,
+        surgeMultiplier: parseFloat((z.avgPpk / baselinePpk).toFixed(3)),
+      }));
+
+    if (surgeZones.length > 0) {
+      await saveSurgeZones(pool, surgeZones);
+      console.log(`   ✅ Saved ${surgeZones.length} surge zones for heatmap`);
+    }
+  }
 }
 
 async function fetchCompetitors(