//--------------------------------------------------------------------------- #pragma hdrstop #include "CDSRepeatCongestF.h" #include "AppGlobalF.h" //--------------------------------------------------------------------------- #pragma package(smart_init) TItsRepeatCongest::TItsRepeatCongest() { Clear(); } //--------------------------------------------------------------------------- void TItsRepeatCongest::Clear() { #if 0 //FIFSC_ID = ""; // 정보제공구간 ID FSTAT_YM = ""; // 통계 년월 FDAY_TYPE_CD = ""; // 요일 유형 코드 FCNFS_STRT_HM = ""; // 혼잡 시작 시분 FCNFS_END_HM = ""; // 혼잡 종료 시분 FAVRG_SPED = ""; // 평균 속도 FAVRG_TRVL_HH = ""; // 평균 통행 시간 FDCSN_YN = ""; // 확정 여부 FCRTN_YMD = ""; // 생성 일자 FREPT_CNGS_SECT_ORGN_CD = ""; // 반복 정체 구간 원본 코드 #endif } //--------------------------------------------------------------------------- TItsRepeatCongest::~TItsRepeatCongest() { } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetValue(String &AOrgValue, String AValue) { if (AOrgValue != AValue) { AOrgValue = AValue; if (FCompleted) FModified = true; } } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetFIFSC_ID(String AValue) { SetValue(FIFSC_ID, AValue); } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetFSTAT_YM(String AValue) { SetValue(FSTAT_YM, AValue); } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetFDAY_TYPE_CD(String AValue) { SetValue(FDAY_TYPE_CD, AValue); } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetFCNFS_STRT_HM(String AValue) { SetValue(FCNFS_STRT_HM, AValue); } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetFCNFS_END_HM(String AValue) { SetValue(FCNFS_END_HM, AValue); } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetFAVRG_SPED(String AValue) { SetValue(FAVRG_SPED, AValue); } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetFAVRG_TRVL_HH(String AValue) { SetValue(FAVRG_TRVL_HH, AValue); } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetFDCSN_YN(String AValue) { SetValue(FDCSN_YN, AValue); } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetFCRTN_YMD(String AValue) { SetValue(FCRTN_YMD, AValue); } //--------------------------------------------------------------------------- void TItsRepeatCongest::SetFREPT_CNGS_SECT_ORGN_CD(String AValue) { SetValue(FREPT_CNGS_SECT_ORGN_CD, AValue); } //--------------------------------------------------------------------------- //--------------------------------------------------------------------------- TItsRepeatCongestManager *ItsRepeatCongestManager = NULL; //--------------------------------------------------------------------------- /* * RepeatCongest Manager */ TItsRepeatCongestManager::TItsRepeatCongestManager() { } //--------------------------------------------------------------------------- TItsRepeatCongestManager::~TItsRepeatCongestManager() { } //--------------------------------------------------------------------------- bool TItsRepeatCongestManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/) { bool bResult = true; String sQry; TADOQuery *pADO = NULL; sQry = "SELECT * \r\n" " FROM TB_REPT_CNGS_SECT \r\n"; // " ORDER BY IFSC_ID \r\n"; try { FDataSeq = 0; FLists.Lock(); FListsCnfm.Lock(); FLists.RemoveAll(); FListsCnfm.RemoveAll(); try { pADO = new TADOQuery(NULL); pADO->Close(); pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection(); pADO->SQL->Clear(); pADO->SQL->Text = sQry; pADO->Open(); for( ; !pADO->Eof; pADO->Next()) { TItsRepeatCongest *pRepeatCongest = new TItsRepeatCongest(); pRepeatCongest->FIFSC_ID = pADO->FieldByName("IFSC_ID")->AsString; // 정보제공구간 ID pRepeatCongest->FSTAT_YM = pADO->FieldByName("CRTN_YMD")->AsString; // 통계 년월 pRepeatCongest->FDAY_TYPE_CD = pADO->FieldByName("DAY_TYPE_CD")->AsString; // 요일 유형 코드 pRepeatCongest->FCNFS_STRT_HM = pADO->FieldByName("CNFS_STRT_HM")->AsString; // 혼잡 시작 시분 pRepeatCongest->FCNFS_END_HM = pADO->FieldByName("CNFS_END_HM")->AsString; // 혼잡 종료 시분 pRepeatCongest->FAVRG_SPED = pADO->FieldByName("AVRG_SPED")->AsString; // 평균 속도 pRepeatCongest->FAVRG_TRVL_HH = pADO->FieldByName("AVRG_TRVL_HH")->AsString; // 평균 통행 시간 pRepeatCongest->FDCSN_YN = pADO->FieldByName("DCSN_YN")->AsString; // 확정 여부 pRepeatCongest->FCRTN_YMD = pADO->FieldByName("CRTN_YMD")->AsString; // 생성 일자 pRepeatCongest->FREPT_CNGS_SECT_ORGN_CD = pADO->FieldByName("REPT_CNGS_SECT_ORGN_CD")->AsString; // 반복 정체 구간 원본 코드 if( pRepeatCongest->FDCSN_YN != "Y" ) FLists.Push(String(FDataSeq++), pRepeatCongest); else FListsCnfm.Push(String(FDataSeq++), pRepeatCongest); pRepeatCongest->Completed = true; } } catch(EDatabaseError &E) { ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2); DBERRORLOG("TItsRepeatCongestManager::LoadFromDb", 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("TItsRepeatCongestManager::LoadFromDb", String(exception.ClassName()), exception.Message, sQry); return false; throw Exception(String(exception.ClassName()) + exception.Message); } } __finally { if (pADO) { pADO->Close(); delete pADO; } FLists.UnLock(); FListsCnfm.UnLock(); } #if 1 return bResult; #else return LoadFromDbWthrCnfm(ADbConn); #endif } //--------------------------------------------------------------------------- bool TItsRepeatCongestManager::LoadFromDbWthr(TADOConnection *ADbConn/*=NULL*/) { bool bResult = true; String sQry; TADOQuery *pADO = NULL; sQry = "SELECT * \r\n" " FROM TB_REPT_CNGS_SECT_WTHR \r\n"; // " ORDER BY IFSC_ID \r\n"; try { FDataSeqWthr = 0; FListsWthr.Lock(); FListsCnfmWthr.Lock(); FListsWthr.RemoveAll(); FListsCnfmWthr.RemoveAll(); try { pADO = new TADOQuery(NULL); pADO->Close(); pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection(); pADO->SQL->Clear(); pADO->SQL->Text = sQry; pADO->Open(); for( ; !pADO->Eof; pADO->Next()) { TItsRepeatCongestWthr *pRepeatCongest = new TItsRepeatCongestWthr(); pRepeatCongest->IFSC_ID = pADO->FieldByName("IFSC_ID")->AsString; // 정보제공구간 ID pRepeatCongest->CRTN_YMD = pADO->FieldByName("CRTN_YMD")->AsString; // 생성 일자 pRepeatCongest->WTHR_TYPE_CD = pADO->FieldByName("WTHR_TYPE_CD")->AsString; // 기상 코드 pRepeatCongest->CNFS_STRT_HM = pADO->FieldByName("CNFS_STRT_HM")->AsString; // 혼잡 시작 시분 pRepeatCongest->CNFS_END_HM = pADO->FieldByName("CNFS_END_HM")->AsString; // 혼잡 종료 시분 pRepeatCongest->AVRG_SPED = pADO->FieldByName("AVRG_SPED")->AsString; // 평균 속도 pRepeatCongest->AVRG_TRVL_HH = pADO->FieldByName("AVRG_TRVL_HH")->AsString; // 평균 통행 시간 pRepeatCongest->DCSN_YN = pADO->FieldByName("DCSN_YN")->AsString; // 확정 여부 pRepeatCongest->REPT_CNGS_SECT_ORGN_CD = pADO->FieldByName("REPT_CNGS_SECT_ORGN_CD")->AsString; // 반복 정체 구간 원본 코드 if( pRepeatCongest->DCSN_YN != "Y" ) FListsWthr.Push(String(FDataSeqWthr++), pRepeatCongest); else FListsCnfmWthr.Push(String(FDataSeqWthr++), pRepeatCongest); pRepeatCongest->Completed = true; } } catch(EDatabaseError &E) { ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2); DBERRORLOG("TItsRepeatCongestManager::LoadFromDbWthr", 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("TItsRepeatCongestManager::LoadFromDbWthr", String(exception.ClassName()), exception.Message, sQry); return false; throw Exception(String(exception.ClassName()) + exception.Message); } } __finally { if (pADO) { pADO->Close(); delete pADO; } FListsWthr.UnLock(); FListsCnfmWthr.UnLock(); } return bResult; } //--------------------------------------------------------------------------- bool TItsRepeatCongestManager::LoadFromDbWthrCnfm(TADOConnection *ADbConn/*=NULL*/) { bool bResult = true; String sQry; TADOQuery *pADO = NULL; sQry = "SELECT * \r\n" " FROM TB_REPT_CNGS_SECT_WTHR \r\n" " WHERE DCSN_YN = 'Y' \r\n"; // " ORDER BY IFSC_ID \r\n"; try { FDataSeqWthr = 0; FListsWthr.Lock(); FListsCnfmWthr.Lock(); FListsWthr.RemoveAll(); FListsCnfmWthr.RemoveAll(); try { pADO = new TADOQuery(NULL); pADO->Close(); pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection(); pADO->SQL->Clear(); pADO->SQL->Text = sQry; pADO->Open(); for( ; !pADO->Eof; pADO->Next()) { TItsRepeatCongestWthr *pRepeatCongest = new TItsRepeatCongestWthr(); pRepeatCongest->IFSC_ID = pADO->FieldByName("IFSC_ID")->AsString; // 정보제공구간 ID pRepeatCongest->CRTN_YMD = pADO->FieldByName("CRTN_YMD")->AsString; // 생성 일자 pRepeatCongest->WTHR_TYPE_CD = pADO->FieldByName("WTHR_TYPE_CD")->AsString; // 기상 코드 pRepeatCongest->CNFS_STRT_HM = pADO->FieldByName("CNFS_STRT_HM")->AsString; // 혼잡 시작 시분 pRepeatCongest->CNFS_END_HM = pADO->FieldByName("CNFS_END_HM")->AsString; // 혼잡 종료 시분 pRepeatCongest->AVRG_SPED = pADO->FieldByName("AVRG_SPED")->AsString; // 평균 속도 pRepeatCongest->AVRG_TRVL_HH = pADO->FieldByName("AVRG_TRVL_HH")->AsString; // 평균 통행 시간 pRepeatCongest->DCSN_YN = pADO->FieldByName("DCSN_YN")->AsString; // 확정 여부 pRepeatCongest->REPT_CNGS_SECT_ORGN_CD = pADO->FieldByName("REPT_CNGS_SECT_ORGN_CD")->AsString; // 반복 정체 구간 원본 코드 if( pRepeatCongest->DCSN_YN != "Y" ) FListsWthr.Push(String(FDataSeqWthr++), pRepeatCongest); else FListsCnfmWthr.Push(String(FDataSeqWthr++), pRepeatCongest); pRepeatCongest->Completed = true; } } catch(EDatabaseError &E) { ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2); DBERRORLOG("TItsRepeatCongestManager::LoadFromDbWthrCnfm", 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("TItsRepeatCongestManager::LoadFromDbWthrCnfm", String(exception.ClassName()), exception.Message, sQry); return false; throw Exception(String(exception.ClassName()) + exception.Message); } } __finally { if (pADO) { pADO->Close(); delete pADO; } FListsWthr.UnLock(); FListsCnfmWthr.UnLock(); } return bResult; } //---------------------------------------------------------------------------