ここの情報は古いです。ご理解頂いた上でお取り扱いください。

Changeset 12850


Ignore:
Timestamp:
Sep 8, 2009, 4:16:40 PM (10 years ago)
Author:
fukamachi
Message:

db converter - little fixed at convertMemberProfile. and fixed indents of some lines

File:
1 edited

Legend:

Unmodified
Added
Removed
  • OpenPNE3/branches/fukamachi/db-convert-from-2.x/lib/task/openpneUpgradeFrom2Task.class.php

    r12849 r12850  
    5050    $pluginInstall->run(array('opCommunityTopicPlugin'), array('--stability=beta'));
    5151    //$pluginInstall->run(array('opMessagePlugin'), array('--stability=beta'));
    52     $pluginInstall->run(array('opAshiatoPlugin'), array('--stability=beta'));
     52    //$pluginInstall->run(array('opAshiatoPlugin'), array('--stability=beta'));
    5353
    5454    // install OpenPNE3
     
    101101
    102102    // clear db records
    103     $tables = array('Blacklist', 'File', 'FileBin', 'CommunityCategory', 'Community', 'CommunityConfig', 'CommunityMember', 'Member', 'MemberConfig', 'MemberImage', 'Profile', 'ProfileTranslation', 'ProfileOption', 'ProfileOptionTranslation', 'MemberProfile', 'MemberRelationship', 'CommunityTopic', 'CommunityEvent', 'Diary', 'DiaryImage', 'DiaryComment', 'DiaryCommentImage', 'DiaryCommentUnread', /*'Message', 'MessageSendList', 'DeletedMessage', 'MessageFile', */'Ashiato');
     103    $tables = array('Blacklist', 'File', 'FileBin', 'CommunityCategory', 'Community', 'CommunityConfig', 'CommunityMember', 'Member', 'MemberConfig', 'MemberImage', 'Profile', 'ProfileTranslation', 'ProfileOption', 'ProfileOptionTranslation', 'MemberProfile', 'MemberRelationship', 'CommunityTopic', 'CommunityEvent', 'Diary', 'DiaryImage', 'DiaryComment', 'DiaryCommentImage', 'DiaryCommentUnread', /*'Message', 'MessageSendList', 'DeletedMessage', 'MessageFile', 'Ashiato'*/);
    104104
    105105    foreach ($tables as $table)
     
    145145    //print "converting Message tables : ".memory_get_usage()."\n";
    146146    //$this->convertMessageTables();
    147     print "converting Ashiato : ".memory_get_usage()."\n";
    148     $this->convertAshiato();
     147    //print "converting Ashiato : ".memory_get_usage()."\n";
     148    //$this->convertAshiato();
    149149
    150150    // delete models' cache
     
    202202      {
    203203        $this->_createFile(array(
    204               'id'                => $cFile->getCFileId(),
    205               'name'              => $cFile->getFilename(),
    206               'original_filename' => $cFile->getOriginalFilename(),
    207               'created_at'        => $cFile->getRDatetime(),
    208               'updated_at'        => $cFile->getRDatetime(),
    209               'bin'               => $cFile->getBin(),
    210               ));
     204          'id'                => $cFile->getCFileId(),
     205          'name'              => $cFile->getFilename(),
     206          'original_filename' => $cFile->getOriginalFilename(),
     207          'created_at'        => $cFile->getRDatetime(),
     208          'updated_at'        => $cFile->getRDatetime(),
     209          'bin'               => $cFile->getBin(),
     210        ));
    211211
    212212        if ($maxFileId < $cFile->getCFileId())
     
    338338
    339339        $param = array(
    340             'id'         => $cCommu->getCCommuId(),
    341             'name'       => $cCommu->getName(),
    342             'file_id'    => $this->getFileIdByName($cCommu->getImageFilename()),
    343             'created_at' => $cCommu->getRDate(),
    344             'updated_at' => $cCommu->getUDatetime(),
    345             );
     340          'id'         => $cCommu->getCCommuId(),
     341          'name'       => $cCommu->getName(),
     342          'file_id'    => $this->getFileIdByName($cCommu->getImageFilename()),
     343          'created_at' => $cCommu->getRDate(),
     344          'updated_at' => $cCommu->getUDatetime(),
     345        );
    346346        if (array_key_exists($cCommu->getCCommuCategoryId(), $this->mapCategoryIds))
    347347        {
     
    352352        // CommunityConfigs
    353353        $param = array(
    354             'community_id' => $cCommu->getCCommuId(),
    355             'created_at'   => $this->date,
    356             'updated_at'   => $this->date,
    357             );
     354          'community_id' => $cCommu->getCCommuId(),
     355          'created_at'   => $this->date,
     356          'updated_at'   => $this->date,
     357        );
    358358
    359359        $configs = array();
     
    395395
    396396        $param = array(
    397             'id'           => $cCommuMember->getCCommuMemberId(),
    398             'community_id' => $cCommuMember->getCCommuId(),
    399             'member_id'    => $cCommuMember->getCMemberId(),
    400             'created_at'   => $cCommuMember->getRDatetime(),
    401             'updated_at'   => $cCommuMember->getRDatetime(),
    402             );
     397          'id'           => $cCommuMember->getCCommuMemberId(),
     398          'community_id' => $cCommuMember->getCCommuId(),
     399          'member_id'    => $cCommuMember->getCMemberId(),
     400          'created_at'   => $cCommuMember->getRDatetime(),
     401          'updated_at'   => $cCommuMember->getRDatetime(),
     402        );
    403403        $this->connectTo2();
    404404        if ($cCommuMember->getCMemberId() === $this->mapCommunityAdminId[$cCommuMember->getCCommuId()])
     
    425425      {
    426426        $param = array(
    427             'id'               => $cMember->getCMemberId(),
    428             'name'             => $cMember->getNickname(),
    429             'invite_member_id' => $this->memberIdOrNull($cMember->getCMemberIdInvite()),
    430             'created_at'       => $cMember->getRDate(),
    431             'updated_at'       => $cMember->getUDatetime(),
    432             'is_active'        => !$cMember->getIsLoginRejected(),
    433             );
     427          'id'               => $cMember->getCMemberId(),
     428          'name'             => $cMember->getNickname(),
     429          'invite_member_id' => $this->memberIdOrNull($cMember->getCMemberIdInvite()),
     430          'created_at'       => $cMember->getRDate(),
     431          'updated_at'       => $cMember->getUDatetime(),
     432          'is_active'        => !$cMember->getIsLoginRejected(),
     433        );
    434434
    435435        $this->insertInto('Member', $param);
     
    459459        // common parameters
    460460        $param = array(
    461             'member_id'  => $cMemberSecure->getCMemberId(),
    462             'created_at' => $this->date,
    463             'updated_at' => $this->date,
    464             );
     461          'member_id'  => $cMemberSecure->getCMemberId(),
     462          'created_at' => $this->date,
     463          'updated_at' => $this->date,
     464        );
    465465
    466466        // MemberConfig records
    467467        $configs = array(
    468             'pc_address'     => $this->decrypt($cMemberSecure->getPcAddress()),
    469             'password'       => $cMemberSecure->getHashedPassword(),
    470             'mobile_address' => $this->orNull($cMemberSecure->getKtaiAddress()),
    471             'mobile_uid'     => $this->orNull($cMemberSecure->getEasyAccessId()),
    472             'lastLogin'      => $this->orNull($cMember->getAccessDate()),
    473             );
     468          'pc_address'     => $this->decrypt($cMemberSecure->getPcAddress()),
     469          'password'       => $cMemberSecure->getHashedPassword(),
     470          'mobile_address' => $this->orNull($cMemberSecure->getKtaiAddress()),
     471          'mobile_uid'     => $this->orNull($cMemberSecure->getEasyAccessId()),
     472          'lastLogin'      => $this->orNull($cMember->getAccessDate()),
     473        );
    474474
    475475        $this->createConfigs('MemberConfig', $param, $configs);
     
    523523      {
    524524        $this->insertInto('Profile', array(
    525               'id'                  => $cProfile->getCProfileId(),
    526               'name'                => $cProfile->getName(),
    527               'is_required'         => $cProfile->getIsRequired(),
    528               'is_edit_public_flag' => $cProfile->getPublicFlagEdit(),
    529               'default_public_flag' => $cProfile->getPublicFlagDefault(),
    530               'form_type'           => $cProfile->getFormType(),
    531               'value_type'          => $cProfile->getValType(),
    532               'is_disp_regist'      => $cProfile->getDispRegist(),
    533               'is_disp_config'      => $cProfile->getDispConfig(),
    534               'is_disp_search'      => $cProfile->getDispSearch(),
    535               'value_regexp'        => $cProfile->getValRegexp(),
    536               'value_min'           => $cProfile->getValMin(),
    537               'value_max'           => $cProfile->getValMax(),
    538               'sort_order'          => $cProfile->getSortOrder(),
    539               'created_at'          => $this->date,
    540               'updated_at'          => $this->date,
    541               ));
     525          'id'                  => $cProfile->getCProfileId(),
     526          'name'                => $cProfile->getName(),
     527          'is_required'         => $cProfile->getIsRequired(),
     528          'is_edit_public_flag' => $cProfile->getPublicFlagEdit(),
     529          'default_public_flag' => $cProfile->getPublicFlagDefault(),
     530          'form_type'           => $cProfile->getFormType(),
     531          'value_type'          => $cProfile->getValType(),
     532          'is_disp_regist'      => $cProfile->getDispRegist(),
     533          'is_disp_config'      => $cProfile->getDispConfig(),
     534          'is_disp_search'      => $cProfile->getDispSearch(),
     535          'value_regexp'        => $cProfile->getValRegexp(),
     536          'value_min'           => $cProfile->getValMin(),
     537          'value_max'           => $cProfile->getValMax(),
     538          'sort_order'          => $cProfile->getSortOrder(),
     539          'created_at'          => $this->date,
     540          'updated_at'          => $this->date,
     541        ));
    542542
    543543        $profileTranslation = Doctrine::getTable('Profile')->createQuery('p')
     
    547547
    548548        $param = array(
    549             'caption' => $cProfile->getCaption(),
    550             'lang'    => 'ja_JP',
    551             );
     549          'caption' => $cProfile->getCaption(),
     550          'lang'    => 'ja_JP',
     551        );
    552552        $param['info'] = $cProfile->getInfo();
    553553
     
    592592  protected function convertProfileOption()
    593593  {
    594     $this->connectTo2();
    595     $cProfileOptions = Doctrine::getTable('CProfileOption')->findAll();
    596594    $this->connectTo3();
    597595
     
    602600      {
    603601        $this->_createProfileOption(array(
    604               'id'         => $cProfileOption->getCProfileOptionId(),
    605               'profile_id' => $cProfileOption->getCProfileId(),
    606               'sort_order' => $cProfileOption->getSortOrder(),
    607               ), $cProfileOption->getValue());
     602          'id'         => $cProfileOption->getCProfileOptionId(),
     603          'profile_id' => $cProfileOption->getCProfileId(),
     604          'sort_order' => $cProfileOption->getSortOrder(),
     605        ), $cProfileOption->getValue());
    608606        $cProfileOption->free();
    609607      }
     
    612610
    613611    $this->_createProfileOption(array(
    614           'profile_id' => $this->birthdayProfileId,
    615           'sort_order' => 0,
    616           ));
     612      'profile_id' => $this->birthdayProfileId,
     613      'sort_order' => 0,
     614    ));
    617615  }
    618616
     
    620618  {
    621619    $profileOption = $this->insertInto('ProfileOption', $param, true);
     620    $profileOption->save();
    622621
    623622    if (!is_null($translation))
    624623    {
    625624      $profileOptionTranslation = Doctrine::getTable('ProfileOption')->createQuery('p')
    626         ->leftJoin('p.Translation t WITH t.lang = "ja_JP"')
     625        //->leftJoin('p.Translation t WITH t.lang = "ja_JP"')
     626        ->leftJoin('p.Translation t')
    627627        ->where('p.id = ?', $profileOption->getId())
    628628        ->fetchOne();
     
    631631      {
    632632        $profileOptionTranslation->setValue($translation);
     633        $profileOptionTranslation->setLang('ja_JP');
    633634        $profileOptionTranslation->save();
    634635        $profileOptionTranslation->free();
     
    656657        }
    657658
    658         $memberProfile = $this->_createAndGetMemberProfile(array(
    659           'member_id'         => $cMemberProfile->getCMemberId(),
    660           'profile_id'        => $cMemberProfile->getCProfileId(),
    661           'profile_option_id' => $cMemberProfile->getCProfileOptionId(),
    662           'value'             => $cMemberProfile->getValue(),
    663           'public_flag'       => $cMemberProfile->getPublicFlag(),
    664         ));
    665 
    666         if ($memberProfile)
    667         {
    668           $memberProfile->save();
    669           $memberProfile->free();
     659        // NOTICE: ignore if the profile and profile option are not exist yet
     660        if ($cMemberProfile->getCProfileId() && $cMemberProfile->getCProfileOptionId())
     661        {
     662          $this->insertInto('MemberProfile', array(
     663            'member_id'         => $cMemberProfile->getCMemberId(),
     664            'profile_id'        => $cMemberProfile->getCProfileId(),
     665            'profile_option_id' => $cMemberProfile->getCProfileOptionId(),
     666            'value'             => $cMemberProfile->getValue(),
     667            'public_flag'       => $cMemberProfile->getPublicFlag(),
     668            'created_at'        => $this->date,
     669            'updated_at'        => $this->date,
     670          ));
    670671        }
    671672
     
    679680    $this->connectTo3()->clear();
    680681
     682    // TODO: birthday's field is should be changed. so this process is passed now.
     683    /*
    681684    $offset = 0;
    682685    while ($cMembers = $this->getModelsIterator('CMember', 100, $offset))
     
    684687      foreach ($cMembers as $cMember)
    685688      {
    686         $birthdayRoot = $this->_createAndGetMemberProfile(array(
    687           'member_id'   => $cMember->getCMemberId(),
    688           'profile_id'  => $this->birthdayProfileId,
    689         ));
     689        $birthdayRoot = $this->insertInto('MemberProfile', array(
     690          'member_id'  => $cMember->getCMemberId(),
     691          'profile_id' => $this->birthdayProfileId,
     692          'created_at' => $this->date,
     693          'updated_at' => $this->date,
     694        ), true);
    690695
    691696        $treeProfile->createRoot($birthdayRoot);
    692697
    693         $birthdayYear = $this->_createAndGetMemberProfile(array(
     698        $birthdayYear = $this->insertInto('MemberProfile', array(
    694699          'member_id'   => $cMember->getCMemberId(),
    695700          'profile_id'  => $this->birthdayProfileId,
    696701          'value'       => $cMember->getBirthYear(),
    697702          'public_flag' => $cMember->getPublicFlagBirthYear(),
    698         ));
    699         $birthdayMonth = $this->_createAndGetMemberProfile(array(
    700           'member_id'    => $cMember->getCMemberId(),
    701           'profile_id'   => $this->birthdayProfileId,
    702           'value'        => $cMember->getBirthMonth(),
    703           'public_flag'  => $cMember->getPublicFlagBirthMonthDay(),
    704         ));
    705         $birthdayDay = $this->_createAndGetMemberProfile(array(
    706           'member_id'    => $cMember->getCMemberId(),
    707           'profile_id'   => $this->birthdayProfileId,
    708           'value'        => $cMember->getBirthDay(),
    709           'public_flag'  => $cMember->getPublicFlagBirthMonthDay(),
    710         ));
     703          'created_at'  => $this->date,
     704          'updated_at'  => $this->date,
     705        ), true);
     706        $birthdayMonth = $this->insertInto('MemberProfile', array(
     707          'member_id'   => $cMember->getCMemberId(),
     708          'profile_id'  => $this->birthdayProfileId,
     709          'value'       => $cMember->getBirthMonth(),
     710          'public_flag' => $cMember->getPublicFlagBirthMonthDay(),
     711          'created_at'  => $this->date,
     712          'updated_at'  => $this->date,
     713        ), true);
     714        $birthdayDay = $this->insertInto('MemberProfile', array(
     715          'member_id'   => $cMember->getCMemberId(),
     716          'profile_id'  => $this->birthdayProfileId,
     717          'value'       => $cMember->getBirthDay(),
     718          'public_flag' => $cMember->getPublicFlagBirthMonthDay(),
     719          'created_at'  => $this->date,
     720          'updated_at'  => $this->date,
     721        ), true);
    711722
    712723        $birthdayDay->getNode()->insertAsLastChildOf($birthdayRoot);
     
    722733      $offset += 100;
    723734    }
    724   }
    725 
    726   protected function _createAndGetMemberProfile($param = array())
    727   {
    728     // NOTICE: ignore if c_member_profile.c_profile_id = 0
    729     if (!array_key_exists('profile_id', $param) || !$param['profile_id'])
    730     {
    731       return;
    732     }
    733 
    734     $param['created_at'] = $this->date;
    735     $param['updated_at'] = $this->date;
    736 
    737     return $this->insertInto('MemberProfile', $param, true);
     735    */
    738736  }
    739737
     
    748746      {
    749747        $this->_updateMemberRelationship(array(
    750               'member_id_from' => $cFriend->getCMemberIdFrom(),
    751               'member_id_to'   => $cFriend->getCMemberIdTo(),
    752               'is_friend'      => true,
    753               'created_at'     => $cFriend->getRDatetime(),
    754               'updated_at'     => $cFriend->getRDatetime(),
    755               ));
     748          'member_id_from' => $cFriend->getCMemberIdFrom(),
     749          'member_id_to'   => $cFriend->getCMemberIdTo(),
     750          'is_friend'      => true,
     751          'created_at'     => $cFriend->getRDatetime(),
     752          'updated_at'     => $cFriend->getRDatetime(),
     753        ));
    756754        $cFriend->free();
    757755      }
     
    765763      {
    766764        $this->_updateMemberRelationship(array(
    767               'member_id_from' => $cFriendConfirm->getCMemberIdFrom(),
    768               'member_id_to'   => $cFriendConfirm->getCMemberIdTo(),
    769               'is_friend_pre'  => true,
    770               'created_at'     => $cFriendConfirm->getRDatetime(),
    771               'updated_at'     => $cFriendConfirm->getRDatetime(),
    772               ));
     765          'member_id_from' => $cFriendConfirm->getCMemberIdFrom(),
     766          'member_id_to'   => $cFriendConfirm->getCMemberIdTo(),
     767          'is_friend_pre'  => true,
     768          'created_at'     => $cFriendConfirm->getRDatetime(),
     769          'updated_at'     => $cFriendConfirm->getRDatetime(),
     770        ));
    773771        $cFriendConfirm->free();
    774772      }
     
    782780      {
    783781        $this->_updateMemberRelationship(array(
    784               'member_id_from'  => $cAccessBlock->getCMemberId(),
    785               'member_id_to'    => $cAccessBlock->getCMemberIdBlock(),
    786               'is_access_block' => true,
    787               'created_at'      => $cAccessBlock->getRDatetime(),
    788               'updated_at'      => $cAccessBlock->getRDatetime(),
    789               ));
     782          'member_id_from'  => $cAccessBlock->getCMemberId(),
     783          'member_id_to'    => $cAccessBlock->getCMemberIdBlock(),
     784          'is_access_block' => true,
     785          'created_at'      => $cAccessBlock->getRDatetime(),
     786          'updated_at'      => $cAccessBlock->getRDatetime(),
     787        ));
    790788        $cAccessBlock->free();
    791789      }
Note: See TracChangeset for help on using the changeset viewer.