Changeset 13145 for trunk/modules/boonex/data_migration/classes/BxDataMigrationProfiles.php

Timestamp:

11/05/09 10:48:23 (3 years ago)

Author:

Alexander Ermashev

Message:

• ticket #1416;

File:

• trunk/modules/boonex/data_migration/classes/BxDataMigrationProfiles.php (modified) (3 diffs)

trunk/modules/boonex/data_migration/classes/BxDataMigrationProfiles.php

@@ -110 +110 @@
                      createUserDataFile($iProfileId);
 
-                     $this -> iTransffered++;
-
                      // migrate profile's picture;
                      if($aRow['Picture'] && $this -> bAvatarInstalled) {
                          $this -> _exportAvatar($aRow['ID'], $iProfileId, $aRow['PrimPhoto']);
                      }
+
+                     // migrate friends;
+                     $sResult = $this -> _exportFriends($aRow['ID']);
+                     if($sResult) {
+                         return $sResult;
+                     }
+
+                     $this -> iTransffered++;
                   }
              }
@@ -164 +170 @@
                 }
             }
+        }
+
+        /**
+         * Export all profile's friends;
+         * 
+         * @param $iProfileId integer;
+         * @return string - error message if needed;
+         */
+        function _exportFriends($iProfileId)
+        {
+            $iProfileId = (int) $iProfileId;
+
+            $sQuery = "SELECT * FROM `FriendList` WHERE `ID` = {$iProfileId} OR `Profile` = {$iProfileId}";
+            $rResult = mysql_query($sQuery, $this -> rOldDb);
+
+            while( $aRow = mysql_fetch_assoc($rResult) )
+            {
+                if( !$this -> isFriendExisting($aRow['ID'], $aRow['Profile'])) {
+                   // build query; 
+                   $sQuery =
+                    "
+                        INSERT INTO
+                            `sys_friend_list`
+                        SET
+                           `ID`         = '{$aRow['ID']}',
+                           `Profile`    = '{$aRow['Profile']}',
+                           `Check`      = '{$aRow['Check']}',
+                           `When`       = NOW()
+                   ";
+    
+                   $iResult = (int) $this -> oMigrationModule -> _oDb -> query($sQuery);
+                   if($iResult <= 0) {
+                       return 'Database error. Cannot insert friend list in the database.';
+                   }
+                }
+            }
         }
 
@@ -215 +257 @@
             return $this -> oMigrationModule -> _oDb -> getOne($sQuery) ? true : false;
         } 
+
+        /**
+         * Check friends pair;
+         * 
+         * @param $iProfileId integer
+         * @param $iFriendId integer
+         * @return boolean - true if already existing
+         */
+        function isFriendExisting($iProfileId, $iFriendId)
+        {
+            $iProfileId = (int) $iProfileId;
+            $iFriendId  = (int) $iFriendId;
+
+            $sQuery = 
+            "
+                SELECT 
+                    COUNT(*) 
+                FROM 
+                    `sys_friend_list` 
+                WHERE
+                    (
+                        (`ID` = {$iProfileId} AND `Profile` = {$iFriendId})
+                            OR
+                        (`ID` = {$iFriendId} AND `Profile` = {$iProfileId}) 
+                    )
+                        AND
+                    `Check` = 1 
+            ";
+
+            return $this -> oMigrationModule -> _oDb -> getOne($sQuery) ? true : false;
+        }
     }