UpdateDatabase.php
[Pman.Xtuple] / UpdateDatabase.php
1 <?php
2
3 /**
4  *
5  * Setup the core values in the database
6  *
7  *
8  */
9
10 require_once 'Pman/Core/UpdateDatabase.php';
11 class Pman_Xtuple_UpdateDatabase extends Pman_Core_UpdateDatabase
12 {
13     
14     static $cli_desc = "Update SQL - Beta";
15     
16     static $cli_opts = array(
17         'source' => array(
18             'desc' => 'Source directory for json files.',
19             'short' => 'f',
20             'default' => '',
21             'min' => 1,
22             'max' => 1,
23         ),
24         
25         
26         
27         'base' => array(
28             'desc' => 'Base Currency',
29             'default' => '',
30             'short' => 'b',
31             'min' => 1,
32             'max' => 1,
33             
34         ),
35  
36         'json-accnt' => array(
37             'desc' => 'Accounts JSON file',
38             'default' => '',
39             'min' => 1,
40             'max' => 1,
41             
42         ),
43         'json-curr-symbol' => array(
44             'desc' => 'Currency Symbols JSON file',
45             'default' => '',
46             'min' => 1,
47             'max' => 1,
48             
49         ),
50
51         'json-location' => array(
52             'desc' => 'Location JSON file',
53             'default' => '',
54             'min' => 1,
55             'max' => 1,
56             
57         ),
58         'json-terms' => array(
59             'desc' => 'Terms  JSON file',
60             'default' => '',
61             'min' => 1,
62             'max' => 1,
63             
64         ),
65         
66     );
67     
68     var $cli = false; 
69     function getAuth() {
70         
71         
72         $ff = HTML_FlexyFramework::get();
73         if (!empty($ff->cli)) {
74             $this->cli = true;
75             return true;
76         }
77         die("NOT ALLOWED");
78     }
79     
80     // called to ensure options are correct.
81     // before any data is imported / started..
82     function checkOpts($opts)
83     {
84         $opts = HTML_FlexyFramework::get()->page->opts;
85         if (
86                 (!empty($opts['init']) && empty($opts['base']) )
87                 ||
88                 (empty($opts['init']) && !empty($opts['base']) )
89            ) {
90                     
91             die("--base=XXX  and --init =1 must be used together.");
92         }
93         // default to import the terms.
94         if (
95                 (!empty($opts['init']) && empty($opts['json-terms']) ))
96         {
97             HTML_FlexyFramework::get()->page->opts['json-terms'] = dirname(__FILE__).'/Setup/terms.json';
98             
99         }
100        
101         
102          
103     }
104     
105     
106     function get($k = '',$opts)
107     {
108         $k = strtolower($k);
109         
110         $this->opts = $opts;
111         
112         require_once 'Pman/Core/UpdateDatabase.php';
113         
114         Pman_Core_UpdateDatabase::jsonImportFromArray($opts);
115           
116         $this->updateData($k);
117         
118     }
119     
120     function importModuleSQL($dburl)
121     {
122          
123             $dbtype = $dburl['scheme'];
124             $dirmethod = 'import' . $dburl['scheme'] . 'dir';
125         
126             $m = 'Xtuple';
127             echo "Xtyple:Importing SQL\n";
128         
129             
130             // if init has been called
131             // look in pgsql.ini -- This creates all the tables....
132             
133             if (!empty($this->opts['init'])) {
134                 // it should really use xtuple... but it's not very well organized...
135                 //$this->{$dirmethod}($dburl, $this->rootDir. "/Pman/$m/{$dbtype}.init");
136                 
137                 // ?? use dbscripts/misc/postbooks_empty.backup ???
138                 
139                 $this->{$dirmethod}($dburl, $this->rootDir. "/Pman/$m/{$dbtype}.init");
140                 
141             }
142             /*
143             // let's see if this works.. -- not very flexible... - hardcoding schema...
144             $this->{$dirmethod}($dburl, $this->rootDir. "/Pman/Xtuple/xtuple-database/440_schema.sql");
145             
146             foreach(array(
147                 'public/types',
148                 'public/tables',
149                 'public/views',
150                 'public/functions', 
151                 'public/trigger_functions',
152                 'public/indexes',
153                 'api/functions',
154                 'api/views',
155                 
156                 
157             ) as $dir) {
158                 $this->{$dirmethod}($dburl, $this->rootDir. "/Pman/Xtuple/xtuple-database/" . $dir);   
159             }
160             */
161             // first try the standard from xtuple-database
162             
163             
164             // new -- sql directory..
165             // new style will not support migrate ... they have to go into mysql-migrate.... directories..
166             // new style will not support pg.sql etc.. naming - that's what the direcotries are for..
167             
168             
169             
170              
171             $this->{$dirmethod}($dburl, $this->rootDir. "/Pman/$m/{$dbtype}");
172             
173             
174             
175             if (!empty($this->opts['init']) && file_exists($this->rootDir. "/Pman/$m/{$dbtype}.initdata")) {
176                 HTML_FlexyFramework::get()->generateDataobjectsCache(true);
177                 
178                 $this->{$dirmethod}($dburl, $this->rootDir. "/Pman/$m/{$dbtype}.initdata");
179                 $this->{'fixSequences'. $dbtype}();
180                 
181             }
182               
183     }
184     
185     
186     function updateData($k='')
187     {
188         $ff = HTML_Flexyframework::get();
189         $dburl = parse_url($ff->DB_DataObject['database']);
190        
191         
192 //        $this->importpgsqldir($dburl, $this->rootDir. "/Pman/Xtuple/xtuple-database/empty_data.sql");
193         
194         //DB_DataObject::debugLevel(1);
195         $tables = empty($k) ? array(
196                 
197 //                'curr_symbol', //?? fixme
198                 'custtype',
199                 'plancode',
200                 'prodcat',
201                 'classcode',
202                 'curr_rate',
203                 'char',
204                 'taxzone',
205                 'taxtype',
206                 'expcat',
207                 // accounts - fixme - we need a better 'base set'
208                 // 'costcat' -- fixme - we need to init this..
209             
210 //                'terms', //?? add
211                 
212 //                'location', //?? just check hat one exists.
213         ) : array($k);
214         
215         
216         $core_opts = HTML_FlexyFramework::get()->page->opts;
217         if (!empty($core_opts['init'])) {
218             DB_DataObject::factory('curr_symbol')->setBase($this, $core_opts['base']);
219         }
220         
221         
222         
223         
224         foreach($tables as $t) {
225             $cs = DB_DataObject::factory($t);
226             $cs->initDatabase($this);
227         
228         }
229         
230         // update data is called from main
231         
232         $this->updateMetricValue();
233         
234     }
235     
236     function updateMetricValue()
237     {
238         
239         $d = DB_DataObject::Factory('shipvia');
240         if($d->get('shipvia_code', 'UPS-Ground')){
241             $metric = DB_DataObject::Factory('metric');
242             $metric->query("SELECT setmetric('DefaultShipViaId', '{$d->pid()}')");
243         }
244         
245         $d = DB_DataObject::Factory('accnt');
246         if($d->get('accnt_descrip', 'Currency Gain Loss')){
247             $metric = DB_DataObject::Factory('metric');
248             $metric->query("SELECT setmetric('CurrencyGainLossAccount', '{$d->pid()}')");
249         }
250         
251         $d = DB_DataObject::Factory('salesrep');
252         $d->whereAdd("
253                 salesrep_active
254             AND
255                 salesrep_number IS NOT NULL
256             AND
257                 salesrep_number != ''
258         ");
259         $d->orderBy('salesrep_id ASC');
260         if($d->find(true)){
261             $metric = DB_DataObject::Factory('metric');
262             $metric->query("SELECT setmetric('DefaultSalesRep', '{$d->pid()}')");
263         }
264         
265         $d = DB_DataObject::Factory('shipform');
266         $d->orderBy('shipform_id ASC');
267         if($d->find(true)){
268             $metric = DB_DataObject::Factory('metric');
269             $metric->query("SELECT setmetric('DefaultShipFormId', '{$d->pid()}')");
270         }
271         
272     }
273     
274     
275     
276     
277     
278     
279     
280     
281     
282     
283     
284     
285     
286     
287     /*
288     
289     function updateData($k='')
290     {
291         
292         $this->addWarehouse();
293         $this->addExtraYears();
294         $this->addAccounts();
295         $this->addBankAccounts();
296     }
297     */
298     
299     function addWarehouse()
300     {
301         $l = DB_DataObject::Factory('location');
302         if ($l->count()) {
303             echo "location exists - SKIP\n";
304             return;
305         }
306         $cust = DB_DataObject::Factory('custinfo');
307         $cc =$cust->count() ;
308         if ($cc != 1) {
309             echo "location create - needs 1 custinfo - got $cc\n";
310             return;
311         }
312         $cust->find(true);
313         
314         $l->setFrom(array(
315             'location_name' => 'Warehouse',
316             'location_descrip' => 'Warehouse',
317             'location_cust_id' => $cust->pid()
318         ));
319     }
320     
321     
322     
323     function addExtraYears()
324     {
325         $p = DB_DataObject::Factory('period');
326         if ($p->count()) {
327             echo "SKIP - already have periods\n";
328             return;
329         }
330         $p->initPeriods($this);
331         $p->initPeriods($this);
332         $p->initPeriods($this);
333         $p->initPeriods($this);
334         
335     }
336     function addAccounts()
337     {
338         $ac = DB_DataObject::factory('accnt');
339         if ($ac->count()) {
340             return;
341         }
342         
343         require_once 'File/Convert.php';
344         $cp = $this->tempName('xls');
345         copy(dirname(__FILE__).'/Setup/accounts_sample.xls', $cp);
346         $fc = new File_Convert($cp, 'application/vnd.ms-excel');
347         //var_Dump($img->getStoreName());
348         $csv = $fc->convert('text/csv');
349         unlink($cp);
350         //var_dump($csv);
351         require_once 'Pman/Xtuple/Import/Accounts.php';
352         $ia = new Pman_Xtuple_Import_Accounts();
353         $ia->importCsv($csv);
354     }
355     
356     function addBankAccounts() {
357         
358         $accnt = DB_DataObject::factory('subaccnt');
359         if (!$accnt->get('subaccnt_number', '01')) {
360             echo "SKIP Bank account creation - no subaccnt - 01\n";
361             return;
362         }
363         
364         $bankaccnt = DB_DataObject::factory('bankaccnt');
365         
366         $bankaccnt->whereAdd("
367             bankaccnt_name != ''
368         ");
369         
370         if(!$bankaccnt->count()){
371             $bankaccnt = DB_DataObject::factory('bankaccnt');
372         
373             if(!$bankaccnt->get('bankaccnt_name', 'Current Account')){
374                 $accnt = DB_DataObject::factory('accnt');
375                 $accnt->setFrom(array(
376                     'accnt_number' => '131',
377                     'accnt_descrip' => 'Current Account',
378                     'accnt_comments' => '',
379                     'accnt_profit' => '01',
380                     'accnt_sub' => '01',
381                     'accnt_type' => 'A',
382                     'accnt_extref' => '',
383                     'accnt_closedpost' => false,
384                     'accnt_forwardupdate' => false,
385                     'accnt_subaccnttype_code' => 'CA',
386                     'accnt_curr_id' => $accnt->sqlValue("baseCurrId()"),
387                     'accnt_active' => true
388                 ));
389
390                 if(!$accnt->find(true)){
391                     $accnt->insert();
392                 }
393
394                 $bankaccnt->setFrom(array(
395                     'bankaccnt_name' => 'Current Account',
396                     'bankaccnt_descrip' => 'Current Account',
397                     'bankaccnt_bankname' => 'Current Account',
398                     'bankaccnt_accntnumber' => 'N/A',
399                     'bankaccnt_ar' => true,
400                     'bankaccnt_ap' => true,
401                     'bankaccnt_nextchknum' => 5000,
402                     'bankaccnt_type' => 'K',
403                     'bankaccnt_accnt_id' => $accnt->pid(),
404                     'bankaccnt_curr_id' => $bankaccnt->sqlValue("baseCurrId()"),
405                     'bankaccnt_notes' => '',
406                     'bankaccnt_routing' => '',
407                     'bankaccnt_ach_enabled' => false,
408                     'bankaccnt_ach_origintype' => 'I'
409                 ));
410
411                 $bankaccnt->insert();
412             }
413
414             $bankaccnt = DB_DataObject::factory('bankaccnt');
415
416             if(!$bankaccnt->get('bankaccnt_name', 'Savings Account')){
417                 $accnt = DB_DataObject::factory('accnt');
418                 $accnt->setFrom(array(
419                     'accnt_number' => '404',
420                     'accnt_descrip' => 'Savings Account',
421                     'accnt_comments' => '',
422                     'accnt_profit' => '01',
423                     'accnt_sub' => '01',
424                     'accnt_type' => 'A',
425                     'accnt_extref' => '',
426                     'accnt_closedpost' => false,
427                     'accnt_forwardupdate' => false,
428                     'accnt_subaccnttype_code' => 'CA',
429                     'accnt_curr_id' => $accnt->sqlValue("baseCurrId()"),
430                     'accnt_active' => true
431                 ));
432
433                 if(!$accnt->find(true)){
434                     $accnt->insert();
435                 }
436
437                 $bankaccnt->setFrom(array(
438                     'bankaccnt_name' => 'Savings Account',
439                     'bankaccnt_descrip' => 'Savings Account',
440                     'bankaccnt_bankname' => 'Savings Account',
441                     'bankaccnt_accntnumber' => 'N/A',
442                     'bankaccnt_ar' => true,
443                     'bankaccnt_ap' => true,
444                     'bankaccnt_nextchknum' => 5000,
445                     'bankaccnt_type' => 'K',
446                     'bankaccnt_accnt_id' => $accnt->pid(),
447                     'bankaccnt_curr_id' => $bankaccnt->sqlValue("baseCurrId()"),
448                     'bankaccnt_notes' => '',
449                     'bankaccnt_routing' => '',
450                     'bankaccnt_ach_enabled' => false,
451                     'bankaccnt_ach_origintype' => 'I'
452                 ));
453
454                 $bankaccnt->insert();
455             }
456         }
457         
458     }
459     
460 }