cocos2dx游戏任务系统开发之服务端数据库

分类：Cocos2d-x作者：编程之家用户

前面我给小伙伴们讲了任务系统客户端，服务端写了前搬部分的消息接受处理，现在我在借大家讲解一下当我在服务端这边接受到了客户端的消息，我要知道是不是满足了条件，现在你就要用到数据库了，不管是这样还有其他的比如像道具系统里面道具的查询，出售，人物上线的属性什么都是存到数据库的，这里数据库虽然存有大量的信息，但是在数据库里面做的逻辑操作没多少数据库里面的操作主要是增删改查存这些，其他基本都是在数据库之外操作，各位牛逼的大神都不要喷我这是个人学习来的，当然我才毕业没一年做起来有很多不完善的，我将在以后慢慢的完善改进，只求不喷。

#ifndef __BRUCE_DBPROXY_QUEST_HANDLER_HEADER__
#define __BRUCE_DBPROXY_QUEST_HANDLER_HEADER__

#include "typedef.hpp"
#include <Network.hpp>
#include "DBProxyApp.hpp"
#include "MySQL.hpp"
#include <DBProxyServer/Quest.hpp>
#include "QuestCommon.hpp"

DBPROXY_NS_BEGIN
 class QuestHandler { public: QuestHandler(); ~QuestHandler(); void initialize(); private: // 正在进行时的任务; void createTable(); // 创建完成任务以后储的任务表;Achieve void createAchieveTable(); void registerMessageHandler(); void handleGameServerRequestQuestInfo(Message::Ptr &message); void handleGameServerRequestQuestInfoCallBack(Result& result,SessionID sid,GS2DS_QuestSqlReq gQuestReqSql); //任务向关卡数据库查询提交的条件是否匹配; void handleGameToMissonSqlQuestInfo(Message::Ptr &message); //取出来; void handleGameServerRequestMissonQuestInfoCallBack(Result& result,GS2DS_QuestGetMissonCountInfoReq questGetMissonCountInfoReq); //删除当前数据表中所在的任务信息; void handleGameDeleteQuestIDInof(Message::Ptr &message); //删除后的数据; void handleDeleteDBProxyToGameQuestIDinfo(Result& result,GS2DS_QuesDeleteSqlInfoReq mQuesDeleteSqlInfoReq); //将删除的所有任务数据保存到下来; void handleDeleteQuestSeave(Message::Ptr &message); //将删除的所有任务数据保存到下来; void handleDeleteQuestIDinfo(Result& result,GS2DS_QuestDeltAndSeaveInfoReq sQuestDeltAndSeaveInfoReq); }; APP_NS_END #endif // !__BRUCE_DBPROXY_QUEST_HANDLER_HEADER__
#include "QuestHandler.hpp"

DBPROXY_NS_BEGIN

QuestHandler::QuestHandler()
{
}


QuestHandler::~QuestHandler()
{
}

void QuestHandler::registerMessageHandler()
{
    //DEFREG_MESSAGE(ID_GS2DS_QuestReqSql,QuestHandler,handleGameServerRequestQuestInfo)
    //接收Game过来的查询消息;
    DEFREG_MESSAGE(ID_GS2DS_QuestSqlReq,handleGameServerRequestQuestInfo)

    //接收任务向关卡数据库查请求提交的条件是否满足;
    DEFREG_MESSAGE(ID_GS2DS_QuestGetMissonCountInfoReq,handleGameToMissonSqlQuestInfo)

    //删除数据库中当前任务数据表示中的所在任务的信息;
    DEFREG_MESSAGE(ID_GS2DS_QuesDeleteSqlInfoReq,handleGameDeleteQuestIDInof)

    //保存当前删除的信息;
    DEFREG_MESSAGE(ID_GS2DS_QuestDeltAndSeaveInfoReq,handleDeleteQuestSeave)

}

void QuestHandler::initialize()
{
    createTable();
    createAchieveTable();
    registerMessageHandler();
}

//正在进行的任务表;
void QuestHandler::createTable()
{

    //正在进行的任务表;
    static Colume QuestTable[] =
    {
        { "id","bigint","0" },//任务的ID;
        { "type",//任务类型; 
        { "groups",//解锁等级;
        { " count",//次数;
    };

    g_MySQL.executeNoRs("CREATE TABLE `chr_quest_rec` (`char_id` int NOT NULL)");
    g_MySQL.addColume(QUEST_INFO_TABLE,QuestTable,sizeof(QuestTable) / sizeof(Colume));
}


void QuestHandler::handleGameServerRequestQuestInfo(Message::Ptr &message)
{


    GS2DS_QuestSqlReq questReqSql;
    message->unpack(questReqSql);

    char szSQL[1024] = { 0 };

    //从数据库中找出该玩家ID中的所任务信息;
    sprintf_s(szSQL,sizeof(szSQL),"select id,type,groups,count from chr_quest_rec where char_id = %d AND id = %d AND type = %d AND count = %d ",questReqSql.userID,questReqSql.nQuestid,questReqSql.nQuestType,questReqSql.nQuestCount);
    Query* pQuery = g_connectionPool.createQuery(szSQL);
    pQuery->setCallBack(makeCallBack(&QuestHandler::handleGameServerRequestQuestInfoCallBack,this,message->getSessionID(),questReqSql));

    g_connectionPool.pushQuery(pQuery);


}

void QuestHandler::handleGameServerRequestQuestInfoCallBack(Result& result,SessionID sid,GS2DS_QuestSqlReq cquestReqSql)
{
    if (result.errno())
    {
        BRUCE_LOG(BruCe::logger::Log_Error,"%d",cquestReqSql.userID);
        BRUCE_LOG(BruCe::logger::Log_Debug,"%s:%d handleGameServerRequestQuestInfoCallBack erroe: %s",__FILE__,__LINE__,result.error().c_str());

    } 

    DS2GS_QuestSqlAck qusetAckSql;

    Row* pRow = nullptr;
    for (Row* pRow = result.fetch(); pRow != NULL; pRow = result.fetch())
    {
        i32 SqlQuestInfo = 0;
        *pRow >> SqlQuestInfo;
        qusetAckSql.nQuestfistInfo.push_back(SqlQuestInfo);

    }


    // 将服务查询的数据发送给GameSever接收;

    qusetAckSql.userID = cquestReqSql.userID;
    qusetAckSql.seq = cquestReqSql.seq;
    qusetAckSql.nQuestCount = cquestReqSql.nQuestCount;
    qusetAckSql.nQuestType = cquestReqSql.nQuestType;
    qusetAckSql.Result = 1;

    Message::Ptr sendMsg(new Message());
    sendMsg->pack(qusetAckSql);

    g_sessionManager.send(sid,sendMsg);

}

    //任务向关卡数据库查询提交的条件是否匹配;
void QuestHandler::handleGameToMissonSqlQuestInfo(Message::Ptr &message)
{
    GS2DS_QuestGetMissonCountInfoReq questGetMissonCountInfoReq;
    message->unpack(questGetMissonCountInfoReq);

    char szSQL[1024] = { 0 };

    //从数据库中找出该玩家ID中的所任务信息   如果当传进来的参数是你要选择的这个那么 （mission_count = mission_count);
    //
    sprintf_s(szSQL,"select mission_count from mission_info where char_id = %d AND mission_type = %d ",questGetMissonCountInfoReq.userID,questGetMissonCountInfoReq.mQuestType);
    Query* pQuery = g_connectionPool.createQuery(szSQL);
    pQuery->setCallBack(makeCallBack(&QuestHandler::handleGameServerRequestMissonQuestInfoCallBack,questGetMissonCountInfoReq));

    g_connectionPool.pushQuery(pQuery);

}

void QuestHandler::handleGameServerRequestMissonQuestInfoCallBack(Result& result,GS2DS_QuestGetMissonCountInfoReq questGetMissonCountInfoReq)
{
    if (result.errno())
    {
        BRUCE_LOG(BruCe::logger::Log_Error,questGetMissonCountInfoReq.mQuestType);
        BRUCE_LOG(BruCe::logger::Log_Debug,"%s:%d handleGameServerRequestMissonQuestInfoCallBack erroe: %s",result.error().c_str());

    }
    DS2GS_QuestGetMissonCountInfoAck questGetMissonCountInfoAck;

    for (Row* pRow = result.fetch(); pRow != NULL; pRow = result.fetch()) 
    {
        //*pRow >> questGetMissonCountInfoAck.mQuestType; *pRow >> questGetMissonCountInfoAck.mQuestCount; } // 将服务查询的数据发送给GameSever接收; questGetMissonCountInfoAck.userID = questGetMissonCountInfoReq.userID; questGetMissonCountInfoAck.seq = questGetMissonCountInfoReq.seq; questGetMissonCountInfoAck.mQuestID = questGetMissonCountInfoReq.mQuestID; questGetMissonCountInfoAck.Result = 1; Message::Ptr sendMsg(new Message()); sendMsg->pack(questGetMissonCountInfoAck); g_sessionManager.send(sid,sendMsg); } /***********创建第二张保存表提交完成的任务***************************************************/

// 创建完成任务以后储的任务表;Achieve
void QuestHandler::createAchieveTable()
{
    // 创建完成任务以后储存的任务表;
    static Colume QuestAchieveTable[] =
    {
        { "id",//次数;
    };

    g_MySQL.executeNoRs("CREATE TABLE `chr_quest_achieve` (`char_id` int NOT NULL)");
    g_MySQL.addColume(QUEST_ACHIEVE_TABLE,QuestAchieveTable,sizeof(QuestAchieveTable) / sizeof(Colume));
}


//删除当前数据表中所在的任务信息;
void QuestHandler::handleGameDeleteQuestIDInof(Message::Ptr &message)
{


    GS2DS_QuesDeleteSqlInfoReq mQuesDeleteSqlInfoReq;
    message->unpack(mQuesDeleteSqlInfoReq);

    char szSQL[1024] = { 0 };
    //sprintf_s(szSQL,"select chr_ques from mission_info where char_id ",questGetMissonCountInfoReq.userID);
    sprintf_s(szSQL,"delete from chr_quest_rec where char_id = %d AND id = %d",mQuesDeleteSqlInfoReq.userID,mQuesDeleteSqlInfoReq.dQuestID);
    Query* pQuery = g_connectionPool.createQuery(szSQL);
    pQuery->setCallBack(makeCallBack(&QuestHandler::handleDeleteDBProxyToGameQuestIDinfo,mQuesDeleteSqlInfoReq));
    g_connectionPool.pushQuery(pQuery);

}

//删除后的数据;
void QuestHandler::handleDeleteDBProxyToGameQuestIDinfo(Result& result,GS2DS_QuesDeleteSqlInfoReq mQuesDeleteSqlInfoReq)
{

    if (result.errno())
    {
        BRUCE_LOG(BruCe::logger::Log_Error,mQuesDeleteSqlInfoReq.dQuestID);
        BRUCE_LOG(BruCe::logger::Log_Debug,"%s:%d handleDeleteDBProxyToGameQuestIDinfo erroe: %s",result.error().c_str());
    }

    DS2GS_QuesDeleteSqlInfoAck mQuesDeleteSqlInfoAck;

    mQuesDeleteSqlInfoAck.userID = mQuesDeleteSqlInfoReq.userID;
    mQuesDeleteSqlInfoAck.seq = mQuesDeleteSqlInfoReq.seq;
    mQuesDeleteSqlInfoAck.dQuestID = mQuesDeleteSqlInfoReq.dQuestID;

    Message::Ptr sendMsg(new Message());
    sendMsg->pack(mQuesDeleteSqlInfoAck);
    g_sessionManager.send(sid,sendMsg);

}


//将删除的所有任务数据保存到下来;
void QuestHandler::handleDeleteQuestSeave(Message::Ptr &message)
{

    GS2DS_QuestDeltAndSeaveInfoReq sQuestDeltAndSeaveInfoReq;
    message->unpack(sQuestDeltAndSeaveInfoReq);

    char szSQL[1024] = { 0 };
    sprintf_s(szSQL,"insert into chr_quest_achieve(char_id,id,count) value(%d,%d,%d)",sQuestDeltAndSeaveInfoReq.userID,sQuestDeltAndSeaveInfoReq.QuestSeaveDleID,sQuestDeltAndSeaveInfoReq.QuestSeaveDleType,sQuestDeltAndSeaveInfoReq.QuestSeaveDleGroups,sQuestDeltAndSeaveInfoReq.QuestSeaveDleCount);
    Query* pQuery = g_connectionPool.createQuery(szSQL);
    pQuery->setCallBack(makeCallBack(&QuestHandler::handleDeleteQuestIDinfo,sQuestDeltAndSeaveInfoReq));
    g_connectionPool.pushQuery(pQuery);
}

//将删除的所有任务数据保存下来;
void QuestHandler::handleDeleteQuestIDinfo(Result& result,GS2DS_QuestDeltAndSeaveInfoReq sQuestDeltAndSeaveInfoReq)
{
    if (result.errno())
    {
        BRUCE_LOG(BruCe::logger::Log_Error,sQuestDeltAndSeaveInfoReq.userID);
        BRUCE_LOG(BruCe::logger::Log_Debug,"%s:%d handleDeleteQuestIDinfo erroe: %s",result.error().c_str());
    }

    DS2GS_QuestDeltAndSeaveInfoAck sQuestDeltAndSeaveInfoAck;

    sQuestDeltAndSeaveInfoAck.userID = sQuestDeltAndSeaveInfoReq.userID;
    sQuestDeltAndSeaveInfoAck.seq = sQuestDeltAndSeaveInfoReq.seq;
    sQuestDeltAndSeaveInfoAck.QuestSeaveDleID = sQuestDeltAndSeaveInfoReq.QuestSeaveDleID;

    Message::Ptr sendMsg(new Message());
    sendMsg->pack(sQuestDeltAndSeaveInfoAck);
    g_sessionManager.send(sid,sendMsg);

}





APP_NS_END

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

如何使用CCRenderTexture创建动态纹理 Cocos2d-x 2 1 4
    本文实践自 RayWenderlich、Ali Hafizji 的文章《How To Create Dynamic Textures with CCRenderTexture in Cocos2D 2.X》，文中使用Cocos2D，我在这里使用Cocos2D-x 2.1.4进行学习和移植。在这篇文章，将会学习到如何创建实时纹理、如何用Gimp创建无缝拼接纹
Cocos-code-ide使用入门学习
Cocos-code-ide使用入门学习地点：杭州滨江邮箱：appdevzw@163.com微信公众号：HopToad 欢迎转载，转载标注出处：http://blog.csdn.netotbaron/article/details/424343991.  软件准备 下载地址：http://cn.cocos2d-x.org/download 2.  简介2.1         引用C
Cocos2D-x-3.0 编译(Win7)
第一次開始用手游引擎挺激动！！！进入正题。下载资源1：从Cocos2D-x官网上下载，进入网页http://www.cocos2d-x.org/download，点击Cocos2d-x以下的Download  v3.0，保存到自定义的文件夹2：从python官网上下载。进入网页https://www.python.org/downloads/，我当前下载的是3.4.0（当前最新
Cocos2d-x 2 0 在Windows平台下的使用
    Cocos2d-x是一款强大的基于OpenGLES的跨平台游戏开发引擎，易学易用，支持多种智能移动平台。官网地址：http://cocos2d-x.org/当前版本：2.0    有很多的学习资料，在这里我只做为自己的笔记记录下来，错误之处还请指出。在VisualStudio2008平台的编译：1.下载当前稳
quick-cocos2d-x实例之挑战记忆极限设计文档
1.  来源 QuickV3sample项目中的2048样例游戏，以及最近《最强大脑》娱乐节目。将2048改造成一款挑战玩家对数字记忆的小游戏。邮箱：appdevzw@163.com微信公众号：HopToadAPK下载地址：http://download.csdn.net/detailotbaron/8446223源码下载地址：http://download.csdn.net/
Cocos2d-x 3 X CMake MinGW版本编译运行
   Cocos2d-x3.x已经支持使用CMake来进行构建了，这里尝试以QtCreatorIDE来进行CMake构建。Cocos2d-x3.X地址：https://github.com/cocos2d/cocos2d-x1.打开QtCreator，菜单栏→"打开文件或项目..."，打开cocos2d-x目录下的CMakeLists.txt文件；2.弹出CMake向导，如下图所示：设置
vs 2013 编译cocos2d-x-3.9
 下载地址：链接:https://pan.baidu.com/s/1IkQsMU6NoERAAQLcCUMcXQ提取码:p1pb下载完成后，解压进入build目录使用vs2013打开工程设置平台工具集，打开设置界面设置： 点击开始编译等待编译结束编译成功在build文件下会出现一个新文件夹Debug.win32，里面就是编译
cocos2d-x游戏开发系列教程-超级玛丽01-前言
分享一下我老师大神的人工智能教程吧。零基础！通俗易懂！风趣幽默！还带黄段子！希望你也加入到我们人工智能的队伍中来！http://www.captainbed.net前言上次用象棋演示了cocos2dx的基本用法，但是对cocos2dx并没有作深入的讨论，这次以超级马里奥的源代码为线索，我们一起来学习超级马里奥的实
Cocos2d-x CCControlPotentiometer之圆形音量button及特效
1. 圆形音量button事实上作者的本意应该是叫做“电位计button”。可是我觉得它和我们的圆形音量button非常像，所以就这么叫它吧~先看效果：好了，不多解释，本篇到此为止。（旁白： 噗。就这样结束了？）啊才怪~我们来看看代码：[cpp] viewplaincopyprint?CCContro
Cocos2d-x入门教程二简单的静态显示对象
原文链接：http://www.cnblogs.com/physwf/archive/2013/04/26/3043912.html为了进一步深入学习贯彻Cocos2d，我们将自己写一个场景类，但我们不会走的太远，凡是都要循序渐进，哪怕只前进一点点，那也至少是前进了，总比贪多嚼不烂一头雾水的好。在上一节中我们建
cocos2d-x中CCScale9Sprite的另一种实现
2019独角兽企业重金招聘Python工程师标准>>>cocos2d2.0之后加入了一种九宫格的实现，主要作用是用来拉伸图片，这样的好处在于保留图片四个角不变形的同时，对图片中间部分进行拉伸，来满足一些控件的自适应（PS: 比如包括按钮，对话框，最直观的形象就是ios里的短信气泡了），这就要求图
Cocos2d-x v2.2.2版本+Win7+VS2010环境搭建
原文链接：http://www.cnblogs.com/linji/p/3599478.html1.环境和工具准备Win7VS2010/2012，至于2008v2版本之后似乎就不支持了。 2.安装pythonv.2.0版本之前是用vs模板创建工程的，到vs2.2之后就改用python创建了。到python官网下载版本2.7.5的，然后
Ubuntu14.04+eclipse下cocos2d-x3.0正式版环境的搭建
环境:ubuntu14.04adt-bundle-linux-x86_64android-ndk-r9d-linux-x86_64cocos2d-x-3.0正式版apache-ant1.9.3python2.7(ubuntu自带)加入环境变量exportANDROID_SDK_ROOT=/home/yangming/adt-bundle-linux/sdkexportPATH=${PATH}:/$ANDROID_SDK_ROOTools/export
分别基于WIN32 API界面编程和Cocos2d-x实现的两个版本FlappyBird游戏
1开发背景游戏程序设计涉及了学科中的各个方面，鉴于目的在于学习与进步，本游戏《FlappyBird》采用了两个不同的开发方式来开发本款游戏，一类直接采用win32底层API来实现，另一类采用当前火热的cocos2d-x游戏引擎来开发本游戏。2需求分析2.1数据分析本项目要开发的是一款游
Cocos2d-x 开发小记二：控件
原文链接：http://www.cnblogs.com/linji/p/3599912.html//纯色色块控件（锚点默认左下角）CCLayerColor*ccc=CCLayerColor::create(ccc4(255,0,0,128),200,100);//渐变色块控件CCLayerGradient*ccc=CCLayerGradient::create(ccc4(255,0,0,
Cocos2d-x 开发小记一：基本动作
原文链接：http://www.cnblogs.com/linji/p/3599488.html//载入一张图片CCSprite*leftDoor=CCSprite::create("loading/door.png");leftDoor->setAnchorPoint(ccp(1,0.5));//设置锚点为右边中心点leftDoor->setPosition(ccp(240,160));/
买Cocos2d-x视频课程送纸质图书
为了答谢广大学员对智捷课堂以及关老师的支持，现购买51CTO学院关老师的Cocos2d-x课程之一可以送智捷课堂编写图书一本（专题可以送3本）。一、Cocos2d-x课程列表：1、Cocos2d-x入门与提高视频教程__Part22、Cocos2d-x数据持久化与网络通信__Part33、Cocos2d-x架构设计与性能优化内存优
‎Cocos2d-x 学习笔记(11.10) Spawn
Spawn让多个action同时执行。Spawn有多种不同的create方法，最终都调用了createWithTwoActions(FiniteTimeAction*action1,FiniteTimeAction*action2)方法。createWithTwoActions调用initWithTwoActions方法：对两个action变量初始化：_one=action1;_two=action2;如果两个a
quick-cocos2d-x-develop资源打包环境安装
需要环境：php,luajit.昨天在cygwin上安装php和luajit环境，这真特么是一个坑。建议不要用虚拟环境安装打包环境，否则可能会出现各种莫名问题。折腾了一下午，最终将环境转向linux。其中，luajit的安装脚本已经在quick-cocos2d-x-develop/bin/中，直接luajit_install.sh即可。我的lin
Cocos2d-x 3.0心得01－图片载入与混合模式
v3.0相对v2.2来说，最引人注意的。应该是对触摸层级的优化。和lambda回调函数的引入（嗯嗯，不枉我改了那么多类名。话说，每次cocos2dx大更新。总要改掉一堆类名函数名）。这些特性应该有不少人研究了，所以今天说点跟图片有关的东西。v3.0在载入图片方面也有了非常大改变，仅仅只是
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot