datapolicycron.class.php

Go to the documentation of this file.

<?php
/* Copyright (C) 2018       Nicolas ZABOURI     <info@inovea-conseil.com>
 * Copyright (C) 2018-2026  Frédéric France     <frederic.france@free.fr>
 * Copyright (C) 2024      William Mead      <william.mead@manchenumerique.fr>
 * Copyright (C) 2024-2026  MDW                      <mdeweerd@users.noreply.github.com>
 * Copyright (C) 2025      Quentin VIAL--GOUTEYRON   <quentin.vial-gouteyron@atm-consulting.fr>
 * Copyright (C) 2025      Waël Almoman              <info@almoman.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/>.
 */
 
class DataPolicyCron
{
  public $db;
  public $error;
  public $output;
  private $nbupdated = 0;
  private $nbdeleted = 0;
  private $errorCount = 0;
  private $errorMessages = array();
 
  public function __construct(DoliDB $db)
  {
    $this->db = $db;
  }
 
  public function getDataPolicies()
  {
    $sanitized_prefix = $this->db->prefix();
 
    $arrayofpolicies = array(
      // --- Third Parties ---
      'tiers_client' => array(
        'group' => 'ThirdParty',
        'label_key' => 'DATAPOLICY_TIERS_CLIENT',
        'picto' => img_picto('', 'company', 'class="pictofixedwidth"'),
        'const_delete' => '',
        'const_anonymize' => 'DATAPOLICY_TIERS_CLIENT_ANONYMIZE_DELAY',
        'sql_template' => "SELECT s.rowid FROM ".$sanitized_prefix."societe as s WHERE s.entity = __ENTITY__ AND s.client = ".Societe::CUSTOMER." AND s.fournisseur = 0 AND s.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND NOT EXISTS (SELECT a.id FROM ".$sanitized_prefix."actioncomm as a WHERE a.fk_soc = s.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM ".$sanitized_prefix."facture as f WHERE f.fk_soc = s.rowid)",
        'class' => 'Societe',
        'file' => DOL_DOCUMENT_ROOT . '/societe/class/societe.class.php',
        'anonymize_fields' => array('name' => 'MAKEANONYMOUS', 'name_alias' => 'MAKEANONYMOUS', 'address' => '---', 'town' => '---', 'zip' => '---', 'phone' => '---', 'email' => 'anonymous+__ID__@example.com', 'url' => '---', 'fax' => '---', 'siret' => '---', 'siren' => '---', 'ape' => '---', 'idprof4' => '---', 'idprof5' => '---', 'idprof6' => '---', 'tva_intra' => '---', 'capital' => 0, 'socialnetworks' => [], 'geolat' => 0, 'geolong' => 0, 'ip' => '0.0.0.0'),
        'call_params' => array(
          'delete' => array('id', 'user'), // $object->delete($id, $user)
          'update' => array('id', 'user')  // $object->update($id, $user)
        )
      ),
      'tiers_prospect' => array(
        'group' => 'ThirdParty',
        'label_key' => 'DATAPOLICY_TIERS_PROSPECT',
        'picto' => img_picto('', 'company', 'class="pictofixedwidth"'),
        'const_delete' => '',
        'const_anonymize' => 'DATAPOLICY_TIERS_PROSPECT_ANONYMIZE_DELAY',
        'sql_template' => "SELECT s.rowid FROM ".$sanitized_prefix."societe as s WHERE s.entity = __ENTITY__ AND s.client = ".Societe::PROSPECT." AND s.fournisseur = 0 AND s.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND NOT EXISTS (SELECT a.id FROM ".$sanitized_prefix."actioncomm as a WHERE a.fk_soc = s.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM ".$sanitized_prefix."facture as f WHERE f.fk_soc = s.rowid)",
        'class' => 'Societe',
        'file' => DOL_DOCUMENT_ROOT . '/societe/class/societe.class.php',
        'anonymize_fields' => array('name' => 'MAKEANONYMOUS', 'name_alias' => 'MAKEANONYMOUS', 'address' => '---', 'town' => '---', 'zip' => '---', 'phone' => '---', 'email' => 'anonymous+__ID__@example.com', 'url' => '---', 'fax' => '---', 'siret' => '---', 'siren' => '---', 'ape' => '---', 'idprof4' => '---', 'idprof5' => '---', 'idprof6' => '---', 'tva_intra' => '---', 'capital' => 0, 'socialnetworks' => [], 'geolat' => 0, 'geolong' => 0, 'ip' => '0.0.0.0'),
        'call_params' => array(
          'delete' => array('id', 'user'), // $object->delete($id, $user)
          'update' => array('id', 'user')  // $object->update($id, $user)
        )
      ),
      'tiers_prospect_client' => array(
        'group' => 'ThirdParty',
        'label_key' => 'DATAPOLICY_TIERS_PROSPECT_CLIENT',
        'picto' => img_picto('', 'company', 'class="pictofixedwidth"'),
        'const_delete' => '',
        'const_anonymize' => 'DATAPOLICY_TIERS_PROSPECT_CLIENT_ANONYMIZE_DELAY',
        'sql_template' => "SELECT s.rowid FROM ".$sanitized_prefix."societe as s WHERE s.entity = __ENTITY__ AND s.client = ".Societe::CUSTOMER_AND_PROSPECT." AND s.fournisseur = 0 AND s.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND NOT EXISTS (SELECT a.id FROM ".$sanitized_prefix."actioncomm as a WHERE a.fk_soc = s.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM ".$sanitized_prefix."facture as f WHERE f.fk_soc = s.rowid)",
        'class' => 'Societe',
        'file' => DOL_DOCUMENT_ROOT . '/societe/class/societe.class.php',
        'anonymize_fields' => array('name' => 'MAKEANONYMOUS', 'name_alias' => 'MAKEANONYMOUS', 'address' => '---', 'town' => '---', 'zip' => '---', 'phone' => '---', 'email' => 'anonymous+__ID__@example.com', 'url' => '---', 'fax' => '---', 'siret' => '---', 'siren' => '---', 'ape' => '---', 'idprof4' => '---', 'idprof5' => '---', 'idprof6' => '---', 'tva_intra' => '---', 'capital' => 0, 'socialnetworks' => [], 'geolat' => 0, 'geolong' => 0, 'ip' => '0.0.0.0'),
        'call_params' => array(
          'delete' => array('id', 'user'), // $object->delete($id, $user)
          'update' => array('id', 'user')  // $object->update($id, $user)
        )
      ),
      'tiers_niprosp_niclient' => array(
        'group' => 'ThirdParty',
        'label_key' => 'DATAPOLICY_TIERS_NIPROSPECT_NICLIENT',
        'picto' => img_picto('', 'company', 'class="pictofixedwidth"'),
        'const_delete' => 'DATAPOLICY_TIERS_NIPROSPECT_NICLIENT_DELETE_DELAY',
        'const_anonymize' => 'DATAPOLICY_TIERS_NIPROSPECT_NICLIENT_ANONYMIZE_DELAY',
        'sql_template' => "SELECT s.rowid FROM ".$sanitized_prefix."societe as s WHERE s.entity = __ENTITY__ AND s.client = ".Societe::NO_CUSTOMER." AND s.fournisseur = 0 AND s.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND NOT EXISTS (SELECT a.id FROM ".$sanitized_prefix."actioncomm as a WHERE a.fk_soc = s.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM ".$sanitized_prefix."facture as f WHERE f.fk_soc = s.rowid)",
        'sql_template_delete' => "SELECT s.rowid FROM ".$sanitized_prefix."societe as s WHERE s.entity = __ENTITY__ AND s.client = ".Societe::NO_CUSTOMER." AND s.fournisseur = 0 AND s.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND NOT EXISTS (SELECT a.id FROM ".$sanitized_prefix."actioncomm as a WHERE a.fk_soc = s.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM ".$sanitized_prefix."facture as f WHERE f.fk_soc = s.rowid)",
        'class' => 'Societe',
        'file' => DOL_DOCUMENT_ROOT . '/societe/class/societe.class.php',
        'anonymize_fields' => array('name' => 'MAKEANONYMOUS', 'name_alias' => 'MAKEANONYMOUS', 'address' => '---', 'town' => '---', 'zip' => '---', 'phone' => '---', 'email' => 'anonymous+__ID__@example.com', 'url' => '---', 'fax' => '---', 'siret' => '---', 'siren' => '---', 'ape' => '---', 'idprof4' => '---', 'idprof5' => '---', 'idprof6' => '---', 'tva_intra' => '---', 'capital' => 0, 'socialnetworks' => [], 'geolat' => 0, 'geolong' => 0, 'ip' => '0.0.0.0'),
        'call_params' => array(
          'delete' => array('id', 'user'), // $object->delete($id, $user)
          'update' => array('id', 'user')  // $object->update($id, $user)
        )
      ),
      'tiers_fournisseur' => array(
        'group' => 'ThirdParty',
        'label_key' => 'DATAPOLICY_TIERS_FOURNISSEUR',
        'picto' => img_picto('', 'supplier', 'class="pictofixedwidth"'),
        'const_delete' => '',
        'const_anonymize' => 'DATAPOLICY_TIERS_FOURNISSEUR_ANONYMIZE_DELAY',
        // Suppliers must be checked against llx_facture_fourn (purchase invoices),
        // not llx_facture (sales invoices). A pure supplier with no sales would
        // otherwise always pass the filter and get anonymized regardless of
        // purchase history (#38788).
        'sql_template' => "SELECT s.rowid FROM ".$sanitized_prefix."societe as s WHERE s.entity = __ENTITY__ AND s.fournisseur = 1 AND s.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND NOT EXISTS (SELECT a.id FROM ".$sanitized_prefix."actioncomm as a WHERE a.fk_soc = s.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM ".$sanitized_prefix."facture_fourn as f WHERE f.fk_soc = s.rowid)",
        'class' => 'Societe',
        'file' => DOL_DOCUMENT_ROOT . '/societe/class/societe.class.php',
        'anonymize_fields' => array('name' => 'MAKEANONYMOUS', 'name_alias' => 'MAKEANONYMOUS', 'address' => '---', 'town' => '---', 'zip' => '---', 'phone' => '---', 'email' => 'anonymous+__ID__@example.com', 'url' => '---', 'fax' => '---', 'siret' => '---', 'siren' => '---', 'ape' => '---', 'idprof4' => '---', 'idprof5' => '---', 'idprof6' => '---', 'tva_intra' => '---', 'capital' => 0, 'socialnetworks' => [], 'geolat' => 0, 'geolong' => 0, 'ip' => '0.0.0.0'),
        'call_params' => array(
          'delete' => array('id', 'user'), // $object->delete($id, $user)
          'update' => array('id', 'user')  // $object->update($id, $user)
        )
      ),
      // --- Contacts ---
      'contact_client' => array(
        'group' => 'Contact',
        'label_key' => 'DATAPOLICY_CONTACT_CLIENT',
        'picto' => img_picto('', 'contact', 'class="pictofixedwidth"'),
        'const_delete' => '',
        'const_anonymize' => 'DATAPOLICY_CONTACT_CLIENT_ANONYMIZE_DELAY',
        'sql_template' => "SELECT c.rowid FROM "
          .$sanitized_prefix."socpeople as c INNER JOIN "
          .$sanitized_prefix."societe as s ON s.rowid = c.fk_soc WHERE c.entity = __ENTITY__ AND c.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND s.client = ".Societe::CUSTOMER." AND s.fournisseur = 0 AND NOT EXISTS (SELECT a.id FROM "
          .$sanitized_prefix."actioncomm as a WHERE a.fk_contact = c.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM "
          .$sanitized_prefix."facture as f WHERE f.fk_soc = s.rowid)",
        'class' => 'Contact',
        'file' => DOL_DOCUMENT_ROOT . '/contact/class/contact.class.php',
        'anonymize_fields' => array('lastname' => 'MAKEANONYMOUS', 'firstname' => 'MAKEANONYMOUS', 'poste' => '---', 'address' => '---', 'town' => '---', 'zip' => '---', 'phone_pro' => '---', 'phone_perso' => '---', 'phone_mobile' => '---', 'email' => 'anonymous+__ID__@example.com', 'photo' => '', 'url' => '---', 'fax' => '---', 'socialnetworks' => [], 'geolat' => 0, 'geolong' => 0, 'ip' => '0.0.0.0'),
        'call_params' => array(
          'delete' => array('user'), // $object->delete($user)
          'update' => array('id', 'user') // $object->update($id, $user)
        )
      ),
      'contact_prospect' => array(
        'group' => 'Contact',
        'label_key' => 'DATAPOLICY_CONTACT_PROSPECT',
        'picto' => img_picto('', 'contact', 'class="pictofixedwidth"'),
        'const_delete' => '',
        'const_anonymize' => 'DATAPOLICY_CONTACT_PROSPECT_ANONYMIZE_DELAY',
        'sql_template' => "SELECT c.rowid FROM "
          .$sanitized_prefix."socpeople as c INNER JOIN "
          .$sanitized_prefix."societe as s ON s.rowid = c.fk_soc WHERE c.entity = __ENTITY__ AND c.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND s.client = ".Societe::PROSPECT." AND s.fournisseur = 0 AND NOT EXISTS (SELECT a.id FROM "
          .$sanitized_prefix."actioncomm as a WHERE a.fk_contact = c.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM "
          .$sanitized_prefix."facture as f WHERE f.fk_soc = s.rowid)",
        'class' => 'Contact',
        'file' => DOL_DOCUMENT_ROOT . '/contact/class/contact.class.php',
        'anonymize_fields' => array('lastname' => 'MAKEANONYMOUS', 'firstname' => 'MAKEANONYMOUS', 'poste' => '---', 'address' => '---', 'town' => '---', 'zip' => '---', 'phone_pro' => '---', 'phone_perso' => '---', 'phone_mobile' => '---', 'email' => 'anonymous+__ID__@example.com', 'photo' => '', 'url' => '---', 'fax' => '---', 'socialnetworks' => [], 'geolat' => 0, 'geolong' => 0, 'ip' => '0.0.0.0'),
        'call_params' => array(
          'delete' => array('user'), // $object->delete($user)
          'update' => array('id', 'user') // $object->update($id, $user)
        )
      ),
      'contact_prospect_client' => array(
        'group' => 'Contact',
        'label_key' => 'DATAPOLICY_CONTACT_PROSPECT_CLIENT',
        'picto' => img_picto('', 'contact', 'class="pictofixedwidth"'),
        'const_delete' => '',
        'const_anonymize' => 'DATAPOLICY_CONTACT_PROSPECT_CLIENT_ANONYMIZE_DELAY',
        'sql_template' => "SELECT c.rowid FROM "
          .$sanitized_prefix."socpeople as c INNER JOIN "
          .$sanitized_prefix."societe as s ON s.rowid = c.fk_soc WHERE c.entity = __ENTITY__ AND c.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND s.client = ".Societe::CUSTOMER_AND_PROSPECT." AND s.fournisseur = 0 AND NOT EXISTS (SELECT a.id FROM "
          .$sanitized_prefix."actioncomm as a WHERE a.fk_contact = c.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM "
          .$sanitized_prefix."facture as f WHERE f.fk_soc = s.rowid)",
        'class' => 'Contact',
        'file' => DOL_DOCUMENT_ROOT . '/contact/class/contact.class.php',
        'anonymize_fields' => array('lastname' => 'MAKEANONYMOUS', 'firstname' => 'MAKEANONYMOUS', 'poste' => '---', 'address' => '---', 'town' => '---', 'zip' => '---', 'phone_pro' => '---', 'phone_perso' => '---', 'phone_mobile' => '---', 'email' => 'anonymous+__ID__@example.com', 'photo' => '', 'url' => '---', 'fax' => '---', 'socialnetworks' => [], 'geolat' => 0, 'geolong' => 0, 'ip' => '0.0.0.0'),
        'call_params' => array(
          'delete' => array('user'), // $object->delete($user)
          'update' => array('id', 'user') // $object->update($id, $user)
        )
      ),
      'contact_niprosp_niclient' => array(
        'group' => 'Contact',
        'label_key' => 'DATAPOLICY_CONTACT_NIPROSPECT_NICLIENT',
        'picto' => img_picto('', 'contact', 'class="pictofixedwidth"'),
        'const_delete' => '',
        'const_anonymize' => 'DATAPOLICY_CONTACT_NIPROSPECT_NICLIENT_ANONYMIZE_DELAY',
        'sql_template' => "SELECT c.rowid FROM "
          .$sanitized_prefix."socpeople as c INNER JOIN "
          .$sanitized_prefix."societe as s ON s.rowid = c.fk_soc WHERE c.entity = __ENTITY__ AND c.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND s.client = ".Societe::NO_CUSTOMER." AND s.fournisseur = 0 AND NOT EXISTS (SELECT a.id FROM "
          .$sanitized_prefix."actioncomm as a WHERE a.fk_contact = c.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM "
          .$sanitized_prefix."facture as f WHERE f.fk_soc = s.rowid)",
        'class' => 'Contact',
        'file' => DOL_DOCUMENT_ROOT . '/contact/class/contact.class.php',
        'anonymize_fields' => array('lastname' => 'MAKEANONYMOUS', 'firstname' => 'MAKEANONYMOUS', 'poste' => '---', 'address' => '---', 'town' => '---', 'zip' => '---', 'phone_pro' => '---', 'phone_perso' => '---', 'phone_mobile' => '---', 'email' => 'anonymous+__ID__@example.com', 'photo' => '', 'url' => '---', 'fax' => '---', 'socialnetworks' => [], 'geolat' => 0, 'geolong' => 0, 'ip' => '0.0.0.0'),
        'call_params' => array(
          'delete' => array('user'), // $object->delete($user)
          'update' => array('id', 'user') // $object->update($id, $user)
        )
      ),
      'contact_fournisseur' => array(
        'group' => 'Contact',
        'label_key' => 'DATAPOLICY_CONTACT_FOURNISSEUR',
        'picto' => img_picto('', 'contact', 'class="pictofixedwidth"'),
        'const_delete' => '',
        'const_anonymize' => 'DATAPOLICY_CONTACT_FOURNISSEUR_ANONYMIZE_DELAY',
        // Same as tiers_fournisseur above: a contact attached to a pure supplier
        // must be checked against llx_facture_fourn, not llx_facture (#38788).
        'sql_template' => "SELECT c.rowid FROM "
          .$sanitized_prefix."socpeople as c INNER JOIN "
          .$sanitized_prefix."societe as s ON s.rowid = c.fk_soc WHERE c.entity = __ENTITY__ AND c.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND s.fournisseur = 1 AND NOT EXISTS (SELECT a.id FROM "
          .$sanitized_prefix."actioncomm as a WHERE a.fk_contact = c.rowid AND a.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)) AND NOT EXISTS (SELECT f.rowid FROM "
          .$sanitized_prefix."facture_fourn as f WHERE f.fk_soc = s.rowid)",
        'class' => 'Contact',
        'file' => DOL_DOCUMENT_ROOT . '/contact/class/contact.class.php',
        'anonymize_fields' => array('lastname' => 'MAKEANONYMOUS', 'firstname' => 'MAKEANONYMOUS', 'poste' => '---', 'address' => '---', 'town' => '---', 'zip' => '---', 'phone_pro' => '---', 'phone_perso' => '---', 'phone_mobile' => '---', 'email' => 'anonymous+__ID__@example.com', 'photo' => '', 'url' => '---', 'fax' => '---', 'socialnetworks' => [], 'geolat' => 0, 'geolong' => 0, 'ip' => '0.0.0.0'),
        'call_params' => array(
          'delete' => array('user'), // $object->delete($user)
          'update' => array('id', 'user') // $object->update($id, $user)
        )
      )
    );
    if (isModEnabled('member')) {
      // --- Members ---  Reference date: datefin (end of membership validity).  tms (last modification) is intentionally NOT used here.
      $sqltemplate = "SELECT a.rowid FROM ".$sanitized_prefix."adherent as a WHERE a.entity = __ENTITY__ AND a.datefin < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH)";
      $sqltemplate .= " AND NOT EXISTS (SELECT ac.id FROM ".$sanitized_prefix."actioncomm as ac WHERE ac.fk_element = a.rowid AND ac.elementtype = 'member' AND ac.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH))";
      $sqltemplate .= " AND NOT EXISTS (SELECT s.rowid FROM ".$sanitized_prefix."subscription as s WHERE s.fk_adherent = a.rowid AND s.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH))";
 
      $arrayofpolicies['adherent'] = array(
        'group' => 'Member',
        'label_key' => 'DATAPOLICY_ADHERENT',
        'picto' => img_picto('', 'member', 'class="pictofixedwidth"'),
        'const_delete' => '',
        'const_anonymize' => 'DATAPOLICY_ADHERENT_ANONYMIZE_DELAY',
        'sql_template' => $sqltemplate,
        'class' => 'Adherent',
        'file' => DOL_DOCUMENT_ROOT . '/adherents/class/adherent.class.php',
        'anonymize_fields' => array(
          'lastname' => 'MAKEANONYMOUS', 'firstname' => 'MAKEANONYMOUS', 'societe' => '---', 'address' => '---', 'town' => '---', 'zip' => '---',
          'phone' => '---', 'phone_perso' => '---', 'phone_mobile' => '---', 'email' => 'anonymous+__ID__@example.com', 'birth' => dol_mktime(0, 0, 0, 1, 1, 1900),
          'photo' => '', 'url' => '---', 'fax' => '---', 'socialnetworks' => [], 'ip' => '0.0.0.0', 'note_private' => '---', 'note_public' => '---', 'statut' => 0
        ), // Force status to "canceled"
        'call_params' => array(
          'delete' => array('user'),   // $object->delete($user)
          'update' => array('user')    // $object->update($user)
        )
      );
    }
 
    if (isModEnabled('recruitment')) {
      // --- Recruitment ---
      $arrayofpolicies['recruitment_candidature'] = array(
        'group' => 'Recruitment',
        'label_key' => 'DATAPOLICY_RECRUITMENT_CANDIDATURE',
        'picto' => img_picto('', 'recruitmentcandidature', 'class="pictofixedwidth"'),
        'const_delete' => 'DATAPOLICY_RECRUITMENT_CANDIDATURE_DELETE_DELAY',
        'const_anonymize' => '', // Anonymization not applicable
        'sql_template_delete' => "SELECT c.rowid FROM ".$sanitized_prefix."recruitment_recruitmentcandidature as c WHERE c.entity = __ENTITY__ AND c.tms < DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH) AND NOT EXISTS (SELECT ac.id FROM ".$sanitized_prefix."actioncomm as ac WHERE ac.elementtype = 'recruitmentcandidature@recruitment' AND ac.fk_element = c.rowid AND ac.tms > DATE_SUB(__NOW__, INTERVAL __DELAY__ MONTH))",
        'class' => 'RecruitmentCandidature',
        'file' => DOL_DOCUMENT_ROOT . '/recruitment/class/recruitmentcandidature.class.php',
        'anonymize_fields' => array(),
        'call_params' => array(
          'delete' => array('user'),   // $object->delete($user)
          'update' => array('user')    // $object->update($user)
        )
      );
    }
 
    // TODO Allow an external module to add an entry into the array
 
 
    return $arrayofpolicies;
  }
 
