ITS_OP/SRC/PLUGIN/07.DSRC-RSE/00.CDS/CDSDsrcF.cpp

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


#pragma hdrstop

#include "CDSDsrcF.h"
#include "ITSDbF.h"
#include "AppGlobalF.h"

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

#pragma package(smart_init)

TItsDsrc::TItsDsrc()
{
	FCompleted = false;
    FEditMode  = DB_INIT;
	FGridIndex = -1;
	MEM_DEL    = "N";
    //Clear();
}
//---------------------------------------------------------------------------
void TItsDsrc::Clear()
{
    ID           = "";
    RSE_ID       = "";
    ROAD_SPOT_ID = "";
    LOG_CNNC_ID  = "";
    LOG_CNNC_PW  = "";
    ISTL_LCTN_NM = "";
    LCTN_X       = "";
    LCTN_Y       = "";
    IP           = "";
    PORT         = "";
    MNFC_CMPY_CD = "";
    DEL_YN       = "";
    MEM_DEL      = "";
    CLCT_ABNR_BASI = 0;
}
//---------------------------------------------------------------------------
TItsDsrc::~TItsDsrc()
{
}
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
TItsDsrcManager *ItsDsrcManager = NULL;
//---------------------------------------------------------------------------

/*
* Dsrc Manager
*/
TItsDsrcManager::TItsDsrcManager()
{
}
//---------------------------------------------------------------------------
TItsDsrcManager::~TItsDsrcManager()
{
    FLists.RemoveAll();
}
//---------------------------------------------------------------------------
bool TItsDsrcManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "SELECT ID,              \r\n"
           "       RSE_ID,          \r\n"
           "       ROAD_SPOT_ID,    \r\n"
           "       LOG_CNNC_ID,     \r\n"
           "       LOG_CNNC_PW,     \r\n"
           "       ISTL_LCTN_NM,    \r\n"
           "       LCTN_X,          \r\n"
           "       LCTN_Y,          \r\n"
           "       IP,              \r\n"
           "       PORT,            \r\n"
           "       MNFC_CMPY_CD,    \r\n"
           "       DEL_YN,          \r\n"
           "       CLCT_ABNR_BASI   \r\n"
           "  FROM TB_RSE_MSTR      \r\n";
           //" WHERE DEL_YN = 'N'     \r\n";
           //" ORDER BY TO_NUMBER(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())
            {
				TItsDsrc *pObj = new TItsDsrc();

				pObj->ID            = pADO->FieldByName("ID")->AsString;
				pObj->RSE_ID        = pADO->FieldByName("RSE_ID")->AsString;
				pObj->ROAD_SPOT_ID  = pADO->FieldByName("ROAD_SPOT_ID")->AsString;
				pObj->LOG_CNNC_ID   = pADO->FieldByName("LOG_CNNC_ID")->AsString;
				pObj->LOG_CNNC_PW   = pADO->FieldByName("LOG_CNNC_PW")->AsString;
				pObj->ISTL_LCTN_NM  = pADO->FieldByName("ISTL_LCTN_NM")->AsString;
				pObj->LCTN_X        = pADO->FieldByName("LCTN_X")->AsString;
				pObj->LCTN_Y        = pADO->FieldByName("LCTN_Y")->AsString;
				pObj->IP            = pADO->FieldByName("IP")->AsString;
				pObj->PORT          = pADO->FieldByName("PORT")->AsString;
				pObj->MNFC_CMPY_CD  = pADO->FieldByName("MNFC_CMPY_CD")->AsString;
				pObj->DEL_YN        = pADO->FieldByName("DEL_YN")->AsString;
                pObj->CLCT_ABNR_BASI = pADO->FieldByName("CLCT_ABNR_BASI")->AsInteger;

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

                pObj->Completed = true;
                pObj->MEM_DEL   = "N";
            }
        }
        catch(EDatabaseError &E)
        {
            ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
            DBERRORMSG("RSE정보조회", 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("RSE정보조회", 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 TItsDsrcManager::GetNextRseId(String &ANewId, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "SELECT TO_NUMBER(CASE WHEN EXISTS (SELECT 1 FROM TB_RSE_MSTR)          \r\n"
           "                             THEN (SELECT TRIM(MAX(TO_NUMBER(ID)) + 1) \r\n"
           "                                     FROM TB_RSE_MSTR)                 \r\n"
           "                             ELSE '1' END) NEWID                       \r\n"
           " FROM DUAL                                                             \r\n";

    ANewId = "";
    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            ANewId = pADO->FieldByName("NEWID")->AsString;
            return true;
        }
        catch(EDatabaseError &E)
        {
            ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
            DBERRORMSG("RSE 신규ID조회", 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("RSE 신규ID조회", String(exception.ClassName()), exception.Message, sQry);
            throw Exception(String(exception.ClassName()) + exception.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }
    return false;
}
//---------------------------------------------------------------------------

bool TItsDsrcManager::DeleteDsrc(TItsDsrc *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "UPDATE TB_RSE_MSTR   \r\n"
           "   SET DEL_YN = 'Y'  \r\n"
           " WHERE 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->ID;
			pADO->ExecSQL();

        //TODO: 세종시
        sQry = "UPDATE TB_FCLT_INFR   \r\n"
               "   SET DEL_YN = 'Y'   \r\n"
               " WHERE FCLT_ID = :p01 \r\n";
#if 0
        //TODO: 기타지역
        sQry = "DELETE TB_FCLT_INFR      \r\n"
               " WHERE FCLT_ID = :p01    \r\n";
               //"   AND FCLT_TYPE = 'DSRC' \r\n";
#endif

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

            //TODO: 세종시
			pADO->Parameters->ParamByName("p01")->Value = AObj->RSE_ID;
#if 0
            //TODO: 기타지역
			pADO->Parameters->ParamByName("p01")->Value = AObj->ID;
#endif
			pADO->ExecSQL();

            return true;
        }
        catch(EDatabaseError &E)
        {
            ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
            DBERRORMSG("RSE정보삭제", 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("RSE정보삭제", 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 TItsDsrcManager::UpdateDsrc(String AOldRseId, TItsDsrc *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "UPDATE TB_RSE_MSTR            \r\n"
           "   SET RSE_ID         = :p02, \r\n"
           "       ROAD_SPOT_ID   = :p03, \r\n"
           "       LOG_CNNC_ID    = :p04, \r\n"
           "       LOG_CNNC_PW    = :p05, \r\n"
           "       ISTL_LCTN_NM   = :p06, \r\n"
           "       LCTN_X         = :p07, \r\n"
           "       LCTN_Y         = :p08, \r\n"
           "       IP             = :p09, \r\n"
           "       PORT           = :p10, \r\n"
           "       MNFC_CMPY_CD   = :p11, \r\n"
           "       DEL_YN         = :p12, \r\n"
           "       CLCT_ABNR_BASI = :p13  \r\n"
           " WHERE 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;

            if (AObj->DEL_YN == "") AObj->DEL_YN = "N";
			pADO->Parameters->ParamByName("p01")->Value = AObj->ID;
			pADO->Parameters->ParamByName("p02")->Value = AObj->RSE_ID;
			pADO->Parameters->ParamByName("p03")->Value = AObj->ROAD_SPOT_ID;
			pADO->Parameters->ParamByName("p04")->Value = AObj->LOG_CNNC_ID;
			pADO->Parameters->ParamByName("p05")->Value = AObj->LOG_CNNC_PW;
			pADO->Parameters->ParamByName("p06")->Value = AObj->ISTL_LCTN_NM;
			pADO->Parameters->ParamByName("p07")->Value = AObj->LCTN_X;
			pADO->Parameters->ParamByName("p08")->Value = AObj->LCTN_Y;
			pADO->Parameters->ParamByName("p09")->Value = AObj->IP;
			pADO->Parameters->ParamByName("p10")->Value = AObj->PORT;
			pADO->Parameters->ParamByName("p11")->Value = AObj->MNFC_CMPY_CD;
			pADO->Parameters->ParamByName("p12")->Value = AObj->DEL_YN;
			pADO->Parameters->ParamByName("p13")->Value = AObj->CLCT_ABNR_BASI;
			pADO->ExecSQL();

            sQry = "UPDATE TB_FCLT_INFR       \r\n"
                   "   SET FCLT_LCTN  = :p02, \r\n"
                   "       DEL_YN     = 'N'   \r\n"
                   " WHERE FCLT_ID    = :p01  \r\n";
                   //"   AND FCLT_TYPE = 'DSRC' \r\n";

			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
			pADO->Parameters->ParamByName("p01")->Value = AObj->RSE_ID;
			pADO->Parameters->ParamByName("p02")->Value = AObj->ISTL_LCTN_NM;
			pADO->ExecSQL();

            return true;
        }
        catch(EDatabaseError &E)
        {
            ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
            DBERRORMSG("RSE정보업데이트", 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("RSE정보업데이트", 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 TItsDsrcManager::InsertDsrc(TItsDsrc *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "INSERT INTO TB_RSE_MSTR(ID,           RSE_ID, ROAD_SPOT_ID, LOG_CNNC_ID, LOG_CNNC_PW,  \r\n"
           "                        ISTL_LCTN_NM, LCTN_X, LCTN_Y,       IP,          PORT,         \r\n"
           "                        MNFC_CMPY_CD, DEL_YN, CLCT_ABNR_BASI)                          \r\n"
           "                 VALUES(:p01,         :p02,   :p03,         :p04,        :p05,         \r\n"
           "                        :p06,         :p07,   :p08,         :p09,        :p10,         \r\n"
           "                        :p11,         :p12,   :p13)                                    \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->ID;
			pADO->Parameters->ParamByName("p02")->Value = AObj->RSE_ID;
			pADO->Parameters->ParamByName("p03")->Value = AObj->ROAD_SPOT_ID;
			pADO->Parameters->ParamByName("p04")->Value = AObj->LOG_CNNC_ID;
			pADO->Parameters->ParamByName("p05")->Value = AObj->LOG_CNNC_PW;
			pADO->Parameters->ParamByName("p06")->Value = AObj->ISTL_LCTN_NM;
			pADO->Parameters->ParamByName("p07")->Value = AObj->LCTN_X;
			pADO->Parameters->ParamByName("p08")->Value = AObj->LCTN_Y;
			pADO->Parameters->ParamByName("p09")->Value = AObj->IP;
			pADO->Parameters->ParamByName("p10")->Value = AObj->PORT;
			pADO->Parameters->ParamByName("p11")->Value = AObj->MNFC_CMPY_CD;
			pADO->Parameters->ParamByName("p12")->Value = AObj->DEL_YN;
			pADO->Parameters->ParamByName("p13")->Value = AObj->CLCT_ABNR_BASI;
			pADO->ExecSQL();

        sQry = "INSERT INTO TB_FCLT_INFR(FCLT_ID, FCLT_TYPE, FCLT_LCTN, RSCE_YN, DEL_YN, USE_YEAR, AMT) \r\n"
               "                  VALUES(:p01,    'DSRC',    :p03,      'N',     'N',    '0',      '0') \r\n";

			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
			pADO->Parameters->ParamByName("p01")->Value = AObj->RSE_ID;
			pADO->Parameters->ParamByName("p03")->Value = AObj->ISTL_LCTN_NM;
			pADO->ExecSQL();

            return true;
        }
        catch(EDatabaseError &E)
        {
            ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
            DBERRORMSG("RSE정보입력", 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("RSE정보입력", 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 TItsDsrcManager::UpdateClctAbnrBasi(int AClctAbnrBasi, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "UPDATE TB_RSE_MSTR            \r\n"
           "   SET CLCT_ABNR_BASI = :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 = AClctAbnrBasi;
			pADO->ExecSQL();

            FOR_STL(TItsDsrc*, pObj, FLists)
            {
                if (pObj->DEL_YN == "Y") continue;

                pObj->CLCT_ABNR_BASI = AClctAbnrBasi;
            }
            return true;
        }
        catch(EDatabaseError &E)
        {
            ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
            DBERRORMSG("RSE정보업데이트", 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("RSE정보업데이트", String(exception.ClassName()), exception.Message, sQry);
            throw Exception(String(exception.ClassName()) + exception.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
        FLists.UnLock();
    }

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