Fix: Error when removing supplier prices

htdocs/fourn/fournisseur.product.class.php

@@ -15,16 +15,13 @@
  * 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/fourn/fournisseur.product.class.php
 		\ingroup    produit
 		\brief      Fichier de la classe des produits prédéfinis
-		\version    $Revision$
+		\version    $Id$
 */
 
 require_once DOL_DOCUMENT_ROOT."/product.class.php";
@@ -55,26 +52,70 @@ class ProductFournisseur extends Product
 
 
 	/**
-	*    \brief    Délie un fournisseur au produit/service
+	*    \brief    Remove all prices for this couple supplier-product
-	*    \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($id_fourn)
 	{
-		$sql = "DELETE FROM ".MAIN_DB_PREFIX."product_fournisseur ";
+		$ok=1;
+		
+		$this->db->begin();
+		
+		// Search all links
+		$sql = "SELECT rowid";
+		$sql.= " FROM ".MAIN_DB_PREFIX."product_fournisseur";
 		$sql.= " WHERE fk_product = ".$this->id." AND fk_soc = ".$id_fourn;
 
 		dolibarr_syslog("ProductFournisseur::remove_fournisseur sql=".$sql);
 		$resql=$this->db->query($sql);
 		if ($resql)
 		{
-			return 1;
+			// For each link, delete price line
+			while ($obj=$this->db->fetch_object($resql))
+			{
+				$sql = "DELETE FROM ".MAIN_DB_PREFIX."product_fournisseur_price";
+				$sql.= " WHERE fk_product_fournisseur = ".$obj->rowid;
+				
+				dolibarr_syslog("ProductFournisseur::remove_fournisseur sql=".$sql);
+				$resql2=$this->db->query($sql);
+				if (! $resql2)
+				{
+					$this->error=$this->db->lasterror();
+					dolibarr_syslog("ProductFournisseur::remove_fournisseur ".$this->error, LOG_ERR);
+					$ok=0;
+				}
+			}
+			
+			// Now delete all link supplier-product (they have no more childs)
+			$sql = "DELETE FROM ".MAIN_DB_PREFIX."product_fournisseur";
+			$sql.= " WHERE fk_product = ".$this->id." AND fk_soc = ".$id_fourn;
+			
+			dolibarr_syslog("ProductFournisseur::remove_fournisseur sql=".$sql);
+			$resql=$this->db->query($sql);
+			if (! $resql)
+			{
+				$this->error=$this->db->lasterror();
+				dolibarr_syslog("ProductFournisseur::remove_fournisseur ".$this->error, LOG_ERR);
+				$ok=0;
+			}
+			
+			if ($ok)
+			{
+				$this->db->commit();
+				return 1;
+			}
+			else
+			{
+				$this->db->rollback();
+				return -1;
+			}
 		}
 		else
 		{
+			$this->db->rollback();
 			dolibarr_print_error($this->db);
-			return -1;
+			return -2;
 		}
 	}
 
@@ -96,23 +137,72 @@ class ProductFournisseur extends Product
 		}
 	}
 
-	/*
+	/**
-	*	\return		int		<0 si KO, 0 si non trouve, >0 si efface
+	 * 	\brief		Remove a price for a couple supplier-product
-	*/
+	 * 	\param		rowid	Line id of price
+	 *	\return		int		<0 if KO, >0 if OK
+	 */
 	function remove_product_fournisseur_price($rowid)
 	{
+		$this->db->begin();
+
 		$sql = "DELETE FROM ".MAIN_DB_PREFIX."product_fournisseur_price";
 		$sql.= " WHERE rowid = ".$rowid;
-
 		dolibarr_syslog("ProductFournisseur::remove_product_fournisseur_price sql=".$sql);
 		$resql = $this->db->query($sql);  
 		if ($resql) 
 		{
-			if ($this->db->affected_rows() > 0) return 1;
+			// Remove all entries with no childs
-			else return 0;
+			$sql = "SELECT pf.rowid";
+			$sql.= " FROM ".MAIN_DB_PREFIX."product_fournisseur as pf";
+			$sql.= " LEFT JOIN ".MAIN_DB_PREFIX."product_fournisseur_price as pfp ON pfp.fk_product_fournisseur = pf.rowid";
+			$sql.= " WHERE pfp.rowid IS NULL";
+			dolibarr_syslog("ProductFournisseur::remove_product_fournisseur_price sql=".$sql);
+			$resql = $this->db->query($sql);  
+			if ($resql)
+			{
+				$ok=1;
+	
+				while ($obj=$this->db->fetch_object($resql))
+				{			
+					$rowidpf=$obj->rowid;
+	
+					$sql = "DELETE FROM ".MAIN_DB_PREFIX."product_fournisseur";
+					$sql.= " WHERE rowid = ".$rowidpf;
+					dolibarr_syslog("ProductFournisseur::remove_product_fournisseur_price sql=".$sql);
+					$resql2 = $this->db->query($sql);  
+					if (! $resql2)
+					{
+						$this->error=$this->db->lasterror();
+						dolibarr_syslog("ProductFournisseur::remove_product_fournisseur_price ".$this->error,LOG_ERR);
+						$ok=0;
+					}
+				}
+							
+				if ($ok)
+				{
+					$this->db->commit();
+					return 1;
+				}
+				else
+				{
+					$this->db->rollback();
+					return -3;
+				}
+			}
+			else
+			{
+				$this->error=$this->db->lasterror();
+				dolibarr_syslog("ProductFournisseur::remove_product_fournisseur_price ".$this->error,LOG_ERR);
+				$this->db->rollback();
+				return -2;
+			}
 		}
 		else
 		{
+			$this->error=$this->db->lasterror();
+			dolibarr_syslog("ProductFournisseur::remove_product_fournisseur_price ".$this->error,LOG_ERR);
+			$this->db->rollback();
 			return -1;
 		}
 	}

