CDSVmsIfscF.cpp 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSVmsIfscF.h"
  4. #include "VMSOprMainLibF.h"
  5. //---------------------------------------------------------------------------
  6. #pragma package(smart_init)
  7. //---------------------------------------------------------------------------
  8. TVmsLinkIfsc::TVmsLinkIfsc()
  9. {
  10. }
  11. //---------------------------------------------------------------------------
  12. TVmsLinkIfsc::~TVmsLinkIfsc()
  13. {
  14. }
  15. //---------------------------------------------------------------------------
  16. //---------------------------------------------------------------------------
  17. TVmsIfsc::TVmsIfsc()
  18. {
  19. FCompleted = false;
  20. FEditMode = DB_INIT;
  21. FGridIndex = -1;
  22. MEM_DEL = "N";
  23. VMS_IFSC_NM = ""; ///VARCHAR2(60) Y VMS 정보제공구간 명
  24. DSPL_STRT_NODE_NM = ""; //VARCHAR2(30) Y 표출 시작 노드 명
  25. DSPL_END_NODE_NM = ""; //VARCHAR2(30) Y 표출 종료 노드 명
  26. DETR_ID = 0; //NUMBER(10) Y 우회도로 ID
  27. USE_YN = "Y";
  28. AXIS_YN = "N";
  29. DEL_YN = "N";
  30. MIN[0] = 20; MAX[0] = 180;
  31. MIN[1] = 10; MAX[1] = 19;
  32. MIN[2] = 0; MAX[2] = 9;
  33. InitTraffic();
  34. }
  35. //---------------------------------------------------------------------------
  36. TVmsIfsc::~TVmsIfsc()
  37. {
  38. FLists.RemoveAll();
  39. }
  40. //---------------------------------------------------------------------------
  41. void TVmsIfsc::InitTraffic()
  42. {
  43. PRCN_DT = ""; //N VARCHAR2(14) Y 등록 일시
  44. SPED = 0; //N NUMBER(3) Y 0 속도
  45. CMTR_GRAD_CD = "0"; //N VARCHAR2(7) Y 소통 등급 코드 ==>예는 0,1,2,3으로 들어가네???
  46. TRVL_HH = 0; //N NUMBER(6) Y 0 통행 시간
  47. }
  48. //---------------------------------------------------------------------------
  49. //---------------------------------------------------------------------------
  50. TVmsIfscManager *VmsIfscManager = NULL;
  51. //---------------------------------------------------------------------------
  52. TVmsIfscManager::TVmsIfscManager()
  53. {
  54. }
  55. //---------------------------------------------------------------------------
  56. TVmsIfscManager::~TVmsIfscManager()
  57. {
  58. FLists.RemoveAll();
  59. }
  60. //---------------------------------------------------------------------------
  61. void TVmsIfscManager::InitTraffic()
  62. {
  63. FLists.Lock();
  64. try
  65. {
  66. FOR_STL(TVmsIfsc*, pObj, FLists)
  67. {
  68. pObj->InitTraffic();
  69. }
  70. }
  71. __finally
  72. {
  73. FLists.UnLock();
  74. }
  75. }
  76. //---------------------------------------------------------------------------
  77. bool TVmsIfscManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
  78. {
  79. String sQry;
  80. TADOQuery *pADO = NULL;
  81. FLists.Lock();
  82. try
  83. {
  84. FLists.RemoveAll();
  85. }
  86. __finally
  87. {
  88. FLists.UnLock();
  89. }
  90. #if 0
  91. sQry = "SELECT A.* \r\n"
  92. " FROM TB_VMS_IFSC A \r\n"
  93. " ORDER BY A.VMS_IFSC_ID \r\n";
  94. #else
  95. sQry = "SELECT A.*, \r\n"
  96. " NVL(B.MIN1, 20) AS MIN1, NVL(B.MAX1, 180) AS MAX1, \r\n"
  97. " NVL(B.MIN2, 10) AS MIN2, NVL(B.MAX2, 19) AS MAX2, \r\n"
  98. " NVL(B.MIN3, 0) AS MIN3, NVL(B.MAX3, 9) AS MAX3 \r\n"
  99. " FROM TB_VMS_IFSC A, \r\n"
  100. " (SELECT VMS_IFSC_ID, \r\n"
  101. " SUM(MIN1) AS MIN1, SUM(MAX1) AS MAX1, \r\n"
  102. " SUM(MIN2) AS MIN2, SUM(MAX2) AS MAX2, \r\n"
  103. " SUM(MIN3) AS MIN3, SUM(MAX3) AS MAX3 \r\n"
  104. " FROM (SELECT VMS_IFSC_ID, LWSTSPED AS MIN1, HGHSSPED AS MAX1, 0 AS MIN2, 0 AS MAX2, 0 AS MIN3, 0 AS MAX3 \r\n"
  105. " FROM TB_VMS_IFSC_CMTR_GRAD \r\n"
  106. " WHERE CMTR_GRAD_CD = '1' \r\n"
  107. " UNION ALL \r\n"
  108. " SELECT VMS_IFSC_ID, 0 AS MIN1, 0 AS MAX1, LWSTSPED AS MIN2, HGHSSPED AS MAX2, 0 AS MIN3, 0 AS MAX3 \r\n"
  109. " FROM TB_VMS_IFSC_CMTR_GRAD \r\n"
  110. " WHERE CMTR_GRAD_CD = '2' \r\n"
  111. " UNION ALL \r\n"
  112. " SELECT VMS_IFSC_ID, 0 AS MIN1, 0 AS MAX1, 0 AS MIN2, 0 AS MAX2, LWSTSPED AS MIN3, HGHSSPED AS MAX3 \r\n"
  113. " FROM TB_VMS_IFSC_CMTR_GRAD \r\n"
  114. " WHERE CMTR_GRAD_CD = '3') \r\n"
  115. " GROUP BY VMS_IFSC_ID) B \r\n"
  116. " WHERE A.VMS_IFSC_ID = B.VMS_IFSC_ID(+) \r\n";
  117. // " WHERE A.VMS_IFSC_ID = B.VMS_IFSC_ID \r\n";
  118. #endif
  119. FLists.Lock();
  120. try
  121. {
  122. try
  123. {
  124. pADO = new TADOQuery(NULL);
  125. pADO->Close();
  126. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  127. pADO->SQL->Clear();
  128. pADO->SQL->Text = sQry;
  129. pADO->Open();
  130. for( ; !pADO->Eof; pADO->Next())
  131. {
  132. TVmsIfsc *pObj = new TVmsIfsc();
  133. pObj->VMS_IFSC_ID = pADO->FieldByName("VMS_IFSC_ID")->AsInteger;
  134. pObj->VMS_IFSC_NM = pADO->FieldByName("VMS_IFSC_NM")->AsString;
  135. pObj->DSPL_STRT_NODE_NM = pADO->FieldByName("DSPL_STRT_NODE_NM")->AsString;
  136. pObj->DSPL_END_NODE_NM = pADO->FieldByName("DSPL_END_NODE_NM")->AsString;
  137. pObj->DETR_ID = pADO->FieldByName("DETR_ID")->AsInteger;
  138. pObj->USE_YN = pADO->FieldByName("USE_YN")->AsString;
  139. pObj->ROAD_NM = pADO->FieldByName("ROAD_NM")->AsString;
  140. pObj->SPOT_NM = pADO->FieldByName("SPOT_NM")->AsString;
  141. pObj->AXIS_YN = pADO->FieldByName("AXIS_YN")->AsString;
  142. pObj->MIN[0] = pADO->FieldByName("MIN1")->AsInteger;
  143. pObj->MAX[0] = pADO->FieldByName("MAX1")->AsInteger;
  144. pObj->MIN[1] = pADO->FieldByName("MIN2")->AsInteger;
  145. pObj->MAX[1] = pADO->FieldByName("MAX2")->AsInteger;
  146. pObj->MIN[2] = pADO->FieldByName("MIN3")->AsInteger;
  147. pObj->MAX[2] = pADO->FieldByName("MAX3")->AsInteger;
  148. pObj->CNGS_SPD = pADO->FieldByName("CNGS_SPD")->AsInteger;
  149. pObj->DEL_YN = "N";
  150. FLists.Push(pObj->VMS_IFSC_ID, pObj);
  151. pObj->Completed = true;
  152. }
  153. }
  154. catch(EDatabaseError &E)
  155. {
  156. DBERRORMSG("VMS정보제공구간정보조회", String(E.ClassName()), E.Message, sQry);
  157. throw Exception(String(E.ClassName()) + E.Message);
  158. }
  159. catch(Exception &e)
  160. {
  161. DBERRORMSG("VMS정보제공구간정보조회", String(e.ClassName()), e.Message, sQry);
  162. throw Exception(String(e.ClassName()) + e.Message);
  163. }
  164. }
  165. __finally
  166. {
  167. if (pADO)
  168. {
  169. pADO->Close();
  170. delete pADO;
  171. }
  172. FLists.UnLock();
  173. }
  174. return LoadSubFromDb(ADbConn);
  175. }
  176. //---------------------------------------------------------------------------
  177. bool TVmsIfscManager::LoadSubFromDb(TADOConnection *ADbConn/*=NULL*/)
  178. {
  179. String sQry;
  180. TADOQuery *pADO = NULL;
  181. sQry = "SELECT A.*, NVL(B.IFSC_NM, '-') AS IFSC_NM \r\n"
  182. " FROM TB_VMS_IFSC_RLTN_IFSC A, \r\n"
  183. " TB_IFSC B \r\n"
  184. " WHERE A.IFSC_ID = B.IFSC_ID(+) \r\n"
  185. " ORDER BY A.VMS_IFSC_ID, A.ORD \r\n";
  186. FLists.Lock();
  187. try
  188. {
  189. TVmsIfsc *pIfsc;
  190. TVmsLinkIfsc *pObj;
  191. int VMS_IFSC_ID;
  192. int ORD;
  193. try
  194. {
  195. pADO = new TADOQuery(NULL);
  196. pADO->Close();
  197. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  198. pADO->SQL->Clear();
  199. pADO->SQL->Text = sQry;
  200. pADO->Open();
  201. for( ; !pADO->Eof; pADO->Next())
  202. {
  203. VMS_IFSC_ID = pADO->FieldByName("VMS_IFSC_ID")->AsInteger;
  204. #if 0
  205. //TODO: 세종시 기존데이터에 ORD가 모두 0으로 들어가 있음.
  206. ORD = pADO->FieldByName("ORD")->AsInteger;
  207. #endif
  208. pIfsc = FLists.Find(VMS_IFSC_ID);
  209. if (!pIfsc) continue;
  210. #if 1
  211. //TODO: 세종시 기존데이터에 ORD가 모두 0으로 들어가 있음.
  212. ORD = pIfsc->FLists.Size()+1;
  213. #endif
  214. pObj = pIfsc->FLists.Find(ORD);
  215. if (!pObj)
  216. {
  217. pObj = new TVmsLinkIfsc();
  218. pIfsc->FLists.Push(ORD, pObj);
  219. }
  220. pObj->VMS_IFSC_ID = VMS_IFSC_ID;
  221. pObj->ORD = ORD;
  222. pObj->IFSC_ID = pADO->FieldByName("IFSC_ID")->AsString;
  223. //pObj->DSPL_STRT_NODE_NM = pADO->FieldByName("DSPL_STRT_NODE_NM")->AsString;
  224. //pObj->DSPL_END_NODE_NM = pADO->FieldByName("DSPL_END_NODE_NM")->AsString;
  225. pObj->IFSC_NM = pADO->FieldByName("IFSC_NM")->AsString;
  226. }
  227. }
  228. catch(EDatabaseError &E)
  229. {
  230. DBERRORMSG("VMS정보제공구간링크정보조회", String(E.ClassName()), E.Message, sQry);
  231. throw Exception(String(E.ClassName()) + E.Message);
  232. }
  233. catch(Exception &e)
  234. {
  235. DBERRORMSG("VMS정보제공구간링크정보조회", String(e.ClassName()), e.Message, sQry);
  236. throw Exception(String(e.ClassName()) + e.Message);
  237. }
  238. }
  239. __finally
  240. {
  241. if (pADO)
  242. {
  243. pADO->Close();
  244. delete pADO;
  245. }
  246. FLists.UnLock();
  247. }
  248. return true;
  249. }
  250. //---------------------------------------------------------------------------
  251. bool TVmsIfscManager::LoadTraffic(TADOConnection *ADbConn/*=NULL*/)
  252. {
  253. String sQry;
  254. TADOQuery *pADO = NULL;
  255. InitTraffic();
  256. #if 0
  257. //TODO: 기존 테이블 호환을 위해 PRCN_DT 컬럼을 RGST_DT 로 변경
  258. #endif
  259. sQry = "SELECT VMS_IFSC_ID, NVL(RGST_DT, '19000101000000') AS PRCN_DT, \r\n"
  260. " NVL(SPED, 0) AS SPEED, NVL(TRVL_HH, 0) AS TRVL_HH, \r\n"
  261. " DECODE(CMTR_GRAD_CD, '1', '1', \r\n"
  262. " '2', '2', \r\n"
  263. " '3', '3', '0') AS CMTR_GRAD_CD \r\n"
  264. " FROM TB_VMS_IFSC_TRAF \r\n"
  265. " WHERE RGST_DT > TO_CHAR(SYSDATE - 10 / 1440, 'YYYYMMDDHH24MISS') \r\n";
  266. FLists.Lock();
  267. try
  268. {
  269. try
  270. {
  271. pADO = new TADOQuery(NULL);
  272. pADO->Close();
  273. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  274. pADO->SQL->Clear();
  275. pADO->SQL->Text = sQry;
  276. pADO->Open();
  277. for( ; !pADO->Eof; pADO->Next())
  278. {
  279. int VMS_IFSC_ID = pADO->FieldByName("VMS_IFSC_ID")->AsInteger;
  280. TVmsIfsc *pObj = FLists.Find(VMS_IFSC_ID);
  281. if (!pObj) continue;
  282. pObj->PRCN_DT = pADO->FieldByName("PRCN_DT")->AsString; //N VARCHAR2(14) Y 등록 일시
  283. pObj->SPED = pADO->FieldByName("SPEED")->AsInteger; //N NUMBER(3) Y 0 속도
  284. pObj->CMTR_GRAD_CD = pADO->FieldByName("CMTR_GRAD_CD")->AsString; //N VARCHAR2(7) Y 소통 등급 코드 ==>예는 0,1,2,3으로 들어가네???
  285. pObj->TRVL_HH = pADO->FieldByName("TRVL_HH")->AsInteger; //N NUMBER(6) Y 0 통행 시간
  286. }
  287. }
  288. catch(EDatabaseError &E)
  289. {
  290. DBERRORMSG("VMS_IFSC교통정보조회", String(E.ClassName()), E.Message, sQry);
  291. throw Exception(String(E.ClassName()) + E.Message);
  292. }
  293. catch(Exception &e)
  294. {
  295. DBERRORMSG("VMS_IFSC교통정보조회", String(e.ClassName()), e.Message, sQry);
  296. throw Exception(String(e.ClassName()) + e.Message);
  297. }
  298. }
  299. __finally
  300. {
  301. if (pADO)
  302. {
  303. pADO->Close();
  304. delete pADO;
  305. }
  306. FLists.UnLock();
  307. }
  308. return true;
  309. }
  310. //---------------------------------------------------------------------------
  311. bool TVmsIfscManager::GetNextVmsIfscId(int &AIfscId, TADOConnection *ADbConn/*=NULL*/)
  312. {
  313. String sQry;
  314. TADOQuery *pADO = NULL;
  315. sQry = "SELECT NVL(MAX(VMS_IFSC_ID), 0) + 1 AS NEWID FROM TB_VMS_IFSC \r\n";
  316. try
  317. {
  318. try
  319. {
  320. pADO = new TADOQuery(NULL);
  321. pADO->Close();
  322. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  323. pADO->SQL->Clear();
  324. pADO->SQL->Text = sQry;
  325. pADO->Open();
  326. AIfscId = pADO->FieldByName("NEWID")->AsInteger;
  327. return true;
  328. }
  329. catch(EDatabaseError &E)
  330. {
  331. DBERRORLOG("VMS제공구간ID조회", String(E.ClassName()), E.Message, sQry);
  332. throw Exception(String(E.ClassName()) + E.Message);
  333. }
  334. catch(Exception &e)
  335. {
  336. DBERRORLOG("VMS제공구간ID조회", String(e.ClassName()), e.Message, sQry);
  337. throw Exception(String(e.ClassName()) + e.Message);
  338. }
  339. }
  340. __finally
  341. {
  342. if (pADO)
  343. {
  344. pADO->Close();
  345. delete pADO;
  346. }
  347. }
  348. return false;
  349. }
  350. //---------------------------------------------------------------------------
  351. bool TVmsIfscManager::DeleteVmsIfsc(TVmsIfsc *AObj, TADOConnection *ADbConn/*=NULL*/)
  352. {
  353. String sQry;
  354. TADOQuery *pADO = NULL;
  355. try
  356. {
  357. String sIfscId = String(AObj->VMS_IFSC_ID);
  358. try
  359. {
  360. pADO = new TADOQuery(NULL);
  361. pADO->Close();
  362. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  363. //VMS_정보제공구간 소통 등급
  364. sQry = "DELETE FROM TB_VMS_IFSC_CMTR_GRAD WHERE VMS_IFSC_ID = :p01";
  365. pADO->SQL->Clear();
  366. pADO->SQL->Text = sQry;
  367. pADO->Parameters->ParamByName("p01")->Value = sIfscId;
  368. pADO->ExecSQL();
  369. //VMS LINK 정보제공구간
  370. sQry = "DELETE FROM TB_VMS_IFSC_RLTN_IFSC WHERE VMS_IFSC_ID = :p01";
  371. pADO->SQL->Clear();
  372. pADO->SQL->Text = sQry;
  373. pADO->Parameters->ParamByName("p01")->Value = sIfscId;
  374. pADO->ExecSQL();
  375. //VMS 정보제공구간 관계
  376. sQry = "DELETE FROM TB_VMS_RLTN_IFSC WHERE VMS_IFSC_ID = :p01";
  377. pADO->SQL->Clear();
  378. pADO->SQL->Text = sQry;
  379. pADO->Parameters->ParamByName("p01")->Value = sIfscId;
  380. pADO->ExecSQL();
  381. //VMS_소통정보
  382. sQry = "DELETE FROM TB_VMS_IFSC_TRAF WHERE VMS_IFSC_ID = :p01";
  383. pADO->SQL->Clear();
  384. pADO->SQL->Text = sQry;
  385. pADO->Parameters->ParamByName("p01")->Value = sIfscId;
  386. pADO->ExecSQL();
  387. //VMS_소통정보 이력
  388. #if 0
  389. sQry = "DELETE FROM TB_VMS_IFSC_TRAF_HS WHERE VMS_IFSC_ID = :p01";
  390. pADO->SQL->Clear();
  391. pADO->SQL->Text = sQry;
  392. pADO->Parameters->ParamByName("p01")->Value = sIfscId;
  393. pADO->ExecSQL();
  394. #endif
  395. //VMS_정보제공구간
  396. #if 1
  397. sQry = "DELETE FROM TB_VMS_IFSC WHERE VMS_IFSC_ID = :p01";
  398. #else
  399. sQry = "UPDATE TB_VMS_IFSC SET USE_YN = 'N' WHERE VMS_IFSC_ID = :p01";
  400. #endif
  401. pADO->SQL->Clear();
  402. pADO->SQL->Text = sQry;
  403. pADO->Parameters->ParamByName("p01")->Value = sIfscId;
  404. pADO->ExecSQL();
  405. return true;
  406. }
  407. catch(EDatabaseError &E)
  408. {
  409. DBERRORLOG("VMS정보제공구간삭제", String(E.ClassName()), E.Message, sQry);
  410. throw Exception(String(E.ClassName()) + E.Message);
  411. }
  412. catch(Exception &e)
  413. {
  414. DBERRORLOG("VMS정보제공구간삭제", String(e.ClassName()), e.Message, sQry);
  415. throw Exception(String(e.ClassName()) + e.Message);
  416. }
  417. }
  418. __finally
  419. {
  420. if (pADO)
  421. {
  422. pADO->Close();
  423. delete pADO;
  424. }
  425. }
  426. return true;
  427. }
  428. //---------------------------------------------------------------------------
  429. bool TVmsIfscManager::InsertVmsIfsc(TVmsIfsc *AObj, TADOConnection *ADbConn/*=NULL*/)
  430. {
  431. return MergeVmsIfsc(AObj, ADbConn);
  432. }
  433. //---------------------------------------------------------------------------
  434. bool TVmsIfscManager::UpdateVmsIfsc(TVmsIfsc *AObj, TADOConnection *ADbConn/*=NULL*/)
  435. {
  436. return MergeVmsIfsc(AObj, ADbConn);
  437. }
  438. //---------------------------------------------------------------------------
  439. bool TVmsIfscManager::MergeVmsIfsc(TVmsIfsc *AObj, TADOConnection *ADbConn/*=NULL*/)
  440. {
  441. String sQry;
  442. TADOQuery *pADO = NULL;
  443. int ii;
  444. sQry = "MERGE INTO TB_VMS_IFSC L \r\n"
  445. "USING (SELECT :p01 AS VMS_IFSC_ID, \r\n"
  446. " :p02 AS VMS_IFSC_NM, \r\n"
  447. " :p03 AS DSPL_STRT_NODE_NM, \r\n"
  448. " :p04 AS DSPL_END_NODE_NM, \r\n"
  449. " :p05 AS DETR_ID, \r\n"
  450. " :p06 AS USE_YN, \r\n"
  451. " :p07 AS ROAD_NM, \r\n"
  452. " :p08 AS SPOT_NM, \r\n"
  453. " :p09 AS AXIS_YN, \r\n"
  454. " :p10 AS CNGS_SPD \r\n"
  455. " FROM DUAL) M \r\n"
  456. " ON (L.VMS_IFSC_ID = M.VMS_IFSC_ID) \r\n"
  457. "WHEN MATCHED \r\n"
  458. "THEN \r\n"
  459. " UPDATE SET L.VMS_IFSC_NM = M.VMS_IFSC_NM, \r\n"
  460. " L.DSPL_STRT_NODE_NM = M.DSPL_STRT_NODE_NM, \r\n"
  461. " L.DSPL_END_NODE_NM = M.DSPL_END_NODE_NM, \r\n"
  462. " L.DETR_ID = M.DETR_ID, \r\n"
  463. " L.USE_YN = M.USE_YN, \r\n"
  464. " L.ROAD_NM = M.ROAD_NM, \r\n"
  465. " L.SPOT_NM = M.SPOT_NM, \r\n"
  466. " L.AXIS_YN = M.AXIS_YN, \r\n"
  467. " L.CNGS_SPD = M.CNGS_SPD \r\n"
  468. "WHEN NOT MATCHED \r\n"
  469. "THEN \r\n"
  470. " INSERT (VMS_IFSC_ID, \r\n"
  471. " VMS_IFSC_NM, \r\n"
  472. " DSPL_STRT_NODE_NM, \r\n"
  473. " DSPL_END_NODE_NM, \r\n"
  474. " DETR_ID, \r\n"
  475. " USE_YN, \r\n"
  476. " ROAD_NM, \r\n"
  477. " SPOT_NM, \r\n"
  478. " AXIS_YN, \r\n"
  479. " CNGS_SPD ) \r\n"
  480. " VALUES (M.VMS_IFSC_ID, \r\n"
  481. " M.VMS_IFSC_NM, \r\n"
  482. " M.DSPL_STRT_NODE_NM, \r\n"
  483. " M.DSPL_END_NODE_NM, \r\n"
  484. " M.DETR_ID, \r\n"
  485. " M.USE_YN, \r\n"
  486. " M.ROAD_NM, \r\n"
  487. " M.SPOT_NM, \r\n"
  488. " M.AXIS_YN, \r\n"
  489. " M.CNGS_SPD ) \r\n";
  490. try
  491. {
  492. try
  493. {
  494. String sDetrId = "";
  495. if (AObj->DETR_ID != 0) sDetrId = String(AObj->DETR_ID);
  496. pADO = new TADOQuery(NULL);
  497. pADO->Close();
  498. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  499. pADO->SQL->Clear();
  500. pADO->SQL->Text = sQry;
  501. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_IFSC_ID;
  502. pADO->Parameters->ParamByName("p02")->Value = AObj->VMS_IFSC_NM;
  503. pADO->Parameters->ParamByName("p03")->Value = AObj->DSPL_STRT_NODE_NM;
  504. pADO->Parameters->ParamByName("p04")->Value = AObj->DSPL_END_NODE_NM;
  505. pADO->Parameters->ParamByName("p05")->Value = sDetrId;
  506. pADO->Parameters->ParamByName("p06")->Value = AObj->USE_YN;
  507. pADO->Parameters->ParamByName("p07")->Value = AObj->ROAD_NM;
  508. pADO->Parameters->ParamByName("p08")->Value = AObj->SPOT_NM;
  509. pADO->Parameters->ParamByName("p09")->Value = AObj->AXIS_YN;
  510. pADO->Parameters->ParamByName("p10")->Value = AObj->CNGS_SPD;
  511. pADO->ExecSQL();
  512. //VMS_정보제공구간 소통 등급
  513. sQry = "MERGE INTO TB_VMS_IFSC_CMTR_GRAD L \r\n"
  514. "USING (SELECT :p01 AS VMS_IFSC_ID, \r\n"
  515. " :p02 AS CMTR_GRAD_CD, \r\n"
  516. " :p03 AS LWSTSPED, \r\n"
  517. " :p04 AS HGHSSPED \r\n"
  518. " FROM DUAL) M \r\n"
  519. " ON (L.VMS_IFSC_ID = M.VMS_IFSC_ID \r\n"
  520. " AND L.CMTR_GRAD_CD = M.CMTR_GRAD_CD) \r\n"
  521. "WHEN MATCHED \r\n"
  522. "THEN \r\n"
  523. " UPDATE SET L.LWSTSPED = M.LWSTSPED, \r\n"
  524. " L.HGHSSPED = M.HGHSSPED \r\n"
  525. "WHEN NOT MATCHED \r\n"
  526. "THEN \r\n"
  527. " INSERT (VMS_IFSC_ID, \r\n"
  528. " CMTR_GRAD_CD, \r\n"
  529. " LWSTSPED, \r\n"
  530. " HGHSSPED ) \r\n"
  531. " VALUES (M.VMS_IFSC_ID, \r\n"
  532. " M.CMTR_GRAD_CD, \r\n"
  533. " M.LWSTSPED, \r\n"
  534. " M.HGHSSPED ) \r\n";
  535. String sGradCd;
  536. pADO->SQL->Clear();
  537. pADO->SQL->Text = sQry;
  538. for(ii = 0; ii < 3; ii++)
  539. {
  540. sGradCd = String(ii+1);
  541. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_IFSC_ID;
  542. pADO->Parameters->ParamByName("p02")->Value = sGradCd;
  543. pADO->Parameters->ParamByName("p03")->Value = AObj->MIN[ii];
  544. pADO->Parameters->ParamByName("p04")->Value = AObj->MAX[ii];
  545. pADO->ExecSQL();
  546. }
  547. //VMS LINK 정보제공구간
  548. sQry = "DELETE FROM TB_VMS_IFSC_RLTN_IFSC WHERE VMS_IFSC_ID = :p01";
  549. pADO->SQL->Clear();
  550. pADO->SQL->Text = sQry;
  551. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_IFSC_ID;
  552. pADO->ExecSQL();
  553. sQry = "INSERT INTO TB_VMS_IFSC_RLTN_IFSC(VMS_IFSC_ID, IFSC_ID, ORD) VALUES(:p01, :p02, :p03)";
  554. ii = 0;
  555. pADO->SQL->Clear();
  556. pADO->SQL->Text = sQry;
  557. FOR_STL(TVmsLinkIfsc *, pLink, AObj->FLists)
  558. {
  559. sGradCd = String(ii+1);
  560. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_IFSC_ID;
  561. pADO->Parameters->ParamByName("p02")->Value = pLink->IFSC_ID;
  562. pADO->Parameters->ParamByName("p03")->Value = String(pLink->ORD);
  563. pADO->ExecSQL();
  564. ii++;
  565. }
  566. return true;
  567. }
  568. catch(EDatabaseError &E)
  569. {
  570. DBERRORLOG("VMS제공구간정보저장", String(E.ClassName()), E.Message, sQry);
  571. throw Exception(String(E.ClassName()) + E.Message);
  572. }
  573. catch(Exception &e)
  574. {
  575. DBERRORLOG("VMS제공구간정보저장", String(e.ClassName()), e.Message, sQry);
  576. throw Exception(String(e.ClassName()) + e.Message);
  577. }
  578. }
  579. __finally
  580. {
  581. if (pADO)
  582. {
  583. pADO->Close();
  584. delete pADO;
  585. }
  586. }
  587. return true;
  588. }
  589. //---------------------------------------------------------------------------
  590. bool TVmsIfscManager::UpdateIfscSpeedInfo(TVmsIfsc *AObj, TADOConnection *ADbConn/*=NULL*/)
  591. {
  592. String sQry;
  593. TADOQuery *pADO = NULL;
  594. sQry = "UPDATE TB_VMS_IFSC_CMTR_GRAD \r\n"
  595. " SET LWSTSPED = :p01, \r\n"
  596. " HGHSSPED = :p02 \r\n"
  597. " WHERE CMTR_GRAD_CD = :p03 \r\n";
  598. try
  599. {
  600. try
  601. {
  602. String sGradCd;
  603. pADO = new TADOQuery(NULL);
  604. pADO->Close();
  605. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  606. pADO->SQL->Clear();
  607. pADO->SQL->Text = sQry;
  608. for(int ii = 0; ii < 3; ii++)
  609. {
  610. sGradCd = String(ii+1);
  611. pADO->Parameters->ParamByName("p01")->Value = AObj->MIN[ii];
  612. pADO->Parameters->ParamByName("p02")->Value = AObj->MAX[ii];
  613. pADO->Parameters->ParamByName("p03")->Value = sGradCd;
  614. pADO->ExecSQL();
  615. }
  616. return true;
  617. }
  618. catch(EDatabaseError &E)
  619. {
  620. DBERRORLOG("VMS제공구간속도정보저장", String(E.ClassName()), E.Message, sQry);
  621. throw Exception(String(E.ClassName()) + E.Message);
  622. }
  623. catch(Exception &e)
  624. {
  625. DBERRORLOG("VMS제공구간속도정보저장", String(e.ClassName()), e.Message, sQry);
  626. throw Exception(String(e.ClassName()) + e.Message);
  627. }
  628. }
  629. __finally
  630. {
  631. if (pADO)
  632. {
  633. pADO->Close();
  634. delete pADO;
  635. }
  636. }
  637. return true;
  638. }
  639. //---------------------------------------------------------------------------
  640. bool TVmsIfscManager::UpdateIfscCngsSpeedInfo(int ACngsSpd, TADOConnection *ADbConn/*=NULL*/)
  641. {
  642. String sQry;
  643. TADOQuery *pADO = NULL;
  644. sQry = "UPDATE TB_VMS_IFSC \r\n"
  645. " SET CNGS_SPD = :p01 \r\n";
  646. try
  647. {
  648. try
  649. {
  650. String sGradCd;
  651. pADO = new TADOQuery(NULL);
  652. pADO->Close();
  653. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  654. pADO->SQL->Clear();
  655. pADO->SQL->Text = sQry;
  656. pADO->Parameters->ParamByName("p01")->Value = ACngsSpd;
  657. pADO->ExecSQL();
  658. return true;
  659. }
  660. catch(EDatabaseError &E)
  661. {
  662. DBERRORLOG("VMS제공구간 정체폼 정체판정속도정보저장", String(E.ClassName()), E.Message, sQry);
  663. throw Exception(String(E.ClassName()) + E.Message);
  664. }
  665. catch(Exception &e)
  666. {
  667. DBERRORLOG("VMS제공구간 정체폼 정체판정속도정보저장", String(e.ClassName()), e.Message, sQry);
  668. throw Exception(String(e.ClassName()) + e.Message);
  669. }
  670. }
  671. __finally
  672. {
  673. if (pADO)
  674. {
  675. pADO->Close();
  676. delete pADO;
  677. }
  678. }
  679. return true;
  680. }
  681. //---------------------------------------------------------------------------