Dolibarr\Code\Accountancy\Classes\BookKeeping::create()

Complexity

Conditions	52
Paths	> 20000

Size

Total Lines	263
Code Lines	184

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function create(User $user, $notrigger = 0)
    {
        global $conf, $langs;

        dol_syslog(__METHOD__, LOG_DEBUG);

        $error = 0;

        // Clean parameters</center>
        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->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);
        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;

        // First check if line not yet already in bookkeeping.
        // Note that we must include 'doc_type - fk_doc - numero_compte - label' 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 " . MAIN_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) . "'";
        $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";
                $sqlnum .= " FROM " . MAIN_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_only_class($this) . ":: create sqlnum=" . $sqlnum, LOG_DEBUG);
                $resqlnum = $this->db->query($sqlnum);
                if ($resqlnum) {
                    $objnum = $this->db->fetch_object($resqlnum);
                    $this->piece_num = $objnum->piece_num;
                }

                dol_syslog(get_only_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 " . MAIN_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;
                    }
                    dol_syslog(get_only_class($this) . ":: create now this->piece_num=" . $this->piece_num, LOG_DEBUG);
                }
                if (empty($this->piece_num)) {
                    $this->piece_num = 1;
                }

                $now = dol_now();

                $sql = "INSERT INTO " . MAIN_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 .= ', entity';
                $sql .= ") VALUES (";
                $sql .= "'" . $this->db->idate($this->doc_date) . "'";
                $sql .= ", " . (!isset($this->date_lim_reglement) || dol_strlen($this->date_lim_reglement) == 0 ? 'NULL' : "'" . $this->db->idate($this->date_lim_reglement) . "'");
                $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($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 .= ", " . (!isset($this->entity) ? $conf->entity : $this->entity);
                $sql .= ")";

                $resql = $this->db->query($sql);
                if ($resql) {
                    $id = $this->db->last_insert_id(MAIN_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);
        }

        // Uncomment this and change MYOBJECT to your own tag if you
        // want this action to call a trigger.
        //if (! $error && ! $notrigger) {

        // // Call triggers
        // $result=$this->call_trigger('MYOBJECT_CREATE',$user);
        // if ($result < 0) $error++;
        // // End call triggers
        //}

        // Commit or rollback
        if ($error) {
            $this->db->rollback();
            return -1 * $error;
        } else {
            $this->db->commit();
            return $result;
        }