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

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

金融证券系统

开发平台：

Visual C++

StkReceiver.cpp：源码内容
  2. #include "stdafx.h"
  3. #include "Stockdrv.h" // 通视卡数据结构定义
  4. #include "Tongshi.h" // 通视卡使用函数
  5. #include "STKDRVContainer.h"
  6. #include "StkReceiver.h"
  7. #include "SelectEngineDlg.h"
  9. static CNetSTKDRV gNetTSDLL;
  10. static CSTKDRVContainer gSTOCKDLL;
  12. CStkReceiver & AfxGetStkReceiver()
  13. {
  14. static CStkReceiver gStkReceiver;
  15. return gStkReceiver;
  16. }
  18. /////////////////////////////////////////////////////////////////////////////
  19. // CStkReceiver
  21. HANDLE CStkReceiver::m_hEventKillProcessThread = NULL;
  22. HANDLE CStkReceiver::m_hEventProcessThreadKilled = NULL;
  24. CCriticalSection g_mutexCommPacket;
  25. CPtrArray g_aptrCommPacket;
  27. // 处理接收到的Report数据的线程
  28. UINT StkProcessReceiveReport(LPVOID pParam)
  29. {
  30. while(TRUE)
  31. {
  32. COMMPACKET * pCommPacket = NULL;
  33. {
  34. CSingleLock lock(&g_mutexCommPacket,TRUE);
  35. if(g_aptrCommPacket.GetSize() > 0)
  36. {
  37. pCommPacket = (COMMPACKET *)g_aptrCommPacket.ElementAt(0);
  38. g_aptrCommPacket.RemoveAt(0);
  39. }
  40. }
  42. if(NULL != pCommPacket && CStock::dataReport == pCommPacket->m_dwDataType)
  43. {
  44. // 修改AfxGetStockContainer()
  45. for(DWORD i=0; i<pCommPacket->m_dwCount; i++)
  46. AfxGetStkReceiver().OnReceiveReport(&(pCommPacket->m_pReport[i]));
  48. // 保存至本地文件
  49. AfxGetDB().StoreReport(pCommPacket->m_pReport, pCommPacket->m_dwCount, FALSE);
  51. // 通知各股票信息显示窗口，刷新行情数据
  52. AfxGetStkReceiver().NotifyWndRcvData(CStock::dataReport, (LPARAM)pCommPacket);
  54. // 释放备份数据存储空间
  55. FreeCommPacket(pCommPacket);
  56. }
  58. Sleep(1);
  60. // User wants to quit program
  61. if(WAIT_OBJECT_0 == WaitForSingleObject(CStkReceiver::m_hEventKillProcessThread,0))
  62. {
  63. {
  64. CSingleLock lock(&g_mutexCommPacket,TRUE);
  65. for(int i=0; i<g_aptrCommPacket.GetSize(); i++)
  66. {
  67. pCommPacket = (COMMPACKET *)g_aptrCommPacket.ElementAt(i);
  68. FreeCommPacket(pCommPacket);
  69. }
  70. g_aptrCommPacket.RemoveAll();
  71. }
  72. SetEvent(CStkReceiver::m_hEventProcessThreadKilled);
  73. AfxEndThread(0, TRUE);
  74. return 0;
  75. }
  76. }
  77. }
  79. CStkReceiver::CStkReceiver()
  80. {
  81. m_bTongshiRunning = FALSE;
  82. }
  84. CStkReceiver::~CStkReceiver()
  85. {
  86. }
  88. BOOL CStkReceiver::CreateReceiver(CWnd * pParentWnd)
  89. {
  90. return CreateEx(0, NULL,"",WS_OVERLAPPEDWINDOW | WS_CHILDWINDOW, CRect(0,0,0,0), pParentWnd, 0, NULL);
  91. }
  93. void CStkReceiver::OnReceiveReport(REPORT * pReport)
  94. {
  95. CStockContainer & container = AfxGetStockContainer();
  96. REPORT reportLast;
  97. if(!UpdateStockContainerByREPORT(container, pReport, TRUE, &reportLast))
  98. return;
  100. CStockInfo infoCur;
  102. // 主力大单
  103. if(container.GetStockInfo(pReport->m_szCode, &infoCur, NULL))
  104. {
  105. if(0 != reportLast.m_time && reportLast.m_time < pReport->m_time
  106. && pReport->m_fVolume - reportLast.m_fVolume >= 100000
  107. && !infoCur.IsIndex() && !infoCur.IsBond() && !infoCur.IsFund() && !infoCur.IsBondIndex())
  108. {
  109. REPORT report;
  110. memcpy(&report, pReport, sizeof(report));
  111. report.m_fVolume = pReport->m_fVolume - infoCur.m_reportLatest.m_fVolume;
  112. report.m_fAmount = pReport->m_fAmount - infoCur.m_reportLatest.m_fAmount;
  113. AfxGetDB().StoreReport(&report, 1, TRUE);
  114. }
  115. }
  117. // 指数发生变化
  118. if(0 == strncmp(pReport->m_szCode, STKLIB_CODE_MAIN, sizeof(pReport->m_szCode))
  119. || 0 == strncmp(pReport->m_szCode, STKLIB_CODE_MAINSZN, sizeof(pReport->m_szCode)))
  120. {
  121. NotifyWndRcvAlarm(STKRCV_ALARM_REFRESH, 0);
  122. }
  124. // 盘中预警在此处加入
  125. if(AfxGetAlarmContainer().OnReceiveReport(&infoCur, pReport, &reportLast))
  126. {
  127. NotifyWndRcvAlarm(STKRCV_ALARM_WARNING, 0);
  128. }
  129. }
  131. void CStkReceiver::AddRcvAlarmWnd(HWND hWnd)
  132. {
  133. m_awndRcvAlarm.Add(hWnd);
  134. }
  136. BOOL CStkReceiver::RemoveRcvAlarmWnd(HWND hWnd)
  137. {
  138. for(int i=0; i<m_awndRcvAlarm.GetSize(); i++)
  139. {
  140. if(m_awndRcvAlarm.ElementAt(i) == hWnd)
  141. {
  142. m_awndRcvAlarm.RemoveAt(i,1);
  143. return TRUE;
  144. }
  145. }
  146. return FALSE;
  147. }
  149. void CStkReceiver::NotifyWndRcvAlarm(WPARAM wParam, LPARAM lParam)
  150. {
  151. for(int i=0; i<m_awndRcvAlarm.GetSize(); i++)
  152. ::PostMessage(m_awndRcvAlarm[i], WM_APP_STKRECEIVER_ALARM, wParam, lParam);
  153. }
  155. void CStkReceiver::AddRcvDataWnd(HWND hWnd)
  156. {
  157. m_awndRcvData.Add(hWnd);
  158. }
  160. BOOL CStkReceiver::RemoveRcvDataWnd(HWND hWnd)
  161. {
  162. for(int i=0; i<m_awndRcvData.GetSize(); i++)
  163. {
  164. if(m_awndRcvData.ElementAt(i) == hWnd)
  165. {
  166. m_awndRcvData.RemoveAt(i,1);
  167. return TRUE;
  168. }
  169. }
  170. return FALSE;
  171. }
  173. void CStkReceiver::NotifyWndRcvData(WPARAM wParam, LPARAM lParam)
  174. {
  175. for(int i=0; i<m_awndRcvData.GetSize(); i++)
  176. ::SendMessage(m_awndRcvData[i], WM_APP_STKRECEIVER_DATA , wParam, lParam);
  177. }
  181. BOOL CStkReceiver::NetEngineBeginWorking()
  182. {
  183. return SendMessage(WM_APP_STKRECEIVER_CONNECTSERVER);
  184. }
  186. BOOL CStkReceiver::NetEngineBeginWorking(LPCTSTR lpszAddress, UINT nPort, LPCTSTR lpszUser, LPCTSTR lpszPasswd)
  187. {
  188. if(gNetTSDLL.LoadDriver("NetTS.dll")
  189. && gNetTSDLL.Stock_Init_Nodialog(m_hWnd,WM_APP_STKRECEIVER_TSDATA,RCV_WORK_SENDMSG,
  190. lpszAddress,nPort,lpszUser,lpszPasswd) > 0)
  191. return TRUE;
  192. return FALSE;
  193. }
  195. BOOL CStkReceiver::NetEngineEndWorking()
  196. {
  197. return SendMessage(WM_APP_STKRECEIVER_DISCONNECTSERVER);
  198. }
  200. BOOL CStkReceiver::NetEngineIsWorking()
  201. {
  202. return gNetTSDLL.IsEngineWorking();
  203. }
  205. BOOL CStkReceiver::NetEngineSetAutoReport(int bAutoReport)
  206. {
  207. return gNetTSDLL.SetAutoReport(bAutoReport);
  208. }
  210. int CStkReceiver::RequestStockData(int nDataType/*CStock::DataType*/, CStockInfo * pStockInfo, int nSize, int nKType, int nDataCount)
  211. {
  212. int nDataTypeTS = DataType_to_TSDataType(nDataType);
  214. if(nSize < 0)
  215. return 0;
  217. STOCK_STRUCTEx * pStocks = new STOCK_STRUCTEx[nSize+1];
  218. memset(pStocks, 0, sizeof(STOCK_STRUCTEx)*(nSize+1));
  220. for(int i=0; i<nSize; i++)
  221. {
  222. pStocks[i].m_type = (BYTE)pStockInfo[i].GetType();
  223. strncpy(pStocks[i].m_code, pStockInfo[i].GetStockCode(), sizeof(pStocks[i].m_code));
  224. }
  225. int nRet = gNetTSDLL.RequestStockData(nDataTypeTS, pStocks, nSize, nKType, nDataCount);
  226. delete [] pStocks;
  227. return nRet;
  228. }
  230. int CStkReceiver::RequestKData(CStock *pstock, int period)
  231. {
  232. int nDataCount = 480;
  234. CStockInfo & info = pstock->GetStockInfo();
  235. CKData & kdata = pstock->GetKData(period);
  237. DWORD dateLatest = info.m_datebegin;
  238. if(kdata.GetSize() > 0)
  239. dateLatest = kdata.ElementAt(kdata.GetSize()-1).m_date;
  240. CSPTime tmLatest;
  241. tmLatest.FromStockTime(dateLatest, CKData::IsDayOrMin(period));
  242. CSPTime tmInitial = CStDatabase::GetTimeInitial();
  243. if(tmLatest < tmInitial)
  244. tmLatest = tmInitial;
  245. CSPTime tmNow = CSPTime::GetCurrentTime();
  246. CSPTimeSpan span = tmNow - tmLatest;
  247. switch(period)
  248. {
  249. case CKData::ktypeDay: nDataCount = span.GetDays()*5/7+1; break;
  250. case CKData::ktypeWeek: nDataCount = span.GetDays()/7+1; break;
  251. case CKData::ktypeMonth: nDataCount = span.GetDays()/30+1; break;
  252. default: ;
  253. }
  254. if(nDataCount < 100) nDataCount = 100;
  255. return RequestStockData(CStock::dataK, &info, 1, period, nDataCount);
  256. }
  258. BOOL CStkReceiver::EngineBeginWorking(BOOL bShowSelectEngineDialog)
  259. {
  260. return SendMessage(WM_APP_STKRECEIVER_INIT, !bShowSelectEngineDialog); // 启动通视接收系统
  261. }
  263. BOOL CStkReceiver::EngineSetup()
  264. {
  265. return SendMessage(WM_APP_STKRECEIVER_SETUP);
  266. }
  268. BOOL CStkReceiver::EngineEndWorking()
  269. {
  270. return SendMessage(WM_APP_STKRECEIVER_QUIT);
  271. }
  273. BOOL CStkReceiver::EngineIsWorking()
  274. {
  275. return m_bTongshiRunning;
  276. }
  278. int CStkReceiver::RefreshStockContainer(CStockContainer & container, BOOL bAddIfNotExist)
  279. {
  280. if(gNetTSDLL.IsEngineWorking() || gNetTSDLL.GetTotalNumber() > 0)
  281. {
  282. int nMaxNumber = gNetTSDLL.GetTotalNumber();
  283. ASSERT(nMaxNumber >= 0);
  284. if(nMaxNumber <= 0)
  285. return 0;
  287. int nNO = 0;
  288. while(TRUE)
  289. {
  290. RCV_REPORT_STRUCTEx tsreport;
  291. memset(&tsreport,0,sizeof(tsreport));
  292. int nRet = gNetTSDLL.GetStockByNoEx(nNO, &tsreport);
  293. if(nRet <= 0)
  294. break;
  295. REPORT report;
  296. if(convert_TSREPORT_to_REPORT(&tsreport, &report))
  297. UpdateStockContainerByREPORT(container, &report, bAddIfNotExist);
  299. nNO ++;
  300. }
  301. return nNO;
  302. }
  304. if(m_bTongshiRunning)
  305. {
  306. int nMaxNumber = gSTOCKDLL.GetTotalNumber();
  307. ASSERT(nMaxNumber >= 0);
  308. if(nMaxNumber <= 0)
  309. return 0;
  311. int nNO = 0;
  312. while(TRUE)
  313. {
  314. RCV_REPORT_STRUCTEx tsreport;
  315. memset(&tsreport,0,sizeof(tsreport));
  316. int nRet = gSTOCKDLL.GetStockByNoEx(nNO, &tsreport);
  317. if(nRet <= 0)
  318. break;
  319. REPORT report;
  320. if(convert_TSREPORT_to_REPORT(&tsreport, &report))
  321. UpdateStockContainerByREPORT(container, &report, bAddIfNotExist);
  323. nNO ++;
  324. }
  325. return nNO;
  326. }
  328. return 0;
  329. }
  331. int CStkReceiver::GetReport(CStockInfo &info, CReport &aReport)
  332. {
  333. if(m_bTongshiRunning)
  334. {
  335. int nMarket = SH_MARKET_EX;
  336. if(info.IsShangHai())
  337. nMarket = SH_MARKET_EX;
  338. else if(info.IsShenZhen())
  339. nMarket = SZ_MARKET_EX;
  340. RCV_REPORT_STRUCTEx tsreport;
  341. REPORT  report;
  342. int nRet = gSTOCKDLL.GetStockByCodeEx((char *)info.GetStockCode(), nMarket, &tsreport);
  343. if(nRet > 0 && 0 == strncmp(info.GetStockCode(),tsreport.m_szLabel,min(strlen(info.GetStockCode()),sizeof(tsreport.m_szLabel)))
  344. && convert_TSREPORT_to_REPORT(&tsreport, &report))
  345. {
  346. UpdateStockInfoByREPORT(info, &report);
  347. return 1;
  348. }
  349. }
  351. return 0;
  352. }
  354. BEGIN_MESSAGE_MAP(CStkReceiver, CWnd)
  355. ON_WM_CREATE()
  356. ON_WM_DESTROY()
  357. ON_MESSAGE(WM_APP_STKRECEIVER_CONNECTSERVER,OnStkReceiverConnectserver)
  358. ON_MESSAGE(WM_APP_STKRECEIVER_DISCONNECTSERVER,OnStkReceiverDisconnectserver)
  359. ON_MESSAGE(WM_APP_STKRECEIVER_INIT,OnStkReceiverInit)
  360. ON_MESSAGE(WM_APP_STKRECEIVER_SETUP,OnStkReceiverSetup)
  361. ON_MESSAGE(WM_APP_STKRECEIVER_QUIT,OnStkReceiverQuit)
  362. ON_MESSAGE(WM_APP_STKRECEIVER_TSDATA,OnStkReceiverTsdata)
  363. END_MESSAGE_MAP()
  365. /////////////////////////////////////////////////////////////////////////////
  366. // CStkReceiver message handlers
  368. int CStkReceiver::OnCreate(LPCREATESTRUCT lpCreateStruct)
  369. {
  370. if (CWnd::OnCreate(lpCreateStruct) == -1)
  371. return -1;
  373. CStkReceiver::m_hEventKillProcessThread = CreateEvent(NULL,FALSE,FALSE,NULL);
  374. CStkReceiver::m_hEventProcessThreadKilled = CreateEvent(NULL,FALSE,FALSE,NULL);
  376. AfxBeginThread(StkProcessReceiveReport, NULL, THREAD_PRIORITY_NORMAL);
  378. return 0;
  379. }
  381. void CStkReceiver::OnDestroy()
  382. {
  383. OnStkReceiverQuit(0, 0);
  384. OnStkReceiverDisconnectserver(0, 0);
  385. /*
  386. // These codes do not work well. system will terminate the thread auto, but cause some memory leaks
  387. if(CStkReceiver::m_hEventKillProcessThread)
  388. SetEvent(CStkReceiver::m_hEventKillProcessThread);
  390. if(WAIT_OBJECT_0 == WaitForSingleObject(CStkReceiver::m_hEventKillProcessThread,2000))
  391. {
  392. if(CStkReceiver::m_hEventKillProcessThread)
  393. CloseHandle(CStkReceiver::m_hEventKillProcessThread);
  394. if(CStkReceiver::m_hEventProcessThreadKilled)
  395. CloseHandle(CStkReceiver::m_hEventProcessThreadKilled);
  396. CStkReceiver::m_hEventKillProcessThread = NULL;
  397. CStkReceiver::m_hEventProcessThreadKilled = NULL;
  398. }
  399. */
  400. CWnd::OnDestroy();
  401. }
  403. LRESULT CStkReceiver::OnStkReceiverConnectserver(WPARAM wParam, LPARAM lParam)
  404. {
  405. if(gNetTSDLL.LoadDriver("NetTS.dll")
  406. && gNetTSDLL.Stock_Init(m_hWnd,WM_APP_STKRECEIVER_TSDATA,RCV_WORK_SENDMSG) > 0)
  407. return TRUE;
  409. return FALSE;
  410. }
  412. LRESULT CStkReceiver::OnStkReceiverDisconnectserver(WPARAM wParam, LPARAM lParam)
  413. {
  414. gNetTSDLL.Stock_Quit(m_hWnd);
  416. return TRUE;
  417. }
  419. LRESULT CStkReceiver::OnStkReceiverInit(WPARAM wParam, LPARAM lParam)
  420. {
  421. // 通视及兼容设备
  422. {
  423. CStringArray astrProvider, astrDriver;
  424. if(!wParam)
  425. {
  426. CSelectEngineDlg dlg;
  427. if(IDOK != dlg.DoModal())
  428. return -1L;
  429. dlg.GetSelectedDriver(astrProvider, astrDriver);
  430. }
  432. if(astrDriver.GetSize() <= 0)
  433. {
  434. CSPStringArray aProDefault, aDrvDefault;
  435. AfxGetProfile().GetRcvDriverDefault(aProDefault, aDrvDefault);
  436. for(int i=0; i<aProDefault.GetSize(); i++) astrProvider.Add(aProDefault[i]);
  437. for(i=0; i<aDrvDefault.GetSize(); i++) astrDriver.Add(aDrvDefault[i]);
  438. }
  440. if(astrDriver.GetSize() <= 0)
  441. {
  442. // AfxRegQueryString(HKEY_LOCAL_MACHINE, _T("Software"), _T("stockdrv"), _T("兼容设备"), astrProvider, astrDriver);
  443. astrProvider.InsertAt(0, AfxRegQueryString(HKEY_LOCAL_MACHINE, _T("Software"), _T("stockdrv"), "", "", _T("Provider"), "Tongshi"));
  444. astrDriver.InsertAt(0, AfxRegQueryString(HKEY_LOCAL_MACHINE, _T("Software"), _T("stockdrv"), "", "", _T("Driver"), "Stock.dll"));
  445. }
  447. // 数据共享引用
  448. gSTOCKDLL.Stock_Quit(m_hWnd);
  449. gSTOCKDLL.UnloadDriver();
  450. if(gSTOCKDLL.LoadDriver(astrDriver)
  451. && gSTOCKDLL.Stock_Init(m_hWnd,WM_APP_STKRECEIVER_TSDATA,RCV_WORK_SENDMSG) > 0)
  452. m_bTongshiRunning = TRUE;
  453. else if(!wParam)
  454. AfxMessageBox(AfxModuleLoadString(IDS_SELECTENGINE_ERRLOAD), MB_OK | MB_ICONINFORMATION);
  455. }
  457. return TRUE;
  458. }
  460. LRESULT CStkReceiver::OnStkReceiverSetup(WPARAM wParam, LPARAM lParam)
  461. {
  462. return gSTOCKDLL.SetupReceiver(TRUE);
  463. }
  465. LRESULT CStkReceiver::OnStkReceiverQuit(WPARAM wParam, LPARAM lParam)
  466. {
  467. gSTOCKDLL.Stock_Quit(m_hWnd);
  468. m_bTongshiRunning = FALSE;
  469. gSTOCKDLL.UnloadDriver();
  471. return TRUE;
  472. }
  474. // 通视处理数据
  475. LRESULT CStkReceiver::OnStkReceiverTsdata(
  476. UINT wFileType, // 文件类型, 参见 StockDrv.H
  477. LONG lPara)
  478. {
  479. int i = 0;
  480. PBYTE pFileBuf = NULL;
  481. PBYTE pBuffx = NULL;
  482. PGZLXBINDATA pGZLX = NULL;
  483. RCV_DATA * pHeader = (RCV_DATA *) lPara;
  485. // 检查参数
  486. ASSERT(pHeader && pHeader->m_pData);
  487. if(!pHeader || !pHeader->m_pData)
  488. return -1L;
  489. // ASSERT(pHeader->m_nPacketNum > 0 || pHeader->m_bDISK);
  490. if(pHeader->m_nPacketNum <= 0 && !pHeader->m_bDISK)
  491. return -1L;
  493. // 对于处理较慢的数据类型,建议将数据备份,另创建一线程处理
  494. switch(wFileType)
  495. {
  496. case RCV_REPORT:
  497. {
  498. // 检查参数
  499. ASSERT(pHeader->m_nPacketNum > 0 && !pHeader->m_bDISK);
  500. if(pHeader->m_nPacketNum <= 0 || pHeader->m_bDISK)
  501. return -1L;
  503. // 分配备份数据存储空间
  504. COMMPACKET * pCommPacket = AllocCommPacket(CStock::dataReport, pHeader->m_nPacketNum);
  505. if(NULL == pCommPacket)
  506. return -1L;
  508. // 修改AfxGetStockContainer()
  509. int nBufSize = pHeader->m_pReport[0].m_cbSize;
  510. PBYTE pBaseBuf = (PBYTE)&pHeader->m_pReport[0];
  511. for(i=0; i<pHeader->m_nPacketNum; i++)
  512. {
  513. PRCV_REPORT_STRUCTEx pReport = (PRCV_REPORT_STRUCTEx)(pBaseBuf + nBufSize*i);
  514. if(convert_TSREPORT_to_REPORT(pReport, &(pCommPacket->m_pReport[i])))
  515. {
  516. /* 以下代码转移到新建线程中执行 */
  517. // AfxGetStkReceiver().OnReceiveReport(&(pCommPacket->m_pReport[i]));
  518. }
  519. }
  521. {
  522. CSingleLock lock(&g_mutexCommPacket,TRUE);
  523. g_aptrCommPacket.Add(pCommPacket);
  524. }
  526. /* 以下代码转移到新建线程中执行
  527. // 保存至本地文件
  528. AfxGetDB().StoreReport(pCommPacket->m_pReport, pCommPacket->m_dwCount, FALSE);
  530. // 通知各股票信息显示窗口，刷新行情数据
  531. for(i=0; i<m_awndRcvData.GetSize(); i++)
  532. ::SendMessage(m_awndRcvData[i], WM_APP_STKRECEIVER_DATA, CStock::dataReport, (LPARAM)pCommPacket);
  534. // 释放备份数据存储空间
  535. FreeCommPacket(pCommPacket);
  536. */ 
  537. }
  538. break;
  540. case RCV_FILEDATA:
  541. switch(pHeader->m_wDataType)
  542. {
  543. case FILE_HISTORY_EX: // 补日线数据
  544. {
  545. RCV_HISTORY_STRUCTEx * pDay = pHeader->m_pDay;
  546. int nPacketNum = pHeader->m_nPacketNum;
  547. CKData kdata(CKData::ktypeDay);
  548. CString sCode;
  549. DWORD dwMarket = CStock::marketUnknown;
  551. // 读取文件
  552. if(pHeader->m_bDISK)
  553. {
  554. pDay = NULL;
  555. CFile file;
  556. if(file.Open(pHeader->m_File.m_szFileName,CFile::modeRead))
  557. {
  558. ASSERT(file.GetLength() == pHeader->m_File.m_dwLen);
  559. nPacketNum = (int)(file.GetLength()/sizeof(RCV_HISTORY_STRUCTEx));
  560. if(nPacketNum > 0)
  561. pDay = new RCV_HISTORY_STRUCTEx[nPacketNum];
  562. if(pDay)
  563. file.Read(pDay, sizeof(RCV_HISTORY_STRUCTEx)*nPacketNum);
  564. file.Close();
  565. }
  566. }
  568. // 分配备份数据存储空间
  569. COMMPACKET * pCommPacket = AllocCommPacket(CStock::dataK, nPacketNum);
  570. if(NULL == pCommPacket)
  571. return -1L;
  573. // 处理数据
  574. DWORD dwCount = 0;
  575. for(i=0; i<nPacketNum && pDay; i++)
  576. {
  577. if(pDay[i].m_head.m_dwHeadTag == EKE_HEAD_TAG)
  578. {
  579. if(kdata.GetSize() > 0)
  580. {
  581. kdata.AutoSetKType();
  582. UpdateStockContainerByKData(AfxGetStockContainer(), sCode, kdata);
  583. AfxGetDB().InstallKData(kdata);
  584. kdata.RemoveAll();
  585. }
  586. sCode = pDay[i].m_head.m_szLabel;
  587. dwMarket = TSMarket_to_Market(pDay[i].m_head.m_wMarket);
  588. continue;
  589. }
  590. convert_TSHISTORY_to_KDATA(dwMarket, sCode, &(pDay[i]), &(pCommPacket->m_pKdata[dwCount]));
  591. kdata.Add(pCommPacket->m_pKdata[dwCount]);
  592. dwCount ++;
  593. }
  594. pCommPacket->m_dwCount = dwCount;
  595. if(pHeader->m_bDISK && pDay)
  596. delete [] pDay;
  597. if(kdata.GetSize() > 0)
  598. {
  599. kdata.AutoSetKType();
  600. UpdateStockContainerByKData(AfxGetStockContainer(), sCode, kdata);
  601. AfxGetDB().InstallKData(kdata);
  602. }
  604. // 通知各股票信息显示窗口，刷新行情数据
  605. for(i=0; i<m_awndRcvData.GetSize(); i++)
  606. ::SendMessage(m_awndRcvData[i], WM_APP_STKRECEIVER_DATA, CStock::dataK, (LPARAM)pCommPacket);
  608. // 释放备份数据存储空间
  609. FreeCommPacket(pCommPacket);
  610. }
  611. break;
  613. case FILE_MINUTE_EX: // 补分钟线数据
  614. case 83: // 补分笔数据
  615. {
  616. RCV_MINUTE_STRUCTEx * pMin = pHeader->m_pMinute;
  617. ASSERT(pMin->m_head.m_dwHeadTag == EKE_HEAD_TAG);
  618. CMinute minute;
  619. BOOL bAutoSaveKDataMin = AfxGetProfile().GetAutoSaveKDataMin(); // 作为分钟K线保存
  620. CString sCode;
  621. DWORD dwMarket = CStock::marketUnknown;
  623. // 分配备份数据存储空间
  624. COMMPACKET * pCommPacket = AllocCommPacket(CStock::dataMinute, pHeader->m_nPacketNum);
  625. if(NULL == pCommPacket)
  626. return -1L;
  628. DWORD dwCount = 0;
  629. for(i=0; i<pHeader->m_nPacketNum; i++)
  630. {
  631. if(pMin[i].m_head.m_dwHeadTag == EKE_HEAD_TAG)
  632. {
  633. if(minute.GetSize() > 0)
  634. {
  635. CKData kdMin(CKData::ktypeMin5);
  636. if(minute.ToKData(kdMin))
  637. AfxGetDB().InstallKData(kdMin);
  638. minute.RemoveAll();
  639. }
  640. sCode = pMin[i].m_head.m_szLabel;
  641. dwMarket = TSMarket_to_Market(pMin[i].m_head.m_wMarket);
  642. continue;
  643. }
  644. convert_TSMINUTE_to_MINUTE(dwMarket, sCode, &(pMin[i]), &(pCommPacket->m_pMinute[dwCount]));
  645. if(bAutoSaveKDataMin)
  646. minute.Add(pCommPacket->m_pMinute[dwCount]);
  647. dwCount ++;
  648. }
  649. pCommPacket->m_dwCount = dwCount;
  650. if(minute.GetSize() > 0)
  651. {
  652. CKData kdMin(CKData::ktypeMin5);
  653. if(minute.ToKData(kdMin))
  654. AfxGetDB().InstallKData(kdMin);
  655. }
  657. // 保存至本地文件
  658. AfxGetDB().StoreMinute(pCommPacket->m_pMinute, pCommPacket->m_dwCount);
  660. // 通知各股票信息显示窗口，刷新行情数据
  661. for(i=0; i<m_awndRcvData.GetSize(); i++)
  662. ::SendMessage(m_awndRcvData[i], WM_APP_STKRECEIVER_DATA, CStock::dataMinute, (LPARAM)pCommPacket);
  664. // 释放备份数据存储空间
  665. FreeCommPacket(pCommPacket);
  666. }
  667. break;
  669. case FILE_POWER_EX: // 补充除权数据
  670. {
  671. RCV_POWER_STRUCTEx * pPower = pHeader->m_pPower;
  672. int nPacketNum = pHeader->m_nPacketNum;
  673. CDRData drdata;
  674. CString sCode;
  675. DWORD dwMarket = CStock::marketUnknown;
  677. if(pHeader->m_bDISK)
  678. {
  679. pPower = NULL;
  680. CFile file;
  681. if(file.Open(pHeader->m_File.m_szFileName,CFile::modeRead))
  682. {
  683. ASSERT(file.GetLength() == pHeader->m_File.m_dwLen);
  684. nPacketNum = (int)(file.GetLength()/sizeof(RCV_POWER_STRUCTEx));
  685. if(nPacketNum > 0)
  686. pPower = new RCV_POWER_STRUCTEx[nPacketNum];
  687. if(pPower)
  688. file.Read(pPower, sizeof(RCV_POWER_STRUCTEx)*nPacketNum);
  689. file.Close();
  690. }
  691. }
  693. // 分配备份数据存储空间
  694. COMMPACKET * pCommPacket = AllocCommPacket(CStock::dataDR, nPacketNum);
  695. if(NULL == pCommPacket)
  696. return -1L;
  698. DWORD dwCount = 0;
  699. for(i=0; i<nPacketNum && pPower; i++)
  700. {
  701. if(pPower[i].m_head.m_dwHeadTag == EKE_HEAD_TAG)
  702. {
  703. if(drdata.GetSize() > 0)
  704. AfxGetDB().InstallDRData(drdata);
  705. drdata.RemoveAll();
  706. sCode = pPower[i].m_head.m_szLabel;
  707. dwMarket = TSMarket_to_Market(pPower[i].m_head.m_wMarket);
  708. continue;
  709. }
  710. convert_TSPOWER_to_DRDATA(dwMarket, sCode, &(pPower[i]), &(pCommPacket->m_pDrdata[dwCount]));
  711. drdata.Add(pCommPacket->m_pDrdata[dwCount]);
  712. dwCount ++;
  713. }
  714. if(pHeader->m_bDISK && pPower)
  715. delete [] pPower;
  716. if(drdata.GetSize() > 0)
  717. AfxGetDB().InstallDRData(drdata);
  718. pCommPacket->m_dwCount = dwCount;
  720. // 通知各股票信息显示窗口，刷新行情数据
  721. for(i=0; i<m_awndRcvData.GetSize(); i++)
  722. ::SendMessage(m_awndRcvData[i], WM_APP_STKRECEIVER_DATA, CStock::dataDR, (LPARAM)pCommPacket);
  724. // 释放备份数据存储空间
  725. FreeCommPacket(pCommPacket);
  726. }
  727. break;
  729. case FILE_MULTISORT_EX: // 综合排名
  730. {
  731. RCV_MULTISORT_STRUCTEx * pMultisort = pHeader->m_pMultisort;
  733. // 分配备份数据存储空间
  734. COMMPACKET * pCommPacket = AllocCommPacket(CStock::dataMultisort, pHeader->m_nPacketNum);
  735. if(NULL == pCommPacket)
  736. return -1L;
  738. for(i=0; i<pHeader->m_nPacketNum; i++)
  739. {
  740. convert_TSMULTISORT_to_MULTISORT(&(pMultisort[i]), &(pCommPacket->m_pMultisort[i]));
  741. }
  742. pCommPacket->m_dwCount = pHeader->m_nPacketNum;
  744. // 通知各股票信息显示窗口，刷新行情数据
  745. for(i=0; i<m_awndRcvData.GetSize(); i++)
  746. ::SendMessage(m_awndRcvData[i], WM_APP_STKRECEIVER_DATA, CStock::dataMultisort, (LPARAM)pCommPacket);
  748. // 释放备份数据存储空间
  749. FreeCommPacket(pCommPacket);
  750. }
  751. break;
  753. case FILE_BASE_EX: // 钱龙兼容基本资料文件,m_szFileName仅包含文件名
  754. {
  755. if(pHeader->m_bDISK)
  756. {
  757. AfxGetDB().InstallBaseText(pHeader->m_File.m_szFileName, AfxGetFileTitle(pHeader->m_File.m_szFileName));
  758. }
  759. else
  760. {
  761. AfxGetDB().InstallBaseText(LPCTSTR(pHeader->m_pData), pHeader->m_File.m_dwLen, AfxGetFileTitle(pHeader->m_File.m_szFileName));
  762. }
  764. // 分配备份数据存储空间
  765. COMMPACKET * pCommPacket = AllocCommPacket(CStock::dataCode, 1);
  766. if(NULL == pCommPacket)
  767. return -1L;
  768. CString sTemp = AfxGetFileTitleNoExt(pHeader->m_File.m_szFileName);
  769. strncpy(pCommPacket->m_pStockcode[0].m_szCode, sTemp, min(sizeof(pCommPacket->m_pStockcode[0].m_szCode)-1,sTemp.GetLength()));
  770. pCommPacket->m_pStockcode[0].m_dwMarket = CStock::marketUnknown;
  772. // 通知各股票信息显示窗口，刷新行情数据
  773. for(i=0; i<m_awndRcvData.GetSize(); i++)
  774. ::SendMessage(m_awndRcvData[i], WM_APP_STKRECEIVER_DATA, CStock::dataBasetext, (LPARAM)pCommPacket);
  776. // 释放备份数据存储空间
  777. FreeCommPacket(pCommPacket);
  778. }
  779. break;
  781. case FILE_NEWS_EX: // 新闻类,其类型由m_szFileName中子目录名来定
  782. if(pHeader->m_bDISK)
  783. {
  784. AfxGetDB().InstallNewsText(pHeader->m_File.m_szFileName, AfxGetFileTitle(pHeader->m_File.m_szFileName));
  785. }
  786. else
  787. {
  788. AfxGetDB().InstallNewsText(LPCTSTR(pHeader->m_pData), pHeader->m_File.m_dwLen, AfxGetFileTitle(pHeader->m_File.m_szFileName));
  789. }
  790. // 通知各股票信息显示窗口，刷新行情数据
  791. for(i=0; i<m_awndRcvData.GetSize(); i++)
  792. ::SendMessage(m_awndRcvData[i], WM_APP_STKRECEIVER_DATA, CStock::dataNews, NULL);
  793. break;
  795. case FILE_HTML_EX: // HTML文件,m_szFileName为URL
  796. AfxGetProfile().AddHTMLURLToExplorer(pHeader->m_File.m_szFileName);
  797. break;
  799. case FILE_SOFTWARE_EX:
  800. TRACE("%sn",pHeader->m_File.m_szFileName);
  801. TRACE("%dn",pHeader->m_File.m_dwLen);
  802. pBuffx = (PBYTE)pHeader->m_pData;
  803. break;
  805. case FILE_SHAZQDATA_EX: //h上海国债净价交易
  806. break;
  807. case FILE_TYPE_RES:
  808. TRACE("MSG: CStkReceiver::OnStkDataOK, Replaced data n");
  809. break;
  810. default:
  811. TRACE("Msg: CStkReceiver::OnStkReceiverData,Unkonw data typen");
  812. }
  813. break;
  814. }
  816. return 0L;
  817. }