CDSVdsCtlrF.cpp 57 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSVdsCtlrF.h"
  4. #include "ITS_OPLibF.h"
  5. #include "CDSFcltF.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->CTLR_NMBR = pADO->FieldByName("VDS_CTLR_NMBR")->AsString;
  152. pObj->CTLR_ID = pADO->FieldByName("VDS_CTLR_ID")->AsString;
  153. pObj->NAME = pADO->FieldByName("VDS_NM")->AsString;
  154. pObj->CTLR_IP = pADO->FieldByName("VDS_CTLR_IP")->AsString;
  155. pObj->CTLR_PORT = pADO->FieldByName("VDS_CTLR_PORT")->AsInteger;
  156. pObj->CTLR_LOCAL_NO = pADO->FieldByName("VDS_CTLR_LOCAL_NO")->AsInteger;
  157. pObj->TYPE_CD = pADO->FieldByName("VDS_TYPE_CD")->AsString;
  158. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString;
  159. pObj->ISTL_LCTN_ADDR = pADO->FieldByName("ISTL_LCTN_NM")->AsString.Trim();
  160. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsFloat;
  161. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsFloat;
  162. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  163. pObj->GROUP_NO = pADO->FieldByName("GROUP_NO")->AsInteger;
  164. pObj->FAN_MODE = pADO->FieldByName("FAN_MODE")->AsInteger;
  165. pObj->FAN_RUN_TMPR = pADO->FieldByName("FAN_RUN_TMPR")->AsInteger;
  166. pObj->HETR_RUN_TMPR = pADO->FieldByName("HETR_RUN_TMPR")->AsInteger;
  167. pObj->DETECT_LANES = pADO->FieldByName("DETECT_LANES")->AsInteger;
  168. pObj->TRAF_CLCT_CYCL = pADO->FieldByName("TRAF_CLCT_CYCL")->AsInteger;
  169. pObj->STTS_CLCT_CYCL = pADO->FieldByName("STTS_CLCT_CYCL")->AsInteger;
  170. pObj->MEM_DEL = "N";
  171. FLists.Push(pObj->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->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->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->CTLR_NMBR;
  982. pADO->Parameters->ParamByName("p02")->Value = AObj->CTLR_ID;
  983. pADO->Parameters->ParamByName("p03")->Value = AObj->NAME;
  984. pADO->Parameters->ParamByName("p04")->Value = AObj->CTLR_IP;
  985. pADO->Parameters->ParamByName("p05")->Value = AObj->CTLR_PORT;
  986. pADO->Parameters->ParamByName("p06")->Value = AObj->CTLR_LOCAL_NO;
  987. pADO->Parameters->ParamByName("p07")->Value = AObj->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->CTLR_NMBR;
  1087. pADO->Parameters->ParamByName("p02")->Value = AObj->CTLR_ID;
  1088. pADO->Parameters->ParamByName("p03")->Value = AObj->NAME;
  1089. pADO->Parameters->ParamByName("p04")->Value = AObj->CTLR_IP;
  1090. pADO->Parameters->ParamByName("p05")->Value = AObj->CTLR_PORT;
  1091. pADO->Parameters->ParamByName("p06")->Value = AObj->CTLR_LOCAL_NO;
  1092. pADO->Parameters->ParamByName("p07")->Value = AObj->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->CTLR_ID;
  1162. pADO->Parameters->ParamByName("p02")->Value = "VDS";
  1163. pADO->Parameters->ParamByName("p03")->Value = AObj->NAME;
  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->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. //---------------------------------------------------------------------------