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

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

金融证券系统

开发平台：

Visual C++

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