public function StatisticsCommands::updateStatistics in Opigno statistics 8

Same name and namespace in other branches

1. 3.x src/Commands/StatisticsCommands.php \Drupal\opigno_statistics\Commands\StatisticsCommands::updateStatistics()

Makes update of trainings statistics.

@usage drush statistics-update [uid] [gid]

• Removes statistics records for user with id [uid] and a training with id [gid] and re-creates them.

@usage drush statistics-update 12 23

• Removes statistics records for user with id 12 and a training with id 23 and re-creates them.

@usage drush statistics-update

• Removes all the trainings statistics records and re-creates them.

@command statistics-update @aliases stup

Parameters

int $uid: User entity ID.

int $gid: Training group entity ID.

Throws

\Exception

File

src/Commands/StatisticsCommands.php, line 32

Class

StatisticsCommands

A Drush command file.

Namespace

Drupal\opigno_statistics\Commands

Code

public function updateStatistics($uid = NULL, $gid = NULL) {
  if ($uid && !$gid || !$uid && $gid) {
    $this
      ->output()
      ->writeln('Should be two params - user ID and a training ID.');
    return 2;
  }
  $achievements_table = 'opigno_learning_path_achievements';
  $achievements_steps_table = 'opigno_learning_path_step_achievements';
  $db_connection = \Drupal::service('database');
  if ($gid) {
    $ids = [
      $gid,
    ];
  }
  else {
    $ids = $db_connection
      ->select('groups_field_data', 'g')
      ->fields('g', [
      'id',
    ])
      ->condition('type', 'learning_path')
      ->execute()
      ->fetchCol();
  }
  if ($ids) {
    $groups = Group::loadMultiple($ids);
    if ($groups) {
      if ($uid && $gid) {
        $db_connection
          ->delete($achievements_table)
          ->condition('uid', $uid)
          ->condition('gid', $gid)
          ->execute();
        $db_connection
          ->delete($achievements_steps_table)
          ->condition('uid', $uid)
          ->condition('gid', $gid)
          ->execute();
      }
      else {
        $db_connection
          ->truncate($achievements_table)
          ->execute();
        $db_connection
          ->truncate($achievements_steps_table)
          ->execute();
      }
      foreach ($groups as $group) {

        // Each training.
        $gid = $group
          ->id();
        $this
          ->output()
          ->writeln('Group (' . $gid . ') - "' . $group
          ->label() . '"');
        if ($members = $group
          ->getMembers()) {
          foreach ($members as $group_membership) {

            // Each training member user.
            $user = $group_membership
              ->getUser();
            $member_uid = $user
              ->id();
            if ($uid && $uid != $member_uid) {
              continue;
            }
            $this
              ->output()
              ->writeln(' - user (' . $member_uid . ') - "' . $user
              ->getUsername() . '"');
            try {
              opigno_learning_path_save_achievements($gid, $member_uid);
            } catch (\Exception $e) {
              \Drupal::logger('opigno_statistics')
                ->error($e
                ->getMessage());
              \Drupal::messenger()
                ->addMessage($e
                ->getMessage(), 'error');
            }
            if ($steps = opigno_learning_path_get_all_steps($gid, $member_uid)) {
              foreach ($steps as $step) {

                // Each training steps.
                try {

                  // Save current step parent achievements.
                  $parent_id = isset($current_step['parent']) ? opigno_learning_path_save_step_achievements($gid, $member_uid, $step['parent']) : 0;

                  // Save current step achievements.
                  opigno_learning_path_save_step_achievements($gid, $member_uid, $step, $parent_id);
                } catch (\Exception $e) {
                  \Drupal::logger('opigno_statistics')
                    ->error($e
                    ->getMessage());
                  \Drupal::messenger()
                    ->addMessage($e
                    ->getMessage(), 'error');
                }
              }
            }
          }
        }
      }
    }
  }
}