UserAction.inc.php

<?php
 
import('lib.pkp.classes.user.PKPUserAction');
 
class UserAction extends PKPUserAction {
   public function mergeUsers($oldUserId, $newUserId) {
      if (!parent::mergeUsers($oldUserId, $newUserId)) return false;
 
      // Transfer old user's individual subscriptions for each journal if new user
      // does not have a valid individual subscription for a given journal.
      $individualSubscriptionDao = DAORegistry::getDAO('IndividualSubscriptionDAO'); /* @var $individualSubscriptionDao IndividualSubscriptionDAO */
      $oldUserSubscriptions = $individualSubscriptionDao->getByUserId($oldUserId);
 
      while ($oldUserSubscription = $oldUserSubscriptions->next()) {
         $subscriptionJournalId = $oldUserSubscription->getJournalId();
         $oldUserValidSubscription = $individualSubscriptionDao->isValidIndividualSubscription($oldUserId, $subscriptionJournalId);
         if ($oldUserValidSubscription) {
            // Check if new user has a valid subscription for current journal
            $newUserSubscription = $individualSubscriptionDao->getByUserIdForJournal($newUserId, $subscriptionJournalId);
            if (!$newUserSubscription) {
               // New user does not have this subscription, transfer old user's
               $oldUserSubscription->setUserId($newUserId);
               $individualSubscriptionDao->updateObject($oldUserSubscription);
            } elseif (!$individualSubscriptionDao->isValidIndividualSubscription($newUserId, $subscriptionJournalId)) {
               // New user has a subscription but it's invalid. Delete it and
               // transfer old user's valid one
               $individualSubscriptionDao->deleteByUserIdForJournal($newUserId, $subscriptionJournalId);
               $oldUserSubscription->setUserId($newUserId);
               $individualSubscriptionDao->updateObject($oldUserSubscription);
            }
         }
      }
 
      // Delete any remaining old user's subscriptions not transferred to new user
      $individualSubscriptionDao->deleteByUserId($oldUserId);
 
      // Transfer all old user's institutional subscriptions for each journal to
      // new user. New user now becomes the contact person for these.
      $institutionalSubscriptionDao = DAORegistry::getDAO('InstitutionalSubscriptionDAO'); /* @var $institutionalSubscriptionDao InstitutionalSubscriptionDAO */
      $oldUserSubscriptions = $institutionalSubscriptionDao->getByUserId($oldUserId);
 
      while ($oldUserSubscription = $oldUserSubscriptions->next()) {
         $oldUserSubscription->setUserId($newUserId);
         $institutionalSubscriptionDao->updateObject($oldUserSubscription);
      }
 
      // Transfer completed payments.
      $paymentDao = DAORegistry::getDAO('OJSCompletedPaymentDAO'); /* @var $paymentDao OJSCompletedPaymentDAO */
      $paymentFactory = $paymentDao->getByUserId($oldUserId);
      while ($payment = $paymentFactory->next()) {
         $payment->setUserId($newUserId);
         $paymentDao->updateObject($payment);
      }
 
      return true;
   }
}