src/Utils/HwSMTP.cpp

   1 // HwSMTP.cpp: implementation of the CHwSMTP class.
   2 //
   3 //////////////////////////////////////////////////////////////////////
   4
   5 #include "stdafx.h"
   6 #include "afxstr.h"
   7 #include "HwSMTP.h"
   8 #include "CBase64.h"
   9 #include "SpeedPostEmail.h"
  10 #include "Windns.h"
  11 #include <Afxmt.h>
  12
  13 #ifdef _DEBUG
  14 #undef THIS_FILE
  15 static char THIS_FILE[]=__FILE__;
  16 #define new DEBUG_NEW
  17 #endif
  18
  19 CPtrArray g_PtrAry_Threads;
  20 ::CCriticalSection m_CSFor__g_PtrAry_Threads;
  21
  22 class CEMailObject
  23 {
  24 public:
  25         CEMailObject (
  26                 LPCTSTR lpszSmtpSrvHost,
  27                 LPCTSTR lpszUserName,
  28                 LPCTSTR lpszPasswd,
  29                 BOOL bMustAuth,
  30                 LPCTSTR lpszAddrFrom,
  31                 LPCTSTR lpszAddrTo,
  32                 LPCTSTR lpszFromName,
  33                 LPCTSTR lpszReceiverName,
  34                 LPCTSTR lpszSubject,
  35                 LPCTSTR lpszBody,
  36                 LPCTSTR lpszCharSet,
  37                 CStringArray *pStrAryAttach,
  38                 LPCTSTR pStrAryCC,
  39                 UINT nSmtpSrvPort,
  40                 LPCTSTR pSender,
  41                 LPCTSTR pToList
  42                 )
  43         {
  44                 m_csSmtpSrvHost = GET_SAFE_STRING(lpszSmtpSrvHost);
  45                 m_csUserName = GET_SAFE_STRING(lpszUserName);
  46                 m_csPasswd = GET_SAFE_STRING(lpszPasswd);
  47                 m_bMustAuth = bMustAuth;
  48                 m_csAddrFrom = GET_SAFE_STRING(lpszAddrFrom);
  49                 m_csAddrTo = GET_SAFE_STRING(lpszAddrTo);
  50                 m_csFromName = GET_SAFE_STRING(lpszFromName);
  51                 m_csReceiverName = GET_SAFE_STRING(lpszReceiverName);
  52                 m_csSubject = GET_SAFE_STRING(lpszSubject);
  53                 m_csBody = GET_SAFE_STRING(lpszBody);
  54                 m_csCharSet = GET_SAFE_STRING(lpszCharSet);
  55                 m_StrCC = GET_SAFE_STRING(pStrAryCC);
  56                 m_csSender = GET_SAFE_STRING(pSender);
  57                 m_csToList = GET_SAFE_STRING(pToList);
  58
  59                 if ( pStrAryAttach )
  60                         m_StrAryAttach.Append ( *pStrAryAttach );
  61
  62                 m_nSmtpSrvPort = nSmtpSrvPort;
  63                 m_hThread = NULL;
  64         }
  65
  66 public:
  67         CString m_csSmtpSrvHost;
  68         CString m_csUserName;
  69         CString m_csPasswd;
  70         BOOL m_bMustAuth;
  71         CString m_csAddrFrom;
  72         CString m_csAddrTo;
  73         CString m_csFromName;
  74         CString m_csReceiverName;
  75         CString m_csSubject;
  76         CString m_csBody;
  77         CString m_csCharSet;
  78         CStringArray m_StrAryAttach;
  79         CString m_StrCC;
  80         UINT m_nSmtpSrvPort;
  81         CString m_csSender;
  82         CString m_csToList;
  83
  84         HANDLE m_hThread;
  85 };
  86
  87 //////////////////////////////////////////////////////////////////////
  88 // Construction/Destruction
  89 //////////////////////////////////////////////////////////////////////
  90
  91 CHwSMTP::CHwSMTP () :
  92         m_bConnected ( FALSE ),
  93         m_nSmtpSrvPort ( 25 ),
  94         m_bMustAuth ( TRUE )
  95 {
  96         m_csPartBoundary = _T( "WC_MAIL_PaRt_BoUnDaRy_05151998" );
  97         m_csMIMEContentType = FormatString ( _T( "multipart/mixed; boundary=%s" ), m_csPartBoundary);
  98         m_csNoMIMEText = _T( "This is a multi-part message in MIME format." );
  99         //m_csCharSet = _T("\r\n\tcharset=\"iso-8859-1\"\r\n");
 100
 101         AfxSocketInit();
 102 }
 103
 104 CHwSMTP::~CHwSMTP()
 105 {
 106 }
 107
 108 void CHwSMTP::GetNameAddress(CString &in, CString &name,CString &address)
 109 {
 110         int start,end;
 111         start=in.Find(_T('<'));
 112         end=in.Find(_T('>'));
 113
 114         if(start >=0 && end >=0)
 115         {
 116                 name=in.Left(start);
 117                 address=in.Mid(start+1,end-start-1);
 118         }
 119         else
 120                 address=in;
 121 }
 122
 123 CString CHwSMTP::GetServerAddress(CString &email)
 124 {
 125         CString str;
 126         int start,end;
 127
 128         start = email.Find(_T("<"));
 129         end = email.Find(_T(">"));
 130
 131         if(start>=0 && end >=0)
 132         {
 133                 str=email.Mid(start+1,end-start-1);
 134         }
 135         else
 136         {
 137                 str=email;
 138         }
 139
 140         start = str.Find(_T('@'));
 141         return str.Mid(start+1);
 142
 143 }
 144
 145 BOOL CHwSMTP::SendSpeedEmail
 146                 (
 147                         LPCTSTR lpszAddrFrom,
 148                         LPCTSTR lpszAddrTo,
 149                         LPCTSTR lpszSubject,
 150                         LPCTSTR lpszBody,
 151                         LPCTSTR lpszCharSet,                                            // ×Ö·û¼¯ÀàÐÍ£¬ÀýÈç£º·±ÌåÖÐÎÄÕâÀïÓ¦ÊäÈë"big5"£¬¼òÌåÖÐÎÄÊ±ÊäÈë"gb2312"
 152                         CStringArray *pStrAryAttach,
 153                         LPCTSTR pStrAryCC,
 154                         UINT    nSmtpSrvPort,
 155                         LPCTSTR pSend
 156                 )
 157 {
 158
 159         BOOL ret=true;
 160         CString To;
 161         To += GET_SAFE_STRING(lpszAddrTo);
 162         To += _T(";");
 163         To += GET_SAFE_STRING(pStrAryCC);
 164
 165         std::map<CString,std::vector<CString>> Address;
 166
 167         int start = 0;
 168         while( start >= 0 )
 169         {
 170                 CString one= To.Tokenize(_T(";"),start);
 171                 one=one.Trim();
 172                 if(one.IsEmpty())
 173                         continue;
 174
 175                 CString addr;
 176                 addr = GetServerAddress(one);
 177                 if(addr.IsEmpty())
 178                         continue;
 179
 180
 181                 Address[addr].push_back(one);
 182
 183         }
 184
 185         std::map<CString,std::vector<CString>>::iterator itr1  =  Address.begin();
 186     for(  ;  itr1  !=  Address.end();  ++itr1 )
 187     {
 188         PDNS_RECORD pDnsRecord;
 189                 PDNS_RECORD pNext;
 190
 191                 DnsQuery(itr1->first ,
 192                                     DNS_TYPE_MX,DNS_QUERY_STANDARD,
 193                                             NULL,                   //Contains DNS server IP address.
 194                         &pDnsRecord,                //Resource record that contains the response.
 195                         NULL
 196                                                 );
 197
 198                 CString to;
 199                 to.Empty();
 200                 for(int i=0;i<itr1->second.size();i++)
 201                 {
 202                         to+=itr1->second[i];
 203                         to+=_T(";");
 204                 }
 205                 if(to.IsEmpty())
 206                         continue;
 207
 208                 pNext=pDnsRecord;
 209                 while(pNext)
 210                 {
 211                         if(pNext->wType == DNS_TYPE_MX)
 212                                 if(SendEmail(pNext->Data.MX.pNameExchange,NULL,NULL,false,
 213                                         lpszAddrFrom,to,lpszSubject,lpszBody,lpszCharSet,pStrAryAttach,pStrAryCC,
 214                                         25,pSend,lpszAddrTo))
 215                                         break;
 216                         pNext=pNext->pNext;
 217                 }
 218                 if(pNext == NULL)
 219                         ret = false;
 220
 221                 //SendEmail(itr1.first,NULL,NULL,false,lpszAddrFrom,,lpszFromname);
 222                 DnsRecordListFree(pDnsRecord,DnsFreeRecordList);
 223     }
 224
 225         return ret;
 226 }
 227 BOOL CHwSMTP::SendEmail (
 228                 LPCTSTR lpszSmtpSrvHost,
 229                 LPCTSTR lpszUserName,
 230                 LPCTSTR lpszPasswd,
 231                 BOOL bMustAuth,
 232                 LPCTSTR lpszAddrFrom,
 233                 LPCTSTR lpszAddrTo,
 234                 LPCTSTR lpszSubject,
 235                 LPCTSTR lpszBody,
 236                 LPCTSTR lpszCharSet,                                            // ×Ö·û¼¯ÀàÐÍ£¬ÀýÈç£º·±ÌåÖÐÎÄÕâÀïÓ¦ÊäÈë"big5"£¬¼òÌåÖÐÎÄÊ±ÊäÈë"gb2312"
 237                 CStringArray *pStrAryAttach/*=NULL*/,
 238                 LPCTSTR pStrAryCC/*=NULL*/,
 239                 UINT nSmtpSrvPort,/*=25*/
 240                 LPCTSTR pSender,
 241                 LPCTSTR pToList
 242                 )
 243 {
 244         TRACE ( _T("·¢ËÍÓÊ¼þ£º%s,  %s\n"), lpszAddrTo, lpszBody );
 245         m_StrAryAttach.RemoveAll();
 246
 247         m_StrCC += GET_SAFE_STRING(pStrAryCC);
 248
 249         m_csSmtpSrvHost = GET_SAFE_STRING ( lpszSmtpSrvHost );
 250         if ( m_csSmtpSrvHost.GetLength() <= 0 )
 251         {
 252                 m_csLastError.Format ( _T("Parameter Error!") );
 253                 return FALSE;
 254         }
 255         m_csUserName = GET_SAFE_STRING ( lpszUserName );
 256         m_csPasswd = GET_SAFE_STRING ( lpszPasswd );
 257         m_bMustAuth = bMustAuth;
 258         if ( m_bMustAuth && m_csUserName.GetLength() <= 0 )
 259         {
 260                 m_csLastError.Format ( _T("Parameter Error!") );
 261                 return FALSE;
 262         }
 263
 264         m_csAddrFrom = GET_SAFE_STRING ( lpszAddrFrom );
 265         m_csAddrTo = GET_SAFE_STRING ( lpszAddrTo );
 266 //      m_csFromName = GET_SAFE_STRING ( lpszFromName );
 267 //      m_csReceiverName = GET_SAFE_STRING ( lpszReceiverName );
 268         m_csSubject = GET_SAFE_STRING ( lpszSubject );
 269         m_csBody = GET_SAFE_STRING ( lpszBody );
 270
 271         this->m_csSender = GET_SAFE_STRING(pSender);
 272         this->m_csToList = GET_SAFE_STRING(pToList);
 273
 274         m_nSmtpSrvPort = nSmtpSrvPort;
 275
 276         if ( lpszCharSet && lstrlen(lpszCharSet) > 0 )
 277                 m_csCharSet.Format ( _T("\r\n\tcharset=\"%s\"\r\n"), lpszCharSet );
 278
 279         if      (
 280                         m_csAddrFrom.GetLength() <= 0 || m_csAddrTo.GetLength() <= 0
 281                 )
 282         {
 283                 m_csLastError.Format ( _T("Parameter Error!") );
 284                 return FALSE;
 285         }
 286
 287         if ( pStrAryAttach )
 288         {
 289                 m_StrAryAttach.Append ( *pStrAryAttach );
 290         }
 291         if ( m_StrAryAttach.GetSize() < 1 )
 292                 m_csMIMEContentType = FormatString ( _T( "text/plain; %s" ), m_csCharSet);
 293
 294         // ´´½¨Socket
 295         m_SendSock.Close();
 296         if ( !m_SendSock.Create () )
 297         {
 298                 int nResult = GetLastError();
 299                 m_csLastError.Format ( _T("Create socket failed!") );
 300                 return FALSE;
 301         }
 302
 303         // Á¬½Óµ½·þÎñÆ÷
 304         if ( !m_SendSock.Connect ( m_csSmtpSrvHost, m_nSmtpSrvPort ) )
 305         {
 306                 m_csLastError.Format ( _T("Connect to [ %s ] failed"), m_csSmtpSrvHost );
 307                 TRACE ( _T("%d\n"), GetLastError() );
 308                 return FALSE;
 309         }
 310         if ( !GetResponse( _T("220") ) ) return FALSE;
 311
 312         m_bConnected = TRUE;
 313         BOOL ret= SendEmail();
 314
 315         m_SendSock.Close();
 316
 317         return ret;
 318 }
 319
 320
 321 BOOL CHwSMTP::GetResponse ( LPCTSTR lpszVerifyCode, int *pnCode/*=NULL*/)
 322 {
 323         if ( !lpszVerifyCode || lstrlen(lpszVerifyCode) < 1 )
 324                 return FALSE;
 325
 326         char szRecvBuf[1024] = {0};
 327         int nRet = 0;
 328         char szStatusCode[4] = {0};
 329         nRet = m_SendSock.Receive ( szRecvBuf, sizeof(szRecvBuf) );
 330         TRACE ( _T("Received : %s\r\n"), szRecvBuf );
 331         if ( nRet <= 0 )
 332         {
 333                 m_csLastError.Format ( _T("Receive TCP data failed") );
 334                 return FALSE;
 335         }
 336 //      TRACE ( _T("ÊÕµ½·þÎñÆ÷»ØÓ¦£º%s\n"), szRecvBuf );
 337
 338         memcpy ( szStatusCode, szRecvBuf, 3 );
 339         if ( pnCode ) (*pnCode) = atoi ( szStatusCode );
 340
 341         if ( strcmp ( szStatusCode, CMultiByteString(lpszVerifyCode).GetBuffer() ) != 0 )
 342         {
 343                 m_csLastError.Format ( _T("Received invalid response  : %s"), GetCompatibleString(szRecvBuf,FALSE) );
 344                 return FALSE;
 345         }
 346
 347         return TRUE;
 348 }
 349 BOOL CHwSMTP::SendBuffer(char *buff,int size)
 350 {
 351         if(size<0)
 352                 size=strlen(buff);
 353         if ( !m_bConnected )
 354         {
 355                 m_csLastError.Format ( _T("Didn't connect") );
 356                 return FALSE;
 357         }
 358
 359         if ( m_SendSock.Send ( buff, size ) != size )
 360         {
 361                 m_csLastError.Format ( _T("Socket send data failed") );
 362                 return FALSE;
 363         }
 364
 365         return TRUE;
 366 }
 367 // ÀûÓÃsocket·¢ËÍÊý¾Ý£¬Êý¾Ý³¤¶È²»ÄÜ³¬¹ý10M
 368 BOOL CHwSMTP::Send(CString &str )
 369 {
 370         if ( !m_bConnected )
 371         {
 372                 m_csLastError.Format ( _T("Didn't connect") );
 373                 return FALSE;
 374         }
 375
 376         CMultiByteString cbsData ( str );
 377
 378         TRACE ( _T("Send : %s\r\n"), cbsData.GetBuffer() );
 379         if ( m_SendSock.Send ( cbsData.GetBuffer(), cbsData.GetLength() ) != cbsData.GetLength() )
 380         {
 381                 m_csLastError.Format ( _T("Socket send data failed") );
 382                 return FALSE;
 383         }
 384
 385         return TRUE;
 386 }
 387
 388 BOOL CHwSMTP::SendEmail()
 389 {
 390         BOOL bRet = TRUE;
 391         char szLocalHostName[64] = {0};
 392         gethostname ( (char*)szLocalHostName, sizeof(szLocalHostName) );
 393
 394         // hello£¬ÎÕÊÖ
 395         CString str;
 396         str.Format(_T("HELO %s\r\n"), GetCompatibleString(szLocalHostName,FALSE));
 397         if ( !Send (  str ))
 398         {
 399                 return FALSE;
 400         }
 401         if ( !GetResponse ( _T("250") ) )
 402         {
 403                 return FALSE;
 404         }
 405         // Éí·ÝÑéÖ¤
 406         if ( m_bMustAuth && !auth() )
 407         {
 408                 return FALSE;
 409         }
 410         // ·¢ËÍÓÊ¼þÍ·
 411         if ( !SendHead() )
 412         {
 413                 return FALSE;
 414         }
 415         // ·¢ËÍÓÊ¼þÖ÷Ìâ
 416         if ( !SendSubject() )
 417         {
 418                 return FALSE;
 419         }
 420         // ·¢ËÍÓÊ¼þÕýÎÄ
 421         if ( !SendBody() )
 422         {
 423                 return FALSE;
 424         }
 425         // ·¢ËÍ¸½¼þ
 426         if ( !SendAttach() )
 427         {
 428                 return FALSE;
 429         }
 430         // ½áÊøÓÊ¼þÕýÎÄ
 431         if ( !Send ( CString(_T(".\r\n") ) ) ) return FALSE;
 432         if ( !GetResponse ( _T("250") ) )
 433                 return FALSE;
 434
 435         // ÍË³ö·¢ËÍ
 436         if ( HANDLE_IS_VALID(m_SendSock.m_hSocket) )
 437                 Send ( CString(_T("QUIT\r\n")) );
 438         m_bConnected = FALSE;
 439
 440         return bRet;
 441 }
 442
 443 BOOL CHwSMTP::auth()
 444 {
 445         int nResponseCode = 0;
 446         if ( !Send ( CString(_T("auth login\r\n")) ) ) return FALSE;
 447         if ( !GetResponse ( _T("334"), &nResponseCode ) ) return FALSE;
 448         if ( nResponseCode != 334 )     // ²»ÐèÒªÑéÖ¤ÓÃ»§ÃûºÍÃÜÂë
 449                 return TRUE;
 450
 451         CBase64 Base64Encode;
 452         CMultiByteString cbsUserName ( m_csUserName ), cbsPasswd ( m_csPasswd );
 453         CString csBase64_UserName = GetCompatibleString ( Base64Encode.Encode ( cbsUserName.GetBuffer(), cbsUserName.GetLength() ).GetBuffer(0), FALSE );
 454         CString csBase64_Passwd = GetCompatibleString ( Base64Encode.Encode ( cbsPasswd.GetBuffer(), cbsPasswd.GetLength() ).GetBuffer(0), FALSE );
 455
 456         CString str;
 457         str.Format( _T("%s\r\n"), csBase64_UserName );
 458         if ( !Send ( str ) )
 459                 return FALSE;
 460
 461         if ( !GetResponse ( _T("334") ) )
 462         {
 463                 m_csLastError.Format ( _T("Authentication UserName failed") );
 464                 return FALSE;
 465         }
 466
 467         str.Format(_T("%s\r\n"), csBase64_Passwd );
 468         if ( !Send ( str ) )
 469                 return FALSE;
 470
 471         if ( !GetResponse ( _T("235") ) )
 472         {
 473                 m_csLastError.Format ( _T("Authentication Password failed") );
 474                 return FALSE;
 475         }
 476
 477         return TRUE;
 478 }
 479
 480 BOOL CHwSMTP::SendHead()
 481 {
 482         CString str;
 483         CString name,addr;
 484         GetNameAddress(m_csAddrFrom,name,addr);
 485
 486         str.Format( _T("MAIL From: <%s>\r\n"), addr );
 487         if ( !Send ( str  ) ) return FALSE;
 488
 489         if ( !GetResponse ( _T("250") ) ) return FALSE;
 490
 491         int start=0;
 492         while(start>=0)
 493         {
 494                 CString one=m_csAddrTo.Tokenize(_T(";"),start);
 495                 one=one.Trim();
 496                 if(one.IsEmpty())
 497                         continue;
 498
 499
 500                 GetNameAddress(one,name,addr);
 501
 502                 str.Format(_T("RCPT TO: <%s>\r\n"), addr );
 503                 if ( !Send ( str ) ) return FALSE;
 504                 if ( !GetResponse ( _T("250") ) ) return FALSE;
 505         }
 506
 507 #if 0
 508         for ( int i=0; i<m_StrAryCC.GetSize(); i++ )
 509         {
 510                 str.Format(_T("RCPT TO: <%s>\r\n"), m_StrAryCC.GetAt(i)  );
 511                 if ( !Send ( str ) ) return FALSE;
 512                 if ( !GetResponse ( _T("250") ) ) return FALSE;
 513         }
 514 #endif
 515
 516         if ( !Send ( CString(_T("DATA\r\n") ) ) ) return FALSE;
 517         if ( !GetResponse ( CString(_T("354") )) ) return FALSE;
 518
 519         return TRUE;
 520 }
 521
 522 BOOL CHwSMTP::SendSubject()
 523 {
 524         CString csSubject;
 525         csSubject += _T("Date: ");
 526         COleDateTime tNow = COleDateTime::GetCurrentTime();
 527         if ( tNow > 1 )
 528         {
 529                 csSubject += FormatDateTime (tNow, _T("%a, %d %b %y %H:%M:%S %Z"));
 530         }
 531         csSubject += _T("\r\n");
 532         csSubject += FormatString ( _T("From: %s\r\n"), this->m_csAddrFrom);
 533
 534         csSubject += FormatString ( _T("CC: %s\r\n"), this->m_StrCC);
 535
 536         if(m_csSender.IsEmpty())
 537                 m_csSender =  this->m_csAddrFrom;
 538
 539         csSubject += FormatString ( _T("Sender: %s\r\n"), this->m_csSender);
 540
 541         if(this->m_csToList.IsEmpty())
 542                 m_csToList = m_csReceiverName;
 543
 544         csSubject += FormatString ( _T("To: %s\r\n"), this->m_csToList);
 545
 546         CString m_csToList;
 547
 548         csSubject += FormatString ( _T("Subject: %s\r\n"), m_csSubject );
 549
 550
 551         csSubject += FormatString ( _T("X-Mailer: TortoiseGit\r\nMIME-Version: 1.0\r\nContent-Type: %s\r\n\r\n"),
 552                 m_csMIMEContentType );
 553
 554         return Send ( csSubject );
 555 }
 556
 557 BOOL CHwSMTP::SendBody()
 558 {
 559         CString csBody, csTemp;
 560
 561         if ( m_StrAryAttach.GetSize() > 0 )
 562         {
 563                 csTemp.Format ( _T("%s\r\n\r\n"), m_csNoMIMEText );
 564                 csBody += csTemp;
 565
 566                 csTemp.Format ( _T("--%s\r\n"), m_csPartBoundary );
 567                 csBody += csTemp;
 568
 569                 csTemp.Format ( _T("Content-Type: text/plain\r\n%sContent-Transfer-Encoding: 7Bit\r\n\r\n"),
 570                         m_csCharSet );
 571                 csBody += csTemp;
 572         }
 573
 574         //csTemp.Format ( _T("%s\r\n"), m_csBody );
 575         csBody += m_csBody;
 576         csBody += _T("\r\n");
 577
 578         return Send ( csBody );
 579 }
 580
 581 BOOL CHwSMTP::SendAttach()
 582 {
 583         int nCountAttach = (int)m_StrAryAttach.GetSize();
 584         if ( nCountAttach < 1 ) return TRUE;
 585
 586         for ( int i=0; i<nCountAttach; i++ )
 587         {
 588                 if ( !SendOnAttach ( m_StrAryAttach.GetAt(i) ) )
 589                         return FALSE;
 590         }
 591
 592         return TRUE;
 593 }
 594
 595 BOOL CHwSMTP::SendOnAttach(LPCTSTR lpszFileName)
 596 {
 597         ASSERT ( lpszFileName );
 598         CString csAttach, csTemp;
 599
 600         csTemp = lpszFileName;
 601         CString csShortFileName = csTemp.GetBuffer(0) + csTemp.ReverseFind ( '\\' );
 602         csShortFileName.TrimLeft ( _T("\\") );
 603
 604         csTemp.Format ( _T("--%s\r\n"), m_csPartBoundary );
 605         csAttach += csTemp;
 606
 607         csTemp.Format ( _T("Content-Type: application/octet-stream; file=%s\r\n"), csShortFileName );
 608         csAttach += csTemp;
 609
 610         csTemp.Format ( _T("Content-Transfer-Encoding: base64\r\n") );
 611         csAttach += csTemp;
 612
 613         csTemp.Format ( _T("Content-Disposition: attachment; filename=%s\r\n\r\n"), csShortFileName );
 614         csAttach += csTemp;
 615
 616         DWORD dwFileSize =  hwGetFileAttr(lpszFileName);
 617         if ( dwFileSize > 5*1024*1024 )
 618         {
 619                 m_csLastError.Format ( _T("File [%s] too big. File size is : %s"), lpszFileName, FormatBytes(dwFileSize) );
 620                 return FALSE;
 621         }
 622         char *pBuf = new char[dwFileSize+1];
 623         if ( !pBuf )
 624         {
 625                 ::AfxThrowMemoryException ();
 626                 return FALSE;
 627         }
 628
 629         if(!Send ( csAttach ))
 630                 return FALSE;
 631
 632         CFile file;
 633         CStringA filedata;
 634         try
 635         {
 636                 if ( !file.Open ( lpszFileName, CFile::modeRead ) )
 637                 {
 638                         m_csLastError.Format ( _T("Open file [%s] failed"), lpszFileName );
 639                         return FALSE;
 640                 }
 641                 UINT nFileLen = file.Read ( pBuf, dwFileSize );
 642                 CBase64 Base64Encode;
 643                 filedata = Base64Encode.Encode ( pBuf, nFileLen );
 644                 filedata += _T("\r\n\r\n");
 645         }
 646         catch ( CFileException e )
 647         {
 648                 e.Delete();
 649                 m_csLastError.Format ( _T("Read file [%s] failed"), lpszFileName );
 650                 delete[] pBuf;
 651                 return FALSE;
 652         }
 653
 654         if(!SendBuffer( filedata.GetBuffer() ))
 655                 return FALSE;
 656
 657
 658         delete[] pBuf;
 659
 660         return TRUE;
 661         //return Send ( csAttach );
 662 }
 663
 664 CString CHwSMTP::GetLastErrorText()
 665 {
 666         return m_csLastError;
 667 }
 668
 669
 670 DWORD WINAPI ThreadProc_SendEmail( LPVOID lpParameter )
 671 {
 672         CEMailObject *pEMailObject = (CEMailObject*)lpParameter;
 673         ASSERT ( pEMailObject );
 674
 675         CHwSMTP HwSMTP;
 676         BOOL bRet = HwSMTP.SendEmail (
 677                 pEMailObject->m_csSmtpSrvHost,
 678                 pEMailObject->m_csUserName,
 679                 pEMailObject->m_csPasswd,
 680                 pEMailObject->m_bMustAuth,
 681                 pEMailObject->m_csAddrFrom,
 682                 pEMailObject->m_csAddrTo,
 683                 pEMailObject->m_csSubject,
 684                 pEMailObject->m_csBody,
 685                 pEMailObject->m_csCharSet,
 686                 &pEMailObject->m_StrAryAttach,
 687                 pEMailObject->m_StrCC,
 688                 pEMailObject->m_nSmtpSrvPort,
 689                 pEMailObject->m_csSender
 690                 );
 691         if ( !bRet)
 692         {
 693 #ifdef _DEBUG
 694                 CString csError = HwSMTP.GetLastErrorText ();
 695                 csError = FormatString ( _T("Send a email to [%s] failed."), pEMailObject->m_csSmtpSrvHost );
 696                 AfxMessageBox ( csError );
 697 #endif
 698         }
 699
 700         m_CSFor__g_PtrAry_Threads.Lock ();
 701         int nFindPos = FindFromArray ( g_PtrAry_Threads, pEMailObject->m_hThread );
 702         if ( nFindPos >= 0 )
 703                 g_PtrAry_Threads.RemoveAt ( nFindPos );
 704         m_CSFor__g_PtrAry_Threads.Unlock ();
 705
 706         delete pEMailObject;
 707         return bRet;
 708 }
 709
 710 //
 711 // ÓÃ SMTP ·þÎñ·¢ËÍµç×ÓÓÊ¼þ£¬Èç¹ûÉèÖÃ²ÎÊý bViaThreadSend=TRUE£¬ÄÇÔÚ³ÌÐò½áÊøÊ±Ó¦¸ÃÔÚ ExitInstance() ÖÐµ÷ÓÃ EndOfSMTP() º¯Êý
 712 //
 713 BOOL SendEmail (
 714                                 BOOL bViaThreadSend,
 715                                 LPCTSTR lpszSmtpSrvHost,
 716                                 LPCTSTR lpszUserName,
 717                                 LPCTSTR lpszPasswd,
 718                                 BOOL bMustAuth,
 719                                 LPCTSTR lpszAddrFrom,
 720                                 LPCTSTR lpszAddrTo,
 721                                 LPCTSTR lpszFromName,
 722                                 LPCTSTR lpszReceiverName,
 723                                 LPCTSTR lpszSubject,
 724                                 LPCTSTR lpszBody,
 725                                 LPCTSTR lpszCharSet/*=NULL*/,
 726                                 CStringArray *pStrAryAttach/*=NULL*/,
 727                                 LPCTSTR pStrAryCC/*=NULL*/,
 728                                 UINT nSmtpSrvPort/*=25*/,
 729                                 LPCTSTR lpszSender,
 730                                 LPCTSTR lpszToList
 731                                 )
 732 {
 733         if ( !lpszSmtpSrvHost || lstrlen(lpszSmtpSrvHost) < 1 ||
 734                 !lpszSubject || lstrlen(lpszSubject) < 1 ||
 735                 !lpszBody || lstrlen(lpszBody) < 1 )
 736         {
 737                 AfxMessageBox ( _T("Parameter error !") );
 738                 return FALSE;
 739         }
 740
 741         CEMailObject *pEMailObject = new CEMailObject (
 742                 lpszSmtpSrvHost,
 743                 lpszUserName,
 744                 lpszPasswd,
 745                 bMustAuth,
 746                 lpszAddrFrom,
 747                 lpszAddrTo,
 748                 lpszFromName,
 749                 lpszReceiverName,
 750                 lpszSubject,
 751                 lpszBody,
 752                 lpszCharSet,
 753                 pStrAryAttach,
 754                 pStrAryCC,
 755                 nSmtpSrvPort,
 756                 lpszSender,
 757                 lpszToList
 758                 );
 759         if ( !pEMailObject ) return FALSE;
 760
 761         BOOL bRet = FALSE;
 762         if ( bViaThreadSend )
 763         {
 764                 DWORD dwThreadId = 0;
 765                 pEMailObject->m_hThread = ::CreateThread ( NULL, 0, ::ThreadProc_SendEmail, pEMailObject, CREATE_SUSPENDED, &dwThreadId );
 766                 bRet = HANDLE_IS_VALID(pEMailObject->m_hThread);
 767                 m_CSFor__g_PtrAry_Threads.Lock();
 768                 g_PtrAry_Threads.Add ( pEMailObject->m_hThread );
 769                 m_CSFor__g_PtrAry_Threads.Unlock();
 770                 ResumeThread ( pEMailObject->m_hThread );
 771         }
 772         else
 773         {
 774                 bRet = (BOOL)ThreadProc_SendEmail ( pEMailObject );
 775         }
 776
 777         return bRet;
 778 }
 779
 780 void EndOfSMTP ()
 781 {
 782         // µÈ´ýËùÓÐÏß³ÌÖ´ÐÐÍê±Ï
 783         for ( int i=0; i<g_PtrAry_Threads.GetSize(); i++ )
 784         {
 785                 HANDLE hThread = (HANDLE)g_PtrAry_Threads.GetAt(i);
 786                 if ( HANDLE_IS_VALID(hThread) )
 787                 {
 788                         WaitForThreadEnd ( &hThread, 30*1000 );
 789                 }
 790         }
 791         g_PtrAry_Threads.RemoveAll ();
 792 }
 793
 794
 795 //
 796 // ½«×Ö·û´® lpszOrg ×ª»»Îª¶à×Ö½ÚµÄ×Ö·û´®£¬Èç¹û»¹ÒªÊ¹ÓÃ¶à×Ö·û´®µÄ³¤¶È£¬¿ÉÒÔÓÃÒÔÏÂ·½Ê½À´Ê¹ÓÃÕâ¸öÀà£º
 797 // CMultiByteString MultiByteString(_T("UNICODE×Ö·û´®"));
 798 // printf ( "ANSI ×Ö·û´®Îª£º %s£¬ ×Ö·û¸öÊýÎª£º %d £¬ ³¤¶ÈÎª£º %d×Ö½Ú\n", MultiByteString.GetBuffer(), MultiByteString.GetLength(), MultiByteString.GetSize() );
 799 //
 800 CMultiByteString::CMultiByteString( LPCTSTR lpszOrg, int nOrgStringEncodeType/*=STRING_IS_SOFTCODE*/, OUT char *pOutBuf/*=NULL*/, int nOutBufSize/*=0*/ )
 801 {
 802         m_bNewBuffer = FALSE;
 803         m_pszData = NULL;
 804         m_nDataSize = 0;
 805         m_nCharactersNumber = 0;
 806         if ( !lpszOrg ) return;
 807
 808         // ÅÐ¶ÏÔÊ¼×Ö·û´®µÄ±àÂë·½Ê½
 809         BOOL bOrgIsUnicode = FALSE;
 810         if ( nOrgStringEncodeType == STRING_IS_MULTICHARS ) bOrgIsUnicode = FALSE;
 811         else if ( nOrgStringEncodeType == STRING_IS_UNICODE ) bOrgIsUnicode = TRUE;
 812         else
 813         {
 814 #ifdef UNICODE
 815                 bOrgIsUnicode = TRUE;
 816 #else
 817                 bOrgIsUnicode = FALSE;
 818 #endif
 819         }
 820
 821         // ¼ÆËã×Ö·û´®¸öÊýºÍÐèÒªµÄÄ¿±ê»º³å´óÐ¡
 822         if ( bOrgIsUnicode )
 823         {
 824                 m_nCharactersNumber = (int)wcslen((WCHAR*)lpszOrg);
 825                 m_nDataSize = (m_nCharactersNumber + 1) * sizeof(WCHAR);
 826         }
 827         else
 828         {
 829                 m_nCharactersNumber = (int)strlen((char*)lpszOrg);
 830                 m_nDataSize = (m_nCharactersNumber + 1) * sizeof(char);
 831         }
 832
 833         // Ê¹ÓÃµ÷ÓÃÕß´«ÈëµÄ»º³å
 834         if ( pOutBuf && nOutBufSize > 0 )
 835         {
 836                 m_pszData = pOutBuf;
 837                 m_nDataSize = nOutBufSize;
 838         }
 839         // ×Ô¼ºÉêÇëÄÚ´æ»º³å
 840         else
 841         {
 842                 m_pszData = (char*)new BYTE[m_nDataSize];
 843                 if ( !m_pszData )
 844                 {
 845                         ::AfxThrowMemoryException ();
 846                         return;
 847                 }
 848                 m_bNewBuffer = TRUE;
 849         }
 850         memset ( m_pszData, 0, m_nDataSize );
 851
 852         if ( bOrgIsUnicode )
 853         {
 854                 m_nCharactersNumber = WideCharToMultiByte ( CP_ACP, 0, (LPCWSTR)lpszOrg, m_nCharactersNumber, (LPSTR)m_pszData, m_nDataSize/sizeof(char)-1, NULL, NULL );
 855                 if ( m_nCharactersNumber < 1 ) m_nCharactersNumber = (int)strlen ( m_pszData );
 856         }
 857         else
 858         {
 859                 m_nCharactersNumber = __min ( m_nCharactersNumber, (int)(m_nDataSize/sizeof(char)-1) );
 860                 strncpy ( m_pszData, (const char*)lpszOrg, m_nCharactersNumber );
 861                 m_nCharactersNumber = (int)strlen ( m_pszData );
 862         }
 863         m_nDataSize = ( m_nCharactersNumber + 1 ) * sizeof(char);
 864 }
 865
 866 CMultiByteString::~CMultiByteString ()
 867 {
 868         if ( m_bNewBuffer && m_pszData )
 869         {
 870                 delete[] m_pszData;
 871         }
 872 }
 873
 874 //
 875 // ½« lpszOrg ×ª»»Îª¸Ã³ÌÐòÊ¹ÓÃµÄ±àÂë×Ö·û´®£¬Èç¹û¸Ã³ÌÐòÊÇ UNICODE ¾Í×ªÎª UNICODE£¬Èç¹ûÊÇ ANSI ¾Í×ªÎª ANSI µÄ
 876 //
 877 CString GetCompatibleString ( LPVOID lpszOrg, BOOL bOrgIsUnicode, int nOrgLength/*=-1*/ )
 878 {
 879         if ( !lpszOrg ) return _T("");
 880
 881         TRY
 882         {
 883 #ifdef UNICODE
 884                 if ( bOrgIsUnicode )
 885                 {
 886                         if ( nOrgLength > 0 )
 887                         {
 888                                 WCHAR *szRet = new WCHAR[nOrgLength+1];
 889                                 if ( !szRet ) return _T("");
 890                                 memset ( szRet, 0, (nOrgLength+1)*sizeof(WCHAR) );
 891                                 memcpy ( szRet, lpszOrg, nOrgLength*sizeof(WCHAR) );
 892                                 CString csRet = szRet;
 893                                 delete[] szRet;
 894                                 return csRet;
 895                         }
 896                         else if ( nOrgLength == 0 )
 897                                 return _T("");
 898                         else
 899                                 return (LPCTSTR)lpszOrg;
 900                 }
 901
 902                 if ( nOrgLength < 0 )
 903                         nOrgLength = (int)strlen((const char*)lpszOrg);
 904                 int nWideCount = nOrgLength + 1;
 905                 WCHAR *wchar = new WCHAR[nWideCount];
 906                 if ( !wchar ) return _T("");
 907                 memset ( wchar, 0, nWideCount*sizeof(WCHAR) );
 908                 ::MultiByteToWideChar(CP_ACP, 0, (LPCSTR)lpszOrg, nOrgLength, wchar, nWideCount);
 909                 CString csRet = wchar;
 910                 delete[] wchar;
 911                 return csRet;
 912 #else
 913                 if ( !bOrgIsUnicode )
 914                 {
 915                         if ( nOrgLength > 0 )
 916                         {
 917                                 char *szRet = new char[nOrgLength+1];
 918                                 if ( !szRet ) return _T("");
 919                                 memset ( szRet, 0, (nOrgLength+1)*sizeof(char) );
 920                                 memcpy ( szRet, lpszOrg, nOrgLength*sizeof(char) );
 921                                 CString csRet = szRet;
 922                                 delete[] szRet;
 923                                 return csRet;
 924                         }
 925                         else if ( nOrgLength == 0 )
 926                                 return _T("");
 927                         else
 928                                 return (LPCTSTR)lpszOrg;
 929                 }
 930
 931                 if ( nOrgLength < 0 )
 932                         nOrgLength = (int)wcslen((WCHAR*)lpszOrg);
 933                 int nMultiByteCount = nOrgLength + 1;
 934                 char *szMultiByte = new char[nMultiByteCount];
 935                 if ( !szMultiByte ) return _T("");
 936                 memset ( szMultiByte, 0, nMultiByteCount*sizeof(char) );
 937                 ::WideCharToMultiByte ( CP_ACP, 0, (LPCWSTR)lpszOrg, nOrgLength, (LPSTR)szMultiByte, nMultiByteCount, NULL, NULL );
 938                 CString csRet = szMultiByte;
 939                 delete[] szMultiByte;
 940                 return csRet;
 941 #endif
 942         }
 943         CATCH_ALL(e)
 944         {
 945                 THROW_LAST ();
 946         }
 947         END_CATCH_ALL
 948
 949                 return _T("");
 950 }
 951
 952 CString FormatDateTime ( COleDateTime &DateTime, LPCTSTR pFormat )
 953 {
 954         // If null, return empty string
 955         if ( DateTime.GetStatus() == COleDateTime::null || DateTime.GetStatus() == COleDateTime::invalid )
 956                 return _T("");
 957
 958         UDATE ud;
 959         if (S_OK != VarUdateFromDate(DateTime.m_dt, 0, &ud))
 960         {
 961                 return _T("");
 962         }
 963
 964         TCHAR *weeks[]={_T("Sun"),_T("Mon"),_T("Tue"),_T("Wen"),_T("Thu"),_T("Fri"),_T("Sat")};
 965         TCHAR *month[]={_T("JAN"),_T("FEB"),_T("MAR"),_T("APR"),
 966                                    _T("MAY"),_T("JUN"),_T("JUL"),_T("AUG"),
 967                                    _T("SEP"),_T("OCT"),_T("NOV"),_T("DEC")};
 968
 969         TIME_ZONE_INFORMATION stTimeZone;
 970         GetTimeZoneInformation(&stTimeZone);
 971
 972         CString strDate;
 973         strDate.Format(_T("%s, %d %s %02d %d:%d:%d %c%04d")
 974                 ,weeks[ud.st.wDayOfWeek],
 975                 ud.st.wDay,month[ud.st.wMonth-1],ud.st.wYear%100,ud.st.wHour,
 976                 ud.st.wMinute,ud.st.wSecond,
 977                 stTimeZone.Bias>0?_T('-'):_T('+'),
 978                 abs(stTimeZone.Bias*10/6)
 979                 );
 980         return strDate;
 981 }
 982
 983 CString FormatString ( LPCTSTR lpszStr, ... )
 984 {
 985         TCHAR *buf = NULL;
 986         // Ñ»·¸ñÊ½»¯×Ö·û´®£¬Èç¹û»º³å²»¹»Ôò½«»º³å¼Ó´óÈ»ºóÖØÊÔÒÔ±£Ö¤»º³å¹»ÓÃÍ¬Ê±ÓÖ²»ÀË·Ñ
 987         for ( int nBufCount = 1024; nBufCount<5*1024*1024; nBufCount += 1024 )
 988         {
 989                 buf = new TCHAR[nBufCount];
 990                 if ( !buf )
 991                 {
 992                         ::AfxThrowMemoryException ();
 993                         return _T("");
 994                 }
 995                 memset ( buf, 0, nBufCount*sizeof(TCHAR) );
 996
 997                 va_list  va;
 998                 va_start (va, lpszStr);
 999                 int nLen = _vsnprintf_hw ((TCHAR*)buf, nBufCount-sizeof(TCHAR), lpszStr, va);
1000                 va_end(va);
1001                 if ( nLen <= (int)(nBufCount-sizeof(TCHAR)) )
1002                         break;
1003                 delete[] buf; buf = NULL;
1004         }
1005         if ( !buf )
1006         {
1007                 return _T("");
1008         }
1009
1010         CString csMsg = buf;
1011         delete[] buf; buf = NULL;
1012         return csMsg;
1013 }
1014
1015 /********************************************************************************
1016 * Function Type :       Global
1017 * Parameter             :       lpFileName      -       ÎÄ¼þÂ·¾¶
1018 * Return Value  :       -1                      -       Ê§°Ü
1019 *                                       >=0                     -       ÎÄ¼þ´óÐ¡
1020 * Description   :       »ñÈ¡ÎÄ¼þÊôÐÔ ( ÎÄ¼þ´óÐ¡¡¢´´½¨Ê±¼ä )
1021 *********************************************************************************/
1022 int hwGetFileAttr ( LPCTSTR lpFileName, OUT CFileStatus *pFileStatus/*=NULL*/ )
1023 {
1024         if ( !lpFileName || lstrlen(lpFileName) < 1 ) return -1;
1025
1026         CFileStatus fileStatus;
1027         fileStatus.m_attribute = 0;
1028         fileStatus.m_size = 0;
1029         memset ( fileStatus.m_szFullName, 0, sizeof(fileStatus.m_szFullName) );
1030         BOOL bRet = FALSE;
1031         TRY
1032         {
1033                 if ( CFile::GetStatus(lpFileName,fileStatus) )
1034                 {
1035                         bRet = TRUE;
1036                 }
1037         }
1038         CATCH (CFileException, e)
1039         {
1040                 ASSERT ( FALSE );
1041                 bRet = FALSE;
1042         }
1043         CATCH_ALL(e)
1044         {
1045                 ASSERT ( FALSE );
1046                 bRet = FALSE;
1047         }
1048         END_CATCH_ALL;
1049
1050         if ( pFileStatus )
1051         {
1052                 pFileStatus->m_ctime = fileStatus.m_ctime;
1053                 pFileStatus->m_mtime = fileStatus.m_mtime;
1054                 pFileStatus->m_atime = fileStatus.m_atime;
1055                 pFileStatus->m_size = fileStatus.m_size;
1056                 pFileStatus->m_attribute = fileStatus.m_attribute;
1057                 pFileStatus->_m_padding = fileStatus._m_padding;
1058                 lstrcpy ( pFileStatus->m_szFullName, fileStatus.m_szFullName );
1059
1060         }
1061
1062         return (int)fileStatus.m_size;
1063 }
1064
1065 //
1066 // ½«Ò»¸ö±íÊ¾×Ö½ÚµÄÊýÓÃ¿É¶ÁÐÔºÃµÄ×Ö·û´®À´±íÊ¾£¬ÀýÈç½« 12345678 ×Ö½Ú×ª»»Îª£º
1067 // 11.77M
1068 // nFlag        -       0 : ×Ô¶¯Æ¥Åäµ¥Î»
1069 //                              1 : ÒÔ Kb Îªµ¥Î»
1070 //                              2 : ÒÔ Mb Îªµ¥Î»
1071 //                              3 : ÒÔ Gb Îªµ¥Î»
1072 //
1073 CString FormatBytes ( double fBytesNum, BOOL bShowUnit/*=TRUE*/, int nFlag/*=0*/ )
1074 {
1075         CString csRes;
1076         if ( nFlag == 0 )
1077         {
1078                 if ( fBytesNum >= 1024.0 && fBytesNum < 1024.0*1024.0 )
1079                         csRes.Format ( _T("%.2f%s"), fBytesNum / 1024.0, bShowUnit?_T(" K"):_T("") );
1080                 else if ( fBytesNum >= 1024.0*1024.0 && fBytesNum < 1024.0*1024.0*1024.0 )
1081                         csRes.Format ( _T("%.2f%s"), fBytesNum / (1024.0*1024.0), bShowUnit?_T(" M"):_T("") );
1082                 else if ( fBytesNum >= 1024.0*1024.0*1024.0 )
1083                         csRes.Format ( _T("%.2f%s"), fBytesNum / (1024.0*1024.0*1024.0), bShowUnit?_T(" G"):_T("") );
1084                 else
1085                         csRes.Format ( _T("%.2f%s"), fBytesNum, bShowUnit?_T(" B"):_T("") );
1086         }
1087         else if ( nFlag == 1 )
1088         {
1089                 csRes.Format ( _T("%.2f%s"), fBytesNum / 1024.0, bShowUnit?_T(" K"):_T("") );
1090         }
1091         else if ( nFlag == 2 )
1092         {
1093                 csRes.Format ( _T("%.2f%s"), fBytesNum / (1024.0*1024.0), bShowUnit?_T(" M"):_T("") );
1094         }
1095         else if ( nFlag == 3 )
1096         {
1097                 csRes.Format ( _T("%.2f%s"), fBytesNum / (1024.0*1024.0*1024.0), bShowUnit?_T(" G"):_T("") );
1098         }
1099
1100         return csRes;
1101 }
1102
1103 //
1104 // µÈ´ýÏß³ÌÍË³ö
1105 //
1106 BOOL WaitForThreadEnd ( HANDLE *phThread, DWORD dwWaitTime /*=10*1000*/ )
1107 {
1108         BOOL bRet = TRUE;
1109         ASSERT ( phThread );
1110         if ( !(*phThread) ) return TRUE;
1111         if ( ::WaitForSingleObject ( *phThread, dwWaitTime ) == WAIT_TIMEOUT )
1112         {
1113                 bRet = FALSE;
1114                 ::TerminateThread ( *phThread, 0 );
1115         }
1116         ::CloseHandle ( *phThread );
1117         (*phThread) = NULL;
1118         return bRet;
1119 }