BxDolStudioFormsQuery.php 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961
  1. <?php defined('BX_DOL') or die('hack attempt');
  2. /**
  3. * Copyright (c) UNA, Inc - https://una.io
  4. * MIT License - https://opensource.org/licenses/MIT
  5. *
  6. * @defgroup UnaStudio UNA Studio
  7. * @{
  8. */
  9. class BxDolStudioFormsQuery extends BxDolDb
  10. {
  11. function __construct()
  12. {
  13. parent::__construct();
  14. }
  15. function getForms($aParams, &$aItems, $bReturnCount = true)
  16. {
  17. $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
  18. $sSelectClause = "
  19. `tf`.`id` AS `id`,
  20. `tf`.`object` AS `object`,
  21. `tf`.`module` AS `module`,
  22. `tf`.`title` AS `title`,
  23. `tf`.`action` AS `action`,
  24. `tf`.`form_attrs` AS `form_attrs`,
  25. `tf`.`table` AS `table`,
  26. `tf`.`key` AS `key`,
  27. `tf`.`uri` AS `uri`,
  28. `tf`.`uri_title` AS `uri_title`,
  29. `tf`.`submit_name` AS `submit_name`,
  30. `tf`.`params` AS `params`,
  31. `tf`.`deletable` AS `deletable`,
  32. `tf`.`active` AS `active`,
  33. `tf`.`override_class_name` AS `override_class_name`,
  34. `tf`.`override_class_file` AS `override_class_file`";
  35. $sJoinClause = $sWhereClause = $sGroupClause = $sOrderClause = $sLimitClause = "";
  36. if(!isset($aParams['order']) || empty($aParams['order']))
  37. $sOrderClause = "ORDER BY `tf`.`title` ASC";
  38. switch($aParams['type']) {
  39. case 'by_id':
  40. $aMethod['name'] = 'getRow';
  41. $aMethod['params'][1] = array(
  42. 'id' => $aParams['value']
  43. );
  44. $sWhereClause = " AND `tf`.`id`=:id ";
  45. break;
  46. case 'by_object':
  47. $aMethod['name'] = 'getRow';
  48. $aMethod['params'][1] = [
  49. 'object' => $aParams['value'],
  50. ];
  51. $sWhereClause = "AND `tf`.`object`=:object ";
  52. break;
  53. case 'by_object_display':
  54. $aMethod['name'] = 'getRow';
  55. $aMethod['params'][1] = array(
  56. 'object' => $aParams['object'],
  57. 'display_name' => $aParams['display']
  58. );
  59. $sJoinClause = "LEFT JOIN `sys_form_displays` AS `td` ON `tf`.`object`=`td`.`object` ";
  60. $sWhereClause = "AND `td`.`object`=:object AND `td`.`display_name`=:display_name ";
  61. break;
  62. case 'by_module':
  63. $aMethod['params'][1] = array(
  64. 'module' => $aParams['value']
  65. );
  66. $sWhereClause = "AND `tf`.`module`=:module";
  67. break;
  68. case 'counter_by_modules':
  69. $aMethod['name'] = 'getPairs';
  70. $aMethod['params'][1] = 'module';
  71. $aMethod['params'][2] = 'counter';
  72. $sSelectClause .= ", COUNT(*) AS `counter`";
  73. $sGroupClause = "GROUP BY `tf`.`module`";
  74. break;
  75. case 'nested':
  76. $aMethod['name'] = 'getPairs';
  77. $aMethod['params'][1] = 'object';
  78. $aMethod['params'][2] = 'title';
  79. $aMethod['params'][3] = array(
  80. 'parent_form' => $aParams['parent_form']
  81. );
  82. $sSubQuery = "SELECT `value` FROM `sys_form_inputs` sfi WHERE `type`='nested_form' AND `object` = :parent_form ";
  83. if (!@empty($aParams['ids'])){
  84. $sSubQuery = "SELECT `value` FROM `sys_form_inputs` sfi WHERE `type`='nested_form' AND `object` = :parent_form AND `name` NOT IN (SELECT `input_name` FROM `sys_form_display_inputs` WHERE `id` IN(" . $aParams['ids'] . "))";
  85. }
  86. $sWhereClause = "AND `tf`.`parent_form`=:parent_form AND `object` NOT IN (" . $sSubQuery . ")";
  87. break;
  88. case 'export':
  89. $sSelectClause = "`tf`.*";
  90. break;
  91. case 'all':
  92. break;
  93. }
  94. $aMethod['params'][0] = "SELECT " . ($bReturnCount ? "SQL_CALC_FOUND_ROWS" : "") . $sSelectClause . "
  95. FROM `sys_objects_form` AS `tf` " . $sJoinClause . "
  96. WHERE 1 " . $sWhereClause . " " . $sGroupClause . " " . $sOrderClause . " " . $sLimitClause;
  97. $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
  98. if(!$bReturnCount)
  99. return !empty($aItems);
  100. return (int)$this->getOne("SELECT FOUND_ROWS()");
  101. }
  102. function isForm($sName)
  103. {
  104. $aForm = [];
  105. $this->getForms(['type' => 'by_object', 'value' => $sName], $aForm, false);
  106. return !empty($aForm) && is_array($aForm);
  107. }
  108. function addForm($aFields)
  109. {
  110. return $this->query("INSERT INTO `sys_objects_form` SET " . $this->arrayToSQL($aFields));
  111. }
  112. function updateForms($aParamsSet, $aParamsWhere = [])
  113. {
  114. if(empty($aParamsSet))
  115. return false;
  116. $sWhereClause = "1";
  117. if(!empty($aParamsWhere))
  118. $sWhereClause = $this->arrayToSQL($aParamsWhere, " AND ");
  119. return $this->query("UPDATE `sys_objects_form` SET " . $this->arrayToSQL($aParamsSet) . " WHERE " . $sWhereClause);
  120. }
  121. function updateFormByObject($sObject, $aFields)
  122. {
  123. return $this->query("UPDATE `sys_objects_form` SET " . $this->arrayToSQL($aFields) . " WHERE `object`=:object", [
  124. 'object' => $sObject
  125. ]);
  126. }
  127. function getDisplays($aParams, &$aItems, $bReturnCount = true)
  128. {
  129. $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
  130. $sSelectClause = "
  131. `td`.`id` AS `id`,
  132. `td`.`object` AS `object`,
  133. `td`.`display_name` AS `name`,
  134. `td`.`display_name` AS `display_name`,
  135. `td`.`module` AS `module`,
  136. `td`.`view_mode` AS `view_mode`,
  137. `td`.`title` AS `title`";
  138. $sJoinClause = $sWhereClause = $sGroupClause = $sOrderClause = $sLimitClause = "";
  139. if(!isset($aParams['order']) || empty($aParams['order']))
  140. $sOrderClause = "ORDER BY `td`.`title` ASC";
  141. switch($aParams['type']) {
  142. case 'by_id':
  143. $aMethod['name'] = 'getRow';
  144. $aMethod['params'][1] = array(
  145. 'id' => $aParams['value']
  146. );
  147. $sWhereClause = " AND `td`.`id`=:id ";
  148. $sLimitClause = "LIMIT 1";
  149. break;
  150. case 'by_object_display':
  151. $aMethod['name'] = 'getRow';
  152. $aMethod['params'][1] = array(
  153. 'object' => $aParams['object'],
  154. 'display_name' => $aParams['display']
  155. );
  156. $sWhereClause = " AND `td`.`object`=:object AND `td`.`display_name`=:display_name ";
  157. $sLimitClause = "LIMIT 1";
  158. break;
  159. case 'by_name':
  160. $aMethod['params'][1] = array(
  161. 'display_name' => $aParams['value']
  162. );
  163. $sWhereClause = " AND `td`.`display_name`=:display_name ";
  164. $sLimitClause = "LIMIT 1";
  165. break;
  166. case 'by_module':
  167. $aMethod['params'][1] = array(
  168. 'module' => $aParams['value']
  169. );
  170. $sWhereClause = " AND `td`.`module`=:module ";
  171. break;
  172. case 'by_module_with_forms':
  173. $aMethod['params'][1] = array(
  174. 'module' => $aParams['value']
  175. );
  176. $sSelectClause .= ", `tf`.`title` AS `form_title`";
  177. $sJoinClause = "LEFT JOIN `sys_objects_form` AS `tf` ON `td`.`object`=`tf`.`object` ";
  178. $sWhereClause = " AND `td`.`module`=:module ";
  179. $sOrderClause = "ORDER BY `td`.`object` ASC, `td`.`title` ASC";
  180. break;
  181. case 'by_object':
  182. $aMethod['params'][1] = array(
  183. 'object' => $aParams['value']
  184. );
  185. $sWhereClause = " AND `td`.`object`=:object ";
  186. break;
  187. case 'export_by_object':
  188. $aMethod['params'][1] = [
  189. 'object' => $aParams['value']
  190. ];
  191. $sSelectClause = "`td`.*";
  192. $sWhereClause = " AND `td`.`object`=:object ";
  193. break;
  194. case 'counter_by_forms':
  195. $aMethod['name'] = 'getPairs';
  196. $aMethod['params'][1] = 'object';
  197. $aMethod['params'][2] = 'counter';
  198. $sSelectClause .= ", COUNT(*) AS `counter`";
  199. $sGroupClause = "GROUP BY `td`.`object`";
  200. break;
  201. case 'counter_by_modules':
  202. $aMethod['name'] = 'getPairs';
  203. $aMethod['params'][1] = 'module';
  204. $aMethod['params'][2] = 'counter';
  205. $sSelectClause .= ", COUNT(*) AS `counter`";
  206. $sGroupClause = "GROUP BY `td`.`module`";
  207. break;
  208. case 'all':
  209. break;
  210. case 'all_with_forms':
  211. $sSelectClause .= ", `tf`.`title` AS `form_title`";
  212. $sJoinClause = "LEFT JOIN `sys_objects_form` AS `tf` ON `td`.`object`=`tf`.`object` ";
  213. $sOrderClause = "ORDER BY `td`.`object` ASC, `td`.`title` ASC";
  214. break;
  215. }
  216. $aMethod['params'][0] = "SELECT " . ($bReturnCount ? "SQL_CALC_FOUND_ROWS" : "") . $sSelectClause . "
  217. FROM `sys_form_displays` AS `td` " . $sJoinClause . "
  218. WHERE 1 " . $sWhereClause . " " . $sGroupClause . " " . $sOrderClause . " " . $sLimitClause;
  219. $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
  220. if(!$bReturnCount)
  221. return !empty($aItems);
  222. return (int)$this->getOne("SELECT FOUND_ROWS()");
  223. }
  224. function isDisplay($sName, $sDisplay)
  225. {
  226. $aDisplay = [];
  227. $this->getDisplays(['type' => 'by_object_display', 'object' => $sName, 'display' => $sDisplay], $aDisplay, false);
  228. return !empty($aDisplay) && is_array($aDisplay);
  229. }
  230. function addDisplay($aFields)
  231. {
  232. return $this->query("INSERT INTO `sys_form_displays` SET " . $this->arrayToSQL($aFields));
  233. }
  234. function updateDisplayByObjectAndName($sObject, $sName, $aFields)
  235. {
  236. return $this->query("UPDATE `sys_form_displays` SET " . $this->arrayToSQL($aFields) . " WHERE `object`=:object AND `display_name`=:display_name ", [
  237. 'object' => $sObject,
  238. 'display_name' => $sName
  239. ]);
  240. }
  241. function getInputs($aParams, &$aItems, $bReturnCount = true)
  242. {
  243. $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
  244. $sSelectClause = $sFromClause = $sJoinClause = $sWhereClause = $sGroupClause = $sOrderClause = $sLimitClause = "";
  245. $sSelectClause = "
  246. `tdi`.`id` AS `id`,
  247. `ti`.`name` AS `name`,
  248. `ti`.`type` AS `type`,
  249. `ti`.`caption_system` AS `caption_system`,
  250. `ti`.`caption` AS `caption`,
  251. `tdi`.`visible_for_levels` AS `visible_for_levels`,
  252. `tdi`.`active` AS `active`,
  253. `tdi`.`order` AS `order`";
  254. $sFromClause = "`sys_form_display_inputs` AS `tdi`";
  255. $sJoinClause = "LEFT JOIN `sys_form_inputs` AS `ti` ON `tdi`.`input_name`=`ti`.`name` ";
  256. if(!isset($aParams['order']) || empty($aParams['order']))
  257. $sOrderClause = "ORDER BY `tdi`.`order` ASC";
  258. switch($aParams['type']) {
  259. case 'by_id':
  260. $aMethod['name'] = 'getRow';
  261. $aMethod['params'][1] = array(
  262. 'id' => $aParams['value']
  263. );
  264. $sWhereClause = " AND `tdi`.`id`=:id ";
  265. break;
  266. case 'by_object_id':
  267. $aMethod['name'] = 'getRow';
  268. $aMethod['params'][1] = array(
  269. 'object' => $aParams['object'],
  270. 'id' => $aParams['id']
  271. );
  272. $sSelectClause = "`ti`.*, `tdi`.`id` AS `di_id`, `tdi`.`display_name` AS `display_name`, `tdi`.`visible_for_levels` AS `visible_for_levels`";
  273. $sWhereClause = " AND `ti`.`object`=:object AND `tdi`.`id`=:id ";
  274. break;
  275. case 'by_object_display':
  276. $aMethod['params'][1] = array(
  277. 'object' => $aParams['object'],
  278. 'display_name' => $aParams['display']
  279. );
  280. $sWhereClause = " AND `ti`.`object`=:object AND `tdi`.`display_name`=:display_name ";
  281. if(isset($aParams['active'])) {
  282. $aMethod['params'][1]['active'] = (int)$aParams['active'];
  283. $sWhereClause .= " AND `tdi`.`active`=:active ";
  284. }
  285. break;
  286. case 'by_object_name_filter':
  287. $aMethod['name'] = 'getColumn';
  288. $aMethod['params'][1] = array(
  289. 'object' => $aParams['object'],
  290. 'name_filter' => $aParams['name_filter']
  291. );
  292. $sSelectClause = "DISTINCT `ti`.`name` AS `name`";
  293. $sWhereClause = " AND `ti`.`object`=:object AND `ti`.`name` LIKE (:name_filter) ";
  294. $sOrderClause = "ORDER BY LENGTH(`ti`.`name`) ASC, `ti`.`name` ASC";
  295. break;
  296. case 'dump_inputs':
  297. $aMethod['params'][1] = array(
  298. 'object' => $aParams['value']
  299. );
  300. $sSelectClause = "`ti`.*";
  301. $sFromClause = "`sys_form_inputs` AS `ti`";
  302. $sJoinClause = "";
  303. $sWhereClause = " AND `ti`.`object`=:object ";
  304. $sOrderClause = "";
  305. break;
  306. case 'dump_display_inputs':
  307. $sSelectClause = "`tdi`.*";
  308. $sJoinClause = "";
  309. $sWhereClause = " AND `tdi`.`display_name` IN (" . $this->implode_escape($aParams['displays']) . ") ";
  310. $sOrderClause = "";
  311. break;
  312. case 'dump_connections':
  313. $aMethod['params'][1] = array(
  314. 'object' => $aParams['value']
  315. );
  316. $sSelectClause = "`tdi`.*";
  317. $sJoinClause .= "LEFT JOIN `sys_form_displays` AS `td` ON `tdi`.`display_name`=`td`.`display_name` ";
  318. $sWhereClause = " AND `td`.`object`=:object AND `ti`.`object`=:object ";
  319. $sOrderClause = "ORDER BY `tdi`.`display_name` ASC, `tdi`.`order` ASC";
  320. break;
  321. case 'counter_by_displays':
  322. $aMethod['name'] = 'getPairs';
  323. $aMethod['params'][1] = 'display_name';
  324. $aMethod['params'][2] = 'counter';
  325. $sSelectClause = "`tdi`.`display_name` AS `display_name`, COUNT(`tdi`.`display_name`) AS `counter`";
  326. $sJoinClause = "";
  327. $sGroupClause = "GROUP BY `tdi`.`display_name`";
  328. break;
  329. case 'counter_by_modules':
  330. $aMethod['name'] = 'getPairs';
  331. $aMethod['params'][1] = 'module';
  332. $aMethod['params'][2] = 'counter';
  333. $sSelectClause = "`ti`.`module` AS `module`, COUNT(*) AS `counter`";
  334. $sFromClause = "`sys_form_inputs` AS `ti`";
  335. $sJoinClause = "";
  336. $sGroupClause = "GROUP BY `ti`.`module`";
  337. $sOrderClause = "";
  338. break;
  339. case 'all':
  340. break;
  341. }
  342. $aMethod['params'][0] = "SELECT " . ($bReturnCount ? "SQL_CALC_FOUND_ROWS" : "") . " " . $sSelectClause . "
  343. FROM " . $sFromClause . " " . $sJoinClause . "
  344. WHERE 1 " . $sWhereClause . " " . $sGroupClause . " " . $sOrderClause . " " . $sLimitClause;
  345. $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
  346. if(!$bReturnCount)
  347. return !empty($aItems);
  348. return (int)$this->getOne("SELECT FOUND_ROWS()");
  349. }
  350. function isInput($sObject, $sName)
  351. {
  352. return (int)$this->getOne("SELECT `id` FROM `sys_form_inputs` WHERE `object`=:object AND `name`=:name LIMIT 1", [
  353. 'object' => $sObject,
  354. 'name' => $sName
  355. ]) > 0;
  356. }
  357. function isDisplayInput($sDisplay, $sInput)
  358. {
  359. return (int)$this->getOne("SELECT `id` FROM `sys_form_display_inputs` WHERE `display_name`=:display AND `input_name`=:input LIMIT 1", [
  360. 'display' => $sDisplay,
  361. 'input' => $sInput
  362. ]) > 0;
  363. }
  364. function addInput($aFields)
  365. {
  366. return $this->query("INSERT INTO `sys_form_inputs` SET " . $this->arrayToSQL($aFields));
  367. }
  368. function addDisplayInput($aFields)
  369. {
  370. return $this->query("INSERT INTO `sys_form_display_inputs` SET " . $this->arrayToSQL($aFields));
  371. }
  372. function updateInputByObjectAndName($sObject, $sName, $aFields)
  373. {
  374. return $this->query("UPDATE `sys_form_inputs` SET " . $this->arrayToSQL($aFields) . " WHERE `object`=:object AND `name`=:name ", [
  375. 'object' => $sObject,
  376. 'name' => $sName
  377. ]);
  378. }
  379. public function updateDisplayInputs($aParamsSet, $aParamsWhere = [])
  380. {
  381. if(empty($aParamsSet))
  382. return false;
  383. $sWhereClause = "1";
  384. if(!empty($aParamsWhere))
  385. $sWhereClause = $this->arrayToSQL($aParamsWhere, " AND ");
  386. return $this->query("UPDATE `sys_form_display_inputs` SET " . $this->arrayToSQL($aParamsSet) . " WHERE " . $sWhereClause);
  387. }
  388. function updateDisplayInputByDisplayAndInput($sDisplay, $sInput, $aFields)
  389. {
  390. return $this->query("UPDATE `sys_form_display_inputs` SET " . $this->arrayToSQL($aFields) . " WHERE `display_name`=:display_name AND `input_name`=:input_name ", [
  391. 'display_name' => $sDisplay,
  392. 'input_name' => $sInput
  393. ]);
  394. }
  395. function deleteInputs($aParams)
  396. {
  397. $aBindings = array();
  398. $sWhereClause = $sLimitClause = "";
  399. switch($aParams['type']) {
  400. case 'by_id':
  401. if(isset($aParams['object'], $aParams['name'])) {
  402. $sSql = $this->prepare("DELETE FROM `tdi` USING `sys_form_display_inputs` AS `tdi` LEFT JOIN `sys_form_displays` AS `td` ON `tdi`.`display_name`=`td`.`display_name` WHERE `td`.`object`=? AND `tdi`.`input_name`=?", $aParams['object'], $aParams['name']);
  403. $this->query($sSql);
  404. }
  405. $aBindings['id'] = $aParams['value'];
  406. $sWhereClause = " AND `ti`.`id`=:id ";
  407. break;
  408. case 'all':
  409. break;
  410. }
  411. $sSql = "DELETE FROM `ti` USING `sys_form_inputs` AS `ti` WHERE 1 " . $sWhereClause . " " . $sLimitClause;
  412. return (int)$this->query($sSql, $aBindings) > 0;
  413. }
  414. function checkInputsInDisplays($sObject, $sDisplayName)
  415. {
  416. $aDisplay = array();
  417. $this->getDisplays(array('type' => 'by_object_display', 'object' => $sObject, 'display' => $sDisplayName), $aDisplay, false);
  418. if(empty($aDisplay) || !is_array($aDisplay))
  419. return false;
  420. $sSql = $this->prepare("DELETE FROM `tdi` USING `sys_form_display_inputs` AS `tdi` LEFT JOIN `sys_form_inputs` AS `ti` ON `tdi`.`input_name`=`ti`.`name` WHERE 1 AND `tdi`.`display_name`=? AND `ti`.`id` IS NULL", $sDisplayName);
  421. $this->query($sSql);
  422. $sSql = $this->prepare("INSERT INTO `sys_form_display_inputs`(`display_name`, `input_name`) SELECT ? AS `display_name`,`ti`.`name` AS `input_name` FROM `sys_form_inputs` AS `ti` LEFT JOIN `sys_form_display_inputs` AS `tdi` ON `ti`.`name`=`tdi`.`input_name` AND `tdi`.`display_name`=? WHERE 1 AND `ti`.`object`=? AND `tdi`.`id` IS NULL", $sDisplayName, $sDisplayName, $sObject);
  423. return (int)$this->query($sSql) > 0;
  424. }
  425. function getInputOrderMax($sDisplayName)
  426. {
  427. $sSql = $this->prepare("SELECT MAX(`order`) FROM `sys_form_display_inputs` WHERE `display_name`=? LIMIT 1", $sDisplayName);
  428. return (int)$this->getOne($sSql);
  429. }
  430. function getLists($aParams, &$aItems, $bReturnCount = true)
  431. {
  432. $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
  433. $sSelectClause = $sJoinClause = $sWhereClause = $sGroupClause = $sOrderClause = $sLimitClause = "";
  434. if(!isset($aParams['order']) || empty($aParams['order']))
  435. $sOrderClause = "ORDER BY `tl`.`key` ASC";
  436. switch($aParams['type']) {
  437. case 'by_id':
  438. $aMethod['name'] = 'getRow';
  439. $aMethod['params'][1] = array(
  440. 'id' => $aParams['value']
  441. );
  442. $sWhereClause = " AND `tl`.`id`=:id ";
  443. break;
  444. case 'by_key':
  445. $aMethod['name'] = 'getRow';
  446. $aMethod['params'][1] = array(
  447. 'key' => $aParams['value']
  448. );
  449. $sWhereClause = " AND `tl`.`key`=:key ";
  450. break;
  451. case 'by_module':
  452. $aMethod['params'][1] = array(
  453. 'module' => $aParams['value']
  454. );
  455. $sWhereClause = " AND `tl`.`module`=:module ";
  456. break;
  457. case 'pairs_list_values':
  458. $aMethod['name'] = 'getPairs';
  459. $aMethod['params'][1] = 'key';
  460. $aMethod['params'][2] = 'values';
  461. $sSelectClause = ",COUNT( `tv`.`id`) AS `values`";
  462. $sJoinClause = "LEFT JOIN `sys_form_pre_values` AS `tv` ON `tl`.`key`=`tv`.`Key`";
  463. $sGroupClause = "GROUP BY `tl`.`id`";
  464. break;
  465. case 'counter_by_modules':
  466. $aMethod['name'] = 'getPairs';
  467. $aMethod['params'][1] = 'module';
  468. $aMethod['params'][2] = 'counter';
  469. $sSelectClause = ", COUNT(*) AS `counter`";
  470. $sGroupClause = "GROUP BY `tl`.`module`";
  471. break;
  472. case 'all_for_sets':
  473. $sWhereClause = "AND `tl`.`use_for_sets`='1'";
  474. break;
  475. case 'all':
  476. break;
  477. }
  478. $aMethod['params'][0] = "SELECT " . ($bReturnCount ? "SQL_CALC_FOUND_ROWS" : "") . "
  479. `tl`.`id` AS `id`,
  480. `tl`.`module` AS `module`,
  481. `tl`.`key` AS `key`,
  482. `tl`.`title` AS `title`,
  483. `tl`.`use_for_sets` AS `use_for_sets`,
  484. `tl`.`extendable` AS `extendable`" . $sSelectClause . "
  485. FROM `sys_form_pre_lists` AS `tl` " . $sJoinClause . "
  486. WHERE 1 " . $sWhereClause . " " . $sGroupClause . " " . $sOrderClause . " " . $sLimitClause;
  487. $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
  488. if(!$bReturnCount)
  489. return !empty($aItems);
  490. return (int)$this->getOne("SELECT FOUND_ROWS()");
  491. }
  492. function updateList($iId, $aFields)
  493. {
  494. $sSql = "UPDATE `sys_form_pre_lists` SET `" . implode("`=?, `", array_keys($aFields)) . "`=? WHERE `id`=?";
  495. $sSql = call_user_func_array(array($this, 'prepare'), array_merge(array($sSql), array_values($aFields), array($iId)));
  496. return $this->query($sSql);
  497. }
  498. function isListUsedInSet($sKey)
  499. {
  500. bx_import('BxDolForm');
  501. $sSql = $this->prepare("SELECT
  502. COUNT( DISTINCT `ti`.`id`) AS `id`
  503. FROM `sys_form_pre_lists` AS `tl`
  504. LEFT JOIN `sys_form_inputs` AS `ti` ON CONCAT('" . BX_DATA_LISTS_KEY_PREFIX . "', `tl`.`key`)=`ti`.`values` AND `ti`.`type` IN ('select_multiple', 'checkbox_set')
  505. WHERE 1 AND `tl`.`key`=?", $sKey);
  506. return (int)$this->getOne($sSql) > 0;
  507. }
  508. function getCategories($aParams, &$aItems, $bReturnCount = true)
  509. {
  510. $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
  511. $sSelectClause = $sJoinClause = $sWhereClause = $sGroupClause = $sOrderClause = $sLimitClause = "";
  512. if(!isset($aParams['order']) || empty($aParams['order']))
  513. $sOrderClause = "ORDER BY `tv`.`module` ASC";
  514. switch($aParams['type']) {
  515. case 'by_id':
  516. $aMethod['name'] = 'getRow';
  517. $aMethod['params'][1] = array(
  518. 'id' => $aParams['value']
  519. );
  520. $sWhereClause = " AND `tv`.`id`=:id ";
  521. break;
  522. case 'counter_by_modules':
  523. $aMethod['name'] = 'getPairs';
  524. $aMethod['params'][1] = 'module';
  525. $aMethod['params'][2] = 'counter';
  526. $sSelectClause = ", `tv`.`module` AS `module`, COUNT(`tv`.`id`) AS `counter`";
  527. $sGroupClause = "GROUP BY `tv`.`module`";
  528. break;
  529. case 'all':
  530. break;
  531. }
  532. $aMethod['params'][0] = "SELECT " . ($bReturnCount ? "SQL_CALC_FOUND_ROWS" : "") . "
  533. `tv`.`id` AS `id`,
  534. `tv`.`Value` AS `value`,
  535. `tv`.`Value` AS `Value` " . $sSelectClause . "
  536. FROM `sys_categories` AS `tv` " . $sJoinClause . "
  537. WHERE 1 " . $sWhereClause . " " . $sGroupClause . " " . $sOrderClause . " " . $sLimitClause;
  538. $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
  539. if(!$bReturnCount)
  540. return !empty($aItems);
  541. return (int)$this->getOne("SELECT FOUND_ROWS()");
  542. }
  543. function deleteCategories($CategoryId)
  544. {
  545. $sSql = "DELETE FROM `sys_categories2objects` WHERE `category_id` = :category_id";
  546. $aBindings = array(
  547. 'category_id' => $CategoryId
  548. );
  549. return $this->query($sSql, $aBindings);
  550. }
  551. function getValues($aParams, &$aItems, $bReturnCount = true)
  552. {
  553. $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
  554. $sSelectClause = $sJoinClause = $sWhereClause = $sGroupClause = $sOrderClause = $sLimitClause = "";
  555. if(!isset($aParams['order']) || empty($aParams['order']))
  556. $sOrderClause = "ORDER BY `tv`.`Order` ASC";
  557. switch($aParams['type']) {
  558. case 'by_id':
  559. $aMethod['name'] = 'getRow';
  560. $aMethod['params'][1] = array(
  561. 'id' => $aParams['value']
  562. );
  563. $sWhereClause = " AND `tv`.`id`=:id ";
  564. break;
  565. case 'by_key':
  566. $aMethod['params'][1] = array(
  567. 'key' => $aParams['value']
  568. );
  569. $sWhereClause = " AND `tv`.`Key`=:key ";
  570. break;
  571. case 'by_key_key_value':
  572. $aMethod['name'] = 'getAllWithKey';
  573. $aMethod['params'][1] = 'value';
  574. $aMethod['params'][2] = array(
  575. 'key' => $aParams['value']
  576. );
  577. $sWhereClause = " AND `tv`.`Key`=:key ";
  578. break;
  579. case 'counter_by_lists':
  580. $aMethod['name'] = 'getPairs';
  581. $aMethod['params'][1] = 'key';
  582. $aMethod['params'][2] = 'counter';
  583. $sSelectClause = ", COUNT(*) AS `counter`";
  584. $sGroupClause = "GROUP BY `tv`.`Key`";
  585. break;
  586. case 'counter_by_modules':
  587. $aMethod['name'] = 'getPairs';
  588. $aMethod['params'][1] = 'module';
  589. $aMethod['params'][2] = 'counter';
  590. $sSelectClause = ", `tl`.`module` AS `module`, COUNT(`tv`.`id`) AS `counter`";
  591. $sJoinClause = "LEFT JOIN `sys_form_pre_lists` AS `tl` ON `tv`.`Key`=`tl`.`key`";
  592. $sGroupClause = "GROUP BY `tl`.`module`";
  593. break;
  594. case 'all':
  595. break;
  596. }
  597. $aMethod['params'][0] = "SELECT " . ($bReturnCount ? "SQL_CALC_FOUND_ROWS" : "") . "
  598. `tv`.`id` AS `id`,
  599. `tv`.`Key` AS `key`,
  600. `tv`.`Key` AS `Key`,
  601. `tv`.`Value` AS `value`,
  602. `tv`.`Value` AS `Value`,
  603. `tv`.`LKey` AS `lkey`,
  604. `tv`.`LKey` AS `LKey`,
  605. `tv`.`LKey2` AS `lkey2`,
  606. `tv`.`LKey2` AS `LKey2`,
  607. `tv`.`Data` AS `data`,
  608. `tv`.`Data` AS `Data`,
  609. `tv`.`Order` AS `order`,
  610. `tv`.`Order` AS `Order`" . $sSelectClause . "
  611. FROM `sys_form_pre_values` AS `tv` " . $sJoinClause . "
  612. WHERE 1 " . $sWhereClause . " " . $sGroupClause . " " . $sOrderClause . " " . $sLimitClause;
  613. $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
  614. if(!$bReturnCount)
  615. return !empty($aItems);
  616. return (int)$this->getOne("SELECT FOUND_ROWS()");
  617. }
  618. function deleteValues($aParams)
  619. {
  620. $aBindings = array();
  621. $sWhereClause = $sLimitClause = "";
  622. switch($aParams['type']) {
  623. case 'by_key':
  624. $aBindings['key'] = $aParams['value'];
  625. $sWhereClause = " AND `tv`.`Key`=:key ";
  626. break;
  627. case 'all':
  628. break;
  629. }
  630. $sSql = "DELETE FROM `tv` USING `sys_form_pre_values` AS `tv` WHERE 1 " . $sWhereClause . " " . $sLimitClause;
  631. return $this->query($sSql, $aBindings) !== false;
  632. }
  633. function getValuesOrderMax($sKey)
  634. {
  635. $sSql = $this->prepare("SELECT MAX(`Order`) FROM `sys_form_pre_values` WHERE `Key`=? LIMIT 1", $sKey);
  636. return (int)$this->getOne($sSql);
  637. }
  638. function getSearchForms($aParams, &$aItems, $bReturnCount = true)
  639. {
  640. $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
  641. $sSelectClause = $sJoinClause = $sWhereClause = $sGroupClause = $sOrderClause = $sLimitClause = "";
  642. if(!isset($aParams['order']) || empty($aParams['order']))
  643. $sOrderClause = "ORDER BY `tf`.`title` ASC";
  644. switch($aParams['type']) {
  645. case 'by_id':
  646. $aMethod['name'] = 'getRow';
  647. $aMethod['params'][1] = array(
  648. 'id' => $aParams['id']
  649. );
  650. $sWhereClause = " AND `tf`.`id`=:id ";
  651. break;
  652. case 'by_module':
  653. $aMethod['params'][1] = array(
  654. 'module' => $aParams['module']
  655. );
  656. $sWhereClause = "AND `tf`.`module`=:module";
  657. break;
  658. case 'counter_by_modules':
  659. $aMethod['name'] = 'getPairs';
  660. $aMethod['params'][1] = 'module';
  661. $aMethod['params'][2] = 'counter';
  662. $sSelectClause = ", COUNT(*) AS `counter`";
  663. $sGroupClause = "GROUP BY `tf`.`module`";
  664. case 'all':
  665. break;
  666. }
  667. $aMethod['params'][0] = "SELECT " . ($bReturnCount ? "SQL_CALC_FOUND_ROWS" : "") . "
  668. `tf`.*" . $sSelectClause . "
  669. FROM `sys_objects_search_extended` AS `tf` " . $sJoinClause . "
  670. WHERE 1 " . $sWhereClause . " " . $sGroupClause . " " . $sOrderClause . " " . $sLimitClause;
  671. $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
  672. if(!$bReturnCount)
  673. return !empty($aItems);
  674. return (int)$this->getOne("SELECT FOUND_ROWS()");
  675. }
  676. function getSearchFields($aParams, &$aItems, $bReturnCount = true)
  677. {
  678. $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
  679. $sSelectClause = $sFromClause = $sJoinClause = $sWhereClause = $sGroupClause = $sOrderClause = $sLimitClause = "";
  680. if(!isset($aParams['order']) || empty($aParams['order']))
  681. $sOrderClause = "ORDER BY `tfld`.`order` ASC";
  682. switch($aParams['type']) {
  683. case 'by_id':
  684. $aMethod['name'] = 'getRow';
  685. $aMethod['params'][1] = array(
  686. 'id' => $aParams['id']
  687. );
  688. $sWhereClause = " AND `tfld`.`id`=:id ";
  689. break;
  690. case 'by_object':
  691. $aMethod['params'][1] = array(
  692. 'object' => $aParams['object']
  693. );
  694. $sWhereClause = "AND `tfld`.`object`=:object";
  695. break;
  696. case 'counter_by_modules':
  697. $aMethod['name'] = 'getPairs';
  698. $aMethod['params'][1] = 'module';
  699. $aMethod['params'][2] = 'counter';
  700. $sSelectClause = ", COUNT(*) AS `counter`";
  701. $sGroupClause = "GROUP BY `tfld`.`module`";
  702. $sOrderClause = "";
  703. break;
  704. case 'all':
  705. break;
  706. }
  707. $aMethod['params'][0] = "SELECT " . ($bReturnCount ? "SQL_CALC_FOUND_ROWS" : "") . "
  708. `tfld`.*" . $sSelectClause . "
  709. FROM `sys_search_extended_fields` AS `tfld` " . $sJoinClause . "
  710. WHERE 1 " . $sWhereClause . " " . $sGroupClause . " " . $sOrderClause . " " . $sLimitClause;
  711. $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
  712. if(!$bReturnCount)
  713. return !empty($aItems);
  714. return (int)$this->getOne("SELECT FOUND_ROWS()");
  715. }
  716. function getSortableFields($aParams, &$aItems, $bReturnCount = true)
  717. {
  718. $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
  719. $sSelectClause = $sFromClause = $sJoinClause = $sWhereClause = $sGroupClause = $sOrderClause = $sLimitClause = "";
  720. if(!isset($aParams['order']) || empty($aParams['order']))
  721. $sOrderClause = "ORDER BY `tfld`.`order` ASC";
  722. switch($aParams['type']) {
  723. case 'by_id':
  724. $aMethod['name'] = 'getRow';
  725. $aMethod['params'][1] = array(
  726. 'id' => $aParams['id']
  727. );
  728. $sWhereClause = " AND `tfld`.`id`=:id ";
  729. break;
  730. case 'by_object':
  731. $aMethod['params'][1] = array(
  732. 'object' => $aParams['object']
  733. );
  734. $sWhereClause = "AND `tfld`.`object`=:object";
  735. break;
  736. case 'counter_by_modules':
  737. $aMethod['name'] = 'getPairs';
  738. $aMethod['params'][1] = 'module';
  739. $aMethod['params'][2] = 'counter';
  740. $sSelectClause = ", COUNT(*) AS `counter`";
  741. $sGroupClause = "GROUP BY `tfld`.`module`";
  742. $sOrderClause = "";
  743. break;
  744. case 'all':
  745. break;
  746. }
  747. $aMethod['params'][0] = "SELECT " . ($bReturnCount ? "SQL_CALC_FOUND_ROWS" : "") . "
  748. `tfld`.*" . $sSelectClause . "
  749. FROM `sys_search_extended_sorting_fields` AS `tfld` " . $sJoinClause . "
  750. WHERE 1 " . $sWhereClause . " " . $sGroupClause . " " . $sOrderClause . " " . $sLimitClause;
  751. $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
  752. if(!$bReturnCount)
  753. return !empty($aItems);
  754. return (int)$this->getOne("SELECT FOUND_ROWS()");
  755. }
  756. function alterAdd($sTable, $sField, $sType)
  757. {
  758. if($this->isFieldExists($sTable, $sField))
  759. return true;
  760. return (int)$this->query("ALTER TABLE `" . $sTable . "` ADD `" . $sField . "` " . $sType) > 0;
  761. }
  762. function alterChange($sTable, $sFieldOld, $sFieldNew, $sTypeNew)
  763. {
  764. if(!$this->isFieldExists($sTable, $sFieldOld))
  765. return false;
  766. if(strcmp($sFieldOld, $sFieldNew) !== 0 && $this->isFieldExists($sTable, $sFieldNew))
  767. return false;
  768. return (int)$this->query("ALTER TABLE `" . $sTable . "` CHANGE `" . $sFieldOld . "` `" . $sFieldNew . "` " . $sTypeNew) > 0;
  769. }
  770. function alterRemove($sTable, $sField)
  771. {
  772. if(!$this->isFieldExists($sTable, $sField))
  773. return true;
  774. return (int)$this->query("ALTER TABLE `" . $sTable . "` DROP `" . $sField . "`") > 0;
  775. }
  776. }
  777. /** @} */