Progetto Guidato — Creare un CRM con PHP e MySQL

CREATE TABLE aziende ( id INT AUTO_INCREMENT PRIMARY KEY, ragione_sociale VARCHAR(200) NOT NULL, settore VARCHAR(100) ); CREATE TABLE contatti ( id INT AUTO_INCREMENT PRIMARY KEY, nome VARCHAR(100) NOT NULL, email VARCHAR(150), azienda_id INT, FOREIGN KEY (azienda_id) REFERENCES aziende(id) ); CREATE TABLE trattative ( id INT AUTO_INCREMENT PRIMARY KEY, titolo VARCHAR(200) NOT NULL, valore DECIMAL(10,2), fase ENUM('lead', 'qualificato', 'proposta', 'chiuso_vinto', 'chiuso_perso') DEFAULT 'lead', contatto_id INT, commerciale_id INT, creata_il TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (contatto_id) REFERENCES contatti(id) ); CREATE TABLE interazioni ( id INT AUTO_INCREMENT PRIMARY KEY, trattativa_id INT, tipo ENUM('chiamata', 'email', 'riunione', 'nota'), contenuto TEXT, creata_il TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (trattativa_id) REFERENCES trattative(id) );

<?php $host = 'localhost'; $db = 'crm_volta'; $user = 'root'; $password = getenv('DB_PASSWORD'); try { $pdo = new PDO("mysql:host=$host;dbname=$db;charset=utf8mb4", $user, $password); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } catch (PDOException $e) { die("Connessione fallita: " . $e->getMessage()); } ?>

<?php require 'config.php'; echo "Connessione riuscita al database $db!"; ?>

<?php require 'config.php'; if ($_SERVER['REQUEST_METHOD'] === 'POST') { $titolo = $_POST['titolo'] ?? ''; $valore = (float) ($_POST['valore'] ?? 0); $stmt = $pdo->prepare("INSERT INTO trattative (titolo, valore) VALUES (:titolo, :valore)"); $stmt->execute(['titolo' => $titolo, 'valore' => $valore]); header('Location: trattative.php'); exit; } ?> <form method="post"> <input type="text" name="titolo" placeholder="Titolo trattativa" required> <input type="number" name="valore" step="0.01" placeholder="Valore €"> <button type="submit">Salva</button> </form>

<?php require 'config.php'; $stmt = $pdo->query("SELECT id, titolo, valore, fase FROM trattative ORDER BY creata_il DESC"); $trattative = $stmt->fetchAll(PDO::FETCH_ASSOC); ?> <h1>Le tue trattative</h1> <a href="nuova_trattativa.php">+ Nuova trattativa</a> <ul> <?php foreach ($trattative as $t): ?> <li><?= htmlspecialchars($t['titolo']) ?> — €<?= $t['valore'] ?> (<?= $t['fase'] ?>)</li> <?php endforeach; ?> </ul>

<?php require 'config.php'; if ($_SERVER['REQUEST_METHOD'] === 'POST') { $titolo = $_POST['titolo'] ?? ''; $valore = (float) ($_POST['valore'] ?? 0); $contattoId = (int) ($_POST['contatto_id'] ?? 0); $stmt = $pdo->prepare("INSERT INTO trattative (titolo, valore, contatto_id) VALUES (:titolo, :valore, :contatto_id)"); $stmt->execute(['titolo' => $titolo, 'valore' => $valore, 'contatto_id' => $contattoId]); header('Location: trattative.php'); exit; } // nuovo: elenco contatti per il menu a tendina $contatti = $pdo->query("SELECT id, nome FROM contatti")->fetchAll(PDO::FETCH_ASSOC); ?> <form method="post"> <input type="text" name="titolo" placeholder="Titolo trattativa" required> <input type="number" name="valore" step="0.01" placeholder="Valore €"> <select name="contatto_id"> <?php foreach ($contatti as $c): ?> <option value="<?= $c['id'] ?>"><?= htmlspecialchars($c['nome']) ?></option> <?php endforeach; ?> </select> <button type="submit">Salva</button> </form>

<?php require 'config.php'; $stmt = $pdo->query(" SELECT t.titolo, t.valore, t.fase, c.nome AS contatto, a.ragione_sociale AS azienda FROM trattative t LEFT JOIN contatti c ON t.contatto_id = c.id LEFT JOIN aziende a ON c.azienda_id = a.id ORDER BY t.creata_il DESC "); $righe = $stmt->fetchAll(PDO::FETCH_ASSOC); ?> <?php foreach ($righe as $r): ?> <p><?= htmlspecialchars($r['titolo']) ?> — <?= htmlspecialchars($r['contatto'] ?? 'nessun contatto') ?> (<?= htmlspecialchars($r['azienda'] ?? 'n/d') ?>)</p> <?php endforeach; ?>

