ggoffy /
wgevents
| Conditions | 18 |
| Paths | 18 |
| Total Lines | 97 |
| Code Lines | 66 |
| Lines | 0 |
| Ratio | 0 % |
| Changes | 1 | ||
| Bugs | 0 | Features | 1 |
Small methods make your code easier to understand, in particular if combined with a good name. Besides, if your method is small, finding a good name is usually much easier.
For example, if you find yourself adding comments to a method's body, this is usually a good sign to extract the commented part to a new method, and use the comment as a starting point when coming up with a good name for this new method.
Commonly applied refactorings include:
If many parameters/temporary variables are present:
| 1 | <?php |
||
| 172 | public function processTasks($log_level = 0) |
||
| 173 | { |
||
| 174 | $helper = \XoopsModules\Wgevents\Helper::getInstance(); |
||
| 175 | |||
| 176 | // get limit_hour from primary account |
||
| 177 | $accountHandler = $helper->getHandler('Account'); |
||
| 178 | $limitHour = $accountHandler->getLimitHour(); |
||
| 179 | |||
| 180 | $resProcess = ''; |
||
| 181 | |||
| 182 | $crTaskPending = new \CriteriaCompo(); |
||
| 183 | $crTaskPending->add(new \Criteria('status', Constants::STATUS_PENDING)); |
||
| 184 | $tasksCountPending = $this->getCount($crTaskPending); |
||
| 185 | |||
| 186 | // if all works properly there shouldn't be a task type 'processing' left |
||
| 187 | $crTaskProcessing = new \CriteriaCompo(); |
||
| 188 | $crTaskProcessing->add(new \Criteria('status', Constants::STATUS_PROCESSING)); |
||
| 189 | $tasksCountProcessing = $this->getCount($crTaskProcessing); |
||
| 190 | |||
| 191 | $crTaskDone = new \CriteriaCompo(); |
||
| 192 | $crTaskDone->add(new \Criteria('status', Constants::STATUS_DONE)); |
||
| 193 | $crTaskDone->add(new \Criteria('datedone', time() - 3600, '>')); |
||
| 194 | $tasksCountDone = $this->getCount($crTaskDone); |
||
| 195 | |||
| 196 | $counterDone = 0; |
||
| 197 | if ($log_level > 0) { |
||
| 198 | $resProcess .= '<br>Start processTasks'; |
||
| 199 | $resProcess .= '<br>time - 3600: ' . \formatTimestamp(time() - 3600, 'm'); |
||
| 200 | if ($tasksCountProcessing > 0) { |
||
| 201 | $resProcess .= '<br><span style="color:#ff0000;font-weight:700">Count status PROCESSING at start: ' . $tasksCountProcessing . '</span>'; |
||
| 202 | } |
||
| 203 | $resProcess .= '<br>Count status PENDING at start: ' . $tasksCountPending; |
||
| 204 | $resProcess .= '<br>Count status DONE at start: ' . $tasksCountDone; |
||
| 205 | } |
||
| 206 | if (($tasksCountPending > 0) && ($tasksCountDone < $limitHour || 0 == $limitHour)) { |
||
| 207 | if ($limitHour > 0) { |
||
| 208 | $crTaskPending->setLimit($limitHour); |
||
| 209 | } |
||
| 210 | $tasksAll = $this->getAll($crTaskPending); |
||
| 211 | $resultMH = 0; |
||
| 212 | foreach (\array_keys($tasksAll) as $i) { |
||
| 213 | // check whether task is still pending |
||
| 214 | // ignore it if meanwhile another one started to process the task |
||
| 215 | if ($log_level > 1) { |
||
| 216 | $resProcess .= '<br>Task key: ' . $i; |
||
| 217 | } |
||
| 218 | if (554 === $resultMH) { |
||
| 219 | $resProcess .= '<br>Skipped Error 554: SMTP limit exceeded'; |
||
| 220 | } else { |
||
| 221 | if ((Constants::STATUS_PENDING == (int)$tasksAll[$i]->getVar('status')) |
||
| 222 | && ($tasksCountDone < $limitHour || 0 == $limitHour)) { |
||
| 223 | $taskProcessObj = $this->get($i); |
||
| 224 | $taskProcessObj->setVar('status', Constants::STATUS_PROCESSING); |
||
| 225 | if ($this->insert($taskProcessObj)) { |
||
| 226 | $mailsHandler = new MailHandler(); |
||
| 227 | $mailParams = json_decode($tasksAll[$i]->getVar('params', 'n'), true); |
||
| 228 | $mailParams['recipients'] = $tasksAll[$i]->getVar('recipient'); |
||
| 229 | $mailParams['taskId'] = $i; |
||
| 230 | $mailsHandler->setParams($mailParams); |
||
| 231 | $mailsHandler->setType($tasksAll[$i]->getVar('type')); |
||
| 232 | // send mails |
||
| 233 | $resultMH = (int)$mailsHandler->execute(); |
||
| 234 | unset($mailsHandler); |
||
| 235 | //update task list corresponding the result |
||
| 236 | if (0 === $resultMH) { |
||
| 237 | $taskProcessObj->setVar('status', Constants::STATUS_DONE); |
||
| 238 | $taskProcessObj->setVar('datedone', time()); |
||
| 239 | $counterDone++; |
||
| 240 | if ($log_level > 1) { |
||
| 241 | $resProcess .= ' - done'; |
||
| 242 | } |
||
| 243 | } else { |
||
| 244 | $taskProcessObj->setVar('status', Constants::STATUS_PENDING); |
||
| 245 | if ($log_level > 1) { |
||
| 246 | $resProcess .= ' - failed'; |
||
| 247 | } |
||
| 248 | } |
||
| 249 | $this->insert($taskProcessObj); |
||
| 250 | } else { |
||
| 251 | $resProcess .= ' - error insert taskProcessObj'; |
||
| 252 | } |
||
| 253 | } |
||
| 254 | } |
||
| 255 | // check once more number of done |
||
| 256 | $tasksCountDone = $this->getCount($crTaskDone); |
||
| 257 | } |
||
| 258 | } |
||
| 259 | // check once more number of open tasks |
||
| 260 | $crTaskOpen = new \CriteriaCompo(); |
||
| 261 | $crTaskOpen->add(new \Criteria('status', Constants::STATUS_DONE, '<')); |
||
| 262 | $tasksCountOpen = $this->getCount($crTaskOpen); |
||
| 263 | |||
| 264 | if ($log_level > 0) { |
||
| 265 | $resProcess .= '<br>End processTasks'; |
||
| 266 | } |
||
| 267 | |||
| 268 | return ['pending' => $tasksCountPending, 'done' => $counterDone, 'resprocess' => $resProcess, 'still_open' => $tasksCountOpen]; |
||
| 269 | } |
||
| 271 |
Loading history...
Let?s assume that you have a directory layout like this:
. |-- OtherDir | |-- Bar.php | `-- Foo.php `-- SomeDir `-- Foo.phpand let?s assume the following content of
Bar.php:If both files
OtherDir/Foo.phpandSomeDir/Foo.phpare loaded in the same runtime, you will see a PHP error such as the following:PHP Fatal error: Cannot use SomeDir\Foo as Foo because the name is already in use in OtherDir/Foo.phpHowever, as
OtherDir/Foo.phpdoes not necessarily have to be loaded and the error is only triggered if it is loaded beforeOtherDir/Bar.php, this problem might go unnoticed for a while. In order to prevent this error from surfacing, you must import the namespace with a different alias: