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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 金融证券系统 > 查看源码
ExportDest.cpp
资源名称：clking_src.rar　[点击查看]
上传用户：zhanglf88
上传日期：2013-11-19
资源大小：6036k
文件大小：27k
源码类别：

金融证券系统

开发平台：

Visual C++

ExportDest.cpp：源码内容
  1. // ExportDest.cpp : implementation file
  2. //
  4. #include "stdafx.h"
  6. #include "ExportDest.h"
  7. #include "SelectStk.h"
  8. #include "ExportOption.h"
  9. #include <io.h>
  10. #include "..Dialogs.h"
  12. #ifdef _DEBUG
  13. #define new DEBUG_NEW
  14. #undef THIS_FILE
  15. static char THIS_FILE[] = __FILE__;
  16. #endif
  18. /////////////////////////////////////////////////////////////////////////////
  19. // CExportDest property page
  21. void CExportDest::StoreProfile( )
  22. {
  23. AfxGetApp()->WriteProfileInt( "exportdest", "txtcheck", m_bTxtCheck );
  24. AfxGetApp()->WriteProfileInt( "exportdest", "mdbcheck", m_bMdbCheck );
  25. AfxGetApp()->WriteProfileInt( "exportdest", "csvcheck", m_bCsvCheck );
  26. AfxGetApp()->WriteProfileInt( "exportdest", "odbccheck", m_bODBCCheck );
  27. AfxGetApp()->WriteProfileString( "exportdest", "txtdest", m_strTxtDest );
  28. AfxGetApp()->WriteProfileString( "exportdest", "mdbdest", m_strMdbDest );
  29. AfxGetApp()->WriteProfileString( "exportdest", "csvdest", m_strCsvDest );
  30. AfxGetApp()->WriteProfileString( "exportdest", "odbcdest", m_strODBCDest );
  31. AfxGetApp()->WriteProfileInt( "exportdest", "exeonfinish", m_bExeOnFinish );
  32. AfxGetApp()->WriteProfileInt( "exportdest", "overwrite", m_bOverwrite );
  33. }
  35. void CExportDest::LoadProfile( )
  36. {
  37. m_bTxtCheck = TRUE;
  38. m_bOverwrite = TRUE;
  39. m_bExeOnFinish = TRUE;
  40. m_strTxtDest = AfxGetProfile().GetExportPath() + "txt";
  41. m_strMdbDest = AfxGetProfile().GetExportPath() + "KData.mdb";
  42. m_strCsvDest = AfxGetProfile().GetExportPath() + "csv";
  43. m_strODBCDest = "ODBC;DSN=Excel Files;DBQ="
  44. + AfxGetProfile().GetExportPath()
  45. + "KData.xls;DefaultDir="
  46. + AfxGetProfile().GetExportPath()
  47. + ";DriverId=790;MaxBufferSize=2048;PageTimeout=5;";
  50. if( (0 != access( m_strTxtDest, 0 ) || FILE_ATTRIBUTE_DIRECTORY != GetFileAttributes( m_strTxtDest ) )
  51. && !CreateDirectory( m_strTxtDest, NULL ) )
  52. m_strTxtDest = AfxGetProfile().GetExportPath();
  53. if( (0 != access( m_strCsvDest, 0 ) || FILE_ATTRIBUTE_DIRECTORY != GetFileAttributes( m_strCsvDest ) )
  54. && !CreateDirectory( m_strCsvDest, NULL ) )
  55. m_strCsvDest = AfxGetProfile().GetExportPath();
  57. m_bTxtCheck = AfxGetApp()->GetProfileInt( "exportdest", "txtcheck", m_bTxtCheck );
  58. m_bMdbCheck = AfxGetApp()->GetProfileInt( "exportdest", "mdbcheck", m_bMdbCheck );
  59. m_bCsvCheck = AfxGetApp()->GetProfileInt( "exportdest", "csvcheck", m_bCsvCheck );
  60. m_bODBCCheck = AfxGetApp()->GetProfileInt( "exportdest", "odbccheck", m_bODBCCheck );
  61. m_strTxtDest = AfxGetApp()->GetProfileString( "exportdest", "txtdest", m_strTxtDest );
  62. m_strMdbDest = AfxGetApp()->GetProfileString( "exportdest", "mdbdest", m_strMdbDest );
  63. m_strCsvDest = AfxGetApp()->GetProfileString( "exportdest", "csvdest", m_strCsvDest );
  64. m_strODBCDest = AfxGetApp()->GetProfileString( "exportdest", "odbcdest", m_strODBCDest );
  65. m_bExeOnFinish = AfxGetApp()->GetProfileInt( "exportdest", "exeonfinish", m_bExeOnFinish );
  66. m_bOverwrite = AfxGetApp()->GetProfileInt( "exportdest", "overwrite", m_bOverwrite );
  67. }
  69. IMPLEMENT_DYNCREATE(CExportDest, CPropertyPageEx)
  71. CExportDest::CExportDest() : CPropertyPageEx(CExportDest::IDD)
  72. {
  73. //{{AFX_DATA_INIT(CExportDest)
  74. m_strTxtDest = _T("");
  75. m_strMdbDest = _T("");
  76. m_strCsvDest = _T("");
  77. m_bTxtCheck = FALSE;
  78. m_bMdbCheck = FALSE;
  79. m_bCsvCheck = FALSE;
  80. m_bExeOnFinish = FALSE;
  81. m_bODBCCheck = FALSE;
  82. m_strODBCDest = _T("");
  83. //}}AFX_DATA_INIT
  84. m_bExporting = FALSE;
  85. m_bCanceled = FALSE;
  87. m_dwButtonFlags = PSWIZB_BACK | PSWIZB_NEXT;
  88. }
  90. CExportDest::CExportDest(UINT nIDCaption, UINT nIDTitle, UINT nIDSubTitle)
  91.  : CPropertyPageEx(CExportDest::IDD, nIDCaption, nIDTitle, nIDSubTitle)
  92. {
  93. m_strTxtDest = _T("");
  94. m_strMdbDest = _T("");
  95. m_strCsvDest = _T("");
  96. m_bTxtCheck = FALSE;
  97. m_bMdbCheck = FALSE;
  98. m_bCsvCheck = FALSE;
  99. m_bExeOnFinish = FALSE;
  100. m_bODBCCheck = FALSE;
  101. m_strODBCDest = _T("");
  103. m_bExporting = FALSE;
  104. m_bCanceled = FALSE;
  106. m_dwButtonFlags = PSWIZB_BACK | PSWIZB_NEXT;
  107. }
  109. CExportDest::~CExportDest()
  110. {
  111. }
  113. BOOL CExportDest::ExportBegin(CStringArray &astrColumnName, CUIntArray &anWidth,
  114. BOOL bReportError )
  115. {
  116. CString strTxt, strMdb, strCsv, strODBC;
  117. if( m_bTxtCheck ) strTxt = AfxGetFileDirectoryExist( m_strTxtDest, (LPCTSTR)AfxGetProfile().GetExportPath() );
  118. if( m_bMdbCheck ) strMdb = m_strMdbDest;
  119. if( m_bCsvCheck ) strCsv = AfxGetFileDirectoryExist( m_strCsvDest, (LPCTSTR)AfxGetProfile().GetExportPath() );
  120. if( m_bODBCCheck ) strODBC = m_strODBCDest;
  121. if( !m_exportdb.OpenAllDB(strTxt, TRUE, strMdb, strCsv, TRUE, strODBC,
  122. bReportError ) )
  123. return FALSE;
  125. if( ! m_exportdb.SetTableColumn( astrColumnName, anWidth ) )
  126. return FALSE;
  128. return TRUE;
  129. }
  131. BOOL CExportDest::ExportOpenTable( CStock &stock, int ktype, BOOL bReportError )
  132. {
  133. CString strTableName = stock.GetStockCode();
  134. strTableName += AfxGetKTypeString( ktype );
  135. if( !m_exportdb.OpenAllTable( strTableName, m_bOverwrite, bReportError ) )
  136. return FALSE;
  137. return TRUE;
  138. }
  140. BOOL CExportDest::ExportAddItem( CStringArray &astrItemText )
  141. {
  142. // Pump Message
  143. MSG msg;
  144. while (::PeekMessage(&msg, NULL, NULL, NULL, PM_NOREMOVE) )
  145. AfxGetApp()->PumpMessage();
  147. return m_exportdb.AddItem( astrItemText );
  148. }
  150. void CExportDest::ExportCloseTable( )
  151. {
  152. m_exportdb.CloseAllTable( );
  153. }
  155. BOOL CExportDest::ExportFinish( )
  156. {
  157. m_exportdb.CloseAllDB( );
  159. if( m_bExeOnFinish )
  160. {
  161. if( m_bTxtCheck && m_strTxtDest.GetLength() > 0 )
  162. ShellExecute( NULL, "open", m_strTxtDest, NULL, NULL, SW_SHOW );
  163. if( m_bMdbCheck && m_strMdbDest.GetLength() > 0 )
  164. ShellExecute( NULL, "open", m_strMdbDest, NULL, NULL, SW_SHOW );
  165. if( m_bCsvCheck && m_strCsvDest.GetLength() > 0 )
  166. ShellExecute( NULL, "open", m_strCsvDest, NULL, NULL, SW_SHOW );
  167. if( m_bODBCCheck && m_strODBCDest.GetLength() > 0 )
  168. CExportDB::ExecuteODBCFile( m_strODBCDest );
  169. }
  171. // Set Progress
  172. m_ctrlProgress.SetWindowPos( NULL, 0, 0, 0, 0, SWP_SHOWWINDOW | SWP_NOSIZE | SWP_NOMOVE );
  173. m_staticProgress.SetWindowPos( NULL, 0, 0, 0, 0, SWP_SHOWWINDOW | SWP_NOSIZE | SWP_NOMOVE );
  175. int nLower = 0, nUpper = 100;
  176. m_ctrlProgress.GetRange( nLower, nUpper );
  178. if( nUpper > nLower )
  179. {
  180. m_ctrlProgress.SetPos( nUpper );
  181. CString strInfo;
  182. strInfo.LoadString( IDS_EXPORTDB_FINISHED );
  183. m_staticProgress.SetWindowText( strInfo );
  184. }
  186. return TRUE;
  187. }
  189. void CExportDest::DoExport( )
  190. {
  191. // if( !AfxAssertFunclimitProf( ) )
  192. // return;
  194. // EnableWindow FALSE
  195. CPropertySheetEx * pSheet = DYNAMIC_DOWNCAST( CPropertySheetEx, GetParent() );
  196. if( pSheet )
  197. {
  198. CWnd * pWnd = pSheet->GetDlgItem( IDCANCEL );
  199. if( pWnd && ::IsWindow( pWnd->GetSafeHwnd() ) )
  200. pWnd->EnableWindow( FALSE );
  201. pWnd = pSheet->GetDlgItem( ID_WIZBACK );
  202. if( pWnd && ::IsWindow( pWnd->GetSafeHwnd() ) )
  203. pWnd->EnableWindow( FALSE );
  204. pWnd = pSheet->GetDlgItem( ID_WIZNEXT );
  205. if( pWnd && ::IsWindow( pWnd->GetSafeHwnd() ) )
  206. pWnd->EnableWindow( FALSE );
  207. }
  209. // Get Pages
  210. CSelectStk * pStk = (CSelectStk *)pSheet->GetPage(0);
  211. CExportOption * pOption = (CExportOption *)pSheet->GetPage(1);
  213. // Store CExportOption tmEnd
  214. CSPTime timeEnd;
  215. if( !AfxGetDB().GetTimeLocalRange( &timeEnd, NULL, NULL ) )
  216. timeEnd = CSPTime::GetCurrentTime();
  217. if( pOption->m_bTimeDefine && timeEnd.GetTime() > pOption->m_tmEnd.GetTime() )
  218. timeEnd = pOption->m_tmEnd.GetTime();
  219. pOption->m_tmEnd = timeEnd.GetTime();
  220. pOption->StoreProfile( );
  222. // Columns
  223. CStringArray astrColumn;
  224. CUIntArray anWidth;
  225. CString strTemp;
  226. strTemp.LoadString( IDS_EXPORTDEST_DATE ); astrColumn.Add( strTemp ); anWidth.Add( SLH_WIDTH_MIN );
  227. strTemp.LoadString( IDS_EXPORTDEST_OPEN ); astrColumn.Add( strTemp ); anWidth.Add( SLH_WIDTH_MIN );
  228. strTemp.LoadString( IDS_EXPORTDEST_HIGH ); astrColumn.Add( strTemp ); anWidth.Add( SLH_WIDTH_MIN );
  229. strTemp.LoadString( IDS_EXPORTDEST_LOW ); astrColumn.Add( strTemp ); anWidth.Add( SLH_WIDTH_MIN );
  230. strTemp.LoadString( IDS_EXPORTDEST_CLOSE ); astrColumn.Add( strTemp ); anWidth.Add( SLH_WIDTH_MIN );
  231. strTemp.LoadString( IDS_EXPORTDEST_AMOUNT ); astrColumn.Add( strTemp ); anWidth.Add( SLH_WIDTH_MIN );
  232. strTemp.LoadString( IDS_EXPORTDEST_VOLUME ); astrColumn.Add( strTemp ); anWidth.Add( SLH_WIDTH_MIN );
  234. m_bExporting = TRUE;
  235. m_bCanceled = FALSE;
  236. if( ExportBegin( astrColumn, anWidth, TRUE ) )
  237. {
  238. CString strText;
  239. int nCount = 0, nTotalCount = pStk->m_domainTemp.GetSize();
  240. SetProgressRange( 0, nTotalCount*10 );
  242. for( int i=0; i<pStk->m_domainTemp.GetSize(); i++ )
  243. {
  244. CStock stock;
  245. stock.SetStockCode( CStock::marketUnknown, pStk->m_domainTemp.ElementAt(i) );
  246. stock.SetDatabase( &AfxGetDB() );
  248. DoExportStock( stock, nCount*10, nCount*10+10, pOption );
  249. nCount ++;
  250. SetProgress( nCount*10 );
  252. // Canceled 
  253. if( m_bCanceled )
  254. break;
  255. }
  256. }
  258. // Finish Export
  259. ExportFinish( );
  261. if( m_bCanceled )
  262. {
  263. ExportFinish( );
  264. CPropertyPageEx::OnCancel( );
  265. return;
  266. }
  268. m_bExporting = FALSE;
  269. m_bCanceled = FALSE;
  271. // EnableWindow TRUE
  272. if( pSheet )
  273. {
  274. CWnd * pWnd = pSheet->GetDlgItem( IDCANCEL );
  275. if( pWnd && ::IsWindow( pWnd->GetSafeHwnd() ) )
  276. pWnd->EnableWindow( TRUE );
  277. pWnd = pSheet->GetDlgItem( ID_WIZBACK );
  278. if( pWnd && ::IsWindow( pWnd->GetSafeHwnd() ) )
  279. pWnd->EnableWindow( TRUE );
  280. pWnd = pSheet->GetDlgItem( ID_WIZNEXT );
  281. if( pWnd && ::IsWindow( pWnd->GetSafeHwnd() ) )
  282. pWnd->EnableWindow( TRUE );
  283. }
  284. }
  286. void CExportDest::DoExportStock( CStock &stock, int nProgressStart, int nProgressEnd, CExportOption * pOption )
  287. {
  288. // Prepare Data
  289. if( pOption->m_bKMin5 )
  290. stock.PrepareData( CStock::dataK, CKData::ktypeMin5 );
  291. if( pOption->m_bKMin15 )
  292. stock.PrepareData( CStock::dataK, CKData::ktypeMin15 );
  293. if( pOption->m_bKMin30 )
  294. stock.PrepareData( CStock::dataK, CKData::ktypeMin30 );
  295. if( pOption->m_bKMin60 )
  296. stock.PrepareData( CStock::dataK, CKData::ktypeMin60 );
  298. if( pOption->m_bNoResumeDR )
  299. {
  300. if( pOption->m_bKDay )
  301. stock.PrepareData( CStock::dataK, CKData::ktypeDay );
  302. if( pOption->m_bKMonth )
  303. stock.PrepareData( CStock::dataK, CKData::ktypeMonth );
  304. if( pOption->m_bKWeek )
  305. stock.PrepareData( CStock::dataK, CKData::ktypeWeek );
  306. }
  307. else
  308. {
  309. // DR Up or down, auto begin
  310. int nFormat = CKData::formatXDRdown;
  311. if( pOption->m_bResumeDRUp )
  312. nFormat = CKData::formatXDRup;
  313. DWORD dateAutoDRBegin = -1;
  314. if( pOption->m_bAutoResumeDR )
  315. {
  316. CSPTime sptime( pOption->m_tmAutoResumeDRBegin.GetTime() );
  317. dateAutoDRBegin = sptime.ToStockTimeDay( );
  318. }
  320. stock.PrepareData( CStock::dataDR );
  321. CDRData & drdata = stock.GetDRData();
  323. if( pOption->m_bKDay || pOption->m_bKMonth || pOption->m_bKWeek )
  324. {
  325. stock.PrepareData( CStock::dataK, CKData::ktypeDay );
  326. stock.GetKDataDay().SetDRData( drdata );
  327. stock.GetKDataDay().ChangeCurFormat( nFormat, dateAutoDRBegin, pOption->m_nAutoResumeDRLimit );
  329. if( pOption->m_bKMonth )
  330. stock.ExtractKData( CKData::ktypeMonth, TRUE );
  331. if( pOption->m_bKWeek )
  332. stock.ExtractKData( CKData::ktypeWeek, TRUE );
  333. }
  335. stock.GetKDataMin5().SetDRData( drdata );
  336. stock.GetKDataMin5().ChangeCurFormat( nFormat, dateAutoDRBegin, pOption->m_nAutoResumeDRLimit );
  337. stock.GetKDataMin15().SetDRData( drdata );
  338. stock.GetKDataMin15().ChangeCurFormat( nFormat, dateAutoDRBegin, pOption->m_nAutoResumeDRLimit );
  339. stock.GetKDataMin30().SetDRData( drdata );
  340. stock.GetKDataMin30().ChangeCurFormat( nFormat, dateAutoDRBegin, pOption->m_nAutoResumeDRLimit );
  341. stock.GetKDataMin60().SetDRData( drdata );
  342. stock.GetKDataMin60().ChangeCurFormat( nFormat, dateAutoDRBegin, pOption->m_nAutoResumeDRLimit );
  343. }
  345. // Calcuate Progress
  346. int nTotal = 0, nCount = 0;
  347. if( pOption->m_bKMonth ) nTotal += stock.GetKDataMonth().GetSize();
  348. if( pOption->m_bKWeek ) nTotal += stock.GetKDataWeek().GetSize();
  349. if( pOption->m_bKDay ) nTotal += stock.GetKDataDay().GetSize();
  350. if( pOption->m_bKMin5 ) nTotal += stock.GetKDataMin5().GetSize();
  351. if( pOption->m_bKMin15 ) nTotal += stock.GetKDataMin15().GetSize();
  352. if( pOption->m_bKMin30 ) nTotal += stock.GetKDataMin30().GetSize();
  353. if( pOption->m_bKMin60 ) nTotal += stock.GetKDataMin60().GetSize();
  355. if( 0 == nTotal )
  356. return;
  358. // time
  359. DWORD dateDayBegin = 0, dateDayEnd = (DWORD(-1));
  360. DWORD dateMinBegin = 0, dateMinEnd = (DWORD(-1));
  361. if( pOption->m_bTimeDefine )
  362. {
  363. dateDayBegin= CSPTime(pOption->m_tmBegin.GetTime()).ToStockTimeDay();
  364. dateDayEnd = CSPTime(pOption->m_tmEnd.GetTime()).ToStockTimeDay();
  365. dateMinBegin= CSPTime(pOption->m_tmBegin.GetTime()).ToStockTimeMin();
  366. dateMinEnd = CSPTime(pOption->m_tmEnd.GetTime()).ToStockTimeMin();
  367. }
  369. // Begin Export Month
  370. if( pOption->m_bKMonth
  371. && ExportOpenTable( stock, CKData::ktypeMonth, TRUE ) )
  372. {
  373. CKData & kdata = stock.GetKDataMonth( );
  374. for( int k=0; k<kdata.GetSize(); k++ )
  375. {
  376. KDATA kd = kdata.ElementAt(k);
  377. CStringArray astrItemText;
  378. if( DoExportKDATAToStringArray( kd, astrItemText, TRUE, dateDayBegin, dateDayEnd, stock.GetStockInfo().DigitBit() ) )
  379. ExportAddItem( astrItemText );
  380. nCount ++;
  381. SetProgress( nProgressStart + (nProgressEnd-nProgressStart)*nCount/nTotal );
  382. if( m_bCanceled ) return;
  383. }
  384. ExportCloseTable( );
  385. }
  387. // Begin Export Week
  388. if( pOption->m_bKWeek
  389. && ExportOpenTable( stock, CKData::ktypeWeek, TRUE ) )
  390. {
  391. CKData & kdata = stock.GetKDataWeek( );
  392. for( int k=0; k<kdata.GetSize(); k++ )
  393. {
  394. KDATA kd = kdata.ElementAt(k);
  395. CStringArray astrItemText;
  396. if( DoExportKDATAToStringArray( kd, astrItemText, TRUE, dateDayBegin, dateDayEnd, stock.GetStockInfo().DigitBit() ) )
  397. ExportAddItem( astrItemText );
  398. nCount ++;
  399. SetProgress( nProgressStart + (nProgressEnd-nProgressStart)*nCount/nTotal );
  400. if( m_bCanceled ) return;
  401. }
  402. ExportCloseTable( );
  403. }
  405. // Begin Export Day
  406. if( pOption->m_bKDay
  407. && ExportOpenTable( stock, CKData::ktypeDay, TRUE ) )
  408. {
  409. CKData & kdata = stock.GetKDataDay( );
  410. for( int k=0; k<kdata.GetSize(); k++ )
  411. {
  412. KDATA kd = kdata.ElementAt(k);
  413. CStringArray astrItemText;
  414. if( DoExportKDATAToStringArray( kd, astrItemText, TRUE, dateDayBegin, dateDayEnd, stock.GetStockInfo().DigitBit() ) )
  415. ExportAddItem( astrItemText );
  416. nCount ++;
  417. SetProgress( nProgressStart + (nProgressEnd-nProgressStart)*nCount/nTotal );
  418. if( m_bCanceled ) return;
  419. }
  420. ExportCloseTable( );
  421. }
  423. // Begin Export Min5
  424. if( pOption->m_bKMin5
  425. && ExportOpenTable( stock, CKData::ktypeMin5, TRUE ) )
  426. {
  427. CKData & kdata = stock.GetKDataMin5( );
  428. for( int k=0; k<kdata.GetSize(); k++ )
  429. {
  430. KDATA kd = kdata.ElementAt(k);
  431. CStringArray astrItemText;
  432. if( DoExportKDATAToStringArray( kd, astrItemText, FALSE, dateMinBegin, dateMinEnd, stock.GetStockInfo().DigitBit() ) )
  433. ExportAddItem( astrItemText );
  434. nCount ++;
  435. SetProgress( nProgressStart + (nProgressEnd-nProgressStart)*nCount/nTotal );
  436. if( m_bCanceled ) return;
  437. }
  438. ExportCloseTable( );
  439. }
  441. // Begin Export Min15
  442. if( pOption->m_bKMin15
  443. && ExportOpenTable( stock, CKData::ktypeMin15, TRUE ) )
  444. {
  445. CKData & kdata = stock.GetKDataMin15( );
  446. for( int k=0; k<kdata.GetSize(); k++ )
  447. {
  448. KDATA kd = kdata.ElementAt(k);
  449. CStringArray astrItemText;
  450. if( DoExportKDATAToStringArray( kd, astrItemText, FALSE, dateMinBegin, dateMinEnd, stock.GetStockInfo().DigitBit() ) )
  451. ExportAddItem( astrItemText );
  452. nCount ++;
  453. SetProgress( nProgressStart + (nProgressEnd-nProgressStart)*nCount/nTotal );
  454. if( m_bCanceled ) return;
  455. }
  456. ExportCloseTable( );
  457. }
  459. // Begin Export Min30
  460. if( pOption->m_bKMin30
  461. && ExportOpenTable( stock, CKData::ktypeMin30, TRUE ) )
  462. {
  463. CKData & kdata = stock.GetKDataMin30( );
  464. for( int k=0; k<kdata.GetSize(); k++ )
  465. {
  466. KDATA kd = kdata.ElementAt(k);
  467. CStringArray astrItemText;
  468. if( DoExportKDATAToStringArray( kd, astrItemText, FALSE, dateMinBegin, dateMinEnd, stock.GetStockInfo().DigitBit() ) )
  469. ExportAddItem( astrItemText );
  470. nCount ++;
  471. SetProgress( nProgressStart + (nProgressEnd-nProgressStart)*nCount/nTotal );
  472. if( m_bCanceled ) return;
  473. }
  474. ExportCloseTable( );
  475. }
  477. // Begin Export Min60
  478. if( pOption->m_bKMin60
  479. && ExportOpenTable( stock, CKData::ktypeMin60, TRUE ) )
  480. {
  481. CKData & kdata = stock.GetKDataMin60( );
  482. for( int k=0; k<kdata.GetSize(); k++ )
  483. {
  484. KDATA kd = kdata.ElementAt(k);
  485. CStringArray astrItemText;
  486. if( DoExportKDATAToStringArray( kd, astrItemText, FALSE, dateMinBegin, dateMinEnd, stock.GetStockInfo().DigitBit() ) )
  487. ExportAddItem( astrItemText );
  488. nCount ++;
  489. SetProgress( nProgressStart + (nProgressEnd-nProgressStart)*nCount/nTotal );
  490. if( m_bCanceled ) return;
  491. }
  492. ExportCloseTable( );
  493. }
  494. }
  496. BOOL CExportDest::DoExportKDATAToStringArray( KDATA & kd, CStringArray & astrItemText,
  497. BOOL bDayOrMin, DWORD dateBegin, DWORD dateEnd, int nDigitBits )
  498. {
  499. if( bDayOrMin )
  500. {
  501. if( kd.m_date < dateBegin || kd.m_date > dateEnd )
  502. return FALSE;
  503. }
  504. else
  505. {
  506. if( kd.m_date % 100000000 < dateBegin % 100000000
  507. || kd.m_date % 100000000 > dateEnd % 100000000 )
  508. return FALSE;
  509. }
  511. CString strTemp;
  513. // Date
  514. CSPTime sptime;
  515. sptime.FromStockTime( kd.m_date, bDayOrMin );
  516. strTemp = sptime.Format( "%Y-%m-%d" );
  517. astrItemText.Add( strTemp );
  519. CString strPriceFmt;
  520. strPriceFmt.Format( "%%.%df", nDigitBits );
  522. // Open
  523. strTemp.Format( strPriceFmt, kd.m_fOpen );
  524. astrItemText.Add( strTemp );
  526. // High
  527. strTemp.Format( strPriceFmt, kd.m_fHigh );
  528. astrItemText.Add( strTemp );
  530. // Low
  531. strTemp.Format( strPriceFmt, kd.m_fLow );
  532. astrItemText.Add( strTemp );
  534. // Close
  535. strTemp.Format( strPriceFmt, kd.m_fClose );
  536. astrItemText.Add( strTemp );
  538. // Amount
  539. strTemp.Format( "%u", DWORD(kd.m_fAmount/1000) );
  540. astrItemText.Add( strTemp );
  542. // Volume
  543. strTemp.Format( "%u", DWORD(kd.m_fVolume/100) );
  544. astrItemText.Add( strTemp );
  546. return TRUE;
  547. }
  549. void CExportDest::SetProgressRange( int nLower, int nUpper )
  550. {
  551. if( nUpper > nLower )
  552. {
  553. m_ctrlProgress.SetWindowPos( NULL, 0, 0, 0, 0, SWP_SHOWWINDOW | SWP_NOSIZE | SWP_NOMOVE );
  554. m_staticProgress.SetWindowPos( NULL, 0, 0, 0, 0, SWP_SHOWWINDOW | SWP_NOSIZE | SWP_NOMOVE );
  555. m_ctrlProgress.SetRange32( nLower, nUpper );
  556. }
  557. }
  559. void CExportDest::SetProgress( int nPos )
  560. {
  561. int nLower = 0, nUpper = 100;
  562. m_ctrlProgress.GetRange( nLower, nUpper );
  564. if( nUpper > nLower )
  565. {
  566. m_ctrlProgress.SetPos( nPos );
  568. CString strProgressNew;
  569. strProgressNew.Format( "%d%%", 100*nPos/(nUpper-nLower) );
  570. CString strProgressOld;
  571. m_staticProgress.GetWindowText( strProgressOld );
  572. if( 0 != strProgressNew.Compare( strProgressOld ) )
  573. m_staticProgress.SetWindowText( strProgressNew );
  574. }
  575. }
  577. void CExportDest::DoDataExchange(CDataExchange* pDX)
  578. {
  579. CPropertyPageEx::DoDataExchange(pDX);
  580. //{{AFX_DATA_MAP(CExportDest)
  581. DDX_Control(pDX, IDC_ODBC_SOURCE, m_btnODBCSource);
  582. DDX_Control(pDX, IDC_ODBC_DEST, m_editODBCDest);
  583. DDX_Control(pDX, IDC_ODBC_CHECK, m_btnODBCCheck);
  584. DDX_Control(pDX, IDC_STATIC_PROGRESS, m_staticProgress);
  585. DDX_Control(pDX, IDC_PROGRESS, m_ctrlProgress);
  586. DDX_Control(pDX, IDC_CSV_EXPLORER, m_btnCsvExplorer);
  587. DDX_Control(pDX, IDC_CSV_DEST, m_editCsvDest);
  588. DDX_Control(pDX, IDC_CSV_CHECK, m_btnCsvCheck);
  589. DDX_Control(pDX, IDC_MDB_EXPLORER, m_btnMdbExplorer);
  590. DDX_Control(pDX, IDC_MDB_DEST, m_editMdbDest);
  591. DDX_Control(pDX, IDC_MDB_CHECK, m_btnMdbCheck);
  592. DDX_Control(pDX, IDC_TXT_EXPLORER, m_btnTxtExplorer);
  593. DDX_Control(pDX, IDC_TXT_DEST, m_editTxtDest);
  594. DDX_Control(pDX, IDC_TXT_CHECK, m_btnTxtCheck);
  595. DDX_Text(pDX, IDC_TXT_DEST, m_strTxtDest);
  596. DDX_Text(pDX, IDC_MDB_DEST, m_strMdbDest);
  597. DDX_Text(pDX, IDC_CSV_DEST, m_strCsvDest);
  598. DDX_Check(pDX, IDC_TXT_CHECK, m_bTxtCheck);
  599. DDX_Check(pDX, IDC_MDB_CHECK, m_bMdbCheck);
  600. DDX_Check(pDX, IDC_CSV_CHECK, m_bCsvCheck);
  601. DDX_Check(pDX, IDC_EXEONFINISH, m_bExeOnFinish);
  602. DDX_Check(pDX, IDC_ODBC_CHECK, m_bODBCCheck);
  603. DDX_Text(pDX, IDC_ODBC_DEST, m_strODBCDest);
  604. //}}AFX_DATA_MAP
  605. }
  608. BEGIN_MESSAGE_MAP(CExportDest, CPropertyPageEx)
  609. //{{AFX_MSG_MAP(CExportDest)
  610. ON_BN_CLICKED(IDC_TXT_CHECK, OnTxtCheck)
  611. ON_BN_CLICKED(IDC_TXT_EXPLORER, OnTxtExplorer)
  612. ON_BN_CLICKED(IDC_MDB_CHECK, OnMdbCheck)
  613. ON_BN_CLICKED(IDC_MDB_EXPLORER, OnMdbExplorer)
  614. ON_BN_CLICKED(IDC_CSV_CHECK, OnCsvCheck)
  615. ON_BN_CLICKED(IDC_CSV_EXPLORER, OnCsvExplorer)
  616. ON_BN_CLICKED(IDC_ODBC_CHECK, OnODBCCheck)
  617. ON_BN_CLICKED(IDC_ODBC_SOURCE, OnOdbcSource)
  618. //}}AFX_MSG_MAP
  619. END_MESSAGE_MAP()
  621. /////////////////////////////////////////////////////////////////////////////
  622. // CExportDest message handlers
  624. BOOL CExportDest::OnInitDialog() 
  625. {
  626. CPropertyPageEx::OnInitDialog();
  628. // TODO: Add extra initialization here
  629. LoadProfile( );
  630. UpdateData( FALSE );
  632. // txt 
  633. m_btnTxtCheck.SetCheck( m_bTxtCheck );
  634. m_editTxtDest.EnableWindow( m_bTxtCheck );
  635. m_btnTxtExplorer.EnableWindow( m_bTxtCheck );
  636. int nCheckID = IDC_EXPORT_OVERWRITE;
  637. if( !m_bOverwrite )
  638. nCheckID = IDC_EXPORT_APPEND;
  639. CheckRadioButton( IDC_EXPORT_OVERWRITE, IDC_EXPORT_APPEND, nCheckID );
  641. // mdb
  642. m_btnMdbCheck.SetCheck( m_bMdbCheck );
  643. m_editMdbDest.EnableWindow( m_bMdbCheck );
  644. m_btnMdbExplorer.EnableWindow( m_bMdbCheck );
  646. // Csv
  647. m_btnCsvCheck.SetCheck( m_bCsvCheck );
  648. m_editCsvDest.EnableWindow( m_bCsvCheck );
  649. m_btnCsvExplorer.EnableWindow( m_bCsvCheck );
  651. // ODBC
  652. m_btnODBCCheck.SetCheck( m_bODBCCheck );
  653. m_editODBCDest.EnableWindow( m_bODBCCheck );
  654. m_btnODBCSource.EnableWindow( m_bODBCCheck );
  656. // progress ctrl
  657. m_ctrlProgress.SetWindowPos( NULL, 0, 0, 0, 0, SWP_HIDEWINDOW | SWP_NOSIZE | SWP_NOMOVE );
  658. m_staticProgress.SetWindowPos( NULL, 0, 0, 0, 0, SWP_HIDEWINDOW | SWP_NOSIZE | SWP_NOMOVE );
  660. return TRUE;  // return TRUE unless you set the focus to a control
  661.               // EXCEPTION: OCX Property Pages should return FALSE
  662. }
  664. void CExportDest::OnTxtCheck() 
  665. {
  666. // TODO: Add your control notification handler code here
  667. int nCheck = m_btnTxtCheck.GetCheck();
  668. m_editTxtDest.EnableWindow( nCheck );
  669. m_btnTxtExplorer.EnableWindow( nCheck );
  670. }
  672. void CExportDest::OnTxtExplorer() 
  673. {
  674. // TODO: Add your control notification handler code here
  675. UpdateData( );
  677. CString strTemp = AfxGetFileDirectoryExist( m_strTxtDest, (LPCTSTR)AfxGetProfile().GetExportPath() );
  679. if( AfxDoSelectDirectory( strTemp ) )
  680. {
  681. m_strTxtDest = strTemp;
  682. UpdateData( FALSE );
  683. }
  684. }
  686. void CExportDest::OnMdbCheck() 
  687. {
  688. // TODO: Add your control notification handler code here
  689. int nCheck = m_btnMdbCheck.GetCheck();
  690. m_editMdbDest.EnableWindow( nCheck );
  691. m_btnMdbExplorer.EnableWindow( nCheck );
  692. }
  694. void CExportDest::OnMdbExplorer() 
  695. {
  696. // TODO: Add your control notification handler code here
  697. UpdateData( );
  699. CFileDialog dlg (FALSE, NULL, NULL, OFN_EXPLORER | OFN_PATHMUSTEXIST | OFN_ENABLESIZING,
  700. "Microsoft Access Database files (*.mdb)|*.mdb|All files (*.*)|*.*||", NULL);
  701. if( IDOK == dlg.DoModal() )
  702. {
  703. m_strMdbDest = dlg.GetPathName();
  704. UpdateData( FALSE );
  705. }
  706. }
  708. void CExportDest::OnCsvCheck() 
  709. {
  710. // TODO: Add your control notification handler code here
  711. int nCheck = m_btnCsvCheck.GetCheck();
  712. m_editCsvDest.EnableWindow( nCheck );
  713. m_btnCsvExplorer.EnableWindow( nCheck );
  714. }
  716. void CExportDest::OnODBCCheck() 
  717. {
  718. // TODO: Add your control notification handler code here
  719. int nCheck = m_btnODBCCheck.GetCheck();
  720. m_editODBCDest.EnableWindow( nCheck );
  721. m_btnODBCSource.EnableWindow( nCheck );
  722. }
  724. void CExportDest::OnCsvExplorer() 
  725. {
  726. // TODO: Add your control notification handler code here
  727. UpdateData( );
  729. CString strTemp = AfxGetFileDirectoryExist( m_strCsvDest, (LPCTSTR)AfxGetProfile().GetExportPath() );
  731. if( AfxDoSelectDirectory( strTemp ) )
  732. {
  733. m_strCsvDest = strTemp;
  734. UpdateData( FALSE );
  735. }
  736. }
  738. void CExportDest::OnOdbcSource() 
  739. {
  740. // TODO: Add your control notification handler code here
  741. UpdateData( TRUE );
  743. if( m_exportdb.OpenODBCDB( NULL ) )
  744. {
  745. m_strODBCDest = m_exportdb.GetODBCConnect();
  746. UpdateData( FALSE );
  747. }
  748. }
  750. BOOL CExportDest::OnSetActive() 
  751. {
  752. // TODO: Add your specialized code here and/or call the base class
  753. m_bExporting = FALSE;
  754. m_bCanceled = FALSE;
  756. CPropertySheetEx * pSheet = DYNAMIC_DOWNCAST( CPropertySheetEx, GetParent() );
  757. if( pSheet )
  758. {
  759. pSheet->SetWizardButtons( m_dwButtonFlags );
  761. CWnd * pWnd = pSheet->GetDlgItem( ID_WIZNEXT );
  762. if( pWnd && ::IsWindow( pWnd->GetSafeHwnd() ) )
  763. {
  764. CString strTemp;
  765. strTemp.LoadString( IDS_EXPORT_START );
  766. pWnd->SetWindowText( strTemp );
  767. }
  768. }
  770. // progress ctrl
  771. m_ctrlProgress.SetWindowPos( NULL, 0, 0, 0, 0, SWP_HIDEWINDOW | SWP_NOSIZE | SWP_NOMOVE );
  772. m_staticProgress.SetWindowPos( NULL, 0, 0, 0, 0, SWP_HIDEWINDOW | SWP_NOSIZE | SWP_NOMOVE );
  774. return CPropertyPageEx::OnSetActive();
  775. }
  777. LRESULT CExportDest::OnWizardBack() 
  778. {
  779. // TODO: Add your specialized code here and/or call the base class
  781. return CPropertyPageEx::OnWizardBack();
  782. }
  784. LRESULT CExportDest::OnWizardNext() 
  785. {
  786. // TODO: Add your specialized code here and/or call the base class
  787. UpdateData( );
  789. CButton * pbtn = (CButton *)GetDlgItem( IDC_EXPORT_OVERWRITE );
  790. if( pbtn ) m_bOverwrite = pbtn->GetCheck();
  792. if( !m_bTxtCheck && !m_bMdbCheck && !m_bCsvCheck && !m_bODBCCheck )
  793. {
  794. AfxMessageBox( IDS_EXPORTDB_NODEST, MB_OK | MB_ICONINFORMATION );
  795. return -1;
  796. }
  798. if( m_bTxtCheck && m_strTxtDest.GetLength() == 0 )
  799. {
  800. AfxMessageBox( IDS_EXPORTDB_NOTXTDEST, MB_OK | MB_ICONINFORMATION );
  801. return -1;
  802. }
  803. if( m_bMdbCheck && m_strMdbDest.GetLength() == 0 )
  804. {
  805. AfxMessageBox( IDS_EXPORTDB_NOMDBDEST, MB_OK | MB_ICONINFORMATION );
  806. return -1;
  807. }
  808. if( m_bCsvCheck && m_strCsvDest.GetLength() == 0 )
  809. {
  810. AfxMessageBox( IDS_EXPORTDB_NOCSVDEST, MB_OK | MB_ICONINFORMATION );
  811. return -1;
  812. }
  813. if( m_bODBCCheck && m_strODBCDest.GetLength() == 0 )
  814. {
  815. AfxMessageBox( IDS_EXPORTDB_NOODBCDEST, MB_OK | MB_ICONINFORMATION );
  816. return -1;
  817. }
  819. if( m_bTxtCheck )
  820. {
  821. CPathDialog::MakeSurePathExists( m_strTxtDest );
  822. m_strTxtDest = AfxGetFileDirectoryExist( m_strTxtDest, (LPCTSTR)AfxGetProfile().GetExportPath() );
  823. }
  824. if( m_bMdbCheck )
  825. {
  826. int nIndex = m_strMdbDest.Find( "." );
  827. if( -1 == nIndex )
  828. m_strMdbDest += ".mdb";
  829. else if( m_strMdbDest.GetLength()-1 == nIndex )
  830. m_strMdbDest += "mdb";
  831. }
  832. if( m_bCsvCheck )
  833. {
  834. CPathDialog::MakeSurePathExists( m_strCsvDest );
  835. m_strCsvDest = AfxGetFileDirectoryExist( m_strCsvDest, (LPCTSTR)AfxGetProfile().GetExportPath() );
  836. }
  838. UpdateData( FALSE );
  840. // Store profile
  841. StoreProfile( );
  843. // Export
  844. DoExport( );
  846. return -1;
  847. }
  849. void CExportDest::OnCancel() 
  850. {
  851. // TODO: Add your specialized code here and/or call the base class
  852. if( m_bExporting )
  853. {
  854. if( IDOK == AfxMessageBox( IDS_EXPORTDEST_CONFIRMCLOSE, MB_OKCANCEL|MB_ICONINFORMATION ) )
  855. m_bCanceled = TRUE;
  856. return;
  857. }
  858. CPropertyPageEx::OnCancel();
  859. }
  862. BOOL CExportDest::PreTranslateMessage(MSG* pMsg) 
  863. {
  864. // TODO: Add your specialized code here and/or call the base class
  865. if( WM_KEYDOWN == pMsg->message && VK_RETURN == pMsg->wParam )
  866. return TRUE;
  867. return CPropertyPageEx::PreTranslateMessage(pMsg);
  868. }