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

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

金融证券系统

开发平台：

Visual C++

CL_DATA.C：源码内容
  1. #include <windows.h>
  2. #include <stdio.h>
  3. #include <stdlib.h>
  4. #include <string.h>
  5. #include <time.h>
  6. #include <io.h>
  8. #include "dbf_data.h"
  10. #include "hq.h"
  11. #include "sv_hq.h"
  13. #include "data.h"
  15. #include "cl_hq.h"
  16. #include "cl_data.h"
  18. extern BOOL run_cancelled;
  19. extern HWND ghWndMain;
  20. extern int date_num, tim;
  21. extern void MsgLocal(LPSTR msg);
  22. extern BOOL ErrMsg(HWND, LPSTR);
  23. extern int UDPBlockingHook(void);
  24. extern void MsgRecv(char far *msg);
  27. //extern long oldCjss[2];
  28. extern char szDataPath[128];
  31. long zs_times[2][20];
  32. BOOL fWrited[2] ={FALSE, FALSE};
  34. int WriteHqAll(int jys)
  35. {
  36. if(WriteHqData(jys) <0) return -1;
  37. if(WriteMmpData(jys) <0) return -1;
  38. if(WriteMaxMinData(jys) <0) return -1;
  40. return 0;
  41. }
  43. int WriteHqData(int jys)
  44. {
  45. _llseek(hfHq[jys], 0, SEEK_SET);
  46. _lwrite(hfHq[jys], (char *)&HqData[jys].recCount, sizeof(short));
  47. if(_hwrite(hfHq[jys], (char *)HqData[jys].lpPreData,
  48. (long)HqData[jys].recCount*sizeof(HQ_PRE_DATA))
  49. !=(long)(HqData[jys].recCount*sizeof(HQ_PRE_DATA)))
  50. {
  51. ErrMsg(ghWndMain, "Error write hqdata");
  52. return -1;
  53. }
  55. if(_hwrite(hfHq[jys], (char *)HqData[jys].lpRefData,
  56. (long)HqData[jys].recCount*sizeof(HQ_REF_DATA))
  57. !=(long)(HqData[jys].recCount*sizeof(HQ_REF_DATA)))
  58. {
  59. ErrMsg(ghWndMain, "Error write hqdata");
  60. return -1;
  61. }
  62. CreateLzwFile(jys);
  63. return 0;
  64. }
  66. //////////////////////////////////////////////////////////////////////////
  67. //Function:to reduce transfer time between server and client,we must build
  68. //         compress data.this prog compress main mass data(szhq.dat.shhq.dat)
  69. //Para    :None
  70. //Return  :if successful return 0,otherwise return -1
  71. //Writer  :lym
  72. //Create  :1997/08/24
  73. //////////////////////////////////////////////////////////////////////////
  74. int CreateLzwFile(int jys)
  75. {
  76. char temp[256]; //,tmp[256];
  77.     OFSTRUCT os;                 
  78.     HQ_REF_DATA_V202  DataV202;
  79.     long i;
  80.     int lzw;
  81.     
  82.     //for(jys=0;jys<2;jys++)
  83.     //{   
  84. if(HqData[jys].recCount==0)
  85. return(-1);
  86. if(jys==0)
  87. sprintf(temp,"%s\hqdata\szhq.202",szDataPath);
  88. else
  89. sprintf(temp,"%s\hqdata\shhq.202",szDataPath);
  91. if((lzw=OpenFile(temp,&os,OF_WRITE|OF_SHARE_DENY_NONE))==HFILE_ERROR)
  92. if((lzw=OpenFile(temp,&os,OF_WRITE|OF_SHARE_DENY_NONE|OF_CREATE))==HFILE_ERROR)
  93. return(-1);
  95. _lwrite(lzw, (char *)&HqData[jys].recCount, sizeof(short));
  96. for(i=0;i<HqData[jys].recCount;i++)
  97. {
  98. if(run_cancelled) break;
  99. memset((char*)&DataV202,0,sizeof(HQ_REF_DATA_V202));
  100.  
  101.   strcpy(DataV202.zqdm,HqData[jys].lpPreData[i].zqdm);
  102.   strcpy(DataV202.zqmc,HqData[jys].lpPreData[i].zqmc);
  103.         
  104.          sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].zdjg*100.00);
  105.   DataV202.zdjg =atol(temp);
  106.  
  107.   sprintf(temp,"%7.2f",HqData[jys].lpPreData[i].zrsp*100.00);
  108.   DataV202.zrsp =atol(temp)-DataV202.zdjg;
  109.  
  110.   sprintf(temp,"%7.2f",HqData[jys].lpPreData[i].jrkp*100.00);
  111.   DataV202.jrkp =atol(temp)-DataV202.zdjg;
  112.  
  113.   sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].zgjg*100.00);
  114.   DataV202.zgjg =atol(temp)-DataV202.zdjg;
  115.  
  116.   sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].zdjm*100.00);
  117.   DataV202.zdjm =atol(temp)-DataV202.zdjg;
  118.  
  119.   sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].zgjm*100.00);
  120.   DataV202.zgjm =atol(temp)-DataV202.zdjg;
  121.  
  122.   sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].zjcj*100.00);
  123.   DataV202.zjjg =atol(temp)-DataV202.zdjg;
  124.  
  125.   sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].wb*100.00);
  126.   DataV202.wb =atol(temp);
  127.  
  128.   DataV202.cjss =HqData[jys].lpRefData[i].cjss;
  129.   DataV202.npzl =HqData[jys].lpRefData[i].npzl;
  130.   DataV202.cjje =HqData[jys].lpRefData[i].cjje;
  131. _lwrite(lzw,(char *)&DataV202,sizeof(HQ_REF_DATA_V202));
  132. }
  133. _lclose(lzw);
  134. return TRUE;
  135. }
  137. int CreateLzwMemData(int jys)
  138. {
  139. char temp[256];
  140.     long i;
  141.     
  142. if(HqData[jys].recCount==0)
  143. return(-1);
  145. *LzwData202[jys].recCount =HqData[jys].recCount;
  147. for(i=0;i<HqData[jys].recCount;i++)
  148. {
  149. if(run_cancelled) break;
  150.   strcpy(LzwData202[jys].lpData202[i].zqdm,
  151. HqData[jys].lpPreData[i].zqdm);
  152.   strcpy(LzwData202[jys].lpData202[i].zqmc,
  153. HqData[jys].lpPreData[i].zqmc);
  154.         
  155.         sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].zdjg*100.00);
  156.   LzwData202[jys].lpData202[i].zdjg =atol(temp);
  157.  
  158.   sprintf(temp,"%7.2f",HqData[jys].lpPreData[i].zrsp*100.00);
  159.   LzwData202[jys].lpData202[i].zrsp =
  160. atol(temp)-LzwData202[jys].lpData202[i].zdjg;
  161.  
  162.   sprintf(temp,"%7.2f",HqData[jys].lpPreData[i].jrkp*100.00);
  163.   LzwData202[jys].lpData202[i].jrkp =atol(temp)-LzwData202[jys].lpData202[i].zdjg;
  164.  
  165.   sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].zgjg*100.00);
  166.   LzwData202[jys].lpData202[i].zgjg =atol(temp)-LzwData202[jys].lpData202[i].zdjg;
  167.  
  168.   sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].zdjm*100.00);
  169.   LzwData202[jys].lpData202[i].zdjm =atol(temp)-LzwData202[jys].lpData202[i].zdjg;
  170.  
  171.   sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].zgjm*100.00);
  172.   LzwData202[jys].lpData202[i].zgjm =atol(temp)-LzwData202[jys].lpData202[i].zdjg;
  173.  
  174.   sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].zjcj*100.00);
  175.   LzwData202[jys].lpData202[i].zjjg =atol(temp)-LzwData202[jys].lpData202[i].zdjg;
  176.  
  177.   sprintf(temp,"%7.2f",HqData[jys].lpRefData[i].wb*100.00);
  178.   LzwData202[jys].lpData202[i].wb =atol(temp);
  179.  
  180.   LzwData202[jys].lpData202[i].cjss =HqData[jys].lpRefData[i].cjss;
  181.   LzwData202[jys].lpData202[i].npzl =HqData[jys].lpRefData[i].npzl;
  182.   LzwData202[jys].lpData202[i].cjje =HqData[jys].lpRefData[i].cjje;
  183. }
  184. return TRUE;
  185. }
  187. int WriteDpData(int jys)
  188. {
  189. _llseek(hfDp, jys*sizeof(DpData[jys]), SEEK_SET);
  190. _lwrite(hfDp, (char*)&DpData[jys], sizeof(DpData[jys]));
  192. return 0;
  193. }
  195. int WriteMmpData(int jys)
  196. {
  197. _llseek(hfMmp[jys], 0, SEEK_SET);
  199. if(_hwrite(hfMmp[jys], (char *)MmpData[jys].lpMmp, (long)sizeof(MMP)*HqData[jys].recCount)
  200. !=(long)sizeof(MMP)*HqData[jys].recCount)
  201. {
  202. ErrMsg(NULL, "Write mmp failed");
  203. return -1;
  204. }
  206. return 0;
  207. }
  209. int WriteMaxMinData(int jys)
  210. {
  211. _llseek(hfMaxMin[jys], 0, SEEK_SET);
  212. _lwrite(hfMaxMin[jys], (char *)&MaxMinData[jys], sizeof(MAXMIN_DATA)*2);
  214. return 0;
  215. }
  217. long max_l(long val1, long val2)
  218. {
  219. return (val1>val2)? val1:val2;
  220. }
  221. long min_l(long val1, long val2)
  222. {
  223. return (val1<val2)? val1:val2;
  224. }
  225. float max_f(float val1, float val2)
  226. {
  227. return (val1>val2)? val1:val2;
  228. }
  229. float min_f(float val1, float val2)
  230. {
  231. return (val1<val2)? val1:val2;
  232. }
  234. //////////////////////////////////////////////////
  235. //功能 ：读取分时数据文件，初始化内存分时数据头部信息
  236. //参数 ：
  237. //    jys---交易所编码
  238. //返回码 ：
  239. //    0  ---成功
  240. //         -1 ---失败
  241. //修改日期 ：1997/10/15
  242.   
  243. int CheckGraHead(int jys)
  244. {
  245. int i;
  246. char temp[128];
  247. HFILE hFile;
  248. OFSTRUCT os;
  250. wsprintf(temp, "检查分时数据头:%d", jys);
  251. MsgLocal(temp);
  252. for(i =0; i<HqData[jys].recCount; i++)
  253. {
  254. while(UDPBlockingHook());
  255. if(run_cancelled) break;
  257. wsprintf(temp, "%s\%s.dat",
  258. GraphData[jys].szGraPath,
  259. HqData[jys].lpPreData[i].zqdm);
  260. hFile =OpenFile(temp, &os, OF_SHARE_DENY_NONE|OF_READ);
  261. //打开文件失败，必需重新初始化内存分时数据头部信息
  262. if(hFile ==HFILE_ERROR)
  263. goto reset_values;
  264. else
  265. {
  266. //该内存分时数据头部信息读不出，必需重新初始化
  267. if(_lread(hFile, &GraphData[jys].lpGraHead[i],
  268. sizeof(GRA_HEAD)) !=sizeof(GRA_HEAD))
  269. goto reset_values;
  270. //该内存分时数据头部信息日期错，必需重新初始化
  271. if(GraphData[jys].lpGraHead[i].dateNum !=date_num)
  272. goto reset_values;
  273. _lclose(hFile);
  274. //至此说明该内存分时数据头部信息正确，但如存在成交量查，则必须调整
  275. //内存行情数据的内盘总量
  276. HqData[jys].lpRefData[i].npzl =GraphData[jys].lpGraHead[i].npzl
  277. +(HqData[jys].lpRefData[i].cjss-GraphData[jys].lpGraHead[i].npzl
  278. -GraphData[jys].lpGraHead[i].wpzl)/2;
  279. continue;
  280. }
  281. reset_values:
  282. HqData[jys].lpRefData[i].npzl =HqData[jys].lpRefData[i].cjss/2;
  283. memset(&GraphData[jys].lpGraHead[i], 0, sizeof(GRA_HEAD));
  284. GraphData[jys].lpGraHead[i].dateNum =date_num;
  285. GraphData[jys].lpGraHead[i].zrsp =HqData[jys].lpPreData[i].zrsp;
  286. GraphData[jys].lpGraHead[i].zgjg =GraphData[jys].lpGraHead[i].zdjg
  287. =HqData[jys].lpRefData[i].zjcj-HqData[jys].lpPreData[i].zrsp;
  288. if(hFile ==HFILE_ERROR)
  289. {
  290. hFile =OpenFile(temp, &os, OF_SHARE_DENY_NONE|OF_CREATE|OF_READWRITE);
  291. if(hFile ==HFILE_ERROR) continue;
  292. }
  293. _lclose(hFile);
  294. }
  295. return 0;
  296. }
  298. BOOL WriteGraData(int jys,int i)
  299. { 
  300. char tmp[50];
  301. HFILE hFile;
  302. OFSTRUCT os;
  303. UINT ret;
  305. wsprintf(tmp, "%s\%s.dat", GraphData[jys].szGraPath,
  306. HqData[jys].lpPreData[i].zqdm);
  307. //GraphData[jys].lpGraHead[i].dateNum =date_num;
  308. //GraphData[jys].lpGraHead.zrsp =HqData[jys].lpRefData[i].zrsp;
  309. //GraphData[jys].lpGraData[i].tim =tim;
  310. hFile =OpenFile(tmp, &os, OF_SHARE_DENY_NONE|OF_READWRITE);
  311. if(hFile ==HFILE_ERROR)
  312. return FALSE;
  313. if(_llseek(hFile, sizeof(GRA_HEAD)+(GraphData[jys].lpGraHead[i].recCount-1)*sizeof(GRA_DATA),
  314. SEEK_SET) ==HFILE_ERROR)
  315. {
  316. _lclose(hFile);
  317. return FALSE;
  318. }
  319. ret =_lwrite(hFile, (char *)&GraphData[jys].lpGraData[i],sizeof(GRA_DATA));
  321. _llseek(hFile, 0, SEEK_SET);
  322. ret =_lwrite(hFile, (char *)&GraphData[jys].lpGraHead[i],sizeof(GRA_HEAD));
  323. _lclose(hFile);
  325. return TRUE;
  326. }
  328. int WriteMinData(int jys)
  329. {
  330. return 0;
  331. }
  333. BOOL WriteDayData(int jys)
  334. {
  335. int i;
  336. long day_cur;
  337. char tmp[128];
  338. DAY_DATA dayData;
  339. HFILE hFile;
  340. OFSTRUCT os;
  341. time_t ltime;
  342. struct tm *ptm;
  343. //static BOOL fWrited[2] ={FALSE, FALSE};
  344. long len;
  345.     
  346. if(fWrited[jys])
  347. {
  348. MsgLocal("history data already writed!");
  349. return TRUE;
  350. }
  352. MsgLocal("Write day data...");
  353.     
  354. time(&ltime);
  355. ptm =localtime(&ltime);
  356. day_cur =(long)(1900+ptm->tm_year)*10000+(long)(ptm->tm_mon+1)*100+ptm->tm_mday;
  358. for (i=0;i<HqData[jys].recCount;i++) 
  359. {         
  360. while(UDPBlockingHook());
  361. if(run_cancelled) break;
  363. if(GraphData[jys].lpGraHead[i].recCount <=0) continue;
  365. wsprintf(tmp, "%s\%s\%s.day", szDataPath, (jys ==0)?"SZDAY":"SHDAY",
  366. HqData[jys].lpPreData[i].zqdm);                          
  367. hFile =OpenFile(tmp, &os, OF_SHARE_DENY_NONE|OF_READWRITE);
  368. if(hFile ==HFILE_ERROR)
  369. {
  370. hFile =OpenFile(tmp, &os, OF_SHARE_DENY_NONE|OF_CREATE|OF_READWRITE);
  371. if(hFile ==HFILE_ERROR)
  372. {
  373. ErrMsg(NULL, "Create file failed");
  374. ErrMsg(NULL, tmp);
  375. continue;
  376. }
  377. }
  378. else
  379. {
  380. _llseek(hFile, 0, SEEK_SET);
  381. len =_llseek(hFile, 0, SEEK_END);
  382. if(len!=0)
  383. {
  384. if(_llseek(hFile, len-sizeof(dayData), SEEK_SET) ==HFILE_ERROR)
  385. {
  386. _llseek(hFile, 0, SEEK_SET);
  387. }
  388. else if(_lread(hFile, &dayData, sizeof(dayData))
  389. !=sizeof(dayData))
  390. {
  391. ErrMsg(NULL, "Read file failed");
  392. ErrMsg(NULL, tmp);
  393. _lclose(hFile);
  394. continue;
  395. }
  396. else if(dayData.day ==day_cur)
  397. {
  398. _lclose(hFile);
  399. continue;
  400. }
  401. }
  402. }
  403. dayData.day =day_cur;
  404. dayData.kpjg =HqData[jys].lpPreData[i].jrkp;
  405. dayData.spjg =HqData[jys].lpRefData[i].zjcj;
  406. dayData.zgjg =HqData[jys].lpRefData[i].zgjg;
  407. dayData.zdjg =HqData[jys].lpRefData[i].zdjg;
  408. dayData.cjss =HqData[jys].lpRefData[i].cjss;
  409. dayData.cjje =HqData[jys].lpRefData[i].cjje;
  411. _lwrite(hFile,(char *)&dayData,sizeof(DAY_DATA));
  413. _lclose(hFile);
  414. }    
  416. MsgLocal("Write day data ok");
  417. fWrited[jys] =TRUE;
  419. return TRUE;
  420. }
  422. BOOL WriteWeekData(int jys)
  423. {
  424. int i,j;
  425. char tmp[100];
  426. HISTORY_DATA WeekData,DayData,NextDayData;
  427. HFILE hWeekFile,hDayFile;
  428. OFSTRUCT os;
  429. time_t c_time1,c_time2;
  430. static BOOL fWrited[2] ={FALSE, FALSE};
  431.     
  432. if(fWrited[jys])
  433. {
  434. MsgLocal("week data already writed");
  435. return TRUE;
  436. }
  437. MsgLocal("Write week data...");
  438. for (i=0;i<HqData[jys].recCount;i++) 
  439. {   
  440. while(UDPBlockingHook());
  441. if(run_cancelled) break;
  442. //打开日线文件
  443. memset(tmp,0,100);                                                              
  444. if(jys==0)
  445. wsprintf(tmp, "%s%s.day","szase\day\" ,
  446. HqData[jys].lpPreData[i].zqdm);                          
  447. else
  448. wsprintf(tmp, "%s%s.day","shase\day\" ,
  449. HqData[jys].lpPreData[i].zqdm);                          
  451. //MsgLocal(HqData[jys].lpPreData[i].zqdm);      
  452. hDayFile =OpenFile(tmp, &os, OF_SHARE_DENY_NONE|OF_READWRITE);
  453. if(hDayFile ==HFILE_ERROR)
  454. {
  455. _lclose(hDayFile);
  456. continue;               
  457. }
  458. _llseek(hDayFile,-1*(long)(sizeof(HISTORY_DATA)),SEEK_END);
  459. if(_lread(hDayFile,&DayData,sizeof(HISTORY_DATA))!=
  460. sizeof(HISTORY_DATA))
  461. {          
  462. _lclose(hDayFile);      
  463. continue;
  464. }        
  466. memcpy(&WeekData,&DayData,sizeof(HISTORY_DATA));        
  467. memcpy(&c_time1,DayData.date+6,sizeof(time_t));
  469. j=2;            
  470. while(TRUE)
  471. {   
  472. if(j>7) break;
  473.     _llseek(hDayFile,-j*(long)(sizeof(HISTORY_DATA)),SEEK_END);
  474. if(_lread(hDayFile,&NextDayData,sizeof(HISTORY_DATA))!=
  475. sizeof(HISTORY_DATA))                           
  476. break;                          
  477. memcpy(&c_time2,NextDayData.date+6,sizeof(time_t));      
  478. if((int)(difftime(c_time1,c_time2)/(24.00*60.00))>=7)
  479. break;
  480. //计算周线  
  481. WeekData.ks=NextDayData.ks;
  482. WeekData.cj+=NextDayData.cj;
  483. if(WeekData.zg<NextDayData.zg)  WeekData.zg=NextDayData.zg;
  484. if(WeekData.zd>NextDayData.zd)  WeekData.zg=NextDayData.zd;                     
  485. j++;    
  486. }               
  487. //写周线文件            
  488. if(jys==0)
  489. wsprintf(tmp, "%s%s.wek","szase\week\",
  490. HqData[jys].lpPreData[i].zqdm);
  491. else
  492. wsprintf(tmp, "%s%s.wek","shase\week\",
  493. HqData[jys].lpPreData[i].zqdm);
  494. hWeekFile =OpenFile(tmp, &os, OF_SHARE_DENY_NONE|OF_READWRITE);
  495. if(hWeekFile ==HFILE_ERROR)
  496. {
  497. hWeekFile =OpenFile(tmp, &os, OF_SHARE_DENY_NONE|OF_CREATE|OF_READWRITE);
  498. }  
  499. _llseek(hWeekFile,0L,SEEK_END);
  500. _lwrite(hWeekFile,(char*)&WeekData,sizeof(HISTORY_DATA));
  501. _lclose(hWeekFile);
  502. _lclose(hDayFile);
  503.     }
  504. MsgLocal("Write week data ok");
  505. fWrited[jys] =TRUE;
  506. return TRUE;
  507. }
  509. BOOL WriteMonthData(int jys)
  510. {
  511.     int i,j;
  512.     char tmp[100];
  513.     HISTORY_DATA WeekData,MonthData,NextWeekData;
  514. HFILE hWeekFile,hMonthFile;
  515. OFSTRUCT os;
  516. static BOOL fWrited[2] ={FALSE, FALSE};
  518. if(fWrited[jys])
  519. {
  520. MsgLocal("month data already writed!");
  521. return TRUE;
  522. }
  523. MsgLocal("Write month data...");
  524. for (i=0;i<HqData[jys].recCount;i++) 
  525. {   
  526. while(UDPBlockingHook());
  527. if(run_cancelled) break;
  528. //打开周线文件
  529.     if(jys==0)
  530. wsprintf(tmp, "%s%s.wek","szase\week\" ,
  531. HqData[jys].lpPreData[i].zqdm);                          
  532. else
  533. wsprintf(tmp, "%s%s.wek","shase\week\" ,
  534. HqData[jys].lpPreData[i].zqdm);                          
  536. //MsgLocal(HqData[jys].lpPreData[i].zqdm);      
  537. hWeekFile =OpenFile(tmp, &os, OF_SHARE_DENY_NONE|OF_READWRITE);
  538. if(hWeekFile ==HFILE_ERROR)
  539. {
  540. _lclose(hWeekFile);
  541. continue;               
  542. }
  543. _llseek(hWeekFile,-1*(long)(sizeof(HISTORY_DATA)),SEEK_END);
  544. if(_lread(hWeekFile,&WeekData,sizeof(HISTORY_DATA))!=
  545. sizeof(HISTORY_DATA))
  546. {          
  547. _lclose(hWeekFile);     
  548. continue;
  549. }        
  551. memcpy(&MonthData,&WeekData,sizeof(HISTORY_DATA));        
  553. j=2;            
  554. while(TRUE)
  555. {   
  556. if(j>31)        break;
  557.     _llseek(hWeekFile,-j*(long)(sizeof(HISTORY_DATA)),SEEK_END);
  558. if(_lread(hWeekFile,&NextWeekData,sizeof(HISTORY_DATA))!=
  559. sizeof(HISTORY_DATA))                           
  560. break;                  
  561. if(!strncmp(WeekData.date+2,NextWeekData.date+2,2))
  562. break;
  563. //计算月线  
  564. MonthData.ks=NextWeekData.ks;
  565. MonthData.cj+=NextWeekData.cj;
  566. if(MonthData.zg<NextWeekData.zg)  MonthData.zg=NextWeekData.zg;
  567. if(MonthData.zd>NextWeekData.zd)  MonthData.zg=NextWeekData.zd;                 
  568. j++;    
  569. }               
  570. //写月线文件            
  571. if(jys==0)
  572. wsprintf(tmp, "%s%s.mot","szase\month\",
  573. HqData[jys].lpPreData[i].zqdm);
  574. else
  575. wsprintf(tmp, "%s%s.mot","shase\month\",
  576. HqData[jys].lpPreData[i].zqdm);
  577. hMonthFile =OpenFile(tmp, &os, OF_SHARE_DENY_NONE|OF_READWRITE);
  578. if(hMonthFile ==HFILE_ERROR)
  579. {
  580. hMonthFile =OpenFile(tmp, &os, OF_SHARE_DENY_NONE|OF_CREATE|OF_READWRITE);
  581. }  
  582. _llseek(hMonthFile,0L,SEEK_END);
  583. _lwrite(hMonthFile,(char*)&MonthData,sizeof(HISTORY_DATA));
  584. _lclose(hMonthFile);
  585. _lclose(hWeekFile);
  586.     }
  587. MsgLocal("Write month data ok");
  588. fWrited[jys] =TRUE;
  589. return TRUE;
  590. }