source: spip-zone/_plugins_/mailsubscribers/trunk/newsletter/unsubscribe.php @ 112420

<?php
/**
 * Plugin mailsubscribers
 * (c) 2012 Cédric Morin
 * Licence GNU/GPL v3
 *
 */

if (!defined('_ECRIRE_INC_VERSION')) return;

include_spip("action/editer_objet");
include_spip('inc/mailsubscribers');
include_spip('inc/config');
include_spip('inc/autoriser');

/**
 * Desinscrire un subscriber par son email
 * si une ou plusieurs listes precisees, le subscriber est desinscrit de ces seules listes
 * si il n'en reste aucune, le statut du subscriber est suspendu
 *
 * si aucune liste precisee, le subscriber est desinscrit de toutes les listes
 *
 * @param $email
 *   champ obligatoire
 * @param array $options
 *   listes : array
 *   notify : bool
 * @return bool
 *   true si inscrit, false sinon
 */
function newsletter_unsubscribe_dist($email, $options = array()) {
        static $dejala = false;
        if ($dejala) {return false;}

        // chercher si un tel email est deja en base
        $row = sql_fetsel('*', 'spip_mailsubscribers', 'email=' . sql_quote($email));
        if ($row) {

                $set = array();
                $trace_optin = '';
                $notify = array();

                $where = array();
                $where[] = 'id_mailsubscriber=' . intval($row['id_mailsubscriber']);

                if (isset($options['listes'])
                        AND is_array($options['listes'])
                ) {
                        $listes = array_map('mailsubscribers_normaliser_nom_liste', $options['listes']);
                        $ids = sql_allfetsel('id_mailsubscribinglist', 'spip_mailsubscribinglists', sql_in('identifiant', $listes));
                        $ids = array_map('reset', $ids);
                        $where[] = sql_in('id_mailsubscribinglist', $ids);
                }

                // les inscriptions pas deja en refusees pour la trace
                $pas_encore = sql_allfetsel('id_mailsubscribinglist,statut', 'spip_mailsubscriptions', 'statut!=' . sql_quote('refuse') . ' AND id_segment=0 AND ' . implode(' AND ', $where));

                // on met a jour les inscriptions pour les listes demandees (ou pour toutes les listes en cours)
                // l'option remove est utilisee pour la synchro des listes : un abonnement retire lors de la synchro n'est pas conserve en refuse (car ce n'est pas une desinscription)
                if (isset($options['remove']) and $options['remove']){
                        sql_delete('spip_mailsubscriptions', $where);
                }
                else {
                        // on unsubscribe bien tous les segments
                        sql_updateq('spip_mailsubscriptions', array('statut' => 'refuse'), $where);
                }
                $GLOBALS['mailsubscribers_recompte_inscrits'] = true;

                if ($pas_encore) {
                        $changes = sql_allfetsel('id_mailsubscribinglist', 'spip_mailsubscriptions', 'statut=' . sql_quote('refuse') . ' AND id_segment=0 AND ' . implode(' AND ', $where));
                        $changes = array_map('reset', $changes);
                        $changes_identifiants = array();
                        foreach ($pas_encore as $sub_prev){
                                if (in_array($sub_prev['id_mailsubscribinglist'], $changes)){
                                        $identifiant = sql_getfetsel('identifiant', 'spip_mailsubscribinglists', 'id_mailsubscribinglist='.intval($sub_prev['id_mailsubscribinglist']));
                                        $changes_identifiants[] = $identifiant;
                                        $notify[] = array(
                                                'identifiant' => $identifiant,
                                                'id_mailsubscribinglist' => $sub_prev['id_mailsubscribinglist'],
                                                'statut' => 'refuse',
                                                'statut_ancien' => $sub_prev['statut'],
                                        );
                                }
                        }
                        if ($changes_identifiants) {
                                $trace_optin .= '[' . implode(',', $changes_identifiants) . ':' . _T('mailsubscriber:info_statut_refuse') . '] ';
                        }
                }

                // on regarde les inscriptions en cours : si aucune prop ou valide, l'abonne passe en refuse, mail obfusque
                $encore = sql_countsel('spip_mailsubscriptions', 'id_mailsubscriber=' . intval($row['id_mailsubscriber']) . ' AND ' . sql_in('statut', array('prop', 'valide')));
                if (!$encore) {
                        if (!in_array($row['statut'], array('refuse', 'poubelle'))) {
                                $set['statut'] = "refuse";
                        }
                        // pris en charge par pipeline + cron
                        //$set['email'] = mailsubscribers_obfusquer_email($email);
                }
                if ($trace_optin) {
                        $set['optin'] = mailsubscribers_trace_optin($trace_optin,
                                sql_getfetsel('optin', 'spip_mailsubscribers', 'id_mailsubscriber=' . intval($row['id_mailsubscriber'])));
                }

                if (count($set)) {
                        $dejala = true; // ne pas accepter la reentrance de validation des inscriptions quand on valide l'inscrit
                        autoriser_exception("modifier", "mailsubscriber", $row['id_mailsubscriber']);
                        autoriser_exception("instituer", "mailsubscriber", $row['id_mailsubscriber']);
                        autoriser_exception("superinstituer", "mailsubscriber", $row['id_mailsubscriber']);
                        // d'abord le statut pour notifier avec le bon mail, sauf si notify=false en option
                        if (isset($set['statut'])
                                AND (!isset($options['notify']) OR $options['notify'])
                        ) {
                                objet_modifier("mailsubscriber", $row['id_mailsubscriber'], array('statut' => $set['statut']));
                                unset($set['statut']);
                        }
                        // ensuite l'email ou autre si besoin
                        if (count($set)) {
                                objet_modifier("mailsubscriber", $row['id_mailsubscriber'], $set);
                        }
                        autoriser_exception("modifier", "mailsubscriber", $row['id_mailsubscriber'], false);
                        autoriser_exception("instituer", "mailsubscriber", $row['id_mailsubscriber'], false);
                        autoriser_exception("superinstituer", "mailsubscriber", $row['id_mailsubscriber'], false);
                        $dejala = false;

                        // actualiser les segments en auto_update
                        include_spip('inc/mailsubscribinglists');
                        mailsubscribers_actualise_segments($row['id_mailsubscriber']);
                }

                if ($notify and (!isset($options['notify']) or $options['notify'])){
                        $notifications = charger_fonction('notifications','inc');
                        foreach ($notify as $option){
                                $notifications('instituermailsubscription',$row['id_mailsubscriber'],$option);
                        }
                }

        }

        return true;
}