0001792: BLOOMBERG added to Exchange Rate Providers and config fix, improvement
[fa-stable.git] / gl / includes / db / gl_db_rates.inc
1 <?php
2 /**********************************************************************
3     Copyright (C) FrontAccounting, LLC.
4         Released under the terms of the GNU General Public License, GPL, 
5         as published by the Free Software Foundation, either version 3 
6         of the License, or (at your option) any later version.
7     This program is distributed in the hope that it will be useful,
8     but WITHOUT ANY WARRANTY; without even the implied warranty of
9     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  
10     See the License here <http://www.gnu.org/licenses/gpl-3.0.html>.
11 ***********************************************************************/
12 include_once($path_to_root . "/includes/remote_url.inc");
13 //---------------------------------------------------------------------------------------------
14 function get_exchange_rate($rate_id)
15 {
16         $sql = "SELECT * FROM ".TB_PREF."exchange_rates WHERE id=".db_escape($rate_id);
17         $result = db_query($sql, "could not get exchange rate for $rate_id");   
18
19         return db_fetch($result);
20 }
21
22 // Retrieves buy exchange rate for given currency/date, zero if no result
23 function get_date_exchange_rate($curr_code, $date_)
24 {
25         $date = date2sql($date_);
26         $sql = "SELECT rate_buy FROM ".TB_PREF."exchange_rates WHERE curr_code=".db_escape($curr_code)
27         ." AND date_='$date'";
28         $result = db_query($sql, "could not get exchange rate for $curr_code - $date_");        
29
30         if(db_num_rows($result) == 0) 
31                 return 0;
32         $row = db_fetch($result);
33                 return $row[0];
34 }
35
36 //---------------------------------------------------------------------------------------------
37
38 function update_exchange_rate($curr_code, $date_, $buy_rate, $sell_rate)
39 {
40         if (is_company_currency($curr_code))
41                 display_db_error("Exchange rates cannot be set for company currency", "", true);
42                         
43         $date = date2sql($date_);
44                 
45         $sql = "UPDATE ".TB_PREF."exchange_rates SET rate_buy=$buy_rate, rate_sell=".db_escape($sell_rate)
46         ." WHERE curr_code=".db_escape($curr_code)." AND date_='$date'";
47                                 
48         db_query($sql, "could not add exchange rate for $curr_code");                           
49 }
50
51 //---------------------------------------------------------------------------------------------
52
53 function add_exchange_rate($curr_code, $date_, $buy_rate, $sell_rate)
54 {
55         if (is_company_currency($curr_code))
56                 display_db_error("Exchange rates cannot be set for company currency", "", true);
57
58         $date = date2sql($date_);
59                 
60         $sql = "INSERT INTO ".TB_PREF."exchange_rates (curr_code, date_, rate_buy, rate_sell)
61                 VALUES (".db_escape($curr_code).", '$date', ".db_escape($buy_rate)
62                 .", ".db_escape($sell_rate).")";
63         db_query($sql, "could not add exchange rate for $curr_code");                           
64 }
65
66 //---------------------------------------------------------------------------------------------
67
68 function delete_exchange_rate($rate_id)
69 {
70         $sql = "DELETE FROM ".TB_PREF."exchange_rates WHERE id=".db_escape($rate_id);
71         db_query($sql, "could not delete exchange rate $rate_id");              
72 }
73
74 //-----------------------------------------------------------------------------
75 //      Retrieve exchange rate as of date $date from external source (usually inet)
76 //
77 function retrieve_exrate($curr_b, $date)
78 {
79         global $xr_providers, $dflt_xr_provider;
80         $xchg_rate_provider = ((isset($xr_providers) && isset($dflt_xr_provider)) ? $xr_providers[$dflt_xr_provider] : 'ECB');
81         
82         $rate = hook_retrieve_exrate($curr_b, $date);
83         if (is_numeric($rate))
84                 return $rate;
85         return get_extern_rate($curr_b, $xchg_rate_provider, $date);
86 }
87 //-----------------------------------------------------------------------------
88
89 function get_extern_rate($curr_b, $provider = 'ECB', $date) 
90 {
91         $curr_a = get_company_pref('curr_default');
92         if ($provider == 'ECB')
93         {
94                 $filename = "/stats/eurofxref/eurofxref-daily.xml";
95                 $site = "www.ecb.int";
96         }
97         elseif ($provider == 'YAHOO')
98         {
99                 $filename = "/d/quotes.csv?s={$curr_a}{$curr_b}=X&f=sl1d1t1ba&e=.csv"; // new URL's for YAHOO
100                 $site = "download.finance.yahoo.com";
101         //$filename = "/q?s={$curr_a}{$curr_b}=X"; // Let old code be here for a while, Joe.
102                 //$site = "finance.yahoo.com";
103         }
104         elseif ($provider == 'GOOGLE')
105         {
106                 $filename = "/finance/converter?a=1&from={$curr_a}&to={$curr_b}";
107                 $site = "www.google.com";
108         }
109         elseif ($provider == 'BLOOMBERG')
110         {
111                 $filename = "/quote/{$curr_b}{$curr_a}:CUR";
112                 $site = "www.bloomberg.com";
113         }
114         $contents = '';
115         if (function_exists('curl_init'))
116         {       // first check with curl as we can set short timeout;
117                 $retry = 1;
118                 do {
119                $ch = curl_init();
120            curl_setopt ($ch, CURLOPT_URL, 'http://'.$site.$filename);
121                curl_setopt ($ch, CURLOPT_COOKIEJAR, "cookie.txt");
122            curl_setopt ($ch, CURLOPT_HEADER, 0);
123                curl_setopt ($ch, CURLOPT_RETURNTRANSFER, 1);
124                // prevent warning while save_mode/open_basedir on (redireciton doesn't occur at least on ECB page)
125                    if (!ini_get('save_mode') && !ini_get('open_basedir'))
126                 curl_setopt ($ch, CURLOPT_FOLLOWLOCATION, 1);
127                curl_setopt ($ch, CURLOPT_TIMEOUT, 3);
128            $contents = curl_exec ($ch);
129                curl_close($ch);
130                         // due to resolver bug in some curl versions (e.g. 7.15.5) 
131                         // try again for constant IP.
132                    $site="195.128.2.97";
133            } while( ($contents == '') && $retry--);
134            
135         } else {
136                 $contents = url_get_contents("http://".$site.$filename);
137         }
138         if (!$contents) {
139                 display_warning(sprintf(_("Cannot retrieve currency rate from %s page. Please set the rate manually."), $provider));
140         }
141         if ($provider == 'ECB')
142         {
143                 $contents = str_replace ("<Cube currency='USD'", " <Cube currency='EUR' rate='1'/> <Cube currency='USD'", $contents);
144                 $from_mask = "|<Cube\s*currency=\'" . $curr_a . "\'\s*rate=\'([\d.,]*)\'\s*/>|i";
145                 preg_match ( $from_mask, $contents, $out );
146                 $val_a = isset($out[1]) ? $out[1] : 0;
147                 $val_a = str_replace ( ',', '', $val_a );
148                 $to_mask = "|<Cube\s*currency=\'" . $curr_b . "\'\s*rate=\'([\d.,]*)\'\s*/>|i";
149                 preg_match ( $to_mask, $contents, $out );
150                 $val_b = isset($out[1]) ? $out[1] : 0;
151                 $val_b = str_replace ( ',', '', $val_b );
152                 if ($val_b) 
153                 {
154                         $val = $val_a / $val_b;
155                 } 
156                 else 
157                 {
158                         $val = 0;
159                 }
160         }
161         elseif ($provider == 'YAHOO')
162         {
163                 $val = ''; 
164                 $array = explode(',',$contents); // New operations for YAHOO. Safer.
165                 $val = $array[1];
166                 if ($val != 0)
167                         $val = 1 / $val;
168                 /* Let old code be here for a while, Joe.
169                 //if (preg_match('/Last\sTrade:(.*?)Trade\sTime/s', $contents, $matches)) {
170                         $val = strip_tags($matches[1]);
171                         $val = str_replace(',', '', $val);
172                         if ($val != 0)
173                                 $val = 1 / $val;
174                 }
175                 */
176         }
177         elseif ($provider == 'GOOGLE')
178         {
179                 $val = '';
180                 
181                 $regexp = "%([\d|.]+)\s+{$curr_a}\s+=\s+<span\sclass=(.*)>([\d|.]+)\s+{$curr_b}\s*</span>%s";
182                 if (preg_match($regexp, $contents, $matches)) 
183                 {
184                         $val = $matches[3];
185                         $val = str_replace(',', '', $val);
186                         if ($val != 0)
187                                 $val = 1 / $val;
188                 }
189     }    
190         elseif ($provider == 'BLOOMBERG')
191         {
192                 $val = '';
193                 $stmask = '<span class=" price">';
194                 $val = trim(strstr($contents, $stmask));
195                 $stmask = chr(10);
196                 $val = trim(strstr($val, $stmask));
197                 $val = trim(strtok($val, $stmask)); 
198     }    
199         return $val;
200 }  /* end function get_extern_rate */
201
202 //-----------------------------------------------------------------------------
203
204 function get_sql_for_exchange_rates()
205 {
206         $sql = "SELECT date_, rate_buy, id FROM "
207                 .TB_PREF."exchange_rates "
208                 ."WHERE curr_code=".db_escape($_POST['curr_abrev'])."
209                  ORDER BY date_ DESC";
210         return $sql;     
211 }
212 ?>