D:/pwsrc2.0/docs/gauthd/getaddcashsn.hrp

Go to the documentation of this file.

/**
 * @file GetAddCashSN.hpp
 * @brief Заголовочный файл для обработки запросов генерации серийных номеров пополнения баланса
 */
 
#ifndef __GNET_GETADDCASHSN_HPP
#define __GNET_GETADDCASHSN_HPP
 
#include "rpcdefs.h"
#include "callid.hxx"
#include "state.hxx"
#include "getaddcashsnarg"
#include "getaddcashsnres"
#include "gmysqlclient.hpp"
#include "gauthserver.hpp"
#include "addcash.hpp"
 
namespace GNET
{
 
/**
 * @class GetAddCashSN
 * @brief RPC-класс для обработки запросов генерации серийных номеров пополнения
 * 
 * Наследует функциональность ProxyRpc и взаимодействует с базой данных через GMysqlClient,
 * а также отправляет ответы через GAuthServer.
 */
class GetAddCashSN : public ProxyRpc
{
#define RPC_BASECLASS ProxyRpc
    #include "getaddcashsn" ///< Включение сгенерированного RPC-кода
#undef RPC_BASECLASS
 
private:
    /**
     * @brief Отправляет информацию о неудачной операции в БД
     * @param userid Идентификатор пользователя
     * @param status Статус ошибки (0 - ошибка доставки, 1 - ошибка обработки)
     * @note Удаляет соответствующую запись из таблицы ошибок
     */
    void SendFailCash(int userid, int status)
    {
        printf("GetAddCashSN::SendFailCash: userid = %d \n", userid);
        GMysqlClient *db = GMysqlClient::GetInstance();
        int idx = db->GetCashUser(userid);
        char * creatime = db->GetCashCreaTime(idx);
        db->DeleteErrorRow(status, userid, creatime);
        db->DelCashUser(idx);
    }
 
public:
    /**
     * @brief Обрабатывает доставку RPC-запроса
     * @param proxy_sid Идентификатор сессии прокси
     * @param osArg Входные данные в виде OctetsStream
     * @return true если запрос успешно отправлен, false в случае ошибки
     * @note При ошибке отправляет спонсору результат ERR_DELIVER_SEND
     */
    bool Delivery(Manager::Session::ID proxy_sid, const OctetsStream& osArg)
    {
        if( GAuthServer::GetInstance()->Send(proxy_sid, *this ) )
            return true;
            
        GetAddCashSNArg arg;
        osArg >> arg;
        SetResult(GetAddCashSNRes(ERR_DELIVER_SEND));
        SendToSponsor();
        SendFailCash(arg.userid, 0);
        return false;
    }
 
    /**
     * @brief Постобработка результатов RPC-запроса
     * @param proxy_sid Идентификатор сессии прокси
     * @param osArg Входные аргументы
     * @param osRes Результаты выполнения
     * @note Обновляет статус операции в БД, инициирует пополнение баланса при успехе
     */
    void PostProcess(Manager::Session::ID proxy_sid, const OctetsStream& osArg, const OctetsStream& osRes)
    {
        GetAddCashSNArg arg;
        osArg >> arg;
        
        GetAddCashSNRes res;
        osRes >> res;
        
        GMysqlClient *db = GMysqlClient::GetInstance();
        if(res.retcode != 0) { 
            SendFailCash(res.userid, 1); 
            return; 
        }
        
        int idx = db->GetCashUser(res.userid);
        int cash = db->GetCashCash(idx);
        char * creatime = db->GetCashCreaTime(idx);
        
        if(!creatime || !cash) { 
            SendFailCash(res.userid, 1); 
            return; 
        }
        
        int result = db->SetUseCashNow(1, res.sn, res.userid, creatime);
        if( result )
        {
            AddCash Cash = AddCash(res.userid, res.zoneid, res.sn, cash );
            GAuthServer::GetInstance()->Send(proxy_sid, &Cash);
        }
        SetResult( &res );
    }
 
    /**
     * @brief Обработчик таймаута запроса
     * @note В текущей реализации не выполняет действий (закомментирован)
     */
    void OnTimeout( )
    {
        //SendFailCash();
    }
};
 
};
#endif