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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 能源行业(电力石油煤炭) > 查看源码
RTDatOpr.cpp
资源名称：PasRTDat.rar　[点击查看]
上传用户：shtiemo
上传日期：2017-12-29
资源大小：163k
文件大小：47k
源码类别：

能源行业(电力石油煤炭)

开发平台：

Visual C++

RTDatOpr.cpp：源码内容
  2. #include "stdafx.h"
  3. #include <afxtempl.h>
  4. #include "math.h"
  5. #include "RTDatOpr.h"
  7. #include "ES5SBSys.h"
  9. #include "RTUYC.h"
  10. #include "RTUYX.h"
  11. #include "RTU.h"
  13. #include "PwrNet.h"
  14. #include "Station.h"
  15. #include "CT.h"
  16. #include "PT.h"
  17. #include "AMea.h"
  18. #include "CB.h"
  19. #include "DisCon.h"
  20. #include "Tran.h"
  21. #include "PasRTDat.h"
  23. int nSecond = 0;
  24. CTime DatStartTime = CTime::GetCurrentTime(); // 数据断面开始时间
  25. CTime StartTime = CTime::GetCurrentTime(); // 仿真开始时间
  26. int nSeconds = 60;
  27. BOOL bAutoRead = FALSE;
  28. BOOL bAutoSave = FALSE;
  29. int gRtuID = 9999;
  31. #define SHEET_NUM 10
  32. #define SHEET1_ID 4
  34. #define SB_REGFAIL 0
  35. #define SB_REGOK 1
  36. #define RTSERVER_OK 2
  38. char szModulName[] = "PASRTDAT_01S"; // 注册模块名称(根据需要改变)
  39. TCHAR szDBServName[] = "DBSERVER"; // DB Server Name
  40. HANDLE  hReadDataEvent = NULL; // Event Handle
  42. BOOL bYXYCAryBusy = FALSE;
  44. static BOOL bSheetUsed[SHEET_NUM] = {0,0,0,0,0,0,0,0,0,0}; //
  45. BOOL bDBServerOK = FALSE;
  46. BOOL bSBConnect = TRUE;
  48. TASKBLK TaskBLK;
  49. PTASKBLK pCommTask = &TaskBLK; //SB Task block 
  51. CLIENTREQ ClientREQ;
  52. PCLIENTREQ pClientREQ = &ClientREQ;
  54. DEVICEVALUE RetData[MAX_ID_NUM]; // 
  56. CArray<PRTU, PRTU> RtuAry; // RTU数组
  57. CArray<PRTUYX, PRTUYX> YXInfoAry1; // RTU-YX数组
  58. CArray<PRTUYC, PRTUYC> YCInfoAry1; // RTU-YC数组
  60. CArray<PRTUYX, PRTUYX> YXInfoAry2; // 数据文件读入-YX数组
  61. CArray<PRTUYC, PRTUYC> YCInfoAry2; // 数据文件读入-YC数组
  63. CArray<PRTUYX, PRTUYX> YXInfoAry3; // 由电网部件产生-YX数组
  64. CArray<PRTUYC, PRTUYC> YCInfoAry3; // 由电网部件产生-YC数组
  66. BOOL bRTUMea = TRUE; // 默认由RTU信息表获取实时数据
  68. PWRNETPARA PwrNetPara;
  69. CArray<LPSTATIONPARA, LPSTATIONPARA> StaParaAry; // 厂站系数
  70. CArray<LPCTPARA, LPCTPARA> CTParaAry; // CT系数
  71. CArray<LPPTPARA, LPPTPARA> PTParaAry; // PT系数
  72. CArray<LPVAMEAPARA, LPVAMEAPARA> VAMeaParaAry; // 虚拟量系数
  74. CArray<LPCBPARA, LPCBPARA> CBParaAry; // 开关参数
  75. CArray<LPDISPARA, LPDISPARA> DisParaAry; // 刀闸参数
  76. CArray<LPTRANPARA, LPTRANPARA> TranParaAry; // 变压器参数
  78. CArray<PRTU,PRTU> RtuInfoAry; // RTU信息
  80. void CutSpaceChar(char* pChar, int nLen)
  81. {
  82. BOOL bSpace = FALSE;
  83. for (int i=nLen-1; i>=0; i--)
  84. {
  85. if (pChar[i] == 0) continue;
  86. else if (pChar[i] == 32) pChar[i] = 0;
  87. else break;
  88. }
  89. }
  91. int GetFreeSheet()
  92. {
  93. for (int i=0; i<SHEET_NUM; i++)
  94. {
  95. if (!bSheetUsed[i]) return i+SHEET1_ID;
  96.   }
  97. return INVALID_SHEET;
  98. }
  100. VOID RecvServplt (WORD wOpType, LPVOID pPara,
  101.   LPVOID* pRecvBuf, LPDWORD pDataLength)
  102. {
  103. switch( wOpType )
  104. {
  105. case SB_CALL_LinkBroken:
  106. bDBServerOK = FALSE;
  107. break;
  108. case SB_CALL_LinkRestored:
  109. bDBServerOK = TRUE;
  110. break;
  111. case SB_CALL_NpRecvServerInfo:
  112. break;
  113. default:
  114. break;
  115. }
  116. }
  118. //Connect to DB Server
  119. BOOL  ConnectServ()
  120. {
  121. CONNECTSERVER  connserv;
  122. connserv.lpRecvServerInfo = (LP_SBCPLT_ROUTINE)RecvServplt;
  124.     TASKBLK  taskblk;
  125. strcpy(taskblk.cRemoteName, szDBServName); // 请求连服务器
  126. taskblk.dwCommMode = SBC_CONNECT; // 操作方式
  127. taskblk.pSendBuf = (LPVOID)&connserv;
  129.     if (SB_Comm(&taskblk)!= SBR_SUCCESS) return FALSE;
  130. bDBServerOK = TRUE;
  131. return TRUE;
  132. }
  134. //Disconnect from server
  135. BOOL  DisConnectServ()
  136. {
  137.     TASKBLK  taskblk;
  138. taskblk.dwCommMode = SBC_DISCONNECT; // 操作方式
  139. strcpy(taskblk.cRemoteName, szDBServName); // 远程服务名
  141.     if (SB_Comm(&taskblk)!= SBR_SUCCESS) return FALSE;
  142. bDBServerOK = FALSE;
  143. return TRUE;
  144. }
  146. //Cancel sheet
  147. BOOL  CancelDataSheet(LPVOID pDataMenu)
  148. {
  149.     TASKBLK  taskblk;
  150. taskblk.dwCommMode = SBC_CANCELQUERY; // 操作方式
  151. strcpy(taskblk.cRemoteName, szDBServName); // 远程服务名
  152. taskblk.pSendBuf = pDataMenu;   // 用户定单结构指针
  154.     if (SB_Comm(&taskblk) != SBR_SUCCESS) return FALSE;
  155. return TRUE;
  156. }
  158. //Module Regist, Module Name: SBVBSERV_01G
  159. BOOL ModuleRegist()
  160. {
  161. int nRet = SB_REGFAIL;
  162. DWORD result = SB_ModuleRegist(szModulName);
  163. if (result != SBR_SUCCESS) return FALSE;
  165. hReadDataEvent = CreateEvent(NULL, TRUE, TRUE, NULL);
  166. ASSERT(hReadDataEvent);
  168. return TRUE;
  169. }
  171. //Module UnRegist
  172. BOOL ModuleUnRegist()
  173. {
  174. if (bSBConnect)
  175. {
  176. if (hReadDataEvent) CloseHandle(hReadDataEvent);
  177. return SB_ModuleUnregist();
  178. }
  179. return FALSE;
  180. }
  182. BOOL GetRealData(RTMenuData &RtMenuData)
  183. {
  184. int nNewSheet = 4; //GetFreeSheet();
  185. if (nNewSheet == INVALID_SHEET) return NO_SHEET;
  186. if (!bDBServerOK) return DBSERVER_ERROR;
  188. int nIDNum = int(RtMenuData.wIDNum);
  189. if (nIDNum > MAX_ID_NUM) nIDNum = MAX_ID_NUM;
  191. bSheetUsed[nNewSheet-SHEET1_ID] = TRUE;
  192. pClientREQ->wSheetCode = nNewSheet; //(WORD)SheetCode;
  193. pClientREQ->wCountOfEntry = nIDNum; //2*(1 + pYKXH->GuanLianItemNum);
  194. pClientREQ->dwUseAddPara = 2; //2*(1 + MAXYKGUANLIANITEMNUM )* 8 + 16;
  195. pClientREQ->lpReqCallBack = GetRealDataCallBack;
  197. for (int i=0; i<nIDNum; i++)
  198. {
  199. pClientREQ->IDEntryList[i].bIDEntry[0] = BYTE(RtMenuData.PartsRtData[i].wPartTypeID); //CT Type ID
  200. pClientREQ->IDEntryList[i].bIDEntry[1] = BYTE(RtMenuData.PartsRtData[i].wPartParaID); //P ID
  201. pClientREQ->IDEntryList[i].bIDEntry[2] = LOBYTE(RtMenuData.PartsRtData[i].wPartID);
  202. pClientREQ->IDEntryList[i].bIDEntry[3] = HIBYTE(RtMenuData.PartsRtData[i].wPartID);
  203. pClientREQ->IDEntryList[i].wRefresh = SBD_RENEW_LAZY;
  204. pClientREQ->IDEntryList[i].pEntryBuf = NULL;
  205. }
  207. pCommTask->dwCommMode = SBC_QUERY;
  208. strcpy(pCommTask->cRemoteName, szDBServName);
  209. pCommTask->pSendBuf = pClientREQ;
  211. ResetEvent(hReadDataEvent); //Set Event Single
  213. WORD wFlag = SB_Comm(pCommTask); 
  214. WORD wOpCode = 0;
  215. if(wFlag == SBR_SUCCESS) 
  216. {
  217. DWORD RetValue = WaitForSingleObject(hReadDataEvent, 5000L);
  218. switch( RetValue )
  219. {
  220. case WAIT_OBJECT_0:
  221. {
  222. wOpCode = GET_DATA_OK;
  223. BYTE byData = 0;
  224. for (i=0; i<nIDNum; i++)
  225. {
  226. RtMenuData.PartsRtData[i].fYCData = RetData[i].m_Ycv;
  227. RtMenuData.PartsRtData[i].dwTap = RetData[i].m_wBYQFJT;
  228. RtMenuData.PartsRtData[i].dwKWH = DWORD(RetData[i].m_RetwKwhv);
  229. memcpy(&byData, &RetData[i].m_RetYxv, 1);
  230. RtMenuData.PartsRtData[i].byYXVal = byData;
  231. }
  232. }
  233. break;
  235. case WAIT_TIMEOUT:
  236. //AfxMessageBox(_T("发送数据超时!"));
  237. wOpCode = WAIT_SHEET_TIMEOUT;
  238. break;
  240. case WAIT_ABANDONED:
  241. //AfxMessageBox(_T("发送数据失败! WAIT_ABANDONED"));
  242. wOpCode = WAIT_SHEET_ABANDONED;
  243. break;
  245. case WAIT_FAILED:
  246. //AfxMessageBox(_T("发送数据失败! WAIT_FAILED"));
  247. wOpCode = WAIT_SHEET_FAILED;
  248. break;
  249. }
  250. CancelDataSheet(pClientREQ); //
  251. }
  252. else
  253. {
  254. SetEvent(hReadDataEvent);
  255. wOpCode = SBCOM_ERROR;
  256. //AfxMessageBox(_T("发送提交错误"));
  257. }
  259. //Free allocated resources
  260. bSheetUsed[nNewSheet-SHEET1_ID] = FALSE;
  261. return wOpCode;
  262. }
  264. //SB CallBack Function
  265. void GetRealDataCallBack(WORD wOpType, LPVOID pPara, LPVOID* pRecBuf, PDWORD pDataLength)
  266. {
  267. PCLIENTREQ pGClienTReq = NULL;
  268. WORD i, wIDNum;
  269. switch(wOpType)
  270. {
  271. case SB_CALL_StaticReqData:
  272. pGClienTReq = PCLIENTREQ(pPara);
  273. wIDNum = pGClienTReq->wCountOfEntry;
  274. for (i=0; i<wIDNum; i++)
  275. {
  276. if (pGClienTReq->IDEntryList[i].pEntryBuf)
  277. memcpy(&RetData[i], pGClienTReq->IDEntryList[i].pEntryBuf, sizeof(DEVICEVALUE));
  278. else
  279. memset(&RetData[i], 0, sizeof(DEVICEVALUE));
  280. }
  281. SetEvent(hReadDataEvent);
  282. break;
  284. default:
  285. pGClienTReq = NULL;
  286. break;
  287. }
  288. }
  291. BOOL SetModuleStatus() 
  292. {
  293. // TODO: Add your command handler code here
  294. if (!bSBConnect) return FALSE;
  295. char cStatus;
  296. if (SB_GetModuleStatus(&cStatus))
  297. {
  298. if (cStatus != SBGRADE_MAIN)
  299. SB_ModuleChangeStatus(SBXTEVT_MQ_Manual,SBGRADE_MAIN);
  300. else
  301. SB_ModuleChangeStatus(SBXTEVT_MQ_Manual,SBGRADE_NORMAL);
  302. return TRUE;
  303. }
  304. else return FALSE;
  305. }
  307. BOOL GetModuleStatus()
  308. {
  309. if (!bSBConnect) return FALSE;
  310. char cModuleStatus;
  311. WORD wCode = 0;
  312. if (SB_GetModuleStatus(&cModuleStatus))
  313. {
  314. if (cModuleStatus == SBGRADE_MAIN) 
  315. return TRUE;
  316. else
  317. return FALSE;
  318. }
  319. else return FALSE;
  320. }
  323. #define IES500_SERVERPPIPENAME "CCMTOADM"
  324. CRITICAL_SECTION crSendSCADA;
  325. DWORD dwPipePP=0;
  327. // 永久管道客户端回调：本系统中，不接收服务器回送的数据
  328. VOID PPipeClientCallbackFor500(WORD, LPVOID, LPVOID*, LPDWORD)
  329. {
  330. return;
  331. };
  333. // 连接500永久管道服务器
  334. BOOL Connect500PPipeServer()
  335. {
  336. if (dwPipePP!=0) return TRUE;
  338. TASKBLK tkC;
  339. tkC.dwCommMode = SBC_OPENPIPE;
  340. // tkC.dwCommMode = SBC_OPENPIPEPLUSMIS;
  341. lstrcpy (tkC.cRemoteName, IES500_SERVERPPIPENAME);
  342. tkC.pCpltRoutine = PPipeClientCallbackFor500;
  344. if (SB_Comm(&tkC)==SBR_SUCCESS)
  345. {
  346. dwPipePP = (DWORD)tkC.phGroup;
  347. InitializeCriticalSection (&crSendSCADA);
  348. return TRUE;
  349. }
  350. return FALSE;
  351. };
  353. // 断开与500永久管道的连接
  354. // 此管道用于将数据反送至 500 SCADA
  355. BOOL Disconnect500PPipeServer()
  356. {
  357. if (dwPipePP==0) return TRUE;
  359. TASKBLK tkDC;
  360. tkDC.dwCommMode = SBC_CLOSEPIPE;
  361. tkDC.phGroup = (LPVOID)dwPipePP;
  363. if (SB_Comm(&tkDC)==SBR_SUCCESS)
  364. {
  365. dwPipePP = 0;
  366. DeleteCriticalSection (&crSendSCADA);
  367. return TRUE;
  368. }
  369. return FALSE;
  370. };
  373. BOOL CCMComToAdm (LPVOID lpBuf, DWORD dwLen)
  374. {
  375. BOOL bRet = TRUE;
  376. if (dwPipePP == 0) return FALSE;
  378. EnterCriticalSection (&crSendSCADA);
  379. try
  380. {
  381. TASKBLK tkBlk;
  382. memset (&tkBlk, sizeof(TASKBLK),0);
  383. tkBlk.dwCommMode = SBC_SENDPIPE;
  384. tkBlk.pSendBuf = lpBuf;
  385. tkBlk.dwSendDataLen = dwLen;
  386. tkBlk.phGroup = (LPVOID)dwPipePP;
  388. if (SB_Comm(&tkBlk)!=SBR_SUCCESS) bRet = FALSE;
  389. }
  390. catch (...){}
  392. LeaveCriticalSection (&crSendSCADA);
  393. return bRet;
  394. };
  396. BOOL SendAllDataToADM()
  397. {
  398. if (bYXYCAryBusy) return FALSE;
  399. if (!Connect500PPipeServer()) return FALSE; // 无法连通数据接收服务器
  400. bYXYCAryBusy = TRUE;
  402. int i, iStart, iCount;
  403. COM_SB_BUF bkSBBuf;
  404. PCOMSBFRAME pFrame;
  405. PCCMYCDATA pYCData;
  406. PCCMYXDATA  pYXData;
  407. USHORT nDataLen;
  409. memset( &bkSBBuf, 0, sizeof( COM_SB_BUF ) );
  410. BOOL bEnd = FALSE;
  411. iStart = 0;
  412. iCount = YCInfoAry2.GetSize();
  413. while (!bEnd && iCount>0)
  414. {
  415. // 组织数据，注意数据地址处数据类型的转换
  416. bkSBBuf.nDataTotalLength = offsetof(COM_SB_BUF, byBuffer); // 数据总长度
  417. bkSBBuf.pInfPoint[0] = bkSBBuf.nDataTotalLength;
  418. bkSBBuf.nInfBlockNum = 1; // 信息块个数只有一个即为遥测数据
  419. nDataLen = bkSBBuf.nDataTotalLength;
  421. pFrame = (COMSBFRAME*) (&(bkSBBuf.bySB_Reserve[nDataLen]));
  422. #ifdef NEW_SYSTEM
  423. pFrame->byType = 12; // 状态估计浮点型数据
  424. #else
  425. pFrame->byType = 0; // 状态估计浮点型数据
  426. #endif
  427. pFrame->nDataLength = 0;
  428. nDataLen += 3;
  429. bkSBBuf.nDataTotalLength = nDataLen;
  431. try
  432. {
  433. // nDataLen - 当前数据总长度
  434. pYCData = (PCCMYCDATA)(&(bkSBBuf.bySB_Reserve[nDataLen]));
  435. for (i=iStart; i<iCount; i++)
  436. {
  437. if ( nDataLen+sizeof(CCMYCDATA) >= sizeof(COM_SB_BUF) )
  438. {
  439. iStart = i; break; //实施发送
  440. }
  442. nDataLen += sizeof(CCMYCDATA);
  444. // 部件类型
  445. pYCData->sDataId.byBjType = YCInfoAry2[i]->DBID.byBjType;
  446. pYCData->sDataId.byCShType = YCInfoAry2[i]->DBID.byCShType;
  447. pYCData->sDataId.nBjID = YCInfoAry2[i]->DBID.nBjID;
  448. // pYCData->DataVal = 100;
  449. pYCData->DataVal = (SHORT)YCInfoAry2[i]->fVal;
  450. pFrame->nDataLength += sizeof(CCMYCDATA);
  451. bkSBBuf.nDataTotalLength = nDataLen;
  452. pYCData++; // 继续下一个
  453. }
  454. if (i>=iCount) {bEnd = TRUE;} // 全部组包完毕
  455. }
  456. catch (...) {}
  458. // 发送
  459. if (bkSBBuf.nDataTotalLength> offsetof(COM_SB_BUF, byBuffer))
  460. {
  461. Sleep(1);
  462. CCMComToAdm (&bkSBBuf, bkSBBuf.nDataTotalLength);
  463. }
  464. }
  466. memset( &bkSBBuf, 0, sizeof( COM_SB_BUF ) );
  467. bEnd = FALSE;
  468. iStart = 0;
  469. iCount = YXInfoAry2.GetSize();
  470. while (!bEnd && iCount>0)
  471. {
  472. // 组织数据，注意数据地址处数据类型的转换
  473. bkSBBuf.nDataTotalLength = offsetof(COM_SB_BUF, byBuffer); // 数据总长度
  474. bkSBBuf.pInfPoint[0] = bkSBBuf.nDataTotalLength;
  475. bkSBBuf.nInfBlockNum = 1; // 信息块个数只有一个即为遥测数据
  476. nDataLen = bkSBBuf.nDataTotalLength;
  478. pFrame = (COMSBFRAME*) (&(bkSBBuf.bySB_Reserve[nDataLen]));
  479. pFrame->byType = 1; // 状态估计浮点型数据
  481. pFrame->nDataLength = 0;
  482. nDataLen += 3;
  483. bkSBBuf.nDataTotalLength = nDataLen;
  485. try
  486. {
  487. // nDataLen - 当前数据总长度
  488. pYXData = (PCCMYXDATA)(&(bkSBBuf.bySB_Reserve[nDataLen]));
  489. for (i=iStart; i<iCount; i++)
  490. {
  491. if ( nDataLen+sizeof(CCMYXDATA) >= sizeof(COM_SB_BUF) )
  492. {
  493. //实施发送
  494. iStart = i;
  495. break;
  496. }
  498. nDataLen += sizeof(CCMYXDATA);
  500. // 部件类型
  501. pYXData->sDataId.byBjType = YXInfoAry2[i]->DBID.byBjType;
  502. pYXData->sDataId.byCShType = YXInfoAry2[i]->DBID.byCShType;
  503. pYXData->sDataId.nBjID = YXInfoAry2[i]->DBID.nBjID;
  504. // pYXData->DataVal = 1;
  505. pYXData->DataVal = YXInfoAry2[i]->bVal;
  506. pFrame->nDataLength += sizeof(CCMYXDATA);
  507. bkSBBuf.nDataTotalLength = nDataLen;
  508. pYXData++; // 继续下一个
  509. }
  510. if (i>=iCount) {bEnd = TRUE;} // 全部组包完毕
  511. }
  512. catch (...) {}
  514. // 发送
  515. if (bkSBBuf.nDataTotalLength> offsetof(COM_SB_BUF, byBuffer))
  516. {
  517. Sleep(1);
  518. CCMComToAdm (&bkSBBuf, bkSBBuf.nDataTotalLength);
  519. }
  520. }
  522. Disconnect500PPipeServer();
  523. bYXYCAryBusy = FALSE;
  525. return TRUE;
  526. };
  527. //////////////////////////////////////////////////////////////////////////////
  528. void GetRtuName(PDBID pDBID,CString& Name,int nYCYX)
  529. {
  530. BOOL bFind = FALSE;
  531. int RtuID=0;
  532. Name = "RTU";
  533. if (nYCYX==1)
  534. {
  535. int nYCNum = YCInfoAry1.GetSize();
  536. for (int i=0;i<nYCNum;i++)
  537. {
  538. if ((YCInfoAry1[i]->DBID.byBjType==pDBID->byBjType)
  539. &&(YCInfoAry1[i]->DBID.byCShType==pDBID->byCShType)&&(YCInfoAry1[i]->DBID.nBjID==pDBID->nBjID))
  540. {
  541. RtuID = YCInfoAry1[i]->nRTUID;
  542. bFind = TRUE;
  543. break;
  544. }
  546. }
  548. }
  549. else
  550. {
  551. int nYXNum = YXInfoAry1.GetSize();
  552. for (int i=0;i<nYXNum;i++)
  553. {
  554. if ((YXInfoAry1[i]->DBID.byBjType==pDBID->byBjType)
  555. &&(YXInfoAry1[i]->DBID.byCShType==pDBID->byCShType)&&(YXInfoAry1[i]->DBID.nBjID==pDBID->nBjID))
  556. {
  557. RtuID = YXInfoAry1[i]->nRTUID;
  558. bFind = TRUE;
  559. break;
  560. }
  562. }
  563. }
  564. if (bFind)
  565. {
  566. int nRTUNum = RtuAry.GetSize();
  567. for (int i=0;i<nRTUNum;i++)
  568. {
  569. if (RtuAry[i]->nRtuID==RtuID)   
  570. {
  571. Name = RtuAry[i]->szName;
  572. break;
  573. }
  574. }
  575. }
  576. }
  577. ////////////////////////////////////////////////////////////////////////////
  578. BOOL ReadRTUYCYXInfo()
  579. {
  580. FreeRTUYXYCInfo();
  582. CRtu Rtu;
  583. Rtu.m_strSort = ("wRTUNum");
  584. Rtu.m_strFilter = ("");
  586. if (Rtu.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  587. {
  588. while(!Rtu.IsEOF())
  589. {
  590. PRTU pRTU = new RTU; memset(pRTU, 0 , sizeof(RTU));
  591. sprintf(pRTU->szName , Rtu.m_szMingZi);
  592. pRTU->nRtuID = Rtu.m_wRTUNum;
  593. pRTU->nYCNum = Rtu.m_wRTUYCNum;
  594. pRTU->nYXNum = Rtu.m_wRTUYXNum;
  596. RtuAry.Add(pRTU);
  597. Rtu.MoveNext();
  598. }
  599. Rtu.Close();
  600. }
  601. else
  602. return FALSE;
  604. CRTUYC RtuYC;
  605. RtuYC.m_strSort = ("wRTUNum, YC_NO");
  606. RtuYC.m_strFilter = ("byBjType<>0 and byCShType<>0 and nBjID<>0");
  608. float fCoef, fOffSet;
  609. CString strParaName;
  610. if (RtuYC.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  611. {
  612. while(!RtuYC.IsEOF())
  613. {
  614. PRTUYC pRTUYC = new RTUYC; memset(pRTUYC, 0 , sizeof(RTUYC));
  615. pRTUYC->DBID.byBjType = RtuYC.m_byBjType;
  616. pRTUYC->DBID.byCShType = RtuYC.m_byCShType;
  617. pRTUYC->DBID.nBjID = RtuYC.m_nBjID;
  618. pRTUYC->nRTUID = RtuYC.m_wRTUNum;
  619. if (GetMeaCoef(&(pRTUYC->DBID), &fCoef, &fOffSet, strParaName))
  620. {
  621. sprintf(pRTUYC->szName, strParaName);
  622. }
  624. YCInfoAry1.Add(pRTUYC);
  625. RtuYC.MoveNext();
  626. }
  627. RtuYC.Close();
  628. }
  629. else
  630. return FALSE;
  632. CRTUYX RtuYX;
  633. RtuYX.m_strSort = ("wRTUNum,YX_NO");
  634. RtuYX.m_strFilter = ("byBjType<>0 and byCShType<>0 and nBjID<>0");
  636. if (RtuYX.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  637. {
  638. while(!RtuYX.IsEOF())
  639. {
  640. PRTUYX pRTUYX = new RTUYX; memset(pRTUYX, 0, sizeof(RTUYX));
  641. pRTUYX->DBID.byBjType = RtuYX.m_byBjType;
  642. pRTUYX->DBID.byCShType = RtuYX.m_byCShType;
  643. pRTUYX->DBID.nBjID = RtuYX.m_nBjID;
  644. pRTUYX->nRTUID = RtuYX.m_wRTUNum;
  645. if (GetMeaCoef(&(pRTUYX->DBID), &fCoef, &fOffSet, strParaName))
  646. {
  647. sprintf(pRTUYX->szName, strParaName);
  648. }
  650. YXInfoAry1.Add(pRTUYX);
  651. RtuYX.MoveNext();
  652. }
  653. RtuYX.Close();
  654. }
  655. else
  656. return FALSE;
  658. return TRUE;
  659. };
  661. // 从电网部件中创建所有的量测信息
  662. void CreateMeaAryFromPwrNet()
  663. {
  664. PRTUYC pRTUYC = NULL;
  665. PRTUYX pRTUYX = NULL;
  667. // 电网(频率)
  668. pRTUYC = new  RTUYC;
  669. pRTUYC->DBID.byBjType = DianWangTab_ID;
  670. pRTUYC->DBID.byCShType = DW_PinLu;
  671. pRTUYC->DBID.nBjID = 1 ;
  672. YCInfoAry3.Add(pRTUYC);
  674. // 厂站(频率)
  675. int nStaNum = StaParaAry.GetSize();
  676. for (int i=0; i<nStaNum; i++)
  677. {
  678. pRTUYC = new  RTUYC;
  679. pRTUYC->DBID.byBjType = ChangZhanTab_ID;
  680. pRTUYC->DBID.byCShType = CZ_PinLu;
  681. pRTUYC->DBID.nBjID = StaParaAry[i]->ID ;
  682. YCInfoAry3.Add(pRTUYC);
  683. }
  685. // CT(有功、无功、电流)
  686. int nCTNum = CTParaAry.GetSize();
  687. for (i=0; i<nCTNum; i++)
  688. {
  689. pRTUYC = new  RTUYC;
  690. pRTUYC->DBID.byBjType = CTTab_ID;
  691. pRTUYC->DBID.byCShType = CT_P;
  692. pRTUYC->DBID.nBjID = CTParaAry[i]->ID ;
  693. YCInfoAry3.Add(pRTUYC);
  695. pRTUYC = new  RTUYC;
  696. pRTUYC->DBID.byBjType = CTTab_ID;
  697. pRTUYC->DBID.byCShType = CT_Q;
  698. pRTUYC->DBID.nBjID = CTParaAry[i]->ID ;
  699. YCInfoAry3.Add(pRTUYC);
  700. #ifdef NEW_SYSTEM
  701. pRTUYC = new  RTUYC;
  702. pRTUYC->DBID.byBjType = CTTab_ID;
  703. pRTUYC->DBID.byCShType = CT_Ia;
  704. pRTUYC->DBID.nBjID = CTParaAry[i]->ID ;
  705. YCInfoAry3.Add(pRTUYC);
  707. pRTUYC = new  RTUYC;
  708. pRTUYC->DBID.byBjType = CTTab_ID;
  709. pRTUYC->DBID.byCShType = CT_Ib;
  710. pRTUYC->DBID.nBjID = CTParaAry[i]->ID ;
  711. YCInfoAry3.Add(pRTUYC);
  713. pRTUYC = new  RTUYC;
  714. pRTUYC->DBID.byBjType = CTTab_ID;
  715. pRTUYC->DBID.byCShType = CT_Ic;
  716. pRTUYC->DBID.nBjID = CTParaAry[i]->ID ;
  717. YCInfoAry3.Add(pRTUYC);
  718. #else
  719. pRTUYC = new  RTUYC;
  720. pRTUYC->DBID.byBjType = CTTab_ID;
  721. pRTUYC->DBID.byCShType = CT_I;
  722. pRTUYC->DBID.nBjID = CTParaAry[i]->ID ;
  723. YCInfoAry3.Add(pRTUYC);
  724. #endif
  725. }
  727. // PT(有功、无功、电流)
  728. int nPTNum = PTParaAry.GetSize();
  729. for (i=0; i<nPTNum; i++)
  730. {
  731. pRTUYC = new  RTUYC;
  732. pRTUYC->DBID.byBjType = PTTab_ID;
  733. pRTUYC->DBID.byCShType = PT_VA;
  734. pRTUYC->DBID.nBjID = PTParaAry[i]->ID ;
  735. YCInfoAry3.Add(pRTUYC);
  737. pRTUYC = new  RTUYC;
  738. pRTUYC->DBID.byBjType = PTTab_ID;
  739. pRTUYC->DBID.byCShType = PT_VB;
  740. pRTUYC->DBID.nBjID = PTParaAry[i]->ID ;
  741. YCInfoAry3.Add(pRTUYC);
  743. pRTUYC = new  RTUYC;
  744. pRTUYC->DBID.byBjType = PTTab_ID;
  745. pRTUYC->DBID.byCShType = PT_VC;
  746. pRTUYC->DBID.nBjID = PTParaAry[i]->ID ;
  747. YCInfoAry3.Add(pRTUYC);
  748. #ifdef NEW_SYSTEM
  749. pRTUYC = new  RTUYC;
  750. pRTUYC->DBID.byBjType = PTTab_ID;
  751. pRTUYC->DBID.byCShType = PT_VabX;
  752. pRTUYC->DBID.nBjID = PTParaAry[i]->ID ;
  753. YCInfoAry3.Add(pRTUYC);
  755. pRTUYC = new  RTUYC;
  756. pRTUYC->DBID.byBjType = PTTab_ID;
  757. pRTUYC->DBID.byCShType = PT_VbcX;
  758. pRTUYC->DBID.nBjID = PTParaAry[i]->ID ;
  759. YCInfoAry3.Add(pRTUYC);
  761. pRTUYC = new  RTUYC;
  762. pRTUYC->DBID.byBjType = PTTab_ID;
  763. pRTUYC->DBID.byCShType = PT_VcaX;
  764. pRTUYC->DBID.nBjID = PTParaAry[i]->ID ;
  765. YCInfoAry3.Add(pRTUYC);
  766. #else
  767. pRTUYC = new  RTUYC;
  768. pRTUYC->DBID.byBjType = PTTab_ID;
  769. pRTUYC->DBID.byCShType = PT_VX;
  770. pRTUYC->DBID.nBjID = PTParaAry[i]->ID ;
  771. YCInfoAry3.Add(pRTUYC);
  772. #endif
  773. }
  775. // 虚拟模拟量(模拟量值)
  776. int nVMeaNum = VAMeaParaAry.GetSize();
  777. for (i=0; i<nVMeaNum; i++)
  778. {
  779. pRTUYC = new  RTUYC;
  780. pRTUYC->DBID.byBjType = XuNiDMNLiangTab_ID;
  781. pRTUYC->DBID.byCShType = XN_XNValue;
  782. pRTUYC->DBID.nBjID = VAMeaParaAry[i]->ID ;
  783. YCInfoAry3.Add(pRTUYC);
  784. }
  786. // 变压器(分接头)
  787. int nTranNum = TranParaAry.GetSize();
  788. for (i=0; i<nTranNum; i++)
  789. {
  790. if (TranParaAry[i]->bLTC)
  791. {
  792. pRTUYC = new  RTUYC;
  793. pRTUYC->DBID.byBjType = BianYaQiTab_ID;
  794. pRTUYC->DBID.byCShType = BYQ_DDFJT;
  795. pRTUYC->DBID.nBjID = TranParaAry[i]->ID ;
  796. YCInfoAry3.Add(pRTUYC);
  797. }
  798. }
  800. // 开关(开关状态)
  801. int nCBNum = CBParaAry.GetSize();
  802. for (i=0; i<nCBNum; i++)
  803. {
  804. pRTUYX = new  RTUYX;
  805. pRTUYX->DBID.byBjType = KaiGuanTab_ID;
  806. pRTUYX->DBID.byCShType = KG_KGState;
  807. pRTUYX->DBID.nBjID = CBParaAry[i]->ID;
  808. YXInfoAry3.Add(pRTUYX);
  809. }
  811. // 刀闸(刀闸状态)
  812. int nDisNum = DisParaAry.GetSize();
  813. for (i=0; i<nDisNum; i++)
  814. {
  815. pRTUYX = new  RTUYX;
  816. pRTUYX->DBID.byBjType = DaoZhaTab_ID;
  817. pRTUYX->DBID.byCShType = DZ_DZState;
  818. pRTUYX->DBID.nBjID = DisParaAry[i]->ID;
  819. YXInfoAry3.Add(pRTUYX);
  820. }
  821. }
  823. // 从YC、YX表中找出指定RTU的起始索引
  824. int GetRTUYXYCStartIdx(int nRTUID, int nYCYX)
  825. {
  826. int nYCNum = YCInfoAry1.GetSize();
  827. int nYXNum = YXInfoAry1.GetSize();
  828. int nStartIdx = -1;
  829. if (nYCYX == 1)
  830. {
  831. for (int i=0; i<nYCNum; i++)
  832. {
  833. if (YCInfoAry1[i]->nRTUID == nRTUID)
  834. {
  835. nStartIdx = i;
  836. break;
  837. }
  838. }
  839. }
  840. else
  841. {
  842. for (int i=0; i<nYXNum; i++)
  843. {
  844. if (YXInfoAry1[i]->nRTUID == nRTUID)
  845. {
  846. nStartIdx = i;
  847. break;
  848. }
  849. }
  850. }
  851. return nStartIdx;
  852. }
  854. // 从YC、YX表中找出指定RTU的YC或YX数目
  855. int GetRTUYCYXNum(int nRTUID, int nYC, int nStartIdx)
  856. {
  857. int nYCNum = YCInfoAry1.GetSize();
  858. int nYXNum = YXInfoAry1.GetSize();
  859. int nYCYXNum = 0;
  860. if (nYC == 1)
  861. {
  862. for (int i=nStartIdx; i<nYCNum; i++)
  863. {
  864. if (YCInfoAry1[i]->nRTUID == nRTUID) nYCYXNum++;
  865. else break;
  866. }
  867. }
  868. else
  869. {
  870. for (int i=nStartIdx; i<nYXNum; i++)
  871. {
  872. if (YXInfoAry1[i]->nRTUID == nRTUID) nYCYXNum++;
  873. else break;
  874. }
  875. }
  876. return nYCYXNum;
  877. }
  879. // 获取YC、YX信息表中的所有实时数据
  880. // 1、RTU接收YC、YX量测表；
  881. // 2、所有电网设备的实时信息组成的量测表
  882. BOOL GetAllRTData()
  883. {
  884. if (!ConnectServ()) return FALSE;
  886. RTMenuData RtMenuData;
  887. int nYCNum = 0;
  888. if (bRTUMea) nYCNum = YCInfoAry1.GetSize();
  889. else nYCNum = YCInfoAry3.GetSize();
  890. int nCount = 0;
  891. for (int i=0; i<nYCNum; i++)
  892. {
  893. if (bRTUMea)
  894. {
  895. RtMenuData.PartsRtData[nCount].wPartTypeID = YCInfoAry1[i]->DBID.byBjType;
  896. RtMenuData.PartsRtData[nCount].wPartParaID = YCInfoAry1[i]->DBID.byCShType;
  897. RtMenuData.PartsRtData[nCount].wPartID = YCInfoAry1[i]->DBID.nBjID;
  898. }
  899. else
  900. {
  901. RtMenuData.PartsRtData[nCount].wPartTypeID = YCInfoAry3[i]->DBID.byBjType;
  902. RtMenuData.PartsRtData[nCount].wPartParaID = YCInfoAry3[i]->DBID.byCShType;
  903. RtMenuData.PartsRtData[nCount].wPartID = YCInfoAry3[i]->DBID.nBjID;
  904. }
  905. nCount++;
  907. if (nCount == MAX_ID_NUM || i == nYCNum-1)
  908. {
  909. RtMenuData.wIDNum = nCount;
  910. GetRealData(RtMenuData);
  911. for (int j=0; j<nCount; j++)
  912. {
  913. if (bRTUMea)
  914. {
  915. if (YCInfoAry1[i+1-nCount +j]->DBID.byBjType == BianYaQiTab_ID)
  916. YCInfoAry1[i+1-nCount +j]->fVal = float(RtMenuData.PartsRtData[j].dwTap);
  917. else
  918. YCInfoAry1[i+1-nCount +j]->fVal = RtMenuData.PartsRtData[j].fYCData;
  919. }
  920. else
  921. {
  922. if (YCInfoAry3[i+1-nCount +j]->DBID.byBjType == BianYaQiTab_ID)
  923. YCInfoAry3[i+1-nCount +j]->fVal = float(RtMenuData.PartsRtData[j].dwTap);
  924. else
  925. YCInfoAry3[i+1-nCount +j]->fVal = RtMenuData.PartsRtData[j].fYCData;
  926. }
  927. }
  928. nCount = 0;
  929. }
  930. }
  932. // 开关状态的处理(KG_RTUKG1, KG_RTUKG2)
  933. int nYXNum = 0;
  934. if (bRTUMea) nYXNum = YXInfoAry1.GetSize();
  935. else nYXNum = YXInfoAry3.GetSize();
  937. nCount = 0;
  938. for (i=0; i<nYXNum; i++)
  939. {
  940. if (bRTUMea)
  941. {
  942. RtMenuData.PartsRtData[nCount].wPartTypeID = YXInfoAry1[i]->DBID.byBjType;
  943. RtMenuData.PartsRtData[nCount].wPartID = YXInfoAry1[i]->DBID.nBjID;
  944. if (YXInfoAry1[i]->DBID.byBjType == KaiGuanTab_ID && 
  945. (YXInfoAry1[i]->DBID.byCShType == KG_RTUKG1 || 
  946. YXInfoAry1[i]->DBID.byCShType == KG_RTUKG2))
  947. RtMenuData.PartsRtData[nCount].wPartParaID = KG_KGState;
  948. }
  949. else
  950. {
  951. RtMenuData.PartsRtData[nCount].wPartTypeID = YXInfoAry3[i]->DBID.byBjType;
  952. RtMenuData.PartsRtData[nCount].wPartID = YXInfoAry3[i]->DBID.nBjID;
  953. if (YXInfoAry3[i]->DBID.byBjType == KaiGuanTab_ID && 
  954. (YXInfoAry3[i]->DBID.byCShType == KG_RTUKG1 || 
  955. YXInfoAry3[i]->DBID.byCShType == KG_RTUKG2))
  956. RtMenuData.PartsRtData[nCount].wPartParaID = KG_KGState;
  957. }
  958. nCount++;
  960. if (nCount == MAX_ID_NUM || i == nYXNum-1)
  961. {
  962. RtMenuData.wIDNum = nCount;
  963. GetRealData(RtMenuData);
  964. for (int j=0; j<nCount; j++)
  965. {
  966. if (bRTUMea) YXInfoAry1[i+1-nCount +j]->bVal = RtMenuData.PartsRtData[j].byYXVal;
  967. else YXInfoAry3[i+1-nCount +j]->bVal = RtMenuData.PartsRtData[j].byYXVal;
  968. }
  969. nCount = 0;
  970. }
  971. }
  972. DisConnectServ();
  973. return TRUE;
  974. }
  976. BOOL bSaveAll = TRUE;
  977. int nPreMinute = -1;
  978. BOOL saveAllRTDataToFile()
  979. {
  980. CString strFile;
  981. CTime Time = CTime::GetCurrentTime();
  982. strFile.Format("C:\IES500\PARAM\实时数据\实时数据%02d%02d%02d%02d.dat", Time.GetDay(), Time.GetHour(), 
  983. Time.GetMinute(), Time.GetSecond());
  984. CFile fWR;
  985. BOOL bOper = fWR.Open(strFile, CFile::modeWrite|CFile::modeCreate);
  986. if (!bOper) return FALSE;
  988. // 每10分钟保存1次全网数据
  989. int nMinute = Time.GetMinute();
  990. if (nMinute%10 == 0 && nMinute != nPreMinute)
  991. {
  992. bSaveAll = TRUE;
  993. nPreMinute = nMinute;
  994. }
  996. int iItemCount=0;  
  997. int nYCNum = 0;
  998. if (bRTUMea) nYCNum = YCInfoAry1.GetSize();
  999. else nYCNum = YCInfoAry3.GetSize();
  1001. int nYXNum = 0;
  1002. if (bRTUMea) nYXNum = YXInfoAry1.GetSize();
  1003. else nYXNum = YXInfoAry3.GetSize();
  1005. int nChangedYCNum = 0;
  1006. int nChangedYXNum = 0;
  1007. for (int i=0; i<nYCNum; i++)
  1008. {
  1009. if (bRTUMea)
  1010. {
  1011. if (YCInfoAry1[i]->DBID.byBjType == DianWangTab_ID && YCInfoAry1[i]->DBID.byCShType == DW_PinLu)
  1012. {
  1013. YCInfoAry1[i]->bChanged = 1;
  1014. nChangedYCNum ++;
  1015. }
  1016. else if (YCInfoAry1[i]->DBID.byBjType == ChangZhanTab_ID && YCInfoAry1[i]->DBID.byCShType == CZ_PinLu)
  1017. {
  1018. YCInfoAry1[i]->bChanged = 1;
  1019. nChangedYCNum ++;
  1020. }
  1021. else if (fabs(YCInfoAry1[i]->fVal-YCInfoAry1[i]->fPreVal)>0.1)
  1022. {
  1023. YCInfoAry1[i]->fPreVal = YCInfoAry1[i]->fVal;
  1024. YCInfoAry1[i]->bChanged = 1;
  1025. nChangedYCNum ++;
  1026. }
  1027. else
  1028. YCInfoAry1[i]->bChanged = 0;
  1029. }
  1030. else
  1031. {
  1032. if (YCInfoAry3[i]->DBID.byBjType == DianWangTab_ID && YCInfoAry3[i]->DBID.byCShType == DW_PinLu)
  1033. {
  1034. YCInfoAry3[i]->bChanged = 1;
  1035. nChangedYCNum ++;
  1036. }
  1037. else if (YCInfoAry3[i]->DBID.byBjType == ChangZhanTab_ID && YCInfoAry3[i]->DBID.byCShType == CZ_PinLu)
  1038. {
  1039. YCInfoAry3[i]->bChanged = 1;
  1040. nChangedYCNum ++;
  1041. }
  1042. else if (fabs(YCInfoAry3[i]->fVal-YCInfoAry3[i]->fPreVal)>0.1)
  1043. {
  1044. YCInfoAry3[i]->fPreVal = YCInfoAry3[i]->fVal;
  1045. YCInfoAry3[i]->bChanged = 1;
  1046. nChangedYCNum ++;
  1047. }
  1048. else
  1049. YCInfoAry3[i]->bChanged = 0;
  1050. }
  1051. }
  1053. for (i=0; i<nYXNum; i++)
  1054. {
  1055. if (bRTUMea)
  1056. {
  1057. if (YXInfoAry1[i]->bVal != YXInfoAry1[i]->bPreVal)
  1058. {
  1059. YXInfoAry1[i]->bPreVal = YXInfoAry1[i]->bVal;
  1060. YXInfoAry1[i]->bChanged = 1;
  1061. nChangedYXNum ++;
  1062. }
  1063. else
  1064. YXInfoAry1[i]->bChanged = 0;
  1065. }
  1066. else
  1067. {
  1068. if (YXInfoAry3[i]->bVal != YXInfoAry3[i]->bPreVal)
  1069. {
  1070. YXInfoAry3[i]->bPreVal = YXInfoAry3[i]->bVal;
  1071. YXInfoAry3[i]->bChanged = 1;
  1072. nChangedYXNum ++;
  1073. }
  1074. else
  1075. YXInfoAry3[i]->bChanged = 0;
  1076. }
  1077. }
  1079.   try
  1080.   {
  1081. if (bSaveAll)
  1082. {
  1083. nChangedYCNum = nYCNum;
  1084. nChangedYXNum = nYXNum;
  1085. }
  1087. fWR.Write (&nChangedYCNum, sizeof(int));
  1088. for (int i=0; i<nYCNum; i++)
  1089. {
  1090. if (bRTUMea)
  1091. {
  1092. if (YCInfoAry1[i]->bChanged || bSaveAll)
  1093. {
  1094. fWR.Write (&(YCInfoAry1[i]->DBID), sizeof(DBID));
  1095. fWR.Write (&YCInfoAry1[i]->fVal, sizeof (float));
  1096. }
  1097. }
  1098. else
  1099. {
  1100. if (YCInfoAry3[i]->bChanged || bSaveAll)
  1101. {
  1102. fWR.Write (&(YCInfoAry3[i]->DBID), sizeof(DBID));
  1103. fWR.Write (&YCInfoAry3[i]->fVal, sizeof (float));
  1104. }
  1105. }
  1106. }
  1108. fWR.Write (&nChangedYXNum, sizeof(int));
  1109. for (i=0; i<nYXNum; i++)
  1110. {
  1111. if (bRTUMea)
  1112. {
  1113. if (YXInfoAry1[i]->bChanged || bSaveAll)
  1114. {
  1115. fWR.Write (&(YXInfoAry1[i]->DBID), sizeof(DBID));
  1116. fWR.Write (&YXInfoAry1[i]->bVal, sizeof (BYTE));
  1117. }
  1118. }
  1119. else
  1120. {
  1121. if (YXInfoAry3[i]->bChanged || bSaveAll)
  1122. {
  1123. fWR.Write (&(YXInfoAry3[i]->DBID), sizeof(DBID));
  1124. fWR.Write (&YXInfoAry3[i]->bVal, sizeof (BYTE));
  1125. }
  1126. }
  1127. }
  1128. fWR.Close();
  1129.   }
  1130.   catch(...){return FALSE;}
  1132.   bSaveAll = FALSE;
  1133.   return TRUE;
  1134. }
  1136. void FreeRTUYXYCInfo()
  1137. {
  1138. int nRTUNum = RtuAry.GetSize();
  1139. for (int i=0; i<nRTUNum; i++) delete RtuAry[i];
  1140. RtuAry.RemoveAll();
  1142. int nYCNum = YCInfoAry1.GetSize();
  1143. for (i=0; i<nYCNum; i++) delete YCInfoAry1[i];
  1144. YCInfoAry1.RemoveAll();
  1146. int nYXNum = YXInfoAry1.GetSize();
  1147. for (i=0; i<nYXNum; i++) delete YXInfoAry1[i];
  1148. YXInfoAry1.RemoveAll();
  1149. }
  1151. void FreeFileYXYCInfo()
  1152. {
  1153. int nYCNum = YCInfoAry2.GetSize();
  1154. for (int i=0; i<nYCNum; i++) delete YCInfoAry2[i];
  1155. YCInfoAry2.RemoveAll();
  1157. int nYXNum = YXInfoAry2.GetSize();
  1158. for (i=0; i<nYXNum; i++) delete YXInfoAry2[i];
  1159. YXInfoAry2.RemoveAll();
  1160. }
  1162. void FreeMeaCoefInfo()
  1163. {
  1164. int nStaNum = StaParaAry.GetSize();
  1165. for (int i=0; i<nStaNum; i++) delete StaParaAry[i];
  1166. StaParaAry.RemoveAll();
  1168. int nCTNum = CTParaAry.GetSize();
  1169. for (i=0; i<nCTNum; i++) delete CTParaAry[i];
  1170. CTParaAry.RemoveAll();
  1172. int nPTNum = PTParaAry.GetSize();
  1173. for (i=0; i<nPTNum; i++) delete PTParaAry[i];
  1174. PTParaAry.RemoveAll();
  1176. int nVAMeaNum = VAMeaParaAry.GetSize();
  1177. for (i=0; i<nVAMeaNum; i++) delete VAMeaParaAry[i];
  1178. VAMeaParaAry.RemoveAll();
  1180. int nCBNum = CBParaAry.GetSize();
  1181. for (i=0; i<nCBNum; i++) delete CBParaAry[i];
  1182. CBParaAry.RemoveAll();
  1184. int nDisNum = DisParaAry.GetSize();
  1185. for (i=0; i<nDisNum; i++) delete DisParaAry[i];
  1186. DisParaAry.RemoveAll();
  1188. int nTranNum = TranParaAry.GetSize();
  1189. for (i=0; i<nTranNum; i++) delete TranParaAry[i];
  1190. TranParaAry.RemoveAll();
  1192. int nYCNum = YCInfoAry3.GetSize();
  1193. for (i=0; i<nYCNum; i++) delete YCInfoAry3[i];
  1194. YCInfoAry3.RemoveAll();
  1196. int nYXNum = YXInfoAry3.GetSize();
  1197. for (i=0; i<nYXNum; i++) delete YXInfoAry3[i];
  1198. YXInfoAry3.RemoveAll();
  1199. };
  1201. BOOL ReadMeaCoefInfo()
  1202. {
  1203. FreeMeaCoefInfo();
  1205. // 电网参数
  1206. CPwrNet PwrNet;
  1207. if (PwrNet.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  1208. {
  1209. PWRNETPARA PwrNetPara;
  1210. lstrcpyn(PwrNetPara.szName, PwrNet.m_MingZi, PwrNet.m_MingZi.GetLength()+1);
  1211. CutSpaceChar(PwrNetPara.szName, 32);
  1213. PwrNetPara.fPCoef = PwrNet.m_PCoef;
  1214. PwrNetPara.fQCoef = PwrNet.m_QCoef;
  1215. PwrNetPara.fFCoef = 100.f;
  1216. PwrNet.Close();
  1217. }
  1218. else
  1219. return FALSE;
  1221. // 合肥电话 0551-3701024
  1222. // 厂站参数
  1223. CStation Station;
  1224. Station.m_strSort = ("ID");
  1225. Station.m_strFilter = ("ID>0");
  1226. if (Station.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  1227. {
  1228. while(!Station.IsEOF())
  1229. {
  1230. LPSTATIONPARA pStaPara = new STATIONPARA;
  1231. lstrcpyn(pStaPara->szName, Station.m_MingZi, Station.m_MingZi.GetLength()+1);
  1232. CutSpaceChar(pStaPara->szName, 32);
  1234. pStaPara->ID = Station.m_ID;
  1235. pStaPara->fPCoef = Station.m_PCoef;
  1236. pStaPara->fQCoef = Station.m_QCoef;
  1237. pStaPara->fFCoef = 100.f;
  1239. StaParaAry.Add(pStaPara);
  1240. Station.MoveNext();
  1241. }
  1242. Station.Close();
  1243. }
  1244. else
  1245. return FALSE;
  1247. // CT参数
  1248. CCT CT;
  1249. CT.m_strSort = ("ID");
  1250. CT.m_strFilter = ("ID>0");
  1251. if (CT.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  1252. {
  1253. while(!CT.IsEOF())
  1254. {
  1255. LPCTPARA pCTPara = new CTPARA;
  1256. lstrcpyn(pCTPara->szName, CT.m_MingZi, CT.m_MingZi.GetLength()+1);
  1257. CutSpaceChar(pCTPara->szName, 32);
  1259. pCTPara->ID = CT.m_ID;
  1260. pCTPara->fPCoef = CT.m_PCoef;
  1261. pCTPara->fQCoef = CT.m_QCoef;
  1262. pCTPara->fPOffSet = CT.m_POffset;
  1263. pCTPara->fQOffSet = CT.m_QOffset;
  1264. #ifdef NEW_SYSTEM
  1265. pCTPara->fIACoef = CT.m_IACoef;
  1266. pCTPara->fIAOffSet = CT.m_IAOffset;
  1267. pCTPara->fIBCoef = CT.m_IBCoef;
  1268. pCTPara->fIBOffSet = CT.m_IBOffset;
  1269. pCTPara->fICCoef = CT.m_ICCoef;
  1270. pCTPara->fICOffSet = CT.m_ICOffset;
  1271. #else
  1272. pCTPara->fICoef = CT.m_ICoef;
  1273. pCTPara->fIOffSet = CT.m_IOffset;
  1274. #endif
  1275. CTParaAry.Add(pCTPara);
  1276. CT.MoveNext();
  1277. }
  1278. CT.Close();
  1279. }
  1280. else
  1281. return FALSE;
  1283. // PT参数
  1284. CPT PT;
  1285. PT.m_strSort = ("ID");
  1286. PT.m_strFilter = ("ID>0");
  1287. if (PT.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  1288. {
  1289. while(!PT.IsEOF())
  1290. {
  1291. LPPTPARA pPTPara = new PTPARA;
  1292. lstrcpyn(pPTPara->szName, PT.m_MingZi, PT.m_MingZi.GetLength()+1);
  1293. CutSpaceChar(pPTPara->szName, 32);
  1295. pPTPara->ID = PT.m_ID;
  1296. pPTPara->fVACoef = PT.m_VACoef;
  1297. pPTPara->fVBCoef = PT.m_VBCoef;
  1298. pPTPara->fVCCoef = PT.m_VCCoef;
  1300. pPTPara->fVAOffSet = PT.m_VAOffset;
  1301. pPTPara->fVBOffSet = PT.m_VBOffset;
  1302. pPTPara->fVBOffSet = PT.m_VCOffset;
  1303. #ifdef NEW_SYSTEM
  1304. pPTPara->fVABCoef = PT.m_VXABCoef;
  1305. pPTPara->fVABOffSet = PT.m_VXABOffset;
  1306. pPTPara->fVBCCoef = PT.m_VXBCCoef;
  1307. pPTPara->fVBCOffSet = PT.m_VXBCOffset;
  1308. pPTPara->fVACCoef = PT.m_VXBCCoef;
  1309. pPTPara->fVACOffSet = PT.m_VXBCOffset;
  1310. #else
  1311. pPTPara->fVXCoef = PT.m_VXCoef;
  1312. pPTPara->fVXOffSet = PT.m_VXOffset;
  1313. #endif
  1314. PTParaAry.Add(pPTPara);
  1315. PT.MoveNext();
  1316. }
  1317. PT.Close();
  1318. }
  1319. else
  1320. return FALSE;
  1322. // 虚拟量参数
  1323. CAMea VAMea;
  1324. VAMea.m_strSort = ("ID");
  1325. VAMea.m_strFilter = ("ID>0");
  1326. if (VAMea.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  1327. {
  1328. while(!VAMea.IsEOF())
  1329. {
  1330. LPVAMEAPARA pVAMeaPara = new VAMEAPARA;
  1331. lstrcpyn(pVAMeaPara->szName, VAMea.m_MingZi, VAMea.m_MingZi.GetLength()+1);
  1332. CutSpaceChar(pVAMeaPara->szName, 32);
  1334. pVAMeaPara->ID = VAMea.m_ID;
  1335. pVAMeaPara->fCoef = VAMea.m_Coef;
  1336. pVAMeaPara->fOffSet = VAMea.m_OffSetVal;
  1338. VAMeaParaAry.Add(pVAMeaPara);
  1339. VAMea.MoveNext();
  1340. }
  1341. VAMea.Close();
  1342. }
  1343. else
  1344. return FALSE;
  1346. // 开关参数
  1347. CCB CBRec;
  1348. CBRec.m_strSort = ("ID");
  1349. CBRec.m_strFilter = ("ID>0");
  1350. if (CBRec.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  1351. {
  1352. while(!CBRec.IsEOF())
  1353. {
  1354. LPCBPARA pCBPara = new CBPARA;
  1355. lstrcpyn(pCBPara->szName, CBRec.m_MingZi, CBRec.m_MingZi.GetLength()+1);
  1356. CutSpaceChar(pCBPara->szName, 32);
  1358. pCBPara->ID = CBRec.m_ID;
  1359. pCBPara->bNot = CBRec.m_YXConnect;
  1360. pCBPara->bTwoBit = CBRec.m_YXCMode;
  1362. CBParaAry.Add(pCBPara);
  1363. CBRec.MoveNext();
  1364. }
  1365. CBRec.Close();
  1366. }
  1367. else
  1368. return FALSE;
  1370. // 刀闸参数
  1371. CDisCon DisRec;
  1372. DisRec.m_strSort = ("ID");
  1373. DisRec.m_strFilter = ("ID>0");
  1374. if (DisRec.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  1375. {
  1376. while(!DisRec.IsEOF())
  1377. {
  1378. LPDISPARA pDisPara = new DISPARA;
  1379. lstrcpyn(pDisPara->szName, DisRec.m_MingZi, DisRec.m_MingZi.GetLength()+1);
  1380. CutSpaceChar(pDisPara->szName, 32);
  1382. pDisPara->ID = DisRec.m_ID;
  1383. pDisPara->bNot = DisRec.m_Nots;
  1385. DisParaAry.Add(pDisPara);
  1386. DisRec.MoveNext();
  1387. }
  1388. DisRec.Close();
  1389. }
  1390. else
  1391. return FALSE;
  1393. // 变压器参数
  1394. CTran TranRec;
  1395. TranRec.m_strSort = ("ID");
  1396. TranRec.m_strFilter = ("ID>0");
  1397. if (TranRec.Open(CRecordset::forwardOnly, NULL, CRecordset::readOnly))
  1398. {
  1399. while(!TranRec.IsEOF())
  1400. {
  1401. LPTRANPARA pTranPara = new TRANPARA;
  1402. lstrcpyn(pTranPara->szName, TranRec.m_MingZi, TranRec.m_MingZi.GetLength()+1);
  1403. CutSpaceChar(pTranPara->szName, 32);
  1405. pTranPara->ID = TranRec.m_ID;
  1406. pTranPara->bLTC = TranRec.m_DYMode;
  1407. pTranPara->fTapCoef = TranRec.m_DWCoef;
  1409. TranParaAry.Add(pTranPara);
  1410. TranRec.MoveNext();
  1411. }
  1412. TranRec.Close();
  1413. }
  1414. else
  1415. return FALSE;
  1417. CreateMeaAryFromPwrNet();
  1418. return TRUE;
  1419. };
  1421. BOOL GetMeaCoef(PDBID pDBID, float* pCoef, float* pOffSet, CString& strInfo)
  1422. {
  1423. *pCoef = 1.f; *pOffSet = 0.f;
  1424. if (pDBID->byBjType == DianWangTab_ID)
  1425. {
  1426. if (pDBID->byCShType == DW_P)
  1427. {
  1428. *pCoef = PwrNetPara.fPCoef;
  1429. strInfo = "电网有功";
  1430. }
  1431. else if (pDBID->byCShType == DW_Q)
  1432. {
  1433. *pCoef = PwrNetPara.fQCoef;
  1434. strInfo = "电网无功";
  1435. }
  1436. else if (pDBID->byCShType == DW_PinLu)
  1437. {
  1438. *pCoef = PwrNetPara.fFCoef;
  1439. strInfo = "电网频率";
  1440. }
  1441. }
  1443. else if (pDBID->byBjType == ChangZhanTab_ID)
  1444. {
  1445. int nStaNum = StaParaAry.GetSize();
  1446. if (nStaNum<1) return FALSE;
  1447. int nStart = 0, nEnd = nStaNum-1;
  1448. LPSTATIONPARA pStaPara = NULL;
  1449. do
  1450. {
  1451. int nMid = (nStart+nEnd)/2;
  1452. if (StaParaAry[nMid]->ID == pDBID->nBjID)
  1453. {
  1454. pStaPara = StaParaAry[nMid]; break;
  1455. }
  1456. else if (StaParaAry[nStart]->ID == pDBID->nBjID)
  1457. {
  1458. pStaPara = StaParaAry[nStart]; break;
  1459. }
  1460. else if (StaParaAry[nEnd]->ID == pDBID->nBjID)
  1461. {
  1462. pStaPara = StaParaAry[nEnd]; break;
  1463. }
  1464. else if (StaParaAry[nMid]->ID > pDBID->nBjID)
  1465. nEnd = nMid;
  1466. else 
  1467. nStart = nMid; 
  1468. if (nStart == nEnd || nStart+1 == nEnd) break;
  1469. }while (TRUE);
  1470. if (pStaPara)
  1471. {
  1472. if (pDBID->byCShType == CZ_P)
  1473. {
  1474. *pCoef = pStaPara->fPCoef;
  1475. strInfo.Format("%s--%s", pStaPara->szName, "有功");
  1476. }
  1477. else if (pDBID->byCShType == CZ_Q)
  1478. {
  1479. *pCoef = pStaPara->fQCoef;
  1480. strInfo.Format("%s--%s", pStaPara->szName, "无功");
  1481. }
  1482. else if (pDBID->byCShType == CZ_PinLu)
  1483. {
  1484. *pCoef = pStaPara->fFCoef;
  1485. strInfo.Format("%s--%s", pStaPara->szName, "频率");
  1486. }
  1487. }
  1488. else
  1489. return FALSE;
  1490. }
  1492. else if (pDBID->byBjType == CTTab_ID)
  1493. {
  1494. int nCTNum = CTParaAry.GetSize();
  1495. if (nCTNum<1) return FALSE;
  1496. int nStart = 0, nEnd = nCTNum-1;
  1497. LPCTPARA pCTPara = NULL;
  1498. do
  1499. {
  1500. int nMid = (nStart+nEnd)/2;
  1501. if (CTParaAry[nMid]->ID == pDBID->nBjID)
  1502. {
  1503. pCTPara = CTParaAry[nMid]; break;
  1504. }
  1505. else if (CTParaAry[nStart]->ID == pDBID->nBjID)
  1506. {
  1507. pCTPara = CTParaAry[nStart]; break;
  1508. }
  1509. else if (CTParaAry[nEnd]->ID == pDBID->nBjID)
  1510. {
  1511. pCTPara = CTParaAry[nEnd]; break;
  1512. }
  1513. else if (CTParaAry[nMid]->ID > pDBID->nBjID)
  1514. nEnd = nMid;
  1515. else 
  1516. nStart = nMid; 
  1517. if (nStart == nEnd || nStart+1 == nEnd) break;
  1518. }while (TRUE);
  1519. if (pCTPara)
  1520. {
  1521. if (pDBID->byCShType == CT_P)
  1522. {
  1523. *pCoef = pCTPara->fPCoef;
  1524. *pOffSet = pCTPara->fPOffSet;
  1525. strInfo.Format("%s--%s", pCTPara->szName, "有功");
  1526. }
  1527. else if (pDBID->byCShType == CT_Q)
  1528. {
  1529. *pCoef = pCTPara->fQCoef;
  1530. *pOffSet = pCTPara->fQOffSet;
  1531. strInfo.Format("%s--%s", pCTPara->szName, "无功");
  1532. }
  1533. #ifdef NEW_SYSTEM
  1534. else if (pDBID->byCShType == CT_Ia)
  1535. {
  1536. *pCoef = pCTPara->fIACoef;
  1537. *pOffSet = pCTPara->fIAOffSet;
  1538. strInfo.Format("%s--%s", pCTPara->szName, "A相电流");
  1539. }
  1540. else if (pDBID->byCShType == CT_Ib)
  1541. {
  1542. *pCoef = pCTPara->fIBCoef;
  1543. *pOffSet = pCTPara->fIBOffSet;
  1544. strInfo.Format("%s--%s", pCTPara->szName, "B相电流");
  1545. }
  1546. else if (pDBID->byCShType == CT_Ic)
  1547. {
  1548. *pCoef = pCTPara->fICCoef;
  1549. *pOffSet = pCTPara->fICOffSet;
  1550. strInfo.Format("%s--%s", pCTPara->szName, "C相电流");
  1551. }
  1552. #else
  1553. else if (pDBID->byCShType == CT_I)
  1554. {
  1555. *pCoef = pCTPara->fICoef;
  1556. *pOffSet = pCTPara->fIOffSet;
  1557. strInfo.Format("%s--%s", pCTPara->szName, "电流");
  1558. }
  1559. #endif
  1560. }
  1561. else
  1562. return FALSE;
  1563. }
  1565. else if (pDBID->byBjType == PTTab_ID)
  1566. {
  1567. int nPTNum = PTParaAry.GetSize();
  1568. if (nPTNum<1) return FALSE;
  1569. int nStart = 0, nEnd = nPTNum-1;
  1570. LPPTPARA pPTPara = NULL;
  1571. do
  1572. {
  1573. int nMid = (nStart+nEnd)/2;
  1574. if (PTParaAry[nMid]->ID == pDBID->nBjID)
  1575. {
  1576. pPTPara = PTParaAry[nMid]; break;
  1577. }
  1578. else if (PTParaAry[nStart]->ID == pDBID->nBjID)
  1579. {
  1580. pPTPara = PTParaAry[nStart]; break;
  1581. }
  1582. else if (PTParaAry[nEnd]->ID == pDBID->nBjID)
  1583. {
  1584. pPTPara = PTParaAry[nEnd]; break;
  1585. }
  1586. else if (PTParaAry[nMid]->ID > pDBID->nBjID)
  1587. nEnd = nMid;
  1588. else 
  1589. nStart = nMid; 
  1590. if (nStart == nEnd || nStart+1 == nEnd) break;
  1591. }while (TRUE);
  1592. if (pPTPara)
  1593. {
  1594. if (pDBID->byCShType == PT_VA)
  1595. {
  1596. *pCoef = pPTPara->fVACoef;
  1597. *pOffSet = pPTPara->fVAOffSet;
  1598. strInfo.Format("%s--%s", pPTPara->szName, "A相电压");
  1599. }
  1600. else if (pDBID->byCShType == PT_VB)
  1601. {
  1602. *pCoef = pPTPara->fVBCoef;
  1603. *pOffSet = pPTPara->fVBOffSet;
  1604. strInfo.Format("%s--%s", pPTPara->szName, "B相电压");
  1605. }
  1606. else if (pDBID->byCShType == PT_VC)
  1607. {
  1608. *pCoef = pPTPara->fVCCoef;
  1609. *pOffSet = pPTPara->fVCOffSet;
  1610. strInfo.Format("%s--%s", pPTPara->szName, "C相电压");
  1611. }
  1612. #ifdef NEW_SYSTEM
  1613. else if (pDBID->byCShType == PT_VabX)
  1614. {
  1615. *pCoef = pPTPara->fVABCoef;
  1616. *pOffSet = pPTPara->fVABOffSet;
  1617. strInfo.Format("%s--%s", pPTPara->szName, "AB线电压");
  1618. }
  1619. else if (pDBID->byCShType == PT_VbcX)
  1620. {
  1621. *pCoef = pPTPara->fVBCCoef;
  1622. *pOffSet = pPTPara->fVBCOffSet;
  1623. strInfo.Format("%s--%s", pPTPara->szName, "BC线电压");
  1624. }
  1625. else if (pDBID->byCShType == PT_VcaX)
  1626. {
  1627. *pCoef = pPTPara->fVACCoef;
  1628. *pOffSet = pPTPara->fVACOffSet;
  1629. strInfo.Format("%s--%s", pPTPara->szName, "AC线电压");
  1630. }
  1631. #else
  1632. else if (pDBID->byCShType == PT_VX)
  1633. {
  1634. *pCoef = pPTPara->fVXCoef;
  1635. *pOffSet = pPTPara->fVXOffSet;
  1636. strInfo.Format("%s--%s", pPTPara->szName, "线电压");
  1637. }
  1638. #endif
  1639. }
  1640. else
  1641. return FALSE;
  1642. }
  1644. else if (pDBID->byBjType == XuNiDMNLiangTab_ID)
  1645. {
  1646. int nVAMeaNum = VAMeaParaAry.GetSize();
  1647. if (nVAMeaNum<1) return FALSE;
  1648. int nStart = 0, nEnd = nVAMeaNum-1;
  1649. LPVAMEAPARA pVAMeaPara = NULL;
  1650. do
  1651. {
  1652. int nMid = (nStart+nEnd)/2;
  1653. if (VAMeaParaAry[nMid]->ID == pDBID->nBjID)
  1654. {
  1655. pVAMeaPara = VAMeaParaAry[nMid]; break;
  1656. }
  1657. else if (VAMeaParaAry[nStart]->ID == pDBID->nBjID)
  1658. {
  1659. pVAMeaPara = VAMeaParaAry[nStart]; break;
  1660. }
  1661. else if (VAMeaParaAry[nEnd]->ID == pDBID->nBjID)
  1662. {
  1663. pVAMeaPara = VAMeaParaAry[nEnd]; break;
  1664. }
  1665. else if (VAMeaParaAry[nMid]->ID > pDBID->nBjID)
  1666. nEnd = nMid;
  1667. else 
  1668. nStart = nMid; 
  1669. if (nStart == nEnd || nStart+1 == nEnd) break;
  1670. }while (TRUE);
  1671. if (pVAMeaPara)
  1672. {
  1673. if (pDBID->byCShType == XN_XNValue)
  1674. {
  1675. *pCoef = pVAMeaPara->fCoef;
  1676. *pOffSet = pVAMeaPara->fOffSet;
  1677. strInfo.Format("%s--%s", pVAMeaPara->szName, "数值");
  1678. }
  1679. }
  1680. else
  1681. return FALSE;
  1682. }
  1684. else if (pDBID->byBjType == KaiGuanTab_ID)
  1685. {
  1686. *pCoef = 0.f;
  1687. int nCBNum = CBParaAry.GetSize();
  1688. if (nCBNum<1) return FALSE;
  1689. int nStart = 0, nEnd = nCBNum-1;
  1690. LPCBPARA pCBPara = NULL;
  1691. do
  1692. {
  1693. int nMid = (nStart+nEnd)/2;
  1694. if (CBParaAry[nMid]->ID == pDBID->nBjID)
  1695. {
  1696. pCBPara = CBParaAry[nMid]; break;
  1697. }
  1698. else if (CBParaAry[nStart]->ID == pDBID->nBjID)
  1699. {
  1700. pCBPara = CBParaAry[nStart]; break;
  1701. }
  1702. else if (CBParaAry[nEnd]->ID == pDBID->nBjID)
  1703. {
  1704. pCBPara = CBParaAry[nEnd]; break;
  1705. }
  1706. else if (CBParaAry[nMid]->ID > pDBID->nBjID)
  1707. nEnd = nMid;
  1708. else 
  1709. nStart = nMid; 
  1710. if (nStart == nEnd || nStart+1 == nEnd) break;
  1711. }while (TRUE);
  1712. if (pCBPara)
  1713. {
  1714. if (pDBID->byCShType == KG_RTUKG1)
  1715. {
  1716. strInfo.Format("%s--%s", pCBPara->szName, "开关状态1");
  1717. *pCoef = float(pCBPara->bNot);
  1718. }
  1719. else if (pDBID->byCShType == KG_RTUKG2)
  1720. {
  1721. strInfo.Format("%s--%s", pCBPara->szName, "开关状态2");
  1722. *pCoef = float(pCBPara->bNot);
  1723. }
  1724. }
  1725. else
  1726. return FALSE;
  1727. }
  1729. else if (pDBID->byBjType == DaoZhaTab_ID)
  1730. {
  1731. *pCoef = 0.f;
  1732. int nDisNum = DisParaAry.GetSize();
  1733. if (nDisNum<1) return FALSE;
  1734. int nStart = 0, nEnd = nDisNum-1;
  1735. LPDISPARA pDisPara = NULL;
  1736. do
  1737. {
  1738. int nMid = (nStart+nEnd)/2;
  1739. if (DisParaAry[nMid]->ID == pDBID->nBjID)
  1740. {
  1741. pDisPara = DisParaAry[nMid]; break;
  1742. }
  1743. else if (DisParaAry[nStart]->ID == pDBID->nBjID)
  1744. {
  1745. pDisPara = DisParaAry[nStart]; break;
  1746. }
  1747. else if (DisParaAry[nEnd]->ID == pDBID->nBjID)
  1748. {
  1749. pDisPara = DisParaAry[nEnd]; break;
  1750. }
  1751. else if (DisParaAry[nMid]->ID > pDBID->nBjID)
  1752. nEnd = nMid;
  1753. else 
  1754. nStart = nMid; 
  1755. if (nStart == nEnd || nStart+1 == nEnd) break;
  1756. }while (TRUE);
  1757. if (pDisPara)
  1758. {
  1759. if (pDBID->byCShType == DZ_DZState)
  1760. {
  1761. *pCoef = float(pDisPara->bNot);
  1762. strInfo.Format("%s--%s", pDisPara->szName, "刀闸状态");
  1763. }
  1764. }
  1765. else
  1766. return FALSE;
  1767. }
  1769. return TRUE;
  1770. }
  1772. BOOL LoadRTDataFromFile(LPCSTR lpFName)
  1773. {
  1774. if (bYXYCAryBusy) return FALSE;
  1776. CFile fRD;
  1777. if (lpFName == NULL) return FALSE;
  1778. BOOL bOper = fRD.Open(lpFName, CFile::modeRead);
  1779. if (!bOper) return FALSE;
  1781. bYXYCAryBusy = TRUE;
  1782. FreeFileYXYCInfo();
  1784. char szFile[] = "c:\ies500\tmp\YC-YX数据信息.INF";
  1785. FILE* pFile = fopen(szFile, "w");
  1787. // 数值项个数
  1788. float fCoef, fOffSet;
  1789. CString strInfo;
  1790. int nYCNum, nYXNum;
  1791. try
  1792. {
  1793. fRD.Read(&nYCNum, sizeof(int));
  1794. if (pFile) fprintf(pFile, "YC数目：%dnn", nYCNum);
  1795. if (nYCNum>0)
  1796. {
  1797. for (int i=0; i<nYCNum; i++)
  1798. {
  1799. PRTUYC pRTUYC = new RTUYC;
  1800. fRD.Read(&(pRTUYC->DBID), sizeof(DBID));
  1801. fRD.Read(&(pRTUYC->fVal), sizeof(float));
  1802. //dtting
  1803. if (GetMeaCoef(&(pRTUYC->DBID), &fCoef, &fOffSet, strInfo))
  1804. {
  1805. pRTUYC->fVal = pRTUYC->fVal/fCoef;
  1806. }
  1807. else
  1808. {
  1809. fprintf(pFile,"部件类型：%d  ID:%d  参数：%dn",pRTUYC->DBID.byBjType,pRTUYC->DBID.nBjID,pRTUYC->DBID.byCShType);
  1810. pRTUYC->fVal = pRTUYC->fVal/fCoef;
  1811. }
  1812. YCInfoAry2.Add(pRTUYC);
  1813. }
  1814. }
  1816. fRD.Read(&nYXNum, sizeof(int));
  1817. if (pFile) fprintf(pFile, "YX数目：%dnn", nYXNum);
  1818. if (nYXNum>0)
  1819. {
  1820. for (int i=0; i<nYXNum; i++)
  1821. {
  1822. PRTUYX pRTUYX = new RTUYX;
  1823. fRD.Read(&(pRTUYX->DBID), sizeof(DBID));
  1824. YXInfoAry2.Add(pRTUYX);
  1826. fRD.Read(&pRTUYX->bVal, sizeof(BYTE));
  1827. PRTUYX pRTUYX2 = NULL;
  1829. // 开关状态的处理(KG_RTUKG1, KG_RTUKG2)
  1830. if (pRTUYX->DBID.byBjType == KaiGuanTab_ID && 
  1831. pRTUYX->DBID.byCShType == KG_RTUKG1)
  1832. pRTUYX->bVal = pRTUYX->bVal & 1;
  1833. else if (pRTUYX->DBID.byBjType == KaiGuanTab_ID && 
  1834. pRTUYX->DBID.byCShType == KG_RTUKG2)
  1835. pRTUYX->bVal = (pRTUYX->bVal&2)/2;
  1836. else if (pRTUYX->DBID.byBjType == KaiGuanTab_ID && 
  1837. pRTUYX->DBID.byCShType == KG_KGState)
  1838. {
  1839. pRTUYX->DBID.byCShType = KG_RTUKG1;
  1840. pRTUYX->bVal = pRTUYX->bVal & 1;
  1842. pRTUYX2 = new RTUYX;
  1843. memcpy(pRTUYX2, pRTUYX, sizeof(RTUYX));
  1844. pRTUYX2->bVal = (pRTUYX->bVal&2)/2;
  1845. pRTUYX2->DBID.byCShType = KG_RTUKG2;
  1846. YXInfoAry2.Add(pRTUYX2);
  1847. }
  1849. GetMeaCoef(&(pRTUYX->DBID), &fCoef, &fOffSet, strInfo);
  1850. if (fCoef == 1.f) pRTUYX->bVal = !pRTUYX->bVal;
  1852. if (pRTUYX2 && fCoef == 1.f) pRTUYX2->bVal = !pRTUYX2->bVal;
  1853. }
  1854. }
  1855. if (pFile) fclose(pFile);
  1856. fRD.Close();
  1857. }
  1858. catch(...) {return FALSE;}
  1859. bYXYCAryBusy = FALSE;
  1861. return TRUE;
  1862. }
  1864. CSEventSequence CSEvtSeq(ALL_TYPE); // 声明一参数事项队类(指针)
  1865. CSEVENT csEvent;
  1866. // 保存电网数据事项触发 2001.8.1 TIANFZ
  1867. // 检查变压器分接头调整、开关变位、刀闸变位事项
  1868. BOOL BeSCADAEventProcess()
  1869. {
  1870. BOOL bEvtPrc = FALSE;
  1871. int EvtLeftNum = CSEvtSeq.GetEventNum(); // 此时的未处理事项的数目
  1872. while(EvtLeftNum>0)
  1873. {
  1874. //返回值为真， 则有事项存在且未处理，读完全部事项
  1875. if(CSEvtSeq.ReadaEvent(&csEvent, EvtLeftNum))
  1876. {
  1877. // 为避免重复，只判断非 SOE 事项
  1878. if(csEvent.SOEFlag) continue;
  1879. if(csEvent.EventType == BYQEvent)
  1880. {
  1881. if(csEvent.CSType == BYQFJT) bEvtPrc = TRUE;
  1882. }
  1883. else if(csEvent.EventType == KGEvent)
  1884. {
  1885. if(csEvent.CSType == KG) bEvtPrc = TRUE;
  1886. }
  1887. else if(csEvent.EventType == DZEvent)
  1888. {
  1889. if(csEvent.CSType == DZ) bEvtPrc = TRUE;
  1890. }
  1891. }
  1892. };
  1893. return bEvtPrc;
  1894. }
  1896. void Ary2ToAry1()
  1897. {
  1898. int nYC2 = YCInfoAry2.GetSize();
  1899. int nYX2 = YXInfoAry2.GetSize();
  1900. int nYC1 = YCInfoAry1.GetSize();
  1901. int nYX1 = YXInfoAry1.GetSize();
  1902. for (int i=0; i<nYC1; i++) YCInfoAry1[i]->bChanged = 0;
  1903. for (i=0; i<nYX1; i++) YXInfoAry1[i]->bChanged = 0;
  1905. PRTUYC pRTUYC = NULL;
  1906. for (i=0; i<nYC2; i++)
  1907. {
  1908. BOOL bFound = FALSE;
  1909. pRTUYC = YCInfoAry2[i];
  1910. for (int j=0; j<nYC1; j++)
  1911. {
  1912. if (memcmp(&(pRTUYC->DBID), &(YCInfoAry1[j]->DBID), sizeof(DBID)) == 0)
  1913. {
  1914. bFound = TRUE; break;
  1915. }
  1916. }
  1917. if (bFound)
  1918. {
  1919. if (fabs(YCInfoAry1[j]->fVal - pRTUYC->fVal)>0.01)
  1920. {
  1921. YCInfoAry1[j]->fVal = pRTUYC->fVal;
  1922. YCInfoAry1[j]->bChanged = 1;
  1923. }
  1924. }
  1925. }
  1927. PRTUYX pRTUYX = NULL;
  1928. for (i=0; i<nYX2; i++)
  1929. {
  1930. BOOL bFound = FALSE;
  1931. pRTUYX = YXInfoAry2[i];
  1932. for (int j=0; j<nYX1; j++)
  1933. {
  1934. if (memcmp(&(pRTUYX->DBID), &(YXInfoAry1[j]->DBID), sizeof(DBID)) == 0)
  1935. {
  1936. bFound = TRUE; break;
  1937. }
  1938. }
  1939. if (bFound)
  1940. {
  1941. if (YXInfoAry1[j]->bVal != pRTUYX->bVal)
  1942. {
  1943. YXInfoAry1[j]->bVal = pRTUYX->bVal;
  1944. YXInfoAry1[j]->bChanged = 1;
  1945. }
  1946. }
  1947. }
  1948. }