* Copyright (C) 2015-2025 Alexandre Spangaro * Copyright (C) 2015-2020 Florian Henry * Copyright (C) 2018-2025 Frédéric France * Copyright (C) 2024-2025 MDW * Copyright (C) 2024 Jose MARTINEZ * Copyright (C) 2025 Nicolas Barrouillet * * 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 . */ /** * \file htdocs/accountancy/class/bookkeeping.class.php * \ingroup Accountancy (Double entries) * \brief File of class to manage Ledger (General Ledger and Subledger) */ // Class require_once DOL_DOCUMENT_ROOT.'/core/class/commonobject.class.php'; require_once DOL_DOCUMENT_ROOT.'/core/class/commonobjectline.class.php'; require_once DOL_DOCUMENT_ROOT.'/core/class/fiscalyear.class.php'; require_once DOL_DOCUMENT_ROOT.'/accountancy/class/accountingjournal.class.php'; require_once DOL_DOCUMENT_ROOT.'/accountancy/class/accountingaccount.class.php'; /** * Class to manage Ledger (General Ledger and Subledger) */ class BookKeeping extends CommonObject { /** * @var string Id to identify managed objects */ public $element = 'accountingbookkeeping'; /** * @var string Name of table without prefix where object is stored */ public $table_element = 'accounting_bookkeeping'; /** * @var BookKeepingLine[] Lines */ public $lines = array(); /** * @var int ID */ public $id; /** * @var int Date of source document, in db date NOT NULL */ public $doc_date; /** * @var int|null|'' Deadline for payment */ public $date_lim_reglement; /** * @var ?string Doc type */ public $doc_type; /** * @var ?string Doc ref */ public $doc_ref; /** * @var ?int ID */ public $fk_doc; /** * @var ?int ID */ public $fk_docdet; /** * @var ?string Thirdparty code */ public $thirdparty_code; /** * @var string|null Subledger account */ public $subledger_account; /** * @var string|null Subledger label */ public $subledger_label; /** * @var ?string doc_type */ public $numero_compte; /** * @var ?string label compte */ public $label_compte; /** * @var ?string label operation */ public $label_operation; /** * @var ?float FEC:Debit */ public $debit; /** * @var ?float FEC:Credit */ public $credit; /** * @var ?float FEC:Amount (Not necessary) * @deprecated No more used (we have info into debit/credit and sens) */ public $montant; /** * @var ?float FEC:Amount (Not necessary) * @deprecated No more used (we have info into debit/credit and sens) */ public $amount; /** * @var ?string FEC:Sens (Not necessary) */ public $sens; /** * @var ?int ID */ public $fk_user_author; /** * @var ?string key for import */ public $import_key; /** * @var ?string code journal */ public $code_journal; /** * @var ?string label journal */ public $journal_label; /** * @var ?int accounting transaction id */ public $piece_num; /** * @var string accounting transaction dolibarr ref */ public $ref; /** * @var BookKeepingLine[] Movement line array */ public $linesmvt = array(); /** * @var BookKeepingLine[] export line array */ public $linesexport = array(); /** * @var int|string date of movement who are noticed like exported */ public $date_export; /** * @var string String with name of icon for myobject. Must be the part after the 'object_' into object_myobject.png */ public $picto = 'generic'; /** * @var string[] SQL filter used for check if the bookkeeping record can be created/inserted/modified/deleted (cached) */ public static $can_modify_bookkeeping_sql_cached; /** * @var string[] Array of warnings */ public $warnings = array(); /** * Constructor * * @param DoliDB $db Database handler */ public function __construct(DoliDB $db) { $this->db = $db; } /** * Create object into database * * @param User $user User that creates * @param int $notrigger false=launch triggers after, true=disable triggers * @return int Return integer <0 if KO, Id of created object if OK */ public function create(User $user, $notrigger = 0) { global $conf, $langs; dol_syslog(__METHOD__, LOG_DEBUG); $error = 0; // Clean parameters if (isset($this->doc_type)) { $this->doc_type = trim($this->doc_type); } if (isset($this->doc_ref)) { $this->doc_ref = trim($this->doc_ref); $this->doc_ref = dol_trunc($this->doc_ref, 300); // We limit to 300 chars to avoid problems with too long ref in DB } if (isset($this->fk_doc)) { $this->fk_doc = (int) $this->fk_doc; } if (isset($this->fk_docdet)) { $this->fk_docdet = (int) $this->fk_docdet; } if (isset($this->thirdparty_code)) { $this->thirdparty_code = trim($this->thirdparty_code); } if (isset($this->subledger_account)) { $this->subledger_account = trim($this->subledger_account); } if (isset($this->subledger_label)) { $this->subledger_label = trim($this->subledger_label); } if (isset($this->numero_compte)) { $this->numero_compte = trim($this->numero_compte); } if (isset($this->label_compte)) { $this->label_compte = trim($this->label_compte); } if (isset($this->label_operation)) { $this->label_operation = trim($this->label_operation); } if (isset($this->debit)) { $this->debit = (float) $this->debit; } if (isset($this->credit)) { $this->credit = (float) $this->credit; } if (isset($this->montant)) { $this->montant = (float) $this->montant; } if (isset($this->amount)) { $this->amount = (float) $this->amount; } if (isset($this->sens)) { $this->sens = trim($this->sens); } if (isset($this->import_key)) { $this->import_key = trim($this->import_key); } if (isset($this->code_journal)) { $this->code_journal = trim($this->code_journal); } if (isset($this->journal_label)) { $this->journal_label = trim($this->journal_label); } if (isset($this->piece_num)) { $this->piece_num = (int) $this->piece_num; } if (empty($this->debit)) { $this->debit = 0.0; } if (empty($this->credit)) { $this->credit = 0.0; } $result = $this->validBookkeepingDate($this->doc_date); // Check date according to ACCOUNTANCY_FISCAL_PERIOD_MODE. if ($result < 0) { return -1; } elseif ($result == 0) { if (getDolGlobalString('ACCOUNTANCY_FISCAL_PERIOD_MODE') == 'blockedonclosed') { $this->errors[] = $langs->trans('ErrorBookkeepingDocDateIsOnAClosedFiscalPeriod'); } else { $this->errors[] = $langs->trans('ErrorBookkeepingDocDateNotOnActiveFiscalPeriod'); } return -1; } // Check parameters if (($this->numero_compte == "") || $this->numero_compte == '-1' || $this->numero_compte == 'NotDefined') { $langs->loadLangs(array("errors")); if (in_array($this->doc_type, array('bank', 'expense_report'))) { $this->errors[] = $langs->trans('ErrorFieldAccountNotDefinedForBankLine', $this->fk_docdet, $this->doc_type); } else { //$this->errors[]=$langs->trans('ErrorFieldAccountNotDefinedForInvoiceLine', $this->doc_ref, $this->label_compte); $mesg = $this->doc_ref.', '.$langs->trans("AccountAccounting").': '.($this->numero_compte != -1 ? $this->numero_compte : $langs->trans("Unknown")); if ($this->subledger_account && $this->subledger_account != $this->numero_compte) { $mesg .= ', '.$langs->trans("SubledgerAccount").': '.$this->subledger_account; } $this->errors[] = $langs->trans('ErrorFieldAccountNotDefinedForLine', $mesg); } return -1; } $this->db->begin(); $this->piece_num = 0; $this->ref = ''; // First check if line not yet already in bookkeeping. // Note that we must include 'doc_type - fk_doc - numero_compte - label - subledger_account (if not empty)' to be sure to have unicity of line (because we may have several lines // with same doc_type, fk_doc, numero_compte for 1 invoice line when using localtaxes with same account) // WARNING: This is not reliable, label may have been modified. This is just a small protection. // The page that make transfer make the test on couple (doc_type - fk_doc) only. $sql = "SELECT count(*) as nb"; $sql .= " FROM ".$this->db->prefix().$this->table_element; $sql .= " WHERE doc_type = '".$this->db->escape($this->doc_type)."'"; $sql .= " AND fk_doc = ".((int) $this->fk_doc); if (getDolGlobalString('ACCOUNTANCY_ENABLE_FKDOCDET')) { // DO NOT USE THIS IN PRODUCTION. This will generate a lot of trouble into reports and will corrupt database (by generating duplicate entries. $sql .= " AND fk_docdet = ".((int) $this->fk_docdet); // This field can be 0 if record is for several lines } $sql .= " AND numero_compte = '".$this->db->escape($this->numero_compte)."'"; $sql .= " AND label_operation = '".$this->db->escape($this->label_operation)."'"; if (!empty($this->subledger_account)) { $sql .= " AND subledger_account = '".$this->db->escape($this->subledger_account)."'"; } $sql .= " AND entity = ".$conf->entity; // Do not use getEntity for accounting features $resql = $this->db->query($sql); if ($resql) { $row = $this->db->fetch_object($resql); if ($row->nb == 0) { // Not already into bookkeeping // Check to know if piece_num already exists for data we try to insert to reuse the same value $sqlnum = "SELECT piece_num, ref"; $sqlnum .= " FROM ".$this->db->prefix().$this->table_element; $sqlnum .= " WHERE doc_type = '".$this->db->escape($this->doc_type)."'"; // For example doc_type = 'bank' $sqlnum .= " AND fk_doc = ".((int) $this->fk_doc); if (getDolGlobalString('ACCOUNTANCY_ENABLE_FKDOCDET')) { // fk_docdet is rowid into llx_bank or llx_facturedet or llx_facturefourndet, or ... $sqlnum .= " AND fk_docdet = ".((int) $this->fk_docdet); } $sqlnum .= " AND doc_ref = '".$this->db->escape($this->doc_ref)."'"; // ref of source object $sqlnum .= " AND entity = ".$conf->entity; // Do not use getEntity for accounting features dol_syslog(get_class($this).":: create sqlnum=".$sqlnum, LOG_DEBUG); $resqlnum = $this->db->query($sqlnum); if ($resqlnum) { $num = $this->db->num_rows($resqlnum); if ($num > 0) { $objnum = $this->db->fetch_object($resqlnum); $this->piece_num = $objnum->piece_num; $this->ref = $objnum->ref; } else { $this->piece_num = 0; $this->ref = ''; } } dol_syslog(get_class($this)."::create this->piece_num=".$this->piece_num, LOG_DEBUG); if (empty($this->piece_num)) { $sqlnum = "SELECT MAX(piece_num)+1 as maxpiecenum"; $sqlnum .= " FROM ".$this->db->prefix().$this->table_element; $sqlnum .= " WHERE entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features $resqlnum = $this->db->query($sqlnum); if ($resqlnum) { $objnum = $this->db->fetch_object($resqlnum); $this->piece_num = $objnum->maxpiecenum; } $this->ref = $this->getNextNumRef(); dol_syslog(get_class($this).":: create now this->piece_num={$this->piece_num}, this->ref={$this->ref}", LOG_DEBUG); } if (empty($this->piece_num)) { $this->piece_num = 1; } $now = dol_now(); $sql = "INSERT INTO ".$this->db->prefix().$this->table_element." ("; $sql .= "doc_date"; $sql .= ", date_lim_reglement"; $sql .= ", doc_type"; $sql .= ", doc_ref"; $sql .= ", fk_doc"; $sql .= ", fk_docdet"; $sql .= ", thirdparty_code"; $sql .= ", subledger_account"; $sql .= ", subledger_label"; $sql .= ", numero_compte"; $sql .= ", label_compte"; $sql .= ", label_operation"; $sql .= ", debit"; $sql .= ", credit"; $sql .= ", montant"; $sql .= ", sens"; $sql .= ", fk_user_author"; $sql .= ", date_creation"; $sql .= ", code_journal"; $sql .= ", journal_label"; $sql .= ", piece_num"; $sql .= ", ref"; $sql .= ', entity'; $sql .= ") VALUES ("; $sql .= "'".$this->db->idate($this->doc_date)."'"; $sql .= ", ".(isDolTms($this->date_lim_reglement) ? "'".$this->db->idate($this->date_lim_reglement)."'" : 'NULL'); $sql .= ", '".$this->db->escape($this->doc_type)."'"; $sql .= ", '".$this->db->escape($this->doc_ref)."'"; $sql .= ", ".((int) $this->fk_doc); $sql .= ", ".((int) $this->fk_docdet); $sql .= ", ".(!empty($this->thirdparty_code) ? ("'".$this->db->escape($this->thirdparty_code)."'") : "NULL"); $sql .= ", ".(!empty($this->subledger_account) ? ("'".$this->db->escape($this->subledger_account)."'") : "NULL"); $sql .= ", ".(!empty($this->subledger_label) ? ("'".$this->db->escape($this->subledger_label)."'") : "NULL"); $sql .= ", '".$this->db->escape($this->numero_compte)."'"; $sql .= ", ".(!empty($this->label_compte) ? ("'".$this->db->escape($this->label_compte)."'") : "NULL"); $sql .= ", '".$this->db->escape($this->label_operation)."'"; $sql .= ", ".((float) $this->debit); $sql .= ", ".((float) $this->credit); $sql .= ", ".((float) $this->montant); $sql .= ", ".(!empty($this->sens) ? ("'".$this->db->escape($this->sens)."'") : "NULL"); $sql .= ", '".$this->db->escape((string) $this->fk_user_author)."'"; $sql .= ", '".$this->db->idate($now)."'"; $sql .= ", '".$this->db->escape($this->code_journal)."'"; $sql .= ", ".(!empty($this->journal_label) ? ("'".$this->db->escape($this->journal_label)."'") : "NULL"); $sql .= ", ".((int) $this->piece_num); $sql .= ", '".$this->db->escape($this->ref)."'"; $sql .= ", ".(!isset($this->entity) ? $conf->entity : $this->entity); $sql .= ")"; $resql = $this->db->query($sql); if ($resql) { $id = $this->db->last_insert_id($this->db->prefix().$this->table_element); if ($id > 0) { $this->id = $id; $result = 0; } else { $result = -2; $error++; $this->errors[] = 'Error Create Error '.$result.' lecture ID'; dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } } else { $result = -1; $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } } else { // Already exists $result = -3; $error++; $this->error = 'BookkeepingRecordAlreadyExists'; dol_syslog(__METHOD__.' '.$this->error, LOG_WARNING); } } else { $result = -5; $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } // Call triggers if (! $error && ! $notrigger) { $result = $this->call_trigger('BOOKKEEPING_CREATE', $user); if ($result < 0) { $error++; } } // Commit or rollback if ($error) { $this->db->rollback(); return -1 * $error; } else { $this->db->commit(); return $result; } } /** * Create a line in database from values as parameters * * @param int $doc_date Date of source document, in db date NOT NULL * @param string $doc_ref Doc ref * @param string $doc_type Doc type * @param int $fk_doc Doc id * @param int $fk_docdet Doc line id * @param string $numero_compte Account number * @param string $label_compte Account label * @param string $label_operation Operation label * @param double $amount Amount * @param string $code_journal Journal code * @param string $journal_label Journal label * @param string $subledger_account Sub ledger account * @return int Return integer <0 if KO, O nothing done, created object id if OK */ public function createFromValues($doc_date, $doc_ref, $doc_type, $fk_doc, $fk_docdet, $numero_compte, $label_compte, $label_operation, $amount, $code_journal, $journal_label, $subledger_account) { global $conf, $langs, $user; $result = 0; if (!empty($amount)) { $this->doc_date = $doc_date; $this->doc_ref = $doc_ref; $this->doc_type = $doc_type; $this->fk_doc = $fk_doc; $this->fk_docdet = $fk_docdet; $this->numero_compte = $numero_compte; $this->label_compte = $label_compte; $this->label_operation = $label_operation; $this->subledger_account = $subledger_account; $this->montant = $amount; $this->sens = ($amount >= 0) ? 'D' : 'C'; $this->debit = ($amount >= 0 ? $amount : 0); $this->credit = ($amount < 0 ? -$amount : 0); $this->code_journal = $code_journal; $this->journal_label = $journal_label; $this->fk_user_author = $user->id; $this->entity = $conf->entity; $result = $this->create($user); if ($result < 0) { if ($this->error == 'BookkeepingRecordAlreadyExists') { $warning = $langs->trans('WarningBookkeepingRecordAlreadyExists', $this->doc_type, $this->fk_doc, $this->fk_docdet); $this->warnings[] = $warning; dol_syslog(__METHOD__.' '.$warning, LOG_WARNING); } else { dol_syslog(__METHOD__.' '.$this->errorsToString(), LOG_ERR); } } } return $result; } /** * Return a link to the object card (with optionally the picto) * * @param int $withpicto Include picto in link (0=No picto, 1=Include picto into link, 2=Only picto) * @param string $option On what the link point to ('nolink', ...) * @param int $notooltip 1=Disable tooltip * @param string $morecss Add more css on link * @param int $save_lastsearch_value -1=Auto, 0=No save of lastsearch_values when clicking, 1=Save lastsearch_values whenclicking * @return string String with URL */ public function getNomUrl($withpicto = 0, $option = '', $notooltip = 0, $morecss = '', $save_lastsearch_value = -1) { global $db, $conf, $langs; global $dolibarr_main_authentication, $dolibarr_main_demo; global $menumanager, $hookmanager; if (!empty($conf->dol_no_mouse_hover)) { $notooltip = 1; // Force disable tooltips } $result = ''; $companylink = ''; $label = ''.$langs->trans("Transaction").''; $label .= '
'; $label .= ''.$langs->trans('NumberingShort').': '.$this->piece_num; $label .= '
'; $label .= ''.$langs->trans('Ref').': '.$this->ref; $url = DOL_URL_ROOT.'/accountancy/bookkeeping/card.php?piece_num='.$this->piece_num; if ($option != 'nolink') { // Add param to save lastsearch_values or not $add_save_lastsearch_values = ($save_lastsearch_value == 1 ? 1 : 0); if ($save_lastsearch_value == -1 && isset($_SERVER["PHP_SELF"]) && preg_match('/list\.php/', $_SERVER["PHP_SELF"])) { $add_save_lastsearch_values = 1; } if ($add_save_lastsearch_values) { $url .= '&save_lastsearch_values=1'; } } $linkclose = ''; if (empty($notooltip)) { if (getDolGlobalString('MAIN_OPTIMIZEFORTEXTBROWSER')) { $label = $langs->trans("ShowTransaction"); $linkclose .= ' alt="'.dolPrintHTMLForAttribute($label).'"'; } $linkclose .= ' title="'.dolPrintHTMLForAttribute($label).'"'; $linkclose .= ' class="classfortooltip'.($morecss ? ' '.$morecss : '').'"'; } else { $linkclose = ($morecss ? ' class="'.$morecss.'"' : ''); } $linkstart = ''; $linkend = ''; $result .= $linkstart; if ($withpicto) { $result .= img_object(($notooltip ? '' : $label), ($this->picto ? $this->picto : 'generic'), ($notooltip ? (($withpicto != 2) ? 'class="paddingright"' : '') : 'class="'.(($withpicto != 2) ? 'paddingright ' : '').'classfortooltip"'), 0, 0, $notooltip ? 0 : 1); } if ($withpicto != 2) { $result .= $this->piece_num; } $result .= $linkend; //if ($withpicto != 2) $result.=(($addlabel && $this->label) ? $sep . dol_trunc($this->label, ($addlabel > 1 ? $addlabel : 0)) : ''); global $action; $hookmanager->initHooks(array($this->element . 'dao')); $parameters = array('id' => $this->id, 'getnomurl' => &$result); $reshook = $hookmanager->executeHooks('getNomUrl', $parameters, $this, $action); // Note that $action and $object may have been modified by some hooks if ($reshook > 0) { $result = $hookmanager->resPrint; } else { $result .= $hookmanager->resPrint; } return $result; } /** * Create object into database * * @param User $user User that creates * @param int $notrigger false=launch triggers after, true=disable triggers * @param string $mode Mode * @return int Return integer <0 if KO, Id of created object if OK */ public function createStd(User $user, $notrigger = 0, $mode = '') { global $conf, $langs; $langs->loadLangs(array("accountancy", "bills", "compta")); dol_syslog(__METHOD__, LOG_DEBUG); $error = 0; // Clean parameters if (isset($this->doc_type)) { $this->doc_type = trim($this->doc_type); } if (isset($this->doc_ref)) { $this->doc_ref = trim($this->doc_ref); } if (isset($this->fk_doc)) { $this->fk_doc = (int) $this->fk_doc; } if (isset($this->fk_docdet)) { $this->fk_docdet = (int) $this->fk_docdet; } if (isset($this->thirdparty_code)) { $this->thirdparty_code = trim($this->thirdparty_code); } if (isset($this->subledger_account)) { $this->subledger_account = trim($this->subledger_account); } if (isset($this->subledger_label)) { $this->subledger_label = trim($this->subledger_label); } if (isset($this->numero_compte)) { $this->numero_compte = trim($this->numero_compte); } if (isset($this->label_compte)) { $this->label_compte = trim($this->label_compte); } if (isset($this->label_operation)) { $this->label_operation = trim($this->label_operation); } if (isset($this->sens)) { $this->sens = trim($this->sens); } if (isset($this->import_key)) { $this->import_key = trim($this->import_key); } if (isset($this->code_journal)) { $this->code_journal = trim($this->code_journal); } if (isset($this->journal_label)) { $this->journal_label = trim($this->journal_label); } if (isset($this->piece_num)) { $this->piece_num = (int) $this->piece_num; } if (empty($this->debit)) { $this->debit = 0; } if (empty($this->credit)) { $this->credit = 0; } if (empty($this->montant)) { $this->montant = 0; } $result = $this->validBookkeepingDate($this->doc_date); if ($result < 0) { return -1; } elseif ($result == 0) { if (getDolGlobalString('ACCOUNTANCY_FISCAL_PERIOD_MODE') == 'blockedonclosed') { $this->errors[] = $langs->trans('ErrorBookkeepingDocDateIsOnAClosedFiscalPeriod'); } else { $this->errors[] = $langs->trans('ErrorBookkeepingDocDateNotOnActiveFiscalPeriod'); } return -1; } $this->debit = (float) price2num($this->debit, 'MT'); $this->credit = (float) price2num($this->credit, 'MT'); $this->montant = (float) price2num($this->montant, 'MT'); $now = dol_now(); // Check parameters $this->journal_label = $langs->trans($this->journal_label); // Insert request $sql = 'INSERT INTO '.$this->db->prefix().$this->table_element.$mode.' ('; $sql .= 'doc_date,'; $sql .= 'date_lim_reglement,'; $sql .= 'doc_type,'; $sql .= 'doc_ref,'; $sql .= 'fk_doc,'; $sql .= 'fk_docdet,'; $sql .= 'thirdparty_code,'; $sql .= 'subledger_account,'; $sql .= 'subledger_label,'; $sql .= 'numero_compte,'; $sql .= 'label_compte,'; $sql .= 'label_operation,'; $sql .= 'debit,'; $sql .= 'credit,'; $sql .= 'montant,'; $sql .= 'sens,'; $sql .= 'fk_user_author,'; $sql .= 'date_creation,'; $sql .= 'code_journal,'; $sql .= 'journal_label,'; $sql .= 'piece_num,'; $sql .= 'ref,'; $sql .= 'entity'; $sql .= ') VALUES ('; $sql .= ' '.(isDolTms($this->doc_date) ? "'".$this->db->idate($this->doc_date)."'" : 'NULL').','; $sql .= ' '.(isDolTms($this->date_lim_reglement) ? "'".$this->db->idate($this->date_lim_reglement)."'" : 'NULL').','; $sql .= ' '.(!isset($this->doc_type) ? 'NULL' : "'".$this->db->escape($this->doc_type)."'").','; $sql .= ' '.(!isset($this->doc_ref) ? 'NULL' : "'".$this->db->escape($this->doc_ref)."'").','; $sql .= ' '.(empty($this->fk_doc) ? '0' : (int) $this->fk_doc).','; $sql .= ' '.(empty($this->fk_docdet) ? '0' : (int) $this->fk_docdet).','; $sql .= ' '.(!isset($this->thirdparty_code) ? 'NULL' : "'".$this->db->escape($this->thirdparty_code)."'").','; $sql .= ' '.(!isset($this->subledger_account) ? 'NULL' : "'".$this->db->escape($this->subledger_account)."'").','; $sql .= ' '.(!isset($this->subledger_label) ? 'NULL' : "'".$this->db->escape($this->subledger_label)."'").','; $sql .= ' '.(!isset($this->numero_compte) ? 'NULL' : "'".$this->db->escape($this->numero_compte)."'").','; $sql .= ' '.(!isset($this->label_compte) ? 'NULL' : "'".$this->db->escape($this->label_compte)."'").','; $sql .= ' '.(!isset($this->label_operation) ? 'NULL' : "'".$this->db->escape($this->label_operation)."'").','; $sql .= ' '.(!isset($this->debit) ? 'NULL' : $this->debit).','; $sql .= ' '.(!isset($this->credit) ? 'NULL' : $this->credit).','; $sql .= ' '.(!isset($this->montant) ? 'NULL' : $this->montant).','; $sql .= ' '.(!isset($this->sens) ? 'NULL' : "'".$this->db->escape($this->sens)."'").','; $sql .= ' '.((int) $user->id).','; $sql .= ' '."'".$this->db->idate($now)."',"; $sql .= ' '.(empty($this->code_journal) ? 'NULL' : "'".$this->db->escape($this->code_journal)."'").','; $sql .= ' '.(empty($this->journal_label) ? 'NULL' : "'".$this->db->escape($this->journal_label)."'").','; $sql .= ' '.(empty($this->piece_num) ? 'NULL' : $this->db->escape((string) $this->piece_num)).','; $sql .= ' '.(empty($this->ref) ? "''" : "'".$this->db->escape($this->ref)."'").','; $sql .= ' '.(!isset($this->entity) ? $conf->entity : $this->entity); $sql .= ')'; $this->db->begin(); $resql = $this->db->query($sql); if (!$resql) { $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } if (!$error) { $this->id = $this->db->last_insert_id($this->db->prefix().$this->table_element.$mode); // Call triggers if (! $notrigger) { $result = $this->call_trigger('BOOKKEEPING_CREATE', $user); if ($result < 0) { $error++; } } } // Commit or rollback if ($error) { $this->db->rollback(); return -1 * $error; } else { $this->db->commit(); return $this->id; } } /** * Load object in memory from the database * * @param int $id Id object * @param string|null $ref Ref * @param string $mode Mode ('' or 'tmp_') * @return int Return integer <0 if KO, 0 if not found, >0 if OK */ public function fetch($id, $ref = null, $mode = '') { global $conf; dol_syslog(__METHOD__, LOG_DEBUG); $sql = 'SELECT'; $sql .= ' t.rowid,'; $sql .= " t.doc_date,"; $sql .= " t.date_lim_reglement,"; $sql .= " t.doc_type,"; $sql .= " t.doc_ref,"; $sql .= " t.fk_doc,"; $sql .= " t.fk_docdet,"; $sql .= " t.thirdparty_code,"; $sql .= " t.subledger_account,"; $sql .= " t.subledger_label,"; $sql .= " t.numero_compte,"; $sql .= " t.label_compte,"; $sql .= " t.label_operation,"; $sql .= " t.debit,"; $sql .= " t.credit,"; $sql .= " t.montant as amount,"; $sql .= " t.sens,"; $sql .= " t.fk_user_author,"; $sql .= " t.import_key,"; $sql .= " t.code_journal,"; $sql .= " t.journal_label,"; $sql .= " t.piece_num,"; $sql .= " t.ref,"; $sql .= " t.date_creation,"; // In llx_accounting_bookkeeping_tmp, date_export if (!$mode) { $sql .= " t.date_export,"; } $sql .= " t.date_validated as date_validation"; $sql .= ' FROM '.$this->db->prefix().$this->table_element.$mode.' as t'; $sql .= ' WHERE 1 = 1'; $sql .= " AND entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features if (null !== $ref) { $sql .= " AND t.rowid = ".((int) $ref); } else { $sql .= " AND t.rowid = ".((int) $id); } $resql = $this->db->query($sql); if ($resql) { $numrows = $this->db->num_rows($resql); if ($numrows) { $obj = $this->db->fetch_object($resql); $this->id = $obj->rowid; $this->doc_date = $this->db->jdate($obj->doc_date); $this->date_lim_reglement = $this->db->jdate($obj->date_lim_reglement); $this->doc_type = $obj->doc_type; $this->doc_ref = $obj->doc_ref; $this->fk_doc = $obj->fk_doc; $this->fk_docdet = $obj->fk_docdet; $this->thirdparty_code = $obj->thirdparty_code; $this->subledger_account = $obj->subledger_account; $this->subledger_label = $obj->subledger_label; $this->numero_compte = $obj->numero_compte; $this->label_compte = $obj->label_compte; $this->label_operation = $obj->label_operation; $this->debit = $obj->debit; $this->credit = $obj->credit; $this->montant = $obj->amount; $this->amount = $obj->amount; $this->sens = $obj->sens; $this->fk_user_author = $obj->fk_user_author; $this->import_key = $obj->import_key; $this->code_journal = $obj->code_journal; $this->journal_label = $obj->journal_label; $this->piece_num = $obj->piece_num; $this->date_creation = $this->db->jdate($obj->date_creation); if (!$mode) { $this->date_export = $this->db->jdate($obj->date_export); } $this->ref = $obj->ref; $this->date_validation = isset($obj->date_validation) ? $this->db->jdate($obj->date_validation) : ''; } $this->db->free($resql); if ($numrows) { return 1; } else { return 0; } } else { $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); return -1; } } /** * Load object in memory from the database in ->lines. Or just make a simple count if $countonly=1. * * @param string $sortorder Sort Order * @param string $sortfield Sort field * @param int $limit limit * @param int $offset offset limit * @param array $filter filter array * @param string $filtermode filter mode (AND or OR) * @param int $option option (0: general account or 1: subaccount) * @param int $countonly Do not fill the $object->lines, return only the count. * @return int Return integer <0 if KO, Number of lines if OK */ public function fetchAllByAccount($sortorder = '', $sortfield = '', $limit = 0, $offset = 0, array $filter = array(), $filtermode = 'AND', $option = 0, $countonly = 0) { global $conf; dol_syslog(__METHOD__, LOG_DEBUG); $this->lines = array(); $num = 0; $sql = 'SELECT'; if ($countonly) { $sql .= ' COUNT(t.rowid) as nb'; } else { $sql .= ' t.rowid,'; $sql .= " t.doc_date,"; $sql .= " t.doc_type,"; $sql .= " t.doc_ref,"; $sql .= " t.fk_doc,"; $sql .= " t.fk_docdet,"; $sql .= " t.thirdparty_code,"; $sql .= " t.subledger_account,"; $sql .= " t.subledger_label,"; $sql .= " t.numero_compte,"; $sql .= " t.label_compte,"; $sql .= " t.label_operation,"; $sql .= " t.debit,"; $sql .= " t.credit,"; $sql .= " t.montant as amount,"; $sql .= " t.sens,"; $sql .= " t.multicurrency_amount,"; $sql .= " t.multicurrency_code,"; $sql .= " t.lettering_code,"; $sql .= " t.date_lettering,"; $sql .= " t.fk_user_author,"; $sql .= " t.import_key,"; $sql .= " t.code_journal,"; $sql .= " t.journal_label,"; $sql .= " t.piece_num,"; $sql .= " t.ref,"; $sql .= " t.date_creation,"; $sql .= " t.date_export,"; $sql .= " t.date_validated as date_validation,"; $sql .= " t.date_lim_reglement,"; $sql .= " t.import_key"; } // Manage filter $sqlwhere = array(); if (count($filter) > 0) { foreach ($filter as $key => $value) { if ($key == 't.doc_date>=') { $sqlwhere[] = "t.doc_date >= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date<=') { $sqlwhere[] = "t.doc_date <= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date>') { $sqlwhere[] = "t.doc_date > '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date<') { $sqlwhere[] = "t.doc_date < '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.numero_compte>=') { $sqlwhere[] = "t.numero_compte >= '".$this->db->escape($value)."'"; } elseif ($key == 't.numero_compte<=') { $sqlwhere[] = "t.numero_compte <= '".$this->db->escape($value)."'"; } elseif ($key == 't.subledger_account>=') { $sqlwhere[] = "t.subledger_account >= '".$this->db->escape($value)."'"; } elseif ($key == 't.subledger_account<=') { $sqlwhere[] = "t.subledger_account <= '".$this->db->escape($value)."'"; } elseif ($key == 't.fk_doc' || $key == 't.fk_docdet' || $key == 't.piece_num') { $sqlwhere[] = $this->db->sanitize($key).' = '.((int) $value); } elseif ($key == 't.subledger_account' || $key == 't.numero_compte') { $sqlwhere[] = $this->db->sanitize($key)." LIKE '".$this->db->escape($this->db->escapeforlike($value))."%'"; } elseif ($key == 't.date_creation>=') { $sqlwhere[] = "t.date_creation >= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_creation<=') { $sqlwhere[] = "t.date_creation <= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_export>=') { $sqlwhere[] = "t.date_export >= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_export<=') { $sqlwhere[] = "t.date_export <= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_validated>=') { $sqlwhere[] = "t.date_validated >= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_validated<=') { $sqlwhere[] = "t.date_validated <= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_lim_reglement>=') { $sqlwhere[] = "t.date_lim_reglement>='".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_lim_reglement<=') { $sqlwhere[] = "t.date_lim_reglement<='".$this->db->idate((int) $value)."'"; } elseif ($key == 't.credit' || $key == 't.debit') { $sqlwhere[] = natural_search($key, $value, 1, 1); } elseif ($key == 't.reconciled_option') { $sqlwhere[] = 't.lettering_code IS NULL'; } elseif ($key == 't.code_journal' && !empty($value)) { if (is_array($value)) { $sqlwhere[] = natural_search("t.code_journal", implode(',', $value), 3, 1); } else { $sqlwhere[] = natural_search("t.code_journal", $value, 3, 1); } } elseif ($key == 't.search_accounting_code_in' && !empty($value)) { $sqlwhere[] = "t.numero_compte IN (".$this->db->sanitize($value, 1).")"; } else { $sqlwhere[] = natural_search($key, $value, 0, 1); } } } $sql .= ' FROM '.$this->db->prefix().$this->table_element.' as t'; $sql .= ' WHERE entity = ' . ((int) $conf->entity); // Do not use getEntity for accounting features if (count($sqlwhere) > 0) { $sql .= " AND ".implode(" ".$this->db->sanitize($filtermode)." ", $sqlwhere); } // Filter by ledger account or subledger account if (!empty($option)) { $sql .= " AND t.subledger_account IS NOT NULL"; $sql .= " AND t.subledger_account <> ''"; $sortfield = 't.subledger_account'.($sortfield ? ','.$sortfield : ''); $sortorder = 'ASC'.($sortorder ? ','.$sortorder : ''); } else { $sortfield = 't.numero_compte'.($sortfield ? ','.$sortfield : ''); $sortorder = 'ASC'.($sortorder ? ','.$sortorder : ''); } if (!$countonly) { $sql .= $this->db->order($sortfield, $sortorder); if (!empty($limit)) { $sql .= $this->db->plimit($limit + 1, $offset); } } $resql = $this->db->query($sql); if ($resql) { if ($countonly) { $obj = $this->db->fetch_object($resql); if ($obj) { $num = $obj->nb; } } else { $num = $this->db->num_rows($resql); $i = 0; while (($obj = $this->db->fetch_object($resql)) && (empty($limit) || $i < min($limit, $num))) { $line = new BookKeepingLine($this->db); $line->id = $obj->rowid; $line->doc_date = $this->db->jdate($obj->doc_date); $line->doc_type = $obj->doc_type; $line->doc_ref = $obj->doc_ref; $line->fk_doc = $obj->fk_doc; $line->fk_docdet = $obj->fk_docdet; $line->thirdparty_code = $obj->thirdparty_code; $line->subledger_account = $obj->subledger_account; $line->subledger_label = $obj->subledger_label; $line->numero_compte = $obj->numero_compte; $line->label_compte = $obj->label_compte; $line->label_operation = $obj->label_operation; $line->debit = $obj->debit; $line->credit = $obj->credit; $line->montant = $obj->amount; // deprecated $line->amount = $obj->amount; $line->sens = $obj->sens; $line->multicurrency_amount = $obj->multicurrency_amount; $line->multicurrency_code = $obj->multicurrency_code; $line->lettering_code = $obj->lettering_code; $line->date_lettering = $this->db->jdate($obj->date_lettering); $line->fk_user_author = $obj->fk_user_author; $line->import_key = $obj->import_key; $line->code_journal = $obj->code_journal; $line->journal_label = $obj->journal_label; $line->piece_num = $obj->piece_num; $line->ref = $obj->ref; $line->date_creation = $this->db->jdate($obj->date_creation); $line->date_export = $this->db->jdate($obj->date_export); $line->date_validation = $this->db->jdate($obj->date_validation); // Due date $line->date_lim_reglement = $this->db->jdate($obj->date_lim_reglement); $line->import_key = $obj->import_key; $this->lines[] = $line; $i++; } } $this->db->free($resql); return $num; } else { $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); return -1; } } /** * Load object in memory from the database * * @param string $sortorder Sort Order * @param string $sortfield Sort field * @param int $limit Limit * @param int $offset Offset limit * @param string|array $filter Filter array * @param string $filtermode Filter mode (AND or OR) * @param int $showAlreadyExportMovements Show movements when field 'date_export' is not empty (0:No / 1:Yes (Default)) * @return int Return integer <0 if KO, >0 if OK */ public function fetchAll($sortorder = '', $sortfield = '', $limit = 0, $offset = 0, $filter = '', $filtermode = 'AND', $showAlreadyExportMovements = 1) { global $conf; dol_syslog(__METHOD__, LOG_DEBUG); $sql = 'SELECT'; $sql .= ' t.rowid,'; $sql .= " t.doc_date,"; $sql .= " t.doc_type,"; $sql .= " t.doc_ref,"; $sql .= " t.fk_doc,"; $sql .= " t.fk_docdet,"; $sql .= " t.thirdparty_code,"; $sql .= " t.subledger_account,"; $sql .= " t.subledger_label,"; $sql .= " t.numero_compte,"; $sql .= " t.label_compte,"; $sql .= " t.label_operation,"; $sql .= " t.debit,"; $sql .= " t.credit,"; $sql .= " t.lettering_code,"; $sql .= " t.date_lettering,"; $sql .= " t.montant as amount,"; $sql .= " t.sens,"; $sql .= " t.fk_user_author,"; $sql .= " t.import_key,"; $sql .= " t.code_journal,"; $sql .= " t.journal_label,"; $sql .= " t.piece_num,"; $sql .= " t.date_creation,"; $sql .= " t.date_lim_reglement,"; $sql .= " t.tms as date_modification,"; $sql .= " t.date_export,"; $sql .= " t.date_validated as date_validation"; $sql .= ' FROM '.$this->db->prefix().$this->table_element.' as t'; $sql .= ' WHERE t.entity = ' . ((int) $conf->entity); // Do not use getEntity for accounting features if ($showAlreadyExportMovements == 0) { $sql .= " AND t.date_export IS NULL"; } // Manage filter if (is_array($filter)) { // deprecated, use $filter = USF syntax dol_syslog("You are using a deprecated use of fetchAll. filter parameter must be an USF string now.", LOG_WARNING); $sqlwhere = array(); if (count($filter) > 0) { foreach ($filter as $key => $value) { if ($key == 't.doc_date') { $sqlwhere[] = $this->db->sanitize($key)." = '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date>=') { $sqlwhere[] = "t.doc_date >= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date<=') { $sqlwhere[] = "t.doc_date <= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date>') { $sqlwhere[] = "t.doc_date > '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date<') { $sqlwhere[] = "t.doc_date < '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.numero_compte>=') { $sqlwhere[] = "t.numero_compte >= '".$this->db->escape($value)."'"; } elseif ($key == 't.numero_compte<=') { $sqlwhere[] = "t.numero_compte <= '".$this->db->escape($value)."'"; } elseif ($key == 't.subledger_account>=') { $sqlwhere[] = "t.subledger_account >= '".$this->db->escape($value)."'"; } elseif ($key == 't.subledger_account<=') { $sqlwhere[] = "t.subledger_account <= '".$this->db->escape($value)."'"; } elseif ($key == 't.fk_doc' || $key == 't.fk_docdet' || $key == 't.piece_num') { $sqlwhere[] = $this->db->sanitize($key).' = '.((int) $value); } elseif ($key == 't.subledger_account' || $key == 't.numero_compte') { $sqlwhere[] = $this->db->sanitize($key)." LIKE '".$this->db->escape($value)."%'"; } elseif ($key == 't.date_creation>=') { $sqlwhere[] = "t.date_creation >= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_creation<=') { $sqlwhere[] = "t.date_creation <= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.tms>=') { $sqlwhere[] = "t.tms >= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.tms<=') { $sqlwhere[] = "t.tms <= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_export>=') { $sqlwhere[] = "t.date_export >= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_export<=') { $sqlwhere[] = "t.date_export <= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_validated>=') { $sqlwhere[] = "t.date_validated >= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.date_validated<=') { $sqlwhere[] = "t.date_validated <= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.credit' || $key == 't.debit') { $sqlwhere[] = natural_search($key, $value, 1, 1); } elseif ($key == 't.code_journal' && !empty($value)) { if (is_array($value)) { $sqlwhere[] = natural_search("t.code_journal", implode(',', $value), 3, 1); } else { $sqlwhere[] = natural_search("t.code_journal", $value, 3, 1); } } elseif ($key == 't.reconciled_option') { $sqlwhere[] = 't.lettering_code IS NULL'; } else { $sqlwhere[] = natural_search($key, $value, 0, 1); } } } if (count($sqlwhere) > 0) { $sql .= " AND ".implode(" ".$this->db->sanitize($filtermode)." ", $sqlwhere); } $filter = ''; } // Manage filter $errormessage = ''; $sql .= forgeSQLFromUniversalSearchCriteria($filter, $errormessage); if ($errormessage) { $this->errors[] = $errormessage; dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); return -1; } if (!empty($sortfield)) { $sql .= $this->db->order($sortfield, $sortorder); } if (!empty($limit)) { $sql .= $this->db->plimit($limit + 1, $offset); } $this->lines = array(); $resql = $this->db->query($sql); if ($resql) { $num = $this->db->num_rows($resql); $i = 0; while (($obj = $this->db->fetch_object($resql)) && (empty($limit) || $i < min($limit, $num))) { $line = new BookKeepingLine($this->db); $line->id = $obj->rowid; $line->doc_date = $this->db->jdate($obj->doc_date); $line->doc_type = $obj->doc_type; $line->doc_ref = $obj->doc_ref; $line->fk_doc = $obj->fk_doc; $line->fk_docdet = $obj->fk_docdet; $line->thirdparty_code = $obj->thirdparty_code; $line->subledger_account = $obj->subledger_account; $line->subledger_label = $obj->subledger_label; $line->numero_compte = $obj->numero_compte; $line->label_compte = $obj->label_compte; $line->label_operation = $obj->label_operation; $line->debit = $obj->debit; $line->credit = $obj->credit; $line->montant = $obj->amount; // deprecated $line->amount = $obj->amount; $line->sens = $obj->sens; $line->lettering_code = $obj->lettering_code; $line->date_lettering = $this->db->jdate($obj->date_lettering); $line->fk_user_author = $obj->fk_user_author; $line->import_key = $obj->import_key; $line->code_journal = $obj->code_journal; $line->journal_label = $obj->journal_label; $line->piece_num = $obj->piece_num; $line->date_creation = $this->db->jdate($obj->date_creation); $line->date_lim_reglement = $this->db->jdate($obj->date_lim_reglement); $line->date_modification = $this->db->jdate($obj->date_modification); $line->date_export = $this->db->jdate($obj->date_export); $line->date_validation = $this->db->jdate($obj->date_validation); $this->lines[] = $line; $i++; } $this->db->free($resql); return $num; } else { $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); return -1; } } /** * Load object in memory from the database * * @param string $sortorder Sort Order * @param string $sortfield Sort field * @param int $limit Limit * @param int $offset Offset limit * @param string|array $filter Filter * @param string $filtermode Filter mode (AND or OR) * @param int<0,1> $option option (0: aggregate by general account or 1: aggregate by subaccount) * @return int Return integer <0 if KO, >0 if OK */ public function fetchAllBalance($sortorder = '', $sortfield = '', $limit = 0, $offset = 0, $filter = '', $filtermode = 'AND', $option = 0) { global $conf; $this->lines = array(); dol_syslog(__METHOD__, LOG_DEBUG); $sql = 'SELECT'; $sql .= " t.numero_compte,"; if (!empty($option)) { $sql .= " t.subledger_account,"; $sql .= " t.subledger_label,"; } $sql .= " SUM(t.debit) as debit,"; $sql .= " SUM(t.credit) as credit"; $sql .= ' FROM '.$this->db->prefix().$this->table_element.' as t'; $sql .= ' WHERE entity = ' . ((int) $conf->entity); // Do not use getEntity for accounting features // Manage filter if (is_array($filter)) { $sqlwhere = array(); if (count($filter) > 0) { foreach ($filter as $key => $value) { if ($key == 't.doc_date') { $sqlwhere[] = $this->db->sanitize($key)." = '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date>=') { $sqlwhere[] = "t.doc_date >= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date<=') { $sqlwhere[] = "t.doc_date <= '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date>') { $sqlwhere[] = "t.doc_date > '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.doc_date<') { $sqlwhere[] = "t.doc_date < '".$this->db->idate((int) $value)."'"; } elseif ($key == 't.numero_compte>=') { $sqlwhere[] = "t.numero_compte >= '".$this->db->escape($value)."'"; } elseif ($key == 't.numero_compte<=') { $sqlwhere[] = "t.numero_compte <= '".$this->db->escape($value)."'"; } elseif ($key == 't.subledger_account>=') { $sqlwhere[] = "t.subledger_account >= '".$this->db->escape($value)."'"; } elseif ($key == 't.subledger_account<=') { $sqlwhere[] = "t.subledger_account <= '".$this->db->escape($value)."'"; } elseif ($key == 't.fk_doc' || $key == 't.fk_docdet' || $key == 't.piece_num') { $sqlwhere[] = $this->db->sanitize($key)." = ".((int) $value); } elseif ($key == 't.subledger_account' || $key == 't.numero_compte') { $sqlwhere[] = $this->db->sanitize($key)." LIKE '".$this->db->escape($value)."%'"; } elseif ($key == 't.subledger_label') { $sqlwhere[] = $this->db->sanitize($key)." LIKE '".$this->db->escape($value)."%'"; } elseif ($key == 't.code_journal' && !empty($value)) { if (is_array($value)) { $sqlwhere[] = natural_search("t.code_journal", implode(',', $value), 3, 1); } else { $sqlwhere[] = natural_search("t.code_journal", $value, 3, 1); } } elseif ($key == 't.reconciled_option') { $sqlwhere[] = 't.lettering_code IS NULL'; } else { $sqlwhere[] = $this->db->sanitize($key)." LIKE '%".$this->db->escape($this->db->escapeforlike($value))."%'"; } } } if (count($sqlwhere) > 0) { $sql .= " AND ".implode(" ".$this->db->sanitize($filtermode)." ", $sqlwhere); } $filter = ''; } // Manage filter $errormessage = ''; $sql .= forgeSQLFromUniversalSearchCriteria($filter, $errormessage); if ($errormessage) { $this->errors[] = $errormessage; dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); return -1; } if (!empty($option)) { $sql .= " AND t.subledger_account IS NOT NULL"; $sql .= " AND t.subledger_account <> ''"; $sql .= " GROUP BY t.numero_compte, t.subledger_account, t.subledger_label"; $sortfield = 't.subledger_account'.($sortfield ? ','.$sortfield : ''); $sortorder = 'ASC'.($sortorder ? ','.$sortorder : ''); } else { $sql .= ' GROUP BY t.numero_compte'; $sortfield = 't.numero_compte'.($sortfield ? ','.$sortfield : ''); $sortorder = 'ASC'.($sortorder ? ','.$sortorder : ''); } $sql .= $this->db->order($sortfield, $sortorder); if (!empty($limit)) { $sql .= $this->db->plimit($limit + 1, $offset); } //print $sql; $resql = $this->db->query($sql); if ($resql) { $num = $this->db->num_rows($resql); $i = 0; while (($obj = $this->db->fetch_object($resql)) && (empty($limit) || $i < min($limit, $num))) { $line = new BookKeepingLine($this->db); $line->numero_compte = $obj->numero_compte; //$line->label_compte = $obj->label_compte; if (!empty($option)) { $line->subledger_account = $obj->subledger_account; $line->subledger_label = $obj->subledger_label; } $line->debit = $obj->debit; $line->credit = $obj->credit; $this->lines[] = $line; $i++; } $this->db->free($resql); return $num; } else { $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); return -1; } } /** * Update object into database * * @param User $user User that modifies * @param int $notrigger false=launch triggers after, true=disable triggers * @param string $mode Mode ('' or _tmp') * @return int Return integer <0 if KO, >0 if OK */ public function update(User $user, $notrigger = 0, $mode = '') { global $langs; $error = 0; dol_syslog(__METHOD__, LOG_DEBUG); // Clean parameters if (isset($this->doc_type)) { $this->doc_type = trim($this->doc_type); } if (isset($this->doc_ref)) { $this->doc_ref = trim($this->doc_ref); } if (isset($this->fk_doc)) { $this->fk_doc = (int) $this->fk_doc; } if (isset($this->fk_docdet)) { $this->fk_docdet = (int) $this->fk_docdet; } if (isset($this->thirdparty_code)) { $this->thirdparty_code = trim($this->thirdparty_code); } if (isset($this->subledger_account)) { $this->subledger_account = trim($this->subledger_account); } if (isset($this->subledger_label)) { $this->subledger_label = trim($this->subledger_label); } if (isset($this->numero_compte)) { $this->numero_compte = trim($this->numero_compte); } if (isset($this->label_compte)) { $this->label_compte = trim($this->label_compte); } if (isset($this->label_operation)) { $this->label_operation = trim($this->label_operation); } if (isset($this->sens)) { $this->sens = trim($this->sens); } if (isset($this->import_key)) { $this->import_key = trim($this->import_key); } if (isset($this->code_journal)) { $this->code_journal = trim($this->code_journal); } if (isset($this->journal_label)) { $this->journal_label = trim($this->journal_label); } if (isset($this->piece_num)) { $this->piece_num = (int) $this->piece_num; } $result = $this->canModifyBookkeeping($this->id, $mode); if ($result < 0) { return -1; } elseif ($result == 0) { if (getDolGlobalString('ACCOUNTANCY_FISCAL_PERIOD_MODE') == 'blockedonclosed') { $this->errors[] = $langs->trans('ErrorBookkeepingDocDateIsOnAClosedFiscalPeriod'); } else { $this->errors[] = $langs->trans('ErrorBookkeepingDocDateNotOnActiveFiscalPeriod'); } return -1; } $this->debit = (float) price2num($this->debit, 'MT'); $this->credit = (float) price2num($this->credit, 'MT'); $this->montant = (float) price2num($this->montant, 'MT'); // Check parameters // Put here code to add a control on parameters values // Update request $sql = 'UPDATE '.$this->db->prefix().$this->table_element.$mode.' SET'; $sql .= ' doc_date = '.(isDolTms($this->doc_date) ? "'".$this->db->idate($this->doc_date)."'" : 'null').','; $sql .= ' doc_type = '.(isset($this->doc_type) ? "'".$this->db->escape($this->doc_type)."'" : "null").','; $sql .= ' doc_ref = '.(isset($this->doc_ref) ? "'".$this->db->escape($this->doc_ref)."'" : "null").','; $sql .= ' fk_doc = '.(isset($this->fk_doc) ? $this->fk_doc : "null").','; $sql .= ' fk_docdet = '.(isset($this->fk_docdet) ? $this->fk_docdet : "null").','; $sql .= ' thirdparty_code = '.(isset($this->thirdparty_code) ? "'".$this->db->escape($this->thirdparty_code)."'" : "null").','; $sql .= ' subledger_account = '.(isset($this->subledger_account) ? "'".$this->db->escape($this->subledger_account)."'" : "null").','; $sql .= ' subledger_label = '.(isset($this->subledger_label) ? "'".$this->db->escape($this->subledger_label)."'" : "null").','; $sql .= ' numero_compte = '.(isset($this->numero_compte) ? "'".$this->db->escape($this->numero_compte)."'" : "null").','; $sql .= ' label_compte = '.(isset($this->label_compte) ? "'".$this->db->escape($this->label_compte)."'" : "null").','; $sql .= ' label_operation = '.(isset($this->label_operation) ? "'".$this->db->escape($this->label_operation)."'" : "null").','; $sql .= ' debit = '.(isset($this->debit) ? $this->debit : "null").','; $sql .= ' credit = '.(isset($this->credit) ? $this->credit : "null").','; $sql .= ' montant = '.(isset($this->montant) ? $this->montant : "null").','; $sql .= ' sens = '.(isset($this->sens) ? "'".$this->db->escape($this->sens)."'" : "null").','; $sql .= ' fk_user_author = '.(isset($this->fk_user_author) ? $this->fk_user_author : "null").','; $sql .= ' import_key = '.(isset($this->import_key) ? "'".$this->db->escape($this->import_key)."'" : "null").','; $sql .= ' code_journal = '.(isset($this->code_journal) ? "'".$this->db->escape($this->code_journal)."'" : "null").','; $sql .= ' journal_label = '.(isset($this->journal_label) ? "'".$this->db->escape($this->journal_label)."'" : "null").','; $sql .= ' piece_num = '.(isset($this->piece_num) ? $this->piece_num : "null"); $sql .= ' WHERE rowid='.((int) $this->id); $this->db->begin(); $resql = $this->db->query($sql); if (!$resql) { $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } // Call triggers if (! $error && ! $notrigger) { $result = $this->call_trigger('BOOKKEEPING_MODIFY', $user); if ($result < 0) { $error++; } } // Commit or rollback if ($error) { $this->db->rollback(); return -1 * $error; } else { $this->db->commit(); return 1; } } /** * Update accounting movement * * @param string $piece_num Piece num * @param string $field Field * @param string $value Value * @param string $mode Mode ('' or _tmp') * @return int Return integer <0 if KO, >0 if OK */ public function updateByMvt($piece_num = '', $field = '', $value = '', $mode = '') { global $conf; $error = 0; $sql_filter = $this->getCanModifyBookkeepingSQL(); if (!isset($sql_filter)) { return -1; } $this->db->begin(); $sql = "UPDATE ".$this->db->prefix().$this->table_element.$mode; $sql .= " SET ".$this->db->sanitize($field)." = ".(is_numeric($value) ? ((float) $value) : "'".$this->db->escape($value)."'"); $sql .= " WHERE piece_num = ".((int) $piece_num); $sql .= " AND entity = " . ((int) $conf->entity); $sql .= $sql_filter; $resql = $this->db->query($sql); if (!$resql) { $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } if ($error) { $this->db->rollback(); return -1 * $error; } else { $this->db->commit(); return 1; } } /** * Delete object in database * * @param User $user User that deletes * @param int $notrigger 0=launch triggers after, 1=disable triggers * @param string $mode Mode ('' or 'tmp_') * @return int Return integer <0 if KO, >0 if OK */ public function delete(User $user, $notrigger = 0, $mode = '') { global $langs; dol_syslog(__METHOD__, LOG_DEBUG); $result = $this->canModifyBookkeeping($this->id, $mode); if ($result < 0) { return -1; } elseif ($result == 0) { if (getDolGlobalString('ACCOUNTANCY_FISCAL_PERIOD_MODE') == 'blockedonclosed') { $this->errors[] = $langs->trans('ErrorBookkeepingDocDateIsOnAClosedFiscalPeriod'); } else { $this->errors[] = $langs->trans('ErrorBookkeepingDocDateNotOnActiveFiscalPeriod'); } return -1; } $error = 0; $this->db->begin(); // Call triggers if (!$notrigger) { $result = $this->call_trigger('BOOKKEEPING_DELETE', $user); if ($result < 0) { $error++; } } if (!$error) { $sql = 'DELETE FROM '.$this->db->prefix().$this->table_element.$mode; $sql .= ' WHERE rowid='.((int) $this->id); $resql = $this->db->query($sql); if (!$resql) { $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } } // Commit or rollback if ($error) { $this->db->rollback(); return -1 * $error; } else { $this->db->commit(); return 1; } } /** * Delete bookkeeping by importkey * * @param string $importkey Import key * @param string $mode Mode * @return int Result */ public function deleteByImportkey($importkey, $mode = '') { $this->db->begin(); $sql_filter = $this->getCanModifyBookkeepingSQL(); if (!isset($sql_filter)) { return -1; } // first check if line not yet in bookkeeping $sql = "DELETE"; $sql .= " FROM ".$this->db->prefix().$this->table_element.$mode; $sql .= " WHERE import_key = '".$this->db->escape($importkey)."'"; $sql .= $sql_filter; $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = "Error ".$this->db->lasterror(); dol_syslog(get_class($this)."::delete Error ".$this->db->lasterror(), LOG_ERR); $this->db->rollback(); return -1; } $this->db->commit(); return 1; } /** * Delete bookkeeping by year * * @param int $delyear Year to delete * @param string $journal Journal to delete * @param string $mode Mode * @param int $delmonth Month * @return int Return integer <0 if KO, >0 if OK */ public function deleteByYearAndJournal($delyear = 0, $journal = '', $mode = '', $delmonth = 0) { global $conf, $langs; if (empty($delyear) && empty($journal)) { $this->error = 'ErrorOneFieldRequired'; return -1; } if (!empty($delmonth) && empty($delyear)) { $this->error = 'YearRequiredIfMonthDefined'; return -2; } $sql_filter = $this->getCanModifyBookkeepingSQL(); if (!isset($sql_filter)) { return -1; } $this->db->begin(); // Delete record in bookkeeping $sql = "DELETE"; $sql .= " FROM ".$this->db->prefix().$this->table_element.$mode; $sql .= " WHERE 1 = 1"; $sql .= dolSqlDateFilter('doc_date', 0, $delmonth, $delyear); if (!empty($journal)) { $sql .= " AND code_journal = '".$this->db->escape($journal)."'"; } $sql .= " AND entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features // Exclusion of validated entries at the time of deletion $sql .= " AND date_validated IS NULL"; $sql .= $sql_filter; // TODO: In a future we must forbid deletion if record is inside a closed fiscal period. $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = "Error ".$this->db->lasterror(); foreach ($this->errors as $errmsg) { dol_syslog(get_class($this)."::delete ".$errmsg, LOG_ERR); $this->error .= ($this->error ? ', '.$errmsg : $errmsg); } $this->db->rollback(); return -1; } $this->db->commit(); return 1; } /** * Delete bookkeeping by piece number * * @param int $piecenum Piecenum to delete * @param string $mode Mode ('' or '_tmp') * @param int $notrigger 0=launch triggers after, 1=disable triggers * @return int Nb of record deleted */ public function deleteMvtNum($piecenum, $mode = '', $notrigger = 0) { global $conf, $user; $sql_filter = $this->getCanModifyBookkeepingSQL(); if (!isset($sql_filter)) { return -1; } $nbprocessed = 0; $error = 0; $this->db->begin(); // Call triggers if (!$notrigger) { $result = $this->call_trigger('BOOKKEEPING_DELETE', $user); if ($result < 0) { $error++; } } if (!$error) { // first check if line not yet in bookkeeping $sql = "DELETE"; $sql .= " FROM ".$this->db->prefix().$this->table_element.$mode; $sql .= " WHERE piece_num = ".(int) $piecenum; $sql .= " AND date_validated IS NULL"; // For security, exclusion of validated entries at the time of deletion $sql .= " AND entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features $sql .= $sql_filter; $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = "Error ".$this->db->lasterror(); foreach ($this->errors as $errmsg) { dol_syslog(get_class($this)."::delete ".$errmsg, LOG_ERR); $this->error .= ($this->error ? ', '.$errmsg : $errmsg); } $this->db->rollback(); return -1; } else { $nbprocessed = $this->db->affected_rows($resql); } } // Commit or rollback if ($error) { $this->db->rollback(); return -1 * $error; } else { $this->db->commit(); return $nbprocessed; } } /** * Load an object from its id and create a new one in database * * @param User $user User making the clone * @param int $fromid Id of object to clone * @return int New id of clone */ public function createFromClone(User $user, $fromid) { dol_syslog(__METHOD__, LOG_DEBUG); $error = 0; $object = new BookKeeping($this->db); $this->db->begin(); // Load source object $object->fetch($fromid); // Reset object $object->id = 0; // Clear fields // ... // Create clone $object->context['createfromclone'] = 'createfromclone'; $result = $object->create($user); // Other options if ($result < 0) { $error++; $this->errors = $object->errors; dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } unset($object->context['createfromclone']); // End if (!$error) { $this->db->commit(); return $object->id; } else { $this->db->rollback(); return -1; } } /** * Initialise object with example values * Id must be 0 if object instance is a specimen * * @return int */ public function initAsSpecimen() { global $user; $now = dol_now(); $this->id = 0; $this->doc_date = $now; $this->doc_type = ''; $this->doc_ref = ''; $this->fk_doc = 0; $this->fk_docdet = 0; $this->thirdparty_code = 'CU001'; $this->subledger_account = '41100001'; $this->subledger_label = 'My customer company'; $this->numero_compte = '411'; $this->label_compte = 'Customer'; $this->label_operation = 'Sales of pea'; $this->debit = 99.9; $this->credit = 0.0; $this->amount = 0.0; $this->sens = 'D'; $this->fk_user_author = $user->id; $this->import_key = '20201027'; $this->code_journal = 'VT'; $this->journal_label = 'Journal de vente'; $this->piece_num = 1234; $this->date_creation = $now; return 1; } /** * Load an accounting document into memory from database * * @param int $piecenum Accounting document to get * @param string $mode Mode * @return int Return integer <0 if KO, >0 if OK */ public function fetchPerMvt($piecenum, $mode = '') { global $conf; $sql = "SELECT piece_num, ref, doc_date, code_journal, journal_label, doc_ref, doc_type,"; $sql .= " date_creation, tms as date_modification, date_validated as date_validation, date_lim_reglement, import_key"; // In llx_accounting_bookkeeping_tmp, field date_export doesn't exist if ($mode != "_tmp") { $sql .= ", date_export"; } $sql .= " FROM ".$this->db->prefix().$this->table_element.$mode; $sql .= " WHERE piece_num = ".((int) $piecenum); $sql .= " AND entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features dol_syslog(__METHOD__, LOG_DEBUG); $result = $this->db->query($sql); if ($result) { $obj = $this->db->fetch_object($result); $this->piece_num = $obj->piece_num; $this->ref = $obj->ref; $this->code_journal = $obj->code_journal; $this->journal_label = $obj->journal_label; $this->doc_date = $this->db->jdate($obj->doc_date); $this->doc_ref = $obj->doc_ref; $this->doc_type = $obj->doc_type; $this->date_creation = $this->db->jdate($obj->date_creation); $this->date_modification = $this->db->jdate($obj->date_modification); if ($mode != "_tmp") { $this->date_export = $this->db->jdate($obj->date_export); } $this->date_validation = $this->db->jdate($obj->date_validation); $this->date_lim_reglement = $this->db->jdate($obj->date_lim_reglement); $this->import_key = $obj->import_key; } else { $this->error = "Error ".$this->db->lasterror(); dol_syslog(__METHOD__.$this->error, LOG_ERR); return -1; } return 1; } /** * Return next bookkeeping piece number * * @param string $mode Mode * @return int<1, max>|-1 Return next movement number or -1 if error */ public function getNextNumMvt($mode = '') { global $conf; $sql = "SELECT MAX(piece_num) + 1 as max FROM ".$this->db->prefix().$this->table_element.$mode; $sql .= " WHERE entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features dol_syslog(get_class($this)."::getNextNumMvt", LOG_DEBUG); $result = $this->db->query($sql); if ($result) { $obj = $this->db->fetch_object($result); if ($obj) { $result = $obj->max; } if (empty($result)) { $result = 1; } return $result; } else { $this->error = "Error ".$this->db->lasterror(); dol_syslog(get_class($this)."::getNextNumMvt ".$this->error, LOG_ERR); return -1; } } /** * Returns the reference to the following non used Bookkeeping depending on the active numbering module * defined into BOOKKEEPING_ADDON * * @return string Bookkeeping next reference */ public function getNextNumRef() { global $langs, $conf; $langs->load("accountancy"); if (getDolGlobalString('BOOKKEEPING_ADDON')) { $mybool = false; $file = getDolGlobalString('BOOKKEEPING_ADDON') . ".php"; $classname = getDolGlobalString('BOOKKEEPING_ADDON'); // Include file with class $dirmodels = array_merge(array('/'), (array) $conf->modules_parts['models']); foreach ($dirmodels as $reldir) { $dir = dol_buildpath($reldir."core/modules/accountancy/"); // Load file with numbering class (if found) $mybool = ((bool) @include_once $dir.$file) || $mybool; } if (!$mybool) { dol_print_error(null, "Failed to include file ".$file); return ''; } $obj = new $classname(); /** @var ModeleNumRefBookkeeping $obj */ '@phan-var-force ModeleNumRefBookkeeping $obj'; $numref = $obj->getNextValue($this); if ($numref != "") { return $numref; } else { $this->error = $obj->error; //dol_print_error($this->db,get_class($this)."::getNextNumRef ".$obj->error); return ""; } } else { print $langs->trans("Error")." ".$langs->trans("Error_BOOKKEEPING_ADDON_NotDefined"); return ""; } } /** * Load all accounting lines related to a given transaction ID $piecenum * * @param int $piecenum Id of line to get * @param string $mode Mode ('' or '_tmp') * @return int Return integer <0 if KO, >0 if OK */ public function fetchAllPerMvt($piecenum, $mode = '') { global $conf; $sql = "SELECT rowid, doc_date, doc_type,"; $sql .= " doc_ref, fk_doc, fk_docdet, thirdparty_code, subledger_account, subledger_label,"; $sql .= " numero_compte, label_compte, label_operation, debit, credit,"; $sql .= " montant as amount, sens, fk_user_author, import_key, code_journal, journal_label, piece_num,"; $sql .= " date_creation, tms as date_modification, date_validated as date_validation"; // In llx_accounting_bookkeeping_tmp, field date_export doesn't exist if ($mode != "_tmp") { $sql .= ", date_export"; } $sql .= " FROM ".$this->db->prefix().$this->table_element.$mode; $sql .= " WHERE piece_num = ".((int) $piecenum); $sql .= " AND entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features dol_syslog(__METHOD__, LOG_DEBUG); $result = $this->db->query($sql); if ($result) { while ($obj = $this->db->fetch_object($result)) { $line = new BookKeepingLine($this->db); $line->id = $obj->rowid; $line->doc_date = $this->db->jdate($obj->doc_date); $line->doc_type = $obj->doc_type; $line->doc_ref = $obj->doc_ref; $line->fk_doc = $obj->fk_doc; $line->fk_docdet = $obj->fk_docdet; $line->thirdparty_code = $obj->thirdparty_code; $line->subledger_account = $obj->subledger_account; $line->subledger_label = $obj->subledger_label; $line->numero_compte = $obj->numero_compte; $line->label_compte = $obj->label_compte; $line->label_operation = $obj->label_operation; $line->debit = $obj->debit; $line->credit = $obj->credit; $line->montant = $obj->amount; $line->amount = $obj->amount; $line->sens = $obj->sens; $line->code_journal = $obj->code_journal; $line->journal_label = $obj->journal_label; $line->piece_num = $obj->piece_num; $line->date_creation = $obj->date_creation; $line->date_modification = $obj->date_modification; if ($mode != "_tmp") { $line->date_export = $obj->date_export; } $line->date_validation = $obj->date_validation; $this->linesmvt[] = $line; } } else { $this->error = "Error ".$this->db->lasterror(); dol_syslog(__METHOD__.$this->error, LOG_ERR); return -1; } return 1; } // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps /** * Export bookkeeping * * @param string $model Model * @return int Result */ public function export_bookkeeping($model = 'ebp') { // phpcs:enable global $conf; $sql = "SELECT rowid, doc_date, doc_type,"; $sql .= " doc_ref, fk_doc, fk_docdet, thirdparty_code, subledger_account, subledger_label,"; $sql .= " numero_compte, label_compte, label_operation, debit, credit,"; $sql .= " montant as amount, sens, fk_user_author, import_key, code_journal, piece_num,"; $sql .= " date_validated as date_validation"; $sql .= " FROM ".$this->db->prefix().$this->table_element; $sql .= " WHERE entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features dol_syslog(get_class($this)."::export_bookkeeping", LOG_DEBUG); $resql = $this->db->query($sql); if ($resql) { $this->linesexport = array(); $num = $this->db->num_rows($resql); while ($obj = $this->db->fetch_object($resql)) { $line = new BookKeepingLine($this->db); $line->id = $obj->rowid; $line->doc_date = $this->db->jdate($obj->doc_date); $line->doc_type = $obj->doc_type; $line->doc_ref = $obj->doc_ref; $line->fk_doc = $obj->fk_doc; $line->fk_docdet = $obj->fk_docdet; $line->thirdparty_code = $obj->thirdparty_code; $line->subledger_account = $obj->subledger_account; $line->subledger_label = $obj->subledger_label; $line->numero_compte = $obj->numero_compte; $line->label_compte = $obj->label_compte; $line->label_operation = $obj->label_operation; $line->debit = $obj->debit; $line->credit = $obj->credit; $line->montant = $obj->amount; $line->amount = $obj->amount; $line->sens = $obj->sens; $line->code_journal = $obj->code_journal; $line->piece_num = $obj->piece_num; $line->date_validation = $obj->date_validation; $this->linesexport[] = $line; } $this->db->free($resql); return $num; } else { $this->error = "Error ".$this->db->lasterror(); dol_syslog(get_class($this)."::export_bookkeeping ".$this->error, LOG_ERR); return -1; } } /** * Transform transaction * * @param int $direction If 0: tmp => real, if 1: real => tmp * @param string $piece_num Piece num = Transaction ref * @return int int Return integer <0 if KO, >0 if OK */ public function transformTransaction($direction = 0, $piece_num = '') { global $conf; $error = 0; $sql_filter = $this->getCanModifyBookkeepingSQL(); if (!isset($sql_filter)) { return -1; } $this->db->begin(); $tmpBookkeeping = new self($this->db); $tmpData = $this->db->getRow("SELECT doc_date, code_journal, ref FROM {$this->db->prefix()}accounting_bookkeeping_tmp WHERE piece_num = '{$this->db->escape($piece_num)}' AND entity = {$conf->entity}"); $tmpBookkeeping->doc_date = $this->db->jdate($tmpData->doc_date); $tmpBookkeeping->code_journal = $tmpData->code_journal; // Ref is copied from tmp only if defined => free num ref model has been used $ref = $tmpData->ref ?: $tmpBookkeeping->getNextNumRef(); if ($direction == 0) { $next_piecenum = $this->getNextNumMvt(); $now = dol_now(); if ($next_piecenum < 0) { $error++; } if (!$error) { // Delete if there is an empty line $sql = 'DELETE FROM '.$this->db->prefix().$this->table_element.'_tmp WHERE piece_num = '.((int) $piece_num).' AND entity = ' .((int) $conf->entity)." AND numero_compte IS NULL AND debit = 0 AND credit = 0"; $resql = $this->db->query($sql); if (!$resql) { $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } } if (!$error) { $sql = 'INSERT INTO '.$this->db->prefix().$this->table_element.' (doc_date, doc_type, ref,'; $sql .= ' doc_ref, fk_doc, fk_docdet, entity, thirdparty_code, subledger_account, subledger_label,'; $sql .= ' numero_compte, label_compte, label_operation, debit, credit,'; $sql .= ' montant, sens, fk_user_author, import_key, code_journal, journal_label, piece_num, date_creation)'; $sql .= ' SELECT doc_date, doc_type,' . "'{$ref}',"; $sql .= ' doc_ref, fk_doc, fk_docdet, entity, thirdparty_code, subledger_account, subledger_label,'; $sql .= ' numero_compte, label_compte, label_operation, debit, credit,'; $sql .= ' montant, sens, fk_user_author, import_key, code_journal, journal_label, '.((int) $next_piecenum).", '".$this->db->idate($now)."'"; $sql .= ' FROM '.$this->db->prefix().$this->table_element.'_tmp WHERE piece_num = '.((int) $piece_num).' AND numero_compte IS NOT NULL AND entity = ' .((int) $conf->entity); $sql .= $sql_filter; $resql = $this->db->query($sql); if (!$resql) { $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } } if (!$error) { $sql = 'DELETE FROM '.$this->db->prefix().$this->table_element.'_tmp WHERE piece_num = '.((int) $piece_num).' AND entity = ' .((int) $conf->entity); $resql = $this->db->query($sql); if (!$resql) { $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } } } elseif ($direction == 1) { $sql = 'DELETE FROM '.$this->db->prefix().$this->table_element.'_tmp WHERE piece_num = '.((int) $piece_num).' AND entity = ' .((int) $conf->entity); $resql = $this->db->query($sql); if (!$resql) { $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } if (!$error) { $sql = 'INSERT INTO '.$this->db->prefix().$this->table_element.'_tmp (doc_date, doc_type, ref,'; $sql .= ' doc_ref, fk_doc, fk_docdet, thirdparty_code, subledger_account, subledger_label,'; $sql .= ' numero_compte, label_compte, label_operation, debit, credit,'; $sql .= ' montant, sens, fk_user_author, import_key, code_journal, journal_label, piece_num)'; $sql .= ' SELECT doc_date, doc_type,' . "'{$ref}',"; $sql .= ' doc_ref, fk_doc, fk_docdet, thirdparty_code, subledger_account, subledger_label,'; $sql .= ' numero_compte, label_compte, label_operation, debit, credit,'; $sql .= ' montant, sens, fk_user_author, import_key, code_journal, journal_label, piece_num'; $sql .= ' FROM '.$this->db->prefix().$this->table_element.' WHERE piece_num = '.((int) $piece_num).' AND entity = ' .((int) $conf->entity); $sql .= $sql_filter; $resql = $this->db->query($sql); if (!$resql) { $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } } if (!$error) { $sql = 'DELETE FROM '.$this->db->prefix().$this->table_element.'_tmp WHERE piece_num = '.((int) $piece_num).' AND entity = ' .((int) $conf->entity); $sql .= $sql_filter; $resql = $this->db->query($sql); if (!$resql) { $error++; $this->errors[] = 'Error '.$this->db->lasterror(); dol_syslog(__METHOD__.' '.implode(',', $this->errors), LOG_ERR); } } } if (!$error) { $this->db->commit(); return 1; } else { $this->db->rollback(); return -1; } /* $sql = "DELETE FROM "; $sql .= " FROM " . $this->db->prefix() . "accounting_bookkeeping as ab"; $sql .= " LEFT JOIN " . $this->db->prefix() . "accounting_account as aa ON aa.account_number = ab.numero_compte"; $sql .= " AND aa.active = 1"; $sql .= " INNER JOIN " . $this->db->prefix() . "accounting_system as asy ON aa.fk_pcg_version = asy.pcg_version"; $sql .= " AND asy.rowid = " . ((int) $pcgver); $sql .= " AND ab.entity IN (" . getEntity('accountancy') . ")"; $sql .= " ORDER BY account_number ASC"; */ } // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps /** * Return list of accounts with label by chart of accounts * * @param string $selectid Preselected chart of accounts * @param string $htmlname Name of field in html form * @param int<0,1> $showempty Add an empty field * @param array}> $event Event options * @param int $select_in Value is a aa.rowid (0 default) or aa.account_number (1) * @param int $select_out Set value returned by select 0=rowid (default), 1=account_number * @param string $aabase Set accounting_account base class to display empty=all or from 1 to 8 will display only account starting from this number * @return string|int String with HTML select or -1 if KO */ public function select_account($selectid, $htmlname = 'account', $showempty = 0, $event = array(), $select_in = 0, $select_out = 0, $aabase = '') { // phpcs:enable global $conf; require_once DOL_DOCUMENT_ROOT.'/core/lib/accounting.lib.php'; $pcgver = getDolGlobalInt('CHARTOFACCOUNTS'); $sql = "SELECT DISTINCT ab.numero_compte as account_number, aa.label as label, aa.rowid as rowid, aa.fk_pcg_version"; $sql .= " FROM ".$this->db->prefix().$this->table_element." as ab"; $sql .= " LEFT JOIN ".$this->db->prefix()."accounting_account as aa ON aa.account_number = ab.numero_compte"; $sql .= " AND aa.active = 1"; $sql .= " INNER JOIN ".$this->db->prefix()."accounting_system as asy ON aa.fk_pcg_version = asy.pcg_version"; $sql .= " AND asy.rowid = ".((int) $pcgver); $sql .= " AND ab.entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features $sql .= " ORDER BY account_number ASC"; dol_syslog(get_class($this)."::select_account", LOG_DEBUG); $resql = $this->db->query($sql); if (!$resql) { $this->error = "Error ".$this->db->lasterror(); dol_syslog(get_class($this)."::select_account ".$this->error, LOG_ERR); return "-1"; } $out = ajax_combobox($htmlname, $event); $options = array(); $selected = 0; while ($obj = $this->db->fetch_object($resql)) { $label = length_accountg($obj->account_number).' - '.$obj->label; $select_value_in = $obj->rowid; $select_value_out = $obj->rowid; if ($select_in == 1) { $select_value_in = $obj->account_number; } if ($select_out == 1) { $select_value_out = $obj->account_number; } // Remember guy's we store in database llx_facturedet the rowid of accounting_account and not the account_number // Because same account_number can be share between different accounting_system and do have the same meaning if (($selectid != '') && $selectid == $select_value_in) { $selected = $select_value_out; } $options[$select_value_out] = $label; } $out .= Form::selectarray($htmlname, $options, $selected, $showempty, 0, 0, '', 0, 0, 0, '', 'maxwidth300'); $this->db->free($resql); return $out; } /** * Return id and description of a root accounting account. * FIXME: This function takes the parent of parent to get the root account ! * * @param string $account Accounting account * @return array{id:int,account_number:string,label:string}|int<-1,-1> Array with root account information (max 2 upper level), <0 if KO */ public function getRootAccount($account = null) { global $conf; $pcgver = getDolGlobalInt('CHARTOFACCOUNTS'); $sql = "SELECT root.rowid, root.account_number, root.label as label,"; $sql .= " parent.rowid as parent_rowid, parent.account_number as parent_account_number, parent.label as parent_label"; $sql .= " FROM ".$this->db->prefix()."accounting_account as aa"; $sql .= " INNER JOIN ".$this->db->prefix()."accounting_system as asy ON aa.fk_pcg_version = asy.pcg_version"; $sql .= " AND asy.rowid = ".((int) $pcgver); $sql .= " LEFT JOIN ".$this->db->prefix()."accounting_account as parent ON aa.account_parent = parent.rowid AND parent.active = 1"; $sql .= " LEFT JOIN ".$this->db->prefix()."accounting_account as root ON parent.account_parent = root.rowid AND root.active = 1"; $sql .= " WHERE aa.account_number = '".$this->db->escape($account)."'"; $sql .= " AND aa.entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features dol_syslog(get_class($this)."::select_account", LOG_DEBUG); $resql = $this->db->query($sql); if ($resql) { $obj = ''; if ($this->db->num_rows($resql)) { $obj = $this->db->fetch_object($resql); } $result = array('id' => $obj->rowid, 'account_number' => $obj->account_number, 'label' => $obj->label); return $result; } else { $this->error = "Error ".$this->db->lasterror(); dol_syslog(__METHOD__." ".$this->error, LOG_ERR); return -1; } } // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps /** * Description of accounting account * * @param string $account Accounting account * @return string|int Account desc or -1 if KO */ public function get_compte_desc($account = null) { // phpcs:enable global $conf; $pcgver = getDolGlobalInt('CHARTOFACCOUNTS'); $sql = "SELECT aa.account_number, aa.label, aa.rowid, aa.fk_pcg_version, cat.label as category"; $sql .= " FROM ".$this->db->prefix()."accounting_account as aa "; $sql .= " INNER JOIN ".$this->db->prefix()."accounting_system as asy ON aa.fk_pcg_version = asy.pcg_version"; $sql .= " AND aa.account_number = '".$this->db->escape($account)."'"; $sql .= " AND asy.rowid = ".((int) $pcgver); $sql .= " AND aa.active = 1"; $sql .= " LEFT JOIN ".$this->db->prefix()."c_accounting_category as cat ON aa.fk_accounting_category = cat.rowid"; $sql .= " WHERE aa.entity = " . ((int) $conf->entity); // Do not use getEntity for accounting features dol_syslog(get_class($this)."::select_account", LOG_DEBUG); $resql = $this->db->query($sql); if ($resql) { $obj = (object) array('label' => ''); if ($this->db->num_rows($resql)) { $obj = $this->db->fetch_object($resql); } if (empty($obj->category)) { return $obj->label; } else { return $obj->label.' ('.$obj->category.')'; } } else { $this->error = "Error ".$this->db->lasterror(); dol_syslog(__METHOD__." ".$this->error, LOG_ERR); return "-1"; } } /** * Get SQL string for check if the bookkeeping can be modified or deleted ? (cached) * * @param string $alias Bookkeeping alias table * @param bool $force Force reload * @return string|null SQL filter or null if error */ public function getCanModifyBookkeepingSQL($alias = '', $force = false) { global $conf; $alias = trim($alias); $alias = !empty($alias) && strpos($alias, '.') === false ? $alias . "." : $alias; if (!isset(self::$can_modify_bookkeeping_sql_cached[$alias]) || $force) { $result = $this->loadFiscalPeriods($force, 'active'); if ($result < 0) { return null; } $sql_list = array(); if (!empty($conf->cache['active_fiscal_period_cached']) && is_array($conf->cache['active_fiscal_period_cached'])) { $i = 0; foreach ($conf->cache['active_fiscal_period_cached'] as $fiscal_period) { $sql_list[$i] = "("; $sql_list[$i] .= "'".$this->db->idate($fiscal_period['date_start']) . "' <= ".$this->db->sanitize($alias)."doc_date"; if (!empty($fiscal_period['date_end'])) { $sql_list[$i] .= " AND "; $sql_list[$i] .= $this->db->sanitize($alias)."doc_date <= '" . $this->db->idate($fiscal_period['date_end'])."'"; } $sql_list[$i] .= ")"; $i++; } } $sqlsanitized = implode(' OR ', $sql_list); self::$can_modify_bookkeeping_sql_cached[$alias] = empty($sql_list) ? "" : " AND (".$sqlsanitized.")"; } return self::$can_modify_bookkeeping_sql_cached[$alias]; } /** * Is the bookkeeping can be modified or deleted ? * * @param int $id Bookkeeping ID * @param string $mode Mode ('' or 'tmp_') * @return int Return integer <0 if KO, == 0 if No, == 1 if Yes */ public function canModifyBookkeeping($id, $mode = '') { global $conf; if (getDolGlobalString('ACCOUNTANCY_FISCAL_PERIOD_MODE') == 'blockedonclosed') { $result = $this->loadFiscalPeriods(false, 'closed'); if ($result < 0) { return -1; } $bookkeeping = new BookKeeping($this->db); $result = $bookkeeping->fetch($id, null, $mode); if ($result <= 0) { return $result; } if (!empty($conf->cache['closed_fiscal_period_cached']) && is_array($conf->cache['closed_fiscal_period_cached'])) { foreach ($conf->cache['closed_fiscal_period_cached'] as $fiscal_period) { if ($fiscal_period['date_start'] <= $bookkeeping->doc_date && $bookkeeping->doc_date <= $fiscal_period['date_end']) { return 0; } } } return 1; } else { $result = $this->loadFiscalPeriods(false, 'active'); if ($result < 0) { return -1; } $bookkeeping = new BookKeeping($this->db); $result = $bookkeeping->fetch($id, null, $mode); if ($result <= 0) { return $result; } if (!empty($conf->cache['active_fiscal_period_cached']) && is_array($conf->cache['active_fiscal_period_cached'])) { foreach ($conf->cache['active_fiscal_period_cached'] as $fiscal_period) { if (!empty($fiscal_period['date_start']) && $fiscal_period['date_start'] <= $bookkeeping->doc_date && (empty($fiscal_period['date_end']) || $bookkeeping->doc_date <= $fiscal_period['date_end'])) { return 1; } } } return 0; } } /** * Generate label operation when operation is transferred into accounting according to ACCOUNTING_LABEL_OPERATION_ON_TRANSFER * If ACCOUNTING_LABEL_OPERATION_ON_TRANSFER is 0, we concat thirdparty name, ref and label. * If ACCOUNTING_LABEL_OPERATION_ON_TRANSFER is 1, we concat thirdparty name, ref. * If ACCOUNTING_LABEL_OPERATION_ON_TRANSFER is 2, we return just thirdparty name * * @param string $thirdpartyname Thirdparty name * @param string $reference Reference of the element * @param string $labelaccount Label of the accounting account * @param int<0,1> $full 0=Default, 1=Keep label intact (no trunc so HTML content is not corrupted) * @return string Label of the operation */ public function accountingLabelForOperation($thirdpartyname, $reference, $labelaccount, $full = 0) { $accountingLabelOperation = ''; if (!getDolGlobalInt('ACCOUNTING_LABEL_OPERATION_ON_TRANSFER')) { $truncThirdpartyName = 16; // Avoid trunc with dot in accountancy for the compatibility with another accounting software if (empty($full)) { $accountingLabelOperation = dol_trunc($thirdpartyname, $truncThirdpartyName, 'right', 'UTF-8', 1); } else { $accountingLabelOperation = $thirdpartyname; } if (!empty($reference)) { $accountingLabelOperation .= ' - '. $reference; } if (!empty($labelaccount)) { $accountingLabelOperation .= ' - '. $labelaccount; } } elseif (getDolGlobalInt('ACCOUNTING_LABEL_OPERATION_ON_TRANSFER') == 1) { $truncThirdpartyName = 32; // Avoid trunc with dot in accountancy for the compatibility with another accounting software if (empty($full)) { $accountingLabelOperation = dol_trunc($thirdpartyname, $truncThirdpartyName, 'right', 'UTF-8', 1); } else { $accountingLabelOperation = $thirdpartyname; } if (!empty($reference)) { $accountingLabelOperation .= ' - '. $reference; } } elseif (getDolGlobalInt('ACCOUNTING_LABEL_OPERATION_ON_TRANSFER') == 2) { $truncThirdpartyName = 64; // Avoid trunc with dot in accountancy for the compatibility with another accounting software if (empty($full)) { $accountingLabelOperation = dol_trunc($thirdpartyname, $truncThirdpartyName, 'right', 'UTF-8', 1); } else { $accountingLabelOperation = $thirdpartyname; } } return $accountingLabelOperation; } /** * Is the bookkeeping date valid (on an open period or not on a closed period) ? * * @param int $date Bookkeeping date * @return int Return integer <0 if KO, == 0 if No, == 1 if date is valid for a transfer */ public function validBookkeepingDate($date) { global $conf; if (getDolGlobalString('ACCOUNTANCY_FISCAL_PERIOD_MODE') == 'blockedonclosed') { $result = $this->loadFiscalPeriods(false, 'closed'); if ($result < 0) { return -1; } if (!empty($conf->cache['closed_fiscal_period_cached']) && is_array($conf->cache['closed_fiscal_period_cached'])) { foreach ($conf->cache['closed_fiscal_period_cached'] as $fiscal_period) { if ($fiscal_period['date_start'] <= $date && $date <= $fiscal_period['date_end']) { return 0; } } } return 1; } else { $result = $this->loadFiscalPeriods(false, 'active'); if ($result < 0) { return -1; } if (!empty($conf->cache['active_fiscal_period_cached']) && is_array($conf->cache['active_fiscal_period_cached'])) { foreach ($conf->cache['active_fiscal_period_cached'] as $fiscal_period) { if (!empty($fiscal_period['date_start']) && $fiscal_period['date_start'] <= $date && (empty($fiscal_period['date_end']) || $date <= $fiscal_period['date_end'])) { return 1; } } } return 0; } } /** * Load list of active fiscal period * * @param bool $force Force reload * @param string $mode active or closed ? * @return int Return integer <0 if KO, >0 if OK */ public function loadFiscalPeriods($force = false, $mode = 'active') { global $conf; if ($mode == 'active') { if (!isset($conf->cache['active_fiscal_period_cached']) || $force) { $sql = "SELECT date_start, date_end"; $sql .= " FROM " . $this->db->prefix() . "accounting_fiscalyear"; $sql .= " WHERE entity = " . ((int) $conf->entity); $sql .= " AND statut = 0"; $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = $this->db->lasterror(); return -1; } $list = array(); while ($obj = $this->db->fetch_object($resql)) { $list[] = array( 'date_start' => $this->db->jdate($obj->date_start), 'date_end' => $this->db->jdate($obj->date_end), ); } $conf->cache['active_fiscal_period_cached'] = $list; } } if ($mode == 'closed') { if (!isset($conf->cache['closed_fiscal_period_cached']) || $force) { $sql = "SELECT date_start, date_end"; $sql .= " FROM " . $this->db->prefix() . "accounting_fiscalyear"; $sql .= " WHERE entity = " . ((int) $conf->entity); $sql .= " AND statut = 1"; $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = $this->db->lasterror(); return -1; } $list = array(); while ($obj = $this->db->fetch_object($resql)) { $list[] = array( 'date_start' => $this->db->jdate($obj->date_start), 'date_end' => $this->db->jdate($obj->date_end), ); } $conf->cache['closed_fiscal_period_cached'] = $list; } } return 1; } /** * Get list of fiscal period ordered by start date. * * @return array|int Return integer <0 if KO, Fiscal periods : [[id, date_start, date_end, label], ...] */ public function getFiscalPeriods() { global $conf; $list = array(); $sql = "SELECT rowid, label, date_start, date_end, statut"; $sql .= " FROM " . $this->db->prefix() . "accounting_fiscalyear"; $sql .= " WHERE entity = " . ((int) $conf->entity); $sql .= $this->db->order('date_start', 'ASC'); $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = $this->db->lasterror(); return -1; } while ($obj = $this->db->fetch_object($resql)) { $list[$obj->rowid] = array( 'id' => (int) $obj->rowid, 'label' => $obj->label, 'date_start' => $this->db->jdate($obj->date_start), 'date_end' => $this->db->jdate($obj->date_end), 'status' => (int) $obj->statut, ); } return $list; } /** * Get list of count by month into the fiscal period. * This function can be called by step 1 of closure process. * * @param int $date_start Date start * @param int $date_end Date end * @return array{total:int,list:array,int>,total:int}>}|int<-1,-1> Return integer <0 if KO, Fiscal periods : [[id, date_start, date_end, label], ...] */ public function getCountByMonthForFiscalPeriod($date_start, $date_end) { global $conf; $total = 0; $list = array(); $sql = "SELECT YEAR(b.doc_date) as year"; for ($i = 1; $i <= 12; $i++) { $sql .= ", SUM(".$this->db->ifsql("MONTH(b.doc_date) = ".((int) $i), "1", "0") . ") AS month".((int) $i); } $sql .= ", COUNT(b.rowid) as total"; $sql .= " FROM " . $this->db->prefix() . $this->table_element . " as b"; $sql .= " WHERE b.doc_date >= '" . $this->db->idate($date_start) . "'"; $sql .= " AND b.doc_date <= '" . $this->db->idate($date_end) . "'"; $sql .= " AND b.entity IN (" . getEntity('bookkeeping', 0) . ")"; // We don't share object for accountancy // Get count for each month into the fiscal period if (getDolGlobalString("ACCOUNTANCY_DISABLE_CLOSURE_LINE_BY_LINE")) { // Loop on each closed period $sql .= " AND NOT EXISTS (SELECT rowid FROM ".MAIN_DB_PREFIX.'accounting_fiscalyear as af WHERE b.doc_date >= af.date_start AND b.doc_date <= af.date_end AND af.entity = '.((int) $conf->entity)." AND af.statut = 1)"; } else { // Filter on the unitary flag/date lock on each record $sql .= " AND date_validated IS NULL"; // not locked } $sql .= " GROUP BY YEAR(b.doc_date)"; $sql .= $this->db->order("year", 'ASC'); dol_syslog(__METHOD__, LOG_DEBUG); $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = $this->db->lasterror(); return -1; } while ($obj = $this->db->fetch_object($resql)) { $total += (int) $obj->total; $year_list = array( 'year' => (int) $obj->year, 'count' => array(), 'total' => (int) $obj->total, ); for ($i = 1; $i <= 12; $i++) { $year_list['count'][$i] = (int) $obj->{'month' . $i}; } $list[] = $year_list; } $this->db->free($resql); return array( 'total' => $total, 'list' => $list, ); } /** * Validate all movement between the specified dates * * @param int $date_start Date start * @param int $date_end Date end * @return int int Return integer <0 if KO, >0 if OK */ public function validateMovementForFiscalPeriod($date_start, $date_end) { global $conf; $now = dol_now(); // Specify as export : update field date_validated on selected month/year $sql = " UPDATE " . $this->db->prefix() . $this->table_element; $sql .= " SET date_validated = '" . $this->db->idate($now) . "'"; $sql .= " WHERE entity = " . ((int) $conf->entity); $sql .= " AND DATE(doc_date) >= '" . $this->db->idate($date_start) . "'"; $sql .= " AND DATE(doc_date) <= '" . $this->db->idate($date_end) . "'"; $sql .= " AND date_validated IS NULL"; dol_syslog(__METHOD__, LOG_DEBUG); $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = $this->db->lasterror(); return -1; } return 1; } /** * Define accounting result * * @param int $date_start Date start * @param int $date_end Date end * @return string Accounting result */ public function accountingResult($date_start, $date_end) { global $conf; $this->db->begin(); $income_statement_amount = 0; if (getDolGlobalString('ACCOUNTING_CLOSURE_ACCOUNTING_GROUPS_USED_FOR_INCOME_STATEMENT')) { $accounting_groups_used_for_income_statement = array_filter(array_map('trim', explode(',', getDolGlobalString('ACCOUNTING_CLOSURE_ACCOUNTING_GROUPS_USED_FOR_INCOME_STATEMENT'))), 'strlen'); $pcg_type_filter = array(); foreach ($accounting_groups_used_for_income_statement as $item) { $pcg_type_filter[] = "'" . $this->db->escape($item) . "'"; } $sql = 'SELECT'; $sql .= " t.numero_compte,"; $sql .= " aa.pcg_type,"; $sql .= " (SUM(t.credit) - SUM(t.debit)) as accounting_result"; $sql .= ' FROM ' . $this->db->prefix() . $this->table_element . ' as t'; $sql .= ' LEFT JOIN ' . $this->db->prefix() . 'accounting_account as aa ON aa.account_number = t.numero_compte'; $sql .= ' WHERE t.entity = ' . ((int) $conf->entity); // Do not use getEntity for accounting features $sql .= " AND aa.entity = " . ((int) $conf->entity); $sql .= ' AND aa.fk_pcg_version IN (SELECT pcg_version FROM ' . $this->db->prefix() . 'accounting_system WHERE rowid = ' . ((int) getDolGlobalInt('CHARTOFACCOUNTS')) . ')'; $sql .= ' AND aa.pcg_type IN (' . $this->db->sanitize(implode(',', $pcg_type_filter), 1) . ')'; $sql .= " AND DATE(t.doc_date) >= '" . $this->db->idate($date_start) . "'"; $sql .= " AND DATE(t.doc_date) <= '" . $this->db->idate($date_end) . "'"; $sql .= ' GROUP BY t.numero_compte, aa.pcg_type'; $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = 'Error ' . $this->db->lasterror(); dol_syslog(__METHOD__ . ' ' . implode(',', $this->errors), LOG_ERR); } else { while ($obj = $this->db->fetch_object($resql)) { $income_statement_amount += $obj->accounting_result; } } } return (string) $income_statement_amount; } /** * Close fiscal period * * @param int $fiscal_period_id Fiscal year ID * @param int $new_fiscal_period_id New fiscal year ID * @param bool $separate_auxiliary_account Separate auxiliary account * @param bool $generate_bookkeeping_records Generate closure bookkeeping records * @return int int Return integer <0 if KO, >0 if OK */ public function closeFiscalPeriod($fiscal_period_id, $new_fiscal_period_id, $separate_auxiliary_account = false, $generate_bookkeeping_records = true) { global $conf, $langs, $user; // Current fiscal period $fiscal_period_id = max(0, $fiscal_period_id); if (empty($fiscal_period_id)) { $langs->load('errors'); $this->errors[] = $langs->trans('ErrorBadParameters'); return -1; } $fiscal_period = new Fiscalyear($this->db); $result = $fiscal_period->fetch($fiscal_period_id); if ($result < 0) { $this->error = $fiscal_period->error; $this->errors = $fiscal_period->errors; return -1; } elseif (empty($fiscal_period->id)) { $langs->loadLangs(array('errors', 'compta')); $this->errors[] = $langs->trans('ErrorRecordNotFound') . ' - ' . $langs->trans('FiscalPeriod') . ' (' . $fiscal_period_id . ')'; return -1; } // New fiscal period $new_fiscal_period_id = max(0, $new_fiscal_period_id); if (empty($new_fiscal_period_id)) { $langs->load('errors'); $this->errors[] = $langs->trans('ErrorBadParameters'); return -1; } $new_fiscal_period = new Fiscalyear($this->db); $result = $new_fiscal_period->fetch($new_fiscal_period_id); if ($result < 0) { $this->error = $new_fiscal_period->error; $this->errors = $new_fiscal_period->errors; return -1; } elseif (empty($new_fiscal_period->id)) { $langs->loadLangs(array('errors', 'compta')); $this->errors[] = $langs->trans('ErrorRecordNotFound') . ' - ' . $langs->trans('FiscalPeriod') . ' (' . $new_fiscal_period_id . ')'; return -1; } $error = 0; $this->db->begin(); $fiscal_period->statut = Fiscalyear::STATUS_CLOSED; $fiscal_period->status = Fiscalyear::STATUS_CLOSED; // Actually not used $result = $fiscal_period->update($user); if ($result < 0) { $this->error = $fiscal_period->error; $this->errors = $fiscal_period->errors; $error++; } if (!$error && !empty($generate_bookkeeping_records)) { $journal_id = max(0, getDolGlobalString('ACCOUNTING_CLOSURE_DEFAULT_JOURNAL')); if (empty($journal_id)) { $langs->loadLangs(array('errors', 'accountancy')); $this->errors[] = $langs->trans('ErrorBadParameters') . ' - ' . $langs->trans('Codejournal') . ' (' . $langs->trans('AccountingJournalType9') . ')'; $error++; } // Fetch journal if (!$error) { $journal = new AccountingJournal($this->db); $result = $journal->fetch($journal_id); if ($result < 0) { $this->error = $journal->error; $this->errors = $journal->errors; $error++; } elseif ($result == 0) { $langs->loadLangs(array('errors', 'accountancy')); $this->errors[] = $langs->trans('ErrorRecordNotFound') . ' - ' . $langs->trans('Codejournal') . ' (' . $langs->trans('AccountingJournalType9') . ')'; $error++; } } else { $journal = null; } if (!$error && is_object($journal)) { $accounting_groups_used_for_balance_sheet_account = array_filter(array_map('trim', explode(',', getDolGlobalString('ACCOUNTING_CLOSURE_ACCOUNTING_GROUPS_USED_FOR_BALANCE_SHEET_ACCOUNT'))), 'strlen'); $accounting_groups_used_for_income_statement = array_filter(array_map('trim', explode(',', getDolGlobalString('ACCOUNTING_CLOSURE_ACCOUNTING_GROUPS_USED_FOR_INCOME_STATEMENT'))), 'strlen'); $pcg_type_filter = array(); $tmp = array_merge($accounting_groups_used_for_balance_sheet_account, $accounting_groups_used_for_income_statement); foreach ($tmp as $item) { $pcg_type_filter[] = "'" . $this->db->escape($item) . "'"; } $sql = 'SELECT'; $sql .= " t.numero_compte,"; if ($separate_auxiliary_account) { $sql .= " NULLIF(t.subledger_account, '') as subledger_account,"; // fix db issues with Null or "" values } $sql .= " aa.pcg_type,"; $sql .= " (SUM(t.credit) - SUM(t.debit)) as opening_balance"; $sql .= ' FROM ' . $this->db->prefix() . $this->table_element . ' as t'; $sql .= ' LEFT JOIN ' . $this->db->prefix() . 'accounting_account as aa ON aa.account_number = t.numero_compte'; $sql .= ' WHERE t.entity = ' . ((int) $conf->entity); // Do not use getEntity for accounting features $sql .= " AND aa.entity = ". ((int) $conf->entity); $sql .= ' AND aa.fk_pcg_version IN (SELECT pcg_version FROM '.$this->db->prefix().'accounting_system WHERE rowid = '.((int) getDolGlobalInt('CHARTOFACCOUNTS')).')'; $sql .= ' AND aa.pcg_type IN (' . $this->db->sanitize(implode(',', $pcg_type_filter), 1) . ')'; $sql .= " AND DATE(t.doc_date) >= '" . $this->db->idate($fiscal_period->date_start) . "'"; $sql .= " AND DATE(t.doc_date) <= '" . $this->db->idate($fiscal_period->date_end) . "'"; $sql .= ' GROUP BY t.numero_compte, aa.pcg_type'; if ($separate_auxiliary_account) { $sql .= " , NULLIF(t.subledger_account, '')"; } $sql .= ' HAVING (SUM(t.credit) - SUM(t.debit)) != 0 '; // Exclude rows with opening_balance = 0 $sql .= $this->db->order("t.numero_compte", "ASC"); $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = 'Error ' . $this->db->lasterror(); dol_syslog(__METHOD__ . ' ' . implode(',', $this->errors), LOG_ERR); $error++; } else { $now = dol_now(); $income_statement_amount = 0; while ($obj = $this->db->fetch_object($resql)) { if (in_array($obj->pcg_type, $accounting_groups_used_for_income_statement)) { $income_statement_amount += $obj->opening_balance; } else { // Insert bookkeeping record for balance sheet account $mt = $obj->opening_balance; $bookkeeping = new BookKeeping($this->db); $bookkeeping->doc_date = $new_fiscal_period->date_start; $bookkeeping->date_lim_reglement = ''; $bookkeeping->doc_ref = $fiscal_period->label; $bookkeeping->date_creation = $now; $bookkeeping->doc_type = 'closure'; $bookkeeping->fk_doc = $fiscal_period->id; $bookkeeping->fk_docdet = 0; // Useless, can be several lines that are source of this record to add $bookkeeping->thirdparty_code = ''; if ($separate_auxiliary_account) { $bookkeeping->subledger_account = $obj->subledger_account; $sql = 'SELECT'; $sql .= " subledger_label"; $sql .= " FROM " . MAIN_DB_PREFIX . $this->table_element; $sql .= " WHERE subledger_account = '" . $this->db->escape($obj->subledger_account) . "'"; $sql .= " ORDER BY doc_date DESC"; $sql .= " LIMIT 1"; $result = $this->db->query($sql); if (!$result) { $this->errors[] = 'Error: ' . $this->db->lasterror(); dol_syslog(__METHOD__ . ' ' . implode(',', $this->errors), LOG_ERR); $error++; } $objtmp = $this->db->fetch_object($result); $bookkeeping->subledger_label = $objtmp->subledger_label; // latest subledger label used } else { $bookkeeping->subledger_account = null; $bookkeeping->subledger_label = null; } $bookkeeping->numero_compte = $obj->numero_compte; $accountingaccount = new AccountingAccount($this->db); $accountingaccount->fetch(0, $obj->numero_compte); $bookkeeping->label_compte = $accountingaccount->label; // latest account label used $bookkeeping->label_operation = $new_fiscal_period->label; $bookkeeping->montant = $mt; $bookkeeping->sens = ($mt >= 0) ? 'C' : 'D'; $bookkeeping->debit = ($mt < 0) ? -$mt : 0; $bookkeeping->credit = ($mt >= 0) ? $mt : 0; $bookkeeping->code_journal = $journal->code; $bookkeeping->journal_label = $langs->transnoentities($journal->label); $bookkeeping->fk_user_author = $user->id; $bookkeeping->entity = $conf->entity; $result = $bookkeeping->create($user); if ($result < 0) { $this->setErrorsFromObject($bookkeeping); $error++; break; } } } // Insert bookkeeping record for income statement if (!$error && $income_statement_amount != 0) { $mt = $income_statement_amount; $accountingaccount = new AccountingAccount($this->db); $accountingaccount->fetch(0, getDolGlobalString($income_statement_amount < 0 ? 'ACCOUNTING_RESULT_LOSS' : 'ACCOUNTING_RESULT_PROFIT'), true); $bookkeeping = new BookKeeping($this->db); $bookkeeping->doc_date = $new_fiscal_period->date_start; $bookkeeping->date_lim_reglement = ''; $bookkeeping->doc_ref = $fiscal_period->label; $bookkeeping->date_creation = $now; $bookkeeping->doc_type = 'closure'; $bookkeeping->fk_doc = $fiscal_period->id; $bookkeeping->fk_docdet = 0; // Useless, can be several lines that are source of this record to add $bookkeeping->thirdparty_code = ''; if ($separate_auxiliary_account) { $bookkeeping->subledger_account = $obj->subledger_account; $sql = 'SELECT'; $sql .= " subledger_label"; $sql .= " FROM " . MAIN_DB_PREFIX . $this->table_element; $sql .= " WHERE subledger_account = '" . $this->db->escape($obj->subledger_account) . "'"; $sql .= " ORDER BY doc_date DESC"; $sql .= " LIMIT 1"; $result = $this->db->query($sql); if (!$result) { $this->errors[] = 'Error: ' . $this->db->lasterror(); dol_syslog(__METHOD__ . ' ' . implode(',', $this->errors), LOG_ERR); $error++; } $objtmp = $this->db->fetch_object($result); $bookkeeping->subledger_label = $objtmp->subledger_label ?? null; // latest subledger label used } else { $bookkeeping->subledger_account = null; $bookkeeping->subledger_label = null; } $bookkeeping->numero_compte = $accountingaccount->account_number; $bookkeeping->label_compte = $accountingaccount->label; $bookkeeping->label_operation = $new_fiscal_period->label; $bookkeeping->montant = $mt; $bookkeeping->sens = ($mt >= 0) ? 'C' : 'D'; $bookkeeping->debit = ($mt < 0) ? -$mt : 0; $bookkeeping->credit = ($mt >= 0) ? $mt : 0; $bookkeeping->code_journal = $journal->code; $bookkeeping->journal_label = $langs->transnoentities($journal->label); $bookkeeping->fk_user_author = $user->id; $bookkeeping->entity = $conf->entity; $result = $bookkeeping->create($user); if ($result < 0) { $this->setErrorsFromObject($bookkeeping); $error++; } } $this->db->free($resql); } } } if ($error) { $this->db->rollback(); return -1; } else { $this->db->commit(); return 1; } } /** * Insert accounting reversal into the inventory journal of the new fiscal period * * @param int $fiscal_period_id Fiscal year ID * @param int $inventory_journal_id Inventory journal ID * @param int $new_fiscal_period_id New fiscal year ID * @param int $date_start Date start * @param int $date_end Date end * @return int int Return integer <0 if KO, >0 if OK */ public function insertAccountingReversal($fiscal_period_id, $inventory_journal_id, $new_fiscal_period_id, $date_start, $date_end) { global $conf, $langs, $user; // Current fiscal period $fiscal_period_id = max(0, $fiscal_period_id); if (empty($fiscal_period_id)) { $langs->load('errors'); $this->errors[] = $langs->trans('ErrorBadParameters'); return -1; } $fiscal_period = new Fiscalyear($this->db); $result = $fiscal_period->fetch($fiscal_period_id); if ($result < 0) { $this->error = $fiscal_period->error; $this->errors = $fiscal_period->errors; return -1; } elseif (empty($fiscal_period->id)) { $langs->loadLangs(array('errors', 'compta')); $this->errors[] = $langs->trans('ErrorRecordNotFound') . ' - ' . $langs->trans('FiscalPeriod') . ' (' . $fiscal_period_id . ')'; return -1; } // New fiscal period $new_fiscal_period_id = max(0, $new_fiscal_period_id); if (empty($new_fiscal_period_id)) { $langs->load('errors'); $this->errors[] = $langs->trans('ErrorBadParameters'); return -1; } $new_fiscal_period = new Fiscalyear($this->db); $result = $new_fiscal_period->fetch($new_fiscal_period_id); if ($result < 0) { $this->error = $new_fiscal_period->error; $this->errors = $new_fiscal_period->errors; return -1; } elseif (empty($new_fiscal_period->id)) { $langs->loadLangs(array('errors', 'compta')); $this->errors[] = $langs->trans('ErrorRecordNotFound') . ' - ' . $langs->trans('FiscalPeriod') . ' (' . $new_fiscal_period_id . ')'; return -1; } // Inventory journal $inventory_journal_id = max(0, $inventory_journal_id); if (empty($inventory_journal_id)) { $langs->load('errors'); $this->errors[] = $langs->trans('ErrorBadParameters'); return -1; } // Fetch journal $inventory_journal = new AccountingJournal($this->db); $result = $inventory_journal->fetch($inventory_journal_id); if ($result < 0) { $this->error = $inventory_journal->error; $this->errors = $inventory_journal->errors; return -1; } elseif ($result == 0) { $langs->loadLangs(array('errors', 'accountancy')); $this->errors[] = $langs->trans('ErrorRecordNotFound') . ' - ' . $langs->trans('InventoryJournal'); return -1; } $error = 0; $this->db->begin(); $sql = 'SELECT t.rowid'; $sql .= ' FROM ' . $this->db->prefix() . $this->table_element . ' as t'; $sql .= ' WHERE t.entity = ' . ((int) $conf->entity); // Do not use getEntity for accounting features $sql .= " AND code_journal = '" . $this->db->escape($inventory_journal->code) . "'"; $sql .= " AND DATE(t.doc_date) >= '" . $this->db->idate($date_start) . "'"; $sql .= " AND DATE(t.doc_date) <= '" . $this->db->idate($date_end) . "'"; $sql .= " AND DATE(t.doc_date) >= '" . $this->db->idate($fiscal_period->date_start) . "'"; $sql .= " AND DATE(t.doc_date) <= '" . $this->db->idate($fiscal_period->date_end) . "'"; $resql = $this->db->query($sql); if (!$resql) { $this->errors[] = 'Error ' . $this->db->lasterror(); dol_syslog(__METHOD__ . ' ' . implode(',', $this->errors), LOG_ERR); $error++; } else { $now = dol_now(); while ($obj = $this->db->fetch_object($resql)) { $bookkeeping = new BookKeeping($this->db); $result = $bookkeeping->fetch($obj->rowid); if ($result < 0) { $this->error = $inventory_journal->error; $this->errors = $inventory_journal->errors; $error++; break; } elseif ($result == 0) { $langs->loadLangs(array('errors', 'accountancy')); $this->errors[] = $langs->trans('ErrorRecordNotFound') . ' - ' . $langs->trans('LineId') . ': ' . $obj->rowid; $error++; break; } $bookkeeping->id = 0; $bookkeeping->doc_date = $new_fiscal_period->date_start; $bookkeeping->doc_ref = $new_fiscal_period->label; $bookkeeping->date_creation = $now; $bookkeeping->doc_type = 'accounting_reversal'; $bookkeeping->fk_doc = $new_fiscal_period->id; $bookkeeping->fk_docdet = 0; // Useless, can be several lines that are source of this record to add $bookkeeping->montant = -$bookkeeping->montant; $bookkeeping->sens = ($bookkeeping->montant >= 0) ? 'C' : 'D'; $old_debit = $bookkeeping->debit; $bookkeeping->debit = $bookkeeping->credit; $bookkeeping->credit = $old_debit; $bookkeeping->fk_user_author = $user->id; $bookkeeping->entity = $conf->entity; $result = $bookkeeping->create($user); if ($result < 0) { $this->error = $bookkeeping->error; $this->errors = $bookkeeping->errors; $error++; break; } } $this->db->free($resql); } if ($error) { $this->db->rollback(); return -1; } else { $this->db->commit(); return 1; } } /** * Mass account assignment * * @param int[] $toselect Array of BookkeepingId * @param int $accounting_account ID of accounting account define for mass action * @return int int Return integer -1 if KO, 1 if OK */ public function assignAccountMass($toselect, $accounting_account = 0) { global $langs, $user; $error = 0; $this->db->begin(); $bookkeeping = new BookKeeping($this->db); $accountingaccount = new AccountingAccount($this->db); $nb = 0; if ((int) $accounting_account > 0) { $accountingaccount->fetch($accounting_account); $echecT = []; foreach ($toselect as $id) { if ($bookkeeping->fetch($id)) { if ( !getDolGlobalString('ACCOUNTING_ACCOUNT_CUSTOMER')) { $accountcustcode = '411'; } else $accountcustcode = getDolGlobalString('ACCOUNTING_ACCOUNT_CUSTOMER'); if ( !getDolGlobalString('ACCOUNTING_ACCOUNT_SUPPLIER')) { $accountsuppcode = '401'; } else $accountsuppcode = getDolGlobalString('ACCOUNTING_ACCOUNT_SUPPLIER'); if (strpos($bookkeeping->numero_compte, $accountcustcode) === 0 || strpos($bookkeeping->numero_compte, $accountsuppcode) === 0) { $echecT[]=$bookkeeping->numero_compte; continue; } $bookkeeping->numero_compte = $accountingaccount->account_number; $bookkeeping->label_compte = $accountingaccount->label; $result = $bookkeeping->update($user); if ($result > 0) { $nb++; } else { setEventMessages($bookkeeping->error, $bookkeeping->errors, 'errors'); $error++; break; } } } $echecImplode = implode(",", $echecT); } else { setEventMessages($langs->trans('NoAccountSelected'), null, 'errors'); $error++; $this->db->rollback(); } if ($nb > 1) { setEventMessages($nb ." " . $langs->trans('AssignAccountsSuccess'), null, 'mesgs'); } elseif ($nb > 0) { setEventMessages($nb ." " . $langs->trans('AssignAccountSuccess'), null, 'mesgs'); } else { setEventMessages($langs->trans('AssignAccountError'), null, 'errors'); $error++; } if (!empty($echecImplode)) { $nbEchec = count(explode(',', $echecImplode)); setEventMessages($nbEchec == 1 ? $langs->trans('NoAccountChangedWithAccountNumber') . ' ' . $echecImplode : $langs->trans('NoAccountsChangedWithAccountNumber') . ' ' . $echecImplode, null, 'errors' ); } if ($error) { $this->db->rollback(); return -1; } else { $this->db->commit(); return 1; } } /** * Clone accounting entry * * @param string $piecenum Piece number to clone * @param string $code_journal Accounting journal code * @param int $docdate Date of the document * @return int int Return integer -1 if KO, 1 if OK */ public function newClone($piecenum, $code_journal, $docdate) { global $langs; $error = 0; $accountingJournal = new AccountingJournal($this->db); $accountingJournal->fetch(0, $code_journal); $bookKeepingValid = new BookKeeping($this->db); $periodeFiscal = $bookKeepingValid->validBookkeepingDate($docdate); if ($periodeFiscal < 0) { $error++; return -1; } elseif ($periodeFiscal == 0) { if (getDolGlobalString('ACCOUNTANCY_FISCAL_PERIOD_MODE') == 'blockedonclosed') { setEventMessages($langs->trans('ErrorBookkeepingDocDateIsOnAClosedFiscalPeriod'), null, 'errors'); } else { setEventMessages($langs->trans('ErrorBookkeepingDocDateNotOnActiveFiscalPeriod'), null, 'errors'); header("Location: " . $_SERVER['HTTP_REFERER']); } $error++; return -1; } $this->db->begin(); $bookKeepingInstance = new BookKeeping($this->db); $pieceNumNext = $bookKeepingInstance->getNextNumMvt(); $cloneId = []; $sqlRowidClone = "SELECT rowid FROM " . MAIN_DB_PREFIX . "accounting_bookkeeping WHERE piece_num = ".((int) $piecenum); $resqlRowidClone = $this->db->query($sqlRowidClone); if ($resqlRowidClone) { while ($objRowidClone = $this->db->fetch_object($resqlRowidClone)) { $cloneId[] = $objRowidClone->rowid; } foreach ($cloneId as $toselectid) { $bookKeeping = new BookKeeping($this->db); if ($bookKeeping->fetch($toselectid)) { $code_journal = getDolGlobalString('ACCOUNTING_CLONING_ENABLE_INPUT_JOURNAL') ? $code_journal : $bookKeeping->code_journal; $journal_label = getDolGlobalString('ACCOUNTING_CLONING_ENABLE_INPUT_JOURNAL') ? $accountingJournal->label : $bookKeeping->journal_label; $sql = "SELECT piece_num, label_operation, numero_compte, label_compte, doc_type, code_journal, fk_user_author, doc_ref,"; $sql .= " fk_doc, fk_docdet, debit, credit, journal_label, sens, montant"; $sql .= " FROM " . MAIN_DB_PREFIX . "accounting_bookkeeping"; $sql .= " WHERE rowid = " . ((int) $toselectid); $resql = $this->db->query($sql); if ($resql) { while ($obj = $this->db->fetch_object($resql)) { $docRef = $langs->trans('CloneOf', $obj->doc_ref); $sql_insert = "INSERT INTO " . MAIN_DB_PREFIX . "accounting_bookkeeping"; $sql_insert .= " (piece_num, label_operation, numero_compte, label_compte, doc_type, code_journal, doc_date, fk_user_author, doc_ref,"; $sql_insert .= " fk_doc, fk_docdet, debit, credit, date_creation, journal_label, sens, montant)"; $sql_insert .= " VALUES"; $sql_insert .= " (" . ((int) $pieceNumNext) . ", '" . $this->db->escape($obj->label_operation) . "', '" . $this->db->escape($obj->numero_compte) . "', '" . $this->db->escape($obj->label_compte) . "', '" . $this->db->escape($obj->doc_type) . "', '" . $this->db->escape($code_journal) . "', '" . $this->db->idate($docdate) . "', '" . $this->db->escape($obj->fk_user_author) . "', '" . $this->db->escape($docRef) . "', "; $sql_insert .= " ". ((int) $obj->fk_doc) . ", " . ((int) $obj->fk_docdet) . ", " . (float) $obj->debit . ", " . (float) $obj->credit . ", '" . $this->db->idate($docdate) . "', '" . $this->db->escape($journal_label) . "', '" . $this->db->escape($obj->sens) . "', " . (float) $obj->montant . ")"; $resqlInsert = $this->db->query($sql_insert); if ($resqlInsert) { setEventMessages($langs->trans('CloningSuccess', $pieceNumNext), null, 'mesgs'); } else { setEventMessages($langs->trans('CloningFailed') . $this->db->lasterror(), null, 'errors'); $error++; } } } } } } if ($error) { $this->db->rollback(); return -1; } else { $this->db->commit(); return 1; } } /** * Mass clone * * @param int[] $toselect array of BookkeepingId * @param string $code_journal Accounting journal code * @param int $docdate Date of the document * @return int Return integer -1 if KO, 1 if OK */ public function newCloneMass($toselect, $code_journal, $docdate) { global $langs, $user; $error = 0; $this->db->begin(); $now = dol_now(); if (empty($docdate)) { $docdate = $now; } $idImplodeSelect = implode(',', $toselect); $pieceNumT = []; $sqlPieceNum = "SELECT DISTINCT(piece_num) FROM " . MAIN_DB_PREFIX . "accounting_bookkeeping WHERE rowid IN (".$this->db->sanitize($idImplodeSelect).")"; $resqlPieceNum = $this->db->query($sqlPieceNum); if ($resqlPieceNum) { while ($objPieceNum = $this->db->fetch_object($resqlPieceNum)) { $pieceNumT[] = $objPieceNum->piece_num; } foreach ($pieceNumT as $pieceNum) { $accountingJournal = new AccountingJournal($this->db); $accountingJournal->fetch(0, $code_journal); $bookKeepingValid = new BookKeeping($this->db); $periodeFiscal = $bookKeepingValid->validBookkeepingDate($docdate); if ($periodeFiscal < 0) { $error++; } elseif ($periodeFiscal == 0) { if (getDolGlobalString('ACCOUNTANCY_FISCAL_PERIOD_MODE') == 'blockedonclosed') { setEventMessages($langs->trans('ErrorBookkeepingDocDateIsOnAClosedFiscalPeriod'), null, 'errors'); } else { setEventMessages($langs->trans('ErrorBookkeepingDocDateNotOnActiveFiscalPeriod'), null, 'errors'); header("Location: " . $_SERVER['HTTP_REFERER']); } $error++; } $bookKeepingInstance = new BookKeeping($this->db); $pieceNumNext = $bookKeepingInstance->getNextNumMvt(); $cloneId = []; $sqlRowidClone = "SELECT rowid FROM " . MAIN_DB_PREFIX . "accounting_bookkeeping WHERE piece_num = $pieceNum"; $resqlRowidClone = $this->db->query($sqlRowidClone); if ($resqlRowidClone) { while ($objRowidClone = $this->db->fetch_object($resqlRowidClone)) { $cloneId[] = $objRowidClone->rowid; } foreach ($cloneId as $toselectid) { $bookKeeping = new BookKeeping($this->db); if ($bookKeeping->fetch($toselectid)) { $code_journal = getDolGlobalString('ACCOUNTING_CLONING_ENABLE_INPUT_JOURNAL') ? $code_journal : $bookKeeping->code_journal; $journal_label = getDolGlobalString('ACCOUNTING_CLONING_ENABLE_INPUT_JOURNAL') ? $accountingJournal->label : $bookKeeping->journal_label; $sql = "SELECT piece_num, label_operation, numero_compte, label_compte, subledger_account, subledger_label, doc_type, code_journal, fk_user_author, doc_ref, fk_doc, fk_docdet, debit, credit, journal_label, sens, montant"; $sql .= " FROM ".$this->db->prefix()."accounting_bookkeeping WHERE rowid = " . ((int) $toselectid); $resql = $this->db->query($sql); if ($resql) { while ($obj = $this->db->fetch_object($resql)) { $docRef = $langs->trans("CloneOf", $obj->doc_ref); $sql_insert = "INSERT INTO ".$this->db->prefix()."accounting_bookkeeping ("; $sql_insert .= " piece_num"; $sql_insert .= ", label_operation"; $sql_insert .= ", numero_compte"; $sql_insert .= ", label_compte"; $sql_insert .= ", subledger_account"; $sql_insert .= ", subledger_label"; $sql_insert .= ", doc_type"; $sql_insert .= ", code_journal"; $sql_insert .= ", doc_date"; $sql_insert .= ", date_creation"; $sql_insert .= ", fk_user_author"; $sql_insert .= ", doc_ref"; $sql_insert .= ", fk_doc"; $sql_insert .= ", fk_docdet"; $sql_insert .= ", debit"; $sql_insert .= ", credit"; $sql_insert .= ", journal_label"; $sql_insert .= ", sens"; $sql_insert .= ", montant"; $sql_insert .= ")"; $sql_insert .= " VALUES ("; $sql_insert .= $pieceNumNext; $sql_insert .= ", '" . $this->db->escape($obj->label_operation) . "'"; $sql_insert .= ", '" . $this->db->escape($obj->numero_compte) . "'"; $sql_insert .= ", '" . $this->db->escape($obj->label_compte) . "'"; $sql_insert .= ", '" . $this->db->escape($obj->subledger_account) . "'"; $sql_insert .= ", '" . $this->db->escape($obj->subledger_label) . "'"; $sql_insert .= ", ''"; $sql_insert .= ", '" . $this->db->escape($code_journal) . "'"; $sql_insert .= ", '" . $this->db->idate($docdate)."'"; $sql_insert .= ", '" . $this->db->idate($now)."'"; $sql_insert .= ", ".($user->id > 0 ? ((int) $user->id) : "NULL"); $sql_insert .= ", '" . $this->db->escape($docRef) . "'"; $sql_insert .= ", 0"; $sql_insert .= ", 0"; $sql_insert .= ", " . (float) $obj->debit; $sql_insert .= ", " . (float) $obj->credit; $sql_insert .= ", '" . $this->db->escape($journal_label) . "'"; $sql_insert .= ", '" . $this->db->escape($obj->sens) . "'"; $sql_insert .= ", " . (float) $obj->montant; $sql_insert .= ")"; $resqlInsert = $this->db->query($sql_insert); if ($resqlInsert) { setEventMessages($langs->trans('CloningSuccess', $pieceNumNext), null, 'mesgs'); } else { setEventMessages($langs->trans('CloningFailed'), null, 'errors'); $error++; } } } } } } } } if ($error) { $this->db->rollback(); return -1; } else { $this->db->commit(); return 1; } } /** * Mass ReturnAccount * * @param int[] $toselect BookkeepingId * @param string $code_journal Accounting journal code * @param int $docdate Date of the document * @return int int Return integer -1 if KO, 1 if OK * */ public function newReturnAccount(array $toselect, $code_journal, $docdate) { global $langs, $user; $error = 0; $now = dol_now(); if (empty($docdate)) { $docdate = $now; } $accountingJournal = new AccountingJournal($this->db); $accountingJournal->fetch(0, $code_journal); $this->db->begin(); $sqlAlreadyExtourne = "SELECT DISTINCT(piece_num) FROM " .MAIN_DB_PREFIX. "accounting_bookkeeping WHERE label_operation LIKE '%Extourne%'"; $resqlAlreadyExtourne = $this->db->query($sqlAlreadyExtourne); $alreadyExtourneT = array(); if ($resqlAlreadyExtourne) { while ($obj4 = $this->db->fetch_object($resqlAlreadyExtourne)) { $alreadyExtourneT []= $obj4->piece_num; } } $idImplode = implode(',', $toselect); $sql1 = "SELECT DISTINCT(piece_num) from " . MAIN_DB_PREFIX . "accounting_bookkeeping WHERE rowid IN (".$this->db->sanitize($idImplode).")"; $resql1 = $this->db->query($sql1); $pieceNumT = []; if ($resql1) { while ($obj1 = $this->db->fetch_object($resql1)) { $pieceNumT [] = $obj1->piece_num; } $i = mt_rand(0, 100); foreach ($pieceNumT as $pieceNum) { $newBookKeepingInstance = new BookKeeping($this->db); $pieceNumNext = $newBookKeepingInstance->getNextNumMvt(); $extourneIds = []; $sql2 = "SELECT rowid FROM " . MAIN_DB_PREFIX . "accounting_bookkeeping WHERE piece_num = ".((int) $pieceNum); $resql2 = $this->db->query($sql2); if ($resql2) { while ($obj2 = $this->db->fetch_object($resql2)) { $extourneIds [] = $obj2->rowid; } foreach ($extourneIds as $extourneId) { $newBookKeeping = new BookKeeping($this->db); $bookKeeping = new BookKeeping($this->db); if ($bookKeeping->fetch($extourneId)) { if (in_array($bookKeeping->piece_num, $alreadyExtourneT)) { setEventMessages($langs->trans("AlreadyReturnedAccount", $bookKeeping->piece_num), null, 'errors'); } else { $newBookKeeping->debit = $bookKeeping->credit; $newBookKeeping->credit = $bookKeeping->debit; if ($bookKeeping->sens == 'D') { $newBookKeeping->sens = 'C'; } else { $newBookKeeping->sens = 'D'; } $newBookKeeping->label_operation = "Extourne " . $bookKeeping->piece_num . " - " . $bookKeeping->numero_compte . " - " . date('d/m/Y', dol_now()) . " - " . $i; $newBookKeeping->numero_compte = $bookKeeping->numero_compte; $newBookKeeping->label_compte = $bookKeeping->label_compte; $newBookKeeping->doc_type = $bookKeeping->doc_type; $newBookKeeping->code_journal = $bookKeeping->code_journal; $newBookKeeping->doc_date = $docdate; $newBookKeeping->fk_user_author = $user->id; $newBookKeeping->doc_ref = $bookKeeping->doc_ref; $newBookKeeping->montant = $bookKeeping->montant; $newBookKeeping->journal_label = $bookKeeping->journal_label; $newBookKeeping->subledger_account = $bookKeeping->subledger_account; $newBookKeeping->subledger_label = $bookKeeping->subledger_label; } $createResult = $newBookKeeping->create($user); if ($createResult > 0) { $newBookKeeping->piece_num = $pieceNumNext; $newBookKeeping->fk_doc = $bookKeeping->fk_doc; $newBookKeeping->fk_docdet = $bookKeeping->fk_docdet; $result = $newBookKeeping->update($user); setEventMessages($langs->trans("SuccessReturnedAccount", $bookKeeping->piece_num), null, 'mesgs'); } else { setEventMessages($langs->trans("ErrorWhileCreating", $newBookKeeping->error), null, 'errors'); $error++; } } $i++; } } } } if ($error) { $this->db->rollback(); return -1; } else { $this->db->commit(); return 1; } } } /** * Class BookKeepingLine */ class BookKeepingLine extends CommonObjectLine { /** * @var int ID */ public $id; /** * @var ?int Date of source document */ public $doc_date = null; /** * @var string Doc type */ public $doc_type; /** * @var string Doc ref */ public $doc_ref; /** * @var int ID */ public $fk_doc; /** * @var int ID */ public $fk_docdet; /** * @var string Thirdparty code */ public $thirdparty_code; /** * @var string|null Subledger account */ public $subledger_account; /** * @var string|null Subledger label */ public $subledger_label; /** * @var string doc_type */ public $numero_compte; /** * @var string label compte */ public $label_compte; /** * @var string label operation */ public $label_operation; /** * @var float FEC:Debit */ public $debit; /** * @var float FEC:Credit */ public $credit; /** * @var float Amount * @deprecated see $amount */ public $montant; /** * @var float Amount */ public $amount; /** * @var float Multicurrency amount */ public $multicurrency_amount; /** * @var string Multicurrency code */ public $multicurrency_code; /** * @var string Sens */ public $sens; /** * @var ?string */ public $lettering_code; /** * @var string */ public $date_lettering; /** * @var int ID */ public $fk_user_author; /** * @var string key for import */ public $import_key; /** * @var string */ public $code_journal; /** * @var string */ public $journal_label; /** * @var int accounting transaction id */ public $piece_num; /** * @var int|string */ public $date_export; /** * @var int|string */ public $date_lim_reglement; /** * @var string */ public $code_tiers; }