<?php
/* Copyright (C) 2001-2005 Rodolphe Quiedeville <rodolphe@quiedeville.org>
 * Copyright (C) 2004-2005 Laurent Destailleur  <eldy@users.sourceforge.net>
 *
 * 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 2 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, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
 *
 * $Id$
 * $Source$
 *
 */

/**
        \file       htdocs/product.class.php
        \ingroup    produit
        \brief      Fichier de la classe des produits prédéfinis
        \version    $Revision$
*/


/**
        \class      Product
        \brief      Classe permettant la gestion des produits prédéfinis
*/

class Product
{
  var $db ;

  var $id ;
  var $ref;
  var $libelle;
  var $description;
  var $price;
  var $tva_tx;
  var $type;
  var $seuil_stock_alerte;
  var $duration_value;
  var $duration_unit;


  /**
   *    \brief  Constructeur de la classe
   *    \param  DB          handler accès base de données
   *    \param  id          id produit (0 par defaut)
   */
	 
  function Product($DB, $id=0)
    {
      $this->db = $DB;
      $this->id   = $id ;
      $this->envente = 0;
    }  


  /**
   *    \brief  Vérifie que la référence et libellé du produit est non null
   *    \return int         1 si ok, 0 sinon
   */
	 
  function check()
    {
    $this->ref = ereg_replace("'","",stripslashes($this->ref));
    $this->ref = ereg_replace("\"","",stripslashes($this->ref));

      $err = 0;
      if (strlen(trim($this->ref)) == 0)
	$err++;
 
      if (strlen(trim($this->libelle)) == 0)
	$err++;
      
      if ($err > 0)
	{
	  return 0;
	}
      else
	{
	  return 1;
	}      
    }


  /**
   *    \brief  Insère le produit en base
   *    \param  user        utilisateur qui effectue l'insertion
   */
	 
  function create($user) 
    {
      $this->ref = ereg_replace("'","",stripslashes($this->ref));
      $this->ref = ereg_replace("\"","",stripslashes($this->ref));

      dolibarr_syslog("Product::Create Categorie : ".$this->catid);

      $sql = "SELECT count(*)";
      $sql .= " FROM ".MAIN_DB_PREFIX."product WHERE ref = '" .trim($this->ref)."'";
      $result = $this->db->query($sql) ;

      if ( $result )
	{
	  $row = $this->db->fetch_array();
	  if ($row[0] == 0)
	    {
	      if (strlen($this->tva_tx)==0) $this->tva_tx = 0;
	      if (strlen($this->price)==0) $this->price = 0;
	      if (strlen($this->envente)==0) $this->envente = 0;

	      $this->price = ereg_replace(",",".",$this->price);

	      $sql = "INSERT INTO ".MAIN_DB_PREFIX."product ";
	      $sql .= " (datec, fk_user_author, fk_product_type, price)";
	      $sql .= " VALUES (now(),".$user->id.",$this->type, '" . $this->price . "')";
	      $result = $this->db->query($sql);
	      if ( $result )
		{
		  $id = $this->db->last_insert_id(MAIN_DB_PREFIX."product");
		  
		  if ($id > 0)
		    {
		      $this->id = $id;
		      $this->_log_price($user);
		      if ( $this->update($id, $user) )
			{
			  if ($this->catid > 0)
			    {
			      $cat = new Categorie ($this->db, $this->catid);
			      $cat->add_product($this);
			    }
			  return $id;
			}
		    }
		  else
		    {
		      return -2;
		    }
		}
	      else
		{
		  dolibarr_print_error($this->db);
		  return -1;
		}
	    }
	  else
	    {
	      return -3;
	    }
	}
    }


  /**
   *    \brief      Mise à jour du produit en base
   *    \param      id          id du produit
   *    \param      user        utilisateur qui effectue l'insertion
   *    \return     int         1 si ok, -1 si ref deja existante, -2 autre erreur       
   */
	 
