VmsCommServer/SRC/DM/DMCOMMF.cpp

/****************************************************************************
 * @source      : DMCOMMF.cpp
 * @description : Socket Communications Data Module
 ****************************************************************************
 * DATE         AUTHOR    DESCRIPTION
 * --------------------------------------------------------------------------
 *
 ****************************************************************************/

//---------------------------------------------------------------------------
#include "AppGlobalF.h"
#include "DMCOMMF.h"
#include "VmsDataTypeF.h"
#include "VMSSThread.h"
#include "VMSCThread.h"
#include "FrmSysLogF.h"
#include <DateUtils.hpp>
//---------------------------------------------------------------------------
#pragma package(smart_init)
#pragma resource "*.dfm"
TDMCOMM *DMCOMM;
//---------------------------------------------------------------------------
__fastcall TDMCOMM::TDMCOMM(TComponent* Owner)
	: TDataModule(Owner)
{
    FProcessStateMin = -1;
    FEquipStateMin   = -1;
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::DataModuleCreate(TObject *Sender)
{
//
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::DataModuleDestroy(TObject *Sender)
{
//
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::SetErrorString(String AErrorString)
{
    FErrorString = AErrorString;
    FDbLog->LogWrite(NULL, eLOG_ERROR, AnsiString(FErrorString).c_str());
    LERROR(AnsiString(FErrorString).c_str());
}
//---------------------------------------------------------------------------

int TDMCOMM::LogWrite(int ALogKind, char *AFmt, ...)
{
    va_list     ap;
    int         cnt = 0;
    char        szFmtData[MAX_LOG_BUFFER];
    AnsiString  sLogKind;
    int         nStep = 0;

    bool bLog = false;
    switch(ALogKind)
    {
    case eLOG_INFO   : bLog = g_LogCfg.Info;    sLogKind = " [INF] "; break;
    case eLOG_DATA   : bLog = g_LogCfg.Data;    sLogKind = " [DAT] "; break;
    case eLOG_ERROR  : bLog = g_LogCfg.Error;   sLogKind = " [ERR] "; break;
    case eLOG_WARNING: bLog = g_LogCfg.Warning; sLogKind = " [WAN] "; break;
    case eLOG_DEBUG  : bLog = g_LogCfg.Debug;   sLogKind = " [DBG] "; break;
    case eLOG_DETAIL : bLog = g_LogCfg.Detail;  sLogKind = " [DET] "; break;
    }
    if (!bLog) return -1;

    try
    {
        va_start(ap, AFmt);
        cnt = vsprintf(szFmtData, AFmt, ap);
        va_end(ap);

        nStep = 1;
        ITSLog->LogWrite(NULL, ALogKind, szFmtData);

        nStep = 2;
        //IPC_LOG_MESSAGE *pLog = new IPC_LOG_MESSAGE;
        IPC_LOG_MESSAGE *pLog = &FLogMsg;//(IPC_LOG_MESSAGE *)malloc(sizeof(IPC_LOG_MESSAGE));
        if (pLog)
        {
            pLog->Kind = ALogKind;
            pLog->Flag = 0;
            pLog->Len  = strlen(szFmtData);
            pLog->Tm   = Now();
            memset(pLog->Msg, 0x00, sizeof(pLog->Msg));
            sprintf(pLog->Msg, "%sDCOM %s", sLogKind.c_str(), szFmtData);

#if 0
            ITSUtil_Trace(pLog->Msg);
#else
        	DWORD   dwResult = 0;
            LRESULT lResult = SEND_LOGMSG(FrmSysLog->Handle, WM_LOG_DISPLAY, pLog, NULL, SMTO_NORMAL, 2000, dwResult);
            if (lResult == 0)
            {
                dwResult = GetLastError();
                if (dwResult == ERROR_TIMEOUT)
                {
                }
                //SAFE_DELETE(pLog);
            }
#endif
        }
    }
    catch(Exception &e)
    {
        LERROR("LogWrite: %d", nStep);
    }
    return cnt;
}
//---------------------------------------------------------------------------

bool __fastcall TDMCOMM::DbConnect(String AConnStr)
{
    bool bResult = false;

	try
    {
        //DbClose();

        FDbConn = new TADOConnection(NULL);
        if (!FDbConn) return false;

        FDbConn->ConnectionTimeout = 10;
        FDbConn->ConnectionString  = AConnStr;
        FDbConn->KeepConnection	   = true;
        FDbConn->LoginPrompt       = false;
        FDbConn->Open();
        bResult = true;
    }
    catch(EDatabaseError &E)
    {
        ErrorString = String(E.ClassName()) + E.Message;
        DBERRORLOG("DbConnect", String(E.ClassName()), E.Message, AConnStr);
    }
    catch (Exception &exception)
    {
        ErrorString = String(exception.ClassName()) + exception.Message;
        DBERRORLOG("DbConnect", String(exception.ClassName()), exception.Message, AConnStr);
    }
    return bResult;
}
//---------------------------------------------------------------------------

bool __fastcall TDMCOMM::DbClose()
{
    bool bResult = false;

	try
    {
        if (!FDbConn) return false;

        if (FDbConn->Connected)
        {
            FDbConn->Close();
            FDbConn->Connected = false;
        }
        delete FDbConn;
        FDbConn = NULL;
        bResult = true;
    }
    catch(EDatabaseError &E)
    {
        ErrorString = String(E.ClassName()) + E.Message;
        DBERRORLOG("DbClose", String(E.ClassName()), E.Message, " ");
    }
    catch (Exception &exception)
    {
        ErrorString = String(exception.ClassName()) + exception.Message;
        DBERRORLOG("DbClose", String(exception.ClassName()), exception.Message, " ");
    }
    return bResult;
}
//---------------------------------------------------------------------------

bool __fastcall TDMCOMM::SQLText(TADOQuery *adoQry, String sQry, bool AReadOnly/*=true*/)
{
    try
    {
        adoQry->Close();
        adoQry->SQL->Text = sQry;
        if (AReadOnly)
        {
            adoQry->CursorType = ctOpenForwardOnly;
            adoQry->LockType   = ltReadOnly;
            adoQry->DisableControls();
        }
        return true;
    }
    catch(EDatabaseError &E)
    {
        ErrorString = String(E.ClassName()) + E.Message;
        DBERRORLOG("SQLText", String(E.ClassName()), E.Message, sQry);
    }
    catch (Exception &exception)
    {
        ErrorString = String(exception.ClassName()) + exception.Message;
        DBERRORLOG("SQLText", String(exception.ClassName()), exception.Message, sQry);
    }
    return false;
}
//---------------------------------------------------------------------------

bool __fastcall TDMCOMM::SQLBind(TADOQuery *adoQry, String param, String var)
{
    try
    {
        adoQry->Parameters->ParamByName(param)->Value = var;
        return true;
    }
    catch(EDatabaseError &E)
    {
        ErrorString = String(E.ClassName()) + E.Message;
        DBERRORLOG("SQLBind", String(E.ClassName()), E.Message, adoQry->SQL->Text);
    }
    catch (Exception &exception)
    {
        ErrorString = String(exception.ClassName()) + exception.Message;
        DBERRORLOG("SQLBind", String(exception.ClassName()), exception.Message, adoQry->SQL->Text);
    }
    return false;
}
//---------------------------------------------------------------------------

bool __fastcall TDMCOMM::SQLClose(TADOQuery *adoQry)
{
    try
    {
        if (adoQry->Active)
        {
            adoQry->Recordset->Close();
            adoQry->Close();
            adoQry->Active = false;
        }
        adoQry->SQL->Clear();
        return true;
    }
    catch(EDatabaseError &E)
    {
        ErrorString = String(E.ClassName()) + E.Message;
        DBERRORLOG("SQLClose", String(E.ClassName()), E.Message, adoQry->SQL->Text);
    }
    catch (Exception &exception)
    {
        ErrorString = String(exception.ClassName()) + exception.Message;
        DBERRORLOG("SQLClose", String(exception.ClassName()), exception.Message, adoQry->SQL->Text);
    }
    return false;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::SQLOpen(TADOQuery *adoQry)
{
    try
    {
        adoQry->Open();
        adoQry->First();
        return adoQry->RecordCount;
    }
    catch(EDatabaseError &E)
    {
        ErrorString = String(E.ClassName()) + E.Message;
        DBERRORLOG("SQLOpen", String(E.ClassName()), E.Message, adoQry->SQL->Text);
    }
    catch (Exception &exception)
    {
        ErrorString = String(exception.ClassName()) + exception.Message;
        DBERRORLOG("SQLOpen", String(exception.ClassName()), exception.Message, adoQry->SQL->Text);
    }
    return -1;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::SQLExec(TADOQuery *adoQry)
{
    try
    {
        adoQry->ExecSQL();
        return adoQry->RowsAffected;
    }
    catch(EDatabaseError &E)
    {
        ErrorString = String(E.ClassName()) + E.Message;
        DBERRORLOG("SQLExec", String(E.ClassName()), E.Message, adoQry->SQL->Text);
    }
    catch (Exception &exception)
    {
        ErrorString = String(exception.ClassName()) + exception.Message;
        DBERRORLOG("SQLExec", String(exception.ClassName()), exception.Message, adoQry->SQL->Text);
    }
    return -1;
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::DbState(bool AFlag)
{
	if (AFlag)
    {
        SendMessage((HWND)g_AppCfg.lMainWinHandle, WM_USER, WM_DATABASE_OPEN, 0);
    }
    else
    {
        SendMessage((HWND)g_AppCfg.lMainWinHandle, WM_USER, WM_DATABASE_CLOSE, 0);
        LERROR("Database Error");
    }
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::TcpClientDisconnect(TObject *Sender)
{
    try
    {
        TCustomIpClient *pClientSocket = (TCustomIpClient*)Sender;
        AnsiString sRemoteHost = pClientSocket->RemoteHost;
        int        nRemotePort = pClientSocket->RemotePort.ToIntDef(0);
        LINFO("VMS Client Disconnect: %s.%d", sRemoteHost.c_str(), nRemotePort);
    }
    catch(Exception &e)
    {
    }
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::TcpServerGetThread(TObject *Sender, TClientSocketThread *&ClientSocketThread)
{
    TVmsCtlr        *pObj          = NULL;
    TCustomIpClient *pClientSocket = NULL;

    try
    {
        pClientSocket = new TCustomIpClient(NULL);
        //pClientSocket->OnDisconnect = TcpClientDisconnect;

        TcpServer->ServerSocketThread->ServerSocket->Accept(pClientSocket);

		pObj = FindVms(pClientSocket->RemoteHost, pClientSocket->RemotePort.ToIntDef(0));

        AnsiString sRemoteHost = pClientSocket->RemoteHost;
        int        nRemotePort = pClientSocket->RemotePort.ToIntDef(0);

    	LINFO("TCP Client connect request: %s.%d", sRemoteHost.c_str(), nRemotePort);

		if (!pObj)
        {
            LERROR("Unknown VMS Client connect request: %s.%d [socket closed]", sRemoteHost.c_str(), nRemotePort);
            ClientSocketThread = new TClientSocketThread(TcpServer->ServerSocketThread);
            ClientSocketThread->Terminate();
            pClientSocket->Close();
            delete pClientSocket;
            return;
        }

    	LINFO("%s VMS Client connect: %s.%d", pObj->VmsId.c_str(), sRemoteHost.c_str(), nRemotePort);
		ClientSocketThread = new TVMSSThread(TcpServer->ServerSocketThread, pClientSocket, (int)pObj, &pObj->Server.ActiveIndicator);
    }
    catch(Exception &e)
    {
        ClientSocketThread = NULL;
    	LERROR("TCP Client connect request exception: %s", e.Message.c_str());
    }

	pObj->Server.pThread = ClientSocketThread;

	if (pObj->Server.pThread == NULL)
    {
		pObj->Server.Status = process_fail;
    }
    else
	{
		pObj->Server.Status = process_run;
    }
	pObj->ChangeDate = Now().FormatString("yyyymmddhhnnss");
}
//---------------------------------------------------------------------------

TVmsCtlr* __fastcall TDMCOMM::FindVms(AnsiString AIpAddress, int APort)
{
    VmsIterator it;
    for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
    {
        TVmsCtlr *pObj = (TVmsCtlr*)it->second;

        if (pObj->Server.UseFlag != bit_enable) continue;

        if (pObj->IpAddress.AnsiCompare(AIpAddress) == 0)
        {
            if (pObj->Server.ActiveIndicator)
            {
                /* 기존 연결 해제 */
                LWARN("Already connected client: %s %s [closed].", pObj->VmsId.c_str(), AIpAddress.c_str());
                ControlVms(pObj, false);
            }
            return pObj;
        }
    }

    return NULL;
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::TerminateVms(void)
{
    int i;
	TVMSSThread *pVMSSThread;
    DWORD dwWaitResult;

    LINFO("TerminateVms start");
    if (TcpServer->Active)
    {
		TcpServer->Close();
    }
    LINFO("TerminateVms end");
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::ControlVms(TVmsCtlr *AObj, bool ASet)
{
	TVMSSThread *pVMSSThread;
    DWORD        dwWaitResult;

	if (!AObj) return;

	if (AObj->Server.UseFlag != bit_enable) return;

	if (ASet) return;

    AObj->Server.Status = process_stop;
    AObj->ChangeDate    = Now().FormatString("yyyymmddhhnnss");

    if (AObj->Server.pThread         != NULL &&
        AObj->Server.ActiveIndicator == true )
    {
        try
        {
            pVMSSThread = (TVMSSThread *)AObj->Server.pThread;
            //pVMSSThread->Terminate();
            pVMSSThread->FDupClose = true;
            //Sleep(500);
            dwWaitResult = CommUtil_WaitThreadTerm(pVMSSThread->ThreadID, (HANDLE)pVMSSThread->Handle, WAIT_THREAD_TERMINATE_TIME);
            if (dwWaitResult == STILL_ACTIVE)
            {
                LERROR("VMS thread terminate fail: %s", AObj->VmsId.c_str());
            }

            AObj->Server.pThread = NULL;
        }
        catch(Exception &e)
        {
        }
    }
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::MonitoringVms(bool ServerRun)
{
    VmsIterator it;
    for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
    {
        TVmsCtlr *pObj = (TVmsCtlr*)it->second;
        if (pObj->Server.UseFlag != bit_enable) continue;

        switch(pObj->Server.Status)
        {
        case process_fail:
            break;
        case process_run:
            if (pObj->Server.pThread == NULL)
            {
                pObj->Server.Status = process_fail;
                pObj->ChangeDate    = Now().FormatString("yyyymmddhhnnss");
            }
            else
            {
                if (!pObj->Server.ActiveIndicator)
                {
                    pObj->Server.pThread = NULL;
                    pObj->Server.Status  = process_fail;
                    pObj->ChangeDate     = Now().FormatString("yyyymmddhhnnss");
                }
            }
            break;
        case process_stop:
            break;
        }
    }

	if (ServerRun)
	{
		try
		{
			if (!TcpServer->Active)
			{
				TcpServer->LocalPort = g_AppCfg.comm.nListenPort;
				TcpServer->BlockMode = bmThreadBlocking;

                int nReqThreadCacheSize = VMS_MAX_DEVICE + 10;
                int nThreadCacheSize = TcpServer->ServerSocketThread->ThreadCacheSize;
                if (nThreadCacheSize < nReqThreadCacheSize)
                {
                    TcpServer->ServerSocketThread->ThreadCacheSize = nReqThreadCacheSize;
                }
				//TcpServer->ServerSocketThread->ThreadCacheSize = VMS_MAX_DEVICE;

                //서버소켓 리슨 시작
				TcpServer->Open();

                nThreadCacheSize = TcpServer->ServerSocketThread->ThreadCacheSize;
			}
		}
		catch(Exception &e)
		{
		}
 	}
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::MonitoringVmsClient(bool ServerRun)
{
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::TerminateVmsClient(void)
{
    VmsIterator it;
    for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
    {
        TVmsCtlr *pObj = (TVmsCtlr*)it->second;

        if (pObj->Server.UseFlag != bit_enable) continue;

        if (pObj->Server.ActiveIndicator)
        {
            ControlVms(pObj, false);
        }
    }
}
//---------------------------------------------------------------------------

void __fastcall TDMCOMM::ControlVmsClient(int idx, bool set)
{
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::GetDbSysdate()
{
	int         nResult;
	AnsiString  sQry;
    TADOQuery  *pADO = NULL;
    AnsiString  sSysDate = Now().FormatString("yyyymmddhhnnss");

	nResult = VERR_OTHER;

    LDEBUG("GetDbSysdate: Start");
	try
	{
		pADO = new TADOQuery(NULL);
        pADO->Connection = GetDbConnection();

		try
		{
            sQry = "SELECT TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') AS S_DATE  \r\n"
                   "  FROM DUAL                                            \r\n";

            SQLText(pADO, sQry, false);
			SQLOpen(pADO);

			for( ; !pADO->Eof; pADO->Next())
			{
                sSysDate = pADO->FieldByName("S_DATE")->AsString;
                break;
			}

			nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            ErrorString = String(E.ClassName()) + E.Message;
		}
		catch(Exception &e)
		{
            ErrorString = String(e.ClassName()) + e.Message;
		}
	}
	__finally
	{
		SQLFree(pADO);
	}
    LINFO("GetDbSysdate: %s", sSysDate.c_str());
	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::GetProcessInfo()
{
	int         nResult;
	AnsiString  sQry;
	int         nSelCnt = 0;
	TADOQuery  *pADO = NULL;

	nResult = VERR_OTHER;

    LDEBUG("GetProcessInfo: Start");
	try
	{
		pADO = new TADOQuery(NULL);
        pADO->Connection = GetDbConnection();

		try
		{
            sQry = "SELECT SYST_ID, SYST_TYPE,   \r\n"
                   "       SYST_IP_1, PRGM_PORT  \r\n"
                   "  FROM TB_UNIT_SYST          \r\n"
                   " WHERE DEL_YN = 'N'          \r\n"
                   " ORDER BY SYST_ID            \r\n";

            SQLText(pADO, sQry, false);
			SQLOpen(pADO);

			for( ; !pADO->Eof; pADO->Next())
			{
                AnsiString sProcessId = pADO->FieldByName("SYST_ID")->AsString;
                AnsiString sSystemTp  = pADO->FieldByName("SYST_TYPE")->AsString;
                AnsiString sIpAddress = pADO->FieldByName("SYST_IP_1")->AsString;
                AnsiString sUdpPort   = pADO->FieldByName("PRGM_PORT")->AsString;

                if (g_AppCfg.sSystemId == sProcessId)
                {
                    //자기자신은 목록에 추가하지 않는다...
                    //g_AppCfg.comm.nCenterPort = sUdpPort.ToIntDef(g_AppCfg.comm.nCenterPort);
                    continue;
                }
                if (VComm_AddProcess(sProcessId, sSystemTp, sIpAddress, sUdpPort) >= 0)
                {
                    if ("UOT" == sSystemTp)
                    {
                        int nPort = sUdpPort.ToIntDef(0);
                        VComm_AddProcess(sProcessId, sSystemTp, sIpAddress, AnsiString(nPort+1));
                    }
                }
                nSelCnt++;
			}

			nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            ErrorString = String(E.ClassName()) + E.Message;
		}
		catch(Exception &e)
		{
            ErrorString = String(e.ClassName()) + e.Message;
		}
	}
	__finally
	{
		SQLFree(pADO);
	}

    LINFO("GetProcessInfo: %d", nSelCnt);

	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::GetOldProcessInfo()
{
    String     sQry;
    TADOQuery *pADO = NULL;

    int        nSelCnt = 0;

    LDEBUG("GetOldProcessInfo: Start");

    sQry = "SELECT PORT             \r\n"
           "  FROM PROCESS          \r\n"
           " WHERE PROCESSID = :p01 \r\n";

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
            SQLBind(pADO, "p01", g_AppCfg.sProcessId);

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                g_AppCfg.nProcessPort = pADO->FieldByName("PORT")->AsInteger;

                nSelCnt++;
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    LINFO("GetOldProcessInfo: %d EA", nSelCnt);

    return VERR_NONE;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::GetVmsInfo()
{
    String     sQry;
    TADOQuery *pADO = NULL;

    LDEBUG("GetVmsInfo: Start");

    try
    {
        VmsManager->FLists.Lock();
        VmsManager->FLists.RemoveAll();
    }
    __finally
    {
        VmsManager->FLists.UnLock();
    }

    sQry = "SELECT A.*,                                        \r\n"
           "       (SELECT NVL(ATRB1, '320')                   \r\n"
           "          FROM TB_CMMN_CD                          \r\n"
           "         WHERE CMMN_CLSF_CD = 'VMP'                \r\n"
           "           AND CMMN_CD = A.VMS_TYPE_CD) AS FORMW,  \r\n"
           "       (SELECT NVL(ATRB2,  '64')                   \r\n"
           "          FROM TB_CMMN_CD                          \r\n"
           "         WHERE CMMN_CLSF_CD = 'VMP'                \r\n"
           "           AND CMMN_CD = A.VMS_TYPE_CD) AS FORMH   \r\n"
           "  FROM TB_VMS_CTLR A                               \r\n"
           " WHERE A.DEL_YN = 'N'                              \r\n";
    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString VmsNo     = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();
                AnsiString VmsId     = pADO->FieldByName("VMS_CTLR_ID")->AsString.Trim();
                AnsiString VmsType   = pADO->FieldByName("VMS_USAG_TYPE_CD")->AsString.Trim();
                AnsiString Name      = pADO->FieldByName("VMS_NM")->AsString.Trim();
                AnsiString Location  = pADO->FieldByName("ISTL_LCTN_NM")->AsString.Trim();
                AnsiString LocalNo   = pADO->FieldByName("VMS_CMNC_PORT")->AsString;//.ToIntDef(0);
                AnsiString IpAddress = pADO->FieldByName("VMS_CTLR_IP")->AsString.Trim();
                AnsiString WlTelNo   = "";
                AnsiString WlIp      = "";
                AnsiString WlPort    = 0;
                int        VmsDownId = pADO->FieldByName("VMS_ID")->AsString.Trim().ToIntDef(0);

				TVmsCtlr *pObj = new TVmsCtlr();

                pObj->FBmpDownload = g_AppCfg.DownloadBitmap;

                pObj->VmsNo     = VmsNo;
                pObj->VmsId     = VmsId;
                pObj->VmsDownId.printf("%02d", VmsDownId);
                pObj->VmsType   = VmsType;
                pObj->Name      = Name;
                pObj->Location  = Location;
                pObj->LocalNo   = LocalNo.ToIntDef(355);
                pObj->IpAddress = IpAddress;
                pObj->WlTelNo   = WlTelNo;
                pObj->WlIp      = WlIp;
                pObj->WlPort    = 0;

                pObj->DSPL_DT   = "yyyymmddhhnnss";
                pObj->DNLD_YN   = "x";

                pObj->OPER_MODE             = pADO->FieldByName("OPER_MODE")->AsString;

                pObj->MODULE.PowerOnTime    = Now().FormatString("yyyymmdd") + pADO->FieldByName("PANL_ON_TIME")->AsString;
                pObj->MODULE.PowerOffTime   = Now().FormatString("yyyymmdd") + pADO->FieldByName("PANL_OFF_TIME")->AsString;
                pObj->MODULE.Retry          = 0;

                pObj->LUMINANCE.SchTime = Now().FormatString("yyyymmdd");
                pObj->LUMINANCE.Value   = 0;
                pObj->LUMINANCE.Retry   = 0;

                pObj->VMS_PHSE_CHNG_CYCL    = pADO->FieldByName("VMS_PHSE_CHNG_CYCL")->AsInteger;
                pObj->VMS_CMNC_ERR_BASS_VAL = pADO->FieldByName("VMS_CMNC_ERR_BASS_VAL")->AsInteger;
                pObj->FAN_MTNS_TMPR         = pADO->FieldByName("FAN_MTNS_TMPR")->AsInteger;
                pObj->HETR_MTNS_TMPR        = pADO->FieldByName("HETR_MTNS_TMPR")->AsInteger;
                pObj->VMS_MODL_ERR_RATE     = pADO->FieldByName("VMS_MODL_ERR_RATE")->AsInteger;

                pObj->VMS_MAX_PHSE_NUM      = pADO->FieldByName("VMS_MAX_PHSE_NUM")->AsInteger;

                pObj->WIDTH                 = pADO->FieldByName("FORMW")->AsString.Trim().ToIntDef(380);
                pObj->HEIGHT                = pADO->FieldByName("FORMH")->AsString.Trim().ToIntDef(64);

                String VMS_TYPE_CD = pADO->FieldByName("VMS_TYPE_CD")->AsString;
                pObj->ModVerCnt = 2;
                pObj->ModHorCnt = 12;
                if (VMS_TYPE_CD == "VMP0")
                {
                    pObj->ModVerCnt = 2;
                    pObj->ModHorCnt = 10;
                }
                else
                if (VMS_TYPE_CD == "VMP1")
                {
                    pObj->ModVerCnt = 10;
                    pObj->ModHorCnt = 18;
                }
                else
                if (VMS_TYPE_CD == "VMP2")
                {
                    pObj->ModVerCnt = 2*2;
                    pObj->ModHorCnt = 12*2;
                }
                else
                if (VMS_TYPE_CD == "VMP3")
                {
                    pObj->ModVerCnt = 1;
                    pObj->ModHorCnt = 6;
                }

        		sprintf(pObj->DSTATE.VmsId, "%.*s", INT_VMS_MAX_ID, pObj->VmsNo.c_str());

                if (pObj->OPER_MODE == "A")
                    pObj->DSTATE.OprMode = 'A';
                else
                if (pObj->OPER_MODE == "B")
                    pObj->DSTATE.OprMode = 'B';
                else
                    pObj->DSTATE.OprMode = 'F';

                pObj->DSTATE.ScheduledMessageOperatingTime = pObj->VMS_PHSE_CHNG_CYCL;    /* 필수 계획된 메시지의 동작시간(초) */
                pObj->DSTATE.ModuleOperatingTemperature    = pObj->VMS_CMNC_ERR_BASS_VAL; /* 필수 모듈 전원이 꺼지는 온도값(℃) */
                pObj->DSTATE.FanOperatingTemperature       = pObj->FAN_MTNS_TMPR;         /* 필수 Fan 동작 기준 온도값(℃) */
                pObj->DSTATE.HeaterOperatingTemperature    = pObj->HETR_MTNS_TMPR;        /* 필수 Heater 동작 기준 온도값(℃) */
                pObj->DSTATE.ModuleBasicFailureRate        = pObj->VMS_MODL_ERR_RATE;     /* 선택 모듈 장애율 (한 개의 모듈을 장애로 처리하기 위한 픽셀의 백분율값) */
                pObj->DSTATE.ExternalLightOperatingLuminance = 0;                         /* 선택 외부전등 동작 기준 휘도값 */
                pObj->DSTATE.MaximumRetry                    = 3;                         /* 선택 최대 재시도 횟수(회) */
                pObj->DSTATE.ResponseTimeOut                 = 30;                        /* 선택 최대응답대기시간 (초) */
                pObj->DSTATE.BlinkingCycleTime               = 100;                       /* 선택 점멸시간 주기 ( 1/10초단위) */
                memcpy(&pObj->RSTATE, &pObj->DSTATE, sizeof(pObj->RSTATE));
                pObj->RSTATE.Comm = vms_error;
                pObj->RSTATE.Wcomm = vms_error;

                pObj->FSLog = new TITSLog(g_sLogDir + "Comm\\"+pObj->VmsId + "\\", pObj->VmsId+"S", g_AppCfg.sLogDay);
                pObj->FCLog = new TITSLog(g_sLogDir + "Comm\\"+pObj->VmsId + "\\", pObj->VmsId+"C", g_AppCfg.sLogDay);
                pObj->FSLog->FLogCfg = g_LogCfg;
                pObj->FCLog->FLogCfg = g_LogCfg;

                pObj->ChangeDate = Now().FormatString("yyyymmddhhnnss");
                pObj->pPackQueue = new TThreadList();

                if (VComm_CheckIpAddress(pObj->IpAddress.c_str()) &&
                    pObj->pPackQueue &&
                    pObj->FSLog      &&
                    pObj->FCLog      )
                {
                    pObj->Server.UseFlag = bit_enable;
                    pObj->Server.Status  = process_run;

                    pObj->Client.UseFlag = bit_enable;
                    pObj->Client.Status  = process_run;
                }

                pObj->SCHEDULE = new VMS_SCHEDULE_INFO;
                pObj->SCHEDULE->Count = 0;

                pObj->INCIDENT = new VMS_EVENT_INFO;
                pObj->INCIDENT->Count = 0;

                pObj->EVENT = new VMS_EVENT_INFO;
                pObj->EVENT->Count = 0;

                pObj->SAFE = new VMS_SAFE_INFO;
                pObj->SAFE->Count = 0;

                pObj->DOWNLOAD = new VMS_DOWNLOAD_INFO;
                InitDownLoadInfo(pObj->DOWNLOAD);

                pObj->CTLMODE = new VMS_CONTROL_MODE;
                InitCtlModeInfo(pObj->CTLMODE);

                if (pObj->VMS_MAX_PHSE_NUM > INT_MAX_VMS_FORM)
                    pObj->VMS_MAX_PHSE_NUM = INT_MAX_VMS_FORM;

                pObj->CTLMODE->MaxDisplayForm = pObj->VMS_MAX_PHSE_NUM;
                pObj->CTLMODE->Control        = pObj->DSTATE.OprMode;
#if 0
                if (pObj->CTLMODE->MaxDisplayForm > INT_MAX_VMS_FORM)
                    pObj->CTLMODE->MaxDisplayForm = INT_MAX_VMS_FORM;
#endif

                //VMS제공폼을 관리할 관리자 생성(VMS개별적으로 생성함)
                pObj->pForms = new TVmsFormManager();
                pObj->pForms->FormWidth = pObj->WIDTH;
                pObj->pForms->FormHeight= pObj->HEIGHT;

                String sFormDir = g_sFormDir + pObj->VmsId + "\\";
                //ForceDirectories(sFormDir.c_str());

				VmsManager->FLists.Push(pObj->VmsNo, pObj);

                String sFtpDir = g_sFtpDir + pObj->VmsId + "\\";
                //ForceDirectories(sFtpDir.c_str());

            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    LINFO("GetVmsInfo: %d EA", VmsManager->Count);

    //return VERR_NONE;
    return GetVmsStateInfo();
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::GetVmsStateInfo()
{
    String     sQry;
    TADOQuery *pADO = NULL;

    int        nSelCnt = 0;

    LDEBUG("GetVmsStateInfo: Start");

    sQry = "SELECT A.*                                \r\n"
           "  FROM TB_VMS_STTS_PRST A,                \r\n"
           "       TB_VMS_CTLR      B                 \r\n"
           " WHERE B.DEL_YN = 'N'                     \r\n"
           "   AND A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR  \r\n";

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString VmsNo = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();
                TVmsCtlr *pObj = VmsManager->FLists.Find(VmsNo);
                if (!pObj) continue;

                nSelCnt++;

                AnsiString CBOXDOOR_OPEN_STTS_CD = pADO->FieldByName("CBOXDOOR_OPEN_STTS_CD")->AsString.Trim();
                AnsiString PWER_STTS_CD          = pADO->FieldByName("PWER_STTS_CD")->AsString.Trim();
                AnsiString CBOX_TMPR             = pADO->FieldByName("CBOX_TMPR")->AsString.Trim();
                AnsiString CBOX_HMDT             = pADO->FieldByName("CBOX_HMDT")->AsString.Trim();
                AnsiString FAN_STTS_CD           = pADO->FieldByName("FAN_STTS_CD")->AsString.Trim();
                AnsiString HETR_STTS_CD          = pADO->FieldByName("HETR_STTS_CD")->AsString.Trim();
                AnsiString CBOXFAN_STTS_CD       = pADO->FieldByName("CBOXFAN_STTS_CD")->AsString.Trim();

                if (CBOXDOOR_OPEN_STTS_CD == "CDS0")
                {
                    pObj->DSTATE.DoorStatus = vms_close;
                }
                else
                {
                    pObj->DSTATE.DoorStatus = vms_open;
                }

                if (PWER_STTS_CD == "PWS0")
                {
                    pObj->DSTATE.ModulePowerStatus = vms_normal;
                }
                else
                {
                    pObj->DSTATE.ModulePowerStatus = vms_error;
                }
                pObj->DSTATE.BodyTemp = (short)CBOX_TMPR.ToIntDef(0);
                pObj->DSTATE.LuminanceStatus = (BYTE)CBOX_HMDT.ToIntDef(0);

                if (FAN_STTS_CD == "PAS0")
                {
                    pObj->DSTATE.FanStatus = vms_on;
                }
                else
                {
                    pObj->DSTATE.FanStatus = vms_off;
                }

                if (HETR_STTS_CD == "HTS0")
                {
                    pObj->DSTATE.HeaterStatus = vms_on;
                }
                else
                {
                    pObj->DSTATE.HeaterStatus = vms_off;
                }

                if (CBOXFAN_STTS_CD == "MOS0")
                {
                    pObj->DSTATE.ModuleState = vms_normal;
                }
                else
                {
                    pObj->DSTATE.HeaterStatus = vms_error;
                }

                memcpy(&pObj->RSTATE, &pObj->DSTATE, sizeof(pObj->RSTATE));
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    LINFO("GetVmsStateInfo: %d EA", nSelCnt);

    return VERR_NONE;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::GetVmsIfscInfo()
{
    String     sQry;
    TADOQuery *pADO = NULL;
    int        nSelCnt = 0;

    LINFO("GetVmsIfscInfo: Start");

    try
    {
        VmsIterator it;
        for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
        {
            TVmsCtlr *pObj = (TVmsCtlr*)it->second;
            //if (pObj->Server.UseFlag != bit_enable) continue;
            //기존 제공구간정보를 모두 삭제
            pObj->FIfscLists.RemoveAll();
        }
    }
    catch(Exception &e)
    {
    }

    sQry = "SELECT A.VMS_CTLR_NMBR, B.VMS_IFSC_ID,    \r\n"
           "       B.DSPL_PRRT, C.AXIS_YN             \r\n"
           "  FROM TB_VMS_CTLR      A,                \r\n"
           "       TB_VMS_IFSC_RLTN B,                \r\n"
           "       TB_VMS_IFSC      C                 \r\n"
           " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR  \r\n"
           "   AND B.VMS_IFSC_ID   = C.VMS_IFSC_ID    \r\n"
           "   AND C.EDTN_CD <> 'EDI2'                \r\n"
           "   AND A.DEL_YN = 'N'                     \r\n"
           " ORDER BY A.VMS_CTLR_NMBR, B.DSPL_PRRT    \r\n";

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();

				TVmsCtlr *pObj = VmsManager->FLists.Find(VMS_CTLR_NMBR);
                if (!pObj) continue;

                TVmsIfsc *pIfsc = new TVmsIfsc();
                pIfsc->VMS_IFSC_ID = pADO->FieldByName("VMS_IFSC_ID")->AsString;
                pIfsc->DSPL_PRRT   = pADO->FieldByName("DSPL_PRRT")->AsInteger;

                pObj->FIfscLists.Push(pIfsc->DSPL_PRRT, pIfsc);
                nSelCnt++;
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }
    LINFO("GetVmsIfscInfo: %d", nSelCnt);
    return VERR_NONE;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::LoadVmsOnOffTime()
{
    String     sQry;
    TADOQuery *pADO = NULL;
    int        nSelCnt = 0;

    LINFO("   LoadVmsOnOffTime: Start");

    sQry = "SELECT A.VMS_CTLR_NMBR, \r\n"
           "       A.PANL_ON_TIME,  \r\n"
           "       A.PANL_OFF_TIME  \r\n"
           "  FROM TB_VMS_CTLR A    \r\n"
           " WHERE A.DEL_YN = 'N'   \r\n";
    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString VmsNo = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();

				TVmsCtlr *pObj = VmsManager->FLists.Find(VmsNo);
                if (!pObj) continue;

                pObj->MODULE.PowerOnTime  = Now().FormatString("yyyymmdd") + pADO->FieldByName("PANL_ON_TIME")->AsString;
                pObj->MODULE.PowerOffTime = Now().FormatString("yyyymmdd") + pADO->FieldByName("PANL_OFF_TIME")->AsString;
                pObj->MODULE.Retry        = VMS_MAX_RETRY_COUNT;
                nSelCnt++;
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    LINFO("   LoadVmsOnOffTime: %d", nSelCnt);

    return VERR_NONE;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::GetVmsLuminanceTime()
{
    String     sQry;
    TADOQuery *pADO = NULL;
    int        nSelCnt = 0;

    LINFO("GetVmsLuminanceTime: Start");

    sQry = "SELECT A.VMS_CTLR_NMBR, A.SCH_TIME, A.LUMINANCE  \r\n"
           "  FROM TB_VMS_LUM_SET_SCH A,                     \r\n"
           "       TB_VMS_CTLR        B                      \r\n"
           " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR         \r\n"
           "   AND B.DEL_YN = 'N'                            \r\n"
           "   AND A.USE_YN = 'Y'                            \r\n"
           "   AND A.SCH_TIME = TO_CHAR(SYSDATE, 'HH24MI')   \r\n";

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString VmsNo = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();
				TVmsCtlr *pObj = VmsManager->FLists.Find(VmsNo);
                if (!pObj) continue;

                pObj->LUMINANCE.SchTime = Now().FormatString("yyyymmdd") + pADO->FieldByName("SCH_TIME")->AsString;
                pObj->LUMINANCE.Value   = pADO->FieldByName("LUMINANCE")->AsInteger;
                pObj->LUMINANCE.Retry   = VMS_MAX_RETRY_COUNT;
                nSelCnt++;
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    LINFO("GetVmsLuminanceTime: %d", nSelCnt);

    return VERR_NONE;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::GetVmsDownLoadInfo()
{
    String     sQry;
    TADOQuery *pADO = NULL;
    int        nSelCnt = 0;
    int        nDnIdx;
    VMS_DOWNLOAD_INFO *pInfo;

return VERR_NONE;
    LDEBUG("GetVmsFileDownLoadInfo: Start");

    sQry = "SELECT A.VMS_CTLR_NMBR, A.RGST_DT,                               \r\n"
           "       A.FILETYPE, A.FILEID                                      \r\n"
           "  FROM TB_VMS_DOWNLOAD A                                         \r\n"
           " WHERE A.SENDSTARTDATE <= TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS')   \r\n"
           "   AND A.SENDRESULT = 0                                          \r\n"
           " ORDER BY A.VMS_CTLR_NMBR, A.RGST_DT DESC, A.FILETYPE, A.FILEID  \r\n";


    VmsIterator it;
    for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
    {
        TVmsCtlr *pObj = (TVmsCtlr*)it->second;
        pInfo = pObj->DOWNLOAD;
        InitDownLoadInfo(pInfo);
    }

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString VmsNo     = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();
				TVmsCtlr *pObj = VmsManager->FLists.Find(VmsNo);
                if (!pObj) continue;

                if (pObj->DOWNLOAD->Count < VMS_MAX_DOWNLOAD)
                {
                    pInfo = pObj->DOWNLOAD;

                    nDnIdx = pInfo->Count++;
                    pInfo->Unit[nDnIdx].RegDate     = pADO->FieldByName("RGST_DT")->AsString;
                    pInfo->Unit[nDnIdx].FileType    = pADO->FieldByName("FILETYPE")->AsString;
                    pInfo->Unit[nDnIdx].FileId      = pADO->FieldByName("FILEID")->AsString;
                    pInfo->Unit[nDnIdx].SendEndDate = Now().FormatString("yyyymmddhhnnss");
                    pInfo->Unit[nDnIdx].SendStep    = send_wait;
                    pInfo->Unit[nDnIdx].SendResult  = vms_download_fail;
                }
                nSelCnt++;
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
    {
        TVmsCtlr *pObj = (TVmsCtlr*)it->second;
        if (pObj->DOWNLOAD->Count > 0)
        {
            pObj->DOWNLOAD->Enable   = vms_download_enable;
            pObj->DOWNLOAD->SaveFlag = false;
        }
    }

    LINFO("GetVmsFileDownLoadInfo: %d", nSelCnt);

    return VERR_NONE;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::GetVmsImage()
{
    String     sQry;
    TADOQuery *pADO = NULL;
    TStream   *pStream = NULL;
    int        nSelCnt = 0;

    LINFO("GetVmsImage: Start");

    sQry = "SELECT A.*               \r\n"
           "  FROM TB_VMS_SYMB_LIB A \r\n";
    try
    {
        TCDSImage *pVmsImg;
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString sSymbolNmbr  = "";
                bool bTrafSymbol = false;

                int nSymbolNmbr = pADO->FieldByName("SYMBLIB_NMBR")->AsInteger;
                if (nSymbolNmbr >= 8000 && nSymbolNmbr <= 8999)
                {
                    bTrafSymbol = true;
                }

                sSymbolNmbr = AnsiString(nSymbolNmbr) + "0";

				pVmsImg = ImageManager->FLists.Find(sSymbolNmbr);
                if (!pVmsImg)
                {
                    pVmsImg = new TCDSImage();
                    pVmsImg->Nmbr = sSymbolNmbr;
                    ImageManager->FLists.Push(pVmsImg->Nmbr, pVmsImg);
                }
                pVmsImg->FLists.RemoveAll();

                pVmsImg->Type    = vms_image_type_bmp;
                pVmsImg->VmsType = pADO->FieldByName("VMS_TYPE_CD")->AsString.Trim(); //VMP0: 심볼, VMP1: 소통정보배경, VMP1:소통정보
                if (bTrafSymbol) pVmsImg->VmsType = "VMP2";

                pVmsImg->Clear();
    			pVmsImg->pImage->Picture->Bitmap->PixelFormat = pf4bit;

                TStream *pStream = pADO->CreateBlobStream(pADO->FieldByName("IMAG_DATA"), bmRead);
                try
                {
                    if (pStream && pStream->Size > 0)
                    {
                        pStream->Position = 0;
                        switch(pVmsImg->Type)
                        {
                        case vms_image_type_bmp: AssignBmp(pVmsImg->pImage, pStream); break;
                        case vms_image_type_gif: AssignGif(pVmsImg->pImage, pStream); break;
                        case vms_image_type_jpg: AssignJpg(pVmsImg->pImage, pStream); break;
                        case vms_image_type_pcx: break;
                        default: break;
                        }
                    }
                }
                __finally
                {
                    SAFE_DELETE(pStream);
                }
                nSelCnt++;

                if (pVmsImg->VmsType == "VMP2")
                {
                    for (int nTrf = 1; nTrf <= 3; nTrf++)
                    {
                        sSymbolNmbr = AnsiString(nSymbolNmbr) + AnsiString(nTrf);
                        //좌표가 바뀌더라도 셀정보에서 업데이트 한다.
                        //이미지내용이 바뀌는 경우는 없다
                        pVmsImg = ImageManager->FLists.Find(sSymbolNmbr);
                        if (pVmsImg) continue;

                        pVmsImg = new TCDSImage();
                        pVmsImg->Nmbr = sSymbolNmbr;
                        ImageManager->FLists.Push(pVmsImg->Nmbr, pVmsImg);
                        pVmsImg->FLists.RemoveAll();

                        pVmsImg->Type    = vms_image_type_bmp;
                        pVmsImg->VmsType = "VMP2";

                        pVmsImg->Clear();
                        pVmsImg->pImage->Picture->Bitmap->PixelFormat = pf4bit;

                        TStream *pStream = pADO->CreateBlobStream(pADO->FieldByName("IMAG_DATA"), bmRead);
                        try
                        {
                            if (pStream && pStream->Size > 0)
                            {
                                pStream->Position = 0;
                                switch(pVmsImg->Type)
                                {
                                case vms_image_type_bmp: AssignBmp(pVmsImg->pImage, pStream); break;
                                case vms_image_type_gif: AssignGif(pVmsImg->pImage, pStream); break;
                                case vms_image_type_jpg: AssignJpg(pVmsImg->pImage, pStream); break;
                                case vms_image_type_pcx: break;
                                default: break;
                                }
                            }
                        }
                        __finally
                        {
                            SAFE_DELETE(pStream);
                        }
                    }
                }
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }


    int result = GetVmsImageCell();

    //if (g_LogCfg.Debug)
    //FTP로 다운로드 해야 하기 때문에 파일로 저장해야 한다.
    //소통정보 이미지 같은 경우 디비에는 하나만 등록하고 여기서 조회할때
    //소통등급별로 이미지를 만든다.
    {
        AnsiString sImgFile;
        FOR_STL(TCDSImage*, pTmp, ImageManager->FLists)
        {
            sImgFile = g_sImgDir + pTmp->Nmbr;
            try
            {
                switch(pTmp->Type)
                {
                case vms_image_type_bmp: sImgFile += ".bmp"; SaveToFileBmp(pTmp->pImage, sImgFile); break;
                case vms_image_type_gif: sImgFile += ".gif"; SaveToFileGif(pTmp->pImage, sImgFile); break;
                case vms_image_type_jpg: sImgFile += ".jpg"; SaveToFileJpg(pTmp->pImage, sImgFile); break;
                case vms_image_type_pcx: sImgFile += ".pcx"; break;
                default: break;
                }
            }
            catch(Exception &e)
            {
            }
            sImgFile = g_sFtpDir + GetFtpImageId(pTmp->Nmbr);
            try
            {
                switch(pTmp->Type)
                {
                case vms_image_type_bmp: sImgFile += ".bmp"; SaveToFileBmp(pTmp->pImage, sImgFile); break;
                case vms_image_type_gif: sImgFile += ".gif"; SaveToFileGif(pTmp->pImage, sImgFile); break;
                case vms_image_type_jpg: sImgFile += ".jpg"; SaveToFileJpg(pTmp->pImage, sImgFile); break;
                case vms_image_type_pcx: sImgFile += ".pcx"; break;
                default: break;
                }
            }
            catch(Exception &e)
            {
            }
        }
    }

    VmsIterator it;
    for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
    {
        TVmsCtlr *pObj = (TVmsCtlr*)it->second;
        pObj->FSymbolDownload = true;
    }
    LINFO("GetVmsImage: %d", nSelCnt);

    return result;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::GetVmsImageCell()
{
    String     sQry;
    TADOQuery *pADO = NULL;
    int        nSelCnt = 0;

    LINFO("GetVmsImageCell: Start");

    sQry = "SELECT B.*                              \r\n"
           "  FROM TB_VMS_SYMB_LIB  A,              \r\n"
           "       TB_VMS_SYMB_IFSC B               \r\n"
           " WHERE A.SYMBLIB_NMBR = B.SYMBLIB_NMBR  \r\n"
           " ORDER BY B.SYMBLIB_NMBR, B.CELL_ID     \r\n";

    try
    {
        TCDSImage     *pVmsImg;
        TCDSImageCell *pImgCell;
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString SYMBLIB_NMBR = pADO->FieldByName("SYMBLIB_NMBR")->AsString.Trim();
				pVmsImg = ImageManager->FLists.Find(SYMBLIB_NMBR+"0");
                if (!pVmsImg)
                {
                    continue;
                }

                pImgCell = new TCDSImageCell();

                pImgCell->SYMBLIB_NMBR = SYMBLIB_NMBR;
                pImgCell->CELL_ID      = pADO->FieldByName("CELL_ID")->AsInteger;
                pImgCell->POSX         = pADO->FieldByName("POSX")->AsInteger;
                pImgCell->POSY         = pADO->FieldByName("POSY")->AsInteger;
                pImgCell->VMS_IFSC_ID  = pADO->FieldByName("VMS_IFSC_ID")->AsString;

                pVmsImg->FLists.Push(pImgCell->CELL_ID, pImgCell);

                //소통정보 이미지인 경우(원활,지체,정체 이미지 생성)
                if (pVmsImg->VmsType == "VMP2")
                {
                    for (int nTrf = 1; nTrf <= 3; nTrf++)
                    {
                        TCDSImage *pTmpImg = ImageManager->FLists.Find(SYMBLIB_NMBR+AnsiString(nTrf));
                        if (!pVmsImg) continue;

                        try
                        {
                            pTmpImg->pImage->Picture->Bitmap->Canvas->Lock();
                            pTmpImg->pImage->Picture->Bitmap->Canvas->Brush->Color = GradeToFillColor(nTrf);
                            TColor clColor = pTmpImg->pImage->Picture->Bitmap->Canvas->Pixels[pImgCell->POSX][pImgCell->POSY];
                            pTmpImg->pImage->Picture->Bitmap->Canvas->FloodFill(pImgCell->POSX, pImgCell->POSY, clColor, fsSurface);
                        }
                        __finally
                        {
                            pTmpImg->pImage->Picture->Bitmap->Canvas->Unlock();
                        }
                    }
                }
                nSelCnt++;
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    if (0)
    {
        FOR_STL(TCDSImage*, pTmp, ImageManager->FLists)
        {
            if (pTmp->FLists.Size() == 0) continue;
            LDEBUG("Image Cell: %s, Objects: %d", pTmp->Nmbr.c_str(), pTmp->FLists.Size());
        }
    }

    LINFO("GetVmsImageCell: %d", nSelCnt);

    return VERR_NONE;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::LoadVmsForm()
{
    String     sQry;
    TADOQuery *pADO = NULL;
    TStream   *pStream = NULL;
    int        nSelCnt = 0;

    LINFO("        LoadVmsForm: Start");

    sQry = "SELECT A.*           \r\n"
           "  FROM TB_VMS_FORM A \r\n";
    try
    {
        TCDSForm *pVmsForm;
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString sFormId = pADO->FieldByName("VMS_FORM_ID")->AsString.Trim();
				pVmsForm = FormManager->FLists.Find(sFormId);
                if (!pVmsForm)
                {
                    pVmsForm = new TCDSForm();
                    pVmsForm->VMS_FORM_ID = sFormId;
                    pVmsForm->MSG_TP      = 2;  //재난안전폼인경우 기본 2단메시지로 설정
                    FormManager->FLists.Push(pVmsForm->VMS_FORM_ID, pVmsForm);
                }
                pVmsForm->FLists.RemoveAll();

                pVmsForm->TrfBakImgId = ""; //소통정보 배경 이미지 ID
                pVmsForm->VMS_TYPE_CD          = pADO->FieldByName("VMS_TYPE_CD")->AsString;
                pVmsForm->VMS_FORM_TYPE_CD     = pADO->FieldByName("VMS_FORM_TYPE_CD")->AsInteger;
                pVmsForm->VMS_FORM_BCKG_HUE_CD = pADO->FieldByName("VMS_FORM_BCKG_HUE_CD")->AsInteger;
                pVmsForm->VMS_MSG_DSPL_DRCT_CD = pADO->FieldByName("VMS_MSG_DSPL_DRCT_CD")->AsInteger;
                pVmsForm->VMS_MSG_DSPL_MTHD_CD = pADO->FieldByName("VMS_MSG_DSPL_MTHD_CD")->AsInteger;

                pVmsForm->TrfIfsc = false;
                pVmsForm->TrfAxis = false;

                nSelCnt++;
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    LINFO("        LoadVmsForm: %d EA", nSelCnt);

    return LoadVmsFormObject();
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::LoadVmsFormObject()
{
    String     sQry;
    TADOQuery *pADO = NULL;
    TStream   *pStream = NULL;
    int        nSelCnt = 0;

    LINFO("  LoadVmsFormObject: Start");

#if 0
    sQry = "SELECT B.*                                \r\n"
           "  FROM TB_VMS_FORM A,                     \r\n"
           "       TB_VMS_FORM_OBJECT B               \r\n"
           " WHERE A.VMS_FORM_ID = B.VMS_FORM_ID      \r\n"
           " ORDER BY B.VMS_FORM_ID, B.FORM_OBJECT_ID \r\n";
#else
    sQry = "SELECT B.*, NVL(C.IMAG_DATA, B.VMS_DSPL_FIGR) AS IMAG_DATA  \r\n"
           "  FROM TB_VMS_FORM        A,                                \r\n"
           "       TB_VMS_FORM_OBJECT B,                                \r\n"
           "       TB_VMS_SYMB_LIB    C                                 \r\n"
           " WHERE A.VMS_FORM_ID  = B.VMS_FORM_ID                       \r\n"
           "   AND B.SYMBLIB_NMBR = C.SYMBLIB_NMBR(+)                   \r\n"
           " ORDER BY B.VMS_FORM_ID, B.FORM_OBJECT_ID                   \r\n";
#endif

    try
    {
        TCDSForm    *pVmsForm;
        TCDSFormObj *pFormObj;
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString sFormId = pADO->FieldByName("VMS_FORM_ID")->AsString.Trim();
				pVmsForm = FormManager->FLists.Find(sFormId);
                if (!pVmsForm)
                {
                   continue;
                }
                nSelCnt++;

                pFormObj = new TCDSFormObj();

                pFormObj->FORM_OBJECT_ID          = pADO->FieldByName("FORM_OBJECT_ID")->AsInteger;
                pFormObj->VMS_FORM_ID             = pADO->FieldByName("VMS_FORM_ID")->AsString;
                pFormObj->VMS_FORM_DSPL_ROW       = pADO->FieldByName("VMS_FORM_DSPL_ROW")->AsInteger;
                pFormObj->VMS_FORM_DSPL_CLMN      = pADO->FieldByName("VMS_FORM_DSPL_CLMN")->AsInteger;
                pFormObj->VMS_FORM_OBJECT_TYPE_CD = pADO->FieldByName("VMS_FORM_OBJECT_TYPE_CD")->AsInteger;
                pFormObj->VMS_FONT_TYPE_CD        = pADO->FieldByName("VMS_FONT_TYPE_CD")->AsInteger;
                pFormObj->VMS_FONT_HUE_CD         = pADO->FieldByName("VMS_FONT_HUE_CD")->AsInteger;
                pFormObj->VMS_FONT_STYL_CD        = pADO->FieldByName("VMS_FONT_STYL_CD")->AsInteger;
                pFormObj->VMS_FONT_SIZE           = pADO->FieldByName("VMS_FONT_SIZE")->AsInteger;
                pFormObj->VMS_FONT_ALIGN          = pADO->FieldByName("VMS_FONT_ALIGN")->AsInteger;
                pFormObj->VMS_DSPL_TXT            = pADO->FieldByName("VMS_DSPL_TXT")->AsString;
                pFormObj->VMS_DSPL_XCRDN          = pADO->FieldByName("VMS_DSPL_XCRDN")->AsInteger;
                pFormObj->VMS_DSPL_YCRDN          = pADO->FieldByName("VMS_DSPL_YCRDN")->AsInteger;
                pFormObj->VMS_DSPL_WIDTH          = pADO->FieldByName("VMS_DSPL_WIDTH")->AsInteger;
                pFormObj->VMS_DSPL_HEIGHT         = pADO->FieldByName("VMS_DSPL_HEIGHT")->AsInteger;
                pFormObj->VMS_DSPL_BLINKING       = pADO->FieldByName("VMS_DSPL_BLINKING")->AsInteger;
                pFormObj->VMS_DSPL_BKCOLOR        = pADO->FieldByName("VMS_DSPL_BKCOLOR")->AsInteger;
                pFormObj->VMS_DSPL_SIZE           = pADO->FieldByName("VMS_DSPL_SIZE")->AsInteger;
                pFormObj->TRFC_FILL_CD            = pADO->FieldByName("TRFC_FILL_CD")->AsString;
                pFormObj->SYMBLIB_NMBR            = pADO->FieldByName("SYMBLIB_NMBR")->AsString;
                pFormObj->VMS_IFSC_ID             = pADO->FieldByName("VMS_IFSC_ID")->AsString;

                pVmsForm->FLists.Push(pFormObj->FORM_OBJECT_ID, pFormObj);

                int nObjType = pFormObj->VMS_FORM_OBJECT_TYPE_CD;

                if (pVmsForm->VMS_FORM_TYPE_CD == enFormKindSafe && nObjType == 103) //재난안전폼이고 @재난안전문자 3열 인 경우
                {
                    pVmsForm->MSG_TP = 3;
                }
                if (pVmsForm->VMS_FORM_TYPE_CD == enFormKindTrfImg)
                {
                    //도형식 소통정보 폼인데 구간 소통정보를 하단에 표출하는 경우
                    //하나의 폼이 여러개의 소통정보를 표출되도록 하기 위함
                    switch(nObjType)
                    {
                    case 11://, '	@구간명
                    case 12://, '	@시점명
                    case 13://, '	@종점명
                    case 14://, '	@소통상황
                    case 15://, '	@통행시간
                    case 16://, '	@통행속도
                    case 17://, '	@소통정보이미지
                    case 18://, '	@지점명
                        pVmsForm->TrfIfsc = true;
                        break;
                    case 93://, '	@축시점명(순환)
                    case 94://, '	@축종점명(순환)
                    case 95://, '	@축소통상황(순환)
                    case 96://, '	@축통행시간(순환)
                        pVmsForm->TrfAxis = true;
                        break;
                    }
                }

                if (nObjType == 3)
                {
                    pVmsForm->TrfBakImgId = pFormObj->SYMBLIB_NMBR + "0";
                }

                if (nObjType ==  1 || //심볼
                    nObjType ==  2 || //이미지(파일에서 직접입력한것임)
                    nObjType ==  3 || //소통정보배경이미지
                    nObjType == 17 || //소통정보이미지1
                    nObjType == 27 || //소통정보이미지2
                    nObjType == 37 || //소통정보이미지3
                    nObjType == 47 )  //소통정보이미지4
                {
                    pFormObj->Clear();
                    pFormObj->pImage->Picture->Bitmap->PixelFormat = pf4bit;
                    //심볼에서 읽지 않고 폼오브젝트에 있는 이미지를 사용함
#if 0
                    TStream *pStream = pADO->CreateBlobStream(pADO->FieldByName("VMS_DSPL_FIGR"), bmRead);
#else
                    TStream *pStream = pADO->CreateBlobStream(pADO->FieldByName("IMAG_DATA"), bmRead);
#endif
                    try
                    {
                        if (pStream && pStream->Size > 0)
                        {
                            pStream->Position = 0;
                            AssignBmp(pFormObj->pImage, pStream);
                        }
                    }
                    __finally
                    {
                        SAFE_DELETE(pStream);
                    }
                }
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    if (0)//g_LogCfg.Debug)
    {
        FOR_STL(TCDSForm*, pTmp, FormManager->FLists)
        {
            LDEBUG("Vms Form: %s, Objects: %d", pTmp->VMS_FORM_ID.c_str(), pTmp->FLists.Size());
        }
    }

    LINFO("  LoadVmsFormObject: %d EA", nSelCnt);

    return VERR_NONE;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::SaveProcessStateProc(void)
{
	int               nResult;
	AnsiString        sQry;
	DB_STATUS_PROCESS sp;
	TADOQuery        *pADO = NULL;

	nResult = VERR_OTHER;

	//sp.PROCESSID = g_AppCfg.strProcessID;
	sp.RUNVERSION = "1";
	sp.STATUS     = g_SysInfo->State.Action;
	sp.COMM       = g_SysInfo->State.Comm;
	sp.DB         = g_SysInfo->State.DB;

    bool bHistIns = false;
    AnsiString SYST_ID      = g_AppCfg.sSystemId;
    AnsiString SYST_STTS_CD = "SPS1";
	try
	{
        pADO = new TADOQuery(NULL);
        pADO->Connection = GetDbConnection();

		try
		{
            pADO->Connection->BeginTrans();

            if (g_SysInfo->State.Action == state_error)
            {
                SYST_STTS_CD = "SPS3";
                bHistIns = true;
            }

			sQry = "UPDATE TB_UNIT_SYST_STTS                                   \r\n"
                   "   SET SYST_STTS_CD = :p02,                                \r\n"
                   "       UPDT_DT      = TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') \r\n"
                   " WHERE SYST_ID = :p01                                      \r\n";

            SQLText(pADO, sQry, false);
            SQLBind(pADO, "p01", SYST_ID);
            SQLBind(pADO, "p02", SYST_STTS_CD);
            SQLExec(pADO);

            //이력 정보는 기본적으로 5분마다 입력한다(상태정보가 바뀌면 바로 입력).
            int nCurMin = StrToInt(Now().FormatString("nn"));
            if (FProcessStateMin < 0)
            {
                //프로세스 최초 기동시...
                FProcessStateMin = nCurMin;
                bHistIns = true;
            }
            else
            if (!(nCurMin%5))
            {
                //5분주기 체크
                if (FProcessStateMin != nCurMin)
                {
                    FProcessStateMin = nCurMin;
                    bHistIns = true;
                }
            }

            if (bHistIns)
            {
                sQry = "INSERT INTO TB_UNIT_SYST_STTS_HS(SYST_ID, CRTN_DT, SYST_STTS_CD) \r\n"
                       "   VALUES(:p01, TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS'), :p02)      \r\n";

                SQLText(pADO, sQry, false);
                SQLBind(pADO, "p01", SYST_ID);
                SQLBind(pADO, "p02", SYST_STTS_CD);
                SQLExec(pADO);
            }

            pADO->Connection->CommitTrans();

			nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            pADO->Connection->RollbackTrans();
            ErrorString = String(E.ClassName()) + E.Message;
            DBERRORLOG("SaveProcessStateProc", String(E.ClassName()), E.Message, sQry);
		}
		catch(Exception &e)
		{
            pADO->Connection->RollbackTrans();
            ErrorString = String(e.ClassName()) + e.Message;
            DBERRORLOG("SaveProcessStateProc", String(e.ClassName()), e.Message, sQry);
		}
	}
	__finally
	{
        if (pADO)
        {
            SQLClose(pADO);
            SAFE_DELETE(pADO);
        }
	}

    LDEBUG("SYST_ID: %s, STTS_CD: %s", SYST_ID.c_str(), SYST_STTS_CD.c_str());

    return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::SaveEquipStateAllProc(bool ATerm/*=false*/)
{
	int        nResult = VERR_NONE;
	AnsiString sQry, iQry;
	TADOQuery *pADO  = NULL;
	TADOQuery *pADOI = NULL;


    // 상태가 변경되면 바로 입력, 기타 5분마다 이력정보를 입력한다.
    bool bSaveHist = false;

    int nCurrMin = StrToInt(Now().FormatString("nn"));
    if ((nCurrMin % 5) == 0) //매 5분마다 무조건 입력
    {
        if (FEquipStateMin != nCurrMin)
        {
            bSaveHist = true;
            FEquipStateMin = nCurrMin;
        }
    }

    String sSysTime = Now().FormatString("yyyymmddhhnnss");
    String sRgstDt  = sSysTime;
    if (ATerm)
    {
        bSaveHist = true;
        FEquipStateMin = nCurrMin;
        if (FEquipStateInsTime == sSysTime)
        {
            sRgstDt = IncSecond(Now(), 1).FormatString("yyyymmddhhnnss");
        }
    }

    sQry = "MERGE INTO TB_VMS_STTS_PRST L                                     \r\n"
           "USING (SELECT :p01 AS VMS_CTLR_NMBR,                              \r\n"
           "              :p02 AS RGST_DT,                                    \r\n"
           "              :p03 AS CONN_STTS_CD,                               \r\n"
           "              :p04 AS CBOXDOOR_OPEN_STTS_CD,                      \r\n"
           "              :p05 AS PWER_STTS_CD,                               \r\n"
           "              :p06 AS CBOX_TMPR,                                  \r\n"
           "              :p07 AS CBOX_HMDT,                                  \r\n"
           "              :p08 AS FAN_STTS_CD,                                \r\n"
           "              :p09 AS HETR_STTS_CD,                               \r\n"
           "              :p10 AS CBOXFAN_STTS_CD,                            \r\n"
           "              :p11 AS MODL_STTS,                                  \r\n"
           "              :p12 AS PWER_STTS                                   \r\n"
           "         FROM DUAL) M                                             \r\n"
           "ON (L.VMS_CTLR_NMBR = M.VMS_CTLR_NMBR)                            \r\n"
           "WHEN MATCHED THEN                                                 \r\n"
           "    UPDATE SET L.RGST_DT               = M.RGST_DT,               \r\n"
           "               L.CONN_STTS_CD          = M.CONN_STTS_CD,          \r\n"
           "               L.CBOXDOOR_OPEN_STTS_CD = M.CBOXDOOR_OPEN_STTS_CD, \r\n"
           "               L.PWER_STTS_CD          = M.PWER_STTS_CD,          \r\n"
           "               L.CBOX_TMPR             = M.CBOX_TMPR,             \r\n"
           "               L.CBOX_HMDT             = M.CBOX_HMDT,             \r\n"
           "               L.FAN_STTS_CD           = M.FAN_STTS_CD,           \r\n"
           "               L.HETR_STTS_CD          = M.HETR_STTS_CD,          \r\n"
           "               L.CBOXFAN_STTS_CD       = M.CBOXFAN_STTS_CD,       \r\n"
           "               L.MODL_STTS             = M.MODL_STTS,             \r\n"
           "               L.PWER_STTS             = M.PWER_STTS              \r\n"
           "WHEN NOT MATCHED THEN                                             \r\n"
           "    INSERT (L.VMS_CTLR_NMBR,                                      \r\n"
           "            L.RGST_DT,                                            \r\n"
           "            L.CONN_STTS_CD,                                       \r\n"
           "            L.CBOXDOOR_OPEN_STTS_CD,                              \r\n"
           "            L.PWER_STTS_CD,                                       \r\n"
           "            L.CBOX_TMPR,                                          \r\n"
           "            L.CBOX_HMDT,                                          \r\n"
           "            L.FAN_STTS_CD,                                        \r\n"
           "            L.HETR_STTS_CD,                                       \r\n"
           "            L.CBOXFAN_STTS_CD,                                    \r\n"
           "            L.MODL_STTS,                                          \r\n"
           "            L.PWER_STTS                                           \r\n"
           "           )                                                      \r\n"
           "    VALUES (M.VMS_CTLR_NMBR,                                      \r\n"
           "            M.RGST_DT,                                            \r\n"
           "            M.CONN_STTS_CD,                                       \r\n"
           "            M.CBOXDOOR_OPEN_STTS_CD,                              \r\n"
           "            M.PWER_STTS_CD,                                       \r\n"
           "            M.CBOX_TMPR,                                          \r\n"
           "            M.CBOX_HMDT,                                          \r\n"
           "            M.FAN_STTS_CD,                                        \r\n"
           "            M.HETR_STTS_CD,                                       \r\n"
           "            M.CBOXFAN_STTS_CD,                                    \r\n"
           "            M.MODL_STTS,                                          \r\n"
           "            M.PWER_STTS                                           \r\n"
           "           )                                                      \r\n";

    iQry = "INSERT INTO TB_VMS_STTS_HS     \r\n"
           "    (                          \r\n"
           "      VMS_CTLR_NMBR,           \r\n"
           "      RGST_DT,                 \r\n"
           "      CONN_STTS_CD,            \r\n"
           "      PWER_STTS_CD,            \r\n"
           "      FAN_STTS_CD,             \r\n"
           "      HETR_STTS_CD,            \r\n"
           "      CBOXDOOR_OPEN_STTS_CD,   \r\n"
           "      CBOXFAN_STTS_CD,         \r\n"
           "      CBOXHETR_STTS_CD,        \r\n"
           "      CBOX_TMPR,               \r\n"
           "      CBOX_HMDT,               \r\n"
           "      VMS_TMPR                 \r\n"
//           "      MODL_STTS,               \r\n"
//           "      PWER_STTS                \r\n"
           "      )                        \r\n"
           "SELECT VMS_CTLR_NMBR,          \r\n"
           "       :p01,                   \r\n"
           "       CONN_STTS_CD,           \r\n"
           "       PWER_STTS_CD,           \r\n"
           "       FAN_STTS_CD,            \r\n"
           "       HETR_STTS_CD,           \r\n"
           "       CBOXDOOR_OPEN_STTS_CD,  \r\n"
           "       CBOXFAN_STTS_CD,        \r\n"
           "       CBOXHETR_STTS_CD,       \r\n"
           "       CBOX_TMPR,              \r\n"
           "       CBOX_HMDT,              \r\n"
           "       VMS_TMPR                \r\n"
//           "       MODL_STTS,              \r\n"
//           "       PWER_STTS               \r\n"
           "  FROM TB_VMS_STTS_PRST        \r\n"
           " WHERE RGST_DT = :p02          \r\n";

	try
	{
        pADO = new TADOQuery(NULL);
        pADO->Connection = GetDbConnection();

        String ERR_MODL_STTS = "22222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222";
        String ERR_PWER_STTS = "2222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222222";
		try
		{
            pADO->Connection->BeginTrans();

            SQLText(pADO,  sQry, false);

            VmsIterator it;
            for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
            {
                TVmsCtlr *pObj = (TVmsCtlr*)it->second;
                if (pObj->Server.UseFlag != bit_enable) continue;

                if (bSaveHist)
                {
                    pObj->FSaveState = true;
                }
                else
                {
                    pObj->FSaveState = ChangedState(&pObj->DSTATE, &pObj->RSTATE);
                }
                //pObj->RSTATE.Comm = pObj->DSTATE.Comm;
                if (pObj->FSaveState)
                {
                    memcpy(&pObj->DSTATE, &pObj->RSTATE, sizeof(pObj->DSTATE));
                }
                pObj->DSTATE.Comm = (pObj->Server.Status == process_run) ? vms_normal : vms_error;

                String VMS_CTLR_NMBR         = pObj->VmsNo;
                String RGST_DT               = sSysTime;
                String CONN_STTS_CD          = pObj->DSTATE.Comm == vms_normal ? "CMS0" : "CMS1";
                String CBOXDOOR_OPEN_STTS_CD = pObj->DSTATE.DoorStatus == vms_close ? "CDS0" : "CDS1";
                String PWER_STTS_CD          = pObj->DSTATE.ModulePowerStatus == vms_normal ? "PWS0" : "PWS1";
                String CBOX_TMPR             = String(pObj->DSTATE.BodyTemp);
                String CBOX_HMDT             = String(pObj->DSTATE.LuminanceStatus);
                String FAN_STTS_CD           = pObj->DSTATE.FanStatus == vms_on ? "PAS0" : "PAS1";
                String HETR_STTS_CD          = pObj->DSTATE.HeaterStatus == vms_on ? "HTS0" : "HTS1";
                String CBOXFAN_STTS_CD       = pObj->DSTATE.ModuleState == vms_normal ? "MOS0" : "MOS1";
                String MODL_STTS             = "";
                String PWER_STTS             = "";

                if (CONN_STTS_CD != "CMS0") {
                    CBOXDOOR_OPEN_STTS_CD = "CDS2";
                    PWER_STTS_CD          = "PWS2";
                    CBOX_TMPR             = "0";
                    CBOX_HMDT             = "0";
                    FAN_STTS_CD           = "PAS2";
                    HETR_STTS_CD          = "HTS2";
                    CBOXFAN_STTS_CD       = "MOS2";
                    MODL_STTS             = ERR_MODL_STTS;
                    PWER_STTS             = ERR_PWER_STTS;
                } else {
                    int bit;
                    int idx = 0;
                    int nVerCnt = (int)pObj->RSTATE.ModuleHorizontal;
                    int nHorCnt = (int)pObj->RSTATE.ModuleVertical;
                    int ii, jj;
                    for (ii = 0; ii < nVerCnt; ii++)
                    {
                        for (jj = 0; jj < nHorCnt; jj++)
                        {
                            idx = ii*jj;
                            bit = VComm_GetBitString(pObj->RSTATE.ModuleStatus, idx);
                            MODL_STTS += (bit == vms_module_normal) ? "1" : "0";
                            if (idx >= INT_VMS_MAX_MODULE_BIT) {
                                break;
                            }
                        }
                    }
                    nVerCnt = (int)pObj->RSTATE.PowerCount;
                    for (ii = 0; ii < nVerCnt; ii++)
                    {
                        bit = VComm_GetBitString(pObj->RSTATE.PowerStatus, ii);
                        PWER_STTS += (bit == vms_module_normal) ? "1" : "0";
                        if (ii >= INT_VMS_MAX_POWER_BIT) {
                            break;
                        }
                    }
                }

                SQLBind(pADO, "p01", VMS_CTLR_NMBR);
                SQLBind(pADO, "p02", RGST_DT);
                SQLBind(pADO, "p03", CONN_STTS_CD);
                SQLBind(pADO, "p04", CBOXDOOR_OPEN_STTS_CD);
                SQLBind(pADO, "p05", PWER_STTS_CD);
                SQLBind(pADO, "p06", CBOX_TMPR);
                SQLBind(pADO, "p07", CBOX_HMDT);
                SQLBind(pADO, "p08", FAN_STTS_CD);
                SQLBind(pADO, "p09", HETR_STTS_CD);
                SQLBind(pADO, "p10", CBOXFAN_STTS_CD);
                SQLBind(pADO, "p11", MODL_STTS);
                SQLBind(pADO, "p12", PWER_STTS);

                SQLExec(pADO);

#if 0
                if (pObj->FSaveState)
                {
                    //이전주기에 통신이상 이력을 입력하였고 이번에도 통신이상이면
                    //이력으로 저장하지 않는다.
                    if (pObj->DSTATE.Comm == vms_error &&
                        pObj->FOldState   == vms_error)
                    {
                        continue;
                    }

                    SQLBind(pADOI, "p01", VMS_CTLR_NMBR);
                    SQLBind(pADOI, "p02", RGST_DT);
                    SQLBind(pADOI, "p03", CONN_STTS_CD);
                    SQLBind(pADOI, "p04", CBOXDOOR_OPEN_STTS_CD);
                    SQLBind(pADOI, "p05", PWER_STTS_CD);
                    SQLBind(pADOI, "p06", CBOX_TMPR);
                    SQLBind(pADOI, "p07", CBOX_HMDT);
                    SQLBind(pADOI, "p08", FAN_STTS_CD);
                    SQLBind(pADOI, "p09", HETR_STTS_CD);
                    SQLBind(pADOI, "p10", CBOXFAN_STTS_CD);

                    SQLExec(pADOI);

                    pObj->FOldState = pObj->DSTATE.Comm;
                }
#endif
            }

            pADO->Connection->CommitTrans();

            //TODO: 20181023 트리거 사용하지 않고 매5분주기에 이력 정보를 저장하도록 수정
            if (bSaveHist)
            {
                pADOI = new TADOQuery(NULL);
                pADOI->Connection = GetDbConnection();
                pADOI->Connection->BeginTrans();
                SQLText(pADOI, iQry, false);
                SQLBind(pADOI, "p01", sRgstDt);
                SQLBind(pADOI, "p02", sSysTime);
                SQLExec(pADOI);
                pADOI->Connection->CommitTrans();
                if (pADOI)
                {
                    SQLClose(pADOI);
                    SAFE_DELETE(pADOI);
                }
            }
            FEquipStateInsTime = sSysTime;

			nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            pADO->Connection->RollbackTrans();
            ErrorString = String(E.ClassName()) + E.Message;
            DBERRORLOG("SaveEquipStateAllProc", String(E.ClassName()), E.Message, sQry);
		}
		catch(Exception &e)
		{
            pADO->Connection->RollbackTrans();
            ErrorString = String(e.ClassName()) + e.Message;
            DBERRORLOG("SaveEquipStateAllProc", String(e.ClassName()), e.Message, sQry);
		}
	}
	__finally
	{
        if (pADO)
        {
            SQLClose(pADO);
            SAFE_DELETE(pADO);
        }
	}

	return SendEquipStateAllProc();
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::SendEquipStateAllProc(void)
{
	int               nResult = VERR_NONE;
    INT_VMS_STATE_RES Res;
    INT_VMS_STATE    *pVms;

    memset((char*)&Res, 0x00, sizeof(Res));
    Res.Total = VmsManager->Total;
    Res.Error = VmsManager->Error;
    Res.Normal= VmsManager->Normal;
    Res.Module= VmsManager->Module;

    VmsIterator it;
    for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
    {
        TVmsCtlr *pObj = (TVmsCtlr*)it->second;
        if (pObj->Server.UseFlag != bit_enable) continue;

        pVms = &Res.Unit[Res.Count++];
        memcpy((char*)pVms, (char*)&pObj->DSTATE, sizeof(INT_VMS_STATE));
        if (Res.Count >= INT_MAX_VMS_STATE)
        {
            if (g_AppCfg.bSendCenterComm) {
                nResult = VComm_VmsStateNotify(&Res);
            }

            memset((char*)&Res, 0x00, sizeof(Res));
            Res.Total = VmsManager->Total;
            Res.Error = VmsManager->Error;
            Res.Normal= VmsManager->Normal;
            Res.Module= VmsManager->Module;
        }
    }

    if (Res.Count > 0)
    {
        if (g_AppCfg.bSendCenterComm) {
            nResult = VComm_VmsStateNotify(&Res);
        }
    }

	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::SaveEquipStateProc(TVmsCtlr *AObj, int AServerState)
{
	int        nResult = VERR_NONE;
	AnsiString sQry;
	TADOQuery *pADO = NULL;

    if (!AObj) return nResult;

    TVmsCtlr *pObj = AObj;

    if (AServerState)
    {
        //VMS가 접속또는 종료인 경우(조건없이 업데이트)
        memcpy(&pObj->DSTATE, &pObj->RSTATE, sizeof(pObj->DSTATE));
    }
    else
    {
        //VMS클라이언트가 상태정보를 수집한 경우
        //상태정보가 바뀐경우만 업데이트
        pObj->FSaveState = ChangedState(&pObj->DSTATE, &pObj->RSTATE);
        if (!pObj->FSaveState) return nResult;
        //if (pObj->Server.Status != process_run) return nResult;
        memcpy(&pObj->DSTATE, &pObj->RSTATE, sizeof(pObj->DSTATE));
    }
    pObj->DSTATE.Comm = pObj->Server.Status == process_run ? vms_normal : vms_error;
    //pObj->FOldState = pObj->DSTATE.Comm;    //이전상태저장

    String sSysTime = Now().FormatString("yyyymmddhhnnss");

    sQry = "MERGE INTO TB_VMS_STTS_PRST L                                     \r\n"
           "USING (SELECT :p01 AS VMS_CTLR_NMBR,                              \r\n"
           "              :p02 AS RGST_DT,                                    \r\n"
           "              :p03 AS CONN_STTS_CD,                               \r\n"
           "              :p04 AS CBOXDOOR_OPEN_STTS_CD,                      \r\n"
           "              :p05 AS PWER_STTS_CD,                               \r\n"
           "              :p06 AS CBOX_TMPR,                                  \r\n"
           "              :p07 AS CBOX_HMDT,                                  \r\n"
           "              :p08 AS FAN_STTS_CD,                                \r\n"
           "              :p09 AS HETR_STTS_CD,                               \r\n"
           "              :p10 AS CBOXFAN_STTS_CD                             \r\n"
           "         FROM DUAL) M                                             \r\n"
           "ON (L.VMS_CTLR_NMBR = M.VMS_CTLR_NMBR)                            \r\n"
           "WHEN MATCHED THEN                                                 \r\n"
           "    UPDATE SET L.RGST_DT               = M.RGST_DT,               \r\n"
           "               L.CONN_STTS_CD          = M.CONN_STTS_CD,          \r\n"
           "               L.CBOXDOOR_OPEN_STTS_CD = M.CBOXDOOR_OPEN_STTS_CD, \r\n"
           "               L.PWER_STTS_CD          = M.PWER_STTS_CD,          \r\n"
           "               L.CBOX_TMPR             = M.CBOX_TMPR,             \r\n"
           "               L.CBOX_HMDT             = M.CBOX_HMDT,             \r\n"
           "               L.FAN_STTS_CD           = M.FAN_STTS_CD,           \r\n"
           "               L.HETR_STTS_CD          = M.HETR_STTS_CD,          \r\n"
           "               L.CBOXFAN_STTS_CD       = M.CBOXFAN_STTS_CD        \r\n"
           "WHEN NOT MATCHED THEN                                             \r\n"
           "    INSERT (L.VMS_CTLR_NMBR,                                      \r\n"
           "            L.RGST_DT,                                            \r\n"
           "            L.CONN_STTS_CD,                                       \r\n"
           "            L.CBOXDOOR_OPEN_STTS_CD,                              \r\n"
           "            L.PWER_STTS_CD,                                       \r\n"
           "            L.CBOX_TMPR,                                          \r\n"
           "            L.CBOX_HMDT,                                          \r\n"
           "            L.FAN_STTS_CD,                                        \r\n"
           "            L.HETR_STTS_CD,                                       \r\n"
           "            L.CBOXFAN_STTS_CD)                                    \r\n"
           "    VALUES (M.VMS_CTLR_NMBR,                                      \r\n"
           "            M.RGST_DT,                                            \r\n"
           "            M.CONN_STTS_CD,                                       \r\n"
           "            M.CBOXDOOR_OPEN_STTS_CD,                              \r\n"
           "            M.PWER_STTS_CD,                                       \r\n"
           "            M.CBOX_TMPR,                                          \r\n"
           "            M.CBOX_HMDT,                                          \r\n"
           "            M.FAN_STTS_CD,                                        \r\n"
           "            M.HETR_STTS_CD,                                       \r\n"
           "            M.CBOXFAN_STTS_CD)                                    \r\n";

	try
	{
        pADO = new TADOQuery(NULL);
        pADO->Connection = GetDbConnection();

		try
		{
            pADO->Connection->BeginTrans();

            SQLText(pADO, sQry, false);

            {
                String VMS_CTLR_NMBR         = pObj->VmsNo;
                String RGST_DT               = sSysTime;
                String CONN_STTS_CD          = pObj->DSTATE.Comm == vms_normal ? "CMS0" : "CMS1";
                String CBOXDOOR_OPEN_STTS_CD = pObj->DSTATE.DoorStatus == vms_close ? "CDS0" : "CDS1";
                String PWER_STTS_CD          = pObj->DSTATE.ModulePowerStatus == vms_normal ? "PWS0" : "PWS1";
                String CBOX_TMPR             = String(pObj->DSTATE.BodyTemp);
                String CBOX_HMDT             = String(pObj->DSTATE.LuminanceStatus);
                String FAN_STTS_CD           = pObj->DSTATE.FanStatus == vms_on ? "PAS0" : "PAS1";
                String HETR_STTS_CD          = pObj->DSTATE.HeaterStatus == vms_on ? "HTS0" : "HTS1";
                String CBOXFAN_STTS_CD       = pObj->DSTATE.ModuleState == vms_normal ? "MOS0" : "MOS1";

                if (CONN_STTS_CD != "CMS0" ||
                    AServerState == 1) //통신이 비정상이거나 VMS가 최초로 접속한 경우(상태정보를 알수 없다)
                {
                    CBOXDOOR_OPEN_STTS_CD = "CDS2";
                    PWER_STTS_CD          = "PWS2";
                    CBOX_TMPR             = "0";
                    CBOX_HMDT             = "0";
                    FAN_STTS_CD           = "PAS2";
                    HETR_STTS_CD          = "HTS2";
                    CBOXFAN_STTS_CD       = "MOS2";
                }

                SQLBind(pADO, "p01", VMS_CTLR_NMBR);
                SQLBind(pADO, "p02", RGST_DT);
                SQLBind(pADO, "p03", CONN_STTS_CD);
                SQLBind(pADO, "p04", CBOXDOOR_OPEN_STTS_CD);
                SQLBind(pADO, "p05", PWER_STTS_CD);
                SQLBind(pADO, "p06", CBOX_TMPR);
                SQLBind(pADO, "p07", CBOX_HMDT);
                SQLBind(pADO, "p08", FAN_STTS_CD);
                SQLBind(pADO, "p09", HETR_STTS_CD);
                SQLBind(pADO, "p10", CBOXFAN_STTS_CD);

                SQLExec(pADO);


    sQry = "UPDATE TB_VMS_CTLR                   \r\n"
           "   SET VMS_PHSE_CHNG_CYCL    = :p01, \r\n"
           "       VMS_CMNC_ERR_BASS_VAL = :p02, \r\n"
           "       FAN_MTNS_TMPR         = :p03, \r\n"
           "       HETR_MTNS_TMPR        = :p04, \r\n"
           "       VMS_MODL_ERR_RATE     = :p05  \r\n"
           " WHERE VMS_CTLR_NMBR = :p06          \r\n";

                if (AServerState == 0)  //상태정보를 정상적으로 수집한 경우에만
                {
                    if (pObj->VMS_PHSE_CHNG_CYCL    != pObj->DSTATE.ScheduledMessageOperatingTime ||
                        pObj->VMS_CMNC_ERR_BASS_VAL != pObj->DSTATE.ModuleOperatingTemperature    ||
                        pObj->FAN_MTNS_TMPR         != pObj->DSTATE.FanOperatingTemperature       ||
                        pObj->HETR_MTNS_TMPR        != pObj->DSTATE.HeaterOperatingTemperature    ||
                        pObj->VMS_MODL_ERR_RATE     != pObj->DSTATE.ModuleBasicFailureRate        )
                    {
                        pObj->VMS_PHSE_CHNG_CYCL    = pObj->DSTATE.ScheduledMessageOperatingTime;
                        pObj->VMS_CMNC_ERR_BASS_VAL = pObj->DSTATE.ModuleOperatingTemperature;
                        pObj->FAN_MTNS_TMPR         = pObj->DSTATE.FanOperatingTemperature;
                        pObj->HETR_MTNS_TMPR        = pObj->DSTATE.HeaterOperatingTemperature;
                        pObj->VMS_MODL_ERR_RATE     = pObj->DSTATE.ModuleBasicFailureRate;

                        SQLText(pADO, sQry, false);

                        SQLBind(pADO, "p01", pObj->VMS_PHSE_CHNG_CYCL);
                        SQLBind(pADO, "p02", pObj->VMS_CMNC_ERR_BASS_VAL);
                        SQLBind(pADO, "p03", pObj->FAN_MTNS_TMPR);
                        SQLBind(pADO, "p04", pObj->HETR_MTNS_TMPR);
                        SQLBind(pADO, "p05", pObj->VMS_MODL_ERR_RATE);
                        SQLBind(pADO, "p06", VMS_CTLR_NMBR);

                        SQLExec(pADO);
                    }
                }
            }
            pADO->Connection->CommitTrans();

			nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            pADO->Connection->RollbackTrans();
            ErrorString = String(E.ClassName()) + E.Message;
            DBERRORLOG("SaveEquipStateProc", String(E.ClassName()), E.Message, sQry);
		}
		catch(Exception &e)
		{
            pADO->Connection->RollbackTrans();
            ErrorString = String(e.ClassName()) + e.Message;
            DBERRORLOG("SaveEquipStateProc", String(e.ClassName()), e.Message, sQry);
		}
	}
	__finally
	{
        if (pADO)
        {
            SQLClose(pADO);
            SAFE_DELETE(pADO);
        }
	}

    //상태정보를 클라이언트로 전송
    INT_VMS_STATE_RES Res;
    memset((char*)&Res, 0x00, sizeof(Res));
    Res.Total = VmsManager->Total;
    Res.Error = VmsManager->Error;
    Res.Normal= VmsManager->Normal;
    Res.Module= VmsManager->Module;
    Res.Count = 1;
    memcpy((char*)&Res.Unit[0], (char*)&pObj->DSTATE, sizeof(INT_VMS_STATE));
    if (g_AppCfg.bSendCenterComm) {
        nResult = VComm_VmsStateNotify(&Res);
	}
    return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::DataSaveProc(void *pData)
{
#if 0
	int              nResult;
	SET_INFO_STRUCT *pSet;

	nResult = VERR_NONE;

    if (!pData) return VERR_OTHER;

    try
    {
        pSet = (SET_INFO_STRUCT *)pData;

        switch(pSet->CtlType)
        {
        case CTL_TYPE_PARA_SET:
            break;
        case CTL_TYPE_MODULE_ON:
        case CTL_TYPE_MODULE_OFF:
        case CTL_TYPE_RESET:
            break;
        }
    }
    __finally
    {
        delete[] (char *)pData;
    }

	return nResult;
#else
return 0;
#endif
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::LoadIfscTrafficInfo()
{
    String     sQry;
    TADOQuery *pADO = NULL;
    int        nSelCnt = 0;

    LINFO("LoadIfscTrafficInfo: Start");

    sQry = "SELECT A.VMS_IFSC_ID, A.VMS_IFSC_NM, A.DSPL_STRT_NODE_NM, A.DSPL_END_NODE_NM, \r\n"
           "       A.ROAD_NM, A.SPOT_NM,                                                  \r\n"
           "       A.DETR_ID, A.AXIS_YN,                                                  \r\n"
           "       NVL(B.RGST_DT,       '') AS RGST_DT,                                   \r\n"
           "       NVL(B.CMTR_GRAD_CD, '0') AS CMTR_GRAD_CD,                              \r\n"
           "       NVL(B.SPED,           0) AS SPED,                                      \r\n"
           "       NVL(B.TRVL_HH,        0) AS TRVL_HH                                    \r\n"
           "  FROM TB_VMS_IFSC A,                                                         \r\n"
           "       (SELECT *                                                              \r\n"
           "          FROM TB_VMS_CMTRINFR                                                \r\n"
           "         WHERE RGST_DT >= TO_CHAR(SYSDATE-10/1440, 'YYYYMMDDHH24MISS') ) B    \r\n"
           " WHERE A.VMS_IFSC_ID = B.VMS_IFSC_ID(+)                                       \r\n";

    FOR_STL(TCDSIfsc*, pObj, IfscManager->FLists)
    {
        pObj->CMTR_GRAD_CD = "0";
        pObj->TRVL_HH      = 0;
        pObj->SPED         = 0;
    }

    try
    {
        TCDSIfsc *pIfsc;
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString VMS_IFSC_ID = pADO->FieldByName("VMS_IFSC_ID")->AsString.Trim();
				pIfsc = IfscManager->FLists.Find(VMS_IFSC_ID);
                if (!pIfsc)
                {
                    pIfsc = new TCDSIfsc();
                    pIfsc->VMS_IFSC_ID = VMS_IFSC_ID;
                    IfscManager->FLists.Push(pIfsc->VMS_IFSC_ID, pIfsc);
                }

                pIfsc->VMS_IFSC_NM       = pADO->FieldByName("VMS_IFSC_NM")->AsString;
                pIfsc->DSPL_STRT_NODE_NM = pADO->FieldByName("DSPL_STRT_NODE_NM")->AsString;
                pIfsc->DSPL_END_NODE_NM  = pADO->FieldByName("DSPL_END_NODE_NM")->AsString;
                pIfsc->DETR_ID           = pADO->FieldByName("DETR_ID")->AsString;
                pIfsc->ROAD_NM           = pADO->FieldByName("ROAD_NM")->AsString;
                pIfsc->SPOT_NM           = pADO->FieldByName("SPOT_NM")->AsString;
                pIfsc->AXIS_YN           = pADO->FieldByName("AXIS_YN")->AsString;

                pIfsc->RGST_DT      = pADO->FieldByName("RGST_DT")->AsString;
                pIfsc->CMTR_GRAD_CD = pADO->FieldByName("CMTR_GRAD_CD")->AsString;
                pIfsc->SPED         = pADO->FieldByName("SPED")->AsInteger;
                pIfsc->TRVL_HH      = pADO->FieldByName("TRVL_HH")->AsInteger;
                /**
                *  TODO: 20220816: 가공서버에서 통행시간이 1분 미만인 것은 0분으로 처리하는것으로 확인됌
                **/
                if (pIfsc->TRVL_HH <= 0) {
                    pIfsc->TRVL_HH = 1;
                }

                nSelCnt++;
            }
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return VERR_OTHER;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return VERR_OTHER;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    if (0)
    {
        FOR_STL(TCDSIfsc*, pTmp, IfscManager->FLists)
        {
            try
            {
                LDEBUG("Ifsc: %s, Grad: %s", pTmp->VMS_IFSC_ID.c_str(), pTmp->CMTR_GRAD_CD.c_str());
            }
            catch(Exception &e)
            {
            }
        }
    }

    LINFO("LoadIfscTrafficInfo: %d EA", nSelCnt);

    return VERR_NONE;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::ClearVmsProvideMode(AnsiString AVmsId)
{
    int        nSelCnt= 0;

    LINFO("ClearVmsProvideMode: Start");

    FFormDsplDt = Now().FormatString("yyyymmddhhnnss");

    VmsIterator it;
    for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
    {
        TVmsCtlr *pObj = (TVmsCtlr*)it->second;

        if (pObj->Server.UseFlag != bit_enable) continue;

        if (!pObj->FProvide) continue;

        pObj->CTLMODE->MaxDisplayForm = 0;//pObj->VMS_MAX_PHSE_NUM; //0
        pObj->CTLMODE->Enable         = object_disable;
        pObj->CTLMODE->SvcDate        = FFormDsplDt;
        pObj->CTLMODE->SaveFlag       = -1;
        pObj->CTLMODE->pTimer         = Now();
        pObj->CTLMODE->Result         = false;

        ScheduleInit(pObj->SCHEDULE);   //스케줄정보
        EventInit(pObj->INCIDENT);      //돌발정보
        EventInit(pObj->EVENT);         //이벤트(공사/행사)정보
        SafeInit(pObj->SAFE);           //재난안전정보

        pObj->pForms->Clear();

        nSelCnt++;
    }
    LINFO("ClearVmsProvideMode: %d EA", nSelCnt);
    return VERR_NONE;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::LoadVmsScheduleInfo(AnsiString AVmsId)
{
	int         nResult;
	AnsiString  sQry;
	int         nSelCnt = 0;
	TADOQuery  *pADO = NULL;

	nResult = VERR_OTHER;

    LINFO("LoadVmsScheduleInfo: Start");

#if 0
typedef enum enFormType
{
    enFormTraffic = 0,
    enFormDolbal,
    enFormGongsa,
    enFormHongbo,
    enFormDeture,
    enFormFixed,
    enFormBase,
    enFormCongest,
    enFormSafe,
} EN_FORM_TYPE;
#endif
    sQry = "SELECT B.*, DECODE(B.TRFC_SITU_TYPE_CD, '0', 8,                \r\n"
           "                                        '1', 4,                \r\n"
           "                                        '2', 5,                \r\n"
           "                                        '3', 6,                \r\n"
           "                                        '4', 7,                \r\n"
           "                                        '5', 2,                \r\n"
           "                                        '6', 1,                \r\n"
           "                                        '7', 9,                \r\n"
           "                                        '8', 0, 10) AS SCHPRIT \r\n"
           "  FROM TB_VMS_CTLR A,                                          \r\n"
           "       TB_VMS_TRFC_INFR_DSPL_SCH B,                            \r\n"
           "       TB_VMS_FORM C                                           \r\n"
           " WHERE A.DEL_YN = 'N'                                          \r\n"
           "   AND A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR                       \r\n"
           "   AND B.VMS_FORM_ID   = C.VMS_FORM_ID                         \r\n"
           "   AND B.USE_YN        = 'Y'                                   \r\n"
           "   AND TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') BETWEEN            \r\n"
           "       B.DSPL_STRT_HH AND B.DSPL_END_HH                        \r\n";

    sQry = "SELECT * \r\n"
           "  FROM ( \r\n" + sQry +
           "       ) \r\n"
           " ORDER BY VMS_CTLR_NMBR ASC, SCHPRIT ASC, PHASE ASC \r\n";

	try
	{
		pADO = new TADOQuery(NULL);
        pADO->Connection = GetDbConnection();

		try
		{
            SQLText(pADO, sQry, false);
			SQLOpen(pADO);

            int  nIdx;
            int  TRFC_SITU_TYPE_CD;
            bool bBottomTraffic;
            TCDSIfsc *pCDSIfsc;

			for( ; !pADO->Eof; pADO->Next())
			{
                AnsiString sVmsNmbr    = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
                AnsiString VMS_FORM_ID = pADO->FieldByName("VMS_FORM_ID")->AsString;

                //스케줄 유형 코드(0:교통정보,1:돌발,2:공사/행사문안,3:홍보문안,4:우회도로,5:고정스케줄, 6:기본스케줄, 7:정체상황, 8:재난안전)
                TRFC_SITU_TYPE_CD = pADO->FieldByName("TRFC_SITU_TYPE_CD")->AsString.ToIntDef(-1);

                if (TRFC_SITU_TYPE_CD < enFormTraffic||
                    TRFC_SITU_TYPE_CD > enFormSafe)
                {
                    LERROR("VMS Schedule Unknown Type: VmsNmbr(%s)-[%s.%d]", sVmsNmbr.c_str(), VMS_FORM_ID.c_str(), TRFC_SITU_TYPE_CD);
                    continue;
                }

                TVmsCtlr *pObj = VmsManager->FLists.Find(sVmsNmbr);
                if (!pObj) continue;

                if (!pObj->FProvide) continue;

                TCDSForm *pForm = FormManager->FLists.Find(VMS_FORM_ID);
                if (!pForm)
                {
                    LERROR("VMS Schedule Not Found Form: VmsNmbr(%s)-[%s]", sVmsNmbr.c_str(), VMS_FORM_ID.c_str());
                    continue;
                }

                if (pObj->SCHEDULE->Count >= VMS_MAX_SCHEDULE)
                {
                    LERROR("VMS Schedule Count Over: %s, %d", sVmsNmbr.c_str(), pObj->SCHEDULE->Count);
                    continue;
                }

                if (pObj->CTLMODE->Control == 'F')
                {
                    //고정스케쥴인 경우 고정스케쥴정보만 등록한다.
                    if (TRFC_SITU_TYPE_CD != enFormFixed) continue;
                }
                else
                if (pObj->CTLMODE->Control == 'B')
                {
                    //기본스케쥴인 경우 기본스케쥴정보만 등록한다.
                    if (TRFC_SITU_TYPE_CD != enFormBase) continue;
                }
                else
                {
                    //자동시케쥴인 경우 고정스케쥴, 기본스케쥴 체크
                    if (TRFC_SITU_TYPE_CD == enFormFixed || TRFC_SITU_TYPE_CD == enFormBase)
                    {
                        continue; //여기 걸리면 프로그램적으로 오류가 발생한 거임
                    }
                }

                //TODO: 조회정렬은 기본,고정,자동(재난안전, 돌발,공사,행사,우회,교통,정체폼) 순으로 조회된다.
                //      따라서 각 폼에 대한처리를 수행하면 된다.
                //      20180928: 재난안전 추가되어 우선순위가 가장 높게 한다.

                if (TRFC_SITU_TYPE_CD == enFormTraffic && pForm->VMS_FORM_TYPE_CD == enFormKindTrfRow1)
                {
                    //교통정보스케쥴이고 폼의 유형이  소통정보(1단) 인경우....
                    //해당 폼이 돌발이나 이벤트가 등록되어 있다면
                    //폼을 생성하지 않는다.

                    AnsiString FRST_VMS_IFSC_ID = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;

                    if (FRST_VMS_IFSC_ID != "")
                    {
                        for (int ii = 0; ii < pObj->SCHEDULE->Count && ii < VMS_MAX_SCHEDULE; ii++)
                        {
                            if (pObj->SCHEDULE->Unit[ii].TRFC_SITU_TYPE_CD == enFormDolbal ||  //돌발
                                pObj->SCHEDULE->Unit[ii].TRFC_SITU_TYPE_CD == enFormGongsa ||  //공사/행사
                                pObj->SCHEDULE->Unit[ii].TRFC_SITU_TYPE_CD == enFormDeture )   //우회
                            {
                                if (pObj->SCHEDULE->Unit[ii].EVENT)
                                {
                                    if (FRST_VMS_IFSC_ID == pObj->SCHEDULE->Unit[ii].EVENT->VMS_IFSC_ID)
                                    {
                                        //폼을 생성하지 않는다.
                                        continue;
                                    }
                                }
                            }
                        }
                    }
                }

                bBottomTraffic = false;
                switch(TRFC_SITU_TYPE_CD)
                {
                case enFormTraffic:     //교통정보
                    //정보제공구간 하단 소통정보
                    if (pForm->VMS_FORM_TYPE_CD == enFormKindTrfImg && pForm->TrfIfsc)
                    {
                        //도형식 VMS인 경우 하단에 소통정보를 표출하는 경우 다중폼이 생성됨
                        //제공구간소통정보가 정체, 지체인 경우만 하단 소통정보를 표출함
#if 0
                        FOR_STL(TVmsIfsc*, pIfsc, pObj->FIfscLists)
                        {
                            pCDSIfsc = IfscManager->FLists.Find(pIfsc->VMS_IFSC_ID);
                            if (!pCDSIfsc) continue;

                            if (pCDSIfsc->AXIS_YN == "Y") continue;
                            if (pCDSIfsc->CMTR_GRAD_CD == "3" || pCDSIfsc->CMTR_GRAD_CD == "2")
                            {
                                bBottomTraffic = true;
                                break;
                            }
                        }
#else
                        //도형식 배경셀에 등록된 구간에 대해서 표출하도록 수정(20161124)
                        TCDSImage *pBakTrfImg = ImageManager->FLists.Find(pForm->TrfBakImgId);
                        if (pBakTrfImg)
                        {
                            FOR_STL(TCDSImageCell*, pCell, pBakTrfImg->FLists)
                            {
                                TCDSIfsc *pTmpIfsc1 = IfscManager->FLists.Find(pCell->VMS_IFSC_ID);
                                if (pTmpIfsc1)
                                {
                                    if (pTmpIfsc1->CMTR_GRAD_CD == "3" || pTmpIfsc1->CMTR_GRAD_CD == "2")
                                    {
                                        bBottomTraffic = true;
                                        break;
                                    }
                                }
                            }
                        }
#endif
                    }

                    //정보제공구간 축 하단 소통정보
                    if (pForm->VMS_FORM_TYPE_CD == enFormKindTrfImg && pForm->TrfAxis)
                    {
                        //도형식 VMS인 경우 하단에 소통정보를 표출하는 경우 다중폼이 생성됨
                        //축 소통정보인 경우 모든 축에 대해 소통정보를 표출
                        FOR_STL(TVmsIfsc*, pIfsc, pObj->FIfscLists)
                        {
                            pCDSIfsc = IfscManager->FLists.Find(pIfsc->VMS_IFSC_ID);
                            if (!pCDSIfsc) continue;

                            if (pCDSIfsc->AXIS_YN != "Y") continue;
                            if (pCDSIfsc->CMTR_GRAD_CD != "0")
                            {
                                bBottomTraffic = true;
                                break;
                            }
                        }
                    }

                    if (bBottomTraffic)
                    {
                        //도형식 다중 소통정보 표출인 경우
                        //하단소통정보를 표출하는경우 정체, 지체 순으로 표출
                        if (pForm->TrfIfsc)
                        {
                            //정보제공구간 소통정보 순환표출(정체)
#if 0
                            FOR_STL(TVmsIfsc*, pIfsc, pObj->FIfscLists)
                            {
                                pCDSIfsc = IfscManager->FLists.Find(pIfsc->VMS_IFSC_ID);
                                if (!pCDSIfsc) continue;

                                if (pCDSIfsc->AXIS_YN == "Y") continue;
                                if (pCDSIfsc->CMTR_GRAD_CD != "3") continue;

                                nIdx = pObj->SCHEDULE->Count;
                                if (nIdx < VMS_MAX_SCHEDULE)
                                {
                                    nIdx = pObj->SCHEDULE->Count;
                                    pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                                    pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                                    pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = pIfsc->VMS_IFSC_ID;  //하단 제공구간 ID
                                    pObj->SCHEDULE->Count++;
                                    nSelCnt++;
                                }
                            }
#else
                            //도형식 배경셀에 등록된 구간에 대해서 표출하도록 수정(20161124)
                            TCDSImage *pBakTrfImg1 = ImageManager->FLists.Find(pForm->TrfBakImgId);
                            if (pBakTrfImg1)
                            {
                                FOR_STL(TCDSImageCell*, pCell, pBakTrfImg1->FLists)
                                {
                                    TCDSIfsc *pTmpIfsc1 = IfscManager->FLists.Find(pCell->VMS_IFSC_ID);
                                    if (!pTmpIfsc1) continue;

                                    if (pTmpIfsc1->CMTR_GRAD_CD != "3") continue;

                                    nIdx = pObj->SCHEDULE->Count;
                                    if (nIdx < VMS_MAX_SCHEDULE)
                                    {
                                        nIdx = pObj->SCHEDULE->Count;
                                        pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                                        pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                                        pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                                        pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pCell->VMS_IFSC_ID;
                                        pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString;
                                        pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString;
                                        pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString;
                                        pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
                                        pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
                                        pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
                                        pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
                                        pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                                        pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                                        pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = pCell->VMS_IFSC_ID;  //하단 제공구간 ID
                                        pObj->SCHEDULE->Count++;
                                        nSelCnt++;
                                    }
                                }
                            }
#endif
                            //정보제공구간 소통정보 순환표출(지체)
#if 0
                            FOR_STL(TVmsIfsc*, pIfsc, pObj->FIfscLists)
                            {
                                pCDSIfsc = IfscManager->FLists.Find(pIfsc->VMS_IFSC_ID);
                                if (!pCDSIfsc) continue;

                                if (pCDSIfsc->AXIS_YN == "Y") continue;
                                if (pCDSIfsc->CMTR_GRAD_CD != "2") continue;

                                nIdx = pObj->SCHEDULE->Count;
                                if (nIdx < VMS_MAX_SCHEDULE)
                                {
                                    nIdx = pObj->SCHEDULE->Count;
                                    pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                                    pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                                    pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pIfsc->VMS_IFSC_ID;
                                    pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = "";
                                    pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = "";
                                    pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = "";
                                    pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = pIfsc->VMS_IFSC_ID;  //하단 제공구간 ID
                                    pObj->SCHEDULE->Count++;
                                    nSelCnt++;
                                }
                            }
#else
                            //도형식 배경셀에 등록된 구간에 대해서 표출하도록 수정(20161124)
                            TCDSImage *pBakTrfImg2 = ImageManager->FLists.Find(pForm->TrfBakImgId);
                            if (pBakTrfImg2)
                            {
                                FOR_STL(TCDSImageCell*, pCell, pBakTrfImg2->FLists)
                                {
                                    TCDSIfsc *pTmpIfsc1 = IfscManager->FLists.Find(pCell->VMS_IFSC_ID);
                                    if (!pTmpIfsc1) continue;

                                    if (pTmpIfsc1->CMTR_GRAD_CD != "2") continue;

                                    nIdx = pObj->SCHEDULE->Count;
                                    if (nIdx < VMS_MAX_SCHEDULE)
                                    {
                                    nIdx = pObj->SCHEDULE->Count;
                                    pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                                    pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                                    pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pCell->VMS_IFSC_ID;
                                    pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = "";
                                    pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = "";
                                    pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = "";
                                    pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = pCell->VMS_IFSC_ID;  //하단 제공구간 ID
                                    pObj->SCHEDULE->Count++;
                                    nSelCnt++;
                                    }
                                }
                            }
#endif
                        }

                        if (pForm->TrfAxis)
                        {
                            //축소통정보 순환표출
                            FOR_STL(TVmsIfsc*, pIfsc, pObj->FIfscLists)
                            {
                                pCDSIfsc = IfscManager->FLists.Find(pIfsc->VMS_IFSC_ID);
                                if (!pCDSIfsc) continue;

                                if (pCDSIfsc->AXIS_YN != "Y") continue;
                                if (pCDSIfsc->CMTR_GRAD_CD == "0") continue;

                                nIdx = pObj->SCHEDULE->Count;
                                if (nIdx < VMS_MAX_SCHEDULE)
                                {
                                    nIdx = pObj->SCHEDULE->Count;
                                    pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                                    pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                                    pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                                    pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = pIfsc->VMS_IFSC_ID;  //하단 제공구간 ID
                                    pObj->SCHEDULE->Count++;
                                    nSelCnt++;
                                }
                            }
                        }
                    }
                    else
                    {
                        //도형식 다중표출이 아닌경우(하단소통정보가 없는 경우)
                        nIdx = pObj->SCHEDULE->Count;
                        if (nIdx < VMS_MAX_SCHEDULE)
                        {
                            pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                            pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                            pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                            pObj->SCHEDULE->Count++;
                            nSelCnt++;
                        }
                    }
                    break;
                case enFormSafe:  //재난안전
                    //재난안전 스케줄인 경우 해당 VMS에 발생한 모든 재난안전 정보를 표출하도록 스케줄 추가
                    for (int ii = 0; ii < pObj->SAFE->Count && ii < VMS_MAX_SAFE; ii++)
                    {
                        if (pForm->MSG_TP == pObj->SAFE->Unit[ii].MSG_TP)   //재난안전 메시지 표출요형이 같은경우에만(2단,3단메시지)
                        {
                            nIdx = pObj->SCHEDULE->Count;
                            if (nIdx < VMS_MAX_SCHEDULE)
                            {
                                pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                                pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                                pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                                pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = "";
                                pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = "";
                                pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = "";
                                pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = "";
                                pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = "";
                                pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = "";
                                pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = "";
                                pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = "";
                                pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                                pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                                pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = "";
                                pObj->SCHEDULE->Unit[nIdx].SAFE              = &pObj->SAFE->Unit[ii];
                                pObj->SCHEDULE->Count++;
                                nSelCnt++;
                            }
                        }
                    }
                    break;
                case enFormDolbal:  //돌발
                    //돌발 스케줄인 경우 해당 VMS에 발생한 모든 돌발 정보를 표출하도록 스케줄 추가
                    for (int ii = 0; ii < pObj->INCIDENT->Count && ii < VMS_MAX_EVENT; ii++)
                    {
                        nIdx = pObj->SCHEDULE->Count;
                        if (nIdx < VMS_MAX_SCHEDULE)
                        {
                            pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                            pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                            pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = pObj->INCIDENT->Unit[ii].VMS_IFSC_ID;
                            pObj->SCHEDULE->Unit[nIdx].EVENT             = &pObj->INCIDENT->Unit[ii];
                            pObj->SCHEDULE->Count++;
                            nSelCnt++;
                        }
                    }
                    break;
                case enFormGongsa:  //공사/행사문안
                    //공사/행사 \스케줄인 경우 해당 VMS에 발생한 모든 돌발 정보를 표출하도록 스케줄 추가
                    for (int ii = 0; ii < pObj->EVENT->Count && ii < VMS_MAX_EVENT; ii++)
                    {
                        nIdx = pObj->SCHEDULE->Count;
                        if (nIdx < VMS_MAX_SCHEDULE)
                        {
                            pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                            pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                            pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = pObj->EVENT->Unit[ii].VMS_IFSC_ID;
                            pObj->SCHEDULE->Unit[nIdx].EVENT             = &pObj->EVENT->Unit[ii];
                            pObj->SCHEDULE->Count++;
                            nSelCnt++;
                        }
                    }
                    break;
                case enFormDeture:  //우회도로
                    //돌발발생한 구간중 우회도로 구간이 있는경우
                    for (int ii = 0; ii < pObj->INCIDENT->Count && ii < VMS_MAX_EVENT; ii++)
                    {
                        if (pObj->INCIDENT->Unit[ii].DETR_ID == "0") continue;

                        nIdx = pObj->SCHEDULE->Count;
                        if (nIdx < VMS_MAX_SCHEDULE)
                        {
                            pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                            pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                            pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = pObj->INCIDENT->Unit[ii].VMS_IFSC_ID;
                            pObj->SCHEDULE->Unit[nIdx].EVENT             = &pObj->INCIDENT->Unit[ii];
                            pObj->SCHEDULE->Count++;
                            nSelCnt++;
                        }
                    }

                    //공사/행사 발생한 구간중 우회도로 구간이 있는경우
                    for (int ii = 0; ii < pObj->EVENT->Count && ii < VMS_MAX_EVENT; ii++)
                    {
                        if (pObj->EVENT->Unit[ii].DETR_ID == "0") continue;

                        nIdx = pObj->SCHEDULE->Count;
                        if (nIdx < VMS_MAX_SCHEDULE)
                        {
                            pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                            pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                            pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                            pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = pObj->EVENT->Unit[ii].VMS_IFSC_ID;
                            pObj->SCHEDULE->Unit[nIdx].EVENT             = &pObj->EVENT->Unit[ii];
                            pObj->SCHEDULE->Count++;
                            nSelCnt++;
                        }
                    }
                    break;
                case enFormHongbo:  //홍보
                case enFormFixed:   //고정스케줄
                case enFormBase:    //기본스케줄
                    nIdx = pObj->SCHEDULE->Count;
                    if (nIdx < VMS_MAX_SCHEDULE)
                    {
                        pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                        pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                        pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                        pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
                        pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString;
                        pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString;
                        pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString;
                        pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
                        pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
                        pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
                        pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
                        pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                        pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                        pObj->SCHEDULE->Count++;
                        nSelCnt++;
                    }
                    break;
                case enFormCongest: //정체상황
                    //스케쥴에 등록된 제공구간의 속도가 5km/h 이하인 경우에만 표출
                    {
                        bool bDup = false;
                        AnsiString sVmsIfscId[4];
                        int nObjCnt = pObj->SCHEDULE->Count;

                        for (int ii = 0; ii < nObjCnt && ii < VMS_MAX_SCHEDULE; ii++)
                        {
                            sVmsIfscId[0] = "";
                            sVmsIfscId[1] = "";
                            sVmsIfscId[2] = "";
                            sVmsIfscId[3] = "";

                            switch(pObj->SCHEDULE->Unit[ii].TRFC_SITU_TYPE_CD)
                            {
                            case enFormDolbal: //돌발
                            case enFormGongsa: //공사/행사
                            case enFormDeture: //우회
                                sVmsIfscId[0] = pObj->SCHEDULE->Unit[ii].VMS_IFSC_ID;
                                break;
                            case enFormTraffic:
                                sVmsIfscId[0] = pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID;
                                sVmsIfscId[1] = pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID;
                                sVmsIfscId[2] = pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID;
                                sVmsIfscId[3] = pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID;
                                //도형식인 경우 체크확인 해야함
                                break;
                            case enFormHongbo:
                            case enFormFixed:
                            case enFormBase:
                            case enFormCongest:
                            default: continue;
                            }

                            for (int kk = 0; kk < 4; kk++)
                            {
                                if (sVmsIfscId[kk] == "") continue;

                                pCDSIfsc = IfscManager->FLists.Find(sVmsIfscId[kk]);
                                if (pCDSIfsc)
                                {
                                    if (pCDSIfsc->CMTR_GRAD_CD == "3" && pCDSIfsc->SPED <= 5)
                                    {
                                        bDup = false;
                                        for (int jj = nObjCnt-1; jj < pObj->SCHEDULE->Count && ii < VMS_MAX_SCHEDULE; ii++)
                                        {
                                            if (pObj->SCHEDULE->Unit[jj].TRFC_SITU_TYPE_CD != enFormCongest) continue;
                                            if (pObj->SCHEDULE->Unit[jj].VMS_IFSC_ID == sVmsIfscId[kk])
                                            {
                                                bDup = true;
                                                break;
                                            }
                                        }

                                        if (bDup) continue;

                                        nIdx = pObj->SCHEDULE->Count;
                                        if (nIdx < VMS_MAX_SCHEDULE)
                                        {
                                            pObj->SCHEDULE->Unit[nIdx].TRFC_SITU_TYPE_CD = TRFC_SITU_TYPE_CD;
                                            pObj->SCHEDULE->Unit[nIdx].PHASE             = pADO->FieldByName("PHASE")->AsInteger;
                                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID       = VMS_FORM_ID;
                                            pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID  = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
                                            pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID  = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString;
                                            pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID  = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString;
                                            pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID  = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString;
                                            pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID  = pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
                                            pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID  = pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
                                            pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID  = pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
                                            pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID  = pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
                                            pObj->SCHEDULE->Unit[nIdx].DSPL_HH           = pADO->FieldByName("DSPL_HH")->AsInteger;
                                            pObj->SCHEDULE->Unit[nIdx].VMS_FORM_PRRT_CD  = pADO->FieldByName("VMS_FORM_PRRT_CD")->AsString;
                                            pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID       = sVmsIfscId[kk];
                                            pObj->SCHEDULE->Count++;
                                            nSelCnt++;
                                        }
                                    }
                                }
                            }
                        }
                    }
                    break;
                }
			}

			nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            ErrorString = String(E.ClassName()) + E.Message;
		}
		catch(Exception &e)
		{
            ErrorString = String(e.ClassName()) + e.Message;
		}
	}
	__finally
	{
		SQLFree(pADO);
	}

    if (0)
    {
        VmsIterator it;
        for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
        {
            TVmsCtlr *pObj = (TVmsCtlr*)it->second;

            if (pObj->Server.UseFlag != bit_enable) continue;
            LDEBUG("VMS Schedule: %s, %d EA", pObj->VmsNo.c_str(), pObj->SCHEDULE->Count);
        }
    }

    LINFO("LoadVmsScheduleInfo: %d EA", nSelCnt);

	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::LoadVmsEventOccrInf(AnsiString AVmsId)
{
	int         nResult;
	AnsiString  sQry;
	int         nSelCnt = 0;
	TADOQuery  *pADO = NULL;

	nResult = VERR_OTHER;

    LINFO("LoadVmsEventOccrInf: Start");

    sQry = "SELECT V.VMS_CTLR_NMBR, V.LINK_ID, V.IFSC_ID, V.VMS_IFSC_ID,   \r\n"
           "       V.VMS_IFSC_NM, V.DSPL_STRT_NODE_NM, V.DSPL_END_NODE_NM, \r\n"
           "       V.DETR_ID, V.DSPL_PRRT, I.INCD_OCRR_ID, I.STRT_LCTN_NM, \r\n"
           "       V.ROAD_NM, V.SPOT_NM,                                   \r\n"
           "       I.END_LCTN_NM, I.OCRR_LCTN_NM,                          \r\n"
           "       (SELECT CMMN_CD_KOR_NM                                  \r\n"
           "         FROM TB_CMMN_CD                                       \r\n"
           "        WHERE CMMN_CD = I.VMS_INCD_TYPE_CD                     \r\n"
           "          AND CMMN_CLSF_CD = 'VIT') AS VMS_INCD_TYPE_NM,       \r\n"
           "       I.VMS_INCD_TYPE_CD,                                     \r\n"
           "       CASE WHEN I.VMS_INCD_TYPE_CD = 'VIT1' THEN              \r\n"
           "       (SELECT CMMN_CD_KOR_NM                                  \r\n"
           "          FROM TB_CMMN_CD                                      \r\n"
           "         WHERE CMMN_CD      = I.VMS_INCD_DETL_TYPE_CD          \r\n"
           "           AND CMMN_CLSF_CD = 'IDT')                           \r\n"
           "       ELSE                                                    \r\n"
           "       (SELECT CMMN_CD_KOR_NM                                  \r\n"
           "          FROM TB_CMMN_CD                                      \r\n"
           "         WHERE CMMN_CD      = I.VMS_INCD_DETL_TYPE_CD          \r\n"
           "           AND CMMN_CLSF_CD = 'EDT')                           \r\n"
           "       END AS VMS_INCD_DETL_NM,                                \r\n"
           "       I.VMS_INCD_DETL_TYPE_CD,                                \r\n"
           "       (SELECT CMMN_CD_KOR_NM                                  \r\n"
           "          FROM TB_CMMN_CD                                      \r\n"
           "         WHERE CMMN_CD      = I.CMTR_GRAD_CD                   \r\n"
           "           AND CMMN_CLSF_CD = 'LTC') AS CMTR_GRAD_NM,          \r\n"
           "       I.CMTR_GRAD_CD,                                         \r\n"
           "       I.INCD_CLSR_LANE,                                       \r\n"
           "       I.INCD_STRT_DT,                                         \r\n"
           "       I.INCD_END_PRAR_DT                                      \r\n"
           "  FROM (SELECT D.VMS_CTLR_NMBR, A.LINK_ID,                     \r\n"
           "               A.IFSC_ID, B.VMS_IFSC_ID,                       \r\n"
           "               C.VMS_IFSC_NM,                                  \r\n"
           "               C.DSPL_STRT_NODE_NM,                            \r\n"
           "               C.DSPL_END_NODE_NM,                             \r\n"
           "               NVL(C.DETR_ID, 0) AS DETR_ID,                   \r\n"
           "               C.ROAD_NM, C.SPOT_NM,                           \r\n"
           "               D.DSPL_PRRT                                     \r\n"
           "          FROM TB_IFSC_LINK_RLTN A,                            \r\n"
           "               TB_VMS_LINK_IFSC  B,                            \r\n"
           "               TB_VMS_IFSC       C,                            \r\n"
           "               TB_VMS_IFSC_RLTN  D                             \r\n"
           "         WHERE A.IFSC_ID     = B.IFSC_ID                       \r\n"
           "           AND B.VMS_IFSC_ID = C.VMS_IFSC_ID                   \r\n"
           "           AND C.VMS_IFSC_ID = D.VMS_IFSC_ID ) V,              \r\n"
           "       (SELECT *                                               \r\n"
           "          FROM TB_INCD_OCRR_VMS                                \r\n"
           "         WHERE INCD_PRGR_STEP_CD = 'ISS2'                      \r\n"
           "           AND VMS_DSPL_YN       = 'Y'                         \r\n"
           "           AND VMS_INCD_TYPE_CD IN ('VIT1', 'VIT2') ) I        \r\n"
           " WHERE V.LINK_ID = I.LINK_ID                                   \r\n"
           " ORDER BY V.VMS_CTLR_NMBR                                      \r\n";

	try
	{
		pADO = new TADOQuery(NULL);
        pADO->Connection = GetDbConnection();

		try
		{
            SQLText(pADO, sQry, false);
			SQLOpen(pADO);

            int nIdx;
			for( ; !pADO->Eof; pADO->Next())
			{
                AnsiString sVmsNmbr = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;

                TVmsCtlr *pObj = VmsManager->FLists.Find(sVmsNmbr);
                if (!pObj) continue;

                if (!pObj->FProvide) continue;

                AnsiString VMS_INCD_TYPE_CD = pADO->FieldByName("VMS_INCD_TYPE_CD")->AsString;
                AnsiString INCD_OCRR_ID     = pADO->FieldByName("INCD_OCRR_ID")->AsString;

                VMS_EVENT_INFO *pEvt;
                if (VMS_INCD_TYPE_CD ==  "VIT1")
                {
                    if (pObj->INCIDENT->Count >= VMS_MAX_EVENT)
                    {
                        LERROR("VMS Incident Over: %s, %d", pObj->VmsNo.c_str(), pObj->INCIDENT->Count);
                        continue;
                    }
                    bool bDup = false;
                    for (int ii = 0; ii < pObj->INCIDENT->Count; ii++)
                    {
                        if (INCD_OCRR_ID == pObj->INCIDENT->Unit[ii].INCD_OCRR_ID)
                        {
                            bDup = true;
                            break;
                        }
                    }
                    if (bDup)
                    {
                        LERROR("VMS Incident dup: %s, %s", pObj->VmsNo.c_str(), INCD_OCRR_ID.c_str());
                        continue;
                    }
                    nIdx = pObj->INCIDENT->Count;
                    pEvt = pObj->INCIDENT;
                }
                else
                {
                    if (pObj->EVENT->Count >= VMS_MAX_EVENT)
                    {
                        LERROR("VMS Event Over: %s, %d", pObj->VmsNo.c_str(), pObj->EVENT->Count);
                        continue;
                    }
                    bool bDup = false;
                    for (int ii = 0; ii < pObj->EVENT->Count; ii++)
                    {
                        if (INCD_OCRR_ID == pObj->EVENT->Unit[ii].INCD_OCRR_ID)
                        {
                            bDup = true;
                            break;
                        }
                    }
                    if (bDup)
                    {
                        LERROR("VMS Event dup: %s, %s", pObj->VmsNo.c_str(), INCD_OCRR_ID.c_str());
                        continue;
                    }
                    nIdx = pObj->EVENT->Count;
                    pEvt = pObj->EVENT;
                }

                pEvt->Unit[nIdx].LINK_ID                = pADO->FieldByName("LINK_ID")->AsString;
                pEvt->Unit[nIdx].IFSC_ID                = pADO->FieldByName("IFSC_ID")->AsString;
                pEvt->Unit[nIdx].VMS_IFSC_ID            = pADO->FieldByName("VMS_IFSC_ID")->AsString;
                pEvt->Unit[nIdx].VMS_IFSC_NM            = pADO->FieldByName("VMS_IFSC_NM")->AsString;
                pEvt->Unit[nIdx].DSPL_STRT_NODE_NM      = pADO->FieldByName("DSPL_STRT_NODE_NM")->AsString;
                pEvt->Unit[nIdx].DSPL_END_NODE_NM       = pADO->FieldByName("DSPL_END_NODE_NM")->AsString;
                pEvt->Unit[nIdx].DETR_ID                = pADO->FieldByName("DETR_ID")->AsString.Trim();
                pEvt->Unit[nIdx].DSPL_PRRT              = pADO->FieldByName("DSPL_PRRT")->AsString;
                pEvt->Unit[nIdx].INCD_OCRR_ID           = INCD_OCRR_ID;
                pEvt->Unit[nIdx].STRT_LCTN_NM           = pADO->FieldByName("STRT_LCTN_NM")->AsString;
                pEvt->Unit[nIdx].END_LCTN_NM            = pADO->FieldByName("END_LCTN_NM")->AsString;

                if (pEvt->Unit[nIdx].STRT_LCTN_NM == "")
                {
                    pEvt->Unit[nIdx].STRT_LCTN_NM = pEvt->Unit[nIdx].DSPL_STRT_NODE_NM;
                }
                if (pEvt->Unit[nIdx].END_LCTN_NM == "")
                {
                    pEvt->Unit[nIdx].END_LCTN_NM = pEvt->Unit[nIdx].DSPL_END_NODE_NM;
                }

                pEvt->Unit[nIdx].OCRR_LCTN_NM           = pADO->FieldByName("OCRR_LCTN_NM")->AsString;
                pEvt->Unit[nIdx].VMS_INCD_TYPE_NM       = pADO->FieldByName("VMS_INCD_TYPE_NM")->AsString;
                pEvt->Unit[nIdx].VMS_INCD_TYPE_CD       = pADO->FieldByName("VMS_INCD_TYPE_CD")->AsString;
                pEvt->Unit[nIdx].VMS_INCD_DETL_NM       = pADO->FieldByName("VMS_INCD_DETL_NM")->AsString;
                pEvt->Unit[nIdx].VMS_INCD_DETL_TYPE_CD  = pADO->FieldByName("VMS_INCD_DETL_TYPE_CD")->AsString;
                pEvt->Unit[nIdx].CMTR_GRAD_NM           = pADO->FieldByName("CMTR_GRAD_NM")->AsString;
                pEvt->Unit[nIdx].CMTR_GRAD_CD           = pADO->FieldByName("CMTR_GRAD_CD")->AsString;
                pEvt->Unit[nIdx].INCD_CLSR_LANE         = pADO->FieldByName("INCD_CLSR_LANE")->AsString;
                pEvt->Unit[nIdx].INCD_STRT_DT           = pADO->FieldByName("INCD_STRT_DT")->AsString;
                pEvt->Unit[nIdx].INCD_END_PRAR_DT       = pADO->FieldByName("INCD_END_PRAR_DT")->AsString;
                pEvt->Unit[nIdx].ROAD_NM                = pADO->FieldByName("ROAD_NM")->AsString;
                pEvt->Unit[nIdx].SPOT_NM                = pADO->FieldByName("SPOT_NM")->AsString;

                pEvt->Count++;

                nSelCnt++;
			}

			nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            ErrorString = String(E.ClassName()) + E.Message;
		}
		catch(Exception &e)
		{
            ErrorString = String(e.ClassName()) + e.Message;
		}
	}
	__finally
	{
		SQLFree(pADO);
	}

    if (0)
    {
        VmsIterator it;
        for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
        {
            TVmsCtlr *pObj = (TVmsCtlr*)it->second;

            if (pObj->Server.UseFlag != bit_enable) continue;
            LDEBUG("VMS Event(I/E): %s, %d/%d EA", pObj->VmsNo.c_str(), pObj->INCIDENT->Count, pObj->EVENT->Count);
        }
    }

    LINFO("LoadVmsEventOccrInf: %d EA", nSelCnt);

	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::LoadVmsSafeOccrInf(AnsiString AVmsId)
{
	int         nResult;
	AnsiString  sQry;
	int         nSelCnt = 0;
	TADOQuery  *pADO = NULL;

	nResult = VERR_OTHER;

    LINFO(" LoadVmsSafeOccrInf: Start");

    sQry = "SELECT X.VMS_CTLR_NMBR,                                                                     \r\n"
           "       Y.SAFE_ALM_ID, Y.MSG_TP, Y.RGST_DT, Y.ALM_STRT_DT, Y.ALM_END_DT,                     \r\n"
           "       Y.MSG_LN_1, Y.MSG_LN_2, Y.MSG_LN_3                                                   \r\n"
           "  FROM (SELECT A.VMS_CTLR_NMBR                                                              \r\n"
           "          FROM TB_VMS_CTLR A                                                                \r\n"
           "         WHERE A.DEL_YN = 'N'                                                               \r\n"
           "       ) X,                                                                                 \r\n"
           "       (SELECT B.SAFE_ALM_ID, B.MSG_TP, B.RGST_DT, B.ALM_STRT_DT, B.ALM_END_DT,             \r\n"
           "               B.MSG_LN_1, B.MSG_LN_2, B.MSG_LN_3                                           \r\n"
           "          FROM TB_VMS_SAFE_ALM B                                                            \r\n"
           "         WHERE TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') BETWEEN B.ALM_STRT_DT AND B.ALM_END_DT  \r\n"
           "        ) Y                                                                                 \r\n"
           " ORDER BY X.VMS_CTLR_NMBR, Y.SAFE_ALM_ID, Y.MSG_TP                                          \r\n";

	try
	{
		pADO = new TADOQuery(NULL);
        pADO->Connection = GetDbConnection();

		try
		{
            SQLText(pADO, sQry, false);
			SQLOpen(pADO);

			for( ; !pADO->Eof; pADO->Next())
			{
                AnsiString sVmsNmbr = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;

                TVmsCtlr *pObj = VmsManager->FLists.Find(sVmsNmbr);
                if (!pObj) continue;

                if (!pObj->FProvide) continue;

                if (pObj->SAFE->Count >= VMS_MAX_SAFE)
                {
                    LERROR("VMS Safe Over: %s, %d", pObj->VmsNo.c_str(), pObj->SAFE->Count);
                    continue;
                }

                VMS_SAFE_DETL* pEvt = &pObj->SAFE->Unit[pObj->SAFE->Count];

                pEvt->SAFE_ALM_ID = pADO->FieldByName("SAFE_ALM_ID")->AsString.Trim();  //재난안전 알람 ID(YYYYMMDDNNNNN)
                pEvt->MSG_TP      = pADO->FieldByName("MSG_TP")->AsInteger;             //표출메시지종류(2:2단메시지,3:3단메시지)
                pEvt->RGST_DT     = pADO->FieldByName("RGST_DT")->AsString.Trim();      //등록 일시(YYYYMMDDHH24MISS)
                pEvt->ALM_STRT_DT = pADO->FieldByName("ALM_STRT_DT")->AsString.Trim();  //방송시작시각(YYYYMMDDHH24MISS)
                pEvt->ALM_END_DT  = pADO->FieldByName("ALM_END_DT")->AsString.Trim();   //방송종료시각(YYYYMMDDHH24MISS)
                pEvt->MSG_LN_1    = pADO->FieldByName("MSG_LN_1")->AsString;            //재난안전문자 1열
                pEvt->MSG_LN_2    = pADO->FieldByName("MSG_LN_2")->AsString;            //재난안전문자 2열
                pEvt->MSG_LN_3    = pADO->FieldByName("MSG_LN_3")->AsString;            //재난안전문자 3열

                pObj->SAFE->Count++;

                nSelCnt++;
			}

			nResult = VERR_NONE;

            if (nSelCnt > 0)
            {
                sQry = "UPDATE TB_VMS_SAFE_ALM                                                          \r\n"
                       "   SET ALM_CNFM = 'Y'                                                           \r\n"
                       " WHERE ALM_CNFM = 'N'                                                           \r\n"
                       "   AND TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') BETWEEN ALM_STRT_DT AND ALM_END_DT  \r\n";
                pADO->SQL->Clear();
                pADO->SQL->Text = sQry;
                SQLExec(pADO);
            }
		}
		catch(EDatabaseError &E)
		{
            ErrorString = String(E.ClassName()) + E.Message;
		}
		catch(Exception &e)
		{
            ErrorString = String(e.ClassName()) + e.Message;
		}
	}
	__finally
	{
		SQLFree(pADO);
	}

    LINFO(" LoadVmsSafeOccrInf: %d EA", nSelCnt);

	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::MakeVmsScenarioForm(AnsiString AVmsId)
{
	int nResult = VERR_NONE;

    LINFO("MakeVmsScenarioForm: Start");

	ClearVmsProvideMode(AVmsId);

    if (LOAD_DB)
    {
        GetVmsImage();
        LoadVmsForm();
        GetVmsIfscInfo();
    }

#ifdef VMS_SAFE
    //재난재해가 발생한 정보를 VMS에 맵핑한다.
    nResult = LoadVmsSafeOccrInf(AVmsId);
    if (nResult != VERR_NONE)
    {
        LERROR("LoadVmsSafeOccrInf: error: %d", nResult);
    }
#endif

    //돌발/공사/행사가 발생한 정보를 VMS에 맵핑한다.
    nResult = LoadVmsEventOccrInf(AVmsId);
    if (nResult != VERR_NONE)
    {
        LERROR("LoadVmsEventOccrInf: error: %d", nResult);
    }

    // VMS구간 소통정보를 모두 읽어오자..(데이터가 많을 경우 해당되는 정보만 읽어오도록 수정
    nResult = LoadIfscTrafficInfo();
    if (nResult != VERR_NONE)
    {
        LERROR("LoadIfscTrafficInfo: error: %d", nResult);
    }

    //VMS의 스케줄정보를 조회한다.
    nResult = LoadVmsScheduleInfo(AVmsId);
    if (nResult != VERR_NONE)
    {
        LERROR("LoadVmsScheduleInfo: error: %d", nResult);
    }

    LINFO("MakeVmsScenarioForm: End");
    return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::SaveVmsDownloadForm()
{
	int nResult = VERR_NONE;
    int nSaveVmsCnt, nSaveFormCnt;

    LINFO("SaveVmsDownloadForm: Start");

    nSaveVmsCnt = 0;
    nSaveFormCnt= 0;

    //생성한 폼을 데이터베이스에 저장한다.
    VmsIterator it;
    for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
    {
        TVmsCtlr *pObj = (TVmsCtlr*)it->second;

        if (pObj->Server.UseFlag != bit_enable) continue;
        if (!pObj->FProvide) continue;

        nSaveFormCnt += SaveVmsDatabaseForm(pObj);
        nSaveVmsCnt++;
    }

    //생성한 폼을 제어기에 전송할 수 있도록 플래그를 설정한다.
    for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
    {
        TVmsCtlr *pObj = (TVmsCtlr*)it->second;

        if (pObj->Server.UseFlag != bit_enable) continue;
        if (!pObj->FProvide) continue;

        if (pObj->pForms->Count() > 0)
        {
            pObj->CTLMODE->Enable   = object_enable;
            pObj->CTLMODE->SaveFlag = false;
            pObj->CTLMODE->Result   = false;
        }
    }

    INT_VMS_FORM_SAVE_REQ Req;
    memset((char*)&Req, 0x00, sizeof(Req));
    memcpy(Req.Date, FFormDsplDt.c_str(), INT_VMS_MAX_DATETIME);
    //if (g_AppCfg.bSendCenterComm) {
        VComm_VmsFormSaveNotify(&Req);
    //}

    LINFO("SaveVmsDownloadForm: End. (VMS: %d EA, Forms %d EA)", nSaveVmsCnt, nSaveFormCnt);
    LINFO("*** VMS Msg create end.");
	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::SetVmsMode()
{
	int         nResult;
	int         nSelCnt = 0;

	nResult = VERR_OTHER;

    LINFO("SetVmsMode: Start");

    try
    {
        VmsIterator it;
        for(it=VmsManager->FLists.FMapObject.begin(); it != VmsManager->FLists.FMapObject.end(); ++it)
        {
            TVmsCtlr *pObj = (TVmsCtlr*)it->second;

            if (pObj->Server.UseFlag != bit_enable) continue;

            if (!pObj->FProvide) continue;

            if (!pObj->FModeChange) continue;   //모드가 변경이 안되어 있으면 업데이트할 필요 없음

            AnsiString VMS_CTLR_NMBR = pObj->VmsNo;
            AnsiString OPER_MODE     = "A";

            if (pObj->CTLMODE->Control == 'F')
                OPER_MODE = "F";
            else
            if (pObj->CTLMODE->Control == 'B')
                OPER_MODE = "B";

            pObj->RSTATE.OprMode = pObj->CTLMODE->Control;

            nSelCnt++;
        }

        nResult = VERR_NONE;
    }
    catch(Exception &e)
    {
        ErrorString = String(e.ClassName()) + e.Message;
    }

    LINFO("SetVmsMode: %d", nSelCnt);

	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::LoadVmsOperatorMode()
{
	int         nResult;
	AnsiString  sQry;
	int         nSelCnt = 0;
	TADOQuery  *pADO = NULL;

	nResult = VERR_OTHER;

    LINFO("LoadVmsOperatorMode: Start");

    sQry = "SELECT A.VMS_CTLR_NMBR, A.OPER_MODE,                    \r\n"
           "       NVL(A.VMS_MAX_PHSE_NUM, 16) AS VMS_MAX_PHSE_NUM  \r\n"
           "  FROM TB_VMS_CTLR A                                    \r\n"
           " WHERE A.DEL_YN = 'N'                                   \r\n";

	try
	{
		pADO = new TADOQuery(NULL);
        pADO->Connection = GetDbConnection();

		try
		{
            SQLText(pADO, sQry, false);
			SQLOpen(pADO);

			for( ; !pADO->Eof; pADO->Next())
			{
                AnsiString sVmsNmbr = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;

                TVmsCtlr *pObj = VmsManager->FLists.Find(sVmsNmbr);
                if (!pObj) continue;

                pObj->OPER_MODE = pADO->FieldByName("OPER_MODE")->AsString;
                int nMaxFormCnt = pADO->FieldByName("VMS_MAX_PHSE_NUM")->AsInteger;

                if (pObj->OPER_MODE == "A")
                    pObj->DSTATE.OprMode = 'A';
                else
                if (pObj->OPER_MODE == "B")
                    pObj->DSTATE.OprMode = 'B';
                else
                    pObj->DSTATE.OprMode = 'F';

                if (pObj->CTLMODE->Control == pObj->DSTATE.OprMode)
                    pObj->FModeChange = false;
                else
                    pObj->FModeChange = true;

                pObj->CTLMODE->Control = pObj->DSTATE.OprMode;
                pObj->RSTATE.OprMode   = pObj->CTLMODE->Control;

                pObj->VMS_MAX_PHSE_NUM = nMaxFormCnt;
                if (pObj->VMS_MAX_PHSE_NUM > INT_MAX_VMS_FORM)
                    pObj->VMS_MAX_PHSE_NUM = INT_MAX_VMS_FORM;

                pObj->CTLMODE->MaxDisplayForm = pObj->VMS_MAX_PHSE_NUM;
#if 0
                if (pObj->CTLMODE->MaxDisplayForm > INT_MAX_VMS_FORM)
                    pObj->CTLMODE->MaxDisplayForm = INT_MAX_VMS_FORM;
#endif

                nSelCnt++;
			}

			nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            ErrorString = String(E.ClassName()) + E.Message;
		}
		catch(Exception &e)
		{
            ErrorString = String(e.ClassName()) + e.Message;
		}
	}
	__finally
	{
		SQLFree(pADO);
	}

    LINFO("LoadVmsOperatorMode: %d EA", nSelCnt);

	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::ProvideProc(void *AData)
{
	int             nResult;
	PROVIDE_STRUCT *pPro;

    LINFO("********ProvideProc: Start");

	nResult = VERR_NONE;

	pPro = (PROVIDE_STRUCT*)AData;
    if (!pPro)
    {
        return VERR_OTHER;
    }

    try
    {
        switch(pPro->Type)
        {
        case provide_event: //자동스케줄타임에 의한 메시지 생성
            {
                LINFO("--From Provider Event");

                if ((nResult = LoadVmsOperatorMode()) != VERR_NONE)
                {
                    break;
                }

                //모든 VMS에 메시지다운로드 플래그 활성화 시킴
                VmsManager->InitProvide(true);

                if ((nResult = MakeVmsScenarioForm(ALL_VMS_ID)) != VERR_NONE)
                {
                }
            }
            break;
        case provide_mode:  //개별 VMS 제어(모드변경)
            {
                LINFO("-From Oper Mode change");

                AnsiString sVmsNmbr;

                //모든 VMS에 메시지다운로드 플래그 비활성화 시킴
                VmsManager->InitProvide(false);

                for(int ii = 0; ii < pPro->Count && ii < INT_MAX_VMS_MODE; ii++)
                {
                    sVmsNmbr.sprintf("%.*s", INT_VMS_MAX_ID, pPro->Unit[ii].VmsId);

                    TVmsCtlr *pObj = VmsManager->FLists.Find(sVmsNmbr);
                    if (!pObj) continue;
                    if (pObj->Server.UseFlag != bit_enable) continue;

                    if (pObj->CTLMODE->Control == pPro->Unit[ii].Mode)
                        pObj->FModeChange = false;
                    else
                        pObj->FModeChange = true;

                    pObj->CTLMODE->Control = pPro->Unit[ii].Mode;
                    pObj->DSTATE.OprMode = pObj->CTLMODE->Control;
                    pObj->RSTATE.OprMode = pObj->CTLMODE->Control;
                    if      (pObj->CTLMODE->Control == 'A') pObj->OPER_MODE = "A";
                    else if (pObj->CTLMODE->Control == 'B') pObj->OPER_MODE = "B";
                    else                                    pObj->OPER_MODE = "F";
                    pObj->FProvide = true;
                }

                if ((nResult = MakeVmsScenarioForm(ALL_VMS_ID)) != VERR_NONE)
                {
                }
            }
            break;
        }
    }
    __finally
    {
        delete[] (char *)AData;
    }

    LINFO("********ProvideProc: End");

	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::SaveVmsDownLoad(TVmsCtlr *AObj)
{
	int         nResult;
	AnsiString  sQry;
	TADOQuery  *pADO = NULL;

	nResult = VERR_OTHER;

    LINFO("SaveVmsDownLoad: Start");

    if (!AObj) return VERR_MEMORY_ALLOC;

    sQry = "UPDATE TB_VMS_DOWNLOAD        \r\n"
           "   SET SENDENDDATE   = :p05,  \r\n"
           "       SENDSTEP	     = :p06,  \r\n"
           "       SENDRESULT    = :p07   \r\n"
           " WHERE RGST_DT       = :p01   \r\n"
           "   AND VMS_CTLR_NMBR = :p02   \r\n"
           "   AND FILETYPE      = :p03   \r\n"
           "   AND FILEID        = :p04   \r\n";
	try
	{
        pADO = new TADOQuery(NULL);
        pADO->Connection = GetDbConnection();

		try
		{
            pADO->Connection->BeginTrans();

            SQLText(pADO, sQry, false);

            for (int ii = 0; ii < AObj->DOWNLOAD->Count && ii < VMS_MAX_DOWNLOAD; ii++)
            {
                SQLBind(pADO, "p01", AObj->DOWNLOAD->Unit[ii].RegDate);
                SQLBind(pADO, "p02", AObj->VmsNo);
                SQLBind(pADO, "p03", AObj->DOWNLOAD->Unit[ii].FileType);
                SQLBind(pADO, "p04", AObj->DOWNLOAD->Unit[ii].FileId);
                SQLBind(pADO, "p05", AObj->DOWNLOAD->Unit[ii].SendEndDate);
                SQLBind(pADO, "p06", AObj->DOWNLOAD->Unit[ii].SendStep);
                SQLBind(pADO, "p07", AObj->DOWNLOAD->Unit[ii].SendResult);

                SQLExec(pADO);
            }
            pADO->Connection->CommitTrans();
            nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            pADO->Connection->RollbackTrans();
            ErrorString = String(E.ClassName()) + E.Message;
            DBERRORLOG("SaveVmsDownLoad", String(E.ClassName()), E.Message, sQry);
            nResult = VERR_OTHER;
		}
		catch(Exception &e)
		{
            pADO->Connection->RollbackTrans();
            ErrorString = String(e.ClassName()) + e.Message;
            DBERRORLOG("SaveVmsDownLoad", String(e.ClassName()), e.Message, sQry);
		}
	}
	__finally
	{
        if (pADO)
        {
            SQLClose(pADO);
            SAFE_DELETE(pADO);
        }
	}
    LDEBUG("SaveVmsDownLoad: End, %s", AObj->VmsNo.c_str());
    return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::UpdateVmsProvideResult(TVmsCtlr *AObj)
{
	int         nResult;
	AnsiString  sQry;
	TADOQuery  *pSADO = NULL;
    int         nFormCnt = 0;

	nResult = VERR_OTHER;

    LDEBUG("UpdateVmsProvideResult: Start");

    if (!AObj) return VERR_MEMORY_ALLOC;

//LINFO("UpdateVmsProvideResult[U]: %s", AObj->VmsId.c_str());

    sQry = "UPDATE TB_VMS_DSPL_PRST      \r\n"
           "   SET DSPL_DT       = :p03, \r\n"
           "       DNLD_YN       = :p04  \r\n"
           " WHERE VMS_CTLR_NMBR = :p01  \r\n"
           "   AND PHASE        <= :p02  \r\n";

    String VMS_CTLR_NMBR;
    String PHASE;
    String DSPL_DT;
    String DNLD_YN;

	try
	{
        nFormCnt = AObj->pForms->Count();

        if (nFormCnt == 0) return VERR_NONE;

        pSADO = new TADOQuery(NULL);
        pSADO->Connection = GetDbConnection();

        VMS_CTLR_NMBR = AObj->VmsNo;
        PHASE         = String(nFormCnt);
        DSPL_DT       = AObj->CTLMODE->SvcDate;
        DNLD_YN       = AObj->CTLMODE->Result ? "Y" : "N";

		try
		{
            pSADO->Connection->BeginTrans();

            SQLText(pSADO, sQry, false);

            SQLBind(pSADO, "p01", VMS_CTLR_NMBR);
            SQLBind(pSADO, "p02", PHASE);
            SQLBind(pSADO, "p03", DSPL_DT);
            SQLBind(pSADO, "p04", DNLD_YN);
            SQLExec(pSADO);

            pSADO->Connection->CommitTrans();

            nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            pSADO->Connection->RollbackTrans();
            ErrorString = String(E.ClassName()) + E.Message;
            //DBERRORLOG("UpdateVmsProvideResult", String(E.ClassName()), E.Message, sQry);
            nResult = VERR_OTHER;
		}
		catch(Exception &e)
		{
            pSADO->Connection->RollbackTrans();
            ErrorString = String(e.ClassName()) + e.Message;
            //DBERRORLOG("UpdateVmsProvideResult", String(e.ClassName()), e.Message, sQry);
		}

        //TODO: 20181230
        //다운로드결과가 늦게 오는경우가 있어 이력저장할때 오류가 발생할수 있다.
        if (AObj->DSPL_DT == DSPL_DT && AObj->DNLD_YN == DNLD_YN)
        {
            LINFO("Duplicate Provide Result: %s, %s,%s", AObj->VmsNo.c_str(), DSPL_DT.c_str(), DNLD_YN.c_str());
            return VERR_NONE;
        }

        bool bUpdate = false;
        if (AObj->DSPL_DT == DSPL_DT && AObj->DNLD_YN != DNLD_YN)
        {
            bUpdate = true;
    sQry = "UPDATE TB_VMS_DSPL_HS        \r\n"
           "   SET DNLD_YN       = :p04  \r\n"
           " WHERE VMS_CTLR_NMBR = :p01  \r\n"
           "   AND PHASE        <= :p02  \r\n"
           "   AND DSPL_DT       = :p03  \r\n";
        }
        else
        {
        //TODO: 이력 테이블의 VMS_DSPL_MSG_TXT 컬럼은 사이즈를 키우지 않았음.(20220704)
    sQry = "INSERT INTO TB_VMS_DSPL_HS                           \r\n"
           "           (VMS_CTLR_NMBR, DSPL_PHASE_NUM, DSPL_DT,  \r\n"
           "            VMS_DSPL_MSG_DATA, VMS_DSPL_MSG_TXT,     \r\n"
           "            TRFC_SITU_TYPE_CD, VMS_MSG_DSPL_DRCT_CD, \r\n"
           "            VMS_MSG_DSPL_MTHD_CD, DSPL_HH,           \r\n"
           "            VMS_FORM_ID, DNLD_YN)                    \r\n"
           "SELECT VMS_CTLR_NMBR, PHASE, DSPL_DT,                \r\n"
           "       VMS_DSPL_MSG_DATA,                            \r\n"
           "       SUBSTR(VMS_DSPL_MSG_TXT, 1, 200),             \r\n"
           "       TRFC_SITU_TYPE_CD, VMS_MSG_DSPL_DRCT_CD,      \r\n"
           "       VMS_MSG_DSPL_MTHD_CD, DSPL_HH,                \r\n"
           "       VMS_FORM_ID, DNLD_YN                          \r\n"
           "  FROM TB_VMS_DSPL_PRST                              \r\n"
           " WHERE VMS_CTLR_NMBR = :p01                          \r\n"
           "   AND PHASE        <= :p02                          \r\n";
        }

        AObj->DSPL_DT = DSPL_DT;
        AObj->DNLD_YN = DNLD_YN;

		try
		{
            pSADO->Connection->BeginTrans();

            SQLText(pSADO, sQry, false);

            SQLBind(pSADO, "p01", VMS_CTLR_NMBR);
            SQLBind(pSADO, "p02", PHASE);
            if (bUpdate)
            {
                SQLBind(pSADO, "p03", DSPL_DT);
                SQLBind(pSADO, "p04", DNLD_YN);
            }
            SQLExec(pSADO);

            pSADO->Connection->CommitTrans();

            nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            pSADO->Connection->RollbackTrans();
            ErrorString = String(E.ClassName()) + E.Message;
            //DBERRORLOG("UpdateVmsProvideResult-Hist", String(E.ClassName()), E.Message, sQry);
            nResult = VERR_OTHER;
		}
		catch(Exception &e)
		{
            pSADO->Connection->RollbackTrans();
            ErrorString = String(e.ClassName()) + e.Message;
            //DBERRORLOG("UpdateVmsProvideResult-Hist", String(e.ClassName()), e.Message, sQry);
		}
	}
	__finally
	{
        if (pSADO)
        {
            SQLClose(pSADO);
            SAFE_DELETE(pSADO);
        }
	}
LDEBUG("UpdateVmsProvideResult: End, %s, %d EA [%s]", AObj->VmsNo.c_str(), nFormCnt, AnsiString(DNLD_YN).c_str());
    return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::SaveVmsDatabaseForm(TVmsCtlr *AObj)
{
	int         nResult;
	AnsiString  sQry;
	AnsiString  uQry;
	TADOQuery  *pSADO = NULL;
	TADOQuery  *pUADO = NULL;
    int         nSelCnt = 0;


	nResult = VERR_OTHER;

//LINFO("[%s]SaveVmsDatabaseForm: Start", AObj->VmsNo.c_str());

    if (!AObj) return VERR_MEMORY_ALLOC;

//LINFO("SaveVmsDatabaseForm[M]: %s", AObj->VmsId.c_str());
    int nFormCnt = AObj->pForms->Count();
    if (nFormCnt == 0) return VERR_NONE;

    sQry = "MERGE INTO TB_VMS_DSPL_PRST L                                  \r\n"
           "USING (SELECT :p01 AS VMS_CTLR_NMBR,                           \r\n"
           "              :p02 AS PHASE,                                   \r\n"
           "              :p03 AS DSPL_DT,                                 \r\n"
           "              :p04 AS VMS_DSPL_MSG_DATA,                       \r\n"
           "              :p05 AS VMS_DSPL_MSG_TXT,                        \r\n"
           "              :p06 AS TRFC_SITU_TYPE_CD,                       \r\n"
           "              :p07 AS VMS_MSG_DSPL_DRCT_CD,                    \r\n"
           "              :p08 AS VMS_MSG_DSPL_MTHD_CD,                    \r\n"
           "              :p09 AS DSPL_HH,                                 \r\n"
           "              :p10 AS VMS_FORM_ID,                             \r\n"
           "              :p11 AS DNLD_YN                                  \r\n"
           "         FROM DUAL) M                                          \r\n"
           " ON (L.VMS_CTLR_NMBR = M.VMS_CTLR_NMBR AND L.PHASE = M.PHASE)  \r\n"
           "WHEN MATCHED THEN                                              \r\n"
           "UPDATE SET L.DSPL_DT              = M.DSPL_DT,                 \r\n"
           "           L.VMS_DSPL_MSG_DATA    = M.VMS_DSPL_MSG_DATA,       \r\n"
           "           L.VMS_DSPL_MSG_TXT     = M.VMS_DSPL_MSG_TXT,        \r\n"
           "           L.TRFC_SITU_TYPE_CD    = M.TRFC_SITU_TYPE_CD,       \r\n"
           "           L.VMS_MSG_DSPL_DRCT_CD = M.VMS_MSG_DSPL_DRCT_CD,    \r\n"
           "           L.VMS_MSG_DSPL_MTHD_CD = M.VMS_MSG_DSPL_MTHD_CD,    \r\n"
           "           L.DSPL_HH              = M.DSPL_HH,                 \r\n"
           "           L.VMS_FORM_ID          = M.VMS_FORM_ID,             \r\n"
           "           L.DNLD_YN              = M.DNLD_YN                  \r\n"
           "WHEN NOT MATCHED THEN                                          \r\n"
           "INSERT (VMS_CTLR_NMBR, PHASE, DSPL_DT,                         \r\n"
           "        VMS_DSPL_MSG_DATA, VMS_DSPL_MSG_TXT,                   \r\n"
           "        TRFC_SITU_TYPE_CD, VMS_MSG_DSPL_DRCT_CD,               \r\n"
           "        VMS_MSG_DSPL_MTHD_CD, DSPL_HH,                         \r\n"
           "        VMS_FORM_ID, DNLD_YN)                                  \r\n"
           "VALUES (M.VMS_CTLR_NMBR, M.PHASE, M.DSPL_DT,                   \r\n"
           "        M.VMS_DSPL_MSG_DATA, M.VMS_DSPL_MSG_TXT,               \r\n"
           "        M.TRFC_SITU_TYPE_CD, M.VMS_MSG_DSPL_DRCT_CD,           \r\n"
           "        M.VMS_MSG_DSPL_MTHD_CD, M.DSPL_HH,                     \r\n"
           "        M.VMS_FORM_ID, M.DNLD_YN)                              \r\n";

    uQry = "UPDATE TB_VMS_DSPL_PRST         \r\n"
           "   SET VMS_DSPL_MSG_IMAG = :p03 \r\n"
           " WHERE VMS_CTLR_NMBR = :p01     \r\n"
           "   AND PHASE         = :p02     \r\n";


	try
	{
        pSADO = new TADOQuery(NULL);
        pSADO->Connection = GetDbConnection();
        pUADO = new TADOQuery(NULL);
        pUADO->Connection = GetDbConnection();

		try
		{
            AObj->pForms->Lock();

            pSADO->Connection->BeginTrans();

            SQLText(pSADO, sQry, false);
            SQLText(pUADO, uQry, false);
//            SQLText(pIADO, iQry, false);

    //LDEBUG("SaveVmsProvide: %s, Forms: %d EA", AObj->VmsNo.c_str(), nFormCnt);
            for (int ii = 0; ii < nFormCnt; ii++)
            {
				TVmsForm *pForm = AObj->pForms->GetItem(ii);

    //LDEBUG("SaveVmsProvide: %s, %d", AObj->VmsNo.c_str(), ii+1);
                String VMS_CTLR_NMBR        = AObj->VmsNo;
                String PHASE                = String(ii+1);
                String DSPL_DT              = AObj->CTLMODE->SvcDate;
                String VMS_DSPL_MSG_DATA    = "";
                String VMS_DSPL_MSG_TXT     = "";
                String TRFC_SITU_TYPE_CD    = String(pForm->FormKind);
                String VMS_MSG_DSPL_DRCT_CD = pForm->DisplayDir;
                String VMS_MSG_DSPL_MTHD_CD = pForm->DisplayMode;
                String DSPL_HH              = String(pForm->DisplayTime);
                String VMS_FORM_ID          = pForm->FormId;
                String DNLD_YN              = pForm->SvcRes ? "Y" : "N";

                AnsiString sTmp  = "";
                AnsiString sCont = "";

                int nObjCnt, nObjType;
                try
                {
                    //폼종류/표출시간/배경색상
                    sCont = "";
                    sCont.printf("%02.02X%02.02X%02.02X|", pForm->FormKind, pForm->DisplayTime, pForm->BkColor);
                    VMS_DSPL_MSG_DATA += sCont;

                    nObjCnt = pForm->Count();
    //LDEBUG("SaveVmsProvide: %s, %d, object: %d EA", AObj->VmsNo.c_str(), ii+1, nObjCnt);

                    for (int jj = 0; jj < nObjCnt; jj++)
                    {
                        TVmsFormObj *pFormObj = pForm->GetItem(jj);
                        switch(pFormObj->ObjectType)
                        {
                        case 1: //심볼
                        case 2: //이미지
                            nObjType = vms_obj_bitmap;
                            sTmp = "";
#if 0
                            sTmp.printf("%02.02X%04.04X%04.04X%02.02X%s|",
#else
                            sTmp.printf("%02.02X%04.04X%04.04X%02.02d%s|",
#endif
                                pFormObj->IsBlinking,
                                pFormObj->PosX,
                                pFormObj->PosY,
                                pFormObj->BkColor,
                                pFormObj->ImageId.SubString(1,4).c_str());

                            sCont = "";
                            sCont.printf("%02.02X%02.02X%s", nObjType, sTmp.Length(), sTmp.c_str());
                            VMS_DSPL_MSG_DATA += sCont;
                            break;
                        case 17: //소통정보이미지1
                        case 27: //소통정보이미지2
                        case 37: //소통정보이미지3
                        case 47: //소통정보이미지4
                        case  3: //소통정보배경이미지
                            {
                                nObjType = vms_obj_draw;
                                sTmp = "";
#if 0
                                sTmp.printf("%02.02X%04.04X%04.04X%02.02X%s+",
#else
                                sTmp.printf("%02.02X%04.04X%04.04X%02.02d%s+",
#endif
                                    pFormObj->IsBlinking,
                                    pFormObj->PosX,
                                    pFormObj->PosY,
                                    pFormObj->BkColor,
                                    pFormObj->ImageId.SubString(1,4).c_str());

                                sCont = "";
                                sCont.printf("%02.02X%02.02X%s", nObjType, sTmp.Length(), sTmp.c_str());
                                VMS_DSPL_MSG_DATA += sCont;

                                AnsiString sVertex = "";
                                TCDSImage *pSymbol = ImageManager->FLists.Find(pFormObj->ImageId);
                                if (pSymbol)
                                {
                                    sTmp = "";
                                    int nCnt = 0;

                                    FOR_STL(TCDSImageCell*, pCell, pSymbol->FLists)
                                    {
                                        TCDSIfsc *pIfsc = NULL;
                                        if (pFormObj->ObjectType == 3)
                                            pIfsc = IfscManager->FLists.Find(pCell->VMS_IFSC_ID);
                                        else
                                            pIfsc = IfscManager->FLists.Find(pFormObj->IFSC_ID);

                                        if (pIfsc)
                                        {
                                            sVertex = "";
                                            sVertex.sprintf("%03.03d%03.03d%01.01d", pCell->POSX, pCell->POSY, pIfsc->CMTR_GRAD_CD.ToIntDef(0));
                                            sTmp += sVertex;
                                            nCnt++;
                                        }
                                    }
                                    sCont = "";
                                    sCont.printf("%02.02X%s|", nCnt, sTmp.c_str());
                                    VMS_DSPL_MSG_DATA += sCont;
                                }
                                else
                                {
                                    VMS_DSPL_MSG_DATA += "X|";
                                }
                            }
                            break;
                        default://기타 문자열
                            VMS_DSPL_MSG_TXT += pFormObj->TextData;
                            VMS_DSPL_MSG_TXT += " ";

                            nObjType = vms_obj_text;
                            sTmp = "";
#if 0
                            sTmp.printf("%02.02X%04.04X%04.04X%02.02X%02.02X%02.02X%02.02X%02.02X%02.02X%s|",
                                pFormObj->IsBlinking,
                                pFormObj->PosX,
                                pFormObj->PosY,
                                pFormObj->BkColor,
                                pFormObj->TextFontSize,
                                pFormObj->TextFontColor,
                                pFormObj->TextFontName,
                                pFormObj->TextFontBold,
                                pFormObj->TextData.Length(),
                                pFormObj->TextData.c_str());
#else
/* 용인 폰트색상이 한자리로 찍혀서 %02d로 변경 */
                            sTmp.printf("%02.02X%04.04X%04.04X%02.02X%02.02X%02.02d%02.02X%02.02X%02.02X%s|",
                                pFormObj->IsBlinking,
                                pFormObj->PosX,
                                pFormObj->PosY,
                                pFormObj->BkColor,
                                pFormObj->TextFontSize,
                                pFormObj->TextFontColor,
                                pFormObj->TextFontName,
                                pFormObj->TextFontBold,
                                pFormObj->TextData.Length(),
                                pFormObj->TextData.c_str());
#endif

                            sCont = "";
                            sCont.printf("%02.02X%02.02X%s", nObjType, sTmp.Length(), sTmp.c_str());
                            VMS_DSPL_MSG_DATA += sCont;
                            break;
                        }
                    }

                    if (VMS_DSPL_MSG_DATA.Length() > 1200)
                    {
                        LERROR("XXXXXX VMS_DSPL_MSG_DATA Over: %d", VMS_DSPL_MSG_DATA.Length());
                        VMS_DSPL_MSG_DATA = VMS_DSPL_MSG_DATA.SubString(1, 1200);
                    }

                    if (VMS_DSPL_MSG_TXT.Length()  > 200)
                    {
                        LERROR("XXXXXX VMS_DSPL_MSG_TXT Over: %d", VMS_DSPL_MSG_TXT.Length());
                        VMS_DSPL_MSG_TXT  = VMS_DSPL_MSG_TXT.SubString(1, 199);
                    }

//LDEBUG("SaveVmsProvide: %s, %d Merge", AObj->VmsNo.c_str(), ii+1);
                    SQLBind(pSADO, "p01", VMS_CTLR_NMBR);
                    SQLBind(pSADO, "p02", PHASE);
                    SQLBind(pSADO, "p03", DSPL_DT);
                    SQLBind(pSADO, "p04", VMS_DSPL_MSG_DATA);
                    SQLBind(pSADO, "p05", VMS_DSPL_MSG_TXT);
                    SQLBind(pSADO, "p06", TRFC_SITU_TYPE_CD);
                    SQLBind(pSADO, "p07", VMS_MSG_DSPL_DRCT_CD);
                    SQLBind(pSADO, "p08", VMS_MSG_DSPL_MTHD_CD);
                    SQLBind(pSADO, "p09", DSPL_HH);
                    SQLBind(pSADO, "p10", VMS_FORM_ID);
                    SQLBind(pSADO, "p11", DNLD_YN);
                    SQLExec(pSADO);

                    try
                    {
//LDEBUG("SaveVmsProvide: %s, %d Update", AObj->VmsNo.c_str(), ii+1);
                        SQLBind(pUADO, "p01", VMS_CTLR_NMBR);
                        SQLBind(pUADO, "p02", PHASE);
                        //pUADO->Parameters->ParamByName("p03")->LoadFromStream(pStream, ftBlob);
                        pUADO->Parameters->ParamByName("p03")->LoadFromStream(pForm->pStream, ftBlob);
                        SQLExec(pUADO);

//LINFO("[%s] FormImage Size: %d", AObj->VmsNo.c_str(), pForm->pStream->Size);
                        //pForm->pBitmap->SaveToFile(g_sFormDir + AObj->VmsId + "\\" + PHASE + ".bmp");
                        //pImage->Picture->SaveToFile(g_sFormDir + AObj->VmsId + "\\" + PHASE + ".bmp");
                    }
                    catch(Exception &e)
                    {
                    }

                    nSelCnt++;
                }
                __finally
                {
                }
            }

            pSADO->Connection->CommitTrans();

            nResult = VERR_NONE;
		}
		catch(EDatabaseError &E)
		{
            pSADO->Connection->RollbackTrans();
            ErrorString = String(E.ClassName()) + E.Message;
            DBERRORLOG("SaveVmsProvide", String(E.ClassName()), E.Message, sQry);
            nResult = VERR_OTHER;
		}
		catch(Exception &e)
		{
            pSADO->Connection->RollbackTrans();
            ErrorString = String(e.ClassName()) + e.Message;
            DBERRORLOG("SaveVmsProvide", String(e.ClassName()), e.Message, sQry);
		}
	}
	__finally
	{
        AObj->pForms->UnLock();

        if (pSADO)
        {
            SQLClose(pSADO);
            SAFE_DELETE(pSADO);
        }
        if (pUADO)
        {
            SQLClose(pUADO);
            SAFE_DELETE(pUADO);
        }
	}
    LINFO("SaveVmsDatabaseForm: End, %s, %d EA", AObj->VmsNo.c_str(), nSelCnt);
    return nSelCnt;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::ProvideSave(void *AData)
{
	int          nResult, ii;
    TVmsCtlr    *pObj;
	SAVE_STRUCT *pSave;
    int          nJobCnt = 0;

	nResult = VERR_NONE;

    LINFO("ProvideSave: Start");

    pSave = (SAVE_STRUCT*)AData;
    if (!pSave)
    {
        LERROR("ProvideSave: Data NULL");
        return VERR_MEMORY_ALLOC;
    }

    try
    {
        switch(pSave->Type)
        {
        case save_download:
            for (ii = 0; ii < pSave->Count && ii < INT_MAX_VMS_STATE; ii++)
            {
                pObj = (TVmsCtlr*)pSave->pObj[ii];
                if (!pObj) continue;
                if ((nResult = SaveVmsDownLoad(pObj)) != VERR_NONE)
                {
                    LERROR("ProvideSave: SaveVmsDownLoad failed");
                }
            }
            break;
        case save_provide:
            {
                INT_VMS_FORM_DOWNLOAD_REQ VmsSave;

                memset(&VmsSave, 0x00, sizeof(VmsSave));
                VmsSave.Count = 0;

                LINFO("VMS Msg Dnld Result Save: %d EA", pSave->Count);
                for (ii = 0; ii < pSave->Count && ii < INT_MAX_VMS_FORM_DOWNLOAD; ii++)
                {
                    pObj = (TVmsCtlr*)pSave->pObj[ii];
                    if (!pObj) continue;
#if 0
                    if ((nResult = SaveVmsProvide(pObj)) != VERR_NONE)
#else
                    if ((nResult = UpdateVmsProvideResult(pObj)) != VERR_NONE)
#endif
                    {
                        LERROR("ProvideSave: UpdateVmsProvideResult failed");
                    }
                    else
                    {
                        nJobCnt++;

                        memcpy(VmsSave.Unit[VmsSave.Count].VmsId, pObj->VmsNo.c_str(), INT_VMS_MAX_ID);
                        memcpy(VmsSave.Unit[VmsSave.Count].Date,  pObj->CTLMODE->SvcDate.c_str(), INT_VMS_MAX_DATETIME);
                        VmsSave.Unit[VmsSave.Count].Result = pObj->CTLMODE->Result ? vms_download_succ : vms_download_fail;
                        VmsSave.Count++;

                        if (VmsSave.Count >= INT_MAX_VMS_FORM_DOWNLOAD)
                        {
                            VComm_VmsFormDownLoadNotify(&VmsSave);
                            VmsSave.Count = 0;
                        }
                    }
                }
                if (VmsSave.Count > 0)
                {
                    VComm_VmsFormDownLoadNotify(&VmsSave);
                }
            }
            break;
        }
    }
    __finally
    {
        delete[] (char *)AData;
    }
    LINFO("ProvideSave: %d EA", nJobCnt);
	return nResult;
}
//---------------------------------------------------------------------------

int __fastcall TDMCOMM::CheckSafeAlarm()
{
    String     sQry;
    TADOQuery *pADO = NULL;
    int        nSelCnt = 0;

    sQry = "SELECT SAFE_ALM_ID, MSG_TP                                                      \r\n"
           "  FROM TB_VMS_SAFE_ALM                                                          \r\n"
           " WHERE ALM_CNFM = 'N'                                                           \r\n"
           "   AND TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') BETWEEN ALM_STRT_DT AND ALM_END_DT  \r\n";
    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = GetDbConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                AnsiString SAFE_ALM_ID = pADO->FieldByName("SAFE_ALM_ID")->AsString.Trim();
                AnsiString MSG_TP      = pADO->FieldByName("MSG_TP")->AsString.Trim();
                nSelCnt++;
            }

#if 0
            if (nSelCnt > 0)
            {
                sQry = "UPDATE TB_VMS_SAFE_ALM                                                          \r\n"
                       "   SET ALM_CNFM = 'Y'                                                           \r\n"
                       " WHERE ALM_CNFM = 'N'                                                           \r\n"
                       "   AND TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') BETWEEN ALM_STRT_DT AND ALM_END_DT  \r\n";
                pADO->SQL->Clear();
                pADO->SQL->Text = sQry;
                SQLExec(pADO);
            }
#endif
        }
        catch(EDatabaseError &E)
        {
            ErrorString = String(E.ClassName()) + E.Message;
            return nSelCnt;
        }
        catch(Exception &e)
        {
            ErrorString = String(e.ClassName()) + e.Message;
            return nSelCnt;
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return nSelCnt;
}
//---------------------------------------------------------------------------