VmsCommServer/SRC/COMMON/VMSCThreadSendF.cpp

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


#pragma hdrstop

#include "VMSCThread.h"
#include "VMSCThreadSendF.h"

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

#pragma package(smart_init)

/*
 * 송신 패킷 처리
 *  arguments
 *   void
 *  return
 *   void
 */
int __fastcall TVMSCThread::ProcessSendPacket(BYTE AOpCode, COMMAND_ARGUMENT *AArg)
{
FErrLine = 10;
    VMS_PACKET *Pkt    = (VMS_PACKET*)m_TxBuff;
    int         result = SYS_ERR_NONE;
	int         nData  = 0;
    int         sndLen = 0;

    unsigned crc;
	unsigned short year, mon, day;
	unsigned short hour, min, sec, msec;

	Now().DecodeDate(&year, &mon, &day);
	Now().DecodeTime(&hour, &min, &sec, &msec);

    Pkt->hd.STX    = VMS_STX;   // STX, 0x02
    Pkt->hd.ID     = 0x00;      // Reserved, 0x00
    Pkt->hd.OpCode = AOpCode;   // OpCode
    sprintf(Pkt->hd.ADDR, "%04d", FVmsObj->Id); // Address

	switch(AOpCode)
    {
    case REQ_VMS_STATUS://                  0x50        // Status 요청,  센터->VMS
        Pkt->data[nData++] = (BYTE)HIBYTE(year);
        Pkt->data[nData++] = (BYTE)LOBYTE(year);
        Pkt->data[nData++] = (BYTE)mon;
        Pkt->data[nData++] = (BYTE)day;
        Pkt->data[nData++] = (BYTE)hour;
        Pkt->data[nData++] = (BYTE)min;
        Pkt->data[nData++] = (BYTE)sec;
        break;
    case REQ_VMS_MSG_DOWNLOAD://            0x51        // 문안 전송 요청, 센터->VMS
        nData = MakeMsgDownload(Pkt->data, AArg);
        if (nData <= 0)
        {
            LERROR(">>> MakeMsgDownload Faild");
            return SYS_ERR_DATABASE;
        }
        break;
    case REQ_VMS_LIB_DOWNLOAD://            0x52        // Library download 요청, 센터->VMS
        nData = MakeLibDownload(Pkt->data, AArg);
        if (nData <= 0)
        {
            LERROR(">>> MakeLibDownload Faild");
            return SYS_ERR_DATABASE;
        }
        break;
    case REQ_VMS_PARAM_DOWNLOAD://          0x53        // Parameter download 요청, 센터->VMS
		Pkt->data[nData++] = AArg->Publication.Data.Set2.DefCommErr;                           // 통신장애 기본값, 제어기가 Host로부터 Poll 또는 명령을 받지 않고 경과할 수 있는 최대시간 (default ; 60초)
		Pkt->data[nData++] = (BYTE)HIBYTE(AArg->Publication.Data.Set2.SlotCommErr);                          // 통신장애 slot번호, 통신 fail 시 표시할 메시지 번호(default 0번)
		Pkt->data[nData++] = (BYTE)LOBYTE(AArg->Publication.Data.Set2.SlotCommErr);                          // 통신장애 slot번호, 통신 fail 시 표시할 메시지 번호(default 0번)
		Pkt->data[nData++] = (BYTE)HIBYTE(AArg->Publication.Data.Set2.SlotPowerErr);                         // 전원장애 slot번호, 전원장애 시 표시할 메시지 번호(default 0번)
		Pkt->data[nData++] = (BYTE)LOBYTE(AArg->Publication.Data.Set2.SlotPowerErr);                         // 전원장애 slot번호, 전원장애 시 표시할 메시지 번호(default 0번)
		Pkt->data[nData++] = AArg->Publication.Data.Set2.NightLuminance;                       // 야간 휘도 값, 0x30 ~ 0x3F
		Pkt->data[nData++] = AArg->Publication.Data.Set2.DayLuminance;                         // 주간 휘도 값, 0x40 ~ 0x4F
		Pkt->data[nData++] = AArg->Publication.Data.Set2.PhaseCycleTime;                       // phase시간주기, 장애시 phase주기 (default : 3초, 범위 : 0 ~ 10초)
		Pkt->data[nData++] = AArg->Publication.Data.Set2.ModuleFailRate;                       // 모듈장애율, 한개의 module을 장애로 처리하기 위한 장애 pixel백분율 (default 10%)
		Pkt->data[nData++] = AArg->Publication.Data.Set2.ModuleCheckTime;                      // 모듈감시 주기, 0 ~ 255 (단위:초)
		Pkt->data[nData++] = AArg->Publication.Data.Set2.BoardOnHour;                          // 전광판 On time(시), 0시 ~ 23시
		Pkt->data[nData++] = AArg->Publication.Data.Set2.BoardOnMin;                           // 전광판 On time(분), 0시 ~ 23시
		Pkt->data[nData++] = AArg->Publication.Data.Set2.BoardOffHour;                         // 전광판 Off time(시), 0시 ~ 23시
	    Pkt->data[nData++] = AArg->Publication.Data.Set2.BoardOffMin;                          // 전광판 Off time(분), 0시 ~ 23시
#if 0
11 통신장애 기본값 제어기가 Host로부터 Poll 또는 명령을 받지 않고 경과할 수 있는 최대시간 (default ; 60초)
12 통신장애 slot번호 통신 fail 시 표시할 메시지 번호(default 0번)
13
14 전원장애 slot번호 전원장애 시 표시할 메시지 번호(default 0번)
15
16 야간 휘도 값 0x30 ~ 0x3F
17 주간 휘도 값 0x40 ~ 0x4F
18 phase시간주기 장애시 phase주기 (default : 3초, 범위 : 0 ~ 10초)
19 모듈장애율 한개의 module을 장애로 처리하기 위한 장애 pixel백분율 (default 10%)
20 모듈감시 주기 0 ~ 255 (단위:초)
21 전광판 On time(시) 0시 ~ 23시 0x00000000 : 없음
22 전광판 On time(분) 0분 ~ 59분
23 전광판 Off time(시) 0시 ~ 23시
24 전광판 Off time(분) 0분 ~ 59분
#endif
        break;
    case REQ_VMS_BLANK_DISP://              0x54        // Blank 요청, 센터->VMS
        //설정데이터없이 헤더로 정보로 전송
        break;
    case REQ_VMS_DEF_MSG_DISP://            0x55        // Default message display 요청, 센터->VMS
        //설정데이터없이 헤더로 정보로 전송
        break;
    case REQ_VMS_MODULE_STATUS://           0x56        // Module status upload 요청, 센터->VMS
        //설정데이터없이 헤더로 정보로 전송
        break;
    case REQ_VMS_INITIALIZE://              0x57        // Initialize 요청, 센터->VMS
        //설정데이터없이 헤더로 정보로 전송
        break;
    case REQ_VMS_LUMINANCE_LEVEL_SET://     0x58        // Luminance level set 요청, 센터->VMS
        Pkt->data[nData++] = AArg->Publication.Data.Ctl;
        break;
    case REQ_SIGNBOARD_POWER_CONTROL://     0x59        // Signboard power control 요청, 센터->VMS
        Pkt->data[nData++] = AArg->Publication.Data.Ctl;
        break;
	default:
        LERROR(">>> Unknown ProcessSendPacket: 0x%02X", AOpCode);
        return SYS_ERR_UNKNOWN_COMMAND;
	}

#if 0
BYTE    STX;
BYTE    ID;
BYTE    OpCode;
UINT    Size;
char    ADDR[4];
char    DATA[n];
char    CRC[2];
char    ETX;
#endif
    sndLen = nData+1+1+4+4+2; // ID부터 CRC까지의 전체 길이(byte order준수)
    Pkt->hd.Size = CommUtil_swapl((DWORD)sndLen);

    crc = CommUtil_MakeCrc16((void*)&Pkt->hd.ID, (WORD)(sndLen-2));    //ID부터 DATA까지의 CRC-16 생성다항식에 의해 계산된 값
    Pkt->data[nData++] = HIBYTE(crc);   // CRC
    Pkt->data[nData++] = LOBYTE(crc);   // CRC
    Pkt->data[nData++] = VMS_ETX;       // ETX, 0x03

    result = SendPacket((BYTE*)Pkt, sndLen+2);  //STX+Pkt->Size+ETX

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

int __fastcall TVMSCThread::MakeMsgDownload(BYTE *ABuff, COMMAND_ARGUMENT *AArg)
{
	int nData  = 0;
    int nForms = 0;
    unsigned int nImgSize;

	TVmsForm  *pVmsForm = NULL;

	AnsiString MessageId;
	int        ii;
    bool       bException = false;

    try
    {
        m_pVmsFormList->Lock();
        int nFormCnt = m_pVmsFormList->Count();
        if (nFormCnt > 9) nFormCnt = 9;
        if (nFormCnt <= 0)
        {
            SERROR("Msg Download Form Count is zero ! ! !");
            return -1;
        }

        ABuff[nData++] = 0x07;  // 정지화면 (Stationary)
        ABuff[nData++] = 0x02;  // Left(오른쪽에서 왼쪽으로)

        int nDispTime = FVmsObj->VMS_PHSE_CHNG_CYCL;
        if (FVmsObj->VMS_PHSE_CHNG_CYCL <  3) nDispTime = 3;
        if (FVmsObj->VMS_PHSE_CHNG_CYCL > 10) nDispTime = 10;

        ABuff[nData++] = (BYTE)nDispTime;//0x05;  // 표출 시간/기간

        ABuff[nData++] = (BYTE)nFormCnt-1;  // PHASE 갯수(0x00-1EA, 0x01 ~ 0x08=9EA)

LDEBUG("Display Time: %d sec, Forms: %d", nDispTime, nFormCnt);
        for (int ii = 0; ii < nFormCnt; ii++)
        {
            pVmsForm = m_pVmsFormList->GetItem(ii);
            if (!pVmsForm)
            {
                SERROR("Msg FormId Memory Not Found: %d", ii);
                continue;
            }
#if 0
            LINFO("            pVmsForm->DisplayTime: %d", pVmsForm->DisplayTime);
            LINFO("pVmsForm->DisplayMode.ToIntDef(0): %d", pVmsForm->DisplayMode.ToIntDef(0));
            LINFO(" pVmsForm->DisplayDir.ToIntDef(0): %d", pVmsForm->DisplayDir.ToIntDef(0));
            LINFO("          pVmsForm->pStream->Size: %d", pVmsForm->pStream->Size);
#endif

            nImgSize = pVmsForm->pStream->Size;

            ABuff[nData++] = 'G';   //G: 그래픽, T: Text, B: Bar, S: Symbol
            ABuff[nData++] = (BYTE)(nImgSize >> 24) & 0xFFFFFFFF;
            ABuff[nData++] = (BYTE)(nImgSize >> 16) & 0xFFFFFFFF;
            ABuff[nData++] = (BYTE)(nImgSize >>  8) & 0xFFFFFFFF;
            ABuff[nData++] = (BYTE)(nImgSize      ) & 0xFFFFFFFF;

            try
            {
                pVmsForm->pStream->Position = 0;
                memcpy((char*)&ABuff[nData], (char *)pVmsForm->pStream->Memory, nImgSize);
                nData += nImgSize;
            }
            catch(Exception &e)
            {
                bException = true;
                SERROR("MemoryStream Allocation error: %s, FormId: %s", AnsiString(e.Message).c_str(), pVmsForm->FormId.c_str());
            }
        }
    }
    __finally
    {
        m_pVmsFormList->UnLock();
    }

    return nData;
}
//---------------------------------------------------------------------------

int __fastcall TVMSCThread::MakeLibDownload(BYTE *ABuff, COMMAND_ARGUMENT *AArg)
{
	int nData  = 0;
    int nForms = 0;
    unsigned int nImgSize;

	TVmsForm  *pVmsForm = NULL;

	AnsiString MessageId;
	int        ii;
    bool       bException = false;

    try
    {
        m_pVmsFormList->Lock();
        int nFormCnt = m_pVmsFormList->Count();
        if (nFormCnt > 9) nFormCnt = 9;
        if (nFormCnt <= 0)
        {
            SERROR("Msg Download Form Count is zero ! ! !");
            return -1;
        }

#if 0
□ LIBRARY 메시지 번호의 범위
  - Text Message Number			    : 1000 - 5999
  - Graphic Symbol Message Number	: 6000 - 8999
  - Full Graphic Message Number		: 9000 - 9999
  - Message Number 0 은 Default Message
#endif

        int nLibNo = 0;
        ABuff[nData++] = 0x07;  // 정지화면 (Stationary)
        ABuff[nData++] = 0x02;  // Left(오른쪽에서 왼쪽으로)

        ABuff[nData++] = (BYTE)(nLibNo >>  8) & 0xFFFFFFFF;
        ABuff[nData++] = (BYTE)(nLibNo      ) & 0xFFFFFFFF;

        ABuff[nData++] = (BYTE)nFormCnt;  // PHASE 갯수(0x00-1EA, 0x01 ~ 0x08=9EA)

LDEBUG("Lib Download: Forms: %d", nFormCnt);

        for (int ii = 0; ii < nFormCnt; ii++)
        {
            pVmsForm = m_pVmsFormList->GetItem(ii);
            if (!pVmsForm)
            {
                SERROR("Msg FormId Memory Not Found: %d", ii);
                continue;
            }
#if 0
            LINFO("            pVmsForm->DisplayTime: %d", pVmsForm->DisplayTime);
            LINFO("pVmsForm->DisplayMode.ToIntDef(0): %d", pVmsForm->DisplayMode.ToIntDef(0));
            LINFO(" pVmsForm->DisplayDir.ToIntDef(0): %d", pVmsForm->DisplayDir.ToIntDef(0));
            LINFO("          pVmsForm->pStream->Size: %d", pVmsForm->pStream->Size);
#endif

            nImgSize = pVmsForm->pStream->Size;

            ABuff[nData++] = 'S';   //G: 그래픽, T: Text, B: Bar, S: Symbol
            ABuff[nData++] = (BYTE)(nImgSize >> 24) & 0xFFFFFFFF;
            ABuff[nData++] = (BYTE)(nImgSize >> 16) & 0xFFFFFFFF;
            ABuff[nData++] = (BYTE)(nImgSize >>  8) & 0xFFFFFFFF;
            ABuff[nData++] = (BYTE)(nImgSize      ) & 0xFFFFFFFF;

            try
            {
                pVmsForm->pStream->Position = 0;
                memcpy((char*)&ABuff[nData], (char *)pVmsForm->pStream->Memory, nImgSize);
                nData += nImgSize;
            }
            catch(Exception &e)
            {
                bException = true;
                SERROR("MemoryStream Allocation error: %s, FormId: %s", AnsiString(e.Message).c_str(), pVmsForm->FormId.c_str());
            }
        }
    }
    __finally
    {
        m_pVmsFormList->UnLock();
    }

    return nData;
}
//---------------------------------------------------------------------------

/*
 * 패킷 송신
 *  arguments
 *   void
 *  return
 *   void
 */
int __fastcall TVMSCThread::SendPacket(BYTE *ACmdBuff, int AReqSendLen)
{
    int result = SYS_ERR_NONE;

    try
    {
        int nSendBytes = TcpClient->SendBuf(ACmdBuff, AReqSendLen);
        if (nSendBytes == AReqSendLen)
        {
            FClient.sendRetry--;
            FClient.sendTimer = Now();
        }
        else
        {
            result = SYS_ERR_WRITE_LENGTH;
        }

        if (SYS_ERR_NONE == result) LogData("SEND",      ACmdBuff, AReqSendLen);
        else                        LogData("SEND Fail", ACmdBuff, nSendBytes);

        InfoPacket(ACmdBuff, nSendBytes, true, result);
    }
    catch(Exception &e)
    {
        result = SYS_ERR_MEMORY;
    }
	return result;
}
//---------------------------------------------------------------------------