  function update($id, $user)
  {
    global $langs;
    $langs->load("main");
    $langs->load("products");
    
    if (! $this->libelle) $this->libelle = 'LIBELLE MANQUANT';
    $this->ref = ereg_replace("\"","",stripslashes($this->ref));
    $this->ref = ereg_replace("'","",stripslashes($this->ref));

    $this->ref = trim($this->ref);
    $this->libelle = trim($this->libelle);
    $this->description = trim($this->description);
    
    $sql = "UPDATE ".MAIN_DB_PREFIX."product ";
    $sql .= " SET label = '" . addslashes($this->libelle) ."'";
    if ($this->ref) $sql .= ",ref = '" . $this->ref ."'";
    $sql .= ",tva_tx = " . $this->tva_tx ;
    $sql .= ",envente = " . $this->envente ;
    $sql .= ",seuil_stock_alerte = " . $this->seuil_stock_alerte ;
    $sql .= ",description = '" . addslashes($this->description) ."'";
    $sql .= ",duration = '" . $this->duration_value . $this->duration_unit ."'";
    $sql .= " WHERE rowid = " . $id;
    
    if ( $this->db->query($sql) )
    {
        return 1;
    }
    else
    {
        if ($this->db->errno() == DB_ERROR_RECORD_ALREADY_EXISTS) {
            $this->mesg_error=$langs->trans("Error")." : ".$langs->trans("ErrorProductAlreadyExists",$this->ref);
            return -1;
        }
        else {
            $this->mesg_error=$langs->trans("Error")." : ".$this->db->error();
    	    return -2;
        }
    }
  }


  /**
   *    \brief  Ajoute un changement de prix en base dans l'historique des prix
   *    \param  user        utilisateur qui modifie le prix
   */
	 
    function _log_price($user) 
    {
        // On supprimme ligne existante au cas ou
        $sql = "DELETE FROM ".MAIN_DB_PREFIX."product_price ";
        $sql .= "WHERE date_price = now()";
        $sql .= " and fk_product = ".$this->id;
        $sql .= " and fk_user_author = ".$user->id;
        $sql .= " and price = ".ereg_replace(",",".",$this->price);
        $sql .= " and envente = ".$this->envente;
        $sql .= " and tva_tx = ".$this->tva_tx;

        $this->db->query($sql);
        
        // On ajoute nouveau tarif
        $sql = "INSERT INTO ".MAIN_DB_PREFIX."product_price(date_price,fk_product,fk_user_author,price,envente,tva_tx) ";
        $sql .= " VALUES(now(),".$this->id.",".$user->id.",".ereg_replace(",",".",$this->price).",".$this->envente.",".$this->tva_tx;
        $sql .= ")";
        if ($this->db->query($sql) )
        {
            return 1;	      
        }
        else
        {
            dolibarr_print_error($this->db);
            return 0;
        }
    }


  /**
   *    \brief  Lit le prix d'achat pour un fournisseur
   *    \param  id_fourn        Id du fournisseur
   *    \param  qty             Quantite pour lequel le prix est valide
   *    \return int             Renvoi prix
   */
  function get_buyprice($fourn_id, $qty) 
    {
        $result = 0;
        $sql = "SELECT pf.price";
        $sql.= " FROM ".MAIN_DB_PREFIX."product_fournisseur_price as pf ";
        $sql.= " WHERE pf.fk_soc = ".$fourn_id;
        $sql.= " AND pf.fk_product =" .$this->id;
        $sql.= " AND quantity <= ".$qty;
        $sql.= " ORDER BY quantity DESC";
        $sql.= " LIMIT 1";
        
        $resql = $this->db->query($sql);
        if ($resql)
        {
            $row = $this->db->fetch_row($resql);
            $this->buyprice = $row[0];
        }
        return $result;
    }


