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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 远程控制编程 > 查看源码
Msgman.cpp
资源名称：anywhere.zip　[点击查看]
上传用户：zhenhuadz
上传日期：2007-01-07
资源大小：1511k
文件大小：8k
源码类别：

远程控制编程

开发平台：

Visual C++

Msgman.cpp：源码内容
  1. // Msgman.cpp : implementation file
  2. //
  4. #include "stdafx.h"
  5. #include "anywhere.h"
  6. #include "Msgman.h"
  7. #include "visualfx.h"
  8. #include "frameprop.h"
  9. //test code
  10. #include "mainfrm.h" //没用
  12. #include "anywheredoc.h"
  15. #ifdef _DEBUG
  16. #define new DEBUG_NEW
  17. #undef THIS_FILE
  18. static char THIS_FILE[] = __FILE__;
  19. #endif
  21. /////////////////////////////////////////////////////////////////////////////
  22. // CMsgman
  24. CMsgman::CMsgman(CAnywhereDoc *pDoc)
  25. {
  26. msglist_pos=NULL;
  27. m_pDoc=pDoc;
  28. }
  30. CMsgman::~CMsgman()
  31. {
  32. Msglist_type *pmsg;
  33. while (!Msglist.IsEmpty()) {
  34.          pmsg=(Msglist_type *)Msglist.RemoveHead();
  35. delete pmsg;
  36. }
  38. }
  41. // Do not edit the following lines, which are needed by ClassWizard.
  42. #if 0
  43. BEGIN_MESSAGE_MAP(CMsgman, CAsyncSocket)
  44. //{{AFX_MSG_MAP(CMsgman)
  45. //}}AFX_MSG_MAP
  46. END_MESSAGE_MAP()
  47. #endif // 0
  49. /////////////////////////////////////////////////////////////////////////////
  50. // CMsgman member functions
  52. void CMsgman::init(HWND hFrame)
  53. {
  54.   //msglist_pos=NULL;
  55.    m_hFrame=hFrame;
  56. }
  59. void CMsgman::SendMsg(CString order)
  60. {
  61. //CString order;
  62. CString text;
  63. DWORD ThreadId;
  65. //if (msglist_pos) {
  66.   /*      
  67. Msglist_type *pmsg=(Msglist_type *)Msglist.GetTail();
  68.   order=pmsg->message;
  69.   */
  70. //}
  72. if (order=="CONNECT")
  73. {
  74. AfxBeginThread(Connect,&linkrc);
  75. }
  76.  if (order=="GETINFO*")
  77.  {
  78.  //linkrc.pmsgman=this;
  79.  
  80.  hSend=CreateThread(NULL,0,SendThread,&linkrc,0,&ThreadId);
  81.    //AfxBeginThread(Send,&linkrc);
  82.  }
  83.  if (order=="VIEWSCR*")
  84.  {
  85.  //linkrc.pmsgman=this;
  86.  CreateThread(NULL,0,ViewScr,&linkrc,0,&ThreadId);
  87.  //AfxBeginThread(ViewScr,&linkrc);
  89.  }
  90.  if (order=="LISTFILE")
  91.  {
  92.  hSend=CreateThread(NULL,0,SendThread,&linkrc,0,&ThreadId);
  93.  }
  94. //InsertItem(num,pfile->filename,pfile->icon);
  96. }
  98. BOOL CMsgman::AddMsg(CString message, CString msg_tip,enum  status_type status, BOOL bEnable, CSockAddr target, int priority)
  99. {
  100. /* if (!CheckConnect())
  101. if (IDYES==MessageBox(m_hMainWnd,"现在需要连接远程主机吗? ","提示:",MB_YESNO))
  102. {
  104. Msglist_type * pMsg=new Msglist_type;   
  105.             pMsg->message="CONNECT";
  106.             pMsg-msg_tip="与远程机器连接";
  107.             pMsg->status=first;
  108.             pMsg->target=linkrc.sAddr;
  109.             pMsg->bEnable=TRUE;
  110.             msglist_pos=Msglist.InsertAfter(msglist_pos,(CObject*)pMsg);
  111.             SendMsg();//立即发送连接消息
  112. //优先级并无用处
  113. return TRUE;
  114.     }
  115. else return FALSE;
  116. */
  117. //msglist_pos=Msglist.GetTailPosition();
  118. int order=CheckMsg(message);
  119. if (order==0) {//表示是新的命令
  120.     Msglist_type * pMsg=new Msglist_type;   
  121.     pMsg->message=message;
  122.     pMsg->msg_tip=msg_tip;
  123.     pMsg->status=status;
  124.     pMsg->target=target;
  125.     pMsg->bEnable=bEnable;
  126. Msglist.AddTail(pMsg);
  127.   //msglist_pos=Msglist.InsertAfter(msglist_pos,(CObject*)pMsg);
  128.   //SendMsg();//立即发送
  129.   return TRUE;
  130. }
  131. /*
  132. else if (order==1) { //队列已存在该命令
  133.   if (IDYES==MessageBox(m_hFrame,"系统先前已接受了该条消息,但还没有完成,你希望将命令加入队列,等待发送吗?",
  134.   "提示:",MB_YESNO))
  135.   {
  136.   Msglist_type * pMsg=new Msglist_type;   
  137.   pMsg->message=message;
  138.   pMsg->msg_tip=msg_tip;
  139.   pMsg->status=wait;//标记为等待
  140.   pMsg->target=target;
  141.   pMsg->bEnable=bEnable;
  142.   msglist_pos=Msglist.InsertAfter(msglist_pos,(CObject*)pMsg);
  143.   return TRUE;
  144.   }
  145.   
  146.   
  147. }
  148. */
  149.   return FALSE;//失败的命令
  150.    
  153. }
  155. int CMsgman::CheckMsg(CString message)
  156. {
  157. if (!Msglist.IsEmpty()) {
  158. msglist_pos=Msglist.GetHeadPosition();
  159. }
  161. POSITION pos;
  163. while ((pos=msglist_pos)!=NULL) 
  164. {
  165.        Msglist.GetNext(pos);
  166. if (pos) {
  167. Msglist_type *pmsg=(Msglist_type*)Msglist.GetAt(pos);
  168. if (pmsg->message==message)
  169. { 
  170. //msglist_pos=Msglist.GetTailPosition();
  171. //if (pmsg->status==wait) 
  172. return 1;//(找到标记为等待的)
  173.   //else return 2;
  174. }
  175. msglist_pos=pos;
  176. }
  177.        else {
  178. //msglist_pos=Msglist.GetTailPosition();
  179.         return 0;//没找到立即执行
  180.    }
  182. }
  183. //msglist_pos=Msglist.GetTailPosition();
  184. return 0;//没找到立即执行
  185. //return TRUE;
  186. }
  188. int CMsgman::Respones(CString text)
  189. {
  190. //test---
  191. CString order=text.Left(8);
  192. int length=text.GetLength();
  193. text=text.Right(length-8);//text已更改为主要内容
  194. length=text.GetLength();
  196. POSITION list_pos=NULL;
  197. // int pos;
  198. int num=0;
  199.     
  201. if (!CheckMsg(order))
  202. {
  203. if (order=="GETINFO*")
  204. {
  205. Dispense(text);
  207. /*BOOL bFinished=FALSE;
  208. char *pdrv;
  209. while (!bFinished) {
  210.    if ((pos=m_pDoc->m_sys[8].Find("\"))!=-1)
  211.   {
  212.     pdrv=new char[4];
  213. strcpy(pdrv,m_pDoc->m_sys[8].Left(pos));
  214. pdrv[3]=0;
  215. list_pos=m_pDoc->drvlist.InsertAfter(list_pos,pdrv);
  216. m_pDoc->m_sys[8]=m_pDoc->m_sys[8].Right(m_pDoc->m_sys[8].GetLength()-pos-1);
  217.              num++;
  218.   }
  219.    else bFinished=TRUE;
  220. }*/
  222.         return 1;//为sysinfo 的id
  223. }
  224. if (order=="VIEWSCR*")
  225. return 4;
  227. if (order=="LISTFILE")
  228. {
  230. return 2;}
  231. }
  234. return 0;//返回值是窗口的id
  236. }
  238. void CMsgman::Dispense(CString text)//处理得到的系统信息
  239. {
  240. BOOL bFinished=FALSE;
  241. int num=0;
  242. int pos;
  243.     while (!bFinished) {
  244. if ((pos=text.Find("*"))!=-1)
  245. {
  246. m_pDoc->m_sys[num]=text.Left(pos);
  247. text=text.Right(text.GetLength()-pos-1);
  248. num++;
  249. }
  250.         else bFinished=TRUE;
  251. /*else {
  252. m_pDoc->m_sys[num]=text;
  253. bFinished=TRUE;
  254. }*/
  256. }
  257. //SendMessage(m_hFrame,WM_SETACTIVE,1,0);
  258. //m_pDoc->UpdateAllViews(NULL);
  259. //m_pFrame->SetActive(2);
  260. //CMainFrame *pFrame = (CMainFrame*)AfxGetMainWnd();
  261. //m_pDoc->UpdateAllViews();
  262.      //CMainFrame *pFrame = (CMainFrame*)AfxGetApp()->m_pMainWnd;
  263. //if (pFrame) {
  265. // CDocument *pDoc2=pFrame->GetActiveDocument();
  266. //CAnywhereDoc *pDoc=(CAnywhereDoc *)(pFrame->GetActiveDocument());
  268. //} 
  269. }
  271. int CMsgman::Okmsg(CString text,BOOL success)
  272. {
  273. /* if (!Msglist.IsEmpty()) {
  274. msglist_pos=Msglist.GetHeadPosition();
  275. }
  276. */
  277. // POSITION pos;
  278. //CString order=text.Left(8);
  279.     if (success)return (Respones(text));
  280.   else return 0;   //返回无效id0意味失败;
  282. /*
  283. while ((pos=msglist_pos)!=NULL) 
  284. {
  285.        Msglist.GetNext(pos);
  286. if (pos) {
  287. Msglist_type *pmsg=(Msglist_type*)Msglist.GetAt(pos);
  288. if (pmsg->message==order)
  289. { 
  290. //pmsg->status=done;//标记为完成
  291.   Msglist_type *pmsg=Msglist.GetAt(pos);
  292.   Msglist.RemoveAt(pos);//删除该条命令
  293.   delete pmsg;
  294.   
  295.               
  296.   if (success)return (Respones(text));
  297.   else return 0;   //返回无效id0意味失败;
  298.   //msglist_pos=Msglist.GetTailPosition();
  299.   //return FALSE;//找到了
  300. }
  301. msglist_pos=pos;
  302. }
  303. else {
  304. //msglist_pos=Msglist.GetTailPosition();
  305. return 0;//没找到
  306. }
  308. }
  310. return 0;
  311. */
  313. }
  315. void CMsgman::SetActive(int id)
  316. {
  318. //int nIndex;
  319.   //TVisualFramework *m_Fx;
  320.   //CMainFrame *pFrame=(CMainFrame *)AfxGetMainWnd();
  321.   //m_Fx=&(m_pDoc->m_pFrame)->m_Framework;
  322.   //m_Fx=&((CMainFrame *)AfxGetMainWnd())->m_Framework;
  323. //   (m_pFrame->m_Framework).SetActivePane(m_pFrame->pObject);
  324.   
  325.   //TVisualFramework m_Fx;
  326.   //&m_Fx=&((CMainFrame*)AfxGetMainWnd())->m_Framework;
  327.   /*TVisualFrameworkIterator it((m_pDoc->m_pFrame)->m_Framework);
  328.   while (!it.End()) {
  329.     TVisualObject *pObject = it.Get();
  330.     if ((pObject->CanFocus()) & (pObject->GetID()==id)) {
  331.       ((m_pDoc->m_pFrame)->m_Framework).SetActivePane(pObject);
  332. //nIndex = m_List.AddString(pObject->GetDescription());
  333.       //m_List.SetItemData(nIndex, (DWORD)pObject);
  334.     }
  335.     it ++;
  336.   }
  337.   */
  339.   
  340.   //CFrameworkProperties dialog(
  341.   
  343.   //dialog.DoModal();
  345. }
  347. BOOL CMsgman::CheckConnect()
  348. {
  349. if (linkrc.bConnected==1) return 
  350. TRUE;
  351. else return FALSE;
  354. }