From e2db9ed61846ff4d7ba99e0abedaa93eccae80ff Mon Sep 17 00:00:00 2001 From: lumijiez <59575049+lumijiez@users.noreply.github.com> Date: Thu, 22 May 2025 22:17:37 +0300 Subject: [PATCH] prediction charts --- src/app/api/predictions/route.js | 95 ++++++++++++++++++++ src/app/page.js | 10 +++ src/components/PowerPredictionGraph.js | 118 +++++++++++++++++++++++++ src/lib/models/prediction.js | 30 +++++++ 4 files changed, 253 insertions(+) create mode 100644 src/app/api/predictions/route.js create mode 100644 src/components/PowerPredictionGraph.js create mode 100644 src/lib/models/prediction.js diff --git a/src/app/api/predictions/route.js b/src/app/api/predictions/route.js new file mode 100644 index 0000000..21cf644 --- /dev/null +++ b/src/app/api/predictions/route.js @@ -0,0 +1,95 @@ +import { NextResponse } from 'next/server'; +import { connectToDatabase } from '@/lib/mongodb'; + +const CACHE_DURATION = 2 * 60 * 60 * 1000; // 2 hours in milliseconds + +async function fetchWeatherData() { + const response = await fetch( + `http://api.weatherapi.com/v1/forecast.json?key=${process.env.WEATHER_API_KEY}&q=47.06149235737582,28.86683069635403&days=7&aqi=no` + ); + if (!response.ok) throw new Error('Failed to fetch weather data'); + return response.json(); +} + +async function calculatePrediction(weatherData, historicalData) { + // Simple prediction model based on weather conditions and historical data + const predictions = weatherData.forecast.forecastday.map(day => { + const cloudCover = day.day.cloud; + const rainChance = day.day.daily_chance_of_rain; + const avgTemp = (day.day.maxtemp_c + day.day.mintemp_c) / 2; + + // Base prediction on historical average + const historicalAvg = historicalData.reduce((sum, data) => sum + data.power, 0) / historicalData.length; + + // Adjust based on weather conditions + let weatherFactor = 1.0; + weatherFactor *= (100 - cloudCover) / 100; // Less clouds = more power + weatherFactor *= (100 - rainChance) / 100; // Less rain = more power + weatherFactor *= Math.min(1, 1 - Math.abs(avgTemp - 25) / 50); // Optimal temperature around 25°C + + const predictedPower = historicalAvg * weatherFactor; + const confidence = 0.7 + (weatherFactor * 0.3); // Higher confidence for better weather conditions + + return { + date: new Date(day.date), + predictedPower: Math.round(predictedPower * 100) / 100, + weatherData: day, + confidence: Math.round(confidence * 100) / 100 + }; + }); + + return predictions; +} + +export async function GET() { + try { + const { db } = await connectToDatabase(); + const now = new Date(); + + // Check for cached predictions + const cachedPredictions = await db.collection('predictions') + .find({ + date: { $gte: now }, + lastUpdated: { $gte: new Date(now.getTime() - CACHE_DURATION) } + }) + .sort({ date: 1 }) + .toArray(); + + if (cachedPredictions.length === 7) { + return NextResponse.json(cachedPredictions); + } + + // Fetch fresh weather data + const weatherData = await fetchWeatherData(); + + // Get historical power data for the last 30 days + const thirtyDaysAgo = new Date(now.getTime() - 30 * 24 * 60 * 60 * 1000); + const historicalData = await db.collection('power') + .find({ timestamp: { $gte: thirtyDaysAgo } }) + .toArray(); + + // Calculate new predictions + const predictions = await calculatePrediction(weatherData, historicalData); + + // Store predictions in database + const bulkOps = predictions.map(prediction => ({ + updateOne: { + filter: { date: prediction.date }, + update: { $set: prediction }, + upsert: true + } + })); + + if (bulkOps.length > 0) { + await db.collection('predictions').bulkWrite(bulkOps); + } + + return NextResponse.json(predictions); + } catch (error) { + console.error('Prediction error:', error); + return NextResponse.json( + { error: 'Failed to generate predictions' }, + { status: 500 } + ); + } +} \ No newline at end of file diff --git a/src/app/page.js b/src/app/page.js index c97ddac..e02e665 100644 --- a/src/app/page.js +++ b/src/app/page.js @@ -11,6 +11,7 @@ import { Select, SelectContent, SelectItem, SelectTrigger, SelectValue } from '@ import { motion, AnimatePresence } from 'framer-motion' import { Navbar } from '@/components/Navbar' import WeatherForecast from '@/components/WeatherForecast' +import PowerPredictionGraph from '@/components/PowerPredictionGraph' export default function Dashboard() { const [data, setData] = useState([]) @@ -180,6 +181,15 @@ export default function Dashboard() { + + + + { + const fetchPredictions = async () => { + try { + const response = await fetch('/api/predictions'); + if (!response.ok) throw new Error('Failed to fetch predictions'); + const data = await response.json(); + setPredictions(data); + } catch (err) { + setError(err.message); + } finally { + setLoading(false); + } + }; + + fetchPredictions(); + }, []); + + if (loading) { + return ( +
+
Loading predictions...
+
+ ); + } + + if (error) { + return ( +
+
Error loading predictions
+
+ ); + } + + if (!predictions?.length) { + return null; + } + + const chartData = predictions.map(pred => ({ + date: new Date(pred.date).toLocaleDateString('en-US', { weekday: 'short' }), + predicted: pred.predictedPower, + confidence: pred.confidence * 100 + })); + + return ( + +

7-Day Power Generation Forecast

+
+ + + + + + + + + + + +
+ + ); +} \ No newline at end of file diff --git a/src/lib/models/prediction.js b/src/lib/models/prediction.js new file mode 100644 index 0000000..c160b82 --- /dev/null +++ b/src/lib/models/prediction.js @@ -0,0 +1,30 @@ +import mongoose from 'mongoose'; + +const predictionSchema = new mongoose.Schema({ + date: { + type: Date, + required: true, + index: true + }, + predictedPower: { + type: Number, + required: true + }, + weatherData: { + type: Object, + required: true + }, + confidence: { + type: Number, + required: true + }, + lastUpdated: { + type: Date, + default: Date.now + } +}); + +// Create compound index for efficient querying +predictionSchema.index({ date: 1, lastUpdated: 1 }); + +export const Prediction = mongoose.models.Prediction || mongoose.model('Prediction', predictionSchema); \ No newline at end of file