  /**
   *    \brief  Modifie le prix d'achat pour un fournisseur
   *    \param  id_fourn        Id du fournisseur
   *    \param  qty             Quantite pour lequel le prix est valide
   *    \param  buyprice        Prix d'achat pour la quantité
   *    \param  user            Objet user de l'utilisateur qui modifie
   */
  function update_buyprice($id_fourn, $qty, $buyprice, $user) 
    {
        $error=0;
        $this->db->begin();
        
        // Supprime prix courant du fournisseur pour cette quantité
        $sql = "DELETE FROM  ".MAIN_DB_PREFIX."product_fournisseur_price ";
        $sql .= " WHERE ";
        $sql .= " fk_product = ".$this->id;
        $sql .= " AND fk_soc = ".$id_fourn;
        $sql .= " AND quantity = ".$qty;
    
        if ($this->db->query($sql))
        {
            // Ajoute prix courant du fournisseur pour cette quantité
            $sql = "INSERT INTO ".MAIN_DB_PREFIX."product_fournisseur_price ";
            $sql .= " SET datec = now()";
            $sql .= " ,fk_product = ".$this->id;
            $sql .= " ,fk_soc = ".$id_fourn;
            $sql .= " ,fk_user = ".$user->id;
            $sql .= " ,price = ".ereg_replace(",",".",$buyprice);
            $sql .= " ,quantity = ".$qty;
    
            if (! $this->db->query($sql))
            {
                $error++;
            }
    
            if (! $error) {
                // Ajoute modif dans table log
                $sql = "INSERT INTO ".MAIN_DB_PREFIX."product_fournisseur_price_log ";
                $sql .= " SET datec = now()";
                $sql .= " ,fk_product = ".$this->id;
                $sql .= " ,fk_soc = ".$id_fourn;
                $sql .= " ,fk_user = ".$user->id;
                $sql .= " ,price = ".ereg_replace(",",".",$buyprice);
                $sql .= " ,quantity = ".$qty;

                if (! $this->db->query($sql))
                {
                    $error++;
                }
            }

            if (! $error)
            {
                $this->db->commit();
                return 0;
            }
            else
            {
                $this->error=$this->db->error()." ($sql)";
                $this->db->rollback();
                return -2;
            }
        }
        else
        {
            $this->error=$this->db->error()." ($sql)";
            $this->db->rollback();
            return -1;
        }
    }

  
  /**
   *    \brief  Modifie le prix d'un produit/service
   *    \param  id          id du produit/service à modifier
   *    \param  user        utilisateur qui modifie le prix
   */
	 
  function update_price($id, $user)
  {
    if (strlen(trim($this->price)) > 0 )
      {
	
	$sql = "UPDATE ".MAIN_DB_PREFIX."product ";
	$sql .= " SET price = " . ereg_replace(",",".",$this->price);	  
	$sql .= " WHERE rowid = " . $id;
	
	if ( $this->db->query($sql) )
	  {
	    $this->_log_price($user);
	    return 1;
	  }
	else
	  {
        dolibarr_print_error($this->db);
	    return -1;
	  }
      }
    else
      {
	$this->mesg_error = "Prix saisi invalide.";
	return -2;
      }
  }


  /**
   *    \brief  Charge le produit/service en mémoire
   *    \param  id          id du produit/service à charger
   */
	 
  function fetch ($id)
    {    
      $sql = "SELECT rowid, ref, label, description, price, tva_tx, envente, nbvente, fk_product_type, duration, seuil_stock_alerte";
      $sql .= " FROM ".MAIN_DB_PREFIX."product WHERE rowid = $id";

      $result = $this->db->query($sql) ;

      if ( $result )
	{
	  $result = $this->db->fetch_array();

	  $this->id                 = $result["rowid"];
	  $this->ref                = $result["ref"];
	  $this->libelle            = stripslashes($result["label"]);
	  $this->description        = stripslashes($result["description"]);
	  $this->price              = $result["price"];
	  $this->tva_tx             = $result["tva_tx"];
	  $this->type               = $result["fk_product_type"];
	  $this->nbvente            = $result["nbvente"];
	  $this->envente            = $result["envente"];
	  $this->duration           = $result["duration"];
	  $this->duration_value     = substr($result["duration"],0,strlen($result["duration"])-1);
	  $this->duration_unit      = substr($result["duration"],-1);
	  $this->seuil_stock_alerte = $result["seuil_stock_alerte"];

	  $this->label_url = '<a href="'.DOL_URL_ROOT.'/product/fiche.php?id='.$this->id.'">'.$this->libelle.'</a>';

	  if ($this->type == 0)
	    {
	      $this->isproduct = 1;
	      $this->isservice = 0;
	    }
	  else
	    {
	      $this->isproduct = 0;
	      $this->isservice = 1;
	    }

	  $this->db->free();

	  $sql = "SELECT reel, fk_entrepot";
	  $sql .= " FROM ".MAIN_DB_PREFIX."product_stock WHERE fk_product = $id";
	  $result = $this->db->query($sql) ;
	  if ( $result )
	    {
	      $num = $this->db->num_rows();
	      $i=0;
	      if ($num > 0)
		{
		  while ($i < $num )
		    {
		      $row = $this->db->fetch_row($i);
		      $this->stock_entrepot[$row[1]] = $row[0];

		      $this->stock_reel = $this->stock_reel + $row[0];
		      $i++;
		    }

		  $this->no_stock = 0;
		}
	      else
		{
		  $this->no_stock = 1;
		}
	      $this->db->free();
	    }
	  return 1;
	}
      else
	{
	  dolibarr_print_error($this->db);
	  return -1;
	}
  }