<?php session_start(); require 'config.php'; if ($_SERVER['REQUEST_METHOD'] === 'POST') { $stmt = $pdo->prepare("SELECT * FROM utenti WHERE email = :email"); $stmt->execute(['email' => $_POST['email']]); $utente = $stmt->fetch(PDO::FETCH_ASSOC); if ($utente && password_verify($_POST['password'], $utente['password_hash'])) { $_SESSION['utente_id'] = $utente['id']; $_SESSION['ruolo'] = $utente['ruolo']; // 'manager' o 'commerciale' header('Location: trattative.php'); exit; } echo "Credenziali non valide"; } ?> <form method="post"> <input type="email" name="email" required> <input type="password" name="password" required> <button type="submit">Accedi</button> </form>

<?php session_start(); if (!isset($_SESSION['utente_id'])) { header('Location: login.php'); exit; } require 'config.php'; // se manager, vede tutto; se commerciale, solo le proprie trattative if ($_SESSION['ruolo'] === 'manager') { $stmt = $pdo->query("SELECT id, titolo, valore, fase FROM trattative ORDER BY creata_il DESC"); $trattative = $stmt->fetchAll(PDO::FETCH_ASSOC); } else { $stmt = $pdo->prepare("SELECT id, titolo, valore, fase FROM trattative WHERE commerciale_id = :id ORDER BY creata_il DESC"); $stmt->execute(['id' => $_SESSION['utente_id']]); $trattative = $stmt->fetchAll(PDO::FETCH_ASSOC); } ?> // il resto (il foreach che stampa l'elenco) resta identico al Passo 3

<?php session_start(); if (!isset($_SESSION['utente_id'])) { header('Location: login.php'); exit; } require 'config.php'; if ($_SERVER['REQUEST_METHOD'] === 'POST') { // ... come nel Passo 4, con l'aggiunta di commerciale_id ... $stmt = $pdo->prepare("INSERT INTO trattative (titolo, valore, contatto_id, commerciale_id) VALUES (:titolo, :valore, :contatto_id, :commerciale_id)"); $stmt->execute([ 'titolo' => $titolo, 'valore' => $valore, 'contatto_id' => $contattoId, 'commerciale_id' => $_SESSION['utente_id'] ]); } ?>

<?php session_start(); if (!isset($_SESSION['utente_id'])) { header('Location: login.php'); exit; } require 'config.php'; $id = (int) ($_GET['id'] ?? 0); if ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_POST['nuova_fase'])) { $faseValide = ['lead', 'qualificato', 'proposta', 'chiuso_vinto', 'chiuso_perso']; if (in_array($_POST['nuova_fase'], $faseValide)) { $stmt = $pdo->prepare("UPDATE trattative SET fase = :fase WHERE id = :id"); $stmt->execute(['fase' => $_POST['nuova_fase'], 'id' => $id]); } } if ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_POST['nuova_interazione'])) { $stmt = $pdo->prepare("INSERT INTO interazioni (trattativa_id, tipo, contenuto) VALUES (:tid, :tipo, :contenuto)"); $stmt->execute(['tid' => $id, 'tipo' => $_POST['tipo'], 'contenuto' => $_POST['nuova_interazione']]); } $interazioni = $pdo->prepare("SELECT tipo, contenuto, creata_il FROM interazioni WHERE trattativa_id = :id ORDER BY creata_il ASC"); $interazioni->execute(['id' => $id]); $storico = $interazioni->fetchAll(PDO::FETCH_ASSOC); ?> <?php foreach ($storico as $i): ?> <p>[<?= $i['tipo'] ?>] <?= htmlspecialchars($i['contenuto']) ?></p> <?php endforeach; ?>

<?php // aggiunta al report del Passo 4: query di sintesi per la pipeline $stmt = $pdo->query(" SELECT fase, COUNT(*) AS numero, SUM(valore) AS totale FROM trattative WHERE fase NOT IN ('chiuso_vinto', 'chiuso_perso') GROUP BY fase "); $pipeline = $stmt->fetchAll(PDO::FETCH_ASSOC); ?>