MyModel.php 47 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655
  1. <?php
  2. App::uses('Model', 'Model');
  3. App::uses('Utility', 'Tools.Utility');
  4. App::uses('Hash', 'Utility');
  5. /**
  6. * Model enhancements for Cake2
  7. *
  8. * @author Mark Scherer
  9. * @license http://opensource.org/licenses/mit-license.php MIT
  10. */
  11. class MyModel extends Model {
  12. public $recursive = -1;
  13. public $actsAs = ['Containable'];
  14. /**
  15. * MyModel::__construct()
  16. *
  17. * @param int $id
  18. * @param string $table
  19. * @param string $ds
  20. */
  21. public function __construct($id = false, $table = null, $ds = null) {
  22. parent::__construct($id, $table, $ds);
  23. // enable caching
  24. if (!Configure::read('Cache.disable') && Cache::config('sql') === false) {
  25. if (!file_exists(CACHE . 'sql')) {
  26. mkdir(CACHE . 'sql', CHOWN_PUBLIC);
  27. }
  28. Cache::config('sql', [
  29. 'engine' => 'File',
  30. 'serialize' => true,
  31. 'prefix' => '',
  32. 'path' => CACHE . 'sql' . DS,
  33. 'duration' => '+1 day'
  34. ]);
  35. }
  36. if (!Configure::read('Model.disablePrefixing')) {
  37. $this->prefixOrderProperty();
  38. }
  39. // Get a notice if there is an AppModel instance instead of a real Model (in those cases usually a dev error!)
  40. if (!is_a($this, $this->name) && $this->displayField !== $this->primaryKey && $this->useDbConfig === 'default'
  41. && !Configure::read('Core.disableModelInstanceNotice')) {
  42. trigger_error('AppModel instance! Expected: ' . $this->name);
  43. }
  44. }
  45. /**
  46. * Prefixes the order property with the actual alias if its a string or array.
  47. *
  48. * The core fails on using the proper prefix when building the query with two
  49. * different tables.
  50. *
  51. * @return void
  52. */
  53. public function prefixOrderProperty() {
  54. if (is_string($this->order)) {
  55. $this->order = $this->prefixAlias($this->order);
  56. }
  57. if (is_array($this->order)) {
  58. foreach ($this->order as $key => $value) {
  59. if (is_numeric($key)) {
  60. $this->order[$key] = $this->prefixAlias($value);
  61. } else {
  62. $newKey = $this->prefixAlias($key);
  63. $this->order[$newKey] = $value;
  64. if ($newKey !== $key) {
  65. unset($this->order[$key]);
  66. }
  67. }
  68. }
  69. }
  70. }
  71. /**
  72. * Checks if a string of a field name contains a dot if not it will add it and add the alias prefix.
  73. *
  74. * @param string
  75. * @return string
  76. */
  77. public function prefixAlias($string) {
  78. if (strpos($string, '.') === false) {
  79. return $this->alias . '.' . $string;
  80. }
  81. return $string;
  82. }
  83. /**
  84. * Deconstructs a complex data type (array or object) into a single field value.
  85. * BUGFIXED VERSION - autodetects type and allows manual override
  86. *
  87. * @param string $field The name of the field to be deconstructed
  88. * @param array|object $data An array or object to be deconstructed into a field
  89. * @return mixed The resulting data that should be assigned to a field
  90. */
  91. public function deconstruct($field, $data, $type = null) {
  92. if (!is_array($data)) {
  93. return $data;
  94. }
  95. if ($type === null) {
  96. $type = $this->getColumnType($field);
  97. }
  98. if ($type === null) {
  99. //try to autodetect
  100. if (isset($data['day']) || isset($data['month']) || isset($data['year'])) {
  101. $type = 'date';
  102. }
  103. if (isset($data['hour']) || isset($data['min']) || isset($data['sec'])) {
  104. $type .= 'time';
  105. }
  106. }
  107. if (in_array($type, ['datetime', 'timestamp', 'date', 'time'])) {
  108. $useNewDate = (isset($data['year']) || isset($data['month']) ||
  109. isset($data['day']) || isset($data['hour']) || isset($data['minute']));
  110. $dateFields = ['Y' => 'year', 'm' => 'month', 'd' => 'day', 'H' => 'hour', 'i' => 'min', 's' => 'sec'];
  111. $timeFields = ['H' => 'hour', 'i' => 'min', 's' => 'sec'];
  112. $date = [];
  113. if (isset($data['meridian']) && empty($data['meridian'])) {
  114. return null;
  115. }
  116. if (
  117. isset($data['hour']) &&
  118. isset($data['meridian']) &&
  119. !empty($data['hour']) &&
  120. $data['hour'] != 12 &&
  121. 'pm' == $data['meridian']
  122. ) {
  123. $data['hour'] = $data['hour'] + 12;
  124. }
  125. if (isset($data['hour']) && isset($data['meridian']) && $data['hour'] == 12 && 'am' == $data['meridian']) {
  126. $data['hour'] = '00';
  127. }
  128. if ($type === 'time') {
  129. foreach ($timeFields as $key => $val) {
  130. if (!isset($data[$val]) || $data[$val] === '0' || $data[$val] === '00') {
  131. $data[$val] = '00';
  132. } elseif ($data[$val] !== '') {
  133. $data[$val] = sprintf('%02d', $data[$val]);
  134. }
  135. if (!empty($data[$val])) {
  136. $date[$key] = $data[$val];
  137. } else {
  138. return null;
  139. }
  140. }
  141. }
  142. if ($type === 'datetime' || $type === 'timestamp' || $type === 'date') {
  143. foreach ($dateFields as $key => $val) {
  144. if ($val === 'hour' || $val === 'min' || $val === 'sec') {
  145. if (!isset($data[$val]) || $data[$val] === '0' || $data[$val] === '00') {
  146. $data[$val] = '00';
  147. } else {
  148. $data[$val] = sprintf('%02d', $data[$val]);
  149. }
  150. }
  151. if (!isset($data[$val]) || isset($data[$val]) && (empty($data[$val]) || $data[$val][0] === '-')) {
  152. return null;
  153. }
  154. if (isset($data[$val]) && !empty($data[$val])) {
  155. $date[$key] = $data[$val];
  156. }
  157. }
  158. }
  159. if ($useNewDate && !empty($date)) {
  160. $format = $this->getDataSource()->columns[$type]['format'];
  161. foreach (['m', 'd', 'H', 'i', 's'] as $index) {
  162. if (isset($date[$index])) {
  163. $date[$index] = sprintf('%02d', $date[$index]);
  164. }
  165. }
  166. return str_replace(array_keys($date), array_values($date), $format);
  167. }
  168. }
  169. return $data;
  170. }
  171. /**
  172. * The main method for any enumeration, should be called statically
  173. * Now also supports reordering/filtering
  174. *
  175. * @link http://www.dereuromark.de/2010/06/24/static-enums-or-semihardcoded-attributes/
  176. * @param string $value or array $keys or NULL for complete array result
  177. * @param array $options (actual data)
  178. * @return mixed string/array
  179. */
  180. public static function enum($value, $options, $default = null) {
  181. if ($value !== null && !is_array($value)) {
  182. if (array_key_exists($value, $options)) {
  183. return $options[$value];
  184. }
  185. return $default;
  186. } elseif ($value !== null) {
  187. $newOptions = [];
  188. foreach ($value as $v) {
  189. $newOptions[$v] = $options[$v];
  190. }
  191. return $newOptions;
  192. }
  193. return $options;
  194. }
  195. /**
  196. * @return string Error message with error number
  197. */
  198. public function lastError() {
  199. $db = $this->getDataSource();
  200. return $db->lastError();
  201. }
  202. /**
  203. * Combine virtual fields with fields values of find()
  204. * USAGE:
  205. * $this->Model->find('all', array('fields' => $this->Model->virtualFields('full_name')));
  206. * Also adds the field to the virtualFields array of the model (for correct result)
  207. * TODO: adding of fields only temperory!
  208. *
  209. * @param array $virtualFields to include
  210. * @return array
  211. */
  212. public function virtualFields($fields = []) {
  213. $res = [];
  214. foreach ((array)$fields as $field => $sql) {
  215. if (is_int($field)) {
  216. $field = $sql;
  217. $sql = null;
  218. }
  219. $plugin = $model = null;
  220. if (($pos = strrpos($field, '.')) !== false) {
  221. $model = substr($field, 0, $pos);
  222. $field = substr($field, $pos + 1);
  223. if (($pos = strrpos($model, '.')) !== false) {
  224. list($plugin, $model) = pluginSplit($model);
  225. }
  226. }
  227. if (empty($model)) {
  228. $model = $this->alias;
  229. if ($sql === null) {
  230. $sql = $this->virtualFields[$field];
  231. } else {
  232. $this->virtualFields[$field] = $sql;
  233. }
  234. } else {
  235. if (!isset($this->$model)) {
  236. $fullModelName = ($plugin ? $plugin . '.' : '') . $model;
  237. $this->$model = ClassRegistry::init($fullModelName);
  238. }
  239. if ($sql === null) {
  240. $sql = $this->$model->virtualFields[$field];
  241. } else {
  242. $this->$model->virtualFields[$field] = $sql;
  243. }
  244. }
  245. $res[] = $sql . ' AS ' . $model . '__' . $field;
  246. }
  247. return $res;
  248. }
  249. /**
  250. * HIGHLY EXPERIMENTAL
  251. * manually escape value for updateAll() etc
  252. *
  253. * @return string
  254. */
  255. public function escapeValue($value) {
  256. if ($value === null || is_numeric($value)) {
  257. return $value;
  258. }
  259. if (is_bool($value)) {
  260. return (int)$value;
  261. }
  262. return "'" . $value . "'";
  263. }
  264. /**
  265. * HIGHLY EXPERIMENTAL
  266. *
  267. * @see http://cakephp.lighthouseapp.com/projects/42648/tickets/1799-model-should-have-escapefield-method
  268. * @return string
  269. */
  270. public function value($content) {
  271. $db = $this->getDatasource();
  272. return $db->value($content);
  273. }
  274. /**
  275. * TODO: move to behavior (Incremental)
  276. *
  277. * @param mixed id (single string)
  278. * @param options:
  279. * - step (defaults to 1)
  280. * - current (if none it will get it from db)
  281. * - reset (if true, it will be set to 0)
  282. * - field (defaults to 'count')
  283. * - modify (if true if will affect modified timestamp)
  284. * - timestampField (if provided it will be filled with NOW())
  285. * @return See Model::save()
  286. */
  287. public function up($id, $customOptions = []) {
  288. $step = 1;
  289. if (isset($customOptions['step'])) {
  290. $step = $customOptions['step'];
  291. }
  292. $field = 'count';
  293. if (isset($customOptions['field'])) {
  294. $field = $customOptions['field'];
  295. }
  296. if (isset($customOptions['reset'])) {
  297. $currentValue = $step = 0;
  298. } elseif (!isset($customOptions['current'])) {
  299. $currentValue = $this->field($field, [$this->alias . '.id' => $id]);
  300. if ($currentValue === false) {
  301. return false;
  302. }
  303. } else {
  304. $currentValue = $customOptions['current'];
  305. }
  306. $value = (int)$currentValue + (int)$step;
  307. $data = [$field => $value];
  308. if (empty($customOptions['modify'])) {
  309. $data['modified'] = false;
  310. }
  311. if (!empty($customOptions['timestampField'])) {
  312. $data[$customOptions['timestampField']] = date(FORMAT_DB_DATETIME);
  313. }
  314. $this->id = $id;
  315. return $this->save($data, false);
  316. }
  317. /**
  318. * Return the next auto increment id from the current table
  319. * UUIDs will return false
  320. *
  321. * @return int next auto increment value or False on failure
  322. */
  323. public function getNextAutoIncrement() {
  324. $query = "SHOW TABLE STATUS WHERE name = '" . $this->tablePrefix . $this->table . "'";
  325. $result = $this->query($query);
  326. if (!isset($result[0]['TABLES']['Auto_increment'])) {
  327. return false;
  328. }
  329. return (int)$result[0]['TABLES']['Auto_increment'];
  330. }
  331. /**
  332. * Fix for non atomic queries (MyISAM etc) and saveAll to still return just the boolean result
  333. * Otherwise you would have to iterate over all result values to find out if the save was successful.
  334. *
  335. * Use Configure::read('Model.atomic') to modify atomic behavior.
  336. * Additional options:
  337. *
  338. * - returnArray: bool
  339. *
  340. * @param mixed $data
  341. * @param array $options
  342. * @return bool Success
  343. */
  344. public function saveAll($data = null, $options = []) {
  345. if (!isset($options['atomic']) && Configure::read('Model.atomic') !== null) {
  346. $options['atomic'] = (bool)Configure::read('Model.atomic');
  347. }
  348. $res = parent::saveAll($data, $options);
  349. if (is_array($res) && empty($options['returnArray'])) {
  350. $res = Utility::isValidSaveAll($res);
  351. }
  352. return $res;
  353. }
  354. /**
  355. * Override default updateAll to workaround forced joins.
  356. *
  357. * This is a shim method to more easily migrate to 3.x as there
  358. * updateAll() does not allow joining anymore.
  359. *
  360. * @param array $fields Set of fields and values, indexed by fields.
  361. * Fields are treated as SQL snippets, to insert literal values manually escape your data.
  362. * @param mixed $conditions Conditions to match, true for all records
  363. * @return bool True on success, false on failure
  364. */
  365. public function updateAllJoinless($fields, $conditions = true) {
  366. $name = $this->name;
  367. $this->name = '_model_';
  368. try {
  369. $result = $this->updateAll($fields, $conditions);
  370. } catch (Exception $e) {
  371. $this->name = $name;
  372. throw $e;
  373. }
  374. $this->name = $name;
  375. return $result;
  376. }
  377. /**
  378. * Override default deleteAll to workaround forced joins
  379. *
  380. * This is a shim method to more easily migrate to 3.x as there
  381. * deleteAll() does not allow joining anymore.
  382. *
  383. * @param mixed $conditions Conditions to match
  384. * @param bool $cascade Set to true to delete records that depend on this record
  385. * @param bool $callbacks Run callbacks
  386. * @return bool True on success, false on failure
  387. */
  388. public function deleteAllJoinless($conditions, $dependent = true, $callbacks = false) {
  389. $associated = [];
  390. foreach ($this->getAssociated() as $model => $type) {
  391. $associated[$type][] = $model;
  392. }
  393. $this->unbindModel($associated);
  394. return $this->deleteAll($conditions, $dependent, $callbacks);
  395. }
  396. /**
  397. * Enables HABTM-Validation
  398. * e.g. with
  399. * 'rule' => array('multiple', array('min' => 2))
  400. *
  401. * @return bool Success
  402. */
  403. public function beforeValidate($options = []) {
  404. foreach ($this->hasAndBelongsToMany as $k => $v) {
  405. if (isset($this->data[$k][$k])) {
  406. $this->data[$this->alias][$k] = $this->data[$k][$k];
  407. }
  408. }
  409. return parent::beforeValidate($options);
  410. }
  411. /**
  412. * @param params
  413. * - key: functioName or other key used
  414. * @return bool Success
  415. */
  416. public function deleteCache($key = null) {
  417. $key = Inflector::underscore($key);
  418. if (!empty($key)) {
  419. return Cache::delete(strtolower(Inflector::underscore($this->alias)) . '__' . $key, 'sql');
  420. }
  421. return Cache::clear(false, 'sql');
  422. }
  423. /**
  424. * Generates a SQL subquery snippet to be used in your actual query.
  425. * Your subquery snippet needs to return a single value or flat array of values.
  426. *
  427. * Example:
  428. *
  429. * $this->Model->find('first', array(
  430. * 'conditions' => array('NOT' => array('some_id' => $this->Model->subquery(...)))
  431. * ))
  432. *
  433. * Note: You might have to set `autoFields` to false in order to retrieve only the fields you request:
  434. * http://book.cakephp.org/2.0/en/core-libraries/behaviors/containable.html#containablebehavior-options
  435. *
  436. * @param string $type The type of the query ('count'/'all'/'first' - first only works with some mysql versions)
  437. * @param array $options The options array
  438. * @param string $alias You can use this intead of $options['alias'] if you want
  439. * @param bool $parenthesise Add parenthesis before and after
  440. * @return string result sql snippet of the query to run
  441. * @modified Mark Scherer (cake2.x ready and improvements)
  442. * @link http://bakery.cakephp.org/articles/lucaswxp/2011/02/11/easy_and_simple_subquery_cakephp
  443. */
  444. public function subquery($type, $options = [], $alias = null, $parenthesise = true) {
  445. if ($alias === null) {
  446. $alias = 'Sub' . $this->alias . '';
  447. }
  448. $fields = [$alias . '.id'];
  449. $limit = null;
  450. switch ($type) {
  451. case 'count':
  452. $fields = ['COUNT(*)'];
  453. break;
  454. case 'first':
  455. $limit = 1;
  456. break;
  457. }
  458. $dbo = $this->getDataSource();
  459. $default = [
  460. 'fields' => $fields,
  461. 'table' => $dbo->fullTableName($this),
  462. 'alias' => $alias,
  463. 'limit' => $limit,
  464. 'offset' => null,
  465. 'joins' => [],
  466. 'conditions' => [],
  467. 'order' => null,
  468. 'group' => null
  469. ];
  470. $params = array_merge($default, $options);
  471. $subQuery = trim($dbo->buildStatement($params, $this));
  472. if ($parenthesise) {
  473. $subQuery = '(' . $subQuery . ')';
  474. }
  475. return $subQuery;
  476. }
  477. /**
  478. * Wrapper find() to cache sql queries.
  479. *
  480. * @param array $conditions
  481. * @param array $fields
  482. * @param string $order
  483. * @param string $recursive
  484. * @return array
  485. */
  486. public function find($type = null, $query = []) {
  487. // reset/delete
  488. if (!empty($query['reset'])) {
  489. if (!empty($query['cache'])) {
  490. if (is_array($query['cache'])) {
  491. $key = $query['cache'][0];
  492. } else {
  493. $key = $query['cache'];
  494. if ($key === true) {
  495. $backtrace = debug_backtrace();
  496. $key = $backtrace[1]['function'];
  497. }
  498. }
  499. $this->deleteCache($key);
  500. }
  501. }
  502. // having and group clauses enhancement
  503. if (is_array($query) && !empty($query['having']) && !empty($query['group'])) {
  504. if (!is_array($query['group'])) {
  505. $query['group'] = [$query['group']];
  506. }
  507. $ds = $this->getDataSource();
  508. $having = $ds->conditions($query['having'], true, false);
  509. $query['group'][count($query['group']) - 1] .= " HAVING $having";
  510. } /* elseif (is_array($query) && !empty($query['having'])) {
  511. $ds = $this->getDataSource();
  512. $having = $ds->conditions($query['having'], true, false);
  513. $query['conditions'][] = '1=1 HAVING '.$having;
  514. }
  515. */
  516. // find
  517. if (!Configure::read('Cache.disable') && Configure::read('Cache.check') && !empty($query['cache'])) {
  518. if (is_array($query['cache'])) {
  519. $key = $query['cache'][0];
  520. $expires = DAY;
  521. if (!empty($query['cache'][1])) {
  522. $expires = $query['cache'][1];
  523. }
  524. } else {
  525. $key = $query['cache'];
  526. if ($key === true) {
  527. $backtrace = debug_backtrace();
  528. $key = $backtrace[1]['function'];
  529. }
  530. $expires = DAY;
  531. }
  532. $options = ['prefix' => strtolower(Inflector::underscore($this->alias)) . '__', ];
  533. if (!empty($expires)) {
  534. $options['duration'] = $expires;
  535. }
  536. if (!Configure::read('Cache.disable')) {
  537. Cache::config('sql', $options);
  538. $key = Inflector::underscore($key);
  539. $results = Cache::read($key, 'sql');
  540. }
  541. if (!isset($results)) {
  542. $results = parent::find($type, $query);
  543. Cache::write($key, $results, 'sql');
  544. }
  545. return $results;
  546. }
  547. // Without caching
  548. return parent::find($type, $query);
  549. }
  550. /**
  551. * This code will add formatted list functionallity to find you can easy replace the $this->Model->find('list'); with $this->Model->find('formattedlist', array('fields' => array('Model.id', 'Model.field1', 'Model.field2', 'Model.field3'), 'format' => '%s-%s %s')); and get option tag output of: Model.field1-Model.field2 Model.field3. Even better part is being able to setup your own format for the output!
  552. *
  553. * @see http://bakery.cakephp.org/articles/view/add-formatted-lists-to-your-appmodel
  554. * @deprecated
  555. * added Caching
  556. */
  557. protected function _find($type, $options = []) {
  558. $res = false;
  559. if ($res === false) {
  560. if (isset($options['cache'])) {
  561. unset($options['cache']);
  562. }
  563. if (!isset($options['recursive'])) {
  564. //$options['recursive'] = -1;
  565. }
  566. switch ($type) {
  567. // @see http://bakery.cakephp.org/deu/articles/nate/2010/10/10/quick-tipp_-_doing_ad-hoc-joins_bei_model_find
  568. case 'matches':
  569. if (!isset($options['joins'])) {
  570. $options['joins'] = [];
  571. }
  572. if (!isset($options['model']) || !isset($options['scope'])) {
  573. break;
  574. }
  575. $assoc = $this->hasAndBelongsToMany[$options['model']];
  576. $bind = "{$assoc['with']}.{$assoc['foreignKey']} = {$this->alias}.{$this->primaryKey}";
  577. $options['joins'][] = [
  578. 'table' => $assoc['joinTable'],
  579. 'alias' => $assoc['with'],
  580. 'type' => 'inner',
  581. 'foreignKey' => false,
  582. 'conditions' => [$bind]
  583. ];
  584. $bind = $options['model'] . '.' . $this->{$options['model']}->primaryKey . ' = ';
  585. $bind .= "{$assoc['with']}.{$assoc['associationForeignKey']}";
  586. $options['joins'][] = [
  587. 'table' => $this->{$options['model']}->table,
  588. 'alias' => $options['model'],
  589. 'type' => 'inner',
  590. 'foreignKey' => false,
  591. 'conditions' => [$bind] + (array)$options['scope'],
  592. ];
  593. unset($options['model'], $options['scope']);
  594. $type = 'all';
  595. break;
  596. // probably deprecated since "virtual fields" in 1.3
  597. case 'formattedlist':
  598. if (!isset($options['fields']) || count($options['fields']) < 3) {
  599. $res = parent::find('list', $options);
  600. break;
  601. }
  602. $this->recursive = -1;
  603. //setup formating
  604. $format = '';
  605. if (!isset($options['format'])) {
  606. for ($i = 0; $i < (count($options['fields']) - 1); $i++) {
  607. $format .= '%s ';
  608. }
  609. $format = substr($format, 0, -1);
  610. } else {
  611. $format = $options['format'];
  612. }
  613. //get data
  614. $list = parent::find('all', $options);
  615. // remove model alias from strings to only get field names
  616. $tmpPath2[] = $format;
  617. for ($i = 1; $i <= (count($options['fields']) - 1); $i++) {
  618. $field[$i] = str_replace($this->alias . '.', '', $options['fields'][$i]);
  619. $tmpPath2[] = '{n}.' . $this->alias . '.' . $field[$i];
  620. }
  621. //do the magic?? read the code...
  622. $res = Hash::combine($list, '{n}.' . $this->alias . '.' . $this->primaryKey, $tmpPath2);
  623. break;
  624. default:
  625. $res = parent::find($type, $options);
  626. }
  627. if (!empty($this->useCache)) {
  628. Cache::write($this->cacheName, $res, $this->cacheConfig);
  629. if (Configure::read('debug') > 0) {
  630. $this->log('WRITE (' . $this->cacheConfig . '): ' . $this->cacheName, 'cache');
  631. }
  632. }
  633. } else {
  634. if (Configure::read('debug') > 0) {
  635. $this->log('READ (' . $this->cacheConfig . '): ' . $this->cacheName, 'cache');
  636. }
  637. }
  638. return $res;
  639. }
  640. /**
  641. * Core-fix for multiple sort orders
  642. *
  643. * @param addiotional 'scope'=>array(field,order) - value is retrieved by (submitted) primary key
  644. * @return mixed
  645. * TODO: fix it
  646. */
  647. protected function _findNeighbors($state, $query, $results = []) {
  648. return parent::_findNeighbors($state, $query, $results);
  649. if (isset($query['scope'])) {
  650. //TODO
  651. }
  652. return parent::find($type, $options);
  653. }
  654. /**
  655. * @param mixed $id: id only, or request array
  656. * @param array $options
  657. * - filter: open/closed/none
  658. * - field (sortField, if not id)
  659. * - reverse: sortDirection (0=normalAsc/1=reverseDesc)
  660. * - displayField: ($this->displayField, if empty)
  661. * @param array $qryOptions
  662. * - recursive (defaults to -1)
  663. * TODO: try to use core function, TRY TO ALLOW MULTIPLE SORT FIELDS
  664. * @return array
  665. */
  666. public function neighbors($id = null, $options = [], $qryOptions = []) {
  667. $sortField = (!empty($options['field']) ? $options['field'] : 'created');
  668. $normalDirection = (!empty($options['reverse']) ? false : true);
  669. $sortDirWord = $normalDirection ? ['ASC', 'DESC'] : ['DESC', 'ASC'];
  670. $sortDirSymb = $normalDirection ? ['>=', '<='] : ['<=', '>='];
  671. $displayField = (!empty($options['displayField']) ? $options['displayField'] : $this->displayField);
  672. if (is_array($id)) {
  673. $data = $id;
  674. $id = $data[$this->alias][$this->primaryKey];
  675. } elseif ($id === null) {
  676. $id = $this->id;
  677. }
  678. if (!empty($id)) {
  679. $data = $this->find('first', ['conditions' => [$this->primaryKey => $id], 'contain' => []]);
  680. }
  681. if (empty($id) || empty($data) || empty($data[$this->alias][$sortField])) {
  682. return [];
  683. } else {
  684. $field = $data[$this->alias][$sortField];
  685. }
  686. $findOptions = ['recursive' => -1];
  687. if (isset($qryOptions['recursive'])) {
  688. $findOptions['recursive'] = $qryOptions['recursive'];
  689. }
  690. if (isset($qryOptions['contain'])) {
  691. $findOptions['contain'] = $qryOptions['contain'];
  692. }
  693. $findOptions['fields'] = [$this->alias . '.' . $this->primaryKey, $this->alias . '.' . $displayField];
  694. $findOptions['conditions'][$this->alias . '.' . $this->primaryKey . ' !='] = $id;
  695. // //TODO: take out
  696. if (!empty($options['filter']) && $options['filter'] == REQUEST_STATUS_FILTER_OPEN) {
  697. $findOptions['conditions'][$this->alias . '.status <'] = REQUEST_STATUS_DECLINED;
  698. } elseif (!empty($options['filter']) && $options['filter'] == REQUEST_STATUS_FILTER_CLOSED) {
  699. $findOptions['conditions'][$this->alias . '.status >='] = REQUEST_STATUS_DECLINED;
  700. }
  701. $return = [];
  702. if (!empty($qryOptions['conditions'])) {
  703. $findOptions['conditions'] = Hash::merge($findOptions['conditions'], $qryOptions['conditions']);
  704. }
  705. $options = $findOptions;
  706. $options['conditions'] = Hash::merge($options['conditions'], [$this->alias . '.' . $sortField . ' ' . $sortDirSymb[1] => $field]);
  707. $options['order'] = [$this->alias . '.' . $sortField . '' => $sortDirWord[1]];
  708. $this->id = $id;
  709. $return['prev'] = $this->find('first', $options);
  710. $options = $findOptions;
  711. $options['conditions'] = Hash::merge($options['conditions'], [$this->alias . '.' . $sortField . ' ' . $sortDirSymb[0] => $field]);
  712. $options['order'] = [$this->alias . '.' . $sortField . '' => $sortDirWord[0]]; // ??? why 0 instead of 1
  713. $this->id = $id;
  714. $return['next'] = $this->find('first', $options);
  715. return $return;
  716. }
  717. /**
  718. * Delete all records using an atomic query similar to updateAll().
  719. * Note: Does not need manual sanitizing/escaping, though.
  720. *
  721. * Does not do any callbacks
  722. *
  723. * @param mixed $conditions Conditions to match, true for all records
  724. * @return bool Success
  725. */
  726. public function deleteAllRaw($conditions = true) {
  727. return $this->getDataSource()->delete($this, $conditions);
  728. }
  729. /**
  730. * Overwrite invalidate to allow last => true
  731. *
  732. * @param string $field The name of the field to invalidate
  733. * @param mixed $value Name of validation rule that was not failed, or validation message to
  734. * be returned. If no validation key is provided, defaults to true.
  735. * @param bool $last If this should be the last validation check for this validation run
  736. * @return void
  737. */
  738. public function invalidate($field, $value = true, $last = false) {
  739. parent::invalidate($field, $value);
  740. if (!$last) {
  741. return;
  742. }
  743. $this->validator()->remove($field);
  744. }
  745. /**
  746. * Validates a primary or foreign key depending on the current schema data for this field
  747. * recognizes uuid (char36) and aiid (int10 unsigned) - not yet mixed (varchar36)
  748. * more useful than using numeric or notEmpty which are type specific
  749. *
  750. * @param array $data
  751. * @param array $options
  752. * - allowEmpty
  753. * @return bool Success
  754. */
  755. public function validateKey($data = [], $options = []) {
  756. $keys = array_keys($data);
  757. $key = array_shift($keys);
  758. $value = array_shift($data);
  759. $schema = $this->schema($key);
  760. if (!$schema) {
  761. return true;
  762. }
  763. $defaults = [
  764. 'allowEmpty' => false,
  765. ];
  766. $options += $defaults;
  767. if ($schema['type'] !== 'integer') {
  768. if ($options['allowEmpty'] && $value === '') {
  769. return true;
  770. }
  771. return Validation::uuid($value);
  772. }
  773. if ($options['allowEmpty'] && $value === 0) {
  774. return true;
  775. }
  776. return is_numeric($value) && (int)$value == $value && $value > 0;
  777. }
  778. /**
  779. * Checks if the passed enum value is valid
  780. *
  781. * @return bool Success
  782. */
  783. public function validateEnum(array $data, $enum = null, $additionalKeys = []) {
  784. $keys = array_keys($data);
  785. $valueKey = array_shift($keys);
  786. $value = $data[$valueKey];
  787. $keys = [];
  788. if ($enum === true) {
  789. $enum = $valueKey;
  790. }
  791. if ($enum !== null) {
  792. if (!method_exists($this, $enum)) {
  793. trigger_error('Enum method \'' . $enum . '()\' not exists', E_USER_ERROR);
  794. return false;
  795. }
  796. //TODO: make static
  797. $keys = $this->{$enum}();
  798. }
  799. $keys = array_merge($additionalKeys, array_keys($keys));
  800. if (!empty($keys) && in_array($value, $keys)) {
  801. return true;
  802. }
  803. return false;
  804. }
  805. /**
  806. * Checks if the content of 2 fields are equal
  807. * Does not check on empty fields! Return TRUE even if both are empty (secure against empty in another rule)!
  808. *
  809. * @return bool Success
  810. */
  811. public function validateIdentical($data = [], $compareWith = null, $options = []) {
  812. if (is_array($data)) {
  813. $value = array_shift($data);
  814. } else {
  815. $value = $data;
  816. }
  817. $compareValue = $this->data[$this->alias][$compareWith];
  818. $matching = ['string' => 'string', 'int' => 'integer', 'float' => 'float', 'bool' => 'boolean'];
  819. if (!empty($options['cast']) && array_key_exists($options['cast'], $matching)) {
  820. // cast values to string/int/float/bool if desired
  821. settype($compareValue, $matching[$options['cast']]);
  822. settype($value, $matching[$options['cast']]);
  823. }
  824. return ($compareValue === $value);
  825. }
  826. /**
  827. * Validate range, but in a more sane way than CORE range().
  828. * This range() validation rule is inclusive regarding the borders.
  829. *
  830. * If $lower and $upper are not set, will return true if
  831. * $check is a legal finite on this platform
  832. *
  833. * @param string $check Value to check
  834. * @param float $lower Lower limit
  835. * @param float $upper Upper limit
  836. * @return bool Success
  837. */
  838. public function validateRange($data, $lower = null, $upper = null) {
  839. foreach ($data as $key => $check) {
  840. break;
  841. }
  842. if (!is_numeric($check)) {
  843. return false;
  844. }
  845. if (isset($lower) && isset($upper)) {
  846. return ($check >= $lower && $check <= $upper);
  847. }
  848. return is_finite($check);
  849. }
  850. /**
  851. * Checks a record, if it is unique - depending on other fields in this table (transfered as array)
  852. * example in model: 'rule' => array ('validateUnique', array('belongs_to_table_id','some_id','user_id')),
  853. * if all keys (of the array transferred) match a record, return false, otherwise true
  854. *
  855. * @param array $fields Other fields to depend on
  856. * TODO: add possibity of deep nested validation (User -> Comment -> CommentCategory: UNIQUE comment_id, Comment.user_id)
  857. * @param array $options
  858. * - requireDependentFields Require all dependent fields for the validation rule to return true
  859. * @return bool Success
  860. */
  861. public function validateUnique($data, $fields = [], $options = []) {
  862. $id = (!empty($this->data[$this->alias][$this->primaryKey]) ? $this->data[$this->alias][$this->primaryKey] : 0);
  863. if (!$id && $this->id) {
  864. $id = $this->id;
  865. }
  866. foreach ($data as $key => $value) {
  867. $fieldName = $key;
  868. $fieldValue = $value;
  869. break;
  870. }
  871. $conditions = [
  872. $this->alias . '.' . $fieldName => $fieldValue,
  873. $this->alias . '.id !=' => $id];
  874. $fields = (array)$fields;
  875. if (!array_key_exists('allowEmpty', $fields)) {
  876. foreach ($fields as $dependingField) {
  877. if (isset($this->data[$this->alias][$dependingField])) { // add ONLY if some content is transfered (check on that first!)
  878. $conditions[$this->alias . '.' . $dependingField] = $this->data[$this->alias][$dependingField];
  879. } elseif (isset($this->data['Validation'][$dependingField])) { // add ONLY if some content is transfered (check on that first!
  880. $conditions[$this->alias . '.' . $dependingField] = $this->data['Validation'][$dependingField];
  881. } elseif (!empty($id)) {
  882. // manual query! (only possible on edit)
  883. $res = $this->find('first', ['fields' => [$this->alias . '.' . $dependingField], 'conditions' => [$this->alias . '.id' => $id]]);
  884. if (!empty($res)) {
  885. $conditions[$this->alias . '.' . $dependingField] = $res[$this->alias][$dependingField];
  886. }
  887. } else {
  888. if (!empty($options['requireDependentFields'])) {
  889. trigger_error('Required field ' . $dependingField . ' for validateUnique validation not present');
  890. return false;
  891. }
  892. return true;
  893. }
  894. }
  895. }
  896. $this->recursive = -1;
  897. if (count($conditions) > 2) {
  898. $this->recursive = 0;
  899. }
  900. $options = ['fields' => [$this->alias . '.' . $this->primaryKey], 'conditions' => $conditions];
  901. $res = $this->find('first', $options);
  902. return empty($res);
  903. }
  904. /**
  905. * Checks if a url is valid AND accessable (returns false otherwise)
  906. *
  907. * @param array/string $data: full url(!) starting with http://...
  908. * @options array
  909. * - allowEmpty TRUE/FALSE (TRUE: if empty => return TRUE)
  910. * - required TRUE/FALSE (TRUE: overrides allowEmpty)
  911. * - autoComplete (default: TRUE)
  912. * - deep (default: TRUE)
  913. * @return bool Success
  914. */
  915. public function validateUrl($data, $options = []) {
  916. if (is_array($data)) {
  917. foreach ($data as $key => $url) {
  918. break;
  919. }
  920. } else {
  921. $url = $data;
  922. }
  923. if (empty($url)) {
  924. if (!empty($options['allowEmpty']) && empty($options['required'])) {
  925. return true;
  926. }
  927. return false;
  928. }
  929. if (!isset($options['autoComplete']) || $options['autoComplete'] !== false) {
  930. $url = $this->_autoCompleteUrl($url);
  931. if (isset($key)) {
  932. $this->data[$this->alias][$key] = $url;
  933. }
  934. }
  935. if (!isset($options['strict']) || $options['strict'] !== false) {
  936. $options['strict'] = true;
  937. }
  938. // validation
  939. if (!Validation::url($url, $options['strict']) && env('REMOTE_ADDR') && env('REMOTE_ADDR') !== '127.0.0.1') {
  940. return false;
  941. }
  942. // same domain?
  943. if (!empty($options['sameDomain']) && env('HTTP_HOST')) {
  944. $is = parse_url($url, PHP_URL_HOST);
  945. $expected = env('HTTP_HOST');
  946. if (mb_strtolower($is) !== mb_strtolower($expected)) {
  947. return false;
  948. }
  949. }
  950. if (isset($options['deep']) && $options['deep'] === false) {
  951. return true;
  952. }
  953. return $this->_validUrl($url);
  954. }
  955. /**
  956. * Prepend protocol if missing
  957. *
  958. * @param string $url
  959. * @return string Url
  960. */
  961. protected function _autoCompleteUrl($url) {
  962. if (mb_strpos($url, '/') === 0) {
  963. $url = Router::url($url, true);
  964. } elseif (mb_strpos($url, '://') === false && mb_strpos($url, 'www.') === 0) {
  965. $url = 'http://' . $url;
  966. }
  967. return $url;
  968. }
  969. /**
  970. * Checks if a url is valid
  971. *
  972. * @param string url
  973. * @return bool Success
  974. */
  975. protected function _validUrl($url) {
  976. $headers = Utility::getHeaderFromUrl($url);
  977. if ($headers === false) {
  978. return false;
  979. }
  980. $headers = implode("\n", $headers);
  981. $protocol = mb_strpos($url, 'https://') === 0 ? 'HTTP' : 'HTTP';
  982. if (!preg_match('#^' . $protocol . '/.*?\s+[(200|301|302)]+\s#i', $headers)) {
  983. return false;
  984. }
  985. if (preg_match('#^' . $protocol . '/.*?\s+[(404|999)]+\s#i', $headers)) {
  986. return false;
  987. }
  988. return true;
  989. }
  990. /**
  991. * Validation of DateTime Fields (both Date and Time together)
  992. *
  993. * @param options
  994. * - dateFormat (defaults to 'ymd')
  995. * - allowEmpty
  996. * - after/before (fieldName to validate against)
  997. * - min/max (defaults to >= 1 - at least 1 second apart)
  998. * @return bool Success
  999. */
  1000. public function validateDateTime($data, $options = []) {
  1001. $format = !empty($options['dateFormat']) ? $options['dateFormat'] : 'ymd';
  1002. if (is_array($data)) {
  1003. $value = array_shift($data);
  1004. } else {
  1005. $value = $data;
  1006. }
  1007. $dateTime = explode(' ', trim($value), 2);
  1008. $date = $dateTime[0];
  1009. $time = (!empty($dateTime[1]) ? $dateTime[1] : '');
  1010. if (!empty($options['allowEmpty']) && (empty($date) && empty($time) || $date == DEFAULT_DATE && $time == DEFAULT_TIME || $date == DEFAULT_DATE && empty($time))) {
  1011. return true;
  1012. }
  1013. /*
  1014. if ($this->validateDate($date, $options) && $this->validateTime($time, $options)) {
  1015. return true;
  1016. }
  1017. */
  1018. if (Validation::date($date, $format) && Validation::time($time)) {
  1019. // after/before?
  1020. $seconds = isset($options['min']) ? $options['min'] : 1;
  1021. if (!empty($options['after']) && isset($this->data[$this->alias][$options['after']])) {
  1022. if (strtotime($this->data[$this->alias][$options['after']]) > strtotime($value) - $seconds) {
  1023. return false;
  1024. }
  1025. }
  1026. if (!empty($options['before']) && isset($this->data[$this->alias][$options['before']])) {
  1027. if (strtotime($this->data[$this->alias][$options['before']]) < strtotime($value) + $seconds) {
  1028. return false;
  1029. }
  1030. }
  1031. return true;
  1032. }
  1033. return false;
  1034. }
  1035. /**
  1036. * Validation of Date fields (as the core one is buggy!!!)
  1037. *
  1038. * @param options
  1039. * - dateFormat (defaults to 'ymd')
  1040. * - allowEmpty
  1041. * - after/before (fieldName to validate against)
  1042. * - min (defaults to 0 - equal is OK too)
  1043. * @return bool Success
  1044. */
  1045. public function validateDate($data, $options = []) {
  1046. $format = !empty($options['format']) ? $options['format'] : 'ymd';
  1047. if (is_array($data)) {
  1048. $value = array_shift($data);
  1049. } else {
  1050. $value = $data;
  1051. }
  1052. $dateTime = explode(' ', trim($value), 2);
  1053. $date = $dateTime[0];
  1054. if (!empty($options['allowEmpty']) && (empty($date) || $date == DEFAULT_DATE)) {
  1055. return true;
  1056. }
  1057. if (Validation::date($date, $format)) {
  1058. // after/before?
  1059. $days = !empty($options['min']) ? $options['min'] : 0;
  1060. if (!empty($options['after']) && isset($this->data[$this->alias][$options['after']])) {
  1061. if ($this->data[$this->alias][$options['after']] > date(FORMAT_DB_DATE, strtotime($date) - $days * DAY)) {
  1062. return false;
  1063. }
  1064. }
  1065. if (!empty($options['before']) && isset($this->data[$this->alias][$options['before']])) {
  1066. if ($this->data[$this->alias][$options['before']] < date(FORMAT_DB_DATE, strtotime($date) + $days * DAY)) {
  1067. return false;
  1068. }
  1069. }
  1070. return true;
  1071. }
  1072. return false;
  1073. }
  1074. /**
  1075. * Validation of Time fields
  1076. *
  1077. * @param array $options
  1078. * - timeFormat (defaults to 'hms')
  1079. * - allowEmpty
  1080. * - after/before (fieldName to validate against)
  1081. * - min/max (defaults to >= 1 - at least 1 minute apart)
  1082. * @return bool Success
  1083. */
  1084. public function validateTime($data, $options = []) {
  1085. if (is_array($data)) {
  1086. $value = array_shift($data);
  1087. } else {
  1088. $value = $data;
  1089. }
  1090. $dateTime = explode(' ', trim($value), 2);
  1091. $value = array_pop($dateTime);
  1092. if (Validation::time($value)) {
  1093. // after/before?
  1094. if (!empty($options['after']) && isset($this->data[$this->alias][$options['after']])) {
  1095. if ($this->data[$this->alias][$options['after']] >= $value) {
  1096. return false;
  1097. }
  1098. }
  1099. if (!empty($options['before']) && isset($this->data[$this->alias][$options['before']])) {
  1100. if ($this->data[$this->alias][$options['before']] <= $value) {
  1101. return false;
  1102. }
  1103. }
  1104. return true;
  1105. }
  1106. return false;
  1107. }
  1108. /**
  1109. * Validation of Date Fields (>= minDate && <= maxDate)
  1110. *
  1111. * @param options
  1112. * - min/max (TODO!!)
  1113. */
  1114. public function validateDateRange($data, $options = []) {
  1115. }
  1116. /**
  1117. * Validation of Time Fields (>= minTime && <= maxTime)
  1118. *
  1119. * @param options
  1120. * - min/max (TODO!!)
  1121. */
  1122. public function validateTimeRange($data, $options = []) {
  1123. }
  1124. /**
  1125. * Model validation rule for email addresses
  1126. *
  1127. * @return bool Success
  1128. */
  1129. public function validateUndisposable($data, $proceed = false) {
  1130. $email = array_shift($data);
  1131. if (empty($email)) {
  1132. return true;
  1133. }
  1134. return $this->isUndisposableEmail($email, false, $proceed);
  1135. }
  1136. /**
  1137. * NOW: can be set to work offline only (if server is down etc)
  1138. * Checks if a email is not from a garbage hoster
  1139. *
  1140. * @param string email (necessary)
  1141. * @return bool true if valid, else false
  1142. */
  1143. public function isUndisposableEmail($email, $onlineMode = false, $proceed = false) {
  1144. if (!isset($this->UndisposableEmail)) {
  1145. App::import('Vendor', 'undisposable/undisposable');
  1146. $this->UndisposableEmail = new UndisposableEmail();
  1147. }
  1148. if (!$onlineMode) {
  1149. // crashed with white screen of death otherwise... (if foreign page is 404)
  1150. $this->UndisposableEmail->useOnlineList(false);
  1151. }
  1152. if (!class_exists('Validation')) {
  1153. App::uses('Validation', 'Utility');
  1154. }
  1155. if (!Validation::email($email)) {
  1156. return false;
  1157. }
  1158. if ($this->UndisposableEmail->isUndisposableEmail($email) === false) {
  1159. // trigger log
  1160. $this->log('Disposable Email detected: ' . h($email) . ' (IP ' . env('REMOTE_ADDR') . ')', 'undisposable');
  1161. if ($proceed === true) {
  1162. return true;
  1163. }
  1164. return false;
  1165. }
  1166. return true;
  1167. }
  1168. /**
  1169. * Is blocked email?
  1170. * //TODO: move outside of MyModel?
  1171. *
  1172. * @return bool ifNotBlacklisted
  1173. */
  1174. public function validateNotBlocked($params) {
  1175. $email = array_shift($params);
  1176. if (!isset($this->Blacklist)) {
  1177. $this->Blacklist = ClassRegistry::init('Tools.Blacklist');
  1178. }
  1179. if ($this->Blacklist->isBlacklisted(Blacklist::TYPE_EMAIL, $email)) {
  1180. return false;
  1181. }
  1182. return true;
  1183. }
  1184. /**
  1185. * Set + guaranteeFields!
  1186. * Extends the core set function (only using data!!!)
  1187. *
  1188. * @param mixed $data
  1189. * @param mixed $data2 (optional)
  1190. * @param array $requiredFields Required fields
  1191. * @param array $fieldList Whitelist / Allowed fields
  1192. * @return array
  1193. */
  1194. public function set($data, $data2 = null, $requiredFields = [], $fieldList = []) {
  1195. if (!empty($requiredFields)) {
  1196. $data = $this->guaranteeFields($requiredFields, $data);
  1197. }
  1198. if (!empty($fieldList)) {
  1199. $data = $this->whitelist($fieldList, $data);
  1200. }
  1201. return parent::set($data, $data2);
  1202. }
  1203. /**
  1204. * @param array $fieldList
  1205. * @param array $data (optional)
  1206. * @return array
  1207. */
  1208. public function whitelist(array $fieldList, $data = null) {
  1209. $model = $this->alias;
  1210. if ($data === null) {
  1211. $data =& $this->data;
  1212. }
  1213. if (empty($data[$model])) {
  1214. return [];
  1215. }
  1216. foreach ($data[$model] as $key => $val) {
  1217. if (!in_array($key, $fieldList)) {
  1218. unset($data[$model][$key]);
  1219. }
  1220. }
  1221. return $data;
  1222. }
  1223. /**
  1224. * Instead of whitelisting this will remove all blacklisted keys.
  1225. *
  1226. * @param array $blacklist
  1227. * - array: fields to blacklist
  1228. * - boolean TRUE: removes all foreign_keys (_id)
  1229. * note: one-dimensional
  1230. * @return array
  1231. */
  1232. public function blacklist($blacklist, $data = null) {
  1233. $model = $this->alias;
  1234. if ($data === null) {
  1235. $data =& $this->data;
  1236. }
  1237. if (empty($data[$model])) {
  1238. return [];
  1239. }
  1240. if ($blacklist === true) {
  1241. foreach ($data[$model] as $key => $value) {
  1242. if (substr($key, -3, 3) === '_id') {
  1243. unset($data[$model][$key]);
  1244. }
  1245. }
  1246. return;
  1247. }
  1248. foreach ($blacklist as $key) {
  1249. if (isset($data[$model][$key])) {
  1250. unset($data[$model][$key]);
  1251. }
  1252. }
  1253. return $data;
  1254. }
  1255. /**
  1256. * Generate a whitelist, based on the current schema and a passed blacklist.
  1257. *
  1258. * @param array $blacklist
  1259. * @return array
  1260. */
  1261. public function generateWhitelistFromBlacklist(array $blacklist) {
  1262. return array_diff(array_keys($this->schema()), $blacklist);
  1263. }
  1264. /**
  1265. * Make sure required fields exists - in order to properly validate them
  1266. *
  1267. * @param array: field1, field2 - or field1, Model2.field1 etc
  1268. * @param array: data (optional, otherwise the array with the required fields will be returned)
  1269. * @return array
  1270. */
  1271. public function guaranteeFields($requiredFields, $data = null) {
  1272. $guaranteedFields = [];
  1273. foreach ($requiredFields as $column) {
  1274. if (strpos($column, '.') !== false) {
  1275. list($model, $column) = explode('.', $column, 2);
  1276. } else {
  1277. $model = $this->alias;
  1278. }
  1279. $guaranteedFields[$model][$column] = ''; # now field exists in any case!
  1280. }
  1281. if ($data === null) {
  1282. return $guaranteedFields;
  1283. }
  1284. if (!empty($guaranteedFields)) {
  1285. $data = Hash::merge($guaranteedFields, $data);
  1286. }
  1287. return $data;
  1288. }
  1289. /**
  1290. * Make certain fields a requirement for the form to validate
  1291. * (they must only be present - can still be empty, though!)
  1292. *
  1293. * @param array $fieldList
  1294. * @param bool $allowEmpty (or NULL to not touch already set elements)
  1295. * @return void
  1296. */
  1297. public function requireFields($requiredFields, $allowEmpty = null) {
  1298. if ($allowEmpty === null) {
  1299. $setAllowEmpty = true;
  1300. } else {
  1301. $setAllowEmpty = $allowEmpty;
  1302. }
  1303. foreach ($requiredFields as $column) {
  1304. if (strpos($column, '.') !== false) {
  1305. list($model, $column) = explode('.', $column, 2);
  1306. } else {
  1307. $model = $this->alias;
  1308. }
  1309. if ($model !== $this->alias) {
  1310. continue;
  1311. }
  1312. if (empty($this->validate[$column])) {
  1313. $this->validate[$column]['notEmpty'] = ['rule' => 'notEmpty', 'required' => true, 'allowEmpty' => $setAllowEmpty, 'message' => 'valErrMandatoryField'];
  1314. } else {
  1315. $keys = array_keys($this->validate[$column]);
  1316. if (!in_array('rule', $keys)) {
  1317. $key = array_shift($keys);
  1318. $this->validate[$column][$key]['required'] = true;
  1319. if (!isset($this->validate[$column][$key]['allowEmpty'])) {
  1320. $this->validate[$column][$key]['allowEmpty'] = $setAllowEmpty;
  1321. }
  1322. } else {
  1323. $keys['required'] = true;
  1324. if (!isset($keys['allowEmpty'])) {
  1325. $keys['allowEmpty'] = $setAllowEmpty;
  1326. }
  1327. $this->validate[$column] = $keys;
  1328. }
  1329. }
  1330. }
  1331. }
  1332. /**
  1333. * Shortcut method to find a specific entry via primary key.
  1334. *
  1335. * Either provide the id directly:
  1336. *
  1337. * $record = $this->Model->get($id);
  1338. *
  1339. * Or use
  1340. *
  1341. * $this->Model->id = $id;
  1342. * $record = $this->Model->get();
  1343. *
  1344. * @param mixed $id
  1345. * @param array $options Options for find(). Used to be fields array/string.
  1346. * @param array $contain Deprecated - use
  1347. * @return mixed
  1348. */
  1349. public function get($id = null, $options = [], $contain = []) {
  1350. if (is_array($id)) {
  1351. $column = $id[0];
  1352. $value = $id[1];
  1353. } else {
  1354. $column = $this->primaryKey;
  1355. $value = $id;
  1356. if ($value === null) {
  1357. $value = $this->id;
  1358. }
  1359. }
  1360. if (!$value) {
  1361. return [];
  1362. }
  1363. // BC
  1364. $fields = null;
  1365. if (is_string($options)) {
  1366. $fields = $options;
  1367. $options = [];
  1368. }
  1369. if (!empty($options) && !array_key_exists('fields', $options) && !array_key_exists('contain', $options)) {
  1370. $fields = $options;
  1371. $options = [];
  1372. }
  1373. if ($fields === '*') {
  1374. $fields = $this->alias . '.*';
  1375. } elseif (!empty($fields)) {
  1376. foreach ((array)$fields as $row => $field) {
  1377. if (strpos($field, '.') !== false) {
  1378. continue;
  1379. }
  1380. $fields[$row] = $this->alias . '.' . $field;
  1381. }
  1382. }
  1383. $options = [
  1384. 'conditions' => [$this->alias . '.' . $column => $value],
  1385. ] + $options;
  1386. // BC
  1387. if (!empty($fields)) {
  1388. $options['fields'] = $fields;
  1389. }
  1390. if (!empty($contain)) {
  1391. $options['contain'] = $contain;
  1392. }
  1393. return $this->find('first', $options);
  1394. }
  1395. /**
  1396. * Get all related entries that have been used so far
  1397. *
  1398. * @param string $modelName The related model
  1399. * @param string $groupField Field to group by
  1400. * @param string $type Find type
  1401. * @param array $options
  1402. * @return array
  1403. */
  1404. public function getRelatedInUse($modelName, $groupField = null, $type = 'all', $options = []) {
  1405. if ($groupField === null) {
  1406. $groupField = $this->belongsTo[$modelName]['foreignKey'];
  1407. }
  1408. $defaults = [
  1409. 'contain' => [$modelName],
  1410. 'group' => $groupField,
  1411. 'order' => $this->$modelName->order ? $this->$modelName->order : [$modelName . '.' . $this->$modelName->displayField => 'ASC'],
  1412. ];
  1413. if ($type === 'list') {
  1414. $defaults['fields'] = [$modelName . '.' . $this->$modelName->primaryKey, $modelName . '.' . $this->$modelName->displayField];
  1415. }
  1416. $options += $defaults;
  1417. return $this->find($type, $options);
  1418. }
  1419. /**
  1420. * Get all fields that have been used so far
  1421. *
  1422. * @param string $groupField Field to group by
  1423. * @param string $type Find type
  1424. * @param array $options
  1425. * @return array
  1426. */
  1427. public function getFieldInUse($groupField, $type = 'all', $options = []) {
  1428. $defaults = [
  1429. 'group' => $groupField,
  1430. 'order' => [$this->alias . '.' . $this->displayField => 'ASC'],
  1431. ];
  1432. if ($type === 'list') {
  1433. $defaults['fields'] = [$this->alias . '.' . $this->primaryKey, $this->alias . '.' . $this->displayField];
  1434. }
  1435. $options += $defaults;
  1436. return $this->find($type, $options);
  1437. }
  1438. /**
  1439. * Update a row with certain fields (dont use "Model" as super-key)
  1440. *
  1441. * @param int $id
  1442. * @param array $data
  1443. * @return bool|array Success
  1444. */
  1445. public function update($id, $data, $validate = false) {
  1446. $this->id = $id;
  1447. $options = [
  1448. 'validate' => $validate,
  1449. 'fieldList' => array_keys($data)
  1450. ];
  1451. return $this->save($data, $options);
  1452. }
  1453. /**
  1454. * Toggles Field (Important/Deleted/Primary etc)
  1455. *
  1456. * @param STRING fieldName
  1457. * @param int id (cleaned!)
  1458. * @return ARRAY record: [Model][values],...
  1459. */
  1460. public function toggleField($fieldName, $id) {
  1461. $record = $this->get($id, [$this->primaryKey, $fieldName]);
  1462. if (!empty($record) && !empty($fieldName) && $this->hasField($fieldName)) {
  1463. $record[$this->alias][$fieldName] = ($record[$this->alias][$fieldName] == 1 ? 0 : 1);
  1464. $this->id = $id;
  1465. $this->saveField($fieldName, $record[$this->alias][$fieldName]);
  1466. }
  1467. return $record;
  1468. }
  1469. /**
  1470. * Truncate TABLE (already validated, that table exists)
  1471. *
  1472. * @param string table [default:FALSE = current model table]
  1473. * @return bool Success
  1474. */
  1475. public function truncate($table = null) {
  1476. if (empty($table)) {
  1477. $table = $this->table;
  1478. }
  1479. $db = ConnectionManager::getDataSource($this->useDbConfig);
  1480. return $db->truncate($table);
  1481. }
  1482. /**
  1483. * Recursive Dropdown Lists
  1484. * NEEDS tree behavior, NEEDS lft, rght, parent_id (!)
  1485. * //FIXME
  1486. */
  1487. public function recursiveSelect($conditions = [], $attachTree = false, $spacer = '-- ') {
  1488. if ($attachTree) {
  1489. $this->Behaviors->load('Tree');
  1490. }
  1491. $data = $this->generateTreeList($conditions, null, null, $spacer);
  1492. return $data;
  1493. }
  1494. /**
  1495. * From http://othy.wordpress.com/2006/06/03/generatenestedlist/
  1496. * NEEDS parent_id
  1497. * //TODO refactor for 1.2
  1498. *
  1499. * @deprecated use generateTreeList instead
  1500. */
  1501. public function generateNestedList($conditions = null, $indent = '--') {
  1502. $cats = $this->find('threaded', ['conditions' => $conditions, 'fields' => [
  1503. $this->alias . '.' . $this->primaryKey,
  1504. $this->alias . '.' . $this->displayField,
  1505. $this->alias . '.parent_id']]);
  1506. return $this->_generateNestedList($cats, $indent);
  1507. }
  1508. /**
  1509. * From http://othy.wordpress.com/2006/06/03/generatenestedlist/
  1510. *
  1511. * @deprecated use generateTreeList instead
  1512. */
  1513. public function _generateNestedList($cats, $indent = '--', $level = 0) {
  1514. static $list = [];
  1515. $c = count($cats);
  1516. for ($i = 0; $i < $c; $i++) {
  1517. $list[$cats[$i][$this->alias][$this->primaryKey]] = str_repeat($indent, $level) . $cats[$i][$this->alias][$this->displayField];
  1518. if (!empty($cats[$i]['children'])) {
  1519. $this->_generateNestedList($cats[$i]['children'], $indent, $level + 1);
  1520. }
  1521. }
  1522. return $list;
  1523. }
  1524. }