365 lines
14 KiB
PHP
365 lines
14 KiB
PHP
<?php
|
||
/**
|
||
* MSIN API ChronoTrack — config par eve_id (lien event, statut, mapping épreuves).
|
||
*/
|
||
|
||
function fxChronotrackApiConfigGet($intEveId) {
|
||
global $objDatabase;
|
||
|
||
$intEveId = intval($intEveId);
|
||
if ($intEveId <= 0) {
|
||
return null;
|
||
}
|
||
|
||
$sql = "SELECT * FROM api_chronotrack_config WHERE eve_id = " . $intEveId . " LIMIT 1";
|
||
return $objDatabase->fxGetRow($sql);
|
||
}
|
||
|
||
function fxChronotrackApiConfigStatusLabel($strStatus) {
|
||
switch ($strStatus) {
|
||
case MSIN_API_CHRONOTRACK_SYNC_ACTIF:
|
||
return 'Actif';
|
||
case MSIN_API_CHRONOTRACK_SYNC_FERME:
|
||
return 'Fermé';
|
||
case MSIN_API_CHRONOTRACK_SYNC_LIE:
|
||
default:
|
||
return 'Lié';
|
||
}
|
||
}
|
||
|
||
function fxChronotrackApiConfigSaveLink($intEveId, $intCtEventId, $strCtEventName, $strCtEventDate, $intUsaId) {
|
||
global $objDatabase;
|
||
|
||
$intEveId = intval($intEveId);
|
||
$intCtEventId = intval($intCtEventId);
|
||
if ($intEveId <= 0 || $intCtEventId <= 0) {
|
||
return array('state' => 'error', 'message' => 'Identifiants invalides');
|
||
}
|
||
|
||
$arrExisting = fxChronotrackApiConfigGet($intEveId);
|
||
if ($arrExisting !== null && $arrExisting['sync_status'] === MSIN_API_CHRONOTRACK_SYNC_FERME) {
|
||
return array('state' => 'error', 'message' => 'Événement fermé — réouverture non autorisée depuis cette interface.');
|
||
}
|
||
|
||
$strName = $objDatabase->fxEscape(trim($strCtEventName));
|
||
$strDateSql = 'NULL';
|
||
if (trim($strCtEventDate) !== '') {
|
||
$intTs = strtotime($strCtEventDate);
|
||
if ($intTs !== false) {
|
||
$strDateSql = "'" . $objDatabase->fxEscape(date('Y-m-d H:i:s', $intTs)) . "'";
|
||
}
|
||
}
|
||
|
||
if ($arrExisting === null) {
|
||
$sql = "INSERT INTO api_chronotrack_config SET eve_id = " . $intEveId
|
||
. ", ct_event_id = " . $intCtEventId
|
||
. ", ct_event_name = '" . $strName . "'"
|
||
. ", ct_event_date = " . $strDateSql
|
||
. ", sync_status = '" . MSIN_API_CHRONOTRACK_SYNC_LIE . "'"
|
||
. ", linked_at = '" . fxGetDateTime() . "'"
|
||
. ", linked_by_usa_id = " . intval($intUsaId)
|
||
. ", updated_at = '" . fxGetDateTime() . "'";
|
||
} else {
|
||
$sql = "UPDATE api_chronotrack_config SET ct_event_id = " . $intCtEventId
|
||
. ", ct_event_name = '" . $strName . "'"
|
||
. ", ct_event_date = " . $strDateSql
|
||
. ", updated_at = '" . fxGetDateTime() . "'"
|
||
. " WHERE eve_id = " . $intEveId
|
||
. " AND sync_status <> '" . MSIN_API_CHRONOTRACK_SYNC_FERME . "'";
|
||
}
|
||
|
||
if (!$objDatabase->fxQuery($sql)) {
|
||
return array('state' => 'error', 'message' => 'Erreur SQL enregistrement lien');
|
||
}
|
||
|
||
return array('state' => 'ok');
|
||
}
|
||
|
||
function fxChronotrackApiConfigSetStatus($intEveId, $strStatus, $intUsaId) {
|
||
global $objDatabase;
|
||
|
||
$intEveId = intval($intEveId);
|
||
$arrExisting = fxChronotrackApiConfigGet($intEveId);
|
||
if ($arrExisting === null) {
|
||
return array('state' => 'error', 'message' => 'Aucun lien ChronoTrack pour cet événement');
|
||
}
|
||
|
||
if ($arrExisting['sync_status'] === MSIN_API_CHRONOTRACK_SYNC_FERME) {
|
||
if ($strStatus !== MSIN_API_CHRONOTRACK_SYNC_LIE) {
|
||
return array('state' => 'error', 'message' => 'Événement fermé — seule la réouverture (Lié) est permise.');
|
||
}
|
||
}
|
||
|
||
$strStatus = trim($strStatus);
|
||
if (!in_array($strStatus, array(MSIN_API_CHRONOTRACK_SYNC_LIE, MSIN_API_CHRONOTRACK_SYNC_ACTIF, MSIN_API_CHRONOTRACK_SYNC_FERME), true)) {
|
||
return array('state' => 'error', 'message' => 'Statut invalide');
|
||
}
|
||
|
||
$strExtra = '';
|
||
if ($strStatus === MSIN_API_CHRONOTRACK_SYNC_ACTIF) {
|
||
$strExtra = ", activated_at = '" . fxGetDateTime() . "'";
|
||
}
|
||
if ($strStatus === MSIN_API_CHRONOTRACK_SYNC_FERME) {
|
||
$strExtra = ", closed_at = '" . fxGetDateTime() . "', closed_by_usa_id = " . intval($intUsaId);
|
||
}
|
||
if ($strStatus === MSIN_API_CHRONOTRACK_SYNC_LIE && $arrExisting['sync_status'] === MSIN_API_CHRONOTRACK_SYNC_FERME) {
|
||
$strExtra = ", closed_at = NULL, closed_by_usa_id = NULL";
|
||
}
|
||
|
||
$sql = "UPDATE api_chronotrack_config SET sync_status = '" . $objDatabase->fxEscape($strStatus) . "'"
|
||
. $strExtra
|
||
. ", updated_at = '" . fxGetDateTime() . "'"
|
||
. " WHERE eve_id = " . $intEveId;
|
||
if (!$objDatabase->fxQuery($sql)) {
|
||
return array('state' => 'error', 'message' => 'Erreur SQL changement statut');
|
||
}
|
||
|
||
return array('state' => 'ok');
|
||
}
|
||
|
||
/**
|
||
* MSIN-4328 — mémorise la fin d’un push réussi (référence pour par_maj).
|
||
*/
|
||
function fxChronotrackApiConfigSetLastPush($intEveId, $intOkCount) {
|
||
global $objDatabase;
|
||
|
||
$intEveId = intval($intEveId);
|
||
if ($intEveId <= 0) {
|
||
return false;
|
||
}
|
||
|
||
$sql = "UPDATE api_chronotrack_config SET last_push_at = '" . fxGetDateTime() . "'"
|
||
. ", last_push_ok_count = " . max(0, intval($intOkCount))
|
||
. ", updated_at = '" . fxGetDateTime() . "'"
|
||
. " WHERE eve_id = " . $intEveId;
|
||
return (bool)$objDatabase->fxQuery($sql);
|
||
}
|
||
|
||
/**
|
||
* MSIN-4328 — fréquences autorisées (minutes), phase A.
|
||
*/
|
||
function fxChronotrackApiConfigAutoSyncIntervals() {
|
||
return array(1, 5, 15, 30, 60);
|
||
}
|
||
|
||
/**
|
||
* MSIN-4328 — enregistre la config sync auto (UI). Le cron (phase B) lira ces champs.
|
||
*/
|
||
function fxChronotrackApiConfigSaveAutoSync($intEveId, $blnEnabled, $intIntervalMin, $strUntil) {
|
||
global $objDatabase;
|
||
|
||
$intEveId = intval($intEveId);
|
||
$arrExisting = fxChronotrackApiConfigGet($intEveId);
|
||
if ($arrExisting === null) {
|
||
return array('state' => 'error', 'message' => 'Événement non lié à ChronoTrack');
|
||
}
|
||
if (($arrExisting['sync_status'] ?? '') === MSIN_API_CHRONOTRACK_SYNC_FERME) {
|
||
return array('state' => 'error', 'message' => 'Événement fermé — sync auto impossible.');
|
||
}
|
||
|
||
$blnEnabled = $blnEnabled ? 1 : 0;
|
||
$intIntervalMin = intval($intIntervalMin);
|
||
if (!in_array($intIntervalMin, fxChronotrackApiConfigAutoSyncIntervals(), true)) {
|
||
$intIntervalMin = 15;
|
||
}
|
||
|
||
$strUntilSql = 'NULL';
|
||
$strUntil = trim((string)$strUntil);
|
||
if ($strUntil !== '') {
|
||
// Accepte "YYYY-MM-DDTHH:MM" (input datetime-local) ou "YYYY-MM-DD HH:MM[:SS]"
|
||
$strUntilNorm = str_replace('T', ' ', $strUntil);
|
||
if (preg_match('/^\d{4}-\d{2}-\d{2} \d{2}:\d{2}$/', $strUntilNorm)) {
|
||
$strUntilNorm .= ':00';
|
||
}
|
||
$intTs = strtotime($strUntilNorm);
|
||
if ($intTs === false) {
|
||
return array('state' => 'error', 'message' => 'Date / heure de fin invalide');
|
||
}
|
||
if ($blnEnabled && $intTs <= time()) {
|
||
return array('state' => 'error', 'message' => 'La date/heure de fin doit être dans le futur');
|
||
}
|
||
$strUntilSql = "'" . $objDatabase->fxEscape(date('Y-m-d H:i:s', $intTs)) . "'";
|
||
} elseif ($blnEnabled) {
|
||
return array('state' => 'error', 'message' => 'Indiquez une date et une heure de fin pour activer la sync auto');
|
||
}
|
||
|
||
$sql = "UPDATE api_chronotrack_config SET auto_sync_enabled = " . $blnEnabled
|
||
. ", auto_sync_interval_min = " . $intIntervalMin
|
||
. ", auto_sync_until = " . $strUntilSql
|
||
. ", updated_at = '" . fxGetDateTime() . "'"
|
||
. " WHERE eve_id = " . $intEveId;
|
||
if (!$objDatabase->fxQuery($sql)) {
|
||
return array('state' => 'error', 'message' => 'Erreur SQL enregistrement sync auto');
|
||
}
|
||
|
||
$arrFresh = fxChronotrackApiConfigGet($intEveId);
|
||
return array(
|
||
'state' => 'ok',
|
||
'message' => $blnEnabled
|
||
? ('Sync auto enregistrée (toutes les ' . $intIntervalMin . ' min jusqu’au '
|
||
. trim((string)($arrFresh['auto_sync_until'] ?? '')) . '). Cron : auto_chronotrack_sync.php')
|
||
: 'Sync auto désactivée.',
|
||
'auto_sync' => array(
|
||
'enabled' => intval($arrFresh['auto_sync_enabled'] ?? 0) === 1,
|
||
'interval_min' => intval($arrFresh['auto_sync_interval_min'] ?? 15),
|
||
'until' => ($arrFresh['auto_sync_until'] ?? null),
|
||
'last_run_at' => ($arrFresh['last_auto_run_at'] ?? null),
|
||
),
|
||
);
|
||
}
|
||
|
||
/**
|
||
* MSIN-4328 — events avec sync auto ON (pas fermés).
|
||
*/
|
||
function fxChronotrackApiConfigListAutoSyncEnabled() {
|
||
global $objDatabase;
|
||
|
||
$sql = "SELECT c.*"
|
||
. " FROM api_chronotrack_config c"
|
||
. " WHERE IFNULL(c.auto_sync_enabled, 0) = 1"
|
||
. " AND c.sync_status <> '" . $objDatabase->fxEscape(MSIN_API_CHRONOTRACK_SYNC_FERME) . "'"
|
||
. " ORDER BY c.eve_id ASC";
|
||
$arrRows = $objDatabase->fxGetResults($sql);
|
||
$tabOut = array();
|
||
if (!is_array($arrRows)) {
|
||
return $tabOut;
|
||
}
|
||
for ($i = 1; $i <= count($arrRows); $i++) {
|
||
$tabOut[] = $arrRows[$i];
|
||
}
|
||
return $tabOut;
|
||
}
|
||
|
||
/**
|
||
* MSIN-4328 — horodatage dernier passage cron auto.
|
||
*/
|
||
function fxChronotrackApiConfigTouchAutoRun($intEveId) {
|
||
global $objDatabase;
|
||
|
||
$intEveId = intval($intEveId);
|
||
if ($intEveId <= 0) {
|
||
return false;
|
||
}
|
||
$sql = "UPDATE api_chronotrack_config SET last_auto_run_at = '" . fxGetDateTime() . "'"
|
||
. ", updated_at = '" . fxGetDateTime() . "'"
|
||
. " WHERE eve_id = " . $intEveId;
|
||
return (bool)$objDatabase->fxQuery($sql);
|
||
}
|
||
|
||
/**
|
||
* MSIN-4328 — coupe la sync auto (échéance atteinte).
|
||
*/
|
||
function fxChronotrackApiConfigDisableAutoSync($intEveId) {
|
||
global $objDatabase;
|
||
|
||
$intEveId = intval($intEveId);
|
||
if ($intEveId <= 0) {
|
||
return false;
|
||
}
|
||
$sql = "UPDATE api_chronotrack_config SET auto_sync_enabled = 0"
|
||
. ", updated_at = '" . fxGetDateTime() . "'"
|
||
. " WHERE eve_id = " . $intEveId;
|
||
return (bool)$objDatabase->fxQuery($sql);
|
||
}
|
||
|
||
function fxChronotrackApiRaceMapGetForEvent($intEveId) {
|
||
global $objDatabase;
|
||
|
||
$sql = "SELECT * FROM api_chronotrack_race_map WHERE eve_id = " . intval($intEveId);
|
||
$arrRows = $objDatabase->fxGetResults($sql);
|
||
$arrMap = array();
|
||
if ($arrRows !== null) {
|
||
for ($i = 1; $i <= count($arrRows); $i++) {
|
||
$arrMap[intval($arrRows[$i]['epr_id'])] = $arrRows[$i];
|
||
}
|
||
}
|
||
return $arrMap;
|
||
}
|
||
|
||
function fxChronotrackApiMs1EpreuvesForEvent($intEveId, $strLangue = 'fr') {
|
||
global $objDatabase;
|
||
|
||
$strLangue = ($strLangue === 'en') ? 'en' : 'fr';
|
||
$sql = "SELECT epr_id, epr_nom_" . $strLangue . " AS epr_nom, epr_type_" . $strLangue . " AS epr_type, epr_date"
|
||
. " FROM inscriptions_epreuves WHERE eve_id = " . intval($intEveId)
|
||
. " ORDER BY epr_date, epr_nom_" . $strLangue;
|
||
return $objDatabase->fxGetResults($sql);
|
||
}
|
||
|
||
function fxChronotrackApiRaceMapSave($intEveId, $arrMapInput) {
|
||
global $objDatabase;
|
||
|
||
$intEveId = intval($intEveId);
|
||
$arrExisting = fxChronotrackApiConfigGet($intEveId);
|
||
if ($arrExisting === null) {
|
||
return array('state' => 'error', 'message' => 'Lier d\'abord un événement ChronoTrack');
|
||
}
|
||
if ($arrExisting['sync_status'] === MSIN_API_CHRONOTRACK_SYNC_FERME) {
|
||
return array('state' => 'error', 'message' => 'Événement fermé — mapping en lecture seule');
|
||
}
|
||
|
||
if (!is_array($arrMapInput)) {
|
||
return array('state' => 'error', 'message' => 'Mapping invalide');
|
||
}
|
||
|
||
foreach ($arrMapInput as $intEprId => $arrRace) {
|
||
$intEprId = intval($intEprId);
|
||
$intCtRaceId = intval($arrRace['ct_race_id'] ?? 0);
|
||
$strCtRaceName = trim((string)($arrRace['ct_race_name'] ?? ''));
|
||
|
||
if ($intEprId <= 0) {
|
||
continue;
|
||
}
|
||
if ($intCtRaceId <= 0) {
|
||
$sqlDel = "DELETE FROM api_chronotrack_race_map WHERE eve_id = " . $intEveId . " AND epr_id = " . $intEprId;
|
||
$objDatabase->fxQuery($sqlDel);
|
||
continue;
|
||
}
|
||
|
||
$sqlExists = "SELECT map_id FROM api_chronotrack_race_map WHERE eve_id = " . $intEveId
|
||
. " AND epr_id = " . $intEprId . " LIMIT 1";
|
||
if ($objDatabase->fxGetRow($sqlExists) !== null) {
|
||
$sql = "UPDATE api_chronotrack_race_map SET ct_race_id = " . $intCtRaceId
|
||
. ", ct_race_name = '" . $objDatabase->fxEscape($strCtRaceName) . "'"
|
||
. ", updated_at = '" . fxGetDateTime() . "'"
|
||
. " WHERE eve_id = " . $intEveId . " AND epr_id = " . $intEprId;
|
||
} else {
|
||
$sql = "INSERT INTO api_chronotrack_race_map SET eve_id = " . $intEveId
|
||
. ", epr_id = " . $intEprId
|
||
. ", ct_race_id = " . $intCtRaceId
|
||
. ", ct_race_name = '" . $objDatabase->fxEscape($strCtRaceName) . "'"
|
||
. ", updated_at = '" . fxGetDateTime() . "'";
|
||
}
|
||
$objDatabase->fxQuery($sql);
|
||
}
|
||
|
||
return array('state' => 'ok');
|
||
}
|
||
|
||
function fxChronotrackApiMs1EventRow($intEveId, $strLangue = 'fr') {
|
||
global $objDatabase;
|
||
|
||
$strLangue = ($strLangue === 'en') ? 'en' : 'fr';
|
||
$sql = "SELECT eve_id, eve_nom_" . $strLangue . " AS eve_nom, eve_date_debut, eve_date_fin"
|
||
. " FROM inscriptions_evenements WHERE eve_id = " . intval($intEveId) . " LIMIT 1";
|
||
return $objDatabase->fxGetRow($sql);
|
||
}
|
||
|
||
function fxChronotrackApiListActiveConfigs($arrStatuses = null) {
|
||
global $objDatabase;
|
||
|
||
if ($arrStatuses === null) {
|
||
$arrStatuses = array(MSIN_API_CHRONOTRACK_SYNC_LIE, MSIN_API_CHRONOTRACK_SYNC_ACTIF);
|
||
}
|
||
$arrEsc = array();
|
||
foreach ($arrStatuses as $strStatus) {
|
||
$arrEsc[] = "'" . $objDatabase->fxEscape($strStatus) . "'";
|
||
}
|
||
$sql = "SELECT c.*, e.eve_nom_fr AS eve_nom"
|
||
. " FROM api_chronotrack_config c"
|
||
. " INNER JOIN inscriptions_evenements e ON e.eve_id = c.eve_id"
|
||
. " WHERE c.sync_status IN (" . implode(',', $arrEsc) . ")"
|
||
. " ORDER BY c.sync_status DESC, c.updated_at DESC";
|
||
return $objDatabase->fxGetResults($sql);
|
||
}
|