synchro_import.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644
  1. <?php
  2. // Copyright (C) 2011 Combodo SARL
  3. //
  4. // This program is free software; you can redistribute it and/or modify
  5. // it under the terms of the GNU General Public License as published by
  6. // the Free Software Foundation; version 3 of the License.
  7. //
  8. // This program is distributed in the hope that it will be useful,
  9. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  10. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  11. // GNU General Public License for more details.
  12. //
  13. // You should have received a copy of the GNU General Public License
  14. // along with this program; if not, write to the Free Software
  15. // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  16. /**
  17. * Data Exchange web service
  18. *
  19. * @author Erwan Taloc <erwan.taloc@combodo.com>
  20. * @author Romain Quetiez <romain.quetiez@combodo.com>
  21. * @author Denis Flaven <denis.flaven@combodo.com>
  22. * @license http://www.opensource.org/licenses/gpl-3.0.html LGPL
  23. */
  24. //
  25. // Known limitations
  26. // - reconciliation is made on the column primary_key
  27. //
  28. if (!defined('__DIR__')) define('__DIR__', dirname(__FILE__));
  29. require_once(__DIR__.'/../approot.inc.php');
  30. require_once(APPROOT.'/application/application.inc.php');
  31. require_once(APPROOT.'/application/webpage.class.inc.php');
  32. require_once(APPROOT.'/application/csvpage.class.inc.php');
  33. require_once(APPROOT.'/application/clipage.class.inc.php');
  34. require_once(APPROOT.'/application/startup.inc.php');
  35. class ExchangeException extends Exception
  36. {
  37. }
  38. $aPageParams = array
  39. (
  40. 'auth_user' => array
  41. (
  42. 'mandatory' => true,
  43. 'modes' => 'cli',
  44. 'default' => null,
  45. 'description' => 'login (must have enough rights to create objects of the given class)',
  46. ),
  47. 'auth_pwd' => array
  48. (
  49. 'mandatory' => true,
  50. 'modes' => 'cli',
  51. 'default' => null,
  52. 'description' => 'password',
  53. ),
  54. 'data_source_id' => array
  55. (
  56. 'mandatory' => true,
  57. 'modes' => 'http,cli',
  58. 'default' => null,
  59. 'description' => 'Synchro data source id',
  60. ),
  61. 'csvdata' => array
  62. (
  63. 'mandatory' => true,
  64. 'modes' => 'http',
  65. 'default' => null,
  66. 'description' => 'data',
  67. ),
  68. 'csvfile' => array
  69. (
  70. 'mandatory' => true,
  71. 'modes' => 'cli',
  72. 'default' => '',
  73. 'description' => 'local data file, replaces csvdata if specified',
  74. ),
  75. 'synchronize' => array
  76. (
  77. 'mandatory' => false,
  78. 'modes' => 'http,cli',
  79. 'default' => '1',
  80. 'description' => 'If set to 1, then the synchronization will be executed right after the data load',
  81. ),
  82. 'charset' => array
  83. (
  84. 'mandatory' => false,
  85. 'modes' => 'http,cli',
  86. 'default' => 'UTF-8',
  87. 'description' => 'Character set encoding of the CSV data: UTF-8, ISO-8859-1, WINDOWS-1251, WINDOWS-1252, ISO-8859-15',
  88. ),
  89. 'date_format' => array
  90. (
  91. 'mandatory' => false,
  92. 'modes' => 'http,cli',
  93. 'default' => '',
  94. 'description' => 'Input date format (used both for dates and datetimes) - Examples: %Y-%m-%d, %d/%m/%Y (Europe) - no transformation is applied if the argument is omitted',
  95. ),
  96. 'separator' => array
  97. (
  98. 'mandatory' => false,
  99. 'modes' => 'http,cli',
  100. 'default' => ';',
  101. 'description' => 'column separator in CSV data',
  102. ),
  103. 'qualifier' => array
  104. (
  105. 'mandatory' => false,
  106. 'modes' => 'http,cli',
  107. 'default' => '"',
  108. 'description' => 'test qualifier in CSV data',
  109. ),
  110. 'output' => array
  111. (
  112. 'mandatory' => false,
  113. 'modes' => 'http,cli',
  114. 'default' => 'summary',
  115. 'description' => '[retcode] to return the count of lines in error, [summary] to return a concise report, [details] to get a detailed report (each line listed)',
  116. ),
  117. /*
  118. 'reportlevel' => array
  119. (
  120. 'mandatory' => false,
  121. 'modes' => 'http,cli',
  122. 'default' => 'errors|warnings|created|changed|unchanged',
  123. 'description' => 'combination of flags to limit the detailed output',
  124. ),
  125. */
  126. 'simulate' => array
  127. (
  128. 'mandatory' => false,
  129. 'modes' => 'http,cli',
  130. 'default' => '0',
  131. 'description' => 'If set to 1, then the load will not be executed, but the expected report will be produced',
  132. ),
  133. 'comment' => array
  134. (
  135. 'mandatory' => false,
  136. 'modes' => 'http,cli',
  137. 'default' => '',
  138. 'description' => 'Comment to be added into the change log',
  139. ),
  140. );
  141. function UsageAndExit($oP)
  142. {
  143. global $aPageParams;
  144. $bModeCLI = utils::IsModeCLI();
  145. $oP->p("USAGE:\n");
  146. foreach($aPageParams as $sParam => $aParamData)
  147. {
  148. $aModes = explode(',', $aParamData['modes']);
  149. if ($bModeCLI)
  150. {
  151. if (in_array('cli', $aModes))
  152. {
  153. $sDesc = $aParamData['description'].', '.($aParamData['mandatory'] ? 'mandatory' : 'optional, defaults to ['.$aParamData['default'].']');
  154. $oP->p("$sParam = $sDesc");
  155. }
  156. }
  157. else
  158. {
  159. if (in_array('http', $aModes))
  160. {
  161. $sDesc = $aParamData['description'].', '.($aParamData['mandatory'] ? 'mandatory' : 'optional, defaults to ['.$aParamData['default'].']');
  162. $oP->p("$sParam = $sDesc");
  163. }
  164. }
  165. }
  166. $oP->output();
  167. exit;
  168. }
  169. function ReadParam($oP, $sParam, $sSanitizationFilter = 'parameter')
  170. {
  171. global $aPageParams;
  172. assert(isset($aPageParams[$sParam]));
  173. assert(!$aPageParams[$sParam]['mandatory']);
  174. $sValue = utils::ReadParam($sParam, $aPageParams[$sParam]['default'], true /* Allow CLI */, $sSanitizationFilter);
  175. return trim($sValue);
  176. }
  177. function ReadMandatoryParam($oP, $sParam, $sSanitizationFilter)
  178. {
  179. global $aPageParams;
  180. assert(isset($aPageParams[$sParam]));
  181. assert($aPageParams[$sParam]['mandatory']);
  182. $sValue = utils::ReadParam($sParam, null, true /* Allow CLI */, $sSanitizationFilter);
  183. if (is_null($sValue))
  184. {
  185. $oP->p("ERROR: Missing argument '$sParam'\n");
  186. UsageAndExit($oP);
  187. }
  188. return trim($sValue);
  189. }
  190. function ChangeDateFormat($sProposedDate, $sDateFormat)
  191. {
  192. // Make sure this is a valid MySQL datetime
  193. $iTime = utils::StringToTime($sProposedDate, $sDateFormat);
  194. if ($iTime !== false)
  195. {
  196. $sDate = date('Y-m-d H:i:s', $iTime);
  197. return $sDate;
  198. }
  199. else
  200. {
  201. return false;
  202. }
  203. }
  204. /////////////////////////////////
  205. // Main program
  206. if (utils::IsModeCLI())
  207. {
  208. $oP = new CLIPage(Dict::S("TitleSynchroExecution"));
  209. }
  210. else
  211. {
  212. $oP = new WebPage(Dict::S("TitleSynchroExecution"));
  213. }
  214. try
  215. {
  216. utils::UseParamFile();
  217. }
  218. catch(Exception $e)
  219. {
  220. $oP->p("Error: ".$e->GetMessage());
  221. $oP->output();
  222. exit -2;
  223. }
  224. if (utils::IsModeCLI())
  225. {
  226. // Next steps:
  227. // specific arguments: 'csvfile'
  228. //
  229. $sAuthUser = ReadMandatoryParam($oP, 'auth_user', 'raw_data');
  230. $sAuthPwd = ReadMandatoryParam($oP, 'auth_pwd', 'raw_data');
  231. $sCsvFile = ReadMandatoryParam($oP, 'csvfile', 'raw_data');
  232. if (UserRights::CheckCredentials($sAuthUser, $sAuthPwd))
  233. {
  234. UserRights::Login($sAuthUser); // Login & set the user's language
  235. }
  236. else
  237. {
  238. $oP->p("Access restricted or wrong credentials ('$sAuthUser')");
  239. $oP->output();
  240. exit -1;
  241. }
  242. if (!is_readable($sCsvFile))
  243. {
  244. $oP->p("Input file could not be found or could not be read: '$sCsvFile'");
  245. $oP->output();
  246. exit -1;
  247. }
  248. $sCSVData = file_get_contents($sCsvFile);
  249. }
  250. else
  251. {
  252. $_SESSION['login_mode'] = 'basic';
  253. require_once(APPROOT.'/application/loginwebpage.class.inc.php');
  254. LoginWebPage::DoLogin(); // Check user rights and prompt if needed
  255. $sCSVData = utils::ReadPostedParam('csvdata', '', false, 'raw_data');
  256. }
  257. try
  258. {
  259. //////////////////////////////////////////////////
  260. //
  261. // Read parameters
  262. //
  263. $iDataSourceId = ReadMandatoryParam($oP, 'data_source_id');
  264. $sSynchronize = ReadParam($oP, 'synchronize');
  265. $sSep = ReadParam($oP, 'separator', 'raw_data');
  266. $sQualifier = ReadParam($oP, 'qualifier', 'raw_data');
  267. $sCharSet = ReadParam($oP, 'charset', 'raw_data');
  268. $sDateFormat = ReadParam($oP, 'date_format', 'raw_data');
  269. $sOutput = ReadParam($oP, 'output');
  270. // $sReportLevel = ReadParam($oP, 'reportlevel');
  271. $sSimulate = ReadParam($oP, 'simulate');
  272. $sComment = ReadParam($oP, 'comment', 'raw_data');
  273. $oLoadStartDate = new DateTime(); // Now
  274. // Note about date formatting: These MySQL settings are read-only... and in fact unused :-(
  275. // SET SESSION date_format = '%d/%m/%Y';
  276. // SET SESSION datetime_format = '%d/%m/%Y %H:%i:%s';
  277. // Therefore, we have to allow users to transform the format according to a given specification: date_format
  278. //////////////////////////////////////////////////
  279. //
  280. // Statistics
  281. //
  282. $iCountErrors = 0;
  283. $iCountCreations = 0;
  284. $iCountUpdates = 0;
  285. //////////////////////////////////////////////////
  286. //
  287. // Check parameters format/consistency
  288. //
  289. if (strlen($sCSVData) == 0)
  290. {
  291. throw new ExchangeException("Missing data - at least one line is expected");
  292. }
  293. $oDataSource = MetaModel::GetObject('SynchroDataSource', $iDataSourceId, false);
  294. if (is_null($oDataSource))
  295. {
  296. throw new ExchangeException("Unknown data source id: '$iDataSourceId'");
  297. }
  298. $sClass = $oDataSource->GetTargetClass();
  299. if (strlen($sSep) > 1)
  300. {
  301. throw new ExchangeException("Separator is limited to one character, found '$sSep'");
  302. }
  303. if (strlen($sQualifier) > 1)
  304. {
  305. throw new ExchangeException("Text qualifier is limited to one character, found '$sQualifier'");
  306. }
  307. if (!in_array($sOutput, array('retcode', 'summary', 'details')))
  308. {
  309. throw new ExchangeException("Unknown output format: '$sOutput'");
  310. }
  311. /*
  312. $aReportLevels = explode('|', $sReportLevel);
  313. foreach($aReportLevels as $sLevel)
  314. {
  315. if (!in_array($sLevel, explode('|', 'errors|warnings|created|changed|unchanged')))
  316. {
  317. throw new ExchangeException("Unknown level in reporting level: '$sLevel'");
  318. }
  319. }
  320. */
  321. if ($sSimulate == '1')
  322. {
  323. $bSimulate = true;
  324. }
  325. else
  326. {
  327. $bSimulate = false;
  328. }
  329. if ($sSynchronize == '1')
  330. {
  331. $bSynchronize = true;
  332. }
  333. else
  334. {
  335. $bSynchronize = false;
  336. }
  337. //////////////////////////////////////////////////
  338. //
  339. // Parse first line, check attributes, analyse the request
  340. //
  341. if ($sCharSet == 'UTF-8')
  342. {
  343. $sUTF8Data = $sCSVData;
  344. }
  345. else
  346. {
  347. $sUTF8Data = iconv($sCharSet, 'UTF-8//IGNORE//TRANSLIT', $sCSVData);
  348. }
  349. $oCSVParser = new CSVParser($sUTF8Data, $sSep, $sQualifier);
  350. $aInputColumns = $oCSVParser->ListFields();
  351. $iColCount = count($aInputColumns);
  352. // Check columns
  353. $aColumns = $oDataSource->GetSQLColumns();
  354. $aDateColumns = $oDataSource->GetDateSQLColumns();
  355. $aIsDateToTransform = array();
  356. $aDateToTransformReport = array();
  357. foreach($aInputColumns as $iFieldId => $sInputColumn)
  358. {
  359. if ((strlen($sDateFormat) > 0) && (array_key_exists($sInputColumn, $aDateColumns)))
  360. {
  361. $aIsDateToTransform[$iFieldId] = true;
  362. $aDateToTransformReport[] = $sInputColumn;
  363. }
  364. else
  365. {
  366. $aIsDateToTransform[$iFieldId] = false;
  367. }
  368. if ($sInputColumn == 'primary_key')
  369. {
  370. $iPrimaryKeyCol = $iFieldId;
  371. continue;
  372. }
  373. if (!array_key_exists($sInputColumn, $aColumns))
  374. {
  375. throw new ExchangeException("Unknown column '$sInputColumn' (class: '$sClass')");
  376. }
  377. }
  378. if (!isset($iPrimaryKeyCol))
  379. {
  380. throw new ExchangeException("Missing reconciliation column 'primary_key'");
  381. }
  382. //////////////////////////////////////////////////
  383. //
  384. // Go for parsing and interpretation
  385. //
  386. try
  387. {
  388. $oP->add_comment('Load--------------');
  389. $oP->add_comment('------------------');
  390. if ($bSimulate)
  391. {
  392. CMDBSource::Query('START TRANSACTION');
  393. }
  394. $aData = $oCSVParser->ToArray();
  395. $iLineCount = count($aData);
  396. $sTable = $oDataSource->GetDataTable();
  397. // Prepare insert columns
  398. $sInsertColumns = '`'.implode('`, `', $aInputColumns).'`';
  399. foreach($aData as $iRow => $aRow)
  400. {
  401. $sReconciliationCondition = "`primary_key` = ".CMDBSource::Quote($aRow[$iPrimaryKeyCol]);
  402. $sSelect = "SELECT COUNT(*) FROM `$sTable` WHERE $sReconciliationCondition";
  403. $aRes = CMDBSource::QueryToArray($sSelect);
  404. $iCount = $aRes[0]['COUNT(*)'];
  405. if ($iCount == 0)
  406. {
  407. // No record... create it
  408. //
  409. $iCountCreations++;
  410. if ($sOutput == 'details')
  411. {
  412. $oP->add("$iRow: New entry, reconciliation: '$sReconciliationCondition'\n");
  413. }
  414. $aValues = array(); // Used to build the insert query
  415. foreach ($aRow as $iCol => $value)
  416. {
  417. if (is_null($value))
  418. {
  419. $aValues[] = 'NULL';
  420. }
  421. elseif ($aIsDateToTransform[$iCol])
  422. {
  423. $sDate = ChangeDateFormat($value, $sDateFormat);
  424. if ($sDate === false)
  425. {
  426. $aValues[] = CMDBSource::Quote('');
  427. if ($sOutput == 'details')
  428. {
  429. $oP->add("$iRow: Wrong format for date field: '$value' (skipped column)\n");
  430. }
  431. }
  432. else
  433. {
  434. $aValues[] = CMDBSource::Quote($sDate);
  435. }
  436. }
  437. else
  438. {
  439. $aValues[] = CMDBSource::Quote($value);
  440. }
  441. }
  442. $sValues = implode(', ', $aValues);
  443. $sInsert = "INSERT INTO `$sTable` ($sInsertColumns) VALUES ($sValues)";
  444. CMDBSource::Query($sInsert);
  445. }
  446. elseif ($iCount == 1)
  447. {
  448. // Found a match... update it
  449. //
  450. $iCountUpdates++;
  451. if ($sOutput == 'details')
  452. {
  453. $oP->add("$iRow: Update entry, reconciliation: '$sReconciliationCondition'\n");
  454. }
  455. $aValuePairs = array(); // Used to build the update query
  456. foreach ($aRow as $iCol => $value)
  457. {
  458. // Skip reconciliation column
  459. if ($iCol == $iPrimaryKeyCol) continue;
  460. $sCol = $aInputColumns[$iCol];
  461. if ($aIsDateToTransform[$iCol])
  462. {
  463. $sDate = ChangeDateFormat($aRow[$iCol], $sDateFormat);
  464. if ($sDate === false)
  465. {
  466. // Skip this column spec
  467. if ($sOutput == 'details')
  468. {
  469. $oP->add("$iRow: Wrong format for date field: '".$aRow[$iCol]."' (skipped column)\n");
  470. }
  471. }
  472. else
  473. {
  474. $aValuePairs[] = "`$sCol` = ".CMDBSource::Quote($sDate);
  475. }
  476. }
  477. else
  478. {
  479. $aValuePairs[] = "`$sCol` = ".CMDBSource::Quote($aRow[$iCol]);
  480. }
  481. }
  482. $sValuePairs = implode(', ', $aValuePairs);
  483. $sUpdateQuery = "UPDATE `$sTable` SET $sValuePairs WHERE $sReconciliationCondition";
  484. CMDBSource::Query($sUpdateQuery);
  485. }
  486. else
  487. {
  488. // Too many records... ambiguity
  489. //
  490. $iCountErrors++;
  491. $oP->add("$iRow: Error - Failed to reconcile, found $iCount rows having '$sReconciliationCondition'\n");
  492. }
  493. }
  494. if (($sOutput == "summary") || ($sOutput == 'details'))
  495. {
  496. $oP->add_comment("Data Source: ".$iDataSourceId);
  497. $oP->add_comment("Synchronize: ".($bSynchronize ? '1' : '0'));
  498. $oP->add_comment("Class: ".$sClass);
  499. $oP->add_comment("Separator: ".$sSep);
  500. $oP->add_comment("Qualifier: ".$sQualifier);
  501. $oP->add_comment("Charset Encoding:".$sCharSet);
  502. if (strlen($sDateFormat) > 0)
  503. {
  504. $oP->add_comment("Date format: '$sDateFormat', applied to columns {".implode(', ', $aDateToTransformReport)."}");
  505. }
  506. else
  507. {
  508. $oP->add_comment("Date format: <none>");
  509. }
  510. $oP->add_comment("Data Size: ".strlen($sCSVData));
  511. $oP->add_comment("Data Lines: ".$iLineCount);
  512. $oP->add_comment("Columns: ".implode(', ', $aInputColumns));
  513. $oP->add_comment("Output format: ".$sOutput);
  514. // $oP->add_comment("Report level: ".$sReportLevel);
  515. $oP->add_comment("Simulate: ".($bSimulate ? '1' : '0'));
  516. $oP->add_comment("Change tracking comment: ".$sComment);
  517. $oP->add_comment("Issues (before synchro): ".$iCountErrors);
  518. // $oP->add_comment("Warnings: ".$iCountWarnings);
  519. $oP->add_comment("Created (before synchro): ".$iCountCreations);
  520. $oP->add_comment("Updated (before synchro): ".$iCountUpdates);
  521. }
  522. //////////////////////////////////////////////////
  523. //
  524. // Synchronize
  525. //
  526. if ($bSynchronize)
  527. {
  528. $oStatLog = $oDataSource->Synchronize($oLoadStartDate);
  529. $oP->add_comment('Synchronization---');
  530. $oP->add_comment('------------------');
  531. if ($sOutput == 'details')
  532. {
  533. foreach ($oStatLog->GetTraces() as $sMessage)
  534. {
  535. $oP->add_comment($sMessage);
  536. }
  537. }
  538. if ($oStatLog->Get('status') == 'error')
  539. {
  540. $oP->p("ERROR: ".$oStatLog->Get('last_error'));
  541. }
  542. $oP->add_comment("Replicas: ".$oStatLog->Get('stats_nb_replica_total'));
  543. $oP->add_comment("Replicas touched since last synchro: ".$oStatLog->Get('stats_nb_replica_seen'));
  544. $oP->add_comment("Objects deleted: ".$oStatLog->Get('stats_nb_obj_deleted'));
  545. $oP->add_comment("Objects deletion errors: ".$oStatLog->Get('stats_nb_obj_deleted_errors'));
  546. $oP->add_comment("Objects obsoleted: ".$oStatLog->Get('stats_nb_obj_obsoleted'));
  547. $oP->add_comment("Objects obsolescence errors: ".$oStatLog->Get('stats_nb_obj_obsoleted_errors'));
  548. $oP->add_comment("Objects created: ".$oStatLog->Get('stats_nb_obj_created'));
  549. $oP->add_comment("Objects creation errors: ".$oStatLog->Get('stats_nb_obj_created_errors'));
  550. $oP->add_comment("Objects updated: ".$oStatLog->Get('stats_nb_obj_updated'));
  551. $oP->add_comment("Objects update errors: ".$oStatLog->Get('stats_nb_obj_updated_errors'));
  552. $oP->add_comment("Objects reconciled (updated): ".$oStatLog->Get('stats_nb_obj_new_updated'));
  553. $oP->add_comment("Objects reconciled (unchanged): ".$oStatLog->Get('stats_nb_obj_new_unchanged'));
  554. $oP->add_comment("Objects reconciliation errors: ".$oStatLog->Get('stats_nb_replica_reconciled_errors'));
  555. $oP->add_comment("Replica disappeared, no action taken: ".$oStatLog->Get('stats_nb_replica_disappeared_no_action'));
  556. }
  557. }
  558. catch(Exception $e)
  559. {
  560. if ($bSimulate)
  561. {
  562. CMDBSource::Query('ROLLBACK');
  563. }
  564. throw $e;
  565. }
  566. if ($bSimulate)
  567. {
  568. CMDBSource::Query('ROLLBACK');
  569. }
  570. //////////////////////////////////////////////////
  571. //
  572. // Summary of settings and results
  573. //
  574. if ($sOutput == 'retcode')
  575. {
  576. $oP->add($iCountErrors);
  577. }
  578. }
  579. catch(ExchangeException $e)
  580. {
  581. $oP->add_comment($e->getMessage());
  582. }
  583. catch(SecurityException $e)
  584. {
  585. $oP->add_comment($e->getMessage());
  586. }
  587. catch(Exception $e)
  588. {
  589. $oP->add_comment((string)$e);
  590. }
  591. $oP->output();
  592. ?>