htdocs/fourn/product/fiche.php

@@ -151,7 +151,7 @@ if ($_GET["action"] == 'remove_fourn')
 	$product = new ProductFournisseur($db);
 	if( $product->fetch($_GET["id"]) )
 	{
-		if ($product->remove_fournisseur($user, $_GET["id_fourn"]) > 0)
+		if ($product->remove_fournisseur($_GET["id_fourn"]) > 0)
 		{
 	  $_GET["action"] = '';
 	  $mesg = $langs->trans("SupplierRemoved");
@@ -194,9 +194,15 @@ if ($_POST["cancel"] == $langs->trans("Cancel"))
 }
 
 
-// Le produit n'est pas encore chargé a ce stade
+
+/*
+ * View
+ */
+
 llxHeader("","",$langs->trans("CardProduct0"));
 
+// Le produit n'est pas encore chargé a ce stade
+
 /*
  * Création du produit
  *

htdocs/product/fournisseurs.php

@@ -57,13 +57,15 @@ if ($_GET["action"] == 'remove_pf')
     $product = new ProductFournisseur($db);
     if ($product->fetch($_GET["id"]) > 0)
     {
-        if ($_GET["rowid"] && $product->remove_product_fournisseur_price($_GET["rowid"]) > 0)
+        if ($_GET["rowid"])
         {
+			$result=$product->remove_product_fournisseur_price($_GET["rowid"]);
             $_GET["action"] = '';
             $mesg = '<div class="ok">'.$langs->trans("PriceRemoved").'.</div>';
 		}
         else
         {	
+        	// Deprecated. Should not occurs
             if ($product->remove_fournisseur($_GET["socid"]) > 0)
             {
                 $_GET["action"] = '';
@@ -141,6 +143,7 @@ if ($_POST["action"] == 'updateprice' && $_POST["cancel"] <> $langs->trans("Canc
 		if (! $error)
 		{
 			$db->commit();
+			$_POST['action']='';
 		}
 		else
 		{
@@ -225,7 +228,7 @@ if ($_GET["id"] || $_GET["ref"])
 
 
 			// Form to add or update a price
-			if ($_GET["action"] == 'add_price' && $user->rights->produit->creer)
+			if (($_GET["action"] == 'add_price' || $_POST["action"] == 'updateprice' )&& $user->rights->produit->creer)
 			{
 				$langs->load("suppliers");