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

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

手机短信编程

开发平台：

Visual C++

EsmeTransceiverCom.cpp：源码内容
  1. // EsmeTransceiverCom.cpp : Implementation of CEsmeTransceiverCom
  3. #include "stdafx.h"
  4. #include "EsmeTransceiverCom.h"
  7. // CEsmeTransceiverCom
  9. STDMETHODIMP CEsmeTransceiverCom::bind(BSTR sysid, BSTR passwd, BSTR systype, ISmppAddressCom* iaddr, VARIANT_BOOL* pret)
  10. {
  11. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  13. // TODO: Add your implementation code here
  14. USES_CONVERSION;
  16. LPSTR sid, pwd, stype;
  18. sid = OLE2A(sysid);
  19. pwd = OLE2A(passwd);
  20. stype = OLE2A(systype);
  22. SHORT npi;
  23. SHORT ton;
  24. BSTR addr;
  26. iaddr->get_NPI(&npi);
  27. iaddr->get_TON(&ton);
  28. iaddr->get_Address(&addr);
  30. LPSTR paddr = OLE2A(addr);
  31. CSmppAddress srange(ton, npi, paddr);
  33. SysFreeString(addr);
  35. //setting finished, going to bind to SMSC
  37. EnterCriticalSection(&m_cs); //enter m_cs
  39. ResetEvent(m_response_event);
  40. CEsmeTransceiver::bind(sid, pwd, stype, srange);
  42. HANDLE hwait[] = {m_response_event, m_hDisconnectEvent, m_hKillEvent};
  44. DWORD ret = WaitForMultipleObjects(3, hwait, FALSE, 30000);
  46. if (ret == WAIT_OBJECT_0)
  47. {
  48. if (m_last_error)
  49. *pret = VARIANT_FALSE;
  50. else
  51. *pret = VARIANT_TRUE;
  52. }
  53. else
  54. *pret = VARIANT_FALSE;
  56. ResetEvent(m_response_event);
  58. LeaveCriticalSection(&m_cs); //leave m_cs
  60. return S_OK;
  61. }
  63. STDMETHODIMP CEsmeTransceiverCom::unbind(VARIANT_BOOL* pret)
  64. {
  65. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  67. // TODO: Add your implementation code here
  69. EnterCriticalSection(&m_cs); //enter m_cs
  71. ResetEvent(m_response_event);
  72. CEsmeTransceiver::unbind();
  74. HANDLE hwait[] = {m_response_event, m_hDisconnectEvent, m_hKillEvent};
  76. DWORD ret = WaitForMultipleObjects(3, hwait, FALSE, 30000);
  78. if (ret == WAIT_OBJECT_0)
  79. {
  80. if (m_last_error)
  81. *pret = VARIANT_FALSE;
  82. else
  83. *pret = VARIANT_TRUE;
  84. }
  85. else
  86. *pret = VARIANT_FALSE;
  88. ResetEvent(m_response_event);
  90. LeaveCriticalSection(&m_cs); //leave m_cs
  92. return S_OK;
  93. }
  95. STDMETHODIMP CEsmeTransceiverCom::enquireLink(VARIANT_BOOL* pret)
  96. {
  97. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  99. // TODO: Add your implementation code here
  101. EnterCriticalSection(&m_cs); //enter m_cs
  103. ResetEvent(m_response_event);
  104. CEsmeTransceiver::enquireLink();
  106. HANDLE hwait[] = {m_response_event, m_hDisconnectEvent, m_hKillEvent};
  108. DWORD ret = WaitForMultipleObjects(3, hwait, FALSE, 30000);
  110. if (ret == WAIT_OBJECT_0)
  111. {
  112. if (m_last_error)
  113. *pret = VARIANT_FALSE;
  114. else
  115. *pret = VARIANT_TRUE;
  116. }
  117. else
  118. *pret = VARIANT_FALSE;
  120. ResetEvent(m_response_event);
  122. LeaveCriticalSection(&m_cs); //leave m_cs
  124. return S_OK;
  125. }
  127. STDMETHODIMP CEsmeTransceiverCom::init(BSTR svrip, LONG port)
  128. {
  129. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  131. // TODO: Add your implementation code here
  133. USES_CONVERSION;
  135. LPSTR sip = OLE2A(svrip);
  137. CEsmeTransceiver::init(sip, port);
  139. return S_OK;
  140. }
  142. STDMETHODIMP CEsmeTransceiverCom::close(void)
  143. {
  144. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  146. // TODO: Add your implementation code here
  147. CEsmeTransceiver::close();
  149. return S_OK;
  150. }
  152. STDMETHODIMP CEsmeTransceiverCom::get_Connected(VARIANT_BOOL* pVal)
  153. {
  154. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  156. // TODO: Add your implementation code here
  158. if (CEsmeTransceiver::isConnected())
  159. {
  160. *pVal = VARIANT_TRUE;
  161. }
  162. else
  163. {
  164. *pVal = VARIANT_FALSE;
  165. }
  167. return S_OK;
  168. }
  170. STDMETHODIMP CEsmeTransceiverCom::submitMessage(ISubmitSMCom* isubmit, BSTR* pMsgid, VARIANT_BOOL* pret)
  171. {
  172. AFX_MANAGE_STATE(AfxGetStaticModuleState());
  174. // TODO: Add your implementation code here
  175. CSubmitSM sm;
  177. USES_CONVERSION;
  179. BSTR svrtype;
  180. isubmit->get_ServiceType(&svrtype);
  181. LPSTR stype = OLE2A(svrtype);
  183. sm.setServiceType(stype);
  185. SHORT dc, esm, repif, priflag, proid, defmsg, regdel;
  187. isubmit->get_dataCoding(&dc);
  188. isubmit->get_esmClass(&esm);
  189. isubmit->get_replaceIfPresent(&repif);
  190. isubmit->get_priorityFlag(&priflag);
  191. isubmit->get_protocolID(&proid);
  192. isubmit->get_smDefaultMsgId(&defmsg);
  193. isubmit->get_registeredDelivery(&regdel);
  195. sm.setDataCoding(dc);
  196. sm.setEsmClass(esm);
  197. sm.setReplaceIfPresent(repif);
  198. sm.setPriorityFlag(priflag);
  199. sm.setProtocolId(proid);
  200. sm.setSmDefaultMsgId(defmsg);
  201. sm.setRegisteredDelivery(regdel);
  203. SHORT ton, npi;
  204. BSTR addr;
  206. ISmppAddressCom *iaddr;
  208. //getting source
  209. isubmit->get_Source(&iaddr);
  210. iaddr->get_TON(&ton);
  211. iaddr->get_NPI(&npi);
  212. iaddr->get_Address(&addr);
  213. iaddr->Release();
  215. LPSTR paddr = OLE2A(addr);
  216. SysFreeString(addr);
  218. CSmppAddress src(ton, npi, paddr);
  220. //getting destination
  221. isubmit->get_Destination(&iaddr);
  222. iaddr->get_TON(&ton);
  223. iaddr->get_NPI(&npi);
  224. iaddr->get_Address(&addr);
  225. iaddr->Release();
  227. paddr = OLE2A(addr);
  228. SysFreeString(addr);
  230. CSmppAddress dst(ton, npi, paddr);
  232. //assing source and destination
  233. sm.setSource(src);
  234. sm.setDestination(dst);
  236. ISmppDateCom *idate;
  237. BSTR strdate;
  239. //getting ScheduledDelivery
  240. isubmit->get_scheduledDelivery(&idate);
  241. idate->toString(&strdate);
  242. LPSTR sdt = OLE2A(strdate);
  243. idate->Release();
  245. CSmppDate schdel;
  246. schdel.setDate(sdt);
  248. //getting ValidityPeriod
  249. isubmit->get_validityPeriod(&idate);
  250. idate->toString(&strdate);
  251. sdt = OLE2A(strdate);
  252. idate->Release();
  254. CSmppDate valprd;
  255. valprd.setDate(sdt);
  257. //assign scheduledDelivery and validityPeriod to sm
  258. sm.setScheduledDelivery(schdel);
  259. sm.setValidityPeriod(valprd);
  261. VARIANT var;
  262. isubmit->getMessage(&var);
  263. SAFEARRAY *psa = var.parray;
  264. BYTE *padata;
  266. int nsize = psa->rgsabound->cElements;
  267. SafeArrayAccessData(psa, (void **) &padata);
  268. sm.setMessage(padata, nsize);
  269. SafeArrayUnaccessData(psa);
  272. //
  273. //okay, we've setting up the SubmitSM, send it
  274. //
  276. EnterCriticalSection(&m_cs); //enter m_cs
  278. ResetEvent(m_response_event);
  279. CEsmeTransceiver::submitMessage(sm);
  281. HANDLE hwait[] = {m_response_event, m_hDisconnectEvent, m_hKillEvent};
  283. DWORD ret = WaitForMultipleObjects(3, hwait, FALSE, 30000);
  285. if (ret == WAIT_OBJECT_0)
  286. {
  287. if (m_last_error)
  288. *pret = VARIANT_FALSE;
  289. else
  290. {
  291. *pret = VARIANT_TRUE;
  292. *pMsgid = m_last_msg_id.AllocSysString();
  293. }
  294. }
  295. else
  296. *pret = VARIANT_FALSE;
  298. ResetEvent(m_response_event);
  300. LeaveCriticalSection(&m_cs); //leave m_cs
  302. return S_OK;
  303. }
  305. //registered callback to handle SMPP packets sent from SMSC
  306. //(must be static class method or global procedure)
  307. void __stdcall CEsmeTransceiverCom::processPacketProc(CPacketBase *pak, LPVOID param)
  308. {
  309. CEsmeTransceiverCom *pTrans = (CEsmeTransceiverCom *) param;
  311. //route to instance method, so it can access instance attributes
  312. pTrans->processPacket(pak);
  313. }
  316. //actuallly SMPP packets are in turns handled here 
  317. void CEsmeTransceiverCom::processPacket(CPacketBase *pak)
  318. {
  320. switch (pak->getCommandId())
  321. {
  324. case SMPP_ENQUIRE_LINK:
  325. {
  326. //SMSC requested us to send querylink response
  328. CEnquireLink *pPak;
  329. pPak = static_cast<CEnquireLink *>(pak);
  331. //automatic reponse for enquery link
  332. CEnquireLinkResp elresp(*pPak);
  333. sendPacket(elresp);
  335. }
  336. break;
  338. case SMPP_DELIVER_SM:
  339. {
  340. //got a deliver SM
  341. CDeliverSM *pPak;
  342. pPak = static_cast<CDeliverSM *>(pak);
  344. //automatic response deliversm reponse
  345. CDeliverSMResp dresp (*pPak);
  346. sendPacket(dresp);
  348. //notify client for the deliver SM
  349. NotifyClientDeliverSM(pPak);
  350. }
  351. break;
  353. case SMPP_BIND_TRANSCEIVER_RESP:
  354. {
  355. //bind transceiver response
  357. CBindTransceiverResp *pPak;
  358. pPak = static_cast<CBindTransceiverResp *>(pak);
  360. if (pPak->getCommandStatus() == 0)
  361. {
  362. m_last_error = false;
  363. }
  364. else
  365. {
  366. m_last_error = true;
  367. }
  368. SetEvent(m_response_event);
  369. }
  370. break;
  373. case SMPP_UNBIND_RESP:
  374. {
  375. //unbind response
  377. CUnbindResp *pPak;
  378. pPak = static_cast<CUnbindResp *>(pak);
  380. if (pPak->getCommandStatus() == 0)
  381. {
  382. m_last_error = false;
  383. }
  384. else
  385. {
  386. m_last_error = true;
  387. }
  388. SetEvent(m_response_event);
  389. }
  390. break;
  393. case SMPP_SUBMIT_SM_RESP:
  394. {
  395. //Submit Short Message Response
  397. CSubmitSMResp *pPak;
  398. pPak = static_cast<CSubmitSMResp *>(pak);
  400. if (pPak->getCommandStatus() == 0)
  401. {
  402. m_last_msg_id = pPak->getMessageId();
  403. m_last_error = false;
  404. }
  405. else
  406. {
  407. m_last_error = true;
  408. }
  409. SetEvent(m_response_event);
  410. }
  411. break;
  414. case SMPP_ENQUIRE_LINK_RESP:
  415. {
  416. //Previous EnquireLink is responsed
  418. CEnquireLinkResp *pPak;
  419. pPak = static_cast<CEnquireLinkResp *>(pak);
  421. if (pPak->getCommandStatus() == 0)
  422. {
  423. m_last_error = false;
  424. SetEvent(m_response_event);
  425. }
  426. else
  427. {
  428. m_last_error = true;
  429. }
  430. SetEvent(m_response_event);
  431. }
  432. break;
  435. default:
  436. break;
  437. }
  438. }
  440. void CEsmeTransceiverCom::NotifyClientDeliverSM(CDeliverSM *pak)
  441. {
  442. IDeliverSMCom *pVal;
  444. //create an CDeliverSMCom instance to return
  445. CoCreateInstance( CLSID_DeliverSMCom,
  446. NULL,
  447. CLSCTX_ALL,
  448. IID_IDeliverSMCom,
  449. (void **) &pVal);
  451. USES_CONVERSION;
  453. pVal->put_dataCoding(pak->getDataCoding());
  454. pVal->put_esmClass(pak->getEsmClass());
  455. pVal->put_replaceIfPresent(pak->getReplaceIfPresent());
  456. pVal->put_priorityFlag(pak->getPriorityFlag());
  457. pVal->put_protocolID(pak->getProtocolId());
  458. pVal->put_smDefaultMsgId(pak->getSmDefaultMsgId());
  459. pVal->put_registeredDelivery(pak->getRegisteredDelivery());
  462. //create an CSmppAddressCom for setting addresses
  463. ISmppAddressCom *iaddr;
  464. CoCreateInstance( CLSID_SmppAddressCom,
  465. NULL,
  466. CLSCTX_ALL,
  467. IID_ISmppAddressCom,
  468. (void **) &iaddr);
  470. BSTR addrstr;
  472. //Setting source
  473. CSmppAddress source = pak->getSource();
  474. iaddr->put_TON(source.m_addr_ton);
  475. iaddr->put_NPI(source.m_addr_npi);
  476. addrstr = source.m_addr.AllocSysString();
  477. iaddr->put_Address(addrstr);
  478. SysFreeString(addrstr);
  480. pVal->put_Source(iaddr);
  482. //Setting Destination
  483. CSmppAddress destination = pak->getDestination();
  484. iaddr->put_TON(destination.m_addr_ton);
  485. iaddr->put_NPI(destination.m_addr_npi);
  486. addrstr = destination.m_addr.AllocSysString();
  487. iaddr->put_Address(addrstr);
  488. SysFreeString(addrstr);
  490. pVal->put_Destination(iaddr);
  492. iaddr->Release();
  495. //create an CSmppDate for setting dates
  496. ISmppDateCom *idate;
  497. CoCreateInstance( CLSID_SmppDateCom,
  498. NULL,
  499. CLSCTX_ALL,
  500. IID_ISmppDateCom,
  501. (void **) &idate);
  503. BSTR strdate;
  505. //setting scheduleddelivery
  506. CSmppDate schdate = pak->getScheduledDelivery();
  507. strdate = schdate.toString().AllocSysString();
  508. idate->setDate(strdate);
  509. pVal->put_scheduledDelivery(idate);
  510. SysFreeString(strdate);
  512. //setting validityperiod
  513. CSmppDate vldprd = pak->getValidityPeriod();
  514. strdate = vldprd.toString().AllocSysString();
  515. idate->setDate(strdate);
  516. pVal->put_validityPeriod(idate);
  517. SysFreeString(strdate);
  519. idate->Release();
  521. //setting message
  522. PBYTE pdata;
  523. uint32 nsize;
  524. pak->getMessage(pdata, nsize);
  526. VARIANT var;
  528. VariantInit(&var);
  529. var.vt = VT_ARRAY | VT_UI1;
  530. SAFEARRAY *psa;
  531. SAFEARRAYBOUND bounds = {nsize, 0};
  532. psa = SafeArrayCreate(VT_UI1, 1, &bounds);
  533. BYTE *padata;
  534. SafeArrayAccessData(psa, (void **) &padata);
  535. memcpy(padata, pdata, nsize);
  536. SafeArrayUnaccessData(psa);
  537. var.parray = psa;
  539. pVal->setMessage(var);
  541. //fire notification event
  542. Fire_OnDeliverSM(pVal);
  544. }