Notify::send() - Code Metrics - Inspection of "Classes from the Categories, Comm, Commande, Compt..." - alxarafe/alixar - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — EXTRACT_CLASSES ( 0382f2...c25e41 )

by Rafael
created 2024-08-23 10:51 UTC
Notify::send() F

↳ Parent: Notify
Complexity

Conditions	126
Paths	4902
Size

Total Lines	700
Code Lines	573
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	126
eloc	573
nc	4902
nop	5
dl	0
loc	700
rs	0
c	0
b	0
f	0
How to fix Long Method Complexity

<?php

/* Copyright (C) 2003-2005  Rodolphe Quiedeville        <[email protected]>
 * Copyright (C) 2004-2011  Laurent Destailleur         <[email protected]>
 * Copyright (C) 2014	    Juanjo Menent		        <[email protected]>
 * Copyright (C) 2018 	    Philippe Grand		        <[email protected]>
 * Copyright (C) 2021 	    Thibault FOUCART		    <[email protected]>
 * Copyright (C) 2022       Anthony Berton     	        <[email protected]>
 * Copyright (C) 2023       William Mead                <[email protected]>
 * Copyright (C) 2024       Jon Bendtsen                <[email protected]>
 * Copyright (C) 2024		MDW							<[email protected]>
 * Copyright (C) 2024       Rafael San José             <[email protected]>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program. If not, see <https://www.gnu.org/licenses/>.
 */

namespace Dolibarr\Code\Core\Classes;

use DoliDB;

/**
 *      \file       htdocs/core/class/notify.class.php
 *      \ingroup    notification
 *      \brief      File of class to manage notifications
 */

require_once constant('DOL_DOCUMENT_ROOT') . '/core/class/CMailFile.class.php';


/**
 *      Class to manage the table of subscription to notifications
 */
class Notify
{
    /**
     * @var int ID
     */
    public $id;

    /**
     * @var DoliDB Database handler.
     */
    public $db;

    /**
     * @var string type
     */
    public $type;

    /**
     * @var string threshold
     */
    public $threshold;

    /**
     * @var string context
     */
    public $context;


    /**
     * @var int     ID of event action that trigger the notification
     */
    public $event;

    /**
     * @var int     Third-party ID
     */
    public $socid;

    /**
     * @var int     (Third-party) Contact ID
     */
    public $contact_id;

    /**
     * @var string fk_user
     */
    public $fk_user;

    /**
     * @var string email
     */
    public $email;


    /**
     * Date creation record (datec)
     *
     * @var integer
     */
    public $datec;

    /**
     * Date modified record (datem)
     *
     * @var integer
     */
    public $datem;

    /**
     * @var string Error code (or message)
     */
    public $error = '';

    /**
     * @var string[] Error codes (or messages)
     */
    public $errors = array();

    public $author;
    public $ref;
    public $date;
    public $duree;
    public $note;

    /**
     * @var int Project ID
     */
    public $fk_project;

    // This codes actions are defined into table llx_notify_def
    public static $arrayofnotifsupported = array(
        'BILL_CANCEL',
        'BILL_VALIDATE',
        'BILL_PAYED',
        'ORDER_CANCEL',
        'ORDER_CREATE',
        'ORDER_VALIDATE',
        'ORDER_CLOSE',
        'PROPAL_VALIDATE',
        'PROPAL_CLOSE_SIGNED',
        'PROPAL_CLOSE_REFUSED',
        'FICHINTER_VALIDATE',
        'FICHINTER_CLOSE',
        'FICHINTER_ADD_CONTACT',
        'ORDER_SUPPLIER_CANCEL',
        'ORDER_SUPPLIER_VALIDATE',
        'ORDER_SUPPLIER_APPROVE',
        'ORDER_SUPPLIER_SUBMIT',
        'ORDER_SUPPLIER_REFUSE',
        'SHIPPING_VALIDATE',
        'EXPENSE_REPORT_VALIDATE',
        'EXPENSE_REPORT_APPROVE',
        'HOLIDAY_VALIDATE',
        'HOLIDAY_APPROVE',
        'ACTION_CREATE'
    );

    /**
     *  Constructor
     *
     *  @param      DoliDB      $db     Database handler
     */
    public function __construct($db)
    {
        $this->db = $db;
    }


    /**
     *  Return message that say how many notification (and to which email) will occurs on requested event.
     *  This is to show confirmation messages before event is recorded.
     *
     *  @param  string  $action     Id of action in llx_c_action_trigger
     *  @param  int     $socid      Id of third party
     *  @param  Object  $object     Object the notification is about
     *  @return string              Message
     */
    public function confirmMessage($action, $socid, $object)
    {
        global $langs;
        $langs->load("mails");

        // Get full list of all notifications subscribed for $action, $socid and $object
        $listofnotiftodo = $this->getNotificationsArray($action, $socid, $object, 0);

        if (getDolGlobalString('NOTIFICATION_EMAIL_DISABLE_CONFIRM_MESSAGE_USER')) {
            foreach ($listofnotiftodo as $val) {
                if ($val['type'] == 'touser') {
                    unset($listofnotiftodo[$val['email']]);
                    //$listofnotiftodo = array_merge($listofnotiftodo);
                }
            }
        }
        if (getDolGlobalString('NOTIFICATION_EMAIL_DISABLE_CONFIRM_MESSAGE_CONTACT')) {
            foreach ($listofnotiftodo as $val) {
                if ($val['type'] == 'tocontact') {
                    unset($listofnotiftodo[$val['email']]);
                    //$listofnotiftodo = array_merge($listofnotiftodo);
                }
            }
        }
        if (getDolGlobalString('NOTIFICATION_EMAIL_DISABLE_CONFIRM_MESSAGE_FIX')) {
            foreach ($listofnotiftodo as $val) {
                if ($val['type'] == 'tofixedemail') {
                    unset($listofnotiftodo[$val['email']]);
                    //$listofnotiftodo = array_merge($listofnotiftodo);
                }
            }
        }

        $texte = '';
        $nb = -1;
        if (is_array($listofnotiftodo)) {
            $nb = count($listofnotiftodo);
        }
        if ($nb < 0) {
            $texte = img_object($langs->trans("Notifications"), 'email', 'class="pictofixedwidth"') . $langs->trans("ErrorFailedToGetListOfNotificationsToSend");
        } elseif ($nb == 0) {
            $texte = img_object($langs->trans("Notifications"), 'email', 'class="pictofixedwidth"') . $langs->trans("NoNotificationsWillBeSent");
        } elseif ($nb == 1) {
            $texte = img_object($langs->trans("Notifications"), 'email', 'class="pictofixedwidth"') . $langs->trans("ANotificationsWillBeSent");
        } else { // Always >= 2 if ($nb >= 2) {
            $texte = img_object($langs->trans("Notifications"), 'email', 'class="pictofixedwidth"') . $langs->trans("SomeNotificationsWillBeSent", $nb);
        }

        if (is_array($listofnotiftodo)) {
            $i = 0;
            foreach ($listofnotiftodo as $val) {
                if ($i) {
                    $texte .= ', ';
                } else {
                    $texte .= ' (';
                }
                if ($val['isemailvalid']) {
                    $texte .= $val['email'];
                } else {
                    $texte .= $val['emaildesc'];
                }
                $i++;
            }
            if ($i) {
                $texte .= ')';
            }
        }

        return $texte;
    }

