db=$p_cn;
$this->qcode="";
$this->user=$_SESSION[SESSION_KEY.'g_user'];
$this->periode=$g_user->get_periode();
$this->jr_id=0;
$this->jr_optype="NOR";
$this->amount=0;
$this->currency_rate=1;
$this->currency_rate_ref=1;
$this->currency_id=NULL;
}
/**
*@brief retrieve the grpt_id from jrn for a jr_id
*@return jrn.jr_grpt_id or an empty string if not found
*/
function seek_group()
{
$ret=$this->db->get_value('select jr_grpt_id from jrn where jr_id=$1',
array($this->jr_id));
return $ret;
}
/**
* \brief prepare the query for getting the qcode of the tiers, when
* executing this SQL , an array of (jrn.jr_id , jrnx.j_id) must be
* provided
*/
private function prepare_sql_tiers()
{
// prepare for getting the tiers
$this->db->prepare('prep_tiers',"select fiche_detail.f_id,ad_value from
fiche_detail
join (select qf_other as f_id
from quant_fin
where
quant_fin.jr_id = $1
union all
select qp_supplier as f_id
from quant_purchase
where quant_purchase.j_id=$2
union all
select qs_client as f_id
from quant_sold
where quant_sold.j_id=$2 ) as v_fiche on (fiche_detail.f_id=v_fiche.f_id) where ad_id=23 ");
}
/**
* \brief prepare the query for getting the qcode of the tiers, when
* executing this SQL , an array of (jrn.jr_id , jrnx.j_id) must be
* provided
*/
private function prepare_sql_counterpart()
{
// prepare for getting the tiers
$this->db->prepare('prep_counterpart',"select fiche_detail.f_id,ad_value from
fiche_detail
join (select qf_bank as f_id
from quant_fin
where
quant_fin.jr_id = $1
union all
select qp_fiche as f_id
from quant_purchase
where quant_purchase.j_id=$2
union all
select qs_fiche as f_id
from quant_sold
where quant_sold.j_id=$2 ) as v_fiche on (fiche_detail.f_id=v_fiche.f_id) where ad_id=23 ");
}
/**
* @brief Find the tiers of an operation , thanks the SQL prepared query
* prep_tiers and prep_counterpart. Return a string with the quick_code
* @param type $pn_jrn_id pk of the table jrn (jrn.jr_id)
* @param type $pn_jrnx_id pk of the table jrnx (jrnx.jr_id)
* @param type $p_code quickcode
* @return string
*/
function find_tiers($pn_jrn_id,$pn_jrnx_id,$p_code)
{
static $p=0;
if ( $p == 0 ){
$this->prepare_sql_counterpart();
$this->prepare_sql_tiers();
$p=1;
}
$tiers="";
$res_tiers=$this->db->execute('prep_tiers',
array($pn_jrn_id,$pn_jrnx_id));
if ( Database::num_row($res_tiers) > 0) {
$atiers=Database::fetch_array($res_tiers);
$tiers=$atiers['ad_value'];
// If the found tiers has the same quickcode than the current
// card, it means it is a card of supplier or customer,
// so we must look for the countercard
if ($tiers == $p_code) {
$res_counterpart=$this->db->execute('prep_counterpart',
array($pn_jrn_id,$pn_jrnx_id));
$tiers="";
if ( Database::num_row($res_counterpart) > 0) {
$atiers=Database::fetch_array($res_counterpart);
$tiers=$atiers['ad_value'];
}
}
}
return $tiers;
}
/**
*@brief Insert into the table Jrn
*The needed data are :
* - this->date
* - this->amount
* - this->poste
* - this->grpt
* - this->jrn
* - this->type ( debit or credit)
* - this->user
* - this->periode
* - this->qcode
* - this->desc optional
*@note if the amount is less than 0 then side changes, for example debit becomes
*a credit and vice versa
*@return jrnx.j_id
*/
function insert_jrnx()
{
if ( $this->poste == "") { throw new Exception (__FILE__.':'.__LINE__.' Poste comptable vide');return false; }
/* for negative amount the operation is reversed */
if ( $this->amount < 0 )
{
$this->type=($this->type=='d')?'c':'d';
}
if ( DEBUGNOALYSS > 1 ) {
echo "insert_jrnx = [{ $this->poste}] {$this->amount} rounded ".round($this->amount,2)." type {$this->type}
";
}
$this->amount=abs($this->amount);
$debit=($this->type=='c')?'false':'true';
$this->desc=(isset($this->desc))?$this->desc:'';
$this->amount=(trim($this->amount)==''||$this->amount==NULL)?0:$this->amount;
$Res=$this->db->exec_sql("select insert_jrnx
($1::text,abs($2)::numeric,$3::account_type,$4::integer,$5::integer,$6::bool,$7::text,$8::integer,upper($9),$10::text)",
array(
$this->date, //$1
round($this->amount,2), //$2
$this->poste, //$3
$this->grpt, //$4
$this->jrn, //$5
$debit, //$6
$this->user, //$7
$this->periode, //$8
$this->qcode, // $9
$this->desc)); //$10
if ( $Res===FALSE) return FALSE;
$this->jrnx_id=$this->db->get_current_seq('s_jrn_op');
return $this->jrnx_id;
}
/**
* @brief get the sum of other tax linked to this operation
*/
function get_sum_other_tax() {
if ( $this->jr_id == 0 ) {return 0;}
$sum=$this->db->get_value("select
sum(case when j_debit is false and jrn_def.jrn_def_type='ACH'
then 0-j_montant when j_debit is true and jrn_def.jrn_def_type='VEN'
then 0-j_montant
else j_montant end) sum_tax
from
jrn_tax join jrnx j1 using (j_id)
join jrn on (jr_grpt_id=j1.j_grpt)
join jrn_def on (jrn.jr_def_id=jrn_def.jrn_def_id)
where
jrn.jr_id=$1",[$this->jr_id]);
;
if ( $this->db->count()==0) {return 0;}
return $sum;
}
/*!\brief set the pj of a operation in jrn. the jr_id must be set
*\note if the jr_id it fails
*/
function set_pj()
{
if ( strlen(trim($this->pj)) == 0 )
{
$sql="update jrn set jr_pj_number=$1 where jr_id=$2";
$this->db->exec_sql($sql,array(null,$this->jr_id));
return '';
}
/* is pj uniq ? */
if ( $this->db->count_sql("select jr_id from jrn where jr_pj_number=$1 and jr_def_id=$2",
array($this->pj,$this->jrn)
) == 0 )
{
$sql="update jrn set jr_pj_number=$1 where jr_id=$2";
$this->db->exec_sql($sql,array($this->pj,$this->jr_id));
}
else
{
/* get pref */
$pref=$this->db->get_value("select jrn_def_pj_pref from jrn_def where jrn_def_id=$1",
array($this->jrn));
/* try another seq */
$flag=0;
$limit=100;
while ( $flag == 0 )
{
/* limit the search to $limit */
if ( $limit < 1 )
{
$this->pj='';
$flag=2;
break;
}
$seq=$this->db->get_next_seq('s_jrn_pj'.$this->jrn);
$this->pj=$pref.$seq;
/* check if the new pj numb exist */
$c=$this->db->count_sql("select jr_id from jrn where jr_pj_number=$1 and jr_def_id=$2",
array($this->pj,$this->jrn)
);
if ( $c == 0 )
{
$flag=1;
break;
}
$limit--;
}
/* a pj numb is found */
if ( $flag == 1 )
{
$sql="update jrn set jr_pj_number=$1 where jr_id=$2";
$this->db->exec_sql($sql,array($this->pj,$this->jr_id));
}
}
return $this->pj;
}
/*!
*\brief Insert into the table Jrn, the amount is computed from jrnx thanks the
* group id ($p_grpt)
*
* \return sequence of jr_id
*
*/
function insert_jrn()
{
$p_comment=$this->desc;
if ( DEBUGNOALYSS > 1 ) {
echo "insert_jrn = {$this->amount}
";
}
$diff=$this->db->get_value("select check_balance ($1)",array($this->grpt));
if ( $diff != 0 )
{
printf (_("Erreur : balance incorrecte :diff = %s"),$diff);
return false;
}
$echeance=( isset( $this->echeance) && strlen(trim($this->echeance)) != 0)?$this->echeance:null;
if ( ! isset($this->mt) )
{
$this->mt=microtime(true);
}
// if amount == -1then the triggers will throw an error
//
$this->amount=(trim($this->amount)==''||$this->amount==NULL)?0:$this->amount;
$Res=$this->db->exec_sql("insert into jrn (jr_def_id,jr_montant,jr_comment,".
"jr_date,jr_ech,jr_grpt_id,jr_tech_per,jr_mt,jr_optype,currency_id,currency_rate,currency_rate_ref) values (".
"$1,$2,$3,".
"to_date($4,'DD.MM.YYYY'),to_date($5,'DD.MM.YYYY'),$6,$7,$8,$9,$10,$11,$12)",
array ($this->jrn, $this->amount,$p_comment,
$this->date,$echeance,$this->grpt,$this->periode,$this->mt,$this->jr_optype,
$this->currency_id,$this->currency_rate,$this->currency_rate_ref)
);
if ($Res==FALSE)
{
return FALSE;
}
$this->jr_id=$this->db->get_current_seq('s_jrn');
return $this->jr_id;
}
/*!
* \brief Return the internal value, the property jr_id must be set before
*
* \return null si aucune valeur de trouv
*
*/
function get_internal()
{
if ( ! isset($this->jr_id) )
throw new Exception('jr_id is not set',1);
$Res=$this->db->exec_sql("select jr_internal from jrn where jr_id=".$this->jr_id);
if ( Database::num_row($Res) == 0 ) return null;
$l_line=Database::fetch_array($Res);
$this->jr_internal= $l_line['jr_internal'];
return $this->jr_internal;
}
/*!\brief search an operation thankx it internal code
* \param internal code
* \return 0 ok -1 nok
*/
function seek_internal($p_internal)
{
$res=$this->db->exec_sql('select jr_id from jrn where jr_internal=$1',
array($p_internal));
if ( Database::num_row($res) == 0 ) return -1;
$this->jr_id=Database::fetch_result($res,0,0);
return 0;
}
/*!\brief retrieve data from jrnx
*\note the data are filtered by the access of the current user
* \return an array or FALSE if nothing found
*/
function get_jrnx_detail()
{
global $g_user;
$filter_sql=$g_user->get_ledger_sql('ALL',3);
$filter_sql=str_replace('jrn_def_id','jr_def_id',$filter_sql);
if ( $this->jr_id==0 ) return;
$sql=" select jr_id,j_id,jr_date,j_qcode,j_poste,j_montant,jr_internal,case when j_debit = 'f' then 'C' else 'D' end as debit,jr_comment as description,
vw_name,pcm_lib,j_debit,coalesce(comptaproc.get_letter_jnt(j_id),-1) as letter,jr_def_id ".
" from jrnx join jrn on (jr_grpt_id=j_grpt)
join tmp_pcmn on (j_poste=pcm_val)
left join vw_fiche_attr on (j_qcode=quick_code)
where
jr_id=$1 and $filter_sql order by j_debit desc";
$res=$this->db->exec_sql($sql,array($this->jr_id));
if ( Database::num_row ($res) == 0 ) return array();
$all=Database::fetch_all($res);
return $all;
}
/*!\brief add a comment to the line (jrnx.j_text) */
function update_comment($p_text)
{
$sql="update jrnx set j_text=$1 where j_id=$2";
$this->db->exec_sql($sql,array($p_text,$this->jrnx_id));
}
/*!\brief add a comment to the operation (jrn.jr_text) */
function operation_update_comment($p_text)
{
$sql="update jrn set jr_comment=$1 where jr_id=$2";
$this->db->exec_sql($sql,array($p_text,$this->jr_id));
}
/*!\brief add a limit of payment to the operation (jrn.jr_ech) */
function operation_update_date_limit($p_text)
{
if ( isDate($p_text) == null )
{
$p_text=null;
}
$sql="update jrn set jr_ech=to_date($1,'DD.MM.YYYY') where jr_id=$2";
$this->db->exec_sql($sql,array($p_text,$this->jr_id));
}
/*!\brief return the jrn_def_id from jrn */
function get_ledger()
{
$sql="select jr_def_id from jrn where jr_id=$1";
$row=$this->db->get_value($sql,array($this->jr_id));
return $row;
}
/*!\brief display_jrnx_detail : get the data from get_jrnx_data and
return a string with HTML code
* \param table(=0 no code for table,1 code for table,2 code for CSV)
*/
function display_jrnx_detail($p_table)
{
$show=$this->get_jrnx_detail();
$r='';
$r_notable='';
$csv="";
foreach ($show as $l)
{
$border="";
if ( $l['j_poste'] == $this->poste || ($l['j_qcode']==$this->qcode && trim($this->qcode) != ''))
$border=' class="highlight"';
$r.='