Changeset 12744

Timestamp:

Aug 24, 2009, 2:25:57 PM (13 years ago)

Author:

fukamachi

Message:

db converter - revert r12743. and added a convert method for member_image table

File:

• OpenPNE3/branches/fukamachi/db-convert-from-2.x/lib/task/openpneUpgradeFrom2Task.class.php (modified) (5 diffs)

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

@@ -96 +96 @@
     $this->convertCommunityAndCommunityConfig();
     $this->convertCommunityMember();
-    $this->convertCommunity();
     $this->convertMember();
     $this->convertMemberConfig();
+    $this->convertMemberImage();
 
     // delete models' cache
@@ -229 +229 @@
       $community->setId($cCommu->getCCommuId());
       $community->setName($cCommu->getName());
-
-      if ($cCommu->getImageFilename())
-      {
-        $this->connectTo2();
-        $fileId = Doctrine::getTable('CFile')->createQuery()
-          ->select('c_file_id')
-          ->where('filename = ?', $cCommu->getImageFilename())
-          ->fetchOne();
-        $this->connectTo3();
-        if ($file)
-        {
-          $community->setFileId($file->getCFileId());
-        }
-      }
-
+      $community->setFileId($this->getFileIdByName($cCommu->getImageFilename()));
       $community->setCommunityCategoryId($this->mapCategoryIds[$cCommu->getCCommuCategoryId()]);
       $community->setCreatedAt($cCommu->getRDate());
@@ -298 +284 @@
 
       $communityMember->save();
-    }
-  }
-
-  protected function convertCommunity()
-  {
-    $this->connectTo2();
-    $cCommus = Doctrine::getTable('CCommu')->findAll();
-    $this->connectTo3();
-    $this->clearDbTable('Community');
-
-    foreach ($cCommus as $cCommu)
-    {
-      $community = new TempCommunity();
-      $community->setId($cCommu->getCCommuId());
-      $community->setName($cCommu->getName());
-      if ($cCommu->getImageFilename())
-      {
-        $file = Doctrine::getTable('File')->createQuery()
-          ->select('id')
-          ->where('name = ?', $cCommu->getImageFilename())
-          ->fetchOne();
-        $community->setFileId($file->getId());
-      }
-      $community->setCommunityCategoryId($this->mapCategoryIds[$cCommu->getCCommuCategoryId()]);
-      $community->setCreatedAt($cCommu->getRDatetime());
-      $community->setUpdatedAt($cCommu->getUDatetime());
-
-      $community->save();
     }
   }
@@ -413 +371 @@
 
     $memberConfig->save();
+  }
+
+  protected function convertMemberImage()
+  {
+    $this->connectTo2();
+    $cMembers = Doctrine::getTable('CMember')->findAll();
+    $this->connectTo3();
+
+    foreach ($cMembers as $cMember)
+    {
+      $primaryImage = $cMember->getImageFilename();
+
+      $this->_createMemberImage(array(
+        'member_id'      => $cMember->getCMemberId(),
+        'image_filename' => $cMember->getImageFilename_1(),
+        'primary_image'  => $primaryImage,
+      ));
+
+      $this->_createMemberImage(array(
+        'member_id'      => $cMember->getCMemberId(),
+        'image_filename' => $cMember->getImageFilename_2(),
+        'primary_image'  => $primaryImage,
+      ));
+
+      $this->_createMemberImage(array(
+        'member_id'      => $cMember->getCMemberId(),
+        'image_filename' => $cMember->getImageFilename_3(),
+        'primary_image'  => $primaryImage,
+      ));
+    }
+  }
+
+  protected function _createMemberImage($param = array())
+  {
+    if (!$param['image_filename'])
+    {
+      return;
+    }
+
+    $memberImage = new TempMemberImage();
+    $memberImage->setMemberId($param['member_id']);
+    $memberImage->setFileId($this->getFileIdByName($param['image_filename']));
+    if ($param['image_filename'] === $param['primary_image'])
+    {
+      $memberImage->setIsPrimary(true);
+    }
+    $memberImage->setCreatedAt($this->date);
+    $memberImage->setUpdatedAt($this->date);
+
+    $memberImage->save();
   }
 
@@ -526 +534 @@
     return $singleton;
   }
+
+  protected function getFileIdByName($name)
+  {
+    if (!$name)
+    {
+      return;
+    }
+
+    $this->connectTo3();
+    $file = Doctrine::getTable('File')->createQuery()
+      ->select('id')
+      ->where('name = ?', $name)
+      ->fetchOne();
+
+    if ($file)
+    {
+      return $file->getId();
+    }
+  }
 }