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

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

模拟服务器

开发平台：

C/C++

S3PAccount.cpp：源码内容
  1. //-----------------------------------------//
  2. //                                         //
  3. //  File : S3PAccount.cpp    //
  4. // Author : Yang Xiaodong            //
  5. // Modified : 8/29/2002                //
  6. //                                         //
  7. //-----------------------------------------//
  8. #pragma warning(disable: 4786)
  9. #include "S3PAccount.h"
  10. #include "S3PDBConVBC.h"
  11. #include "S3PResultVBC.h"
  12. #include "COMUtil.h"
  14. S3PAccount::S3PAccount()
  15. {
  16. }
  18. S3PAccount::~S3PAccount()
  19. {
  20. }
  22. DWORD GetGMID();
  24. int S3PAccount::ServerLogin(S3PDBConVBC* pConn, const char* strAccName, const char* strPassword, const DWORD Address, const short Port, const BYTE Mac[6], DWORD& nGameID)
  25. {
  26. nGameID = 0;
  27. int iRet = ACTION_FAILED;
  28. if (NULL == pConn)
  29. {
  30. return iRet;
  31. }
  32. char strSQL[MAX_PATH];
  33. sprintf(strSQL, "select cIP, iPort, iid, cMemo from ServerList where (cServerName = '%s') and (cPassword COLLATE Chinese_PRC_CS_AS = '%s')", strAccName, strPassword);
  34. S3PResultVBC* pResult = NULL;
  35. if (pConn->QuerySql(strSQL, &pResult))
  36. {
  37. if (pResult->num_rows() <= 0)
  38. iRet = E_ACCOUNT_OR_PASSWORD;
  39. else
  40. {
  41. iRet = E_ADDRESS_OR_PORT;
  42. if ((Address & 0x0000FFFF) == 0x0000a8c0)
  43. {
  44. _variant_t clientid = 0L;
  45. pResult->get_field_data(2, &clientid, sizeof(_variant_t));
  46. nGameID = clientid.lVal;
  47. iRet = ACTION_SUCCESS; //Local network not check ip
  48. }
  49. else
  50. {
  51. _variant_t vaddr;
  52. _variant_t vaMac;
  53. if (pResult->get_field_data(0, &vaddr, sizeof(_variant_t)) &&
  54. pResult->get_field_data(3, &vaMac, sizeof(_variant_t)) &&
  55. vaddr.vt == VT_BSTR && vaMac.vt == VT_BSTR)
  56. {
  57. DWORD addr = inet_addr((const char *)(_bstr_t)vaddr);
  58. char szmac[15];
  59. sprintf(szmac, "%02X%02X-%02X%02X-%02X%02X", Mac[0], Mac[1], Mac[2], Mac[3],Mac[4], Mac[5]);
  60. szmac[14] = 0;
  61. if (addr == Address &&
  62. strcmpi((const char *)(_bstr_t)vaMac, szmac) == 0)
  63. {
  64. _variant_t gameid = 0L;
  65. pResult->get_field_data(2, &gameid, sizeof(_variant_t));
  66. nGameID = gameid.lVal;
  67. iRet = ACTION_SUCCESS;
  68. }
  69. }
  70. }
  71. }
  72. }
  74. if (pResult)
  75. pResult->unuse();
  77. return iRet;
  78. }
  80. int S3PAccount::CheckAddress(S3PDBConVBC* pConn, const DWORD Address, const short Port)
  81. {
  82. int iRet = ACTION_FAILED;
  83. if (NULL == pConn)
  84. {
  85. return iRet;
  86. }
  87. if ((Address & 0x0000FFFF) == 0x0000a8c0)
  88. iRet = ACTION_SUCCESS; //Local network not check ip
  89. else
  90. {
  91. char strSQL[MAX_PATH];
  92. in_addr add;
  93. add.s_addr = Address;
  94. sprintf(strSQL, "select iid from ServerList where (cIP = '%s')", inet_ntoa(add));
  95. S3PResultVBC* pResult = NULL;
  96. if (pConn->QuerySql(strSQL, &pResult))
  97. {
  98. if (pResult->num_rows() <= 0)
  99. iRet = E_ADDRESS_OR_PORT;
  100. else
  101. iRet = ACTION_SUCCESS;
  102. }
  103. if (pResult)
  104. pResult->unuse();
  105. }
  107. return iRet;
  108. }
  110. int S3PAccount::ServerLogout(S3PDBConVBC* pConn, DWORD ClientID, BOOL bElapse)
  111. {
  112. int iRet = ACTION_FAILED;
  113. if (NULL == pConn)
  114. {
  115. return iRet;
  116. }
  118. iRet = ACTION_SUCCESS;
  120. return iRet;
  121. }
  123. int S3PAccount::GetAccountCount(S3PDBConVBC* pConn, DWORD nGameID, BOOL bOnline, DWORD& dwCount)
  124. {
  125. int iRet = ACTION_FAILED;
  126. if (NULL == pConn)
  127. {
  128. return iRet;
  129. }
  130. iRet = ACTION_SUCCESS;
  131. dwCount = 0;
  133. char strSQL[MAX_PATH];
  134. strSQL[0] = 0;
  135. std::string strwhere;
  136. if (bOnline)
  137. {
  138. strwhere = "where ";
  139. if (nGameID > 0)
  140. {
  141. sprintf(strSQL, "(iClientID = %d)", nGameID);
  142. }
  143. else
  144. {
  145. sprintf(strSQL, "(iClientID <> 0) and (iClientID is not null)");
  146. }
  147. }
  148. strwhere += strSQL;
  150. sprintf(strSQL, "select count(*) from Account_info %s", strwhere.c_str());
  151. S3PResultVBC* pResult = NULL;
  152. if (pConn->QuerySql(strSQL, &pResult))
  153. {
  154. if (pResult->num_rows() > 0)
  155. {
  156. _variant_t count = 0L;
  157. pResult->get_field_data(0, &count, sizeof(_variant_t));
  158. dwCount = count.lVal;
  159. }
  160. }
  162. if (pResult)
  163. pResult->unuse();
  165. return iRet;
  166. }
  168. int S3PAccount::GetAccountGameID(S3PDBConVBC* pConn, const char* strAccName, DWORD& ClientID)
  169. {
  170. int iRet = ACTION_FAILED;
  171. if (NULL == pConn)
  172. {
  173. return iRet;
  174. }
  175. char strSQL[MAX_PATH];
  176. sprintf(strSQL, "select iClientID from Account_info where (cAccName = '%s')", strAccName);
  177. S3PResultVBC* pResult = NULL;
  178. if (pConn->QuerySql(strSQL, &pResult))
  179. {
  180. if (pResult->num_rows() <= 0)
  181. iRet = E_ACCOUNT_OR_PASSWORD;
  182. else
  183. {
  184. _variant_t lID = 0L;
  185. pResult->get_field_data(0, &lID, sizeof(_variant_t));
  186. ClientID = lID.lVal;
  187. iRet = ACTION_SUCCESS;
  188. }
  189. }
  191. if (pResult)
  192. pResult->unuse();
  194. return iRet;
  195. }
  197. int S3PAccount::UnlockAccount(S3PDBConVBC* pConn, const char* strAccName)
  198. {
  199. int iRet = ACTION_FAILED;
  200. if (NULL == pConn)
  201. {
  202. return iRet;
  203. }
  204. char strSQL[MAX_PATH];
  205. sprintf(strSQL, "update Account_info set iClientID = 0 where (cAccName = '%s')", strAccName);
  206. S3PResultVBC* pResult = NULL;
  207. if (pConn->Do(strSQL))
  208. iRet = ACTION_SUCCESS;
  210. return iRet;
  211. }
  213. int S3PAccount::FreezeAccount(S3PDBConVBC* pConn, const char* strAccName)
  214. {
  215. int iRet = ACTION_FAILED;
  216. if (NULL == pConn)
  217. {
  218. return iRet;
  219. }
  220. char strSQL[MAX_PATH];
  221. sprintf(strSQL, "update Account_info set iClientID = %d where (cAccName = '%s')", GetGMID(), strAccName);
  222. S3PResultVBC* pResult = NULL;
  223. if (pConn->Do(strSQL))
  224. iRet = ACTION_SUCCESS;
  226. return iRet;
  227. }
  229. int S3PAccount::UnlockServer(S3PDBConVBC* pConn, unsigned long nGameID)
  230. {
  231. int iRet = ACTION_FAILED;
  232. if (NULL == pConn)
  233. {
  234. return iRet;
  235. }
  236. char strSQL[MAX_PATH];
  237. sprintf(strSQL, "update Account_info set iClientID = 0 where (iClientID = %d)", nGameID);
  238. S3PResultVBC* pResult = NULL;
  239. if (pConn->Do(strSQL))
  240. iRet = ACTION_SUCCESS;
  242. return iRet;
  243. }
  245. int S3PAccount::GetAccountsTime(S3PDBConVBC* pConn, DWORD ClientID, DWORD dwMinSecond, AccountTimeList& List)
  246. {
  247. int iRet = ACTION_FAILED;
  248. if (NULL == pConn)
  249. {
  250. return iRet;
  251. }
  252. char strSQL[MAX_PATH];
  253. sprintf(strSQL, "select datediff(second, getdate(), dEndDate), iLeftSecond, cAccName, datediff(second, getdate(), dLoginDate) from View_AccountMoney where (iClientID = %d) and (dLoginDate is not null)", ClientID);
  254. S3PResultVBC* pResult = NULL;
  255. if (pConn->QuerySql(strSQL, &pResult))
  256. {
  257. for (int iRow = 0; iRow < pResult->num_rows(); iRow++)
  258. {
  259. KAccountUserTimeInfo aReturn;
  260. aReturn.Size = sizeof(KAccountUserTimeInfo);
  261. aReturn.Type = AccountUserTimeInfo;
  262. aReturn.Operate = 0;
  264. _variant_t left = 0L;
  265. _variant_t diffDate;
  266. _variant_t accname;
  267. _variant_t usesencond;
  268. pResult->get_field_data(0, &diffDate, sizeof(_variant_t));
  269. pResult->get_field_data(1, &left, sizeof(_variant_t));
  270. pResult->get_field_data(2, &accname, sizeof(_variant_t));
  271. pResult->get_field_data(3, &usesencond, sizeof(_variant_t));
  272. long liLeft = left.lVal;
  274. if (diffDate.vt == VT_I4 && diffDate.lVal > 0) //包月有效
  275. {
  276. liLeft += diffDate.lVal;
  277. }
  278. else if (usesencond.vt == VT_I4 && usesencond.lVal < 0) //点卡扣点起作用了
  279. {
  280. liLeft += usesencond.lVal;
  281. }
  282. aReturn.nTime = max(0, liLeft);
  283. memcpy(aReturn.Account, (const char *)_bstr_t(accname.bstrVal, true), LOGIN_USER_ACCOUNT_MAX_LEN);
  284. aReturn.nReturn = ACTION_SUCCESS;
  285. if (aReturn.nTime <= dwMinSecond)
  286. List.push_back(aReturn);
  287. pResult->data_seek(1, S3PResultVBC::next);
  288. }
  289. iRet = ACTION_SUCCESS;
  290. }
  292. if (pResult)
  293. pResult->unuse();
  295. return iRet;
  296. }
  298. int S3PAccount::GetServerID(S3PDBConVBC* pConn, const char* strAccName, unsigned long& nGameID)
  299. {
  300. nGameID = 0;
  301. int iRet = ACTION_FAILED;
  302. if (NULL == pConn)
  303. {
  304. return iRet;
  305. }
  306. char strSQL[MAX_PATH];
  307. sprintf(strSQL, "select iid from ServerList where (cServerName = '%s')", strAccName);
  308. S3PResultVBC* pResult = NULL;
  309. if (pConn->QuerySql(strSQL, &pResult))
  310. {
  311. if (pResult->num_rows() <= 0)
  312. iRet = E_ACCOUNT_OR_PASSWORD;
  313. else
  314. {
  315. _variant_t clientid = 0L;
  316. pResult->get_field_data(0, &clientid, sizeof(_variant_t));
  317. nGameID = clientid.lVal;
  318. iRet = ACTION_SUCCESS; //Local network not check ip
  319. }
  320. }
  322. if (pResult)
  323. pResult->unuse();
  325. return iRet;
  326. }