source: trunk/inc/classes/BxDolAclQuery.php @ 16013

Last change on this file since 16013 was 16013, checked in by Alexander Trofimov, 3 years ago

ACL - new user levels and fixes

File size: 13.0 KB
Line 
1<?php
2/**
3 * @package     Dolphin Core
4 * @copyright   Copyright (c) BoonEx Pty Limited - http://www.boonex.com/
5 * @license     CC-BY - http://creativecommons.org/licenses/by/3.0/
6 */
7defined('BX_DOL') or die('hack attempt');
8
9bx_import('BxDolDb');
10
11class BxDolAclQuery extends BxDolDb {
12    function __construct() {
13        if (isset($GLOBALS['bxDolClasses'][get_class($this)]))
14            trigger_error ('Multiple instances are not allowed for the class: ' . get_class($this), E_USER_ERROR);
15
16        parent::BxDolDb();
17    }
18
19    /**
20     * Prevent cloning the instance
21     */
22    public function __clone() {
23        if (isset($GLOBALS['bxDolClasses'][get_class($this)]))
24            trigger_error('Clone is not allowed for the class: ' . get_class($this), E_USER_ERROR);
25    }
26
27    /**
28     * Get singleton instance of the class
29     */
30    static function getInstance() {
31        if(!isset($GLOBALS['bxDolClasses'][__CLASS__]))
32            $GLOBALS['bxDolClasses'][__CLASS__] = new BxDolAclQuery();
33
34        return $GLOBALS['bxDolClasses'][__CLASS__];
35    }
36
37    function getLevels($aParams, &$aItems, $bReturnCount = true) {
38        $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
39        $sSelectClause = $sJoinClause = $sWhereClause = $sOrderClause = $sLimitClause = "";
40
41        if(!isset($aParams['order']) || empty($aParams['order']))
42           $sOrderClause = "ORDER BY `tal`.`Order` ASC";
43
44        switch($aParams['type']) {
45            case 'by_id':
46                $aMethod['name'] = 'getRow';
47                $sWhereClause .= $this->prepare("AND `tal`.`ID`=?", $aParams['value']);
48                $sLimitClause .= "LIMIT 1";
49                break;
50            case 'all_active':
51                $sWhereClause .= "AND `tal`.`Active`='yes'";
52                break;
53            case 'all_active_purchasble_pair':
54                $aMethod['name'] = "getPairs";
55                $aMethod['params'][1] = 'id';
56                $aMethod['params'][2] = 'name';
57                $sWhereClause .= "AND `tal`.`Active`='yes' AND `tal`.`Purchasable`='yes'";
58                break;
59            case 'all_active_pair':
60                $aMethod['name'] = "getPairs";
61                $aMethod['params'][1] = 'id';
62                $aMethod['params'][2] = 'name';
63                $sWhereClause .= "AND `tal`.`Active`='yes'";
64                break;   
65            case 'all_pair':
66                $aMethod['name'] = "getPairs";
67                $aMethod['params'][1] = 'id';
68                $aMethod['params'][2] = 'name';
69                break;
70            case 'all_order_id':
71                $sOrderClause = "ORDER BY `tal`.`ID` ASC";
72                break;
73            case 'all':
74                break;
75        }
76
77        $aMethod['params'][0] = "SELECT SQL_CALC_FOUND_ROWS
78                `tal`.`ID` AS `id`,
79                `tal`.`Name` AS `name`,
80                `tal`.`Icon` AS `icon`,
81                `tal`.`Description` AS `description`,
82                `tal`.`Active` AS `active`,
83                `tal`.`Purchasable` AS `purchasable`,
84                `tal`.`Removable` AS `removable`,
85                `tal`.`QuotaSize` AS `quota_size`,
86                `tal`.`QuotaNumber` AS `quota_number`,
87                `tal`.`QuotaMaxFileSize` AS `quota_max_file_size`,
88                `tal`.`Order` AS `order`" . $sSelectClause . "
89            FROM `sys_acl_levels` AS `tal` " . $sJoinClause . "
90            WHERE 1 " . $sWhereClause . " " . $sOrderClause . " " . $sLimitClause;
91        $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
92
93        if(!$bReturnCount)
94            return count($aItems) > 0;
95
96        return (int)$this->getOne("SELECT FOUND_ROWS()");
97    }
98
99    function getActions($aParams, &$aItems, $bReturnCount = true) {
100        $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
101        $sSelectClause = $sJoinClause = $sWhereClause = $sOrderClause = $sLimitClause = "";
102
103        if(!isset($aParams['order']) || empty($aParams['order']))
104           $sOrderClause = "ORDER BY `taa`.`Title` ASC";
105
106        switch($aParams['type']) {
107            case 'by_names':
108                $sWhereClause .= " AND `taa`.`Name` IN(" . $this->implode_escape($aParams['value']) . ")";
109                break;
110            case 'by_level_id':
111                $sSelectClause .= ", `tam`.`AllowedCount` AS `allowed_count`, `tam`.`AllowedPeriodLen` AS `allowed_period_len` ";
112                $sJoinClause .= "LEFT JOIN `sys_acl_matrix` AS `tam` ON `taa`.`ID`=`tam`.`IDAction` ";
113                $sWhereClause .= $this->prepare("AND `tam`.`IDLevel`=? AND (`taa`.`DisabledForLevels`='0' OR `taa`.`DisabledForLevels`&?=0)", $aParams['value'], pow(2, ($aParams['value'] - 1)));
114                break;
115            case 'by_level_id_key_id':
116                $aMethod['name'] = 'getAllWithKey';
117                $aMethod['params'][1] = 'id';
118                $sSelectClause .= ", `tam`.`AllowedCount` AS `allowed_count`, `tam`.`AllowedPeriodLen` AS `allowed_period_len` ";
119                $sJoinClause .= "LEFT JOIN `sys_acl_matrix` AS `tam` ON `taa`.`ID`=`tam`.`IDAction` ";
120                $sWhereClause .= $this->prepare("AND `tam`.`IDLevel`=?", $aParams['value']);
121                break;
122        }
123
124        $aMethod['params'][0] = "SELECT
125                `taa`.`ID` AS `id`,
126                `taa`.`Module` AS `module`,
127                `taa`.`Name` AS `name`,
128                `taa`.`Title` AS `title`,
129                `taa`.`Countable` AS `countable`,
130                `taa`.`DisabledForLevels` AS `disabled_for_levels`" . $sSelectClause . "
131            FROM `sys_acl_actions` AS `taa` " . $sJoinClause . "
132            WHERE 1 " . $sWhereClause . " " . $sOrderClause . " " . $sLimitClause;
133        $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
134
135        if(!$bReturnCount)
136            return count($aItems) > 0;
137
138        $sQuery = "SELECT
139                COUNT(`taa`.`ID`)
140            FROM `sys_acl_actions` AS `taa`" . $sJoinClause . "
141            WHERE 1 " . $sWhereClause . "
142            LIMIT 1";
143        return $this->getOne($sQuery);
144    }
145
146    function getPrices($aParams, &$aItems, $bReturnCount = true) {
147        $aMethod = array('name' => 'getAll', 'params' => array(0 => 'query'));
148        $sSelectClause = $sJoinClause = $sWhereClause = $sOrderClause = $sLimitClause = "";
149
150        if(!isset($aParams['order']) || empty($aParams['order']))
151           $sOrderClause = "ORDER BY `tap`.`Order` ASC";
152
153        switch($aParams['type']) {
154            case 'by_id':
155                $aMethod['name'] = 'getRow';
156                $sWhereClause .= $this->prepare("AND `tap`.`id`=?", $aParams['value']);
157                break;
158            case 'by_level_id':
159                $sWhereClause .= $this->prepare("AND `tap`.`IDLevel`=?", $aParams['value']);
160                break;
161            case 'by_level_id_pair':
162                $aMethod['name'] = "getPairs";
163                $aMethod['params'][1] = 'days';
164                $aMethod['params'][2] = 'price';
165                $sWhereClause .= $this->prepare("AND `tap`.`IDLevel`=?", $aParams['value']);
166                break;
167            case 'by_level_id_duration':
168                $aMethod['name'] = 'getRow';
169                $sWhereClause .= $this->prepare("AND `tap`.`IDLevel`=? AND `tap`.`Days`=?", $aParams['level_id'], $aParams['days']);
170                break;
171        }
172
173        $aMethod['params'][0] = "SELECT
174                `tap`.`id` AS `id`,
175                `tap`.`IDLevel` AS `level_id`,
176                `tap`.`Days` AS `days`,
177                `tap`.`Price` AS `price`,
178                `tap`.`Order` AS `order`" . $sSelectClause . "
179            FROM `sys_acl_level_prices` AS `tap` " . $sJoinClause . "
180            WHERE 1 " . $sWhereClause . " " . $sOrderClause . " " . $sLimitClause;
181        $aItems = call_user_func_array(array($this, $aMethod['name']), $aMethod['params']);
182
183        if(!$bReturnCount)
184            return count($aItems) > 0;
185
186        $sQuery = "SELECT
187                COUNT(`tap`.`id`)
188            FROM `sys_acl_level_prices` AS `tap`" . $sJoinClause . "
189            WHERE 1 " . $sWhereClause . "
190            LIMIT 1";
191        return $this->getOne($sQuery);
192    }
193
194    /**
195     * Fetch the last purchased/assigned membership that is still active for the given profile.
196     *
197     * NOTE. Don't use cache here, because it's causing an error, if a number of memberrship levels are purchased at the same time.
198     *
199     * fromMemory returns the same DateExpires because buyMembership function is called in cycle in the same session.
200     */
201    function getLevelCurrent($iProfileId, $iTime = 0) {
202        $iTime = $iTime == 0 ? time() : (int)$iTime;
203
204        $sSql = $this->prepare("
205            SELECT  `sys_acl_levels_members`.`IDLevel` as `id`,
206                    `sys_acl_levels`.`Name` AS `name`,
207                    `sys_acl_levels`.`QuotaSize` AS `quota_size`,
208                    `sys_acl_levels`.`QuotaNumber` AS `quota_number`,
209                    `sys_acl_levels`.`QuotaMaxFileSize` AS `quota_max_file_size`,
210                    UNIX_TIMESTAMP(`sys_acl_levels_members`.`DateStarts`) as `date_starts`,
211                    UNIX_TIMESTAMP(`sys_acl_levels_members`.`DateExpires`) as `date_expires`,
212                    `sys_acl_levels_members`.`TransactionID` AS `transaction_id`,
213                    `sys_profiles`.`status`
214            FROM `sys_acl_levels_members`
215            RIGHT JOIN `sys_profiles` ON `sys_acl_levels_members`.IDMember = `sys_profiles`.`id`
216                AND (`sys_acl_levels_members`.DateStarts IS NULL OR `sys_acl_levels_members`.DateStarts <= FROM_UNIXTIME(?))
217                AND (`sys_acl_levels_members`.DateExpires IS NULL OR `sys_acl_levels_members`.DateExpires > FROM_UNIXTIME(?))
218            LEFT JOIN `sys_acl_levels` ON `sys_acl_levels_members`.IDLevel = `sys_acl_levels`.ID
219            WHERE `sys_profiles`.`id` = ?
220            ORDER BY `sys_acl_levels_members`.DateStarts DESC
221            LIMIT 1", $iTime, $iTime, $iProfileId);
222
223        return $this->getRow($sSql);
224    }
225
226    function getLevelByIdCached($iLevel) {
227        $sQuery = $this->prepare("SELECT
228                `tal`.`ID` AS `id`,
229                `tal`.`Name` AS `name`,
230                `tal`.`QuotaSize` AS `quota_size`,
231                `tal`.`QuotaNumber` AS `quota_number`,
232                `tal`.`QuotaMaxFileSize` AS `quota_max_file_size`
233            FROM `sys_acl_levels` AS `tal`
234            WHERE `tal`.`ID`=?
235            LIMIT 1", $iLevel);
236        return $this->fromCache('sys_acl_levels' . $iLevel, 'getRow', $sQuery);
237    }
238
239    function getAction($iMembershipId, $iActionId) {
240        $sQuery = $this->prepare("SELECT
241                `tam`.`IDAction` AS `id`,
242                `taa`.`Name` AS `name`, 
243                `taa`.`Title` AS `title`,
244                `tam`.`AllowedCount` AS `allowed_count`,
245                `tam`.`AllowedPeriodLen` AS `allowed_period_len`,
246                UNIX_TIMESTAMP(`tam`.`AllowedPeriodStart`) as `allowed_period_start`,
247                UNIX_TIMESTAMP(`tam`.`AllowedPeriodEnd`) as `allowed_period_end`,
248                `tam`.`AdditionalParamValue` AS `additional_param_value`
249            FROM `sys_acl_actions` AS `taa`
250            LEFT JOIN `sys_acl_matrix` AS `tam` ON `tam`.`IDAction` = `taa`.`ID` AND `tam`.`IDLevel` = ?
251            WHERE `taa`.`ID` = ?", $iMembershipId, $iActionId);
252        return $this->getRow($sQuery);
253    }
254
255    function getActionTrack($iActionId, $iProfileId) {
256        $sQuery = $this->prepare("SELECT
257                `taat`.`ActionsLeft` AS `actions_left`,
258                UNIX_TIMESTAMP(`taat`.`ValidSince`) as `valid_since`
259            FROM `sys_acl_actions_track` AS `taat`
260            WHERE `taat`.`IDAction`=? AND `taat`.`IDMember`=?", $iActionId, $iProfileId);
261        return $this->getRow($sQuery); 
262    }
263
264    function insertActionTarck($iActionId, $iProfileId, $iActionsLeft, $iValidSince) {
265        $sQuery = $this->prepare("INSERT INTO `sys_acl_actions_track`(`IDAction`, `IDMember`, `ActionsLeft`, `ValidSince`) VALUES (?, ?, ?, FROM_UNIXTIME(?))", $iActionId, $iProfileId, $iActionsLeft, $iValidSince);
266        return (int)$this->query($sQuery) > 0;
267    }
268
269    function updateActionTrack($iActionId, $iProfileId, $iActionsLeft, $iValidSince = 0) {
270        $sUpdateAddon = "";
271        if($iValidSince != 0)
272            $sUpdateAddon = $this->prepare(", ValidSince=FROM_UNIXTIME(?)", $iValidSince);
273
274        $sQuery = $this->prepare("UPDATE `sys_acl_actions_track` SET `ActionsLeft`=?" . $sUpdateAddon . " WHERE `IDAction`=? AND `IDMember`=?", $iActionsLeft, $iActionId, $iProfileId);
275        return (int)$this->query($sQuery) > 0;
276    }
277
278    function insertLevelByProfileId($iProfileId, $iMembershipId, $iDateStarts, $iDateExpires, $sTransactionId) {
279        $sQuery = $this->prepare("INSERT `sys_acl_levels_members` (`IDMember`, `IDLevel`, `DateStarts`, `DateExpires`, `TransactionID`) VALUES (?, ?, FROM_UNIXTIME(?), FROM_UNIXTIME(?), '?')", $iProfileId, $iMembershipId, $iDateStarts, $iDateExpires, $sTransactionId);
280        return (int)$this->query($sQuery) > 0;
281    }
282
283    function deleteLevelByProfileId($iProfileId, $bAll = false) {
284        $sQuery = $this->prepare("DELETE FROM `sys_acl_levels_members` WHERE `IDMember`=?" . ($bAll ? " AND (`DateExpires` IS NULL OR `DateExpires`>NOW())" : ""), $iProfileId);
285        return (int)$this->query($sQuery) > 0;
286    }
287}
288/** @} */
Note: See TracBrowser for help on using the repository browser.