<?php
require_once __DIR__ . '/../models/Prospect.php';
require_once __DIR__ . '/../models/Client.php';
require_once __DIR__ . '/../models/ImportMask.php';
require_once __DIR__ . '/../lib/CsvService.php';
require_once __DIR__ . '/../lib/ImportAssistant.php';
class ProspectsController {
private $prospectModel;
private $clientModel;
private $importMaskModel;
private const IMPORT_ENTITY = 'prospects';
public function __construct() {
$this->prospectModel = new Prospect();
$this->clientModel = new Client();
$this->importMaskModel = new ImportMask();
}
public function handle(): void {
$action = $_GET['action'] ?? '';
switch ($action) {
case 'export_csv':
$this->exportCsv();
return;
case 'template_csv':
$this->downloadTemplate();
return;
case 'import_csv':
$this->importCsv();
return;
}
if ($_SERVER['REQUEST_METHOD'] === 'POST') {
if (isset($_POST['save_import_mask'])) {
$this->saveImportMask();
return;
}
if (isset($_POST['add_prospect'])) {
$this->addProspect();
return;
}
if (isset($_POST['edit_prospect'])) {
$this->editProspect();
return;
}
if (isset($_POST['delete_prospect'])) {
$this->deleteProspect();
return;
}
if (isset($_POST['convert_prospect'])) {
$this->convertProspect();
return;
}
}
$prospects = $this->prospectModel->getAll();
$importMasks = $this->importMaskModel->getAllForEntity(self::IMPORT_ENTITY);
require_once __DIR__ . '/../views/prospection.php';
}
private function getExportFields(): array {
return [
'id' => 'ID',
'prenom' => 'Prenom',
'nom' => 'Nom',
'entreprise' => 'Entreprise',
'telephone' => 'Telephone',
'email' => 'Email',
'montant_projet' => 'Montant projet',
'statut' => 'Statut',
];
}
private function getImportFields(): array {
return [
'prenom' => 'Prenom',
'nom' => 'Nom',
'entreprise' => 'Entreprise',
'telephone' => 'Telephone',
'email' => 'Email',
'montant_projet' => 'Montant projet',
'statut' => 'Statut',
];
}
private function exportCsv(): void {
$fields = CsvService::sanitizeSelectedFields($this->getExportFields(), $_GET['fields'] ?? null);
$rows = $this->prospectModel->getAll();
CsvService::downloadCsv('prospects.csv', $fields, $rows);
}
private function downloadTemplate(): void {
CsvService::downloadTemplate('prospects_template.csv', array_keys($this->getImportFields()));
}
private function importCsv(): void {
try {
$rows = CsvService::parseUploadedCsv($_FILES['csv_file'] ?? null);
$mask = $this->resolveImportMaskFromRequest();
$mappings = $this->resolveImportMappings($mask);
$savedMaskName = $this->persistImportMaskIfRequested($mappings);
$imported = 0;
foreach ($rows as $row) {
$mappedRow = ImportAssistant::mapRow($row, $this->getImportFields(), $mappings);
$prenom = trim((string) ($mappedRow['prenom'] ?? ''));
$nom = trim((string) ($mappedRow['nom'] ?? ''));
if ($prenom === '' && $nom === '') {
continue;
}
$this->prospectModel->add([
'prenom' => $prenom,
'nom' => $nom,
'entreprise' => trim((string) ($mappedRow['entreprise'] ?? '')),
'telephone' => trim((string) ($mappedRow['telephone'] ?? '')),
'email' => trim((string) ($mappedRow['email'] ?? '')),
'montant_projet' => (float) ($mappedRow['montant_projet'] ?? 0),
'statut' => trim((string) ($mappedRow['statut'] ?? 'Relancer par téléphone')),
]);
$imported++;
}
$suffix = !empty($mask['name']) ? ' via le masque "' . $mask['name'] . '".' : '.';
if ($savedMaskName !== '') {
$suffix .= ' Masque enregistre : ' . $savedMaskName . '.';
}
$this->redirectWithMessage('success', $imported . ' prospect(s) importe(s)' . $suffix);
} catch (RuntimeException $e) {
$this->redirectWithMessage('error', $e->getMessage());
}
}
private function saveImportMask(): void {
try {
$mappings = ImportAssistant::extractMappingsFromRequest($this->getImportFields(), 'mask_mapping');
if (count(array_filter($mappings, static function ($value) {
return $value !== '';
})) === 0) {
throw new RuntimeException('Renseignez au moins une correspondance de champ.');
}
$this->importMaskModel->save(
self::IMPORT_ENTITY,
trim((string) ($_POST['mask_name'] ?? '')),
$mappings
);
$this->redirectWithMessage('success', 'Masque d\'import enregistre.');
} catch (RuntimeException $e) {
$this->redirectWithMessage('error', $e->getMessage());
}
}
private function addProspect(): void {
$prenom = trim((string) ($_POST['prenom'] ?? ''));
$nom = trim((string) ($_POST['nom'] ?? ''));
if ($prenom !== '' || $nom !== '') {
$this->prospectModel->add($_POST);
}
header('Location: index.php?page=prospection');
exit;
}
private function editProspect(): void {
$id = $_POST['id'] ?? '';
$prenom = trim((string) ($_POST['prenom'] ?? ''));
$nom = trim((string) ($_POST['nom'] ?? ''));
if ($id && ($prenom !== '' || $nom !== '')) {
$this->prospectModel->update($id, $_POST);
}
header('Location: index.php?page=prospection');
exit;
}
private function deleteProspect(): void {
$id = $_POST['id'] ?? '';
if ($id) {
$this->prospectModel->delete($id);
}
header('Location: index.php?page=prospection');
exit;
}
private function convertProspect(): void {
$id = $_POST['id'] ?? '';
if (!$id) {
header('Location: index.php?page=prospection');
exit;
}
$prospect = $this->prospectModel->getById($id);
if (!$prospect) {
$this->redirectWithMessage('error', 'Prospect introuvable.');
}
$fullName = trim((string) (($prospect['prenom'] ?? '') . ' ' . ($prospect['nom'] ?? '')));
if ($fullName === '') {
$fullName = trim((string) ($prospect['nom'] ?? ''));
}
$this->clientModel->add(
$fullName,
trim((string) ($prospect['entreprise'] ?? '')),
trim((string) ($prospect['email'] ?? '')),
trim((string) ($prospect['telephone'] ?? '')),
'',
'',
''
);
$this->prospectModel->delete($id);
$this->redirectWithMessage('success', 'Prospect transforme en client.');
}
private function redirectWithMessage(string $status, string $message): void {
header('Location: index.php?page=prospection&csv_status=' . urlencode($status) . '&csv_message=' . urlencode($message));
exit;
}
private function resolveImportMaskFromRequest(): ?array {
$maskId = isset($_POST['import_mask_id']) ? (int) $_POST['import_mask_id'] : 0;
if ($maskId <= 0) {
return null;
}
$mask = $this->importMaskModel->getById($maskId);
if (!$mask || ($mask['entity_type'] ?? '') !== self::IMPORT_ENTITY) {
throw new RuntimeException('Masque d\'import introuvable.');
}
return $mask;
}
private function resolveImportMappings(?array $mask): array {
$maskMappings = is_array($mask['mappings'] ?? null) ? $mask['mappings'] : [];
$requestMappings = ImportAssistant::extractMappingsFromRequest($this->getImportFields());
return ImportAssistant::normalizeMappings(
$this->getImportFields(),
array_merge($maskMappings, $requestMappings)
);
}
private function persistImportMaskIfRequested(array $mappings): string {
$maskName = trim((string) ($_POST['save_mask_name'] ?? ''));
if ($maskName === '') {
return '';
}
if (count(array_filter($mappings, static function ($value) {
return trim((string) $value) !== '';
})) === 0) {
throw new RuntimeException('Impossible d\'enregistrer un masque vide. Renseignez au moins une correspondance de champ.');
}
$this->importMaskModel->save(self::IMPORT_ENTITY, $maskName, $mappings);
return $maskName;
}
}