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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > ICQ/即时通讯 > 查看源码
RecvData.cpp
资源名称：src.zip　[点击查看]
上传用户：guangzhiyw
上传日期：2007-01-09
资源大小：495k
文件大小：34k
源码类别：

ICQ/即时通讯

开发平台：

Visual C++

RecvData.cpp：源码内容
  1. ////////////////////////////////////////////////////////////////
  2. //   //
  3. // 处理客户请求的工人线程函数   //
  4. //   //
  5. //   //
  6. ////////////////////////////////////////////////////////////////
  8. #include "stdafx.h"
  9. #include "common.h"
  10. #include "msg.h"
  11. #include "Server.h"
  12. #include "MainFrm.h"
  13. #include "ServerView.h"
  16. UINT ProcessRecvData(LPVOID param)
  17. {
  18. CData* pData=(CData*)param;
  19. UINT index=pData->index;
  21. CServerApp * pApp=(CServerApp*)AfxGetApp();
  22. CMainFrame* pMainWnd=(CMainFrame*)(pApp->m_pMainWnd);
  23. CServerView *pView=(CServerView*)(pMainWnd->GetActiveView());
  25. UserOnline * pUsers=pApp->m_pUsers;
  26. CDatabase * pDatabase=&pApp->m_Database;
  27. CServerSocket * pSocket=&pApp->m_Socket;
  29. ::InterlockedIncrement((long*)&pApp->m_nRecvMsg);
  31. switch(index)
  32. {
  33. case ONHIDE:
  34. {
  35. int pIndex=pData->MyId-UserIdRadix;
  36. if(pIndex>=0&&pIndex<pApp->m_nTotalUserNumber)  // true means it esxit
  37. {
  38. if(pUsers[pIndex].State==0||pUsers[pIndex].State==1)
  39. {
  40. CData mc;
  41. mc.index=ONHIDE_OK;
  42. mc.MyId=pData->MyId;
  43. mc.tarIP=pData->tarIP;
  44. mc.nPort=pData->nPort;
  45. mc.wIndex=pData->wIndex;
  46. if(!pSocket->SendData(&mc))break;
  48. if(pUsers[pIndex].State==0)
  49. {
  50. //找出我的朋友
  51. CRecordset recordset(pDatabase);
  52. CString mysql;
  53. mysql.Format("select FriendId from Friends where MyId=%d",pUsers[pIndex].Id);
  54. recordset.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  55. CDBVariant value;
  56. CArray<DWORD,DWORD>pFriendId;
  57. while(!recordset.IsEOF())
  58. {
  59. recordset.GetFieldValue(short(0),value);
  60. pFriendId.Add(value.m_lVal);
  61. recordset.MoveNext();
  62. }
  63. recordset.Close();
  65. // 发送好友列表给用户
  66. CMsg2 msg;
  67. msg.index=ALL_FRIEND_ID;
  68. msg.wIndex=pData->wIndex;
  69. msg.tarIP=pData->tarIP;
  70. msg.nPort=pData->nPort;
  71. msg.MyId=pData->MyId;
  72. msg.aFriendId.Append(pFriendId);
  73. if(!pSocket->SendData(&msg))break;
  75. // 发送在线好友给用户
  76. CMsgOnlineFriend msg1;
  77. msg1.index=ONLINE_FRIEND;
  78. msg1.wIndex=pData->wIndex;
  79. msg1.tarIP=pData->tarIP;
  80. msg1.nPort=pData->nPort;
  81. msg1.MyId=pData->MyId;
  82. for(int i=0;i<pFriendId.GetSize();i++)
  83. {
  84. int pi=pFriendId.GetAt(i)-UserIdRadix;
  85. if(pUsers[pi].State)
  86. {
  87. msg1.aFriendId.Add(pUsers[pi].Id);
  88. msg1.aFriendIP.Add(pUsers[pi].IP);
  89. msg1.aFriendPort.Add(pUsers[pi].Port);
  90. msg1.aFriendState.Add(pUsers[pi].State);
  91. }
  92. }
  93. Sleep(500);
  94. if(!pSocket->SendData(&msg1))break;
  96. //发送离线广播消息
  97. mysql.Format("select broadcast.SendTime,broadcast.SenderId,broadcast.msg,offbroadcast.num from broadcast,offbroadcast where offbroadcast.msgid=broadcast.msgid and offbroadcast.RecvId=%d",pData->MyId);
  98. CRecordset rs(pDatabase);
  99. rs.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  100. CMsg1 msg3;
  101. CDBVariant s1;
  102. msg3.tarIP=pData->tarIP;
  103. msg3.nPort=pData->nPort;
  104. msg3.index=SYSTEM_BROADCAST;
  105. msg3.wIndex=pData->wIndex;
  106. msg3.FriendId=pData->MyId;
  108. while(!rs.IsEOF())
  109. {
  110. rs.GetFieldValue(short(0),s1);
  111. msg3.Time=s1.m_lVal;
  112. rs.GetFieldValue(1,s1);
  113. msg3.MyId=s1.m_lVal;
  114. rs.GetFieldValue(2,msg3.Msg);
  115. rs.GetFieldValue(3,s1);
  117. int inum=0;
  118. inum=s1.m_lVal;
  119. Sleep(500);
  120. if(pSocket->SendData(&msg3))
  121. {
  122. CString sql1;
  123. sql1.Format("delete from offbroadcast where num=%d",inum);
  124. pDatabase->ExecuteSQL(sql1);
  125. }
  126. else
  127. {
  128. rs.Close();
  129. goto proc_end;
  130. }
  131. rs.MoveNext();
  132. }
  133. rs.Close();
  135. //发送离线消息
  136. mysql.Format("select * from offmsg where RecvId=%d",pData->MyId);
  137. rs.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  139. CMsg1 offmsg3;
  140. CDBVariant dbMsgId,dbSenderId,dbRecvId,dbRecvTime,dbmIndex;
  141. offmsg3.tarIP=pData->tarIP;
  142. offmsg3.nPort=pData->nPort;
  143. offmsg3.FriendId=pData->MyId;
  144. offmsg3.wIndex=pData->wIndex;
  146. while(!rs.IsEOF())
  147. {
  148. rs.GetFieldValue("MsgId",dbMsgId);
  149. rs.GetFieldValue("SenderId",dbSenderId);
  150. rs.GetFieldValue("RecvId",dbRecvId);
  151. rs.GetFieldValue("RecvTime",dbRecvTime);
  152. rs.GetFieldValue("mIndex",dbmIndex);
  153. rs.GetFieldValue("Msg",offmsg3.Msg);
  154. offmsg3.MyId=dbSenderId.m_lVal;
  155. offmsg3.Time=dbRecvTime.m_lVal;
  156. offmsg3.index=dbmIndex.m_chVal;
  158. int inum=0;
  159. inum=dbMsgId.m_lVal;
  160. Sleep(500);
  161. if(pSocket->SendData(&offmsg3))
  162. {
  163. CString sql1;
  164. sql1.Format("delete from offmsg where MsgID=%d",inum);
  165. pDatabase->ExecuteSQL(sql1);
  166. }
  167. else
  168. {
  169. rs.Close();
  170. goto proc_end;
  171. }
  172. rs.MoveNext();
  173. }
  174. rs.Close();
  176. pUsers[pIndex].IP=pData->tarIP;
  177. pUsers[pIndex].Port=pData->nPort;
  178. ::InterlockedIncrement((LPLONG)&pApp->m_nNumberOnline);
  179. }
  181. pUsers[pIndex].State=2;
  183. //找出把我当为好友的人，给其中在线或隐身的人发送我的隐身消息
  184. CRecordset recordset(pDatabase);
  185. CString mysql;
  186. mysql.Format("select MyId from Friends where FriendId=%d",pUsers[pIndex].Id);
  187. recordset.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  188. CDBVariant value;
  189. CNoticeMsg msg;
  190. msg.index=SOMEONE_ONHIDE;
  191. msg.MyId=pData->MyId;
  192. msg.IP=pData->tarIP;
  193. msg.Port=pData->nPort;
  194. while(!recordset.IsEOF())
  195. {
  196. recordset.GetFieldValue(short(0),value);
  197. int pi=value.m_lVal-UserIdRadix;
  198. if(pUsers[pi].State)
  199. {
  200. msg.tarIP=pUsers[pi].IP;
  201. msg.nPort=pUsers[pi].Port;
  202. pSocket->SendData(&msg);
  203. }
  204. recordset.MoveNext();
  205. }
  206. recordset.Close();
  207. }
  208. CString str;
  209. in_addr tIP;
  210. tIP.S_un.S_addr=pData->tarIP;
  211. str.Format("ID: %d 隐身登陆,IP: %s,Port: %d",pData->MyId,inet_ntoa(tIP),pData->nPort);
  212. #ifdef _DEBUG
  213. pView->ShowMessage(str);
  214. #endif
  215. }
  216. else
  217. {
  218. CString str;
  219. str.Format("ID: %d A Invalid ID",pData->MyId);
  220. #ifdef _DEBUG
  221. pView->ShowMessage(str);
  222. #endif
  223. }
  224. break;
  225. }
  226. case ONLINE:
  227. {
  228. int pIndex=pData->MyId-UserIdRadix;
  229. if(pIndex>=0&&pIndex<pApp->m_nTotalUserNumber)  // true means it esxit
  230. {
  231. if(pUsers[pIndex].State==0||pUsers[pIndex].State==2)
  232. {
  233. CData mc;
  234. mc.index=ONLINE_OK;
  235. mc.wIndex=pData->wIndex;
  236. mc.MyId=pData->MyId;
  237. mc.tarIP=pData->tarIP;
  238. mc.nPort=pData->nPort;
  239. if(!pSocket->SendData(&mc))break;
  241. if(pUsers[pIndex].State==0)
  242. {
  243. CRecordset recordset(pDatabase);
  244. CString mysql;
  245. mysql.Format("select FriendId from Friends where MyId=%d",pUsers[pIndex].Id);
  246. recordset.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  247. CDBVariant value;
  248. CArray<DWORD,DWORD>pFriendId;
  249. while(!recordset.IsEOF())
  250. {
  251. recordset.GetFieldValue(short(0),value);
  252. pFriendId.Add(value.m_lVal);
  253. recordset.MoveNext();
  254. }
  255. recordset.Close();
  257. // 发送好友列表给用户
  258. CMsg2 msg;
  259. msg.index=ALL_FRIEND_ID;
  260. msg.wIndex=pData->wIndex;
  261. msg.tarIP=pData->tarIP;
  262. msg.nPort=pData->nPort;
  263. msg.MyId=pData->MyId;
  264. msg.aFriendId.Append(pFriendId);
  265. if(!pSocket->SendData(&msg))break;
  267. // 发送在线好友给用户
  268. CMsgOnlineFriend msg1;
  269. msg1.index=ONLINE_FRIEND;
  270. msg1.wIndex=pData->wIndex;
  271. msg1.tarIP=pData->tarIP;
  272. msg1.nPort=pData->nPort;
  273. msg1.MyId=pData->MyId;
  274. for(int i=0;i<pFriendId.GetSize();i++)
  275. {
  276. int pi=pFriendId.GetAt(i)-UserIdRadix;
  277. if(pUsers[pi].State)
  278. {
  279. msg1.aFriendId.Add(pUsers[pi].Id);
  280. msg1.aFriendIP.Add(pUsers[pi].IP);
  281. msg1.aFriendPort.Add(pUsers[pi].Port);
  282. msg1.aFriendState.Add(pUsers[pi].State);
  283. }
  284. }
  285. Sleep(500);
  286. if(!pSocket->SendData(&msg1))break;
  288. //offline broadcast
  289. mysql.Format("select broadcast.SendTime,broadcast.SenderId,broadcast.msg,offbroadcast.num from broadcast,offbroadcast where offbroadcast.msgid=broadcast.msgid and offbroadcast.RecvId=%d",pData->MyId);
  290. CRecordset rs(pDatabase);
  291. rs.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  293. CMsg1 msg3;
  294. CDBVariant s1;
  295. msg3.wIndex=pData->wIndex;
  296. msg3.tarIP=pData->tarIP;
  297. msg3.nPort=pData->nPort;
  298. msg3.index=SYSTEM_BROADCAST;
  299. msg3.FriendId=pData->MyId;
  301. while(!rs.IsEOF())
  302. {
  303. rs.GetFieldValue(short(0),s1);
  304. msg3.Time=s1.m_lVal;
  305. rs.GetFieldValue(1,s1);
  306. msg3.MyId=s1.m_lVal;
  307. rs.GetFieldValue(2,msg3.Msg);
  308. rs.GetFieldValue(3,s1);
  310. int inum=0;
  311. inum=s1.m_lVal;
  312. Sleep(500);
  313. if(pSocket->SendData(&msg3))
  314. {
  315. CString sql1;
  316. sql1.Format("delete from offbroadcast where num=%d",inum);
  317. pDatabase->ExecuteSQL(sql1);
  318. }
  319. else
  320. {
  321. rs.Close();
  322. goto proc_end;
  323. }
  324. rs.MoveNext();
  325. }
  326. rs.Close();
  328. //offline msg
  329. mysql.Format("select * from offmsg where RecvId=%d",pData->MyId);
  330. rs.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  332. CMsg1 offmsg3;
  333. CDBVariant dbMsgId,dbSenderId,dbRecvId,dbRecvTime,dbmIndex;
  334. offmsg3.tarIP=pData->tarIP;
  335. offmsg3.nPort=pData->nPort;
  336. offmsg3.FriendId=pData->MyId;
  337. offmsg3.wIndex=pData->wIndex;
  339. while(!rs.IsEOF())
  340. {
  341. rs.GetFieldValue("MsgId",dbMsgId);
  342. rs.GetFieldValue("SenderId",dbSenderId);
  343. rs.GetFieldValue("RecvId",dbRecvId);
  344. rs.GetFieldValue("RecvTime",dbRecvTime);
  345. rs.GetFieldValue("mIndex",dbmIndex);
  346. rs.GetFieldValue("Msg",offmsg3.Msg);
  347. offmsg3.MyId=dbSenderId.m_lVal;
  348. offmsg3.Time=dbRecvTime.m_lVal;
  349. offmsg3.index=dbmIndex.m_chVal;
  351. int inum=0;
  352. inum=dbMsgId.m_lVal;
  353. Sleep(500);
  354. if(pSocket->SendData(&offmsg3))
  355. {
  356. CString sql1;
  357. sql1.Format("delete from offmsg where MsgID=%d",inum);
  358. pDatabase->ExecuteSQL(sql1);
  359. }
  360. else
  361. {
  362. rs.Close();
  363. goto proc_end;
  364. }
  365. rs.MoveNext();
  366. }
  367. rs.Close();
  369. ::InterlockedIncrement((LPLONG)&pApp->m_nNumberOnline);
  370. }
  371. pUsers[pIndex].State=1;
  372. pUsers[pIndex].IP=pData->tarIP;
  373. pUsers[pIndex].Port=pData->nPort;
  375. //找出把我当作好友的人,并发ONLINE消息
  376. CRecordset recordset(pDatabase);
  377. CString mysql;
  378. mysql.Format("select MyId from Friends where FriendId=%d",pUsers[pIndex].Id);
  379. recordset.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  380.     CDBVariant value;
  381. CNoticeMsg msg;
  382. msg.index=SOMEONE_ONLINE;
  383. msg.MyId=pData->MyId;
  384. msg.IP=pData->tarIP;
  385. msg.Port=pData->nPort;
  386. while(!recordset.IsEOF())
  387. {
  388. recordset.GetFieldValue(short(0),value);
  389. int pi=value.m_lVal-UserIdRadix;
  390. if(pUsers[pi].State)
  391. {
  392. msg.tarIP=pUsers[pi].IP;
  393. msg.nPort=pUsers[pi].Port;
  394. pSocket->SendData(&msg);
  395. }
  396. recordset.MoveNext();
  397. }
  398. recordset.Close();
  399. }
  400. CString str;
  401. in_addr tIP;
  402. tIP.S_un.S_addr=pData->tarIP;
  403. str.Format("ID: %d 上线(正常登陆),IP: %s,Port: %d",pData->MyId,inet_ntoa(tIP),pData->nPort);
  404. #ifdef _DEBUG
  405. pView->ShowMessage(str);
  406. #endif
  407. }
  408. else
  409. {
  410. CString str;
  411. str.Format("ID: %d A Invalid ID",pData->MyId);
  412. #ifdef _DEBUG
  413. pView->ShowMessage(str);
  414. #endif
  415. }
  416. break;
  417. }
  418. case OFFLINE:
  419. {
  420. int pIndex=pData->MyId-UserIdRadix;
  421. if(pIndex>=0&&pIndex<pApp->m_nTotalUserNumber)  // true means it esxit
  422. {
  423. if(pUsers[pIndex].State)
  424. {
  425. pUsers[pIndex].State=0;
  426. ::InterlockedDecrement((LPLONG)&pApp->m_nNumberOnline);
  427. //找出把我当作好友的人,并发OFFLINE消息
  428. CRecordset recordset(pDatabase);
  429. CString mysql;
  430. mysql.Format("select MyId from Friends where FriendId=%d",pUsers[pIndex].Id);
  431. recordset.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  432. CDBVariant value;
  433. CData msg;
  434. msg.index=SOMEONE_OFFLINE;
  435. msg.MyId=pData->MyId;
  436. while(!recordset.IsEOF())
  437. {
  438. recordset.GetFieldValue(short(0),value);
  439. int pi=value.m_lVal-UserIdRadix;
  440. if(pUsers[pi].State)
  441. {
  442. msg.tarIP=pUsers[pi].IP;
  443. msg.nPort=pUsers[pi].Port;
  444. pSocket->SendData(&msg);
  445. }
  446. recordset.MoveNext();
  447. }
  448. recordset.Close();
  449. }
  450. CString str;
  451. str.Format("ID: %d 下线",pData->MyId);
  452. #ifdef _DEBUG
  453. pView->ShowMessage(str);
  454. #endif
  455. }
  456. else
  457. {
  458. CString str;
  459. str.Format("ID: %d A Invalid ID",pData->MyId);
  460. #ifdef _DEBUG
  461. pView->ShowMessage(str);
  462. #endif
  463. }
  464. break;
  465. }
  466. case SEND_MSG_TO_FRIEND:
  467. case REFUSE_AS_FRIEND:
  468. case ACCEPT_AS_FRIEND:
  469. case FRIEND_IDENTITY_VALIDATE:
  470. {
  471. //  用户给朋友发的离线消息 
  472. CMsg1 msg;
  473. CopyDataBuf(&msg,pData);
  474. if(!msg.LoadFromBuf())
  475. {
  476. #ifdef _DEBUG
  477. pView->ShowMessage("msg.LoadFromBuf error!");
  478. #endif
  479. break;
  480. }
  482. int pIndex=msg.FriendId-UserIdRadix;
  483. int mIndex=msg.MyId-UserIdRadix;
  484. if(pIndex>=0&&pIndex<pApp->m_nTotalUserNumber&&mIndex>=0&&mIndex<pApp->m_nTotalUserNumber) //It's fit user
  485. {
  486. if(index==ACCEPT_AS_FRIEND)
  487. {
  488. CRecordset rs(pDatabase);
  489. CString sql1;
  490. sql1.Format("select friendid from friends where myid=%d and friendid=%d",msg.FriendId,msg.MyId);
  491. rs.Open(AFX_DB_USE_DEFAULT_TYPE,sql1);
  492. int count=rs.GetRecordCount();
  493. rs.Close();
  494. if(count==0)
  495. {
  496. CString mysql;
  497. mysql.Format("insert into Friends(Myid,FriendId) values(%d,%d)",msg.FriendId,msg.MyId);
  498. pDatabase->ExecuteSQL(mysql);
  499. }
  500. else break;
  501. }
  503. // Is frined online?
  504. BOOL SendOK=FALSE;
  505. if(pUsers[pIndex].State)
  506. {
  507. msg.tarIP=pUsers[pIndex].IP;
  508. msg.nPort=pUsers[pIndex].Port;
  509. if(pSocket->SendData(&msg))
  510. SendOK=TRUE;
  511. }
  512. // Save it to database
  513. if(!SendOK)
  514. {
  515. CString mysql;
  516. CTime t1=CTime::GetCurrentTime();
  518. mysql.Format("insert into offmsg(SenderId,RecvId,mIndex,RecvTime,Msg) values(%d,%d,%d,%d,'%s')",
  519. msg.MyId,msg.FriendId,msg.index,t1,msg.Msg);
  520. try
  521. {
  522. pDatabase->ExecuteSQL(mysql);
  523. }
  524. catch(CDBException e)
  525. {
  526. #ifdef _DEBUG
  527. pView->ShowMessage(e.m_strError);
  528. #endif
  529. }
  530. }
  531. CString str;
  532. str.Format("ID: %d To ID: %d 用户给朋友发的离线消息",msg.MyId,msg.FriendId);
  533. #ifdef _DEBUG
  534. pView->ShowMessage(str);
  535. #endif
  536. }
  537. else
  538. {
  539. #ifdef _DEBUG
  540. pView->ShowMessage("A Invalid Id");
  541. #endif
  542. }
  544. break;
  545. }
  546. case MULTI_SEND_MSG:
  547. {
  548. //  用户给多个朋友发的离线消息 
  549. CMsg2 msg;
  550. CopyDataBuf(&msg,pData);
  551. if(!msg.LoadFromBuf())
  552. {
  553. TRACE0("msg.LoadFromBuf error!n");
  554. break;
  555. }
  557. int mIndex=msg.MyId-UserIdRadix;
  558. if(mIndex>=0&&mIndex<pApp->m_nTotalUserNumber) //It's fit user
  559. {
  560. for(int i=0;i<msg.aFriendId.GetSize();i++)
  561. {
  562. int pIndex=msg.aFriendId.GetAt(i)-UserIdRadix;
  563. if(pIndex<0||pIndex>=pApp->m_nTotalUserNumber)continue;
  565. // Is This frined online?
  566. BOOL SendOK=FALSE;
  568. if(pUsers[pIndex].State)
  569. {
  570. CMsg1 msg1;
  571. msg1.index=SEND_MSG_TO_FRIEND;
  572. msg1.Msg=msg.Msg;
  573. msg1.MyId=msg.MyId;
  574. msg1.Time=msg.Time;
  575. msg1.FriendId=msg.aFriendId.GetAt(i);
  576. msg1.tarIP=pUsers[pIndex].IP;
  577. msg1.nPort=pUsers[pIndex].Port;
  579. if(pSocket->SendData(&msg1))
  580. SendOK=TRUE;
  581. }
  582. if(!SendOK)
  583. {
  584. // Save it to database
  585. CString mysql;
  586. CTime t1=CTime::GetCurrentTime();
  587. mysql.Format("insert into offmsg(SenderId,RecvId,mIndex,RecvTime,Msg) values(%d,%d,%d,%d,'%s')",
  588. msg.MyId,msg.aFriendId.GetAt(i),SEND_MSG_TO_FRIEND,t1,msg.Msg);
  589. try
  590. {
  591. pDatabase->ExecuteSQL(mysql);
  592. }
  593. catch(CDBException e)
  594. {
  595. #ifdef _DEBUG
  596. pView->ShowMessage(e.m_strError);
  597. #endif
  598. }
  599. }
  600. }
  601. CString str;
  602. str.Format("ID: %d 用户给多个朋友发的离线消息",msg.MyId);
  603. #ifdef _DEBUG
  604. pView->ShowMessage(str);
  605. #endif
  606. }
  608. break;
  609. }
  610. case SEND_BROADCAST:
  611. {
  612. //  发送广播消息
  613. CMsg4 msg;
  614. CopyDataBuf(&msg,pData);
  615. if(!msg.LoadFromBuf())
  616. {
  617. TRACE0("msg.LoadFromBuf error!n");
  618. break;
  619. }
  621. int mIndex=msg.MyId-UserIdRadix;
  622. if(mIndex>=0&&mIndex<pApp->m_nTotalUserNumber)
  623. {
  624. if(msg.BroadcastPwd==pApp->m_strBroadcastPwd)
  625. {
  626. CString mysql;
  627. CTime t1=CTime::GetCurrentTime();
  628. mysql.Format("insert into broadcast(SenderId,SendTime,Msg) values(%d,%d,'%s')",msg.MyId,t1,msg.Msg);
  629. pDatabase->ExecuteSQL(mysql);
  631. int CurMsgId=0;
  632. CRecordset rs(pDatabase);
  633. rs.Open(AFX_DB_USE_DEFAULT_TYPE,"select last(MsgId) from broadcast");
  634. CDBVariant v1;
  635. rs.GetFieldValue(short(0),v1);
  636. rs.Close();
  637. CurMsgId=v1.m_lVal;
  639. // Check for everyone ,send broadcast
  640. CMsg1 msg1;
  641. msg1.index=SYSTEM_BROADCAST;
  642. msg1.MyId=msg.MyId;
  643. msg1.Msg=msg.Msg;
  644. msg1.Time=t1;
  645. for(int i=0;i<pApp->m_nTotalUserNumber;i++)
  646. {
  647. if(pUsers[i].Id==0||pUsers[i].Id==msg.MyId)
  648. continue;
  649. BOOL SendOK=FALSE;
  650. if(pUsers[i].State)
  651. {
  652. msg1.tarIP=pUsers[i].IP;
  653. msg1.nPort=pUsers[i].Port;
  654. if(pSocket->SendData(&msg1))
  655. SendOK=TRUE;
  656. }
  657. if(!SendOK)
  658. {
  659. //Save it to Database
  660. CString mysql;
  661. mysql.Format("insert into OffBroadcast(RecvId,MsgId) values(%d,%d)",i+1+UserIdRadix,CurMsgId);
  662. pDatabase->ExecuteSQL(mysql);
  663. }
  664. }
  665. CString str;
  666. str.Format("ID: %d 发送广播消息",msg.MyId);
  667. #ifdef _DEBUG
  668. pView->ShowMessage(str);
  669. #endif
  670. }
  671. }
  673. break;
  674. }
  675. case FRIEND_DETAIL:
  676. {
  677. // 好友详细信息
  678. CMsg1 msg;
  679. CopyDataBuf(&msg,pData);
  680. if(!msg.LoadFromBuf())
  681. {
  682. TRACE0("msg.LoadFromBuf error!n");
  683. break;
  684. }
  685. TRACE1("Request Friend Detail %dn",msg.FriendId);
  686. int mIndex=msg.FriendId-UserIdRadix;
  687. if(mIndex>=0&&mIndex<pApp->m_nTotalUserNumber&&pUsers[mIndex].Id)
  688. {
  689. CMsgPerson msg1;
  690. msg1.index=RE_FRIEND_DETAIL;
  691. msg1.wIndex=msg.wIndex;
  692. msg1.tarIP=msg.tarIP;
  693. msg1.nPort=msg.nPort;
  694. msg1.MyId=pUsers[mIndex].Id;
  695. msg1.Name=pUsers[mIndex].Name;
  696. msg1.PhotoId=pUsers[mIndex].PhotoId;
  697. msg1.Department=pUsers[mIndex].Department;
  699. CRecordset recordset(pDatabase);
  700. CString mysql;
  701. mysql.Format("select Sex,Age,Email,Homepage,Address,Phone,fax,description,canbeadd from Users where Id=%d",msg.FriendId);
  702. recordset.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  703. if(recordset.GetRecordCount()==0)break;
  704. CDBVariant s1;
  705. recordset.GetFieldValue(short(0),s1);
  706. msg1.Sex=s1.m_chVal;
  707. recordset.GetFieldValue(1,msg1.Age);
  708. recordset.GetFieldValue(2,msg1.Email);
  709. recordset.GetFieldValue(3,msg1.Homepage);
  710. recordset.GetFieldValue(4,msg1.Address);
  711. recordset.GetFieldValue(5,msg1.Phone);
  712. recordset.GetFieldValue(6,msg1.Fax);
  713. recordset.GetFieldValue(7,msg1.Description);
  714. recordset.GetFieldValue(8,s1);
  715. msg1.Canbeadd=s1.m_chVal;
  717. recordset.Close();
  719. if(pSocket->SendData(&msg1))
  720. {
  721. CString str;
  722. str.Format("ID: %d FriendID: %d 好友详细信息",msg.MyId,msg.FriendId);
  723. #ifdef _DEBUG
  724. pView->ShowMessage(str);
  725. #endif
  726. }
  727. }
  729. break;
  730. }
  731. case ADD_AS_FRIEND:
  732. {
  733. // 加为好友请求
  734. CMsg1 msg;
  735. CopyDataBuf(&msg,pData);
  736. if(!msg.LoadFromBuf())
  737. {
  738. TRACE0("msg.LoadFromBuf error!n");
  739. break;
  740. }
  742. int MyIndex=msg.MyId-UserIdRadix;
  743. int FriendIndex=msg.FriendId-UserIdRadix;
  745. //if it is not valid user.
  746. if(MyIndex<0||MyIndex>=pApp->m_nTotalUserNumber||FriendIndex<0||FriendIndex>=pApp->m_nTotalUserNumber)
  747. break;
  748. if(!pUsers[MyIndex].Id||!pUsers[FriendIndex].Id)break;
  750. // find the friendid user
  751. CMsg3 msg3;
  752. msg3.tarIP=msg.tarIP;
  753. msg3.nPort=msg.nPort;
  754. msg3.index=RE_ADD_AS_FRIEND;
  755. msg3.wIndex=msg.wIndex;
  756. if(pUsers[FriendIndex].CanbeAdd!=1)
  757. {
  758. // 拒绝任何人加入 or 需要身份验证
  759. msg3.Value=pUsers[FriendIndex].CanbeAdd;
  760. if(!pSocket->SendData(&msg3))
  761. break;
  762. }
  763. else
  764. {
  765. // add it be my friend
  766. CRecordset rs(pDatabase);
  767. CString sql1;
  768. sql1.Format("select friendid from friends where myid=%d and friendid=%d",msg.MyId,msg.FriendId);
  769. rs.Open(AFX_DB_USE_DEFAULT_TYPE,sql1);
  770. int count=rs.GetRecordCount();
  771. rs.Close();
  772. if(msg.MyId!=msg.FriendId&&count==0)
  773. {
  774. CString mysql;
  775. mysql.Format("insert into Friends(Myid,FriendId) values(%d,%d)",msg.MyId,msg.FriendId);
  776. pDatabase->ExecuteSQL(mysql);
  777. msg3.Value=1;
  778. //成功加入
  779. pSocket->SendData(&msg3);
  781. //通知被加入的人
  782. CMsg1 msg4;
  783. msg4.tarIP=pUsers[FriendIndex].IP;
  784. msg4.nPort=pUsers[FriendIndex].Port;
  785. msg4.index=BE_ADDED_AS_FRIEND;
  786. msg4.MyId=msg.MyId;
  787. msg4.FriendId=msg.FriendId;
  788. msg4.Msg.Format("%d 把你加为好友",msg.MyId);
  789. msg4.Time=CTime::GetCurrentTime();
  790. if(pUsers[FriendIndex].State&&pSocket->SendData(&msg4))
  791. {
  792. Sleep(500);
  793. CNoticeMsg msg5;
  794. if(pUsers[FriendIndex].State==1)
  795. msg5.index=SOMEONE_ONLINE;
  796. else
  797. msg5.index=SOMEONE_ONHIDE;
  798. msg5.MyId=pUsers[FriendIndex].Id;
  799. msg5.IP=pUsers[FriendIndex].IP;
  800. msg5.Port=pUsers[FriendIndex].Port;
  801. msg5.tarIP=pData->tarIP;
  802. msg5.nPort=pData->nPort;
  803. pSocket->SendData(&msg5);
  804. }
  805. else
  806. {
  807. CString mysql;
  809. mysql.Format("insert into offmsg(SenderId,RecvId,mIndex,RecvTime,Msg) values(%d,%d,%d,%d,'%s')",
  810. msg4.MyId,msg4.FriendId,msg4.index,msg4.Time,msg4.Msg);
  811. try
  812. {
  813. pDatabase->ExecuteSQL(mysql);
  814. }
  815. catch(CDBException e)
  816. {
  817. #ifdef _DEBUG
  818. pView->ShowMessage(e.m_strError);
  819. #endif
  820. }
  821. }
  822. }
  823. else
  824. {
  825. // this friend is already in your friends
  826. msg3.Value=3;
  827. if(!pSocket->SendData(&msg3))
  828. goto proc_end;
  829. }
  830. }
  832. CString str;
  833. str.Format("ID: %d want add ID: %d as friend!",msg.MyId,msg.FriendId);
  834. #ifdef _DEBUG
  835. pView->ShowMessage(str);
  836. #endif
  837. break;
  838. }
  839. case APPLY_SHOW_ONLINE:
  840. {
  841. //查看在线的人
  842. CMsg3 msg;
  843. CopyDataBuf(&msg,pData);
  844. if(!msg.LoadFromBuf())break;
  846. int mIndex=msg.MyId-UserIdRadix;
  847. if(mIndex<0||mIndex>=pApp->m_nTotalUserNumber||!pUsers[mIndex].Id)break;
  849. int offsize=msg.Value;
  850. int count=0;
  851. int mOff=offsize*PersonNumEveryTime;
  852. if(mOff>=pApp->m_nTotalUserNumber) break;
  853. for(int i=0;i<pApp->m_nTotalUserNumber&&count<mOff;i++)
  854. if(pUsers[i].State)count++;
  855. if(count==mOff)
  856. {
  857. CShowOnlinePeople msg1;
  858. msg1.tarIP=msg.tarIP;
  859. msg1.nPort=msg.nPort;
  860. msg1.index=RECV_SHOW_ONLINE;
  861. msg1.wIndex=msg.wIndex;
  862. msg1.MyId=msg.MyId;
  863. for(int j=0;i<pApp->m_nTotalUserNumber&&j<PersonNumEveryTime;i++)
  864. {
  865. if(pUsers[i].State)
  866. {
  867. msg1.aPhotoId.Add(pUsers[i].PhotoId);
  868. msg1.aId.Add(pUsers[i].Id);
  869. msg1.aName.Add(pUsers[i].Name);
  870. msg1.aDepartment.Add(pUsers[i].Department);
  871. j++;
  872. }
  873. }
  874. if(msg1.aId.GetSize()>0)
  875. pSocket->SendData(&msg1);
  876. }
  878. #ifdef _DEBUG
  879. pView->ShowMessage("查看在线的人");
  880. #endif
  881. break;
  882. }
  883. case FIND_FRIEND_BY_ID:
  884. {
  885. //用号码查找朋友
  886. CMsg1 msg;
  887. CopyDataBuf(&msg,pData);
  888. if(!msg.LoadFromBuf())break;
  890. int mIndex=msg.MyId-UserIdRadix;
  891. int fIndex=msg.FriendId-UserIdRadix;
  892. if(mIndex>=0&&mIndex<pApp->m_nTotalUserNumber&&fIndex>=0&&fIndex<pApp->m_nTotalUserNumber&&pUsers[fIndex].Id&&pUsers[mIndex].Id)  //fint it
  893. {
  894. //return this peron's detail
  895. CMsgPerson msg1;
  896. msg1.index=FOUND_FRIEND_BY_ID;
  897. msg1.wIndex=msg.wIndex;
  898. msg1.tarIP=msg.tarIP;
  899. msg1.nPort=msg.nPort;
  900. msg1.MyId=pUsers[fIndex].Id;
  901. msg1.Name=pUsers[fIndex].Name;
  902. msg1.PhotoId=pUsers[fIndex].PhotoId;
  903. msg1.Department=pUsers[fIndex].Department;
  905. CRecordset recordset(pDatabase);
  906. CString mysql;
  907. mysql.Format("select Sex,Age,Email,Homepage,Address,Phone,fax,description,canbeadd from Users where Id=%d",msg.FriendId);
  908. recordset.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  909. if(recordset.GetRecordCount()==0)break;
  910. CDBVariant s1;
  911. recordset.GetFieldValue(short(0),s1);
  912. msg1.Sex=s1.m_chVal;
  913. recordset.GetFieldValue(1,msg1.Age);
  914. recordset.GetFieldValue(2,msg1.Email);
  915. recordset.GetFieldValue(3,msg1.Homepage);
  916. recordset.GetFieldValue(4,msg1.Address);
  917. recordset.GetFieldValue(5,msg1.Phone);
  918. recordset.GetFieldValue(6,msg1.Fax);
  919. recordset.GetFieldValue(7,msg1.Description);
  920. recordset.GetFieldValue(8,s1);
  921. msg1.Canbeadd=s1.m_chVal;
  923. recordset.Close();
  924. pSocket->SendData(&msg1);
  925. }
  926. else
  927. {
  928. //return not found!
  929. CData msg1;
  930. msg1.index=ID_NOT_FOUND_BY_ID;
  931. msg1.wIndex=msg.wIndex;
  932. msg1.tarIP=msg.tarIP;
  933. msg1.nPort=msg.nPort;
  934. msg1.MyId=msg.MyId;
  935. pSocket->SendData(&msg1);
  936. }
  937. //-----------------------
  938. #ifdef _DEBUG
  939. pView->ShowMessage("用号码查找朋友");
  940. #endif
  941. break;
  942. }
  943. case FIND_FRIEND_BY_NAME:
  944. {
  945. //用姓名查找朋友
  946. CMsg4 msg;
  947. CopyDataBuf(&msg,pData);
  948. if(!msg.LoadFromBuf())break;
  950. int mIndex=msg.MyId-UserIdRadix;
  951. if(mIndex<0||mIndex>=pApp->m_nTotalUserNumber||!pUsers[mIndex].Id)break;
  953. CShowOnlinePeople msg1;
  954. for(int i=0;i<pApp->m_nTotalUserNumber;i++)
  955. {
  956. if(pUsers[i].Name==msg.Msg)
  957. {
  958. msg1.aPhotoId.Add(pUsers[i].PhotoId);
  959. msg1.aId.Add(pUsers[i].Id);
  960. msg1.aName.Add(pUsers[i].Name);
  961. msg1.aDepartment.Add(pUsers[i].Department);
  962. }
  963. }
  964. if(msg1.aId.GetSize()>0)
  965. {
  966. msg1.tarIP=msg.tarIP;
  967. msg1.nPort=msg.nPort;
  968. msg1.MyId=msg.MyId;
  969. msg1.index=FOUND_FRIEND_BY_NAME;
  970. msg1.wIndex=msg.wIndex;
  971. pSocket->SendData(&msg1);
  972. }
  973. else
  974. {
  975. CData msg2;
  976. msg2.tarIP=msg.tarIP;
  977. msg2.nPort=msg.nPort;
  978. msg2.MyId=msg.MyId;
  979. msg2.index=NAME_NOT_FOUND_BY_NAME;
  980. msg2.wIndex=msg.wIndex;
  981. pSocket->SendData(&msg2);
  982. }
  984. #ifdef _DEBUG
  985. pView->ShowMessage("用姓名查找朋友");
  986. #endif
  987. break;
  988. }
  989. case DELETE_A_FRIEND:
  990. {
  991. // 删除一个好友
  992. CMsg1 msg;
  993. CopyDataBuf(&msg,pData);
  994. if(!msg.LoadFromBuf())break;
  996. int MyIndex=msg.MyId-UserIdRadix;
  997. int FriendIndex=msg.FriendId-UserIdRadix;
  999. //if it is not valid user.
  1000. if(MyIndex<0||MyIndex>=pApp->m_nTotalUserNumber||FriendIndex<0||FriendIndex>=pApp->m_nTotalUserNumber)
  1001. break;
  1002. if(!pUsers[MyIndex].Id||!pUsers[FriendIndex].Id)break;
  1004. // delete the friendid user
  1005. CString mysql;
  1006. mysql.Format("delete from friends where myid=%d and friendid=%d",msg.MyId,msg.FriendId);
  1007. pDatabase->ExecuteSQL(mysql);
  1009. CString str;
  1010. str.Format("ID: %d want 删除一个好友ID: %d",msg.MyId,msg.FriendId);
  1011. #ifdef _DEBUG
  1012. pView->ShowMessage(str);
  1013. #endif
  1014. break;
  1015. }
  1016. case DELETE_SELF_IN_FRIEND:
  1017. {
  1018. //选择在某人的好友中删除自己
  1019. CMsg1 msg;
  1020. CopyDataBuf(&msg,pData);
  1021. if(!msg.LoadFromBuf())break;
  1023. int MyIndex=msg.MyId-UserIdRadix;
  1024. int FriendIndex=msg.FriendId-UserIdRadix;
  1026. //if it is not valid user.
  1027. if(MyIndex<0||MyIndex>=pApp->m_nTotalUserNumber||FriendIndex<0||FriendIndex>=pApp->m_nTotalUserNumber)
  1028. break;
  1029. if(!pUsers[MyIndex].Id||!pUsers[FriendIndex].Id)break;
  1031. CString mysql;
  1032. mysql.Format("delete from friends where myid=%d and friendid=%d",msg.FriendId,msg.MyId);
  1033. pDatabase->ExecuteSQL(mysql);
  1035. #ifdef _DEBUG
  1036. pView->ShowMessage("选择在某人的好友中删除自己");
  1037. #endif
  1038. break;
  1039. }
  1040. case CHANGE_PERSONAL_INFO:
  1041. {
  1042. CMsgChangePI msg;
  1043. CopyDataBuf(&msg,pData);
  1044. if(!msg.LoadFromBuf())break;
  1046. int mIndex=msg.MyId-UserIdRadix;
  1047. if(mIndex<0||mIndex>=pApp->m_nTotalUserNumber||!pUsers[mIndex].Id)break;
  1049. if(!msg.Mask)break;
  1051. CString strHead,strWhere,str,Mysql;
  1052. strHead.Format("update users set ");
  1053. strWhere.Format(" where id=%d",msg.MyId);
  1055. if(msg.Mask&CMsgChangePI::NAME)
  1056. str.Format("Name='%s',",msg.Name),strHead+=str;
  1057. if(msg.Mask&CMsgChangePI::SEX)
  1058. str.Format("Sex='%d',",msg.Sex),strHead+=str;
  1059. if(msg.Mask&CMsgChangePI::AGE)
  1060. str.Format("Age='%s',",msg.Age),strHead+=str;
  1061. if(msg.Mask&CMsgChangePI::CANBEADD)
  1062. str.Format("Canbeadd=%d,",msg.Canbeadd),strHead+=str;
  1063. if(msg.Mask&CMsgChangePI::ADDRESS)
  1064. str.Format("Address=%d,",msg.Address),strHead+=str;
  1065. if(msg.Mask&CMsgChangePI::DEPARTMENT)
  1066. str.Format("department='%s',",msg.Department),strHead+=str;
  1067. if(msg.Mask&CMsgChangePI::DESCRIPTION)
  1068. str.Format("Description='%s',",msg.Description),strHead+=str;
  1069. if(msg.Mask&CMsgChangePI::EMAIL)
  1070. str.Format("email='%s',",msg.Email),strHead+=str;
  1071. if(msg.Mask&CMsgChangePI::FAX)
  1072. str.Format("Fax='%s',",msg.Fax),strHead+=str;
  1073. if(msg.Mask&CMsgChangePI::HOMEPAGE)
  1074. str.Format("Homepage='%s',",msg.Homepage),strHead+=str;
  1075. if(msg.Mask&CMsgChangePI::PHONE)
  1076. str.Format("Phone='%s',",msg.Phone),strHead+=str;
  1077. if(msg.Mask&CMsgChangePI::PHOTOID)
  1078. str.Format("Photoid=%d,",msg.PhotoId),strHead+=str;
  1080. if(strHead.GetAt(strHead.GetLength()-1)==',')
  1081. Mysql=strHead.Left(strHead.GetLength()-1);
  1082. else Mysql=strHead;
  1084. Mysql+=strWhere;
  1085. pDatabase->ExecuteSQL(Mysql);
  1087. // change in pUsers array
  1088. if(msg.Mask&CMsgChangePI::NAME)
  1089. pUsers[mIndex].Name=msg.Name;
  1090. if(msg.Mask&CMsgChangePI::CANBEADD)
  1091. pUsers[mIndex].CanbeAdd=msg.Canbeadd;
  1092. if(msg.Mask&CMsgChangePI::DEPARTMENT)
  1093. pUsers[mIndex].Department=msg.Department;
  1094. if(msg.Mask&CMsgChangePI::PHOTOID)
  1095. pUsers[mIndex].PhotoId=msg.PhotoId;
  1097. #ifdef _DEBUG
  1098. pView->ShowMessage("CHANGE_PERSONAL_INFORMATION");
  1099. #endif
  1100. break;
  1101. }
  1102. case CHANGE_PASSWORD:
  1103. {
  1104. CMsgModifyPwd msg;
  1105. CopyDataBuf(&msg,pData);
  1106. if(!msg.LoadFromBuf())break;
  1108. int mIndex=msg.MyId-UserIdRadix;
  1109. if(mIndex>=0&&mIndex<pApp->m_nTotalUserNumber&&pUsers[mIndex].Id)
  1110. {
  1111. CRecordset rs(pDatabase);
  1112. CString mysql;
  1113. mysql.Format("select Password from users where id=%d",msg.MyId);
  1114. rs.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  1115. if(rs.GetRecordCount==0)break;
  1116. CString pwd;
  1117. rs.GetFieldValue(short(0),pwd);
  1118. if(msg.OldPwd==pwd)
  1119. {
  1120. CString sql1;
  1121. sql1.Format("update users set Password=%s where id=%d",msg.NewPwd,msg.MyId);
  1122. pDatabase->ExecuteSQL(sql1);
  1123. }
  1124. }
  1126. CString str;
  1127. str.Format("ID: %d 修改个人信息",msg.MyId);
  1128. #ifdef _DEBUG
  1129. pView->ShowMessage(str);
  1130. #endif
  1131. break;
  1132. }
  1133. case APPLY_ID_LOGIN:
  1134. {
  1135. CMsgPerson msg;
  1136. CopyDataBuf(&msg,pData);
  1137. if(!msg.LoadFromBuf())break;
  1139. CString mysql; 
  1140. int nAppID=0;
  1142. pApp->m_criticalMaxUserId.Lock();
  1143. pApp->m_nTotalUserNumber++;
  1144. pApp->m_nMaxUserId++;
  1145. nAppID=pApp->m_nMaxUserId;
  1146. pApp->m_criticalMaxUserId.Unlock();
  1148. mysql.Format("insert into users(id,photoid,password,name,sex,age,canbeadd,email,homepage,address,phone,fax,department,description) values(%d,%d,'%s','%s',%d,'%s',%d,'%s','%s','%s','%s','%s','%s','%s')",
  1149. nAppID,msg.PhotoId,msg.Password,msg.Name,msg.Sex,msg.Age,msg.Canbeadd,msg.Email,msg.Homepage,msg.Address,msg.Phone,msg.Fax,msg.Department,msg.Description);
  1150. try
  1151. {
  1152. pDatabase->ExecuteSQL(mysql);
  1153. }
  1154. catch(CDBException e)
  1155. {
  1156. AfxMessageBox(e.m_strError);
  1157. }
  1159. CData msg1;
  1160. msg1.index=APPLY_ID_OK;
  1161. msg1.MyId=nAppID;
  1162. msg1.tarIP=msg.tarIP;
  1163. msg1.nPort=msg.nPort;
  1164. pSocket->SendData(&msg1);
  1166. ::InterlockedIncrement((LPLONG)&pApp->m_nNumberOnline);
  1168. pUsers[msg1.MyId-UserIdRadix].Id=msg1.MyId;
  1169. pUsers[msg1.MyId-UserIdRadix].Name=msg.Name;
  1170. pUsers[msg1.MyId-UserIdRadix].CanbeAdd=msg.Canbeadd;
  1171. pUsers[msg1.MyId-UserIdRadix].PhotoId=msg.PhotoId;
  1172. pUsers[msg1.MyId-UserIdRadix].Department=msg.Department;
  1173. pUsers[msg1.MyId-UserIdRadix].IP=msg.tarIP;
  1174. pUsers[msg1.MyId-UserIdRadix].Port=msg.nPort;
  1175. pUsers[msg1.MyId-UserIdRadix].State=1;
  1177. CString str;
  1178. str.Format("用户：%s 申请帐号成功，ID：%d",msg.Name,msg1.MyId);
  1179. #ifdef _DEBUG
  1180. pView->ShowMessage(str);
  1181. #endif
  1183. break;
  1184. }
  1185. case HAVE_ID_LOGIN:
  1186. {
  1187. //使用已有号码进行登陆
  1188. CMsgModifyPwd msg;
  1189. CopyDataBuf(&msg,pData);
  1190. if(!msg.LoadFromBuf())break;
  1192. int mIndex=msg.MyId-UserIdRadix;
  1194. CMsg3 msg1;
  1195. msg1.index=RE_LOGIN_INFO;
  1196. msg1.wIndex=msg.wIndex;
  1197. msg1.MyId=msg.MyId;
  1198. msg1.tarIP=msg.tarIP;
  1199. msg1.nPort=msg.nPort;
  1201. if(mIndex>=0&&mIndex<pApp->m_nTotalUserNumber&&pUsers[mIndex].Id)
  1202. {
  1203. CRecordset rs(pDatabase);
  1204. CString mysql;
  1205. mysql.Format("select Password from users where id=%d",msg.MyId);
  1206. rs.Open(AFX_DB_USE_DEFAULT_TYPE,mysql);
  1207. if(rs.GetRecordCount==0)break;
  1208. CString pwd;
  1209. rs.GetFieldValue(short(0),pwd);
  1211. if(msg.OldPwd!=pwd)
  1212. {
  1213. msg1.Value=1;
  1214. pSocket->SendData(&msg1);
  1215. }
  1216. else
  1217. {
  1218. msg1.Value=2;
  1219. pSocket->SendData(&msg1);
  1220. }
  1221. }
  1222. else
  1223. {
  1224. msg1.Value=0;
  1225. pSocket->SendData(&msg1);
  1226. }
  1228. CString str;
  1229. str.Format("ID: %d 使用已有ID进行登陆!",msg.MyId);
  1230. #ifdef _DEBUG
  1231. pView->ShowMessage(str);
  1232. #endif
  1233. break;
  1234. }
  1235. }
  1236. proc_end:
  1237. if(pData)
  1238. {
  1239. delete pData;
  1240. pData=NULL;
  1241. }
  1243. return 0;
  1244. }