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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Email客户端 > 查看源码
SmartMailSvr.cpp
资源名称：SmartMailSvr　[点击查看]
上传用户：qdlutongda
上传日期：2007-01-14
资源大小：133k
文件大小：94k
源码类别：

Email客户端

开发平台：

Visual C++

SmartMailSvr.cpp：源码内容
  1. // SmartMailSvr.cpp : Defines the entry point for the console application.
  2. //
  4. #include "stdafx.h"
  5. #include "SmartMailSvr.h"
  7. #include "MailService.h"
  8. #include "dnsmx.h"
  9. #include "Encoder.h"
  11. #ifdef _DEBUG
  12. #define new DEBUG_NEW
  13. #undef THIS_FILE
  14. static char THIS_FILE[] = __FILE__;
  15. #endif
  17. #define MAXMESSAGELENGTH 255
  18. #define CURVER "1.0" //current version
  19. #define SOCKET_SIZE  1024
  20. /////////////////////////////////////////////////////////////////////////////
  21. // The one and only application object
  22. CWinApp theApp;
  24. typedef struct
  25. {
  26. char sender[50];
  27. char recver[50];
  28. char title[50];
  29. char time[20];
  30. long size;
  31. }_UDPPacketInfo;
  33. typedef struct
  34. {
  35. SOCKET sock;
  36. char fname[255];
  37. }_SendPop3Param;
  39. int gSocketUseCount = 0; //test
  40. /*************     变量    ****************/
  41. //TCP SOCKET服务对象
  42. SOCKET m_SocketPop3;
  43. SOCKET m_SocketSmtp;
  44. //UDP SOCKET对象
  45. UINT m_nUDPPort;
  46. CString m_strUDPIP;
  47. SOCKET m_UdpSocket;
  48. //FD_SET
  49. fd_set fdset, rfdset;
  51. //保存Socket连接的数组
  52. //CArray<SocketInfo,SocketInfo>m_SocketList;
  53. SocketInfo m_SocketList[SOCKET_SIZE];
  54. //要删除得邮件列表
  55. CArray<DeleteInfo,DeleteInfo>m_DeleteList;
  56. //m_DeleteList的临界区
  57. CRITICAL_SECTION m_csDeleteList;
  58. //通过其他SMTP Server发送的列表
  59. CArray<SMTPForwardInfo,SMTPForwardInfo> m_SMTPForwardList;
  60. //m_SMTPForwardList的临界区
  61. CRITICAL_SECTION m_csSMTPForward;
  63. //上述Socket对应的服务运行状态
  64. bool m_bPop3Allowed = false;
  65. bool m_bSmtpAllowed = false;
  66. bool m_bWebMailAllowed = false;
  67. bool m_bTelnetAllowed = false;
  68. //路径
  69. CString m_strExePath;
  71. //COM对象
  72. IMailSvrConfigCtrl* m_pMailConfig = NULL;
  73. IMailDB* m_pMailDB = NULL;
  74. //Log对象
  75. CLogFile m_logFile;
  77. //POP3 Message
  78. char pop3_msg00[MAXMESSAGELENGTH]; //+OK inetserv ready. %s
  79. char pop3_msg01[MAXMESSAGELENGTH]; //+OK HELO
  80. char pop3_msg02[MAXMESSAGELENGTH]; //-ERR unknown message
  81. char pop3_msg03[MAXMESSAGELENGTH]; //+OK user accepted
  82. char pop3_msg04[MAXMESSAGELENGTH]; //-ERR invalid username
  83. char pop3_msg05[MAXMESSAGELENGTH]; //welcome user!
  84. char pop3_msg06[MAXMESSAGELENGTH]; //wrong password for this user, try again!
  85. char pop3_msg07[MAXMESSAGELENGTH]; //OK closing connection
  86. char pop3_msg08[MAXMESSAGELENGTH]; // message not found
  87. char pop3_msg09[MAXMESSAGELENGTH]; // ok, rset
  88. char pop3_msg10[MAXMESSAGELENGTH]; // -ERR no data found
  89. char pop3_msg11[MAXMESSAGELENGTH]; // -ERR nothing to delete
  90. char pop3_msg12[MAXMESSAGELENGTH]; // +OK Message deleted
  91. char pop3_msg13[MAXMESSAGELENGTH]; // -ERR unknown command
  93. /*************     函数     ****************/
  94. bool Ini_MailCom(); //初始化COM，并连接数据库
  95. void Release_MailCom(); //释放COM
  96. UINT main_mailsvr(LPVOID); //主线程函数
  97. UINT Pop3_AcceptThread(LPVOID); //POP3接收连接线程函数
  98. UINT Smtp_AcceptThread(LPVOID); //SMTP接收连接线程函数
  100. UINT Pop3_ReceiveThread(LPVOID); //接收处理POP数据线程函数
  101. UINT Smtp_ReceiveThread(LPVOID); //接收处理SMTP数据线程函数
  103. void ReadPop3(char* buf, int nDataLen, int i); //处理POP3连接的数据处理
  104. void ReadSmtp(char* buf, int nDataLen, int i); //处理SMTP连接的数据处理
  106. void SendPop3Mail(SOCKET s, char* fileName); //向客户端发送Mail文件
  107. //UINT SendPop3Mail(LPVOID); //向客户端发送Mail文件
  109. void DeleteCRLF(char *string);
  110. void ProcessNewMail(CString CTL, CString Fname,CString Sender);
  111. void LogError (CString expr);
  112. void SendSMTP();
  113. int  SendSmtpMail(int litem);
  114. int  SendSmtpMailDirect(int litem);
  115. BOOL IsLocalUser(const char* tempstr); //判断是否是本地用户
  116. bool SendUDPData(_UDPPacketInfo udpData);
  117. bool WriteMailInfoToDB(CString strSender, CString strRecver, CString strTitle, CString strTime,  long lSize);
  118. bool DealMailInfo(CString strFileName, CString strSender, CString strRecver);
  119. bool AddMessageID(CString strFileName); //加入Message-ID
  121. using namespace std;
  123. int _tmain(int argc, TCHAR* argv[], TCHAR* envp[])
  124. {
  125. int nRetCode = 0;
  127. // initialize MFC and print and error on failure
  128. if (!AfxWinInit(::GetModuleHandle(NULL), NULL, ::GetCommandLine(), 0))
  129. {
  130. // TODO: change error code to suit your needs
  131. //cerr << _T("Fatal Error: MFC initialization failed") << endl;
  132. nRetCode = 1;
  133. }
  134. else
  135. {
  136. // TODO: code your application's behavior here.
  137. CMailService serv;
  139. // RegisterService() checks the parameterlist for predefined switches
  140. // (such as -d or -i etc.; see NTService.h for possible switches) and
  141. // starts the service's functionality.
  142. // You can use the return value from "RegisterService()"
  143. // as your exit-code.
  144. return serv.RegisterService(argc, argv);
  146. }
  148. return nRetCode;
  149. }
  151. bool Ini_MailCom()
  152. {
  153. //设置Log对象的路径
  154. CString strExePath;
  155. LPTSTR lpPath;
  156. lpPath = strExePath.GetBuffer(MAX_PATH);
  157. ::GetModuleFileName(NULL, lpPath, MAX_PATH);
  158. strExePath.ReleaseBuffer();
  159. int nPos = strExePath.ReverseFind('\');
  160. int nSize = strExePath.GetLength();
  161. m_logFile.SetLogFilePath(strExePath.Left(nPos + 1));
  164. CString strLog;
  166. //初始化COM库
  167. HRESULT hr;
  168. hr = ::CoInitialize(NULL);
  169. if(FAILED(hr))
  170. {
  171. m_logFile.WriteLog("CoInitialize() failed");
  172. return false;
  173. }
  174. //创建IMailSvrConfigCtrl接口指针 
  175. hr = ::CoCreateInstance(CLSID_MailSvrConfigCtrl, 
  176. NULL, 
  177. CLSCTX_INPROC_SERVER, 
  178. IID_IMailSvrConfigCtrl, 
  179. (VOID FAR**)&m_pMailConfig);
  180. if(FAILED(hr))
  181. {
  182. m_logFile.WriteLog("CoCreateInstance() for IMailSvrConfigCtrl failed");
  183. return false;
  184. }
  185. //创建IMailDB接口指针 
  186. hr = ::CoCreateInstance(CLSID_MailDB, 
  187. NULL, 
  188. CLSCTX_INPROC_SERVER, 
  189. IID_IMailDB, 
  190. (VOID FAR**)&m_pMailDB);
  191. if(FAILED(hr))
  192. {
  193. m_logFile.WriteLog("CoCreateInstance() for IMailDB failed");
  194. return false;
  195. }
  196. //检查参数配置是否正确
  197. short nCheckResult = 0;
  198. m_pMailConfig->CheckConfig(&nCheckResult);
  199. if(nCheckResult == 0)
  200. {
  201. m_logFile.WriteLog("Lack or Invalid Config In the Register");
  202. return false;
  203. }
  204. //连接数据库
  205. BSTR BstrConnectionString;
  206. m_pMailConfig->GetDBConnectionConfig(&BstrConnectionString);
  207. m_pMailDB->SetMailSvrDBConfig(BstrConnectionString);
  208. hr = m_pMailDB->ConnectMailSvrDB();
  209. if(FAILED(hr))
  210. {
  211. strLog.Format("Connect MailDB, ConnectionString=%S Failed", BstrConnectionString);
  212. m_logFile.WriteLog(strLog);
  213. return false;
  214. }
  215. strLog.Format("Connect MailDB, ConnectionString=%S Succeed", BstrConnectionString);
  216. m_logFile.WriteLog(strLog);
  218. //设置用户信息表名字段
  219. BSTR BstrUserTableName, BstrUserIDField, BstrUserPasswordField, BstrNameField;
  220. m_pMailConfig->GetUserTableConfig(&BstrUserTableName, &BstrUserIDField, &BstrUserPasswordField, &BstrNameField);
  221. m_pMailDB->SetMailUserTableConfig(BstrUserTableName, BstrUserIDField, BstrUserPasswordField, BstrNameField);
  222. strLog.Format("User Table Info: TableName=%S, UserIDField=%S, UserPasswordField=%S, UserNameField=%S", 
  223.    BstrUserTableName, BstrUserIDField, BstrUserPasswordField, BstrNameField);
  224. m_logFile.WriteLog(strLog);
  226. //设置接收的邮件信息表名和字段
  227. BSTR BstrRecvTableName, BstrTimeField, BstrTitleField, BstrSenderField, BstrRecverField, BstrSizeField;
  228. m_pMailConfig->GetRecvMailInfoTableConfig(&BstrRecvTableName, &BstrTimeField, &BstrTitleField, 
  229.  &BstrSenderField, &BstrRecverField, &BstrSizeField);
  230. m_pMailDB->SetMailRecvTableConfig(BstrRecvTableName, BstrTimeField, BstrTitleField, 
  231.   BstrSenderField, BstrRecverField, BstrSizeField);
  232. strLog.Format("RecvInfo Table Info: TableName=%S, TimeField=%S, TitleField=%S, SenderField=%S, RecverField=%S, SizeField=%S",
  233. BstrRecvTableName, BstrTimeField, BstrTitleField, BstrSenderField, BstrRecverField, BstrSizeField);
  234. m_logFile.WriteLog(strLog);
  236. WSADATA WSData;
  237. if (WSAStartup(MAKEWORD(1, 1), &WSData) ) 
  238. {
  239. m_logFile.WriteLog("Load socket lib failed");
  240. return false;
  241. }
  244. char chPath[256];
  245. GetModuleFileName(NULL,chPath,256);
  247. m_strExePath=chPath;
  249. for(int i=m_strExePath.GetLength();i>=0;i--)
  250. {
  251. if(m_strExePath.Mid(i,1)=="\"){
  252. m_strExePath=m_strExePath.Left(i);
  253. break;
  254. }
  255. }
  256. //创建默认文件夹
  257. CString strMailPath;
  258. strMailPath.Format("%s\mail", m_strExePath);
  259. CreateDirectory((LPCTSTR)strMailPath, NULL);
  260. strMailPath.Format("%s\mail\unknown", m_strExePath);
  261. CreateDirectory((LPCTSTR)strMailPath, NULL);
  262. // mkdir("mail");
  263. // mkdir("mail\unknown");
  265. short nCount;
  266. BSTR BstrUserID, BstrPass;
  267. CString strUserPath;
  268. m_pMailDB->GetUser(&nCount);
  269. for(int j=0; j<nCount; j++)
  270. {
  271. m_pMailDB->GetUserInfo(j, &BstrUserID, &BstrPass);
  272. bstr_t bstrUserID(BstrUserID, FALSE);
  273. strUserPath.Format("%s\mail\%s", m_strExePath, (char*)bstrUserID);
  274. CreateDirectory((LPCTSTR)strUserPath, NULL);
  275. }
  277. return true;
  278. }
  280. void Release_MailCom()
  281. {
  282. //释放IMailSvrConfigCtrl接口指针
  283. if(m_pMailConfig != NULL)
  284. m_pMailConfig->Release();
  286. //释放IMailDB接口指针
  287. if(m_pMailDB != NULL)
  288. {
  289. m_pMailDB->DisConnectMailSvrDB();
  290. m_pMailDB->Release();
  291. }
  293. //释放COM库
  294. ::CoUninitialize();
  296. //释放SOCKET库
  297. WSACleanup();
  298. }
  300. UINT main_mailsvr(LPVOID pParam)
  301. {
  302. if((m_pMailConfig == NULL)||(m_pMailDB == NULL))
  303. {
  304. m_logFile.WriteLog("Invalid IMailConfigCtrl or IMailDB pointer");
  305. return 0;
  306. }
  307. //初始化临界区
  308. ::InitializeCriticalSection(&m_csDeleteList);
  309. ::InitializeCriticalSection(&m_csSMTPForward);
  311. CString strLog;
  313. short nPop3Port, nSmtpPort;
  314. short nWebMailFlag, nWebMailPort;
  315. short nTelnetFlag, nTelnetPort;
  317. //读取参数
  318. m_pMailConfig->GetPop3Port(&nPop3Port);
  319. m_pMailConfig->GetSmtpPort(&nSmtpPort);
  320. m_pMailConfig->GetWebMailConfig(&nWebMailFlag, &nWebMailPort);
  321. m_pMailConfig->GetTelnetConfig(&nTelnetFlag, &nTelnetPort);
  323. //创建UDP SOCKET对象
  324. BSTR BstrUdpAdd;
  325. short nUdpPort;
  326. m_pMailConfig->GetUDPConfig(&BstrUdpAdd, &nUdpPort);
  327. _bstr_t bstrUdpAdd(BstrUdpAdd, FALSE);
  328. m_strUDPIP = (char*)bstrUdpAdd;
  329. m_nUDPPort = nUdpPort;
  331. FD_ZERO(&fdset);
  332. FD_ZERO(&rfdset);
  334. m_UdpSocket = socket(AF_INET, SOCK_DGRAM, 0);
  335. if(m_UdpSocket == INVALID_SOCKET)
  336. {
  337. m_logFile.WriteLog("FAILED to Create UDP Socket");
  338. closesocket(m_UdpSocket);
  340. }
  341. else
  342. m_logFile.WriteLog("Succeed to Create UDP Socket");
  345. //创建POP3侦听线程
  346. struct sockaddr_in pop3_add;
  347. m_SocketPop3 = socket(AF_INET, SOCK_STREAM, 0);
  348. if(m_SocketPop3 < 0)
  349. {
  350. strLog.Format("failed to create pop3 socket.");
  351. m_logFile.WriteLog(strLog);
  352. return 0;
  353. }
  354. strLog.Format("Succeed to Create POP3 Socket");
  355. m_logFile.WriteLog(strLog);
  357. memset((char*)&pop3_add, 0x0, sizeof(sockaddr_in));
  358. pop3_add.sin_family = AF_INET;
  359. pop3_add.sin_port = htons(nPop3Port);
  360. pop3_add.sin_addr.s_addr = htonl(INADDR_ANY);
  362. if(bind(m_SocketPop3, (struct sockaddr*)&pop3_add, sizeof(pop3_add)) < 0)
  363. {
  364. strLog.Format("failed to bind POP3 socket on Port %d.", nPop3Port);
  365. m_logFile.WriteLog(strLog);
  366. closesocket(m_SocketPop3);
  367. return 0;
  368. }
  369. strLog.Format("Succeed to bind Pop3 socket on Port %d", nPop3Port);
  370. m_logFile.WriteLog(strLog);
  372. if(listen(m_SocketPop3, 5) < 0)
  373. {
  374. strLog.Format("Failed to Listen Pop3 Socket");
  375. m_logFile.WriteLog(strLog);
  376. closesocket(m_SocketPop3);
  377. return 0;
  378. }
  379. strLog.Format("Succeed to Listen Pop3 Socket");
  380. m_logFile.WriteLog(strLog);
  382. FD_SET(m_SocketPop3, &fdset);
  384. //创建POP接受连接线程 
  385. CWinThread * pop3_thread = NULL;
  386. pop3_thread = AfxBeginThread(Pop3_AcceptThread, NULL);
  387. if(pop3_thread == NULL)
  388. {
  389. strLog.Format("Failed to CreateThread for POP3");
  390. m_logFile.WriteLog(strLog);
  391.     FD_CLR(m_SocketPop3, &fdset);
  392. closesocket(m_SocketPop3);
  393. return 0;
  394. }
  395. strLog.Format("Succeed to CreateThread for POP3");
  396. m_logFile.WriteLog(strLog);
  398. //创建SMTP侦听线程
  399. struct sockaddr_in smtp_add;
  400. m_SocketSmtp = socket(AF_INET, SOCK_STREAM, 0);
  401. if(m_SocketSmtp < 0)
  402. {
  403. strLog.Format("Failed to Create Socket for SMTP");
  404. m_logFile.WriteLog(strLog);
  405. return 0;
  406. }
  407. strLog.Format("Succeed to Create Socket for SMTP");
  408. m_logFile.WriteLog(strLog);
  410. memset((char*)&smtp_add, 0x0, sizeof(smtp_add));
  411. smtp_add.sin_family = AF_INET;
  412. smtp_add.sin_port = htons(nSmtpPort);
  413. smtp_add.sin_addr.s_addr = htonl(INADDR_ANY);
  415. if(bind(m_SocketSmtp, (struct sockaddr*)&smtp_add, sizeof(smtp_add)) < 0)
  416. {
  417. strLog.Format("Failed to bind SMTP Socket on Port %d", nSmtpPort);
  418. m_logFile.WriteLog(strLog);
  419. closesocket(m_SocketSmtp);
  421. TerminateThread(pop3_thread->m_hThread, 0);
  422. FD_CLR(m_SocketPop3, &fdset);
  423. closesocket(m_SocketPop3);
  424. return 0;
  425. }
  426. strLog.Format("Succeed to bind SMTP Socket on Port %d", nSmtpPort);
  427. m_logFile.WriteLog(strLog);
  429. if(listen(m_SocketSmtp, 5) < 0)
  430. {
  431. strLog.Format("Failed to listen SMTP Socket");
  432. m_logFile.WriteLog(strLog);
  433. closesocket(m_SocketSmtp);
  435. TerminateThread(pop3_thread->m_hThread, 0);
  436. FD_CLR(m_SocketPop3, &fdset);
  437. closesocket(m_SocketPop3);
  438. return 0;
  439. }
  440. strLog.Format("Succeed to listen SMTP Socket");
  441. m_logFile.WriteLog(strLog);
  443. FD_SET(m_SocketSmtp, &fdset);
  445. //创建SMTP Socket 接受线程
  446. CWinThread* smtp_thread = NULL;
  447. smtp_thread = AfxBeginThread(Smtp_AcceptThread, NULL);
  448. if(smtp_thread == NULL)
  449. {
  450. strLog.Format("Failed to CreateThread for SMTP");
  451. m_logFile.WriteLog(strLog);
  452. FD_CLR(m_SocketSmtp, &fdset);
  453. closesocket(m_SocketSmtp);
  455. TerminateThread(pop3_thread->m_hThread, 0);
  456. FD_CLR(m_SocketPop3, &fdset);
  457. closesocket(m_SocketPop3);
  459. return 0;
  460. }
  461. strLog.Format("Succeed to CreateThread for SMTP");
  462. m_logFile.WriteLog(strLog);
  464. //创建SMTP Realying处理线程
  465. unsigned long lThreadID;
  466. m_logFile.WriteLog("starting SMTP-Relay thread");
  467. HANDLE hSMTP = CreateThread(NULL,
  468.  0,
  469.  (LPTHREAD_START_ROUTINE)SendSMTP, 
  470.  NULL,
  471.  0,
  472.  &lThreadID);
  473. if(hSMTP == NULL)
  474. m_logFile.WriteLog("SMTP-Relay thread failed");
  475. else
  476. m_logFile.WriteLog("SMTP-Relay thread Started");
  478. sprintf(pop3_msg00,"");
  479. sprintf(pop3_msg01,"HELO d00d");
  480. sprintf(pop3_msg12,"no message found");
  481. sprintf(pop3_msg03,"user accepted");
  482. sprintf(pop3_msg04,"invalid username");
  483. sprintf(pop3_msg05,"welcome");
  484. sprintf(pop3_msg06,"wrong password for this user");
  485. sprintf(pop3_msg07,"closing connection");
  486. sprintf(pop3_msg08,"message not found");
  487. sprintf(pop3_msg09,"done");
  488. sprintf(pop3_msg10,"no data found");
  489. sprintf(pop3_msg11,"nothing to delete");
  490. sprintf(pop3_msg12,"Message deleted");
  491. sprintf(pop3_msg13,"unknown command");
  493. return 1;
  494. }
  496. UINT Pop3_AcceptThread(LPVOID pParam)
  497. {
  498. char send_data[255];
  500. CString strLog;
  502. CString strIP;
  503. UINT nPort;
  505. struct timeval timeout;
  506. struct sockaddr_in client_add;
  507. int nClientSock;
  508. int ret, len;
  509. len = sizeof(client_add);
  510. while(1)
  511. {
  512. if(FD_ISSET(m_SocketPop3, &fdset))
  513. {
  514. timeout.tv_sec = 60;
  515. timeout.tv_usec = 0;
  516. memcpy(&rfdset, &fdset, sizeof(fdset));
  517. ret = select(1, &rfdset, 0, 0, &timeout);
  518. if(ret  < 0)
  519. {
  520. strLog.Format("select() failed for POP3 Socket");
  521. m_logFile.WriteLog(strLog);
  522. break;
  523. }
  524. memset(&client_add, 0x0, sizeof(client_add));
  525. nClientSock = accept(m_SocketPop3, (struct sockaddr*)&client_add, &len);
  526. if(nClientSock < 0)
  527. {
  528. strLog.Format("Pop3 Socket Accept Failed");
  529. m_logFile.WriteLog(strLog);
  530. break;
  531. }
  532. else
  533. {
  534. //test
  535. gSocketUseCount++;
  536. strLog.Format("*************Current Socket for POP3 Count=%d", gSocketUseCount);
  537. m_logFile.WriteLog(strLog);
  539. struct sockaddr_in peer_add;
  540. int nPeerLen = sizeof(peer_add);
  541. getpeername(nClientSock, (struct sockaddr*)&peer_add, &nPeerLen);
  542. strIP = inet_ntoa(peer_add.sin_addr);
  543. nPort = ntohs(peer_add.sin_port);
  544. strLog.Format("Get Pop3 Connection at IP=%s, PORT=%d", strIP, nPort);
  545. m_logFile.WriteLog(strLog);
  547. bool bFlag = false;
  548. for(int i=0; i<SOCKET_SIZE; i++)
  549. {
  550. if(m_SocketList[i].sock == -1)
  551. {
  552. bFlag = true;
  553. break;
  554. }
  555. }
  557. if(!bFlag)
  558. {
  559. strLog.Format("Not Enough Socket buff for the Connection");
  560. m_logFile.WriteLog(strLog);
  561. continue;
  562. }
  564. m_SocketList[i].typ = 1;
  565. m_SocketList[i].sock = nClientSock;
  566. m_SocketList[i].ip = strIP;
  568. FD_SET(nClientSock, &fdset);
  570. sprintf(send_data, "+OK POP3 on Smart Mail Server for M-Office (%s) ready. %srn",CURVER,pop3_msg00);
  571. send(nClientSock, send_data, strlen(send_data), 0);
  573. //启动接收数据线程
  574. AfxBeginThread(Pop3_ReceiveThread, (LPVOID)i); 
  575. strLog.Format("Start Thread %d",i);
  576. m_logFile.WriteLog(strLog);
  578. }
  579. }
  580. else
  581. break;
  582. }
  584. return 0;
  585. }
  587. UINT Smtp_AcceptThread(LPVOID pParam)
  588. {
  589. char send_data[255];
  591. CString strLog;
  593. CString strIP;
  594. UINT nPort;
  596. struct timeval timeout;
  597. struct sockaddr_in client_add;
  598. int nClientSock;
  599. int ret, len;
  600. len = sizeof(client_add);
  601. //接收SMTP连接
  602. while(1)
  603. {
  604. if(FD_ISSET(m_SocketSmtp, &fdset))
  605. {
  606. timeout.tv_sec = 10;
  607. timeout.tv_usec = 0;
  608. memcpy(&rfdset, &fdset, sizeof(fdset));
  609. ret = select(1, &rfdset, 0, 0, &timeout);
  610. if(ret < 0)
  611. {
  612. strLog.Format("select() failed for SMTP socket");
  613. m_logFile.WriteLog(strLog);
  614. break;
  615. }
  616. memset(&client_add, 0x0, sizeof(client_add));
  617. nClientSock = accept(m_SocketSmtp, (struct sockaddr*)&client_add, &len);
  618. if(nClientSock < 0)
  619. {
  620. strLog.Format("SMTP Socket Accept Failed");
  621. m_logFile.WriteLog(strLog);
  622. break;
  623. }
  624. else
  625. {
  626. struct sockaddr_in peer_add;
  627. int nPeerLen = sizeof(peer_add);
  628. getpeername(nClientSock, (struct sockaddr*)&peer_add, &nPeerLen);
  629. strIP = inet_ntoa(peer_add.sin_addr);
  630. nPort = ntohs(peer_add.sin_port);
  631. strLog.Format("Get SMTP Connection at IP=%s, PORT=%d", strIP, nPort);
  632. m_logFile.WriteLog(strLog);
  634. bool bFlag = false;
  635. for(int i=0; i<SOCKET_SIZE; i++)
  636. {
  637. if(m_SocketList[i].sock == -1)
  638. {
  639. bFlag = true;
  640. break;
  641. }
  642. }
  644. if(!bFlag)
  645. {
  646. strLog.Format("Not Enough Socket buff for the Connection");
  647. m_logFile.WriteLog(strLog);
  648. continue;
  649. }
  651. m_SocketList[i].typ = 2;
  652. m_SocketList[i].sock = nClientSock;
  653. m_SocketList[i].ip = strIP;
  655. FD_SET(nClientSock, &fdset);
  657. sprintf(send_data, "220 SMTP on Smart Mail Server for M-Office(%s) ready.rn",CURVER);
  658. send(nClientSock, send_data, strlen(send_data), 0);
  659. //创建线程
  660. AfxBeginThread(Smtp_ReceiveThread, (LPVOID)i);
  661. }
  662. }
  663. else
  664. break;
  665. }
  666. return 1;
  667. }
  669. UINT Pop3_ReceiveThread(LPVOID pParam)
  670. {
  671. CString strLog;
  673. int index = (int)pParam;
  674. char buff[1025];
  676. while(1)
  677. {
  678. memset(buff, 0x0, sizeof(buff));
  680. int ret = recv(m_SocketList[index].sock, (char*)buff, 1024, 0);
  681. if(ret <= 0)
  682. {
  683. // strLog.Format("recv() from pop3 client failed");
  684. // m_logFile.WriteLog(strLog);
  686. if(m_SocketList[index].sock != -1)
  687. {
  688. FD_CLR(m_SocketList[index].sock, &fdset);
  689. closesocket(m_SocketList[index].sock);
  690. m_SocketList[index].sock = -1;
  692. //test
  693. gSocketUseCount--;
  694. strLog.Format("***********Close socket for Pop3 Connection, SocketCOunt=%d", gSocketUseCount);
  695. m_logFile.WriteLog(strLog);
  697. m_SocketList[index].showlog = FALSE;
  698. m_SocketList[index].status2 = 0;
  699. m_SocketList[index].status = 0;
  700. m_SocketList[index].typ = 0;
  701. m_SocketList[index].openf= 0;
  702. m_SocketList[index].Temp = "";
  703. m_SocketList[index].Username = "unknown";
  704. m_SocketList[index].dontwrite = FALSE;
  705. }
  706. break;
  707. }
  708. else
  709. {
  710. ReadPop3(buff, ret, index); //处理数据 
  711. }
  712. }
  714. return 1;
  715. }
  717. UINT Smtp_ReceiveThread(LPVOID pParam)
  718. {
  719. CString strLog;
  721. int index = (int)pParam;
  722. char buff[1025];
  724. while(1)
  725. {
  726. int ret = recv(m_SocketList[index].sock, (char*)buff, 1024, 0);
  727. if(ret <= 0)
  728. {
  729. // strLog.Format("recv() from SMTP client failed");
  730. // m_logFile.WriteLog(strLog);
  732. if(m_SocketList[index].sock != -1)
  733. {
  734. FD_CLR(m_SocketList[index].sock, &fdset);
  735. closesocket(m_SocketList[index].sock);
  736. m_SocketList[index].sock = -1;
  737. }
  738. break;
  739. }
  740. else
  741. {
  742. ReadSmtp(buff, ret, index); //处理数据 
  743. }
  744. }
  745. return 1;
  746. }
  748. void ReadPop3(char* buf, int nDataLen, int i)
  749. {
  750. CString strLog;
  752. SOCKET sock_temp = m_SocketList[i].sock;
  753. // char buf[1025];
  754. CString tempstr = "";
  755. // int nix = pSocket->Receive(&buf, 1024,0);
  756. int nix = nDataLen;
  758. buf[nix] = '';
  759. strLog.Format("SOCKET=%d Pop3 Received buf[%d]: %s", sock_temp, i, buf);
  760. m_logFile.WriteLog(strLog);
  762. CString tempcstr;
  763. tempstr = buf;
  765. char sendstr[255];
  767. tempcstr = tempstr;
  768. m_SocketList[i].Temp = m_SocketList[i].Temp + tempstr;
  769. if (m_SocketList[i].Temp.GetLength()>240) 
  770. {
  771. m_SocketList[i].Temp = "";
  772. return;
  773. }; //buffer to large problem
  775. tempstr =  m_SocketList[i].Temp;
  776. if(tempstr.GetLength() == 0)
  777. return ;
  778. if(tempstr.GetAt(tempstr.GetLength()-1) != 'n') 
  779. return;
  781. strLog.Format("SOCKET=%d Pop3 Received aaaaaa[%d]: %s", sock_temp, i, tempstr);
  782. m_logFile.WriteLog(strLog);
  784. char tempstrU[255];
  786. sprintf(tempstrU,"%s",tempstr);
  787. strupr(tempstrU);
  789. //AUTH command
  790. if ((tempstrU[0] == 'A') && (tempstrU[1] == 'U') 
  791. && (tempstrU[2] == 'T') && (tempstrU[3] == 'H') 
  792. && (tempstrU[4] == ' ') )
  793. {
  794. sprintf(sendstr,"-ERR %srn",pop3_msg02);
  795. send (sock_temp, sendstr,strlen(sendstr),0);
  796. m_SocketList[i].Temp = "";
  797. return;
  798. }
  800. //USER command 
  801. if ((tempstrU[0] == 'U') && (tempstrU[1] == 'S') 
  802. && (tempstrU[2] == 'E') && (tempstrU[3] == 'R') 
  803. && (tempstrU[4] == ' ') )
  804. {
  805. sprintf(sendstr,"+OK %srn",pop3_msg03);
  806. send(sock_temp, sendstr,strlen(sendstr),0);
  807. char tempstr2[255];
  809. sprintf(tempstr2,"%s",tempstr);
  811. for (UINT z = 5; z<= strlen(tempstr2);z++)
  812. {
  813. tempstr2[z-5] = tempstr2[z];
  814. }
  815. tempstr2[z-5] = '';
  817. CString tempcstr;
  818. if (tempstr2[strlen(tempstr2)-2] == 'n') tempstr2[strlen(tempstr2)-2] = '';
  819. if (tempstr2[strlen(tempstr2)-2] == 'r') tempstr2[strlen(tempstr2)-2] = '';
  820. tempcstr = tempstr2;
  822. m_SocketList[i].Username= tempcstr;
  823. m_SocketList[i].status = 1; 
  824. m_SocketList[i].Temp = "";
  825. return;
  826. }
  828. //XSENDER command
  829. if ((tempstrU[0] == 'X') && (tempstrU[1] == 'S') 
  830. && (tempstrU[2] == 'E') && (tempstrU[3] == 'N') 
  831. && (tempstrU[4] == 'D') && (tempstrU[5] == 'E')
  832. && (tempstrU[6] == 'R') && (tempstrU[7] == ' '))
  833. {
  834. send(sock_temp, "+OKrn",5,0);
  835. m_SocketList[i].Temp = "";
  836. return;
  837. }
  839. //PASS command
  840. if (((tempstrU[0] == 'P') && (tempstrU[1] == 'A') 
  841. && (tempstrU[2] == 'S') && (tempstrU[3] == 'S') 
  842. && (tempstrU[4] == ' ') ) && (m_SocketList[i].status == 1))
  843. {
  844. bool bOK = false;
  845. //查询数据库,查找对应的用户
  846. HRESULT hr;
  847. BSTR BstrUserID, BstrPassword, BstrName;
  848. CString strUserID, strPassword;
  849. strUserID.Format("%s", m_SocketList[i].Username);
  850. BstrUserID = strUserID.AllocSysString();
  851. hr = m_pMailDB->FindUserByUserID(BstrUserID, &BstrPassword, &BstrName);
  853. if(FAILED(hr)) //查询失败
  854. m_logFile.WriteLog("Seach the UserID from DB Failed");
  855. else
  856. {
  857. _bstr_t bstrPassword(BstrPassword, FALSE);
  858. strPassword = (char*)bstrPassword;
  859. if(strPassword != "") //存在此用户,不存在该用户时Password返回空
  860. bOK = true;
  861. }
  863. if (!bOK)
  864. {
  865. strLog.Format("SOCKET=%d POP3 Login incorrect: User=%s not Exist from IP=%s", sock_temp, m_SocketList[i].Username, m_SocketList[i].ip);
  866. m_logFile.WriteLog(strLog);
  868. sprintf(sendstr,"-ERR %srn",pop3_msg04);
  869. send (sock_temp, sendstr,strlen(sendstr),0);
  870. m_SocketList[i].status = 0;
  871. m_SocketList[i].Temp = "";
  872. return;
  873. }
  875. char tempstr2[255];
  876. sprintf(tempstr2,"%s",tempstr);
  878. for (UINT z = 5; z<= strlen(tempstr2);z++)
  879. {
  880. tempstr2[z-5] = tempstr2[z];
  881. }
  882. tempstr2[z-5] = '';
  884. CString tempcstr;
  885. if (tempstr2[strlen(tempstr2)-2] == 'n') tempstr2[strlen(tempstr2)-2] = '';
  886. if (tempstr2[strlen(tempstr2)-2] == 'r') tempstr2[strlen(tempstr2)-2] = '';
  888. if (strPassword == tempstr2)
  889. {
  891. strLog.Format("SOCKET=%d User login: UserID=%s from IP=%s",sock_temp,m_SocketList[i].Username,m_SocketList[i].ip);
  892. m_logFile.WriteLog(strLog);
  893. sprintf(sendstr,"+OK %srn",pop3_msg05);
  894. send(sock_temp, sendstr,strlen(sendstr),0);
  895. strLog.Format("SOCKET=%d send:%s", sock_temp, sendstr);
  896. m_logFile.WriteLog(strLog);
  898. m_SocketList[i].Temp = "";
  899. m_SocketList[i].status = 2; 
  902. }
  903. else
  904. {
  905. sprintf(sendstr,"-ERR %srn",pop3_msg06);
  906. send (sock_temp, sendstr,strlen(sendstr),0);
  907. m_SocketList[i].Temp = "";
  908. m_SocketList[i].status = 0; 
  909. strLog.Format("Login incorrect: User=%s from IP=%s", m_SocketList[i].Username, m_SocketList[i].ip);
  910. m_logFile.WriteLog(strLog);
  911. }
  913. return;
  914. }
  916. //NOOP command
  917. if ((tempstrU[0] == 'N') && (tempstrU[1] == 'O') 
  918. && (tempstrU[2] == 'O') && (tempstrU[3] == 'P') )
  919. {
  920. send (sock_temp, "+OKrn",5,0);
  921. m_SocketList[i].Temp = "";
  922. return;
  923. }
  924. //QUIT command
  925. if ((tempstrU[0] == 'Q') && (tempstrU[1] == 'U') 
  926. && (tempstrU[2] == 'I') && (tempstrU[3] == 'T') )
  927. {
  928. sprintf(sendstr,"+OK %srn",pop3_msg07);
  929. send(sock_temp, sendstr,strlen(sendstr),0);
  931. for (int z = 0; z < m_DeleteList.GetSize(); z++)
  932. {
  933. if (m_SocketList[i].sock == m_DeleteList[z].sock)
  934. {
  935. int m = DeleteFile(m_strExePath + "\" +m_DeleteList[z].Filename);
  937. ::EnterCriticalSection(&m_csDeleteList);
  938. m_DeleteList.RemoveAt(z);
  939. ::LeaveCriticalSection(&m_csDeleteList);
  941. z--;
  942. }
  943. }
  944. //关闭该socket
  945. if(m_SocketList[i].sock != -1)
  946. {
  947. //test
  948. /* gSocketUseCount--;
  949. strLog.Format("***********Close socket for Pop3 Connection, SocketCOunt=%d", gSocketUseCount);
  950. m_logFile.WriteLog(strLog);
  952. FD_CLR(m_SocketList[i].sock, &fdset);
  953. closesocket(m_SocketList[i].sock);
  954. m_SocketList[i].sock = -1;
  956. strLog.Format("Connection closed for %s",m_SocketList[i].ip);
  957. m_logFile.WriteLog(strLog);
  959. m_SocketList[i].showlog = FALSE;
  960. m_SocketList[i].status2 = 0;
  961. m_SocketList[i].status = 0;
  962. m_SocketList[i].typ = 0;
  963. m_SocketList[i].openf= 0;
  964. m_SocketList[i].Temp = "";
  965. m_SocketList[i].Username = "unknown";
  966. m_SocketList[i].dontwrite = FALSE;
  967. */
  968. }
  970. return;
  971. }
  973. //LIST command
  974. if ((tempstrU[0] == 'L') && (tempstrU[1] == 'I') 
  975. && (tempstrU[2] == 'S') && (tempstrU[3] == 'T') 
  976. && (m_SocketList[i].status == 2))
  977. {
  979. char fstr[255];
  980. sprintf(fstr,"%s\mail\%s\*.in",m_strExePath, m_SocketList[i].Username); 
  982. HANDLE hFind;
  983. WIN32_FIND_DATA findData = {0};
  984. char tempinf[255];
  985. char tempbuf[1024];
  986. sprintf(tempbuf,"");
  987. int c = 0;
  988. int length = 0;
  990. if(strlen(tempstrU) == 6)
  991. {
  992. hFind = FindFirstFile (fstr, &findData);
  994. if (hFind != INVALID_HANDLE_VALUE)
  995. {
  996. do
  997. {
  998. if (findData.cFileName[0] != '.')
  999. {
  1000. c++;
  1001. length = length + (findData.nFileSizeHigh * MAXDWORD) + findData.nFileSizeLow;
  1002. }
  1003. }while (FindNextFile(hFind, &findData));
  1005. sprintf(tempbuf,"+OK %i %irn",c,length);
  1007. FindClose (hFind);
  1008. }
  1011. c = 0;
  1012. length = 0;
  1014. hFind = FindFirstFile (fstr, &findData);
  1016. if (hFind == INVALID_HANDLE_VALUE)
  1017. {
  1018. send (sock_temp, "+OK 0 0rn.rn",9,0);
  1019. strLog.Format("SOCKET=%d send:+OK 0 0rn.rn", sock_temp);
  1020. m_logFile.WriteLog(strLog);
  1021. }
  1022. else
  1023. {
  1024. do
  1025. {
  1026. if (findData.cFileName[0] != '.')
  1027. {
  1029. c++;
  1030. length = (findData.nFileSizeHigh * MAXDWORD) + findData.nFileSizeLow;
  1031. sprintf(tempbuf,"%s%i %irn",tempbuf,c,length);
  1032. }
  1033. }   while (FindNextFile(hFind, &findData));
  1035. sprintf(tempbuf,"%s.rn",tempbuf);
  1036. send (sock_temp, tempbuf,strlen(tempbuf),0);   
  1038. strLog.Format("SOCKET=%d send:%s", sock_temp, tempbuf);
  1039. m_logFile.WriteLog(strLog);
  1041. FindClose (hFind);
  1042. }
  1043. }
  1044. else
  1045. {
  1046. int nr;
  1048. hFind = FindFirstFile (fstr, &findData);
  1050. DeleteCRLF(tempstrU);
  1052. int foundit = 0;
  1053. sscanf(tempstrU,"%s %i",tempinf,&nr);
  1055. if (hFind == INVALID_HANDLE_VALUE)
  1056. {
  1057. send (sock_temp, "+OK 0 0rn",9,0);
  1059. strLog.Format("SOCKET=%d send:+OK 0 0rn", sock_temp);
  1060. m_logFile.WriteLog(strLog);
  1062. }
  1063. else
  1064. {
  1066. do
  1067. {
  1068. if (findData.cFileName[0] != '.')
  1069. {
  1070. c++;
  1071. if (c == nr) 
  1072. {
  1073. foundit = 1;
  1074. length = (findData.nFileSizeHigh * MAXDWORD) + findData.nFileSizeLow;
  1075. }
  1076. }
  1077. }   while (FindNextFile(hFind, &findData));
  1079. if (foundit == 1)
  1080. sprintf(tempinf,"+OK %i %irn",nr,length);
  1082. if (foundit == 0)
  1083. sprintf(tempinf,"-ERR %srn",pop3_msg08);
  1085. send (sock_temp, tempinf,strlen(tempinf),0);   
  1086. strLog.Format("SOCKET=%d send:%s", sock_temp,tempinf);
  1087. m_logFile.WriteLog(strLog);
  1089. FindClose (hFind);
  1090. }
  1092. }
  1094. m_SocketList[i].Temp = "";
  1095. return;
  1096. }
  1098. //RSET command
  1099. if ((tempstrU[0] == 'R') && (tempstrU[1] == 'S') 
  1100. && (tempstrU[2] == 'E') && (tempstrU[3] == 'T') )
  1101. {
  1102. sprintf(sendstr,"+OK %srn",pop3_msg09);
  1103. send (sock_temp, sendstr,strlen(sendstr),0);
  1104. m_SocketList[i].Temp = "";
  1105. m_SocketList[i].status = 0; 
  1106. return;
  1107. }
  1109. //RETR command
  1110. if ((tempstrU[0] == 'R') && (tempstrU[1] == 'E') 
  1111. && (tempstrU[2] == 'T') && (tempstrU[3] == 'R') 
  1112. && (tempstrU[4] == ' ')&& (m_SocketList[i].status >= 2) )
  1113. {
  1114. char tempstr2[255];
  1115. sprintf(tempstr2,tempstr);
  1117. for (UINT z = 5; z<= strlen(tempstr2);z++)
  1118. {
  1120. tempstr2[z-5] = tempstr2[z];
  1121. }
  1122. tempstr2[z-5] = '';
  1125. CString tempcstr;
  1126. if (tempstr2[strlen(tempstr2)-2] == 'n') tempstr2[strlen(tempstr2)-2] = '';
  1127. if (tempstr2[strlen(tempstr2)-2] == 'r') tempstr2[strlen(tempstr2)-2] = '';
  1128. tempcstr = tempstr2;
  1130. int iretr = atoi(tempcstr); //the number of the mail...
  1132. char fstr[255];
  1133. sprintf(fstr,"%s\mail\%s\*.in", m_strExePath, m_SocketList[i].Username); 
  1135. HANDLE hFind;
  1136. char fname[255];
  1137. WIN32_FIND_DATA findData = {0};
  1139. hFind = FindFirstFile (fstr, &findData);
  1141. if (hFind == INVALID_HANDLE_VALUE)
  1142. {
  1143. sprintf(sendstr,"-ERR %srn",pop3_msg10);
  1144. send (sock_temp, sendstr,strlen(sendstr),0);
  1145. }
  1146. else
  1147. {
  1148. int c = 0;
  1149. int length = 0;
  1150. BOOL found = FALSE;
  1152. int status1 = 0;
  1153. do
  1154. {
  1155. if (findData.cFileName[0] != '.')
  1156. {
  1157. c++;
  1158. length = length + (findData.nFileSizeHigh * MAXDWORD) + findData.nFileSizeLow;
  1159. if (c == iretr)
  1160. {
  1161. found = TRUE;
  1162. sprintf(sendstr,"+OK %i octetsrn",length);
  1163. int len=strlen(sendstr);
  1164. send(sock_temp, sendstr, strlen(sendstr), 0);
  1166. sprintf(fname,"mail\%s\%s", m_SocketList[i].Username, findData.cFileName);
  1167. //发送Mail内容
  1168. SendPop3Mail(sock_temp, fname);
  1169. /* _SendPop3Param* pSock_file = new _SendPop3Param;
  1170. pSock_file->sock = sock_temp;
  1171. memcpy(&pSock_file->fname, fname, sizeof(pSock_file->fname));
  1173. AfxBeginThread(SendPop3Mail, (LPVOID)pSock_file );
  1174. */
  1175. }
  1176. }
  1177. }
  1178. while (FindNextFile(hFind, &findData));
  1180. FindClose (hFind);
  1182. if (found == FALSE)
  1183. {
  1184. sprintf(sendstr,"-ERR %srn",pop3_msg10);
  1185. send (sock_temp, sendstr,strlen(sendstr),0);
  1186. }
  1187. }
  1188. m_SocketList[i].Temp = "";
  1190. return;
  1191. }
  1193. //TOP command
  1194. if ((tempstrU[0] == 'T') && (tempstrU[1] == 'O') 
  1195. && (tempstrU[2] == 'P') && (tempstrU[3] == ' ') && (m_SocketList[i].status == 2))
  1196. {
  1197. char tempstr2[255];
  1198. sprintf(tempstr2,tempstr);
  1200. CString tempcstr;
  1201. if (tempstr2[strlen(tempstr2)-2] == 'n') tempstr2[strlen(tempstr2)-2] = '';
  1202. if (tempstr2[strlen(tempstr2)-2] == 'r') tempstr2[strlen(tempstr2)-2] = '';
  1203. tempcstr = tempstr2;
  1205. char tempstr1[255];
  1207. char mesgn[255];
  1208. sprintf(mesgn,"");
  1210. char lines[255];
  1211. sprintf(lines,"");
  1213. sscanf(tempcstr,"%s %s %s",tempstr1,mesgn,lines);
  1215. int iretr = atoi(mesgn);
  1217. char fstr[255];
  1218. sprintf(fstr,"%s\mail\%s\*.in", m_strExePath, m_SocketList[i].Username); 
  1221. HANDLE hFind;
  1222. char fname[255];
  1223. WIN32_FIND_DATA findData = {0};
  1224. char outstr[255];
  1225. int err;
  1226. BOOL found = FALSE;
  1227. FILE *outmail;
  1228. hFind = FindFirstFile (fstr, &findData);
  1230. if (hFind == INVALID_HANDLE_VALUE)
  1231. {
  1232. send (sock_temp, "-ERR No data foundrn",20,0);
  1233. strLog.Format("SOCKET=%d send:-ERR No data foundrn", sock_temp);
  1234. m_logFile.WriteLog(strLog);
  1236. }
  1237. else
  1238. {
  1239. int c = 0;
  1240. int length = 0;
  1242. int status1 = 0;
  1243. do
  1244. {
  1246. if (findData.cFileName[0] != '.')
  1247. {
  1249. c++;
  1250. length = length + (findData.nFileSizeHigh * MAXDWORD) + findData.nFileSizeLow;
  1251. if (c == iretr)
  1252. {
  1253. char sendstr[255];
  1254. int ilines = abs(atoi(lines));
  1255. //if (ilines == 0) ilines = 10;
  1256. //sprintf(sendstr,"+OK showing %i linesrn",ilines);
  1257. sprintf(sendstr,"+OKrn");
  1258. send (sock_temp, sendstr,strlen(sendstr),0);
  1260. sprintf(fname,"%s\mail\%s\%s", m_strExePath,
  1261. m_SocketList[i].Username, findData.cFileName);
  1262. if( (outmail= fopen(fname, "rb" )) != NULL )
  1263. {
  1264. //for (int ii = 0;ii<ilines;ii++)
  1265. int SendLines=0;
  1266. for (;;)
  1267. {
  1268. memset(outstr,0x0,255);
  1269. fgets(outstr,254,outmail);
  1270. if (!feof(outmail))
  1271. {
  1272. //outstr[strlen(outstr)-2] = 'n';
  1273. outstr[strlen(outstr)] = '';
  1276. int nbyte;
  1277. nbyte = send (sock_temp, outstr,strlen(outstr),0);
  1278. strLog.Format("SOCKET=%d send:%s", sock_temp,outstr);
  1279. m_logFile.WriteLog(strLog);
  1281. if(nbyte < 0)
  1282. {
  1283. err = GetLastError();
  1284. if(err == WSAEWOULDBLOCK)
  1285. {
  1286. while(err == WSAEWOULDBLOCK)
  1287. {
  1288. send (sock_temp, outstr,strlen(outstr),0);
  1289. strLog.Format("SOCKET=%d send:%s", sock_temp,outstr);
  1290. m_logFile.WriteLog(strLog);
  1291. err = GetLastError();
  1292. }
  1293. }
  1294. else
  1295. {
  1296. fclose(outmail); 
  1297. send (sock_temp, "-ERR Server Send Data Errorrn",20,0);
  1298. strLog.Format("SOCKET=%d send:-ERR Server Send Data Errorrn", sock_temp);
  1299. m_logFile.WriteLog(strLog);
  1300. return;
  1301. }
  1302. }
  1303. }else
  1304. {
  1306. break;
  1307. }
  1308. if((strlen(outstr)==2 && SendLines==0) ||  SendLines >0)
  1309. SendLines++;
  1310. if (SendLines > ilines)
  1311. break;
  1312. }
  1314. found = TRUE;
  1315. if (!feof(outmail)) 
  1316. {
  1317. send (sock_temp, ".rn",3,0);
  1318. strLog.Format("SOCKET=%d send:.rn", sock_temp);
  1319. m_logFile.WriteLog(strLog);
  1320. }
  1321. fclose(outmail);
  1322. }
  1323. }
  1324. }
  1325. }
  1326. while (FindNextFile(hFind, &findData));
  1328. FindClose (hFind);
  1329. }
  1330. if (found == FALSE)  
  1331. {
  1332. send (sock_temp, "-ERR No data foundrn",20,0);
  1333. strLog.Format("SOCKET=%d send:-ERR No data foundrn", sock_temp);
  1334. m_logFile.WriteLog(strLog);
  1335. }
  1336. m_SocketList[i].Temp = "";
  1337. return;
  1338. }
  1340. //DELE command
  1341. if (((tempstrU[0] == 'D') && (tempstrU[1] == 'E') 
  1342. && (tempstrU[2] == 'L') && (tempstrU[3] == 'E') 
  1343. && (tempstrU[4] == ' ')) && (m_SocketList[i].status == 2))
  1344. {
  1345. char tempstr2[255];
  1346. sprintf(tempstr2,tempstr);
  1348. for (UINT z = 5; z<= strlen(tempstr2);z++)
  1349. {
  1350. tempstr2[z-5] = tempstr2[z];
  1351. }
  1352. tempstr2[z-5] = '';
  1354. CString tempcstr;
  1355. if (tempstr2[strlen(tempstr2)-2] == 'n') tempstr2[strlen(tempstr2)-2] = '';
  1356. if (tempstr2[strlen(tempstr2)-2] == 'r') tempstr2[strlen(tempstr2)-2] = '';
  1357. tempcstr = tempstr2;
  1359. int iretr = atoi(tempcstr);
  1361. char fstr[255];
  1362. sprintf(fstr,"%s\mail\%s\*.in", m_strExePath, m_SocketList[i].Username); 
  1364. DeleteInfo Mydelinfo;   
  1365. Mydelinfo.sock = m_SocketList[i].sock;
  1366. HANDLE hFind;
  1367. char fname[255];
  1368. WIN32_FIND_DATA findData = {0};
  1370. hFind = FindFirstFile (fstr, &findData);
  1372. if (hFind == INVALID_HANDLE_VALUE)
  1373. {
  1374. sprintf(sendstr,"-ERR %srn",pop3_msg11);
  1375. send (sock_temp, sendstr,strlen(sendstr),0);
  1376. }
  1377. else
  1378. {
  1379. int c = 0;
  1380. BOOL found = FALSE;
  1381. do
  1382. {
  1384. if (findData.cFileName[0] != '.')
  1385. {
  1387. c++;
  1388. if (c == iretr)
  1389. {
  1390. sprintf(fname,"mail\%s\%s", m_SocketList[i].Username, findData.cFileName);
  1391. Mydelinfo.Filename = fname;
  1392. m_DeleteList.Add(Mydelinfo);
  1393. sprintf(sendstr,"+OK %srn",pop3_msg12);
  1394. send (sock_temp, sendstr,strlen(sendstr),0);
  1395. found = TRUE;
  1396. }
  1397. }
  1398. }while (FindNextFile(hFind, &findData));
  1400. FindClose (hFind);
  1402. if (found == FALSE)
  1403. {
  1404. sprintf(sendstr,"-ERR %srn",pop3_msg11);
  1405. send (sock_temp, sendstr,strlen(sendstr),0);
  1406. }
  1407. }
  1408. m_SocketList[i].Temp = "";
  1409. return;
  1410. }
  1412. //STAT command
  1413. if (((tempstrU[0] == 'S') && (tempstrU[1] == 'T') 
  1414. && (tempstrU[2] == 'A') && (tempstrU[3] == 'T') 
  1415. ) && (m_SocketList[i].status == 2))
  1416. {
  1418. char fstr[255];
  1419. sprintf(fstr,"%s\mail\%s\*.in", m_strExePath, m_SocketList[i].Username); 
  1421. char tempinf[255];
  1423. HANDLE hFind;
  1424. WIN32_FIND_DATA findData = {0};
  1425. hFind = FindFirstFile (fstr, &findData);
  1427. if (hFind == INVALID_HANDLE_VALUE)
  1428. {
  1429. send (sock_temp, "+OK 0 0rn",9,0);
  1430. strLog.Format("SOCKET=%d send:+OK 0 0rn", sock_temp);
  1431. m_logFile.WriteLog(strLog);
  1432. }
  1433. else
  1434. {
  1436. int c = 0;
  1437. int length = 0;
  1439. do
  1440. {
  1442. if (findData.cFileName[0] != '.')
  1443. {
  1445. c++;
  1446. length = length + (findData.nFileSizeHigh * MAXDWORD) + findData.nFileSizeLow;
  1447. }
  1448. }   while (FindNextFile(hFind, &findData));
  1450. sprintf(tempinf,"+OK %i %irn",c,length);
  1452. send (sock_temp, tempinf,strlen(tempinf),0);
  1453. strLog.Format("SOCKET=%d send:%s", sock_temp, tempinf);
  1454. m_logFile.WriteLog(strLog);
  1456. FindClose (hFind);
  1457. }
  1459. m_SocketList[i].Temp = "";
  1460. return;
  1461. }
  1463. sprintf(sendstr,"-ERR %srn",pop3_msg13);
  1464. send (sock_temp, sendstr,strlen(sendstr),0);
  1465. strLog.Format("SOCKET=%d send:%s", sock_temp, sendstr);
  1466. m_logFile.WriteLog(strLog);
  1468. if (tempstr[tempstr.GetLength()-1] == 'n') 
  1469. m_SocketList[i].Temp = "";
  1470. }
  1472. void ReadSmtp(char* buf, int nDataLen, int i)
  1473. {
  1474. CString strLog;
  1476. SOCKET sock_temp = m_SocketList[i].sock;
  1478. // char buf[1025];
  1479. CString tempstr;
  1480. FILE *stream;
  1481. // int nix = pSocket->Receive(&buf, 1024,0);
  1482. int nix = nDataLen;
  1483. buf[nix] = '';
  1486. if (m_SocketList[i].status >= 5) // get a mail... :)
  1487. {
  1488. //将收到的邮件内容以流的形式写入文件
  1489. // fprintf(m_SocketList[i].mail,"%s",buf); 
  1490. m_SocketList[i].strHead = m_SocketList[i].strHead+ buf;
  1491. if(m_SocketList[i].bTransHead == 0) //信件头部未传输完毕
  1492. {
  1494. if(m_SocketList[i].strHead.Find("rnrn") > -1)
  1495. {
  1496. m_SocketList[i].bTransHead = 1;
  1497. CString strTemp=m_SocketList[i].strHead;
  1498. strTemp.MakeUpper();
  1499. if(strTemp.Find("rnMESSAGE-ID:") >-1 || strTemp.Find("MESSAGE-ID:") == 0)
  1500. {
  1501. fprintf(m_SocketList[i].mail,"%s",m_SocketList[i].strHead);
  1502. m_SocketList[i].strHead="";
  1503. }else
  1504. {
  1505. //产生message-id
  1506. char chMessageID[100];
  1507. time_t tm;
  1508. time(&tm);
  1509. srand((unsigned)time(NULL));
  1510. sprintf(chMessageID, "Message-ID: <%d.%d.smartmailserver@m_office.com>rn", tm, rand());
  1512. strTemp=chMessageID+m_SocketList[i].strHead;
  1513. fprintf(m_SocketList[i].mail,"%s",strTemp);
  1514. m_SocketList[i].strHead="";
  1515. }
  1516. }
  1517. }else
  1518. {
  1519. if(m_SocketList[i].strHead.GetLength()>4096)
  1520. {
  1522. if(fprintf(m_SocketList[i].mail,"%s",m_SocketList[i].strHead)!=m_SocketList[i].strHead.GetLength())
  1523. {
  1524. CString strLog;
  1525. strLog.Format("Write file %s error",m_SocketList[i].Fname);
  1526. m_logFile.WriteLog(strLog);
  1527. }
  1528. m_SocketList[i].strHead = "";
  1529. }
  1530. }
  1531. if (nix == 1)
  1532. {
  1533. m_SocketList[i].crstr[0] = m_SocketList[i].crstr[1];
  1534. m_SocketList[i].crstr[1] = m_SocketList[i].crstr[2];
  1535. m_SocketList[i].crstr[2] = m_SocketList[i].crstr[3];
  1536. m_SocketList[i].crstr[3] = m_SocketList[i].crstr[4];
  1537. m_SocketList[i].crstr[4] = buf[0];
  1538. }
  1539. if (nix == 2)
  1540. {
  1541. m_SocketList[i].crstr[0] = m_SocketList[i].crstr[2];
  1542. m_SocketList[i].crstr[1] = m_SocketList[i].crstr[3];
  1543. m_SocketList[i].crstr[2] = m_SocketList[i].crstr[4];
  1544. m_SocketList[i].crstr[3] = buf[0];
  1545. m_SocketList[i].crstr[4] = buf[1];
  1546. }
  1547. if (nix == 3)
  1548. {
  1549. m_SocketList[i].crstr[0] = m_SocketList[i].crstr[3];
  1550. m_SocketList[i].crstr[1] = m_SocketList[i].crstr[4];
  1551. m_SocketList[i].crstr[2] = buf[0];
  1552. m_SocketList[i].crstr[3] = buf[1];
  1553. m_SocketList[i].crstr[4] = buf[2];
  1554. }
  1555. if (nix == 4)
  1556. {
  1557. m_SocketList[i].crstr[0] = m_SocketList[i].crstr[1];
  1558. m_SocketList[i].crstr[1] = buf[0];
  1559. m_SocketList[i].crstr[2] = buf[1];
  1560. m_SocketList[i].crstr[3] = buf[2];
  1561. m_SocketList[i].crstr[4] = buf[3];
  1562. }
  1564. if (nix == 5)
  1565. {
  1566. m_SocketList[i].crstr[0] = buf[0];
  1567. m_SocketList[i].crstr[1] = buf[1];
  1568. m_SocketList[i].crstr[2] = buf[2];
  1569. m_SocketList[i].crstr[3] = buf[3];
  1570. m_SocketList[i].crstr[4] = buf[4];
  1571. }
  1573. if (nix > 5)
  1574. {
  1575. m_SocketList[i].crstr[0] = buf[nix-5];
  1576. m_SocketList[i].crstr[1] = buf[nix-4];
  1577. m_SocketList[i].crstr[2] = buf[nix-3];
  1578. m_SocketList[i].crstr[3] = buf[nix-2];
  1579. m_SocketList[i].crstr[4] = buf[nix-1];
  1580. }
  1581. /*
  1582. if(m_SocketList[i].bTransHead == 0) //信件头部未传输完毕
  1583. {
  1584. CString strTemp=m_SocketList[i].crstr;
  1585. strTemp=strTemp+buf;
  1586. strTemp.MakeUpper();
  1587. //查找Message-ID:
  1588. if(strTemp.Find("rnMESSAGE-ID:") >-1)
  1589. {
  1590. m_SocketList[i].bFinded = 1;
  1591. }
  1592. int pos=strTemp.Find("rnrn");
  1593. if(pos > -1)//信件头部已经传输完毕
  1594. {
  1595. m_SocketList[i].bTransHead = 1;
  1597. if(m_SocketList[i].bFinded ==0)  //在头部没有发现Message-ID
  1598. {
  1599. //产生message-id
  1600. char chMessageID[100];
  1601. time_t tm;
  1602. time(&tm);
  1603. srand((unsigned)time(NULL));
  1604. sprintf(chMessageID, "Message-ID: <%d.%d.smartmailserver@m_office.com>rn", tm, rand());
  1606. CString strBuf=m_SocketList[i].crstr;
  1607. strBuf=strBuf+buf;
  1608. CString WriteStr;
  1609. WriteStr=strBuf.Left(pos+2)+chMessageID+strBuf.Right(strBuf.GetLength()-pos-2);
  1610. fseek(m_SocketList[i].mail, -5, SEEK_CUR);
  1611. fprintf(m_SocketList[i].mail,"%s",WriteStr);
  1612. }
  1613. }
  1615. fprintf(m_SocketList[i].mail,"%s",buf);
  1616. }else
  1617. {
  1618. fprintf(m_SocketList[i].mail,"%s",buf);
  1619. }
  1620. */
  1621. if (strcmp(m_SocketList[i].crstr,"rn.rn") == 0)
  1622. {
  1623. fprintf(m_SocketList[i].mail,"%s",m_SocketList[i].strHead); //保存剩余部分
  1624. m_SocketList[i].strHead = "";
  1625. send (sock_temp, "250 OKrn",8,0); //TODO if ok
  1626. if (m_SocketList[i].openf ==  1) 
  1627. fclose(m_SocketList[i].mail);
  1628. m_SocketList[i].status = 0;
  1630. ProcessNewMail(m_SocketList[i].FnameCTL,m_SocketList[i].Fname,m_SocketList[i].Sender);
  1632. if (m_SocketList[i].openf ==  1) 
  1633. fclose(m_SocketList[i].mail);
  1634. m_SocketList[i].FnameCTL = "";
  1635. m_SocketList[i].Fname = "";
  1636. }
  1637. return;
  1638. }
  1641. CString tempcstr;
  1642. tempstr = buf;
  1643. tempcstr = tempstr;
  1644. m_SocketList[i].Temp = m_SocketList[i].Temp + tempstr;
  1646. if (m_SocketList[i].Temp.GetLength()>240) 
  1647. {
  1648. m_SocketList[i].Temp = "";
  1649. return;
  1650. } //buffer to large problem
  1652. tempstr = m_SocketList[i].Temp;
  1653. if (tempstr[tempstr.GetLength()-1] != 'n') 
  1654. return;
  1656. strLog.Format("Smtp Received[%d]: %s", i, tempstr);
  1657. m_logFile.WriteLog(strLog);
  1659. char tempstrU[255];
  1660. sprintf(tempstrU,tempstr);
  1661. strupr(tempstrU);
  1663. if(m_SocketList[i].sLogin ==1) //已发送Auth login
  1664. {
  1665. char UserNameTemp[255];
  1666. strcpy(UserNameTemp,tempstr);
  1668. if (UserNameTemp[strlen(UserNameTemp)-2] == 'n') UserNameTemp[strlen(UserNameTemp)-2] = '';
  1669. if (UserNameTemp[strlen(UserNameTemp)-2] == 'r') UserNameTemp[strlen(UserNameTemp)-2] = '';
  1671. char UserName[255];
  1672. memset(UserName,0x0,255);
  1673. CEncoder base;
  1674. base.Decode(UserNameTemp,strlen(UserNameTemp),UserName,254,0);
  1675. m_SocketList[i].strLoginUserName =UserName;
  1676. m_SocketList[i].sLogin=2;
  1677. int dd=send (sock_temp, "334 UGFzc3dvcmQ6rn",18,0);
  1678. m_SocketList[i].Temp = "";
  1679. return;
  1681. }else if(m_SocketList[i].sLogin ==2) //已发送用户名
  1682. {
  1683. char PasswordTemp[255];
  1684. strcpy(PasswordTemp,tempstr);
  1686. if (PasswordTemp[strlen(PasswordTemp)-2] == 'n') PasswordTemp[strlen(PasswordTemp)-2] = '';
  1687. if (PasswordTemp[strlen(PasswordTemp)-2] == 'r') PasswordTemp[strlen(PasswordTemp)-2] = '';
  1689. char Password[255];
  1690. memset(Password,0x0,255);
  1691. CEncoder base;
  1692. base.Decode(PasswordTemp,strlen(PasswordTemp),Password,254,0);
  1694. m_SocketList[i].strLoginPassword =Password;
  1697. BSTR BstrUserID, BstrPassword,BstrName;
  1698. CString strPassword;
  1699. BstrUserID = m_SocketList[i].strLoginUserName.AllocSysString();
  1700. m_pMailDB->FindUserByUserID(BstrUserID, &BstrPassword, &BstrName);
  1701. _bstr_t  bstrPassword(BstrPassword, FALSE);
  1702. strPassword = (char*)bstrPassword;
  1703. if(strPassword ==m_SocketList[i].strLoginPassword)
  1704. {
  1705. send (sock_temp, "235 Authentication successfulrn",31,0);
  1706. m_SocketList[i].sLogin =3;
  1707. }else
  1708. {
  1709. send (sock_temp, "501 Login Errorrn",17,0);
  1710. m_SocketList[i].sLogin =4;
  1711. }
  1713. m_SocketList[i].Temp = "";
  1714. return;
  1715. }
  1717. //EHLO command
  1718. if ((tempstrU[0] == 'E') && (tempstrU[1] == 'H') 
  1719. && (tempstrU[2] == 'L') && (tempstrU[3] == 'O') 
  1720. && (tempstrU[4] == ' ') )
  1721. {
  1722. //send (sock_temp, "250 implementedrn",21,0);
  1724. send (sock_temp, "250-Welcomern",12,0);
  1725. send (sock_temp, "250-AUTH=LOGINrn",16,0);
  1726. send (sock_temp, "250 AUTH LOGINrn",16,0);
  1727. m_SocketList[i].sLogin =0;
  1728. m_SocketList[i].Temp = "";
  1729. return;
  1730. }
  1732. //AUTH LOGIN command
  1733. if ((tempstrU[0] == 'A') && (tempstrU[1] == 'U') 
  1734. && (tempstrU[2] == 'T') && (tempstrU[3] == 'H') 
  1735. && (tempstrU[4] == ' ') && (tempstrU[5] == 'L')
  1736. && (tempstrU[6] == 'O') && (tempstrU[7] == 'G')
  1737. && (tempstrU[8] == 'I') && (tempstrU[9] == 'N'))
  1738. {
  1739. send (sock_temp, "334 VXNlcm5hbWU6rn",18,0);
  1740. m_SocketList[i].sLogin =1;
  1741. m_SocketList[i].Temp = "";
  1742. return;
  1743. }
  1746. //HELO command
  1747. if ((tempstrU[0] == 'H') && (tempstrU[1] == 'E') 
  1748. && (tempstrU[2] == 'L') && (tempstrU[3] == 'O') 
  1749. && (tempstrU[4] == ' ') )
  1750. {
  1751. send (sock_temp, "250 HELOrn",10,0);
  1752. m_SocketList[i].sLogin =0;
  1753. m_SocketList[i].Temp = "";
  1754. return;
  1755. }
  1757. //NOOP command
  1758. if ((tempstrU[0] == 'N') && (tempstrU[1] == 'O') 
  1759. && (tempstrU[2] == 'O') && (tempstrU[3] == 'P') )
  1760. {
  1761. send (sock_temp, "220 OKrn",8,0);
  1762. m_SocketList[i].Temp = "";
  1763. return;
  1764. }
  1766. //RSET command
  1767. if ((tempstrU[0] == 'R') && (tempstrU[1] == 'S') 
  1768. && (tempstrU[2] == 'E') && (tempstrU[3] == 'T') )
  1769. {
  1770. send (sock_temp, "220 OKrn",8,0);
  1771. m_SocketList[i].Temp = "";
  1772. return;
  1773. }
  1775. //MAIL FROM command
  1776. if ((tempstrU[0] == 'M') && (tempstrU[1] == 'A') 
  1777. && (tempstrU[2] == 'I') && (tempstrU[3] == 'L') 
  1778. && (tempstrU[4] == ' ')&& (tempstrU[5]  == 'F') 
  1779. && (tempstrU[6] == 'R') && (tempstrU[7] == 'O')
  1780. && (tempstrU[8] == 'M'))
  1781. {
  1782. send (sock_temp, "250 OKrn",8,0);
  1783. m_SocketList[i].Temp = "";
  1784. m_SocketList[i].Sender = tempstr;
  1785. return;
  1786. }
  1788. //RCPT TO command
  1789. if ((tempstrU[0] == 'R') && (tempstrU[1] == 'C') 
  1790. && (tempstrU[2] == 'P') && (tempstrU[3] == 'T') 
  1791. && (tempstrU[4] == ' ')&& (tempstrU[5]  == 'T') 
  1792. && (tempstrU[6] == 'O'))
  1793. {
  1795. CString strRcpt=tempstr;
  1796. if(!IsLocalUser((LPSTR)(LPCSTR)strRcpt) && m_SocketList[i].sLogin != 3)  //不是本地用户并且没有通过验证
  1797. {
  1798. send (sock_temp, "501 Not loginrn",18,0);
  1799. }else
  1800. {
  1801. if (m_SocketList[i].FnameCTL == "")
  1802. {
  1803. char tempstrA[255];
  1805. CTime t = CTime::GetCurrentTime();
  1806. SYSTEMTIME stime;
  1807. GetSystemTime(&stime);
  1809. sprintf(tempstrA,"%i%02i%02i%02i%02i%02i%i.in",t.GetYear(),t.GetMonth(),t.GetDay(),t.GetHour(),t.GetMinute(),t.GetSecond(),stime.wMilliseconds);
  1810. int xxi = 0;
  1812. m_SocketList[i].Fname = tempstrA;
  1813. sprintf(tempstrA,"%i%02i%02i%02i%02i%02i%i.ctl",t.GetYear(),t.GetMonth(),t.GetDay(),t.GetHour(),t.GetMinute(),t.GetSecond(),stime.wMilliseconds);
  1814. m_SocketList[i].FnameCTL = tempstrA;
  1815. }
  1818. if( (stream  = fopen(m_strExePath+"\mail\" + m_SocketList[i].FnameCTL, "at" )) != NULL )
  1819. {
  1820. fprintf(stream,"%s",tempstr);
  1821. fclose(stream);
  1822. send (sock_temp, "250 OKrn",8,0);
  1823. }
  1824. else
  1825. {
  1826. send (sock_temp, "501 Server Errorrn",18,0);
  1827. }
  1828. m_SocketList[i].status = 4; 
  1829. }
  1831. m_SocketList[i].Temp = "";
  1832. return;
  1833. }
  1835. //DATA command
  1836. if ( ((tempstrU[0] == 'D') && (tempstrU[1] == 'A') 
  1837. && (tempstrU[2] == 'T') && (tempstrU[3] == 'A')) && m_SocketList[i].status == 4)
  1838. {
  1839. send (sock_temp, "354 Enter your data, end with <crlf>.<crlf>rn",45,0);
  1841. if( (m_SocketList[i].mail = fopen(m_strExePath+"\mail\" + m_SocketList[i].Fname, "wb" )) != NULL )
  1842. {
  1843. m_SocketList[i].crstr[0] = ' ';
  1844. m_SocketList[i].crstr[1] = ' ';
  1845. m_SocketList[i].crstr[2] = ' ';
  1846. m_SocketList[i].crstr[3] = ' ';
  1847. m_SocketList[i].crstr[4] = ' ';
  1848. m_SocketList[i].crstr[5] = '';
  1849. m_SocketList[i].status = 5;
  1850. m_SocketList[i].openf = 1;
  1851. m_SocketList[i].bTransHead = 0;
  1852. m_SocketList[i].strHead="";
  1853. //m_SocketList[i].bFinded = 0;
  1854. } 
  1855. else
  1856. {
  1857. send (sock_temp, "502 Server Errorrn",18,0);
  1858. }
  1860. m_SocketList[i].Temp = "";
  1861. return;
  1862. }
  1864. if ((tempstrU[0] == 'Q') && (tempstrU[1] == 'U') 
  1865. && (tempstrU[2] == 'I') && (tempstrU[3] == 'T') )
  1866. {
  1867. send(sock_temp, "221 Closing connectionrn",24,0);
  1869. strLog.Format("Connection closed for %s", m_SocketList[i].ip);
  1870. m_logFile.WriteLog(strLog);
  1871. if(m_SocketList[i].sock != -1)
  1872. {
  1873. FD_CLR(m_SocketList[i].sock, &fdset);
  1874. closesocket(m_SocketList[i].sock);
  1875. m_SocketList[i].sock = -1;
  1877. m_SocketList[i].showlog = FALSE;
  1878. m_SocketList[i].status2 = 0;
  1879. m_SocketList[i].status = 0;
  1880. m_SocketList[i].typ = 0;
  1881. m_SocketList[i].openf= 0;
  1882. m_SocketList[i].Temp = "";
  1883. m_SocketList[i].Username = "unknown";
  1884. m_SocketList[i].dontwrite = FALSE;
  1885. }
  1886. return;
  1887. }
  1888. }
  1890. void SendSMTP()
  1891. {
  1892. CString strLog;
  1894. time_t the_time;
  1895. int curitem = -1;
  1897. for (;;)
  1898. {
  1899. Sleep(1000); //zzz, every second we check if we should send a mail
  1901. if(m_SMTPForwardList.GetSize()>0)
  1902. {
  1903. for (int li= 0;li<=m_SMTPForwardList.GetSize()-1;li++)
  1904. {
  1905. curitem = li;
  1906. if (m_SMTPForwardList[curitem].error == 0)
  1907. {
  1908. m_SMTPForwardList[curitem].sendnr = 0;
  1910. strLog.Format("Trying to send mail (%s)", m_SMTPForwardList[curitem].Rcpt);
  1911. m_logFile.WriteLog(strLog);
  1913. // if (SendSmtpMail(curitem) == 0)
  1914. if (SendSmtpMailDirect(curitem) == 0)
  1916. {
  1917. DeleteFile(m_strExePath+"\"+m_SMTPForwardList[curitem].Fname);
  1918. strLog.Format("Successfull SMTP mail send (%s)", m_SMTPForwardList[curitem].Rcpt);
  1919. m_logFile.WriteLog(strLog);
  1921. ::EnterCriticalSection(&m_csSMTPForward);
  1922. m_SMTPForwardList.RemoveAt(curitem);
  1923. ::LeaveCriticalSection(&m_csSMTPForward);
  1925. break;
  1926. }
  1927. else
  1928. {
  1929. strLog.Format("Sending of SMTP mail (%s) failed the first time.", m_SMTPForwardList[curitem].Rcpt);
  1930. m_logFile.WriteLog(strLog);
  1932. ::EnterCriticalSection(&m_csSMTPForward);
  1933. time(&the_time);
  1934. m_SMTPForwardList[curitem].timestamp = the_time;
  1935. m_SMTPForwardList[curitem].error= 1;
  1936. m_SMTPForwardList[curitem].sendnr++;
  1937. ::LeaveCriticalSection(&m_csSMTPForward);
  1938. }
  1939. }
  1940. else
  1941. {
  1942. short nMaxTries;
  1943. m_pMailConfig->GetRelayMaxTries(&nMaxTries);
  1945. if (nMaxTries < m_SMTPForwardList[curitem].sendnr)
  1946. {
  1947. strLog.Format("Send mail (%s) not possible after maximum tries.",  m_SMTPForwardList[curitem].Rcpt);
  1948. m_logFile.WriteLog(strLog);
  1950. // SendErrorMail(curitem);
  1951. DeleteFile(m_strExePath+"\"+m_SMTPForwardList[curitem].Fname);
  1952. ::EnterCriticalSection(&m_csSMTPForward);
  1953. m_SMTPForwardList.RemoveAt(curitem);
  1954. ::LeaveCriticalSection(&m_csSMTPForward);
  1955. break;
  1956. }
  1958. time(&the_time);
  1960. short nTimeInterval;
  1961. m_pMailConfig->GetRelayTimeInterval(&nTimeInterval);
  1963. if (difftime(the_time, m_SMTPForwardList[curitem].timestamp) > nTimeInterval*60)
  1964. {
  1965. strLog.Format("Trying to send failed mail again (%s)", m_SMTPForwardList[curitem].Rcpt);
  1966. m_logFile.WriteLog(strLog);
  1968. m_SMTPForwardList[curitem].error = 0;
  1970. // if (SendSmtpMail(curitem) == 0)
  1971. if (SendSmtpMailDirect(curitem) == 0)
  1972. {
  1973. strLog.Format("Successfull SMTP mail send (%s)", m_SMTPForwardList[curitem].Rcpt);
  1974. m_logFile.WriteLog(strLog);
  1976. ::EnterCriticalSection(&m_csSMTPForward);
  1977. DeleteFile(m_strExePath+"\"+m_SMTPForwardList[curitem].Fname);
  1978. m_SMTPForwardList.RemoveAt(curitem);
  1979. ::LeaveCriticalSection(&m_csSMTPForward);
  1980. break;
  1981. }
  1982. else
  1983. {
  1984. time(&the_time);
  1985. m_SMTPForwardList[curitem].timestamp = the_time;
  1986. m_SMTPForwardList[curitem].error= 1;
  1987. m_SMTPForwardList[curitem].sendnr++;
  1988. strLog.Format("Could not send %s", m_SMTPForwardList[curitem].Rcpt);
  1989. m_logFile.WriteLog(strLog);
  1990. }
  1991. }
  1992. }
  1993. }
  1994. }
  1995. }
  1996. }
  1998. int SendSmtpMail(int litem) //relay
  1999. {
  2001. SOCKET         hServer;
  2002. char           szBuffer[4096];
  2003. SOCKADDR_IN    SockAddr;
  2005. // WSADATA        WSData;
  2007. LPHOSTENT      lpHostEntry;
  2008. int            iProtocolPort;
  2009. char           ServerName[255];
  2011. BSTR BstrRelaySmtpServer;
  2012. m_pMailConfig->GetRelayServerName(&BstrRelaySmtpServer);
  2013. bstr_t bstrRelaySmtpServer(BstrRelaySmtpServer, FALSE);
  2015. sprintf(ServerName,"%s",(char*)bstrRelaySmtpServer);
  2017. lpHostEntry = gethostbyname(ServerName);
  2018. if (lpHostEntry == NULL) 
  2019. {
  2020. // WSACleanup();
  2021. return 1;
  2022. }
  2024. hServer = socket( PF_INET, SOCK_STREAM, 0); 
  2025. if (hServer == INVALID_SOCKET) 
  2026. {
  2027. closesocket( hServer );
  2028. // WSACleanup();
  2029. return 1;
  2030. }
  2032. iProtocolPort = htons(25);
  2034. SockAddr.sin_family = AF_INET;
  2035. SockAddr.sin_port = iProtocolPort;
  2036. SockAddr.sin_addr = *((LPIN_ADDR)*lpHostEntry->h_addr_list);
  2038. int stimeout = 60000;
  2039. int rtimeout = 60000;
  2041. int err;
  2043. if (stimeout != 0) 
  2044. {
  2045. err = setsockopt(hServer ,      
  2046.  SOL_SOCKET,     
  2047.  SO_SNDTIMEO,
  2048.  (char *)&stimeout,  
  2049.  sizeof(stimeout) );
  2050. if (err != NO_ERROR) 
  2051. {
  2052. closesocket( hServer );
  2053. // WSACleanup();
  2054. return 1;
  2055. }
  2056. }
  2058. if (rtimeout != 0) 
  2059. {
  2060. err = setsockopt(hServer ,      
  2061.  SOL_SOCKET,     
  2062.  SO_RCVTIMEO,
  2063.  (char *)&rtimeout,  
  2064.  sizeof(rtimeout) );
  2066. if (err != NO_ERROR) 
  2067. {
  2068. closesocket( hServer );
  2069. // WSACleanup();
  2070. return 1;
  2071. }
  2072. }
  2073. if (connect( hServer, (PSOCKADDR) &SockAddr, sizeof(SockAddr)))
  2074. {
  2075. closesocket(hServer);
  2076. // WSACleanup();
  2077. return 1;
  2078. }
  2080. //AskError();
  2082. int cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  2084. if (cnt == SOCKET_ERROR)
  2085. { 
  2086. closesocket( hServer );
  2087. // WSACleanup();
  2088. return 1;
  2089. }
  2091. if (szBuffer[0] != '2') 
  2092. {
  2093. closesocket( hServer );
  2094. // WSACleanup();
  2095. return 1;
  2096. }
  2098. char sendstr[255];
  2100. BSTR BstrHostName;
  2101. m_pMailConfig->GetHostName(1, &BstrHostName);
  2102. bstr_t bstrHostName(BstrHostName, FALSE);
  2104. sprintf(sendstr,"HELO %srn",(char*)bstrHostName);
  2105. cnt = send( hServer, sendstr, strlen(sendstr), 0);
  2107. if (cnt == SOCKET_ERROR)
  2108. { 
  2109. closesocket( hServer );
  2110. // WSACleanup();
  2111. return 1;
  2112. }
  2114. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  2116. if (cnt == SOCKET_ERROR)
  2117. { 
  2118. closesocket( hServer );
  2119. // WSACleanup();
  2120. return 1;
  2121. }
  2123. if (szBuffer[0] != '2') 
  2124. {
  2125. closesocket( hServer );
  2126. // WSACleanup();
  2127. return 1;
  2128. }
  2131. sprintf(sendstr,"%s",m_SMTPForwardList[litem].Sender);
  2132. cnt = send( hServer, sendstr, strlen(sendstr), 0);
  2134. if (cnt == SOCKET_ERROR)
  2135. { 
  2136. closesocket( hServer );
  2137. // WSACleanup();
  2138. return 1;
  2139. }
  2141. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  2143. if (cnt == SOCKET_ERROR)
  2144. { 
  2145. closesocket( hServer );
  2146. // WSACleanup();
  2147. return 1;
  2148. }
  2150. if (szBuffer[0] != '2') 
  2151. {
  2152. closesocket( hServer );
  2153. // WSACleanup();
  2154. return 1;
  2155. }
  2157. sprintf(sendstr,"%srn", m_SMTPForwardList[litem].Rcpt);
  2158. cnt = send( hServer, sendstr, strlen(sendstr), 0);
  2160. if (cnt == SOCKET_ERROR)
  2161. { 
  2162. closesocket( hServer );
  2163. // WSACleanup();
  2164. return 1;
  2165. }
  2167. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  2169. if (cnt == SOCKET_ERROR)
  2170. { 
  2171. closesocket( hServer );
  2172. // WSACleanup();
  2173. return 1;
  2174. }
  2176. if (szBuffer[0] != '2') 
  2177. {
  2178. closesocket( hServer );
  2179. // WSACleanup();
  2180. return 1;
  2181. }
  2184. sprintf(sendstr,"DATArn");
  2186. cnt = send( hServer, sendstr, strlen(sendstr), 0);
  2188. if (cnt == SOCKET_ERROR)
  2189. { 
  2190. closesocket( hServer );
  2191. // WSACleanup();
  2192. return 1;
  2193. }
  2195. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  2197. if (cnt == SOCKET_ERROR)
  2198. { 
  2199. closesocket( hServer );
  2200. // WSACleanup();
  2201. return 1;
  2202. }
  2204. if (szBuffer[0] != '3')
  2205. {
  2206. closesocket( hServer );
  2207. // WSACleanup();
  2208. return 1;
  2209. }
  2211. FILE *fp = fopen(m_strExePath+"\"+m_SMTPForwardList[litem].Fname,"rb");
  2213. if (fp == NULL) 
  2214. {
  2215. closesocket( hServer );
  2216. // WSACleanup();
  2217. return 1;
  2218. }
  2220. char tempstr[255];
  2221. while(!feof(fp))
  2222. {
  2223. fgets(tempstr,255,fp);
  2224. tempstr[strlen(tempstr)-2] = 'n';
  2225. tempstr[strlen(tempstr)-1] = '';
  2227. if (!feof(fp))
  2228. {
  2230. cnt = send( hServer, tempstr, strlen(tempstr), 0);
  2231. if (cnt == SOCKET_ERROR)
  2232. { 
  2233. fclose(fp);
  2234. closesocket( hServer );
  2235. // WSACleanup();
  2236. return 1;
  2237. }
  2238. }
  2240. }
  2241. fclose(fp);
  2243. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  2245. if (cnt == SOCKET_ERROR)
  2246. { 
  2247. closesocket( hServer );
  2248. // WSACleanup();
  2249. return 1;
  2250. }
  2251. if (szBuffer[0] != '2')
  2252. {
  2253. closesocket( hServer );
  2254. // WSACleanup();
  2255. return 1;
  2256. }
  2258. sprintf(sendstr,"QUITrn");
  2260. cnt = send( hServer, sendstr, strlen(sendstr), 0);
  2262. if (cnt == SOCKET_ERROR)
  2263. { 
  2264. closesocket( hServer );
  2265. // WSACleanup();
  2266. return 1;
  2267. }
  2269. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  2271. if (cnt == SOCKET_ERROR)
  2272. { 
  2273. closesocket( hServer );
  2274. // WSACleanup();
  2275. return 1;
  2276. }
  2278. if (szBuffer[0] != '2') 
  2279. {
  2280. closesocket( hServer );
  2281. // WSACleanup();
  2282. return 1;
  2283. }
  2286. closesocket( hServer );
  2287. // WSACleanup();
  2289. return 0;
  2290. }
  2292. //向客户端发送Mail文件
  2293. void SendPop3Mail(SOCKET s, char* fileName)
  2294. //UINT SendPop3Mail(LPVOID pParam)
  2295. {
  2296. // _SendPop3Param* psock_file = (_SendPop3Param*)pParam;
  2298. // SOCKET s = psock_file->sock;
  2299. // char* fileName = psock_file->fname;
  2301. FILE *outmail;
  2302. char outstr[255];
  2303. int err = 0;
  2305. if( (outmail= fopen(m_strExePath+"\"+fileName, "rb" )) != NULL )
  2306. {
  2308. while (!feof(outmail))
  2309. {
  2311. fgets(outstr,254,outmail);
  2312. //outstr[strlen(outstr)-2] = 'n';
  2313. outstr[strlen(outstr)] = '';
  2315. if (!feof(outmail))
  2316. {
  2317. int nByte;
  2318. nByte = send (s, outstr,strlen(outstr),0);
  2319. if(nByte < 0)
  2320. {
  2321. err = GetLastError();
  2322. if(err == WSAEWOULDBLOCK)
  2323. {
  2324. while(err == WSAEWOULDBLOCK)
  2325. {
  2326. send (s, outstr,strlen(outstr),0);
  2327. err = GetLastError();
  2328. }
  2329. }
  2330. else
  2331. break;
  2332. }
  2333. }
  2334. }
  2335. fclose(outmail);
  2336. }
  2337. // return 0;
  2338. }
  2340. void DeleteCRLF(char *string)
  2341. {
  2342. if (string[strlen(string)-2] == 'n') string[strlen(string)-2] = '';
  2343. if (string[strlen(string)-2] == 'r') string[strlen(string)-2] = '';
  2344. if (string[strlen(string)-1] == 'n') string[strlen(string)-1] = '';
  2345. if (string[strlen(string)-1] == 'r') string[strlen(string)-1] = '';
  2346. }
  2348. void ProcessNewMail(CString CTL, CString Fname,CString Sender)
  2349. {
  2350. if (Fname == "") return;
  2352. CString strLog;
  2354. //在邮件中加入Message-ID
  2355. // AddMessageID(Fname);
  2357. short nCopyAllFlag;
  2358. BSTR BstrCopyDesUserID;
  2359. CString strCopyDesUserID;
  2360. m_pMailConfig->GetCopyAllMailConfig(&nCopyAllFlag, &BstrCopyDesUserID);
  2362. if(nCopyAllFlag == 1)
  2363. {
  2364. _bstr_t bstrCopyDesUserID(BstrCopyDesUserID, FALSE);
  2365. strCopyDesUserID = (char*)bstrCopyDesUserID;
  2366. //this one should may be a extra thread:
  2367. CopyFile(m_strExePath+"\mail\" + Fname, m_strExePath+"mail\" + strCopyDesUserID + "\"  + Fname,FALSE );
  2368. }
  2370. CString rcpt;
  2371. char srcpt[255];
  2372. char srcptip[255];
  2374. FILE *stream;
  2377. CString rcptFull;
  2379. char tempstr[255];
  2380. if( (stream  = fopen(m_strExePath+"\mail\" + CTL, "rt" )) != NULL )
  2381. {
  2382. m_logFile.WriteLog("Open Ctl Filen");
  2383. while (!feof(stream))
  2384. {
  2385. fgets(tempstr,255,stream);
  2386. if (!feof(stream))
  2387. {
  2388. if (tempstr[strlen(tempstr)-2] == 'n') tempstr[strlen(tempstr)-2] = '';
  2389. if (tempstr[strlen(tempstr)-2] == 'r') tempstr[strlen(tempstr)-2] = '';
  2391. rcptFull = tempstr;
  2392. int beginsign= -1;
  2393. int endsign= -1;
  2394. int atsign= -1;
  2396. for (UINT i = 0;i<= strlen(tempstr);i++)
  2397. {
  2398. if (tempstr[i] == '@') atsign = i;
  2399. if (tempstr[i] == '<') beginsign = i;
  2400. if (tempstr[i] == '>') endsign = i;
  2401. }
  2403. if ((beginsign==  -1) || (endsign==  -1) || (atsign==  -1))
  2404. {
  2405. char err[255];
  2406. sprintf(err,"wrong reciepment format: %s (mail\unknown\%s)",tempstr,Fname);
  2407. m_logFile.WriteLog((CString)err);
  2408. LogError(err);
  2409. CopyFile(m_strExePath+"\mail\" + Fname,m_strExePath+"\mail\unknown\"  + Fname,FALSE );
  2410. }
  2411. else
  2412. {
  2413. beginsign++;
  2415. for (int z = beginsign;z<=atsign;z++)
  2416. {
  2417. srcpt[z-beginsign] = tempstr[z];
  2419. }
  2420. srcpt[z-beginsign-1] = '';
  2422. atsign++;
  2423. for (z = atsign;z<=endsign;z++)
  2424. {
  2425. srcptip[z-atsign] = tempstr[z];
  2427. }
  2428. srcptip[z-atsign-1] = '';
  2431. rcpt = srcptip;
  2432. BOOL aka_ok = FALSE;
  2433. BOOL rcpt_ok = FALSE;
  2434. /*
  2435. for (int a = 0;a<= MyAkaList.GetSize()-1;a++)
  2436. {
  2437. if (strcmpi(MyAkaList[a].Text,rcpt) == 0) 
  2438. aka_ok = TRUE;
  2439. }
  2440. */
  2441. CString strRcpt;
  2442. strRcpt.Format("%s", rcpt);
  2443. short nHostCount;
  2444. BSTR BstrHostName;
  2445. CString strHostName;
  2446. m_pMailConfig->GetHostNameCount(&nHostCount);
  2447. for(int i=1; i<=nHostCount; i++) //index begins from 1
  2448. {
  2449. m_pMailConfig->GetHostName(i, &BstrHostName);
  2450. _bstr_t bstrHostName(BstrHostName, FALSE);
  2451. strHostName = (char*)bstrHostName;
  2453. if(strHostName == strRcpt)
  2454. {
  2455. aka_ok = TRUE;
  2456. break;
  2457. }
  2458. }
  2459. /*
  2460. for (a = 0;a<= MailUserList.GetSize()-1;a++)
  2461. {
  2462. if (strcmpi(MailUserList[a].Username,srcpt)== 0) 
  2463. rcpt_ok = TRUE;
  2464. }
  2465. */
  2466. BSTR BstrUserID, BstrPassword, BstrName;
  2467. CString strUserID, strPassword;
  2468. strUserID.Format("%s", srcpt);
  2469. BstrUserID = strUserID.AllocSysString();
  2470. m_pMailDB->FindUserByUserID(BstrUserID, &BstrPassword, &BstrName);
  2471. _bstr_t  bstrPassword(BstrPassword, FALSE);
  2472. strPassword = (char*)bstrPassword;
  2473. if(strPassword != "")
  2474. rcpt_ok = TRUE;
  2476. if ((aka_ok) && (rcpt_ok)) 
  2477. {
  2478. rcpt = srcpt;
  2479. //创建收件用户的文件夹
  2480. CString strFolder;
  2481. strFolder.Format("%s\mail\%s", m_strExePath, rcpt);
  2482. CreateDirectory((LPCTSTR)strFolder, NULL);
  2483. //mkdir(chfolder);
  2484. if (CopyFile(m_strExePath+"\mail\" + Fname,m_strExePath+"\mail\" + rcpt + "\" + Fname,FALSE ) == FALSE)
  2485. {
  2486. CopyFile(m_strExePath+"\mail\" + Fname,m_strExePath+"\mail\unknown\"  + Fname,FALSE );    
  2488. strLog.Format("Count not send %s", tempstr);
  2489. m_logFile.WriteLog(strLog);
  2490. LogError(strLog);
  2491. }
  2492. else
  2493. {
  2494. //发送UDP包，并将相关的信息写入数据库
  2495. CString strFileName, strRecver;
  2496. strFileName.Format("mail\%s\%s", rcpt, Fname);
  2497. strRecver.Format("%s", tempstr);
  2498. DealMailInfo(strFileName, Sender, strRecver);
  2500. strLog.Format("Mail Send To: %s", tempstr);
  2501. m_logFile.WriteLog(strLog);
  2502. }
  2503. }
  2504. else
  2505. {
  2506. //FORWARD Check
  2507. BOOL fwd =FALSE;
  2508. BOOL listmail = FALSE;
  2510. if (aka_ok == TRUE)
  2511. {
  2512. FILE *fwdfp;
  2514. fwdfp = fopen (m_strExePath+"\forward.ctl","rt");
  2516. if (fwdfp != NULL)
  2517. {
  2518. char fwdstr[255];
  2519. char fwdsrc[255];
  2520. char fwddest[255];
  2522. sprintf(fwdstr,"");
  2523. while (!feof(fwdfp))
  2524. {
  2525. sprintf(fwdstr,"");
  2527. fgets(fwdstr,255,fwdfp);
  2529. if (strlen(fwdstr) > 3)
  2530. {
  2532. if (fwdstr[strlen(fwdstr)-2] == 'n') fwdstr[strlen(fwdstr)-2] = '';
  2533. if (fwdstr[strlen(fwdstr)-2] == 'r') fwdstr[strlen(fwdstr)-2] = '';
  2535. sscanf(fwdstr,"%s %s",fwdsrc,fwddest);
  2537. rcpt = srcpt;
  2539. if (strcmpi(fwdsrc,rcpt) == 0)
  2540. {
  2541. fwd =TRUE;
  2543. //char mkd[255];
  2544. CString strmkd;
  2545. strmkd.Format("%s\mail\%s", m_strExePath, fwddest);
  2546. CreateDirectory((LPCTSTR)strmkd, NULL);
  2548. //sprintf(mkd,"mail\%s",fwddest);
  2550. //mkdir(mkd);
  2552. rcpt = fwddest;
  2553. if (CopyFile(m_strExePath+"\mail\" + Fname,m_strExePath+"\mail\" + rcpt + "\" + Fname,FALSE ) == FALSE)
  2554. {
  2555. char logstr[255];
  2556. sprintf(logstr,"Could not send mail (read error): %s (mail\unknown\%s)n",tempstr,Fname);
  2557. LogError(logstr);
  2558. CopyFile(m_strExePath+"\mail\" + Fname,m_strExePath+"\mail\unknown\"  + Fname,FALSE );    
  2560. strLog.Format("Could not send %s",tempstr);
  2561. m_logFile.WriteLog(strLog);
  2562. }
  2563. else
  2564. {
  2565. strLog.Format("Mail forward: %s->%s",fwdsrc,fwddest);
  2566. m_logFile.WriteLog(strLog);
  2567. }
  2568. }
  2569. }
  2570. }
  2571. fclose(fwdfp);
  2572. //end alias-check
  2573. }
  2574. else
  2575. {
  2576. m_logFile.WriteLog("Cant read forward.ctl! Mail marked as bad.");
  2577. }
  2579. //is the user a list?
  2581. char curname[255];
  2582. strlwr(srcpt);
  2583. HANDLE hFind;
  2584. WIN32_FIND_DATA findData = {0};
  2585. hFind = FindFirstFile (m_strExePath+"\lists\*.lst", &findData);
  2587. if (hFind != INVALID_HANDLE_VALUE)
  2588. {
  2589. do
  2590. {
  2591. if (findData.cFileName[0] != '.')
  2592. {
  2593. sprintf(curname,"%s",findData.cFileName);
  2594. strlwr(curname);
  2595. if ((curname[strlen(curname)-3] == 'l') &&
  2596. (curname[strlen(curname)-2] == 's') &&
  2597. (curname[strlen(curname)-1] == 't'))
  2598. {
  2599. curname[strlen(curname)-4] = '';
  2601. if (stricmp(srcpt,curname) == 0) //valid list
  2602. {
  2603. listmail = TRUE;
  2604. strLog.Format("New Mailinglist ( %s ) mail", curname);
  2605. m_logFile.WriteLog(strLog);
  2607. HANDLE hFind1;
  2608. WIN32_FIND_DATA findData1 = {0};
  2609. hFind1 = FindFirstFile (m_strExePath + "\mail\" + Fname, &findData1);
  2611. int mlsize = (findData1.nFileSizeHigh * MAXDWORD) + findData1.nFileSizeLow;
  2612. FindClose(hFind1);
  2614. FILE *fpf;
  2615. char listfname[255];
  2616. sprintf(listfname,"%s\lists\%s",m_strExePath,findData.cFileName);
  2617. fpf = fopen (listfname,"rt");
  2618. if (fpf == NULL) //this sucks
  2619. {
  2620. m_logFile.WriteLog("Couldn't read mailing list file");
  2621. }
  2622. else
  2623. {
  2624. int readstatus = 0;
  2625. int maxsize = 0;
  2626. char reply_to[255];
  2627. char xtdsender[255];
  2628. char subject_prefix[255];
  2630. char templine[255];
  2631. sprintf(reply_to,"");
  2632. sprintf(subject_prefix,"");
  2633. sprintf(xtdsender,"");
  2635. while (!feof(fpf))
  2636. {
  2637. fgets(templine,255,fpf);
  2638. if(!feof(fpf))
  2639. {
  2640. DeleteCRLF(templine);
  2641. if ((templine[0] != '#') || (templine[0] != '['))
  2642. {
  2643. if (readstatus == 1)
  2644. {
  2645. char seps[] = "=";
  2646. char *token;
  2647. token = strtok( templine, seps );
  2648. char lastoption[255];
  2649. int xpos = 0;
  2650. while( token != NULL )
  2651. {
  2652. if (xpos == 0)
  2653. {
  2654. sprintf(lastoption,"%s",token);
  2655. }
  2656. if (xpos == 1)
  2657. {
  2658. if (stricmp(lastoption,"reply_to") == 0)
  2659. {
  2660. sprintf(reply_to,"%s",token);
  2661. }
  2663. if (stricmp(lastoption,"maxlength") == 0)
  2664. {
  2665. maxsize = atoi(token);
  2666. }
  2668. if (stricmp(lastoption,"subject_prefix") == 0)
  2669. {
  2670. sprintf(subject_prefix,"%s",token);
  2671. }
  2673. if (stricmp(lastoption,"sender") == 0)
  2674. {
  2675. sprintf(xtdsender,"%s",token);
  2676. }
  2677. }
  2679. xpos++;
  2680. token = strtok( NULL, seps );
  2681. }
  2683. if (maxsize != 0)
  2684. {
  2685. if (mlsize >= maxsize)
  2686. {
  2687. m_logFile.WriteLog("Mail to large for mailing list");
  2688. break;
  2689. }
  2690. }
  2691. }
  2692. if (readstatus == 2)
  2693. {
  2694. //mkdir("spool");
  2695. CString strSpool;
  2696. strSpool.Format("%s\spool", m_strExePath);
  2697. CreateDirectory((LPCTSTR)strSpool, NULL);
  2699. SMTPForwardInfo fwdinf;
  2700. //we generate a new filename for each send
  2701. //so we can easely delete the file
  2702. CTime t = CTime::GetCurrentTime();
  2703. SYSTEMTIME stime;
  2704. GetSystemTime(&stime);
  2706. char fnamenew[255];
  2707. sprintf(fnamenew,"%i%02i%02i%02i%02i%02i%i.out",t.GetYear(),t.GetMonth(),t.GetDay(),t.GetHour(),t.GetMinute(),t.GetSecond(),stime.wMilliseconds);
  2709. fwdinf.Fname = "spool\" + (CString)fnamenew;
  2710. fwdinf.error= 0;
  2711. fwdinf.sendnr = 0;
  2712. fwdinf.Sender= "MAIL FROM: <" + (CString) xtdsender + ">rn";
  2713. fwdinf.Rcpt= "RCPT TO: <" + (CString)templine + ">";
  2715. time_t theTime;
  2716. time(&theTime);
  2717. fwdinf.timestamp = theTime;
  2718. fwdinf.islocal = true;
  2720. CopyFile(m_strExePath+"\mail\" + Fname,m_strExePath+"\"+fwdinf.Fname ,FALSE );
  2721. strLog.Format("Posting mailing-list mail to %s", templine);
  2722. m_logFile.WriteLog(strLog);
  2724. ::EnterCriticalSection(&m_csSMTPForward);
  2725. m_SMTPForwardList.Add(fwdinf); //have fun :)
  2726. ::LeaveCriticalSection(&m_csSMTPForward);
  2727. }
  2728. }
  2730. if (strcmp(templine,"[Setup]") == 0) readstatus = 1;
  2731. if (strcmp(templine,"[Users]") == 0)
  2732. {
  2733. readstatus = 2;
  2734. FILE *fpin = fopen(m_strExePath+"\mail\" + Fname,"rt");
  2736. CTime t = CTime::GetCurrentTime();
  2737. SYSTEMTIME stime;
  2738. GetSystemTime(&stime);
  2740. char tempfile[255];
  2741. sprintf(tempfile,"mail\%i%02i%02i%02i%02i%02i%i.in",t.GetYear(),t.GetMonth(),t.GetDay(),t.GetHour(),t.GetMinute(),t.GetSecond(),stime.wMilliseconds);
  2743. FILE *fpout = fopen(m_strExePath+"\"+tempfile,"wt");
  2745. BOOL insideheader = TRUE;
  2746. while(!feof(fpin))
  2747. {
  2748. fgets(templine,255,fpin);
  2750. if(!feof(fpin))
  2751. {
  2752. if (insideheader)
  2753. {
  2754. if ((templine[0] == 'S') && (templine[1] == 'u') && (templine[2] == 'b')
  2755. && (templine[3] == 'j') && (templine[4] == 'e') && (templine[5] == 'c')
  2756. && (templine[6] == 't') && (templine[7] == ':'))
  2757. {
  2758. //modify subject?
  2759. if (strlen(subject_prefix) != 0) 
  2760. {
  2761. //is our new subject already in the text?
  2762. if (strstr(templine,subject_prefix) == NULL)
  2763. {
  2764. //there isnt
  2765. for (UINT x = 9;x<= strlen(templine);x++)
  2766. {
  2767. templine[x-9] = templine[x];
  2768. }
  2769. fprintf(fpout,"Subject: %s %s",subject_prefix,templine);
  2770. sprintf(templine,"");
  2771. }
  2772. }
  2773. }
  2776. if ((templine[0] == 'S') && (templine[1] == 'e') && (templine[2] == 'n')
  2777. && (templine[3] == 'd') && (templine[4] == 'e') && (templine[5] == 'r')
  2778. && (templine[6] == ':') ) //sender already excist, use ours now
  2779. {
  2781. //if xtdsender is = 0 something is wrong or we already have it
  2782. if (strlen(xtdsender) != 0) 
  2783. {
  2784. fprintf(fpout,"Sender: %srn",xtdsender);
  2785. sprintf(xtdsender,"");
  2786. sprintf(templine,"");
  2787. }
  2788. }
  2790. if (stricmp(templine,"rn") == 0)
  2791. {
  2792. if (strlen(xtdsender) != 0) fprintf(fpout,"Sender: %srn",xtdsender);
  2793. if (strlen(reply_to) != 0) fprintf(fpout,"Reply-To: %srn",reply_to);
  2795. fprintf(fpout,"rn");
  2796. insideheader = FALSE;
  2797. }
  2798. else
  2799. {
  2800. fprintf(fpout,"%s",templine);
  2801. }
  2802. }
  2803. else
  2804. {
  2805. fprintf(fpout,"%s",templine);
  2806. }
  2808. }
  2809. }
  2810. fclose(fpin);
  2811. fclose(fpout);
  2812. CopyFile(m_strExePath+"\" + tempfile,m_strExePath+"\mail\" + Fname,FALSE );
  2813. DeleteFile(m_strExePath+"\"+tempfile);
  2814. }
  2815. }
  2816. }
  2817. fclose(fpf);
  2818. }
  2819. }
  2820. }
  2822. }
  2823. }   while (FindNextFile(hFind, &findData));
  2825. FindClose (hFind);
  2826. }
  2827. }
  2829. if ((fwd == FALSE) && (listmail == FALSE)) //dont know that user
  2830. {
  2831. //send to user who receives all unknown stuff
  2832. short nUnknownFlag;
  2833. BSTR BstrForwardUserID;
  2834. CString strForwardUserID;
  2835. m_pMailConfig->GetForwardUnknowMailUserConfig(&nUnknownFlag, &BstrForwardUserID);
  2836. if(nUnknownFlag == 1)
  2837. {
  2838. _bstr_t bstrForwardUserID(BstrForwardUserID, FALSE);
  2839. strForwardUserID = (char*)bstrForwardUserID;
  2841. //char mkd[255];
  2842. CString strmkd;
  2843. strmkd.Format("%s\mail\%s", m_strExePath, strForwardUserID);
  2844. CreateDirectory((LPCTSTR)strmkd, NULL);
  2845. //sprintf(mkd,"mail\%s",strForwardUserID);
  2846. //mkdir(mkd);
  2847. CopyFile(m_strExePath+"\mail\" + Fname,m_strExePath+"\mail\" + strForwardUserID +  "\"  + Fname,FALSE );    
  2848. }
  2849. //after that lets relay (if allowed)
  2850. BOOL islocal = FALSE;
  2852. if (aka_ok == FALSE)
  2853. {
  2854. char tempstra[255];
  2855. sprintf(tempstra,"%s",Sender);
  2856. int ps = 0;
  2857. for (UINT ci = 0;ci<strlen(tempstra);ci++)
  2858. {
  2859. if(tempstra[ci] == '@')
  2860. {
  2861. ps = ci;
  2862. }
  2863. }
  2865. for (UINT xi = ps;xi<strlen(tempstra);xi++)
  2866. {
  2867. tempstra[xi-ps] = tempstra[xi+1];
  2869. }
  2870. tempstra[xi-ps-4] = '';
  2871. strlwr(tempstra);
  2874. /* for (int bb = 0;bb<= MyAkaList.GetSize()-1;bb++)
  2875. {
  2877. if (strcmpi(MyAkaList[bb].Text,tempstra) == 0) 
  2878. {
  2879. islocal = TRUE;
  2880. }
  2881. }
  2882. */
  2883. CString str_tempstra;
  2884. str_tempstra.Format("%s", tempstra);
  2885. short nHostCount;
  2886. BSTR BstrHostName;
  2887. CString strHostName;
  2888. m_pMailConfig->GetHostNameCount(&nHostCount);
  2889. for(int i=1; i<=nHostCount; i++) //index begins from 1
  2890. {
  2891. m_pMailConfig->GetHostName(i, &BstrHostName);
  2892. _bstr_t bstrHostName(BstrHostName, FALSE);
  2893. strHostName = (char*)bstrHostName;
  2895. if(strHostName == str_tempstra)
  2896. {
  2897. islocal = TRUE;
  2898. break;
  2899. }
  2900. }
  2902. // char tempstr2[255];
  2903. // sprintf(tempstr2,"%s",GetReg("Software\InetServ","SMTPRelayCheckHost"));
  2906. BOOL sender_ok = TRUE;
  2907. /* //lets check if we must validate hosts
  2908. if (strcmp(tempstr2,"TRUE") == 0)
  2909. {
  2910. if (islocal == FALSE) sender_ok = FALSE;
  2912. }
  2913. */
  2914. if (sender_ok == TRUE)
  2915. {
  2916. //mkdir("spool");
  2917. CString str_spool;
  2918. str_spool.Format("%s\spool", m_strExePath);
  2919. CreateDirectory((LPCTSTR)str_spool, NULL);
  2921. SMTPForwardInfo fwdinf;
  2922. //we generate a new filename for each send
  2923. //so we can easely delete the file
  2924. CTime t = CTime::GetCurrentTime();
  2925. SYSTEMTIME stime;
  2926. GetSystemTime(&stime);
  2928. char fnamenew[255];
  2929. sprintf(fnamenew,"%i%02i%02i%02i%02i%02i%i.out",t.GetYear(),t.GetMonth(),t.GetDay(),t.GetHour(),t.GetMinute(),t.GetSecond(),stime.wMilliseconds);
  2932. fwdinf.Fname = "spool\" + (CString)fnamenew;
  2933. fwdinf.error= 0;
  2934. fwdinf.sendnr = 0;
  2935. fwdinf.Sender= Sender;
  2936. fwdinf.Rcpt= rcptFull;
  2937. //memset(fwdinf.RcptHostName,0x0,255);
  2938. strcpy(fwdinf.RcptHostName,strRcpt);
  2940. time_t theTime;
  2941. time(&theTime);
  2942. fwdinf.timestamp = theTime;
  2943. fwdinf.islocal = true;
  2945. CopyFile(m_strExePath+"\mail\" + Fname,m_strExePath+"\"+fwdinf.Fname ,FALSE );
  2946. m_logFile.WriteLog("Relaying mail...");
  2947. ::EnterCriticalSection(&m_csSMTPForward);
  2948. m_SMTPForwardList.Add(fwdinf); //have fun :)
  2949. ::LeaveCriticalSection(&m_csSMTPForward);
  2950. }
  2951. else
  2952. {
  2953. //user not known to me, mail dropped
  2954. m_logFile.WriteLog("Relay tried to use by non local user: " + Sender);
  2955. }
  2956. }
  2957. else
  2958. {
  2959. CopyFile(m_strExePath+"\mail\" + Fname,m_strExePath+"\mail\unknown\"  + Fname,FALSE );
  2961. char logstr[255];
  2962. sprintf(logstr,"User not local: %s (mail\unknown\%s)n",tempstr,Fname);
  2963. LogError(logstr);
  2965. strLog.Format("Could not send %s",tempstr);
  2966. m_logFile.WriteLog(strLog);
  2967. }
  2969. }
  2970. }
  2971. }
  2972. }
  2973. }
  2975. fclose(stream);
  2977. DeleteFile(m_strExePath+"\"+"mail\" + Fname);
  2978. DeleteFile(m_strExePath+"\"+"mail\" + CTL);
  2979.    }
  2980.    else
  2981.    {
  2982.    
  2983.    m_logFile.WriteLog("WARNING! Could not process NewMail"); //this is a hard error!
  2984.    }
  2985. }
  2987. void LogError (CString expr)//log to logfiles\error.txt
  2988. {
  2989. CTime t = CTime::GetCurrentTime();
  2991. FILE *x;
  2992. CString logcstr = expr + "rn";
  2993. CString strLogfiles;
  2994. //mkdir ("logfiles");
  2995. CString strLog;
  2996. strLogfiles.Format("%s\logfiles", m_strExePath, NULL);
  2997. CreateDirectory((LPCTSTR)strLogfiles, NULL);
  3000. if( (x = fopen(m_strExePath+"\logfiles\error.txt", "at" )) != NULL )
  3001. {
  3002. fprintf(x,"%02i:%02i:%02i: %s",t.GetHour(),t.GetMinute(),t.GetSecond(),logcstr);
  3003. fclose(x);
  3004. }
  3005. }
  3007. bool AddMessageID(CString strFileName)
  3008. {
  3009. BOOL bHasMsgID = FALSE;
  3011. int nLines = 0;
  3012. char chMessageID[255];
  3014. char chFile[255];
  3015. sprintf(chFile, "%s\mail\%s", m_strExePath, strFileName);
  3017. char filebuff[255], filebuff_temp[255];
  3018. FILE* fstream = fopen(chFile, "a+t");
  3019. if(fstream != NULL)
  3020. {
  3021. fseek(fstream, 0, SEEK_SET);
  3022. while(!feof(fstream))
  3023. {
  3024. fgets(filebuff, 255, fstream);
  3025. filebuff[strlen(filebuff)-2] = 'n';
  3026. filebuff[strlen(filebuff)-1] = '';
  3028. sprintf(filebuff_temp, "%s", filebuff);
  3029. strupr(filebuff_temp);
  3031. if(!feof(fstream))
  3032. {
  3033. nLines++;
  3035. if((nLines > 10)||(bHasMsgID == TRUE))
  3036. break;
  3038. if((filebuff_temp[0] == 'M')&&(filebuff_temp[1] == 'E')
  3039. &&(filebuff_temp[2] == 'S')&&(filebuff_temp[3] == 'S')
  3040. &&(filebuff_temp[4] == 'A')&&(filebuff_temp[5] == 'G')
  3041. &&(filebuff_temp[6] == 'E')&&(filebuff_temp[7] == '-')
  3042. &&(filebuff_temp[8] == 'I')&&(filebuff_temp[9] == 'D')
  3043. &&(filebuff_temp[10] == ' '))
  3044. {
  3045. bHasMsgID = TRUE;
  3046. break;
  3047. }
  3048. }
  3049. }
  3051. if(bHasMsgID == FALSE)
  3052. {
  3053. fclose(fstream);
  3055. char chFileNew[255];
  3056. sprintf(chFileNew, "%s\mail\%s_temp", m_strExePath, strFileName);
  3057. rename(chFile, chFileNew);
  3059. FILE* fs = fopen(chFile, "w+b");
  3060. if(fs != NULL)
  3061. {
  3062. //产生message-id
  3063. time_t tm;
  3064. time(&tm);
  3065. srand((unsigned)time(NULL));
  3066. sprintf(chMessageID, "Message-ID: <%d.%d.smartmailserver@m_office.com>rn", tm, rand());
  3067. //写入MessageID
  3068. fprintf(fs, "%s", chMessageID);
  3069. FILE* fs_old = fopen(chFileNew, "rb");
  3070. char file_content[255];
  3071. int rdcount=0;
  3072. if(fs_old != NULL)
  3073. {
  3074. while(!feof(fs_old))
  3075. {
  3076. rdcount = fread(file_content, sizeof(char), 255, fs_old);
  3077. fwrite(file_content, sizeof(char), rdcount, fs);
  3078. }
  3079. fclose(fs);
  3080. fclose(fs_old);
  3081. DeleteFile(chFileNew);
  3082. }
  3083. else
  3084. {
  3085. fclose(fs);
  3086. DeleteFile(chFile);
  3087. rename(chFileNew, chFile);
  3088. }
  3089. }
  3090. else
  3091. {
  3092. rename(chFileNew, chFile);
  3093. }
  3094. }
  3095. else
  3096. fclose(fstream);
  3098. }
  3100. return true;
  3101. }
  3103. bool DealMailInfo(CString strFileName, CString strSender, CString strRecver)
  3104. {
  3105. CString strLog;
  3107. char chFile[255];
  3108. sprintf(chFile, "%s\%s", m_strExePath, strFileName);
  3110. //发送UDP数据包，并将相关的接收信息写入数据库
  3111. HANDLE hFile = CreateFile(chFile, 
  3112.   GENERIC_READ,
  3113.   FILE_SHARE_READ,
  3114.   NULL,
  3115.   OPEN_EXISTING, 
  3116.   FILE_ATTRIBUTE_NORMAL, 
  3117.   NULL);
  3118. if(hFile == NULL)
  3119. {
  3120. strLog.Format("Open File %s failed while Send UDP Info", strFileName);
  3121. m_logFile.WriteLog(strLog);
  3122. return false;
  3123. }
  3125. DWORD dwSize = GetFileSize(hFile, NULL);
  3126. if(dwSize == -1)
  3127. {
  3128. strLog.Format("GetFileSize() failed, ErrorCode=%d", GetLastError());
  3129. CloseHandle(hFile);
  3130. return false;
  3131. }
  3132. CloseHandle(hFile);
  3134. CString strTime, strSubject;
  3135. char tempstr[255];
  3137. long lSize = (long)(dwSize*0.75);
  3139. char filebuff[255], filebuff_temp[255];
  3140. short sFlag=0;
  3141. FILE *fstream = fopen(chFile, "rt");
  3143. if(fstream != NULL)
  3144. {
  3145. while(!feof(fstream))
  3146. {
  3147. fgets(filebuff, 255, fstream);
  3148. //filebuff[strlen(filebuff)-2] = 'n';
  3149. filebuff[strlen(filebuff)-1] = '';
  3150. if(filebuff[0]=='')
  3151. break;
  3153. sprintf(filebuff_temp, "%s", filebuff);
  3154. strupr(filebuff_temp);
  3156. if(!feof(fstream))
  3157. {
  3158. //Date:
  3159. if((filebuff_temp[0] == 'D') && (filebuff_temp[1] == 'A') && (filebuff_temp[2] == 'T')
  3160. && (filebuff_temp[3] == 'E') && (filebuff_temp[4] == ':'))
  3161. {
  3162. for(int i=0; i<strlen(filebuff); i++)
  3163. tempstr[i] = filebuff[i+6];
  3164. strTime.Format("%s", tempstr);
  3165. strTime.TrimRight();
  3167. sFlag++;
  3168. continue;
  3169. }
  3170. //Subject
  3171. if((filebuff_temp[0] == 'S') && (filebuff_temp[1] == 'U') && (filebuff_temp[2] == 'B')
  3172. && (filebuff_temp[3] == 'J') && (filebuff_temp[4] == 'E') && (filebuff_temp[5] == 'C')
  3173. && (filebuff_temp[6] == 'T') && (filebuff_temp[7] == ':'))
  3174. {
  3175. sprintf(tempstr, "%s", &filebuff[9]);
  3176. strSubject.Format("%s", tempstr);
  3177. strSubject.TrimRight();
  3179. sFlag++;
  3180. continue;
  3181. }
  3182. }
  3183. }
  3184. fclose(fstream);
  3185. }
  3187. if(sFlag != 2)
  3188. return false;
  3190. int npos, nlen;
  3191. npos = strRecver.Find('<');
  3192. nlen = strRecver.GetLength();
  3193. strRecver = strRecver.Right(nlen - npos - 1);
  3194. npos = strRecver.Find('>');
  3195. strRecver = strRecver.Left(npos);
  3197. npos = strSender.Find('<');
  3198. nlen = strSender.GetLength();
  3199. strSender = strSender.Right(nlen - npos - 1);
  3200. npos = strSender.Find('>');
  3201. strSender = strSender.Left(npos);
  3203. _UDPPacketInfo data;
  3204. sprintf(data.recver, "%s", strRecver);
  3205. sprintf(data.sender, "%s", strSender);
  3206. sprintf(data.title, "%s", strSubject);
  3207. sprintf(data.time, "%s", strTime);
  3208. data.size = htonl(lSize);
  3210. if(!SendUDPData(data))
  3211. {
  3212. strLog.Format("Failed to Send UDP : Recver=%s, Sender=%s, Subject=%s, Date=%s, Size=%d",
  3213. strRecver, strSender, strSubject, strTime, lSize);
  3214. m_logFile.WriteLog(strLog);
  3215. }
  3216. else
  3217. {
  3218. strLog.Format("Succeed to Send UDP : Recver=%s, Sender=%s, Subject=%s, Date=%s, Size=%d",
  3219. strRecver, strSender, strSubject, strTime, lSize);
  3220. m_logFile.WriteLog(strLog);
  3221. }
  3224. if(!WriteMailInfoToDB(strSender, strRecver, strSubject, strTime, lSize))
  3225. {
  3226. strLog.Format("Failed to Insert RecvInfo to DB : Recver=%s, Sender=%s, Subject=%s, Date=%s, Size=%d",
  3227. strRecver, strSender, strSubject, strTime, lSize);
  3228. m_logFile.WriteLog(strLog);
  3229. }
  3230. else
  3231. {
  3232. strLog.Format("Succeed to Insert RecvInfo to DB : Recver=%s, Sender=%s, Subject=%s, Date=%s, Size=%d",
  3233. strRecver, strSender, strSubject, strTime, lSize);
  3234. m_logFile.WriteLog(strLog);
  3235. }
  3237. return true;
  3238. }
  3240. bool SendUDPData(_UDPPacketInfo udpData)
  3241. {
  3242. struct sockaddr_in udpadd;
  3243. memset(&udpadd, 0x0, sizeof(sockaddr_in));
  3244. udpadd.sin_family = AF_INET;
  3245. udpadd.sin_port = htons(m_nUDPPort);
  3246. udpadd.sin_addr.s_addr = inet_addr(m_strUDPIP);
  3248.     int nRet = sendto(m_UdpSocket, (char*)&udpData, sizeof(_UDPPacketInfo), 0, (struct sockaddr*)&udpadd, sizeof(udpadd));
  3249. if(nRet < 0)
  3250. return false;
  3251. return true;
  3252. }
  3254. bool WriteMailInfoToDB(CString strSender, CString strRecver, CString strTitle, CString strTime, long lSize)
  3255. {
  3256. if(m_pMailDB == NULL)
  3257. return false;
  3258. BSTR BstrSender, BstrRecver, BstrTitle, BstrTime;
  3259. BstrSender = strSender.AllocSysString();
  3260. BstrRecver = strRecver.AllocSysString();
  3261. BstrTitle = strTitle.AllocSysString();
  3262.     BstrTime = strTime.AllocSysString();
  3264. HRESULT hr;
  3265. hr = m_pMailDB->InsertRecvMailInfo(BstrTime, BstrTitle, BstrSender, BstrRecver, lSize);
  3266. if(FAILED(hr))
  3267. return false;
  3269. return true;
  3270. }
  3272. //直接发送到目的地，
  3273. int SendSmtpMailDirect(int litem) //relay
  3274. {
  3276. SOCKET         hServer;
  3277. char           szBuffer[4096];
  3278. SOCKADDR_IN    SockAddr;
  3280. // WSADATA        WSData;
  3282. LPHOSTENT      lpHostEntry;
  3283. int            iProtocolPort;
  3284. char           ServerName[255];
  3286. BSTR BstrDnsSmtpServer;
  3287. m_pMailConfig->GetDnsServerName(&BstrDnsSmtpServer);
  3288. bstr_t bstrDnsSmtpServer(BstrDnsSmtpServer, FALSE);
  3290. sprintf(ServerName,"%s",(char*)bstrDnsSmtpServer);
  3292. //加入获取Mx记录,把原来设置的转发服务器变为DNS服务器的设置
  3293. char* pchDestMachine;
  3294. pchDestMachine=GetMX(m_SMTPForwardList[litem].RcptHostName,ServerName,1);
  3296. CString strDestMachine=pchDestMachine;
  3297. if(strDestMachine.GetLength()<1)
  3298. {
  3299. return 1;
  3300. }
  3301. HeapFree(GetProcessHeap(),HEAP_NO_SERIALIZE,pchDestMachine);
  3302. strDestMachine=strDestMachine.Left(strDestMachine.Find(" "));
  3303. CString strLog;
  3304. strLog.Format("Relay To:%s",strDestMachine);
  3305. m_logFile.WriteLog(strLog);
  3306. int nPos=strDestMachine.Find("n");
  3307. if(nPos!=-1)
  3308. {
  3309. strDestMachine=strDestMachine.Left(strDestMachine.Find("n"));
  3310. }
  3311. lpHostEntry = gethostbyname(strDestMachine);
  3312. if (lpHostEntry == NULL) 
  3313. {
  3314. // WSACleanup();
  3315. strLog.Format("Error1");
  3316. m_logFile.WriteLog(strLog);
  3317. return 1;
  3318. }
  3320. hServer = socket( PF_INET, SOCK_STREAM, 0); 
  3321. if (hServer == INVALID_SOCKET) 
  3322. {
  3323. strLog.Format("Error2");
  3324. m_logFile.WriteLog(strLog);
  3325. closesocket( hServer );
  3326. // WSACleanup();
  3327. return 1;
  3328. }
  3330. iProtocolPort = htons(25);
  3332. SockAddr.sin_family = AF_INET;
  3333. SockAddr.sin_port = iProtocolPort;
  3334. SockAddr.sin_addr = *((LPIN_ADDR)*lpHostEntry->h_addr_list);
  3336. int stimeout = 60000;
  3337. int rtimeout = 60000;
  3339. int err;
  3341. if (stimeout != 0) 
  3342. {
  3343. err = setsockopt(hServer ,      
  3344.  SOL_SOCKET,     
  3345.  SO_SNDTIMEO,
  3346.  (char *)&stimeout,  
  3347.  sizeof(stimeout) );
  3348. if (err != NO_ERROR) 
  3349. {
  3350. strLog.Format("Error3");
  3351. m_logFile.WriteLog(strLog);
  3352. closesocket( hServer );
  3353. // WSACleanup();
  3354. return 1;
  3355. }
  3356. }
  3358. if (rtimeout != 0) 
  3359. {
  3360. err = setsockopt(hServer ,      
  3361.  SOL_SOCKET,     
  3362.  SO_RCVTIMEO,
  3363.  (char *)&rtimeout,  
  3364.  sizeof(rtimeout) );
  3366. if (err != NO_ERROR) 
  3367. {
  3368. strLog.Format("Error4");
  3369. m_logFile.WriteLog(strLog);
  3370. closesocket( hServer );
  3371. // WSACleanup();
  3372. return 1;
  3373. }
  3374. }
  3375. if (connect( hServer, (PSOCKADDR) &SockAddr, sizeof(SockAddr)))
  3376. {
  3377. strLog.Format("Error5");
  3378. m_logFile.WriteLog(strLog);
  3379. closesocket(hServer);
  3380. // WSACleanup();
  3381. return 1;
  3382. }
  3384. //AskError();
  3386. int cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  3388. if (cnt == SOCKET_ERROR)
  3389. { 
  3390. strLog.Format("Error6");
  3391. m_logFile.WriteLog(strLog);
  3392. closesocket( hServer );
  3393. // WSACleanup();
  3394. return 1;
  3395. }
  3397. if (szBuffer[0] != '2') 
  3398. {
  3399. strLog.Format("Error7");
  3400. m_logFile.WriteLog(strLog);
  3401. closesocket( hServer );
  3402. // WSACleanup();
  3403. return 1;
  3404. }
  3406. char sendstr[255];
  3408. BSTR BstrHostName;
  3409. m_pMailConfig->GetHostName(1, &BstrHostName);
  3410. bstr_t bstrHostName(BstrHostName, FALSE);
  3412. sprintf(sendstr,"HELO %srn",(char*)bstrHostName);
  3413. cnt = send( hServer, sendstr, strlen(sendstr), 0);
  3415. if (cnt == SOCKET_ERROR)
  3416. { 
  3417. strLog.Format("Error8");
  3418. m_logFile.WriteLog(strLog);
  3419. closesocket( hServer );
  3420. // WSACleanup();
  3421. return 1;
  3422. }
  3424. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  3426. if (cnt == SOCKET_ERROR)
  3427. { 
  3428. strLog.Format("Error9");
  3429. m_logFile.WriteLog(strLog);
  3430. closesocket( hServer );
  3431. // WSACleanup();
  3432. return 1;
  3433. }
  3435. if (szBuffer[0] != '2') 
  3436. {
  3437. closesocket( hServer );
  3438. // WSACleanup();
  3439. return 1;
  3440. }
  3443. sprintf(sendstr,"%s",m_SMTPForwardList[litem].Sender);
  3444. cnt = send( hServer, sendstr, strlen(sendstr), 0);
  3446. if (cnt == SOCKET_ERROR)
  3447. { 
  3448. closesocket( hServer );
  3449. // WSACleanup();
  3450. return 1;
  3451. }
  3453. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  3455. if (cnt == SOCKET_ERROR)
  3456. { 
  3457. closesocket( hServer );
  3458. // WSACleanup();
  3459. return 1;
  3460. }
  3462. if (szBuffer[0] != '2') 
  3463. {
  3464. closesocket( hServer );
  3465. // WSACleanup();
  3466. return 1;
  3467. }
  3469. sprintf(sendstr,"%srn", m_SMTPForwardList[litem].Rcpt);
  3470. cnt = send( hServer, sendstr, strlen(sendstr), 0);
  3472. if (cnt == SOCKET_ERROR)
  3473. { 
  3474. closesocket( hServer );
  3475. // WSACleanup();
  3476. return 1;
  3477. }
  3479. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  3481. if (cnt == SOCKET_ERROR)
  3482. { 
  3483. strLog.Format("Error12");
  3484. m_logFile.WriteLog(strLog);
  3485. closesocket( hServer );
  3486. // WSACleanup();
  3487. return 1;
  3488. }
  3490. if (szBuffer[0] != '2') 
  3491. {
  3492. strLog.Format("Error13");
  3493. m_logFile.WriteLog(strLog);
  3494. closesocket( hServer );
  3495. // WSACleanup();
  3496. return 1;
  3497. }
  3500. sprintf(sendstr,"DATArn");
  3502. cnt = send( hServer, sendstr, strlen(sendstr), 0);
  3504. if (cnt == SOCKET_ERROR)
  3505. { 
  3506. closesocket( hServer );
  3507. // WSACleanup();
  3508. return 1;
  3509. }
  3511. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  3513. if (cnt == SOCKET_ERROR)
  3514. { 
  3515. closesocket( hServer );
  3516. // WSACleanup();
  3517. return 1;
  3518. }
  3520. if (szBuffer[0] != '3')
  3521. {
  3522. closesocket( hServer );
  3523. // WSACleanup();
  3524. return 1;
  3525. }
  3527. FILE *fp = fopen(m_strExePath+"\"+m_SMTPForwardList[litem].Fname,"rb");
  3528. strLog.Format("Open file:%s",m_SMTPForwardList[litem].Fname);
  3529. m_logFile.WriteLog(strLog);
  3531. if (fp == NULL) 
  3532. {
  3533. closesocket( hServer );
  3534. // WSACleanup();
  3535. return 1;
  3536. }
  3538. char tempstr[255];
  3539. while(!feof(fp))
  3540. {
  3541. fgets(tempstr,255,fp);
  3542. //tempstr[strlen(tempstr)-2] = 'n';
  3543. tempstr[strlen(tempstr)] = '';
  3545. if (!feof(fp))
  3546. {
  3548. cnt = send( hServer, tempstr, strlen(tempstr), 0);
  3549. if (cnt == SOCKET_ERROR)
  3550. { 
  3551. fclose(fp);
  3552. closesocket( hServer );
  3553. // WSACleanup();
  3554. return 1;
  3555. }
  3556. }
  3558. }
  3559. fclose(fp);
  3561. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  3563. if (cnt == SOCKET_ERROR)
  3564. { 
  3565. closesocket( hServer );
  3566. // WSACleanup();
  3567. return 1;
  3568. }
  3569. if (szBuffer[0] != '2')
  3570. {
  3571. closesocket( hServer );
  3572. // WSACleanup();
  3573. return 1;
  3574. }
  3576. sprintf(sendstr,"QUITrn");
  3578. cnt = send( hServer, sendstr, strlen(sendstr), 0);
  3580. if (cnt == SOCKET_ERROR)
  3581. { 
  3582. closesocket( hServer );
  3583. // WSACleanup();
  3584. return 1;
  3585. }
  3587. cnt = recv( hServer, szBuffer, sizeof(szBuffer), 0);
  3589. if (cnt == SOCKET_ERROR)
  3590. { 
  3591. closesocket( hServer );
  3592. // WSACleanup();
  3593. return 1;
  3594. }
  3596. if (szBuffer[0] != '2') 
  3597. {
  3598. closesocket( hServer );
  3599. // WSACleanup();
  3600. return 1;
  3601. }
  3604. closesocket( hServer );
  3605. // WSACleanup();
  3607. return 0;
  3608. }
  3610. BOOL IsLocalUser(const char* tempstr)
  3611. {
  3612. BOOL bRet;
  3613. CString rcpt;
  3614. char srcpt[255];
  3615. char srcptip[255];
  3618. CString rcptFull;
  3619. rcptFull=tempstr;
  3620. bRet=FALSE;
  3622. if (rcptFull.GetAt(rcptFull.GetLength()-2) == 'n') 
  3623. rcptFull.SetAt(rcptFull.GetLength()-2,'');
  3624. if (rcptFull.GetAt(rcptFull.GetLength()-2) == 'r') 
  3625. rcptFull.SetAt(rcptFull.GetLength()-2,'');
  3627. int beginsign= -1;
  3628. int endsign= -1;
  3629. int atsign= -1;
  3631. for (UINT i = 0;i<= strlen(rcptFull);i++)
  3632. {
  3633. if (rcptFull.GetAt(i) == '@') atsign = i;
  3634. if (rcptFull.GetAt(i) == '<') beginsign = i;
  3635. if (rcptFull.GetAt(i) == '>') endsign = i;
  3636. }
  3638. if ((beginsign==  -1) || (endsign==  -1) || (atsign==  -1))
  3639. {
  3640. bRet=FALSE;
  3641. }
  3642. else
  3643. {
  3644. beginsign++;
  3646. for (int z = beginsign;z<=atsign;z++)
  3647. {
  3648. srcpt[z-beginsign] = rcptFull[z];
  3650. }
  3651. srcpt[z-beginsign-1] = '';
  3653. atsign++;
  3654. for (z = atsign;z<=endsign;z++)
  3655. {
  3656. srcptip[z-atsign] = rcptFull[z];
  3658. }
  3659. srcptip[z-atsign-1] = '';
  3662. rcpt = srcptip;
  3663. BOOL aka_ok = FALSE;
  3664. CString strRcpt;
  3665. strRcpt.Format("%s", rcpt);
  3666. short nHostCount;
  3667. BSTR BstrHostName;
  3668. CString strHostName;
  3669. m_pMailConfig->GetHostNameCount(&nHostCount);
  3670. for(int i=1; i<=nHostCount; i++) //index begins from 1
  3671. {
  3672. m_pMailConfig->GetHostName(i, &BstrHostName);
  3673. _bstr_t bstrHostName(BstrHostName, FALSE);
  3674. strHostName = (char*)bstrHostName;
  3676. if(strHostName == strRcpt)
  3677. {
  3678. aka_ok = TRUE;
  3679. break;
  3680. }
  3681. }
  3682. if( aka_ok)
  3683. {
  3684. bRet=TRUE;
  3685. }
  3686. }
  3687. return bRet;
  3688. }