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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Ftp客户端 > 查看源码
FtpFunction.cpp
资源名称：FTP总集.rar　[点击查看]
上传用户：tjfeida
上传日期：2013-03-10
资源大小：1917k
文件大小：40k
源码类别：

Ftp客户端

开发平台：

Visual C++

FtpFunction.cpp：源码内容
  1. // FtpTransmitFile.cpp: implementation of the CFtpTransmitFile class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  4. /*********************************************
  5. **该文件是属于WolfFTP工程中的。如果有什么问题
  6. **请联系
  7. **         tablejiang@21cn.com
  8. **或者访问
  9. **         http://wolfftp.51.net
  10. **以得到最新的支持。
  11. *********************************************/
  12. #include "stdafx.h"
  13. #include "QuickFTP.h"
  14. #include "FtpFunction.h"
  15. #include "InputFileNameDlg.h"
  16. #include "shlwapi.h"
  18. #ifdef _DEBUG
  19. #undef THIS_FILE
  20. static char THIS_FILE[]=__FILE__;
  21. #define new DEBUG_NEW
  22. #endif
  24. //////////////////////////////////////////////////////////////////////
  25. // Construction/Destruction
  26. //////////////////////////////////////////////////////////////////////
  28. CFtpFunction::CFtpFunction()
  29. {
  30. m_bAskUser = true ;
  31. m_iWhenExistAction = 0 ;
  32. }
  34. CFtpFunction::~CFtpFunction()
  35. {
  37. }
  39. /***********************************************************
  40. ** @Description:
  41. ** Send "ABORrn" command to fpt server, 
  42. abord the current data link .
  43. ** @Parameter:
  44. **
  45. ** @Return: 
  46. ** @Author:    Table.JHM.太子
  47. ** e-mail: tablejiang@21cn.com
  48. ** Date: 2001 3 26
  49. *************************************************************/
  50. BOOL CFtpFunction::AbordThreadFunction()
  51. {
  52. char szCommand[MAX_PATH] ;
  53. memset( szCommand , 0 , MAX_PATH) ;
  54. closesocket( m_hDataSocket ) ;
  55. sprintf( szCommand , "ABORrn" ) ;
  56. SendFtpCommand( szCommand , m_hControlSocket ) ;
  57. ClearUpReceiveBuffer( ) ;
  58. return true ;
  59. }
  61. /***********************************************************
  62. ** @Description:
  63. ** check the ftp server is support broken download.
  64. **
  65. ** @Parameter:
  66. **
  67. ** @Return: if support return true ,else return false .
  68. ** @Author:    Table.JHM.太子
  69. ** e-mail: tablejiang@21cn.com
  70. ** Date: 2001 3 26
  71. *************************************************************/
  72. BOOL CFtpFunction::CheckBrokenDownload()
  73. {
  74. //set type I
  75. UINT nReplyCode = 0 ;
  76. nReplyCode = SendFtpCommand( "TYPE Irn" , m_hControlSocket ) ;
  77. if( nReplyCode != 200 )
  78. return false ;
  80. //reset file pointer.
  81. nReplyCode = SendFtpCommand( "REST 100rn" , m_hControlSocket ) ;
  82. if( nReplyCode >= 400 )
  83. return false ;
  84. if( nReplyCode == 350 )
  85. {
  86. m_SiteInfo.brokendownload = true ; 
  87. sprintf( m_szFtpBuffer , _T("站点支持断点续传") ) ;
  88. SendStatusStr( m_szFtpBuffer ) ;
  89. }
  90. else
  91. {
  92. m_SiteInfo.brokendownload = false ;
  93. sprintf( m_szFtpBuffer , _T("站点不支持断点续传") ) ;
  94. SendStatusStr( m_szFtpBuffer ) ;
  95. }
  97. //reset.
  98. nReplyCode = SendFtpCommand( "REST 0rn" , m_hControlSocket ) ;
  99. if( nReplyCode >= 400 )
  100. return false ;
  102. return true ;
  103. }
  105. /***********************************************************
  106. ** @Description:
  107. ** check the ftp server operate system type .
  108. **
  109. ** @Parameter:
  110. **
  111. ** @Return: if success return true , else return false 
  112. ** @Author:    Table.JHM.太子
  113. ** e-mail: tablejiang@21cn.com
  114. ** Date: 2001 3 26
  115. *************************************************************/
  116. BOOL CFtpFunction::CheckServerType()
  117. {
  118. UINT uReplyCode = 0 ;
  119. char szBuffer[1024] ;
  120. int iLength = 0 ;
  121. //send syst command .
  122. sprintf( szBuffer , "SYSTrn" ) ;
  123. if( send( m_hControlSocket , szBuffer , strlen( szBuffer ) , 0 ) == SOCKET_ERROR ) 
  124. {
  125. int iWinsockErr = WSAGetLastError( ) ;
  126. sprintf( m_szFtpBuffer , " %d error while Send ftp command !" , iWinsockErr ) ;
  127. MessageBox( NULL , m_szFtpBuffer , MSGBOX_TITLE , MB_OK ) ;
  128. return ( ERROR_FTP_CODE ) ;
  129. }
  131. //Send msg to window .
  132. SendMsgToParentWnd( szBuffer , true ) ;
  134. //receive server reply string .
  135. if( ( iLength = recv( m_hControlSocket , szBuffer , 1024 , 0 ) ) == SOCKET_ERROR )
  136. {
  137. int iWinsockErr = WSAGetLastError( ) ;
  138. sprintf( m_szFtpBuffer , " %d error while recv server reply!" , iWinsockErr ) ;
  139. MessageBox( NULL , m_szFtpBuffer , MSGBOX_TITLE , MB_OK ) ;
  140. return ( ERROR_FTP_CODE ) ;
  141. }
  142. if( iLength < MAX_PATH )
  143. szBuffer[ iLength ] = 0 ;
  144. else
  145. szBuffer[ MAX_PATH - 1 ] = 0 ;
  147. //Send msg to window .
  148. SendMsgToParentWnd( szBuffer , false ) ;
  150. UINT nReplyCode = GetReplyCode ( szBuffer ) ;
  151. if( nReplyCode >= 400 || nReplyCode <= 0 )
  152. return false ;
  154. if( strstr( szBuffer , "UNIX" ) != NULL )
  155. {
  156. m_SiteInfo.hosttype = 1 ;
  157. }
  158. else
  159. {
  160. if( strstr( szBuffer , _T("Windows_NT") ) != NULL )
  161. m_SiteInfo.hosttype = 2 ;
  162. else
  163. m_SiteInfo.hosttype = 1 ;
  164. }
  166. return true ;
  167. }
  169. /***********************************************************
  170. ** @Description:
  171. ** Because the receive buffer can leave some message,
  172. so we must clear the receive buffer before 
  173. send another command .
  174. ** @Parameter:
  175. ** void 
  176. **
  177. ** @Return: void
  178. ** @Author:    Table.JHM.太子
  179. ** e-mail: tablejiang@21cn.com
  180. ** Date: 2001 3 26
  181. *************************************************************/
  182. void CFtpFunction::ClearUpReceiveBuffer()
  183. {
  184. while( true ) 
  185. {
  186. if( !IsReadyToRead( m_hControlSocket ) )
  187. {
  188. return ;
  189. }
  190. GetServerReply(  m_hControlSocket ) ;
  191. }
  192. }
  194. /***********************************************************
  195. ** @Description:
  196. ** Create the specify directory in ftp server .
  197. **
  198. ** @Parameter:
  199. ** LPSTR szPath :the directory name which want create.
  200. **
  201. ** @Return: if success return true ,else return false .
  202. ** @Author:    Table.JHM.太子
  203. ** e-mail: tablejiang@21cn.com
  204. ** Date: 2001 3 26
  205. *************************************************************/
  206. BOOL CFtpFunction::CreateFtpDirectory(LPCTSTR szPath)
  207. {
  208. char szCommand[MAX_PATH] ;
  209. UINT nReplyCode = 0 ;
  211. sprintf( szCommand , "MKD %srn" , szPath ) ;
  212. nReplyCode = SendFtpCommand( szCommand , m_hControlSocket ) ;
  214. if( nReplyCode >= 400 )
  215. return false  ;
  216. else
  217. return true ;
  218. }
  219. /***********************************************************
  220. ** @Description:
  221. ** transmit file function . this function download or upload
  222. ** the specify file.
  223. **
  224. ** @Parameter:
  225. ** FTPFILEINFO* pParam : ftp file info.
  226. **
  227. ** @Return: success true ,else false .
  228. ** @Author:    Table.JHM.太子
  229. ** e-mail: tablejiang@21cn.com
  230. ** Date: 2001 3 26
  231. *************************************************************/
  232. BOOL CFtpFunction::PutGetFileFunction(FTPFILEINFO *pParam)
  233. {
  235. FTPFILEINFO FtpFileInfo ;
  236. memcpy( &FtpFileInfo , pParam , sizeof( FTPFILEINFO ) ) ;
  238. UINT nReplyCode ;
  239. SOCKET hDataSocket ;
  240. SOCKET hListenSocket ;
  241. char szCommand[MAX_PATH] ;
  243. //make full path name ;
  244. char szPathName[MAX_PATH] ;
  245. strcpy( szPathName , FtpFileInfo.localpath ) ;
  246. int iLength = strlen( FtpFileInfo.localpath ) ;
  247. if( szPathName[iLength-1 ] != '\' )
  248. {
  249. szPathName[iLength]= '\' ;
  250. szPathName[iLength+1] = '' ;
  251. }
  252. strcat( szPathName , FtpFileInfo.localfilename ) ;
  254. HANDLE hFile ;
  256. //open local file ,and set ftp file info.
  257. hFile = OpenLocalFile( &FtpFileInfo , szPathName ) ;//CreateFile( szPathName , GENERIC_READ | GENERIC_WRITE ,  FILE_SHARE_READ , NULL , OPEN_ALWAYS , FILE_ATTRIBUTE_NORMAL , 0 ) ;
  259. if( hFile == INVALID_HANDLE_VALUE )
  260. {
  261. return false ;
  262. }
  264. //entry the directory .
  265. //sprintf( szCommand , "CWD %srn" , pFtpFileInfo->remotepath ) ;
  266. //nReplyCode = ftp.SendFtpCommand( szCommand , pFtpFileInfo->hSocket ) ;
  267. //if ( nReplyCode >= 400 )
  268. // return false ;
  270. //make the command , is put or get file .
  271. //if put file to server , send command STOR.
  272. //if get file from server , send command RETR.
  273. memset( szCommand , 0 , MAX_PATH );
  275. /*
  276. if( FtpFileInfo.site.brokendownload )
  277. {
  278. char szTemp[MAX_PATH] ;
  279. strcpy( szCommand , "REST " ) ;
  280. _i64toa( FtpFileInfo.startpos , szTemp , 10 ) ;
  281. strcat( szCommand , szTemp ) ;
  282. strcat( szCommand , "rn" ) ;
  283. nReplyCode = SendFtpCommand( szCommand , FtpFileInfo.hSocket ) ;
  284. if( nReplyCode == 350 )
  285. MyFileSeek( hFile , FtpFileInfo.startpos ,  FILE_BEGIN ) ;
  286. }
  288. if( FtpFileInfo.bfileput )
  289. sprintf( szCommand , "STOR %srn" , FtpFileInfo.remotefilename ) ;
  290. else
  291. sprintf( szCommand , "APPE %srn" , FtpFileInfo.remotefilename ) ;
  292. */
  293. //make the broken transmit pos .
  294. MakeBrokenPos( szCommand , &FtpFileInfo , hFile ) ;
  296. //set data type to I.
  297. nReplyCode = SendFtpCommand( "TYPE Irn" , FtpFileInfo.hSocket ) ;
  298. if( nReplyCode >= 400 )
  299. {
  300. CloseHandle( hFile ) ;
  301. hFile = INVALID_HANDLE_VALUE ;
  302. return false ;
  303. }
  305. //make the date link 
  306. hListenSocket = CreateListenCannel( FtpFileInfo.hSocket ) ;
  307. if( hListenSocket == INVALID_SOCKET )
  308. {
  309. CloseHandle( hFile ) ;
  310. hFile = INVALID_HANDLE_VALUE ;
  311. return false ;
  312. }
  314. //send transmit command .
  315. nReplyCode = SendFtpCommand( szCommand , FtpFileInfo.hSocket ) ;
  316. if( nReplyCode >= 400 )
  317. {
  318. CloseHandle( hFile ) ;
  319. hFile = INVALID_HANDLE_VALUE ;
  320. return false ;
  321. }
  323. //accept the connected.
  324. hDataSocket = AcceptDataConnect( hListenSocket ) ;
  325. if( hDataSocket == INVALID_SOCKET )
  326. {
  327. CloseHandle( hFile ) ;
  328. hFile = INVALID_HANDLE_VALUE ;
  329. return false ;
  330. }
  332. //notify the parent wnd .
  333. SendFileNameToParentWnd( FtpFileInfo.remotefilename ) ;
  335. //start transmit.
  336. if( FtpFileInfo.bfileput )
  337. nReplyCode = WriteDataCannelFromFile( FtpFileInfo.hSocket , hDataSocket , hFile ) ;
  338. else
  339. nReplyCode = ReadDataCannelToFile( FtpFileInfo.hSocket , hDataSocket , hFile , FtpFileInfo.filesize ) ;
  341. //clear server reply buffer .
  342. ClearUpReceiveBuffer( ) ;
  344. closesocket( hListenSocket ) ;
  346. if( nReplyCode >= 400 || nReplyCode == 0 )
  347. {
  348. CloseHandle( hFile ) ;
  349. return false ;
  350. }
  352. m_FileQueue.DeleteItem( pParam ) ;
  354. return 1 ;
  355. }
  356. /***********************************************************
  357. ** @Description:
  358. ** this function is upload a directory to ftp server.
  359. ** this function use recursion arithmetic .
  360. **
  361. ** @Parameter:
  362. ** FTPFILEINFO* pFileInfo : the directory info.
  363. **
  364. ** @Return: success true ,else false .
  365. ** @Author:    Table.JHM.太子
  366. ** e-mail: tablejiang@21cn.com
  367. ** Date: 2001 3 26
  368. *************************************************************/
  369. BOOL CFtpFunction::UploadDirectory(FTPFILEINFO *pFileInfo)
  370. {
  371. FTPITEM* pItemQueueHead ;
  372. FTPITEM* pItemCur ;
  373. FTPFILEINFO FtpFileInfo ;
  374. char szPathBak[MAX_PATH] ;
  375. BOOL bRet ;
  377. //copy the dir info.
  378. memcpy( &FtpFileInfo , pFileInfo , sizeof( FTPFILEINFO ) ) ;
  380. //prepare the path .
  381. if( !MakeFtpUploadPath( &FtpFileInfo ) )
  382. return false ;
  384. //backup current path.
  385. strcpy( szPathBak , m_CurrentFtpDirectory ) ;
  387. CFileFind find ;
  388. CString Path = FtpFileInfo.localpath ;
  389. if( Path.Right( 1 ) != '\' )
  390. Path += '\' ;
  391. Path += "*.*" ;
  392. BOOL bFind = find.FindFile( Path ) ;
  394. pItemQueueHead = m_ListItem ;
  395. pItemCur = m_ListItem ;
  396. while( bFind )
  397. {
  398. bFind = find.FindNextFile( ) ;
  400. if( find.IsDirectory() && !find.IsDots( ) )
  401. {
  402. //is directory .
  403. FtpFileInfo.bfileput = true ;
  404. FtpFileInfo.bIsDirectory = true ;
  405. FtpFileInfo.endpos = 0 ;
  406. FtpFileInfo.startpos = 0 ;
  407. strcpy( FtpFileInfo.remotefilename , find.GetFileName( ) ) ;
  408. strcpy( FtpFileInfo.localfilename , find.GetFileName( ) ) ;
  409. //FtpFileInfo.hSocket = pFileInfo->hSocket ;
  410. //FtpFileInfo.hWnd = pFileInfo->hWnd ;
  411. UploadDirectory( &FtpFileInfo ) ;
  412. EnterFtpDirectory( szPathBak ) ;
  413. if( !GetCurrentFtpDir() )
  414. return false ;
  415. }
  416. if ( !find.IsDirectory() )
  417. {
  418. //is file .
  419. FtpFileInfo.bfileput = true ;
  420. FtpFileInfo.bIsDirectory = false ;
  421. FtpFileInfo.endpos = 0 ;
  422. //is the file already exist in server?
  423. FtpFileInfo.startpos = FindFileInFileList( find.GetFileName( ) , pItemCur ) ;
  425. strcpy( FtpFileInfo.remotefilename , find.GetFileName( ) ) ;
  426. strcpy( FtpFileInfo.localfilename , find.GetFileName( ) ) ;
  427. //broken transmit .
  428. bRet = BrokenDownload( &FtpFileInfo ) ;
  429. if( !bRet )
  430. return false ;
  431. }
  432. }
  433. //free the ftp file list.
  434. FreeItemList( pItemCur ) ;
  435. m_FileQueue.DeleteItem( pFileInfo ) ;
  437. return true ;
  438. }
  440. /***********************************************************
  441. ** @Description:
  442. ** the function is download a directory from server.
  443. ** this function use recursion arithmetic .
  444. **
  445. ** @Parameter:
  446. **
  447. ** @Return: 
  448. ** @Author:    Table.JHM.太子
  449. ** e-mail: tablejiang@21cn.com
  450. ** Date: 2001 3 26
  451. *************************************************************/
  452. BOOL CFtpFunction::DownLoadDirectory(FTPFILEINFO *pFileInfo)
  453. {
  454. FTPITEM* pItemQueueHead ;
  455. FTPITEM* pItemCur ;
  456. FTPFILEINFO FtpFileInfo ;
  457. char szPathBak[MAX_PATH] ;
  458. BOOL bRet = true ;
  460. memcpy( &FtpFileInfo , pFileInfo , sizeof( FTPFILEINFO ) ) ;
  462. //prepare the directory .
  463. if( !MakeFtpDownloadPath( &FtpFileInfo ) )
  464. return false ;
  466. //get the current dir .
  467. if( !GetCurrentFtpDir() )
  468. return false ;
  470. //backup current directory.
  471. strcpy( szPathBak , m_CurrentFtpDirectory ) ;
  473. if( m_ListItem->pNext == NULL )
  474. {
  475. m_FileQueue.DeleteItem( pFileInfo ) ;
  476. return true ;
  477. }
  479. pItemQueueHead = m_ListItem ;
  480. pItemCur = m_ListItem ;
  481. while( pItemCur->pNext != NULL )
  482. {
  483. //is directory .
  484. if( pItemCur->dwType == 1 )
  485. {
  486. //make directory info.
  487. FtpFileInfo.bfileput = false ;
  488. FtpFileInfo.bIsDirectory = true ;
  489. FtpFileInfo.endpos = 0 ;
  490. FtpFileInfo.startpos = 0 ;
  491. strcpy( FtpFileInfo.remotefilename , pItemCur->szName ) ;
  492. strcpy( FtpFileInfo.localfilename , pItemCur->szName ) ;
  493. //download directory.
  494. bRet = DownLoadDirectory( &FtpFileInfo ) ;
  495. //after download directory, we must recover the directory.
  496. EnterFtpDirectory( szPathBak ) ;
  497. if( !bRet )
  498. return false ;
  499. }
  500. else
  501. {
  502. FtpFileInfo.bfileput = false ;
  503. FtpFileInfo.bIsDirectory = false ;
  504. FtpFileInfo.endpos = 0 ;
  505. strcpy( FtpFileInfo.remotefilename , pItemCur->szName ) ;
  506. strcpy( FtpFileInfo.localfilename , pItemCur->szName ) ;
  508. char szFilePathName[MAX_PATH] ;
  509. sprintf( szFilePathName , "%s%s" , FtpFileInfo.localpath , 
  510. FtpFileInfo.localfilename ) ;
  511. FtpFileInfo.filesize = _atoi64( pItemCur->szSize ) ;
  513. //find the start pos.
  514. FtpFileInfo.startpos = FindFileInLocal( szFilePathName ) ;
  516. bRet = BrokenDownload( &FtpFileInfo ) ;
  518. if( !bRet )
  519. return false ;
  520. }
  521. pItemCur = pItemCur->pNext ;
  522. }
  524. //free the list.
  525. FreeItemList( pItemQueueHead ) ;
  526. m_FileQueue.DeleteItem( pFileInfo ) ;
  528. return true ;
  529. }
  531. /***********************************************************
  532. ** @Description:
  533. ** this function is perpare the download path .
  534. **
  535. ** @Parameter:
  536. ** FTPFILEINFO* pFileInfo : the download item info.
  537. **
  538. ** @Return: 
  539. ** @Author:    Table.JHM.太子
  540. ** e-mail: tablejiang@21cn.com
  541. ** Date: 2001 3 26
  542. *************************************************************/
  543. BOOL CFtpFunction::MakeFtpDownloadPath(FTPFILEINFO *pFileInfo)
  544. {
  545. int iLength = strlen( pFileInfo->localpath ) ;
  547. if( pFileInfo->localpath[iLength-1] != '\' )
  548. {
  549. pFileInfo->localpath[iLength] = '\' ;
  550. pFileInfo->localpath[iLength + 1] = '' ;
  551. }
  553. //make local path.
  554. strcat( pFileInfo->localpath , pFileInfo->remotefilename ) ;
  555. strcat( pFileInfo->localpath , "\" ) ;
  557. //create local path .
  558. CreateDirectory( pFileInfo->localpath , NULL ) ;
  560. //make remote path
  561. iLength = strlen( pFileInfo->remotepath ) ;
  562. if( pFileInfo->remotepath[iLength-1] != '/' )
  563. {
  564. pFileInfo->remotepath[iLength] = '/' ;
  565. pFileInfo->remotepath[iLength + 1] = '' ;
  566. }
  567. strcat( pFileInfo->remotepath , pFileInfo->remotefilename ) ;
  568. strcat( pFileInfo->remotepath , "/" ) ;
  570. //enter remote path.
  571. if( !EnterFtpDirectory( pFileInfo->remotepath ) )
  572. return false ;
  574. if( !GetCurrentFtpDir() )
  575. return false ;
  577. ListDirectory( false ) ;
  579. return true  ;
  581. }
  583. /***********************************************************
  584. ** @Description:
  585. ** this function is enter specify remote path .
  586. **
  587. ** @Parameter:
  588. ** LPSTR strPath : the remote path.
  589. **
  590. ** @Return: success return true ,else return false .
  591. ** @Author:    Table.JHM.太子
  592. ** e-mail: tablejiang@21cn.com
  593. ** Date: 2001 3 26
  594. *************************************************************/
  595. BOOL CFtpFunction::EnterFtpDirectory(LPSTR strPath)
  596. {
  597. char szCommand[MAX_PATH] ;
  598. UINT nReplyCode = 0 ;
  600. //make command .
  601. sprintf( szCommand , "CWD %srn" , strPath ) ;
  602. //send command .
  603. nReplyCode = SendFtpCommand( szCommand , m_hControlSocket ) ;
  605. if( nReplyCode >= 400 )
  606. return false  ;
  607. else
  608. return true ;
  610. }
  612. /***********************************************************
  613. ** @Description:
  614. ** this function is free the ftp file queue.
  615. **
  616. ** @Parameter:
  617. ** FTPITEM* pFtpItem :the file queue head pointer.
  618. **
  619. ** @Return: 
  620. ** @Author:    Table.JHM.太子
  621. ** e-mail: tablejiang@21cn.com
  622. ** Date: 2001 3 26
  623. *************************************************************/
  624. BOOL CFtpFunction::FreeItemList(FTPITEM * pFtpItem )
  625. {
  626. FTPITEM * pNextItem = pFtpItem ;
  627. FTPITEM * pCurItem = pFtpItem ;
  628. while( pNextItem != NULL )
  629. {
  630. pCurItem = pNextItem ;
  631. pNextItem = pNextItem->pNext ;
  632. try
  633. {
  634. delete pCurItem ;
  635. }
  636. catch(...)
  637. {
  638. TRACE( "memory delete error!" ) ;
  639. }
  640. pCurItem = NULL ;
  641. }
  642. return true ;
  643. }
  645. /***********************************************************
  646. ** @Description:
  647. ** this function is prepare the upload directory.
  648. **
  649. ** @Parameter:
  650. ** FTPFILEINFO* pFileInfo : the ftp file info.
  651. **
  652. ** @Return: 
  653. ** @Author:    Table.JHM.太子
  654. ** e-mail: tablejiang@21cn.com
  655. ** Date: 2001 3 26
  656. *************************************************************/
  657. BOOL CFtpFunction::MakeFtpUploadPath(FTPFILEINFO* pFileInfo )
  658. {
  659. int iLength = strlen( pFileInfo->localpath ) ;
  661. //make local path.
  662. if( pFileInfo->localpath[iLength-1] != '\' )
  663. {
  664. pFileInfo->localpath[iLength] = '\' ;
  665. pFileInfo->localpath[iLength + 1] = '' ;
  666. }
  668. strcat( pFileInfo->localpath , pFileInfo->localfilename ) ;
  669. iLength = strlen( pFileInfo->remotepath ) ;
  670. //create the fpt directory , 
  671. //we needn't to chech the success or not .
  672. CreateFtpDirectory( pFileInfo->remotefilename ) ;
  674. strcat( pFileInfo->localpath , "\" ) ;
  676. //make remote path.
  677. if( pFileInfo->remotepath[iLength-1] != '/' )
  678. {
  679. pFileInfo->remotepath[iLength] = '/' ;
  680. pFileInfo->remotepath[iLength + 1] = '' ;
  681. }
  682. strcat( pFileInfo->remotepath , pFileInfo->localfilename ) ;
  684. //enter remote path.
  685. if( !EnterFtpDirectory( pFileInfo->remotepath ) )
  686. return false ;
  688. strcat( pFileInfo->remotepath , "/" ) ;
  690. if( !GetCurrentFtpDir() )
  691. return false ;
  693. ListDirectory( false ) ;
  695. return true  ;
  696. }
  697. /***********************************************************
  698. ** @Description:
  699. ** this function list the current directory , and get
  700. ** current directory file list.
  701. ** @Parameter:
  702. ** BOOL bWantSend : is want send list to parent wnd ?
  703. **
  704. ** @Return: 
  705. ** @Author:    Table.JHM.太子
  706. ** e-mail: tablejiang@21cn.com
  707. ** Date: 2001 3 26
  708. *************************************************************/
  709. BOOL CFtpFunction::ListDirectory( BOOL bWantSend )
  710. {
  711. SOCKET hDataSocket ;
  712. SOCKET hListenSocket ;
  713. int nReplyCode = 0 ;
  715. //make the status .
  716. //sprintf( m_szFtpBuffer , "刷新文件列表rn" ) ;
  717. //SendStatusStr( m_szFtpBuffer ) ;
  719. nReplyCode = SendFtpCommand( "TYPE Arn" , m_hControlSocket ) ;
  720. if( nReplyCode >= 400 || nReplyCode <= 0 )
  721. return false ;
  723. hListenSocket = CreateListenCannel( m_hControlSocket ) ;
  724. if( hListenSocket == INVALID_SOCKET )
  725. return false ;
  727. nReplyCode = SendFtpCommand( "LISTrn" , m_hControlSocket ) ;
  728. if( nReplyCode >= 400 || nReplyCode <= 0 )
  729. return false ;
  731. //now let UI wait the thread receive list data complete .
  732. char* pStr ;
  733. pStr = new char[1];
  734. pStr[0] = '' ;
  735. ::PostMessage( m_hWndInfo.hInfoWnd , FTP_SEND_COMMAND_MSG , 0 , (LPARAM)pStr );
  737. //accept the server connect socket .
  738. hDataSocket = AcceptDataConnect( hListenSocket ) ;
  739. m_hDataSocket = hDataSocket ;
  741. if( hDataSocket == INVALID_SOCKET )
  742. return false ;
  744. //send status msg
  745. sprintf( m_szFtpBuffer , "接收文件目录列表....." ) ;
  746. SendStatusStr( m_szFtpBuffer ) ;
  748. //read the data from the data link.
  749. nReplyCode = ReadDataCannel( m_hControlSocket , hDataSocket , bWantSend ) ;
  750. if( nReplyCode >= 400 || nReplyCode <= 0 )
  751. return false ;
  753. closesocket( hListenSocket ) ;
  754. hListenSocket = INVALID_SOCKET ;
  756. //send status msg.
  757. sprintf( m_szFtpBuffer , "接收完毕" ) ;
  758. SendStatusStr( m_szFtpBuffer ) ;
  760. return true ;
  761. }
  763. /***********************************************************
  764. ** @Description:
  765. ** this function is get current ftp directory.
  766. **
  767. ** @Parameter:
  768. ** void
  769. **
  770. ** @Return: 
  771. ** @Author:    Table.JHM.太子
  772. ** e-mail: tablejiang@21cn.com
  773. ** Date: 2001 3 26
  774. *************************************************************/
  775. BOOL CFtpFunction::GetCurrentFtpDir()
  776. {
  777. char szBuffer[MAX_PATH] ;
  778. int iLength = 0 ;
  780. //make command .
  781. sprintf( szBuffer , "PWDrn" ) ;
  783. if( !m_bRun )
  784. return ERROR_FTP_CODE ;
  786. //send command.
  787. if( send( m_hControlSocket , szBuffer , strlen( szBuffer ) , 0 ) == SOCKET_ERROR ) 
  788. {
  789. int iWinsockErr = WSAGetLastError( ) ;
  790. sprintf( m_szFtpBuffer , " %d error while Send ftp command !" , iWinsockErr ) ;
  791. MessageBox( NULL , m_szFtpBuffer , MSGBOX_TITLE , MB_OK ) ;
  792. return ( ERROR_FTP_CODE ) ;
  793. }
  795. SendMsgToParentWnd( szBuffer , true ) ;
  797. //  AfxMessageBox( szBuffer ) ;
  799. //peek the message .
  800. if( ( iLength = recv( m_hControlSocket , szBuffer , 1024 , MSG_PEEK ) ) == SOCKET_ERROR )
  801. {
  802. int iWinsockErr = WSAGetLastError( ) ;
  803. sprintf( m_szFtpBuffer , " %d error while recv server reply!" , iWinsockErr ) ;
  804. MessageBox( NULL , m_szFtpBuffer , MSGBOX_TITLE , MB_OK ) ;
  805. //return ( ERROR_FTP_CODE ) ;
  806. }
  808. int iBuffer = 0 ;
  810. while( szBuffer[iBuffer] != 'n' )
  811. {
  812. iBuffer ++ ;
  813. if( iBuffer >= iLength )
  814. break ;
  815. }
  816. iBuffer ++ ;
  818. //add by table 2001 4 24
  819. //test recv in win98
  820. //iBuffer = MAX_PATH ;
  822. //receive server reply string .
  823. if( ( iLength = recv( m_hControlSocket , szBuffer , iBuffer , 0 ) ) == SOCKET_ERROR )
  824. {
  825. int iWinsockErr = WSAGetLastError( ) ;
  826. sprintf( m_szFtpBuffer , " %d error while recv server reply!" , iWinsockErr ) ;
  827. MessageBox( NULL , m_szFtpBuffer , MSGBOX_TITLE , MB_OK ) ;
  828. return ( ERROR_FTP_CODE ) ;
  829. }
  830. if( iLength < MAX_PATH )
  831. szBuffer[ iLength ] = 0 ;
  832. else
  833. szBuffer[ MAX_PATH - 1 ] = 0 ;
  835. //Send msg to window .
  836. SendMsgToParentWnd( szBuffer , false ) ;
  839. UINT nReplyCode = GetReplyCode ( szBuffer ) ;
  841. if( nReplyCode >= 400 || nReplyCode <= 0 )
  842. return false ;
  844. //Get return path string .
  845. //the server reply string include the current path .
  846. CString strFind = szBuffer ;
  847. int StartPos = 0 ;
  848. int EndPos = 0 ; 
  850. memset( m_CurrentFtpDirectory , 0 , sizeof( m_CurrentFtpDirectory) ) ;
  852. if( ( StartPos =strFind.Find( """ , 0 ) ) == -1 )
  853. return true ;
  855. StartPos ++ ;
  856. if( ( EndPos = strFind.Find ( """ , StartPos ) ) == -1 )
  857. return true ;
  859. strFind = strFind.Mid( StartPos , EndPos - StartPos ) ;
  860. strcpy( m_CurrentFtpDirectory , (LPCTSTR)strFind ) ;
  862. return true  ;
  864. }
  866. /***********************************************************
  867. ** @Description:
  868. ** read data from cannel.
  869. **
  870. ** @Parameter:
  871. **
  872. ** @Return: 
  873. ** @Author:    Table.JHM.太子
  874. ** e-mail: tablejiang@21cn.com
  875. ** Date: 2001 3 26
  876. *************************************************************/
  877. UINT CFtpFunction::ReadDataCannel(SOCKET hControlSocket, SOCKET hDataSocket , BOOL bWantSend )
  878. {
  879. DWORD nByteRec = 0 ;
  880. DWORD lDataNum = 0 ;
  881. char ReceiveBuffer[64] ;
  883. //use CString class to store the data
  884. CString strBuffer ;
  886. strBuffer.Empty() ;
  888. do
  889. {
  890. memset( ReceiveBuffer , 0 , sizeof( ReceiveBuffer ) ) ;
  891. nByteRec = recv( hDataSocket , ReceiveBuffer , 63 , 0 ) ;
  892. if( nByteRec == SOCKET_ERROR )
  893. break ;
  895. if( nByteRec > 0 )
  896. {
  897. ReceiveBuffer[nByteRec] = 0 ;
  898. lDataNum = nByteRec + lDataNum ;
  899. strBuffer += ReceiveBuffer ;
  900. //display the receive bytes .
  901. m_szFtpBuffer[0] = '' ;
  902. sprintf( m_szFtpBuffer , "接收到的字节数: %d" , lDataNum ) ;
  903. //TRACE( "%d - %d rn " , lDataNum , nByteRec ) ;
  904. SendFileNameToParentWnd( m_szFtpBuffer ) ;
  905. }
  906. }
  907. while( nByteRec > 0  );
  909. //clear the display bytes .
  910. sprintf( m_szFtpBuffer , " " ) ;
  911. SendFileNameToParentWnd( m_szFtpBuffer ) ;
  913. SendFileNameToParentWnd( m_szFtpBuffer ) ;
  914. //strBuffer.SetAt( lDataNum , '' ) ;
  915. //parse the directory .
  916. ParseDirectroyInfo( strBuffer , bWantSend );
  918. closesocket( hDataSocket ) ;
  919. hDataSocket = NULL ;
  920. m_hDataSocket = NULL ;
  922. if( nByteRec == SOCKET_ERROR )
  923. return false ;
  925. if( lDataNum == 0 )
  926. return ( GetServerReply( hControlSocket ) ) ;
  928. return ( GetServerReply( hControlSocket ) ) ;
  929. }
  932. /***********************************************************
  933. ** @Description:
  934. **
  935. ** @Parameter:
  936. **
  937. ** @Return: 
  938. ** @Author:    Table.JHM.太子
  939. ** e-mail: tablejiang@21cn.com
  940. ** Date: 2001 3 26
  941. *************************************************************/
  942. void CFtpFunction::ParseDirectroyInfo(CString buffer , BOOL bWantSend )
  943. {
  945. /*
  946. AfxMessageBox( buffer ) ;
  947. CFile file ;
  948. file.Open( "e:\abc.txt" , CFile::modeCreate|CFile::modeWrite ) ;
  949. file.Write( (LPCTSTR)buffer , buffer.GetLength() ) ;
  950. file.Close() ;
  951. */
  953. int EndPos = 0 ;
  955. FTPITEM* pFtpItemHead ;
  956. FTPITEM*    pFtpItem ;
  957. FTPITEM* pCurItem ;
  959. char szBuffer[MAX_PATH] ;
  960. int iRet = 0 ;
  962. pFtpItem = new FTPITEM ;
  963. memset( pFtpItem , 0 , sizeof( FTPITEM ) ) ;
  965. CString pLine ;
  967. pFtpItemHead = pFtpItem ;
  968. pCurItem = pFtpItem ;
  970. //choose the server type .
  971. switch( m_SiteInfo.hosttype )
  972. {
  973. case UNIX_SERVER :
  974. //skip the first line .
  975. while( iRet != 2 && EndPos < buffer.GetLength() )
  976. {
  977. iRet = GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  978. }
  980. while( EndPos < buffer.GetLength() )
  981. {
  982. iRet = 0 ;
  983. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  984. strcpy( pCurItem->szAttrib , szBuffer ) ;
  985. if( szBuffer[0] == 'd' )
  986. pCurItem->dwType = 1 ;
  987. else
  988. pCurItem->dwType = 0 ;
  990. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  991. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  992. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  993. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  994. strcpy( pCurItem->szSize , szBuffer ) ;
  995. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  996. strcpy( pCurItem->szDate , szBuffer ) ;
  997. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  998. strcat( pCurItem->szDate , " " ) ;
  999. strcat( pCurItem->szDate , szBuffer ) ;
  1000. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1001. strcpy( pCurItem->szTime , szBuffer ) ;
  1002. while( iRet != 2 && EndPos < buffer.GetLength() )
  1003. {
  1004. iRet = GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1005. strcat( pCurItem->szName , szBuffer ) ;
  1006. if( iRet != 2 )
  1007. strcat( pCurItem->szName , " " ) ;
  1008. }
  1009. pFtpItem = new FTPITEM ;
  1010. //pFtpItem->pNext = NULL ;
  1011. memset ( pFtpItem , 0 , sizeof( FTPITEM ) ) ;
  1012. pCurItem->pNext = pFtpItem ;
  1013. pCurItem = pFtpItem ;
  1014. }
  1015. break ;
  1017. case WINNT_SERVER :
  1018. while( EndPos < buffer.GetLength() )
  1019. {
  1020. iRet = 0 ;
  1021. GetSubItem( &EndPos , szBuffer , MAX_PATH , &buffer ) ;
  1022. strcpy( pCurItem->szDate , szBuffer ) ;
  1023. GetSubItem( &EndPos , szBuffer , MAX_PATH , &buffer ) ;
  1024. strcpy( pCurItem->szTime , szBuffer ) ;
  1025. GetSubItem( &EndPos , szBuffer , MAX_PATH , &buffer ) ;
  1026. if( strcmp( szBuffer , "<DIR>" ) == 0 )
  1027. {
  1028. pCurItem->dwType = 1 ;
  1029. strcpy( pCurItem->szSize , "" ) ;
  1030. }
  1031. else
  1032. {
  1033. pCurItem->dwType = 0 ;
  1034. strcpy( pCurItem->szSize , szBuffer ) ;
  1035. }
  1036. while( iRet != 2 && EndPos < buffer.GetLength() )
  1037. {
  1038. iRet = GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1039. strcat( pCurItem->szName , szBuffer ) ;
  1040. if( iRet != 2 )
  1041. strcat( pCurItem->szName , " " ) ;
  1042. }
  1043. strcpy( pCurItem->szAttrib, "" ) ;
  1044. pFtpItem = new FTPITEM ;
  1045. //pFtpItem->pNext = NULL ;
  1046. memset ( pFtpItem , 0 , sizeof( FTPITEM ) ) ;
  1047. pCurItem->pNext = pFtpItem ;
  1048. pCurItem = pFtpItem ;
  1050. }
  1051. break ;
  1053. case LINUX_SERVER :
  1054. {
  1055. iRet = 0 ;
  1056. while( iRet != 2 && EndPos < buffer.GetLength() )
  1057. {
  1058. iRet = GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1059. }
  1061. while( EndPos < buffer.GetLength() )
  1062. {
  1063. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1064. strcpy( pCurItem->szAttrib , szBuffer ) ;
  1065. if( szBuffer[0] == 'd' )
  1066. pCurItem->dwType = 1 ;
  1067. else
  1068. pCurItem->dwType = 0 ;
  1069. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1070. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1071. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1072. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1073. strcpy( pCurItem->szSize , szBuffer ) ;
  1074. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1075. strcpy( pCurItem->szDate , szBuffer ) ;
  1076. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1077. strcat( pCurItem->szDate , " " ) ;
  1078. strcat( pCurItem->szDate , szBuffer ) ;
  1079. GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1080. strcpy( pCurItem->szTime , szBuffer ) ;
  1081. while( iRet != 2 && EndPos < buffer.GetLength() )
  1082. {
  1083. iRet = GetSubItem( &EndPos , szBuffer ,  MAX_PATH , &buffer ) ;
  1084. strcat( pCurItem->szName , szBuffer ) ;
  1085. if( iRet != 2 )
  1086. strcat( pCurItem->szName , " " ) ;
  1087. }
  1088. pFtpItem = new FTPITEM ;
  1089. //pFtpItem->pNext = NULL ;
  1090. memset ( pFtpItem , 0 , sizeof( FTPITEM ) ) ;
  1091. pCurItem->pNext = pFtpItem ;
  1092. pCurItem = pFtpItem ;
  1093. }
  1094. }
  1095. break ;
  1096. default:
  1097. break;
  1098. }
  1099. if( bWantSend )
  1100. {
  1101. ::PostMessage( m_hWndInfo.hFtpDirListWnd , FTP_SERVER_DIR_LIST_MSG , (WPARAM)pFtpItemHead , 0 ) ;
  1102. }
  1103. else
  1104. {
  1105. m_ListItem = pFtpItemHead ;
  1106. }
  1108. }
  1109. /***********************************************************
  1110. ** @Description:
  1111. ** delete a file in ftp server .
  1112. **
  1113. ** @Parameter:
  1114. ** LPSTR szFileName : the delete file name .
  1115. **
  1116. ** @Return: 
  1117. ** @Author:    Table.JHM.太子
  1118. ** e-mail: tablejiang@21cn.com
  1119. ** Date: 2001 3 26
  1120. *************************************************************/
  1121. BOOL CFtpFunction::DeleteFtpFile(LPSTR szFileName)
  1122. {
  1123. char szCommand[MAX_PATH] ;
  1124. UINT uReplyCode = 0 ;
  1125. sprintf( szCommand , "DELE %srn" , szFileName ) ;
  1126. uReplyCode = SendFtpCommand( szCommand , m_hControlSocket ) ;
  1127. if( uReplyCode > 400 )
  1128. return false ;
  1130. return true ;
  1131. }
  1132. /***********************************************************
  1133. ** @Description:
  1134. ** this function delete a directory in ftp server .
  1135. ** this function use recursion arithmetic .
  1136. **
  1137. ** @Parameter:
  1138. ** FTPFILEINFO* pFileInfo : the delete directory info .
  1139. **
  1140. ** @Return: 
  1141. ** @Author:    Table.JHM.太子
  1142. ** e-mail: tablejiang@21cn.com
  1143. ** Date: 2001 3 26
  1144. *************************************************************/
  1145. BOOL CFtpFunction::DeleteFtpDirectory(FTPFILEINFO *pFileInfo)
  1146. {
  1147. FTPITEM* pItemQueueHead ;
  1148. FTPITEM* pItemCur ;
  1149. FTPFILEINFO FtpFileInfo ;
  1150. char szPathBak[MAX_PATH] ;
  1152. memcpy( &FtpFileInfo , pFileInfo , sizeof( FTPFILEINFO ) ) ;
  1154. if( !MakeFtpDownloadPath( &FtpFileInfo ) )
  1155. return false ;
  1157. if( !GetCurrentFtpDir() )
  1158. return false ;
  1160. strcpy( szPathBak , m_CurrentFtpDirectory ) ;
  1162. pItemQueueHead = m_ListItem ;
  1163. pItemCur = m_ListItem ;
  1165. if( m_ListItem->pNext == NULL )
  1166. {
  1167. FreeItemList( pItemQueueHead ) ;
  1168. return false ;
  1169. }
  1171. while( pItemCur->pNext != NULL )
  1172. {
  1173. if( pItemCur->dwType == 1 )
  1174. {
  1175. FtpFileInfo.bfileput = false ;
  1176. FtpFileInfo.bIsDirectory = true ;
  1177. FtpFileInfo.endpos = 0 ;
  1178. FtpFileInfo.startpos = 0 ;
  1179. strcpy( FtpFileInfo.remotefilename , pItemCur->szName ) ;
  1180. strcpy( FtpFileInfo.localfilename , pItemCur->szName ) ;
  1181. //FtpFileInfo.hSocket = pFileInfo->hSocket ;
  1182. //FtpFileInfo.hWnd = pFileInfo->hWnd ;
  1184. DeleteFtpDirectory( &FtpFileInfo ) ;
  1185. EnterFtpDirectory( szPathBak ) ;
  1186. RemoveFtpDirectory( FtpFileInfo.remotefilename ) ;
  1187. }
  1188. else
  1189. {
  1190. DeleteFtpFile( pItemCur->szName ) ;
  1191. }
  1192. pItemCur = pItemCur->pNext ;
  1193. }
  1195. FreeItemList( pItemQueueHead ) ;
  1197. return true ;
  1198. }
  1199. /***********************************************************
  1200. ** @Description:
  1201. ** this function remove a directory in ftp server .
  1202. **
  1203. ** @Parameter:
  1204. ** LPSTR szDirName : the dir name .
  1205. **
  1206. ** @Return: 
  1207. ** @Author:    Table.JHM.太子
  1208. ** e-mail: tablejiang@21cn.com
  1209. ** Date: 2001 3 26
  1210. *************************************************************/
  1211. BOOL CFtpFunction::RemoveFtpDirectory(LPSTR szDirName)
  1212. {
  1213. char szCommand[MAX_PATH] ;
  1214. UINT uReplyCode = 0 ;
  1215. sprintf( szCommand , "RMD %srn" , szDirName ) ;
  1216. uReplyCode = SendFtpCommand( szCommand , m_hControlSocket ) ;
  1217. if( uReplyCode > 400 )
  1218. return false ;
  1220. return true ;
  1222. }
  1224. /****************************************************
  1225. ** @Description
  1226. ** Find file in remote file list .
  1227. **
  1228. ** @Parameter
  1229. ** LPCTSTR szFileName : the file name .
  1230. ** FTPITEM* pFileList : remote file list.
  1231. **
  1232. ** @Return: the broken transmit position .
  1233. ** @Author:    Table.JHM.太子
  1234. ** e-mail: tablejiang@21cn.com
  1235. ** @Date: 2001 3 26
  1236. ****************************************************/
  1237. __int64 CFtpFunction::FindFileInFileList(LPCTSTR szFileName, FTPITEM *pFileList)
  1238. {
  1239. FTPITEM* pCur ;
  1240. __int64 iSize = 0 ;
  1242. if( pFileList == NULL )
  1243. return 0 ;
  1245. pCur = pFileList ;
  1246. while( pCur->pNext != NULL )
  1247. {
  1248. if( strcmp( szFileName , pCur->szName ) == 0 )
  1249. {
  1250. //is want ask user ?
  1251. if( m_bAskUser )
  1252. {
  1253. char szPathName[MAX_PATH] ;
  1254. sprintf( szPathName , "%s/%s" , m_CurrentFtpDirectory , szFileName ) ;
  1255. m_SelActionDlg.m_strPathName = szPathName ;
  1256. m_SelActionDlg.DoModal( ) ;
  1257. m_bAskUser = !m_SelActionDlg.m_bAsk ;
  1258. m_iWhenExistAction = m_SelActionDlg.m_iAction ;
  1259. }
  1261. iSize = _atoi64( pCur->szSize ) ;
  1262. switch( m_iWhenExistAction )
  1263. {
  1264. case 1 :
  1265. //overlay
  1266. {
  1267. iSize = 0 ;
  1268. }
  1269. break ;
  1270. case 2 :
  1271. //resume
  1272. break ;
  1273. case 3 :
  1274. //rename
  1275. iSize = 0 ;
  1276. break ;
  1277. case 4 :
  1278. //skip
  1279. break ;
  1280. default :
  1281. break ;
  1282. }
  1283. return iSize ;
  1284. }
  1285. pCur = pCur->pNext ;
  1286. }
  1287. return 0 ;
  1288. }
  1290. /****************************************************
  1291. ** @Description
  1292. ** find file in local .
  1293. **
  1294. ** @Parameter
  1295. ** LPCTSTR szPathName : the file path name .
  1296. **
  1297. ** @Return: the broken transmit position .
  1298. ** @Author:    Table.JHM.太子
  1299. ** e-mail: tablejiang@21cn.com
  1300. ** @Date: 2001 3 26
  1301. ****************************************************/
  1302. __int64 CFtpFunction::FindFileInLocal(LPCTSTR szPathName)
  1303. {
  1304. __int64 iSize = 0 ;
  1305. TRACE( "%s---%drn" , szPathName , m_bAskUser ) ;
  1306. if( PathFileExists( szPathName ) )
  1307. {
  1308. TRACE( "%s---%drn" , szPathName , m_bAskUser ) ;
  1309. if( m_bAskUser )
  1310. {
  1311. m_SelActionDlg.m_strPathName = szPathName ;
  1312. m_SelActionDlg.DoModal( ) ;
  1313. m_bAskUser = !m_SelActionDlg.m_bAsk ;
  1314. m_iWhenExistAction = m_SelActionDlg.m_iAction ;
  1315. }
  1317. HANDLE hFile = CreateFile( szPathName , GENERIC_READ | GENERIC_WRITE ,  
  1318. FILE_SHARE_READ , NULL , OPEN_ALWAYS , FILE_ATTRIBUTE_NORMAL , 0 ) ;
  1320. if( hFile == INVALID_HANDLE_VALUE )
  1321. return 0 ;
  1323. DWORD dwlSize ;
  1324. DWORD dwhSize ;
  1326. dwlSize = GetFileSize( hFile , &dwhSize ) ;
  1328. iSize = dwhSize ;
  1329. iSize = iSize << 32 ;
  1330. iSize += dwlSize ;
  1332. switch( m_iWhenExistAction )
  1333. {
  1334. case 1 :
  1335. //overlay
  1336. {
  1337. iSize = 0 ;
  1338. }
  1339. break ;
  1340. case 2 :
  1341. //resume
  1342. break ;
  1343. case 3 :
  1344. //rename
  1345. iSize = 0 ;
  1346. break ;
  1347. case 4 :
  1348. //skip
  1349. break ;
  1350. default :
  1351. break ;
  1352. }
  1353. CloseHandle( hFile ) ;
  1354. return iSize ;
  1355. }
  1356. else
  1357. {
  1358. //char dis[500] ;
  1359. //sprintf( 
  1360. //AfxMessageBox( "Can't Find File ! " ) ;
  1361. //AfxMessageBox( szPathName ) ;
  1362. }
  1363. return iSize ;
  1364. }
  1366. /****************************************************
  1367. ** @Description
  1368. **
  1369. **
  1370. ** @Parameter
  1371. **
  1372. **
  1373. ** @Return:
  1374. ** @Author:    Table.JHM.太子
  1375. ** e-mail: tablejiang@21cn.com
  1376. ** @Date: 2001 3 26
  1377. ****************************************************/
  1378. BOOL CFtpFunction::BrokenDownload( FTPFILEINFO *pFile)
  1379. {
  1380. BOOL bRet = true ;
  1381. switch( m_iWhenExistAction )
  1382. {
  1383. case 4 :
  1384. {
  1385. break ;
  1386. }
  1387. case 3 :
  1388. //rename
  1389. {
  1390. CInputFileNameDlg dlg ;
  1391. dlg.DoModal( ) ;
  1392. if( pFile->bfileput )
  1393. strcpy( pFile->remotefilename , dlg.m_strName ) ;
  1394. else
  1395. strcpy( pFile->localfilename , dlg.m_strName ) ;
  1396. }
  1397. case 1 :
  1398. case 2 :
  1399. default :
  1400. {
  1401. //strcpy( pFile->localfilename , pItemCur->szName ) ;
  1402. pFile->iExistAction = m_iWhenExistAction ;
  1403. bRet = PutGetFileFunction( pFile ) ;
  1404. }
  1405. break ;
  1406. }
  1407. return bRet ;
  1408. }
  1410. /****************************************************
  1411. ** @Description
  1412. ** open the file with the specify file info.
  1413. **
  1414. ** @Parameter
  1415. ** FTPFILEINFO* pFile : file info
  1416. ** LPCTSTR szPathName : the file path name .
  1417. **
  1418. ** @Return:
  1419. ** @Author:    Table.JHM.太子
  1420. ** e-mail: tablejiang@21cn.com
  1421. ** @Date: 2001 3 26
  1422. ****************************************************/
  1423. HANDLE CFtpFunction::OpenLocalFile(FTPFILEINFO *pFile, LPCTSTR szPathName)
  1424. {
  1425. HANDLE hFile ;
  1426. if( !pFile->bfileput )
  1427. {
  1428. switch( pFile->iExistAction )
  1429. {
  1430. case 2 ://resume transmit .
  1431. hFile = CreateFile( szPathName , GENERIC_READ | GENERIC_WRITE ,  
  1432. FILE_SHARE_READ , NULL , OPEN_ALWAYS , FILE_ATTRIBUTE_NORMAL , 0 ) ;
  1433. break ;
  1434. default :
  1435. hFile = CreateFile( szPathName , GENERIC_READ | GENERIC_WRITE ,  
  1436. FILE_SHARE_READ , NULL , CREATE_ALWAYS , FILE_ATTRIBUTE_NORMAL , 0 ) ;
  1437. break ;
  1438. }
  1439. }
  1440. else
  1441. {
  1442. hFile = CreateFile( szPathName , GENERIC_READ | GENERIC_WRITE ,  
  1443. FILE_SHARE_READ , NULL , OPEN_ALWAYS , FILE_ATTRIBUTE_NORMAL , 0 ) ;
  1444. if( hFile == INVALID_HANDLE_VALUE )
  1445. {
  1446. DWORD dwErr = GetLastError( ) ;
  1447. }
  1448. }
  1449. return hFile ;
  1450. }
  1452. /****************************************************
  1453. ** @Description
  1454. ** prepare the broken transmit , move to 
  1455. ** broken position .
  1456. **
  1457. ** @Parameter
  1458. **
  1459. **
  1460. ** @Return:
  1461. ** @Author:    Table.JHM.太子
  1462. ** e-mail: tablejiang@21cn.com
  1463. ** @Date: 2001 3 26
  1464. ****************************************************/
  1465. BOOL CFtpFunction::MakeBrokenPos(char *szCommand, FTPFILEINFO *pFile , HANDLE hFile )
  1466. {
  1467. UINT nReplyCode = 0 ;
  1468. if( pFile->site.brokendownload )
  1469. {
  1470. char szTemp[MAX_PATH] ;
  1471. strcpy( szCommand , "REST " ) ;
  1472. _i64toa( pFile->startpos , szTemp , 10 ) ;
  1473. strcat( szCommand , szTemp ) ;
  1474. strcat( szCommand , "rn" ) ;
  1476. //send rest command.
  1477. nReplyCode = SendFtpCommand( szCommand , pFile->hSocket ) ;
  1478. if( nReplyCode == 350 )
  1479. MyFileSeek( hFile , pFile->startpos ,  FILE_BEGIN ) ;
  1480. }
  1482. if( pFile->bfileput )
  1483. {
  1484. switch( pFile->iExistAction )
  1485. {
  1486. case 2 :
  1487. //append the data to exist file .
  1488. sprintf( szCommand , "APPE %srn" , pFile->remotefilename ) ;
  1489. break ;
  1490. default :
  1491. sprintf( szCommand , "STOR %srn" , pFile->remotefilename ) ;
  1492. break ;
  1493. }
  1494. }
  1495. else
  1496. sprintf( szCommand , "RETR %srn" , pFile->remotefilename ) ;
  1498. return true ;
  1499. }
  1501. /****************************************************
  1502. ** @Description
  1503. ** send current transmit file name to parent wnd .
  1504. **
  1505. ** @Parameter
  1506. ** LPCTSTR szName : file name .
  1507. **
  1508. ** @Return:
  1509. ** @Author:    Table.JHM.太子
  1510. ** @e-mail: tablejiang@21cn.com
  1511. ** @Date: 2001 3 26
  1512. ****************************************************/
  1513. BOOL CFtpFunction::SendFileNameToParentWnd(LPCTSTR szName)
  1514. {
  1515. char * pName ;
  1516. int iLength = strlen( szName ) ;
  1517. pName = new char[iLength + 1] ;
  1519. strcpy( pName , szName ) ;
  1520. pName[iLength] = '' ;
  1522. PostMessage( m_hParentWnd , SEND_TRANSMIT_FILENAME_MSG , (WPARAM)pName , 0 ) ;
  1523. return true;
  1524. }
  1526. /****************************************************
  1527. ** @Description
  1528. ** send status info to parent wnd .
  1529. **
  1530. ** @Parameter
  1531. ** char* pText : status string .
  1532. **
  1533. ** @Return:
  1534. ** @Author:    Table.JHM.太子
  1535. ** e-mail: tablejiang@21cn.com
  1536. ** @Date: 2001 3 26
  1537. ****************************************************/
  1538. void CFtpFunction::SendStatusStr(char *pText)
  1539. {
  1540. char* pSend ;
  1542. int iLength = strlen( pText ) ;
  1543. if( pText[iLength-2] != 'r' )
  1544. strcat( pText , "rn" ) ;
  1546. iLength = strlen( pText ) ;
  1548. //the alloc memory will delete in parent window.
  1549. pSend = new char[iLength + 16];
  1550. strcpy( pSend , "STATUS>        " ) ;
  1551. strcat( pSend , pText ) ;
  1552. PostMessage( m_hWndInfo.hInfoWnd , FTP_STATUS_MSG , 0 , (LPARAM)pSend ) ;
  1553. }
  1554. /***********************************************************
  1555. ** @Description:
  1556. ** this public function is used for chech is connected 
  1557. ** with ftp server .
  1558. **
  1559. ** @Note:
  1560. **
  1561. ** @Return: if connected return true ,else return false .
  1562. ** @Author:    Table.JHM.太子
  1563. ** e-mail: tablejiang@21cn.com
  1564. ** Date: 2001 3 26
  1565. *************************************************************/
  1566. BOOL CFtpFunction::IsConnect()
  1567. {
  1568. return m_bIsConnected ;
  1569. }