root/websites/trajoin/trunk/lib/model/HistoryPeer.php @ 29893

<?php

class HistoryPeer extends BaseHistoryPeer
{
  static public function save($translation, $note, $approvedAt =null)
  {
    $history = new History();
    $history->setTranslationId($translation->getId());
    $history->setCulture($translation->getCurrentTranslationI18n()->getCulture());
    $history->setOriginal($translation->getOriginal());
    $history->setTranslated($translation->getTranslated());
    $history->setUserId($translation->getUserId());
    $history->setNote($note);
    $history->setApprovedAt($approvedAt);
    $history->save();
    // approve if admin commit
    if ($approvedAt) {
      $sameHistories = self::retrieveByTranslationId($translation->getId(), $history->getCulture());
      foreach ($sameHistories as $sameHistory) {
        if ($sameHistory->getCreatedAt() < $history->getCreatedAt() && !$sameHistory->getApprovedAt()) {
          $sameHistory->setApprovedAt($approvedAt);
          $sameHistory->save();
        }
      }
    }
    // cache clear status
    $cacheManager = sfContext::getInstance()->getViewCacheManager();
    if ($cacheManager instanceof sfViewCacheManager) {
      $cacheManager->remove('translation/showStatus?sf_culture=' . $translation->getCurrentTranslationI18n()->getCulture());
    }
  }
  static public function retrieveByFilePath($filePath, $culture)
  {
    $c = new Criteria();
    $c->add(TranslationPeer::FILE_PATH, $filePath, Criteria::EQUAL);
    $c->add(self::CULTURE, $culture);
    return self::doSelectJoinAll($c);
  }
  static public function retrieveByFilePathNotTranslationId($filePath, $translationId = "", $culture)
  {
    $c = new Criteria();
    $c->add(TranslationPeer::FILE_PATH, $filePath, Criteria::EQUAL);
    if ($translationId != "") {
      $c->add(TranslationPeer::ID, $translationId, Criteria::NOT_EQUAL);
    }
    $c->add(self::CULTURE, $culture);
    return self::doSelectJoinAll($c);
  }
  static public function retrieveByTranslationId($translationId, $culture)
  {
    $c = new Criteria();
    $c->addDescendingOrderByColumn(HistoryPeer::CREATED_AT);
    $c->add(TranslationPeer::ID, $translationId, Criteria::EQUAL);
    $c->add(self::CULTURE, $culture);
    return self::doSelectJoinAll($c);
  }
  static public function retrieveByFilePathLatest($filePath, $limit, $culture)
  {
    $c = new Criteria();
    $c->addDescendingOrderByColumn(HistoryPeer::CREATED_AT);
    $c->setLimit($limit);
    $c->add(TranslationPeer::FILE_PATH, $filePath, Criteria::EQUAL);
    $c->add(self::CULTURE, $culture);
    return self::doSelectJoinAll($c);
  }
  static public function retrieveLatest($limit, $culture)
  {
    $c = new Criteria();
    $c->addDescendingOrderByColumn(HistoryPeer::CREATED_AT);
    $c->setLimit($limit);
    $c->add(self::CULTURE, $culture);
    return self::doSelectJoinAll($c);
  }
  static public function retrieveByUserId($id, $page=1)
  {
    $c = new Criteria();
    $c->add(self::USER_ID, $id);
    $c->addDescendingOrderByColumn(self::CREATED_AT);
    $pager = new sfPropelPager('History', 10);
    $pager->setCriteria($c);
    $pager->setPage($page);
    $pager->init();
    return $pager;
  }
  static public function getLastByTranslationId($translationId, $culture, $onlyApproved=false)
  {
    $c = new Criteria();
    $c->addDescendingOrderByColumn(HistoryPeer::CREATED_AT);
    $c->setLimit(1);
    $c->add(HistoryPeer::TRANSLATION_ID, $translationId);
    if ($onlyApproved) {
      $c->Add(HistoryPeer::APPROVED_AT, null, Criteria::ISNOTNULL);
    }
    $c->add(self::CULTURE, $culture);
    $obj = self::doSelectJoinAll($c);
    return (count($obj))? $obj[0]: new History();
  }
  static public function getNotApproved()
  {
    $c = new Criteria();
    $c->add(self::APPROVED_AT, null, Criteria::ISNULL);
    return self::doSelect($c);
  }
  static public function approve($id)
  {
    // update approved time
    $history = self::retrieveByPk($id);
    $history->setApprovedAt(date('Y-m-d H:i:s'));
    $history->save();
    // insert new translation data
    $translation = $history->getTranslation();
    $translation->getCurrentTranslationI18n()->setTranslated($history->getTranslated());
    $translation->getCurrentTranslationI18n()->setUserId($history->getUserId());
    $translation->save();
    // commit to repo
    self::commit2repo($translation->getFilePath(), $history->getNote());
    // clear histories by same user and same chunk
    $sameHistories = self::retrieveByTranslationId($history->getTranslationId(), $history->getCulture());
    foreach ($sameHistories as $sameHistory) {
      if ($sameHistory->getCreatedAt() < $history->getCreatedAt() && !$sameHistory->getApprovedAt()) {
        $sameHistory->delete();
      }
    }
    // cache clear status
    $cacheManager = sfContext::getInstance()->getViewCacheManager();
    if ($cacheManager instanceof sfViewCacheManager) {
      $cacheManager->remove('translation/showStatus?sf_culture=' . $translation->getCurrentTranslationI18n()->getCulture());
    }
  }
  static public function commit2repo($filePath, $message="")
  {
    // svn commit if on production server
    if (in_array(@$_SERVER['REMOTE_ADDR'], array('127.0.0.1', '::1'))) return;
    $Filesystem = new sfFilesystem();
    $svnPath = "../data/contents/markdown/1.2/";
    $cmd= sprintf('svn update --config-dir /home/svn/.subversion %s', $svnPath);
    //$cmd= sprintf('svn update  %s', $svnPath);
    self::logMessage($Filesystem->sh($cmd));
    self::logMessage($Filesystem->sh(sprintf('../symfony trajoin:markdown %s', $filePath)));
    $cmd= sprintf('svn status --config-dir /home/svn/.subversion %s* |grep ^? |cut -d \' \' -f 7 | xargs --no-run-if-empty svn add --config-dir /home/svn/.subversion ', $svnPath);
    //$cmd= sprintf('svn status  %s* |grep ^? |cut -d \' \' -f 7 | xargs svn add ', $svnPath);
    self::logMessage($Filesystem->sh($cmd));
    $cmd= sprintf('svn commit --config-dir /home/svn/.subversion -m "%s" %s --username trajoin', escapeshellcmd($message), $svnPath);
    //$cmd= sprintf('svn commit -m "%s" %s --username trajoin', escapeshellcmd($message), $svnPath);
    self::logMessage($Filesystem->sh($cmd));
  }
  static private function logMessage($message)
  {
  if (sfConfig::get('sf_logging_enabled')) {
      sfContext::getInstance()->getLogger()->info($message);
    }
  }
}