sendaction.cpp

#include "common/macros.h"
#include "common/nndef.h"
#include "common/nnlogic.h"
#include "gameroot.h"
#include "logic/gamelogic/core/sendhdcard.h"
#include "utils/tarslog.h"
#include "context/context.h"
#include "message/sendclientmessage.h"
#include "config/gameconfig.h"
#include "logic/gamelogic/core/begintimer.h"
#include "logic/gamelogic/core/endtimer.h"
#include "logic/timeoutlogic/core/actiontimeout.h"
#include "process/process.h"
#include "message/sendroommessage.h"
#include "third.pb.h"
#include "XGameComm.pb.h"
#include "ddz.pb.h"

using namespace nndef;

namespace game
{
    namespace logic
    {
        namespace gamelogic
        {
            void SendAction(GameRoot *root, int opType)
            {
                PERFSTATS_ENTRY();
                __TRY__

                DLOG_TRACE("roomid:" << root->roomid() << ", " << "SendAction roomid:" << root->roomid());

                using namespace context;
                using namespace message;
                using namespace nnlogic;
                using namespace config;
                using namespace process;
                using namespace RoomSo;
                using namespace timeoutlogic;

                if(root->pro->getProcess() < NN_STATE_JIAODIZHU ||  root->pro->getProcess() > NN_STATE_DAPAI )
                {
                    DLOG_TRACE("roomid:" << root->roomid() << ", " << "SendAction process err. process:" << root->pro->getProcess());
                    return ;
                }

                DLOG_TRACE("roomid:" << root->roomid() << ", " << "tokencid: " << root->con->getTokenCid() <<", firstdapai: "<< root->con->isFirstDaPai());

                //是否第一手牌
                if(root->con->isFirstDaPai())
                {
                    root->con->setTokenCid(root->con->getBankerCid());
                }
                else
                {
                    if(root->con->getTokenCid() == nil_cid)
                    {
                        root->con->setTokenCid(rand() % 3);
                    }
                    else
                    {
                        cid_t nextCid = root->con->getNextCid(root->con->getTokenCid(), 3, 1);
                        root->con->setTokenCid(nextCid); 
                    }
                }

                root->con->setCurCid(root->con->getTokenCid());

                if(root->con->getStartCid() == nil_cid)
                {
                    root->con->setStartCid(root->con->getTokenCid());
                }
                
                int cfgActionTime = root->cfg->getDecisionTime(opType); 
                int remainActionTime = cfgActionTime;

                XGameDDZProto::DDZ_msg2sActNotify shcm2;
                shcm2.set_icid(root->con->getTokenCid());
                shcm2.set_iacttype(opType);
                shcm2.set_bfirstdapai(root->con->isFirstDaPai());

                switch(opType)
                {
                case 1://叫地主
                    break;
                case 2://加倍
                    break;
                case 3: //打牌
                    {
                        User* user = root->con->getUserByCid(root->con->getTokenCid());
                        if(user)
                        {
                            if(root->con->getLastDecision().size() == 1)
                            {
                                if(root->con->getLastDecision().begin()->first == user->getCid())
                                {
                                    root->con->clearLastDecision();
                                }
                            }
                            vecc_t vecCards = user->getVecCards();
                            auto last_decision = root->con->getLastDecision();
                            E_NN_TYPE lastCardType = root->con->getLastCardType();

                            vecc_t vecDaPaiCards;
                            E_NN_TYPE cardType = E_NN_TYPE::NN_TYPE_NN_NONE;
                            user->setCanDaPai(nnlogic::check(vecDaPaiCards, vecCards ,last_decision, lastCardType, cardType, 1) == 1);
                            shcm2.set_bcandapai(user->isCanDaPai());

                            for(auto decision : last_decision)
                            {
                                for(auto card : decision.second)
                                {
                                    shcm2.add_sprecards(card);
                                }
                            }
                            shcm2.set_iprecardtype(lastCardType);
                            if(user->isRobot())
                            {
                                cfgActionTime = rand() % 5 + 1;
                            }

                            if(user->isTuoGuan() || !user->isCanDaPai())
                            {
                                cfgActionTime = 3;
                            }
                        }
                        root->con->setFirstDaPai(false);
                    }
                    break;
                default:
                    DLOG_TRACE("roomid:" << root->roomid() << ", " << "opType err. opType:" << opType);
                break;
                }

                shcm2.set_icfgoptiontime(cfgActionTime);
                shcm2.set_iremainoptiontime(remainActionTime);

                if(opType == 1 || opType == 3)
                {
                    sendAllClientMessage<XGameDDZProto::DDZ_msg2sActNotify>(XGameDDZProto::DDZ_msg2sActNotify_E, shcm2, root);
                    DLOG_TRACE("roomid:" << root->roomid() << ", " << ">>>SendAction shcm2: " << logPb(shcm2));
                }
                else
                {
                    std::map<cid_t, User> &usermap = root->con->refUserMap();
                    for (auto it = usermap.begin(); it != usermap.end(); it++)
                    {
                        if(!it->second.isReady())
                        {
                            continue;
                        }
                        shcm2.set_icid(it->first);
                        sendClientMessage<XGameDDZProto::DDZ_msg2sActNotify>(it->second.getUid(), XGameDDZProto::DDZ_msg2sActNotify_E, shcm2, root);
                        DLOG_TRACE("roomid:" << root->roomid() << ", " << ">>>SendAction shcm2: " << logPb(shcm2));
                    }
                }

                root->con->setOptionTime();

                EndTimer(NN_XTIME_GAME_XTIME, root, false);
                BeginTimer(NN_XTIME_GAME_XTIME, cfgActionTime, [](TimerParam & param)->int
                {
                    auto body = static_cast<std::tuple<GameRoot *> const *>(param.getBody());
                    auto root = std::get<0>(*body);

                    ActionTimeOut(root);
                    return 0;
                }, root, false);

                __CATCH__
                PERFSTATS_EXIT();
            }
        }
    }
}