ITS_OP/VmsOprMain/VMSOprMainLib/CDS/CDSIfsc_VMSF.cpp

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

#pragma hdrstop

#include "CDSIfsc_VMSF.h"
#include "VMSOprMainLibF.h"

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

#pragma package(smart_init)

//---------------------------------------------------------------------------
TIfsc::TIfsc()
{
    InitTraffic();
}
//---------------------------------------------------------------------------
TIfsc::~TIfsc()
{
}
//---------------------------------------------------------------------------
void TIfsc::InitTraffic()
{
    PRCN_DT      = "";	        //N	VARCHAR2(14)	Y			가공 일시
    TFVL         = 0;	            //N	NUMBER(6)	    Y	0		교통량
    SPED         = 0;	            //N	NUMBER(3)	    Y	0		속도
    PTRN_SPED    = 0;	        //N	NUMBER(3)	    Y	0		패턴 속도
    OCPY_RATE    = 0;	        //N	NUMBER(5,2)	    Y	0		점유 율
    TRVL_HH      = 0;	        //N	NUMBER(6)	    Y	0		통행 시간
    CMTR_GRAD_CD = "0";	    //N	VARCHAR2(7)	    Y			소통 등급 코드
    DATA_NUM     = 0;	        //N	NUMBER(3)	    Y	0		데이터 개수
}
//---------------------------------------------------------------------------


