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

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

金融证券系统

开发平台：

Visual C++

NetDB.cpp：源码内容
  1. /*
  2. Cross Platform Core Code.
  4. Copyright(R) 2001-2002 Balang Software.
  5. All rights reserved.
  7. Using:
  8. class CPackages;
  9. class CNetDatabase;
  10. */
  12. #include "stdafx.h"
  13. #include "../Include/XMLDoc.h"
  14. #include "../Include/HttpClt.h"
  15. #include "../Include/NetDB.h"
  16. #include "../Include/InfoZip.h"
  17. #include "Strings.h"
  18. #include <direct.h>
  19. #include <io.h>
  21. #ifdef _DEBUG
  22. #undef THIS_FILE
  23. static char THIS_FILE[]=__FILE__;
  24. #define new DEBUG_NEW
  25. #endif
  27. const char *szMarkupStockana = "stockana"; // For CMarkup Use
  28. const char *szMarkupSetting = "setting"; // For CMarkup Use
  29. const char *szMarkupServer = "server"; // For CMarkup Use
  30. const char *szMarkupQuoteServer = "quoteserver"; // For CMarkup Use
  31. const char *szMarkupAlias = "alias"; // For CMarkup Use
  32. const char *szMarkupPackage = "package"; // For CMarkup Use
  33. const char *szMarkupElement = "element"; // For CMarkup Use
  35. const char *szSettingElement = "/stockana/setting/element";
  36. const char *szSettingType = "type";
  37. const char *szSettingValue = "value";
  38. const char *szSettingVersion = "version";
  39. const char *szSettingDataVersion= "dataversion";
  40. const char *szSettingBasepath = "basepath";
  41. const char *szSettingYearfmt = "yearfmt";
  42. const char *szSettingMonthfmt = "monthfmt";
  43. const char *szSettingDayfmt = "dayfmt";
  44. const char *szSettingInfo = "info";
  45. const char *szSettingInfourl = "infourl";
  46. const char *szSettingLatestver = "latestver";
  47. const char *szServerElement = "/stockana/server/element";
  48. const char *szServerAddress = "address";
  49. const char *szServerPort = "port";
  50. const char *szServerDescript = "discript";
  52. const char *szQuoteServerElement = "/stockana/quoteserver/element";
  53. const char *szQuoteServerName = "name";
  54. const char *szQuoteServerAddress= "address";
  55. const char *szQuoteServerPort = "port";
  56. const char *szQuoteServerUser = "user";
  57. const char *szQuoteServerPasswd = "passwd";
  58. const char *szAliasElement = "/stockana/alias/element";
  59. const char *szAliasName = "name";
  60. const char *szAliasValue = "value";
  61. const char *szPackageElement = "/stockana/package/element";
  62. const char *szPackageURL = "url";
  63. const char *szPackageType = "type";
  64. const char *szPackageTypeCode = "code";
  65. const char *szPackageTypeDay = "day";
  66. const char *szPackageTypeMin5 = "min5";
  67. const char *szPackageTypeDR = "dr";
  68. const char *szPackageTypeBasetext = "basetext";
  69. const char *szPackageTypeBasetable = "basetable";
  70. const char *szPackageLength = "length";
  71. const char *szPackageDescript = "discript";
  72. const char *szPackageFrom = "from";
  73. const char *szPackageTo = "to";
  74. const char *szPackageZipStatus = "zipstatus";
  75. const char *szPackageTimefmt = "timefmt";
  76. const char *szPackageAlternateURL = "alter";
  78. //////////////////////////////////////////////////////////////////////////////////
  79. // class CPackage
  81. CPackage::CPackage()
  82. {
  83. m_nType = packageUnknown;
  84. m_nLength = 0;
  85. m_tmFrom = CSPTime(NULL);
  86. m_tmTo = CSPTime(NULL);
  87. m_bIsZipped = FALSE;
  88. m_bIsTimefmt= FALSE;
  90. m_bDownloadOK = FALSE;
  91. m_pExpandPackages = NULL;
  92. }
  94. CPackage::CPackage( const CPackage &src )
  95. {
  96. m_pExpandPackages = NULL;
  97. *this = src;
  98. }
  100. CPackage::~CPackage( )
  101. {
  102. if( m_pExpandPackages )
  103. {
  104. delete m_pExpandPackages;
  105. m_pExpandPackages = NULL;
  106. }
  107. }
  109. CPackage & CPackage::operator = ( const CPackage &src )
  110. {
  111. if( m_pExpandPackages )
  112. {
  113. delete m_pExpandPackages;
  114. m_pExpandPackages = NULL;
  115. }
  117. m_strURL = src.m_strURL;
  118. m_strAlternateURL = src.m_strAlternateURL;
  119. m_nType = src.m_nType;
  120. m_tmFrom = src.m_tmFrom;
  121. m_tmTo = src.m_tmTo;
  122. m_nLength = src.m_nLength;
  123. m_strDescript = src.m_strDescript;
  124. m_bIsZipped = src.m_bIsZipped;
  125. m_bIsTimefmt = src.m_bIsTimefmt;
  127. // temp data
  128. m_bDownloadOK = src.m_bDownloadOK;
  129. m_strLocalFilename = src.m_strLocalFilename;
  130. if( src.HasExpandPackage() )
  131. {
  132. m_pExpandPackages = new CPackages;
  133. m_pExpandPackages->AppendPackages( src.m_pExpandPackages );
  134. }
  136. return *this;
  137. }
  139. BOOL CPackage::SetAttribute( CMarkup & markup )
  140. {
  141. m_nType = packageUnknown;
  142. CString strType = CXMLNode::getAttrValue( markup, szPackageType );
  143. if( 0 == strType.CompareNoCase( szPackageTypeCode ) )
  144. m_nType = packageCode;
  145. else if( 0 == strType.CompareNoCase( szPackageTypeDay ) )
  146. m_nType = packageDay;
  147. else if( 0 == strType.CompareNoCase( szPackageTypeMin5 ) )
  148. m_nType = packageMin5;
  149. else if( 0 == strType.CompareNoCase( szPackageTypeDR ) )
  150. m_nType = packageDR;
  151. else if( 0 == strType.CompareNoCase( szPackageTypeBasetext ) )
  152. m_nType = packageBasetext;
  153. else if( 0 == strType.CompareNoCase( szPackageTypeBasetable ) )
  154. m_nType = packageBasetable;
  156. m_strURL = CXMLNode::getAttrValue( markup, szPackageURL );
  157. m_strAlternateURL = CXMLNode::getAttrValue( markup, szPackageAlternateURL );
  158. m_tmFrom = CXMLNode::getAttrValue_T( markup, szPackageFrom );
  159. m_tmTo = CXMLNode::getAttrValue_T( markup, szPackageTo );
  160. m_nLength = CXMLNode::getAttrValue_I( markup, szPackageLength );
  161. m_strDescript = CXMLNode::getAttrValue( markup, szPackageDescript );
  162. m_bIsZipped = CXMLNode::getAttrValue_I( markup, szPackageZipStatus );
  163. m_bIsTimefmt= CXMLNode::getAttrValue_I( markup, szPackageTimefmt );
  165. if( m_tmFrom > m_tmTo )
  166. m_tmFrom = m_tmTo;
  168. if( m_tmTo.GetHour() == 0 )
  169. m_tmTo += CSPTimeSpan( 0, 23, 59, 59 );
  170. return TRUE;
  171. }
  173. BOOL CPackage::operator<(CPackage& p) const
  174. {
  175. return (m_tmFrom < p.m_tmFrom);
  176. }
  178. CString CPackage::GetURL( CString strBasePath )
  179. {
  180. if( !m_bIsTimefmt )
  181. return strBasePath + m_strURL;
  182. else
  183. {
  184. CSPTime time = CSPTime::GetCurrentTime();
  185. int nWeekDay = time.GetDayOfWeek( );
  186. if( nWeekDay == 1 )
  187. {
  188. time -= CSPTimeSpan( 2, 0, 0, 0 );
  189. }
  190. else if( nWeekDay == 7 )
  191. {
  192. time -= CSPTimeSpan( 1, 0, 0, 0 );
  193. }
  194. return strBasePath + (LPCTSTR)time.Format( m_strURL );
  195. }
  196. }
  198. BOOL CPackage::HasAlternateURL( ) const
  199. {
  200. return !m_strAlternateURL.IsEmpty();
  201. }
  203. CString CPackage::GetAlternateURL( CString strBasePath )
  204. {
  205. return strBasePath + m_strAlternateURL;
  206. }
  208. BOOL CPackage::HasExpandPackage( ) const
  209. {
  210. return ( m_pExpandPackages && m_pExpandPackages->GetSize() > 0 );
  211. }
  213. BOOL CPackage::ExpandYearPackage( CString strMonthfmt, CString strDayfmt, int nYear )
  214. {
  215. if( NULL != m_pExpandPackages )
  216. {
  217. delete m_pExpandPackages;
  218. m_pExpandPackages = NULL;
  219. }
  221. m_pExpandPackages = new CPackages( );
  223. if( m_pExpandPackages && !strMonthfmt.IsEmpty() )
  224. {
  225. int nMonthStart = 1;
  226. int nMonthEnd = 12;
  227. for( int nMonth=nMonthStart; nMonth<=nMonthEnd; nMonth ++ )
  228. {
  229. CPackage pac;
  230. pac.m_bIsTimefmt = FALSE;
  231. pac.m_bIsZipped = TRUE;
  232. pac.m_nLength = 400000;
  233. pac.m_nType = CPackage::packageDay;
  234. pac.m_strDescript.Format( szFmtMonthDescript, nYear, nMonth );
  236. CSPTime tmMonth( nYear, nMonth, 1, 0, 0, 0 );
  237. pac.m_strURL = tmMonth.Format( strMonthfmt );
  238. pac.m_tmFrom = CSPTime( nYear, nMonth, 1, 0, 0, 0 );
  239. pac.m_tmTo = CSPTime( nYear, nMonth, 31, 23, 59, 59 );
  240. if( nMonth == nMonthEnd )
  241. pac.ExpandMonthPackage( strDayfmt, nYear, nMonth );
  243. m_pExpandPackages->Add( pac );
  244. }
  245. return TRUE;
  246. }
  247. return FALSE;
  248. }
  250. BOOL CPackage::ExpandMonthPackage( CString strDayfmt, int nYear, int nMonth )
  251. {
  252. if( NULL != m_pExpandPackages )
  253. {
  254. delete m_pExpandPackages;
  255. m_pExpandPackages = NULL;
  256. }
  258. m_pExpandPackages = new CPackages( );
  260. if( m_pExpandPackages && !strDayfmt.IsEmpty() )
  261. {
  262. int nDayStart = 1;
  263. CSPTime tmDay( nYear, nMonth, nDayStart, 23, 0, 0 );
  264. for( ; tmDay.GetMonth() == nMonth; tmDay += CSPTimeSpan(1,0,0,0) )
  265. {
  266. CPackage pac;
  267. pac.m_bIsTimefmt = FALSE;
  268. pac.m_bIsZipped = FALSE;
  269. pac.m_nLength = 20000;
  270. pac.m_nType = CPackage::packageDay;
  271. pac.m_strDescript.Format( szFmtDayDescript, nYear, nMonth, tmDay.GetDay() );
  273. pac.m_strURL = tmDay.Format( strDayfmt );
  274. pac.m_tmFrom = CSPTime( nYear, nMonth, tmDay.GetDay(), 0, 0, 0 );
  275. pac.m_tmTo = CSPTime( nYear, nMonth, tmDay.GetDay(), 23, 59, 59 );
  277. if( tmDay.GetDayOfWeek() != 1 && tmDay.GetDayOfWeek() != 7 )
  278. m_pExpandPackages->Add( pac );
  279. }
  280. return TRUE;
  281. }
  282. return FALSE;
  283. }
  285. CPackages * CPackage::GetExpandPackages( )
  286. {
  287. ASSERT( HasExpandPackage() );
  288. return m_pExpandPackages;
  289. }
  291. void CPackage::DeleteExpandPackages( )
  292. {
  293. if( m_pExpandPackages )
  294. {
  295. delete m_pExpandPackages;
  296. m_pExpandPackages = NULL;
  297. }
  298. }
  301. //////////////////////////////////////////////////////////////////////////////////
  302. // class CPackages
  304. CPackages::CPackages()
  305. {
  306. Clear( );
  307. }
  309. CPackages::~CPackages()
  310. {
  311. Clear();
  312. }
  314. void CPackages::Clear( )
  315. {
  316. m_bIsOK = FALSE;
  317. m_xmlDocument.Release();
  319. m_strVersion.Empty();
  320. m_nDataVersion = 0;
  321. m_strBasePath.Empty();
  322. m_strYearfmt.Empty();
  323. m_strMonthfmt.Empty();
  324. m_strDayfmt.Empty();
  325. m_strInfo.Empty();
  326. m_strInfourl.Empty();
  327. m_strLatestver.Empty();
  328. SetSize( 0 );
  329. }
  331. BOOL CPackages::IsOK( )
  332. {
  333. return m_bIsOK;
  334. }
  336. BOOL CPackages::AddSmartAdditional( )
  337. {
  338. CSPTime tmLatest;
  339. GetLatestTime( tmLatest, CPackage::packageDay );
  340. CSPTime tmNow = CSPTime::GetCurrentTime();
  342. CSPTime tmBegin = tmLatest + CSPTimeSpan( 1, 0, 0, 0 );
  344. if( !m_strYearfmt.IsEmpty() )
  345. {
  346. int nYearStart = tmBegin.GetYear();
  347. int nYearEnd = tmNow.GetYear()-1;
  348. for( int nYear=nYearStart; nYear<=nYearEnd; nYear ++ )
  349. {
  350. CPackage pac;
  351. pac.m_bIsTimefmt = FALSE;
  352. pac.m_bIsZipped = TRUE;
  353. pac.m_nLength = 5000000;
  354. pac.m_nType = CPackage::packageDay;
  355. pac.m_strDescript.Format( szFmtYearDescript, nYear );
  357. CSPTime tmYear( nYear, tmBegin.GetMonth(), 1, 0, 0, 0 );
  358. pac.m_strURL = tmYear.Format( m_strYearfmt );
  359. pac.m_tmFrom = CSPTime( nYear, 1, 1, 0, 0, 0 );
  360. pac.m_tmTo = CSPTime( nYear, 12, 31, 23, 59, 59 );
  361. if( nYear == nYearEnd )
  362. pac.ExpandYearPackage( m_strMonthfmt, m_strDayfmt, nYear );
  364. Add( pac );
  365. }
  366. }
  368. if( !m_strMonthfmt.IsEmpty() )
  369. {
  370. int nMonthStart = 1;
  371. if( tmBegin.GetYear() == tmNow.GetYear() )
  372. nMonthStart = tmBegin.GetMonth();
  373. int nMonthEnd = tmNow.GetMonth()-1;
  374. for( int nMonth=nMonthStart; nMonth<=nMonthEnd; nMonth ++ )
  375. {
  376. CPackage pac;
  377. pac.m_bIsTimefmt = FALSE;
  378. pac.m_bIsZipped = TRUE;
  379. pac.m_nLength = 400000;
  380. pac.m_nType = CPackage::packageDay;
  381. pac.m_strDescript.Format( szFmtMonthDescript, tmNow.GetYear(), nMonth );
  383. CSPTime tmMonth( tmNow.GetYear(), nMonth, 1, 0, 0, 0 );
  384. pac.m_strURL = tmMonth.Format( m_strMonthfmt );
  385. pac.m_tmFrom = CSPTime( tmNow.GetYear(), nMonth, 1, 0, 0, 0 );
  386. pac.m_tmTo = CSPTime( tmNow.GetYear(), nMonth, 31, 23, 59, 59 );
  387. if( nMonth == nMonthEnd )
  388. pac.ExpandMonthPackage( m_strDayfmt, tmNow.GetYear(), nMonth );
  390. Add( pac );
  391. }
  392. }
  394. if( !m_strDayfmt.IsEmpty() )
  395. {
  396. int nDayStart = 1;
  397. if( tmBegin.GetYear() == tmNow.GetYear() && tmBegin.GetMonth() == tmNow.GetMonth() )
  398. nDayStart = tmBegin.GetDay();
  399. int nDayEnd = tmNow.GetDay();
  400. for( int nDay=nDayStart; nDay<=nDayEnd; nDay ++ )
  401. {
  402. CPackage pac;
  403. pac.m_bIsTimefmt = FALSE;
  404. pac.m_bIsZipped = FALSE;
  405. pac.m_nLength = 20000;
  406. pac.m_nType = CPackage::packageDay;
  407. pac.m_strDescript.Format( szFmtDayDescript, tmNow.GetYear(), tmNow.GetMonth(), nDay );
  409. CSPTime tmDay( tmNow.GetYear(), tmNow.GetMonth(), nDay, 23, 0, 0 );
  410. pac.m_strURL = tmDay.Format( m_strDayfmt );
  411. pac.m_tmFrom = CSPTime( tmNow.GetYear(), tmNow.GetMonth(), nDay, 0, 0, 0 );
  412. pac.m_tmTo = CSPTime( tmNow.GetYear(), tmNow.GetMonth(), nDay, 23, 59, 59 );
  414. if( tmDay.GetDayOfWeek() != 1 && tmDay.GetDayOfWeek() != 7 )
  415. Add( pac );
  416. }
  417. }
  419. return TRUE;
  420. }
  422. BOOL CPackages::SetRawXMLDocument( CString &strDoc )
  423. {
  424. Clear( );
  426. m_bIsOK = FALSE;
  428. if( m_xmlDocument.Initialize() )
  429. m_bIsOK = m_xmlDocument.SetRawDocument( strDoc );
  431. if( m_bIsOK )
  432. {
  433. m_bIsOK = ExtractFromXMLDoc( );
  434. }
  436. if( m_bIsOK )
  437. {
  438. m_bIsOK = AddSmartAdditional( );
  439. }
  441. return m_bIsOK;
  442. }
  444. BOOL CPackages::SetAttribute( CMarkup & markup )
  445. {
  446. CString strType = CXMLNode::getAttrValue( markup, szSettingType );
  448. if( 0 == strType.CompareNoCase(szSettingVersion) )
  449. m_strVersion = CXMLNode::getAttrValue( markup, szSettingValue );
  450. else if( 0 == strType.CompareNoCase(szSettingDataVersion) )
  451. m_nDataVersion = CXMLNode::getAttrValue_I( markup, szSettingValue );
  452. else if( 0 == strType.CompareNoCase(szSettingBasepath) )
  453. m_strBasePath = CXMLNode::getAttrValue( markup, szSettingValue );
  454. else if( 0 == strType.CompareNoCase(szSettingYearfmt) )
  455. m_strYearfmt = CXMLNode::getAttrValue( markup, szSettingValue );
  456. else if( 0 == strType.CompareNoCase(szSettingMonthfmt) )
  457. m_strMonthfmt = CXMLNode::getAttrValue( markup, szSettingValue );
  458. else if( 0 == strType.CompareNoCase(szSettingDayfmt) )
  459. m_strDayfmt = CXMLNode::getAttrValue( markup, szSettingValue );
  460. else if( 0 == strType.CompareNoCase(szSettingInfo) )
  461. m_strInfo = CXMLNode::getAttrValue( markup, szSettingValue );
  462. else if( 0 == strType.CompareNoCase(szSettingInfourl) )
  463. m_strInfourl = CXMLNode::getAttrValue( markup, szSettingValue );
  464. else if( 0 == strType.CompareNoCase(szSettingLatestver) )
  465. m_strLatestver = CXMLNode::getAttrValue( markup, szSettingValue );
  467. return TRUE;
  468. }
  470. BOOL CPackages::ExtractFromXMLDoc( )
  471. {
  472. CMarkup & markup = m_xmlDocument.Markup();
  474. // extract setting
  475. markup.ResetPos();
  476. if( !markup.FindElem(szMarkupStockana) )
  477. return FALSE;
  478. ASSERT( 0 == markup.GetTagName().Compare( szMarkupStockana ) );
  479. if( markup.FindChildElem(szMarkupSetting) )
  480. {
  481. markup.IntoElem();
  482. ASSERT( 0 == markup.GetTagName().Compare( szMarkupSetting ) );
  483. if( markup.FindChildElem( szMarkupElement ) )
  484. {
  485. do {
  486. markup.IntoElem();
  487. ASSERT( 0 == markup.GetTagName().Compare( szMarkupElement ) );
  488. if( !SetAttribute( markup ) )
  489. {
  490. m_xmlDocument.SetLastErrorMessage( szErrXMLServerSetting );
  491. return FALSE;
  492. }
  493. }while( markup.FindElem( szMarkupElement ) );
  494. }
  495. }
  497. // extract package
  498. markup.ResetPos();
  499. if( !markup.FindElem(szMarkupStockana) )
  500. return FALSE;
  501. ASSERT( 0 == markup.GetTagName().Compare( szMarkupStockana ) );
  502. if( markup.FindChildElem(szMarkupPackage) )
  503. {
  504. markup.IntoElem();
  505. ASSERT( 0 == markup.GetTagName().Compare( szMarkupPackage ) );
  506. if( markup.FindChildElem( szMarkupElement ) )
  507. {
  508. do {
  509. markup.IntoElem();
  510. ASSERT( 0 == markup.GetTagName().Compare( szMarkupElement ) );
  511. CPackage package;
  512. if( package.SetAttribute( markup ) )
  513. Add( package );
  514. } while( markup.FindElem( szMarkupElement ) );
  515. }
  516. }
  518. markup.ResetPos();
  519. return TRUE;
  520. /* OLD VERSION
  521. m_strVersion.Empty();
  522. m_nDataVersion = 0;
  523. m_strBasePath.Empty();
  524. SetSize( 0 );
  526. MSXML::IXMLDOMNodePtr pNodeRoot = m_xmlDocument.XMLDoc();
  528. try
  529. {
  530. // extract setting
  531. MSXML::IXMLDOMNodeListPtr pNodeList = pNodeRoot->selectNodes( szSettingElement );
  532. if( NULL != pNodeList )
  533. {
  534. for( int i=0; i<pNodeList->length; i++ )
  535. {
  536. MSXML::IXMLDOMNodePtr pNode = pNodeList->Getitem(i);
  537. if( !SetAttribute( pNode ) )
  538. {
  539. m_xmlDocument.SetLastErrorMessage( szErrXMLPackageSetting );
  540. return FALSE;
  541. }
  542. }
  543. }
  545. // extract package
  546. pNodeList = pNodeRoot->selectNodes( szPackageElement );
  547. if( NULL == pNodeList || 0 == pNodeList->length )
  548. {
  549. m_xmlDocument.SetLastErrorMessage( szErrXMLPackageData );
  550. return FALSE;
  551. }
  553. for( int i=0; i<pNodeList->length; i++ )
  554. {
  555. MSXML::IXMLDOMNodePtr pNode = pNodeList->Getitem(i);
  556. CPackage package;
  557. if( package.SetAttribute( pNode ) )
  558. Add( package );
  559. }
  560. }
  561. catch( _com_error e )
  562. {
  563. m_xmlDocument.SetLastErrorMessage( e.ErrorMessage() );
  564. return FALSE;
  565. }
  566. return TRUE;
  567. */
  568. }
  570. int SortPackage(const void *p1,const void *p2)
  571. {
  572. CPackage *pPackage1 = (CPackage *)p1;
  573. CPackage *pPackage2 = (CPackage *)p2;
  575. if( pPackage1 && pPackage2 && pPackage1->m_tmFrom < pPackage2->m_tmFrom )
  576. return -1;
  577. else if( pPackage1 && pPackage2 && pPackage1->m_tmFrom > pPackage2->m_tmFrom )
  578. return 1;
  579. return 0;
  580. }
  582. void CPackages::Sort( )
  583. {
  584. if( NULL != GetData() )
  585. qsort( GetData(), GetSize(), sizeof(CPackage), SortPackage );
  586. }
  588. void CPackages::AppendPackages( CPackages * psrc )
  589. {
  590. if( !psrc || psrc->GetSize() == 0 )
  591. return;
  593. int nOldSize = GetSize();
  595. SetSize( nOldSize + psrc->GetSize() );
  596. for( int i=0; i<psrc->GetSize(); i++ )
  597. {
  598. SetAt( nOldSize+i, psrc->GetAt(i) );
  599. }
  600. }
  602. BOOL CPackages::GetLatestTime( CSPTime &tm, int packagetype )
  603. {
  604. tm = CSPTime(NULL);
  605. BOOL bHas = FALSE;
  606. for( int i=0; i<GetSize(); i++ )
  607. {
  608. CPackage & pac = ElementAt(i);
  609. if( pac.m_nType == packagetype
  610. && tm < pac.m_tmTo )
  611. {
  612. tm = pac.m_tmTo;
  613. bHas = TRUE;
  614. }
  615. }
  616. if( !bHas )
  617. tm = CSPTime::GetCurrentTime();
  618. return TRUE;
  619. }
  621. BOOL CPackages::GetLastErrorMessage(LPTSTR lpszError, UINT nMaxError)
  622. {
  623. return m_xmlDocument.GetLastErrorMessage( lpszError, nMaxError );
  624. }
  626. //////////////////////////////////////////////////////////////////////////////////
  627. // class CDownloadServer
  629. CDownloadServer::CDownloadServer( const CDownloadServer &src )
  630. {
  631. *this = src;
  632. }
  634. CDownloadServer & CDownloadServer::operator = ( const CDownloadServer & src )
  635. {
  636. m_strAddress = src.m_strAddress;
  637. m_nPort = src.m_nPort;
  638. m_strDescript = src.m_strDescript;
  639. return *this;
  640. }
  642. BOOL CDownloadServer::SetAttribute( CMarkup & markup )
  643. {
  644. m_strAddress = CXMLNode::getAttrValue( markup, szServerAddress );
  645. m_nPort = CXMLNode::getAttrValue_I( markup, szServerPort );
  646. m_strDescript = CXMLNode::getAttrValue( markup, szServerDescript );
  648. #ifdef CLKLAN_ENGLISH_US
  649. if( !AfxIsEnglish( m_strDescript, m_strDescript.GetLength() ) )
  650. m_strDescript.Empty();
  651. #endif
  653. return TRUE;
  654. }
  656. BOOL CDownloadServer::FromString( CString string )
  657. {
  658. m_strAddress.Empty();
  659. m_nPort = INTERNET_DEFAULT_HTTP_PORT;
  660. m_strDescript.Empty();
  662. int nIndex = string.Find( ':' );
  663. if( -1 == nIndex )
  664. {
  665. m_strAddress = string;
  666. return m_strAddress.GetLength()>0;
  667. }
  668. m_strAddress = string.Left( nIndex );
  669. string = string.Mid( nIndex+1 );
  671. nIndex = string.Find( ':' );
  672. if( -1 == nIndex )
  673. {
  674. m_nPort = (INTERNET_PORT)atol(string);
  675. return m_strAddress.GetLength()>0;
  676. }
  677. m_nPort = (INTERNET_PORT)atol(string.Left(nIndex));
  678. m_strDescript = string.Mid(nIndex+1);
  679. return m_strAddress.GetLength()>0;
  680. }
  682. CString CDownloadServer::AsString( )
  683. {
  684. CString string;
  685. string.Format( "%s:%d:%s", m_strAddress, m_nPort, m_strDescript );
  686. return string;
  687. }
  689. BOOL AliasSetAttribute( CMarkup & markup, CAlias & alias )
  690. {
  691. alias.m_strName = CXMLNode::getAttrValue( markup, szAliasName );
  692. alias.m_strValue = CXMLNode::getAttrValue( markup, szAliasValue );
  693. return TRUE;
  694. }
  696. BOOL QuoteServerSetAttribute( CMarkup & markup, CQuoteServer & qs )
  697. {
  698. qs.m_strName = CXMLNode::getAttrValue( markup, szQuoteServerName );
  699. qs.m_strAddress = CXMLNode::getAttrValue( markup, szQuoteServerAddress );
  700. qs.m_nPort = CXMLNode::getAttrValue_I( markup, szQuoteServerPort );
  701. qs.m_strUser = CXMLNode::getAttrValue( markup, szQuoteServerUser );
  702. qs.m_strPasswd = CXMLNode::getAttrValue( markup, szQuoteServerPasswd );
  703. qs.m_bSavePasswd = TRUE;
  704. #ifdef CLKLAN_ENGLISH_US
  705. if( !AfxIsEnglish( qs.m_strName, qs.m_strName.GetLength() ) )
  706. qs.m_strName = qs.m_strAddress;
  707. #endif
  708. return TRUE;
  709. }
  712. //////////////////////////////////////////////////////////////////////////////////
  713. // class CServers
  715. CServers::CServers()
  716. {
  717. Clear( );
  718. }
  720. CServers::~CServers()
  721. {
  722. Clear();
  723. }
  725. void CServers::Clear( )
  726. {
  727. m_bIsOK = FALSE;
  728. m_xmlDocument.Release();
  730. m_strVersion.Empty();
  731. m_aDownloadServers.SetSize( 0 );
  732. m_aQuoteServers.SetSize( 0 );
  733. m_aAliases.SetSize( 0 );
  734. }
  736. BOOL CServers::IsOK( )
  737. {
  738. return m_bIsOK;
  739. }
  741. BOOL CServers::SetRawXMLDocument( CString &strDoc )
  742. {
  743. Clear( );
  744. m_bIsOK = FALSE;
  746. if( m_xmlDocument.Initialize() )
  747. m_bIsOK = m_xmlDocument.SetRawDocument( strDoc );
  749. if( m_bIsOK )
  750. {
  751. m_bIsOK = ExtractFromXMLDoc( );
  752. }
  754. return m_bIsOK;
  755. }
  757. BOOL CServers::SetAttribute( CMarkup & markup )
  758. {
  759. CString strType = CXMLNode::getAttrValue( markup, szSettingType );
  761. if( 0 == strType.CompareNoCase(szSettingVersion) )
  762. m_strVersion = CXMLNode::getAttrValue( markup, szSettingValue );
  764. return TRUE;
  765. }
  767. BOOL CServers::ExtractFromXMLDoc( )
  768. {
  769. CMarkup & markup = m_xmlDocument.Markup();
  771. // extract setting
  772. markup.ResetPos();
  773. if( !markup.FindElem(szMarkupStockana) )
  774. return FALSE;
  775. ASSERT( 0 == markup.GetTagName().Compare( szMarkupStockana ) );
  776. if( markup.FindChildElem(szMarkupSetting) )
  777. {
  778. markup.IntoElem();
  779. ASSERT( 0 == markup.GetTagName().Compare( szMarkupSetting ) );
  780. if( markup.FindChildElem( szMarkupElement ) )
  781. {
  782. do {
  783. markup.IntoElem();
  784. ASSERT( 0 == markup.GetTagName().Compare( szMarkupElement ) );
  785. if( !SetAttribute( markup ) )
  786. {
  787. m_xmlDocument.SetLastErrorMessage( szErrXMLServerSetting );
  788. return FALSE;
  789. }
  790. }while( markup.FindElem( szMarkupElement ) );
  791. }
  792. }
  794. // extract server
  795. markup.ResetPos();
  796. if( !markup.FindElem(szMarkupStockana) )
  797. return FALSE;
  798. ASSERT( 0 == markup.GetTagName().Compare( szMarkupStockana ) );
  799. if( markup.FindChildElem(szMarkupServer) )
  800. {
  801. markup.IntoElem();
  802. ASSERT( 0 == markup.GetTagName().Compare( szMarkupServer ) );
  803. if( markup.FindChildElem( szMarkupElement ) )
  804. {
  805. do {
  806. markup.IntoElem();
  807. ASSERT( 0 == markup.GetTagName().Compare( szMarkupElement ) );
  808. CDownloadServer server;
  809. if( server.SetAttribute( markup ) )
  810. m_aDownloadServers.Add( server );
  811. } while( markup.FindElem( szMarkupElement ) );
  812. }
  813. }
  815. // extract quote server
  816. markup.ResetPos();
  817. if( !markup.FindElem(szMarkupStockana) )
  818. return FALSE;
  819. ASSERT( 0 == markup.GetTagName().Compare( szMarkupStockana ) );
  820. if( markup.FindChildElem(szMarkupQuoteServer) )
  821. {
  822. markup.IntoElem();
  823. ASSERT( 0 == markup.GetTagName().Compare( szMarkupQuoteServer ) );
  824. if( markup.FindChildElem( szMarkupElement ) )
  825. {
  826. do {
  827. markup.IntoElem();
  828. ASSERT( 0 == markup.GetTagName().Compare( szMarkupElement ) );
  829. CQuoteServer server;
  830. if( QuoteServerSetAttribute( markup, server ) )
  831. m_aQuoteServers.Add( server );
  832. } while( markup.FindElem( szMarkupElement ) );
  833. }
  834. }
  836. // extract alias
  837. markup.ResetPos();
  838. if( !markup.FindElem(szMarkupStockana) )
  839. return FALSE;
  840. ASSERT( 0 == markup.GetTagName().Compare( szMarkupStockana ) );
  841. if( markup.FindChildElem(szMarkupAlias) )
  842. {
  843. markup.IntoElem();
  844. ASSERT( 0 == markup.GetTagName().Compare( szMarkupAlias ) );
  845. if( markup.FindChildElem( szMarkupElement ) )
  846. {
  847. do {
  848. markup.IntoElem();
  849. ASSERT( 0 == markup.GetTagName().Compare( szMarkupElement ) );
  850. CAlias alias;
  851. if( AliasSetAttribute( markup, alias ) )
  852. m_aAliases.Add( alias );
  853. } while( markup.FindElem( szMarkupElement ) );
  854. }
  855. }
  857. markup.ResetPos();
  858. return TRUE;
  860. /* OLD VERSION
  861. SetSize( 0 );
  862. m_strVersion.Empty();
  864. MSXML::IXMLDOMNodePtr pNodeRoot = m_xmlDocument.XMLDoc();
  866. try
  867. {
  868. // extract setting
  869. MSXML::IXMLDOMNodeListPtr pNodeList = pNodeRoot->selectNodes( szSettingElement );
  870. if( NULL != pNodeList )
  871. {
  872. for( int i=0; i<pNodeList->length; i++ )
  873. {
  874. MSXML::IXMLDOMNodePtr pNode = pNodeList->Getitem(i);
  875. if( !SetAttribute( pNode ) )
  876. {
  877. m_xmlDocument.SetLastErrorMessage( szErrXMLServerSetting );
  878. return FALSE;
  879. }
  880. }
  881. }
  883. // extract server
  884. pNodeList = pNodeRoot->selectNodes( szServerElement );
  885. if( NULL == pNodeList || 0 == pNodeList->length )
  886. {
  887. return TRUE;
  888. }
  890. for( int i=0; i<pNodeList->length; i++ )
  891. {
  892. MSXML::IXMLDOMNodePtr pNode = pNodeList->Getitem(i);
  893. CDownloadServer server;
  894. if( server.SetAttribute( pNode ) )
  895. m_aDownloadServers.Add( server );
  896. }
  897. }
  898. catch( _com_error e )
  899. {
  900. m_xmlDocument.SetLastErrorMessage( e.ErrorMessage() );
  901. return FALSE;
  902. }
  903. return TRUE;
  904. */
  905. }
  907. BOOL CServers::GetLastErrorMessage(LPTSTR lpszError, UINT nMaxError)
  908. {
  909. return m_xmlDocument.GetLastErrorMessage( lpszError, nMaxError );
  910. }
  912. BOOL CServers::SaveToProfile( )
  913. {
  914. CSPStringArray astrServers;
  915. for( int i=0; i<m_aDownloadServers.GetSize(); i++ )
  916. astrServers.Add( m_aDownloadServers.ElementAt(i).AsString() );
  917. AfxGetProfile().SetDownloadServers( astrServers );
  918. AfxGetProfile().StoreProfile();
  919. AfxGetQSProfile().AddQuoteServers( m_aQuoteServers );
  920. AfxGetQSProfile().StoreAliases( m_aAliases );
  921. AfxGetQSProfile().StoreProfile();
  922. return TRUE;
  923. }
  925. //////////////////////////////////////////////////////////////////////////////////
  926. // class CNetDatabase
  928. CNetDatabase::CNetDatabase( )
  929. {
  930. }
  932. CNetDatabase::~CNetDatabase( )
  933. {
  934. }
  936. BOOL CNetDatabase::SetServer( LPCTSTR lpszServer, INTERNET_PORT port )
  937. {
  938. if( !m_httpClient.SetServer( lpszServer, port ) )
  939. {
  940. SetLastError( ERR_NETDB_HTTPCLIENT );
  941. return FALSE;
  942. }
  943. return TRUE;
  944. }
  946. BOOL CNetDatabase::SetAccessType( int nAccessType, int nProxyType, LPCTSTR lpszProxyAddress, UINT nProxyPort,
  947. LPCSTR lpszProxyUser, LPCTSTR lpszProxyPasswd )
  948. {
  949. if( ! m_httpClient.SetAccessType( nAccessType, nProxyType, lpszProxyAddress, nProxyPort, lpszProxyUser, lpszProxyPasswd ) )
  950. {
  951. SetLastError( ERR_NETDB_HTTPCLIENT );
  952. return FALSE;
  953. }
  954. return TRUE;
  955. }
  957. BOOL CNetDatabase::Login( LPCTSTR lpszRegCode, LPCTSTR lpszUserName,
  958.   LPCTSTR lpszPasswd, LPCTSTR lpszVersion )
  959. {
  960. if( ! m_httpClient.Login( lpszRegCode, lpszUserName, lpszPasswd, lpszVersion ) )
  961. {
  962. SetLastError( ERR_NETDB_HTTPCLIENT );
  963. return FALSE;
  964. }
  965. return TRUE;
  966. }
  968. BOOL CNetDatabase::Logout( )
  969. {
  970. if( ! m_httpClient.Logout( ) )
  971. {
  972. SetLastError( ERR_NETDB_HTTPCLIENT );
  973. return FALSE;
  974. }
  975. return TRUE;
  976. }
  978. BOOL CNetDatabase::GetLastErrorMessage(LPTSTR lpszError, UINT nMaxError )
  979. {
  980. switch( GetLastError() )
  981. {
  982. case ERR_NETDB_HTTPCLIENT:
  983. return m_httpClient.GetLastErrorMessage( lpszError, nMaxError );
  984. case ERR_NETDB_PACKAGES:
  985. return m_packages.GetLastErrorMessage( lpszError, nMaxError );
  986. case ERR_NETDB_SERVERS:
  987. return m_servers.GetLastErrorMessage( lpszError, nMaxError );
  988. case ERR_NETDB_ZIPDLL:
  989. strncpy( lpszError, szErrZipDll, nMaxError );
  990. return strlen(lpszError)>0;
  991. case ERR_NETDB_ZIP:
  992. strncpy( lpszError, szErrZip, nMaxError );
  993. return strlen(lpszError)>0;
  994. default:
  995. return CStDatabase::GetLastErrorMessage( lpszError, nMaxError );
  996. }
  997. }
  999. CString CNetDatabase::GetProgressMessage(UINT nProgressCode)
  1000. {
  1001. CString string;
  1002. switch( nProgressCode )
  1003. {
  1004. case PROG_HTTPCONNECTTING: string = szProgHttpConnectting; break;
  1005. case PROG_REQUESTSENT: string = szProgRequestSent; break;
  1006. case PROG_REDIRECTING: string = szProgRedirecting; break;
  1007. case PROG_TRANSFERRING: string = szProgTransferring; break;
  1008. case PROG_INSTALLPACKAGE: string = szProgInstallPackage; break;
  1009. case PROG_EXTRACTZIPFILES: string = szProgExtractZipFiles; break;
  1010. case PROG_ERRORPAC: string = szProgErrorPac; break;
  1011. default:;
  1012. }
  1013. return string;
  1014. }
  1016. BOOL CNetDatabase::NetloadPackageInfo( PROGRESS_CALLBACK fnCallback, void *cookie )
  1017. {
  1018. CString strPackageInfo;
  1019. if( !m_httpClient.LoadPackageInfo( strPackageInfo, fnCallback, cookie ) )
  1020. {
  1021. SetLastError( ERR_NETDB_HTTPCLIENT );
  1022. return FALSE;
  1023. }
  1025. if( ! m_packages.SetRawXMLDocument( strPackageInfo ) )
  1026. {
  1027. SetLastError( ERR_NETDB_PACKAGES );
  1028. return FALSE;
  1029. }
  1031. AfxGetProfile().SetNetInfo( m_packages.m_strInfo, m_packages.m_strInfourl );
  1032. AfxGetProfile().SetLatestver( m_packages.m_strLatestver );
  1034. return TRUE;
  1035. }
  1037. BOOL CNetDatabase::NetloadServerInfo( PROGRESS_CALLBACK fnCallback, void *cookie )
  1038. {
  1039. CString strServerInfo;
  1040. if( !m_httpClient.LoadServerInfo( strServerInfo, fnCallback, cookie ) )
  1041. {
  1042. SetLastError( ERR_NETDB_HTTPCLIENT );
  1043. return FALSE;
  1044. }
  1046. if( ! m_servers.SetRawXMLDocument( strServerInfo ) )
  1047. {
  1048. SetLastError( ERR_NETDB_SERVERS );
  1049. return FALSE;
  1050. }
  1052. return TRUE;
  1053. }
  1055. int CNetDatabase::NetloadCodetbl( PROGRESS_CALLBACK fnCallback, void *cookie )
  1056. {
  1057. if( ! m_packages.IsOK() )
  1058. return FALSE;
  1060. CSPTime tmFrom(NULL);
  1061. CSPTime tmTo = CSPTime::GetCurrentTime();
  1062. return NetloadPackage( CPackage::packageCode, tmFrom, tmTo, fnCallback, cookie );
  1063. }
  1066. int CNetDatabase::NetloadDayKLine( LPCTSTR lpszStockCode, CSPTime *ptmFrom, CSPTime *ptmTo,
  1067.    PROGRESS_CALLBACK fnCallback, void *cookie )
  1068. {
  1069. if( ! m_packages.IsOK() )
  1070. return FALSE;
  1072. CSPTime tmFrom(NULL), tmTo(NULL);
  1073. if( NULL != ptmFrom )
  1074. tmFrom = *ptmFrom;
  1076. if( NULL != ptmTo )
  1077. tmTo = *ptmTo;
  1078. else
  1079. GetLatestTimeNet( tmTo, CPackage::packageDay );
  1081. return NetloadPackage( CPackage::packageDay, tmFrom, tmTo, fnCallback, cookie );
  1082. }
  1084. int CNetDatabase::Netload5MinKLine( LPCTSTR lpszStockCode, CSPTime *ptmFrom, CSPTime *ptmTo,
  1085. PROGRESS_CALLBACK fnCallback, void *cookie )
  1086. {
  1087. if( ! m_packages.IsOK() )
  1088. return FALSE;
  1090. CSPTime tmFrom(NULL), tmTo(NULL);
  1091. if( NULL != ptmFrom )
  1092. tmFrom = *ptmFrom;
  1094. if( NULL != ptmTo )
  1095. tmTo = *ptmTo;
  1096. else
  1097. GetLatestTimeNet( tmTo, CPackage::packageMin5 );
  1099. return NetloadPackage( CPackage::packageMin5, tmFrom, tmTo, fnCallback, cookie );
  1100. }
  1102. int CNetDatabase::NetloadDRData( LPCTSTR lpszStockCode, CSPTime *ptmFrom, CSPTime *ptmTo,
  1103.  PROGRESS_CALLBACK fnCallback, void *cookie )
  1104. {
  1105. if( ! m_packages.IsOK() )
  1106. return FALSE;
  1108. CSPTime tmFrom(NULL), tmTo(NULL);
  1109. if( NULL != ptmFrom )
  1110. tmFrom = *ptmFrom;
  1112. if( NULL != ptmTo )
  1113. tmTo = *ptmTo;
  1114. else
  1115. GetLatestTimeNet( tmTo, CPackage::packageDR );
  1117. return NetloadPackage( CPackage::packageDR, tmFrom, tmTo, fnCallback, cookie );
  1118. }
  1120. int CNetDatabase::NetloadBasetext( LPCTSTR lpszStockCode, CSPTime *ptmFrom, CSPTime *ptmTo,
  1121.    PROGRESS_CALLBACK fnCallback, void *cookie )
  1122. {
  1123. if( ! m_packages.IsOK() )
  1124. return FALSE;
  1126. CSPTime tmFrom(NULL), tmTo(NULL);
  1127. if( NULL != ptmFrom )
  1128. tmFrom = *ptmFrom;
  1129. else
  1130. tmFrom = CSPTime(NULL);
  1131. if( NULL != ptmTo )
  1132. tmTo = *ptmTo;
  1133. else
  1134. GetLatestTimeNet( tmTo, CPackage::packageBasetext );
  1136. return NetloadPackage( CPackage::packageBasetext, tmFrom, tmTo, fnCallback, cookie );
  1137. }
  1139. int CNetDatabase::NetloadBasetable( LPCTSTR lpszStockCode, CSPTime *ptmFrom, CSPTime *ptmTo,
  1140.    PROGRESS_CALLBACK fnCallback, void *cookie )
  1141. {
  1142. if( ! m_packages.IsOK() )
  1143. return FALSE;
  1145. CSPTime tmFrom(NULL), tmTo(NULL);
  1146. if( NULL != ptmFrom )
  1147. tmFrom = *ptmFrom;
  1148. else
  1149. tmFrom = CSPTime(NULL);
  1150. if( NULL != ptmTo )
  1151. tmTo = *ptmTo;
  1152. else
  1153. GetLatestTimeNet( tmTo, CPackage::packageBasetable );
  1155. return NetloadPackage( CPackage::packageBasetable, tmFrom, tmTo, fnCallback, cookie );
  1156. }
  1158. struct progress_cookie_t {
  1159. DWORD nLenFinished;
  1160. DWORD nLenCur;
  1161. DWORD nLenTotal;
  1162. PROGRESS_CALLBACK fnCallbackSuper;
  1163. void * cookieSuper;
  1164. };
  1166. BOOL CALLBACK LocalProgressCallback(DWORD dwCode, DWORD dwProgress,
  1167. LPCTSTR lpszMsg, void *cookie)
  1168. {
  1169. struct progress_cookie_t *p = (struct progress_cookie_t *)cookie;
  1171. if( PROG_PROGRESS == dwCode )
  1172. {
  1173. DWORD dwLenCurFinished = DWORD( (double(dwProgress))*p->nLenCur / STKLIB_MAXF_PROGRESS );
  1174. if( dwLenCurFinished > p->nLenCur )
  1175. dwLenCurFinished = p->nLenCur;
  1176. DWORD dwTotalProgress = dwProgress;
  1177. if( p->nLenTotal > 0 )
  1178. dwTotalProgress = DWORD( STKLIB_MAXF_PROGRESS*(p->nLenFinished+dwLenCurFinished)/(p->nLenTotal) );
  1179. if( p->fnCallbackSuper )
  1180. return p->fnCallbackSuper( dwCode, dwTotalProgress, lpszMsg, p->cookieSuper );
  1181. return TRUE;
  1182. }
  1183. else
  1184. {
  1185. if( p->fnCallbackSuper )
  1186. return p->fnCallbackSuper( dwCode, dwProgress, lpszMsg, p->cookieSuper );
  1187. return TRUE;
  1188. }
  1189. }
  1191. int CNetDatabase::NetloadPackage( int nPackageType, CSPTime &tmFrom, CSPTime &tmTo,
  1192.   PROGRESS_CALLBACK fnCallback, void *cookie )
  1193. {
  1194. if( ! m_packages.IsOK() )
  1195. return FALSE;
  1197. m_packages.Sort( );
  1199. int nTotalLen = 0;
  1200. for( int i=0; i<m_packages.GetSize(); i++ )
  1201. {
  1202. CPackage & pac = m_packages.ElementAt(i);
  1203. if( pac.m_nType != nPackageType
  1204. || pac.m_tmTo < tmFrom
  1205. || pac.m_tmFrom > tmTo )
  1206. continue;
  1208. nTotalLen += pac.m_nLength;
  1209. }
  1211. struct progress_cookie_t cookieLocal;
  1212. cookieLocal.fnCallbackSuper = fnCallback;
  1213. cookieLocal.cookieSuper = cookie;
  1214. cookieLocal.nLenTotal = nTotalLen<<1;
  1215. cookieLocal.nLenFinished = 0;
  1217. for( i=0; i<m_packages.GetSize(); i++ )
  1218. {
  1219. CPackage pac = m_packages.ElementAt(i);
  1220. if( pac.m_nType != nPackageType
  1221. || pac.m_tmTo < tmFrom
  1222. || pac.m_tmFrom > tmTo )
  1223. continue;
  1225. cookieLocal.nLenCur = pac.m_nLength;
  1227. CFile file;
  1228. BOOL bOK = FALSE;
  1229. BOOL bExpand = FALSE;
  1230. CString sFileName;
  1231. if( GetTempFile( sFileName ) 
  1232. && file.Open( sFileName, CFile::modeCreate | CFile::modeReadWrite ) )
  1233. {
  1234. bOK = m_httpClient.LoadPackage( pac.GetURL( m_packages.m_strBasePath ), &file, LocalProgressCallback, &cookieLocal );
  1235. if( !bOK && pac.HasAlternateURL() )
  1236. {
  1237. file.Close();
  1238. if( file.Open( sFileName, CFile::modeCreate | CFile::modeReadWrite ) )
  1239. bOK = m_httpClient.LoadPackage( pac.GetAlternateURL(m_packages.m_strBasePath), &file, LocalProgressCallback, &cookieLocal );
  1240. }
  1242. if( !bOK && pac.HasExpandPackage( ) )
  1243. {
  1244. m_packages.AppendPackages( pac.GetExpandPackages() );
  1245. m_packages.ElementAt(i).DeleteExpandPackages();
  1246. bExpand = TRUE;
  1247. }
  1249. if( CFile::hFileNull != file.m_hFile )
  1250. file.Close();
  1252. m_packages.ElementAt(i).m_bDownloadOK = bOK;
  1253. m_packages.ElementAt(i).m_strLocalFilename = sFileName;
  1254. }
  1256. if( !bExpand )
  1257. cookieLocal.nLenFinished += pac.m_nLength;
  1258. }
  1260. int nCount = 0;
  1261. for( i=0; i<m_packages.GetSize(); i++ )
  1262. {
  1263. CPackage & pac = m_packages.ElementAt(i);
  1265. BOOL bOK = pac.m_bDownloadOK;
  1266. pac.m_bDownloadOK = FALSE;
  1267. if( bOK )
  1268. {
  1269. cookieLocal.nLenCur = pac.m_nLength;
  1270. bOK = InstallPackageEx( pac, pac.m_strLocalFilename, LocalProgressCallback, &cookieLocal );
  1271. if( !bOK && fnCallback )
  1272. {
  1273. CString str = pac.m_strDescript;
  1274. fnCallback( PROG_ERRORPAC, 0, str.GetBuffer(str.GetLength()+1), cookie );
  1275. str.ReleaseBuffer();
  1276. }
  1278. RemoveTempFile( pac.m_strLocalFilename );
  1279. LocalProgressCallback( PROG_PROGRESS, STKLIB_MAX_PROGRESS, NULL, &cookieLocal );
  1280. cookieLocal.nLenFinished += pac.m_nLength;
  1281. if( bOK )
  1282. nCount ++;
  1283. }
  1284. }
  1286. return nCount;
  1287. }
  1289. BOOL CNetDatabase::GetLatestTimeNet( CSPTime &tm, int packagetype )
  1290. {
  1291. return m_packages.GetLatestTime( tm, packagetype );
  1292. }
  1294. CServers & CNetDatabase::GetServers( )
  1295. {
  1296. return m_servers;
  1297. }
  1299. CPackages & CNetDatabase::GetPackages( )
  1300. {
  1301. return m_packages;
  1302. }
  1304. int CNetDatabase::GetMaxStockNumber( )
  1305. {
  1306. return CStDatabase::GetMaxStockNumber();
  1307. }
  1309. int CNetDatabase::LoadCodetable( CStockContainer & container )
  1310. {
  1311. return CStDatabase::LoadCodetable( container );
  1312. }
  1314. int CNetDatabase::LoadBaseText( CStock *pstock )
  1315. {
  1316. return CStDatabase::LoadBaseText( pstock );
  1317. }
  1319. int CNetDatabase::LoadKData( CStock *pstock, int period )
  1320. {
  1321. return CStDatabase::LoadKData( pstock, period );
  1322. }
  1324. int CNetDatabase::LoadDRData( CStock *pstock )
  1325. {
  1326. return CStDatabase::LoadDRData( pstock );
  1327. }
  1329. BOOL CNetDatabase::EmptyTempDirectory( LPCTSTR lpszPath )
  1330. {
  1331. CString strFinder;
  1332. if( NULL == lpszPath )
  1333. {
  1334. char szTempPath[MAX_PATH+1];
  1335. memset( szTempPath, 0, sizeof(szTempPath) );
  1336. if( GetSelfTempPath( szTempPath, MAX_PATH ) <= 0 )
  1337. return FALSE;
  1338. strFinder = szTempPath;
  1339. }
  1340. else
  1341. strFinder = lpszPath;
  1343. strFinder += "*";
  1345. CFileFind finder;
  1346. BOOL bWorking = finder.FindFile( strFinder );
  1347. while( bWorking )
  1348. {
  1349. bWorking = finder.FindNextFile();
  1350. DWORD attr = GetFileAttributes( finder.GetFilePath() );
  1351. if( 0xFFFFFFFF != attr && (attr & FILE_ATTRIBUTE_DIRECTORY) )
  1352. {
  1353. CString strName = finder.GetFileName();
  1354. if( 0 != strName.CompareNoCase(".") && 0 != strName.CompareNoCase("..") )
  1355. {
  1356. EmptyTempDirectory( finder.GetFilePath() + STRING_DIRSEP );
  1357. RemoveDirectory( finder.GetFilePath() );
  1358. }
  1359. }
  1360. else
  1361. {
  1362. DeleteFile( finder.GetFilePath() );
  1363. }
  1364. }
  1365. finder.Close();
  1366. return TRUE;
  1367. }
  1370. // protected method
  1371. BOOL CNetDatabase::GetTempFile( CString &rString )
  1372. {
  1373. char szTempPath[MAX_PATH+1];
  1374. memset( szTempPath, 0, sizeof(szTempPath) );
  1375. GetSelfTempPath( szTempPath, MAX_PATH );
  1377. if( 0 == strlen(szTempPath) )
  1378. GetTempPath( MAX_PATH, szTempPath );
  1380. if( 0 == strlen(szTempPath) )
  1381. return FALSE;
  1383. char szFile[MAX_PATH+1];
  1384. memset( szFile, 0, sizeof(szFile) );
  1385. if( 0!=GetTempFileName( szTempPath, "net", 0, szFile ) )
  1386. {
  1387. rString = szFile;
  1388. return TRUE;
  1389. }
  1390. return FALSE;
  1391. }
  1393. BOOL CNetDatabase::RemoveTempFile( CString sFileName )
  1394. {
  1395. return DeleteFile( sFileName );
  1396. }
  1398. BOOL CNetDatabase::OpenTempFile( CFile &file )
  1399. {
  1400. CString strFileName;
  1401. GetTempFile( strFileName );
  1403. BOOL bOpen = file.Open( strFileName, CFile::modeCreate | CFile::modeReadWrite | CFile::shareExclusive );
  1404. if( !bOpen )
  1405. DeleteFile(strFileName);
  1406. return bOpen;
  1407. }
  1409. BOOL CNetDatabase::CloseAndRemoveTempFile( CFile &file )
  1410. {
  1411. if( CFile::hFileNull != file.m_hFile )
  1412. {
  1413. CString strFileName = file.GetFilePath( );
  1414. try{
  1415. file.Close();
  1416. }catch( CException * e ) { e->Delete(); }
  1417. return DeleteFile( strFileName );
  1418. }
  1419. return FALSE;
  1420. }
  1422. BOOL CNetDatabase::GetTempNewDirectory( CString &sTempNewDir )
  1423. {
  1424. char szTempPath[MAX_PATH+1];
  1425. memset( szTempPath, 0, sizeof(szTempPath) );
  1427. GetSelfTempPath( szTempPath, MAX_PATH );
  1429. if( 0 == strlen(szTempPath) )
  1430. GetTempPath( MAX_PATH, szTempPath );
  1432. if( 0 == strlen(szTempPath) )
  1433. return FALSE;
  1435. CString sDir = szTempPath;
  1436. sDir += "NFO";
  1438. srand( time(NULL) );
  1439. DWORD dw = rand() % 10000;
  1440. sTempNewDir.Format( "%s%.4d\", sDir, dw );
  1442. int nCount = 0;
  1443. while( 0 == access(sDir,0) )
  1444. {
  1445. nCount ++;
  1446. if( nCount > 1000 )
  1447. return FALSE;
  1448. dw ++;
  1449. sTempNewDir.Format( "%s%.4d\", sDir, dw );
  1450. }
  1452. return CreateDirectory( sTempNewDir, NULL );
  1453. }
  1455. BOOL CNetDatabase::RemoveTempNewDirectory( CString sTempNewDir )
  1456. {
  1457. CFileFind finder;
  1458. BOOL bWorking = finder.FindFile( sTempNewDir + "*.*" );
  1459. while( bWorking )
  1460. {
  1461. bWorking = finder.FindNextFile();
  1462. DeleteFile( finder.GetFilePath() );
  1463. }
  1464. finder.Close();
  1466. return RemoveDirectory(sTempNewDir);
  1467. }
  1469. int CNetDatabase::GetFileCount( const char * path, BOOL bRecurse )
  1470. {
  1471. if( NULL == path || strlen(path) == 0 )
  1472. return FALSE;
  1474. int nCount = 0;
  1476. CString strFinder = path;
  1477. if( strFinder.GetLength() > 0 &&
  1478. strFinder[strFinder.GetLength()-1] != '\' && strFinder[strFinder.GetLength()-1] != '/' )
  1479. strFinder += STRING_DIRSEP;
  1480. strFinder += "*";
  1481. CFileFind finder;
  1482. BOOL bWorking = finder.FindFile( strFinder );
  1483. while( bWorking )
  1484. {
  1485. bWorking = finder.FindNextFile();
  1486. DWORD attr = GetFileAttributes( finder.GetFilePath() );
  1487. if( 0xFFFFFFFF != attr && (attr & FILE_ATTRIBUTE_DIRECTORY) && bRecurse )
  1488. {
  1489. CString strName = finder.GetFileName();
  1490. if( 0 != strName.CompareNoCase(".") && 0 != strName.CompareNoCase("..") )
  1491. nCount += GetFileCount( finder.GetFilePath() + STRING_DIRSEP, bRecurse );
  1492. }
  1493. if( 0xFFFFFFFF != attr && !(attr & FILE_ATTRIBUTE_DIRECTORY) )
  1494. nCount ++;
  1495. }
  1496. finder.Close();
  1497. return nCount;
  1498. }
  1500. BOOL CNetDatabase::InstallPackageEx( CPackage &pac, const char *zipfilename,
  1501. PROGRESS_CALLBACK fnCallback, void *cookie )
  1502. {
  1503. if( !pac.m_bIsZipped )
  1504. {
  1505. if( fnCallback )
  1506. fnCallback( PROG_INSTALLPACKAGE, 0, NULL, cookie );
  1507. return InstallPackage( pac, zipfilename, fnCallback, cookie );
  1508. }
  1510. if( NULL == zipfilename || strlen(zipfilename) == 0 )
  1511. return FALSE;
  1513. CInfoZip InfoZip;
  1514. if (!InfoZip.InitializeUnzip())
  1515. {
  1516. SetLastError( ERR_NETDB_ZIPDLL );
  1517. return FALSE;
  1518. }
  1520. CString sTempNewDir;
  1521. if( !GetTempNewDirectory( sTempNewDir ) )
  1522. {
  1523. InfoZip.FinalizeUnzip();
  1524. return FALSE;
  1525. }
  1527. if( fnCallback )
  1528. fnCallback( PROG_EXTRACTZIPFILES, 0, NULL, cookie );
  1530. if (!InfoZip.ExtractFiles(zipfilename, sTempNewDir))
  1531. {
  1532. SetLastError( ERR_NETDB_ZIP );
  1533. InfoZip.FinalizeUnzip();
  1534. return FALSE;
  1535. }
  1537. if (!InfoZip.FinalizeUnzip())
  1538. {
  1539. SetLastError( ERR_NETDB_ZIPDLL );
  1540. }
  1542. if( fnCallback )
  1543. fnCallback( PROG_INSTALLPACKAGE, 0, NULL, cookie );
  1545. int nTotalCount = GetFileCount( sTempNewDir );
  1546. BOOL bRet = InstallPackagePath( pac, sTempNewDir, fnCallback, cookie, nTotalCount, 0 );
  1548. RemoveTempNewDirectory( sTempNewDir );
  1550. return bRet;
  1551. }
  1553. BOOL CNetDatabase::InstallPackagePath( CPackage &pac, const char *path,
  1554. PROGRESS_CALLBACK fnCallback, void *cookie,
  1555. int nTotalCount, int nFinishCount, BOOL bDeleteAfterInstall )
  1556. {
  1557. if( NULL == path || strlen(path) == 0 )
  1558. return FALSE;
  1560. CString strFinder = path;
  1561. if( strFinder[strFinder.GetLength()-1] != '\' && strFinder[strFinder.GetLength()-1] != '/' )
  1562. strFinder += STRING_DIRSEP;
  1563. strFinder += "*";
  1565. BOOL bRet = TRUE;
  1566. CFileFind finder;
  1567. BOOL bWorking = finder.FindFile( strFinder );
  1568. while( bWorking )
  1569. {
  1570. bWorking = finder.FindNextFile();
  1571. DWORD attr = GetFileAttributes( finder.GetFilePath() );
  1572. if( 0xFFFFFFFF != attr && (attr & FILE_ATTRIBUTE_DIRECTORY) )
  1573. {
  1574. CString strName = finder.GetFileName();
  1575. if( 0 != strName.CompareNoCase(".") && 0 != strName.CompareNoCase("..") )
  1576. {
  1577. bRet &= InstallPackagePath( pac, finder.GetFilePath() + STRING_DIRSEP,
  1578. fnCallback, cookie, nTotalCount, nFinishCount );
  1579. if( bDeleteAfterInstall )
  1580. RemoveDirectory( finder.GetFilePath() );
  1581. }
  1582. }
  1583. if( 0xFFFFFFFF != attr && !(attr & FILE_ATTRIBUTE_DIRECTORY) )
  1584. {
  1585. if( 1 == nTotalCount )
  1586. bRet &= InstallPackage( pac, finder.GetFilePath(), fnCallback, cookie );
  1587. else
  1588. bRet &= InstallPackage( pac, finder.GetFilePath(), fnCallback, cookie );
  1589. if( bDeleteAfterInstall )
  1590. DeleteFile( finder.GetFilePath() );
  1591. nFinishCount ++;
  1592. if( fnCallback && nTotalCount > 1 )
  1593. fnCallback( PROG_PROGRESS, DWORD(STKLIB_MAXF_PROGRESS*nFinishCount/nTotalCount), NULL, cookie );
  1594. }
  1595. }
  1596. finder.Close();
  1597. if( fnCallback )
  1598. fnCallback( PROG_PROGRESS, STKLIB_MAX_PROGRESS, NULL, cookie );
  1599. return bRet;
  1600. }
  1602. BOOL CNetDatabase::InstallPackage( CPackage &pac, const char *pacfile,
  1603.    PROGRESS_CALLBACK fnCallback, void *cookie )
  1604. {
  1605. CString strFilenameOrg;
  1606. if( pac.m_bIsZipped )
  1607. strFilenameOrg = pacfile;
  1608. else if( !pac.m_strURL.IsEmpty() )
  1609. strFilenameOrg = pac.m_strURL;
  1610. else
  1611. strFilenameOrg = pacfile;
  1612. int nIndex = strFilenameOrg.ReverseFind( '/' );
  1613. if( -1 != nIndex )
  1614. strFilenameOrg = strFilenameOrg.Mid( nIndex + 1 );
  1615. nIndex = strFilenameOrg.ReverseFind( '\' );
  1616. if( -1 != nIndex )
  1617. strFilenameOrg = strFilenameOrg.Mid( nIndex + 1 );
  1619. BOOL bOK = strFilenameOrg.GetLength() > 4;
  1620. if( bOK && CPackage::packageCode == pac.m_nType )
  1621. {
  1622. CString strDomainFile = AfxGetProfile().GetDomainFile();
  1623. int nIndex = strDomainFile.ReverseFind( '/' );
  1624. if( -1 != nIndex )
  1625. strDomainFile = strDomainFile.Mid( nIndex + 1 );
  1626. nIndex = strDomainFile.ReverseFind( '\' );
  1627. if( -1 != nIndex )
  1628. strDomainFile = strDomainFile.Mid( nIndex + 1 );
  1630. if( 0 == strFilenameOrg.CompareNoCase( strDomainFile ) ) // 板块数据
  1631. bOK = (InstallCodetblBlock( pacfile, strFilenameOrg ) >= 0 );
  1632. else if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".blk" ) ) // 分析家板块
  1633. bOK = (InstallCodetblFxjBlock( pacfile, strFilenameOrg ) >= 0 );
  1634. else
  1635. bOK = (InstallCodetbl( pacfile, strFilenameOrg ) > 0 );
  1636. }
  1637. else if( bOK && CPackage::packageDay == pac.m_nType )
  1638. {
  1639. if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".stk" ) ) // 通用格式
  1640. bOK = ( InstallKDataTy( pacfile, CKData::ktypeDay, fnCallback, cookie ) > 0 );
  1641. else if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".dad" ) ) // 分析家格式
  1642. bOK = ( InstallKDataFxj( pacfile, CKData::ktypeDay, fnCallback, cookie ) > 0 );
  1643. else if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".txt" ) ) // 说明文件
  1644. bOK = TRUE;
  1645. else
  1646. bOK = FALSE;
  1647. }
  1648. else if( bOK && CPackage::packageMin5 == pac.m_nType )
  1649. {
  1650. if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".stk" ) ) // 通用格式
  1651. bOK = ( InstallKDataTy( pacfile, CKData::ktypeMin5, fnCallback, cookie ) > 0 );
  1652. else if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".dad" ) ) // 分析家格式
  1653. bOK = ( InstallKDataFxj( pacfile, CKData::ktypeMin5, fnCallback, cookie ) > 0 );
  1654. else if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".txt" ) ) // 说明文件
  1655. bOK = TRUE;
  1656. else
  1657. bOK = FALSE;
  1658. }
  1659. else if( bOK && CPackage::packageDR == pac.m_nType )
  1660. {
  1661. if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".dat" ) ) // 普通格式
  1662. bOK = ( InstallDRDataClk( pacfile, strFilenameOrg ) > 0 );
  1663. else if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".pwr" ) ) // 分析家除权格式
  1664. bOK = ( InstallDRDataFxj( pacfile ) > 0 );
  1665. else
  1666. bOK = FALSE;
  1667. }
  1668. else if( bOK && CPackage::packageBasetext == pac.m_nType )
  1669. {
  1670. if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".txt" ) ) // 文本资料
  1671. bOK = ( InstallBaseText( pacfile, strFilenameOrg ) > 0 );
  1672. else
  1673. bOK = FALSE;
  1674. }
  1675. else if( bOK && CPackage::packageBasetable == pac.m_nType )
  1676. {
  1677. if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".bst" ) ) // 财务格式
  1678. bOK = ( InstallBasetable( pacfile, strFilenameOrg ) > 0 );
  1679. else if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".dbf" ) ) // 通达信财务格式
  1680. bOK = ( InstallBasetableTdx( pacfile ) > 0 );
  1681. else if( 0 == strFilenameOrg.Right(4).CompareNoCase( ".fin" ) ) // 分析家财务格式
  1682. bOK = ( InstallBasetableFxj( pacfile ) > 0 );
  1683. else
  1684. bOK = FALSE;
  1685. }
  1686. else
  1687. bOK = FALSE;
  1689. if( !bOK )
  1690. {
  1691. CFileStatus rStatus;
  1692. if( ! (CFile::GetStatus( pacfile, rStatus ) && rStatus.m_size > 0) )
  1693. bOK = TRUE;
  1694. }
  1695. if( !bOK && fnCallback )
  1696. {
  1697. CString string = pac.m_strDescript;
  1698. fnCallback( PROG_ERRORPAC, 0, string.GetBuffer(string.GetLength()+1), cookie );
  1699. string.ReleaseBuffer();
  1700. }
  1701. return bOK;
  1702. }