    /**
     *  Delete a notification from database
     *
     *  @param      User|null   $user       User deleting
     *  @return     int                     Return integer <0 if KO, >0 if OK
     */
    public function delete(User $user = null)

    {
        $error = 0;

        dol_syslog(get_class($this) . "::delete " . $this->id, LOG_DEBUG);

        $this->db->begin();

        if (!$error) {
            $sql = "DELETE FROM " . MAIN_DB_PREFIX . "notify_def";
            $sql .= " WHERE rowid = " . ((int) $this->id);

            if (!$this->db->query($sql)) {
                $error++;
                $this->errors[] = $this->db->lasterror();
            }
        }

        if (!$error) {
            $this->db->commit();
            return 1;
        } else {
            $this->db->rollback();
            return -1 * $error;
        }
    }

    /**
     * Create notification information record.
     *
     * @param   User|null   $user       User
     * @param   int         $notrigger  1=Disable triggers
     * @return  int                     Return integer <0 if KO, > 0 if OK (ID of newly created company notification information)
     */
    public function create(User $user = null, $notrigger = 0)
    {
        $now = dol_now();

        $error = 0;

        // Check parameters
        if (empty($this->socid)) {
            $this->error = 'BadValueForParameter';
            $this->errors[] = $this->error;
            return -1;
        }

        if (empty($this->datec)) {
            $this->datec = $now;
        }

        $this->db->begin();

        $sql = "INSERT INTO " . MAIN_DB_PREFIX . "notify_def (fk_soc, fk_action, fk_contact, type, datec)";
        $sql .= " VALUES (" . ((int) $this->socid) . ", " . ((int) $this->event) . ", " . ((int) $this->contact_id) . ",";
        $sql .= "'" . $this->db->escape($this->type) . "', '" . $this->db->idate($this->datec) . "')";

        $resql = $this->db->query($sql);
        if ($resql) {
            if ($this->db->affected_rows($resql)) {
                $this->id = $this->db->last_insert_id(MAIN_DB_PREFIX . "notify_def");
            }
        } else {
            $error++;
            $this->error = $this->db->lasterror();
            $this->errors[] = $this->error;
        }

        if (!$error) {
            $this->db->commit();
            return $this->id;
        } else {
            $this->db->rollback();
            return -1;
        }
    }

    /**
     *  Load record from database
     *
     *  @param  int     $id         Id of record
     *  @param  int     $socid      Id of company. If this is filled, function will return only records belonging to this thirdparty
     *  @param  string  $type       If id of company filled, we say if we want record of this type only
     *  @return int                 Return integer <0 if KO, >0 if OK
     */
    public function fetch($id, $socid = 0, $type = 'email')
    {
        if (empty($id) && empty($socid)) {
            return -1;
        }

        $sql = "SELECT rowid, fk_action as event, fk_soc as socid, fk_contact as contact_id, type, datec, tms as datem";
        $sql .= " FROM " . MAIN_DB_PREFIX . "notify_def";

        if ($id) {
            $sql .= " WHERE rowid = " . ((int) $id);
        } elseif ($socid > 0) {
            $sql .= " WHERE fk_soc  = " . ((int) $socid);
            if ($type) {
                $sql .= " AND type = '" . $this->db->escape($type) . "'";
            }
        }

        $resql = $this->db->query($sql);
        if ($resql) {
            if ($this->db->num_rows($resql)) {
                $obj = $this->db->fetch_object($resql);

                $this->id = $obj->rowid;
                $this->type = $obj->type;
                $this->event = $obj->event;
                $this->socid = $obj->socid;
                $this->contact_id = $obj->contact_id;
                $this->fk_user = $obj->fk_user;
                $this->email = $obj->email;
                $this->threshold = $obj->threshold;
                $this->context  = $obj->context;
                $this->datec = $this->db->jdate($obj->datec);
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
                $this->datem = $this->db->jdate($obj->datem);
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
            }
            $this->db->free($resql);

            return 1;
        } else {
            dol_print_error($this->db);
            return -1;
        }
    }

    /**
     *  Update record in database
     *
     *  @param  User|null   $user        Object user
     *  @param  int         $notrigger   1=Disable triggers
     *  @return int                      Return integer <=0 if KO, >0 if OK
     */
    public function update(User $user = null, $notrigger = -1)
    {
        global $langs;

        $error = 0;

        if (!$this->id) {
            return -1;
        }

        $this->db->begin();

        $sql = "UPDATE " . MAIN_DB_PREFIX . "notify_def SET";
        $sql .= " type = '" . $this->db->escape($this->type) . "'";
        // $sql .= ",fk_user = ".((int) $this->fk_user);
        // $sql .= ",email = '".$this->db->escape($this->email)."'";
        // $sql .= ",threshold = '".$this->db->escape($this->threshold)."'";
        // $sql .= ",context = '".$this->db->escape($this->context)."'";
        $sql .= ",fk_soc = " . ((int) $this->socid);
        $sql .= ",fk_action = " . ((int) $this->event);
        $sql .= ",fk_contact = " . ((int) $this->contact_id);
        $sql .= " WHERE rowid = " . ((int) $this->id);

        $result = $this->db->query($sql);
        if (!$result) {
            $error++;
            if ($this->db->errno() == 'DB_ERROR_RECORD_ALREADY_EXISTS') {
                $this->error = $langs->trans('ErrorDuplicateField');
            } else {
                $this->error = $this->db->lasterror();
            }
            $this->errors[] = $this->error;
        }

        if (!$error) {
            $this->db->commit();
            return 1;
        } else {
            $this->db->rollback();
            return -1;
        }
    }

