//--------------------------------------------------------------------------- #pragma hdrstop #include "CDSLinkF.h" #include "CDSLayerF.h" #include "ITS_OPLibF.h" //--------------------------------------------------------------------------- #pragma package(smart_init) TItsLink::TItsLink() { IFSC_ID = ""; ROAD_ID = ""; Clear(); } //--------------------------------------------------------------------------- void TItsLink::Clear() { } //--------------------------------------------------------------------------- TItsLink::~TItsLink() { } //--------------------------------------------------------------------------- void TItsLink::InitTraffic() { TRAF->InitTraffic(); } //--------------------------------------------------------------------------- //--------------------------------------------------------------------------- TItsLinkManager *ItsLinkManager = NULL; //--------------------------------------------------------------------------- /* * Link Manager */ TItsLinkManager::TItsLinkManager() { } //--------------------------------------------------------------------------- TItsLinkManager::~TItsLinkManager() { FLists.RemoveAll(); FClctSystStts.RemoveAll(); } //--------------------------------------------------------------------------- void TItsLinkManager::InitTraffic() { try { FLists.Lock(); FOR_STL(TItsLink*, pObj, FLists) { pObj->InitTraffic(); } } __finally { FLists.UnLock(); } } //--------------------------------------------------------------------------- bool TItsLinkManager::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()) { TItsLink *pLink = new TItsLink(); 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("TItsLinkManager::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("TItsLinkManager::LoadFromDb", String(exception.ClassName()), exception.Message, sQry); throw Exception(String(exception.ClassName()) + exception.Message); } } __finally { if (pADO) { pADO->Close(); delete pADO; } FLists.UnLock(); } if (g_AppCfg.isLoadFromFile) { return LoadVrtxFromFile(ADbConn); } return LoadVrtxFromDb(ADbConn); } //--------------------------------------------------------------------------- bool TItsLinkManager::LoadVrtxFromFile(TADOConnection *ADbConn/*=NULL*/) { String sQry; AnsiString sAppDir = ExtractFilePath(Application->ExeName); AnsiString sFileName = sAppDir + "\\MAPDATA\\layers\\LINK.dat"; sQry = String(sFileName); FILE *fd; if ((fd = fopen(sFileName.c_str(), "r")) == NULL) { return false; } FLists.Lock(); TStringList *sl = NULL; char szBuff[8192]; int nCnt = 0; try { sl = new TStringList; sl->Delimiter = ';'; sl->StrictDelimiter = true; while (1) { nCnt++; memset(szBuff, 0x00, sizeof(szBuff)); if (fgets(szBuff, sizeof(szBuff), fd) == NULL) break; sl->DelimitedText = String(szBuff); if (sl->Count != 3) { continue; } try { String LINK_ID = sl->Strings[0]; TItsLink *pObj = FLists.Find(LINK_ID); if (pObj) { pObj->IsVertex = true; pObj->X_CRDN_ARR = sl->Strings[1]; //pObj->Y_CRDN_ARR = sl->Strings[2]; pObj->Y_CRDN_ARR = StringReplace(sl->Strings[2], "\n", "", TReplaceFlags() << rfReplaceAll); } } catch(Exception &e) { DBERRORMSG("TItsLinkManager::LoadVertexFromDb", String(e.ClassName()), e.Message, sQry); throw Exception(String(e.ClassName()) + e.Message); } } } __finally { if (sl) delete sl; if (fd) fclose(fd); FLists.UnLock(); } return true; } //--------------------------------------------------------------------------- bool TItsLinkManager::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 #if 0 sQry = "SELECT * \r\n" " FROM VW_LINK_VRTX_ARR \r\n"; #else sQry = "SELECT A.LINK_ID AS LINK_ID, A.LEVL AS LEVL, \r\n" " SUBSTR(A.X_CRDN_ARR, 1, 400) AS XMSG01, \r\n" " SUBSTR(A.X_CRDN_ARR, 401, 400) AS XMSG02, \r\n" " SUBSTR(A.X_CRDN_ARR, 801, 400) AS XMSG03, \r\n" " SUBSTR(A.X_CRDN_ARR, 1201, 400) AS XMSG04, \r\n" " SUBSTR(A.X_CRDN_ARR, 1601, 400) AS XMSG05, \r\n" " SUBSTR(A.X_CRDN_ARR, 2001, 400) AS XMSG06, \r\n" " SUBSTR(A.X_CRDN_ARR, 2401, 400) AS XMSG07, \r\n" " SUBSTR(A.X_CRDN_ARR, 2801, 400) AS XMSG08, \r\n" " SUBSTR(A.X_CRDN_ARR, 3201, 400) AS XMSG09, \r\n" " SUBSTR(A.X_CRDN_ARR, 3601, 400) AS XMSG10, \r\n" " SUBSTR(A.X_CRDN_ARR, 4001, 400) AS XMSG11, \r\n" " SUBSTR(A.X_CRDN_ARR, 4401, 400) AS XMSG12, \r\n" " SUBSTR(A.Y_CRDN_ARR, 1, 400) AS YMSG01, \r\n" " SUBSTR(A.Y_CRDN_ARR, 401, 400) AS YMSG02, \r\n" " SUBSTR(A.Y_CRDN_ARR, 801, 400) AS YMSG03, \r\n" " SUBSTR(A.Y_CRDN_ARR, 1201, 400) AS YMSG04, \r\n" " SUBSTR(A.Y_CRDN_ARR, 1601, 400) AS YMSG05, \r\n" " SUBSTR(A.Y_CRDN_ARR, 2001, 400) AS YMSG06, \r\n" " SUBSTR(A.Y_CRDN_ARR, 2401, 400) AS YMSG07, \r\n" " SUBSTR(A.Y_CRDN_ARR, 2801, 400) AS YMSG08, \r\n" " SUBSTR(A.Y_CRDN_ARR, 3201, 400) AS YMSG09, \r\n" " SUBSTR(A.Y_CRDN_ARR, 3601, 400) AS YMSG10, \r\n" " SUBSTR(A.Y_CRDN_ARR, 4001, 400) AS YMSG11, \r\n" " SUBSTR(A.Y_CRDN_ARR, 4401, 400) AS YMSG12 \r\n" " FROM VW_LINK_VRTX_ARR A \r\n"; #endif #endif TItsLink* 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; #if 0 pObj->X_CRDN_ARR = pADO->FieldByName("X_CRDN_ARR")->AsString; pObj->Y_CRDN_ARR = pADO->FieldByName("Y_CRDN_ARR")->AsString; #else pObj->X_CRDN_ARR = ""; pObj->Y_CRDN_ARR = ""; String COLM; for (int ii = 1; ii < 13; ii++) { COLM.printf(L"XMSG%02d", ii); pObj->X_CRDN_ARR += pADO->FieldByName(COLM)->AsString; COLM.printf(L"YMSG%02d", ii); pObj->Y_CRDN_ARR += pADO->FieldByName(COLM)->AsString; } #endif #endif } } catch(EDatabaseError &E) { ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2); DBERRORMSG("TItsLinkManager::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("TItsLinkManager::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 TItsLinkManager::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("TItsLinkManager::LoadRegionVertexFromDb", String(E.ClassName()), E.Message, sQry); throw Exception(String(E.ClassName()) + E.Message); } catch(Exception &exception) { DBERRORMSG("TItsLinkManager::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 TItsLinkManager::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; TItsLink *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 == "LTC0") pObj->TRAF->MISSING = "Y"; if (pObj->TRAF->MISSING == "Y") pObj->TRAF->CMTR_GRAD_CD = "LTC0"; 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("TItsLinkManager::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("TItsLinkManager::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; } //--------------------------------------------------------------------------- bool TItsLinkManager::LoadClctSystStts(TADOConnection *ADbConn/*=NULL*/) { bool bResult = true; String sQry; TADOQuery *pADO = NULL; FOR_STL(TClctSystStts*, pObj, FClctSystStts) { pObj->IsCollected = false; } sQry = "SELECT A.PRCN_DT, A.CLCT_SYST_CD, B.CLCT_SYST_NM, A.CLCT_NUM, A.FLTR_NUM, A.FUSN_NUM \r\n" " FROM TB_CLCT_SYST_STTS_HS A, \r\n" " TB_CLCT_SYST_STUP B \r\n" " WHERE A.PRCN_DT = (SELECT MAX(PRCN_DT) \r\n" " FROM TB_CLCT_SYST_STTS_HS \r\n" " WHERE PRCN_DT >= TO_CHAR(SYSDATE - 1/24, 'YYYYMMDDHH24MISS') \r\n" " ) \r\n" " AND B.CLCT_SYST_CD = A.CLCT_SYST_CD(+) \r\n" " AND B.USE_YN = 'Y' \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 CLCT_SYST_CD = pADO->FieldByName("CLCT_SYST_CD")->AsString; TClctSystStts *pObj = FClctSystStts.Find(CLCT_SYST_CD); if (!pObj) { pObj = new TClctSystStts(); pObj->CLCT_SYST_CD = CLCT_SYST_CD; FClctSystStts.Push(pObj->CLCT_SYST_CD, pObj); } pObj->CLCT_SYST_NM = pADO->FieldByName("CLCT_SYST_NM")->AsString; pObj->PRCN_DT = pADO->FieldByName("PRCN_DT")->AsString; pObj->CLCT_NUM = pADO->FieldByName("CLCT_NUM")->AsInteger; pObj->FLTR_NUM = pADO->FieldByName("FLTR_NUM")->AsInteger; pObj->FUSN_NUM = pADO->FieldByName("FUSN_NUM")->AsInteger; pObj->IsCollected = true; } } catch(EDatabaseError &E) { ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2); DBERRORLOG("TItsLinkManager::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("TItsLinkManager::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; } //---------------------------------------------------------------------------