VmsCommServer/SRC/COMMON/VMSCThreadRecvF.cpp

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


#pragma hdrstop

#include "VMSCThread.h"
#include "VMSCThreadRecvF.h"

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

#pragma package(smart_init)

/*
 * 패킷 수신
 *  arguments
 *   void
 *  return
 *   void
 */
int __fastcall TVMSCThread::RecvPacket(BYTE *ABuffer, int ALen)
{
FErrLine = 3;
    int       result = SYS_ERR_NONE;
    BYTE      data;
    PKT_HEAD *pHd = (PKT_HEAD*)m_RxBuff;

    if (ALen > 0)
    {
        LogData("RECV", (char*)ABuffer, ALen);
    }

    m_rcvPacketTimer = Now();

    for (int ii = 0; ii < ALen; ii++)
    {
        data = ABuffer[ii];
        switch(m_RxState)
        {
        case RX_STX:
            if (data == VMS_STX)
            {
                m_RxBuff[m_RxLen++] = data;
                m_RxState = RX_HEAD;
            }
            else
            {
                LERROR("Receive packet format sequence error[STX]: %02X, %d", data, m_RxLen);
                InitRx();
            }
            break;

        case RX_HEAD:
             m_RxBuff[m_RxLen++] = data;
             if (m_RxLen == (int)sizeof(PKT_HEAD))
             {
                m_RxDataLen = htonl(pHd->Size);

                if (m_RxDataLen > (CLIENT_RCV_BUF_SIZE-10) || m_RxDataLen == 0)
                {
                    LERROR("Receive packet length error: %d", m_RxDataLen);
                    InitRx();
                }
                else
                {
                    m_RxPktLen = 1 + 1 + m_RxDataLen; // stx+etx+data(id~crc)
                    m_RxState = RX_DATA;
                }
             }
             break;

        case RX_DATA:
             // 나머지 데이터에 대한 유효성 처리는 하지 않는다.(ETX 체크안함)
             m_RxBuff[m_RxLen++] = data;
             if (m_RxLen == m_RxPktLen)
             {
                //패킷완성
                result = ProcessRecvPacket(m_RxBuff, m_RxPktLen);
                InitRx();
                m_WatchDogTimer = Now();
             }
             break;
        }
    }

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

/*
 * 수신 패킷 처리
 *  arguments
 *   void
 *  return
 *   void
 */
int __fastcall TVMSCThread::ProcessRecvPacket(BYTE *ABuffer, int ARcvLen)
{
FErrLine = 4;
    VMS_PACKET *Pkt    = (VMS_PACKET*)ABuffer;
	int         result = SYS_ERR_NONE;

    InfoPacket(ABuffer, ARcvLen, false);

    switch(Pkt->hd.OpCode)
    {
    case RES_VMS_STATUS://                   0x50        // Status 응답,  VMS->센터
        result = ResVmsStatus(ABuffer, ARcvLen);
        break;
    case RES_VMS_MSG_DOWNLOAD://             0x51        // 문안 전송 응답, VMS->센터
        result = ResVmsMsgDownload(ABuffer, ARcvLen);
        break;
    case RES_VMS_LIB_DOWNLOAD://             0x52        // Library download 응답, VMS->센터
        result = ResVmsLibDownload(ABuffer, ARcvLen);
        break;
    case RES_VMS_PARAM_DOWNLOAD://           0x53        // Parameter download 응답, VMS->센터
        break;
    case RES_VMS_BLANK_DISP://               0x54        // Blank 응답, VMS->센터
        break;
    case RES_VMS_DEF_MSG_DISP://             0x55        // Default message display 응답, VMS->센터
        break;
    case RES_VMS_MODULE_STATUS://            0x56        // Module status upload 응답, VMS->센터
        result = ResVmsModuleStatus(ABuffer, ARcvLen);
        break;
    case RES_VMS_INITIALIZE://               0x57        // Initialize 응답, VMS->센터
        result = ResVmsInitialize(ABuffer, ARcvLen);
        break;
    case RES_VMS_LUMINANCE_LEVEL_SET://      0x58        // Luminance level set 응답, VMS->센터
        break;
    case RES_SIGNBOARD_POWER_CONTROL://      0x59        // Signboard power control 응답, VMS->센터
        result = ResVmsSignboardPowerControl(ABuffer, ARcvLen);
        break;
    default:
        LERROR("<<< Unknown ProcessRecvPacket: 0x%02X", Pkt->hd.OpCode);
        return SYS_ERR_UNKNOWN_COMMAND;
    }

	if (result == SYS_ERR_NONE)
    {
		FClient.sendRetry = VMS_MAX_RETRY_COUNT;
	}

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

// Initialize 요청 응답
int __fastcall TVMSCThread::ResVmsInitialize(BYTE *ABuffer, int ARcvLen)
{
    VMS_PACKET *Pkt    = (VMS_PACKET*)ABuffer;
	int         result = SYS_ERR_NONE;

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

// Signboard powwer control 요청 응답
int __fastcall TVMSCThread::ResVmsSignboardPowerControl(BYTE *ABuffer, int ARcvLen)
{
    VMS_PACKET *Pkt    = (VMS_PACKET*)ABuffer;
	int         result = SYS_ERR_NONE;

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

// VMS 상태정보 요청 응답
int __fastcall TVMSCThread::ResVmsStatus(BYTE *ABuffer, int ARcvLen)
{
    VMS_PACKET *Pkt    = (VMS_PACKET*)ABuffer;
	int         result = SYS_ERR_NONE;
    ACK_NAK     res;

    if (FClient.State == CT_CLIENT_WAIT)
    {
        //TODO: 클라이언트로 결과전송
    }

    if (FLocalCmd.obj == OBJ_GeneralStatus)
    {
        FLocalCmd.GeneralStatus = true;
    }

    if (FClient.State == CT_CLIENT_WAIT)
        FClient.State = CT_CLIENT_COMMAND;
    else
    if (FClient.State == CT_LOCAL_WAIT)
        FClient.State = CT_LOCAL_COMMAND;

    SaveStatusData(ABuffer);

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

/*
 *
 *  arguments
 *   void
 *  return
 *   void
 */
int __fastcall TVMSCThread::SaveStatusData(BYTE *pGS)
{
	int         result = SYS_ERR_OTHER;
    VMS_STATUS1 status1;
    VMS_STATUS2 status2;
    short        temp;

	if (m_pState == NULL) return result;

#if 0
typedef struct tagVmsStatus1
{
    BYTE localModeActive  : 1;
    BYTE defaultParameter : 1;
    BYTE resetOccured     : 1;
    BYTE longPowerFail    : 1;
    BYTE shortPowerFail   : 1;
    BYTE doorOpen         : 1;
    BYTE moduleErrRateOver: 1;
    BYTE ramRomError      : 1;
} VMS_STATUS1;

typedef struct tagVmsStatus2
{
    BYTE libChecksumErr: 1;
    BYTE fan           : 1;
    BYTE heater        : 1;
    BYTE boardPower    : 1;
    BYTE boardPowerFail: 1;
    BYTE blankDisp     : 1;
    BYTE sirenFail     : 1;
    BYTE reserved      : 1;
} VMS_STATUS2;
#endif
    memcpy((char*)&status2, (char*)&pGS[11], sizeof(BYTE));
    memcpy((char*)&status1, (char*)&pGS[12], sizeof(BYTE));
    temp = (short)pGS[13];

    m_pState->DoorStatus        = status1.doorOpen   == 0x01 ? vms_open : vms_close;
    m_pState->ModulePowerStatus = status2.boardPower == 0x01 ? vms_on   : vms_off;
    m_pState->FanStatus         = status2.fan        == 0x01 ? vms_on   : vms_off;
    m_pState->HeaterStatus      = status2.heater     == 0x01 ? vms_on   : vms_off;
	m_pState->BodyTemp          = temp;
	m_pState->LuminanceStatus   = 0;  //PASIG 없음
    m_pState->ModuleState       = status1.moduleErrRateOver == 0x01 ? vms_error : vms_normal;

LDEBUG("     module_StatusCode: %2d, %s", status1.moduleErrRateOver, m_pState->ModuleState       == vms_normal ? "Normal" : "Error");
LDEBUG("modulePower_StatusCode: %2d, %s", status2.boardPower,        m_pState->ModulePowerStatus == vms_on     ? "On"     : "Off");
LDEBUG("       door_StatusCode: %2d, %s", status1.doorOpen,          m_pState->DoorStatus        == vms_open   ? "Open"   : "Close");
LDEBUG("        fan_StatusCode: %2d, %s", status2.fan,               m_pState->FanStatus         == vms_on     ? "On"     : "Off");
LDEBUG("     heater_StatusCode: %2d, %s", status2.heater,            m_pState->HeaterStatus      == vms_on     ? "On"     : "Off");
LDEBUG("   body_TemperatureQty: %2d, %d", temp,                      m_pState->BodyTemp         );
//LDEBUG("   luminance_StatusQty: %2d, %d", m_pState->LuminanceStatus, m_pState->LuminanceStatus  );

	result = SYS_ERR_NONE;

    //if (FGenState && FModState && FPowState)
    {
        //FGenState = FModState = FPowState = false;
        POST_MSG(MAINHANDLE, WM_VMS_THREAD, WM_VMS_STATE_STTS, (int)FVmsObj);
    }
	return result;
}
//---------------------------------------------------------------------------

// VMS 상태정보 요청 응답
int __fastcall TVMSCThread::ResVmsModuleStatus(BYTE *ABuffer, int ARcvLen)
{
    VMS_PACKET *Pkt    = (VMS_PACKET*)ABuffer;
	int         result = SYS_ERR_NONE;

    if (FClient.State == CT_CLIENT_WAIT)
    {
        //TODO: 클라이언트로 결과전송
    }

    if (FLocalCmd.obj == OBJ_ModuleStatus)
    {
        FLocalCmd.ModuleStatus = true;
    }

    if (FClient.State == CT_CLIENT_WAIT)
        FClient.State = CT_CLIENT_COMMAND;
    else
    if (FClient.State == CT_LOCAL_WAIT)
        FClient.State = CT_LOCAL_COMMAND;

    BYTE ModuleState;
    memset((char*)m_pState->ModuleStatus, 0x00, sizeof(m_pState->ModuleStatus));
    //INT_VMS_MAX_MODULE_BIT
    int nBytes = (int)CommUtil_swapl(Pkt->hd.Size);
    nBytes -= 12;
    if (FLogFile->FLogCfg.Debug)
    {
    LDEBUG("ModuleInfo Bytes: %d, %d", nBytes, nBytes*8);
        for (int ii = 0; ii < nBytes; ii++)
        {
    LDEBUG("                : %d, %02X", ii, Pkt->data[ii]);
        }
    }

    memcpy((char*)m_pState->ModuleStatus, (char*)Pkt->data, nBytes);
	return result;
}
//---------------------------------------------------------------------------

// VMS MSG Download 요청 응답
int __fastcall TVMSCThread::ResVmsMsgDownload(BYTE *ABuffer, int ARcvLen)
{
    VMS_PACKET *Pkt    = (VMS_PACKET*)ABuffer;
	int         result = SYS_ERR_NONE;

    try
    {
        m_pVmsFormList->Lock();

        int nFormCnt = m_pVmsFormList->Count();
        for (int ii = 0; ii < nFormCnt; ii++)
        {
            TVmsForm *pVmsForm = m_pVmsFormList->GetItem(ii);
            if (!pVmsForm) continue;

            pVmsForm->SvcRes = true;
        }
    }
    __finally
    {
        m_pVmsFormList->UnLock();
    }

    if (FLocalCmd.obj == OBJ_RealTimeDisplay)
    {
        SAVE_STRUCT ProvideSave;

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

        ProvideSave.Type    = save_provide;
        ProvideSave.Count   = 1;
        ProvideSave.pObj[0] = (void*)FVmsObj;

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


        if ((result = SendDbThreadDataMessage(WM_PROVIDE_SAVE, &ProvideSave, sizeof(ProvideSave))) != VERR_NONE)
        {
            SERROR("SendDbThreadDataMessage Error %d", result);
        }
    }

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

// VMS LIB Download 요청 응답
int __fastcall TVMSCThread::ResVmsLibDownload(BYTE *ABuffer, int ARcvLen)
{
    VMS_PACKET *Pkt    = (VMS_PACKET*)ABuffer;
	int         result = SYS_ERR_NONE;

    try
    {
        m_pVmsFormList->Lock();

        int nFormCnt = m_pVmsFormList->Count();
        for (int ii = 0; ii < nFormCnt; ii++)
        {
            TVmsForm *pVmsForm = m_pVmsFormList->GetItem(ii);
            if (!pVmsForm) continue;

            pVmsForm->SvcRes = true;
        }
    }
    __finally
    {
        m_pVmsFormList->UnLock();
    }

    if (FLocalCmd.obj == OBJ_RealTimeDisplay)
    {
        SAVE_STRUCT ProvideSave;

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

        ProvideSave.Type    = save_provide;
        ProvideSave.Count   = 1;
        ProvideSave.pObj[0] = (void*)FVmsObj;

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


        if ((result = SendDbThreadDataMessage(WM_PROVIDE_SAVE, &ProvideSave, sizeof(ProvideSave))) != VERR_NONE)
        {
            SERROR("SendDbThreadDataMessage Error %d", result);
        }
    }

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