    /**
     * Return number of notifications activated, for all or a given action code (and third party)
     *
     * @param   string  $notifcode      Code of action in llx_c_action_trigger (new usage) or Id of action in llx_c_action_trigger (old usage)
     * @param   int     $socid          Id of third party or 0 for all thirdparties or -1 for no thirdparties
     * @param   Object  $object         Object the notification is about (need it to check threshold value of some notifications)
     * @param   int     $userid         Id of user or 0 for all users or -1 for no users
     * @param   array   $scope          Scope where to search
     * @return  array|int               Return integer <0 if KO, array of notifications to send if OK
     */
    public function getNotificationsArray($notifcode, $socid = 0, $object = null, $userid = 0, $scope = array('thirdparty', 'user', 'global'))
    {
        global $conf, $user;

        $error = 0;
        $resarray = array();

        $valueforthreshold = 0;
        if (is_object($object)) {
            $valueforthreshold = $object->total_ht;
        }

        $sqlnotifcode = '';
        if ($notifcode) {
            if (is_numeric($notifcode)) {
                $sqlnotifcode = " AND n.fk_action = " . ((int) $notifcode); // Old usage
            } else {
                $sqlnotifcode = " AND a.code = '" . $this->db->escape($notifcode) . "'"; // New usage
            }
        }

        // Subscription per contact
        if (!$error) {
            if ($socid >= 0 && in_array('thirdparty', $scope)) {
                $sql = "SELECT a.code, c.email, c.rowid, c.statut as status";
                $sql .= " FROM " . $this->db->prefix() . "notify_def as n,";
                $sql .= " " . $this->db->prefix() . "socpeople as c,";

                $sql .= " " . $this->db->prefix() . "c_action_trigger as a,";
                $sql .= " " . $this->db->prefix() . "societe as s";
                $sql .= " WHERE n.fk_contact = c.rowid";
                $sql .= " AND a.rowid = n.fk_action";
                $sql .= " AND n.fk_soc = s.rowid";
                $sql .= $sqlnotifcode;
                $sql .= " AND s.entity IN (" . getEntity('societe') . ")";
                if ($socid > 0) {
                    $sql .= " AND s.rowid = " . ((int) $socid);
                }

                dol_syslog(__METHOD__ . " " . $notifcode . ", " . $socid, LOG_DEBUG);

                $resql = $this->db->query($sql);
                if ($resql) {
                    $num = $this->db->num_rows($resql);
                    $i = 0;
                    while ($i < $num) {
                        $obj = $this->db->fetch_object($resql);
                        // we want to notify only if contact is enable
                        if ($obj && $obj->status ==  1) {
                            $newval2 = trim($obj->email);
                            $isvalid = isValidEmail($newval2);
                            if (empty($resarray[$newval2])) {
                                $resarray[$newval2] = array('type' => 'tocontact', 'code' => trim($obj->code), 'emaildesc' => 'Contact id ' . $obj->rowid, 'email' => $newval2, 'contactid' => $obj->rowid, 'isemailvalid' => $isvalid);
                            }
                        }
                        $i++;
                    }
                } else {
                    $error++;
                    $this->error = $this->db->lasterror();
                }
            }
        }

        // Subscription per user
        if (!$error) {
            if ($userid >= 0 && in_array('user', $scope)) {
                $sql = "SELECT a.code, c.email, c.rowid";
                $sql .= " FROM " . $this->db->prefix() . "notify_def as n,";
                $sql .= " " . $this->db->prefix() . "user as c,";
                $sql .= " " . $this->db->prefix() . "c_action_trigger as a";
                $sql .= " WHERE n.fk_user = c.rowid";
                $sql .= " AND a.rowid = n.fk_action";
                $sql .= $sqlnotifcode;
                $sql .= " AND c.entity IN (" . getEntity('user') . ")";
                if ($userid > 0) {
                    $sql .= " AND c.rowid = " . ((int) $userid);
                }

                dol_syslog(__METHOD__ . " " . $notifcode . ", " . $socid, LOG_DEBUG);

                $resql = $this->db->query($sql);
                if ($resql) {
                    $num = $this->db->num_rows($resql);
                    $i = 0;
                    while ($i < $num) {
                        $obj = $this->db->fetch_object($resql);
                        if ($obj) {
                            $newval2 = trim($obj->email);
                            $isvalid = isValidEmail($newval2);
                            if (empty($resarray[$newval2])) {
                                $resarray[$newval2] = array('type' => 'touser', 'code' => trim($obj->code), 'emaildesc' => 'User id ' . $obj->rowid, 'email' => $newval2, 'userid' => $obj->rowid, 'isemailvalid' => $isvalid);
                            }
                        }
                        $i++;
                    }
                } else {
                    $error++;
                    $this->error = $this->db->lasterror();
                }
            }
        }

        // Subscription global
        if (!$error) {
            if (in_array('global', $scope)) {
                // List of notifications enabled for fixed email
                foreach ($conf->global as $key => $val) {
                    if ($notifcode) {
                        if ($val == '' || !preg_match('/^NOTIFICATION_FIXEDEMAIL_' . $notifcode . '_THRESHOLD_HIGHER_(.*)$/', $key, $reg)) {
                            continue;
                        }
                    } else {
                        if ($val == '' || !preg_match('/^NOTIFICATION_FIXEDEMAIL_.*_THRESHOLD_HIGHER_(.*)$/', $key, $reg)) {
                            continue;
                        }
                    }

                    $threshold = (float) $reg[1];
                    if ($valueforthreshold < $threshold) {
                        continue;
                    }

                    $tmpemail = explode(',', $val);
                    foreach ($tmpemail as $key2 => $val2) {
                        $newval2 = trim($val2);
                        if ($newval2 == '__SUPERVISOREMAIL__') {
                            if ($user->fk_user > 0) {
                                $tmpuser = new User($this->db);
                                $tmpuser->fetch($user->fk_user);
                                if ($tmpuser->email) {
                                    $newval2 = trim($tmpuser->email);
                                } else {
                                    $newval2 = '';
                                }
                            } else {
                                $newval2 = '';
                            }
                        }
                        if ($newval2) {
                            $isvalid = isValidEmail($newval2, 0);
                            if (empty($resarray[$newval2])) {
                                $resarray[$newval2] = array('type' => 'tofixedemail', 'code' => trim($key), 'emaildesc' => trim($val2), 'email' => $newval2, 'isemailvalid' => $isvalid);
                            }
                        }
                    }
                }
            }
        }

        if ($error) {
            return -1;
        }

        //var_dump($resarray);
        return $resarray;
    }

