ITS_OP/COMMON/CDS/CDSObjectF.cpp

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


#pragma hdrstop

#include "CDSAtrdF.h"
#include "ITSDbF.h"
#include "AppGlobalF.h"

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

#pragma package(smart_init)

TItsAtrdRoad::TItsAtrdRoad()
{
	FCompleted = false;
    FEditMode  = DB_INIT;
	FGridIndex = -1;
	MEM_DEL    = "N";
    //Clear();
}
//---------------------------------------------------------------------------
void TItsAtrdRoad::Clear()
{
    ATRD_ID  = "";
    ROAD_ID  = "";
    ORD      = "";
    MEM_DEL  = "";
}
//---------------------------------------------------------------------------
TItsAtrdRoad::~TItsAtrdRoad()
{
}
//---------------------------------------------------------------------------

TItsAtrd::TItsAtrd()
{
	FCompleted = false;
    FEditMode  = DB_INIT;
	FGridIndex = -1;
	MEM_DEL    = "N";
    //Clear();
}
//---------------------------------------------------------------------------
void TItsAtrd::Clear()
{
    ATRD_ID = "";
    ATRD_NM = "";
    DRCT_CD = "";
    AREA_CD = "";
    DEL_YN  = "";
    MEM_DEL = "";
}
//---------------------------------------------------------------------------
TItsAtrd::~TItsAtrd()
{
}
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
TItsAtrdManager *ItsAtrdManager = NULL;
//---------------------------------------------------------------------------

/*
* Atrd Manager
*/
TItsAtrdManager::TItsAtrdManager()
{
}
//---------------------------------------------------------------------------
TItsAtrdManager::~TItsAtrdManager()
{
    FLists.RemoveAll();
}
//---------------------------------------------------------------------------
bool TItsAtrdManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
{
    LoadFromAtrdDb(ADbConn);
    LoadFromAtrdRoadDb(ADbConn);
    return true;
}

