expedition.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@inodbox.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-2020  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-2017  Francis Appels          <francis.appels@yahoo.com>
 * Copyright (C) 2015       Claudio Aschieri        <c.aschieri@19.coop>
 * Copyright (C) 2016-2024  Ferran Marcet     <fmarcet@2byte.es>
 * Copyright (C) 2018       Nicolas ZABOURI     <info@inovea-conseil.com>
 * Copyright (C) 2018-2025  Frédéric France         <frederic.france@free.fr>
 * Copyright (C) 2020       Lenin Rivas           <lenin@leninrivas.com>
 * Copyright (C) 2024-2025  MDW             <mdeweerd@users.noreply.github.com>
 * Copyright (C) 2024   William Mead      <william.mead@manchenumerique.fr>
 *
 * 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."/expedition/class/expeditionligne.class.php";
require_once DOL_DOCUMENT_ROOT.'/core/class/commonincoterm.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';
}
require_once DOL_DOCUMENT_ROOT.'/expedition/class/expeditionlinebatch.class.php';
require_once DOL_DOCUMENT_ROOT.'/core/class/commonsignedobject.class.php';
require_once DOL_DOCUMENT_ROOT.'/subtotals/class/commonsubtotal.class.php';
 
class Expedition extends CommonObject
{
  use CommonIncoterm;
  use CommonSignedObject;
  use CommonSubtotal;
 
  public $element = "shipping";
 
  public $fk_element = "fk_expedition";
 
  public $table_element = "expedition";
 
  public $table_element_line = "expeditiondet";
 
  public $picto = 'dolly';
 
 
  public $fields = array();
 
  public $user_author_id;
 
  public $fk_user_author;
 
  public $socid;
 
  public $ref_client;
 
  public $ref_customer;
 
  public $entrepot_id;
 
  public $tracking_number;
 
  public $tracking_url;
  public $billed;
 
  public $trueWeight;
  public $weight_units;
  public $trueWidth;
  public $width_units;
  public $trueHeight;
  public $height_units;
  public $trueDepth;
  public $depth_units;
  public $trueSize;
 
  public $livraison_id;
 
  public $multicurrency_subprice;
 
  public $size_units;
 
  public $sizeH;
 
  public $sizeS;
 
  public $sizeW;
 
  public $weight;
 
  public $date_delivery;
 
  public $date;
 
  public $date_expedition;
 
  public $date_shipping;
 
  public $date_valid;
 
  public $meths;
  public $listmeths; // List of carriers
 
  public $commande_id;
 
  public $commande;
 
  public $lines = array();
 
  // Multicurrency
  public $fk_multicurrency;
 
  public $multicurrency_code;
  public $multicurrency_tx;
  public $multicurrency_total_ht;
  public $multicurrency_total_tva;
  public $multicurrency_total_ttc;
 
  const STATUS_DRAFT = 0;
 
  const STATUS_VALIDATED = 1;
 
  const STATUS_CLOSED = 2;
 
  const STATUS_CANCELED = -1;
 
  const STATUS_SHIPMENT_IN_PROGRESS = 3;
 
  public function __construct($db)
  {
    global $conf;
 
    $this->db = $db;
 
    $this->ismultientitymanaged = 1;
    $this->isextrafieldmanaged = 1;
 
    // List of long language codes for status
    $this->labelStatus = array();
    $this->labelStatus[-1] = 'StatusSendingCanceled';
    $this->labelStatus[0]  = 'StatusSendingDraft';
    $this->labelStatus[1]  = 'StatusSendingValidated';
    $this->labelStatus[2]  = 'StatusSendingProcessed';
 
    // List of short language codes for status
    $this->labelStatusShort = array();
    $this->labelStatusShort[-1] = 'StatusSendingCanceledShort';
    $this->labelStatusShort[0]  = 'StatusSendingDraftShort';
    $this->labelStatusShort[1]  = 'StatusSendingValidatedShort';
    $this->labelStatusShort[2]  = 'StatusSendingProcessedShort';
  }
 
  public function getNextNumRef($soc)
  {
    global $langs, $conf;
    $langs->load("sendings");
 
    if (getDolGlobalString('EXPEDITION_ADDON_NUMBER')) {
      $mybool = false;
 
      $file = getDolGlobalString('EXPEDITION_ADDON_NUMBER') . ".php";
      $classname = getDolGlobalString('EXPEDITION_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/expedition/");
 
        // 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 ModelNumRefExpedition $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_EXPEDITION_ADDON_NUMBER_NotDefined");
      return "";
    }
  }
 
  public function create($user, $notrigger = 0)
  {
    $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->date_creation)) {
      $this->date_creation = $now;
    }
    if (empty($this->date_shipping) && !empty($this->date_expedition)) {
      $this->date_shipping = $this->date_expedition;
    }
    $this->entity = setEntity($this);
 
    $this->user = $user;
 
    $this->db->begin();
 
    $sql = "INSERT INTO ".MAIN_DB_PREFIX."expedition (";
    $sql .= "ref";
    $sql .= ", entity";
    $sql .= ", ref_customer";
    $sql .= ", ref_ext";
    $sql .= ", date_creation";
    $sql .= ", fk_user_author";
    $sql .= ", date_expedition";
    $sql .= ", date_delivery";
    $sql .= ", fk_soc";
    $sql .= ", fk_projet";
    $sql .= ", fk_address";
    $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 .= ", signed_status";
    $sql .= ") VALUES (";
    $sql .= "'(PROV)'";
    $sql .= ", ".((int) $this->entity);
    $sql .= ", ".($this->ref_customer ? "'".$this->db->escape($this->ref_customer)."'" : "null");
    $sql .= ", ".($this->ref_ext ? "'".$this->db->escape($this->ref_ext)."'" : "null");
    $sql .= ", '".$this->db->idate($this->date_creation)."'";
    $sql .= ", ".((int) $user->id);
    $sql .= ", ".($this->date_shipping > 0 ? "'".$this->db->idate($this->date_shipping)."'" : "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_delivery_address > 0 ? $this->fk_delivery_address : "null");
    $sql .= ", ".($this->shipping_method_id > 0 ? ((int) $this->shipping_method_id) : "null");
    $sql .= ", '".$this->db->escape($this->tracking_number)."'";
    $sql .= ", ".(is_numeric($this->weight) ? $this->weight : 'NULL');
    $sql .= ", ".(is_numeric($this->sizeS) ? $this->sizeS : 'NULL'); // TODO Should use this->trueDepth
    $sql .= ", ".(is_numeric($this->sizeW) ? $this->sizeW : 'NULL'); // TODO Should use this->trueWidth
    $sql .= ", ".(is_numeric($this->sizeH) ? $this->sizeH : 'NULL'); // TODO Should use this->trueHeight
    $sql .= ", ".($this->weight_units != '' ? (int) $this->weight_units : 'NULL');
    $sql .= ", ".($this->size_units != '' ? (int) $this->size_units : 'NULL');
    $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 .= ", ".($this->signed_status);
    $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."expedition");
 
