import.php 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825
  1. <?php
  2. // Copyright (C) 2010 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. * Import 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 first column
  27. //
  28. // Known issues
  29. // - ALMOST impossible to troubleshoot when an externl key has a wrong value
  30. // - no character escaping in the xml output (yes !?!?!)
  31. // - not outputing xml when a wrong input is given (class, attribute names)
  32. //
  33. if (!defined('__DIR__')) define('__DIR__', dirname(__FILE__));
  34. require_once(__DIR__.'/../approot.inc.php');
  35. require_once(APPROOT.'/application/application.inc.php');
  36. require_once(APPROOT.'/application/webpage.class.inc.php');
  37. require_once(APPROOT.'/application/csvpage.class.inc.php');
  38. require_once(APPROOT.'/application/clipage.class.inc.php');
  39. require_once(APPROOT.'/application/startup.inc.php');
  40. class BulkLoadException extends Exception
  41. {
  42. }
  43. $aPageParams = array
  44. (
  45. 'auth_user' => array
  46. (
  47. 'mandatory' => true,
  48. 'modes' => 'cli',
  49. 'default' => null,
  50. 'description' => 'login (must have enough rights to create objects of the given class)',
  51. ),
  52. 'auth_pwd' => array
  53. (
  54. 'mandatory' => true,
  55. 'modes' => 'cli',
  56. 'default' => null,
  57. 'description' => 'password',
  58. ),
  59. 'class' => array
  60. (
  61. 'mandatory' => true,
  62. 'modes' => 'http,cli',
  63. 'default' => null,
  64. 'description' => 'class of loaded objects',
  65. ),
  66. 'csvdata' => array
  67. (
  68. 'mandatory' => true,
  69. 'modes' => 'http',
  70. 'default' => null,
  71. 'description' => 'data',
  72. ),
  73. 'csvfile' => array
  74. (
  75. 'mandatory' => true,
  76. 'modes' => 'cli',
  77. 'default' => '',
  78. 'description' => 'local data file, replaces csvdata if specified',
  79. ),
  80. 'charset' => array
  81. (
  82. 'mandatory' => false,
  83. 'modes' => 'http,cli',
  84. 'default' => 'UTF-8',
  85. 'description' => 'Character set encoding of the CSV data: UTF-8, ISO-8859-1, WINDOWS-1251, WINDOWS-1252, ISO-8859-15',
  86. ),
  87. 'date_format' => array
  88. (
  89. 'mandatory' => false,
  90. 'modes' => 'http,cli',
  91. 'default' => '',
  92. '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',
  93. ),
  94. 'separator' => array
  95. (
  96. 'mandatory' => false,
  97. 'modes' => 'http,cli',
  98. 'default' => ',',
  99. 'description' => 'column separator in CSV data (1 char, or \'tab\')',
  100. ),
  101. 'qualifier' => array
  102. (
  103. 'mandatory' => false,
  104. 'modes' => 'http,cli',
  105. 'default' => '"',
  106. 'description' => 'test qualifier in CSV data',
  107. ),
  108. 'output' => array
  109. (
  110. 'mandatory' => false,
  111. 'modes' => 'http,cli',
  112. 'default' => 'summary',
  113. '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)',
  114. ),
  115. /*
  116. 'reportlevel' => array
  117. (
  118. 'mandatory' => false,
  119. 'modes' => 'http,cli',
  120. 'default' => 'errors|warnings|created|changed|unchanged',
  121. 'description' => 'combination of flags to limit the detailed output',
  122. ),
  123. */
  124. 'reconciliationkeys' => array
  125. (
  126. 'mandatory' => false,
  127. 'modes' => 'http,cli',
  128. 'default' => '',
  129. 'description' => 'name of the columns used to identify existing objects and update them, or create a new one',
  130. ),
  131. 'simulate' => array
  132. (
  133. 'mandatory' => false,
  134. 'modes' => 'http,cli',
  135. 'default' => '0',
  136. 'description' => 'If set to 1, then the load will not be executed, but the expected report will be produced',
  137. ),
  138. 'comment' => array
  139. (
  140. 'mandatory' => false,
  141. 'modes' => 'http,cli',
  142. 'default' => '',
  143. 'description' => 'Comment to be added into the change log',
  144. ),
  145. );
  146. function UsageAndExit($oP)
  147. {
  148. global $aPageParams;
  149. $bModeCLI = utils::IsModeCLI();
  150. $oP->p("USAGE:\n");
  151. foreach($aPageParams as $sParam => $aParamData)
  152. {
  153. $aModes = explode(',', $aParamData['modes']);
  154. if ($bModeCLI)
  155. {
  156. if (in_array('cli', $aModes))
  157. {
  158. $sDesc = $aParamData['description'].', '.($aParamData['mandatory'] ? 'mandatory' : 'optional, defaults to ['.$aParamData['default'].']');
  159. $oP->p("$sParam = $sDesc");
  160. }
  161. }
  162. else
  163. {
  164. if (in_array('http', $aModes))
  165. {
  166. $sDesc = $aParamData['description'].', '.($aParamData['mandatory'] ? 'mandatory' : 'optional, defaults to ['.$aParamData['default'].']');
  167. $oP->p("$sParam = $sDesc");
  168. }
  169. }
  170. }
  171. $oP->output();
  172. exit;
  173. }
  174. function ReadParam($oP, $sParam, $sSanitizationFilter = 'parameter')
  175. {
  176. global $aPageParams;
  177. assert(isset($aPageParams[$sParam]));
  178. assert(!$aPageParams[$sParam]['mandatory']);
  179. $sValue = utils::ReadParam($sParam, $aPageParams[$sParam]['default'], true /* Allow CLI */, $sSanitizationFilter);
  180. return trim($sValue);
  181. }
  182. function ReadMandatoryParam($oP, $sParam, $sSanitizationFilter)
  183. {
  184. global $aPageParams;
  185. assert(isset($aPageParams[$sParam]));
  186. assert($aPageParams[$sParam]['mandatory']);
  187. $sValue = utils::ReadParam($sParam, null, true /* Allow CLI */, $sSanitizationFilter);
  188. if (is_null($sValue))
  189. {
  190. $oP->p("ERROR: Missing argument '$sParam'\n");
  191. UsageAndExit($oP);
  192. }
  193. return trim($sValue);
  194. }
  195. /////////////////////////////////
  196. // Main program
  197. if (utils::IsModeCLI())
  198. {
  199. $oP = new CLIPage("iTop - Bulk import");
  200. }
  201. else
  202. {
  203. $oP = new CSVPage("iTop - Bulk import");
  204. }
  205. try
  206. {
  207. utils::UseParamFile();
  208. }
  209. catch(Exception $e)
  210. {
  211. $oP->p("Error: ".$e->GetMessage());
  212. $oP->output();
  213. exit -2;
  214. }
  215. if (utils::IsModeCLI())
  216. {
  217. // Next steps:
  218. // specific arguments: 'csvfile'
  219. //
  220. $sAuthUser = ReadMandatoryParam($oP, 'auth_user', 'raw_data');
  221. $sAuthPwd = ReadMandatoryParam($oP, 'auth_pwd', 'raw_data');
  222. $sCsvFile = ReadMandatoryParam($oP, 'csvfile', 'raw_data');
  223. if (UserRights::CheckCredentials($sAuthUser, $sAuthPwd))
  224. {
  225. UserRights::Login($sAuthUser); // Login & set the user's language
  226. }
  227. else
  228. {
  229. $oP->p("Access restricted or wrong credentials ('$sAuthUser')");
  230. $oP->output();
  231. exit -1;
  232. }
  233. if (!is_readable($sCsvFile))
  234. {
  235. $oP->p("Input file could not be found or could not be read: '$sCsvFile'");
  236. $oP->output();
  237. exit -1;
  238. }
  239. $sCSVData = file_get_contents($sCsvFile);
  240. }
  241. else
  242. {
  243. $_SESSION['login_mode'] = 'basic';
  244. require_once(APPROOT.'/application/loginwebpage.class.inc.php');
  245. LoginWebPage::DoLogin(); // Check user rights and prompt if needed
  246. $sCSVData = utils::ReadPostedParam('csvdata', '', 'raw_data');
  247. }
  248. try
  249. {
  250. //////////////////////////////////////////////////
  251. //
  252. // Read parameters
  253. //
  254. $sClass = ReadMandatoryParam($oP, 'class', 'class');
  255. $sSep = ReadParam($oP, 'separator', 'raw_data');
  256. $sQualifier = ReadParam($oP, 'qualifier', 'raw_data');
  257. $sCharSet = ReadParam($oP, 'charset', 'raw_data');
  258. $sDateFormat = ReadParam($oP, 'date_format', 'raw_data');
  259. $sOutput = ReadParam($oP, 'output', 'string');
  260. // $sReportLevel = ReadParam($oP, 'reportlevel');
  261. $sReconcKeys = ReadParam($oP, 'reconciliationkeys', 'raw_data');
  262. $sSimulate = ReadParam($oP, 'simulate');
  263. $sComment = ReadParam($oP, 'comment', 'raw_data');
  264. if (strtolower(trim($sSep)) == 'tab')
  265. {
  266. $sSep = "\t";
  267. }
  268. //////////////////////////////////////////////////
  269. //
  270. // Check parameters format/consistency
  271. //
  272. if (strlen($sCSVData) == 0)
  273. {
  274. throw new ExchangeException("Missing data - at least one line is expected");
  275. }
  276. if (!MetaModel::IsValidClass($sClass))
  277. {
  278. throw new BulkLoadException("Unknown class: '$sClass'");
  279. }
  280. if (strlen($sSep) > 1)
  281. {
  282. throw new BulkLoadException("Separator is limited to one character, found '$sSep'");
  283. }
  284. if (strlen($sQualifier) > 1)
  285. {
  286. throw new BulkLoadException("Text qualifier is limited to one character, found '$sQualifier'");
  287. }
  288. if (!in_array($sOutput, array('retcode', 'summary', 'details')))
  289. {
  290. throw new BulkLoadException("Unknown output format: '$sOutput'");
  291. }
  292. if (strlen($sDateFormat) == 0)
  293. {
  294. $sDateFormat = null;
  295. }
  296. /*
  297. $aReportLevels = explode('|', $sReportLevel);
  298. foreach($aReportLevels as $sLevel)
  299. {
  300. if (!in_array($sLevel, explode('|', 'errors|warnings|created|changed|unchanged')))
  301. {
  302. throw new BulkLoadException("Unknown level in reporting level: '$sLevel'");
  303. }
  304. }
  305. */
  306. if ($sSimulate == '1')
  307. {
  308. $bSimulate = true;
  309. }
  310. else
  311. {
  312. $bSimulate = false;
  313. }
  314. if (($sOutput == "summary") || ($sOutput == 'details'))
  315. {
  316. $oP->add_comment("Output format: ".$sOutput);
  317. $oP->add_comment("Class: ".$sClass);
  318. $oP->add_comment("Separator: ".$sSep);
  319. $oP->add_comment("Qualifier: ".$sQualifier);
  320. $oP->add_comment("Charset Encoding:".$sCharSet);
  321. if (strlen($sDateFormat) > 0)
  322. {
  323. $oP->add_comment("Date format: '$sDateFormat'");
  324. }
  325. else
  326. {
  327. $oP->add_comment("Date format: <none>");
  328. }
  329. $oP->add_comment("Data Size: ".strlen($sCSVData));
  330. }
  331. //////////////////////////////////////////////////
  332. //
  333. // Security
  334. //
  335. if (!UserRights::IsActionAllowed($sClass, UR_ACTION_BULK_MODIFY))
  336. {
  337. throw new SecurityException(Dict::Format('UI:Error:BulkModifyNotAllowedOn_Class', $sClass));
  338. }
  339. //////////////////////////////////////////////////
  340. //
  341. // Make translated column reference
  342. //
  343. // array of <LowercaseTranslatedName> => <ExtendedAttCode>
  344. //
  345. // Examples:
  346. // 'organization' => 'org_id'
  347. // 'organization->name' => 'org_id->name'
  348. //
  349. // Note: it may happen that an external field has the same label as the external key
  350. // in that case, we consider that the external key has precedence
  351. //
  352. $aFriendlyToInternalAttCode = array();
  353. foreach(MetaModel::ListAttributeDefs($sClass) as $sAttCode => $oAttDef)
  354. {
  355. $sFriendlyName = strtolower(BulkChange::GetFriendlyAttCodeName($sClass, $sAttCode));
  356. if (!$oAttDef->IsExternalField() || !array_key_exists($sFriendlyName, $aFriendlyToInternalAttCode))
  357. {
  358. $aFriendlyToInternalAttCode[$sFriendlyName] = $sAttCode;
  359. }
  360. if ($oAttDef->IsExternalKey(EXTKEY_RELATIVE))
  361. {
  362. $sRemoteClass = $oAttDef->GetTargetClass();
  363. foreach(MetaModel::ListAttributeDefs($sRemoteClass) as $sRemoteAttCode => $oRemoteAttDef)
  364. {
  365. $sAttCodeEx = $sAttCode.'->'.$sRemoteAttCode;
  366. $sFriendlyName = strtolower(BulkChange::GetFriendlyAttCodeName($sClass, $sAttCodeEx));
  367. if (!array_key_exists($sFriendlyName, $aFriendlyToInternalAttCode))
  368. {
  369. $aFriendlyToInternalAttCode[$sFriendlyName] = $sAttCodeEx;
  370. }
  371. }
  372. }
  373. }
  374. //////////////////////////////////////////////////
  375. //
  376. // Parse first line, check attributes, analyse the request
  377. //
  378. if ($sCharSet == 'UTF-8')
  379. {
  380. $sUTF8Data = $sCSVData;
  381. }
  382. else
  383. {
  384. $sUTF8Data = iconv($sCharSet, 'UTF-8//IGNORE//TRANSLIT', $sCSVData);
  385. }
  386. $oCSVParser = new CSVParser($sUTF8Data, $sSep, $sQualifier);
  387. // Limitation: as the attribute list is in the first line, we can not match external key by a third-party attribute
  388. $aRawFieldList = $oCSVParser->ListFields();
  389. $iColCount = count($aRawFieldList);
  390. // Translate into internal names
  391. $aFieldList = array();
  392. foreach($aRawFieldList as $iFieldId => $sFieldName)
  393. {
  394. $sFieldName = trim($sFieldName);
  395. $aMatches = array();
  396. if (preg_match('/^(.+)\*$/', $sFieldName, $aMatches))
  397. {
  398. // Ignore any trailing "star" (*) that simply indicates a mandatory field
  399. $sFieldName = $aMatches[1];
  400. }
  401. if (array_key_exists(strtolower($sFieldName), $aFriendlyToInternalAttCode))
  402. {
  403. $aFieldList[$iFieldId] = $aFriendlyToInternalAttCode[strtolower($sFieldName)];
  404. }
  405. else
  406. {
  407. // Secure the field names against XSS injection (no <> neither " chars)
  408. $sSafeName = str_replace(array('"', '<', '>'), '', $sFieldName);
  409. $aFieldList[$iFieldId] = $sSafeName;
  410. }
  411. }
  412. // Note: at this stage the list of fields is supposed to be made of attcodes (and the symbol '->')
  413. $aAttList = array();
  414. $aExtKeys = array();
  415. foreach($aFieldList as $iFieldId => $sFieldName)
  416. {
  417. $aMatches = array();
  418. if (preg_match('/^(.+)->(.+)$/', trim($sFieldName), $aMatches))
  419. {
  420. // The column has been specified as "extkey->attcode"
  421. //
  422. $sExtKeyAttCode = $aMatches[1];
  423. $sRemoteAttCode = $aMatches[2];
  424. if (!MetaModel::IsValidAttCode($sClass, $sExtKeyAttCode))
  425. {
  426. throw new BulkLoadException("Unknown attribute '$sExtKeyAttCode' (class: '$sClass')");
  427. }
  428. $oAtt = MetaModel::GetAttributeDef($sClass, $sExtKeyAttCode);
  429. if (!$oAtt->IsExternalKey())
  430. {
  431. throw new BulkLoadException("Not an external key '$sExtKeyAttCode' (class: '$sClass')");
  432. }
  433. $sTargetClass = $oAtt->GetTargetClass();
  434. if (!MetaModel::IsValidAttCode($sTargetClass, $sRemoteAttCode))
  435. {
  436. throw new BulkLoadException("Unknown attribute '$sRemoteAttCode' (key: '$sExtKeyAttCode', class: '$sTargetClass')");
  437. }
  438. $aExtKeys[$sExtKeyAttCode][$sRemoteAttCode] = $iFieldId;
  439. }
  440. elseif ($sFieldName == 'id')
  441. {
  442. $aAttList[$sFieldName] = $iFieldId;
  443. }
  444. else
  445. {
  446. // The column has been specified as "attcode"
  447. //
  448. if (!MetaModel::IsValidAttCode($sClass, $sFieldName))
  449. {
  450. throw new BulkLoadException("Unknown attribute '$sFieldName' (class: '$sClass')");
  451. }
  452. $oAtt = MetaModel::GetAttributeDef($sClass, $sFieldName);
  453. if ($oAtt->IsExternalKey())
  454. {
  455. $aExtKeys[$sFieldName]['id'] = $iFieldId;
  456. $aAttList[$sFieldName] = $iFieldId;
  457. }
  458. elseif ($oAtt->IsExternalField())
  459. {
  460. $sExtKeyAttCode = $oAtt->GetKeyAttCode();
  461. $sRemoteAttCode = $oAtt->GetExtAttCode();
  462. $aExtKeys[$sExtKeyAttCode][$sRemoteAttCode] = $iFieldId;
  463. }
  464. else
  465. {
  466. $aAttList[$sFieldName] = $iFieldId;
  467. }
  468. }
  469. }
  470. // Make sure there are some reconciliation keys
  471. //
  472. if (empty($sReconcKeys))
  473. {
  474. $aReconcSpec = array();
  475. // Base reconciliation scheme on the default one
  476. // The reconciliation attributes not present in the data will be ignored
  477. foreach(MetaModel::GetReconcKeys($sClass) as $sReconcKeyAttCode)
  478. {
  479. if (in_array($sReconcKeyAttCode, $aFieldList))
  480. {
  481. $aReconcSpec[] = $sReconcKeyAttCode;
  482. }
  483. }
  484. if (count($aReconcSpec) == 0)
  485. {
  486. throw new BulkLoadException("No reconciliation scheme could be defined, please add a column corresponding to one defined reconciliation key (class: '$sClass', reconciliation:".implode(',', MetaModel::GetReconcKeys($sClass)).")");
  487. }
  488. $sReconcKeys = implode(',', $aReconcSpec);
  489. }
  490. // Interpret the list of reconciliation keys
  491. //
  492. $aFinalReconcilKeys = array();
  493. $aReconcilKeysReport = array();
  494. foreach (explode(',', $sReconcKeys) as $sReconcKey)
  495. {
  496. $sReconcKey = trim($sReconcKey);
  497. if (empty($sReconcKey)) continue; // skip empty spec
  498. if (array_key_exists(strtolower($sReconcKey), $aFriendlyToInternalAttCode))
  499. {
  500. // Translate from a translated name to codes
  501. $sReconcKey = $aFriendlyToInternalAttCode[strtolower($sReconcKey)];
  502. }
  503. // Check that the reconciliation key is either a given column, or an external key
  504. if (!in_array($sReconcKey, $aFieldList))
  505. {
  506. if (!array_key_exists($sReconcKey, $aExtKeys))
  507. {
  508. // Protect against XSS injection
  509. $sSafeName = str_replace(array('"', '<', '>'), '', $sReconcKey);
  510. throw new BulkLoadException("Reconciliation key not found in the input columns: '$sSafeName'");
  511. }
  512. }
  513. if (preg_match('/^(.+)->(.+)$/', trim($sReconcKey), $aMatches))
  514. {
  515. // The column has been specified as "extkey->attcode"
  516. //
  517. $sExtKeyAttCode = $aMatches[1];
  518. $sRemoteAttCode = $aMatches[2];
  519. $aFinalReconcilKeys[] = $sExtKeyAttCode;
  520. $aReconcilKeysReport[$sExtKeyAttCode][] = $sRemoteAttCode;
  521. }
  522. else
  523. {
  524. if (!MetaModel::IsValidAttCode($sClass, $sReconcKey))
  525. {
  526. // Safety net: should never happen, but...
  527. throw new BulkLoadException("Unknown reconciliation attribute '$sReconcKey' (class: '$sClass')");
  528. }
  529. $oAtt = MetaModel::GetAttributeDef($sClass, $sReconcKey);
  530. if ($oAtt->IsExternalKey())
  531. {
  532. $aFinalReconcilKeys[] = $sReconcKey;
  533. $aReconcilKeysReport[$sReconcKey][] = 'id';
  534. }
  535. elseif ($oAtt->IsExternalField())
  536. {
  537. $sReconcAttCode = $oAtt->GetKeyAttCode();
  538. $sReconcKeyReport = "$sReconcAttCode ($sReconcKey)";
  539. $aFinalReconcilKeys[] = $sReconcAttCode;
  540. $aReconcilKeysReport[$sReconcAttCode][] = $sReconcKeyReport;
  541. }
  542. else
  543. {
  544. $aFinalReconcilKeys[] = $sReconcKey;
  545. $aReconcilKeysReport[$sReconcKey] = array();
  546. }
  547. }
  548. }
  549. //////////////////////////////////////////////////
  550. //
  551. // Go for parsing and interpretation
  552. //
  553. $aData = $oCSVParser->ToArray();
  554. $iLineCount = count($aData);
  555. if (($sOutput == "summary") || ($sOutput == 'details'))
  556. {
  557. $oP->add_comment("Data Lines: ".$iLineCount);
  558. $oP->add_comment("Simulate: ".($bSimulate ? '1' : '0'));
  559. $oP->add_comment("Columns: ".implode(', ', $aFieldList));
  560. $aReconciliationReport = array();
  561. foreach($aReconcilKeysReport as $sKey => $aKeyDetails)
  562. {
  563. if (count($aKeyDetails) > 0)
  564. {
  565. $aReconciliationReport[] = $sKey.' ('.implode(',', $aKeyDetails).')';
  566. }
  567. else
  568. {
  569. $aReconciliationReport[] = $sKey;
  570. }
  571. }
  572. $oP->add_comment("Reconciliation Keys: ".implode(', ', $aReconciliationReport));
  573. }
  574. $oBulk = new BulkChange(
  575. $sClass,
  576. $aData,
  577. $aAttList,
  578. $aExtKeys,
  579. $aFinalReconcilKeys,
  580. null, // synchro scope
  581. null, // on delete
  582. $sDateFormat
  583. );
  584. if ($bSimulate)
  585. {
  586. $oMyChange = null;
  587. }
  588. else
  589. {
  590. $oMyChange = MetaModel::NewObject("CMDBChange");
  591. $oMyChange->Set("date", time());
  592. $sUserString = CMDBChange::GetCurrentUserName();
  593. if (strlen($sComment) > 0)
  594. {
  595. $sMoreInfo = 'Web Service (CSV) - '.$sComment;
  596. }
  597. else
  598. {
  599. $sMoreInfo = 'Web Service (CSV)';
  600. }
  601. $oMyChange->Set("userinfo", $sUserString.', '.$sMoreInfo);
  602. $iChangeId = $oMyChange->DBInsert();
  603. }
  604. $aRes = $oBulk->Process($oMyChange);
  605. //////////////////////////////////////////////////
  606. //
  607. // Compute statistics
  608. //
  609. $iCountErrors = 0;
  610. $iCountWarnings = 0;
  611. $iCountCreations = 0;
  612. $iCountUpdates = 0;
  613. $iCountUnchanged = 0;
  614. foreach($aRes as $iRow => $aRowData)
  615. {
  616. $bWritten = false;
  617. $oStatus = $aRowData["__STATUS__"];
  618. switch(get_class($oStatus))
  619. {
  620. case 'RowStatus_NoChange':
  621. $iCountUnchanged++;
  622. break;
  623. case 'RowStatus_Modify':
  624. $iCountUpdates++;
  625. $bWritten = true;
  626. break;
  627. case 'RowStatus_NewObj':
  628. $iCountCreations++;
  629. $bWritten = true;
  630. break;
  631. case 'RowStatus_Issue':
  632. $iCountErrors++;
  633. break;
  634. }
  635. if ($bWritten)
  636. {
  637. // Something has been done, still there may be some issues to report
  638. foreach($aRowData as $key => $value)
  639. {
  640. if (!is_object($value)) continue;
  641. switch (get_class($value))
  642. {
  643. case 'CellStatus_Void':
  644. case 'CellStatus_Modify':
  645. break;
  646. case 'CellStatus_Issue':
  647. case 'CellStatus_SearchIssue':
  648. case 'CellStatus_NullIssue':
  649. case 'CellStatus_Ambiguous':
  650. $iCountWarnings++;
  651. break;
  652. }
  653. }
  654. }
  655. }
  656. //////////////////////////////////////////////////
  657. //
  658. // Summary of settings and results
  659. //
  660. if ($sOutput == 'retcode')
  661. {
  662. $oP->add($iCountErrors);
  663. }
  664. if (($sOutput == "summary") || ($sOutput == 'details'))
  665. {
  666. // $oP->add_comment("Report level: ".$sReportLevel);
  667. $oP->add_comment("Change tracking comment: ".$sComment);
  668. $oP->add_comment("Issues: ".$iCountErrors);
  669. $oP->add_comment("Warnings: ".$iCountWarnings);
  670. $oP->add_comment("Created: ".$iCountCreations);
  671. $oP->add_comment("Updated: ".$iCountUpdates);
  672. $oP->add_comment("Unchanged: ".$iCountUnchanged);
  673. }
  674. if ($sOutput == 'details')
  675. {
  676. // Setup result presentation
  677. //
  678. $aDisplayConfig = array();
  679. $aDisplayConfig["__LINE__"] = array("label"=>"Line", "description"=>"");
  680. $aDisplayConfig["__STATUS__"] = array("label"=>"Status", "description"=>"");
  681. $aDisplayConfig["__OBJECT_CLASS__"] = array("label"=>"Object Class", "description"=>"");
  682. $aDisplayConfig["__OBJECT_ID__"] = array("label"=>"Object Id", "description"=>"");
  683. foreach($aExtKeys as $sExtKeyAttCode => $aRemoteAtt)
  684. {
  685. $sLabel = MetaModel::GetAttributeDef($sClass, $sExtKeyAttCode)->GetLabel();
  686. $aDisplayConfig["$sExtKeyAttCode"] = array("label"=>$sExtKeyAttCode, "description"=>$sLabel." - ext key");
  687. }
  688. foreach($aFinalReconcilKeys as $iCol => $sAttCode)
  689. {
  690. // $sLabel = MetaModel::GetAttributeDef($sClass, $sAttCode)->GetLabel();
  691. // $aDisplayConfig["$iCol"] = array("label"=>"$sLabel", "description"=>"");
  692. }
  693. foreach ($aAttList as $sAttCode => $iCol)
  694. {
  695. if ($sAttCode == 'id')
  696. {
  697. $sLabel = Dict::S('UI:CSVImport:idField');
  698. $aDisplayConfig["$iCol"] = array("label"=>$sAttCode, "description"=>$sLabel);
  699. }
  700. else
  701. {
  702. $sLabel = MetaModel::GetAttributeDef($sClass, $sAttCode)->GetLabel();
  703. $aDisplayConfig["$iCol"] = array("label"=>$sAttCode, "description"=>$sLabel);
  704. }
  705. }
  706. $aResultDisp = array(); // to be displayed
  707. foreach($aRes as $iRow => $aRowData)
  708. {
  709. $aRowDisp = array();
  710. $aRowDisp["__LINE__"] = $iRow;
  711. if (is_object($aRowData["__STATUS__"]))
  712. {
  713. $aRowDisp["__STATUS__"] = $aRowData["__STATUS__"]->GetDescription();
  714. }
  715. else
  716. {
  717. $aRowDisp["__STATUS__"] = "*No status available*";
  718. }
  719. if (isset($aRowData["finalclass"]) && isset($aRowData["id"]))
  720. {
  721. $aRowDisp["__OBJECT_CLASS__"] = $aRowData["finalclass"];
  722. $aRowDisp["__OBJECT_ID__"] = $aRowData["id"]->GetDisplayableValue();
  723. }
  724. else
  725. {
  726. $aRowDisp["__OBJECT_CLASS__"] = "n/a";
  727. $aRowDisp["__OBJECT_ID__"] = "n/a";
  728. }
  729. foreach($aRowData as $key => $value)
  730. {
  731. $sKey = (string) $key;
  732. if ($sKey == '__STATUS__') continue;
  733. if ($sKey == 'finalclass') continue;
  734. if ($sKey == 'id') continue;
  735. if (is_object($value))
  736. {
  737. $aRowDisp["$sKey"] = $value->GetDisplayableValue().$value->GetDescription();
  738. }
  739. else
  740. {
  741. $aRowDisp["$sKey"] = $value;
  742. }
  743. }
  744. $aResultDisp[$iRow] = $aRowDisp;
  745. }
  746. $oP->table($aDisplayConfig, $aResultDisp);
  747. }
  748. }
  749. catch(BulkLoadException $e)
  750. {
  751. $oP->add_comment($e->getMessage());
  752. }
  753. catch(SecurityException $e)
  754. {
  755. $oP->add_comment($e->getMessage());
  756. }
  757. catch(Exception $e)
  758. {
  759. $oP->add_comment((string)$e);
  760. }
  761. $oP->output();
  762. ?>