mailing_targets.class.php

<?php
/* Copyright (C) 2025   Cloned from htdocs/comm/mailing/class/mailing.class.php then modified
 * Copyright (C) 2025   Jon Bendtsen <jon.bendtsen.github@jonb.dk>
 * Copyright (C) 2026   MDW       <mdeweerd@users.noreply.github.com>
 *
 * 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/>.
 */
 
require_once DOL_DOCUMENT_ROOT.'/core/class/commonobject.class.php';
 
 
class MailingTarget extends CommonObject
{
  public $element = 'mailing_target';
 
  public $table_element = 'mailing_cibles';
 
  public $picto = 'contact';
 
  public $fk_mailing;
 
  public $fk_contact;
 
  public $lastname;
 
  public $firstname;
 
  public $email;
 
  public $other;
 
  public $tag;
 
  public $statut; // Status 0=Not sent, 1=Sent, 2=Read, 3=Read and unsubscribed, -1=Error
 
  public $status; // Status 0=Not sent, 1=Sent, 2=Read, 3=Read and unsubscribed, -1=Error
 
  public $statut_dest = array();
 
  public $source_url;
 
  public $source_id;
 
  public $source_type;
 
  public $date_envoi;
 
  public $tms;
 
  public $error_text;
 
  const STATUS_NOTSENT = 0;
  const STATUS_SENT = 1;
  const STATUS_READ = 2;
  const STATUS_READANDUNSUBSCRIBED = 3;
  const STATUS_ERROR = -1;
 
  public function __construct($db)
  {
    $this->db = $db;
 
    // List of language codes for status
    $this->labelStatus[0] = 'TargetStatusNotSent';
    $this->labelStatus[1] = 'TargetStatusSent';
    $this->labelStatus[2] = 'TargetStatusRead';
    $this->labelStatus[3] = 'TargetStatusReadAndUnsubscribed';
    $this->labelStatus[-1] = 'TargetStatusError';
 
    $this->statut_dest[0] = 'TargetStatusNotSent';
    $this->statut_dest[1] = 'TargetStatusSent';
    $this->statut_dest[2] = 'TargetStatusRead';
    $this->statut_dest[3] = 'TargetStatusReadAndUnsubscribed'; // Read but ask to not be contacted anymore
    $this->statut_dest[-1] = 'TargetStatusError';
  }
 
  public function create($user)
  {
    global $conf, $langs;
 
    if (empty($this->fk_mailing)) {
      $this->error = $langs->trans("ErrorFieldRequired", $langs->transnoentitiesnoconv("Mailing"));
      return -2;
      // we probably should also check that this number actually exists in ".MAIN_DB_PREFIX."mailing";
    }
    if (0 == $this->fk_mailing) {
      $this->error = $langs->trans("ErrorFieldRequired", $langs->transnoentitiesnoconv("Mailing"));
      return -4;
    }
    if (empty($this->email)) {
      $this->error = $langs->trans("ErrorFieldRequired", $langs->transnoentitiesnoconv("Email"));
      return -3;
    }
    if (empty($this->statut)) {
      $statut = 0;
    }
    if (empty($this->status)) {
      $status = 0;
    }
    if ($this->status !== $this->statut) {
      $this->error = 'Status='.$this->status.' and Statut='.$this->statut.' field must be identical';
      return -4;
    }
    if (empty($this->fk_contact)) {
      $fk_contact = 0;
    }
 
    $error = 0;
 
    $this->db->begin();
 
 
    // 2025-10-09 06:33:26 DEBUG   192.168.127.1        52     33  sql=INSERT INTO llx_mailing_cibles (fk_mailing, fk_contact, email, statut) VALUES ('4',  .((int) 0)., 'jon@jonb.dk',  .((int) )).
    //2025-10-09 06:35:13 DEBUG   192.168.127.1        54     33  sql=INSERT INTO llx_mailing_cibles (fk_mailing, fk_contact, email, statut) VALUES (4,  .((int) 0)., 'jon@jonb.dk',  .((int) )).
 
    $sql = "INSERT INTO ".MAIN_DB_PREFIX."mailing_cibles";
    $sql .= " (fk_mailing, fk_contact, email, statut)";
    $sql .= " VALUES (".((int) $this->fk_mailing).", ";
    $sql .=  ((int) $this->fk_contact).", ";
    $sql .= "'".$this->db->escape($this->email)."', ";
    $sql .=  ((int) $conf->statut)." )";
 
    dol_syslog(__METHOD__, LOG_DEBUG);
 
    $resql = $this->db->query($sql);
    if ($resql) {
      $this->id = $this->db->last_insert_id(MAIN_DB_PREFIX."mailing_cibles");
 
      $result = $this->update($user);
      if ($result < 0) {
        $error++;
      }
 
      if (!$error) {
        $this->db->commit();
        return $this->id;
      } else {
        $this->db->rollback();
        dol_syslog(__METHOD__ . ' ' . $this->error, LOG_ERR);
        return -2;
      }
    } else {
      $this->error = $this->db->lasterror();
      $this->db->rollback();
      return -1;
    }
  }
 
