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

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

金融证券系统

开发平台：

Visual C++

Database.h：源码内容
  1. /*
  2. Cross Platform Core Code.
  4. Copyright(R) 2001-2002 Balang Software.
  5. All rights reserved.
  7. Using:
  8. class CStdatabase;
  9. */
  11. #if !defined( __STKLIB_DATABASE_H__ )
  12. #define __STKLIB_DATABASE_H__
  14. #include "StdAfx.h"
  15. #include "Stock.h"
  17. #define MAX_DATATYPENAME 128
  19. class CDBType
  20. {
  21. public:
  22. CDBType( );
  24. int type;
  25. char name[MAX_DATATYPENAME];
  26. };
  28. #pragma pack(1)
  30. ////////////////////////////////////////////////////////////////////
  31. // 通用数据包的数据结构(*.STK)
  32. typedef struct tyday_fheader {
  33. char magic;
  34. char code[6];
  35. char magic2;
  36. char name[8];
  37. DWORD date; //日期
  38. DWORD datebegin; //起始日期
  39. DWORD dateend; //终止日期
  40. DWORD gendate; //生成日期
  41. DWORD gentime; //生成时间
  42. DWORD from; //来源
  43. DWORD sharecount; //股票数
  44. DWORD recordcount;//记录数
  45. }TYDAY_FHEADER;
  47. typedef struct tyday_record {
  48. char magic;
  49. char code[6];
  50. char magic2;
  51. char name[8];
  52. DWORD date; //日期
  53. DWORD open; //开盘(元/1000)
  54. DWORD high; //最高价(元/1000)
  55. DWORD low; //最低价(元/1000)
  56. DWORD close; //收盘(元/1000)
  57. DWORD amount; //成交额(千元)
  58. DWORD volume; //成交量(手)
  59. DWORD serial; //记录序号
  60. }TYDAY_RECORD;
  62. ////////////////////////////////////////////////////////////////////
  63. // 分析家数据包的数据结构(*.DAD)
  64. #define FXJDAY_FHEADER_MAGIC 0x8C19FC33
  65. typedef struct fxjday_fheader {
  66. DWORD m_dwMagic; // 33 FC 19 8C，老版本的Magic
  67. DWORD m_dwUnknown; // 未知
  68. DWORD m_dwStockCount; // 为本文件的股票数
  69. DWORD m_dwReserved; // = 0
  70. }FXJDAY_FHEADER;
  72. typedef union fxjday_record {
  73. struct
  74. {
  75. DWORD m_dwMagic; // = -1
  76. WORD m_wMarket; // 市场 SH, SZ
  77. char m_szCode[6];
  78. DWORD m_dwReserved[5];
  79. };
  80. struct
  81. {
  82. time_t m_time; //日期
  83. float open; //开盘(元/1000)
  84. float high; //最高价(元/1000)
  85. float low; //最低价(元/1000)
  86. float close; //收盘(元/1000)
  87. float volume; //成交量(手)
  88. float amount; //成交额(元)
  89. float reserved; //
  90. };
  91. }FXJDAY_RECORD;
  93. #pragma pack()
  95. BOOL convert_TYDAY_RECORD_to_KDATA( TYDAY_RECORD * precord, KDATA * pkd );
  96. BOOL convert_TYDAY_RECORD_MIN_to_KDATA( TYDAY_RECORD * precord, KDATA * pkd );
  97. BOOL convert_KDATA_to_TYDAY_RECORD( DWORD dwSerial, const char * name, KDATA * pkd, TYDAY_RECORD * precord );
  98. BOOL convert_KDATA_to_TYDAY_RECORD_MIN( DWORD dwSerial, const char * name, KDATA * pkd, TYDAY_RECORD * precord );
  100. BOOL convert_FXJDAY_RECORD_to_KDATA( DWORD dwMarket, LPCTSTR lpszCode, int nKType, FXJDAY_RECORD *precord, KDATA *pkd );
  102. typedef BOOL (CALLBACK* PROGRESS_CALLBACK)(DWORD dwCode, DWORD dwProgress, LPCTSTR lpszMsg, VOID * cookie);
  104. #define PROG_PROGRESS 1
  105. #define STKLIB_MAX_PROGRESS 10000
  106. #define STKLIB_MAXF_PROGRESS 10000.
  108. class CStockContainer;
  110. /***
  111. 读取K线数据的通用接口，各种格式的读取K线数据类必须从此类继承
  112. */
  113. class IStStore
  114. {
  115. public:
  116. enum DBTypes { // 数据格式类型，目前只支持typeSelfDB（自有格式）和typeQianlong（钱龙格式）
  117. dbtypeUnknown = 0x01,
  118. dbtypeSelfDB = 0x02,
  119. dbtypeQianlong = 0x03,
  120. dbtypeShenglong = 0x04,
  121. };
  123. static BOOL IsValidDataType( int nType );
  124. static int GetSupportedDataType ( CDBType * pdbtype, int maxsize );
  125. static IStStore * CreateStore( const char * rootpath, int nDBType = dbtypeUnknown ); // 给出根目录和类型，新建一个对象
  127. virtual int IsOK( ) { return m_bIsOK; }
  128. virtual const char * GetRootPath( ); // 得到当前对象的根目录
  130. virtual int GetDBType( ) = 0; // 得到当前对象的数据类型
  131. virtual const char * GetDBTypeName( ) = 0; // 得到当前对象的数据类型名称
  132. virtual int GetMaxStockNumber( ) = 0; // 得到股票数量
  133. virtual int LoadCodetable( CStockContainer & container ) = 0; // 读取所有股票的信息
  134. virtual int StoreCodetable( CStockContainer & container ) = 0; // 保存代码表
  135. virtual int LoadKDataCache( CStockContainer & container, PROGRESS_CALLBACK fnCallback, void *cookie, int nProgStart, int nProgEnd ) = 0; // 读取所有股票的最近日线数据缓冲
  136. virtual int LoadBasetable( CStockContainer & container ) = 0; // 读取某一股票的财务资料表，包括每股收益，每股净资产等，见CBaseData
  137. virtual int StoreBasetable( CStockContainer & container ) = 0; // 保存某一股票的财务资料表
  138. virtual int LoadBaseText( CStock *pstock ) = 0; // 读取某一股票的基本资料文本
  139. virtual int LoadKData( CStock *pstock, int nKType ) = 0; // 读取某一股票的某个周期的K线数据
  140. virtual int LoadDRData( CStock *pstock ) = 0; // 读取某一股票的除权除息资料
  141. virtual int StoreDRData( CStock *pstock ) = 0; // 保存某一股票的除权除息资料
  142. virtual int LoadReport( CStock *pstock ) = 0; // 读取某一股票的行情刷新数据
  143. virtual int LoadMinute( CStock *pstock ) = 0; // 读取某一股票的行情分时数据
  144. virtual int LoadOutline( CStock *pstock ) = 0; // 读取某一股票的行情额外数据
  145. virtual int StoreReport( REPORT * pReport, int nCount, BOOL bBigTrade ) = 0; // 保存行情刷新数据
  146. virtual int StoreMinute( MINUTE * pMinute, int nCount ) = 0; // 保存行情分时数据
  147. virtual int StoreOutline( OUTLINE * pOutline, int nCount ) = 0; // 保存行情分时数据
  150. virtual int InstallCodetbl( const char * filename, const char *orgname ) = 0; // 安装下载的代码表
  151. virtual int InstallCodetblBlock( const char * filename, const char *orgname ) = 0; // 安装下载的板块表
  152. virtual int InstallCodetblFxjBlock( const char * filename, const char *orgname ) = 0; // 安装下载的分析家板块表
  153. virtual int InstallKData( CKData & kdata, BOOL bOverwrite = FALSE ) = 0; // 安装K线数据
  154. virtual int InstallKDataTy( const char * stkfile, int nKType, PROGRESS_CALLBACK fnCallback, void *cookie ) = 0; // 安装下载的K线通用格式数据包
  155. virtual int InstallKDataFxj( const char * dadfile, int nKType, PROGRESS_CALLBACK fnCallback, void *cookie ) = 0; // 安装下载的K线分析家格式通用数据包
  156. virtual int InstallDRData( CDRData & drdata ) = 0; // 安装除权除息数据
  157. virtual int InstallDRDataClk( const char * filename, const char *orgname ) = 0; // 安装下载的除权除息数据，一只股票一个文件
  158. virtual int InstallDRDataFxj( const char * fxjfilename ) = 0; // 安装分析家除权除息数据
  159. virtual int InstallBasetable( const char * filename, const char *orgname ) = 0; // 安装财务数据
  160. virtual int InstallBasetableTdx( const char * filename ) = 0; // 安装通达信财务数据
  161. virtual int InstallBasetableFxj( const char * filename ) = 0; // 安装分析家财务数据
  162. virtual int InstallBaseText( const char * filename, const char *orgname ) = 0; // 安装下载的基本资料数据，一只股票一个文件
  163. virtual int InstallBaseText( const char * buffer, int nLen, const char *orgname ) = 0; // 安装基本资料数据
  164. virtual int InstallNewsText( const char * filename, const char *orgname ) = 0; // 安装新闻数据文件
  165. virtual int InstallNewsText( const char * buffer, int nLen, const char *orgname ) = 0; // 安装新闻数据
  167. virtual BOOL GetFileName( CSPString &sFileName, int nDataType,
  168. CStockInfo * pInfo = NULL, int nKType = CKData::ktypeDay ) = 0; // 得到某种数据的文件名称
  169. protected:
  170. BOOL m_bIsOK;
  171. char m_szRootPath[1024];
  172. };
  174. #define ERR_DB_MAX 1000
  176. /***
  177. 本地数据类，提供对磁盘数据的操作接口，包括股票信息，各种周期K线数据，基本
  178. 资料，权息资料的读取和安装。
  180. 使用方法如下：
  181. CStDatabase::CreateSelfDB( "./" );
  183. CStDatabase db;
  184. db.SetRootPath( "./", IStStore::dbtypeSelfDB );
  186. CStockContainer container;
  187. nLen = db.LoadCodetable( container );
  188. db.LoadBasetable( container );
  189. db.LoadKDataCache( container, NULL, NULL, 0, 0 );
  191. CStock stock;
  192. stock.SetDatabase( &db );
  193. stock.PrepareData( CStock::dataK, CKData::ktypeDay );
  194. stock.PrepareData( CStock::dataDR );
  195. stock.PrepareData( CStock::dataK, m_nCurKType );
  196. CStockInfo & info = stock.GetStockInfo();
  197. CKData & kday = stock.GetKDataDay();
  198. CKData & kdata = stock.GetKData(m_nCurKType);
  199. kday.SetDRData( stock.GetDRData() );
  200. kday.ChangeCurFormat( CKData::formatXDRdown, AfxGetProfile().GetAutoResumeDRBegin(), AfxGetProfile().GetAutoResumeDRLimit() );
  202. 注意：使用CStDatabase的子类CNetDatabase也可以实现上述功能，并且提供的功能
  203. 更多，使用方法相同。
  204. */
  205. class CStDatabase : public Object
  206. {
  207. public:
  208. // Constructors
  209. CStDatabase();
  210. virtual ~CStDatabase();
  212. // Flag values
  214. // Attributes
  216. // Operations
  217. static BOOL CreateSelfDB( const char * rootpath ); // 创建所需目录
  218. static BOOL IsValidDataType( int nType ); // 类型是否合法
  219. static int GetSupportedDataType ( CDBType * pdbtype, int maxsize ); // 得到支持的数据类型
  220. BOOL SetRootPath( const char * rootpath, int nDBType = IStStore::dbtypeUnknown ); // 设定数据目录
  222. BOOL IsOK( ); // 数据目录是否符合
  223. const char * GetRootPath( ); // 得到数据目录
  224. int GetDBType( ); // 得到数据类型
  225. const char * GetDBTypeName( ); // 得到数据类型名称
  227. virtual DWORD GetSelfTempPath( char *szTempPath, int size ); // 得到临时目录
  229. virtual BOOL GetLastErrorMessage(LPTSTR lpszError, UINT nMaxError); // 得到最近错误
  230. virtual int GetMaxStockNumber( ); // 得到股票数量
  231. virtual int LoadCodetable( CStockContainer &container ); // 读取所有股票的信息
  232. virtual int StoreCodetable( CStockContainer & container ); // 保存代码表
  233. virtual int LoadKDataCache( CStockContainer &container, PROGRESS_CALLBACK fnCallback, void *cookie, int nProgStart, int nProgEnd ); // 读取所有股票的最近日线数据缓冲
  234. virtual int LoadBasetable( CStockContainer & container ); // 读取某一股票的财务资料表，包括每股收益，每股净资产等，见CBaseData
  235. virtual int StoreBasetable( CStockContainer & container ); // 保存某一股票的财务资料表
  236. virtual int LoadBaseText( CStock *pstock ); // 读取某一股票的基本资料文本
  237. virtual int LoadKData( CStock *pstock, int nKType ); // 读取某一股票的某个周期的K线数据
  238. virtual int LoadDRData( CStock *pstock ); // 读取某一股票的除权除息资料
  239. virtual int StoreDRData( CStock *pstock ); // 保存某一股票的除权除息资料
  240. virtual int LoadReport( CStock *pstock ); // 读取某一股票的行情刷新数据
  241. virtual int LoadMinute( CStock *pstock ); // 读取某一股票的行情分时数据
  242. virtual int LoadOutline( CStock *pstock ); // 读取某一股票的行情额外数据
  243. virtual int StoreReport( REPORT * pReport, int nCount, BOOL bBigTrade ); // 保存行情刷新数据
  244. virtual int StoreMinute( MINUTE * pMinute, int nCount ); // 保存行情分时数据
  245. virtual int StoreOutline( OUTLINE * pOutline, int nCount ); // 保存行情分时数据
  247. virtual int InstallCodetbl( const char * filename, const char *orgname ); // 安装下载的代码表
  248. virtual int InstallCodetblBlock( const char * filename, const char *orgname ); // 安装下载的板块表
  249. virtual int InstallCodetblFxjBlock( const char * filename, const char *orgname ); // 安装下载的分析家板块表
  250. virtual int InstallKData( CKData & kdata, BOOL bOverwrite = FALSE ); // 安装K线数据
  251. virtual int InstallKDataTy( const char * stkfile, int nKType, PROGRESS_CALLBACK fnCallback, void *cookie ); // 安装下载的K线通用格式数据
  252. virtual int InstallKDataFxj( const char * dadfile, int nKType, PROGRESS_CALLBACK fnCallback, void *cookie ); // 安装下载的K线分析家格式数据
  253. virtual int InstallDRData( CDRData & drdata ); // 安装除权除息数据
  254. virtual int InstallDRDataClk( const char * filename, const char *orgname ); // 安装下载的除权除息数据，一只股票一个文件
  255. virtual int InstallDRDataFxj( const char * fxjfilename ); // 安装分析家除权除息数据
  256. virtual int InstallBasetable( const char * filename, const char *orgname ); // 安装财务数据
  257. virtual int InstallBasetableTdx( const char * filename ); // 安装通达信财务数据
  258. virtual int InstallBasetableFxj( const char * filename ); // 安装分析家财务数据
  259. virtual int InstallBaseText( const char * filename, const char *orgname ); // 安装下载的基本资料数据，一只股票一个文件
  260. virtual int InstallBaseText( const char * buffer, int nLen, const char *orgname ); // 安装基本资料数据
  261. virtual int InstallNewsText( const char * filename, const char *orgname ); // 安装新闻数据文件
  262. virtual int InstallNewsText( const char * buffer, int nLen, const char *orgname ); // 安装新闻数据
  265. // assistant operation
  266. BOOL AddAssistantRootPath( const char * rootpath, int nDBType = IStStore::dbtypeUnknown ); // 指定另外一个附加数据源的目录，自动读取
  267. void RemoveAssistant( const char * rootpath ); // 移除另外一个附加数据源目录
  268. void RemoveAllAssistant(  ); // 移除所有附加数据源目录
  270. static CSPTime GetTimeInitial( ); // 得到初始数据日期
  271. BOOL GetTimeLocalRange( CSPTime *ptmLatest, CSPTime * ptmPioneer, CSPTime * ptmInitial ); // 得到本地数据日期区间
  272. BOOL GetNeedDownloadRange( CStockInfo &info, CSPTime tmBegin, CSPTime tmEnd, CSPTime &tmDLBegin, CSPTime &tmDLEnd ); // 得到需要下载的数据日期区间
  274. // 将钱龙格式K线数据 加入 通用数据包
  275. static int AppendToTyData( const char *code, const char *name, int nKType, LPCTSTR lpszKFile, LPCTSTR lpszTyDataFile, time_t tmBegin, time_t tmEnd );
  277. protected:
  278. IStStore * m_pStore;
  279. CSPPtrArray m_aptrAssistant;
  280. };
  282. #endif //__STKLIB_DATABASE_H__