D:/pwsrc2.0/docs/gauthd/userlogin.hpp

Go to the documentation of this file.

 
#ifndef __GNET_USERLOGIN_HPP
#define __GNET_USERLOGIN_HPP
 
#include "rpcdefs.h"
#include "callid.hxx"
#include "state.hxx"
 
#include "userloginarg"
#include "userloginres"
#include "gmysqlclient.hpp"
#include "gauthserver.hpp"
#include "kickoutuser.hpp"
 
namespace GNET
{

class UserLogin : public Rpc
{
#define RPC_BASECLASS Rpc
    #include "userlogin"  
#undef RPC_BASECLASS

    void Server(Rpc::Data *argument, Rpc::Data *result, Manager *manager, Manager::Session::ID sid)
    {
        UserLoginArg *arg = (UserLoginArg *)argument;
        UserLoginRes *res = (UserLoginRes *)result;
 
        GAuthServer* ausm = GAuthServer::GetInstance();
        char zoneid;
        
        // Блокировка доступа к карте зон
        {
            Thread::Mutex::Scoped l(ausm->locker_zonemap);    
            if(ausm->zonemap.find(sid) == ausm->zonemap.end()) return;
            zoneid = ausm->zonemap[sid];  
        }
 
        bool IsGM = false;
        int creatime = 0;
        char zid = zoneid;
        int zonelocalsid = arg->localsid;
        int overwrite = arg->blkickuser;
        
        GMysqlClient *db = GMysqlClient::GetInstance();
        // Обновление информации о подключении в БД
        db->OnlineRecord(arg->userid, db->GetAid(), zid, zonelocalsid, overwrite);
        db->UserCreatime(arg->userid, creatime);
        db->UserGMPrivilege(arg->userid, zid, IsGM);
        db->AlexAddLogin(arg->userid, 1);
 
        // Проверка согласованности идентификаторов зоны
        if(zid != zoneid || zonelocalsid != arg->localsid)
        {
            printf("UserLogin::Server zid != zoneid || zonelocalsid != arg->localsid \n");
        }
 
        // Обработка конфликта сессий с блокировкой записи
        Thread::RWLock::WRScoped l(ausm->locker_map);
        if(ausm->usermap.find(arg->userid) != ausm->usermap.end())
        {
            if(arg->blkickuser)
            {
                // Отправка команды отключения предыдущей сессии
                ausm->Send(ausm->usermap[arg->userid].sid, 
                          KickoutUser(arg->userid, ausm->usermap[arg->userid].localsid));
            }
            else
            {
                res->retcode = ERR_MULTILOGIN;
                return;
            }
        }
 
        // Заполнение результата
        res->retcode = ERR_SUCCESS;
        res->blIsGM = IsGM;
        res->func = 0;
        res->funcparm = 0;
        res->remain_playtime = creatime;
        res->free_time_left = 0;
        res->free_time_end = 0;
 
        // Обновление информации о пользователе
        ausm->usermap[arg->userid] = UserInfo(sid, arg->localsid, zoneid);
        
        DEBUG_PRINT("gauthd::userlogin: user(id=%d,localsid=%d) login successfully from zone %d\n",
                   arg->userid, arg->localsid, zoneid);
    }

    void Client(Rpc::Data *argument, Rpc::Data *result, Manager *manager, Manager::Session::ID sid)
    {
        // TODO: Реализовать клиентскую обработку
        // UserLoginArg *arg = (UserLoginArg *)argument;
        // UserLoginRes *res = (UserLoginRes *)result;
    }

    void OnTimeout()
    {
        // TODO: Реализовать обработку таймаутов для клиента
    }
};
 
};
#endif