BaseElectricEqpmt.cpp 42 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291
  1. #include "pch.h"
  2. #include "BaseElectricEqpmt.h"
  3. #include "PublicEqpmtID.h"
  4. #include "YD_Public_OCC.h"
  5. #include "ElectricEqpmt_PowerBolt.h"
  6. static int m_AlarmID=0;
  7. TrackRelationXDMAP BaseElectricEqpmt::m_TrackRelationXDMap;
  8. ErrorToProtectMAP BaseElectricEqpmt::m_mapErrorToProtect;
  9. CALLBACKFUNC_Telesignalisation BaseElectricEqpmt::m_hCallBackTelesignalisation = nullptr;
  10. void* BaseElectricEqpmt::m_pTelesignalisationOwner = nullptr;
  11. CALLBACKFUNC_DealElcTurnOffArea BaseElectricEqpmt::m_hCallBackDealElcTurnOffArea = nullptr;
  12. //int BaseElectricEqpmt::m_nCtrlMark = 0;
  13. CALLBACKFUNC_Deal400VLoadTurnOff BaseElectricEqpmt::m_hCallBackDeal400VLoadTurnOff = nullptr;
  14. ELCEQPMTALARMINFOMAP* BaseElectricEqpmt::m_EqpmtAlarmInfoMap;
  15. BaseElectricEqpmt::BaseElectricEqpmt()
  16. {
  17. //m_type = 0;
  18. //m_nRegion =0;
  19. m_OperStationID = -1;
  20. m_OperSubsysID = -1;
  21. m_OperViewID = -1;
  22. //m_TrackPower = -;
  23. //m_PreTrackPower;
  24. m_nRelationElcTurnOffArea = -1;
  25. m_nCurProtectID = -1;
  26. //CtrlArea=ELC_EQPMTCTRL_REMOTE;
  27. SetBaseType(0);
  28. SetSubType(-1);
  29. SetRegion(0);
  30. IsProhibitedReversion = false;
  31. isReallyEqpmt = false;
  32. isRealEqpmtFeedback = false;
  33. m_nRealEqpmtStatus = -1;
  34. m_nCtrlMark = 0;
  35. m_nDelaydurTime = Auto_CtrlExecution_Time;
  36. }
  37. //mod by yangs
  38. //新增整形参数 nDesSysID:消息指定发送系统ID
  39. //将状态变化更新到客户端
  40. void BaseElectricEqpmt::UpdateEqpmtStatus(ELEEQPMTMAP& eqpmtmap,int status,int ctrltype,int nDesSysID)
  41. {
  42. printf("-------------ElectricityVOC-BaseElectricEqpmt-UpdateEqpmtStatus--------------------\r");
  43. printf("-------------ElectricityVOC-BaseElectricEqpmt-UpdateEqpmtStatus-Timer: %d--------------------\r", GetSys_SecondTime_2());
  44. //m_status=status;
  45. if (p_SendList!=nullptr)
  46. {
  47. if (MRunLineID == 200)
  48. {
  49. }
  50. //else if(MRunLineID == 300 ||MRunLineID == 400 )//chenht
  51. {
  52. //1.向行调更新接触网/轨带电状态
  53. TrackRelationXDMAP::iterator iteTrackRelaXD = m_TrackRelationXDMap.find(GetEqpmentID());
  54. // iteTrackRelaXD = m_TrackRelationXDMap.find(m_strid);
  55. if (iteTrackRelaXD != m_TrackRelationXDMap.end())
  56. {
  57. if (GetStatus()!= status)
  58. {
  59. //m_PreTrackPower = iteTrackRelaXD->second->m_IsPower;
  60. //m_TrackPower = updatadata.Status;
  61. //m_TrackRelationXD.m_PreIsPower = iteTrackRelaXD->second->m_IsPower;
  62. m_TrackRelationXD.m_PreIsPower = GetStatus();
  63. m_TrackRelationXD.m_strID = GetEqpmentID();
  64. m_TrackRelationXD.m_IsPower = status;
  65. m_TrackRelationXD.m_NoID = iteTrackRelaXD->second->m_NoID;
  66. m_TrackRelationXD.m_Direction = iteTrackRelaXD->second->m_Direction;
  67. //iteTrackRelaXD->second->m_IsPower = updatadata.Status;
  68. COMMANDTOXD cmdtoxd;
  69. cmdtoxd.type = DDTOXD_ELCTRACK_STATUS;
  70. cmdtoxd.ObjectID = iteTrackRelaXD->second->m_NoID;
  71. cmdtoxd.data1 = status;
  72. cmdtoxd.data2 = iteTrackRelaXD->second->m_Direction;
  73. OCCCOMMAND tmpSendOC;
  74. tmpSendOC.cmdType = OCCCOMMAND::CmdType::eCommantoXD;
  75. tmpSendOC.DesSysType = OCC_SYS_XD_SVR;
  76. tmpSendOC.ScrSysType = OCC_SYS_DD_SVR;
  77. tmpSendOC.TrainningID = m_Trianid;
  78. tmpSendOC.DateLen = sizeof(COMMANDTOXD);
  79. tmpSendOC.Net_LS_CommandtoXD = cmdtoxd;
  80. p_SendList->push(tmpSendOC);
  81. }
  82. }
  83. }
  84. //2.更新设备状态
  85. //add by chenht 更具控制类型分别设置挂牌和状态
  86. switch(ctrltype)
  87. {
  88. case CTRLTYPE_CARD:
  89. {
  90. SetCardStatus(status);
  91. break;
  92. }
  93. case CTRLTYPE_STATUS:
  94. {
  95. SetStatus(status);
  96. break;
  97. }
  98. }
  99. //mod by yangs 控制分合闸时,在状态更新前进行自投分闸处理
  100. if (CTRLTYPE_STATUS == ctrltype)
  101. {
  102. CheckMotherAutoBolt(eqpmtmap);
  103. }
  104. //added by zhangjiahua
  105. DHEQPMTUPDATE updatadata;
  106. updatadata.CtrlLock=GetControlLock();
  107. updatadata.FaultLock=GetFaultLockStatus();
  108. updatadata.RemoteLock=GetRemoteLockStatus();
  109. updatadata.CommunicationStaus=GetCommunicationStatus();
  110. updatadata.CtrlArea=GetControlArea();
  111. updatadata.CtrlType = ctrltype;
  112. //updatadata.Status= GetStatus();
  113. updatadata.Status= status;
  114. updatadata.Category = GetBaseType();
  115. updatadata.SubSys = ISCS_SUBSYS_TYPE_ELC;
  116. string strID=GetEqpmentID();
  117. strncpy(updatadata.EqpmtStrID, strID.c_str(), sizeof(updatadata.EqpmtStrID));
  118. string strName=GetEqpmentName();
  119. strncpy(updatadata.EqpmtName,strName.c_str(), sizeof(updatadata.EqpmtName));
  120. updatadata.StationID = GetStationID();
  121. updatadata.ViewID = GetViewID();
  122. OCCCOMMAND tmpSendHC;
  123. tmpSendHC.setPacketValue(&updatadata,OCCCOMMAND::eUpdateEqpmtStatus);
  124. //没有指定系统ID发送则向全部客户端发送
  125. if (nDesSysID == 0)
  126. {
  127. tmpSendHC.DesSysType=OCC_SYS_DD_CLIENT;
  128. }
  129. else
  130. {
  131. tmpSendHC.DesSysType=OCC_SYS_SERVER_SETSYS;
  132. tmpSendHC.DesNetID=nDesSysID;
  133. }
  134. tmpSendHC.TrainningID = m_Trianid;
  135. tmpSendHC.ScrSysType=OCC_SYS_DD_SVR;
  136. p_SendList->push(tmpSendHC);
  137. //2.更新控制结果
  138. DHSVRREPLY CheckReplyMsg;
  139. string retstr;
  140. memset(CheckReplyMsg.ReplyText,0,ALARM_LEN);
  141. int autoboldstatus = -1;
  142. int ctrlLock = -1;
  143. ELEEQPMTMAP::iterator itereqpmt = eqpmtmap.find(GetEqpmentID());
  144. if (itereqpmt->second != nullptr && itereqpmt->second->GetBaseType() == OCC_EQPMTTYPE_AUTOBOLT)
  145. {
  146. autoboldstatus = itereqpmt->second->GetStatus();
  147. }
  148. if (itereqpmt->second != nullptr && (itereqpmt->second->GetBaseType() == OCC_EQPMTTYPE_35kVBREAKER
  149. || itereqpmt->second->GetBaseType() == OCC_EQPMTTYPE_400vACControlBreaker || itereqpmt->second->GetBaseType() == OCC_EQPMTTYPE_BREAKER_DC))
  150. {
  151. ctrlLock = itereqpmt->second->GetControlLock();
  152. }
  153. if (m_Trianid>0 && (autoboldstatus != -1 || ctrlLock != -1))
  154. {
  155. if (autoboldstatus == -1)
  156. {
  157. autoboldstatus = 1;
  158. }
  159. CheckReplyMsg.AutoBoltStatus = autoboldstatus;
  160. CheckReplyMsg.CtrlLock = ctrlLock;
  161. string strID=GetEqpmentID();
  162. CheckReplyMsg.CmdID = OCCCOMMAND::eUpdateOperCheck;
  163. strncpy(CheckReplyMsg.EqpmtStrID,strID.c_str(), sizeof(CheckReplyMsg.EqpmtStrID));
  164. //CheckReplyMsg.CtrlLock=CtrlLockStatus;
  165. //CheckReplyMsg.StdID = stdid;
  166. //CheckReplyMsg.EqpmtStatus =retstatus; //100表示通过,101拒绝
  167. CheckReplyMsg.StationID=m_OperStationID;
  168. CheckReplyMsg.ViewID = m_OperViewID;
  169. CheckReplyMsg.SubSysID = m_OperSubsysID;
  170. OCCCOMMAND NetOrder;
  171. //没有指定系统ID发送则向全部客户端发送
  172. if (nDesSysID == 0)
  173. {
  174. tmpSendHC.DesSysType=OCC_SYS_DD_CLIENT;
  175. }
  176. else
  177. {
  178. tmpSendHC.DesSysType=OCC_SYS_SERVER_SETSYS;
  179. tmpSendHC.DesNetID=nDesSysID;
  180. }
  181. NetOrder.ScrSysType = OCC_SYS_DD_SVR;
  182. NetOrder.TrainningID = m_Trianid;
  183. NetOrder.setPacketValue(&CheckReplyMsg,OCCCOMMAND::eUpdateSvrReply);
  184. p_SendList->push(NetOrder);
  185. }
  186. //m_PreTrackPower =
  187. // TrackRelationXDMAP::iterator iteTrackRelaXD = m_TrackRelationXDMap.find(m_strid);
  188. //// iteTrackRelaXD = m_TrackRelationXDMap.find(m_strid);
  189. // if (iteTrackRelaXD != m_TrackRelationXDMap.end())
  190. // {
  191. // if (iteTrackRelaXD->second->m_IsPower != updatadata.Status)
  192. // {
  193. // //m_PreTrackPower = iteTrackRelaXD->second->m_IsPower;
  194. // //m_TrackPower = updatadata.Status;
  195. // m_TrackRelationXD.m_PreIsPower = iteTrackRelaXD->second->m_IsPower;
  196. // m_TrackRelationXD.m_strID = m_strid;
  197. // m_TrackRelationXD.m_IsPower = updatadata.Status;
  198. // //iteTrackRelaXD->second->m_IsPower = updatadata.Status;
  199. // }
  200. // }
  201. }
  202. CheckElcEnvirRelation();
  203. InitiativeUnionCtrl(status,eqpmtmap);
  204. //mod by yangs 函数提前,在更新状态前进行自投逻辑判断处理
  205. //CheckMotherAutoBolt(eqpmtmap);
  206. // 处理合闸、分闸遥信
  207. DealTelesignalisation( GetStatus(), GetEqpmentID(), 1);
  208. DealTelesignalisation( !GetStatus(), GetEqpmentID(), 0);
  209. if(m_nCurProtectID==10000)
  210. {
  211. DealTelesignalisation( m_nCurProtectID, GetEqpmentID(), 0);
  212. }
  213. else if ( m_nCurProtectID > 0 /*&& GetStatus()*/ )
  214. {
  215. DealTelesignalisation( m_nCurProtectID, GetEqpmentID(), 0);
  216. }
  217. }
  218. void BaseElectricEqpmt::UpdateCommmunicationStatus(int status)
  219. {
  220. if (GetCommunicationStatus()!=status)
  221. {
  222. //m_nCommunicationStatus=status;
  223. SetCommunicationStatus(status);
  224. }
  225. }
  226. void BaseElectricEqpmt::CutCommunication(map<string,BaseElectricEqpmt*>& ElectricEqpmtMap)
  227. {
  228. UpdateCommmunicationStatus(1);
  229. UpdateEqpmtStatus(ElectricEqpmtMap,GetStatus());
  230. //xyx屏蔽begin
  231. //string text;
  232. //text.Format(" %s %s 通讯中断",GetBaseTypeName(),GetEqpmentName());
  233. //SendMsgNotice(GetSourceStationID(),ISCS_SUBSYS_TYPE_ELC,3,DH_MSGCATEGORY_SOE,text);
  234. //xyx屏蔽end
  235. //xyx修改begin
  236. string EqpmtTypeName = GetBaseTypeName(); //设备类型名称
  237. string EqpmtName = GetEqpmentName(); //设备名称
  238. int EqpmtSourceStatonID = GetSourceStationID(); //设备所属车站ID
  239. int EqpmtType = GetBaseType(); //设备类型
  240. int nActType = ElcAlarm_TripActType_Comloss; //“通讯中断”报文类型
  241. UpdateAlarmType(EqpmtType,EqpmtTypeName,EqpmtName,EqpmtSourceStatonID,nActType);
  242. //xyx修改end
  243. }
  244. void BaseElectricEqpmt::RevertCommunication(map<string,BaseElectricEqpmt*>& ElectricEqpmtMap)
  245. {
  246. UpdateCommmunicationStatus(0);
  247. UpdateEqpmtStatus(ElectricEqpmtMap,GetStatus());
  248. //xyx屏蔽begin
  249. //string text;
  250. //text.Format(" %s %s 通讯恢复",GetBaseTypeName(),GetEqpmentName());
  251. //SendMsgNotice(GetSourceStationID(),ISCS_SUBSYS_TYPE_ELC,2,DH_MSGCATEGORY_SOE,text);
  252. //xyx屏蔽end
  253. //xyx修改begin
  254. string EqpmtTypeName = GetBaseTypeName(); //设备类型名称
  255. string EqpmtName = GetEqpmentName(); //设备名称
  256. int EqpmtSourceStatonID = GetSourceStationID(); //设备所属车站ID
  257. int EqpmtType = GetBaseType(); //设备类型
  258. int nActType = ElcAlarm_TripActType_ComRecovery; //“通讯恢复”报文更新
  259. UpdateAlarmType(EqpmtType,EqpmtTypeName,EqpmtName,EqpmtSourceStatonID,nActType);
  260. //xyx修改end
  261. }
  262. //设备报警
  263. void BaseElectricEqpmt::CutEqpmtAlarm(map<string,BaseElectricEqpmt*>& ElectricEqpmtMap, int nTripActType)
  264. {
  265. string EqpmtTypeName = GetBaseTypeName(); //设备类型名称
  266. string EqpmtName = GetEqpmentName(); //设备名称
  267. int EqpmtSourceStatonID = GetSourceStationID(); //设备所属车站ID
  268. int EqpmtType = GetBaseType(); //设备类型
  269. int nActType = nTripActType; //“设备报警”报文更新
  270. UpdateAlarmType(EqpmtType,EqpmtTypeName,EqpmtName,EqpmtSourceStatonID,nActType);
  271. }
  272. //设备报警恢复
  273. void BaseElectricEqpmt::RevertEqpmtAlarm(map<string,BaseElectricEqpmt*>& ElectricEqpmtMap, int nTripActType)
  274. {
  275. string EqpmtTypeName = GetBaseTypeName(); //设备类型名称
  276. string EqpmtName = GetEqpmentName(); //设备名称
  277. int EqpmtSourceStatonID = GetSourceStationID(); //设备所属车站ID
  278. int EqpmtType = GetBaseType(); //设备类型
  279. int nActType = nTripActType; //“设备报警恢复”报文更新
  280. UpdateAlarmType(EqpmtType,EqpmtTypeName,EqpmtName,EqpmtSourceStatonID,nActType);
  281. }
  282. void BaseElectricEqpmt::AddCtrlUnoin(int operstatus,string preeqpmtid,int prestatus,int relation,int delaytime,int index)
  283. {
  284. UionCtrl ctrlunion;
  285. ctrlunion.Sourceid = GetEqpmentID();
  286. ctrlunion.OperStatus = operstatus;
  287. ctrlunion.PreEqpmtID = preeqpmtid;
  288. ctrlunion.PreStatus = prestatus;
  289. ctrlunion.Relation = relation;
  290. ctrlunion.delaytime = delaytime;
  291. ctrlunion.Index = index;
  292. m_CtrlUnions.push_back(ctrlunion);
  293. }
  294. void BaseElectricEqpmt::InitiativeUnionCtrl(int status,ELEEQPMTMAP& ElectricEqpmtMap)
  295. {
  296. for (size_t i=0;i<m_CtrlUnions.size();i++)
  297. {
  298. if (m_CtrlUnions[i].Sourceid==GetEqpmentID()&&m_CtrlUnions[i].OperStatus==status&&m_CtrlUnions[i].Relation==EQPMT_RELATIONTYPE_INITUIONCTRL)
  299. {
  300. ELEEQPMTMAP::iterator iter = ElectricEqpmtMap.find(m_CtrlUnions[i].PreEqpmtID);
  301. if (iter!=ElectricEqpmtMap.end())
  302. {
  303. DelayTimeInfo delay;
  304. delay.type=Auto_DelayTime_InitCtrl;
  305. delay.delaydur=m_CtrlUnions[i].delaytime;
  306. delay.occartime = GetNumTime_Second_2();
  307. delay.srcid = GetEqpmentID();
  308. delay.srcstatus = status;
  309. delay.desid =m_CtrlUnions[i].PreEqpmtID;
  310. delay.destatus = m_CtrlUnions[i].PreStatus;
  311. p_DelayTimeMap->insert(make_pair(m_CtrlUnions[i].PreEqpmtID,delay));
  312. }
  313. }
  314. }
  315. }
  316. void BaseElectricEqpmt::OccarSearchError(int errorid)
  317. {
  318. ERRORMAP::iterator iter = m_CurErrorNos.find(errorid);
  319. if (iter==m_CurErrorNos.end())
  320. {
  321. ErrorInfo errorinfo;
  322. errorinfo.ID = errorid;
  323. errorinfo.Status = Electric_Fault_Status_Start;
  324. m_CurErrorNos.insert(make_pair(errorid,errorinfo));
  325. }
  326. }
  327. void BaseElectricEqpmt::SendMsgNotice(int station,int sysid,int level,int type, int fault, string labelvalue,string strEqpmtID/* = _T("")*/)
  328. {
  329. if (p_SendList!=nullptr)
  330. {
  331. DHMSGNOTICE DHNotice;
  332. DHNotice.StationID = station;
  333. DHNotice.Time = GetNumTime_Second_2();
  334. DHNotice.RegionID = ISCS_SUBSYS_TYPE_ELC;
  335. DHNotice.Type = type;
  336. DHNotice.Level =level;
  337. strncpy(DHNotice.LabelValue, labelvalue.c_str(), sizeof(DHNotice.LabelValue));
  338. strncpy(DHNotice.EqpmtID, strEqpmtID.c_str(), sizeof(DHNotice.EqpmtID));
  339. OCCCOMMAND NetOrder;
  340. NetOrder.DesSysType = OCC_SYS_DD_CLIENT;
  341. NetOrder.ScrSysType = OCC_SYS_DD_SVR;
  342. NetOrder.TrainningID = m_Trianid;
  343. NetOrder.setPacketValue(&DHNotice,OCCCOMMAND::eUpdateDHMsgNotice);
  344. p_SendList->push(NetOrder);
  345. }
  346. }
  347. void BaseElectricEqpmt::RevertAlarms()
  348. {
  349. for (size_t i =0;i<m_AlarmIDs.size();i++)
  350. {
  351. if (p_SendList!=nullptr)
  352. {
  353. ALARMREVERT RevertNotice;
  354. RevertNotice.AlarmID = m_AlarmIDs[i];
  355. OCCCOMMAND NetOrder;
  356. NetOrder.DesSysType = OCC_SYS_DD_CLIENT;
  357. NetOrder.ScrSysType = OCC_SYS_DD_SVR;
  358. NetOrder.TrainningID = m_Trianid;
  359. NetOrder.setPacketValue(&RevertNotice,OCCCOMMAND::eUpdateAlarmRevert);
  360. p_SendList->push(NetOrder);
  361. }
  362. }
  363. m_AlarmIDs.clear();
  364. }
  365. BaseElectricEqpmt:: ~BaseElectricEqpmt()
  366. {
  367. }
  368. bool BaseElectricEqpmt::PowerIn(ELEEQPMTMAP& eqpmtmap,string sourceid) //使与sourceid相关的电力元件全部通电
  369. {
  370. /*std::map<string,string>::iterator iter = OutputEqpmtIDMap.begin();
  371. for (;iter!=OutputEqpmtIDMap.end();iter++)
  372. {
  373. ELEEQPMTMAP::iterator iter_Output=eqpmtmap.find(iter->first);
  374. if (iter_Output!=eqpmtmap.end())
  375. {
  376. if (!iter_Output->second->GetPower()&&iter_Output->second->GetControlType()==Electric_Eqpmt_CtrlType_Auto)
  377. {
  378. iter_Output->second->UpdateEqpmtStatus(eqpmtmap,Electric_Eqpmt_Status_ON);
  379. iter_Output->second->SetPower(true);
  380. iter_Output->second->PowerIn(eqpmtmap,iter_Output->second->GetEqpmentID());
  381. }
  382. else if (!iter_Output->second->GetPower()&&iter_Output->second->GetControlType()==Electric_Eqpmt_CtrlType_Mannual&&iter_Output->second->GetStatus()==Electric_Eqpmt_Status_ON)
  383. {
  384. iter_Output->second->SetPower(true);
  385. iter_Output->second->PowerIn(eqpmtmap,iter_Output->second->GetEqpmentID());
  386. }
  387. }
  388. }
  389. DealElcTurnOffArea();
  390. return true;*/
  391. INPUTEQPMTMAP::iterator iter = InputEqpmtIDMap.begin(); //BaseElectricEqpmt实体为sourceid的输出设备,InputEqpmtIDMap为sourceid的输出设备的输入设备
  392. for (;iter!=InputEqpmtIDMap.end();iter++)
  393. {
  394. if (sourceid==iter->first) //在输入设备列表中查找与sourceid一致的电力元件
  395. {
  396. if (iter->second.InputPower)
  397. {
  398. return false;
  399. }
  400. iter->second.InputPower = true;
  401. SetPower(true);
  402. UpdateEqpmtStatus(eqpmtmap,Electric_Eqpmt_Status_ON);
  403. }
  404. }
  405. OUTPUTEQPMTMAP::iterator iter2 = OutputEqpmtIDMap.begin(); //OutputEqpmtIDMap为sourceid的输出设备的输出设备
  406. for (;iter2!=OutputEqpmtIDMap.end();iter2++)
  407. {
  408. if (iter2->first!=sourceid) //在输出设备列表中查找与sourceid不一致但在eqpmtmap表中的数据,如果能找到相应数据,则此数据为相关输出设备
  409. {
  410. ELEEQPMTMAP::iterator iter3 = eqpmtmap.find(iter2->first);
  411. if (iter3!=eqpmtmap.end())
  412. {
  413. iter3->second->PowerIn(eqpmtmap,GetEqpmentID()); //设置相关输出设备元件有电
  414. }
  415. }
  416. }
  417. DealElcTurnOffArea();
  418. return true;
  419. }
  420. bool BaseElectricEqpmt::PowerLost(ELEEQPMTMAP& eqpmtmap,string sourceid,int offcase) //改变电力元件设备状态并送客户端(UpdateEqpmtStatus),更改电力元件受电失电标志(PowerCut)
  421. {
  422. /*if (GetControlType()==Electric_Eqpmt_CtrlType_Auto)
  423. {
  424. UpdateEqpmtStatus(eqpmtmap,Electric_Eqpmt_Status_OFF); //如果为自动控制设备,将受电失电的颜色状态状态改变,即完成电力元件的状态改变
  425. }
  426. SetPower(false);
  427. OUTPUTEQPMTMAP::iterator iter = OutputEqpmtIDMap.begin(); //OutputEqpmtIDMap为sourceid的输出设备
  428. for (;iter!=OutputEqpmtIDMap.end();iter++)
  429. {
  430. ELEEQPMTMAP::iterator iter1 = eqpmtmap.find(iter->first); //查找eqpmtmap列表中是否存在输出设备列表中的电力元件,如存在则表明eqpmtmap表中有要停电的电力元件
  431. if (iter1==eqpmtmap.end())
  432. continue;
  433. if (iter1->second->GetEqpmentID()==GetEqpmentID())
  434. {
  435. continue;
  436. }
  437. //iter1->second->PowerCut(eqpmtmap,m_strid,offcase); //使相应的电力元件停电 //PowerCut完成是否通电,维护InputLineInfo这个数据结构
  438. if (iter1->second->GetPower())
  439. {
  440. if (iter1->second->PowerCut(eqpmtmap,GetEqpmentID(),offcase))
  441. {
  442. //PowerLost(eqpmtmap,iter1->second->GetStrID(),offcase);
  443. string a=iter1->first;
  444. bool b=false;
  445. if (a=="{8CD21152-DB65-4EF8-993E-585E935D21F6}")
  446. {
  447. b=true;
  448. }
  449. iter1->second->PowerLost(eqpmtmap,iter1->second->GetEqpmentID(),offcase);
  450. }
  451. }
  452. }*/
  453. SetPower(false);
  454. UpdateEqpmtStatus(eqpmtmap,Electric_Eqpmt_Status_OFF); //将受电失电的颜色状态状态改变,即完成电力元件的状态改变
  455. OUTPUTEQPMTMAP::iterator iter = OutputEqpmtIDMap.begin(); //OutputEqpmtIDMap为sourceid的输出设备
  456. for (;iter!=OutputEqpmtIDMap.end();iter++)
  457. {
  458. ELEEQPMTMAP::iterator iter1 = eqpmtmap.find(iter->first); //查找eqpmtmap列表中是否存在输出设备列表中的电力元件,如存在则表明eqpmtmap表中有要停电的电力元件
  459. if (iter1==eqpmtmap.end())
  460. continue;
  461. iter1->second->PowerCut(eqpmtmap,GetEqpmentID(),offcase); //使相应的电力元件停电 //PowerCut完成是否通电,维护InputLineInfo这个数据结构
  462. }
  463. DealElcTurnOffArea();
  464. return true;
  465. }
  466. bool BaseElectricEqpmt::CheckElcEnvirRelation()
  467. {
  468. if (p_SendList!=nullptr)
  469. {
  470. for (int i=0;i < m_ElcEnvirRelations.size();i++)
  471. {
  472. ELCENVIRRELATION EnvirPower;
  473. string strID=GetEqpmentID();
  474. strncpy(EnvirPower.EqpmtStrID, strID.c_str(), sizeof(EnvirPower.EqpmtStrID));
  475. EnvirPower.EnvirArea = m_ElcEnvirRelations[i].EnvirAreaID;
  476. EnvirPower.EqpmtStatus = GetStatus();
  477. strncpy(EnvirPower.AreaName, m_ElcEnvirRelations[i].Areaname.c_str(), sizeof(EnvirPower.AreaName));
  478. OCCCOMMAND NetOrder;
  479. NetOrder.DesSysType = OCC_SYS_HD_SVR;
  480. NetOrder.ScrSysType = OCC_SYS_DD_SVR;
  481. NetOrder.TrainningID = m_Trianid;
  482. NetOrder.setPacketValue(&EnvirPower,OCCCOMMAND::eUpdateElcEnvirRelation);
  483. p_SendList->push(NetOrder);
  484. }
  485. }
  486. return true;
  487. }
  488. bool BaseElectricEqpmt::PowerCut(ELEEQPMTMAP& eqpmtmap,string sourceid,int offcase)
  489. {
  490. /* bool bIsPowerLost=true;
  491. INPUTEQPMTMAP::iterator iter = InputEqpmtIDMap.begin(); //检查设备输入设备是否有电
  492. if (InputEqpmtIDMap.size()>1)
  493. {
  494. for (;iter!=InputEqpmtIDMap.end();iter++)
  495. {
  496. ELEEQPMTMAP::iterator iter_input=eqpmtmap.find(iter->first);
  497. if (iter_input!=eqpmtmap.end())
  498. {
  499. if (iter_input->second->GetEqpmentID()!=sourceid&&iter_input->second->GetPower())
  500. {
  501. if (!iter_input->second->PowerCut(eqpmtmap,GetEqpmentID(),offcase)) //输入设备的输入设备有电,则继续检查输入设备的输入设备的输入设备
  502. {
  503. //return false;
  504. bIsPowerLost=false;
  505. break;
  506. }
  507. }
  508. if (iter_input->second->GetEqpmentID()==sourceid)
  509. {
  510. continue;
  511. }
  512. }
  513. }
  514. }
  515. else if (InputEqpmtIDMap.size()==1)
  516. {
  517. ELEEQPMTMAP::iterator iter_input=eqpmtmap.find(iter->first);
  518. if (iter_input!=eqpmtmap.end())
  519. {
  520. if (iter_input->second->GetEqpmentID()==sourceid)
  521. {
  522. bIsPowerLost=true;
  523. }
  524. }
  525. }
  526. else if (InputEqpmtIDMap.size()==0&&GetPower())
  527. {
  528. bIsPowerLost=false;
  529. }
  530. return bIsPowerLost;*/
  531. int count =0;
  532. string id="";
  533. bool isinput =false;
  534. INPUTEQPMTMAP::iterator iter = InputEqpmtIDMap.begin(); //InputEqpmtIDMap为sourceid的输出设备的输入设备列表
  535. for (;iter!=InputEqpmtIDMap.end();iter++)
  536. {
  537. if (sourceid==iter->first)
  538. {
  539. if (!iter->second.InputPower)
  540. {
  541. return false;
  542. }
  543. iter->second.InputPower = false;
  544. isinput=true;
  545. }
  546. if (iter->second.InputPower)
  547. {
  548. count++;
  549. id = iter->first;
  550. }
  551. }
  552. if (!isinput)
  553. return false;
  554. if (count==1) //处理电力元件有两个输入的情况
  555. {
  556. ELEEQPMTMAP::iterator iter3 = eqpmtmap.find(id);
  557. if (iter3!=eqpmtmap.end())
  558. {
  559. iter3->second->PowerCut(eqpmtmap,GetEqpmentID(),offcase);
  560. }
  561. }
  562. if (count<1) //处理电力元件有三个输入的情况
  563. {
  564. PowerLost(eqpmtmap,GetEqpmentID(),offcase);
  565. }
  566. //处理直流侧输入输出逻辑错误 暂屏蔽 yangs
  567. //直流母线多输入处理
  568. //if (OCC_EQPMTTYPE_1500vDCMLine == GetBaseType())
  569. //{
  570. // //检查带电来源
  571. // if (CheckDCMLineInPowerNums(eqpmtmap))
  572. // {
  573. // return true;
  574. // }
  575. // //查找输入
  576. // vector<string> vecInputEqpmtID;
  577. // vecInputEqpmtID.clear();
  578. // INPUTEQPMTMAP::iterator iterInput = InputEqpmtIDMap.begin();
  579. // for (; iterInput != InputEqpmtIDMap.end(); iterInput++)
  580. // {
  581. // if (iterInput->second.InputPower)
  582. // {
  583. // vecInputEqpmtID.push_back(iterInput->first);
  584. // }
  585. // }
  586. // //对输入进行断电检查
  587. // for (int i = 0; i < vecInputEqpmtID.size(); i++)
  588. // {
  589. // ELEEQPMTMAP::iterator iter15 = eqpmtmap.find(vecInputEqpmtID[i]);
  590. // if (iter15 != eqpmtmap.end())
  591. // {
  592. // iter15->second->PowerCut(eqpmtmap, GetEqpmentID(), offcase);
  593. // }
  594. // }
  595. //}
  596. return true;
  597. }
  598. bool BaseElectricEqpmt::PowerCutMLineOutPower(int nType)
  599. {
  600. INPUTEQPMTMAP::iterator iter1 = InputEqpmtIDMap.begin();
  601. for (; iter1 != InputEqpmtIDMap.end(); iter1++)
  602. {
  603. if (iter1->second.InputPower)
  604. {
  605. //对输入分类统计
  606. /* ELEEQPMTMAP::iterator iter3 = eqpmtmap.find(iter1->first);
  607. if (iter3 != eqpmtmap.end())
  608. {
  609. if (iter3->second->GetSubType() == nType)
  610. {
  611. iter3->second->PowerCut(eqpmtmap, GetEqpmentID(), offcase);
  612. }
  613. }*/
  614. }
  615. }
  616. }
  617. bool BaseElectricEqpmt::CheckDCMLineInPowerNums(map<string, BaseElectricEqpmt*>& eqpmtmap)
  618. {
  619. bool bRet = true;
  620. int nCount = 0, nLcount = 0, nRcount = 0;
  621. INPUTEQPMTMAP::iterator iter1 = InputEqpmtIDMap.begin();
  622. for (; iter1 != InputEqpmtIDMap.end(); iter1++)
  623. {
  624. if (iter1->second.InputPower)
  625. {
  626. //对输入分类统计
  627. ELEEQPMTMAP::iterator iter3 = eqpmtmap.find(iter1->first);
  628. if (iter3 != eqpmtmap.end())
  629. {
  630. //本站1500V进线
  631. if (iter3->second->GetSubType() == Electric_PowerLine_Input)
  632. {
  633. nCount++;
  634. }
  635. //左邻馈线
  636. else if (iter3->second->GetSubType() == Electric_PowerLine_OnTouch_L)
  637. {
  638. nLcount++;
  639. }
  640. //右邻馈线
  641. else if (iter3->second->GetSubType() == Electric_PowerLine_OnTouch_R)
  642. {
  643. nRcount++;
  644. }
  645. }
  646. }
  647. }
  648. //本站1500V进线无电并且左邻馈线或右邻馈线无电
  649. if (nCount == 0 && (nLcount == 0 || nRcount == 0))
  650. {
  651. bRet = false;
  652. }
  653. return bRet;
  654. }
  655. int BaseElectricEqpmt::CheckInPowerNums()
  656. {
  657. int count = 0;
  658. INPUTEQPMTMAP::iterator iter1 = InputEqpmtIDMap.begin();
  659. for (;iter1!=InputEqpmtIDMap.end();iter1++)
  660. {
  661. if (iter1->second.InputPower)
  662. {
  663. count++;
  664. }
  665. }
  666. return count;
  667. }
  668. bool BaseElectricEqpmt::AddProtect(string id, int EventID )
  669. {
  670. ProtectCtrl protectCtrl;
  671. protectCtrl.ProtectStrID = id;
  672. protectCtrl.EventID = EventID;
  673. ProtectVecs.push_back(protectCtrl);
  674. return true;
  675. }
  676. bool BaseElectricEqpmt::handle_fault(int eventOper,ELEEQPMTMAP& eqpmtmap,int errorid, int Param, int nType)
  677. {
  678. OccarSearchError(errorid);
  679. bool bAlarmFault = true;//仅产生告警故障
  680. for (size_t i=0;i<ProtectVecs.size();i++)
  681. {
  682. if ( ProtectVecs[i].EventID == Param )
  683. {
  684. ELEEQPMTMAP::iterator iter = eqpmtmap.find( ProtectVecs[i].ProtectStrID );
  685. if (iter==eqpmtmap.end())
  686. continue;
  687. iter->second->handle_checkprotect(eventOper,eqpmtmap,errorid,Param);
  688. //chenht 使用字段与是否重合闸判断字段冲突
  689. //if (nType == 2) //该类型故障设备无法复归
  690. //{
  691. // iter->second->setProhibitedReversion();
  692. //}
  693. bAlarmFault = false;
  694. }
  695. }
  696. // 根据故障设备闭锁设备列表闭锁相关设备
  697. map<string,BaseElectricEqpmt*>::iterator iterEqpmt;
  698. for ( int i = 0; i < m_ProtectLockingEqpmt.size(); i++ )
  699. {
  700. if ( m_ProtectLockingEqpmt[i].EventID == Param )
  701. {
  702. iterEqpmt = eqpmtmap.find( m_ProtectLockingEqpmt[i].PreEqpmtID );
  703. if ( iterEqpmt != eqpmtmap.end() )
  704. {
  705. ProtectLocking( iterEqpmt->second, m_ProtectLockingEqpmt[i].strText, m_ProtectLockingEqpmt[i].EventID);
  706. }
  707. }
  708. }
  709. // 根据故障场景闭锁设备列表闭锁相关设备
  710. for (int i = 0; i < m_vecFaultSceneLockingEqpmt.size(); i++)
  711. {
  712. if (m_vecFaultSceneLockingEqpmt[i].EventID == Param)
  713. {
  714. iterEqpmt = eqpmtmap.find(m_vecFaultSceneLockingEqpmt[i].PreEqpmtID);
  715. if (iterEqpmt != eqpmtmap.end())
  716. {
  717. FaultSceneLocking(iterEqpmt->second, m_vecFaultSceneLockingEqpmt[i].EventID);
  718. }
  719. }
  720. }
  721. //只有报警没有设备动作的故障处理
  722. if (bAlarmFault)
  723. {
  724. CutEqpmtAlarm(eqpmtmap,Param);
  725. }
  726. return true;
  727. }
  728. bool BaseElectricEqpmt::handle_revert(int eventOper,ELEEQPMTMAP& eqpmtmap,int Param)
  729. {
  730. #if 0
  731. ERRORMAP::iterator iter = m_CurErrorNos.find(Param);
  732. if (iter!=m_CurErrorNos.end())
  733. {
  734. m_CurErrorNos.erase(iter);
  735. RevertErrorToProtect(eventOper, eqpmtmap, Param);
  736. //xyx屏蔽begin
  737. //string text;
  738. //text.Format(" %s %s 故障恢复 ",GetBaseTypeName(),GetEqpmentName());
  739. //SendMsgNotice(GetSourceStationID(),GetRegion(),4,DH_MSGCATEGORY_SOE,text);
  740. //xyx屏蔽end
  741. //xyx修改begin
  742. string EqpmtTypeName = GetBaseTypeName(); //设备类型名称
  743. string EqpmtName = GetEqpmentName(); //设备名称
  744. int EqpmtSourceStatonID = GetSourceStationID(); //设备所属车站ID
  745. int EqpmtType = GetBaseType(); //设备类型
  746. int nActType = ElcAlarm_TripActType_FualtRecovery; ////“故障恢复”报文更新
  747. UpdateAlarmType(EqpmtType,EqpmtTypeName,EqpmtName,EqpmtSourceStatonID,nActType);
  748. //xyx修改end
  749. }
  750. #else
  751. if (EraseErrorNosByErrorID(Param))
  752. {
  753. RevertErrorToProtect(eventOper, eqpmtmap, Param);
  754. //xyx屏蔽begin
  755. //string text;
  756. //text.Format(" %s %s 故障恢复 ",GetBaseTypeName(),GetEqpmentName());
  757. //SendMsgNotice(GetSourceStationID(),GetRegion(),4,DH_MSGCATEGORY_SOE,text);
  758. //xyx屏蔽end
  759. //xyx修改begin
  760. string EqpmtTypeName = GetBaseTypeName(); //设备类型名称
  761. string EqpmtName = GetEqpmentName(); //设备名称
  762. int EqpmtSourceStatonID = GetSourceStationID(); //设备所属车站ID
  763. int EqpmtType = GetBaseType(); //设备类型
  764. int nActType = ElcAlarm_TripActType_FualtRecovery; ////“故障恢复”报文更新
  765. UpdateAlarmType(EqpmtType,EqpmtTypeName,EqpmtName,EqpmtSourceStatonID,nActType);
  766. //xyx修改end
  767. }
  768. #endif
  769. return true;
  770. }
  771. bool BaseElectricEqpmt::EraseErrorNosByErrorID(int nErrorID)
  772. {
  773. bool bRet = false;
  774. ERRORMAP::iterator iter = m_CurErrorNos.find(nErrorID);
  775. if (iter!=m_CurErrorNos.end())
  776. {
  777. m_CurErrorNos.erase(iter);
  778. bRet = true;
  779. }
  780. return bRet;
  781. }
  782. void BaseElectricEqpmt::SetTrackRelationXDMap( TrackRelationXDMAP trackrelationmap )
  783. {
  784. m_TrackRelationXDMap = trackrelationmap;
  785. }
  786. TrackRelationXDMAP BaseElectricEqpmt::GetTrackRelationXDMap()
  787. {
  788. return m_TrackRelationXDMap;
  789. }
  790. bool BaseElectricEqpmt::CheckErrorToProtect( int eventOper,map<string,BaseElectricEqpmt*>& eqpmtmap, int nErrorid )
  791. {
  792. ErrorToProtectMAP::iterator iterErrorToProtect = m_mapErrorToProtect.find( nErrorid );
  793. if ( iterErrorToProtect == m_mapErrorToProtect.end() )
  794. {
  795. return false;
  796. }
  797. // 自身是否需要断开
  798. if ( iterErrorToProtect->second.bSelfLost )
  799. {
  800. UpdateEqpmtStatus(eqpmtmap,Electric_Eqpmt_Status_OFF);
  801. PowerLost( eqpmtmap, GetEqpmentID(), Electric_Eqpmt_Status_OFF);
  802. }
  803. // 遍历保护类型
  804. for( int i = 0; i < iterErrorToProtect->second.vecProtectClass.size(); i++ )
  805. {
  806. handle_fault( eventOper, eqpmtmap, nErrorid, iterErrorToProtect->second.vecProtectClass[i], iterErrorToProtect->second.nErrorType );
  807. }
  808. //处理源头设备,否则系统无法正常供电操作 noted by zhnagjiahua
  809. if (InputEqpmtIDMap.empty() && Electric_Eqpmt_Status_ON == GetStatus())
  810. {
  811. UpdateEqpmtStatus(eqpmtmap, Electric_Eqpmt_Status_OFF);
  812. PowerLost(eqpmtmap, GetEqpmentID(), Electric_Eqpmt_Status_OFF);
  813. }
  814. }
  815. bool BaseElectricEqpmt::RevertErrorToProtect( int eventOper,map<string,BaseElectricEqpmt*>& eqpmtmap, int nErrorid )
  816. {
  817. ErrorToProtectMAP::iterator iterErrorToProtect = m_mapErrorToProtect.find( nErrorid );
  818. if ( iterErrorToProtect == m_mapErrorToProtect.end() )
  819. {
  820. return false;
  821. }
  822. // 遍历保护类型
  823. for( int i = 0; i < iterErrorToProtect->second.vecProtectClass.size(); i++ )
  824. {
  825. RevertErrorToProtect( eventOper, eqpmtmap, nErrorid, iterErrorToProtect->second.vecProtectClass[i] );
  826. }
  827. //处理源头设备,否则系统无法正常供电操作 noted by zhnagjiahua
  828. if ( InputEqpmtIDMap.empty() && Electric_Eqpmt_Status_OFF == GetStatus() )
  829. {
  830. UpdateEqpmtStatus( eqpmtmap,Electric_Eqpmt_Status_ON );
  831. PowerIn(eqpmtmap, GetEqpmentID() );
  832. }
  833. // 有输入但是自身断开了的设备
  834. else if (iterErrorToProtect->second.bSelfLost && Electric_Eqpmt_Status_OFF == GetStatus())
  835. {
  836. UpdateEqpmtStatus(eqpmtmap, Electric_Eqpmt_Status_ON);
  837. PowerIn(eqpmtmap, GetEqpmentID());
  838. }
  839. return true;
  840. }
  841. bool BaseElectricEqpmt::RevertErrorToProtect( int eventOper,map<string,BaseElectricEqpmt*>& eqpmtmap, int nErrorid, int nProtectID )
  842. {
  843. for (size_t i=0;i<ProtectVecs.size();i++)
  844. {
  845. if ( ProtectVecs[i].EventID == nProtectID )
  846. {
  847. ELEEQPMTMAP::iterator iter = eqpmtmap.find(ProtectVecs[i].ProtectStrID);
  848. if (iter==eqpmtmap.end())
  849. continue;
  850. //mode by yangs 20230702
  851. //iter->second->ClearProtect(eqpmtmap,nProtectID);
  852. iter->second->ClearProtect(eqpmtmap,nErrorid);
  853. iter->second->UpdateEqpmtLightCardStatu(-1);
  854. }
  855. }
  856. // 根据故障场景闭锁设备列表解锁相关设备 add by yangs
  857. map<string, BaseElectricEqpmt*>::iterator iterEqpmt;
  858. for (int i = 0; i < m_vecFaultSceneLockingEqpmt.size(); i++)
  859. {
  860. if (m_vecFaultSceneLockingEqpmt[i].EventID == nProtectID)
  861. {
  862. iterEqpmt = eqpmtmap.find(m_vecFaultSceneLockingEqpmt[i].PreEqpmtID);
  863. if (iterEqpmt != eqpmtmap.end())
  864. {
  865. iterEqpmt->second->SetFaultSceneLock(nProtectID, false);
  866. }
  867. }
  868. }
  869. return true;
  870. }
  871. void BaseElectricEqpmt::AddProtectLockingEqpmt( const string& strProtectLockingEqpmtID, int nProtectId,const string& strLockintText )
  872. {
  873. UionCtrl protectLockingUion;
  874. protectLockingUion.Sourceid = GetEqpmentID();
  875. protectLockingUion.EventID = nProtectId;
  876. protectLockingUion.PreEqpmtID = strProtectLockingEqpmtID;
  877. protectLockingUion.strText = strLockintText;
  878. m_ProtectLockingEqpmt.push_back(protectLockingUion);
  879. }
  880. void BaseElectricEqpmt::ProtectLocking( BaseElectricEqpmt* pEqpmt, const string& strLockingDisplayContent ,int nProtectID )
  881. {
  882. if( nullptr == pEqpmt ) return;
  883. //xyx屏蔽begin
  884. //string strtext;
  885. //strtext.Format("%s %s",pEqpmt->GetEqpmentName(), strLockingDisplayContent );
  886. //SendMsgNotice(GetSourceStationID(),GetRegion(),1,DH_MSGCATEGORY_SYS,strtext,pEqpmt->GetEqpmentID());
  887. //xyx屏蔽end
  888. //xyx修改begin
  889. string EqpmtTypeName = pEqpmt->GetBaseTypeName(); //设备类型名称
  890. string EqpmtName = pEqpmt->GetEqpmentName(); //设备名称
  891. int EqpmtSourceStatonID = pEqpmt->GetSourceStationID(); //设备所属车站ID
  892. int EqpmtType = pEqpmt->GetBaseType(); //设备类型
  893. ELCEQPMTALARMINFOMAP::iterator iterAlarmEqpmtType = m_EqpmtAlarmInfoMap->find(EqpmtType);
  894. if (iterAlarmEqpmtType!=m_EqpmtAlarmInfoMap->end())
  895. {
  896. ELCEQPMTALARMACTTYPEMAP mapAlarmActType = iterAlarmEqpmtType->second;
  897. ELCEQPMTALARMACTTYPEMAP::iterator iterAlarmActType=mapAlarmActType.begin();
  898. for (;iterAlarmActType!=mapAlarmActType.end();iterAlarmActType++)
  899. {
  900. if (nProtectID == iterAlarmActType->first)
  901. {
  902. iterAlarmActType->second.m_strProtectLock=strLockingDisplayContent;
  903. UpdateAlarmInfo(EqpmtTypeName,EqpmtName,EqpmtSourceStatonID,iterAlarmActType->second);
  904. //更新闭锁设备的闭锁状态 add by chenht 2020-1222
  905. pEqpmt->SetFaultLockStatus(Electric_Eqpmt_Status_Lock);
  906. }
  907. }
  908. }
  909. //xyx修改end
  910. //更新闭锁设备的闭锁状态 add by chenht 2020-1222
  911. pEqpmt->SetFaultLockStatus(Electric_Eqpmt_Status_Lock);
  912. }
  913. void BaseElectricEqpmt::AddFaultSceneLockingEqpmt(const string& strProtectLockingEqpmtID, int nProtectId)
  914. {
  915. FaultSceneCtrl faultsceneLocking;
  916. faultsceneLocking.Sourceid = GetEqpmentID();
  917. faultsceneLocking.EventID = nProtectId;
  918. faultsceneLocking.PreEqpmtID = strProtectLockingEqpmtID;
  919. m_vecFaultSceneLockingEqpmt.push_back(faultsceneLocking);
  920. }
  921. void BaseElectricEqpmt::FaultSceneLocking(BaseElectricEqpmt* pEqpmt, int nProtectID)
  922. {
  923. if(nullptr == pEqpmt) return;
  924. //更新故障场景设备闭锁 add by yangs
  925. pEqpmt->SetFaultSceneLock(nProtectID,true);
  926. }
  927. void BaseElectricEqpmt::CheckMotherAutoBolt(map<string,BaseElectricEqpmt*>& eqpmtmap)
  928. {
  929. //非备自投又没有关联备自投 即其他断路器
  930. if ( m_strMotherAutoBolt.empty() )
  931. {
  932. return;
  933. }
  934. ELEEQPMTMAP::iterator iterbolt = eqpmtmap.find(m_strMotherAutoBolt);
  935. //没有找到关联的备自投
  936. if ( iterbolt == eqpmtmap.end() )
  937. {
  938. return;
  939. }
  940. ElectricEqpmt_PowerBolt* pbolt= (ElectricEqpmt_PowerBolt*)iterbolt->second;
  941. if ( nullptr != pbolt )
  942. {
  943. pbolt->CheckSelfShut( eqpmtmap,pbolt->GetRelationBreaker() );
  944. }
  945. }
  946. bool BaseElectricEqpmt::AddFaultEqpmt(string FaultEqpmt)
  947. {
  948. vector<string>::iterator vec;
  949. vec=find(m_FaultEqpmt.begin(),m_FaultEqpmt.end(),FaultEqpmt);
  950. if (vec==m_FaultEqpmt.end())
  951. {
  952. m_FaultEqpmt.push_back(FaultEqpmt);
  953. }
  954. return true;
  955. }
  956. void BaseElectricEqpmt::DealTelesignalisation( int nProtectID, const string& strEqpmtStrID, int nMark )
  957. {
  958. if ( nullptr != m_hCallBackTelesignalisation )
  959. {
  960. m_hCallBackTelesignalisation( m_pTelesignalisationOwner, nProtectID, strEqpmtStrID, nMark );
  961. if ( nProtectID > 1 )
  962. {
  963. if ( nMark )
  964. {
  965. m_nCurProtectID = nProtectID;
  966. }
  967. else
  968. {
  969. m_nCurProtectID = -1;
  970. }
  971. }
  972. }
  973. }
  974. void BaseElectricEqpmt::DealElcTurnOffArea()
  975. {
  976. Deal400VLoad();
  977. if ( m_nRelationElcTurnOffArea < 0 )
  978. {
  979. return;
  980. }
  981. if ( nullptr != m_hCallBackDealElcTurnOffArea )
  982. {
  983. m_hCallBackDealElcTurnOffArea( m_pTelesignalisationOwner, GetEqpmentID() );
  984. }
  985. }
  986. void BaseElectricEqpmt::Deal400VLoad()
  987. {
  988. if ( m_n400VLoadID > 0 && nullptr != m_hCallBackDeal400VLoadTurnOff )
  989. {
  990. m_hCallBackDeal400VLoadTurnOff( m_pTelesignalisationOwner, GetEqpmentID(), m_n400VLoadID );
  991. }
  992. }
  993. bool BaseElectricEqpmt::IsPower()
  994. {
  995. return GetPower();
  996. }
  997. void BaseElectricEqpmt::ElcAreaAlarm( bool bPower )
  998. {
  999. //xyx屏蔽begin
  1000. //string strPower;
  1001. //if ( bPower )
  1002. //{
  1003. // strPower = _T("线路带电");
  1004. //}
  1005. //else
  1006. //{
  1007. // strPower = _T("线路失电");
  1008. //}
  1009. //string strText;
  1010. //strText.Format( "%s %s %s", GetBaseTypeName(), GetEqpmentName(), strPower);
  1011. //SendMsgNotice(GetSourceStationID(),GetRegion(),1,DH_MSGCATEGORY_SYS,strText,GetEqpmentID());
  1012. //xyx屏蔽end
  1013. //xyx修改begin
  1014. string EqpmtTypeName = GetBaseTypeName(); //设备类型名称
  1015. string EqpmtName = GetEqpmentName(); //设备名称
  1016. int EqpmtSourceStatonID = GetSourceStationID(); //设备所属车站ID
  1017. int EqpmtType = GetBaseType(); //设备类型
  1018. if ( bPower )
  1019. {
  1020. int nActType1 = ElcAlarm_TripActType_TransLineLosePower; //“线路失电”报文类型
  1021. UpdateAlarmType(EqpmtType,EqpmtTypeName,EqpmtName,EqpmtSourceStatonID,nActType1);
  1022. }
  1023. else
  1024. {
  1025. int nActType2 = ElcAlarm_TripActType_TransLineOnPower; //“线路带电”报文类型
  1026. UpdateAlarmType(EqpmtType,EqpmtTypeName,EqpmtName,EqpmtSourceStatonID,nActType2);
  1027. }
  1028. //xyx修改end
  1029. }
  1030. void BaseElectricEqpmt::AddOutLineElectricEqpmt( int nType, const string& strOutLineElectricEqpmtStrID )
  1031. {
  1032. m_vecOutLineElectricEqpmt.push_back( OutLineElectricEqpmt(nType, strOutLineElectricEqpmtStrID) );
  1033. }
  1034. void BaseElectricEqpmt::CheckOutLineElectricEqpmt(map<string,BaseElectricEqpmt*>& eqpmtmap, int nMark /*= 0*/)
  1035. {
  1036. }
  1037. bool BaseElectricEqpmt::BoltPowerIn_35KV( map<string,BaseElectricEqpmt*>& eqpmtmap, const string& strOutLineElectricEqpmtStrID )
  1038. {
  1039. return true;
  1040. }
  1041. void BaseElectricEqpmt::PowerCutCurElectricEqpmt_400V( ELEEQPMTMAP& ElectricEqpmtMap )
  1042. {
  1043. }
  1044. void BaseElectricEqpmt::SetElcEqpmtAlarmInfoMap( ELCEQPMTALARMINFOMAP* m_AlarmInfoMap )
  1045. {
  1046. m_EqpmtAlarmInfoMap = m_AlarmInfoMap;
  1047. }
  1048. void BaseElectricEqpmt::UpdateAlarmInfo( string EppmtTypeName,string EqpmtName,int SourceStaionID,ELCEQPMTALARMINFO& EqpmtAlarmInfo )
  1049. {
  1050. string AlarmText = EqpmtAlarmInfo.m_strAlrmText; //报文内容
  1051. int AlarmSytem = EqpmtAlarmInfo.m_nAlarmSystem; //报文所属系统:Elc_AlarmRegion_PSCADA-10
  1052. int AlarmLevel = EqpmtAlarmInfo.m_nAlarmLevel; //报文等级
  1053. int AlarmType = EqpmtAlarmInfo.m_nAlarmType; //报文类型:报警DH_MSGCATEGORY_PSCADA-9,日志DH_MSGCATEGORY_SOE-2等
  1054. int IsFault = EqpmtAlarmInfo.m_nIsFault; //是否为故障触发报文:故障1、常规操作0
  1055. string strtext;
  1056. std::stringstream ss;
  1057. ss << EppmtTypeName << " " << EqpmtName << " " << AlarmText;
  1058. strtext = ss.str();
  1059. SendMsgNotice(SourceStaionID, AlarmSytem, AlarmLevel, AlarmType, IsFault, strtext,GetEqpmentID());//modified by zhangjiahua
  1060. }
  1061. void BaseElectricEqpmt::UpdateAlarmType( int EppmtType,string EppmtTypeName,string EqpmtName,int SourceStaionID ,int ActType)
  1062. {
  1063. string strEqpmtTypeName = EppmtTypeName; //设备类型名称
  1064. string strEqpmtName = EqpmtName; //设备名称
  1065. int nEqpmtSourceStatonID = SourceStaionID; //设备所属车站ID
  1066. int nEqpmtType = EppmtType; //设备类型
  1067. int nActType = ActType; //动作类型
  1068. ELCEQPMTALARMINFOMAP::iterator iterAlarmEqpmtType = m_EqpmtAlarmInfoMap->find(nEqpmtType);
  1069. if (iterAlarmEqpmtType!=m_EqpmtAlarmInfoMap->end())
  1070. {
  1071. ELCEQPMTALARMACTTYPEMAP mapAlarmActType = iterAlarmEqpmtType->second;
  1072. ELCEQPMTALARMACTTYPEMAP::iterator iterAlarmActType=mapAlarmActType.begin();
  1073. for (;iterAlarmActType!=mapAlarmActType.end();iterAlarmActType++)
  1074. {
  1075. if (ActType==iterAlarmActType->first)
  1076. {
  1077. UpdateAlarmInfo(strEqpmtTypeName,strEqpmtName,nEqpmtSourceStatonID,iterAlarmActType->second);
  1078. }
  1079. }
  1080. }
  1081. }
  1082. void BaseElectricEqpmt::UpdateOperResultToTechEva( string strEqpmtID,int nResultStatus )
  1083. {
  1084. UpdateEvaOperStatus pUpdateOperTemp;
  1085. pUpdateOperTemp.TrainID = m_Trianid; //训练号
  1086. pUpdateOperTemp.OperItemType = Item_Type_DD; //条目类型:2-电调
  1087. strncpy(pUpdateOperTemp.AssociPara1, strEqpmtID.c_str(), sizeof(pUpdateOperTemp.AssociPara1)); //关联参数1:设备ID
  1088. pUpdateOperTemp.OperStatus = nResultStatus; //操作状态:设备操作结果状态
  1089. pUpdateOperTemp.OperItemObject = MajorType_DD; //条目对应评价对象-电调
  1090. pUpdateOperTemp.OperStuID = MajorType_DD; //操作对象类型-电调
  1091. pUpdateOperTemp.OperItemSubType1 = 1; //开关设备操作
  1092. if (nResultStatus == 1)
  1093. {
  1094. pUpdateOperTemp.OperItemSubType2 = 2; //合闸
  1095. }
  1096. else if (nResultStatus == 0)
  1097. {
  1098. pUpdateOperTemp.OperItemSubType2 = 1; //分闸
  1099. }
  1100. OCCCOMMAND NetOrderToTech;
  1101. NetOrderToTech.DesSysType = OCC_SYS_SERVER_TH;
  1102. NetOrderToTech.ScrSysType = OCC_SYS_DD_SVR;
  1103. NetOrderToTech.TrainningID = m_Trianid;
  1104. NetOrderToTech.setPacketValue(&pUpdateOperTemp,OCCCOMMAND::eUpdateEvaOperStatus);
  1105. p_SendList->push(NetOrderToTech);
  1106. }
  1107. void BaseElectricEqpmt::UpdateEqpmtLightCardStatu(int nProtectID)
  1108. {
  1109. DHEQPMTUPDATE updatadata;
  1110. updatadata.CtrlLock=GetControlLock();
  1111. updatadata.FaultLock=GetFaultLockStatus();
  1112. updatadata.RemoteLock=GetRemoteLockStatus();
  1113. updatadata.CommunicationStaus=GetCommunicationStatus();
  1114. updatadata.CtrlArea=GetControlArea();
  1115. updatadata.CtrlType = CTRLTYPE_UpLightCard;
  1116. updatadata.Status= nProtectID;
  1117. updatadata.Category = GetBaseType();
  1118. updatadata.SubSys = ISCS_SUBSYS_TYPE_ELC;
  1119. string strID=GetEqpmentID();
  1120. strncpy(updatadata.EqpmtStrID,strID.c_str(), sizeof(updatadata.EqpmtStrID));
  1121. string strName=GetEqpmentName();
  1122. strncpy(updatadata.EqpmtName,strName.c_str(), sizeof(updatadata.EqpmtName));
  1123. updatadata.StationID = GetStationID();
  1124. updatadata.ViewID = GetViewID();
  1125. OCCCOMMAND tmpSendHC;
  1126. tmpSendHC.setPacketValue(&updatadata,OCCCOMMAND::eUpdateEqpmtStatus);
  1127. tmpSendHC.DesSysType=OCC_SYS_DD_CLIENT;
  1128. tmpSendHC.TrainningID = m_Trianid;
  1129. tmpSendHC.ScrSysType=OCC_SYS_DD_SVR;
  1130. p_SendList->push(tmpSendHC);
  1131. }
  1132. void BaseElectricEqpmt::SendExamModeEqpmtCheckStatus(int stdid,int subsysyid,int trianid,int stationid,int viewid)
  1133. {
  1134. DHSVRREPLY CheckReplyMsg;
  1135. memset(CheckReplyMsg.ReplyText,0,ALARM_LEN) ;
  1136. string retstr = "";
  1137. int retstatus = DH_CmdReplyStatus_Pass;
  1138. strncpy(CheckReplyMsg.ReplyText,retstr.c_str(), sizeof(CheckReplyMsg.ReplyText));
  1139. CheckReplyMsg.CmdID = OCCCOMMAND::eUpdateOperCheck;
  1140. string strID=GetEqpmentID();
  1141. strncpy(CheckReplyMsg.EqpmtStrID,strID.c_str(), sizeof(CheckReplyMsg.EqpmtStrID));
  1142. CheckReplyMsg.AutoBoltStatus=1;
  1143. CheckReplyMsg.CtrlLock= GetFaultLockStatus() /*GetControlLock()*/;
  1144. CheckReplyMsg.StdID = stdid;
  1145. CheckReplyMsg.EqpmtStatus =retstatus; //100表示通过,101拒绝
  1146. CheckReplyMsg.StationID=stationid;
  1147. CheckReplyMsg.ViewID = viewid;
  1148. CheckReplyMsg.SubSysID = subsysyid;
  1149. OCCCOMMAND NetOrder;
  1150. NetOrder.DesSysType = OCC_SYS_DD_CLIENT;
  1151. NetOrder.ScrSysType = OCC_SYS_DD_SVR;
  1152. NetOrder.TrainningID = trianid;
  1153. NetOrder.setPacketValue(&CheckReplyMsg,OCCCOMMAND::eUpdateSvrReply);
  1154. p_SendList->push(NetOrder);
  1155. }
  1156. void BaseElectricEqpmt::UpdateEqpmtTeleValue( string strEqpmtID, int nType, float fValue, int IsReset)
  1157. {
  1158. EQPMTTELEMTRYVALUE SetEqpmtTeleValue;
  1159. strncpy(SetEqpmtTeleValue.EqpmtStrID, strEqpmtID.c_str(), sizeof(SetEqpmtTeleValue.EqpmtStrID));
  1160. SetEqpmtTeleValue.nType = nType;
  1161. SetEqpmtTeleValue.fValue = fValue;
  1162. SetEqpmtTeleValue.IsReset = IsReset;
  1163. OCCCOMMAND NetOrder;
  1164. NetOrder.DesSysType = OCC_SYS_DD_CLIENT;
  1165. NetOrder.ScrSysType = OCC_SYS_DD_SVR;
  1166. NetOrder.TrainningID = m_Trianid;
  1167. NetOrder.setPacketValue(&SetEqpmtTeleValue,OCCCOMMAND::eUpdateEqpmtTelemeteryValue);
  1168. p_SendList->push(NetOrder);
  1169. }
  1170. //更新设备带电状态
  1171. void BaseElectricEqpmt::UpdateEqpmtPower( string strEqpmtID, int power)
  1172. {
  1173. if (p_SendList!=nullptr)
  1174. {
  1175. EQPMTPOWERSTATUS SetEqpmtPower;
  1176. strncpy(SetEqpmtPower.EqpmtStrID, strEqpmtID.c_str(), sizeof(SetEqpmtPower.EqpmtStrID));
  1177. SetEqpmtPower.nPower = power;
  1178. OCCCOMMAND NetOrder;
  1179. NetOrder.DesSysType = OCC_SYS_DD_CLIENT;
  1180. NetOrder.ScrSysType = OCC_SYS_DD_SVR;
  1181. NetOrder.TrainningID = m_Trianid;
  1182. NetOrder.setPacketValue(&SetEqpmtPower,OCCCOMMAND::eUpdateEqpmtPowerStatus);
  1183. p_SendList->push(NetOrder);
  1184. }
  1185. }