Changeset 13145

Timestamp:

11/05/09 10:48:23 (2 weeks ago)

Author:

Alexander Ermashev

Message:

- ticket #1416;

Files:

• 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;
+        }
-    }