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

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

金融证券系统

开发平台：

Visual C++

MONITOR.C：源码内容
  1. #include <windows.h>
  2. #include <windowsx.h>
  3. #include "monitor.h"
  4. extern BOOL GetInitString(LPSTR, LPSTR, LPSTR);
  5. extern BOOL ErrMsg(HWND, LPSTR);
  7. MONITOR Monitor;
  8. unsigned int StartNo;
  10. typedef struct tag_HQ_USER
  11. {
  12. unsigned int id;
  13. char pass[6+1];
  14. char priv;
  15. }USER,*LPUSER;
  17. LPUSER User=NULL;
  18. int user_rec_num =0;
  20. BOOL MonitorInit()
  21. {
  22. char temp[200],tmp[100];
  23. char MonitorBuf[100];
  24.     int i;
  26. memset(&Monitor.File,0,sizeof(DBF_DATA));
  27. Monitor.File.hf =-1;
  29. if(GetInitString("MONITOR", "RUN", temp))
  30. {
  31. if(temp[0] =='N' || temp[0] =='n')
  32. {
  33. Monitor.IsRun =FALSE;
  34. return TRUE;
  35. }
  36. else
  37. Monitor.IsRun=TRUE;
  38. }
  39. else
  40. {
  41. Monitor.IsRun=FALSE;
  42. return TRUE;
  43. }
  45. if(!GetInitString("MONITOR","FILE",temp))
  46. {
  47. ErrMsg(NULL,"Can not find file item in init file!");
  48. Monitor.IsRun=FALSE;
  49. return FALSE;
  50. }
  51.     
  52. if(access(temp,_S_IREAD|_S_IWRITE) <0)
  53. {
  54. wsprintf(tmp, "can not read %s:n %s",
  55. (LPSTR)"MONITORFILE", (LPSTR)temp);
  56. ErrMsg(NULL, tmp);
  57. Monitor.IsRun=FALSE;
  58. return FALSE;
  59. }
  61. Monitor.File.hf=OpenDbfBase(temp,O_RDWR);
  62. if (Monitor.File.hf==-1)
  63. {
  64. wsprintf(tmp, "can not open %s:n %s",
  65. (LPSTR)"COMMFILE", (LPSTR)&temp[0]);
  66. ErrMsg(NULL, tmp);
  67. return FALSE;
  68. }
  69. if (InitBase(Monitor.File.hf,&Monitor.File.dbfStruct,
  70. &Monitor.File.fldStruct,&Monitor.File.fldCount)
  71. !=SUCCEED)
  72. {
  73. wsprintf(tmp, "can not init %s:n %s",
  74. (LPSTR)"COMMFILE", (LPSTR)temp);
  75. ErrMsg(NULL, temp);
  76. return FALSE;
  77. }
  79. user_rec_num =*(int *)(Monitor.File.dbfStruct.recnum);
  80. User =GlobalAllocPtr(GHND,(DWORD)(user_rec_num*sizeof(USER)));
  81. if(User ==NULL)
  82. {
  83. ErrMsg(NULL, "Can not alloc user info memory");
  84. return FALSE;
  85. }
  86. for(i=0;i<user_rec_num;i++)
  87. {
  88. ReadRecord(Monitor.File.hf,i+1L,*(short *)Monitor.File.dbfStruct.hlen,
  89. *(short *)Monitor.File.dbfStruct.rlen,MonitorBuf);
  91. FldToString(MonitorBuf,&Monitor.File.fldStruct[fld_CODE],temp);
  92. User[i].id =atoi(temp);
  93. if(i==0)
  94. StartNo=User[0].id;
  96. FldToString(MonitorBuf,&Monitor.File.fldStruct[fld_PASS],temp);
  97. strncpy(User[i].pass,temp,6);
  98. User[i].priv =MonitorBuf[*(short*)Monitor.File.fldStruct[fld_PRIV].offset];   
  99. }
  101. if(!GetInitString("MONITOR","CHECKPOINT",temp))
  102. {
  103. Monitor.CheckPoint=5;
  104. }
  105.     else
  106. {
  107. Monitor.CheckPoint=atoi(temp);
  108. }
  109. return TRUE;
  110. }
  112. BOOL MonitorExit()
  113. {
  114. if(Monitor.File.hf!=-1)
  115. {
  116. CloseDbf(Monitor.File.hf);
  117. if(Monitor.File.fldStruct)
  118. GlobalFreePtr(Monitor.File.fldStruct);
  119. }
  121. if(User!=NULL)
  122. GlobalFreePtr(User);
  124. return TRUE;
  125. }
  127. /*
  128. int RegisterUser(char *UserId,char *Pass)
  129. {
  130. int pos=1,priv,lock,recnum;
  131. char pass[7],userid[7],temp[10];
  132. char MonitorBuf[100];
  134. if(Monitor.File.hf ==-1) 
  135. return LOGIN_SYS_ERR;
  137. pos=atoi(UserId) - StartNo +1;
  138. if(pos>*(int *)(Monitor.File.dbfStruct.recnum)+1)
  139. recnum =GetRecNum(Monitor.File.hf);
  140. else
  141. recnum =*(int *)(Monitor.File.dbfStruct.recnum);
  143. if(pos<=recnum)
  144. {
  145. ReadRecord(Monitor.File.hf,pos,*(short *)Monitor.File.dbfStruct.hlen,
  146. *(short *)Monitor.File.dbfStruct.rlen,MonitorBuf);
  148. FldToString(MonitorBuf,&Monitor.File.fldStruct[fld_CODE],userid);
  149. }
  150. else
  151. userid[0]=0;
  153. if(strncmp(userid,UserId,6))
  154. {
  155. pos =1;
  156. do
  157. {
  158. ReadRecord(Monitor.File.hf,pos,*(short *)Monitor.File.dbfStruct.hlen,
  159. *(short *)Monitor.File.dbfStruct.rlen,MonitorBuf);
  161. FldToString(MonitorBuf,&Monitor.File.fldStruct[fld_CODE],userid);
  162. if(!(strncmp(userid,UserId,6)))
  163. break;
  164. else
  165. {
  166. if(pos>recnum)
  167. {
  168. return LOGIN_NO_THIS_ID;
  169. }
  170. }
  171. ShoutBlockingHook();
  172. pos++;
  173. }while(strncmp(userid,UserId,6));
  174. }
  176. FldToString(MonitorBuf,&Monitor.File.fldStruct[fld_PASS],pass);
  177. FldToString(MonitorBuf,&Monitor.File.fldStruct[fld_TIME],temp);
  178. lock=MonitorBuf[*(short*)Monitor.File.fldStruct[fld_LOCK].offset];   
  179. if(lock=='T')
  180. return LOGIN_LOCKED;
  181. priv=MonitorBuf[*(short*)Monitor.File.fldStruct[fld_PRIV].offset];   
  182.     if(atoi(temp)==0&&priv!='9')
  183. return LOGIN_NO_TIME;
  184. if(atoi(temp)==-1&&priv!='9')
  185. return LOGIN_NO_THIS_ID;
  186. if(strncmp(Pass,pass,6))
  187. return LOGIN_NO_PRIV;
  188. else
  189. return pos;
  190. }
  191. */
  193. int RegisterUser(char *UserId,char *Pass)
  194. {
  195. int pos=0;
  196. unsigned int ReqId;
  198. if(Monitor.File.hf ==-1) 
  199. return LOGIN_SYS_ERR;
  201. ReqId =atoi(UserId);
  203. pos=ReqId - StartNo;
  205. if(pos>=user_rec_num)
  206. {
  207. pos =0;
  208. for(;;)
  209. {
  210. if(User[pos].id==ReqId)
  211. break;
  212. pos++;
  213. if(pos>=user_rec_num)
  214. return LOGIN_NO_THIS_ID;
  215. }
  216. }
  217. else
  218. {
  219. if(User[pos].id!=ReqId)
  220. {
  221. pos =0;
  222. for(;;)
  223. {
  224. if(User[pos].id==ReqId)
  225. break;
  227. pos++;
  228. if(pos>=user_rec_num)
  229. return LOGIN_NO_THIS_ID;
  230. }
  231. }
  232. }
  234. if(strncmp(Pass,User[pos].pass,strlen(User[pos].pass)))
  235. return LOGIN_NO_PRIV;
  236. else
  237. {
  238. pos++;
  239. return pos;
  240. }
  241. }
  243. int WriteUserStatus(int Pos,int Utime,int Lstatus,char * ReqHead)
  244. {
  245. char temp[20];
  246. char MonitorBuf[100];
  247. int rtime,priv;
  249. if(Monitor.File.hf ==-1) 
  250. return 0;
  252. memset(MonitorBuf,' ',100);
  254. ReadRecord(Monitor.File.hf,Pos,*(short *)Monitor.File.dbfStruct.hlen,
  255. *(short *)Monitor.File.dbfStruct.rlen,MonitorBuf);
  256. FldToString(MonitorBuf,&Monitor.File.fldStruct[fld_TIME],temp);
  257. rtime=atoi(temp);
  258. rtime-=Utime;
  259. if(rtime<0) rtime=0;
  260. sprintf(temp,"%d",rtime);
  261. StringToFld(MonitorBuf,Monitor.File.fldStruct[fld_TIME],temp);
  262. MonitorBuf[*(short*)Monitor.File.fldStruct[fld_LSTA].offset]=Lstatus;
  263. MonitorBuf[*(short*)Monitor.File.fldStruct[fld_USED].offset]='T';
  264. priv=MonitorBuf[*(short*)Monitor.File.fldStruct[fld_PRIV].offset];
  265. if(priv=='9')
  266. rtime=600;
  268. //strncpy(temp,ReqHead,strlen(ReqHead));
  269. //StringToFld(MonitorBuf,Monitor.File.fldStruct[fld_ADDR],temp);
  271. WriteRecord(Monitor.File.hf,Pos,*(short *)Monitor.File.dbfStruct.hlen,
  272. *(short *)Monitor.File.dbfStruct.rlen,MonitorBuf);
  274. return rtime;
  275. }
  277. char ReadLockControl(int Pos)
  278. {
  279. char MonitorBuf[100];
  281. if(Monitor.File.hf ==-1) return 0;
  283. ReadRecord(Monitor.File.hf,Pos,*(short *)Monitor.File.dbfStruct.hlen,
  284. *(short *)Monitor.File.dbfStruct.rlen,MonitorBuf);
  285. return MonitorBuf[*(short*)Monitor.File.fldStruct[fld_LOCK].offset];
  286. }
  288. int SetUserEnv(int Pos,TCP_FRAME_HQ_ENV * lpPara,int len)
  289. {
  290. char temp[10];
  291. char MonitorBuf[100];
  293. if(Monitor.File.hf ==-1) 
  294. return SET_SYS_ERROR;
  295. if(len!=sizeof(TCP_FRAME_HQ_ENV))
  296. return SET_DATA_ERROR;
  298. memset(MonitorBuf,' ',100);
  300. ReadRecord(Monitor.File.hf,Pos,*(short *)Monitor.File.dbfStruct.hlen,
  301. *(short *)Monitor.File.dbfStruct.rlen,MonitorBuf);
  302. FldToString(MonitorBuf,&Monitor.File.fldStruct[fld_PASS],temp);
  303.     if(strncmp(temp,lpPara->pwd,6)!=0)
  304. return SET_PWD_ERROR;
  305. StringToFld(MonitorBuf,Monitor.File.fldStruct[fld_PASS],lpPara->newpwd);
  306. WriteRecord(Monitor.File.hf,Pos,*(short *)Monitor.File.dbfStruct.hlen,
  307. *(short *)Monitor.File.dbfStruct.rlen,MonitorBuf);
  309. if(Pos>0 &&Pos <=user_rec_num)
  310. strncpy(User[Pos-1].pass ,lpPara->newpwd,strlen(lpPara->newpwd));
  312. return SET_SUCC;
  313. }