ITS_OP/VmsCommonLib/CenterComm/CenterCommF.cpp

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

#include <vcl.h>
#include <windows.h>
#pragma hdrstop

//---------------------------------------------------------------------------
#include "CenterCommF.h"
//#include "CenterProtocolF.h"
#include "DMNetServerF.h"
//---------------------------------------------------------------------------
#define MIN(a,b) (((a)<(b))?(a):(b))
#define MAX(a,b) (((a)>(b))?(a):(b))
//---------------------------------------------------------------------------

DWORD CComm_CheckIpAddress(char *ABuff)
{
    BYTE          add[4], i;
    unsigned long val;

    for (i = 0; i < 4; i++, ABuff++)
    {
        if ((val = strtoul(ABuff, &ABuff, 0)) > 255) return 0;

        add[i] = (BYTE)val;

        if(i < 3 && *ABuff != '.')return 0;
    }

    if(*(DWORD *)&add == 0 ||
       *(DWORD *)&add == 0xFFFFFFFF) return 0;

    return *(DWORD *)&add;
}
//---------------------------------------------------------------------------

int CheckDigit(AnsiString Str)
{
	int ii;

    if(Str.Length() == 0) return S_FAIL;

	for (ii = 1; ii <= Str.Length(); ii++)
    {
        if(!isdigit(Str [ii]))return S_FAIL;
    }

    return S_SUCC;
}
//---------------------------------------------------------------------------

int CheckPort(AnsiString Port)
{
    if (CheckDigit(Port) ||
        Port.ToInt() < 0 || Port.ToInt() > 65535) return S_FAIL;

    return Port.ToInt();
}
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
DWORD ip2ulong(char *AIp);
char *ulong2ip(DWORD AIp);
//---------------------------------------------------------------------------
DWORD CComm_ip2ulong(char *AIp)
{
    return ip2ulong(AIp);
}
//---------------------------------------------------------------------------
char* CComm_ulong2ip(DWORD AIp)
{
    return ulong2ip(AIp);
}
//---------------------------------------------------------------------------

int CComm_SetBitString(char *ABuff, int ABit, int AOnOff/*=1*/)
{
    if (AOnOff == 1)
        ABuff[ABit / 8] |= (1 << (7 - (ABit % 8)));
    else
    {
        ABuff[ABit / 8] &= ~(1 << (7 - (ABit % 8)));
    }
    return VERR_NONE;
}
/*--------------------------------------------------------------------------*/

int CComm_GetBitString(char *ABuff, int ABit)
{
    return ((ABuff[ABit / 8] & (1 << (7 - (ABit % 8)))) ? 1 : 0);
}
/*--------------------------------------------------------------------------*/

#pragma pack(push, 1)
typedef struct
{
    BYTE val0 : 2;
    BYTE val1 : 2;
    BYTE val2 : 2;
    BYTE val3 : 2;
} BIT_2;

typedef union
{
    BYTE    cc;
    BIT_2   bit;
} TWOBIT;
#pragma pack(pop)

int CComm_SetBitValue(BYTE *ABuff, int ABit, int AValue)
{
    TWOBIT u;
    int nMok = ABit / 4;
    int nNam = ABit % 4;

    u.cc = ABuff[nMok];
    switch(nNam)
    {
    case 0: u.bit.val0 = AValue; break;
    case 1: u.bit.val1 = AValue; break;
    case 2: u.bit.val2 = AValue; break;
    case 3: u.bit.val3 = AValue; break;
    }
    ABuff[nMok] = u.cc;

    return VERR_NONE;
}
/*--------------------------------------------------------------------------*/
int CComm_GetBitValue(BYTE *ABuff, int ABit)
{
    int    res = 0;
    TWOBIT u;
    int nMok = ABit / 4;
    int nNam = ABit % 4;

    u.cc = ABuff[nMok];
    switch(nNam)
    {
    case 0: res = u.bit.val0; break;
    case 1: res = u.bit.val1; break;
    case 2: res = u.bit.val2; break;
    case 3: res = u.bit.val3; break;
    }

    return res;
}
/*--------------------------------------------------------------------------*/

