You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
533 lines
18 KiB
533 lines
18 KiB
<?php
|
|
/**
|
|
* Pieplines utilisées par le plugin Commandes
|
|
*
|
|
* @plugin Commandes
|
|
* @copyright 2014
|
|
* @author Ateliers CYM, Matthieu Marcillaud, Les Développements Durables
|
|
* @licence GPL 3
|
|
* @package SPIP\Commandes\Pipelines
|
|
*/
|
|
|
|
// Sécurité
|
|
if (!defined('_ECRIRE_INC_VERSION')) return;
|
|
|
|
|
|
/**
|
|
* Insertion de la feuille de style CSS sur les pages publiques
|
|
*
|
|
* @pipeline insert_head_css
|
|
* @param string $flux Données du pipeline
|
|
* @return string Données du pipeline
|
|
*/
|
|
function commandes_insert_head_css($flux){
|
|
$css = find_in_path('css/commandes.css');
|
|
$flux .= "<link rel='stylesheet' type='text/css' media='all' href='$css' />\n";
|
|
return $flux;
|
|
}
|
|
|
|
|
|
/**
|
|
* Optimiser la base de donnée en abandonnant toutes les commandes en cours qui sont trop vieilles
|
|
*
|
|
* Le délai de "péremption" est défini dans les options de configuration du plugin.
|
|
* Par défaut, c'est 24h
|
|
*
|
|
* @pipeline optimiser_base_disparus
|
|
* @param array $flux Données du pipeline
|
|
* @return array Données du pipeline
|
|
*/
|
|
function commandes_optimiser_base_disparus($flux) {
|
|
include_spip('inc/config');
|
|
include_spip('base/abstract_sql');
|
|
$duree_vie = lire_config('commandes/duree_vie', 24);
|
|
// On cherche la date depuis quand on a le droit d'avoir fait la commande
|
|
$depuis = date('Y-m-d H:i:s', time() - 3600*intval($duree_vie));
|
|
// On récupère les commandes trop vieilles
|
|
$commandes = sql_allfetsel(
|
|
'id_commande',
|
|
'spip_commandes',
|
|
'statut = '.sql_quote('encours').' and date<'.sql_quote($depuis)
|
|
);
|
|
|
|
// S'il y a bien des commandes à abandonner
|
|
if ($commandes) {
|
|
$ids_commandes = array_map('reset', $commandes);
|
|
include_spip('action/editer_objet');
|
|
foreach ($ids_commandes as $id_commande) {
|
|
objet_instituer('commande', $id_commande, array('statut' => 'abandonne'));
|
|
}
|
|
$flux['data'] += count($commandes);
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
|
|
/**
|
|
* Ajout de contenu sur certaines pages
|
|
*
|
|
* - Formulaires pour modifier les dates sur la fiche d'une commande
|
|
*
|
|
* @pipeline affiche_milieu
|
|
* @param array $flux Données du pipeline
|
|
* @return array Données du pipeline
|
|
*/
|
|
function commandes_affiche_milieu($flux) {
|
|
|
|
if (
|
|
$exec = trouver_objet_exec($flux['args']['exec'])
|
|
and $exec['edition'] == false
|
|
and $exec['type'] == 'commande'
|
|
and $id_table_objet = $exec['id_table_objet']
|
|
and (isset($flux['args'][$id_table_objet]) and $id_commande = intval($flux['args'][$id_table_objet]))
|
|
) {
|
|
$texte = recuperer_fond('prive/squelettes/contenu/commande_affiche_milieu',array('id_commande'=>$id_commande));
|
|
}
|
|
|
|
if (isset($texte)) {
|
|
if ($p=strpos($flux['data'],"<!--affiche_milieu-->"))
|
|
$flux['data'] = substr_replace($flux['data'],$texte,$p,0);
|
|
else
|
|
$flux['data'] .= $texte;
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
|
|
/**
|
|
* Ajout de contenu dans la liste des éléments en attente de validation
|
|
*
|
|
* - Liste des commandes aux statuts définis comme "actifs" dans les options de configuration
|
|
*
|
|
* @pipeline accueil_encours
|
|
* @param array $flux Données du pipeline
|
|
* @return array Données du pipeline
|
|
*/
|
|
function commandes_accueil_encours($flux) {
|
|
|
|
include_spip('inc/config');
|
|
$activer = lire_config('commandes/accueil_encours');
|
|
$statuts = lire_config('commandes/statuts_actifs');
|
|
if ($activer and is_array($statuts)) {
|
|
foreach($statuts as $statut){
|
|
if ($nb_{$statut} = sql_countsel(table_objet_sql('commande'), "statut=".sql_quote($statut))) {
|
|
$titre_{$statut} = singulier_ou_pluriel($nb_{$statut}, 'commandes:info_1_commande_statut_'.$statut, 'commandes:info_nb_commandes_statut_'.$statut);
|
|
$flux .= recuperer_fond('prive/objets/liste/commandes', array(
|
|
'titre' => $titre_{$statut},
|
|
'statut' => $statut,
|
|
'cacher_tri' => true,
|
|
'nb' => 5),
|
|
array('ajax' => true)
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
|
|
/**
|
|
* Ajout de liste sur la vue d'un auteur
|
|
*
|
|
* - Liste des commandes de l'auteur
|
|
*
|
|
* @pipeline affiche_auteurs_interventions
|
|
* @param array $flux Données du pipeline
|
|
* @return array Données du pipeline
|
|
**/
|
|
function commandes_affiche_auteurs_interventions($flux) {
|
|
|
|
if ($id_auteur = intval($flux['args']['id_auteur'])) {
|
|
|
|
$ins = recuperer_fond('prive/objets/liste/commandes', array(
|
|
'id_auteur' => $id_auteur,
|
|
'titre' => _T('commandes:titre_commandes_auteur'),
|
|
'cacher_tri' => true
|
|
),
|
|
array('ajax' => true)
|
|
);
|
|
$mark = '<!--bank-->';
|
|
if (($p = strpos($flux['data'], $mark)) !== false) {
|
|
$flux['data'] = substr_replace($flux['data'], $ins, $p + strlen($mark), 0);
|
|
}
|
|
else {
|
|
$flux['data'] .= $ins;
|
|
}
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
|
|
/**
|
|
* Compléter la liste des types d'adresses du plugin Coordonnées
|
|
*
|
|
* Ajout de 2 types d'adresses : facturation et livraison
|
|
*
|
|
* @pipeline types_coordonnees
|
|
* @param array $liste Données du pipeline
|
|
* @return array Données du pipeline
|
|
**/
|
|
function commandes_types_coordonnees($liste) {
|
|
|
|
$types_adresses = $liste['adresse'];
|
|
if (!$types_adresses or !is_array($types_adresses)) $types_adresses = array();
|
|
|
|
// on définit les couples types + chaînes de langue à ajouter
|
|
$types_adresses_commandes = array(
|
|
'livraison' => _T('commandes:type_adresse_livraison'),
|
|
'facturation' => _T('commandes:type_adresse_facturation')
|
|
);
|
|
// on les rajoute à la liste des types des adresses
|
|
$liste['adresse'] = array_merge($types_adresses, $types_adresses_commandes);
|
|
|
|
return $liste;
|
|
}
|
|
|
|
|
|
/**
|
|
* Enregistrer le bon reglement d'une commande liee a une transaction du plugin bank
|
|
*
|
|
* @pipeline bank_traiter_reglement
|
|
* @param array $flux
|
|
* @return array mixed
|
|
*/
|
|
function commandes_bank_traiter_reglement($flux){
|
|
// Si on est dans le bon cas d'un paiement de commande et qu'il y a un id_commande et que la commande existe toujours
|
|
if (
|
|
$id_transaction = $flux['args']['id_transaction']
|
|
and $transaction = sql_fetsel("*","spip_transactions","id_transaction=".intval($id_transaction))
|
|
and $id_commande = $transaction['id_commande']
|
|
and $commande = sql_fetsel('id_commande, statut, id_auteur, echeances, reference', 'spip_commandes', 'id_commande='.intval($id_commande))
|
|
){
|
|
$statut_commande = $commande['statut'];
|
|
$montant_regle = $transaction['montant_regle'];
|
|
$transaction_mode = $transaction['mode'];
|
|
$statut_nouveau = 'paye';
|
|
|
|
|
|
// Si la commande n'a pas d'échéance, le montant attendu est celui du prix de la commande
|
|
include_spip('inc/commandes_echeances');
|
|
if (!$commande['echeances']
|
|
or !$echeances = unserialize($commande['echeances'])
|
|
or !$desc = commandes_trouver_prochaine_echeance_desc($id_commande, $echeances, true)
|
|
or !isset($desc['montant'])) {
|
|
$fonction_prix = charger_fonction('prix', 'inc/');
|
|
$montant_attendu = $fonction_prix('commande', $id_commande);
|
|
}
|
|
// Sinon le montant attendu est celui de la prochaine échéance (en ignorant la dernière transaction OK que justement on cherche à tester)
|
|
else {
|
|
$montant_attendu = $desc['montant'];
|
|
}
|
|
spip_log("commande #$id_commande attendu:$montant_attendu regle:$montant_regle", 'commandes');
|
|
|
|
// Si le plugin n'était pas déjà en payé et qu'on a pas assez payé
|
|
// (si le plugin était déjà en payé, ce sont possiblement des renouvellements)
|
|
if (
|
|
$statut_commande != 'paye'
|
|
and (floatval($montant_attendu) - floatval($montant_regle)) >= 0.01
|
|
){
|
|
$statut_nouveau = 'partiel';
|
|
}
|
|
|
|
// S'il y a bien un statut à changer
|
|
if ($statut_nouveau !== $statut_commande){
|
|
spip_log("commandes_bank_traiter_reglement marquer la commande #$id_commande statut: $statut_commande -> $statut_nouveau mode=$transaction_mode",'commandes');
|
|
// On met a jour la commande
|
|
include_spip("action/editer_commande");
|
|
commande_modifier($id_commande, array('statut'=>$statut_nouveau, 'mode'=>$transaction_mode));
|
|
}
|
|
|
|
// un message gentil pour l'utilisateur qui vient de payer, on lui rappelle son numero de commande
|
|
$flux['data'] .= "<br />"._T('commandes:merci_de_votre_commande_paiement',array('reference'=>$commande['reference']));
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
/**
|
|
* Enregistrer le reglement en attente d'une commande liee a une transaction du plugin bank
|
|
* (cas du reglement par cheque par exemple)
|
|
*
|
|
* @pipeline trig_bank_reglement_en_attente
|
|
* @param array $flux
|
|
* @return array mixed
|
|
*/
|
|
function commandes_trig_bank_reglement_en_attente($flux){
|
|
// Si on est dans le bon cas d'un paiement de commande et qu'il y a un id_commande et que la commande existe toujours
|
|
if ($id_transaction = $flux['args']['id_transaction']
|
|
AND $transaction = sql_fetsel("*","spip_transactions","id_transaction=".intval($id_transaction))
|
|
AND $id_commande = $transaction['id_commande']
|
|
AND $commande = sql_fetsel('id_commande, statut, id_auteur, mode', 'spip_commandes', 'id_commande='.intval($id_commande))){
|
|
|
|
$statut_commande = $commande['statut'];
|
|
$transaction_mode = $transaction['mode'];
|
|
$commande_mode = $commande['mode'];
|
|
$statut_nouveau = 'attente';
|
|
if ($statut_nouveau !== $statut_commande OR $transaction_mode !==$commande_mode){
|
|
spip_log("commandes_trig_bank_reglement_en_attente marquer la commande #$id_commande statut=$statut_nouveau mode=$transaction_mode",'commandes');
|
|
//on met a jour la commande
|
|
include_spip("action/editer_commande");
|
|
commande_modifier($id_commande,array('statut'=>$statut_nouveau,'mode'=>$transaction_mode));
|
|
}
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
|
|
/**
|
|
* Enregistrer le reglement en echec d'une commande liee a une transaction du plugin bank
|
|
* (cas du reglement annule ou du refus de carte etc)
|
|
*
|
|
* @pipeline trig_bank_reglement_en_echec
|
|
* @param array $flux
|
|
* @return array mixed
|
|
*/
|
|
function commandes_trig_bank_reglement_en_echec($flux){
|
|
// Si on est dans le bon cas d'un paiement de commande et qu'il y a un id_commande et que la commande existe toujours
|
|
if ($id_transaction = $flux['args']['id_transaction']
|
|
AND $transaction = sql_fetsel("*","spip_transactions","id_transaction=".intval($id_transaction))
|
|
AND $id_commande = $transaction['id_commande']
|
|
AND $commande = sql_fetsel('id_commande, statut, id_auteur', 'spip_commandes', 'id_commande='.intval($id_commande))){
|
|
|
|
$statut_commande = $commande['statut'];
|
|
$transaction_mode = $transaction['mode'];
|
|
$statut_nouveau = $statut_commande;
|
|
|
|
// on ne passe la commande en erreur que si le reglement a effectivement echoue,
|
|
// pas si c'est une simple annulation (retour en arriere depuis la page de paiement bancaire)
|
|
if (strncmp($transaction['statut'],"echec",5)==0){
|
|
$statut_nouveau = 'erreur';
|
|
}
|
|
if ($statut_nouveau !== $statut_commande){
|
|
spip_log("commandes_trig_bank_reglement_en_attente marquer la commande #$id_commande statut=$statut_nouveau",'commandes');
|
|
//on met a jour la commande
|
|
include_spip("action/editer_commande");
|
|
commande_modifier($id_commande,array('statut'=>$statut_nouveau,'mode'=>$transaction_mode));
|
|
}
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
/**
|
|
* Déclarer les échéances à la banque
|
|
*
|
|
* @pipeline bank_abos_decrire_echeance
|
|
**/
|
|
function commandes_bank_abos_decrire_echeance($flux) {
|
|
if (
|
|
// si on doit bien faire du prélèvement auto
|
|
$flux['args']['force_auto'] == true
|
|
// et qu'on a une transaction sous la main
|
|
and $id_transaction = intval($flux['args']['id_transaction'])
|
|
// et que cette transaction a un id_commande
|
|
and $id_commande = intval(sql_getfetsel('id_commande', 'spip_transactions', 'id_transaction = '.$id_transaction))
|
|
// et que la commande a des informations d'échéances
|
|
and $commande = sql_fetsel('echeances_type, echeances_date_debut, echeances', 'spip_commandes', 'id_commande = '.$id_commande)
|
|
and $echeances = unserialize($commande['echeances'])
|
|
and $echeances_type = $commande['echeances_type']
|
|
and in_array($echeances_type, array('mois', 'annee'))
|
|
) {
|
|
// On définit la périodicité
|
|
switch($echeances_type) {
|
|
case 'mois':
|
|
$flux['data']['freq'] = 'monthly';
|
|
break;
|
|
case 'annee':
|
|
$flux['data']['freq'] = 'yearly';
|
|
break;
|
|
}
|
|
|
|
if ($commande['echeances_date_debut']
|
|
and strtotime($commande['echeances_date_debut'])>$_SERVER['REQUEST_TIME']) {
|
|
$flux['data']['date_start'] = $commande['echeances_date_debut'];
|
|
}
|
|
|
|
// Si c'est une seule valeur toute simple
|
|
if (!is_array($echeances)) {
|
|
$echeances = floatval($echeances);
|
|
$flux['data']['montant'] = $echeances;
|
|
}
|
|
// ou un array d'une seule echeance
|
|
elseif (count($echeances) == 1) {
|
|
$echeance = reset($echeances);
|
|
$flux['data']['montant'] = floatval($echeance['montant']);
|
|
if (isset($echeance['nb'])) {
|
|
$flux['data']['count'] = $echeance['nb'];
|
|
}
|
|
}
|
|
// Sinon c'est un peu plus compliqué, et pour l'instant on ne gère que DEUX montants possibles
|
|
elseif (count($echeances) >= 2) {
|
|
// Premier montant d'échéances
|
|
$flux['data']['montant_init'] = $echeances[0]['montant'];
|
|
$flux['data']['count_init'] = $echeances[0]['nb'];
|
|
// Deuxième montant d'échéances
|
|
$flux['data']['montant'] = $echeances[1]['montant'];
|
|
if (isset($echeances[1]['nb'])) {
|
|
$flux['data']['count'] = $echeances[1]['nb'];
|
|
}
|
|
}
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
/**
|
|
* Lier une commande à un identifiant bancaire lorsqu'un prélèvement bancaire est bien validé
|
|
*
|
|
* @pipeline bank_abos_activer_abonnement
|
|
**/
|
|
function commandes_bank_abos_activer_abonnement($flux){
|
|
// Si on a une transaction
|
|
if ($id_transaction = intval($flux['args']['id_transaction'])) {
|
|
$where = 'id_transaction = '.$id_transaction;
|
|
}
|
|
// Sinon on cherche par l'identifiant d'abonnement bancaire
|
|
elseif ($abo_uid = $flux['args']['abo_uid']) {
|
|
$where = 'abo_uid = '.sql_quote($abo_uid);
|
|
}
|
|
|
|
// On gère d'abord les erreurs possibles si on ne trouve pas la bonne transaction
|
|
if (!$where or !$transaction = sql_fetsel('*', 'spip_transactions', $where)) {
|
|
spip_log("Impossible de trouver la transaction ($id_transaction / $abo_uid).", 'commandes.'._LOG_ERREUR);
|
|
$flux['data'] = false;
|
|
}
|
|
elseif ($transaction['statut'] == 'commande') {
|
|
spip_log("La transaction ${transaction['id_transaction']} n’a pas été réglée.", 'commandes.'._LOG_ERREUR);
|
|
$flux['data'] = false;
|
|
}
|
|
elseif (strncmp($transaction['statut'], 'echec',5) == 0) {
|
|
spip_log("La transaction ${transaction['id_transaction']} a echoué.",'commandes.'._LOG_ERREUR);
|
|
$flux['data'] = false;
|
|
}
|
|
// Si on a trouvé ce qu'il faut, on va lier la commande à l'identifiant bancaire
|
|
elseif ($id_commande = intval($transaction['id_commande'])) {
|
|
include_spip('action/editer_objet');
|
|
|
|
objet_modifier('commande', $id_commande, array('bank_uid' => $flux['args']['abo_uid']));
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
/**
|
|
* Créer la transaction correspondant à la prochaine échéance d'une commande
|
|
*
|
|
* @pipeline bank_abos_preparer_echeance
|
|
**/
|
|
function commandes_bank_abos_preparer_echeance($flux){
|
|
// On commence par chercher la commande dont il s'agit
|
|
// et vérifier qu'elle a des échéances
|
|
if (
|
|
isset($flux['args']['id'])
|
|
and $id = $flux['args']['id']
|
|
and strncmp($id,"uid:",4) == 0
|
|
and $bank_uid = substr($id, 4)) {
|
|
|
|
// robustesse pour retrouver la comande correspondant a un numero d'abonnement
|
|
if ($id_commande = sql_getfetsel('id_commande','spip_commandes','bank_uid='.sql_quote($bank_uid))
|
|
or $id_commande = sql_getfetsel('id_commande','spip_transactions','abo_uid='.sql_quote($bank_uid))) {
|
|
|
|
if ($commande = sql_fetsel('*', 'spip_commandes', 'id_commande='.intval($id_commande))
|
|
and $echeances = unserialize($commande['echeances'])
|
|
and $echeances_type = $commande['echeances_type'] ) {
|
|
|
|
include_spip('inc/commandes_echeances');
|
|
|
|
// Si on a bien trouvé une prochaine échéance
|
|
if ($desc = commandes_trouver_prochaine_echeance_desc($id_commande, $echeances)
|
|
and isset($desc['montant'])) {
|
|
include_spip('action/editer_objet');
|
|
|
|
$set = array('statut' => 'attente');
|
|
// robustesse/reparation si echec d'update a la premiere echeance payee
|
|
if (!$commande['bank_uid']) {
|
|
$set['bank_uid'] = $bank_uid;
|
|
}
|
|
|
|
// On remet la commande en attente de paiement puisqu'on… attend un paiement !
|
|
objet_modifier('commande', $id_commande, $set);
|
|
|
|
// On crée la transaction qui testera le vrai paiement
|
|
$montant = $desc['montant'];
|
|
$inserer_transaction = charger_fonction('inserer_transaction', 'bank');
|
|
$options_transaction = array(
|
|
'id_auteur' => intval($commande['id_auteur']),
|
|
'champs' => array(
|
|
'id_commande' => $id_commande,
|
|
),
|
|
);
|
|
if (isset($desc['montant_ht'])) {
|
|
$options_transaction['montant_ht'] = $desc['montant_ht'];
|
|
}
|
|
$id_transaction = intval($inserer_transaction($montant, $options_transaction));
|
|
|
|
$flux['data'] = $id_transaction;
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
/**
|
|
* Mettre en erreur une commande dont le prélèvement automatique aurait échoué
|
|
* on repere ce cas via le flag erreur=true envoyer lors de la resiliation
|
|
*
|
|
* @pipeline bank_abos_resilier
|
|
**/
|
|
function commandes_bank_abos_resilier($flux){
|
|
// On commence par chercher la commande dont il s'agit
|
|
// et vérifier qu'elle a des échéances
|
|
if (
|
|
isset($flux['args']['erreur']) and $flux['args']['erreur']
|
|
and isset($flux['args']['id']) and $id = $flux['args']['id']
|
|
and strncmp($id,"uid:",4) == 0
|
|
and $bank_uid = substr($id, 4)
|
|
and $commande = sql_fetsel('*', 'spip_commandes', 'bank_uid = '.sql_quote($bank_uid))
|
|
and $id_commande = intval($commande['id_commande'])
|
|
) {
|
|
include_spip('action/editer_objet');
|
|
|
|
// Le prélèvement a échoué explicitement, donc la commande d'origine est en erreur
|
|
objet_modifier('commande', $id_commande, array('statut' => 'erreur'));
|
|
}
|
|
|
|
return $flux;
|
|
}
|
|
|
|
/**
|
|
* Si le plugin Bank est activé, un changement de statut vers Payée redirige vers la page de paiement de la transaction
|
|
*
|
|
* @pipeline pre_edition
|
|
**/
|
|
|
|
function commandes_pre_edition($flux){
|
|
if (test_plugin_actif('bank')
|
|
AND $flux['args']['table'] == 'spip_commandes'
|
|
AND $flux['args']['action'] == 'instituer'
|
|
AND $flux['data']['statut'] == 'paye') {
|
|
|
|
/*
|
|
$id_commande = $flux['args']['id_objet'];
|
|
|
|
$transaction = sql_fetsel('id_transaction, transaction_hash, statut', 'spip_transactions', 'id_commande='.intval($id_commande));
|
|
|
|
if (!is_null($transaction) AND $transaction['statut'] != 'ok') {
|
|
$arguments = "id_transaction=".$transaction['id_transaction']."&transaction_hash=".$transaction['transaction_hash'];
|
|
|
|
include_spip('inc/headers');
|
|
redirige_url_ecrire('payer' , $arguments);
|
|
}
|
|
*/
|
|
}
|
|
return $flux;
|
|
}
|