  /**
   *    \brief  Renvoie le nombre de propale incluant le produit/service
   *    \param  socid       id societe
   *    \return int         nombre d'inclusion
   */
	 
  function count_propale($socid=0)
    {
      $sql = "SELECT pd.fk_propal";
      $sql .= " FROM ".MAIN_DB_PREFIX."propaldet as pd, ".MAIN_DB_PREFIX."product as p, ".MAIN_DB_PREFIX."propal as pr";
      $sql .= " WHERE pr.rowid = pd.fk_propal AND p.rowid = pd.fk_product AND p.rowid = ".$this->id;
      if ($socid > 0)
	{
	  $sql .= " AND pr.fk_soc = $socid";
	}
      $sql .= " GROUP BY pd.fk_propal";

      $result = $this->db->query($sql) ;

      if ( $result )
	{
	  return $this->db->num_rows();
	}
      else
	{
	  return 0;
	}
    }


  /**
   *    \brief  Renvoie le nombre de client avec propale incluant le produit/service
   *    \param  socid       id societe
   *    \return int         nombre d'inclusion
   */
	 
  function count_propale_client($socid=0)
    {
      $sql = "SELECT pr.fk_soc";
      $sql .= " FROM ".MAIN_DB_PREFIX."propaldet as pd, ".MAIN_DB_PREFIX."product as p, ".MAIN_DB_PREFIX."propal as pr";
      $sql .= " WHERE p.rowid = pd.fk_product AND pd.fk_propal = pr.rowid AND p.rowid = ".$this->id;
      if ($socid > 0)
	{
	  $sql .= " AND pr.fk_soc = $socid";
	}
      $sql .= " GROUP BY pr.fk_soc";

      $result = $this->db->query($sql) ;

      if ( $result )
	{
	  return $this->db->num_rows();
	}
      else
	{
	  return 0;
	}
    }


  /**
   *    \brief  Renvoie le nombre de facture incluant le produit/service
   *    \param  socid       id societe
   *    \return int         nombre d'inclusion
   */
	 
  function count_facture($socid=0)
    {
      $sql = "SELECT pd.fk_facture";
      $sql .= " FROM ".MAIN_DB_PREFIX."facturedet as pd, ".MAIN_DB_PREFIX."product as p";
      $sql .= ", ".MAIN_DB_PREFIX."facture as f";
      $sql .= " WHERE f.rowid = pd.fk_facture AND p.rowid = pd.fk_product AND p.rowid = ".$this->id;
      if ($socid > 0)
	{
	  $sql .= " AND f.fk_soc = $socid";
	}
      $sql .= " GROUP BY pd.fk_facture";

      $result = $this->db->query($sql) ;

      if ( $result )
	{
	  return $this->db->num_rows();
	}
      else
	{
	  return 0;
	}
    }


  /**
   *    \brief  Renvoie des stats
   *    \param  sql         requete a exécuter
   *    \return array       tableau ?
   */
	 
  function _get_stats($sql)
    {
      $result = $this->db->query($sql) ;

      if ( $result )
	{
	  $num = $this->db->num_rows();
	  $i = 0;
	  while ($i < $num)
	    {
	      $arr = $this->db->fetch_array($i);
	      $ventes[$arr[1]] = $arr[0];
	      $i++;
	    }
	}

      $year = strftime('%Y',time());
      $month = strftime('%m',time());
      $result = array();

      for ($j = 0 ; $j < 12 ; $j++)
	{
	  $idx=ucfirst(strftime("%b",mktime(12,0,0,$month,1,$year)));
	  if (isset($ventes[$year . $month]))
	    {
	      $result[$j] = array($idx, $ventes[$year . $month]);
	    }
	  else
	    {
	      $result[$j] = array($idx,0);
	    }

	  $month = "0".($month - 1);
	  if (strlen($month) == 3)
	    {
	      $month = substr($month,1);
	    }
	  if ($month == 0)
	    {
	      $month = 12;
	      $year = $year - 1;
	    }
	}
      return array_reverse($result);

    }


