reception.class.php

Go to the documentation of this file.

<?php
/* Copyright (C) 2003-2008  Rodolphe Quiedeville  <rodolphe@quiedeville.org>
 * Copyright (C) 2005-2012  Regis Houssin     <regis.houssin@capnetworks.com>
 * Copyright (C) 2007   Franky Van Liedekerke <franky.van.liedekerke@telenet.be>
 * Copyright (C) 2006-2012  Laurent Destailleur   <eldy@users.sourceforge.net>
 * Copyright (C) 2011-2017  Juanjo Menent     <jmenent@2byte.es>
 * Copyright (C) 2013       Florian Henry     <florian.henry@open-concept.pro>
 * Copyright (C) 2014   Cedric GROSS      <c.gross@kreiz-it.fr>
 * Copyright (C) 2014-2015  Marcos García           <marcosgdf@gmail.com>
 * Copyright (C) 2014-2020  Francis Appels          <francis.appels@yahoo.com>
 * Copyright (C) 2015       Claudio Aschieri        <c.aschieri@19.coop>
 * Copyright (C) 2016-2022  Ferran Marcet     <fmarcet@2byte.es>
 * Copyright (C) 2018   Quentin Vial-Gouteyron  <quentin.vial-gouteyron@atm-consulting.fr>
 * Copyright (C) 2022-2025  Frédéric France         <frederic.france@free.fr>
 * Copyright (C) 2024-2026  MDW           <mdeweerd@users.noreply.github.com>
 * Copyright (C) 2025-2026  Nick Fragoulis
 * Copyright (C) 2026   Mathieu Moulin      <mathieu@iprospective.fr>
 * Copyright (C) 2026   Jose Martinez     <jose.martinez@pichinov.com>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>.
 */
 
require_once DOL_DOCUMENT_ROOT.'/core/class/commonobject.class.php';
require_once DOL_DOCUMENT_ROOT."/core/class/commonobjectline.class.php";
require_once DOL_DOCUMENT_ROOT.'/core/class/commonincoterm.class.php';
require_once DOL_DOCUMENT_ROOT.'/reception/class/receptionlinebatch.class.php';
if (isModEnabled("propal")) {
  require_once DOL_DOCUMENT_ROOT.'/comm/propal/class/propal.class.php';
}
if (isModEnabled('order')) {
  require_once DOL_DOCUMENT_ROOT.'/commande/class/commande.class.php';
}
 
 
class Reception extends CommonObject
{
  use CommonIncoterm;
 
  public $TRIGGER_PREFIX = 'RECEPTION';   // to be overridden in child class implementations, i.e. 'BILL', 'TASK', 'PROPAL', etc.
 
  public $code = "";
 
  public $element = "reception";
 
  public $fk_element = "fk_reception";
 
  public $table_element = "reception";
 
  public $table_element_line = "receptiondet_batch";
 
  public $picto = 'dollyrevert';
 
  public $socid;
  public $ref_supplier;
 
  public $entrepot_id;
  public $tracking_number;
  public $tracking_url;
  public $billed;
 
  public $weight;
  public $trueWeight;
  public $weight_units;
  public $trueWidth;
  public $width_units;
  public $trueHeight;
  public $height_units;
  public $trueDepth;
  public $depth_units;
  public $trueSize;
  public $size_units;
  public $user_author_id;
 
  public $date_delivery;
 
  public $date;
 
  public $date_reception;
 
  public $date_valid;
 
  public $meths;
  public $listmeths; // List of carriers
 
  public $lines = array();
 
 
  public $detail_batch;
 
  const STATUS_CANCELED = -1;
  const STATUS_DRAFT = 0;
  const STATUS_VALIDATED = 1;
  const STATUS_CLOSED = 2;
 
 
  public $fk_warehouse;
 
  public function __construct($db)
  {
    $this->db = $db;
 
    $this->ismultientitymanaged = 1; // 0=No test on entity, 1=Test with field entity, 2=Test with link by societe
    $this->isextrafieldmanaged = 1;
  }
 
