<?php
session_start();
require_once __DIR__ . '/db/config.php';

if ($_SERVER['REQUEST_METHOD'] === 'POST') {
    $lead_id = $_POST['lead_id'] ?? null;
    $activity_type = $_POST['activity_type'] ?? null;
    $due_date = $_POST['due_date'] ?? null;
    $notes = $_POST['notes'] ?? null;

    if ($lead_id && $activity_type) {
        try {
            $pdo = db();
            $stmt = $pdo->prepare("INSERT INTO activities (LeadID, ActivityType, DueDate, Notes) VALUES (:lead_id, :activity_type, :due_date, :notes)");
            $stmt->execute([
                ':lead_id' => $lead_id,
                ':activity_type' => $activity_type,
                ':due_date' => !empty($due_date) ? $due_date : null,
                ':notes' => $notes
            ]);

            $_SESSION['success_message'] = "New activity added successfully!";

        } catch (PDOException $e) {
            $_SESSION['error_message'] = "Error adding activity: " . $e->getMessage();
        }
    } else {
        $_SESSION['error_message'] = "Lead ID and activity type are required.";
    }
} else {
    $_SESSION['error_message'] = "Invalid request method.";
}

header("Location: index.php");
exit;