  /**
   *    \brief  Renvoie le nombre de ventes du produit/service par mois
   *    \param  socid       id societe
   *    \return array       nombre de vente par mois
   */
	 
  function get_nb_vente($socid=0)
    {
      $sql = "SELECT sum(d.qty), date_format(f.datef, '%Y%m') ";
      $sql .= " FROM ".MAIN_DB_PREFIX."facturedet as d, ".MAIN_DB_PREFIX."facture as f";
      $sql .= " WHERE f.rowid = d.fk_facture and d.fk_product =".$this->id;
      if ($socid > 0)
	{
	  $sql .= " AND f.fk_soc = $socid";
	}
      $sql .= " GROUP BY date_format(f.datef,'%Y%m') DESC ;";

      return $this->_get_stats($sql);
    }


  /**
   *    \brief  Renvoie le nombre de factures dans lesquelles figure le produit par mois
   *    \param  socid       id societe
   *    \return array       nombre de factures par mois
   */
	 
  function get_num_vente($socid=0)
    {
      $sql = "SELECT count(*), date_format(f.datef, '%Y%m') ";
      $sql .= " FROM ".MAIN_DB_PREFIX."facturedet as d, ".MAIN_DB_PREFIX."facture as f";
      $sql .= " WHERE f.rowid = d.fk_facture AND d.fk_product =".$this->id;
      if ($socid > 0)
	{
	  $sql .= " AND f.fk_soc = $socid";
	}
      $sql .= " GROUP BY date_format(f.datef,'%Y%m') DESC ;";

      return $this->_get_stats($sql);
    }


  /**
   *    \brief  Renvoie le nombre de propales dans lesquelles figure le produit par mois
   *    \param  socid       id societe
   *    \return array       nombre de propales par mois
   */
	 
  function get_num_propal($socid=0)
  {
      $sql = "SELECT count(*), date_format(p.datep, '%Y%m') ";
      $sql .= " FROM ".MAIN_DB_PREFIX."propaldet as d, ".MAIN_DB_PREFIX."propal as p";
      $sql .= " WHERE p.rowid = d.fk_propal and d.fk_product =".$this->id;
      if ($socid > 0)
	{
	  $sql .= " AND p.fk_soc = $socid";
	}
      $sql .= " GROUP BY date_format(p.datep,'%Y%m') DESC ;";

      return $this->_get_stats($sql);
    }


  /**
   *    \brief      Lie un fournisseur au produit/service
   *    \param      user        Utilisateur qui fait le lien
   *    \param      id_fourn    Id du fournisseur
   *    \param      ref_fourn   Reference chez le fournisseur
   *    \return     int         < 0 si erreur, > 0 si ok
   */
	 
  function add_fournisseur($user, $id_fourn, $ref_fourn) 
    {
        $sql = "SELECT count(*) as nb";
        $sql.= " FROM ".MAIN_DB_PREFIX."product_fournisseur";
        $sql.= " WHERE fk_product = ".$this->id." AND fk_soc = ".$id_fourn;
        $sql.= " AND ref_fourn = '".$ref_fourn."'";
    
        $resql=$this->db->query($sql);
        if ($resql)
        {
            $obj = $this->db->fetch_object($resql);
            if ($obj->nb == 0)
            {
                $sql = "INSERT INTO ".MAIN_DB_PREFIX."product_fournisseur ";
                $sql .= " (datec, fk_product, fk_soc, ref_fourn, fk_user_author)";
                $sql .= " VALUES (now(), $this->id, $id_fourn, '$ref_fourn', $user->id)";
    
                if ($this->db->query($sql))
                {
                    return 1;
                }
                else
                {
                    $this->error=$this->db->error();
                    return -1;
                }
            }
            $this->db->free($resql);
        }
        else
        {
            $this->error=$this->db->error();
            return -2;
        }
    }


  /**
   *    \brief  Renvoie le nombre de fournisseurs
   *    \return int         nombre de fournisseur
   */
	 
  function count_fournisseur()
    {
      $sql = "SELECT fk_soc";
      $sql .= " FROM ".MAIN_DB_PREFIX."product_fournisseur as p";
      $sql .= " WHERE p.fk_product = ".$this->id;

      $result = $this->db->query($sql) ;

      if ( $result )
	{
	  $num = $this->db->num_rows();

	  if ($num == 1)
	    {
	      $row = $this->db->fetch_row();
	      $this->fourn_appro_open = $row[0];
	      return 1;
	    }
	  else
	    {
	      return 0;
	    }
	}
      else
	{
	  return 0;
	}
    }