  public function delete($user)
  {
    $error = 0;
 
    $this->db->begin();
 
    $sql = "DELETE FROM ".MAIN_DB_PREFIX."mailing_cibles";
    $sql .= " WHERE rowid = " . ((int) $this->id);
 
    dol_syslog(__METHOD__, LOG_DEBUG);
    $resql = $this->db->query($sql);
    if ($resql) {
      dol_syslog(__METHOD__ . ' success');
      $this->db->commit();
      return 1;
    } else {
      $this->db->rollback();
      $this->error = $this->db->lasterror();
      return -1;
    }
  }
 
  public function setNotSent()
  {
    $now = dol_now();
 
    $sql = "UPDATE ".MAIN_DB_PREFIX."mailing_cibles ";
    $sql .= " SET statut = ".((int) self::STATUS_NOTSENT).", tms = '".$this->db->idate($now)."'";
    $sql .= " WHERE rowid = ".((int) $this->id);
 
    dol_syslog("Mailing::valid", LOG_DEBUG);
    if ($this->db->query($sql)) {
      return 1;
    } else {
      $this->error = $this->db->lasterror();
      return -1;
    }
  }
 
  public function setSent()
  {
    $now = dol_now();
 
    $sql = "UPDATE ".MAIN_DB_PREFIX."mailing_cibles ";
    $sql .= " SET statut = ".((int) self::STATUS_SENT).", tms = '".$this->db->idate($now)."'";
    $sql .= " WHERE rowid = ".((int) $this->id);
 
    dol_syslog("Mailing::valid", LOG_DEBUG);
    if ($this->db->query($sql)) {
      return 1;
    } else {
      $this->error = $this->db->lasterror();
      return -1;
    }
  }
 
  public function setRead()
  {
    $now = dol_now();
 
    $sql = "UPDATE ".MAIN_DB_PREFIX."mailing_cibles ";
    $sql .= " SET statut = ".((int) self::STATUS_READ).", tms = '".$this->db->idate($now)."'";
    $sql .= " WHERE rowid = ".((int) $this->id);
 
    dol_syslog("Mailing::valid", LOG_DEBUG);
    if ($this->db->query($sql)) {
      return 1;
    } else {
      $this->error = $this->db->lasterror();
      return -1;
    }
  }
 
  public function setReadAndUnsubscribed()
  {
    $now = dol_now();
 
    $sql = "UPDATE ".MAIN_DB_PREFIX."mailing_cibles ";
    $sql .= " SET statut = ".((int) self::STATUS_READANDUNSUBSCRIBED).", tms = '".$this->db->idate($now)."'";
    $sql .= " WHERE rowid = ".((int) $this->id);
 
    dol_syslog("Mailing::valid", LOG_DEBUG);
    if ($this->db->query($sql)) {
      return 1;
    } else {
      $this->error = $this->db->lasterror();
      return -1;
    }
  }
 
  public function setError()
  {
    $now = dol_now();
 
    $sql = "UPDATE ".MAIN_DB_PREFIX."mailing_cibles ";
    $sql .= " SET statut = ".((int) self::STATUS_ERROR).", tms = '".$this->db->idate($now)."'";
    $sql .= " WHERE rowid = ".((int) $this->id);
 
    dol_syslog("Mailing::valid", LOG_DEBUG);
    if ($this->db->query($sql)) {
      return 1;
    } else {
      $this->error = $this->db->lasterror();
      return -1;
    }
  }
 
