ITS_OP/COMMON/CDS/CDSRepeatCongestF.cpp

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


#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;
}
//---------------------------------------------------------------------------