TranslateBehavior.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574
  1. <?php
  2. /**
  3. * CakePHP(tm) : Rapid Development Framework (http://cakephp.org)
  4. * Copyright 2005-2011, Cake Software Foundation, Inc. (http://cakefoundation.org)
  5. *
  6. * Licensed under The MIT License
  7. * Redistributions of files must retain the above copyright notice.
  8. *
  9. * @copyright Copyright 2005-2011, Cake Software Foundation, Inc. (http://cakefoundation.org)
  10. * @link http://cakephp.org CakePHP(tm) Project
  11. * @package Cake.Model.Behavior
  12. * @since CakePHP(tm) v 1.2.0.4525
  13. * @license MIT License (http://www.opensource.org/licenses/mit-license.php)
  14. */
  15. App::uses('I18n', 'I18n');
  16. App::uses('I18nModel', 'Model');
  17. /**
  18. * Translate behavior
  19. *
  20. * @package Cake.Model.Behavior
  21. * @link http://book.cakephp.org/2.0/en/core-libraries/behaviors/translate.html
  22. */
  23. class TranslateBehavior extends ModelBehavior {
  24. /**
  25. * Used for runtime configuration of model
  26. *
  27. * @var array
  28. */
  29. public $runtime = array();
  30. /**
  31. * Stores the joinTable object for generating joins.
  32. *
  33. * @var object
  34. */
  35. protected $_joinTable;
  36. /**
  37. * Stores the runtime model for generating joins.
  38. *
  39. * @var Model
  40. */
  41. protected $_runtimeModel;
  42. /**
  43. * Callback
  44. *
  45. * $config for TranslateBehavior should be
  46. * array('fields' => array('field_one',
  47. * 'field_two' => 'FieldAssoc', 'field_three'))
  48. *
  49. * With above example only one permanent hasMany will be joined (for field_two
  50. * as FieldAssoc)
  51. *
  52. * $config could be empty - and translations configured dynamically by
  53. * bindTranslation() method
  54. *
  55. * @param Model $model Model the behavior is being attached to.
  56. * @param array $config Array of configuration information.
  57. * @return mixed
  58. */
  59. public function setup($model, $config = array()) {
  60. $db = ConnectionManager::getDataSource($model->useDbConfig);
  61. if (!$db->connected) {
  62. trigger_error(
  63. __d('cake_dev', 'Datasource %s for TranslateBehavior of model %s is not connected', $model->useDbConfig, $model->alias),
  64. E_USER_ERROR
  65. );
  66. return false;
  67. }
  68. $this->settings[$model->alias] = array();
  69. $this->runtime[$model->alias] = array('fields' => array());
  70. $this->translateModel($model);
  71. return $this->bindTranslation($model, $config, false);
  72. }
  73. /**
  74. * Cleanup Callback unbinds bound translations and deletes setting information.
  75. *
  76. * @param Model $model Model being detached.
  77. * @return void
  78. */
  79. public function cleanup($model) {
  80. $this->unbindTranslation($model);
  81. unset($this->settings[$model->alias]);
  82. unset($this->runtime[$model->alias]);
  83. }
  84. /**
  85. * beforeFind Callback
  86. *
  87. * @param Model $model Model find is being run on.
  88. * @param array $query Array of Query parameters.
  89. * @return array Modified query
  90. */
  91. public function beforeFind($model, $query) {
  92. $this->runtime[$model->alias]['virtualFields'] = $model->virtualFields;
  93. $locale = $this->_getLocale($model);
  94. if (empty($locale)) {
  95. return $query;
  96. }
  97. $db = $model->getDataSource();
  98. $RuntimeModel = $this->translateModel($model);
  99. if (!empty($RuntimeModel->tablePrefix)) {
  100. $tablePrefix = $RuntimeModel->tablePrefix;
  101. } else {
  102. $tablePrefix = $db->config['prefix'];
  103. }
  104. $joinTable = new StdClass();
  105. $joinTable->tablePrefix = $tablePrefix;
  106. $joinTable->table = $RuntimeModel->table;
  107. $joinTable->schemaName = $RuntimeModel->getDataSource()->getSchemaName();
  108. $this->_joinTable = $joinTable;
  109. $this->_runtimeModel = $RuntimeModel;
  110. if (is_string($query['fields']) && 'COUNT(*) AS ' . $db->name('count') == $query['fields']) {
  111. $query['fields'] = 'COUNT(DISTINCT('.$db->name($model->alias . '.' . $model->primaryKey) . ')) ' . $db->alias . 'count';
  112. $query['joins'][] = array(
  113. 'type' => 'INNER',
  114. 'alias' => $RuntimeModel->alias,
  115. 'table' => $joinTable,
  116. 'conditions' => array(
  117. $model->alias . '.' . $model->primaryKey => $db->identifier($RuntimeModel->alias.'.foreign_key'),
  118. $RuntimeModel->alias.'.model' => $model->name,
  119. $RuntimeModel->alias.'.locale' => $locale
  120. )
  121. );
  122. $conditionFields = $this->_checkConditions($model, $query);
  123. foreach ($conditionFields as $field) {
  124. $query = $this->_addJoin($model, $query, $field, $field, $locale);
  125. }
  126. unset($this->_joinTable, $this->_runtimeModel);
  127. return $query;
  128. }
  129. $fields = array_merge($this->settings[$model->alias], $this->runtime[$model->alias]['fields']);
  130. $addFields = array();
  131. if (empty($query['fields'])) {
  132. $addFields = $fields;
  133. } elseif (is_array($query['fields'])) {
  134. foreach ($fields as $key => $value) {
  135. $field = (is_numeric($key)) ? $value : $key;
  136. if (in_array($model->alias.'.*', $query['fields']) || in_array($model->alias.'.' . $field, $query['fields']) || in_array($field, $query['fields'])) {
  137. $addFields[] = $field;
  138. }
  139. }
  140. }
  141. $this->runtime[$model->alias]['virtualFields'] = $model->virtualFields;
  142. if ($addFields) {
  143. foreach ($addFields as $_f => $field) {
  144. $aliasField = is_numeric($_f) ? $field : $_f;
  145. foreach (array($aliasField, $model->alias . '.' . $aliasField) as $_field) {
  146. $key = array_search($_field, (array)$query['fields']);
  147. if ($key !== false) {
  148. unset($query['fields'][$key]);
  149. }
  150. }
  151. $query = $this->_addJoin($model, $query, $field, $aliasField, $locale);
  152. }
  153. }
  154. $this->runtime[$model->alias]['beforeFind'] = $addFields;
  155. unset($this->_joinTable, $this->_runtimeModel);
  156. return $query;
  157. }
  158. /**
  159. * Check a query's conditions for translated fields.
  160. * Return an array of translated fields found in the conditions.
  161. *
  162. * @param Model $model The model being read.
  163. * @param array $query The query array.
  164. * @return array The list of translated fields that are in the conditions.
  165. */
  166. protected function _checkConditions(Model $model, $query) {
  167. $conditionFields = array();
  168. if (empty($query['conditions']) || (!empty($query['conditions']) && !is_array($query['conditions'])) ) {
  169. return $conditionFields;
  170. }
  171. foreach ($query['conditions'] as $col => $val) {
  172. foreach ($this->settings[$model->alias] as $field => $assoc) {
  173. if (is_numeric($field)) {
  174. $field = $assoc;
  175. }
  176. if (strpos($col, $field) !== false) {
  177. $conditionFields[] = $field;
  178. }
  179. }
  180. }
  181. return $conditionFields;
  182. }
  183. /**
  184. * Appends a join for translated fields and possibly a field.
  185. *
  186. * @param Model $model The model being worked on.
  187. * @param object $joinTable The jointable object.
  188. * @param array $query The query array to append a join to.
  189. * @param string $field The field name being joined.
  190. * @param string $aliasField The aliased field name being joined.
  191. * @param mixed $locale The locale(s) having joins added.
  192. * @param boolean $addField Whether or not to add a field.
  193. * @return array The modfied query
  194. */
  195. protected function _addJoin(Model $model, $query, $field, $aliasField, $locale, $addField = false) {
  196. $db = ConnectionManager::getDataSource($model->useDbConfig);
  197. $RuntimeModel = $this->_runtimeModel;
  198. $joinTable = $this->_joinTable;
  199. if (is_array($locale)) {
  200. foreach ($locale as $_locale) {
  201. $model->virtualFields['i18n_' . $field . '_' . $_locale] = 'I18n__' . $field . '__' . $_locale . '.content';
  202. if (!empty($query['fields']) && is_array($query['fields'])) {
  203. $query['fields'][] = 'i18n_'.$field.'_'.$_locale;
  204. }
  205. $query['joins'][] = array(
  206. 'type' => 'LEFT',
  207. 'alias' => 'I18n__'.$field.'__'.$_locale,
  208. 'table' => $joinTable,
  209. 'conditions' => array(
  210. $model->alias . '.' . $model->primaryKey => $db->identifier("I18n__{$field}__{$_locale}.foreign_key"),
  211. 'I18n__'.$field.'__'.$_locale.'.model' => $model->name,
  212. 'I18n__'.$field.'__'.$_locale.'.'.$RuntimeModel->displayField => $aliasField,
  213. 'I18n__'.$field.'__'.$_locale.'.locale' => $_locale
  214. )
  215. );
  216. }
  217. } else {
  218. $model->virtualFields['i18n_' . $field] = 'I18n__' . $field . '.content';
  219. if (!empty($query['fields']) && is_array($query['fields'])) {
  220. $query['fields'][] = 'i18n_'.$field;
  221. }
  222. $query['joins'][] = array(
  223. 'type' => 'INNER',
  224. 'alias' => 'I18n__'.$field,
  225. 'table' => $joinTable,
  226. 'conditions' => array(
  227. $model->alias . '.' . $model->primaryKey => $db->identifier("I18n__{$field}.foreign_key"),
  228. 'I18n__'.$field.'.model' => $model->name,
  229. 'I18n__'.$field.'.'.$RuntimeModel->displayField => $aliasField,
  230. 'I18n__'.$field.'.locale' => $locale
  231. )
  232. );
  233. }
  234. return $query;
  235. }
  236. /**
  237. * afterFind Callback
  238. *
  239. * @param Model $model Model find was run on
  240. * @param array $results Array of model results.
  241. * @param boolean $primary Did the find originate on $model.
  242. * @return array Modified results
  243. */
  244. public function afterFind($model, $results, $primary) {
  245. $model->virtualFields = $this->runtime[$model->alias]['virtualFields'];
  246. $this->runtime[$model->alias]['virtualFields'] = $this->runtime[$model->alias]['fields'] = array();
  247. $locale = $this->_getLocale($model);
  248. if (empty($locale) || empty($results) || empty($this->runtime[$model->alias]['beforeFind'])) {
  249. return $results;
  250. }
  251. $beforeFind = $this->runtime[$model->alias]['beforeFind'];
  252. foreach ($results as $key => &$row) {
  253. $results[$key][$model->alias]['locale'] = (is_array($locale)) ? current($locale) : $locale;
  254. foreach ($beforeFind as $_f => $field) {
  255. $aliasField = is_numeric($_f) ? $field : $_f;
  256. if (is_array($locale)) {
  257. foreach ($locale as $_locale) {
  258. if (!isset($row[$model->alias][$aliasField]) && !empty($row[$model->alias]['i18n_' . $field . '_' . $_locale])) {
  259. $row[$model->alias][$aliasField] = $row[$model->alias]['i18n_' . $field . '_' . $_locale];
  260. $row[$model->alias]['locale'] = $_locale;
  261. }
  262. unset($row[$model->alias]['i18n_' . $field . '_' . $_locale]);
  263. }
  264. if (!isset($row[$model->alias][$aliasField])) {
  265. $row[$model->alias][$aliasField] = '';
  266. }
  267. } else {
  268. $value = '';
  269. if (!empty($row[$model->alias]['i18n_' . $field])) {
  270. $value = $row[$model->alias]['i18n_' . $field];
  271. }
  272. $row[$model->alias][$aliasField] = $value;
  273. unset($row[$model->alias]['i18n_' . $field]);
  274. }
  275. }
  276. }
  277. return $results;
  278. }
  279. /**
  280. * beforeValidate Callback
  281. *
  282. * @param Model $model Model invalidFields was called on.
  283. * @return boolean
  284. */
  285. public function beforeValidate($model) {
  286. $locale = $this->_getLocale($model);
  287. if (empty($locale)) {
  288. return true;
  289. }
  290. $fields = array_merge($this->settings[$model->alias], $this->runtime[$model->alias]['fields']);
  291. $tempData = array();
  292. foreach ($fields as $key => $value) {
  293. $field = (is_numeric($key)) ? $value : $key;
  294. if (isset($model->data[$model->alias][$field])) {
  295. $tempData[$field] = $model->data[$model->alias][$field];
  296. if (is_array($model->data[$model->alias][$field])) {
  297. if (is_string($locale) && !empty($model->data[$model->alias][$field][$locale])) {
  298. $model->data[$model->alias][$field] = $model->data[$model->alias][$field][$locale];
  299. } else {
  300. $values = array_values($model->data[$model->alias][$field]);
  301. $model->data[$model->alias][$field] = $values[0];
  302. }
  303. }
  304. }
  305. }
  306. $this->runtime[$model->alias]['beforeSave'] = $tempData;
  307. return true;
  308. }
  309. /**
  310. * afterSave Callback
  311. *
  312. * @param Model $model Model the callback is called on
  313. * @param boolean $created Whether or not the save created a record.
  314. * @return void
  315. */
  316. public function afterSave($model, $created) {
  317. if (!isset($this->runtime[$model->alias]['beforeSave'])) {
  318. return true;
  319. }
  320. $locale = $this->_getLocale($model);
  321. $tempData = $this->runtime[$model->alias]['beforeSave'];
  322. unset($this->runtime[$model->alias]['beforeSave']);
  323. $conditions = array('model' => $model->alias, 'foreign_key' => $model->id);
  324. $RuntimeModel = $this->translateModel($model);
  325. foreach ($tempData as $field => $value) {
  326. unset($conditions['content']);
  327. $conditions['field'] = $field;
  328. if (is_array($value)) {
  329. $conditions['locale'] = array_keys($value);
  330. } else {
  331. $conditions['locale'] = $locale;
  332. if (is_array($locale)) {
  333. $value = array($locale[0] => $value);
  334. } else {
  335. $value = array($locale => $value);
  336. }
  337. }
  338. $translations = $RuntimeModel->find('list', array('conditions' => $conditions, 'fields' => array($RuntimeModel->alias . '.locale', $RuntimeModel->alias . '.id')));
  339. foreach ($value as $_locale => $_value) {
  340. $RuntimeModel->create();
  341. $conditions['locale'] = $_locale;
  342. $conditions['content'] = $_value;
  343. if (array_key_exists($_locale, $translations)) {
  344. $RuntimeModel->save(array($RuntimeModel->alias => array_merge($conditions, array('id' => $translations[$_locale]))));
  345. } else {
  346. $RuntimeModel->save(array($RuntimeModel->alias => $conditions));
  347. }
  348. }
  349. }
  350. }
  351. /**
  352. * afterDelete Callback
  353. *
  354. * @param Model $model Model the callback was run on.
  355. * @return void
  356. */
  357. public function afterDelete($model) {
  358. $RuntimeModel = $this->translateModel($model);
  359. $conditions = array('model' => $model->alias, 'foreign_key' => $model->id);
  360. $RuntimeModel->deleteAll($conditions);
  361. }
  362. /**
  363. * Get selected locale for model
  364. *
  365. * @param Model $model Model the locale needs to be set/get on.
  366. * @return mixed string or false
  367. */
  368. protected function _getLocale($model) {
  369. if (!isset($model->locale) || is_null($model->locale)) {
  370. $I18n = I18n::getInstance();
  371. $I18n->l10n->get(Configure::read('Config.language'));
  372. $model->locale = $I18n->l10n->locale;
  373. }
  374. return $model->locale;
  375. }
  376. /**
  377. * Get instance of model for translations.
  378. *
  379. * If the model has a translateModel property set, this will be used as the class
  380. * name to find/use. If no translateModel property is found 'I18nModel' will be used.
  381. *
  382. * @param Model $model Model to get a translatemodel for.
  383. * @return Model
  384. */
  385. public function translateModel($model) {
  386. if (!isset($this->runtime[$model->alias]['model'])) {
  387. if (!isset($model->translateModel) || empty($model->translateModel)) {
  388. $className = 'I18nModel';
  389. } else {
  390. $className = $model->translateModel;
  391. }
  392. $this->runtime[$model->alias]['model'] = ClassRegistry::init($className, 'Model');
  393. }
  394. if (!empty($model->translateTable) && $model->translateTable !== $this->runtime[$model->alias]['model']->useTable) {
  395. $this->runtime[$model->alias]['model']->setSource($model->translateTable);
  396. } elseif (empty($model->translateTable) && empty($model->translateModel)) {
  397. $this->runtime[$model->alias]['model']->setSource('i18n');
  398. }
  399. return $this->runtime[$model->alias]['model'];
  400. }
  401. /**
  402. * Bind translation for fields, optionally with hasMany association for
  403. * fake field.
  404. *
  405. * *Note* You should avoid binding translations that overlap existing model properties.
  406. * This can cause un-expected and un-desirable behavior.
  407. *
  408. * @param Model $model instance of model
  409. * @param string|array $fields string with field or array(field1, field2=>AssocName, field3)
  410. * @param boolean $reset
  411. * @return boolean
  412. */
  413. public function bindTranslation($model, $fields, $reset = true) {
  414. if (is_string($fields)) {
  415. $fields = array($fields);
  416. }
  417. $associations = array();
  418. $RuntimeModel = $this->translateModel($model);
  419. $default = array('className' => $RuntimeModel->alias, 'foreignKey' => 'foreign_key');
  420. foreach ($fields as $key => $value) {
  421. if (is_numeric($key)) {
  422. $field = $value;
  423. $association = null;
  424. } else {
  425. $field = $key;
  426. $association = $value;
  427. }
  428. if ($association === 'name') {
  429. throw new CakeException(
  430. __d('cake_dev', 'You cannot bind a translation named "name".')
  431. );
  432. }
  433. if (array_key_exists($field, $this->settings[$model->alias])) {
  434. unset($this->settings[$model->alias][$field]);
  435. } elseif (in_array($field, $this->settings[$model->alias])) {
  436. $this->settings[$model->alias] = array_merge(array_diff_assoc($this->settings[$model->alias], array($field)));
  437. }
  438. if (array_key_exists($field, $this->runtime[$model->alias]['fields'])) {
  439. unset($this->runtime[$model->alias]['fields'][$field]);
  440. } elseif (in_array($field, $this->runtime[$model->alias]['fields'])) {
  441. $this->runtime[$model->alias]['fields'] = array_merge(array_diff_assoc($this->runtime[$model->alias]['fields'], array($field)));
  442. }
  443. if (is_null($association)) {
  444. if ($reset) {
  445. $this->runtime[$model->alias]['fields'][] = $field;
  446. } else {
  447. $this->settings[$model->alias][] = $field;
  448. }
  449. } else {
  450. if ($reset) {
  451. $this->runtime[$model->alias]['fields'][$field] = $association;
  452. } else {
  453. $this->settings[$model->alias][$field] = $association;
  454. }
  455. foreach (array('hasOne', 'hasMany', 'belongsTo', 'hasAndBelongsToMany') as $type) {
  456. if (isset($model->{$type}[$association]) || isset($model->__backAssociation[$type][$association])) {
  457. trigger_error(
  458. __d('cake_dev', 'Association %s is already bound to model %s', $association, $model->alias),
  459. E_USER_ERROR
  460. );
  461. return false;
  462. }
  463. }
  464. $associations[$association] = array_merge($default, array('conditions' => array(
  465. 'model' => $model->alias,
  466. $RuntimeModel->displayField => $field
  467. )));
  468. }
  469. }
  470. if (!empty($associations)) {
  471. $model->bindModel(array('hasMany' => $associations), $reset);
  472. }
  473. return true;
  474. }
  475. /**
  476. * Unbind translation for fields, optionally unbinds hasMany association for
  477. * fake field
  478. *
  479. * @param Model $model instance of model
  480. * @param mixed $fields string with field, or array(field1, field2=>AssocName, field3), or null for
  481. * unbind all original translations
  482. * @return boolean
  483. */
  484. public function unbindTranslation($model, $fields = null) {
  485. if (empty($fields) && empty($this->settings[$model->alias])) {
  486. return false;
  487. }
  488. if (empty($fields)) {
  489. return $this->unbindTranslation($model, $this->settings[$model->alias]);
  490. }
  491. if (is_string($fields)) {
  492. $fields = array($fields);
  493. }
  494. $RuntimeModel = $this->translateModel($model);
  495. $associations = array();
  496. foreach ($fields as $key => $value) {
  497. if (is_numeric($key)) {
  498. $field = $value;
  499. $association = null;
  500. } else {
  501. $field = $key;
  502. $association = $value;
  503. }
  504. if (array_key_exists($field, $this->settings[$model->alias])) {
  505. unset($this->settings[$model->alias][$field]);
  506. } elseif (in_array($field, $this->settings[$model->alias])) {
  507. $this->settings[$model->alias] = array_merge(array_diff_assoc($this->settings[$model->alias], array($field)));
  508. }
  509. if (array_key_exists($field, $this->runtime[$model->alias]['fields'])) {
  510. unset($this->runtime[$model->alias]['fields'][$field]);
  511. } elseif (in_array($field, $this->runtime[$model->alias]['fields'])) {
  512. $this->runtime[$model->alias]['fields'] = array_merge(array_diff_assoc($this->runtime[$model->alias]['fields'], array($field)));
  513. }
  514. if (!is_null($association) && (isset($model->hasMany[$association]) || isset($model->__backAssociation['hasMany'][$association]))) {
  515. $associations[] = $association;
  516. }
  517. }
  518. if (!empty($associations)) {
  519. $model->unbindModel(array('hasMany' => $associations), false);
  520. }
  521. return true;
  522. }
  523. }