  /**
   *
   *
   */
  function fastappro($user)
  {
    include_once DOL_DOCUMENT_ROOT."/fourn/fournisseur.class.php";

    $nbf = $this->count_fournisseur();
    if ($nbf == 1)
      {
	dolibarr_syslog("Product::fastappro");
	$fournisseur = new Fournisseur($this->db);
	$fournisseur->fetch($this->fourn_appro_open);

	$fournisseur->ProductCommande($user, $this->id);
      }

  }


  /**
   *    \brief  Supprime un tarif fournisseur
   *    \param  user        utilisateur qui défait le lien
   *    \param  id_fourn    id du fournisseur
   *    \param  qty         quantité
   *    \return int         < 0 si erreur, > 0 si ok
   */
	 
  function remove_price($user, $id_fourn, $qty) 
    {
      $sql = "DELETE FROM ".MAIN_DB_PREFIX."product_fournisseur_price";
      $sql.= " WHERE fk_product = $this->id AND fk_soc = $id_fourn and quantity = '".$qty."';";	
      
      if ($this->db->query($sql) )
	{
	  return 1;	      
	}
      else
	{
	  dolibarr_print_error($this->db);
	  return -1;
	}
    }
    
  /**
   *    \brief  Délie un fournisseur au produit/service
   *    \param  user        utilisateur qui défait le lien
   *    \param  id_fourn    id du fournisseur
   *    \return int         < 0 si erreur, > 0 si ok
   */
	 
  function remove_fournisseur($user, $id_fourn) 
    {
      $sql = "DELETE FROM ".MAIN_DB_PREFIX."product_fournisseur ";
      $sql.= " WHERE fk_product = $this->id AND fk_soc = $id_fourn;";	
      
      if ($this->db->query($sql) )
	{
	  return 1;	      
	}
      else
	{
	  dolibarr_print_error($this->db);
	  return -1;
	}
    }


  /**
   *    \brief  Entre un nombre de piece du produit en stock dans un entrepôt
   *    \param  id_entrepot     id de l'entrepot
   *    \param  nbpiece         nombre de pieces
   */
	 
  function create_stock($id_entrepot, $nbpiece)
  {
    
    $sql = "INSERT INTO ".MAIN_DB_PREFIX."product_stock ";
    $sql .= " (fk_product, fk_entrepot, reel)";
    $sql .= " VALUES ($this->id, $id_entrepot, $nbpiece)";
    
    if ($this->db->query($sql) )
      {
	return 1;	      
      }
    else
      {
    dolibarr_print_error($this->db);
	return -1;
      }    
  }


  /**
   *    \brief  Ajuste le stock d'un entrepôt pour le produit à une valeure donnée
   *    \param  user            utilisateur qui demande l'ajustement
   *    \param  id_entrepot     id de l'entrepot
   *    \param  nbpiece         nombre de pieces
   *    \param  mouvement       0 = ajout, 1 = suppression
   */
	 
  function correct_stock($user, $id_entrepot, $nbpiece, $mouvement)
  {

    $sql = "SELECT count(*) FROM ".MAIN_DB_PREFIX."product_stock ";
    $sql .= " WHERE fk_product = $this->id AND fk_entrepot = $id_entrepot";
    
    if ($this->db->query($sql) )
      {
	$row = $this->db->fetch_row(0);
	if ($row[0] > 0)
	  {
	    return $this->ajust_stock($user, $id_entrepot, $nbpiece, $mouvement);
	  }
	else
	  {
	    return $this->create_stock($id_entrepot, $nbpiece);
	  }
      }
    else
      {
	  dolibarr_print_error($this->db);
  	  $this->db->rollback();
	  return -1;
      }        
  }


  /**
   *    \brief  Augment ou réduit la valeur de stock pour le produit
   *    \param  user            utilisateur qui demande l'ajustement
   *    \param  id_entrepot     id de l'entrepot
   *    \param  nbpiece         nombre de pieces
   *    \param  mouvement       0 = ajout, 1 = suppression
   */
	 
