VMSCommServer/SRC/VMSCommLib/COMMON/PacketHandllingF.cpp

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

#pragma hdrstop

#include <DateUtils.hpp>
#include "PacketHandllingF.h"
#include "ClientSessionF.h"
#include "VMSCommLibF.h"
#include "CenterCommF.h"
//---------------------------------------------------------------------------
#define TERROR(args...)     ASession->SysLogWrite(eLOG_ERROR, ##args)
#define TDEBUG(args...)     ASession->LogWrite(eLOG_DEBUG, ##args)
#define TINFO(args...)      ASession->LogWrite(eLOG_INFO, ##args)

#define OK_DEBUG    0

#pragma package(smart_init)

extern const unsigned short g_crc16_table[256] =
{
	0x0000, 0xC0C1, 0xC181, 0x0140, 0xC301, 0x03C0, 0x0280, 0xC241,
	0xC601, 0x06C0, 0x0780, 0xC741, 0x0500, 0xC5C1, 0xC481, 0x0440,
	0xCC01, 0x0CC0, 0x0D80, 0xCD41, 0x0F00, 0xCFC1, 0xCE81, 0x0E40,
	0x0A00, 0xCAC1, 0xCB81, 0x0B40, 0xC901, 0x09C0, 0x0880, 0xC841,
	0xD801, 0x18C0, 0x1980, 0xD941, 0x1B00, 0xDBC1, 0xDA81, 0x1A40,
	0x1E00, 0xDEC1, 0xDF81, 0x1F40, 0xDD01, 0x1DC0, 0x1C80, 0xDC41,
	0x1400, 0xD4C1, 0xD581, 0x1540, 0xD701, 0x17C0, 0x1680, 0xD641,
	0xD201, 0x12C0, 0x1380, 0xD341, 0x1100, 0xD1C1, 0xD081, 0x1040,
	0xF001, 0x30C0, 0x3180, 0xF141, 0x3300, 0xF3C1, 0xF281, 0x3240,
	0x3600, 0xF6C1, 0xF781, 0x3740, 0xF501, 0x35C0, 0x3480, 0xF441,
	0x3C00, 0xFCC1, 0xFD81, 0x3D40, 0xFF01, 0x3FC0, 0x3E80, 0xFE41,
	0xFA01, 0x3AC0, 0x3B80, 0xFB41, 0x3900, 0xF9C1, 0xF881, 0x3840,
	0x2800, 0xE8C1, 0xE981, 0x2940, 0xEB01, 0x2BC0, 0x2A80, 0xEA41,
	0xEE01, 0x2EC0, 0x2F80, 0xEF41, 0x2D00, 0xEDC1, 0xEC81, 0x2C40,
	0xE401, 0x24C0, 0x2580, 0xE541, 0x2700, 0xE7C1, 0xE681, 0x2640,
	0x2200, 0xE2C1, 0xE381, 0x2340, 0xE101, 0x21C0, 0x2080, 0xE041,
	0xA001, 0x60C0, 0x6180, 0xA141, 0x6300, 0xA3C1, 0xA281, 0x6240,
	0x6600, 0xA6C1, 0xA781, 0x6740, 0xA501, 0x65C0, 0x6480, 0xA441,
	0x6C00, 0xACC1, 0xAD81, 0x6D40, 0xAF01, 0x6FC0, 0x6E80, 0xAE41,
	0xAA01, 0x6AC0, 0x6B80, 0xAB41, 0x6900, 0xA9C1, 0xA881, 0x6840,
	0x7800, 0xB8C1, 0xB981, 0x7940, 0xBB01, 0x7BC0, 0x7A80, 0xBA41,
	0xBE01, 0x7EC0, 0x7F80, 0xBF41, 0x7D00, 0xBDC1, 0xBC81, 0x7C40,
	0xB401, 0x74C0, 0x7580, 0xB541, 0x7700, 0xB7C1, 0xB681, 0x7640,
	0x7200, 0xB2C1, 0xB381, 0x7340, 0xB101, 0x71C0, 0x7080, 0xB041,
	0x5000, 0x90C1, 0x9181, 0x5140, 0x9301, 0x53C0, 0x5280, 0x9241,
	0x9601, 0x56C0, 0x5780, 0x9741, 0x5500, 0x95C1, 0x9481, 0x5440,
	0x9C01, 0x5CC0, 0x5D80, 0x9D41, 0x5F00, 0x9FC1, 0x9E81, 0x5E40,
	0x5A00, 0x9AC1, 0x9B81, 0x5B40, 0x9901, 0x59C0, 0x5880, 0x9841,
	0x8801, 0x48C0, 0x4980, 0x8941, 0x4B00, 0x8BC1, 0x8A81, 0x4A40,
	0x4E00, 0x8EC1, 0x8F81, 0x4F40, 0x8D01, 0x4DC0, 0x4C80, 0x8C41,
	0x4400, 0x84C1, 0x8581, 0x4540, 0x8701, 0x47C0, 0x4680, 0x8641,
	0x8201, 0x42C0, 0x4380, 0x8341, 0x4100, 0x81C1, 0x8081, 0x4040
};
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
static WORD GETCRC16(char *AData, int ALen)
{
	WORD crc = 0;

	for (int ii = 0; ii < ALen; ii++)
	{
		crc = ( (crc >> 8) ^ g_crc16_table[(crc ^ AData[ii]) & 0x0ff] );
	}

	return crc;
}
//---------------------------------------------------------------------------


//---------------------------------------------------------------------------
typedef int (*RecvPktHandlerFunc)(TClientSession *ASession, BYTE *AData, int APktLen);
//---------------------------------------------------------------------------

static int UnknownPktHandler(TClientSession *ASession, BYTE *AData, int APktLen)
{
    if (ASession->CDSLogCtlr)
    {
        TERROR("+CLI Invalid packet handler: %s. will be closed.", ASession->IpAddress.c_str());
    }

    VMS_HEAD *pHd = (VMS_HEAD*)AData;
    if (!pHd) return -1;

    MERROR("+CLI Invalid packet handler: %s. 0x%02X, will be closed.", ASession->IpAddress.c_str(), pHd->OpCode);

    ASession->LogData("RECV", (BYTE*)ASession->GetRecvBuff(), APktLen);
	ASession->Disconnect();
    return -1;
}
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
static RecvPktHandlerFunc G_FuncPktHandler[e_vms_MAX] = {NULL};
//---------------------------------------------------------------------------

struct _init_pkt_handler
{
    //정적 패킷핸들러 함수 초기화
	_init_pkt_handler()
	{
		for (int ii = 0; ii < e_vms_MAX; ii++)
		{
        	G_FuncPktHandler[ii] = UnknownPktHandler;
        }
	}
};
static _init_pkt_handler init_pkt_handler;
//---------------------------------------------------------------------------

struct RegisterHandler
{
	RegisterHandler(BYTE AOpCode, RecvPktHandlerFunc AFuncHandler)
	{
		G_FuncPktHandler[(int)AOpCode] = AFuncHandler;
	}
};
//---------------------------------------------------------------------------

#define REGISTER_HANDLER(PKT_TYPE)	\
	static int Handler_##PKT_TYPE(TClientSession* ASession, BYTE *AData, int APktLen); \
	static RegisterHandler _register_##PKT_TYPE(PKT_TYPE, Handler_##PKT_TYPE); \
	static int Handler_##PKT_TYPE(TClientSession* ASession, BYTE *AData, int APktLen)

void CALLBACK RecvCompletion(DWORD dwError, DWORD cbTransferred, LPWSAOVERLAPPED lpOverlapped, DWORD dwFlags)
{
    TClientSession *pSession = static_cast<OverlappedIO*>(lpOverlapped)->FSession;

    if (!pSession->IsConnected)
    {
        MERROR("+SVR RecvCompletion(IsConnected false): %s[%d]", pSession->IpAddress.c_str(), pSession->Socket);
        return;
    }

    /// 에러 발생시 해당 세션 종료
    if (dwError || cbTransferred == 0)
    {
        MERROR("+SVR RecvCompletion(dwError || cbTransferred==0): %s[%d], will be closed", pSession->IpAddress.c_str(), pSession->Socket);
        pSession->Disconnect();
        return;
    }

    /// 받은 데이터 처리
    pSession->OnRead(cbTransferred);
}
//---------------------------------------------------------------------------

#if 0
void CALLBACK SendCompletion(DWORD dwError, DWORD cbTransferred, LPWSAOVERLAPPED lpOverlapped, DWORD dwFlags)
{
    TClientSession *pSession = static_cast<OverlappedIO*>(lpOverlapped)->FSession;

    if (!pSession->IsConnected)
    {
        MERROR("+SVR SendCompletion(IsConnected false): %s[%d]", pSession->IpAddress.c_str(), pSession->Socket);
        return;
    }

    /// 에러 발생시 해당 세션 종료
    if (dwError || cbTransferred == 0)
    {
        MERROR("+SVR SendCompletion(dwError || cbTransferred==0): %s[%d], will be closed", pSession->IpAddress.c_str(), pSession->Socket);
        pSession->Disconnect();
        return;
    }

    pSession->OnWriteComplete(cbTransferred, cbTransferred);
}
//---------------------------------------------------------------------------
#endif

static TCDSCtlr* FindControllerByIpAddr(AnsiString AIpAddress)
{
    CtlrItr it;
    for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
    {
        TCDSCtlr *pObj = (TCDSCtlr*)it->second;

        if (!pObj->Used) continue;

        if (pObj->CTLR_IP.AnsiCompare(AIpAddress) == 0)
        {
            return pObj;
        }
    }

    return NULL;
}
//---------------------------------------------------------------------------
static TCDSCtlr* FindControllerById(AnsiString ACtrlNmbrId)
{
    CtlrItr it;
    for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
    {
        TCDSCtlr *pObj = (TCDSCtlr*)it->second;

        if (!pObj->Used) continue;

        if (pObj->CTLR_NMBR_ID.AnsiCompare(ACtrlNmbrId) == 0)
        {
            return pObj;
        }
    }

    return NULL;
}
//---------------------------------------------------------------------------
static int RequestJob(TClientSession *ASession, int AJob, char *AData, int ALen)
{
    IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
    pMsg->Type   = AJob;
    pMsg->ObjPtr = (DWORD)ASession;
    if (ALen > 0)
    {
        memcpy(pMsg->Buff, AData, ALen);
    }
    pMsg->Len = ALen;
    g_jobQ.PushBlocking((DWORD)pMsg);
    return 0;
}
//---------------------------------------------------------------------------

bool TClientSession::SendPacketDleStuffing(char *AData, int ADataLen)
{
    int nSendLen;
    int nLen;
    WORD crc;
    BYTE c;
    BYTE *msgPrt;
    BYTE *pData;

    msgPrt = FMsgBuff;
    pData  = AData;

    nLen = ADataLen;
    crc  = GETCRC16(pData, nLen);

    *msgPrt++ = VMS_DLE;
    *msgPrt++ = VMS_STX;

    // DLE Stuffing
    for (int ii = 0; ii < ADataLen; ii++)
    {
        *msgPrt++ = AData[ii];

        if (pData[ii] == VMS_DLE)
        {
            *msgPrt++ = VMS_DLE;
        }
    }

    *msgPrt++ = VMS_DLE;
    *msgPrt++ = VMS_ETX;

    *msgPrt++ = HIBYTE(crc);
    *msgPrt++ = LOBYTE(crc);

    nSendLen = msgPrt - FMsgBuff;

    if (!SendRequest((char*)FMsgBuff, nSendLen))
    {
        SERROR("+CLI SendPacketDleStuffing send request faild: %s, 0x%02X will be closed.", FIpAddress.c_str(), AData[4]);
        MERROR("+CLI SendPacketDleStuffing send request faild: %s, 0x%02X will be closed.", FIpAddress.c_str(), AData[4]);
        Disconnect();
        return false;
    }

    return SendFlushComplete();
}
//---------------------------------------------------------------------------

bool TClientSession::SendPacketDLE(char *AData, int ADataLen, bool AIsDle)
{
    int nSendLen;
    int nLen;
    BYTE c;
    BYTE *msgPrt;
    BYTE *pData;

    IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();

    msgPrt = (BYTE*)pMsg->Buff;
    pData  = AData;

    *msgPrt++ = AData[0];
    *msgPrt++ = AData[1];

    // DLE Stuffing
    for (int ii = 2; ii < ADataLen-4; ii++)
    {
        *msgPrt++ = AData[ii];

        if (AIsDle && pData[ii] == VMS_DLE)
        {
            *msgPrt++ = VMS_DLE;
        }
    }

    *msgPrt++ = AData[ADataLen-4];  // DLE
    *msgPrt++ = AData[ADataLen-3];  // ETX
    *msgPrt++ = AData[ADataLen-2];  // CRC
    *msgPrt++ = AData[ADataLen-1];  // CRC

    nSendLen = msgPrt - (BYTE*)pMsg->Buff;

    pMsg->Type   = eVmsSendPacket;
    pMsg->ObjPtr = (DWORD)this;
    pMsg->Len    = nSendLen;
    g_jobQ.PushBlocking((DWORD)pMsg);

    Sleep(20);
    return true;
}
//---------------------------------------------------------------------------

bool TClientSession::SendPacket(char *AData, int ADataLen)
{
    int nSendLen;
    int nLen;
    WORD crc;
    BYTE c;
    BYTE *msgPtr;
    BYTE *pData;

    msgPtr = FMsgBuff;
    pData  = AData;

    nLen = ADataLen;
    crc  = GETCRC16(pData, nLen);

    *msgPtr++ = VMS_DLE;
    *msgPtr++ = VMS_STX;

    // DLE Stuffing
    for (int ii = 0; ii < ADataLen; ii++)
    {
        *msgPtr++ = AData[ii];

        if (pData[ii] == VMS_DLE)
        {
            *msgPtr++ = VMS_DLE;
        }
    }

    *msgPtr++ = VMS_DLE;
    *msgPtr++ = VMS_ETX;
    *msgPtr++ = HIBYTE(crc);
    *msgPtr++ = LOBYTE(crc);

    nSendLen = msgPtr - FMsgBuff;

    if (!SendRequest((char*)FMsgBuff, nSendLen))
    {
        SERROR("+CLI SendPacket send request faild: %s, 0x%02X will be closed.", FIpAddress.c_str(), AData[4]);
        MERROR("+CLI SendPacket send request faild: %s, 0x%02X will be closed.", FIpAddress.c_str(), AData[4]);
        Disconnect();
        return false;
    }
    return true;
#if 0
    int nSendLen;
    int nLen;
    WORD crc;
    BYTE c;
    BYTE *msgPtr;
    BYTE *pData;

    msgPtr = FMsgBuff;
    pData  = AData;

    nLen = ADataLen;
    crc  = GETCRC16(pData, nLen);

    msgPtr[0] = VMS_DLE;
    msgPtr[1] = VMS_STX;

    if (ADataLen > 0)
    {
        memcpy(&msgPtr[2], AData, ADataLen);
    }
    msgPtr[ADataLen+2] = VMS_DLE;
    msgPtr[ADataLen+3] = VMS_ETX;
    msgPtr[ADataLen+4] = HIBYTE(crc);
    msgPtr[ADataLen+5] = LOBYTE(crc);

#if 0
    for (int ii = 0; ii < ADataLen; ii++)
    {
        *msgPrt++ = AData[ii];
#if 0
        if (pData[ii] == VMS_DLE)
        {
            *msgPrt++ = VMS_DLE;
        }
#endif
    }
#endif

    nSendLen = ADataLen + 6;

    if (!SendRequest((char*)msgPtr, nSendLen))
    {
        SERROR("+CLI SendPacket send request faild: %s, 0x%02X will be closed.", FIpAddress.c_str(), AData[4]);
        MERROR("+CLI SendPacket send request faild: %s, 0x%02X will be closed.", FIpAddress.c_str(), AData[4]);
        Disconnect();
        return false;
    }
    return true;
#endif
}
//---------------------------------------------------------------------------

