+global\BonPrelevement::Create()

Complexity

Conditions	34
Paths	15607

Size

Total Lines	354
Code Lines	175

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
	function Create($banque=0, $agence=0, $mode='real', $format='ALL',$executiondate='')
	{
		global $conf,$langs;

		dol_syslog(__METHOD__."::Bank=".$banque." Office=".$agence." mode=".$mode." format=".$format, LOG_DEBUG);

		require_once (DOL_DOCUMENT_ROOT."/compta/facture/class/facture.class.php");
		require_once (DOL_DOCUMENT_ROOT."/societe/class/societe.class.php");

		if (empty($format)) return 'ErrorBadParametersForDirectDebitFileCreate';

		$error = 0;

		$datetimeprev = time();
                //Choice the date of the execution direct debit
                if(!empty($executiondate)) $datetimeprev = $executiondate;

		$month = strftime("%m", $datetimeprev);
		$year = strftime("%Y", $datetimeprev);

		$puser = new User($this->db, $conf->global->PRELEVEMENT_USER);

		$this->invoice_in_error = array();
		$this->thirdparty_in_error = array();

		// Read invoices
		$factures = array();
		$factures_prev = array();
		$factures_result = array();
		$factures_prev_id=array();
		$factures_errors=array();

		if (! $error)
		{
			$sql = "SELECT f.rowid, pfd.rowid as pfdrowid, f.fk_soc";
			$sql.= ", pfd.code_banque, pfd.code_guichet, pfd.number, pfd.cle_rib";
			$sql.= ", pfd.amount";
			$sql.= ", s.nom as name";
			$sql.= " FROM ".MAIN_DB_PREFIX."facture as f";
			$sql.= ", ".MAIN_DB_PREFIX."societe as s";
			$sql.= ", ".MAIN_DB_PREFIX."prelevement_facture_demande as pfd";
			$sql.= " WHERE f.rowid = pfd.fk_facture";
			$sql.= " AND f.entity IN (".getEntity('facture').')';
			$sql.= " AND s.rowid = f.fk_soc";
			//if ($banque || $agence) $sql.= " AND s.rowid = sr.fk_soc";
			$sql.= " AND f.fk_statut = 1";
			$sql.= " AND f.paye = 0";
			$sql.= " AND pfd.traite = 0";
			$sql.= " AND f.total_ttc > 0";
			//if ($banque) $sql.= " AND sr.code_banque = '".$conf->global->PRELEVEMENT_CODE_BANQUE."'";
			//if ($agence) $sql.= " AND sr.code_guichet = '".$conf->global->PRELEVEMENT_CODE_GUICHET."'";

			dol_syslog(__METHOD__."::Read invoices, sql=".$sql, LOG_DEBUG);

			$resql = $this->db->query($sql);
			if ($resql)
			{
				$num = $this->db->num_rows($resql);
				$i = 0;

				while ($i < $num)
				{
					$row = $this->db->fetch_row($resql);
					$factures[$i] = $row;	// All fields
					$i++;
				}
				$this->db->free($resql);
				dol_syslog(__METHOD__."::Read invoices, ".$i." invoices to withdraw", LOG_DEBUG);
			}
			else
			{
				$error++;
				dol_syslog(__METHOD__."::Read invoices error ".$this->db->error(), LOG_ERR);
			}
		}

		if (! $error)
		{
			require_once DOL_DOCUMENT_ROOT . '/societe/class/companybankaccount.class.php';
			$soc = new Societe($this->db);

			// Check RIB
			$i = 0;
			dol_syslog(__METHOD__."::Check RIB", LOG_DEBUG);

			if (count($factures) > 0)
			{
				foreach ($factures as $key => $fac)
				{
					$fact = new Facture($this->db);
					$resfetch = $fact->fetch($fac[0]);
					if ($resfetch >= 0)		// Field 0 of $fac is rowid of invoice
					{
						if ($soc->fetch($fact->socid) >= 0)
						{
							$bac = new CompanyBankAccount($this->db);
							$bac->fetch(0, $soc->id);

							if ($format == 'FRST' && $bac->frstrecur != 'FRST')
							{
								continue;
							}
							if ($format == 'RCUR' && ($bac->frstrecur != 'RCUR' && $bac->frstrecur != 'RECUR'))
							{
								continue;
							}

							if ($bac->verif() >= 1)
							{
								$factures_prev[$i] = $fac;
								/* second tableau necessaire pour BonPrelevement */
								$factures_prev_id[$i] = $fac[0];
								$i++;
								//dol_syslog(__METHOD__."::RIB is ok", LOG_DEBUG);
							}
							else
							{
								dol_syslog(__METHOD__."::Check RIB Error on default bank number IBAN/BIC for thirdparty reported by verif() ".$fact->socid." ".$soc->name, LOG_WARNING);
								$this->invoice_in_error[$fac[0]]="Error on default bank number IBAN/BIC for invoice ".$fact->getNomUrl(0)." for thirdparty ".$soc->getNomUrl(0);
								$this->thirdparty_in_error[$soc->id]="Error on default bank number IBAN/BIC for invoice ".$fact->getNomUrl(0)." for thirdparty ".$soc->getNomUrl(0);
							}
						}
						else
						{
							dol_syslog(__METHOD__."::Check RIB Failed to read company", LOG_WARNING);
						}
					}
					else
					{
						dol_syslog(__METHOD__."::Check RIB Failed to read invoice", LOG_WARNING);
					}
				}
			}
			else
			{
				dol_syslog(__METHOD__."::Check RIB No invoice to process", LOG_WARNING);
			}
		}

		$ok=0;

		// Withdraw invoices in factures_prev array
		$out=count($factures_prev)." invoices will be withdrawn.";
		//print $out."\n";
		dol_syslog($out);

		// Return warning
		/*$i=0;
        foreach ($this->thirdparty_in_error as $key => $val)
        {
        	if ($i < 10) setEventMessages($val, null, 'warnings');
        	else setEventMessages('More error were discarded...', null, 'warnings');
        	$i++;
        }*/

		if (count($factures_prev) > 0)
		{
			if ($mode=='real')
			{
				$ok=1;
			}
			else
			{
				print $langs->trans("ModeWarning"); //"Option for real mode was not set, we stop after this simulation\n";
			}
		}


		if ($ok)
		{
			/*
             * We are in real mode.
             * We create withdraw receipt and build withdraw into disk
             */
			$this->db->begin();

			$now=dol_now();

			/*
             * Traitements
             */
			if (!$error)
			{
				$ref = substr($year,-2).$month;

				$sql = "SELECT substring(ref from char_length(ref) - 1)";
				$sql.= " FROM ".MAIN_DB_PREFIX."prelevement_bons";
				$sql.= " WHERE ref LIKE '%".$this->db->escape($ref)."%'";
				$sql.= " AND entity = ".$conf->entity;
				$sql.= " ORDER BY ref DESC LIMIT 1";

				dol_syslog(get_class($this)."::Create sql=".$sql, LOG_DEBUG);
				$resql = $this->db->query($sql);

				if ($resql)
				{
					$row = $this->db->fetch_row($resql);
					$ref = "T".$ref.str_pad(dol_substr("00".intval($row[0])+1,0,2),2,"0",STR_PAD_LEFT);

					$dir=$conf->prelevement->dir_output.'/receipts';
					if (! is_dir($dir)) dol_mkdir($dir);

					$this->filename = $dir.'/'.$ref.'.xml';

					// Create withdraw receipt in database
					$sql = "INSERT INTO ".MAIN_DB_PREFIX."prelevement_bons (";
					$sql.= " ref, entity, datec";
					$sql.= ") VALUES (";
					$sql.= "'".$this->db->escape($ref)."'";
					$sql.= ", ".$conf->entity;
					$sql.= ", '".$this->db->idate($now)."'";
					$sql.= ")";

					$resql = $this->db->query($sql);
					if ($resql)
					{
						$prev_id = $this->db->last_insert_id(MAIN_DB_PREFIX."prelevement_bons");
						$this->id = $prev_id;
						$this->ref = $ref;
					}
					else
					{
						$error++;
						dol_syslog(__METHOD__."::Create withdraw receipt ".$this->db->lasterror(), LOG_ERR);
					}
				}
				else
				{
					$error++;
					dol_syslog(__METHOD__."::Get last withdraw receipt ".$this->db->lasterror(), LOG_ERR);
				}
			}

			if (!$error)
			{
				/*
	             * Create withdrawal receipt in database
	             */
				if (count($factures_prev) > 0)
				{
					foreach ($factures_prev as $fac)	// Add a link in database for each invoice
					{
						// Fetch invoice
						$fact = new Facture($this->db);
						$fact->fetch($fac[0]);
						/*
                         * Add standing order
                         *
                         *
                         * $fac[3] : banque
                         * $fac[4] : guichet
                         * $fac[5] : number
                         * $fac[6] : cle rib
                         * $fac[7] : amount
                         * $fac[8] : client nom
                         * $fac[2] : client id
                         */
						$ri = $this->AddFacture($fac[0], $fac[2], $fac[8], $fac[7], $fac[3], $fac[4], $fac[5], $fac[6]);
						if ($ri <> 0)
						{
							$error++;
						}

						// Update invoice requests as done
						$sql = "UPDATE ".MAIN_DB_PREFIX."prelevement_facture_demande";
						$sql.= " SET traite = 1";
						$sql.= ", date_traite = '".$this->db->idate($now)."'";
						$sql.= ", fk_prelevement_bons = ".$this->id;
						$sql.= " WHERE rowid = ".$fac[1];

						dol_syslog(__METHOD__."::Update Orders::Sql=".$sql, LOG_DEBUG);
						$resql=$this->db->query($sql);

						if (! $resql)
						{
							$error++;
							dol_syslog(__METHOD__."::Update Orders::Error=".$this->db->error(), LOG_ERR);
						}

					}
				}

			}

			if (!$error)
			{
				/*
                 * Create direct debit order in a XML file
                 */

				dol_syslog(__METHOD__."::Init withdraw receipt for ".count($factures_prev)." invoices", LOG_DEBUG);


				if (count($factures_prev) > 0)
				{
					$this->date_echeance = $datetimeprev;
					$this->reference_remise = $ref;

The variable $ref does not seem to be defined for all execution paths leading up to this point.

					$id=$conf->global->PRELEVEMENT_ID_BANKACCOUNT;
					$account = new Account($this->db);
					if ($account->fetch($id)>0)
					{
						$this->emetteur_code_banque 	   = $account->code_banque;
						$this->emetteur_code_guichet       = $account->code_guichet;
						$this->emetteur_numero_compte      = $account->number;
						$this->emetteur_number_key		   = $account->cle_rib;
						$this->emetteur_iban               = $account->iban;
						$this->emetteur_bic                = $account->bic;

						$this->emetteur_ics                = $conf->global->PRELEVEMENT_ICS;		// Ex: PRELEVEMENT_ICS = "FR78ZZZ123456";

						$this->raison_sociale              = $account->proprio;
					}

					$this->factures = $factures_prev_id;

					// Generation of SEPA file $this->filename
					$this->generate($format,$executiondate);
				}
				dol_syslog(__METHOD__."::End withdraw receipt, file ".$this->filename, LOG_DEBUG);
			}
			//var_dump($factures_prev);exit;

			/*
             * Update total
             */
			$sql = "UPDATE ".MAIN_DB_PREFIX."prelevement_bons";
			$sql.= " SET amount = ".price2num($this->total);
			$sql.= " WHERE rowid = ".$this->id;
			$sql.= " AND entity = ".$conf->entity;

			$resql=$this->db->query($sql);
			if (! $resql)
			{
				$error++;
				dol_syslog(__METHOD__."::Error update total: ".$this->db->error(), LOG_ERR);
			}

			if (!$error)
			{
				$this->db->commit();
			}
			else
			{
				$this->db->rollback();
			}

			return count($factures_prev);
		}
		else
		{
			return 0;
		}
	}