updated

RoofTopCalculation.py

@@ -103,6 +103,25 @@ def rainFallPrediction(location,RainFallData):
         }
         
         return default_rainfall.get(location_lower, 750)  # Default to 750mm if location not found
+
+def daily_to_annual(daily_mm, method="simple", month=None, monthly_avg=None, mu=None, sigma=None, sims=10000):
+    if method == "simple":
+        return  daily_mm * 365
+    if method == "monthly_factor":
+        if month is None or monthly_avg is None:
+            raise ValueError("month and monthly_avg (array of 12) required")
+        days = calendar.monthrange(2024, month)[1]  # only for days count
+        # naive: scale predicted day to that month then sum using monthly averages
+        monthly_est = [monthly_avg[i] if i+1 != month else daily_mm * days for i in range(12)]
+        return sum(monthly_est)
+    if method == "monte_carlo":
+        if mu is None or sigma is None:
+            raise ValueError("mu and sigma required for monte_carlo")
+        draws = np.random.normal(mu, sigma, size=(sims, 365))
+        draws[draws < 0] = 0.0
+        totals = draws.sum(axis=1)
+        return {"mean": totals.mean(), "median": np.median(totals), "p10": np.percentile(totals,10), "p90": np.percentile(totals,90)}
+    raise ValueError("unknown method")
 def get_groundwater_level(lat, lon, date):
     """
     Fetch groundwater level from India WRIS API for a given lat, lon, and date.
@@ -112,41 +131,20 @@ def get_groundwater_level(lat, lon, date):
     # Here, we use Erode, Tamil Nadu for demonstration
     import requests
     url = (
-        "https://indiawris.gov.in/Dataset/Ground%20Water%20Level"
-        "?stateName=Tamil%20Nadu&districtName=Erode&agencyName=CGWB"
-        f"&startdate={date}&enddate={date}&download=false&page=0&size=1"
+        "https://indiawris.gov.in/Dataset/Ground Water Level?stateName=Tamil%20Nadu&districtName=Karur&agencyName=CGWB&startdate=2025-09-14&enddate=2025-09-14&download=false&page=0&size=1"
     )
-    headers = {
-        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36"
-    }
     try:
-        resp = requests.get(url, timeout=5, headers=headers)  # Reduced timeout to 5 seconds
-        print(f"[DEBUG] Groundwater API status: {resp.status_code}")
-        if resp.status_code == 200:
-            try:
-                data = resp.json()
-                print(f"[DEBUG] Groundwater API response: {data}")
-                # Parse groundwater level from response (update as per actual API response)
-                if data and isinstance(data, list) and len(data) > 0:
-                    gw_level = data[0].get('groundWaterLevel', 15)
-                    return float(gw_level)
-                else:
-                    print("[WARN] No groundwater data found in response.")
-            except Exception as json_err:
-                print(f"[ERROR] Failed to parse JSON: {json_err}\nResponse text: {resp.text}")
-        else:
-            print(f"[ERROR] Groundwater API returned status {resp.status_code}: {resp.text}")
-    except requests.exceptions.ConnectTimeout:
-        print(f"[ERROR] Connection timeout when fetching groundwater level")
-    except requests.exceptions.ReadTimeout:
-        print(f"[ERROR] Read timeout when fetching groundwater level")
-    except requests.exceptions.ConnectionError:
-        print(f"[ERROR] Connection error when fetching groundwater level")
+        resp = requests.post(url, timeout=10)
+        data = resp.json()
+        print(data)
+        if resp:
+            print(data)
+            if data:
+                gw_level = data['data'][0].get('dataValue', 15)
+                return float(gw_level)
     except Exception as e:
-        print(f"[ERROR] Exception fetching groundwater level: {e}")
-    
-    # Return a reasonable default based on Indian groundwater levels
-    return 15  # fallback default (meters below ground level)
+        print(f"Error fetching groundwater level: {e}")
+    return 15  # fallback default
 
 def get_soil_type(lat, lon):
     """
@@ -155,23 +153,16 @@ def get_soil_type(lat, lon):
     import requests
     url = f"https://api.openepi.io/soil/type?lat={lat}&lon={lon}&top_k=3"
     try:
-        resp = requests.get(url, timeout=5)  # Reduced timeout to 5 seconds
+        resp = requests.get(url, timeout=10)
         if resp.status_code == 200:
             data = resp.json()
             # Parse soil type from response (update as per actual API response)
-            if data and 'soil_types' in data and len(data['soil_types']) > 0:
-                return data['soil_types'][0].get('name', 'Loamy')
-    except requests.exceptions.ConnectTimeout:
-        print(f"[ERROR] Connection timeout when fetching soil type")
-    except requests.exceptions.ReadTimeout:
-        print(f"[ERROR] Read timeout when fetching soil type")
-    except requests.exceptions.ConnectionError:
-        print(f"[ERROR] Connection error when fetching soil type")
+            if data:
+                return data['properties'].get('most_probable_soil_type', 'Loamy')
     except Exception as e:
         print(f"Error fetching soil type: {e}")
     return "Loamy"  # fallback default
 
-
 def RooftTopCalculation(input_data,RainFallData):
     """
     Calculate rainwater harvesting parameters based on input data
@@ -280,18 +271,19 @@ def RooftTopCalculation(input_data,RainFallData):
 def get_coordinates(location):
     """Get coordinates for a location (simplified - would use geocoding service in production)"""
     location_coordinates = {
-        "karur": [10.9601, 78.0766],
-        "new delhi": [28.6139, 77.2090],
-        "delhi": [28.6139, 77.2090],
-        "mumbai": [19.0760, 72.8777],
-        "bangalore": [12.9716, 77.5946],
-        "chennai": [13.0827, 80.2707],
-        "hyderabad": [17.3850, 78.4867],
-        "pune": [18.5204, 73.8567],
-        "kolkata": [22.5726, 88.3639],
-        "ahmedabad": [23.0225, 72.5714],
-        "jaipur": [26.9124, 75.7873]
-    }
+    "karur": [10.9601, 78.0766],
+    "new delhi": [28.6139, 77.2090],
+    "delhi": [28.6139, 77.2090],
+    "mumbai": [19.0760, 72.8777],
+    "bangalore": [12.9716, 77.5946],
+    "chennai": [13.0827, 80.2707],
+    "hyderabad": [17.3850, 78.4867],
+    "salem": [11.6643, 78.1460],
+    "kolkata": [22.5726, 88.3639],
+    "madurai": [9.9252, 78.1198],
+    "erode": [11.3410, 77.7172]
+}
+
     
     location_lower = location.lower()
     return location_coordinates.get(location_lower, [28.6139, 77.2090])  # Default to Delhi
@@ -399,4 +391,4 @@ def get_regional_language(location):
         "jaipur": "Hindi"
     }
     
-    return language_map.get(location.lower(), "Hindi")
+    return language_map.get(location.lower(), "Tamil")