Step 2 - Calculate Scope 1 Emissions

┌─────────────────────────────────────────────────────────────────────────────┐
│                           SCOPE 1: Direct Emissions                         │
├─────────────────────┬─────────────────────┬─────────────────────────────────┤
│  Stationary         │  Mobile             │  Process & Fugitive             │
│  Combustion         │  Combustion         │  Emissions                      │
├─────────────────────┼─────────────────────┼─────────────────────────────────┤
│  • Boilers          │  • Company cars     │  • Industrial processes         │
│  • Furnaces         │  • Trucks           │  • Refrigerant leaks            │
│  • Generators       │  • Forklifts        │  • Wastewater treatment CH₄     │
│  • Heaters          │  • Company fleet    │  • Natural gas leaks            │
└─────────────────────┴─────────────────────┴─────────────────────────────────┘

Facility Setup → Invoice Creation → Emissions Calculation
      ↓                ↓                      ↓
  Facility config   Fuel consumption    CO2e per invoice
  (with country)    records (invoices)  (method auto-selected)

# Create invoice for refrigerant recharge (fugitive emissions)
recharge_data = {
    "type": "recharge",
    "facility_percentages": [
        {
            "organization_id": os.getenv("DCYCLE_ORG_ID"),
            "facility_id": facility_id,
            "percentage": 1.0,
        }
    ],
    "base_quantity": 15,  # 15 kg of R-410A refrigerant
    "unit_id": "61743a63-ff70-459c-9567-5eee8f7dfd5c",  # kg
    "facility_fuel_id": refrigerant_fuel_id,  # R-410A fuel ID
    "start_date": "2024-03-15",
    "end_date": "2024-03-15",
    "invoice_id": "RECHARGE-2024-001",
    "uploaded_by": os.getenv("DCYCLE_USER_ID"),
    # "custom_emission_factor_id": "your-custom-ef-id",
}

response = requests.post(
    "https://api.dcycle.io/api/v1/invoices",
    headers=headers,
    json=recharge_data,
)

print(f"✅ Recharge recorded: {response.json()['id']}")
print(f"   R-410A has GWP of ~2,088 - high impact!")

# Create invoice for process emissions (e.g., VOC from painting operations)
process_data = {
    "type": "process",
    "facility_percentages": [
        {
            "organization_id": os.getenv("DCYCLE_ORG_ID"),
            "facility_id": facility_id,
            "percentage": 1.0,
        }
    ],
    "base_quantity": 250,  # 250 kg of VOC emissions
    "unit_id": "61743a63-ff70-459c-9567-5eee8f7dfd5c",  # kg
    "facility_fuel_id": process_fuel_id,  # Fuel/source associated with the process
    "start_date": "2024-01-01",
    "end_date": "2024-03-31",
    "invoice_id": "PROCESS-2024-Q1",
    "uploaded_by": os.getenv("DCYCLE_USER_ID"),
    # "custom_emission_factor_id": "your-custom-ef-id",
}

response = requests.post(
    "https://api.dcycle.io/api/v1/invoices",
    headers=headers,
    json=process_data,
)

print(f"✅ Process emissions recorded: {response.json()['id']}")

import requests
import os
from datetime import date, timedelta

headers = {
    "Authorization": f"Bearer {os.getenv('DCYCLE_API_KEY')}",
    "Content-Type": "application/json",
    "x-organization-id": os.getenv("DCYCLE_ORG_ID"),
    "x-user-id": os.getenv("DCYCLE_USER_ID"),
}

# Prepare daily waste water treatment data
daily_data = []
base_date = date(2024, 1, 1)

for i in range(31):  # January 2024
    measurement_date = base_date + timedelta(days=i)
    daily_data.append({
        "name": f"WWT-{measurement_date.isoformat()}",
        "measurement_date": measurement_date.isoformat(),
        "m3_water_in": 10000 + (i * 100),  # Daily influent (m³)
        "m3_water_out": 9500 + (i * 95),   # Daily effluent (m³)
        "kg_bod_per_m3_wwt_line": 0.25,    # BOD concentration
        "kg_n_per_m3_wwt_line": 0.04,      # Nitrogen concentration
        "kg_sludge": 500 + (i * 10),       # Sludge produced (kg)
        "kg_bod_per_kg_sludge_line": 0.6,
        "kg_bod_per_m3_wwd_line": 0.02,
        "kg_n_per_m3_wwd_line": 0.01,
        "m3_biogas_engine": 200,           # Biogas to engine (m³)
        "m3_biogas_flare": 50,             # Biogas flared (m³)
        "m3_biogas_boiler": 100,           # Biogas to boiler (m³)
        "st": 0.25,                        # Solids content
        "methane": 0.65,                   # Methane content in biogas
    })

wwt_data = {
    "facility_id": "your-wwt-facility-uuid",
    "daily_waste_water_treatment_data": daily_data,
}

response = requests.post(
    "https://api.dcycle.io/api/v1/bulk/waste_water_treatments",
    headers=headers,
    json=wwt_data,
)

wwt_records = response.json()
print(f"✅ Created {len(wwt_records)} waste water treatment records")
print(f"   Emissions calculated from CH₄ and N₂O")

Vehicle Registration → Fuel Consumption → Emissions Calculation
      ↓                      ↓                    ↓
  Fleet database      Monthly records        CO2e per vehicle

# Get presigned URL for bulk vehicle consumption upload
consumption_upload = requests.post(
    "https://api.dcycle.io/api/v1/vehicle_consumptions/bulk/csv",
    headers=headers,
    json={"file_name": "vehicle_consumptions_q1_2024.csv"},
).json()

print(f"✅ Upload URL generated for consumptions")
print(f"   CSV columns required:")
print(f"   description(optional), vehicle_license_plate, start_date_recharge,")
print(f"   end_date_recharge, quantity, unit_measure, organization_id")

description(optional),vehicle_license_plate,start_date_recharge,end_date_recharge,quantity,unit_measure,organization_id
January fuel,1234ABC,2024-01-01,2024-01-31,450,l,your-org-uuid
February fuel,1234ABC,2024-02-01,2024-02-29,420,l,your-org-uuid
Q1 fuel,5678XYZ,2024-01-01,2024-03-31,1250,l,your-org-uuid

# Get vehicle consumptions for a specific vehicle
vehicle_id = "your-vehicle-uuid"

consumptions = requests.get(
    f"https://api.dcycle.io/api/v1/vehicle_consumptions/vehicle/{vehicle_id}",
    headers=headers,
    params={
        "page": 1,
        "size": 50,
        "start_date": 1704067200,  # 2024-01-01 timestamp
        "end_date": 1711929600,    # 2024-04-01 timestamp
    },
).json()

print(f"📊 Vehicle Consumptions:")
for consumption in consumptions["items"]:
    print(f"   {consumption['start_date']} - {consumption['end_date']}")
    print(f"   Quantity: {consumption['quantity']} {consumption['unit_name']}")
    print(f"   CO₂e: {consumption.get('co2e', 'N/A')} kg")
    print()