//---------------------------------------------------------------------------
TIfscManager *IfscManager = NULL;
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
TIfscManager::TIfscManager()
{
}
//---------------------------------------------------------------------------
TIfscManager::~TIfscManager()
{
    FLists.RemoveAll();
}
//---------------------------------------------------------------------------
void TIfscManager::InitTraffic()
{
    FLists.Lock();
    try
    {
        FOR_STL(TIfsc*, pObj, FLists)
        {
            pObj->InitTraffic();
        }
    }
    __finally
    {
        FLists.UnLock();
    }
}
//---------------------------------------------------------------------------
bool TIfscManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
{
    String     sQry;
    TADOQuery *pADO = NULL;

    sQry = "SELECT A.*        \r\n"
           "  FROM TB_IFSC A  \r\n";

    FLists.Lock();
    try
    {
        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 DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
                if (DEL_YN == "Y") continue;

				TIfsc *pObj = new TIfsc();

                pObj->IFSC_ID           = pADO->FieldByName("IFSC_ID")->AsString;	        //N	NUMBER(10)	    N			정보제공구간 ID
                pObj->IFSC_NM           = pADO->FieldByName("IFSC_NM")->AsString;	        //N	VARCHAR2(100)	Y			정보제공구간 명
                pObj->DRCT_CD           = pADO->FieldByName("DRCT_CD")->AsString;	        //N	VARCHAR2(7)	    Y			방향 코드
                pObj->STRT_NM           = pADO->FieldByName("STRT_NM")->AsString;	        //N	VARCHAR2(100)	Y			시점 명
                pObj->END_NM            = pADO->FieldByName("END_NM")->AsString;	        //N	VARCHAR2(100)	Y			종점 명
                pObj->SECT_LNGT         = pADO->FieldByName("SECT_LNGT")->AsInteger;	    //N	NUMBER(5)	    Y	0		구간 길이
                pObj->EXTR_CNCT_SECT_YN = pADO->FieldByName("EXTR_CNCT_SECT_YN")->AsString;	//N	CHAR(1)	        Y	'N'		외부 연계 구간 여부
                pObj->DEL_YN            = pADO->FieldByName("DEL_YN")->AsString;	        //N	CHAR(1)	        Y	'N'		삭제 여부
                pObj->RMRK              = pADO->FieldByName("RMRK")->AsString;	            //N	VARCHAR2(600)	Y			비고
                pObj->F_NODE_ID         = pADO->FieldByName("F_NODE_ID")->AsString;	        //N	NUMBER(10)	    Y			시작 노드 ID
                pObj->T_NODE_ID         = pADO->FieldByName("T_NODE_ID")->AsString;	        //N	NUMBER(10)	    Y			종료 노드 ID
                pObj->SECT_GRAD_CD      = pADO->FieldByName("SECT_GRAD_CD")->AsString;	    //N	VARCHAR2(7)	    Y			구간 등급 코드
                pObj->AREA_CD           = pADO->FieldByName("AREA_CD")->AsString;	        //N	VARCHAR2(7)	    Y			지역 코드

                pObj->vertex = false;
				FLists.Push(pObj->IFSC_ID, pObj);
            }
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("TIfscManager::LoadFromDb", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORMSG("TIfscManager::LoadFromDb", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
        FLists.UnLock();
    }

    return true;
}
//---------------------------------------------------------------------------
bool TIfscManager::LoadVertexFromFile(TADOConnection *ADbConn/*=NULL*/)
{
    String     sQry;
    AnsiString sAppDir = ExtractFilePath(Application->ExeName);
    AnsiString sFileName = sAppDir + "\\MAPDATA\\layers\\IFSC.dat";

    sQry = String(sFileName);

	FILE *fd;
	if ((fd = fopen(sFileName.c_str(), "r")) == NULL)
    {
        return false;
    }

    FLists.Lock();

    TStringList *sl = NULL;
    char         szBuff[8192];

    try
    {
        sl = new TStringList;
        sl->Delimiter = ';';
        sl->StrictDelimiter = true;

        int nCnt = 0;
        while (1)
        {
            nCnt++;
            memset(szBuff, 0x00, sizeof(szBuff));
            if (fgets(szBuff, sizeof(szBuff), fd) == NULL) break;

            sl->DelimitedText = String(szBuff);
            if (sl->Count != 3)
            {
                continue;
            }
            try {
                String IFSC_ID = sl->Strings[0];
				TIfsc *pObj = FLists.Find(IFSC_ID);
                if (pObj)
                {
                    pObj->vertex     = true;
                    pObj->X_CRDN_ARR = sl->Strings[1];
                    //pObj->Y_CRDN_ARR = sl->Strings[2];
                    pObj->Y_CRDN_ARR = StringReplace(sl->Strings[2], "\n", "", TReplaceFlags() << rfReplaceAll);
                }
            }
            catch(Exception &e)
            {
                DBERRORMSG("TIfscManager::LoadVertexFromDb", String(e.ClassName()), e.Message, sQry);
                throw Exception(String(e.ClassName()) + e.Message);
            }
        }
    }
    __finally
    {
        if (sl) delete sl;
        if (fd) fclose(fd);
        FLists.UnLock();
    }

    return true;
}
//---------------------------------------------------------------------------
bool TIfscManager::LoadVertexFromDb(TADOConnection *ADbConn/*=NULL*/)
{
    String     sQry;
    TADOQuery *pADO = NULL;

#if 0
    sQry = "SELECT B.IFSC_ID,                  \r\n"
           "       B.X_CRDN_ARR, B.Y_CRDN_ARR  \r\n"
           "  FROM TB_IFSC          A,         \r\n"
           "       TB_IFSC_VRTX_ARR B          \r\n"
           " WHERE A.DEL_YN  = 'N'             \r\n"
           "   AND A.IFSC_ID = B.IFSC_ID       \r\n"
           "   AND B.LEVL    = 2               \r\n";
#else
#if 0
    sQry = "SELECT *                 \r\n"
           "  FROM VW_IFSC_VRTX_ARR  \r\n";
#else
    sQry = "SELECT A.IFSC_ID AS IFSC_ID, A.LEVL AS LEVL,        \r\n"
           "       SUBSTR(A.X_CRDN_ARR,    1, 400) AS XMSG01,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR,  401, 400) AS XMSG02,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR,  801, 400) AS XMSG03,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR, 1201, 400) AS XMSG04,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR, 1601, 400) AS XMSG05,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR, 2001, 400) AS XMSG06,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR, 2401, 400) AS XMSG07,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR, 2801, 400) AS XMSG08,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR, 3201, 400) AS XMSG09,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR, 3601, 400) AS XMSG10,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR, 4001, 400) AS XMSG11,   \r\n"
           "       SUBSTR(A.X_CRDN_ARR, 4401, 400) AS XMSG12,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR,    1, 400) AS YMSG01,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR,  401, 400) AS YMSG02,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR,  801, 400) AS YMSG03,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR, 1201, 400) AS YMSG04,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR, 1601, 400) AS YMSG05,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR, 2001, 400) AS YMSG06,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR, 2401, 400) AS YMSG07,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR, 2801, 400) AS YMSG08,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR, 3201, 400) AS YMSG09,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR, 3601, 400) AS YMSG10,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR, 4001, 400) AS YMSG11,   \r\n"
           "       SUBSTR(A.Y_CRDN_ARR, 4401, 400) AS YMSG12    \r\n"
           "  FROM VW_IFSC_VRTX_ARR A                           \r\n";
#endif
#endif

    FLists.Lock();
    try
    {
        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 IFSC_ID = pADO->FieldByName("IFSC_ID")->AsString;

				TIfsc *pObj = FLists.Find(IFSC_ID);
                if (pObj)
                {
                    pObj->vertex     = true;
#if 0
                    //pObj->X_CRDN_ARR = pADO->FieldByName("X_CRDN_ARR")->AsString;
                    //pObj->Y_CRDN_ARR = pADO->FieldByName("Y_CRDN_ARR")->AsString;
                    String X_CRDN_ARR = pADO->FieldByName("X_CRDN_ARR")->AsString;
                    String Y_CRDN_ARR = pADO->FieldByName("Y_CRDN_ARR")->AsString;
#else
                    pObj->X_CRDN_ARR = "";
                    pObj->Y_CRDN_ARR = "";
                    String COLM;
                    for (int ii = 1; ii < 13; ii++)
                    {
                        COLM.printf(L"XMSG%02d", ii);
                        pObj->X_CRDN_ARR += pADO->FieldByName(COLM)->AsString;
                        COLM.printf(L"YMSG%02d", ii);
                        pObj->Y_CRDN_ARR += pADO->FieldByName(COLM)->AsString;
                    }
#endif
                }
            }
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("TIfscManager::LoadVertexFromDb", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORMSG("TIfscManager::LoadVertexFromDb", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
        FLists.UnLock();
    }

    return true;
}
//---------------------------------------------------------------------------
bool TIfscManager::LoadVertexFromDb_gen(TADOConnection *ADbConn/*=NULL*/)
{
    String     sQry;
    TADOQuery *pADO = NULL;

    sQry = "SELECT X.IFSC_ID AS IFSC_ID,                                                        \r\n"
           "       X.ORD,                                                                       \r\n"
           "       X.X_CRDN, X.Y_CRDN                                                           \r\n"
           "  FROM (SELECT IFSC_ID,                                                             \r\n"
           "               ROW_NUMBER() OVER(PARTITION BY IFSC_ID, LEVL ORDER BY ORD) ORD,      \r\n"
           "               X_CRDN, Y_CRDN                                                       \r\n"
           "          FROM TB_IFSC_VRTX                                                         \r\n"
           "         WHERE LEVL = 3) X                                                          \r\n"
           " ORDER BY X.IFSC_ID, X.ORD                                                          \r\n";

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

			pADO->Open();

            TIfsc *pObj;
            String o_IFSC_ID  = "";
            String X_CRDN_ARR = "";
            String Y_CRDN_ARR = "";

            for( ; !pADO->Eof; pADO->Next())
            {
                String IFSC_ID = pADO->FieldByName("IFSC_ID")->AsString;

                if (IFSC_ID != o_IFSC_ID)
                {
                    // 아이디가 변경되었으면 이전 데이터를 설정
                    pObj = FLists.Find(o_IFSC_ID);
                    if (pObj)
                    {
                        pObj->vertex     = true;
                        pObj->X_CRDN_ARR = X_CRDN_ARR;
                        pObj->Y_CRDN_ARR = Y_CRDN_ARR;
                    }

                    // 데이터 초기화
                    o_IFSC_ID = IFSC_ID;

                    // 현재 정보는 최초 정보이므로 그냥 할당
                    X_CRDN_ARR = pADO->FieldByName("X_CRDN")->AsString;
                    Y_CRDN_ARR = pADO->FieldByName("Y_CRDN")->AsString;
                }
                else
                {
                    // 두번째 데이터 이므로 분리자 추가
                    X_CRDN_ARR += "," + pADO->FieldByName("X_CRDN")->AsString;
                    Y_CRDN_ARR += "," + pADO->FieldByName("Y_CRDN")->AsString;
                }
            }
            //마지막 데이터 처리
            pObj = FLists.Find(o_IFSC_ID);
            if (pObj)
            {
                pObj->vertex     = true;
                pObj->X_CRDN_ARR = X_CRDN_ARR;
                pObj->Y_CRDN_ARR = Y_CRDN_ARR;
            }
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("TIfscManager::LoadVertexFromDb", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORMSG("TIfscManager::LoadVertexFromDb", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
        FLists.UnLock();
    }

    return true;
}
//---------------------------------------------------------------------------
bool TIfscManager::LoadTraffic(TADOConnection *ADbConn/*=NULL*/)
{
    String     sQry;
    TADOQuery *pADO = NULL;

    InitTraffic();

    sQry = "SELECT IFSC_ID AS LINKID, NVL(PRCN_DT, '19000101000000') AS PRCN_DT,    \r\n"
           "       NVL(TFVL,      0) AS TFVL,      NVL(SPED,      0) AS SPED,       \r\n"
           "       NVL(PTRN_SPED, 0) AS PTRN_SPED, NVL(OCPY_RATE, 0) AS OCPY_RATE,  \r\n"
           "       NVL(TRVL_HH,   0) AS TRVL_HH,                                    \r\n"
           "       DECODE(CMTR_GRAD_CD, 'LTC1', '1',                                \r\n"
           "                            'LTC2', '2',                                \r\n"
           "                            'LTC3', '3', '0') AS CMTR_GRAD_CD,          \r\n"
           "       NVL(DATA_NUM, 0) AS DATA_NUM                                     \r\n"
           "  FROM TB_IFSC_TRAF                                                     \r\n"
           " WHERE PRCN_DT > TO_CHAR(SYSDATE -  5 / 1440, 'YYYYMMDDHH24MISS')       \r\n";

#if 0
    sQry = "SELECT 2 AS LEVL, A.IFSC_ID AS LINKID,  NVL(B.SPED, 0) AS SPEED, NVL(CMTR_GRAD_CD, 'LTC0') CMTR_GRAD_CD, \r\n"
           "       DECODE(CMTR_GRAD_CD, 'LTC1', '1', 'LTC2', '2', 'LTC3', '3', '0') TRF_GRADE,                       \r\n"
           "       NVL(B.PRCN_DT, '19000101000000')     AS REGDATE,                                                  \r\n"
           "       NVL(B.DATA_NUM, 0) AS DATACNT,                                                                    \r\n"
           "       NVL(B.TRVL_HH, 0) AS TRVTM                                                                        \r\n"
           "  FROM TB_IFSC A,                                                                                        \r\n"
           "       (SELECT *                                                                                         \r\n"
           "          FROM TB_IFSC_TRAF                                                                              \r\n"
           //"         WHERE PRCN_DT > TO_CHAR(SYSDATE -  5 / 1440, 'YYYYMMDDHH24MISS')                                \r\n"
           "       ) B                                                                                               \r\n"
           " WHERE A.IFSC_ID = B.IFSC_ID(+)                                                                          \r\n";
#endif

    FLists.Lock();
    try
    {
        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 LINKID = pADO->FieldByName("LINKID")->AsString;

				TIfsc *pObj = FLists.Find(LINKID);
                if (!pObj) continue;

                pObj->PRCN_DT       = pADO->FieldByName("PRCN_DT")->AsString;	        //N	VARCHAR2(14)	Y			가공 일시
                pObj->TFVL          = pADO->FieldByName("TFVL")->AsInteger;	            //N	NUMBER(6)	    Y	0		교통량
                pObj->SPED          = pADO->FieldByName("SPED")->AsInteger;	            //N	NUMBER(3)	    Y	0		속도
                pObj->PTRN_SPED     = pADO->FieldByName("PTRN_SPED")->AsInteger;	    //N	NUMBER(3)	    Y	0		패턴 속도
                pObj->OCPY_RATE     = pADO->FieldByName("OCPY_RATE")->AsFloat;	        //N	NUMBER(5,2)	    Y	0		점유 율
                pObj->TRVL_HH       = pADO->FieldByName("TRVL_HH")->AsInteger;	        //N	NUMBER(6)	    Y	0		통행 시간
                pObj->CMTR_GRAD_CD  = pADO->FieldByName("CMTR_GRAD_CD")->AsString;	    //N	VARCHAR2(7)	    Y			소통 등급 코드
                pObj->DATA_NUM      = pADO->FieldByName("DATA_NUM")->AsInteger;	        //N	NUMBER(3)	    Y	0		데이터 개수
            }
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("IFSC교통정보조회", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORMSG("IFSC교통정보조회", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
        FLists.UnLock();
    }

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