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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 金融证券系统 > 查看源码
CL_HQ.C
资源名称：inet_stock.zip　[点击查看]
上传用户：bjghjy
上传日期：2007-01-07
资源大小：379k
文件大小：49k
源码类别：

金融证券系统

开发平台：

Visual C++

CL_HQ.C：源码内容
  1. #include <windows.h>
  2. #include <windowsx.h>
  3. #include <stdio.h>
  4. #include <string.h>
  5. #include <stdlib.h>
  6. #include <io.h>
  7. #include <sysstat.h>
  8. #include <share.h>
  9. #include <fcntl.h>
  10. #include <time.h>
  12. #include "main.h"
  13. #include "hq.h"
  14. #include "sv_hq.h"
  16. #include "dbf_data.h"
  17. #include "data.h"
  19. #include "cl_hq.h"
  20. #include "cl_data.h"
  21.                               
  22. DBF_DATA HqkData[2], GpkData[2], SzZskData, SzMmpkData;
  23. ZX_DATA ZxData;
  26. extern void DelSpaces(LPSTR);
  28. extern BOOL clGetInitString(LPSTR, LPSTR, LPSTR);
  29. extern void clPutInitString(LPSTR, LPSTR, LPSTR);
  31. extern int GetInitInt(LPSTR, LPSTR);
  33. extern int UDPBlockingHook(void);
  35. extern BOOL run_cancelled;
  36. extern BOOL gfIsNewsSrcDel;
  38. extern int date_num,tim;
  39. extern char *HqItems[];
  41. LPDBF_DATA lpDbfDatas[]={&HqkData[0], &HqkData[1],
  42. &GpkData[0],/* &GpkData[1],*/
  43. &SzZskData,
  44. &SzMmpkData,NULL};
  46. LPDBF_DATA  lpDbfFile[2][5] ={
  47. {&HqkData[0],&GpkData[0],&SzZskData,&SzMmpkData,NULL},
  48. {&HqkData[1],NULL,       NULL,      NULL,       NULL}
  49. };
  51. long oldDpCjss2[2][20];
  52. int gnHqRefreshTime =5;
  53. int Skip = -1,Idel;
  54.   
  55. int clHqInit(void)
  56. {
  57. int i, jys;
  58. char tmp[256], temp[256];
  59. OFSTRUCT os;
  61. memset(&oldDpCjss2, 0, sizeof(oldDpCjss2));
  62. memset(&zs_times, 0, sizeof(zs_times));
  64. if(GetInitString("HQ", "RUN", tmp))
  65. {
  66. if(tmp[0]=='N')
  67. {
  68. HqIsRun=FALSE;
  69. return 0;
  70. }
  71. }
  73. for(i =0; i<2; i++)
  74. {
  75. memset(&HqData[i], 0, sizeof(HqData[i]));
  76. memset(&MmpData[i], 0, sizeof(MmpData[i]));
  77. memset(&HqTime[i], 0, sizeof(HqTime[i]));
  78. memset(&GraphData[i], 0, sizeof(GraphData[i]));
  79. memset(&DpData[i], 0, sizeof(DpData[i]));
  80. hfHq[i] =HFILE_ERROR;
  81. hfMmp[i] =HFILE_ERROR;
  82. hfMaxMin[i] =HFILE_ERROR;
  83. }
  84. hfDp =HFILE_ERROR;
  86. //初始化广告和新闻
  87. memset(&ZxData, 0, sizeof(ZxData));
  88. if(!GetInitString("ZX", "FILE0", ZxDataFile))
  89. {
  90. ErrMsg(ghWndMain, "get zx init failed!");
  91. PutInitString("ZX", "FILE0", "");
  92. return -1;
  93. }
  94. strupr(ZxDataFile);
  95. hfZx =OpenFile(ZxDataFile, &os, OF_SHARE_DENY_NONE|OF_READ);
  96. if(hfZx ==HFILE_ERROR)
  97. {
  98. ErrMsg(ghWndMain, "open zx file failed");
  99. return -1;
  100. }
  102. szNewsPath[0] =0;
  103. if(!GetInitString("NEWS", "DIR", szNewsPath))
  104. {
  105. ErrMsg(ghWndMain, "get news init failed!");
  106. PutInitString("NEWS", "DIR", "");
  107. }
  109. szNewsSrc[0] =0;
  110. if(!GetInitString("NEWS", "SRC", szNewsSrc))
  111. {
  112. ErrMsg(ghWndMain, "get news init failed!");
  113. PutInitString("NEWS", "SRC", "");
  114. }
  115. if(GetInitString("NEWS", "DELSRC", tmp))
  116. {
  117. if(tmp[0]=='Y')
  118. gfIsNewsSrcDel =TRUE;
  119. else
  120. gfIsNewsSrcDel =FALSE;
  121. }
  122. else
  123. gfIsNewsSrcDel =FALSE;
  125. i=0;
  126. while(HqItems[i])
  127. {
  128. memset(lpDbfDatas[i], 0, sizeof(DBF_DATA));
  129. lpDbfDatas[i]->hf =-1;
  130. i++;
  131. }
  133.     memset(tmp,0,sizeof(tmp));
  134. if(clGetInitString("GLOBAL", "IDEL", tmp))
  135. {
  136. Idel= atoi(tmp);
  137. }
  138. else
  139. {
  140. clPutInitString("GLOBAL", "IDEL", "0");
  141. Idel=10;
  142. }
  144. //设置开闭市时间
  145. for(jys =0; jys <2; jys++)
  146. {
  147. for(i =0; i<4; i++)
  148. {
  149. if(!GetInitString("TIME", HqTimeItems[i+4*jys], tmp))
  150. {
  151. strcpy(tmp, HqTimeDefs[i+4*jys]);
  152. PutInitString("TIME", HqTimeItems[i+4*jys], tmp);
  153. }
  154. else
  155. {
  156. if(strlen(tmp) > 12 || strlen(tmp) <3)
  157. {
  158. ErrMsg(ghWndMain, "time set error!");
  159. return -1;
  160. }
  161. }
  162. *lpHqTimes[i+4*jys] =atoi(strtok(tmp, ":"))*60;
  163. *lpHqTimes[i+4*jys] +=atoi(strtok(NULL, ":"));
  164. }
  166. }
  167.     
  168.     //初始化DBF文件
  169. i =0;
  170. while(HqItems[i])
  171. {
  172. if(!clGetInitString("DBF", HqItems[i], tmp))
  173. {
  174. wsprintf(temp, "can not find %s:n %s",
  175. (LPSTR)HqItems[i], (LPSTR)tmp);
  176. ErrMsg(ghWndMain, temp);
  177. clPutInitString("DBF", HqItems[i], NULL);
  178. return -1;
  179. }
  181. if(access(tmp,_S_IREAD) <0)
  182. {
  183. wsprintf(temp, "can not read %s:n %s",
  184. (LPSTR)HqItems[i], (LPSTR)tmp);
  185. ErrMsg(ghWndMain, temp);
  186. return -1;
  187. }  
  188. lpDbfDatas[i]->hf=OpenDbfBase(tmp,OF_READ);
  189. if (lpDbfDatas[i]->hf==-1)
  190. {
  191. wsprintf(temp, "can not open %s:n %s",
  192. (LPSTR)HqItems[i], (LPSTR)tmp);
  193. ErrMsg(ghWndMain, temp);
  194. return -1;
  195. }
  196. strcpy(lpDbfDatas[i]->file,tmp); 
  198. if (InitBase(lpDbfDatas[i]->hf,&lpDbfDatas[i]->dbfStruct,
  199. &lpDbfDatas[i]->fldStruct,&lpDbfDatas[i]->fldCount)
  200. !=SUCCEED) 
  201. {
  202. wsprintf(temp, "can not init %s:n %s",
  203. (LPSTR)HqItems[i], (LPSTR)tmp);
  204. ErrMsg(ghWndMain, temp);
  205. return -1;
  206. }
  208. i++;
  209. }
  211.     //初始化分时数据结构
  212. if(!clGetInitString("HQ", "DATAPATH", szDataPath))
  213. {
  214. ErrMsg(ghWndMain, "not set datapath in [graph]");
  215. PutInitString("HQ", "DATAPATH", NULL);
  216. return -1;
  217. }
  218. i =strlen(szDataPath);
  219. if(szDataPath[i] =='\')
  220. szDataPath[i] =0;
  222. wsprintf(HqDataPath, "%s\HQDATA", szDataPath);
  223. wsprintf(GraphData[0].szGraPath, "%s\SZDATA", szDataPath);
  224. wsprintf(GraphData[1].szGraPath, "%s\SHDATA", szDataPath);
  226. //初始化行情数据文件
  227. i =0;
  228. while(HqDataFileName[i])
  229. {
  230. wsprintf(tmp, "%s\%s.dat", HqDataPath, HqDataFileName[i]);
  231. if(access(tmp,_S_IREAD) <0)
  232. {
  233. *HqDataFile[i] =OpenFile(tmp,&os, OF_SHARE_DENY_NONE|OF_CREATE|OF_READWRITE);
  234. if(*HqDataFile[i] ==-1)
  235. {
  236. wsprintf(temp, "can not create hq_data_file %s:", tmp);
  237. ErrMsg(ghWndMain, temp);
  238. return -1;
  239. }
  240. }  
  241. else 
  242. *HqDataFile[i] =OpenFile(tmp, &os, OF_SHARE_DENY_NONE|OF_READWRITE);
  244. if (*HqDataFile[i] ==HFILE_ERROR)
  245. {
  246. wsprintf(temp, "can not open hq_data_file %s:", tmp);
  247. ErrMsg(ghWndMain, temp);
  248. return -1;
  249. } 
  250. i++;
  251. }
  253. //gnHqRefreshTime =GetInitInt("HQ", "REF_TIME");
  254. //if(gnHqRefreshTime <5 || gnHqRefreshTime >60) 
  255. gnHqRefreshTime =5;
  256.     
  257.     
  258. for(jys =0; jys <2; jys++)
  259. {
  260. CloseDbfFile(jys);
  261. }
  263. return 0;
  264. }
  266. void clHqExit(void)
  267. {
  268. static BOOL fExit =FALSE;
  269. int jys, i;
  271. if(fExit ==TRUE) return;
  272. fExit =TRUE;
  273. for(jys =0; jys <2; jys++)
  274. {
  275. if(HqData[jys].lpPreData !=NULL) 
  276. GlobalFreePtr(HqData[jys].lpPreData);
  277. if(HqData[jys].lpRefData !=NULL) 
  278. GlobalFreePtr(HqData[jys].lpRefData);
  279. if(HqData[jys].lpbChanged !=NULL) 
  280. GlobalFreePtr(HqData[jys].lpbChanged);
  281. if(MmpData[jys].lpMmp) 
  282. GlobalFreePtr(MmpData[jys].lpMmp);
  283. if(GraphData[jys].lpGraData) 
  284. GlobalFreePtr(GraphData[jys].lpGraData);
  285. if(GraphData[jys].lpGraHead) 
  286. GlobalFreePtr(GraphData[jys].lpGraHead);
  287. if(LzwData202[jys].recCount)
  288. GlobalFreePtr(LzwData202[jys].recCount);
  290. if(hfHq[jys] !=HFILE_ERROR) _lclose(hfHq[jys]);
  291. if(hfMmp[jys] !=HFILE_ERROR) _lclose(hfMmp[jys]);
  292. if(hfMaxMin[jys] !=HFILE_ERROR) _lclose(hfMaxMin[jys]);
  293. }
  294. if(hfDp !=HFILE_ERROR) _lclose(hfDp);
  295. i =0;
  296. while(HqItems[i])
  297. {
  298. if(lpDbfDatas[i]->hf!=-1)
  299. {
  300. CloseDbf(lpDbfDatas[i]->hf);
  301. }
  302. if(lpDbfDatas[i]->fldStruct)
  303. GlobalFreePtr(lpDbfDatas[i]->fldStruct);
  304. i++;
  305. }
  307. if(ZxData.lpText) free(ZxData.lpText);
  308. }
  311. BOOL OpenDbfFile(int jys)
  312. {
  313. int i =0;
  315. while(lpDbfFile[jys][i]!=NULL)
  316. {   
  317. if(lpDbfFile[jys][i]->hf==-1)
  318. lpDbfFile[jys][i]->hf =OpenDbfBase(lpDbfFile[jys][i]->file,OF_READ);
  319. if(lpDbfFile[jys][i]->hf == -1)
  320. return FALSE;
  321. i++;
  322. }
  323. return TRUE;
  324. }
  327. void CloseDbfFile(int jys)
  328. {
  329. int i=0;
  331.     while(lpDbfFile[jys][i]!=NULL)
  332.     {
  333.      if(lpDbfFile[jys][i]->hf!=-1)
  334.      {
  335.   CloseDbf(lpDbfFile[jys][i]->hf);
  336.   lpDbfFile[jys][i]->hf =-1; 
  337.   }
  338.   i++;
  339.   } 
  340. }
  344. //zqdm,zrsp,jrkp,zgjg,zdjg,zgjm,zdjm,zjjg,zd,cjss,lc,npzl,wb,cjje
  345. int HqFldLens[HQ_FLDS_COUNT]=
  346. {
  347. MAX_ZQDM_SIZE, sizeof(float),sizeof(float), sizeof(float), sizeof(float),
  348. sizeof(float), sizeof(float), sizeof(float), sizeof(float),sizeof(int),
  349. sizeof(int), sizeof(int), sizeof(float), sizeof(int)
  350. };
  352. int HqFldTypes[HQ_FLDS_COUNT]=
  353. {
  354. FLD_TYPE_STRING, FLD_TYPE_FLOAT, FLD_TYPE_FLOAT, FLD_TYPE_FLOAT,
  355. FLD_TYPE_FLOAT, FLD_TYPE_FLOAT, FLD_TYPE_FLOAT, FLD_TYPE_FLOAT,
  356. FLD_TYPE_FLOAT, FLD_TYPE_LONG,  FLD_TYPE_LONG, FLD_TYPE_LONG,
  357. FLD_TYPE_FLOAT, FLD_TYPE_LONG
  358. };
  360. int HqFldPoss[2][HQ_FLDS_COUNT] =
  361. {
  362. //0zqdm,1zrsp,2jrkp,3zgjg,4zdjg,5zgjm,6zdjm,7zjjg,8zd,9cjss,0lc,11npzl,
  363. //12wb,13cjje
  364. //{0, 2, 3, 5, 6, 8, 9, 7, -1,  4, -1,-1, -1, 15},
  365. {0, 1, 2, 4, 5, 7, 8, 6, -1,  3, -1,-1, -1, 14},
  366. {0, 2, 3, 5, 6, 8, 9, 7, -1, 10, -1, -1, -1, 4},
  367. };
  369. BOOL IsTodayHq(int jys)
  370. {
  371.     struct _stat buff;
  372.     char tmp[10];
  373.     
  374.     _strdate(tmp);    
  375.     _fstat(HqkData[jys].hf,&buff);
  376.     
  377. return TRUE;
  378. }
  380. #define _hread hRead
  381. #define PER_READ_LEN 1024L
  383. long hRead(HFILE hf,char * buff,long len)
  384. {                             
  385. long rlen=0;
  386. UINT ret,plen ;
  388. if(len<=PER_READ_LEN)
  389. {
  390. ret =_lread(hf,buff,(UINT)(len));
  391. rlen =(long)(ret);
  392. }
  393. else
  394. {
  395. rlen =0;
  396. do
  397. {
  398. if(len -rlen>= PER_READ_LEN)
  399. {
  400. plen =(UINT)(PER_READ_LEN);
  401. }
  402. else
  403. {
  404. plen =(UINT)(len -rlen);
  405. }
  407. ret =_lread(hf,buff,plen);
  408. if(ret!=HFILE_ERROR)
  409. {                   
  410. buff+=ret;
  411. rlen +=ret;
  412. }
  413. else
  414. {   
  415. return -1;
  416. }
  417. }while(rlen<len&&ret!=HFILE_ERROR);
  418. }
  420. return rlen;
  421. }
  423. //////////////////////////////////////////////////////////////////
  424. //功能 ：初始化内存行情数据对象、内存买卖盘对象、内存分时数据头部信息 ，       
  425. //          同时，填充相应的内存行情数据的股票名称字段， 三个内存对象与填充
  426. //          操作以内存行情数据的记录号为主索引 ，所以当行情数据的记录数有变化
  427. //          时，一定要更新其余的内存对象，并重作名称填充。该例程同时初始化大盘
  428. //          内存对象和排行榜内存对象
  429. //参数 ：
  430. //      jys---交易所编码
  431. //返回码 ：
  432. // TRUE---成功
  433. //          FALSE--失败
  434. //修改日期 ：1997/10/15
  435. //修改建议 ：可将内存行情数据放入BTREE，BTREE内包含其余的两内存数据对象，以股票
  436. // 代码作索引
  439. int ReadHqFirst(int jys)
  440. {
  441. int i, j ;
  442. short reclen, headlen;
  444. long recCount,bytes;
  445. char *buffer;
  446. char *lpTmp;
  447. LPSTR lpFld;
  448. char tmp[100];
  449. static BOOL fFirst[2] ={TRUE, TRUE};
  451. if(HqkData[jys].hf <0)
  452. { 
  453.    ErrMsg(ghWndMain, "ReadHqFirst 不能打开行情库句柄!");
  454. return FALSE;
  455.     }
  456. if(jys ==0) MsgLocal("读取深圳行情");
  457. else MsgLocal("读取上海行情");
  459. reclen=*(short *)HqkData[jys].dbfStruct.rlen;
  460. headlen=*(short *)HqkData[jys].dbfStruct.hlen;
  462. //计算行情库有效记录
  463. //recCount =GetDbfRecCount(HqkData[jys].hf,headlen,reclen);
  464. recCount =GetValidRecNum(jys);
  466. if(jys ==1)
  467. {
  468. recCount --;
  469. }
  470. if(recCount <=0) 
  471. {
  472. ErrMsg(ghWndMain, "ReadHqFirst 行情库记录数为零!");
  473. return FALSE;
  474. }
  475. // 分配内存，同时将分时数据结构等清零及初始化              
  476. if(clHqAllocMem(jys, (int)recCount) <0) 
  477. {
  478. ErrMsg(ghWndMain, "ReadHqFirst:HqAllocMem错!");
  479. return FALSE;
  480. }
  482. HqData[jys].recCount =(short)recCount; 
  484. //读交易所行情文件
  486. buffer =(char *)GlobalAllocPtr(GHND, recCount*reclen+1);
  487. if (buffer==NULL) 
  488. {
  489. ErrMsg(ghWndMain, "ReadHqFirst:alloc buffer 错!");
  490. return FALSE;
  491.     }
  492. _llseek(HqkData[jys].hf,(long)headlen,SEEK_SET);
  493. if(jys ==1)
  494. _llseek(HqkData[jys].hf, reclen, SEEK_CUR);
  496. bytes =hRead(HqkData[jys].hf, buffer, recCount*reclen);
  498. if(bytes == -1)
  499. {
  500. ErrMsg(ghWndMain,"ReadHqFirst:hRead bytes =-1错");
  501. GlobalFreePtr(buffer);  
  502. return FALSE;
  503. } 
  505. if(bytes !=recCount*reclen)
  506. {
  507.   ErrMsg(ghWndMain, "ReadHqFirst:bytes !=recCount*reclen");
  508.   GlobalFreePtr(buffer);  
  509.   return FALSE;
  510. }
  511.     
  512. //初始化行情数据结构    
  513. lpTmp =buffer;
  514. for (i=0;i<recCount;i++) 
  515. {
  516. for(j =0; j<HQ_FLDS_COUNT; j++)
  517. {
  518. lpFld =GetHqFldPos(jys, i, j);
  519. if(HqFldPoss[jys][j] >=0)
  520. {
  521. FldToString(lpTmp,
  522. (FieldStruct *)&HqkData[jys].fldStruct[HqFldPoss[jys][j]],
  523. tmp);
  524. switch(HqFldTypes[j])
  525. {
  526. case FLD_TYPE_STRING:
  527. strcpy(lpFld, tmp);
  528. break;
  529. case FLD_TYPE_FLOAT:
  530. *(float *)lpFld =(float)atof(tmp);
  531. break;
  532. case FLD_TYPE_LONG:
  533. *(int *)lpFld =atol(tmp);
  534. break;
  535. }
  536. }
  537. }
  539. if(IsGuoZhai(jys, i))
  540. HqData[jys].lpRefData[i].cjss /=10;     //单位：手
  541. else
  542. HqData[jys].lpRefData[i].cjss /=100;    //单位：手
  543. HqData[jys].lpRefData[i].cjje /=1000;       //单位：万
  545. HqData[jys].lpRefData[i].lc =0;
  547. if(HqData[jys].lpPreData[i].zrsp ==0
  548. ||HqData[jys].lpRefData[i].zjcj ==0)
  549. HqData[jys].lpRefData[i].zdf =0;
  550. else
  551. HqData[jys].lpRefData[i].zdf =
  552. (HqData[jys].lpRefData[i].zjcj
  553. - HqData[jys].lpPreData[i].zrsp)
  554. /HqData[jys].lpPreData[i].zrsp*100;
  556. if(clIsZsRec(jys, i))
  557. {
  558. if(jys ==1)
  559. {
  560. GetShZsFirst(lpTmp, DpData[jys].zsCount);
  561. DpData[jys].zsCount++;
  562. }
  563. }
  565. if(jys ==1)
  566. {               
  567. FldToString(lpTmp,(FieldStruct *)&HqkData[jys].fldStruct[1],
  568. HqData[jys].lpPreData[i].zqmc);
  569. GetShMmp(TRUE, i, lpTmp);
  570. }
  571. lpTmp +=reclen;
  572. }
  573.  
  574. GlobalFreePtr(buffer);  
  575. CheckGraHead(jys);
  577. if(jys ==0)
  578. {
  579. if(!GetSzZqmc(jys)) 
  580. {
  581. ErrMsg(ghWndMain,"ReadHqFirst:GetSzZqmc(jys)错");
  582. return FALSE;
  583. }
  584. if(!ReadSzZsFirst()) 
  585. {
  586.     ErrMsg(ghWndMain,"ReadHqFirst:ReadSzZsFirst()错");
  587. return FALSE;
  588. }
  589. if(!ReadSzMmp(TRUE))
  590. {
  591.     ErrMsg(ghWndMain,"ReadHqFirst:ReadSzZsFirst()错");
  592. return FALSE;
  593. }
  594. }
  596. i =GetMaxMin10(jys);
  598. GetDpData(jys, TRUE);
  600. MsgLocal("OK.");
  601. fFirst[jys] =FALSE;
  603. return TRUE;
  604. }
  606. ////////////////////////////////////////////////////////
  607. //功能 ：根据股票代码、记录号获取股票名称，该功能只支持深股
  608. //参数 ：
  609. // jys---交易所编号
  610. //          rec---记录标号（0-->记录数-1)
  611. //          gpdm--股票代码
  612. //          gpmc--股票名称
  613. //返回码 ：
  614. // 0   --成功
  615. // -1  --失败
  616. //修改日期 ：1997/10/15
  618. int GetZqmc(int jys,int rec,char *gpdm,char *gpmc)
  619. {
  620. int i;
  621. short reclen, headlen, fldnum;
  622. int rec_count;
  624. char *buffer;
  625. char tmp[40];
  627. if(GpkData[jys].hf ==-1)
  628. return -1;
  629. if(jys==1)
  630. return -1;
  632. reclen=*(short *)GpkData[jys].dbfStruct.rlen;
  633. headlen=*(short *)GpkData[jys].dbfStruct.hlen;
  635. rec_count =(int)GetDbfRecCount(GpkData[jys].hf,headlen,reclen);
  637. if(rec_count <=0) return -1;
  638. fldnum =GpkData[jys].fldCount;
  640. buffer =(char *)malloc(reclen+1);
  641. if (buffer==NULL) 
  642. {
  643. ErrMsg(ghWndMain, "GetZqmc:alloc buffer failed!");
  644. return -1;
  645.     }
  646.     //用记录数定位
  647. if(rec<rec_count)
  648. {
  649. _llseek(GpkData[jys].hf,(long)(headlen+reclen*rec),SEEK_SET);
  650. if(_lread(GpkData[jys].hf,buffer,reclen) ==(UINT)reclen)
  651. {
  652. FldToString(buffer,(FieldStruct *)&GpkData[jys].fldStruct[0], tmp);
  653. if(!strcmp(tmp, gpdm))
  654. {
  655. FldToString(buffer,(FieldStruct *)&GpkData[jys].fldStruct[1],gpmc);
  656.      free(buffer);
  657. return 0;
  658. }
  659. }
  660. }
  661. //线性搜索
  662. _llseek(GpkData[jys].hf,(long)headlen,SEEK_SET);
  663. for (i=0;i<rec_count;i++) 
  664. {
  665. if(_lread(GpkData[jys].hf,buffer,reclen) !=(UINT)reclen) break;
  667. FldToString(buffer,(FieldStruct *)&GpkData[jys].fldStruct[0], tmp);
  668. if(!strcmp(tmp, gpdm))
  669. {
  670. FldToString(buffer,(FieldStruct *)&GpkData[jys].fldStruct[1],gpmc);     
  671.     free(buffer);
  672. return 0;
  673. }
  674. }
  675. free(buffer);
  676. return -1;
  677. }
  679. /////////////////////////////////////////////////
  680. //功能 ：刷新行情数据
  681. //参数 ：
  682. //      jys---交易所编码
  683. //返回码 ：
  684. // 0---成功
  685. //          -1--失败
  686. //修改日期 ：1997/10/15
  688. int HqRefresh(int jys)
  689. {
  690. int i, j;
  691. short reclen, headlen ;
  692. int zs_num[2] ={0, 0};
  694. char *buffer;
  695. char *lpTmp;
  696. LPSTR lpFld;
  697. char tmp[50];
  698. long l,bytes;
  699. HQ_REF_DATA LastHq;
  700. char LastZqdm[MAX_ZQDM_SIZE];
  702.     int recCount;
  704. if(HqkData[jys].hf ==-1)
  705. {   
  706. ErrMsg(ghWndMain, "HqRefresh:不能打开行情库文件句柄");
  707. return FALSE;
  708.     }
  709. if(jys ==0) MsgLocal("刷新深圳行情");
  710. else MsgLocal("刷新上海行情");
  712. reclen=*(short *)HqkData[jys].dbfStruct.rlen;
  713. headlen=*(short *)HqkData[jys].dbfStruct.hlen;
  715. //recCount =(int)GetDbfRecCount(HqkData[jys].hf,headlen,reclen);
  716. recCount =GetValidRecNum(jys);
  718. //检查行情库记录数有无增减,如有效记录数发生变化，则应从新调整内存 ，
  719. if(recCount ==0)
  720. {
  721. ErrMsg(ghWndMain,"HqRefresh:GetDbfRecCount =0");
  722. return FALSE;
  723. }
  725. //上海行情库少采集一条记录
  726. if(jys ==1) recCount --;
  728. if(recCount <=0)
  729. {
  730. ErrMsg(ghWndMain,"HqRefresh:调整recCount <=0");
  731. return FALSE;
  732. }
  734. //HqData[jys].recCount =recCount;  ///add for deal with GetV function
  735. if(recCount!=HqData[jys].recCount)
  736. {
  737. MsgLocal("HqRefresh:记录数不匹配，重新初始化");
  738. return FALSE;
  739. }
  741. if(HqData[jys].recCount <=0)
  742. {   
  743.     ErrMsg(ghWndMain, "HqRefresh:行情库记录数错");
  744.   return FALSE;
  745. }
  746. l =HqData[jys].recCount;
  747. if ((buffer=(char *)GlobalAllocPtr(GHND, l*reclen+1))==NULL) 
  748. {
  749. ErrMsg(ghWndMain, "HqRefresh:行情采集分配缓冲区错!");
  750. return FALSE;
  751. }
  753. _llseek(HqkData[jys].hf,(long)headlen,SEEK_SET);
  754.     
  755.     //上海行情库第一条记录不能采集
  756. if(jys ==1)
  757. _llseek(HqkData[jys].hf, reclen, SEEK_CUR);
  759. bytes =hRead(HqkData[jys].hf, buffer, l*reclen);
  761. if(bytes == -1)
  762. {
  763. ErrMsg(ghWndMain,"HqRefresh:bytes == -1");
  764. GlobalFreePtr(buffer);
  765. return FALSE;
  766. }
  768. if(bytes!=l*reclen)
  769. {
  770. ErrMsg(ghWndMain, "HqRefresh:bytes!=l*reclen");
  771. GlobalFreePtr(buffer);
  772. return FALSE;
  773. }
  774. else
  775. {
  776. lpTmp =buffer;
  777. for (i=0;i<HqData[jys].recCount;i++) 
  778. {    
  779. while(UDPBlockingHook());
  780. if(run_cancelled) break;
  781. //拷贝行情老数据，作增量判断
  782. memcpy(&LastHq,&HqData[jys].lpRefData[i],
  783. sizeof(HQ_REF_DATA));
  784. //拷贝股票代码，以下用于股票数量加减判断
  785. strcpy(LastZqdm,HqData[jys].lpPreData[i].zqdm);
  787. for(j =0; j<HQ_FLDS_COUNT; j++)
  788. {
  789. lpFld =GetHqFldPos(jys, i, j);
  790. if(HqFldPoss[jys][j] >=0)
  791. {
  792. FldToString(lpTmp,(FieldStruct *)&HqkData[jys].fldStruct[HqFldPoss[jys][j]],
  793. tmp);
  794. switch(HqFldTypes[j])
  795. {
  796. case FLD_TYPE_STRING:
  797. strcpy(lpFld, tmp);
  798. break;
  799. case FLD_TYPE_FLOAT:
  800. *(float *)lpFld =(float)atof(tmp);
  801. break;
  802. case FLD_TYPE_LONG:
  803. *(int *)lpFld =atol(tmp);
  804. break;
  805. }
  806. }
  807. }
  808. //判断股票代码有无改变，如改变，则应获取正确的行情老数据
  809. //如股票代码有改变，则相应的名称也应改变
  810. if(strcmp(HqData[jys].lpPreData[i].zqdm,LastZqdm)!=0)
  811. {
  812.      //重读股票名称
  813. if(jys==0)
  814. {
  815. if(GetZqmc(jys,i,HqData[jys].lpPreData[i].zqdm,
  816. HqData[jys].lpPreData[i].zqmc)!=0)
  817. {
  818. strcpy(HqData[jys].lpPreData[i].zqmc,
  819. HqData[jys].lpPreData[i].zqdm);
  820. }
  821. }
  822. if(jys==1)
  823. {
  824. FldToString(lpTmp,(FieldStruct *)&HqkData[jys].fldStruct[1],
  825. HqData[jys].lpPreData[i].zqmc);
  826. }
  827. //放弃该次采集，处理下一条
  828. lpTmp +=reclen;
  829. continue;
  830. }
  831. if(IsGuoZhai(jys, i))
  832. HqData[jys].lpRefData[i].cjss /=10;     //单位：手
  833. else
  834. HqData[jys].lpRefData[i].cjss /=100;    //单位：手
  835. HqData[jys].lpRefData[i].cjje /=1000;       //单位：万
  836. if(jys ==1)
  837. {
  838. //FldToString(lpTmp,(FieldStruct *)&HqkData[jys].fldStruct[1],
  839. // HqData[jys].lpPreData[i].zqmc);
  841. if(clIsZsRec(jys, i))
  842. {
  843. RefreshShZs(lpTmp, zs_num[1]);
  844. zs_num[1] ++;
  845. }
  846. else GetShMmp(FALSE, i, lpTmp);
  847. }
  848. HqData[jys].lpRefData[i].lc =
  849. HqData[jys].lpRefData[i].cjss -LastHq.cjss;
  850. //没有成交 ，处理下一条
  851. if(HqData[jys].lpRefData[i].lc <=0)
  852. {
  853. lpTmp +=reclen;
  854. continue;
  855. }
  856. //有成交，计算涨跌              
  857. if(HqData[jys].lpPreData[i].zrsp ==0
  858. ||HqData[jys].lpRefData[i].zjcj ==0)
  859. HqData[jys].lpRefData[i].zdf =0;
  860. else
  861. HqData[jys].lpRefData[i].zdf =
  862. (HqData[jys].lpRefData[i].zjcj
  863. - HqData[jys].lpPreData[i].zrsp)
  864. /HqData[jys].lpPreData[i].zrsp*100;
  866. //如果是指数，则不处理
  867. if(!clIsZsRec(jys, i))
  868. {
  869. GetGraData(jys, i, &LastHq);
  870. if(HqData[jys].lpRefData[i].lc >0)
  871. WriteGraData(jys, i);
  872. }
  874. lpTmp +=reclen;
  875. }       
  876. }
  877. GlobalFreePtr(buffer);
  878. MsgLocal("OK.");
  880. if(jys ==0)
  881. {
  882. ReadSzMmp(FALSE);
  883. RefreshSzZs();
  884. }
  886. GetMaxMin10(jys);
  887. GetDpData(jys, FALSE);
  889. return TRUE;
  890. }
  892. int ReadSzZsFirst(void)
  893. {
  894. int i ; 
  895. short reclen, headlen;
  896. char *buffer;
  897.     char tmp[100];
  898.     
  899. if(SzZskData.hf <0)
  900. {
  901.     ErrMsg(ghWndMain, "ReadSzZsFirst:SzZskData.hf <0!");
  902. return FALSE;
  903.     }
  904. DpData[0].zsCount =*(int *)SzZskData.dbfStruct.recnum;
  905. if(DpData[0].zsCount >15) DpData[0].zsCount =15;
  907. reclen=*(short *)SzZskData.dbfStruct.rlen;
  908. headlen=*(short *)SzZskData.dbfStruct.hlen;
  910. if(DpData[0].zsCount <=0) 
  911. {
  912.     ErrMsg(ghWndMain, "ReadSzZsFirst:DpData[0].recCount <=0!");
  913. return FALSE;
  914. }
  916. buffer =(char *)malloc(reclen*DpData[0].zsCount+1);
  917. if (buffer==NULL) 
  918. {
  919. ErrMsg(ghWndMain, "ReadSzZsFirst:alloc buffer failed!");
  920. return FALSE;
  921.     }
  922. memset(buffer, 0, reclen*DpData[0].zsCount+1);
  924. _llseek(SzZskData.hf,(long)headlen,SEEK_SET);
  925. _lread(SzZskData.hf,buffer, reclen*DpData[0].zsCount);
  926. for (i=0;i<DpData[0].zsCount;i++) 
  927. {
  928. FldToString(buffer+i*reclen,
  929. (FieldStruct *)&SzZskData.fldStruct[2],tmp);
  930. DpData[0].sp[i] =(float)atof(tmp);
  931. FldToString(buffer+i*reclen,
  932. (FieldStruct *)&SzZskData.fldStruct[6],
  933. tmp);
  934. DpData[0].zs[i] =(float)atof(tmp);
  935. DpData[0].zd[i] =DpData[0].zs[i] -DpData[0].sp[i];
  936. }
  937. free(buffer);
  938. return TRUE;
  939. }
  941. int GetShZsFirst(LPSTR lpbuf, int zsnum)
  942. {
  943. char tmp[100];
  945. if(zsnum >15) return 0;
  946. FldToString(lpbuf,(FieldStruct *)&HqkData[1].fldStruct[7],
  947. tmp);
  948. DpData[1].zs[zsnum] =(float)atof(tmp);
  950. FldToString(lpbuf,(FieldStruct *)&HqkData[1].fldStruct[2],
  951. tmp);
  952. DpData[1].sp[zsnum] =(float)atof(tmp);
  954. //FldToString(lpbuf,(FieldStruct *)&HqkData[1].fldStruct[3],
  955. // tmp);
  956. //if((float)atof(tmp)!=0.00)
  957. // DpData[1].zd[zsnum] =(float)atof(tmp)-DpData[1].sp[zsnum];
  958.     //else
  959. DpData[1].zd[zsnum] =DpData[1].zs[zsnum]-DpData[1].sp[zsnum];    
  960. return 0;
  961. }
  963. int GetShMmp(BOOL fFirst, int rec_num, LPSTR buffer)
  964. {
  965. int i;
  966. char tmp[100];
  967.     double f1, f2;
  968. MMP LastMmp;
  969.     long tmpl;
  970.     float tmpf;
  971.     
  972. memcpy(&LastMmp, &MmpData[1].lpMmp[rec_num], sizeof(MMP));
  973. MmpData[1].lpMmp[rec_num].jwBuy[0]
  974. =HqData[1].lpRefData[rec_num].zgjm;
  975. MmpData[1].lpMmp[rec_num].jwSell[0]
  976. =HqData[1].lpRefData[rec_num].zdjm;
  977. f1 =f2 =0;
  978. for(i =0; i<3; i++)
  979. {
  980. FldToString(buffer,(FieldStruct *)&HqkData[1].fldStruct[12+i*2],
  981. tmp);
  982. MmpData[1].lpMmp[rec_num].slBuy[i] =atol(tmp)/100;
  983. if(i !=2)
  984. {
  985. FldToString(buffer,(FieldStruct *)&HqkData[1].fldStruct[12+i*2+1],
  986. tmp);
  987. MmpData[1].lpMmp[rec_num].jwBuy[i+1] =(float)atof(tmp);
  988. }
  989. f2+=MmpData[1].lpMmp[rec_num].slBuy[i];
  990. }
  991. for(i =0; i<3; i++)
  992. {
  993. FldToString(buffer,(FieldStruct *)&HqkData[1].fldStruct[17+i*2],
  994. tmp);
  995. MmpData[1].lpMmp[rec_num].slSell[i] =atol(tmp)/100;
  996. if(i !=2)
  997. {
  998. FldToString(buffer,(FieldStruct *)&HqkData[1].fldStruct[17+i*2+1],
  999. tmp);
  1000. MmpData[1].lpMmp[rec_num].jwSell[i+1] =(float)atof(tmp);
  1001. }
  1002. f1+=MmpData[1].lpMmp[rec_num].slSell[i];
  1003. }
  1005. tmpl=MmpData[1].lpMmp[rec_num].slSell[0];
  1006. tmpf=MmpData[1].lpMmp[rec_num].jwSell[0];
  1008. MmpData[1].lpMmp[rec_num].slSell[0]=
  1009. MmpData[1].lpMmp[rec_num].slSell[2];
  1010. MmpData[1].lpMmp[rec_num].jwSell[0]=
  1011. MmpData[1].lpMmp[rec_num].jwSell[2];
  1013. MmpData[1].lpMmp[rec_num].slSell[2]=tmpl;
  1014. MmpData[1].lpMmp[rec_num].jwSell[2]=tmpf;
  1016.                                        
  1017. if(f1+f2 ==0)
  1018. HqData[1].lpRefData[rec_num].wb =0;
  1019. else
  1020. HqData[1].lpRefData[rec_num].wb =(float)((f2-f1)/(f2+f1));                                               
  1022. if(memcmp(&LastMmp, &MmpData[1].lpMmp[rec_num], sizeof(MMP)))
  1023. MmpData[1].lpChanged[rec_num] =TRUE;
  1024. else MmpData[1].lpChanged[rec_num] =FALSE;
  1026. return 0;
  1027. }
  1029. int ReadSzMmp(BOOL fFirst)
  1030. {
  1031. int i, j ;
  1032. short reclen, headlen;
  1033. char *buffer;
  1034. char *lpTmp;
  1035. char tmp[100];
  1036. double f1, f2;
  1037. int rec_count;
  1038. MMP LastMmp;
  1039. long bytes;
  1041. if(SzMmpkData.hf <0)
  1042. {
  1043.     ErrMsg(ghWndMain, "ReadSzMmp:SzMmpkData.hf <0!");
  1044. return FALSE;
  1045. }
  1047. MsgLocal("read Sz_Mmp...");
  1049. rec_count =HqData[0].recCount*6;
  1051. reclen=*(short *)SzMmpkData.dbfStruct.rlen;
  1052. headlen=*(short *)SzMmpkData.dbfStruct.hlen;
  1054. //加入以下代码处理买卖盘库尚未传完的情况
  1055. i=(int)GetDbfRecCount(SzMmpkData.hf,headlen,reclen);
  1056. if(rec_count>i) rec_count =i;
  1058. buffer =(char *)GlobalAllocPtr(GHND, (long)rec_count*reclen+1);
  1059. if (buffer==NULL) 
  1060. {
  1061. ErrMsg(ghWndMain, "ReadSzMmp:alloc buffer failed!");
  1062. return FALSE;
  1063. }
  1064. _llseek(SzMmpkData.hf,(long)headlen,SEEK_SET);
  1066. bytes =hRead(SzMmpkData.hf, buffer, (long)rec_count*reclen);
  1068. if(bytes ==-1)
  1069. {
  1070. MsgLocal("HqRefresh:重新初化szmmpk");
  1071. GlobalFreePtr(buffer);
  1072. return FALSE;
  1073. }
  1075. if(bytes !=(long)rec_count*reclen)
  1076. {
  1077. ErrMsg(ghWndMain, "error read sz_mmpk");
  1078. }
  1079. else
  1080. {
  1081. lpTmp =buffer;
  1082. for(i =0; i<rec_count/6; i++)
  1083. {
  1084. while(UDPBlockingHook());
  1085. if(run_cancelled) break;
  1087. if(clIsZsRec(0, i)) continue;
  1088. memcpy(&LastMmp, &MmpData[0].lpMmp[i], sizeof(MMP));
  1089. f1 =f2 =0;
  1090. //应加入股票代码检查
  1091. for(j =0; j<3; j++)
  1092. {
  1093. //if(_lread(SzMmpkData.hf,buffer, reclen) !=(UINT)reclen) break;
  1094. //if(fFirst && j==0)
  1095. //      FldToString(lpTmp,
  1096. //              (FieldStruct *)&SzMmpkData.fldStruct[0],
  1097. //              MmpData[0].lpMmp[i].zqdm);
  1098. FldToString(lpTmp,(FieldStruct *)&SzMmpkData.fldStruct[2],
  1099. tmp);
  1100. MmpData[0].lpMmp[i].jwSell[j] =(float)atof(tmp);
  1101. FldToString(lpTmp,(FieldStruct *)&SzMmpkData.fldStruct[4],
  1102. tmp);
  1103. MmpData[0].lpMmp[i].slSell[j] =atol(tmp)/100;
  1104. f1+=(double)MmpData[0].lpMmp[i].slSell[j];
  1105. lpTmp +=reclen;
  1106. }
  1107. if(j !=3) break;
  1108. for(j =0; j<3; j++)
  1109. {
  1110. //if(_lread(SzMmpkData.hf,buffer, reclen) !=(UINT)reclen) break;;
  1111. FldToString(lpTmp,(FieldStruct *)&SzMmpkData.fldStruct[2],
  1112. tmp);
  1113. MmpData[0].lpMmp[i].jwBuy[j] =(float)atof(tmp);
  1114. FldToString(lpTmp,(FieldStruct *)&SzMmpkData.fldStruct[3],
  1115. tmp);
  1116. MmpData[0].lpMmp[i].slBuy[j] =atol(tmp)/100;
  1117. f2+=(double)MmpData[0].lpMmp[i].slBuy[j];
  1118. lpTmp +=reclen;
  1119. }                                               
  1120. if(j !=3) break;
  1121. if(f1+f2 !=0)
  1122. HqData[0].lpRefData[i].wb
  1123. =(float)((f2-f1)/(f1+f2));
  1124. else HqData[0].lpRefData[i].wb =0;
  1125. if(memcmp(&LastMmp, &MmpData[0].lpMmp[i], sizeof(MMP)))
  1126. MmpData[0].lpChanged[i] =TRUE;
  1127. else MmpData[0].lpChanged[i] =FALSE;
  1128. //rec_num++;
  1129. }
  1130. }
  1131. //没有初始化的买卖盘数据
  1132. if(rec_count/6<HqData[0].recCount)
  1133. {         
  1134. memset(&MmpData[0].lpMmp[rec_count/6],0,
  1135. sizeof(MMP)*(HqData[0].recCount -rec_count/6));
  1136. }
  1137. GlobalFreePtr(buffer);
  1138. MsgLocal("OK.");
  1139. return TRUE;
  1140. }
  1142. int RefreshSzZs(void)
  1143. {
  1144. int i ;
  1145. short reclen, headlen;
  1147. char *buffer;
  1148. char tmp[100];
  1149. static int times =0;
  1151. if(SzZskData.hf <0)
  1152. return 0;
  1154. reclen=*(short *)SzZskData.dbfStruct.rlen;
  1155. headlen=*(short *)SzZskData.dbfStruct.hlen;
  1157. buffer =(char *)malloc(reclen*DpData[0].zsCount+1);
  1158. if (buffer==NULL) 
  1159. {
  1160. ErrMsg(ghWndMain, "RefreshSzZs:alloc buffer failed!");
  1161. return -1;
  1162. }
  1163. memset(buffer, 0, reclen*DpData[0].zsCount+1);
  1165. _llseek(SzZskData.hf,(long)headlen,SEEK_SET);
  1166. _lread(SzZskData.hf,buffer, reclen*DpData[0].zsCount);
  1167. for (i=0;i<DpData[0].zsCount;i++) 
  1168. {
  1169. FldToString(buffer+i*reclen,
  1170. (FieldStruct *)&SzZskData.fldStruct[6],
  1171. tmp);
  1172. DpData[0].zs[i] =(float)atof(tmp);
  1173. DpData[0].zd[i] =DpData[0].zs[i]-DpData[0].sp[i];
  1174. }
  1175. free(buffer);
  1176. return 0;
  1177. }
  1179. int RefreshShZs(LPSTR lpbuf, int zsnum)
  1180. {
  1181. char tmp[100];
  1183. if(zsnum >15) return 0;
  1184. FldToString((char *)lpbuf,(FieldStruct *)&HqkData[1].fldStruct[7],
  1185. tmp);
  1186. DpData[1].zs[zsnum] =(float)atof(tmp);
  1187.     
  1188. FldToString((char *)lpbuf,(FieldStruct *)&HqkData[1].fldStruct[2],
  1189. tmp);
  1190. DpData[1].sp[zsnum] =(float)atof(tmp);
  1191.     
  1192. DpData[1].zd[zsnum] =DpData[1].zs[zsnum]-DpData[1].sp[zsnum];
  1194. return 0;
  1195. }
  1197. int GetSzZqmc(int jys)
  1198. {
  1199. int i, j ;
  1200. short reclen, headlen, fldnum;
  1201. int rec_count;
  1203. char *buffer;
  1204. char tmp[40];
  1206. if(GpkData[jys].hf ==-1)
  1207. {
  1208. ErrMsg(ghWndMain, "GetSzZqmc:GpkData[jys].hf ==-1!");
  1209. return FALSE;
  1210. }
  1211. rec_count =*(int *)GpkData[jys].dbfStruct.recnum;
  1212. if(rec_count <HqData[jys].recCount) rec_count =HqData[jys].recCount;
  1214. fldnum =GpkData[jys].fldCount;
  1215. reclen=*(short *)GpkData[jys].dbfStruct.rlen;
  1216. headlen=*(short *)GpkData[jys].dbfStruct.hlen;
  1217. if(rec_count <=0)
  1218. {   
  1219.      ErrMsg(ghWndMain, "GetSzZqmc:rec_count <=0!");
  1220.  return FALSE;
  1221. }
  1222. buffer =(char *)malloc(reclen+1);
  1223. if (buffer==NULL) 
  1224. {
  1225. ErrMsg(ghWndMain, "GetSzZqmc:alloc buffer failed!");
  1226. return FALSE;
  1227.     }
  1229. _llseek(GpkData[jys].hf,(long)headlen,SEEK_SET);
  1230. for (i=0;i<rec_count;i++) 
  1231. {
  1232. if(_lread(GpkData[jys].hf,buffer,reclen) !=(UINT)reclen) break;
  1234. // get zqdm
  1235. FldToString(buffer,(FieldStruct *)&GpkData[jys].fldStruct[0], tmp);
  1236. for(j =0; j<HqData[jys].recCount; j++)
  1237. if(!strcmp(tmp, HqData[jys].lpPreData[j].zqdm))
  1238. break;
  1239. if(j <HqData[jys].recCount)
  1240. FldToString(buffer,(FieldStruct *)&GpkData[jys].fldStruct[1],
  1241. HqData[jys].lpPreData[j].zqmc);
  1242. }
  1243. if(i <rec_count)
  1244. {
  1245. for(; i<HqData[jys].recCount; i++)
  1246. {
  1247. strcpy(HqData[jys].lpPreData[i].zqmc,
  1248. HqData[jys].lpPreData[i].zqdm);
  1249. }
  1250. }
  1251. free(buffer);
  1253. return TRUE;
  1254. }
  1256. int CheckZqdm(LPSTR lpzqdm)
  1257. {
  1258. return 0;
  1259. }
  1261. extern long tim_seconds;
  1262. //取大盘数据
  1263. int GetDpData(int jys, BOOL fFirst)
  1264. {
  1265. int i;
  1266. //int jys;
  1267. float oldjg;
  1268. long b_lc =0L, s_lc =0L;
  1269. HQ_REF_DATA LastHq;
  1270. DP_DATA LastDp;
  1271. int rec_num;
  1273. memcpy(&LastDp, &DpData[jys], sizeof(DP_DATA));
  1275. DpData[jys].cjzje =CalcCjzje(jys);
  1276. DpData[jys].npbl =CalcNpbl(jys);
  1277. DpData[jys].cjss =CalcCjss(jys);
  1278. DpData[jys].upCount =DpData[jys].downCount =DpData[jys].equalCount =0;
  1280. for(i =0; i<HqData[jys].recCount; i++)
  1281. {
  1282. oldjg =HqData[jys].lpRefData[i].zjcj;
  1283. //如果不是指数，则计算升跌家数
  1284. if(!clIsZsRec(jys, i))
  1285. {
  1286. if(HqData[jys].lpRefData[i].zdf >0)
  1287. DpData[jys].upCount ++;
  1288. else if(HqData[jys].lpRefData[i].zdf <0)
  1289. DpData[jys].downCount ++;
  1290. else DpData[jys].equalCount ++;
  1291. }
  1292. else
  1293. {
  1294. memcpy(&LastHq, &HqData[jys].lpRefData[i], sizeof(HQ_REF_DATA));
  1296. HqData[jys].lpRefData[i].cjss =DpData[jys].cjss;
  1297. HqData[jys].lpRefData[i].cjje =DpData[jys].cjzje;
  1298. HqData[jys].lpRefData[i].npzl 
  1299. =(int)((double)DpData[jys].npbl*(double)DpData[jys].cjss);
  1300. HqData[jys].lpRefData[i].wb =0;
  1301. HqData[jys].lpRefData[i].lc =DpData[jys].cjss-LastDp.cjss;
  1302. if(HqData[jys].lpRefData[i].lc <0)
  1303. HqData[jys].lpRefData[i].lc =0L;
  1306. if(jys ==0) rec_num =HqData[jys].recCount-i;
  1307. else rec_num =i;
  1308. if(!fFirst)
  1309. {
  1310. if(tim_seconds -zs_times[jys][rec_num] >gnHqRefreshTime)
  1311. {
  1312. GraphData[jys].lpGraData[i].lc =
  1313. DpData[jys].cjss-oldDpCjss2[jys][rec_num];
  1314. GetDpGraData(jys, i);
  1315. if(GraphData[jys].lpGraData[i].lc)
  1316. WriteGraData(jys, i);
  1317. zs_times[jys][rec_num] =tim_seconds;
  1318. oldDpCjss2[jys][rec_num] =DpData[jys].cjss;
  1319. }
  1320. }
  1321. else
  1322. {
  1323. zs_times[jys][rec_num] =tim_seconds;
  1324. oldDpCjss2[jys][rec_num] =DpData[jys].cjss;
  1325. }
  1326. }
  1327. }
  1329. if(memcmp(&LastDp, &DpData[jys], sizeof(DP_DATA))) return 1;
  1331. return 0;
  1332. }
  1334. int GetMaxMin10(int jys)
  1335. {
  1336. int ret =0;
  1337. MAXMIN_DATA LastMaxMin[2];
  1339. memcpy(&LastMaxMin[0], &MaxMinData[jys][0], sizeof(MAXMIN_DATA));
  1340. memcpy(&LastMaxMin[1], &MaxMinData[jys][1], sizeof(MAXMIN_DATA));
  1342. GetMaxZd10(jys);
  1343. GetMaxZdf10(jys);
  1344. GetMaxCjss10(jys);
  1345. GetMaxCjje10(jys);
  1346. if(memcmp(&MaxMinData[jys][0], &LastMaxMin[0], sizeof(MAXMIN_DATA)))
  1347. ret++;
  1348. GetMinZd10(jys);
  1349. GetMinZdf10(jys);
  1350. GetMinCjss10(jys);
  1351. GetMinCjje10(jys);
  1352. if(memcmp(&MaxMinData[jys][1], &LastMaxMin[1], sizeof(MAXMIN_DATA)))
  1353. ret+=2;
  1355. return ret;
  1356. }
  1358. void GetMaxZdf10(int jys)
  1359. {
  1360. GetFloatSort10(jys, 8, SORT_UP, &MaxMinData[jys][0].recNum[0][0]);
  1361. }
  1363. void GetMinZdf10(int jys)
  1364. {
  1365. GetFloatSort10(jys, 8, SORT_DOWN, &MaxMinData[jys][1].recNum[0][0]);
  1366. }
  1368. void GetMaxCjss10(int jys)
  1369. {
  1370. GetLongSort10(jys, 9, SORT_UP, &MaxMinData[jys][0].recNum[2][0]);
  1371. }
  1373. void GetMinCjss10(int jys)
  1374. {
  1375. GetLongSort10(jys, 9, SORT_DOWN, &MaxMinData[jys][1].recNum[2][0]);
  1376. }
  1378. void GetMaxCjje10(int jys)
  1379. {
  1380. GetLongSort10(jys, 13, SORT_UP, &MaxMinData[jys][0].recNum[3][0]);
  1381. }
  1383. void GetMinCjje10(int jys)
  1384. {
  1385. GetLongSort10(jys, 13, SORT_DOWN, &MaxMinData[jys][1].recNum[3][0]);
  1386. }
  1388. void GetMaxZd10(int jys)
  1389. {
  1390. int key, i, j, n;
  1391. float fval, f1, f;
  1392. int count =0;
  1393. int fldNum =8;
  1395. for(i =0; i<10; i++)
  1396. MaxMinData[jys][0].recNum[1][i] =i;
  1398. for(i =0; i<HqData[jys].recCount; i++)
  1399. keys[i] =i;
  1401. for(i =0; i<HqData[jys].recCount; i++)
  1402. {
  1403. if(!IsMaxMin(jys, keys[i])) continue;
  1404. if(HqData[jys].lpRefData[keys[i]].zjcj ==0) continue;
  1405. key =i;
  1406. if(HqData[jys].lpPreData[keys[key]].zrsp)
  1407. fval =HqData[jys].lpRefData[keys[key]].zjcj
  1408. -HqData[jys].lpPreData[keys[key]].zrsp;
  1409. else fval =-100;
  1410. for(j =i+1; j<HqData[jys].recCount; j++)
  1411. {
  1412. if(!IsMaxMin(jys, keys[j])) continue;
  1413. if(HqData[jys].lpRefData[keys[j]].zjcj ==0) continue;
  1414. if(HqData[jys].lpPreData[keys[j]].zrsp)
  1415. f1 =HqData[jys].lpRefData[keys[j]].zjcj
  1416. -HqData[jys].lpPreData[keys[j]].zrsp;
  1417. else f1 =-100;
  1418. f =f1-fval;
  1419. if(f1>fval)
  1420. {
  1421. key =j;
  1422. fval =f1;
  1423. }
  1424. }
  1425. if(key >i)
  1426. {
  1427. n =keys[i];
  1428. keys[i] =keys[key];
  1429. keys[key] =n;
  1430. }
  1431. MaxMinData[jys][0].recNum[1][count] =key;
  1432. if(++count >=10) break;
  1433. }
  1434. }
  1436. void GetMinZd10(int jys)
  1437. {
  1438. int key, i, j, n;
  1439. float fval, f1, f;
  1440. int count =0;
  1441. int fldNum =8;
  1443. for(i =0; i<10; i++)
  1444. MaxMinData[jys][1].recNum[1][i] =i;
  1446. for(i =0; i<HqData[jys].recCount; i++)
  1447. keys[i] =i;
  1449. for(i =0; i<HqData[jys].recCount; i++)
  1450. {
  1451. if(!IsMaxMin(jys, keys[i])) continue;
  1452. if(HqData[jys].lpRefData[keys[i]].zjcj ==0) continue;
  1453. key =i;
  1454. if(HqData[jys].lpPreData[keys[key]].zrsp)
  1455. fval =HqData[jys].lpRefData[keys[key]].zjcj
  1456. -HqData[jys].lpPreData[keys[key]].zrsp;
  1457. else fval =100;
  1458. for(j =i+1; j<HqData[jys].recCount; j++)
  1459. {
  1460. if(!IsMaxMin(jys, keys[j])) continue;
  1461. if(HqData[jys].lpRefData[keys[j]].zjcj ==0) continue;
  1462. if(HqData[jys].lpPreData[keys[j]].zrsp)
  1463. f1 =HqData[jys].lpRefData[keys[j]].zjcj
  1464. -HqData[jys].lpPreData[keys[j]].zrsp;
  1465. else f1 =100;
  1466. f =f1-fval;
  1467. if(f1<fval)
  1468. {
  1469. key =j;
  1470. fval =f1;
  1471. }
  1472. }
  1473. if(key >i)
  1474. {
  1475. n =keys[i];
  1476. keys[i] =keys[key];
  1477. keys[key] =n;
  1478. }
  1479. MaxMinData[jys][1].recNum[1][count] =key;
  1480. if(++count >=10) break;
  1481. }
  1482. }
  1484. BOOL CheckTpbz(int jys, LPSTR buffer)
  1485. {
  1486. return FALSE;
  1487. }
  1489. BOOL clIsZsRec(int jys, int rec_num)
  1490. {
  1491. if(jys ==0)
  1492. {
  1493. if(!strncmp(HqData[jys].lpPreData[rec_num].zqdm, "99", 2))
  1494. return TRUE;
  1495. }
  1496. else
  1497. if(!strncmp(HqData[jys].lpPreData[rec_num].zqdm, "0000", 4)
  1498. && (HqData[jys].lpPreData[rec_num].zqdm[4] =='0'
  1499. ||HqData[jys].lpPreData[rec_num].zqdm[4] =='1'))
  1500. return TRUE;
  1502. return FALSE;
  1503. }
  1505. LPSTR GetHqFldPos(int jys, int rec_num, int fld_num)
  1506. {
  1507. switch(fld_num)
  1508. {
  1509. case 0:
  1510. return (LPSTR)&HqData[jys].lpPreData[rec_num].zqdm[0];
  1511. case 1:
  1512. return (LPSTR)&HqData[jys].lpPreData[rec_num].zrsp;
  1513. case 2:
  1514. return (LPSTR)&HqData[jys].lpPreData[rec_num].jrkp;
  1515. case 3:
  1516. return (LPSTR)&HqData[jys].lpRefData[rec_num].zgjg;
  1517. case 4:
  1518. return (LPSTR)&HqData[jys].lpRefData[rec_num].zdjg;
  1519. case 5:
  1520. return (LPSTR)&HqData[jys].lpRefData[rec_num].zgjm;
  1521. case 6:
  1522. return (LPSTR)&HqData[jys].lpRefData[rec_num].zdjm;
  1523. case 7:
  1524. return (LPSTR)&HqData[jys].lpRefData[rec_num].zjcj;
  1525. case 8:
  1526. return (LPSTR)&HqData[jys].lpRefData[rec_num].zdf;
  1527. case 9:
  1528. return (LPSTR)&HqData[jys].lpRefData[rec_num].cjss;
  1529. case 10:
  1530. return (LPSTR)&HqData[jys].lpRefData[rec_num].lc;
  1531. case 11:
  1532. return (LPSTR)&HqData[jys].lpRefData[rec_num].npzl;
  1533. case 12:
  1534. return (LPSTR)&HqData[jys].lpRefData[rec_num].wb;
  1535. case 13:
  1536. return (LPSTR)&HqData[jys].lpRefData[rec_num].cjje;
  1537. }
  1538. }
  1540. int GetFloatSort10(int jys, short fldNum, int type, short *lpKeys)
  1541. {
  1542. int key, i, j, n;
  1543. float fval, f1, f;
  1544. int count =0;
  1546. for(i =0; i<10; i++)
  1547. lpKeys[i] =i;
  1549. for(i =0; i<HqData[jys].recCount; i++)
  1550. keys[i] =i;
  1552. for(i =0; i<HqData[jys].recCount; i++)
  1553. {
  1554. if(!IsMaxMin(jys, keys[i])) continue;
  1555. if(HqData[jys].lpRefData[keys[i]].zjcj ==0) continue;
  1556. key =i;
  1557. fval =*(float*)GetHqFldPos(jys, keys[key], fldNum);
  1558. for(j =i+1; j<HqData[jys].recCount; j++)
  1559. {
  1560. if(!IsMaxMin(jys, keys[j])) continue;
  1561. if(HqData[jys].lpRefData[keys[j]].zjcj ==0) continue;
  1562. f1 =*(float *)GetHqFldPos(jys, keys[j], fldNum);
  1563. f =f1-fval;
  1564. if(type ==SORT_UP && f>.0)
  1565. {
  1566. key =j;
  1567. fval =f1;
  1568. }
  1569. else if(type ==SORT_DOWN && f<.0)
  1570. {
  1571. key =j;
  1572. fval =f1;
  1573. }
  1574. }
  1575. if(key >i)
  1576. {
  1577. n =keys[i];
  1578. keys[i] =keys[key];
  1579. keys[key] =n;
  1580. }
  1581. lpKeys[count] =key;
  1582. if(++count >=10) break;
  1583. }
  1584. return 0;
  1585. }
  1587. int GetLongSort10(int jys, short fldNum, int type, short *lpKeys)
  1588. {
  1589. int key, i, j, n;
  1590. int lval, l1, l;
  1591. int count =0;
  1593. for(i =0; i<10; i++)
  1594. lpKeys[i] =i;
  1596. for(i =0; i<HqData[jys].recCount; i++)
  1597. keys[i] =i;
  1599. for(i =0; i<HqData[jys].recCount; i++)
  1600. {
  1601. if(!IsMaxMin(jys, keys[i])) continue;
  1602. if(HqData[jys].lpRefData[keys[i]].zjcj ==0) continue;
  1603. key =i;
  1604. lval =*(int*)GetHqFldPos(jys, keys[key], fldNum);
  1605. for(j =i+1; j<HqData[jys].recCount; j++)
  1606. {
  1607. if(!IsMaxMin(jys, keys[j])) continue;
  1608. if(HqData[jys].lpRefData[keys[j]].zjcj ==0) continue;
  1609. l1 =*(int *)GetHqFldPos(jys, keys[j], fldNum);
  1610. l =l1-lval;
  1611. if(type ==SORT_UP && l>.0)
  1612. {
  1613. key =j;
  1614. lval =l1;
  1615. }
  1616. else if(type ==SORT_DOWN && l<.0)
  1617. {
  1618. key =j;
  1619. lval =l1;
  1620. }
  1621. }
  1622. if(key >i)
  1623. {
  1624. n =keys[i];
  1625. keys[i] =keys[key];
  1626. keys[key] =n;
  1627. }
  1628. lpKeys[count] =key;
  1629. if(++count >=10) break;
  1630. }
  1631. return 0;
  1632. }
  1634. long CalcCjzje(int jys)
  1635. {
  1636. int i;
  1637. long l =0;
  1639. for(i =0; i<HqData[jys].recCount; i++)
  1640. {   
  1641. if(jys==0)
  1642. {
  1643. if(HqData[jys].lpPreData[i].zqdm[0]=='1'||HqData[jys].lpPreData[i].zqdm[0]=='9')
  1644. continue;
  1645. if(HqData[jys].lpPreData[i].zqdm[0]=='3'||HqData[jys].lpPreData[i].zqdm[0]=='8')
  1646. continue;
  1647. }
  1648. if(jys==1)
  1649. {   
  1650. //if(strncmp(HqData[jys].lpPreData[i].zqdm,"70",2)!=0&&strncmp(HqData[jys].lpPreData[i].zqdm,"71",2)!=0)
  1651.             {
  1652. if(HqData[jys].lpPreData[i].zqdm[0]=='0'||HqData[jys].lpPreData[i].zqdm[0]=='1'||
  1653. HqData[jys].lpPreData[i].zqdm[0]=='2'||HqData[jys].lpPreData[i].zqdm[0]=='7')
  1654. continue;
  1655. }
  1656. }
  1657. if(!clIsZsRec(jys, i))    
  1658. l +=HqData[jys].lpRefData[i].cjje;
  1659. }
  1661. return l;
  1662. }
  1664. float CalcNpbl(int jys)
  1665. {
  1666. int i;
  1667. long double lfbuy =0, lftotal =0;
  1668. float lf;
  1670. for(i =0; i<HqData[jys].recCount; i++)
  1671. {   
  1672. if(jys==0)
  1673. {
  1674. if(HqData[jys].lpPreData[i].zqdm[0]=='1'||HqData[jys].lpPreData[i].zqdm[0]=='9')
  1675. continue;
  1676. if(HqData[jys].lpPreData[i].zqdm[0]=='3'||HqData[jys].lpPreData[i].zqdm[0]=='8')
  1677. continue;
  1678. }
  1679. if(jys==1)
  1680. { 
  1681. //if(strncmp(HqData[jys].lpPreData[i].zqdm,"70",2)!=0&&strncmp(HqData[jys].lpPreData[i].zqdm,"71",2)!=0)
  1682.     {
  1683. if(HqData[jys].lpPreData[i].zqdm[0]=='0'||HqData[jys].lpPreData[i].zqdm[0]=='1'||
  1684. HqData[jys].lpPreData[i].zqdm[0]=='2'||HqData[jys].lpPreData[i].zqdm[0]=='7')
  1685. continue;
  1686. }
  1687. }
  1688. if(!clIsZsRec(jys, i))
  1689. {
  1690. lfbuy +=(long double)HqData[jys].lpRefData[i].npzl;
  1691. lftotal +=(long double)HqData[jys].lpRefData[i].cjss;
  1692. }
  1693. }
  1694. if(lftotal ==0) return (float)0;
  1696. lf =(float)(lfbuy/lftotal);
  1697. return lf;
  1698. }
  1700. long CalcCjss(int jys)
  1701. {
  1702. int i;
  1703. long l =0;
  1705. for(i =0; i<HqData[jys].recCount; i++)
  1706. {
  1707. if(jys==0)
  1708. {
  1709. if(HqData[jys].lpPreData[i].zqdm[0]=='1'||HqData[jys].lpPreData[i].zqdm[0]=='9')
  1710. continue;
  1711. if(HqData[jys].lpPreData[i].zqdm[0]=='3'||HqData[jys].lpPreData[i].zqdm[0]=='8')
  1712. continue;
  1713. }
  1714. if(jys==1)
  1715. {    
  1716. //if(strncmp(HqData[jys].lpPreData[i].zqdm,"70",2)!=0&&strncmp(HqData[jys].lpPreData[i].zqdm,"71",2)!=0)
  1717. {
  1718. if(HqData[jys].lpPreData[i].zqdm[0]=='0'||HqData[jys].lpPreData[i].zqdm[0]=='1'||
  1719. HqData[jys].lpPreData[i].zqdm[0]=='2'||HqData[jys].lpPreData[i].zqdm[0]=='7')
  1720. continue;
  1721. }
  1722. }
  1723. if(!clIsZsRec(jys, i))
  1724. l +=HqData[jys].lpRefData[i].cjss;
  1725. }
  1726. return l;
  1727. }
  1729. int UDPBlockingHook(void)
  1730. {
  1731. MSG msg;
  1733. if(PeekMessage(&msg, NULL, 0, 0, PM_REMOVE))
  1734. {
  1735. if(!ghWndMain || !IsDialogMessage(ghWndMain, &msg))
  1736. {
  1737. TranslateMessage(&msg);
  1738. DispatchMessage(&msg);   
  1739. if(msg.message ==WM_QUIT)
  1740. {
  1741. PostQuitMessage(0);
  1742. run_cancelled =TRUE;               
  1743. return FALSE;
  1744. }
  1745. }            
  1746. return TRUE;
  1747. }
  1748. return FALSE;
  1749. }
  1751. int clHqAllocMem(int jys, int recCount)
  1752. {
  1753. static MAX_REC_NUM =1000;
  1754. unsigned int ReqBytes;
  1756. if(recCount>MAX_REC_NUM)
  1757. return -1;
  1759. if(HqData[jys].recCount ==0)
  1760. {
  1761. HqData[jys].recCount =recCount;
  1763. ReqBytes =MAX_REC_NUM*sizeof(HQ_PRE_DATA);
  1764. HqData[jys].lpPreData =(LPHQ_PRE_DATA)GlobalAllocPtr(GHND, 
  1765. ReqBytes);
  1767. ReqBytes =MAX_REC_NUM*sizeof(HQ_REF_DATA);
  1768. HqData[jys].lpRefData =(LPHQ_REF_DATA)GlobalAllocPtr(GHND, 
  1769. ReqBytes);
  1771. ReqBytes =MAX_REC_NUM*HQ_REF_ITEM_COUNT;
  1772. HqData[jys].lpbChanged =(BYTE *)GlobalAllocPtr(GHND, 
  1773. ReqBytes);
  1775. ReqBytes =MAX_REC_NUM*sizeof(GRA_DATA);
  1776. GraphData[jys].lpGraData =(LPGRA_DATA)GlobalAllocPtr(GHND,
  1777. HqData[jys].recCount*sizeof(GRA_DATA));
  1779. ReqBytes =MAX_REC_NUM*sizeof(GRA_HEAD);
  1780. GraphData[jys].lpGraHead =(LPGRA_HEAD)GlobalAllocPtr(GHND,
  1781. ReqBytes);
  1783. ReqBytes =MAX_REC_NUM*sizeof(MMP);
  1784. MmpData[jys].lpMmp =(LPMMP)GlobalAllocPtr(GHND,
  1785. ReqBytes);
  1787. ReqBytes =MAX_REC_NUM;
  1788. MmpData[jys].lpChanged =(BYTE *)GlobalAllocPtr(GHND,
  1789. ReqBytes);
  1791. ReqBytes =MAX_REC_NUM*sizeof(HQ_REF_DATA_V202)+sizeof(short);
  1792. LzwData202[jys].recCount =(short *)GlobalAllocPtr(GHND,
  1793.   ReqBytes);
  1794. LzwData202[jys].lpData202 =(LPHQ_REF_DATA_V202)(LzwData202[jys].recCount +1);
  1795. }
  1796. /*
  1797. else if(HqData[jys].recCount <recCount)
  1798. {
  1799. HqData[jys].recCount =recCount;
  1800. HqData[jys].lpPreData =(LPHQ_PRE_DATA)GlobalReAllocPtr(HqData[jys].lpPreData,
  1801. HqData[jys].recCount*sizeof(HQ_PRE_DATA), GMEM_MOVEABLE);
  1802. HqData[jys].lpRefData =(LPHQ_REF_DATA)GlobalReAllocPtr(HqData[jys].lpRefData,
  1803. HqData[jys].recCount*sizeof(HQ_REF_DATA), GMEM_MOVEABLE);
  1804. HqData[jys].lpbChanged =(BYTE *)GlobalReAllocPtr(HqData[jys].lpbChanged,
  1805. HqData[jys].recCount*HQ_REF_ITEM_COUNT, GMEM_MOVEABLE);
  1806. GraphData[jys].lpGraHead =(LPGRA_HEAD)GlobalReAllocPtr(GraphData[jys].lpGraHead,
  1807. HqData[jys].recCount*sizeof(GRA_HEAD),GMEM_MOVEABLE);
  1808. GraphData[jys].lpGraData =(LPGRA_DATA)GlobalReAllocPtr(GraphData[jys].lpGraData,
  1809. HqData[jys].recCount*sizeof(GRA_DATA),GMEM_MOVEABLE);
  1810. MmpData[jys].lpMmp =(LPMMP)GlobalReAllocPtr(MmpData[jys].lpMmp,
  1811. HqData[jys].recCount*sizeof(MMP), GMEM_MOVEABLE);
  1812. MmpData[jys].lpChanged =(BYTE *)GlobalReAllocPtr(MmpData[jys].lpChanged,
  1813. HqData[jys].recCount, GHND);
  1815. LzwData202[jys].recCount =(short *)GlobalReAllocPtr(LzwData202[jys].recCount,
  1816. HqData[jys].recCount*sizeof(HQ_REF_DATA_V202)+sizeof(short), GMEM_MOVEABLE);
  1818. LzwData202[jys].lpData202 =(LPHQ_REF_DATA_V202)( LzwData202[jys].recCount+1);
  1819. }
  1820. */
  1822. if(HqData[jys].lpPreData ==NULL)
  1823. {
  1824. ErrMsg(ghWndMain, "alloc mem pre data failed!");
  1825. return -1;
  1826. }
  1828. if(HqData[jys].lpRefData ==NULL)
  1829. {
  1830. ErrMsg(ghWndMain, "alloc mem ref data failed!");
  1831. return -1;
  1832. }
  1833. if(HqData[jys].lpbChanged ==NULL)
  1834. {
  1835. ErrMsg(ghWndMain, "alloc mem chg data failed!");
  1836. return -1;
  1837. }
  1838. if(GraphData[jys].lpGraData ==NULL || GraphData[jys].lpGraHead ==NULL)
  1839. {
  1840. ErrMsg(ghWndMain, "alloc mem graph data failed!");
  1841. return -1;
  1842. }
  1843. if(MmpData[jys].lpMmp ==NULL)
  1844. {
  1845. ErrMsg(ghWndMain, "alloc mem mmp failed!");
  1846. return -1;
  1847. }
  1848. if(MmpData[jys].lpChanged ==NULL)
  1849. {
  1850. ErrMsg(ghWndMain, "alloc mem mmp changed failed!");
  1851. return -1;
  1852. }
  1853. if(LzwData202[jys].recCount==NULL)
  1854. {
  1855. ErrMsg(ghWndMain, "alloc mem DataV202 failed!");
  1856. return -1;
  1857. }
  1858. return 0;       
  1859. }
  1861. BOOL IsMaxMin(int jys, int rec_num)
  1862. {
  1863. char c;
  1864. c =HqData[jys].lpPreData[rec_num].zqdm[0];      
  1866. if(clIsZsRec(jys, rec_num)) return FALSE;
  1867. if(jys ==0)
  1868. {
  1869. if(c =='0' || c =='4') return TRUE;             
  1870. }
  1871. else if((c =='0' && !clIsZsRec(jys, rec_num))
  1872. || c =='5' || c=='6')
  1873. return TRUE;
  1875. return FALSE;
  1876. }
  1878. BOOL IsB(int jys, int rec_num)
  1879. {
  1880. if((jys ==0 && HqData[jys].lpPreData[rec_num].zqdm[0] =='2')
  1881. || (jys ==1 && HqData[jys].lpPreData[rec_num].zqdm[0] =='2'))
  1882. return TRUE;
  1883. return FALSE;
  1884. }
  1886. BOOL IsGuoZhai(int jys, int rec_num)
  1887. {
  1888. return FALSE;
  1889. }
  1891. int GetGraData(int jys, int i, LPHQ_REF_DATA lpLastHq)
  1892. {
  1893. float jg1, jg2;
  1895. if(HqData[jys].lpRefData[i].lc>0)
  1896. {
  1897. //计算内盘
  1898. //GraphData[jys].lpGraHead[i].dateNum==date_num;
  1899. GraphData[jys].lpGraData[i].tim=tim;                                    
  1900. if(GraphData[jys].lpGraHead[i].recCount==0)
  1901. {
  1902. //第一次有正量差，开市初始化
  1903. //HqData[jys].lpPreData[i].jrkp=lpLastHq->zjcj;
  1904. //初始化分时数据