CDSVdsCtlrF.cpp 57 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSVdsCtlrF.h"
  4. #include "ITSDbF.h"
  5. #include "AppGlobalF.h"
  6. //---------------------------------------------------------------------------
  7. #pragma package(smart_init)
  8. TVdsDtctLink::TVdsDtctLink()
  9. {
  10. FCompleted = false;
  11. FEditMode = DB_INIT;
  12. FGridIndex = -1;
  13. MEM_DEL = "N";
  14. }
  15. //---------------------------------------------------------------------------
  16. TVdsDtctLink::~TVdsDtctLink()
  17. {
  18. }
  19. //---------------------------------------------------------------------------
  20. TVdsDtct::TVdsDtct()
  21. {
  22. FCompleted = false;
  23. FEditMode = DB_INIT;
  24. FGridIndex = -1;
  25. MEM_DEL = "N";
  26. //Clear();
  27. }
  28. //---------------------------------------------------------------------------
  29. TVdsDtct::~TVdsDtct()
  30. {
  31. }
  32. //---------------------------------------------------------------------------
  33. TVdsCtlr::TVdsCtlr()
  34. {
  35. }
  36. //---------------------------------------------------------------------------
  37. TVdsCtlr::~TVdsCtlr()
  38. {
  39. }
  40. //---------------------------------------------------------------------------
  41. //---------------------------------------------------------------------------
  42. TVdsCtlrManager *VdsCtlrManager = NULL;
  43. //---------------------------------------------------------------------------
  44. /*
  45. * Vds Manager
  46. */
  47. TVdsCtlrManager::TVdsCtlrManager()
  48. {
  49. }
  50. //---------------------------------------------------------------------------
  51. TVdsCtlrManager::~TVdsCtlrManager()
  52. {
  53. FLists.RemoveAll();
  54. }
  55. //---------------------------------------------------------------------------
  56. bool TVdsCtlrManager::LoadFromDbVdsLink(TADOConnection *ADbConn/*=NULL*/)
  57. {
  58. String sQry;
  59. TADOQuery *pADO = NULL;
  60. sQry = "SELECT A.LINK_ID, C.NODE_NAME AS STR_NAME, D.NODE_NAME AS END_NAME, \r\n"
  61. " F.VDS_CTLR_NMBR, F.VDS_NM \r\n"
  62. " FROM TB_VDS_DTCT_RLTN_LINK A, \r\n"
  63. " TB_LINK B, \r\n"
  64. " TB_NODE C, \r\n"
  65. " TB_NODE D, \r\n"
  66. " TB_VDS_DTCT E, \r\n"
  67. " TB_VDS_CTLR F \r\n"
  68. " WHERE A.LINK_ID = B.LINK_ID \r\n"
  69. " AND B.F_NODE_ID = C.NODE_ID \r\n"
  70. " AND B.T_NODE_ID = D.NODE_ID \r\n"
  71. " AND A.VDS_DTCT_NMBR = E.VDS_DTCT_NMBR \r\n"
  72. " AND E.VDS_CTLR_NMBR = F.VDS_CTLR_NMBR \r\n"
  73. " AND F.VDS_TYPE_CD = 'I' \r\n"
  74. " GROUP BY A.LINK_ID, C.NODE_NAME, D.NODE_NAME, F.VDS_CTLR_NMBR, F.VDS_NM \r\n";
  75. // " ORDER BY F.VDS_CTLR_NMBR, A.LINK_ID \r\n";
  76. try
  77. {
  78. FLinkSelCnt = 0;
  79. FLinkLists.Lock();
  80. FLinkLists.RemoveAll();
  81. try
  82. {
  83. pADO = new TADOQuery(NULL);
  84. pADO->Close();
  85. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  86. pADO->SQL->Clear();
  87. pADO->SQL->Text = sQry;
  88. pADO->Prepared = true;
  89. pADO->Open();
  90. for( ; !pADO->Eof; pADO->Next())
  91. {
  92. TVdsLink *pObj = new TVdsLink();
  93. pObj->VDS_CTLR_NMBR = pADO->FieldByName("VDS_CTLR_NMBR")->AsString;
  94. pObj->VDS_NM = pADO->FieldByName("VDS_NM")->AsString;
  95. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
  96. pObj->STR_NAME = pADO->FieldByName("STR_NAME")->AsString;
  97. pObj->END_NAME = pADO->FieldByName("END_NAME")->AsString;
  98. pObj->IsSelected = true;
  99. FLinkSelCnt++;
  100. FLinkLists.Push(pObj->LINK_ID, pObj);
  101. }
  102. }
  103. catch(EDatabaseError &E)
  104. {
  105. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  106. DBERRORMSG("TItsAtrdManager::LoadFromDbAtrdName", String(E.ClassName()), E.Message, sQry);
  107. throw Exception(String(E.ClassName()) + E.Message);
  108. }
  109. catch(Exception &exception)
  110. {
  111. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  112. DBERRORMSG("TItsAtrdManager::LoadFromDbAtrdName", String(exception.ClassName()), exception.Message, sQry);
  113. throw Exception(String(exception.ClassName()) + exception.Message);
  114. }
  115. }
  116. __finally
  117. {
  118. if (pADO)
  119. {
  120. pADO->Close();
  121. delete pADO;
  122. }
  123. FLinkLists.UnLock();
  124. }
  125. return true;
  126. }
  127. //---------------------------------------------------------------------------
  128. bool TVdsCtlrManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
  129. {
  130. String sQry;
  131. TADOQuery *pADO = NULL;
  132. sQry = "SELECT * \r\n"
  133. " FROM TB_VDS_CTLR \r\n"
  134. " WHERE DEL_YN = 'N' \r\n";
  135. FLists.Lock();
  136. try
  137. {
  138. FLists.RemoveAll();
  139. try
  140. {
  141. pADO = new TADOQuery(NULL);
  142. pADO->Close();
  143. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  144. pADO->SQL->Clear();
  145. pADO->SQL->Text = sQry;
  146. pADO->Prepared = true;
  147. pADO->Open();
  148. for( ; !pADO->Eof; pADO->Next())
  149. {
  150. TVdsCtlr *pObj = new TVdsCtlr();
  151. pObj->VDS_CTLR_NMBR = pADO->FieldByName("VDS_CTLR_NMBR")->AsString;
  152. pObj->VDS_CTLR_ID = pADO->FieldByName("VDS_CTLR_ID")->AsString;
  153. pObj->VDS_NM = pADO->FieldByName("VDS_NM")->AsString;
  154. pObj->VDS_CTLR_IP = pADO->FieldByName("VDS_CTLR_IP")->AsString;
  155. pObj->VDS_CTLR_PORT = pADO->FieldByName("VDS_CTLR_PORT")->AsInteger;
  156. pObj->VDS_CTLR_LOCAL_NO = pADO->FieldByName("VDS_CTLR_LOCAL_NO")->AsInteger;
  157. pObj->VDS_TYPE_CD = pADO->FieldByName("VDS_TYPE_CD")->AsString;
  158. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString;
  159. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsFloat;
  160. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsFloat;
  161. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  162. pObj->GROUP_NO = pADO->FieldByName("GROUP_NO")->AsInteger;
  163. pObj->FAN_MODE = pADO->FieldByName("FAN_MODE")->AsInteger;
  164. pObj->FAN_RUN_TMPR = pADO->FieldByName("FAN_RUN_TMPR")->AsInteger;
  165. pObj->HETR_RUN_TMPR = pADO->FieldByName("HETR_RUN_TMPR")->AsInteger;
  166. pObj->DETECT_LANES = pADO->FieldByName("DETECT_LANES")->AsInteger;
  167. pObj->TRAF_CLCT_CYCL = pADO->FieldByName("TRAF_CLCT_CYCL")->AsInteger;
  168. pObj->STTS_CLCT_CYCL = pADO->FieldByName("STTS_CLCT_CYCL")->AsInteger;
  169. pObj->ISTL_LCTN_ADDR = pADO->FieldByName("ISTL_LCTN_ADDR")->AsString;
  170. pObj->MEM_DEL = "N";
  171. FLists.Push(pObj->VDS_CTLR_NMBR, pObj);
  172. pObj->Completed = true;
  173. pObj->MEM_DEL = "N";
  174. }
  175. }
  176. catch(EDatabaseError &E)
  177. {
  178. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  179. DBERRORMSG("TVdsCtlrManager::LoadFromDb", String(E.ClassName()), E.Message, sQry);
  180. throw Exception(String(E.ClassName()) + E.Message);
  181. }
  182. catch(Exception &exception)
  183. {
  184. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  185. DBERRORMSG("TVdsCtlrManager::LoadFromDb", String(exception.ClassName()), exception.Message, sQry);
  186. throw Exception(String(exception.ClassName()) + exception.Message);
  187. }
  188. }
  189. __finally
  190. {
  191. if (pADO)
  192. {
  193. pADO->Close();
  194. delete pADO;
  195. }
  196. FLists.UnLock();
  197. }
  198. return LoadFromCmraDb(ADbConn);
  199. }
  200. //---------------------------------------------------------------------------
  201. bool TVdsCtlrManager::LoadFromCmraDb(TADOConnection *ADbConn/*=NULL*/)
  202. {
  203. String sQry;
  204. TADOQuery *pADO = NULL;
  205. sQry = "SELECT * \r\n"
  206. " FROM TB_VDS_CMRA \r\n"
  207. " WHERE DEL_YN = 'N' \r\n";
  208. TVdsCtlr *pVds;
  209. FLists.Lock();
  210. try
  211. {
  212. try
  213. {
  214. pADO = new TADOQuery(NULL);
  215. pADO->Close();
  216. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  217. pADO->SQL->Clear();
  218. pADO->SQL->Text = sQry;
  219. pADO->Prepared = true;
  220. pADO->Open();
  221. for( ; !pADO->Eof; pADO->Next())
  222. {
  223. String VDS_CTLR_NMBR = pADO->FieldByName("VDS_CTLR_NMBR")->AsString;
  224. pVds = FLists.Find(VDS_CTLR_NMBR);
  225. if (!pVds) continue;
  226. TVdsCmra *pObj = new TVdsCmra();
  227. pObj->VDS_CTLR_NMBR = VDS_CTLR_NMBR;
  228. pObj->VDS_CMRA_NO = pADO->FieldByName("VDS_CMRA_NO")->AsInteger;
  229. pObj->VDS_CMRA_NM = pADO->FieldByName("VDS_CMRA_NM")->AsString.Trim();
  230. pObj->DETECT_LANE = pADO->FieldByName("DETECT_LANE")->AsInteger;
  231. pObj->CMRA_DRCT_CD = pADO->FieldByName("CMRA_DRCT_CD")->AsString.Trim();
  232. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString.Trim();
  233. pObj->CCAM_CTLR_NMBR = pADO->FieldByName("CCAM_CTLR_NMBR")->AsString.Trim();
  234. pObj->ROAD_NAME = pADO->FieldByName("ROAD_NAME")->AsString.Trim();
  235. pObj->CROSS_NAME = pADO->FieldByName("CROSS_NAME")->AsString.Trim();
  236. pObj->DIR_NAME = pADO->FieldByName("DIR_NAME")->AsString.Trim();
  237. pObj->VDS_CMRA_IP = pADO->FieldByName("VDS_CMRA_IP")->AsString.Trim();
  238. pVds->FCmras.Push(pObj->VDS_CMRA_NO, pObj);
  239. }
  240. }
  241. catch(EDatabaseError &E)
  242. {
  243. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  244. DBERRORMSG("TVdsCtlrManager::LoadFromCmraDb", String(E.ClassName()), E.Message, sQry);
  245. throw Exception(String(E.ClassName()) + E.Message);
  246. }
  247. catch(Exception &exception)
  248. {
  249. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  250. DBERRORMSG("TVdsCtlrManager::LoadFromCmraDb", String(exception.ClassName()), exception.Message, sQry);
  251. throw Exception(String(exception.ClassName()) + exception.Message);
  252. }
  253. }
  254. __finally
  255. {
  256. if (pADO)
  257. {
  258. pADO->Close();
  259. delete pADO;
  260. }
  261. FLists.UnLock();
  262. }
  263. return true;
  264. }
  265. //---------------------------------------------------------------------------
  266. bool TVdsCtlrManager::LoadFromDtctDb(TADOConnection *ADbConn/*=NULL*/)
  267. {
  268. String sQry;
  269. TADOQuery *pADO = NULL;
  270. sQry = "SELECT * \r\n"
  271. " FROM TB_VDS_DTCT \r\n";
  272. TVdsCtlr *pVds;
  273. FLists.Lock();
  274. try
  275. {
  276. try
  277. {
  278. pADO = new TADOQuery(NULL);
  279. pADO->Close();
  280. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  281. pADO->SQL->Clear();
  282. pADO->SQL->Text = sQry;
  283. pADO->Prepared = true;
  284. pADO->Open();
  285. for( ; !pADO->Eof; pADO->Next())
  286. {
  287. String VDS_CTLR_NMBR = pADO->FieldByName("VDS_CTLR_NMBR")->AsString;
  288. pVds = FLists.Find(VDS_CTLR_NMBR);
  289. if (!pVds) continue;
  290. TVdsDtct *pObj = new TVdsDtct();
  291. pObj->VDS_DTCT_NMBR = pADO->FieldByName("VDS_DTCT_NMBR")->AsString;
  292. pObj->VDS_DTCT_ID = pADO->FieldByName("VDS_DTCT_ID")->AsString;
  293. pObj->VDS_DTCT_NM = pADO->FieldByName("VDS_DTCT_NM")->AsString;
  294. pObj->VDS_CTLR_NMBR = pADO->FieldByName("VDS_CTLR_NMBR")->AsString;
  295. pObj->VDS_CMRA_NO = pADO->FieldByName("VDS_CMRA_NO")->AsInteger;
  296. pObj->DTCT_TYPE = pADO->FieldByName("DTCT_TYPE")->AsString;
  297. pObj->DTCT_DIR = pADO->FieldByName("DTCT_DIR")->AsString;
  298. pObj->DETECT_LANE = pADO->FieldByName("DETECT_LANE")->AsInteger;
  299. pObj->ISTL_LANE = pADO->FieldByName("ISTL_LANE")->AsInteger;
  300. pObj->SPED_CLCT_YN = pADO->FieldByName("SPED_CLCT_YN")->AsString;
  301. pObj->TFVL_CLCT_YN = pADO->FieldByName("TFVL_CLCT_YN")->AsString;
  302. pObj->OCPY_CLCT_YN = pADO->FieldByName("OCPY_CLCT_YN")->AsString;
  303. pObj->MAX_TFVL = pADO->FieldByName("MAX_TFVL")->AsInteger;
  304. pObj->MIN_TFVL = pADO->FieldByName("MIN_TFVL")->AsInteger;
  305. pObj->MAX_OCPY_RATE = pADO->FieldByName("MAX_OCPY_RATE")->AsFloat;
  306. pObj->MIN_OCPY_RATE = pADO->FieldByName("MIN_OCPY_RATE")->AsFloat;
  307. pObj->MAX_SPED = pADO->FieldByName("MAX_SPED")->AsInteger;
  308. pObj->MIN_SPED = pADO->FieldByName("MIN_SPED")->AsInteger;
  309. pObj->USE_YN = pADO->FieldByName("USE_YN")->AsString;
  310. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  311. pVds->FDtcts.Push(pObj->VDS_DTCT_NMBR, pObj);
  312. pObj->Completed = true;
  313. pObj->MEM_DEL = "N";
  314. }
  315. }
  316. catch(EDatabaseError &E)
  317. {
  318. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  319. DBERRORMSG("TVdsCtlrManager::LoadFromDtctDb", String(E.ClassName()), E.Message, sQry);
  320. throw Exception(String(E.ClassName()) + E.Message);
  321. }
  322. catch(Exception &exception)
  323. {
  324. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  325. DBERRORMSG("TVdsCtlrManager::LoadFromDtctDb", String(exception.ClassName()), exception.Message, sQry);
  326. throw Exception(String(exception.ClassName()) + exception.Message);
  327. }
  328. }
  329. __finally
  330. {
  331. if (pADO)
  332. {
  333. pADO->Close();
  334. delete pADO;
  335. }
  336. FLists.UnLock();
  337. }
  338. return true;
  339. }
  340. //---------------------------------------------------------------------------
  341. bool TVdsCtlrManager::LoadFromDtctLinkDb(TADOConnection *ADbConn/*=NULL*/)
  342. {
  343. String sQry;
  344. TADOQuery *pADO = NULL;
  345. sQry = "SELECT A.VDS_CTLR_NMBR, \r\n"
  346. " A.VDS_DTCT_NMBR, \r\n"
  347. " B.LINK_ID \r\n"
  348. " FROM TB_VDS_DTCT A, \r\n"
  349. " TB_VDS_DTCT_RLTN_LINK B \r\n"
  350. " WHERE A.VDS_DTCT_NMBR = B.VDS_DTCT_NMBR \r\n"
  351. " ORDER BY VDS_CTLR_NMBR \r\n";
  352. TVdsCtlr *pVds;
  353. TVdsDtct *pVdsDtct;
  354. FLists.Lock();
  355. try
  356. {
  357. try
  358. {
  359. pADO = new TADOQuery(NULL);
  360. pADO->Close();
  361. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  362. pADO->SQL->Clear();
  363. pADO->SQL->Text = sQry;
  364. pADO->Prepared = true;
  365. pADO->Open();
  366. for( ; !pADO->Eof; pADO->Next())
  367. {
  368. String VDS_CTLR_NMBR = pADO->FieldByName("VDS_CTLR_NMBR")->AsString;
  369. pVds = FLists.Find(VDS_CTLR_NMBR);
  370. if (!pVds) continue;
  371. String VDS_DTCT_NMBR = pADO->FieldByName("VDS_DTCT_NMBR")->AsString;
  372. pVdsDtct = pVds->FDtcts.Find(VDS_DTCT_NMBR);
  373. if (!pVdsDtct) continue;
  374. TVdsDtctLink *pObj = new TVdsDtctLink();
  375. pObj->VDS_CTLR_NMBR = VDS_CTLR_NMBR;
  376. pObj->VDS_DTCT_NMBR = VDS_DTCT_NMBR;
  377. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
  378. pVdsDtct->FLinks.Push(pObj->LINK_ID, pObj);
  379. pObj->Completed = true;
  380. pObj->MEM_DEL = "N";
  381. }
  382. }
  383. catch(EDatabaseError &E)
  384. {
  385. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  386. DBERRORMSG("TVdsCtlrManager::LoadFromDtctLinkDb", String(E.ClassName()), E.Message, sQry);
  387. throw Exception(String(E.ClassName()) + E.Message);
  388. }
  389. catch(Exception &exception)
  390. {
  391. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  392. DBERRORMSG("TVdsCtlrManager::LoadFromDtctLinkDb", String(exception.ClassName()), exception.Message, sQry);
  393. throw Exception(String(exception.ClassName()) + exception.Message);
  394. }
  395. }
  396. __finally
  397. {
  398. if (pADO)
  399. {
  400. pADO->Close();
  401. delete pADO;
  402. }
  403. FLists.UnLock();
  404. }
  405. return true;
  406. }
  407. //---------------------------------------------------------------------------
  408. bool TVdsCtlrManager::LoadStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  409. {
  410. String sQry;
  411. TADOQuery *pADO = NULL;
  412. sQry = "SELECT * \r\n"
  413. " FROM TB_VDS_CTLR_STTS A, TB_VDS_CTLR B \r\n"
  414. " WHERE A.VDS_CTLR_NMBR = B.VDS_CTLR_NMBR \r\n"
  415. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n";
  416. FLists.Lock();
  417. try
  418. {
  419. TVdsCtlr *pObj = NULL;
  420. try
  421. {
  422. pADO = new TADOQuery(NULL);
  423. pADO->Close();
  424. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  425. pADO->SQL->Clear();
  426. pADO->SQL->Text = sQry;
  427. pADO->Prepared = true;
  428. pADO->Open();
  429. //int nRows = pADO->RecordCount;
  430. for( ; !pADO->Eof; pADO->Next())
  431. {
  432. String sVmsNmbr = pADO->FieldByName("VDS_CTLR_NMBR")->AsString;
  433. pObj = FLists.Find(sVmsNmbr);
  434. if (!pObj) continue;
  435. String UPDT_DT = pADO->FieldByName("UPDT_DT")->AsString;
  436. String CONN_STTS_CD = pADO->FieldByName("CMNC_STTS_CD")->AsString;
  437. if (CONN_STTS_CD != "CMS0")
  438. {
  439. //통신장애
  440. continue;
  441. }
  442. #if 0
  443. pObj->STATE.Comm = vms_comm_normal;
  444. String CBOXDOOR_OPEN_STTS_CD = pADO->FieldByName("CBOX_DOOR_STTS_CD")->AsString;
  445. if (CBOXDOOR_OPEN_STTS_CD == "CDS0") pObj->STATE.DoorStatus = vms_door_close;
  446. else if (CBOXDOOR_OPEN_STTS_CD == "CDS1") pObj->STATE.DoorStatus = vms_door_open;
  447. String CBOXFAN_STTS_CD = pADO->FieldByName("FAN_STTS_CD")->AsString;
  448. if (CBOXFAN_STTS_CD == "MOS0") pObj->STATE.ModulePowerStatus = vms_module_power_on;
  449. else if (CBOXFAN_STTS_CD == "MOS1") pObj->STATE.ModulePowerStatus = vms_module_power_off;
  450. String CBOX_TMPR = pADO->FieldByName("CBOX_TMPR")->AsString;
  451. pObj->STATE.BodyTemp = CBOX_TMPR.ToIntDef(0);
  452. String CBOX_HMDT = pADO->FieldByName("BRGH_VAL")->AsString;
  453. pObj->STATE.LuminanceStatus = CBOX_HMDT.ToIntDef(0);
  454. String FAN_STTS_CD = pADO->FieldByName("FAN_STTS_CD")->AsString;
  455. if (FAN_STTS_CD == "PAS0") pObj->STATE.FanStatus = vms_fan_on;
  456. else if (FAN_STTS_CD == "PAS1") pObj->STATE.FanStatus = vms_fan_off;
  457. String HETR_STTS_CD = pADO->FieldByName("HETR_STTS_CD")->AsString;
  458. if (HETR_STTS_CD == "HTS0") pObj->STATE.HeaterStatus = vms_heater_on;
  459. else if (HETR_STTS_CD == "HTS1") pObj->STATE.HeaterStatus = vms_heater_off;
  460. String COMM_STTS_CD = pADO->FieldByName("COMM_STTS_CD")->AsString;
  461. if (COMM_STTS_CD == "CMS0") pObj->STATE.Wcomm = vms_wcomm_normal;
  462. else if (COMM_STTS_CD == "CMS1") pObj->STATE.Wcomm = vms_wcomm_error;
  463. #endif
  464. }
  465. }
  466. catch(EDatabaseError &E)
  467. {
  468. DBERRORMSG("TVdsCtlrManager::LoadStatusFromDb", String(E.ClassName()), E.Message, sQry);
  469. throw Exception(String(E.ClassName()) + E.Message);
  470. }
  471. catch(Exception &e)
  472. {
  473. DBERRORMSG("TVdsCtlrManager::LoadStatusFromDb", String(e.ClassName()), e.Message, sQry);
  474. throw Exception(String(e.ClassName()) + e.Message);
  475. }
  476. }
  477. __finally
  478. {
  479. if (pADO)
  480. {
  481. pADO->Close();
  482. delete pADO;
  483. }
  484. FLists.UnLock();
  485. }
  486. return true;
  487. }
  488. //---------------------------------------------------------------------------
  489. bool TVdsCtlrManager::GetNextVdsId(int &ANmbr, int &AId, TADOConnection *ADbConn/*=NULL*/)
  490. {
  491. String sQry;
  492. TADOQuery *pADO = NULL;
  493. sQry = "SELECT NVL(MAX(VDS_CTLR_NMBR), 10000) + 1 AS NEWID FROM TB_VDS_CTLR \r\n";
  494. try
  495. {
  496. try
  497. {
  498. pADO = new TADOQuery(NULL);
  499. pADO->Close();
  500. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  501. pADO->SQL->Clear();
  502. pADO->SQL->Text = sQry;
  503. pADO->Prepared = true;
  504. pADO->Open();
  505. ANmbr = pADO->FieldByName("NEWID")->AsInteger;
  506. AId = ANmbr / 10000;
  507. return true;
  508. }
  509. catch(EDatabaseError &E)
  510. {
  511. DBERRORLOG("TVdsCtlrManager::GetNextVdsId", String(E.ClassName()), E.Message, sQry);
  512. throw Exception(String(E.ClassName()) + E.Message);
  513. }
  514. catch(Exception &e)
  515. {
  516. DBERRORLOG("TVdsCtlrManager::GetNextVdsId", String(e.ClassName()), e.Message, sQry);
  517. throw Exception(String(e.ClassName()) + e.Message);
  518. }
  519. }
  520. __finally
  521. {
  522. if (pADO)
  523. {
  524. pADO->Close();
  525. delete pADO;
  526. }
  527. }
  528. return false;
  529. }
  530. //---------------------------------------------------------------------------
  531. bool TVdsCtlrManager::GetNextVdsDtctId(int &ANmbr, int &AId, TADOConnection *ADbConn/*=NULL*/)
  532. {
  533. String sQry;
  534. TADOQuery *pADO = NULL;
  535. sQry = "SELECT NVL(MAX(VDS_DTCT_NMBR), 10000) + 1 AS NEWID FROM TB_VDS_DTCT \r\n";
  536. try
  537. {
  538. try
  539. {
  540. pADO = new TADOQuery(NULL);
  541. pADO->Close();
  542. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  543. pADO->SQL->Clear();
  544. pADO->SQL->Text = sQry;
  545. pADO->Prepared = true;
  546. pADO->Open();
  547. ANmbr = pADO->FieldByName("NEWID")->AsInteger;
  548. AId = ANmbr / 10000;
  549. return true;
  550. }
  551. catch(EDatabaseError &E)
  552. {
  553. DBERRORLOG("TVdsCtlrManager::GetNextVdsId", String(E.ClassName()), E.Message, sQry);
  554. throw Exception(String(E.ClassName()) + E.Message);
  555. }
  556. catch(Exception &e)
  557. {
  558. DBERRORLOG("TVdsCtlrManager::GetNextVdsId", String(e.ClassName()), e.Message, sQry);
  559. throw Exception(String(e.ClassName()) + e.Message);
  560. }
  561. }
  562. __finally
  563. {
  564. if (pADO)
  565. {
  566. pADO->Close();
  567. delete pADO;
  568. }
  569. }
  570. return false;
  571. }
  572. //---------------------------------------------------------------------------
  573. bool TVdsCtlrManager::DeleteVdsDtctSubTable(TVdsDtct *AObj, TADOConnection *ADbConn/*=NULL*/)
  574. {
  575. String sQry;
  576. TADOQuery *pADO = NULL;
  577. try
  578. {
  579. try
  580. {
  581. pADO = new TADOQuery(NULL);
  582. pADO->Close();
  583. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  584. sQry = "DELETE TB_VDS_DTCT_RLTN_LINK \r\n"
  585. " WHERE VDS_DTCT_NMBR = :p01 \r\n";
  586. pADO->SQL->Clear();
  587. pADO->SQL->Text = sQry;
  588. pADO->Parameters->ParamByName("p01")->Value = AObj->VDS_DTCT_NMBR;
  589. pADO->ExecSQL();
  590. return true;
  591. }
  592. catch(EDatabaseError &E)
  593. {
  594. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  595. DBERRORMSG("TVdsCtlrManager::DeleteVdsDtctSubTable", String(E.ClassName()), E.Message, sQry);
  596. throw Exception(String(E.ClassName()) + E.Message);
  597. }
  598. catch(Exception &exception)
  599. {
  600. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  601. DBERRORMSG("TVdsCtlrManager::DeleteVdsDtctSubTable", String(exception.ClassName()), exception.Message, sQry);
  602. throw Exception(String(exception.ClassName()) + exception.Message);
  603. }
  604. }
  605. __finally
  606. {
  607. if (pADO)
  608. {
  609. pADO->Close();
  610. delete pADO;
  611. }
  612. }
  613. return true;
  614. }
  615. //---------------------------------------------------------------------------
  616. bool TVdsCtlrManager::DeleteVdsDtct(TVdsDtct *AObj, TADOConnection *ADbConn/*=NULL*/)
  617. {
  618. String sQry;
  619. TADOQuery *pADO = NULL;
  620. sQry = "UPDATE TB_VDS_DTCT \r\n"
  621. " SET DEL_YN = 'Y' \r\n"
  622. " WHERE VDS_DTCT_NMBR = :p01 \r\n";
  623. try
  624. {
  625. DeleteVdsDtctSubTable(AObj, ADbConn);
  626. try
  627. {
  628. pADO = new TADOQuery(NULL);
  629. pADO->Close();
  630. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  631. pADO->SQL->Clear();
  632. pADO->SQL->Text = sQry;
  633. pADO->Parameters->ParamByName("p01")->Value = AObj->VDS_DTCT_NMBR;
  634. pADO->ExecSQL();
  635. return true;
  636. }
  637. catch(EDatabaseError &E)
  638. {
  639. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  640. DBERRORMSG("TVdsCtlrManager::DeleteVdsDtct", String(E.ClassName()), E.Message, sQry);
  641. throw Exception(String(E.ClassName()) + E.Message);
  642. }
  643. catch(Exception &exception)
  644. {
  645. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  646. DBERRORMSG("TVdsCtlrManager::DeleteVdsDtct", String(exception.ClassName()), exception.Message, sQry);
  647. throw Exception(String(exception.ClassName()) + exception.Message);
  648. }
  649. }
  650. __finally
  651. {
  652. if (pADO)
  653. {
  654. pADO->Close();
  655. delete pADO;
  656. }
  657. }
  658. return true;
  659. }
  660. //---------------------------------------------------------------------------
  661. bool TVdsCtlrManager::SaveVdsDtct(TVdsDtct *AObj, TADOConnection *ADbConn/*=NULL*/)
  662. {
  663. String sQry;
  664. TADOQuery *pADO = NULL;
  665. sQry = "MERGE INTO TB_VDS_DTCT L \r\n"
  666. "USING (SELECT :p01 AS VDS_DTCT_NMBR, \r\n"
  667. " :p02 AS VDS_DTCT_ID, \r\n"
  668. " :p03 AS VDS_DTCT_NM, \r\n"
  669. " :p04 AS VDS_CTLR_NMBR, \r\n"
  670. " :p05 AS VDS_CMRA_NO, \r\n"
  671. " :p06 AS DTCT_TYPE, \r\n"
  672. " :p07 AS DTCT_DIR, \r\n"
  673. " :p08 AS DETECT_LANE, \r\n"
  674. " :p09 AS ISTL_LANE, \r\n"
  675. " :p10 AS SPED_CLCT_YN, \r\n"
  676. " :p11 AS TFVL_CLCT_YN, \r\n"
  677. " :p12 AS OCPY_CLCT_YN, \r\n"
  678. " :p13 AS MAX_TFVL, \r\n"
  679. " :p14 AS MIN_TFVL, \r\n"
  680. " :p15 AS MAX_OCPY_RATE, \r\n"
  681. " :p16 AS MIN_OCPY_RATE, \r\n"
  682. " :p17 AS MAX_SPED, \r\n"
  683. " :p18 AS MIN_SPED, \r\n"
  684. " :p19 AS USE_YN, \r\n"
  685. " :p20 AS DEL_YN \r\n"
  686. " FROM DUAL) M \r\n"
  687. " ON (L.VDS_DTCT_NMBR = M.VDS_DTCT_NMBR) \r\n"
  688. "WHEN MATCHED THEN \r\n"
  689. " UPDATE SET L.VDS_DTCT_ID = M.VDS_DTCT_ID, \r\n"
  690. " L.VDS_DTCT_NM = M.VDS_DTCT_NM, \r\n"
  691. " L.VDS_CTLR_NMBR = M.VDS_CTLR_NMBR, \r\n"
  692. " L.VDS_CMRA_NO = M.VDS_CMRA_NO, \r\n"
  693. " L.DTCT_TYPE = M.DTCT_TYPE, \r\n"
  694. " L.DTCT_DIR = M.DTCT_DIR, \r\n"
  695. " L.DETECT_LANE = M.DETECT_LANE, \r\n"
  696. " L.ISTL_LANE = M.ISTL_LANE, \r\n"
  697. " L.SPED_CLCT_YN = M.SPED_CLCT_YN, \r\n"
  698. " L.TFVL_CLCT_YN = M.TFVL_CLCT_YN, \r\n"
  699. " L.OCPY_CLCT_YN = M.OCPY_CLCT_YN, \r\n"
  700. " L.MAX_TFVL = M.MAX_TFVL, \r\n"
  701. " L.MIN_TFVL = M.MIN_TFVL, \r\n"
  702. " L.MAX_OCPY_RATE = M.MAX_OCPY_RATE, \r\n"
  703. " L.MIN_OCPY_RATE = M.MIN_OCPY_RATE, \r\n"
  704. " L.MAX_SPED = M.MAX_SPED, \r\n"
  705. " L.MIN_SPED = M.MIN_SPED, \r\n"
  706. " L.USE_YN = M.USE_YN, \r\n"
  707. " L.DEL_YN = M.DEL_YN \r\n"
  708. "WHEN NOT MATCHED THEN \r\n"
  709. " INSERT (VDS_DTCT_NMBR, \r\n"
  710. " VDS_DTCT_ID, \r\n"
  711. " VDS_DTCT_NM, \r\n"
  712. " VDS_CTLR_NMBR, \r\n"
  713. " VDS_CMRA_NO, \r\n"
  714. " DTCT_TYPE, \r\n"
  715. " DTCT_DIR, \r\n"
  716. " DETECT_LANE, \r\n"
  717. " ISTL_LANE, \r\n"
  718. " SPED_CLCT_YN, \r\n"
  719. " TFVL_CLCT_YN, \r\n"
  720. " OCPY_CLCT_YN, \r\n"
  721. " MAX_TFVL, \r\n"
  722. " MIN_TFVL, \r\n"
  723. " MAX_OCPY_RATE, \r\n"
  724. " MIN_OCPY_RATE, \r\n"
  725. " MAX_SPED, \r\n"
  726. " MIN_SPED, \r\n"
  727. " USE_YN, \r\n"
  728. " DEL_YN ) \r\n"
  729. " VALUES (M.VDS_DTCT_NMBR, \r\n"
  730. " M.VDS_DTCT_ID, \r\n"
  731. " M.VDS_DTCT_NM, \r\n"
  732. " M.VDS_CTLR_NMBR, \r\n"
  733. " M.VDS_CMRA_NO, \r\n"
  734. " M.DTCT_TYPE, \r\n"
  735. " M.DTCT_DIR, \r\n"
  736. " M.DETECT_LANE, \r\n"
  737. " M.ISTL_LANE, \r\n"
  738. " M.SPED_CLCT_YN, \r\n"
  739. " M.TFVL_CLCT_YN, \r\n"
  740. " M.OCPY_CLCT_YN, \r\n"
  741. " M.MAX_TFVL, \r\n"
  742. " M.MIN_TFVL, \r\n"
  743. " M.MAX_OCPY_RATE, \r\n"
  744. " M.MIN_OCPY_RATE, \r\n"
  745. " M.MAX_SPED, \r\n"
  746. " M.MIN_SPED, \r\n"
  747. " M.USE_YN, \r\n"
  748. " M.DEL_YN ) \r\n";
  749. try
  750. {
  751. //관련정보를 모두 삭제
  752. DeleteVdsDtctSubTable(AObj, ADbConn);
  753. try
  754. {
  755. pADO = new TADOQuery(NULL);
  756. pADO->Close();
  757. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  758. pADO->SQL->Clear();
  759. pADO->SQL->Text = sQry;
  760. pADO->Parameters->ParamByName("p01")->Value = AObj->VDS_DTCT_NMBR;
  761. pADO->Parameters->ParamByName("p02")->Value = AObj->VDS_DTCT_ID;
  762. pADO->Parameters->ParamByName("p03")->Value = AObj->VDS_DTCT_NM;
  763. pADO->Parameters->ParamByName("p04")->Value = AObj->VDS_CTLR_NMBR;
  764. pADO->Parameters->ParamByName("p05")->Value = AObj->VDS_CMRA_NO;
  765. pADO->Parameters->ParamByName("p06")->Value = AObj->DTCT_TYPE;
  766. pADO->Parameters->ParamByName("p07")->Value = AObj->DTCT_DIR;
  767. pADO->Parameters->ParamByName("p08")->Value = AObj->DETECT_LANE;
  768. pADO->Parameters->ParamByName("p09")->Value = AObj->ISTL_LANE;
  769. pADO->Parameters->ParamByName("p10")->Value = AObj->SPED_CLCT_YN;
  770. pADO->Parameters->ParamByName("p11")->Value = AObj->TFVL_CLCT_YN;
  771. pADO->Parameters->ParamByName("p12")->Value = AObj->OCPY_CLCT_YN;
  772. pADO->Parameters->ParamByName("p13")->Value = AObj->MAX_TFVL;
  773. pADO->Parameters->ParamByName("p14")->Value = AObj->MIN_TFVL;
  774. pADO->Parameters->ParamByName("p15")->Value = String(AObj->MAX_OCPY_RATE);
  775. pADO->Parameters->ParamByName("p16")->Value = String(AObj->MIN_OCPY_RATE);
  776. pADO->Parameters->ParamByName("p17")->Value = AObj->MAX_SPED;
  777. pADO->Parameters->ParamByName("p18")->Value = AObj->MIN_SPED;
  778. pADO->Parameters->ParamByName("p19")->Value = AObj->USE_YN;
  779. pADO->Parameters->ParamByName("p20")->Value = AObj->DEL_YN;
  780. pADO->ExecSQL();
  781. //링크구성정보 입력
  782. sQry = "INSERT INTO TB_VDS_DTCT_RLTN_LINK (VDS_DTCT_NMBR, LINK_ID) \r\n"
  783. " VALUES (:p01, :p02 ) \r\n";
  784. pADO->SQL->Clear();
  785. pADO->SQL->Text = sQry;
  786. FOR_STL(TVdsDtctLink *, pObj, AObj->FLinks)
  787. {
  788. pADO->Parameters->ParamByName("p01")->Value = AObj->VDS_DTCT_NMBR;
  789. pADO->Parameters->ParamByName("p02")->Value = pObj->LINK_ID;
  790. pADO->ExecSQL();
  791. }
  792. return true;
  793. }
  794. catch(EDatabaseError &E)
  795. {
  796. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  797. DBERRORMSG("TVdsCtlrManager::SaveVdsDtct", String(E.ClassName()), E.Message, sQry);
  798. throw Exception(String(E.ClassName()) + E.Message);
  799. }
  800. catch(Exception &exception)
  801. {
  802. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  803. DBERRORMSG("TVdsCtlrManager::SaveVdsDtct", String(exception.ClassName()), exception.Message, sQry);
  804. throw Exception(String(exception.ClassName()) + exception.Message);
  805. }
  806. }
  807. __finally
  808. {
  809. if (pADO)
  810. {
  811. pADO->Close();
  812. delete pADO;
  813. }
  814. }
  815. return true;
  816. }
  817. //---------------------------------------------------------------------------
  818. bool TVdsCtlrManager::DeleteVds(TVdsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  819. {
  820. String sQry;
  821. TADOQuery *pADO = NULL;
  822. sQry = "UPDATE TB_VDS_CTLR \r\n"
  823. " SET DEL_YN = 'Y' \r\n"
  824. " WHERE VDS_CTLR_NMBR = :p01 \r\n";
  825. try
  826. {
  827. FLists.Lock();
  828. try
  829. {
  830. pADO = new TADOQuery(NULL);
  831. pADO->Close();
  832. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  833. pADO->SQL->Clear();
  834. pADO->SQL->Text = sQry;
  835. pADO->Parameters->ParamByName("p01")->Value = AObj->VDS_CTLR_NMBR;
  836. pADO->ExecSQL();
  837. sQry = "DELETE TB_FCLT_INFR \r\n"
  838. " WHERE FCLT_ID = :p01 \r\n";
  839. pADO->SQL->Clear();
  840. pADO->SQL->Text = sQry;
  841. pADO->Parameters->ParamByName("p01")->Value = AObj->VDS_CTLR_ID;
  842. pADO->ExecSQL();
  843. DeleteVdsCmra(AObj, ADbConn);
  844. return true;
  845. }
  846. catch(EDatabaseError &E)
  847. {
  848. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  849. DBERRORMSG("TVdsCtlrManager::DeleteVds", String(E.ClassName()), E.Message, sQry);
  850. throw Exception(String(E.ClassName()) + E.Message);
  851. }
  852. catch(Exception &exception)
  853. {
  854. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  855. DBERRORMSG("TVdsCtlrManager::DeleteVds", String(exception.ClassName()), exception.Message, sQry);
  856. throw Exception(String(exception.ClassName()) + exception.Message);
  857. }
  858. }
  859. __finally
  860. {
  861. if (pADO)
  862. {
  863. pADO->Close();
  864. delete pADO;
  865. }
  866. FLists.UnLock();
  867. }
  868. return true;
  869. }
  870. //---------------------------------------------------------------------------
  871. bool TVdsCtlrManager::UpdateVds(TVdsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  872. {
  873. return MergeVds(AObj, ADbConn);
  874. }
  875. //---------------------------------------------------------------------------
  876. bool TVdsCtlrManager::MergeVds(TVdsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  877. {
  878. String sQry;
  879. TADOQuery *pADO = NULL;
  880. sQry = "MERGE INTO TB_VDS_CTLR L \r\n"
  881. "USING (SELECT :p01 AS VDS_CTLR_NMBR, \r\n"
  882. " :p02 AS VDS_CTLR_ID, \r\n"
  883. " :p03 AS VDS_NM, \r\n"
  884. " :p04 AS VDS_CTLR_IP, \r\n"
  885. " :p05 AS VDS_CTLR_PORT, \r\n"
  886. " :p06 AS VDS_CTLR_LOCAL_NO, \r\n"
  887. " :p07 AS VDS_TYPE_CD, \r\n"
  888. " :p08 AS ISTL_LCTN_NM, \r\n"
  889. " :p09 AS X_CRDN, \r\n"
  890. " :p10 AS Y_CRDN, \r\n"
  891. " :p11 AS DEL_YN, \r\n"
  892. " :p12 AS GROUP_NO, \r\n"
  893. " :p13 AS FAN_MODE, \r\n"
  894. " :p14 AS FAN_RUN_TMPR, \r\n"
  895. " :p15 AS HETR_MODE, \r\n"
  896. " :p16 AS HETR_RUN_TMPR, \r\n"
  897. " :p17 AS DETECT_LANES, \r\n"
  898. " :p18 AS TRAF_CLCT_CYCL, \r\n"
  899. " :p19 AS STTS_CLCT_CYCL, \r\n"
  900. " :p20 AS ISTL_LCTN_ADDR \r\n"
  901. " FROM DUAL) M \r\n"
  902. " ON (L.VDS_CTLR_NMBR = M.VDS_CTLR_NMBR) \r\n"
  903. "WHEN MATCHED THEN \r\n"
  904. " UPDATE SET L.VDS_CTLR_ID = M.VDS_CTLR_ID, \r\n"
  905. " L.VDS_NM = M.VDS_NM, \r\n"
  906. " L.VDS_CTLR_IP = M.VDS_CTLR_IP, \r\n"
  907. " L.VDS_CTLR_PORT = M.VDS_CTLR_PORT, \r\n"
  908. " L.VDS_CTLR_LOCAL_NO = M.VDS_CTLR_LOCAL_NO, \r\n"
  909. " L.VDS_TYPE_CD = M.VDS_TYPE_CD, \r\n"
  910. " L.ISTL_LCTN_NM = M.ISTL_LCTN_NM, \r\n"
  911. " L.X_CRDN = M.X_CRDN, \r\n"
  912. " L.Y_CRDN = M.Y_CRDN, \r\n"
  913. " L.DEL_YN = M.DEL_YN, \r\n"
  914. " L.GROUP_NO = M.GROUP_NO, \r\n"
  915. " L.FAN_MODE = M.FAN_MODE, \r\n"
  916. " L.FAN_RUN_TMPR = M.FAN_RUN_TMPR, \r\n"
  917. " L.HETR_MODE = M.HETR_MODE, \r\n"
  918. " L.HETR_RUN_TMPR = M.HETR_RUN_TMPR, \r\n"
  919. " L.DETECT_LANES = M.DETECT_LANES, \r\n"
  920. " L.TRAF_CLCT_CYCL = M.TRAF_CLCT_CYCL, \r\n"
  921. " L.STTS_CLCT_CYCL = M.STTS_CLCT_CYCL, \r\n"
  922. " L.ISTL_LCTN_ADDR = M.ISTL_LCTN_ADDR \r\n"
  923. "WHEN NOT MATCHED THEN \r\n"
  924. " INSERT ( \r\n"
  925. " VDS_CTLR_NMBR, \r\n"
  926. " VDS_CTLR_ID, \r\n"
  927. " VDS_NM, \r\n"
  928. " VDS_CTLR_IP, \r\n"
  929. " VDS_CTLR_PORT, \r\n"
  930. " VDS_CTLR_LOCAL_NO, \r\n"
  931. " VDS_TYPE_CD, \r\n"
  932. " ISTL_LCTN_NM, \r\n"
  933. " X_CRDN, \r\n"
  934. " Y_CRDN, \r\n"
  935. " DEL_YN, \r\n"
  936. " GROUP_NO, \r\n"
  937. " FAN_MODE, \r\n"
  938. " FAN_RUN_TMPR, \r\n"
  939. " HETR_MODE, \r\n"
  940. " HETR_RUN_TMPR, \r\n"
  941. " DETECT_LANES, \r\n"
  942. " TRAF_CLCT_CYCL, \r\n"
  943. " STTS_CLCT_CYCL, \r\n"
  944. " ISTL_LCTN_ADDR \r\n"
  945. " ) \r\n"
  946. " VALUES ( \r\n"
  947. " M.VDS_CTLR_NMBR, \r\n"
  948. " M.VDS_CTLR_ID, \r\n"
  949. " M.VDS_NM, \r\n"
  950. " M.VDS_CTLR_IP, \r\n"
  951. " M.VDS_CTLR_PORT, \r\n"
  952. " M.VDS_CTLR_LOCAL_NO, \r\n"
  953. " M.VDS_TYPE_CD, \r\n"
  954. " M.ISTL_LCTN_NM, \r\n"
  955. " M.X_CRDN, \r\n"
  956. " M.Y_CRDN, \r\n"
  957. " M.DEL_YN, \r\n"
  958. " M.GROUP_NO, \r\n"
  959. " M.FAN_MODE, \r\n"
  960. " M.FAN_RUN_TMPR, \r\n"
  961. " M.HETR_MODE, \r\n"
  962. " M.HETR_RUN_TMPR, \r\n"
  963. " M.DETECT_LANES, \r\n"
  964. " M.TRAF_CLCT_CYCL, \r\n"
  965. " M.STTS_CLCT_CYCL, \r\n"
  966. " M.ISTL_LCTN_ADDR \r\n"
  967. " ) \r\n";
  968. try
  969. {
  970. try
  971. {
  972. pADO = new TADOQuery(NULL);
  973. pADO->Close();
  974. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  975. pADO->SQL->Clear();
  976. pADO->SQL->Text = sQry;
  977. AObj->FAN_MODE = 2;
  978. AObj->FAN_RUN_TMPR = 30;
  979. AObj->HETR_MODE = 2;
  980. AObj->HETR_RUN_TMPR = 0;
  981. pADO->Parameters->ParamByName("p01")->Value = AObj->VDS_CTLR_NMBR;
  982. pADO->Parameters->ParamByName("p02")->Value = AObj->VDS_CTLR_ID;
  983. pADO->Parameters->ParamByName("p03")->Value = AObj->VDS_NM;
  984. pADO->Parameters->ParamByName("p04")->Value = AObj->VDS_CTLR_IP;
  985. pADO->Parameters->ParamByName("p05")->Value = AObj->VDS_CTLR_PORT;
  986. pADO->Parameters->ParamByName("p06")->Value = AObj->VDS_CTLR_LOCAL_NO;
  987. pADO->Parameters->ParamByName("p07")->Value = AObj->VDS_TYPE_CD;
  988. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  989. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  990. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  991. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  992. pADO->Parameters->ParamByName("p12")->Value = AObj->GROUP_NO;
  993. pADO->Parameters->ParamByName("p13")->Value = AObj->FAN_MODE;
  994. pADO->Parameters->ParamByName("p14")->Value = AObj->FAN_RUN_TMPR;
  995. pADO->Parameters->ParamByName("p15")->Value = AObj->HETR_MODE;
  996. pADO->Parameters->ParamByName("p16")->Value = AObj->HETR_RUN_TMPR;
  997. pADO->Parameters->ParamByName("p17")->Value = AObj->DETECT_LANES;
  998. pADO->Parameters->ParamByName("p18")->Value = AObj->TRAF_CLCT_CYCL;
  999. pADO->Parameters->ParamByName("p19")->Value = AObj->STTS_CLCT_CYCL;
  1000. pADO->Parameters->ParamByName("p20")->Value = AObj->ISTL_LCTN_ADDR;
  1001. pADO->ExecSQL();
  1002. MergeFcltInfo(AObj, ADbConn);
  1003. }
  1004. catch(EDatabaseError &E)
  1005. {
  1006. DBERRORMSG("TVdsCtlrManager::MergeVds", String(E.ClassName()), E.Message, sQry);
  1007. throw Exception(String(E.ClassName()) + E.Message);
  1008. }
  1009. catch(Exception &e)
  1010. {
  1011. DBERRORMSG("TVdsCtlrManager::MergeVds", String(e.ClassName()), e.Message, sQry);
  1012. throw Exception(String(e.ClassName()) + e.Message);
  1013. }
  1014. }
  1015. __finally
  1016. {
  1017. if (pADO)
  1018. {
  1019. pADO->Close();
  1020. delete pADO;
  1021. }
  1022. }
  1023. return InsertVdsCmra(AObj, ADbConn);
  1024. }
  1025. //---------------------------------------------------------------------------
  1026. bool TVdsCtlrManager::InsertVds(TVdsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  1027. {
  1028. String sQry;
  1029. TADOQuery *pADO = NULL;
  1030. sQry = "INSERT INTO TB_VDS_CTLR ( \r\n"
  1031. " VDS_CTLR_NMBR , \r\n"
  1032. " VDS_CTLR_ID , \r\n"
  1033. " VDS_NM , \r\n"
  1034. " VDS_CTLR_IP , \r\n"
  1035. " VDS_CTLR_PORT , \r\n"
  1036. " VDS_CTLR_LOCAL_NO , \r\n"
  1037. " VDS_TYPE_CD , \r\n"
  1038. " ISTL_LCTN_NM , \r\n"
  1039. " X_CRDN , \r\n"
  1040. " Y_CRDN , \r\n"
  1041. " DEL_YN , \r\n"
  1042. " GROUP_NO , \r\n"
  1043. " FAN_MODE , \r\n"
  1044. " FAN_RUN_TMPR , \r\n"
  1045. " HETR_MODE , \r\n"
  1046. " HETR_RUN_TMPR , \r\n"
  1047. " DETECT_LANES , \r\n"
  1048. " TRAF_CLCT_CYCL , \r\n"
  1049. " STTS_CLCT_CYCL , \r\n"
  1050. " ISTL_LCTN_ADDR \r\n"
  1051. " ) \r\n"
  1052. " VALUES (:p01, \r\n"
  1053. " :p02, \r\n"
  1054. " :p03, \r\n"
  1055. " :p04, \r\n"
  1056. " :p05, \r\n"
  1057. " :p06, \r\n"
  1058. " :p07, \r\n"
  1059. " :p08, \r\n"
  1060. " :p09, \r\n"
  1061. " :p10, \r\n"
  1062. " :p11, \r\n"
  1063. " :p12, \r\n"
  1064. " :p13, \r\n"
  1065. " :p14, \r\n"
  1066. " :p15, \r\n"
  1067. " :p16, \r\n"
  1068. " :p17, \r\n"
  1069. " :p18, \r\n"
  1070. " :p19, \r\n"
  1071. " :p20) \r\n";
  1072. FLists.Lock();
  1073. try
  1074. {
  1075. try
  1076. {
  1077. pADO = new TADOQuery(NULL);
  1078. pADO->Close();
  1079. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1080. pADO->SQL->Clear();
  1081. pADO->SQL->Text = sQry;
  1082. AObj->FAN_MODE = 2;
  1083. AObj->FAN_RUN_TMPR = 30;
  1084. AObj->HETR_MODE = 2;
  1085. AObj->HETR_RUN_TMPR = 0;
  1086. pADO->Parameters->ParamByName("p01")->Value = AObj->VDS_CTLR_NMBR;
  1087. pADO->Parameters->ParamByName("p02")->Value = AObj->VDS_CTLR_ID;
  1088. pADO->Parameters->ParamByName("p03")->Value = AObj->VDS_NM;
  1089. pADO->Parameters->ParamByName("p04")->Value = AObj->VDS_CTLR_IP;
  1090. pADO->Parameters->ParamByName("p05")->Value = AObj->VDS_CTLR_PORT;
  1091. pADO->Parameters->ParamByName("p06")->Value = AObj->VDS_CTLR_LOCAL_NO;
  1092. pADO->Parameters->ParamByName("p07")->Value = AObj->VDS_TYPE_CD;
  1093. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  1094. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  1095. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  1096. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  1097. pADO->Parameters->ParamByName("p12")->Value = AObj->GROUP_NO;
  1098. pADO->Parameters->ParamByName("p13")->Value = AObj->FAN_MODE;
  1099. pADO->Parameters->ParamByName("p14")->Value = AObj->FAN_RUN_TMPR;
  1100. pADO->Parameters->ParamByName("p15")->Value = AObj->HETR_MODE;
  1101. pADO->Parameters->ParamByName("p16")->Value = AObj->HETR_RUN_TMPR;
  1102. pADO->Parameters->ParamByName("p17")->Value = AObj->DETECT_LANES;
  1103. pADO->Parameters->ParamByName("p18")->Value = AObj->TRAF_CLCT_CYCL;
  1104. pADO->Parameters->ParamByName("p19")->Value = AObj->STTS_CLCT_CYCL;
  1105. pADO->Parameters->ParamByName("p20")->Value = AObj->ISTL_LCTN_ADDR;
  1106. pADO->ExecSQL();
  1107. MergeFcltInfo(AObj, ADbConn);
  1108. }
  1109. catch(EDatabaseError &E)
  1110. {
  1111. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1112. DBERRORMSG("TVdsCtlrManager::InsertVds", String(E.ClassName()), E.Message, sQry);
  1113. throw Exception(String(E.ClassName()) + E.Message);
  1114. }
  1115. catch(Exception &exception)
  1116. {
  1117. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1118. DBERRORMSG("TVdsCtlrManager::InsertVds", String(exception.ClassName()), exception.Message, sQry);
  1119. throw Exception(String(exception.ClassName()) + exception.Message);
  1120. }
  1121. }
  1122. __finally
  1123. {
  1124. if (pADO)
  1125. {
  1126. pADO->Close();
  1127. delete pADO;
  1128. }
  1129. FLists.UnLock();
  1130. }
  1131. return InsertVdsCmra(AObj, ADbConn);
  1132. }
  1133. //---------------------------------------------------------------------------
  1134. bool TVdsCtlrManager::MergeFcltInfo(TVdsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  1135. {
  1136. String sQry;
  1137. TADOQuery *pADO = NULL;
  1138. sQry = "MERGE INTO TB_FCLT_INFR L \r\n"
  1139. "USING (SELECT :p01 AS FCLT_ID, \r\n"
  1140. " :p02 AS FCLT_TYPE, \r\n"
  1141. " :p03 AS FCLT_LCTN \r\n"
  1142. " FROM DUAL) M \r\n"
  1143. " ON (L.FCLT_ID = M.FCLT_ID AND L.FCLT_TYPE = M.FCLT_TYPE) \r\n"
  1144. "WHEN MATCHED \r\n"
  1145. "THEN \r\n"
  1146. " UPDATE SET L.FCLT_LCTN = M.FCLT_LCTN, \r\n"
  1147. " L.DEL_YN = 'N' \r\n"
  1148. "WHEN NOT MATCHED \r\n"
  1149. "THEN \r\n"
  1150. " INSERT ( FCLT_ID, FCLT_TYPE, FCLT_LCTN) \r\n"
  1151. " VALUES (M.FCLT_ID, M.FCLT_TYPE, M.FCLT_LCTN) \r\n";
  1152. try
  1153. {
  1154. try
  1155. {
  1156. pADO = new TADOQuery(NULL);
  1157. pADO->Close();
  1158. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1159. pADO->SQL->Clear();
  1160. pADO->SQL->Text = sQry;
  1161. pADO->Parameters->ParamByName("p01")->Value = AObj->VDS_CTLR_ID;
  1162. pADO->Parameters->ParamByName("p02")->Value = "VDS";
  1163. pADO->Parameters->ParamByName("p03")->Value = AObj->VDS_NM;
  1164. pADO->ExecSQL();
  1165. return true;
  1166. }
  1167. catch(EDatabaseError &E)
  1168. {
  1169. DBERRORMSG("TVdsCtlrManager::MergeFcltInfo", String(E.ClassName()), E.Message, sQry);
  1170. throw Exception(String(E.ClassName()) + E.Message);
  1171. }
  1172. catch(Exception &e)
  1173. {
  1174. DBERRORMSG("TVdsCtlrManager::MergeFcltInfo", String(e.ClassName()), e.Message, sQry);
  1175. throw Exception(String(e.ClassName()) + e.Message);
  1176. }
  1177. }
  1178. __finally
  1179. {
  1180. if (pADO)
  1181. {
  1182. pADO->Close();
  1183. delete pADO;
  1184. }
  1185. }
  1186. return true;
  1187. }
  1188. //---------------------------------------------------------------------------
  1189. bool TVdsCtlrManager::DeleteVdsCmra(TVdsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  1190. {
  1191. String sQry;
  1192. TADOQuery *pADO = NULL;
  1193. sQry = "DELETE TB_VDS_CMRA \r\n"
  1194. " WHERE VDS_CTLR_NMBR = :p01 \r\n";
  1195. FLists.Lock();
  1196. try
  1197. {
  1198. try
  1199. {
  1200. pADO = new TADOQuery(NULL);
  1201. pADO->Close();
  1202. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1203. pADO->SQL->Clear();
  1204. pADO->SQL->Text = sQry;
  1205. pADO->Parameters->ParamByName("p01")->Value = AObj->VDS_CTLR_NMBR;
  1206. pADO->ExecSQL();
  1207. return true;
  1208. }
  1209. catch(EDatabaseError &E)
  1210. {
  1211. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1212. DBERRORMSG("TVdsCtlrManager::DeleteVdsCmra", String(E.ClassName()), E.Message, sQry);
  1213. throw Exception(String(E.ClassName()) + E.Message);
  1214. }
  1215. catch(Exception &exception)
  1216. {
  1217. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1218. DBERRORMSG("TVdsCtlrManager::DeleteVdsCmra", String(exception.ClassName()), exception.Message, sQry);
  1219. throw Exception(String(exception.ClassName()) + exception.Message);
  1220. }
  1221. }
  1222. __finally
  1223. {
  1224. if (pADO)
  1225. {
  1226. pADO->Close();
  1227. delete pADO;
  1228. }
  1229. FLists.UnLock();
  1230. }
  1231. return true;
  1232. }
  1233. //---------------------------------------------------------------------------
  1234. bool TVdsCtlrManager::InsertVdsCmra(TVdsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  1235. {
  1236. String sQry;
  1237. TADOQuery *pADO = NULL;
  1238. sQry = "INSERT INTO TB_VDS_CMRA(VDS_CTLR_NMBR, VDS_CMRA_NO, VDS_CMRA_NM, DETECT_LANE, CMRA_DRCT_CD, DEL_YN, CCAM_CTLR_NMBR, ROAD_NAME, CROSS_NAME, DIR_NAME, VDS_CMRA_IP) \r\n"
  1239. " VALUES(:p01, :p02, :p03, :p04, :p05, 'N', :p06, :p07, :p08, :p09, :p10 ) \r\n";
  1240. FLists.Lock();
  1241. try
  1242. {
  1243. try
  1244. {
  1245. DeleteVdsCmra(AObj, ADbConn);
  1246. pADO = new TADOQuery(NULL);
  1247. pADO->Close();
  1248. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1249. pADO->SQL->Clear();
  1250. pADO->SQL->Text = sQry;
  1251. FOR_STL(TVdsCmra*, pCmra, AObj->FCmras)
  1252. {
  1253. if (pCmra->DEL_YN == "Y") continue;
  1254. pADO->Parameters->ParamByName("p01")->Value = pCmra->VDS_CTLR_NMBR;
  1255. pADO->Parameters->ParamByName("p02")->Value = pCmra->VDS_CMRA_NO;
  1256. pADO->Parameters->ParamByName("p03")->Value = pCmra->VDS_CMRA_NM;
  1257. pADO->Parameters->ParamByName("p04")->Value = pCmra->DETECT_LANE;
  1258. pADO->Parameters->ParamByName("p05")->Value = pCmra->CMRA_DRCT_CD;
  1259. pADO->Parameters->ParamByName("p06")->Value = pCmra->CCAM_CTLR_NMBR;
  1260. pADO->Parameters->ParamByName("p07")->Value = pCmra->ROAD_NAME;
  1261. pADO->Parameters->ParamByName("p08")->Value = pCmra->CROSS_NAME;
  1262. pADO->Parameters->ParamByName("p09")->Value = pCmra->DIR_NAME;
  1263. pADO->Parameters->ParamByName("p10")->Value = pCmra->VDS_CMRA_IP;
  1264. pADO->ExecSQL();
  1265. }
  1266. return true;
  1267. }
  1268. catch(EDatabaseError &E)
  1269. {
  1270. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1271. DBERRORMSG("TVdsCtlrManager::InsertVdsCmra", String(E.ClassName()), E.Message, sQry);
  1272. throw Exception(String(E.ClassName()) + E.Message);
  1273. }
  1274. catch(Exception &exception)
  1275. {
  1276. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  1277. DBERRORMSG("TVdsCtlrManager::InsertVdsCmra", String(exception.ClassName()), exception.Message, sQry);
  1278. throw Exception(String(exception.ClassName()) + exception.Message);
  1279. }
  1280. }
  1281. __finally
  1282. {
  1283. if (pADO)
  1284. {
  1285. pADO->Close();
  1286. delete pADO;
  1287. }
  1288. FLists.UnLock();
  1289. }
  1290. return true;
  1291. }
  1292. //---------------------------------------------------------------------------