CDSFacilityF.cpp 97 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSFacilityF.h"
  4. #include "ITS_OPLibF.h"
  5. //---------------------------------------------------------------------------
  6. #pragma package(smart_init)
  7. TItsRegFacility::TItsRegFacility()
  8. {
  9. UnRegisterd = "N";
  10. GridIndex = -1;
  11. Clear();
  12. }
  13. //---------------------------------------------------------------------------
  14. TItsRegFacility::~TItsRegFacility()
  15. {
  16. }
  17. //---------------------------------------------------------------------------
  18. void TItsRegFacility::Clear()
  19. {
  20. #if 0
  21. Type = "";
  22. Id = "";
  23. Name = "";
  24. DelYn = ""
  25. UnRegisterd = "N";
  26. #endif
  27. }
  28. //---------------------------------------------------------------------------
  29. TItsFacility::TItsFacility()
  30. {
  31. FCommStatus = "CMS2"; // 장비 통신상태값
  32. FDoorStatus = "CMS2"; // 장비 Door상태값
  33. GridIndex = -1; // 그리드 인덱스
  34. StatusGridIndex = -1;
  35. Deleted = "N";
  36. Clear();
  37. }
  38. //---------------------------------------------------------------------------
  39. void TItsFacility::Clear()
  40. {
  41. #if 0
  42. FCLT_ID = ""; // FCLT_ID VARCHAR(50 BYTE) NOT NULL, '시설물 ID';
  43. RFID_ID = ""; // RFID_ID VARCHAR(50 BYTE) NOT NULL, '시설물 ID';
  44. FCLT_TYPE = ""; // FCLT_TYPE VARCHAR(7 BYTE) NOT NULL, '시설물유형';
  45. FCLT_LCTN = ""; // FCLT_LCTN VARCHAR(100 BYTE), '시설물 위치';
  46. RSCE_YN = ""; // RSCE_YN CHAR(1 BYTE) DEFAULT 'N', '현장자산유무';
  47. MDL_NM = ""; // MDL_NM VARCHAR(30 BYTE), '모델명';
  48. USE_YEAR = ""; // USE_YEAR NUMBER(3), '사용년수';
  49. INWR_DT = ""; // INWR_DT VARCHAR(14 BYTE), '입고일시';
  50. OTWR_DT = ""; // OTWR_DT VARCHAR(14 BYTE), '출고일시';
  51. ISTL_DT = ""; // ISTL_DT VARCHAR(14 BYTE), '설치일시';
  52. TAKT_DT = ""; // TAKT_DT VARCHAR(14 BYTE), '반출일시';
  53. TAKT_RESN = ""; // TAKT_RESN VARCHAR(100 BYTE), '반출사유';
  54. TAKN_DT = ""; // TAKN_DT VARCHAR(14 BYTE), '반입일시';
  55. ABDN_DT = ""; // ABDN_DT VARCHAR(14 BYTE), '폐기일시';
  56. ADTN_NM = ""; // ADTN_NM VARCHAR(30 BYTE), '추가자명';
  57. ADTN_DT = ""; // ADTN_DT VARCHAR(14 BYTE), '추가일시';
  58. CHNG_NM = ""; // CHNG_NM VARCHAR(30 BYTE), '변경자명';
  59. CHNG_DT = ""; // CHNG_DT VARCHAR(14 BYTE), '변경일시';
  60. AMT = ""; // AMT NUMBER(15), '금액';
  61. DEL_YN = ""; // DEL_YN CHAR(1 BYTE) DEFAULT 'N', '삭제여부';
  62. ISTL_CMPY_ID = ""; // ISTL_CMPY_ID VARCHAR(30 BYTE), '설치업체ID';
  63. MNFC_CMPY_ID = ""; // PRDC_CMPY_ID VARCHAR(30 BYTE) '제조업체ID';
  64. ISTL_LCTN_ADDR = "";
  65. CommStatus = "CMS2"; // 장비 통신상태값
  66. DoorStatus = "CMS2"; // 장비 Door상태값
  67. GridIndex = -1; // 메인폼에 뿌려지는 그리드 인덱스
  68. #endif
  69. }
  70. //---------------------------------------------------------------------------
  71. TItsFacility::~TItsFacility()
  72. {
  73. }
  74. //---------------------------------------------------------------------------
  75. //---------------------------------------------------------------------------
  76. TItsFacilityManager *ItsFacilityManager = NULL;
  77. //---------------------------------------------------------------------------
  78. /*
  79. * Facility Manager
  80. */
  81. TItsFacilityManager::TItsFacilityManager()
  82. {
  83. }
  84. //---------------------------------------------------------------------------
  85. TItsFacilityManager::~TItsFacilityManager()
  86. {
  87. FRegLists.RemoveAll();
  88. FLists.RemoveAll();
  89. }
  90. //---------------------------------------------------------------------------
  91. void TItsFacilityManager::SetCenterId(String ACenterId)
  92. {
  93. CenterId = ACenterId;
  94. }
  95. //---------------------------------------------------------------------------
  96. bool TItsFacilityManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
  97. {
  98. try
  99. {
  100. FLocalCctvCnt = 0;
  101. FRseLists.Lock();
  102. FAviLists.Lock();
  103. FBitLists.Lock();
  104. FSigLists.Lock();
  105. FSigDetLists.Lock();
  106. FPisLists.Lock();
  107. FPcsLists.Lock();
  108. FRegLists.Lock();
  109. FLists.Lock();
  110. FRseLists.RemoveAll();
  111. FAviLists.RemoveAll();
  112. FBitLists.RemoveAll();
  113. FSigLists.RemoveAll();
  114. FSigDetLists.RemoveAll();
  115. FPisLists.RemoveAll();
  116. FPcsLists.RemoveAll();
  117. FRegLists.RemoveAll();
  118. FLists.RemoveAll();
  119. }
  120. __finally
  121. {
  122. FRseLists.UnLock();
  123. FAviLists.UnLock();
  124. FBitLists.UnLock();
  125. FSigLists.UnLock();
  126. FSigDetLists.UnLock();
  127. FPisLists.UnLock();
  128. FPcsLists.UnLock();
  129. FRegLists.UnLock();
  130. FLists.UnLock();
  131. }
  132. LoadFacilityReg(ADbConn); // 시설물 개별 테이블 조회(ID, NAME 등)
  133. LoadFacilityMaster(ADbConn); // TB_FCLT_INFR
  134. LoadFacilityVds(ADbConn);
  135. LoadFacilityCctv(ADbConn);
  136. LoadFacilityIncCctv(ADbConn);
  137. LoadFacilityVms(ADbConn);
  138. LoadFacilityWebCam(ADbConn);
  139. LoadFacilityCrsCam(ADbConn);
  140. LoadFacilityPark(ADbConn);
  141. LoadFacilityRse(ADbConn);
  142. LoadFacilityAvi(ADbConn);
  143. LoadFacilityDsrc(ADbConn);
  144. LoadFacilityBit(ADbConn);
  145. LoadFacilitySig(ADbConn);
  146. LoadFacilitySigDet(ADbConn);
  147. LoadFacilityPvms(ADbConn);
  148. LoadFacilityPvds(ADbConn);
  149. LoadFacilityCross(ADbConn);
  150. CheckFacility();
  151. return true;
  152. }
  153. //---------------------------------------------------------------------------
  154. bool TItsFacilityManager::CheckFacility()
  155. {
  156. try
  157. {
  158. FLists.Lock();
  159. FOR_STL(TItsFacility *, pFacility, FLists)
  160. {
  161. TItsRegFacility *pRegFacility = FRegLists.Find(pFacility->FCLT_TYPE + pFacility->FCLT_ID);
  162. if (!pRegFacility)
  163. {
  164. pFacility->Deleted = "Y";
  165. }
  166. }
  167. }
  168. __finally
  169. {
  170. FLists.UnLock();
  171. }
  172. try
  173. {
  174. FRegLists.Lock();
  175. FOR_STL(TItsRegFacility *, pRegFacility, FRegLists)
  176. {
  177. TItsFacility *pFacility = FLists.Find(pRegFacility->Id);
  178. if (!pFacility)
  179. {
  180. pRegFacility->UnRegisterd = "Y";
  181. }
  182. }
  183. }
  184. __finally
  185. {
  186. FRegLists.UnLock();
  187. }
  188. return true;
  189. }
  190. //---------------------------------------------------------------------------
  191. bool TItsFacilityManager::LoadFacilityReg(TADOConnection *ADbConn/*=NULL*/)
  192. {
  193. String sQry;
  194. TADOQuery *pADO = NULL;
  195. sQry = "SELECT '' AS FAC_TYPE, '' AS FAC_ID, '' AS FAC_NM, '' AS DEL_YN \r\n"
  196. " FROM DUAL \r\n"
  197. " WHERE 1 = 0 \r\n"
  198. #ifdef USE_CCTV
  199. #if 0
  200. "UNION \r\n"
  201. "SELECT 'CCTV' AS FAC_TYPE, CCTV_CTLR_ID AS FAC_ID, CCTV_NM AS FAC_NM, DEL_YN \r\n"
  202. " FROM TB_CCTV_CTLR \r\n"
  203. " WHERE DEL_YN = 'N' \r\n"
  204. #else
  205. "UNION \r\n"
  206. "SELECT 'CCTV' AS FAC_TYPE, CCTV_CTLR_ID AS FAC_ID, ISTL_LCTN_NM AS FAC_NM, DEL_YN \r\n"
  207. " FROM TB_CCTV_CTLR \r\n"
  208. " WHERE DEL_YN = 'N' \r\n"
  209. #endif
  210. #endif
  211. #ifdef USE_INCCCTV
  212. "UNION \r\n"
  213. "SELECT 'ICAM' AS FAC_TYPE, CCTV_CTLR_ID AS FAC_ID, ISTL_LCTN_NM AS FAC_NM, DEL_YN \r\n"
  214. " FROM VW_INC_CCTV_CTLR \r\n"
  215. " WHERE DEL_YN = 'N' \r\n"
  216. #endif
  217. #ifdef USE_VDS
  218. "UNION \r\n"
  219. "SELECT 'VDS' AS FAC_TYPE, VDS_CTLR_ID AS FAC_ID, VDS_NM AS FAC_N, DEL_YN \r\n"
  220. " FROM TB_VDS_CTLR \r\n"
  221. " WHERE DEL_YN = 'N' \r\n"
  222. #endif
  223. #ifdef USE_VMS
  224. "UNION \r\n"
  225. "SELECT 'VMS' AS FAC_TYPE, VMS_CTLR_ID AS FAC_ID, VMS_NM AS FAC_NM, DEL_YN \r\n"
  226. " FROM TB_VMS_CTLR \r\n"
  227. " WHERE DEL_YN = 'N' \r\n"
  228. #endif
  229. #ifdef USE_WCAM
  230. #ifdef USE_WEB_CMRA
  231. "UNION \r\n"
  232. "SELECT 'WCAM' AS FAC_TYPE, WEB_CMRA_ID AS FAC_ID, ISTL_LCTN_NM AS FAC_NM, DEL_YN \r\n"
  233. " FROM TB_WEB_CMRA \r\n"
  234. " WHERE DEL_YN = 'N' \r\n"
  235. #else
  236. "UNION \r\n"
  237. "SELECT WCAM_TYPE_CD AS FAC_TYPE, WCAM_CTLR_ID AS FAC_ID, WCAM_NM AS FAC_NM, DEL_YN \r\n"
  238. " FROM TB_WCAM_CTLR \r\n"
  239. " WHERE DEL_YN = 'N' \r\n"
  240. #endif
  241. #endif
  242. #ifdef USE_CCAM
  243. "UNION \r\n"
  244. "SELECT 'CCAM' AS FAC_TYPE, CCAM_CTLR_ID AS FAC_ID, CCAM_NM AS FAC_NM, DEL_YN \r\n"
  245. " FROM TB_CCAM_CTLR \r\n"
  246. " WHERE DEL_YN = 'N' \r\n"
  247. #endif
  248. #ifdef USE_AVI
  249. "UNION \r\n"
  250. "SELECT 'AVI' AS FAC_TYPE, AVI_ID AS FAC_ID, AVI_LCTN_NM AS FAC_NM, DEL_YN \r\n"
  251. " FROM TB_AVI_CTLR \r\n"
  252. " WHERE DEL_YN = 'N' \r\n"
  253. #endif
  254. #ifdef USE_DSRC
  255. "UNION \r\n"
  256. "SELECT 'DSRC' AS FAC_TYPE, RSE_ID AS FAC_ID, ISTL_LCTN_NM AS FAC_NM, DEL_YN \r\n"
  257. " FROM TB_RSE_MSTR \r\n"
  258. " WHERE DEL_YN = 'N' \r\n"
  259. #endif
  260. #ifdef USE_BIT
  261. "UNION \r\n"
  262. "SELECT 'BIT' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, FCLT_LCTN AS FAC_NM, 'N' AS DEL_YN \r\n"
  263. " FROM VW_BIT \r\n"
  264. #if 0
  265. "SELECT 'BIT' AS FAC_TYPE, TO_CHAR(A.BIT_ID) AS FAC_ID, B.STOP_NAME AS FAC_NM, \r\n"
  266. " 'N' AS DEL_YN \r\n"
  267. " FROM BIT A, BUSSTOP B \r\n"
  268. " WHERE 1=1 \r\n"
  269. " AND A.INSTALL_STOP_ID = B.STOP_ID \r\n"
  270. " AND B.USE_FLAG = '1' \r\n"
  271. #endif
  272. #endif
  273. #ifdef USE_SIG
  274. "UNION \r\n"
  275. "SELECT 'SIG' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, FCLT_LCTN AS FAC_NM, 'N' AS DEL_YN \r\n"
  276. " FROM VW_SIG_CTLR \r\n"
  277. #endif
  278. #ifdef USE_PVMS
  279. "UNION \r\n"
  280. "SELECT 'PVMS' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, FCLT_LCTN AS FAC_NM, 'N' AS DEL_YN \r\n"
  281. " FROM VW_PIS_VMS \r\n"
  282. #endif
  283. #ifdef USE_PVDS
  284. "UNION \r\n"
  285. "SELECT 'PVDS' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, FCLT_LCTN AS FAC_NM, 'N' AS DEL_YN \r\n"
  286. " FROM VW_PIS_CONT \r\n"
  287. #endif
  288. #ifdef USE_SIGDET
  289. "UNION \r\n"
  290. "SELECT 'LVD' AS FAC_TYPE, FCLT_ID AS FAC_ID, FCLT_LCTN AS FAC_NM, 'N' AS DEL_YN \r\n"
  291. " FROM VW_SIG_LVDS \r\n"
  292. #endif
  293. #ifdef USE_RSE
  294. "UNION \r\n"
  295. "SELECT 'RSE' AS FAC_TYPE, RSEID AS FAC_ID, LOCATION AS FAC_NM, 'N' AS DEL_YN \r\n"
  296. " FROM RSEMST \r\n"
  297. #endif
  298. #ifdef USE_PARK
  299. "UNION \r\n"
  300. "SELECT 'PARK' AS FAC_TYPE, PRLT_CTLR_ID AS FAC_ID, PRLT_NM AS FAC_NM, DEL_YN \r\n"
  301. " FROM TB_PRLT_CTLR \r\n"
  302. " WHERE DEL_YN = 'N' \r\n"
  303. #endif
  304. #ifdef USE_CROSS
  305. // 교차로교통량
  306. "UNION \r\n"
  307. "SELECT 'CRS' AS FAC_TYPE, CROSS_ID AS FAC_ID, NAME AS FAC_NM, 'N' AS DEL_YN \r\n"
  308. " FROM TB_CRS \r\n"
  309. " WHERE DEL_YN = 'N' \r\n"
  310. // 교차로교통량 CCTV
  311. "UNION \r\n"
  312. "SELECT 'CRSCAM' AS FAC_TYPE, A.CAM_ID AS FAC_ID, A.NAME AS FAC_NM, 'N' AS DEL_YN \r\n"
  313. " FROM TB_CRS_CMRA A, TB_CRS B \r\n"
  314. " WHERE A.DEL_YN = 'N' \r\n"
  315. " AND B.DEL_YN = 'N' \r\n"
  316. " AND A.CROSS_ID = B.CROSS_ID \r\n"
  317. #endif
  318. ;
  319. FRegLists.Lock();
  320. try
  321. {
  322. FRegLists.RemoveAll();
  323. try
  324. {
  325. pADO = new TADOQuery(NULL);
  326. pADO->Close();
  327. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  328. pADO->SQL->Clear();
  329. pADO->SQL->Text = sQry;
  330. pADO->Prepared = true;
  331. pADO->Open();
  332. for( ; !pADO->Eof; pADO->Next())
  333. {
  334. TItsRegFacility *pRegFacility = new TItsRegFacility();
  335. pRegFacility->Type = pADO->FieldByName("FAC_TYPE")->AsString;
  336. pRegFacility->Id = pADO->FieldByName("FAC_ID")->AsString;
  337. pRegFacility->Name = pADO->FieldByName("FAC_NM")->AsString;
  338. pRegFacility->DelYn = pADO->FieldByName("DEL_YN")->AsString;
  339. pRegFacility->GridIndex = -1;
  340. FRegLists.Push(pRegFacility->Type + pRegFacility->Id, pRegFacility);
  341. }
  342. }
  343. catch(EDatabaseError &E)
  344. {
  345. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  346. DBERRORMSG("TItsFacilityManager::LoadFacilityReg", String(E.ClassName()), E.Message, sQry);
  347. throw Exception(String(E.ClassName()) + E.Message);
  348. }
  349. catch(Exception &exception)
  350. {
  351. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  352. DBERRORMSG("TItsFacilityManager::LoadFacilityReg", String(exception.ClassName()), exception.Message, sQry);
  353. throw Exception(String(exception.ClassName()) + exception.Message);
  354. }
  355. }
  356. __finally
  357. {
  358. if (pADO)
  359. {
  360. pADO->Close();
  361. delete pADO;
  362. }
  363. FRegLists.UnLock();
  364. }
  365. return true;
  366. }
  367. //---------------------------------------------------------------------------
  368. bool TItsFacilityManager::LoadFacilityMaster(TADOConnection *ADbConn/*=NULL*/)
  369. {
  370. String sQry;
  371. TADOQuery *pADO = NULL;
  372. sQry = "SELECT * \r\n"
  373. " FROM TB_FCLT_INFR \r\n"
  374. " WHERE DEL_YN = 'N' \r\n";
  375. TFacilityStatus *pStatus;
  376. FListStatus.Lock();
  377. FLists.Lock();
  378. try
  379. {
  380. FListStatus.RemoveAll();
  381. FLists.RemoveAll();
  382. try
  383. {
  384. pADO = new TADOQuery(NULL);
  385. pADO->Close();
  386. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  387. pADO->SQL->Clear();
  388. pADO->SQL->Text = sQry;
  389. pADO->Prepared = true;
  390. pADO->Open();
  391. for( ; !pADO->Eof; pADO->Next())
  392. {
  393. TItsFacility *pFacility = new TItsFacility();
  394. pFacility->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  395. pFacility->RFID_ID = pADO->FieldByName("RFID_ID")->AsString;
  396. pFacility->FCLT_TYPE = pADO->FieldByName("FCLT_TYPE")->AsString;
  397. pFacility->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  398. pFacility->RSCE_YN = pADO->FieldByName("RSCE_YN")->AsString;
  399. pFacility->MDL_NM = pADO->FieldByName("MDL_NM")->AsString;
  400. pFacility->USE_YEAR = pADO->FieldByName("USE_YEAR")->AsString;
  401. if (pFacility->USE_YEAR == "") pFacility->USE_YEAR = "0";
  402. pFacility->INWR_DT = pADO->FieldByName("INWR_DT")->AsString;
  403. pFacility->OTWR_DT = pADO->FieldByName("OTWR_DT")->AsString;
  404. pFacility->ISTL_DT = pADO->FieldByName("ISTL_DT")->AsString;
  405. pFacility->TAKT_DT = pADO->FieldByName("TAKT_DT")->AsString;
  406. pFacility->TAKT_RESN = pADO->FieldByName("TAKT_RESN")->AsString;
  407. pFacility->TAKN_DT = pADO->FieldByName("TAKN_DT")->AsString;
  408. pFacility->ABDN_DT = pADO->FieldByName("ABDN_DT")->AsString;
  409. pFacility->ADTN_NM = pADO->FieldByName("ADTN_NM")->AsString;
  410. pFacility->ADTN_DT = pADO->FieldByName("ADTN_DT")->AsString;
  411. pFacility->CHNG_NM = pADO->FieldByName("CHNG_NM")->AsString;
  412. pFacility->CHNG_DT = pADO->FieldByName("CHNG_DT")->AsString;
  413. pFacility->AMT = pADO->FieldByName("AMT")->AsString;
  414. pFacility->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  415. pFacility->ISTL_CMPY_ID = pADO->FieldByName("ISTL_CMPY_ID")->AsString;
  416. pFacility->MNFC_CMPY_ID = pADO->FieldByName("MNFC_CMPY_ID")->AsString;
  417. pFacility->ISTL_LCTN_ADDR = pADO->FieldByName("ISTL_LCTN_ADDR")->AsString;
  418. pFacility->Sts00 = "-";
  419. pFacility->GridIndex = -1; // 메인폼에 뿌려지는 그리드 인덱스
  420. pFacility->StatusGridIndex = -1;
  421. pFacility->Object = NULL;
  422. FLists.Push(pFacility->FCLT_ID, pFacility);
  423. pFacility->Completed = true;
  424. String FCLT_TYPE = pFacility->FCLT_TYPE;
  425. if (FCLT_TYPE == "VDS" && pFacility->FCLT_ID.Pos("VDC"))
  426. {
  427. FCLT_TYPE = "CRSSVR";
  428. }
  429. pStatus = FListStatus.Find(FCLT_TYPE);
  430. if (!pStatus)
  431. {
  432. pStatus = new TFacilityStatus();
  433. pStatus->Type = FCLT_TYPE;
  434. pStatus->Total = 0;
  435. pStatus->Normal = 0;
  436. pStatus->Error = 0;
  437. pStatus->Module = 0;
  438. pStatus->Collect= 0;
  439. FListStatus.Push(FCLT_TYPE, pStatus);
  440. }
  441. pStatus->Total++; /* 전체 갯수를 증가 시킴 */
  442. }
  443. }
  444. catch(EDatabaseError &E)
  445. {
  446. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  447. DBERRORMSG("TItsFacilityManager::LoadFacilityMaster", String(E.ClassName()), E.Message, sQry);
  448. throw Exception(String(E.ClassName()) + E.Message);
  449. }
  450. catch(Exception &exception)
  451. {
  452. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  453. DBERRORMSG("TItsFacilityManager::LoadFacilityMaster", String(exception.ClassName()), exception.Message, sQry);
  454. throw Exception(String(exception.ClassName()) + exception.Message);
  455. }
  456. }
  457. __finally
  458. {
  459. if (pADO)
  460. {
  461. pADO->Close();
  462. delete pADO;
  463. }
  464. FListStatus.UnLock();
  465. FLists.UnLock();
  466. }
  467. return true;
  468. }
  469. //---------------------------------------------------------------------------
  470. bool TItsFacilityManager::LoadFacilityWebCam(TADOConnection *ADbConn/*=NULL*/)
  471. {
  472. if (!WCamCtlrManager)
  473. {
  474. WCamCtlrManager = new TWCamCtlrManager();
  475. }
  476. #ifdef USE_WCAM
  477. TItsFacility *pFacility;
  478. WCamCtlrManager->LoadFromDb();
  479. FOR_STL(TWCamCtlr*, pObj, WCamCtlrManager->FLists)
  480. {
  481. if (pObj->DEL_YN == "Y") continue;
  482. pFacility = FLists.Find(pObj->WCAM_CTLR_ID);
  483. if (!pFacility) continue;
  484. pFacility->Object = pObj;
  485. }
  486. #endif
  487. return true;
  488. }
  489. //---------------------------------------------------------------------------
  490. bool TItsFacilityManager::LoadFacilityCrsCam(TADOConnection *ADbConn/*=NULL*/)
  491. {
  492. if (!CCamCtlrManager)
  493. {
  494. CCamCtlrManager = new TCCamCtlrManager();
  495. }
  496. #ifdef USE_CCAM
  497. TItsFacility *pFacility;
  498. CCamCtlrManager->LoadFromDb();
  499. FOR_STL(TCCamCtlr*, pObj, CCamCtlrManager->FLists)
  500. {
  501. if (pObj->DEL_YN == "Y") continue;
  502. pFacility = FLists.Find(pObj->CCAM_CTLR_ID);
  503. if (!pFacility) continue;
  504. pFacility->Object = pObj;
  505. pFacility->FCLT_KIND = pObj->TYPE_CD;
  506. }
  507. #endif
  508. return true;
  509. }
  510. //---------------------------------------------------------------------------
  511. bool TItsFacilityManager::LoadFacilityCctv(TADOConnection *ADbConn/*=NULL*/)
  512. {
  513. if (!CctvCtlrManager)
  514. {
  515. CctvCtlrManager = new TCctvCtlrManager();
  516. }
  517. #ifdef USE_CCTV
  518. TItsFacility *pFacility;
  519. CctvCtlrManager->LoadFromDb();
  520. FOR_STL(TCctvCtlr*, pObj, CctvCtlrManager->FLists)
  521. {
  522. if (pObj->DEL_YN == "Y") continue;
  523. pFacility = FLists.Find(pObj->CCTV_CTLR_ID);
  524. if (!pFacility) continue;
  525. pFacility->Object = pObj;
  526. pFacility->FCLT_KIND = pObj->TYPE_CD;
  527. }
  528. #endif
  529. return true;
  530. }
  531. //---------------------------------------------------------------------------
  532. bool TItsFacilityManager::LoadFacilityIncCctv(TADOConnection *ADbConn/*=NULL*/)
  533. {
  534. if (!IncCctvCtlrManager)
  535. {
  536. IncCctvCtlrManager = new TIncCctvCtlrManager();
  537. }
  538. #ifdef USE_INCCCTV
  539. TItsFacility *pFacility;
  540. IncCctvCtlrManager->LoadFromDb();
  541. FOR_STL(TIncCctvCtlr*, pObj, IncCctvCtlrManager->FLists)
  542. {
  543. if (pObj->DEL_YN == "Y") continue;
  544. pFacility = FLists.Find(pObj->CCTV_CTLR_ID);
  545. if (!pFacility) continue;
  546. pFacility->Object = pObj;
  547. pFacility->FCLT_KIND = pObj->TYPE_CD;
  548. }
  549. #endif
  550. return true;
  551. }
  552. //---------------------------------------------------------------------------
  553. bool TItsFacilityManager::LoadFacilityVms(TADOConnection *ADbConn/*=NULL*/)
  554. {
  555. if (!VmsCtlrManager)
  556. {
  557. VmsCtlrManager = new TVmsCtlrManager();
  558. }
  559. #ifdef USE_VMS
  560. TItsFacility *pFacility;
  561. VmsCtlrManager->LoadVmsSize();
  562. VmsCtlrManager->LoadFromDb();
  563. VmsCtlrManager->LoadVmsFormUsage();
  564. VmsCtlrManager->LoadIfscRltn();
  565. FOR_STL(TVmsCtlr*, pObj, VmsCtlrManager->FLists)
  566. {
  567. if (pObj->DEL_YN == "Y") continue;
  568. pFacility = FLists.Find(pObj->VMS_CTLR_ID);
  569. if (!pFacility) continue;
  570. pFacility->Object = pObj;
  571. pFacility->FCLT_KIND = pObj->TYPE_CD;
  572. }
  573. #endif
  574. return true;
  575. }
  576. //---------------------------------------------------------------------------
  577. bool TItsFacilityManager::LoadFacilityVds(TADOConnection *ADbConn/*=NULL*/)
  578. {
  579. if (!VdsCtlrManager)
  580. {
  581. VdsCtlrManager = new TVdsCtlrManager();
  582. }
  583. #ifdef USE_VDS
  584. TItsFacility *pFacility;
  585. VdsCtlrManager->LoadFromDb();
  586. VdsCtlrManager->LoadFromDtctDb();
  587. FOR_STL(TVdsCtlr*, pObj, VdsCtlrManager->FLists)
  588. {
  589. if (pObj->DEL_YN == "Y") continue;
  590. pFacility = FLists.Find(pObj->VDS_CTLR_ID);
  591. if (!pFacility) continue;
  592. pFacility->Object = pObj;
  593. pFacility->FCLT_KIND = pObj->TYPE_CD;
  594. }
  595. #endif
  596. return true;
  597. }
  598. //---------------------------------------------------------------------------
  599. bool TItsFacilityManager::LoadFacilityDsrc(TADOConnection *ADbConn/*=NULL*/)
  600. {
  601. if (!ItsDsrcManager)
  602. {
  603. ItsDsrcManager = new TItsDsrcManager();
  604. }
  605. #ifdef USE_DSRC
  606. TItsFacility *pFacility;
  607. ItsDsrcManager->LoadFromDb();
  608. FOR_STL(TItsDsrc*, pObj, ItsDsrcManager->FLists)
  609. {
  610. if (pObj->DEL_YN == "Y") continue;
  611. pFacility = FLists.Find(pObj->DSRC_CTLR_ID);
  612. if (!pFacility) continue;
  613. pFacility->Object = pObj;
  614. pFacility->FCLT_KIND = pObj->TYPE_CD;
  615. }
  616. #endif
  617. return true;
  618. }
  619. //---------------------------------------------------------------------------
  620. bool TItsFacilityManager::LoadFacilityRse(TADOConnection *ADbConn/*=NULL*/)
  621. {
  622. String sQry;
  623. TADOQuery *pADO = NULL;
  624. #ifndef USE_RSE
  625. return true;
  626. #endif
  627. sQry = "SELECT RSEID, \r\n"
  628. " INSTDT, \r\n"
  629. " CITYCD, \r\n"
  630. " REGIONCD, \r\n"
  631. " AREACD, \r\n"
  632. " RSEIP, \r\n"
  633. " (COORDX/10000000) COORDX, \r\n"
  634. " (COORDY/10000000) COORDY, \r\n"
  635. " RADIUS1, \r\n"
  636. " RADIUS2, \r\n"
  637. " COMPCD, \r\n"
  638. " LOCATION, \r\n"
  639. " RSECONFIGID, \r\n"
  640. " OBEPARAMID, \r\n"
  641. " PORT, \r\n"
  642. " BRIDGE, \r\n"
  643. " COMYN \r\n"
  644. " FROM RSEMST \r\n";
  645. //" ORDER BY RSEID \r\n";
  646. try
  647. {
  648. FRseLists.Lock();
  649. //FRseLists.RemoveAll();
  650. try
  651. {
  652. pADO = new TADOQuery(NULL);
  653. pADO->Close();
  654. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  655. pADO->SQL->Clear();
  656. pADO->SQL->Text = sQry;
  657. pADO->Prepared = true;
  658. pADO->Open();
  659. for( ; !pADO->Eof; pADO->Next())
  660. {
  661. TItsRse *pObj = new TItsRse();
  662. pObj->RSEID = pADO->FieldByName("RSEID")->AsString;
  663. //pObj->INSTDT = pADO->FieldByName("INSTDT")->AsString;
  664. pObj->CITYCD = pADO->FieldByName("CITYCD")->AsString;
  665. pObj->REGIONCD = pADO->FieldByName("REGIONCD")->AsString;
  666. pObj->AREACD = pADO->FieldByName("AREACD")->AsString;
  667. pObj->RSEIP = pADO->FieldByName("RSEIP")->AsString;
  668. pObj->COORDX = pADO->FieldByName("COORDX")->AsString;
  669. pObj->COORDY = pADO->FieldByName("COORDY")->AsString;
  670. pObj->RADIUS1 = pADO->FieldByName("RADIUS1")->AsString;
  671. pObj->RADIUS2 = pADO->FieldByName("RADIUS2")->AsString;
  672. //pObj->COMPCD = pADO->FieldByName("COMPCD")->AsString;
  673. pObj->LOCATION = pADO->FieldByName("LOCATION")->AsString;
  674. //pObj->RSECONFIGID = pADO->FieldByName("RSECONFIGID")->AsString;
  675. //pObj->OBEPARAMID = pADO->FieldByName("OBEPARAMID")->AsString;
  676. //pObj->PORT = pADO->FieldByName("PORT")->AsString;
  677. //pObj->BRIDGE = pADO->FieldByName("BRIDGE")->AsString;
  678. pObj->COMYN = pADO->FieldByName("COMYN")->AsString;
  679. pObj->CTLR_NMBR = pObj->RSEID;
  680. pObj->CTLR_ID = pObj->RSEID;
  681. pObj->NAME = pObj->LOCATION;
  682. pObj->X_CRDN = pObj->COORDX.ToDouble();
  683. pObj->Y_CRDN = pObj->COORDY.ToDouble();
  684. pObj->CTLR_IP = pObj->RSEIP;
  685. pObj->CTLR_PORT = 0;
  686. pObj->CTLR_LOCAL_NO = 0;
  687. FRseLists.Push(pObj->RSEID, pObj);
  688. }
  689. }
  690. catch(EDatabaseError &E)
  691. {
  692. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  693. DBERRORMSG("TItsFacilityManager::LoadFacilityRse", String(E.ClassName()), E.Message, sQry);
  694. throw Exception(String(E.ClassName()) + E.Message);
  695. }
  696. catch(Exception &exception)
  697. {
  698. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  699. DBERRORMSG("TItsFacilityManager::LoadFacilityRse", String(exception.ClassName()), exception.Message, sQry);
  700. throw Exception(String(exception.ClassName()) + exception.Message);
  701. }
  702. }
  703. __finally
  704. {
  705. if (pADO)
  706. {
  707. pADO->Close();
  708. delete pADO;
  709. }
  710. FRseLists.UnLock();
  711. }
  712. TItsFacility *pFacility;
  713. FOR_STL(TItsRse*, pObj, FRseLists)
  714. {
  715. pFacility = FLists.Find(pObj->RSEID);
  716. if (!pFacility) continue;
  717. pFacility->Object = pObj;
  718. }
  719. return true;
  720. }
  721. //---------------------------------------------------------------------------
  722. bool TItsFacilityManager::LoadFacilityAvi(TADOConnection *ADbConn/*=NULL*/)
  723. {
  724. String sQry;
  725. TADOQuery *pADO = NULL;
  726. #ifndef USE_AVI
  727. return true;
  728. #endif
  729. sQry = "SELECT AVI_CTLR_MNGM_NMBR, \r\n"
  730. " AVI_ID, \r\n"
  731. " LINK_ID, \r\n"
  732. " AVI_LCTN_NM, \r\n"
  733. " AVI_VALD_YN, \r\n"
  734. " AVI_CTLR_IP, \r\n"
  735. " AVI_CTLR_CMNC_PORT, \r\n"
  736. " AVI_MAIN_CTLR_YN, \r\n"
  737. " AVI_MNGM_LANE_NUM, \r\n"
  738. " AVI_CMRA_NUM, \r\n"
  739. " AVI_DTCT_NUM, \r\n"
  740. " AVI_DTCT_NM, \r\n"
  741. " AVI_CLCT_CYCL, \r\n"
  742. " AVI_LAMP_AUTO_YN, \r\n"
  743. " AVI_LAMP_ON_HMS, \r\n"
  744. " AVI_LAMP_OFF_HMS, \r\n"
  745. " AVI_LAMP_ON_YN, \r\n"
  746. " X_CRDN, \r\n"
  747. " Y_CRDN, \r\n"
  748. " RMRK, \r\n"
  749. " DEL_YN \r\n"
  750. " FROM TB_AVI_CTLR \r\n";
  751. //" ORDER BY AVI_CTLR_MNGM_NMBR \r\n";
  752. try
  753. {
  754. FAviLists.Lock();
  755. //FAviLists.RemoveAll();
  756. try
  757. {
  758. pADO = new TADOQuery(NULL);
  759. pADO->Close();
  760. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  761. pADO->SQL->Clear();
  762. pADO->SQL->Text = sQry;
  763. pADO->Prepared = true;
  764. pADO->Open();
  765. for( ; !pADO->Eof; pADO->Next())
  766. {
  767. TItsAvi *pObj = new TItsAvi();
  768. pObj->AVI_CTLR_MNGM_NMBR= pADO->FieldByName("AVI_CTLR_MNGM_NMBR")->AsString;
  769. pObj->AVI_ID = pADO->FieldByName("AVI_ID")->AsString;
  770. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
  771. pObj->AVI_LCTN_NM = pADO->FieldByName("AVI_LCTN_NM")->AsString;
  772. pObj->AVI_VALD_YN = pADO->FieldByName("AVI_VALD_YN")->AsString;
  773. pObj->AVI_CTLR_IP = pADO->FieldByName("AVI_CTLR_IP")->AsString;
  774. pObj->AVI_CTLR_CMNC_PORT= pADO->FieldByName("AVI_CTLR_CMNC_PORT")->AsString;
  775. pObj->AVI_MAIN_CTLR_YN = pADO->FieldByName("AVI_MAIN_CTLR_YN")->AsString;
  776. pObj->AVI_MNGM_LANE_NUM = pADO->FieldByName("AVI_MNGM_LANE_NUM")->AsString;
  777. pObj->AVI_CMRA_NUM = pADO->FieldByName("AVI_CMRA_NUM")->AsString;
  778. pObj->AVI_DTCT_NUM = pADO->FieldByName("AVI_DTCT_NUM")->AsString;
  779. pObj->AVI_DTCT_NM = pADO->FieldByName("AVI_DTCT_NM")->AsString;
  780. pObj->AVI_CLCT_CYCL = pADO->FieldByName("AVI_CLCT_CYCL")->AsString;
  781. pObj->AVI_LAMP_AUTO_YN = pADO->FieldByName("AVI_LAMP_AUTO_YN")->AsString;
  782. pObj->AVI_LAMP_ON_HMS = pADO->FieldByName("AVI_LAMP_ON_HMS")->AsString;
  783. pObj->AVI_LAMP_OFF_HMS = pADO->FieldByName("AVI_LAMP_OFF_HMS")->AsString;
  784. pObj->AVI_LAMP_ON_YN = pADO->FieldByName("AVI_LAMP_ON_YN")->AsString;
  785. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  786. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  787. pObj->RMRK = pADO->FieldByName("RMRK")->AsString;
  788. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  789. //FAviLists.Push(pObj->AVI_CTLR_MNGM_NMBR, pObj);
  790. FAviLists.Push(pObj->AVI_ID, pObj);
  791. }
  792. }
  793. catch(EDatabaseError &E)
  794. {
  795. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  796. DBERRORMSG("TItsFacilityManager::LoadFacilityAvi", String(E.ClassName()), E.Message, sQry);
  797. throw Exception(String(E.ClassName()) + E.Message);
  798. }
  799. catch(Exception &exception)
  800. {
  801. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  802. DBERRORMSG("TItsFacilityManager::LoadFacilityAvi", String(exception.ClassName()), exception.Message, sQry);
  803. throw Exception(String(exception.ClassName()) + exception.Message);
  804. }
  805. }
  806. __finally
  807. {
  808. if (pADO)
  809. {
  810. pADO->Close();
  811. delete pADO;
  812. }
  813. FAviLists.UnLock();
  814. }
  815. return true;
  816. }
  817. //---------------------------------------------------------------------------
  818. bool TItsFacilityManager::LoadFacilityBit(TADOConnection *ADbConn/*=NULL*/)
  819. {
  820. String sQry;
  821. TADOQuery *pADO = NULL;
  822. #ifndef USE_BIT
  823. return true;
  824. #endif
  825. #if 0
  826. sQry = "SELECT A.BIT_ID, \r\n"
  827. " A.BIT_TYPE, \r\n"
  828. " A.FAN_MIN_TEMPERATURE, \r\n"
  829. " A.FAN_MAX_TEMPERATURE, \r\n"
  830. " A.HEATER_MIN_TEMPERATURE, \r\n"
  831. " A.HEATER_MAX_TEMPERATURE, \r\n"
  832. " A.INSTALL_STOP_ID, \r\n"
  833. " B.STOP_ID, \r\n"
  834. " B.SERVICE_ID, \r\n"
  835. " B.STOP_TYPE, \r\n"
  836. " B.STOP_NAME, \r\n"
  837. " B.STOP_SHORTNAME, \r\n"
  838. " B.STOP_EXPLAIN, \r\n"
  839. " B.LAT AS COORDY, \r\n"
  840. " B.LNG AS COORDX, \r\n"
  841. " B.LINK_ID, \r\n"
  842. " B.USE_FLAG \r\n"
  843. " FROM BIT A, BUSSTOP B \r\n"
  844. " WHERE 1=1 \r\n"
  845. " AND A.INSTALL_STOP_ID = B.STOP_ID \r\n"
  846. " AND B.USE_FLAG = '1' \r\n";
  847. #else
  848. sQry = "SELECT * FROM VW_BIT \r\n";
  849. #endif
  850. try
  851. {
  852. FBitLists.Lock();
  853. //FBitLists.RemoveAll();
  854. try
  855. {
  856. pADO = new TADOQuery(NULL);
  857. pADO->Close();
  858. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  859. pADO->SQL->Clear();
  860. pADO->SQL->Text = sQry;
  861. pADO->Prepared = true;
  862. pADO->Open();
  863. for( ; !pADO->Eof; pADO->Next())
  864. {
  865. TItsBit *pObj = new TItsBit();
  866. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  867. pObj->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  868. pObj->BIT_ID = pADO->FieldByName("BIT_ID")->AsString;
  869. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  870. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  871. pObj->STOP_ID = pADO->FieldByName("STOP_ID")->AsString;
  872. #if 0
  873. pObj->BIT_TYPE = pADO->FieldByName("BIT_TYPE")->AsString;
  874. pObj->FAN_MIN_TEMPERATURE = pADO->FieldByName("FAN_MIN_TEMPERATURE")->AsInteger;
  875. pObj->FAN_MAX_TEMPERATURE = pADO->FieldByName("FAN_MAX_TEMPERATURE")->AsInteger;
  876. pObj->HEATER_MIN_TEMPERATURE = pADO->FieldByName("HEATER_MIN_TEMPERATURE")->AsInteger;
  877. pObj->HEATER_MAX_TEMPERATURE = pADO->FieldByName("HEATER_MAX_TEMPERATURE")->AsInteger;
  878. pObj->INSTALL_STOP_ID = pADO->FieldByName("INSTALL_STOP_ID")->AsString;
  879. pObj->SERVICE_ID = pADO->FieldByName("SERVICE_ID")->AsString;
  880. pObj->STOP_TYPE = pADO->FieldByName("STOP_TYPE")->AsString;
  881. pObj->STOP_NAME = pADO->FieldByName("STOP_NAME")->AsString;
  882. pObj->STOP_SHORTNAME = pADO->FieldByName("STOP_SHORTNAME")->AsString;
  883. #endif
  884. pObj->STOP_EXPLAIN = pADO->FieldByName("REMARK")->AsString;
  885. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
  886. pObj->DEL_YN = "N";
  887. FBitLists.Push(pObj->FCLT_ID, pObj);
  888. }
  889. }
  890. catch(EDatabaseError &E)
  891. {
  892. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  893. DBERRORMSG("TItsFacilityManager::LoadFacilityBit", String(E.ClassName()), E.Message, sQry);
  894. throw Exception(String(E.ClassName()) + E.Message);
  895. }
  896. catch(Exception &exception)
  897. {
  898. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  899. DBERRORMSG("TItsFacilityManager::LoadFacilityBit", String(exception.ClassName()), exception.Message, sQry);
  900. throw Exception(String(exception.ClassName()) + exception.Message);
  901. }
  902. }
  903. __finally
  904. {
  905. if (pADO)
  906. {
  907. pADO->Close();
  908. delete pADO;
  909. }
  910. FBitLists.UnLock();
  911. }
  912. return true;
  913. }
  914. //---------------------------------------------------------------------------
  915. bool TItsFacilityManager::LoadFacilitySig(TADOConnection *ADbConn/*=NULL*/)
  916. {
  917. String sQry;
  918. TADOQuery *pADO = NULL;
  919. #ifndef USE_SIG
  920. return true;
  921. #endif
  922. sQry = "SELECT * FROM VW_SIG_CTLR \r\n";
  923. try
  924. {
  925. FSigLists.Lock();
  926. //FSigLists.RemoveAll();
  927. try
  928. {
  929. pADO = new TADOQuery(NULL);
  930. pADO->Close();
  931. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  932. pADO->SQL->Clear();
  933. pADO->SQL->Text = sQry;
  934. pADO->Prepared = true;
  935. pADO->Open();
  936. for( ; !pADO->Eof; pADO->Next())
  937. {
  938. TItsSig *pObj = new TItsSig();
  939. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  940. pObj->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  941. pObj->SIG_ID = pADO->FieldByName("FACIL_ID")->AsString;
  942. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  943. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  944. pObj->MDL_NM = pADO->FieldByName("MDL_NM")->AsString;
  945. pObj->DEL_YN = "N";
  946. FSigLists.Push(pObj->FCLT_ID, pObj);
  947. }
  948. }
  949. catch(EDatabaseError &E)
  950. {
  951. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  952. DBERRORMSG("TItsFacilityManager::LoadFacilitySig", String(E.ClassName()), E.Message, sQry);
  953. throw Exception(String(E.ClassName()) + E.Message);
  954. }
  955. catch(Exception &exception)
  956. {
  957. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  958. DBERRORMSG("TItsFacilityManager::LoadFacilitySig", String(exception.ClassName()), exception.Message, sQry);
  959. throw Exception(String(exception.ClassName()) + exception.Message);
  960. }
  961. }
  962. __finally
  963. {
  964. if (pADO)
  965. {
  966. pADO->Close();
  967. delete pADO;
  968. }
  969. FSigLists.UnLock();
  970. }
  971. return true;
  972. }
  973. //---------------------------------------------------------------------------
  974. bool TItsFacilityManager::LoadFacilitySigDet(TADOConnection *ADbConn/*=NULL*/)
  975. {
  976. String sQry;
  977. TADOQuery *pADO = NULL;
  978. #ifndef USE_SIGDET
  979. return true;
  980. #endif
  981. sQry = "SELECT * FROM VW_SIG_LVDS \r\n";
  982. try
  983. {
  984. FSigDetLists.Lock();
  985. //FSigDetLists.RemoveAll();
  986. try
  987. {
  988. pADO = new TADOQuery(NULL);
  989. pADO->Close();
  990. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  991. pADO->SQL->Clear();
  992. pADO->SQL->Text = sQry;
  993. pADO->Prepared = true;
  994. pADO->Open();
  995. for( ; !pADO->Eof; pADO->Next())
  996. {
  997. TItsSigDet *pObj = new TItsSigDet();
  998. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  999. pObj->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  1000. pObj->SDET_ID = pADO->FieldByName("FACIL_ID")->AsString;
  1001. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  1002. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  1003. pObj->MDL_NM = pADO->FieldByName("MDL_NM")->AsString;
  1004. pObj->SIG_ID = pADO->FieldByName("ASSETS_CODE")->AsString;
  1005. pObj->DEL_YN = "N";
  1006. FSigDetLists.Push(pObj->FCLT_ID, pObj);
  1007. }
  1008. }
  1009. catch(EDatabaseError &E)
  1010. {
  1011. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1012. DBERRORMSG("TItsFacilityManager::LoadFacilitySigDet", String(E.ClassName()), E.Message, sQry);
  1013. throw Exception(String(E.ClassName()) + E.Message);
  1014. }
  1015. catch(Exception &exception)
  1016. {
  1017. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1018. DBERRORMSG("TItsFacilityManager::LoadFacilitySigDet", String(exception.ClassName()), exception.Message, sQry);
  1019. throw Exception(String(exception.ClassName()) + exception.Message);
  1020. }
  1021. }
  1022. __finally
  1023. {
  1024. if (pADO)
  1025. {
  1026. pADO->Close();
  1027. delete pADO;
  1028. }
  1029. FSigDetLists.UnLock();
  1030. }
  1031. return true;
  1032. }
  1033. //---------------------------------------------------------------------------
  1034. bool TItsFacilityManager::LoadFacilityPvms(TADOConnection *ADbConn/*=NULL*/)
  1035. {
  1036. String sQry;
  1037. TADOQuery *pADO = NULL;
  1038. #ifndef USE_PVMS
  1039. return true;
  1040. #endif
  1041. sQry = "SELECT * FROM VW_PIS_VMS \r\n";
  1042. try
  1043. {
  1044. FPisLists.Lock();
  1045. //FPisLists.RemoveAll();
  1046. try
  1047. {
  1048. pADO = new TADOQuery(NULL);
  1049. pADO->Close();
  1050. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1051. pADO->SQL->Clear();
  1052. pADO->SQL->Text = sQry;
  1053. pADO->Prepared = true;
  1054. pADO->Open();
  1055. for( ; !pADO->Eof; pADO->Next())
  1056. {
  1057. TItsPis *pObj = new TItsPis();
  1058. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  1059. pObj->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  1060. pObj->PIS_ID = pADO->FieldByName("FACIL_ID")->AsString;
  1061. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  1062. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  1063. pObj->DEL_YN = "N";
  1064. FPisLists.Push(pObj->FCLT_ID, pObj);
  1065. }
  1066. }
  1067. catch(EDatabaseError &E)
  1068. {
  1069. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1070. DBERRORMSG("TItsFacilityManager::LoadFacilityPvms", String(E.ClassName()), E.Message, sQry);
  1071. throw Exception(String(E.ClassName()) + E.Message);
  1072. }
  1073. catch(Exception &exception)
  1074. {
  1075. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1076. DBERRORMSG("TItsFacilityManager::LoadFacilityPvms", String(exception.ClassName()), exception.Message, sQry);
  1077. throw Exception(String(exception.ClassName()) + exception.Message);
  1078. }
  1079. }
  1080. __finally
  1081. {
  1082. if (pADO)
  1083. {
  1084. pADO->Close();
  1085. delete pADO;
  1086. }
  1087. FPisLists.UnLock();
  1088. }
  1089. return true;
  1090. }
  1091. //---------------------------------------------------------------------------
  1092. bool TItsFacilityManager::LoadFacilityPvds(TADOConnection *ADbConn/*=NULL*/)
  1093. {
  1094. String sQry;
  1095. TADOQuery *pADO = NULL;
  1096. #ifndef USE_PVDS
  1097. return true;
  1098. #endif
  1099. sQry = "SELECT * FROM VW_PIS_CONT \r\n";
  1100. try
  1101. {
  1102. FPcsLists.Lock();
  1103. //FPcsLists.RemoveAll();
  1104. try
  1105. {
  1106. pADO = new TADOQuery(NULL);
  1107. pADO->Close();
  1108. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1109. pADO->SQL->Clear();
  1110. pADO->SQL->Text = sQry;
  1111. pADO->Prepared = true;
  1112. pADO->Open();
  1113. for( ; !pADO->Eof; pADO->Next())
  1114. {
  1115. TItsPcs *pObj = new TItsPcs();
  1116. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  1117. pObj->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  1118. pObj->PCS_ID = pADO->FieldByName("FACIL_ID")->AsString;
  1119. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  1120. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  1121. pObj->DEL_YN = "N";
  1122. FPcsLists.Push(pObj->FCLT_ID, pObj);
  1123. }
  1124. }
  1125. catch(EDatabaseError &E)
  1126. {
  1127. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1128. DBERRORMSG("TItsFacilityManager::LoadFacilityPvds", String(E.ClassName()), E.Message, sQry);
  1129. throw Exception(String(E.ClassName()) + E.Message);
  1130. }
  1131. catch(Exception &exception)
  1132. {
  1133. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1134. DBERRORMSG("TItsFacilityManager::LoadFacilityPvds", String(exception.ClassName()), exception.Message, sQry);
  1135. throw Exception(String(exception.ClassName()) + exception.Message);
  1136. }
  1137. }
  1138. __finally
  1139. {
  1140. if (pADO)
  1141. {
  1142. pADO->Close();
  1143. delete pADO;
  1144. }
  1145. FPisLists.UnLock();
  1146. }
  1147. return true;
  1148. }
  1149. //---------------------------------------------------------------------------
  1150. bool TItsFacilityManager::LoadFacilityPark(TADOConnection *ADbConn/*=NULL*/)
  1151. {
  1152. if (!PrltCtlrManager)
  1153. {
  1154. PrltCtlrManager = new TPrltCtlrManager();
  1155. }
  1156. #ifdef USE_PARK
  1157. TItsFacility *pFacility;
  1158. TFacilityStatus *pStatus = FListStatus.Find("PARK");
  1159. if (pStatus)
  1160. {
  1161. pStatus->Total = 0;
  1162. pStatus->Normal = 0;
  1163. pStatus->Error = 0;
  1164. pStatus->Module = 0;
  1165. pStatus->Collect= 0;
  1166. }
  1167. PrltCtlrManager->LoadFromDb();
  1168. FOR_STL(TPrltCtlr*, pObj, PrltCtlrManager->FLists)
  1169. {
  1170. if (pObj->DEL_YN == "Y") continue;
  1171. pFacility = FLists.Find(pObj->PRLT_CTLR_ID);
  1172. if (!pFacility) continue;
  1173. pFacility->Object = pObj;
  1174. pFacility->FCLT_KIND = pObj->REAL_DATA_YN; //실시간주차정보제공여부
  1175. //주차장중에 실시간정보를 수집하는 것만 상태정보 범례를 표출하자
  1176. if (pObj->REAL_DATA_YN == "Y")
  1177. {
  1178. if (pStatus)
  1179. {
  1180. pStatus->Total++; /* 전체 갯수를 증가 시킴 */
  1181. }
  1182. }
  1183. }
  1184. #endif
  1185. return true;
  1186. }
  1187. //---------------------------------------------------------------------------
  1188. bool TItsFacilityManager::LoadFacilityCross(TADOConnection *ADbConn/*=NULL*/)
  1189. {
  1190. if (!CrossManager)
  1191. {
  1192. CrossManager = new TCrossManager();
  1193. }
  1194. #ifdef USE_CROSS
  1195. TItsFacility *pFacility;
  1196. CrossManager->LoadFromDb();
  1197. FOR_STL(TCross*, pObj, CrossManager->FLists)
  1198. {
  1199. if (pObj->DEL_YN == "Y") continue;
  1200. pFacility = FLists.Find(pObj->CROSS_ID);
  1201. if (!pFacility) continue;
  1202. pFacility->Object = pObj;
  1203. pFacility->FCLT_KIND = pObj->TYPE_CD;
  1204. }
  1205. FOR_STL(TCrossCam*, pObj, CrossManager->FCamLists)
  1206. {
  1207. if (pObj->DEL_YN == "Y") continue;
  1208. pFacility = FLists.Find(pObj->CAM_ID);
  1209. if (!pFacility) continue;
  1210. pFacility->Object = pObj;
  1211. pFacility->FCLT_KIND = pObj->TYPE_CD;
  1212. }
  1213. #endif
  1214. return true;
  1215. }
  1216. //---------------------------------------------------------------------------
  1217. bool TItsFacilityManager::LoadFacilityStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  1218. {
  1219. bool bResult = true;
  1220. String sQry;
  1221. TADOQuery *pADO = NULL;
  1222. sQry = "SELECT '' AS FAC_TYPE, '' AS FAC_ID, \r\n"
  1223. " '' AS STTS_CD, '' AS DOOR_STTS_CD, \r\n"
  1224. " DECODE('', 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1225. " DECODE('', 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1226. " NVL(NULL, 0) AS CBOX_TMPR, \r\n"
  1227. " '' AS STS00, \r\n"
  1228. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1229. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1230. " FROM DUAL \r\n"
  1231. " WHERE 1 = 0 \r\n"
  1232. #ifdef USE_CCTV
  1233. #if 0
  1234. "UNION \r\n"
  1235. "SELECT 'CCTV' AS FAC_TYPE, B.CCTV_CTLR_ID AS FAC_ID, \r\n"
  1236. " CONN_STTS_CD AS STTS_CD, 'CDS0' AS DOOR_STTS_CD, \r\n"
  1237. " DECODE(CONN_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1238. " '0' AS DOOR, \r\n"
  1239. " 0 AS CBOX_TMPR, \r\n"
  1240. " A.UPDT_DT AS STS00, \r\n"
  1241. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1242. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1243. " FROM TB_CCTV_CTLR_STTS A, TB_CCTV_CTLR B \r\n"
  1244. " WHERE A.CCTV_CTLR_NMBR = B.CCTV_CTLR_NMBR \r\n"
  1245. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1246. #else
  1247. "UNION \r\n"
  1248. "SELECT 'CCTV' AS FAC_TYPE, B.CCTV_CTLR_ID AS FAC_ID, \r\n"
  1249. " CMNC_STTS_CD AS STTS_CD, CBOX_DOOR_STTS_CD AS DOOR_STTS_CD, \r\n"
  1250. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1251. " DECODE(CBOX_DOOR_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1252. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1253. " A.UPDT_DT AS STS00, \r\n"
  1254. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1255. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1256. " FROM TB_CCTV_STTS A, TB_CCTV_CTLR B \r\n"
  1257. " WHERE A.CCTV_MNGM_NMBR = B.CCTV_MNGM_NMBR \r\n"
  1258. " AND UPDT_DT >= TO_CHAR(SYSDATE-10/1440, 'YYYYMMDDHH24MISS') \r\n"
  1259. #endif
  1260. #endif
  1261. #ifdef USE_INCCCTV
  1262. "UNION \r\n"
  1263. "SELECT 'ICAM' AS FAC_TYPE, B.CCTV_CTLR_ID AS FAC_ID, \r\n"
  1264. " CMNC_STTS_CD AS STTS_CD, CBOX_DOOR_STTS_CD AS DOOR_STTS_CD, \r\n"
  1265. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1266. " DECODE(CBOX_DOOR_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1267. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1268. " A.UPDT_DT AS STS00, \r\n"
  1269. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1270. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1271. " FROM TB_CCTV_STTS A, VW_INC_CCTV_CTLR B \r\n"
  1272. " WHERE A.CCTV_MNGM_NMBR = B.CCTV_MNGM_NMBR \r\n"
  1273. " AND UPDT_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n"
  1274. #endif
  1275. #ifdef USE_WCAM
  1276. #ifdef USE_WEB_CMRA
  1277. "UNION \r\n"
  1278. "SELECT 'WCAM' AS FAC_TYPE, B.WEB_CMRA_ID AS FAC_ID, \r\n"
  1279. " CMNC_STTS_CD AS STTS_CD, 'CDS0' AS DOOR_STTS_CD, \r\n"
  1280. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '0') AS COMM, \r\n"
  1281. " '0' AS DOOR, 0 AS CBOX_TMPR, \r\n"
  1282. " A.UPDT_DT AS STS00, \r\n"
  1283. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1284. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1285. " FROM TB_WEB_CMRA_STTS A, TB_WEB_CMRA B \r\n"
  1286. " WHERE A.WEB_CMRA_NMBR = B.WEB_CMRA_NMBR \r\n"
  1287. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1288. #else
  1289. "UNION \r\n"
  1290. "SELECT B.WCAM_TYPE_CD AS FAC_TYPE, B.WCAM_CTLR_ID AS FAC_ID, \r\n"
  1291. " CMNC_STTS_CD AS STTS_CD, 'CDS0' AS DOOR_STTS_CD, \r\n"
  1292. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '0') AS COMM, \r\n"
  1293. " '0' AS DOOR, 0 AS CBOX_TMPR, \r\n"
  1294. " A.UPDT_DT AS STS00, \r\n"
  1295. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1296. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1297. " FROM TB_WCAM_CTLR_STTS A, TB_WCAM_CTLR B \r\n"
  1298. " WHERE A.WCAM_CTLR_NMBR = B.WCAM_CTLR_NMBR \r\n"
  1299. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1300. #endif
  1301. #endif
  1302. #ifdef USE_CCAM
  1303. "UNION \r\n"
  1304. "SELECT 'CCAM' AS FAC_TYPE, B.CCAM_CTLR_ID AS FAC_ID, \r\n"
  1305. " CMNC_STTS_CD AS STTS_CD, CBOX_DOOR_STTS_CD AS DOOR_STTS_CD, \r\n"
  1306. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1307. " DECODE(CBOX_DOOR_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1308. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1309. " A.UPDT_DT AS STS00, \r\n"
  1310. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1311. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1312. " FROM TB_CCAM_CTLR_STTS A, TB_CCAM_CTLR B \r\n"
  1313. " WHERE A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1314. " AND A.CCAM_CTLR_NMBR = B.CCAM_CTLR_NMBR \r\n"
  1315. #endif
  1316. #ifdef USE_VMS
  1317. #if 1
  1318. "UNION \r\n"
  1319. "SELECT 'VMS' AS FAC_TYPE, B.VMS_CTLR_ID AS FAC_ID, \r\n"
  1320. " CMNC_STTS_CD AS STTS_CD, CBOX_DOOR_STTS_CD AS DOOR_STTS_CD, \r\n"
  1321. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1322. " DECODE(CBOX_DOOR_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1323. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1324. " A.UPDT_DT AS STS00, \r\n"
  1325. " DECODE(A.PWER_STTS_CD, 'MOS0', '0', '1') AS STS01, \r\n"
  1326. " DECODE(A.MODL_STTS_CD, 'MOS0', '0', '1') AS STS02, \r\n"
  1327. " '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1328. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1329. " FROM TB_VMS_CTLR_STTS A, TB_VMS_CTLR B \r\n"
  1330. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  1331. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1332. #else
  1333. "UNION \r\n"
  1334. "SELECT 'VMS' AS FAC_TYPE, B.VMS_CTLR_ID AS FAC_ID, \r\n"
  1335. " CONN_STTS_CD AS STTS_CD, CBOXDOOR_OPEN_STTS_CD AS DOOR_STTS_CD, \r\n"
  1336. " DECODE(CONN_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1337. " DECODE(CBOXDOOR_OPEN_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1338. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1339. " A.RGST_DT AS STS00, \r\n"
  1340. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1341. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1342. " FROM TB_VMS_STTS_PRST A, TB_VMS_CTLR B \r\n"
  1343. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  1344. " AND A.RGST_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1345. #endif
  1346. #endif
  1347. #ifdef USE_VDS
  1348. "UNION \r\n"
  1349. "SELECT 'VDS' AS FAC_TYPE, B.VDS_CTLR_ID AS FAC_ID, \r\n"
  1350. " CMNC_STTS_CD AS STTS_CD, CBOX_DOOR_STTS_CD AS DOOR_STTS_CD, \r\n"
  1351. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1352. " DECODE(CBOX_DOOR_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1353. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1354. " A.UPDT_DT AS STS00, \r\n"
  1355. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1356. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1357. " FROM TB_VDS_CTLR_STTS A, TB_VDS_CTLR B \r\n"
  1358. " WHERE A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1359. " AND A.VDS_CTLR_NMBR = B.VDS_CTLR_NMBR \r\n"
  1360. #endif
  1361. #ifdef USE_AVI
  1362. "UNION \r\n"
  1363. "SELECT 'AVI' AS FAC_TYPE, B.AVI_ID AS FAC_ID, \r\n"
  1364. " CONN_STTS_CD AS STTS_CD, CBOX_DOOR_STTS_CD AS DOOR_STTS_CD, \r\n"
  1365. " DECODE(CONN_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1366. " DECODE(CBOX_DOOR_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1367. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1368. " A.UPDT_DT AS STS00, \r\n"
  1369. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1370. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1371. " FROM TB_AVI_CTLR_STTS A, TB_AVI_CTLR B \r\n"
  1372. " WHERE A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1373. " AND A.AVI_CTLR_MNGM_NMBR = B.AVI_CTLR_MNGM_NMBR \r\n"
  1374. #endif
  1375. #ifdef USE_DSRC
  1376. "UNION \r\n"
  1377. "SELECT 'DSRC' AS FAC_TYPE, B.RSE_ID AS FAC_ID, \r\n"
  1378. " DECODE(CMNC_STTS, '0', 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1379. " DECODE(CNTL_DEVC_STTS, '0', 'CDS0', '4', 'CDS0', 'CDS1') AS DOOR_STTS_CD, \r\n"
  1380. " DECODE(CMNC_STTS, '0', '0', '1') AS COMM, \r\n"
  1381. " '0' AS DOOR, 0 AS CBOX_TMPR, \r\n"
  1382. " A.CLCT_DT AS STS00, \r\n"
  1383. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1384. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1385. " FROM TB_RSE_STTS_PNST A, TB_RSE_MSTR B \r\n"
  1386. " WHERE A.CLCT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1387. " AND A.ID = B.ID \r\n"
  1388. #endif
  1389. #ifdef USE_RSE
  1390. "UNION \r\n"
  1391. "SELECT 'RSE' AS FAC_TYPE, B.RSEID AS FAC_ID, \r\n"
  1392. " 'CMS0' AS STTS_CD, 'CDS0' AS DOOR_STTS_CD, \r\n"
  1393. " '0' AS COMM, '0' AS DOOR, 0 AS CBOX_TMPR, \r\n"
  1394. " TO_CHAR(A.COLLDT, 'YYYYMMDDHH24MISS') AS STS00, \r\n"
  1395. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1396. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1397. " FROM RSEOPSTATE A, RSEMST B \r\n"
  1398. " WHERE B.RSEID = A.RSEID \r\n"
  1399. " AND A.COLLDT > SYSDATE - 30/1440 \r\n"
  1400. #endif
  1401. #ifdef USE_BIT
  1402. "UNION \r\n"
  1403. "SELECT 'BIT' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, \r\n"
  1404. " CONN_STATE AS STTS_CD, 'CDS0' AS DOOR_STTS_CD, \r\n"
  1405. " DECODE(CONN_STATE, 'CMS0', '0', '1') AS COMM, \r\n"
  1406. " '0' AS DOOR, 0 AS CBOX_TMPR, \r\n"
  1407. " UPDATE_DT AS STS00, \r\n"
  1408. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1409. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1410. " FROM VW_BIT_STATUS \r\n"
  1411. #endif
  1412. #ifdef USE_SIG
  1413. "UNION \r\n"
  1414. "SELECT 'SIG' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, \r\n"
  1415. " CONN_STATE AS STTS_CD, DOOR_STATE AS DOOR_STTS_CD, \r\n"
  1416. " DECODE(CONN_STATE, 'CMS0', '0', '1') AS COMM, \r\n"
  1417. " DECODE(DOOR_STATE, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1418. " 0 AS CBOX_TMPR, \r\n"
  1419. " UPDATE_DT AS STS00, \r\n"
  1420. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1421. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1422. " FROM VW_SIG_CTLR_STATUS \r\n"
  1423. #endif
  1424. #ifdef USE_SIGDET
  1425. "UNION \r\n"
  1426. "SELECT 'LVD' AS FAC_TYPE, FCLT_ID AS FAC_ID, \r\n"
  1427. " DECODE(DISCONN_STATE, 'STS0', 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1428. " 'CDS0' AS DOOR_STTS_CD, \r\n"
  1429. " DECODE(DISCONN_STATE, 'STS0', '0', '1') AS COMM, \r\n"
  1430. " '0' AS DOOR, 0 AS CBOX_TMPR \r\n"
  1431. " FROM VW_SIG_LVDS_STATUS \r\n"
  1432. #endif
  1433. #ifdef USE_PVMS
  1434. "UNION \r\n"
  1435. "SELECT 'PVMS' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, \r\n"
  1436. " DECODE(COMM_STATE, 0, 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1437. " DECODE(DOOR_STATE, 0, 'CDS0', 'CDS1') AS DOOR_STTS_CD, \r\n"
  1438. " DECODE(COMM_STATE, 0, '0', '1') AS COMM, '0' AS DOOR, \r\n"
  1439. " 0 AS CBOX_TMPR, \r\n"
  1440. " UPDATE_DT AS STS00, \r\n"
  1441. " '0' AS STS01, \r\n"
  1442. " TO_CHAR(POWER_STATE) AS STS02, \r\n"
  1443. " TO_CHAR(MODULE_STATE) AS STS03, \r\n"
  1444. " TO_CHAR(FAN_STATE) AS STS04, \r\n"
  1445. " TO_CHAR(HEATER_STATE) AS STS05, \r\n"
  1446. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1447. " FROM VW_PIS_VMS_STATUS \r\n"
  1448. #endif
  1449. #ifdef USE_PVDS
  1450. "UNION \r\n"
  1451. "SELECT 'PVMS' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, \r\n"
  1452. " DECODE(COMM_STATE, '0', 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1453. " 'CDS0' AS DOOR_STTS_CD, \r\n"
  1454. " DECODE(COMM_STATE, '0', '0', '1') AS COMM, '0' AS DOOR, \r\n"
  1455. " 0 AS CBOX_TMPR, \r\n"
  1456. " UPDATE_DT AS STS00, \r\n"
  1457. " TO_CHAR(CONT_STATE) AS STS01, \r\n"
  1458. " '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1459. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1460. " FROM VW_PIS_CONT_STATUS \r\n"
  1461. #endif
  1462. #ifdef USE_PARK
  1463. "UNION \r\n"
  1464. "SELECT 'PARK' AS FAC_TYPE, B.PRLT_CTLR_ID AS FAC_ID, \r\n"
  1465. " DECODE(A.CMNC_STTS_CD, 'CMS0', 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1466. " 'CDS0' AS DOOR_STTS_CD, \r\n"
  1467. " DECODE(A.CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '0') AS COMM, \r\n"
  1468. " '0' AS DOOR, \r\n"
  1469. " 0 AS CBOX_TMPR, \r\n"
  1470. " A.UPDT_DT AS STS00, \r\n"
  1471. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1472. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1473. " FROM TB_PRLT_CTLR_STTS A, TB_PRLT_CTLR B \r\n"
  1474. " WHERE A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1475. " AND A.PRLT_CTLR_NMBR = B.PRLT_CTLR_NMBR \r\n"
  1476. #endif
  1477. #ifdef USE_CROSS
  1478. "UNION \r\n"
  1479. "SELECT 'CRSCAM' AS FAC_TYPE, A.CAM_ID AS FAC_ID, \r\n"
  1480. " DECODE(A.CMNC_STTS_CD, 'CMS0', 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1481. " 'CDS0' AS DOOR_STTS_CD, \r\n"
  1482. " DECODE(A.CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '0') AS COMM, \r\n"
  1483. " '0' AS DOOR, 0 AS CBOX_TMPR, \r\n"
  1484. " A.UPDT_DT AS STS00, \r\n"
  1485. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1486. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1487. " FROM TB_CRS_CMRA_STTS A \r\n"
  1488. " WHERE A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1489. #endif
  1490. ;
  1491. try
  1492. {
  1493. TItsFacility *pFacility = NULL;
  1494. ItsFacilityManager->FLists.Lock();
  1495. FOR_STL(TItsFacility*, pObj, ItsFacilityManager->FLists)
  1496. {
  1497. pObj->FCollCntBase = 0;
  1498. pObj->FCollCntCurr = 0;
  1499. //수집시간내에 조회되는것은 수집오류가 아니므로 초기에 수집오류로 설정
  1500. if (pObj->FCLT_TYPE == "VDS" ||
  1501. pObj->FCLT_TYPE == "AVI" ||
  1502. pObj->FCLT_TYPE == "DSRC")
  1503. {
  1504. pObj->FCollError = true;
  1505. //pObj->FCollError = false;
  1506. }
  1507. else
  1508. {
  1509. pObj->FCollError = false;
  1510. }
  1511. pObj->FComm = str_state_error;
  1512. pObj->FDoor = str_state_normal;
  1513. pObj->FCommStatus = "CMS1";
  1514. pObj->FDoorStatus = "CDS0";
  1515. #if 0
  1516. if (pObj->FCLT_TYPE == "CCTV" ||
  1517. pObj->FCLT_TYPE == "VMS" ||
  1518. pObj->FCLT_TYPE == "VDS" ||
  1519. pObj->FCLT_TYPE == "AVI")
  1520. {
  1521. pObj->FCBoxTmpr = "?";
  1522. }
  1523. else
  1524. {
  1525. pObj->FCBoxTmpr = "-";
  1526. }
  1527. #else
  1528. pObj->FCBoxTmpr = 0;
  1529. #endif
  1530. #ifdef USE_CROSS
  1531. // 교차로교통량 상태정보 정상으로 초기화 한다.(교차로교통량은 교차로위치를 표출하는 것이다.)
  1532. if (pObj->FCLT_TYPE == "CRS") //교차로교통량
  1533. {
  1534. pObj->FComm = str_state_normal;
  1535. pObj->FDoor = str_state_normal;
  1536. pObj->FCommStatus = "CMS0";
  1537. pObj->FDoorStatus = "CDS0";
  1538. }
  1539. #endif
  1540. }
  1541. //상태정보를 읽어오기전에 상태정보 통계데이터를 초기화한다.
  1542. FOR_STL(TFacilityStatus*, pStatus, ItsFacilityManager->FListStatus)
  1543. {
  1544. //pStatus->Total = 0; 전체 수량은 초기화하지 않는다.
  1545. pStatus->Normal = 0;
  1546. pStatus->Error = 0;
  1547. pStatus->Module = 0;
  1548. pStatus->Collect= 0;
  1549. }
  1550. try
  1551. {
  1552. int nORD;
  1553. pADO = new TADOQuery(NULL);
  1554. pADO->Close();
  1555. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1556. pADO->SQL->Clear();
  1557. pADO->SQL->Text = sQry;
  1558. pADO->Prepared = true;
  1559. pADO->Open();
  1560. //int nRows = pADO->RecordCount;
  1561. for( ; !pADO->Eof; pADO->Next())
  1562. {
  1563. String sId = pADO->FieldByName("FAC_ID")->AsString;
  1564. pFacility = ItsFacilityManager->FLists.Find(sId);
  1565. if (!pFacility) continue;
  1566. pFacility->FCommStatus = pADO->FieldByName("STTS_CD")->AsString;
  1567. pFacility->FDoorStatus = pADO->FieldByName("DOOR_STTS_CD")->AsString;
  1568. pFacility->FComm = pADO->FieldByName("COMM")->AsString;
  1569. pFacility->FDoor = pADO->FieldByName("DOOR")->AsString;
  1570. pFacility->Sts00 = pADO->FieldByName("STS00")->AsString;
  1571. pFacility->Sts01 = pADO->FieldByName("STS01")->AsString;
  1572. pFacility->Sts02 = pADO->FieldByName("STS02")->AsString;
  1573. pFacility->Sts03 = pADO->FieldByName("STS03")->AsString;
  1574. pFacility->Sts04 = pADO->FieldByName("STS04")->AsString;
  1575. pFacility->Sts05 = pADO->FieldByName("STS05")->AsString;
  1576. pFacility->Sts06 = pADO->FieldByName("STS06")->AsString;
  1577. pFacility->Sts07 = pADO->FieldByName("STS07")->AsString;
  1578. pFacility->Sts08 = pADO->FieldByName("STS08")->AsString;
  1579. pFacility->Sts09 = pADO->FieldByName("STS09")->AsString;
  1580. pFacility->Sts10 = pADO->FieldByName("STS10")->AsString;
  1581. //if (pFacility->FCLT_TYPE == "CCTV" ||
  1582. // pFacility->FCLT_TYPE == "VMS" ||
  1583. // pFacility->FCLT_TYPE == "VDS" ||
  1584. // pFacility->FCLT_TYPE == "AVI")
  1585. //{
  1586. // pFacility->FCBoxTmpr = pADO->FieldByName("CBOX_TMPR")->AsString;
  1587. //}
  1588. pFacility->FCBoxTmpr = pADO->FieldByName("CBOX_TMPR")->AsInteger;
  1589. if (pFacility->FComm == str_state_normal)
  1590. {
  1591. //통신이 정상인데 함체문이 열려있으면 모듈이상으로 처리
  1592. #if 0
  1593. if (pFacility->FDoor == "1")
  1594. pFacility->FComm = str_state_module; //모듈이상(함체문 열림)
  1595. #endif
  1596. }
  1597. }
  1598. //수집데이터를 처리하구 수집오류=false로 설정함
  1599. #ifdef USE_DSRC
  1600. LoadDsrcCollectStatusFromDb(ADbConn);
  1601. #endif
  1602. #ifdef USE_VDS
  1603. LoadVdsCollectStatusFromDb(ADbConn);
  1604. #endif
  1605. #ifdef USE_AVI
  1606. LoadAviCollectStatusFromDb(ADbConn);
  1607. #endif
  1608. #ifdef USE_CROSS
  1609. // 교차로교통량, 교차로교통량 CCTV의 상태정보를 참조하여 교차로교통량 상태정보를 업데이트 한다.
  1610. // 교차로교통량 상태정보는 정상으로 초기화 하였다.
  1611. if (CrossManager != NULL)
  1612. {
  1613. FOR_STL(TCross*, pObj, CrossManager->FLists)
  1614. {
  1615. FOR_STL(TCrossCam*, pCam, pObj->FLists)
  1616. {
  1617. pFacility = ItsFacilityManager->FLists.Find(pCam->CAM_ID);
  1618. if (pFacility && pFacility->FComm != str_state_normal)
  1619. {
  1620. TItsFacility *pTrfCross = ItsFacilityManager->FLists.Find(pObj->CROSS_ID);
  1621. if (pTrfCross)
  1622. {
  1623. pTrfCross->FComm = str_state_error;
  1624. }
  1625. break;
  1626. }
  1627. }
  1628. }
  1629. }
  1630. #endif
  1631. }
  1632. catch(EDatabaseError &E)
  1633. {
  1634. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1635. DBERRORLOG("TItsFacilityManager::LoadFacilityStatusFromDb", String(E.ClassName()), E.Message, sQry);
  1636. return false;
  1637. throw Exception(String(E.ClassName()) + E.Message);
  1638. }
  1639. catch(Exception &exception)
  1640. {
  1641. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1642. DBERRORLOG("TItsFacilityManager::LoadFacilityStatusFromDb", String(exception.ClassName()), exception.Message, sQry);
  1643. return false;
  1644. throw Exception(String(exception.ClassName()) + exception.Message);
  1645. }
  1646. }
  1647. __finally
  1648. {
  1649. // 상태정보를 최종 체크한다.
  1650. TFacilityStatus *pStatus;
  1651. FOR_STL(TItsFacility*, pTmpObj, ItsFacilityManager->FLists)
  1652. {
  1653. String FCLT_TYPE = pTmpObj->FCLT_TYPE;
  1654. #if 0
  1655. if (FCLT_TYPE == "VDS" && pTmpObj->FCLT_KIND == "C")
  1656. {
  1657. FCLT_TYPE = "CRSSVR";
  1658. }
  1659. #endif
  1660. pStatus = ItsFacilityManager->FListStatus.Find(FCLT_TYPE);
  1661. if (!pStatus) continue;
  1662. if (FCLT_TYPE == "PARK" && pTmpObj->FCLT_KIND == "N")
  1663. {
  1664. //주차장이면서 실시간정보를 제공하지않는경우 통신정상으로 설정
  1665. pTmpObj->FComm = str_state_default;
  1666. continue;
  1667. }
  1668. if (pTmpObj->FComm == str_state_error) pStatus->Error++;
  1669. else if (pTmpObj->FComm == str_state_module) pStatus->Module++;
  1670. if (pTmpObj->FComm != str_state_error)
  1671. {
  1672. //통신이상이 아닌 경우 수집이상인 경우 수집이상 갯수를 증가시킨다.
  1673. if (pTmpObj->FCollError)
  1674. {
  1675. pStatus->Collect++;
  1676. pTmpObj->FComm = str_state_collect;
  1677. }
  1678. }
  1679. }
  1680. if (pADO)
  1681. {
  1682. pADO->Close();
  1683. delete pADO;
  1684. }
  1685. //각각의 제어기에 대한 상태정보를 업데이트 한다.
  1686. TItsFacility *pFacility;
  1687. FOR_STL(TWCamCtlr*, pObj, WCamCtlrManager->FLists)
  1688. {
  1689. if (pObj->DEL_YN == "Y") continue;
  1690. pFacility = ItsFacilityManager->FLists.Find(pObj->WCAM_CTLR_ID);
  1691. if (pFacility)
  1692. {
  1693. pObj->STATE.Comm = pFacility->FComm != str_state_error ? wcam_normal : wcam_error;
  1694. }
  1695. }
  1696. FOR_STL(TCCamCtlr*, pObj, CCamCtlrManager->FLists)
  1697. {
  1698. if (pObj->DEL_YN == "Y") continue;
  1699. pFacility = ItsFacilityManager->FLists.Find(pObj->CCAM_CTLR_ID);
  1700. if (pFacility)
  1701. {
  1702. pObj->STATE.Comm = pFacility->FComm != str_state_error ? ccam_normal : ccam_error;
  1703. }
  1704. }
  1705. FOR_STL(TVdsCtlr*, pObj, VdsCtlrManager->FLists)
  1706. {
  1707. if (pObj->DEL_YN == "Y") continue;
  1708. pFacility = ItsFacilityManager->FLists.Find(pObj->VDS_CTLR_ID);
  1709. if (pFacility)
  1710. {
  1711. pObj->STATE.Comm = pFacility->FComm != str_state_error ? vds_normal : vds_error;
  1712. }
  1713. }
  1714. FOR_STL(TVmsCtlr*, pObj, VmsCtlrManager->FLists)
  1715. {
  1716. if (pObj->DEL_YN == "Y") continue;
  1717. pFacility = ItsFacilityManager->FLists.Find(pObj->VMS_CTLR_ID);
  1718. if (pFacility)
  1719. {
  1720. pObj->STATE.Comm = pFacility->FComm != str_state_error ? vms_comm_normal : vms_comm_error;
  1721. }
  1722. }
  1723. FOR_STL(TPrltCtlr*, pObj, PrltCtlrManager->FLists)
  1724. {
  1725. if (pObj->DEL_YN == "Y") continue;
  1726. pFacility = ItsFacilityManager->FLists.Find(pObj->PRLT_CTLR_ID);
  1727. if (pFacility)
  1728. {
  1729. pObj->STATE.Comm = pFacility->FComm != str_state_error ? park_comm_normal : park_comm_error;
  1730. }
  1731. }
  1732. FOR_STL(TItsDsrc*, pObj, ItsDsrcManager->FLists)
  1733. {
  1734. if (pObj->DEL_YN == "Y") continue;
  1735. pFacility = ItsFacilityManager->FLists.Find(pObj->DSRC_CTLR_ID);
  1736. if (pFacility)
  1737. {
  1738. pObj->STATE.Comm = pFacility->FComm != str_state_error ? dsrc_normal : dsrc_error;
  1739. }
  1740. }
  1741. ItsFacilityManager->FLists.UnLock();
  1742. }
  1743. return bResult;
  1744. }
  1745. //---------------------------------------------------------------------------
  1746. bool TItsFacilityManager::LoadDsrcCollectStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  1747. {
  1748. String sQry;
  1749. TADOQuery *pADO = NULL;
  1750. #ifndef USE_DSRC
  1751. return true;
  1752. #endif
  1753. sQry = "SELECT DISTINCT B.RSE_ID \r\n"
  1754. " FROM TB_RSE_OBU_CLCT_PNST A, \r\n"
  1755. " TB_RSE_MSTR B \r\n"
  1756. " WHERE A.CLCT_DT > TO_CHAR(SYSDATE-1/24, 'YYYYMMDDHH24MISS') \r\n"
  1757. " AND A.ID = B.ID \r\n";
  1758. try
  1759. {
  1760. TItsFacility *pFacility = NULL;
  1761. try
  1762. {
  1763. int nORD;
  1764. pADO = new TADOQuery(NULL);
  1765. pADO->Close();
  1766. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1767. pADO->SQL->Clear();
  1768. pADO->SQL->Text = sQry;
  1769. pADO->Prepared = true;
  1770. pADO->Open();
  1771. for( ; !pADO->Eof; pADO->Next())
  1772. {
  1773. String sDsrcId = pADO->FieldByName("RSE_ID")->AsString;
  1774. pFacility = ItsFacilityManager->FLists.Find(sDsrcId);
  1775. if (!pFacility) continue;
  1776. pFacility->FCollError = false;
  1777. }
  1778. }
  1779. catch(EDatabaseError &E)
  1780. {
  1781. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1782. DBERRORLOG("TItsFacilityManager::LoadDsrcCollectStatusFromDb", String(E.ClassName()), E.Message, sQry);
  1783. throw Exception(String(E.ClassName()) + E.Message);
  1784. }
  1785. catch(Exception &exception)
  1786. {
  1787. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1788. DBERRORLOG("TItsFacilityManager::LoadDsrcCollectStatusFromDb", String(exception.ClassName()), exception.Message, sQry);
  1789. throw Exception(String(exception.ClassName()) + exception.Message);
  1790. }
  1791. }
  1792. __finally
  1793. {
  1794. if (pADO)
  1795. {
  1796. pADO->Close();
  1797. delete pADO;
  1798. }
  1799. }
  1800. return true;
  1801. }
  1802. //---------------------------------------------------------------------------
  1803. bool TItsFacilityManager::LoadVdsCollectStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  1804. {
  1805. String sQry;
  1806. TADOQuery *pADO = NULL;
  1807. #ifndef USE_VDS
  1808. return true;
  1809. #endif
  1810. sQry = "SELECT DISTINCT C.VDS_CTLR_ID AS VDS_CTLR_ID \r\n"
  1811. " FROM TB_VDS_DTCT_CLCT_PNST A, \r\n"
  1812. " TB_VDS_DTCT B, \r\n"
  1813. " TB_VDS_CTLR C \r\n"
  1814. " WHERE A.CLCT_DT > TO_CHAR(SYSDATE-10/1440, 'YYYYMMDDHH24MISS') \r\n"
  1815. " AND A.VDS_DTCT_NMBR = B.VDS_DTCT_NMBR \r\n"
  1816. " AND B.VDS_CTLR_NMBR = C.VDS_CTLR_NMBR \r\n";
  1817. try
  1818. {
  1819. TItsFacility *pFacility = NULL;
  1820. try
  1821. {
  1822. int nORD;
  1823. pADO = new TADOQuery(NULL);
  1824. pADO->Close();
  1825. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1826. pADO->SQL->Clear();
  1827. pADO->SQL->Text = sQry;
  1828. pADO->Prepared = true;
  1829. pADO->Open();
  1830. pADO->First();
  1831. for( ; !pADO->Eof; pADO->Next())
  1832. {
  1833. String sVdsId = pADO->FieldByName("VDS_CTLR_ID")->AsString;
  1834. pFacility = ItsFacilityManager->FLists.Find(sVdsId);
  1835. if (!pFacility) continue;
  1836. pFacility->FCollError = false;
  1837. }
  1838. }
  1839. catch(EDatabaseError &E)
  1840. {
  1841. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1842. DBERRORLOG("TItsFacilityManager::LoadVdsCollectStatusFromDb", String(E.ClassName()), E.Message, sQry);
  1843. throw Exception(String(E.ClassName()) + E.Message);
  1844. }
  1845. catch(Exception &exception)
  1846. {
  1847. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1848. DBERRORLOG("TItsFacilityManager::LoadVdsCollectStatusFromDb", String(exception.ClassName()), exception.Message, sQry);
  1849. throw Exception(String(exception.ClassName()) + exception.Message);
  1850. }
  1851. }
  1852. __finally
  1853. {
  1854. if (pADO)
  1855. {
  1856. pADO->Close();
  1857. delete pADO;
  1858. }
  1859. }
  1860. return true;
  1861. }
  1862. //---------------------------------------------------------------------------
  1863. bool TItsFacilityManager::LoadAviCollectStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  1864. {
  1865. String sQry;
  1866. TADOQuery *pADO = NULL;
  1867. #ifndef USE_AVI
  1868. return true;
  1869. #endif
  1870. sQry = "SELECT A.AVI_CTLR_MNGM_NMBR, B.AVI_ID \r\n"
  1871. " FROM TB_AVI_PASS_VHCL_PNST A, \r\n"
  1872. " TB_AVI_CTLR B \r\n"
  1873. " WHERE A.CRTN_DT > TO_CHAR(SYSDATE-1/24, 'YYYYMMDDHH24MISS') \r\n"
  1874. " AND A.AVI_CTLR_MNGM_NMBR = B.AVI_CTLR_MNGM_NMBR \r\n";
  1875. try
  1876. {
  1877. TItsFacility *pFacility = NULL;
  1878. try
  1879. {
  1880. int nORD;
  1881. pADO = new TADOQuery(NULL);
  1882. pADO->Close();
  1883. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1884. pADO->SQL->Clear();
  1885. pADO->SQL->Text = sQry;
  1886. pADO->Prepared = true;
  1887. pADO->Open();
  1888. pADO->First();
  1889. for( ; !pADO->Eof; pADO->Next())
  1890. {
  1891. String sAviId = pADO->FieldByName("AVI_ID")->AsString;
  1892. pFacility = ItsFacilityManager->FLists.Find(sAviId);
  1893. if (!pFacility) continue;
  1894. pFacility->FCollError = false;
  1895. }
  1896. }
  1897. catch(EDatabaseError &E)
  1898. {
  1899. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1900. DBERRORLOG("TItsFacilityManager::LoadAviCollectStatusFromDb", String(E.ClassName()), E.Message, sQry);
  1901. throw Exception(String(E.ClassName()) + E.Message);
  1902. }
  1903. catch(Exception &exception)
  1904. {
  1905. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1906. DBERRORLOG("TItsFacilityManager::LoadAviCollectStatusFromDb", String(exception.ClassName()), exception.Message, sQry);
  1907. throw Exception(String(exception.ClassName()) + exception.Message);
  1908. }
  1909. }
  1910. __finally
  1911. {
  1912. if (pADO)
  1913. {
  1914. pADO->Close();
  1915. delete pADO;
  1916. }
  1917. }
  1918. return true;
  1919. }
  1920. //---------------------------------------------------------------------------
  1921. bool TItsFacilityManager::LoadDsrcCollectStatusFromDb_OLD(TADOConnection *ADbConn/*=NULL*/)
  1922. {
  1923. String sQry;
  1924. TADOQuery *pADO = NULL;
  1925. #ifndef USE_DSRC
  1926. return true;
  1927. #endif
  1928. sQry = "SELECT X.ID, X.RSE_ID, X.CLCT_ABNR_BASI, \r\n"
  1929. " Y.STAT_DT, NVL(Y.CLCT_NUM, 0) AS CLCT_NUM \r\n"
  1930. " FROM (SELECT M.ID, M.RSE_ID, M.CLCT_ABNR_BASI \r\n"
  1931. " FROM TB_RSE_MSTR M \r\n"
  1932. " WHERE M.DEL_YN <> 'Y' \r\n"
  1933. " ) X, \r\n"
  1934. " (SELECT P.ID, P.STAT_DT, P.CLCT_NUM \r\n"
  1935. " FROM TB_RSE_OBU_CLCT_HH_PNST P \r\n"
  1936. " WHERE P.STAT_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n"
  1937. " ) Y \r\n"
  1938. " WHERE X.ID = Y.ID(+) \r\n";
  1939. #if 0
  1940. sQry = "SELECT X.ID, X.RSE_ID, X.CLCT_ABNR_BASI, \r\n"
  1941. " Y.STAT_DT, NVL(Y.CLCT_NUM, 0) AS CLCT_NUM \r\n"
  1942. " FROM (SELECT M.ID, M.RSE_ID, M.CLCT_ABNR_BASI \r\n"
  1943. " FROM TB_RSE_MSTR M \r\n"
  1944. " WHERE M.DEL_YN <> 'Y' \r\n"
  1945. " ) X, \r\n"
  1946. " (SELECT ID, STAT_DT, CLCT_NUM \r\n"
  1947. " FROM TB_RSE_OBU_CLCT_HH_PNST \r\n"
  1948. " WHERE (ID, STAT_DT) IN (SELECT P.ID, MAX(P.STAT_DT) \r\n"
  1949. " FROM TB_RSE_OBU_CLCT_HH_PNST P \r\n"
  1950. " WHERE P.STAT_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n"
  1951. " GROUP BY P.ID) \r\n"
  1952. " ) Y \r\n"
  1953. " WHERE X.ID = Y.ID(+) \r\n";
  1954. #endif
  1955. try
  1956. {
  1957. TItsFacility *pFacility = NULL;
  1958. try
  1959. {
  1960. int nORD;
  1961. pADO = new TADOQuery(NULL);
  1962. pADO->Close();
  1963. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1964. pADO->SQL->Clear();
  1965. pADO->SQL->Text = sQry;
  1966. pADO->Prepared = true;
  1967. pADO->Open();
  1968. //int nRows = pADO->RecordCount;
  1969. for( ; !pADO->Eof; pADO->Next())
  1970. {
  1971. String sId = pADO->FieldByName("RSE_ID")->AsString;
  1972. pFacility = ItsFacilityManager->FLists.Find(sId);
  1973. if (!pFacility) continue;
  1974. pFacility->FCollCntBase = pADO->FieldByName("CLCT_ABNR_BASI")->AsInteger;
  1975. pFacility->FCollCntCurr = pADO->FieldByName("CLCT_NUM")->AsInteger;
  1976. }
  1977. }
  1978. catch(EDatabaseError &E)
  1979. {
  1980. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1981. DBERRORLOG("TItsFacilityManager::LoadDsrcCollectStatusFromDb_OLD", String(E.ClassName()), E.Message, sQry);
  1982. throw Exception(String(E.ClassName()) + E.Message);
  1983. }
  1984. catch(Exception &exception)
  1985. {
  1986. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1987. DBERRORLOG("TItsFacilityManager::LoadDsrcCollectStatusFromDb_OLD", String(exception.ClassName()), exception.Message, sQry);
  1988. throw Exception(String(exception.ClassName()) + exception.Message);
  1989. }
  1990. }
  1991. __finally
  1992. {
  1993. if (pADO)
  1994. {
  1995. pADO->Close();
  1996. delete pADO;
  1997. }
  1998. }
  1999. return true;
  2000. }
  2001. //---------------------------------------------------------------------------
  2002. bool TItsFacilityManager::LoadAviCollectStatusFromDb_OLD(TADOConnection *ADbConn/*=NULL*/)
  2003. {
  2004. String sQry;
  2005. TADOQuery *pADO = NULL;
  2006. #ifndef USE_AVI
  2007. return true;
  2008. #endif
  2009. sQry = "SELECT A.AVI_CTLR_MNGM_NMBR, A.AVI_ID, NVL(B.COLCNT, 0) AS COLCNT \r\n"
  2010. " FROM TB_AVI_CTLR A, \r\n"
  2011. " (SELECT AVI_CTLR_MNGM_NMBR, MAX(CRTN_DT) AS CRTN_DT, COUNT(1) AS COLCNT \r\n"
  2012. " FROM TB_AVI_PASS_VHCL_PNST \r\n"
  2013. " WHERE CRTN_DT >= TO_CHAR(SYSDATE-10/1440, 'YYYYMMDDHH24MISS') \r\n"
  2014. " GROUP BY AVI_CTLR_MNGM_NMBR ) B \r\n"
  2015. " WHERE A.DEL_YN = 'N' \r\n"
  2016. " AND A.AVI_CTLR_MNGM_NMBR = B.AVI_CTLR_MNGM_NMBR(+) \r\n";
  2017. try
  2018. {
  2019. TItsFacility *pFacility = NULL;
  2020. try
  2021. {
  2022. int nORD;
  2023. pADO = new TADOQuery(NULL);
  2024. pADO->Close();
  2025. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  2026. pADO->SQL->Clear();
  2027. pADO->SQL->Text = sQry;
  2028. pADO->Prepared = true;
  2029. pADO->Open();
  2030. pADO->First();
  2031. String sAviId;
  2032. int nColCnt;
  2033. for( ; !pADO->Eof; pADO->Next())
  2034. {
  2035. sAviId = pADO->FieldByName("AVI_ID")->AsString;
  2036. pFacility = ItsFacilityManager->FLists.Find(sAviId);
  2037. if (!pFacility)
  2038. {
  2039. continue;
  2040. }
  2041. nColCnt = pADO->FieldByName("COLCNT")->AsInteger;
  2042. if (nColCnt == 0)
  2043. {
  2044. if (pFacility->FComm != str_state_error)
  2045. {
  2046. pFacility->FCollError = true;
  2047. }
  2048. }
  2049. }
  2050. }
  2051. catch(EDatabaseError &E)
  2052. {
  2053. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2054. DBERRORLOG("TItsFacilityManager::LoadAviCollectStatusFromDb_OLD", String(E.ClassName()), E.Message, sQry);
  2055. throw Exception(String(E.ClassName()) + E.Message);
  2056. }
  2057. catch(Exception &exception)
  2058. {
  2059. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2060. DBERRORLOG("TItsFacilityManager::LoadAviCollectStatusFromDb_OLD", String(exception.ClassName()), exception.Message, sQry);
  2061. throw Exception(String(exception.ClassName()) + exception.Message);
  2062. }
  2063. }
  2064. __finally
  2065. {
  2066. if (pADO)
  2067. {
  2068. pADO->Close();
  2069. delete pADO;
  2070. }
  2071. }
  2072. return true;
  2073. }
  2074. //---------------------------------------------------------------------------