    /**
     *  Check if notification are active for couple action/company.
     *  If yes, send mail and save trace into llx_notify.
     *
     *  @param  string  $notifcode          Code of action in llx_c_action_trigger (new usage) or Id of action in llx_c_action_trigger (old usage)
     *  @param  Object  $object             Object the notification deals on
     *  @param  array   $filename_list      List of files to attach (full path of filename on file system)
     *  @param  array   $mimetype_list      List of MIME type of attached files
     *  @param  array   $mimefilename_list  List of attached file name in message
     *  @return int                         Return integer <0 if KO, or number of changes if OK
     */
    public function send($notifcode, $object, $filename_list = array(), $mimetype_list = array(), $mimefilename_list = array())
    {
        global $user, $conf, $langs, $mysoc;
        global $hookmanager;
        global $dolibarr_main_url_root;
        global $action;

        // Complete the array Notify::$arrayofnotifsupported
        if (!is_object($hookmanager)) {
            include_once DOL_DOCUMENT_ROOT . '/core/class/hookmanager.class.php';
            $hookmanager = new HookManager($this->db);
        }
        $hookmanager->initHooks(array('notification'));

        $parameters = array('notifcode' => $notifcode);
        $reshook = $hookmanager->executeHooks('notifsupported', $parameters, $object, $action);
        if (empty($reshook)) {
            if (!empty($hookmanager->resArray['arrayofnotifsupported'])) {
                Notify::$arrayofnotifsupported = array_merge(Notify::$arrayofnotifsupported, $hookmanager->resArray['arrayofnotifsupported']);
            }
        }

        // If the trigger code is not managed by the Notification module
        if (!in_array($notifcode, Notify::$arrayofnotifsupported)) {
            return 0;
        }

        include_once DOL_DOCUMENT_ROOT . '/core/lib/files.lib.php';

        dol_syslog(get_class($this) . "::send notifcode=" . $notifcode . ", object id=" . $object->id);

        $langs->load("other");

        // Define $urlwithroot
        $urlwithouturlroot = preg_replace('/' . preg_quote(DOL_URL_ROOT, '/') . '$/i', '', trim($dolibarr_main_url_root));
        $urlwithroot = $urlwithouturlroot . DOL_URL_ROOT; // This is to use external domain name found into config file
        //$urlwithroot=DOL_MAIN_URL_ROOT;                       // This is to use same domain name than current

        // Define some vars
        $application = 'Dolibarr';
        if (getDolGlobalString('MAIN_APPLICATION_TITLE')) {
            $application = getDolGlobalString('MAIN_APPLICATION_TITLE');
        }
        $from = getDolGlobalString('NOTIFICATION_EMAIL_FROM');
        $object_type = '';
        $link = '';
        $num = 0;
        $error = 0;

        $oldref = (empty($object->oldref) ? $object->ref : $object->oldref);
        $newref = (empty($object->newref) ? $object->ref : $object->newref);

        $sql = '';

        // Check notification per third party
        if (!empty($object->socid) && $object->socid > 0) {
            $sql .= "SELECT 'tocontactid' as type_target, c.email, c.rowid as cid, c.lastname, c.firstname, c.default_lang,";
            $sql .= " a.rowid as adid, a.label, a.code, n.rowid, n.threshold, n.context, n.type";
            $sql .= " FROM " . $this->db->prefix() . "socpeople as c,";
            $sql .= " " . $this->db->prefix() . "c_action_trigger as a,";
            $sql .= " " . $this->db->prefix() . "notify_def as n,";
            $sql .= " " . $this->db->prefix() . "societe as s";
            $sql .= " WHERE n.fk_contact = c.rowid AND a.rowid = n.fk_action";
            $sql .= " AND n.fk_soc = s.rowid";
            $sql .= " AND c.statut = 1";
            if (is_numeric($notifcode)) {
                $sql .= " AND n.fk_action = " . ((int) $notifcode); // Old usage
            } else {
                $sql .= " AND a.code = '" . $this->db->escape($notifcode) . "'"; // New usage
            }
            $sql .= " AND s.rowid = " . ((int) $object->socid);

            $sql .= "\nUNION\n";
        }

        // Check notification per user
        $sql .= "SELECT 'touserid' as type_target, c.email, c.rowid as cid, c.lastname, c.firstname, c.lang as default_lang,";
        $sql .= " a.rowid as adid, a.label, a.code, n.rowid, n.threshold, n.context, n.type";
        $sql .= " FROM " . $this->db->prefix() . "user as c,";
        $sql .= " " . $this->db->prefix() . "c_action_trigger as a,";
        $sql .= " " . $this->db->prefix() . "notify_def as n";
        $sql .= " WHERE n.fk_user = c.rowid AND a.rowid = n.fk_action";
        $sql .= " AND c.statut = 1";
        if (is_numeric($notifcode)) {
            $sql .= " AND n.fk_action = " . ((int) $notifcode); // Old usage
        } else {
            $sql .= " AND a.code = '" . $this->db->escape($notifcode) . "'"; // New usage
        }

        // Check notification fixed
        // TODO Move part found after, into a sql here


        // Loop on all notifications enabled
        $result = $this->db->query($sql);
        if ($result) {
            $num = $this->db->num_rows($result);
            $projtitle = '';
            if (is_object($object->project) || $object->fetch_project() > 0) {
                $projtitle = '(' . $object->project->title . ')';
            }

            if ($num > 0) {
                $i = 0;
                while ($i < $num && !$error) {  // For each notification couple defined (third party/actioncode)
                    $obj = $this->db->fetch_object($result);

                    $sendto = dolGetFirstLastname($obj->firstname, $obj->lastname) . " <" . $obj->email . ">";
                    $notifcodedefid = $obj->adid;
                    $trackid = '';
                    if ($obj->type_target == 'tocontactid') {
                        $trackid = 'ctc' . $obj->cid;
                    }
                    if ($obj->type_target == 'touserid') {
                        $trackid = 'use' . $obj->cid;
                    }

                    if (dol_strlen($obj->email)) {
                        // Set output language
                        $outputlangs = $langs;
                        if ($obj->default_lang && $obj->default_lang != $langs->defaultlang) {
                            $outputlangs = new Translate('', $conf);
                            $outputlangs->setDefaultLang($obj->default_lang);
                            $outputlangs->loadLangs(array("main", "other"));
                        }

                        $appli = $mysoc->name;

                        $subject = '[' . $appli . '] ' . $outputlangs->transnoentitiesnoconv("DolibarrNotification") . ($projtitle ? ' ' . $projtitle : '');

                        switch ($notifcode) {
                            case 'BILL_CANCEL':
                                $link = '<a href="' . $urlwithroot . '/compta/facture/card.php?facid=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->facture->dir_output . "/" . get_exdir(0, 0, 0, 1, $object, 'invoice');
                                $object_type = 'facture';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextInvoiceCanceled", $link);
                                break;
                            case 'BILL_VALIDATE':
                                $link = '<a href="' . $urlwithroot . '/compta/facture/card.php?facid=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->facture->dir_output . "/" . get_exdir(0, 0, 0, 1, $object, 'invoice');
                                $object_type = 'facture';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextInvoiceValidated", $link);
                                break;
                            case 'BILL_PAYED':
                                $link = '<a href="' . $urlwithroot . '/compta/facture/card.php?facid=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->facture->dir_output . "/" . get_exdir(0, 0, 0, 1, $object, 'invoice');
                                $object_type = 'facture';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextInvoicePayed", $link);
                                break;
                            case 'ORDER_CANCEL':
                                $link = '<a href="' . $urlwithroot . '/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->commande->dir_output . "/" . get_exdir(0, 0, 0, 1, $object, 'commande');
                                $object_type = 'order';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextOrderCanceled", $link);
                                break;
                            case 'ORDER_VALIDATE':
                                $link = '<a href="' . $urlwithroot . '/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->commande->dir_output . "/" . get_exdir(0, 0, 0, 1, $object, 'commande');
                                $object_type = 'order';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextOrderValidated", $link);
                                break;
                            case 'ORDER_CLOSE':
                                $link = '<a href="' . $urlwithroot . '/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->commande->dir_output . "/" . get_exdir(0, 0, 0, 1, $object, 'commande');
                                $object_type = 'order';
                                $labeltouse = getDolGlobalString('ORDER_CLOSE_TEMPLATE');
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextOrderClose", $link);
                                break;
                            case 'PROPAL_VALIDATE':
                                $link = '<a href="' . $urlwithroot . '/comm/propal/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->propal->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object, 'propal');
                                $object_type = 'propal';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextProposalValidated", $link);
                                break;
                            case 'PROPAL_CLOSE_REFUSED':
                                $link = '<a href="' . $urlwithroot . '/comm/propal/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->propal->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object, 'propal');
                                $object_type = 'propal';
                                $labeltouse = getDolGlobalString('PROPAL_CLOSE_REFUSED_TEMPLATE');
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextProposalClosedRefused", $link);
                                if (!empty($object->context['closedfromonlinesignature'])) {
                                    $mesg .= ' - From online page';
                                }
                                break;
                            case 'PROPAL_CLOSE_SIGNED':
                                $link = '<a href="' . $urlwithroot . '/comm/propal/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->propal->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object, 'propal');
                                $object_type = 'propal';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextProposalClosedSigned", $link);
                                if (!empty($object->context['closedfromonlinesignature'])) {
                                    $mesg .= ' - From online page';
                                }
                                break;
                            case 'FICHINTER_ADD_CONTACT':
                                $link = '<a href="' . $urlwithroot . '/fichinter/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->ficheinter->dir_output;
                                $object_type = 'ficheinter';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextInterventionAddedContact", $link);
                                break;
                            case 'FICHINTER_VALIDATE':
                                $link = '<a href="' . $urlwithroot . '/fichinter/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->ficheinter->dir_output;
                                $object_type = 'ficheinter';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextInterventionValidated", $link);
                                break;
                            case 'FICHINTER_CLOSE':
                                $link = '<a href="' . $urlwithroot . '/fichinter/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->ficheinter->dir_output;
                                $object_type = 'ficheinter';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextInterventionClosed", $link);
                                break;
                            case 'ORDER_SUPPLIER_VALIDATE':
                                $link = '<a href="' . $urlwithroot . '/fourn/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->fournisseur->commande->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object);
                                $object_type = 'order_supplier';
                                $labeltouse = isset($conf->global->ORDER_SUPPLIER_VALIDATE_TEMPLATE) ? $conf->global->ORDER_SUPPLIER_VALIDATE_TEMPLATE : '';
                                $mesg = $outputlangs->transnoentitiesnoconv("Hello") . ",\n\n";
                                $mesg .= $outputlangs->transnoentitiesnoconv("EMailTextSupplierOrderValidatedBy", $link, $user->getFullName($outputlangs));
                                $mesg .= "\n\n" . $outputlangs->transnoentitiesnoconv("Sincerely") . ".\n\n";
                                break;
                            case 'ORDER_SUPPLIER_CANCEL':
                                $link = '<a href="' . $urlwithroot . '/fourn/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->fournisseur->commande->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object);
                                $object_type = 'order_supplier';
                                $mesg = $outputlangs->transnoentitiesnoconv("Hello") . ",\n\n";
                                $mesg .= $outputlangs->transnoentitiesnoconv("EMailTextSupplierOrderCanceledBy", $link, $user->getFullName($outputlangs));
                                $mesg .= "\n\n" . $outputlangs->transnoentitiesnoconv("Sincerely") . ".\n\n";
                                break;
                            case 'ORDER_SUPPLIER_APPROVE':
                                $link = '<a href="' . $urlwithroot . '/fourn/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->fournisseur->commande->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object);
                                $object_type = 'order_supplier';
                                $labeltouse = isset($conf->global->ORDER_SUPPLIER_APPROVE_TEMPLATE) ? $conf->global->ORDER_SUPPLIER_APPROVE_TEMPLATE : '';
                                $mesg = $outputlangs->transnoentitiesnoconv("Hello") . ",\n\n";
                                $mesg .= $outputlangs->transnoentitiesnoconv("EMailTextSupplierOrderApprovedBy", $link, $user->getFullName($outputlangs));
                                $mesg .= "\n\n" . $outputlangs->transnoentitiesnoconv("Sincerely") . ".\n\n";
                                break;
                            case 'ORDER_SUPPLIER_SUBMIT':
                                $link = '<a href="' . $urlwithroot . '/fourn/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->fournisseur->commande->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object);
                                $object_type = 'order_supplier';
                                $mesg = $outputlangs->transnoentitiesnoconv("Hello") . ",\n\n";
                                $mesg .= $outputlangs->transnoentitiesnoconv("EMailTextSupplierOrderSubmittedBy", $link, $user->getFullName($outputlangs));
                                $mesg .= "\n\n" . $outputlangs->transnoentitiesnoconv("Sincerely") . ".\n\n";
                                break;
                            case 'ORDER_SUPPLIER_REFUSE':
                                $link = '<a href="' . $urlwithroot . '/fourn/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->fournisseur->commande->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object);
                                $object_type = 'order_supplier';
                                $labeltouse = isset($conf->global->ORDER_SUPPLIER_REFUSE_TEMPLATE) ? $conf->global->ORDER_SUPPLIER_REFUSE_TEMPLATE : '';
                                $mesg = $outputlangs->transnoentitiesnoconv("Hello") . ",\n\n";
                                $mesg .= $outputlangs->transnoentitiesnoconv("EMailTextSupplierOrderRefusedBy", $link, $user->getFullName($outputlangs));
                                $mesg .= "\n\n" . $outputlangs->transnoentitiesnoconv("Sincerely") . ".\n\n";
                                break;
                            case 'SHIPPING_VALIDATE':
                                $link = '<a href="' . $urlwithroot . '/expedition/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->expedition->dir_output . "/sending/" . get_exdir(0, 0, 0, 1, $object, 'shipment');
                                $object_type = 'shipping';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextExpeditionValidated", $link);
                                break;
                            case 'EXPENSE_REPORT_VALIDATE':
                                $link = '<a href="' . $urlwithroot . '/expensereport/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->expensereport->dir_output;
                                $object_type = 'expensereport';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextExpenseReportValidated", $link);
                                break;
                            case 'EXPENSE_REPORT_APPROVE':
                                $link = '<a href="' . $urlwithroot . '/expensereport/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->expensereport->dir_output;
                                $object_type = 'expensereport';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextExpenseReportApproved", $link);
                                break;
                            case 'HOLIDAY_VALIDATE':
                                $link = '<a href="' . $urlwithroot . '/holiday/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->holiday->dir_output;
                                $object_type = 'holiday';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextHolidayValidated", $link);
                                break;
                            case 'HOLIDAY_APPROVE':
                                $link = '<a href="' . $urlwithroot . '/holiday/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->holiday->dir_output;
                                $object_type = 'holiday';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextHolidayApproved", $link);
                                break;
                            case 'ACTION_CREATE':
                                $link = '<a href="' . $urlwithroot . '/comm/action/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                                $dir_output = $conf->agenda->dir_output;
                                $object_type = 'action';
                                $mesg = $outputlangs->transnoentitiesnoconv("EMailTextActionAdded", $link);
                                break;
                            default:
                                $object_type = $object->element;
                                $dir_output = $conf->$object_type->multidir_output[$object->entity ? $object->entity : $conf->entity] . "/" . get_exdir(0, 0, 0, 1, $object, $object_type);
                                $template = $notifcode . '_TEMPLATE';
                                $mesg = $outputlangs->transnoentitiesnoconv('Notify_' . $notifcode) . ' ' . $newref . ' ' . $dir_output;
                                break;
                        }

                        include_once DOL_DOCUMENT_ROOT . '/core/class/html.formmail.class.php';
                        $formmail = new FormMail($this->db);
                        $arraydefaultmessage = null;

                        $template = $notifcode . '_TEMPLATE';
                        $labeltouse = getDolGlobalString($template);
                        if (!empty($labeltouse)) {
                            $arraydefaultmessage = $formmail->getEMailTemplate($this->db, $object_type . '_send', $user, $outputlangs, 0, 1, $labeltouse);
                        }
                        if (!empty($labeltouse) && is_object($arraydefaultmessage) && $arraydefaultmessage->id > 0) {
                            $substitutionarray = getCommonSubstitutionArray($outputlangs, 0, null, $object);
                            complete_substitutions_array($substitutionarray, $outputlangs, $object);
                            $subject = make_substitutions($arraydefaultmessage->topic, $substitutionarray, $outputlangs);
                            $message = make_substitutions($arraydefaultmessage->content, $substitutionarray, $outputlangs);
                        } else {
                            $message = $outputlangs->transnoentities("YouReceiveMailBecauseOfNotification", $application, $mysoc->name) . "\n";
                            $message .= $outputlangs->transnoentities("YouReceiveMailBecauseOfNotification2", $application, $mysoc->name) . "\n";
                            $message .= "\n";
                            $message .= $mesg;
                        }

                        $ref = dol_sanitizeFileName($newref);
                        $pdf_path = $dir_output . "/" . $ref . ".pdf";
                        if (!dol_is_file($pdf_path) || (is_object($arraydefaultmessage) && $arraydefaultmessage->id > 0 && !$arraydefaultmessage->joinfiles)) {
                            // We can't add PDF as it is not generated yet.
                            $filepdf = '';
                        } else {
                            $filepdf = $pdf_path;
                            $filename_list[] = $filepdf;
                            $mimetype_list[] = mime_content_type($filepdf);
                            $mimefilename_list[] = $ref . ".pdf";
                        }

                        $labeltouse = !empty($labeltouse) ? $labeltouse : '';

                        // Replace keyword __SUPERVISOREMAIL__
                        if (preg_match('/__SUPERVISOREMAIL__/', $sendto)) {
                            $newval = '';
                            if ($user->fk_user > 0) {
                                $supervisoruser = new User($this->db);
                                $supervisoruser->fetch($user->fk_user);
                                if ($supervisoruser->email) {
                                    $newval = trim(dolGetFirstLastname($supervisoruser->firstname, $supervisoruser->lastname) . ' <' . $supervisoruser->email . '>');
                                }
                            }
                            dol_syslog("Replace the __SUPERVISOREMAIL__ key into recipient email string with " . $newval);
                            $sendto = preg_replace('/__SUPERVISOREMAIL__/', $newval, $sendto);
                            $sendto = preg_replace('/,\s*,/', ',', $sendto); // in some case you can have $sendto like "email, __SUPERVISOREMAIL__ , otheremail" then you have "email,  , othermail" and it's not valid
                            $sendto = preg_replace('/^[\s,]+/', '', $sendto); // Clean start of string
                            $sendto = preg_replace('/[\s,]+$/', '', $sendto); // Clean end of string
                        }

                        $parameters = array('notifcode' => $notifcode, 'sendto' => $sendto, 'from' => $from, 'file' => $filename_list, 'mimefile' => $mimetype_list, 'filename' => $mimefilename_list, 'outputlangs' => $outputlangs, 'labeltouse' => $labeltouse);
                        if (!isset($action)) {
                            $action = '';
                        }

                        $reshook = $hookmanager->executeHooks('formatNotificationMessage', $parameters, $object, $action); // Note that $action and $object may have been modified by some hooks
                        if (empty($reshook)) {
                            if (!empty($hookmanager->resArray['files'])) {
                                $filename_list = $hookmanager->resArray['files']['file'];
                                $mimetype_list = $hookmanager->resArray['files']['mimefile'];
                                $mimefilename_list = $hookmanager->resArray['files']['filename'];
                            }
                            if (!empty($hookmanager->resArray['subject'])) {
                                $subject .= $hookmanager->resArray['subject'];
                            }
                            if (!empty($hookmanager->resArray['message'])) {
                                $message .= $hookmanager->resArray['message'];
                            }
                        }

                        $mailfile = new CMailFile(
                            $subject,
                            $sendto,
                            $from,
                            $message,
                            $filename_list,
                            $mimetype_list,
                            $mimefilename_list,
                            '',
                            '',
                            0,
                            -1,
                            '',
                            '',
                            $trackid,
                            '',
                            'notification'
                        );

                        if ($mailfile->sendfile()) {
                            if ($obj->type_target == 'touserid') {
                                $sql = "INSERT INTO " . $this->db->prefix() . "notify (daten, fk_action, fk_soc, fk_user, type, objet_type, type_target, objet_id, email)";
                                $sql .= " VALUES ('" . $this->db->idate(dol_now()) . "', " . ((int) $notifcodedefid) . ", " . ($object->socid > 0 ? ((int) $object->socid) : 'null') . ", " . ((int) $obj->cid) . ", '" . $this->db->escape($obj->type) . "', '" . $this->db->escape($object_type) . "', '" . $this->db->escape($obj->type_target) . "', " . ((int) $object->id) . ", '" . $this->db->escape($obj->email) . "')";
                            } else {
                                $sql = "INSERT INTO " . $this->db->prefix() . "notify (daten, fk_action, fk_soc, fk_contact, type, objet_type, type_target, objet_id, email)";
                                $sql .= " VALUES ('" . $this->db->idate(dol_now()) . "', " . ((int) $notifcodedefid) . ", " . ($object->socid > 0 ? ((int) $object->socid) : 'null') . ", " . ((int) $obj->cid) . ", '" . $this->db->escape($obj->type) . "', '" . $this->db->escape($object_type) . "', '" . $this->db->escape($obj->type_target) . "', " . ((int) $object->id) . ", '" . $this->db->escape($obj->email) . "')";
                            }
                            if (!$this->db->query($sql)) {
                                dol_print_error($this->db);
                            }
                        } else {
                            $error++;
                            $this->errors[] = $mailfile->error;
                        }
                    } else {
                        dol_syslog("No notification sent for " . $sendto . " because email is empty");
                    }
                    $i++;
                }
            } else {
                dol_syslog("No notification to thirdparty sent, nothing into notification setup for the thirdparty socid = " . (empty($object->socid) ? '' : $object->socid));
            }
        } else {
            $error++;
            $this->errors[] = $this->db->lasterror();
            dol_syslog("Failed to get list of notification to send " . $this->db->lasterror(), LOG_ERR);
            return -1;
        }

        // Check notification using fixed email
        // TODO Move vars NOTIFICATION_FIXEDEMAIL into table llx_notify_def and inclulde the case into previous loop of sql result
        if (!$error) {
            foreach ($conf->global as $key => $val) {
                $reg = array();
                if ($val == '' || !preg_match('/^NOTIFICATION_FIXEDEMAIL_' . $notifcode . '_THRESHOLD_HIGHER_(.*)$/', $key, $reg)) {
                    continue;
                }

                $sendto = $val;

                $threshold = (float) $reg[1];
                if (!empty($object->total_ht) && $object->total_ht <= $threshold) {
                    dol_syslog("A notification is requested for notifcode = " . $notifcode . " but amount = " . $object->total_ht . " so lower than threshold = " . $threshold . ". We discard this notification");
                    continue;
                }

                $notifcodedefid = dol_getIdFromCode($this->db, $notifcode, 'c_action_trigger', 'code', 'rowid');
                if ($notifcodedefid <= 0) {
                    dol_print_error($this->db, 'Failed to get id from code');
                }
                $trackid = '';

                $object_type = '';
                $link = '';
                $num++;

                $appli = $mysoc->name;

                $subject = '[' . $appli . '] ' . $langs->transnoentitiesnoconv("DolibarrNotification") . ($projtitle ? ' ' . $projtitle : '');

                switch ($notifcode) {
                    case 'BILL_VALIDATE':
                        $link = '<a href="' . $urlwithroot . '/compta/facture/card.php?facid=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->facture->dir_output . "/" . get_exdir(0, 0, 0, 1, $object, 'invoice');
                        $object_type = 'facture';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextInvoiceValidated", $link);
                        break;
                    case 'BILL_PAYED':
                        $link = '<a href="' . $urlwithroot . '/compta/facture/card.php?facid=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->facture->dir_output . "/" . get_exdir(0, 0, 0, 1, $object, 'invoice');
                        $object_type = 'facture';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextInvoicePayed", $link);
                        break;
                    case 'ORDER_VALIDATE':
                        $link = '<a href="' . $urlwithroot . '/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->commande->dir_output . "/" . get_exdir(0, 0, 0, 1, $object, 'commande');
                        $object_type = 'order';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextOrderValidated", $link);
                        break;
                    case 'ORDER_CLOSE':
                        $link = '<a href="' . $urlwithroot . '/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->commande->dir_output . "/" . get_exdir(0, 0, 0, 1, $object, 'commande');
                        $object_type = 'order';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextOrderClose", $link);
                        break;
                    case 'PROPAL_VALIDATE':
                        $link = '<a href="' . $urlwithroot . '/comm/propal/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->propal->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object, 'propal');
                        $object_type = 'propal';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextProposalValidated", $link);
                        break;
                    case 'PROPAL_CLOSE_SIGNED':
                        $link = '<a href="' . $urlwithroot . '/comm/propal/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->propal->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object, 'propal');
                        $object_type = 'propal';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextProposalClosedSigned", $link);
                        break;
                    case 'FICHINTER_ADD_CONTACT':
                        $link = '<a href="' . $urlwithroot . '/fichinter/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->ficheinter->dir_output;
                        $object_type = 'ficheinter';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextInterventionAddedContact", $link);
                        break;
                    case 'FICHINTER_VALIDATE':
                        $link = '<a href="' . $urlwithroot . '/fichinter/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->facture->dir_output;
                        $object_type = 'ficheinter';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextInterventionValidated", $link);
                        break;
                    case 'FICHINTER_CLOSE':
                        $link = '<a href="' . $urlwithroot . '/fichinter/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->facture->dir_output;
                        $object_type = 'ficheinter';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextInterventionClosed", $link);
                        break;
                    case 'ORDER_SUPPLIER_CANCEL':
                        $link = '<a href="' . $urlwithroot . '/fourn/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->fournisseur->commande->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object);
                        $object_type = 'order_supplier';
                        $mesg = $langs->transnoentitiesnoconv("Hello") . ",\n\n";
                        $mesg .= $langs->transnoentitiesnoconv("EMailTextSupplierOrderCanceledBy", $link, $user->getFullName($langs));
                        $mesg .= "\n\n" . $langs->transnoentitiesnoconv("Sincerely") . ".\n\n";
                        break;
                    case 'ORDER_SUPPLIER_VALIDATE':
                        $link = '<a href="' . $urlwithroot . '/fourn/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->fournisseur->commande->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object);
                        $object_type = 'order_supplier';
                        $mesg = $langs->transnoentitiesnoconv("Hello") . ",\n\n";
                        $mesg .= $langs->transnoentitiesnoconv("EMailTextSupplierOrderValidatedBy", $link, $user->getFullName($langs));
                        $mesg .= "\n\n" . $langs->transnoentitiesnoconv("Sincerely") . ".\n\n";
                        break;
                    case 'ORDER_SUPPLIER_APPROVE':
                        $link = '<a href="' . $urlwithroot . '/fourn/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->fournisseur->commande->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object);
                        $object_type = 'order_supplier';
                        $mesg = $langs->transnoentitiesnoconv("Hello") . ",\n\n";
                        $mesg .= $langs->transnoentitiesnoconv("EMailTextSupplierOrderApprovedBy", $link, $user->getFullName($langs));
                        $mesg .= "\n\n" . $langs->transnoentitiesnoconv("Sincerely") . ".\n\n";
                        break;
                    case 'ORDER_SUPPLIER_SUBMIT':
                        $link = '<a href="' . $urlwithroot . '/fourn/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->fournisseur->commande->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object);
                        $object_type = 'order_supplier';
                        $mesg = $langs->transnoentitiesnoconv("Hello") . ",\n\n";
                        $mesg .= $langs->transnoentitiesnoconv("EMailTextSupplierOrderSubmittedBy", $link, $user->getFullName($langs));
                        $mesg .= "\n\n" . $langs->transnoentitiesnoconv("Sincerely") . ".\n\n";
                        break;
                    case 'ORDER_SUPPLIER_REFUSE':
                        $link = '<a href="' . $urlwithroot . '/fourn/commande/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->fournisseur->commande->multidir_output[$object->entity] . "/" . get_exdir(0, 0, 0, 1, $object);
                        $object_type = 'order_supplier';
                        $mesg = $langs->transnoentitiesnoconv("Hello") . ",\n\n";
                        $mesg .= $langs->transnoentitiesnoconv("EMailTextSupplierOrderRefusedBy", $link, $user->getFullName($langs));
                        $mesg .= "\n\n" . $langs->transnoentitiesnoconv("Sincerely") . ".\n\n";
                        break;
                    case 'SHIPPING_VALIDATE':
                        $link = '<a href="' . $urlwithroot . '/expedition/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->expedition->dir_output . "/sending/" . get_exdir(0, 0, 0, 1, $object, 'shipment');
                        $object_type = 'order_supplier';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextExpeditionValidated", $link);
                        break;
                    case 'EXPENSE_REPORT_VALIDATE':
                        $link = '<a href="' . $urlwithroot . '/expensereport/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->expensereport->dir_output;
                        $object_type = 'expensereport';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextExpenseReportValidated", $link);
                        break;
                    case 'EXPENSE_REPORT_APPROVE':
                        $link = '<a href="' . $urlwithroot . '/expensereport/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->expensereport->dir_output;
                        $object_type = 'expensereport';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextExpenseReportApproved", $link);
                        break;
                    case 'HOLIDAY_VALIDATE':
                        $link = '<a href="' . $urlwithroot . '/holiday/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->holiday->dir_output;
                        $object_type = 'holiday';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextHolidayValidated", $link);
                        break;
                    case 'HOLIDAY_APPROVE':
                        $link = '<a href="' . $urlwithroot . '/holiday/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->holiday->dir_output;
                        $object_type = 'holiday';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextHolidayApproved", $link);
                        break;
                    case 'ACTION_CREATE':
                        $link = '<a href="' . $urlwithroot . '/comm/action/card.php?id=' . $object->id . '&entity=' . $object->entity . '">' . $newref . '</a>';
                        $dir_output = $conf->agenda->dir_output;
                        $object_type = 'action';
                        $mesg = $langs->transnoentitiesnoconv("EMailTextActionAdded", $link);
                        break;
                    default:
                        $object_type = $object->element;
                        $dir_output = $conf->$object_type->multidir_output[$object->entity ? $object->entity : $conf->entity] . "/" . get_exdir(0, 0, 0, 1, $object, $object_type);
                        $mesg = $langs->transnoentitiesnoconv('Notify_' . $notifcode) . ' ' . $newref;
                        break;
                }
                $ref = dol_sanitizeFileName($newref);
                $pdf_path = $dir_output . "/" . $ref . "/" . $ref . ".pdf";
                if (!dol_is_file($pdf_path)) {
                    // We can't add PDF as it is not generated yet.
                    $filepdf = '';
                } else {
                    $filepdf = $pdf_path;
                    $filename_list[] = $pdf_path;
                    $mimetype_list[] = mime_content_type($filepdf);
                    $mimefilename_list[] = $ref . ".pdf";
                }

                // Set output language
                $outputlangs = $langs;

                // if an e-mail template is configured for this notification code (for instance 'SHIPPING_VALIDATE_TEMPLATE', ...),
                // we fetch this template by its label. Otherwise, a default message content will be sent.
                $mailTemplateLabel = getDolGlobalString($notifcode . '_TEMPLATE');
                $emailTemplate = null;
                if (!empty($mailTemplateLabel)) {
                    include_once DOL_DOCUMENT_ROOT . '/core/class/html.formmail.class.php';
                    $formmail = new FormMail($this->db);
                    $emailTemplate = $formmail->getEMailTemplate($this->db, $object_type . '_send', $user, $outputlangs, 0, 1, $mailTemplateLabel);
                }
                if (!empty($mailTemplateLabel) && is_object($emailTemplate) && $emailTemplate->id > 0) {
                    if (property_exists($object, 'thirdparty') && $object->thirdparty instanceof Societe && $object->thirdparty->default_lang && $object->thirdparty->default_lang != $langs->defaultlang) {

                        $outputlangs = new Translate('', $conf);
                        $outputlangs->setDefaultLang($object->thirdparty->default_lang);
                        $outputlangs->loadLangs(array('main', 'other'));
                    }
                    $substitutionarray = getCommonSubstitutionArray($outputlangs, 0, null, $object);
                    complete_substitutions_array($substitutionarray, $outputlangs, $object);
                    $subject = make_substitutions($emailTemplate->topic, $substitutionarray, $outputlangs);
                    $message = make_substitutions($emailTemplate->content, $substitutionarray, $outputlangs);
                } else {
                    $message = '';
                    $message .= $outputlangs->transnoentities("YouReceiveMailBecauseOfNotification2", $application, $mysoc->name) . "\n";
                    $message .= "\n";
                    $message .= $mesg;

                    $message = nl2br($message);
                }

                // Replace keyword __SUPERVISOREMAIL__
                if (preg_match('/__SUPERVISOREMAIL__/', $sendto)) {
                    $newval = '';
                    if ($user->fk_user > 0) {
                        $supervisoruser = new User($this->db);
                        $supervisoruser->fetch($user->fk_user);
                        if ($supervisoruser->email) {
                            $newval = trim(dolGetFirstLastname($supervisoruser->firstname, $supervisoruser->lastname) . ' <' . $supervisoruser->email . '>');
                        }
                    }
                    dol_syslog("Replace the __SUPERVISOREMAIL__ key into recipient email string with " . $newval);
                    $sendto = preg_replace('/__SUPERVISOREMAIL__/', $newval, $sendto);
                    $sendto = preg_replace('/,\s*,/', ',', $sendto); // in some case you can have $sendto like "email, __SUPERVISOREMAIL__ , otheremail" then you have "email,  , othermail" and it's not valid
                    $sendto = preg_replace('/^[\s,]+/', '', $sendto); // Clean start of string
                    $sendto = preg_replace('/[\s,]+$/', '', $sendto); // Clean end of string
                }

                if ($sendto) {
                    $parameters = array('notifcode' => $notifcode, 'sendto' => $sendto, 'from' => $from, 'file' => $filename_list, 'mimefile' => $mimetype_list, 'filename' => $mimefilename_list, 'subject' => &$subject, 'message' => &$message);
                    $reshook = $hookmanager->executeHooks('formatNotificationMessage', $parameters, $object, $action); // Note that $action and $object may have been modified by some hooks
                    if (empty($reshook)) {
                        if (!empty($hookmanager->resArray['files'])) {
                            $filename_list = $hookmanager->resArray['files']['file'];
                            $mimetype_list = $hookmanager->resArray['files']['mimefile'];
                            $mimefilename_list = $hookmanager->resArray['files']['filename'];
                        }
                        if (!empty($hookmanager->resArray['subject'])) {
                            $subject .= $hookmanager->resArray['subject'];
                        }
                        if (!empty($hookmanager->resArray['message'])) {
                            $message .= $hookmanager->resArray['message'];
                        }
                    }
                    $mailfile = new CMailFile(
                        $subject,
                        $sendto,
                        $from,
                        $message,
                        $filename_list,
                        $mimetype_list,
                        $mimefilename_list,
                        '',
                        '',
                        0,
                        1,
                        '',
                        $trackid,
                        '',
                        '',
                        'notification'
                    );

                    if ($mailfile->sendfile()) {
                        $sql = "INSERT INTO " . $this->db->prefix() . "notify (daten, fk_action, fk_soc, fk_contact, type, type_target, objet_type, objet_id, email)";
                        $sql .= " VALUES ('" . $this->db->idate(dol_now()) . "', " . ((int) $notifcodedefid) . ", " . ($object->socid > 0 ? ((int) $object->socid) : 'null') . ", null, 'email', 'tofixedemail', '" . $this->db->escape($object_type) . "', " . ((int) $object->id) . ", '" . $this->db->escape($sendto) . "')";
                        if (!$this->db->query($sql)) {
                            dol_print_error($this->db);
                        }
                    } else {
                        $error++;
                        $this->errors[] = $mailfile->error;
                    }
                }
            }
        }

        if (!$error) {
            return $num;
        } else {
            return -1 * $error;
        }
    }
}

alxarafe / alixar

Push — EXTRACT_CLASSES ( 0382f2...c25e41 )

Notify::send() F

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like