  public function cleanDataForDataPolicy(): int
  {
    global $conf, $user;
 
    // Reset state properties for this specific execution run.
    $this->nbupdated = 0;
    $this->nbdeleted = 0;
    $this->errorCount = 0;
    $this->errorMessages = array();
 
    // Tracks record IDs that have been processed in this run to prevent duplicate actions (e.g., anonymizing a just-deleted record).
    $processedIds = array();
    // Caches object instances to avoid redundant 'new Class()' calls, improving performance.
    $objectInstances = array();
 
    // Retrieve the master list of all data policies. This separates configuration from execution.
    $dataPolicies = $this->getDataPolicies();
 
    $this->db->begin();
 
    // Iterate through each defined policy to apply its rules.
    foreach ($dataPolicies as $policy) {
      // Instantiate object only once per class type for efficiency.
      if (! isset($objectInstances[$policy['class']])) {
        require_once $policy['file'];
        $classtoinit = $policy['class'];
        $objectInstances[$policy['class']] = new $classtoinit($this->db);
      }
      $object = $objectInstances[$policy['class']];
 
      // Process actions.
      // ->errorCount, ->nbupdated and ->nbdelete will be set after that.
 
      // The order of operations is critical: deletion is always processed before anonymization.
      // This ensures that if a record meets criteria for both, it is deleted as the first and final action.
      $this->_processPolicyAction($policy, 'delete', $object, $processedIds, $conf, $user);
      // Now process anonymization
      $this->_processPolicyAction($policy, 'anonymize', $object, $processedIds, $conf, $user);
    }
 
    // Finalize the transaction based on the outcome of all operations.
    if (! $this->errorCount) {
      $this->db->commit();
      $this->output = $this->nbupdated . ' record(s) anonymized, ' . $this->nbdeleted . ' record(s) deleted.';
    } else {
      $this->db->rollback();
      $this->error = implode("\n", $this->errorMessages);
    }
 
    return $this->errorCount ? 1 : 0;
  }
 
