CDSFacilityF.cpp 116 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSFacilityF.h"
  4. #include "AppGlobalF.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. FWebCamLists.Lock();
  102. FCctvLists.Lock();
  103. FVmsLists.Lock();
  104. FRseLists.Lock();
  105. FVdsLists.Lock();
  106. FAviLists.Lock();
  107. FDsrcLists.Lock();
  108. FBitLists.Lock();
  109. FSigLists.Lock();
  110. FSigDetLists.Lock();
  111. FPisLists.Lock();
  112. FPcsLists.Lock();
  113. FParkLists.Lock();
  114. FRegLists.Lock();
  115. FLists.Lock();
  116. FWebCamLists.RemoveAll();
  117. FCctvLists.RemoveAll();
  118. FVmsLists.RemoveAll();
  119. FRseLists.RemoveAll();
  120. FVdsLists.RemoveAll();
  121. FAviLists.RemoveAll();
  122. FDsrcLists.RemoveAll();
  123. FBitLists.RemoveAll();
  124. FSigLists.RemoveAll();
  125. FSigDetLists.RemoveAll();
  126. FPisLists.RemoveAll();
  127. FPcsLists.RemoveAll();
  128. FParkLists.RemoveAll();
  129. FRegLists.RemoveAll();
  130. FLists.RemoveAll();
  131. }
  132. __finally
  133. {
  134. FWebCamLists.UnLock();
  135. FCctvLists.UnLock();
  136. FVmsLists.UnLock();
  137. FRseLists.UnLock();
  138. FVdsLists.UnLock();
  139. FAviLists.UnLock();
  140. FDsrcLists.UnLock();
  141. FBitLists.UnLock();
  142. FSigLists.UnLock();
  143. FSigDetLists.UnLock();
  144. FPisLists.UnLock();
  145. FPcsLists.UnLock();
  146. FParkLists.UnLock();
  147. FRegLists.UnLock();
  148. FLists.UnLock();
  149. }
  150. LoadFacilityReg(ADbConn);
  151. LoadFacilityMaster(ADbConn);
  152. #ifdef USE_WCAM
  153. LoadFacilityWebCam(ADbConn);
  154. #endif
  155. #ifdef USE_CCTV
  156. LoadFacilityCctv(ADbConn);
  157. #endif
  158. #ifdef USE_VMS
  159. LoadFacilityVms(ADbConn);
  160. #endif
  161. #ifdef USE_RSE
  162. LoadFacilityRse(ADbConn);
  163. #endif
  164. #ifdef USE_VDS
  165. LoadFacilityVds(ADbConn);
  166. #endif
  167. #ifdef USE_AVI
  168. LoadFacilityAvi(ADbConn);
  169. #endif
  170. #ifdef USE_DSRC
  171. LoadFacilityDsrc(ADbConn);
  172. #endif
  173. #ifdef USE_BIT
  174. LoadFacilityBit(ADbConn);
  175. #endif
  176. #ifdef USE_SIG
  177. LoadFacilitySig(ADbConn);
  178. #endif
  179. #ifdef USE_SIGDET
  180. LoadFacilitySigDet(ADbConn);
  181. #endif
  182. #ifdef USE_PVMS
  183. LoadFacilityPvms(ADbConn);
  184. #endif
  185. #ifdef USE_PVDS
  186. LoadFacilityPvds(ADbConn);
  187. #endif
  188. #ifdef USE_PARK
  189. LoadFacilityPark(ADbConn);
  190. #endif
  191. CheckFacility();
  192. return true;
  193. }
  194. //---------------------------------------------------------------------------
  195. bool TItsFacilityManager::CheckFacility()
  196. {
  197. try
  198. {
  199. FLists.Lock();
  200. FOR_STL(TItsFacility *, pFacility, FLists)
  201. {
  202. TItsRegFacility *pRegFacility = FRegLists.Find(pFacility->FCLT_TYPE + pFacility->FCLT_ID);
  203. if (!pRegFacility)
  204. {
  205. pFacility->Deleted = "Y";
  206. }
  207. }
  208. }
  209. __finally
  210. {
  211. FLists.UnLock();
  212. }
  213. try
  214. {
  215. FRegLists.Lock();
  216. FOR_STL(TItsRegFacility *, pRegFacility, FRegLists)
  217. {
  218. TItsFacility *pFacility = FLists.Find(pRegFacility->Id);
  219. if (!pFacility)
  220. {
  221. pRegFacility->UnRegisterd = "Y";
  222. }
  223. }
  224. }
  225. __finally
  226. {
  227. FRegLists.UnLock();
  228. }
  229. return true;
  230. }
  231. //---------------------------------------------------------------------------
  232. bool TItsFacilityManager::LoadFacilityReg(TADOConnection *ADbConn/*=NULL*/)
  233. {
  234. String sQry;
  235. TADOQuery *pADO = NULL;
  236. sQry = "SELECT '' AS FAC_TYPE, '' AS FAC_ID, '' AS FAC_NM, '' AS DEL_YN \r\n"
  237. " FROM DUAL \r\n"
  238. " WHERE 1 = 0 \r\n"
  239. #ifdef USE_CCTV
  240. "UNION \r\n"
  241. "SELECT 'CCTV' AS FAC_TYPE, CCTV_CTLR_ID AS FAC_ID, ISTL_LCTN_NM AS FAC_NM, DEL_YN \r\n"
  242. " FROM TB_CCTV_CTLR \r\n"
  243. " WHERE DEL_YN = 'N' \r\n"
  244. #endif
  245. #ifdef USE_WCAM
  246. "UNION \r\n"
  247. "SELECT 'WCAM' AS FAC_TYPE, WEB_CMRA_ID AS FAC_ID, ISTL_LCTN_NM AS FAC_NM, DEL_YN \r\n"
  248. " FROM TB_WEB_CMRA \r\n"
  249. " WHERE DEL_YN = 'N' \r\n"
  250. #endif
  251. #ifdef USE_VMS
  252. "UNION \r\n"
  253. "SELECT 'VMS' AS FAC_TYPE, VMS_CTLR_ID AS FAC_ID, VMS_NM AS FAC_NM, DEL_YN \r\n"
  254. " FROM TB_VMS_CTLR \r\n"
  255. " WHERE DEL_YN = 'N' \r\n"
  256. #endif
  257. #ifdef USE_AVI
  258. "UNION \r\n"
  259. "SELECT 'AVI' AS FAC_TYPE, AVI_ID AS FAC_ID, AVI_LCTN_NM AS FAC_NM, DEL_YN \r\n"
  260. " FROM TB_AVI_CTLR \r\n"
  261. " WHERE DEL_YN = 'N' \r\n"
  262. #endif
  263. #ifdef USE_VDS
  264. "UNION \r\n"
  265. "SELECT 'VDS' AS FAC_TYPE, VDS_CTLR_ID AS FAC_ID, LCTN AS FAC_N, DEL_YN \r\n"
  266. " FROM TB_VDS_CTLR \r\n"
  267. " WHERE DEL_YN = 'N' \r\n"
  268. #endif
  269. #ifdef USE_DSRC
  270. "UNION \r\n"
  271. "SELECT 'DSRC' AS FAC_TYPE, RSE_ID AS FAC_ID, ISTL_LCTN_NM AS FAC_NM, DEL_YN \r\n"
  272. " FROM TB_RSE_MSTR \r\n"
  273. " WHERE DEL_YN = 'N' \r\n"
  274. #endif
  275. #ifdef USE_BIT
  276. "UNION \r\n"
  277. "SELECT 'BIT' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, FCLT_LCTN AS FAC_NM, 'N' AS DEL_YN \r\n"
  278. " FROM VW_BIT \r\n"
  279. #if 0
  280. "SELECT 'BIT' AS FAC_TYPE, TO_CHAR(A.BIT_ID) AS FAC_ID, B.STOP_NAME AS FAC_NM, \r\n"
  281. " 'N' AS DEL_YN \r\n"
  282. " FROM BIT A, BUSSTOP B \r\n"
  283. " WHERE 1=1 \r\n"
  284. " AND A.INSTALL_STOP_ID = B.STOP_ID \r\n"
  285. " AND B.USE_FLAG = '1' \r\n"
  286. #endif
  287. #endif
  288. #ifdef USE_SIG
  289. "UNION \r\n"
  290. "SELECT 'SIG' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, FCLT_LCTN AS FAC_NM, 'N' AS DEL_YN \r\n"
  291. " FROM VW_SIG_CTLR \r\n"
  292. #endif
  293. #ifdef USE_PVMS
  294. "UNION \r\n"
  295. "SELECT 'PVMS' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, FCLT_LCTN AS FAC_NM, 'N' AS DEL_YN \r\n"
  296. " FROM VW_PIS_VMS \r\n"
  297. #endif
  298. #ifdef USE_PVDS
  299. "UNION \r\n"
  300. "SELECT 'PVDS' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, FCLT_LCTN AS FAC_NM, 'N' AS DEL_YN \r\n"
  301. " FROM VW_PIS_CONT \r\n"
  302. #endif
  303. #ifdef USE_SIGDET
  304. "UNION \r\n"
  305. "SELECT 'LVD' AS FAC_TYPE, FCLT_ID AS FAC_ID, FCLT_LCTN AS FAC_NM, 'N' AS DEL_YN \r\n"
  306. " FROM VW_SIG_LVDS \r\n"
  307. #endif
  308. #ifdef USE_RSE
  309. "UNION \r\n"
  310. "SELECT 'RSE' AS FAC_TYPE, RSEID AS FAC_ID, LOCATION AS FAC_NM, 'N' AS DEL_YN \r\n"
  311. " FROM RSEMST \r\n"
  312. #endif
  313. #ifdef USE_PARK
  314. "UNION \r\n"
  315. "SELECT 'PARK' AS FAC_TYPE, CTLR_MNGM_NMBR AS FAC_ID, CTLR_MNGM_NM AS FAC_NM, DEL_YN \r\n"
  316. " FROM TB_PRLT_CTLR \r\n"
  317. " WHERE DEL_YN = 'N' \r\n"
  318. #endif
  319. ;
  320. try
  321. {
  322. FRegLists.Lock();
  323. //FRegLists.RemoveAll();
  324. try
  325. {
  326. pADO = new TADOQuery(NULL);
  327. pADO->Close();
  328. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  329. pADO->SQL->Clear();
  330. pADO->SQL->Text = sQry;
  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. // " ORDER BY FCLT_TYPE, FCLT_ID \r\n";
  376. try
  377. {
  378. TFacilityStatus *pStatus;
  379. FListStatus.Lock();
  380. FListStatus.RemoveAll();
  381. FLists.Lock();
  382. //FLists.RemoveAll();
  383. try
  384. {
  385. pADO = new TADOQuery(NULL);
  386. pADO->Close();
  387. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  388. pADO->SQL->Clear();
  389. pADO->SQL->Text = sQry;
  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. FLists.Push(pFacility->FCLT_ID, pFacility);
  422. pFacility->Completed = true;
  423. pStatus = FListStatus.Find(pFacility->FCLT_TYPE);
  424. if (!pStatus)
  425. {
  426. pStatus = new TFacilityStatus();
  427. pStatus->Type = pFacility->FCLT_TYPE;
  428. pStatus->Total = 0;
  429. pStatus->Normal = 0;
  430. pStatus->Error = 0;
  431. pStatus->Module = 0;
  432. pStatus->Collect= 0;
  433. FListStatus.Push(pFacility->FCLT_TYPE, pStatus);
  434. }
  435. pStatus->Total++; /* 전체 갯수를 증가 시킴 */
  436. }
  437. }
  438. catch(EDatabaseError &E)
  439. {
  440. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  441. DBERRORMSG("TItsFacilityManager::LoadFacilityMaster", String(E.ClassName()), E.Message, sQry);
  442. throw Exception(String(E.ClassName()) + E.Message);
  443. }
  444. catch(Exception &exception)
  445. {
  446. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  447. DBERRORMSG("TItsFacilityManager::LoadFacilityMaster", String(exception.ClassName()), exception.Message, sQry);
  448. throw Exception(String(exception.ClassName()) + exception.Message);
  449. }
  450. }
  451. __finally
  452. {
  453. if (pADO)
  454. {
  455. pADO->Close();
  456. delete pADO;
  457. }
  458. FListStatus.UnLock();
  459. FLists.UnLock();
  460. }
  461. return true;
  462. }
  463. //---------------------------------------------------------------------------
  464. bool TItsFacilityManager::LoadFacilityWebCam(TADOConnection *ADbConn/*=NULL*/)
  465. {
  466. String sQry;
  467. TADOQuery *pADO = NULL;
  468. #ifndef USE_WCAM
  469. return true;
  470. #endif
  471. sQry = "SELECT A.WEB_CMRA_NMBR, \r\n"
  472. " A.WEB_CMRA_ID, \r\n"
  473. " A.CMRA_IP, \r\n"
  474. " A.CMRA_PORT, \r\n"
  475. " A.STRM_SVR_IP, \r\n"
  476. " A.STRM_SVR_PORT, \r\n"
  477. " A.STRM_SESN_NM, \r\n"
  478. " A.X_CRDN, \r\n"
  479. " A.Y_CRDN, \r\n"
  480. " A.ISTL_LCTN_NM, \r\n"
  481. " A.ISTL_LCTN_ADDR, \r\n"
  482. " A.EQPM_KIND, \r\n"
  483. " A.DEL_YN, \r\n"
  484. " A.LINK_ID, \r\n"
  485. " B.STRM_RTSP_ADDR, \r\n"
  486. " B.STRM_RTMP_ADDR, \r\n"
  487. " B.STRM_HTTP_ADDR, \r\n"
  488. " B.STRM_STOR_ADDR \r\n"
  489. " FROM TB_WEB_CMRA A, \r\n"
  490. " TB_WEB_CMRA_STRM B \r\n"
  491. " WHERE DEL_YN = 'N' \r\n"
  492. " AND A.WEB_CMRA_NMBR = B.WEB_CMRA_NMBR(+) \r\n";
  493. //" ORDER BY A.WEB_CMRA_NMBR \r\n";
  494. try
  495. {
  496. FWebCamLists.Lock();
  497. try
  498. {
  499. pADO = new TADOQuery(NULL);
  500. pADO->Close();
  501. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  502. pADO->SQL->Clear();
  503. pADO->SQL->Text = sQry;
  504. pADO->Open();
  505. for( ; !pADO->Eof; pADO->Next())
  506. {
  507. TItsWebCam *pObj = new TItsWebCam();
  508. pObj->WEB_CMRA_NMBR = pADO->FieldByName("WEB_CMRA_NMBR")->AsString;
  509. pObj->WEB_CMRA_ID = pADO->FieldByName("WEB_CMRA_ID")->AsString;
  510. pObj->CMRA_IP = pADO->FieldByName("CMRA_IP")->AsString;
  511. pObj->CMRA_PORT = pADO->FieldByName("CMRA_PORT")->AsString;
  512. pObj->STRM_SVR_IP = pADO->FieldByName("STRM_SVR_IP")->AsString;
  513. pObj->STRM_SVR_PORT = pADO->FieldByName("STRM_SVR_PORT")->AsString;
  514. pObj->STRM_SESN_NM = pADO->FieldByName("STRM_SESN_NM")->AsString;
  515. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  516. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  517. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString;
  518. pObj->ISTL_LCTN_ADDR = pADO->FieldByName("ISTL_LCTN_ADDR")->AsString;
  519. pObj->EQPM_KIND = pADO->FieldByName("EQPM_KIND")->AsString;
  520. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  521. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
  522. pObj->STRM_RTSP_ADDR = pADO->FieldByName("STRM_RTSP_ADDR")->AsString;
  523. pObj->STRM_RTMP_ADDR = pADO->FieldByName("STRM_RTMP_ADDR")->AsString;
  524. pObj->STRM_HTTP_ADDR = pADO->FieldByName("STRM_HTTP_ADDR")->AsString;
  525. pObj->STRM_STOR_ADDR = pADO->FieldByName("STRM_STOR_ADDR")->AsString;
  526. pObj->ID = "admin";
  527. pObj->PSWD = "4321";
  528. pObj->FData1 = NULL;
  529. pObj->FData2 = NULL;
  530. FWebCamLists.Push(pObj->WEB_CMRA_ID, pObj);
  531. }
  532. }
  533. catch(EDatabaseError &E)
  534. {
  535. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  536. DBERRORMSG("TItsFacilityManager::LoadFacilityWebCam", String(E.ClassName()), E.Message, sQry);
  537. throw Exception(String(E.ClassName()) + E.Message);
  538. }
  539. catch(Exception &exception)
  540. {
  541. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  542. DBERRORMSG("TItsFacilityManager::LoadFacilityWebCam", String(exception.ClassName()), exception.Message, sQry);
  543. throw Exception(String(exception.ClassName()) + exception.Message);
  544. }
  545. }
  546. __finally
  547. {
  548. if (pADO)
  549. {
  550. pADO->Close();
  551. delete pADO;
  552. }
  553. FWebCamLists.UnLock();
  554. }
  555. return true;
  556. }
  557. //---------------------------------------------------------------------------
  558. bool TItsFacilityManager::LoadFacilityCctv(TADOConnection *ADbConn/*=NULL*/)
  559. {
  560. String sQry;
  561. TADOQuery *pADO = NULL;
  562. #ifndef USE_CCTV
  563. return true;
  564. #endif
  565. sQry = "SELECT CCTV_MNGM_NMBR, \r\n"
  566. " CCTV_CTLR_ID, \r\n"
  567. " CCTV_CTLR_IP, \r\n"
  568. " CCTV_CTLR_PORT, \r\n"
  569. " CCTV_CAPT_IP, \r\n"
  570. " CCTV_CAPT_PORT, \r\n"
  571. " CCTV_FIBR_IP, \r\n"
  572. " CCTV_ENCD_IP, \r\n"
  573. " STRM_SVR_IP, \r\n"
  574. " STRM_SVR_PORT, \r\n"
  575. " STRM_SESN_NM, \r\n"
  576. " NVL(X_CRDN, 0) X_CRDN, \r\n"
  577. " NVL(Y_CRDN, 0) Y_CRDN, \r\n"
  578. " ISTL_LCTN_NM, \r\n"
  579. " ISTL_LCTN_ADDR, \r\n"
  580. " CCTV_CHNL, \r\n"
  581. " DEL_YN, \r\n"
  582. " FRST_REGR_NMBR, \r\n"
  583. " FRST_RGST_DT, \r\n"
  584. " LAST_CRPR_NMBR, \r\n"
  585. " LAST_CRCT_DT, \r\n"
  586. " LINK_ID, \r\n"
  587. " CCTV_ID, \r\n"
  588. " RELY_PORT, \r\n"
  589. " STRM_RTSP_ADDR, \r\n"
  590. " STRM_RTMP_ADDR, \r\n"
  591. " STRM_HTTP_ADDR, \r\n"
  592. " CCTV_TYPE \r\n"
  593. " FROM TB_CCTV_CTLR \r\n"
  594. " WHERE DEL_YN = 'N' \r\n";
  595. //" ORDER BY CCTV_CTLR_ID \r\n";
  596. try
  597. {
  598. FLocalCctvCnt = 0;
  599. FCctvLists.Lock();
  600. //FCctvLists.RemoveAll();
  601. try
  602. {
  603. pADO = new TADOQuery(NULL);
  604. pADO->Close();
  605. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  606. pADO->SQL->Clear();
  607. pADO->SQL->Text = sQry;
  608. pADO->Open();
  609. for( ; !pADO->Eof; pADO->Next())
  610. {
  611. TItsCctv *pObj = new TItsCctv();
  612. pObj->CCTV_MNGM_NMBR = pADO->FieldByName("CCTV_MNGM_NMBR")->AsString;
  613. pObj->CCTV_CTLR_ID = pADO->FieldByName("CCTV_CTLR_ID")->AsString;
  614. pObj->CCTV_CTLR_IP = pADO->FieldByName("CCTV_CTLR_IP")->AsString;
  615. pObj->CCTV_CTLR_PORT = pADO->FieldByName("CCTV_CTLR_PORT")->AsString;
  616. pObj->CCTV_CAPT_IP = pADO->FieldByName("CCTV_CAPT_IP")->AsString;
  617. pObj->CCTV_CAPT_PORT = pADO->FieldByName("CCTV_CAPT_PORT")->AsString;
  618. pObj->CCTV_FIBR_IP = pADO->FieldByName("CCTV_FIBR_IP")->AsString;
  619. pObj->CCTV_ENCD_IP = pADO->FieldByName("CCTV_ENCD_IP")->AsString;
  620. pObj->STRM_SVR_IP = pADO->FieldByName("STRM_SVR_IP")->AsString;
  621. pObj->STRM_SVR_PORT = pADO->FieldByName("STRM_SVR_PORT")->AsString;
  622. pObj->STRM_SESN_NM = pADO->FieldByName("STRM_SESN_NM")->AsString;
  623. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  624. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  625. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString;
  626. pObj->ISTL_LCTN_ADDR = pADO->FieldByName("ISTL_LCTN_ADDR")->AsString;
  627. pObj->CCTV_CHNL = pADO->FieldByName("CCTV_CHNL")->AsString;
  628. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  629. pObj->FRST_REGR_NMBR = pADO->FieldByName("FRST_REGR_NMBR")->AsString;
  630. pObj->FRST_RGST_DT = pADO->FieldByName("FRST_RGST_DT")->AsString;
  631. pObj->LAST_CRPR_NMBR = pADO->FieldByName("LAST_CRPR_NMBR")->AsString;
  632. pObj->LAST_CRCT_DT = pADO->FieldByName("LAST_CRCT_DT")->AsString;
  633. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
  634. pObj->CCTV_ID = pADO->FieldByName("CCTV_ID")->AsString;
  635. pObj->RELY_PORT = pADO->FieldByName("RELY_PORT")->AsString;
  636. pObj->STRM_RTSP_ADDR = pADO->FieldByName("STRM_RTSP_ADDR")->AsString;
  637. pObj->STRM_RTMP_ADDR = pADO->FieldByName("STRM_RTMP_ADDR")->AsString;
  638. pObj->STRM_HTTP_ADDR = pADO->FieldByName("STRM_HTTP_ADDR")->AsString;
  639. pObj->CCTV_TYPE = pADO->FieldByName("CCTV_TYPE")->AsString;
  640. pObj->FData1 = NULL;
  641. pObj->FData2 = NULL;
  642. FCctvLists.Push(pObj->CCTV_CTLR_ID, pObj);
  643. if (pObj->CCTV_CTLR_ID.Pos(CenterId))
  644. {
  645. pObj->LOCAL_YN = "Y";
  646. FLocalCctvCnt++;
  647. }
  648. else
  649. {
  650. pObj->LOCAL_YN = "N";
  651. }
  652. }
  653. }
  654. catch(EDatabaseError &E)
  655. {
  656. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  657. DBERRORMSG("TItsFacilityManager::LoadFacilityCctv", String(E.ClassName()), E.Message, sQry);
  658. throw Exception(String(E.ClassName()) + E.Message);
  659. }
  660. catch(Exception &exception)
  661. {
  662. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  663. DBERRORMSG("TItsFacilityManager::LoadFacilityCctv", String(exception.ClassName()), exception.Message, sQry);
  664. throw Exception(String(exception.ClassName()) + exception.Message);
  665. }
  666. }
  667. __finally
  668. {
  669. if (pADO)
  670. {
  671. pADO->Close();
  672. delete pADO;
  673. }
  674. FCctvLists.UnLock();
  675. }
  676. return true;
  677. }
  678. //---------------------------------------------------------------------------
  679. bool TItsFacilityManager::LoadFacilityVms(TADOConnection *ADbConn/*=NULL*/)
  680. {
  681. String sQry;
  682. TADOQuery *pADO = NULL;
  683. #ifndef USE_VMS
  684. return true;
  685. #endif
  686. #if 0
  687. " scp.dec_b64('DAMO','SCP','ARIA_256.SCPS', WEB_CMRA_PWD) AS WEB_CMRA_PWD, \r\n"
  688. #endif
  689. #if 0
  690. sQry = "SELECT A.*, \r\n"
  691. " (SELECT NVL(ATRB1, '320') \r\n"
  692. " FROM TB_CMMN_CD \r\n"
  693. " WHERE CMMN_CLSF_CD = 'VMP' \r\n"
  694. " AND CMMN_CD = A.VMS_TYPE_CD) AS FORMW, \r\n"
  695. " (SELECT NVL(ATRB2, '64') \r\n"
  696. " FROM TB_CMMN_CD \r\n"
  697. " WHERE CMMN_CLSF_CD = 'VMP' \r\n"
  698. " AND CMMN_CD = A.VMS_TYPE_CD) AS FORMH \r\n"
  699. " FROM TB_VMS_CTLR A \r\n";
  700. " WHERE DEL_YN = 'N' \r\n";
  701. #else
  702. #if 0
  703. //FOR 남양주???
  704. sQry = "SELECT A.*, \r\n"
  705. " (SELECT NVL(VMS_WDTH, 320) \r\n"
  706. " FROM TB_VMS_TYPE \r\n"
  707. " WHERE VMS_TYPE_CD = A.VMS_TYPE_CD) AS FORMW, \r\n"
  708. " (SELECT NVL(VMS_HGHT, 64) \r\n"
  709. " FROM TB_VMS_TYPE \r\n"
  710. " WHERE VMS_TYPE_CD = A.VMS_TYPE_CD) AS FORMH, \r\n"
  711. " (SELECT NVL(MODL_ROW_NUM, 2) \r\n"
  712. " FROM TB_VMS_TYPE \r\n"
  713. " WHERE VMS_TYPE_CD = A.VMS_TYPE_CD) AS MODV, \r\n"
  714. " (SELECT NVL(MODL_COL_NUM, 12) \r\n"
  715. " FROM TB_VMS_TYPE \r\n"
  716. " WHERE VMS_TYPE_CD = A.VMS_TYPE_CD) AS MODH \r\n"
  717. " FROM TB_VMS_CTLR A \r\n";
  718. " WHERE DEL_YN = 'N' \r\n";
  719. #else
  720. sQry = "SELECT A.*, \r\n"
  721. " B.VMS_WDTH AS FORMW, \r\n"
  722. " B.VMS_HGHT AS FORMH, \r\n"
  723. " B.MODL_ROW_NUM AS MODV, \r\n"
  724. " B.MODL_COL_NUM AS MODH \r\n"
  725. " FROM TB_VMS_CTLR A, TB_VMS_TYPE B \r\n"
  726. " WHERE A.DEL_YN = 'N' \r\n"
  727. " AND A.VMS_TYPE_CD = B.VMS_TYPE_CD \r\n";
  728. #endif
  729. #endif
  730. try
  731. {
  732. FVmsLists.Lock();
  733. //FVmsLists.RemoveAll();
  734. try
  735. {
  736. pADO = new TADOQuery(NULL);
  737. pADO->Close();
  738. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  739. pADO->SQL->Clear();
  740. pADO->SQL->Text = sQry;
  741. pADO->Open();
  742. for( ; !pADO->Eof; pADO->Next())
  743. {
  744. TItsVms *pObj = new TItsVms();
  745. pObj->VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  746. pObj->VMS_ID = pADO->FieldByName("VMS_ID")->AsString;
  747. pObj->VMS_CTLR_ID = pADO->FieldByName("VMS_CTLR_ID")->AsString;
  748. pObj->VMS_NM = pADO->FieldByName("VMS_NM")->AsString;
  749. pObj->VMS_CTLR_IP = pADO->FieldByName("VMS_CTLR_IP")->AsString;
  750. pObj->VMS_USAG_TYPE_CD = pADO->FieldByName("VMS_USAG_TYPE_CD")->AsString;
  751. pObj->VMS_FRM_TYPE_CD = pADO->FieldByName("VMS_FRM_TYPE_CD")->AsString;
  752. pObj->VMS_TYPE_CD = pADO->FieldByName("VMS_TYPE_CD")->AsString;
  753. pObj->VMS_MODL_TYPE_CD = pADO->FieldByName("VMS_MODL_TYPE_CD")->AsString;
  754. pObj->VMS_CMNC_PORT = pADO->FieldByName("VMS_CMNC_PORT")->AsString;
  755. pObj->OPER_MODE = pADO->FieldByName("OPER_MODE")->AsString;
  756. pObj->VMS_CMNC_ERR_BASS_VAL = pADO->FieldByName("VMS_CMNC_ERR_BASS_VAL")->AsString;
  757. pObj->VMS_NGHT_BRGH_STEP = pADO->FieldByName("VMS_NGHT_BRGH_STEP")->AsString;
  758. pObj->VMS_WEEK_BRGH_STEP = pADO->FieldByName("VMS_WEEK_BRGH_STEP")->AsString;
  759. pObj->VMS_PHSE_CHNG_CYCL = pADO->FieldByName("VMS_PHSE_CHNG_CYCL")->AsString;
  760. pObj->VMS_MODL_ERR_RATE = pADO->FieldByName("VMS_MODL_ERR_RATE")->AsString;
  761. pObj->CMNCFAIL_SLOT_NMBR = pADO->FieldByName("CMNCFAIL_SLOT_NMBR")->AsString;
  762. pObj->PWER_FAIL_SLOT_NMBR = pADO->FieldByName("PWER_FAIL_SLOT_NMBR")->AsString;
  763. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  764. pObj->CMTRINFR_CNCT_YN = pADO->FieldByName("CMTRINFR_CNCT_YN")->AsString;
  765. pObj->WTHRINFR_CNCT_YN = pADO->FieldByName("WTHRINFR_CNCT_YN")->AsString;
  766. pObj->ENVRINFR_CNCT_YN = pADO->FieldByName("ENVRINFR_CNCT_YN")->AsString;
  767. pObj->VMS_MAX_PHSE_NUM = pADO->FieldByName("VMS_MAX_PHSE_NUM")->AsString;
  768. pObj->FRST_REGR_NMBR = pADO->FieldByName("FRST_REGR_NMBR")->AsString;
  769. pObj->FRST_RGST_DT = pADO->FieldByName("FRST_RGST_DT")->AsString;
  770. pObj->LAST_CRPR_NMBR = pADO->FieldByName("LAST_CRPR_NMBR")->AsString;
  771. pObj->LAST_CRCT_DT = pADO->FieldByName("LAST_CRCT_DT")->AsString;
  772. pObj->PANL_ON_TIME = pADO->FieldByName("PANL_ON_TIME")->AsString;
  773. pObj->PANL_OFF_TIME = pADO->FieldByName("PANL_OFF_TIME")->AsString;
  774. pObj->PANL_PWER_MODE = pADO->FieldByName("PANL_PWER_MODE")->AsString;
  775. pObj->BRGH_MODE = pADO->FieldByName("BRGH_MODE")->AsString;
  776. pObj->WEB_CMRA_IP = pADO->FieldByName("WEB_CMRA_IP")->AsString;
  777. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  778. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  779. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString;
  780. pObj->TRFC_STRG_USE_YN = pADO->FieldByName("TRFC_STRG_USE_YN")->AsString;
  781. #if 1
  782. //FOR 남양주???
  783. pObj->VMS_LOC_IFSC_ID = pADO->FieldByName("WEB_CMRA_PORT")->AsString.Trim();
  784. pObj->FAN_MTNS_TMPR = pADO->FieldByName("WEB_CMRA_PORT")->AsString.Trim();
  785. pObj->HETR_MTNS_TMPR = pADO->FieldByName("WEB_CMRA_PORT")->AsString.Trim();
  786. #endif
  787. pObj->WEB_CMRA_PORT = pADO->FieldByName("WEB_CMRA_PORT")->AsString.Trim();
  788. pObj->WEB_CMRA_ID = pADO->FieldByName("WEB_CMRA_ID")->AsString.Trim();
  789. pObj->WEB_CMRA_PWD = pADO->FieldByName("WEB_CMRA_PWD")->AsString.Trim();
  790. pObj->STRM_SESN_NM = pADO->FieldByName("STRM_SESN_NM")->AsString.Trim();
  791. pObj->WIDTH = pADO->FieldByName("FORMW")->AsInteger;
  792. pObj->HEIGHT = pADO->FieldByName("FORMH")->AsInteger;
  793. pObj->ModVerCnt = pADO->FieldByName("MODV")->AsInteger;
  794. pObj->ModHorCnt = pADO->FieldByName("MODH")->AsInteger;
  795. pObj->FData1 = NULL;
  796. pObj->FData2 = NULL;
  797. //FVmsLists.Push(pObj->VMS_CTLR_NMBR, pObj);
  798. FVmsLists.Push(pObj->VMS_CTLR_ID, pObj);
  799. }
  800. }
  801. catch(EDatabaseError &E)
  802. {
  803. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  804. DBERRORMSG("TItsFacilityManager::LoadFacilityVms", String(E.ClassName()), E.Message, sQry);
  805. throw Exception(String(E.ClassName()) + E.Message);
  806. }
  807. catch(Exception &exception)
  808. {
  809. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  810. DBERRORMSG("TItsFacilityManager::LoadFacilityVms", String(exception.ClassName()), exception.Message, sQry);
  811. throw Exception(String(exception.ClassName()) + exception.Message);
  812. }
  813. }
  814. __finally
  815. {
  816. if (pADO)
  817. {
  818. pADO->Close();
  819. delete pADO;
  820. }
  821. FVmsLists.UnLock();
  822. }
  823. return true;
  824. }
  825. //---------------------------------------------------------------------------
  826. bool TItsFacilityManager::LoadFacilityRse(TADOConnection *ADbConn/*=NULL*/)
  827. {
  828. String sQry;
  829. TADOQuery *pADO = NULL;
  830. #ifndef USE_RSE
  831. return true;
  832. #endif
  833. sQry = "SELECT RSEID, \r\n"
  834. " INSTDT, \r\n"
  835. " CITYCD, \r\n"
  836. " REGIONCD, \r\n"
  837. " AREACD, \r\n"
  838. " RSEIP, \r\n"
  839. " (COORDX/10000000) COORDX, \r\n"
  840. " (COORDY/10000000) COORDY, \r\n"
  841. " RADIUS1, \r\n"
  842. " RADIUS2, \r\n"
  843. " COMPCD, \r\n"
  844. " LOCATION, \r\n"
  845. " RSECONFIGID, \r\n"
  846. " OBEPARAMID, \r\n"
  847. " PORT, \r\n"
  848. " BRIDGE, \r\n"
  849. " COMYN \r\n"
  850. " FROM RSEMST \r\n";
  851. //" ORDER BY RSEID \r\n";
  852. try
  853. {
  854. FRseLists.Lock();
  855. //FRseLists.RemoveAll();
  856. try
  857. {
  858. pADO = new TADOQuery(NULL);
  859. pADO->Close();
  860. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  861. pADO->SQL->Clear();
  862. pADO->SQL->Text = sQry;
  863. pADO->Open();
  864. for( ; !pADO->Eof; pADO->Next())
  865. {
  866. TItsRse *pObj = new TItsRse();
  867. pObj->RSEID = pADO->FieldByName("RSEID")->AsString;
  868. //pObj->INSTDT = pADO->FieldByName("INSTDT")->AsString;
  869. pObj->CITYCD = pADO->FieldByName("CITYCD")->AsString;
  870. pObj->REGIONCD = pADO->FieldByName("REGIONCD")->AsString;
  871. pObj->AREACD = pADO->FieldByName("AREACD")->AsString;
  872. pObj->RSEIP = pADO->FieldByName("RSEIP")->AsString;
  873. pObj->COORDX = pADO->FieldByName("COORDX")->AsString;
  874. pObj->COORDY = pADO->FieldByName("COORDY")->AsString;
  875. pObj->RADIUS1 = pADO->FieldByName("RADIUS1")->AsString;
  876. pObj->RADIUS2 = pADO->FieldByName("RADIUS2")->AsString;
  877. //pObj->COMPCD = pADO->FieldByName("COMPCD")->AsString;
  878. pObj->LOCATION = pADO->FieldByName("LOCATION")->AsString;
  879. //pObj->RSECONFIGID = pADO->FieldByName("RSECONFIGID")->AsString;
  880. //pObj->OBEPARAMID = pADO->FieldByName("OBEPARAMID")->AsString;
  881. //pObj->PORT = pADO->FieldByName("PORT")->AsString;
  882. //pObj->BRIDGE = pADO->FieldByName("BRIDGE")->AsString;
  883. pObj->COMYN = pADO->FieldByName("COMYN")->AsString;
  884. FRseLists.Push(pObj->RSEID, pObj);
  885. }
  886. }
  887. catch(EDatabaseError &E)
  888. {
  889. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  890. DBERRORMSG("TItsFacilityManager::LoadFacilityRse", String(E.ClassName()), E.Message, sQry);
  891. throw Exception(String(E.ClassName()) + E.Message);
  892. }
  893. catch(Exception &exception)
  894. {
  895. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  896. DBERRORMSG("TItsFacilityManager::LoadFacilityRse", String(exception.ClassName()), exception.Message, sQry);
  897. throw Exception(String(exception.ClassName()) + exception.Message);
  898. }
  899. }
  900. __finally
  901. {
  902. if (pADO)
  903. {
  904. pADO->Close();
  905. delete pADO;
  906. }
  907. FRseLists.UnLock();
  908. }
  909. return true;
  910. }
  911. //---------------------------------------------------------------------------
  912. bool TItsFacilityManager::LoadFacilityVds(TADOConnection *ADbConn/*=NULL*/)
  913. {
  914. String sQry;
  915. TADOQuery *pADO = NULL;
  916. #ifndef USE_VDS
  917. return true;
  918. #endif
  919. sQry = "SELECT CTLR_MNGM_NMBR, \r\n"
  920. " CTLR_TYPE_CD, \r\n"
  921. " VALD_YN, \r\n"
  922. " X_CRDN, \r\n"
  923. " Y_CRDN, \r\n"
  924. " LCTN, \r\n"
  925. " TRMN_IP, \r\n"
  926. " TRMN_PORT, \r\n"
  927. " CTLR_CLCT_CYCL, \r\n"
  928. " CTLR_STTS_CYCL, \r\n"
  929. " LOOP_BORD_NUM, \r\n"
  930. " DLTR_NMBR, \r\n"
  931. " DEL_DT, \r\n"
  932. " DEL_YN, \r\n"
  933. " FRST_REGR_NMBR, \r\n"
  934. " FRST_RGST_DT, \r\n"
  935. " LAST_CRPR_NMBR, \r\n"
  936. " LAST_CRCT__DT, \r\n"
  937. " VDS_CTLR_ID \r\n"
  938. " FROM TB_VDS_CTLR \r\n";
  939. //" ORDER BY CTLR_MNGM_NMBR \r\n";
  940. try
  941. {
  942. FVdsLists.Lock();
  943. //FVdsLists.RemoveAll();
  944. try
  945. {
  946. pADO = new TADOQuery(NULL);
  947. pADO->Close();
  948. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  949. pADO->SQL->Clear();
  950. pADO->SQL->Text = sQry;
  951. pADO->Open();
  952. for( ; !pADO->Eof; pADO->Next())
  953. {
  954. TItsVds *pObj = new TItsVds();
  955. pObj->CTLR_MNGM_NMBR = pADO->FieldByName("CTLR_MNGM_NMBR")->AsString;
  956. pObj->CTLR_TYPE_CD = pADO->FieldByName("CTLR_TYPE_CD")->AsString;
  957. pObj->VALD_YN = pADO->FieldByName("VALD_YN")->AsString;
  958. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  959. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  960. pObj->LCTN = pADO->FieldByName("LCTN")->AsString;
  961. pObj->TRMN_IP = pADO->FieldByName("TRMN_IP")->AsString;
  962. pObj->TRMN_PORT = pADO->FieldByName("TRMN_PORT")->AsString;
  963. pObj->CTLR_CLCT_CYCL = pADO->FieldByName("CTLR_CLCT_CYCL")->AsString;
  964. pObj->CTLR_STTS_CYCL = pADO->FieldByName("CTLR_STTS_CYCL")->AsString;
  965. pObj->LOOP_BORD_NUM = pADO->FieldByName("LOOP_BORD_NUM")->AsString;
  966. pObj->DLTR_NMBR = pADO->FieldByName("DLTR_NMBR")->AsString;
  967. pObj->DEL_DT = pADO->FieldByName("DEL_DT")->AsString;
  968. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  969. pObj->FRST_REGR_NMBR = pADO->FieldByName("FRST_REGR_NMBR")->AsString;
  970. pObj->FRST_RGST_DT = pADO->FieldByName("FRST_RGST_DT")->AsString;
  971. pObj->LAST_CRPR_NMBR = pADO->FieldByName("LAST_CRPR_NMBR")->AsString;
  972. pObj->LAST_CRCT__DT = pADO->FieldByName("LAST_CRCT__DT")->AsString;
  973. pObj->VDS_CTLR_ID = pADO->FieldByName("VDS_CTLR_ID")->AsString;
  974. //FVdsLists.Push(pObj->CTLR_MNGM_NMBR, pObj);
  975. FVdsLists.Push(pObj->VDS_CTLR_ID, pObj);
  976. }
  977. }
  978. catch(EDatabaseError &E)
  979. {
  980. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  981. DBERRORMSG("TItsFacilityManager::LoadFacilityVds", String(E.ClassName()), E.Message, sQry);
  982. throw Exception(String(E.ClassName()) + E.Message);
  983. }
  984. catch(Exception &exception)
  985. {
  986. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  987. DBERRORMSG("TItsFacilityManager::LoadFacilityVds", String(exception.ClassName()), exception.Message, sQry);
  988. throw Exception(String(exception.ClassName()) + exception.Message);
  989. }
  990. }
  991. __finally
  992. {
  993. if (pADO)
  994. {
  995. pADO->Close();
  996. delete pADO;
  997. }
  998. FVdsLists.UnLock();
  999. }
  1000. return true;
  1001. }
  1002. //---------------------------------------------------------------------------
  1003. bool TItsFacilityManager::LoadFacilityAvi(TADOConnection *ADbConn/*=NULL*/)
  1004. {
  1005. String sQry;
  1006. TADOQuery *pADO = NULL;
  1007. #ifndef USE_AVI
  1008. return true;
  1009. #endif
  1010. sQry = "SELECT AVI_CTLR_MNGM_NMBR, \r\n"
  1011. " AVI_ID, \r\n"
  1012. " LINK_ID, \r\n"
  1013. " AVI_LCTN_NM, \r\n"
  1014. " AVI_VALD_YN, \r\n"
  1015. " AVI_CTLR_IP, \r\n"
  1016. " AVI_CTLR_CMNC_PORT, \r\n"
  1017. " AVI_MAIN_CTLR_YN, \r\n"
  1018. " AVI_MNGM_LANE_NUM, \r\n"
  1019. " AVI_CMRA_NUM, \r\n"
  1020. " AVI_DTCT_NUM, \r\n"
  1021. " AVI_DTCT_NM, \r\n"
  1022. " AVI_CLCT_CYCL, \r\n"
  1023. " AVI_LAMP_AUTO_YN, \r\n"
  1024. " AVI_LAMP_ON_HMS, \r\n"
  1025. " AVI_LAMP_OFF_HMS, \r\n"
  1026. " AVI_LAMP_ON_YN, \r\n"
  1027. " X_CRDN, \r\n"
  1028. " Y_CRDN, \r\n"
  1029. " RMRK, \r\n"
  1030. " DEL_YN, \r\n"
  1031. " FRST_REGR_NMBR, \r\n"
  1032. " FRST_RGST_DT, \r\n"
  1033. " LAST_CRPR_NMBR, \r\n"
  1034. " LAST_CRCT_DT \r\n"
  1035. " FROM TB_AVI_CTLR \r\n";
  1036. //" ORDER BY AVI_CTLR_MNGM_NMBR \r\n";
  1037. try
  1038. {
  1039. FAviLists.Lock();
  1040. //FAviLists.RemoveAll();
  1041. try
  1042. {
  1043. pADO = new TADOQuery(NULL);
  1044. pADO->Close();
  1045. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1046. pADO->SQL->Clear();
  1047. pADO->SQL->Text = sQry;
  1048. pADO->Open();
  1049. for( ; !pADO->Eof; pADO->Next())
  1050. {
  1051. TItsAvi *pObj = new TItsAvi();
  1052. pObj->AVI_CTLR_MNGM_NMBR= pADO->FieldByName("AVI_CTLR_MNGM_NMBR")->AsString;
  1053. pObj->AVI_ID = pADO->FieldByName("AVI_ID")->AsString;
  1054. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
  1055. pObj->AVI_LCTN_NM = pADO->FieldByName("AVI_LCTN_NM")->AsString;
  1056. pObj->AVI_VALD_YN = pADO->FieldByName("AVI_VALD_YN")->AsString;
  1057. pObj->AVI_CTLR_IP = pADO->FieldByName("AVI_CTLR_IP")->AsString;
  1058. pObj->AVI_CTLR_CMNC_PORT= pADO->FieldByName("AVI_CTLR_CMNC_PORT")->AsString;
  1059. pObj->AVI_MAIN_CTLR_YN = pADO->FieldByName("AVI_MAIN_CTLR_YN")->AsString;
  1060. pObj->AVI_MNGM_LANE_NUM = pADO->FieldByName("AVI_MNGM_LANE_NUM")->AsString;
  1061. pObj->AVI_CMRA_NUM = pADO->FieldByName("AVI_CMRA_NUM")->AsString;
  1062. pObj->AVI_DTCT_NUM = pADO->FieldByName("AVI_DTCT_NUM")->AsString;
  1063. pObj->AVI_DTCT_NM = pADO->FieldByName("AVI_DTCT_NM")->AsString;
  1064. pObj->AVI_CLCT_CYCL = pADO->FieldByName("AVI_CLCT_CYCL")->AsString;
  1065. pObj->AVI_LAMP_AUTO_YN = pADO->FieldByName("AVI_LAMP_AUTO_YN")->AsString;
  1066. pObj->AVI_LAMP_ON_HMS = pADO->FieldByName("AVI_LAMP_ON_HMS")->AsString;
  1067. pObj->AVI_LAMP_OFF_HMS = pADO->FieldByName("AVI_LAMP_OFF_HMS")->AsString;
  1068. pObj->AVI_LAMP_ON_YN = pADO->FieldByName("AVI_LAMP_ON_YN")->AsString;
  1069. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  1070. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  1071. pObj->RMRK = pADO->FieldByName("RMRK")->AsString;
  1072. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  1073. pObj->FRST_REGR_NMBR = pADO->FieldByName("FRST_REGR_NMBR")->AsString;
  1074. pObj->FRST_RGST_DT = pADO->FieldByName("FRST_RGST_DT")->AsString;
  1075. pObj->LAST_CRPR_NMBR = pADO->FieldByName("LAST_CRPR_NMBR")->AsString;
  1076. pObj->LAST_CRCT_DT = pADO->FieldByName("LAST_CRCT_DT")->AsString;
  1077. //FAviLists.Push(pObj->AVI_CTLR_MNGM_NMBR, pObj);
  1078. FAviLists.Push(pObj->AVI_ID, pObj);
  1079. }
  1080. }
  1081. catch(EDatabaseError &E)
  1082. {
  1083. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1084. DBERRORMSG("TItsFacilityManager::LoadFacilityAvi", String(E.ClassName()), E.Message, sQry);
  1085. throw Exception(String(E.ClassName()) + E.Message);
  1086. }
  1087. catch(Exception &exception)
  1088. {
  1089. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1090. DBERRORMSG("TItsFacilityManager::LoadFacilityAvi", String(exception.ClassName()), exception.Message, sQry);
  1091. throw Exception(String(exception.ClassName()) + exception.Message);
  1092. }
  1093. }
  1094. __finally
  1095. {
  1096. if (pADO)
  1097. {
  1098. pADO->Close();
  1099. delete pADO;
  1100. }
  1101. FAviLists.UnLock();
  1102. }
  1103. return true;
  1104. }
  1105. //---------------------------------------------------------------------------
  1106. bool TItsFacilityManager::LoadFacilityDsrc(TADOConnection *ADbConn/*=NULL*/)
  1107. {
  1108. String sQry;
  1109. TADOQuery *pADO = NULL;
  1110. #ifndef USE_DSRC
  1111. return true;
  1112. #endif
  1113. sQry = "SELECT ID, \r\n"
  1114. " RSE_ID, \r\n"
  1115. " ROAD_SPOT_ID, \r\n"
  1116. " LOG_CNNC_ID, \r\n"
  1117. " LOG_CNNC_PW, \r\n"
  1118. " ISTL_LCTN_NM, \r\n"
  1119. " LCTN_X, \r\n"
  1120. " LCTN_Y, \r\n"
  1121. " IP, \r\n"
  1122. " PORT, \r\n"
  1123. " MNFC_CMPY_CD, \r\n"
  1124. " DEL_YN, \r\n"
  1125. " CLCT_ABNR_BASI \r\n"
  1126. " FROM TB_RSE_MSTR \r\n";
  1127. //" ORDER BY ID \r\n";
  1128. try
  1129. {
  1130. FDsrcLists.Lock();
  1131. //FDsrcLists.RemoveAll();
  1132. try
  1133. {
  1134. pADO = new TADOQuery(NULL);
  1135. pADO->Close();
  1136. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1137. pADO->SQL->Clear();
  1138. pADO->SQL->Text = sQry;
  1139. pADO->Open();
  1140. for( ; !pADO->Eof; pADO->Next())
  1141. {
  1142. TItsDsrc *pObj = new TItsDsrc();
  1143. pObj->ID = pADO->FieldByName("ID")->AsString;
  1144. pObj->RSE_ID = pADO->FieldByName("RSE_ID")->AsString;
  1145. pObj->ROAD_SPOT_ID = pADO->FieldByName("ROAD_SPOT_ID")->AsString;
  1146. pObj->LOG_CNNC_ID = pADO->FieldByName("LOG_CNNC_ID")->AsString;
  1147. pObj->LOG_CNNC_PW = pADO->FieldByName("LOG_CNNC_PW")->AsString;
  1148. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString;
  1149. pObj->LCTN_X = pADO->FieldByName("LCTN_X")->AsString;
  1150. pObj->LCTN_Y = pADO->FieldByName("LCTN_Y")->AsString;
  1151. pObj->IP = pADO->FieldByName("IP")->AsString;
  1152. pObj->PORT = pADO->FieldByName("PORT")->AsString;
  1153. pObj->MNFC_CMPY_CD = pADO->FieldByName("MNFC_CMPY_CD")->AsString;
  1154. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  1155. pObj->CLCT_ABNR_BASI = pADO->FieldByName("CLCT_ABNR_BASI")->AsInteger;
  1156. //FDsrcLists.Push(pObj->ID, pObj);
  1157. FDsrcLists.Push(pObj->RSE_ID, pObj);
  1158. }
  1159. }
  1160. catch(EDatabaseError &E)
  1161. {
  1162. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1163. DBERRORMSG("TItsFacilityManager::LoadFacilityDsrc", String(E.ClassName()), E.Message, sQry);
  1164. throw Exception(String(E.ClassName()) + E.Message);
  1165. }
  1166. catch(Exception &exception)
  1167. {
  1168. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1169. DBERRORMSG("TItsFacilityManager::LoadFacilityDsrc", String(exception.ClassName()), exception.Message, sQry);
  1170. throw Exception(String(exception.ClassName()) + exception.Message);
  1171. }
  1172. }
  1173. __finally
  1174. {
  1175. if (pADO)
  1176. {
  1177. pADO->Close();
  1178. delete pADO;
  1179. }
  1180. FDsrcLists.UnLock();
  1181. }
  1182. return true;
  1183. }
  1184. //---------------------------------------------------------------------------
  1185. bool TItsFacilityManager::LoadFacilityBit(TADOConnection *ADbConn/*=NULL*/)
  1186. {
  1187. String sQry;
  1188. TADOQuery *pADO = NULL;
  1189. #ifndef USE_BIT
  1190. return true;
  1191. #endif
  1192. #if 0
  1193. sQry = "SELECT A.BIT_ID, \r\n"
  1194. " A.BIT_TYPE, \r\n"
  1195. " A.FAN_MIN_TEMPERATURE, \r\n"
  1196. " A.FAN_MAX_TEMPERATURE, \r\n"
  1197. " A.HEATER_MIN_TEMPERATURE, \r\n"
  1198. " A.HEATER_MAX_TEMPERATURE, \r\n"
  1199. " A.INSTALL_STOP_ID, \r\n"
  1200. " B.STOP_ID, \r\n"
  1201. " B.SERVICE_ID, \r\n"
  1202. " B.STOP_TYPE, \r\n"
  1203. " B.STOP_NAME, \r\n"
  1204. " B.STOP_SHORTNAME, \r\n"
  1205. " B.STOP_EXPLAIN, \r\n"
  1206. " B.LAT AS COORDY, \r\n"
  1207. " B.LNG AS COORDX, \r\n"
  1208. " B.LINK_ID, \r\n"
  1209. " B.USE_FLAG \r\n"
  1210. " FROM BIT A, BUSSTOP B \r\n"
  1211. " WHERE 1=1 \r\n"
  1212. " AND A.INSTALL_STOP_ID = B.STOP_ID \r\n"
  1213. " AND B.USE_FLAG = '1' \r\n";
  1214. #else
  1215. sQry = "SELECT * FROM VW_BIT \r\n";
  1216. #endif
  1217. try
  1218. {
  1219. FBitLists.Lock();
  1220. //FBitLists.RemoveAll();
  1221. try
  1222. {
  1223. pADO = new TADOQuery(NULL);
  1224. pADO->Close();
  1225. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1226. pADO->SQL->Clear();
  1227. pADO->SQL->Text = sQry;
  1228. pADO->Open();
  1229. for( ; !pADO->Eof; pADO->Next())
  1230. {
  1231. TItsBit *pObj = new TItsBit();
  1232. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  1233. pObj->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  1234. pObj->BIT_ID = pADO->FieldByName("BIT_ID")->AsString;
  1235. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  1236. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  1237. pObj->STOP_ID = pADO->FieldByName("STOP_ID")->AsString;
  1238. #if 0
  1239. pObj->BIT_TYPE = pADO->FieldByName("BIT_TYPE")->AsString;
  1240. pObj->FAN_MIN_TEMPERATURE = pADO->FieldByName("FAN_MIN_TEMPERATURE")->AsInteger;
  1241. pObj->FAN_MAX_TEMPERATURE = pADO->FieldByName("FAN_MAX_TEMPERATURE")->AsInteger;
  1242. pObj->HEATER_MIN_TEMPERATURE = pADO->FieldByName("HEATER_MIN_TEMPERATURE")->AsInteger;
  1243. pObj->HEATER_MAX_TEMPERATURE = pADO->FieldByName("HEATER_MAX_TEMPERATURE")->AsInteger;
  1244. pObj->INSTALL_STOP_ID = pADO->FieldByName("INSTALL_STOP_ID")->AsString;
  1245. pObj->SERVICE_ID = pADO->FieldByName("SERVICE_ID")->AsString;
  1246. pObj->STOP_TYPE = pADO->FieldByName("STOP_TYPE")->AsString;
  1247. pObj->STOP_NAME = pADO->FieldByName("STOP_NAME")->AsString;
  1248. pObj->STOP_SHORTNAME = pADO->FieldByName("STOP_SHORTNAME")->AsString;
  1249. #endif
  1250. pObj->STOP_EXPLAIN = pADO->FieldByName("REMARK")->AsString;
  1251. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
  1252. pObj->DEL_YN = "N";
  1253. FBitLists.Push(pObj->FCLT_ID, pObj);
  1254. }
  1255. }
  1256. catch(EDatabaseError &E)
  1257. {
  1258. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1259. DBERRORMSG("TItsFacilityManager::LoadFacilityBit", String(E.ClassName()), E.Message, sQry);
  1260. throw Exception(String(E.ClassName()) + E.Message);
  1261. }
  1262. catch(Exception &exception)
  1263. {
  1264. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1265. DBERRORMSG("TItsFacilityManager::LoadFacilityBit", String(exception.ClassName()), exception.Message, sQry);
  1266. throw Exception(String(exception.ClassName()) + exception.Message);
  1267. }
  1268. }
  1269. __finally
  1270. {
  1271. if (pADO)
  1272. {
  1273. pADO->Close();
  1274. delete pADO;
  1275. }
  1276. FBitLists.UnLock();
  1277. }
  1278. return true;
  1279. }
  1280. //---------------------------------------------------------------------------
  1281. bool TItsFacilityManager::LoadFacilitySig(TADOConnection *ADbConn/*=NULL*/)
  1282. {
  1283. String sQry;
  1284. TADOQuery *pADO = NULL;
  1285. #ifndef USE_SIG
  1286. return true;
  1287. #endif
  1288. sQry = "SELECT * FROM VW_SIG_CTLR \r\n";
  1289. try
  1290. {
  1291. FSigLists.Lock();
  1292. //FSigLists.RemoveAll();
  1293. try
  1294. {
  1295. pADO = new TADOQuery(NULL);
  1296. pADO->Close();
  1297. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1298. pADO->SQL->Clear();
  1299. pADO->SQL->Text = sQry;
  1300. pADO->Open();
  1301. for( ; !pADO->Eof; pADO->Next())
  1302. {
  1303. TItsSig *pObj = new TItsSig();
  1304. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  1305. pObj->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  1306. pObj->SIG_ID = pADO->FieldByName("FACIL_ID")->AsString;
  1307. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  1308. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  1309. pObj->MDL_NM = pADO->FieldByName("MDL_NM")->AsString;
  1310. pObj->DEL_YN = "N";
  1311. FSigLists.Push(pObj->FCLT_ID, pObj);
  1312. }
  1313. }
  1314. catch(EDatabaseError &E)
  1315. {
  1316. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1317. DBERRORMSG("TItsFacilityManager::LoadFacilitySig", String(E.ClassName()), E.Message, sQry);
  1318. throw Exception(String(E.ClassName()) + E.Message);
  1319. }
  1320. catch(Exception &exception)
  1321. {
  1322. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1323. DBERRORMSG("TItsFacilityManager::LoadFacilitySig", String(exception.ClassName()), exception.Message, sQry);
  1324. throw Exception(String(exception.ClassName()) + exception.Message);
  1325. }
  1326. }
  1327. __finally
  1328. {
  1329. if (pADO)
  1330. {
  1331. pADO->Close();
  1332. delete pADO;
  1333. }
  1334. FSigLists.UnLock();
  1335. }
  1336. return true;
  1337. }
  1338. //---------------------------------------------------------------------------
  1339. bool TItsFacilityManager::LoadFacilitySigDet(TADOConnection *ADbConn/*=NULL*/)
  1340. {
  1341. String sQry;
  1342. TADOQuery *pADO = NULL;
  1343. #ifndef USE_SIGDET
  1344. return true;
  1345. #endif
  1346. sQry = "SELECT * FROM VW_SIG_LVDS \r\n";
  1347. try
  1348. {
  1349. FSigDetLists.Lock();
  1350. //FSigDetLists.RemoveAll();
  1351. try
  1352. {
  1353. pADO = new TADOQuery(NULL);
  1354. pADO->Close();
  1355. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1356. pADO->SQL->Clear();
  1357. pADO->SQL->Text = sQry;
  1358. pADO->Open();
  1359. for( ; !pADO->Eof; pADO->Next())
  1360. {
  1361. TItsSigDet *pObj = new TItsSigDet();
  1362. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  1363. pObj->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  1364. pObj->SDET_ID = pADO->FieldByName("FACIL_ID")->AsString;
  1365. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  1366. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  1367. pObj->MDL_NM = pADO->FieldByName("MDL_NM")->AsString;
  1368. pObj->SIG_ID = pADO->FieldByName("ASSETS_CODE")->AsString;
  1369. pObj->DEL_YN = "N";
  1370. FSigDetLists.Push(pObj->FCLT_ID, pObj);
  1371. }
  1372. }
  1373. catch(EDatabaseError &E)
  1374. {
  1375. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1376. DBERRORMSG("TItsFacilityManager::LoadFacilitySigDet", String(E.ClassName()), E.Message, sQry);
  1377. throw Exception(String(E.ClassName()) + E.Message);
  1378. }
  1379. catch(Exception &exception)
  1380. {
  1381. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1382. DBERRORMSG("TItsFacilityManager::LoadFacilitySigDet", String(exception.ClassName()), exception.Message, sQry);
  1383. throw Exception(String(exception.ClassName()) + exception.Message);
  1384. }
  1385. }
  1386. __finally
  1387. {
  1388. if (pADO)
  1389. {
  1390. pADO->Close();
  1391. delete pADO;
  1392. }
  1393. FSigDetLists.UnLock();
  1394. }
  1395. return true;
  1396. }
  1397. //---------------------------------------------------------------------------
  1398. bool TItsFacilityManager::LoadFacilityPvms(TADOConnection *ADbConn/*=NULL*/)
  1399. {
  1400. String sQry;
  1401. TADOQuery *pADO = NULL;
  1402. #ifndef USE_PVMS
  1403. return true;
  1404. #endif
  1405. sQry = "SELECT * FROM VW_PIS_VMS \r\n";
  1406. try
  1407. {
  1408. FPisLists.Lock();
  1409. //FPisLists.RemoveAll();
  1410. try
  1411. {
  1412. pADO = new TADOQuery(NULL);
  1413. pADO->Close();
  1414. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1415. pADO->SQL->Clear();
  1416. pADO->SQL->Text = sQry;
  1417. pADO->Open();
  1418. for( ; !pADO->Eof; pADO->Next())
  1419. {
  1420. TItsPis *pObj = new TItsPis();
  1421. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  1422. pObj->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  1423. pObj->PIS_ID = pADO->FieldByName("FACIL_ID")->AsString;
  1424. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  1425. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  1426. pObj->DEL_YN = "N";
  1427. FPisLists.Push(pObj->FCLT_ID, pObj);
  1428. }
  1429. }
  1430. catch(EDatabaseError &E)
  1431. {
  1432. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1433. DBERRORMSG("TItsFacilityManager::LoadFacilityPvms", String(E.ClassName()), E.Message, sQry);
  1434. throw Exception(String(E.ClassName()) + E.Message);
  1435. }
  1436. catch(Exception &exception)
  1437. {
  1438. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1439. DBERRORMSG("TItsFacilityManager::LoadFacilityPvms", String(exception.ClassName()), exception.Message, sQry);
  1440. throw Exception(String(exception.ClassName()) + exception.Message);
  1441. }
  1442. }
  1443. __finally
  1444. {
  1445. if (pADO)
  1446. {
  1447. pADO->Close();
  1448. delete pADO;
  1449. }
  1450. FPisLists.UnLock();
  1451. }
  1452. return true;
  1453. }
  1454. //---------------------------------------------------------------------------
  1455. bool TItsFacilityManager::LoadFacilityPvds(TADOConnection *ADbConn/*=NULL*/)
  1456. {
  1457. String sQry;
  1458. TADOQuery *pADO = NULL;
  1459. #ifndef USE_PVDS
  1460. return true;
  1461. #endif
  1462. sQry = "SELECT * FROM VW_PIS_CONT \r\n";
  1463. try
  1464. {
  1465. FPcsLists.Lock();
  1466. //FPcsLists.RemoveAll();
  1467. try
  1468. {
  1469. pADO = new TADOQuery(NULL);
  1470. pADO->Close();
  1471. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1472. pADO->SQL->Clear();
  1473. pADO->SQL->Text = sQry;
  1474. pADO->Open();
  1475. for( ; !pADO->Eof; pADO->Next())
  1476. {
  1477. TItsPcs *pObj = new TItsPcs();
  1478. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString;
  1479. pObj->FCLT_LCTN = pADO->FieldByName("FCLT_LCTN")->AsString;
  1480. pObj->PCS_ID = pADO->FieldByName("FACIL_ID")->AsString;
  1481. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  1482. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  1483. pObj->DEL_YN = "N";
  1484. FPcsLists.Push(pObj->FCLT_ID, pObj);
  1485. }
  1486. }
  1487. catch(EDatabaseError &E)
  1488. {
  1489. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1490. DBERRORMSG("TItsFacilityManager::LoadFacilityPvds", String(E.ClassName()), E.Message, sQry);
  1491. throw Exception(String(E.ClassName()) + E.Message);
  1492. }
  1493. catch(Exception &exception)
  1494. {
  1495. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1496. DBERRORMSG("TItsFacilityManager::LoadFacilityPvds", String(exception.ClassName()), exception.Message, sQry);
  1497. throw Exception(String(exception.ClassName()) + exception.Message);
  1498. }
  1499. }
  1500. __finally
  1501. {
  1502. if (pADO)
  1503. {
  1504. pADO->Close();
  1505. delete pADO;
  1506. }
  1507. FPisLists.UnLock();
  1508. }
  1509. return true;
  1510. }
  1511. //---------------------------------------------------------------------------
  1512. bool TItsFacilityManager::LoadFacilityPark(TADOConnection *ADbConn/*=NULL*/)
  1513. {
  1514. String sQry;
  1515. TADOQuery *pADO = NULL;
  1516. #ifndef USE_PARK
  1517. return true;
  1518. #endif
  1519. sQry = "SELECT A.*, \r\n"
  1520. " B.PRLT_MNGM_INTN_NM, \r\n"
  1521. " B.PRLT_MNGM_INTN_TEL, \r\n"
  1522. " B.PARK_NDSY_CD, \r\n"
  1523. " B.PARK_OPER_DAY_CD, \r\n"
  1524. " B.PARK_WKDY_STRT_HH, \r\n"
  1525. " B.PARK_WKDY_END_HH, \r\n"
  1526. " B.PARK_LHDY_STRT_HH, \r\n"
  1527. " B.PARK_LHDY_END_HH, \r\n"
  1528. " B.PARK_OPDR_CD, \r\n"
  1529. " B.PARK_FARE_IMPS_CD, \r\n"
  1530. " B.PARK_APNT_OFFR_YN \r\n"
  1531. " FROM TB_PRLT_CTLR A, \r\n"
  1532. " TB_PRLT_OPER_INFR B \r\n"
  1533. " WHERE A.DEL_YN = 'N' \r\n"
  1534. " AND A.CTLR_MNGM_NMBR = B.CTLR_MNGM_NMBR(+) \r\n";
  1535. try
  1536. {
  1537. FParkLists.Lock();
  1538. //FParkLists.RemoveAll();
  1539. try
  1540. {
  1541. pADO = new TADOQuery(NULL);
  1542. pADO->Close();
  1543. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1544. pADO->SQL->Clear();
  1545. pADO->SQL->Text = sQry;
  1546. pADO->Open();
  1547. for( ; !pADO->Eof; pADO->Next())
  1548. {
  1549. TItsParking *pObj = new TItsParking();
  1550. pObj->CTLR_MNGM_NMBR = pADO->FieldByName("CTLR_MNGM_NMBR")->AsString;
  1551. pObj->PRLT_OPER_DVSN_CD = pADO->FieldByName("PRLT_OPER_DVSN_CD")->AsString;
  1552. pObj->PRLT_TYPE_DVSN_CD = pADO->FieldByName("PRLT_TYPE_DVSN_CD")->AsString;
  1553. pObj->VALD_YN = pADO->FieldByName("VALD_YN")->AsString;
  1554. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsString;
  1555. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsString;
  1556. pObj->ISTL_LCTN_ADDR = pADO->FieldByName("ISTL_LCTN_ADDR")->AsString;
  1557. pObj->TRMN_IP = pADO->FieldByName("TRMN_IP")->AsString;
  1558. pObj->TRMN_PORT = pADO->FieldByName("TRMN_PORT")->AsString;
  1559. pObj->CTLR_CLCT_CYCL = pADO->FieldByName("CTLR_CLCT_CYCL")->AsString;
  1560. pObj->CTLR_STTS_CYCL = pADO->FieldByName("CTLR_STTS_CYCL")->AsString;
  1561. pObj->WHOL_NPLS = pADO->FieldByName("WHOL_NPLS")->AsString;
  1562. pObj->DEL_USER_ID = pADO->FieldByName("DEL_USER_ID")->AsString;
  1563. pObj->DEL_DT = pADO->FieldByName("DEL_DT")->AsString;
  1564. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  1565. pObj->ADTN_USER_ID = pADO->FieldByName("ADTN_USER_ID")->AsString;
  1566. pObj->ADTN_DT = pADO->FieldByName("ADTN_DT")->AsString;
  1567. pObj->CHNG_USER_ID = pADO->FieldByName("CHNG_USER_ID")->AsString;
  1568. pObj->CHNG_DT = pADO->FieldByName("CHNG_DT")->AsString;
  1569. pObj->CTLR_MNGM_NM = pADO->FieldByName("CTLR_MNGM_NM")->AsString;
  1570. #ifdef USE_PARK_REAL
  1571. pObj->REAL_DATA_YN = pADO->FieldByName("REAL_DATA_YN")->AsString;
  1572. #else
  1573. pObj->REAL_DATA_YN = "Y";
  1574. #endif
  1575. pObj->PRLT_MNGM_INTN_NM = pADO->FieldByName("PRLT_MNGM_INTN_NM")->AsString;
  1576. pObj->PRLT_MNGM_INTN_TEL= pADO->FieldByName("PRLT_MNGM_INTN_TEL")->AsString;
  1577. pObj->PARK_NDSY_CD = pADO->FieldByName("PARK_NDSY_CD")->AsString;
  1578. pObj->PARK_OPER_DAY_CD = pADO->FieldByName("PARK_OPER_DAY_CD")->AsString;
  1579. pObj->PARK_WKDY_STRT_HH = pADO->FieldByName("PARK_WKDY_STRT_HH")->AsString;
  1580. pObj->PARK_WKDY_END_HH = pADO->FieldByName("PARK_WKDY_END_HH")->AsString;
  1581. pObj->PARK_LHDY_STRT_HH = pADO->FieldByName("PARK_LHDY_STRT_HH")->AsString;
  1582. pObj->PARK_LHDY_END_HH = pADO->FieldByName("PARK_LHDY_END_HH")->AsString;
  1583. pObj->PARK_OPDR_CD = pADO->FieldByName("PARK_OPDR_CD")->AsString;
  1584. pObj->PARK_FARE_IMPS_CD = pADO->FieldByName("PARK_FARE_IMPS_CD")->AsString;
  1585. pObj->PARK_APNT_OFFR_YN = pADO->FieldByName("PARK_APNT_OFFR_YN")->AsString;
  1586. FParkLists.Push(pObj->CTLR_MNGM_NMBR, pObj);
  1587. }
  1588. }
  1589. catch(EDatabaseError &E)
  1590. {
  1591. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1592. DBERRORLOG("TItsFacilityManager::LoadFacilityPark", String(E.ClassName()), E.Message, sQry);
  1593. return false;
  1594. throw Exception(String(E.ClassName()) + E.Message);
  1595. }
  1596. catch(Exception &exception)
  1597. {
  1598. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1599. DBERRORLOG("TItsFacilityManager::LoadFacilityPark", String(exception.ClassName()), exception.Message, sQry);
  1600. return false;
  1601. throw Exception(String(exception.ClassName()) + exception.Message);
  1602. }
  1603. }
  1604. __finally
  1605. {
  1606. if (pADO)
  1607. {
  1608. pADO->Close();
  1609. delete pADO;
  1610. }
  1611. FParkLists.UnLock();
  1612. }
  1613. return true;
  1614. }
  1615. //---------------------------------------------------------------------------
  1616. bool TItsFacilityManager::LoadFacilityStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  1617. {
  1618. bool bResult = true;
  1619. String sQry;
  1620. TADOQuery *pADO = NULL;
  1621. sQry = "SELECT '' AS FAC_TYPE, '' AS FAC_ID, \r\n"
  1622. " '' AS STTS_CD, '' AS DOOR_STTS_CD, \r\n"
  1623. " DECODE('', 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1624. " DECODE('', 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1625. " NVL(NULL, 0) AS CBOX_TMPR, \r\n"
  1626. " '' AS STS00, \r\n"
  1627. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1628. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1629. " FROM DUAL \r\n"
  1630. " WHERE 1 = 0 \r\n"
  1631. #ifdef USE_CCTV
  1632. "UNION \r\n"
  1633. "SELECT 'CCTV' AS FAC_TYPE, B.CCTV_CTLR_ID AS FAC_ID, \r\n"
  1634. " CMNC_STTS_CD AS STTS_CD, CBOX_DOOR_STTS_CD AS DOOR_STTS_CD, \r\n"
  1635. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1636. " DECODE(CBOX_DOOR_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1637. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1638. " A.UPDT_DT AS STS00, \r\n"
  1639. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1640. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1641. " FROM TB_CCTV_STTS A, TB_CCTV_CTLR B \r\n"
  1642. " WHERE A.CCTV_MNGM_NMBR = B.CCTV_MNGM_NMBR \r\n"
  1643. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1644. #endif
  1645. #ifdef USE_WCAM
  1646. "UNION \r\n"
  1647. "SELECT 'WCAM' AS FAC_TYPE, B.WEB_CMRA_ID AS FAC_ID, \r\n"
  1648. " CMNC_STTS_CD AS STTS_CD, 'CDS0' AS DOOR_STTS_CD, \r\n"
  1649. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '0') AS COMM, \r\n"
  1650. " '0' AS DOOR, 0 AS CBOX_TMPR, \r\n"
  1651. " A.UPDT_DT AS STS00, \r\n"
  1652. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1653. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1654. " FROM TB_WEB_CMRA_STTS A, TB_WEB_CMRA B \r\n"
  1655. " WHERE A.WEB_CMRA_NMBR = B.WEB_CMRA_NMBR \r\n"
  1656. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1657. #endif
  1658. #ifdef USE_VMS
  1659. "UNION \r\n"
  1660. "SELECT 'VMS' AS FAC_TYPE, B.VMS_CTLR_ID AS FAC_ID, \r\n"
  1661. " CONN_STTS_CD AS STTS_CD, CBOXDOOR_OPEN_STTS_CD AS DOOR_STTS_CD, \r\n"
  1662. " DECODE(CONN_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1663. " DECODE(CBOXDOOR_OPEN_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1664. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1665. " A.RGST_DT AS STS00, \r\n"
  1666. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1667. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1668. " FROM TB_VMS_STTS_PRST A, TB_VMS_CTLR B \r\n"
  1669. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  1670. " AND A.RGST_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1671. #endif
  1672. #ifdef USE_VDS
  1673. "UNION \r\n"
  1674. "SELECT 'VDS' AS FAC_TYPE, B.VDS_CTLR_ID AS FAC_ID, \r\n"
  1675. " CMNC_STTS_CD AS STTS_CD, CBOX_DOOR_STTS_CD AS DOOR_STTS_CD, \r\n"
  1676. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1677. " DECODE(CBOX_DOOR_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1678. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1679. " A.UPDT_DT AS STS00, \r\n"
  1680. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1681. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1682. " FROM TB_VDS_CTLR_STTS A, TB_VDS_CTLR B \r\n"
  1683. " WHERE A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1684. " AND A.CTLR_MNGM_NMBR = B.CTLR_MNGM_NMBR \r\n"
  1685. #endif
  1686. #ifdef USE_AVI
  1687. "UNION \r\n"
  1688. "SELECT 'AVI' AS FAC_TYPE, B.AVI_ID AS FAC_ID, \r\n"
  1689. " CMNC_STTS_CD AS STTS_CD, CBOX_DOOR_STTS_CD AS DOOR_STTS_CD, \r\n"
  1690. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '2') AS COMM, \r\n"
  1691. " DECODE(CBOX_DOOR_STTS_CD, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1692. " NVL(A.CBOX_TMPR, 0) AS CBOX_TMPR, \r\n"
  1693. " A.UPDT_DT AS STS00, \r\n"
  1694. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1695. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1696. " FROM TB_AVI_CTLR_STTS A, TB_AVI_CTLR B \r\n"
  1697. " WHERE A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1698. " AND A.AVI_CTLR_MNGM_NMBR = B.AVI_CTLR_MNGM_NMBR \r\n"
  1699. #endif
  1700. #ifdef USE_DSRC
  1701. "UNION \r\n"
  1702. "SELECT 'DSRC' AS FAC_TYPE, B.RSE_ID AS FAC_ID, \r\n"
  1703. " DECODE(CMNC_STTS, '0', 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1704. " DECODE(CNTL_DEVC_STTS, '0', 'CDS0', '4', 'CDS0', 'CDS1') AS DOOR_STTS_CD, \r\n"
  1705. " DECODE(CMNC_STTS, '0', '0', '1') AS COMM, \r\n"
  1706. " '0' AS DOOR, 0 AS CBOX_TMPR, \r\n"
  1707. " A.CLCT_DT AS STS00, \r\n"
  1708. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1709. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1710. " FROM TB_RSE_STTS_PNST A, TB_RSE_MSTR B \r\n"
  1711. " WHERE A.CLCT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1712. " AND A.ID = B.ID \r\n"
  1713. #endif
  1714. #ifdef USE_RSE
  1715. "UNION \r\n"
  1716. "SELECT 'RSE' AS FAC_TYPE, B.RSEID AS FAC_ID, \r\n"
  1717. " 'CMS0' AS STTS_CD, 'CDS0' AS DOOR_STTS_CD, \r\n"
  1718. " '0' AS COMM, '0' AS DOOR, 0 AS CBOX_TMPR, \r\n"
  1719. " TO_CHAR(A.COLLDT, 'YYYYMMDDHH24MISS') AS STS00, \r\n"
  1720. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1721. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1722. " FROM RSEOPSTATE A, RSEMST B \r\n"
  1723. " WHERE B.RSEID = A.RSEID \r\n"
  1724. " AND A.COLLDT > SYSDATE - 30/1440 \r\n"
  1725. #endif
  1726. #ifdef USE_BIT
  1727. "UNION \r\n"
  1728. "SELECT 'BIT' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, \r\n"
  1729. " CONN_STATE AS STTS_CD, 'CDS0' AS DOOR_STTS_CD, \r\n"
  1730. " DECODE(CONN_STATE, 'CMS0', '0', '1') AS COMM, \r\n"
  1731. " '0' AS DOOR, 0 AS CBOX_TMPR, \r\n"
  1732. " UPDATE_DT AS STS00, \r\n"
  1733. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1734. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1735. " FROM VW_BIT_STATUS \r\n"
  1736. #endif
  1737. #ifdef USE_SIG
  1738. "UNION \r\n"
  1739. "SELECT 'SIG' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, \r\n"
  1740. " CONN_STATE AS STTS_CD, DOOR_STATE AS DOOR_STTS_CD, \r\n"
  1741. " DECODE(CONN_STATE, 'CMS0', '0', '1') AS COMM, \r\n"
  1742. " DECODE(DOOR_STATE, 'CDS0', '0', 'CDS1', '1', '0') AS DOOR, \r\n"
  1743. " 0 AS CBOX_TMPR, \r\n"
  1744. " UPDATE_DT AS STS00, \r\n"
  1745. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1746. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1747. " FROM VW_SIG_CTLR_STATUS \r\n"
  1748. #endif
  1749. #ifdef USE_SIGDET
  1750. "UNION \r\n"
  1751. "SELECT 'LVD' AS FAC_TYPE, FCLT_ID AS FAC_ID, \r\n"
  1752. " DECODE(DISCONN_STATE, 'STS0', 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1753. " 'CDS0' AS DOOR_STTS_CD, \r\n"
  1754. " DECODE(DISCONN_STATE, 'STS0', '0', '1') AS COMM, \r\n"
  1755. " '0' AS DOOR, 0 AS CBOX_TMPR \r\n"
  1756. " FROM VW_SIG_LVDS_STATUS \r\n"
  1757. #endif
  1758. #ifdef USE_PVMS
  1759. "UNION \r\n"
  1760. "SELECT 'PVMS' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, \r\n"
  1761. " DECODE(COMM_STATE, 0, 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1762. " DECODE(DOOR_STATE, 0, 'CDS0', 'CDS1') AS DOOR_STTS_CD, \r\n"
  1763. " DECODE(COMM_STATE, 0, '0', '1') AS COMM, '0' AS DOOR, \r\n"
  1764. " 0 AS CBOX_TMPR, \r\n"
  1765. " UPDATE_DT AS STS00, \r\n"
  1766. " '0' AS STS01, \r\n"
  1767. " TO_CHAR(POWER_STATE) AS STS02, \r\n"
  1768. " TO_CHAR(MODULE_STATE) AS STS03, \r\n"
  1769. " TO_CHAR(FAN_STATE) AS STS04, \r\n"
  1770. " TO_CHAR(HEATER_STATE) AS STS05, \r\n"
  1771. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1772. " FROM VW_PIS_VMS_STATUS \r\n"
  1773. #endif
  1774. #ifdef USE_PVDS
  1775. "UNION \r\n"
  1776. "SELECT 'PVMS' AS FAC_TYPE, TO_CHAR(FCLT_ID) AS FAC_ID, \r\n"
  1777. " DECODE(COMM_STATE, '0', 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1778. " 'CDS0' AS DOOR_STTS_CD, \r\n"
  1779. " DECODE(COMM_STATE, '0', '0', '1') AS COMM, '0' AS DOOR, \r\n"
  1780. " 0 AS CBOX_TMPR, \r\n"
  1781. " UPDATE_DT AS STS00, \r\n"
  1782. " TO_CHAR(CONT_STATE) AS STS01, \r\n"
  1783. " '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1784. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1785. " FROM VW_PIS_CONT_STATUS \r\n"
  1786. #endif
  1787. #ifdef USE_PARK
  1788. "UNION \r\n"
  1789. "SELECT 'PARK' AS FAC_TYPE, B.CTLR_MNGM_NMBR AS FAC_ID, \r\n"
  1790. " DECODE(CMNC_STTS_CD, 'CMS0', 'CMS0', 'CMS1') AS STTS_CD, \r\n"
  1791. " 'CDS0' AS DOOR_STTS_CD, \r\n"
  1792. " DECODE(CMNC_STTS_CD, 'CMS0', '0', 'CMS1', '1', '0') AS COMM, \r\n"
  1793. " '0' AS DOOR, \r\n"
  1794. " 0 AS CBOX_TMPR, \r\n"
  1795. " A.UPDT_DT AS STS00, \r\n"
  1796. " '0' AS STS01, '0' AS STS02, '0' AS STS03, '0' AS STS04, '0' AS STS05, \r\n"
  1797. " '0' AS STS06, '0' AS STS07, '0' AS STS08, '0' AS STS09, '0' AS STS10 \r\n"
  1798. " FROM TB_PRLT_CTLR_STTS A, TB_PRLT_CTLR B \r\n"
  1799. " WHERE A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  1800. " AND A.CTLR_MNGM_NMBR = B.CTLR_MNGM_NMBR \r\n"
  1801. #endif
  1802. ;
  1803. try
  1804. {
  1805. TItsFacility *pFacility = NULL;
  1806. FLists.Lock();
  1807. FOR_STL(TItsFacility*, pObj, ItsFacilityManager->FLists)
  1808. {
  1809. pObj->FCollCntBase = 0;
  1810. pObj->FCollCntCurr = 0;
  1811. //남양주에서 수집시간내에 조회되는것은 수집오류가 아니므로 초기에 수집오류로 설정
  1812. if (pObj->FCLT_TYPE == "VDS" ||
  1813. pObj->FCLT_TYPE == "AVI" ||
  1814. pObj->FCLT_TYPE == "DSRC")
  1815. {
  1816. pObj->FCollError = true;
  1817. }
  1818. else
  1819. {
  1820. pObj->FCollError = false;
  1821. }
  1822. pObj->FComm = state_error;
  1823. pObj->FDoor = "0";
  1824. pObj->FCommStatus = "CMS1";
  1825. pObj->FDoorStatus = "CDS0";
  1826. if (pObj->FCLT_TYPE == "CCTV" ||
  1827. pObj->FCLT_TYPE == "VMS" ||
  1828. pObj->FCLT_TYPE == "VDS" ||
  1829. pObj->FCLT_TYPE == "AVI")
  1830. {
  1831. pObj->FCBoxTmpr = "?";
  1832. }
  1833. else
  1834. {
  1835. pObj->FCBoxTmpr = "-";
  1836. }
  1837. }
  1838. //상태정보를 읽어오기전에 상태정보 통계데이터를 초기화한다.
  1839. FOR_STL(TFacilityStatus*, pStatus, ItsFacilityManager->FListStatus)
  1840. {
  1841. //pStatus->Total = 0; 전체 수량은 초기화하지 않는다.
  1842. pStatus->Normal = 0;
  1843. pStatus->Error = 0;
  1844. pStatus->Module = 0;
  1845. pStatus->Collect= 0;
  1846. }
  1847. try
  1848. {
  1849. int nORD;
  1850. pADO = new TADOQuery(NULL);
  1851. pADO->Close();
  1852. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1853. pADO->SQL->Clear();
  1854. pADO->SQL->Text = sQry;
  1855. pADO->Open();
  1856. //int nRows = pADO->RecordCount;
  1857. for( ; !pADO->Eof; pADO->Next())
  1858. {
  1859. String sId = pADO->FieldByName("FAC_ID")->AsString;
  1860. pFacility = ItsFacilityManager->FLists.Find(sId);
  1861. if (!pFacility) continue;
  1862. pFacility->FCommStatus = pADO->FieldByName("STTS_CD")->AsString;
  1863. pFacility->FDoorStatus = pADO->FieldByName("DOOR_STTS_CD")->AsString;
  1864. pFacility->FComm = pADO->FieldByName("COMM")->AsString;
  1865. pFacility->FDoor = pADO->FieldByName("DOOR")->AsString;
  1866. pFacility->Sts00 = pADO->FieldByName("STS00")->AsString;
  1867. pFacility->Sts01 = pADO->FieldByName("STS01")->AsString;
  1868. pFacility->Sts02 = pADO->FieldByName("STS02")->AsString;
  1869. pFacility->Sts03 = pADO->FieldByName("STS03")->AsString;
  1870. pFacility->Sts04 = pADO->FieldByName("STS04")->AsString;
  1871. pFacility->Sts05 = pADO->FieldByName("STS05")->AsString;
  1872. pFacility->Sts06 = pADO->FieldByName("STS06")->AsString;
  1873. pFacility->Sts07 = pADO->FieldByName("STS07")->AsString;
  1874. pFacility->Sts08 = pADO->FieldByName("STS08")->AsString;
  1875. pFacility->Sts09 = pADO->FieldByName("STS09")->AsString;
  1876. pFacility->Sts10 = pADO->FieldByName("STS10")->AsString;
  1877. if (pFacility->FCLT_TYPE == "CCTV" ||
  1878. pFacility->FCLT_TYPE == "VMS" ||
  1879. pFacility->FCLT_TYPE == "VDS" ||
  1880. pFacility->FCLT_TYPE == "AVI")
  1881. {
  1882. pFacility->FCBoxTmpr = pADO->FieldByName("CBOX_TMPR")->AsString;
  1883. }
  1884. if (pFacility->FComm == state_normal)
  1885. {
  1886. //통신이 정상인데 함체문이 열려있으면 모듈이상으로 처리
  1887. #if 0
  1888. if (pFacility->FDoor == "1")
  1889. pFacility->FComm = state_module; //모듈이상(함체문 열림)
  1890. #endif
  1891. }
  1892. }
  1893. //수집데이터를 처리하구 수집오류=false로 설정함
  1894. #ifdef USE_DSRC
  1895. LoadDsrcCollectStatusFromDb(ADbConn);
  1896. #endif
  1897. #ifdef USE_VDS
  1898. LoadVdsCollectStatusFromDb(ADbConn);
  1899. #endif
  1900. #ifdef USE_AVI
  1901. LoadAviCollectStatusFromDb(ADbConn);
  1902. #endif
  1903. }
  1904. catch(EDatabaseError &E)
  1905. {
  1906. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1907. DBERRORLOG("TItsFacilityManager::LoadFacilityStatusFromDb", String(E.ClassName()), E.Message, sQry);
  1908. return false;
  1909. throw Exception(String(E.ClassName()) + E.Message);
  1910. }
  1911. catch(Exception &exception)
  1912. {
  1913. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1914. DBERRORLOG("TItsFacilityManager::LoadFacilityStatusFromDb", String(exception.ClassName()), exception.Message, sQry);
  1915. return false;
  1916. throw Exception(String(exception.ClassName()) + exception.Message);
  1917. }
  1918. }
  1919. __finally
  1920. {
  1921. // 상태정보를 최종 체크한다.
  1922. TFacilityStatus *pStatus;
  1923. FOR_STL(TItsFacility*, pTmpObj, ItsFacilityManager->FLists)
  1924. {
  1925. pStatus = ItsFacilityManager->FListStatus.Find(pTmpObj->FCLT_TYPE);
  1926. if (!pStatus) continue;
  1927. if (pTmpObj->FComm == state_error) pStatus->Error++;
  1928. else if (pTmpObj->FComm == state_module) pStatus->Module++;
  1929. if (pTmpObj->FComm != state_error)
  1930. {
  1931. //통신이상이 아닌 경우 수집이상인 경우 수집이상 갯수를 증가시킨다.
  1932. if (pTmpObj->FCollError)
  1933. {
  1934. pStatus->Collect++;
  1935. pTmpObj->FComm = state_collect;
  1936. }
  1937. }
  1938. }
  1939. if (pADO)
  1940. {
  1941. pADO->Close();
  1942. delete pADO;
  1943. }
  1944. FLists.UnLock();
  1945. }
  1946. return bResult;
  1947. }
  1948. //---------------------------------------------------------------------------
  1949. bool TItsFacilityManager::LoadDsrcCollectStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  1950. {
  1951. String sQry;
  1952. TADOQuery *pADO = NULL;
  1953. #ifndef USE_DSRC
  1954. return true;
  1955. #endif
  1956. sQry = "SELECT DISTINCT B.RSE_ID \r\n"
  1957. " FROM TB_RSE_OBU_CLCT_PNST A, \r\n"
  1958. " TB_RSE_MSTR B \r\n"
  1959. " WHERE A.CLCT_DT > TO_CHAR(SYSDATE-1/24, 'YYYYMMDDHH24MISS') \r\n"
  1960. " AND A.ID = B.ID \r\n";
  1961. try
  1962. {
  1963. TItsFacility *pFacility = NULL;
  1964. try
  1965. {
  1966. int nORD;
  1967. pADO = new TADOQuery(NULL);
  1968. pADO->Close();
  1969. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1970. pADO->SQL->Clear();
  1971. pADO->SQL->Text = sQry;
  1972. pADO->Open();
  1973. for( ; !pADO->Eof; pADO->Next())
  1974. {
  1975. String sRseId = pADO->FieldByName("RSE_ID")->AsString;
  1976. pFacility = ItsFacilityManager->FLists.Find(sRseId);
  1977. if (!pFacility) continue;
  1978. pFacility->FCollError = false;
  1979. }
  1980. }
  1981. catch(EDatabaseError &E)
  1982. {
  1983. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1984. DBERRORLOG("TItsFacilityManager::LoadDsrcCollectStatusFromDb", String(E.ClassName()), E.Message, sQry);
  1985. throw Exception(String(E.ClassName()) + E.Message);
  1986. }
  1987. catch(Exception &exception)
  1988. {
  1989. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1990. DBERRORLOG("TItsFacilityManager::LoadDsrcCollectStatusFromDb", String(exception.ClassName()), exception.Message, sQry);
  1991. throw Exception(String(exception.ClassName()) + exception.Message);
  1992. }
  1993. }
  1994. __finally
  1995. {
  1996. if (pADO)
  1997. {
  1998. pADO->Close();
  1999. delete pADO;
  2000. }
  2001. }
  2002. return true;
  2003. }
  2004. //---------------------------------------------------------------------------
  2005. bool TItsFacilityManager::LoadVdsCollectStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  2006. {
  2007. String sQry;
  2008. TADOQuery *pADO = NULL;
  2009. #ifndef USE_VDS
  2010. return true;
  2011. #endif
  2012. sQry = "SELECT DISTINCT C.VDS_CTLR_ID AS VDS_CTLR_ID \r\n"
  2013. " FROM TB_VDS_DTCT_RAW_PNST A, \r\n"
  2014. " TB_VDS_DTCT_MSTR B, \r\n"
  2015. " TB_VDS_CTLR C \r\n"
  2016. " WHERE A.OCRR_DT > TO_CHAR(SYSDATE-1/24, 'YYYYMMDDHH24MISS') \r\n"
  2017. " AND A.DTCT_NMBR = B.DTCT_NMBR \r\n"
  2018. " AND B.CTLR_MNGM_NMBR = C.CTLR_MNGM_NMBR \r\n";
  2019. try
  2020. {
  2021. TItsFacility *pFacility = NULL;
  2022. try
  2023. {
  2024. int nORD;
  2025. pADO = new TADOQuery(NULL);
  2026. pADO->Close();
  2027. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  2028. pADO->SQL->Clear();
  2029. pADO->SQL->Text = sQry;
  2030. pADO->Open();
  2031. pADO->First();
  2032. for( ; !pADO->Eof; pADO->Next())
  2033. {
  2034. String sVdsId = pADO->FieldByName("VDS_CTLR_ID")->AsString;
  2035. pFacility = ItsFacilityManager->FLists.Find(sVdsId);
  2036. if (!pFacility) continue;
  2037. pFacility->FCollError = false;
  2038. }
  2039. }
  2040. catch(EDatabaseError &E)
  2041. {
  2042. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2043. DBERRORLOG("TItsFacilityManager::LoadVdsCollectStatusFromDb", String(E.ClassName()), E.Message, sQry);
  2044. throw Exception(String(E.ClassName()) + E.Message);
  2045. }
  2046. catch(Exception &exception)
  2047. {
  2048. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2049. DBERRORLOG("TItsFacilityManager::LoadVdsCollectStatusFromDb", String(exception.ClassName()), exception.Message, sQry);
  2050. throw Exception(String(exception.ClassName()) + exception.Message);
  2051. }
  2052. }
  2053. __finally
  2054. {
  2055. if (pADO)
  2056. {
  2057. pADO->Close();
  2058. delete pADO;
  2059. }
  2060. }
  2061. return true;
  2062. }
  2063. //---------------------------------------------------------------------------
  2064. bool TItsFacilityManager::LoadAviCollectStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  2065. {
  2066. String sQry;
  2067. TADOQuery *pADO = NULL;
  2068. #ifndef USE_AVI
  2069. return true;
  2070. #endif
  2071. sQry = "SELECT A.AVI_CTLR_MNGM_NMBR, B.AVI_ID \r\n"
  2072. " FROM TB_AVI_PASS_VHCL_PNST A, \r\n"
  2073. " TB_AVI_CTLR B \r\n"
  2074. " WHERE A.CRTN_DT > TO_CHAR(SYSDATE-1/24, 'YYYYMMDDHH24MISS') \r\n"
  2075. " AND A.AVI_CTLR_MNGM_NMBR = B.AVI_CTLR_MNGM_NMBR \r\n";
  2076. try
  2077. {
  2078. TItsFacility *pFacility = NULL;
  2079. try
  2080. {
  2081. int nORD;
  2082. pADO = new TADOQuery(NULL);
  2083. pADO->Close();
  2084. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  2085. pADO->SQL->Clear();
  2086. pADO->SQL->Text = sQry;
  2087. pADO->Open();
  2088. pADO->First();
  2089. for( ; !pADO->Eof; pADO->Next())
  2090. {
  2091. String sAviId = pADO->FieldByName("AVI_ID")->AsString;
  2092. pFacility = ItsFacilityManager->FLists.Find(sAviId);
  2093. if (!pFacility) continue;
  2094. pFacility->FCollError = false;
  2095. }
  2096. }
  2097. catch(EDatabaseError &E)
  2098. {
  2099. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2100. DBERRORLOG("TItsFacilityManager::LoadAviCollectStatusFromDb", String(E.ClassName()), E.Message, sQry);
  2101. throw Exception(String(E.ClassName()) + E.Message);
  2102. }
  2103. catch(Exception &exception)
  2104. {
  2105. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2106. DBERRORLOG("TItsFacilityManager::LoadAviCollectStatusFromDb", String(exception.ClassName()), exception.Message, sQry);
  2107. throw Exception(String(exception.ClassName()) + exception.Message);
  2108. }
  2109. }
  2110. __finally
  2111. {
  2112. if (pADO)
  2113. {
  2114. pADO->Close();
  2115. delete pADO;
  2116. }
  2117. }
  2118. return true;
  2119. }
  2120. //---------------------------------------------------------------------------
  2121. bool TItsFacilityManager::LoadDsrcCollectStatusFromDb_OLD(TADOConnection *ADbConn/*=NULL*/)
  2122. {
  2123. String sQry;
  2124. TADOQuery *pADO = NULL;
  2125. #ifndef USE_DSRC
  2126. return true;
  2127. #endif
  2128. sQry = "SELECT X.ID, X.RSE_ID, X.CLCT_ABNR_BASI, \r\n"
  2129. " Y.STAT_DT, NVL(Y.CLCT_NUM, 0) AS CLCT_NUM \r\n"
  2130. " FROM (SELECT M.ID, M.RSE_ID, M.CLCT_ABNR_BASI \r\n"
  2131. " FROM TB_RSE_MSTR M \r\n"
  2132. " WHERE M.DEL_YN <> 'Y' \r\n"
  2133. " ) X, \r\n"
  2134. " (SELECT P.ID, P.STAT_DT, P.CLCT_NUM \r\n"
  2135. " FROM TB_RSE_OBU_CLCT_HH_PNST P \r\n"
  2136. " WHERE P.STAT_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n"
  2137. " ) Y \r\n"
  2138. " WHERE X.ID = Y.ID(+) \r\n";
  2139. #if 0
  2140. sQry = "SELECT X.ID, X.RSE_ID, X.CLCT_ABNR_BASI, \r\n"
  2141. " Y.STAT_DT, NVL(Y.CLCT_NUM, 0) AS CLCT_NUM \r\n"
  2142. " FROM (SELECT M.ID, M.RSE_ID, M.CLCT_ABNR_BASI \r\n"
  2143. " FROM TB_RSE_MSTR M \r\n"
  2144. " WHERE M.DEL_YN <> 'Y' \r\n"
  2145. " ) X, \r\n"
  2146. " (SELECT ID, STAT_DT, CLCT_NUM \r\n"
  2147. " FROM TB_RSE_OBU_CLCT_HH_PNST \r\n"
  2148. " WHERE (ID, STAT_DT) IN (SELECT P.ID, MAX(P.STAT_DT) \r\n"
  2149. " FROM TB_RSE_OBU_CLCT_HH_PNST P \r\n"
  2150. " WHERE P.STAT_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n"
  2151. " GROUP BY P.ID) \r\n"
  2152. " ) Y \r\n"
  2153. " WHERE X.ID = Y.ID(+) \r\n";
  2154. #endif
  2155. try
  2156. {
  2157. TItsFacility *pFacility = NULL;
  2158. try
  2159. {
  2160. int nORD;
  2161. pADO = new TADOQuery(NULL);
  2162. pADO->Close();
  2163. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  2164. pADO->SQL->Clear();
  2165. pADO->SQL->Text = sQry;
  2166. pADO->Open();
  2167. //int nRows = pADO->RecordCount;
  2168. for( ; !pADO->Eof; pADO->Next())
  2169. {
  2170. String sId = pADO->FieldByName("RSE_ID")->AsString;
  2171. pFacility = ItsFacilityManager->FLists.Find(sId);
  2172. if (!pFacility) continue;
  2173. pFacility->FCollCntBase = pADO->FieldByName("CLCT_ABNR_BASI")->AsInteger;
  2174. pFacility->FCollCntCurr = pADO->FieldByName("CLCT_NUM")->AsInteger;
  2175. }
  2176. }
  2177. catch(EDatabaseError &E)
  2178. {
  2179. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2180. DBERRORLOG("TItsFacilityManager::LoadDsrcCollectStatusFromDb_OLD", String(E.ClassName()), E.Message, sQry);
  2181. throw Exception(String(E.ClassName()) + E.Message);
  2182. }
  2183. catch(Exception &exception)
  2184. {
  2185. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2186. DBERRORLOG("TItsFacilityManager::LoadDsrcCollectStatusFromDb_OLD", String(exception.ClassName()), exception.Message, sQry);
  2187. throw Exception(String(exception.ClassName()) + exception.Message);
  2188. }
  2189. }
  2190. __finally
  2191. {
  2192. if (pADO)
  2193. {
  2194. pADO->Close();
  2195. delete pADO;
  2196. }
  2197. }
  2198. return true;
  2199. }
  2200. //---------------------------------------------------------------------------
  2201. bool TItsFacilityManager::LoadVdsCollectStatusFromDb_OLD(TADOConnection *ADbConn/*=NULL*/)
  2202. {
  2203. String sQry;
  2204. TADOQuery *pADO = NULL;
  2205. #ifndef USE_VDS
  2206. return true;
  2207. #endif
  2208. #if 1
  2209. sQry = "SELECT A.CTLR_MNGM_NMBR, A.VDS_CTLR_ID, NVL(B.COLCNT, 0) AS COLCNT \r\n"
  2210. " FROM TB_VDS_CTLR A, \r\n"
  2211. " (SELECT A.CTLR_MNGM_NMBR, MAX(B.OCRR_DT) AS OCRR_DT, COUNT(1) AS COLCNT \r\n"
  2212. " FROM TB_VDS_DTCT_MSTR A, TB_VDS_DTCT_RAW_PNST B \r\n"
  2213. " WHERE A.DTCT_NMBR = B.DTCT_NMBR \r\n"
  2214. " AND B.OCRR_DT >= TO_CHAR(SYSDATE-10/1440, 'YYYYMMDDHH24MISS') \r\n"
  2215. " GROUP BY A.CTLR_MNGM_NMBR ) B \r\n"
  2216. " WHERE A.DEL_YN = 'N' \r\n"
  2217. " AND A.CTLR_MNGM_NMBR = B.CTLR_MNGM_NMBR(+) \r\n";
  2218. #else
  2219. sQry = "SELECT CTLR_NMBR AS CTLR_MNGM_NMBR, CTLR_ID AS VDS_CTLR_ID, COLCNT \r\n"
  2220. " FROM (SELECT A.CTLR_MNGM_NMBR AS CTLR_NMBR, A.VDS_CTLR_ID AS CTLR_ID, A.LCTN AS CTLR_NM, \r\n"
  2221. " NVL(C.UPDT_DT, '-') AS UPDT_DT, NVL(C.CMNC_STTS_CD, 'CMS1') AS COMM_CD, \r\n"
  2222. " NVL(C.COLCNT, 0) AS COLCNT, NVL(B.COMMERRCNT, 0) AS COMMERRCNT \r\n"
  2223. " FROM TB_VDS_CTLR A, \r\n"
  2224. " (SELECT CTLR_MNGM_NMBR, COUNT(1) AS COMMERRCNT \r\n"
  2225. " FROM TB_VDS_CTLR_STTS_RAW \r\n"
  2226. " WHERE 1=1 \r\n"
  2227. " AND CMNC_STTS_CD <> 'CMS0' \r\n"
  2228. " AND OCRR_DT >= TO_CHAR(TRUNC(SYSDATE), 'YYYYMMDD') || '000000' \r\n"
  2229. " GROUP BY CTLR_MNGM_NMBR \r\n"
  2230. " ) B, \r\n"
  2231. " (SELECT X.CTLR_MNGM_NMBR, X.UPDT_DT, X.CMNC_STTS_CD, NVL(Y.COLCNT, 0) AS COLCNT \r\n"
  2232. " FROM TB_VDS_CTLR_STTS X, \r\n"
  2233. " (SELECT A.CTLR_MNGM_NMBR, COUNT(1) AS COLCNT \r\n"
  2234. " FROM TB_VDS_DTCT_MSTR A, TB_VDS_DTCT_RAW_PNST B \r\n"
  2235. " WHERE 1=1 \r\n"
  2236. " AND A.DTCT_NMBR = B.DTCT_NMBR \r\n"
  2237. " AND B.OCRR_DT >= TO_CHAR(SYSDATE-10/1440, 'YYYYMMDDHH24MISS') \r\n"
  2238. " GROUP BY A.CTLR_MNGM_NMBR ) Y \r\n"
  2239. " WHERE 1=1 \r\n"
  2240. " AND X.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n"
  2241. " AND X.CTLR_MNGM_NMBR = Y.CTLR_MNGM_NMBR(+) \r\n"
  2242. " ) C \r\n"
  2243. " WHERE 1=1 \r\n"
  2244. " AND A.DEL_YN = 'N' \r\n"
  2245. " AND A.CTLR_MNGM_NMBR = B.CTLR_MNGM_NMBR(+) \r\n"
  2246. " AND A.CTLR_MNGM_NMBR = C.CTLR_MNGM_NMBR(+) \r\n"
  2247. " ) \r\n"
  2248. " WHERE 1=1 \r\n"
  2249. " AND (COMM_CD = 'CMS0' AND COLCNT = 0) \r\n";
  2250. #endif
  2251. try
  2252. {
  2253. TItsFacility *pFacility = NULL;
  2254. try
  2255. {
  2256. int nORD;
  2257. pADO = new TADOQuery(NULL);
  2258. pADO->Close();
  2259. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  2260. pADO->SQL->Clear();
  2261. pADO->SQL->Text = sQry;
  2262. pADO->Open();
  2263. pADO->First();
  2264. String sVdsId;
  2265. int nColCnt;
  2266. for( ; !pADO->Eof; pADO->Next())
  2267. {
  2268. sVdsId = pADO->FieldByName("VDS_CTLR_ID")->AsString;
  2269. pFacility = ItsFacilityManager->FLists.Find(sVdsId);
  2270. if (!pFacility)
  2271. {
  2272. continue;
  2273. }
  2274. nColCnt = pADO->FieldByName("COLCNT")->AsInteger;
  2275. if (nColCnt == 0)
  2276. {
  2277. if (pFacility->FComm != state_error)
  2278. {
  2279. pFacility->FCollError = true;
  2280. }
  2281. }
  2282. }
  2283. }
  2284. catch(EDatabaseError &E)
  2285. {
  2286. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2287. DBERRORLOG("TItsFacilityManager::LoadVdsCollectStatusFromDb_OLD", String(E.ClassName()), E.Message, sQry);
  2288. throw Exception(String(E.ClassName()) + E.Message);
  2289. }
  2290. catch(Exception &exception)
  2291. {
  2292. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2293. DBERRORLOG("TItsFacilityManager::LoadVdsCollectStatusFromDb_OLD", String(exception.ClassName()), exception.Message, sQry);
  2294. throw Exception(String(exception.ClassName()) + exception.Message);
  2295. }
  2296. }
  2297. __finally
  2298. {
  2299. if (pADO)
  2300. {
  2301. pADO->Close();
  2302. delete pADO;
  2303. }
  2304. }
  2305. return true;
  2306. }
  2307. //---------------------------------------------------------------------------
  2308. bool TItsFacilityManager::LoadAviCollectStatusFromDb_OLD(TADOConnection *ADbConn/*=NULL*/)
  2309. {
  2310. String sQry;
  2311. TADOQuery *pADO = NULL;
  2312. #ifndef USE_AVI
  2313. return true;
  2314. #endif
  2315. sQry = "SELECT A.AVI_CTLR_MNGM_NMBR, A.AVI_ID, NVL(B.COLCNT, 0) AS COLCNT \r\n"
  2316. " FROM TB_AVI_CTLR A, \r\n"
  2317. " (SELECT AVI_CTLR_MNGM_NMBR, MAX(CRTN_DT) AS CRTN_DT, COUNT(1) AS COLCNT \r\n"
  2318. " FROM TB_AVI_PASS_VHCL_PNST \r\n"
  2319. " WHERE CRTN_DT >= TO_CHAR(SYSDATE-10/1440, 'YYYYMMDDHH24MISS') \r\n"
  2320. " GROUP BY AVI_CTLR_MNGM_NMBR ) B \r\n"
  2321. " WHERE A.DEL_YN = 'N' \r\n"
  2322. " AND A.AVI_CTLR_MNGM_NMBR = B.AVI_CTLR_MNGM_NMBR(+) \r\n";
  2323. try
  2324. {
  2325. TItsFacility *pFacility = NULL;
  2326. try
  2327. {
  2328. int nORD;
  2329. pADO = new TADOQuery(NULL);
  2330. pADO->Close();
  2331. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  2332. pADO->SQL->Clear();
  2333. pADO->SQL->Text = sQry;
  2334. pADO->Open();
  2335. pADO->First();
  2336. String sAviId;
  2337. int nColCnt;
  2338. for( ; !pADO->Eof; pADO->Next())
  2339. {
  2340. sAviId = pADO->FieldByName("AVI_ID")->AsString;
  2341. pFacility = ItsFacilityManager->FLists.Find(sAviId);
  2342. if (!pFacility)
  2343. {
  2344. continue;
  2345. }
  2346. nColCnt = pADO->FieldByName("COLCNT")->AsInteger;
  2347. if (nColCnt == 0)
  2348. {
  2349. if (pFacility->FComm != state_error)
  2350. {
  2351. pFacility->FCollError = true;
  2352. }
  2353. }
  2354. }
  2355. }
  2356. catch(EDatabaseError &E)
  2357. {
  2358. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2359. DBERRORLOG("TItsFacilityManager::LoadAviCollectStatusFromDb_OLD", String(E.ClassName()), E.Message, sQry);
  2360. throw Exception(String(E.ClassName()) + E.Message);
  2361. }
  2362. catch(Exception &exception)
  2363. {
  2364. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  2365. DBERRORLOG("TItsFacilityManager::LoadAviCollectStatusFromDb_OLD", String(exception.ClassName()), exception.Message, sQry);
  2366. throw Exception(String(exception.ClassName()) + exception.Message);
  2367. }
  2368. }
  2369. __finally
  2370. {
  2371. if (pADO)
  2372. {
  2373. pADO->Close();
  2374. delete pADO;
  2375. }
  2376. }
  2377. return true;
  2378. }
  2379. //---------------------------------------------------------------------------