create type dajbre as (status int,id bigint);

CREATE OR REPLACE FUNCTION proc_uni(integer,integer,inet,text,integer,integer,text,integer,integer,
text,int, int,boolean,text) RETURNS setof dajbre AS '

DECLARE

uid alias for $1; 
pid alias for $2;
ip_i alias for $3;
s_number alias for $4;
s_ton_i alias for $5; 
s_npi_i alias for $6;
d_number alias for $7;
d_ton_i alias for $8;
d_npi_i alias for $9;
mess alias for $10;
dcs_i alias for $11;
esm_i alias for $12;
delivery_i alias for $13;
u_mess_id_i alias for $14; 

r dajbre%rowtype;

prefixfound boolean;
prefixprice billing.price%TYPE;
dest_num_len int;
tmp_dest_number text;
tmp_user_bal numeric;
tmp_returnval int;
novi_status int;
tmp_his_id bigint;
tmp_u_mess_id_i text;


begin


dest_num_len := char_length(d_number);
tmp_dest_number := d_number; 
prefixfound := false;

 
while dest_num_len > 0 loop 

	select into prefixprice price from billing 
        where u_id=uid and prefix=tmp_dest_number; 

	if not found then 
		tmp_dest_number := substring (tmp_dest_number from 1 for dest_num_len-1);
		dest_num_len := char_length(tmp_dest_number);
	else 
		prefixfound := true; 
		exit;
	end if;
end loop;


if prefixfound=false then 
	tmp_returnval :=11; 
	novi_status :=11;
else if prefixprice = 0 then
	tmp_returnval :=11;
	novi_status :=50; 
     else select into tmp_user_bal maxsms-cursms from users where id=uid; 
	if tmp_user_bal < prefixprice then 
		tmp_returnval :=11;
		novi_status :=51; 
	else
		tmp_returnval :=0; 
	end if;
     end if;
end if;


if tmp_returnval = 0 then 


insert into history (ip,source,dest,message,dcs,esm,s_ton,s_npi,d_ton,d_npi,u_id,delivery,price,p_id,u_mess_id) values
(ip_i,s_number,d_number,decode(mess,''base64''),dcs_i,esm_i,s_ton_i,s_npi_i,d_ton_i,d_npi_i,uid,delivery_i,prefixprice,pid,u_mess_id_i);

 tmp_his_id := currval(''history_id_seq'');



if pid = 2 then
	if u_mess_id_i = 0 then
  		tmp_u_mess_id_i := '''';
	else
		tmp_u_mess_id_i := u_mess_id_i;
	end if;
else if pid = 3 then
	  tmp_u_mess_id_i := tmp_his_id ;
     end if;
end if;

update history set u_mess_id = tmp_u_mess_id_i where id = tmp_his_id;


update users set cursms=cursms+ prefixprice where id=uid;


insert into inqueue(id, u_id) values (tmp_his_id, uid);

r.status := 0;
r.id := tmp_his_id;
return next r;


else 


	insert into rejected (ip,source,dest,message,dcs,esm,s_ton,s_npi,d_ton,d_npi,status,u_id,delivery,u_mess_id) values
(ip_i,s_number,d_number,decode(mess,''base64''),dcs_i,esm_i,s_ton_i,s_npi_i,d_ton_i,d_npi_i,novi_status,uid,delivery_i,u_mess_id_i);

r.status := 11;
r.id := 0;
return next r;

end if;

	return;

end; 

' language 'plpgsql';