  private function _processPolicyAction($policy, $action, $object, &$processedIds, $conf, $user)
  {
    $constName = $policy['const_' . $action] ?? null;
    $delay = $constName ? getDolGlobalInt($constName) : 0;
 
    if ($delay <= 0) {
      return;
    }
 
    // Prepare SQL query
    $sqlPlaceholders = array(
      '__ENTITY__' => (string) ((int) $conf->entity),
      '__DELAY__' => (string) ((int) $delay),
      '__NOW__' => "'" . $this->db->idate(dol_now()) . "'"
    );
    $sql = str_replace(array_keys($sqlPlaceholders), array_values($sqlPlaceholders), $policy['sql_template'.($action == 'delete' ? '_delete' : '')]);  // @phan-suppress-current-line SqlInjection
 
    $resql = $this->db->query($sql);
 
    if (! $resql) {
      $this->errorCount++;
      $this->errorMessages[] = 'Error executing ' . $action . ' query for policy ' . $constName . ': ' . $this->db->lasterror();
 
      return;
    }
 
    // Define the handler method for the action
    $handlerMethod = '_handle' . ucfirst($action);
 
    // Process the records found by the query
    while ($obj = $this->db->fetch_object($resql)) {
      if (in_array($obj->rowid, $processedIds) || ! method_exists($this, $handlerMethod)) {
        continue;
      }
      $object = clone $object;
      $object->fetch($obj->rowid);
 
      // isObjectUsed() is a referential-integrity guard for deletion (cannot drop a
      // thirdparty that still has quotes/orders/contracts pointing at it). Anonymization
      // must still be allowed: personal data has to be erasable even when commercial
      // documents from the retention period are kept (#38786).
      if ($action === 'delete' && !empty($object->childtables) && method_exists($object, 'isObjectUsed') && $object->isObjectUsed() != 0) {
        continue; // Not an error, just skipping.
      }
 
      // Dynamically call the appropriate handler (_handleDelete or _handleAnonymize)
      $result = $this->$handlerMethod($object, $user, $policy);
 
      // Record the outcome and add to processed list on success
      $this->_recordActionResult($result, $object, $action);
      $processedIds[] = $obj->rowid;
    }
  }
 
