123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380 |
- //---------------------------------------------------------------------------
- #pragma hdrstop
- #include "CDSLink_VMSF.h"
- #include "ITSUtilF.h"
- #include "AppGlobalF.h"
- //---------------------------------------------------------------------------
- #pragma package(smart_init)
- TLink::TLink()
- {
- IFSC_ID = "";
- ROAD_ID = "";
- Clear();
- }
- //---------------------------------------------------------------------------
- void TLink::Clear()
- {
- }
- //---------------------------------------------------------------------------
- TLink::~TLink()
- {
- }
- //---------------------------------------------------------------------------
- void TLink::InitTraffic()
- {
- TRAF->InitTraffic();
- }
- //---------------------------------------------------------------------------
- //---------------------------------------------------------------------------
- TLinkManager *LinkManager = NULL;
- //---------------------------------------------------------------------------
- /*
- * Link Manager
- */
- TLinkManager::TLinkManager()
- {
- }
- //---------------------------------------------------------------------------
- TLinkManager::~TLinkManager()
- {
- }
- //---------------------------------------------------------------------------
- void TLinkManager::InitTraffic()
- {
- try
- {
- FLists.Lock();
- FOR_STL(TLink*, pObj, FLists)
- {
- pObj->InitTraffic();
- }
- }
- __finally
- {
- FLists.UnLock();
- }
- }
- //---------------------------------------------------------------------------
- bool TLinkManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
- {
- String sQry;
- TADOQuery *pADO = NULL;
- sQry = "SELECT LINK_ID, F_NODE_ID, T_NODE_ID, ROAD_USE, LANES, \r\n"
- " ROAD_RANK, TRIM(ROAD_TYPE) AS ROAD_TYPE, ROAD_NO, TRIM(ROAD_NAME) ROAD_NAME, \r\n"
- " MULTI_LINK, TRIM(LINK_CONNECT) AS LINK_CONNECT, MAX_SPD, \r\n"
- " TRIM(REST_VEH) AS REST_VEH, REST_W, REST_H, LINK_LENG, RMRK, \r\n"
- " DEL_YN, DFLT_SPED, DFLT_SPED_USE_YN, \r\n"
- " SECT_GRAD_CD, AREA_CD, \r\n"
- " DECODE(AREA_CD, 'LAT001', 'Y', 'N') REGN_YN, PARA_ID \r\n"
- " FROM TB_LINK \r\n";
- FLists.Lock();
- try
- {
- FLists.RemoveAll();
- try
- {
- pADO = new TADOQuery(NULL);
- pADO->Close();
- pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
- pADO->SQL->Clear();
- pADO->SQL->Text = sQry;
- pADO->Prepared = true;
- pADO->Open();
- //int nRows = pADO->RecordCount;
- for( ; !pADO->Eof; pADO->Next())
- {
- TLink *pLink = new TLink();
- pLink->IsVertex = false;
- pLink->LINK_ID = pADO->FieldByName("LINK_ID")->AsString; //'링크ID';;
- pLink->F_NODE_ID = pADO->FieldByName("F_NODE_ID")->AsString; //'시작노드ID';;
- pLink->T_NODE_ID = pADO->FieldByName("T_NODE_ID")->AsString; //'종료노드ID';;
- pLink->ROAD_USE = pADO->FieldByName("ROAD_USE")->AsString; //'도로사용여부';;
- pLink->LANES = pADO->FieldByName("LANES")->AsString; //'차로수';;
- pLink->ROAD_RANK = pADO->FieldByName("ROAD_RANK")->AsString; //'도로등급';;
- pLink->ROAD_TYPE = pADO->FieldByName("ROAD_TYPE")->AsString; //'도로유형';;
- pLink->ROAD_NO = pADO->FieldByName("ROAD_NO")->AsString; //'도로번호';;
- pLink->ROAD_NAME = pADO->FieldByName("ROAD_NAME")->AsString.Trim(); //'도로명';;
- pLink->MULTI_LINK = pADO->FieldByName("MULTI_LINK")->AsString; //'중용구간여부';;
- pLink->LINK_CONNECT = pADO->FieldByName("LINK_CONNECT")->AsString; //'연결로코드';;
- pLink->MAX_SPD = pADO->FieldByName("MAX_SPD")->AsString; //'최고제한속도';;
- pLink->REST_VEH = pADO->FieldByName("REST_VEH")->AsString; //'통행제한차량';;
- pLink->REST_W = pADO->FieldByName("REST_W")->AsString; //'통과제한하중';;
- pLink->REST_H = pADO->FieldByName("REST_H")->AsString; //'통과제한높이';;
- pLink->LINK_LENG = pADO->FieldByName("LINK_LENG")->AsString; //'연장';;
- pLink->RMRK = pADO->FieldByName("RMRK")->AsString.Trim(); //'비고';;
- pLink->DEL_YN = pADO->FieldByName("DEL_YN")->AsString; //'삭제 여부';;
- pLink->DFLT_SPED = pADO->FieldByName("DFLT_SPED")->AsString; //'디폴트 속도';;
- pLink->DFLT_SPED_USE_YN = pADO->FieldByName("DFLT_SPED_USE_YN")->AsString; //'디폴트 속도 사용 여부';;
- pLink->SECT_GRAD_CD = pADO->FieldByName("SECT_GRAD_CD")->AsString; //'구간 등급 코드';;
- pLink->AREA_CD = pADO->FieldByName("AREA_CD")->AsString; //'지역 코드';;
- pLink->REGN_YN = pADO->FieldByName("REGN_YN")->AsString; //'로컬지역여부';
- pLink->PARA_ID = pADO->FieldByName("PARA_ID")->AsString; //'파라미터ID
- //pLink->REGN_YN = "Y";
- FLists.Push(pLink->LINK_ID, pLink);
- pLink->Completed = true;
- pLink->TRAF = new TCDSTraffic();
- }
- }
- catch(EDatabaseError &E)
- {
- ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
- DBERRORMSG("TLinkManager::LoadFromDb", String(E.ClassName()), E.Message, sQry);
- throw Exception(String(E.ClassName()) + E.Message);
- }
- catch(Exception &exception)
- {
- ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
- DBERRORMSG("TLinkManager::LoadFromDb", String(exception.ClassName()), exception.Message, sQry);
- throw Exception(String(exception.ClassName()) + exception.Message);
- }
- }
- __finally
- {
- if (pADO)
- {
- pADO->Close();
- delete pADO;
- }
- FLists.UnLock();
- }
- return LoadVrtxFromDb(ADbConn);
- }
- //---------------------------------------------------------------------------
- bool TLinkManager::LoadVrtxFromDb(TADOConnection *ADbConn/*=NULL*/)
- {
- String sQry;
- TADOQuery *pADO = NULL;
- #if 0
- sQry = "SELECT A.LINK_ID, A.LEVL, \r\n"
- " A.X_CRDN_ARR, A.Y_CRDN_ARR \r\n"
- " FROM TB_LINK_VRTX_ARR A, \r\n"
- " TB_LINK B \r\n"
- " WHERE B.DEL_YN = 'N' \r\n"
- " AND B.LINK_ID = A.LINK_ID \r\n"
- " AND A.LEVL = 1 \r\n";
- #else
- sQry = "SELECT * \r\n"
- " FROM VW_LINK_VRTX_ARR \r\n";
- #endif
- TLink* pObj;
- FLists.Lock();
- try
- {
- try
- {
- pADO = new TADOQuery(NULL);
- pADO->Close();
- pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
- pADO->SQL->Clear();
- pADO->SQL->Text = sQry;
- pADO->Prepared = true;
- pADO->Open();
- for( ; !pADO->Eof; pADO->Next())
- {
- String LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
- pObj = FLists.Find(LINK_ID);
- if (!pObj) continue;
- #if 0
- LEVL = pADO->FieldByName("LEVL")->AsInteger;
- TItsVrtx* pVrtx = new TItsVrtx();
- pVrtx->X_CRDN_ARR = pADO->FieldByName("X_CRDN_ARR")->AsString;
- pVrtx->Y_CRDN_ARR = pADO->FieldByName("Y_CRDN_ARR")->AsString;
- pObj->Vrtxs.Push(LEVL, pVrtx);
- #else
- pObj->IsVertex = true;
- pObj->X_CRDN_ARR = pADO->FieldByName("X_CRDN_ARR")->AsString;
- pObj->Y_CRDN_ARR = pADO->FieldByName("Y_CRDN_ARR")->AsString;
- #endif
- }
- }
- catch(EDatabaseError &E)
- {
- ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
- DBERRORMSG("TLinkManager::LoadVrtxFromDb", String(E.ClassName()), E.Message, sQry);
- throw Exception(String(E.ClassName()) + E.Message);
- }
- catch(Exception &exception)
- {
- ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
- DBERRORMSG("TLinkManager::LoadVrtxFromDb", String(exception.ClassName()), exception.Message, sQry);
- throw Exception(String(exception.ClassName()) + exception.Message);
- }
- }
- __finally
- {
- if (pADO)
- {
- pADO->Close();
- delete pADO;
- }
- FLists.UnLock();
- }
- return true;
- }
- //---------------------------------------------------------------------------
- bool TLinkManager::LoadRegionVertexFromDb(TADOConnection *ADbConn/*=NULL*/)
- {
- String sQry;
- TADOQuery *pADO = NULL;
- sQry = "SELECT * FROM TB_REGION_VRTX WHERE CENTERID = 'L01'";
- try
- {
- try
- {
- pADO = new TADOQuery(NULL);
- pADO->Close();
- pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
- pADO->SQL->Clear();
- pADO->SQL->Text = sQry;
- pADO->Prepared = true;
- pADO->Open();
- for( ; !pADO->Eof; pADO->Next())
- {
- String CENTERID = pADO->FieldByName("CENTERID")->AsString;
- FRegionPointCnt = pADO->FieldByName("POINTCNT")->AsInteger;
- FRegionVertex = pADO->FieldByName("VERTEX")->AsString;
- }
- }
- catch(EDatabaseError &E)
- {
- DBERRORMSG("TLinkManager::LoadRegionVertexFromDb", String(E.ClassName()), E.Message, sQry);
- throw Exception(String(E.ClassName()) + E.Message);
- }
- catch(Exception &exception)
- {
- DBERRORMSG("TLinkManager::LoadRegionVertexFromDb", String(exception.ClassName()), exception.Message, sQry);
- throw Exception(String(exception.ClassName()) + exception.Message);
- }
- }
- __finally
- {
- if (pADO)
- {
- pADO->Close();
- delete pADO;
- }
- FLists.UnLock();
- }
- return true;
- }
- //---------------------------------------------------------------------------
- bool TLinkManager::LoadTraffic(TADOConnection *ADbConn/*=NULL*/)
- {
- bool bResult = true;
- String sQry;
- TADOQuery *pADO = NULL;
- InitTraffic();
- sQry = "SELECT A.LINK_ID, PRCN_DT, TFVL, SPED, OCPY_RATE, TRVL_HH, CMTR_GRAD_CD, MISS_YN, \r\n"
- " PRCN_SPED, SMTH_SPED, ADJS_SPED, PTRN_SPED, PRCN_SORC, ADJS_SORC, DATA_NUM, \r\n"
- " (CASE WHEN PRCN_DT <= TO_CHAR(SYSDATE - 10/1440, 'YYYYMMDDHH24MISS') \r\n"
- " THEN 'Y' ELSE 'N' END) AS MISSING, \r\n"
- " (CASE WHEN PRCN_DT >= TO_CHAR(SYSDATE - 15/1440, 'YYYYMMDDHH24MISS') \r\n"
- " THEN 'Y' ELSE 'N' END) AS LASTANS, \r\n"
- " (SELECT MAX(PRCN_DT) FROM TB_LINK_TRAF) MPRCN_DT \r\n"
- " FROM TB_LINK_TRAF A, TB_LINK B \r\n"
- " WHERE A.LINK_ID = B.LINK_ID \r\n";
- FLists.Lock();
- try
- {
- try
- {
- pADO = new TADOQuery(NULL);
- pADO->Close();
- pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
- pADO->SQL->Clear();
- pADO->SQL->Text = sQry;
- pADO->Prepared = true;
- pADO->Open();
- for( ; !pADO->Eof; pADO->Next())
- {
- String ID = pADO->FieldByName("LINK_ID")->AsString;
- TLink *pObj = FLists.Find(ID);
- if (!pObj) continue;
- pObj->TRAF->PRCN_DT = pADO->FieldByName("PRCN_DT")->AsString;
- pObj->TRAF->TFVL = pADO->FieldByName("TFVL")->AsInteger;
- pObj->TRAF->SPED = pADO->FieldByName("SPED")->AsInteger;
- pObj->TRAF->OCPY_RATE = pADO->FieldByName("OCPY_RATE")->AsFloat;
- pObj->TRAF->TRVL_HH = pADO->FieldByName("TRVL_HH")->AsInteger;
- pObj->TRAF->CMTR_GRAD_CD = pADO->FieldByName("CMTR_GRAD_CD")->AsString;
- pObj->TRAF->MISSING = pADO->FieldByName("MISSING")->AsString; // 결측여부
- pObj->TRAF->LASTANS = pADO->FieldByName("LASTANS")->AsString; // 최근 15분 이내 가공
- pObj->TRAF->MPRCN_DT = pADO->FieldByName("MPRCN_DT")->AsString; // 가공시각(최신)
- pObj->TRAF->DATA_NUM = pADO->FieldByName("DATA_NUM")->AsInteger;
- pObj->TRAF->PTRN_SPED = pADO->FieldByName("PTRN_SPED")->AsInteger;
- if (pObj->TRAF->CMTR_GRAD_CD == "LTC1") pObj->TRAF->TRAF_GRAD = 1;
- else if (pObj->TRAF->CMTR_GRAD_CD == "LTC2") pObj->TRAF->TRAF_GRAD = 2;
- else if (pObj->TRAF->CMTR_GRAD_CD == "LTC3") pObj->TRAF->TRAF_GRAD = 3;
- else pObj->TRAF->TRAF_GRAD = 0;
- pObj->TRAF->MISS_YN = pADO->FieldByName("MISS_YN")->AsString; // '결측 여부';
- pObj->TRAF->PRCN_SPED = pADO->FieldByName("PRCN_SPED")->AsInteger; // '가공 속도';
- pObj->TRAF->SMTH_SPED = pADO->FieldByName("SMTH_SPED")->AsInteger; // '평활화 속도';
- pObj->TRAF->ADJS_SPED = pADO->FieldByName("ADJS_SPED")->AsInteger; // '보정 속도';
- pObj->TRAF->PRCN_SORC = pADO->FieldByName("PRCN_SORC")->AsString; // '가공 소스';
- pObj->TRAF->ADJS_SORC = pADO->FieldByName("ADJS_SORC")->AsString; // '보정 소스';
- if (pObj->TRAF->CMTR_GRAD_CD == "LTC0" && pObj->TRAF->MISS_YN == "Y") pObj->TRAF->MISSING = "Y";
- }
- }
- catch(EDatabaseError &E)
- {
- ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
- DBERRORLOG("TLinkManager::LoadTraffic", String(E.ClassName()), E.Message, sQry);
- return false;
- throw Exception(String(E.ClassName()) + E.Message);
- }
- catch(Exception &exception)
- {
- ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
- DBERRORLOG("TLinkManager::LoadTraffic", String(exception.ClassName()), exception.Message, sQry);
- return false;
- throw Exception(String(exception.ClassName()) + exception.Message);
- }
- }
- __finally
- {
- if (pADO)
- {
- pADO->Close();
- delete pADO;
- }
- FLists.UnLock();
- }
- return bResult;
- }
- //---------------------------------------------------------------------------
|