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

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

模拟服务器

开发平台：

C/C++

S3PAccount.cpp：源码内容
  1. //-----------------------------------------//
  2. //                                         //
  3. //  File : S3PAccount.cpp    //
  4. // Author : Yang Xiaodong            //
  5. // Modified : 8/29/2002                //
  6. //                                         //
  7. //-----------------------------------------//
  9. #include "S3PAccount.h"
  11. S3PAccount::S3PAccount():
  12. m_bLocked( TRUE )
  13. {
  14. }
  16. S3PAccount::~S3PAccount()
  17. {
  18. }
  20. //----------------------------------------------------------
  21. // < Static Member Function >
  22. // Name : ActivateAccount
  23. // Return : BOOL
  24. //   = TRUE ---- Successful;
  25. //   = FALSE ---- Failed to access database.
  26. // Description : Activate a account.
  27. //----------------------------------------------------------
  28. BOOL S3PAccount::ActivateAccount( const std::string strAccName,
  29.  const std::string strPassword,
  30.  const DWORD dwGameID )
  31. {
  32. BOOL bRet = FALSE;
  34. S3PDBConnection* pAccountCon =
  35. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  37. if ( NULL != pAccountCon )
  38. {
  39. S3PAccountInfoDAO account( pAccountCon );
  40. ColumnAndValue cav;
  41. char szBuffer[20];
  42. _ltoa( dwGameID, szBuffer, 10 );
  43. cav["igameid"] = szBuffer;
  45. ColumnAndValue where;
  46. where["caccname"] = strAccName;
  47. where["strpassword"] = strPassword;
  48. where["igameid"] = szBuffer;
  51. S3PRow row( account.GetTableName(), &cav, pAccountCon );
  52. S3PRow rowWhere( account.GetTableName(), &where, pAccountCon );
  54. if ( account.Update( &row, &rowWhere ) <= 0 )
  55. {
  56. bRet = FALSE;
  57. assert( false );
  58. }
  59. else
  60. {
  61. bRet = TRUE;
  62. }
  63. pAccountCon->Close();
  64. }
  66. return bRet;
  67. }
  69. //----------------------------------------------------------
  70. // < Static Member Function >
  71. // Name : AddAccount
  72. // Return : int
  73. //   = 1 ---- Successful;
  74. //   = 0 ---- Failed to access database;
  75. //   = -1 ---- Parameter "strAccName" is null;
  76. //   = -2 ---- Parameter "strPassword" is null;
  77. //   = -3 ---- Parameter "strRealName" is null;
  78. //   = -4 ---- The account has existed;
  79. //   = others ---- Not defined.
  80. // Description : Add a new account.
  81. //----------------------------------------------------------
  82. int S3PAccount::AddAccount( const std::string strAccName,
  83. const std::string strPassword,
  84. const std::string strRealName,
  85. const std::string strIDNum,
  86. const std::string strBirthDay,
  87. const std::string strArea,
  88. const std::string strPhone )
  89. {
  90. int iRet = 1;
  92. if ( strAccName.empty() )
  93. {
  94. iRet = -1;
  95. return iRet;
  96. }
  97. if ( strPassword.empty() )
  98. {
  99. iRet = -2;
  100. return iRet;
  101. }
  102. if ( strRealName.empty() )
  103. {
  104. iRet = -3;
  105. return iRet;
  106. }
  108. S3PDBConnection* pAccountCon =
  109. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  110. if ( NULL != pAccountCon )
  111. {
  112. S3PAccountInfoDAO account( pAccountCon );
  113. ColumnAndValue cav;
  114. cav["caccname"] = strAccName;
  115. cav["cpassword"] = strPassword;
  116. cav["crealname"] = strRealName;
  117. if ( !( strIDNum.empty() ) )
  118. {
  119. cav["cidnum"] = strIDNum;
  120. }
  121. if ( !( strBirthDay.empty() ) )
  122. {
  123. cav["dbirthday"] = strBirthDay;
  124. }
  125. if ( !( strArea.empty() ) )
  126. {
  127. cav["carea"] = strArea;
  128. }
  129. if ( !( strPhone.empty() ) )
  130. {
  131. cav["cphone"] = strPhone;
  132. }
  133. cav["dregdate"] = pAccountCon->GetDate();
  135. ColumnAndValue where;
  136. where["caccname"] = strAccName;
  138. S3PRow rowCav( account.GetTableName(), &cav, pAccountCon );
  139. S3PRow rowWhere( account.GetTableName(), &where, pAccountCon );
  140. if ( false == account.HasItem( &rowWhere ) )
  141. {
  142. int iResult = account.Add( &rowCav );
  143. if ( iResult <= 0 )
  144. {
  145. iRet = 0;
  146. }
  147. else
  148. {
  149. iRet = 1;
  150. }
  151. }
  152. else
  153. {
  154. iRet = -4;
  155. }
  157. pAccountCon->Close();
  158. }
  159. else
  160. {
  161. iRet = 0;
  162. }
  164. return iRet;
  165. }
  167. //----------------------------------------------------------
  168. // < Static Member Function >
  169. // Name : Login
  170. // Return : int
  171. //   = 1 ---- Successful;
  172. //   = 0 ---- Failed to access database;
  173. //   = -1 ---- Parameter "strAccName" is null;
  174. //   = -2 ---- Parameter "strPassword" is null;
  175. //   = -3 ---- The same user has logged in from
  176. //      other host machine;
  177. //   = -4 ---- The user has not registered;
  178. //   = others ---- Not defined.
  179. // Description : login from game.
  180. //----------------------------------------------------------
  181. int S3PAccount::Login( const std::string strAccName, const std::string strPassword, int iGameId )
  182. {
  183. int iRet = 1;
  184. if ( strAccName.empty() )
  185. {
  186. iRet = -1;
  187. return iRet;
  188. }
  189. if ( strPassword.empty() )
  190. {
  191. iRet = -2;
  192. return iRet;
  193. }
  195. S3PDBConnection* pAccountCon =
  196. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  197. if ( NULL != pAccountCon )
  198. {
  199. S3PAccountInfoDAO account( pAccountCon );
  200. ColumnAndValue cav;
  201. char szGameID[11]; // The maxima number is 4294967296
  202. memset( szGameID, 0, 11 );
  203. _itoa( iGameId, szGameID, 10 );
  204. cav["igameid"] = szGameID;
  205. cav["itimecount"] = "1";
  207. ColumnAndValue where;
  208. where["caccname"] = strAccName;
  209. where["cpassword"] = strPassword;
  210. S3PRow rowWhere0( account.GetTableName(), &where, pAccountCon );
  211. if ( account.HasItem( &rowWhere0 ) )
  212. {
  213. where["igameid"] = "0";
  214. S3PRow rowWhere1( account.GetTableName(), &where, pAccountCon );
  215. if ( account.HasItem( &rowWhere1 ) )
  216. {
  217. if ( 0 != iGameId )
  218. {
  219. S3PRow rowCav( account.GetTableName(), &cav, pAccountCon );
  220. S3PRow rowWhere2( account.GetTableName(), &where, pAccountCon );
  221. if ( account.Update( &rowCav, &rowWhere2 ) <= 0 )
  222. {
  223. iRet = 0;
  224. }
  225. else
  226. {
  227. iRet = 1;
  228. }
  229. }
  230. else
  231. {
  232. iRet = 1;
  233. }
  234. }
  235. else
  236. {
  237. iRet = -3;
  238. }
  239. }
  240. else
  241. {
  242. iRet = -4;
  243. }
  245. pAccountCon->Close();
  246. }
  247. else
  248. {
  249. iRet = 0;
  250. }
  251. return iRet;
  252. }
  254. //----------------------------------------------------------
  255. // < Static Member Function >
  256. // Name : Logout
  257. // Return : int
  258. //   = 1 ---- Successful;
  259. //   = 0 ---- Failed to access database;
  260. //   = -1 ---- Parameter "strAccName" is null;
  261. //   = -2 ---- Parameter "strPassword" is null;
  262. //   = others ---- Not defined.
  263. // Description : logout from game.
  264. //----------------------------------------------------------
  265. int S3PAccount::Logout( const std::string strAccName, const std::string strPassword, int iGameId )
  266. {
  267. int iRet = 1;
  268. if ( strAccName.empty() )
  269. {
  270. iRet = -1;
  271. return iRet;
  272. }
  273. if ( strPassword.empty() )
  274. {
  275. iRet = -2;
  276. return iRet;
  277. }
  279. S3PDBConnection* pAccountCon =
  280. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  281. if ( NULL != pAccountCon )
  282. {
  283. S3PAccountInfoDAO account( pAccountCon );
  284. ColumnAndValue cav;
  285. char szGameId[11]; // The maxima number is 4294967296
  286. memset( szGameId, 0, 11 );
  287. _itoa( iGameId, szGameId, 10 );
  288. cav["igameid"] = "0";
  289. cav["itimecount"] = "0";
  291. ColumnAndValue where;
  292. where["caccname"] = strAccName;
  293. where["cpassword"] = strPassword;
  294. where["igameid"] = szGameId;
  296. S3PRow rowCav( account.GetTableName(), &cav, pAccountCon );
  297. S3PRow rowWhere( account.GetTableName(), &where, pAccountCon );
  300. if ( account.Update( &rowCav, &rowWhere ) <= 0 )
  301. {
  302. iRet = 0;
  303. }
  304. else
  305. {
  306. iRet = 1;
  307. }
  309. pAccountCon->Close();
  310. }
  311. else
  312. {
  313. iRet = 0;
  314. }
  316. return iRet;
  317. }
  319. //----------------------------------------------------------
  320. // < Static Member Function >
  321. // Name : Report
  322. // Return : int
  323. //   = 1 ---- Successful;
  324. //   = 0 ---- Failed to access database;
  325. //   = -1 ---- Parameter "strAccName" is null;
  326. //   = -2 ---- Parameter "strPassword" is null;
  327. //   = -3 ---- Has been disconnected;
  328. //   = -4 ---- User has not registered;
  329. //   = others ---- Not defined.
  330. // Description : 与服务器握手,用于检查游戏是否在线.
  331. //----------------------------------------------------------
  332. int S3PAccount::Report( const std::string strAccName, const std::string strPassword, int iGameId )
  333. {
  334. int iRet = 1;
  335. if ( strAccName.empty() )
  336. {
  337. iRet = -1;
  338. return iRet;
  339. }
  340. if ( strPassword.empty() )
  341. {
  342. iRet = -2;
  343. return iRet;
  344. }
  345. S3PDBConnection* pAccountCon =
  346. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  347. if ( NULL != pAccountCon )
  348. {
  349. S3PAccountInfoDAO account( pAccountCon );
  350. ColumnAndValue cav;
  351. char szGameId[11]; // The maxima number is 4294967296
  352. memset( szGameId, 0, 11 );
  353. _itoa( iGameId, szGameId, 10 );
  354. cav["itimecount"] = "1";
  355. ColumnAndValue where0;
  356. where0["caccname"] = strAccName;
  357. where0["cpassword"] = strPassword;
  358. S3PRow rowWhere0( account.GetTableName(), &where0, pAccountCon );
  359. if ( account.HasItem( &rowWhere0 ) )
  360. {
  361. ColumnAndValue where;
  362. where["caccname"] = strAccName;
  363. where["cpassword"] = strPassword;
  364. where["igameid"] = "0";
  366. S3PRow rowCav( account.GetTableName(), &cav, pAccountCon );
  367. S3PRow rowWhere( account.GetTableName(), &where, pAccountCon );
  369. if ( !( account.HasItem( &rowWhere ) ) )
  370. {
  371. where["igameid"] = szGameId;
  372. where["itimecount"] = "0";
  373. S3PRow rowWhere1( account.GetTableName(), &where, pAccountCon );
  374. if ( account.Update( &rowCav, &rowWhere1 ) <= 0 )
  375. {
  376. iRet = 0;
  377. }
  378. else
  379. {
  380. iRet = 1;
  381. }
  382. }
  383. else
  384. {
  385. iRet = -3;
  386. }
  387. }
  388. else
  389. {
  390. iRet = -4;
  391. }
  393. pAccountCon->Close();
  394. }
  395. else
  396. {
  397. iRet = 0;
  398. }
  400. return iRet;
  401. }
  403. //----------------------------------------------------------
  404. // < Static Member Function >
  405. // Name : QueryGameserverList
  406. // Return : int
  407. //   = 1 ---- Successful;
  408. //   = 0 ---- Failed to access database;
  409. //   = -1 ---- Parameter "strAccName" is null;
  410. //   = -2 ---- Parameter "strPassword" is null;
  411. //   = -3 ---- i)The account doesn't exist,
  412. //      ii)account or password is wrong;
  413. //   = -4 ---- The size of "pServers"("dwSize") is
  414. //      smaller than the reality;
  415. //   = others ---- Not defined.
  416. // Description : Query game server list.
  417. //----------------------------------------------------------
  418. int S3PAccount::QueryGameserverList( const std::string strAccName,
  419. const std::string strPassword,
  420. IBYTE* pServers, DWORD& dwSize )
  421. {
  422. int iRet = 1;
  423. if ( strAccName.empty() )
  424. {
  425. iRet = -1;
  426. return iRet;
  427. }
  428. if ( strPassword.empty() )
  429. {
  430. iRet = -2;
  431. return iRet;
  432. }
  433. S3PDBConnection* pAccountCon =
  434. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  435. if ( NULL != pAccountCon )
  436. {
  437. S3PAccountInfoDAO account( pAccountCon );
  438. S3PServerListDAO serverList( pAccountCon );
  440. ColumnAndValue where;
  441. where["caccname"] = strAccName;
  442. where["cpassword"] = strPassword;
  444. S3PRow rowWhere( account.GetTableName(), &where, pAccountCon );
  445. if ( account.HasItem( &rowWhere ) )
  446. {
  447. std::string strTableName = serverList.GetTableName();
  448. std::string strSql = "select * from ";
  449. strSql += strTableName;
  450. S3PResult res;
  451. serverList.Query( strSql, res );
  453. int iRowNum = res.num_rows();
  454. DWORD dwSizeTemp = iRowNum * sizeof( KLoginGameServer );
  455. if ( dwSizeTemp > dwSize )
  456. {
  457. iRet = -4;
  458. }
  459. else
  460. {
  461. if ( NULL != pServers )
  462. {
  463. memset( pServers, 0, dwSizeTemp );
  464. res.data_seek( 0 );
  465. for ( int i = 0; i < iRowNum; i++ )
  466. {
  467. ColumnAndValue cav = res[i];
  468. std::string strName = cav["cservername"];
  469. std::string strIP = cav["dwip"];
  470. std::string strPort = cav["iport"];
  471. std::string strID = cav["iid"];
  472. DWORD dwIP = atol( strIP.c_str() );
  473. int iPort = atol( strPort.c_str() );
  474. DWORD dwID = atol( strID.c_str() );
  476. int iLength = strName.length();
  477. int offset = 0;
  478. memcpy( &( pServers[i*sizeof( KLoginGameServer )+offset] ),
  479. strName.c_str(),
  480. GAMESERVERNAME_MAX_LEN );
  481. offset += GAMESERVERNAME_MAX_LEN + 2;
  482. memcpy( &( pServers[i*sizeof( KLoginGameServer )+offset] ),
  483. &dwIP, sizeof( DWORD ) );
  484. offset += sizeof( DWORD );
  485. memcpy( &( pServers[i*sizeof( KLoginGameServer )+offset] ),
  486. &iPort, sizeof( short ) );
  487. offset += sizeof( short );
  488. memcpy( &( pServers[i*sizeof( KLoginGameServer )+offset] ),
  489. &dwID, sizeof( DWORD ) );
  490. }
  491. iRet = 1;
  492. }
  493. }
  494. dwSize = dwSizeTemp;
  495. }
  496. else
  497. {
  498. iRet = -3; // 未注册用户或者用户名、密码错误
  499. }
  501. pAccountCon->Close();
  502. }
  503. else
  504. {
  505. iRet = 0;
  506. }
  507. return iRet;
  508. }
  510. //----------------------------------------------------------
  511. // < Static Member Function >
  512. // Name : DBLogin
  513. // Return : int
  514. //   = 1 ---- Successful;
  515. //   = 0 ---- Failed to access database;
  516. //   = -1 ---- Parameter "strUserName" is null;
  517. //   = -2 ---- Parameter "strPassword" is null;
  518. //   = -3 ---- Parameter "strHostAddr" is null;
  519. //   = -4 ---- User has logged in.
  520. //   = others ---- Not defined.
  521. // Description : log in account database as database
  522. //   remote user.
  523. //----------------------------------------------------------
  524. int S3PAccount::DBLogin( const std::string strUserName,
  525. const std::string strPassword,
  526. const std::string strHostAddr )
  527. {
  528. int iRet = 1;
  529. if ( strUserName.empty() )
  530. {
  531. iRet = -1;
  532. return iRet;
  533. }
  534. if ( strPassword.empty() )
  535. {
  536. iRet = -2;
  537. return iRet;
  538. }
  539. if ( strHostAddr.empty() )
  540. {
  541. iRet = -3;
  542. return iRet;
  543. }
  544. S3PDBConnection* pAccountCon =
  545. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  546. if ( NULL != pAccountCon )
  547. {
  548. S3PAccountUserDAO user( pAccountCon );
  550. ColumnAndValue where0;
  551. where0["szusername"] = strUserName;
  552. where0["szpassword"] = strPassword;
  553. where0["eloggedin"] = "N";
  555. S3PRow rowWhere0( user.GetTableName(), &where0, pAccountCon );
  556. if ( user.HasItem( &rowWhere0 ) )
  557. {
  558. ColumnAndValue cav;
  559. cav["eloggedin"] = "Y";
  560. cav["szhostaddr"] = strHostAddr;
  561. cav["dlastlogintime"] = pAccountCon->GetDateTime();
  563. ColumnAndValue where1;
  564. where1["szusername"] = strUserName;
  565. where1["szpassword"] = strPassword;
  567. S3PRow rowCav( user.GetTableName(), &cav, pAccountCon );
  568. S3PRow rowWhere1( user.GetTableName(), &where1, pAccountCon );
  569. if ( user.Update( &rowCav, &rowWhere1 ) <= 0 )
  570. {
  571. iRet = 0;
  572. }
  573. else
  574. {
  575. iRet = 1;
  576. }
  577. }
  578. else
  579. {
  580. where0["eloggedin"] = "Y";
  581. S3PRow rowWhereTemp( user.GetTableName(), &where0, pAccountCon );
  582. if ( user.HasItem( &rowWhereTemp ) )
  583. iRet = -4; // User has logged in.
  584. else
  585. iRet = 0;
  586. }
  588. pAccountCon->Close();
  589. }
  590. else
  591. {
  592. iRet = 0;
  593. }
  594. return iRet;
  595. }
  597. //----------------------------------------------------------
  598. // < Static Member Function >
  599. // Name : DBLogout
  600. // Return : int
  601. //   = 1 ---- Successful;
  602. //   = 0 ---- Failed to access database;
  603. //   = -1 ---- Parameter "strUserName" is null;
  604. //   = -2 ---- Parameter "strPassword" is null;
  605. //   = others ---- Not defined.
  606. // Description : log out from account database as database
  607. //   remote user.
  608. //----------------------------------------------------------
  609. int S3PAccount::DBLogout( const std::string strUserName,
  610.  const std::string strPassword )
  611. {
  612. int iRet = 1;
  613. if ( strUserName.empty() )
  614. {
  615. iRet = -1;
  616. return iRet;
  617. }
  618. if ( strPassword.empty() )
  619. {
  620. iRet = -2;
  621. return iRet;
  622. }
  624. S3PDBConnection* pAccountCon =
  625. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  626. if ( NULL != pAccountCon )
  627. {
  628. S3PAccountUserDAO user( pAccountCon );
  630. ColumnAndValue cav;
  631. cav["eloggedin"] = "N";
  632. cav["dlastlogouttime"] = pAccountCon->GetDateTime();
  634. ColumnAndValue where;
  635. where["szusername"] = strUserName;
  636. where["szpassword"] = strPassword;
  638. S3PRow rowCav( user.GetTableName(), &cav, pAccountCon );
  639. S3PRow rowWhere( user.GetTableName(), &where, pAccountCon );
  640. if ( user.Update( &rowCav, &rowWhere ) <= 0 )
  641. {
  642. iRet = 0;
  643. }
  644. else
  645. {
  646. iRet = 1;
  647. }
  649. pAccountCon->Close();
  650. }
  651. else
  652. {
  653. iRet = 0;
  654. }
  656. return iRet;
  657. }
  659. //----------------------------------------------------------
  660. // < Static Member Function >
  661. // Name : DBQueryUserList
  662. // Return : int
  663. //   = 1 ---- Successful;
  664. //   = 0 ---- Failed to access database;
  665. //   = -1 ---- Parameter "strUserName" is null;
  666. //   = -2 ---- Parameter "strPassword" is null;
  667. //   = -3 ---- Has no enough priority;
  668. //   = -4 ---- Has no such user or password is wrong
  669. //      or the user has not logged in;
  670. //   = -5 ---- User list is empty;
  671. //   = -6 ---- The size of pUser buffer is not enough big;
  672. //   = others ---- Not defined.
  673. // Description : Query user list from account database
  674. //   as database remote user.
  675. //----------------------------------------------------------
  676. int S3PAccount::DBQueryUserList( const std::string strUserName,
  677. const std::string strPassword,
  678. IBYTE* pUsers, DWORD& dwSize )
  679. {
  680. int iRet = 1;
  681. if ( strUserName.empty() )
  682. {
  683. iRet = -1;
  684. return iRet;
  685. }
  686. if ( strPassword.empty() )
  687. {
  688. iRet = -2;
  689. return iRet;
  690. }
  692. S3PDBConnection* pAccountCon =
  693. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  694. if ( NULL != pAccountCon )
  695. {
  696. S3PAccountUserDAO user( pAccountCon );
  698. std::string strTableName = user.GetTableName();
  699. std::string strSql = "select * from ";
  700. strSql += strTableName;
  701. strSql += " where szUserName='";
  702. strSql += strUserName;
  703. strSql += "' and szPassword='";
  704. strSql += strPassword;
  705. strSql += "' and eLoggedin='Y'";
  706. S3PResult res;
  707. user.Query( strSql, res );
  709. int iRowNum = res.num_rows();
  710. res.data_seek( 0 );
  711. if ( 1 == iRowNum )
  712. {
  713. ColumnAndValue cav = res[0];
  714. std::string strPriority = cav["epriority"];
  715. BOOL bHasPriority = FALSE;
  716. if ( 0 == stricmp( "Read", strPriority.c_str() ) )
  717. {
  718. bHasPriority = TRUE;
  719. }
  720. else if ( 0 == stricmp( "Read-Write", strPriority.c_str() ) )
  721. {
  722. bHasPriority = TRUE;
  723. }
  724. else if ( 0 == stricmp( "Administrator", strPriority.c_str() ) )
  725. {
  726. bHasPriority = TRUE;
  727. }
  728. if ( TRUE == bHasPriority )
  729. {
  730. strSql = "select * from ";
  731. strSql += strTableName;
  732. S3PResult queryUserListRes;
  733. user.Query( strSql, queryUserListRes );
  734. iRowNum = queryUserListRes.num_rows();
  735. queryUserListRes.data_seek( 0 );
  736. if ( 0 < iRowNum )
  737. {
  738. DWORD dwSizeTemp = iRowNum * sizeof( _USERINFO );
  739. if ( NULL != pUsers )
  740. {
  741. if ( dwSizeTemp > dwSize )
  742. {
  743. iRet = -6;
  744. }
  745. else
  746. {
  747. memset( pUsers, 0, dwSize );
  748. for ( int i = 0; i < iRowNum; i++ )
  749. {
  750. int offset = 0;
  751. ColumnAndValue userinfo = queryUserListRes[i];
  752. memcpy( &pUsers[i*sizeof( _USERINFO )+offset], 
  753. userinfo["szhostaddr"].c_str(), 16 );
  754. offset += 16;
  755. memcpy( &pUsers[i*sizeof( _USERINFO )+offset],
  756. userinfo["szusername"].c_str(),
  757. userinfo["szusername"].size() );
  758. offset += def_DBUSERNAME_MAX_LEN + 1;
  759. memcpy( &pUsers[i*sizeof( _USERINFO )+offset],
  760. userinfo["szpassword"].c_str(),
  761. userinfo["szpassword"].size() );
  762. offset += def_DBPASSWORD_MAX_LEN + 1;
  763. short siPriority;
  764. std::string strPriority = userinfo["epriority"];
  765. if ( 0 == stricmp( strPriority.c_str(), "Read" ) )
  766. {
  767. siPriority = 0;
  768. }
  769. else if ( 0 == stricmp( strPriority.c_str(), "Write" ) )
  770. {
  771. siPriority = 1;
  772. }
  773. else if ( 0 == stricmp( strPriority.c_str(), "Read-Write" ) )
  774. {
  775. siPriority = 2;
  776. }
  777. else if ( 0 == stricmp( strPriority.c_str(), "Administrator" ) )
  778. {
  779. siPriority = 3;
  780. }
  781. memcpy( &pUsers[i*sizeof( _USERINFO )+offset],
  782. &siPriority, sizeof( short ) );
  783. offset += sizeof( short );
  784. BOOL bLoggedin;
  785. std::string strLoggedin = userinfo["eloggedin"];
  786. if ( 0 == stricmp( strLoggedin.c_str(), "N" ) )
  787. {
  788. bLoggedin = FALSE;
  789. }
  790. else if ( 0 == stricmp( strLoggedin.c_str(), "Y" ) )
  791. {
  792. bLoggedin = TRUE;
  793. }
  794. memcpy( &pUsers[i*sizeof( _USERINFO )+offset],
  795. &bLoggedin, sizeof( BOOL ) );
  796. offset += sizeof( BOOL );
  797. memcpy( &pUsers[i*sizeof( _USERINFO )+offset],
  798. userinfo["dlastlogintime"].c_str(),
  799. userinfo["dlastlogintime"].size() );
  800. offset += 20;
  801. memcpy( &pUsers[i*sizeof( _USERINFO )+offset],
  802. userinfo["dlastlogouttime"].c_str(),
  803. userinfo["dlastlogouttime"].size() );
  804. offset += 20;
  805. }
  806. iRet = 1;
  807. }
  808. }
  809. else
  810. {
  811. iRet = 1;
  812. }
  813. dwSize = dwSizeTemp;
  814. }
  815. else
  816. {
  817. iRet = -5;
  818. // or iRet = 0;
  819. }
  820. }
  821. else
  822. {
  823. iRet = -3; // Has no enough priority.
  824. }
  825. }
  826. else
  827. {
  828. iRet = -4;
  829. }
  831. pAccountCon->Close();
  832. }
  833. else
  834. {
  835. iRet = 0;
  836. }
  838. return iRet;
  839. }
  841. //----------------------------------------------------------
  842. // < Static Member Function >
  843. // Name : DBLock
  844. // Return : int
  845. //   = 1 ---- Successful;
  846. //   = 0 ---- Failed to access database;
  847. //   = -1 ---- Parameter "strUserName" is null;
  848. //   = -2 ---- Parameter "strPassword" is null;
  849. //   = others ---- Not defined.
  850. // Description : Check whether the specified user who carry out
  851. //       locking account database operation is connected.
  852. //----------------------------------------------------------
  853. int S3PAccount::DBLock( const std::string strUserName, const std::string strPassword )
  854. {
  855. int iRet = 1;
  856. if ( strUserName.empty() )
  857. {
  858. iRet = -1;
  859. return iRet;
  860. }
  861. if ( strPassword.empty() )
  862. {
  863. iRet = -2;
  864. return iRet;
  865. }
  867. S3PDBConnection* pAccountCon =
  868. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  869. if ( NULL != pAccountCon )
  870. {
  871. S3PAccountUserDAO user( pAccountCon );
  873. ColumnAndValue where;
  874. where["szusername"] = strUserName;
  875. where["szpassword"] = strPassword;
  876. where["eloggedin"] = "Y";
  878. S3PRow rowWhere( user.GetTableName(), &where, pAccountCon );
  879. if ( user.HasItem( &rowWhere ) )
  880. {
  881. iRet = 1;
  882. }
  883. else
  884. {
  885. iRet = 0;
  886. }
  888. pAccountCon->Close();
  889. }
  890. else
  891. {
  892. iRet = 0;
  893. }
  894. return iRet;
  895. }
  897. //----------------------------------------------------------
  898. // < Static Member Function >
  899. // Name : DBLock
  900. // Return : int
  901. //   = 1 ---- Successful;
  902. //   = 0 ---- Failed to access database;
  903. //   = -1 ---- Parameter "strUserName" is null;
  904. //   = -2 ---- Parameter "strPassword" is null;
  905. //   = others ---- Not defined.
  906. // Description : Check whether the specified user who carry out
  907. //       activating account database operation is connected.
  908. //----------------------------------------------------------
  909. int S3PAccount::DBActivate( const std::string strUserName, const std::string strPassword )
  910. {
  911. int iRet = 1;
  912. if ( strUserName.empty() )
  913. {
  914. iRet = -1;
  915. return iRet;
  916. }
  917. if ( strPassword.empty() )
  918. {
  919. iRet = -2;
  920. return iRet;
  921. }
  923. S3PDBConnection* pAccountCon =
  924. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  925. if ( NULL != pAccountCon )
  926. {
  927. S3PAccountUserDAO user( pAccountCon );
  929. ColumnAndValue where;
  930. where["szusername"] = strUserName;
  931. where["szpassword"] = strPassword;
  932. where["eloggedin"] = "Y";
  934. S3PRow rowWhere( user.GetTableName(), &where, pAccountCon );
  935. if ( user.HasItem( &rowWhere ) )
  936. {
  937. iRet = 1;
  938. }
  939. else
  940. {
  941. iRet = 0;
  942. }
  944. pAccountCon->Close();
  945. }
  946. else
  947. {
  948. iRet = 0;
  949. }
  950. return iRet;
  951. }
  953. //----------------------------------------------------------
  954. // < Static Member Function >
  955. // Name : DBAddUser
  956. // Return : int
  957. //   = 1 ---- Successful;
  958. //   = 0 ---- Failed to access database;
  959. //   = -1 ---- Parameter "strUserName" is null;
  960. //   = -2 ---- Parameter "strPassword" is null;
  961. //   = -3 ---- Parameter "strNewUserName" is null;
  962. //   = -4 ---- Parameter "strNewUserPassword" is null;
  963. //   = -5 ---- Parameter "siNewUserPriority" is invalid;
  964. //   = -6 ---- Has no enough priority;
  965. //   = -7 ---- The user has existed;
  966. //   = others ---- Not defined.
  967. // Description : Add new administrator of account database.
  968. //----------------------------------------------------------
  969. int S3PAccount::DBAddUser( const std::string strUserName, const std::string strPassword,
  970.   const std::string strNewUserName, const std::string strNewUserPassword,
  971.   short int siNewUserPriority )
  972. {
  973. int iRet = 0;
  974. if ( strUserName.empty() )
  975. {
  976. iRet = -1;
  977. return iRet;
  978. }
  979. if ( strPassword.empty() )
  980. {
  981. iRet = -2;
  982. return iRet;
  983. }
  984. if ( strNewUserName.empty() )
  985. {
  986. iRet = -3;
  987. return iRet;
  988. }
  989. if ( strNewUserPassword.empty() )
  990. {
  991. iRet = -4;
  992. return iRet;
  993. }
  994. if ( ( 0 > siNewUserPriority ) || ( 3 < siNewUserPriority ) )
  995. {
  996. iRet = -5;
  997. return iRet;
  998. }
  1000. S3PDBConnection* pAccountCon =
  1001. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  1002. if ( NULL != pAccountCon )
  1003. {
  1004. S3PAccountUserDAO user( pAccountCon );
  1006. std::string strTableName = user.GetTableName();
  1007. std::string strSql = "select * from ";
  1008. strSql += strTableName;
  1009. strSql += " where szUserName='";
  1010. strSql += strUserName;
  1011. strSql += "' and szPassword='";
  1012. strSql += strPassword;
  1013. strSql += "' and eLoggedin='Y'";
  1014. S3PResult res;
  1015. user.Query( strSql, res );
  1017. int iRowNum = res.num_rows();
  1018. res.data_seek( 0 );
  1019. if ( 1 == iRowNum )
  1020. {
  1021. ColumnAndValue cav = res[0];
  1022. std::string strPriority = cav["epriority"];
  1023. BOOL bHasPriority = FALSE;
  1024. if ( 0 == stricmp( "Write", strPriority.c_str() ) )
  1025. {
  1026. if ( ( 0 < siNewUserPriority )
  1027. && ( 1 >= siNewUserPriority ) )
  1028. {
  1029. bHasPriority = TRUE;
  1030. }
  1031. }
  1032. else if ( 0 == stricmp( "Read-Write", strPriority.c_str() ) )
  1033. {
  1034. if ( ( 0 < siNewUserPriority )
  1035. && ( 2 >= siNewUserPriority ) )
  1036. {
  1037. bHasPriority = TRUE;
  1038. }
  1039. }
  1040. else if ( 0 == stricmp( "Administrator", strPriority.c_str() ) )
  1041. {
  1042. bHasPriority = TRUE;
  1043. }
  1044. if ( TRUE == bHasPriority )
  1045. {
  1046. ColumnAndValue where;
  1047. where["szusername"] = strNewUserName;
  1048. S3PRow rowWhere( user.GetTableName(), &where, pAccountCon );
  1049. if ( false == user.HasItem( &rowWhere ) )
  1050. {
  1051. ColumnAndValue newCav;
  1052. newCav["szusername"] = strNewUserName;
  1053. newCav["szpassword"] = strNewUserPassword;
  1054. newCav["eloggedin"] = "N";
  1055. //newCav["szhostaddr"] = "0.0.0.0";
  1056. //newCav["dlastlogintime"] = "1978-2-21 12:00:00";
  1057. //newCav["dlastlogouttime"] = "1978-2-21 12:00:00";
  1058. switch ( siNewUserPriority )
  1059. {
  1060. case 0:
  1061. newCav["epriority"] = "Read";
  1062. break;
  1063. case 1:
  1064. newCav["epriority"] = "Write";
  1065. break;
  1066. case 2:
  1067. newCav["epriority"] = "Read-Write";
  1068. break;
  1069. case 3:
  1070. newCav["epriority"] = "Administrator";
  1071. break;
  1072. }
  1073. S3PRow rowCav( user.GetTableName(), &newCav, pAccountCon );
  1074. int iResult = user.Add( &rowCav );
  1075. if ( iResult <= 0 )
  1076. {
  1077. iRet = 0;
  1078. }
  1079. else
  1080. {
  1081. iRet = 1;
  1082. }
  1083. }
  1084. else
  1085. {
  1086. iRet = -7;
  1087. }
  1088. }
  1089. else
  1090. {
  1091. iRet = -6;
  1092. }
  1093. }
  1094. else
  1095. {
  1096. iRet = 0;
  1097. }
  1099. pAccountCon->Close();
  1100. }
  1101. else
  1102. {
  1103. iRet = 0;
  1104. }
  1106. return iRet;
  1107. }
  1109. //----------------------------------------------------------
  1110. // < Static Member Function >
  1111. // Name : DBDeleteUser
  1112. // Return : int
  1113. //   = 1 ---- Successful;
  1114. //   = 0 ---- Failed to access database;
  1115. //   = -1 ---- Parameter "strUserName" is null;
  1116. //   = -2 ---- Parameter "strPassword" is null;
  1117. //   = -3 ---- Parameter "strSelUserName" is null;
  1118. //   = -4 ---- Has no enough priority or is disconnected;
  1119. //   = others ---- Not defined.
  1120. // Description : Delete specified administrator of account database.
  1121. //----------------------------------------------------------
  1122. int S3PAccount::DBDeleteUser( const std::string strUserName,
  1123.  const std::string strPassword,
  1124.  const std::string strSelUserName )
  1125. {
  1126. int iRet = 0;
  1127. if ( strUserName.empty() )
  1128. {
  1129. iRet = -1;
  1130. return iRet;
  1131. }
  1132. if ( strPassword.empty() )
  1133. {
  1134. iRet = -2;
  1135. return iRet;
  1136. }
  1137. if ( strSelUserName.empty() )
  1138. {
  1139. iRet = -3;
  1140. return iRet;
  1141. }
  1142. S3PDBConnection* pAccountCon =
  1143. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  1144. if ( NULL != pAccountCon )
  1145. {
  1146. S3PAccountUserDAO user( pAccountCon );
  1147. ColumnAndValue where1;
  1148. where1["szusername"] = strUserName;
  1149. where1["szpassword"] = strPassword;
  1150. where1["eloggedin"] = "Y";
  1151. where1["epriority"] = "Administrator";
  1152. S3PRow rowWhere1( user.GetTableName(), &where1, pAccountCon );
  1153. if ( user.HasItem( &rowWhere1 ) )
  1154. {
  1155. ColumnAndValue where2;
  1156. where2["szusername"] = strSelUserName;
  1157. S3PRow rowWhere2( user.GetTableName(), &where2, pAccountCon );
  1158. if ( 1 == user.Delete( &rowWhere2 ) )
  1159. {
  1160. iRet = 1;
  1161. }
  1162. else
  1163. {
  1164. iRet = 0;
  1165. }
  1166. }
  1167. else
  1168. {
  1169. iRet = -4;
  1170. }
  1171. pAccountCon->Close();
  1172. }
  1173. return iRet;
  1174. }
  1176. //----------------------------------------------------------
  1177. // < Static Member Function >
  1178. // Name : DBDeleteUser
  1179. // Return : int
  1180. //   = 1 ---- Successful;
  1181. //   = 0 ---- Failed to access database;
  1182. //   = -1 ---- Parameter "strUserName" is null;
  1183. //   = -2 ---- Parameter "strPassword" is null;
  1184. //   = -3 ---- Parameter "strAccRealName" is null;
  1185. //   = -4 ---- Parameter "strAccPassword" is null;
  1186. //   = -5 ---- Parameter "strAccName" is null;
  1187. //   = -6 ---- Has no enough priority or is disconnected;
  1188. //   = -7 ---- The account has existed;
  1189. //   = others ---- Not defined.
  1190. // Description : Create new account.
  1191. //----------------------------------------------------------
  1192. int S3PAccount::DBCreateAccount( const std::string strUserName,
  1193. const std::string strPassword,
  1194. const std::string strAccRealName,
  1195. const std::string strAccPassword,
  1196. const std::string strAccName )
  1197. {
  1198. int iRet = 1;
  1199. if ( strUserName.empty() )
  1200. {
  1201. iRet = -1;
  1202. return iRet;
  1203. }
  1204. if ( strPassword.empty() )
  1205. {
  1206. iRet = -2;
  1207. return iRet;
  1208. }
  1209. if ( strAccRealName.empty() )
  1210. {
  1211. iRet = -3;
  1212. return iRet;
  1213. }
  1214. if ( strAccPassword.empty() )
  1215. {
  1216. iRet = -4;
  1217. return iRet;
  1218. }
  1219. if ( strAccName.empty() )
  1220. {
  1221. iRet = -5;
  1222. return iRet;
  1223. }
  1224. S3PDBConnection* pAccountCon =
  1225. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  1226. if ( NULL != pAccountCon )
  1227. {
  1228. S3PAccountUserDAO user( pAccountCon );
  1229. ColumnAndValue where;
  1230. where["szusername"] = strUserName;
  1231. where["szpassword"] = strPassword;
  1232. where["eloggedin"] = "Y";
  1233. where["epriority"] = "Administrator";
  1234. S3PRow rowWhere( user.GetTableName(), &where, pAccountCon );
  1235. if ( user.HasItem( &rowWhere ) )
  1236. {
  1237. S3PAccountInfoDAO account( pAccountCon );
  1239. ColumnAndValue where1;
  1240. where1["caccname"] = strAccName;
  1241. S3PRow rowWhere1( account.GetTableName(), &where1, pAccountCon );
  1242. if ( !( account.HasItem( &rowWhere1 ) ) )
  1243. {
  1244. ColumnAndValue cav;
  1245. cav["caccname"] = strAccName;
  1246. cav["cpassword"] = strAccPassword;
  1247. cav["crealname"] = strAccRealName;
  1248. cav["dregdate"] = pAccountCon->GetDate();
  1249. S3PRow rowCav( account.GetTableName(), &cav, pAccountCon );
  1250. if ( account.Add( &rowCav ) <= 0 )
  1251. {
  1252. iRet = 0;
  1253. }
  1254. else
  1255. {
  1256. iRet = 1;
  1257. }
  1258. }
  1259. else
  1260. {
  1261. iRet = -7;
  1262. }
  1263. }
  1264. else
  1265. {
  1266. iRet = -6;
  1267. }
  1268. pAccountCon->Close();
  1269. }
  1270. return iRet;
  1271. }