bool TClientSession::CheckLoginClient()
{
    TCDSCtlr *pCDSCtlr = FindControllerByIpAddr(FIpAddress);
    if (!pCDSCtlr)
    {
        MERROR("+CLI Unknown client address: %s. will be closed.", FIpAddress.c_str());
        return false;
    }

    //이전 접속정보가 있는지 확인한다.
    if (FCDSCtlr)
    {
        TClientSession *pSession = FCDSCtlr->FSession;
        if (pSession)
        {
            //이전 접속을 종료하고 현재 접속을 새로운 VMS 제어기 통신으로 사용한다.
            MERROR("+CLI Client allready connect: %s. old connection will be closed.", FIpAddress.c_str());
            pSession->Disconnect();
        }
    }

    FState      = eSS_LoginReq;     //최초접속후 폼을 다운로드 하기위해 사용할 플래그(기존에는 로그인체크용으로 사용)
    FCDSCtlr    = pCDSCtlr;
    FCDSLogCtlr = pCDSCtlr;
    FCDSCtlr->FSession = this;
    FCDSCtlr->LOGIN_IPADDR     = FIpAddress;      //연결된 IP주소 설정
    FCDSCtlr->Server.commState = comm_open;
    FCDSCtlr->Server.ConnectTm = Now().FormatString("yyyy-MM-dd hh:nn:ss");
    FCtlrId.printf("%10.010d", FCDSCtlr->CTLR_NMBR.ToIntDef(0));
    POST_MSG(MAINHANDLE, WM_TCP_THREAD, WM_TCP_SERVER_STTS, (int)pCDSCtlr);
    ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

    // 최초에 폼정보를 모두 다운로드 해버리자.(TODO: 메모리 할당이 위에서 끝난다음에 초기화해야함)
    FCDSCtlr->InitDownloadFileInfo();

    //최초에 상태정보를 요청하고 상태정보요청 응답이 완료되면 시나리오를 다운로드 하자.
    RequestJob(this, eVmsStatusReq, NULL, 0);

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

bool TClientSession::OnDisconnected()
{
    if (FCDSCtlr)
    {
        if (FCDSCtlr->IsVideo) {
            FCDSCtlr->InitFtpFileInfo();    // TODO: FTP 다운로드 정보를 초기화 한다.
        }

        FCDSCtlr->Server.DisconnectTm = Now().FormatString("yyyy-MM-dd hh:nn:ss");
        FCDSCtlr->Server.commState    = comm_close;
        FCDSCtlr->FSession            = NULL;
        //FCDSCtlr->LOGIN_IPADDR        = "";

        LERROR("VMS %s disconnected.", CtlrId.c_str());
        MERROR("%s.%d, VMS %s disconnected.", FIpAddress.c_str(), FSocket, CtlrId.c_str());

        TCDSCtlr* pCDSCtlr = FCDSCtlr;
        POST_MSG(MAINHANDLE, WM_TCP_THREAD, WM_TCP_SERVER_STTS, (int)pCDSCtlr);
    }
    else
    {
        MERROR("%s.%d, disconnected.", FIpAddress.c_str(), FSocket);
    }

    FState = eSS_Disconnect;
    return true;
}
//---------------------------------------------------------------------------

/*
* 1개의 패킷을 모두 전송한 후 호출됨
*/
void TClientSession::OnWrite(char *APktPtr, int ASendLen)
{
    VMS_HEAD *pHd = (VMS_HEAD*)APktPtr;
    if (!pHd) return;

    if (ASendLen > 0)
    {
        LDEBUG("SEND: %d Bytes", ASendLen);
        LogData("SEND", APktPtr, ASendLen);
    }
    InfoPacket(pHd->OpCode, ASendLen, true, 0);

#if 0
    switch(pHd->OpCode)
    {
    case VMS_ID_REQ:            // 0xFF        // server -> client
    case DNLD_SCENARIO_REQ:     // 0x02        // server -> client
    case CTRL_RESET_REQ:        // 0x03        // server -> client
    case DNLD_FILE_REQ:         // 0x04        // server -> client
    case PARAMETER_REQ:         // 0x05        // server -> client
    case CTRL_LED_POWER_REQ:    // 0x06        // server -> client
    case CTRL_FAN_POWER_REQ:    // 0x07        // server -> client
    case CTRL_BRGH_REQ:         // 0x08        // server -> client
    case CTRL_CONFIG_REQ:       // 0x09        // server -> client
    case CTRL_TIME_REQ:         // 0x10        // server -> client
        FTmrSend = Now();
        if (FChkRecvTO == false)
        {
            FTmrRecv = Now();
        }
        FChkRecvTO = true;
        break;
    default:
        FChkRecvTO = false;     // 0x01        // server -> client
        break;
    }
#endif
}
//---------------------------------------------------------------------------

/*
*  프로토콜에 따른 처리
*/
void TClientSession::OnRead(int ALen)
{
    int  readIdx;
    int  stuffing;
    int  dleEtx;
    int  msgSize;
    BYTE msgBuff[SESSION_SEND_BUFFER];
    BYTE data;
    WORD crc;

    VMS_RES_HEAD *pHead;

    FRecvIdx += ALen;

    if (FRecvIdx > 0)
    {
        LDEBUG("RECV: %d Bytes", FRecvIdx);
        LogData("RECV", (char*)FRecvBuff, FRecvIdx);
    }

	while(true)
	{
        if (FRecvIdx < (int)sizeof(VMS_HEAD))
        {
            break;
        }

        if (FRecvBuff[0] != VMS_DLE && FRecvBuff[1] != VMS_STX)
        {
            MERROR("+CLI Packet parsing data start command error: %s, 0x%02X, 0x%02X. will be closed.", FIpAddress.c_str(), FRecvBuff[0], FRecvBuff[1]);
            Disconnect();
            return;
        }

        readIdx    = 0;
        stuffing   = 0; // 연속된 DLE 데이터 체크, 1 이면 DLE Stuffing
        dleEtx     = 0; // DLE_ETX, ETX를 체크하기 위함, 1 이고 ETX 데이터를 읽었으면 패킷의 마지막(DLE_ETX, ETX 데이터 임)
        msgSize    = 0; // 순수 데이터 사이즈

        while (readIdx < FRecvIdx && msgSize < (int)sizeof(msgBuff))
        {
            data = FRecvBuff[readIdx++];
            if (data == VMS_DLE)
            {
                if (stuffing)
                {
                    stuffing = 0;
                    dleEtx   = 0;   // TODO
                }
                else
                {
                    msgBuff[msgSize++] = data;
                    stuffing = 1;
                    dleEtx   = 1;
                }
            }
            else
            if (data == VMS_ETX)
            {
                msgBuff[msgSize++] = data;
                if (dleEtx)
                {
                    // 이전데이터가 DLE이고 현재 데이터가 ETX이면 패킷의 끝임.
                    // 다음 2바이트는 CRC 데이터임, 남아 있는 데이터가 CRC 2바이트를 포함한 크기보다 작으면
                    // 하나의 패킷을 완전히 수신하지 못한 것임
                    if ((readIdx + 2) > FRecvIdx)
                    {
                        // 하나의 패킷을 읽지 못함
                        return;
                    }
                    msgBuff[msgSize++] = FRecvBuff[readIdx++];  // CRC1
                    msgBuff[msgSize++] = FRecvBuff[readIdx++];  // CRC2

                    // 하나의 패킷을 완전히 읽었음.
                    ResetPacket(readIdx);   // 메모리에서 수신 인덱스 초기화

#if 0
                    // dle, stx 제외, dle,etx,crc(2) 제외
                    crc = GETCRC16(&msgBuff[2], msgSize-2-sizeof(VMS_TAIL));
                    if (msgBuff[readIdx-2] != HIBYTE(crc) || msgBuff[readIdx-1] != LOBYTE(crc))
                    {
                        MERROR("+CLI Packet parsing data crc error: %s, 0x%02X, 0x%02X, 0x%02X, 0x%02X. will be closed.",
                                FIpAddress.c_str(), msgBuff[readIdx-2], msgBuff[readIdx-1], HIBYTE(crc), LOBYTE(crc));
                        Disconnect();
                        return;
                    }
#endif

                    pHead = (VMS_RES_HEAD*)msgBuff;
                    if (pHead->Length != msgSize-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL))
                    {
                        MERROR("+CLI Packet parsing data length error: %s, %d, %d. will be closed.",
                                FIpAddress.c_str(), pHead->Length, msgSize-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL));

                        ITSLog->LogData("RECV", FRecvBuff, FRecvIdx);
                        if (FCDSCtlr != NULL && FCDSCtlr->FSLog->FLogCfg.Data) FCDSCtlr->FSLog->LogData("RECV", FRecvBuff, FRecvIdx);

                        Disconnect();
                        return;
                    }

                    InfoPacket(pHead->OpCode, msgSize, false, 0);
                    if (G_FuncPktHandler[pHead->OpCode](this, msgBuff, msgSize) < 0)
                    {
                        Disconnect();
                        return;
                    }
                    SendFlush();
                    break;
                }
                else
                {
                    dleEtx = 0;
                }
            }
            else
            {
                // 순수 데이터를 읽음
                msgBuff[msgSize++] = data;
                stuffing = 0;
                dleEtx   = 0;
            }
        }

        if (readIdx >= FRecvIdx)
        {
            break;
        }
    }
}
//---------------------------------------------------------------------------

template <class PKT_TYPE>
bool TClientSession::ParsePacket(PKT_TYPE& pkt, int APktLen)
{
    if (APktLen > FRecvIdx)
    {
        MERROR("+CLI ParsePacket Error: %s, PktLen: %d, RecvIdx: %d", FIpAddress.c_str(), APktLen, FRecvIdx);
        return false;
    }

    memcpy((char*)&pkt, FRecvBuff, APktLen);
    FRecvIdx -= APktLen;
    if (FRecvIdx > 0)
    {
        memmove(FRecvBuff, FRecvBuff+APktLen, FRecvIdx);
    }
    return true;
}
//---------------------------------------------------------------------------

bool TClientSession::InfoPacket(BYTE AOpCode, int ALen, bool ASend, int AResult/*=0*/)
{
    TCDSCtlr* pCDSCtlr = FCDSLogCtlr;

    if (!pCDSCtlr) return -1;
    //if (!pCDSCtlr->FDispLog) return -1;
    //if (!g_LogCfg.Debug) return -1;
    if (!g_LogCfg.Info) return -1;

    AnsiString sCmd;

    switch(AOpCode)
    {
    case e_txt_disp_immediate_text://        = 0x02, //  Display Immediate Text                Opcode = 2  [0x02]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_disp_immediate_text";
        break;
    case e_txt_disp_immediate_graphic://     = 0x04, //  Display Immediate graphics            Opcode = 4  [0x04]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_disp_immediate_graphic";
        break;
    case e_txt_disp_lib_message://           = 0x06, //  Display Library Message               Opcode = 6  [0x06]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_disp_lib_message";
        break;
    case e_txt_download_message_lib://       = 0x08, //  Download  A Message Library           Opcode = 8  [0x08]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_download_message_lib";
        break;
    case e_txt_download_full_graphic_lib://  = 0x0A, //  Download Graphics Library             Opcode = 10 [0x0A]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_download_full_graphic_lib";
        break;
    case e_txt_download_graphic_symb_lib://  = 0x0C, //  Download Graphic Symbol Library       Opcode = 12 [0x0C]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_download_graphic_symb_lib";
        break;
    case e_txt_display_schedule_msg://       = 0x0E, //  Display Schedule Message              Opcode = 14 [0x0E]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_display_schedule_msg";
        break;
    case e_txt_initialize://                 = 0x12, //  Initailize                            Opcode = 18 [0x12]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_initialize";
        break;
    case e_txt_disp_test_pattern://          = 0x14, //  Display Test Pattern                  Opcode = 20 [0x14]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_disp_test_pattern";
        break;
    case e_txt_blank://                      = 0x16, //  Blank                                 Opcode = 22 [0x16]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_blank";
        break;

    case e_txt_download_parameter://         = 0x1C, //  Download Parameter                    Opcode = 28 [0x1C]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_download_parameter";
        break;
    case e_txt_display_default_msg://        = 0x1E, //  Display Default Message               Opcode = 30 [0x1E]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_display_default_msg";
        break;
    case e_txt_set_luminance_level://        = 0x20, //  Set Luminance Level                   Opcode = 32 [0x20]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_set_luminance_level";
        break;
    case e_txt_signboard_control://          = 0x24, //  Signboard Power Control               Opcode = 36 [0x24]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_signboard_control";
        break;
    case e_txt_signboard_alarm_control://    = 0x2A, //  Signboard Alarm Control               Opcode = 42 [0x2A]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_signboard_alarm_control";
        break;
    case e_txt_pan_hetr_temp_control://      = 0x31, //  함체 PAN/HEATER 온도 설정             Opcode = 49 [0x31]  ⇔ Opcode = 72 [0x48]
        sCmd = "txt_pan_hetr_temp_control";
        break;

    case e_txt_status_req://                 = 0x18, //  Status Request                        Opcode = 24 [0x18]  ⇔ Opcode = 64 [0x40]
        sCmd = "txt_status_req";
        break;
    case e_txt_status_res://                 = 0x40, //  Status Response                       Opcode = 24 [0x18]  ⇔ Opcode = 64 [0x40]
        sCmd = "txt_status_res";
        break;

    case e_txt_upload_modl_status_req://     = 0x28, //  Upload Module Status                  Opcode = 40 [0x28]  ⇔ Opcode = 74 [0x4A]
        sCmd = "txt_upload_modl_status_req";
        break;
    case e_txt_upload_modl_status_res://     = 0x4A, //  Upload Module Status                  Opcode = 40 [0x28]  ⇔ Opcode = 74 [0x4A]
        sCmd = "txt_upload_modl_status_res";
        break;

    case e_txt_pan_hetr_temp_req://          = 0x32, //  함체 PAN/HEATER 온도 요청    	      Opcode = 50 [0x32]  ⇔ Opcode = 66 [0x42]
        sCmd = "txt_pan_hetr_temp_req";
        break;
    //case e_txt_pan_hetr_temp_res://          = 0x42, //  함체 PAN/HEATER 온도 요청    	      Opcode = 50 [0x32]  ⇔ Opcode = 66 [0x42]
    //    sCmd = "txt_pan_hetr_temp_res";
    //    break;

    case e_txt_failed_elem_data_req://       = 0x1A, //  Failed Element Data Request           Opcode = 26 [0x1A]  ⇔ Opcode = 66 [0x42]
        sCmd = "txt_failed_elem_data_req";
        break;
    case e_txt_failed_elem_data_res://       = 0x42, //  Failed Element Data Response          Opcode = 26 [0x1A]  ⇔ Opcode = 66 [0x42]
        sCmd = "txt_failed_elem_data_res";
        break;

    case e_txt_upload_msg_req://             = 0x22, //  Upload A Message                      Opcode = 34 [0x22]  ⇔ Opcode = 68 [0x44]
        sCmd = "txt_upload_msg_req";
        break;
    case e_txt_upload_msg_res://             = 0x44, //  Upload A Message  Response            Opcode = 34 [0x22]  ⇔ Opcode = 68 [0x44]
        sCmd = "txt_upload_msg_res";
        break;

    case e_txt_upload_schedule_msg_req://    = 0x23, //  Upload Schedule Message               Opcode = 35 [0x23]  ⇔ Opcode = 69 [0x45]
        sCmd = "txt_upload_schedule_msg_req";
        break;
    case e_txt_upload_schedule_msg_res://    = 0x45, //  Upload Schedule Message               Opcode = 35 [0x23]  ⇔ Opcode = 69 [0x45]
        sCmd = "txt_upload_schedule_msg_res";
        break;

    case e_txt_msg_echo_back_req://          = 0x26, //  Message Echo Back                     Opcode = 38 [0x26]  ⇔ Opcode = 70 [0x46]
        sCmd = "txt_msg_echo_back_req";
        break;
    case e_txt_msg_echo_back_res://          = 0x46, //  Message Echo Back                     Opcode = 38 [0x26]  ⇔ Opcode = 70 [0x46]
        sCmd = "txt_msg_echo_back_res";
        break;

    case e_txt_image_req://                  = 0x2C, //  영상이미지 요청 Status                Opcode = 44 [0x2C]  ⇔ Opcode = 76 [0x4C]
        sCmd = "txt_image_req";
        break;
    case e_txt_image_res://                  = 0x4C, //  영상이미지 요청 Status                Opcode = 44 [0x2C]  ⇔ Opcode = 76 [0x4C]
        sCmd = "txt_image_res";
        break;

    //case e_txt_ftp_download://               = 0x2C, //  동영상 파일 FTP 다운로드              Opcode = 44 [0x2C]  ⇔ Opcode = 72 [0x48]
    //    sCmd = "txt_ftp_download";
    //    break;
    case e_txt_ftp_download_completed://     = 0x2E, //  동영상 파일 FTP 다운로드 완료         Opcode = 46 [0x2E]
        sCmd = "txt_ftp_download_completed";
        break;

    case e_txt_response://                   = 0x48, //  제어기 응답(ACK/NAK)
        sCmd = "txt_response";
        break;

    case e_vms_form_display://          = 0x80,//    폼 데이터 표출                          송신    표출할 폼 데이터 송신                       센터 → VMS
        sCmd = "vms_form_display";
        break;
    case e_vms_file_download://         = 0x82,//    데이터 다운로드                         송신    INI, CFG , Bitmap , Data파일송신            센터 → VMS
        sCmd = "vms_file_download";
        break;
    case e_vms_data_upload://           = 0x84,//    데이터 업로드                           송신    INI, CFG , Bitmap , Data파일 업로드 요구    센터 → VMS
        sCmd = "vms_data_upload";
        break;
    case e_vms_status_control://        = 0x86,//    VMS 상태제어                            송신    VMS 제어정보 송신                           센터 → VMS
        sCmd = "vms_status_control";
        break;
    case e_vms_status://                = 0x88,//    VMS Status 요구                         송신    VMS 상태정보 요구 송신                      센터 → VMS
        sCmd = "vms_status";
        break;
    case e_vms_parameter://             = 0x8A,//    VMS 파라미터 요구                       송신    VMS 로컬 상태 요구 송신                     센터 → VMS
        sCmd = "vms_parameter";
        break;
    case e_vms_power_module_status://   = 0x8C,//    전원 모듈 상태 요구                     송신    전원 모듈 상태를 검사 결과를 요청한다       센터 → VMS
        sCmd = "vms_power_module_status";
        break;
    case e_vms_display_module_status:// = 0x8E,//    표출 모듈 상태 요구                     송신    표출 모듈 상태를 검사 결과를 요청한다       센터 → VMS
        sCmd = "vms_display_module_status";
        break;
    case e_vms_pixel_image://           = 0x92,//    VMS Pixel Image 요구                    송신    VMS LED Pixel 상태요구 송신                 센터 → VMS
        sCmd = "vms_pixel_image";
        break;
    case e_vms_current_display_form://  = 0x94,//    현재표출폼 Upload                       송신    Local에서 표출 중인 폼  Upload요구          센터 → VMS
        sCmd = "vms_current_display_form";
        break;
    case e_vms_download_schedule_form:// = 0x96,//    Display Schedule Form                   송신    계획된 Form 표출 요구                       센터 → VMS
        sCmd = "vms_download_schedule_form";
        break;
    case e_vms_display_default_form://  = 0x98,//    Display Default Form                    송신    디폴트 From표출 요구                        센터 → VMS
        sCmd = "vms_display_default_form";
        break;
    case e_vms_download_form://         = 0x9A,//    Download Form                           송신    Form download                               센터 → VMS
        sCmd = "vms_download_form";
        break;
    case e_vms_upload_schedule_form://  = 0x9C,//    Upload Schedule Form                    송신    스케줄 메시지 업로드 요구                   센터 → VMS
        sCmd = "vms_upload_schedule_form";
        break;
    case e_vms_blank://                 = 0x9E,//    Blank                                   송신    schedule 표출                               센터 → VMS
        sCmd = "vms_blank";
        break;
    case e_vms_display_form_id://       = 0xA0,//    Display Form ID                         송신    Form ID에 해당하는 Form 표출                센터 → VMS
        sCmd = "vms_display_form_id";
        break;
    case e_vms_video_ftp_download_req://    = 0xA1, //    동영상 파일 FTP 다운로드 요청                                                               센터 → VMS
        sCmd = "e_vms_video_ftp_download_req";
        break;
    case e_vms_video_ftp_download_completed://    = 0xA2, //    동영상 파일 FTP 다운로드 완료                                                               센터 ← VMS
        sCmd = "e_vms_video_ftp_download_completed";
        break;
    default:
        sCmd.printf("UNKNOWN Packet: %02X", AOpCode);
        return false;
    }

    if (ASend)
    {
        if (AResult == 0) {
            if (pCDSCtlr->IsDle)
                LINFO("SEND: %s, %d Bytes, [DLE Stuffing]", sCmd.c_str(), ALen);
            else
                LINFO("SEND: %s, %d Bytes.", sCmd.c_str(), ALen);
        }
        else {
            if (pCDSCtlr->IsDle)
                LERROR("SEND FAIL: %s, %d Bytes, [DLE Stuffing]", sCmd.c_str(), ALen);
            else
                LERROR("SEND FAIL: %s, %d Bytes.", sCmd.c_str(), ALen);
        }
    }
    else
    {
        if (pCDSCtlr->IsDle)
            LINFO("RECV: %s, %d Bytes, [DLE Stuffing]", sCmd.c_str(), ALen);
        else
            LINFO("RECV: %s, %d Bytes.", sCmd.c_str(), ALen);
    }
    return true;
}
//---------------------------------------------------------------------------