  public function update($user)
  {
    global $langs;
 
    if (empty($this->fk_mailing)) {
      return -2;
      // we probably should also check that this number actually exists in ".MAIN_DB_PREFIX."mailing";
    }
    if (empty($this->email)) {
      return -3;
    }
    if (empty($this->statut)) {
      $statut = 0;
    }
    if (empty($this->status)) {
      $status = 0;
    }
    if ($this->status !== $this->statut) {
      return -4;
    }
    if (empty($this->fk_contact)) {
      $fk_contact = 0;
    }
 
    $now = dol_now();
    $error = 0;
    $this->db->begin();
 
    $sql = "UPDATE ".MAIN_DB_PREFIX."mailing_cibles";
    $sql .= " SET fk_mailing = ".((int) $this->fk_mailing);
    $sql .= ", fk_contact = ".((int) $this->fk_contact);
    $sql .= ", lastname = '".$this->db->escape($this->lastname)."'";
    $sql .= ", firstname = '".$this->db->escape($this->firstname)."'";
    $sql .= ", email = '".$this->db->escape($this->email)."'";
    $sql .= ", other = '".$this->db->escape($this->other)."'";
    $sql .= ", tag = '".$this->db->escape($this->tag)."'";
    $sql .= ", statut = ".((int) $this->statut);
    $sql .= ", source_url = '".$this->db->escape($this->source_url)."'";
    $sql .= ", source_id = ".((int) $this->source_id);
    $sql .= ", source_type = '".$this->db->escape($this->source_type)."'";
    if ($this->date_envoi) {
      $sql .= ", date_envoi = '".$this->db->idate($this->date_envoi)."'";
    }
    $sql .= ", error_text = '".($this->error_text ? $this->db->escape($this->error_text) : null)."'";
    $sql .= " WHERE rowid = ".(int) $this->id;
 
    dol_syslog(__METHOD__, LOG_DEBUG);
    $resql = $this->db->query($sql);
    if ($resql) {
      dol_syslog(__METHOD__ . ' success');
      $this->db->commit();
      return 1;
    } else {
      if ($this->db->lasterrno() == 'DB_ERROR_RECORD_ALREADY_EXISTS') {
        $this->error = $langs->trans("ErrorRecordAlreadyExists", $this->email);
      } else {
        $this->error = $this->db->lasterror();
      }
      $this->db->rollback();
      return -6;
    }
  }
 
  public function fetch($rowid)
  {
    $sql = "SELECT t.rowid";
    $sql .= ", t.fk_mailing";
    $sql .= ", t.fk_contact";
    $sql .= ", t.lastname";
    $sql .= ", t.firstname";
    $sql .= ", t.email";
    $sql .= ", t.other";
    $sql .= ", t.tag";
    $sql .= ", t.statut as status";
    $sql .= ", t.source_url";
    $sql .= ", t.source_id";
    $sql .= ", t.source_type";
    $sql .= ", t.date_envoi";
    $sql .= ", t.tms as date_modification";
    $sql .= ", t.error_text";
    $sql .= " FROM ".MAIN_DB_PREFIX."mailing_cibles as t";
    $sql .= " WHERE t.rowid = ".(int) $rowid;
 
    dol_syslog(get_class($this)."::fetch", LOG_DEBUG);
    $result = $this->db->query($sql);
    if ($result) {
      if ($this->db->num_rows($result)) {
        $obj = $this->db->fetch_object($result);
 
        $this->id = $obj->rowid;
        $this->fk_mailing = $obj->fk_mailing;
        $this->fk_contact = $obj->fk_contact;
        $this->lastname = $obj->lastname;
        $this->firstname = $obj->firstname;
        $this->email = $obj->email;
        $this->other = $obj->other;
        $this->tag = $obj->tag;
        $this->statut = $obj->status; // deprecated
        $this->status = $obj->status;
        $this->source_url = $obj->source_url;
        $this->source_id = $obj->source_id;
        $this->source_type = $obj->source_type;
        $this->date_envoi = $this->db->jdate($obj->date_envoi);
        $this->date_modification = $this->db->jdate($obj->date_modification); // tms
        $this->tms = $this->db->jdate($obj->date_modification); // tms
        $this->error_text = $obj->error_text;
 
        return 1;
      } else {
        dol_syslog(get_class($this)."::fetch Error -1");
        return -1;
      }
    } else {
      dol_syslog(get_class($this)."::fetch Error -2");
      return -2;
    }
  }
}