  private function _handleDelete($object, $user, $policy): int
  {
    $callArgs = $this->_buildCallArguments($object, $user, $policy, 'delete');
 
    return $object->delete(...$callArgs);
  }
 
  private function _handleAnonymize($object, $user, $policy): int
  {
    foreach ($policy['anonymize_fields'] as $field => $val) {
      if ($val == 'MAKEANONYMOUS') {
        // For each field with rule "MAKEANONYMOUS, set the new value, keeping the ID.
        $object->$field = $field . '-anon-' . $object->id;
      } else {
        // For others, force the value, but only if not already empty.
        if (!empty($object->$field)) {
          $newval = str_replace('__ID__', $object->id ? (string) $object->id : '0', $val);
          $object->$field = $newval;
        }
      }
    }
 
    $this->_anonymizeExtraFields($object);
 
    $callArgs = $this->_buildCallArguments($object, $user, $policy, 'update');
 
    $result = $object->update(...$callArgs);
 
    if ($result > 0) {
      $object->insertExtraFields();
    }
 
    return $result;
  }
 
  private function _anonymizeExtraFields($object)
  {
    if (empty($object->table_element)) {
      return;
    }
 
    // Retrieve extra fields definitions flagged as personal data for this object type
    $sql = "SELECT ef.name, ef.type";
    $sql .= " FROM " . $this->db->prefix() . "extrafields as ef";
    $sql .= " WHERE ef.elementtype = '" . $this->db->escape($object->table_element) . "'";
    $sql .= " AND ef.personal_data = 1";
    $sql .= " AND ef.entity IN (0, " . (int) (isset($GLOBALS['conf']) ? $GLOBALS['conf']->entity : 1) . ")";
 
    $resql = $this->db->query($sql);
 
    if (!$resql) {
      $this->errorCount++;
      $this->errorMessages[] = 'Error fetching personal extra fields for ' . $object->table_element . ': ' . $this->db->lasterror();
      return;
    }
 
    while ($efObj = $this->db->fetch_object($resql)) {
      $fieldName = $efObj->name;
      $fieldType = $efObj->type;
 
      // Extra field values are stored in $object->array_options with key 'options_<name>'
      $optionKey = 'options_' . $fieldName;
 
      if (!isset($object->array_options[$optionKey])) {
        continue;
      }
 
      if (empty($object->array_options[$optionKey])) {
        continue;
      }
 
      if (in_array($fieldType, array('multiselect', 'checkbox'))) {
        $object->array_options[$optionKey] = array(); // Default: treat as array
      } elseif (in_array($fieldType, array('boolean', 'radio'))) {
        $object->array_options[$optionKey] = '0'; // Default: treat as boolean
      } elseif (in_array($fieldType, array('date', 'datetime', 'timestamp'))) {
        $object->array_options[$optionKey] = dol_mktime(0, 0, 0, 1, 1, 1900); // Default: treat as timestamp
      } elseif (in_array($fieldType, array('int', 'double', 'price', 'stars'))) {
        $object->array_options[$optionKey] = 0; // Default: treat as numeric
      } else {
        $object->array_options[$optionKey] = '---'; // Default: treat as varchar/text
      }
    }
  }
 
  private function _buildCallArguments($object, $user, $policy, $method)
  {
    $availableArgs = array(
      'id' => $object->id,
      'user' => $user
    );
 
    $paramConfig = $policy['call_params'][$method] ?? [];
 
    return array_map(
      static function (string $paramName) use ($availableArgs) {
        return $availableArgs[$paramName];
      },
      $paramConfig
    );
  }
 
  private function _recordActionResult($result, $object, $action)
  {
    if ($result < 0) {
      $this->errorCount++;
      $this->errorMessages[] = 'Failed to ' . $action . ' record ID ' . $object->id . ' from class ' . get_class($object) . '. Error: ' . $object->errorsToString();
    } else {
      if ($action === 'delete') {
        $this->nbdeleted++;
      } elseif ($action === 'anonymize') {
        // Only count as updated if the update method returns a positive result
        $this->nbupdated++;
      }
    }
  }
}