StatisticsReport.inc.php

<?php
 
import('lib.pkp.classes.scheduledTask.ScheduledTask');
 
class StatisticsReport extends ScheduledTask {
   private $_roleIds = [ROLE_ID_MANAGER, ROLE_ID_SUB_EDITOR];
 
   private $_sleepEvery = 100;
 
   private $_sleepBy = 2;
 
 
   public function getName() : string
   {
      return __('admin.scheduledTask.statisticsReport');
   }
 
   public function executeActions() : bool
   {
      @set_time_limit(0);
      import('lib.pkp.classes.notification.managerDelegate.EditorialReportNotificationManager');
 
      $contextDao = Application::get()->getContextDAO();
      $userGroupDao = DAORegistry::getDAO('UserGroupDAO'); /* @var $userGroupDao UserGroupDAO */
 
      $sentMessages = 0;
      for ($contexts = $contextDao->getAll(true); $context = $contexts->next(); ) {
         AppLocale::requireComponents(
            [LOCALE_COMPONENT_PKP_USER, LOCALE_COMPONENT_PKP_MANAGER, LOCALE_COMPONENT_PKP_SUBMISSION, LOCALE_COMPONENT_PKP_COMMON, LOCALE_COMPONENT_APP_COMMON],
            $context->getPrimaryLocale()
         );
         $editorialReportNotificationManager = new EditorialReportNotificationManager(NOTIFICATION_TYPE_EDITORIAL_REPORT);
         $editorialReportNotificationManager->initialize(
            $context,
            new DateTimeImmutable('first day of previous month midnight'),
            new DateTimeImmutable('first day of this month midnight')
         );
         $notifiedUsersSet = [];
         foreach ($this->_roleIds as $roleId) {
            for ($userGroups = $userGroupDao->getByRoleId($context->getId(), $roleId); $userGroup = $userGroups->next(); ) {
               for ($users = $userGroupDao->getUsersById($userGroup->getId(), $context->getId()); $user = $users->next(); ) {
                  if (isset($notifiedUsersSet[$user->getId()])) {
                     continue;
                  }
                  $editorialReportNotificationManager->notify($user);
                  $notifiedUsersSet[$user->getId()] = 0;
                  if (!(++$sentMessages % $this->_sleepEvery)) {
                     sleep($this->_sleepBy);
                  }
               }
            }
         }
      }
      return true;
   }
}