bool TItsAtrdManager::LoadFromAtrdDb(TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "SELECT ATRD_ID,     \r\n"
           "       ATRD_NM,     \r\n"
           "       DRCT_CD,     \r\n"
           "       AREA_CD,     \r\n"
           "       DEL_YN       \r\n"
           "  FROM TB_ATRD      \r\n";
           //" WHERE DEL_YN = 'N' \r\n";
           //" ORDER BY ATRD_ID   \r\n";
    try
    {
        FLists.Lock();
        FLists.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())
            {
				TItsAtrd *pObj = new TItsAtrd();

                pObj->ATRD_ID = pADO->FieldByName("ATRD_ID")->AsString;
                pObj->ATRD_NM = pADO->FieldByName("ATRD_NM")->AsString;
                pObj->DRCT_CD = pADO->FieldByName("DRCT_CD")->AsString;
                pObj->AREA_CD = pADO->FieldByName("AREA_CD")->AsString;
                pObj->DEL_YN  = pADO->FieldByName("DEL_YN")->AsString;

				FLists.Push(pObj->ATRD_ID, pObj);

                pObj->Completed = true;
                pObj->MEM_DEL   = "N";
            }
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("간선도로정보조회", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &exception)
        {
            DBERRORMSG("간선도로정보조회", 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 TItsAtrdManager::LoadFromAtrdRoadDb(TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "SELECT ATRD_ID,           \r\n"
           "       ROAD_ID,           \r\n"
           "       ORD                \r\n"
           "  FROM TB_ATRD_ROAD_RLTN  \r\n";
           " ORDER BY ATRD_ID, ORD    \r\n";
    try
    {
        TItsAtrd *pAtrd;
        FLists.Lock();
        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())
            {
                String ATRD_ID = pADO->FieldByName("ATRD_ID")->AsString;
                pAtrd = FLists.Find(ATRD_ID);
                if (!pAtrd) continue;

				TItsAtrdRoad *pObj = new TItsAtrdRoad();

                pObj->ATRD_ID   = ATRD_ID;
                pObj->ROAD_ID   = pADO->FieldByName("ROAD_ID")->AsString;
                pObj->ORD       = pADO->FieldByName("ORD")->AsString;

				pAtrd->FSubLists.Push(pObj->ORD, pObj);

                pObj->Completed = true;
                pObj->MEM_DEL   = "N";
            }
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("간선도로-구간정보조회", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &exception)
        {
            DBERRORMSG("간선도로-구간정보조회", 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 TItsAtrdManager::DeleteAtrdRoad(TItsAtrd *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "DELETE TB_ATRD_ROAD_RLTN  \r\n"
           " WHERE ATRD_ID = :p01     \r\n";
    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
			pADO->Parameters->ParamByName("p01")->Value = AObj->ATRD_ID;
			pADO->ExecSQL();

            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("간선도로-구간정보삭제", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &exception)
        {
            DBERRORMSG("간선도로-구간정보삭제", String(exception.ClassName()), exception.Message, sQry);
            throw Exception(String(exception.ClassName()) + exception.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------

bool TItsAtrdManager::DeleteAtrd(TItsAtrd *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "UPDATE TB_ATRD        \r\n"
           "   SET DEL_YN = 'Y'   \r\n"
           " WHERE ATRD_ID = :p01 \r\n";
    try
    {
        FLists.Lock();
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
			pADO->Parameters->ParamByName("p01")->Value = AObj->ATRD_ID;
			pADO->ExecSQL();

            DeleteAtrdRoad(AObj, ADbConn);
            
            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("간선도로정보삭제", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &exception)
        {
            DBERRORMSG("간선도로정보삭제", 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 TItsAtrdManager::InsertAtrdRoad(TItsAtrd *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    //링크구성정보 입력
    sQry = "INSERT INTO TB_ATRD_ROAD_RLTN (ATRD_ID, ROAD_ID, ORD ) \r\n"
           "                       VALUES (:p01,    :p02,    :p03) \r\n";
    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();

			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

            FOR_STL(TItsAtrdRoad *, pObj, AObj->FSubLists)
            {
                pADO->Parameters->ParamByName("p01")->Value = AObj->ATRD_ID;
                pADO->Parameters->ParamByName("p02")->Value = pObj->ROAD_ID;
                pADO->Parameters->ParamByName("p03")->Value = pObj->ORD;
                pADO->ExecSQL();
            }

            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("간선도로-구간정보입력", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &exception)
        {
            DBERRORMSG("간선도로-구간정보입력", String(exception.ClassName()), exception.Message, sQry);
            throw Exception(String(exception.ClassName()) + exception.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------

bool TItsAtrdManager::UpdateAtrd(TItsAtrd *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;


    sQry = "UPDATE TB_ATRD          \r\n"
           "   SET ATRD_NM  = :p02, \r\n"
           "       DRCT_CD  = :p03, \r\n"
           "       AREA_CD  = :p04, \r\n"
           "       DEL_YN   = :p05  \r\n"
           " WHERE ATRD_ID  = :p01  \r\n";
    try
    {
        FLists.Lock();
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Parameters->ParamByName("p01")->Value = AObj->ATRD_ID;
			pADO->Parameters->ParamByName("p02")->Value = AObj->ATRD_NM;
			pADO->Parameters->ParamByName("p03")->Value = AObj->DRCT_CD;
			pADO->Parameters->ParamByName("p04")->Value = AObj->AREA_CD;
			pADO->Parameters->ParamByName("p05")->Value = AObj->DEL_YN;

			pADO->ExecSQL();

            DeleteAtrdRoad(AObj, ADbConn);
            InsertAtrdRoad(AObj, ADbConn);

            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("간선도로정보업데이트", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &exception)
        {
            DBERRORMSG("간선도로정보업데이트", 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 TItsAtrdManager::InsertAtrd(TItsAtrd *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "INSERT INTO TB_ATRD(ATRD_ID, ATRD_NM, DRCT_CD, AREA_CD, DEL_YN) \r\n"
           "             VALUES(:p01,    :p02,    :p03,    :p04,    :p05)   \r\n";
    try
    {
        FLists.Lock();
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Parameters->ParamByName("p01")->Value = AObj->ATRD_ID;
			pADO->Parameters->ParamByName("p02")->Value = AObj->ATRD_NM;
			pADO->Parameters->ParamByName("p03")->Value = AObj->DRCT_CD;
			pADO->Parameters->ParamByName("p04")->Value = AObj->AREA_CD;
			pADO->Parameters->ParamByName("p05")->Value = AObj->DEL_YN;

			pADO->ExecSQL();

            DeleteAtrdRoad(AObj, ADbConn);
            InsertAtrdRoad(AObj, ADbConn);

            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("간선도로정보입력", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &exception)
        {
            DBERRORMSG("간선도로정보입력", String(exception.ClassName()), exception.Message, sQry);
            throw Exception(String(exception.ClassName()) + exception.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
        FLists.UnLock();
    }

    return true;
}
//---------------------------------------------------------------------------