  public function getNextNumRef($soc)
  {
    global $langs, $conf;
    $langs->load("receptions");
 
    if (getDolGlobalString('RECEPTION_ADDON_NUMBER')) {
      $mybool = false;
 
      $file = getDolGlobalString('RECEPTION_ADDON_NUMBER') . ".php";
      $classname = getDolGlobalString('RECEPTION_ADDON_NUMBER');
 
      // Include file with class
      $dirmodels = array_merge(array('/'), (array) $conf->modules_parts['models']);
 
      foreach ($dirmodels as $reldir) {
        $dir = dol_buildpath($reldir."core/modules/reception/");
 
        // 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();
      '@phan-var-force ModelNumRefReception $obj';
      $numref = $obj->getNextValue($soc, $this);
 
      if ($numref != "") {
        return $numref;
      } else {
        dol_print_error($this->db, get_class($this)."::getNextNumRef ".$obj->error);
        return "";
      }
    } else {
      print $langs->trans("Error")." ".$langs->trans("Error_RECEPTION_ADDON_NUMBER_NotDefined");
      return "";
    }
  }
 
  public function create($user, $notrigger = 0)
  {
    global $conf;
 
    $now = dol_now();
 
    require_once DOL_DOCUMENT_ROOT.'/product/stock/class/mouvementstock.class.php';
    $error = 0;
 
    // Clean parameters
    $this->tracking_number = dol_sanitizeFileName($this->tracking_number);
    if (empty($this->fk_project)) {
      $this->fk_project = 0;
    }
    if (empty($this->weight_units)) {
      $this->weight_units = 0;
    }
    if (empty($this->size_units)) {
      $this->size_units = 0;
    }
    if (empty($this->date_creation)) {
      $this->date_creation = $now;
    }
 
    $this->entity = setEntity($this);
 
    $this->user = $user;
 
    $this->db->begin();
 
    // If there is only one active warehouse, use it as the default warehouse of the reception
    if (empty($this->fk_warehouse)) {
      $resqlwh = $this->db->query("SELECT rowid FROM ".MAIN_DB_PREFIX."entrepot WHERE entity IN (".getEntity('stock').") AND statut = 1");
      if ($resqlwh && $this->db->num_rows($resqlwh) == 1) {
        $objwh = $this->db->fetch_object($resqlwh);
        $this->fk_warehouse = (int) $objwh->rowid;
      }
    }
 
    $sql = "INSERT INTO ".MAIN_DB_PREFIX."reception (";
    $sql .= "ref";
    $sql .= ", entity";
    $sql .= ", ref_supplier";
    $sql .= ", date_creation";
    $sql .= ", fk_user_author";
    $sql .= ", date_reception";
    $sql .= ", date_delivery";
    $sql .= ", fk_soc";
    $sql .= ", fk_projet";
    $sql .= ", fk_warehouse";
    $sql .= ", fk_shipping_method";
    $sql .= ", tracking_number";
    $sql .= ", weight";
    $sql .= ", size";
    $sql .= ", width";
    $sql .= ", height";
    $sql .= ", weight_units";
    $sql .= ", size_units";
    $sql .= ", note_private";
    $sql .= ", note_public";
    $sql .= ", model_pdf";
    $sql .= ", fk_incoterms, location_incoterms";
    $sql .= ") VALUES (";
    $sql .= "'(PROV)'";
    $sql .= ", ".((int) $this->entity);
    $sql .= ", ".($this->ref_supplier ? "'".$this->db->escape($this->ref_supplier)."'" : "null");
    $sql .= ", '".$this->db->idate($this->date_creation)."'";
    $sql .= ", ".((int) $user->id);
    $sql .= ", ".($this->date_reception > 0 ? "'".$this->db->idate($this->date_reception)."'" : "null");
    $sql .= ", ".($this->date_delivery > 0 ? "'".$this->db->idate($this->date_delivery)."'" : "null");
    $sql .= ", ".($this->socid > 0 ? ((int) $this->socid) : "null");
    $sql .= ", ".($this->fk_project > 0 ? ((int) $this->fk_project) : "null");
    $sql .= ", ".($this->fk_warehouse > 0 ? ((int) $this->fk_warehouse) : "null");
    $sql .= ", ".($this->shipping_method_id > 0 ? ((int) $this->shipping_method_id) : "null");
    $sql .= ", '".$this->db->escape($this->tracking_number)."'";
    $sql .= ", ".(is_null($this->weight) ? "NULL" : ((float) $this->weight));
    $sql .= ", ".(is_null($this->trueDepth) ? "NULL" : ((float) $this->trueDepth));
    $sql .= ", ".(is_null($this->trueWidth) ? "NULL" : ((float) $this->trueWidth));
    $sql .= ", ".(is_null($this->trueHeight) ? "NULL" : ((float) $this->trueHeight));
    $sql .= ", ".((int) $this->weight_units);
    $sql .= ", ".((int) $this->size_units);
    $sql .= ", ".(!empty($this->note_private) ? "'".$this->db->escape($this->note_private)."'" : "null");
    $sql .= ", ".(!empty($this->note_public) ? "'".$this->db->escape($this->note_public)."'" : "null");
    $sql .= ", ".(!empty($this->model_pdf) ? "'".$this->db->escape($this->model_pdf)."'" : "null");
    $sql .= ", ".(int) $this->fk_incoterms;
    $sql .= ", '".$this->db->escape($this->location_incoterms)."'";
    $sql .= ")";
 
    dol_syslog(get_class($this)."::create", LOG_DEBUG);
 
    $resql = $this->db->query($sql);
 
    if ($resql) {
      $this->id = $this->db->last_insert_id(MAIN_DB_PREFIX."reception");
 
      // update ref
      $initialref = '(PROV'.$this->id.')';
      if (!empty($this->ref)) {
        $initialref = $this->ref;
      }
 
      $sql = "UPDATE ".MAIN_DB_PREFIX."reception";
      $sql .= " SET ref = '".$this->db->escape($initialref)."'";
      $sql .= " WHERE rowid = ".((int) $this->id);
 
      dol_syslog(get_class($this)."::create", LOG_DEBUG);
      if ($this->db->query($sql)) {
        // Insert of lines
        $num = count($this->lines);
        for ($i = 0; $i < $num; $i++) {
          $this->lines[$i]->fk_reception = $this->id;
 
          if ($this->lines[$i]->create($user) <= 0) {
            $this->setErrorsFromObject($this->lines[$i]);
            $error++;
          }
        }
 
        if (!$error && $this->id && $this->origin_id) {
          $ret = $this->add_object_linked();
          if (!$ret) {
            $error++;
          }
        }
 
        // Create extrafields
        if (!$error) {
          $result = $this->insertExtraFields();
          if ($result < 0) {
            $error++;
          }
        }
 
        if (!$error && !$notrigger) {
          // Call trigger
          $result = $this->call_trigger('RECEPTION_CREATE', $user);
          if ($result < 0) {
            $error++;
          }
          // End call triggers
        }
 
        if (!$error) {
          $this->db->commit();
          return $this->id;
        } else {
          foreach ($this->errors as $errmsg) {
            dol_syslog(get_class($this)."::create ".$errmsg, LOG_ERR);
            $this->error .= ($this->error ? ', '.$errmsg : $errmsg);
          }
          $this->db->rollback();
          return -1 * $error;
        }
      } else {
        $error++;
        $this->error = $this->db->lasterror()." - sql=$sql";
        $this->db->rollback();
        return -2;
      }
    } else {
      $error++;
      $this->error = $this->db->error()." - sql=$sql";
      $this->db->rollback();
      return -1;
    }
  }
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function create_line($entrepot_id, $origin_line_id, $qty, $rang = 0, $array_options = [], $parent_line_id = 0, $product_id = 0)
  {
    //phpcs:enable
    global $user;
 
    $receptionline = new ReceptionLineBatch($this->db);
    $receptionline->fk_reception = $this->id;
    $receptionline->entrepot_id = $entrepot_id;
    $receptionline->fk_elementdet = $origin_line_id;
    $receptionline->element_type = $this->origin;
    $receptionline->fk_parent = $parent_line_id;
    $receptionline->fk_product = $product_id;
    $receptionline->qty = $qty;
    $receptionline->rang = $rang;
    $receptionline->array_options = $array_options;
 
    if (!($receptionline->fk_product > 0)) {
      $order_line = new CommandeFournisseurLigne($this->db);
      $order_line->fetch($receptionline->fk_elementdet);
      $receptionline->fk_product = $order_line->fk_product;
    }
 
    if (($lineId = $receptionline->insert($user)) < 0) {
      $this->errors[] = $receptionline->error;
    }
    return $lineId;
  }
 
  public function fetch($id, $ref = '', $ref_ext = '')
  {
    // Check parameters
    if (empty($id) && empty($ref) && empty($ref_ext)) {
      return -1;
    }
 
    $sql = "SELECT e.rowid, e.entity, e.ref, e.fk_soc as socid, e.date_creation, e.ref_supplier, e.ref_ext, e.fk_user_author, e.fk_statut as status, e.fk_projet as fk_project, e.billed, e.fk_warehouse";
    $sql .= ", e.weight, e.weight_units, e.size, e.size_units, e.width, e.height";
    $sql .= ", e.date_reception as date_reception, e.model_pdf, e.date_delivery, e.date_valid";
    $sql .= ", e.fk_shipping_method, e.tracking_number";
    $sql .= ", el.fk_source as origin_id, el.sourcetype as origin";
    $sql .= ", e.note_private, e.note_public";
    $sql .= ', e.fk_incoterms, e.location_incoterms';
    $sql .= ', i.libelle as label_incoterms';
    $sql .= " FROM ".MAIN_DB_PREFIX."reception as e";
    $sql .= " LEFT JOIN ".MAIN_DB_PREFIX."element_element as el ON el.fk_target = e.rowid AND el.targettype = '".$this->db->escape($this->element)."' AND el.sourcetype = 'order_supplier'";
    $sql .= ' LEFT JOIN '.MAIN_DB_PREFIX.'c_incoterms as i ON e.fk_incoterms = i.rowid';
 
    if ($id) {
      $sql .= " WHERE e.rowid = ".((int) $id);
    } else {
      $sql .= " WHERE e.entity IN (".getEntity('reception').")";
      if ($ref) {
        $sql .= " AND e.ref = '".$this->db->escape($ref)."'";
      } elseif ($ref_ext) {
        $sql .= " AND e.ref_ext = '".$this->db->escape($ref_ext)."'";
      }
    }
 
    dol_syslog(get_class($this)."::fetch", LOG_DEBUG);
    $result = $this->db->query($sql);
    if ($result) {
      if ($this->db->num_rows($result)) {
        $obj = $this->db->fetch_object($result);
 
        $this->id                   = $obj->rowid;
        $this->entity               = $obj->entity;
        $this->ref                  = $obj->ref;
        $this->socid                = $obj->socid;
        $this->ref_supplier         = $obj->ref_supplier;
        $this->ref_ext              = $obj->ref_ext;
        $this->statut               = $obj->status;
        $this->status               = $obj->status;
        $this->billed               = $obj->billed;
        $this->fk_warehouse = $obj->fk_warehouse;
        $this->fk_project       = $obj->fk_project;
        $this->user_author_id       = $obj->fk_user_author;
        $this->date_creation        = $this->db->jdate($obj->date_creation);
        $this->date                 = $this->db->jdate($obj->date_reception); // TODO deprecated
        $this->date_reception       = $this->db->jdate($obj->date_reception); // Date real
        $this->date_delivery        = $this->db->jdate($obj->date_delivery); // Date planned
        $this->date_valid         = $this->db->jdate($obj->date_valid); // Date validation
        $this->model_pdf            = $obj->model_pdf;
        $this->shipping_method_id   = $obj->fk_shipping_method;
        $this->tracking_number      = $obj->tracking_number;
        $this->origin               = ($obj->origin ? $obj->origin : 'commande'); // For compatibility
        $this->origin_type          = ($obj->origin ? $obj->origin : 'commande'); // For compatibility
        $this->origin_id            = $obj->origin_id;
 
        $this->trueWeight           = $obj->weight;
        $this->weight_units         = $obj->weight_units;
 
        $this->trueWidth            = $obj->width;
        $this->width_units          = $obj->size_units;
        $this->trueHeight           = $obj->height;
        $this->height_units         = $obj->size_units;
        $this->trueDepth            = $obj->size;
        $this->depth_units          = $obj->size_units;
 
        $this->note_public          = $obj->note_public;
        $this->note_private         = $obj->note_private;
 
        // A denormalized value
        $this->trueSize = $obj->size."x".$obj->width."x".$obj->height;
        $this->size_units = $obj->size_units;
 
        //Incoterms
        $this->fk_incoterms = $obj->fk_incoterms;
        $this->location_incoterms = $obj->location_incoterms;
        $this->label_incoterms = $obj->label_incoterms;
 
        $this->db->free($result);
 
        //$file = $conf->reception->dir_output."/".get_exdir(0, 0, 0, 1, $this, 'reception')."/".$this->id.".pdf";
        //$this->pdf_filename = $file;
 
        // Tracking url
        $this->getUrlTrackingStatus($obj->tracking_number);
 
        /*
         * Thirdparty
         */
        $result = $this->fetch_thirdparty();
 
 
        // Retrieve all extrafields for reception
        // fetch optionals attributes and labels
        require_once DOL_DOCUMENT_ROOT.'/core/class/extrafields.class.php';
        $extrafields = new ExtraFields($this->db);
        $extrafields->fetch_name_optionals_label($this->table_element, true);
        $this->fetch_optionals();
 
        /*
         * Lines
         */
        if (empty($obj->origin_id)) {
          $result = $this->fetch_lines_free();
        } else {
          $result = $this->fetch_lines();
        }
        if ($result < 0) {
          return -3;
        }
 
        return 1;
      } else {
        dol_syslog(get_class($this).'::Fetch no reception found', LOG_ERR);
        $this->error = 'Reception with id '.$id.' not found';
        return 0;
      }
    } else {
      $this->error = $this->db->error();
      return -1;
    }
  }
 
  public function valid($user, $notrigger = 0)
  {
    global $conf, $langs;
 
    require_once DOL_DOCUMENT_ROOT.'/core/lib/files.lib.php';
 
    dol_syslog(get_class($this)."::valid");
 
    // Protection
    if ($this->statut) {
      dol_syslog(get_class($this)."::valid no draft status", LOG_WARNING);
      return 0;
    }
 
    if (!((!getDolGlobalInt('MAIN_USE_ADVANCED_PERMS') && $user->hasRight('reception', 'creer'))
    || (getDolGlobalInt('MAIN_USE_ADVANCED_PERMS') && $user->hasRight('reception', 'reception_advance', 'validate')))) {
      $this->error = 'Permission denied';
      dol_syslog(get_class($this)."::valid ".$this->error, LOG_ERR);
      return -1;
    }
 
    $this->db->begin();
 
    $error = 0;
 
    // Define new ref
    $soc = new Societe($this->db);
    $soc->fetch($this->socid);
 
 
    // Define new ref
    if (!$error && (preg_match('/^[\‍(]?PROV/i', $this->ref) || empty($this->ref))) { // empty should not happened, but when it occurs, the test save life
      $numref = $this->getNextNumRef($soc);
    } else {
      $numref = (string) $this->ref;
    }
 
    $this->newref = dol_sanitizeFileName($numref);
 
    $now = dol_now();
 
    // Validate
    $sql = "UPDATE ".MAIN_DB_PREFIX."reception SET";
    $sql .= " ref='".$this->db->escape($numref)."'";
    $sql .= ", fk_statut = 1";
    $sql .= ", date_valid = '".$this->db->idate($now)."'";
    $sql .= ", fk_user_valid = ".((int) $user->id);
    $sql .= " WHERE rowid = ".((int) $this->id);
    dol_syslog(get_class($this)."::valid update reception", LOG_DEBUG);
    $resql = $this->db->query($sql);
    if (!$resql) {
      $this->error = $this->db->lasterror();
      $error++;
    }
 
    // If stock increment is done on reception (recommended choice)
    if (!$error && isModEnabled('stock') && getDolGlobalInt('STOCK_CALCULATE_ON_RECEPTION')) {
      require_once DOL_DOCUMENT_ROOT.'/product/stock/class/mouvementstock.class.php';
 
      $langs->load("agenda");
 
      // Loop on each product line to add a stock movement
      // TODO in future, reception lines may not be linked to order line
      $sql = "SELECT COALESCE(NULLIF(ed.fk_product, 0), cd.fk_product) as fk_product, cd.subprice, cd.remise_percent,";
      $sql .= " ed.rowid, ed.qty, ed.fk_entrepot,";
      $sql .= " ed.eatby, ed.sellby, ed.batch,";
      $sql .= " ed.fk_elementdet, ed.cost_price";
      $sql .= " FROM ".MAIN_DB_PREFIX."receptiondet_batch as ed";
      $sql .= " LEFT JOIN ".MAIN_DB_PREFIX."commande_fournisseurdet as cd ON cd.rowid = ed.fk_elementdet";
      $sql .= " WHERE ed.fk_reception = ".((int) $this->id);
      $sql .= " AND COALESCE(NULLIF(ed.fk_product, 0), cd.fk_product) IS NOT NULL";
      $sql .= " AND ed.fk_entrepot IS NOT NULL AND ed.fk_entrepot > 0"; // A line without destination warehouse generates no stock movement (sample, servicing, ...)
 
      dol_syslog(get_class($this)."::valid select details", LOG_DEBUG);
      $resql = $this->db->query($sql);
      if ($resql) {
        $cpt = $this->db->num_rows($resql);
        for ($i = 0; $i < $cpt; $i++) {
          $obj = $this->db->fetch_object($resql);
 
          $qty = $obj->qty;
 
          if ($qty == 0 || ($qty < 0 && !getDolGlobalInt('RECEPTION_ALLOW_NEGATIVE_QTY'))) {
            continue;
          }
 
          dol_syslog(get_class($this)."::valid movement index ".$i." ed.rowid=".$obj->rowid);
 
          //var_dump($this->lines[$i]);
          $mouvS = new MouvementStock($this->db);
          $mouvS->origin = &$this;
          $mouvS->setOrigin($this->element, $this->id, $obj->fk_elementdet, $obj->rowid);
 
          if (empty($obj->batch)) {
            // line without batch detail
 
            // We decrement stock of product (and sub-products) -> update table llx_product_stock (key of this table is fk_product+fk_entrepot) and add a movement record.
            $inventorycode = '';
            $result = $mouvS->reception($user, $obj->fk_product, $obj->fk_entrepot, $qty, $obj->cost_price, $langs->trans("ReceptionValidatedInDolibarr", $numref), '', '', '', '', 0, $inventorycode);
 
            if (intval($result) < 0) {
              $error++;
              $this->setErrorsFromObject($mouvS);
              break;
            }
          } else {
            // line with batch detail
 
            // We decrement stock of product (and sub-products) -> update table llx_product_stock (key of this table is fk_product+fk_entrepot) and add a movement record.
            // Note: ->fk_origin_stock = id into table llx_product_batch (may be rename into llx_product_stock_batch in another version)
            $inventorycode = '';
            $result = $mouvS->reception($user, $obj->fk_product, $obj->fk_entrepot, $qty, $obj->cost_price, $langs->trans("ReceptionValidatedInDolibarr", $numref), $this->db->jdate($obj->eatby), $this->db->jdate($obj->sellby), $obj->batch, '', 0, $inventorycode);
 
            if (intval($result) < 0) {
              $error++;
              $this->setErrorsFromObject($mouvS);
              break;
            }
          }
        }
      } else {
        $this->db->rollback();
        $this->error = $this->db->error();
        return -2;
      }
    }
 
    if (!$error && $this->origin_id > 0) {
      // Change status of purchase order to "reception in process" or "totally received"
      $status = $this->getStatusDispatch();
      if ($status < 0) {
        $error++;
      } else {
        $trigger_key = '';
        if ($this->origin_object instanceof CommandeFournisseur && $status == CommandeFournisseur::STATUS_RECEIVED_COMPLETELY) {
          $ret = $this->origin_object->Livraison($user, dol_now(), 'tot', '');
          if ($ret < 0) {
            $error++;
            $this->errors = array_merge($this->errors, $this->origin_object->errors);
          }
        } else {
          $ret = $this->setStatut($status, $this->origin_id, 'commande_fournisseur', $trigger_key);
          if ($ret < 0) {
            $error++;
          }
        }
      }
    }
 
    if (!$error && !$notrigger) {
      // Call trigger
      $result = $this->call_trigger('RECEPTION_VALIDATE', $user);
      if ($result < 0) {
        $error++;
      }
      // End call triggers
    }
 
    if (!$error) {
      $this->oldref = $this->ref;
 
      // Rename directory if dir was a temporary ref
      if (preg_match('/^[\‍(]?PROV/i', $this->ref)) {
        // Now we rename also files into index
        $sql = 'UPDATE '.MAIN_DB_PREFIX."ecm_files set filename = CONCAT('".$this->db->escape($this->newref)."', SUBSTR(filename, ".(strlen($this->ref) + 1).")), filepath = 'reception/".$this->db->escape($this->newref)."'";
        $sql .= " WHERE filename LIKE '".$this->db->escape($this->ref)."%' AND filepath = 'reception/".$this->db->escape($this->ref)."' AND entity = ".((int) $conf->entity);
        $resql = $this->db->query($sql);
        if (!$resql) {
          $error++;
          $this->error = $this->db->lasterror();
        }
        $sql = 'UPDATE '.MAIN_DB_PREFIX."ecm_files set filepath = 'reception/".$this->db->escape($this->newref)."'";
        $sql .= " WHERE filepath = 'reception/".$this->db->escape($this->ref)."' and entity = ".((int) $conf->entity);
        $resql = $this->db->query($sql);
        if (!$resql) {
          $error++;
          $this->error = $this->db->lasterror();
        }
 
        // We rename directory ($this->ref = old ref, $num = new ref) in order not to lose the attachments
        $oldref = dol_sanitizeFileName($this->ref);
        $newref = dol_sanitizeFileName($numref);
        $dirsource = $conf->reception->dir_output.'/'.$oldref;
        $dirdest = $conf->reception->dir_output.'/'.$newref;
        if (!$error && file_exists($dirsource)) {
          dol_syslog(get_class($this)."::valid rename dir ".$dirsource." into ".$dirdest);
 
          if (@rename($dirsource, $dirdest)) {
            dol_syslog("Rename ok");
            // Rename docs starting with $oldref with $newref
            $listoffiles = dol_dir_list($conf->reception->dir_output.'/'.$newref, 'files', 1, '^'.preg_quote($oldref, '/'));
            foreach ($listoffiles as $fileentry) {
              $dirsource = $fileentry['name'];
              $dirdest = preg_replace('/^'.preg_quote($oldref, '/').'/', $newref, $dirsource);
              $dirsource = $fileentry['path'].'/'.$dirsource;
              $dirdest = $fileentry['path'].'/'.$dirdest;
              @rename($dirsource, $dirdest);
            }
          }
        }
      }
    }
 
    // Set new ref and current status
    if (!$error) {
      $this->ref = $numref;
      $this->statut = self::STATUS_VALIDATED;
      $this->status = self::STATUS_VALIDATED;
    }
 
    if (!$error) {
      $this->db->commit();
      return 1;
    } else {
      foreach ($this->errors as $errmsg) {
        dol_syslog(get_class($this)."::valid ".$errmsg, LOG_ERR);
        $this->error .= ($this->error ? ', '.$errmsg : $errmsg);
      }
      $this->db->rollback();
      return -1 * $error;
    }
  }
 
  public function getStatusDispatch()
  {
    require_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.class.php';
    require_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.dispatch.class.php';
 
    $status = CommandeFournisseur::STATUS_RECEIVED_PARTIALLY;
 
    if (!empty($this->origin) && $this->origin_id > 0 && ($this->origin == 'order_supplier' || $this->origin == 'commandeFournisseur')) {
      if (empty($this->origin_object)) {
        $this->fetch_origin();
        if ($this->origin_object instanceof CommonObject && empty($this->origin_object->lines)) {
          $res = $this->origin_object->fetch_lines();
          $this->commandeFournisseur = null;  // deprecated
          if ($res < 0) {
            return $res;
          }
        } elseif ($this->origin_object instanceof CommandeFournisseur && empty($this->origin_object->lines)) {
          $res = $this->origin_object->fetch_lines();
          $this->commandeFournisseur = $this->origin_object;  // deprecated
          if ($res < 0) {
            return $res;
          }
        }
      }
 
      $qty_received = array();
      $qty_wished = array();
 
      $supplierorderdispatch = new CommandeFournisseurDispatch($this->db);
      $filter = array('t.fk_element' => $this->origin_id);
      if (getDolGlobalInt('SUPPLIER_ORDER_USE_DISPATCH_STATUS')) {
        $filter['t.status'] = 1; // Restrict to lines with status validated
      }
 
      $ret = $supplierorderdispatch->fetchAll('', '', 0, 0, $filter);
      if ($ret < 0) {
        $this->setErrorsFromObject($supplierorderdispatch);
        return $ret;
      } else {
        // Lines of draft receptions are not received yet
        $draft_lines = array();
        $sql = "SELECT rb.rowid FROM ".MAIN_DB_PREFIX."receptiondet_batch as rb";
        $sql .= " INNER JOIN ".MAIN_DB_PREFIX."reception as r ON r.rowid = rb.fk_reception";
        $sql .= " WHERE rb.fk_element = ".((int) $this->origin_id);
        $sql .= " AND r.fk_statut = ".self::STATUS_DRAFT;
        $resql = $this->db->query($sql);
        if (!$resql) {
          $this->error = $this->db->lasterror();
          return -1;
        }
        while ($obj = $this->db->fetch_object($resql)) {
          $draft_lines[(int) $obj->rowid] = (int) $obj->rowid;
        }
        $this->db->free($resql);
 
        // build array with quantity received by product in all supplier orders (origin)
        foreach ($supplierorderdispatch->lines as $dispatch_line) {
          if (isset($draft_lines[(int) $dispatch_line->id])) {
            continue;
          }
          if (array_key_exists($dispatch_line->fk_product, $qty_received)) {
            $qty_received[$dispatch_line->fk_product] += $dispatch_line->qty;
          } else {
            $qty_received[$dispatch_line->fk_product] = $dispatch_line->qty;
          }
        }
 
        // qty wished in origin (purchase order, ...)
        foreach ($this->origin_object->lines as $origin_line) {
          // exclude lines not qualified for reception
          if (($origin_line->product_type > 0 && (!getDolGlobalInt('STOCK_SUPPORTS_SERVICES') || empty($origin_line->stockable_product))) || $origin_line->product_type > 1) {
            continue;
          }
          if (array_key_exists($origin_line->fk_product, $qty_wished)) {
            $qty_wished[$origin_line->fk_product] += $origin_line->qty;
          } else {
            $qty_wished[$origin_line->fk_product] = $origin_line->qty;
          }
        }
 
        // compare array
        $diff_array = array_diff_assoc($qty_received, $qty_wished); // Warning: $diff_array is done only on common keys.
        $keys_in_wished_not_in_received = array_diff(array_keys($qty_wished), array_keys($qty_received));
        $keys_in_received_not_in_wished = array_diff(array_keys($qty_received), array_keys($qty_wished));
 
        if (count($diff_array) == 0 && count($keys_in_wished_not_in_received) == 0 && count($keys_in_received_not_in_wished) == 0) { // no diff => mean everything is received
          $status = CommandeFournisseur::STATUS_RECEIVED_COMPLETELY;
        } elseif (getDolGlobalInt('SUPPLIER_ORDER_MORE_THAN_WISHED')) {
          // set totally received if more products received than ordered
          $close = 0;
 
          if (count($diff_array) > 0) {
            // there are some difference between the two arrays
            // scan the array of results
            foreach ($diff_array as $key => $value) {
              // if the quantity delivered is greater or equal to ordered quantity @phan-suppress-next-line PhanTypeInvalidDimOffset
              if ($qty_received[$key] >= $qty_wished[$key]) {
                $close++;
              }
            }
          }
 
          if ($close == count($diff_array)) {
            // all the products are received equal or more than the ordered quantity
            $status = CommandeFournisseur::STATUS_RECEIVED_COMPLETELY;
          }
        }
      }
    }
 
    return $status;
  }
 
  public function addline($entrepot_id, $id, $qty, $array_options = [], $comment = '', $eatby = null, $sellby = null, $batch = '', $cost_price = 0)
  {
    // Instantiated below: required here because a caller outside the
    // reception card (the REST API, a job) has not loaded them.
    require_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.dispatch.class.php';
    require_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.class.php';
 
    global $conf, $langs, $user;
 
    $num = count($this->lines);
    $line = new CommandeFournisseurDispatch($this->db);
 
    $line->fk_entrepot = $entrepot_id;
    $line->fk_commandefourndet = $id;
    $line->qty = $qty;
 
    $supplierorderline = new CommandeFournisseurLigne($this->db);
    $result = $supplierorderline->fetch($id);
    if ($result <= 0) {
      $this->setErrorsFromObject($supplierorderline);
      return -1;
    }
 
    $fk_product = 0;
    if (isModEnabled('stock') && !empty($supplierorderline->fk_product)) {
      $fk_product = $supplierorderline->fk_product;
 
      if (!($entrepot_id > 0) && !getDolGlobalInt('STOCK_WAREHOUSE_NOT_REQUIRED_FOR_RECEPTIONS')) {
        $langs->load("errors");
        $this->error = $langs->trans("ErrorWarehouseRequiredIntoReceptionLine");
        return -1;
      }
    }
 
    // Check batch is set
    $product = new Product($this->db);
    $product->fetch($fk_product);
    if (isModEnabled('productbatch')) {
      $langs->load("errors");
      if (!empty($product->status_batch) && empty($batch)) {
        $this->error = $langs->trans('ErrorProductNeedBatchNumber', $product->ref);
        return -1;
      } elseif (empty($product->status_batch) && !empty($batch)) {
        $this->error = $langs->trans('ErrorProductDoesNotNeedBatchNumber', $product->ref);
        return -1;
      }
 
      // check sell-by / eat-by date is mandatory
      $errorMsgArr = Productlot::checkSellOrEatByMandatoryFromProductAndDates($product, $sellby, $eatby);
      if (!empty($errorMsgArr)) {
        $errorMessage = '<b>' . $product->ref . '</b> : ';
        $errorMessage .= '<ul>';
        foreach ($errorMsgArr as $errorMsg) {
          $errorMessage .= '<li>' . $errorMsg . '</li>';
        }
        $errorMessage .= '</ul>';
        $this->error = $errorMessage;
        return -1;
      }
    }
    unset($product);
 
    // extrafields
    $line->array_options = $supplierorderline->array_options;
    if (!getDolGlobalInt('MAIN_EXTRAFIELDS_DISABLED') && is_array($array_options) && count($array_options) > 0) {
      foreach ($array_options as $key => $value) {
        $line->array_options[$key] = $value;
      }
    }
 
    $line->fk_product = $fk_product;
    $line->fk_commande = $supplierorderline->fk_commande;
    $line->fk_user = $user->id;
    $line->comment = $comment;
    $line->batch = $batch;
    $line->eatby = $eatby;
    $line->sellby = $sellby;
    $line->status = 1;
    $line->cost_price = $cost_price;
    $line->fk_reception = $this->id;
 
    $this->lines[$num] = $line;
 
    return $num;
  }
 
  public function addlinefree($qty, $element_type, $fk_product, $fk_unit, $rang, $description, $array_options = [], $cost_price = 0, $ref_fourn = '', $fk_entrepot = 0, $batch = '')
  {
    global $mysoc, $langs, $user;
 
    if ($this->status == self::STATUS_DRAFT) {
      if (empty($rang)) {
        $rang = 0;
      }
 
      $qty = (float) price2num($qty);
 
      $this->db->begin();
 
      // Rank to use
      $ranktouse = $this->rang;
      if ($ranktouse == -1) {
        $rangmax = $this->line_max($this->fk_reception);
        $ranktouse = $rangmax + 1;
      }
 
      // Insert line
      $this->line = new ReceptionLineBatch($this->db);
      $this->line->fk_reception = $this->id;
      $this->line->element_type = $element_type;
      $this->line->fk_product = $fk_product;
      $this->line->description = $description;
 
      $this->line->qty = (float) $qty;
      $this->line->fk_unit = $fk_unit;
      $this->line->rang = $ranktouse;
      $this->line->cost_price = (float) $cost_price;
      $this->line->ref_fourn = trim((string) $ref_fourn);
      if ((int) $fk_entrepot > 0) {
        $this->line->fk_entrepot = (int) $fk_entrepot;
      }
      if ((string) $batch !== '') {
        $this->line->batch = trim((string) $batch);
      }
 
      if (is_array($array_options) && count($array_options) > 0) {
        $this->line->array_options = $array_options;
      }
 
      $result = $this->line->insert($user);
      if ($result > 0) {
        if (!isset($this->context['createfromclone'])) {
          if ($this->fk_reception) {
            $this->line_order(true, 'DESC');
          } elseif ($ranktouse > 0 && $ranktouse <= count($this->lines)) {
            $linecount = count($this->lines);
            for ($ii = $ranktouse; $ii <= $linecount; $ii++) {
              $this->updateRangOfLine($this->lines[$ii - 1]->id, $ii + 1);
            }
          }
          $this->lines[] = $this->line;
        }
 
        $this->db->commit();
        return $this->line->id;
      } else {
        $this->error = $this->line->error;
        dol_syslog(get_class($this)."::addlinefree error=".$this->error, LOG_ERR);
        $this->db->rollback();
        return -2;
      }
    } else {
      dol_syslog(get_class($this)."::addlinefree status of reception must be Draft to allow use of ->addlinefree()", LOG_ERR);
      return -3;
    }
  }
 
  public function updatelinefree($rowid, $qty, $element_type, $fk_product, $fk_unit, $rang, $description, $notrigger, $array_options = array(), $cost_price = null, $ref_fourn = null, $fk_entrepot = -1, $batch = null)
  {
    global $mysoc, $langs, $user;
 
    if ($this->statut == self::STATUS_DRAFT) {
      $this->db->begin();
 
      if (empty($qty)) {
        $qty = 0;
      }
      if (empty($rang)) {
        $rang = 0;
      }
 
      $qty = (float) $qty;
      $description = trim((string) $description);
 
      // Fetch current line from the database and then clone the object and set it in $oldline property
      $line = new ReceptionLineBatch($this->db);
 
      $line->fetch($rowid);
      $line->fetch_optionals();
 
      if (!empty($line->fk_product)) {
        $product = new Product($this->db);
        $result = $product->fetch($line->fk_product);
        $product_type = $product->type;
      }
 
      $staticline = clone $line;
 
      $line->oldline = $staticline;
      $this->line = $line;
      $this->line->context = $this->context;
      $this->line->rang = $rang;
      $this->line->fk_reception = $this->id;
      $this->line->element_type = $element_type;
      $this->line->fk_product = $line->fk_product;
      $this->line->qty = $qty;
      $this->line->fk_unit = $fk_unit;
      $this->line->description = $description;
      if ($cost_price !== null && $cost_price !== '') {
        $this->line->cost_price = (float) $cost_price;
      }
      if ($ref_fourn !== null) {
        $this->line->ref_fourn = trim((string) $ref_fourn);
      }
      if ((int) $fk_entrepot >= 0) {
        $this->line->fk_entrepot = ((int) $fk_entrepot > 0 ? (int) $fk_entrepot : 0); // 0 clears the destination warehouse
      }
      if ($batch !== null) {
        $this->line->batch = trim((string) $batch);
      }
 
      if (is_array($array_options) && count($array_options) > 0) {
        // We replace values in this->line->array_options only for entries defined into $array_options
        foreach ($array_options as $key => $value) {
          $this->line->array_options[$key] = $array_options[$key];
        }
      }
 
 
      $result = $this->line->update($user, $notrigger);
      if ($result > 0) {
        // Reorder if child line
 
 
        $this->db->commit();
        return $result;
      } else {
        $this->error = $this->line->error;
 
        $this->db->rollback();
        return -1;
      }
    } else {
      $this->error = get_class($this)."::updatelinefree reception status makes operation forbidden";
      $this->errors = array('ReceptionStatusMakeOperationForbidden');
      return -2;
    }
  }
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function fetch_lines_free()
  {
    // phpcs:enable
    $this->lines = array();
 
    $sql = 'SELECT rc.rowid, rc.fk_reception, rc.fk_entrepot, rc.fk_product, rc.fk_unit, rc.description, rc.fk_elementdet, rc.fk_element, rc.element_type, rc.qty, rc.rang, rc.cost_price, rc.ref_fourn, rc.batch, rc.eatby, rc.sellby';
    $sql .= ' FROM '.MAIN_DB_PREFIX.'receptiondet_batch as rc';
    $sql .= ' LEFT JOIN '.MAIN_DB_PREFIX.'product as p ON (p.rowid = rc.fk_product)';
    $sql .= ' WHERE rc.fk_reception = '.((int) $this->id);
 
    $sql .= ' ORDER BY rc.rang, rc.rowid';
 
    dol_syslog(get_class($this)."::fetch_lines_free", LOG_DEBUG);
    $result = $this->db->query($sql);
    if ($result) {
      $num = $this->db->num_rows($result);
 
      $i = 0;
      while ($i < $num) {
        $objp = $this->db->fetch_object($result);
 
        $line = new ReceptionLineBatch($this->db);
 
        $line->rowid            = $objp->rowid;
        $line->id       = $objp->rowid;
        $line->fk_reception   = $this->id;
 
        $line->description      = $objp->description;
        $line->qty              = $objp->qty;
        $line->fk_entrepot      = $objp->fk_entrepot;
        $line->cost_price       = $objp->cost_price;
        $line->ref_fourn        = $objp->ref_fourn;
        $line->batch            = $objp->batch;
        $line->eatby            = $objp->eatby;
        $line->sellby           = $objp->sellby;
        $line->fk_product       = $objp->fk_product;
 
        $line->rang             = $objp->rang;
 
 
        $line->fk_element     = $objp->fk_element;
        $line->fk_unit          = $objp->fk_unit;
        $line->fk_elementdet  = $objp->fk_elementdet;
        $line->fk_element_type  = $objp->element_type;
        $line->fetch_optionals();
 
        $this->lines[$i] = $line;
 
        $i++;
      }
 
      $this->db->free($result);
 
      return 1;
    } else {
      $this->error = $this->db->error();
      return -3;
    }
  }
 
  public function getLinesArray()
  {
    return $this->fetch_lines_free();
  }
 
  public function update($user = null, $notrigger = 0)
  {
    global $conf;
    $error = 0;
 
    // Clean parameters
 
    if (isset($this->ref)) {
      $this->ref = trim($this->ref);
    }
    if (isset($this->entity)) {
      $this->entity = (int) $this->entity;
    }
    if (isset($this->ref_supplier)) {
      $this->ref_supplier = trim($this->ref_supplier);
    }
    if (isset($this->socid)) {
      $this->socid = (int) trim((string) $this->socid);
    }
    if (isset($this->fk_user_author)) {
      $this->fk_user_author = (int) $this->fk_user_author;
    }
    if (isset($this->fk_user_valid)) {
      $this->fk_user_valid = (int) $this->fk_user_valid;
    }
    if (isset($this->shipping_method_id)) {
      $this->shipping_method_id = (int) $this->shipping_method_id;
    }
    if (isset($this->tracking_number)) {
      $this->tracking_number = trim($this->tracking_number);
    }
    if (isset($this->statut)) {
      $this->statut = (int) $this->statut;
    }
    if (isset($this->trueDepth)) {
      $this->trueDepth = price2num($this->trueDepth);
    }
    if (isset($this->trueWidth)) {
      $this->trueWidth = price2num($this->trueWidth);
    }
    if (isset($this->trueHeight)) {
      $this->trueHeight = price2num($this->trueHeight);
    }
    $this->size_units = (int) $this->size_units;
 
    if (isset($this->trueWeight)) {
      $this->weight = price2num($this->trueWeight);
    }
    $this->weight_units = (int) $this->weight_units;
 
    if (isset($this->note_private)) {
      $this->note_private = trim($this->note_private);
    }
    if (isset($this->note_public)) {
      $this->note_public = trim($this->note_public);
    }
    if (isset($this->model_pdf)) {
      $this->model_pdf = trim($this->model_pdf);
    }
 
 
    // Check parameters
    // Put here code to add control on parameters values
 
    // Update request
    $sql = "UPDATE ".MAIN_DB_PREFIX."reception SET";
 
    $sql .= " ref=".(isset($this->ref) ? "'".$this->db->escape($this->ref)."'" : "null").",";
    $sql .= " ref_supplier=".(isset($this->ref_supplier) ? "'".$this->db->escape($this->ref_supplier)."'" : "null").",";
    $sql .= " fk_soc=".(isset($this->socid) ? ((int) $this->socid) : "null").",";
    $sql .= " date_creation=".(dol_strlen($this->date_creation) != 0 ? "'".$this->db->idate($this->date_creation)."'" : 'null').",";
    $sql .= " fk_user_author=".(isset($this->fk_user_author) ? ((int) $this->fk_user_author) : "null").",";
    $sql .= " date_valid=".(dol_strlen($this->date_valid) != 0 ? "'".$this->db->idate($this->date_valid)."'" : 'null').",";
    $sql .= " fk_user_valid=".(isset($this->fk_user_valid) ? ((int) $this->fk_user_valid) : "null").",";
    $sql .= " date_reception=".(dol_strlen($this->date_reception) != 0 ? "'".$this->db->idate($this->date_reception)."'" : 'null').",";
    $sql .= " date_delivery=".(dol_strlen($this->date_delivery) != 0 ? "'".$this->db->idate($this->date_delivery)."'" : 'null').",";
    $sql .= " fk_shipping_method=".((isset($this->shipping_method_id) && $this->shipping_method_id > 0) ? ((int) $this->shipping_method_id) : "null").",";
    $sql .= " tracking_number=".(isset($this->tracking_number) ? "'".$this->db->escape($this->tracking_number)."'" : "null").",";
    $sql .= " fk_statut=".(isset($this->statut) ? ((int) $this->statut) : "null").",";
    $sql .= " height=".(($this->trueHeight != '') ? (float) $this->trueHeight : "null").",";
    $sql .= " width=".(($this->trueWidth != '') ? (float) $this->trueWidth : "null").",";
    $sql .= " size_units=".((int) $this->size_units).",";
    $sql .= " size=".(($this->trueDepth != '') ? (float) $this->trueDepth : "null").",";
    $sql .= " weight_units=".((int) $this->weight_units).",";
    $sql .= " weight=".(($this->trueWeight != '') ? (float) $this->trueWeight : "null").",";
    $sql .= " note_private=".(isset($this->note_private) ? "'".$this->db->escape($this->note_private)."'" : "null").",";
    $sql .= " note_public=".(isset($this->note_public) ? "'".$this->db->escape($this->note_public)."'" : "null").",";
    $sql .= " model_pdf=".(isset($this->model_pdf) ? "'".$this->db->escape($this->model_pdf)."'" : "null").",";
    $sql .= " fk_projet=".((isset($this->fk_project) && $this->fk_project > 0) ? ((int) $this->fk_project) : "null").",";
    $sql .= " fk_warehouse=".((isset($this->fk_warehouse) && $this->fk_warehouse > 0) ? ((int) $this->fk_warehouse) : "null").",";
    $sql .= " entity = ".((int) $conf->entity);
    $sql .= " WHERE rowid=".((int) $this->id);
 
    $this->db->begin();
 
    dol_syslog(get_class($this)."::update", LOG_DEBUG);
    $resql = $this->db->query($sql);
    if (!$resql) {
      $error++;
      $this->errors[] = "Error ".$this->db->lasterror();
    }
 
    if (!$error) {
      if (!$notrigger) {
        // Call trigger
        $result = $this->call_trigger('RECEPTION_MODIFY', $user);
        if ($result < 0) {
          $error++;
        }
        // End call triggers
      }
    }
 
    // Commit or rollback
    if ($error) {
      foreach ($this->errors as $errmsg) {
        dol_syslog(get_class($this)."::update ".$errmsg, LOG_ERR);
        $this->error .= ($this->error ? ', '.$errmsg : $errmsg);
      }
      $this->db->rollback();
      return -1 * $error;
    } else {
      $this->db->commit();
      return 1;
    }
  }
 
  public function delete(User $user)
  {
    global $conf, $langs, $user;
    require_once DOL_DOCUMENT_ROOT.'/core/lib/files.lib.php';
 
    $error = 0;
    $this->error = '';
 
 
    $this->db->begin();
 
    // Stock control
    if (isModEnabled('stock') && ((getDolGlobalInt('STOCK_CALCULATE_ON_RECEPTION') && $this->status > Reception::STATUS_DRAFT)
        || (getDolGlobalInt('STOCK_CALCULATE_ON_RECEPTION_CLOSE') && $this->status == Reception::STATUS_CLOSED))
    ) {
      require_once DOL_DOCUMENT_ROOT."/product/stock/class/mouvementstock.class.php";
 
      $langs->load("agenda");
 
      // Loop on each product line to add a stock movement
      $sql = "SELECT COALESCE(NULLIF(ed.fk_product, 0), cd.fk_product) as fk_product, cd.subprice, ed.qty, ed.fk_entrepot, ed.eatby, ed.sellby, ed.batch, ed.rowid as receptiondet_batch_id";
      $sql .= " FROM ".MAIN_DB_PREFIX."receptiondet_batch as ed";
      $sql .= " LEFT JOIN ".MAIN_DB_PREFIX."commande_fournisseurdet as cd ON cd.rowid = ed.fk_elementdet";
      $sql .= " WHERE ed.fk_reception = ".((int) $this->id);
      $sql .= " AND COALESCE(NULLIF(ed.fk_product, 0), cd.fk_product) IS NOT NULL";
      $sql .= " AND ed.fk_entrepot IS NOT NULL AND ed.fk_entrepot > 0"; // A line without destination warehouse generates no stock movement (sample, servicing, ...)
 
      dol_syslog(get_class($this)."::delete select details", LOG_DEBUG);
      $resql = $this->db->query($sql);
      if ($resql) {
        $cpt = $this->db->num_rows($resql);
        for ($i = 0; $i < $cpt; $i++) {
          dol_syslog(get_class($this)."::delete movement index ".$i);
          $obj = $this->db->fetch_object($resql);
 
          $mouvS = new MouvementStock($this->db);
          // we do not log origin because it will be deleted
          $mouvS->origin = null;
 
          $result = $mouvS->livraison($user, $obj->fk_product, $obj->fk_entrepot, $obj->qty, 0, $langs->trans("ReceptionDeletedInDolibarr", $this->ref), '', $obj->eatby ? $this->db->jdate($obj->eatby) : null, $obj->sellby ? $this->db->jdate($obj->sellby) : null, $obj->batch); // Price is set to 0, because we don't want to see WAP changed
          if ($result < 0) {
            $error++;
            $this->error = $mouvS->error;
            $this->errors = $mouvS->errors;
          }
        }
      } else {
        $error++;
        $this->errors[] = "Error ".$this->db->lasterror();
      }
    }
 
    if (!$error) {
      $sanitized_main = MAIN_DB_PREFIX.'receptiondet_batch';
      $sanitized_ef = $sanitized_main."_extrafields";
 
      $sqlef = "DELETE FROM ".$sanitized_ef." WHERE fk_object IN (SELECT rowid FROM ".$sanitized_main." WHERE fk_reception = ".((int) $this->id).")";
 
      $sql = "DELETE FROM ".MAIN_DB_PREFIX."receptiondet_batch";
      $sql .= " WHERE fk_reception = ".((int) $this->id);
 
      if ($this->db->query($sqlef) && $this->db->query($sql)) {
        // Delete linked object
        $res = $this->deleteObjectLinked();
        if ($res < 0) {
          $error++;
        }
 
        if (!$error) {
          $sql = "DELETE FROM ".MAIN_DB_PREFIX."reception";
          $sql .= " WHERE rowid = ".((int) $this->id);
 
          if ($this->db->query($sql)) {
            // Call trigger
            $result = $this->call_trigger('RECEPTION_DELETE', $user);
            if ($result < 0) {
              $error++;
            }
            // End call triggers
 
            if (!empty($this->origin) && $this->origin_id > 0) {
              $this->fetch_origin();
              $origin_object = $this->origin_object;
              '@phan-var-force CommandeFournisseur $origin_object';
              if ($origin_object->status == 4) {     // If order source of reception is "partially received"
                // Check if there is no more reception. If not, we can move back status of order to "validated" instead of "reception in progress"
                $origin_object->loadReceptions();
                //var_dump($this->$origin->receptions);exit;
                if (count($origin_object->receptions) <= 0) {
                  $origin_object->setStatut(3); // CommandeFournisseur ordered
                }
              }
            }
 
            if (!$error) {
              $this->db->commit();
 
              // We delete PDFs
              $ref = dol_sanitizeFileName($this->ref);
              if (!empty($conf->reception->dir_output)) {
                $dir = $conf->reception->dir_output.'/'.$ref;
                $file = $dir.'/'.$ref.'.pdf';
                if (file_exists($file)) {
                  if (!dol_delete_file($file)) {
                    return 0;
                  }
                }
                if (file_exists($dir)) {
                  if (!dol_delete_dir_recursive($dir)) {
                    $this->error = $langs->trans("ErrorCanNotDeleteDir", $dir);
                    return 0;
                  }
                }
              }
 
              return 1;
            } else {
              $this->db->rollback();
              return -1;
            }
          } else {
            $this->error = $this->db->lasterror()." - sql=$sql";
            $this->db->rollback();
            return -3;
          }
        } else {
          $this->error = $this->db->lasterror()." - sql=$sql";
          $this->db->rollback();
          return -2;
        }
      } else {
        $this->error = $this->db->lasterror()." - sql=$sql";
        $this->db->rollback();
        return -1;
      }
    } else {
      $this->db->rollback();
      return -1;
    }
  }
 
  public function deleteLine($user, $lineid)
  {
    if ($this->status != self::STATUS_DRAFT) {
      $this->error = 'ErrorDeleteLineNotAllowedByObjectStatus';
      return -2;
    }
 
    $line = new ReceptionLineBatch($this->db);
    if ($line->fetch($lineid) <= 0) {
      $this->error = 'ErrorRecordNotFound';
      return -1;
    }
    if ($line->fk_reception != $this->id) {
      $this->error = 'ErrorLineIDDoesNotMatchWithObjectID';
      return -1;
    }
 
    $this->db->begin();
    if ($line->delete($user) > 0) {
      $this->db->commit();
      return 1;
    }
    $this->error = $line->error;
    $this->db->rollback();
    return -1;
  }
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function fetch_lines()
  {
    // Instantiated below: required here because a caller outside the
    // reception card (the REST API, a job) has not loaded them.
    require_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.dispatch.class.php';
    require_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.class.php';
 
    // phpcs:enable
    $this->lines = array();
 
    require_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.dispatch.class.php';
 
    $sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."receptiondet_batch";
    $sql .= " WHERE fk_reception = ".((int) $this->id);
 
    $resql = $this->db->query($sql);
 
    if (!empty($resql)) {
      while ($obj = $this->db->fetch_object($resql)) {
        $line = new CommandeFournisseurDispatch($this->db);
 
        $line->fetch($obj->rowid);
 
        // TODO Remove or keep this ?
        $line->fetch_product();
 
        $sql_commfourndet = 'SELECT qty, ref, label, description, tva_tx, vat_src_code, localtax1_tx, localtax2_tx, subprice, multicurrency_subprice, remise_percent, total_ht, total_ttc, total_tva, date_start, date_end, product_type';
        $sql_commfourndet .= ' FROM '.MAIN_DB_PREFIX.'commande_fournisseurdet';
        $sql_commfourndet .= ' WHERE rowid = '.((int) $line->fk_commandefourndet);
        $sql_commfourndet .= ' ORDER BY rang';
 
        $resql_commfourndet = $this->db->query($sql_commfourndet);
        if (!empty($resql_commfourndet)) {
          $obj = $this->db->fetch_object($resql_commfourndet);
          $line->qty_asked = $obj->qty;
          $line->description = $obj->description;
          $line->desc = $obj->description;
          $line->tva_tx = $obj->tva_tx;
          $line->vat_src_code = $obj->vat_src_code;
          $line->localtax1_tx = $obj->localtax1_tx;
          $line->localtax2_tx = $obj->localtax2_tx;
          $line->subprice = $obj->subprice;
          $line->multicurrency_subprice = $obj->multicurrency_subprice;
          $line->remise_percent = $obj->remise_percent;
          $line->label = !empty($obj->label) ? $obj->label : (is_object($line->product) ? $line->product->label : '');
          $line->ref_supplier = $obj->ref;
          $line->total_ht = $obj->total_ht;
          $line->total_ttc = $obj->total_ttc;
          $line->total_tva = $obj->total_tva;
          $line->date_start = $this->db->jdate($obj->date_start);
          $line->date_end = $this->db->jdate($obj->date_end);
          $line->product_type = $obj->product_type;
        } else {
          $line->qty_asked = 0;
          $line->description = '';
          $line->desc = '';
          $line->label = $obj->label;
        }
 
        $pu_ht = ($line->subprice * $line->qty) * (100 - $line->remise_percent) / 100;
        $tva = $pu_ht * $line->tva_tx / 100;
        $this->total_ht += $pu_ht;
        $this->total_tva += $pu_ht * $line->tva_tx / 100;
 
        $this->total_ttc += $pu_ht + $tva;
 
        if (isModEnabled('productbatch') && !empty($line->batch)) {
          $detail_batch = new stdClass();
          $detail_batch->eatby = $line->eatby;
          $detail_batch->sellby = $line->sellby;
          $detail_batch->batch = $line->batch;
          $detail_batch->qty = $line->qty;
 
          $line->detail_batch[] = $detail_batch;
        }
 
        $this->lines[] = $line;
      }
 
      return 1;
    } else {
      return -1;
    }
  }
 
  public function getTooltipContentArray($params)
  {
    global $langs;
 
    $datas = array();
    $datas['picto'] = img_picto('', $this->picto).' <u>'.$langs->trans("Reception").'</u>';
    $datas['ref'] = '<br><b>'.$langs->trans('Ref').':</b> '.$this->ref;
    $datas['refsupplier'] = '<br><b>'.$langs->trans('RefSupplier').':</b> '.($this->ref_supplier ? $this->ref_supplier : '');
 
    return $datas;
  }
 
  public function getNomUrl($withpicto = 0, $option = '', $max = 0, $short = 0, $notooltip = 0)
  {
    global $langs, $hookmanager;
 
    $result = '';
    $params = array();
    $label = $this->getTooltipContent($params);
 
    $url = DOL_URL_ROOT.'/reception/card.php?id='.$this->id;
 
    if ($short) {
      return $url;
    }
 
    $linkclose = '';
    if (empty($notooltip)) {
      if (getDolGlobalInt('MAIN_OPTIMIZEFORTEXTBROWSER')) {
        $label = $langs->trans("Reception");
        $linkclose .= ' alt="'.dolPrintHTMLForAttribute($label).'"';
      }
      $linkclose .= ' title="'.dolPrintHTMLForAttribute($label).'"';
      $linkclose .= ' class="classfortooltip"';
    }
 
    $linkstart = '<a href="'.$url.'"';
    $linkstart .= $linkclose.'>';
    $linkend = '</a>';
 
    $result .= $linkstart;
    if ($withpicto) {
      $result .= img_object(($notooltip ? '' : $label), $this->picto, '', 0, 0, $notooltip ? 0 : 1);
    }
    if ($withpicto != 2) {
      $result .= $this->ref;
    }
 
    $result .= $linkend;
 
    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;
  }
 
  public function getLibStatut($mode = 0)
  {
    return $this->LibStatut($this->statut, $mode);
  }
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function LibStatut($status, $mode)
  {
    // phpcs:enable
    global $langs;
 
    // List of long language codes for status
    $this->labelStatus[-1] = 'StatusReceptionCanceled';
    $this->labelStatus[0]  = 'StatusReceptionDraft';
    // product to receive if stock increase is on close or already received if stock increase is on validation
    $this->labelStatus[1]  = 'StatusReceptionValidated';
    if (getDolGlobalInt("STOCK_CALCULATE_ON_RECEPTION")) {
      $this->labelStatus[1]  = 'StatusReceptionValidatedReceived';
    }
    if (getDolGlobalInt("STOCK_CALCULATE_ON_RECEPTION_CLOSE")) {
      $this->labelStatus[1]  = 'StatusReceptionValidatedToReceive';
    }
    $this->labelStatus[2]  = 'StatusReceptionProcessed';
 
    // List of short language codes for status
    $this->labelStatusShort[-1] = 'StatusReceptionCanceledShort';
    $this->labelStatusShort[0]  = 'StatusReceptionDraftShort';
    $this->labelStatusShort[1]  = 'StatusReceptionValidatedShort';
    $this->labelStatusShort[2]  = 'StatusReceptionProcessedShort';
 
    $labelStatus = $langs->transnoentitiesnoconv($this->labelStatus[$status]);
    $labelStatusShort = $langs->transnoentitiesnoconv($this->labelStatusShort[$status]);
 
    $statusType = 'status'.$status;
    if ($status == self::STATUS_VALIDATED) {
      $statusType = 'status4';
    }
    if ($status == self::STATUS_CLOSED) {
      $statusType = 'status6';
    }
 
    return dolGetStatus($labelStatus, $labelStatusShort, '', $statusType, $mode);
  }
 
  public function getKanbanView($option = '', $arraydata = null)
  {
    $selected = (empty($arraydata['selected']) ? 0 : $arraydata['selected']);
 
    $return = '<div class="box-flex-item box-flex-grow-zero">';
    $return .= '<div class="info-box info-box-sm">';
    $return .= '<div class="info-box-icon bg-infobox-action">';
    $return .= img_picto('', 'order');
    $return .= '</div>';
    $return .= '<div class="info-box-content">';
    $return .= '<span class="info-box-ref inline-block tdoverflowmax150 valignmiddle">'.(method_exists($this, 'getNomUrl') ? $this->getNomUrl() : $this->ref).'</span>';
    if ($selected >= 0) {
      $return .= '<input id="cb'.$this->id.'" class="flat checkforselect fright" type="checkbox" name="toselect[]" value="'.$this->id.'"'.($selected ? ' checked="checked"' : '').'>';
    }
    if (property_exists($this, 'thirdparty') && is_object($this->thirdparty)) {
      $return .= '<br><div class="info-box-ref tdoverflowmax150">'.$this->thirdparty->getNomUrl(1).'</div>';
    }
    /*if (property_exists($this, 'total_ht')) {
      $return .= '<div class="info-box-ref amount">'.price($this->total_ht, 0, $langs, 0, -1, -1, getDolCurrency()).' '.$langs->trans('HT').'</div>';
    }*/
    if (method_exists($this, 'getLibStatut')) {
      $return .= '<div class="info-box-status">'.$this->getLibStatut(3).'</div>';
    }
    $return .= '</div>';
    $return .= '</div>';
    $return .= '</div>';
 
    return $return;
  }
 
  public function initAsSpecimen()
  {
    global $langs;
 
    include_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.class.php';
    include_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.dispatch.class.php';
    $now = dol_now();
 
    dol_syslog(get_class($this)."::initAsSpecimen");
 
    $order = new CommandeFournisseur($this->db);
    $order->initAsSpecimen();
 
    // Initialise parameters
    $this->id = 0;
    $this->ref = 'SPECIMEN';
    $this->specimen = 1;
    $this->statut               = 1;
    $this->status               = 1;
    $this->date                 = $now;
    $this->date_creation        = $now;
    $this->date_valid           = $now;
    $this->date_delivery        = $now;
    $this->date_reception     = $now + 24 * 3600;
    $this->entrepot_id          = 0;
    $this->socid                = 1;
    $this->origin_id            = 1;
    $this->origin_type          = 'supplier_order';
    $this->origin_object        = $order;
    $this->note_private     = 'Private note';
    $this->note_public      = 'Public note';
    $this->tracking_number    = 'TRACKID-ABC123';
    $this->fk_incoterms     = 1;
    $nbp = min(1000, GETPOSTINT('nblines') ? GETPOSTINT('nblines') : 5);  // We can force the nb of lines to test from command line (but not more than 1000)
    $xnbp = 0;
    while ($xnbp < $nbp) {
      $line = new CommandeFournisseurDispatch($this->db);
      $line->desc = $langs->trans("Description")." ".$xnbp;
      $line->libelle = $langs->trans("Description")." ".$xnbp;  // deprecated
      $line->label = $langs->trans("Description")." ".$xnbp;
      $line->qty = 10;
 
      $line->fk_product = $this->origin_object->lines[$xnbp]->fk_product;
 
      $this->lines[] = $line;
      $xnbp++;
    }
 
    return 1;
  }
 
  public function setDeliveryDate($user, $delivery_date)
  {
    // phpcs:enable
    if ($user->hasRight('reception', 'creer')) {
      $sql = "UPDATE ".MAIN_DB_PREFIX."reception";
      $sql .= " SET date_delivery = ".($delivery_date ? "'".$this->db->idate($delivery_date)."'" : 'null');
      $sql .= " WHERE rowid = ".((int) $this->id);
 
      dol_syslog(get_class($this)."::setDeliveryDate", LOG_DEBUG);
      $resql = $this->db->query($sql);
      if ($resql) {
        $this->date_delivery = $delivery_date;
        return 1;
      } else {
        $this->error = $this->db->error();
        return -1;
      }
    } else {
      return -2;
    }
  }
 
  public function setReceptionDate($user, $reception_date)
  {
    if ($user->hasRight('reception', 'creer')) {
      $sql = "UPDATE ".MAIN_DB_PREFIX."reception";
      $sql .= " SET date_reception = ".($reception_date ? "'".$this->db->idate($reception_date)."'" : 'null');
      $sql .= " WHERE rowid = ".((int) $this->id);
 
      dol_syslog(get_class($this)."::setReceptionDate", LOG_DEBUG);
      $resql = $this->db->query($sql);
      if ($resql) {
        $this->date_reception = $reception_date;
        return 1;
      } else {
        $this->error = $this->db->error();
        return -1;
      }
    } else {
      return -2;
    }
  }
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function fetch_delivery_methods()
  {
    // phpcs:enable
    global $langs;
    $this->meths = array();
 
    $sql = "SELECT em.rowid, em.code, em.libelle";
    $sql .= " FROM ".MAIN_DB_PREFIX."c_shipment_mode as em";
    $sql .= " WHERE em.active = 1";
    $sql .= " ORDER BY em.libelle ASC";
 
    $resql = $this->db->query($sql);
    if ($resql) {
      while ($obj = $this->db->fetch_object($resql)) {
        $label = $langs->trans('ReceptionMethod'.$obj->code);
        $this->meths[$obj->rowid] = ($label != 'ReceptionMethod'.$obj->code ? $label : $obj->libelle);
      }
    }
  }
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function list_delivery_methods($id = 0)
  {
    // phpcs:enable
    global $langs;
 
    $this->listmeths = array();
    $i = 0;
 
    $sql = "SELECT em.rowid, em.code, em.libelle, em.description, em.tracking, em.active";
    $sql .= " FROM ".MAIN_DB_PREFIX."c_shipment_mode as em";
    if (!empty($id)) {
      $sql .= " WHERE em.rowid = ".((int) $id);
    }
 
    $resql = $this->db->query($sql);
    if ($resql) {
      while ($obj = $this->db->fetch_object($resql)) {
        $this->listmeths[$i]['rowid'] = $obj->rowid;
        $this->listmeths[$i]['code'] = $obj->code;
        $label = $langs->trans('ReceptionMethod'.$obj->code);
        $this->listmeths[$i]['libelle'] = ($label != 'ReceptionMethod'.$obj->code ? $label : $obj->libelle);
        $this->listmeths[$i]['description'] = $obj->description;
        $this->listmeths[$i]['tracking'] = $obj->tracking;
        $this->listmeths[$i]['active'] = $obj->active;
        $i++;
      }
    }
  }
 
  public function getUrlTrackingStatus($value = '')
  {
    if (!empty($this->shipping_method_id)) {
      $sql = "SELECT em.code, em.tracking";
      $sql .= " FROM ".MAIN_DB_PREFIX."c_shipment_mode as em";
      $sql .= " WHERE em.rowid = ".((int) $this->shipping_method_id);
 
      $resql = $this->db->query($sql);
      if ($resql) {
        if ($obj = $this->db->fetch_object($resql)) {
          $tracking = $obj->tracking;
        }
      }
    }
 
    if (!empty($tracking) && !empty($value)) {
      $url = str_replace('{TRACKID}', $value, $tracking);
      $this->tracking_url = sprintf('<a target="_blank" rel="noopener noreferrer" href="%s">%s</a>', $url, ($value ? $value : 'url'));
    } else {
      $this->tracking_url = $value;
    }
  }
 
  public function setClosed()
  {
    global $conf, $langs, $user;
 
    $error = 0;
 
    // Protection. This avoid to move stock later when we should not
    if ($this->statut == Reception::STATUS_CLOSED) {
      dol_syslog(get_class($this)."::setClosed already in closed status", LOG_WARNING);
      return 0;
    }
 
    $this->db->begin();
 
    $sql = 'UPDATE '.MAIN_DB_PREFIX.'reception SET fk_statut = '.self::STATUS_CLOSED;
    $sql .= " WHERE rowid = ".((int) $this->id).' AND fk_statut > 0';
 
    $resql = $this->db->query($sql);
    if ($resql) {
      // Set order billed if 100% of order is received (qty in reception lines match qty in order lines)
      if ($this->origin == 'order_supplier' && $this->origin_id > 0) {
        require_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.class.php';
 
        $order = new CommandeFournisseur($this->db);
        $order->fetch($this->origin_id);
 
        $order->loadReceptions(self::STATUS_CLOSED); // Fill $order->receptions = array(orderlineid => qty)
 
        $receptions_match_order = 1;
        foreach ($order->lines as $line) {
          $lineid = $line->id;
          $qty = $line->qty;
          if (($line->product_type == 0 || getDolGlobalInt('STOCK_SUPPORTS_SERVICES')) && $order->receptions[$lineid] < $qty) {
            $receptions_match_order = 0;
            $text = 'Qty for order line id '.$lineid.' is '.$qty.'. However in the receptions with status Reception::STATUS_CLOSED='.self::STATUS_CLOSED.' we have qty = '.$order->receptions[$lineid].', so we can t close order';
            dol_syslog($text);
            break;
          }
        }
        if ($receptions_match_order) {
          dol_syslog("Qty for the ".count($order->lines)." lines of order have same value for receptions with status Reception::STATUS_CLOSED=".self::STATUS_CLOSED.', so we close order');
          $order->Livraison($user, dol_now(), 'tot', 'Reception '.$this->ref);
        }
      }
 
      $this->statut = self::STATUS_CLOSED;
      $this->status = self::STATUS_CLOSED;
 
      // If stock increment is done on closing
      if (!$error && isModEnabled('stock') && getDolGlobalInt('STOCK_CALCULATE_ON_RECEPTION_CLOSE')) {
        require_once DOL_DOCUMENT_ROOT.'/product/stock/class/mouvementstock.class.php';
 
        $langs->load("agenda");
 
        // Loop on each product line to add a stock movement
        // TODO possibility to receive from a proposal or other origin ?
        $sql = "SELECT COALESCE(NULLIF(ed.fk_product, 0), cd.fk_product) as fk_product, cd.subprice,";
        $sql .= " ed.rowid, ed.qty, ed.fk_entrepot,";
        $sql .= " ed.eatby, ed.sellby, ed.batch,";
        $sql .= " ed.fk_elementdet, ed.cost_price";
        $sql .= " FROM ".MAIN_DB_PREFIX."receptiondet_batch as ed";
        $sql .= " LEFT JOIN ".MAIN_DB_PREFIX."commande_fournisseurdet as cd ON cd.rowid = ed.fk_elementdet";
        $sql .= " WHERE ed.fk_reception = ".((int) $this->id);
        $sql .= " AND COALESCE(NULLIF(ed.fk_product, 0), cd.fk_product) IS NOT NULL";
        $sql .= " AND ed.fk_entrepot IS NOT NULL AND ed.fk_entrepot > 0"; // A line without destination warehouse generates no stock movement (sample, servicing, ...)
 
        dol_syslog(get_class($this)."::valid select details", LOG_DEBUG);
        $resql = $this->db->query($sql);
 
        if ($resql) {
          $cpt = $this->db->num_rows($resql);
          for ($i = 0; $i < $cpt; $i++) {
            $obj = $this->db->fetch_object($resql);
 
            $qty = $obj->qty;
 
            if ($qty == 0 || ($qty < 0 && !getDolGlobalInt('RECEPTION_ALLOW_NEGATIVE_QTY'))) {
              continue;
            }
 
            dol_syslog(get_class($this)."::valid movement index ".$i." ed.rowid=".$obj->rowid);
 
            $mouvS = new MouvementStock($this->db);
            $mouvS->origin = &$this;
            $mouvS->setOrigin($this->element, $this->id, $obj->fk_elementdet, $obj->rowid);
 
            if (empty($obj->batch)) {
              // line without batch detail
 
              // We decrement stock of product (and sub-products) -> update table llx_product_stock (key of this table is fk_product+fk_entrepot) and add a movement record
              $inventorycode = '';
              $result = $mouvS->reception($user, $obj->fk_product, $obj->fk_entrepot, $qty, $obj->cost_price, $langs->trans("ReceptionClassifyClosedInDolibarr", $this->ref), '', '', '', '', 0, $inventorycode);
              if ($result < 0) {
                $this->error = $mouvS->error;
                $this->errors = $mouvS->errors;
                $error++;
                break;
              }
            } else {
              // line with batch detail
 
              // We decrement stock of product (and sub-products) -> update table llx_product_stock (key of this table is fk_product+fk_entrepot) and add a movement record
              $inventorycode = '';
              $result = $mouvS->reception($user, $obj->fk_product, $obj->fk_entrepot, $qty, $obj->cost_price, $langs->trans("ReceptionClassifyClosedInDolibarr", $this->ref), $this->db->jdate($obj->eatby), $this->db->jdate($obj->sellby), $obj->batch, '', 0, $inventorycode);
 
              if ($result < 0) {
                $this->error = $mouvS->error;
                $this->errors = $mouvS->errors;
                $error++;
                break;
              }
            }
          }
        } else {
          $this->error = $this->db->lasterror();
          $error++;
        }
      }
 
      // Call trigger
      if (!$error) {
        $result = $this->call_trigger('RECEPTION_CLOSED', $user);
        if ($result < 0) {
          $error++;
        }
      }
    } else {
      dol_print_error($this->db);
      $error++;
    }
 
    if (!$error) {
      $this->db->commit();
      return 1;
    } else {
      $this->statut = self::STATUS_VALIDATED;
      $this->status = self::STATUS_VALIDATED;
      $this->db->rollback();
      return -1;
    }
  }
 
  public function setBilled()
  {
    global $user;
    $error = 0;
 
    $this->db->begin();
 
    if ($this->statut == Reception::STATUS_VALIDATED) {
      // do not close if already closed
      $this->setClosed();
    }
 
    $sql = 'UPDATE '.MAIN_DB_PREFIX.'reception SET billed=1';
    $sql .= " WHERE rowid = ".((int) $this->id).' AND fk_statut > 0';
 
    $resql = $this->db->query($sql);
    if ($resql) {
      $this->billed = 1;
 
      // Call trigger
      $result = $this->call_trigger('RECEPTION_BILLED', $user);
      if ($result < 0) {
        $this->billed = 0;
        $error++;
      }
    } else {
      $error++;
      $this->errors[] = $this->db->lasterror;
    }
 
    if (empty($error)) {
      $this->db->commit();
      return 1;
    } else {
      $this->db->rollback();
      return -1;
    }
  }
 
  public function reOpen()
  {
    global $langs, $user;
 
    $error = 0;
 
    $this->db->begin();
 
    $sql = 'UPDATE '.MAIN_DB_PREFIX.'reception SET fk_statut=1, billed=0';
    $sql .= " WHERE rowid = ".((int) $this->id).' AND fk_statut > 0';
 
    $resql = $this->db->query($sql);
    $rollbackStatus = $this->status;
    $rollbackBilled = $this->billed;
    if ($resql) {
      $this->statut = self::STATUS_VALIDATED;
      $this->status = self::STATUS_VALIDATED;
      $this->billed = 0;
 
      // If stock increment is done on closing
      if (!$error && isModEnabled('stock') && getDolGlobalInt('STOCK_CALCULATE_ON_RECEPTION_CLOSE')) {
        require_once DOL_DOCUMENT_ROOT.'/product/stock/class/mouvementstock.class.php';
        $numref = (string) $this->ref;
        $langs->load("agenda");
 
        // Loop on each product line to add a stock movement
        // TODO possibility to receive from a proposal or other origin
        $sql = "SELECT COALESCE(NULLIF(ed.fk_product, 0), cd.fk_product) as fk_product, cd.subprice,";
        $sql .= " ed.rowid, ed.qty, ed.fk_entrepot,";
        $sql .= " ed.eatby, ed.sellby, ed.batch,";
        $sql .= " ed.fk_elementdet, ed.cost_price";
        $sql .= " FROM ".MAIN_DB_PREFIX."receptiondet_batch as ed";
        $sql .= " LEFT JOIN ".MAIN_DB_PREFIX."commande_fournisseurdet as cd ON cd.rowid = ed.fk_elementdet";
        $sql .= " WHERE ed.fk_reception = ".((int) $this->id);
        $sql .= " AND COALESCE(NULLIF(ed.fk_product, 0), cd.fk_product) IS NOT NULL";
        $sql .= " AND ed.fk_entrepot IS NOT NULL AND ed.fk_entrepot > 0"; // A line without destination warehouse generates no stock movement (sample, servicing, ...)
 
        dol_syslog(get_class($this)."::valid select details", LOG_DEBUG);
        $resql = $this->db->query($sql);
        if ($resql) {
          $cpt = $this->db->num_rows($resql);
          for ($i = 0; $i < $cpt; $i++) {
            $obj = $this->db->fetch_object($resql);
 
            $qty = $obj->qty;
 
            if ($qty == 0 || ($qty < 0 && !getDolGlobalInt('RECEPTION_ALLOW_NEGATIVE_QTY'))) {
              continue;
            }
            dol_syslog(get_class($this)."::reopen reception movement index ".$i." ed.rowid=".$obj->rowid);
 
            //var_dump($this->lines[$i]);
            $mouvS = new MouvementStock($this->db);
            $mouvS->origin = &$this;
            $mouvS->setOrigin($this->element, $this->id, $obj->fk_elementdet, $obj->rowid);
 
            if (empty($obj->batch)) {
              // line without batch detail
 
              // We decrement stock of product (and sub-products) -> update table llx_product_stock (key of this table is fk_product+fk_entrepot) and add a movement record
              $inventorycode = '';
              $result = $mouvS->livraison($user, $obj->fk_product, $obj->fk_entrepot, $qty, $obj->cost_price, $langs->trans("ReceptionUnClassifyCloseddInDolibarr", $numref), '', '', '', '', 0, $inventorycode);
 
              if ($result < 0) {
                $this->error = $mouvS->error;
                $this->errors = $mouvS->errors;
                $error++;
                break;
              }
            } else {
              // line with batch detail
 
              // We decrement stock of product (and sub-products) -> update table llx_product_stock (key of this table is fk_product+fk_entrepot) and add a movement record
              $inventorycode = '';
              $result = $mouvS->livraison($user, $obj->fk_product, $obj->fk_entrepot, $qty, $obj->cost_price, $langs->trans("ReceptionUnClassifyCloseddInDolibarr", $numref), '', $this->db->jdate($obj->eatby), $this->db->jdate($obj->sellby), $obj->batch, $obj->fk_origin_stock, $inventorycode);
              if ($result < 0) {
                $this->error = $mouvS->error;
                $this->errors = $mouvS->errors;
                $error++;
                break;
              }
            }
          }
        } else {
          $this->error = $this->db->lasterror();
          $error++;
        }
      }
 
      if (!$error) {
        // Call trigger
        $result = $this->call_trigger('RECEPTION_REOPEN', $user);
        if ($result < 0) {
          $error++;
        }
      }
 
      if (!$error && $this->origin == 'order_supplier') {
        require_once DOL_DOCUMENT_ROOT.'/fourn/class/fournisseur.commande.class.php';
 
        $commande = new CommandeFournisseur($this->db);
        $commande->fetch($this->origin_id);
        $result = $commande->setStatus($user, 4);
        if ($result < 0) {
          $error++;
          $this->error = $commande->error;
          $this->errors = $commande->errors;
        }
      }
    } else {
      $error++;
      $this->errors[] = $this->db->lasterror();
    }
 
    if (!$error) {
      $this->db->commit();
      return 1;
    } else {
      $this->statut = $this->status = $rollbackStatus;
      $this->billed = $rollbackBilled;
      $this->db->rollback();
      return -1;
    }
  }
 
  public function setDraft($user)
  {
    // phpcs:enable
    global $langs;
 
    $error = 0;
 
    // Protection
    if ($this->statut <= self::STATUS_DRAFT) {
      return 0;
    }
 
    if (!((!getDolGlobalInt('MAIN_USE_ADVANCED_PERMS') && $user->hasRight('reception', 'creer'))
    || (getDolGlobalInt('MAIN_USE_ADVANCED_PERMS') && $user->hasRight('reception', 'reception_advance', 'validate')))) {
      $this->error = 'Permission denied';
      return -1;
    }
 
    $this->db->begin();
 
    $sql = "UPDATE ".MAIN_DB_PREFIX."reception";
    $sql .= " SET fk_statut = ".self::STATUS_DRAFT;
    $sql .= " WHERE rowid = ".((int) $this->id);
 
    dol_syslog(__METHOD__, LOG_DEBUG);
    if ($this->db->query($sql)) {
      // If stock increment is done on closing
      if (!$error && isModEnabled('stock') && getDolGlobalInt('STOCK_CALCULATE_ON_RECEPTION')) {
        require_once DOL_DOCUMENT_ROOT.'/product/stock/class/mouvementstock.class.php';
 
        $langs->load("agenda");
 
        // Loop on each product line to add a stock movement
        // TODO possibility to receive from a proposal or other origin
        $sql = "SELECT COALESCE(NULLIF(ed.fk_product, 0), cd.fk_product) as fk_product, cd.subprice,";
        $sql .= " ed.rowid, ed.qty, ed.fk_entrepot,";
        $sql .= " ed.eatby, ed.sellby, ed.batch,";
        $sql .= " ed.fk_elementdet, ed.cost_price";
        $sql .= " FROM ".MAIN_DB_PREFIX."receptiondet_batch as ed";
        $sql .= " LEFT JOIN ".MAIN_DB_PREFIX."commande_fournisseurdet as cd ON cd.rowid = ed.fk_elementdet";
        $sql .= " WHERE ed.fk_reception = ".((int) $this->id);
        $sql .= " AND COALESCE(NULLIF(ed.fk_product, 0), cd.fk_product) IS NOT NULL";
        $sql .= " AND ed.fk_entrepot IS NOT NULL AND ed.fk_entrepot > 0"; // A line without destination warehouse generates no stock movement (sample, servicing, ...)
 
        dol_syslog(get_class($this)."::valid select details", LOG_DEBUG);
        $resql = $this->db->query($sql);
        if ($resql) {
          $cpt = $this->db->num_rows($resql);
          for ($i = 0; $i < $cpt; $i++) {
            $obj = $this->db->fetch_object($resql);
 
            $qty = $obj->qty;
 
            if ($qty == 0 || ($qty < 0 && !getDolGlobalInt('RECEPTION_ALLOW_NEGATIVE_QTY'))) {
              continue;
            }
 
            dol_syslog(get_class($this)."::reopen reception movement index ".$i." ed.rowid=".$obj->rowid);
 
            //var_dump($this->lines[$i]);
            $mouvS = new MouvementStock($this->db);
            $mouvS->origin = &$this;
            $mouvS->setOrigin($this->element, $this->id, $obj->fk_elementdet, $obj->rowid);
 
            if (empty($obj->batch)) {
              // line without batch detail
 
              // We decrement stock of product (and sub-products) -> update table llx_product_stock (key of this table is fk_product+fk_entrepot) and add a movement record
              $inventorycode = '';
              $result = $mouvS->livraison($user, $obj->fk_product, $obj->fk_entrepot, $qty, $obj->cost_price, $langs->trans("ReceptionBackToDraftInDolibarr", $this->ref), '', '', '', '', 0, $inventorycode);
              if ($result < 0) {
                $this->error = $mouvS->error;
                $this->errors = $mouvS->errors;
                $error++;
                break;
              }
            } else {
              // line with batch detail
 
              // We decrement stock of product (and sub-products) -> update table llx_product_stock (key of this table is fk_product+fk_entrepot) and add a movement record
              $inventorycode = '';
              $result = $mouvS->livraison($user, $obj->fk_product, $obj->fk_entrepot, $qty, $obj->cost_price, $langs->trans("ReceptionBackToDraftInDolibarr", $this->ref), '', $this->db->jdate($obj->eatby), $this->db->jdate($obj->sellby), $obj->batch, 0, $inventorycode);
              if ($result < 0) {
                $this->error = $mouvS->error;
                $this->errors = $mouvS->errors;
                $error++;
                break;
              }
            }
          }
        } else {
          $this->error = $this->db->lasterror();
          $error++;
        }
      }
 
      if (!$error) {
        // Call trigger
        $result = $this->call_trigger('RECEPTION_UNVALIDATE', $user);
        if ($result < 0) {
          $error++;
        }
      }
      if ($this->origin == 'order_supplier') {
        if (!empty($this->origin) && $this->origin_id > 0) {
          $this->fetch_origin();
          if ($this->origin_object->statut == 4) {  // If order source of reception is "partially received"
            // Check if there is no more reception validated.
            $this->origin_object->fetchObjectLinked();
            $setStatut = 1;
            if (!empty($this->origin_object->linkedObjects['reception'])) {
              foreach ($this->origin_object->linkedObjects['reception'] as $rcption) {
                if ($rcption->statut > 0) {
                  $setStatut = 0;
                  break;
                }
              }
              //var_dump($this->$origin->receptions);exit;
              if ($setStatut) {
                $this->origin_object->setStatut(3); // CommandeFournisseur ordered
              }
            }
          }
        }
      }
 
      if (!$error) {
        $this->statut = self::STATUS_DRAFT;
        $this->status = self::STATUS_DRAFT;
        $this->db->commit();
        return 1;
      } else {
        $this->db->rollback();
        return -1;
      }
    } else {
      $this->error = $this->db->error();
      $this->db->rollback();
      return -1;
    }
  }
 
  public function generateDocument($modele, $outputlangs, $hidedetails = 0, $hidedesc = 0, $hideref = 0)
  {
    global $conf, $langs;
 
    $langs->load("receptions");
 
    if (!dol_strlen($modele)) {
      $modele = 'squille';
 
      if ($this->model_pdf) {
        $modele = $this->model_pdf;
      } elseif (getDolGlobalString('RECEPTION_ADDON_PDF')) {
        $modele = getDolGlobalString('RECEPTION_ADDON_PDF');
      }
    }
 
    $modelpath = "core/modules/reception/doc/";
 
    $this->fetch_origin();
 
    return $this->commonGenerateDocument($modelpath, $modele, $outputlangs, $hidedetails, $hidedesc, $hideref);
  }
 
  public static function replaceThirdparty(DoliDB $dbs, $origin_id, $dest_id)
  {
    $tables = array('reception');
 
    return CommonObject::commonReplaceThirdparty($dbs, $origin_id, $dest_id, $tables);
  }
 
  public static function replaceProduct(DoliDB $dbs, $origin_id, $dest_id)
  {
    $tables = array(
      'receptiondet_batch'
    );
 
    return CommonObject::commonReplaceProduct($dbs, $origin_id, $dest_id, $tables);
  }
}