Dolibarr\Code\Core\Classes\Notify::getNotificationsArray()

Complexity

Conditions	37
Paths	1296

Size

Total Lines	156
Code Lines	102

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    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;
    }