CDSLink_VMSF.cpp 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSLink_VMSF.h"
  4. #include "ITS_OPLibF.h"
  5. //---------------------------------------------------------------------------
  6. #pragma package(smart_init)
  7. TLink::TLink()
  8. {
  9. IFSC_ID = "";
  10. ROAD_ID = "";
  11. Clear();
  12. }
  13. //---------------------------------------------------------------------------
  14. void TLink::Clear()
  15. {
  16. }
  17. //---------------------------------------------------------------------------
  18. TLink::~TLink()
  19. {
  20. }
  21. //---------------------------------------------------------------------------
  22. void TLink::InitTraffic()
  23. {
  24. TRAF->InitTraffic();
  25. }
  26. //---------------------------------------------------------------------------
  27. //---------------------------------------------------------------------------
  28. TLinkManager *LinkManager = NULL;
  29. //---------------------------------------------------------------------------
  30. /*
  31. * Link Manager
  32. */
  33. TLinkManager::TLinkManager()
  34. {
  35. }
  36. //---------------------------------------------------------------------------
  37. TLinkManager::~TLinkManager()
  38. {
  39. }
  40. //---------------------------------------------------------------------------
  41. void TLinkManager::InitTraffic()
  42. {
  43. try
  44. {
  45. FLists.Lock();
  46. FOR_STL(TLink*, pObj, FLists)
  47. {
  48. pObj->InitTraffic();
  49. }
  50. }
  51. __finally
  52. {
  53. FLists.UnLock();
  54. }
  55. }
  56. //---------------------------------------------------------------------------
  57. bool TLinkManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
  58. {
  59. String sQry;
  60. TADOQuery *pADO = NULL;
  61. #if 1
  62. // for POHANG
  63. sQry = "SELECT LINK_ID, F_NODE AS F_NODE_ID, T_NODE AS T_NODE_ID, ROAD_USE, LANES, \r\n"
  64. " ROAD_RANK, TRIM(ROAD_TYPE) AS ROAD_TYPE, ROAD_NO, TRIM(ROAD_NAME) ROAD_NAME, \r\n"
  65. " MULTI_LINK, TRIM(LINK_CONNECT) AS LINK_CONNECT, MAX_SPD, \r\n"
  66. " TRIM(REST_VEH) AS REST_VEH, REST_W, REST_H, LINK_LENG, RMRK, \r\n"
  67. " DEL_YN, DFLT_SPED, DFLT_SPED_USE_YN, \r\n"
  68. " SECT_GRAD_CD, AREA_CD, \r\n"
  69. " DECODE(AREA_CD, 'LAT001', 'Y', 'N') REGN_YN, 1 AS PARA_ID \r\n"
  70. " FROM TB_LINK \r\n";
  71. #else
  72. sQry = "SELECT LINK_ID, F_NODE_ID, T_NODE_ID, ROAD_USE, LANES, \r\n"
  73. " ROAD_RANK, TRIM(ROAD_TYPE) AS ROAD_TYPE, ROAD_NO, TRIM(ROAD_NAME) ROAD_NAME, \r\n"
  74. " MULTI_LINK, TRIM(LINK_CONNECT) AS LINK_CONNECT, MAX_SPD, \r\n"
  75. " TRIM(REST_VEH) AS REST_VEH, REST_W, REST_H, LINK_LENG, RMRK, \r\n"
  76. " DEL_YN, DFLT_SPED, DFLT_SPED_USE_YN, \r\n"
  77. " SECT_GRAD_CD, AREA_CD, \r\n"
  78. " DECODE(AREA_CD, 'LAT001', 'Y', 'N') REGN_YN, PARA_ID \r\n"
  79. " FROM TB_LINK \r\n";
  80. #endif
  81. FLists.Lock();
  82. try
  83. {
  84. FLists.RemoveAll();
  85. try
  86. {
  87. pADO = new TADOQuery(NULL);
  88. pADO->Close();
  89. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  90. pADO->SQL->Clear();
  91. pADO->SQL->Text = sQry;
  92. pADO->Prepared = true;
  93. pADO->Open();
  94. //int nRows = pADO->RecordCount;
  95. for( ; !pADO->Eof; pADO->Next())
  96. {
  97. TLink *pLink = new TLink();
  98. pLink->IsVertex = false;
  99. pLink->LINK_ID = pADO->FieldByName("LINK_ID")->AsString; //'링크ID';;
  100. pLink->F_NODE_ID = pADO->FieldByName("F_NODE_ID")->AsString; //'시작노드ID';;
  101. pLink->T_NODE_ID = pADO->FieldByName("T_NODE_ID")->AsString; //'종료노드ID';;
  102. pLink->ROAD_USE = pADO->FieldByName("ROAD_USE")->AsString; //'도로사용여부';;
  103. pLink->LANES = pADO->FieldByName("LANES")->AsString; //'차로수';;
  104. pLink->ROAD_RANK = pADO->FieldByName("ROAD_RANK")->AsString; //'도로등급';;
  105. pLink->ROAD_TYPE = pADO->FieldByName("ROAD_TYPE")->AsString; //'도로유형';;
  106. pLink->ROAD_NO = pADO->FieldByName("ROAD_NO")->AsString; //'도로번호';;
  107. pLink->ROAD_NAME = pADO->FieldByName("ROAD_NAME")->AsString.Trim(); //'도로명';;
  108. pLink->MULTI_LINK = pADO->FieldByName("MULTI_LINK")->AsString; //'중용구간여부';;
  109. pLink->LINK_CONNECT = pADO->FieldByName("LINK_CONNECT")->AsString; //'연결로코드';;
  110. pLink->MAX_SPD = pADO->FieldByName("MAX_SPD")->AsString; //'최고제한속도';;
  111. pLink->REST_VEH = pADO->FieldByName("REST_VEH")->AsString; //'통행제한차량';;
  112. pLink->REST_W = pADO->FieldByName("REST_W")->AsString; //'통과제한하중';;
  113. pLink->REST_H = pADO->FieldByName("REST_H")->AsString; //'통과제한높이';;
  114. pLink->LINK_LENG = pADO->FieldByName("LINK_LENG")->AsString; //'연장';;
  115. pLink->RMRK = pADO->FieldByName("RMRK")->AsString.Trim(); //'비고';;
  116. pLink->DEL_YN = pADO->FieldByName("DEL_YN")->AsString; //'삭제 여부';;
  117. pLink->DFLT_SPED = pADO->FieldByName("DFLT_SPED")->AsString; //'디폴트 속도';;
  118. pLink->DFLT_SPED_USE_YN = pADO->FieldByName("DFLT_SPED_USE_YN")->AsString; //'디폴트 속도 사용 여부';;
  119. pLink->SECT_GRAD_CD = pADO->FieldByName("SECT_GRAD_CD")->AsString; //'구간 등급 코드';;
  120. pLink->AREA_CD = pADO->FieldByName("AREA_CD")->AsString; //'지역 코드';;
  121. pLink->REGN_YN = pADO->FieldByName("REGN_YN")->AsString; //'로컬지역여부';
  122. pLink->PARA_ID = pADO->FieldByName("PARA_ID")->AsString; //'파라미터ID
  123. //pLink->REGN_YN = "Y";
  124. FLists.Push(pLink->LINK_ID, pLink);
  125. pLink->Completed = true;
  126. pLink->TRAF = new TCDSTraffic();
  127. }
  128. }
  129. catch(EDatabaseError &E)
  130. {
  131. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  132. DBERRORMSG("TLinkManager::LoadFromDb", String(E.ClassName()), E.Message, sQry);
  133. throw Exception(String(E.ClassName()) + E.Message);
  134. }
  135. catch(Exception &exception)
  136. {
  137. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  138. DBERRORMSG("TLinkManager::LoadFromDb", String(exception.ClassName()), exception.Message, sQry);
  139. throw Exception(String(exception.ClassName()) + exception.Message);
  140. }
  141. }
  142. __finally
  143. {
  144. if (pADO)
  145. {
  146. pADO->Close();
  147. delete pADO;
  148. }
  149. FLists.UnLock();
  150. }
  151. return LoadVrtxFromDb(ADbConn);
  152. }
  153. //---------------------------------------------------------------------------
  154. bool TLinkManager::LoadVrtxFromDb(TADOConnection *ADbConn/*=NULL*/)
  155. {
  156. String sQry;
  157. TADOQuery *pADO = NULL;
  158. #if 0
  159. sQry = "SELECT A.LINK_ID, A.LEVL, \r\n"
  160. " A.X_CRDN_ARR, A.Y_CRDN_ARR \r\n"
  161. " FROM TB_LINK_VRTX_ARR A, \r\n"
  162. " TB_LINK B \r\n"
  163. " WHERE B.DEL_YN = 'N' \r\n"
  164. " AND B.LINK_ID = A.LINK_ID \r\n"
  165. " AND A.LEVL = 1 \r\n";
  166. #else
  167. #if 0
  168. sQry = "SELECT * \r\n"
  169. " FROM VW_LINK_VRTX_ARR \r\n";
  170. #else
  171. sQry = "SELECT A.LINK_ID AS LINK_ID, A.LEVL AS LEVL, \r\n"
  172. " SUBSTR(A.X_CRDN_ARR, 1, 400) AS XMSG01, \r\n"
  173. " SUBSTR(A.X_CRDN_ARR, 401, 400) AS XMSG02, \r\n"
  174. " SUBSTR(A.X_CRDN_ARR, 801, 400) AS XMSG03, \r\n"
  175. " SUBSTR(A.X_CRDN_ARR, 1201, 400) AS XMSG04, \r\n"
  176. " SUBSTR(A.X_CRDN_ARR, 1601, 400) AS XMSG05, \r\n"
  177. " SUBSTR(A.X_CRDN_ARR, 2001, 400) AS XMSG06, \r\n"
  178. " SUBSTR(A.X_CRDN_ARR, 2401, 400) AS XMSG07, \r\n"
  179. " SUBSTR(A.X_CRDN_ARR, 2801, 400) AS XMSG08, \r\n"
  180. " SUBSTR(A.X_CRDN_ARR, 3201, 400) AS XMSG09, \r\n"
  181. " SUBSTR(A.X_CRDN_ARR, 3601, 400) AS XMSG10, \r\n"
  182. " SUBSTR(A.X_CRDN_ARR, 4001, 400) AS XMSG11, \r\n"
  183. " SUBSTR(A.X_CRDN_ARR, 4401, 400) AS XMSG12, \r\n"
  184. " SUBSTR(A.Y_CRDN_ARR, 1, 400) AS YMSG01, \r\n"
  185. " SUBSTR(A.Y_CRDN_ARR, 401, 400) AS YMSG02, \r\n"
  186. " SUBSTR(A.Y_CRDN_ARR, 801, 400) AS YMSG03, \r\n"
  187. " SUBSTR(A.Y_CRDN_ARR, 1201, 400) AS YMSG04, \r\n"
  188. " SUBSTR(A.Y_CRDN_ARR, 1601, 400) AS YMSG05, \r\n"
  189. " SUBSTR(A.Y_CRDN_ARR, 2001, 400) AS YMSG06, \r\n"
  190. " SUBSTR(A.Y_CRDN_ARR, 2401, 400) AS YMSG07, \r\n"
  191. " SUBSTR(A.Y_CRDN_ARR, 2801, 400) AS YMSG08, \r\n"
  192. " SUBSTR(A.Y_CRDN_ARR, 3201, 400) AS YMSG09, \r\n"
  193. " SUBSTR(A.Y_CRDN_ARR, 3601, 400) AS YMSG10, \r\n"
  194. " SUBSTR(A.Y_CRDN_ARR, 4001, 400) AS YMSG11, \r\n"
  195. " SUBSTR(A.Y_CRDN_ARR, 4401, 400) AS YMSG12 \r\n"
  196. " FROM VW_LINK_VRTX_ARR A \r\n";
  197. #endif
  198. #endif
  199. TLink* pObj;
  200. FLists.Lock();
  201. try
  202. {
  203. try
  204. {
  205. pADO = new TADOQuery(NULL);
  206. pADO->Close();
  207. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  208. pADO->SQL->Clear();
  209. pADO->SQL->Text = sQry;
  210. pADO->Prepared = true;
  211. pADO->Open();
  212. for( ; !pADO->Eof; pADO->Next())
  213. {
  214. String LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
  215. pObj = FLists.Find(LINK_ID);
  216. if (!pObj) continue;
  217. #if 0
  218. LEVL = pADO->FieldByName("LEVL")->AsInteger;
  219. TItsVrtx* pVrtx = new TItsVrtx();
  220. pVrtx->X_CRDN_ARR = pADO->FieldByName("X_CRDN_ARR")->AsString;
  221. pVrtx->Y_CRDN_ARR = pADO->FieldByName("Y_CRDN_ARR")->AsString;
  222. pObj->Vrtxs.Push(LEVL, pVrtx);
  223. #else
  224. pObj->IsVertex = true;
  225. #if 0
  226. pObj->X_CRDN_ARR = pADO->FieldByName("X_CRDN_ARR")->AsString;
  227. pObj->Y_CRDN_ARR = pADO->FieldByName("Y_CRDN_ARR")->AsString;
  228. #else
  229. pObj->X_CRDN_ARR = "";
  230. pObj->Y_CRDN_ARR = "";
  231. String COLM;
  232. for (int ii = 1; ii < 13; ii++)
  233. {
  234. COLM.printf(L"XMSG%02d", ii);
  235. pObj->X_CRDN_ARR += pADO->FieldByName(COLM)->AsString;
  236. COLM.printf(L"YMSG%02d", ii);
  237. pObj->Y_CRDN_ARR += pADO->FieldByName(COLM)->AsString;
  238. }
  239. #endif
  240. #endif
  241. }
  242. }
  243. catch(EDatabaseError &E)
  244. {
  245. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  246. DBERRORMSG("TLinkManager::LoadVrtxFromDb", String(E.ClassName()), E.Message, sQry);
  247. throw Exception(String(E.ClassName()) + E.Message);
  248. }
  249. catch(Exception &exception)
  250. {
  251. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  252. DBERRORMSG("TLinkManager::LoadVrtxFromDb", String(exception.ClassName()), exception.Message, sQry);
  253. throw Exception(String(exception.ClassName()) + exception.Message);
  254. }
  255. }
  256. __finally
  257. {
  258. if (pADO)
  259. {
  260. pADO->Close();
  261. delete pADO;
  262. }
  263. FLists.UnLock();
  264. }
  265. return true;
  266. }
  267. //---------------------------------------------------------------------------
  268. bool TLinkManager::LoadRegionVertexFromDb(TADOConnection *ADbConn/*=NULL*/)
  269. {
  270. String sQry;
  271. TADOQuery *pADO = NULL;
  272. sQry = "SELECT * FROM TB_REGION_VRTX WHERE CENTERID = 'L01'";
  273. try
  274. {
  275. try
  276. {
  277. pADO = new TADOQuery(NULL);
  278. pADO->Close();
  279. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  280. pADO->SQL->Clear();
  281. pADO->SQL->Text = sQry;
  282. pADO->Prepared = true;
  283. pADO->Open();
  284. for( ; !pADO->Eof; pADO->Next())
  285. {
  286. String CENTERID = pADO->FieldByName("CENTERID")->AsString;
  287. FRegionPointCnt = pADO->FieldByName("POINTCNT")->AsInteger;
  288. FRegionVertex = pADO->FieldByName("VERTEX")->AsString;
  289. }
  290. }
  291. catch(EDatabaseError &E)
  292. {
  293. DBERRORMSG("TLinkManager::LoadRegionVertexFromDb", String(E.ClassName()), E.Message, sQry);
  294. throw Exception(String(E.ClassName()) + E.Message);
  295. }
  296. catch(Exception &exception)
  297. {
  298. DBERRORMSG("TLinkManager::LoadRegionVertexFromDb", String(exception.ClassName()), exception.Message, sQry);
  299. throw Exception(String(exception.ClassName()) + exception.Message);
  300. }
  301. }
  302. __finally
  303. {
  304. if (pADO)
  305. {
  306. pADO->Close();
  307. delete pADO;
  308. }
  309. FLists.UnLock();
  310. }
  311. return true;
  312. }
  313. //---------------------------------------------------------------------------
  314. bool TLinkManager::LoadTraffic(TADOConnection *ADbConn/*=NULL*/)
  315. {
  316. bool bResult = true;
  317. String sQry;
  318. TADOQuery *pADO = NULL;
  319. InitTraffic();
  320. sQry = "SELECT A.LINK_ID, PRCN_DT, TFVL, SPED, OCPY_RATE, TRVL_HH, CMTR_GRAD_CD, MISS_YN, \r\n"
  321. " PRCN_SPED, SMTH_SPED, ADJS_SPED, PTRN_SPED, PRCN_SORC, ADJS_SORC, DATA_NUM, \r\n"
  322. " (CASE WHEN PRCN_DT <= TO_CHAR(SYSDATE - 10/1440, 'YYYYMMDDHH24MISS') \r\n"
  323. " THEN 'Y' ELSE 'N' END) AS MISSING, \r\n"
  324. " (CASE WHEN PRCN_DT >= TO_CHAR(SYSDATE - 15/1440, 'YYYYMMDDHH24MISS') \r\n"
  325. " THEN 'Y' ELSE 'N' END) AS LASTANS, \r\n"
  326. " (SELECT MAX(PRCN_DT) FROM TB_LINK_TRAF) MPRCN_DT \r\n"
  327. " FROM TB_LINK_TRAF A, TB_LINK B \r\n"
  328. " WHERE A.LINK_ID = B.LINK_ID \r\n";
  329. FLists.Lock();
  330. try
  331. {
  332. try
  333. {
  334. pADO = new TADOQuery(NULL);
  335. pADO->Close();
  336. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  337. pADO->SQL->Clear();
  338. pADO->SQL->Text = sQry;
  339. pADO->Prepared = true;
  340. pADO->Open();
  341. for( ; !pADO->Eof; pADO->Next())
  342. {
  343. String ID = pADO->FieldByName("LINK_ID")->AsString;
  344. TLink *pObj = FLists.Find(ID);
  345. if (!pObj) continue;
  346. pObj->TRAF->PRCN_DT = pADO->FieldByName("PRCN_DT")->AsString;
  347. pObj->TRAF->TFVL = pADO->FieldByName("TFVL")->AsInteger;
  348. pObj->TRAF->SPED = pADO->FieldByName("SPED")->AsInteger;
  349. pObj->TRAF->OCPY_RATE = pADO->FieldByName("OCPY_RATE")->AsFloat;
  350. pObj->TRAF->TRVL_HH = pADO->FieldByName("TRVL_HH")->AsInteger;
  351. pObj->TRAF->CMTR_GRAD_CD = pADO->FieldByName("CMTR_GRAD_CD")->AsString;
  352. pObj->TRAF->MISSING = pADO->FieldByName("MISSING")->AsString; // 결측여부
  353. pObj->TRAF->LASTANS = pADO->FieldByName("LASTANS")->AsString; // 최근 15분 이내 가공
  354. pObj->TRAF->MPRCN_DT = pADO->FieldByName("MPRCN_DT")->AsString; // 가공시각(최신)
  355. pObj->TRAF->DATA_NUM = pADO->FieldByName("DATA_NUM")->AsInteger;
  356. pObj->TRAF->PTRN_SPED = pADO->FieldByName("PTRN_SPED")->AsInteger;
  357. if (pObj->TRAF->CMTR_GRAD_CD == "LTC1") pObj->TRAF->TRAF_GRAD = 1;
  358. else if (pObj->TRAF->CMTR_GRAD_CD == "LTC2") pObj->TRAF->TRAF_GRAD = 2;
  359. else if (pObj->TRAF->CMTR_GRAD_CD == "LTC3") pObj->TRAF->TRAF_GRAD = 3;
  360. else pObj->TRAF->TRAF_GRAD = 0;
  361. pObj->TRAF->MISS_YN = pADO->FieldByName("MISS_YN")->AsString; // '결측 여부';
  362. pObj->TRAF->PRCN_SPED = pADO->FieldByName("PRCN_SPED")->AsInteger; // '가공 속도';
  363. pObj->TRAF->SMTH_SPED = pADO->FieldByName("SMTH_SPED")->AsInteger; // '평활화 속도';
  364. pObj->TRAF->ADJS_SPED = pADO->FieldByName("ADJS_SPED")->AsInteger; // '보정 속도';
  365. pObj->TRAF->PRCN_SORC = pADO->FieldByName("PRCN_SORC")->AsString; // '가공 소스';
  366. pObj->TRAF->ADJS_SORC = pADO->FieldByName("ADJS_SORC")->AsString; // '보정 소스';
  367. if (pObj->TRAF->CMTR_GRAD_CD == "LTC0" && pObj->TRAF->MISS_YN == "Y") pObj->TRAF->MISSING = "Y";
  368. }
  369. }
  370. catch(EDatabaseError &E)
  371. {
  372. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  373. DBERRORLOG("TLinkManager::LoadTraffic", String(E.ClassName()), E.Message, sQry);
  374. return false;
  375. throw Exception(String(E.ClassName()) + E.Message);
  376. }
  377. catch(Exception &exception)
  378. {
  379. ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
  380. DBERRORLOG("TLinkManager::LoadTraffic", String(exception.ClassName()), exception.Message, sQry);
  381. return false;
  382. throw Exception(String(exception.ClassName()) + exception.Message);
  383. }
  384. }
  385. __finally
  386. {
  387. if (pADO)
  388. {
  389. pADO->Close();
  390. delete pADO;
  391. }
  392. FLists.UnLock();
  393. }
  394. return bResult;
  395. }
  396. //---------------------------------------------------------------------------