      $sql = "UPDATE ".MAIN_DB_PREFIX."expedition";
      $sql .= " SET ref = '(PROV".$this->id.")'";
      $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);
        $kits_list = array();
        if (getDolGlobalInt('PRODUIT_SOUSPRODUITS')) {
          for ($i = 0; $i < $num; $i++) {
            $objectsrc = new OrderLine($this->db);
            $objectsrc->fetch($this->lines[$i]->origin_line_id);
            if ($this->lines[$i]->product_type == "9" && $objectsrc->special_code == SUBTOTALS_SPECIAL_CODE) {
              if ($this->create_line($this->lines[$i]->entrepot_id, $this->lines[$i]->origin_line_id, $this->lines[$i]->qty, $this->lines[$i]->rang, $this->lines[$i]->array_options) <= 0) {
                $error++;
              }
              continue;
            }
            if (empty($this->lines[$i]->product_type) || getDolGlobalString('STOCK_SUPPORTS_SERVICES') || getDolGlobalString('SHIPMENT_SUPPORTS_SERVICES')) {
              // virtual products
              $line = $this->lines[$i];
              if ($line->fk_product > 0) {
                // We group kit lines by the fulfilled order line (fk_elementdet) and not by product id: when a same kit product
                // is present on several distinct order lines, each order line must keep its own shipment line so the ordered
                // qty stays consistent with the shipped qty (grouping by product would sum the shipped qty of all lines while
                // keeping the ordered qty of a single line, resulting in a wrong/negative remaining qty to ship). Several
                // warehouse pickings of the same order line still share the same fk_elementdet and are grouped together.
                if (!isset($kits_list[$line->fk_elementdet])) {
                  if (!is_object($line->product)) {
                    $line_product = new Product($this->db);
                    $result = $line_product->fetch($line->fk_product, '', '', '', 1, 1, 1);
                    if ($result <= 0) {
                      $error++;
                    }
                  } else {
                    $line_product = $line->product;
                  }
 
                  // get all children of virtual product
                  $line_product->get_sousproduits_arbo();
                  $prods_arbo = $line_product->get_arbo_each_prod($line->qty);
                  if (count($prods_arbo) > 0) {
                    $kits_list[$line->fk_elementdet] = array(
                      'arbo' => $prods_arbo,
                      'total_qty' => $line->qty,
                    );
                  }
                } else {
                  $kits_list[$line->fk_elementdet]['total_qty'] += $line->qty;
                }
              }
            }
          }
        }
        $kits_id_cached = array();
        $sub_kits_id_cached = array();
        $sub_parents_cached = array();
        for ($i = 0; $i < $num; $i++) {
          $line = $this->lines[$i];
          if (empty($line->product_type) || getDolGlobalString('STOCK_SUPPORTS_SERVICES') || getDolGlobalString('SHIPMENT_SUPPORTS_SERVICES')) {
            $line_id = 0;
            if (!isset($kits_id_cached[$line->fk_elementdet])) {
              if (!isset($line->detail_batch) || (isset($kits_list[$line->fk_elementdet]) && !getDolGlobalInt('PRODUIT_SOUSPRODUITS_ALSO_ENABLE_PARENT_STOCK_MOVE'))) {    // no batch management or is kit
                $qty = isset($kits_list[$line->fk_elementdet]) ? $kits_list[$line->fk_elementdet]['total_qty'] : $line->qty;
                $warehouse_id = (isset($kits_list[$line->fk_elementdet]) && !getDolGlobalInt('PRODUIT_SOUSPRODUITS_ALSO_ENABLE_PARENT_STOCK_MOVE')) ? 0 : $line->entrepot_id;
                $line_id = $this->create_line($warehouse_id, $line->origin_line_id, $qty, $line->rang, $line->array_options, 0, $line->fk_product);
                if ($line_id <= 0) {
                  $error++;
                }
                if (isset($kits_list[$line->fk_elementdet])) $kits_id_cached[$line->fk_elementdet] = $line_id;
              } else {    // with batch management
                if ($this->create_line_batch($line, $line->array_options) <= 0) {
                  $error++;
                }
              }
            } else {
              $line_id = $kits_id_cached[$line->fk_elementdet];
            }
 
            // virtual products
            if (isset($kits_list[$line->fk_elementdet]) && !getDolGlobalInt('PRODUIT_SOUSPRODUITS_ALSO_ENABLE_PARENT_STOCK_MOVE')) {
              $prods_arbo = $kits_list[$line->fk_elementdet]['arbo'];
 
              // get all children of virtual product
              $parent_line_id = $line_id; // parent line created
              $level_last = 1;
              $product_child_id = 0;
              foreach ($prods_arbo as $index => $product_child_arr) {
                // 'id' => Id product
                // 'id_parent' => Id parent product
                // 'ref' => Ref product
                // 'nb' => Nb of units that compose parent product
                // 'nb_total' => // Nb of units for all nb of product
                // 'stock' => Stock
                // 'stock_alert' => Stock alert
                // 'label' => Label
                // 'fullpath' => // Full path label
                // 'type' =>
                // 'desiredstock' => Desired stock
                // 'level' => Level
                // 'incdec' => Need to be incremented or decremented
                // 'entity' => Entity
                $product_child_level = (int) $product_child_arr['level'];
                $product_child_incdec = !empty($product_child_arr['incdec']);
 
                // detect new level
                if ($product_child_level != $level_last) {
                  $parent_line_id = $line_id; // last line id
                  $parent_product_id = $product_child_id; // last line id
                  if (isset($sub_parents_cached[$line->fk_elementdet][$parent_product_id])) {
                    $parent_line_id = $sub_parents_cached[$line->fk_elementdet][$parent_product_id];
                  } else {
                    $sub_parents_cached[$line->fk_elementdet][$parent_product_id] = $parent_line_id;
                  }
                }
 
                // determine if it's a kit : check next level
                $is_kit = false;
                $next_level = $product_child_level;
                $next_index = $index + 1;
                if (isset($prods_arbo[$next_index])) {
                  $next_level = (int) $prods_arbo[$next_index]['level'];
                }
                if ($next_level > $product_child_level) {
                  $is_kit = true;
                }
 
                // determine quantity of sub-product
                $product_child_id = (int) $product_child_arr['id'];
                $product_child_qty = (float) $product_child_arr['nb_total']; // by default
                $warehouse_id = $line->entrepot_id; // by default
                if ($is_kit || !$product_child_incdec) {
                  if (!$product_child_incdec) {
                    $product_child_qty = 0;
                  }
                  $warehouse_id = 0; // no warehouse used for a kit or if stock is not managed (empty incdec)
                }
 
                // create line for a child of virtual product
                if (!isset($sub_kits_id_cached[$line->fk_elementdet][$product_child_id]) || $warehouse_id > 0) {
                  $line_id = $this->create_line($warehouse_id, ($parent_line_id ? 0 : $line->origin_line_id), $product_child_qty, $line->rang, $line->array_options, $parent_line_id, $product_child_id);
                  if ($line_id <= 0) {
                    $error++;
                    dol_syslog(__METHOD__ . ' : ' . $this->errorsToString(), LOG_ERR);
                    break;
                  }
 
                  // if kit or not manage stock (empty incdec)
                  if (empty($warehouse_id)) {
                    $sub_kits_id_cached[$line->fk_elementdet][$product_child_id] = $line_id;
                  }
                }
 
                $level_last = $product_child_level;
              }
            }
          }
        }
 
        if (!$error && $this->id && $this->origin_id) {
          $ret = $this->add_object_linked();
          if (!$ret) {
            $error++;
          }
        }
 
        if (!$error && $this->id && getDolGlobalInt('SHIPPING_USE_ITS_OWN_CONTACTS') && getDolGlobalString('MAIN_PROPAGATE_CONTACTS_FROM_ORIGIN') && !empty($this->origin_type) && !empty($this->origin_id)) {   // Get contact from origin object
          $originforcontact = $this->origin_type;
          $originidforcontact = $this->origin_id;
 
          $sqlcontact = "SELECT ctc.code, ctc.source, ec.fk_socpeople FROM ".MAIN_DB_PREFIX."element_contact as ec, ".MAIN_DB_PREFIX."c_type_contact as ctc";
          $sqlcontact .= " WHERE element_id = ".((int) $originidforcontact)." AND ec.fk_c_type_contact = ctc.rowid AND ctc.element = '".$this->db->escape($originforcontact)."'";
 
          $resqlcontact = $this->db->query($sqlcontact);
          if ($resqlcontact) {
            while ($objcontact = $this->db->fetch_object($resqlcontact)) {
              $this->add_contact($objcontact->fk_socpeople, $objcontact->code, $objcontact->source); // May failed because of duplicate key or because code of contact type does not exists for new object
            }
          } else {
            dol_print_error($this->db);
          }
        }
 
        // Actions on extra fields
        if (!$error) {
          $result = $this->insertExtraFields();
          if ($result < 0) {
            $error++;
          }
        }
 
        if (!$error && !$notrigger) {
          // Call trigger
          $result = $this->call_trigger('SHIPPING_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->db->rollback();
          return -3;
        }
      } 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;
 
    $expeditionline = new ExpeditionLigne($this->db);
    $expeditionline->fk_expedition = $this->id;
    $expeditionline->entrepot_id = $entrepot_id;
    $expeditionline->fk_elementdet = $origin_line_id;
    $expeditionline->element_type = $this->origin;
    $expeditionline->fk_parent = $parent_line_id;
    $expeditionline->fk_product = $product_id;
    $expeditionline->qty = $qty;
    $expeditionline->rang = $rang;
    $expeditionline->array_options = $array_options;
 
    if (!($expeditionline->fk_product > 0)) {
      $order_line = new OrderLine($this->db);
      $order_line->fetch($expeditionline->fk_elementdet);
      $expeditionline->fk_product = $order_line->fk_product;
    }
 
    if (($lineId = $expeditionline->insert($user)) < 0) {
      $this->errors[] = $expeditionline->error;
    }
    return $lineId;
  }
 
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function create_line_batch($line_ext, $array_options = [])
  {
    // phpcs:enable
    $error = 0;
    $stockLocationQty = array(); // associated array with batch qty in stock location
 
    $tab = $line_ext->detail_batch;
    // create stockLocation Qty array
    foreach ($tab as $detbatch) {
      if (!empty($detbatch->fk_warehouse)) {
        if (empty($stockLocationQty[$detbatch->fk_warehouse])) {
          $stockLocationQty[$detbatch->fk_warehouse] = 0;
        }
        $stockLocationQty[$detbatch->fk_warehouse] += $detbatch->qty;
      }
    }
    // create shipment lines
    foreach ($stockLocationQty as $stockLocation => $qty) {
      $line_id = $this->create_line($stockLocation, $line_ext->origin_line_id, $qty, $line_ext->rang, $array_options);
      if ($line_id < 0) {
        $error++;
      } else {
        // create shipment batch lines for stockLocation
        foreach ($tab as $detbatch) {
          if ($detbatch->fk_warehouse == $stockLocation) {
            if (!($detbatch->create($line_id) > 0)) {   // Create an ExpeditionLineBatch
              $this->errors = $detbatch->errors;
              $error++;
            }
          }
        }
      }
    }
 
    if (!$error) {
      return 1;
    } else {
      return -1;
    }
  }
 
  public function fetch($id, $ref = '', $ref_ext = '', $notused = '')
  {
    global $conf;
 
    // 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_customer, e.ref_ext, e.fk_user_author, e.fk_statut, e.signed_status, e.fk_projet as fk_project, e.billed";
    $sql .= ", e.date_valid";
    $sql .= ", e.weight, e.weight_units, e.size, e.size_units, e.width, e.height";
    $sql .= ", e.date_expedition as date_expedition, e.model_pdf, e.fk_address, e.date_delivery";
    $sql .= ", e.fk_shipping_method, e.tracking_number";
    $sql .= ", e.note_private, e.note_public";
    $sql .= ', e.fk_incoterms, e.location_incoterms';
    $sql .= ', e.signed_status';
    $sql .= ', i.libelle as label_incoterms';
    $sql .= ', s.libelle as shipping_method';
    $sql .= ", el.fk_source as origin_id, el.sourcetype as origin_type";
    $sql .= " FROM ".MAIN_DB_PREFIX."expedition 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)."'";
    $sql .= ' LEFT JOIN '.MAIN_DB_PREFIX.'c_incoterms as i ON e.fk_incoterms = i.rowid';
    $sql .= ' LEFT JOIN '.MAIN_DB_PREFIX.'c_shipment_mode as s ON e.fk_shipping_method = s.rowid';
    $sql .= " WHERE e.entity IN (".getEntity('expedition').")";
    if ($id) {
      $sql .= " AND e.rowid = ".((int) $id);
    }
    if ($ref) {
      $sql .= " AND e.ref='".$this->db->escape($ref)."'";
    }
    if ($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_customer = $obj->ref_customer;
        $this->ref_ext        = $obj->ref_ext;
        $this->status               = $obj->fk_statut;
        $this->statut               = $this->status; // Deprecated
        $this->signed_status    = $obj->signed_status;
        $this->user_author_id       = $obj->fk_user_author;
        $this->fk_user_author       = $obj->fk_user_author;
        $this->date_creation        = $this->db->jdate($obj->date_creation);
        $this->date_valid = $this->db->jdate($obj->date_valid);
        $this->date                 = $this->db->jdate($obj->date_expedition); // TODO deprecated
        $this->date_expedition      = $this->db->jdate($obj->date_expedition); // TODO deprecated
        $this->date_shipping        = $this->db->jdate($obj->date_expedition); // Date real
        $this->date_delivery        = $this->db->jdate($obj->date_delivery); // Date planned
        $this->fk_delivery_address  = $obj->fk_address;
        $this->model_pdf            = $obj->model_pdf;
        $this->shipping_method_id   = $obj->fk_shipping_method;
        $this->shipping_method = $obj->shipping_method;
        $this->tracking_number      = $obj->tracking_number;
        $this->origin               = ($obj->origin_type ? $obj->origin_type : 'commande'); // For compatibility
        $this->origin_type          = ($obj->origin_type ? $obj->origin_type : 'commande');
        $this->origin_id            = $obj->origin_id;
        $this->billed               = $obj->billed;
        $this->fk_project = $obj->fk_project;
        $this->signed_status        = $obj->signed_status;
        $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);
 
        // Tracking url
        $this->getUrlTrackingStatus($obj->tracking_number);
 
        // Thirdparty
        $result = $this->fetch_thirdparty(); // TODO Remove this
 
        // Retrieve extrafields
        $this->fetch_optionals();
 
        // Fix Get multicurrency param for transmitted
        if (isModEnabled('multicurrency')) {
          if (!empty($this->multicurrency_code)) {
            $this->multicurrency_code = $this->thirdparty->multicurrency_code;
          }
          if (getDolGlobalString('MULTICURRENCY_USE_ORIGIN_TX') && !empty($this->thirdparty->multicurrency_tx)) {
            $this->multicurrency_tx = $this->thirdparty->multicurrency_tx;
          }
        }
 
        /*
         * Lines
         */
        $result = $this->fetch_lines();
        if ($result < 0) {
          return -3;
        }
 
        return 1;
      } else {
        dol_syslog(get_class($this).'::Fetch no expedition found', LOG_ERR);
        $this->error = 'Shipment with id '.$id.' not found';
        return 0;
      }
    } else {
      $this->error = $this->db->error();
      return -1;
    }
  }
 
  public function valid($user, $notrigger = 0)
  {
    global $conf;
 
    require_once DOL_DOCUMENT_ROOT.'/core/lib/files.lib.php';
 
    dol_syslog(get_class($this)."::valid");
 
    // Protection
    if ($this->status) {
      dol_syslog(get_class($this)."::valid not in draft status", LOG_WARNING);
      return 0;
    }
 
    if (!((!getDolGlobalString('MAIN_USE_ADVANCED_PERMS') && $user->hasRight('expedition', 'creer'))
    || (getDolGlobalString('MAIN_USE_ADVANCED_PERMS') && $user->hasRight('expedition', 'shipping_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);
 
    // Class of company linked to order
    $result = $soc->setAsCustomer();
 
    // 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);
    } elseif (!empty($this->ref)) {
      $numref = $this->ref;
    } else {
      $numref = "EXP".$this->id;
    }
    $this->newref = dol_sanitizeFileName($numref);
 
    $now = dol_now();
 
    // Validate
    $sql = "UPDATE ".MAIN_DB_PREFIX."expedition 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 expedition", LOG_DEBUG);
    $resql = $this->db->query($sql);
    if (!$resql) {
      $this->error = $this->db->lasterror();
      $error++;
    }
 
    // If stock increment is done on sending (recommended choice)
    if (!$error && isModEnabled('stock') && getDolGlobalString('STOCK_CALCULATE_ON_SHIPMENT')) {
      $result = $this->manageStockMvtOnEvt($user, "ShipmentValidatedInDolibarr");
      if ($result < 0) {
        return -2;
      }
    }
 
    // Change status of order to "shipment in process"
    $triggerKey = 'SHIPPING_'; // Because when the trigger is fired the object is a shipping and not the real target object, so I add a prefix like SHIPPING_ to avoid confusion
    if ($this->origin == 'commande') {
      $triggerKey.= 'ORDER_SHIPMENTONPROCESS';
    } else {
      $triggerKey.= strtoupper($this->origin).'_SHIPMENTONPROCESS';
    }
 
    // TODO : load the origin object to trigger the right setStatus according to origin object
    $ret = $this->setStatut(Commande::STATUS_SHIPMENTONPROCESS, $this->origin_id, $this->origin, $triggerKey);
    if (!$ret) {
      $error++;
    }
 
    if (!$error && !$notrigger) {
      // Call trigger
      $result = $this->call_trigger('SHIPPING_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 = 'expedition/sending/".$this->db->escape($this->newref)."'";
        $sql .= " WHERE filename LIKE '".$this->db->escape($this->ref)."%' AND filepath = 'expedition/sending/".$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 = 'expedition/sending/".$this->db->escape($this->newref)."'";
        $sql .= " WHERE filepath = 'expedition/sending/".$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->expedition->dir_output.'/sending/'.$oldref;
        $dirdest = $conf->expedition->dir_output.'/sending/'.$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->expedition->dir_output.'/sending/'.$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 {
      $this->db->rollback();
      return -1 * $error;
    }
  }
 
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function create_delivery($user)
  {
    // phpcs:enable
    global $conf;
 
    if (getDolGlobalInt('MAIN_SUBMODULE_DELIVERY')) {
      if ($this->status == self::STATUS_VALIDATED || $this->status == self::STATUS_CLOSED) {
        // Expedition validee
        include_once DOL_DOCUMENT_ROOT.'/delivery/class/delivery.class.php';
        $delivery = new Delivery($this->db);
        $result = $delivery->create_from_sending($user, $this->id);
        if ($result > 0) {
          return $result;
        } else {
          $this->error = $delivery->error;
          return $result;
        }
      } else {
        return 0;
      }
    } else {
      return 0;
    }
  }
 
  public function addline($entrepot_id, $id, $qty, $array_options = [], $fk_product = 0, $fk_parent = 0)
  {
    global $conf, $langs;
 
    $num = count($this->lines);
    $line = new ExpeditionLigne($this->db);
 
    $line->entrepot_id = $entrepot_id;
    $line->origin_line_id = $id;
    $line->fk_elementdet = $id;
    $line->element_type = 'order';
    $line->fk_parent = $fk_parent;
    $line->fk_product = $fk_product;
    $line->qty = $qty;
 
    $orderline = new OrderLine($this->db);
    $orderline->fetch($id);
 
    // Copy the rang of the order line to the expedition line
    $line->rang = $orderline->rang;
    $line->product_type = $orderline->product_type;
    if (!($line->fk_product > 0)) {
      $line->fk_product = $orderline->fk_product;
    }
 
    if (isModEnabled('stock') && !empty($orderline->fk_product)) {
      $product = new Product($this->db);
      $product->fetch($orderline->fk_product);
 
      if (!($entrepot_id > 0) && !getDolGlobalString('STOCK_WAREHOUSE_NOT_REQUIRED_FOR_SHIPMENTS') && !(getDolGlobalString('SHIPMENT_SUPPORTS_SERVICES') && $line->product_type == Product::TYPE_SERVICE) && $product->stockable_product == Product::ENABLED_STOCK && !empty($line->qty)) {
        $langs->load("errors");
        $this->error = $langs->trans("ErrorWarehouseRequiredIntoShipmentLine");
        return -1;
      }
 
      if (getDolGlobalString('STOCK_MUST_BE_ENOUGH_FOR_SHIPMENT') && ($qty > 0 || !getDolGlobalString('SHIPMENT_GETS_ALL_ORDER_PRODUCTS'))) {
        $productChildrenNb = 0;
        if (getDolGlobalInt('PRODUIT_SOUSPRODUITS')) {
          $productChildrenNb = $product->hasFatherOrChild(1);
        }
        if ($productChildrenNb > 0) {
          $product_stock = null;
          $product->loadStockForVirtualProduct('warehouseopen', $line->qty);
          if ($entrepot_id > 0) {
            if (isset($product->stock_warehouse[$entrepot_id])) {
              $product_stock = $product->stock_warehouse[$entrepot_id]->real;
            }
          } else {
            foreach ($product->stock_warehouse as $componentStockWarehouse) {
              if ($product_stock === null) {
                $product_stock = $componentStockWarehouse->real;
              } else {
                $product_stock = min($product_stock, $componentStockWarehouse->real);
              }
            }
          }
          if ($product_stock === null) {
            $product_stock = 0;
          }
        } else {
          // Check must be done for stock of product into warehouse if $entrepot_id defined
          if ($entrepot_id > 0) {
            $product->load_stock('warehouseopen');
            $product_stock = $product->stock_warehouse[$entrepot_id]->real;
          } else {
            $product_stock = $product->stock_reel;
          }
        }
 
        $product_type = $product->type;
        if ($product_type == 0 || getDolGlobalString('STOCK_SUPPORTS_SERVICES')) {
          $isavirtualproduct = ($productChildrenNb > 0);
          // The product is qualified for a check of quantity (must be enough in stock to be added into shipment).
          if (!$isavirtualproduct || !getDolGlobalString('PRODUIT_SOUSPRODUITS') || ($isavirtualproduct && !getDolGlobalString('STOCK_EXCLUDE_VIRTUAL_PRODUCTS'))) {  // If STOCK_EXCLUDE_VIRTUAL_PRODUCTS is set, we do not manage stock for kits/virtual products.
            if ($product->stockable_product == Product::ENABLED_STOCK && $product_stock < $qty) {
              $langs->load("errors");
              $this->error = $langs->trans('ErrorStockIsNotEnoughToAddProductOnShipment', $product->ref);
              $this->errorhidden = 'ErrorStockIsNotEnoughToAddProductOnShipment';
 
              $this->db->rollback();
              return -3;
            }
          }
        }
      }
    }
 
    // If product need a batch number, we should not have called this function but addline_batch instead.
    // If this happen, we may have a bug in card.php page
    if (isModEnabled('productbatch') && !empty($line->fk_product) && !empty($orderline->product_tobatch)) {
      $this->error = 'ADDLINE_WAS_CALLED_INSTEAD_OF_ADDLINEBATCH '.$orderline->id.' '.$line->fk_product;  //
      return -4;
    }
 
    // extrafields
    if (!getDolGlobalString('MAIN_EXTRAFIELDS_DISABLED') && is_array($array_options) && count($array_options) > 0) { // For avoid conflicts if trigger used
      $line->array_options = $array_options;
    }
 
    $this->lines[$num] = $line;
 
    return 1;
  }
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function addline_batch($dbatch, $array_options = [], $origin_line = null)
  {
    // phpcs:enable
    global $conf, $langs;
 
    $num = count($this->lines);
    $linebatch = null;
    if ($dbatch['qty'] > 0 || ($dbatch['qty'] == 0 && getDolGlobalString('SHIPMENT_GETS_ALL_ORDER_PRODUCTS'))) {
      $line = new ExpeditionLigne($this->db);
      $tab = array();
      foreach ($dbatch['detail'] as $key => $value) {
        if ($value['q'] > 0 || ($value['q'] == 0 && getDolGlobalString('SHIPMENT_GETS_ALL_ORDER_PRODUCTS'))) {
          // $value['q']=qty to move
          // $value['id_batch']=id into llx_product_batch of record to move
          //var_dump($value);
 
          $linebatch = new ExpeditionLineBatch($this->db);
          $ret = $linebatch->fetchFromStock($value['id_batch']); // load serial, sellby, eatby
          if ($ret < 0) {
            $this->setErrorsFromObject($linebatch);
            return -1;
          }
          $linebatch->qty = $value['q'];
          if ($linebatch->qty == 0 && getDolGlobalString('SHIPMENT_GETS_ALL_ORDER_PRODUCTS')) {
            $linebatch->batch = null;
          }
          $tab[] = $linebatch;
 
          if (getDolGlobalString("STOCK_MUST_BE_ENOUGH_FOR_SHIPMENT", '0') && ($linebatch->qty > 0 || !getDolGlobalString('SHIPMENT_GETS_ALL_ORDER_PRODUCTS'))) {
            require_once DOL_DOCUMENT_ROOT.'/product/class/productbatch.class.php';
            $prod_batch = new Productbatch($this->db);
            $prod_batch->fetch($value['id_batch']);
 
            if ($prod_batch->qty < $linebatch->qty) {
              $langs->load("errors");
              $this->errors[] = $langs->trans('ErrorStockIsNotEnoughToAddProductOnShipment', $prod_batch->fk_product);
              dol_syslog(get_class($this)."::addline_batch error=Product ".$prod_batch->batch.": ".$this->errorsToString(), LOG_ERR);
              $this->db->rollback();
              return -1;
            }
          }
 
          //var_dump($linebatch);
        }
      }
      if (is_object($linebatch)) {
        $line->entrepot_id = $linebatch->fk_warehouse;
      }
      $line->origin_line_id = $dbatch['ix_l']; // deprecated
      $line->fk_elementdet = $dbatch['ix_l'];
      $line->qty = $dbatch['qty'];
      $line->detail_batch = $tab;
      if (!($line->rang > 0)) {
        $line->rang = $origin_line->rang;
      }
      if (!($line->fk_product > 0)) {
        $line->fk_product = $origin_line->fk_product;
      }
 
      // extrafields
      if (!getDolGlobalString('MAIN_EXTRAFIELDS_DISABLED') && is_array($array_options) && count($array_options) > 0) { // For avoid conflicts if trigger used
        $line->array_options = $array_options;
      }
 
      //var_dump($line);
      $this->lines[$num] = $line;
      return 1;
    }
    return 0;
  }
 
  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_customer)) {
      $this->ref_customer = trim($this->ref_customer);
    }
    if (isset($this->socid)) {
      $this->socid = (int) $this->socid;
    }
    if (isset($this->fk_user_author)) {
      $this->fk_user_author = (int) $this->fk_user_author;
    }
    if (isset($this->fk_user_valid)) { // @phan-ignore-current-line PhanUndeclaredProperty
      // If set, then accept @phan-ignore-next-line PhanUndeclaredProperty
      $this->fk_user_valid = (int) $this->fk_user_valid;
    }
    if (isset($this->fk_delivery_address)) {
      $this->fk_delivery_address = (int) $this->fk_delivery_address;
    }
    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->status)) {
      $this->status = (int) $this->status;
    }
    if (isset($this->trueDepth)) {
      $this->trueDepth = trim($this->trueDepth);
    }
    if (isset($this->trueWidth)) {
      $this->trueWidth = trim($this->trueWidth);
    }
    if (isset($this->trueHeight)) {
      $this->trueHeight = trim($this->trueHeight);
    }
    if (isset($this->size_units)) {
      $this->size_units = trim($this->size_units);
    }
    if (isset($this->weight_units)) {
      $this->weight_units = (int) $this->weight_units;
    }
    if (isset($this->trueWeight)) {
      $this->weight = trim((string) $this->trueWeight);
    }
    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);
    }
    if (!empty($this->date_expedition)) {
      $this->date_shipping = $this->date_expedition;
    }
 
    // Check parameters
    // Put here code to add control on parameters values
 
    // Update request
    $sql = "UPDATE ".MAIN_DB_PREFIX."expedition SET";
    $sql .= " ref = ".(isset($this->ref) ? "'".$this->db->escape($this->ref)."'" : "null").",";
    $sql .= " ref_ext = ".(isset($this->ref_ext) ? "'".$this->db->escape($this->ref_ext)."'" : "null").",";
    $sql .= " ref_customer = ".(isset($this->ref_customer) ? "'".$this->db->escape($this->ref_customer)."'" : "null").",";
    $sql .= " fk_soc = ".(isset($this->socid) ? $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) ? $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) ? $this->fk_user_valid : "null").",";
    $sql .= " date_expedition = ".(dol_strlen($this->date_shipping) != 0 ? "'".$this->db->idate($this->date_shipping)."'" : 'null').",";
    $sql .= " date_delivery = ".(dol_strlen($this->date_delivery) != 0 ? "'".$this->db->idate($this->date_delivery)."'" : 'null').",";
    $sql .= " fk_address = ".(isset($this->fk_delivery_address) ? $this->fk_delivery_address : "null").",";
    $sql .= " fk_shipping_method = ".((isset($this->shipping_method_id) && $this->shipping_method_id > 0) ? $this->shipping_method_id : "null").",";
    $sql .= " tracking_number = ".(isset($this->tracking_number) ? "'".$this->db->escape($this->tracking_number)."'" : "null").",";
    $sql .= " fk_statut = ".(isset($this->status) ? $this->status : "null").",";
    $sql .= " fk_projet = ".(isset($this->fk_project) ? $this->fk_project : "null").",";
    $sql .= " height = ".(($this->trueHeight != '') ? $this->trueHeight : "null").",";
    $sql .= " width = ".(($this->trueWidth != '') ? $this->trueWidth : "null").",";
    $sql .= " size_units = ".(isset($this->size_units) ? $this->size_units : "null").",";
    $sql .= " size = ".(($this->trueDepth != '') ? $this->trueDepth : "null").",";
    $sql .= " weight_units = ".(isset($this->weight_units) ? $this->weight_units : "null").",";
    $sql .= " weight = ".(($this->trueWeight != '') ? $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 .= " 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();
    }
 
    // Actions on extra fields
    if (!$error) {
      $result = $this->insertExtraFields();
      if ($result < 0) {
        $error++;
      }
    }
 
    if (!$error && !$notrigger) {
      // Call trigger
      $result = $this->call_trigger('SHIPPING_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 cancel($notrigger = 0, $also_update_stock = false)
  {
    global $conf, $langs, $user;
 
    require_once DOL_DOCUMENT_ROOT.'/core/lib/files.lib.php';
 
    $error = 0;
    $this->error = '';
 
    $this->db->begin();
 
    // Add a protection to refuse deleting if shipment has at least one delivery
    $this->fetchObjectLinked($this->id, 'shipping', 0, 'delivery'); // Get deliveries linked to this shipment
    if (isset($this->linkedObjectsIds['delivery']) && count($this->linkedObjectsIds['delivery']) > 0) {
      $this->error = 'ErrorThereIsSomeDeliveries';
      $error++;
    }
 
    if (!$error && !$notrigger) {
      // Call trigger
      $result = $this->call_trigger('SHIPPING_CANCEL', $user);
      if ($result < 0) {
        $error++;
      }
      // End call triggers
    }
 
    // Stock control
    $can_update_stock = isModEnabled('stock') &&
      ((getDolGlobalString('STOCK_CALCULATE_ON_SHIPMENT') && $this->status > self::STATUS_DRAFT) ||
        (getDolGlobalString('STOCK_CALCULATE_ON_SHIPMENT_CLOSE') && $this->status == self::STATUS_CLOSED && $also_update_stock));
    if (!$error) {
      require_once DOL_DOCUMENT_ROOT."/product/stock/class/mouvementstock.class.php";
 
      $langs->load("agenda");
 
      // Loop on each product line to add a stock movement (contain sub-products)
      $sql = "SELECT ";
      $sql .= " ed.fk_product";
      $sql .= ", ed.qty, ed.fk_entrepot, ed.rowid as expeditiondet_id";
      $sql .= ", SUM(".$this->db->ifsql("pa.rowid IS NOT NULL", "1", "0").") as iskit";
      $sql .= ", ".$this->db->ifsql("pai.incdec IS NULL", "1", "pai.incdec")." as incdec";
      $sql .= " FROM ".$this->db->prefix()."expeditiondet as ed";
      $sql .= " LEFT JOIN ".$this->db->prefix()."product_association as pa ON pa.fk_product_pere = ed.fk_product";
      $sql .= " LEFT JOIN ".$this->db->prefix()."expeditiondet as edp ON edp.rowid = ed.fk_parent";
      $sql .= " LEFT JOIN ".$this->db->prefix()."product_association as pai ON pai.fk_product_pere = edp.fk_product AND pai.fk_product_fils = ed.fk_product";
      $sql .= " WHERE ed.fk_expedition = ".((int) $this->id);
      $sql .= " GROUP BY ed.fk_product, ed.qty, ed.fk_entrepot, ed.rowid, pai.incdec";
      $sql .= $this->db->order("ed.rowid", "DESC");
 
      dol_syslog(get_class($this)."::delete select details", LOG_DEBUG);
      $resql = $this->db->query($sql);
      if ($resql) {
        $cpt = $this->db->num_rows($resql);
 
        $shipmentlinebatch = new ExpeditionLineBatch($this->db);
 
        for ($i = 0; $i < $cpt; $i++) {
          dol_syslog(get_class($this)."::delete movement index ".$i);
          $obj = $this->db->fetch_object($resql);
          $line_id = (int) $obj->expeditiondet_id;
 
          if ($can_update_stock && (empty($obj->iskit) || getDolGlobalInt('PRODUIT_SOUSPRODUITS_ALSO_ENABLE_PARENT_STOCK_MOVE')) && !empty($obj->incdec)) {
            $mouvS = new MouvementStock($this->db);
            // we do not log origin because it will be deleted
            $mouvS->origin = '';
            // get lot/serial
            $lotArray = null;
            if (isModEnabled('productbatch')) {
              $lotArray = $shipmentlinebatch->fetchAll($obj->expeditiondet_id);
              if (!is_array($lotArray)) {
                $error++;
                $this->errors[] = "Error ".$this->db->lasterror();
              }
            }
 
            if (empty($lotArray)) {
              // no lot/serial
              // We increment stock of product (and sub-products)
              // We use warehouse selected for each line
              $result = $mouvS->reception($user, $obj->fk_product, $obj->fk_entrepot, $obj->qty, 0, $langs->trans("ShipmentCanceledInDolibarr", $this->ref), '', '', '', '', 0, '', 0, (empty($obj->iskit) ? 1 : 0)); // Price is set to 0, because we don't want to see WAP changed
              if ($result < 0) {
                $error++;
                $this->errors = array_merge($this->errors, $mouvS->errors);
                break;
              }
            } else {
              // We increment stock of batches
              // We use warehouse selected for each line
              foreach ($lotArray as $lot) {
                $result = $mouvS->reception($user, $obj->fk_product, $obj->fk_entrepot, $lot->qty, 0, $langs->trans("ShipmentCanceledInDolibarr", $this->ref), $lot->eatby, $lot->sellby, (string) $lot->batch, '', 0, '', 0, (empty($obj->iskit) ? 1 : 0)); // Price is set to 0, because we don't want to see WAP changed
                if ($result < 0) {
                  $error++;
                  $this->errors = array_merge($this->errors, $mouvS->errors);
                  break;
                }
              }
              if ($error) {
                break; // break for loop in case of error
              }
            }
          }
 
          if (!$error) {
            // delete all children and batches of this shipment line
            $shipment_line = new ExpeditionLigne($this->db);
            $res = $shipment_line->fetch($line_id);
            if ($res > 0) {
              $result = $shipment_line->delete($user);
              if ($result < 0) {
                $error++;
                $this->errors[] = "Error ".$shipment_line->errorsToString();
              }
            } else {
              $error++;
              $this->errors[] = "Error ".$shipment_line->errorsToString();
            }
          }
 
          if ($error) {
            break;
          }
        }
      } else {
        $error++;
        $this->errors[] = "Error ".$this->db->lasterror();
      }
    }
 
    if (!$error) {
      // Delete linked object
      $res = $this->deleteObjectLinked();
      if ($res < 0) {
        $error++;
      }
 
      // No delete expedition
      if (!$error) {
        $sql = "SELECT rowid FROM ".$this->db->prefix()."expedition";
        $sql .= " WHERE rowid = ".((int) $this->id);
 
        if ($this->db->query($sql)) {
          if (!empty($this->origin) && $this->origin_id > 0) {
            $this->fetch_origin();
            $origin_object = $this->origin_object;
            '@phan-var-force Facture|Commande $origin_object';
            if ($origin_object->status == Commande::STATUS_SHIPMENTONPROCESS) {     // If order source of shipment is "shipment in progress"
              // Check if there is no more shipment. If not, we can move back status of order to "validated" instead of "shipment in progress"
              $origin_object->loadExpeditions();
              //var_dump($this->$origin->expeditions);exit;
              if (count($origin_object->expeditions) <= 0) {
                $origin_object->setStatut(Commande::STATUS_VALIDATED);
              }
            }
          }
 
          if (!$error) {
            $this->db->commit();
 
            // We delete PDFs
            $ref = dol_sanitizeFileName($this->ref);
            if (!empty($conf->expedition->dir_output)) {
              $dir = $conf->expedition->dir_output.'/sending/'.$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->db->rollback();
        return -2;
      }
    } else {
      $this->db->rollback();
      return -1;
    }
  }
 
  public function delete($user = null, $notrigger = 0, $also_update_stock = false)
  {
    global $conf, $langs;
 
    if (empty($user)) {
      global $user;
    }
 
    require_once DOL_DOCUMENT_ROOT.'/core/lib/files.lib.php';
 
    $error = 0;
    $this->error = '';
 
    $this->db->begin();
 
    // Add a protection to refuse deleting if shipment has at least one delivery
    $this->fetchObjectLinked($this->id, 'shipping', 0, 'delivery'); // Get deliveries linked to this shipment
    if (isset($this->linkedObjectsIds['delivery']) && count($this->linkedObjectsIds['delivery']) > 0) {
      $this->error = 'ErrorThereIsSomeDeliveries';
      $error++;
    }
 
    if (!$error && !$notrigger) {
      // Call trigger
      $result = $this->call_trigger('SHIPPING_DELETE', $user);
      if ($result < 0) {
        $error++;
      }
      // End call triggers
    }
 
    // Stock control
    $can_update_stock = isModEnabled('stock') &&
      ((getDolGlobalString('STOCK_CALCULATE_ON_SHIPMENT') && $this->status > self::STATUS_DRAFT) ||
        (getDolGlobalString('STOCK_CALCULATE_ON_SHIPMENT_CLOSE') && $this->status == self::STATUS_CLOSED && $also_update_stock));
    if (!$error) {
      require_once DOL_DOCUMENT_ROOT."/product/stock/class/mouvementstock.class.php";
 
      $langs->load("agenda");
 
      // we try deletion of batch line even if module batch not enabled in case of the module were enabled and disabled previously
      $shipmentlinebatch = new ExpeditionLineBatch($this->db);
 
      // Loop on each product line to add a stock movement (contain sub-products)
      $sql = "SELECT ";
      $sql .= " ed.fk_product";
      $sql .= ", ed.qty, ed.fk_entrepot, ed.rowid as expeditiondet_id";
      $sql .= ", SUM(".$this->db->ifsql("pa.rowid IS NOT NULL", "1", "0").") as iskit";
      $sql .= ", ".$this->db->ifsql("pai.incdec IS NULL", "1", "pai.incdec")." as incdec";
      $sql .= " FROM ".$this->db->prefix()."expeditiondet as ed";
      $sql .= " LEFT JOIN ".$this->db->prefix()."product_association as pa ON pa.fk_product_pere = ed.fk_product";
      $sql .= " LEFT JOIN ".$this->db->prefix()."expeditiondet as edp ON edp.rowid = ed.fk_parent";
      $sql .= " LEFT JOIN ".$this->db->prefix()."product_association as pai ON pai.fk_product_pere = edp.fk_product AND pai.fk_product_fils = ed.fk_product";
      $sql .= " WHERE ed.fk_expedition = ".((int) $this->id);
      $sql .= " GROUP BY ed.fk_product, ed.qty, ed.fk_entrepot, ed.rowid, pai.incdec";
      $sql .= $this->db->order("ed.rowid", "DESC");
 
      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);
          $line_id = (int) $obj->expeditiondet_id;
 
          if ($can_update_stock && (empty($obj->iskit) || getDolGlobalInt('PRODUIT_SOUSPRODUITS_ALSO_ENABLE_PARENT_STOCK_MOVE')) && !empty($obj->incdec)) {
            $mouvS = new MouvementStock($this->db);
            // we do not log origin because it will be deleted
            $mouvS->origin = '';
            // get lot/serial
            $lotArray = $shipmentlinebatch->fetchAll($line_id);
            if (!is_array($lotArray)) {
              $error++;
              $this->errors[] = "Error ".$this->db->lasterror();
            }
            if (empty($lotArray)) {
              // no lot/serial
              // We increment stock of product (disable for sub-products : already in shipment lines)
              // We use warehouse selected for each line
              $result = $mouvS->reception($user, $obj->fk_product, $obj->fk_entrepot, $obj->qty, 0, $langs->trans("ShipmentDeletedInDolibarr", $this->ref), '', '', '', '', 0, '', 0, (empty($obj->iskit) ? 1 : 0)); // Price is set to 0, because we don't want to see WAP changed
              if ($result < 0) {
                $error++;
                $this->errors = array_merge($this->errors, $mouvS->errors);
                break;
              }
            } else {
              // We increment stock of batches
              // We use warehouse selected for each line
              foreach ($lotArray as $lot) {
                if (empty($lot->qty)) {
                  continue;
                }
                $result = $mouvS->reception($user, $obj->fk_product, $obj->fk_entrepot, $lot->qty, 0, $langs->trans("ShipmentDeletedInDolibarr", $this->ref), $lot->eatby, $lot->sellby, (string) $lot->batch, '', 0, '', 0, (empty($obj->iskit) ? 1 : 0)); // Price is set to 0, because we don't want to see WAP changed
                if ($result < 0) {
                  $error++;
                  $this->errors = array_merge($this->errors, $mouvS->errors);
                  break;
                }
              }
              if ($error) {
                break; // break for loop in case of error
              }
            }
          }
 
          if (!$error) {
            // delete all children and batches of this shipment line
            $shipment_line = new ExpeditionLigne($this->db);
            $res = $shipment_line->fetch($line_id);
            if ($res > 0) {
              $result = $shipment_line->delete($user);
              if ($result < 0) {
                $error++;
                $this->errors[] = "Error ".$shipment_line->errorsToString();
              }
            } else {
              $error++;
              $this->errors[] = "Error ".$shipment_line->errorsToString();
            }
          }
 
          if ($error) {
            break;
          }
        }
      } else {
        $error++;
        $this->errors[] = "Error ".$this->db->lasterror();
      }
    }
 
    if (!$error) {
      // Delete linked object
      $res = $this->deleteObjectLinked();
      if ($res < 0) {
        $error++;
      }
 
      // delete extrafields
      $res = $this->deleteExtraFields();
      if ($res < 0) {
        $error++;
      }
 
      if (!$error) {
        // Delete linked contacts
        $res = $this->delete_linked_contact();
        if ($res < 0) {
          $error++;
        }
      }
      if (!$error) {
        $sql = "DELETE FROM ".$this->db->prefix()."expedition";
        $sql .= " WHERE rowid = ".((int) $this->id);
 
        if ($this->db->query($sql)) {
          if (!empty($this->origin) && $this->origin_id > 0) {
            $this->fetch_origin();
            $origin_object = $this->origin_object;
            '@phan-var-force Facture|Commande $origin_object';
            if ($origin_object->status == Commande::STATUS_SHIPMENTONPROCESS) {     // If order source of shipment is "shipment in progress"
              // Check if there is no more shipment. If not, we can move back status of order to "validated" instead of "shipment in progress"
              $origin_object->loadExpeditions();
              //var_dump($this->$origin->expeditions);exit;
              if (count($origin_object->expeditions) <= 0) {
                $origin_object->setStatut(Commande::STATUS_VALIDATED);
              }
            }
          }
 
          if (!$error) {
            $this->db->commit();
 
            // Delete record into ECM index (Note that delete is also done when deleting files with the dol_delete_dir_recursive
            $this->deleteEcmFiles(0);  // Deleting files physically is done later with the dol_delete_dir_recursive
            $this->deleteEcmFiles(1);  // Deleting files physically is done later with the dol_delete_dir_recursive
 
            // We delete PDFs
            $ref = dol_sanitizeFileName($this->ref);
            if (!empty($conf->expedition->dir_output)) {
              $dir = $conf->expedition->dir_output . '/sending/' . $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->db->rollback();
        return -2;
      }
    } else {
      $this->db->rollback();
      return -1;
    }
  }
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function fetch_lines()
  {
    // phpcs:enable
    global $mysoc;
 
    $this->lines = array();
 
    // NOTE: This fetch_lines is special because it groups all lines with the same origin_line_id into one line.
    // TODO: See if we can restore a common fetch_lines (one line = one record)
 
    $sql = "SELECT cd.rowid, cd.fk_product, cd.label as custom_label, cd.description, cd.qty as qty_asked, cd.product_type, cd.fk_unit";
    $sql .= ", cd.total_ht, cd.total_localtax1, cd.total_localtax2, cd.total_ttc, cd.total_tva";
    $sql .= ", cd.fk_remise_except, cd.fk_product_fournisseur_price as fk_fournprice";
    $sql .= ", cd.vat_src_code, cd.tva_tx, cd.localtax1_tx, cd.localtax2_tx, cd.localtax1_type, cd.localtax2_type, cd.info_bits, cd.price, cd.subprice, cd.remise_percent,cd.buy_price_ht as pa_ht";
    $sql .= ", cd.fk_multicurrency, cd.multicurrency_code, cd.multicurrency_subprice, cd.multicurrency_total_ht, cd.multicurrency_total_tva, cd.multicurrency_total_ttc, cd.rang, cd.date_start, cd.date_end, cd.special_code";
    $sql .= ", ed.rowid as line_id, ed.qty as qty_shipped, ed.fk_element, ed.fk_elementdet, ed.element_type, ed.fk_entrepot, ed.extraparams";
    $sql .= ", p.ref as product_ref, p.label as product_label, p.fk_product_type, p.barcode as product_barcode";
    $sql .= ", p.weight, p.weight_units, p.length, p.length_units, p.width, p.width_units, p.height, p.height_units";
    $sql .= ", p.surface, p.surface_units, p.volume, p.volume_units, p.tosell as product_tosell, p.tobuy as product_tobuy";
    $sql .= ", p.tobatch as product_tobatch, p.stockable_product";
    $sql .= " FROM ".MAIN_DB_PREFIX."expeditiondet as ed, ".MAIN_DB_PREFIX."commandedet as cd";
    $sql .= " LEFT JOIN ".MAIN_DB_PREFIX."product as p ON p.rowid = cd.fk_product";
    $sql .= " WHERE ed.fk_expedition = ".((int) $this->id);
    $sql .= " AND ed.fk_elementdet = cd.rowid";
    $sql .= " ORDER BY cd.rang, ed.fk_elementdet";    // We need after a break on fk_elementdet but when there is no break on fk_elementdet, cd.rang is same so we can add it as first order criteria.
 
    dol_syslog(get_class($this)."::fetch_lines", LOG_DEBUG);
    $resql = $this->db->query($sql);
    if ($resql) {
      include_once DOL_DOCUMENT_ROOT.'/core/lib/price.lib.php';
 
      $num = $this->db->num_rows($resql);
      $i = 0;
      $line = new ExpeditionLigne($this->db);
      $lineindex = 0;
      $originline = 0;
 
      $this->total_ht = 0;
      $this->total_tva = 0;
      $this->total_ttc = 0;
      $this->total_localtax1 = 0;
      $this->total_localtax2 = 0;
 
      $this->multicurrency_total_ht = 0;
      $this->multicurrency_total_tva = 0;
      $this->multicurrency_total_ttc = 0;
 
      $shipmentlinebatch = new ExpeditionLineBatch($this->db);
 
      $line = new ExpeditionLigne($this->db); // always set $line for PHAN analyser. @phan-var-force muse be used after an assignation, and there is no assignation for $line.
      while ($i < $num) {
        $obj = $this->db->fetch_object($resql);
 
        if ($originline > 0 && $originline == $obj->fk_elementdet) {
          // '@phan-var-force ExpeditionLigne $line'; // $line from previous loop
          $line->entrepot_id = 0; // entrepod_id in details_entrepot
          $line->qty_shipped += $obj->qty_shipped;
        } else {
          $line = new ExpeditionLigne($this->db);   // new group to start
          $line->entrepot_id = $obj->fk_entrepot; // this is a property of a shipment line
          $line->qty_shipped = $obj->qty_shipped; // this is a property of a shipment line
        }
 
        $detail_entrepot              = new stdClass();
        $detail_entrepot->entrepot_id = $obj->fk_entrepot;
        $detail_entrepot->qty_shipped = $obj->qty_shipped;
        $detail_entrepot->line_id     = $obj->line_id;
        $line->details_entrepot[]     = $detail_entrepot;
 
        $line->line_id          = $obj->line_id; // TODO deprecated
        $line->rowid            = $obj->line_id; // TODO deprecated
        $line->id               = $obj->line_id;
 
        $line->fk_origin = 'orderline'; // TODO deprecated, we already have element_type that can be use to guess type of line
 
        $line->fk_element     = $obj->fk_element;
        $line->origin_id    = $obj->fk_element;
        $line->fk_elementdet  = $obj->fk_elementdet;
        $line->origin_line_id   = $obj->fk_elementdet;
        $line->element_type   = $obj->element_type;
 
        $line->fk_expedition    = $this->id; // id of parent
 
        $line->stockable_product = $obj->stockable_product;
        $line->product_type     = $obj->product_type;
        $line->fk_product       = $obj->fk_product;
        $line->fk_product_type  = $obj->fk_product_type;
        $line->ref = $obj->product_ref; // TODO deprecated
        $line->product_ref = $obj->product_ref;
        $line->product_label = $obj->product_label;
        $line->libelle          = $obj->product_label; // TODO deprecated
        $line->product_barcode = $obj->product_barcode; // Barcode number product
        $line->product_tosell = $obj->product_tosell;
        $line->product_tobuy = $obj->product_tobuy;
        $line->product_tobatch = $obj->product_tobatch;
        $line->fk_fournprice = $obj->fk_fournprice;
        $line->label = $obj->custom_label;
        $line->description      = $obj->description;
        $line->qty_asked        = $obj->qty_asked;
        $line->rang = $obj->rang;
        $line->weight           = $obj->weight;
        $line->weight_units     = $obj->weight_units;
        $line->length           = $obj->length;
        $line->length_units     = $obj->length_units;
        $line->width           = $obj->width;
        $line->width_units     = $obj->width_units;
        $line->height           = $obj->height;
        $line->height_units     = $obj->height_units;
        $line->surface          = $obj->surface;
        $line->surface_units = $obj->surface_units;
        $line->volume           = $obj->volume;
        $line->volume_units         = $obj->volume_units;
        $line->stockable_product    = $obj->stockable_product;
        $line->fk_unit              = $obj->fk_unit;
 
        $line->extraparams = !empty($obj->extraparams) ? (array) json_decode($obj->extraparams, true) : array();
 
        $line->pa_ht = $obj->pa_ht;
 
        // Local taxes
        $localtax_array = array(0 => $obj->localtax1_type, 1 => $obj->localtax1_tx, 2 => $obj->localtax2_type, 3 => $obj->localtax2_tx);
        $localtax1_tx = get_localtax($obj->tva_tx, 1, $this->thirdparty);
        $localtax2_tx = get_localtax($obj->tva_tx, 2, $this->thirdparty);
 
        // For invoicing
        $tabprice = calcul_price_total($obj->qty_shipped, $obj->subprice, $obj->remise_percent, $obj->tva_tx, $localtax1_tx, $localtax2_tx, 0, 'HT', $obj->info_bits, $obj->fk_product_type, $mysoc, $localtax_array); // We force type to 0
        $line->desc = $obj->description; // We need ->desc because some code into CommonObject use desc (property defined for other elements)
        $line->qty = $line->qty_shipped;
        $line->total_ht = (float) $tabprice[0];
        $line->total_localtax1  = (float) $tabprice[9];
        $line->total_localtax2  = (float) $tabprice[10];
        $line->total_ttc    = (float) $tabprice[2];
        $line->total_tva    = (float) $tabprice[1];
        $line->vat_src_code = $obj->vat_src_code;
        $line->tva_tx = $obj->tva_tx;
        $line->localtax1_tx   = $obj->localtax1_tx;
        $line->localtax2_tx   = $obj->localtax2_tx;
        $line->info_bits = $obj->info_bits;
        $line->price = $obj->price;
        $line->subprice = $obj->subprice;
        $line->fk_remise_except = $obj->fk_remise_except;
        $line->remise_percent = $obj->remise_percent;
 
        $this->total_ht += $tabprice[0];
        $this->total_tva += $tabprice[1];
        $this->total_ttc += $tabprice[2];
        $this->total_localtax1 += $tabprice[9];
        $this->total_localtax2 += $tabprice[10];
 
        $line->date_start       = $this->db->jdate($obj->date_start);
        $line->date_end         = $this->db->jdate($obj->date_end);
 
        $line->special_code     = $obj->special_code;
 
        // Multicurrency
        $this->fk_multicurrency = $obj->fk_multicurrency;
        $this->multicurrency_code = $obj->multicurrency_code;
        $line->multicurrency_subprice   = $obj->multicurrency_subprice;
        $line->multicurrency_total_ht   = $obj->multicurrency_total_ht;
        $line->multicurrency_total_tva  = $obj->multicurrency_total_tva;
        $line->multicurrency_total_ttc  = $obj->multicurrency_total_ttc;
 
        $this->multicurrency_total_ht   += $obj->multicurrency_total_ht;
        $this->multicurrency_total_tva  += $obj->multicurrency_total_tva;
        $this->multicurrency_total_ttc  += $obj->multicurrency_total_ttc;
 
        if ($originline != $obj->fk_elementdet) {
          $line->detail_batch = array();
        }
 
        // Detail of batch
        if (isModEnabled('productbatch') && $obj->line_id > 0 && $obj->product_tobatch > 0) {
          $newdetailbatch = $shipmentlinebatch->fetchAll($obj->line_id, $obj->fk_product);
 
          if (is_array($newdetailbatch)) {
            if ($originline != $obj->fk_elementdet) {
              $line->detail_batch = $newdetailbatch;
            } else {
              $line->detail_batch = array_merge($line->detail_batch, $newdetailbatch);
            }
          }
        }
 
        // virtual product : find all children stock (group by product id and warehouse id)
        if (getDolGlobalInt('PRODUIT_SOUSPRODUITS')) {
          $detail_children = array(); // detail by product : array of [warehouse_id => total_qty]
          $line_child_list = array();
          $res = $line->findAllChild($line->id, $line_child_list, 1);
          if ($res > 0) {
            foreach ($line_child_list as $child_line) {
              foreach ($child_line as $child_obj) {
                $child_product_id = (int) $child_obj->fk_product;
                $child_warehouse_id = (int) $child_obj->fk_warehouse;
 
                if ($child_warehouse_id > 0) {
                  // child quantities group by warehouses
                  if (!isset($detail_children[$child_product_id])) {
                    $detail_children[$child_product_id] = array();
                  }
                  if (!isset($detail_children[$child_product_id][$child_warehouse_id])) {
                    $detail_children[$child_product_id][$child_warehouse_id] = 0;
                  }
                  $detail_children[$child_product_id][$child_warehouse_id] += $child_obj->qty;
                }
              }
            }
          }
          $line->detail_children = $detail_children;
        }
 
        $line->fetch_optionals();
 
        if ($originline != $obj->fk_elementdet) {
          $this->lines[$lineindex] = $line;
          $lineindex++;
        } else {
          $line->total_ht += $tabprice[0];
          $line->total_localtax1  += $tabprice[9];
          $line->total_localtax2  += $tabprice[10];
          $line->total_ttc    += $tabprice[2];
          $line->total_tva    += $tabprice[1];
        }
 
        $i++;
        $originline = $obj->fk_elementdet;
      }
      $this->db->free($resql);
      return 1;
    } else {
      $this->error = $this->db->error();
      return -3;
    }
  }
 
  public function deleteLine($user, $lineid)
  {
    global $user;
 
    if ($this->status == self::STATUS_DRAFT) {
      $this->db->begin();
 
      $line = new ExpeditionLigne($this->db);
 
      // For triggers
      $line->fetch($lineid);
 
      if ($line->delete($user) > 0) {
        //$this->update_price(1);
 
        $this->db->commit();
        return 1;
      } else {
        $this->db->rollback();
        return -1;
      }
    } else {
      $this->error = 'ErrorDeleteLineNotAllowedByObjectStatus';
      return -2;
    }
  }
 
 
  public function getTooltipContentArray($params)
  {
    global $conf, $langs;
 
    $langs->load('sendings');
 
    $nofetch = !empty($params['nofetch']);
 
    $datas = array();
    $datas['picto'] = img_picto('', $this->picto).' <u class="paddingrightonly">'.$langs->trans("Shipment").'</u>';
    if (isset($this->status)) {
      $datas['picto'] .= ' '.$this->getLibStatut(5);
    }
    $datas['ref'] = '<br><b>'.$langs->trans('Ref').':</b> '.$this->ref;
    $datas['refcustomer'] = '<br><b>'.$langs->trans('RefCustomer').':</b> '.($this->ref_customer ? $this->ref_customer : $this->ref_client);
    if (!$nofetch) {
      $langs->load('companies');
      if (empty($this->thirdparty)) {
        $this->fetch_thirdparty();
      }
      $datas['customer'] = '<br><b>'.$langs->trans('Customer').':</b> '.$this->thirdparty->getNomUrl(1, '', 0, 1);
    }
 
    return $datas;
  }
 
  public function getNomUrl($withpicto = 0, $option = '', $max = 0, $short = 0, $notooltip = 0, $save_lastsearch_value = -1)
  {
    global $langs, $hookmanager;
 
    $result = '';
    $params = [
      'id' => $this->id,
      'objecttype' => $this->element,
      'option' => $option,
      'nofetch' => 1,
    ];
    $classfortooltip = 'classfortooltip';
    $dataparams = '';
    if (getDolGlobalInt('MAIN_ENABLE_AJAX_TOOLTIP')) {
      $classfortooltip = 'classforajaxtooltip';
      $dataparams = ' data-params="'.dol_escape_htmltag(json_encode($params)).'"';
      $label = '';
    } else {
      $label = implode($this->getTooltipContentArray($params));
    }
 
    $url = DOL_URL_ROOT.'/expedition/card.php?id='.$this->id;
 
    if ($short) {
      return $url;
    }
 
    if ($option !== 'nolink') {
      // Add param to save lastsearch_values or not
      $add_save_lastsearch_values = ($save_lastsearch_value == 1 ? 1 : 0);
      if ($save_lastsearch_value == -1 && isset($_SERVER["PHP_SELF"]) && preg_match('/list\.php/', $_SERVER["PHP_SELF"])) {
        $add_save_lastsearch_values = 1;
      }
      if ($add_save_lastsearch_values) {
        $url .= '&save_lastsearch_values=1';
      }
    }
 
    $linkclose = '';
    if (empty($notooltip)) {
      if (getDolGlobalString('MAIN_OPTIMIZEFORTEXTBROWSER')) {
        $label = $langs->trans("Shipment");
        $linkclose .= ' alt="'.dolPrintHTMLForAttribute($label).'"';
      }
      $linkclose .= ($label ? ' title="'.dolPrintHTMLForAttribute($label).'"' : ' title="tocomplete"');
      $linkclose .= $dataparams.' class="'.$classfortooltip.'"';
    }
 
    $linkstart = '<a href="'.$url.'"';
    $linkstart .= $linkclose.'>';
    $linkend = '</a>';
 
    $result .= $linkstart;
    if ($withpicto) {
      $result .= img_object(($notooltip ? '' : $label), ($this->picto ? $this->picto : 'generic'), ($notooltip ? (($withpicto != 2) ? 'class="paddingright"' : '') : 'class="'.(($withpicto != 2) ? 'paddingright ' : '').'"'), 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->status, $mode);
  }
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function LibStatut($status, $mode)
  {
    // phpcs:enable
    global $langs;
 
    $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';
    }
    if ($status == self::STATUS_CANCELED) {
      $statusType = 'status9';
    }
 
    $signed_label = ' (' . $this->getLibSignedStatus() . ')';
    $status_label = $this->signed_status ? $labelStatus . $signed_label : $labelStatus;
    $status_label_short = $this->signed_status ? $labelStatusShort . $signed_label : $labelStatusShort;
 
    return dolGetStatus($status_label, $status_label_short, '', $statusType, $mode);
  }
 
  public function getKanbanView($option = '', $arraydata = null)
  {
    global $langs, $conf;
 
    $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, $conf->currency).' '.$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;
 
    $now = dol_now();
 
    dol_syslog(get_class($this)."::initAsSpecimen");
 
    $order = new Commande($this->db);
    $order->initAsSpecimen();
 
    // Initialise parameters
    $this->id = 0;
    $this->ref = 'SPECIMEN';
    $this->specimen = 1;
    $this->status = self::STATUS_VALIDATED;
    $this->livraison_id         = 0;
    $this->date                 = $now;
    $this->date_creation        = $now;
    $this->date_valid           = $now;
    $this->date_delivery        = $now + 24 * 3600;
    $this->date_expedition      = $now + 24 * 3600;
 
    $this->entrepot_id          = 0;
    $this->fk_delivery_address  = 0;
    $this->socid                = 1;
 
    $this->commande_id          = 0;
    $this->commande             = $order;
 
    $this->origin_id = 1;
    $this->origin_type = 'commande';
 
    $this->note_private = 'Private note';
    $this->note_public = 'Public note';
 
    $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 ExpeditionLigne($this->db);
      $line->product_desc = $langs->trans("Description")." ".$xnbp;
      $line->product_label = $langs->trans("Description")." ".$xnbp;
      $line->qty = 10;
      $line->qty_asked = 5;
      $line->qty_shipped = 4;
      $line->fk_product = $this->commande->lines[$xnbp]->fk_product;
 
      $line->weight = 1.123456;
      $line->weight_units = 0;    // kg
 
      $line->volume = 2.34567;
      $line->volume_unit = 0;
 
      $this->lines[] = $line;
      $xnbp++;
    }
 
    return 1;
  }
 
  // phpcs:disable PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps
  public function set_date_livraison($user, $delivery_date)
  {
    // phpcs:enable
    return $this->setDeliveryDate($user, $delivery_date);
  }
 
  public function setDeliveryDate($user, $delivery_date)
  {
    if ($user->hasRight('expedition', 'creer')) {
      $sql = "UPDATE ".MAIN_DB_PREFIX."expedition";
      $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 setShippingDate($user, $shipping_date)
  {
    if ($user->hasRight('expedition', 'creer')) {
      $sql = "UPDATE ".MAIN_DB_PREFIX."expedition";
      $sql .= " SET date_expedition = ".($shipping_date ? "'".$this->db->idate($shipping_date)."'" : 'null');
      $sql .= " WHERE rowid = ".((int) $this->id);
 
      dol_syslog(get_class($this)."::setShippingDate", LOG_DEBUG);
      $resql = $this->db->query($sql);
      if ($resql) {
        $this->date_shipping = $shipping_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 as label";
    $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('SendingMethod'.$obj->code);
        $this->meths[$obj->rowid] = ($label != 'SendingMethod'.$obj->code ? $label : $obj->label);
      }
    }
  }
 
  // 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 as label, 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('SendingMethod'.$obj->code);
        $this->listmeths[$i]['libelle'] = ($label != 'SendingMethod'.$obj->code ? $label : $obj->label);
        $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 $user;
 
    $error = 0;
 
    // Protection. This avoid to move stock later when we should not
    if ($this->status == self::STATUS_CLOSED) {
      return 0;
    }
 
    $this->db->begin();
 
    $sql = "UPDATE ".MAIN_DB_PREFIX."expedition SET fk_statut = ".self::STATUS_CLOSED;
    if (empty($this->date_shipping)) {  // Date of real shipment was not yet set, we force it on closing
      $sql .= ", date_expedition = '".$this->db->escape($this->db->idate(dol_now()))."'";
    }
    $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 shipped (qty in shipment lines match qty in order lines)
      if ($this->origin == 'commande' && $this->origin_id > 0) {
        $order = new Commande($this->db);
        $order->fetch($this->origin_id);
 
        $order->loadExpeditions(self::STATUS_CLOSED); // Fill $order->expeditions = array(orderlineid => qty)
 
        $shipments_match_order = 1;
        foreach ($order->lines as $line) {
          $lineid = $line->id;
          $qty = $line->qty;
          if (($line->product_type == 0 || getDolGlobalString('STOCK_SUPPORTS_SERVICES')) && $order->expeditions[$lineid] != $qty) {
            $shipments_match_order = 0;
            $text = 'Qty for order line id '.$lineid.' is '.$qty.'. However in the shipments with status Expedition::STATUS_CLOSED='.self::STATUS_CLOSED.' we have qty = '.$order->expeditions[$lineid].', so we can t close order';
            dol_syslog($text);
            break;
          }
        }
        if ($shipments_match_order) {
          dol_syslog("Qty for the ".count($order->lines)." lines of the origin order is same than qty for lines in the shipment we close (shipments_match_order is true), with new status Expedition::STATUS_CLOSED=".self::STATUS_CLOSED.', so we close order');
          // We close the order
          $order->cloture($user);   // Note this may also create an invoice if module workflow ask it
        }
      }
 
      $this->statut = self::STATUS_CLOSED;  // Will be revert to STATUS_VALIDATED at end if there is a rollback
      $this->status = self::STATUS_CLOSED;  // Will be revert to STATUS_VALIDATED at end if there is a rollback
 
      // If stock increment is done on closing
      if (!$error && isModEnabled('stock') && getDolGlobalString('STOCK_CALCULATE_ON_SHIPMENT_CLOSE')) {
        $result = $this->manageStockMvtOnEvt($user);
        if ($result < 0) {
          $error++;
        }
      }
 
      // Call trigger
      if (!$error) {
        $result = $this->call_trigger('SHIPPING_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;
    }
  }
 
  private function manageStockMvtOnEvt($user, $labelmovement = 'ShipmentClassifyClosedInDolibarr')
  {
    global $langs;
 
    $error = 0;
 
    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";
    $sql .= " ed.rowid as edid, ed.fk_product, ed.qty, ed.fk_entrepot";
    $sql .= ", cd.rowid as cdid";
    $sql .= ", cd.subprice";
    $sql .= ", edb.rowid as edbrowid, edb.eatby, edb.sellby, edb.batch, edb.qty as edbqty, edb.fk_origin_stock";
    $sql .= ", e.ref";
    $sql .= " FROM " . $this->db->prefix() . "expeditiondet as ed";
    $sql .= " LEFT JOIN " . $this->db->prefix() . "commandedet as cd ON cd.rowid = ed.fk_elementdet";
    $sql .= " LEFT JOIN " . $this->db->prefix() . "expeditiondet_batch as edb on edb.fk_expeditiondet = ed.rowid";
    $sql .= " INNER JOIN " . $this->db->prefix() . "expedition as e ON ed.fk_expedition = e.rowid";
    $sql .= " WHERE ed.fk_expedition = " . ((int) $this->id);
    //$sql .= " AND cd.rowid = ed.fk_elementdet";
 
    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);
        if (empty($obj->edbrowid)) {
          $qty = $obj->qty;
        } else {
          $qty = $obj->edbqty;
        }
        if ($qty <= 0 || ($qty < 0 && !getDolGlobalInt('SHIPMENT_ALLOW_NEGATIVE_QTY'))) {
          continue;
        }
        dol_syslog(get_class($this) . "::valid movement index " . $i . " ed.rowid=" . $obj->edid . " edb.rowid=" . $obj->edbrowid);
 
        $mouvS = new MouvementStock($this->db);
        $mouvS->origin = &$this;
        $mouvS->setOrigin($this->element, $this->id, $obj->cdid, $obj->edid);
 
        if (empty($obj->edbrowid)) {
          // 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
          $result = $mouvS->livraison($user, $obj->fk_product, $obj->fk_entrepot, $qty, $obj->subprice, $langs->trans($labelmovement, $obj->ref));
          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
          $result = $mouvS->livraison($user, $obj->fk_product, $obj->fk_entrepot, $qty, $obj->subprice, $langs->trans($labelmovement, $obj->ref), '', $this->db->jdate($obj->eatby), $this->db->jdate($obj->sellby), $obj->batch, $obj->fk_origin_stock);
          if ($result < 0) {
            $this->error = $mouvS->error;
            $this->errors = $mouvS->errors;
            $error++;
            break;
          }
        }
 
        // If some stock lines are now 0, we can remove entry into llx_product_stock, but only if there is no child lines into llx_product_batch (detail of batch, because we can imagine
        // having a lot1/qty=X and lot2/qty=-X, so 0 but we must not loose repartition of different lot.
        $sqldelete = "DELETE FROM ".$this->db->prefix()."product_stock WHERE reel = 0 AND rowid NOT IN (SELECT fk_product_stock FROM ".$this->db->prefix()."product_batch as pb)";
        $resqldelete = $this->db->query($sqldelete);
        // We do not test error, it can fails if there is child in batch details
      }
    } else {
      $this->error = $this->db->lasterror();
      $this->errors[] = $this->db->lasterror();
      $error++;
    }
 
    if (!$error) {
      return 1;
    } else {
      return -1;
    }
  }
 
  public function setBilled()
  {
    global $user;
    $error = 0;
 
    $this->db->begin();
 
    $sql = 'UPDATE '.MAIN_DB_PREFIX.'expedition 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('SHIPPING_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 setDraft($user, $notrigger = 0)
  {
    // Protection
    if ($this->status <= self::STATUS_DRAFT) {
      return 0;
    }
 
    return $this->setStatusCommon($user, self::STATUS_DRAFT, $notrigger, 'SHIPMENT_UNVALIDATE');
  }
 
  public function reOpen()
  {
    global $langs, $user;
 
    $error = 0;
 
    // Protection. This avoid to move stock later when we should not
    if ($this->status == self::STATUS_VALIDATED) {
      return 0;
    }
 
    $this->db->begin();
 
    $oldbilled = $this->billed;
 
    $sql = 'UPDATE '.MAIN_DB_PREFIX.'expedition SET fk_statut = 1';
    $sql .= " WHERE rowid = ".((int) $this->id).' AND fk_statut > 0';
 
    $resql = $this->db->query($sql);
    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') && getDolGlobalString('STOCK_CALCULATE_ON_SHIPMENT_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 possibilite d'expedier a partir d'une propale ou autre origine
        $sql = "SELECT cd.fk_product, cd.subprice,";
        $sql .= " ed.rowid, ed.qty, ed.fk_entrepot,";
        $sql .= " edb.rowid as edbrowid, edb.eatby, edb.sellby, edb.batch, edb.qty as edbqty, edb.fk_origin_stock";
        $sql .= " FROM ".MAIN_DB_PREFIX."commandedet as cd,";
        $sql .= " ".MAIN_DB_PREFIX."expeditiondet as ed";
        $sql .= " LEFT JOIN ".MAIN_DB_PREFIX."expeditiondet_batch as edb on edb.fk_expeditiondet = ed.rowid";
        $sql .= " WHERE ed.fk_expedition = ".((int) $this->id);
        $sql .= " AND cd.rowid = ed.fk_elementdet";
 
        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);
            if (empty($obj->edbrowid)) {
              $qty = $obj->qty;
            } else {
              $qty = $obj->edbqty;
            }
            if ($qty <= 0) {
              continue;
            }
            dol_syslog(get_class($this)."::reopen expedition movement index ".$i." ed.rowid=".$obj->rowid." edb.rowid=".$obj->edbrowid);
 
            //var_dump($this->lines[$i]);
            $mouvS = new MouvementStock($this->db);
            $mouvS->origin = &$this;
            $mouvS->setOrigin($this->element, $this->id);
 
            if (empty($obj->edbrowid)) {
              // 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
              $result = $mouvS->livraison($user, $obj->fk_product, $obj->fk_entrepot, -$qty, $obj->subprice, $langs->trans("ShipmentUnClassifyCloseddInDolibarr", $this->ref));
              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
              $result = $mouvS->livraison($user, $obj->fk_product, $obj->fk_entrepot, -$qty, $obj->subprice, $langs->trans("ShipmentUnClassifyCloseddInDolibarr", $this->ref), '', $this->db->jdate($obj->eatby), $this->db->jdate($obj->sellby), $obj->batch, $obj->fk_origin_stock);
              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('SHIPPING_REOPEN', $user);
        if ($result < 0) {
          $error++;
        }
      }
    } else {
      $error++;
      $this->errors[] = $this->db->lasterror();
    }
 
    if (!$error) {
      $this->db->commit();
      return 1;
    } else {
      $this->statut = self::STATUS_CLOSED;
      $this->status = self::STATUS_CLOSED;
      $this->billed = $oldbilled;
      $this->db->rollback();
      return -1;
    }
  }
 
  public function generateDocument($modele, $outputlangs, $hidedetails = 0, $hidedesc = 0, $hideref = 0, $moreparams = null)
  {
    $outputlangs->load("products");
 
    if (!dol_strlen($modele)) {
      $modele = 'rouget';
 
      if (!empty($this->model_pdf)) {
        $modele = $this->model_pdf;
      } elseif (getDolGlobalString('EXPEDITION_ADDON_PDF')) {
        $modele = getDolGlobalString('EXPEDITION_ADDON_PDF');
      }
    }
 
    $modelpath = "core/modules/expedition/doc/";
 
    $this->fetch_origin();
 
    return $this->commonGenerateDocument($modelpath, $modele, $outputlangs, $hidedetails, $hidedesc, $hideref, $moreparams);
  }
 
  public static function replaceThirdparty(DoliDB $dbs, $origin_id, $dest_id)
  {
    $tables = array(
      'expedition'
    );
 
    return CommonObject::commonReplaceThirdparty($dbs, $origin_id, $dest_id, $tables);
  }
}