开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
S3DBInterface.cpp
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：36k
源码类别：

模拟服务器

开发平台：

C/C++

S3DBInterface.cpp：源码内容
  1. /*******************************************************************************
  2. // FileName : S3DBInterface.cpp
  3. // FileAuthor : RomanDou
  4. // FileCreateDate : 2002-10-16 15:32:22
  5. // FileDescription :
  6. // Revision Count :
  7. *******************************************************************************/
  8. #include "Kstdafx.h"
  9. #include "S3DBInterface.h"
  10. #include "GlobalDTD.h"
  11. #include "s3ptableinfocatch.h"
  12. #include "s3pdbconnectionpool.h"
  13. #include "s3pdbconnector.h"
  14. #include "s3pManipulator.h"
  15. #include "S3pEquipBaseInfo.h"
  16. #include "S3pEquipEfficInfo.h"
  17. #include "s3pEquipRequireInfo.h"
  18. #include "s3pEquipment.h"
  19. #include "s3pFightSkill.h"
  20. #include "s3pFriend.h"
  21. #include "s3pLifeSkill.h"
  22. #include "s3pRole.h"
  23. #include "s3pTask.h"
  24. #include "s3pTaskList.h"
  25. #include "S3PTableObjList.h"
  26. #include "kengine.h"
  27. #include "ktabfileCtrl.h"
  28. #include "KIniFile.h"
  29. #include "s3pRoleList.h"
  30. #include "stdio.h"
  31. #pragma warning(disable:4786)
  32. #define MAX_FRIENDNAMELEN 100
  34. //DBTableKeyMap  g_RoleTableKeyMap;
  35. //DBTableKeyMap  g_ItemTableKeyMap;
  37. S3PManipulator * GetTableFromString(S3_DB_TABLENAME tablename, std::string strUser);
  38. S3PManipulator * GetTableFromID(S3_DB_TABLENAME tablename, int nId);
  40. #ifdef _DEBUG
  41. extern FILE * g_pOutFile;
  42. #endif
  44. S3DBI_API BOOL S3DBI_InitDBInterface()
  45. {
  46. #ifdef _DEBUG
  47. g_pOutFile = fopen("c:\swsql.txt", "wa");
  48. #endif
  49. int iRet = 0;
  50. TCHAR szINIPath[MAX_PATH+1];
  51. KPIGetExePath( szINIPath, MAX_PATH );
  52. _tcscat( szINIPath, "DataBase.ini" );
  54. S3PTableInfoCatch::Instance();
  55. S3PDBConnectionPool::Init( szINIPath );
  56. S3PDBConnectionPool::Instance();
  57. S3PDBConnector::Instance();
  59. return TRUE;
  60. }
  62. S3DBI_API void S3DBI_ReleaseDBInterface()
  63. {
  64. S3PDBConnectionPool::ReleaseInstance();
  65. S3PDBConnector::ReleaseInstance();
  66. S3PTableInfoCatch::Release();
  67. }
  69. BOOL Cav2TableFile(ColumnAndValue *pCav, KTabFileCtrl * pTabFile)
  70. {
  71. if ((!pCav) || (!pTabFile)) return FALSE;
  72. if (pCav->size() == 0) return FALSE;
  74. // pTabFile->Clear();
  76. int nt = 1;
  77. ColumnAndValue::iterator i;
  78. for(i=pCav->begin(); i!=pCav->end(); i++)
  79. {
  80. std::string key   = i->first;
  81. std::string value = i->second;
  83. pTabFile->WriteString(1, nt, (char *)key.c_str() );
  84. pTabFile->WriteString(2, nt++, (char *)value.c_str());
  85. }
  86. return TRUE;
  87. }
  89. BOOL TabFile2Cav(KTabFileCtrl * pTabFile, ColumnAndValue * pCav)
  90. {
  91. if ((!pCav) || (!pTabFile)) return FALSE;
  93. int nRow = pTabFile->GetHeight();
  95. int nWidth = pTabFile->GetWidth();
  96. for (int i =  0; i < nWidth; i ++)
  97. {
  98. char szValue[200];
  99. pTabFile->GetString(nRow, i + 1 , "", szValue, 200);
  100. (*pCav)[pTabFile->GetColName(i + 1)] = szValue;
  102. }
  103. return TRUE;
  104. }
  106. /*
  107. [ROLE]
  108. Name= DOUHAO
  109. OLD= SJDLJFSDJF
  111.   [ITEMS]
  112.   COUNT=10
  113.   
  114. [ITEM1]
  115. ...
  116. ...
  118.   [ITEMN]
  119.   BLISTS=1
  120.   ELISTS=3
  121.   RLISTS=4
  122.   
  123. [IBN_1]
  124. ..
  125. [IBN_N]
  127.   
  128. [FRIENDS]
  129. COUNT=10
  130. F1=
  131. F2=
  132. F3=
  134.   [TASKS]
  135.   T1=
  136.   TV1=
  137.   T2=
  138.   TV2=
  139.   
  140. [FSKILLS]
  141. COUNT=10
  142. S1=
  143. L1=
  144. S2=
  145. L2
  147. */
  149. void Item_BaseDataConversion(IN TDBItemData * pItemData, ColumnAndValue &ItemValue)
  150. {
  152. pItemData->iid = atoi( ItemValue["iid"].c_str());   
  153. // strcpy(pItemData->cusercode,   ItemValue["cusercode"].c_str());             
  154. pItemData->iequipclasscode = atoi(   ItemValue["iequipclasscode"].c_str());       
  155. pItemData->ilocal = atoi( ItemValue["ilocal"].c_str());                
  156. pItemData->ix = atoi(   ItemValue["ix"].c_str());                    
  157. pItemData->iy = atoi(   ItemValue["iy"].c_str());                    
  158. pItemData->iequipcode = atoi(   ItemValue["iequipcode"].c_str());            
  159. pItemData->idetailtype = atoi(   ItemValue["idetailtype"].c_str());           
  160. pItemData->iparticulartype = atoi(   ItemValue["iparticulartype"].c_str());       
  161. pItemData->ilevel = atoi(   ItemValue["ilevel"].c_str());                
  162. pItemData->iseries = atoi(   ItemValue["iseries"].c_str());               
  163. pItemData->iequipversion = atoi(   ItemValue["iequipversion"].c_str());         
  164. pItemData->irandseed = atoi(   ItemValue["irandseed"].c_str());             
  165. pItemData->iparam2 = atoi(   ItemValue["iparam2"].c_str());               
  166. pItemData->iparam3 = atoi(   ItemValue["iparam3"].c_str());               
  167. pItemData->iparam5 = atoi(   ItemValue["iparam5"].c_str());               
  168. pItemData->iparam4 = atoi(   ItemValue["iparam4"].c_str());               
  169. pItemData->iparam6 = atoi(   ItemValue["iparam6"].c_str());               
  170. pItemData->iparam1 = atoi(   ItemValue["iparam1"].c_str());               
  171. pItemData->ilucky = atoi(   ItemValue["ilucky"].c_str());                
  172. }
  174. void Role_BaseDataConversion(IN TRoleBaseInfo * pRoleData, IN ColumnAndValue &RoleValue)
  175. {
  176. pRoleData->dwId = atoi(RoleValue["iid"].c_str());
  177. strcpy(pRoleData->szName, RoleValue["cusercode"].c_str());
  178. const char * pSex = RoleValue["bsex"].c_str();
  179. if (!strcmp(pSex , "男")) pRoleData->bSex = 0;
  180. else pRoleData->bSex = 1;
  181. //pRoleData->bSex = atoi(RoleValue["bsex"].c_str());
  182. strcpy(pRoleData->szAlias, RoleValue["calias"].c_str());
  183. pRoleData->nFirstSect = atoi(RoleValue["ifirstsect"].c_str());
  184. pRoleData->nSect = atoi(RoleValue["isect"].c_str());
  185. pRoleData->ijoincount = atoi(RoleValue["ijoincount"].c_str());
  186. pRoleData->isectrole = atoi(RoleValue["isectrole"].c_str());
  187. pRoleData->igrouprole = atoi(RoleValue["igroupcode"].c_str());
  188. pRoleData->igrouprole = atoi(RoleValue["igrouprole"].c_str());
  189. pRoleData->irevivalid = atoi(RoleValue["irevivalid"].c_str());
  190. strcpy(pRoleData->cpartnercode , RoleValue["cpartnercode"].c_str());
  191. pRoleData->isavemoney = atoi(RoleValue["isavemoney"].c_str());
  192. pRoleData->imoney = atoi(RoleValue["imoney"].c_str());
  193. pRoleData->ifiveprop = atoi(RoleValue["ifiveprop"].c_str());
  194. pRoleData->iteam = atoi(RoleValue["iteam"].c_str());
  195. pRoleData->ifightlevel = atoi(RoleValue["ifightlevel"].c_str());
  196. pRoleData->fightexp = atoi(RoleValue["ifightexp"].c_str());
  197. pRoleData->ileadlevel = atoi(RoleValue["ileadlevel"].c_str());
  198. pRoleData->ileadexp = atoi(RoleValue["ileadexp"].c_str());
  199. pRoleData->iliveexp = atoi(RoleValue["iliveexp"].c_str());
  200. pRoleData->ipower = atoi(RoleValue["ipower"].c_str());
  201. pRoleData->iagility = atoi(RoleValue["iagility"].c_str());
  202. pRoleData->iouter = atoi(RoleValue["iouter"].c_str());
  203. pRoleData->iinside = atoi(RoleValue["iinside"].c_str());
  204. pRoleData->iluck = atoi(RoleValue["iluck"].c_str());
  205. pRoleData->imaxlife = atoi(RoleValue["imaxlife"].c_str());
  206. pRoleData->imaxstamina = atoi(RoleValue["imaxstamina"].c_str());
  207. pRoleData->imaxinner = atoi(RoleValue["imaxinner"].c_str());
  208. pRoleData->ileftprop = atoi(RoleValue["ileftprop"].c_str());
  209. pRoleData->ileftfight = atoi(RoleValue["ileftfight"].c_str());
  210. pRoleData->ileftlife = atoi(RoleValue["ileftlife"].c_str());
  211. strcpy(pRoleData->caccname ,RoleValue["caccname"].c_str());
  212. pRoleData->ifinishgame = atoi(RoleValue["ifinishgame"].c_str());
  213. pRoleData->irevivalx = atoi(RoleValue["irevivalx"].c_str());
  214. pRoleData->irevivaly = atoi(RoleValue["irevivaly"].c_str());
  215. pRoleData->iarmorres = atoi(RoleValue["iarmorres"].c_str());
  216. pRoleData->iweaponres = atoi(RoleValue["iweaponres"].c_str());
  217. pRoleData->ihelmres = atoi(RoleValue["ihelmres"].c_str());
  218. }
  220. S3DBI_API void * S3DBI_GetRoleInfo(IN OUT BYTE * pRoleBuffer, IN char * strUser, IN OUT int &nBufLen)
  221. {
  223. int  nFriendBufferLen;
  224. TRoleData* pRoleData = (TRoleData*) pRoleBuffer;
  226. //*************************************************
  227. // 加载玩家的基本信息//
  228. S3PRole Role(strUser);
  229. if (Role.GetLastResult()<0) return NULL;
  230. ColumnAndValue &RoleInfo  = Role.GetProperties();
  231. pRoleData->bBaseNeedUpdate = 1;
  232. Role_BaseDataConversion((TRoleBaseInfo*)pRoleBuffer,RoleInfo);
  234. //*************************************************
  237. pRoleData->dwFSkillOffset = (BYTE*)&pRoleData->pBuffer - (BYTE*)pRoleData;
  238. //*************************************************
  239. // 加载玩家的战斗技能列表
  240. S3PTableObjList<S3PFightSkill> * pFightSkillList = Role.GetFightSkillList();
  242. int nFightSkillCount =  pFightSkillList->Size();
  243. pRoleData->nFightSkillCount = nFightSkillCount;
  244. int nFightSkillBufferLen = nFightSkillCount * sizeof(TDBSkillData);
  245. BYTE * pFightSkillBuffer = (BYTE*)pRoleData + pRoleData->dwFSkillOffset;
  246. TDBSkillData * pFSkillData = (TDBSkillData * )pFightSkillBuffer;
  247. for (int t = 0; t < nFightSkillCount; t++, pFSkillData ++)
  248. {
  249. ColumnAndValue &FightSkillValue = ((*pFightSkillList)[t])->GetProperties();
  250. pFSkillData->m_nSkillId = atoi(FightSkillValue["ifightskill"].c_str());
  251. pFSkillData->m_nSkillLevel = atoi(FightSkillValue["ifightskilllevel"].c_str());
  252. }
  253. //*************************************************
  256. pRoleData->dwLSkillOffset = pRoleData->dwFSkillOffset + nFightSkillBufferLen;
  257. //*************************************************
  258. // 加载玩家的生活技能列表
  259. S3PTableObjList<S3PLifeSkill> * pLifeSkillList = Role.GetLifeSkillList();
  260. int nLifeSkillCount =  pLifeSkillList->Size();
  261. pRoleData->nLiveSkillCount = nLifeSkillCount;
  262. int nLifeSkillBufferLen = nLifeSkillCount * sizeof(TDBSkillData);
  263. BYTE * pLifeSkillBuffer = (BYTE*)pRoleData + pRoleData->dwLSkillOffset;
  264. TDBSkillData * pLSkillData = (TDBSkillData * )pLifeSkillBuffer;
  265. for (t = 0; t < nLifeSkillCount; t++, pLSkillData ++)
  266. {
  267. ColumnAndValue &LifeSkillValue = ((*pLifeSkillList)[t])->GetProperties();
  268. pLSkillData->m_nSkillId = atoi(LifeSkillValue["ilifeskill"].c_str());
  269. pLSkillData->m_nSkillLevel = atoi(LifeSkillValue["ilifeskilllevel"].c_str());
  270. }
  271. //*************************************************
  274. pRoleData->dwTaskOffset = pRoleData->dwLSkillOffset + nLifeSkillBufferLen;
  275. //*************************************************
  276. // 加载玩家的任务列表
  277. S3PTableObjList<S3PTask> * pTaskList = Role.GetTaskList();
  278. int nTaskCount = pTaskList->Size();
  279. pRoleData->nTaskCount = nTaskCount;
  280. int nTaskBufferLen = nTaskCount * sizeof(TDBTaskData);
  281. TDBTaskData * pTaskData = (TDBTaskData*)((BYTE *)pRoleData + pRoleData->dwTaskOffset);
  282. for (t= 0; t < nTaskCount; t++, pTaskData ++)
  283. {
  284. ColumnAndValue &TaskValue = (*pTaskList)[t]->GetProperties();
  285. pTaskData->m_nTaskId = atoi(TaskValue["itaskcode"].c_str());
  286. pTaskData->m_nTaskValue = atoi(TaskValue["idegree"].c_str());
  287. }
  288. //*************************************************
  291. pRoleData->dwItemOffset = pRoleData->dwTaskOffset + nTaskBufferLen;
  292. //*************************************************
  293. // 加载玩家的物品列表
  294. S3PTableObjList<S3PEquipment> *EquipList =  Role.GetEquipmentList();
  296. int nEquiptListCount = EquipList->Size();
  297. pRoleData->nItemCount = nEquiptListCount;
  298. TDBItemData * pItemData = (TDBItemData*)((BYTE*)pRoleData + pRoleData->dwItemOffset);
  299. KMagicAttrib * pMagicAttrib = NULL;
  300. //
  301. for (int j = 0 ; j < nEquiptListCount; j ++)
  302. {
  304. //基本信息加载
  305. ColumnAndValue &BaseInfoValue = (*EquipList)[j]->GetProperties();
  306. Item_BaseDataConversion(pItemData, BaseInfoValue);
  308. #ifdef SAVE_ITEM_MAGICATTRIB_TO_DB
  309. //基本属性加载
  310. S3PTableObjList<S3PEquipBaseInfo> *EquipBaseInfoList = (*EquipList)[j]->GetEquipBaseInfoList();
  311. int nEquipBaseInfoListCount = EquipBaseInfoList->Size();
  312. pItemData->BaseInfoCount = nEquipBaseInfoListCount;
  313. pMagicAttrib = (KMagicAttrib*) &pItemData->pBuffer;
  314. for (int k = 0; k < nEquipBaseInfoListCount; k ++, pMagicAttrib ++)
  315. {
  316. ColumnAndValue &BaseValue = (*EquipBaseInfoList)[k]->GetProperties();
  317. pMagicAttrib->nAttribType = atoi(BaseValue["iclass"].c_str());
  318. pMagicAttrib->nValue[0] = atoi(BaseValue["ivalue1"].c_str());
  319. pMagicAttrib->nValue[1] = atoi(BaseValue["ivalue2"].c_str());
  320. pMagicAttrib->nValue[2] = atoi(BaseValue["ivalue3"].c_str());
  321. }
  323. // 效果数据加载
  324. S3PTableObjList<S3PEquipEfficInfo> *EquipEfficInfoList = (*EquipList)[j]->GetEquipEfficInfoList();
  325. int nEquipEfficInfoListCount = EquipEfficInfoList->Size();
  326. pItemData->EfficCount = nEquipEfficInfoListCount;
  329. for ( k = 0; k < nEquipEfficInfoListCount; k ++, pMagicAttrib ++)
  330. {
  331. ColumnAndValue &EfficValue = (*EquipEfficInfoList)[k]->GetProperties();
  332. pMagicAttrib->nAttribType = atoi(EfficValue["iclass"].c_str());
  333. pMagicAttrib->nValue[0] = atoi(EfficValue["ivalue1"].c_str());
  334. pMagicAttrib->nValue[1] = atoi(EfficValue["ivalue2"].c_str());
  335. pMagicAttrib->nValue[2] = atoi(EfficValue["ivalue3"].c_str());
  336. }
  337. //需求属性加载
  338. S3PTableObjList<S3PEquipRequireInfo> *EquipRequireInfoList = (*EquipList)[j]->GetEquipRequireInfoList();
  339. int nEquipRequireInfoListCount = EquipRequireInfoList->Size();
  340. pItemData->RequireInfoCount = nEquipRequireInfoListCount;
  342. for (k = 0; k < nEquipRequireInfoListCount; k ++, pMagicAttrib ++)
  343. {
  344. ColumnAndValue &RequireValue = (*EquipRequireInfoList)[k]->GetProperties();
  345. pMagicAttrib->nAttribType = atoi(RequireValue["iclass"].c_str());
  346. pMagicAttrib->nValue[0] = atoi(RequireValue["ivalue1"].c_str());
  347. pMagicAttrib->nValue[1] = atoi(RequireValue["ivalue2"].c_str());
  348. pMagicAttrib->nValue[2] = atoi(RequireValue["ivalue3"].c_str());
  349. }
  350. pItemData = (TDBItemData *)pMagicAttrib;
  351. #else
  352. pItemData ++;
  353. #endif
  354. }
  355. //*************************************************
  358. //*************************************************
  359. // 加载玩家的好友列表//
  360. // 玩家的姓名列表放在唯一的一块Buffer上，通过0标计间隔开
  361. if (pItemData)
  362. pRoleData->dwFriendOffset = (BYTE*)pItemData - (BYTE*)pRoleData;
  363. else
  364. pRoleData->dwFriendOffset = pRoleData->dwItemOffset;
  365. S3PTableObjList<S3PFriend> * pFriendList = Role.GetFriendList();
  366. int nFriendCount =  pFriendList->Size();
  367. pRoleData->nFriendCount = nFriendCount;
  369. void * pFriendBuffer = (BYTE *)pRoleData + pRoleData->dwFriendOffset;
  370. BYTE * pCurFriend = (BYTE*)pFriendBuffer;
  372. for (t = 0; t < nFriendCount; t++)
  373. {
  374. ColumnAndValue &FriendValue = ((*pFriendList)[t])->GetProperties();
  375. const char * pFriendName = FriendValue["cfriendcode"].c_str();
  376. int nCurNameLen = strlen(pFriendName);
  377. memcpy(pCurFriend, pFriendName, nCurNameLen);
  378. pCurFriend = (BYTE *)((char *)pCurFriend + nCurNameLen);
  379. *(pCurFriend++) = 0;
  380. }
  381. nFriendBufferLen = pCurFriend - (BYTE*)pFriendBuffer;
  382. //*************************************************
  384. nBufLen = pRoleData->dwFriendOffset + nFriendBufferLen;
  385. return pRoleBuffer;
  386. }
  388. void Item_SaveBaseInfo(ColumnAndValue &ItemValue, TDBItemData * pItemData)
  389. {
  390. char szValue[100];
  391. //ItemValue["iid"]    = itoa(pItemData->iid, szValue, 10);
  392.    //ItemValue["cusercode"]              = pItemData->cusercode;
  393.    ItemValue["iequipclasscode"]        = itoa(pItemData->iequipclasscode, szValue, 10);
  394.    ItemValue["ilocal"]                 = itoa(pItemData->ilocal, szValue, 10);
  395.    ItemValue["ix"]                     = itoa(pItemData->ix, szValue, 10);
  396.    ItemValue["iy"]                     = itoa(pItemData->iy, szValue, 10);
  397.    ItemValue["iequipcode"]             = itoa(pItemData->iequipcode, szValue, 10);
  398.    ItemValue["idetailtype"]            = itoa(pItemData->idetailtype, szValue, 10);
  399.    ItemValue["iparticulartype"]        = itoa(pItemData->iparticulartype, szValue, 10);
  400.    ItemValue["ilevel"]                 = itoa(pItemData->ilevel, szValue, 10);
  401.    ItemValue["iseries"]                = itoa(pItemData->iseries, szValue, 10);
  402.    ItemValue["iequipversion"]          = itoa(pItemData->iequipversion, szValue, 10);
  403.    ItemValue["irandseed"]              = itoa(pItemData->irandseed, szValue, 10);
  404.    ItemValue["iparam2"]                = itoa(pItemData->iparam2, szValue, 10);
  405.    ItemValue["iparam3"]                = itoa(pItemData->iparam3, szValue, 10);
  406.    ItemValue["iparam5"]                = itoa(pItemData->iparam5, szValue, 10);
  407.    ItemValue["iparam4"]                = itoa(pItemData->iparam4, szValue, 10);
  408.    ItemValue["iparam6"]                = itoa(pItemData->iparam6, szValue, 10);
  409.    ItemValue["iparam1"]                = itoa(pItemData->iparam1, szValue, 10);
  410.    ItemValue["ilucky"]                 = itoa(pItemData->ilucky, szValue, 10);
  411. }
  415. void Role_SaveBaseInfo(ColumnAndValue &RoleValue, TRoleData * pRoleData )
  416. {
  417. char szValue[100];
  419. RoleValue["cusercode"] = pRoleData->BaseInfo.szName;
  421. if (pRoleData->BaseInfo.bSex) RoleValue["bsex"] = "女";
  422. else
  423. RoleValue["bsex"] = "男";
  424. RoleValue["calias"] = pRoleData->BaseInfo.szAlias;
  425. RoleValue["ifirstsect"] = itoa(pRoleData->BaseInfo.nFirstSect , szValue, 10);
  426. RoleValue["isect"] = itoa(pRoleData->BaseInfo.nSect , szValue, 10);
  427. RoleValue["ijoincount"] = itoa(pRoleData->BaseInfo.ijoincount , szValue, 10);
  428. RoleValue["isectrole"] = itoa(pRoleData->BaseInfo.isectrole , szValue, 10);
  429. RoleValue["igroupcode"] = itoa(pRoleData->BaseInfo.igrouprole , szValue, 10);
  430. RoleValue["igrouprole"] = itoa(pRoleData->BaseInfo.igrouprole , szValue, 10);
  431. RoleValue["irevivalid"] = itoa(pRoleData->BaseInfo.irevivalid , szValue, 10);
  432. RoleValue["cpartnercode"] = pRoleData->BaseInfo.cpartnercode;
  433. RoleValue["isavemoney"] = itoa(pRoleData->BaseInfo.isavemoney , szValue, 10);
  434. RoleValue["imoney"] = itoa(pRoleData->BaseInfo.imoney , szValue, 10);
  435. RoleValue["ifiveprop"] = itoa(pRoleData->BaseInfo.ifiveprop , szValue, 10);
  436. RoleValue["iteam"] = itoa(pRoleData->BaseInfo.iteam , szValue, 10);
  437. RoleValue["ifightlevel"] = itoa(pRoleData->BaseInfo.ifightlevel , szValue, 10);
  438. RoleValue["ifightexp"] = itoa(pRoleData->BaseInfo.fightexp , szValue, 10);
  439. RoleValue["ileadlevel"] = itoa(pRoleData->BaseInfo.ileadlevel , szValue, 10);
  440. RoleValue["ileadexp"] = itoa(pRoleData->BaseInfo.ileadexp , szValue, 10);
  441. RoleValue["iliveexp"] = itoa(pRoleData->BaseInfo.iliveexp , szValue, 10);
  442. RoleValue["ipower"] = itoa(pRoleData->BaseInfo.ipower , szValue, 10);
  443. RoleValue["iagility"] = itoa(pRoleData->BaseInfo.iagility , szValue, 10);
  444. RoleValue["iouter"] = itoa(pRoleData->BaseInfo.iouter , szValue, 10);
  445. RoleValue["iinside"] = itoa(pRoleData->BaseInfo.iinside , szValue, 10);
  446. RoleValue["iluck"] = itoa(pRoleData->BaseInfo.iluck , szValue, 10);
  447. RoleValue["imaxlife"] = itoa(pRoleData->BaseInfo.imaxlife , szValue, 10);
  448. RoleValue["imaxstamina"] = itoa(pRoleData->BaseInfo.imaxstamina , szValue, 10);
  449. RoleValue["imaxinner"] = itoa(pRoleData->BaseInfo.imaxinner , szValue, 10);
  450. RoleValue["ileftprop"] = itoa(pRoleData->BaseInfo.ileftprop , szValue, 10);
  451. RoleValue["ileftfight"] = itoa(pRoleData->BaseInfo.ileftfight , szValue, 10);
  452. RoleValue["ileftlife"] = itoa(pRoleData->BaseInfo.ileftlife , szValue, 10);
  453. RoleValue["caccname"] = pRoleData->BaseInfo.caccname;
  454. RoleValue["ifinishgame"] = itoa(pRoleData->BaseInfo.ifinishgame , szValue, 10);
  455. RoleValue["irevivalx"] = itoa(pRoleData->BaseInfo.irevivalx , szValue, 10);
  456. RoleValue["irevivaly"] = itoa(pRoleData->BaseInfo.irevivaly , szValue, 10);
  457. RoleValue["iarmorres"] = itoa(pRoleData->BaseInfo.iarmorres , szValue, 10);
  458. RoleValue["iweaponres"] = itoa(pRoleData->BaseInfo.iweaponres , szValue, 10);
  459. RoleValue["ihelmres"] = itoa(pRoleData->BaseInfo.ihelmres , szValue, 10);
  461. }
  463. #ifdef SHOWDEBUGINFO
  464. {
  466. }
  467. #endif
  469. S3DBI_API void S3DBI_ShowDebugInfo(IN BYTE * pRoleBuffer, char * pShowString)
  470. {
  471. if (!pShowString) return;
  472. //检查入口有效性
  474. if (!pRoleBuffer) return ;
  476. //获得数据库中玩家基本信息表
  478. TRoleData *pRoleData = (TRoleData*)pRoleBuffer;
  481. ColumnAndValue RoleValue ;//= Role.GetProperties();
  482. Role_SaveBaseInfo(RoleValue, pRoleData);
  483. ColumnAndValue::iterator II;
  484. sprintf(pShowString, "---------------RoleBaseINfo-------------n");
  485. for (II = RoleValue.begin(); II != RoleValue.end(); II ++)
  486. {
  487. sprintf(pShowString , "%s %s = %sn",  pShowString, II->first.c_str(), II->second.c_str());
  488. }
  490. //*************************************************
  491. //更新玩家的战斗技能列表
  492. sprintf(pShowString, "%s---------------FightSkill-------------n", pShowString);
  493. if (pRoleData->dwFSkillOffset > 0)
  494. {
  495. int nFightCount = pRoleData->nFightSkillCount;
  497. TDBSkillData * pSkillData = (TDBSkillData *)((BYTE *)pRoleData + pRoleData->dwFSkillOffset);
  498. for (int nT = 0; nT < nFightCount; nT ++, pSkillData ++)
  499. {
  501. sprintf(pShowString, "%sFight SkillId = %d, SkillLevel = %dn",pShowString, pSkillData->m_nSkillId, pSkillData->m_nSkillLevel);
  502. }
  503. }
  505. //*************************************************
  508. //*************************************************
  509. // 更新玩家的生活技能列表
  510. sprintf(pShowString, "%s---------------LifeSkill-------------n",pShowString);
  511. if (pRoleData->dwLSkillOffset > 0)
  512. {
  513. TDBSkillData * pSkillData = (TDBSkillData *)((BYTE *) pRoleData + pRoleData->dwLSkillOffset);
  514. int nLifeCount = pRoleData->nLiveSkillCount;
  516. for (int nT = 0; nT < nLifeCount; nT ++, pSkillData ++)
  517. {
  519. sprintf(pShowString,"%sLive SkillId = %d, SkillLevel = %dn",pShowString, pSkillData->m_nSkillId, pSkillData->m_nSkillLevel);
  520. }
  521. }
  525. //*************************************************
  528. //*************************************************
  529. // 更新玩家的任务列表
  530. sprintf(pShowString, "%s---------------Task-------------n", pShowString);
  531. if (pRoleData->dwTaskOffset > 0)
  532. {
  533. int nTaskCount = pRoleData->nTaskCount;
  534. TDBTaskData * pTaskData = (TDBTaskData *)((BYTE*)pRoleData + pRoleData->dwTaskOffset);
  536. for (int nT = 0; nT < nTaskCount; nT ++, pTaskData ++)
  537. {
  538. sprintf(pShowString, "%sTask%d Value%dn", pShowString, pTaskData->m_nTaskId, pTaskData->m_nTaskValue);
  539. }
  540. }
  543. //*************************************************
  547. //*************************************************
  548. // 更新玩家的物品列表
  549. //存在物品列表则更新物品列表
  550. sprintf(pShowString, "%s---------------ItemList-------------n", pShowString);
  551. if (pRoleData->dwItemOffset > 0)
  552. {
  553. int nEquipListCount = pRoleData->nItemCount;
  554. TDBItemData * pItemData = (TDBItemData *)((BYTE * ) pRoleData + pRoleData->dwItemOffset);
  557. {
  559. //依次保存每一个物件
  560. sprintf(pShowString, "%s---------------ItemBase-------------n", pShowString);
  561. for (int j = 0; j < nEquipListCount; j ++)
  562. {
  563. sprintf(pShowString, "%sn", pShowString);
  564. int nEquipBaseInfoListCount  = 0;//某个物件的基本属性列表数目
  565. ColumnAndValue InfoValue;
  567. Item_SaveBaseInfo(InfoValue, pItemData);
  568. ColumnAndValue::iterator II;
  569. for (II = InfoValue.begin(); II != InfoValue.end(); II ++)
  570. {
  571. sprintf(pShowString, "%s%s = %sn", pShowString, II->first.c_str(), II->second.c_str());
  572. }
  574. #ifdef SAVE_ITEM_MAGICATTRIB_TO_DB
  575. //基本属性更新
  577. nEquipBaseInfoListCount = pItemData->BaseInfoCount;
  579. KMagicAttrib * pMagicAttrib = (KMagicAttrib *)&pItemData->pBuffer;
  581. //保存物件基本属性
  582. for (int  t = 0; t < nEquipBaseInfoListCount; t++, pMagicAttrib ++)
  583. {
  584. //物件列表中第j+1物件的基本信息的t+1项
  585. sprintf(pShowString, "%sBaseInfo[%d] %d, %d, %d, %dn",pShowString, t, pMagicAttrib->nAttribType, pMagicAttrib->nValue[0], pMagicAttrib->nValue[1], pMagicAttrib->nValue[2] );
  586. }
  589. //更新效果属性
  590. int nEquipEfficInfoListCount = pItemData->EfficCount;
  592. //保存物件
  593. for ( t = 0; t < nEquipEfficInfoListCount; t++, pMagicAttrib ++)
  594. {
  595. //物件列表中第j+1物件的基本信息的t+1项
  596. sprintf(pShowString, "%sEfficInfo[%d] %d, %d, %d, %dn", pShowString, t, pMagicAttrib->nAttribType, pMagicAttrib->nValue[0], pMagicAttrib->nValue[1], pMagicAttrib->nValue[2] );
  597. }
  599. //更新需求属性
  600. int nEquipRequireInfoListCount = pItemData->RequireInfoCount;
  602. //保存物件
  603. for ( t = 0; t < nEquipRequireInfoListCount; t++, pMagicAttrib ++)
  604. {
  605. //物件列表中第j+1物件的基本信息的t+1项
  606. sprintf(pShowString, "%sRequireInfo[%d] %d, %d, %d, %dn",pShowString, t, pMagicAttrib->nAttribType, pMagicAttrib->nValue[0], pMagicAttrib->nValue[1], pMagicAttrib->nValue[2] );
  608. }
  609. pItemData = (TDBItemData*)pMagicAttrib;
  610. #else
  611. pItemData ++;
  612. #endif
  613. }
  616. }
  617. }
  618. //*************************************************
  622. //************************************************
  623. // 更新玩家的好友列表//
  624. sprintf(pShowString, "%s---------------Friend-------------n", pShowString);
  625. if (pRoleData->dwFriendOffset > 0)
  626. {
  627. int nFriendCount = pRoleData->nFriendCount;
  628. char * pFriendBuffer = (char *)((BYTE *)pRoleData + pRoleData->dwFriendOffset);
  630. for (int nT = 0; nT < nFriendCount; nT ++)
  631. {
  633. sprintf(pShowString, "%sFriend%d is %sn", pShowString, nT, pFriendBuffer);
  634. pFriendBuffer += strlen(pFriendBuffer) + 1;
  635. }
  636. }
  638. //*************************************************
  640. }
  642. // result -1 othererror
  643. // -4 have or no user exist
  644. // 
  646. S3DBI_API int S3DBI_SaveRoleInfo(IN BYTE * pRoleBuffer, IN char * strUser, BOOL bAutoInsertWhenNoExistUser)
  647. {
  648. //检查入口有效性
  649. char strRoleName[50];
  650. if (!pRoleBuffer) return -1;
  652. if ((!strUser )|| (!strUser[0])) 
  653. {
  654. TRoleData * ptmpRoleData = (TRoleData*) pRoleBuffer;
  655. strcpy(strRoleName, ptmpRoleData->BaseInfo.szName);
  656. }
  657. else
  658. strcpy(strRoleName, strUser);
  660. int bSaveRole = FALSE;//保存角色基本信息是否成功
  661. int nLastResult = 0;
  662. BOOL bNewUser = FALSE;//是否是新创建该玩家
  665. //获得数据库中玩家基本信息表
  666. S3PRole Role(strRoleName);
  668. if ((nLastResult = Role.GetLastResult()) < 0 )
  669. {
  670. //-4表示不存在该用户，需增加
  671. if (nLastResult == -4)
  672. {
  673. if (bAutoInsertWhenNoExistUser)//当已设定成角色在数据库中不存在自动增加时，增加。否则返回
  674. bNewUser = TRUE;
  675. else 
  676. return -1;
  677. }
  678. else
  679. return -1;//其它错误返回
  680. }
  683. TRoleData *pRoleData = (TRoleData*)pRoleBuffer;
  685. if (pRoleData->bBaseNeedUpdate)
  686. {
  687. if (!bNewUser) //非新用户，直接更新!
  688. {
  689. char szCurKey[100] = "";
  690. char szPrevKey[100] = "";
  692. ColumnAndValue &RoleValue = Role.GetProperties();
  693. RoleValue.clear();
  694. Role_SaveBaseInfo(RoleValue, pRoleData);
  695. bSaveRole = Role.Save();
  696. if (bSaveRole < 0 ) return -1;
  697. }
  698. else //新用户，增加数据！
  699. {
  700. char szCurKey[100] = "";
  701. char szPrevKey[100] = "";
  703. //S3PRole NewRole;
  704. ColumnAndValue RoleValue ;//= Role.GetProperties();
  705. Role_SaveBaseInfo(RoleValue, pRoleData);
  706. bSaveRole = Role.Add(RoleValue);
  707. if (bSaveRole < 0 ) return -1;
  708. //Role = NewRole;
  709. }
  710. }
  711. else
  712. {
  713. if (bNewUser) return -1;//新用户必须含有基本信息!
  714. }
  717. //*************************************************
  718. //更新玩家的战斗技能列表
  719. if (pRoleData->dwFSkillOffset > 0)
  720. {
  721. int nFightCount = pRoleData->nFightSkillCount;
  723. Role.GetFightSkillList()->DeleteAll();
  724. TDBSkillData * pSkillData = (TDBSkillData *)((BYTE *)pRoleData + pRoleData->dwFSkillOffset);
  725. for (int nT = 0; nT < nFightCount; nT ++, pSkillData ++)
  726. {
  727. char szValue[100];
  728. ColumnAndValue FightSkillValue;
  729. FightSkillValue["ifightskill"] = itoa(pSkillData->m_nSkillId, szValue, 10);
  730. FightSkillValue["ifightskilllevel"] = itoa(pSkillData->m_nSkillLevel, szValue, 10);
  731. Role.GetFightSkillList()->Add(FightSkillValue);
  732. }
  733. }
  735. //*************************************************
  738. //*************************************************
  739. // 更新玩家的生活技能列表
  740. if (pRoleData->dwLSkillOffset > 0)
  741. {
  742. TDBSkillData * pSkillData = (TDBSkillData *)((BYTE *) pRoleData + pRoleData->dwLSkillOffset);
  743. int nLifeCount = pRoleData->nLiveSkillCount;
  744. Role.GetLifeSkillList()->DeleteAll();
  746. for (int nT = 0; nT < nLifeCount; nT ++, pSkillData ++)
  747. {
  748. char szValue[100];
  749. ColumnAndValue LifeSkillValue;
  750. LifeSkillValue["ilifeskill"] = itoa(pSkillData->m_nSkillId, szValue, 10);
  751. LifeSkillValue["ilifeskilllevel"] = itoa(pSkillData->m_nSkillLevel, szValue, 10);
  752. Role.GetLifeSkillList()->Add(LifeSkillValue);
  753. }
  754. }
  758. //*************************************************
  761. //*************************************************
  762. // 更新玩家的任务列表
  763. if (pRoleData->dwTaskOffset > 0)
  764. {
  765. int nTaskCount = pRoleData->nTaskCount;
  766. Role.GetTaskList()->DeleteAll();
  767. TDBTaskData * pTaskData = (TDBTaskData *)((BYTE*)pRoleData + pRoleData->dwTaskOffset);
  769. for (int nT = 0; nT < nTaskCount; nT ++, pTaskData ++)
  770. {
  771. char szValue[200] ;
  772. ColumnAndValue TaskValue;
  773. TaskValue["itaskcode"] = itoa(pTaskData->m_nTaskId, szValue, 10);
  774. TaskValue["idegree"] = itoa(pTaskData->m_nTaskValue, szValue, 10);
  775. Role.GetTaskList()->Add(TaskValue);
  776. }
  777. }
  780. //*************************************************
  784. //*************************************************
  785. // 更新玩家的物品列表
  786. //存在物品列表则更新物品列表
  787. if (pRoleData->dwItemOffset > 0)
  788. {
  789. int nEquipListCount = pRoleData->nItemCount;
  790. S3PTableObjList<S3PEquipment> * pEquipList = Role.GetEquipmentList();
  791. TDBItemData * pItemData = (TDBItemData *)((BYTE * ) pRoleData + pRoleData->dwItemOffset);
  793. if (pEquipList)
  794. {
  795. pEquipList->DeleteAll();//清除所有物件
  797. //依次保存每一个物件
  798. for (int j = 0; j < nEquipListCount; j ++)
  799. {
  800. int nEquipBaseInfoListCount  = 0;//某个物件的基本属性列表数目
  801. //基本信息更新
  803. ColumnAndValue InfoValue;
  805. Item_SaveBaseInfo(InfoValue, pItemData);
  806. if (pEquipList->Add(InfoValue) < 0 ) continue; //如果保存失败，则该物件的其它数据不用再更新了
  807. std::string  szIid = (*pEquipList)[pEquipList->Size() - 1]->GetProperties()["iid"];
  809. #ifdef SAVE_ITEM_MAGICATTRIB_TO_DB
  811. //基本属性更新
  813. nEquipBaseInfoListCount = pItemData->BaseInfoCount;
  815. char szValue[200];
  816. KMagicAttrib * pMagicAttrib = (KMagicAttrib *)&pItemData->pBuffer;
  818. //保存物件基本属性
  819. for (int  t = 0; t < nEquipBaseInfoListCount; t++, pMagicAttrib ++)
  820. {
  821. //物件列表中第j+1物件的基本信息的t+1项
  823. ColumnAndValue BaseValue;
  824. BaseValue["iclass"] = itoa(pMagicAttrib->nAttribType, szValue, 10);
  825. BaseValue["ivalue1"] = itoa(pMagicAttrib->nValue[0], szValue, 10);
  826. BaseValue["ivalue2"] = itoa(pMagicAttrib->nValue[1], szValue, 10);
  827. BaseValue["ivalue3"] = itoa(pMagicAttrib->nValue[2], szValue, 10);
  828. BaseValue["imainid"] = szIid;//不一定要写
  829. (*pEquipList)[pEquipList->Size() - 1]->GetEquipBaseInfoList()->Add(BaseValue);
  831. }
  834. //更新效果属性
  835. int nEquipEfficInfoListCount = pItemData->EfficCount;
  837. //保存物件
  838. for ( t = 0; t < nEquipEfficInfoListCount; t++, pMagicAttrib ++)
  839. {
  840. //物件列表中第j+1物件的基本信息的t+1项
  842. ColumnAndValue EfficValue;
  843. EfficValue["iclass"] = itoa(pMagicAttrib->nAttribType, szValue, 10);
  844. EfficValue["ivalue1"] = itoa(pMagicAttrib->nValue[0], szValue, 10);
  845. EfficValue["ivalue2"] = itoa(pMagicAttrib->nValue[1], szValue, 10);
  846. EfficValue["ivalue3"] = itoa(pMagicAttrib->nValue[2], szValue, 10);
  847. EfficValue["imainid"] = szIid;//不一定要写
  848. (*pEquipList)[pEquipList->Size() - 1]->GetEquipEfficInfoList()->Add(EfficValue);
  849. }
  851. //更新需求属性
  852. int nEquipRequireInfoListCount = pItemData->RequireInfoCount;
  854. //保存物件
  855. for ( t = 0; t < nEquipRequireInfoListCount; t++, pMagicAttrib ++)
  856. {
  857. //物件列表中第j+1物件的基本信息的t+1项
  858. ColumnAndValue RequireValue;
  859. RequireValue["iclass"] = itoa(pMagicAttrib->nAttribType, szValue, 10);
  860. RequireValue["ivalue1"] = itoa(pMagicAttrib->nValue[0], szValue, 10);
  861. RequireValue["ivalue2"] = itoa(pMagicAttrib->nValue[1], szValue, 10);
  862. RequireValue["ivalue3"] = itoa(pMagicAttrib->nValue[2], szValue, 10);
  863. RequireValue["imainid"] = szIid;//不一定要写
  864. (*pEquipList)[pEquipList->Size() - 1]->GetEquipRequireInfoList()->Add(RequireValue);
  866. }
  867. pItemData = (TDBItemData *) pMagicAttrib;
  868. #else
  869. pItemData ++;
  870. #endif
  871. }
  873. }
  874. }
  875. //*************************************************
  879. //************************************************
  880. // 更新玩家的好友列表//
  881. if (pRoleData->dwFriendOffset > 0)
  882. {
  883. int nFriendCount = pRoleData->nFriendCount;
  884. Role.GetFriendList()->DeleteAll();
  885. char * pFriendBuffer = (char *)((BYTE *)pRoleData + pRoleData->dwFriendOffset);
  887. for (int nT = 0; nT < nFriendCount; nT ++)
  888. {
  890. ColumnAndValue FriendValue;
  891. FriendValue["cfriendcode"] = pFriendBuffer;
  892. FriendValue["cusercode"] = strRoleName;
  893. pFriendBuffer += strlen(pFriendBuffer) + 1;
  894. Role.GetFriendList()->Add(FriendValue);
  895. }
  896. }
  898. //*************************************************
  900. return 1;
  901. }
  904. S3DBI_API int S3DBI_DeleteRole(char * strUser)
  905. {
  906. if (!strUser || !strUser[0])  return -1;
  907. S3PRole Role(strUser);
  908. int nLastResult = 0;
  910. //查询不到就返回!
  911. if ((nLastResult = Role.GetLastResult()) < 0 ) return -1;
  913. //************************************************
  914. // 删除玩家的好友列表//
  915. nLastResult = Role.GetFriendList()->DeleteAll();
  916. if (nLastResult < 0) g_DebugLog("Delete[%s]Player FriendList Error!,Result = %d", strUser, nLastResult);
  917. //*************************************************
  920. //*************************************************
  921. // 玩家的战斗技能列表
  922. nLastResult = Role.GetFightSkillList()->DeleteAll();
  923. if (nLastResult < 0) g_DebugLog("Delete[%s]Player FightSkillList Error!,Result = %d", strUser, nLastResult);
  924. //*************************************************
  927. //*************************************************
  928. // 玩家的生活技能列表
  929. nLastResult = Role.GetLifeSkillList()->DeleteAll();
  930. if (nLastResult < 0) g_DebugLog("Delete[%s]Player LifeSkillList Error!,Result = %d", strUser, nLastResult);
  932. //*************************************************
  935. //*************************************************
  936. // 玩家的物品列表
  937. nLastResult = Role.GetEquipmentList()->DeleteAll();
  938. if (nLastResult < 0) g_DebugLog("Delete[%s]Player Item List Error!,Result = %d", strUser, nLastResult);
  940. //*************************************************
  942. //*************************************************
  943. // 玩家的任务列表
  944. nLastResult = Role.GetTaskList()->DeleteAll();
  945. if (nLastResult < 0) g_DebugLog("Delete[%s]Player TaskList Error!,Result = %d", strUser, nLastResult);
  946. //*************************************************
  948. //数据库中玩家基本信息表
  949. nLastResult = Role.Delete();
  950. if (nLastResult < 0) g_DebugLog("Delete[%s]Player InfoData Error!,Result = %d", strUser, nLastResult);
  951. return nLastResult;
  952. }
  954. S3DBI_API int S3DBI_GetRoleListOfAccount(char * szAccountName, S3DBI_RoleBaseInfo * RoleBaseList, int nMaxCount)
  955. {
  956. if (!szAccountName || (!szAccountName[0])) return 0;
  957. S3PRoleList RoleList(szAccountName);
  958. int nCount = RoleList.Size();
  959. if (nCount <= 0) return 0;
  960. if (nCount > nMaxCount) nCount = nMaxCount;
  962. for (int i  = 0; i < nCount; i ++)
  963. {
  964. ColumnAndValue &RoleValue = (*RoleList[i]).GetProperties();
  965. strcpy((RoleBaseList + i)->szName,RoleValue["cusercode"].c_str()); 
  966. (RoleBaseList + i)->Level = atoi(RoleValue["ifightlevel"].c_str());
  967. (RoleBaseList + i)->ArmorType = atoi(RoleValue["iarmorres"].c_str());
  968. (RoleBaseList + i)->WeaponType = atoi(RoleValue["iweaponres"].c_str());
  969. (RoleBaseList + i)->HelmType = atoi(RoleValue["ihelmres"].c_str());
  971. if (!strcmp(RoleValue["bsex"].c_str(), "男")) 
  972. (RoleBaseList + i)->Sex = 0;
  973. else
  974. (RoleBaseList + i)->Sex = 1;
  975. }
  977. return nCount;
  978. }
  980. S3DBI_API BOOL S3DBI_IsRoleNameExisted(char * strUser)
  981. {
  982. if ((!strUser) || (!strUser[0])) return FALSE;
  983. //获得数据库中玩家基本信息表
  984. S3PRole Role(strUser);
  985. int nLastResult = Role.GetLastResult();
  986. if (nLastResult > 0)
  987.  return TRUE;
  988. return FALSE;
  989. }
  991. //获得数据库中玩家基本信息表
  994. //************************************************
  995. // 更新玩家的好友列表//
  998. //*************************************************
  1001. //*************************************************
  1002. // 加载玩家的战斗技能列表
  1004. //*************************************************
  1007. //*************************************************
  1008. // 加载玩家的生活技能列表
  1013. //*************************************************
  1016. //*************************************************
  1017. // 加载玩家的物品列表
  1020. //*************************************************
  1023. //*************************************************
  1024. // 加载玩家的任务列表
  1027. //*************************************************