ITS_OP/COMMON/CDS/CDSTrafficF.cpp

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


#pragma hdrstop

#include "CDSTrafficF.h"
#include "ITSUtilF.h"
#include "AppGlobalF.h"

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

#pragma package(smart_init)

TItsTraffic::TItsTraffic(int ALEVL, String AID, void* AObj)
{
    ID     = AID;
    LEVL   = ALEVL;
    Object = AObj;

    InitTraffic();
}
//---------------------------------------------------------------------------
TItsTraffic::~TItsTraffic()
{
}
//---------------------------------------------------------------------------
void TItsTraffic::InitTraffic()
{
    CMTR_GRAD_CD = "LTC0";
    PRCN_DT      = "19000101000000";
    SPED         = 0;
    TRVL_HH      = 0;
    DATA_NUM     = 0;
    TRAF_GRAD    = 0;
}
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
TItsTrafficManager *ItsTrafficManager = NULL;
//---------------------------------------------------------------------------

/*
* Link Traffic Manager
*/
TItsTrafficManager::TItsTrafficManager()
{
}
//---------------------------------------------------------------------------
TItsTrafficManager::~TItsTrafficManager()
{
}
//---------------------------------------------------------------------------
void TItsTrafficManager::InitTraffic()
{
    try
    {
        FLists.Lock();

        FOR_STL(TItsTraffic*, pObj, FLists)
        {
            pObj->InitTraffic();
        }
    }
    __finally
    {
        FLists.UnLock();
    }
}
//---------------------------------------------------------------------------
bool TItsTrafficManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
{
    bool         bResult = true;
    String       sQry;
    TADOQuery   *pADO = NULL;
    TItsTraffic *pTraf;

    InitTraffic();

#if 0
    sQry = "SELECT 3 AS LEVL, A.ROAD_ID AS LINKID,  NVL(B.SPED, 0) AS SPEED, NVL(B.CMTR_GRAD_CD, 'LTC0') CMTR_GRAD_CD, \r\n"
           "       DECODE(B.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_ROAD A,                                                                                          \r\n"
           "       (SELECT *                                                                                           \r\n"
           "          FROM TB_ROAD_TRAF                                                                                \r\n"
           "         WHERE PRCN_DT > TO_CHAR(SYSDATE -  8 / 1440, 'YYYYMMDDHH24MISS')                                  \r\n"
           "           ) B                                                                                             \r\n"
           " WHERE A.ROAD_ID = B.ROAD_ID(+)                                                                            \r\n"
           "UNION ALL                                                                                                  \r\n"
           "SELECT 2 AS LEVL, A.IFSC_ID AS LINKID,  NVL(B.SPED, 0) AS SPEED, NVL(B.CMTR_GRAD_CD, 'LTC0') CMTR_GRAD_CD, \r\n"
           "       DECODE(B.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 -  8 / 1440, 'YYYYMMDDHH24MISS')                                  \r\n"
           "       ) B                                                                                                 \r\n"
           " WHERE A.IFSC_ID = B.IFSC_ID(+)                                                                            \r\n"
           "UNION ALL                                                                                                  \r\n"
           "SELECT 1 AS LEVL, A.LINK_ID AS LINKID,  NVL(B.SPED, 0) AS SPEED, NVL(B.CMTR_GRAD_CD, 'LTC0') CMTR_GRAD_CD, \r\n"
           "       DECODE(B.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_LINK A,                                                                                          \r\n"
           "       (SELECT *                                                                                           \r\n"
           "          FROM TB_LINK_TRAF                                                                                \r\n"
           "         WHERE PRCN_DT > TO_CHAR(SYSDATE -  8 / 1440, 'YYYYMMDDHH24MISS')                                  \r\n"
           "       ) B                                                                                                 \r\n"
           " WHERE A.LINK_ID = B.LINK_ID(+)                                                                            \r\n";
#else
    sQry = "SELECT 1 AS LEVL, A.LINK_ID AS LINKID, PRCN_DT, TFVL, SPED, OCPY_RATE, TRVL_HH, CMTR_GRAD_CD, PTRN_SPED, DATA_NUM,   \r\n"
           "       (CASE WHEN PRCN_DT <= TO_CHAR(SYSDATE - 10/1440, 'YYYYMMDDHH24MISS')                                          \r\n"
           "             THEN 'Y' ELSE 'N' END) AS MISSING,                                                                      \r\n"
           "       (CASE WHEN PRCN_DT >= TO_CHAR(SYSDATE - 15/1440, 'YYYYMMDDHH24MISS')                                          \r\n"
           "             THEN 'Y' ELSE 'N' END) AS LASTANS,                                                                      \r\n"
           "       (SELECT MAX(PRCN_DT) FROM TB_LINK_TRAF) MPRCN_DT,                                                             \r\n"
           "       MISS_YN, PRCN_SPED, SMTH_SPED, ADJS_SPED, PRCN_SORC, ADJS_SORC                                                \r\n"
           "  FROM TB_LINK_TRAF A, TB_LINK B                                                                                     \r\n"
           " WHERE A.LINK_ID = B.LINK_ID                                                                                         \r\n"
           "UNION ALL                                                                                                            \r\n"
           "SELECT 2 AS LEVL, A.IFSC_ID AS LINKID, PRCN_DT, TFVL, SPED, OCPY_RATE, TRVL_HH, CMTR_GRAD_CD, PTRN_SPED, DATA_NUM,   \r\n"
           "       (CASE WHEN PRCN_DT <= TO_CHAR(SYSDATE - 10/1440, 'YYYYMMDDHH24MISS')                                          \r\n"
           "             THEN 'Y' ELSE 'N' END) AS MISSING,                                                                      \r\n"
           "       (CASE WHEN PRCN_DT >= TO_CHAR(SYSDATE - 15/1440, 'YYYYMMDDHH24MISS')                                          \r\n"
           "             THEN 'Y' ELSE 'N' END) AS LASTANS,                                                                      \r\n"
           "       (SELECT MAX(PRCN_DT) FROM TB_LINK_TRAF) MPRCN_DT,                                                             \r\n"
           "       'N' AS MISS_YN, SPED AS PRCN_SPED, SPED AS SMTH_SPED, SPED AS ADJS_SPED, '' AS PRCN_SORC, 'MCS0' AS ADJS_SORC \r\n"
           "  FROM TB_IFSC_TRAF A, TB_IFSC B                                                                                     \r\n"
           " WHERE A.IFSC_ID = B.IFSC_ID                                                                                         \r\n"
           "UNION ALL                                                                                                            \r\n"
           "SELECT 3 AS LEVL, A.ROAD_ID AS LINKID, PRCN_DT, TFVL, SPED, OCPY_RATE, TRVL_HH, CMTR_GRAD_CD, PTRN_SPED, DATA_NUM,   \r\n"
           "       (CASE WHEN PRCN_DT <= TO_CHAR(SYSDATE - 10/1440, 'YYYYMMDDHH24MISS')                                          \r\n"
           "             THEN 'Y' ELSE 'N' END) AS MISSING,                                                                      \r\n"
           "       (CASE WHEN PRCN_DT >= TO_CHAR(SYSDATE - 15/1440, 'YYYYMMDDHH24MISS')                                          \r\n"
           "             THEN 'Y' ELSE 'N' END) AS LASTANS,                                                                      \r\n"
           "       (SELECT MAX(PRCN_DT) FROM TB_ROAD_TRAF) MPRCN_DT,                                                             \r\n"
           "       'N' AS MISS_YN, SPED AS PRCN_SPED, SPED AS SMTH_SPED, SPED AS ADJS_SPED, '' AS PRCN_SORC, 'MCS0' AS ADJS_SORC \r\n"
           "  FROM TB_ROAD_TRAF A, TB_ROAD B                                                                                     \r\n"
           " WHERE A.ROAD_ID = B.ROAD_ID                                                                                         \r\n";

    #endif

    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->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
				String LINKID = pADO->FieldByName("LINKID")->AsString;
                pTraf = FLists.Find(LINKID);
                if (!pTraf) continue;

                pTraf->PRCN_DT      = pADO->FieldByName("PRCN_DT")->AsString;
                pTraf->TFVL         = pADO->FieldByName("TFVL")->AsInteger;
                pTraf->SPED         = pADO->FieldByName("SPED")->AsInteger;
                pTraf->OCPY_RATE    = pADO->FieldByName("OCPY_RATE")->AsFloat;
                pTraf->TRVL_HH      = pADO->FieldByName("TRVL_HH")->AsInteger;
                pTraf->CMTR_GRAD_CD = pADO->FieldByName("CMTR_GRAD_CD")->AsString;
				pTraf->MISSING      = pADO->FieldByName("MISSING")->AsString;       // 결측여부
				pTraf->LASTANS      = pADO->FieldByName("LASTANS")->AsString;       // 최근 15분 이내 가공
				pTraf->MPRCN_DT     = pADO->FieldByName("MPRCN_DT")->AsString;      // 가공시각(최신)
                pTraf->DATA_NUM     = pADO->FieldByName("DATA_NUM")->AsInteger;
                pTraf->PTRN_SPED    = pADO->FieldByName("PTRN_SPED")->AsInteger;

                if      (pTraf->CMTR_GRAD_CD == "LTC1") pTraf->TRAF_GRAD = 1;
                else if (pTraf->CMTR_GRAD_CD == "LTC2") pTraf->TRAF_GRAD = 2;
                else if (pTraf->CMTR_GRAD_CD == "LTC3") pTraf->TRAF_GRAD = 3;
                else                                    pTraf->TRAF_GRAD = 0;

				pTraf->MISS_YN      = pADO->FieldByName("MISS_YN")->AsString;       // '결측 여부';
				pTraf->PRCN_SPED    = pADO->FieldByName("PRCN_SPED")->AsInteger;    // '가공 속도';
				pTraf->SMTH_SPED    = pADO->FieldByName("SMTH_SPED")->AsInteger;    // '평활화 속도';
				pTraf->ADJS_SPED    = pADO->FieldByName("ADJS_SPED")->AsInteger;    // '보정 속도';
				pTraf->PRCN_SORC    = pADO->FieldByName("PRCN_SORC")->AsString;     // '가공 소스';
				pTraf->ADJS_SORC    = pADO->FieldByName("ADJS_SORC")->AsString;     // '보정 소스';
            }
        }
        catch(EDatabaseError &E)
        {
            ::PostMessage(Application->MainForm->Handle, (UINT)(WM_USER+0xF4), (WPARAM)0xB2, (LPARAM)0xB2);
            DBERRORLOG("TItsTrafficManager::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("TItsTrafficManager::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();
    }

    return bResult;
}
//---------------------------------------------------------------------------