void TClientSession::DisplayResponseError(BYTE *AData)
{
    BYTE *pData = &AData[sizeof(VMS_RES_HEAD)];
    if (pData[0] != VMS_NAK)
    {
        return;
    }

    AnsiString sErr = "";
    switch(pData[1])
    {
    case 0x30: sErr = "Data Length가 2,047 Byte 보다 크면 보고되는 오류";                   break;
    case 0x31: sErr = "Data Length 이후의 데이터가 Data Length + 5Byte가 되지 않는 오류";   break;
    case 0x32: sErr = "데이터 크기 불일치";                                                 break;
    case 0x33: sErr = "작업이전 작업 진행중 작업요구";                                      break;
    case 0x34: sErr = "파라미터 범위 초과";                                                 break;
    case 0x35: sErr = "저장되지 않은 폼데이터 요구";                                        break;
    case 0x36: sErr = "업무처리 해당사항 없음";                                             break;
    case 0x37: sErr = "STN Address 틀림";                                                   break;
    default  : sErr.printf("NAK, Unknown Result Code 0x%02X", (int)pData[1]);               break;
    }
    LERROR(sErr.c_str());
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_txt_response)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
#if 0
	if (nLength < 1)    // ACK or NAK
	{
        TERROR("%s.%d, e_txt_response Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_txt_response Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
#endif
    TDEBUG("e_txt_response Length: %d", nLength);

    TDownloadForm *pInfo = NULL;
    VMS_RES_HEAD *pRes = (VMS_RES_HEAD*)AData;
    TCDSCtlr *AObj = ASession->CDSCtlr;
    if (AObj)
    {
        if (pRes->Ctlr != (BYTE)AObj->CTLR_LOCAL_NO)
        {
            TERROR("%s.%d, e_txt_response Controller No Error: %d, %d.", ASession->IpAddress.c_str(), ASession->Socket, AObj->CTLR_LOCAL_NO, (int)pRes->Ctlr);
            MERROR("%s.%d, e_txt_response Controller No Error: %d, %d.", ASession->IpAddress.c_str(), ASession->Socket, AObj->CTLR_LOCAL_NO, (int)pRes->Ctlr);
            return -3;
        }

        if (AObj->FTxtOpCode == e_txt_download_full_graphic_lib)
        {
            //라이브러리폼을 계속 다운로드
            TCDSCtlr *AObj = ASession->CDSCtlr;
            if (AObj)
            {
                pInfo = AObj->FDownloadLists.Find(AObj->DownloadFormId);
                if (pInfo)
                {
                    pInfo->AlreadyDownload = true;
                    pInfo->DownloadTm      = Now();
                }
            }
            ASession->download_lib_form_0x0A();
        }
        else
        if (AObj->FTxtOpCode == e_txt_display_schedule_msg)
        {
            //스케쥴다운로드가 완료됐으므로 blank 명령 전송
            ASession->download_blank_0x16();
        }
        else
        if (AObj->FTxtOpCode == e_txt_blank)
        {
            //Blank 명령 전송 완료 수신하면 OpCode 초기화
            AObj->FTxtOpCode == 0x00;

            // 폼 스케쥴 정보 다운로드 완료 메시지 처리
            ASession->download_form_schedule_complete();
        }

    }
    if (nLength == 1 && AData[sizeof(VMS_RES_HEAD)] == VMS_ACK)
    {
#if OK_DEBUG
        TINFO("e_txt_response : ACK...");
#endif
    }
    else
    if (nLength == 2 && AData[sizeof(VMS_RES_HEAD)] == VMS_NAK)
    {
        if (AObj && pInfo)
        {
            pInfo->AlreadyDownload = false;
        }
        VMS_RESULT *pRes = (VMS_RESULT*)&AData[sizeof(VMS_RES_HEAD)];
        TERROR("%s.%d, e_txt_response Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        MERROR("%s.%d, e_txt_response Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        ASession->DisplayResponseError(AData);
        return -2;

    }
#if OK_DEBUG
    else
    {
        TINFO("e_txt_response : OK...");
    }
#endif
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_txt_status_res)
{
    TCDSCtlr *AObj = ASession->CDSCtlr;
    if (!AObj)
    {
        TERROR("%s.%d, e_txt_status_res Controller NULL. will be closed.", ASession->IpAddress.c_str(), ASession->Socket);
        MERROR("%s.%d, e_txt_status_res Controller NULL. will be closed.", ASession->IpAddress.c_str(), ASession->Socket);
        return -5;
    }
    if (ASession->State == eSS_LoginReq)
    {
        VMS_RES_HEAD *pRes = (VMS_RES_HEAD*)AData;

        if (pRes->Ctlr != (BYTE)AObj->CTLR_LOCAL_NO)
        {
            TERROR("%s.%d, e_txt_status_res Controller No Error: %d, %d.", ASession->IpAddress.c_str(), ASession->Socket, AObj->CTLR_LOCAL_NO, (int)pRes->Ctlr);
            MERROR("%s.%d, e_txt_status_res Controller No Error: %d, %d.", ASession->IpAddress.c_str(), ASession->Socket, AObj->CTLR_LOCAL_NO, (int)pRes->Ctlr);
            return -4;
        }
    }

    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
	if (nLength < 2)
	{
        TERROR("%s.%d, e_txt_status_res Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_txt_status_res Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
    TDEBUG("e_txt_status_res Length: %d", nLength);

    int nReqSize =  sizeof(VMS_TXT_STATUS);
	if (nLength != nReqSize)
	{
        TERROR("%s.%d, e_txt_status_res Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        MERROR("%s.%d, e_txt_status_res Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        if (nLength == 2)
        {
             ASession->DisplayResponseError(AData);
        }
		return -2;
	}

    VMS_TXT_STATUS *pStatus = (VMS_TXT_STATUS*)&AData[sizeof(VMS_RES_HEAD)];

    TDEBUG("VMS_TXT_STATUS: Door(%02X), Power(%02X), Fan(%02X), Heater(%02X), Reset(%02X), Temp(%02X,%d)",
            pStatus->DOOR,
            pStatus->POWER,
            pStatus->FAN,
            pStatus->HEATER,
            pStatus->RESET,
            pStatus->CBOX_TEMP,
            pStatus->CBOX_TEMP
            );

    INT_VMS_STATE *FStts = &AObj->RSTATE;

#if 0
    BYTE    DOOR;	    // Door Open/Close 상태	0x00 : Open, 0x01 : Close, 0x09 : Unknown
    BYTE    POWER;      // 전원의 ON/OFF 상태	0x00 : On, 0x01 : Off (Sign Board)
    BYTE    FAN;		// VMS Fan 동작상태		0x00 : On, 0x01 : Off, 0x09: Unknown
						// 함체 Fan 동작상태	0x00 : On, 0x10 : Off, 0x90: Unknown
    BYTE    HEATER;		// VMS Heater 동작상태	0x00 : On, 0x01 : Off, 0x09: Unknown
						// 함체 Heater 동작상태	x00 : On, 0x10 : Off, 0x90: Unknown
    WORD    FORM_NUM;	// 표출 폼 번호	0x00 : 통신 폼, 0x01 : 디폴트 폼
    BYTE    REBOOT_YN;	// 재실행 여부	0x00 : 정상, 0x01 : 재실행
    char    CBOX_TEMP;	// 함체온도	127 ~ -127 -128 : Unknown
    BYTE    BRIGHT[4];	// 화면의 밝기	최대를 100으로 했을 때의 백분율 값 및 기준휘도
                        // 0: 현재  휘도(00:주간,01:야간,02:자동)
                        // 1: 야간휘도설정값
                        // 2: 주간휘도설정값
                        // 3: 현재휘도값(이건 나의 추측)
    char    DP_TEMP;	// 표출부온도	127 ~ -127 -128 : Unknown
    BYTE    DP_HUM;		// 표출부습도	0~100%, 포항UTIS부터 추가함
#endif

    if      (pStatus->POWER == 0x00) FStts->ModulePowerStatus = vms_module_power_off;
    else if (pStatus->POWER == 0x01) FStts->ModulePowerStatus = vms_module_power_on;
    else                             FStts->ModulePowerStatus = vms_module_power_unknown;

    if      (pStatus->DOOR == 0x00) FStts->DoorStatus = vms_door_close;
    else if (pStatus->DOOR == 0x01) FStts->DoorStatus = vms_door_open;
    else                            FStts->DoorStatus = vms_door_unknown;

    if      (pStatus->FAN == 0x00) FStts->FanStatus = vms_fan_off;
    else if (pStatus->FAN == 0x01) FStts->FanStatus = vms_fan_on;
    else                           FStts->FanStatus = vms_fan_unknown;

    if      (pStatus->HEATER == 0x00) FStts->HeaterStatus = vms_heater_off;
    else if (pStatus->HEATER == 0x01) FStts->HeaterStatus = vms_heater_on;
    else                              FStts->HeaterStatus = vms_heater_unknown;

    FStts->PowerCtrlStatus = FStts->ModulePowerStatus;  // 문자식은 받아오는게 없으니까 모듈전원상태와 동일한것으로 하자

    FStts->BodyTemp        = (short)pStatus->CBOX_TEMP;                             /* 함체온도값(℃), 범위(-128~127) */
    //FStts->LuminanceStatus = (BYTE)pStatus->BRIGHT[3];                                 /* 화면의 밝기값 (최대 휘도값을 100으로 했을 때의 백분율 값), 범위(0~100) */
    FStts->Wcomm           = vms_comm_normal;// : vms_comm_error;   /* 무선통신상태, 0:정상 1:장애 */
    //AObj->BRGH_WEEK_STEP   = pStatus->BRIGHT[2];
    //AObj->BRGH_NGHT_STEP   = pStatus->BRIGHT[1];

    RequestJob(ASession, eVmsDisplayModuleStatusReq, NULL, 0);
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_txt_failed_elem_data_res)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
	if (nLength < (int)sizeof(VMS_TXT_MODL_STATUE))    // module count 2 byte
	{
        TERROR("%s.%d, e_txt_failed_elem_data_res Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_txt_failed_elem_data_res Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
    TDEBUG("e_txt_failed_elem_data_res Length: %d", nLength);

    VMS_TXT_MODL_STATUE *pData = (VMS_TXT_MODL_STATUE*)&AData[sizeof(VMS_RES_HEAD)];

    int idx = 0;
    int xCnt = 0;
    int yCnt = 0;
    TCDSCtlr *AObj = ASession->CDSCtlr;
    if (AObj)
    {
        INT_VMS_STATE *FStts = &AObj->RSTATE;

        yCnt = AObj->ROW_NUM;
        xCnt = AObj->COL_NUM;
        FStts->ModuleHorizontal = xCnt;                             /* 가로 모듈수 */
        FStts->ModuleVertical   = yCnt;                             /* 세로 모듈수 */

        idx = 0;
        for (int ii = 0; ii < yCnt && ii < MAX_TXT_MODL_ROWS; ii++)
        {
            for (int jj = 0; jj < xCnt && jj < MAX_TXT_MODL_COLS; jj++)
            {
                CComm_SetBitValue(FStts->ModuleStatus, idx, pData->Modl[ii][jj] == 0 ? 1 : 0);
                idx++;
            }
        }
    }

    TDEBUG("VMS_DISPLAY_MODULE : X(%d) Y(%d)", xCnt, yCnt);
    AnsiString sModSts = "";
    AnsiString sTmp;
    AnsiString MODL_STTS = "";
    idx = 0;
    for (int ii = 0; ii < yCnt && ii < MAX_TXT_MODL_ROWS; ii++)
    {
        sModSts = "";
        for (int jj = 0; jj < xCnt && jj < MAX_TXT_MODL_COLS; jj++)
        {
            sTmp.printf("%d", pData->Modl[ii][jj]);    //0x00 : Off, 0x01 : On, 0x02 : Unknown,
            sModSts += sTmp;
            idx++;
        }
        MODL_STTS += sModSts;
        TDEBUG("VMS_DISPLAY_MODULE: %02d, %s", ii+1, sModSts.c_str());
    }
    if (AObj) AObj->MODL_STTS = MODL_STTS;

    POST_MSG(MAINHANDLE, WM_TCP_THREAD, WM_CTLR_STATE_STTS, (int)ASession->CDSCtlr);    // 상태정보 업데이트

#if 0
    // 설정온도 요청하면 응답으로 모듈상태정보가 올라와서 사용할 수 없음.
    RequestJob(ASession, eVmsParamReq, NULL, 0);
#else
    if (ASession->State == eSS_LoginReq)
    {
        ASession->State = eSS_Connected;

        // 제어기가 최초 접속했을 때 마지막으로 시나리오를 전송한 시각과 다음 전송할 시각을 계산해서
        // 1분 이상 차이가 있을때에 시나리오를 전송하도록 한다.
        RequestJob(ASession, eVmsScenarioDownload, NULL, 0);
    }
#endif
    return 0;
}
//---------------------------------------------------------------------------

#if 0
//TODO: 이거 사용하면 OpCode가 중복이 되어 모듈상태정보 처리를 하지 못한다.
/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_txt_pan_hetr_temp_res)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
	if (nLength < (int)sizeof(VMS_TXT_PARAMETER))    // module count 2 byte
	{
        TERROR("%s.%d, e_txt_pan_hetr_temp_res Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_txt_pan_hetr_temp_res Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
    TDEBUG("e_txt_pan_hetr_temp_res Length: %d", nLength);

    VMS_TXT_PARAMETER *pParam = (VMS_TXT_PARAMETER*)&AData[sizeof(VMS_RES_HEAD)];

    int nReqSize =  sizeof(VMS_TXT_PARAMETER);
	if (nLength != nReqSize)    // module count 2 byte
	{
        TERROR("%s.%d, e_txt_pan_hetr_temp_res Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        MERROR("%s.%d, e_txt_pan_hetr_temp_res Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        if (nLength == 2)
        {
             ASession->DisplayResponseError(AData);
        }
		return -2;
	}

    TCDSCtlr *AObj = ASession->CDSCtlr;
    if (AObj)
    {
        AObj->FAN_RUN_TMPR   = pParam->FanRunTemp;      // Fan의 동작개시온도           1 Byte  온도( 0x00 ~0x03f )
        AObj->HETR_RUN_TMPR  = pParam->HeaterRunTemp;   // Heater 의 동작개시온도       1 Byte  온도(0x00 ~ 0x3f )

        TDEBUG("VMS_TXT_PARAMETER: ");
        TDEBUG("                 FAN_RUN_TMPR: %d",   AObj->FAN_RUN_TMPR);
        TDEBUG("                HETR_RUN_TMPR: %02X", AObj->HETR_RUN_TMPR);

        CTLR_STTS stts;
        stts.Type = 2;
        stts.ObjPtr = (void*)AObj;

        INT_VMS_STATE  *FStts = &ASession->CDSCtlr->RSTATE;

        if (AObj->MODULE.IsOnOff)
        {
            if (AObj->MODULE.OnOff != AObj->PANL_PWER_MODE)
            {
                IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
                pMsg->Type    = eVmsStatusControl;
                pMsg->ObjPtr  = (DWORD)ASession;
                pMsg->Buff[0] = 0x01;
                pMsg->Buff[1] = ASession->CDSCtlr->MODULE.OnOff;// == vms_module_power_off ? 0x00 : 0x01;
                pMsg->Len     = 2;
                g_jobQ.PushBlocking((DWORD)pMsg);
            }
            else
            {
                AObj->MODULE.IsOnOff = false;
            }
        }
        //1분마다 주기적으로 상태정보를 업데이트 하니까 실시간으로 업데이트 할 필요가 없다.
        //운영단말로 실시간으로 데이터만 보내도록 하자
        APP_PostDbThreadMessage(dbm_parma_res, sizeof(stts), &stts);                        // 파라미터 저장
        POST_MSG(MAINHANDLE, WM_TCP_THREAD, WM_CTLR_STATE_STTS, (int)ASession->CDSCtlr);    // 상태정보 업데이트
    }

    if (ASession->State == eSS_LoginReq)
    {
        ASession->State = eSS_Connected;

        // 제어기가 최초 접속했을 때 마지막으로 시나리오를 전송한 시각과 다음 전송할 시각을 계산해서
        // 1분 이상 차이가 있을때에 시나리오를 전송하도록 한다.
        RequestJob(ASession, eVmsScenarioDownload, NULL, 0);
    }
    return 0;
}
//---------------------------------------------------------------------------
#endif

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_status)
{
    TCDSCtlr *AObj = ASession->CDSCtlr;
    if (!AObj)
    {
        TERROR("%s.%d, e_vms_status Controller NULL. will be closed.", ASession->IpAddress.c_str(), ASession->Socket);
        MERROR("%s.%d, e_vms_status Controller NULL. will be closed.", ASession->IpAddress.c_str(), ASession->Socket);
        return -5;
    }
    if (ASession->State == eSS_LoginReq)
    {
        VMS_RES_HEAD *pRes = (VMS_RES_HEAD*)AData;

        if (pRes->Ctlr != (BYTE)AObj->CTLR_LOCAL_NO)
        {
            TERROR("%s.%d, e_vms_status Controller No Error: %d, %d.", ASession->IpAddress.c_str(), ASession->Socket, AObj->CTLR_LOCAL_NO, (int)pRes->Ctlr);
            MERROR("%s.%d, e_vms_status Controller No Error: %d, %d.", ASession->IpAddress.c_str(), ASession->Socket, AObj->CTLR_LOCAL_NO, (int)pRes->Ctlr);
            return -4;
        }
    }

    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
	if (nLength < 2)
	{
        TERROR("%s.%d, e_vms_status Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_status Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
    TDEBUG("e_vms_status Length: %d", nLength);

    int nReqSize =  sizeof(VMS_STATUS);
	if (nLength != nReqSize)
	{
        TERROR("%s.%d, e_vms_status Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        MERROR("%s.%d, e_vms_status Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        if (nLength == 2)
        {
             ASession->DisplayResponseError(AData);
        }
		return -2;
	}

    VMS_STATUS *pStatus = (VMS_STATUS*)&AData[sizeof(VMS_RES_HEAD)];

    pStatus->FORM_NO = htons(pStatus->FORM_NO);
    //pStatus->BRIGHT  = htonl(pStatus->BRIGHT);

    TDEBUG("VMS_STATUS: Door(%02X), Power(%02X), Fan(%02X), Heater(%02X), FormNo(%d), Reboot(%02X), Temp(%02X,%d), Bright(%02X,%02X,%02X,%02X), ExtTemp(%02X,%d), ExtHum(%02X,%d)",
            pStatus->DOOR,
            pStatus->POWER,
            pStatus->FAN,
            pStatus->HEATER,
            pStatus->FORM_NO,
            pStatus->REBOOT_YN,
            pStatus->CBOX_TEMP,
            pStatus->CBOX_TEMP,
            pStatus->BRIGHT[0],
            pStatus->BRIGHT[1],
            pStatus->BRIGHT[2],
            pStatus->BRIGHT[3],
            pStatus->DP_TEMP,
            pStatus->DP_TEMP,
            pStatus->DP_HUM,
            pStatus->DP_HUM
            );

    INT_VMS_STATE *FStts = &AObj->RSTATE;

#if 0
    BYTE    DOOR;	    // Door Open/Close 상태	0x00 : Open, 0x01 : Close, 0x09 : Unknown
    BYTE    POWER;      // 전원의 ON/OFF 상태	0x00 : On, 0x01 : Off (Sign Board)
    BYTE    FAN;		// VMS Fan 동작상태		0x00 : On, 0x01 : Off, 0x09: Unknown
						// 함체 Fan 동작상태	0x00 : On, 0x10 : Off, 0x90: Unknown
    BYTE    HEATER;		// VMS Heater 동작상태	0x00 : On, 0x01 : Off, 0x09: Unknown
						// 함체 Heater 동작상태	x00 : On, 0x10 : Off, 0x90: Unknown
    WORD    FORM_NUM;	// 표출 폼 번호	0x00 : 통신 폼, 0x01 : 디폴트 폼
    BYTE    REBOOT_YN;	// 재실행 여부	0x00 : 정상, 0x01 : 재실행
    char    CBOX_TEMP;	// 함체온도	127 ~ -127 -128 : Unknown
    BYTE    BRIGHT[4];	// 화면의 밝기	최대를 100으로 했을 때의 백분율 값 및 기준휘도
                        // 0: 현재  휘도(00:주간,01:야간,02:자동)
                        // 1: 야간휘도설정값
                        // 2: 주간휘도설정값
                        // 3: 현재휘도값(이건 나의 추측)
    char    DP_TEMP;	// 표출부온도	127 ~ -127 -128 : Unknown
    BYTE    DP_HUM;		// 표출부습도	0~100%, 포항UTIS부터 추가함
#endif

    if      (pStatus->POWER == 0x01) FStts->ModulePowerStatus = vms_module_power_off;
    else if (pStatus->POWER == 0x00) FStts->ModulePowerStatus = vms_module_power_on;
    else                             FStts->ModulePowerStatus = vms_module_power_unknown;

    if      (pStatus->DOOR == 0x01) FStts->DoorStatus = vms_door_close;
    else if (pStatus->DOOR == 0x00) FStts->DoorStatus = vms_door_open;
    else                            FStts->DoorStatus = vms_door_unknown;

    // 2021.03.25 신규 추가 VMS
    // 랩에서 테스트시 장비가 연결되어 있지 않아서 9로 올라옴. ==> 현장에서는 정상적으로 올라올거라함.

    int S1, S2;

    // 둘다 꺼져 있으면 OFF, 하나라도 켜져 있으면 ON
    S1 = (pStatus->FAN & 0x0F);
    S2 = (pStatus->FAN & 0xF0) >> 4;
    if (S1 != 0 && S1 != 1) S1 = 1;
    if (S2 != 0 && S2 != 1) S2 = 1;
    if (S1 == 1 && S2 == 1)
        pStatus->FAN = 0x01;
    else
        pStatus->FAN = 0x00;

    //VMS : 0x00 : On, 0x01 : Off, 0x09: Unknown
    //함체: 0x00 : On, 0x10 : Off, 0x90: Unknown
    if      (pStatus->FAN == 0x00) FStts->FanStatus = vms_fan_on;
    else if (pStatus->FAN == 0x01) FStts->FanStatus = vms_fan_off;
    else if (pStatus->FAN == 0x10) FStts->FanStatus = vms_fan_off;
    else if (pStatus->FAN == 0x11) FStts->FanStatus = vms_fan_off;           // ??? 실제 현장 상황에 맞게
    else                           FStts->FanStatus = vms_fan_unknown;

    // 둘다 꺼져 있으면 OFF, 하나라도 켜져 있으면 ON
    S1 = (pStatus->HEATER & 0x0F);
    S2 = (pStatus->HEATER & 0xF0) >> 4;
    if (S1 != 0 && S1 != 1) S1 = 1;
    if (S2 != 0 && S2 != 1) S2 = 1;
    if (S1 == 1 && S2 == 1)
        pStatus->HEATER = 0x01;
    else
        pStatus->HEATER = 0x00;
    //VMS : 0x00 : On, 0x01 : Off, 0x09: Unknown
    //함체: 0x00 : On, 0x10 : Off, 0x90: Unknown
    if      (pStatus->HEATER == 0x00) FStts->HeaterStatus = vms_heater_on;
    else if (pStatus->HEATER == 0x01) FStts->HeaterStatus = vms_heater_off;
    else if (pStatus->HEATER == 0x10) FStts->HeaterStatus = vms_heater_off;
    else if (pStatus->HEATER == 0x11) FStts->HeaterStatus = vms_heater_off;     // // ??? 실제 현장 상황에 맞게
    else                              FStts->HeaterStatus = vms_heater_unknown;

    FStts->BodyTemp        = (short)pStatus->CBOX_TEMP;                             /* 함체온도값(℃), 범위(-128~127) */
    FStts->LuminanceStatus = (BYTE)pStatus->BRIGHT[3];                                 /* 화면의 밝기값 (최대 휘도값을 100으로 했을 때의 백분율 값), 범위(0~100) */
    FStts->Wcomm           = vms_comm_normal;// : vms_comm_error;   /* 무선통신상태, 0:정상 1:장애 */
    AObj->BRGH_WEEK_STEP   = pStatus->BRIGHT[2];
    AObj->BRGH_NGHT_STEP   = pStatus->BRIGHT[1];

    RequestJob(ASession, eVmsPowerModuleStautsReq, NULL, 0);
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_power_module_status)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
	if (nLength < 1)    // module count 1 byte
	{
        TERROR("%s.%d, e_vms_power_module_status Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_power_module_status Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
    TDEBUG("e_vms_power_module_status Length: %d", nLength);

    BYTE *pData = &AData[sizeof(VMS_RES_HEAD)];
    int nModCnt = pData[0];
    // pData[1] ==> Reserved area

    int nReqSize =  (nModCnt+2);
	if (nLength != nReqSize)
	{
        TERROR("%s.%d, e_vms_power_module_status Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        MERROR("%s.%d, e_vms_power_module_status Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        if (nLength == 2)
        {
             ASession->DisplayResponseError(AData);
        }
		return -2;
	}

    TCDSCtlr *AObj = ASession->CDSCtlr;
    if (AObj)
    {
        INT_VMS_STATE *FStts = &ASession->CDSCtlr->RSTATE;
        FStts->PowerCount = nModCnt;
        for (int ii = 0; ii < nModCnt; ii++)
        {
            CComm_SetBitValue(FStts->PowerStatus, ii, pData[2+ii]);
        }
    }

    TDEBUG("VMS_POWER_MODULE COUNT: %d", nModCnt);
    AnsiString sModSts = "";
    AnsiString sTmp;
    AnsiString PWER_STTS = "";

    for (int ii = 0; ii < nModCnt; ii++)
    {
        sTmp.printf("%d", pData[2+ii]);    //0x00 : Off, 0x01 : On, 0x02 : Unknown,
        sModSts += sTmp;
    }
    PWER_STTS += sModSts;
    if (AObj) AObj->PWER_STTS = PWER_STTS;

    TDEBUG("VMS_POWER_MODULE STATUS: %s", sModSts.c_str());

    RequestJob(ASession, eVmsDisplayModuleStatusReq, NULL, 0);
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_display_module_status)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
	if (nLength < 2)    // module count 2 byte
	{
        TERROR("%s.%d, e_vms_display_module_status Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_display_module_status Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
    TDEBUG("e_vms_display_module_status Length: %d", nLength);

    BYTE *pData = (BYTE*)&AData[sizeof(VMS_RES_HEAD)];
    int xCnt = pData[0];    // 1 Byte(X축) VMS 모듈수 //가로
    int yCnt = pData[1];    // 1 Byte(Y축) VMS 모듈수 //세로
    // 예)VMS 모듈수 : 2단 5열일 경우 모듈개수 (5(x), 2(y))를 표지한다.

    int nReqSize =  (xCnt*yCnt+2);
	if (nLength < nReqSize)    // module count 2 byte
	{
        TERROR("%s.%d, e_vms_display_module_status Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        MERROR("%s.%d, e_vms_display_module_status Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        if (nLength == 2)
        {
             ASession->DisplayResponseError(AData);
        }
		return -2;
	}

    int idx = 0;
    TCDSCtlr *AObj = ASession->CDSCtlr;
    if (AObj)
    {
        INT_VMS_STATE *FStts = &AObj->RSTATE;
        FStts->ModuleHorizontal = xCnt;                             /* 가로 모듈수 */
        FStts->ModuleVertical   = yCnt;                             /* 세로 모듈수 */

        idx = 0;
        for (int ii = 0; ii < yCnt; ii++)
        {
            for (int jj = 0; jj < xCnt; jj++)
            {
                //CComm_SetBitValue(FStts->ModuleStatus, idx, pData[2+idx]);
                CComm_SetBitValue(FStts->ModuleStatus, idx, pData[2+idx] == 0 ? 1 : 0);
                idx++;
            }
        }
    }

    TDEBUG("VMS_DISPLAY_MODULE : X(%d) Y(%d)", xCnt, yCnt);
    AnsiString sModSts = "";
    AnsiString sTmp;
    AnsiString MODL_STTS = "";

    idx = 0;
    for (int ii = 0; ii < yCnt; ii++)
    {
        sModSts = "";
        for (int jj = 0; jj < xCnt; jj++)
        {
            sTmp.printf("%d", pData[2+idx]);    //0x00 : Off, 0x01 : On, 0x02 : Unknown,
            sModSts += sTmp;
            idx++;
        }
        MODL_STTS += sModSts;
        TDEBUG("VMS_DISPLAY_MODULE: %02d, %s", ii+1, sModSts.c_str());
    }
    if (AObj) AObj->MODL_STTS = MODL_STTS;

    //백분율 컬럼 없음(프로토콜 문서에는 있는데 제어기에서 올리지 않음)
    //TDEBUG("VMS_DISPLAY_MODULE: Error Rate: 0x%02X, 0x%02X", pData[2+(xCnt*yCnt)], pData[2+(xCnt*yCnt)+1];

    RequestJob(ASession, eVmsParamReq, NULL, 0);
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_parameter)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
	if (nLength < (int)sizeof(VMS_PARAMETER))    // module count 2 byte
	{
        TERROR("%s.%d, e_vms_parameter Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_parameter Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
    TDEBUG("e_vms_parameter Length: %d", nLength);

    VMS_PARAMETER *pParam = (VMS_PARAMETER*)&AData[sizeof(VMS_RES_HEAD)];

    int nReqSize =  sizeof(VMS_PARAMETER);
	if (nLength != nReqSize)    // module count 2 byte
	{
        TERROR("%s.%d, e_vms_parameter Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        MERROR("%s.%d, e_vms_parameter Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        if (nLength == 2)
        {
             ASession->DisplayResponseError(AData);
        }
		return -2;
	}

    TCDSCtlr *AObj = ASession->CDSCtlr;
    if (AObj)
    {
        AObj->PANL_PWER_MODE = pParam->PowerCtrlMode;   // 전원제어 모드                1 Byte  0x00 : 꺼짐, 0x01 : 켜짐,
        AObj->FAN_MODE       = pParam->FanRunMode;      // Fan 동작모드                 1 Byte  0x00 : 꺼짐, 0x01 : 켜짐, 0x02 : 자동, 0x09: Unknown
        AObj->FAN_RUN_TMPR   = pParam->FanRunTemp;      // Fan의 동작개시온도           1 Byte  온도( 0x00 ~0x03f )
        AObj->HETR_MODE      = pParam->HeaterRunMode;   // Heater의 동작모드            1 Byte  0x00 : 꺼짐, 0x01 : 켜짐, 0x02 : 자동, 0x09: Unknown
        AObj->HETR_RUN_TMPR  = pParam->HeaterRunTemp;   // Heater 의 동작개시온도       1 Byte  온도(0x00 ~ 0x3f )
        AObj->BRGH_MODE      = pParam->BrightMode;      // 밝기 모드                    2 Byte  0x0 : 수동, 0x1 : 자동, 비율 : 0-100
        AObj->BRGH_CURR_STEP = pParam->BrightRate;      // 밝기 모드                    2 Byte  0x0 : 수동, 0x1 : 자동, 비율 : 0-100
        //AObj->BRGH_WEEK_STEP = 0x00;                    // res.para.brghDay;     //	N	NUMBER(3)	Y	64		휘도 주간 단계(0~100)
        //AObj->BRGH_NGHT_STEP = 0x00;                    // res.para.brghNight;     //	N	NUMBER(3)	Y	48		휘도 야간 단계(0~100)
        AObj->ParamResTime.printf("%04d%02d%02d%02d%02d%02d",
                                  pParam->Year+2000,    // 년       1 Byte  0x00 ~ 0x32
                                  pParam->Mon,          // 월       1 Byte  0x01 ~ 0x0c
                                  pParam->Day,          // 일       1 Byte  0x01 ~ 0x1f
                                  pParam->Hour,         // 시       1 Byte  0x00 ~ 0x17
                                  pParam->Min,          // 분       1 Byte  0x00 ~ 0x3b
                                  pParam->Sec           // 초       1 Byte  0x00 ~ 0x3b
                                 );
#if 0
        pParam->BlinkTime;      // 깜빡이는 시간주기            1 Byte  문자 비트맵의 깜빡이는 시간주기 0x00 ~ 0x1e( 0.1 ~3.0 )
        pParam->ScnTurnTime;    // 디폴트 시나리오로 전환시간   2 Byte  디폴트 시나리오로 전환될 때까지 기다리는 시간, 단위 : 초
        pParam->Reserved;       // 기타                         1 Byte
#endif

        TDEBUG("VMS_PARAMETER: PANL_PWER_MODE: 0x%02X",     AObj->PANL_PWER_MODE);
        TDEBUG("                     FAN_MODE: 0x%02X",     AObj->FAN_MODE);
        TDEBUG("                 FAN_RUN_TMPR: 0x%02X, %d", AObj->FAN_RUN_TMPR);
        TDEBUG("                    HETR_MODE: 0x%02X",     AObj->HETR_MODE);
        TDEBUG("                HETR_RUN_TMPR: 0x%02X",     AObj->HETR_RUN_TMPR);
        TDEBUG("                    BRGH_MODE: 0x%02X",     AObj->BRGH_MODE);
        TDEBUG("               BRGH_CURR_STEP: 0x%02X, %d", AObj->BRGH_CURR_STEP, AObj->BRGH_CURR_STEP);
        TDEBUG("                   LOCAL_TIME: %s",         AObj->ParamResTime.c_str());

        CTLR_STTS stts;
        stts.Type = 2;
        stts.ObjPtr = (void*)AObj;

        // AObj->PANL_PWER_MODE 여기 정보가 모듈전원이 On/Off 된 것을 저장하고 있다.
        INT_VMS_STATE  *FStts = &ASession->CDSCtlr->RSTATE;
        //FStts->PowerCtrlStatus = pParam->PowerCtrlMode; // 전원제어 모드                1 Byte  0x00 : 꺼짐, 0x01 : 켜짐,
        if      (pParam->PowerCtrlMode == 0x00) FStts->PowerCtrlStatus = vms_module_power_off;
        else if (pParam->PowerCtrlMode == 0x01) FStts->PowerCtrlStatus = vms_module_power_on;
        else                                    FStts->PowerCtrlStatus = vms_module_power_unknown;

        memcpy(FStts->ControllerCurrentTime, AObj->ParamResTime.c_str(), INT_VMS_MAX_DATETIME);

        if (AObj->MODULE.IsOnOff)
        {
            if (AObj->MODULE.OnOff != AObj->PANL_PWER_MODE)
            {
                IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
                pMsg->Type    = eVmsStatusControl;
                pMsg->ObjPtr  = (DWORD)ASession;
                pMsg->Buff[0] = 0x01;
                pMsg->Buff[1] = ASession->CDSCtlr->MODULE.OnOff;// == vms_module_power_off ? 0x00 : 0x01;
                pMsg->Len     = 2;
                g_jobQ.PushBlocking((DWORD)pMsg);
            }
            else
            {
                AObj->MODULE.IsOnOff = false;
            }
        }
        //1분마다 주기적으로 상태정보를 업데이트 하니까 실시간으로 업데이트 할 필요가 없다.
        //운영단말로 실시간으로 데이터만 보내도록 하자
        APP_PostDbThreadMessage(dbm_parma_res, sizeof(stts), &stts);                        // 파라미터 저장
        POST_MSG(MAINHANDLE, WM_TCP_THREAD, WM_CTLR_STATE_STTS, (int)ASession->CDSCtlr);    // 상태정보 업데이트
    }

    // TODO: 동영상 VMS 인 경우 동영상 파일을 다운로드 하도록 명령을 전송한다.
    if (AObj->IsVideo && AObj->RemainFtpFile()) {
        TINFO("ftp-file-download request to jobQ-1.");
        RequestJob(ASession, eVmsFtpFileDownload, NULL, 0);
    }


    if (ASession->State == eSS_LoginReq)
    {
        ASession->State = eSS_Connected;

        // 제어기가 최초 접속했을 때 마지막으로 시나리오를 전송한 시각과 다음 전송할 시각을 계산해서
        // 1분 이상 차이가 있을때에 시나리오를 전송하도록 한다.
        RequestJob(ASession, eVmsScenarioDownload, NULL, 0);
    }
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_pixel_image)
{
    // 요거는 제어기에서 응답을 하지 않음.
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
	if (nLength < (int)sizeof(VMS_PARAMETER))    // module count 2 byte
	{
        TERROR("%s.%d, e_vms_parameter Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_parameter Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
    TDEBUG("e_vms_parameter Length: %d", nLength);

    VMS_PARAMETER *pParam = (VMS_PARAMETER*)&AData[sizeof(VMS_RES_HEAD)];

    int nReqSize =  sizeof(VMS_PARAMETER);
	if (nLength != nReqSize)    // module count 2 byte
	{
        TERROR("%s.%d, e_vms_parameter Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        MERROR("%s.%d, e_vms_parameter Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        if (nLength == 2)
        {
             ASession->DisplayResponseError(AData);
        }
		return -2;
	}
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_current_display_form)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
	if (nLength < (int)sizeof(VMS_PARAMETER))    // module count 2 byte
	{
        TERROR("%s.%d, e_vms_current_display_form Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_current_display_form Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
    TDEBUG("e_vms_current_display_form Length: %d", nLength);
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_display_default_form)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
#if 0
	if (nLength < 1)    // ACK or NAK
	{
        TERROR("%s.%d, e_vms_display_default_form Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_display_default_form Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
#endif
    TDEBUG("e_vms_display_default_form Length: %d", nLength);

    VMS_RESULT *pRes = (VMS_RESULT*)&AData[sizeof(VMS_RES_HEAD)];
    if (pRes->Result != VMS_ACK)
    {
        TERROR("%s.%d, e_vms_display_default_form Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        MERROR("%s.%d, e_vms_display_default_form Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        ASession->DisplayResponseError(AData);
        return -2;
    }
#if OK_DEBUG
    else
    {
        TINFO("e_vms_display_default_form : OK...");
    }
#endif
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_upload_schedule_form)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
#if 0
	if (nLength < 1)    // ACK or NAK
	{
        TERROR("%s.%d, e_vms_upload_schedule_form Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_upload_schedule_form Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
#endif
    TDEBUG("e_vms_upload_schedule_form Length: %d", nLength);

    VMS_SCHEDULE_FORM *pRes = (VMS_SCHEDULE_FORM*)&AData[sizeof(VMS_RES_HEAD)];

    int nReqSize =  sizeof(VMS_SCHEDULE_FORM);
	if (nLength < nReqSize)
	{
        TERROR("%s.%d, e_vms_upload_schedule_form Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        MERROR("%s.%d, e_vms_upload_schedule_form Data Size error(%d, %d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength, nReqSize);
        if (nLength == 2)
        {
             ASession->DisplayResponseError(AData);
        }
		return -2;
	}

    for (int ii = 0; ii < MAX_VMS_SCENARIO_FORM; ii++)
    {
        TDEBUG("e_vms_upload_schedule_form %02d: FormNo: %d, Display Second: %d", ii+1, ntohs(pRes->Form[ii].FormNo), pRes->Form[ii].DispSec);
    }
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_display_form_id)
{
    //프로토콜에는 있으나 제어기에서 반응을 하지 않음
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
#if 0
	if (nLength < 1)    // ACK or NAK
	{
        TERROR("%s.%d, e_vms_display_form_id Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_display_form_id Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
#endif
    TDEBUG("e_vms_display_form_id Length: %d", nLength);

    VMS_RESULT *pRes = (VMS_RESULT*)&AData[sizeof(VMS_RES_HEAD)];
    if (pRes->Result != VMS_ACK)
    {
        TERROR("%s.%d, e_vms_display_form_id Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        MERROR("%s.%d, e_vms_display_form_id Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        ASession->DisplayResponseError(AData);
        return -2;
    }
#if OK_DEBUG
    else
    {
        TINFO("e_vms_display_form_id : OK...");
    }
#endif
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_status_control)
{
    //프로토콜에는 있으나 제어기에서 반응을 하지 않음
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
#if 0
	if (nLength < 1)    // ACK or NAK
	{
        TERROR("%s.%d, e_vms_status_control Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_status_control Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
#endif
    TDEBUG("e_vms_status_control Length: %d", nLength);

    VMS_RESULT *pRes = (VMS_RESULT*)&AData[sizeof(VMS_RES_HEAD)];
    if (pRes->Result != VMS_ACK)
    {
        TERROR("%s.%d, e_vms_status_control Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        MERROR("%s.%d, e_vms_status_control Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        ASession->DisplayResponseError(AData);
        return -2;
    }
#if OK_DEBUG
    else
    {
        TINFO("e_vms_status_control : OK...");
    }
#endif

    RequestJob(ASession, eVmsStatusReq, NULL, 0);

    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_download_form)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
#if 0
	if (nLength < 1)    // ACK or NAK
	{
        TERROR("%s.%d, e_vms_download_form Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_download_form Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
#endif
    TDEBUG("e_vms_download_form Length: %d", nLength);

    VMS_RESULT *pRes = (VMS_RESULT*)&AData[sizeof(VMS_RES_HEAD)];
    if (pRes->Result != VMS_ACK)
    {
        TERROR("%s.%d, e_vms_download_form Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        MERROR("%s.%d, e_vms_download_form Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        ASession->DisplayResponseError(AData);
        return -2;
    }
#if OK_DEBUG
    else
    {
        TINFO("e_vms_download_form : OK...");
    }
#endif

    // 폼정보를 계속해서 다운로드 한다.
    // 스케쥴 모드가 기본모드인 경우에는 폼정보가 하나만 내려가기때문에
    // 폼파일을 다운로드 해야 하고
    // 일반모드(자동, 고정) 인경우에는 폼정보를 계속해서 다운로드 해야 한다.
    if (ASession->CDSCtlr->FormDownload.IsDefault)
    {
        ASession->download_file_0x82();
    }
    else
    {
        ASession->download_form_0x9A();
    }

    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_form_display)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
#if 0
	if (nLength < 1)    // ACK or NAK
	{
        TERROR("%s.%d, e_vms_form_display Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_form_display Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
#endif
    TDEBUG("e_vms_form_display Length: %d", nLength);

    VMS_RESULT *pRes = (VMS_RESULT*)&AData[sizeof(VMS_RES_HEAD)];
    if (pRes->Result != VMS_ACK)
    {
        TERROR("%s.%d, e_vms_form_display Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        MERROR("%s.%d, e_vms_form_display Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        ASession->DisplayResponseError(AData);
        return -2;
    }
#if OK_DEBUG
    else
    {
        TINFO("e_vms_form_display : OK...");
    }
#endif
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_download_schedule_form)
{
    //프로토콜에는 있으나 제어기에서 반응을 하지 않음
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
#if 0
	if (nLength < 1)    // ACK or NAK
	{
        TERROR("%s.%d, e_vms_download_schedule_form Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_download_schedule_form Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
#endif
    TDEBUG("e_vms_download_schedule_form Length: %d", nLength);

    VMS_RESULT *pRes = (VMS_RESULT*)&AData[sizeof(VMS_RES_HEAD)];
    if (pRes->Result != VMS_ACK)
    {
        TERROR("%s.%d, e_vms_download_schedule_form Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        MERROR("%s.%d, e_vms_download_schedule_form Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        ASession->DisplayResponseError(AData);
        return -2;
    }
#if OK_DEBUG
    else
    {
        TINFO("e_vms_download_schedule_form : OK...");
    }
#endif

    // 스케쥴 표출 마지막 데이터 전송
    ASession->download_blank_0x9E();

    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_file_download)
{
    //프로토콜에는 있으나 제어기에서 반응을 하지 않음
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
#if 0
	if (nLength < 1)    // ACK or NAK
	{
        TERROR("%s.%d, e_vms_file_download Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_file_download Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
#endif
    TDEBUG("e_vms_file_download Length: %d", nLength);

    TDownloadForm *pInfo = NULL;
    TCDSCtlr *AObj = ASession->CDSCtlr;
    if (AObj)
    {
        pInfo = AObj->FDownloadLists.Find(AObj->DownloadFormId);
    }

    VMS_RESULT *pRes = (VMS_RESULT*)&AData[sizeof(VMS_RES_HEAD)];
    if (pRes->Result != VMS_ACK)
    {
        if (pInfo)
        {
            pInfo->AlreadyDownload = false;
        }
        TERROR("%s.%d, e_vms_file_download Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        MERROR("%s.%d, e_vms_file_download Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        ASession->DisplayResponseError(AData);
        return -2;
    }
    else
    {
        if (pInfo)
        {
            pInfo->AlreadyDownload = true;
            pInfo->DownloadTm      = Now();
        }
#if OK_DEBUG
        TINFO("e_vms_file_download : OK...");
#endif
    }

    // 폼이미지를 계속해서 다운로드 한다.
    ASession->download_file_0x82();
    return 0;
}
//---------------------------------------------------------------------------

/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_blank)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
#if 0
	if (nLength < 1)    // ACK or NAK
	{
        TERROR("%s.%d, e_vms_blank Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_blank Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}
#endif
    TDEBUG("e_vms_blank Length: %d", nLength);

    VMS_RESULT *pRes = (VMS_RESULT*)&AData[sizeof(VMS_RES_HEAD)];
    if (pRes->Result != VMS_ACK)
    {
        TERROR("%s.%d, e_vms_blank Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        MERROR("%s.%d, e_vms_blank Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        ASession->DisplayResponseError(AData);
        return -2;
    }
#if OK_DEBUG
    else
    {
        TINFO("e_vms_blank : OK...");
    }
#endif

    if (ASession->CDSCtlr && ASession->CDSCtlr->FormDownload.IsDefault)
    {
        // 기본스케쥴인 경우에는 BLANK 명령을 내려보내지 말아야 한다.
        //ASession->ReqDisplayDefaultForm();
        //return download_form_schedule_complete();
    }

    // 폼 스케쥴 정보 다운로드 완료 메시지 처리
    ASession->download_form_schedule_complete();
    return 0;
}
//---------------------------------------------------------------------------


// TODO: 20241220 ==> FTP 다운로드 전송 메시지를 VMS에서 정상적으로 수신하였다는 메시지
/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_video_ftp_download_req)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
    TDEBUG("e_vms_video_ftp_download_req Length: %d", nLength);

    VMS_RESULT *pRes = (VMS_RESULT*)&AData[sizeof(VMS_RES_HEAD)];
    if (pRes->Result != VMS_ACK)
    {
        TERROR("%s.%d, e_vms_video_ftp_download_req Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        MERROR("%s.%d, e_vms_video_ftp_download_req Result Error. Error: 0x%02X.", ASession->IpAddress.c_str(), ASession->Socket, pRes->Error);
        ASession->DisplayResponseError(AData);
        return -2;
    }
#if OK_DEBUG
    else
    {
        TINFO("e_vms_video_ftp_download_req : OK...");
    }
#endif

    return 0;
}
//---------------------------------------------------------------------------

// TODO: 20241220 ==> FTP 다운로드 전송 메시지를 VMS에서 정상적으로 수신 후 FTP  까지 완료하였다는 메시지
/////////////////////////////////////////////////////////
REGISTER_HANDLER(e_vms_video_ftp_download_completed)
{
    int nLength = APktLen-sizeof(VMS_RES_HEAD)-sizeof(VMS_TAIL);
	if (nLength < (int)sizeof(VMS_FILE_FTP_DATA))
	{
        TERROR("%s.%d, e_vms_video_ftp_download_completed Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
        MERROR("%s.%d, e_vms_video_ftp_download_completed Data Length error(%d). will be closed.", ASession->IpAddress.c_str(), ASession->Socket, nLength);
		return -1;
	}

    VMS_FILE_FTP_DATA *pFtpFile = (VMS_FILE_FTP_DATA*)&AData[sizeof(VMS_RES_HEAD)];
    AnsiString sFtpFileName = AnsiString(pFtpFile->FILE_NM);

    TINFO("e_vms_video_ftp_download_completed: %s", sFtpFileName.c_str());


    TCDSCtlr *AObj = ASession->CDSCtlr;
    if (AObj)
    {
        TFtpFile *ftpFile = AObj->FFtpFileLists.Find(sFtpFileName);
        if (ftpFile != NULL) {
            ftpFile->IsFtpOk = true;
            ftpFile->UpdateTm = Now();
        }

        // TODO: 동영상 파일을 다운로드 하도록 명령을 전송한다.
        //if (AObj->RemainFtpFile())
        {
            //TINFO("ftp-file-download request to jobQ-2.");
            RequestJob(ASession, eVmsFtpFileDownload, NULL, 0);
        }
    }

    return 0;
}
//---------------------------------------------------------------------------


int TClientSession::ReqStauts()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    VMS_REQ_DATA req;

    req.OpCode = (AObj->PROTOCOL_VER == 1) ? e_txt_status_req : e_vms_status;
    req.Group  = AObj->GROUP_NO;
    req.Ctlr   = AObj->CTLR_LOCAL_NO;

    if (!SendPacket((char*)&req, sizeof(VMS_REQ_DATA)))
    {
        SERROR("+CLI ReqStauts send request faild: %s will be closed.", FIpAddress.c_str());
        MERROR("+CLI ReqStauts send request faild: %s will be closed.", FIpAddress.c_str());
        Disconnect();
        return -1;
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::ReqPowerModuleStatus()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    VMS_REQ_DATA req;

    req.OpCode = e_vms_power_module_status;
    req.Group  = AObj->GROUP_NO;
    req.Ctlr   = AObj->CTLR_LOCAL_NO;

    if (!SendPacket((char*)&req, sizeof(VMS_REQ_DATA)))
    {
        SERROR("+CLI ReqPowerModuleStatus send request faild: %s will be closed.", FIpAddress.c_str());
        MERROR("+CLI ReqPowerModuleStatus send request faild: %s will be closed.", FIpAddress.c_str());
        Disconnect();
        return -1;
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::ReqDisplayModuelStatus()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    VMS_REQ_DATA req;

    req.OpCode = (AObj->PROTOCOL_VER == 1) ? e_txt_failed_elem_data_req : e_vms_display_module_status;
    req.Group  = AObj->GROUP_NO;
    req.Ctlr   = AObj->CTLR_LOCAL_NO;

    if (!SendPacket((char*)&req, sizeof(VMS_REQ_DATA)))
    {
        SERROR("+CLI ReqDisplayModuelStatus send request faild: %s will be closed.", FIpAddress.c_str());
        MERROR("+CLI ReqDisplayModuelStatus send request faild: %s will be closed.", FIpAddress.c_str());
        Disconnect();
        return -1;
    }
    return 1;
}
//---------------------------------------------------------------------------


int TClientSession::ReqParameter()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    VMS_REQ_DATA req;

#if 0
    // 설정온도 요청하면 모듈상태정보가 응답으로 올라온다
    // 프로토콜의 OpCode도 동일하다.
    req.OpCode = (AObj->PROTOCOL_VER == 1) ? e_txt_pan_hetr_temp_req : e_vms_parameter;
#else
    req.OpCode = e_vms_parameter;
#endif
    req.Group  = AObj->GROUP_NO;
    req.Ctlr   = AObj->CTLR_LOCAL_NO;

    if (!SendPacket((char*)&req, sizeof(VMS_REQ_DATA)))
    {
        SERROR("+CLI ReqParameter send request faild: %s will be closed.", FIpAddress.c_str());
        MERROR("+CLI ReqParameter send request faild: %s will be closed.", FIpAddress.c_str());
        Disconnect();
        return -1;
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::ReqPixelImage(char *ACmd)
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    VMS_REQ_INFO_DATA req;

    req.OpCode = e_vms_pixel_image;
    req.Group  = AObj->GROUP_NO;
    req.Ctlr   = AObj->CTLR_LOCAL_NO;
    req.Data[0] = ACmd[0];
    req.Length  = 1;

    if (!SendPacket((char*)&req, sizeof(VMS_REQ_DATA)+1))
    {
        SERROR("+CLI ReqPixelImage send request faild: %s will be closed.", FIpAddress.c_str());
        MERROR("+CLI ReqPixelImage send request faild: %s will be closed.", FIpAddress.c_str());
        Disconnect();
        return -1;
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::ReqUploadCurrentForm()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    VMS_REQ_DATA req;

    req.OpCode = e_vms_current_display_form;
    req.Group  = AObj->GROUP_NO;
    req.Ctlr   = AObj->CTLR_LOCAL_NO;

    if (!SendPacket((char*)&req, sizeof(VMS_REQ_DATA)))
    {
        SERROR("+CLI ReqUploadCurrentForm send request faild: %s will be closed.", FIpAddress.c_str());
        MERROR("+CLI ReqUploadCurrentForm send request faild: %s will be closed.", FIpAddress.c_str());
        Disconnect();
        return -1;
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::ReqDisplayDefaultForm()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    VMS_REQ_DATA req;

    req.OpCode = e_vms_display_default_form;
    req.Group  = AObj->GROUP_NO;
    req.Ctlr   = AObj->CTLR_LOCAL_NO;

    if (!SendPacket((char*)&req, sizeof(VMS_REQ_DATA)))
    {
        SERROR("+CLI ReqDisplayDefaultForm send request faild: %s will be closed.", FIpAddress.c_str());
        MERROR("+CLI ReqDisplayDefaultForm send request faild: %s will be closed.", FIpAddress.c_str());
        Disconnect();
        return -1;
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::ReqUploadScheduleForm()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    VMS_REQ_DATA req;

    req.OpCode = e_vms_upload_schedule_form;
    req.Group  = AObj->GROUP_NO;
    req.Ctlr   = AObj->CTLR_LOCAL_NO;

    if (!SendPacket((char*)&req, sizeof(VMS_REQ_DATA)))
    {
        SERROR("+CLI ReqUploadScheduleForm send request faild: %s will be closed.", FIpAddress.c_str());
        MERROR("+CLI ReqUploadScheduleForm send request faild: %s will be closed.", FIpAddress.c_str());
        Disconnect();
        return -1;
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::ReqDisplayFormId(char *ACmd)
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    VMS_REQ_INFO_DATA req;

    req.OpCode = e_vms_display_form_id;
    req.Group  = AObj->GROUP_NO;
    req.Ctlr   = AObj->CTLR_LOCAL_NO;
    req.Data[0] = 0;//ACmd[0];
    req.Data[1] = 0;//ACmd[2];
    req.Length  = 2;

    if (!SendPacket((char*)&req, sizeof(VMS_REQ_DATA)+2))
    {
        SERROR("+CLI ReqDisplayFormId send request faild: %s will be closed.", FIpAddress.c_str());
        MERROR("+CLI ReqDisplayFormId send request faild: %s will be closed.", FIpAddress.c_str());
        Disconnect();
        return -1;
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::ReqStatusControl(char *ACmd, int ALen)
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    char *pSendData = NULL;
    int   nSendByte = 0;

    if (AObj->PROTOCOL_VER == 1)
    {
        VMS_REQ_INFO_DATA req;

        req.Group   = AObj->GROUP_NO;
        req.Ctlr    = AObj->CTLR_LOCAL_NO;

        if (ACmd[0] == 0x01)
        {
            //SignBoard On/Off
            req.OpCode  = e_txt_signboard_control;
            req.Length  = 1;
            req.Data[0] = ACmd[1];   //Power Off=0, Power On = 1

            pSendData = (char*)&req;
            nSendByte = sizeof(VMS_REQ_DATA)+req.Length;
        }
        else
        if (ACmd[0] == 0x02)
        {
            //Initialize(Reset)
            req.OpCode  = e_txt_initialize;
            req.Length  = 0;

            pSendData = (char*)&req;
            nSendByte = sizeof(VMS_REQ_DATA)+req.Length;
        }
        else
        if (ACmd[0] == 0x06)
        {
            //Set luminance Level
            req.OpCode  = e_txt_set_luminance_level;
            req.Length  = 1;
            req.Data[0] = ACmd[1];
            switch(ACmd[1]) //도형식과 비교해서 값이 다름
            {
            case 0x00:  //주간
                req.Data[0] = 1;
                break;
            case 0x01:  //야간
                req.Data[0] = 2;
                break;
            case 0x02:  //자동
                req.Data[0] = 0;
                break;
            }

            pSendData = (char*)&req;
            nSendByte = sizeof(VMS_REQ_DATA)+req.Length;
        }
    }
    else
    {
        VMS_REQ_INFO_DATA req;

        req.OpCode = e_vms_status_control;
        req.Group  = AObj->GROUP_NO;
        req.Ctlr   = AObj->CTLR_LOCAL_NO;
        memcpy(req.Data, ACmd, ALen);
        req.Length = ALen;

        pSendData = (char*)&req;
        nSendByte = sizeof(VMS_REQ_DATA)+ALen;
    }

    if (pSendData == NULL || nSendByte == 0)
    {
        return 1;
    }
    if (!SendPacket(pSendData, nSendByte))
    {
        SERROR("+CLI ReqStatusControl send request faild: %s will be closed.", FIpAddress.c_str());
        MERROR("+CLI ReqStatusControl send request faild: %s will be closed.", FIpAddress.c_str());
        Disconnect();
        return -1;
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::download_form_schedule_complete()
{
    // VMS 메시지 다운로드 완료
    TCDSCtlr *AObj = FCDSCtlr;
    if (AObj)
    {
        if (AObj->CTRLMODE->Schedule)
        {
            VMS_PROVIDE_RESULE ProvideSave;

            memset(&ProvideSave,  0x00, sizeof(ProvideSave));

            ProvideSave.Type    = provide_form;
            ProvideSave.Count   = 1;
            ProvideSave.pObj[0] = (void*)AObj;

            AObj->CTRLMODE->Enable   = object_disable;
            AObj->CTRLMODE->SvcDate  = Now().FormatString("yyyymmddhhnnss");
            AObj->CTRLMODE->SaveFlag = true;
            AObj->CTRLMODE->Result   = true;

            APP_PostDbThreadMessage(dbm_provide_result, sizeof(ProvideSave), &ProvideSave);
        }
    }
    return 0;
}
//---------------------------------------------------------------------------

int TClientSession::download_form_schedule(bool ASchedule/*=true*/)
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    if (ASchedule)
    {
        LDEBUG("Download Form Schedule by schedule...");
    }
    else
    {
        LDEBUG("Download Form Schedule by user control...");
    }

    AObj->CTRLMODE->Schedule = ASchedule;   // 스케쥴 모드인 경우 디비에 저장한다.

    //다운로드 정보만 초기화 한다.
    memset((char*)&AObj->FormDownload, 0x00, sizeof(VMS_DOWNLOAD_DATA));
    AObj->FTxtOpCode == 0x00;

    int nForms = 0;
    int nFormCnt = 0;

    AObj->pForms->Lock();
	try
	{
        nFormCnt = AObj->pForms->Count();
        if (nFormCnt == 0)
        {
            return 0;
        }

	    for (int ii = 0; ii < nFormCnt; ii++)
	    {
            TVmsForm *pForm = AObj->pForms->GetItem(ii);
            if (!pForm->Success)
            {
                continue;
            }
            // TODO: 20241220
            //if (pForm->fileType == P_FILE_TYPE_VIDEO  || pForm->fileType == P_FILE_TYPE_STREAM)
            if (pForm->fileType == P_FILE_TYPE_STREAM)
            {
                continue;
            }
            if (AObj->PROTOCOL_VER == 1 && pForm->fileType == P_FILE_TYPE_VIDEO)
            {
                // 문자식이면서 동영상 폼이면 표출하지 못함
                continue;
            }

            if (!pForm->pStream || pForm->pStream->Size == 0)
            {
                continue;
            }

            AObj->FormDownload.Info[nForms].fileType    = pForm->fileType;
            AObj->FormDownload.Info[nForms].STRM_ADDR   = pForm->STRM_ADDR;
            AObj->FormDownload.Info[nForms].VMS_FORM_ID = pForm->VMS_FORM_ID;
            AObj->FormDownload.Info[nForms].IsDownload  = true;
            AObj->FormDownload.Info[nForms].FormIdx     = ii;                       // 리스트상의 순서
            if (AObj->PROTOCOL_VER == 1)
            {
                //문자식 프로토콜 적용
                //AObj->FormDownload.Info[nForms].BitmapId = (pForm->VMS_FORM_ID.ToIntDef(0) % 1000) + TEXT_BASE_FORMID;  // 리스트상의 순서
                AObj->FormDownload.Info[nForms].BitmapId = nForms + TEXT_BASE_FORMID;  // 리스트상의 순서
                AObj->FormDownload.Info[nForms].FormNo   = AObj->FormDownload.Info[nForms].BitmapId;                    // 실재 다운로드되는 순서
            }
            else
            {
                //도형식 프로토콜 적용
                //AObj->FormDownload.Info[nForms].BitmapId = (pForm->VMS_FORM_ID.ToIntDef(0) % 1000) + 1000;              // 리스트상의 순서
                AObj->FormDownload.Info[nForms].BitmapId = nForms + 1000;              // 리스트상의 순서
                AObj->FormDownload.Info[nForms].FormNo   = PICTURE_BASE_FORMID+nForms;                                  // 실재 다운로드되는 순서
            }
            AObj->FormDownload.Info[nForms].DispSec = (BYTE)pForm->DSPL_HH;

            TDownloadForm *pInfo    = AObj->FDownloadLists.Find(pForm->VMS_FORM_ID);
            TCDSForm      *pCDSForm = CDSFormManager->FLists.Find(pForm->VMS_FORM_ID);
            if (pCDSForm)
            {
                if (pCDSForm->VMS_FORM_TYPE_CD == eFormTp_hongbo)
                {
                    if (AObj->PROTOCOL_VER == 1)
                    {
                        //문자식 프로토콜 적용
                        AObj->FormDownload.Info[nForms].BitmapId = (pForm->VMS_FORM_ID.ToIntDef(0) % 1000) + TEXT_BASE_FORMID;  // 리스트상의 순서
                        AObj->FormDownload.Info[nForms].FormNo   = AObj->FormDownload.Info[nForms].BitmapId;                    // 실재 다운로드되는 순서
                    }
                    else
                    {
                        //도형식 프로토콜 적용
                        AObj->FormDownload.Info[nForms].BitmapId = (pForm->VMS_FORM_ID.ToIntDef(0) % 1000) + 1000;              // 리스트상의 순서
                    }
                }

                //홍보폼이면서 신규폼이 아니면서 이전 다운로드 목록이 존재하는 경우에 다운로드 여부를 체크한다.
                if (pCDSForm->VMS_FORM_TYPE_CD == eFormTp_hongbo && pCDSForm->IsNewForm == false && pInfo)
                {
                    if (pInfo->AlreadyDownload)
                    {
                        // 이미 이전에 다운로드를 했기때문에 이번에는 제어기로 다운로드를 하지 않는다.
                        AObj->FormDownload.Info[nForms].IsDownload = false;
                    }
                }
                //이전에 다운로드한 정보가 존재하면
                if (pInfo)
                {
                    if (pInfo->UPDT_DT != pCDSForm->UPDT_DT)
                    {
                        // 업데이트시각이 다르기때문에 신규폼으로 판단한다.
                        pInfo->AlreadyDownload = false;
                        AObj->FormDownload.Info[nForms].IsDownload = true;
                        pInfo->UPDT_DT = pCDSForm->UPDT_DT;
                    }
                }
            }
            if (!pInfo && pCDSForm)
            {
                pInfo = AObj->FDownloadLists.Find(pForm->VMS_FORM_ID);
                if (!pInfo)
                {
                    pInfo = new TDownloadForm();
                    if (pInfo)
                    {
                        //신규로추가
                        pInfo->VMS_FORM_ID = pForm->VMS_FORM_ID;
                        AObj->FDownloadLists.Push(pInfo->VMS_FORM_ID, pInfo);
                    }
                }
                if (pInfo)
                {
                    //다운로드정보설정
                    pInfo->AlreadyDownload = false;
                    pInfo->UPDT_DT = pCDSForm->UPDT_DT;
                }
            }

            nForms++;
            if (nForms >= MAX_VMS_SCENARIO_FORM)
            {
                // 최대폼까지 다운로드
                break;
            }
        }
	}
	__finally
	{
        AObj->pForms->UnLock();
	}

    for (int jj = 0; jj < nFormCnt; jj++)
    {
        LDEBUG("Form schedule(%2d), VMS_FORM_ID: %s, FormIdx: %d, FormId: %d, BitmapId: %d, IsDownload: %s",
            jj,
            AObj->FormDownload.Info[jj].VMS_FORM_ID.c_str(),
            AObj->FormDownload.Info[jj].FormIdx,
            AObj->FormDownload.Info[jj].FormNo,
            AObj->FormDownload.Info[jj].BitmapId,
            AObj->FormDownload.Info[jj].IsDownload ? "true" : "false");
    }

    if (nForms <= 0)
    {
        return 0;
    }

    AObj->FormDownload.MaxSchedule = nForms;
    AObj->FormDownload.DownloadCnt = 0;

    if (AObj->PROTOCOL_VER == 1)
    {
        //문자식 프로토콜 적용
        AObj->FormDownload.IsDefault = false;
        download_lib_form_0x0A();
    }
    else
    {
        //도형식 프로토콜 적용
        if (AObj->OPER_MODE == "B")
        {
            // 기본모드인 경우
            //e_vms_download_form          = 0x9A,//    Download Form                           송신    Form download                               센터 → VMS
            //e_vms_file_download          = 0x82,//    데이터 다운로드                         송신    INI, CFG , Bitmap , Data파일송신            센터 → VMS
            //e_vms_download_schedule_form = 0x96,//    Display Schedule Form                   송신    계획된 Form 표출 요구                       센터 → VMS
            //e_vms_blank                  = 0x9E,//    Blank                                   송신    schedule 표출                               센터 → VMS
            AObj->FormDownload.IsDefault = true;
            download_default_form_0x9A();         // Download Form  (기본폼은 하나의 폼에 여러폼을 다운로드한다.)
        }
        else
        {
            // 스케쥴 모드인 경우(A:자동, F:고정)
            //e_vms_download_form          = 0x9A,//    Download Form                           송신    Form download                               센터 → VMS
            //e_vms_file_download          = 0x82,//    데이터 다운로드                         송신    INI, CFG , Bitmap , Data파일송신            센터 → VMS
            //e_vms_download_schedule_form = 0x96,//    Display Schedule Form                   송신    계획된 Form 표출 요구                       센터 → VMS
            //e_vms_blank                  = 0x9E,//    Blank                                   송신    schedule 표출                               센터 → VMS
            AObj->FormDownload.IsDefault = false;
            download_form_0x9A();         // Download Form  (기본폼은 하나의 폼에 여러폼을 다운로드한다.)
        }
    }
    return 1;
}
//---------------------------------------------------------------------------

// TODO: 20241220
int TClientSession::download_ftp_file()
{
    IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    //if (!AObj->RemainFtpFile()) return -2;

    TFtpFile *pFtpFile = NULL;
    FOR_STL(TFtpFile*, pInfo, AObj->FFtpFileLists)
    {
        if (!pInfo->IsFtpOk) {
            pFtpFile = pInfo;
            LINFO("download_ftp_file_0xA1: %s, try download.", pFtpFile->FtpFileName.c_str());
            break;
        }
        else {
            LINFO("download_ftp_file_0xA1: %s, already download.", pInfo->FtpFileName.c_str());
        }
    }
    if (pFtpFile == NULL) {
        LINFO("download_ftp_file_0xA1: ftp download completed.");
        return -3;
    }

    BYTE               *msgPtr;
    VMS_HEAD           *pHead;
    VMS_FILE_FTP_DATA  *pData;

    WORD crc;
    int  nPktSize;

    msgPtr = (BYTE*)pMsg->Buff;
    pHead  = (VMS_HEAD*)&msgPtr[0];
    pData  = (VMS_FILE_FTP_DATA*)&msgPtr[sizeof(VMS_HEAD)];
    memset((char*)pData, 0x00, sizeof(VMS_FILE_FTP_DATA));

    pHead->Dle    = VMS_DLE;
    pHead->Stx    = VMS_STX;
    pHead->Group  = AObj->GROUP_NO;
    pHead->Ctlr   = AObj->CTLR_LOCAL_NO;
    pHead->OpCode = e_vms_video_ftp_download_req;
    pHead->Curr   = 1;
    pHead->Total  = 1;
    pHead->Length = 0;

    sprintf(pData->FILE_NM, "%s", pFtpFile->FtpFileName.c_str());

    LINFO("download_ftp_file_0xA1: %s, %s", pFtpFile->FtpFileName.c_str(), pData->FILE_NM);

    pHead->Length = sizeof(VMS_FILE_FTP_DATA);

    nPktSize = sizeof(VMS_HEAD)+pHead->Length-2; //DLE/STX
    crc  = GETCRC16((char*)&pHead->Group, nPktSize);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+0] = VMS_DLE;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+1] = VMS_ETX;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+2] = HIBYTE(crc);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+3] = LOBYTE(crc);

    SendPacketDLE((char*)msgPtr, nPktSize+6, AObj->IsDle);
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::download_default_form_0x9A()
{
    IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    BYTE               *msgPtr;
    // 파일다운로드
    VMS_HEAD           *pHead;
    VMS_FILE_DATA      *pFile;

    // 폼다운로드
    VMS_FORM_HEAD       *pForm;
    VMS_FORM_BMPID_DATA *pBmpIdData;

    WORD crc;
    int  nPktSize;
    int  nPktIdx;

    nPktIdx = sizeof(VMS_HEAD)+sizeof(VMS_FORM_HEAD);
    msgPtr = (BYTE*)pMsg->Buff;
    pHead  = (VMS_HEAD*)&msgPtr[0];
    pForm  = (VMS_FORM_HEAD*)&msgPtr[sizeof(VMS_HEAD)];
    pBmpIdData  = (VMS_FORM_BMPID_DATA*)&msgPtr[nPktIdx];

    pHead->Dle    = VMS_DLE;
    pHead->Stx    = VMS_STX;
    pHead->Group  = AObj->GROUP_NO;
    pHead->Ctlr   = AObj->CTLR_LOCAL_NO;
    pHead->OpCode = e_vms_download_form;
    pHead->Curr   = 1;
    pHead->Total  = 1;
    pHead->Length = 0;

    int nFormId  = DEFAULT_FORMID;
    int nFormCnt = AObj->FormDownload.MaxSchedule;   // 폼정보는 하나만 내려보내야 한다. 제어기에서 수용하지 못함
    if (nFormCnt > MAX_VMS_SCENARIO_FORM) {
        nFormCnt = MAX_VMS_SCENARIO_FORM;
    }

    LDEBUG("download_default_form_0x9A: FormId: %d, FormCnt: %d", nFormId, nFormCnt);

    pForm->FORM_ID  = htons(nFormId);
    pForm->FORM_CNT = htons(nFormCnt);

    pHead->Length = sizeof(VMS_FORM_HEAD)+(sizeof(VMS_FORM_BMPID_INFO)*nFormCnt);

    for (int ii = 0; ii < nFormCnt; ii++)
    {
        pBmpIdData  = (VMS_FORM_BMPID_DATA*)&msgPtr[nPktIdx];
        memset(pBmpIdData, 0x00, sizeof(VMS_FORM_BMPID_DATA));

        pBmpIdData->INFO.data.FORM_SEQ     = htons(ii);                                  // 폼 표출 일련번호,        2Byte
        pBmpIdData->INFO.data.DISPLAY_TIME = 4;                                          // 폼의 표출시간을 지정,    1Byte( 0x00 이면 계속 표출 ) ==> 제어기에서 사용안함
        pBmpIdData->INFO.data.DISPLAY_TYPE = e_static_normal;                            // 폼의 표출유형을 지정,    1Byte
        pBmpIdData->INFO.data.BG_RGB       = e_bg_black;                                 // 폼의 배경색을 지정,      1Byte
        pBmpIdData->INFO.data.OBJ_CNT      = 1;                                          // 표출할 오브젝트 전체 수, 1Byte

        pBmpIdData->INFO.obj.OBJ_TYPE    = e_obj_bitmapid;                               // 오브젝트 종류
        pBmpIdData->INFO.obj.OBJ_SIZE    = htons(sizeof(VMS_OBJ_BITMAPID));              // 오브젝트 데이터 크기
        pBmpIdData->INFO.obj.FLASH       = 0x00;                                         // 점멸여부, 1Byte(0x00 : 고정, 0x01 : 점멸)
        pBmpIdData->INFO.obj.X           = htons(0);                                     // 좌표 X
        pBmpIdData->INFO.obj.Y           = htons(0);                                     // 좌표 Y
        pBmpIdData->INFO.obj.TEXT_BG_RGB = e_bg_black;                                   // 문자열 배경색을 지정

        pBmpIdData->INFO.bmpid.WIDTH     = htons(AObj->WIDTH);                             // 비트맵 표시 Width,  2 Byte, 0 ~ 1023 : 표출 비트맵 Width
        pBmpIdData->INFO.bmpid.HEIGHT    = htons(AObj->HEIGHT);                            // 비트맵 표시 Heitht, 2 Byte, 0 ~ 1023 : 표출 비트맵 Width
        pBmpIdData->INFO.bmpid.IMG_TYPE  = e_img_bitmap;                                   // e_img_type
        pBmpIdData->INFO.bmpid.BITMAP_ID = htons(AObj->FormDownload.Info[ii].BitmapId);    // 표출할 비트맵 ID,   2 Byte, 0～ 9999 : 표출할 비트맵 ID

        LDEBUG("download_default_form_0x9A: FormSeq: %d, FormId: %d", ii, AObj->FormDownload.Info[ii].BitmapId);
        nPktIdx += sizeof(VMS_FORM_BMPID_DATA);
    }

    nPktSize = sizeof(VMS_HEAD)+pHead->Length-2; //DLE/STX
    crc  = GETCRC16((char*)&pHead->Group, nPktSize);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+0] = VMS_DLE;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+1] = VMS_ETX;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+2] = HIBYTE(crc);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+3] = LOBYTE(crc);

    SendPacketDLE((char*)msgPtr, nPktSize+6, AObj->IsDle);
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::download_form_0x9A()
{
    IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    if (AObj->FormDownload.DownloadCnt && AObj->FormDownload.MaxSchedule &&
        AObj->FormDownload.DownloadCnt >= AObj->FormDownload.MaxSchedule)
    {
        // 폼정보를 모두 다운로드 했기때문에
        // 폼파일을 다운로드 해야 한다.
        AObj->FormDownload.DownloadCnt = 0; // 폼이미지파일을 다운로드해야 하기때문에 다운로드 인덱스를 다시 0으로 리셋
        download_file_0x82();
        return 1;
    }

    BYTE               *msgPtr;
    // 파일다운로드
    VMS_HEAD           *pHead;
    VMS_FILE_DATA      *pFile;

    // 폼다운로드
    VMS_FORM_HEAD       *pForm;
    VMS_FORM_BMPID_DATA *pBmpIdData;
    VMS_FORM_VIDEO_DATA *pVideoData;

    WORD crc;
    int  nPktSize;
    int  nPktIdx;

    nPktIdx = sizeof(VMS_HEAD)+sizeof(VMS_FORM_HEAD);
    msgPtr = (BYTE*)pMsg->Buff;
    pHead  = (VMS_HEAD*)&msgPtr[0];
    pForm  = (VMS_FORM_HEAD*)&msgPtr[sizeof(VMS_HEAD)];
    pBmpIdData  = (VMS_FORM_BMPID_DATA*)&msgPtr[nPktIdx];
    pVideoData  = (VMS_FORM_VIDEO_DATA*)&msgPtr[nPktIdx];

    pHead->Dle    = VMS_DLE;
    pHead->Stx    = VMS_STX;
    pHead->Group  = AObj->GROUP_NO;
    pHead->Ctlr   = AObj->CTLR_LOCAL_NO;
    pHead->OpCode = e_vms_download_form;
    pHead->Curr   = 1;
    pHead->Total  = 1;
    pHead->Length = 0;

    // 폼아이디는 제어기가 최초에 접속했을때 한번만 내려보내기 때문에
    // 폼아이디를 여기서 설정해 주어야 한다.
    BYTE fileType        = AObj->FormDownload.Info[AObj->FormDownload.DownloadCnt].fileType;
    AnsiString STRM_ADDR = AObj->FormDownload.Info[AObj->FormDownload.DownloadCnt].STRM_ADDR;

    int nFormId   = AObj->FormDownload.Info[AObj->FormDownload.DownloadCnt].FormNo;
    int nBitmapId = AObj->FormDownload.Info[AObj->FormDownload.DownloadCnt].BitmapId;
    int nFormCnt  = 1;   // 폼정보는 하나만 내려보내야 한다. 제어기에서 수용하지 못함

    pForm->FORM_ID  = htons(nFormId);
    pForm->FORM_CNT = htons(nFormCnt);

    // TODO: 20241220
    if (fileType == P_FILE_TYPE_VIDEO) {
        // 동영상 표출
        //LDEBUG("download_form_0x9A: DownloadCnt: %d, FormId: %d, VideoId: %s", AObj->FormDownload.DownloadCnt, nFormId, STRM_ADDR.c_str());
        pHead->Length = sizeof(VMS_FORM_HEAD)+(sizeof(VMS_FORM_VIDEO_INFO)*nFormCnt);
    }
    else {
        //LDEBUG("download_form_0x9A: DownloadCnt: %d, FormId: %d, BitmapId: %d", AObj->FormDownload.DownloadCnt, nFormId, nBitmapId);
        pHead->Length = sizeof(VMS_FORM_HEAD)+(sizeof(VMS_FORM_BMPID_INFO)*nFormCnt);
    }


    //for (int ii = 0; ii < nFormCnt; ii++) {
        if (fileType == P_FILE_TYPE_VIDEO) {
            // 동영상 표출
            pVideoData  = (VMS_FORM_VIDEO_DATA*)&msgPtr[nPktIdx];
            memset(pVideoData, 0x00, sizeof(VMS_FORM_VIDEO_DATA));

            pVideoData->INFO.data.FORM_SEQ     = htons(nFormId);                         // 폼 표출 일련번호,        2Byte
            pVideoData->INFO.data.DISPLAY_TIME = 1;                                      // 폼의 표출시간을 지정,    1Byte( 0x00 이면 계속 표출 ) ==> 제어기에서 사용안함
            pVideoData->INFO.data.DISPLAY_TYPE = e_static_normal;                        // 폼의 표출유형을 지정,    1Byte
            pVideoData->INFO.data.BG_RGB       = e_bg_black;                             // 폼의 배경색을 지정,      1Byte
            pVideoData->INFO.data.OBJ_CNT      = 1;                                      // 표출할 오브젝트 전체 수, 1Byte

            pVideoData->INFO.obj.OBJ_TYPE    = e_obj_video;                              // 오브젝트 종류
            pVideoData->INFO.obj.OBJ_SIZE    = htons(sizeof(VMS_OBJ_VIDEO));             // 오브젝트 데이터 크기
            pVideoData->INFO.obj.FLASH       = 0x00;                                     // 점멸여부, 1Byte(0x00 : 고정, 0x01 : 점멸)
            pVideoData->INFO.obj.X           = htons(0);                                 // 좌표 X
            pVideoData->INFO.obj.Y           = htons(0);                                 // 좌표 Y
            pVideoData->INFO.obj.TEXT_BG_RGB = e_bg_black;                               // 문자열 배경색을 지정

            pVideoData->INFO.video.WIDTH     = htons(AObj->WIDTH);                         // 비트맵 표시 Width,  2 Byte, 0 ~ 1023 : 표출 비트맵 Width
            pVideoData->INFO.video.HEIGHT    = htons(AObj->HEIGHT);                        // 비트맵 표시 Heitht, 2 Byte, 0 ~ 1023 : 표출 비트맵 Width
            pVideoData->INFO.video.ETC       = 0x00;                                       // 기타
            sprintf(pVideoData->INFO.video.FILE_NM, "%s", STRM_ADDR.c_str());              // 동영상 파일 이름
            nPktIdx += sizeof(VMS_FORM_VIDEO_DATA);

            LINFO("download_form_0x9A: DownloadCnt: %d, FormId: %d, VideoId: %s", AObj->FormDownload.DownloadCnt, nFormId, pVideoData->INFO.video.FILE_NM);
        }
        else {
            pBmpIdData  = (VMS_FORM_BMPID_DATA*)&msgPtr[nPktIdx];
            memset(pBmpIdData, 0x00, sizeof(VMS_FORM_BMPID_DATA));

            pBmpIdData->INFO.data.FORM_SEQ     = htons(nFormId);                         // 폼 표출 일련번호,        2Byte
            pBmpIdData->INFO.data.DISPLAY_TIME = 1;                                      // 폼의 표출시간을 지정,    1Byte( 0x00 이면 계속 표출 ) ==> 제어기에서 사용안함
            pBmpIdData->INFO.data.DISPLAY_TYPE = e_static_normal;                        // 폼의 표출유형을 지정,    1Byte
            pBmpIdData->INFO.data.BG_RGB       = e_bg_black;                             // 폼의 배경색을 지정,      1Byte
            pBmpIdData->INFO.data.OBJ_CNT      = 1;                                      // 표출할 오브젝트 전체 수, 1Byte

            pBmpIdData->INFO.obj.OBJ_TYPE    = e_obj_bitmapid;                           // 오브젝트 종류
            pBmpIdData->INFO.obj.OBJ_SIZE    = htons(sizeof(VMS_OBJ_BITMAPID));          // 오브젝트 데이터 크기
            pBmpIdData->INFO.obj.FLASH       = 0x00;                                     // 점멸여부, 1Byte(0x00 : 고정, 0x01 : 점멸)
            pBmpIdData->INFO.obj.X           = htons(0);                                 // 좌표 X
            pBmpIdData->INFO.obj.Y           = htons(0);                                 // 좌표 Y
            pBmpIdData->INFO.obj.TEXT_BG_RGB = e_bg_black;                               // 문자열 배경색을 지정

            pBmpIdData->INFO.bmpid.WIDTH     = htons(AObj->WIDTH);                         // 비트맵 표시 Width,  2 Byte, 0 ~ 1023 : 표출 비트맵 Width
            pBmpIdData->INFO.bmpid.HEIGHT    = htons(AObj->HEIGHT);                        // 비트맵 표시 Heitht, 2 Byte, 0 ~ 1023 : 표출 비트맵 Width
            pBmpIdData->INFO.bmpid.IMG_TYPE  = e_img_bitmap;                               // e_img_type
            pBmpIdData->INFO.bmpid.BITMAP_ID = htons(nBitmapId);                           // 표출할 비트맵 ID,   2 Byte, 0～ 9999 : 표출할 비트맵 ID
            nPktIdx += sizeof(VMS_FORM_BMPID_DATA);

            LINFO("download_form_0x9A: DownloadCnt: %d, FormId: %d, BitmapId: %d", AObj->FormDownload.DownloadCnt, nFormId, nBitmapId);
        }
    //}

    nPktSize = sizeof(VMS_HEAD)+pHead->Length-2; //DLE/STX
    crc  = GETCRC16((char*)&pHead->Group, nPktSize);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+0] = VMS_DLE;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+1] = VMS_ETX;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+2] = HIBYTE(crc);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+3] = LOBYTE(crc);

    AObj->FormDownload.DownloadCnt++;

    SendPacketDLE((char*)msgPtr, nPktSize+6, AObj->IsDle);

    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::download_file_0x82()
{
    IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    if (AObj->FormDownload.MaxSchedule == 0)
    {
        // 여기 들어오면 안됌, 다운로드할 폼정보가 존해해야 여기 함수를 호출하게 돼있음
        return 0;
    }

    int nDownloadCnt = AObj->FormDownload.DownloadCnt;
    if (nDownloadCnt >= AObj->FormDownload.MaxSchedule)
    {
        // 폼파일이(폼이미지파일) 모두 다운로드 되었으므로 스케쥴 정보를 다운로드 한다.
        download_schedule_form_0x96();  // Display Schedule Form
        return 0;
    }

    bool                bResult = true;
    BYTE               *msgPtr;
    // 파일다운로드
    VMS_HEAD           *pHead;
    VMS_FILE_DATA      *pFile;
    char               *pStrm;

    // 폼다운로드
    VMS_FORM_HEAD       *pForm;
    VMS_FORM_BMPID_DATA *pData;

    WORD crc;
    int  nPktSize;

    int  ii;
    bool isEndDownload = true;
    AObj->pForms->Lock();
	try
	{
        for (ii = nDownloadCnt; ii < AObj->FormDownload.MaxSchedule; ii++)
        {
            AObj->FormDownload.DownloadCnt++;

            int nFormId   = AObj->FormDownload.Info[ii].FormNo;
            int nBitmapId = AObj->FormDownload.Info[ii].BitmapId;
            int nFormIdx  = AObj->FormDownload.Info[ii].FormIdx;

            if (g_AppCfg.IsCheckNewForm && AObj->FormDownload.Info[ii].IsDownload == false)
            {
                // 이미 다운로드 했기 때문에 다시 다운로드 하지 않는다.
                LDEBUG("download_file_0x82: DownloadCnt: %d, FormId: %d, BitmapId: %d, already download...", ii, nFormId, nBitmapId);
                continue;
            }

            TVmsForm *pForm = AObj->pForms->FLists.Find(nFormIdx);
            if (!pForm)
            {
                continue;
            }
            if (!pForm->Success)
            {
                continue;
            }

            // TODO: 20241220
            if (pForm->fileType == P_FILE_TYPE_STREAM)
            {
                continue;
            }
            if (!pForm->pStream || pForm->pStream->Size == 0)
            {
                continue;
            }
            if (pForm->fileType == P_FILE_TYPE_VIDEO)
            {
                // 필요에 따라서 동영상 FTP 다운로드 프로토콜을 여기서도 사용하자.....
                continue;
            }

            isEndDownload = false;
            AObj->DownloadFormId = AObj->FormDownload.Info[ii].VMS_FORM_ID;

            LDEBUG("download_file_0x82: DownloadCnt: %d, FormId: %d, BitmapId: %d, VMS_FORM_ID: %s", ii, nFormId, nBitmapId, AObj->DownloadFormId.c_str());

            // 다운로드
            msgPtr = (BYTE*)pMsg->Buff;
            pHead  = (VMS_HEAD*)&msgPtr[0];
            pFile  = (VMS_FILE_DATA*)&msgPtr[sizeof(VMS_HEAD)];
            pStrm  = (char*)&msgPtr[sizeof(VMS_HEAD)+sizeof(VMS_FILE_DATA)];

            pHead->Dle    = VMS_DLE;
            pHead->Stx    = VMS_STX;
            pHead->Group  = AObj->GROUP_NO;
            pHead->Ctlr   = AObj->CTLR_LOCAL_NO;
            pHead->OpCode = e_vms_file_download;
            pHead->Curr   = 1;
            pHead->Total  = 1;
            pHead->Length = 0;

            int nFileNameSize = 11;
            int nFileSize     = pForm->pStream->Size;

            nFileNameSize = 11;
            pHead->Length = sizeof(VMS_FILE_DATA)+nFileNameSize+nFileSize;

            pFile->head.SAVE_LOC  = e_download_prog_image;   // Download Data 저장위치 Code,    1 Byte
            pFile->head.NAME_SIZE = 11;                      // 파일명 길이,                    1 Byte, 1～ 255
            pFile->head.SIZE      = nFileSize;               // 저장하여야 할 데이터의 크기,    4 Byte

            pForm->pStream->Position = 0;

            try
            {
                sprintf((char*)&pStrm[0], "BID%04d.BMP", nBitmapId);
                memcpy((char*)&pStrm[pFile->head.NAME_SIZE], (char*)pForm->pStream->Memory, nFileSize);

                // 바이트 오더링 변환
                pFile->head.SIZE = htonl(pFile->head.SIZE);

                nPktSize = sizeof(VMS_HEAD)+pHead->Length-2; //DLE/STX
                crc  = GETCRC16((char*)&pHead->Group, nPktSize);
                msgPtr[sizeof(VMS_HEAD)+pHead->Length+0] = VMS_DLE;
                msgPtr[sizeof(VMS_HEAD)+pHead->Length+1] = VMS_ETX;
                msgPtr[sizeof(VMS_HEAD)+pHead->Length+2] = HIBYTE(crc);
                msgPtr[sizeof(VMS_HEAD)+pHead->Length+3] = LOBYTE(crc);

                SendPacketDLE((char*)msgPtr, nPktSize+6, AObj->IsDle);
                break;
            }
            catch(Exception &e)
            {
                bResult = false;
            }
        }
	}
	__finally
	{
        AObj->pForms->UnLock();
	}

    if (isEndDownload)
    {
        // 폼이미지 정보가 모두 다운로드 되었으므로 스케쥴 정보를 다운로드 한다.
        download_schedule_form_0x96();  // Display Schedule Form
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::download_schedule_form_0x96()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    char                Buff[1024];
    BYTE               *msgPtr;
    VMS_HEAD           *pHead;
    VMS_SCHEDULE_FORM  *pSche;

    WORD crc;
    int  nPktSize;

    msgPtr = Buff;
    pHead  = (VMS_HEAD*)&msgPtr[0];
    pSche  = (VMS_SCHEDULE_FORM*)&msgPtr[sizeof(VMS_HEAD)];

    pHead->Dle    = VMS_DLE;
    pHead->Stx    = VMS_STX;
    pHead->Group  = AObj->GROUP_NO;
    pHead->Ctlr   = AObj->CTLR_LOCAL_NO;
    pHead->OpCode = e_vms_download_schedule_form;
    pHead->Curr   = 1;
    pHead->Total  = 1;
    pHead->Length = sizeof(VMS_SCHEDULE_FORM);

    memset((char*)pSche, 0x00, sizeof(VMS_SCHEDULE_FORM));

    if (AObj->FormDownload.IsDefault)
    {
        pSche->Form[0].FormNo  = htons(DEFAULT_FORMID);
        pSche->Form[0].DispSec = 4;
        LINFO("download_schedule_form_0x96: 0, DEFAULT_FORMID: %d, DispSec: %d", DEFAULT_FORMID, pSche->Form[0].DispSec);
    }
    else
    {
        for (int ii = 0; ii < AObj->FormDownload.MaxSchedule && ii < MAX_VMS_SCENARIO_FORM; ii++)
        {
            pSche->Form[ii].FormNo  = htons(AObj->FormDownload.Info[ii].FormNo);
            pSche->Form[ii].DispSec = AObj->FormDownload.Info[ii].DispSec;
            LINFO("download_schedule_form_0x96: %d, FormId: %d, DispSec: %d", ii, AObj->FormDownload.Info[ii].FormNo, AObj->FormDownload.Info[ii].DispSec);
        }
    }

    nPktSize = sizeof(VMS_HEAD)+pHead->Length-2; //DLE/STX
    crc  = GETCRC16((char*)&pHead->Group, nPktSize);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+0] = VMS_DLE;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+1] = VMS_ETX;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+2] = HIBYTE(crc);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+3] = LOBYTE(crc);

    SendPacketDLE((char*)msgPtr, nPktSize+6, AObj->IsDle);

    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::download_blank_0x9E()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    char                Buff[1024];
    BYTE               *msgPtr;
    VMS_HEAD           *pHead;

    WORD crc;
    int  nPktSize;

    LDEBUG("download_blank_0x9E: .................");

    msgPtr = Buff;
    pHead  = (VMS_HEAD*)&msgPtr[0];

    pHead->Dle    = VMS_DLE;
    pHead->Stx    = VMS_STX;
    pHead->Group  = AObj->GROUP_NO;
    pHead->Ctlr   = AObj->CTLR_LOCAL_NO;
    pHead->OpCode = e_vms_blank;
    pHead->Curr   = 1;
    pHead->Total  = 1;
    pHead->Length = 0;

    nPktSize = sizeof(VMS_HEAD)+pHead->Length-2; //DLE/STX
    crc  = GETCRC16((char*)&pHead->Group, nPktSize);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+0] = VMS_DLE;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+1] = VMS_ETX;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+2] = HIBYTE(crc);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+3] = LOBYTE(crc);

    SendPacketDLE((char*)msgPtr, nPktSize+6, AObj->IsDle);

    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::download_lib_form_0x0A()
{
    IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    if (AObj->FormDownload.MaxSchedule == 0)
    {
        // 여기 들어오면 안됌, 다운로드할 폼정보가 존해해야 여기 함수를 호출하게 돼있음
        return 0;
    }

    int nDownloadCnt = AObj->FormDownload.DownloadCnt;
    if (nDownloadCnt >= AObj->FormDownload.MaxSchedule)
    {
        // 폼파일이(폼이미지파일) 모두 다운로드 되었으므로 스케쥴 정보를 다운로드 한다.
        download_schedule_form_0x0E();  // Display Schedule Form
        return 0;
    }

    bool                bResult = true;
    BYTE               *msgPtr;
    // Download Graphics Library (Full Graphic Data)
    VMS_HEAD             *pHead;
    VMS_FULL_GRAPHIC_LIB *pFile;

    WORD crc;
    int  nPktSize;

    int  ii;
    bool isEndDownload = true;
    AObj->pForms->Lock();
	try
	{
        for (ii = nDownloadCnt; ii < AObj->FormDownload.MaxSchedule; ii++)
        {
            AObj->FormDownload.DownloadCnt++;

            int nFormId   = AObj->FormDownload.Info[ii].FormNo;
            int nBitmapId = AObj->FormDownload.Info[ii].BitmapId;
            int nFormIdx  = AObj->FormDownload.Info[ii].FormIdx;

            if (g_AppCfg.IsCheckNewForm && AObj->FormDownload.Info[ii].IsDownload == false)
            {
                // 이미 다운로드 했기 때문에 다시 다운로드 하지 않는다.
                LDEBUG("download_lib_form_0x0A: DownloadCnt: %d, FormId: %d, BitmapId: %d, already download...", ii, nFormId, nBitmapId);
                continue;
            }

            TVmsForm *pForm = AObj->pForms->FLists.Find(nFormIdx);
            if (!pForm)
            {
                continue;
            }
            if (!pForm->Success)
            {
                continue;
            }

            if (pForm->fileType == P_FILE_TYPE_VIDEO  || pForm->fileType == P_FILE_TYPE_STREAM)
            {
                continue;
            }

            if (!pForm->pStream || pForm->pStream->Size == 0)
            {
                continue;
            }
            if (!pForm->pBitmap || pForm->pBitmap->Width == 0 || pForm->pBitmap->Height == 0)
            {
                continue;
            }

            // pForm->pBitmap->PixelFormat = pf24bit;
            // 픽셀포멧이 24비트여야 ScanLine을 사용할 수 있다. 24비트가 아닌경우에는 다른 방법으로 처리해야 한다.

            isEndDownload = false;
            AObj->DownloadFormId = AObj->FormDownload.Info[ii].VMS_FORM_ID;

            LDEBUG("download_lib_form_0x0A: DownloadCnt: %d, FormId: %d, BitmapId: %d, VMS_FORM_ID: %s", ii, nFormId, nBitmapId, AObj->DownloadFormId.c_str());

            // 다운로드
            msgPtr = (BYTE*)pMsg->Buff;
            pHead  = (VMS_HEAD*)&msgPtr[0];
            pFile  = (VMS_FULL_GRAPHIC_LIB*)&msgPtr[sizeof(VMS_HEAD)];

            AObj->FTxtOpCode = e_txt_download_full_graphic_lib;

            pHead->Dle    = VMS_DLE;
            pHead->Stx    = VMS_STX;
            pHead->Group  = AObj->GROUP_NO;
            pHead->Ctlr   = AObj->CTLR_LOCAL_NO;
            pHead->OpCode = e_txt_download_full_graphic_lib;
            pHead->Curr   = 1;
            pHead->Total  = 1;
            pHead->Length = sizeof(VMS_FULL_GRAPHIC_LIB);

            memset((char*)pFile, 0x00, sizeof(VMS_FULL_GRAPHIC_LIB));

            pFile->Phase    = 0x00;     // 0x00(1phase), 0x01(2phase)
            pFile->DispFunc = 0x07;     // 0x07(static)
            pFile->DispDir  = 0x00;     // 0x00(drop down)
            pFile->MsgNmbr  = (WORD)nBitmapId;

            pFile->MsgNmbr = htons(pFile->MsgNmbr);
            try
            {
                int idx = 0;
                int ll, mm;
                int r, g, b;
                int nW = pForm->pBitmap->Width;
                int nH = pForm->pBitmap->Height;

                TPixelFormat PixelFormat = pForm->pBitmap->PixelFormat;
                if (PixelFormat == pf24bit)
                {
                    for (ll = 0; ll < nH; ll++)
                    {
                        TRGBTriple *p = reinterpret_cast<TRGBTriple *>(pForm->pBitmap->ScanLine[ll]);
                        for (mm = 0; mm < nW; mm++)
                        {
                            r = p[mm].rgbtRed;
                            g = p[mm].rgbtGreen;
                            //b = p[mm].rgbtBlue;

                            if (r > g_AppCfg.PixelValue) CComm_SetBitString(pFile->R_Data1, idx, 1);
                            if (g > g_AppCfg.PixelValue) CComm_SetBitString(pFile->G_Data1, idx, 1);
                            idx++;
                        }
                    }
                }
                else
                if (PixelFormat == pf32bit)
                {
                    for (ll = 0; ll < nH; ll++)
                    {
                        TRGBQuad *p = reinterpret_cast<TRGBQuad *>(pForm->pBitmap->ScanLine[ll]);
                        for (mm = 0; mm < nW; mm++)
                        {
                            r = p[mm].rgbRed;
                            g = p[mm].rgbGreen;
                            //b = p[mm].rgbBlue;

                            if (r > g_AppCfg.PixelValue) CComm_SetBitString(pFile->R_Data1, idx, 1);
                            if (g > g_AppCfg.PixelValue) CComm_SetBitString(pFile->G_Data1, idx, 1);
                            idx++;
                        }
                    }
                }
                else
                if (PixelFormat == pf16bit)
                {
                    //FILE *fp = fopen("C:\\temp.dat", "w+");
                    for (ll = 0; ll < nH; ll++)
                    {
                        WORD *p = reinterpret_cast<WORD *>(pForm->pBitmap->ScanLine[ll]);
                        for (mm = 0; mm < nW; mm++)
                        {
                            r = p[mm] >> 11 & 0x1F; // 5
                            g = p[mm] >>  5 & 0x3F; // 6
                            //b = p[mm] >>  0 & 0x1F; // 5
                            //((blue>>3)<<10) | ((green>>3)<<5) | (red>>3);

                            if (r > g_AppCfg.PixelValue) CComm_SetBitString(pFile->R_Data1, idx, 1);
                            if (g > g_AppCfg.PixelValue) CComm_SetBitString(pFile->G_Data1, idx, 1);
                            idx++;

                            //if (r > 0 || g > 0) fprintf(fp, "*"); else fprintf(fp, "-");
                        }
                        //fprintf(fp, "\n");
                    }
                    //fclose(fp);
                }
                else
                if (PixelFormat == pf8bit)
                {
                    PALETTEENTRY PalEntries[257];
                    if (pForm->pBitmap->Palette != 0)
                    {
                        GetPaletteEntries(pForm->pBitmap->Palette, 0, 256, (LPPALETTEENTRY)PalEntries);
                        //FILE *fp = fopen("C:\\temp.dat", "w+");
                        for (ll = 0; ll < nH; ll++)
                        {
                            BYTE *p = reinterpret_cast<BYTE *>(pForm->pBitmap->ScanLine[ll]);
                            for (mm = 0; mm < nW; mm++)
                            {
                                r = PalEntries[p[mm]].peRed;
                                g = PalEntries[p[mm]].peGreen;
                                b = PalEntries[p[mm]].peBlue;

                                if (r > g_AppCfg.PixelValue) CComm_SetBitString(pFile->R_Data1, idx, 1);
                                if (g > g_AppCfg.PixelValue) CComm_SetBitString(pFile->G_Data1, idx, 1);
                                idx++;

                                //if (r > 0 || g > 0) fprintf(fp, "*"); else fprintf(fp, "-");
                            }
                            //fprintf(fp, "\n");
                        }
                        //fclose(fp);
                    }
                }
                else
                if (PixelFormat == pf4bit)
                //    PixelFormat == pf1bit)
                {
                    PALETTEENTRY PalEntries[17];
                    if (pForm->pBitmap->Palette != 0)
                    {
                        int clrIdx;
                        GetPaletteEntries(pForm->pBitmap->Palette, 0, 16, (LPPALETTEENTRY)PalEntries);
                        //FILE *fp = fopen("C:\\temp.dat", "w+");
                        for (ll = 0; ll < nH; ll++)
                        {
                            BYTE *p = reinterpret_cast<BYTE *>(pForm->pBitmap->ScanLine[ll]);
                            for (mm = 0; mm < nW/2; mm++)
                            {
                                clrIdx = (p[mm] >> 4) & 0xF;
                                r = PalEntries[clrIdx].peRed;
                                g = PalEntries[clrIdx].peGreen;
                                b = PalEntries[clrIdx].peBlue;

                                if (r > g_AppCfg.PixelValue) CComm_SetBitString(pFile->R_Data1, idx, 1);
                                if (g > g_AppCfg.PixelValue) CComm_SetBitString(pFile->G_Data1, idx, 1);
                                idx++;

                                //if (r > 0 || g > 0) fprintf(fp, "*"); else fprintf(fp, "-");

                                clrIdx = p[mm] & 0xF;
                                r = PalEntries[clrIdx].peRed;
                                g = PalEntries[clrIdx].peGreen;
                                b = PalEntries[clrIdx].peBlue;

                                if (r > g_AppCfg.PixelValue) CComm_SetBitString(pFile->R_Data1, idx, 1);
                                if (g > g_AppCfg.PixelValue) CComm_SetBitString(pFile->G_Data1, idx, 1);
                                idx++;

                                //if (r > 0 || g > 0) fprintf(fp, "*"); else fprintf(fp, "-");
                            }
                            //fprintf(fp, "\n");
                        }
                        //fclose(fp);
                    }
                }

                nPktSize = sizeof(VMS_HEAD)+pHead->Length-2; //DLE/STX
                crc  = GETCRC16((char*)&pHead->Group, nPktSize);
                msgPtr[sizeof(VMS_HEAD)+pHead->Length+0] = VMS_DLE;
                msgPtr[sizeof(VMS_HEAD)+pHead->Length+1] = VMS_ETX;
                msgPtr[sizeof(VMS_HEAD)+pHead->Length+2] = HIBYTE(crc);
                msgPtr[sizeof(VMS_HEAD)+pHead->Length+3] = LOBYTE(crc);

                SendPacketDLE((char*)msgPtr, nPktSize+6, AObj->IsDle);
                break;
            }
            catch(Exception &e)
            {
                bResult = false;
            }
        }
	}
	__finally
	{
        AObj->pForms->UnLock();
	}

    if (isEndDownload)
    {
        // 폼이미지 정보가 모두 다운로드 되었으므로 스케쥴 정보를 다운로드 한다.
        download_schedule_form_0x0E();  // Display Schedule Form
    }
    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::download_schedule_form_0x0E()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    char                Buff[1024];
    BYTE               *msgPtr;
    VMS_HEAD           *pHead;
    VMS_SCHEDULE_FORM  *pSche;

    WORD crc;
    int  nPktSize;

    AObj->FTxtOpCode = e_txt_display_schedule_msg;

    msgPtr = Buff;
    pHead  = (VMS_HEAD*)&msgPtr[0];
    pSche  = (VMS_SCHEDULE_FORM*)&msgPtr[sizeof(VMS_HEAD)];

    pHead->Dle    = VMS_DLE;
    pHead->Stx    = VMS_STX;
    pHead->Group  = AObj->GROUP_NO;
    pHead->Ctlr   = AObj->CTLR_LOCAL_NO;
    pHead->OpCode = e_txt_display_schedule_msg;
    pHead->Curr   = 1;
    pHead->Total  = 1;
    pHead->Length = sizeof(VMS_SCHEDULE_FORM);

    memset((char*)pSche, 0x00, sizeof(VMS_SCHEDULE_FORM));

    for (int ii = 0; ii < AObj->FormDownload.MaxSchedule && ii < MAX_VMS_SCENARIO_FORM; ii++)
    {
        pSche->Form[ii].FormNo  = htons(AObj->FormDownload.Info[ii].FormNo);
        pSche->Form[ii].DispSec = AObj->FormDownload.Info[ii].DispSec;
        LINFO("download_lib_form_0x0A: %d, FormId: %d, DispSec: %d", ii, AObj->FormDownload.Info[ii].FormNo, AObj->FormDownload.Info[ii].DispSec);
    }

    nPktSize = sizeof(VMS_HEAD)+pHead->Length-2; //DLE/STX
    crc  = GETCRC16((char*)&pHead->Group, nPktSize);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+0] = VMS_DLE;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+1] = VMS_ETX;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+2] = HIBYTE(crc);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+3] = LOBYTE(crc);

    SendPacketDLE((char*)msgPtr, nPktSize+6, AObj->IsDle);

    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::download_blank_0x16()
{
    TCDSCtlr *AObj = FCDSCtlr;
    if (!AObj) return -1;

    char                Buff[1024];
    BYTE               *msgPtr;
    VMS_HEAD           *pHead;

    WORD crc;
    int  nPktSize;

    AObj->FTxtOpCode = e_txt_blank;

    msgPtr = Buff;
    pHead  = (VMS_HEAD*)&msgPtr[0];

    pHead->Dle    = VMS_DLE;
    pHead->Stx    = VMS_STX;
    pHead->Group  = AObj->GROUP_NO;
    pHead->Ctlr   = AObj->CTLR_LOCAL_NO;
    pHead->OpCode = e_txt_blank;
    pHead->Curr   = 1;
    pHead->Total  = 1;
    pHead->Length = 0;

    nPktSize = sizeof(VMS_HEAD)+pHead->Length-2; //DLE/STX
    crc  = GETCRC16((char*)&pHead->Group, nPktSize);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+0] = VMS_DLE;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+1] = VMS_ETX;
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+2] = HIBYTE(crc);
    msgPtr[sizeof(VMS_HEAD)+pHead->Length+3] = LOBYTE(crc);

    SendPacketDLE((char*)msgPtr, nPktSize+6, AObj->IsDle);

    return 1;
}
//---------------------------------------------------------------------------

int TClientSession::ReqSendPacket(char *ACmd, int ALen)
{
    VMS_HEAD *pHead = (VMS_HEAD*)ACmd;

    if (ALen <= 0)
    {
        return -1;
    }

    if (!SendRequest(ACmd, ALen))
    {
        SERROR("+CLI ReqSendPacket send request faild: %s, 0x%02X will be closed.", FIpAddress.c_str(), pHead->OpCode);
        MERROR("+CLI ReqSendPacket send request faild: %s, 0x%02X will be closed.", FIpAddress.c_str(), pHead->OpCode);
        Disconnect();
        return -2;
    }

    SendFlushComplete();

    return 1;
}
//---------------------------------------------------------------------------