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

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

模拟服务器

开发平台：

C/C++

DBBackup.cpp：源码内容
  1. // DBBackup.cpp: implementation of the CDBBackup class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  4. #include "stdafx.h"
  5. #include "DBTABLE.H"
  6. #include "DBBackup.h"
  7. #include "DBDumpLoad.h"
  8. #include <FSTREAM>
  9. #include <direct.h>
  10. #include "Macro.h"
  11. #include "CRC32.h"
  13. using namespace std;
  15. #define IS_OUTPUT_LOG true
  17. #define ROLE_FILTER_FILE "RoleFilter.ini"
  18. #define ROLE_FILTER_COUNT 300
  20. static char DBPath[32] = {0}; //数据库目录
  21. static char DBName[32] = {0}; //数据库名
  22. static ZDBTable* RunTable = NULL;
  24. static bool IsBackupWorking = false; //是否正在备份
  25. static bool IsThreadWorking = false; //线程是否在工作
  26. static bool IsSuspended = false; //线程是否挂起
  27. static WORD BackupTime = 0; //备份间隔时间
  28. static bool IsTimeToBackup = true;
  30. static CDBBackup::TStatData oldGameStatData;//旧的游戏统计数据
  31. static CDBBackup::TStatData newGameStatData;//新的游戏统计数据
  33. static TGAME_STAT_DATA SendStatData; //取得发送给客户端的统计数据结构
  35. int CDBBackup::GetIndexByName(char* aName, TRoleList* aList, int aListSize)
  36. {
  37. if(aList[0].Name[0] == '') return -1;
  38. for(int i=0;i<aListSize;++i)
  39. {
  40. if(aList[i].Name[0] == '') return -1;
  41. if (strcmp(aName, aList[i].Name) == 0)
  42. return i;
  43. }
  44. return -1;
  45. }
  47. CDBBackup::TRoleList* CDBBackup::GetMin(
  48. TRoleList* const aRoleList,
  49. const int n,
  50. const StatType aType)
  51. {//查找出列表中钱/级别（或其他）最少的一个元素
  52. TRoleList* tmpData;
  53. tmpData = &aRoleList[0];
  54. while(true)
  55. {
  56. for(int i=0;i<n;++i)
  57. {
  58. if(aRoleList[i].Name[0] == '')
  59. return &aRoleList[i];
  60. int aSourse, aDest;
  61. switch(aType)
  62. {
  63. case stMoney:
  64. aDest = tmpData->Money;
  65. aSourse = aRoleList[i].Money;
  66. break;
  67. case stLevel:
  68. aDest = tmpData->Level;
  69. aSourse = aRoleList[i].Level;
  70. break;
  71. case stKiller:
  72. aDest = tmpData->KillNum;
  73. aSourse = aRoleList[i].KillNum;
  74. break;
  75. }
  76. if(aDest > aSourse)
  77. {
  78. tmpData = &aRoleList[i];
  79. break;
  80. }
  81. }
  82. if(i==n)break;
  83. }
  84. return tmpData;
  85. }
  88. void CDBBackup::ListSort(
  89. TRoleList* const aRoleList,
  90. const int n,
  91. const StatType aType)
  92. {//对列表做特定的排序
  93. int i,j;
  94. for(i=0;i<n;++i)
  95. {
  96. TRoleList* tmpData = &aRoleList[i];
  97. for(j=i+1;j<n;++j)
  98. {
  99. __int64 aSourse, aDest;
  100. switch(aType)
  101. {
  102. case stMoney:
  103. aDest = tmpData->Money;
  104. aSourse = aRoleList[j].Money;
  105. break;
  106. case stLevel:
  107. aDest = (__int64)tmpData->Level * 0xffffffff + (__int64)tmpData->FightExp;
  108. aSourse = (__int64)aRoleList[j].Level * 0xffffffff + (__int64)aRoleList[j].FightExp;
  109. break;
  110. case stKiller:
  111. aDest = tmpData->KillNum;
  112. aSourse = aRoleList[j].KillNum;
  113. break;
  114. }
  115. if( aSourse > aDest )
  116. swap(*tmpData, aRoleList[j]);
  117. }
  118. }
  119. }
  121. void CDBBackup::RoleDataCopy(TRoleList* Desc, TRoleData* Source)
  122. {//把RoleData有用的结构复制到RoleList结构中
  123. //strcpy(Desc->Account, Source->BaseInfo.caccname);
  124. strcpy(Desc->Name, Source->BaseInfo.szName);
  125. Desc->Sect = Source->BaseInfo.nSect;
  126. Desc->Money = Source->BaseInfo.imoney + Source->BaseInfo.isavemoney;
  127. Desc->Level = Source->BaseInfo.ifightlevel;
  128. Desc->KillNum = Source->BaseInfo.nKillPeopleNumber;
  129. Desc->FightExp = Source->BaseInfo.fightexp;
  130. }
  132. char* CDBBackup::LoadFilterName()
  133. {//取得要过滤的用户名列表 二维数组 [最大名字长度20][数目]
  134. char* aRoleList = new char[ROLE_FILTER_COUNT * 20];
  135. char aBuffer[20];
  136. char aAppPath[MAX_PATH] = {0};
  137. getcwd(aAppPath,MAX_PATH);
  138. strcat(aAppPath,"\");
  139. strcat(aAppPath,ROLE_FILTER_FILE);
  141. fstream aFile(aAppPath,ios::in);
  142. if(!aFile.is_open())
  143. {
  144. SAFE_DELETE_ARRAY(aRoleList);
  145. return NULL;
  146. }
  147. for(int i=0;i<ROLE_FILTER_COUNT;++i)
  148. {
  149. aFile.getline(aBuffer, 20);
  150. if(!aBuffer[0])break;
  151. int aLen = strlen(aBuffer);
  152. strcpy(&aRoleList[i * 20],aBuffer);
  153. aRoleList[i *20 + 19] = '';
  154. }
  155. aFile.close();
  157. return aRoleList;
  158. }
  160. bool CDBBackup::IsRoleFilter(char* aName, char* aList)
  161. {//过滤某些角色
  162. if(!aList) return false;
  163. for(int i=0;i<ROLE_FILTER_COUNT;++i)
  164. {
  165. if(aList[i * 20] == '') return false;
  166. if (strcmp(aName, &aList[i * 20]) == 0)
  167. return true;
  168. }
  169. return false;
  170. }
  172. CDBBackup::CDBBackup(char* aPath, char* aName, ZDBTable* aRunTable)
  173. {
  174. memset(DBPath,0,32);
  175. memset(DBName,0,32);
  176. strcpy(DBPath, aPath);
  177. strcpy(DBName, aName);
  178. BackupTime = 0;
  179. m_hThread = NULL;
  180. m_hManualThread = NULL;
  181. RunTable = aRunTable;
  183. memset(&oldGameStatData, 0, sizeof(TStatData));
  184. memset(&newGameStatData, 0, sizeof(TStatData));
  185. memset(&SendStatData, 0, sizeof(TGAME_STAT_DATA));
  186. }
  188. bool CDBBackup::Open(int aTime)
  189. {
  190. aTime = aTime % 24;
  191. if((DBPath[0] == '')||(DBName[0] == ''))
  192. return false;//初始化有问题就退出
  194. BackupTime = aTime;
  195. DWORD dwThreadId, dwThrdParam = 1;
  196. m_hThread = CreateThread(
  197. NULL,                        // no security attributes 
  198.         0,                           // use default stack size  
  199.         TimerThreadFunc,             // thread function 
  200.         &dwThrdParam,                // argument to thread function 
  201.         0,                           // use default creation flags 
  202.         &dwThreadId);                // returns the thread identifier 
  203. if(!m_hThread)
  204. {
  205. BackupTime = 0;
  206. return false;//创建线程失败
  207. }
  209. char aAppPath[MAX_PATH] = {0};
  210. getcwd(aAppPath,MAX_PATH);
  211. strcat(aAppPath,"\StatData.dat");
  212. //读取旧排名
  213. memset(&newGameStatData,0,sizeof(CDBBackup::TStatData));
  214. FILE* aStatFile = fopen(aAppPath,"rb");
  215. if(aStatFile)
  216. {
  217. int a = fread(&newGameStatData, 1, sizeof(CDBBackup::TStatData), aStatFile);
  218. fclose(aStatFile);
  219. }
  220. MakeSendStatData();
  222. return true;
  223. }
  225. bool CDBBackup::Close()
  226. {
  227. BackupTime = 0;
  228. if(m_hManualThread) CloseHandle( m_hManualThread );
  229. return (CloseHandle( m_hThread ) == TRUE);
  231. }
  233. bool CDBBackup::Suspend()
  234. {
  235. if(!m_hThread) return false; //如果线程没有初始化好就不能挂起
  236. if(!IsThreadWorking) return false; //如果线程没有开始就不能挂起
  237. if(IsBackupWorking) return false; //如果正在备份就中止挂起
  238. if(IsSuspended) return false; //如果正在备份就中止挂起
  239. if(SuspendThread(m_hThread) == -1)return false;
  240. IsSuspended = true;
  241. return true;
  242. }
  244. bool CDBBackup::Resume()
  245. {//继续执行线程
  246. if(!m_hThread) return false; //如果线程没有初始化好就不能挂起
  247. if(!IsSuspended) return false; //如果正在备份就中止挂起
  248. if(!IsThreadWorking) return false; //如果线程没有开始就不能继续执行线程
  250. if(ResumeThread(m_hThread) == -1)return false;
  251. IsSuspended = false;
  252. return true;
  253. }
  255. TGAME_STAT_DATA CDBBackup::GetSendStatData()
  256. {//取得发送给客户端的统计数据结构
  257. return SendStatData;
  258. }
  260. bool CDBBackup::IsWorking()
  261. {//线程是否在工作
  262. return IsThreadWorking;
  263. }
  265. bool CDBBackup::IsBackuping()
  266. {//备份是否在工作
  267. return IsBackupWorking;
  268. }
  270. bool CDBBackup::ManualBackup()
  271. {//手工备份
  272. if(!m_hThread) return false; //如果线程没有初始化好就不能挂起
  273. if(!IsThreadWorking) return false; //如果线程没有开始就不能继续执行线程
  275. DWORD dwThreadId, dwThrdParam = 1;
  276. m_hManualThread = CreateThread(
  277. NULL,                        // no security attributes 
  278.         0,                           // use default stack size  
  279.         ManualThreadFunc,             // thread function 
  280.         &dwThrdParam,                // argument to thread function 
  281.         0,                           // use default creation flags 
  282.         &dwThreadId);                // returns the thread identifier 
  283. if(!m_hManualThread)
  284. {
  285. BackupTime = 0;
  286. return false;//创建线程失败
  287. }
  289. return true;
  290. }
  292. DWORD WINAPI CDBBackup::TimerThreadFunc( LPVOID lpParam )
  293. {//备份计时线程
  294. IsThreadWorking = true;
  295. while(true)
  296. {
  297. SYSTEMTIME aSysTime;
  298. GetLocalTime(&aSysTime);
  299. if(aSysTime.wHour == BackupTime)
  300. {
  301. if(IsTimeToBackup) Backup();
  302. IsTimeToBackup = false;
  303. }
  304. else
  305. {
  306. IsTimeToBackup = true;
  307. }
  309. Sleep(1000 * 60 * 30);
  310. //Sleep(BackupTime);
  311. }
  312. IsThreadWorking = false;
  313. return 0;
  314. }
  316. DWORD WINAPI CDBBackup::ManualThreadFunc( LPVOID lpParam )
  317. {//手工备份线程
  318. Backup();
  319. return 0;
  320. }
  322. void CDBBackup::Backup()
  323. {
  324. IsBackupWorking = true;
  326. //打开备份状态log文件
  327. char aLogPath[MAX_PATH] = {0};
  328. getcwd(aLogPath,MAX_PATH);
  329. strcat(aLogPath,"\Backup.log");
  331. fstream aLogFile(aLogPath,ios::out);
  333. SYSTEMTIME aSysTime;
  334. GetSystemTime(&aSysTime);
  335. string aBackupDir;
  336. char aIntStr[10];
  337. itoa(aSysTime.wYear,aIntStr,10);
  338. aBackupDir = aIntStr;
  339. itoa(aSysTime.wMonth,aIntStr,10);
  340. aBackupDir += aIntStr;
  341. itoa(aSysTime.wDay,aIntStr,10);
  342. aBackupDir += aIntStr;
  343. aBackupDir += "_";
  344. itoa(aSysTime.wHour,aIntStr,10);
  345. aBackupDir += aIntStr;
  346. itoa(aSysTime.wMinute,aIntStr,10);
  347. aBackupDir += aIntStr;
  348. itoa(aSysTime.wSecond,aIntStr,10);
  349. aBackupDir += aIntStr;
  350. itoa(aSysTime.wMilliseconds,aIntStr,10);
  351. aBackupDir += aIntStr;
  352. aLogFile<<"Backup Log File Open Time:"<<aSysTime.wYear<<"."<<
  353. aSysTime.wMonth<<"."<<aSysTime.wDay<<" "<<
  354. aSysTime.wHour<<":"<<aSysTime.wMinute<<":"<<aSysTime.wSecond<<endl;
  355. int i,j;
  356. char aSavePath[MAX_PATH] = {0};
  357. getcwd(aSavePath, MAX_PATH);
  358. strcat(aSavePath,"\");
  359. strcat(aSavePath,DBPath);
  360. strcat(aSavePath,"\");
  361. #ifdef WIN32
  362. mkdir(aSavePath);
  363. #else
  364.         mkdir(aSavePath, 0);
  365. #endif
  366. strcat(aSavePath,aBackupDir.c_str());
  367. strcat(aSavePath,"\");
  368. #ifdef WIN32
  369. mkdir(aSavePath);
  370. #else
  371.         mkdir(aSavePath, 0);
  372. #endif
  373. strcat(aSavePath,aBackupDir.c_str());
  375. //数据库记录统计（维护查看用）==========Add by Fellow,2003.08.26
  376. char aDBSFullPath[MAX_PATH] = {0};
  377. strcpy(aDBSFullPath, aSavePath);
  378. strcat(aDBSFullPath,".txt");
  379. fstream aDBSOutput(aDBSFullPath,ios::out);
  380. aDBSOutput<<"账号名t角色名t门派t等级t金钱"<<endl;
  381. int aDBSPlayerCount=0;
  382. int aDBSSectPlayerCount[12] = {0};
  383. double aDBSMoneyCount=0;
  384. double aDBSSectMoneyCount[12] = {0};
  385. int aDBSLevelPlayerCount[200] = {0};
  386. //==================
  388. strcat(aSavePath,".bak");
  389. CDBDump DBDump;
  390. DBDump.Open(aSavePath);
  392. if(!RunTable)
  393. {
  394. aLogFile<<"RunTable NULL Error."<<endl;
  395. return;
  396. }
  398. char* RoleFilterList = LoadFilterName(); //取得要过滤的用户名列表
  399. TStatData aStatData;//实时备份后产生的游戏统计数据
  400. memset(&aStatData, 0, sizeof(TStatData));
  402. ZCursor *cursor = RunTable->first();
  403. aLogFile<<"RunTable cursor Opened. Backup begin."<<endl;
  404. while(cursor)
  405. {
  406. if(!DBDump.AddData(cursor->key,cursor->key_size,cursor->data,cursor->size))
  407. {
  408. aLogFile<<"Role["<<cursor->key<<"] Dump Error."<<endl;
  409. }
  411. TRoleList* tmpData;
  412. TRoleData* pRoleData = (TRoleData*)cursor->data;
  414. //数据库记录统计（维护查看用）==========Add by Fellow,2003.08.26
  415. char aDBSSect[32] = {0};
  416. int aDBSSectIndex = (int)pRoleData->BaseInfo.nSect;
  417. switch(aDBSSectIndex)
  418. {
  419. case 0:strcpy(aDBSSect,"少林派");break;
  420. case 1:strcpy(aDBSSect,"天王帮");break;
  421. case 2:strcpy(aDBSSect,"唐门");break;
  422. case 3:strcpy(aDBSSect,"五毒教");break;
  423. case 4:strcpy(aDBSSect,"峨嵋派");break;
  424. case 5:strcpy(aDBSSect,"翠烟门");break;
  425. case 6:strcpy(aDBSSect,"丐帮");break;
  426. case 7:strcpy(aDBSSect,"天忍教");break;
  427. case 8:strcpy(aDBSSect,"武当派");break;
  428. case 9:strcpy(aDBSSect,"昆仑派");break;
  429. default:
  430. if(pRoleData->BaseInfo.ijoincount == 0)
  431. {strcpy(aDBSSect,"新手");break;}
  432. else
  433. {strcpy(aDBSSect,"出师");break;}
  434. }
  435. if(aDBSSectIndex == 255)
  436. {
  437. if(pRoleData->BaseInfo.ijoincount == 0)
  438. {
  439. ++aDBSSectPlayerCount[10];
  440. aDBSSectMoneyCount[10] += pRoleData->BaseInfo.isavemoney + pRoleData->BaseInfo.imoney;
  441. }
  442. else
  443. {
  444. ++aDBSSectPlayerCount[11];
  445. aDBSSectMoneyCount[11] += pRoleData->BaseInfo.isavemoney + pRoleData->BaseInfo.imoney;
  446. }
  447. }
  448. else
  449. {
  450. ++aDBSSectPlayerCount[aDBSSectIndex];
  451. aDBSSectMoneyCount[aDBSSectIndex] += pRoleData->BaseInfo.isavemoney + pRoleData->BaseInfo.imoney;
  452. }
  453. aDBSMoneyCount += pRoleData->BaseInfo.isavemoney + pRoleData->BaseInfo.imoney;
  454. ++aDBSPlayerCount;
  455. if(((pRoleData->BaseInfo.ifightlevel >0))&&(pRoleData->BaseInfo.ifightlevel < 200))
  456. aDBSLevelPlayerCount[pRoleData->BaseInfo.ifightlevel]++;
  457. else
  458. {
  459. aDBSOutput<<"***级别问题*** ";
  460. aDBSLevelPlayerCount[0]++;
  461. }
  462. aDBSOutput<<pRoleData->BaseInfo.caccname<<"t"<<
  463. pRoleData->BaseInfo.szName<<"t"<<
  464. aDBSSect<<"t"<<
  465. pRoleData->BaseInfo.ifightlevel<<"t"<<
  466. pRoleData->BaseInfo.isavemoney + pRoleData->BaseInfo.imoney<<endl;
  468. //=======================================
  470. if(IsRoleFilter(pRoleData->BaseInfo.szName, RoleFilterList))
  471. {//过滤某些角色
  472. if(!RunTable->next(cursor))break;
  473. continue;
  474. }
  475. //////////////////////////////玩家统计////////////////////////////////////
  476. //对金钱排序
  477. tmpData = GetMin(aStatData.MoneyStat, MONEYSTATNUM, stMoney);
  478. if( tmpData->Money < pRoleData->BaseInfo.imoney + pRoleData->BaseInfo.isavemoney)
  479. {//如果当前数据较大就把当前数据代替列表中最小的
  480. RoleDataCopy(tmpData, pRoleData);
  481. }
  483. //对级别排序
  484. tmpData = GetMin(aStatData.LevelStat, LEVELSTATNUM, stLevel);
  485. if( tmpData->Level < pRoleData->BaseInfo.ifightlevel)
  486. {//如果当前数据较大就把当前数据代替列表中最小的
  487. RoleDataCopy(tmpData, pRoleData);
  488. }
  490. //对杀人数排序
  491. tmpData = GetMin(aStatData.KillerStat, KILLERSTATNUM, stKiller);
  492. if( tmpData->KillNum < pRoleData->BaseInfo.nKillPeopleNumber)
  493. {//如果当前数据较大就把当前数据代替列表中最小的
  494. RoleDataCopy(tmpData, pRoleData);
  495. }
  497. //各门派对金钱排序
  498. if( (pRoleData->BaseInfo.nSect <=10) && (pRoleData->BaseInfo.nSect >= 1) )
  499. {
  500. tmpData = GetMin(aStatData.MoneyStatBySect[pRoleData->BaseInfo.nSect + 1], SECTMAXSTATNUM, stMoney);
  501. }
  502. else
  503. {
  504. tmpData = GetMin(aStatData.MoneyStatBySect[0], SECTMAXSTATNUM, stMoney);
  505. }
  506. if( tmpData->Money < pRoleData->BaseInfo.imoney  + pRoleData->BaseInfo.isavemoney)
  507. {//如果当前数据较大就把当前数据代替列表中最小的
  508. RoleDataCopy(tmpData, pRoleData);
  509. }
  511. //各门派对级别排序
  512. if( (pRoleData->BaseInfo.nSect <=10) && (pRoleData->BaseInfo.nSect >= 1) )
  513. {
  514. tmpData = GetMin(aStatData.LevelStatBySect[pRoleData->BaseInfo.nSect + 1], SECTMAXSTATNUM, stMoney);
  515. }
  516. else
  517. {
  518. tmpData = GetMin(aStatData.LevelStatBySect[0], SECTMAXSTATNUM, stMoney);
  519. }
  520. if( tmpData->Level < pRoleData->BaseInfo.ifightlevel)
  521. {//如果当前数据较大就把当前数据代替列表中最小的
  522. RoleDataCopy(tmpData, pRoleData);
  523. }
  525. //////////////////////////////门派统计////////////////////////////////////
  526. //各个门派的玩家数统计
  527. if( (pRoleData->BaseInfo.nSect <=10) && (pRoleData->BaseInfo.nSect >= 1) )
  528. {
  529. ++aStatData.SectPlayerNum[pRoleData->BaseInfo.nSect + 1];
  530. }
  531. else
  532. {
  533. ++aStatData.SectPlayerNum[0];
  534. }
  536. if(!RunTable->next(cursor))break;
  537. }
  538. DBDump.Close(); //关闭备份数据库
  539. aLogFile<<"DB Dump Finished."<<endl;
  540. aLogFile<<"RunTable cursor closed."<<endl;
  542. //数据库记录统计（维护查看用）==========Add by Fellow,2003.08.26
  543. aDBSOutput<<"==记录结束=="<<endl<<endl;
  544. aDBSOutput<<"==统计=="<<endl;
  545. aDBSOutput<<"总人数："<<aDBSPlayerCount<<endl;
  546. for(i=0;i<12;++i)
  547. {
  548. char aDBSSect[32] = {0};
  549. switch(i)
  550. {
  551. case 0:strcpy(aDBSSect,"少林派");break;
  552. case 1:strcpy(aDBSSect,"天王帮");break;
  553. case 2:strcpy(aDBSSect,"唐门");break;
  554. case 3:strcpy(aDBSSect,"五毒教");break;
  555. case 4:strcpy(aDBSSect,"峨嵋派");break;
  556. case 5:strcpy(aDBSSect,"翠烟门");break;
  557. case 6:strcpy(aDBSSect,"丐帮");break;
  558. case 7:strcpy(aDBSSect,"天忍教");break;
  559. case 8:strcpy(aDBSSect,"武当派");break;
  560. case 9:strcpy(aDBSSect,"昆仑派");break;
  561. case 10:strcpy(aDBSSect,"新手");break;
  562. case 11:strcpy(aDBSSect,"出师");break;
  563. }
  564. aDBSOutput<<aDBSSect<<"人数："<<aDBSSectPlayerCount[i]<<endl;
  565. }
  566. aDBSOutput<<"------------------------------------------------"<<endl;
  567. aDBSOutput<<"总金钱数："<<aDBSMoneyCount<<endl;
  568. for(i=0;i<12;++i)
  569. {
  570. char aDBSSect[32] = {0};
  571. switch(i)
  572. {
  573. case 0:strcpy(aDBSSect,"少林派");break;
  574. case 1:strcpy(aDBSSect,"天王帮");break;
  575. case 2:strcpy(aDBSSect,"唐门");break;
  576. case 3:strcpy(aDBSSect,"五毒教");break;
  577. case 4:strcpy(aDBSSect,"峨嵋派");break;
  578. case 5:strcpy(aDBSSect,"翠烟门");break;
  579. case 6:strcpy(aDBSSect,"丐帮");break;
  580. case 7:strcpy(aDBSSect,"天忍教");break;
  581. case 8:strcpy(aDBSSect,"武当派");break;
  582. case 9:strcpy(aDBSSect,"昆仑派");break;
  583. case 10:strcpy(aDBSSect,"新手");break;
  584. case 11:strcpy(aDBSSect,"出师");break;
  585. }
  586. aDBSOutput<<aDBSSect<<"金钱数："<<aDBSSectMoneyCount[i]<<endl;
  587. }
  588. aDBSOutput<<"------------------------------------------------"<<endl;
  589. aDBSOutput<<"角色级别分布[1-200级]："<<endl;
  590. for(i=1;i<200;++i)
  591. if(aDBSLevelPlayerCount[i] != 0)
  592. aDBSOutput<<i<<"级人数："<<aDBSLevelPlayerCount[i]<<endl;
  593. aDBSOutput<<"级别异常人数："<<aDBSLevelPlayerCount[0]<<endl;
  594. //======================================
  596. for(i=0;i<MONEYSTATNUM;++i)
  597. { //财富排名前一百玩家中各门派所占比例数
  598. if( (aStatData.MoneyStat[i].Sect <=10) && (aStatData.MoneyStat[i].Sect >= 1) )
  599. {
  600. ++aStatData.SectMoneyMost[aStatData.MoneyStat[i].Sect + 1];
  601. }
  602. else
  603. {
  604. ++aStatData.SectMoneyMost[0];
  605. }
  606. }
  608. for(i=0;i<LEVELSTATNUM;++i)
  609. {//级别排名前一百玩家中各门派所占比例数
  610. if( (aStatData.LevelStat[i].Sect <=10) && (aStatData.LevelStat[i].Sect >= 1) )
  611. {
  612. ++aStatData.SectLevelMost[aStatData.LevelStat[i].Sect + 1];
  613. }
  614. else
  615. {
  616. ++aStatData.SectLevelMost[0];
  617. }
  618. }
  620. //////////////////////////////排序////////////////////////////////////
  621. ListSort(aStatData.MoneyStat, MONEYSTATNUM, stMoney);
  622. ListSort(aStatData.LevelStat, LEVELSTATNUM, stLevel);
  623. ListSort(aStatData.KillerStat, KILLERSTATNUM, stKiller);
  624. for(i=0;i<11;++i)
  625. {//各门派金钱排序
  626. ListSort(aStatData.MoneyStatBySect[i], SECTMAXSTATNUM, stMoney);
  627. }
  628. for(i=0;i<11;++i)
  629. {//各门派级别排序
  630. ListSort(aStatData.LevelStatBySect[i], SECTMAXSTATNUM, stLevel);
  631. }
  633. SAFE_DELETE_ARRAY(RoleFilterList);
  634. ///////////////以下为对统计数据的处理//////////////////////////////////////////////////////
  635. char aAppPath[MAX_PATH] = {0};
  636. getcwd(aAppPath,MAX_PATH);
  637. strcat(aAppPath,"\StatData.dat");
  638. //读取旧排名
  639. memset(&oldGameStatData,0,sizeof(CDBBackup::TStatData));
  640. FILE* aStatFile = fopen(aAppPath,"rb");
  641. if(aStatFile)
  642. {
  643. int a = fread(&oldGameStatData, 1, sizeof(CDBBackup::TStatData), aStatFile);
  644. fclose(aStatFile);
  645. }
  647. newGameStatData = aStatData;
  649. //找出前十名的oldGameStatData中的排名（或名次上升还是下降）
  650. for(i=0;i<10;++i)
  651. {
  652. int aIndex;
  653. //等级
  654. aIndex = CDBBackup::GetIndexByName(
  655. newGameStatData.LevelStat[i].Name,oldGameStatData.LevelStat, LEVELSTATNUM);
  656. if(aIndex != -1)
  657. {
  658. if(i < aIndex)
  659. newGameStatData.LevelStat[i].Sort = 1;
  660. else if(i > aIndex)
  661. newGameStatData.LevelStat[i].Sort = 255;
  662. else
  663. newGameStatData.LevelStat[i].Sort = 0;
  664. }
  665. else
  666. newGameStatData.LevelStat[i].Sort = 1;
  668. //金钱
  669. aIndex = CDBBackup::GetIndexByName(
  670. newGameStatData.MoneyStat[i].Name,oldGameStatData.MoneyStat, MONEYSTATNUM);
  671. if(aIndex != -1)
  672. {
  673. if(i < aIndex)
  674. newGameStatData.MoneyStat[i].Sort = 1;
  675. else if(i > aIndex)
  676. newGameStatData.MoneyStat[i].Sort = 255;
  677. else
  678. newGameStatData.MoneyStat[i].Sort = 0;
  679. }
  680. else
  681. newGameStatData.MoneyStat[i].Sort = 1;
  683. //杀人数
  684. aIndex = CDBBackup::GetIndexByName(
  685. newGameStatData.KillerStat[i].Name,oldGameStatData.KillerStat, KILLERSTATNUM);
  686. if(aIndex != -1)
  687. {
  688. if(i < aIndex)
  689. newGameStatData.KillerStat[i].Sort = 1;
  690. else if(i > aIndex)
  691. newGameStatData.KillerStat[i].Sort = 255;
  692. else
  693. newGameStatData.KillerStat[i].Sort = 0;
  694. }
  695. else
  696. newGameStatData.KillerStat[i].Sort = 1;
  698. for(j=0;j<11;++j)
  699. {//各个门派
  700. //等级
  701. aIndex = CDBBackup::GetIndexByName(
  702. newGameStatData.LevelStatBySect[j][i].Name,oldGameStatData.LevelStatBySect[j], SECTMAXSTATNUM);
  703. if(aIndex != -1)
  704. {
  705. if(i < aIndex)
  706. newGameStatData.LevelStatBySect[j][i].Sort = 1;
  707. else if(i > aIndex)
  708. newGameStatData.LevelStatBySect[j][i].Sort = 255;
  709. else
  710. newGameStatData.LevelStatBySect[j][i].Sort = 0;
  711. }
  712. else
  713. newGameStatData.LevelStatBySect[j][i].Sort = 1;
  715. //金钱
  716. aIndex = CDBBackup::GetIndexByName(
  717. newGameStatData.MoneyStatBySect[j][i].Name,oldGameStatData.MoneyStatBySect[j], SECTMAXSTATNUM);
  718. if(aIndex != -1)
  719. {
  720. if(i < aIndex)
  721. newGameStatData.MoneyStatBySect[j][i].Sort = 1;
  722. else if(i > aIndex)
  723. newGameStatData.MoneyStatBySect[j][i].Sort = 255;
  724. else
  725. newGameStatData.MoneyStatBySect[j][i].Sort = 0;
  726. }
  727. else
  728. newGameStatData.MoneyStatBySect[j][i].Sort = 1;
  729. }
  730. }
  732. //储存新排名
  733. aStatFile = fopen(aAppPath,"wb");
  734. if(aStatFile)
  735. {
  736. int a = fwrite(&newGameStatData, 1, sizeof(CDBBackup::TStatData), aStatFile);
  738. fclose(aStatFile);
  739. }
  741. MakeSendStatData();//把统计数据写到发送给客户端的统计数据结构中
  743. //test===========
  744. if(IS_OUTPUT_LOG){//是否输出统计数据
  745. aLogFile<<"DB Statistic Log:"<<endl;
  746. aLogFile<<"--------------Level--------------"<<endl;
  747. for(i=0;i<10;++i)
  748. {
  749. aLogFile<<SendStatData.LevelStat[i].Name<<"t"<<
  750. SendStatData.LevelStat[i].nValue<<"t"<<
  751. (int)SendStatData.LevelStat[i].bySort<<endl;
  752. }
  753. aLogFile<<"--------------Money--------------"<<endl;
  754. for(i=0;i<10;++i)
  755. {
  756. aLogFile<<SendStatData.MoneyStat[i].Name<<"t"<<
  757. SendStatData.MoneyStat[i].nValue<<"t"<<
  758. (int)SendStatData.MoneyStat[i].bySort<<endl;
  759. }
  760. aLogFile<<"--------------Killer--------------"<<endl;
  761. for(i=0;i<10;++i)
  762. {
  763. aLogFile<<SendStatData.KillerStat[i].Name<<"t"<<
  764. SendStatData.KillerStat[i].nValue<<"t"<<
  765. (int)SendStatData.KillerStat[i].bySort<<endl;
  766. }
  767. for(i=0;i<11;++i)
  768. {
  769. aLogFile<<"--------------Sect "<<i<<" Level--------------"<<endl;
  770. for(j=0;j<10;++j)
  771. {
  772. aLogFile<<SendStatData.LevelStatBySect[i][j].Name<<"t"<<
  773. SendStatData.LevelStatBySect[i][j].nValue<<"t"<<
  774. (int)SendStatData.LevelStatBySect[i][j].bySort<<endl;
  775. }
  776. aLogFile<<"-------------Sect "<<i<<" Money---------------"<<endl;
  777. for(j=0;j<10;++j)
  778. {
  779. aLogFile<<SendStatData.MoneyStatBySect[i][j].Name<<"t"<<
  780. SendStatData.MoneyStatBySect[i][j].nValue<<"t"<<
  781. (int)SendStatData.MoneyStatBySect[i][j].bySort<<endl;
  782. }
  783. }
  784. aLogFile<<"各个门派的玩家数"<<endl;
  785. for(i=0;i<11;++i)
  786. {
  787. aLogFile<<"Sect "<<i<<" ："<<SendStatData.SectPlayerNum[i]<<endl;
  788. }
  789. aLogFile<<"财富排名前 "<<MONEYSTATNUM<<" 玩家中各门派所占比例数"<<endl;
  790. for(i=0;i<11;++i)
  791. {
  792. aLogFile<<"Sect "<<i<<" ："<<SendStatData.SectMoneyMost[i]<<endl;
  793. }
  794. aLogFile<<"级别排名前 "<<MONEYSTATNUM<<" 玩家中各门派所占比例数"<<endl;
  795. for(i=0;i<11;++i)
  796. {
  797. aLogFile<<"Sect "<<i<<" ："<<SendStatData.SectLevelMost[i]<<endl;
  798. }
  799. }
  800. //================
  802. IsBackupWorking = false;
  803. }
  805. void CDBBackup::MakeSendStatData()
  806. {//生成发送给客户端的统计数据结构
  807. int i,j;
  808. memset(&SendStatData,0,sizeof(TGAME_STAT_DATA));
  809. for(i=0;i<10;++i)
  810. {
  811. strcpy(SendStatData.LevelStat[i].Name, newGameStatData.LevelStat[i].Name);
  812. SendStatData.LevelStat[i].nValue = newGameStatData.LevelStat[i].Level;
  813. SendStatData.LevelStat[i].bySort = newGameStatData.LevelStat[i].Sort;
  815. strcpy(SendStatData.MoneyStat[i].Name, newGameStatData.MoneyStat[i].Name);
  816. SendStatData.MoneyStat[i].nValue = newGameStatData.MoneyStat[i].Money;
  817. SendStatData.MoneyStat[i].bySort = newGameStatData.MoneyStat[i].Sort;
  819. strcpy(SendStatData.KillerStat[i].Name, newGameStatData.KillerStat[i].Name);
  820. SendStatData.KillerStat[i].nValue = newGameStatData.KillerStat[i].KillNum;
  821. SendStatData.KillerStat[i].bySort = newGameStatData.KillerStat[i].Sort;
  823. for(j=0;j<11;++j)
  824. {//各个门派
  825. strcpy(SendStatData.LevelStatBySect[j][i].Name, newGameStatData.LevelStatBySect[j][i].Name);
  826. SendStatData.LevelStatBySect[j][i].nValue = newGameStatData.LevelStatBySect[j][i].Level;
  827. SendStatData.LevelStatBySect[j][i].bySort = newGameStatData.LevelStatBySect[j][i].Sort;
  829. strcpy(SendStatData.MoneyStatBySect[j][i].Name, newGameStatData.MoneyStatBySect[j][i].Name);
  830. SendStatData.MoneyStatBySect[j][i].nValue = newGameStatData.MoneyStatBySect[j][i].Money;
  831. SendStatData.MoneyStatBySect[j][i].bySort = newGameStatData.MoneyStatBySect[j][i].Sort;
  833. SendStatData.SectLevelMost[j] = newGameStatData.SectLevelMost[j];
  834. SendStatData.SectMoneyMost[j] = newGameStatData.SectMoneyMost[j];
  835. SendStatData.SectPlayerNum[j] = newGameStatData.SectPlayerNum[j];
  836. }
  837. }
  838. }
  840. void CDBBackup::SaveStatInfo()
  841. {//把游戏世界等级排名写到指定玩家角色中
  842. TStatData aStatData;
  843. char aAppPath[MAX_PATH] = {0};
  844. getcwd(aAppPath,MAX_PATH);
  845. strcat(aAppPath,"\StatData.dat");
  846. //读取排名
  847. memset(&aStatData,0,sizeof(TStatData));
  848. FILE* aStatFile = fopen(aAppPath,"rb");
  849. if(aStatFile)
  850. {
  851. int aRead = fread(&aStatData, sizeof(TStatData), 1, aStatFile);
  852. if(aRead != 1) return;
  853. fclose(aStatFile);
  854. }
  855. else
  856. {
  857. return;
  858. }
  860. int i,j;
  861. for(i=0;i<LEVELSTATNUM;++i)
  862. {
  863. if(aStatData.LevelStat[i].Name[0] == '')continue;
  864. ZCursor *cursor = RunTable->search(aStatData.LevelStat[i].Name, strlen(aStatData.LevelStat[i].Name) +1);
  865. // char* aBuffer = RunTable->search(aStatData.LevelStat[i].Name, strlen(aStatData.LevelStat[i].Name) +1,size);
  866. if(!cursor)
  867. {
  868. continue;
  869. }
  870. TRoleData* pRoleData = (TRoleData*)cursor->data;
  871. pRoleData->BaseInfo.nWorldStat = i+1;
  873. if (pRoleData->dwDataLen - 4 == pRoleData->dwFriendOffset)
  874. {
  875. DWORD dwCRC = 0;
  876. dwCRC = CRC32(dwCRC, pRoleData, pRoleData->dwDataLen - 4);
  877. memcpy(cursor->data + pRoleData->dwDataLen - 4, &dwCRC, 4);
  878. }
  880. RunTable->add(aStatData.LevelStat[i].Name, strlen(aStatData.LevelStat[i].Name) +1, cursor->data, cursor->size);
  881. RunTable->closeCursor(cursor);
  882. }
  885. //把门派等级排名写到指定玩家角色中
  886. for(i=0;i<11;++i)
  887. {
  888. for(j=0;j<SECTMAXSTATNUM;++j)
  889. {
  890. if(aStatData.LevelStatBySect[i][j].Name[0] == '')continue;
  891. ZCursor *cursor = RunTable->search( aStatData.LevelStatBySect[i][j].Name, strlen(aStatData.LevelStatBySect[i][j].Name) +1 );
  892. // char* aBuffer = RunTable->search(aStatData.LevelStatBySect[i][j].Name, strlen(aStatData.LevelStatBySect[i][j].Name) +1,size);
  893. if(!cursor)
  894. {
  895. continue;
  896. }
  897. TRoleData* pRoleData = (TRoleData*)cursor->data;
  898. pRoleData->BaseInfo.nSectStat = j+1;
  900. if (pRoleData->dwDataLen - 4 == pRoleData->dwFriendOffset)
  901. {
  902. DWORD dwCRC = 0;
  903. dwCRC = CRC32(dwCRC, pRoleData, pRoleData->dwDataLen - 4);
  904. memcpy(cursor->data + pRoleData->dwDataLen - 4, &dwCRC, 4);
  905. }
  906. RunTable->add(aStatData.LevelStatBySect[i][j].Name, strlen(aStatData.LevelStatBySect[i][j].Name) +1, cursor->data, cursor->size);
  907. RunTable->closeCursor(cursor);
  908. }
  909. }
  910. }