  function ajust_stock($user, $id_entrepot, $nbpiece, $mouvement)
  {
    $op[0] = "+" . trim($nbpiece);
    $op[1] = "-" . trim($nbpiece);

    if ($this->db->begin())
      {

	$sql = "UPDATE ".MAIN_DB_PREFIX."product ";
	$sql .= " SET stock_commande = stock_commande ".$op[$mouvement].", stock_propale = stock_propale ".$op[$mouvement];
	$sql .= " WHERE rowid = $this->id ";
	
	if ($this->db->query($sql) )
	  {	    
	    $sql = "UPDATE ".MAIN_DB_PREFIX."product_stock ";
	    $sql .= " SET reel = reel ".$op[$mouvement];
	    $sql .= " WHERE fk_product = $this->id AND fk_entrepot = $id_entrepot";
	    
	    if ($this->db->query($sql) )
	      {		
		$sql = "INSERT INTO ".MAIN_DB_PREFIX."stock_mouvement (datem, fk_product, fk_entrepot, value, type_mouvement, fk_user_author)";
		$sql .= " VALUES (now(), $this->id, $id_entrepot, ".$op[$mouvement].", 0, $user->id)";
		
		if ($this->db->query($sql) )
		  {
		    $this->db->commit();
		    return 1;	      
		  }
		else
		  {
      	    dolibarr_print_error($this->db);
		    $this->db->rollback();
		    return -2;
		  }
	      }
	    else
	      {
  	    dolibarr_print_error($this->db);
		$this->db->rollback();
		return -1;
	      } 
	  }
	else
	  {
 	    dolibarr_print_error($this->db);
	    $this->db->rollback();
	    return -3;
	  }    
      }
  }


  /**
   *    \brief      Charge les informations relatives à un fournisseur
   *    \param      fournid         id du fournisseur
   *    \return     int             < 0 si erreur, > 0 si ok
   */
  function fetch_fourn_data($fournid)
    {    
        $sql = "SELECT rowid, ref_fourn";
        $sql.= " FROM ".MAIN_DB_PREFIX."product_fournisseur ";
        $sql.= " WHERE fk_product = ".$this->id;
        $sql.= " AND fk_soc = ".$fournid;
        $result = $this->db->query($sql) ;
        
        if ($result)
        {
            $result = $this->db->fetch_array();
            $this->ref_fourn = $result["ref_fourn"];
            return 1;
        }
        else {
            return -1;
        }
    }


  /**
   *    \brief      Déplace fichier uploadé sous le nom $files dans le répertoire sdir
   *    \param      sdir        Répertoire destination finale
   *    \param      $files      Nom du fichier uploadé
   */
  function add_photo($sdir, $files)
  {
    $dir = $sdir .'/'. get_exdir($this->id) . $this->id ."/";
    $dir .= "photos/";
    
    if (! file_exists($dir))
    {
        dolibarr_syslog("Product Create $dir");
        create_exdir($dir);
    }
    
    if (file_exists($dir))
    {
        // Crée fichier en taille vignette
        // \todo A faire

        // Crée fichier en taille origine
        doliMoveFileUpload($files['tmp_name'], $dir . $files['name']);
    }
  }


  /**
   *    \brief      Affiche la première photo du produit
   *    \param      sdir        Répertoire à scanner
   *    \return     boolean     true si photo dispo, flase sinon
   */
  function is_photo_available($sdir)
  {
    $pdir = get_exdir($this->id) . $this->id ."/photos/";
    $dir = $sdir . '/'. $pdir;
    
    $nbphoto=0;
    if (file_exists($dir))
    {
        $handle=opendir($dir);
    
        while (($file = readdir($handle)) != false)
        {
            if (is_file($dir.$file)) return true;
        }
     }
     return false;
  }
  

  /**
   *    \brief      Affiche la première photo du produit
   *    \param      sdir    Répertoire à scanner
   *    \param      size    0=taille origine, 1 taille vignette
   *    \return     int     Nombre de photos affichées
   */
  function show_photo($sdir,$size=0)
  {
    return $this->show_photos($sdir,$size,1,0);
  }


