lib/tools.php

Go to the documentation of this file.

<?php
/***************************************************************************
 This program is free software; you can redistribute it and/or
 modify it under the terms of the GNU General Public License
 as published by the Free Software Foundation; either version 2
 of the License, or (at your option) any later version.

 This program is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.

 You should have received a copy of the GNU General Public License
 along with this program; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 ***************************************************************************/

class Tools
{
    var $oDB;   

    function Tools( &$oDB )
    {
        $this->oDB =& $oDB;
    }

    function clean( $booCleanMap )
    {
        $intCount = 0;
        $this->oDB->query('DELETE FROM '.$this->oDB->tblPlayer.' WHERE player_id > 1;');
        $this->oDB->query('UPDATE '.$this->oDB->tblUser.' SET player_id=0;');
        $intCount += intval( $this->oDB->affected_rows() );
        $this->oDB->query('DELETE FROM '.$this->oDB->tblTown.';');
        $intCount += intval( $this->oDB->affected_rows() );
        $this->oDB->query('DELETE FROM '.$this->oDB->tblGuild.' WHERE guild_id > 1;');
        $intCount += intval( $this->oDB->affected_rows() );
        $this->oDB->query('DELETE FROM '.$this->oDB->tblMapData.';');
        $intCount += intval( $this->oDB->affected_rows() );
        if( $booCleanMap )
        {
            $this->oDB->query('DELETE FROM '.$this->oDB->tblMap.';');
            $intCount += intval( $this->oDB->affected_rows() );
        }
        return $intCount;
    }

    function csvimport( $intServerId, $intLine = 0, $intLinesPerCall = 10, $booDbIsClean = false )
    {
        // check if import file exists
        if( !file_exists( './server'.$intServerId.'.csv' ) )
        {
            return false;
        }
        $fp = fopen( './server'.$intServerId.'.csv', 'r' );
        if( $fp === false )
        {
            // opening file failed
            return false;
        }


        // get first line (which is not needed) and check if it has the right length
        $aLine = fgetcsv( $fp, 10000, ',' );
        if( count( $aLine ) - 2 != $GLOBALS['intMapSize'] )
        {
            return false;
        }
        $booLastRun = false;

        // position the filepointer
        $intPosition = ( $GLOBALS['intMapSize'] * 3 + 5 ) * $intLine;
        fseek( $fp, $intPosition );

        $aMap = array();
        $intTime = time();
        $intCount = $intLine + $intLinesPerCall;
        if( $intCount > $GLOBALS['intMapSize'] + 1 )
        {
            $intCount = $GLOBALS['intMapSize'] + 1;
            $booLastRun = true;
        }
        // first add all fields to the map array
        for( $y = $intLine; $y < $intCount; $y++)
        {
            $aLineInfo = fgetcsv( $fp, 10000, ',' );
            if( $aLineInfo === false )
            {
                // there was not a line... -> finished
                $booLastRun = true;
                $y = $intCount;
                continue;
            }
            $intSize = count( $aLineInfo ) - 1;
            for( $x = 1; $x < $intSize; $x++ )
            {
                $aMap[$x.'-'.$y] = array( 't' => $aLineInfo[$x], 'x' => $x, 'y' => $y );
            }
        }
        fclose( $fp );

        // now insert all into the database
        if( !$booDbIsClean )
        {
            // database is not clean, we have to check each field
            $aCurrentMap = array();
            $sqlReturn = $this->oDB->query( "SELECT x,y,terrain FROM ".$this->oDB->tblMap." WHERE y BETWEEN $intLine AND $intCount;");
            while( $aRow = $this->oDB->fetch_assoc( $sqlReturn ) )
            {
                $aCurrentMap[$aRow['x'].'-'.$aRow['y']] = $aRow['terrain'];
            }
            // all available fields are in the array, start the import
            $strInsert = '';
            foreach( $aMap AS $aField )
            {
                if( !isset( $aCurrentMap[$aField['x'].'-'.$aField['y']] ) )
                {
                    // field is not in the db, insert it later
                    $strInsert .= '('.$aField['x'].','.$aField['y'].','.$aField['t'].'),';
                }
                elseif( $aCurrentMap[$aField['x'].'-'.$aField['y']]['terrain'] != $aField['t'] )
                {
                    // update the field
                    $this->oDB->query("UPDATE ".$this->oDB->tblMap." SET terrain='".$aField['t']."' WHERE x='".$aField['x']."' AND y='".$aField['y']."';" );
                }
            }
            if( $strInsert != '' )
            {
                // strip the last ,
                $strInsert = 'INSERT INTO '.$this->oDB->tblMap.' (x,y,terrain) VALUES '.substr( $strInsert, 0, -1 ).';';
                $this->oDB->query( $strInsert );
            }
        }
        else
        {
            // database is clean, we can do all inserts at once!
            $strInsert = '';
            foreach( $aMap AS $aField )
            {
                $strInsert .= '('.$aField['x'].','.$aField['y'].','.$aField['t'].'),';
            }
            if( $strInsert != '' )
            {
                // strip the last ,
                $strInsert = 'INSERT INTO '.$this->oDB->tblMap.' (x,y,terrain) VALUES '.substr( $strInsert, 0, -1 ).';';
                $this->oDB->query($strInsert);
            }
        }
        if( $booLastRun )
        {
            // analyze table, to optimize later queries
            $this->oDB->query('ANALYZE TABLE `'.$this->oDB->tblMap.'`;');
        }

        return $booLastRun ? true : ( $intLine + $intLinesPerCall );
    }
}

---