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

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

金融证券系统

开发平台：

Visual C++

Main.c：源码内容
  1. /* sv_comm:数据通讯机。将变化数据主动发送到每个client端。多线程
  2. *  by lgd/Paladin.InetSoft guangzhou，1996.9
  3. *  modify by lym(修改后作者里却不愿写上原作者的一个人) guangzhou，1997.4-1998
  4. */
  5. #include <windows.h>
  6. #include <stdio.h>
  7. #include <string.h>
  8. #include <time.h>
  9. #include <stdlib.h>
  10. #include "resource.h"
  11. #include "main.h"
  12. #include "pctcp.h"
  13. #include "hq.h"
  14. #include "hqdest.h"
  15. #include "jydest.h"
  16. #include "sv_hq.h"
  17. #include "sv_jy.h"
  18. #include "sv_tcp.h"
  19. #include "zx.h"
  20. #include "data.h"
  21. #include "monitor.h"
  22. #include "rsa.h"
  24. #include "cl_hq.h"
  25. #include "cl_main.h"
  26. #include "cl_data.h"
  28. #define WND_CAPTION (LPSTR)"数据通讯服务"
  29.  
  30. extern CRITICAL_SECTION hqCriticalSection;
  32. LRESULT CALLBACK MainDlgProc(HWND, UINT, WPARAM, LPARAM);
  34. HWND ghWndMain =NULL;
  35. HINSTANCE ghInstance =NULL;
  37. extern MONITOR Monitor;
  38. extern BOOL HqIsRun;
  40. extern long TF_AnaRecvData(int sd);
  41. extern long TF_ScanJyDest(void);
  44. extern DEST_INFO dest_info[];
  45. extern int dest_info_count;
  46. extern int DesInit(void);
  47. extern HINSTANCE hDesDll;
  49. void SetHqUsers(int count);
  50. void SetJyUsers(int count);
  52. extern BOOL fUseJy,fTestJy,fRsa;
  53. extern LPSTR GetError(LPSTR err_prefix);
  54. extern char szNewsPath[128],szNewsSrc[128];
  56. extern int CreateNewsManagerThread(void);
  58. //LONG g_lNumReaders =-1;
  59. //HANDLE g_hEventDataReady;
  60. //HANDLE g_hSemReaders;
  62. HANDLE g_hEventDataWrite;
  64. int WINAPI WinMain(HINSTANCE hInstance, HINSTANCE hInstPre,
  65. LPSTR lpszCmdLine, int nCmdShow)
  66.  {
  67. HWND hwnd;
  68. FARPROC lpDlgProc;
  70. if(hInstPre)
  71. {
  72. hwnd =FindWindow(NULL, WND_CAPTION);
  73. if(hwnd)
  74. SetFocus(hwnd);
  75. return FALSE;
  76. }
  77.     
  78. ghInstance =hInstance;
  80. InitializeCriticalSection(&hqCriticalSection);
  81. if(!AppInit())
  82. {
  83. ErrMsg(NULL, "应用初始化失败!");
  84. goto appexit;
  85. }
  87. lpDlgProc =(FARPROC)MakeProcInstance((FARPROC)MainDlgProc, hInstance);
  88. if(lpDlgProc ==NULL)
  89. {
  90. ErrMsg(NULL, "不能建立对话框!");
  91. goto appexit;
  92. }
  93. DialogBox(hInstance, MAKEINTRESOURCE(IDD_MAIN), NULL, lpDlgProc);
  94. FreeProcInstance(lpDlgProc);
  96. appexit:
  97. AppExit();
  98. DeleteCriticalSection(&hqCriticalSection);
  100. return 0;
  101. }
  103. FILE *fpMsg =NULL;
  104. BOOL AppInit(void)
  105. {
  106. SetHandleCount(110);
  108. GlobalVaryInit();
  110. if(!DestInit())
  111. {
  112. ErrMsg(NULL, "行情目标地址表初始化失败!");
  113. return FALSE;
  114. }
  115. if(!JyDestInit())
  116. {
  117. ErrMsg(NULL, "交易目标地址表初始化失败!");
  118. return FALSE;
  119. }
  121. if(IsClectRun)
  122. {
  123. if(clHqInit() <0)
  124. {
  125. ErrMsg(NULL, "数据采集初始化失败!");
  126. return FALSE;
  127. }
  128. }
  129. else
  130. {
  131. if(HqInit() <0)
  132. {
  133. ErrMsg(NULL, "行情初始化失败!");
  134. return FALSE;
  135. }
  136. }
  138. if(JyInit() <0)
  139. {
  140. ErrMsg(NULL, "交易初始化失败!");
  141. //return FALSE;
  142. }
  143. if(MonitorInit()<0)
  144.     {
  145. ErrMsg(NULL,"用户监视初始化失败!");
  146. }
  147. if(PCTCPInit() !=0)
  148. {
  149. ErrMsg(NULL, "通讯初始化失败!");
  150. return FALSE;
  151. }
  152. return TRUE;
  153. }
  155. void AppExit(void)
  156. {
  157. static BOOL fExit =FALSE;
  159. if(fExit) return;
  160. fExit =TRUE;
  162. if(IsClectRun)
  163. clHqExit();
  164. else
  165. HqExit();
  167. JyExit();
  168. MonitorExit();
  169. DestExit();
  170. JyDestExit();
  171. PCTCPExit();
  172. }
  174. short total_times =0;
  175. extern int sdHq, sdJy;
  176. extern int BindSocket(HWND);
  177. extern void HqDestSendClose(void);
  179. LRESULT CALLBACK MainDlgProc(HWND hDlg, UINT message,
  180. WPARAM wParam, LPARAM lParam)
  181. {
  182. char dt[40];
  183. DWORD dw;
  184. char temp[400];
  185. int sdTmp =-1,sdTmp1;
  186. int i;
  187. // static int j=0;
  188. // static time_t ScanTim=0;
  190. //HANDLE hThrd;
  191. //LONG lThreadId;
  193. switch(message)
  194. {
  195. case WM_INITDIALOG:
  196. remove("\sv_com32.log");
  197. SetWindowText(hDlg, WND_CAPTION);
  198. ghWndMain =hDlg;
  199. g_hEventDataWrite =CreateEvent(NULL,TRUE,FALSE,NULL);
  200. _strdate(dt);
  201. strcat(dt, " ");
  202. _strtime(&dt[strlen(dt)]);
  203. SetDlgItemText(hDlg, IDC_STARTTIME, dt);
  204. SetDlgItemText(hDlg, IDC_STATIC1,"启动时间");
  205. SetDlgItemText(hDlg, IDC_STATIC2,"本地状态");
  206. SetDlgItemText(hDlg, IDC_STATIC3,"接收信息");
  207. SetDlgItemText(hDlg, IDC_STATIC4,"发送信息");
  208. SetDlgItemText(hDlg, IDC_STATIC5,"行情用户");
  209. SetDlgItemText(hDlg, IDC_STATIC6,"交易用户");
  210. SetDlgItemText(hDlg, IDC_STATIC7,"错误信息");
  211. if(BindSocket(hDlg) <0)
  212. {
  213. ErrMsg(hDlg, "BindSocket失败!");
  214. EndDialog(hDlg, 0);
  215. return FALSE;
  216. }
  218. ReadySysFile();
  219. PostMessage(hDlg, WM_HQ_INIT, 0, 0L);
  221. //if(Monitor.IsRun)
  222. // SetTimer(hDlg,1,Monitor.CheckPoint*60*1000,NULL);
  224. if(fUseJy||fTestJy)
  225. SetTimer(hDlg,4,9000,NULL);
  226. return TRUE;
  227. case WM_TIMER:
  228. /*
  229. if(wParam==1)
  230. {
  231. for(j =0; j<dest_info_count; j++)
  232. {
  233. lpDestTmp=&dest_info[j];
  234. if(!lpDestTmp) break;
  235. if(lpDestTmp->isDead)
  236. continue;
  237. if(strlen(lpDestTmp->userID)==0||lpDestTmp->recNum==0)
  238. continue;
  240. rtime=WriteUserStatus(lpDestTmp->recNum,
  241. (int)(difftime(time(NULL),lpDestTmp->startTime)/60),'F',"CHECKPOINT");
  242. lpDestTmp->startTime=time(NULL);
  243. if(rtime<=0)
  244. {
  245. SendMsg(lpDestTmp->sd,"你的时间用完!");
  246. HqDestSetDeadByPrt(lpDestTmp);
  247. }
  248. }
  249. }
  250. */
  252. if(wParam ==4)
  253. {
  254. //MsgLocal("扫描交易用户...");
  255. KillTimer(hDlg,4);
  256. TF_ScanJyDest();
  257. SetTimer(hDlg,4,500,NULL);
  258. //MsgLocal("扫描成功");
  259. }
  260. break;
  261. case WM_HQ_INIT:
  262. MsgLocal("初始化行情...");
  264. if(fUseJy) DesInit();
  266. ReadHq(0);
  267. ReadHq(1);
  268. CreateLzwMemData(0);
  269. CreateLzwMemData(1);
  271. if(IsClectRun)
  272. {
  273. if(CreateClectThread()<0)
  274. ErrMsg(ghWndMain, "CreateClectThread失败!");
  275. }
  276. else
  277. SetEvent(g_hEventDataWrite);
  279. //CheckTime();
  281. if(HqIsRun)
  282. {
  283. if(CreateScanDestThread() <0)
  284. ErrMsg(ghWndMain, "CreateScanDestThread失败!");
  285. }
  286. if(fUseJy)
  287. {
  288. if(CreateScanJyDestThread() <0)
  289. ErrMsg(ghWndMain, "CreateScanJyDestThread失败!");
  290. }
  291. if(szNewsPath[0]!=0 &&szNewsSrc[0]!=0)
  292. {
  293. if(CreateNewsManagerThread()<0)
  294. ErrMsg(ghWndMain, "Failed to CreateNewsManagerThread!");
  295. }
  296. if(fRsa)
  297. EnableWindow(GetDlgItem(hDlg,IDC_RSA_INIT),TRUE);
  298. MsgLocal("初始化行情成功");
  300. if(HqIsRun)
  301. {
  302. sdTmp1 =listen(sdHq,SOMAXCONN);
  303. if(sdTmp1 ==SOCKET_ERROR)
  304. {
  305. ErrMsg(NULL, GetError("来自BindSocket:listen()"));
  306. return -1;
  307. }
  308. }
  309. if(fUseJy)
  310. {
  311. sdTmp1=listen(sdJy,SOMAXCONN); //SOMAXCONN);
  312. if(sdTmp1==SOCKET_ERROR)
  313. ErrMsg(ghWndMain,GetError("来自Main:JY/listen()"));
  314. }
  315. break;
  316. case WM_UDP_HQ:
  317. sdTmp =(int)wParam;
  318. if(!HqIsRun) break;
  319. switch(lParam)
  320. {
  321. case FD_ACCEPT:
  322. sdTmp1=accept(sdHq, NULL, NULL);
  323. if(sdTmp1==INVALID_SOCKET)
  324. {
  325. ErrMsg(ghWndMain,GetError("来自Main:HQ/accept()"));
  326. break;
  327. }
  328. else
  329. {
  330. i =WSAAsyncSelect(sdTmp1, hDlg, WM_UDP_HQ, FD_READ);
  331. }
  332. //sdTmp1=listen(sdHq, 0);
  333. //if(sdTmp1==SOCKET_ERROR)
  334. // ErrMsg(ghWndMain,GetError("来自Main:HQ/listen()"));
  335. break;
  336. case FD_READ:
  337. AnaRecvData(sdTmp,0);
  338. break;
  339. }
  340. break;
  342. case WM_UDP_JY:
  343. sdTmp =(int)wParam;
  344. switch(lParam)
  345. {
  346. case FD_ACCEPT:
  347. sdTmp1=accept(sdJy, NULL, NULL);
  348. if(sdTmp1==INVALID_SOCKET)
  349. {
  350. ErrMsg(ghWndMain,GetError("来自Main:JY/accept()"));
  351. break;
  352. }
  353. //else
  354. //{
  355. // i =WSAAsyncSelect(sdTmp1, hDlg, WM_UDP_JY, FD_READ);
  356. //}
  357. //sdTmp1=listen(sdJy,SOMAXCONN);
  358. //if(sdTmp1==SOCKET_ERROR)
  359. // ErrMsg(ghWndMain,GetError("来自Main:JY/listen()"));
  360. break;
  361. case FD_READ:
  362. AnaRecvData(sdTmp,1);
  363. break;
  364. }
  365. break;
  366. case WM_COMMAND:
  367. switch(wParam)
  368. {
  369. case IDOK:
  370. if(GetFocus() ==GetDlgItem(hDlg, IDL_MSG))
  371. {
  372. dw =SendDlgItemMessage(hDlg, IDL_MSG, LB_GETCURSEL, 0, 0L);
  373. if(dw !=LB_ERR)
  374. {
  375. SendDlgItemMessage(hDlg, IDL_MSG, LB_GETTEXT, (int)dw, (LPARAM)(LPSTR)temp);
  376. MessageBox(hDlg, temp, "请您注意", MB_OK);
  377. }
  378. }
  379. break;
  380. case IDC_RSA_INIT:
  381. if(fRsa)
  382. {
  383. if(MessageBox(hDlg, "需要运行很长时间，您要继续吗?", WND_CAPTION,
  384. MB_YESNO|MB_ICONQUESTION|MB_DEFBUTTON2) ==IDNO)
  385. break;
  386. MsgLocal("初始化RSA加密参数");
  387. EnableWindow(GetDlgItem(hDlg,IDC_RSA_INIT),FALSE);
  388. if(RsaPrepare(SK,PK,R))
  389. {
  390. WriteRsaFile(R,PK,SK);
  391. }
  392. EnableWindow(GetDlgItem(hDlg,IDC_RSA_INIT),TRUE);
  393. }
  394. break;
  395. case IDCANCEL:
  396. if(MessageBox(hDlg, "您要退出吗?", WND_CAPTION,
  397. MB_YESNO|MB_ICONQUESTION|MB_DEFBUTTON2) ==IDNO)
  398. run_cancelled =FALSE;
  399. else
  400. {
  401. run_cancelled =TRUE;
  402. HqDestSendClose();
  404. if(fUseJy || fTestJy)
  405. KillTimer(hDlg,4);
  407. Sleep(2000);
  409. // WaitForSingleObject(g_hEventDataWrite,INFINITE);
  410. CloseHandle(g_hEventDataWrite);
  412. EndDialog(hDlg, 0);
  413. if(fUseJy) FreeLibrary(hDesDll);
  414. ghWndMain =NULL;
  415. PostQuitMessage(0);   // not used
  416. }
  417. break;
  418. }
  419. break;
  420. }
  422. return FALSE;
  423. }
  425. extern void WriteMsg(LPSTR msg);
  427. BOOL ErrMsg(HWND hWnd, LPSTR msg)
  428. {
  429. // char tmp[256];
  430. static BOOL msgbox_exist =FALSE;
  431. DWORD dw;
  433. //WriteMsg(msg);
  434. //if(ghWndMain)
  435. //{
  436. if((dw =SendDlgItemMessage(ghWndMain, IDL_MSG,
  437. LB_ADDSTRING, 0, (LPARAM)(LPSTR)msg))>1000)
  438. SendDlgItemMessage(ghWndMain, IDL_MSG,
  439. LB_RESETCONTENT, 0, (LPARAM)(LPSTR)msg);
  440. else SendDlgItemMessage(ghWndMain, IDL_MSG,
  441. LB_SETCURSEL, (int)dw, 0L);
  442. //}
  443. //else
  444. //if(!msgbox_exist)
  445. //{
  446. // msgbox_exist =TRUE;
  447. // if(strlen(msg)>=250) *(msg+250) =0;
  448. // wsprintf(tmp, "错误: %s", msg);
  449. // MessageBox(hWnd, tmp, WND_CAPTION, MB_OK|MB_ICONSTOP);
  450. // msgbox_exist =FALSE;
  451. //}
  453. return FALSE;
  454. }
  456. void ErrPrint(char *msg)
  457. {
  458. ErrMsg(ghWndMain, msg);
  459. }
  461. void DelSpaces(LPSTR lpstr)
  462. {
  463. return;
  464. }
  466. BOOL GetInitString(char *Entry, char *Item, char *buf)
  467. {
  468. GetPrivateProfileString(Entry, Item, "", buf, 256, "sv_com32.ini");
  469. if(*buf ==0) return FALSE;
  470. return TRUE;
  471. }
  473. BOOL PutInitString(char *Entry, char *Item, char *buf)
  474. {
  475. return WritePrivateProfileString(Entry, Item, buf, "sv_com32.ini");
  476. }
  478. void MsgSend(char far *msg)
  479. {
  480. SetDlgItemText(ghWndMain, IDC_STATUS_SEND, msg);
  481. }
  483. void MsgRecv(char far *msg)
  484. {
  485. SetDlgItemText(ghWndMain, IDC_STATUS_RECV, msg);
  486. }
  488. void MsgLocal(LPSTR msg)
  489. {
  490. SetDlgItemText(ghWndMain, IDC_STATE_LOCAL, msg);
  491. }
  493. short date_num =-1, tim =-1;
  494. short CheckTime(void)
  495. {
  496. char tmp[40];
  497. LPSTR tok;
  498. short jys;
  500. if(date_num <0)
  501. {
  502. _strdate(tmp);
  503. strtok(tmp, "/");
  504. tok =strtok(NULL, "/");
  505. date_num =atoi(tok);
  506. }
  507. _strtime(tmp);
  508. MsgLocal(tmp);
  509. tok =strtok(tmp, ":");
  510. tim =atoi(tok)*60;
  511. tim +=atoi(strtok(NULL, ":"));
  512. if(tim <5 && tim >0) date_num =-1;
  514. for(jys =0; jys <2; jys++)
  515. {
  516. if(tim-1 <HqTime[jys].am_min_start
  517. || tim >HqTime[jys].pm_min_end
  518. || (tim <HqTime[jys].pm_min_start 
  519. && tim >HqTime[jys].am_min_end))
  520. {
  521. if(HqTime[jys].fRunning ==TRUE)
  522. {
  523. HqTime[jys].fRunning =FALSE;
  524. MsgLocal("Jy is closed");
  525. }
  526. }
  527. else if(HqTime[jys].fRunning ==FALSE)
  528. HqTime[jys].fRunning =TRUE;
  530. }
  531. return 0;
  532. }
  534. void SetHqUsers(int count)
  535. {
  536. char tmp[20];
  538. wsprintf(tmp, "%d", count);
  539. SetDlgItemText(ghWndMain, IDC_HQUSERS, tmp);
  540. }
  542. void SetJyUsers(int count)
  543. {
  544. char tmp[20];
  546. wsprintf(tmp, "%d", count);
  547. SetDlgItemText(ghWndMain, IDC_JYUSERS, tmp);
  548. }
  550. void GlobalVaryInit(void)
  551. {
  552. char temp[50];
  554.     if(GetInitString("GLOBAL", "READDATA", temp))
  555. {
  556. if(temp[0] =='Y' || temp[0] =='y')
  557. gfReadData =TRUE;
  558. else
  559. gfReadData =FALSE;
  560. }
  561. else PutInitString("GLOBAL", "READDATA", "No");
  563.     if(GetInitString("GLOBAL", "CLRUN", temp))
  564. {
  565. if(temp[0] =='Y' || temp[0] =='y')
  566. IsClectRun =TRUE;
  567. else
  568. IsClectRun =FALSE;
  569. }
  570. else PutInitString("GLOBAL", "CLRUN", "No");
  571. }