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

Cocos2d-x 前端之家
前端之家收集整理的这篇文章主要介绍了cocos2dx游戏任务系统开发之服务端数据库，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。

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

  1. #ifndef __BRUCE_DBPROXY_QUEST_HANDLER_HEADER__
  2. #define __BRUCE_DBPROXY_QUEST_HANDLER_HEADER__
  3.  
  4. #include "typedef.hpp"
  5. #include <Network.hpp>
  6. #include "DBProxyApp.hpp"
  7. #include "MysqL.hpp"
  8. #include <DBProxyServer/Quest.hpp>
  9. #include "QuestCommon.hpp"
  10.  
  11. DBPROXY_NS_BEGIN
  12.  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__
  1. #include "QuestHandler.hpp"
  2.  
  3. DBPROXY_NS_BEGIN
  4.  
  5. QuestHandler::QuestHandler()
  6. {
  7. }
  8.  
  9.  
  10. QuestHandler::~QuestHandler()
  11. {
  12. }
  13.  
  14. void QuestHandler::registerMessageHandler()
  15. {
  16.     //DEFREG_MESSAGE(ID_GS2DS_QuestReqsql,QuestHandler,handleGameServerRequestQuestInfo)
  17.     //接收Game过来的查询消息;
  18.     DEFREG_MESSAGE(ID_GS2DS_QuestsqlReq,handleGameServerRequestQuestInfo)
  19.  
  20.     //接收任务向关卡数据库查请求提交的条件是否满足;
  21.     DEFREG_MESSAGE(ID_GS2DS_QuestGetMissonCountInfoReq,handleGameToMissonsqlQuestInfo)
  22.  
  23.     //删除数据库中当前任务数据表示中的所在任务的信息;
  24.     DEFREG_MESSAGE(ID_GS2DS_QuesDeletesqlInfoReq,handleGameDeleteQuestIDInof)
  25.  
  26.     //保存当前删除的信息;
  27.     DEFREG_MESSAGE(ID_GS2DS_QuestDeltAndSeaveInfoReq,handleDeleteQuestSeave)
  28.  
  29. }
  30.  
  31. void QuestHandler::initialize()
  32. {
  33.     createTable();
  34.     createAchieveTable();
  35.     registerMessageHandler();
  36. }
  37.  
  38. //正在进行的任务表;
  39. void QuestHandler::createTable()
  40. {
  41.  
  42.     //正在进行的任务表;
  43.     static Colume QuestTable[] =
  44.     {
  45.         { "id","bigint","0" },//任务的ID;
  46.         { "type",//任务类型; 
  47.         { "groups",//解锁等级;
  48.         { " count",//次数;
  49.     };
  50.  
  51.     g_MysqL.executeNoRs("CREATE TABLE `chr_quest_rec` (`char_id` int NOT NULL)");
  52.     g_MysqL.addColume(QUEST_INFO_TABLE,QuestTable,sizeof(QuestTable) / sizeof(Colume));
  53. }
  54.  
  55.  
  56. void QuestHandler::handleGameServerRequestQuestInfo(Message::Ptr &message)
  57. {
  58.  
  59.  
  60.     GS2DS_QuestsqlReq questReqsql;
  61.     message->unpack(questReqsql);
  62.  
  63.     char szsql[1024] = { 0 };
  64.  
  65.     //从数据库中找出该玩家ID中的所任务信息;
  66.     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);
  67.     Query* pQuery = g_connectionPool.createQuery(szsql);
  68.     pQuery->setCallBack(makeCallBack(&QuestHandler::handleGameServerRequestQuestInfoCallBack,this,message->getSessionID(),questReqsql));
  69.  
  70.     g_connectionPool.pushQuery(pQuery);
  71.  
  72.  
  73. }
  74.  
  75. void QuestHandler::handleGameServerRequestQuestInfoCallBack(Result& result,SessionID sid,GS2DS_QuestsqlReq cquestReqsql)
  76. {
  77.     if (result.errno())
  78.     {
  79.         BRUCE_LOG(BruCe::logger::Log_Error,"%d",cquestReqsql.userID);
  80.         BRUCE_LOG(BruCe::logger::Log_Debug,"%s:%d handleGameServerRequestQuestInfoCallBack erroe: %s",__FILE__,__LINE__,result.error().c_str());
  81.  
  82.     } 
  83.  
  84.     DS2GS_QuestsqlAck qusetAcksql;
  85.  
  86.     Row* pRow = nullptr;
  87.     for (Row* pRow = result.fetch(); pRow != NULL; pRow = result.fetch())
  88.     {
  89.         i32 sqlQuestInfo = 0;
  90.         *pRow >> sqlQuestInfo;
  91.         qusetAcksql.nQuestfistInfo.push_back(sqlQuestInfo);
  92.  
  93.     }
  94.  
  95.  
  96.     // 将服务查询的数据发送给GameSever接收;
  97.  
  98.     qusetAcksql.userID = cquestReqsql.userID;
  99.     qusetAcksql.seq = cquestReqsql.seq;
  100.     qusetAcksql.nQuestCount = cquestReqsql.nQuestCount;
  101.     qusetAcksql.nQuestType = cquestReqsql.nQuestType;
  102.     qusetAcksql.Result = 1;
  103.  
  104.     Message::Ptr sendMsg(new Message());
  105.     sendMsg->pack(qusetAcksql);
  106.  
  107.     g_sessionManager.send(sid,sendMsg);
  108.  
  109. }
  110.  
  111.     //任务向关卡数据库查询提交的条件是否匹配;
  112. void QuestHandler::handleGameToMissonsqlQuestInfo(Message::Ptr &message)
  113. {
  114.     GS2DS_QuestGetMissonCountInfoReq questGetMissonCountInfoReq;
  115.     message->unpack(questGetMissonCountInfoReq);
  116.  
  117.     char szsql[1024] = { 0 };
  118.  
  119.     //从数据库中找出该玩家ID中的所任务信息   如果当传进来的参数是你要选择的这个那么 （mission_count = mission_count);
  120.     //
  121.     sprintf_s(szsql,"select mission_count from mission_info where char_id = %d AND mission_type = %d ",questGetMissonCountInfoReq.userID,questGetMissonCountInfoReq.mQuestType);
  122.     Query* pQuery = g_connectionPool.createQuery(szsql);
  123.     pQuery->setCallBack(makeCallBack(&QuestHandler::handleGameServerRequestMissonQuestInfoCallBack,questGetMissonCountInfoReq));
  124.  
  125.     g_connectionPool.pushQuery(pQuery);
  126.  
  127. }
  128.  
  129. void QuestHandler::handleGameServerRequestMissonQuestInfoCallBack(Result& result,GS2DS_QuestGetMissonCountInfoReq questGetMissonCountInfoReq)
  130. {
  131.     if (result.errno())
  132.     {
  133.         BRUCE_LOG(BruCe::logger::Log_Error,questGetMissonCountInfoReq.mQuestType);
  134.         BRUCE_LOG(BruCe::logger::Log_Debug,"%s:%d handleGameServerRequestMissonQuestInfoCallBack erroe: %s",result.error().c_str());
  135.  
  136.     }
  137.     DS2GS_QuestGetMissonCountInfoAck questGetMissonCountInfoAck;
  138.  
  139.     for (Row* pRow = result.fetch(); pRow != NULL; pRow = result.fetch()) 
  140.     {
  141.         //*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); } /***********创建第二张保存表提交完成的任务***************************************************/
  142.  
  143. // 创建完成任务以后储的任务表;Achieve
  144. void QuestHandler::createAchieveTable()
  145. {
  146.     // 创建完成任务以后储存的任务表;
  147.     static Colume QuestAchieveTable[] =
  148.     {
  149.         { "id",//次数;
  150.     };
  151.  
  152.     g_MysqL.executeNoRs("CREATE TABLE `chr_quest_achieve` (`char_id` int NOT NULL)");
  153.     g_MysqL.addColume(QUEST_ACHIEVE_TABLE,QuestAchieveTable,sizeof(QuestAchieveTable) / sizeof(Colume));
  154. }
  155.  
  156.  
  157. //删除当前数据表中所在的任务信息;
  158. void QuestHandler::handleGameDeleteQuestIDInof(Message::Ptr &message)
  159. {
  160.  
  161.  
  162.     GS2DS_QuesDeletesqlInfoReq mQuesDeletesqlInfoReq;
  163.     message->unpack(mQuesDeletesqlInfoReq);
  164.  
  165.     char szsql[1024] = { 0 };
  166.     //sprintf_s(szsql,"select chr_ques from mission_info where char_id ",questGetMissonCountInfoReq.userID);
  167.     sprintf_s(szsql,"delete from chr_quest_rec where char_id = %d AND id = %d",mQuesDeletesqlInfoReq.userID,mQuesDeletesqlInfoReq.dQuestID);
  168.     Query* pQuery = g_connectionPool.createQuery(szsql);
  169.     pQuery->setCallBack(makeCallBack(&QuestHandler::handleDeleteDBProxyToGameQuestIDinfo,mQuesDeletesqlInfoReq));
  170.     g_connectionPool.pushQuery(pQuery);
  171.  
  172. }
  173.  
  174. //删除后的数据;
  175. void QuestHandler::handleDeleteDBProxyToGameQuestIDinfo(Result& result,GS2DS_QuesDeletesqlInfoReq mQuesDeletesqlInfoReq)
  176. {
  177.  
  178.     if (result.errno())
  179.     {
  180.         BRUCE_LOG(BruCe::logger::Log_Error,mQuesDeletesqlInfoReq.dQuestID);
  181.         BRUCE_LOG(BruCe::logger::Log_Debug,"%s:%d handleDeleteDBProxyToGameQuestIDinfo erroe: %s",result.error().c_str());
  182.     }
  183.  
  184.     DS2GS_QuesDeletesqlInfoAck mQuesDeletesqlInfoAck;
  185.  
  186.     mQuesDeletesqlInfoAck.userID = mQuesDeletesqlInfoReq.userID;
  187.     mQuesDeletesqlInfoAck.seq = mQuesDeletesqlInfoReq.seq;
  188.     mQuesDeletesqlInfoAck.dQuestID = mQuesDeletesqlInfoReq.dQuestID;
  189.  
  190.     Message::Ptr sendMsg(new Message());
  191.     sendMsg->pack(mQuesDeletesqlInfoAck);
  192.     g_sessionManager.send(sid,sendMsg);
  193.  
  194. }
  195.  
  196.  
  197. //将删除的所有任务数据保存到下来;
  198. void QuestHandler::handleDeleteQuestSeave(Message::Ptr &message)
  199. {
  200.  
  201.     GS2DS_QuestDeltAndSeaveInfoReq sQuestDeltAndSeaveInfoReq;
  202.     message->unpack(sQuestDeltAndSeaveInfoReq);
  203.  
  204.     char szsql[1024] = { 0 };
  205.     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);
  206.     Query* pQuery = g_connectionPool.createQuery(szsql);
  207.     pQuery->setCallBack(makeCallBack(&QuestHandler::handleDeleteQuestIDinfo,sQuestDeltAndSeaveInfoReq));
  208.     g_connectionPool.pushQuery(pQuery);
  209. }
  210.  
  211. //将删除的所有任务数据保存下来;
  212. void QuestHandler::handleDeleteQuestIDinfo(Result& result,GS2DS_QuestDeltAndSeaveInfoReq sQuestDeltAndSeaveInfoReq)
  213. {
  214.     if (result.errno())
  215.     {
  216.         BRUCE_LOG(BruCe::logger::Log_Error,sQuestDeltAndSeaveInfoReq.userID);
  217.         BRUCE_LOG(BruCe::logger::Log_Debug,"%s:%d handleDeleteQuestIDinfo erroe: %s",result.error().c_str());
  218.     }
  219.  
  220.     DS2GS_QuestDeltAndSeaveInfoAck sQuestDeltAndSeaveInfoAck;
  221.  
  222.     sQuestDeltAndSeaveInfoAck.userID = sQuestDeltAndSeaveInfoReq.userID;
  223.     sQuestDeltAndSeaveInfoAck.seq = sQuestDeltAndSeaveInfoReq.seq;
  224.     sQuestDeltAndSeaveInfoAck.QuestSeaveDleID = sQuestDeltAndSeaveInfoReq.QuestSeaveDleID;
  225.  
  226.     Message::Ptr sendMsg(new Message());
  227.     sendMsg->pack(sQuestDeltAndSeaveInfoAck);
  228.     g_sessionManager.send(sid,sendMsg);
  229.  
  230. }
  231.  
  232.  
  233.  
  234.  
  235.  
  236. APP_NS_END

猜你在找的Cocos2d-x相关文章

创建自定义的Cocos2d-x场景
操作步骤 1、创建cocos2d-x工程 2、新建 Scene1.cpp Scene1.h Scene1.h代码 #ifndef __SCE...
给vs2010安装上cocos2d-x的模版
开发环境：OS(WINDOWS 8.1 X64 企业版) cocos2d-x 2.2.1 vs2010 想给vs安装上cocos的模版，...
Python创建Cocos2d-x 2.2方法
把创建项目做成一个批处理，当创建项目时可以省时省力很多。 操作步骤 1、在 E:cocos2d-x-...
cocos2dx 物理碰撞
https://www.cnblogs.com/JiaoQing/p/3906780.html 四个响应函数 1 EventListenerPhysics...
cocos2d-js 自定义事件监听派发
转载于 http://www.cnblogs.com/kenkofox/p/3926797.html 熟悉js的dom事件或者flash事件的...
cocos常用 实用 公共函数 lua代码
公共资源加载，缓存retain；防止被自动销毁 2. 数字滚动递增；用于得奖后，总金币跳动增加...
cocos creator box2d
title Map 使用box2d var sfloors = this.tiledMap.getObjectGroup(‘Special_Floor‘).g...
（转）让quick-cocos2d-x支持加密的plist文件
前篇：quick-cocos2d-x图片资源加密 在前篇里面，我们实现了图片资源的加密，但还没有实现...
（转）quick-cocos2d-x图片资源加密(续)
摘要: 对在quick-cocos2d-x上实现的资源加密方法的补充 前篇： quick-cocos2d-x图片资源加...
Cocos Creator 动态改变sprite图片
首先将存放图片最外层文件夹命名为resources 　　 changeBj: function(){ 　　　　var url...
iOSAndroidSwiftHybridCocos2d-xFlutterXcodeSilverlightcocoaCordova
调试桥筛选栏假异步不会丢失AndPermissio权限申请抽屉式systemUI信号栏多行排列跨多行显示viewmode数据共享录制语音视频通话多行显示Studio3.5拉伸控件望远镜发动态走势图点赞控件显示牌冷启动v3签名v2签名v1签名本地html外接键盘流式标签