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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > 手机短信编程 > 查看源码
EsmeTransmitterCom.cpp
资源名称：smpplib.zip　[点击查看]
上传用户：hkcoast
上传日期：2007-01-12
资源大小：979k
文件大小：8k
源码类别：

手机短信编程

开发平台：

Visual C++

EsmeTransmitterCom.cpp：源码内容
  1. // EsmeTransmitterCom.cpp : Implementation of CEsmeTransmitterCom
  3. #include "stdafx.h"
  4. #include "EsmeTransmitterCom.h"
  7. // CEsmeTransmitterCom
  10. STDMETHODIMP CEsmeTransmitterCom::bind(BSTR sysid, BSTR passwd, BSTR systype, ISmppAddressCom* iaddr, VARIANT_BOOL* pret)
  11. {
  12. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  14. // TODO: Add your implementation code here
  15. USES_CONVERSION;
  17. LPSTR sid, pwd, stype;
  19. sid = OLE2A(sysid);
  20. pwd = OLE2A(passwd);
  21. stype = OLE2A(systype);
  23. SHORT npi;
  24. SHORT ton;
  25. BSTR addr;
  27. iaddr->get_NPI(&npi);
  28. iaddr->get_TON(&ton);
  29. iaddr->get_Address(&addr);
  31. LPSTR paddr = OLE2A(addr);
  32. CSmppAddress srange(ton, npi, paddr);
  34. SysFreeString(addr);
  36. //setting finished, going to bind to SMSC
  38. EnterCriticalSection(&m_cs); //enter m_cs
  40. ResetEvent(m_response_event);
  41. CEsmeTransmitter::bind(sid, pwd, stype, srange);
  43. HANDLE hwait[] = {m_response_event, m_hDisconnectEvent, m_hKillEvent};
  45. DWORD ret = WaitForMultipleObjects(3, hwait, FALSE, 30000);
  47. if (ret == WAIT_OBJECT_0)
  48. {
  49. if (m_last_error)
  50. *pret = VARIANT_FALSE;
  51. else
  52. *pret = VARIANT_TRUE;
  53. }
  54. else
  55. *pret = VARIANT_FALSE;
  57. ResetEvent(m_response_event);
  59. LeaveCriticalSection(&m_cs); //leave m_cs
  61. return S_OK;
  62. }
  64. STDMETHODIMP CEsmeTransmitterCom::unbind(VARIANT_BOOL* pret)
  65. {
  66. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  68. // TODO: Add your implementation code here
  70. EnterCriticalSection(&m_cs); //enter m_cs
  72. ResetEvent(m_response_event);
  73. CEsmeTransmitter::unbind();
  75. HANDLE hwait[] = {m_response_event, m_hDisconnectEvent, m_hKillEvent};
  77. DWORD ret = WaitForMultipleObjects(3, hwait, FALSE, 30000);
  79. if (ret == WAIT_OBJECT_0)
  80. {
  81. if (m_last_error)
  82. *pret = VARIANT_FALSE;
  83. else
  84. *pret = VARIANT_TRUE;
  85. }
  86. else
  87. *pret = VARIANT_FALSE;
  89. ResetEvent(m_response_event);
  91. LeaveCriticalSection(&m_cs); //leave m_cs
  93. return S_OK;
  94. }
  96. STDMETHODIMP CEsmeTransmitterCom::enquireLink(VARIANT_BOOL* pret)
  97. {
  98. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  100. // TODO: Add your implementation code here
  102. EnterCriticalSection(&m_cs); //enter m_cs
  104. ResetEvent(m_response_event);
  105. CEsmeTransmitter::enquireLink();
  107. HANDLE hwait[] = {m_response_event, m_hDisconnectEvent, m_hKillEvent};
  109. DWORD ret = WaitForMultipleObjects(3, hwait, FALSE, 30000);
  111. if (ret == WAIT_OBJECT_0)
  112. {
  113. if (m_last_error)
  114. *pret = VARIANT_FALSE;
  115. else
  116. *pret = VARIANT_TRUE;
  117. }
  118. else
  119. *pret = VARIANT_FALSE;
  121. ResetEvent(m_response_event);
  123. LeaveCriticalSection(&m_cs); //leave m_cs
  125. return S_OK;
  126. }
  128. STDMETHODIMP CEsmeTransmitterCom::init(BSTR svrip, LONG port)
  129. {
  130. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  132. // TODO: Add your implementation code here
  134. USES_CONVERSION;
  136. LPSTR sip = OLE2A(svrip);
  138. CEsmeTransmitter::init(sip, port);
  140. return S_OK;
  141. }
  143. STDMETHODIMP CEsmeTransmitterCom::close(void)
  144. {
  145. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  147. // TODO: Add your implementation code here
  148. CEsmeTransmitter::close();
  150. return S_OK;
  151. }
  153. STDMETHODIMP CEsmeTransmitterCom::get_Connected(VARIANT_BOOL* pVal)
  154. {
  155. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  157. // TODO: Add your implementation code here
  159. if (CEsmeTransmitter::isConnected())
  160. {
  161. *pVal = VARIANT_TRUE;
  162. }
  163. else
  164. {
  165. *pVal = VARIANT_FALSE;
  166. }
  168. return S_OK;
  169. }
  171. STDMETHODIMP CEsmeTransmitterCom::submitMessage(ISubmitSMCom* isubmit, BSTR* pMsgid, VARIANT_BOOL* pret)
  172. {
  173. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  175. // TODO: Add your implementation code here
  176. CSubmitSM sm;
  178. USES_CONVERSION;
  180. BSTR svrtype;
  181. isubmit->get_ServiceType(&svrtype);
  182. LPSTR stype = OLE2A(svrtype);
  184. sm.setServiceType(stype);
  186. SHORT dc, esm, repif, priflag, proid, defmsg, regdel;
  188. isubmit->get_dataCoding(&dc);
  189. isubmit->get_esmClass(&esm);
  190. isubmit->get_replaceIfPresent(&repif);
  191. isubmit->get_priorityFlag(&priflag);
  192. isubmit->get_protocolID(&proid);
  193. isubmit->get_smDefaultMsgId(&defmsg);
  194. isubmit->get_registeredDelivery(&regdel);
  196. sm.setDataCoding(dc);
  197. sm.setEsmClass(esm);
  198. sm.setReplaceIfPresent(repif);
  199. sm.setPriorityFlag(priflag);
  200. sm.setProtocolId(proid);
  201. sm.setSmDefaultMsgId(defmsg);
  202. sm.setRegisteredDelivery(regdel);
  204. SHORT ton, npi;
  205. BSTR addr;
  207. ISmppAddressCom *iaddr;
  209. //getting source
  210. isubmit->get_Source(&iaddr);
  211. iaddr->get_TON(&ton);
  212. iaddr->get_NPI(&npi);
  213. iaddr->get_Address(&addr);
  214. iaddr->Release();
  216. LPSTR paddr = OLE2A(addr);
  217. SysFreeString(addr);
  219. CSmppAddress src(ton, npi, paddr);
  221. //getting destination
  222. isubmit->get_Destination(&iaddr);
  223. iaddr->get_TON(&ton);
  224. iaddr->get_NPI(&npi);
  225. iaddr->get_Address(&addr);
  226. iaddr->Release();
  228. paddr = OLE2A(addr);
  229. SysFreeString(addr);
  231. CSmppAddress dst(ton, npi, paddr);
  233. //assing source and destination
  234. sm.setSource(src);
  235. sm.setDestination(dst);
  237. ISmppDateCom *idate;
  238. BSTR strdate;
  240. //getting ScheduledDelivery
  241. isubmit->get_scheduledDelivery(&idate);
  242. idate->toString(&strdate);
  243. LPSTR sdt = OLE2A(strdate);
  244. idate->Release();
  246. CSmppDate schdel;
  247. schdel.setDate(sdt);
  249. //getting ValidityPeriod
  250. isubmit->get_validityPeriod(&idate);
  251. idate->toString(&strdate);
  252. sdt = OLE2A(strdate);
  253. idate->Release();
  255. CSmppDate valprd;
  256. valprd.setDate(sdt);
  258. //assign scheduledDelivery and validityPeriod to sm
  259. sm.setScheduledDelivery(schdel);
  260. sm.setValidityPeriod(valprd);
  262. VARIANT var;
  263. isubmit->getMessage(&var);
  264. SAFEARRAY *psa = var.parray;
  265. BYTE *padata;
  267. int nsize = psa->rgsabound->cElements;
  268. SafeArrayAccessData(psa, (void **) &padata);
  269. sm.setMessage(padata, nsize);
  270. SafeArrayUnaccessData(psa);
  273. //
  274. //okay, we've setting up the SubmitSM, send it
  275. //
  277. EnterCriticalSection(&m_cs); //enter m_cs
  279. ResetEvent(m_response_event);
  280. CEsmeTransmitter::submitMessage(sm);
  282. HANDLE hwait[] = {m_response_event, m_hDisconnectEvent, m_hKillEvent};
  284. DWORD ret = WaitForMultipleObjects(3, hwait, FALSE, 30000);
  286. if (ret == WAIT_OBJECT_0)
  287. {
  288. if (m_last_error)
  289. *pret = VARIANT_FALSE;
  290. else
  291. {
  292. *pret = VARIANT_TRUE;
  293. *pMsgid = m_last_msg_id.AllocSysString();
  294. }
  295. }
  296. else
  297. *pret = VARIANT_FALSE;
  299. ResetEvent(m_response_event);
  301. LeaveCriticalSection(&m_cs); //leave m_cs
  303. return S_OK;
  304. }
  306. //registered callback to handle SMPP packets sent from SMSC
  307. //(must be static class method or global procedure)
  308. void __stdcall CEsmeTransmitterCom::processPacketProc(CPacketBase *pak, LPVOID param)
  309. {
  310. CEsmeTransmitterCom *pTrans = (CEsmeTransmitterCom *) param;
  312. //route to instance method, so it can access instance attributes
  313. pTrans->processPacket(pak);
  314. }
  317. //actuallly SMPP packets are in turns handled here 
  318. void CEsmeTransmitterCom::processPacket(CPacketBase *pak)
  319. {
  321. switch (pak->getCommandId())
  322. {
  325. case SMPP_ENQUIRE_LINK:
  326. {
  327. //SMSC requested us to send querylink response
  329. CEnquireLink *pPak;
  330. pPak = static_cast<CEnquireLink *>(pak);
  332. //automatic reponse for enquery link
  333. CEnquireLinkResp elresp(*pPak);
  334. sendPacket(elresp);
  336. }
  337. break;
  340. case SMPP_BIND_TRANSMITTER_RESP:
  341. {
  342. //bind transmitter response
  344. CBindTransmitterResp *pPak;
  345. pPak = static_cast<CBindTransmitterResp *>(pak);
  347. if (pPak->getCommandStatus() == 0)
  348. {
  349. m_last_error = false;
  350. }
  351. else
  352. {
  353. m_last_error = true;
  354. }
  355. SetEvent(m_response_event);
  356. }
  357. break;
  360. case SMPP_UNBIND_RESP:
  361. {
  362. //unbind response
  364. CUnbindResp *pPak;
  365. pPak = static_cast<CUnbindResp *>(pak);
  367. if (pPak->getCommandStatus() == 0)
  368. {
  369. m_last_error = false;
  370. }
  371. else
  372. {
  373. m_last_error = true;
  374. }
  375. SetEvent(m_response_event);
  376. }
  377. break;
  380. case SMPP_SUBMIT_SM_RESP:
  381. {
  382. //Submit Short Message Response
  384. CSubmitSMResp *pPak;
  385. pPak = static_cast<CSubmitSMResp *>(pak);
  387. if (pPak->getCommandStatus() == 0)
  388. {
  389. m_last_msg_id = pPak->getMessageId();
  390. m_last_error = false;
  391. }
  392. else
  393. {
  394. m_last_error = true;
  395. }
  396. SetEvent(m_response_event);
  397. }
  398. break;
  401. case SMPP_ENQUIRE_LINK_RESP:
  402. {
  403. //Previous EnquireLink is responsed
  405. CEnquireLinkResp *pPak;
  406. pPak = static_cast<CEnquireLinkResp *>(pak);
  408. if (pPak->getCommandStatus() == 0)
  409. {
  410. m_last_error = false;
  411. SetEvent(m_response_event);
  412. }
  413. else
  414. {
  415. m_last_error = true;
  416. }
  417. SetEvent(m_response_event);
  418. }
  419. break;
  422. default:
  423. break;
  424. }
  425. }