int CComm_Initialize(long AHandle, AnsiString ATrsPrcsid, AnsiString FRcvPrcsId, int ABindPort)
{
    int nResult = VERR_NONE;

    if (!DMNetServer) {
        try {
            DMNetServer = new TDMNetServer(NULL);
        }
        catch(Exception &e) {
            nResult = VERR_OTHER;
        }
    }
    DMNetServer->FHandle = (HWND)AHandle;
    DMNetServer->FTrsPrcsId = ATrsPrcsid;
    DMNetServer->FRcvPrcsId = FRcvPrcsId;
    DMNetServer->FBindPort  = ABindPort;
    DMNetServer->FPktSeq    = 0x00;

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

int CComm_Terminate()
{
    //CComm_Close();

    if (DMNetServer) {
        delete DMNetServer;
        DMNetServer = NULL;
    }
    return VERR_NONE;
}
//---------------------------------------------------------------------------

void FillVmsReqHead(HEADER *AHeader, int ADataSize)
{
    AHeader->Stx        = PKT_STX;
    AHeader->Seq        = DMNetServer->GetNextPktSeq();
    AHeader->MsgCl      = 0x00;         // 0x11 : 데이터 전송 시작, 0x01 : 데이터 전송 계속, 0x00 : 데이터 전송 종료, Default : 0x00
    AHeader->RespTp     = 0x00;         // 0:Without Response, 1:With Response
    AHeader->SendNodeId = OPER_NODE_ID;
    AHeader->SendTaskId = OPER_TASK_ID;
    AHeader->SendTaskNo = PRCS_TASK_NO;
    AHeader->RecvNodeId = VMSP_NODE_ID;
    AHeader->RecvTaskId = VMSP_TASK_ID;
    AHeader->RecvTaskNo = PRCS_TASK_NO;
    AHeader->SystemCode = OPE_SYSTEM_CD;
    AHeader->OpCode     = OP_CTRL_VMS;
    AHeader->BodySize   = htonl(ADataSize);
}
//---------------------------------------------------------------------------
void FillVmsReqTail(TAIL *ATail)
{
    ATail->Crc = 0x00;
    ATail->Etx = PKT_ETX;
}
//---------------------------------------------------------------------------

void FillVmsControl(BYTE ACommand, VMS_CONTROL *AControl, String AOperId, String AVmsId)
{
    AnsiString sReqTime = Now().FormatString("yyyymmddhhnnss");

    strcpy(AControl->OperId,  AnsiString(AOperId).c_str());      /* 운영자 ID */
    strcpy(AControl->VmsId,   AnsiString(AVmsId).c_str());       /* VMS ID */
    //memcpy(AControl->OperId,  AnsiString(AOperId).c_str(), OPER_ID_SZ);      /* 운영자 ID */
    //memcpy(AControl->VmsId,   AnsiString(AVmsId).c_str(),  VMS_ID_SZ);       /* VMS ID */
    memcpy(AControl->ReqTime, sReqTime.c_str(), DATETIME_SZ);     /* 명령수행시각 */

    AControl->Command = ACommand;
}

int CComm_VmsReqReset(String ADstIpAddr, int ADstPort, String AOperId, String AVmsId)
{
    VMS_REQ_RESET req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsReqHead(&req.Head, sizeof(req.Control));

    FillVmsControl('X', &req.Control, AOperId, AVmsId);

    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------

int CComm_VmsReqBlank(String ADstIpAddr, int ADstPort, String AOperId, String AVmsId)
{
    VMS_REQ_BLANK req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsReqHead(&req.Head, sizeof(req.Control));

    FillVmsControl('B', &req.Control, AOperId, AVmsId);

    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------

int CComm_VmsReqCmncErrMin(String ADstIpAddr, int ADstPort, String AOperId, String AVmsId, BYTE AErrMin)
{
    VMS_REQ_ERR_MIN req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsReqHead(&req.Head, sizeof(req.Control)+1);

    FillVmsControl('P', &req.Control, AOperId, AVmsId);

    req.ErrMin = AErrMin;

    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------

int CComm_VmsReqModlErrRate(String ADstIpAddr, int ADstPort, String AOperId, String AVmsId, BYTE AErrRate)
{
    VMS_REQ_ERR_NODL req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsReqHead(&req.Head, sizeof(req.Control)+1);

    FillVmsControl('M', &req.Control, AOperId, AVmsId);

    req.ErrRate = AErrRate;

    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------

int CComm_VmsReqLumiSet(String ADstIpAddr, int ADstPort, String AOperId, String AVmsId, BYTE ALumiMode, BYTE AValue)
{
    VMS_REQ_LUMI req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsReqHead(&req.Head, sizeof(req.Control)+1);

    FillVmsControl('L', &req.Control, AOperId, AVmsId);

    req.LumiMode = ALumiMode;
    req.Value    = AValue;

    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------

int CComm_VmsReqPowerOnOff(String ADstIpAddr, int ADstPort, String AOperId, String AVmsId, bool AOnOff/*true:on,false:off*/)
{
    VMS_REQ_POWER req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsReqHead(&req.Head, sizeof(req.Control)+1);

    FillVmsControl('S', &req.Control, AOperId, AVmsId);

    req.Power = AOnOff ? 0x01 : 0x00;

    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------

int CComm_VmsReqDbScenario(String ADstIpAddr, int ADstPort, String AOperId, String AVmsId, VMS_DB_SCNR *ADbScnr)
{
    VMS_REQ_DB_SCENARIO req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsReqHead(&req.Head, sizeof(req.Control)+1+sizeof(VMS_DB_SCNR));

    FillVmsControl('D', &req.Control, AOperId, AVmsId);

    memcpy((char*)&req.Scnr, (char*)ADbScnr, sizeof(VMS_DB_SCNR));

    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------

void FillVmsNotiHead(BYTE AOpCode, HEADER *AHeader, int ADataSize)
{
    AHeader->Stx        = PKT_STX;
    AHeader->Seq        = DMNetServer->GetNextPktSeq();
    AHeader->MsgCl      = 0x00;         // 0x11 : 데이터 전송 시작, 0x01 : 데이터 전송 계속, 0x00 : 데이터 전송 종료, Default : 0x00
    AHeader->RespTp     = 0x00;         // 0:Without Response, 1:With Response
    AHeader->SendNodeId = OPER_NODE_ID;
    AHeader->SendTaskId = OPER_TASK_ID;
    AHeader->SendTaskNo = PRCS_TASK_NO;
    AHeader->RecvNodeId = VMSM_NODE_ID;
    AHeader->RecvTaskId = VMSM_TASK_ID;
    AHeader->RecvTaskNo = PRCS_TASK_NO;
    AHeader->SystemCode = OPE_SYSTEM_CD;
    AHeader->OpCode     = AOpCode;
    AHeader->BodySize   = htonl(ADataSize);
}
//---------------------------------------------------------------------------

int CComm_VmsNotiRegIncident(String ADstIpAddr, int ADstPort)
{
    VMS_NOTI_REG_INCD req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsNotiHead(OP_REG_INCIDENT, &req.Head, 0);
    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------
int CComm_VmsNotiRegDsplMsg(String ADstIpAddr, int ADstPort)
{
    VMS_NOTI_REG_DSPL_MSG req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsNotiHead(OP_REG_DISP_VMS_MSG, &req.Head, 0);
    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------
int CComm_VmsNotiRegDfltMsg(String ADstIpAddr, int ADstPort, String AVmsId)
{
    VMS_NOTI_REG_DFLT_MSG req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsNotiHead(OP_REG_DFLT_VMS_MSG, &req.Head, sizeof(NOTI_VMS));

    strcpy(req.Data.VmsId, AnsiString(AVmsId).c_str());       /* VMS ID */

    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------
int CComm_VmsNotiRegEmgnMsg(String ADstIpAddr, int ADstPort, String AVmsId)
{
    VMS_NOTI_REG_EMGN_MSG req;
    memset((char*)&req, 0x00, sizeof(req));

    FillVmsNotiHead(OP_REG_EMER_VMS_MSG, &req.Head, sizeof(NOTI_VMS));

    strcpy(req.Data.VmsId, AnsiString(AVmsId).c_str());       /* VMS ID */

    FillVmsReqTail(&req.Tail);

    return DMNetServer->SendData(ADstIpAddr, ADstPort, (BYTE*)&req, sizeof(req));
}
//---------------------------------------------------------------------------

int CComm_Close()
{
    if (DMNetServer)
    {
        DMNetServer->Close();
    }
    return VERR_NONE;
}
//---------------------------------------------------------------------------

int CComm_GetPort()
{
    return DMNetServer->GetPort();
}
//---------------------------------------------------------------------------

String CComm_GetIP()
{
    return DMNetServer->GetIP();
}
//---------------------------------------------------------------------------

int CComm_Open(int ABuffSize/*=8192*/)
{
    return DMNetServer->Open(ABuffSize);
}
//---------------------------------------------------------------------------