ITS-OP/COMMON/CDS__/CDSRepeatCongestF.cpp

//---------------------------------------------------------------------------


#pragma hdrstop

#include "CDSRepeatCongestF.h"
#include "AppGlobalF.h"

//---------------------------------------------------------------------------

#pragma package(smart_init)

TItsRepeatCongest::TItsRepeatCongest()
{
}
//---------------------------------------------------------------------------
TItsRepeatCongest::~TItsRepeatCongest()
{
}
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
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->Prepared = true;
			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
				TItsRepeatCongest *pRepeatCongest = new TItsRepeatCongest();

                pRepeatCongest->IFSC_ID		            = pADO->FieldByName("IFSC_ID")->AsString;                  // 정보제공구간 ID
                pRepeatCongest->STAT_YM		            = pADO->FieldByName("CRTN_YMD")->AsString;                  // 통계 년월
                pRepeatCongest->DAY_TYPE_CD	            = pADO->FieldByName("DAY_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->CRTN_YMD		        = pADO->FieldByName("CRTN_YMD")->AsString;                 // 생성 일자
                pRepeatCongest->REPT_CNGS_SECT_ORGN_CD	= pADO->FieldByName("REPT_CNGS_SECT_ORGN_CD")->AsString;   // 반복 정체 구간 원본 코드

				if( pRepeatCongest->DCSN_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->Prepared = true;
			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->Prepared = true;
			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;
}
//---------------------------------------------------------------------------