  /**
   *    \brief      Affiche toutes les photos du produit (nbmax maximum)
   *    \param      sdir        Répertoire à scanner
   *    \param      size        0=taille origine, 1 taille vignette
   *    \param      nbmax       Nombre maximum de photos (0=pas de max)
   *    \param      nbbyrow     Nombre vignettes par ligne (si mode vignette)
   *    \return     int         Nombre de photos affichées
   *    \todo   A virer, seule la methode avec size=0 sert encore.
   */
  function show_photos($sdir,$size=0,$nbmax=0,$nbbyrow=5)
  {
    $pdir = get_exdir($this->id) . $this->id ."/photos/";
    $dir = $sdir . '/'. $pdir;
    
    $nbphoto=0;
    if (file_exists($dir))
    {
        $handle=opendir($dir);
    
        while (($file = readdir($handle)) != false)
        {
            $photo='';
            if (is_file($dir.$file)) $photo = $file;
    
            if ($photo)
            {
                $nbphoto++;

                if ($size == 1) {   // Format vignette
                    
                    // On determine nom du fichier vignette
                    $photo_vignette='';
                    if (eregi('(\.jpg|\.bmp|\.gif|\.png|\.tiff)$',$photo,$regs)) {
                        $photo_vignette=eregi_replace($regs[0],'',$photo)."_small".$regs[0];
                    }


                    if ($nbbyrow && $nbphoto == 1) print '<table width="100%" valign="top" align="center" border="0" cellpadding="2" cellspacing="2">';

                    if ($nbbyrow && ($nbphoto % $nbbyrow == 1)) print '<tr align=center valign=middle border=1>';
                    if ($nbbyrow) print '<td width="'.ceil(100/$nbbyrow).'%" class="photo">';
                    
                    print '<a href="'.DOL_URL_ROOT.'/viewimage.php?modulepart=product&file='.urlencode($pdir.$photo).'" alt="Taille origine" target="_blank">';

                    // Si fichier vignette disponible, on l'utilise, sinon on utilise photo origine
                    if ($photo_vignette && is_file($photo_vignette)) {
                        print '<img border="0" height="120" src="'.DOL_URL_ROOT.'/viewimage.php?modulepart=product&file='.urlencode($pdir.$photo_vignette).'">';
                    }
                    else {
                        print '<img border="0" height="120" src="'.DOL_URL_ROOT.'/viewimage.php?modulepart=product&file='.urlencode($pdir.$photo).'">';
                    }

                    print '</a>';

                    if ($nbbyrow) print '</td>';
                    if ($nbbyrow && ($nbphoto % $nbbyrow == 0)) print '</tr>';

                }
    
                if ($size == 0)     // Format origine
                    print '<img border="0" src="'.DOL_URL_ROOT.'/viewimage.php?modulepart=product&file='.urlencode($pdir.$photo).'">';
    
                // On continue ou on arrete de boucler ?
                if ($nbmax && $nbphoto >= $nbmax) break;
            }
        }
        
        if ($nbbyrow && $size==1)
        {
            // Ferme tableau
            while ($nbphoto % $nbbyrow) {
                print '<td width="'.ceil(100/$nbbyrow).'%">&nbsp;</td>';
                $nbphoto++;
            }
            
            if ($nbphoto) print '</table>';
        }
        
        closedir($handle);
    }
    
    return $nbphoto;
  }
  
  /**
   *    \brief      Retourne tableau de toutes les photos du produit
   *    \param      dir         Répertoire à scanner
   *    \param      nbmax       Nombre maximum de photos (0=pas de max)
   *    \return     array       Tableau de photos
   */
  function liste_photos($dir,$nbmax=0)
  {
    $nbphoto=0;
    $tabobj=array();
    
    if (file_exists($dir))
    {
        $handle=opendir($dir);
    
        while (($file = readdir($handle)) != false)
        {
            if (is_file($dir.$file))
            {
                $nbphoto++;
                $photo = $file;

                // On determine nom du fichier vignette
                $photo_vignette='';
                if (eregi('(\.jpg|\.bmp|\.gif|\.png|\.tiff)$',$photo,$regs)) {
                    $photo_vignette=eregi_replace($regs[0],'',$photo)."_small".$regs[0];
                }
 
                // Objet
                $obj->photo=$photo;
                if ($photo_vignette && is_file($photo_vignette)) $obj->photo_vignette=$photo_vignette;
                else $obj->photo_vignette="";
                $tabobj[$nbphoto-1]=$obj;

                // On continue ou on arrete de boucler ?
                if ($nbmax && $nbphoto >= $nbmax) break;
            }
        }
        
        closedir($handle);
    }
    
    return $tabobj;
  }

}
?>